LessonSticsController.cs 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627
  1. using Microsoft.AspNetCore.Http;
  2. using Microsoft.AspNetCore.Mvc;
  3. using System;
  4. using System.Collections.Generic;
  5. using System.Linq;
  6. using System.Threading.Tasks;
  7. using TEAMModelOS.Models;
  8. using TEAMModelOS.SDK.DI;
  9. using Microsoft.Extensions.Options;
  10. using Azure.Cosmos;
  11. using System.Text.Json;
  12. using TEAMModelOS.SDK.Models.Cosmos.Common;
  13. using TEAMModelOS.SDK.Models;
  14. using TEAMModelBI.Models;
  15. using TEAMModelOS.SDK.Extension;
  16. using System.Text;
  17. using TEAMModelBI.Tool;
  18. using MathNet.Numerics.LinearAlgebra.Double;
  19. using TEAMModelBI.Tool.CosmosBank;
  20. using TEAMModelOS.SDK.Context.BI;
  21. using TEAMModelOS.SDK.Models.Service.BI;
  22. namespace TEAMModelBI.Controllers.Census
  23. {
  24. [Route("lesson")]
  25. [ApiController]
  26. public class LessonSticsController : ControllerBase
  27. {
  28. private readonly AzureCosmosFactory _azureCosmos;
  29. private readonly AzureStorageFactory _azureStorage;
  30. private readonly DingDing _dingDing;
  31. private readonly Option _option;
  32. public LessonSticsController(AzureCosmosFactory azureCosmos, AzureStorageFactory azureFactory, DingDing dingDing, IOptionsSnapshot<Option> option)
  33. {
  34. _azureCosmos = azureCosmos;
  35. _azureStorage = azureFactory;
  36. _dingDing = dingDing;
  37. _option = option?.Value;
  38. }
  39. /// <summary>
  40. /// 查询课例数量
  41. /// </summary>
  42. /// <param name="jsonElement"></param>
  43. /// <returns></returns>
  44. [HttpPost("get-count")]
  45. public async Task<IActionResult> GetCount(JsonElement jsonElement)
  46. {
  47. jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
  48. if (!jsonElement.TryGetProperty("term", out JsonElement term)) return BadRequest();
  49. jsonElement.TryGetProperty("site", out JsonElement site);
  50. var cosmosClient = _azureCosmos.GetCosmosClient();
  51. if ($"{site}".Equals(BIConst.Global))
  52. cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  53. var (start, end) = TimeHelper.GetTermStartOrEnd(DateTime.Now);
  54. object totals = new();
  55. StringBuilder sqlTxt = new($"select COUNT(c.id) AS totals from c where c.pk='LessonRecord'");
  56. if (!string.IsNullOrEmpty($"{tmdId}"))
  57. {
  58. List<SchoolLen> schoolLens = new();
  59. List<string> schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
  60. foreach (var itemId in schoolIds)
  61. {
  62. School school = new();
  63. var response = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(itemId, new PartitionKey("Base"));
  64. if (response.Status == 200)
  65. {
  66. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  67. school = json.ToObject<School>();
  68. }
  69. SchoolLen schoolLen = new() { id = itemId, name =
  70. school.name != null ? school.name : itemId };
  71. //string sqlTxt = $"SELECT COUNT(c.id) AS totals FROM c WHERE c.code='LessonRecord-{itemId}'";
  72. sqlTxt.Append($" WHERE c.code='LessonRecord-{itemId}'");
  73. if (bool.Parse($"{term}") == true)
  74. {
  75. sqlTxt.Append($" and c.startTime >= {start} and c.startTime <= {end}");
  76. }
  77. schoolLen.totals = await CommonFind.FindTotals(cosmosClient, sqlTxt.ToString(), new List<string>() { "School" });
  78. schoolLens.Add(schoolLen);
  79. }
  80. totals = schoolLens;
  81. }
  82. else
  83. {
  84. sqlTxt.Append($" where c.pk='LessonRecord'");
  85. if (bool.Parse($"{term}") == true)
  86. {
  87. sqlTxt.Append($" and c.startTime >= {start} and c.startTime <= {end}");
  88. }
  89. totals = await CommonFind.FindTotals(cosmosClient, sqlTxt.ToString(), new List<string>() { "School","Teacher" });
  90. }
  91. return Ok(new { state = 200, totals });
  92. }
  93. /// <summary>
  94. /// 统计所有课例数量
  95. /// </summary>
  96. /// <returns></returns>
  97. [HttpPost("get-total")]
  98. public async Task<IActionResult> GetAllCount(JsonElement jsonElement)
  99. {
  100. try
  101. {
  102. jsonElement.TryGetProperty("site", out JsonElement site);
  103. var cosmosClient = _azureCosmos.GetCosmosClient();
  104. if ($"{site}".Equals(BIConst.Global))
  105. cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  106. string lessonSql = $"select COUNT(c.id) AS totals from c where c.pk='LessonRecord'";
  107. long total = await CommonFind.FindTotals(cosmosClient, lessonSql, new List<string>() { "School","Teacher" });
  108. return Ok(new { state = 200, total });
  109. }
  110. catch (Exception ex)
  111. {
  112. await _dingDing.SendBotMsg($"BI,{_option.Location} /lesson/get-total \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  113. return BadRequest();
  114. }
  115. }
  116. /// <summary>
  117. /// 管家所关联的课例数据
  118. /// </summary>
  119. /// <param name="jsonElement"></param>
  120. /// <returns></returns>
  121. [ProducesDefaultResponseType]
  122. [HttpPost("get-assiist")]
  123. public async Task<IActionResult> GetAssiist(JsonElement jsonElement)
  124. {
  125. try
  126. {
  127. if (!jsonElement.TryGetProperty("tmdId", out JsonElement tmdId)) return BadRequest();
  128. jsonElement.TryGetProperty("site", out JsonElement site);
  129. var cosmosClient = _azureCosmos.GetCosmosClient();
  130. if ($"{site}".Equals(BIConst.Global))
  131. cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  132. List<SchoolLen> schoolLens = new();
  133. List<string> schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
  134. foreach (var itemId in schoolIds)
  135. {
  136. School school = new();
  137. var response = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(itemId, new PartitionKey("Base"));
  138. if (response.Status == 200)
  139. {
  140. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  141. school = json.ToObject<School>();
  142. }
  143. SchoolLen schoolLen = new() { id = itemId, name = school != null ? school.name : itemId };
  144. string sqlTxt = $"SELECT COUNT(c.id) AS totals FROM c WHERE c.code='LessonRecord-{itemId}'";
  145. schoolLen.totals = await CommonFind.FindTotals(cosmosClient, sqlTxt, new List<string>() { "School" });
  146. schoolLens.Add(schoolLen);
  147. }
  148. return Ok(new { state = 200, schoolLens });
  149. }
  150. catch (Exception ex)
  151. {
  152. await _dingDing.SendBotMsg($"BI, {_option.Location} /lesson/get-assiist {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  153. return BadRequest();
  154. }
  155. }
  156. /// <summary>
  157. /// 统计所有的课例数据
  158. /// </summary>
  159. /// <returns></returns>
  160. [HttpPost("get-diccount")]
  161. public async Task<IActionResult> GetDicCount(JsonElement jsonElement)
  162. {
  163. jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
  164. jsonElement.TryGetProperty("site", out JsonElement site);
  165. var cosmosClient = _azureCosmos.GetCosmosClient();
  166. if ($"{site}".Equals(BIConst.Global))
  167. cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  168. if (!string.IsNullOrEmpty($"{tmdId}"))
  169. {
  170. jsonElement.TryGetProperty("years", out JsonElement _years);
  171. int years = DateTime.UtcNow.Year;
  172. if (!string.IsNullOrEmpty($"{_years}"))
  173. {
  174. years = _years.GetInt32();
  175. }
  176. List<SchoolLen> schoolLens = new();
  177. List<string> schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
  178. foreach (string schoolId in schoolIds)
  179. {
  180. School school = new();
  181. var response = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(schoolId, new PartitionKey("Base"));
  182. if (response.Status == 200)
  183. {
  184. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  185. school = json.ToObject<School>();
  186. }
  187. SchoolLen schoolLen = new() { id = schoolId, name = school != null ? school.name : schoolId };
  188. List<List<double>> begin = new();
  189. await foreach (var lcount in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<LessonCount>(queryText: "select value(c) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"LessonCount-{schoolId}-{years}") }))
  190. {
  191. begin.Add(lcount.beginCount);
  192. }
  193. schoolLen.totals = (long)DenseMatrix.OfColumns(begin).ColumnSums().Sum();
  194. schoolLens.Add(schoolLen);
  195. }
  196. return Ok(new { state = 200, schoolLens });
  197. }
  198. else
  199. {
  200. List<List<double>> begin = new();
  201. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<LessonCount>(queryText: "select value(c) from c where c.pk='LessonCount'", requestOptions: new QueryRequestOptions() { }))
  202. {
  203. begin.Add(item.beginCount);
  204. }
  205. var count = DenseMatrix.OfColumns(begin).ColumnSums().Sum();
  206. return Ok(new { state = 200, count });
  207. }
  208. }
  209. /// <summary>
  210. /// 顾问关联的学校统计本学期的课例
  211. /// </summary>
  212. /// <param name="jsonElement"></param>
  213. /// <returns></returns>
  214. [HttpPost("get-termcount")]
  215. public async Task<IActionResult> GetTermCount(JsonElement jsonElement)
  216. {
  217. if (jsonElement.TryGetProperty("tmdId", out JsonElement tmdId)) BadRequest();
  218. jsonElement.TryGetProperty("site", out JsonElement site);
  219. var cosmosClient = _azureCosmos.GetCosmosClient();
  220. if ($"{site}".Equals(BIConst.Global))
  221. cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  222. List<SchoolLen> schoolLens = new();
  223. List<string> schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
  224. foreach (var scid in schoolIds)
  225. {
  226. School school = new();
  227. var response = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(scid, new PartitionKey("Base"));
  228. if (response.Status == 200)
  229. {
  230. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  231. school = json.ToObject<School>();
  232. }
  233. SchoolLen schoolLen = new() { id = scid, name = !string.IsNullOrEmpty(school.name) ? school.name : scid };
  234. DateTimeOffset dateTime = DateTimeOffset.UtcNow;
  235. int year = (dateTime.Month <= 8 && dateTime.Month >= 3) ? dateTime.Year : dateTime.Year - 1;
  236. long stime = DateTimeOffset.Parse($"{year}-9-1").ToUnixTimeMilliseconds();
  237. //long etime = DateTimeOffset.Parse($"{year}-2-{((year % 4 == 0 && year % 100 != 0 || year % 400 == 0) ? 29 : 28)}").ToUnixTimeMilliseconds();
  238. double totals = 0;
  239. var syear = DateTimeOffset.FromUnixTimeMilliseconds(stime).Year;
  240. var tyear = DateTimeOffset.UtcNow.Year;
  241. var tday = DateTimeOffset.UtcNow.DayOfYear;
  242. //今年多少天
  243. int tdays = (tyear % 4 == 0 && tyear % 100 != 0 || tyear % 400 == 0) ? 366 : 365;
  244. //去年多少天
  245. int pydays = (syear % 4 == 0 && syear % 100 != 0 || syear % 400 == 0) ? 366 : 365;
  246. List<LessonCount> scount = new();
  247. List<LessonCount> tcount = new();
  248. DenseMatrix dense = null;
  249. var queryClass = $"select value(c) from c ";
  250. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<LessonCount>(queryText: queryClass, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"LessonCount-{scid}-{syear}") }))
  251. {
  252. scount.Add(item);
  253. }
  254. if (tyear > syear)
  255. {
  256. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<LessonCount>(queryText: queryClass, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"LessonCount-{scid}-{tyear}") }))
  257. {
  258. tcount.Add(item);
  259. }
  260. if (tcount.Count > 0)
  261. {
  262. List<List<double>> be = new();
  263. foreach (var item in tcount)
  264. {
  265. be.Add(item.beginCount);
  266. }
  267. dense = DenseMatrix.OfColumns(be);
  268. }
  269. }
  270. if (scount.Count > 0)
  271. {
  272. List<List<double>> begin = new();
  273. foreach (LessonCount lesson in scount)
  274. {
  275. begin.Add(lesson.beginCount);
  276. }
  277. var matrix = DenseMatrix.OfColumns(begin);
  278. //求本学期
  279. var sdays = DateTimeOffset.FromUnixTimeMilliseconds(stime).DayOfYear;
  280. if (tday - sdays < 0)
  281. {
  282. //var tmatrix = DenseMatrix.OfColumns(scount.beginCount);
  283. //跨年后开始到本学期结束
  284. double endMonth = 0;
  285. if (null != dense)
  286. {
  287. endMonth = dense.SubMatrix(0, tday, 0, dense.ColumnCount).ColumnSums().Sum();
  288. }
  289. var startMonth = matrix.SubMatrix(sdays - 1, pydays - sdays, 0, matrix.ColumnCount).ColumnSums().Sum();
  290. totals = (endMonth + startMonth);
  291. }
  292. else
  293. {
  294. var allMonth = matrix.SubMatrix(sdays - 1, tday - sdays + 1, 0, matrix.ColumnCount).ColumnSums().Sum();
  295. totals = allMonth;
  296. }
  297. }
  298. schoolLen.totals = (long)totals;
  299. schoolLens.Add(schoolLen);
  300. }
  301. return Ok(new { state = 200, schoolLens });
  302. }
  303. /// <summary>
  304. /// 统计区级课例
  305. /// </summary>
  306. /// <param name="jsonElement"></param>
  307. /// <returns></returns>
  308. [ProducesDefaultResponseType]
  309. [HttpPost("get-areacount")]
  310. public async Task<IActionResult> GetAreaCount(JsonElement jsonElement)
  311. {
  312. if(!jsonElement.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
  313. jsonElement.TryGetProperty("site", out JsonElement site);
  314. List<string> schools = new();
  315. var cosmosClient = _azureCosmos.GetCosmosClient();
  316. if ($"{site}".Equals(BIConst.Global))
  317. cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  318. StringBuilder scSqlTxt = new("select c.id from c");
  319. if (!string.IsNullOrEmpty($"{areaId}"))
  320. {
  321. scSqlTxt.Append($" where c.areaId='{areaId}'");
  322. }
  323. schools = await CommonFind.FindSchoolIds(cosmosClient, scSqlTxt.ToString(), "Base");
  324. //所有的课程记录
  325. List<LessonRecord> records = new();
  326. List<string> tecIds = new();
  327. foreach (var school in schools)
  328. {
  329. string sqlTxt = $"select value(c) from c where c.code='LessonRecord-{school}'";
  330. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<LessonRecord>(queryText: sqlTxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"LessonRecord-{school}") }))
  331. {
  332. records.Add(item);
  333. }
  334. }
  335. tecIds = await CommonFind.FindRolesId(cosmosClient, schools);
  336. foreach (var tecId in tecIds)
  337. {
  338. string sqlTxt = $"select value(c) from c where c.id='{tecId}'";
  339. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<LessonRecord>(queryText: sqlTxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"LessonRecord") }))
  340. {
  341. records.Add(item);
  342. }
  343. }
  344. int dayCount = 0;
  345. var (dayStart, dayEnd) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow);
  346. records.ForEach(x => { if (x.startTime >= dayStart && x.startTime <= dayEnd) dayCount += 1; });
  347. int weekCount = 0;
  348. var (weekStart, weekEnd) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow, "week");
  349. records.ForEach(x => { if (x.startTime >= weekStart && x.startTime <= weekEnd) weekCount += 1; });
  350. int monthCount = 0;
  351. var (monthStart, monthEnd) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow, "month");
  352. records.ForEach(x => { if (x.startTime >= monthStart && x.startTime <= monthEnd) monthCount += 1; });
  353. int termCount = 0;
  354. var (termStart, termEnd) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow, "term");
  355. records.ForEach(x => { if (x.startTime >= termStart && x.startTime <= termEnd) termCount += 1; });
  356. double teachCount = records.Where(r => r.tmdid != null).Where((x, i) => records.FindIndex(z => z.tmdid == x.tmdid) == i).ToList().Count;
  357. return Ok(new { state = 200, lessonCount = records.Count, teachCount, dayCount, weekCount, monthCount, termCount });
  358. }
  359. /// <summary>
  360. /// 统计区级一年每周的课例数据趋势
  361. /// </summary>
  362. /// <param name="jsonElement"></param>
  363. /// <returns></returns>
  364. [ProducesDefaultResponseType]
  365. [HttpPost("get-weekcount")]
  366. public async Task<IActionResult> GetWeekCount(JsonElement jsonElement)
  367. {
  368. jsonElement.TryGetProperty("areaId", out JsonElement areaId);
  369. jsonElement.TryGetProperty("site", out JsonElement site);
  370. //Dictionary<int, double> weeks = new();
  371. List<double> weeks = new();
  372. var cosmosClient = _azureCosmos.GetCosmosClient();
  373. if ($"{site}".Equals(BIConst.Global))
  374. cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  375. int year = DateTimeOffset.UtcNow.Year;
  376. int dayOfweek = (int)DateTimeOffset.Parse($"{year}-1-1").DayOfWeek;
  377. int currentTime = DateTimeOffset.UtcNow.DayOfYear / 7 + 1;
  378. int currentTime1 = DateTimeOffset.UtcNow.DayOfYear / 7;
  379. var sqlTxts = "select value(c) from c";
  380. List<LessonCount> scount = new();
  381. List<LessonCount> tcount = new();
  382. StringBuilder sqlTxt = new("select c.id from c");
  383. if (!string.IsNullOrEmpty($"{areaId}"))
  384. {
  385. sqlTxt.Append($" where c.areaId='{areaId}'");
  386. }
  387. List<string> schools = await CommonFind.FindSchoolIds(cosmosClient, sqlTxt.ToString(), "Base");
  388. foreach (var sId in schools)
  389. {
  390. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<LessonCount>(queryText:sqlTxts,requestOptions:new QueryRequestOptions() { PartitionKey =new PartitionKey($"LessonCount-{sId}-{year}")}))
  391. {
  392. scount.Add(item);
  393. }
  394. }
  395. List<string> teacIds = await CommonFind.FindRolesId(cosmosClient, schools);
  396. foreach (var tId in teacIds)
  397. {
  398. var sqlTxtt = $"select value(c) from c where c.id='{tId}'";
  399. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "Teacher").GetItemQueryIterator<LessonCount>(queryText: sqlTxtt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"LessonCount-{year}") }))
  400. {
  401. tcount.Add(item);
  402. }
  403. }
  404. int days = (year % 4 == 0 && year % 100 != 0 || year % 400 == 0) ? days = 366 : days = 365;
  405. List<List<double>> lessons = new();
  406. if (scount.Count > 0)
  407. {
  408. foreach (LessonCount item in scount)
  409. {
  410. lessons.Add(item.beginCount);
  411. }
  412. }
  413. if (tcount.Count > 0)
  414. {
  415. foreach (LessonCount item in tcount)
  416. {
  417. lessons.Add(item.beginCount);
  418. }
  419. }
  420. if (lessons.Count > 0)
  421. {
  422. var bmatrix = DenseMatrix.OfColumns(lessons);
  423. //开学第一周周内开课
  424. if (dayOfweek == 0)
  425. {
  426. dayOfweek = 7;
  427. }
  428. //第一周多少天
  429. var dd = 7 - dayOfweek + 1;
  430. //一年有几周
  431. int sweeks = days / 7;
  432. //查询天数
  433. int dayYear = 0;
  434. if (currentTime > 0)
  435. {
  436. for (int i = 0; i <= currentTime; i++)
  437. {
  438. if (i == 0)
  439. {
  440. var bsum = bmatrix.SubMatrix(dayYear, dd, 0, bmatrix.ColumnCount).ColumnSums().Sum();
  441. dayYear += dd;
  442. //weeks.Add(i, bsum);
  443. weeks.Add(bsum);
  444. }
  445. else
  446. {
  447. var bsum = bmatrix.SubMatrix(dayYear, 7, 0, bmatrix.ColumnCount).ColumnSums().Sum();
  448. dayYear += 7;
  449. //weeks.Add(i, bsum);
  450. weeks.Add(bsum);
  451. }
  452. }
  453. }
  454. //最后一周是否有余
  455. int stary = days - dayYear;
  456. if (stary > 0 && stary < 7)
  457. {
  458. var bsum = bmatrix.SubMatrix(dayYear, stary - 1, 0, bmatrix.ColumnCount).ColumnSums().Sum();
  459. //weeks.Add((sweeks + 1), bsum);
  460. weeks.Add(bsum);
  461. }
  462. }
  463. return Ok(new { state = 200, weeks });
  464. }
  465. /// <summary>
  466. /// 统计所有区级的课例和活动
  467. /// </summary>
  468. /// <returns></returns>
  469. [HttpPost("get-allarea")]
  470. public async Task<IActionResult> GetAllArea(JsonElement jsonElement)
  471. {
  472. jsonElement.TryGetProperty("site", out JsonElement site);
  473. var cosmosClient = _azureCosmos.GetCosmosClient();
  474. if ($"{site}".Equals(BIConst.Global))
  475. cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  476. List<AllAreaInfo> areaInfos = new();
  477. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "Normal").GetItemQueryIterator<AllAreaInfo>(queryText: $"select c.id,c.name,c.standard,c.standardName from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base-Area") }))
  478. {
  479. areaInfos.Add(item);
  480. }
  481. foreach (var area in areaInfos)
  482. {
  483. string comSql = $"select value(c.id) from c where c.areaId='{area.id}'";
  484. List<string> scIds = await CommonFind.GetValueSingle(cosmosClient, "School", comSql, "Base");
  485. int tLessCnt = 0;
  486. int tActCnt = 0;
  487. string Sql = $"select value(c.id) from c where c.areaId='{area.id}'";
  488. if (scIds.Count > 0)
  489. {
  490. comSql = BICommonWay.ManyScSql("c.school", scIds);
  491. string lesSql = $"select value(count(c.id)) from c where c.pk='LessonRecord' and {comSql}";
  492. tLessCnt = await CommonFind.GetSqlValueCount(cosmosClient, new List<string>() { "School", "Teacher" }, lesSql);
  493. comSql = BICommonWay.ManyScSql(" and c.school", scIds);
  494. tActCnt = await ActivityWay.GetCnt(cosmosClient, comSql);
  495. }
  496. area.lessCnt = tLessCnt;
  497. area.actCnt = tActCnt;
  498. area.allCnt = tLessCnt + tActCnt;
  499. }
  500. areaInfos = areaInfos.Where(w => w.allCnt != 0).ToList();
  501. return Ok(new { state = 200 , areaInfos });
  502. }
  503. /// <summary>
  504. /// 依据课例Id获取课例详情 数据管理工具——查询工具
  505. /// </summary>
  506. /// <param name="jsonElement"></param>
  507. /// <returns></returns>
  508. [HttpPost("get-info")]
  509. public async Task<IActionResult> GetInfo(JsonElement jsonElement)
  510. {
  511. if (!jsonElement.TryGetProperty("lessonId", out JsonElement lessonId)) return BadRequest();
  512. jsonElement.TryGetProperty("site", out JsonElement site);
  513. var cosmosClient = _azureCosmos.GetCosmosClient();
  514. if ($"{site}".Equals(BIConst.Global))
  515. cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  516. List<object> lessons = new();
  517. string sqlTxt = $"select * from c where c.id='{lessonId}'";
  518. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: sqlTxt, requestOptions: new QueryRequestOptions() { }))
  519. {
  520. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  521. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  522. {
  523. lessons.Add(obj.ToObject<object>());
  524. }
  525. }
  526. return Ok(new { state = 200, lessons });
  527. }
  528. public record AllAreaInfo
  529. {
  530. public string id { get; set; }
  531. public string name { get; set; }
  532. public string standard { get; set; }
  533. public string standardName { get; set; }
  534. public int lessCnt { get; set; }
  535. public int actCnt { get; set; }
  536. public int allCnt { get; set; }
  537. }
  538. public record SchoolLen
  539. {
  540. public string id { get; set; }
  541. public string name { get; set;}
  542. public long totals { get; set; }
  543. }
  544. }
  545. }