IESActivityService.cs 51 KB

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