|
@@ -22,6 +22,7 @@ using TEAMModelOS.SDK.DI;
|
|
using TEAMModelOS.SDK.Extension;
|
|
using TEAMModelOS.SDK.Extension;
|
|
using TEAMModelOS.SDK.Models;
|
|
using TEAMModelOS.SDK.Models;
|
|
using TEAMModelOS.SDK.Models.Cosmos.BI;
|
|
using TEAMModelOS.SDK.Models.Cosmos.BI;
|
|
|
|
+using TEAMModelOS.SDK.Models.Cosmos.BI.BISchool;
|
|
using TEAMModelOS.SDK.Models.Service.BI;
|
|
using TEAMModelOS.SDK.Models.Service.BI;
|
|
using TEAMModelOS.SDK.Models.Service.BIStatsWay;
|
|
using TEAMModelOS.SDK.Models.Service.BIStatsWay;
|
|
|
|
|
|
@@ -682,6 +683,64 @@ namespace TEAMModelBI.Controllers.Census
|
|
return Ok(new { state = RespondCode.Ok ,area, statsInfo, scIds });
|
|
return Ok(new { state = RespondCode.Ok ,area, statsInfo, scIds });
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ /// <summary>
|
|
|
|
+ /// 学校信息
|
|
|
|
+ /// </summary>
|
|
|
|
+ /// <param name="jsonElement"></param>
|
|
|
|
+ /// <returns></returns>
|
|
|
|
+ [ProducesDefaultResponseType]
|
|
|
|
+ [HttpPost("get-scinfos")]
|
|
|
|
+ public async Task<IActionResult> GetScInfos(JsonElement jsonElement)
|
|
|
|
+ {
|
|
|
|
+ var cosmosClient = _azureCosmos.GetCosmosClient();
|
|
|
|
+ List<string> scId = await CommonFind.FindScIds(cosmosClient, "select value(c.id) from c ", "Base");
|
|
|
|
+
|
|
|
|
+ foreach (var itemId in scId)
|
|
|
|
+ {
|
|
|
|
+ BIRelation bIRelation = null;
|
|
|
|
+ var resRel = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(itemId, new PartitionKey("BIRel"));
|
|
|
|
+ if (resRel.Status == 200)
|
|
|
|
+ {
|
|
|
|
+ using var fileJson = await JsonDocument.ParseAsync(resRel.ContentStream);
|
|
|
|
+ bIRelation = fileJson.ToObject<BIRelation>();
|
|
|
|
+ }
|
|
|
|
+ else
|
|
|
|
+ {
|
|
|
|
+ ScBaseInfo scBaseInfo = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<ScBaseInfo>(itemId, new PartitionKey("Base"));
|
|
|
|
+ string areaName = null;
|
|
|
|
+ if (!string.IsNullOrEmpty(scBaseInfo.areaId))
|
|
|
|
+ {
|
|
|
|
+ await foreach (var itemName in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<string>(queryText: $"select value(c.name) from c where c.pk='Area' and c.id='{scBaseInfo.areaId}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base-Area") }))
|
|
|
|
+ {
|
|
|
|
+ areaName = itemName;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ bIRelation = new BIRelation()
|
|
|
|
+ {
|
|
|
|
+ name = scBaseInfo.name,
|
|
|
|
+ picture = scBaseInfo.picture,
|
|
|
|
+ size = scBaseInfo.size,
|
|
|
|
+ createDate = scBaseInfo.createTime,
|
|
|
|
+ region = scBaseInfo.region,
|
|
|
|
+ province = scBaseInfo.province,
|
|
|
|
+ city = scBaseInfo.city,
|
|
|
|
+ dist = scBaseInfo.dist,
|
|
|
|
+ address = scBaseInfo.address,
|
|
|
|
+ areaId = scBaseInfo.areaId,
|
|
|
|
+ scale = scBaseInfo.scale,
|
|
|
|
+ areaName = areaName,
|
|
|
|
+ upDate = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
|
|
|
|
+ };
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ return Ok(new { state = 200 });
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
|
|
/// <summary>
|
|
/// <summary>
|
|
/// 依据Id查询School容器 数据管理工具——查询工具
|
|
/// 依据Id查询School容器 数据管理工具——查询工具
|