12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055 |
- using Azure.Cosmos;
- using Azure.Storage.Blobs.Models;
- using Azure.Storage.Sas;
- using DocumentFormat.OpenXml.Bibliography;
- using DocumentFormat.OpenXml.Drawing;
- using DocumentFormat.OpenXml.Drawing.Charts;
- using DocumentFormat.OpenXml.Math;
- using DocumentFormat.OpenXml.Spreadsheet;
- using DocumentFormat.OpenXml.Wordprocessing;
- using HTEXLib.COMM.Helpers;
- using System;
- using System.Collections.Generic;
- using System.Diagnostics;
- using System.Linq;
- using System.Text;
- using System.Text.Json;
- using System.Threading.Tasks;
- using TEAMModelOS.SDK.DI;
- using TEAMModelOS.SDK.Extension;
- using TEAMModelOS.SDK.Models;
- using TEAMModelOS.Services;
- using Activity = TEAMModelOS.SDK.Models.Activity;
- namespace TEAMModelOS.SDK
- {
- public static class ActivityService
- {
- /*
- /// <summary>
- /// 分配作品
- /// </summary>
- /// <param name="_azureCosmos"></param>
- /// <param name="activity"></param>
- /// <returns></returns>
- public static async Task<(List<ExpertContestTaskDto> expertContestTasks, List<ExpertContestTaskDto > activityEnrollsInvalid, List<ExpertContestTaskDto> expertContestTasksDB)> AllocationTask(AzureCosmosFactory _azureCosmos, IEnumerable<ExpertPeriodSubjectDto> experts, Contest activity,HashSet<string> periodSubjectKeys,string distribute, int taskCount)
- {
- //检查报名,学段和科目是否匹配
- string enrollSQL = "select value c from c where c.pk='ActivityEnroll'";
- var resultActivityEnroll= await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(enrollSQL, $"ActivityEnroll-{activity.id}");
- List<ExpertContestTaskDto > activityEnrollsInvalid = new List<ExpertContestTaskDto>();
- Dictionary<string, List<ActivityEnroll>> uploads = new Dictionary<string, List<ActivityEnroll>>();
- foreach (ActivityEnroll enroll in resultActivityEnroll.list)
- {
- var period = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("period"));
- var subject = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("subject"));
- string periodSubjectKey =string.Empty;
- int count = 0;
- if (enroll.upload != null && enroll.upload.sokrates.IsNotEmpty())
- {
- count += enroll.upload.sokrates.Count;
- }
- if (enroll.upload != null && enroll.upload.files.IsNotEmpty())
- {
- count += enroll.upload.files.Count;
- }
- //学段学科不匹配
- var taskDto = new ExpertContestTaskDto
- {
- uploadId = enroll.upload?.uploadId,
- name = $"{enroll?.schoolName}-{enroll?.tmdName}",
- uploadTypes = new List<string> { enroll?.upload.type },
- count = count,
- cipher = enroll.contest?.cipher,
- type = enroll.contest != null ? enroll.contest.type : 0,
- leader = enroll.contest != null ? enroll.contest.type : 0,
- tmdid = enroll.id,
- status = -1,
- score = -1,
- //detailScore=new List<RuleConfig>()
- members = new List<IdNameCode>(),
- periodSubjectKey = periodSubjectKey,
- period = period?.val,
- subject = subject?.val,
-
- };
- if (distribute.Equals("period"))
- {
- if (period != null)
- {
- periodSubjectKey = $"{period.val}-";
- }
- else {
- taskDto.available = 2;
- activityEnrollsInvalid.Add(taskDto);
- break;
- }
- }
- else if (distribute.Equals("subject"))
- {
-
- if (subject != null)
- {
- periodSubjectKey = $"-{subject.val}";
- }
- else {
- taskDto.available = 3;
- activityEnrollsInvalid.Add(taskDto);
- break;
- }
- }
- else if (distribute.Equals("periodAndSubject"))
- {
-
- if (period != null && subject != null)
- {
- periodSubjectKey = $"{period.val}-{subject.val}";
- }
- else {
- taskDto.available = 4;
- activityEnrollsInvalid.Add(taskDto);
- break;
- }
- }
- //else if (distribute.Equals("none"))
- //{
-
- //}
- else {
- periodSubjectKey = "-";
- }
-
- if (periodSubjectKeys.Contains(periodSubjectKey))
- {
- if (!string.IsNullOrWhiteSpace(enroll.upload?.uploadId))
- {
- if (uploads.ContainsKey(enroll.upload.uploadId))
- {
- uploads[enroll.upload.uploadId].Add(enroll);
- }
- else
- {
- uploads[enroll.upload.uploadId]= new List<ActivityEnroll>() { enroll};
- }
- }
- else {
- taskDto.available = 5;
- activityEnrollsInvalid.Add(taskDto);
- //未上传作品
- //activityEnrollsInvalid.Add((enroll, 2));
- }
- }
- else {
- taskDto.available =6;
- activityEnrollsInvalid.Add(taskDto);
- //学段学科不匹配
- //activityEnrollsInvalid.Add((enroll, 1));
- }
- }
- List<ExpertContestTaskDto> expertContestTasks = new List<ExpertContestTaskDto>();
- List<ExpertContestTaskDto> expertContestTasksDB = new List<ExpertContestTaskDto>();
- foreach (var upload in uploads.Keys)
- {
-
- var team = uploads[upload].FindAll(z => z.contest?.type==1);
- if (team.IsNotEmpty())
- {
- var leader = team.FindAll(z => z.contest?.leader==1);
- //有队长,说明是作品是一个人的队伍的作品。或者是由队长统一上传的作品。
- if (leader.IsNotEmpty())
- {
- 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();
- //队长的报名信息
- var enroll = leader?.First();
- if (enroll!= null)
- {
- string name = enroll.contest?.teamName;
- var period = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("period"));
- var subject = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("subject"));
- string periodSubjectKey = $"{period?.val}-{subject?.val}";
- if (string.IsNullOrEmpty(name))
- {
- name=$"{enroll.contest?.enrollInfos?.Find(z => z.code.Equals("name"))?.val}({team.Count})";
- }
- int count = 0;
- if (enroll.upload.sokrates.IsNotEmpty())
- {
- count+=enroll.upload.sokrates.Count;
- }
- if (enroll.upload.files.IsNotEmpty())
- {
- count+=enroll.upload.files.Count;
- }
- expertContestTasks.Add(new ExpertContestTaskDto
- {
- uploadId = upload,
- name = $"{uploads[upload].First()?.schoolName}-{name}",
- uploadTypes = new List<string> { enroll?.upload.type },
- count = count,
- cipher = enroll.contest?.cipher,
- type = 1,
- leader = 1,
- tmdid = enroll.id,
- status = -1,
- score = -1,
- //detailScore=new List<RuleConfig>()
- members = members,
- periodSubjectKey = periodSubjectKey,
- period = period?.val,
- subject = subject?.val
- }) ;
- }
- }
- //没有队长,则是队员上传的作品(队员自己上传,不是队长统一上传的)、
- else {
- if (team.Count==1) {
- var enroll = team?.First();
- if (enroll!= null)
- {
- var period = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("period"));
- var subject = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("subject"));
- string periodSubjectKey = $"{period?.val}-{subject?.val}";
- string name = enroll.contest?.teamName;
- if (string.IsNullOrEmpty(name))
- {
- name=$"{enroll.contest?.enrollInfos?.Find(z => z.code.Equals("name"))?.val}({team.Count})";
- }
- int count = 0;
- if (enroll.upload.sokrates.IsNotEmpty())
- {
- count+=enroll.upload.sokrates.Count;
- }
- if (enroll.upload.files.IsNotEmpty())
- {
- count+=enroll.upload.files.Count;
- }
- expertContestTasks.Add(new ExpertContestTaskDto
- {
- uploadId = upload,
- name=$"{uploads[upload].First()?.schoolName}-{name}",
- uploadTypes=new List<string> { enroll?.upload.type },
- count=count,
- cipher=enroll.contest?.cipher,
- type=1,
- leader=0,
- tmdid=enroll.id,
- status=-1,
- score=-1,
- //detailScore=new List<RuleConfig>()
- // members= new List<IdNameCode>()
- periodSubjectKey=periodSubjectKey,
- period = period?.val,
- subject = subject?.val
- }) ;
- }
- }
- }
- }
- else {
- //个人
- var enroll = uploads[upload]?.First();
- if (enroll!= null) {
- var period = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("period"));
- var subject = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("subject"));
- string periodSubjectKey = $"{period?.val}-{subject?.val}";
- string name = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("name"))?.val;
- if (!string.IsNullOrEmpty(name))
- {
- name=$"({name})";
- }
- else
- {
- name=string.Empty;
- }
- int count = 0;
- if (enroll.upload.sokrates.IsNotEmpty()) {
- count+=enroll.upload.sokrates.Count;
- }
- if (enroll.upload.files.IsNotEmpty())
- {
- count+=enroll.upload.files.Count;
- }
- expertContestTasks.Add(new ExpertContestTaskDto
- {
- uploadId = upload,
- name=$"{uploads[upload].First()?.schoolName}-{uploads[upload].First()?.tmdName}{name}",
- uploadTypes=new List<string> { enroll?.upload.type },
- count=count,
- cipher=null,
- type=0,
- leader=-1,
- tmdid=enroll.id,
- status=-1,
- score=-1,
- //detailScore=new List<RuleConfig>()
- //members= new List<IdNameCode>()
- periodSubjectKey=periodSubjectKey,
- period = period?.val,
- subject = subject?.val
- });
- }
- }
- }
- if (expertContestTasks.IsNotEmpty() && experts!=null && experts.Count()>0 && taskCount > 0) {
- string taskSQL = $"select value c from c where c.pk='ActivityExpertTask'";
- List<ExpertContestTaskDto> worksDB= new List<ExpertContestTaskDto>();
- var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpertTask>(taskSQL, $"ActivityExpertTask-{activity.id}") ;
- if (result.list.IsNotEmpty()) {
- foreach(var item in result.list)
- {
- worksDB.AddRange(item.contestTasks.Select(z =>
- new ExpertContestTaskDto
- {
- expertId = item.id,
- available = 1,
- uploadId = z.uploadId,
- name = z.name,
- uploadTypes = z.uploadTypes,
- count = z.count,
- cipher=z.cipher,type=z.type,
- leader=z.leader,members=z.members,
- tmdid=z.tmdid,
- score=z.score,
- status=z.status,
- detailScore=z.detailScore
- }));
- }
- }
- var data = AssignWorksToExperts(expertContestTasks, worksDB, experts, taskCount);
- expertContestTasks = data.assignmentsAdd;
- expertContestTasksDB = worksDB;
- activityEnrollsInvalid.AddRange(data.assignmentsInvalid);
- }
- return (expertContestTasks, activityEnrollsInvalid, expertContestTasksDB);
- }
- */
- public static async Task<(List<ExpertContestTaskDto> expertContestTasks, List<ExpertContestTaskDto> activityEnrollsInvalid, List<ExpertContestTaskDto> expertContestTasksDB)>
- AllocationTask(AzureCosmosFactory _azureCosmos, IEnumerable<ExpertPeriodSubjectDto> experts, Contest contest, HashSet<string> periodSubjectKeys, string distribute, int taskCount)
- {
- //先获取已经分配完成的
- List<ExpertContestTaskDto> worksDB = new List<ExpertContestTaskDto>();
- IEnumerable<ExpertContestTaskDto> complete = new List<ExpertContestTaskDto>();
- string taskSQL = $"select value c from c where c.pk='ActivityExpertTask'";
- var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpertTask>(taskSQL, $"ActivityExpertTask-{contest.id}");
- if (result.list.IsNotEmpty())
- {
- foreach (var item in result.list)
- {
- worksDB.AddRange(item.contestTasks.Select(z =>
- new ExpertContestTaskDto
- {
- expertId = item.id,
- available = 1,
- uploadId = z.uploadId,
- name = z.name,
- uploadTypes = z.uploadTypes,
- count = z.count,
- cipher=z.cipher,
- type=z.type,
- leader=z.leader,
- members=z.members,
- tmdid=z.tmdid,
- score=z.score,
- status=z.status,
- detailScore=z.detailScore
- }));
- }
- //处理已经分配完成(taskCount)的作品
- complete = worksDB.GroupBy(task => task.uploadId).Where(group => group.Count() >= taskCount).SelectMany(group => group);
- }
- string enrollSQL = "select value c from c where c.pk='ActivityEnroll'";
- //已经满足分配的无需再去处理检查。
- if (complete!=null && complete.Count()>0)
- {
- var uploadIds = complete.Select(z => z.uploadId).ToHashSet();
- enrollSQL =$"{enrollSQL} where c.upload.uploadId not in ({string.Join(",", uploadIds.Select(z => $"'{z}'"))})";
- }
- //检查报名,学段和科目是否匹配
- var resultActivityEnroll = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(enrollSQL, $"ActivityEnroll-{contest.id}");
- List<ExpertContestTaskDto> expertContestTasks = new List<ExpertContestTaskDto>();
- foreach (ActivityEnroll enroll in resultActivityEnroll.list)
- {
- //如果是队长统一上传
- if (contest.upload.captainUpload == 1 && !string.IsNullOrWhiteSpace(enroll.contest?.cipher))
- {
- var team = resultActivityEnroll.list.FindAll(z => z.contest != null && z.contest.type == 1 && enroll.contest?.type == 1 && z.contest.cipher.Equals(enroll.contest.cipher));
- //获取队长信息
- var leaders = team.FindAll(z => z.contest.leader == 1);
- if (leaders.IsNotEmpty())
- {
- leaders = new List<ActivityEnroll>() { enroll };
- }
- 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();
- //队长的报名信息
- var leader = leaders?.First();
- string name = leader.contest?.teamName;
- var period = leader.contest?.enrollInfos?.Find(z => z.code.Equals("period"));
- var subject = leader.contest?.enrollInfos?.Find(z => z.code.Equals("subject"));
- string uploadId = string.Empty;
- if (string.IsNullOrEmpty(name))
- {
- name = $"{leader.contest?.enrollInfos?.Find(z => z.code.Equals("name"))?.val}({team.Count})";
- }
- int count = 0;
- int available = -1;
- var checkResult = ActivityService.CheckPeriodSubject(distribute, period, subject, periodSubjectKeys);
- if (checkResult.available == 0)
- {
- if (leader.upload != null && leader.upload.sokrates.IsNotEmpty())
- {
- count += leader.upload.sokrates.Count;
- }
- if (leader.upload != null && leader.upload.files.IsNotEmpty())
- {
- count += leader.upload.files.Count;
- }
- if (count <= 0)
- {
- uploadId = enroll.contest.cipher;
- available = 5;
- }
- else
- {
- uploadId = leader.upload?.uploadId;
- available = checkResult.available;
- }
- }
- else
- {
- uploadId = enroll.contest.cipher;
- available = checkResult.available;
- }
- ExpertContestTaskDto expertContestTask = expertContestTasks.Find(z => !string.IsNullOrWhiteSpace(z.uploadId) && z.uploadId.Equals(leader.upload));
- if (expertContestTask == null)
- {
- expertContestTasks.Add(new ExpertContestTaskDto
- {
- uploadId = leader.upload?.uploadId,
- name = $"{leader.schoolName}-{name}",
- uploadTypes = new List<string> { leader?.upload.type },
- count = count,
- cipher = leader.contest?.cipher,
- type = 1,
- leader = 1,
- tmdid = leader.id,
- status = -1,
- score = -1,
- //detailScore=new List<RuleConfig>()
- members = members,
- periodSubjectKey = checkResult.periodSubjectKey,
- period = period?.val,
- subject = subject?.val,
- available = available
- });
- }
- else
- {
- expertContestTask.available = available;
- expertContestTask.name = name;
- expertContestTask.count = count;
- expertContestTask.members = members;
- expertContestTask.periodSubjectKey = checkResult.periodSubjectKey;
- }
- }
- else
- {
- //如果不是队长统一上传
- //学段
- var period = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("period"));
- //科目
- var subject = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("subject"));
- string periodSubjectKey = string.Empty;
- string name = enroll.contest?.enrollInfos?.Find(z => z.code.Equals("name"))?.val;
- string uploadId = string.Empty;
- if (!string.IsNullOrEmpty(name))
- {
- name = $"({name})";
- }
- else
- {
- name = string.Empty;
- }
- int count = 0;
- int available = -1;
- var checkResult = ActivityService.CheckPeriodSubject(distribute, period, subject, periodSubjectKeys);
- if (checkResult.available == 0)
- {
- if (enroll.upload != null && enroll.upload.sokrates.IsNotEmpty())
- {
- count += enroll.upload.sokrates.Count;
- }
- if (enroll.upload != null && enroll.upload.files.IsNotEmpty())
- {
- count += enroll.upload.files.Count;
- }
- if (count <= 0)
- {
- available = 5;
- uploadId = enroll.id;
- }
- else
- {
- available = checkResult.available;
- uploadId = enroll.upload.uploadId;
- }
- }
- else
- {
- uploadId = enroll.id;
- available = checkResult.available;
- }
- ExpertContestTaskDto expertContestTask = expertContestTasks.Find(z => !string.IsNullOrWhiteSpace(z.uploadId) && z.uploadId.Equals(enroll.upload));
- if (expertContestTask == null)
- {
- expertContestTasks.Add(new ExpertContestTaskDto
- {
- uploadId = uploadId,
- name = $"{enroll.schoolName}-{name}",
- uploadTypes = new List<string> { enroll.upload?.type },
- count = count,
- cipher = enroll.contest?.cipher,
- type = 1,
- leader = 1,
- tmdid = enroll.id,
- status = -1,
- score = -1,
- periodSubjectKey = checkResult.periodSubjectKey,
- period = period?.val,
- subject = subject?.val,
- available = available
- });
- }
- else
- {
- expertContestTask.available = available;
- expertContestTask.name = name;
- expertContestTask.count = count;
- expertContestTask.periodSubjectKey = checkResult.periodSubjectKey;
- }
- }
- }
- List<ExpertContestTaskDto> invalids = expertContestTasks.FindAll(z => z.available!=0);
- List<ExpertContestTaskDto> works = expertContestTasks.FindAll(z => z.available==0);
- var data = AssignWorksToExperts(works, worksDB, experts, taskCount);
- if (invalids.IsNotEmpty()) {
- invalids.AddRange(data.assignmentsInvalid);
- }
- return (data.assignmentsAdd, invalids, worksDB);
- }
- public static (int available, string periodSubjectKey) CheckPeriodSubject(string distribute , EnrollInfo period, EnrollInfo subject, HashSet<string> periodSubjectKeys) {
- int available = -1;
- string periodSubjectKey= string.Empty;
- if (distribute.Equals("period"))
- {
- if (period != null)
- {
- periodSubjectKey = $"{period.val}-";
- }
- else
- {
- available = 2;
- }
- }
- else if (distribute.Equals("subject"))
- {
- if (subject != null)
- {
- periodSubjectKey = $"-{subject.val}";
- }
- else
- {
- available = 3;
- }
- }
- else if (distribute.Equals("periodAndSubject"))
- {
- if (period != null && subject != null)
- {
- periodSubjectKey = $"{period.val}-{subject.val}";
- }
- else
- {
- available = 4;
- }
- }
- else
- {
- periodSubjectKey = "-";
- }
- if (!string.IsNullOrWhiteSpace(periodSubjectKey)) {
- if (periodSubjectKeys.Contains(periodSubjectKey))
- {
- available = 0;
- }
- else
- {
- //学段学科不匹配
- available = 6;
- }
- }
- return (available, periodSubjectKey);
- }
- /// <summary>
- /// 将作品按分配次数,分配给不同的专家
- /// </summary>
- /// <param name="works"></param>
- /// <param name="experts"></param>
- /// <param name="N"></param>
- /// <returns></returns>
- static (List<ExpertContestTaskDto> assignmentsAdd, List<ExpertContestTaskDto> assignmentsInvalid) AssignWorksToExperts(List<ExpertContestTaskDto> works,List<ExpertContestTaskDto> worksDB, IEnumerable<ExpertPeriodSubjectDto> experts, int N)
- {
- //增加的
- var assignmentsAdd = new List<ExpertContestTaskDto>();
- //未分配到的
- var assignmentsInvalid = new List<ExpertContestTaskDto>();
- var random = new Random();
- //用于处理数据库和新分配的结果中检查已经分配过的作品和专家
- var assignmentsAll = worksDB.ToJsonString().ToObject<List<ExpertContestTaskDto>>();
- foreach (var work in works)
- {
- for (int i = 0; i < N; i++)
- {
- //分配次数已经Ok,分配结果完善的,不需要再去处理
- if (assignmentsAll.Count(z => z.uploadId.Equals(work.uploadId))>=N) {
- continue;
- }
- var availableExperts = experts
- .OrderBy(expert => assignmentsAll.Count(a => a.expertId == expert.expertId))
- .Where(expert => expert.periodSubjects.Contains(work.periodSubjectKey) && !assignmentsAll.Any(a => a.uploadId == work.uploadId && a.expertId == expert.expertId))
- .ToList();
- if (availableExperts.Count > 0)
- {
- var selectedExpert = availableExperts[random.Next(availableExperts.Count)];
- var newWork= work.DeepCopy<ExpertContestTaskDto>();
- newWork.expertId = selectedExpert.expertId;
- newWork.available = 1;
- newWork.turn = i + 1;
- assignmentsAdd.Add(newWork);
- assignmentsAll.Add(newWork);
- }
- else
- {
- var newWork = work.DeepCopy<ExpertContestTaskDto>();
- newWork.expertId =null;
- newWork.available = 7;
- newWork.turn = i + 1;
- //作品在第几轮未匹配到
- assignmentsInvalid.Add(newWork);
- //Console.WriteLine($"No available expert for WorkId {work.uploadId} and subject {work.periodSubjectKey} in attempt {i + 1}.");
- break;
- }
- }
- }
- return (assignmentsAdd, assignmentsInvalid);
- }
- /// <summary>
- /// 删除活动关联的数据
- /// </summary>
- /// <param name="_azureCosmos"></param>
- /// <param name="activity"></param>
- /// <returns></returns>
- public static async Task DeleteActivityRelated(AzureCosmosFactory _azureCosmos,Activity activity)
- {
- //删除模块,Contest, Training ,Research, ReviewRule规则(ReviewRule-disposable"; 存为活动)
- await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).DeleteItemStreamAsync(activity.id, new PartitionKey("Contest"));
- await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).DeleteItemStreamAsync(activity.id, new PartitionKey("Training"));
- await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).DeleteItemStreamAsync(activity.id, new PartitionKey("Research"));
- await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).DeleteItemStreamAsync(activity.id, new PartitionKey("ReviewRule-disposable"));
- //删除邀请教师 ActivityTeacher,
- var resultTeacher = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
- .GetList<IdCode>("select c.id ,c.code from c where c.pk='ActivityEnroll' and c.", $"ActivityTeacher-{activity.id}");
- if (resultTeacher.list.IsNotEmpty())
- {
- await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).DeleteItemsStreamAsync(resultTeacher.list.Select(z => z.id).ToList(), $"ActivityTeacher-{activity.id}");
- }
- //删除报名数据 ActivityEnroll
- var resultEnroll = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
- .GetList<IdCode>("select c.id ,c.code from c where c.pk='ActivityEnroll' and c.", $"ActivityEnroll-{activity.id}");
- if (resultEnroll.list.IsNotEmpty())
- {
- await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).DeleteItemsStreamAsync(resultEnroll.list.Select(z => z.id).ToList(), $"ActivityEnroll-{activity.id}");
- }
- //删除专家数据 ActivityExpert
- await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).DeleteItemStreamAsync(activity.id, new PartitionKey("ActivityExpert"));
- }
- /// <summary>
- /// 生成组队口令
- /// </summary>
- /// <param name="client"></param>
- /// <param name="_dingDing"></param>
- /// <param name="_option"></param>
- /// <param name="_activityId"></param>
- /// <returns></returns>
- /// <exception cref="Exception"></exception>
- public static async Task<string> GenCipher(CosmosClient client, DingDing _dingDing, TEAMModelOS.Models.Option _option, string _activityId)
- {
- string _num09 = "123456789";
- string no = $"{Utils.CreatSaltString(7, _num09)}";
- for (int i = 0; i < 10; i++)
- {
- List<SheetConfig> sheets = new List<SheetConfig>();
- bool hasCurrFrom = false;
- 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}' ";
- var cipherResult = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<string>(cipherSQL, $"ActivityEnroll-{_activityId}");
- if (cipherResult.list.IsNotEmpty() && cipherResult.list.Count>0) {
- hasCurrFrom = true;
- }
- if (hasCurrFrom)
- {
- if (i == 9)
- {
- string msg = $"{_option.Location},ActivityService/GenCipher\n 组队口令生成异常,重复生成次数超过10次";
- await _dingDing.SendBotMsg($"OS,{_option.Location},{msg}", GroupNames.醍摩豆服務運維群組);
- throw new Exception(msg);
- }
- else
- {
- no = $"{Utils.CreatSaltString(7, _num09)}";
- }
- }
- else { break; }
- }
- return no;
- }
- public static async Task<List<TeacherActivityDto>> TeacherActivityList(AzureCosmosFactory _azureCosmos,AzureStorageFactory _azureStorage, JsonElement request, string tmdid)
- {
- List<TeacherActivityDto> activities = new List<TeacherActivityDto>();
- HashSet<string> inviteActivityIds = new HashSet<string>();
- string yearSql = $" and c.year={DateTimeOffset.Now.Year}";
- if (request.TryGetProperty("year", out JsonElement _year) && int.TryParse($"{_year}",out int year ))
- {
- yearSql = $" and c.year={year}";
- }
- //先获取邀请制的
- string sqlInvite = $"select value c from c join t in c.inviteTeachers where t.id='{tmdid}' and c.pk='ActivityTeacher'";
- var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityTeacher>(sqlInvite);
- inviteActivityIds= result.list.Select(z => z.id).ToHashSet();
- if (inviteActivityIds.Count>0)
- {
- string sqlActivity = $"select value c from c where c.id in ({string.Join(",", inviteActivityIds.Select(z => $"'{z}'"))}) {yearSql} ";
- var resultActivity = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<TeacherActivityDto>(sqlInvite, "Activity");
- if (resultActivity.list.IsNotEmpty())
- {
- activities.AddRange(resultActivity.list);
- }
- }
- Teacher teacher = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemAsync<Teacher>(tmdid, new PartitionKey("Base"));
- string schoolOwnerIn = string.Empty;
- string schoolIdIn = string.Empty;
- if (teacher.schools.IsNotEmpty())
- {
- schoolIdIn = $"and i.id in ({string.Join(",", teacher.schools.Select(z => $"'{z.schoolId}'"))})";
- schoolOwnerIn= $"and c.owner in ({string.Join(",", teacher.schools.Select(z => $"'{z.schoolId}'"))})";
- }
- //获取开放的
- {
- //完全开放 所有的学校
- 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} ";
- var resultOpen = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<TeacherActivityDto>(sqlOpen, "Activity");
- activities.AddRange(resultOpen.list);
- if (!string.IsNullOrWhiteSpace(schoolIdIn))
- { //部分学校
- 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} ";
- var resultSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<TeacherActivityDto>(sqlSchool, "Activity");
- activities.AddRange(resultSchool.list);
- }
- }
- string areaOwnerIn = string.Empty;
- var hasAreaSchools = teacher.schools.FindAll(z => !string.IsNullOrWhiteSpace(z.areaId));
- if (hasAreaSchools.IsNotEmpty())
- {
- areaOwnerIn = $"and c.owner in ({string.Join(",", hasAreaSchools.Select(z => $"'{z.areaId}'"))})";
- schoolIdIn = $"and i.id in ({string.Join(",", hasAreaSchools.Select(z => $"'{z.schoolId}'"))})";
- }
- //获取所有区级的
- if (!string.IsNullOrWhiteSpace(areaOwnerIn) && !string.IsNullOrEmpty(schoolIdIn))
- {
- 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} ";
- var resultOpen = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<TeacherActivityDto>(sqlOpen, "Activity");
- activities.AddRange(resultOpen.list);
- }
- //获取所有学校的
- if (!string.IsNullOrWhiteSpace(schoolOwnerIn))
- {
- 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} ";
- var resultSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<TeacherActivityDto>(sqlSchool, "Activity");
- activities.AddRange(resultSchool.list);
- }
- activities.ForEach(z =>
- {
- var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS(z.owner, BlobContainerSasPermissions.Read);
- z.sas=blob_sas;
- });
- if (activities.IsNotEmpty())
- {
- 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}'"))})";
- var resultEnroll = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(sql);
- foreach (var enroll in resultEnroll.list)
- {
- var activityDto = activities.Find(z => z.id.Equals(enroll.activityId));
- if (activityDto!=null)
- {
- if (enroll.contest!=null && !string.IsNullOrWhiteSpace(enroll.contest.cipher))
- {
- activityDto.contestSign=1;
- activityDto.signTime=enroll.contest.enrollTime;
- activityDto.contestType=enroll.contest.type;
- }
- if (enroll.upload!=null && (enroll.upload.files.IsNotEmpty() || enroll.upload.sokrates.IsNotEmpty()))
- {
- activityDto.contestUpload=1;
- activityDto.uploadTime=enroll.upload.uploadTime;
- activityDto.uploadType=enroll.upload.type;
- }
- }
- }
- }
- return activities;
- }
- public static async Task<(ReviewRule reviewRule, int invalidCode, string msg)> UpsertReviewRule(ReviewRuleTree reviewRuleTree,Activity activity, Contest contest, AzureCosmosFactory _azureCosmos)
- {
- var nodes = new List<RuleConfig>();
- nodes= TreeToList(reviewRuleTree.trees, nodes);
- ReviewRule reviewRule = new ReviewRule() {
- id= activity.id,
- code="ReviewRule-disposable",
- pk="ReviewRule",
- name=reviewRuleTree.name,
- desc=reviewRuleTree.desc,
- owner=activity.owner,
- type="disposable",
- configs=nodes,
- sourceName=activity.name,
- taskCount=reviewRuleTree.taskCount,
- scoreRule=reviewRuleTree.scoreRule,
- distribute=reviewRuleTree.distribute,
- scoreDetail=reviewRuleTree.scoreDetail,
- };
- //代码顺序不能动
- var checkReult = CheckReviewRule(reviewRule, contest);
- if (checkReult.invalidCode==200) {
- await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).UpsertItemAsync(reviewRule, new Azure.Cosmos.PartitionKey(reviewRule.code));
- if (reviewRuleTree.upsertAsTemplate==1)
- {
- reviewRule.code="ReviewRule-template";
- reviewRule.type="template";
- reviewRule.taskCount = reviewRuleTree.taskCount;
- reviewRule.scoreRule = reviewRuleTree.scoreRule;
- reviewRule.distribute = reviewRuleTree.distribute;
- reviewRule.scoreDetail = reviewRuleTree.scoreDetail;
- await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).UpsertItemAsync(reviewRule, new Azure.Cosmos.PartitionKey(reviewRule.code));
- }
- }
- return (reviewRule,checkReult.invalidCode,checkReult.msg);
- }
- public static (int invalidCode, string msg) CheckReviewRule(ReviewRule reviewRule,Contest contest)
- {
- int invalidCode = -1;
- string msg = "";
- if (reviewRule.taskCount<=0) {
- invalidCode=28;
- msg="作品分配次数至少一次!";
- }
- if (reviewRule.taskCount==1 )
- {
- if (reviewRule.scoreRule.Equals("only"))
- {
- invalidCode=200;
- }
- else
- {
- invalidCode=21;//分配次数一次,必须匹配only
- msg="分配次数1次,必须匹配【默认统分】规则";
- }
- }
-
- if (reviewRule.taskCount>=2 )
- {
- if ((reviewRule.scoreRule.Equals("avg")||reviewRule.scoreRule.Equals("top"))) {
- invalidCode=200;
- }
- else
- {
- invalidCode=22;//分配次数2次,必须匹配avg,top
- msg="分配次数2次,必须匹配【按平均分】,【按最高分】";
- }
- }
-
- if (reviewRule.taskCount>=3 )
- {if ((reviewRule.scoreRule.Equals("avg")||reviewRule.scoreRule.Equals("top")||reviewRule.scoreRule.Equals("rmLowAvg")||reviewRule.scoreRule.Equals("rmTopAvg")))
- {
- invalidCode=200;
- }
- else
- {
- invalidCode=23;//分配次数2次,必须匹配avg,top,rmLowAvg,rmTopAvg
- msg="分配次数3次,必须匹配必须匹配【按平均分】,【按最高分】,【去掉最低分的平均分】,【去掉最高分的平均分】";
- }
- }
-
- if (reviewRule.taskCount>=4 )
- {
- if ((reviewRule.scoreRule.Equals("avg")||reviewRule.scoreRule.Equals("top")||reviewRule.scoreRule.Equals("rmLowAvg")||reviewRule.scoreRule.Equals("rmTopAvg")||reviewRule.scoreRule.Equals("rmLowTopAvg")))
- {
- invalidCode=200;
- }
- else
- {
- invalidCode=24;//分配次数2次,必须匹配avg,top,rmLowAvg,rmTopAvg,rmLowTopAvg
- msg="分配次数4次,必须匹配必须匹配【按平均分】,【按最高分】,【去掉最低分的平均分】,【去掉最高分的平均分】,【去掉最高分和最低分的平均分】";
- }
- }
- if (invalidCode==200) {
- if (!string.IsNullOrWhiteSpace(reviewRule.distribute))
- {
- if (reviewRule.distribute.Equals("period"))
- {
- var period = contest.sign?.fields?.Find(z => z.field.Equals("period"));
- if (period!= null)
- {
- invalidCode = 200;
- }
- else
- {
- invalidCode=25;
- msg="作品分配匹配规则为【学段】,但报名填写表单未配置。";
- }
- }
- else if (reviewRule.distribute.Equals("subject"))
- {
- var subject = contest.sign?.fields?.Find(z => z.field.Equals("subject"));
- if (subject!= null)
- {
- invalidCode = 200;
- }
- else
- {
- invalidCode=26;
- msg="作品分配匹配规则为【学科】,但报名填写表单未配置。";
- }
- }
- else if (reviewRule.distribute.Equals("periodAndSubject"))
- {
- var period = contest.sign?.fields?.Find(z => z.field.Equals("period"));
- var subject = contest.sign?.fields?.Find(z => z.field.Equals("subject"));
- if (subject!= null && period!= null)
- {
- invalidCode = 200;
- }
- else
- {
- invalidCode=27;
- msg="作品分配匹配规则为【学段,学科】,但报名填写表单未配置。";
- }
- }
- else if (reviewRule.distribute.Equals("none"))
- {
- invalidCode=200;
- }
- else
- {
- invalidCode=30;
- msg=$"作品分配匹配规则未识别【{reviewRule.distribute}】。";
- }
- }
- else {
- invalidCode=29;
- msg="作品分配匹配规则不能为空。";
- }
-
- }
- return (invalidCode,msg);
- }
- public static List<RuleConfig> TreeToList(List<RuleConfigTree> trees, List<RuleConfig> nodes) {
- trees = trees.OrderBy(x => x.order).ToList();
- List<RuleConfig> list = new List<RuleConfig>();
- trees.ForEach(x => {
- List<string> cids = new List<string>();
- if (x.children.IsNotEmpty())
- {
- x.children.ForEach(y => cids.Add(y.id));
- }
- var node = new RuleConfig
- {
-
- id = x.id,
- pid = x.pid,
- cids= cids,
- label = x.label,
- desc = x.desc,
- score = x.score,
- order = x.order,
- };
- list.Add(node);
- });
- nodes.AddRange(list);
- foreach (RuleConfigTree tree in trees)
- {
- if (null != tree.children && tree.children.Count > 0)
- {
- TreeToList(tree.children, nodes);
- }
- }
- return nodes;
- }
- public static List<RuleConfigTree> ListToTree(List<RuleConfig> noes)
- {
- List<RuleConfigTree> list = noes.ToJsonString().ToObject<List<RuleConfigTree>>();
- var res = from r in list group r by r.id into g select g;
- Dictionary<string, RuleConfigTree> blockDict = new Dictionary<string, RuleConfigTree>();
- foreach (var s in res)
- {
- blockDict.TryAdd(s.First().id, s.First());
- }
- return GetChild(list, blockDict);
- }
- private static List<RuleConfigTree> GetChild(List<RuleConfigTree> list, Dictionary<string, RuleConfigTree> dict)
- {
- List<RuleConfigTree> trees = new List<RuleConfigTree>();
- trees = trees.OrderBy(x => x.order).ToList();
- foreach (RuleConfigTree node in list)
- {
- bool flag = dict.TryGetValue(node.pid, out RuleConfigTree syllabus);
- if (flag && syllabus != null)
- {
- syllabus.children.Add(node);
- }
- else
- {
- trees.Add(node);
- }
- }
- return trees;
- }
- }
- }
|