BIStats.cs 54 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927
  1. using Microsoft.Azure.Cosmos;
  2. using Azure.Storage.Blobs;
  3. using MathNet.Numerics.LinearAlgebra.Double;
  4. using TEAMModelOS.SDK.Models.Table;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.Diagnostics;
  8. using System.Linq;
  9. using System.Text;
  10. using System.Text.Json;
  11. using System.Threading.Tasks;
  12. using TEAMModelOS.SDK.DI;
  13. using TEAMModelOS.SDK.Extension;
  14. using TEAMModelOS.SDK.Models.Cosmos.BI;
  15. using TEAMModelOS.SDK.Models.Cosmos.BI.BISchool;
  16. using Microsoft.Azure.Cosmos.Table;
  17. namespace TEAMModelOS.SDK.Models.Service.BI
  18. {
  19. public static class BIStats
  20. {
  21. /// <summary>
  22. /// 依据类型增/减量统计方法
  23. /// </summary>
  24. /// <param name="cosmosClient">连接字符</param>
  25. /// <param name="scId">学校id</param>
  26. /// <param name="type">类型:Exam(测验) Survey(问卷调查) Vote(投票) Homework(作业) Less(课例) Student(学生) Tchaer(教师) </param>
  27. /// <param name="count">增减数量 </param>
  28. /// <param name="interaction">互动</param>
  29. /// <param name="careDate">时间</param>
  30. /// <returns></returns>
  31. public static async Task SetTypeAddStats(CosmosClient cosmosClient, DingDing _dingDing, string scId, string type, int count, int lessType = 0, int interaction = 0, long careDate = 0)
  32. {
  33. try
  34. {
  35. return;
  36. if (string.IsNullOrEmpty(scId) || scId.Equals("SYSTEM_NO_SCHOOL",StringComparison.OrdinalIgnoreCase))
  37. return;
  38. DateTimeOffset cuurDateOff = DateTimeOffset.UtcNow;
  39. DateTimeOffset dateOff = DateTimeOffset.UtcNow;
  40. if (careDate > 1000000000000)
  41. dateOff = DateTimeOffset.FromUnixTimeMilliseconds(careDate);
  42. else
  43. dateOff = DateTimeOffset.FromUnixTimeSeconds(careDate);
  44. if (careDate == 0)
  45. {
  46. dateOff = DateTimeOffset.UtcNow;
  47. careDate = dateOff.ToUnixTimeMilliseconds();
  48. }
  49. var (lastWeekS, lastWeekE) = TimeHelper.GetStartOrEnd(dateOff, "lastweek"); //计算上周开始/结束时间
  50. var (weekS, weekE) = TimeHelper.GetStartOrEnd(dateOff, "week"); //计算本周开始/结束时间
  51. var (lastMonthS, lastMonthE) = TimeHelper.GetStartOrEnd(dateOff, "lastMonth"); //上月开始/结束时间
  52. var (monthS, monthE) = TimeHelper.GetStartOrEnd(dateOff, "month"); //本月开始/结束时间
  53. var (lastTermS, lastTermE) = TimeHelper.GetStartOrEnd(dateOff, "lastterm"); //计算上学期开始/结束时间
  54. var (termS, termE) = TimeHelper.GetStartOrEnd(dateOff, "term"); //计算本学期开始/结束时间
  55. var (yearS, yearE) = TimeHelper.GetStartOrEnd(cuurDateOff, "year"); //计算今年开始/结束时间
  56. var (lWeekDayS, lWeekDayE) = TimeHelper.GetLongToTime(lastWeekS, lastWeekE);
  57. var (weekDayS, weekDayE) = TimeHelper.GetLongToTime(weekS, weekE);
  58. var (lTermDayS, lTermDayE) = TimeHelper.GetLongToTime(lastTermS, lastTermE);
  59. var (termDayS, termDayE) = TimeHelper.GetLongToTime(termS, termE);
  60. var (lMonthS, lMonthE) = TimeHelper.GetLongToTime(lastMonthS, lastMonthE);
  61. var (monthDayS, monthDayE) = TimeHelper.GetLongToTime(monthS, monthE);
  62. var lastDay = dateOff.AddDays(-1);
  63. int lmthDay = TimeHelper.GetDateDay(lMonthE);
  64. StatsInfo statsInfo = null;
  65. var resStsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{dateOff.Year}-{scId}", new PartitionKey("Statistics"));
  66. if (resStsInfo.StatusCode == System.Net.HttpStatusCode.OK)
  67. {
  68. using var fileJson = await JsonDocument.ParseAsync(resStsInfo.Content);
  69. statsInfo = fileJson.ToObject<StatsInfo>();
  70. if (string.IsNullOrEmpty(statsInfo.schoolId))
  71. {
  72. statsInfo.schoolId = scId;
  73. }
  74. }
  75. else
  76. {
  77. var resLastStsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{dateOff.Year - 1}-{scId}", new PartitionKey("Statistics"));
  78. if (resLastStsInfo.StatusCode == System.Net.HttpStatusCode.OK)
  79. {
  80. using var fileJson = await JsonDocument.ParseAsync(resLastStsInfo.Content);
  81. statsInfo = fileJson.ToObject<StatsInfo>();
  82. statsInfo.id = $"{dateOff.Year}-{scId}";
  83. statsInfo.year = dateOff.Year;
  84. statsInfo.schoolId = scId;
  85. statsInfo.stuYear = new double[366].ToList();
  86. statsInfo.tchYear = new double[366].ToList();
  87. statsInfo.lesson.year = new double[366].ToList();
  88. statsInfo.lesson.yearInters = new double[366].ToList();
  89. statsInfo.activity.year = new double[366].ToList();
  90. }
  91. else
  92. {
  93. ScBase scBase = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemAsync<ScBase>(scId, new PartitionKey("Base"));
  94. statsInfo = new StatsInfo
  95. {
  96. id = $"{dateOff.Year}-{scBase.id}",
  97. schoolId = scBase.id,
  98. name = scBase.name,
  99. picture = scBase.picture,
  100. size = scBase.size,
  101. scCreateTime = scBase.createTime,
  102. areaId = scBase.areaId,
  103. upTime = careDate,
  104. stuYear = new double[366].ToList(),
  105. tchYear = new double[366].ToList()
  106. };
  107. statsInfo.lesson.year = new double[366].ToList();
  108. statsInfo.lesson.yearInters = new double[366].ToList();
  109. statsInfo.activity.year = new double[366].ToList();
  110. }
  111. }
  112. switch ($"{type}")
  113. {
  114. case "Exam":
  115. statsInfo.activity.exam += count;
  116. if(statsInfo.activity.exam < 0) statsInfo.activity.exam = 0;
  117. break;
  118. case "Survey":
  119. statsInfo.activity.survey += count;
  120. if(statsInfo.activity.survey < 0) statsInfo.activity.survey = 0;
  121. break;
  122. case "Vote":
  123. statsInfo.activity.vote += count;
  124. if(statsInfo.activity.vote < 0) statsInfo.activity.vote = 0;
  125. break;
  126. case "Homework":
  127. statsInfo.activity.homework += count;
  128. if(statsInfo.activity.homework < 0) statsInfo.activity.homework = 0;
  129. break;
  130. case "Less":
  131. //课例
  132. statsInfo.lesson.year[dateOff.DayOfYear - 1] += count;
  133. statsInfo.lesson.all += count;
  134. if (lessType == 0)
  135. statsInfo.lesson.open += count;
  136. else
  137. statsInfo.lesson.less += count;
  138. var lessList = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.lesson.year });
  139. DenseMatrix lastLesson = null;
  140. DenseMatrix lastInter = null;
  141. StatsInfo lastStats = null;
  142. var resLastStats = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{dateOff.Year - 1}-{scId}", new PartitionKey("Statistics"));
  143. if (resLastStats.StatusCode == System.Net.HttpStatusCode.OK)
  144. {
  145. using var fileJson = await JsonDocument.ParseAsync(resLastStats.Content);
  146. lastStats = fileJson.ToObject<StatsInfo>();
  147. lastLesson = DenseMatrix.OfColumns(new List<List<double>>() { lastStats.lesson.year });
  148. lastInter = DenseMatrix.OfColumns(new List<List<double>>() { lastStats.lesson.yearInters });
  149. }
  150. int lastDayCnt = 0;
  151. if (lastDay.Year < dateOff.Year)
  152. {
  153. lastDayCnt = ((int)lastStats.lesson.year[lastDay.DayOfYear - 1]);
  154. }
  155. else
  156. {
  157. lastDayCnt = ((int)statsInfo.lesson.year[lastDay.DayOfYear - 1]);
  158. }
  159. statsInfo.lesson.lastDay = lastDayCnt;
  160. statsInfo.lesson.day = ((int)statsInfo.lesson.year[dateOff.DayOfYear - 1]);
  161. int lastWeek = 0;
  162. if (lWeekDayS.Year != dateOff.Year)
  163. {
  164. if (lastLesson != null)
  165. {
  166. lastWeek += ((int)lastLesson.SubMatrix(lWeekDayS.DayOfYear - 1, lastLesson.RowCount - lWeekDayS.DayOfYear + 1, 0, lessList.ColumnCount).ColumnSums().Sum());
  167. }
  168. lastWeek += ((int)lessList.SubMatrix(0, lWeekDayE.DayOfYear, 0, lessList.ColumnCount).ColumnSums().Sum());
  169. }
  170. else
  171. {
  172. lastWeek = ((int)lessList.SubMatrix(lWeekDayS.DayOfYear - 1, lWeekDayE.DayOfYear - lWeekDayS.DayOfYear + 1, 0, lessList.ColumnCount).ColumnSums().Sum());
  173. }
  174. statsInfo.lesson.lastWeek = lastWeek;
  175. statsInfo.lesson.week = ((int)lessList.SubMatrix(weekDayS.DayOfYear - 1, (dateOff.DayOfYear - weekDayS.DayOfYear + 1), 0, lessList.ColumnCount).ColumnSums().Sum());
  176. //var resLast = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{lTermDayS.Year}-{scId}", new PartitionKey("Statistics"));
  177. //if (resLast.StatusCode == System.Net.HttpStatusCode.OK)
  178. //{
  179. // using var fileJson = await JsonDocument.ParseAsync(resLast.Content);
  180. // lastStats = fileJson.ToObject<StatsInfo>();
  181. //}
  182. int lastTerm = 0;
  183. if (lTermDayS.Year < dateOff.Year)
  184. {
  185. if (lastLesson != null)
  186. {
  187. lastTerm += ((int)lastLesson.SubMatrix(lTermDayS.DayOfYear - 1, lastStats.lesson.year.Count - lTermDayS.DayOfYear + 1, 0, 1).ColumnSums().Sum());
  188. }
  189. lastTerm += ((int)lessList.SubMatrix(0, lTermDayE.DayOfYear, 0, lessList.ColumnCount).ColumnSums().Sum());
  190. }
  191. else
  192. {
  193. lastTerm += ((int)lessList.SubMatrix(lTermDayS.DayOfYear - 1, lTermDayE.DayOfYear - lTermDayS.DayOfYear + 1, 0, lessList.ColumnCount).ColumnSums().Sum());
  194. }
  195. statsInfo.lesson.lastTerm = lastTerm;
  196. int term = 0;
  197. if (termDayE.Year > dateOff.Year)
  198. {
  199. if (lastStats != null)
  200. {
  201. term = ((int)lessList.SubMatrix(termDayS.DayOfYear - 1, (statsInfo.lesson.year.Count - termDayS.DayOfYear + 1), 0, lessList.ColumnCount).ColumnSums().Sum());
  202. }
  203. }
  204. else
  205. {
  206. if (termDayS.Year < dateOff.Year)
  207. {
  208. if (lastLesson != null)
  209. {
  210. term += ((int)lastLesson.SubMatrix(termDayS.DayOfYear - 1, lastStats.lesson.year.Count - termDayS.DayOfYear + 1, 0, 1).ColumnSums().Sum());
  211. }
  212. term += ((int)lessList.SubMatrix(0, termDayE.DayOfYear, 0, lessList.ColumnCount).ColumnSums().Sum());
  213. }
  214. else
  215. {
  216. term = ((int)lessList.SubMatrix(termDayS.DayOfYear - 1, termDayE.DayOfYear - termDayS.DayOfYear + 1, 0, lessList.ColumnCount).ColumnSums().Sum());
  217. }
  218. }
  219. statsInfo.lesson.term = term;
  220. int lastMonth = 0;
  221. if (lMonthS.Year < dateOff.Year)
  222. {
  223. if (lastLesson != null)
  224. {
  225. lastMonth = ((int)lastLesson.SubMatrix(lMonthS.DayOfYear - 1, lmthDay, 0, lastLesson.ColumnCount).ColumnSums().Sum());
  226. }
  227. }
  228. else
  229. {
  230. lastMonth = ((int)lessList.SubMatrix(lMonthS.DayOfYear - 1, lmthDay, 0, lessList.ColumnCount).ColumnSums().Sum());
  231. }
  232. statsInfo.lesson.lastMonth = lastMonth;
  233. statsInfo.lesson.month = ((int)lessList.SubMatrix(monthDayS.DayOfYear - 1, (dateOff.DayOfYear - monthDayS.DayOfYear + 1), 0, lessList.ColumnCount).ColumnSums().Sum());
  234. //课例互动
  235. statsInfo.lesson.yearInters[dateOff.DayOfYear - 1] += interaction;
  236. statsInfo.lesson.allInter += interaction;
  237. int lastDayInter = 0;
  238. if (lastDay.Year < dateOff.Year)
  239. {
  240. lastDayInter = ((int)lastStats.lesson.yearInters[lastDay.DayOfYear - 1]);
  241. }
  242. else
  243. {
  244. lastDayInter = ((int)statsInfo.lesson.yearInters[lastDay.DayOfYear - 1]);
  245. }
  246. statsInfo.lesson.lastDayInter = lastDayInter;
  247. statsInfo.lesson.dayInter = ((int)statsInfo.lesson.yearInters[dateOff.DayOfYear - 1]);
  248. var interList = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.lesson.yearInters });
  249. int lastMonthInter = 0;
  250. if (lMonthS.Year < dateOff.Year)
  251. {
  252. if (lastInter != null)
  253. {
  254. lastMonthInter = ((int)lastInter.SubMatrix(lMonthS.DayOfYear - 1, lmthDay, 0, lastInter.ColumnCount).ColumnSums().Sum());
  255. }
  256. }
  257. else
  258. {
  259. lastMonthInter = ((int)interList.SubMatrix(lMonthS.DayOfYear - 1, lmthDay, 0, interList.ColumnCount).ColumnSums().Sum());
  260. }
  261. statsInfo.lesson.lastMonthInter = lastMonthInter;
  262. statsInfo.lesson.monthInter = ((int)interList.SubMatrix(monthDayS.DayOfYear - 1, (dateOff.DayOfYear - monthDayS.DayOfYear + 1), 0, interList.ColumnCount).ColumnSums().Sum());
  263. int lastTermI = 0;
  264. if (lastStats != null)
  265. {
  266. if (lastInter != null)
  267. {
  268. lastTermI = ((int)lastInter.SubMatrix(0, lastStats.lesson.year.Count, 0, lastInter.ColumnCount).ColumnSums().Sum());
  269. }
  270. }
  271. statsInfo.lesson.lastYearInter = lastTermI;
  272. statsInfo.lesson.upTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  273. break;
  274. case "Student":
  275. statsInfo.stuYear[dateOff.DayOfYear - 1] += count;
  276. statsInfo.stu += count;
  277. statsInfo.dayStu = ((int)statsInfo.stuYear[dateOff.DayOfYear - 1]);
  278. var stuList = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.stuYear });
  279. statsInfo.weekStu = ((int)stuList.SubMatrix(weekDayS.DayOfYear - 1, (dateOff.DayOfYear - weekDayS.DayOfYear + 1), 0, stuList.ColumnCount).ColumnSums().Sum());
  280. statsInfo.monthStu = ((int)stuList.SubMatrix(monthDayS.DayOfYear - 1, (dateOff.DayOfYear - monthDayS.DayOfYear + 1), 0, stuList.ColumnCount).ColumnSums().Sum());
  281. statsInfo.stuUpTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  282. break;
  283. case "Teacher":
  284. statsInfo.tchYear[dateOff.DayOfYear - 1] += count;
  285. statsInfo.tch += count;
  286. statsInfo.dayTch = ((int)statsInfo.tchYear[dateOff.DayOfYear - 1]);
  287. var tchList = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.tchYear });
  288. statsInfo.weekTch = ((int)tchList.SubMatrix(weekDayS.DayOfYear - 1, (dateOff.DayOfYear - weekDayS.DayOfYear + 1), 0, tchList.ColumnCount).ColumnSums().Sum());
  289. statsInfo.monthTch = ((int)tchList.SubMatrix(monthDayS.DayOfYear - 1, (dateOff.DayOfYear - monthDayS.DayOfYear + 1), 0, tchList.ColumnCount).ColumnSums().Sum());
  290. statsInfo.tchUpTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  291. break;
  292. }
  293. if ($"{type}".Equals("Exam") || $"{type}".Equals("Survey") || $"{type}".Equals("Vote") || $"{type}".Equals("Homework"))
  294. {
  295. statsInfo.activity.all += count;
  296. if (careDate >= yearS && careDate <= yearE)
  297. {
  298. if (count > 0)
  299. {
  300. statsInfo.activity.year[dateOff.DayOfYear - 1] += count;
  301. DenseMatrix matris = DenseMatrix.OfColumns(new List<List<double>>() { statsInfo.activity.year });
  302. DenseMatrix lastAct = null;
  303. StatsInfo lastStats = null;
  304. var resLastStats = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{dateOff.Year - 1}-{scId}", new PartitionKey("Statistics"));
  305. if (resLastStats.StatusCode == System.Net.HttpStatusCode.OK)
  306. {
  307. using var fileJson = await JsonDocument.ParseAsync(resLastStats.Content);
  308. lastStats = fileJson.ToObject<StatsInfo>();
  309. lastAct = DenseMatrix.OfColumns(new List<List<double>>() { lastStats.activity.year });
  310. }
  311. int lastDayCnt = 0;
  312. if (lastDay.Year < dateOff.Year)
  313. {
  314. if (lastStats != null)
  315. {
  316. lastDayCnt = ((int)lastStats.activity.year[lastDay.DayOfYear - 1]);
  317. }
  318. }
  319. else
  320. {
  321. lastDayCnt = ((int)statsInfo.activity.year[lastDay.DayOfYear - 1]);
  322. }
  323. statsInfo.activity.lastDay = lastDayCnt;
  324. statsInfo.activity.dayCnt = ((int)statsInfo.activity.year[dateOff.DayOfYear - 1]);
  325. int lastWeek = 0;
  326. if (lWeekDayS.Year < dateOff.Year)
  327. {
  328. if (lastAct != null)
  329. {
  330. lastWeek += ((int)lastAct.SubMatrix(lWeekDayS.DayOfYear - 1, lastAct.RowCount - lWeekDayS.DayOfYear + 1, 0, lastAct.ColumnCount).ColumnSums().Sum());
  331. }
  332. lastWeek += ((int)matris.SubMatrix(0, lWeekDayE.DayOfYear, 0, matris.ColumnCount).ColumnSums().Sum());
  333. }
  334. else
  335. {
  336. lastWeek = ((int)matris.SubMatrix(lWeekDayS.DayOfYear - 1, lWeekDayE.DayOfYear - lWeekDayS.DayOfYear + 1, 0, matris.ColumnCount).ColumnSums().Sum());
  337. }
  338. statsInfo.activity.lastWeek = lastWeek;
  339. statsInfo.activity.week = ((int)matris.SubMatrix(weekDayS.DayOfYear - 1, dateOff.DayOfYear - weekDayS.DayOfYear + 1, 0, matris.ColumnCount).ColumnSums().Sum());
  340. int lastTerm = 0;
  341. if (lTermDayS.Year < dateOff.Year)
  342. {
  343. if (lastStats != null)
  344. {
  345. lastTerm += ((int)lastAct.SubMatrix(lTermDayS.DayOfYear - 1, lastStats.activity.year.Count - lTermDayS.DayOfYear + 1, 0, lastAct.ColumnCount).ColumnSums().Sum());
  346. }
  347. lastTerm += ((int)matris.SubMatrix(0, lTermDayE.DayOfYear, 0, matris.ColumnCount).ColumnSums().Sum());
  348. }
  349. else
  350. {
  351. lastTerm += ((int)matris.SubMatrix(lTermDayS.DayOfYear - 1, lTermDayE.DayOfYear - lTermDayS.DayOfYear + 1, 0, matris.ColumnCount).ColumnSums().Sum());
  352. }
  353. statsInfo.activity.lastTerm = lastTerm;
  354. int term = 0;
  355. if (termDayS.Year > dateOff.Year)
  356. {
  357. if (lastAct != null)
  358. {
  359. term += ((int)lastAct.SubMatrix(termDayS.DayOfYear - 1, lastStats.activity.year.Count - termDayS.DayOfYear + 1, 0, lastAct.ColumnCount).ColumnSums().Sum());
  360. }
  361. term += ((int)matris.SubMatrix(0, termDayE.DayOfYear + 1, 0, matris.ColumnCount).ColumnSums().Sum());
  362. }
  363. else
  364. {
  365. if (lTermDayS.Year < dateOff.Year)
  366. {
  367. if (lastAct != null)
  368. {
  369. term += ((int)lastAct.SubMatrix(termDayS.DayOfYear - 1, lastStats.activity.year.Count - termDayS.DayOfYear + 1, 0, 1).ColumnSums().Sum());
  370. }
  371. term += ((int)matris.SubMatrix(0, termDayE.DayOfYear, 0, matris.ColumnCount).ColumnSums().Sum());
  372. }
  373. else
  374. {
  375. // 判定计算出的数据是否为负数 如果为负数 当前时间减去学期开始时间 否则是 本学期时间 减去 本学期开始时间天数
  376. // (termDayE.DayOfYear - termDayS.DayOfYear + 1) < 0 ? dateOff.DayOfYear - termDayS.DayOfYear + 1 : termDayE.DayOfYear - termDayS.DayOfYear + 1
  377. term += ((int)matris.SubMatrix(termDayS.DayOfYear - 1, (termDayE.DayOfYear - termDayS.DayOfYear + 1) < 0 ? dateOff.DayOfYear - termDayS.DayOfYear + 1 : termDayE.DayOfYear - termDayS.DayOfYear + 1, 0, matris.ColumnCount).ColumnSums().Sum());
  378. //term += ((int)matris.SubMatrix(termDayS.DayOfYear - 1, termDayE.DayOfYear - termDayS.DayOfYear + 1, 0, matris.ColumnCount).ColumnSums().Sum());
  379. }
  380. }
  381. statsInfo.activity.term = term;
  382. int lastMonth = 0;
  383. if (lMonthS.Year < dateOff.Year)
  384. {
  385. if (lastAct != null)
  386. {
  387. lastMonth = ((int)lastAct.SubMatrix(lMonthS.DayOfYear - 1, lmthDay, 0, matris.ColumnCount).ColumnSums().Sum());
  388. }
  389. }
  390. else
  391. {
  392. lastMonth = ((int)matris.SubMatrix(lMonthS.DayOfYear - 1, lmthDay, 0, matris.ColumnCount).ColumnSums().Sum());
  393. }
  394. statsInfo.activity.lastMonth = lastMonth;
  395. statsInfo.activity.month += ((int)matris.SubMatrix(monthDayS.DayOfYear, (dateOff.DayOfYear - monthDayS.DayOfYear), 0, matris.ColumnCount).ColumnSums().Sum());
  396. statsInfo.activity.upTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  397. }
  398. }
  399. }
  400. if (resStsInfo.StatusCode == System.Net.HttpStatusCode.OK)
  401. {
  402. statsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync<StatsInfo>(statsInfo, statsInfo.id, new PartitionKey("Statistics"));
  403. }
  404. else
  405. {
  406. statsInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").CreateItemAsync<StatsInfo>(statsInfo, new PartitionKey("Statistics"));
  407. }
  408. }
  409. catch (Exception ex)
  410. {
  411. await _dingDing.SendBotMsg($"BI,{Environment.GetEnvironmentVariable("Option:Location")},SetTypeAddStats(),参数: 学校:{scId},统计类型:{type}, 增/减数:{count},课例类型(0:开课,1:课例):{lessType},学生互动数:{interaction},时间戳:{careDate}\n {ex.Message}\n {ex.StackTrace}", GroupNames.成都开发測試群組);
  412. }
  413. }
  414. /// <summary>
  415. /// 创建/创建BI统计信息接口
  416. /// </summary>
  417. /// <param name="cosmosClient"></param>
  418. /// <param name="school"></param>
  419. /// <returns></returns>
  420. public static async Task SetScStatsInfo(CosmosClient cosmosClient, DingDing _dingDing, School school)
  421. {
  422. try
  423. {
  424. DateTimeOffset dateOff = DateTimeOffset.UtcNow;
  425. StatsInfo statsInfo = new();
  426. var resStats = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{dateOff.Year}-{school.id}", new PartitionKey("Statistics"));
  427. if (resStats.StatusCode == System.Net.HttpStatusCode.OK)
  428. {
  429. using var fileJson = await JsonDocument.ParseAsync(resStats.Content);
  430. statsInfo = fileJson.ToObject<StatsInfo>();
  431. }
  432. else
  433. {
  434. double[] tchYear = new double[366];
  435. tchYear[0] = 1;
  436. statsInfo.id = $"{dateOff.Year}-{school.id}";
  437. statsInfo.year = dateOff.Year;
  438. statsInfo.stuYear = new double[366].ToList();
  439. statsInfo.tchYear = tchYear.ToList();
  440. statsInfo.tch = 1;
  441. statsInfo.weekTch = 1;
  442. statsInfo.monthTch = 1;
  443. statsInfo.tchUpTime = dateOff.ToUnixTimeMilliseconds();
  444. statsInfo.lesson.year = new double[366].ToList();
  445. statsInfo.lesson.yearInters = new double[366].ToList();
  446. statsInfo.activity.year = new double[366].ToList();
  447. }
  448. statsInfo.schoolId = school.id;
  449. statsInfo.name = school.name;
  450. statsInfo.picture = school.picture;
  451. statsInfo.size = school.size;
  452. statsInfo.scCreateTime = school.createTime;
  453. statsInfo.areaId = school.areaId;
  454. statsInfo.upTime = dateOff.ToUnixTimeMilliseconds();
  455. if (resStats.StatusCode == System.Net.HttpStatusCode.OK)
  456. {
  457. await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync<StatsInfo>(statsInfo, statsInfo.id, new PartitionKey("Statistics"));
  458. }
  459. else
  460. {
  461. await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").CreateItemAsync<StatsInfo>(statsInfo, new PartitionKey("Statistics"));
  462. }
  463. }
  464. catch (Exception ex)
  465. {
  466. await _dingDing.SendBotMsg($"BI,{Environment.GetEnvironmentVariable("Option:Location")},SetScStatsInfo() 学校:{school} \n{ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  467. }
  468. }
  469. /// <summary>
  470. /// 新增/修改学校列表中间件
  471. /// </summary>
  472. /// <param name="cosmosClient"></param>
  473. /// <param name="tableClient"></param>
  474. /// <param name="blobClient"></param>
  475. /// <param name="_dingDing"></param>
  476. /// <param name="school"></param>
  477. /// <returns></returns>
  478. public static async Task SetSchoolBIRelation(CosmosClient cosmosClient, BlobContainerClient blobClient, CloudTableClient tableClient, DingDing _dingDing, School school)
  479. {
  480. try
  481. {
  482. string type = "";
  483. BIRelation bIRelation = new();
  484. var resBiRel = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(school.id, new PartitionKey("BIRel"));
  485. if (resBiRel.StatusCode == System.Net.HttpStatusCode.OK)
  486. {
  487. using var fileJson = await JsonDocument.ParseAsync(resBiRel.Content);
  488. bIRelation = fileJson.ToObject<BIRelation>();
  489. }
  490. else
  491. {
  492. bIRelation.id = school.id;
  493. }
  494. string aName = null;
  495. if (!string.IsNullOrEmpty($"{school.areaId}"))
  496. {
  497. aName = await CosmosQueryHelper.GetStr(cosmosClient, "Normal", $"select value(c.name) from c where c.id='{school.areaId}'", "Base-Area");
  498. }
  499. bIRelation.name = school.name;
  500. bIRelation.picture = school.picture;
  501. bIRelation.region = school.region;
  502. bIRelation.province = school.province;
  503. bIRelation.city = school.city;
  504. bIRelation.dist = school.dist;
  505. bIRelation.address = school.address;
  506. bIRelation.areaId = school.areaId;
  507. bIRelation.size = school.size;
  508. bIRelation.scale = school.scale;
  509. bIRelation.upDate = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  510. bIRelation.areaName = aName;
  511. bIRelation.edition = school.edition;
  512. if (resBiRel.StatusCode == System.Net.HttpStatusCode.OK)
  513. {
  514. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<BIRelation>(bIRelation, bIRelation.id, new PartitionKey("BIRel"));
  515. type = "update";
  516. }
  517. else
  518. {
  519. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<BIRelation>(bIRelation, new PartitionKey("BIRel"));
  520. type = "add";
  521. }
  522. //保存操作记录
  523. await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, $"birelation-{type}", $"触发更新学校信息表中间件", _dingDing);
  524. }
  525. catch (Exception ex)
  526. {
  527. await _dingDing.SendBotMsg($"BI,{Environment.GetEnvironmentVariable("Option:Location")},SetSchoolBIRelation() 学校:{school} \n{ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  528. }
  529. }
  530. /// <summary>
  531. /// 每天00:00执行统计清零方法;zore时间
  532. /// </summary>
  533. /// <param name="_azureCosmos"></param>
  534. /// <param name="_dingDing"></param>
  535. /// <returns></returns>
  536. public static async Task SetStatsZeroPoint(AzureCosmosFactory _azureCosmos, DingDing _dingDing)
  537. {
  538. List<string> scId = new();
  539. try
  540. {
  541. var cosmosClient = _azureCosmos.GetCosmosClient();
  542. DateTimeOffset dateOff = DateTimeOffset.Now;
  543. long upTime = dateOff.ToUnixTimeMilliseconds();
  544. var (DayS, DayE) = TimeHelper.GetStartOrEnd(dateOff); //今天开始时间结束时间
  545. var (lastWeekS, lastWeekE) = TimeHelper.GetStartOrEnd(dateOff, "lastweek"); //计算上周开始/结束时间
  546. var (weekS, weekE) = TimeHelper.GetStartOrEnd(dateOff, "week"); //计算本周开始/结束时间
  547. var (lastMonthS, lastMonthE) = TimeHelper.GetStartOrEnd(dateOff, "lastMonth"); //上月开始/结束时间
  548. var (monthS, monthE) = TimeHelper.GetStartOrEnd(dateOff, "month"); //本月开始/结束时间
  549. var (lastTermS, lastTermE) = TimeHelper.GetStartOrEnd(dateOff, "lastterm"); //计算上学期开始/结束时间
  550. var (termS, termE) = TimeHelper.GetStartOrEnd(dateOff, "term"); //计算本学期开始/结束时间
  551. var (lWeekDayS, lWeekDayE) = TimeHelper.GetLongToTime(lastWeekS, lastWeekE);
  552. var (weekDayS, weekDayE) = TimeHelper.GetLongToTime(weekS, weekE);
  553. var (lTermDayS, lTermDayE) = TimeHelper.GetLongToTime(lastTermS, lastTermE);
  554. var (termDayS, termDayE) = TimeHelper.GetLongToTime(termS, termE);
  555. var (lMonthS, lMonthE) = TimeHelper.GetLongToTime(lastMonthS, lastMonthE);
  556. var (monthDayS, monthDayE) = TimeHelper.GetLongToTime(monthS, monthE);
  557. var lastDay = dateOff.AddDays(-1);
  558. int lmthDay = TimeHelper.GetDateDay(lMonthE);
  559. List<Task<ItemResponse<StatsInfo>>> statsInfos = new();
  560. List<StatsInfo> tempStatsInfos = new();
  561. StringBuilder statsSql = new($"select value(c) from c where c.year={dateOff.Year}");
  562. List<string> scIds = new();
  563. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIteratorSql<string>(queryText: $"select value(c.id) from c ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("BIRel") }))
  564. {
  565. scIds.Add(item);
  566. }
  567. if (scIds.Count > 0)
  568. {
  569. statsSql.Append($" and {BICommonWay.ManyScSql("c.id", scIds, $"{dateOff.Year}-")}");
  570. }
  571. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryIteratorSql<StatsInfo>(queryText: statsSql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Statistics") }))
  572. {
  573. tempStatsInfos.Add(item);
  574. }
  575. if (tempStatsInfos.Count > 0)
  576. {
  577. foreach (var item in tempStatsInfos)
  578. {
  579. try
  580. {
  581. StatsInfo lastStatsInfo = null;
  582. DenseMatrix lastTch = null;
  583. DenseMatrix lastStu = null;
  584. DenseMatrix lastLesson = null;
  585. DenseMatrix lastInter = null;
  586. DenseMatrix lastAct = null;
  587. var lastSts = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync($"{dateOff.Year - 1}-{item.schoolId}", new PartitionKey("Statistics"));
  588. if (lastSts.StatusCode == System.Net.HttpStatusCode.OK)
  589. {
  590. using var fileJson = await JsonDocument.ParseAsync(lastSts.Content);
  591. lastStatsInfo = fileJson.ToObject<StatsInfo>();
  592. item.schoolId = lastStatsInfo.schoolId;
  593. item.year = dateOff.Year;
  594. item.picture = lastStatsInfo.picture;
  595. item.name = lastStatsInfo.name;
  596. item.areaId = lastStatsInfo.areaId;
  597. item.size = lastStatsInfo.size;
  598. item.useSize = lastStatsInfo.useSize;
  599. item.tch = lastStatsInfo.tch;
  600. lastTch = DenseMatrix.OfColumns(new List<List<double>>() { lastStatsInfo.tchYear });
  601. lastStu = DenseMatrix.OfColumns(new List<List<double>>() { lastStatsInfo.stuYear });
  602. lastLesson = DenseMatrix.OfColumns(new List<List<double>>() { lastStatsInfo.lesson.year });
  603. lastInter = DenseMatrix.OfColumns(new List<List<double>>() { lastStatsInfo.lesson.yearInters });
  604. lastAct = DenseMatrix.OfColumns(new List<List<double>>() { lastStatsInfo.activity.year });
  605. }
  606. var tchList = DenseMatrix.OfColumns(new List<List<double>>() { item.tchYear });
  607. var stuList = DenseMatrix.OfColumns(new List<List<double>>() { item.stuYear });
  608. int dayTch = 0;
  609. int dayStu = 0;
  610. int lastDayLesson = 0;
  611. int lastDayAct = 0;
  612. if (lastDay.Year < dateOff.Year)
  613. {
  614. if (lastStatsInfo != null)
  615. {
  616. dayTch = ((int)lastStatsInfo.tchYear[lastDay.DayOfYear - 1]);
  617. dayStu = ((int)lastStatsInfo.stuYear[lastDay.DayOfYear - 1]);
  618. lastDayLesson = ((int)lastStatsInfo.lesson.year[lastDay.DayOfYear - 1]);
  619. lastDayAct = ((int)lastStatsInfo.activity.year[lastDay.DayOfYear - 1]);
  620. }
  621. }
  622. else
  623. {
  624. dayTch = ((int)item.tchYear[dateOff.DayOfYear - 1]);
  625. dayStu = ((int)item.stuYear[dateOff.DayOfYear - 1]);
  626. lastDayLesson = ((int)item.lesson.year[lastDay.DayOfYear - 1]);
  627. lastDayAct = ((int)item.activity.year[lastDay.DayOfYear - 1]);
  628. }
  629. item.dayTch = dayTch;
  630. int weekTch = 0;
  631. int weekStu = 0;
  632. if (weekDayS.Year < dateOff.Year)
  633. {
  634. if (lastTch != null)
  635. {
  636. weekTch += ((int)lastTch.SubMatrix(weekDayS.DayOfYear - 1, lastTch.RowCount - weekDayS.DayOfYear + 1, 0, lastTch.ColumnCount).ColumnSums().Sum());
  637. }
  638. weekTch += ((int)tchList.SubMatrix(0, weekDayE.DayOfYear + 1, 0, tchList.ColumnCount).ColumnSums().Sum());
  639. if (lastStu != null)
  640. {
  641. weekStu += ((int)lastStu.SubMatrix(weekDayS.DayOfYear - 1, lastStu.RowCount - weekDayS.DayOfYear + 1, 0, lastStu.ColumnCount).ColumnSums().Sum());
  642. }
  643. weekStu += ((int)lastStu.SubMatrix(0, weekDayE.DayOfYear + 1, 0, lastStu.ColumnCount).ColumnSums().Sum());
  644. }
  645. else
  646. {
  647. weekTch = ((int)tchList.SubMatrix(weekDayS.DayOfYear - 1, 7, 0, tchList.ColumnCount).ColumnSums().Sum());
  648. weekStu = ((int)stuList.SubMatrix(weekDayS.DayOfYear - 1, 7, 0, stuList.ColumnCount).ColumnSums().Sum());
  649. }
  650. item.weekTch = weekTch;
  651. item.monthTch = ((int)tchList.SubMatrix(monthDayS.DayOfYear - 1, (dateOff.DayOfYear - monthDayS.DayOfYear + 1), 0, tchList.ColumnCount).ColumnSums().Sum());
  652. item.tchUpTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  653. item.dayStu = dayStu;
  654. item.weekStu = weekStu;
  655. item.monthStu = ((int)stuList.SubMatrix(monthDayS.DayOfYear - 1, (dateOff.DayOfYear - monthDayS.DayOfYear + 1), 0, stuList.ColumnCount).ColumnSums().Sum());
  656. item.stuUpTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  657. var lessList = DenseMatrix.OfColumns(new List<List<double>>() { item.lesson.year });
  658. var interList = DenseMatrix.OfColumns(new List<List<double>>() { item.lesson.yearInters });
  659. var actList = DenseMatrix.OfColumns(new List<List<double>>() { item.activity.year });
  660. item.lesson.lastDay = lastDayLesson;
  661. int lastWeekLesson = 0;
  662. int lastWeekAct = 0;
  663. if (lWeekDayS.Year != dateOff.Year)
  664. {
  665. if (lastLesson != null)
  666. {
  667. lastWeekLesson += ((int)lastLesson.SubMatrix(lWeekDayS.DayOfYear - 1, lastLesson.RowCount - lWeekDayS.DayOfYear + 1, 0, lessList.ColumnCount).ColumnSums().Sum());
  668. }
  669. lastWeekLesson += ((int)lessList.SubMatrix(0, lWeekDayE.DayOfYear, 0, lessList.ColumnCount).ColumnSums().Sum());
  670. if (lastAct != null)
  671. {
  672. lastWeekAct += ((int)lastAct.SubMatrix(lWeekDayS.DayOfYear - 1, lastAct.RowCount - lWeekDayS.DayOfYear + 1, 0, lastAct.ColumnCount).ColumnSums().Sum());
  673. }
  674. lastWeekAct += ((int)lastAct.SubMatrix(0, lWeekDayE.DayOfYear, 0, lastAct.ColumnCount).ColumnSums().Sum());
  675. }
  676. else
  677. {
  678. lastWeekLesson = ((int)lessList.SubMatrix(lWeekDayS.DayOfYear - 1, lWeekDayE.DayOfYear - lWeekDayS.DayOfYear + 1, 0, lessList.ColumnCount).ColumnSums().Sum());
  679. lastWeekAct = ((int)actList.SubMatrix(lWeekDayS.DayOfYear - 1, 7, 0, actList.ColumnCount).ColumnSums().Sum());
  680. }
  681. item.lesson.lastWeek = lastWeekLesson;
  682. item.lesson.week = ((int)lessList.SubMatrix(weekDayS.DayOfYear - 1, (dateOff.DayOfYear - weekDayS.DayOfYear + 1), 0, lessList.ColumnCount).ColumnSums().Sum());
  683. int lastTerm = 0;
  684. if (lTermDayS.Year < dateOff.Year)
  685. {
  686. if (lastLesson != null)
  687. {
  688. lastTerm += ((int)lastLesson.SubMatrix(lTermDayS.DayOfYear - 1, lastStatsInfo.lesson.year.Count - lTermDayS.DayOfYear + 1, 0, 1).ColumnSums().Sum());
  689. }
  690. lastTerm += ((int)lessList.SubMatrix(0, lTermDayE.DayOfYear, 0, lessList.ColumnCount).ColumnSums().Sum());
  691. }
  692. else
  693. {
  694. lastTerm += ((int)lessList.SubMatrix(lTermDayS.DayOfYear - 1, lTermDayE.DayOfYear - lTermDayS.DayOfYear + 1, 0, lessList.ColumnCount).ColumnSums().Sum());
  695. }
  696. item.lesson.lastTerm = lastTerm;
  697. int term = 0;
  698. if (termDayE.Year > dateOff.Year)
  699. {
  700. if (lessList != null)
  701. {
  702. term = ((int)lessList.SubMatrix(termDayS.DayOfYear - 1, (lessList.RowCount - termDayS.DayOfYear + 1), 0, lessList.ColumnCount).ColumnSums().Sum());
  703. }
  704. }
  705. else
  706. {
  707. if (termDayS.Year < dateOff.Year)
  708. {
  709. if (lastLesson != null)
  710. {
  711. term += ((int)lastLesson.SubMatrix(termDayS.DayOfYear - 1, lastLesson.RowCount - termDayS.DayOfYear + 1, 0, lastLesson.ColumnCount).ColumnSums().Sum());
  712. }
  713. term += ((int)lessList.SubMatrix(0, termDayE.DayOfYear, 0, lessList.ColumnCount).ColumnSums().Sum());
  714. }
  715. else
  716. {
  717. term = ((int)lessList.SubMatrix(termDayS.DayOfYear - 1, termDayE.DayOfYear - termDayS.DayOfYear + 1, 0, lessList.ColumnCount).ColumnSums().Sum());
  718. }
  719. }
  720. item.lesson.term = term;
  721. item.lesson.day = 0;
  722. int lastMonth = 0;
  723. int lastMonthInter = 0;
  724. int lastMonthAct = 0;
  725. if (lMonthS.Year < dateOff.Year)
  726. {
  727. if (lastLesson != null)
  728. {
  729. lastMonth = ((int)lastLesson.SubMatrix(lMonthS.DayOfYear - 1, lmthDay, 0, lastLesson.ColumnCount).ColumnSums().Sum());
  730. }
  731. if (lastInter != null)
  732. {
  733. lastMonthInter = ((int)lastInter.SubMatrix(lMonthS.DayOfYear - 1, lmthDay, 0, lastInter.ColumnCount).ColumnSums().Sum());
  734. }
  735. if (lastAct != null)
  736. {
  737. lastMonthAct = ((int)lastAct.SubMatrix(lMonthS.DayOfYear - 1, lmthDay, 0, lastAct.ColumnCount).ColumnSums().Sum());
  738. }
  739. }
  740. else
  741. {
  742. lastMonth = ((int)lessList.SubMatrix(lMonthS.DayOfYear - 1, lmthDay, 0, lessList.ColumnCount).ColumnSums().Sum());
  743. lastMonthInter = ((int)interList.SubMatrix(lMonthS.DayOfYear - 1, lmthDay, 0, interList.ColumnCount).ColumnSums().Sum());
  744. lastMonthAct = ((int)actList.SubMatrix(lMonthS.DayOfYear - 1, lmthDay, 0, actList.ColumnCount).ColumnSums().Sum());
  745. }
  746. item.lesson.lastMonth = lastMonth;
  747. item.lesson.month += ((int)lessList.SubMatrix(monthDayS.DayOfYear - 1, (dateOff.DayOfYear - monthDayS.DayOfYear + 1), 0, lessList.ColumnCount).ColumnSums().Sum());
  748. item.lesson.upTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  749. int lastDayInter = 0;
  750. if (lastDay.Year < dateOff.Year)
  751. {
  752. if (lastStatsInfo.lesson.yearInters.Count > 0)
  753. {
  754. lastDayInter = ((int)lastStatsInfo.lesson.yearInters[lastDay.DayOfYear - 1]);
  755. }
  756. }
  757. else
  758. {
  759. lastDayInter = ((int)item.lesson.yearInters[lastDay.DayOfYear - 1]);
  760. }
  761. item.lesson.lastDayInter = lastDayInter;
  762. item.lesson.dayInter = 0;
  763. item.lesson.lastMonthInter = lastMonthInter;
  764. item.lesson.monthInter = ((int)interList.SubMatrix(monthDayS.DayOfYear - 1, (dateOff.DayOfYear - monthDayS.DayOfYear + 1), 0, interList.ColumnCount).ColumnSums().Sum());
  765. if (lastStatsInfo != null)
  766. {
  767. if (lastInter != null)
  768. {
  769. item.lesson.lastYearInter = ((int)lastInter.SubMatrix(0, lastInter.RowCount, 0, lastInter.ColumnCount).ColumnSums().Sum());
  770. }
  771. }
  772. item.lesson.yearInter = ((int)item.lesson.yearInters.Sum());
  773. item.activity.dayCnt = ((int)item.activity.year[dateOff.DayOfYear - 1]);
  774. item.activity.lastDay = lastDayAct;
  775. item.activity.lastWeek = lastWeekAct;
  776. item.activity.week = ((int)actList.SubMatrix(weekDayS.DayOfYear - 1, (dateOff.DayOfYear - monthDayS.DayOfYear + 1), 0, actList.ColumnCount).ColumnSums().Sum());
  777. item.activity.lastMonth = lastMonthAct;
  778. int lastTermAct = 0;
  779. if (lTermDayS.Year < dateOff.Year)
  780. {
  781. if (lastAct != null && lastAct.RowCount.Equals(actList.RowCount))
  782. {
  783. lastTermAct += ((int)lastAct.SubMatrix(lTermDayS.DayOfYear - 1, lastStatsInfo.activity.year.Count - lTermDayS.DayOfYear + 1, 0, lastAct.ColumnCount).ColumnSums().Sum());
  784. }
  785. lastTermAct += ((int)actList.SubMatrix(0, lTermDayE.DayOfYear, 0, actList.ColumnCount).ColumnSums().Sum());
  786. }
  787. else
  788. {
  789. lastTermAct += ((int)actList.SubMatrix(lTermDayS.DayOfYear - 1, lTermDayE.DayOfYear - lTermDayS.DayOfYear + 1, 0, actList.ColumnCount).ColumnSums().Sum());
  790. }
  791. item.activity.lastTerm = lastTerm;
  792. int termAct = 0;
  793. if (termDayS.Year > dateOff.Year)
  794. {
  795. if (lastAct != null)
  796. {
  797. termAct += ((int)lastAct.SubMatrix(termDayS.DayOfYear - 1, lastStatsInfo.activity.year.Count - termDayS.DayOfYear + 1, 0, lastAct.ColumnCount).ColumnSums().Sum());
  798. }
  799. termAct += ((int)actList.SubMatrix(0, termDayE.DayOfYear + 1, 0, actList.ColumnCount).ColumnSums().Sum());
  800. }
  801. else
  802. {
  803. if (lTermDayS.Year < dateOff.Year)
  804. {
  805. if (lastAct != null && lastAct.RowCount.Equals(actList.RowCount))
  806. {
  807. termAct += ((int)lastAct.SubMatrix(termDayS.DayOfYear - 1, lastStatsInfo.lesson.year.Count - termDayS.DayOfYear + 1, 0, 1).ColumnSums().Sum());
  808. }
  809. termAct += ((int)actList.SubMatrix(0, termDayE.DayOfYear, 0, actList.ColumnCount).ColumnSums().Sum());
  810. }
  811. else
  812. {
  813. termAct += ((int)actList.SubMatrix(termDayS.DayOfYear - 1, termDayE.DayOfYear - termDayS.DayOfYear + 1, 0, actList.ColumnCount).ColumnSums().Sum());
  814. }
  815. }
  816. item.activity.term = term;
  817. item.activity.upTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  818. statsInfos.Add(cosmosClient.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync<StatsInfo>(item, item.id, new PartitionKey("Statistics")));
  819. }
  820. catch
  821. {
  822. scId.Add(item.schoolId);
  823. }
  824. }
  825. if (statsInfos.Count < 256)
  826. {
  827. await Task.WhenAll(statsInfos);
  828. }
  829. else
  830. {
  831. int pages = (statsInfos.Count + 255) / 256;
  832. for (int i = 0; i < pages; i++)
  833. {
  834. List<Task<ItemResponse<StatsInfo>>> itemResponses = statsInfos.Skip((i) * 256).Take(256).ToList();
  835. await Task.WhenAll(itemResponses);
  836. }
  837. }
  838. }
  839. string str = "";
  840. if (scId.Count > 0)
  841. {
  842. str = $"定时未清理学校id:{scId.ToJsonString()}";
  843. }
  844. else
  845. {
  846. str = "定时清理学校统计成功";
  847. }
  848. //await _dingDing.SendBotMsg($"BI,{Environment.GetEnvironmentVariable("Option:Location")},SetStatsZeroPoint() {str}\n ", GroupNames.醍摩豆服務運維群組);
  849. }
  850. catch (Exception ex)
  851. {
  852. await _dingDing.SendBotMsg($"BI,{Environment.GetEnvironmentVariable("Option:Location")},SetStatsZeroPoint() \n{scId.ToJsonString()} \n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  853. }
  854. }
  855. }
  856. }