TriggerHomework.cs 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391
  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. using TEAMModelOS.SDK.Models.Service.BI;
  19. namespace TEAMModelOS.FunctionV4
  20. {
  21. public static class TriggerHomework
  22. {
  23. public static async Task Trigger(CoreAPIHttpService _coreAPIHttpService, AzureServiceBusFactory _serviceBus, AzureStorageFactory _azureStorage, DingDing _dingDing,
  24. CosmosClient client, JsonElement input, TriggerData tdata, AzureRedisFactory _azureRedis, IConfiguration _configuration)
  25. {
  26. try
  27. {
  28. if ((tdata.status != null && tdata.status.Value == 404))
  29. {
  30. await client.GetContainer(Constant.TEAMModelOS, "Common").DeleteItemStreamAsync(tdata.id, new PartitionKey(tdata.code));
  31. ActivityList data = input.ToObject<ActivityList>();
  32. //await IESActivityService.DeleteActivity(_coreAPIHttpService, client, _dingDing, data);
  33. var table_cancel = _azureStorage.GetCloudTableClient().GetTableReference("ChangeRecord");
  34. List<ChangeRecord> records = await table_cancel.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", tdata.id } });
  35. foreach (var record in records)
  36. {
  37. try
  38. {
  39. await table_cancel.DeleteSingle<ChangeRecord>(record.PartitionKey, record.RowKey);
  40. await _serviceBus.GetServiceBusClient().CancelMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), record.sequenceNumber);
  41. }
  42. catch (Exception)
  43. {
  44. continue;
  45. }
  46. }
  47. await BIStats.SetTypeAddStats(client, _dingDing, tdata.school, "Homework", -1, careDate: tdata.startTime);//BI统计增/减量
  48. return;
  49. }
  50. var adid = tdata.id;
  51. var adcode = "";
  52. string blobcntr = null;
  53. if (tdata.scope.Equals("school"))
  54. {
  55. adcode = $"Activity-{tdata.school}";
  56. blobcntr = tdata.school;
  57. }
  58. else
  59. {
  60. adcode = $"Activity-{tdata.creatorId}";
  61. blobcntr = tdata.creatorId;
  62. }
  63. //await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}作业活动【{tdata.name}-{tdata.id}-ttl={tdata.ttl}】正在操作", GroupNames.醍摩豆服務運維群組);
  64. Homework work = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<Homework>(tdata.id, new Azure.Cosmos.PartitionKey($"{tdata.code}"));
  65. var table = _azureStorage.GetCloudTableClient().GetTableReference("ChangeRecord");
  66. if (work != null)
  67. {
  68. string PartitionKey = string.Format("{0}{1}{2}", work.code, "-", work.progress);
  69. List<ChangeRecord> changeRecords = await table.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", tdata.id }, { "PartitionKey", PartitionKey } });
  70. switch (work.progress)
  71. {
  72. case "pending":
  73. var messageWork = new ServiceBusMessage(new { tdata.id, progress = "going", tdata.code }.ToJsonString());
  74. messageWork.ApplicationProperties.Add("name", "Homework");
  75. if (changeRecords.Count > 0)
  76. {
  77. try
  78. {
  79. await _serviceBus.GetServiceBusClient().CancelMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), changeRecords[0].sequenceNumber);
  80. }
  81. catch (Exception)
  82. {
  83. }
  84. long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWork, DateTimeOffset.FromUnixTimeMilliseconds(tdata.startTime));
  85. changeRecords[0].sequenceNumber = start;
  86. await table.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
  87. }
  88. else
  89. {
  90. long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWork, DateTimeOffset.FromUnixTimeMilliseconds(tdata.startTime));
  91. ChangeRecord changeRecord = new()
  92. {
  93. RowKey = tdata.id,
  94. PartitionKey = PartitionKey,
  95. sequenceNumber = start,
  96. msgId = messageWork.MessageId
  97. };
  98. await table.Save<ChangeRecord>(changeRecord);
  99. }
  100. break;
  101. case "going":
  102. string pkey = string.Format("{0}{1}{2}", work.code, "-", "pending");
  103. await table.DeleteSingle<ChangeRecord>(pkey, tdata.id);
  104. await Activity(_coreAPIHttpService, _serviceBus, _dingDing, client, _configuration, work);
  105. var messageWorkEnd = new ServiceBusMessage(new { id = tdata.id, progress = "finish", code = tdata.code }.ToJsonString());
  106. messageWorkEnd.ApplicationProperties.Add("name", "Homework");
  107. if (changeRecords.Count > 0)
  108. {
  109. long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWorkEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
  110. try
  111. {
  112. await _serviceBus.GetServiceBusClient().CancelMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), changeRecords[0].sequenceNumber);
  113. }
  114. catch (Exception)
  115. {
  116. }
  117. changeRecords[0].sequenceNumber = end;
  118. await table.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
  119. }
  120. else
  121. {
  122. long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWorkEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
  123. ChangeRecord changeRecord = new()
  124. {
  125. RowKey = tdata.id,
  126. PartitionKey = PartitionKey,
  127. sequenceNumber = end,
  128. msgId = messageWorkEnd.MessageId
  129. };
  130. await table.Save<ChangeRecord>(changeRecord);
  131. }
  132. //if (bustasks.IsNotEmpty())
  133. //{
  134. // await Task.WhenAll(bustasks);
  135. //}
  136. break;
  137. case "finish":
  138. string pk = string.Format("{0}{1}{2}", work.code, "-", "going");
  139. await table.DeleteSingle<ChangeRecord>(pk, tdata.id);
  140. await Activity(_coreAPIHttpService, _serviceBus, _dingDing, client, _configuration, work);
  141. List<(string pId, List<string> gid)> gls = new List<(string pId, List<string> gid)>();
  142. if (work.groupLists.Count > 0)
  143. {
  144. var group = work.groupLists;
  145. foreach (var gp in group)
  146. {
  147. foreach (KeyValuePair<string, List<string>> pp in gp)
  148. {
  149. gls.Add((pp.Key, pp.Value));
  150. }
  151. }
  152. }
  153. //处理家庭作业活动结束统计账户信息
  154. if (work.staffIds.Count == 0) {
  155. List<FMember> idsList = await GroupListService.GetFinishMemberInfo(_coreAPIHttpService, client, _dingDing, work.school, work.classes, work.stuLists, work.tchLists,gls);
  156. work.staffIds = idsList;
  157. await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync<Homework>(work, work.id, new Azure.Cosmos.PartitionKey(work.code));
  158. }
  159. break;
  160. }
  161. }
  162. }
  163. catch (CosmosException e)
  164. {
  165. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-CosmosDB异常{e.Message}\n{e.StackTrace}\n{e.Status}", GroupNames.醍摩豆服務運維群組);
  166. }
  167. catch (Exception ex)
  168. {
  169. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修作业活动异常{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  170. }
  171. }
  172. private static async Task Activity(CoreAPIHttpService _coreAPIHttpService, AzureServiceBusFactory _serviceBus, DingDing _dingDing, CosmosClient client, IConfiguration _configuration, Homework work)
  173. {
  174. List<(string pId, List<string> gid)> ps = new List<(string pId, List<string> gid)>();
  175. if (work.groupLists.Count > 0)
  176. {
  177. var group = work.groupLists;
  178. foreach (var gp in group)
  179. {
  180. foreach (KeyValuePair<string, List<string>> pp in gp)
  181. {
  182. ps.Add((pp.Key, pp.Value));
  183. }
  184. }
  185. }
  186. List<string> classes = ExamService.getClasses(work.classes, work.stuLists);
  187. (List<RMember> tmdids, List<RGroupList> classLists) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, classes, work.school, ps);
  188. var addStudentsCls = tmdids.FindAll(x => x.type == 2);
  189. var addTmdidsCls = tmdids.FindAll(x => x.type == 1);
  190. //List<StuActivity> stuActivities = new();
  191. //List<StuActivity> tmdActivities = new();
  192. //List<StuActivity> tchActivities = new();
  193. //List<StuActivity> tac = new();
  194. List<string> tIds = addStudentsCls.Select(x => x.id).ToList();
  195. /*
  196. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<StuActivity>(queryText: $"select value(c) from c where c.id ='{work.id}' and c.type = 'Homework'"))
  197. {
  198. tac.Add(item);
  199. }
  200. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<StuActivity>(queryText: $"select value(c) from c where c.id ='{work.id}' and c.type = 'Homework'"))
  201. {
  202. tac.Add(item);
  203. }
  204. List<string> sub = new();
  205. if (work.tchLists.Count == 0)
  206. {
  207. if (work.targets.Count > 0)
  208. {
  209. foreach (var course in work.targets)
  210. {
  211. var info = course.ToObject<List<string>>();
  212. if (info.Count > 1)
  213. {
  214. sub.Add(info[0]);
  215. }
  216. }
  217. }
  218. }
  219. if (addTmdidsCls.IsNotEmpty())
  220. {
  221. addTmdidsCls.ForEach(x =>
  222. {
  223. HashSet<string> classIds = new HashSet<string>();
  224. classLists.ForEach(z =>
  225. {
  226. z.members.ForEach(y =>
  227. {
  228. if (y.id.Equals(x.id) && y.type == 1)
  229. {
  230. classIds.Add(z.id);
  231. }
  232. });
  233. });
  234. int sta = -1;
  235. if (tac.Count > 0)
  236. {
  237. StuActivity activity = tac.Where(t => t.code.Equals($"Activity-{x.id}")).FirstOrDefault();
  238. if (activity != null)
  239. {
  240. sta = activity.taskStatus;
  241. }
  242. }
  243. tmdActivities.Add(new StuActivity
  244. {
  245. pk = "Activity",
  246. id = work.id,
  247. code = $"Activity-{x.id}",
  248. type = "Homework",
  249. name = work.name,
  250. startTime = work.startTime,
  251. endTime = work.endTime,
  252. scode = work.code,
  253. scope = work.scope,
  254. school = work.school,
  255. creatorId = work.creatorId,
  256. subjects = sub,
  257. blob = work.blob,
  258. owner = work.owner,
  259. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  260. taskStatus = sta,
  261. mustSubmit = work.mustSubmit,
  262. classIds = classIds.ToList()
  263. });
  264. });
  265. }
  266. if (addStudentsCls.IsNotEmpty())
  267. {
  268. addStudentsCls.ForEach(x =>
  269. {
  270. HashSet<string> classIds = new HashSet<string>();
  271. classLists.ForEach(z =>
  272. {
  273. z.members.ForEach(y =>
  274. {
  275. if (y.id.Equals(x.id) && y.type == 2)
  276. {
  277. classIds.Add(z.id);
  278. }
  279. });
  280. });
  281. int sta = -1;
  282. if (tac.Count > 0)
  283. {
  284. StuActivity activity = tac.Where(t => t.code.Equals($"Activity-{x.code.Replace("Base-", "")}-{x.id}")).FirstOrDefault();
  285. if (activity != null)
  286. {
  287. sta = activity.taskStatus;
  288. }
  289. }
  290. stuActivities.Add(new StuActivity
  291. {
  292. pk = "Activity",
  293. id = work.id,
  294. code = $"Activity-{x.code.Replace("Base-", "")}-{x.id}",
  295. type = "Homework",
  296. name = work.name,
  297. startTime = work.startTime,
  298. endTime = work.endTime,
  299. scode = work.code,
  300. scope = work.scope,
  301. school = work.school,
  302. creatorId = work.creatorId,
  303. subjects = sub,
  304. blob = work.blob,
  305. owner = work.owner,
  306. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  307. taskStatus = sta,
  308. classIds = classIds.ToList(),
  309. mustSubmit = work.mustSubmit
  310. });
  311. });
  312. }
  313. */
  314. (List<RMember> tchList, List<RGroupList> classInfos) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, work.tchLists, work.school, ps);
  315. (string standard, List<string> tmdids, string school, List<string> update, int statistics) list = (null, null, null, new List<string> { StatisticsService.OfflineRecord }, 0);
  316. if (tchList.IsNotEmpty())
  317. {
  318. list.tmdids = tchList.Select(x => x.id).ToList();
  319. School school = null;
  320. if (!string.IsNullOrEmpty(work.school))
  321. {
  322. school = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>(work.school, new Azure.Cosmos.PartitionKey("Base"));
  323. list.school = school.id;
  324. list.standard = school.standard;
  325. }
  326. /*
  327. tchList.ForEach(x =>
  328. {
  329. HashSet<string> classIds = new();
  330. classInfos.ForEach(z =>
  331. {
  332. z.members.ForEach(y =>
  333. {
  334. if (y.id.Equals(x.id) && y.type == 1)
  335. {
  336. classIds.Add(z.id);
  337. }
  338. });
  339. });
  340. int sta = -1;
  341. if (tac.Count > 0)
  342. {
  343. StuActivity activity = tac.Where(t => t.code.Equals($"Activity-{x.id}")).FirstOrDefault();
  344. if (activity != null)
  345. {
  346. sta = activity.taskStatus;
  347. }
  348. }
  349. tchActivities.Add(new StuActivity
  350. {
  351. pk = "Activity",
  352. id = work.id,
  353. code = $"Activity-{x.id}",
  354. type = "Homework",
  355. name = work.name,
  356. startTime = work.startTime,
  357. endTime = work.endTime,
  358. scode = work.code,
  359. scope = work.scope,
  360. school = work.school,
  361. creatorId = work.creatorId,
  362. subjects = new List<string> { "" },
  363. blob = work.blob,
  364. owner = work.owner,
  365. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  366. taskStatus = sta,
  367. classIds = classIds.ToList()
  368. });
  369. });
  370. */
  371. }
  372. //await IESActivityService.SaveStuActivity(client, _dingDing, stuActivities, tmdActivities, tchActivities);
  373. await StatisticsService.SendServiceBus(list, _configuration, _serviceBus, client);
  374. }
  375. }
  376. }