SyllabusController.cs 6.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168
  1. using Microsoft.AspNetCore.Mvc;
  2. using System.Collections.Generic;
  3. using System.Threading.Tasks;
  4. using TEAMModelOS.Service.Models.Syllabus;
  5. using TEAMModelOS.SDK.Context.Exception;
  6. using TEAMModelOS.SDK.Extension.DataResult.JsonRpcRequest;
  7. using TEAMModelOS.SDK.Extension.DataResult.JsonRpcResponse;
  8. using TEAMModelOS.SDK.Extension.SnowFlake;
  9. using TEAMModelOS.SDK.Module.AzureCosmosDB.Interfaces;
  10. using TEAMModelOS.SDK.Helper.Common.CollectionHelper;
  11. using System;
  12. using TEAMModelOS.SDK.Helper.Common.JsonHelper;
  13. using System.Linq;
  14. namespace TEAMModelOS.Controllers.Syllabus
  15. {
  16. [Route("api/[controller]")]
  17. [ApiController]
  18. //[Authorize]
  19. public class SyllabusController : BaseController
  20. {
  21. private readonly IAzureCosmosDBRepository azureCosmosDBRepository;
  22. public SyllabusController(IAzureCosmosDBRepository _azureCosmosDBRepository)
  23. {
  24. azureCosmosDBRepository = _azureCosmosDBRepository;
  25. }
  26. /// <summary>
  27. /// 批量保存或更新课纲
  28. /// </summary>
  29. /// <param name="request"></param>
  30. /// <returns></returns>
  31. [HttpPost("SaveOrUpdateAsTree")]
  32. public async Task<BaseJosnRPCResponse> SaveOrUpdateAsTree(JosnRPCRequest<List<SyllabusTree>> request)
  33. {
  34. JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
  35. List<SyllabusNode> nodes = new List<SyllabusNode>();
  36. TreeToList(request.@params, nodes);
  37. // List<SyllabusNode> nods = nodes.ToJson().FromJson<List<SyllabusNode>>() ;
  38. await azureCosmosDBRepository.SaveAll<SyllabusNode>(nodes);
  39. List<SyllabusTree> treess = ListToTree(nodes);
  40. return builder.Data(treess).build();
  41. }
  42. public static List<SyllabusNode> TreeToList(List<SyllabusTree> trees, List<SyllabusNode> nodes)
  43. {
  44. trees = trees.OrderBy(x => x.order).ToList();
  45. nodes.AddRange(trees.ToJson().FromJson<List<SyllabusNode>>());
  46. foreach (SyllabusTree tree in trees)
  47. {
  48. if (null != tree.children && tree.children.Count > 0)
  49. {
  50. TreeToList(tree.children, nodes);
  51. }
  52. }
  53. return nodes;
  54. }
  55. /// <summary>
  56. /// 批量保存或更新课纲
  57. /// </summary>
  58. /// <param name="request"></param>
  59. /// <returns></returns>
  60. [HttpPost("SaveOrUpdateAsNodes")]
  61. public async Task<BaseJosnRPCResponse> SaveOrUpdateAsNodes(JosnRPCRequest<List<SyllabusNode>> request) {
  62. JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
  63. List<SyllabusNode> nodes = await azureCosmosDBRepository.SaveAll<SyllabusNode>(request.@params);
  64. return builder.Data(nodes).build();
  65. }
  66. private static List<SyllabusTree> ListToTree(List<SyllabusNode> noes)
  67. {
  68. List<SyllabusTree> list = noes.ToJson().FromJson<List<SyllabusTree>>();
  69. //var lookup = list.ToDictionary(n => n.RowKey, n => n);
  70. var res = from r in list group r by r.id into g select g;
  71. Dictionary<string, SyllabusTree> blockDict = new Dictionary<string, SyllabusTree>();
  72. foreach (var s in res)
  73. {
  74. blockDict.TryAdd(s.First().id, s.First());
  75. }
  76. return GetChild(list, blockDict);
  77. }
  78. public static List<SyllabusTree> GetChild(List<SyllabusTree> list, Dictionary<string, SyllabusTree> dict)
  79. {
  80. // list = list.OrderBy(m => m.Order).ToList();
  81. List<SyllabusTree> trees = new List<SyllabusTree>();
  82. foreach (SyllabusTree node in list)
  83. {
  84. bool flag = dict.TryGetValue(node.pid, out SyllabusTree syllabus);
  85. if (flag && syllabus != null)
  86. {
  87. syllabus.children.Add(node);
  88. }
  89. else
  90. {
  91. trees.Add(node);
  92. }
  93. }
  94. return trees;
  95. }
  96. /// <summary>
  97. /// 删除课纲
  98. /// </summary>
  99. /// <param name="request"></param>
  100. /// <returns></returns>
  101. [HttpPost("Delete")]
  102. public async Task<BaseJosnRPCResponse> Delete(JosnRPCRequest<Dictionary<string, object>> request)
  103. {
  104. bool flag = false;
  105. JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
  106. List<SyllabusNode> nodes = new List<SyllabusNode>();
  107. List<SyllabusNode> data = await azureCosmosDBRepository.FindByDict<SyllabusNode>(request.@params, true);
  108. if (data.IsNotEmpty())
  109. {
  110. await FindByPid(data, nodes, azureCosmosDBRepository);
  111. if (nodes.IsNotEmpty()) {
  112. nodes.ForEach(async e => {
  113. await azureCosmosDBRepository.DeleteAsync<SyllabusNode>(e.id, e.volumeCode);
  114. });
  115. flag = true;
  116. }
  117. }
  118. else {
  119. throw new BizException("数据不存在", ResponseCode.DATA_EMPTY_NULL);
  120. }
  121. return builder.Data(flag).Extend(new Dictionary<string, object>() { { "deleteData",nodes } }).build();
  122. }
  123. public static async Task<List<SyllabusNode>> FindByPid(List<SyllabusNode> data, List<SyllabusNode> nodes , IAzureCosmosDBRepository azureCosmosDBRepository) {
  124. nodes.AddRange(data);
  125. foreach (SyllabusNode node in data)
  126. {
  127. List<SyllabusNode> syllabusNodes= await azureCosmosDBRepository.FindByDict<SyllabusNode>(new Dictionary<string, object>() { { "pid", node.id } }, true);
  128. if (syllabusNodes.IsNotEmpty()) {
  129. await FindByPid(syllabusNodes, nodes ,azureCosmosDBRepository);
  130. }
  131. }
  132. return nodes;
  133. }
  134. /// <summary>
  135. /// 查找课纲
  136. /// </summary>
  137. /// <param name="request"></param>
  138. /// <returns></returns>
  139. [HttpPost("Find")]
  140. public async Task<BaseJosnRPCResponse> Find(JosnRPCRequest<Dictionary<string, object>> request)
  141. {
  142. JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
  143. List<SyllabusNode> data =await azureCosmosDBRepository.FindByDict<SyllabusNode>(request.@params);
  144. if (request.@params.TryGetValue("id", out object id))
  145. {
  146. List<SyllabusNode> nodes = new List<SyllabusNode>();
  147. if (data.IsNotEmpty()) {
  148. await FindByPid(data, nodes, azureCosmosDBRepository);
  149. data = nodes;
  150. }
  151. }
  152. List<SyllabusTree> treess = ListToTree(data);
  153. return builder.Data(treess).build();
  154. }
  155. }
  156. }