PaperController.cs 8.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190
  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.Json;
  8. using System.Threading.Tasks;
  9. using TEAMModelOS.Models;
  10. using TEAMModelOS.SDK.DI;
  11. using TEAMModelOS.SDK.Models;
  12. namespace TEAMModelBI.Controllers.BISchool
  13. {
  14. /// <summary>
  15. /// 试卷
  16. /// </summary>
  17. [Route("paper")]
  18. [ApiController]
  19. public class PaperController : ControllerBase
  20. {
  21. private readonly AzureCosmosFactory _azureCosmos;
  22. private readonly AzureStorageFactory _azureStorage;
  23. private readonly DingDing _dingDing;
  24. private readonly Option _option;
  25. public PaperController(AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, DingDing dingDing, IOptionsSnapshot<Option> option)
  26. {
  27. _azureCosmos = azureCosmos;
  28. _azureStorage = azureStorage;
  29. _dingDing = dingDing;
  30. _option = option?.Value;
  31. }
  32. /// <summary>
  33. /// 查询试卷的数量统计
  34. /// </summary>
  35. /// <param name="jsonElement"></param>
  36. /// <returns></returns>
  37. [HttpPost("get-count")]
  38. public async Task<IActionResult> GetCount(JsonElement jsonElement)
  39. {
  40. jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
  41. var cosmosClient = _azureCosmos.GetCosmosClient();
  42. object total = new object();
  43. if (!string.IsNullOrEmpty($"{tmdId}"))
  44. {
  45. List<string> schoolIds = new List<string>();
  46. List<SchoolPaper> schoolPapers = new List<SchoolPaper>();
  47. string schoolSql = $"SELECT DISTINCT REPLACE(c.code,'Teacher-','') AS schoolId,c.code,c.roles,c.id,c.name From c where ARRAY_CONTAINS(c.roles,'assist',true) AND c.pk = 'Teacher' AND c.status = 'join' AND c.id='{tmdId}'";
  48. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: schoolSql, requestOptions: new QueryRequestOptions() { }))
  49. {
  50. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  51. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  52. {
  53. schoolIds.Add(obj.GetProperty("schoolId").GetString());
  54. }
  55. }
  56. foreach (var schoolId in schoolIds)
  57. {
  58. SchoolPaper schoolPaper = new SchoolPaper() { id = schoolId };
  59. School school = new();
  60. try
  61. {
  62. school = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemAsync<School>(schoolId, new PartitionKey("Base"));
  63. }
  64. catch
  65. {
  66. }
  67. schoolPaper.name = school != null ? school.name : schoolId;
  68. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator($"select c.id from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{schoolId}") }))
  69. {
  70. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  71. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt64() > 0)
  72. {
  73. schoolPaper.total += count.GetInt64();
  74. }
  75. }
  76. schoolPapers.Add(schoolPaper);
  77. }
  78. total = schoolPapers;
  79. }
  80. else
  81. {
  82. long tempTotal = 0;
  83. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: $"select c.id from c where c.pk='Item'", requestOptions: new QueryRequestOptions() { }))
  84. {
  85. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  86. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt64() > 0)
  87. {
  88. tempTotal += count.GetInt64();
  89. }
  90. }
  91. total = tempTotal;
  92. }
  93. return Ok(new { state = 200 , total });
  94. }
  95. /// <summary>
  96. /// 查询所有的试题数量
  97. /// </summary>
  98. /// <returns></returns>
  99. [HttpPost("get-total")]
  100. public async Task<IActionResult> GetTotal()
  101. {
  102. var cosmosClient = _azureCosmos.GetCosmosClient();
  103. long total = 0;
  104. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: $"select c.id from c where c.pk='Item'", requestOptions: new QueryRequestOptions() { }))
  105. {
  106. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  107. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt64() > 0)
  108. {
  109. total += count.GetInt64();
  110. }
  111. }
  112. return Ok(new { state = 200, total });
  113. }
  114. /// <summary>
  115. /// 依据醍摩豆账户统计相关联的学校试卷数量
  116. /// </summary>
  117. /// <param name="jsonElement"></param>
  118. /// <returns></returns>
  119. [ProducesDefaultResponseType]
  120. [HttpPost("get-assistschool")]
  121. public async Task<IActionResult> GetAssistSchool(JsonElement jsonElement)
  122. {
  123. if (!jsonElement.TryGetProperty("tmdId", out JsonElement tmdId)) return BadRequest();
  124. var cosmosClient = _azureCosmos.GetCosmosClient();
  125. List<string> schoolIds = new List<string>();
  126. List<SchoolPaper> schoolPapers = new List<SchoolPaper>();
  127. string schoolSql = $"SELECT DISTINCT REPLACE(c.code,'Teacher-','') AS schoolId,c.code,c.roles,c.id,c.name From c where ARRAY_CONTAINS(c.roles,'assist',true) AND c.pk = 'Teacher' AND c.status = 'join' AND c.id='{tmdId}'";
  128. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: schoolSql, requestOptions: new QueryRequestOptions() { }))
  129. {
  130. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  131. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  132. {
  133. schoolIds.Add(obj.GetProperty("schoolId").GetString());
  134. }
  135. }
  136. foreach (var schoolId in schoolIds)
  137. {
  138. SchoolPaper schoolPaper = new SchoolPaper() { id = schoolId };
  139. School school = new();
  140. try
  141. {
  142. school = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemAsync<School>(schoolId, new PartitionKey("Base"));
  143. }
  144. catch
  145. {
  146. }
  147. schoolPaper.name = school != null ? school.name : schoolId;
  148. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator($"select c.id from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{schoolId}") }))
  149. {
  150. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  151. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt64() > 0)
  152. {
  153. schoolPaper.total += count.GetInt64();
  154. }
  155. }
  156. schoolPapers.Add(schoolPaper);
  157. }
  158. return Ok(new { state = 200, schoolPapers });
  159. }
  160. public record SchoolPaper
  161. {
  162. public string id { get; set; }
  163. public string name { get; set; }
  164. public long total { get; set; }
  165. }
  166. }
  167. }