TEAMModelOS/TEAMModelOS.SDK/Models/Service/LessonService.cs

using Azure.Core;
using Azure.Cosmos;
using Azure.Messaging.ServiceBus;
using DocumentFormat.OpenXml.Drawing.Charts;
using DocumentFormat.OpenXml.VariantTypes;
using HTEXLib.COMM.Helpers;
using MathNet.Numerics.Distributions;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Hosting;
using OpenXmlPowerTools;
using StackExchange.Redis;
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.Helper.Common.DateTimeHelper;
using TEAMModelOS.SDK.Models.Cosmos.Common;
using TEAMModelOS.SDK.Models.Cosmos.OpenEntity;
using TEAMModelOS.SDK.Services;

namespace TEAMModelOS.SDK.Models.Service
{
    public class LessonService
    {
        public static readonly DateTime dateTime1970 = new DateTime(1970, 1, 1).ToLocalTime();

        public static  Dictionary<string, object> GetLessonCond(JsonElement request)
        {
            Dictionary<string, object> dict = new Dictionary<string, object>();

            if (request.TryGetProperty("tmdid", out JsonElement tmdid))
            {
                if (tmdid.ValueKind.Equals(JsonValueKind.String) &&  !string.IsNullOrWhiteSpace($"{tmdid}"))
                {
                    dict.Add("tmdid", tmdid);
                }
                else if(tmdid.ValueKind.Equals(JsonValueKind.Array)) {
                    dict.Add("tmdid", tmdid);
                }
            }
            if (request.TryGetProperty("courseId", out JsonElement courseId) && !string.IsNullOrWhiteSpace($"{courseId}"))
            {
                dict.Add("courseId", courseId);
            }
            if (request.TryGetProperty("courseIds", out JsonElement courseIds))
            {
                dict.Add("courseId[*]", courseIds);
            }
            if (request.TryGetProperty("periodId", out JsonElement periodId) && !string.IsNullOrWhiteSpace($"{periodId}"))
            {
                dict.Add("periodId", periodId);
            }
            if (request.TryGetProperty("subjectId", out JsonElement subjectId))
            {
                dict.Add("subjectId", subjectId);
            }
            if (request.TryGetProperty("groupIds", out JsonElement groupIds))
            {
                dict.Add("groupIds[*]", groupIds);
            }
            if (request.TryGetProperty("grade", out JsonElement grade))
            {
                dict.Add("grade[*]", grade);
            }
            if (request.TryGetProperty("category", out JsonElement category))
            {
                dict.Add("category[*]", category);
            }
            if (request.TryGetProperty("doubleGreen", out JsonElement doubleGreen) && doubleGreen.GetBoolean())
            {
                dict.Add("=.tLevel", 2);
                dict.Add("=.pLevel", 2);
                //dict.Add(">=.tScore", 70);
                //dict.Add(">=.pScore", 70);
            }
            if (request.TryGetProperty("doubleRed", out JsonElement doubleRed) && doubleRed.GetBoolean())
            {
                dict.Add("=.tLevel", 0);
                dict.Add("=.pLevel", 0);
                //dict.Add(">=.tScore", 70);
                //dict.Add(">=.pScore", 70);
            }
            if (request.TryGetProperty("quality", out JsonElement quality) && quality.GetBoolean())
            {
                dict.Add(">=.discuss", 1);
            }
            if (request.TryGetProperty("excellent", out JsonElement excellent) && excellent.GetBoolean())
            {
                dict.Add(">=.excellent", 1);
            }
            if (request.TryGetProperty("name", out JsonElement name) && !string.IsNullOrWhiteSpace($"{name}"))
            {
                dict.Add("$.name", name);
            }
            if (request.TryGetProperty("today", out JsonElement today) && today.GetBoolean())
            {
                DateTime dateTimeA = Convert.ToDateTime(DateTimeOffset.UtcNow.ToString("D"));
                DateTime dateTimeB = Convert.ToDateTime(DateTimeOffset.UtcNow.ToString("D")).AddDays(1);
                double dayOf00_00_00 = (dateTimeA - dateTime1970).TotalMilliseconds;
                double day1Of00_00_00 = (dateTimeB - dateTime1970).TotalMilliseconds;
                dict.Add(">=.startTime", dayOf00_00_00);
                dict.Add("<.startTime", day1Of00_00_00);
            }

            if (request.TryGetProperty("week", out JsonElement week) && week.GetBoolean())
            {
                // DateTime dateTimeA = Convert.ToDateTime(DateTimeOffset.UtcNow.ToString("D"));
                DateTime dateTimeB = Convert.ToDateTime(DateTimeOffset.UtcNow.ToString("D")).AddDays(-7);
                double now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
                double dayB = (dateTimeB - dateTime1970).TotalMilliseconds;
                dict.Add("<=.startTime", now);
                dict.Add(">=.startTime", dayB);
            }
            //查询即将到期的且没有被清理的。
            if (request.TryGetProperty("expire", out JsonElement expire) && expire.ValueKind.Equals(JsonValueKind.True))
            {
                dict.Add(">.expire", 0);
                dict.Add("!=.status", 404);
            }
            //查询已经清理的
            if (request.TryGetProperty("is404", out JsonElement is404) && is404.ValueKind.Equals(JsonValueKind.True))
            {
                dict.Add("=.status", 404);
            }
            //只查有效的
            if (request.TryGetProperty("isOk", out JsonElement isOk) && isOk.ValueKind.Equals(JsonValueKind.True))
            {
                dict.Add("<=.expire", 0);
                dict.Add("!=.status", 404);
            }
            if (request.TryGetProperty("month", out JsonElement month) && month.GetBoolean())
            {
                //DateTime dateTimeA = Convert.ToDateTime(DateTimeOffset.UtcNow.ToString("D"));
                DateTime dateTimeB = Convert.ToDateTime(DateTimeOffset.UtcNow.ToString("D")).AddDays(-30);
                double now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
                double dayB = (dateTimeB - dateTime1970).TotalMilliseconds;
                dict.Add("<=.startTime", now);
                dict.Add(">=.startTime", dayB);
            }
            if (request.TryGetProperty("stime", out JsonElement stime) && !string.IsNullOrWhiteSpace($"{stime}"))
            {
                dict.Add(">=.startTime", stime);
            }
            if (request.TryGetProperty("etime", out JsonElement etime) && !string.IsNullOrWhiteSpace($"{etime}"))
            {
                dict.Add("<=.startTime", etime);
            }
            if (request.TryGetProperty("conds", out JsonElement conds) && conds.ValueKind.Equals(JsonValueKind.Array))
            {
                List<LessonSettingCond> settingConds = conds.Deserialize<List<LessonSettingCond>>();
                foreach (var item in settingConds)
                {
                    dict.TryAdd($"{item.type}.{item.key}", item.val);
                    //switch (item.type)
                    //{
                    //    case ">=":
                    //        dict.TryAdd($">=.{item.key}",item.val);
                    //        break;
                    //    case "<=":
                    //        dict.TryAdd($"<=.{item.key}", item.val);
                    //        break;
                    //}
                }
            }
            return dict;
        }
        public static async void DoLessonStudentRecord(DingDing _dingding, SnowflakeId snowflakeId, LessonRecord lessonRecord, string scope, CosmosClient client, string school, string tmdid,
            Teacher teacher,   AzureServiceBusFactory _serviceBus, AzureStorageFactory _azureStorage, IConfiguration _configuration, LessonBase lessonBase,AzureRedisFactory _azureRedis,
            List<int> pickupMemberIds, List<TaskData> taskDatas, List<IRSData> iRSDatas)
        {
            School schoolBase = null;
            Period period = null;
            try
            {
                int year = DateTimeOffset.UtcNow.Year;
                string hs = lessonBase?.report?.clientSummaryList.ToJsonString();
                var clientSummaryLists = lessonBase?.report?.clientSummaryList?.Where(x => x.groupTaskCompleteCount != 0 || x.groupScore != 0 || x.score != 0 || x.interactScore != 0 || x.taskCompleteCount != 0);
                IEnumerable<LessonStudent> students = new List<LessonStudent>();
                if (clientSummaryLists.Any())
                {
                    var ids = clientSummaryLists.Select(x => x.seatID);
                    students = lessonBase.student.Where(x => ids.Contains(x.seatID));
                }
                List<Student> studentsBase = new List<Student>();
                var stuids = students.Where(x => x.type == 2);
                if (stuids.Any())
                {
                    stuids.ToList().ForEach(x => {
                        x.school = string.IsNullOrWhiteSpace(x.school) ? school : x.school;
                    });
                  var result= await client.GetContainer(Constant.TEAMModelOS, Constant.Student).GetList<Student>($"select value c from c where c.id in ({string.Join(",",stuids.Select(d=>$"'{d.id}'"))})", $"Base-{school}");
                    if (result.list.Any()) { 
                        studentsBase = result.list;
                    
                    }
                }
                var groups = stuids.Where(z => !string.IsNullOrWhiteSpace(z.school)).GroupBy(x => x.school).Select(y => new { code = y.Key, list = y.ToList() });
                List<StudentScoreRecord> lessonStudentRecords = new List<StudentScoreRecord>();
                foreach (var group in groups)
                {

                    string stusql = $"select value(c) from c where c.stuid in({string.Join(",", group.list.Select(x => $"'{x.id}'"))}) and  c.school='{group.code}' and c.year={year}";
                    await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Student).GetItemQueryIterator<StudentScoreRecord>(queryText: stusql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"StudentScoreRecord") }))
                    {
                        lessonStudentRecords.Add(item);
                    }

                }
                var tmdids = students.Where(x => x.type == 1);
                if (tmdids.Any())
                {
                    string tmdsql = $"select value(c) from c where c.tmdid in({string.Join(",", tmdids.Select(x => $"'{x}'"))})    and c.year={year}";
                    await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Student).GetItemQueryIterator<StudentScoreRecord>(queryText: tmdsql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"StudentScoreRecord") }))
                    {
                        lessonStudentRecords.Add(item);
                    }
                }
              
                (Semester currSemester, int studyYear, DateTimeOffset currSemesterDate, DateTimeOffset date, DateTimeOffset nextSemester) dataSemester = new(null,-1, DateTimeOffset.UtcNow, DateTimeOffset.UtcNow, DateTimeOffset.UtcNow) ;
                if (!string.IsNullOrWhiteSpace(school)) {
                     schoolBase = await client.GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemAsync<School>(school, new PartitionKey("Base"));
                     period = schoolBase.period.Find(x => x.id.Equals($"{lessonRecord.periodId}"));
                    if (period!= null) {
                        dataSemester= SchoolService.GetSemester(period);
                    }
                     
                }
                List <Task<ItemResponse<StudentScoreRecord>>> records = new List<Task<ItemResponse<StudentScoreRecord>>>();
                HashSet <OverallEducation> overallEducations   = new HashSet<OverallEducation>();

                // 互动次数,-1 表示没有进行互动。 与 0 不同
                int interactCount = -1;
                //抢权作答的学生
                List<int > buzzClients= new List<int>();


                if (iRSDatas.IsNotEmpty()) {
                    var keys = iRSDatas.Where(z => z.isBuzz==false).Select(v => v.clientAnswers).SelectMany(z => z.Keys).ToList();
                    var values = iRSDatas.Where(z => z.isBuzz==false).Select(v => v.clientAnswers).SelectMany(z => z.Values).ToList();

                    interactCount= keys.Count();
                    var bclients = iRSDatas.Where(z => z.buzzClients.IsNotEmpty()).SelectMany(v => v.buzzClients);
                    if (bclients!=null && bclients.Count()>0) {
                        foreach (var bc in bclients) {
                            if (int.TryParse(bc, out int b)) {
                                buzzClients.Add(b);
                            }
                        }
                    }
                }
                //任务发布次数 ,-1 表示没有进行互动。 与 0 不同
                int taskCount = -1;
                var groupNames  = lessonBase.report.clientSummaryList.Where(z => !string.IsNullOrEmpty(z.groupName))?.Select(z=>z.groupName)?.ToHashSet()?.OrderBy(z=>z)?.ToList();
              
                List<IdCodeCount> groupTaskJoinCounts = new List<IdCodeCount>();
                if (groupNames.IsNotEmpty()) {
                    groupTaskJoinCounts = groupNames.Select(z => new IdCodeCount { name=z, count = 0 }).ToList();
                } 
                //組任務發佈數
                int groupTaskCount = -1;
                if (taskDatas.IsNotEmpty())
                {
                   
                    taskCount=0;
                    bool hasGroupTask = false;
                    int groupTaksCountTemp = 0;
                    foreach (var taskData in taskDatas)
                    {
                        var isGroupItem = taskData.clientWorks.FindAll(z => z.isGroupItem);
                        if (isGroupItem.IsNotEmpty())
                        { 
                            //有组任务
                            hasGroupTask = true;
                            groupTaksCountTemp += 1;
                            foreach (var item in isGroupItem)
                            {
                                int groupIndex = 0;
                                int.TryParse(item.groupID,out  groupIndex);
                                //由于分组下标从1 开始，则需要判断是否与分组数组大小一致，且提交了作品，则数量+1 
                                if ( groupIndex>0 && item.blobFiles.IsNotEmpty() && groupIndex <= groupTaskJoinCounts.Count) {
                                    groupTaskJoinCounts[groupIndex-1].count+=1;
                                }
                            }
                           
                        }
                        else
                        {
                            //没有组任务
                            taskCount += 1;
                        }
                    }
                    if (hasGroupTask) {
                        groupTaskCount=groupTaksCountTemp;
                    }
                }
                foreach (var x in stuids) {
                    var record = lessonStudentRecords.Find(l => l.stuid.Equals(x.id) && l.code.Equals($"StudentScoreRecord") && l.school.Equals(x.school));
                    ClientSummaryList clientSummaryList = lessonBase.report.clientSummaryList.Find(c => c.seatID == x.seatID);
                    int stuInteractCount = -1;
                    int stuInteractJoin = 0;
                    //获取挑人的互动
                    var ids=  pickupMemberIds.FindAll(z => z==x.seatID);
                    if (ids.IsNotEmpty())
                    {
                        stuInteractJoin=ids.Count;
                        if (interactCount>=0)
                        {
                            stuInteractCount=interactCount+ids.Count;
                        }
                        else
                        {
                            stuInteractCount=ids.Count;

                        }
                    }
                    //获取抢权的互动
                    var buzIds = buzzClients.FindAll(z => z==x.seatID);
                    if (buzIds.IsNotEmpty()) {
                        stuInteractJoin=stuInteractJoin+buzIds.Count;
                        if (stuInteractCount>-1)
                        {
                            stuInteractCount = stuInteractCount + buzIds.Count;
                        }
                        else {
                            stuInteractCount = buzIds.Count;
                        }

                    }
                    //普通作答的互动


                    if (record != null)
                    {
                        if (clientSummaryList != null)
                        {
                            var hasrecord = record.lessonRecords.Find(x => x.lessonId.Equals(lessonRecord.id));
                            if (hasrecord != null)
                            {
                                hasrecord.gscore = clientSummaryList.groupScore;
                                hasrecord.pscore = clientSummaryList.score;
                                hasrecord.tscore = clientSummaryList.interactScore;
                                hasrecord.tmdid = teacher.id;
                                hasrecord.school = school;
                                hasrecord.scope = lessonRecord.scope;
                                hasrecord.lessonId = lessonRecord.id;
                                hasrecord.courseId = lessonRecord.courseId;
                                hasrecord.periodId = lessonRecord.periodId;
                                hasrecord.subjectId = lessonRecord.subjectId;
                                hasrecord.time = lessonRecord.startTime;
                            }
                            else
                            {
                                record.lessonRecords.Add(
                                     new StudentLessonRecord
                                     {
                                         gscore = clientSummaryList.groupScore,
                                         pscore = clientSummaryList.score,
                                         tscore = clientSummaryList.interactScore,
                                         tmdid = teacher.id,
                                         school = school,
                                         scope = lessonRecord.scope,
                                         lessonId = lessonRecord.id,
                                         courseId = lessonRecord.courseId,
                                         periodId = lessonRecord.periodId,
                                         subjectId = lessonRecord.subjectId,
                                         time = lessonRecord.startTime
                                     }
                                 );
                            }
                        }
                    }
                    else
                    {
                        record = new StudentScoreRecord
                        {
                            userType = Constant.ScopeStudent,
                            id = $"{snowflakeId.NextId()}",
                            year = year,
                            stuid = x.id,
                            school = x.school,
                            code = $"StudentScoreRecord",
                            pk = "StudentScoreRecord",
                            ttl = -1,
                            lessonRecords = new List<StudentLessonRecord> {  new StudentLessonRecord
                             {
                                 gscore = clientSummaryList.groupScore,
                                 pscore = clientSummaryList.score,
                                 tscore = clientSummaryList.interactScore,
                                 tmdid = teacher.id,
                                 school = school,
                                 scope = lessonRecord.scope,
                                 lessonId = lessonRecord.id,
                                 courseId = lessonRecord.courseId,
                                 periodId = lessonRecord.periodId,
                                 subjectId = lessonRecord.subjectId,
                                 time= lessonRecord.startTime
                             }}
                        };

                    }
                    record.userType = Constant.ScopeStudent;
                    record.gscore = record.lessonRecords.Select(x => x.gscore).Sum();
                    record.pscore = record.lessonRecords.Select(x => x.pscore).Sum();
                    record.tscore = record.lessonRecords.Select(x => x.tscore).Sum();
                    if (dataSemester.currSemester != null  && (clientSummaryList.groupScore>0  || clientSummaryList.score > 0 || clientSummaryList.interactScore > 0))
                    {
                        string oid = $"{dataSemester.studyYear}-{dataSemester.currSemester.id}-{record.stuid}";
                        string ocode = $"OverallEducation-{school}";
                        var student = studentsBase.Find(stu => stu.id.Equals(x.id));
                        Azure.Response response = await client.GetContainer(Constant.TEAMModelOS, Constant.Student).ReadItemStreamAsync(oid, new PartitionKey(ocode));
                        OverallEducation overallEducation = null;
                        if (response.Status != 200)
                        {
                            overallEducation = new OverallEducation
                            {
                                id =oid,
                                code = $"OverallEducation-{school}",
                                pk = "OverallEducation",
                                ttl = -1,
                                name = x.name,
                                classId = student?.classId,
                                schoolCode = $"{school}",
                                semesterId = dataSemester.currSemester.id,
                                year = dataSemester.studyYear,
                                periodId = $"{period.id}",
                                stuYear = student.year,
                                studentId = x.id,
                                lessonScore= new List<StudentLessonRecord> { new StudentLessonRecord
                             {
                                 gscore = clientSummaryList.groupScore,
                                 pscore = clientSummaryList.score,
                                 tscore = clientSummaryList.interactScore,
                                 tmdid = teacher.id,
                                 school = school,
                                 scope = lessonRecord.scope,
                                 lessonId = lessonRecord.id,
                                 courseId = lessonRecord.courseId,
                                 periodId = lessonRecord.periodId,
                                 subjectId = lessonRecord.subjectId,
                                 time= lessonRecord.startTime
                             }}
                            };
                        }
                        else
                        {
                            overallEducation=JsonDocument.Parse(response.Content).RootElement.ToObject<OverallEducation>();
                            var hasrecord = overallEducation.lessonScore.Find(x => x.lessonId.Equals(lessonRecord.id));
                            if (hasrecord != null)
                            {
                                hasrecord.gscore = clientSummaryList.groupScore;
                                hasrecord.pscore = clientSummaryList.score;
                                hasrecord.tscore = clientSummaryList.interactScore;
                                hasrecord.tmdid = teacher.id;
                                hasrecord.school = school;
                                hasrecord.scope = lessonRecord.scope;
                                hasrecord.lessonId = lessonRecord.id;
                                hasrecord.courseId = lessonRecord.courseId;
                                hasrecord.periodId = lessonRecord.periodId;
                                hasrecord.subjectId = lessonRecord.subjectId;
                                hasrecord.time = lessonRecord.startTime;
                            }
                            else
                            {
                                overallEducation.lessonScore.Add(
                                     new StudentLessonRecord
                                     {
                                         gscore = clientSummaryList.groupScore,
                                         pscore = clientSummaryList.score,
                                         tscore = clientSummaryList.interactScore,
                                         tmdid = teacher.id,
                                         school = school,
                                         scope = lessonRecord.scope,
                                         lessonId = lessonRecord.id,
                                         courseId = lessonRecord.courseId,
                                         periodId = lessonRecord.periodId,
                                         subjectId = lessonRecord.subjectId,
                                         time = lessonRecord.startTime
                                     }
                                 );
                            }
                        }
                        overallEducations.Add(overallEducation);
                    }
                    records.Add(client.GetContainer(Constant.TEAMModelOS, Constant.Student).UpsertItemAsync(record, partitionKey: new PartitionKey(record.code)));

                }


                foreach (var x in tmdids) {
                    var record = lessonStudentRecords.Find(l => l.tmdid.Equals(x.id) && l.code.Equals($"StudentScoreRecord"));
                    ClientSummaryList clientSummaryList = lessonBase.report.clientSummaryList.Find(c => c.seatID == x.seatID);
                    if (record != null)
                    {
                        if (clientSummaryList != null)
                        {
                            var hasrecord = record.lessonRecords.Find(x => x.lessonId.Equals(lessonRecord.id));
                            if (hasrecord != null)
                            {
                                hasrecord.gscore = clientSummaryList.groupScore;
                                hasrecord.pscore = clientSummaryList.score;
                                hasrecord.tscore = clientSummaryList.interactScore;
                                hasrecord.tmdid = teacher.id;
                                hasrecord.school = school;
                                hasrecord.scope = lessonRecord.scope;
                                hasrecord.lessonId = lessonRecord.id;
                                hasrecord.courseId = lessonRecord.courseId;
                                hasrecord.periodId = lessonRecord.periodId;
                                hasrecord.subjectId = lessonRecord.subjectId;
                                hasrecord.time = lessonRecord.startTime;
                            }
                            else
                            {
                                record.lessonRecords.Add(
                                     new StudentLessonRecord
                                     {
                                         gscore = clientSummaryList.groupScore,
                                         pscore = clientSummaryList.score,
                                         tscore = clientSummaryList.interactScore,
                                         tmdid = teacher.id,
                                         school = school,
                                         scope = lessonRecord.scope,
                                         lessonId = lessonRecord.id,
                                         courseId = lessonRecord.courseId,
                                         periodId = lessonRecord.periodId,
                                         subjectId = lessonRecord.subjectId,
                                         time = lessonRecord.startTime
                                     }
                                 );
                            }
                        }
                    }
                    else
                    {
                        record = new StudentScoreRecord
                        {
                            userType = Constant.ScopeTmdUser,
                            id = $"{snowflakeId.NextId()}",
                            code = $"StudentScoreRecord",
                            pk = "StudentScoreRecord",
                            ttl = -1,
                            year = year,
                            tmdid = x.id,
                            lessonRecords = new List<StudentLessonRecord>
                            {
                                new StudentLessonRecord
                                {
                                 gscore = clientSummaryList.groupScore,
                                 pscore = clientSummaryList.score,
                                 tscore = clientSummaryList.interactScore,
                                 tmdid = teacher.id,
                                 school = school,
                                 scope = lessonRecord.scope,
                                 lessonId = lessonRecord.id,
                                 courseId = lessonRecord.courseId,
                                 periodId = lessonRecord.periodId,
                                 subjectId = lessonRecord.subjectId,
                                 time=lessonRecord.startTime
                                }
                            }
                        };
                    }
                    record.userType = Constant.ScopeStudent;
                    record.gscore = record.lessonRecords.Select(x => x.gscore).Sum();
                    record.pscore = record.lessonRecords.Select(x => x.pscore).Sum();
                    record.tscore = record.lessonRecords.Select(x => x.tscore).Sum();
                    records.Add(client.GetContainer(Constant.TEAMModelOS, Constant.Student).UpsertItemAsync(record, partitionKey: new PartitionKey(record.code)));
                }
                if (records.Any())
                {
                    await Task.WhenAll(records);
                }
                if (overallEducations.Any())
                {
                    foreach (var item in overallEducations) {
                        await client.GetContainer(Constant.TEAMModelOS, Constant.Student).UpsertItemAsync(item, partitionKey: new PartitionKey(item.code));
                        string key = $"OverallEducation:{item.schoolCode}:{item.periodId}:{item.year}:{item.semesterId}:{item.classId}";
                        await _azureRedis.GetRedisClient(8).HashSetAsync(key, item.studentId, item.ToJsonString());
                        await _azureRedis.GetRedisClient(8).KeyExpireAsync(key,new TimeSpan(180 *24 ,0,0));
                    }
                }
            }
            catch (Exception ex)
            {
                await _dingding.SendBotMsg($"学生个人课例统计信息异常，{ex.Message}\n{ex.StackTrace},{lessonRecord?.ToJsonString()}{school}", GroupNames.醍摩豆服務運維群組);
            }
        }

        public static async void DoAutoDeleteSchoolLessonRecord(LessonRecord lessonRecord, string scope, CosmosClient client, string school, string tmdid,
            Teacher teacher,   AzureServiceBusFactory _serviceBus, AzureStorageFactory _azureStorage, IConfiguration _configuration, CoreAPIHttpService _coreAPIHttpService,DingDing _dingDing,AzureRedisFactory _azureRedis)
        {
            if (lessonRecord.scope.Equals("school"))
            {
                SchoolSetting setting = null;
                Azure.Response schoolSetting = await client.GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemStreamAsync(school, new PartitionKey("SchoolSetting"));
                School schoolBase = await client.GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemAsync<School>(school, new PartitionKey("Base"));
                if (schoolSetting.Status == 200)
                {
                    setting = JsonDocument.Parse(schoolSetting.Content).RootElement.Deserialize<SchoolSetting>();
                    if (setting.lessonSetting != null)
                    {
                        //两种状态都不属于，则默认未开启。
                        if (setting.lessonSetting.openAutoClean != 0 && setting.lessonSetting.openAutoClean != 1)
                        {
                            setting.lessonSetting.openAutoClean = 0;
                            setting.lessonSetting.expireDays = Constant.school_lesson_expire;
                        }
                        else { 
                            //属于 要么开启1，要么关闭0
                        }
                    }
                    else
                    {
                        setting.lessonSetting = new LessonSetting() { openAutoClean = 0, expireDays = Constant.school_lesson_expire };
                    }
                }
                else
                {
                    setting = new SchoolSetting() { lessonSetting = new LessonSetting { openAutoClean = 0, expireDays = Constant.school_lesson_expire } };
                }
                int school_lesson_expire = 0;
                bool save = true;
                List<string> msg = new List<string>();
                if (setting.lessonSetting.openAutoClean == 1)
                {
                    if (setting.lessonSetting.conds.IsEmpty())
                    {
                        save = false;
                    }
                    else
                    {
                        school_lesson_expire = setting.lessonSetting.expireDays;
                        foreach (var item in setting.lessonSetting.conds)
                        {
                            switch (item.type)
                            {
                                case ">=":
                                    switch (item.key)
                                    {
                                        case "attendRate":
                                            if (!(lessonRecord.attendRate >= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.attendRate}{item.type}{item.val}");
                                            }
                                            break;
                                        case "groupCount":
                                            if (!(lessonRecord.groupCount >= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.groupCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "totalPoint":
                                            if (!(lessonRecord.totalPoint >= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.totalPoint}{item.type}{item.val}");
                                            }
                                            break;
                                        case "collateTaskCount":
                                            if (!(lessonRecord.collateTaskCount >= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.collateTaskCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "collateCount":
                                            if (!(lessonRecord.collateCount >= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.collateCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "pushCount":
                                            if (!(lessonRecord.pushCount >= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.pushCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "totalInteractPoint":
                                            if (!(lessonRecord.totalInteractPoint >= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.totalInteractPoint}{item.type}{item.val}");
                                            }
                                            break;
                                        case "interactionCount":
                                            if (!(lessonRecord.interactionCount >= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.interactionCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "clientInteractionCount":
                                            if (!(lessonRecord.clientInteractionCount >= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.clientInteractionCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "examQuizCount":
                                            if (!(lessonRecord.examQuizCount >= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.examQuizCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "examPointRate":
                                            if (!(lessonRecord.examPointRate >= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.examPointRate}{item.type}{item.val}");
                                            }
                                            break;
                                    }
                                    break;
                                case "<=":
                                    switch (item.key)
                                    {
                                        case "attendRate":
                                            if (!(lessonRecord.attendRate <= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.attendRate}{item.type}{item.val}");
                                            }
                                            break;
                                        case "groupCount":
                                            if (!(lessonRecord.groupCount <= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.groupCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "totalPoint":
                                            if (!(lessonRecord.totalPoint <= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.totalPoint}{item.type}{item.val}");
                                            }
                                            break;
                                        case "collateTaskCount":
                                            if (!(lessonRecord.collateTaskCount <= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.collateTaskCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "collateCount":
                                            if (!(lessonRecord.collateCount <= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.collateCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "pushCount":
                                            if (!(lessonRecord.pushCount <= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.pushCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "totalInteractPoint":
                                            if (!(lessonRecord.totalInteractPoint <= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.totalInteractPoint}{item.type}{item.val}");
                                            }
                                            break;
                                        case "interactionCount":
                                            if (!(lessonRecord.interactionCount <= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.interactionCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "clientInteractionCount":
                                            if (!(lessonRecord.clientInteractionCount <= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.clientInteractionCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "examQuizCount":
                                            if (!(lessonRecord.examQuizCount <= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.examQuizCount}{item.type}{item.val}");
                                            }
                                            break;
                                        case "examPointRate":
                                            if (!(lessonRecord.examPointRate <= item.val))
                                            {
                                                save = false;
                                                msg.Add($"{item.key}:{lessonRecord.examPointRate}{item.type}{item.val}");
                                            }
                                            break;
                                    }
                                    break;
                            }
                        }
                    }
                }
                /* 注释start 2023.3.22,该段逻辑在开课的时候已经处理，详见ActiveTaskTopic. LessonRecordEvent   create ，无论有没有开启setting.lessonSetting.openAutoClean  自动删除策略，只要空间不足都会对课例进行自动清理管理。
                else
                {
                    ///未设置openAutoClean=1时，则检查学校使用空间是否充足。
                  
                    double usize = 0;
                    int  tsize = schoolBase.tsize;
                    //schoolBase.tsize
                    //計算學校或個人的使用空間
                    RedisValue redisValue = _azureRedis.GetRedisClient(8).HashGet($"Blob:Record", $"{schoolBase.id}");
                    if (redisValue.HasValue && long.TryParse(redisValue.ToString(), out var bsize))
                    {
                        usize = Math.Round(bsize / 1073741824.0 - (tsize), 2, MidpointRounding.AwayFromZero); //1073741824  1G
                    }
                    else //如果檢測不到緩存，觸發刷新計算空間
                    {
                        await BlobService.RefreshBlobRoot(new BlobRefreshMessage { progress = "update", root = "records", name = $"{schoolBase.id}" }, _serviceBus, _configuration, _azureRedis);
                    }
                    ///空间充足的情况保存。
                    if (schoolBase.size - usize > 0)
                    {
                        save = true;
                    }
                    else {
                        save = false;
                        school_lesson_expire = Constant.school_lesson_expire;
                    }
                } 注释end 2023.3.22,该段逻辑在开课的时候已经处理，详见ActiveTaskTopic. LessonRecordEvent   create ，无论有没有开启setting.lessonSetting.openAutoClean  自动删除策略，只要空间不足都会对课例进行自动清理管理。
                */
                if (!save && school_lesson_expire > 0)
                {
                    // 1-时间戳，7-时间戳
                    Dictionary<int, ExpireTag> result = new Dictionary<int, ExpireTag>();
                    //暂定7天 
                    var now = DateTimeOffset.UtcNow;
                    //剩余3天的通知
                    //var day3= now.AddDays(school_lesson_expire - 3).ToUnixTimeMilliseconds();
                    //result.Add(3, day3);
                    //剩余1天的通知
                    var day1 = now.AddDays(school_lesson_expire - (school_lesson_expire - 1)).ToUnixTimeMilliseconds();
                    result.Add(1, new ExpireTag { expire = day1, tag = "notification" });
                    //到期通知
                    //不到五点上传的课例，七天之后直接删除。
                    int addSecond = 0;
                    if (now.Hour > 5)
                    {
                        // 到凌晨00点还差 (24 - now.Hour) *60 * 60 分钟，再加天数;
                        addSecond = school_lesson_expire * 86400 + (24 - now.Hour) * 3600 - (now.Hour * 3600);
                        //再加 00到05小时内的 随机秒数
                        Random rand = new Random();
                        int randInt = rand.Next(0, 18000);
                        addSecond += randInt;
                    }
                    else
                    {
                        addSecond = school_lesson_expire * 24 * 60 * 60;
                    }
                    lessonRecord.expire = now.AddSeconds(addSecond).ToUnixTimeMilliseconds();
                    result.Add(school_lesson_expire, new ExpireTag { expire = lessonRecord.expire, tag = "delete" });
                    // result.Add(school_lesson_expire, lessonRecord.expire);
                    string biz = "expire";
                     
                    string expireTime = DateTimeOffset.FromUnixTimeMilliseconds(lessonRecord.expire).ToString("yyyy-MM-dd HH:mm:ss");
                    Teacher targetTeacher = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemAsync<Teacher>($"{tmdid}", new PartitionKey($"Base"));
                    _coreAPIHttpService.PushNotify(new List<IdNameCode> { new IdNameCode { id = targetTeacher.id, name = targetTeacher.name, code = targetTeacher.lang } }, "expire-school_lessonRecord", Constant.NotifyType_IES5_Course,
                                 new Dictionary<string, object> { { "tmdid", teacher.id }, { "tmdname", teacher.name }, { "schoolName", schoolBase.name }, 
                                     { "schoolId", $"{school}" },{ "lessonId",lessonRecord.id }, { "expireTime", expireTime },{ "lessonName",lessonRecord.name } }, $"{Environment.GetEnvironmentVariable("Option:Location")}", _configuration, _dingDing, "");
                    var table = _azureStorage.GetCloudTableClient().GetTableReference("ChangeRecord");
                    List<ChangeRecord> records = await table.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", lessonRecord.id } });
                    if (records.Count <= 0)
                    {
                        foreach (var item in result)
                        {
                            string PartitionKey = string.Format("{0}{1}{2}", lessonRecord.code, "-", $"expire-{item.Key}");
                            //课堂的id ,
                            //课堂的通知时间类型progress， 默认就会发送一条，到期前一天发送一条，最后已到期发送一条。
                            var message = new ServiceBusMessage(new
                            {
                                id = lessonRecord.id,
                                progress = item.Key,
                                code = lessonRecord.code,
                                scope = lessonRecord.scope,
                                school = lessonRecord.school,
                                opt = "delete",
                                expire = lessonRecord.expire,
                                tmdid = tmdid,
                                tmdname = teacher.name,
                                name = lessonRecord.name,
                                startTime = lessonRecord.startTime,
                                tag = item.Value.tag
                            }.ToJsonString());
                            message.ApplicationProperties.Add("name", "LessonRecordExpire");
                            long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), message, DateTimeOffset.FromUnixTimeMilliseconds(item.Value.expire));
                            ChangeRecord changeRecord = new ChangeRecord
                            {
                                RowKey = lessonRecord.id,
                                PartitionKey = PartitionKey,
                                sequenceNumber = start,
                                msgId = message.MessageId
                            };
                            await table.Save<ChangeRecord>(changeRecord);
                        }
                    }
                }
                else
                {

                    if (lessonRecord.expire > 0)
                    {
                        var table = _azureStorage.GetCloudTableClient().GetTableReference("ChangeRecord");
                        List<ChangeRecord> records = await table.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", lessonRecord.id } });
                        foreach (var record in records)
                        {
                            try
                            {
                                await table.DeleteSingle<ChangeRecord>(record.PartitionKey, record.RowKey);
                                await _serviceBus.GetServiceBusClient().CancelMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), record.sequenceNumber);
                            }
                            catch (Exception)
                            {
                                continue;
                            }
                        }
                    }
                    lessonRecord.save = 1;
                    lessonRecord.expire = -1;
                }
            }
        }


        public record ExpireTag
        {
            public long expire { get; set; }
            public string tag { get; set; }
        }
        /// <summary>
        /// 
        /// </summary>
        /// <param name="client"></param>
        /// <param name="_dingDing"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public static LessonDis DisLessonCount(LessonRecord oldRecord, LessonRecord newRecord, LessonDis lessonDis)
        {
            //创建课堂的情况
            if (oldRecord == null && newRecord != null)
            {
                lessonDis.record = 1;
            }
            //删除数据的情况
            //不再对LessonCount进行减
            else if (oldRecord != null && newRecord == null)
            {
                /*lessonDis.record = -1;
                //P分数量加减
                if (oldRecord.pScore >= 70)
                {
                    lessonDis.disPCount = -1;
                }
                //T分数量加减
                if (oldRecord.tScore >= 70)
                {
                    lessonDis.disTCount = -1;
                }
                if (oldRecord.tScore >= 70 && oldRecord.pScore >= 70)
                {
                    lessonDis.disTCount = -1;
                }*/
            }
            //无效操作
            else if (oldRecord == null && newRecord == null)
            {

            }
            //前后操作都有值，则表示更新
            else
            {
                //P分数量加减
                if (oldRecord.pScore >= 70)
                {
                    if (newRecord.pScore < 70)
                    {
                        lessonDis.disPCount = -1;
                    }
                }
                else
                {
                    if (newRecord.pScore >= 70)
                    {
                        lessonDis.disPCount = 1;
                    }
                }
                //T分数量加减

                if (oldRecord.tScore >= 70)
                {
                    if (newRecord.tScore < 70)
                    {
                        lessonDis.disTCount = -1;
                    }
                }
                else
                {
                    if (newRecord.tScore >= 70)
                    {
                        lessonDis.disTCount = 1;
                    }
                }
                //双绿灯数量

                if (oldRecord.tScore >= 70 && oldRecord.pScore >= 70)
                {
                    if (newRecord.tScore < 70 || newRecord.pScore < 70)
                    {
                        lessonDis.disDCount = -1;
                    }
                }
                else
                {
                    if (newRecord.tScore >= 70 && newRecord.pScore >= 70)
                    {
                        lessonDis.disDCount = 1;
                    }
                }
            }
            return lessonDis;
        }

        public static LessonDis DisLessonCount_2(LessonRecord oldRecord, LessonRecord newRecord, LessonDis lessonDis)
        {
            //创建课堂的情况
            if (oldRecord == null && newRecord != null)
            {
                lessonDis.record = 1;
                //P分数量加减

                if (newRecord.pScore >= 70)
                {
                    lessonDis.disPCount = 1;
                }

                //T分数量加减


                if (newRecord.tScore >= 70)
                {
                    lessonDis.disTCount = 1;
                }

                //双绿灯数量


                if (newRecord.tScore >= 70 && newRecord.pScore >= 70)
                {
                    lessonDis.disDCount = 1;
                }

            }
            return lessonDis;
        }


        public static async Task FixLessonCount(CosmosClient client, DingDing _dingDing, LessonRecord record, LessonRecord oldRecord, LessonDis lessonDis)
        {
            LessonRecord data = null;
            try
            {
                if (record != null && oldRecord == null)
                {
                    data = record;
                }
                if (record == null && oldRecord != null)
                {
                    data = oldRecord;
                }
                if (record != null && oldRecord != null)
                {
                    data = record;
                }

                int day = DateTimeOffset.FromUnixTimeMilliseconds(data.startTime).DayOfYear;
                int year = DateTimeOffset.FromUnixTimeMilliseconds(data.startTime).Year;
                int days = DateTimeHelper.getDays(year);
                //int years = DateTimeOffset.UtcNow.DayOfYear;
                string tbname = string.Empty;
                string code = string.Empty;
                if (data.groupIds.Any()) {
                    if (data.scope != null && data.scope.Equals("school"))
                    {
                        if (string.IsNullOrEmpty(data.periodId))
                        {
                            code = $"LessonCount-{data.school}-{year}";
                            tbname = "School";
                        }
                        else
                        {
                            code = $"LessonCount-{data.school}-{year}-{data.periodId}";
                            tbname = "School";
                        }

                    }
                    else
                    {
                        code = $"LessonCount-{year}";
                        tbname = "Teacher";
                    }
                    var response = await client.GetContainer(Constant.TEAMModelOS, tbname).ReadItemStreamAsync(data.tmdid.ToString(), new PartitionKey(code));
                    if (response.Status == 200)
                    {
                        using var json = await JsonDocument.ParseAsync(response.ContentStream);
                        LessonCount count = json.ToObject<LessonCount>();

                        count.tCount[day - 1] += lessonDis.disTCount;
                        count.pCount[day - 1] += lessonDis.disPCount;
                        count.ptCount[day - 1] += lessonDis.disDCount;
                        count.beginCount[day - 1] += lessonDis.record;

                        await client.GetContainer("TEAMModelOS", tbname).ReplaceItemAsync(count, count.id, new PartitionKey(code));
                    }
                    else
                    {
                        LessonCount count = new()
                        {
                            id = data.tmdid,
                            code = code,
                            ttl = -1
                        };
                        double[] da = new double[days];
                        List<double> list = new(da);
                        List<double> listT = new(da);
                        List<double> listP = new(da);
                        List<double> listPT = new(da);

                        list[day - 1] += lessonDis.record;
                        listT[day - 1] += lessonDis.disTCount;
                        listP[day - 1] += lessonDis.disPCount;
                        listPT[day - 1] += lessonDis.disDCount;
                        count.beginCount.AddRange(list);
                        count.tCount.AddRange(listT);
                        count.pCount.AddRange(listP);
                        count.ptCount.AddRange(listPT);
                        //count.courseIds.Add(data.courseId);
                        await client.GetContainer("TEAMModelOS", tbname).CreateItemAsync(count, new PartitionKey(code));
                    }
                }              
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-LessonCount-FixLessonCount\n{ex.Message}\n{ex.StackTrace}{data.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
            }
        }
    }
}