RoomController.cs 7.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162
  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.IdentityModel.Tokens.Jwt;
  8. using System.IO;
  9. using System.Linq;
  10. using System.Text;
  11. using System.Text.Json;
  12. using System.Threading.Tasks;
  13. using TEAMModelOS.Models;
  14. using TEAMModelOS.Models.Dto;
  15. using TEAMModelOS.SDK.Models;
  16. using TEAMModelOS.SDK;
  17. using TEAMModelOS.SDK.DI;
  18. using TEAMModelOS.SDK.DI.AzureCosmos.Inner;
  19. using TEAMModelOS.SDK.Extension;
  20. using TEAMModelOS.SDK.Helper.Common.StringHelper;
  21. using System.Dynamic;
  22. using Azure;
  23. using TEAMModelOS.SDK.Models.Cosmos.Common;
  24. using Azure.Messaging.ServiceBus;
  25. using Microsoft.Extensions.Configuration;
  26. using TEAMModelOS.Filter;
  27. using Azure.Storage.Blobs.Models;
  28. using HTEXLib.COMM.Helpers;
  29. using Microsoft.AspNetCore.Authorization;
  30. namespace TEAMModelAPI.Controllers
  31. {
  32. [Route("school")]
  33. [ApiController]
  34. public class RoomController : ControllerBase
  35. {
  36. private AzureCosmosFactory _azureCosmos;
  37. private readonly DingDing _dingDing;
  38. private readonly Option _option;
  39. private readonly AzureServiceBusFactory _serviceBus;
  40. private readonly AzureStorageFactory _azureStorage;
  41. public IConfiguration _configuration { get; set; }
  42. public RoomController(AzureCosmosFactory azureCosmos, DingDing dingDing, IOptionsSnapshot<Option> option, AzureServiceBusFactory serviceBus, AzureStorageFactory azureStorage, IConfiguration configuration)
  43. {
  44. _azureCosmos = azureCosmos;
  45. _dingDing = dingDing;
  46. _option = option?.Value;
  47. _serviceBus = serviceBus;
  48. _configuration = configuration;
  49. _azureStorage = azureStorage;
  50. }
  51. /// <summary>
  52. /// 获取物理教室列表
  53. /// </summary>
  54. /// <param name="json"></param>
  55. /// <returns></returns>
  56. [ProducesDefaultResponseType]
  57. [HttpPost("get-room-list")]
  58. [ApiToken(Auth = "1401", Name = "获取物理教室列表", RW = "R", Limit = false)]
  59. public async Task<IActionResult> GetRoomList(JsonElement json)
  60. {
  61. var client = _azureCosmos.GetCosmosClient();
  62. var (id, school) = HttpContext.GetApiTokenInfo();
  63. StringBuilder sql = new StringBuilder($"select value(c) from c where 1=1 ");
  64. json.TryGetProperty("openType", out JsonElement openType);
  65. if (!string.IsNullOrWhiteSpace($"{openType}"))
  66. {
  67. sql.Append($" and c.openType='{openType}'");
  68. }
  69. List<Room> rooms = new List<Room>();
  70. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Room>(queryText: sql.ToString(),
  71. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Room-{school}") }))
  72. {
  73. rooms.Add(item);
  74. }
  75. return Ok(new { rooms = rooms.Select(x => new { x.id, x.name, x.x, x.y, x.openType, x.style, x.area, x.address, school = school }) });
  76. }
  77. /// <summary>
  78. /// 获取物理教室详细信息
  79. /// </summary>
  80. /// <param name="json"></param>
  81. /// <returns></returns>
  82. [ProducesDefaultResponseType]
  83. [HttpPost("get-room-info")]
  84. [ApiToken(Auth = "1402", Name = "获取物理教室详细信息", RW = "R", Limit = false)]
  85. public async Task<IActionResult> GetRoomInfo(JsonElement json)
  86. {
  87. var (id, school) = HttpContext.GetApiTokenInfo();
  88. if (!json.TryGetProperty("roomId", out JsonElement roomId)) return BadRequest();
  89. Azure.Response response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School")
  90. .ReadItemStreamAsync($"{roomId}", new PartitionKey($"Room-{school}"));
  91. if (response.Status == 200)
  92. {
  93. JsonDocument document = JsonDocument.Parse(response.Content);
  94. Room room = document.RootElement.Deserialize<Room>();
  95. return Ok(new { room.id, room.name, room.x, room.y, room.openType, room.style, room.area, room.address, school = school });
  96. }
  97. else
  98. {
  99. return Ok(new { error = 1, msg = "教室不存在!" });
  100. }
  101. }
  102. /// <summary>
  103. /// 创建或更新教学班基本信息
  104. /// </summary>
  105. /// <param name="request"></param>
  106. /// <returns></returns>
  107. [ProducesDefaultResponseType]
  108. [HttpPost("upsert-room-infos")]
  109. [ApiToken(Auth = "1403", Name = "创建或更新教学班", RW = "W", Limit = false)]
  110. public async Task<IActionResult> UpsertRoomInfo(JsonElement json)
  111. {
  112. var (id, school) = HttpContext.GetApiTokenInfo();
  113. if (!json.TryGetProperty("rooms", out JsonElement _rooms)) { return Ok(new { error = 1, msg = "名单对象不存在" }); }
  114. var rooms = _rooms.ToObject<List<RoomDto>>();
  115. List<Room> db_rooms = new List<Room>();
  116. List<Room> roomCreate = new List<Room>();
  117. if (rooms != null && rooms.Valid().isVaild)
  118. {
  119. School data = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>(school, new PartitionKey("Base"));
  120. string sql = $"select value(c) from c where c.id in({string.Join(",", rooms.Select(x => $"'{x.id}'"))})";
  121. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School)
  122. .GetItemQueryIterator<Room>(queryText: sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Room-{school}") }))
  123. {
  124. db_rooms.Add(item);
  125. }
  126. //不存在的教室,可以被直接创建
  127. var unexistRoomIds = rooms.Select(x=>x.id).Except(db_rooms.Select(x => x.id));
  128. foreach (var roomId in unexistRoomIds) {
  129. var room_web = rooms.Find(x => x.id.Equals(roomId));
  130. if (room_web != null) {
  131. var room = new Room
  132. {
  133. id = room_web.id,
  134. name = room_web.name,
  135. code = $"Room-{school}",
  136. pk = "Room",
  137. no = room_web.no,
  138. address = room_web.address,
  139. };
  140. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).CreateItemAsync(room, new PartitionKey(room.code));
  141. roomCreate.Add(room);
  142. }
  143. }
  144. foreach (var room in db_rooms) {
  145. var room_web = rooms.Find(x => x.id.Equals(room.id));
  146. if (room_web != null)
  147. {
  148. room.name = string.IsNullOrWhiteSpace(room_web.name) ? room.name : room_web.name;
  149. room.code = $"Room-{school}";
  150. room.pk = "Room";
  151. room.no =string.IsNullOrWhiteSpace(room_web.no)?room.no : room_web.no;
  152. room.address = string.IsNullOrWhiteSpace(room_web.address) ? room.address : room_web.address;
  153. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReplaceItemAsync(room,room.id, new PartitionKey(room.code));
  154. }
  155. }
  156. }
  157. return Ok(new { roomUpdate= db_rooms, roomCreate= roomCreate });
  158. }
  159. }
  160. }