123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290 |
- using Azure.Cosmos;
- using Microsoft.AspNetCore.Http;
- using Microsoft.AspNetCore.Mvc;
- using Microsoft.Extensions.Options;
- using System;
- using System.Collections.Generic;
- using System.Text;
- using System.Text.Json;
- using System.Threading.Tasks;
- using TEAMModelBI.Models;
- using TEAMModelBI.Tool;
- using TEAMModelOS.Models;
- using TEAMModelOS.SDK.DI;
- using TEAMModelOS.SDK.Extension;
- using TEAMModelOS.SDK.Models;
- namespace TEAMModelBI.Controllers.BISchool
- {
- /// <summary>
- /// 试卷
- /// </summary>
- [Route("paper")]
- [ApiController]
- public class PaperController : ControllerBase
- {
- private readonly AzureCosmosFactory _azureCosmos;
- private readonly AzureStorageFactory _azureStorage;
- private readonly DingDing _dingDing;
- private readonly Option _option;
- public PaperController(AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, DingDing dingDing, IOptionsSnapshot<Option> option)
- {
- _azureCosmos = azureCosmos;
- _azureStorage = azureStorage;
- _dingDing = dingDing;
- _option = option?.Value;
- }
- /// <summary>
- /// 查询试卷的数量统计集合
- /// </summary>
- /// <param name="jsonElement"></param>
- /// <returns></returns>
- [HttpPost("get-count")]
- public async Task<IActionResult> GetCount(JsonElement jsonElement)
- {
- jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
- if(!jsonElement.TryGetProperty("term", out JsonElement term)) return BadRequest();
- var (start, end) = DateTimeHeloer.GetTermStartOrEnd(DateTime.Now);
- var cosmosClient = _azureCosmos.GetCosmosClient();
- object paperCount = new object();
- StringBuilder sqlTxt = new StringBuilder("select count(c.id) AS totals from c");
- if (!string.IsNullOrEmpty($"{tmdId}"))
- {
- List<string> schoolIds = new List<string>();
- schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
- List<SchoolPaper> schoolPapers = new List<SchoolPaper>();
- if (bool.Parse($"{term}") == true)
- {
- sqlTxt.Append($" where c.createTime >={start} and c.createTime <={end}");
- }
- foreach (var schoolId in schoolIds)
- {
- School school = new();
- var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("Base"));
- if (response.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(response.ContentStream);
- school = json.ToObject<School>();
- }
- SchoolPaper schoolPaper = new SchoolPaper() { id = schoolId, name = school != null ? school.name : schoolId };
- schoolPaper.totals = await CommonFind.FindTotals(cosmosClient, sqlTxt.ToString(), new List<string>() { "School" });
- schoolPapers.Add(schoolPaper);
- }
- paperCount = schoolPapers;
- }
- else
- {
- sqlTxt.Append(" where c.pk='Paper' ");
- if (bool.Parse($"{term}") == true)
- {
- sqlTxt.Append($" and c.createTime >= {start} and c.createTime <={end}");
- }
- paperCount = await CommonFind.FindTotals(cosmosClient, sqlTxt.ToString(), new List<string>() { "School" });
- }
- return Ok(new { state = 200 , paperCount });
- }
- /// <summary>
- /// 查询所有的试题数量
- /// </summary>
- /// <returns></returns>
- [HttpPost("get-total")]
- public async Task<IActionResult> GetTotal()
- {
- var cosmosClient = _azureCosmos.GetCosmosClient();
- string sqlTxt = $"select COUNT(c.id) AS totals from c where c.pk='Paper'";
- long totals = await CommonFind.FindTotals(cosmosClient, sqlTxt.ToString(), new List<string>() { "School" });
- return Ok(new { state = 200, totals });
- }
- /// <summary>
- /// 依据醍摩豆账户统计相关联的学校试卷数量
- /// </summary>
- /// <param name="jsonElement"></param>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- [HttpPost("get-assistschool")]
- public async Task<IActionResult> GetAssistSchool(JsonElement jsonElement)
- {
- if (!jsonElement.TryGetProperty("tmdId", out JsonElement tmdId)) return BadRequest();
- var cosmosClient = _azureCosmos.GetCosmosClient();
- List<string> schoolIds = new List<string>();
- List<SchoolPaper> schoolPapers = new List<SchoolPaper>();
- schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
- foreach (var schoolId in schoolIds)
- {
- School school = new();
- var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("Base"));
- if (response.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(response.ContentStream);
- school = json.ToObject<School>();
- }
- SchoolPaper schoolPaper = new SchoolPaper() { id = schoolId , name = school != null ? school.name : schoolId };
- schoolPaper.totals = await CommonFind.FindTotals(cosmosClient, "select COUNT(c.id) AS totals from c", new List<string>() { "School" });
- schoolPapers.Add(schoolPaper);
- }
- return Ok(new { state = 200, schoolPapers });
- }
- /// <summary>
- /// 一年的12个月的
- /// </summary>
- /// <param name="jsonElement"></param>
- /// <returns></returns>
- [HttpPost("get-yerar")]
- public async Task<IActionResult> GetNewYear(JsonElement jsonElement)
- {
- jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
- var cosmosClient = _azureCosmos.GetCosmosClient();
- List<MonthStartEnd> endList1 = DateTimeHeloer.GetYearMonthlyStartEnd13(DateTimeOffset.UtcNow.Year);
- if (string.IsNullOrEmpty($"{tmdId}"))
- {
- Dictionary<string, long> schoolYears = new Dictionary<string, long>();
- foreach (var temp in endList1)
- {
- string sqlText = $"SELECT COUNT(c.id) AS totals FROM c WHERE c.createTime >= {temp.start} and c.createTime <= {temp.end} and c.pk='Paper'";
- long total = await CommonFind.FindTotals(cosmosClient, sqlText, new List<string>() { "School", "Teacher" });
- schoolYears.Add(temp.yearMonth, total);
- }
- return Ok(new { state = 200, schoolYears });
- }
- else
- {
- List<string> schoolIds = new List<string>();
- schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
- List<SchoolYear> schoolYears = new List<SchoolYear>();
- foreach (var schoolId in schoolIds)
- {
- School school = new();
- var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("Base"));
- if (response.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(response.ContentStream);
- school = json.ToObject<School>();
- }
- SchoolYear schoolYear = new SchoolYear() { id = schoolId, name = school != null ? school.name : schoolId };
- Dictionary<string, long> yearCount = new Dictionary<string, long>();
- foreach (var temp in endList1)
- {
- string sqlTxt = $"SELECT COUNT(c.id) AS totals FROM c WHERE c.createTime >= {temp.start} and c.createTime <= {temp.end} and c.pk='Paper'";
- long totals = await CommonFind.FindTotals(cosmosClient, sqlTxt, new List<string>() { "School", "Teacher" });
- yearCount.Add(temp.yearMonth, totals);
- }
- schoolYear.yearPaper = yearCount;
- schoolYears.Add(schoolYear);
- }
- return Ok(new { state = 200, schoolYears });
- }
- }
- /// <summary>
- /// 统计当前学期的数量,传醍摩豆则统计该账户相关的学校试题统计,不传则统计当前学期的试卷
- /// </summary>
- /// <param name="jsonElement"></param>
- /// <returns></returns>
- [HttpPost("get-termpaper")]
- public async Task<IActionResult> GetTermPaper(JsonElement jsonElement)
- {
- jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
- var cosmosClient = _azureCosmos.GetCosmosClient();
- var (start, end) = DateTimeHeloer.GetTermStartOrEnd(DateTime.Now);
- var totals = new object();
- if (!string.IsNullOrEmpty($"{tmdId}"))
- {
- List<SchoolPaper> schoolPapers = new List<SchoolPaper>();
- List<string> schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}");
- foreach (var schoolId in schoolIds)
- {
- School school = new();
- var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("Base"));
- if(response.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(response.ContentStream);
- school = json.ToObject<School>();
- }
- SchoolPaper schoolPaper = new SchoolPaper() { id = schoolId, name = school != null ? school.name : schoolId };
- string sqlTxt = $"select count(c.id) AS totals from c where c.createTime >={start} and c.createTime <={end}";
- schoolPaper.totals += await CommonFind.FindTotals(cosmosClient, sqlTxt, "School", $"Paper-{schoolId}");
- //await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText:sqlTxt.ToString(),requestOptions:new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{schoolId}")}))
- //{
- // using var json = await JsonDocument.ParseAsync(item.ContentStream);
- // if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt32() > 0)
- // {
- // foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
- // {
- // schoolPaper.totals += obj.GetProperty("totals").GetInt64();
- // }
- // }
- //}
- //schoolPaper.totals = await CommonFind.FindTotals(cosmosClient, sqlTxt, new List<string>() { "School" });
- schoolPapers.Add(schoolPaper);
- }
- totals = schoolPapers;
- }
- else
- {
- string sqlTxt = $"SELECT COUNT(c.id) AS totals FROM c where c.pk='Paper' and c.createTime >= {start} and c.createTime <= {end}";
- totals = await CommonFind.FindTotals(cosmosClient, sqlTxt, new List<string>() { "School" });
- }
- return Ok(new { state = 200, totals });
- }
- public record SchoolPaper
- {
- public string id { get; set; }
- public string name { get; set; }
- public long totals { get; set; }
- }
- public record SchoolYear
- {
- public string id { get; set; }
- public string name { get; set; }
- public Dictionary<string, long> yearPaper { get; set; }
- }
- }
- }
|