PaperController.cs 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459
  1. using Azure.Cosmos;
  2. using Microsoft.AspNetCore.Http;
  3. using Microsoft.AspNetCore.Mvc;
  4. using Microsoft.Extensions.Options;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.Text;
  8. using System.Text.Json;
  9. using System.Threading.Tasks;
  10. using TEAMModelBI.Models;
  11. using TEAMModelBI.Tool;
  12. using TEAMModelOS.Models;
  13. using TEAMModelOS.SDK.Context.BI;
  14. using TEAMModelOS.SDK.Context.Constant;
  15. using TEAMModelOS.SDK.DI;
  16. using TEAMModelOS.SDK.DI.AzureCosmos.Inner;
  17. using TEAMModelOS.SDK.Extension;
  18. using TEAMModelOS.SDK.Models;
  19. namespace TEAMModelBI.Controllers.Census
  20. {
  21. /// <summary>
  22. /// 试卷
  23. /// </summary>
  24. [Route("paper")]
  25. [ApiController]
  26. public class PaperController : ControllerBase
  27. {
  28. private readonly AzureCosmosFactory _azureCosmos;
  29. private readonly AzureStorageFactory _azureStorage;
  30. private readonly DingDing _dingDing;
  31. private readonly Option _option;
  32. public PaperController(AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, DingDing dingDing, IOptionsSnapshot<Option> option)
  33. {
  34. _azureCosmos = azureCosmos;
  35. _azureStorage = azureStorage;
  36. _dingDing = dingDing;
  37. _option = option?.Value;
  38. }
  39. /// <summary>
  40. /// 查询学校试卷列表
  41. /// </summary>
  42. /// <param name="jsonElement"></param>
  43. /// <returns></returns>
  44. [ProducesDefaultResponseType]
  45. [HttpPost("get-list")]
  46. public async Task<IActionResult> GetList(JsonElement jsonElement)
  47. {
  48. if (!jsonElement.TryGetProperty("code", out JsonElement code)) return BadRequest();
  49. jsonElement.TryGetProperty("scope", out JsonElement scope);
  50. Dictionary<string, object> dic = new();
  51. if (jsonElement.TryGetProperty("periodId", out JsonElement periodId))
  52. dic.Add("periodId", periodId);
  53. if (jsonElement.TryGetProperty("subjectId", out JsonElement subjectId))
  54. dic.Add("subjectId", subjectId);
  55. if (jsonElement.TryGetProperty("gradeIds", out JsonElement gradeIds))
  56. dic.Add("gradeIds", gradeIds);
  57. if (jsonElement.TryGetProperty("isSort", out JsonElement isSort))
  58. {
  59. if (!string.IsNullOrEmpty($"{isSort}"))
  60. {
  61. if (bool.Parse($"{isSort}") == true)
  62. dic.Add("@DESC", "createTime");
  63. else
  64. dic.Add("@ASC", "createTime");
  65. }
  66. else
  67. dic.Add("@ASC", "createTime");
  68. }
  69. var cosmosClinet = _azureCosmos.GetCosmosClient();
  70. StringBuilder sql = new("select value(c) from c ");
  71. AzureCosmosQuery cosmosDbQuery = SQLHelper.GetSQL(dic, sql);
  72. List<Paper> papers = new();
  73. if (scope.ToString().Equals("school"))
  74. {
  75. await foreach (var item in cosmosClinet.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Paper>(queryDefinition: cosmosDbQuery.CosmosQueryDefinition, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{code}") }))
  76. {
  77. papers.Add(item);
  78. }
  79. }
  80. else if (scope.ToString().Equals("private"))
  81. {
  82. await foreach (var item in cosmosClinet.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Paper>(queryDefinition: cosmosDbQuery.CosmosQueryDefinition, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{code}") }))
  83. {
  84. papers.Add(item);
  85. }
  86. }
  87. else
  88. {
  89. await foreach (var item in cosmosClinet.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Paper>(queryDefinition: cosmosDbQuery.CosmosQueryDefinition, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{code}") }))
  90. {
  91. papers.Add(item);
  92. }
  93. await foreach (var item in cosmosClinet.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Paper>(queryDefinition: cosmosDbQuery.CosmosQueryDefinition, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{code}") }))
  94. {
  95. papers.Add(item);
  96. }
  97. }
  98. return Ok(new { state = RespondCode.Ok,cnt = papers.Count, papers });
  99. }
  100. /// <summary>
  101. /// 复制试卷信息到另外一个学校
  102. /// </summary>
  103. /// <param name="jsonElement"></param>
  104. /// <returns></returns>
  105. [ProducesDefaultResponseType]
  106. [HttpPost("copy-infos")]
  107. public async Task<IActionResult> CopyInfos(JsonElement jsonElement)
  108. {
  109. return Ok(new { state = RespondCode.Ok});
  110. }
  111. /// <summary>
  112. /// 查询试卷的数量统计集合
  113. /// </summary>
  114. /// <param name="jsonElement"></param>
  115. /// <returns></returns>
  116. [ProducesDefaultResponseType]
  117. [HttpPost("get-count")]
  118. public async Task<IActionResult> GetCount(JsonElement jsonElement)
  119. {
  120. jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
  121. if(!jsonElement.TryGetProperty("term", out JsonElement term)) return BadRequest();
  122. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  123. var (start, end) = TimeHelper.GetTermStartOrEnd(DateTime.Now);
  124. var cosmosClient = _azureCosmos.GetCosmosClient();
  125. ////分开部署,就不需要,一站多用时,取消注释
  126. //if ($"{site}".Equals(BIConst.Global))
  127. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  128. object paperCount = new object();
  129. if (!string.IsNullOrEmpty($"{tmdId}"))
  130. {
  131. List<string> schoolIds = new();
  132. schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
  133. List<SchoolPaper> schoolPapers = new();
  134. string time = "";
  135. bool bos = bool.Parse($"{term}");
  136. if (bos == true)
  137. {
  138. time = $" where c.createTime >={start} and c.createTime <={end}";
  139. }
  140. foreach (var schoolId in schoolIds)
  141. {
  142. StringBuilder sqlTxt = new("select value(count(c.id)) from c");
  143. if (bos != true)
  144. sqlTxt.Append($" where c.code='Paper-{schoolId}'");
  145. else
  146. {
  147. sqlTxt.Append(time);
  148. sqlTxt.Append($" and c.code='Paper-{schoolId}'");
  149. };
  150. School school = new();
  151. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("Base"));
  152. if (response.Status == 200)
  153. {
  154. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  155. school = json.ToObject<School>();
  156. }
  157. SchoolPaper schoolPaper = new() { id = schoolId, name = school != null ? school.name : schoolId };
  158. schoolPaper.totals = await CommonFind.GetSqlValueCount(cosmosClient, "School", sqlTxt.ToString());
  159. schoolPapers.Add(schoolPaper);
  160. }
  161. paperCount = schoolPapers;
  162. }
  163. else
  164. {
  165. StringBuilder sqlTxt = new ("select value(count(c.id)) from c where c.pk='Paper'");
  166. if (bool.Parse($"{term}") == true)
  167. {
  168. sqlTxt.Append($" and c.createTime >= {start} and c.createTime <={end}");
  169. }
  170. paperCount = await CommonFind.GetSqlValueCount(cosmosClient, "School", sqlTxt.ToString());
  171. }
  172. return Ok(new { state = 200 , paperCount });
  173. }
  174. /// <summary>
  175. /// 查询所有的试题数量
  176. /// </summary>
  177. /// <returns></returns>
  178. [ProducesDefaultResponseType]
  179. [HttpPost("get-total")]
  180. public async Task<IActionResult> GetTotal(JsonElement jsonElement)
  181. {
  182. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  183. var cosmosClient = _azureCosmos.GetCosmosClient();
  184. ////分开部署,就不需要,一站多用时,取消注释
  185. //if ($"{site}".Equals(BIConst.Global))
  186. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  187. string sqlTxt = $"select value(COUNT(c.id)) from c where c.pk='Paper'";
  188. long totals = await CommonFind.GetSqlValueCount(cosmosClient, "School", sqlTxt.ToString());
  189. return Ok(new { state = 200, totals });
  190. }
  191. /// <summary>
  192. /// 依据醍摩豆账户统计相关联的学校试卷数量
  193. /// </summary>
  194. /// <param name="jsonElement"></param>
  195. /// <returns></returns>
  196. [ProducesDefaultResponseType]
  197. [HttpPost("get-assistschool")]
  198. public async Task<IActionResult> GetAssistSchool(JsonElement jsonElement)
  199. {
  200. if (!jsonElement.TryGetProperty("tmdId", out JsonElement tmdId)) return BadRequest();
  201. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  202. var cosmosClient = _azureCosmos.GetCosmosClient();
  203. ////分开部署,就不需要,一站多用时,取消注释
  204. //if ($"{site}".Equals(BIConst.Global))
  205. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  206. List<string> schoolIds = new();
  207. List<SchoolPaper> schoolPapers = new();
  208. schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
  209. foreach (var schoolId in schoolIds)
  210. {
  211. School school = new();
  212. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("Base"));
  213. if (response.Status == 200)
  214. {
  215. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  216. school = json.ToObject<School>();
  217. }
  218. SchoolPaper schoolPaper = new() { id = schoolId , name = school != null ? school.name : schoolId };
  219. schoolPaper.totals = await CommonFind.GetSqlValueCount(cosmosClient, "School", $"select value(COUNT(c.id)) from c where c.code='Paper-{schoolId}'");
  220. schoolPapers.Add(schoolPaper);
  221. }
  222. return Ok(new { state = 200, schoolPapers });
  223. }
  224. /// <summary>
  225. /// 一年的12个月的
  226. /// </summary>
  227. /// <param name="jsonElement"></param>
  228. /// <returns></returns>
  229. [ProducesDefaultResponseType]
  230. [HttpPost("get-yerar")]
  231. public async Task<IActionResult> GetNewYear(JsonElement jsonElement)
  232. {
  233. jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
  234. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  235. var cosmosClient = _azureCosmos.GetCosmosClient();
  236. ////分开部署,就不需要,一站多用时,取消注释
  237. //if ($"{site}".Equals(BIConst.Global))
  238. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  239. List<MonthStartEnd> endList1 = TimeHelper.GetYearMonthlyStartEnd(DateTimeOffset.UtcNow.Year);
  240. if (string.IsNullOrEmpty($"{tmdId}"))
  241. {
  242. Dictionary<string, long> schoolYears = new Dictionary<string, long>();
  243. foreach (var temp in endList1)
  244. {
  245. string sqlText = $"SELECT value(COUNT(c.id)) FROM c WHERE c.createTime >= {temp.start} and c.createTime <= {temp.end} and c.pk='Paper'";
  246. long total = await CommonFind.GetSqlValueCount(cosmosClient, new List<string>() { "School", "Teacher" }, sqlText);
  247. schoolYears.Add(temp.yearMonth, total);
  248. }
  249. return Ok(new { state = 200, schoolYears });
  250. }
  251. else
  252. {
  253. List<string> schoolIds = new();
  254. schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
  255. List<SchoolYear> schoolYears = new();
  256. foreach (var schoolId in schoolIds)
  257. {
  258. School school = new();
  259. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("Base"));
  260. if (response.Status == 200)
  261. {
  262. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  263. school = json.ToObject<School>();
  264. }
  265. SchoolYear schoolYear = new() { id = schoolId, name = school != null ? school.name : schoolId };
  266. Dictionary<string, long> yearCount = new();
  267. foreach (var temp in endList1)
  268. {
  269. string sqlTxt = $"SELECT value(COUNT(c.id)) FROM c WHERE c.code='Paper-{schoolId}' and c.createTime >= {temp.start} and c.createTime <= {temp.end} and c.pk='Paper'";
  270. long totals = await CommonFind.GetSqlValueCount(cosmosClient, new List<string>() { "School", "Teacher" }, sqlTxt);
  271. yearCount.Add(temp.yearMonth, totals);
  272. }
  273. schoolYear.yearPaper = yearCount;
  274. schoolYears.Add(schoolYear);
  275. }
  276. return Ok(new { state = 200, schoolYears });
  277. }
  278. }
  279. /// <summary>
  280. /// 统计当前学期的数量,传醍摩豆则统计该账户相关的学校试题统计,不传则统计当前学期的试卷
  281. /// </summary>
  282. /// <param name="jsonElement"></param>
  283. /// <returns></returns>
  284. [ProducesDefaultResponseType]
  285. [HttpPost("get-termpaper")]
  286. public async Task<IActionResult> GetTermPaper(JsonElement jsonElement)
  287. {
  288. jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
  289. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  290. var cosmosClient = _azureCosmos.GetCosmosClient();
  291. ////分开部署,就不需要,一站多用时,取消注释
  292. //if ($"{site}".Equals(BIConst.Global))
  293. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  294. var (start, end) = TimeHelper.GetTermStartOrEnd(DateTime.Now);
  295. var totals = new object();
  296. if (!string.IsNullOrEmpty($"{tmdId}"))
  297. {
  298. List<SchoolPaper> schoolPapers = new();
  299. List<string> schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
  300. foreach (var schoolId in schoolIds)
  301. {
  302. School school = new();
  303. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("Base"));
  304. if(response.Status == 200)
  305. {
  306. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  307. school = json.ToObject<School>();
  308. }
  309. SchoolPaper schoolPaper = new() { id = schoolId, name = school != null ? school.name : schoolId };
  310. string sqlTxt = $"select value(count(c.id)) from c where c.createTime >={start} and c.createTime <={end}";
  311. schoolPaper.totals += await CommonFind.GetSqlValueCount(cosmosClient, "School", sqlTxt, $"Paper-{schoolId}");
  312. //await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText:sqlTxt.ToString(),requestOptions:new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{schoolId}")}))
  313. //{
  314. // using var json = await JsonDocument.ParseAsync(item.ContentStream);
  315. // if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt32() > 0)
  316. // {
  317. // foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  318. // {
  319. // schoolPaper.totals += obj.GetProperty("totals").GetInt64();
  320. // }
  321. // }
  322. //}
  323. //schoolPaper.totals = await CommonFind.FindTotals(cosmosClient, sqlTxt, new List<string>() { "School" });
  324. schoolPapers.Add(schoolPaper);
  325. }
  326. totals = schoolPapers;
  327. }
  328. else
  329. {
  330. string sqlTxt = $"SELECT value(count(c.id)) FROM c where c.pk='Paper' and c.createTime >= {start} and c.createTime <= {end}";
  331. totals = await CommonFind.GetSqlValueCount(cosmosClient, new List<string>() { "School" }, sqlTxt);
  332. }
  333. return Ok(new { state = 200, totals });
  334. }
  335. /// <summary>
  336. /// 依据试卷Id查询试卷信息 数据管理工具——查询工具
  337. /// </summary>
  338. /// <param name="jsonElement"></param>
  339. /// <returns></returns>
  340. [ProducesDefaultResponseType]
  341. [HttpPost("get-info")]
  342. public async Task<IActionResult> GetInfo(JsonElement jsonElement)
  343. {
  344. if (!jsonElement.TryGetProperty("paperId", out JsonElement paperId)) return BadRequest();
  345. jsonElement.TryGetProperty("isPersonal", out JsonElement isPersonal);
  346. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  347. var cosmosClient = _azureCosmos.GetCosmosClient();
  348. ////分开部署,就不需要,一站多用时,取消注释
  349. //if ($"{site}".Equals(BIConst.Global))
  350. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  351. List<object> paperInfos = new();
  352. string sqlTxt = $"select * from c where c.id='{paperId}' and c.pk='Paper'";
  353. if (!string.IsNullOrEmpty($"{isPersonal}"))
  354. {
  355. string tableName = "School";
  356. if (bool.Parse($"{isPersonal}") == true)
  357. {
  358. tableName = "Teacher";
  359. }
  360. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", tableName).GetItemQueryStreamIterator(queryText: sqlTxt, requestOptions: new QueryRequestOptions() { }))
  361. {
  362. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  363. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  364. {
  365. paperInfos.Add(obj.ToObject<object>());
  366. }
  367. }
  368. }
  369. else
  370. {
  371. List<string> tableName = new(){ "School", "Teacher" };
  372. foreach (var temp in tableName)
  373. {
  374. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", temp).GetItemQueryStreamIterator(queryText: sqlTxt, requestOptions: new QueryRequestOptions() { }))
  375. {
  376. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  377. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  378. {
  379. paperInfos.Add(obj.ToObject<object>());
  380. }
  381. }
  382. }
  383. }
  384. return Ok(new { state = 200, paperInfos });
  385. }
  386. public record SchoolPaper
  387. {
  388. public string id { get; set; }
  389. public string name { get; set; }
  390. public long totals { get; set; }
  391. }
  392. public record SchoolYear
  393. {
  394. public string id { get; set; }
  395. public string name { get; set; }
  396. public Dictionary<string, long> yearPaper { get; set; }
  397. }
  398. }
  399. }