AreaRelevantController.cs 8.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186
  1. using Azure.Cosmos;
  2. using Microsoft.AspNetCore.Http;
  3. using Microsoft.AspNetCore.Mvc;
  4. using Microsoft.Extensions.Options;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.Linq;
  8. using System.Text.Json;
  9. using System.Threading.Tasks;
  10. using TEAMModelBI.Filter;
  11. using TEAMModelBI.Tool.Extension;
  12. using TEAMModelOS.Models;
  13. using TEAMModelOS.SDK.DI;
  14. using TEAMModelOS.SDK.Extension;
  15. using TEAMModelOS.SDK.Models;
  16. using TEAMModelOS.SDK.Models.Cosmos.BI;
  17. namespace TEAMModelBI.Controllers.BISchool
  18. {
  19. [Route("area")]
  20. [ApiController]
  21. public class AreaRelevantController : ControllerBase
  22. {
  23. //数据容器
  24. private readonly AzureCosmosFactory _azureCosmos;
  25. private readonly AzureStorageFactory _azureStorage;
  26. //钉钉提示信息
  27. private readonly DingDing _dingDing;
  28. private readonly Option _option;
  29. public AreaRelevantController(AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, DingDing dingDing, IOptionsSnapshot<Option> option)
  30. {
  31. _azureCosmos = azureCosmos;
  32. _azureStorage = azureStorage;
  33. _dingDing = dingDing;
  34. _option = option?.Value;
  35. }
  36. /// <summary>
  37. /// 查询区域已经有的学校
  38. /// </summary>
  39. /// <param name="jsonElement"></param>
  40. /// <returns></returns>
  41. [ProducesDefaultResponseType]
  42. [HttpPost("get-areaschools")]
  43. public async Task<IActionResult> GetAreaSchools(JsonElement jsonElement)
  44. {
  45. try
  46. {
  47. jsonElement.TryGetProperty("areaId", out JsonElement _areaId);
  48. var cosmosClient = _azureCosmos.GetCosmosClient();
  49. List<JoinAreaSchool> joinAreaSchools = new List<JoinAreaSchool>();
  50. string sqltxt = $"SELECT c.id,c.name,c.schoolCode,c.province,c.city,c.dist,c.picture,c.period,c.areaId,c.standard,c.manyAreas FROM c WHERE c.areaId='{_areaId}'";
  51. if (!string.IsNullOrEmpty($"{_areaId}"))
  52. {
  53. sqltxt = $"SELECT c.id,c.name,c.schoolCode,c.province,c.city,c.dist,c.picture,c.period,c.areaId,c.standard,c.manyAreas FROM c join m in c.manyAreas WHERE c.areaId ='{_areaId}' or m.areaId='{_areaId}'";
  54. //sqltxt = $"SELECT c.id,c.name,c.schoolCode,c.province,c.city,c.dist,c.picture,c.period FROM c join m in c.manyAreas where m.areaId='{_areaId}' or c.areaId='{_areaId}'";
  55. }
  56. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: sqltxt, requestOptions:new QueryRequestOptions() { PartitionKey = new PartitionKey("Base")}))
  57. {
  58. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  59. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  60. {
  61. foreach(var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  62. {
  63. JoinAreaSchool joinAreaSchool = new JoinAreaSchool
  64. {
  65. id = obj.GetProperty("id").GetString(),
  66. name = obj.GetProperty("name").GetString(),
  67. schoolCode = obj.GetProperty("schoolCode").GetString(),
  68. province = obj.GetProperty("province").GetString(),
  69. city = obj.GetProperty("city").GetString(),
  70. dist = obj.GetProperty("dist").GetString(),
  71. picture = obj.GetProperty("picture").GetString(),
  72. period = obj.GetProperty("period").ToObject<List<Period>>().Select(x => x.name).ToList(),
  73. areaId = obj.GetProperty("areaId").GetString(),
  74. standard = obj.GetProperty("standard").GetString()
  75. };
  76. try
  77. {
  78. joinAreaSchool.manyAreas = obj.GetProperty("manyAreas").ToObject<List<ManyArea>>();
  79. }
  80. catch { }
  81. joinAreaSchools.Add(joinAreaSchool);
  82. }
  83. }
  84. }
  85. return Ok(new { state = 200, joinAreaSchools });
  86. }
  87. catch (Exception ex)
  88. {
  89. await _dingDing.SendBotMsg($"BI, {_option.Location} /area/get-areaschools \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  90. return BadRequest();
  91. }
  92. }
  93. /// <summary>
  94. /// 学校移出区域
  95. /// </summary>
  96. /// <param name="jsonElement"></param>
  97. /// <returns></returns>
  98. [ProducesDefaultResponseType]
  99. [AuthToken(Roles = "admin,,rdc,assist")]
  100. [HttpPost("set-areashiftschool")]
  101. public async Task<IActionResult> SetAreaShiftSchool(JsonElement jsonElement)
  102. {
  103. try
  104. {
  105. if (!jsonElement.TryGetProperty("schoolId", out JsonElement schoolId)) return BadRequest();
  106. jsonElement.TryGetProperty("areaId", out JsonElement areaId);
  107. jsonElement.TryGetProperty("standard", out JsonElement standard);
  108. jsonElement.TryGetProperty("isDefault", out JsonElement isDefault);
  109. var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);
  110. var cosmosClient = _azureCosmos.GetCosmosClient();
  111. School tempSchool = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>($"{schoolId}", new PartitionKey("Base"));
  112. if (bool.Parse($"{isDefault}") == true)
  113. {
  114. tempSchool.areaId = null;
  115. tempSchool.standard = null;
  116. }
  117. if (tempSchool.manyAreas.Count > 0)
  118. {
  119. if (bool.Parse($"{isDefault}") == true)
  120. {
  121. tempSchool.areaId = "";
  122. tempSchool.standard = "";
  123. }
  124. if (tempSchool.manyAreas != null)
  125. {
  126. if (!string.IsNullOrEmpty($"{areaId}"))
  127. {
  128. var temp = tempSchool.manyAreas.Find(ma => ma.areaId == $"{areaId}");
  129. if (temp != null)
  130. tempSchool.manyAreas.Remove(temp);
  131. }
  132. if (!string.IsNullOrEmpty($"{standard}"))
  133. {
  134. var temp = tempSchool.manyAreas.Find(ma => ma.standard == $"{standard}");
  135. if (temp != null)
  136. tempSchool.manyAreas.Remove(temp);
  137. }
  138. }
  139. }
  140. School school = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<School>(tempSchool, tempSchool.id, new PartitionKey("Base"));
  141. //保存操作记录
  142. await _azureStorage.SaveBILog("school-update", $"{_tmdName}【{_tmdId}】已操作学校({schoolId})移除该区域", _dingDing, httpContext: HttpContext);
  143. return Ok(new { state = 200, school });
  144. }
  145. catch (Exception ex)
  146. {
  147. await _dingDing.SendBotMsg($"BI, {_option.Location} /area/set-areashiftschool \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  148. return BadRequest();
  149. }
  150. }
  151. /// <summary>
  152. /// 已加入区域的学校
  153. /// </summary>
  154. public record JoinAreaSchool
  155. {
  156. public string id { get; set; }
  157. public string name { get; set; }
  158. public string schoolCode { get; set; }
  159. public string picture { get; set; }
  160. public string areaId{ get; set; }
  161. public string standard { get; set; }
  162. public List<string> period { get; set; }
  163. public string province { get; set; }
  164. public string city { get; set; }
  165. public string dist { get; set; }
  166. public List<ManyArea> manyAreas { get; set; } = new List<ManyArea>();
  167. }
  168. }
  169. }