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(LessonRecord lessonRecord, string scope, CosmosClient client, string school, string tmdid,
            Teacher teacher, NotificationService _notificationService, AzureServiceBusFactory _serviceBus, AzureStorageFactory _azureStorage, IConfiguration _configuration, LessonBase lessonBase)
        {
            var stuids = lessonBase.student.Where(x => x.type == 2).Select(x => new IdNameCode { id = x.id ,code=x.school});
            if (stuids.Any()) {
                stuids.ToList().ForEach(x => {
                    x.code = string.IsNullOrWhiteSpace(x.code) ? school : x.code;
                });
            }
            var groups= stuids.Where(z=>!string.IsNullOrWhiteSpace(z.code)).GroupBy(x => x.code).Select(y=>new { code=y.Key,list=y.ToList()});
            List<LessonStudentRecord> lessonStudentRecords = new List<LessonStudentRecord>();
            foreach (var group in groups) {
               
                string stusql = $"select value(c) from c where c.id in({string.Join(",",group.list.Select(x=>$"'{x.id}'"))})";
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Student).GetItemQueryIterator<LessonStudentRecord>(queryText: stusql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"LessonStudentRecord-{group.code}") })) {
                    lessonStudentRecords.Add(item);
                }

            }
            var tmdids = lessonBase.student.Where(x => x.type == 1).Select(x => new { id = x.id });
            if (tmdids.Any()) {
                string tmdsql = $"select value(c) from c where c.id in({string.Join(",", tmdids.Select(x => $"'{x}'"))})";
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Student).GetItemQueryIterator<LessonStudentRecord>(queryText: tmdsql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"LessonStudentRecord") }))
                {
                    lessonStudentRecords.Add(item);
                }
            }
            List<Task<ItemResponse<LessonStudentRecord>>> records = new List<Task<ItemResponse<LessonStudentRecord>>>();
            stuids.ToList().ForEach(x => {
                var record = lessonStudentRecords.Find(l => l.id.Equals(x.id) && l.code.Equals($"LessonStudentRecord-{x.code}"));
                if (record != null)
                {
                    record.records.Add(new StudentRecord {
                        tmdid = teacher.id,
                        tmdname = teacher.name,
                        name = lessonRecord.name,
                        school = lessonRecord.school,
                        scope = lessonRecord.scope,
                        lessonId = lessonRecord.id,
                        courseId = lessonRecord.courseId,
                        periodId = lessonRecord.periodId,
                        subjectId = lessonRecord.subjectId,
                    });
                }
                else { 
                    
                }
            });
            tmdids.ToList().ForEach(x => {
                var record = lessonStudentRecords.Find(l => l.id.Equals(x.id) && l.code.Equals($"LessonStudentRecord"));
            });
        }

        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;
            }
            //删除数据的情况
            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"))
                {
                    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;
                    /*if (!count.courseIds.Contains(data.courseId))
                    {
                        count.courseIds.Add(data.courseId);
                        count.beginCount[day] += 1;
                    }*/


                    await client.GetContainer("TEAMModelOS", tbname).ReplaceItemAsync(count, count.id, new PartitionKey(code));
                }
                else
                {
                    LessonCount count = new LessonCount
                    {
                        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.醍摩豆服務運維群組);
            }
        }
    }
}