SchoolController.cs 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577
  1. using Azure.Cosmos;
  2. using HTEXLib.COMM.Helpers;
  3. using Microsoft.AspNetCore.Http;
  4. using Microsoft.AspNetCore.Mvc;
  5. using Microsoft.Extensions.Configuration;
  6. using Microsoft.Extensions.Options;
  7. using StackExchange.Redis;
  8. using System;
  9. using System.Collections.Generic;
  10. using System.Linq;
  11. using System.Text;
  12. using System.Text.Json;
  13. using System.Threading.Tasks;
  14. using TEAMModelBI.Filter;
  15. using TEAMModelBI.Tool;
  16. using TEAMModelBI.Tool.Extension;
  17. using TEAMModelOS.Models;
  18. using TEAMModelOS.SDK.DI;
  19. using TEAMModelOS.SDK.Extension;
  20. using TEAMModelOS.SDK.Models;
  21. using TEAMModelOS.SDK.Models.Service;
  22. namespace TEAMModelBI.Controllers.BISchool
  23. {
  24. [Route("schoolcheck")]
  25. [ApiController]
  26. public class SchoolController : ControllerBase
  27. {
  28. private readonly AzureCosmosFactory _azureCosmos;
  29. private readonly DingDing _dingDing;
  30. private readonly Option _option;
  31. private readonly AzureStorageFactory _azureStorage;
  32. private readonly AzureRedisFactory _azureRedis;
  33. private readonly IConfiguration _configuration;
  34. private readonly NotificationService _notificationService;
  35. public SchoolController(AzureCosmosFactory azureCosmos, DingDing dingDing, AzureStorageFactory azureStorage, IOptionsSnapshot<Option> option, AzureRedisFactory azureRedis, IConfiguration configuration, NotificationService notificationService)
  36. {
  37. _azureCosmos = azureCosmos;
  38. _dingDing = dingDing;
  39. _azureStorage = azureStorage;
  40. _option = option?.Value;
  41. _azureRedis = azureRedis;
  42. _configuration = configuration;
  43. _notificationService = notificationService;
  44. }
  45. /// <summary>
  46. /// 查询未加入区域的学校
  47. /// </summary>
  48. /// <returns></returns>
  49. [ProducesDefaultResponseType]
  50. [HttpPost("get-notarea")]
  51. public async Task<IActionResult> GetNotAreaSchool()
  52. {
  53. try
  54. {
  55. var cosmosClient = _azureCosmos.GetCosmosClient();
  56. string sqltxt = $"SELECT c.id,c.name,c.schoolCode,c.province,c.city,c.dist,c.picture,c.period FROM c WHERE c.standard=null";
  57. List<NotAreaSchool> notAreaSchools = new List<NotAreaSchool>();
  58. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  59. {
  60. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  61. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  62. {
  63. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  64. {
  65. //List<string> temp0 = obj.GetProperty("period").ToObject<List<Period>>().Select(x=>x.name).ToList();
  66. NotAreaSchool notAreaSchool = new NotAreaSchool()
  67. {
  68. id = obj.GetProperty("id").GetString(),
  69. name = obj.GetProperty("name").GetString(),
  70. schoolCode = obj.GetProperty("schoolCode").GetString(),
  71. picture = obj.GetProperty("picture").GetString(),
  72. period = obj.GetProperty("period").ToObject<List<Period>>().Select(x => x.name).ToList(),
  73. province = obj.GetProperty("province").GetString(),
  74. city = obj.GetProperty("city").GetString(),
  75. dist = obj.GetProperty("dist").GetString(),
  76. };
  77. notAreaSchools.Add(notAreaSchool);
  78. }
  79. }
  80. }
  81. return Ok(new { state = 200, notAreaSchools });
  82. }
  83. catch (Exception ex)
  84. {
  85. await _dingDing.SendBotMsg($"BI,{_option.Location} /schoolcheck/get-notarea \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
  86. return BadRequest();
  87. }
  88. }
  89. /// <summary>
  90. /// 学校加入区
  91. /// </summary>
  92. /// <param name="jsonElement"></param>
  93. /// <returns></returns>
  94. [ProducesDefaultResponseType]
  95. [AuthToken(Roles = "assist")]
  96. [HttpPost("set-schooljoinarea")]
  97. public async Task<IActionResult> SetSchoolJoinArea(JsonElement jsonElement)
  98. {
  99. try
  100. {
  101. if (!jsonElement.TryGetProperty("standard", out JsonElement standard)) return BadRequest();
  102. if (!jsonElement.TryGetProperty("schoolCode", out JsonElement _schoolCode)) return BadRequest();
  103. if (!jsonElement.TryGetProperty("areaId", out JsonElement _areaId)) return BadRequest();
  104. var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);
  105. List<string> schoolCodes = _schoolCode.ToObject<List<string>>();
  106. var cosmosCliet = _azureCosmos.GetCosmosClient();
  107. if (schoolCodes.Count > 0)
  108. {
  109. foreach (var tempCode in schoolCodes)
  110. {
  111. School school = await cosmosCliet.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>(tempCode,new PartitionKey("Base"));
  112. if (school != null)
  113. {
  114. school.standard = $"{standard}";
  115. school.areaId = $"{_areaId}";
  116. await cosmosCliet.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<School>(school, school.id, new PartitionKey(school.code));
  117. }
  118. }
  119. }
  120. //保存操作记录
  121. await _azureStorage.SaveLog("school-join", $"{_tmdName}【{_tmdId}】操作学校加入区域功能,加入的区域:{standard},学校ID:{string.Join("|", schoolCodes.ToArray())}", _dingDing, httpContext: HttpContext);
  122. return Ok(new { state = 200 });
  123. }
  124. catch (Exception ex)
  125. {
  126. await _dingDing.SendBotMsg($"BI,{_option.Location} /schoolcheck/set-schooljoinarea \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
  127. return BadRequest();
  128. }
  129. }
  130. /// <summary>
  131. /// 依据醍摩豆账户查询顾问管理学校的基础信息
  132. /// </summary>
  133. /// <param name="jsonElement"></param>
  134. /// <returns></returns>
  135. [HttpPost("get-assustschool")]
  136. public async Task<IActionResult> GetAssistSchool(JsonElement jsonElement)
  137. {
  138. try
  139. {
  140. if (!jsonElement.TryGetProperty("tmdId", out JsonElement tmdId)) return BadRequest();
  141. List<string> schoolIds = new List<string>();
  142. List<object> schools = new List<object>();
  143. var cosmosClient = _azureCosmos.GetCosmosClient();
  144. string sqlTxt = $"SELECT DISTINCT REPLACE(c.code, 'Teacher-', '') AS schoolId FROM c WHERE c.pk = 'Teacher' AND c.status = 'join' AND ARRAY_CONTAINS(c.roles, 'assist', true) AND c.id='{tmdId}' ";
  145. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: sqlTxt, requestOptions: new QueryRequestOptions() { }))
  146. {
  147. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  148. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  149. {
  150. schoolIds.Add(obj.GetProperty("schoolId").GetString());
  151. }
  152. }
  153. foreach (var item in schoolIds)
  154. {
  155. await foreach (var itemBase in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: $"select c.id,c.code,c.name,c.picture,c.region,c.province,c.city,c.dist from c where c.id='{item}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  156. {
  157. var json = await JsonDocument.ParseAsync(itemBase.ContentStream);
  158. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  159. {
  160. schools.Add(obj.ToObject<object>());
  161. }
  162. }
  163. }
  164. return Ok(new { state = 200, schools });
  165. }
  166. catch (Exception ex)
  167. {
  168. await _dingDing.SendBotMsg($"BI,{_option.Location} /schoolcheck/get-assustschool {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
  169. return BadRequest();
  170. }
  171. }
  172. /// <summary>
  173. /// 依据学校编号查询学校信息
  174. /// </summary>
  175. /// <param name="jsonElement"></param>
  176. /// <returns></returns>
  177. [HttpPost("get-schoolid")]
  178. public async Task<IActionResult> GetSchoolId(JsonElement jsonElement)
  179. {
  180. try
  181. {
  182. if (!jsonElement.TryGetProperty("schoolId", out JsonElement schoolId)) return BadRequest();
  183. var cosmosClient = _azureCosmos.GetCosmosClient();
  184. var rsponse = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync($"{schoolId}", new PartitionKey("Base"));
  185. if (rsponse.Status == 200)
  186. {
  187. using var json = await JsonDocument.ParseAsync(rsponse.ContentStream);
  188. School school = json.ToObject<School>();
  189. return Ok(new { state = 200, school });
  190. }
  191. else
  192. return Ok(new { state = 404, msg = $"未找到ID是({schoolId})的学校" });
  193. }
  194. catch (Exception ex)
  195. {
  196. await _dingDing.SendBotMsg($"BI,{_option.Location} /schoolcheck/get-schoolid {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
  197. return BadRequest();
  198. }
  199. }
  200. /// <summary>
  201. /// 修改学校信息
  202. /// </summary>
  203. /// <param name="school"></param>
  204. /// <returns></returns>
  205. [ProducesDefaultResponseType]
  206. [AuthToken(Roles = "assist")]
  207. [HttpPost("upd-school")]
  208. public async Task<IActionResult> UpdSchool(School school)
  209. {
  210. try
  211. {
  212. School schoolInfo = new School();
  213. var cosmosClient = _azureCosmos.GetCosmosClient();
  214. string _auth = HttpContext.GetXAuth("AuthToken");
  215. //var (tmdId, tmdName) = HttpJwtAnalysis.JwtXAuth(_auth, _option);
  216. var (tmdId, tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(_auth, _option);
  217. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(school.id, new PartitionKey($"Base"));
  218. if (response.Status == 200)
  219. {
  220. string sql = $"SELECT distinct value(c) FROM c join A1 in c.schools where A1.schoolId='{school.id}'";
  221. List<Teacher> teachers = new List<Teacher>();
  222. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "Teacher").GetItemQueryIterator<Teacher>(sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
  223. {
  224. teachers.Add(item);
  225. }
  226. foreach (var item in teachers)
  227. {
  228. Teacher.TeacherSchool teacherSchool = item.schools.Find(x => x.schoolId.Equals(school.id));
  229. if (teacherSchool != null)
  230. {
  231. teacherSchool.name = school.name;
  232. teacherSchool.picture = school.picture;
  233. teacherSchool.areaId = school.areaId;
  234. }
  235. await cosmosClient.GetContainer("TEAMModelOS", "Teacher").ReplaceItemAsync(item, item.id, new PartitionKey($"Base"));
  236. }
  237. schoolInfo = await cosmosClient.GetContainer("TEAMModelOS", "School").ReplaceItemAsync<School>(school,school.id, new PartitionKey($"Base"));
  238. //保存操作记录
  239. await _azureStorage.SaveLog("school-update", $"{tmdName}【{tmdId}】修改学校信息,学校和ID:{school.name}【{school.id}】", _dingDing, httpContext: HttpContext);
  240. }
  241. else return Ok(new { state = 400, message = "请求错误!" });
  242. return Ok(new { state = 200, schoolInfo });
  243. //School tempShool = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>(replaceSchool.school.id, new PartitionKey("Base"));
  244. //if (tempShool != null)
  245. //{
  246. // List<Teacher> teachers = new List<Teacher>();
  247. // string sqltxt = $"select distinct value(c) from c join a1 in c.schools where a1.schoolId='{replaceSchool.school.id}'";
  248. // await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  249. // {
  250. // teachers.Add(item);
  251. // }
  252. // foreach (var item in teachers)
  253. // {
  254. // Teacher.TeacherSchool teacherSchool = item.schools.Find(x => x.schoolId.Equals(replaceSchool.school.id));
  255. // if (teacherSchool != null)
  256. // {
  257. // teacherSchool.name = replaceSchool.school.name;
  258. // teacherSchool.picture = replaceSchool.school.picture;
  259. // teacherSchool.areaId = replaceSchool.school.areaId;
  260. // }
  261. // await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync(item, item.id, new PartitionKey("Base"));
  262. // }
  263. // schoolInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<School>(replaceSchool.school, replaceSchool.school.id, new PartitionKey("Base"));
  264. // //保存操作记录
  265. // await _azureStorage.SaveLog("school-update", $"{replaceSchool.tmdName}【{replaceSchool.tmdId}】修改学校信息,学校和ID:{replaceSchool.school.name}【{replaceSchool.school.id}】", _dingDing, httpContext: HttpContext);
  266. // return Ok(new { state = 200, schoolInfo });
  267. //}
  268. //else return Ok(new { state = 400, message = "请求错误!" });
  269. }
  270. catch (Exception ex)
  271. {
  272. await _dingDing.SendBotMsg($"BI,{_option.Location} /batchschool/upd-school \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
  273. return BadRequest();
  274. }
  275. }
  276. /// <summary>
  277. /// 顾问学校空间使用情况
  278. /// </summary>
  279. /// <param name="jsonElement"></param>
  280. /// <returns></returns>
  281. [HttpPost("get-space")]
  282. public async Task<IActionResult> GetAssistSchoolSpace(JsonElement jsonElement)
  283. {
  284. if (!jsonElement.TryGetProperty("tmdId", out JsonElement tmdId)) return BadRequest();
  285. var cosmosClient = _azureCosmos.GetCosmosClient();
  286. List<string> schools = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
  287. List<SchoolSpace> schoolSpaces = new List<SchoolSpace>();
  288. foreach (var sid in schools)
  289. {
  290. School school = new();
  291. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(sid, new PartitionKey("Base"));
  292. if (response.Status == 200)
  293. {
  294. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  295. school = json.ToObject<School>();
  296. }
  297. long teach = 0;
  298. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: $"SELECT sum(c.size) as size FROM c ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Teacher-{sid}") }))
  299. {
  300. var json = await JsonDocument.ParseAsync(item.ContentStream);
  301. foreach (var elmt in json.RootElement.GetProperty("Documents").EnumerateArray())
  302. {
  303. if (elmt.TryGetProperty("size", out JsonElement _size) && _size.ValueKind.Equals(JsonValueKind.Number))
  304. {
  305. teach = _size.GetInt32();
  306. break;
  307. }
  308. }
  309. }
  310. SchoolSpace schoolSpace = new SchoolSpace() { id = sid, name = school != null ? school.name : sid };
  311. Space space = new Space();
  312. long blobsize = 0; //使用大小
  313. RedisValue value = default;
  314. value = _azureRedis.GetRedisClient(8).HashGet($"Blob:Record", sid);
  315. if (value != default && !value.IsNullOrEmpty)
  316. {
  317. JsonElement record = value.ToString().ToObject<JsonElement>();
  318. if (record.TryGetInt64(out blobsize))
  319. {
  320. }
  321. }
  322. else
  323. {
  324. var client = _azureStorage.GetBlobContainerClient(sid);
  325. var size = await client.GetBlobsCatalogSize();
  326. await _azureRedis.GetRedisClient(8).HashSetAsync($"Blob:Record", sid, size.Item1);
  327. foreach (var key in size.Item2.Keys)
  328. {
  329. await _azureRedis.GetRedisClient(8).SortedSetRemoveAsync($"Blob:Catalog:{sid}", key);
  330. await _azureRedis.GetRedisClient(8).SortedSetIncrementAsync($"Blob:Catalog:{sid}", key, size.Item2[key].HasValue ? size.Item2[key].Value : 0);
  331. }
  332. space.useSize = (long)size.Item1; space.tSize = teach; space.catalogSize = size.Item2;
  333. schoolSpace.space = space;
  334. schoolSpaces.Add(schoolSpace);
  335. continue;
  336. }
  337. Dictionary<string, double?> catalog = new Dictionary<string, double?>();
  338. SortedSetEntry[] Scores = _azureRedis.GetRedisClient(8).SortedSetRangeByScoreWithScores($"Blob:Catalog:{sid}");
  339. if (Scores != null)
  340. {
  341. foreach (var score in Scores)
  342. {
  343. double val = score.Score;
  344. string key = score.Element.ToString();
  345. catalog.Add(key, val);
  346. }
  347. space.useSize = blobsize; space.tSize = teach; space.catalogSize = catalog;
  348. schoolSpace.space = space;
  349. schoolSpaces.Add(schoolSpace);
  350. continue;
  351. }
  352. else
  353. {
  354. var client = _azureStorage.GetBlobContainerClient(sid);
  355. var size = await client.GetBlobsCatalogSize();
  356. await _azureRedis.GetRedisClient(8).HashSetAsync($"Blob:Record", sid, size.Item1);
  357. foreach (var key in size.Item2.Keys)
  358. {
  359. await _azureRedis.GetRedisClient(8).SortedSetRemoveAsync($"Blob:Catalog:{sid}", key);
  360. await _azureRedis.GetRedisClient(8).SortedSetIncrementAsync($"Blob:Catalog:{sid}", key, size.Item2[key].HasValue ? size.Item2[key].Value : 0);
  361. }
  362. space.useSize = (long)size.Item1;
  363. space.tSize = teach;
  364. space.catalogSize = size.Item2;
  365. schoolSpace.space = space;
  366. schoolSpaces.Add(schoolSpace);
  367. continue;
  368. }
  369. }
  370. return Ok(new { state = 200, schoolSpaces });
  371. }
  372. /// <summary>
  373. /// 移交学校顾问
  374. /// </summary>
  375. /// <param name="jsonElement"></param>
  376. /// <returns></returns>
  377. [HttpPost("get-shift")]
  378. public async Task<IActionResult> GetShift(JsonElement jsonElement)
  379. {
  380. var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);
  381. if (!jsonElement.TryGetProperty("school", out JsonElement _school)) return BadRequest();
  382. //if (!jsonElement.TryGetProperty("teacher", out JsonElement _teacher)) return BadRequest();
  383. if (!jsonElement.TryGetProperty("shiftTeacher", out JsonElement _shiftTeacher)) return BadRequest();
  384. var cosmosClient = _azureCosmos.GetCosmosClient();
  385. SchoolTeacher schoolTeacher = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemAsync<SchoolTeacher>($"{_tmdId}", new PartitionKey($"Teacher-{_school}"));
  386. if (schoolTeacher.roles.IsNotEmpty() && schoolTeacher.roles.Contains("assist"))
  387. {
  388. schoolTeacher.roles.Remove("assist");
  389. SchoolTeacher newSchoolTeacher = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemAsync<SchoolTeacher>($"{_shiftTeacher}", new PartitionKey($"Teacher-{_school}"));
  390. if (!newSchoolTeacher.roles.Contains("assist"))
  391. {
  392. newSchoolTeacher.roles.Add("assist");
  393. newSchoolTeacher = await cosmosClient.GetContainer("TEAMModelOS", "School").ReplaceItemAsync<SchoolTeacher>(newSchoolTeacher, $"{_shiftTeacher}", new PartitionKey($"Teacher-{_school}"));
  394. }
  395. await cosmosClient.GetContainer("TEAMModelOS", "School").ReplaceItemAsync<SchoolTeacher>(schoolTeacher, $"{_tmdId}", new PartitionKey($"Teacher-{_school}"));
  396. School schoolBase = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemAsync<School>($"{_school}", new PartitionKey($"Base"));
  397. //发送消息实体
  398. string shiftCode = "shift-assist";
  399. Notification notification = new Notification
  400. {
  401. hubName = "hita",
  402. type = "msg",
  403. from = $"BI:{_option.Location}:{_school}",
  404. to = new List<string> { $"{_shiftTeacher}" },
  405. label = $"{shiftCode}_school",
  406. body = new { location = _option.Location, biz = shiftCode, tmdid = $"{_tmdId}", tmdname = $"{_tmdName}", status = 1, time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() }.ToJsonString(),
  407. expires = DateTimeOffset.UtcNow.AddDays(7).ToUnixTimeSeconds()
  408. };
  409. if (notification != null)
  410. {
  411. var url = _configuration.GetValue<string>("HaBookAuth:CoreService:sendnotification");
  412. var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
  413. var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
  414. var location = _option.Location;
  415. await _notificationService.SendNotification(clientID, clientSecret, location, url, notification);//站内发送消息
  416. }
  417. //保存操作记录
  418. await _azureStorage.SaveLog("area-add", $"{_tmdName}【{_tmdId}】移交顾问给{newSchoolTeacher.name}【{newSchoolTeacher.id}】", _dingDing, httpContext: HttpContext);
  419. return Ok(new { state = 200 });
  420. }
  421. else { return Ok(new { status = 201, msg = $"{_tmdName}【{_tmdId}】账号不是顾问" }); }
  422. }
  423. /// <summary>
  424. /// 查询学校 数据管理工具——查询工具
  425. /// </summary>
  426. /// <returns></returns>
  427. [HttpPost("get-info")]
  428. public async Task<IActionResult> GetSchool(JsonElement jsonElement)
  429. {
  430. jsonElement.TryGetProperty("schoolId", out JsonElement schoolId);
  431. var clientCosmosDB = _azureCosmos.GetCosmosClient();
  432. StringBuilder sqlTxt = new StringBuilder("select * from c");
  433. if (!string.IsNullOrEmpty($"{schoolId}"))
  434. {
  435. sqlTxt.Append($" where c.id='{schoolId}'");
  436. }
  437. List<School> schools = new();
  438. await foreach (var item in clientCosmosDB.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: sqlTxt.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  439. {
  440. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  441. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  442. {
  443. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  444. {
  445. schools.Add(obj.ToObject<School>());
  446. }
  447. }
  448. }
  449. return Ok(new { state = 200, schools });
  450. }
  451. /// <summary>
  452. /// 修改学校的结构
  453. /// </summary>
  454. public record ReplaceSchool()
  455. {
  456. /// <summary>
  457. /// 醍摩豆账户ID
  458. /// </summary>
  459. public string tmdId { get; set; }
  460. /// <summary>
  461. /// 醍摩豆账户名称
  462. /// </summary>
  463. public string tmdName { get; set; }
  464. /// <summary>
  465. /// 学校
  466. /// </summary>
  467. public School school { get; set; }
  468. }
  469. /// <summary>
  470. /// 未加入区域的学校
  471. /// </summary>
  472. public record NotAreaSchool
  473. {
  474. public string id { get; set; }
  475. public string name { get; set; }
  476. public string schoolCode { get; set; }
  477. public string picture { get; set; }
  478. public List<string> period { get; set; }
  479. public string province { get; set; }
  480. public string city { get; set; }
  481. public string dist { get; set; }
  482. }
  483. /// <summary>
  484. /// 学校空间使用情况
  485. /// </summary>
  486. public record SchoolSpace
  487. {
  488. public string id { get; set; }
  489. public string name { get; set; }
  490. public Space space { get; set; }
  491. }
  492. /// <summary>
  493. /// 空间
  494. /// </summary>
  495. public record Space
  496. {
  497. /// <summary>
  498. /// 已使用空间
  499. /// </summary>
  500. public long useSize { get; set; }
  501. /// <summary>
  502. /// 分配教师空间
  503. /// </summary>
  504. public long tSize { get; set; }
  505. /// <summary>
  506. /// 空间类型
  507. /// </summary>
  508. public Dictionary<string, double?> catalogSize { get; set; }
  509. }
  510. }
  511. }