VolumeController.cs 8.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181
  1. using Microsoft.AspNetCore.Mvc;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Linq;
  5. using System.Text;
  6. using System.Threading.Tasks;
  7. using TEAMModelOS.Service.Models.Core;
  8. using TEAMModelOS.Service.Models.Syllabus;
  9. using TEAMModelOS.SDK.Context.Exception;
  10. using TEAMModelOS.SDK.Extension.DataResult.JsonRpcRequest;
  11. using TEAMModelOS.SDK.Extension.DataResult.JsonRpcResponse;
  12. using TEAMModelOS.SDK.Extension.SnowFlake;
  13. using TEAMModelOS.SDK.Helper.Common.CollectionHelper;
  14. using TEAMModelOS.SDK.Helper.Security.ShaHash;
  15. using TEAMModelOS.SDK.Module.AzureCosmosDB.Interfaces;
  16. using TEAMModelOS.Controllers;
  17. namespace TEAMModelOS.Controllers.Syllabus
  18. {
  19. [Route("api/[controller]")]
  20. [ApiController]
  21. public class VolumeController : BaseController
  22. {
  23. private readonly IAzureCosmosDBRepository azureCosmosDBRepository;
  24. public VolumeController(IAzureCosmosDBRepository _azureCosmosDBRepository)
  25. {
  26. azureCosmosDBRepository = _azureCosmosDBRepository;
  27. }
  28. /// <summary>
  29. /// 新增册别
  30. /// </summary>
  31. /// <param name="request"></param>
  32. /// <returns></returns>
  33. [HttpPost("SaveOrUpdate")]
  34. public async Task<BaseJosnRPCResponse> SaveOrUpdate(JosnRPCRequest<Volume> request)
  35. {
  36. JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
  37. if (request.@params.editors != null && request.@params.editors.Length > 5)
  38. {
  39. throw new BizException("共编人数大于5人!");
  40. }
  41. if (string.IsNullOrEmpty(request.@params.id))
  42. {
  43. if (request.@params.type == 0)
  44. {
  45. List<Volume> volumesFind = await azureCosmosDBRepository.FindByDict<Volume>(new Dictionary<string, object>() {
  46. { "schoolCode",request.@params.schoolCode},{ "periodCode", request.@params.periodCode},
  47. { "subjectCode", request.@params.subjectCode},{ "gradeCode", request.@params.gradeCode},
  48. { "semesterCode",request.@params.gradeCode},{ "volumeName",request.@params.volumeName} ,
  49. { "status",1} ,{ "type",0} }, true);
  50. if (volumesFind.IsNotEmpty())
  51. {
  52. throw new BizException("已存在!", 500);
  53. }
  54. ///校本课纲
  55. string key = request.@params.schoolCode + IdWorker.getInstance().NextId();
  56. request.@params.id = key;
  57. request.@params.volumeCode = key;
  58. }
  59. else if (request.@params.type == 1)
  60. {
  61. List<Volume> volumesFind = await azureCosmosDBRepository.FindByDict<Volume>(new Dictionary<string, object>() {
  62. { "schoolCode",request.@params.schoolCode},{ "periodCode", request.@params.periodCode},
  63. { "subjectCode", request.@params.subjectCode},{ "gradeCode", request.@params.gradeCode},
  64. { "semesterCode",request.@params.gradeCode},{ "volumeName",request.@params.volumeName},
  65. { "TEAMModelId",request.@params.TEAMModelId}, { "status",1} ,{ "type",1} }, true);
  66. if (volumesFind.IsNotEmpty())
  67. {
  68. throw new BizException("已存在!", 500);
  69. }
  70. ///个人课纲
  71. string key = "dynamic" + request.@params.TEAMModelId.Replace("#", "") + IdWorker.getInstance().NextId();
  72. request.@params.id = key;
  73. request.@params.volumeCode = key;
  74. }
  75. else if (request.@params.type == 2)
  76. {
  77. ///系统课纲
  78. string key = "system" + IdWorker.getInstance().NextId();
  79. request.@params.schoolCode = "system";
  80. request.@params.id = key;
  81. request.@params.volumeCode = key;
  82. }
  83. }
  84. else {
  85. if (request.@params.type == 0)
  86. {
  87. List<Volume> volumesFind = await azureCosmosDBRepository.FindByDict<Volume>(new Dictionary<string, object>() {
  88. { "schoolCode",request.@params.schoolCode},{ "periodCode", request.@params.periodCode},
  89. { "subjectCode", request.@params.subjectCode},{ "gradeCode", request.@params.gradeCode},
  90. { "semesterCode",request.@params.gradeCode},{ "volumeName",request.@params.volumeName} ,
  91. { "status",1} ,{ "type",0} }, true);
  92. if (volumesFind.IsNotEmpty())
  93. {
  94. if (!volumesFind[0].id.Equals(request.@params.id)) {
  95. throw new BizException("已存在!", 500);
  96. }
  97. }
  98. }
  99. else if (request.@params.type == 1)
  100. {
  101. List<Volume> volumesFind = await azureCosmosDBRepository.FindByDict<Volume>(new Dictionary<string, object>() {
  102. { "schoolCode",request.@params.schoolCode},{ "periodCode", request.@params.periodCode},
  103. { "subjectCode", request.@params.subjectCode},{ "gradeCode", request.@params.gradeCode},
  104. { "semesterCode",request.@params.gradeCode},{ "volumeName",request.@params.volumeName},
  105. { "TEAMModelId",request.@params.TEAMModelId}, { "status",1} ,{ "type",1} }, true);
  106. if (volumesFind.IsNotEmpty())
  107. {
  108. if (!volumesFind[0].id.Equals(request.@params.id))
  109. {
  110. throw new BizException("已存在!", 500);
  111. }
  112. }
  113. }
  114. else if (request.@params.type == 2)
  115. {
  116. }
  117. }
  118. List<Volume> volumes = new List<Volume>
  119. {
  120. request.@params
  121. };
  122. List<Volume> volume = await azureCosmosDBRepository.SaveAll<Volume>(volumes);
  123. return builder.Data(volume.IsEmpty() ? null : volume[0]).build();
  124. }
  125. /// <summary>
  126. /// 删除册别
  127. /// </summary>
  128. /// <param name="request"></param>
  129. /// <returns></returns>
  130. [HttpPost("Delete")]
  131. public async Task<BaseJosnRPCResponse> Delete(JosnRPCRequest<Volume> request)
  132. {
  133. JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
  134. bool flag = false;
  135. if (!string.IsNullOrEmpty(request.@params.id))
  136. {
  137. //if (request.@params.type == 0)
  138. //{
  139. request.@params.status = 0;
  140. List<Volume> volumes = new List<Volume>
  141. {
  142. request.@params
  143. };
  144. await azureCosmosDBRepository.SaveAll<Volume>(volumes);
  145. flag = true;
  146. //}
  147. //else
  148. //{
  149. // await azureCosmosDBRepository.DeleteAsync<Volume>(request.@params.id, request.@params.schoolCode);
  150. // await azureCosmosDBRepository.DeleteAll<SyllabusNode>(new Dictionary<string, object>() { { "volumeCode", request.@params.id } });
  151. // flag = true;
  152. //}
  153. }
  154. return builder.Data(flag).build();
  155. }
  156. /// <summary>
  157. /// 查找册别
  158. /// </summary>
  159. /// <param name="request"></param>
  160. /// <returns></returns>
  161. [HttpPost("Find")]
  162. public async Task<BaseJosnRPCResponse> Find(JosnRPCRequest<Dictionary<string, object>> request)
  163. {
  164. JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
  165. List<Volume> volumes ;
  166. if (request.@params.TryGetValue("schoolCode", out _))
  167. {
  168. volumes = await azureCosmosDBRepository.FindByParams<Volume>(request.@params);
  169. }
  170. else
  171. {
  172. throw new BizException("schoolCode is null!");
  173. }
  174. return builder.Data(volumes).build();
  175. }
  176. }
  177. }