ActivityService.cs 65 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283
  1. using Azure.Cosmos;
  2. using Azure.Storage.Blobs.Models;
  3. using Azure.Storage.Sas;
  4. using DocumentFormat.OpenXml.Bibliography;
  5. using DocumentFormat.OpenXml.Drawing;
  6. using DocumentFormat.OpenXml.Drawing.Charts;
  7. using DocumentFormat.OpenXml.Math;
  8. using DocumentFormat.OpenXml.Spreadsheet;
  9. using DocumentFormat.OpenXml.Wordprocessing;
  10. using HTEXLib.COMM.Helpers;
  11. using OpenXmlPowerTools;
  12. using System;
  13. using System.Collections.Generic;
  14. using System.Diagnostics;
  15. using System.Linq;
  16. using System.Net.Http;
  17. using System.Net.NetworkInformation;
  18. using System.Text;
  19. using System.Text.Json;
  20. using System.Threading.Tasks;
  21. using TEAMModelOS.Models;
  22. using TEAMModelOS.SDK.DI;
  23. using TEAMModelOS.SDK.Extension;
  24. using TEAMModelOS.SDK.Models;
  25. using TEAMModelOS.Services;
  26. using static TEAMModelOS.SDK.Models.Cosmos.Student.StudentAnalysis;
  27. using Activity = TEAMModelOS.SDK.Models.Activity;
  28. namespace TEAMModelOS.SDK
  29. {
  30. public static class ActivityService
  31. {
  32. public static async Task<List<ExpertDto>> ListExperts(AzureCosmosFactory _azureCosmos ,CoreAPIHttpService _coreAPIHttpService,DingDing _dingDing, Option _option, string _activityId) {
  33. List<ExpertDto> expertTasks = new List<ExpertDto>();
  34. ActivityExpert activityExpert = null;
  35. Azure.Response response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync($"{_activityId}", new PartitionKey("ActivityExpert"));
  36. if (response.Status == 200)
  37. {
  38. bool change = false;
  39. activityExpert = JsonDocument.Parse(response.Content).RootElement.Deserialize<ActivityExpert>();
  40. var experts = activityExpert.experts.FindAll(z => string.IsNullOrWhiteSpace(z.id));
  41. var tmdids = experts.Where(x => !string.IsNullOrWhiteSpace(x.tmdid)).Select(z => z.tmdid);
  42. var phones = experts.Where(x => !string.IsNullOrWhiteSpace(x.mobile)).Select(z => z.mobile);
  43. var emails = experts.Where(x => !string.IsNullOrWhiteSpace(x.email)).Select(z => z.email);
  44. List<string> keys = new List<string>();
  45. if (tmdids.Any())
  46. {
  47. keys.AddRange(tmdids);
  48. }
  49. if (phones.Any())
  50. {
  51. keys.AddRange(phones);
  52. }
  53. if (emails.Any())
  54. {
  55. keys.AddRange(emails);
  56. }
  57. List<CoreUser> coreUsers = new List<CoreUser>();
  58. if (keys.Any())
  59. {
  60. try
  61. {
  62. var content = new StringContent(keys.ToJsonString(), Encoding.UTF8, "application/json");
  63. string json = await _coreAPIHttpService.GetUserInfos(content);
  64. if (!string.IsNullOrWhiteSpace(json))
  65. {
  66. coreUsers = json.ToObject<List<CoreUser>>();
  67. }
  68. }
  69. catch (Exception ex)
  70. {
  71. await _dingDing.SendBotMsg($"{_option.Location},导入名单时,查验key信息错误{ex.Message}\n{ex.StackTrace}\n\n{keys.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
  72. }
  73. }
  74. if (coreUsers.IsNotEmpty())
  75. {
  76. foreach (var t in experts)
  77. {
  78. if (!string.IsNullOrWhiteSpace(t.tmdid))
  79. {
  80. CoreUser coreUser = coreUsers.Find(x => x.id.Equals(t.tmdid));
  81. if (coreUser != null)
  82. {
  83. change=true;
  84. t.id = coreUser.id;
  85. t.name = coreUser.name;
  86. t.picture = coreUser.picture;
  87. t.tmdid = coreUser.id;
  88. if (!string.IsNullOrWhiteSpace(coreUser.mobile))
  89. {
  90. t.mobile = coreUser.mobile;
  91. }
  92. if (!string.IsNullOrWhiteSpace(coreUser.mail))
  93. {
  94. t.email = coreUser.mail;
  95. }
  96. }
  97. }
  98. if (string.IsNullOrWhiteSpace(t.id))
  99. {
  100. if (!string.IsNullOrWhiteSpace(t.mobile))
  101. {
  102. CoreUser coreUser = coreUsers.Find(x => !string.IsNullOrWhiteSpace(x.mobile) && x.mobile.Equals(t.mobile));
  103. if (coreUser != null)
  104. {
  105. change=true;
  106. t.id = coreUser.id;
  107. t.name = coreUser.name;
  108. t.picture = coreUser.picture;
  109. t.tmdid = coreUser.id;
  110. if (!string.IsNullOrWhiteSpace(coreUser.mobile))
  111. {
  112. t.mobile = coreUser.mobile;
  113. }
  114. if (!string.IsNullOrWhiteSpace(coreUser.mail))
  115. {
  116. t.email = coreUser.mail;
  117. }
  118. }
  119. }
  120. }
  121. if (string.IsNullOrWhiteSpace(t.id))
  122. {
  123. if (!string.IsNullOrWhiteSpace(t.email))
  124. {
  125. CoreUser coreUser = coreUsers.Find(x => !string.IsNullOrWhiteSpace(x.mail) && x.mail.Equals(t.email));
  126. if (coreUser != null)
  127. {
  128. change=true;
  129. t.id = coreUser.id;
  130. t.name = coreUser.name;
  131. t.picture = coreUser.picture;
  132. t.tmdid = coreUser.id;
  133. if (!string.IsNullOrWhiteSpace(coreUser.mobile))
  134. {
  135. t.mobile = coreUser.mobile;
  136. }
  137. if (!string.IsNullOrWhiteSpace(coreUser.mail))
  138. {
  139. t.email = coreUser.mail;
  140. }
  141. }
  142. }
  143. }
  144. }
  145. }
  146. if (change)
  147. {
  148. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(activityExpert, new PartitionKey("ActivityExpert"));
  149. }
  150. Contest contest = null;
  151. Azure.Response contestResponse = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId, new PartitionKey("Contest"));
  152. if (contestResponse.Status==200)
  153. {
  154. contest = JsonDocument.Parse(contestResponse.Content).RootElement.ToObject<Contest>();
  155. }
  156. List<ExpertDto> expertDtos = activityExpert.experts.Select(z => z.ToJsonString().ToObject<ExpertDto>()).ToList();
  157. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  158. //进入评审环节
  159. if (contest.review!= null && now > contest.review.stime)
  160. {
  161. if (expertDtos!=null && expertDtos.Count()>0)
  162. {
  163. var hasIds = expertDtos.Where(x => !string.IsNullOrWhiteSpace(x.id));
  164. if (hasIds!=null && hasIds.Count()>0)
  165. {
  166. string taskSql = $"select value c from c where c.id in ({string.Join(",", hasIds.Select(z => $"'{z.id}'"))})";
  167. var taskResults = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpertTask>(taskSql, $"ActivityExpertTask-{_activityId}");
  168. foreach (var item in taskResults.list)
  169. {
  170. var dto = expertDtos.Find(z => !string.IsNullOrWhiteSpace(z.id) && z.id.Equals(item.id));
  171. if (dto!=null)
  172. {
  173. dto.taskCount =item.contestTasks.Count();
  174. dto.teacherCount=item.contestTasks.SelectMany(z => z.members).Count();
  175. dto.completeCount=item.contestTasks.Where(z => z.status==1).Count();
  176. dto.uploads= item.contestTasks.Select(z => new ContestUploadData { name = z.name, id=z.uploadId, code=string.Join(",", z.uploadTypes), count=z.count, status= z.status, score=z.score, detailScore=z.detailScore }).ToList();
  177. }
  178. }
  179. }
  180. }
  181. }
  182. expertTasks.AddRange(expertDtos);
  183. }
  184. return expertTasks;
  185. }
  186. public static async Task<List<ActivityScoreLevel>> ActivityScores (AzureCosmosFactory _azureCosmos,JsonElement _activityId,string teacherId= null) {
  187. List<ActivityScoreLevel> scoreLevels = new List<ActivityScoreLevel>();
  188. Azure.Response responseContest = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  189. if (responseContest.Status == 200)
  190. {
  191. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  192. Contest contest = JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  193. string sql = $"select value c from c ";
  194. if (!string.IsNullOrWhiteSpace(teacherId)) {
  195. sql=$"{sql} where c.id ='{teacherId}'";
  196. }
  197. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(sql, $"ActivityEnroll-{_activityId}");
  198. //List<ActivityTeacherScoreLevel> teacherScoreLevels = new List<ActivityTeacherScoreLevel>();
  199. List<ActivityTeacherScore> teacherScores = new List<ActivityTeacherScore>();
  200. if (result.list.IsNotEmpty())
  201. {
  202. if (contest.sign.type==1)
  203. {
  204. var teams = result.list.Where(x => !string.IsNullOrEmpty(x.contest?.cipher)).GroupBy(z => z.contest.cipher);
  205. foreach (var team in teams)
  206. {
  207. var members = team.ToList();
  208. var leader = members.FindAll(z => z.contest.leader==1)?.FirstOrDefault();
  209. if (leader==null)
  210. {
  211. leader=members.First();
  212. }
  213. double score = leader.upload?.score??-1;
  214. if (leader.upload?.showScore==1)
  215. {
  216. score= leader.upload.maskScore;
  217. }
  218. teacherScores.Add(new ActivityTeacherScore
  219. {
  220. uploadId=leader.upload?.uploadId,
  221. uploadName=!string.IsNullOrWhiteSpace(leader.upload?.name) ? leader.upload?.name : $"{leader.contest.teamName}",
  222. score=score,
  223. tmdid=leader.id,
  224. nickname=leader.tmdName,
  225. name=leader.contest.enrollInfos.Find(z => z.code.Equals("name"))?.val,
  226. picture=leader.tmdPicture,
  227. school=leader.schoolId,
  228. schoolName=leader.schoolName,
  229. schoolPicture=leader.schoolPicture,
  230. cipher=leader.contest.cipher,
  231. teamName=leader.contest.teamName,
  232. type=leader.contest.type,
  233. members=members.Select(z => new IdNameCode { id=z.id, name=z.contest.enrollInfos.Find(x => x.code.Equals("name"))?.val, picture=z.tmdPicture, nickname=z.tmdName }).ToList(),
  234. });
  235. }
  236. }
  237. else
  238. {
  239. ///个人组
  240. foreach (var item in result.list)
  241. {
  242. double score = item.upload?.score??-1;
  243. if (item.upload?.showScore==1)
  244. {
  245. score= item.upload.maskScore;
  246. }
  247. teacherScores.Add(new ActivityTeacherScore
  248. {
  249. uploadId=item.upload?.uploadId,
  250. uploadName=!string.IsNullOrWhiteSpace(item.upload?.name) ? item.upload?.name : $"{item.contest.enrollInfos.Find(z => z.code.Equals("name"))?.val}",
  251. score=score,
  252. tmdid=item.id,
  253. nickname=item.tmdName,
  254. name=item.contest.enrollInfos.Find(z => z.code.Equals("name"))?.val,
  255. picture=item.tmdPicture,
  256. school=item.schoolId,
  257. schoolName=item.schoolName,
  258. schoolPicture=item.schoolPicture,
  259. type=item.contest.type,
  260. });
  261. }
  262. }
  263. if(contest.modules.Contains("score") && contest.score!= null)
  264. {
  265. if (contest.score.showType==1)
  266. {
  267. teacherScores= teacherScores.Where(x => x.score>=0).OrderByDescending(x => x.score).ToList();
  268. if (contest.score.levelType==1)
  269. {
  270. var levels = contest.score.scoreLevels.OrderBy(x => x.order).ToList();
  271. foreach (var level in levels)
  272. {
  273. var datas = teacherScores.Take(level.top);
  274. var scores = datas.ToJsonString().ToObject<List<ActivityTeacherScoreLevel>>();
  275. scores.ForEach(z => { z.scoreLevel=level.lable; });
  276. scoreLevels.Add(new ActivityScoreLevel { lable=level.lable, scores=scores });
  277. teacherScores.RemoveAll(x => scores.Select(v => v.uploadId).Contains(x.uploadId));
  278. }
  279. }
  280. else
  281. {
  282. var levels = contest.score.scoreLevels.OrderByDescending(x => x.max);
  283. foreach (var level in levels)
  284. {
  285. scoreLevels.Add(new ActivityScoreLevel { lable=level.lable });
  286. foreach (var item in teacherScores)
  287. {
  288. if (item.score==80)
  289. {
  290. Console.Write(1);
  291. }
  292. string label = string.Empty;
  293. if (level.max==100)
  294. {
  295. if (item.score>=level.min && item.score<=level.max)
  296. {
  297. label=level.lable;
  298. }
  299. }
  300. else
  301. {
  302. if (item.score>=level.min && item.score<level.max)
  303. {
  304. label=level.lable;
  305. }
  306. }
  307. if (!string.IsNullOrWhiteSpace(label))
  308. {
  309. var score = item.ToJsonString().ToObject<ActivityTeacherScoreLevel>();
  310. score.scoreLevel=label;
  311. score.score=item.score;
  312. var data = scoreLevels.Find(x => x.lable.Equals(label));
  313. if (data!=null)
  314. {
  315. data.scores.Add(score);
  316. }
  317. else
  318. {
  319. scoreLevels.Add(new ActivityScoreLevel { lable=label, scores= new List<ActivityTeacherScoreLevel>() { score } });
  320. }
  321. }
  322. }
  323. }
  324. }
  325. }
  326. else
  327. {
  328. if (contest.score.top>-1)
  329. {
  330. teacherScores= teacherScores.Where(x => x.score>=0).OrderByDescending(x => x.score).Take(contest.score.top).ToList();
  331. }
  332. else
  333. {
  334. teacherScores= teacherScores.Where(x => x.score>=0).ToList();
  335. }
  336. var scores = new List<ActivityTeacherScoreLevel>();
  337. foreach (var item in teacherScores)
  338. {
  339. double score = item.score;
  340. var teacher = item.ToJsonString().ToObject<ActivityTeacherScoreLevel>();
  341. teacher.scoreLevel=$"{score}";
  342. teacher.score=score;
  343. scores.Add(teacher);
  344. }
  345. scoreLevels.Add(new ActivityScoreLevel { lable="", scores=scores });
  346. }
  347. }
  348. }
  349. }
  350. return scoreLevels;
  351. }
  352. public static async Task<(List<ExpertContestTaskDto> expertContestTasks, List<ExpertContestTaskDto> activityEnrollsInvalid, List<ExpertContestTaskDto> expertContestTasksDB)>
  353. AllocationTask(AzureCosmosFactory _azureCosmos, IEnumerable<ExpertPeriodSubjectDto> experts, Contest contest, HashSet<string> periodSubjectKeys, string distribute, int taskCount)
  354. {
  355. //先获取已经分配完成的
  356. List<ExpertContestTaskDto> worksDB = new List<ExpertContestTaskDto>();
  357. IEnumerable<ExpertContestTaskDto> complete = new List<ExpertContestTaskDto>();
  358. string taskSQL = $"select value c from c where c.pk='ActivityExpertTask'";
  359. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpertTask>(taskSQL, $"ActivityExpertTask-{contest.id}");
  360. if (result.list.IsNotEmpty())
  361. {
  362. foreach (var item in result.list)
  363. {
  364. worksDB.AddRange(item.contestTasks.Select(z =>
  365. new ExpertContestTaskDto
  366. {
  367. expertName=item.name ,
  368. expertPicture=item.picture,
  369. expertTmdname=item.tmdname,
  370. expertId = item.id,
  371. available = 1,
  372. uploadId = z.uploadId,
  373. name = z.name,
  374. uploadTypes = z.uploadTypes,
  375. count = z.count,
  376. cipher=z.cipher,
  377. type=z.type,
  378. leader=z.leader,
  379. members=z.members,
  380. tmdid=z.tmdid,
  381. score=z.score,
  382. status=z.status,
  383. detailScore=z.detailScore,
  384. activityId=contest.id
  385. }));
  386. }
  387. //处理已经分配完成(taskCount)的作品
  388. complete = worksDB.GroupBy(task => task.uploadId).Where(group => group.Count() >= taskCount).SelectMany(group => group);
  389. }
  390. string enrollSQL = "select value c from c where c.pk='ActivityEnroll'";
  391. //已经满足分配的无需再去处理检查。
  392. if (complete!=null && complete.Count()>0)
  393. {
  394. var uploadIds = complete.Select(z => z.uploadId).ToHashSet();
  395. enrollSQL =$"{enrollSQL} where c.upload.uploadId not in ({string.Join(",", uploadIds.Select(z => $"'{z}'"))})";
  396. }
  397. //检查报名,学段和科目是否匹配
  398. var resultActivityEnroll = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(enrollSQL, $"ActivityEnroll-{contest.id}");
  399. List<ExpertContestTaskDto> expertContestTasks = new List<ExpertContestTaskDto>();
  400. foreach (ActivityEnroll enroll in resultActivityEnroll.list)
  401. {
  402. //如果是队长统一上传
  403. if (contest.upload.captainUpload == 1 && !string.IsNullOrWhiteSpace(enroll.contest?.cipher))
  404. {
  405. var team = resultActivityEnroll.list.FindAll(z => z.contest != null && z.contest.type == 1 && enroll.contest?.type == 1 && z.contest.cipher.Equals(enroll.contest.cipher));
  406. //获取队长信息
  407. var leaders = team.FindAll(z => z.contest.leader == 1);
  408. if (leaders.IsNotEmpty())
  409. {
  410. leaders = new List<ActivityEnroll>() { enroll };
  411. }
  412. List<IdNameCode> members = team.Select(z => new IdNameCode { id = z.id, code = z.schoolId, picture = z.tmdPicture, nickname = z.tmdName, name = z.contest?.enrollInfos?.Find(e => e.code.Equals("name")).val }).ToList();
  413. //队长的报名信息
  414. var leader = leaders?.First();
  415. string name = leader?.contest?.teamName;
  416. var period = leader?.contest?.enrollInfos?.Find(z => z.code.Equals("period"));
  417. var subject = leader?.contest?.enrollInfos?.Find(z => z.code.Equals("subject"));
  418. string uploadId = string.Empty;
  419. if (string.IsNullOrEmpty(name))
  420. {
  421. name = $"{leader?.contest?.enrollInfos?.Find(z => z.code.Equals("name"))?.val}({team.Count})";
  422. }
  423. int count = 0;
  424. int available = -1;
  425. var checkResult = ActivityService.CheckPeriodSubject(distribute, period, subject, periodSubjectKeys);
  426. if (checkResult.available == 0)
  427. {
  428. if (leader?.upload != null && leader.upload.sokrates.IsNotEmpty())
  429. {
  430. count += leader.upload.sokrates.Count;
  431. }
  432. if (leader?.upload != null && leader.upload.files.IsNotEmpty())
  433. {
  434. count += leader.upload.files.Count;
  435. }
  436. if (leader?.upload != null && leader.upload.lessons.IsNotEmpty())
  437. {
  438. count += leader.upload.lessons.Count;
  439. }
  440. if (leader?.upload!=null && leader.upload.complexes.IsNotEmpty())
  441. {
  442. count+=leader.upload.complexes.Count();
  443. }
  444. if (count <= 0)
  445. {
  446. uploadId = enroll.contest.cipher;
  447. available = 5;
  448. }
  449. else
  450. {
  451. uploadId = leader?.upload?.uploadId;
  452. available = checkResult.available;
  453. }
  454. }
  455. else
  456. {
  457. uploadId = enroll.contest.cipher;
  458. available = checkResult.available;
  459. }
  460. ExpertContestTaskDto expertContestTask = expertContestTasks.Find(z => !string.IsNullOrWhiteSpace(z.uploadId) && z.uploadId.Equals(leader.upload));
  461. if (expertContestTask == null)
  462. {
  463. expertContestTasks.Add(new ExpertContestTaskDto
  464. {
  465. uploadId = leader.upload?.uploadId,
  466. name = $"{leader.schoolName}-{name}",
  467. // uploadTypes = new List<string> { leader?.upload.type },
  468. uploadTypes =leader.upload.uploadType,
  469. count = count,
  470. cipher = leader.contest?.cipher,
  471. type = 1,
  472. leader = 1,
  473. tmdid = leader.id,
  474. status = -1,
  475. score = -1,
  476. //detailScore=new List<RuleConfig>()
  477. members = members,
  478. periodSubjectKey = checkResult.periodSubjectKey,
  479. period = period?.val,
  480. subject = subject?.val,
  481. available = available,
  482. activityId=contest.id,
  483. });
  484. }
  485. else
  486. {
  487. expertContestTask.available = available;
  488. expertContestTask.name = name;
  489. expertContestTask.count = count;
  490. expertContestTask.members = members;
  491. expertContestTask.periodSubjectKey = checkResult.periodSubjectKey;
  492. expertContestTask.activityId=contest?.id;
  493. }
  494. }
  495. else
  496. {
  497. if (enroll.upload!= null)
  498. {
  499. //如果不是队长统一上传
  500. //学段
  501. var period = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("period"));
  502. //科目
  503. var subject = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("subject"));
  504. string periodSubjectKey = string.Empty;
  505. string name = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("name"))?.val;
  506. string uploadId = string.Empty;
  507. if (!string.IsNullOrEmpty(name))
  508. {
  509. name = $"({name})";
  510. }
  511. else
  512. {
  513. name = string.Empty;
  514. }
  515. int count = 0;
  516. int available = -1;
  517. var checkResult = ActivityService.CheckPeriodSubject(distribute, period, subject, periodSubjectKeys);
  518. if (checkResult.available == 0)
  519. {
  520. if (enroll.upload != null && enroll.upload.sokrates.IsNotEmpty())
  521. {
  522. count += enroll.upload.sokrates.Count;
  523. }
  524. if (enroll.upload != null && enroll.upload.files.IsNotEmpty())
  525. {
  526. count += enroll.upload.files.Count;
  527. }
  528. if (enroll.upload != null && enroll.upload.lessons.IsNotEmpty())
  529. {
  530. count += enroll.upload.lessons.Count;
  531. }
  532. if (enroll.upload != null && enroll.upload.complexes.IsNotEmpty())
  533. {
  534. count+=enroll.upload.complexes.Count();
  535. }
  536. if (count <= 0)
  537. {
  538. available = 5;
  539. uploadId = enroll.id;
  540. }
  541. else
  542. {
  543. available = checkResult.available;
  544. uploadId = enroll.upload.uploadId;
  545. }
  546. }
  547. else
  548. {
  549. uploadId = enroll.id;
  550. available = checkResult.available;
  551. }
  552. ExpertContestTaskDto expertContestTask = expertContestTasks.Find(z => !string.IsNullOrWhiteSpace(z.uploadId) && z.uploadId.Equals(enroll.upload));
  553. if (expertContestTask == null)
  554. {
  555. expertContestTasks.Add(new ExpertContestTaskDto
  556. {
  557. uploadId = uploadId,
  558. name = $"{enroll.schoolName}-{name}",
  559. //uploadTypes = new List<string> { enroll.upload?.type },
  560. uploadTypes =enroll.upload.uploadType,
  561. count = count,
  562. cipher = enroll.contest?.cipher,
  563. type = 1,
  564. leader = 1,
  565. tmdid = enroll.id,
  566. status = -1,
  567. score = -1,
  568. periodSubjectKey = checkResult.periodSubjectKey,
  569. period = period?.val,
  570. subject = subject?.val,
  571. available = available,
  572. activityId = contest?.id,
  573. });
  574. }
  575. else
  576. {
  577. expertContestTask.available = available;
  578. expertContestTask.name = name;
  579. expertContestTask.count = count;
  580. expertContestTask.periodSubjectKey = checkResult.periodSubjectKey;
  581. expertContestTask.activityId=contest?.id;
  582. }
  583. }
  584. }
  585. }
  586. List<ExpertContestTaskDto> invalids = expertContestTasks.FindAll(z => z.available!=0);
  587. List<ExpertContestTaskDto> works = expertContestTasks.FindAll(z => z.available==0);
  588. var data = AssignWorksToExperts(works, worksDB, experts, taskCount);
  589. if (invalids.IsNotEmpty()) {
  590. invalids.AddRange(data.assignmentsInvalid);
  591. }
  592. List<ExpertContestTaskDto> okTask = new List<ExpertContestTaskDto>();
  593. okTask.AddRange(data.assignmentsAdd);
  594. okTask.AddRange(worksDB);
  595. var groups= okTask.GroupBy(z => z.uploadId).Select(x => new { key = x.Key, list = x.ToList() });
  596. foreach (var item in groups) {
  597. if (item.list.Count()<taskCount) {
  598. ExpertContestTaskDto taskDto= item.list.First().ToJsonString().ToObject<ExpertContestTaskDto>();
  599. taskDto.expertName=null;
  600. taskDto.expertId=null;
  601. taskDto.expertPicture=null;
  602. taskDto.expertTmdname=null;
  603. //,8分配次数不足
  604. taskDto.available=8;
  605. invalids.Add(taskDto);
  606. }
  607. }
  608. return (data.assignmentsAdd, invalids, worksDB);
  609. }
  610. public static (int available, string periodSubjectKey) CheckPeriodSubject(string distribute , EnrollInfo period, EnrollInfo subject, HashSet<string> periodSubjectKeys) {
  611. int available = -1;
  612. string periodSubjectKey= string.Empty;
  613. if (distribute.Equals("period"))
  614. {
  615. if (period != null)
  616. {
  617. periodSubjectKey = $"{period.val}-";
  618. }
  619. else
  620. {
  621. available = 2;
  622. }
  623. }
  624. else if (distribute.Equals("subject"))
  625. {
  626. if (subject != null)
  627. {
  628. periodSubjectKey = $"-{subject.val}";
  629. }
  630. else
  631. {
  632. available = 3;
  633. }
  634. }
  635. else if (distribute.Equals("periodAndSubject"))
  636. {
  637. if (period != null && subject != null)
  638. {
  639. periodSubjectKey = $"{period.val}-{subject.val}";
  640. }
  641. else
  642. {
  643. available = 4;
  644. }
  645. }
  646. else
  647. {
  648. periodSubjectKey = "-";
  649. }
  650. if (!string.IsNullOrWhiteSpace(periodSubjectKey)) {
  651. if (periodSubjectKeys.Contains(periodSubjectKey))
  652. {
  653. available = 0;
  654. }
  655. else
  656. {
  657. //学段学科不匹配
  658. available = 6;
  659. }
  660. }
  661. return (available, periodSubjectKey);
  662. }
  663. /// <summary>
  664. /// 将作品按分配次数,分配给不同的专家
  665. /// </summary>
  666. /// <param name="works"></param>
  667. /// <param name="experts"></param>
  668. /// <param name="N"></param>
  669. /// <returns></returns>
  670. static (List<ExpertContestTaskDto> assignmentsAdd, List<ExpertContestTaskDto> assignmentsInvalid) AssignWorksToExperts(List<ExpertContestTaskDto> works,List<ExpertContestTaskDto> worksDB, IEnumerable<ExpertPeriodSubjectDto> experts, int N)
  671. {
  672. //增加的
  673. var assignmentsAdd = new List<ExpertContestTaskDto>();
  674. //未分配到的
  675. var assignmentsInvalid = new List<ExpertContestTaskDto>();
  676. var random = new Random();
  677. //用于处理数据库和新分配的结果中检查已经分配过的作品和专家
  678. var assignmentsAll = worksDB.ToJsonString().ToObject<List<ExpertContestTaskDto>>();
  679. foreach (var work in works)
  680. {
  681. for (int i = 0; i < N; i++)
  682. {
  683. //分配次数已经Ok,分配结果完善的,不需要再去处理
  684. if (assignmentsAll.Count(z => z.uploadId.Equals(work.uploadId))>=N) {
  685. continue;
  686. }
  687. var availableExperts = experts
  688. .OrderBy(expert => assignmentsAll.Count(a => a.expertId == expert.expertId))
  689. .Where(expert => expert.periodSubjects.Contains(work.periodSubjectKey) && !assignmentsAll.Any(a => a.uploadId == work.uploadId && a.expertId == expert.expertId))
  690. .ToList();
  691. if (availableExperts.Count > 0)
  692. {
  693. var selectedExpert = availableExperts[random.Next(availableExperts.Count)];
  694. var newWork= work.DeepCopy<ExpertContestTaskDto>();
  695. newWork.expertId = selectedExpert.expertId;
  696. newWork.expertName = selectedExpert.expertName;
  697. newWork.expertPicture = selectedExpert.expertPicture;
  698. newWork.expertTmdname = selectedExpert.expertTmdname;
  699. newWork.available = 1;
  700. newWork.turn = i + 1;
  701. assignmentsAdd.Add(newWork);
  702. assignmentsAll.Add(newWork);
  703. }
  704. else
  705. {
  706. var newWork = work.DeepCopy<ExpertContestTaskDto>();
  707. newWork.expertId =null;
  708. newWork.available = 7;
  709. newWork.turn = i + 1;
  710. //作品在第几轮未匹配到
  711. assignmentsInvalid.Add(newWork);
  712. //Console.WriteLine($"No available expert for WorkId {work.uploadId} and subject {work.periodSubjectKey} in attempt {i + 1}.");
  713. break;
  714. }
  715. }
  716. }
  717. return (assignmentsAdd, assignmentsInvalid);
  718. }
  719. /// <summary>
  720. /// 删除活动关联的数据
  721. /// </summary>
  722. /// <param name="_azureCosmos"></param>
  723. /// <param name="activity"></param>
  724. /// <returns></returns>
  725. public static async Task DeleteActivityRelated(AzureCosmosFactory _azureCosmos,Activity activity)
  726. {
  727. //删除模块,Contest, Training ,Research, ReviewRule规则(ReviewRule-disposable"; 存为活动)
  728. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).DeleteItemStreamAsync(activity.id, new PartitionKey("Contest"));
  729. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).DeleteItemStreamAsync(activity.id, new PartitionKey("Training"));
  730. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).DeleteItemStreamAsync(activity.id, new PartitionKey("Research"));
  731. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).DeleteItemStreamAsync(activity.id, new PartitionKey("ReviewRule-disposable"));
  732. //删除邀请教师 ActivityTeacher,
  733. var resultTeacher = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
  734. .GetList<IdCode>("select c.id ,c.code from c where c.pk='ActivityEnroll' and c.", $"ActivityTeacher-{activity.id}");
  735. if (resultTeacher.list.IsNotEmpty())
  736. {
  737. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).DeleteItemsStreamAsync(resultTeacher.list.Select(z => z.id).ToList(), $"ActivityTeacher-{activity.id}");
  738. }
  739. //删除报名数据 ActivityEnroll
  740. var resultEnroll = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
  741. .GetList<IdCode>("select c.id ,c.code from c where c.pk='ActivityEnroll' and c.", $"ActivityEnroll-{activity.id}");
  742. if (resultEnroll.list.IsNotEmpty())
  743. {
  744. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).DeleteItemsStreamAsync(resultEnroll.list.Select(z => z.id).ToList(), $"ActivityEnroll-{activity.id}");
  745. }
  746. //删除专家数据 ActivityExpert
  747. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).DeleteItemStreamAsync(activity.id, new PartitionKey("ActivityExpert"));
  748. }
  749. /// <summary>
  750. /// 生成组队口令
  751. /// </summary>
  752. /// <param name="client"></param>
  753. /// <param name="_dingDing"></param>
  754. /// <param name="_option"></param>
  755. /// <param name="_activityId"></param>
  756. /// <returns></returns>
  757. /// <exception cref="Exception"></exception>
  758. public static async Task<string> GenCipher(CosmosClient client, DingDing _dingDing, TEAMModelOS.Models.Option _option, string _activityId)
  759. {
  760. string _num09 = "123456789";
  761. string no = $"{Utils.CreatSaltString(7, _num09)}";
  762. for (int i = 0; i < 10; i++)
  763. {
  764. List<SheetConfig> sheets = new List<SheetConfig>();
  765. bool hasCurrFrom = false;
  766. string cipherSQL = $"select value c.id from c where c.contest!=null and c.activityId='{_activityId}' and c.contest.type=1 and c.contest.cipher='{no}' ";
  767. var cipherResult = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<string>(cipherSQL, $"ActivityEnroll-{_activityId}");
  768. if (cipherResult.list.IsNotEmpty() && cipherResult.list.Count>0) {
  769. hasCurrFrom = true;
  770. }
  771. if (hasCurrFrom)
  772. {
  773. if (i == 9)
  774. {
  775. string msg = $"{_option.Location},ActivityService/GenCipher\n 组队口令生成异常,重复生成次数超过10次";
  776. await _dingDing.SendBotMsg($"OS,{_option.Location},{msg}", GroupNames.醍摩豆服務運維群組);
  777. throw new Exception(msg);
  778. }
  779. else
  780. {
  781. no = $"{Utils.CreatSaltString(7, _num09)}";
  782. }
  783. }
  784. else { break; }
  785. }
  786. return no;
  787. }
  788. public static async Task<IEnumerable<ActivityDto>> AreaActivityList(AzureCosmosFactory _azureCosmos, AzureStorageFactory _azureStorage, JsonElement request, string _areaId, int isCount = 0)
  789. {
  790. string yearSql = string.Empty;
  791. if (isCount==0) {
  792. yearSql = $" and c.year={DateTimeOffset.Now.Year}";
  793. if (request.TryGetProperty("year", out JsonElement _year))
  794. {
  795. yearSql = $" and c.year={_year}";
  796. }
  797. }
  798. string sql = $"select value c from c where c.owner='{_areaId}' {yearSql} ";
  799. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sql, "Activity");
  800. result.list.ForEach(z => {
  801. var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS(z.owner, BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);
  802. z.sas=blob_sas;
  803. z.url=blob_uri;
  804. });
  805. return result.list.OrderByDescending(z => z.stime);
  806. }
  807. public static async Task<List<ActivityDto>> SchoolActivityList(AzureCosmosFactory _azureCosmos, AzureStorageFactory _azureStorage, JsonElement request, string school, int isCount = 0) {
  808. School schoolbase = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemAsync<School>(school, new PartitionKey("Base"));
  809. List<ActivityDto> activities = new List<ActivityDto>();
  810. string yearSql = string.Empty;
  811. if (isCount==0)
  812. {
  813. yearSql = $" and c.year={DateTimeOffset.Now.Year}";
  814. if (request.TryGetProperty("year", out JsonElement _year))
  815. {
  816. yearSql = $" and c.year={_year}";
  817. }
  818. }
  819. //获取开放的
  820. {
  821. //完全开放 所有的学校
  822. string sqlOpen = $"select value c from c where c.scope='public' {yearSql} and (c.publish=1 or c.publish=2 ) and( ARRAY_LENGTH(c.invitedSchools)=0 or IS_DEFINED(c.invitedSchools) = false ) ";
  823. var resultOpen = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlOpen, "Activity");
  824. activities.AddRange(resultOpen.list);
  825. //部分学校
  826. string sqlSchool = $"select value c from c join s in c.invitedSchools where c.scope='public' {yearSql} and (c.publish=1 or c.publish=2 ) and s.id='{school}' ";
  827. var resultSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlSchool, "Activity");
  828. resultSchool.list.ForEach(z =>
  829. {
  830. var confirmedSchool = z.confirmedSchools.Find(z => z.id.Equals(school));
  831. if (confirmedSchool==null)
  832. {
  833. z.confirmedSchools.Add(new ActivityConfirmedSchool
  834. {
  835. id=schoolbase.id,
  836. name=schoolbase.name,
  837. picture=schoolbase.picture,
  838. status=0
  839. });
  840. }
  841. });
  842. activities.AddRange(resultSchool.list);
  843. }
  844. //获取区级下放的
  845. {
  846. if (!string.IsNullOrWhiteSpace(schoolbase.areaId))
  847. {
  848. //区级所有学校
  849. string sqlOpen = $"select value c from c where c.scope='area'{yearSql} and (c.publish=1 or c.publish=2 ) and c.owner='{schoolbase.areaId}' and( ARRAY_LENGTH(c.invitedSchools)=0 or IS_DEFINED(c.invitedSchools) = false) ";
  850. var resultOpen = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlOpen, "Activity");
  851. resultOpen.list.ForEach(z =>
  852. {
  853. var confirmedSchool = z.confirmedSchools.Find(z => z.id.Equals(school));
  854. if (confirmedSchool==null)
  855. {
  856. z.confirmedSchools.Add(new ActivityConfirmedSchool
  857. {
  858. id=schoolbase.id,
  859. name=schoolbase.name,
  860. picture=schoolbase.picture,
  861. status=0
  862. });
  863. }
  864. });
  865. activities.AddRange(resultOpen.list);
  866. //区级部分学校
  867. string sqlSchool = $"select value c from c join s in c.invitedSchools where c.scope='area'{yearSql} and (c.publish=1 or c.publish=2 ) and c.owner='{schoolbase.areaId}' and s.id='{school}' ";
  868. var resultSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlSchool, "Activity");
  869. resultSchool.list.ForEach(z =>
  870. {
  871. var confirmedSchool = z.confirmedSchools.Find(z => z.id.Equals(school));
  872. if (confirmedSchool==null)
  873. {
  874. z.confirmedSchools.Add(new ActivityConfirmedSchool
  875. {
  876. id=schoolbase.id,
  877. name=schoolbase.name,
  878. picture=schoolbase.picture,
  879. status=0
  880. });
  881. }
  882. });
  883. activities.AddRange(resultSchool.list);
  884. }
  885. }
  886. //获取学校自己的
  887. {
  888. string sqlSchool = $"select value c from c where c.scope='school'{yearSql} and c.owner='{school}' ";
  889. var resultSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlSchool, "Activity");
  890. activities.AddRange(resultSchool.list);
  891. }
  892. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  893. activities.ForEach(z =>
  894. {
  895. var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS(z.owner, BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);
  896. z.sas=blob_sas;
  897. z.url = blob_uri;
  898. if (z.etime<now)
  899. {
  900. z.publish=2;
  901. }
  902. });
  903. return activities;
  904. }
  905. public static async Task<List<TeacherActivityDto>> TeacherActivityList(AzureCosmosFactory _azureCosmos,AzureStorageFactory _azureStorage, JsonElement request, string tmdid, int isCount = 0)
  906. {
  907. List<TeacherActivityDto> activities = new List<TeacherActivityDto>();
  908. HashSet<string> inviteActivityIds = new HashSet<string>();
  909. string yearSql = string.Empty;
  910. if (isCount==0)
  911. {
  912. yearSql = $" and c.year={DateTimeOffset.Now.Year}";
  913. if (request.TryGetProperty("year", out JsonElement _year) && int.TryParse($"{_year}", out int year))
  914. {
  915. yearSql = $" and c.year={year}";
  916. }
  917. }
  918. //先获取邀请制的
  919. string sqlInvite = $"select value c from c join t in c.inviteTeachers where t.id='{tmdid}' and c.pk='ActivityTeacher'";
  920. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityTeacher>(sqlInvite);
  921. inviteActivityIds= result.list.Where(x=>!string.IsNullOrWhiteSpace(x.activityId)).Select(z => z.activityId).ToHashSet();
  922. if (inviteActivityIds.Count>0)
  923. {
  924. string sqlActivity = $"select value c from c where c.id in ({string.Join(",", inviteActivityIds.Select(z => $"'{z}'"))}) {yearSql} ";
  925. var resultActivity = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<TeacherActivityDto>(sqlActivity, "Activity");
  926. if (resultActivity.list.IsNotEmpty())
  927. {
  928. activities.AddRange(resultActivity.list);
  929. }
  930. }
  931. Teacher teacher = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemAsync<Teacher>(tmdid, new PartitionKey("Base"));
  932. string schoolOwnerIn = string.Empty;
  933. string schoolIdIn = string.Empty;
  934. if (teacher.schools.IsNotEmpty())
  935. {
  936. schoolIdIn = $"and i.id in ({string.Join(",", teacher.schools.Select(z => $"'{z.schoolId}'"))})";
  937. schoolOwnerIn= $"and c.owner in ({string.Join(",", teacher.schools.Select(z => $"'{z.schoolId}'"))})";
  938. }
  939. //获取开放的
  940. {
  941. //完全开放 所有的学校
  942. string sqlOpen = $"select value c from c where c.scope='public' and (c.publish=1 or c.publish=2 ) and( ARRAY_LENGTH(c.invitedSchools)=0 or IS_DEFINED(c.invitedSchools) = false ) {yearSql} ";
  943. var resultOpen = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<TeacherActivityDto>(sqlOpen, "Activity");
  944. activities.AddRange(resultOpen.list);
  945. if (!string.IsNullOrWhiteSpace(schoolIdIn))
  946. { //部分学校
  947. string sqlSchool = $"select value c from c join i in c.confirmedSchools where c.scope='public' and c.joinMode='enroll' and (c.publish=1 or c.publish=2 ) and i.status=1 {yearSql} {schoolIdIn} ";
  948. var resultSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<TeacherActivityDto>(sqlSchool, "Activity");
  949. activities.AddRange(resultSchool.list);
  950. }
  951. }
  952. string areaOwnerIn = string.Empty;
  953. var hasAreaSchools = teacher.schools.FindAll(z => !string.IsNullOrWhiteSpace(z.areaId));
  954. if (hasAreaSchools.IsNotEmpty())
  955. {
  956. areaOwnerIn = $"and c.owner in ({string.Join(",", hasAreaSchools.Select(z => $"'{z.areaId}'"))})";
  957. schoolIdIn = $"and i.id in ({string.Join(",", hasAreaSchools.Select(z => $"'{z.schoolId}'"))})";
  958. }
  959. //获取所有区级的
  960. if (!string.IsNullOrWhiteSpace(areaOwnerIn) && !string.IsNullOrEmpty(schoolIdIn))
  961. {
  962. string sqlOpen = $"select value c from c join i in c.confirmedSchools where c.scope='area' and c.joinMode='enroll' and (c.publish=1 or c.publish=2 ) and i.status=1 {yearSql} {areaOwnerIn} {schoolIdIn} ";
  963. var resultOpen = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<TeacherActivityDto>(sqlOpen, "Activity");
  964. activities.AddRange(resultOpen.list);
  965. }
  966. //获取所有学校的
  967. if (!string.IsNullOrWhiteSpace(schoolOwnerIn))
  968. {
  969. string sqlSchool = $"select value c from c where c.scope='school' and c.joinMode='enroll' and (c.publish=1 or c.publish=2 ) {yearSql} {schoolOwnerIn} ";
  970. var resultSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<TeacherActivityDto>(sqlSchool, "Activity");
  971. activities.AddRange(resultSchool.list);
  972. }
  973. long now=DateTimeOffset.Now.ToUnixTimeMilliseconds();
  974. activities.ForEach(z =>
  975. {
  976. var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS(z.owner, BlobContainerSasPermissions.Read);
  977. z.sas=blob_sas;
  978. z.url=blob_uri;
  979. if (z.etime<now)
  980. {
  981. z.publish=2;
  982. }
  983. });
  984. if (activities.IsNotEmpty())
  985. {
  986. string sql = $"select value c from c where c.pk='ActivityEnroll' and contains(c.code,'ActivityEnroll-') and c.id='{tmdid}' and c.activityId in ({string.Join(",", activities.Select(z => $"'{z.id}'"))})";
  987. var resultEnroll = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(sql);
  988. foreach (var enroll in resultEnroll.list)
  989. {
  990. var activityDto = activities.Find(z => z.id.Equals(enroll.activityId));
  991. if (activityDto!=null)
  992. {
  993. if (enroll.contest!=null && enroll.contest.enrollTime>0)
  994. {
  995. activityDto.contestSign=1;
  996. activityDto.signTime=enroll.contest.enrollTime;
  997. activityDto.contestType=enroll.contest.type;
  998. }
  999. //if (enroll.upload!=null && (enroll.upload.files.IsNotEmpty() || enroll.upload.sokrates.IsNotEmpty() || enroll.upload.lessons.IsNotEmpty()) )
  1000. //{
  1001. // activityDto.contestUpload=1;
  1002. // activityDto.uploadTime=enroll.upload.uploadTime;
  1003. // activityDto.uploadType=enroll.upload.type;
  1004. //}
  1005. if (enroll.upload!=null &&enroll.upload.complexes.IsNotEmpty())
  1006. {
  1007. activityDto.contestUpload=1;
  1008. activityDto.uploadTime=enroll.upload.uploadTime;
  1009. activityDto.uploadTypes=enroll.upload.uploadType;
  1010. }
  1011. }
  1012. }
  1013. }
  1014. return activities;
  1015. }
  1016. public static async Task<(ReviewRule reviewRule, int invalidCode, string msg)> UpsertReviewRule(ReviewRuleTree reviewRuleTree,Activity activity, Contest contest, AzureCosmosFactory _azureCosmos)
  1017. {
  1018. var nodes = new List<RuleConfig>();
  1019. nodes= TreeToList(reviewRuleTree.trees, nodes);
  1020. ReviewRule reviewRule = new ReviewRule() {
  1021. id= activity.id,
  1022. code="ReviewRule-disposable",
  1023. pk="ReviewRule",
  1024. name=reviewRuleTree.name,
  1025. desc=reviewRuleTree.desc,
  1026. owner=activity.owner,
  1027. type="disposable",
  1028. configs=nodes,
  1029. sourceName=activity.name,
  1030. taskCount=reviewRuleTree.taskCount,
  1031. scoreRule=reviewRuleTree.scoreRule,
  1032. distribute=reviewRuleTree.distribute,
  1033. scoreDetail=reviewRuleTree.scoreDetail,
  1034. };
  1035. //代码顺序不能动
  1036. var checkReult = CheckReviewRule(reviewRule, contest);
  1037. if (checkReult.invalidCode==200) {
  1038. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).UpsertItemAsync(reviewRule, new Azure.Cosmos.PartitionKey(reviewRule.code));
  1039. if (reviewRuleTree.upsertAsTemplate==1)
  1040. {
  1041. reviewRule.code="ReviewRule-template";
  1042. reviewRule.type="template";
  1043. reviewRule.taskCount = reviewRuleTree.taskCount;
  1044. reviewRule.scoreRule = reviewRuleTree.scoreRule;
  1045. reviewRule.distribute = reviewRuleTree.distribute;
  1046. reviewRule.scoreDetail = reviewRuleTree.scoreDetail;
  1047. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).UpsertItemAsync(reviewRule, new Azure.Cosmos.PartitionKey(reviewRule.code));
  1048. }
  1049. }
  1050. return (reviewRule,checkReult.invalidCode,checkReult.msg);
  1051. }
  1052. public static (int invalidCode, string msg) CheckReviewRule(ReviewRule reviewRule,Contest contest)
  1053. {
  1054. int invalidCode = -1;
  1055. string msg = "";
  1056. if (reviewRule.taskCount<=0) {
  1057. invalidCode=28;
  1058. msg="作品分配次数至少一次!";
  1059. }
  1060. if (reviewRule.taskCount==1 )
  1061. {
  1062. if (reviewRule.scoreRule.Equals("only"))
  1063. {
  1064. invalidCode=200;
  1065. }
  1066. else
  1067. {
  1068. invalidCode=21;//分配次数一次,必须匹配only
  1069. msg="分配次数1次,必须匹配【默认统分】规则";
  1070. }
  1071. }
  1072. if (reviewRule.taskCount>=2 )
  1073. {
  1074. if ((reviewRule.scoreRule.Equals("avg")||reviewRule.scoreRule.Equals("top"))) {
  1075. invalidCode=200;
  1076. }
  1077. else
  1078. {
  1079. invalidCode=22;//分配次数2次,必须匹配avg,top
  1080. msg="分配次数2次,必须匹配【按平均分】,【按最高分】";
  1081. }
  1082. }
  1083. if (reviewRule.taskCount>=3 )
  1084. {if ((reviewRule.scoreRule.Equals("avg")||reviewRule.scoreRule.Equals("top")||reviewRule.scoreRule.Equals("rmLowAvg")||reviewRule.scoreRule.Equals("rmTopAvg")))
  1085. {
  1086. invalidCode=200;
  1087. }
  1088. else
  1089. {
  1090. invalidCode=23;//分配次数2次,必须匹配avg,top,rmLowAvg,rmTopAvg
  1091. msg="分配次数3次,必须匹配必须匹配【按平均分】,【按最高分】,【去掉最低分的平均分】,【去掉最高分的平均分】";
  1092. }
  1093. }
  1094. if (reviewRule.taskCount>=4 )
  1095. {
  1096. if ((reviewRule.scoreRule.Equals("avg")||reviewRule.scoreRule.Equals("top")||reviewRule.scoreRule.Equals("rmLowAvg")||reviewRule.scoreRule.Equals("rmTopAvg")||reviewRule.scoreRule.Equals("rmLowTopAvg")))
  1097. {
  1098. invalidCode=200;
  1099. }
  1100. else
  1101. {
  1102. invalidCode=24;//分配次数2次,必须匹配avg,top,rmLowAvg,rmTopAvg,rmLowTopAvg
  1103. msg="分配次数4次,必须匹配必须匹配【按平均分】,【按最高分】,【去掉最低分的平均分】,【去掉最高分的平均分】,【去掉最高分和最低分的平均分】";
  1104. }
  1105. }
  1106. if (invalidCode==200) {
  1107. if (!string.IsNullOrWhiteSpace(reviewRule.distribute))
  1108. {
  1109. if (reviewRule.distribute.Equals("period"))
  1110. {
  1111. var period = contest.sign?.fields?.Find(z => z.field.Equals("period"));
  1112. if (period!= null)
  1113. {
  1114. invalidCode = 200;
  1115. }
  1116. else
  1117. {
  1118. invalidCode=25;
  1119. msg="作品分配匹配规则为【学段】,但报名填写表单未配置。";
  1120. }
  1121. }
  1122. else if (reviewRule.distribute.Equals("subject"))
  1123. {
  1124. var subject = contest.sign?.fields?.Find(z => z.field.Equals("subject"));
  1125. if (subject!= null)
  1126. {
  1127. invalidCode = 200;
  1128. }
  1129. else
  1130. {
  1131. invalidCode=26;
  1132. msg="作品分配匹配规则为【学科】,但报名填写表单未配置。";
  1133. }
  1134. }
  1135. else if (reviewRule.distribute.Equals("periodAndSubject"))
  1136. {
  1137. var period = contest.sign?.fields?.Find(z => z.field.Equals("period"));
  1138. var subject = contest.sign?.fields?.Find(z => z.field.Equals("subject"));
  1139. if (subject!= null && period!= null)
  1140. {
  1141. invalidCode = 200;
  1142. }
  1143. else
  1144. {
  1145. invalidCode=27;
  1146. msg="作品分配匹配规则为【学段,学科】,但报名填写表单未配置。";
  1147. }
  1148. }
  1149. else if (reviewRule.distribute.Equals("none"))
  1150. {
  1151. invalidCode=200;
  1152. }
  1153. else
  1154. {
  1155. invalidCode=30;
  1156. msg=$"作品分配匹配规则未识别【{reviewRule.distribute}】。";
  1157. }
  1158. }
  1159. else {
  1160. invalidCode=29;
  1161. msg="作品分配匹配规则不能为空。";
  1162. }
  1163. }
  1164. return (invalidCode,msg);
  1165. }
  1166. public static List<RuleConfig> TreeToList(List<RuleConfigTree> trees, List<RuleConfig> nodes) {
  1167. trees = trees.OrderBy(x => x.order).ToList();
  1168. List<RuleConfig> list = new List<RuleConfig>();
  1169. trees.ForEach(x => {
  1170. List<string> cids = new List<string>();
  1171. if (x.children.IsNotEmpty())
  1172. {
  1173. x.children.ForEach(y => cids.Add(y.id));
  1174. }
  1175. var node = new RuleConfig
  1176. {
  1177. id = x.id,
  1178. pid = x.pid,
  1179. cids= cids,
  1180. label = x.label,
  1181. desc = x.desc,
  1182. score = x.score,
  1183. order = x.order,
  1184. };
  1185. list.Add(node);
  1186. });
  1187. nodes.AddRange(list);
  1188. foreach (RuleConfigTree tree in trees)
  1189. {
  1190. if (null != tree.children && tree.children.Count > 0)
  1191. {
  1192. TreeToList(tree.children, nodes);
  1193. }
  1194. }
  1195. return nodes;
  1196. }
  1197. public static List<RuleConfigTree> ListToTree(List<RuleConfig> noes)
  1198. {
  1199. List<RuleConfigTree> list = noes.ToJsonString().ToObject<List<RuleConfigTree>>();
  1200. var res = from r in list group r by r.id into g select g;
  1201. Dictionary<string, RuleConfigTree> blockDict = new Dictionary<string, RuleConfigTree>();
  1202. foreach (var s in res)
  1203. {
  1204. blockDict.TryAdd(s.First().id, s.First());
  1205. }
  1206. return GetChild(list, blockDict);
  1207. }
  1208. private static List<RuleConfigTree> GetChild(List<RuleConfigTree> list, Dictionary<string, RuleConfigTree> dict)
  1209. {
  1210. List<RuleConfigTree> trees = new List<RuleConfigTree>();
  1211. trees = trees.OrderBy(x => x.order).ToList();
  1212. foreach (RuleConfigTree node in list)
  1213. {
  1214. bool flag = dict.TryGetValue(node.pid, out RuleConfigTree syllabus);
  1215. if (flag && syllabus != null)
  1216. {
  1217. syllabus.children.Add(node);
  1218. }
  1219. else
  1220. {
  1221. trees.Add(node);
  1222. }
  1223. }
  1224. return trees;
  1225. }
  1226. }
  1227. }