PaperController.cs 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591
  1. using Azure.Cosmos;
  2. using Azure.Storage.Blobs;
  3. using Azure.Storage.Blobs.Models;
  4. using Azure.Storage.Sas;
  5. using DocumentFormat.OpenXml.Drawing.Diagrams;
  6. using Microsoft.AspNetCore.Http;
  7. using Microsoft.AspNetCore.Mvc;
  8. using Microsoft.Extensions.Options;
  9. using Microsoft.Extensions.Primitives;
  10. using System;
  11. using System.Collections.Generic;
  12. using System.Globalization;
  13. using System.IO;
  14. using System.Linq;
  15. using System.Text;
  16. using System.Text.Json;
  17. using System.Threading.Tasks;
  18. using TEAMModelBI.Models;
  19. using TEAMModelBI.Tool;
  20. using TEAMModelOS.Models;
  21. using TEAMModelOS.SDK.Context.BI;
  22. using TEAMModelOS.SDK.Context.Constant;
  23. using TEAMModelOS.SDK.DI;
  24. using TEAMModelOS.SDK.DI.AzureCosmos.Inner;
  25. using TEAMModelOS.SDK.Extension;
  26. using TEAMModelOS.SDK.Models;
  27. using TEAMModelOS.SDK.Models.Cosmos.BI;
  28. using TEAMModelOS.SDK.Models.Service.BI;
  29. namespace TEAMModelBI.Controllers.Census
  30. {
  31. /// <summary>
  32. /// 试卷
  33. /// </summary>
  34. [Route("paper")]
  35. [ApiController]
  36. public class PaperController : ControllerBase
  37. {
  38. private readonly AzureCosmosFactory _azureCosmos;
  39. private readonly AzureStorageFactory _azureStorage;
  40. private readonly DingDing _dingDing;
  41. private readonly Option _option;
  42. public PaperController(AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, DingDing dingDing, IOptionsSnapshot<Option> option)
  43. {
  44. _azureCosmos = azureCosmos;
  45. _azureStorage = azureStorage;
  46. _dingDing = dingDing;
  47. _option = option?.Value;
  48. }
  49. /// <summary>
  50. /// 查询学校试卷列表
  51. /// </summary>
  52. /// <param name="jsonElement"></param>
  53. /// <returns></returns>
  54. [ProducesDefaultResponseType]
  55. [HttpPost("get-list")]
  56. public async Task<IActionResult> GetList(JsonElement jsonElement)
  57. {
  58. if (!jsonElement.TryGetProperty("code", out JsonElement code)) return BadRequest();
  59. jsonElement.TryGetProperty("scope", out JsonElement _scope);
  60. string scope = "school";
  61. if (string.IsNullOrEmpty($"{_scope}"))
  62. scope = $"{_scope}";
  63. StringBuilder sql = new($"select value(c) from c where c.scope='{scope}'");
  64. if (!jsonElement.TryGetProperty("periodId", out JsonElement periodId)) return BadRequest();
  65. if (!jsonElement.TryGetProperty("subjectId", out JsonElement subjectId)) return BadRequest();
  66. if (!jsonElement.TryGetProperty("gradeIds", out JsonElement gradeIds)) return BadRequest();
  67. if (!jsonElement.TryGetProperty("isSort", out JsonElement isSort)) return BadRequest();
  68. if (!string.IsNullOrEmpty($"{periodId}"))
  69. sql.Append($" and c.periodId ='{periodId}' ");
  70. if (!string.IsNullOrEmpty($"{subjectId}"))
  71. {
  72. List<string> subIds = subjectId.ToObject<List<string>>();
  73. if (subIds.Count > 1)
  74. {
  75. sql.Append($" and c.subjectId in (");
  76. for (int i = 0; i < subIds.Count; i++)
  77. {
  78. if (i == (subIds.Count - 1))
  79. sql.Append($"'{subIds[i]}'");
  80. else
  81. sql.Append($"{subIds[i]},");
  82. }
  83. }
  84. else if(subIds.Count ==1)
  85. {
  86. sql.Append($" and c.subjectId='{subjectId[0]}'");
  87. }
  88. }
  89. if (!string.IsNullOrEmpty($"{gradeIds}"))
  90. sql.Append($" and ARRAY_CONTAINS(c.gradeIds,'{gradeIds}')");
  91. if (bool.Parse($"{isSort}") == true)
  92. sql.Append(" Order By c.createTime DESC");
  93. else
  94. sql.Append(" Order By c.createTime ASC");
  95. var cosmosClinet = _azureCosmos.GetCosmosClient();
  96. List<Paper> papers = new();
  97. if (scope.ToString().Equals("school"))
  98. {
  99. await foreach (var item in cosmosClinet.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Paper>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{code}") }))
  100. {
  101. papers.Add(item);
  102. }
  103. }
  104. return Ok(new { state = RespondCode.Ok,cnt = papers.Count, papers });
  105. }
  106. /// <summary>
  107. /// 复制试卷信息到另外一个学校
  108. /// </summary>
  109. /// <param name="jsonElement"></param>
  110. /// <returns></returns>
  111. [ProducesDefaultResponseType]
  112. [HttpPost("copy-infos")]
  113. public async Task<IActionResult> CopyInfos(JsonElement jsonElement)
  114. {
  115. try
  116. {
  117. if (!jsonElement.TryGetProperty("papers", out JsonElement jsPapers)) return BadRequest();
  118. if (!jsonElement.TryGetProperty("newSc", out JsonElement _newSchool)) return BadRequest();
  119. List<CopyPaper> papers = jsPapers.ToObject<List<CopyPaper>>();
  120. List<newSchool> newSchools = _newSchool.ToObject<List<newSchool>>();
  121. List<Task<CopyFromUriOperation>> filelist = new(); //可复制256M以上文件
  122. List<dynamic> existScPaper = new();
  123. var cosmosClinet = _azureCosmos.GetCosmosClient();
  124. foreach (var itemSc in newSchools)
  125. {
  126. List<string> existPaper = new();
  127. foreach (var cItem in papers)
  128. {
  129. Paper paper = await cosmosClinet.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<Paper>(cItem.oldId, new PartitionKey($"Paper-{cItem.oldSc}"));
  130. paper.periodId = itemSc.newPrdId;
  131. paper.subjectId = itemSc.newSubId;
  132. paper.subjectName = itemSc.newSubName;
  133. paper.gradeIds = itemSc.newGrId;
  134. paper.code = $"Paper-{itemSc.newSc}";
  135. var resState = await cosmosClinet.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(paper.id, new PartitionKey(paper.code));
  136. if (resState.Status == 200)
  137. paper.id = Guid.NewGuid().ToString();
  138. await foreach (var item in cosmosClinet.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<string>(queryText: $"select value(c.name) from c where c.name='{paper.name}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{itemSc.newSc}") }))
  139. {
  140. existPaper.Add(item);
  141. }
  142. if (existPaper.Count == 0)
  143. {
  144. paper = await cosmosClinet.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<Paper>(paper, new PartitionKey(paper.code));
  145. var oldBobCilent = _azureStorage.GetBlobContainerClient(containerName: $"{cItem.oldSc}");
  146. var newBobCilent = _azureStorage.GetBlobContainerClient(containerName: $"{itemSc.newSc}");
  147. string blobUrl = "";
  148. if (paper.blob.IndexOf('/') == 0)
  149. blobUrl = $"{paper.blob}".Substring(1, paper.blob.Length - 1);
  150. else
  151. blobUrl = $"{paper.blob}";
  152. await foreach (BlobItem blobItem in oldBobCilent.GetBlobsAsync(BlobTraits.None, BlobStates.None, blobUrl))
  153. {
  154. var urlSas = _azureStorage.GetBlobSAS($"{cItem.oldSc}", blobItem.Name, BlobSasPermissions.Read | BlobSasPermissions.List); //获取容器sas和有效期
  155. filelist.Add(newBobCilent.GetBlobClient(blobItem.Name).StartCopyFromUriAsync(new Uri(urlSas)));
  156. ////序列化数据修改数据
  157. //if (blobItem.Name.EndsWith(".json"))
  158. //{
  159. // BlobClient tempClient = oldBobCilent.GetBlobClient(blobItem.Name);
  160. // using (var meomoryStream = new MemoryStream())
  161. // {
  162. // StringBuilder itemStr = new();
  163. // BlobClient tempBlobClient = oldBobCilent.GetBlobClient(blobItem.Name);
  164. // BlobDownloadInfo download = tempBlobClient.Download();
  165. // var content = download.Content;
  166. // string text;
  167. // using (var streamReader = new StreamReader(content))
  168. // {
  169. // while ((text = streamReader.ReadLine()) != null)
  170. // {
  171. // if (streamReader.EndOfStream)
  172. // itemStr.Append($"{text.ToString()}");
  173. // else
  174. // itemStr.Append($"{text.ToString()},");
  175. // }
  176. // streamReader.Close();
  177. // }
  178. // string input = itemStr.ToString();
  179. // BlobItemInfo blobbItemInfo = input.ToObject<BlobItemInfo>();
  180. // //var response = oldBobCilent.GetBlobClient($"{blobItem.Name}").DownloadTo(meomoryStream);
  181. // //BlobItemInfo blobbItemInfo = Encoding.UTF8.GetString(meomoryStream.ToArray()).ToString().ToObject<BlobItemInfo>();
  182. // blobbItemInfo.exercise.periodId = cItem.newPrdId;
  183. // blobbItemInfo.exercise.gradeIds = cItem.newGrId;
  184. // blobbItemInfo.exercise.subjectId = cItem.newSubId;
  185. // var urlSas = _azureStorage.GetBlobSAS($"{cItem.newSc}", blobItem.Name, BlobSasPermissions.Read | BlobSasPermissions.List); //获取容器sas和有效期
  186. // var ster = newBobCilent.UploadFileByContainer(blobbItemInfo.ToJsonString(), blobItem.Name, blobbItemInfo.id);
  187. // }
  188. //}
  189. }
  190. }
  191. }
  192. if (existPaper.Count > 0)
  193. existScPaper.Add(new { schoolId = itemSc.newSc, papers = existPaper });
  194. }
  195. if (filelist.Count <= 256)
  196. await Task.WhenAll(filelist);
  197. else
  198. {
  199. int pages = (filelist.Count + 255) / 256;
  200. for (int i = 0; i < pages; i++)
  201. {
  202. List<Task<CopyFromUriOperation>> rspBlobCopyInfos = filelist.Skip((i) * 256).Take(256).ToList(); //可复制256M以上文件
  203. //List<Task<Response<BlobCopyInfo>>> rspBlobCopyInfos = filelist.Skip((i) * 256).Take(256).ToList(); //复制256M以下文件
  204. await Task.WhenAll(rspBlobCopyInfos);
  205. }
  206. }
  207. return Ok(new { state = RespondCode.Ok , existScPaper });
  208. }
  209. catch (Exception ex)
  210. {
  211. //await _dingDing.SendBotMsg($"BI,{_option.Location} /paper/copy-infos \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  212. return BadRequest();
  213. }
  214. }
  215. /// <summary>
  216. /// 查询试卷的数量统计集合
  217. /// </summary>
  218. /// <param name="jsonElement"></param>
  219. /// <returns></returns>
  220. [ProducesDefaultResponseType]
  221. [HttpPost("get-count")]
  222. public async Task<IActionResult> GetCount(JsonElement jsonElement)
  223. {
  224. jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
  225. if(!jsonElement.TryGetProperty("term", out JsonElement term)) return BadRequest();
  226. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  227. var (start, end) = TimeHelper.GetTermStartOrEnd(DateTime.Now);
  228. var cosmosClient = _azureCosmos.GetCosmosClient();
  229. ////分开部署,就不需要,一站多用时,取消注释
  230. //if ($"{site}".Equals(BIConst.Global))
  231. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  232. object paperCount = new object();
  233. if (!string.IsNullOrEmpty($"{tmdId}"))
  234. {
  235. List<string> schoolIds = new();
  236. schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
  237. List<SchoolPaper> schoolPapers = new();
  238. string time = "";
  239. bool bos = bool.Parse($"{term}");
  240. if (bos == true)
  241. {
  242. time = $" where c.createTime >={start} and c.createTime <={end}";
  243. }
  244. foreach (var schoolId in schoolIds)
  245. {
  246. StringBuilder sqlTxt = new("select value(count(c.id)) from c");
  247. if (bos != true)
  248. sqlTxt.Append($" where c.code='Paper-{schoolId}'");
  249. else
  250. {
  251. sqlTxt.Append(time);
  252. sqlTxt.Append($" and c.code='Paper-{schoolId}'");
  253. };
  254. School school = new();
  255. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("Base"));
  256. if (response.Status == 200)
  257. {
  258. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  259. school = json.ToObject<School>();
  260. }
  261. SchoolPaper schoolPaper = new() { id = schoolId, name = school != null ? school.name : schoolId };
  262. schoolPaper.totals = await CommonFind.GetSqlValueCount(cosmosClient, "School", sqlTxt.ToString());
  263. schoolPapers.Add(schoolPaper);
  264. }
  265. paperCount = schoolPapers;
  266. }
  267. else
  268. {
  269. StringBuilder sqlTxt = new ("select value(count(c.id)) from c where c.pk='Paper'");
  270. if (bool.Parse($"{term}") == true)
  271. {
  272. sqlTxt.Append($" and c.createTime >= {start} and c.createTime <={end}");
  273. }
  274. paperCount = await CommonFind.GetSqlValueCount(cosmosClient, "School", sqlTxt.ToString());
  275. }
  276. return Ok(new { state = 200 , paperCount });
  277. }
  278. /// <summary>
  279. /// 查询所有的试题数量
  280. /// </summary>
  281. /// <returns></returns>
  282. [ProducesDefaultResponseType]
  283. [HttpPost("get-total")]
  284. public async Task<IActionResult> GetTotal(JsonElement jsonElement)
  285. {
  286. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  287. var cosmosClient = _azureCosmos.GetCosmosClient();
  288. ////分开部署,就不需要,一站多用时,取消注释
  289. //if ($"{site}".Equals(BIConst.Global))
  290. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  291. string sqlTxt = $"select value(COUNT(c.id)) from c where c.pk='Paper'";
  292. long totals = await CommonFind.GetSqlValueCount(cosmosClient, "School", sqlTxt.ToString());
  293. return Ok(new { state = 200, totals });
  294. }
  295. /// <summary>
  296. /// 依据醍摩豆账户统计相关联的学校试卷数量
  297. /// </summary>
  298. /// <param name="jsonElement"></param>
  299. /// <returns></returns>
  300. [ProducesDefaultResponseType]
  301. [HttpPost("get-assistschool")]
  302. public async Task<IActionResult> GetAssistSchool(JsonElement jsonElement)
  303. {
  304. if (!jsonElement.TryGetProperty("tmdId", out JsonElement tmdId)) return BadRequest();
  305. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  306. var cosmosClient = _azureCosmos.GetCosmosClient();
  307. ////分开部署,就不需要,一站多用时,取消注释
  308. //if ($"{site}".Equals(BIConst.Global))
  309. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  310. List<string> schoolIds = new();
  311. List<SchoolPaper> schoolPapers = new();
  312. schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
  313. foreach (var schoolId in schoolIds)
  314. {
  315. School school = new();
  316. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("Base"));
  317. if (response.Status == 200)
  318. {
  319. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  320. school = json.ToObject<School>();
  321. }
  322. SchoolPaper schoolPaper = new() { id = schoolId , name = school != null ? school.name : schoolId };
  323. schoolPaper.totals = await CommonFind.GetSqlValueCount(cosmosClient, "School", $"select value(COUNT(c.id)) from c where c.code='Paper-{schoolId}'");
  324. schoolPapers.Add(schoolPaper);
  325. }
  326. return Ok(new { state = 200, schoolPapers });
  327. }
  328. /// <summary>
  329. /// 一年的12个月的
  330. /// </summary>
  331. /// <param name="jsonElement"></param>
  332. /// <returns></returns>
  333. [ProducesDefaultResponseType]
  334. [HttpPost("get-yerar")]
  335. public async Task<IActionResult> GetNewYear(JsonElement jsonElement)
  336. {
  337. jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
  338. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  339. var cosmosClient = _azureCosmos.GetCosmosClient();
  340. ////分开部署,就不需要,一站多用时,取消注释
  341. //if ($"{site}".Equals(BIConst.Global))
  342. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  343. List<StartEndTime> endList1 = TimeHelper.GetYearMonthlyStartEnd(DateTimeOffset.UtcNow.Year);
  344. if (string.IsNullOrEmpty($"{tmdId}"))
  345. {
  346. Dictionary<string, long> schoolYears = new Dictionary<string, long>();
  347. foreach (var temp in endList1)
  348. {
  349. string sqlText = $"SELECT value(COUNT(c.id)) FROM c WHERE c.createTime >= {temp.start} and c.createTime <= {temp.end} and c.pk='Paper'";
  350. long total = await CommonFind.GetSqlValueCount(cosmosClient, new List<string>() { "School", "Teacher" }, sqlText);
  351. schoolYears.Add(temp.date, total);
  352. }
  353. return Ok(new { state = 200, schoolYears });
  354. }
  355. else
  356. {
  357. List<string> schoolIds = new();
  358. schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
  359. List<SchoolYear> schoolYears = new();
  360. foreach (var schoolId in schoolIds)
  361. {
  362. School school = new();
  363. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("Base"));
  364. if (response.Status == 200)
  365. {
  366. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  367. school = json.ToObject<School>();
  368. }
  369. SchoolYear schoolYear = new() { id = schoolId, name = school != null ? school.name : schoolId };
  370. Dictionary<string, long> yearCount = new();
  371. foreach (var temp in endList1)
  372. {
  373. 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'";
  374. long totals = await CommonFind.GetSqlValueCount(cosmosClient, new List<string>() { "School", "Teacher" }, sqlTxt);
  375. yearCount.Add(temp.date, totals);
  376. }
  377. schoolYear.yearPaper = yearCount;
  378. schoolYears.Add(schoolYear);
  379. }
  380. return Ok(new { state = 200, schoolYears });
  381. }
  382. }
  383. /// <summary>
  384. /// 统计当前学期的数量,传醍摩豆则统计该账户相关的学校试题统计,不传则统计当前学期的试卷
  385. /// </summary>
  386. /// <param name="jsonElement"></param>
  387. /// <returns></returns>
  388. [ProducesDefaultResponseType]
  389. [HttpPost("get-termpaper")]
  390. public async Task<IActionResult> GetTermPaper(JsonElement jsonElement)
  391. {
  392. jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
  393. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  394. var cosmosClient = _azureCosmos.GetCosmosClient();
  395. ////分开部署,就不需要,一站多用时,取消注释
  396. //if ($"{site}".Equals(BIConst.Global))
  397. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  398. var (start, end) = TimeHelper.GetTermStartOrEnd(DateTime.Now);
  399. var totals = new object();
  400. if (!string.IsNullOrEmpty($"{tmdId}"))
  401. {
  402. List<SchoolPaper> schoolPapers = new();
  403. List<string> schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
  404. foreach (var schoolId in schoolIds)
  405. {
  406. School school = new();
  407. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("Base"));
  408. if(response.Status == 200)
  409. {
  410. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  411. school = json.ToObject<School>();
  412. }
  413. SchoolPaper schoolPaper = new() { id = schoolId, name = school != null ? school.name : schoolId };
  414. string sqlTxt = $"select value(count(c.id)) from c where c.createTime >={start} and c.createTime <={end}";
  415. schoolPaper.totals += await CommonFind.GetSqlValueCount(cosmosClient, "School", sqlTxt, $"Paper-{schoolId}");
  416. //await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText:sqlTxt.ToString(),requestOptions:new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{schoolId}")}))
  417. //{
  418. // using var json = await JsonDocument.ParseAsync(item.ContentStream);
  419. // if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt32() > 0)
  420. // {
  421. // foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  422. // {
  423. // schoolPaper.totals += obj.GetProperty("totals").GetInt64();
  424. // }
  425. // }
  426. //}
  427. //schoolPaper.totals = await CommonFind.FindTotals(cosmosClient, sqlTxt, new List<string>() { "School" });
  428. schoolPapers.Add(schoolPaper);
  429. }
  430. totals = schoolPapers;
  431. }
  432. else
  433. {
  434. string sqlTxt = $"SELECT value(count(c.id)) FROM c where c.pk='Paper' and c.createTime >= {start} and c.createTime <= {end}";
  435. totals = await CommonFind.GetSqlValueCount(cosmosClient, new List<string>() { "School" }, sqlTxt);
  436. }
  437. return Ok(new { state = 200, totals });
  438. }
  439. /// <summary>
  440. /// 依据试卷Id查询试卷信息 数据管理工具——查询工具
  441. /// </summary>
  442. /// <param name="jsonElement"></param>
  443. /// <returns></returns>
  444. [ProducesDefaultResponseType]
  445. [HttpPost("get-info")]
  446. public async Task<IActionResult> GetInfo(JsonElement jsonElement)
  447. {
  448. if (!jsonElement.TryGetProperty("paperId", out JsonElement paperId)) return BadRequest();
  449. jsonElement.TryGetProperty("isPersonal", out JsonElement isPersonal);
  450. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  451. var cosmosClient = _azureCosmos.GetCosmosClient();
  452. ////分开部署,就不需要,一站多用时,取消注释
  453. //if ($"{site}".Equals(BIConst.Global))
  454. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  455. List<object> paperInfos = new();
  456. string sqlTxt = $"select * from c where c.id='{paperId}' and c.pk='Paper'";
  457. if (!string.IsNullOrEmpty($"{isPersonal}"))
  458. {
  459. string tableName = "School";
  460. if (bool.Parse($"{isPersonal}") == true)
  461. {
  462. tableName = "Teacher";
  463. }
  464. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", tableName).GetItemQueryStreamIterator(queryText: sqlTxt, requestOptions: new QueryRequestOptions() { }))
  465. {
  466. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  467. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  468. {
  469. paperInfos.Add(obj.ToObject<object>());
  470. }
  471. }
  472. }
  473. else
  474. {
  475. List<string> tableName = new(){ "School", "Teacher" };
  476. foreach (var temp in tableName)
  477. {
  478. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", temp).GetItemQueryStreamIterator(queryText: sqlTxt, requestOptions: new QueryRequestOptions() { }))
  479. {
  480. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  481. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  482. {
  483. paperInfos.Add(obj.ToObject<object>());
  484. }
  485. }
  486. }
  487. }
  488. return Ok(new { state = 200, paperInfos });
  489. }
  490. public record SchoolPaper
  491. {
  492. public string id { get; set; }
  493. public string name { get; set; }
  494. public long totals { get; set; }
  495. }
  496. public record SchoolYear
  497. {
  498. public string id { get; set; }
  499. public string name { get; set; }
  500. public Dictionary<string, long> yearPaper { get; set; }
  501. }
  502. public record CopyPaper
  503. {
  504. public string oldId { get; set; }
  505. public string oldSc { get; set; }
  506. }
  507. public record newSchool
  508. {
  509. public string newSc { get; set; }
  510. public string newPrdId { get; set; }
  511. public string newSubId { get; set; }
  512. public string newSubName { get; set; }
  513. public List<string> newGrId { get; set; }
  514. }
  515. }
  516. }