TriggerArt.cs 56 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874
  1. using Azure.Messaging.ServiceBus;
  2. using HTEXLib.COMM.Helpers;
  3. using Microsoft.Extensions.Configuration;
  4. using System;
  5. using System.Collections.Generic;
  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.Models;
  13. using TEAMModelOS.SDK;
  14. using Azure.Cosmos;
  15. using TEAMModelOS.SDK.Models.Cosmos.Common;
  16. using Azure.Core;
  17. using TEAMModelOS.SDK.Models.Service;
  18. using Microsoft.AspNetCore.Http;
  19. using OpenXmlPowerTools;
  20. using DocumentFormat.OpenXml.Office2010.Excel;
  21. using DocumentFormat.OpenXml.Office2016.Excel;
  22. using static TEAMModelOS.SDK.Models.Cosmos.Student.StudentAnalysis;
  23. using HTEXLib.Helpers.ShapeHelpers;
  24. using DocumentFormat.OpenXml.Spreadsheet;
  25. using NUnit.Framework;
  26. using Microsoft.AspNetCore.Mvc;
  27. using TEAMModelOS.SDK.Models.Cosmos.OpenEntity;
  28. using static System.Formats.Asn1.AsnWriter;
  29. namespace TEAMModelOS.FunctionV4.CosmosDB
  30. {
  31. public class TriggerArt
  32. {
  33. public static async Task Trigger(CoreAPIHttpService _coreAPIHttpService, AzureServiceBusFactory _serviceBus, AzureStorageFactory _azureStorage, DingDing _dingDing,
  34. CosmosClient client, JsonElement input, TriggerData tdata, AzureRedisFactory _azureRedis, IConfiguration _configuration, HttpTrigger _httpTrigger)
  35. {
  36. try
  37. {
  38. if ((tdata.status != null && tdata.status.Value == 404))
  39. {
  40. await client.GetContainer(Constant.TEAMModelOS, "Common").DeleteItemStreamAsync(tdata.id, new PartitionKey(tdata.code));
  41. ActivityList data = input.ToObject<ActivityList>();
  42. //删除blob 相关资料
  43. await _azureStorage.GetBlobServiceClient().DeleteBlobs(_dingDing, tdata.school, new List<string> { $"art/{tdata.id}" });
  44. // await IESActivityService.DeleteActivity(_coreAPIHttpService, client, _dingDing, data);
  45. var table_cancel = _azureStorage.GetCloudTableClient().GetTableReference("ChangeRecord");
  46. List<ChangeRecord> records = await table_cancel.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", tdata.id } });
  47. foreach (var record in records)
  48. {
  49. try
  50. {
  51. await table_cancel.DeleteSingle<ChangeRecord>(record.PartitionKey, record.RowKey);
  52. await _serviceBus.GetServiceBusClient().CancelMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), record.sequenceNumber);
  53. }
  54. catch (Exception)
  55. {
  56. continue;
  57. }
  58. }
  59. return;
  60. }
  61. var table = _azureStorage.GetCloudTableClient().GetTableReference("ChangeRecord");
  62. var adid = tdata.id;
  63. var adcode = "";
  64. string blobcntr = null;
  65. if (tdata.scope.Equals("school"))
  66. {
  67. adcode = $"Activity-{tdata.school}";
  68. blobcntr = tdata.school;
  69. }
  70. else
  71. {
  72. adcode = $"Activity-{tdata.creatorId}";
  73. blobcntr = tdata.creatorId;
  74. }
  75. ArtEvaluation art = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<ArtEvaluation>(tdata.id, new Azure.Cosmos.PartitionKey($"{tdata.code}"));
  76. if (art != null)
  77. {
  78. string PartitionKey = string.Format("{0}{1}{2}", art.code, "-", art.progress);
  79. List<ChangeRecord> voteRecords = await table.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", tdata.id }, { "PartitionKey", PartitionKey } });
  80. switch (art.progress)
  81. {
  82. case "pending":
  83. var messageVote = new ServiceBusMessage(new { tdata.id, progress = "going", code = tdata.code }.ToJsonString());
  84. messageVote.ApplicationProperties.Add("name", "Art");
  85. if (voteRecords.Count > 0)
  86. {
  87. long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageVote, DateTimeOffset.FromUnixTimeMilliseconds(tdata.startTime));
  88. try
  89. {
  90. await _serviceBus.GetServiceBusClient().CancelMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), voteRecords[0].sequenceNumber);
  91. }
  92. catch (Exception)
  93. {
  94. }
  95. voteRecords[0].sequenceNumber = start;
  96. await table.SaveOrUpdate<ChangeRecord>(voteRecords[0]);
  97. }
  98. else
  99. {
  100. long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageVote, DateTimeOffset.FromUnixTimeMilliseconds(tdata.startTime));
  101. ChangeRecord changeRecord = new ChangeRecord
  102. {
  103. RowKey = tdata.id,
  104. PartitionKey = PartitionKey,
  105. sequenceNumber = start,
  106. msgId = messageVote.MessageId
  107. };
  108. await table.Save<ChangeRecord>(changeRecord);
  109. }
  110. break;
  111. case "going":
  112. /*
  113. if (art.classes.Count > 0)
  114. {
  115. List<string> classes = ExamService.getClasses(art.classes, art.stuLists);
  116. (List<RMember> tmdIds, List<RGroupList> classLists) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, classes, art.school, null);
  117. var addStudentsCls = tmdIds.FindAll(x => x.type == 2);
  118. var addTmdidsCls = tmdIds.FindAll(x => x.type == 1);
  119. List<string> tmds = new List<string>();
  120. if (addTmdidsCls.IsNotEmpty())
  121. {
  122. tmds.AddRange(addTmdidsCls.Select(x => x.id).ToList());
  123. }
  124. List<StuActivity> stuActivities = new List<StuActivity>();
  125. List<StuActivity> tmdActivities = new List<StuActivity>();
  126. List<StuActivity> tchActivities = new List<StuActivity>();
  127. List<string> sub = new();
  128. if (art.subjects.Count > 0)
  129. {
  130. foreach (var course in art.subjects)
  131. {
  132. sub.Add(course.id);
  133. }
  134. }
  135. if (tmds.IsNotEmpty())
  136. {
  137. tmds.ForEach(x =>
  138. {
  139. HashSet<string> classIds = new HashSet<string>();
  140. classLists.ForEach(z =>
  141. {
  142. z.members.ForEach(y =>
  143. {
  144. if (y.id.Equals(x) && y.type == 1)
  145. {
  146. classIds.Add(z.id);
  147. }
  148. });
  149. });
  150. tmdActivities.Add(new StuActivity
  151. {
  152. pk = "Activity",
  153. id = art.id,
  154. code = $"Activity-{x}",
  155. type = "Art",
  156. name = art.name,
  157. startTime = art.startTime,
  158. endTime = art.endTime,
  159. scode = art.code,
  160. scope = art.scope,
  161. school = art.school,
  162. creatorId = art.creatorId,
  163. subjects = sub,
  164. blob = null,
  165. owner = art.owner,
  166. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  167. ext = new Dictionary<string, JsonElement>() { { "subjects", art.subjects.ToJsonString().ToObject<JsonElement>() } },
  168. taskStatus = -1,
  169. classIds = classIds.ToList()
  170. });
  171. });
  172. }
  173. if (addStudentsCls.IsNotEmpty())
  174. {
  175. addStudentsCls.ForEach(x =>
  176. {
  177. HashSet<string> classIds = new HashSet<string>();
  178. classLists.ForEach(z =>
  179. {
  180. z.members.ForEach(y =>
  181. {
  182. if (y.id.Equals(x.id) && y.code.Equals(art.school) && y.type == 2)
  183. {
  184. classIds.Add(z.id);
  185. }
  186. });
  187. });
  188. stuActivities.Add(new StuActivity
  189. {
  190. pk = "Activity",
  191. id = art.id,
  192. code = $"Activity-{x.code.Replace("Base-", "")}-{x.id}",
  193. type = "Art",
  194. name = art.name,
  195. startTime = art.startTime,
  196. endTime = art.endTime,
  197. scode = art.code,
  198. scope = art.scope,
  199. school = art.school,
  200. creatorId = art.creatorId,
  201. subjects = sub,
  202. blob = null,
  203. owner = art.owner,
  204. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  205. ext = new Dictionary<string, JsonElement>() { { "subjects", art.subjects.ToJsonString().ToObject<JsonElement>() } },
  206. taskStatus = -1,
  207. classIds = classIds.ToList()
  208. });
  209. });
  210. }
  211. await IESActivityService.SaveStuActivity(client, _dingDing, stuActivities, tmdActivities, tchActivities);
  212. }*/
  213. try
  214. {
  215. var messageVoteEnd = new ServiceBusMessage(new { tdata.id, progress = "finish", tdata.code }.ToJsonString());
  216. messageVoteEnd.ApplicationProperties.Add("name", "Art");
  217. if (voteRecords.Count > 0)
  218. {
  219. long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageVoteEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
  220. try
  221. {
  222. await _serviceBus.GetServiceBusClient().CancelMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), voteRecords[0].sequenceNumber);
  223. }
  224. catch (Exception)
  225. {
  226. }
  227. voteRecords[0].sequenceNumber = end;
  228. await table.SaveOrUpdate<ChangeRecord>(voteRecords[0]);
  229. }
  230. else
  231. {
  232. long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageVoteEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
  233. ChangeRecord changeRecord = new()
  234. {
  235. RowKey = tdata.id,
  236. PartitionKey = PartitionKey,
  237. sequenceNumber = end,
  238. msgId = messageVoteEnd.MessageId
  239. };
  240. await table.Save<ChangeRecord>(changeRecord);
  241. }
  242. }
  243. catch (Exception e)
  244. {
  245. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-艺术评测going{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  246. }
  247. finally {
  248. string pkey = string.Format("{0}{1}{2}", art.code, "-", "pending");
  249. await table.DeleteSingle<ChangeRecord>(pkey, tdata.id);
  250. }
  251. break;
  252. case "finish":
  253. //判定是否是区级创建的活动内容
  254. /* if (art.lost.Count == 0 && art.pass == 0)
  255. {
  256. if (art.owner.Equals("area") && string.IsNullOrEmpty(art.pId))
  257. {
  258. *//* List<(string id, string code, List<Tasks> settings)> artSchools = new();
  259. string ql = $"select c.id,c.school,c.settings,c.classes from c where c.pk = 'Art' and c.pId = '{art.id}'";
  260. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: ql))
  261. {
  262. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  263. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  264. {
  265. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  266. while (accounts.MoveNext())
  267. {
  268. JsonElement account = accounts.Current;
  269. List<Tasks> settings = account.GetProperty("settings").ToObject<List<Tasks>>();
  270. artSchools.Add((account.GetProperty("id").GetString(), account.GetProperty("school").GetString(), settings));
  271. }
  272. }
  273. }
  274. foreach (var (id, code, settings) in artSchools)
  275. {
  276. List<(string eId, string sId)> ids = new();
  277. var examIds = settings.SelectMany(s => s.task).Where(a => a.type == 1).Select(z => new { z.acId, z.subject }).ToList();
  278. examIds.ForEach(x =>
  279. {
  280. ids.Add((x.acId, x.subject));
  281. });
  282. List<(string code, string sub, List<string> stu)> stuInfo = await getLostAsync(ids, client, code);
  283. List<string> stus = new();
  284. foreach (var lost in stuInfo)
  285. {
  286. if (stus.Count == 0)
  287. {
  288. stus = stus.Union(lost.stu).ToList();
  289. }
  290. else {
  291. stus = stus.Intersect(lost.stu).ToList();
  292. }
  293. LostStudent lostStudent = new()
  294. {
  295. code = lost.code,
  296. subject = lost.sub,
  297. stu = lost.stu.Count
  298. };
  299. art.lost.Add(lostStudent);
  300. }
  301. art.miss.Add(stus.Count);
  302. }
  303. art.pass = 1;
  304. await client.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync<ArtEvaluation>(art, art.id, new PartitionKey(art.code));*//*
  305. }
  306. else
  307. {
  308. //获取当前艺术评价相关评测ID目前暂时排除区级发布的评测信息
  309. *//*List<(string eId, string sId)> ids = new();
  310. var examId = art.settings.SelectMany(x => x.task).Where(c => c.type == 1).Select(z => new { z.acId, z.subject }).ToList();
  311. examId.ForEach(x =>
  312. {
  313. ids.Add((x.acId, x.subject));
  314. });
  315. List<(string code, string sub, List<string> stu)> stuInfo = await getLostAsync(ids, client, art.school);
  316. List<string> stus = new();
  317. foreach (var (code, sub, stu) in stuInfo)
  318. {
  319. if (stus.Count == 0)
  320. {
  321. stus = stus.Union(stu).ToList();
  322. }
  323. else
  324. {
  325. stus = stus.Intersect(stu).ToList();
  326. }
  327. LostStudent lostStudent = new()
  328. {
  329. code = code,
  330. subject = sub,
  331. stu = stu.Count
  332. };
  333. art.lost.Add(lostStudent);
  334. }
  335. art.miss.Add(stus.Count);
  336. //art.miss = stus.Count;
  337. art.pass = 1;
  338. await client.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync<ArtEvaluation>(art, art.id, new PartitionKey(art.code));*//*
  339. }
  340. }*/
  341. //根据学校编码去获取区级ID
  342. try {
  343. School scInfo = new();
  344. //School scInfo = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>($"{art.school}", partitionKey: new Azure.Cosmos.PartitionKey("Base"));
  345. var response = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{art.school}", partitionKey: new Azure.Cosmos.PartitionKey("Base"));
  346. if (response.Status == 200)
  347. {
  348. using var cJson = await JsonDocument.ParseAsync(response.ContentStream);
  349. scInfo = cJson.ToObject<School>();
  350. }
  351. ArtSetting setting = new();
  352. try
  353. {
  354. var artResponse = await client.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemStreamAsync($"{scInfo.areaId}", partitionKey: new Azure.Cosmos.PartitionKey("ArtSetting"));
  355. if (response.Status == 200)
  356. {
  357. using var json = await JsonDocument.ParseAsync(artResponse.ContentStream);
  358. setting = json.ToObject<ArtSetting>();
  359. }
  360. }
  361. catch (Exception e)
  362. {
  363. }
  364. if (art.classes.Any())
  365. {
  366. //获取该艺术评测的评测Id
  367. List<(string id, string subjectId)> ids = new();
  368. List<ExamClassResult> examClassResults = new();
  369. var examId = art.settings.SelectMany(x => x.task).Where(c => c.type == 1).Select(z => new { z.acId, z.subject }).ToList();
  370. examId.ForEach(x =>
  371. {
  372. ids.Add((x.acId, x.subject));
  373. });
  374. List<string> results = new();
  375. results = ids.Select(x => x.id).ToList();
  376. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryStreamIterator(queryText: $"select value(c) from c where c.examId in ({string.Join(",", results.Select(x => $"'{x}'"))})", requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"ExamClassResult-{art.school}") }))
  377. {
  378. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  379. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  380. {
  381. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  382. {
  383. examClassResults.Add(obj.ToObject<ExamClassResult>());
  384. }
  385. }
  386. }
  387. //获取该艺术评测下面的评测活动
  388. List<ExamInfo> exams = new();
  389. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Common).GetItemQueryIterator<ExamInfo>(queryText: $"select value(c) from c where c.pk = 'Exam' and c.id in ({string.Join(",", results.Select(o => $"'{o}'"))})"))
  390. {
  391. exams.Add(item);
  392. }
  393. var sta = examClassResults.SelectMany(x => x.status).ToList();
  394. var ansCount = sta.Where(x => x == 0).ToList();
  395. var persent = ansCount.Count * 1.0 / sta.Count * 100;
  396. var period = scInfo.period.Where(x => x.id.Equals(art.period.id))?.FirstOrDefault();
  397. List<StudentArtResult> studentArtResults = new();
  398. string sql = $"SELECT value c FROM c where c.pk='ArtResult' ";
  399. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Student)
  400. .GetItemQueryIterator<StudentArtResult>(queryText: sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"ArtResult-{art.id}") }))
  401. {
  402. studentArtResults.Add(item);
  403. }
  404. List<Task<ItemResponse<StudentArtResult>>> tasks = new List<Task<ItemResponse<StudentArtResult>>>();
  405. //新增数据推送 obj => Portrait
  406. Portrait portrait = new()
  407. {
  408. schoolCode = art.school,
  409. periodId = art.period?.id,
  410. subjectId = "subject_art"
  411. };
  412. //var period = scInfo.period.Where(x => x.id.Equals(art.period.id)).FirstOrDefault();
  413. List<(string ptype, string subId, List<(string name, List<string> kno)> knos)> knoledge = new();
  414. //List<string> subs = new List<string> { "subject_painting", "subject_music" };
  415. if (exams.Count == 0) return;
  416. foreach (var ss in art.subjects)
  417. {
  418. if (string.IsNullOrEmpty(exams[0].papers[0].periodId))
  419. {
  420. knoledge.Add(await getKnowledge("university", "hbcn", client, ss.id, "be32942d-97a9-52ba-45d6-2e5b722583f5"));
  421. }
  422. else
  423. {
  424. knoledge.Add(await getKnowledge(art.periodType, exams.Where(c => c.subjects[0].id.Equals(ss.id))?.FirstOrDefault().papers[0].code, client, ss.id, exams.Where(c => c.subjects[0].id.Equals(ss.id))?.FirstOrDefault().papers[0].periodId));
  425. }
  426. }
  427. List<(string name, double score, double aver, string subject)> blockScore = new();
  428. List<(List<(string name, double score, double point, string subject)> studentScore, string stuId)> studentScores = new();
  429. foreach (var exam in exams)
  430. {
  431. HashSet<string> knowledge = new HashSet<string>();
  432. List<double> point = new List<double>();
  433. List<List<double>> result = new List<List<double>>();
  434. List<ClassRange> classes = new List<ClassRange>();
  435. //求单个知识点所占分数
  436. List<string> per = new List<string>();
  437. if (exam.papers[0].knowledge != null && exam.papers[0].knowledge.Count > 0)
  438. {
  439. exam.papers[0].knowledge.ForEach(k =>
  440. {
  441. k.ForEach(e =>
  442. {
  443. knowledge.Add(e);
  444. });
  445. });
  446. }
  447. point = exam.papers[0].point;
  448. List<string> knowledgeName = new List<string>();
  449. foreach (string cla in knowledge)
  450. {
  451. knowledgeName.Add(cla);
  452. }
  453. for (int k = 0; k < knowledgeName.Count; k++)
  454. {
  455. if (null == knowledgeName[k])
  456. {
  457. knowledgeName.Remove(knowledgeName[k]);
  458. }
  459. }
  460. List<double> Score = new List<double>();
  461. //List<(string name, double score, string subject)> pointScore = new();
  462. List<string> stus = examClassResults.Where(c => c.examId.Equals(exam.id)).SelectMany(z => z.studentIds).ToList();
  463. List<List<double>> stuScores = examClassResults.Where(c => c.examId.Equals(exam.id)).SelectMany(z => z.studentScores).ToList();
  464. foreach (string id in stus)
  465. {
  466. //double scores = 0;
  467. List<(string name, double score, double point, string subject)> studentScore = new();
  468. for (int k = 0; k < knowledgeName.Count; k++)
  469. {
  470. int n = 0;
  471. double OnePoint = 0;
  472. double scores = 0;
  473. exam.papers[0].knowledge.ForEach(kno =>
  474. {
  475. if (kno.Contains(knowledgeName[k]))
  476. {
  477. var itemPersent = kno.Count > 0 ? 1 / Convert.ToDouble(kno.Count) : 0;
  478. OnePoint += point[n] * itemPersent;
  479. int index = stus.IndexOf(id);
  480. if (stuScores[index][n] > 0)
  481. {
  482. scores += stuScores[index][n] * itemPersent;
  483. }
  484. }
  485. n++;
  486. });
  487. studentScore.Add((knowledgeName[k], Math.Round(scores, 2), OnePoint, exam.subjects[0].id));
  488. }
  489. studentScores.Add((studentScore, id));
  490. }
  491. for (int k = 0; k < knowledgeName.Count; k++)
  492. {
  493. double OnePoint = 0;
  494. int n = 0;
  495. double scores = 0;
  496. exam.papers[0].knowledge.ForEach(kno =>
  497. {
  498. if (kno.Contains(knowledgeName[k]))
  499. {
  500. var itemPersent = kno.Count > 0 ? 1 / Convert.ToDouble(kno.Count) : 0;
  501. OnePoint += point[n] * itemPersent;
  502. foreach (string id in stus)
  503. {
  504. int index = stus.IndexOf(id);
  505. if (stuScores[index][n] > 0)
  506. {
  507. scores += stuScores[index][n] * itemPersent;
  508. }
  509. }
  510. }
  511. n++;
  512. });
  513. double sc = stus.Count > 0 ? Math.Round(scores * 1.0 / stus.Count, 2) : 0;
  514. blockScore.Add((knowledgeName[k], OnePoint, sc, exam.subjects[0].id));
  515. //blockScore.AddRange(pointScore);
  516. }
  517. }
  518. var bls = blockScore.GroupBy(x => x.subject).Select(v => new
  519. {
  520. subjectId = v.Key,
  521. knoScore = v.ToList().GroupBy(k => k.name).Select(z => new
  522. {
  523. knoName = z.Key,
  524. score = z.ToList().Sum(j => j.score),
  525. aver = z.ToList().Sum(j => j.aver)
  526. })
  527. });
  528. //List<(string subId,List<(string name, List<string> kno)>)> subjectKnow = knoledge.Select(x => new { x.subId, x.knos }).ToList();
  529. //var subjectKnow;
  530. var subjectKnow = string.IsNullOrEmpty(exams[0].papers[0].periodId) ? knoledge.Select(x => new { x.subId, x.knos }).ToList() : knoledge.Where(c => c.ptype.Equals(art.periodType)).Select(x => new { x.subId, x.knos }).ToList();
  531. /*if (string.IsNullOrEmpty(exams[0].papers[0].periodId))
  532. {
  533. var subjectKnow = knoledge.Select(x => new { x.subId, x.knos }).ToList();
  534. }
  535. else {
  536. var subjectKnow = knoledge.Where(c => c.ptype.Equals(art.periodType)).Select(x => new { x.subId, x.knos }).ToList();
  537. }*/
  538. List<(string subjectId, List<(string name, double score, double persent, double aver, List<string> dim)> bks)> bs = new();
  539. List<(string subjectId, List<(string stuId, List<(string name, double score, double point, List<string> dim)> values)> stuBks)> sbs = new();
  540. List<(string name, double score, double av, string sId)> stuBlockScore = new();
  541. foreach (var bb in subjectKnow)
  542. {
  543. var kno1 = bls.Where(c => c.subjectId.Equals(bb.subId)).SelectMany(x => x.knoScore).ToList();
  544. var stuInfo = studentScores.Select(c => new
  545. {
  546. c.stuId,
  547. subInfo = c.studentScore.Where(x => x.subject.Equals(bb.subId)).ToList()
  548. }).Where(z => z.subInfo.Count > 0).ToList();
  549. //var kno2 = dimensions.Where(c => c.subjectBind.Equals(bb.subId)).Select(x => new { x.dimension,x.blocks}).ToList();
  550. List<(string name, double score, double aver)> blockScores = new();
  551. foreach (var k2 in bb.knos)
  552. {
  553. double bsc = 0;
  554. double avs = 0;
  555. foreach (var k3 in kno1)
  556. {
  557. if (null != k2.kno && k2.kno.Contains(k3.knoName))
  558. {
  559. bsc += k3.score;
  560. avs += k3.aver;
  561. }
  562. }
  563. foreach (var stu in stuInfo)
  564. {
  565. double realScore = 0;
  566. double realPoint = 0;
  567. foreach (var subScore in stu.subInfo)
  568. {
  569. if (null != k2.kno && k2.kno.Contains(subScore.name))
  570. {
  571. realScore = subScore.score;
  572. realPoint = subScore.point;
  573. }
  574. }
  575. stuBlockScore.Add((k2.name, realScore, realPoint, stu.stuId));
  576. }
  577. blockScores.Add((k2.name, bsc, avs));
  578. }
  579. var stuBlock = stuBlockScore.GroupBy(x => (x.sId)).Select(c => new
  580. {
  581. stuId = c.Key,
  582. block = c.ToList().GroupBy(b => b.name).Select(q => new
  583. {
  584. name = q.Key,
  585. score = q.ToList().Sum(q => q.score),
  586. point = q.ToList().Sum(q => q.av),
  587. dimension = setting.dimensions.Where(s => s.blocks.Contains(q.Key)).Select(x => x.dimension).ToList()
  588. })
  589. }).ToList();
  590. var blk = blockScores.Select(x => new
  591. {
  592. x.name,
  593. x.score,
  594. persent = Math.Round(x.aver > 0 ? x.aver / x.score : 0, 2),
  595. x.aver,
  596. dimension = setting.dimensions.Where(s => s.blocks.Contains(x.name)).Select(x => x.dimension)
  597. });
  598. List<(string name, double score, double persent, double aver, List<string> dim)> bks = new();
  599. List<(string stuId, List<(string name, double score, double point, List<string> dim)> values)> stuBks = new();
  600. foreach (var bk in blk)
  601. {
  602. bks.Add((bk.name, bk.score, bk.persent, bk.aver, bk.dimension.ToList()));
  603. }
  604. foreach (var stuBlk in stuBlock)
  605. {
  606. List<(string name, double score, double point, List<string> dim)> values = new();
  607. foreach (var lk in stuBlk.block)
  608. {
  609. values.Add((lk.name, lk.score, lk.point, lk.dimension));
  610. }
  611. stuBks.Add((stuBlk.stuId, values));
  612. }
  613. bs.Add((bb.subId, bks));
  614. sbs.Add((bb.subId, stuBks));
  615. }
  616. var blocks = bs.Select(x => new
  617. {
  618. x.subjectId,
  619. dim = x.bks.Select(z => new
  620. {
  621. z.name,
  622. z.score,
  623. z.persent,
  624. z.aver,
  625. z.dim
  626. })
  627. });
  628. var stuBlocks = sbs.Select(x => new {
  629. x.subjectId,
  630. dim = x.stuBks.Select(z => new {
  631. z.stuId,
  632. blk = z.values.Select(c => new {
  633. c.name,
  634. c.score,
  635. c.point,
  636. c.dim
  637. })
  638. })
  639. });
  640. //获取维度得分率
  641. var dim = setting.dimensions.GroupBy(a => a.subjectBind).Select(x => new
  642. {
  643. x.Key,
  644. dim = x.ToList().Select(c => new
  645. {
  646. c.dimension,
  647. persent = Math.Round(c.blocks.Select(z => new
  648. {
  649. persent = Math.Round(bs.Where(z => z.subjectId.Equals(x.Key)).SelectMany(k => k.bks).Where(q => q.name.Equals(z)).Sum(h => h.score) > 0 ?
  650. bs.Where(z => z.subjectId.Equals(x.Key)).SelectMany(k => k.bks).Where(q => q.name.Equals(z)).Sum(h => h.aver) /
  651. bs.Where(z => z.subjectId.Equals(x.Key)).SelectMany(k => k.bks).Where(q => q.name.Equals(z)).Sum(h => h.score) : 0, 2)
  652. }).Sum(o => o.persent) / c.blocks.Count, 2)
  653. })
  654. });
  655. //获取学期信息
  656. var (currSemester, studyYear, currSemesterDate, date, nextSemester) = SchoolService.GetSemester(period, art.startTime);
  657. //总分的占比情况
  658. foreach (var rs in studentArtResults)
  659. {
  660. foreach (var res in rs.results)
  661. {
  662. if (res.quotaId.Equals("quota_21") && res.score > -1 && res.score < 95)
  663. {
  664. /*res.score *= 1.5;
  665. if (res.score >= 95) {
  666. res.score = new Random().Next(90, 99);
  667. }*/
  668. //res.score = Math.Round(res.score);
  669. }
  670. }
  671. //if (rs.totalScore == 0)
  672. //{
  673. foreach (var sc in rs.subjectScores)
  674. {
  675. //if (sc.score == 0)
  676. //{
  677. /* var subjectMore = rs.results.GroupBy(x => x.subjectId).Select(c => new { subject = c.Key, list = c.ToList().Select(m => new { m.quotaId,m.score}) });
  678. var totalScore = subjectMore.Select(x => new {
  679. x.subject,
  680. quotaScroe = x.list.Select(c => new {
  681. c.quotaId,
  682. c.score
  683. }),
  684. });*/
  685. var quotaPercent = setting.quotas.Select(x => new
  686. {
  687. x.id,
  688. x.percent,
  689. score = x.children.Select(c => new
  690. {
  691. real = rs.results.Where(r => r.quotaId.Equals(c.id) && r.subjectId.Equals(sc.subjectId) && r.score > -1).FirstOrDefault()?.score * c.percent * 0.01,
  692. score = c.children.Select(s => new
  693. {
  694. real = rs.results.Where(r => r.quotaId.Equals(s.id) && r.subjectId.Equals(sc.subjectId) && r.score > -1).FirstOrDefault()?.score * s.percent * 0.01
  695. }).Sum(n => n.real) * c.percent * 0.01
  696. }).Sum(n => n.real + n.score) * x.percent * 0.01
  697. });
  698. double realScore = Math.Round((double)quotaPercent.Sum(c => c.score), 2);
  699. sc.score = realScore;
  700. //}
  701. }
  702. rs.totalScore = Math.Round(rs.subjectScores.Where(m => m.score >= 0).Sum(z => z.score), 2);
  703. tasks.Add(client.GetContainer(Constant.TEAMModelOS, Constant.Student).ReplaceItemAsync(rs, rs.id, new PartitionKey(rs.code)));
  704. PortraitStudent student = new()
  705. {
  706. studentId = rs.studentId,
  707. name = rs.studentName,
  708. classId = rs.classIds[0]
  709. };
  710. SemesterData semesterData = new()
  711. {
  712. examName = art.name,
  713. examId = art.id,
  714. examDate = art.startTime,
  715. examType = "",
  716. year = studyYear,
  717. semesterId = currSemester.id,
  718. totalScore = 200,
  719. sumScore = rs.totalScore,
  720. excellenceRate = 0,
  721. passRate = 0,
  722. };
  723. int index = 0;
  724. foreach (var sj in art.subjects)
  725. {
  726. ItemScore item = new()
  727. {
  728. name = sj.name,
  729. score = rs.subjectScores.Where(x => x.subjectId.Equals(sj.id)).FirstOrDefault().score,
  730. time = art.startTime,
  731. totalScore = 100,
  732. id = sj.id,
  733. type = sj.id,
  734. block = stuBlocks.Where(c => c.subjectId.Equals(sj.id)).SelectMany(x => x.dim).Where(z => z.stuId.Equals(rs.studentId))?.FirstOrDefault().blk,
  735. kno = studentScores.Where(c => c.stuId.Equals(rs.studentId)).SelectMany(c => c.studentScore).Where(
  736. p => p.subject.Equals(sj.id)).Select(z => new
  737. {
  738. z.name,
  739. z.score,
  740. z.point,
  741. block = subjectKnow.Where(v => v.subId.Equals(sj.id)).SelectMany(k => k.knos).Where(c => null != c.kno && c.kno.Contains(z.name)).Select(x => x.name)
  742. }),
  743. dim = dim.Where(c => c.Key.Equals(sj.id))?.FirstOrDefault().dim
  744. };
  745. index++;
  746. semesterData.itemScore.Add(item);
  747. }
  748. student.semesterData.Add(semesterData);
  749. portrait.students.Add(student);
  750. //}
  751. }
  752. if (tasks.Count > 0)
  753. {
  754. await Task.WhenAll(tasks);
  755. }
  756. //获取学生信息
  757. //(List<RMember> rmembers, List<RGroupList> groups) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, art.classes, art.school);
  758. /* foreach (var member in studentArtResults)
  759. {
  760. }*/
  761. if (null != period && persent >= 60)
  762. {
  763. string location = $"{Environment.GetEnvironmentVariable("Option:Location")}";
  764. var responseData = await _httpTrigger.RequestHttpTrigger(portrait, location, "upsert-student-portrait");
  765. }
  766. }
  767. } catch (Exception e) {
  768. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-艺术评测finish{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  769. }
  770. finally
  771. {
  772. string pk = string.Format("{0}{1}{2}", art.code, "-", "going");
  773. await table.DeleteSingle<ChangeRecord>(pk, tdata.id);
  774. }
  775. break;
  776. }
  777. }
  778. }
  779. catch (CosmosException e)
  780. {
  781. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-CosmosDB异常{e.Message}\n{e.StackTrace}\n{e.Status}", GroupNames.醍摩豆服務運維群組);
  782. }
  783. catch (Exception ex)
  784. {
  785. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}艺术评价异常{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  786. }
  787. }
  788. private static async Task<(string key, string subId, List<(string name, List<string> kno)>)> getKnowledge(string key, string school, CosmosClient client, string subjectBid, string pId)
  789. {
  790. try
  791. {
  792. var response = await client.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(school, new PartitionKey($"Base"));
  793. string subjectId = string.Empty;
  794. List<Knowledge> knowledges = new();
  795. List<(string name, List<string> kno)> blocks = new();
  796. if (response.Status == 200)
  797. {
  798. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  799. School sc = json.ToObject<School>();
  800. var subjects = sc.period.Where(p => p.id.Equals(pId)).Select(x => x.subjects);
  801. foreach (var sj in subjects)
  802. {
  803. foreach (var s in sj)
  804. {
  805. if (!string.IsNullOrWhiteSpace(s.bindId) && s.bindId.Equals(subjectBid))
  806. {
  807. subjectId = s.id;
  808. }
  809. }
  810. }
  811. string code = $"Knowledge-{school}-{subjectId}";
  812. StringBuilder sql = new StringBuilder($"select value(c) from c");
  813. if (!string.IsNullOrWhiteSpace(pId))
  814. {
  815. sql.Append($" where c.periodId = '{pId}'");
  816. }
  817. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Knowledge>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"{code}") }))
  818. {
  819. knowledges.Add(item);
  820. }
  821. }
  822. foreach (var know in knowledges)
  823. {
  824. foreach (var block in know.blocks)
  825. {
  826. blocks.Add((block.name, block.points));
  827. }
  828. }
  829. return (key, subjectBid, blocks);
  830. }
  831. catch (Exception e)
  832. {
  833. return (null, null, null);
  834. }
  835. }
  836. }
  837. }