RoomController.cs 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124
  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 = "1206", 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<RoomDto>();
  115. List<Room> roomList = new List<Room>();
  116. if (rooms != null && rooms.Valid().isVaild)
  117. {
  118. }
  119. return Ok();
  120. }
  121. }
  122. }