BIHttpTrigger.cs 32 KB

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