BIHttpTrigger.cs 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Dynamic;
  4. using System.IO;
  5. using System.Linq;
  6. using System.Net;
  7. using System.Net.Http;
  8. using System.Text.Json;
  9. using System.Threading.Tasks;
  10. using Azure.Cosmos;
  11. using Azure.Storage.Blobs;
  12. using DocumentFormat.OpenXml.Bibliography;
  13. using MathNet.Numerics.LinearAlgebra.Double;
  14. using Microsoft.AspNetCore.Http;
  15. using Microsoft.Azure.Functions.Worker;
  16. using Microsoft.Azure.Functions.Worker.Http;
  17. using NUnit.Framework.Constraints;
  18. using StackExchange.Redis;
  19. using TEAMModelOS.SDK.Context.Constant;
  20. using TEAMModelOS.SDK.DI;
  21. using TEAMModelOS.SDK.Extension;
  22. using TEAMModelOS.SDK.Models;
  23. using TEAMModelOS.SDK.Models.Cosmos.BI;
  24. using TEAMModelOS.SDK.Models.Cosmos.BI.BISchool;
  25. using TEAMModelOS.SDK.Models.Service.BI;
  26. using TEAMModelOS.SDK.Models.Service.BIStatsWay;
  27. namespace TEAMModelOS.FunctionV4
  28. {
  29. public class BIHttpTrigger
  30. {
  31. private readonly AzureCosmosFactory _azureCosmos;
  32. private readonly DingDing _dingDing;
  33. private readonly AzureStorageFactory _azureStorage;
  34. private readonly AzureRedisFactory _azureRedis;
  35. public BIHttpTrigger(AzureCosmosFactory azureCosmos, DingDing dingDing, AzureStorageFactory azureStorage, AzureRedisFactory azureRedis)
  36. {
  37. _azureCosmos = azureCosmos;
  38. _dingDing = dingDing;
  39. _azureStorage = azureStorage;
  40. _azureRedis = azureRedis;
  41. }
  42. /// <summary>
  43. /// 学校信息BI中间件更新
  44. /// </summary>
  45. /// <param name="req"></param>
  46. /// <returns></returns>
  47. //[Function("set-sc-birelation")]
  48. public async Task<HttpResponseData> upSchoolBIRelation([HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequestData req)
  49. {
  50. var response = req.CreateResponse(HttpStatusCode.OK);
  51. dynamic jsondata = new ExpandoObject();
  52. try
  53. {
  54. var cosmosClient = _azureCosmos.GetCosmosClient();
  55. var tableClient = _azureStorage.GetCloudTableClient();
  56. var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
  57. string data = await new StreamReader(req.Body).ReadToEndAsync();
  58. var json = JsonDocument.Parse(data).RootElement;
  59. School school = new();
  60. jsondata = json;
  61. if (json.TryGetProperty("school", out JsonElement _school))
  62. {
  63. school = _school.ToObject<School>();
  64. }
  65. string type = "";
  66. BIRelation bIRelation = new();
  67. var resBiRel = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(school.id, new PartitionKey("BIRel"));
  68. if (resBiRel.Status == 200)
  69. {
  70. using var fileJson = await JsonDocument.ParseAsync(resBiRel.ContentStream);
  71. bIRelation = fileJson.ToObject<BIRelation>();
  72. }
  73. else
  74. bIRelation.id = school.id;
  75. string aName = null;
  76. if (!string.IsNullOrEmpty($"{school.areaId}"))
  77. aName = await CosmosQueryHelper.GetStr(cosmosClient, "Normal", $"select value(c.name) from c where c.id='{school.areaId}'", "Base-Area");
  78. bIRelation.name = school.name;
  79. bIRelation.picture = school.picture;
  80. bIRelation.region = school.region;
  81. bIRelation.province = school.province;
  82. bIRelation.city = school.city;
  83. bIRelation.dist = school.dist;
  84. bIRelation.address = school.address;
  85. bIRelation.areaId = school.areaId;
  86. bIRelation.size = school.size;
  87. bIRelation.scale = school.scale;
  88. bIRelation.upDate = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  89. bIRelation.areaName = aName;
  90. if (resBiRel.Status == 200)
  91. {
  92. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<BIRelation>(bIRelation, bIRelation.id, new PartitionKey("BIRel"));
  93. type = "update";
  94. }
  95. else
  96. {
  97. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<BIRelation>(bIRelation, new PartitionKey("BIRel"));
  98. type = "add";
  99. }
  100. //保存操作记录
  101. await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, $"birelation-{type}", $"触发更新学校信息表中间件", _dingDing);
  102. }
  103. catch (Exception ex)
  104. {
  105. await _dingDing.SendBotMsg($"BIFunction, upSchoolBIRelation(),{ex.Message}\n{ex.StackTrace}\n{jsondata.ToJsonString()}", GroupNames.成都开发測試群組);
  106. }
  107. return response;
  108. }
  109. /// <summary>
  110. /// 统计学校的信息
  111. /// </summary>
  112. /// <param name="req"></param>
  113. /// <returns></returns>
  114. //[Function("stats-sc-info")]
  115. public async Task<HttpResponseData> StatsSchoolInfo([HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequestData req)
  116. {
  117. var response = req.CreateResponse(HttpStatusCode.OK);
  118. dynamic jsondata = new ExpandoObject();
  119. try
  120. {
  121. string scId = null;
  122. var cosmosClient = _azureCosmos.GetCosmosClient();
  123. var redisClinet = _azureRedis.GetRedisClient(8);
  124. var tableClient = _azureStorage.GetCloudTableClient();
  125. var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
  126. string data = await new StreamReader(req.Body).ReadToEndAsync();
  127. var json = JsonDocument.Parse(data).RootElement;
  128. jsondata = json;
  129. if (json.TryGetProperty("schoolId", out JsonElement _schoolId))
  130. {
  131. scId = $"{_schoolId}";
  132. }
  133. if (string.IsNullOrEmpty(scId))
  134. {
  135. return response;
  136. }
  137. bool locKey = await _azureRedis.GetRedisClient(8).KeyExistsAsync($"Train:Statistics:Lock:{scId}");
  138. if (!locKey)
  139. {
  140. await _azureRedis.GetRedisClient(8).SetAddAsync($"Train:Statistics:Lock:{scId}", new RedisValue(scId));
  141. DateTime minutes = DateTime.UtcNow.AddMinutes(15); //15分钟
  142. await _azureRedis.GetRedisClient(8).KeyExpireAsync($"Train:Statistics:Lock:{scId}", minutes);
  143. bool isExist = true;
  144. StatsInfo statsInfo = new();
  145. var scDataStats = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{scId}", new PartitionKey("Stats"));
  146. if (scDataStats.Status == 200)
  147. {
  148. using var fileJson = await JsonDocument.ParseAsync(scDataStats.ContentStream);
  149. statsInfo = fileJson.ToObject<StatsInfo>();
  150. }
  151. else
  152. isExist = false;
  153. statsInfo = await SchoolStatsWay.GetSingleSc(cosmosClient,redisClinet, scId);
  154. statsInfo.upTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  155. if (isExist)
  156. statsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<StatsInfo>(statsInfo, statsInfo.id, new PartitionKey("Stats"));
  157. else
  158. statsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<StatsInfo>(statsInfo, new PartitionKey("Stats"));
  159. }
  160. //保存操作记录
  161. await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "trigger-schoolStats", $"触发更新统计数据库", _dingDing);
  162. }
  163. catch (Exception ex)
  164. {
  165. await _dingDing.SendBotMsg($"BIFunction, StatsSchoolInfo() \n {ex.Message}\n{ex.StackTrace}\n{jsondata.ToJsonString()}", GroupNames.成都开发測試群組);
  166. }
  167. return response;
  168. }
  169. public async Task<HttpResponseData> SetSchoolStatsInfo([HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequestData req)
  170. {
  171. var response = req.CreateResponse(HttpStatusCode.OK);
  172. dynamic jsondata = new ExpandoObject();
  173. string data = await new StreamReader(req.Body).ReadToEndAsync();
  174. var json = JsonDocument.Parse(data).RootElement;
  175. jsondata = json;
  176. try
  177. {
  178. School school = null;
  179. if (json.TryGetProperty("school", out JsonElement _school))
  180. school = _school.ToObject<School>();
  181. DateTimeOffset dateOff = DateTimeOffset.UtcNow;
  182. var cosmosClient = _azureCosmos.GetCosmosClient();
  183. if (school != null)
  184. {
  185. StatsInfo statsInfo = new();
  186. var resStats = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{dateOff.Year}-{school.id}", new PartitionKey("Statistics"));
  187. if (resStats.Status == 200)
  188. {
  189. using var fileJson = await JsonDocument.ParseAsync(resStats.ContentStream);
  190. statsInfo = fileJson.ToObject<StatsInfo>();
  191. }
  192. else
  193. {
  194. double[] tchYear = new double[366];
  195. tchYear[0] = 1;
  196. statsInfo.id = $"{dateOff.Year}-{school.id}";
  197. statsInfo.year = dateOff.Year;
  198. statsInfo.stuYear = new double[366].ToList();
  199. statsInfo.tchYear = tchYear.ToList();
  200. statsInfo.tch = 1;
  201. statsInfo.weekTch = 1;
  202. statsInfo.monthTch = 1;
  203. statsInfo.tchUpTime = dateOff.ToUnixTimeMilliseconds();
  204. statsInfo.lesson.year = new double[366].ToList();
  205. statsInfo.lesson.yearInters = new double[366].ToList();
  206. statsInfo.activity.year = new double[366].ToList();
  207. }
  208. statsInfo.schoolId = school.id;
  209. statsInfo.name = school.name;
  210. statsInfo.picture = school.picture;
  211. statsInfo.size = school.size;
  212. statsInfo.scCreateTime = school.createTime;
  213. statsInfo.areaId = school.areaId;
  214. statsInfo.upTime = dateOff.ToUnixTimeMilliseconds();
  215. if (resStats.Status == 200)
  216. await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync<StatsInfo>(statsInfo, statsInfo.id, new PartitionKey("Statistics"));
  217. else
  218. await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").CreateItemAsync<StatsInfo>(statsInfo, new PartitionKey("Statistics"));
  219. }
  220. }
  221. catch (Exception ex)
  222. {
  223. await _dingDing.SendBotMsg($"BIFunction, SetSchoolStatsInfo() \n{ex.Message}\n{ex.StackTrace}\n{jsondata.ToJsonString()}", GroupNames.成都开发測試群組);
  224. }
  225. return response;
  226. }
  227. /// <summary>
  228. /// 处理传过来的信息加入到统计信息中
  229. /// </summary>
  230. /// <param name="req"></param>
  231. /// <returns></returns>
  232. //[Function("set-scstats-type")]
  233. public async Task<HttpResponseData> SetSchoolStatsType([HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequestData req)
  234. {
  235. var response = req.CreateResponse(HttpStatusCode.OK);
  236. dynamic jsondata = new ExpandoObject();
  237. try
  238. {
  239. string data = await new StreamReader(req.Body).ReadToEndAsync();
  240. var json = JsonDocument.Parse(data).RootElement;
  241. jsondata = json;
  242. var cosmosClient = _azureCosmos.GetCosmosClient();
  243. string scId = null, type = null;
  244. long careDate = 0;
  245. int count = 0;
  246. int interaction = 0;
  247. int lessType = 0;
  248. DateTimeOffset cuurDateOff = DateTimeOffset.UtcNow;
  249. DateTimeOffset dateOff = DateTimeOffset.UtcNow;
  250. if (json.TryGetProperty("scId", out JsonElement _schoolId))
  251. scId = $"{_schoolId}";
  252. if (json.TryGetProperty("type", out JsonElement _type))
  253. type = $"{_type}";
  254. if (string.IsNullOrEmpty($"{_schoolId}") && string.IsNullOrEmpty($"{_type}"))
  255. {
  256. await _dingDing.SendBotMsg($"set-scstats-type, {json}", GroupNames.成都开发測試群組);
  257. return response;
  258. }
  259. if (json.TryGetProperty("cnt", out JsonElement _cnt))
  260. count = _cnt.GetInt32();
  261. if (json.TryGetProperty("interaction", out JsonElement _interaction))
  262. interaction = _interaction.GetInt32();
  263. if (json.TryGetProperty("lessType", out JsonElement _lessType))
  264. lessType = _lessType.GetInt32();
  265. if (json.TryGetProperty("date", out JsonElement _date))
  266. careDate = _date.GetInt64();
  267. else
  268. careDate = dateOff.ToUnixTimeMilliseconds();
  269. var (lastWeekS, lastWeekE) = TimeHelper.GetStartOrEnd(dateOff, "lastweek"); //计算上周开始/结束时间
  270. var (weekS, weekE) = TimeHelper.GetStartOrEnd(dateOff, "week"); //计算本周开始/结束时间
  271. var (lastMonthS, lastMonthE) = TimeHelper.GetStartOrEnd(dateOff, "lastMonth"); //上月开始/结束时间
  272. var (monthS, monthE) = TimeHelper.GetStartOrEnd(dateOff, "month"); //本月开始/结束时间
  273. var (lastTermS, lastTermE) = TimeHelper.GetStartOrEnd(dateOff, "lastterm"); //计算上学期开始/结束时间
  274. var (termS, termE) = TimeHelper.GetStartOrEnd(dateOff, "term"); //计算本学期开始/结束时间
  275. var (yearS, yearE) = TimeHelper.GetStartOrEnd(cuurDateOff, "year"); //计算本学期开始/结束时间
  276. var (weekDayS, weekDayE) = TimeHelper.GetLongToTime(weekS, weekE);
  277. var (lWeekDayS, lWeekDayE) = TimeHelper.GetLongToTime(lastWeekS, lastWeekE);
  278. var (lTermDayS, lTermDayE) = TimeHelper.GetLongToTime(lastTermS, lastTermE);
  279. var (termDayS, termDayE) = TimeHelper.GetLongToTime(lastTermS, lastTermE);
  280. var (lMonthS, lMonthE) = TimeHelper.GetLongToTime(lastMonthS, lastMonthE);
  281. var (monthDayS, monthDayE) = TimeHelper.GetLongToTime(monthS, monthE);
  282. var lastDay = dateOff.AddDays(-1);
  283. int lmthDay = TimeHelper.GetDateDay(lMonthE);
  284. StatsInfo statsInfo = new();
  285. var resStsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{dateOff.Year}-{scId}", new PartitionKey("Statistics"));
  286. if (resStsInfo.Status == 200)
  287. {
  288. using var fileJson = await JsonDocument.ParseAsync(resStsInfo.ContentStream);
  289. statsInfo = fileJson.ToObject<StatsInfo>();
  290. }
  291. else
  292. {
  293. var resLastStsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{dateOff.Year - 1}-{scId}", new PartitionKey("Statistics"));
  294. if (resLastStsInfo.Status == 200)
  295. {
  296. using var fileJson = await JsonDocument.ParseAsync(resStsInfo.ContentStream);
  297. statsInfo = fileJson.ToObject<StatsInfo>();
  298. statsInfo.id = $"{dateOff.Year}-{scId}";
  299. statsInfo.year = dateOff.Year;
  300. statsInfo.stuYear = new double[366].ToList();
  301. statsInfo.tchYear = new double[366].ToList();
  302. statsInfo.lesson.year = new double[366].ToList();
  303. statsInfo.lesson.yearInters = new double[366].ToList();
  304. statsInfo.activity.year = new double[366].ToList();
  305. }
  306. else
  307. {
  308. ScBase scBase = await cosmosClient.GetContainer("TEAMModelOS", "Common").ReadItemAsync<ScBase>(scId, new PartitionKey("Base"));
  309. statsInfo.id = $"{dateOff.Year}-{scBase.id}";
  310. statsInfo.schoolId = scBase.id;
  311. statsInfo.name = scBase.name;
  312. statsInfo.picture = scBase.picture;
  313. statsInfo.size = scBase.size;
  314. statsInfo.scCreateTime = scBase.createTime;
  315. statsInfo.areaId = scBase.areaId;
  316. statsInfo.upTime = careDate;
  317. }
  318. }
  319. switch ($"{type}")
  320. {
  321. case "Exam":
  322. statsInfo.activity.exam += count;
  323. break;
  324. case "Survey":
  325. statsInfo.activity.survey += count;
  326. break;
  327. case "Vote":
  328. statsInfo.activity.vote += count;
  329. break;
  330. case "Homework":
  331. statsInfo.activity.homework += count;
  332. break;
  333. case "Less":
  334. //课例
  335. statsInfo.lesson.year[dateOff.DayOfYear] += count;
  336. statsInfo.lesson.all += count;
  337. if (lessType == 0)
  338. statsInfo.lesson.open += count;
  339. else
  340. statsInfo.lesson.less += count;
  341. statsInfo.lesson.lastDay = ((int)statsInfo.lesson.year[lastDay.DayOfYear]);
  342. statsInfo.lesson.day = ((int)statsInfo.lesson.year[dateOff.DayOfYear]);
  343. var lessList = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.lesson.year });
  344. statsInfo.lesson.lastWeek = ((int)lessList.SubMatrix(lWeekDayS.DayOfYear, 7, 0, lessList.ColumnCount).ColumnSums().Sum());
  345. statsInfo.lesson.week = ((int)lessList.SubMatrix(weekDayS.DayOfYear, (dateOff.DayOfYear - weekDayS.DayOfYear), 0, lessList.ColumnCount).ColumnSums().Sum());
  346. if (lastTermS <= statsInfo.lesson.upTime && statsInfo.lesson.upTime <= lastTermE)
  347. {
  348. if (lTermDayS.Year < dateOff.Year)
  349. {
  350. var lastLessSts = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{lTermDayS.Year}-{scId}", new PartitionKey("Statistics"));
  351. if (lastLessSts.Status == 200)
  352. {
  353. using var fileJson = await JsonDocument.ParseAsync(lastLessSts.ContentStream);
  354. var tempSts = fileJson.ToObject<StatsInfo>();
  355. var actYer = DenseMatrix.OfColumns(new List<List<double>>() { tempSts.lesson.year, statsInfo.lesson.year });
  356. statsInfo.lesson.lastTerm = ((int)actYer.SubMatrix(lTermDayS.DayOfYear, lTermDayE.DayOfYear, 0, 1).ColumnSums().Sum());
  357. }
  358. }
  359. }
  360. if (termS <= statsInfo.lesson.upTime && statsInfo.lesson.upTime <= termE)
  361. {
  362. if (termDayS.Year < dateOff.Year)
  363. {
  364. var lastSts = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{termDayS.Year}-{scId}", new PartitionKey("Statistics"));
  365. if (lastSts.Status == 200)
  366. {
  367. using var fileJson = await JsonDocument.ParseAsync(lastSts.ContentStream);
  368. var tempSts = fileJson.ToObject<StatsInfo>();
  369. var actYer = DenseMatrix.OfColumns(new List<List<double>>() { tempSts.lesson.year, statsInfo.lesson.year });
  370. statsInfo.lesson.term = ((int)actYer.SubMatrix(termDayS.DayOfYear, termDayE.DayOfYear, 0, 1).ColumnSums().Sum());
  371. }
  372. else
  373. statsInfo.lesson.term += count;
  374. }
  375. }
  376. statsInfo.lesson.lastMonth = ((int)lessList.SubMatrix(lMonthS.DayOfYear, lmthDay, 0, lessList.ColumnCount).ColumnSums().Sum());
  377. statsInfo.lesson.month += ((int)lessList.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, lessList.ColumnCount).ColumnSums().Sum());
  378. //课例互动
  379. statsInfo.lesson.yearInters[dateOff.DayOfYear] += interaction;
  380. statsInfo.lesson.allInter += interaction;
  381. statsInfo.lesson.lastDayInter = ((int)statsInfo.lesson.yearInters[lastDay.DayOfYear]);
  382. statsInfo.lesson.dayInter = ((int)statsInfo.lesson.yearInters[dateOff.DayOfYear]);
  383. var interList = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.lesson.yearInters });
  384. statsInfo.lesson.lastMonthInter = ((int)interList.SubMatrix(lMonthS.DayOfYear, lmthDay, 0, interList.ColumnCount).ColumnSums().Sum());
  385. statsInfo.lesson.monthInter += ((int)interList.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, interList.ColumnCount).ColumnSums().Sum());
  386. if (lastTermS <= statsInfo.lesson.upTime && statsInfo.lesson.upTime <= lastTermE)
  387. {
  388. if (lTermDayS.Year < dateOff.Year)
  389. {
  390. var lastSts = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{lTermDayS.Year}-{scId}", new PartitionKey("Statistics"));
  391. if (lastSts.Status == 200)
  392. {
  393. using var fileJson = await JsonDocument.ParseAsync(lastSts.ContentStream);
  394. var tempSts = fileJson.ToObject<StatsInfo>();
  395. statsInfo.lesson.lastYearInter = ((int)tempSts.lesson.yearInters.Sum());
  396. }
  397. else
  398. statsInfo.lesson.lastYearInter = 0;
  399. }
  400. }
  401. statsInfo.lesson.upTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  402. break;
  403. case "Student":
  404. statsInfo.stuYear[dateOff.DayOfYear] += count;
  405. statsInfo.stu += count;
  406. statsInfo.dayStu = ((int)statsInfo.stuYear[dateOff.DayOfYear]);
  407. var stuList = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.stuYear });
  408. statsInfo.weekStu = ((int)stuList.SubMatrix(weekDayS.DayOfYear, (dateOff.DayOfYear - weekDayS.DayOfYear), 0, stuList.ColumnCount).ColumnSums().Sum());
  409. statsInfo.monthStu = ((int)stuList.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, stuList.ColumnCount).ColumnSums().Sum());
  410. statsInfo.stuUpTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  411. break;
  412. case "Teacher":
  413. statsInfo.tchYear[dateOff.DayOfYear] += count;
  414. statsInfo.tch += count;
  415. statsInfo.dayTch = ((int)statsInfo.tchYear[dateOff.DayOfYear]);
  416. var tchList = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.tchYear });
  417. statsInfo.weekTch = ((int)tchList.SubMatrix(weekDayS.DayOfYear, (dateOff.DayOfYear - weekDayS.DayOfYear), 0, tchList.ColumnCount).ColumnSums().Sum());
  418. statsInfo.monthTch = ((int)tchList.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, tchList.ColumnCount).ColumnSums().Sum());
  419. statsInfo.tchUpTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  420. break;
  421. }
  422. if ($"{type}".Equals("Exam") || $"{type}".Equals("Survey") || $"{type}".Equals("Vote") || $"{type}".Equals("Homework"))
  423. {
  424. statsInfo.activity.all += count;
  425. if (careDate >= yearS && careDate <= yearE)
  426. {
  427. if (count > 0)
  428. {
  429. statsInfo.activity.year[dateOff.DayOfYear] += count;
  430. DenseMatrix matris = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.activity.year });
  431. statsInfo.activity.lastDay = ((int)statsInfo.activity.year[lastDay.DayOfYear]);
  432. statsInfo.activity.dayCnt = ((int)statsInfo.activity.year[dateOff.DayOfYear]);
  433. statsInfo.activity.lastWeek = ((int)matris.SubMatrix(lWeekDayS.DayOfYear, 7, 0, matris.ColumnCount).ColumnSums().Sum());
  434. statsInfo.activity.week = ((int)matris.SubMatrix(weekDayS.DayOfYear, weekDayE.DayOfYear - weekDayS.DayOfYear, 0, matris.ColumnCount).ColumnSums().Sum());
  435. if (lastTermS <= statsInfo.activity.upTime && statsInfo.activity.upTime <= lastTermE)
  436. {
  437. if (lTermDayS.Year < dateOff.Year)
  438. {
  439. var lastSts = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{lTermDayS.Year}-{scId}", new PartitionKey("Statistics"));
  440. if (lastSts.Status == 200)
  441. {
  442. using var fileJson = await JsonDocument.ParseAsync(lastSts.ContentStream);
  443. var tempSts = fileJson.ToObject<StatsInfo>();
  444. var actYer = DenseMatrix.OfColumns(new List<List<double>>() { tempSts.activity.year, statsInfo.activity.year });
  445. statsInfo.activity.lastTerm = ((int)actYer.SubMatrix(lTermDayS.DayOfYear, lTermDayE.DayOfYear, 0, 1).ColumnSums().Sum());
  446. }
  447. else
  448. statsInfo.activity.lastTerm = 0;
  449. }
  450. }
  451. if (termS <= statsInfo.activity.upTime && statsInfo.activity.upTime <= termE)
  452. {
  453. if (termDayS.Year < dateOff.Year)
  454. {
  455. var lastSts = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{termDayS.Year}-{scId}", new PartitionKey("Statistics"));
  456. if (lastSts.Status == 200)
  457. {
  458. using var fileJson = await JsonDocument.ParseAsync(lastSts.ContentStream);
  459. var tempSts = fileJson.ToObject<StatsInfo>();
  460. var actYer = DenseMatrix.OfColumns(new List<List<double>>() { tempSts.activity.year, statsInfo.activity.year });
  461. statsInfo.activity.term = ((int)actYer.SubMatrix(termDayS.DayOfYear, termDayE.DayOfYear, 0, 1).ColumnSums().Sum());
  462. }
  463. else
  464. statsInfo.activity.term += count;
  465. }
  466. else
  467. {
  468. var actYer = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.activity.year });
  469. statsInfo.activity.term = ((int)actYer.SubMatrix(termDayS.DayOfYear, termDayE.DayOfYear, 0, 1).ColumnSums().Sum());
  470. }
  471. }
  472. statsInfo.activity.lastMonth = ((int)matris.SubMatrix(lMonthS.DayOfYear, lmthDay, 0, matris.ColumnCount).ColumnSums().Sum());
  473. statsInfo.activity.month += ((int)matris.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, matris.ColumnCount).ColumnSums().Sum());
  474. statsInfo.activity.upTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  475. }
  476. }
  477. }
  478. if (resStsInfo.Status == 200)
  479. statsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync<StatsInfo>(statsInfo, scId, new PartitionKey("Statistics"));
  480. else
  481. statsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").CreateItemAsync<StatsInfo>(statsInfo, new PartitionKey("Statistics"));
  482. }
  483. catch (Exception ex)
  484. {
  485. await _dingDing.SendBotMsg($"BIFunction, SetSchoolStatsType() \n{ex.Message}\n{ex.StackTrace}\n{jsondata.ToJsonString()}", GroupNames.成都开发測試群組);
  486. }
  487. return response;
  488. }
  489. }
  490. }