PaperController.cs 26 KB

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