TEAMModelOS/TEAMModelOS.Function/CosmosDBTriggers/TriggerHomework.cs

using Microsoft.Azure.Cosmos;
using Azure.Messaging.ServiceBus;
using Microsoft.Azure.Documents;
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;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK.Models;
using TEAMModelOS.SDK.Models.Cosmos;
using TEAMModelOS.SDK.Models.Service;
using TEAMModelOS.SDK.Models.Service.BI;
using TEAMModelOS.Function;
namespace TEAMModelOS.CosmosDBTriggers
{
    public static class TriggerHomework
    {
        public static async Task Trigger(CoreAPIHttpService _coreAPIHttpService, AzureServiceBusFactory _serviceBus, AzureStorageFactory _azureStorage, DingDing _dingDing,
                    CosmosClient client, JsonElement input, TriggerData tdata, AzureRedisFactory _azureRedis, IConfiguration _configuration)
        {
            try
            {
                if ((tdata.status != null && tdata.status.Value == 404))
                {
                    await client.GetContainer(Constant.TEAMModelOS, "Common").DeleteItemStreamAsync(tdata.id, new Microsoft.Azure.Cosmos.PartitionKey(tdata.code));
                    ActivityList data = input.ToObject<ActivityList>();
                    //await IESActivityService.DeleteActivity(_coreAPIHttpService, client, _dingDing, data);
                    var table_cancel = _azureStorage.GetCloudTableClient().GetTableReference("ChangeRecord");
                    List<ChangeRecord> records = await table_cancel.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", tdata.id } });
                    foreach (var record in records)
                    {
                        try
                        {
                            await table_cancel.DeleteSingle<ChangeRecord>(record.PartitionKey, record.RowKey);
                            await _serviceBus.GetServiceBusClient().CancelMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), record.sequenceNumber);

                        }
                        catch (Exception)
                        {
                            continue;
                        }
                    }

                    await BIStats.SetTypeAddStats(client, _dingDing, tdata.school, "Homework", -1, careDate: tdata.startTime);//BI统计增/减量
                    return;
                }
                var adid = tdata.id;
                var adcode = "";
                string blobcntr = null;
                if (tdata.scope.Equals("school"))
                {
                    adcode = $"Activity-{tdata.school}";
                    blobcntr = tdata.school;
                }
                else
                {
                    adcode = $"Activity-{tdata.creatorId}";
                    blobcntr = tdata.creatorId;
                }
                //await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}作业活动【{tdata.name}-{tdata.id}-ttl={tdata.ttl}】正在操作", GroupNames.醍摩豆服務運維群組);
                Homework work = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<Homework>(tdata.id, new Microsoft.Azure.Cosmos.PartitionKey($"{tdata.code}"));
                var table = _azureStorage.GetCloudTableClient().GetTableReference("ChangeRecord");
                if (work != null)
                {
                    string PartitionKey = string.Format("{0}{1}{2}", work.code, "-", work.progress);
                    List<ChangeRecord> changeRecords = await table.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", tdata.id }, { "PartitionKey", PartitionKey } });
                    switch (work.progress)
                    {
                        case "pending":
                            var messageWork = new ServiceBusMessage(new { tdata.id, progress = "going", tdata.code }.ToJsonString());
                            messageWork.ApplicationProperties.Add("name", "Homework");
                            if (changeRecords.Count > 0)
                            {
                                try
                                {
                                    await _serviceBus.GetServiceBusClient().CancelMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), changeRecords[0].sequenceNumber);
                                }
                                catch (Exception)
                                {
                                }
                                long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWork, DateTimeOffset.FromUnixTimeMilliseconds(tdata.startTime));
                                changeRecords[0].sequenceNumber = start;
                                await table.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
                            }
                            else
                            {
                                long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWork, DateTimeOffset.FromUnixTimeMilliseconds(tdata.startTime));
                                ChangeRecord changeRecord = new()
                                {
                                    RowKey = tdata.id,
                                    PartitionKey = PartitionKey,
                                    sequenceNumber = start,
                                    msgId = messageWork.MessageId
                                };
                                await table.Save<ChangeRecord>(changeRecord);
                            }

                            break;
                        case "going":
                            try {
                                await Activity(_coreAPIHttpService, _serviceBus, _dingDing, client, _configuration, work);
                                var messageWorkEnd = new ServiceBusMessage(new { id = tdata.id, progress = "finish", code = tdata.code }.ToJsonString());
                                messageWorkEnd.ApplicationProperties.Add("name", "Homework");
                                if (changeRecords.Count > 0)
                                {
                                    long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWorkEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
                                    try
                                    {
                                        await _serviceBus.GetServiceBusClient().CancelMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), changeRecords[0].sequenceNumber);
                                    }
                                    catch (Exception)
                                    {
                                    }
                                    changeRecords[0].sequenceNumber = end;
                                    await table.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
                                }
                                else
                                {
                                    long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageWorkEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
                                    ChangeRecord changeRecord = new()
                                    {
                                        RowKey = tdata.id,
                                        PartitionKey = PartitionKey,
                                        sequenceNumber = end,
                                        msgId = messageWorkEnd.MessageId
                                    };
                                    await table.Save<ChangeRecord>(changeRecord);
                                }
                                if (work!=null && work.scope.Equals("private"))
                                {
                                    await SystemService.RecordAccumulateData(_azureRedis, _dingDing, new SDK.Models.Dtos.Accumulate { client="web", count=1, id=work.id, key="homework-going", name=work.name, scope="teacher", target=work.creatorId });
                                }
                            } catch (Exception e) {
                                await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修作业活动going{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
                            }
                            finally {
                                string pkey = string.Format("{0}{1}{2}", work.code, "-", "pending");
                                await table.DeleteSingle<ChangeRecord>(pkey, tdata.id);
                            }
                            
                            
                            //if (bustasks.IsNotEmpty())
                            //{
                            //    await Task.WhenAll(bustasks);
                            //}
                            break;
                        case "finish":
                            try {
                                await Activity(_coreAPIHttpService, _serviceBus, _dingDing, client, _configuration, work);
                                List<(string pId, List<string> gid)> gls = new List<(string pId, List<string> gid)>();
                                if (work.groupLists.Count > 0)
                                {
                                    var group = work.groupLists;
                                    foreach (var gp in group)
                                    {
                                        foreach (KeyValuePair<string, List<string>> pp in gp)
                                        {
                                            gls.Add((pp.Key, pp.Value));
                                        }
                                    }
                                }
                                //处理家庭作业活动结束统计账户信息
                                if (work.staffIds.Count == 0)
                                {
                                    List<FMember> idsList = await GroupListService.GetFinishMemberInfo(_coreAPIHttpService, client, _dingDing, work.school, work.classes, work.stuLists, work.tchLists, gls);
                                    work.staffIds = idsList;

                                    await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync<Homework>(work, work.id, new Microsoft.Azure.Cosmos.PartitionKey(work.code));
                                }
                            } catch (Exception e) {
                                await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修作业活动finish{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);

                            } finally {
                                string pk = string.Format("{0}{1}{2}", work.code, "-", "going");
                                await table.DeleteSingle<ChangeRecord>(pk, tdata.id);
                            }
                            
                                                
                            break;
                    }

                }
            }
            catch (CosmosException e)
            {
                await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-CosmosDB异常{e.Message}\n{e.StackTrace}\n{e.StatusCode}", GroupNames.醍摩豆服務運維群組);
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修作业活动异常{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
            }
        }

        private static async Task Activity(CoreAPIHttpService _coreAPIHttpService, AzureServiceBusFactory _serviceBus, DingDing _dingDing, CosmosClient client, IConfiguration _configuration, Homework work)
        {
            List<(string pId, List<string> gid)> ps = new List<(string pId, List<string> gid)>();
            if (work.groupLists.Count > 0)
            {
                var group = work.groupLists;
                foreach (var gp in group)
                {
                    foreach (KeyValuePair<string, List<string>> pp in gp)
                    {
                        ps.Add((pp.Key, pp.Value));
                    }
                }
            }
            List<string> classes = ExamService.getClasses(work.classes, work.stuLists);
            (List<RMember> tmdids, List<RGroupList> classLists) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, classes, work.school, ps);
            var addStudentsCls = tmdids.FindAll(x => x.type == 2);
            var addTmdidsCls = tmdids.FindAll(x => x.type == 1);
            //List<StuActivity> stuActivities = new();
            //List<StuActivity> tmdActivities = new();
            //List<StuActivity> tchActivities = new();
            //List<StuActivity> tac = new();
            List<string> tIds = addStudentsCls.Select(x => x.id).ToList();
            /*
                         await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIteratorSql<StuActivity>(queryText: $"select value(c) from c where c.id ='{work.id}' and c.type = 'Homework'"))
            {
                tac.Add(item);

            }
            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIteratorSql<StuActivity>(queryText: $"select value(c) from c where c.id ='{work.id}' and c.type = 'Homework'"))
            {
                tac.Add(item);

            }
            List<string> sub = new();
            if (work.tchLists.Count == 0)
            {
                if (work.targets.Count > 0)
                {
                    foreach (var course in work.targets)
                    {
                        var info = course.ToObject<List<string>>();
                        if (info.Count > 1)
                        {
                            sub.Add(info[0]);
                        }
                    }
                }
            }

            if (addTmdidsCls.IsNotEmpty())
            {
                addTmdidsCls.ForEach(x =>
                {
                    HashSet<string> classIds = new HashSet<string>();
                    classLists.ForEach(z =>
                    {
                        z.members.ForEach(y =>
                        {
                            if (y.id.Equals(x.id) && y.type == 1)
                            {
                                classIds.Add(z.id);
                            }
                        });
                    });
                    int sta = -1;
                    if (tac.Count > 0)
                    {
                        StuActivity activity = tac.Where(t => t.code.Equals($"Activity-{x.id}")).FirstOrDefault();
                        if (activity != null)
                        {
                            sta = activity.taskStatus;
                        }
                    }
                    tmdActivities.Add(new StuActivity
                    {
                        pk = "Activity",
                        id = work.id,
                        code = $"Activity-{x.id}",
                        type = "Homework",
                        name = work.name,
                        startTime = work.startTime,
                        endTime = work.endTime,
                        scode = work.code,
                        scope = work.scope,
                        school = work.school,
                        creatorId = work.creatorId,
                        subjects = sub,
                        blob = work.blob,
                        owner = work.owner,
                        createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
                        taskStatus = sta,
                        mustSubmit = work.mustSubmit,
                        classIds = classIds.ToList()
                    });
                });
            }
            if (addStudentsCls.IsNotEmpty())
            {
                addStudentsCls.ForEach(x =>
                {
                    HashSet<string> classIds = new HashSet<string>();
                    classLists.ForEach(z =>
                    {
                        z.members.ForEach(y =>
                        {
                            if (y.id.Equals(x.id) && y.type == 2)
                            {
                                classIds.Add(z.id);
                            }
                        });
                    });
                    int sta = -1;
                    if (tac.Count > 0)
                    {
                        StuActivity activity = tac.Where(t => t.code.Equals($"Activity-{x.code.Replace("Base-", "")}-{x.id}")).FirstOrDefault();
                        if (activity != null)
                        {
                            sta = activity.taskStatus;
                        }
                    }

                    stuActivities.Add(new StuActivity
                    {
                        pk = "Activity",
                        id = work.id,
                        code = $"Activity-{x.code.Replace("Base-", "")}-{x.id}",
                        type = "Homework",
                        name = work.name,
                        startTime = work.startTime,
                        endTime = work.endTime,
                        scode = work.code,
                        scope = work.scope,
                        school = work.school,
                        creatorId = work.creatorId,
                        subjects = sub,
                        blob = work.blob,
                        owner = work.owner,
                        createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
                        taskStatus = sta,
                        classIds = classIds.ToList(),
                        mustSubmit = work.mustSubmit
                    });
                });
            }
             */
            (List<RMember> tchList, List<RGroupList> classInfos) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, work.tchLists, work.school, ps);
            (string standard, List<string> tmdids, string school, List<string> update, int statistics) list = (null, null, null, new List<string> { StatisticsService.OfflineRecord }, 0);
            if (tchList.IsNotEmpty())
            {
                list.tmdids = tchList.Select(x => x.id).ToList();
                School school = null;
                if (!string.IsNullOrEmpty(work.school))
                {
                    school = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>(work.school, new Microsoft.Azure.Cosmos.PartitionKey("Base"));
                    list.school = school.id;
                    list.standard = school.standard;
                }
                /*
                 tchList.ForEach(x =>
                {
                    HashSet<string> classIds = new();
                    classInfos.ForEach(z =>
                    {
                        z.members.ForEach(y =>
                        {
                            if (y.id.Equals(x.id) && y.type == 1)
                            {
                                classIds.Add(z.id);
                            }
                        });
                    });
                    int sta = -1;
                    if (tac.Count > 0)
                    {
                        StuActivity activity = tac.Where(t => t.code.Equals($"Activity-{x.id}")).FirstOrDefault();
                        if (activity != null)
                        {
                            sta = activity.taskStatus;
                        }
                    }
                    tchActivities.Add(new StuActivity
                    {
                        pk = "Activity",
                        id = work.id,
                        code = $"Activity-{x.id}",
                        type = "Homework",
                        name = work.name,
                        startTime = work.startTime,
                        endTime = work.endTime,
                        scode = work.code,
                        scope = work.scope,
                        school = work.school,
                        creatorId = work.creatorId,
                        subjects = new List<string> { "" },
                        blob = work.blob,
                        owner = work.owner,
                        createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
                        taskStatus = sta,
                        classIds = classIds.ToList()
                    });

                });
                 */
            }
            //await IESActivityService.SaveStuActivity(client, _dingDing, stuActivities, tmdActivities, tchActivities);
            await StatisticsService.SendServiceBus(list, _configuration, _serviceBus, client);

        }

    }
}