TEAMModelOS/TEAMModelOS/Controllers/Normal/AbilityStatisticsController.cs

using Azure.Cosmos;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Options;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Text.Json;
using System.Threading.Tasks;
using TEAMModelOS.Models;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK;
using TEAMModelOS.SDK.Models;
using TEAMModelOS.SDK.Extension;
using static TEAMModelOS.Controllers.SchoolTeacherController;
using HTEXLib.COMM.Helpers;
using TEAMModelOS.Filter;
using static TEAMModelOS.Controllers.AbilitySubController;
using Microsoft.AspNetCore.Authorization;
using TEAMModelOS.SDK.Models.Service;
using ScTeacher = TEAMModelOS.SDK.Models.ScTeacher;
using static TEAMModelOS.SDK.StatisticsService;
using Azure.Messaging.ServiceBus;
using Microsoft.Extensions.Configuration;

namespace TEAMModelOS.Controllers
{
    [ProducesResponseType(StatusCodes.Status200OK)]
    [ProducesResponseType(StatusCodes.Status400BadRequest)]

    [Route("research")]
    [ApiController]
    public class AbilityStatisticsController : ControllerBase
    {
        private readonly AzureCosmosFactory _azureCosmos;
        private readonly DingDing _dingDing;
        private readonly Option _option;
        private readonly CoreAPIHttpService _coreAPIHttpService;
        private readonly HttpTrigger _httpTrigger;
        private readonly AzureStorageFactory _azureStorage;
        public IConfiguration _configuration { get; set; }
        private readonly AzureServiceBusFactory _serviceBus;
        private readonly ScsStudyApisService _scsStudyApisService;
        public AbilityStatisticsController(ScsStudyApisService scsStudyApisService, AzureStorageFactory azureStorage, HttpTrigger httpTrigger, CoreAPIHttpService coreAPIHttpService, AzureCosmosFactory azureCosmos, SnowflakeId snowflakeId, DingDing dingDing, IOptionsSnapshot<Option> option,
            AzureServiceBusFactory serviceBus, IConfiguration configuration)
        {
            _azureCosmos = azureCosmos;
            _dingDing = dingDing;
            _option = option?.Value;
            _coreAPIHttpService = coreAPIHttpService;
            _httpTrigger = httpTrigger;
            _azureStorage = azureStorage; 
            _serviceBus = serviceBus;
            _configuration = configuration;
            _scsStudyApisService = scsStudyApisService;
        }
        /// <summary>
        /// 更新教师最终学习分数。
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [Authorize(Roles = "IES")]
        [HttpPost("upsert-teacher-finalScore")]
        [AuthToken(Roles = "admin,teacher", Permissions = "train-appraise")]
        public async Task<IActionResult> UpsertFinalScore(JsonElement request)
        {
            var (userid, name, picture, school) = HttpContext.GetAuthTokenInfo();
            var client = _azureCosmos.GetCosmosClient();
            if (!request.TryGetProperty("finalScore", out JsonElement _finalScore)) return BadRequest();
            if (!request.TryGetProperty("tmdids", out JsonElement _tmdids)) return BadRequest();
            int finalScore = -999;
            int.TryParse($"{_finalScore}", out finalScore);
            List<string> tmdids = _tmdids.ToObject<List<string>>();
            if (tmdids.IsNotEmpty() && finalScore >= -1 && finalScore <= 2)
            {
                List<TeacherTrain> trains = new List<TeacherTrain>();
                string insql = $"select value(c) from c where c.id in ({string.Join(",", tmdids.Select(x => $"'{x}'"))})";
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher")
                    .GetItemQueryIterator<TeacherTrain>(queryText: insql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"TeacherTrain-{school}") }))
                {
                    trains.Add(item);
                }
                List<Task<ItemResponse<TeacherTrain>>> teacherTrains = new List<Task<ItemResponse<TeacherTrain>>>();
                trains.ForEach(x => {
                    x.finalScore = finalScore;
                    teacherTrains.Add(client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync(x, x.id, new PartitionKey(x.code)));
                });
                int pagesize = 50;
                if (teacherTrains.Count <= pagesize)
                {
                    await Task.WhenAll(teacherTrains);
                }
                else
                {
                    int pages = (teacherTrains.Count + pagesize) / pagesize; //256是批量操作最大值，pages = (total + max -1) / max;
                    for (int i = 0; i < pages; i++)
                    {
                        var listssb = teacherTrains.Skip((i) * pagesize).Take(pagesize).ToList();
                        await Task.WhenAll(listssb);
                    }
                }
                return Ok(new { status = 200 });
            }
            else
            {
                return Ok(new { });
            }
        }


        /// <summary>
        /// 提交学习总结、。
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("upsert-teacher-summary")]
        [Authorize(Roles = "IES")]
        [AuthToken(Roles = "teacher,admin,area")]
        public async Task<IActionResult> UpsertSummary(JsonElement request)
        {
            var client = _azureCosmos.GetCosmosClient();
            request.TryGetProperty("summary", out JsonElement _summary);
            if (string.IsNullOrEmpty($"{_summary}"))
            {
                return BadRequest();
            }
            var (userid, name, picture, school) = HttpContext.GetAuthTokenInfo();
            if (!HttpContext.Items.TryGetValue("Standard", out object standard)) return BadRequest();
            try
            {
                TeacherTrain teacherTrain = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<TeacherTrain>(userid, new PartitionKey($"TeacherTrain-{school}"));
                teacherTrain.nickname = name;
                teacherTrain.name = name;

                var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
                List<ScTeacher> teachers = await table.FindListByDict<ScTeacher>(new Dictionary<string, object>() { { "PartitionKey", "ScTeacher" }, { "schoolCode", school }, { "tmdid", $"{teacherTrain.id}" } });
                if (teachers.Any())
                {
                    teacherTrain.name = teachers[0].TeacherName;
                }
                teacherTrain.picture = picture;
                teacherTrain.summary = $"{_summary}";
                await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<TeacherTrain>(teacherTrain, userid, new PartitionKey($"TeacherTrain-{school}"));
                return Ok(new { status = 200 });
            }
            catch (CosmosException ex)
            {
                return Ok(new { error = 1, msg = "你没有学习记录" });
            }
        }

        /// <summary>
        /// 区级数据统计
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        //[HttpPost("statistics-area-simple")]
        [HttpPost("statistics-area-quick")]
        [AuthToken(Roles = "teacher,admin,area")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> StatisticsAreaSimple(JsonElement request)
        {
            var (userid, _, _, _) = HttpContext.GetAuthTokenInfo();
            request.TryGetProperty("standard", out JsonElement _standard);
            string standard = $"{_standard}";
            if (string.IsNullOrEmpty(standard))
            {
                return BadRequest();
            }
            var client = _azureCosmos.GetCosmosClient();
            Area area = null;
            string sql = $"select value(c) from c where c.standard='{standard}'";
            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Area>(queryText: sql,
                  requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-Area") }))
            {
                area = item;
            }
            AreaSetting setting = null;
            if (area != null)
            {
                try
                {
                    setting = await client.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<AreaSetting>(area.id, new PartitionKey("AreaSetting"));
                }
                catch (CosmosException)
                {
                    setting = null;
                }
            }
            if (setting == null)
            {
                setting = new AreaSetting
                {
                    allTime = 50,
                    classTime = 5,
                    submitTime = 15,
                    onlineTime = 20,
                    offlineTime = 10,
                    lessonMinutes = 45,
                };
            }

            try
            {
                List<TeacherTrain> teacherTrains = new List<TeacherTrain>();
                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);
                }
                List<Task<(List<TeacherTrain> trains, List<RGroupList> yxtrain)>> trains = new List<Task<(List<TeacherTrain> trains, List<RGroupList> yxtrain)>>();
                int countArea = 0;
                int appraiseArea = 0;
                List<SchoolInfos> schoolInfos = new List<SchoolInfos>();
                foreach (var school in schools)
                {

                    schoolInfos.Add(new SchoolInfos { schoolId = school.id, schoolName = school.name, picture = school.picture });
                    //增加评审人员总人数，学习总人数。
                    trains.Add(StatisticsService.StatisticsSchool(_coreAPIHttpService, school.id, setting, area, client, _dingDing, null));
                }
                int pagesize = 100;
                if (trains.Count <= pagesize)
                {
                    (List<TeacherTrain> trains, List<RGroupList> yxtrain)[] tasks = await Task.WhenAll(trains);
                    tasks.ToList().ForEach(x => {
                        teacherTrains.AddRange(x.trains);
                        schoolInfos.ForEach(y => {
                            var list = x.yxtrain.Find(z => z.school.Equals(y.schoolId));
                            if (list != null)
                            {
                                y.trainCount = list.members.Count;
                            }
                        });
                    });
                }
                else
                {
                    int pages = (trains.Count + pagesize) / pagesize; //256是批量操作最大值，pages = (total + max -1) / max;
                    for (int i = 0; i < pages; i++)
                    {
                        var listssb = trains.Skip((i) * pagesize).Take(pagesize).ToList();
                        (List<TeacherTrain> trains, List<RGroupList> yxtrain)[] tasks = await Task.WhenAll(listssb);
                        tasks.ToList().ForEach(x => {
                            teacherTrains.AddRange(x.trains);
                            schoolInfos.ForEach(y => {
                                var list = x.yxtrain.Find(z => z.school.Equals(y.schoolId));
                                if (list != null)
                                {
                                    y.trainCount = list.members.Count;
                                }
                            });
                        });
                    }
                }
                long totalTime = teacherTrains.Select(x => x.totalTime).Sum();
                int hgcount = teacherTrains.Where(x => x.finalScore == 1 || x.finalScore == 2).Count();
                setting.accessConfig = null;



                List<dynamic> dynamics = new List<dynamic>();
                teacherTrains.ForEach(x => {
                    x.schoolName = schools.Find(s => s.id.Equals(x.school))?.name;
                    x.currency.videoTime = (int)x.currency.videoTime;
                    x.currency.teacherAilities.ForEach(y => {
                        y.videoTime = (int)y.videoTime;
                        y.onlineTime = (int)y.onlineTime;
                        y.debateOrther = y.debateOrther > 0 ? y.debateOrther : 0;
                    });
                    dynamic dynamic = new {
                        x.schoolName,
                        x.classTime,
                        x.finalScore,
                        x.name,
                        x.offlineTime,
                        x.onlineTime,
                        x.school,
                        x.id,
                        x.totalTime,
                        currency = new {
                            x.currency.submitTime,
                            x.currency.exerciseAbility,
                            x.currency.learnAbility,
                            x.currency.uploadDone,
                            x.currency.uploadTotal,
                            x.currency.videoTime,
                            teacherAilities = x.currency.teacherAilities.Select(t => new {
                                t.onlineTime,
                                t.videoTime,
                                t.no,
                                t.name,
                                t.dimension,
                                t.zpscore, t.xzscore, t.hpscore
                            }),
                        },
                        offlineCountNo = x.offlineRecords.Where(o => o.haswork == 1 && string.IsNullOrWhiteSpace(o.url)).Count(),
                        offlineCountOk = x.offlineRecords.Where(o => o.haswork == 1 && !string.IsNullOrWhiteSpace(o.url)).Count(),
                        teacherClasseCount = x.teacherClasses.Count
                    };
                    dynamics.Add(dynamic);
                });
                //var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
                //var ScTeachers = await table.FindListByDict<ScTeacher>(new Dictionary<string, object>() { { "PartitionKey", "ScTeacher" }, { "areaId", $"{setting.id}" } });
                //var ttt = ScTeachers.Select(x => x.tmdid).Except(teacherTrains.Select(x => x.id));

                return Ok(new { teacherTrains = dynamics, setting, schools = schoolInfos, totalTime, hgcount, teacherCount = countArea, appraiseCount = appraiseArea });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，UpsertSubmitScore/UpsertSubmitScore()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
                return BadRequest(new { ex.Message, ex.StackTrace });

            }
        }


      

        /// <summary>
        /// 区级数据统计
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        //[HttpPost("statistics-area-quick")]
        [HttpPost("statistics-area-simple")]
        [AuthToken(Roles = "teacher,admin,area")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> StatisticsAreaQuick(JsonElement request) {
            var (userid, _, _, _) = HttpContext.GetAuthTokenInfo();
            request.TryGetProperty("standard", out JsonElement _standard);
            string standard = $"{_standard}";
            if (string.IsNullOrEmpty(standard))
            {
                return BadRequest();
            }
            var client = _azureCosmos.GetCosmosClient();
            Area area = null;
            string sql = $"select value(c) from c where c.standard='{standard}'";
            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Area>(queryText: sql,
                  requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-Area") }))
            {
                area = item;
            }
            AreaSetting setting = null;
            if (area != null)
            {
                try
                {
                    setting = await client.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<AreaSetting>(area.id, new PartitionKey("AreaSetting"));
                }
                catch (CosmosException)
                {
                    setting = null;
                }
            }
            if (setting == null)
            {
                setting = new AreaSetting
                {
                    allTime = 50,
                    classTime = 5,
                    submitTime = 15,
                    onlineTime = 20,
                    offlineTime = 10,
                    lessonMinutes = 45,
                };
            }

            try
            {
                List<TeacherTrain> teacherTrains = new List<TeacherTrain>();
                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);
                }
                int countArea = 0;
                int appraiseArea = 0;
                List<SchoolInfos> schoolInfos = new List<SchoolInfos>();
                TeacherTrainChangeMsg msg  = new TeacherTrainChangeMsg() { areaId=area.id};
                List<Task> tasks = new List<Task>();
                List<string> updateTeach = new List<string>();
                schools.ForEach(  school =>
                {
                    tasks.Add(Task.Run(async () =>
                    {
                        schoolInfos.Add(new SchoolInfos { schoolId = school.id, schoolName = school.name, picture = school.picture });
                        (List<TeacherTrain> trains, List<RGroupList> yxtrain, List<TeacherTrain> updateTeacherTrains) = 
                        await StatisticsService.StatisticsSchoolQuik(_coreAPIHttpService, school.id, setting, area, client, _dingDing, null);
                        teacherTrains.AddRange(trains);
                        schoolInfos.ForEach(y =>
                        {
                            var list = yxtrain.Find(z => z.school.Equals(y.schoolId));
                            if (list != null)
                            {
                                y.trainCount = list.members.Count;
                            }
                        });
                        if (updateTeacherTrains.IsNotEmpty())
                        {
                            updateTeach.AddRange(updateTeacherTrains.Select(z => z.id));
                            msg.schools.Add(new TeacherTrainChangeMsgSchoolTeachers { school = school.id, teachers = updateTeacherTrains.Select(z => z.id).ToList() });
                        }
                    }));
                });
                await Task.WhenAll(tasks);
                bool isnew=false;
                if (msg.schools.IsNotEmpty())
                {
                    var messageChange = new ServiceBusMessage(msg.ToJsonString());
                    messageChange.ApplicationProperties.Add("name", "TeacherTrainChange");
                    var ActiveTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
                    await _serviceBus.GetServiceBusClient().SendMessageAsync(ActiveTask, messageChange);
                }
                else {
                    isnew=true;
                }
                long totalTime = teacherTrains.Select(x => x.totalTime).Sum();
                int hgcount = teacherTrains.Where(x => x.finalScore == 1 || x.finalScore == 2).Count();
                setting.accessConfig = null;
                List<dynamic> dynamics = new List<dynamic>();
                teacherTrains.ForEach(x => {
                    x.schoolName = schools.Find(s => s.id.Equals(x.school))?.name;
                    x.currency.videoTime = (int)x.currency.videoTime;
                    x.currency.teacherAilities.ForEach(y => {
                        y.videoTime = (int)y.videoTime;
                        y.onlineTime = (int)y.onlineTime;
                        y.debateOrther = y.debateOrther > 0 ? y.debateOrther : 0;
                    });
                    dynamic dynamic = new
                    {
                        x.schoolName,
                        x.classTime,
                        x.finalScore,
                        x.name,
                        x.offlineTime,
                        x.onlineTime,
                        x.school,
                        x.id,
                        x.totalTime,
                        currency = new
                        {
                            x.currency.submitTime,
                            x.currency.exerciseAbility,
                            x.currency.learnAbility,
                            x.currency.uploadDone,
                            x.currency.uploadTotal,
                            x.currency.videoTime,
                            teacherAilities = x.currency.teacherAilities.Select(t => new {
                                t.onlineTime,
                                t.videoTime,
                                t.no,
                                t.name,
                                t.dimension,
                                t.zpscore,
                                t.xzscore,
                                t.hpscore
                            }),
                        },
                        offlineCountNo = x.offlineRecords.Where(o => o.upload == 0).Count(),
                        offlineCountOk = x.offlineRecords.Where(o => o.upload == 1).Count(),
                        teacherClasseCount = x.teacherClasses.Count
                    };
                    dynamics.Add(dynamic);
                });
                long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
                if (area.updateTime == 0 && isnew ) {
                    area.updateTime = now ;
                }
                if (area.updateTime == 0 && !isnew)
                {
                    area.updateTime = DateTimeOffset.UtcNow.Add(new TimeSpan(-1, 0, 0, 0)).ToUnixTimeMilliseconds();
                }
                //判断两个上次更新时间差
                if (area.updateTime > 0 && !isnew) { 
                    long  timedis= 15 * 60 * 1000;//15分钟
                    if (now - area.updateTime<timedis) { 
                        isnew= true;
                    }
                }
                return Ok(new { teacherTrains = dynamics, setting, schools = schoolInfos, totalTime, hgcount, teacherCount = countArea, appraiseCount = appraiseArea, isnew ,area.updateTime, updateTeach });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，StatisticsAreaQuick()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
                return BadRequest(new { ex.Message, ex.StackTrace });

            }
        }

        /// <summary>
        /// 区级数据统计 
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("statistics-area")]
        [AuthToken(Roles = "teacher,admin,area")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> StatisticsArea(JsonElement request)
        {
            var (userid, _, _, _) = HttpContext.GetAuthTokenInfo();
            request.TryGetProperty("standard", out JsonElement _standard);
            string standard = $"{_standard}";
            if (string.IsNullOrEmpty(standard))
            {
                return BadRequest();
            }
            var client = _azureCosmos.GetCosmosClient();
            Area area = null;
            string sql = $"select value(c) from c where c.standard='{standard}'";
            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Area>(queryText: sql,
                  requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-Area") }))
            {
                area = item;
            }
            AreaSetting setting = null;
            if (area != null)
            {
                try
                {
                    setting = await client.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<AreaSetting>(area.id, new PartitionKey("AreaSetting"));
                }
                catch (CosmosException)
                {
                    setting = null;
                }
            }
            if (setting == null)
            {
                setting = new AreaSetting
                {
                    allTime = 50,
                    classTime = 5,
                    submitTime = 15,
                    onlineTime = 20,
                    offlineTime = 10,
                    lessonMinutes = 45,
                };
            }

            try
            {
                List<TeacherTrain> teacherTrains = new List<TeacherTrain>();
                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);
                }
                List<Task<(List<TeacherTrain> trains, List<RGroupList> yxtrain)>> trains = new List<Task<(List<TeacherTrain> trains, List<RGroupList> yxtrain)>>();
                int countArea = 0;
                int appraiseArea = 0;
                List<SchoolInfos> schoolInfos = new List<SchoolInfos>();
                foreach (var school in schools)
                {
                    int count = 0;
                    int appraise = 0;
                    await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<bool>(queryText: $"select value(ARRAY_CONTAINS( c.permissions,'train-appraise')) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Teacher-{school.id}") }))
                    {
                        if (item)
                        {
                            appraise += 1;
                            appraiseArea += 1;

                        }
                        countArea += 1;
                        count += 1;
                    }
                    schoolInfos.Add(new SchoolInfos { schoolId = school.id, schoolName = school.name, picture = school.picture, teacherCount = count, appraiseCount = appraise });
                    //增加评审人员总人数，学习总人数。
                    trains.Add(StatisticsService.StatisticsSchool(_coreAPIHttpService, school.id, setting, area, client, _dingDing, null));
                }
                int pagesize = 100;
                if (trains.Count <= pagesize)
                {
                    (List<TeacherTrain> trains, List<RGroupList> yxtrain)[] tasks = await Task.WhenAll(trains);
                    tasks.ToList().ForEach(x => {
                        teacherTrains.AddRange(x.trains);
                        schoolInfos.ForEach(y => {
                            var list = x.yxtrain.Find(z => z.school.Equals(y.schoolId));
                            if (list != null)
                            {
                                y.trainCount = list.members.Count;
                            }
                        });
                    });
                }
                else
                {
                    int pages = (trains.Count + pagesize) / pagesize; //256是批量操作最大值，pages = (total + max -1) / max;
                    for (int i = 0; i < pages; i++)
                    {
                        var listssb = trains.Skip((i) * pagesize).Take(pagesize).ToList();
                        (List<TeacherTrain> trains, List<RGroupList> yxtrain)[] tasks = await Task.WhenAll(listssb);
                        tasks.ToList().ForEach(x => {
                            teacherTrains.AddRange(x.trains);
                            schoolInfos.ForEach(y => {
                                var list = x.yxtrain.Find(z => z.school.Equals(y.schoolId));
                                if (list != null)
                                {
                                    y.trainCount = list.members.Count;
                                }
                            });
                        });
                    }
                }
                long totalTime = teacherTrains.Select(x => x.totalTime).Sum();
                int hgcount = teacherTrains.Where(x => x.finalScore == 1 || x.finalScore == 2).Count();
                var teacherAilities = teacherTrains.SelectMany(x => x.currency.teacherAilities);
                setting.accessConfig = null;
                var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
                teacherTrains.ForEach(x => {
                    x.currency.videoTime = (int)x.currency.videoTime;
                    x.currency.teacherAilities.ForEach(y => {
                        y.videoTime = (int)y.videoTime;
                        y.onlineTime = (int)y.onlineTime;
                        y.debateOrther = y.debateOrther > 0 ? y.debateOrther : 0;
                    });
                });
             
                return Ok(new { teacherTrains, setting, schools = schoolInfos, totalTime, hgcount, teacherAilities, teacherCount = countArea, appraiseCount = appraiseArea });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，UpsertSubmitScore/UpsertSubmitScore()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
                return BadRequest(new { ex.Message, ex.StackTrace });

            }
        }
        public class SchoolInfos
        {
            public string schoolId { get; set; }
            public string schoolName { get; set; }
            public string picture { get; set; }
            public int teacherCount { get; set; }
            public int appraiseCount { get; set; }
            public int trainCount { get; set; }
        }

        /// <summary>
        /// 校级数据统计
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("push-school-data")]
        //[AuthToken(Roles = "teacher,admin,area")]
        //[Authorize(Roles = "IES")]
        public async Task<IActionResult> SchoolDataPush(JsonElement request) {
            var client = _azureCosmos.GetCosmosClient();
            request.TryGetProperty("standard", out JsonElement standard);
            request.TryGetProperty("school", out JsonElement _school);
            request.TryGetProperty("pushTeachers", out JsonElement _pushTeachers);
            List<string> pushTeachers = _pushTeachers.ToObject<List<string>>();
            (string accessConfig, Area area, AreaSetting setting) = await ThirdService.GetAccessConfig(client, $"{standard}");
            School school= await client.GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemAsync<School>($"{_school}",new PartitionKey("Base"));
            if (setting.id.Equals($"{school.areaId}"))
            {
                string  json = await ThirdService.SchoolDataPush(setting, _scsStudyApisService, pushTeachers, _option, $"{_school}");
                if (!string.IsNullOrWhiteSpace(json)) {
                    JsonElement element = json.ToObject<JsonElement>();
                    return Ok(new { element });
                }
            }
            else {
                return BadRequest("学校不属于该区");
            }
            return Ok(pushTeachers);
        }
        /// <summary>
        /// 校级数据统计
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-school-appraise")]
#if !DEBUG
 [AuthToken(Roles = "teacher,admin,area")]
        [Authorize(Roles = "IES")]
