BIStats.cs 56 KB

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