AbilityTaskMgmtController.cs 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281
  1. using Microsoft.AspNetCore.Http;
  2. using Microsoft.AspNetCore.Mvc;
  3. using System;
  4. using System.Collections.Generic;
  5. using System.Linq;
  6. using System.Threading.Tasks;
  7. using Microsoft.Extensions.Configuration;
  8. using TEAMModelOS.SDK.DI;
  9. using TEAMModelOS.Models;
  10. using Microsoft.Extensions.Options;
  11. using System.Text.Json;
  12. using TEAMModelOS.SDK.Models;
  13. using Azure.Cosmos;
  14. using HTEXLib.COMM.Helpers;
  15. using TEAMModelOS.SDK.Models.Cosmos.Common;
  16. using System.Text;
  17. using TEAMModeBI.Filter;
  18. using TEAMModelOS.SDK.Services;
  19. namespace TEAMModeBI.Controllers.BIAbility
  20. {
  21. [Route("biabilitytask")]
  22. [ApiController]
  23. public class AbilityTaskMgmtController : ControllerBase
  24. {
  25. //获取配置信息
  26. private readonly IConfiguration _configuration;
  27. //数据容器
  28. private readonly AzureCosmosFactory _azureCosmos;
  29. //文件容器
  30. private readonly AzureStorageFactory _azureStorage;
  31. //钉钉提示信息
  32. private readonly DingDing _dingDing;
  33. private readonly Option _option;
  34. public readonly string mobel = "章节";
  35. public AbilityTaskMgmtController(IConfiguration configuration, AzureCosmosFactory azureCosmos, DingDing dingDing, IOptionsSnapshot<Option> option, AzureStorageFactory azureStorage)
  36. {
  37. _configuration = configuration;
  38. _azureCosmos = azureCosmos;
  39. _dingDing = dingDing;
  40. _option = option?.Value;
  41. _azureStorage = azureStorage;
  42. }
  43. /// <summary>
  44. /// 依据区级标准和能力编号查询能力点信息 章节集合
  45. /// </summary>
  46. /// <param name="jsonElement"></param>
  47. /// <returns></returns>
  48. [ProducesDefaultResponseType]
  49. [HttpPost("get-abilitytasksid")]
  50. public async Task<IActionResult> GetAbilityTasksId(JsonElement jsonElement)
  51. {
  52. try
  53. {
  54. if (!jsonElement.TryGetProperty("standard", out JsonElement standard)) return BadRequest();
  55. if (!jsonElement.TryGetProperty("abilityId", out JsonElement abilityId)) return BadRequest();
  56. var cosmosClient = _azureCosmos.GetCosmosClient();
  57. Ability ability = null;
  58. List<AbilityTaskTreeNode> abilityTaskTreeNodes = new List<AbilityTaskTreeNode>();//原始数据未排序
  59. List<AbilityTaskTreeNode> redtAbilityTaskTreeNodes = new List<AbilityTaskTreeNode>();//排序后的数据
  60. int rnodeCount = 0;
  61. try
  62. {
  63. ability = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<Ability>($"{abilityId}", new PartitionKey($"Ability-{standard}"));
  64. }
  65. catch
  66. {
  67. return Ok(new { state = 400,message="该ID未找到章节" });
  68. }
  69. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AbilityTask>(queryText: $"select value(c) from c where c.abilityId='{abilityId}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"AbilityTask-{standard}") }))
  70. {
  71. var rns = item.children.Select(x => x.rnodes);
  72. if (rns != null)
  73. {
  74. var list = rns.ToList();
  75. list.ForEach(x => { if (x.IsNotEmpty()) { rnodeCount += 1; } });
  76. }
  77. List<AbilityTaskTree> trees = AbilityService.ListToTree(item.children);
  78. AbilityTaskTreeNode abilityTaskTreeNode = new AbilityTaskTreeNode() { id = item.id, scope = item.scope, trees = trees, abilityId = item.abilityId, auth = item.auth, codeval = ability.school };
  79. abilityTaskTreeNodes.Add(abilityTaskTreeNode);
  80. }
  81. if (ability.abilityTaskIds.IsNotEmpty())
  82. {
  83. ability.abilityTaskIds.ForEach(x =>
  84. {
  85. for (int i = 0; i < abilityTaskTreeNodes.Count; i++)
  86. {
  87. if (abilityTaskTreeNodes[i].id.Equals(x))
  88. {
  89. redtAbilityTaskTreeNodes.Add(abilityTaskTreeNodes[i]);
  90. abilityTaskTreeNodes.RemoveAt(i);
  91. }
  92. }
  93. });
  94. redtAbilityTaskTreeNodes.AddRange(abilityTaskTreeNodes);
  95. return Ok(new { state = 200, abilityTaskTreeNodes = redtAbilityTaskTreeNodes });
  96. }
  97. else
  98. {
  99. return Ok(new { state = 200, abilityTaskTreeNodes = abilityTaskTreeNodes, rnodeCount });
  100. }
  101. }
  102. catch (Exception ex)
  103. {
  104. await _dingDing.SendBotMsg($"BI,{_option.Location} /biabilitytask/get-abilitytasksid \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
  105. return BadRequest();
  106. }
  107. }
  108. /// <summary>
  109. /// 修改和新增章节数据
  110. /// </summary>
  111. /// <param name="abilityTask"></param>
  112. /// <returns></returns>
  113. [ProducesDefaultResponseType]
  114. [AuthToken(Roles= "assist")]
  115. [HttpPost("upd-abilitytask")]
  116. public async Task<IActionResult> UpdAbilityTask(RecordAbilityTask recordAbilityTask)//AbilityTask abilityTask)
  117. {
  118. try
  119. {
  120. var cosmosClient = _azureCosmos.GetCosmosClient();
  121. StringBuilder msgBuilder = new StringBuilder($"{recordAbilityTask.tmdName}【{recordAbilityTask.tmdId}】");
  122. string type = null;
  123. long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  124. foreach (var abilityTaskTree in recordAbilityTask.abilityTask)
  125. {
  126. if (!string.IsNullOrEmpty(abilityTaskTree.id))
  127. {
  128. AbilityTask abilityTask = null;
  129. try
  130. {
  131. abilityTask = await cosmosClient.GetContainer("TEAMModelOS", "Normal").ReadItemAsync<AbilityTask>(abilityTaskTree.id, new PartitionKey($"AbilityTask-{recordAbilityTask.standard}"));
  132. }
  133. catch
  134. {
  135. }
  136. if (abilityTask == null)
  137. {
  138. if (abilityTaskTree.trees.IsNotEmpty())
  139. {
  140. abilityTaskTree.trees.ForEach(x => x.id = abilityTaskTree.id);
  141. }
  142. List<Tnode> nodes = new List<Tnode>();
  143. AbilityService.TreeToList(abilityTaskTree.trees, nodes, now);
  144. abilityTask = new AbilityTask();
  145. abilityTask.id = abilityTaskTree.id;
  146. abilityTask.children = nodes;
  147. abilityTask.code = $"AbilityTask-{recordAbilityTask.standard}";
  148. abilityTask.pk = "AbilityTask";
  149. abilityTask.ttl = -1;
  150. abilityTask.abilityId = abilityTaskTree.abilityId;
  151. abilityTask.scope = abilityTaskTree.scope;
  152. abilityTask.codeval = $"{recordAbilityTask.standard}";
  153. abilityTask.standard = $"{recordAbilityTask.standard}";
  154. await _azureCosmos.GetCosmosClient().GetContainer("TEAMModelOS", "Normal").CreateItemAsync<AbilityTask>(abilityTask, new Azure.Cosmos.PartitionKey($"AbilityTask-{recordAbilityTask.standard}"));
  155. msgBuilder.Append($"新增章节功能,章节ID:{abilityTask.id} 分区键:{abilityTask.code}");
  156. type = "abilityTask-Add";
  157. }
  158. else
  159. {
  160. if (abilityTaskTree.trees.IsNotEmpty())
  161. {
  162. abilityTaskTree.trees.ForEach(x => x.id = abilityTaskTree.id);
  163. }
  164. List<Tnode> nodes = new List<Tnode>();
  165. AbilityService.TreeToList(abilityTaskTree.trees, nodes, now);
  166. abilityTask.children = nodes;
  167. abilityTaskTree.auth = abilityTask.auth;
  168. await _azureCosmos.GetCosmosClient().GetContainer("TEAMModelOS", "Normal").ReplaceItemAsync<AbilityTask>(abilityTask, abilityTask.id, new Azure.Cosmos.PartitionKey($"AbilityTask-{recordAbilityTask.standard}"));
  169. msgBuilder.Append($"修改章节功能,章节ID:{abilityTask.id} 分区键:{abilityTask.code}");
  170. type = "abilityTask-update";
  171. }
  172. }
  173. else
  174. {
  175. string id = Guid.NewGuid().ToString();
  176. abilityTaskTree.id = id;
  177. if (abilityTaskTree.trees.IsNotEmpty())
  178. {
  179. abilityTaskTree.trees.ForEach(x => x.id = abilityTaskTree.id);
  180. }
  181. List<Tnode> nodes = new List<Tnode>();
  182. AbilityService.TreeToList(abilityTaskTree.trees, nodes, now);
  183. AbilityTask abilityTask = new AbilityTask
  184. {
  185. id = id,
  186. code = $"AbilityTask-{recordAbilityTask.standard}",
  187. pk = "AbilityTask",
  188. ttl = -1,
  189. abilityId = abilityTaskTree.abilityId,
  190. children = nodes,
  191. scope = abilityTaskTree.scope,
  192. codeval = $"{recordAbilityTask.standard}",
  193. standard = $"{recordAbilityTask.standard}"
  194. };
  195. await _azureCosmos.GetCosmosClient().GetContainer("TEAMModelOS", "Normal").CreateItemAsync<AbilityTask>(abilityTask, new Azure.Cosmos.PartitionKey($"AbilityTask-{recordAbilityTask.standard}"));
  196. msgBuilder.Append($"新增章节功能,章节ID:{abilityTask.id} 分区键:{abilityTask.code}");
  197. type = "abilityTask-add";
  198. }
  199. }
  200. //保存操作记录
  201. await _azureStorage.SaveLog(type, msgBuilder?.ToString(), _dingDing, httpContext: HttpContext);
  202. return Ok(new { state = 200, recordAbilityTask });
  203. }
  204. catch (Exception ex)
  205. {
  206. await _dingDing.SendBotMsg($"BI,{_option.Location} /biabilitytask/upd-abilitytask \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
  207. return BadRequest();
  208. }
  209. }
  210. /// <summary>
  211. /// 依据id删除章节
  212. /// </summary>
  213. /// <param name="jsonElement"></param>
  214. /// <returns></returns>
  215. [ProducesDefaultResponseType]
  216. [AuthToken(Roles = "assist")]
  217. [HttpPost("del-abilitytask")]
  218. public async Task<IActionResult> DelAbilityTask(JsonElement jsonElement)
  219. {
  220. try
  221. {
  222. if (!jsonElement.TryGetProperty("standard", out JsonElement standard)) return BadRequest();
  223. if (!jsonElement.TryGetProperty("id", out JsonElement id)) return BadRequest();
  224. if (!jsonElement.TryGetProperty("tmdId", out JsonElement _tmdId)) return BadRequest(); //醍摩豆账户
  225. if (!jsonElement.TryGetProperty("tmdName", out JsonElement _tmdName)) return BadRequest(); //醍摩豆账号名称
  226. var cosmosClient = _azureCosmos.GetCosmosClient();
  227. var response = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").DeleteItemStreamAsync(id.ToString(), new PartitionKey($"AbilityTask-{standard}"));
  228. string msg = $"{_tmdName}【{_tmdId}】删除册别,删除状态:{response.Status},删除ID:{id}";
  229. //保存操作记录
  230. await _azureStorage.SaveLog("abilitytask-del", msg, _dingDing, httpContext: HttpContext);
  231. if (response.Status == 204)
  232. return Ok(new { state = 200 });
  233. else
  234. return Ok(new { state = response.Status });
  235. }
  236. catch (Exception ex)
  237. {
  238. await _dingDing.SendBotMsg($"BI,{_option.Location} /biabilitytask/del-abilitytask \n {ex.Message} {ex.StackTrace}", GroupNames.成都开发測試群組);
  239. return Ok(new { state = 404 });
  240. }
  241. }
  242. public record RecordAbilityTask()
  243. {
  244. /// <summary>
  245. /// 醍摩豆账户ID
  246. /// </summary>
  247. public string tmdId { get; set; }
  248. /// <summary>
  249. /// 醍摩豆账户名称
  250. /// </summary>
  251. public string tmdName { get; set; }
  252. public string standard { get; set; }
  253. /// <summary>
  254. /// 章节信息
  255. /// </summary>
  256. //public List<AbilityTask> abilityTask { get; set; }
  257. public List<AbilityTaskTreeNode> abilityTask { get; set; }
  258. }
  259. }
  260. }