#endif
        public async Task<IActionResult> GetSchoolAppraise(JsonElement request)
        {
            request.TryGetProperty("school", out JsonElement _school);
            string school = "";
            var (userid, _, _, __school) = HttpContext.GetAuthTokenInfo();
            if (!string.IsNullOrEmpty($"{_school}"))
            {
                school = $"{_school}";
            }
            else
            {
                school = __school;
            }
            request.TryGetProperty("update", out JsonElement _update);
            HashSet<string> update = null;
            if (_update.ValueKind.Equals(JsonValueKind.Array))
            {
                update = _update.ToObject<HashSet<string>>();
            }
            string standard = "";
            if (HttpContext.Items.TryGetValue("Standard", out object _standard))
            {
                standard = $"{_standard}";
            }
            else {
                request.TryGetProperty("standard", out JsonElement _standardParmas);
                standard = $"{_standardParmas}";
            }
            var client = _azureCosmos.GetCosmosClient();
            Area area = null;
            string sql = $"select value(c) from c where c.standard='{standard}'";
            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Area>(queryText: sql,
                  requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-Area") }))
            {
                area = item;
            }
            AreaSetting setting = null;
            if (area != null)
            {
                try
                {
                    //优先找校级
                    setting = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<AreaSetting>(school, new PartitionKey("AreaSetting"));
                }
                catch (CosmosException)
                {
                    try
                    {
                        setting = await client.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<AreaSetting>(area.id, new PartitionKey("AreaSetting"));
                    }
                    catch (CosmosException)
                    {
                        setting = null;
                    }
                }
            }
            if (setting == null)
            {
                setting = new AreaSetting
                {
                    allTime = 50,
                    classTime = 5,
                    submitTime = 15,
                    onlineTime = 20,
                    offlineTime = 10,
                    lessonMinutes = 45,
                };
            }
            try
            {
                int count = 0;
                int appraise = 0;
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<bool>(queryText: $"    select   value(ARRAY_CONTAINS( c.permissions,'train-appraise') ) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Teacher-{school}") }))
                {
                    if (item)
                    {
                        appraise += 1;
                    }
                    count += 1;
                }
                //增加评审人员总人数，学习总人数。
                (List<TeacherTrain> teacherTrains, List<RGroupList> yxtrain) = await StatisticsService.StatisticsSchool(_coreAPIHttpService, school, setting, area, client, _dingDing, update);

                var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
                teacherTrains.ForEach(x => {
                    
                    x.currency.videoTime = (int)x.currency.videoTime;
                    x.currency.teacherAilities.ForEach(y => {
                        y.videoTime = (int)y.videoTime;
                        y.onlineTime = (int)y.onlineTime;
                        y.debateOrther= y.debateOrther>0? y.debateOrther: 0;
                    });
                });
                //try
                //{
                //    teacherTrain = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<TeacherTrain>(userid, new PartitionKey($"TeacherTrain-{school}"));
                //}
                //catch (CosmosException)
                //{

                //    await client.GetContainer(Constant.TEAMModelOS, "Teacher").CreateItemAsync<TeacherTrain>(teacherTrain, new PartitionKey($"TeacherTrain-{school}"));
                //}
                setting.accessConfig = null;
                return Ok(new { teacherTrains, setting, teacherCount = count, appraiseCount = appraise, yxtrain });
            }
            catch (Exception ex)
            {
                return BadRequest(new { ex.Message, ex.StackTrace });

            }
        }


        /// <summary>
        /// 教师个人数据统计
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("statistics-teacher")]
        [AuthToken(Roles = "teacher,admin,area")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> StatisticsTeacher(JsonElement request)
        {
            //{"tmdid":"1595321354","school":"hbcn"}
            var (_userid, name, picture, school) = HttpContext.GetAuthTokenInfo();
            if (!HttpContext.Items.TryGetValue("Standard", out object standard)) return BadRequest();
            var client = _azureCosmos.GetCosmosClient();
            request.TryGetProperty("update", out JsonElement _update);
            HashSet<string> update = null;
            if (_update.ValueKind.Equals(JsonValueKind.Array))
            {
                update = _update.ToObject<HashSet<string>>();
            }
            request.TryGetProperty("tmdid", out JsonElement _tmdid);
            string tmdid = "";
            if (_tmdid.ValueKind.Equals(JsonValueKind.String))
            {
                tmdid = $"{_tmdid}";
            }
            else
            {
                tmdid = $"{_userid}";
            }
            Area area = null;
            string sql = $"select value(c) from c where c.standard='{standard}'";
            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Area>(queryText: sql,
                  requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-Area") }))
            {
                area = item;
            }
            AreaSetting setting = null;
            if (area != null)
            {
                try
                {
                    //优先找校级
                    setting = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<AreaSetting>(school, new PartitionKey("AreaSetting"));
                }
                catch (CosmosException)
                {
                    try
                    {
                        setting = await client.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<AreaSetting>(area.id, new PartitionKey("AreaSetting"));
                    }
                    catch (CosmosException)
                    {
                        setting = null;
                    }
                }
            }
            if (setting == null)
            {
                setting = new AreaSetting
                {
                    allTime = 50,
                    classTime = 5,
                    submitTime = 15,
                    onlineTime = 20,
                    offlineTime = 10,
                    lessonMinutes = 45,
                };
            }
            try
            {
                TeacherTrain teacherTrain = null;
                try
                {
                    teacherTrain = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<TeacherTrain>(tmdid, new PartitionKey($"TeacherTrain-{school}"));
                    var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
                    teacherTrain.nickname = name;
                    teacherTrain.name = name;
                    if (!string.IsNullOrWhiteSpace(setting.accessConfig))
                    {
                        List<ScTeacher> teachers = await table.FindListByDict<ScTeacher>(new Dictionary<string, object>() { { "PartitionKey", "ScTeacher" }, { "areaId", setting.id }, { "schoolCode", school }, { "tmdid", $"{_tmdid}" } });
                        if (teachers.Any())
                        {
                            teacherTrain.name = teachers[0].TeacherName;
                        }
                    }
                    teacherTrain.picture = picture;
                    if (update != null && update.Count > 0)
                    {
                        foreach (var up in update)
                        {
                            teacherTrain.update.Add(up);
                        }
                    }
                    ///强制教师个人信息统计的时候 都再去统计一次。
                    teacherTrain.update.Add(StatisticsService.TeacherAbility);
                    if (teacherTrain.update.Count > 0)
                    {
                        await StatisticsService.StatisticsTeacher(teacherTrain, setting, area, client, null);
                    }
                }
                catch (CosmosException)
                {
                    string tname = name;
                    if (!string.IsNullOrWhiteSpace(setting.accessConfig)) {
                        var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
                        List<ScTeacher> teachers = await table.FindListByDict<ScTeacher>(new Dictionary<string, object>() { { "PartitionKey", "ScTeacher" }, { "areaId", setting.id }, { "schoolCode", school }, { "tmdid", $"{_tmdid}" } });
                        if (teachers.Any())
                        {
                            tname = teachers[0].TeacherName;
                        }
                    }
                   
                    teacherTrain = await StatisticsService.StatisticsTeacher(new TeacherTrain
                    {
                        pk = "TeacherTrain",
                        id = tmdid,
                        code = $"TeacherTrain-{school}",
                        tmdid = tmdid,
                        nickname= name,
                        school = school,
                        name = tname,
                        picture = picture,
                        update = new HashSet<string> {  StatisticsService.TeacherAbility,
                        StatisticsService.TeacherClass, StatisticsService.OfflineRecord }
                    }, setting, area, client, null);
                }
                setting.accessConfig = null;
                teacherTrain.currency.videoTime = (int)teacherTrain.currency.videoTime;
                teacherTrain.currency.teacherAilities.ForEach(y => {
                    y.videoTime = (int)y.videoTime;
                    y.onlineTime = (int)y.onlineTime;
                    y.debateOrther = y.debateOrther > 0 ? y.debateOrther : 0;
                });
                return Ok(new { teacherTrain, setting });
            }
            catch (Exception ex)
            {
                return BadRequest(new { ex.Message, ex.StackTrace });
            }
        }
    }
}