123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552 |
- using Azure.Cosmos;
- using Azure.Storage.Blobs;
- using DocumentFormat.OpenXml.Math;
- using MathNet.Numerics.LinearAlgebra.Double;
- using Microsoft.Azure.Cosmos.Table;
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Text;
- using System.Text.Json;
- using System.Threading.Tasks;
- using TEAMModelOS.SDK.Context.Constant;
- using TEAMModelOS.SDK.DI;
- using TEAMModelOS.SDK.Extension;
- using TEAMModelOS.SDK.Models.Cosmos.BI;
- using TEAMModelOS.SDK.Models.Cosmos.BI.BISchool;
- namespace TEAMModelOS.SDK.Models.Service.BI
- {
- public static class BIStats
- {
- /// <summary>
- /// 依据类型增/减量统计方法
- /// </summary>
- /// <param name="cosmosClient">连接字符</param>
- /// <param name="scId">学校id</param>
- /// <param name="type">类型:Exam(测验) Survey(问卷调查) Vote(投票) Homework(作业) Less(课例) Student(学生) Tchaer(教师) </param>
- /// <param name="count">增减数量 </param>
- /// <param name="interaction">互动</param>
- /// <param name="careDate">时间</param>
- /// <returns></returns>
- public static async Task SetTypeAddStats(CosmosClient cosmosClient, DingDing _dingDing,string scId, string type, int count, int lessType = 0, int interaction = 0, long careDate = 0)
- {
- return;
- try
- {
- if(string.IsNullOrEmpty(scId))
- return;
- DateTimeOffset cuurDateOff = DateTimeOffset.UtcNow;
- DateTimeOffset dateOff = DateTimeOffset.UtcNow;
- if (careDate > 1000000000000)
- dateOff = DateTimeOffset.FromUnixTimeMilliseconds(careDate);
- else
- dateOff = DateTimeOffset.FromUnixTimeSeconds(careDate);
- if (careDate == 0)
- {
- dateOff = DateTimeOffset.UtcNow;
- careDate = dateOff.ToUnixTimeMilliseconds();
- }
- var (lastWeekS, lastWeekE) = TimeHelper.GetStartOrEnd(dateOff, "lastweek"); //计算上周开始/结束时间
- var (weekS, weekE) = TimeHelper.GetStartOrEnd(dateOff, "week"); //计算本周开始/结束时间
- var (lastMonthS, lastMonthE) = TimeHelper.GetStartOrEnd(dateOff, "lastMonth"); //上月开始/结束时间
- var (monthS, monthE) = TimeHelper.GetStartOrEnd(dateOff, "month"); //本月开始/结束时间
- var (lastTermS, lastTermE) = TimeHelper.GetStartOrEnd(dateOff, "lastterm"); //计算上学期开始/结束时间
- var (termS, termE) = TimeHelper.GetStartOrEnd(dateOff, "term"); //计算本学期开始/结束时间
- var (yearS, yearE) = TimeHelper.GetStartOrEnd(cuurDateOff, "year"); //计算本学期开始/结束时间
- var (weekDayS, weekDayE) = TimeHelper.GetLongToTime(weekS, weekE);
- var (lWeekDayS, lWeekDayE) = TimeHelper.GetLongToTime(lastWeekS, lastWeekE);
- var (lTermDayS, lTermDayE) = TimeHelper.GetLongToTime(lastTermS, lastTermE);
- var (termDayS, termDayE) = TimeHelper.GetLongToTime(lastTermS, lastTermE);
- var (lMonthS, lMonthE) = TimeHelper.GetLongToTime(lastMonthS, lastMonthE);
- var (monthDayS, monthDayE) = TimeHelper.GetLongToTime(monthS, monthE);
- var lastDay = dateOff.AddDays(-1);
- int lmthDay = TimeHelper.GetDateDay(lMonthE);
- StatsInfo statsInfo = new();
- var resStsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{dateOff.Year}-{scId}", new PartitionKey("Statistics"));
- if (resStsInfo.Status == 200)
- {
- using var fileJson = await JsonDocument.ParseAsync(resStsInfo.ContentStream);
- statsInfo = fileJson.ToObject<StatsInfo>();
- }
- else
- {
- var resLastStsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{dateOff.Year - 1}-{scId}", new PartitionKey("Statistics"));
- if (resLastStsInfo.Status == 200)
- {
- using var fileJson = await JsonDocument.ParseAsync(resStsInfo.ContentStream);
- statsInfo = fileJson.ToObject<StatsInfo>();
- statsInfo.id = $"{dateOff.Year}-{scId}";
- statsInfo.year = dateOff.Year;
- statsInfo.stuYear = new double[366].ToList();
- statsInfo.tchYear = new double[366].ToList();
- statsInfo.lesson.year = new double[366].ToList();
- statsInfo.lesson.yearInters = new double[366].ToList();
- statsInfo.activity.year = new double[366].ToList();
- }
- else
- {
- ScBase scBase = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemAsync<ScBase>(scId, new PartitionKey("Base"));
- statsInfo.id = $"{dateOff.Year}-{scBase.id}";
- statsInfo.schoolId = scBase.id;
- statsInfo.name = scBase.name;
- statsInfo.picture = scBase.picture;
- statsInfo.size = scBase.size;
- statsInfo.scCreateTime = scBase.createTime;
- statsInfo.areaId = scBase.areaId;
- statsInfo.upTime = careDate;
- statsInfo.stuYear = new double[366].ToList();
- statsInfo.tchYear = new double[366].ToList();
- statsInfo.lesson.year = new double[366].ToList();
- statsInfo.lesson.yearInters = new double[366].ToList();
- statsInfo.activity.year = new double[366].ToList();
- }
- }
- switch ($"{type}")
- {
- case "Exam":
- statsInfo.activity.exam += count;
- break;
- case "Survey":
- statsInfo.activity.survey += count;
- break;
- case "Vote":
- statsInfo.activity.vote += count;
- break;
- case "Homework":
- statsInfo.activity.homework += count;
- break;
- case "Less":
- //课例
- statsInfo.lesson.year[dateOff.DayOfYear] += count;
- statsInfo.lesson.all += count;
- if (lessType == 0)
- statsInfo.lesson.open += count;
- else
- statsInfo.lesson.less += count;
- statsInfo.lesson.lastDay = ((int)statsInfo.lesson.year[lastDay.DayOfYear]);
- statsInfo.lesson.day = ((int)statsInfo.lesson.year[dateOff.DayOfYear]);
- var lessList = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.lesson.year });
- statsInfo.lesson.lastWeek = ((int)lessList.SubMatrix(lWeekDayS.DayOfYear, 7, 0, lessList.ColumnCount).ColumnSums().Sum());
- statsInfo.lesson.week = ((int)lessList.SubMatrix(weekDayS.DayOfYear, (dateOff.DayOfYear - weekDayS.DayOfYear), 0, lessList.ColumnCount).ColumnSums().Sum());
- if (lastTermS <= statsInfo.lesson.upTime && statsInfo.lesson.upTime <= lastTermE)
- {
- if (lTermDayS.Year < dateOff.Year)
- {
- var lastLessSts = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{lTermDayS.Year}-{scId}", new PartitionKey("Statistics"));
- if (lastLessSts.Status == 200)
- {
- using var fileJson = await JsonDocument.ParseAsync(lastLessSts.ContentStream);
- var tempSts = fileJson.ToObject<StatsInfo>();
- var actYer = DenseMatrix.OfColumns(new List<List<double>>() { tempSts.lesson.year, statsInfo.lesson.year });
- statsInfo.lesson.lastTerm = ((int)actYer.SubMatrix(lTermDayS.DayOfYear, lTermDayE.DayOfYear, 0, 1).ColumnSums().Sum());
- }
- }
- }
- if (termS <= statsInfo.lesson.upTime && statsInfo.lesson.upTime <= termE)
- {
- if (termDayS.Year < dateOff.Year)
- {
- var lastSts = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{termDayS.Year}-{scId}", new PartitionKey("Statistics"));
- if (lastSts.Status == 200)
- {
- using var fileJson = await JsonDocument.ParseAsync(lastSts.ContentStream);
- var tempSts = fileJson.ToObject<StatsInfo>();
- var actYer = DenseMatrix.OfColumns(new List<List<double>>() { tempSts.lesson.year, statsInfo.lesson.year });
- statsInfo.lesson.term = ((int)actYer.SubMatrix(termDayS.DayOfYear, termDayE.DayOfYear, 0, 1).ColumnSums().Sum());
- }
- else
- statsInfo.lesson.term += count;
- }
- }
- statsInfo.lesson.lastMonth = ((int)lessList.SubMatrix(lMonthS.DayOfYear, lmthDay, 0, lessList.ColumnCount).ColumnSums().Sum());
- statsInfo.lesson.month += ((int)lessList.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, lessList.ColumnCount).ColumnSums().Sum());
- //课例互动
- statsInfo.lesson.yearInters[dateOff.DayOfYear] += interaction;
- statsInfo.lesson.allInter += interaction;
- statsInfo.lesson.lastDayInter = ((int)statsInfo.lesson.yearInters[lastDay.DayOfYear]);
- statsInfo.lesson.dayInter = ((int)statsInfo.lesson.yearInters[dateOff.DayOfYear]);
- var interList = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.lesson.yearInters });
- statsInfo.lesson.lastMonthInter = ((int)interList.SubMatrix(lMonthS.DayOfYear, lmthDay, 0, interList.ColumnCount).ColumnSums().Sum());
- statsInfo.lesson.monthInter += ((int)interList.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, interList.ColumnCount).ColumnSums().Sum());
- if (lastTermS <= statsInfo.lesson.upTime && statsInfo.lesson.upTime <= lastTermE)
- {
- if (lTermDayS.Year < dateOff.Year)
- {
- var lastSts = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{lTermDayS.Year}-{scId}", new PartitionKey("Statistics"));
- if (lastSts.Status == 200)
- {
- using var fileJson = await JsonDocument.ParseAsync(lastSts.ContentStream);
- var tempSts = fileJson.ToObject<StatsInfo>();
- statsInfo.lesson.lastYearInter = ((int)tempSts.lesson.yearInters.Sum());
- }
- else
- statsInfo.lesson.lastYearInter = 0;
- }
- }
- statsInfo.lesson.upTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- break;
- case "Student":
- statsInfo.stuYear[dateOff.DayOfYear] += count;
- statsInfo.stu += count;
- statsInfo.dayStu = ((int)statsInfo.stuYear[dateOff.DayOfYear]);
- var stuList = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.stuYear });
- statsInfo.weekStu = ((int)stuList.SubMatrix(weekDayS.DayOfYear, (dateOff.DayOfYear - weekDayS.DayOfYear), 0, stuList.ColumnCount).ColumnSums().Sum());
- statsInfo.monthStu = ((int)stuList.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, stuList.ColumnCount).ColumnSums().Sum());
- statsInfo.stuUpTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- break;
- case "Teacher":
- statsInfo.tchYear[dateOff.DayOfYear] += count;
- statsInfo.tch += count;
- statsInfo.dayTch = ((int)statsInfo.tchYear[dateOff.DayOfYear]);
- var tchList = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.tchYear });
- statsInfo.weekTch = ((int)tchList.SubMatrix(weekDayS.DayOfYear, (dateOff.DayOfYear - weekDayS.DayOfYear), 0, tchList.ColumnCount).ColumnSums().Sum());
- statsInfo.monthTch = ((int)tchList.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, tchList.ColumnCount).ColumnSums().Sum());
- statsInfo.tchUpTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- break;
- }
- if ($"{type}".Equals("Exam") || $"{type}".Equals("Survey") || $"{type}".Equals("Vote") || $"{type}".Equals("Homework"))
- {
- statsInfo.activity.all += count;
- if (careDate >= yearS && careDate <= yearE)
- {
- if (count > 0)
- {
- statsInfo.activity.year[dateOff.DayOfYear] += count;
- DenseMatrix matris = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.activity.year });
- statsInfo.activity.lastDay = ((int)statsInfo.activity.year[lastDay.DayOfYear]);
- statsInfo.activity.dayCnt = ((int)statsInfo.activity.year[dateOff.DayOfYear]);
- statsInfo.activity.lastWeek = ((int)matris.SubMatrix(lWeekDayS.DayOfYear, 7, 0, matris.ColumnCount).ColumnSums().Sum());
- statsInfo.activity.week = ((int)matris.SubMatrix(weekDayS.DayOfYear, weekDayE.DayOfYear - weekDayS.DayOfYear, 0, matris.ColumnCount).ColumnSums().Sum());
- if (lastTermS <= statsInfo.activity.upTime && statsInfo.activity.upTime <= lastTermE)
- {
- if (lTermDayS.Year < dateOff.Year)
- {
- var lastSts = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{lTermDayS.Year}-{scId}", new PartitionKey("Statistics"));
- if (lastSts.Status == 200)
- {
- using var fileJson = await JsonDocument.ParseAsync(lastSts.ContentStream);
- var tempSts = fileJson.ToObject<StatsInfo>();
- var actYer = DenseMatrix.OfColumns(new List<List<double>>() { tempSts.activity.year, statsInfo.activity.year });
- statsInfo.activity.lastTerm = ((int)actYer.SubMatrix(lTermDayS.DayOfYear, lTermDayE.DayOfYear, 0, 1).ColumnSums().Sum());
- }
- else
- statsInfo.activity.lastTerm = 0;
- }
- }
- if (termS <= statsInfo.activity.upTime && statsInfo.activity.upTime <= termE)
- {
- if (termDayS.Year < dateOff.Year)
- {
- var lastSts = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{termDayS.Year}-{scId}", new PartitionKey("Statistics"));
- if (lastSts.Status == 200)
- {
- using var fileJson = await JsonDocument.ParseAsync(lastSts.ContentStream);
- var tempSts = fileJson.ToObject<StatsInfo>();
- var actYer = DenseMatrix.OfColumns(new List<List<double>>() { tempSts.activity.year, statsInfo.activity.year });
- statsInfo.activity.term = ((int)actYer.SubMatrix(termDayS.DayOfYear, termDayE.DayOfYear, 0, 1).ColumnSums().Sum());
- }
- else
- statsInfo.activity.term += count;
- }
- else
- {
- var actYer = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.activity.year });
- statsInfo.activity.term = ((int)actYer.SubMatrix(termDayS.DayOfYear, termDayE.DayOfYear, 0, 1).ColumnSums().Sum());
- }
- }
- statsInfo.activity.lastMonth = ((int)matris.SubMatrix(lMonthS.DayOfYear, lmthDay, 0, matris.ColumnCount).ColumnSums().Sum());
- statsInfo.activity.month += ((int)matris.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, matris.ColumnCount).ColumnSums().Sum());
- statsInfo.activity.upTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- }
- }
- }
- if (resStsInfo.Status == 200)
- statsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync<StatsInfo>(statsInfo, statsInfo.id, new PartitionKey("Statistics"));
- else
- statsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").CreateItemAsync<StatsInfo>(statsInfo, new PartitionKey("Statistics"));
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"BI,SetTypeAddStats(),参数: 学校:{scId},统计类型:{type}, 增/减数:{count},课例类型(0:开课,1:课例):{lessType},学生互动数:{interaction},时间戳:{careDate}\n {ex.Message}\n {ex.StackTrace}", GroupNames.成都开发測試群組);
- }
- }
- /// <summary>
- /// 创建/创建BI统计信息接口
- /// </summary>
- /// <param name="cosmosClient"></param>
- /// <param name="school"></param>
- /// <returns></returns>
- public static async Task SetScStatsInfo(CosmosClient cosmosClient, School school)
- {
- DateTimeOffset dateOff = DateTimeOffset.UtcNow;
- StatsInfo statsInfo = new();
- var resStats = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{dateOff.Year}-{school.id}", new PartitionKey("Statistics"));
- if (resStats.Status == 200)
- {
- using var fileJson = await JsonDocument.ParseAsync(resStats.ContentStream);
- statsInfo = fileJson.ToObject<StatsInfo>();
- }
- else
- {
- double[] tchYear = new double[366];
- tchYear[0] = 1;
- statsInfo.id = $"{dateOff.Year}-{school.id}";
- statsInfo.year = dateOff.Year;
- statsInfo.stuYear = new double[366].ToList();
- statsInfo.tchYear = tchYear.ToList();
- statsInfo.tch = 1;
- statsInfo.weekTch = 1;
- statsInfo.monthTch = 1;
- statsInfo.tchUpTime = dateOff.ToUnixTimeMilliseconds();
- statsInfo.lesson.year = new double[366].ToList();
- statsInfo.lesson.yearInters = new double[366].ToList();
- statsInfo.activity.year = new double[366].ToList();
- }
- statsInfo.schoolId = school.id;
- statsInfo.name = school.name;
- statsInfo.picture = school.picture;
- statsInfo.size = school.size;
- statsInfo.scCreateTime = school.createTime;
- statsInfo.areaId = school.areaId;
- statsInfo.upTime = dateOff.ToUnixTimeMilliseconds();
- if (resStats.Status == 200)
- await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync<StatsInfo>(statsInfo, statsInfo.id, new PartitionKey("Statistics"));
- else
- await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").CreateItemAsync<StatsInfo>(statsInfo, new PartitionKey("Statistics"));
- }
- /// <summary>
- /// 新增/修改学校列表中间件
- /// </summary>
- /// <param name="cosmosClient"></param>
- /// <param name="tableClient"></param>
- /// <param name="blobClient"></param>
- /// <param name="_dingDing"></param>
- /// <param name="school"></param>
- /// <returns></returns>
- public static async Task SetSchoolBIRelation(CosmosClient cosmosClient, BlobContainerClient blobClient, CloudTableClient tableClient, DingDing _dingDing, School school)
- {
- string type = "";
- BIRelation bIRelation = new();
- var resBiRel = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(school.id, new PartitionKey("BIRel"));
- if (resBiRel.Status == 200)
- {
- using var fileJson = await JsonDocument.ParseAsync(resBiRel.ContentStream);
- bIRelation = fileJson.ToObject<BIRelation>();
- }
- else
- bIRelation.id = school.id;
- string aName = null;
- if (!string.IsNullOrEmpty($"{school.areaId}"))
- aName = await CosmosQueryHelper.GetStr(cosmosClient, "Normal", $"select value(c.name) from c where c.id='{school.areaId}'", "Base-Area");
- bIRelation.name = school.name;
- bIRelation.picture = school.picture;
- bIRelation.region = school.region;
- bIRelation.province = school.province;
- bIRelation.city = school.city;
- bIRelation.dist = school.dist;
- bIRelation.address = school.address;
- bIRelation.areaId = school.areaId;
- bIRelation.size = school.size;
- bIRelation.scale = school.scale;
- bIRelation.upDate = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- bIRelation.areaName = aName;
- if (resBiRel.Status == 200)
- {
- await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<BIRelation>(bIRelation, bIRelation.id, new PartitionKey("BIRel"));
- type = "update";
- }
- else
- {
- await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<BIRelation>(bIRelation, new PartitionKey("BIRel"));
- type = "add";
- }
- //保存操作记录
- await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, $"birelation-{type}", $"触发更新学校信息表中间件", _dingDing);
- }
- /// <summary>
- /// 每天00:00执行统计清零方法;zore时间
- /// </summary>
- /// <param name="_azureCosmos"></param>
- /// <param name="_dingDing"></param>
- /// <returns></returns>
- public static async Task SetStatsZeroPoint(AzureCosmosFactory _azureCosmos, DingDing _dingDing)
- {
- try
- {
- var cosmosClient = _azureCosmos.GetCosmosClient();
- DateTimeOffset dateOff = DateTimeOffset.UtcNow;
- long upTime = dateOff.ToUnixTimeMilliseconds();
- var (DayS, DayE) = TimeHelper.GetStartOrEnd(dateOff); //今天开始时间结束时间
- var (lastWeekS, lastWeekE) = TimeHelper.GetStartOrEnd(dateOff, "lastweek"); //计算上周开始/结束时间
- var (weekS, weekE) = TimeHelper.GetStartOrEnd(dateOff, "week"); //计算本周开始/结束时间
- var (lastMonthS, lastMonthE) = TimeHelper.GetStartOrEnd(dateOff, "lastMonth"); //上月开始/结束时间
- var (monthS, monthE) = TimeHelper.GetStartOrEnd(dateOff, "month"); //本月开始/结束时间
- var (lastTermS, lastTermE) = TimeHelper.GetStartOrEnd(dateOff, "lastterm"); //计算上学期开始/结束时间
- var (termS, termE) = TimeHelper.GetStartOrEnd(dateOff, "term"); //计算本学期开始/结束时间
- var (weekDayS, weekDayE) = TimeHelper.GetLongToTime(weekS, weekE);
- var (lWeekDayS, lWeekDayE) = TimeHelper.GetLongToTime(lastWeekS, lastWeekE);
- var (lTermDayS, lTermDayE) = TimeHelper.GetLongToTime(lastTermS, lastTermE);
- var (termDayS, termDayE) = TimeHelper.GetLongToTime(lastTermS, lastTermE);
- var (lMonthS, lMonthE) = TimeHelper.GetLongToTime(lastMonthS, lastMonthE);
- var (monthDayS, monthDayE) = TimeHelper.GetLongToTime(monthS, monthE);
- var lastDay = dateOff.AddDays(-1);
- int lmthDay = TimeHelper.GetDateDay(lMonthE);
- int termDay = 0;
- List<Task<ItemResponse<StatsInfo>>> statsInfos = new();
- List<StatsInfo> tempStatsInfos = new();
- await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryIterator<StatsInfo>(queryText: "select value(c) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Statistics") }))
- {
- tempStatsInfos.Add(item);
- }
- if (tempStatsInfos.Count > 0)
- {
- foreach (var item in tempStatsInfos)
- {
- if (termDayE.Year == dateOff.Year)
- termDay = dateOff.DayOfYear;
- else
- termDay = item.activity.year.Count;
- StatsInfo lastStatsInfo = null;
- var lastSts = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{dateOff.Year - 1}-{item.schoolId}", new PartitionKey("Statistics"));
- if (lastSts.Status == 200)
- {
- using var fileJson = await JsonDocument.ParseAsync(lastSts.ContentStream);
- lastStatsInfo = fileJson.ToObject<StatsInfo>();
- }
- var tchList = DenseMatrix.OfColumns(new List<List<double>>() { item.tchYear });
- item.dayTch = ((int)item.tchYear[lastDay.DayOfYear]);
- item.weekTch = ((int)tchList.SubMatrix(weekDayS.DayOfYear, 7, 0, tchList.ColumnCount).ColumnSums().Sum());
- item.monthTch = ((int)tchList.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, tchList.ColumnCount).ColumnSums().Sum());
- item.tchUpTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- var stuList = DenseMatrix.OfColumns(new List<List<double>>() { item.stuYear });
- item.dayStu = ((int)item.stuYear[lastDay.DayOfYear]);
- item.weekStu = ((int)stuList.SubMatrix(weekDayS.DayOfYear, 7, 0, stuList.ColumnCount).ColumnSums().Sum());
- item.monthStu = ((int)stuList.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, stuList.ColumnCount).ColumnSums().Sum());
- item.stuUpTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- var lessList = DenseMatrix.OfColumns(new List<List<double>>() { item.lesson.year });
- item.lesson.lastDay = item.lesson.day;
- item.lesson.lastWeek = ((int)lessList.SubMatrix(lWeekDayS.DayOfYear, 7, 0, lessList.ColumnCount).ColumnSums().Sum());
- item.lesson.week = ((int)lessList.SubMatrix(weekDayS.DayOfYear, 7, 0, lessList.ColumnCount).ColumnSums().Sum());
- if (lTermDayS.Year < dateOff.Year)
- {
- if (lastStatsInfo != null)
- {
- var lessYer = DenseMatrix.OfColumns(new List<List<double>>() { lastStatsInfo.lesson.year, item.lesson.year });
- item.lesson.lastTerm = ((int)lessYer.SubMatrix(lTermDayS.DayOfYear, lTermDayE.DayOfYear, 0, 1).ColumnSums().Sum());
- }
- }
- item.lesson.term = ((int)lessList.SubMatrix(termDayS.DayOfYear, termDay, 0, 1).ColumnSums().Sum());
- item.lesson.day = 0;
- item.lesson.lastMonth = ((int)lessList.SubMatrix(lMonthS.DayOfYear, lmthDay, 0, lessList.ColumnCount).ColumnSums().Sum());
- item.lesson.month += ((int)lessList.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, lessList.ColumnCount).ColumnSums().Sum());
- item.lesson.upTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- var interList = DenseMatrix.OfColumns(new List<List<double>>() { item.lesson.yearInters });
- item.lesson.lastDayInter = ((int)item.lesson.yearInters[lastDay.DayOfYear]);
- item.lesson.dayInter = 0;
- item.lesson.lastMonthInter = ((int)interList.SubMatrix(lMonthS.DayOfYear, lmthDay, 0, interList.ColumnCount).ColumnSums().Sum());
- item.lesson.monthInter = ((int)interList.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, interList.ColumnCount).ColumnSums().Sum());
- if (lastStatsInfo != null)
- {
- var actYer = DenseMatrix.OfColumns(new List<List<double>>() { lastStatsInfo.lesson.yearInters });
- item.lesson.lastYearInter = ((int)actYer.SubMatrix(lTermDayS.DayOfYear, 366, 0, 1).ColumnSums().Sum());
- }
- item.lesson.yearInter = ((int)item.lesson.yearInters.Sum());
- item.activity.dayCnt = ((int)item.activity.year[dateOff.DayOfYear]);
- item.activity.lastDay = ((int)item.activity.year[lastDay.DayOfYear]);
- var actList = DenseMatrix.OfColumns(new List<List<double>>() { item.activity.year });
- item.activity.lastWeek = ((int)actList.SubMatrix(lWeekDayS.DayOfYear, 7, 0, actList.ColumnCount).ColumnSums().Sum());
- item.activity.week = ((int)actList.SubMatrix(weekDayS.DayOfYear, 7, 0, actList.ColumnCount).ColumnSums().Sum());
- if (lMonthS.Year == dateOff.Year)
- item.activity.lastMonth = ((int)actList.SubMatrix(lMonthS.DayOfYear, lMonthE.DayOfYear, 0, actList.ColumnCount).ColumnSums().Sum());
- else
- {
- var lastMthYer = DenseMatrix.OfColumns(new List<List<double>>() { lastStatsInfo.activity.year });
- item.activity.lastMonth = ((int)lastMthYer.SubMatrix(lMonthS.DayOfYear, lMonthE.DayOfYear, 0, actList.ColumnCount).ColumnSums().Sum());
- }
- item.activity.month = ((int)actList.SubMatrix(monthDayS.DayOfYear, monthDayE.DayOfYear, 0, actList.ColumnCount).ColumnSums().Sum());
- if (lastStatsInfo != null)
- {
- var actYer = DenseMatrix.OfColumns(new List<List<double>>() { lastStatsInfo.activity.year });
- item.activity.lastTerm = ((int)actYer.SubMatrix(lTermDayS.DayOfYear, lTermDayE.DayOfYear, 0, 1).ColumnSums().Sum());
- }
- item.activity.upTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- statsInfos.Add(cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync<StatsInfo>(item, item.id, new PartitionKey("Statistics")));
- }
- if (statsInfos.Count < 256)
- await Task.WhenAll(statsInfos);
- else
- {
- int pages = (statsInfos.Count + 255) / 256;
- for (int i = 0; i < pages; i++)
- {
- List<Task<ItemResponse<StatsInfo>>> itemResponses = statsInfos.Skip((i) * 256).Take(256).ToList();
- await Task.WhenAll(itemResponses);
- }
- }
- }
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"BI, SetStatsZeroPoint() \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
- }
- }
- }
- }
|