TriggerHomework.cs 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196
  1. using Azure.Cosmos;
  2. using Azure.Messaging.ServiceBus;
  3. using HTEXLib.COMM.Helpers;
  4. using Microsoft.Azure.Documents;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.Text;
  8. using TEAMModelOS.SDK;
  9. using TEAMModelOS.SDK.DI;
  10. using TEAMModelOS.SDK.Extension;
  11. using TEAMModelOS.SDK.Models;
  12. using TEAMModelOS.SDK.Models.Cosmos.Common;
  13. using TEAMModelOS.SDK.Models.Service;
  14. namespace TEAMModelFunction
  15. {
  16. public static class TriggerHomework
  17. {
  18. public static async void Trigger(AzureServiceBusFactory _serviceBus, AzureStorageFactory _azureStorage, DingDing _dingDing,
  19. CosmosClient client, Document input, TriggerData tdata, AzureRedisFactory _azureRedis)
  20. {
  21. try
  22. {
  23. if ((tdata.status != null && tdata.status.Value == 404) || tdata.ttl > 0)
  24. {
  25. return;
  26. }
  27. var adid = tdata.id;
  28. var adcode = "";
  29. string blobcntr = null;
  30. if (tdata.scope.Equals("school"))
  31. {
  32. adcode = $"Activity-{tdata.school}";
  33. blobcntr = tdata.school;
  34. }
  35. else
  36. {
  37. adcode = $"Activity-{tdata.creatorId}";
  38. blobcntr = tdata.creatorId;
  39. }
  40. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}作业活动【{tdata.name}-{tdata.id}-ttl={tdata.ttl}】正在操作", GroupNames.成都开发測試群組);
  41. Homework work = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<Homework>(input.Id, new Azure.Cosmos.PartitionKey($"{tdata.code}"));
  42. if (work != null)
  43. {
  44. string PartitionKey = string.Format("{0}{1}{2}", work.code, "-", work.progress);
  45. List<ChangeRecord> changeRecords = await _azureStorage.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", input.Id }, { "PartitionKey", PartitionKey } });
  46. switch (work.progress)
  47. {
  48. case "pending":
  49. var messageWork = new ServiceBusMessage(new { id = input.Id, progress = "going", code = tdata.code }.ToJsonString());
  50. messageWork.ApplicationProperties.Add("name", "Homework");
  51. if (changeRecords.Count > 0)
  52. {
  53. await _serviceBus.GetServiceBusClient().cancelMessage(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), changeRecords[0].sequenceNumber);
  54. long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWork, DateTimeOffset.FromUnixTimeMilliseconds(tdata.stime));
  55. changeRecords[0].sequenceNumber = start;
  56. await _azureStorage.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
  57. }
  58. else
  59. {
  60. long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWork, DateTimeOffset.FromUnixTimeMilliseconds(tdata.stime));
  61. ChangeRecord changeRecord = new ChangeRecord
  62. {
  63. RowKey = input.Id,
  64. PartitionKey = PartitionKey,
  65. sequenceNumber = start,
  66. msgId = messageWork.MessageId
  67. };
  68. await _azureStorage.Save<ChangeRecord>(changeRecord);
  69. }
  70. break;
  71. case "going":
  72. List<string> classes = ExamService.getClasses(work.classes, work.stuLists);
  73. (List<TmdInfo> tmdids, List<StuInfo> students, List<ClassListInfo> classLists) = await TriggerStuActivity.GetStuList(client, _dingDing, classes, work.school);
  74. List<StuActivity> stuActivities = new List<StuActivity>();
  75. List<StuActivity> tmdActivities = new List<StuActivity>();
  76. List<StuActivity> tchActivities = new List<StuActivity>();
  77. if (tmdids.IsNotEmpty())
  78. {
  79. tmdids.ForEach(x =>
  80. {
  81. tmdActivities.Add(new StuActivity
  82. {
  83. pk = "Activity",
  84. id = work.id,
  85. code = $"Activity-{x.id}",
  86. type = "Homework",
  87. name = work.name,
  88. startTime = work.startTime,
  89. endTime = work.endTime,
  90. scode = work.code,
  91. scope = work.scope,
  92. school = work.school,
  93. creatorId = work.creatorId,
  94. subjects = new List<string> { "" },
  95. blob = work.blob,
  96. owner = work.owner,
  97. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  98. taskStatus = -1,
  99. classIds = classes
  100. });
  101. });
  102. }
  103. if (students.IsNotEmpty())
  104. {
  105. students.ForEach(x =>
  106. {
  107. stuActivities.Add(new StuActivity
  108. {
  109. pk = "Activity",
  110. id = work.id,
  111. code = $"Activity-{x.code.Replace("Base-", "")}-{x.id}",
  112. type = "Homework",
  113. name = work.name,
  114. startTime = work.startTime,
  115. endTime = work.endTime,
  116. scode = work.code,
  117. scope = work.scope,
  118. school = work.school,
  119. creatorId = work.creatorId,
  120. subjects = new List<string> { "" },
  121. blob = work.blob,
  122. owner = work.owner,
  123. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  124. taskStatus = -1,
  125. classIds = classes
  126. });
  127. });
  128. }
  129. (List<RMember> tchList, List<RGroupList> classInfos) = await GroupListService.GetStutmdidListids(client, _dingDing, work.tchLists, work.school);
  130. // (List<TmdInfo> tmdInfos, List<ClassListInfo> classInfos) = await TriggerStuActivity.GetTchList(client, _dingDing, ids, $"{school}");
  131. // (List<TmdInfo> tchList, _) = await TriggerStuActivity.GetTchList(client, _dingDing, work.tchLists, work.school);
  132. if (tchList.IsNotEmpty())
  133. {
  134. tchList.ForEach(x =>
  135. {
  136. tchActivities.Add(new StuActivity
  137. {
  138. pk = "Activity",
  139. id = work.id,
  140. code = $"Activity-{x.id}",
  141. type = "Homework",
  142. name = work.name,
  143. startTime = work.startTime,
  144. endTime = work.endTime,
  145. scode = work.code,
  146. scope = work.scope,
  147. school = work.school,
  148. creatorId = work.creatorId,
  149. subjects = new List<string> { "" },
  150. blob = work.blob,
  151. owner = work.owner,
  152. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  153. taskStatus = -1,
  154. classIds = work.tchLists
  155. });
  156. });
  157. }
  158. await TriggerStuActivity.SaveStuActivity(client, _dingDing, stuActivities, tmdActivities, tchActivities);
  159. var messageWorkEnd = new ServiceBusMessage(new { id = input.Id, progress = "finish", code = tdata.code }.ToJsonString());
  160. messageWorkEnd.ApplicationProperties.Add("name", "Homework");
  161. if (changeRecords.Count > 0)
  162. {
  163. long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWorkEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.etime));
  164. await _serviceBus.GetServiceBusClient().cancelMessage(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), changeRecords[0].sequenceNumber);
  165. changeRecords[0].sequenceNumber = end;
  166. await _azureStorage.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
  167. }
  168. else
  169. {
  170. long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWorkEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.etime));
  171. ChangeRecord changeRecord = new ChangeRecord
  172. {
  173. RowKey = input.Id,
  174. PartitionKey = PartitionKey,
  175. sequenceNumber = end,
  176. msgId = messageWorkEnd.MessageId
  177. };
  178. await _azureStorage.Save<ChangeRecord>(changeRecord);
  179. }
  180. break;
  181. case "finish":
  182. break;
  183. }
  184. }
  185. }
  186. catch (Exception ex)
  187. {
  188. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修作业活动异常{ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
  189. }
  190. }
  191. }
  192. }