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

using Azure.Cosmos;
using Azure.Storage.Blobs.Models;
using Azure.Storage.Sas;
using HTEXLib.COMM.Helpers;
using System;
using System.Collections.Generic;
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;

namespace TEAMModelOS.SDK
{
    public static class ActivityService
    {

        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))
            {
                yearSql = $" and c.year={_year}";
            }
            //先获取邀请制的
            string sqlInvite = $"select value c from c join t in c.inviteTeachers where   t.id='{tmdid}'";
            var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityTeacher>(sqlInvite, "ActivityTeacher");
            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 | BlobContainerSasPermissions.List);
                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.type))
                        {
                            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> UpsertReviewRule(ReviewRuleTree reviewRuleTree,Activity activity,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
            };
            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";
             await   _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).UpsertItemAsync(reviewRule,new Azure.Cosmos.PartitionKey(reviewRule.code));
            }
            return reviewRule;
        }

        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;
        }
    }
}