TriggerHomework.cs 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230
  1. using Azure.Cosmos;
  2. using Azure.Messaging.ServiceBus;
  3. using HTEXLib.COMM.Helpers;
  4. using Microsoft.Azure.Documents;
  5. using Microsoft.Extensions.Configuration;
  6. using System;
  7. using System.Collections.Generic;
  8. using System.Linq;
  9. using System.Text;
  10. using System.Text.Json;
  11. using System.Threading.Tasks;
  12. using TEAMModelOS.SDK;
  13. using TEAMModelOS.SDK.DI;
  14. using TEAMModelOS.SDK.Extension;
  15. using TEAMModelOS.SDK.Models;
  16. using TEAMModelOS.SDK.Models.Cosmos.Common;
  17. using TEAMModelOS.SDK.Models.Service;
  18. namespace TEAMModelOS.FunctionV4
  19. {
  20. public static class TriggerHomework
  21. {
  22. public static async Task Trigger(AzureServiceBusFactory _serviceBus, AzureStorageFactory _azureStorage, DingDing _dingDing,
  23. CosmosClient client, JsonElement input, TriggerData tdata, AzureRedisFactory _azureRedis, IConfiguration _configuration)
  24. {
  25. try
  26. {
  27. if ((tdata.status != null && tdata.status.Value == 404) || tdata.ttl > 0)
  28. {
  29. return;
  30. }
  31. var adid = tdata.id;
  32. var adcode = "";
  33. string blobcntr = null;
  34. if (tdata.scope.Equals("school"))
  35. {
  36. adcode = $"Activity-{tdata.school}";
  37. blobcntr = tdata.school;
  38. }
  39. else
  40. {
  41. adcode = $"Activity-{tdata.creatorId}";
  42. blobcntr = tdata.creatorId;
  43. }
  44. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}作业活动【{tdata.name}-{tdata.id}-ttl={tdata.ttl}】正在操作", GroupNames.成都开发測試群組);
  45. Homework work = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<Homework>(tdata.id, new Azure.Cosmos.PartitionKey($"{tdata.code}"));
  46. if (work != null)
  47. {
  48. string PartitionKey = string.Format("{0}{1}{2}", work.code, "-", work.progress);
  49. List<ChangeRecord> changeRecords = await _azureStorage.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", tdata.id }, { "PartitionKey", PartitionKey } });
  50. switch (work.progress)
  51. {
  52. case "pending":
  53. var messageWork = new ServiceBusMessage(new { id = tdata.id, progress = "going", code = tdata.code }.ToJsonString());
  54. messageWork.ApplicationProperties.Add("name", "Homework");
  55. if (changeRecords.Count > 0)
  56. {
  57. await _serviceBus.GetServiceBusClient().cancelMessage(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), changeRecords[0].sequenceNumber);
  58. long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWork, DateTimeOffset.FromUnixTimeMilliseconds(tdata.startTime));
  59. changeRecords[0].sequenceNumber = start;
  60. await _azureStorage.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
  61. }
  62. else
  63. {
  64. long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWork, DateTimeOffset.FromUnixTimeMilliseconds(tdata.startTime));
  65. ChangeRecord changeRecord = new ChangeRecord
  66. {
  67. RowKey = tdata.id,
  68. PartitionKey = PartitionKey,
  69. sequenceNumber = start,
  70. msgId = messageWork.MessageId
  71. };
  72. await _azureStorage.Save<ChangeRecord>(changeRecord);
  73. }
  74. break;
  75. case "going":
  76. List<(string pId, List<string> gid)> ps = new List<(string pId, List<string> gid)>();
  77. if (work.groupLists.Count > 0)
  78. {
  79. var group = work.groupLists;
  80. foreach (var gp in group)
  81. {
  82. foreach (KeyValuePair<string, List<string>> pp in gp)
  83. {
  84. ps.Add((pp.Key, pp.Value));
  85. }
  86. }
  87. }
  88. List<string> classes = ExamService.getClasses(work.classes, work.stuLists);
  89. (List<RMember> tmdids, List<RGroupList> classLists) = await GroupListService.GetStutmdidListids(client, _dingDing, classes, work.school, ps);
  90. var addStudentsCls = tmdids.FindAll(x => x.type == 2);
  91. var addTmdidsCls = tmdids.FindAll(x => x.type == 1);
  92. List<StuActivity> stuActivities = new List<StuActivity>();
  93. List<StuActivity> tmdActivities = new List<StuActivity>();
  94. List<StuActivity> tchActivities = new List<StuActivity>();
  95. if (addTmdidsCls.IsNotEmpty())
  96. {
  97. addTmdidsCls.ForEach(x =>
  98. {
  99. tmdActivities.Add(new StuActivity
  100. {
  101. pk = "Activity",
  102. id = work.id,
  103. code = $"Activity-{x.id}",
  104. type = "Homework",
  105. name = work.name,
  106. startTime = work.startTime,
  107. endTime = work.endTime,
  108. scode = work.code,
  109. scope = work.scope,
  110. school = work.school,
  111. creatorId = work.creatorId,
  112. subjects = new List<string> { "" },
  113. blob = work.blob,
  114. owner = work.owner,
  115. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  116. taskStatus = -1,
  117. classIds = classes
  118. });
  119. });
  120. }
  121. if (addStudentsCls.IsNotEmpty())
  122. {
  123. addStudentsCls.ForEach(x =>
  124. {
  125. stuActivities.Add(new StuActivity
  126. {
  127. pk = "Activity",
  128. id = work.id,
  129. code = $"Activity-{x.code.Replace("Base-", "")}-{x.id}",
  130. type = "Homework",
  131. name = work.name,
  132. startTime = work.startTime,
  133. endTime = work.endTime,
  134. scode = work.code,
  135. scope = work.scope,
  136. school = work.school,
  137. creatorId = work.creatorId,
  138. subjects = new List<string> { "" },
  139. blob = work.blob,
  140. owner = work.owner,
  141. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  142. taskStatus = -1,
  143. classIds = classes
  144. });
  145. });
  146. }
  147. (List<RMember> tchList, List<RGroupList> classInfos) = await GroupListService.GetStutmdidListids(client, _dingDing, work.tchLists, work.school,ps);
  148. (string standard, List<string> tmdids, string school, List<string> update, int statistics) list = (null, null, null, new List<string> { StatisticsService.OfflineRecord }, 0);
  149. if (tchList.IsNotEmpty())
  150. {
  151. list.tmdids = tchList.Select(x => x.id).ToList();
  152. School school = null;
  153. if (!string.IsNullOrEmpty(work.school))
  154. {
  155. school = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>(work.school, new Azure.Cosmos.PartitionKey("Base"));
  156. list.school = school.id;
  157. list.standard = school.standard;
  158. }
  159. tchList.ForEach(x =>
  160. {
  161. tchActivities.Add(new StuActivity
  162. {
  163. pk = "Activity",
  164. id = work.id,
  165. code = $"Activity-{x.id}",
  166. type = "Homework",
  167. name = work.name,
  168. startTime = work.startTime,
  169. endTime = work.endTime,
  170. scode = work.code,
  171. scope = work.scope,
  172. school = work.school,
  173. creatorId = work.creatorId,
  174. subjects = new List<string> { "" },
  175. blob = work.blob,
  176. owner = work.owner,
  177. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  178. taskStatus = -1,
  179. classIds = work.tchLists
  180. });
  181. });
  182. }
  183. await ActivityService.SaveStuActivity(client, _dingDing, stuActivities, tmdActivities, tchActivities);
  184. await StatisticsService.SendServiceBus(list, _configuration, _serviceBus, client);
  185. var messageWorkEnd = new ServiceBusMessage(new { id = tdata.id, progress = "finish", code = tdata.code }.ToJsonString());
  186. messageWorkEnd.ApplicationProperties.Add("name", "Homework");
  187. if (changeRecords.Count > 0)
  188. {
  189. long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWorkEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
  190. await _serviceBus.GetServiceBusClient().cancelMessage(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), changeRecords[0].sequenceNumber);
  191. changeRecords[0].sequenceNumber = end;
  192. await _azureStorage.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
  193. }
  194. else
  195. {
  196. long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWorkEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
  197. ChangeRecord changeRecord = new ChangeRecord
  198. {
  199. RowKey = tdata.id,
  200. PartitionKey = PartitionKey,
  201. sequenceNumber = end,
  202. msgId = messageWorkEnd.MessageId
  203. };
  204. await _azureStorage.Save<ChangeRecord>(changeRecord);
  205. }
  206. //if (bustasks.IsNotEmpty())
  207. //{
  208. // await Task.WhenAll(bustasks);
  209. //}
  210. break;
  211. case "finish":
  212. break;
  213. }
  214. }
  215. }
  216. catch (CosmosException e)
  217. {
  218. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-CosmosDB异常{e.Message}\n{e.Status}", GroupNames.成都开发測試群組);
  219. }
  220. catch (Exception ex)
  221. {
  222. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修作业活动异常{ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
  223. }
  224. }
  225. }
  226. }