ActivityHttpTrigger.cs 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534
  1. using System;
  2. using System.IO;
  3. using System.Threading.Tasks;
  4. using Microsoft.AspNetCore.Mvc;
  5. using Microsoft.Azure.WebJobs;
  6. using Microsoft.Azure.WebJobs.Extensions.Http;
  7. using Microsoft.AspNetCore.Http;
  8. using Microsoft.Extensions.Logging;
  9. using TEAMModelOS.SDK.DI;
  10. using Azure.Cosmos;
  11. using System.Text.Json;
  12. using System.Collections.Generic;
  13. using TEAMModelOS.SDK.Models;
  14. using TEAMModelOS.SDK.Extension;
  15. using TEAMModelOS.SDK;
  16. using TEAMModelOS.SDK.Models.Cosmos;
  17. using TEAMModelOS.SDK.Models.Cosmos.Common;
  18. using System.Linq;
  19. using TEAMModelOS.Services.Common;
  20. using TEAMModelOS.SDK.Models.Service;
  21. using HTEXLib.COMM.Helpers;
  22. namespace TEAMModelFunction
  23. {
  24. public class ActivityHttpTrigger
  25. {
  26. private readonly AzureCosmosFactory _azureCosmos;
  27. private readonly DingDing _dingDing;
  28. private readonly AzureStorageFactory _azureStorage;
  29. private readonly AzureRedisFactory _azureRedis;
  30. public ActivityHttpTrigger(AzureCosmosFactory azureCosmos, DingDing dingDing, AzureStorageFactory azureStorage
  31. , AzureRedisFactory azureRedis)
  32. {
  33. _azureCosmos = azureCosmos;
  34. _dingDing = dingDing;
  35. _azureStorage = azureStorage;
  36. _azureRedis = azureRedis;
  37. }
  38. /// <summary>
  39. /// 修复已存在的课程且未初始化学生课程列表的业务。
  40. /// </summary>
  41. /// <param name="req"></param>
  42. /// <param name="log"></param>
  43. /// <returns></returns>
  44. [FunctionName("fix-stu-course")]
  45. public async Task<IActionResult> StuCourse([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req, ILogger log)
  46. {
  47. log.LogInformation("fix-stu-course...");
  48. string originCode = await new StreamReader(req.Body).ReadToEndAsync();
  49. List<Course> courses = new List<Course>();
  50. var client = _azureCosmos.GetCosmosClient();
  51. var query = $"select * from c ";
  52. await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<Course>(queryText: query,
  53. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Course-{originCode}") }))
  54. {
  55. courses.Add(item);
  56. }
  57. await foreach (var item in client.GetContainer("TEAMModelOS", "Teacher").GetItemQueryIterator<Course>(queryText: query,
  58. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Course-{originCode}") }))
  59. {
  60. courses.Add(item);
  61. }
  62. //2.获取课程的id 并尝试添加或移除对应的学生课程记录StuCourse。
  63. foreach (var course in courses)
  64. {
  65. if (course.schedule.IsNotEmpty())
  66. {
  67. foreach (var sc in course.schedule)
  68. {
  69. if (!string.IsNullOrEmpty(sc.stulist))
  70. {
  71. (List<RMember> tchList, List<RGroupList> classLists) = await GroupListService.GetStutmdidListids(client, _dingDing, new List<string>() { sc.stulist }, course.school);
  72. var addStudentsCls = tchList.FindAll(x => x.type == 2);
  73. var addTmdidsCls = tchList.FindAll(x => x.type == 1);
  74. //(List<TmdInfo> tmdids, List<StuInfo> students, List<ClassListInfo> classLists) = await TriggerStuActivity.GetStuList(client, _dingDing, new List<string>() { sc.stulist }, course.school);
  75. foreach (var addStu in addStudentsCls)
  76. {
  77. var stuCourse = new StuCourse
  78. {
  79. id = course.id,
  80. scode = course.code,
  81. name = course.name,
  82. code = $"StuCourse-{course.school}-{addStu.id}",
  83. scope = course.scope,
  84. school = course.school,
  85. creatorId = course.creatorId,
  86. pk = "StuCourse",
  87. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
  88. };
  89. await client.GetContainer("TEAMModelOS", "Student").UpsertItemAsync(stuCourse, new PartitionKey(stuCourse.code));
  90. }
  91. foreach (var addTmd in addTmdidsCls)
  92. {
  93. var tmdCourse = new StuCourse
  94. {
  95. id = course.id,
  96. scode = course.code,
  97. name = course.name,
  98. code = $"StuCourse-{addTmd}",
  99. scope = course.scope,
  100. //school = courseChange.school,
  101. creatorId = course.creatorId,
  102. pk = "StuCourse",
  103. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
  104. };
  105. await client.GetContainer("TEAMModelOS", "Teacher").UpsertItemAsync(tmdCourse, new PartitionKey(tmdCourse.code));
  106. }
  107. }
  108. }
  109. }
  110. }
  111. return new OkObjectResult(new { });
  112. }
  113. /// <summary>
  114. /// 设置评测未初始化学生列表的
  115. /// </summary>
  116. /// <param name="req"></param>
  117. /// <param name="log"></param>
  118. /// <returns></returns>
  119. [FunctionName("fix-exam-activity")]
  120. public async Task<IActionResult> ExamActivity([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req,ILogger log)
  121. {
  122. log.LogInformation("fix-exam-activity...");
  123. string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
  124. List<string> datas = JsonSerializer.Deserialize<List<string>>(requestBody);
  125. var client = _azureCosmos.GetCosmosClient();
  126. var query = $"select * from c ";
  127. foreach (string data in datas) {
  128. List<ExamInfo> exams = new List<ExamInfo>();
  129. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(
  130. queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Exam-{data}") }))
  131. {
  132. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  133. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  134. {
  135. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  136. {
  137. exams.Add(obj.ToObject<ExamInfo>());
  138. }
  139. }
  140. }
  141. log.LogInformation($"{exams.ToJsonString()}");
  142. foreach (var info in exams)
  143. {
  144. List<string> classes = ExamService.getClasses(info.classes,info.stuLists);
  145. if (!classes.IsNotEmpty())
  146. {
  147. continue;
  148. }
  149. List<string> sub = new List<string>();
  150. foreach (ExamSubject subject in info.subjects)
  151. {
  152. sub.Add(subject.id);
  153. }
  154. (List<RMember> tchList, List<RGroupList> classLists) = await GroupListService.GetStutmdidListids(client, _dingDing, classes, info.school);
  155. var addStudentsCls = tchList.FindAll(x => x.type == 2);
  156. var addTmdidsCls = tchList.FindAll(x => x.type == 1);
  157. //(List<TmdInfo> tmdids, List<StuInfo> studentss, List<ClassListInfo> classLists) = await TriggerStuActivity.GetStuList(client, _dingDing, classes, info.school);
  158. List<StuActivity> stuActivities = new List<StuActivity>();
  159. List<StuActivity> tmdActivities = new List<StuActivity>();
  160. if (addTmdidsCls.IsNotEmpty())
  161. {
  162. addTmdidsCls.ForEach(x => {
  163. tmdActivities.Add(new StuActivity
  164. {
  165. pk = "Activity",
  166. id = info.id,
  167. code = $"Activity-{x.id}",
  168. type = "Exam",
  169. name = info.name,
  170. startTime = info.startTime,
  171. endTime = info.endTime,
  172. scode = info.code,
  173. scope = info.scope,
  174. school = info.school,
  175. creatorId = info.creatorId,
  176. subjects = sub,
  177. blob = null,
  178. owner = info.owner,
  179. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  180. taskStatus = -1,
  181. classIds = classes
  182. });
  183. });
  184. }
  185. if (addStudentsCls.IsNotEmpty())
  186. {
  187. addStudentsCls.ForEach(x => {
  188. stuActivities.Add(new StuActivity
  189. {
  190. pk = "Activity",
  191. id = info.id,
  192. code = $"Activity-{info.school}-{x.id}",
  193. type = "Exam",
  194. name = info.name,
  195. startTime = info.startTime,
  196. endTime = info.endTime,
  197. scode = info.code,
  198. scope = info.scope,
  199. school = info.school,
  200. creatorId = info.creatorId,
  201. subjects = sub,
  202. blob=null,
  203. owner = info.owner,
  204. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  205. taskStatus = -1,
  206. classIds = classes
  207. });
  208. });
  209. }
  210. await TriggerStuActivity.SaveStuActivity(client, _dingDing, stuActivities, tmdActivities,null);
  211. }
  212. }
  213. return new OkObjectResult(new { });
  214. }
  215. /// <summary>
  216. /// 设置投票未初始化学生列表的业务
  217. /// </summary>
  218. /// <param name="req"></param>
  219. /// <param name="log"></param>
  220. /// <returns></returns>
  221. [FunctionName("fix-vote-activity")]
  222. public async Task<IActionResult> VoteActivity(
  223. [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
  224. ILogger log)
  225. {
  226. log.LogInformation("fix-vote-activity...");
  227. string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
  228. List<string> datas = JsonSerializer.Deserialize<List<string>>(requestBody);
  229. var client = _azureCosmos.GetCosmosClient();
  230. var query = $"select * from c ";
  231. foreach (string data in datas)
  232. {
  233. List<Vote> votes = new List<Vote>();
  234. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(
  235. queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Vote-{data}") }))
  236. {
  237. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  238. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  239. {
  240. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  241. {
  242. votes.Add(obj.ToObject<Vote>());
  243. }
  244. }
  245. }
  246. log.LogInformation($"{votes.ToJsonString()}");
  247. foreach (var info in votes)
  248. {
  249. List<string> classes = ExamService.getClasses(info.classes, info.stuLists);
  250. if (classes.IsNotEmpty())
  251. {
  252. continue;
  253. }
  254. (List<RMember> tchList, List<RGroupList> classLists) = await GroupListService.GetStutmdidListids(client, _dingDing, classes, info.school);
  255. var addStudentsCls = tchList.FindAll(x => x.type == 2);
  256. var addTmdidsCls = tchList.FindAll(x => x.type == 1);
  257. //(List<TmdInfo> tmdids, List<StuInfo> studentss, List<ClassListInfo> classLists) = await TriggerStuActivity.GetStuList(client, _dingDing, classes, info.school);
  258. List<StuActivity> stuActivities = new List<StuActivity>();
  259. List<StuActivity> tmdActivities = new List<StuActivity>();
  260. if (addTmdidsCls.IsNotEmpty())
  261. {
  262. addTmdidsCls.ForEach(x => {
  263. tmdActivities.Add(new StuActivity
  264. {
  265. pk = "Activity",
  266. id = info.id,
  267. code = $"Activity-{x.id}",
  268. type = "Vote",
  269. name = info.name,
  270. startTime = info.startTime,
  271. endTime = info.endTime,
  272. scode = info.code,
  273. scope = info.scope,
  274. school = info.school,
  275. creatorId = info.creatorId,
  276. subjects = new List<string>() { "" },
  277. blob = null,
  278. owner = info.owner,
  279. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  280. taskStatus = -1,
  281. classIds = classes
  282. });
  283. });
  284. }
  285. if (addStudentsCls.IsNotEmpty())
  286. {
  287. addStudentsCls.ForEach(x => {
  288. stuActivities.Add(new StuActivity
  289. {
  290. pk = "Activity",
  291. id = info.id,
  292. code = $"Activity-{info.school}-{x.id}",
  293. type = "Vote",
  294. name = info.name,
  295. startTime = info.startTime,
  296. endTime = info.endTime,
  297. scode = info.code,
  298. scope = info.scope,
  299. school = info.school,
  300. creatorId = info.creatorId,
  301. subjects = new List<string>() { "" },
  302. blob = null,
  303. owner = info.owner,
  304. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  305. taskStatus = -1,
  306. classIds = classes
  307. });
  308. });
  309. }
  310. await TriggerStuActivity.SaveStuActivity(client, _dingDing, stuActivities, tmdActivities, null);
  311. }
  312. }
  313. return new OkObjectResult(new { });
  314. }
  315. /// <summary>
  316. /// 设置问卷调查未初始化学生列表的业务
  317. /// </summary>
  318. /// <param name="req"></param>
  319. /// <param name="log"></param>
  320. /// <returns></returns>
  321. [FunctionName("fix-survey-activity")]
  322. public async Task<IActionResult> SurveyActivity(
  323. [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
  324. ILogger log)
  325. {
  326. log.LogInformation("fix-survey-activity...");
  327. string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
  328. List<string> datas = JsonSerializer.Deserialize<List<string>>(requestBody);
  329. var client = _azureCosmos.GetCosmosClient();
  330. var query = $"select * from c ";
  331. foreach (string data in datas)
  332. {
  333. List<Survey> surveys = new List<Survey>();
  334. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(
  335. queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Survey-{data}") }))
  336. {
  337. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  338. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  339. {
  340. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  341. {
  342. surveys.Add(obj.ToObject<Survey>());
  343. }
  344. }
  345. }
  346. log.LogInformation($"{surveys.ToJsonString()}");
  347. foreach (var info in surveys)
  348. {
  349. List<string> classes = ExamService.getClasses(info.classes, info.stuLists);
  350. if (!classes.IsNotEmpty())
  351. {
  352. continue;
  353. }
  354. (List<RMember> tchList, List<RGroupList> classLists) = await GroupListService.GetStutmdidListids(client, _dingDing, classes, info.school);
  355. var addStudentsCls = tchList.FindAll(x => x.type == 2);
  356. var addTmdidsCls = tchList.FindAll(x => x.type == 1);
  357. //(List<TmdInfo> tmdids, List<StuInfo> studentss, List<ClassListInfo> classLists) = await TriggerStuActivity.GetStuList(client, _dingDing, classes, info.school);
  358. List<StuActivity> stuActivities = new List<StuActivity>();
  359. List<StuActivity> tmdActivities = new List<StuActivity>();
  360. if (addTmdidsCls.IsNotEmpty())
  361. {
  362. addTmdidsCls.ForEach(x => {
  363. tmdActivities.Add(new StuActivity
  364. {
  365. pk = "Activity",
  366. id = info.id,
  367. code = $"Activity-{x.id}",
  368. type = "Survey",
  369. name = info.name,
  370. startTime = info.startTime,
  371. endTime = info.endTime,
  372. scode = info.code,
  373. scope = info.scope,
  374. school = info.school,
  375. creatorId = info.creatorId,
  376. subjects = new List<string>() { "" },
  377. blob = info.blob,
  378. owner=info.owner,
  379. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  380. taskStatus = -1,
  381. classIds = classes
  382. });
  383. });
  384. }
  385. if (addStudentsCls.IsNotEmpty())
  386. {
  387. addStudentsCls.ForEach(x => {
  388. stuActivities.Add(new StuActivity
  389. {
  390. pk = "Activity",
  391. id = info.id,
  392. code = $"Activity-{info.school}-{x.id}",
  393. type = "Survey",
  394. name = info.name,
  395. startTime = info.startTime,
  396. endTime = info.endTime,
  397. scode = info.code,
  398. scope = info.scope,
  399. school = info.school,
  400. creatorId = info.creatorId,
  401. subjects = new List<string>() { "" },
  402. blob=info.blob,
  403. owner = info.owner,
  404. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  405. taskStatus = -1,
  406. classIds = classes
  407. });
  408. });
  409. }
  410. await TriggerStuActivity.SaveStuActivity(client, _dingDing, stuActivities, tmdActivities, null);
  411. }
  412. }
  413. return new OkObjectResult(new { });
  414. }
  415. /// <summary>
  416. ///获取单个目录的大小,用于获取评测,试题,试卷,问卷,投票等 文件层级超过两层的文件。
  417. ///例如 /exam/uuid/xxx /item/uuid/xxx /paper/uuid/xxx /vote/uuid/xxx /suervy/uuid/xxx
  418. /// {"name":"hbcn","/item/uuid/xxx"}
  419. /// </summary>
  420. /// <param name="req"></param>
  421. /// <param name="log"></param>
  422. /// <returns></returns>
  423. [FunctionName("get-prefixsize")]
  424. public async Task<IActionResult> GetPrefixsize(
  425. [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
  426. ILogger log)
  427. {
  428. try {
  429. string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
  430. var data = System.Text.Json.JsonSerializer.Deserialize<JsonElement>(requestBody);
  431. if (data.TryGetProperty("name", out JsonElement name) && data.TryGetProperty("root", out JsonElement root))
  432. {
  433. var size = await _azureStorage.GetBlobContainerClient($"{name}").GetBlobsSize($"{root}");
  434. return new OkObjectResult(new { size = size });
  435. }
  436. else
  437. {
  438. return new BadRequestResult();
  439. }
  440. } catch (Exception ex) {
  441. await _dingDing.SendBotMsg($"TEAMModelFunction,ActivityHttpTrigger,get-prefixsize()\n{ex.Message}", GroupNames.醍摩豆服務運維群組);
  442. return new BadRequestResult();
  443. }
  444. }
  445. /// <summary>
  446. ///获取多个blob路径的文件大小
  447. /// {"name":"hbcn","blobs":["/paper/uuid/xxx.json","/paper/uuid/aaa.json"]}
  448. /// </summary>
  449. /// <param name="req"></param>
  450. /// <param name="log"></param>
  451. /// <returns></returns>
  452. [FunctionName("used-space")]
  453. public async Task<IActionResult> UsedSpace(
  454. [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
  455. ILogger log)
  456. {
  457. try {
  458. string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
  459. var data = System.Text.Json.JsonSerializer.Deserialize<JsonElement>(requestBody);
  460. if (data.TryGetProperty("name", out JsonElement name) && data.TryGetProperty("blobs", out JsonElement blob))
  461. {
  462. List<string> blobs = JsonSerializer.Deserialize<List<string>>(blob.ToJsonString());
  463. var size= await _azureStorage.GetBlobContainerClient($"{name}").GetBlobsSize(blobs);
  464. return new OkObjectResult(new { size = size });
  465. }
  466. else {
  467. return new BadRequestResult();
  468. }
  469. } catch (Exception ex)
  470. {
  471. await _dingDing.SendBotMsg($"TEAMModelFunction,ActivityHttpTrigger,get-blobsize()\n{ex.Message}", GroupNames.醍摩豆服務運維群組);
  472. return new BadRequestResult();
  473. }
  474. }
  475. /// <summary>
  476. /// 修复容器的内容显示
  477. /// </summary>
  478. /// <param name="req"></param>
  479. /// <param name="log"></param>
  480. /// <returns></returns>
  481. [FunctionName("fix-blob-content")]
  482. public async Task<IActionResult> FixBlobContent(
  483. [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
  484. ILogger log)
  485. {
  486. try
  487. {
  488. var client = _azureCosmos.GetCosmosClient();
  489. string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
  490. var data = System.Text.Json.JsonSerializer.Deserialize<JsonElement>(requestBody);
  491. await FixDataService.FixBlobContent(client, _dingDing, _azureStorage, data);
  492. return new OkObjectResult(new { });
  493. }
  494. catch (Exception ex)
  495. {
  496. await _dingDing.SendBotMsg($"TEAMModelFunction,ActivityHttpTrigger,fix-blob-content()\n{ex.Message}{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  497. return new BadRequestResult();
  498. }
  499. }
  500. /// <summary>
  501. /// 修复容器的内容显示
  502. /// </summary>
  503. /// <param name="req"></param>
  504. /// <param name="log"></param>
  505. /// <returns></returns>
  506. [FunctionName("fix-student-info")]
  507. public async Task<IActionResult> FixStudentInfo(
  508. [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
  509. ILogger log)
  510. {
  511. var client = _azureCosmos.GetCosmosClient();
  512. string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
  513. var data = System.Text.Json.JsonSerializer.Deserialize<JsonElement>(requestBody);
  514. await FixDataService.FixStudentInfo(client, _dingDing, _azureStorage, data);
  515. return new OkObjectResult(new { });
  516. }
  517. }
  518. }