TEAMModelOS/TEAMModelOS.SDK/Models/Service/Common/ActivityService.cs

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
    {
 
        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
                    {   
                        expertName=item.name ,
                        expertPicture=item.picture,
                        expertTmdname=item.tmdname,
                        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,
                        activityId=contest.id
                    }));
                }
                //处理已经分配完成（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,
                            activityId=contest.id,
                        });
                    }
                    else
                    {
                        expertContestTask.available = available;
                        expertContestTask.name = name;
                        expertContestTask.count = count;
                        expertContestTask.members = members;
                        expertContestTask.periodSubjectKey = checkResult.periodSubjectKey;
                        expertContestTask.activityId=contest?.id;
                    }
                }
                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,
                            activityId = contest?.id,
                        });
                    }
                    else
                    {
                        expertContestTask.available = available;
                        expertContestTask.name = name;
                        expertContestTask.count = count;
                        expertContestTask.periodSubjectKey = checkResult.periodSubjectKey;
                        expertContestTask.activityId=contest?.id;
                    }
                }
            }
            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);
            }
            List<ExpertContestTaskDto> okTask = new List<ExpertContestTaskDto>();
            okTask.AddRange(data.assignmentsAdd);
            okTask.AddRange(worksDB);
            var groups= okTask.GroupBy(z => z.uploadId).Select(x => new { key = x.Key, list = x.ToList() });
            foreach (var item in groups) {
                if (item.list.Count()<taskCount) {

                    ExpertContestTaskDto taskDto=  item.list.First().ToJsonString().ToObject<ExpertContestTaskDto>();
                    taskDto.expertName=null;
                    taskDto.expertId=null;
                    taskDto.expertPicture=null;
                    taskDto.expertTmdname=null;
                    //,8分配次数不足
                    taskDto.available=8;
                    invalids.Add(taskDto);
                }
            }
            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.expertName = selectedExpert.expertName;
                        newWork.expertPicture = selectedExpert.expertPicture;
                        newWork.expertTmdname = selectedExpert.expertTmdname;
                        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<IEnumerable<ActivityDto>> AreaActivityList(AzureCosmosFactory _azureCosmos, AzureStorageFactory _azureStorage, JsonElement request, string _areaId, int isCount = 0) 
        {
            string yearSql = string.Empty;
            if (isCount==0) {
                yearSql = $" and c.year={DateTimeOffset.Now.Year}";
                if (request.TryGetProperty("year", out JsonElement _year))
                {
                    yearSql = $" and c.year={_year}";
                }
            }
            string sql = $"select value c from c where c.owner='{_areaId}' {yearSql}  ";
            var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sql, "Activity");
            result.list.ForEach(z => {
                var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS(z.owner, BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);
                z.sas=blob_sas;
                z.url=blob_uri;
            });
            return result.list.OrderByDescending(z => z.stime);
        }

        public static async Task<List<ActivityDto>> SchoolActivityList(AzureCosmosFactory _azureCosmos, AzureStorageFactory _azureStorage, JsonElement request, string school, int isCount = 0) {
            School schoolbase = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemAsync<School>(school, new PartitionKey("Base"));
            List<ActivityDto> activities = new List<ActivityDto>();
            string yearSql = string.Empty;
            if (isCount==0)
            {
                yearSql = $" and c.year={DateTimeOffset.Now.Year}";
                if (request.TryGetProperty("year", out JsonElement _year))
                {
                    yearSql = $" and c.year={_year}";
                }
            }
            //获取开放的
            {

                //完全开放 所有的学校
                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  ) ";
                var resultOpen = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlOpen, "Activity");
                activities.AddRange(resultOpen.list);
                //部分学校
                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}' ";
                var resultSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlSchool, "Activity");
                resultSchool.list.ForEach(z =>
                {
                    var confirmedSchool = z.confirmedSchools.Find(z => z.id.Equals(school));
                    if (confirmedSchool==null)
                    {
                        z.confirmedSchools.Add(new ActivityConfirmedSchool
                        {
                            id=schoolbase.id,
                            name=schoolbase.name,
                            picture=schoolbase.picture,
                            status=0
                        });
                    }
                });
                activities.AddRange(resultSchool.list);
            }
            //获取区级下放的
            {

                if (!string.IsNullOrWhiteSpace(schoolbase.areaId))
                {
                    //区级所有学校
                    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) ";
                    var resultOpen = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlOpen, "Activity");
                    resultOpen.list.ForEach(z =>
                    {
                        var confirmedSchool = z.confirmedSchools.Find(z => z.id.Equals(school));
                        if (confirmedSchool==null)
                        {
                            z.confirmedSchools.Add(new ActivityConfirmedSchool
                            {
                                id=schoolbase.id,
                                name=schoolbase.name,
                                picture=schoolbase.picture,
                                status=0
                            });
                        }
                    });
                    activities.AddRange(resultOpen.list);
                    //区级部分学校
                    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}' ";
                    var resultSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlSchool, "Activity");
                    resultSchool.list.ForEach(z =>
                    {
                        var confirmedSchool = z.confirmedSchools.Find(z => z.id.Equals(school));
                        if (confirmedSchool==null)
                        {
                            z.confirmedSchools.Add(new ActivityConfirmedSchool
                            {
                                id=schoolbase.id,
                                name=schoolbase.name,
                                picture=schoolbase.picture,
                                status=0
                            });
                        }
                    });
                    activities.AddRange(resultSchool.list);
                }
            }
            //获取学校自己的
            {
                string sqlSchool = $"select value c from c where c.scope='school'{yearSql} and  c.owner='{school}'  ";
                var resultSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlSchool, "Activity");
                activities.AddRange(resultSchool.list);
            }
            activities.ForEach(z =>
            {
                var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS(z.owner, BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);
                z.sas=blob_sas;
                z.url = blob_uri;
            });

            return activities;
        }
        public  static async Task<List<TeacherActivityDto>> TeacherActivityList(AzureCosmosFactory _azureCosmos,AzureStorageFactory _azureStorage,  JsonElement request, string tmdid, int isCount = 0)
        {
            List<TeacherActivityDto> activities = new List<TeacherActivityDto>();
            HashSet<string> inviteActivityIds = new HashSet<string>();
            string yearSql = string.Empty;
            if (isCount==0)
            {
                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.Teacher).GetList<ActivityTeacher>(sqlInvite);
            inviteActivityIds= result.list.Where(x=>!string.IsNullOrWhiteSpace(x.activityId)).Select(z => z.activityId).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>(sqlActivity, "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;
                z.url=blob_uri;
            });
            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  && enroll.contest.enrollTime>0)
                        {
                            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;
        }
    }
}