TriggerHomework.cs 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261
  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(CoreAPIHttpService _coreAPIHttpService,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) )
  28. {
  29. await client.GetContainer(Constant.TEAMModelOS, "Common").DeleteItemStreamAsync(tdata.id, new PartitionKey(tdata.code));
  30. ActivityList data = input.ToObject<ActivityList>();
  31. await ActivityService.DeleteActivity(_coreAPIHttpService, client, _dingDing, data);
  32. return;
  33. }
  34. var adid = tdata.id;
  35. var adcode = "";
  36. string blobcntr = null;
  37. if (tdata.scope.Equals("school"))
  38. {
  39. adcode = $"Activity-{tdata.school}";
  40. blobcntr = tdata.school;
  41. }
  42. else
  43. {
  44. adcode = $"Activity-{tdata.creatorId}";
  45. blobcntr = tdata.creatorId;
  46. }
  47. //await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}作业活动【{tdata.name}-{tdata.id}-ttl={tdata.ttl}】正在操作", GroupNames.成都开发測試群組);
  48. Homework work = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<Homework>(tdata.id, new Azure.Cosmos.PartitionKey($"{tdata.code}"));
  49. if (work != null)
  50. {
  51. string PartitionKey = string.Format("{0}{1}{2}", work.code, "-", work.progress);
  52. List<ChangeRecord> changeRecords = await _azureStorage.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", tdata.id }, { "PartitionKey", PartitionKey } });
  53. switch (work.progress)
  54. {
  55. case "pending":
  56. var messageWork = new ServiceBusMessage(new { id = tdata.id, progress = "going", code = tdata.code }.ToJsonString());
  57. messageWork.ApplicationProperties.Add("name", "Homework");
  58. if (changeRecords.Count > 0)
  59. {
  60. await _serviceBus.GetServiceBusClient().cancelMessage(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), changeRecords[0].sequenceNumber);
  61. long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWork, DateTimeOffset.FromUnixTimeMilliseconds(tdata.startTime));
  62. changeRecords[0].sequenceNumber = start;
  63. await _azureStorage.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
  64. }
  65. else
  66. {
  67. long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWork, DateTimeOffset.FromUnixTimeMilliseconds(tdata.startTime));
  68. ChangeRecord changeRecord = new ChangeRecord
  69. {
  70. RowKey = tdata.id,
  71. PartitionKey = PartitionKey,
  72. sequenceNumber = start,
  73. msgId = messageWork.MessageId
  74. };
  75. await _azureStorage.Save<ChangeRecord>(changeRecord);
  76. }
  77. break;
  78. case "going":
  79. List<(string pId, List<string> gid)> ps = new List<(string pId, List<string> gid)>();
  80. if (work.groupLists.Count > 0)
  81. {
  82. var group = work.groupLists;
  83. foreach (var gp in group)
  84. {
  85. foreach (KeyValuePair<string, List<string>> pp in gp)
  86. {
  87. ps.Add((pp.Key, pp.Value));
  88. }
  89. }
  90. }
  91. List<string> classes = ExamService.getClasses(work.classes, work.stuLists);
  92. (List<RMember> tmdids, List<RGroupList> classLists) = await GroupListService.GetStutmdidListids(_coreAPIHttpService, client, _dingDing, classes, work.school, ps);
  93. var addStudentsCls = tmdids.FindAll(x => x.type == 2);
  94. var addTmdidsCls = tmdids.FindAll(x => x.type == 1);
  95. List<StuActivity> stuActivities = new List<StuActivity>();
  96. List<StuActivity> tmdActivities = new List<StuActivity>();
  97. List<StuActivity> tchActivities = new List<StuActivity>();
  98. if (addTmdidsCls.IsNotEmpty())
  99. {
  100. addTmdidsCls.ForEach(x =>
  101. {
  102. HashSet<string> classIds = new HashSet<string>();
  103. classLists.ForEach(z => {
  104. z.members.ForEach(y => {
  105. if (y.id.Equals(x) && y.type == 1)
  106. {
  107. classIds.Add(z.id);
  108. }
  109. });
  110. });
  111. tmdActivities.Add(new StuActivity
  112. {
  113. pk = "Activity",
  114. id = work.id,
  115. code = $"Activity-{x.id}",
  116. type = "Homework",
  117. name = work.name,
  118. startTime = work.startTime,
  119. endTime = work.endTime,
  120. scode = work.code,
  121. scope = work.scope,
  122. school = work.school,
  123. creatorId = work.creatorId,
  124. subjects = new List<string> { "" },
  125. blob = work.blob,
  126. owner = work.owner,
  127. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  128. taskStatus = -1,
  129. classIds = classIds.ToList()
  130. });
  131. });
  132. }
  133. if (addStudentsCls.IsNotEmpty())
  134. {
  135. addStudentsCls.ForEach(x =>
  136. {
  137. HashSet<string> classIds = new HashSet<string>();
  138. classLists.ForEach(z => {
  139. z.members.ForEach(y => {
  140. if (y.id.Equals(x) &&y.code.Equals(work.school) && y.type ==2)
  141. {
  142. classIds.Add(z.id);
  143. }
  144. });
  145. });
  146. stuActivities.Add(new StuActivity
  147. {
  148. pk = "Activity",
  149. id = work.id,
  150. code = $"Activity-{x.code.Replace("Base-", "")}-{x.id}",
  151. type = "Homework",
  152. name = work.name,
  153. startTime = work.startTime,
  154. endTime = work.endTime,
  155. scode = work.code,
  156. scope = work.scope,
  157. school = work.school,
  158. creatorId = work.creatorId,
  159. subjects = new List<string> { "" },
  160. blob = work.blob,
  161. owner = work.owner,
  162. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  163. taskStatus = -1,
  164. classIds = classIds.ToList()
  165. });
  166. });
  167. }
  168. (List<RMember> tchList, List<RGroupList> classInfos) = await GroupListService.GetStutmdidListids(_coreAPIHttpService, client, _dingDing, work.tchLists, work.school,ps);
  169. (string standard, List<string> tmdids, string school, List<string> update, int statistics) list = (null, null, null, new List<string> { StatisticsService.OfflineRecord }, 0);
  170. if (tchList.IsNotEmpty())
  171. {
  172. list.tmdids = tchList.Select(x => x.id).ToList();
  173. School school = null;
  174. if (!string.IsNullOrEmpty(work.school))
  175. {
  176. school = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>(work.school, new Azure.Cosmos.PartitionKey("Base"));
  177. list.school = school.id;
  178. list.standard = school.standard;
  179. }
  180. tchList.ForEach(x =>
  181. {
  182. HashSet<string> classIds = new HashSet<string>();
  183. classInfos.ForEach(z => {
  184. z.members.ForEach(y => {
  185. if (y.id.Equals(x) && y.type == 1)
  186. {
  187. classIds.Add(z.id);
  188. }
  189. });
  190. });
  191. tchActivities.Add(new StuActivity
  192. {
  193. pk = "Activity",
  194. id = work.id,
  195. code = $"Activity-{x.id}",
  196. type = "Homework",
  197. name = work.name,
  198. startTime = work.startTime,
  199. endTime = work.endTime,
  200. scode = work.code,
  201. scope = work.scope,
  202. school = work.school,
  203. creatorId = work.creatorId,
  204. subjects = new List<string> { "" },
  205. blob = work.blob,
  206. owner = work.owner,
  207. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  208. taskStatus = -1,
  209. classIds = classIds.ToList()
  210. });
  211. });
  212. }
  213. await ActivityService.SaveStuActivity(client, _dingDing, stuActivities, tmdActivities, tchActivities);
  214. await StatisticsService.SendServiceBus(list, _configuration, _serviceBus, client);
  215. var messageWorkEnd = new ServiceBusMessage(new { id = tdata.id, progress = "finish", code = tdata.code }.ToJsonString());
  216. messageWorkEnd.ApplicationProperties.Add("name", "Homework");
  217. if (changeRecords.Count > 0)
  218. {
  219. long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWorkEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
  220. await _serviceBus.GetServiceBusClient().cancelMessage(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), changeRecords[0].sequenceNumber);
  221. changeRecords[0].sequenceNumber = end;
  222. await _azureStorage.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
  223. }
  224. else
  225. {
  226. long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWorkEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
  227. ChangeRecord changeRecord = new ChangeRecord
  228. {
  229. RowKey = tdata.id,
  230. PartitionKey = PartitionKey,
  231. sequenceNumber = end,
  232. msgId = messageWorkEnd.MessageId
  233. };
  234. await _azureStorage.Save<ChangeRecord>(changeRecord);
  235. }
  236. //if (bustasks.IsNotEmpty())
  237. //{
  238. // await Task.WhenAll(bustasks);
  239. //}
  240. break;
  241. case "finish":
  242. break;
  243. }
  244. }
  245. }
  246. catch (CosmosException e)
  247. {
  248. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-CosmosDB异常{e.Message}\n{e.Status}", GroupNames.成都开发測試群組);
  249. }
  250. catch (Exception ex)
  251. {
  252. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修作业活动异常{ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
  253. }
  254. }
  255. }
  256. }