123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384 |
- using Azure.Cosmos;
- using Microsoft.AspNetCore.Http;
- using Microsoft.AspNetCore.Mvc;
- using System.Collections.Generic;
- using System.Linq;
- using System.Text.Json;
- using System.Threading.Tasks;
- using TEAMModelBI.Tool;
- using TEAMModelBI.Tool.Context;
- using TEAMModelOS.SDK.DI;
- using TEAMModelOS.SDK.Models;
- namespace TEAMModelBI.Controllers.BISchool
- {
- [Route("Lesson")]
- [ApiController]
- public class LessonController : ControllerBase
- {
- private readonly AzureCosmosFactory _azureCosmos;
- private readonly AzureStorageFactory _azureStorage;
- private readonly AzureRedisFactory _azureRedis;
- public LessonController(AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, AzureRedisFactory azureRedis)
- {
- _azureCosmos = azureCosmos;
- _azureStorage = azureStorage;
- _azureRedis = azureRedis;
- }
- /// <summary>
- /// 历史记录读取
- /// </summary>
- /// <param name="jsonElement"></param>
- /// <returns></returns>
- [HttpPost("get-alllesson")]
- public async Task<IActionResult> GetAllLessonRecords(JsonElement jsonElement)
- {
- jsonElement.TryGetProperty("site", out JsonElement site);
- var cosmosClient = _azureCosmos.GetCosmosClient();
- if ($"{site}".Equals(BIConst.GlobalSite))
- cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.GlobalSite);
- List<LessonRecord> scLesson = new();
- List<LessonRecord> tchLesson = new();
- await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS,"School").GetItemQueryIterator<LessonRecord>(queryText: $"select value(c) from c where c.pk='LessonRecord'",requestOptions:new QueryRequestOptions() { }))
- {
- scLesson.Add(item);
- }
- await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<LessonRecord>(queryText: $"select value(c) from c where c.pk='LessonRecord'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("LessonRecord") }))
- {
- tchLesson.Add(item);
- }
- //scLesson.ForEach(item => { TimeHelper.GetDateTime(item.startTime).Hour })
- List<LessCnt> lessCnts = scLesson.Select(item => new LessCnt { hour = TimeHelper.GetDateTime(item.startTime).ToString("yyyyMMddHH"), cat = item.id, upload = item.upload, schoolId = item.school }).ToList();
- List<LessCnt> openCnt = lessCnts.FindAll(s => s.upload == 0).ToList();
- List<LessCnt> lessCnt = lessCnts.FindAll(s => s.upload == 1).ToList();
- var openL = openCnt.GroupBy(g => g.hour).Select(s => new { key = s.Key, cnt = s.Count() }).ToList();
- var lessL = lessCnt.GroupBy(g => g.hour).Select(s => new { key = s.Key, cnt = s.Count() }).ToList();
- //openL.ForEach(f=> { })
- return Ok(new { state = 200, openL, lessL, openCnt, lessCnt, lessCnts });
- }
- public record LessCnt
- {
- public string hour { get; set; }
- public string schoolId { get; set; }
- public string cat { get; set; }
- public int upload { get; set; }
- }
-
- }
- }
|