TriggerHomework.cs 14 KB

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