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

using Azure.Cosmos;
using Azure.Messaging.ServiceBus;
using HTEXLib.COMM.Helpers;
using Microsoft.Extensions.Configuration;
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;

namespace TEAMModelOS.SDK.Models.Service
{
    public class LessonService
    {
        public static async void DoLessonStudentRecord(DingDing _dingding, SnowflakeId snowflakeId, LessonRecord lessonRecord, string scope, CosmosClient client, string school, string tmdid,
            Teacher teacher, NotificationService _notificationService, AzureServiceBusFactory _serviceBus, AzureStorageFactory _azureStorage, IConfiguration _configuration, LessonBase lessonBase)
        {

            try
            {
                int year = DateTimeOffset.UtcNow.Year;
                var clientSummaryList = lessonBase.report.clientSummaryList.Where(x => x.groupTaskCompleteCount != 0 || x.groupScore != 0 || x.score != 0 || x.tnteractScore != 0 || x.taskCompleteCount != 0);
                IEnumerable<LessonStudent> students = new List<LessonStudent>();
                if (clientSummaryList.Any())
                {
                    students = lessonBase.student.Where(x => clientSummaryList.Select(x => x.seatID).Contains(x.seatID));
                }
                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 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);
                    }
                }
                List<Task<ItemResponse<StudentScoreRecord>>> records = new List<Task<ItemResponse<StudentScoreRecord>>>();
                stuids.ToList().ForEach(x => {
                    var record = lessonStudentRecords.Find(l => l.id.Equals(x.id) && l.code.Equals($"StudentScoreRecord") && l.school.Equals(x.school));
                    ClientSummaryList clientSummaryList = lessonBase.report.clientSummaryList.Find(c => c.seatID == x.seatID);
                    if (record != null)
                    {
                        if (clientSummaryList != null)
                        {
                            record.lessonRecords.Add(
                                 new StudentLessonRecord
                                 {
                                     gscore = clientSummaryList.groupScore,
                                     pscore = clientSummaryList.score,
                                     tscore = clientSummaryList.tnteractScore,
                                     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.tnteractScore,
                                 tmdid = teacher.id,
                                 school = school,
                                 scope = lessonRecord.scope,
                                 lessonId = lessonRecord.id,
                                 courseId = lessonRecord.courseId,
                                 periodId = lessonRecord.periodId,
                                 subjectId = lessonRecord.subjectId,
                             }}
                        };

                    }
                    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)));
                });
                tmdids.ToList().ForEach(x => {
                    var record = lessonStudentRecords.Find(l => l.id.Equals(x.id) && l.code.Equals($"StudentScoreRecord"));
                    ClientSummaryList clientSummaryList = lessonBase.report.clientSummaryList.Find(c => c.seatID == x.seatID);
                    if (record != null)
                    {
                        if (clientSummaryList != null)
                        {
                            record.lessonRecords.Add(
                            new StudentLessonRecord
                            {
                                gscore = clientSummaryList.groupScore,
                                pscore = clientSummaryList.score,
                                tscore = clientSummaryList.tnteractScore,
                                tmdid = teacher.id,
                                school = school,
                                scope = lessonRecord.scope,
                                lessonId = lessonRecord.id,
                                courseId = lessonRecord.courseId,
                                periodId = lessonRecord.periodId,
                                subjectId = lessonRecord.subjectId,
                            });
                        }
                    }
                    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.tnteractScore,
                                 tmdid = teacher.id,
                                 school = school,
                                 scope = lessonRecord.scope,
                                 lessonId = lessonRecord.id,
                                 courseId = lessonRecord.courseId,
                                 periodId = lessonRecord.periodId,
                                 subjectId = lessonRecord.subjectId,
                            }
                        }
                        };
                    }
                    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);
                }
            }
            catch (Exception ex)
            {
                await _dingding.SendBotMsg($"学生个人课例统计信息异常，{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
            }
        }

        public static async void DoAutoDeleteSchoolLessonRecord(LessonRecord lessonRecord, string scope, CosmosClient client, string school, string tmdid,
            Teacher teacher, NotificationService _notificationService, AzureServiceBusFactory _serviceBus, AzureStorageFactory _azureStorage, IConfiguration _configuration)
        {
            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
                    {
                        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;
                            }
                        }
                    }
                }
                else
                {
                    save = false;
                    school_lesson_expire = Constant.school_lesson_expire;
                }
                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";
                    Notification notification = new Notification
                    {
                        hubName = "hita",
                        type = "msg",
                        from = $"ies5:{Environment.GetEnvironmentVariable("Option:Location")}:private",
                        to = new List<string> { tmdid },
                        label = $"{biz}_lessonRecord",
                        body = new
                        {
                            location = $"{Environment.GetEnvironmentVariable("Option:Location")}",
                            biz = biz,
                            tmdid = tmdid,
                            tmdname = teacher.name,
                            scope = scope,
                            school = school,
                            schoolName = schoolBase.name,
                            sid = lessonRecord.id,
                            sname = lessonRecord.name,
                            stime = lessonRecord.startTime,
                            expire = lessonRecord.expire,
                            status = 1,
                            //day = school_lesson_expire,
                            time = now
                        }.ToJsonString(),
                        expires = DateTimeOffset.UtcNow.AddDays(7).ToUnixTimeSeconds()
                    };
                    var url = _configuration.GetValue<string>("HaBookAuth:CoreService:sendnotification");
                    var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
                    var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
                    var location = $"{Environment.GetEnvironmentVariable("Option:Location")}";
                    await _notificationService.SendNotification(clientID, clientSecret, location, url, notification); //站内发送消息

                    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.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.醍摩豆服務運維群組);
            }
        }
    }
}