TEAMModelOS/TEAMModelOS.SDK/Models/Service/StatisticsService.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.Threading.Tasks;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK.Models;

namespace TEAMModelOS.SDK
{
    public static class StatisticsService
    {
        /// <summary>
        /// 教师能力点操作
        /// </summary>
        public const string TeacherAility = "TeacherAility";
        /// <summary>
        /// 课堂实录
        /// </summary>
        public const string TeacherClass = "TeacherClass";
        /// <summary>
        /// 线下研修
        /// </summary>
        public const string OfflineRecord = "OfflineRecord";

        public static async Task SendServiceBus(string standard,string tmdid,string school,string update,int statistics, IConfiguration _configuration, AzureServiceBusFactory _serviceBus) {

            TeacherTrainChange change = new TeacherTrainChange
            {
                standard = standard,
                tmdid =tmdid,
                school =school,
                update = new HashSet<string>(new List<string> { update }),
                statistics = statistics
            };
            var messageChange = new ServiceBusMessage(change.ToJsonString());
            messageChange.ApplicationProperties.Add("name", "TeacherTrainChange");
            var ActiveTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
            await _serviceBus.GetServiceBusClient().SendMessageAsync(ActiveTask, messageChange);
        }

        public static async Task<List<(List<TeacherTrain> trains, List<RGroupList> yxtrain)>> StatisticsArea(AreaSetting setting, Area area, CosmosClient client, DingDing _dingDing,  HashSet<string> updates)
        {
           List<(List<TeacherTrain> trains, List<RGroupList> yxtrain)> teacherTrains = new List<(List<TeacherTrain> trains, List<RGroupList> yxtrain)>() ;
            List<School> schools = new List<School>();
            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School")
            .GetItemQueryIterator<School>(queryText: $"select value(c) from c where c.areaId='{area.id}'  ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
            {
                schools.Add(item);
            }
            await foreach ((List<TeacherTrain> trains, List<RGroupList> yxtrain) tarain in GetStatisticsSchool(schools, setting, area, client,_dingDing,updates))
            {
                teacherTrains.Add(tarain);
            }
            return teacherTrains;
        }
        private static async IAsyncEnumerable<(List<TeacherTrain> trains, List<RGroupList> yxtrain)> GetStatisticsSchool(List<School> schools, AreaSetting setting, Area area, CosmosClient client, DingDing _dingDing,  HashSet<string> updates)
        {
            foreach (var school in schools)
            {
                yield return await StatisticsSchool(school.id, setting, area, client,_dingDing,updates);
            }
        }
        public static async Task<(List<TeacherTrain> trains, List<RGroupList> yxtrain)> StatisticsSchool(string school, AreaSetting setting, Area area, CosmosClient client,DingDing _dingDing,HashSet<string> updates) {
            List<RGroupList> yxtrain = await GroupListService.GetGroupListMemberByType(client, "yxtrain", new List<string> { "school" }, $"{school}", _dingDing);
            List<TeacherTrain> trains = new List<TeacherTrain>();
            var members = yxtrain.SelectMany(x => x.members).ToList();
            if (members.Count <= 0)
            {
                return (trains, yxtrain);
            }
            
            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher")
             .GetItemQueryIterator<TeacherTrain>(queryText: $"select value(c) from c  ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"TeacherTrain-{school}") })) {
               
                trains.Add(item);
            }
            if (updates != null) {
                foreach (var up in updates)
                {
                    trains.ForEach(x => x.updateProperty.Add(up));
                }
            }
            var update = trains.FindAll(x => x.updateProperty.Count() > 0);
            var noupdate = trains.FindAll(x => x.updateProperty.Count() <=0);
            
            var unStatistics = members.Select(x => x.id).Except(trains.Select(x => x.id));
            List<TeacherTrain> teacherTrains = new List<TeacherTrain>();
            List<TeacherTrain> returnTrains = new List<TeacherTrain>();
            if (update.IsNotEmpty()) {
                teacherTrains.AddRange(update);
            }
            if (unStatistics != null) {
                foreach (string x in unStatistics) {
                    var member = members.Find(y => y.id.Equals(x));
                    teacherTrains.Add(new TeacherTrain
                    {   
                        id = x,
                        code = $"TeacherTrain-{school}",
                        tmdid = x,
                        name = member.name,
                        picture=member.picture,
                        school = school,
                        updateProperty = new HashSet<string> { TeacherAility,TeacherClass,OfflineRecord }
                    });
                }
            }
            List<Study> studies = new List<Study>();
            await foreach (var item in client.GetContainer("TEAMModelOS", "Common")
               .GetItemQueryIterator<Study>(queryText: $"select value(c) from c  ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Study-{school}") }))
            {
                studies.Add(item);
            }
            returnTrains = await GetStatisticsTeacher(teacherTrains, setting, area, client,studies);
            //await foreach (var tarain in GetStatisticsTeacher(teacherTrains, setting, area, client))
            //{
            //    returnTrains.Add(tarain);
            //}
            if (noupdate.IsNotEmpty())
            {
                returnTrains.AddRange(noupdate);
            }
            returnTrains.ForEach(x => x.groupName = members.Find(y => y.id.Equals(x.id))?.groupName);
            return (returnTrains, yxtrain); 
        }
        private static async Task<List<TeacherTrain>> GetStatisticsTeacher(List<TeacherTrain> trains, AreaSetting setting, Area area, CosmosClient client, List<Study> studies)
        {
            List<Task<TeacherTrain>> teachers = new List<Task<TeacherTrain>>();
            foreach (var train in trains)
            {
                teachers.Add(StatisticsTeacher(train, setting, area, client,studies));  //yield return await  StatisticsTeacher(  train,   setting,   area,   client);
            }
            await Task.WhenAll(teachers);
            return trains;
        }
        public static async Task<TeacherTrain> StatisticsTeacher(TeacherTrain train,  AreaSetting setting, Area area, CosmosClient client,List<Study> studies) {
            string _school = train.school;
            string _tmdid = train.tmdid;
           // TeacherTrain teacher_train = null;
            List<Task<TeacherTrain>> teachers = new List<Task<TeacherTrain>>();
            if (train.updateProperty.Count > 0) {
                foreach (string property in train.updateProperty) {
                    teachers.Add(DoProperty(train.updateProperty, property, setting, area, client, train,studies));
                }
                await   Task.WhenAll(teachers);
            }
            //每次都统计活动相关的数据。
            train= await DoActivity(train, setting, area, client, _school, _tmdid);
            train.totalTime = train.onlineTime + train.classTime + train.currency.submitTime + train.offlineTime;
            await client.GetContainer(Constant.TEAMModelOS, "Teacher").UpsertItemAsync<TeacherTrain>(train, new PartitionKey($"TeacherTrain-{_school}"));
            return train;
        }
        private static async Task<TeacherTrain> DoProperty(HashSet<string> updateProperty,string property, AreaSetting setting, Area area, CosmosClient client, TeacherTrain train ,List<Study> studies )
        {
            string _school = train.school;
            string _tmdid = train.tmdid;
            switch (property) {
                case TeacherAility:
                    train = await DoTeacherAility(train, setting, area, client, _school, _tmdid);
                    train.updateProperty.Remove(TeacherAility);
                    break;
                //课堂实录更新
                case TeacherClass:
                    train = await DoTeacherClass(train, setting, area, client, _school, _tmdid);
                    train.updateProperty.Remove(TeacherClass);
                    break;
                //线下研修
                case OfflineRecord:
                    train = await DoOfflineRecord(train, setting, area, client, _school, _tmdid,studies);
                    train.updateProperty.Remove(OfflineRecord);
                    break;
                default:
                    train.updateProperty.Remove(property);
                    break;
            }
            return train;
            
        }
        public static async Task<TeacherTrain> DoActivity(TeacherTrain train, AreaSetting setting, Area area, CosmosClient client, string _school, string _tmdid) {
            //问卷调查
            int surveyJoin=0;
            int voteJoin = 0;
            int examJoin = 0;
            int surveyDone = 0;
            int voteDone = 0;
            int examDone = 0;
            int surveyAreaJoin = 0;
            int voteAreaJoin = 0;
            int examAreaJoin = 0;
            int surveyAreaDone = 0;
            int voteAreaDone = 0;
            int examAreaDone = 0;



            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher")
                     .GetItemQueryIterator<StuActivity>(queryText: $"select c.owner, c.taskStatus from c where c.type = 'Survey' ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Activity-{_tmdid}") }))
            {
                if (!string.IsNullOrEmpty(item.owner))
                {
                    if (item.owner.Equals("school"))
                    {
                        surveyJoin += 1;
                        if (item.taskStatus > 0)
                        {
                            surveyDone += 1;
                        }
                    }
                    else if (item.owner.Equals("area"))
                    {
                        surveyAreaJoin += 1;
                        if (item.taskStatus > 0)
                        {
                            surveyAreaDone += 1;
                        }
                    }
                }
            }
            //评量检测
            await foreach (var item in client.GetContainer("TEAMModelOS", "Teacher")
              .GetItemQueryIterator<StuActivity>(queryText: $"select c.owner, c.taskStatus from c where c.type = 'ExamLite' ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Activity-{_tmdid}") }))
            {
                if (!string.IsNullOrEmpty(item.owner))
                {
                    if (item.owner.Equals("school"))
                    {
                        examJoin += 1;
                        if (item.taskStatus > 0)
                        {
                            examDone += 1;
                        }
                    }
                    else if (item.owner.Equals("area"))
                    {
                        examAreaJoin += 1;
                        if (item.taskStatus > 0)
                        {
                            examAreaDone += 1;
                        }
                    }
                }
            }
            //投票活动
            await foreach (var item in client.GetContainer("TEAMModelOS", "Teacher")
             .GetItemQueryIterator<StuActivity>(queryText: $"select c.owner, c.taskStatus from c where c.type = 'Vote' ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Activity-{_tmdid}") }))
            {
                if (!string.IsNullOrEmpty(item.owner))
                {
                    if (item.owner.Equals("school"))
                    {
                        voteJoin += 1;
                        if (item.taskStatus > 0)
                        {
                            voteDone += 1;
                        }
                    }
                    else if (item.owner.Equals("area"))
                    {
                        voteAreaJoin += 1;
                        if (item.taskStatus > 0)
                        {
                            voteAreaDone += 1;
                        }
                    }
                }
            }
            train.surveyJoin = surveyJoin;
            train.voteJoin = voteJoin;
            train.examJoin = examJoin;
            train.surveyDone = surveyDone;
            train.voteDone = voteDone;
            train.examDone = examDone;
            train.surveyAreaJoin = surveyAreaJoin;
            train.voteAreaJoin = voteAreaJoin;
            train.examAreaJoin = examAreaJoin;
            train.surveyAreaDone = surveyAreaDone;
            train.voteAreaDone = voteAreaDone;
            train.examAreaDone = examAreaDone;
            return train;
        }
        
        /// <summary>
        /// 课堂实录更新
        /// </summary>
        /// <param name="train"></param>
        /// <param name="setting"></param>
        /// <param name="area"></param>
        /// <param name="client"></param>
        /// <param name="_school"></param>
        /// <param name="_tmdid"></param>
        /// <returns></returns>
        public static async Task<TeacherTrain> DoOfflineRecord(TeacherTrain train, AreaSetting setting, Area area, CosmosClient client, string _school, string _tmdid, List<Study> studies) {
            //owner:  school  area
            //线下 学校研修活动
            List<StuActivity> activities = new List<StuActivity>();
            await foreach (var item in client.GetContainer("TEAMModelOS", "Teacher")
            .GetItemQueryIterator<StuActivity>(queryText: $"select value(c) from c where  c.type = 'Study' ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Activity-{_tmdid}") }))
            {
                activities.Add(item);
            }
            string insql = "";
            if (studies.IsEmpty()) {
                studies = new List<Study>();
                if (activities.IsNotEmpty())
                {
                    insql = $" where c.id in ({string.Join(",", activities.Select(o => $"'{o.id}'"))})";

                }
                await foreach (var item in client.GetContainer("TEAMModelOS", "Common")
                .GetItemQueryIterator<Study>(queryText: $"select value(c) from c {insql} ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Study-{_school}") }))
                {
                    studies.Add(item);
                }
            }
           
            List<StudyRecord> studyRecords = new List<StudyRecord>();
            await foreach (var item in client.GetContainer("TEAMModelOS", "Teacher")
            .GetItemQueryIterator<StudyRecord>(queryText: $"select value(c) from c {insql} ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"StudyRecord-{_tmdid}") }))
            {
                studyRecords.Add(item);
            }
            List<HomeworkRecord> homeworkRecords = new List<HomeworkRecord>();
            await foreach (var item in client.GetContainer("TEAMModelOS", "Teacher")
            .GetItemQueryIterator<HomeworkRecord>(queryText: $"select value(c) from c {insql} ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"HomeworkRecord-{_tmdid}") }))
            {
                homeworkRecords.Add(item);
            }
            List<OfflineRecord> offlines = new List<OfflineRecord>();
            activities.ForEach(item => {
                Study study = studies.Find(y=>y.id.Equals(item.id));
                StudyRecord studyRecord= studyRecords.Find(y => y.id.Equals(item.id));
                HomeworkRecord homeworkRecord= homeworkRecords.Find(y => y.id.Equals(item.id));
                Attachment attachment = homeworkRecord!=null ? homeworkRecord.content.Find(x => x.prime):null;
                if (!string.IsNullOrEmpty(item.owner) && study != null && !item.owner.Equals("area") )
                {
                    
                    OfflineRecord record = new OfflineRecord
                    {
                        id = item.id,
                        name = item.name,
                        done = item.taskStatus,
                        owner = item.owner
                    };
                    record.sethour = study.hour;
                    if (!string.IsNullOrEmpty(study.workId) ) {
                        record.haswork = 1;
                    }
                    if (null != studyRecord)
                    {
                        //通过获得学时
                        record.hour = studyRecord.status == 1 ? study.hour : 0;
                      
                        record.score = studyRecord.status;
                        if (record.score >= 0)
                        {
                            record.done = 1;
                        }
                        else {
                            record.score = -1;
                        }
                        //取消转换
                        //if (studyRecord.status == 1)
                        //{
                        //    record.score = 1;
                        //    record.done = 1;
                        //}
                        //if (studyRecord.status == 0)
                        //{
                        //    record.score = -1;
                        //}
                        //if (studyRecord.status == 2)
                        //{
                        //    record.score = 0;
                        //    record.done = 1;
                        //}
                    }
                    if (null != attachment)
                    {
                        record.url = attachment.url;
                        record.upload = 1;
                        record.hash = attachment.hash;
                        record.size = attachment.size;
                    }
                    offlines.Add(record);
                }
            });
            train.offlineTime = offlines.Select(x=>x.hour).Sum();
            train.offlineRecords= offlines;
            return train;
        }
        /// <summary>
        /// 课堂实录更新
        /// </summary>
        /// <param name="train"></param>
        /// <param name="setting"></param>
        /// <param name="area"></param>
        /// <param name="client"></param>
        /// <param name="_school"></param>
        /// <param name="_tmdid"></param>
        /// <returns></returns>
        public static async Task<TeacherTrain> DoTeacherClass(TeacherTrain train, AreaSetting setting, Area area, CosmosClient client, string _school, string _tmdid)
        {
            string code = $"ClassVideo-{_school}";
            ClassVideo classVideo = null;
            try {  classVideo = await client.GetContainer("TEAMModelOS", "Teacher").ReadItemAsync<ClassVideo>($"{_tmdid}", new PartitionKey(code)); 
            } catch (Exception ex) {
                classVideo = null;
            }
            if (classVideo != null && classVideo.files.IsNotEmpty())
            {
                //2021.11.17 15：05，与J哥确认，取课堂实录第一个。前端也只show第一个视频。
                var files = classVideo.files[0];
                if (files.score > 0)
                {
                    train.classTime= 5;
                }
                train.teacherClasses= new List<TeacherClass> { new Models.TeacherClass { url = files.url, score = files.score, hash = files.hash, name = files.name, size = files.size } };
            }
            return train;
        }
        
        public static async Task<TeacherTrain> DoTeacherAility(TeacherTrain train, AreaSetting setting,Area area ,  CosmosClient client,string _school,string _tmdid) {
            //视频播放

          
            List<string> abilityIds = new List<string> ();
            TeacherFile file = null;
            try
            {
                file = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<TeacherFile>(_tmdid, new PartitionKey($"TeacherFile-{_school}"));
            }
            catch (CosmosException )
            {
                file = new TeacherFile
                {
                    id = _tmdid,
                    code = $"TeacherFile-{_school}",
                    pk = "TeacherFile",
                    ttl = -1,

                };
                await client.GetContainer(Constant.TEAMModelOS, "Teacher").CreateItemAsync<TeacherFile>(file, new PartitionKey($"TeacherFile-{_school}"));
            }

            List<AbilitySub> abilitySubs= new List<AbilitySub> ();
            //认证材料
            await foreach (var item in client.GetContainer("TEAMModelOS", "Teacher")
                     .GetItemQueryIterator<AbilitySub>(queryText: $"select value(c) from c ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"AbilitySub-{_school}-{_tmdid}") }))
            {
                abilitySubs.Add(item);
               
            }
            List<Ability> abilities = new List<Ability>();
            string insql = "";
            if (abilitySubs.IsNotEmpty()) {
                 insql =$" where c.id in ({string.Join(",", abilitySubs.Select(o => $"'{o.id}'"))})";
           
            }
            await foreach (var item in client.GetContainer("TEAMModelOS", "Normal")
                .GetItemQueryIterator<Ability>(queryText: $"select value(c) from c {insql} ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Ability-{area.standard}") }))
            {
                abilities.Add(item);

            }
            Currency currency= new Currency();
            Currency currencyAll = new Currency();
            abilitySubs.ForEach(item => {
                int currencyInt = item.from == 1 ? 1 : 0;
                Ability ability = abilities.Find(x=>x.id.Equals(item.id));
                if (ability != null) {
                    if (ability != null)
                    {
                        currencyInt = item.from == 0 ? ability.currency : 1;
                    }
                    else
                    {
                        currencyInt = 0;

                    }
                    if (item.uploads.IsNotEmpty())
                    {
                        if (currencyInt == 1)
                        {
                            currency.uploadDone += item.uploads.Count;
                        }
                        currencyAll.uploadDone += item.uploads.Count;
                    }
                    if (item.exerciseScore > 0)
                    {
                        if (currencyInt == 1)
                        {
                            currency.exerciseAbility += 1;
                            currency.learnAbility += item.abilityCount;
                        }
                        currencyAll.exerciseAbility += 1;
                        currencyAll.learnAbility += item.abilityCount;
                    }
                    List<TeacherHprecord> hprecords = new List<TeacherHprecord>();
                    TeacherAility teacherAility = new Models.TeacherAility
                    {
                        id = ability.id,
                        currency = currencyInt,
                        no = ability.no,
                        name = ability.name,
                        dimension = ability.dimension,
                        zpscore = item.self,
                        hprecord = hprecords,
                        uploadHas = item.uploads.Count
                    };

                    if (file != null)
                    {
                        long view = 0;
                        file.fileRecords.ForEach(record => {
                            var abilityVideo = record.files.FindAll(x => x.abilityId.Equals(item.id));
                            if (abilityVideo.IsNotEmpty())
                            {
                                view += record.view;
                            }
                        });
                        //能力点学时限制
                        int limit = ability.hour * setting.lessonMinutes;
                        //如果超过 8* 45分钟学时，则直接赋值360（limit）分钟。
                        view = view / 60;
                        view = view > limit ? limit : view;
                        teacherAility.videoTime = view;
                        teacherAility.limitTime = ability.hour;
                        teacherAility.onlineTime = view / setting.lessonMinutes;
                    }
                    if (item.otherScore.IsNotEmpty())
                    {
                        var schoolScore = item.otherScore.Where(x => x.roleType.Equals("school")).FirstOrDefault();
                        if (schoolScore != null && schoolScore.score >= 0)
                        {
                            teacherAility.xzscore = schoolScore.score;
                            teacherAility.xztime = schoolScore.time;
                            teacherAility.xztmdid = schoolScore.tmdid;
                            teacherAility.xztmdname = schoolScore.tmdname;

                        }
                        var hprecord = item.otherScore.FindAll(x => x.roleType.Equals("member")).Select(y => new TeacherHprecord { tmdid = y.tmdid, tmdname = y.tmdname, score = y.score });
                        if (hprecord != null)
                        {
                            var no = hprecord.Where(x => x.score == 0) != null ? hprecord.Where(x => x.score == 0).Count() : 0;
                            var hg = hprecord.Where(x => x.score == 1) != null ? hprecord.Where(x => x.score == 1).Count() : 0;
                            var yx = hprecord.Where(x => x.score == 2) != null ? hprecord.Where(x => x.score == 2).Count() : 0;
                            if (no == hg && hg == yx && no == 0)
                            {
                                teacherAility.hpscore = -1;
                            }
                            else if (no == hg && hg == yx && no != 0)
                            {
                                teacherAility.hpscore = 2;
                            }
                            else
                            {
                                bool ok = false;
                                List<int> arr = new List<int>() { yx, hg, no };
                                int max = arr.Max();
                                if (max == yx && !ok)
                                {
                                    teacherAility.hpscore = 2;
                                    ok = true;
                                }
                                if (max == hg && !ok)
                                {
                                    teacherAility.hpscore = 1;
                                    ok = true;
                                }
                                if (max == no && !ok)
                                {
                                    teacherAility.hpscore = 0;
                                    ok = true;
                                }
                            }
                            teacherAility.hprecord.AddRange(hprecord);
                        }
                    }
                    if (currencyInt == 1)
                    {
                        currency.subCount += 1;
                        currency.uploadTotal += ability.stds.FindAll(x => x.task.IsNotEmpty()).Select(y => y.task).Count();
                        currency.teacherAilities.Add(teacherAility);
                    }
                    currencyAll.subCount += 1;
                    currencyAll.uploadTotal += ability.stds.FindAll(x => x.task.IsNotEmpty()).Select(y => y.task).Count();
                    currencyAll.teacherAilities.Add(teacherAility);
                }
            });
            train.currency = currency;
            train.currencyAll = currencyAll;
            //如果总分钟数超过20学时，则直接复制20学时。
            var videoTime = (int)train.currency.videoTime / setting.lessonMinutes;
            train.onlineTime = videoTime > setting.onlineTime ? setting.onlineTime:videoTime;
            var bhg = train.currency.teacherAilities.FindAll(x => x.xzscore > 0);
            if (bhg.IsNotEmpty()&& bhg.Count == train.currency.subCount)
            {
                ///要全部合格才能获得学时。
                train.currency.submitTime = setting.submitTime;
                train.currencyAll.submitTime = setting.submitTime;
            }
            return train;
        }
        
    }
}