PaperController.cs 22 KB

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