ActivityService.cs 48 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874
  1. using Azure;
  2. using Azure.Cosmos;
  3. using System;
  4. using System.Collections.Generic;
  5. using System.IO;
  6. using System.Linq;
  7. using System.Text;
  8. using System.Text.Json;
  9. using System.Threading.Tasks;
  10. using TEAMModelOS.SDK.DI;
  11. using TEAMModelOS.SDK.Extension;
  12. using TEAMModelOS.SDK;
  13. using TEAMModelOS.SDK.Models;
  14. using TEAMModelOS.SDK.Models.Cosmos.Common;
  15. using TEAMModelOS.SDK.Models.Service;
  16. using HTEXLib.COMM.Helpers;
  17. namespace TEAMModelOS.SDK
  18. {
  19. public class ActivityService
  20. {
  21. public static async Task FixActivity(CosmosClient client, DingDing _dingDing, GroupChange groupChange, string type)
  22. {
  23. try
  24. {
  25. var query = $"SELECT distinct c.owner, c.id,c.code, c.classes,c.stuLists,c.subjects,c.progress,c.scope,c.startTime,c.school,c.creatorId,c.name,c.pk ,c.endTime FROM c " +
  26. $"where (c.status<>404 or IS_DEFINED(c.status) = false ) and c.pk='{type}' " +
  27. $" and (( array_contains(c.classes,'{groupChange.listid}')) or ( array_contains(c.stuLists,'{groupChange.listid}'))or ( array_contains(c.tchLists,'{groupChange.listid}')))";
  28. //$"and A1 in('{groupChange.listid}') ";
  29. List<MQActivity> datas = new List<MQActivity>();
  30. List<string> classId = new List<string>();
  31. classId.Add(groupChange.listid);
  32. if (groupChange.scope.Equals("school", StringComparison.OrdinalIgnoreCase) && !string.IsNullOrEmpty(groupChange.school))
  33. {
  34. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryIterator<MQActivity>(queryText: query,
  35. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"{type}-{groupChange.school}") }))
  36. {
  37. datas.Add(item);
  38. }
  39. ///还要处理该学校每个老师发布的班级的
  40. List<SchoolTeacher> teachers = new List<SchoolTeacher>();
  41. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<SchoolTeacher>(queryText: $"SELECT c.id, c.name FROM c",
  42. requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Teacher-{groupChange.school}") }))
  43. {
  44. teachers.Add(item);
  45. }
  46. foreach (var techer in teachers)
  47. {
  48. var queryTech = $"SELECT distinct c.owner, c.id,c.code, c.classes,c.stuLists,c.subjects,c.progress,c.scope,c.startTime,c.school,c.creatorId,c.name,c.pk ,c.endTime FROM c " +
  49. $" where (c.status<>404 or IS_DEFINED(c.status) = false ) and c.school='{groupChange.school}' and c.pk='{type}'" +
  50. $" and (( array_contains(c.classes,'{groupChange.listid}')) or ( array_contains(c.stuLists,'{groupChange.listid}')))";
  51. // $" and A1 in('{groupChange.listid}') ";
  52. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryIterator<MQActivity>(queryText: queryTech,
  53. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"{type}-{techer.id}") }))
  54. {
  55. datas.Add(item);
  56. }
  57. }
  58. }
  59. if (groupChange.scope.Equals("private", StringComparison.OrdinalIgnoreCase) && !string.IsNullOrEmpty(groupChange.creatorId))
  60. {
  61. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryIterator<MQActivity>(queryText: query,
  62. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"{type}-{groupChange.creatorId}") }))
  63. {
  64. datas.Add(item);
  65. }
  66. }
  67. long nowtime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  68. foreach (MQActivity activity in datas)
  69. {
  70. //已经完结的不再允许加入,还未开始的。
  71. if (string.IsNullOrEmpty(activity.progress) || activity.progress.Equals("finish") || activity.progress.Equals("pending"))
  72. {
  73. continue;
  74. }
  75. //classId = ExamService.getClasses(activity.classes, activity.stuLists);
  76. List<ExamClassResult> classResults = new List<ExamClassResult>();
  77. List<PaperSimple> standerAnswers = new List<PaperSimple>();
  78. if (type.Equals("Exam"))
  79. {
  80. if (groupChange.scope.Equals("school"))
  81. {
  82. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryIterator<ExamClassResult>(queryText: $"select value(c) from c where c.examId = '{activity.id}'",
  83. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"ExamClassResult-{groupChange.school}") }))
  84. {
  85. classResults.Add(item);
  86. }
  87. }
  88. else
  89. {
  90. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryIterator<ExamClassResult>(queryText: $"select value(c) from c where c.examId = '{activity.id}'",
  91. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"ExamClassResult-{groupChange.creatorId}") }))
  92. {
  93. classResults.Add(item);
  94. }
  95. }
  96. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryIterator<PaperSimple>(
  97. queryText: $"select A0.answers from c join A0 in c.papers where c.id = '{activity.id}'",
  98. requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"{activity.code}") }))
  99. {
  100. standerAnswers.Add(item);
  101. }
  102. }
  103. //stujoin新加入名单的
  104. foreach (Member member in groupChange.stujoin)
  105. {
  106. ExamInfo info = await updateClassResulte(client, classResults, standerAnswers, member, groupChange,activity);
  107. var stucourse = new StuActivity
  108. {
  109. id = activity.id,
  110. scode = activity.code,
  111. name = activity.name,
  112. source = type.Equals("Exam") ? info.source :"",
  113. ext = type.Equals("Exam") ? new Dictionary<string, JsonElement>() { { "type", info.type.ToJsonString().ToObject<JsonElement>() }, { "subjects", info.subjects.ToJsonString().ToObject<JsonElement>() } } : new Dictionary<string, JsonElement>(),
  114. code = $"Activity-{member.code.Replace("Base-", "")}-{member.id}",
  115. scope = activity.scope,
  116. school = activity.school,
  117. creatorId = activity.creatorId,
  118. pk = "Activity",
  119. type = type,
  120. subjects = activity.pk.ToLower().Equals("exam") && activity.subjects.IsNotEmpty() ? new List<string>() { activity.subjects[0].id } : new List<string>() { "" },
  121. startTime = activity.startTime,
  122. endTime = activity.endTime,
  123. blob = activity.blob,
  124. owner = activity.owner,
  125. createTime = nowtime,
  126. taskStatus = -1,
  127. classIds = classId
  128. };
  129. await client.GetContainer(Constant.TEAMModelOS, "Student").UpsertItemAsync(stucourse, new PartitionKey(stucourse.code));
  130. }
  131. //tmdjoin新加入的
  132. foreach (Member member in groupChange.tmdjoin)
  133. {
  134. ExamInfo info = await updateClassResulte(client, classResults, standerAnswers, member, groupChange,activity);
  135. var stucourse = new StuActivity
  136. {
  137. id = activity.id,
  138. scode = activity.code,
  139. name = activity.name,
  140. source = type.Equals("Exam") ? info.source : "",
  141. ext = type.Equals("Exam") ? new Dictionary<string, JsonElement>() { { "type", info.type.ToJsonString().ToObject<JsonElement>() }, { "subjects", info.subjects.ToJsonString().ToObject<JsonElement>() } } : new Dictionary<string, JsonElement>(),
  142. code = $"Activity-{member.id}",
  143. scope = activity.scope,
  144. school = activity.school,
  145. creatorId = activity.creatorId,
  146. pk = "Activity",
  147. type = type,
  148. subjects = activity.pk.ToLower().Equals("exam") && activity.subjects.IsNotEmpty() ? new List<string>() { activity.subjects[0].id } : new List<string>() { "" },
  149. startTime = activity.startTime,
  150. endTime = activity.endTime,
  151. blob = activity.blob,
  152. owner = activity.owner,
  153. createTime = nowtime,
  154. taskStatus = -1,
  155. classIds = classId
  156. };
  157. await client.GetContainer(Constant.TEAMModelOS, "Student").UpsertItemAsync(stucourse, new PartitionKey(stucourse.code));
  158. }
  159. //tchjoin新加入的
  160. foreach (Member member in groupChange.tchjoin)
  161. {
  162. //await updateClassResulte(client, classResults, standerAnswers, member.id);
  163. var stucourse = new StuActivity
  164. {
  165. id = activity.id,
  166. scode = activity.code,
  167. name = activity.name,
  168. code = $"Activity-{member.id}",
  169. scope = activity.scope,
  170. school = activity.school,
  171. creatorId = activity.creatorId,
  172. pk = "Activity",
  173. type = type,
  174. subjects = activity.pk.ToLower().Equals("exam") && activity.subjects.IsNotEmpty() ? new List<string>() { activity.subjects[0].id } : new List<string>() { "" },
  175. startTime = activity.startTime,
  176. endTime = activity.endTime,
  177. blob = activity.blob,
  178. owner = activity.owner,
  179. createTime = nowtime,
  180. taskStatus = -1,
  181. classIds = classId
  182. };
  183. await client.GetContainer(Constant.TEAMModelOS, "Teacher").UpsertItemAsync(stucourse, new PartitionKey(stucourse.code));
  184. }
  185. foreach (Member member in groupChange.stuleave)
  186. {
  187. try
  188. {
  189. await updateClassResulte(client, classResults, standerAnswers, member, groupChange,activity);
  190. StuActivity stuActivity = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemAsync<StuActivity>(activity.id, new PartitionKey($"Activity-{member.code.Replace("Base-", "")}-{member.id}"));
  191. stuActivity.classIds.Remove(groupChange.listid);
  192. if (stuActivity.classIds.IsNotEmpty())
  193. {
  194. await client.GetContainer(Constant.TEAMModelOS, "Student").ReplaceItemAsync<StuActivity>(stuActivity, activity.id, new PartitionKey(stuActivity.code));
  195. }
  196. else
  197. {
  198. await client.GetContainer(Constant.TEAMModelOS, "Student").DeleteItemAsync<StuActivity>(activity.id, new PartitionKey($"Activity-{member.code.Replace("Base-", "")}-{member.id}"));
  199. }
  200. }
  201. catch (CosmosException)
  202. {
  203. continue;
  204. // 继续执行 删除失败
  205. }
  206. }
  207. foreach (Member member in groupChange.tmdleave)
  208. {
  209. try
  210. {
  211. await updateClassResulte(client, classResults, standerAnswers, member, groupChange,activity);
  212. StuActivity stuActivity = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemAsync<StuActivity>(activity.id, new PartitionKey($"Activity-{member.id}"));
  213. stuActivity.classIds.Remove(groupChange.listid);
  214. if (stuActivity.classIds.IsNotEmpty())
  215. {
  216. await client.GetContainer(Constant.TEAMModelOS, "Student").ReplaceItemAsync<StuActivity>(stuActivity, activity.id, new PartitionKey(stuActivity.code));
  217. }
  218. else
  219. {
  220. await client.GetContainer(Constant.TEAMModelOS, "Student").DeleteItemAsync<StuActivity>(activity.id, new PartitionKey($"Activity-{member.id}"));
  221. }
  222. }
  223. catch (CosmosException)
  224. {
  225. continue;
  226. // 继续执行 删除失败
  227. }
  228. }
  229. foreach (Member member in groupChange.tchleave)
  230. {
  231. try
  232. {
  233. StuActivity stuActivity = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<StuActivity>(activity.id, new PartitionKey($"Activity-{member.id}"));
  234. stuActivity.classIds.Remove(groupChange.listid);
  235. if (stuActivity.classIds.IsNotEmpty())
  236. {
  237. await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<StuActivity>(stuActivity, activity.id, new PartitionKey(stuActivity.code));
  238. }
  239. else
  240. {
  241. await client.GetContainer(Constant.TEAMModelOS, "Teacher").DeleteItemAsync<StuActivity>(activity.id, new PartitionKey($"Activity-{member.id}"));
  242. }
  243. }
  244. catch (CosmosException)
  245. {
  246. continue;
  247. // 继续执行 删除失败
  248. }
  249. }
  250. }
  251. }
  252. catch (CosmosException e)
  253. {
  254. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-GroupListService-FixActivity\n{e.Message}\n{e.StackTrace}CosmosException{e.Status}", GroupNames.醍摩豆服務運維群組);
  255. }
  256. catch (Exception ex)
  257. {
  258. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-GroupListService-FixActivity\n{ex.Message}{ex.StackTrace}{groupChange.ToJsonString()}{type}", GroupNames.醍摩豆服務運維群組);
  259. }
  260. }
  261. public static async Task FixStuCourse(CosmosClient client, DingDing _dingDing, GroupChange groupChange)
  262. {
  263. //1.查找学校或教师的课程是否包含该名单的课程。
  264. var query = $"select distinct c.code,c.id,c.no,c.name,c.scope, c.creatorId,c.school from c join A0 in c.schedule where A0.stulist = '{groupChange.listid}' or A0.classId = '{groupChange.listid}' ";
  265. if (groupChange.status.Equals("delete")) {
  266. query = $"select distinct value(c) from c join A0 in c.schedule where A0.stulist = '{groupChange.listid}' or A0.classId = '{groupChange.listid}' ";
  267. }
  268. List<Course> courses = new List<Course>();
  269. if (!string.IsNullOrWhiteSpace(groupChange.creatorId)) {
  270. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Course>(queryText: query,
  271. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Course-{groupChange.creatorId}") }))
  272. {
  273. courses.Add(item);
  274. }
  275. }
  276. if (!string.IsNullOrWhiteSpace(groupChange.school))
  277. {
  278. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Course>(queryText: query,
  279. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Course-{groupChange.school}") }))
  280. {
  281. courses.Add(item);
  282. }
  283. }
  284. //if (groupChange.scope.Equals("school") && !string.IsNullOrEmpty(groupChange.school))
  285. //{
  286. // await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Course>(queryText: query,
  287. // requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Course-{groupChange.school}") }))
  288. // {
  289. // courses.Add(item);
  290. // }
  291. //}
  292. //if (groupChange.scope.Equals("private") && !string.IsNullOrEmpty(groupChange.creatorId))
  293. //{
  294. // await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Course>(queryText: query,
  295. // requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Course-{groupChange.creatorId}") }))
  296. // {
  297. // courses.Add(item);
  298. // }
  299. //}
  300. long nowtime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  301. // await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-GroupListService-FixStuCourse\n名单发生变更 需要处理的课程\n{courses.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
  302. //2.获取课程的id 并尝试添加或移除对应的学生课程记录StuCourse。
  303. foreach (var course in courses)
  304. {
  305. //学生新加入名单的
  306. foreach (Member member in groupChange.stujoin)
  307. {
  308. Azure.Response response = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemStreamAsync(course.id, new PartitionKey($"StuCourse-{member.code.Replace("Base-", "")}-{member.id}"));
  309. if (response.Status == 200)
  310. {
  311. StuCourse stuCourse = JsonDocument.Parse(response.Content).RootElement.Deserialize<StuCourse>();
  312. stuCourse.name = course.name;
  313. stuCourse.scode = course.code;
  314. stuCourse.name = course.name;
  315. stuCourse.scope = course.scope;
  316. stuCourse.school = course.school;
  317. stuCourse.creatorId = course.creatorId;
  318. if (groupChange.type.Equals("class"))
  319. {
  320. if (stuCourse.classId.IsNotEmpty())
  321. {
  322. if (!stuCourse.classId.Contains(groupChange.listid))
  323. {
  324. stuCourse.classId.Add(groupChange.listid);
  325. }
  326. }
  327. else
  328. {
  329. stuCourse.classId = new List<string> { groupChange.listid };
  330. }
  331. }
  332. else {
  333. if (stuCourse.stulist.IsNotEmpty())
  334. {
  335. if (!stuCourse.stulist.Contains(groupChange.listid))
  336. {
  337. stuCourse.stulist.Add(groupChange.listid);
  338. }
  339. }
  340. else
  341. {
  342. stuCourse.stulist = new List<string> { groupChange.listid };
  343. }
  344. }
  345. try
  346. {
  347. await client.GetContainer(Constant.TEAMModelOS, "Student").ReplaceItemAsync(stuCourse, stuCourse.id, new PartitionKey(stuCourse.code));
  348. }
  349. catch (Exception)
  350. {
  351. continue;
  352. }
  353. }
  354. else
  355. {
  356. var stucourse = new StuCourse
  357. {
  358. id = course.id,
  359. scode = course.code,
  360. name = course.name,
  361. code = $"StuCourse-{member.code.Replace("Base-", "")}-{member.id}",
  362. scope = course.scope,
  363. school = course.school,
  364. creatorId = course.creatorId,
  365. pk = "StuCourse",
  366. createTime = nowtime
  367. };
  368. if (groupChange.type.Equals("class"))
  369. {
  370. stucourse.classId = new List<string> { groupChange.listid };
  371. }
  372. else
  373. {
  374. stucourse.stulist = new List<string> { groupChange.listid };
  375. }
  376. try
  377. {
  378. await client.GetContainer(Constant.TEAMModelOS, "Student").CreateItemAsync(stucourse, new PartitionKey(stucourse.code));
  379. }
  380. catch (Exception)
  381. {
  382. continue;
  383. }
  384. }
  385. }
  386. //tmd新加入的
  387. foreach (Member member in groupChange.tmdjoin)
  388. {
  389. try
  390. {
  391. Azure.Response response = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemStreamAsync(course.id, new PartitionKey($"StuCourse-{member.id}"));
  392. if (response.Status == 200)
  393. {
  394. StuCourse stuCourse = JsonDocument.Parse(response.Content).RootElement.Deserialize<StuCourse>();
  395. stuCourse.name = course.name;
  396. stuCourse.scode = course.code;
  397. stuCourse.name = course.name;
  398. stuCourse.scope = course.scope;
  399. stuCourse.school = course.school;
  400. stuCourse.creatorId = course.creatorId;
  401. if (groupChange.type.Equals("class"))
  402. {
  403. if (stuCourse.classId.IsNotEmpty())
  404. {
  405. if (!stuCourse.classId.Contains(groupChange.listid))
  406. {
  407. stuCourse.classId.Add(groupChange.listid);
  408. }
  409. }
  410. else
  411. {
  412. stuCourse.classId = new List<string> { groupChange.listid };
  413. }
  414. }
  415. else
  416. {
  417. if (stuCourse.stulist.IsNotEmpty())
  418. {
  419. if (!stuCourse.stulist.Contains(groupChange.listid))
  420. {
  421. stuCourse.stulist.Add(groupChange.listid);
  422. }
  423. }
  424. else
  425. {
  426. stuCourse.stulist = new List<string> { groupChange.listid };
  427. }
  428. }
  429. await client.GetContainer(Constant.TEAMModelOS, "Student").ReplaceItemAsync(stuCourse, stuCourse.id, new PartitionKey(stuCourse.code));
  430. }
  431. else
  432. {
  433. var stucourse = new StuCourse
  434. {
  435. id = course.id,
  436. scode = course.code,
  437. name = course.name,
  438. code = $"StuCourse-{member.id}",
  439. scope = course.scope,
  440. school = course.school,
  441. creatorId = course.creatorId,
  442. pk = "StuCourse",
  443. createTime = nowtime
  444. };
  445. if (groupChange.type.Equals("class"))
  446. {
  447. stucourse.classId = new List<string> { groupChange.listid };
  448. }
  449. else
  450. {
  451. stucourse.stulist = new List<string> { groupChange.listid };
  452. }
  453. await client.GetContainer(Constant.TEAMModelOS, "Student").CreateItemAsync(stucourse, new PartitionKey(stucourse.code));
  454. }
  455. }
  456. catch (Exception)
  457. {
  458. continue;
  459. }
  460. }
  461. //移除名单的。 在点击相关的课程,再去二次校验是否存在,不存在则再去删除。
  462. foreach (var delStu in groupChange.stuleave)
  463. {
  464. try {
  465. Azure.Response response = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemStreamAsync(course.id, new PartitionKey($"StuCourse-{delStu.code.Replace("Base-", "")}-{delStu.id}"));
  466. if (response.Status == 200)
  467. {
  468. StuCourse stuCourse = JsonDocument.Parse(response.Content).RootElement.Deserialize<StuCourse>();
  469. stuCourse.stulist.Remove(groupChange.listid);
  470. stuCourse.classId.Remove(groupChange.listid);
  471. if (stuCourse.stulist.IsNotEmpty() || stuCourse.classId.IsNotEmpty())
  472. {
  473. await client.GetContainer(Constant.TEAMModelOS, "Student").ReplaceItemAsync(stuCourse, stuCourse.id, new PartitionKey(stuCourse.code));
  474. }
  475. else
  476. {
  477. await client.GetContainer(Constant.TEAMModelOS, "Student").DeleteItemStreamAsync(course.id, new PartitionKey($"StuCourse-{delStu.code.Replace("Base-", "")}-{delStu.id}"));
  478. }
  479. }
  480. } catch (Exception) { continue; }
  481. }
  482. foreach (var delTmd in groupChange.tmdleave)
  483. {
  484. try
  485. {
  486. Azure.Response response = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemStreamAsync(course.id, new PartitionKey($"StuCourse-{delTmd.id}"));
  487. if (response.Status == 200)
  488. {
  489. StuCourse stuCourse = JsonDocument.Parse(response.Content).RootElement.Deserialize<StuCourse>();
  490. stuCourse.stulist.Remove(groupChange.listid);
  491. stuCourse.classId.Remove(groupChange.listid);
  492. if (stuCourse.stulist.IsNotEmpty() || stuCourse.classId.IsNotEmpty())
  493. {
  494. await client.GetContainer(Constant.TEAMModelOS, "Student").ReplaceItemAsync(stuCourse, stuCourse.id, new PartitionKey(stuCourse.code));
  495. }
  496. else
  497. {
  498. await client.GetContainer(Constant.TEAMModelOS, "Student").DeleteItemStreamAsync(course.id, new PartitionKey($"StuCourse-{delTmd.id}"));
  499. }
  500. }
  501. }
  502. catch (Exception)
  503. {
  504. continue;
  505. }
  506. }
  507. }
  508. if (groupChange.status.Equals("delete")) {
  509. foreach (var item in courses)
  510. {
  511. item.schedule.ForEach(x => {
  512. if ( !string.IsNullOrWhiteSpace(x.classId) && x.classId.Equals(groupChange.listid)) {
  513. x.classId = "";
  514. }
  515. if (!string.IsNullOrWhiteSpace(x.stulist) && x.stulist.Equals(groupChange.listid))
  516. {
  517. x.stulist = "";
  518. }
  519. });
  520. if (item.scope.Equals("school"))
  521. {
  522. await client.GetContainer(Constant.TEAMModelOS, Constant.School).ReplaceItemAsync(item, item.id, new PartitionKey(item.code));
  523. }
  524. else {
  525. await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReplaceItemAsync(item, item.id, new PartitionKey(item.code));
  526. }
  527. }
  528. }
  529. }
  530. public static async Task<string> SaveStuActivity(CosmosClient client, DingDing _dingDing, List<StuActivity> stuActivities, List<StuActivity> tmdActivities, List<StuActivity> tchActivities)
  531. {
  532. try
  533. {
  534. if (stuActivities.IsNotEmpty())
  535. {
  536. foreach (var x in stuActivities)
  537. {
  538. await client.GetContainer(Constant.TEAMModelOS, "Student").UpsertItemAsync(x, new PartitionKey(x.code));
  539. }
  540. }
  541. if (tmdActivities.IsNotEmpty())
  542. {
  543. foreach (var x in tmdActivities)
  544. {
  545. await client.GetContainer(Constant.TEAMModelOS, "Student").UpsertItemAsync(x, new PartitionKey(x.code));
  546. }
  547. }
  548. if (tchActivities.IsNotEmpty())
  549. {
  550. foreach (var x in tchActivities)
  551. {
  552. await client.GetContainer(Constant.TEAMModelOS, "Teacher").UpsertItemAsync(x, new PartitionKey(x.code));
  553. }
  554. }
  555. }
  556. catch (Exception ex)
  557. {
  558. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-OS,TriggerStuActivity-SaveStuActivity\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  559. }
  560. return "";
  561. }
  562. public static async Task RefreshStuActivity(CoreAPIHttpService _coreAPIHttpService, CosmosClient client, DingDing _dingDing, string id, string code)
  563. {
  564. MQActivity activity = null;
  565. try
  566. {
  567. var aactivity = await client.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync(id, new Azure.Cosmos.PartitionKey(code));
  568. using var da = await JsonDocument.ParseAsync(aactivity.ContentStream);
  569. activity = da.ToObject<MQActivity>();
  570. }
  571. catch (CosmosException)
  572. {
  573. activity = null;
  574. }
  575. if (activity != null)
  576. {
  577. List<Task<ItemResponse<StuActivity>>> tasks = new List<Task<ItemResponse<StuActivity>>>();
  578. List<string> classes = ExamService.getClasses(activity.classes, activity.stuLists);
  579. (List<RMember> tmdIds, List<RGroupList> classLists) = await GroupListService.GetStutmdidListids(_coreAPIHttpService, client, _dingDing, classes, activity.school);
  580. var students = tmdIds.FindAll(x => x.type == 2);
  581. var tmdids = tmdIds.FindAll(x => x.type == 1);
  582. if (tmdids.IsNotEmpty())
  583. {
  584. foreach (RMember tmdid in tmdids)
  585. {
  586. var response = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemStreamAsync(activity.id, new PartitionKey($"Activity-{tmdid.id}"));
  587. if (response.Status == 200)
  588. {
  589. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  590. StuActivity stu = json.ToObject<StuActivity>();
  591. stu.id = activity.id;
  592. stu.scode = activity.code;
  593. stu.name = activity.name;
  594. stu.source = activity.source;
  595. stu.scope = activity.scope;
  596. stu.school = activity.school;
  597. stu.creatorId = activity.creatorId;
  598. stu.type = activity.pk;
  599. stu.subjects = activity.pk.ToLower().Equals("exam") && activity.subjects.IsNotEmpty() ? new List<string>() { activity.subjects[0].id } : new List<string>() { "" };
  600. stu.startTime = activity.startTime;
  601. stu.endTime = activity.endTime;
  602. stu.blob = activity.blob;
  603. stu.owner = activity.owner;
  604. stu.createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  605. tasks.Add(client.GetContainer(Constant.TEAMModelOS, "Student").ReplaceItemAsync(stu, stu.id, new PartitionKey(stu.code)));
  606. }
  607. }
  608. }
  609. if (students.IsNotEmpty())
  610. {
  611. foreach (RMember student in students)
  612. {
  613. var response = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemStreamAsync(activity.id, new PartitionKey($"Activity-{activity.school}-{student.id}"));
  614. if (response.Status == 200)
  615. {
  616. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  617. StuActivity stu = json.ToObject<StuActivity>();
  618. stu.id = activity.id;
  619. stu.scode = activity.code;
  620. stu.name = activity.name;
  621. stu.source = activity.source;
  622. stu.scope = activity.scope;
  623. stu.school = activity.school;
  624. stu.creatorId = activity.creatorId;
  625. stu.type = activity.pk;
  626. stu.subjects = activity.pk.ToLower().Equals("exam") && activity.subjects.IsNotEmpty() ? new List<string>() { activity.subjects[0].id } : new List<string>() { "" };
  627. stu.startTime = activity.startTime;
  628. stu.endTime = activity.endTime;
  629. stu.blob = activity.blob;
  630. stu.owner = activity.owner;
  631. stu.createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  632. tasks.Add(client.GetContainer(Constant.TEAMModelOS, "Student").ReplaceItemAsync(stu, stu.id, new PartitionKey(stu.code)));
  633. }
  634. //await client.GetContainer(Constant.TEAMModelOS, "Student").UpsertItemAsync(stucourse, new PartitionKey(stucourse.code));
  635. }
  636. }
  637. await Task.WhenAll(tasks);
  638. }
  639. }
  640. public static async Task<ExamInfo> updateClassResulte(CosmosClient client, List<ExamClassResult> classResults, List<PaperSimple> standerAnswers, Member member ,GroupChange change,MQActivity activity)
  641. {
  642. ExamInfo info = new();
  643. try
  644. {
  645. if (classResults.Count > 0)
  646. {
  647. info = await client.GetContainer(Constant.TEAMModelOS, "Common").ReadItemAsync<ExamInfo>(classResults[0].examId, new PartitionKey($"{activity.code}"));
  648. foreach (var item in classResults)
  649. {
  650. if (item.info.id.Equals(change.listid))
  651. {
  652. int index = item.studentIds.IndexOf(member.id);
  653. if (index == -1)
  654. {
  655. List<List<string>> standard = new List<List<string>>();
  656. foreach (PaperSimple simple in standerAnswers)
  657. {
  658. standard = simple.answers;
  659. }
  660. List<double> ansPoint = new List<double>();
  661. List<List<string>> anc = new List<List<string>>();
  662. List<List<Details>> mark = new List<List<Details>>();
  663. foreach (List<string> num in standard)
  664. {
  665. List<string> newAns = new List<string>();
  666. foreach (string san in num)
  667. {
  668. newAns.Add(san);
  669. }
  670. anc.Add(newAns);
  671. ansPoint.Add(-1);
  672. mark.Add(new List<Details>());
  673. }
  674. item.mark.Add(mark);
  675. item.ans.Add(anc);
  676. item.studentIds.Add(member.id);
  677. item.studentScores.Add(ansPoint);
  678. item.studentAnswers.Add(new List<string>());
  679. item.sum.Add(0);
  680. //item.scIds.Add(member.code??"");
  681. item.status.Add(0);
  682. }
  683. else
  684. {
  685. item.mark.RemoveAt(index);
  686. item.ans.RemoveAt(index);
  687. item.studentIds.RemoveAt(index);
  688. item.studentScores.RemoveAt(index);
  689. item.studentAnswers.RemoveAt(index);
  690. item.sum.RemoveAt(index);
  691. //item.scIds.RemoveAt(index);
  692. item.status.RemoveAt(index);
  693. }
  694. try
  695. {
  696. bool isAns = item.studentScores.Exists(s => s.Contains(-1));
  697. if (!isAns)
  698. {
  699. //整合名单
  700. List<string> classes = ExamService.getClasses(info.classes, info.stuLists);
  701. item.progress = true;
  702. info.subjects.ForEach(s =>
  703. {
  704. if (s.classCount != classes.Count)
  705. {
  706. if (s.id.Equals(item.subjectId))
  707. {
  708. s.classCount += 1;
  709. }
  710. }
  711. });
  712. }
  713. long nowTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  714. info.updateTime = nowTime;
  715. await client.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync(info, info.id, new PartitionKey($"{info.code}"));
  716. }
  717. catch (Exception e)
  718. {
  719. }
  720. }
  721. await client.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync(item, item.id, new PartitionKey($"{item.code}"));
  722. }
  723. }
  724. }
  725. catch (Exception e)
  726. {
  727. }
  728. return info;
  729. }
  730. public static async Task DeleteActivity(CoreAPIHttpService _coreAPIHttpService, CosmosClient client, DingDing _dingDing, ActivityList activityList)
  731. {
  732. List<(string pId, List<string> gid)> ps = new List<(string pId, List<string> gid)>();
  733. if (activityList.groupLists.Count > 0)
  734. {
  735. var group = activityList.groupLists;
  736. foreach (var keys in group)
  737. {
  738. foreach (KeyValuePair<string, List<string>> pp in keys)
  739. {
  740. ps.Add((pp.Key, pp.Value));
  741. }
  742. }
  743. }
  744. List<string> classes = ExamService.getClasses(activityList.classes, activityList.stuLists);
  745. (List<RMember> tmdIds, List<RGroupList> classLists) = await GroupListService.GetStutmdidListids(_coreAPIHttpService, client, _dingDing, classes, activityList.school, ps);
  746. var addStudentsCls = tmdIds.FindAll(x => x.type == 2);
  747. var addTmdidsCls = tmdIds.FindAll(x => x.type == 1);
  748. List<string> tmds = new List<string>();
  749. if (addTmdidsCls.IsNotEmpty())
  750. {
  751. tmds.AddRange(addTmdidsCls.Select(x => x.id).ToList());
  752. }
  753. List<StuActivity> stuActivities = new List<StuActivity>();
  754. List<StuActivity> tmdActivities = new List<StuActivity>();
  755. List<StuActivity> tchActivities = new List<StuActivity>();
  756. if (tmds.IsNotEmpty())
  757. {
  758. tmds.ForEach(x =>
  759. {
  760. tmdActivities.Add(new StuActivity
  761. {
  762. id = activityList.id,
  763. code = $"Activity-{x}",
  764. });
  765. });
  766. }
  767. if (addStudentsCls.IsNotEmpty())
  768. {
  769. addStudentsCls.ForEach(x =>
  770. {
  771. stuActivities.Add(new StuActivity
  772. {
  773. id = activityList.id,
  774. code = $"Activity-{x.code.Replace("Base-", "")}-{x.id}",
  775. });
  776. });
  777. }
  778. (List<RMember> tchList, List<RGroupList> classInfos) = await GroupListService.GetStutmdidListids(_coreAPIHttpService, client, _dingDing, activityList.tchLists, activityList.school, ps);
  779. (string standard, List<string> tmdids, string school, List<string> update, int statistics) list = (null, null, null, new List<string> { StatisticsService.TeacherVote }, 0);
  780. if (tchList.IsNotEmpty())
  781. {
  782. list.tmdids = tchList.Select(x => x.id).ToList();
  783. School school = null;
  784. if (!string.IsNullOrEmpty(activityList.school))
  785. {
  786. school = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>(activityList.school, new Azure.Cosmos.PartitionKey("Base"));
  787. list.school = school.id;
  788. list.standard = school.standard;
  789. }
  790. tchList.ForEach(x =>
  791. {
  792. tchActivities.Add(new StuActivity
  793. {
  794. id = activityList.id,
  795. code = $"Activity-{x.id}",
  796. });
  797. });
  798. }
  799. await ActivityService.DeleteStuActivity(client, _dingDing, stuActivities, tmdActivities, tchActivities);
  800. }
  801. public static async Task<string> DeleteStuActivity(CosmosClient client, DingDing _dingDing, List<StuActivity> stuActivities, List<StuActivity> tmdActivities, List<StuActivity> tchActivities)
  802. {
  803. try
  804. {
  805. if (stuActivities.IsNotEmpty())
  806. {
  807. foreach (var x in stuActivities)
  808. {
  809. await client.GetContainer(Constant.TEAMModelOS, "Student").DeleteItemStreamAsync(x.id, new PartitionKey(x.code));
  810. }
  811. }
  812. if (tmdActivities.IsNotEmpty())
  813. {
  814. foreach (var x in tmdActivities)
  815. {
  816. await client.GetContainer(Constant.TEAMModelOS, "Student").DeleteItemStreamAsync(x.id, new PartitionKey(x.code));
  817. }
  818. }
  819. if (tchActivities.IsNotEmpty())
  820. {
  821. foreach (var x in tchActivities)
  822. {
  823. await client.GetContainer(Constant.TEAMModelOS, "Teacher").DeleteItemStreamAsync(x.id, new PartitionKey(x.code));
  824. }
  825. }
  826. }
  827. catch (Exception ex)
  828. {
  829. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-OS,TriggerStuActivity-DeleteStuActivity\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  830. }
  831. return "";
  832. }
  833. }
  834. public class ActivityList
  835. {
  836. public string id { get; set; }
  837. public string school { get; set; }
  838. /// <summary>
  839. /// 行政班
  840. /// </summary>
  841. public List<string> classes { get; set; } = new List<string>();
  842. /// <summary>
  843. /// 学生名单(包含自定义个人学生名单,学校教学班)
  844. /// </summary>
  845. public List<string> stuLists { get; set; } = new List<string>();
  846. /// <summary>
  847. /// 教研组名单
  848. /// </summary>
  849. public List<string> tchLists { get; set; } = new List<string>();
  850. public List<Dictionary<string, List<string>>> groupLists { get; set; } = new List<Dictionary<string, List<string>>>();
  851. }
  852. }