BatchSchoolController.cs 118 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037
  1. using Azure.Cosmos;
  2. using HTEXLib.COMM.Helpers;
  3. using Microsoft.AspNetCore.Http;
  4. using Microsoft.AspNetCore.Mvc;
  5. using Microsoft.Extensions.Options;
  6. using System;
  7. using System.Collections.Generic;
  8. using System.Dynamic;
  9. using System.Linq;
  10. using System.Text;
  11. using System.Text.Json;
  12. using System.Threading.Tasks;
  13. using TEAMModelOS.Models;
  14. using TEAMModelOS.SDK.DI;
  15. using TEAMModelOS.SDK.Extension;
  16. using TEAMModelOS.SDK.Models;
  17. using TEAMModelOS.SDK.Models.Cosmos.BI;
  18. using Microsoft.AspNetCore.Hosting; //引用读取文件
  19. using TEAMModelOS.SDK.Models.Service;
  20. using System.IO;
  21. using System.Net.Http;
  22. using Microsoft.Extensions.Configuration;
  23. using System.Net.Http.Json;
  24. using System.Net;
  25. using TEAMModelBI.Filter;
  26. using TEAMModelBI.Tool.Extension;
  27. using TEAMModelBI.Tool;
  28. using TEAMModelBI.Models;
  29. using TEAMModelOS.SDK;
  30. using TEAMModelOS.SDK.Context.BI;
  31. using TEAMModelOS.SDK.Context.Constant;
  32. using Pipelines.Sockets.Unofficial.Arenas;
  33. using Microsoft.Identity.Client;
  34. using TEAMModelOS.SDK.Models.Dtos;
  35. using DocumentFormat.OpenXml.Spreadsheet;
  36. using DocumentFormat.OpenXml.Wordprocessing;
  37. using DocumentFormat.OpenXml.Bibliography;
  38. using HTEXLib;
  39. using TEAMModelOS.SDK.Models.Service.BI;
  40. using TEAMModelOS.SDK.Models.Cosmos.BI.BISchool;
  41. using DocumentFormat.OpenXml.Vml.Office;
  42. namespace TEAMModelBI.Controllers.BISchool
  43. {
  44. [Route("batchschool")]
  45. [ApiController]
  46. public class BatchSchoolController : ControllerBase
  47. {
  48. private readonly AzureCosmosFactory _azureCosmos;
  49. private readonly DingDing _dingDing;
  50. private readonly Option _option;
  51. private readonly AzureStorageFactory _azureStorage;
  52. private readonly IWebHostEnvironment _environment; //读取文件
  53. private readonly IHttpClientFactory _http;
  54. //读取配置信息
  55. private readonly IConfiguration _configuration;
  56. private readonly CoreAPIHttpService _coreAPIHttpService;
  57. private readonly HttpTrigger _httpTrigger;
  58. public BatchSchoolController(AzureCosmosFactory azureCosmos, DingDing dingDing, AzureStorageFactory azureStorage, IOptionsSnapshot<Option> option, IWebHostEnvironment hostingEnvironment, IConfiguration configuration, IHttpClientFactory http, CoreAPIHttpService coreAPIHttpService, HttpTrigger httpTrigger)
  59. {
  60. _azureCosmos = azureCosmos;
  61. _dingDing = dingDing;
  62. _azureStorage = azureStorage;
  63. _option = option?.Value;
  64. _environment = hostingEnvironment;
  65. _configuration = configuration;
  66. _http = http;
  67. _coreAPIHttpService = coreAPIHttpService;
  68. _httpTrigger = httpTrigger;
  69. }
  70. /// <summary>
  71. /// 获取BI权限列表 //已对接
  72. /// </summary>
  73. /// <returns></returns>
  74. [ProducesDefaultResponseType]
  75. [HttpPost("get-teacher-authoritybilist")]
  76. public async Task<IActionResult> GetAuthorityBIList(JsonElement jsonElement)
  77. {
  78. //jsonElement.TryGetProperty("site", out JsonElement site);
  79. Dictionary<string, object> dic = new() { { "PartitionKey", "authority-bi" } };
  80. var table = _azureStorage.GetCloudTableClient().GetTableReference("SchoolSetting");
  81. ////分开部署,就不需要,一站多用时,取消注释
  82. //if ($"{site}".Equals(BIConst.Global))
  83. // table = _azureStorage.GetCloudTableClient(BIConst.Global).GetTableReference("SchoolSetting");
  84. List<Authority> authorityBIList = await table.FindListByDict<Authority>(dic);
  85. return Ok(new { authorityBIList });
  86. }
  87. /// <summary>
  88. /// 生成学校Code信息
  89. /// </summary>
  90. /// <param name="jsonElement"></param>
  91. /// <returns></returns>
  92. [ProducesDefaultResponseType]
  93. [AuthToken(Roles = "admin,rdc")]
  94. [HttpPost("get-schoolcode")]
  95. public async Task<IActionResult> GetSchoolCode(JsonElement jsonElement)
  96. {
  97. if (!jsonElement.TryGetProperty("schools", out JsonElement schools)) return BadRequest();
  98. var cosmosClient = _azureCosmos.GetCosmosClient();
  99. List<CreateSchoolInfo> cSchools = schools.ToObject<List<CreateSchoolInfo>>();
  100. List<CreateSchoolInfo> createScInfo = new(); //生成好的学校Codd信息
  101. foreach (var item in cSchools)
  102. {
  103. CreateSchoolInfo createSchoolInfo = item;
  104. //生成学校ID
  105. bool tempStaus = true;
  106. do
  107. {
  108. createSchoolInfo = await SchoolCode.GenerateSchoolCode(createSchoolInfo, _dingDing, _environment);
  109. var schoolStatu = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{createSchoolInfo.id}", new PartitionKey($"Base"));
  110. if (schoolStatu.Status != 200) tempStaus = false;
  111. else createSchoolInfo.createCount = createSchoolInfo.createCount >= 3 ? createSchoolInfo.createCount = 3 : createSchoolInfo.createCount += 1;
  112. } while (tempStaus);
  113. createScInfo.Add(createSchoolInfo);
  114. }
  115. return Ok(new { state = RespondCode.Ok, createScInfo });
  116. }
  117. /// <summary>
  118. /// 批量创校 //已对接
  119. /// </summary>
  120. /// <param name="school"></param>
  121. /// <returns></returns>
  122. [ProducesDefaultResponseType]
  123. [AuthToken(Roles = "admin,rdc")]
  124. [HttpPost("batch-school")]
  125. public async Task<IActionResult> BatchCreateSchool(FoundSchools foundSchools)
  126. {
  127. try
  128. {
  129. var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);
  130. List<BISchool> schools = new();
  131. List<BISchool> userScs = new();
  132. List<BISchool> cutArea = new();
  133. List<CreateSchoolInfo> scInfos = new();
  134. List<string> upSc = new();
  135. StringBuilder stringBuilder = new($"{_tmdName}【{_tmdId}】使用批量创校功能:");
  136. StringBuilder vsSql = new();
  137. StringBuilder noticeDD = new(); //创校信息通知
  138. var cosmosClient = _azureCosmos.GetCosmosClient();
  139. var tableClient = _azureStorage.GetCloudTableClient();
  140. var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
  141. //if (BIConst.Global.Equals($"{foundSchools.site}"))
  142. //{
  143. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  144. // tableClient = _azureStorage.GetCloudTableClient(BIConst.Global);
  145. // blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.Global);
  146. //}
  147. if (foundSchools.biSchools.Count > 0)
  148. {
  149. #region 新版直接创建
  150. foreach (BISchool bischool in foundSchools.biSchools)
  151. {
  152. Area area = null;
  153. //查询区是否存在
  154. var respAreaId = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemStreamAsync($"{bischool.areaId}", new PartitionKey("Base-Area"));
  155. if (respAreaId.Status == 200)
  156. {
  157. using var areaBase = await JsonDocument.ParseAsync(respAreaId.ContentStream);
  158. area = areaBase.ToObject<Area>();
  159. }
  160. CreateSchoolInfo createSchoolInfo = new CreateSchoolInfo()
  161. {
  162. province = bischool.province,
  163. id = bischool.id,
  164. name = bischool.name,
  165. city = bischool.city,
  166. aname = "",
  167. createCount = 0,
  168. };
  169. //生成学校ID
  170. bool tempStaus = true;
  171. do
  172. {
  173. createSchoolInfo = await SchoolCode.GenerateSchoolCode(createSchoolInfo, _dingDing, _environment);
  174. var schoolStatu = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{createSchoolInfo.id}", new PartitionKey($"Base"));
  175. if (schoolStatu.Status != 200) tempStaus = false;
  176. else createSchoolInfo.createCount = createSchoolInfo.createCount >= 3 ? createSchoolInfo.createCount = 3 : createSchoolInfo.createCount += 1;
  177. } while (tempStaus);
  178. if (createSchoolInfo.id != null)
  179. {
  180. string campusId = Guid.NewGuid().ToString();
  181. School upSchool = new()
  182. {
  183. id = createSchoolInfo.id,
  184. name = bischool.name,
  185. size = bischool.size == 0 ? 100 : bischool.size,
  186. code = "Base",
  187. campuses = new List<Campus> { new Campus { name = bischool.name, id = campusId } },
  188. region = bischool.region,
  189. province = bischool.province,
  190. city = bischool.city,
  191. dist = bischool.dist,
  192. address = bischool.address,
  193. picture = "https://teammodelstorage.blob.core.chinacloudapi.cn/0-public/school/bbf54fb3-3fc8-43ae-a358-107281c174cc.png",
  194. timeZone = new TEAMModelOS.SDK.Models.TimeZone { label = "(UTC+08:00) 北京,重庆,香港特别行政区,乌鲁木齐", value = "+08:00" },
  195. type = string.IsNullOrEmpty(bischool.type.ToString()) ? 1 : bischool.type,
  196. pk = "School",
  197. ttl = -1,
  198. areaId = area == null ? "" : area.id,
  199. standard = area == null ? "" : area.standard,
  200. schoolCode = createSchoolInfo.id,
  201. period = PresetSchoolPeriod(bischool.period, foundSchools.lang, campusId),
  202. scale = bischool.size >= 300 ? 500 : 0,
  203. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
  204. };
  205. scInfos.Add(createSchoolInfo);
  206. vsSql.Append($"{upSchool.name}【{upSchool.id}】,");
  207. stringBuilder.Append($"创建学校:{upSchool.name}【{upSchool.id}】");
  208. noticeDD.Append($"{upSchool.name}【{upSchool.id}】 \r 学校管理员信息:");
  209. upSc.Add(upSchool.id);
  210. //创建学校
  211. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<School>(upSchool, new PartitionKey(upSchool.code));
  212. //创建学校信息中间件
  213. _ = _httpTrigger.RequestHttpTrigger(new { school = $"{upSchool}" }, _option.Location, "set-sc-birelation");
  214. var content = new StringContent(bischool.admin.ToArray().ToJsonString(), Encoding.UTF8, "application/json");
  215. string json = await _coreAPIHttpService.GetUserInfos(content);
  216. List<TmdUserinfo> tmdInfos = json.ToObject<List<TmdUserinfo>>();
  217. foreach (var tmdIndo in tmdInfos)
  218. {
  219. Teacher teacher = new();
  220. var resTeache = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemStreamAsync($"{tmdIndo.id}", new PartitionKey("Base"));
  221. if (resTeache.Status == 200)
  222. {
  223. using var tchJson = await JsonDocument.ParseAsync(resTeache.ContentStream);
  224. teacher = tchJson.ToObject<Teacher>();
  225. Teacher.TeacherSchool tchSc = null;
  226. //var tempTch = teacher.schools.Select(x => x.schoolId.Equals(upSchool.id)).ToString();
  227. tchSc = teacher.schools.Find(x => x.schoolId.Equals(upSchool.id));
  228. if (tchSc == null)
  229. {
  230. //教师存在,在该教师信息中添加要管理的学校信息
  231. teacher.schools.Add(new Teacher.TeacherSchool { areaId = string.IsNullOrEmpty(bischool.areaId) ? "" : bischool.areaId, schoolId = createSchoolInfo.id, name = bischool.name, status = "join", time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() });
  232. }
  233. //await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, coreUser.id, new PartitionKey("Base"));
  234. SchoolTeacher schoolTeacher = new()
  235. {
  236. id = tmdIndo.id,
  237. code = $"Teacher-{createSchoolInfo.id}",
  238. roles = new List<string> { "admin" },
  239. job = "管理员",
  240. name = teacher.name,
  241. picture = teacher.picture,
  242. status = "join",
  243. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  244. pk = "Teacher",
  245. ttl = -1
  246. };
  247. stringBuilder.Append($"【基础:{schoolTeacher.name}【{schoolTeacher.id}】,权限:{string.Join(",", schoolTeacher.roles)}】");
  248. noticeDD.Append($"{schoolTeacher.name}【{schoolTeacher.id}】");
  249. await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey(teacher.code));
  250. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<SchoolTeacher>(schoolTeacher, new PartitionKey(schoolTeacher.code));
  251. }
  252. else
  253. {
  254. //不存在 新建教师和新建要管理的学校信息
  255. Teacher addteacher = new()
  256. {
  257. id = tmdIndo.id,
  258. pk = "Base",
  259. code = "Base",
  260. name = $"{tmdIndo.name}",
  261. picture = $"{tmdIndo.picture}",
  262. //创建账号并第一次登录IES5则默认赠送1G
  263. size = 1,
  264. defaultSchool = createSchoolInfo.id,
  265. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  266. schools = new List<Teacher.TeacherSchool>() { new Teacher.TeacherSchool { schoolId = createSchoolInfo.id, name = bischool.name, status = "join", time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() } }
  267. };
  268. stringBuilder.Append($"【没有该教师基础信息,创建的教师基本信息:{addteacher.name}【{addteacher.id}】");
  269. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").CreateItemAsync<Teacher>(addteacher, new PartitionKey("Base"));
  270. SchoolTeacher schoolTeacher = new()
  271. {
  272. id = tmdIndo.id,
  273. code = $"Teacher-{createSchoolInfo.id}",
  274. roles = new List<string> { "admin" },
  275. job = "管理员",
  276. name = $"{tmdIndo.name}",
  277. picture = "",
  278. status = "join",
  279. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  280. pk = "Teacher",
  281. ttl = -1
  282. };
  283. stringBuilder.Append($"权限:{string.Join(",", schoolTeacher.roles)}】");
  284. noticeDD.Append($"{schoolTeacher.name}【{schoolTeacher.id}】");
  285. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<SchoolTeacher>(schoolTeacher, new PartitionKey(schoolTeacher.code));
  286. }
  287. }
  288. }
  289. }
  290. #endregion
  291. #region 旧版先检测 在创建
  292. //foreach (BISchool bischool in foundSchools.biSchools)
  293. //{
  294. // List<string> scName = new();
  295. // //查询学校名称是否全字段匹配
  296. // await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<string>(queryText: $"select value(c.name) from c where c.name='{bischool.name}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  297. // {
  298. // scName.Add(item);
  299. // }
  300. // Area area = null;
  301. // //查询区是否存在
  302. // var respAreaId = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemStreamAsync($"{bischool.areaId}", new PartitionKey("Base-Area"));
  303. // if (respAreaId.Status == 200)
  304. // {
  305. // using var areaBase = await JsonDocument.ParseAsync(respAreaId.ContentStream);
  306. // area = areaBase.ToObject<Area>();
  307. // }
  308. // bool isSYNCArea = false;
  309. // //查询去是否同步省平台
  310. // var responseSet = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemStreamAsync($"{bischool.areaId}", new PartitionKey("AreaSetting"));
  311. // if (responseSet.Status == 200)
  312. // {
  313. // using var fileJson = await JsonDocument.ParseAsync(responseSet.ContentStream);
  314. // AreaSetting delSet = fileJson.ToObject<AreaSetting>();
  315. // if (!string.IsNullOrEmpty(delSet.accessConfig))
  316. // isSYNCArea = true;
  317. // }
  318. // if (scName.Count <= 0)
  319. // {
  320. // if (isSYNCArea == false)
  321. // {
  322. // var coreUser = await _coreAPIHttpService.GetUserInfo(new Dictionary<string, string> { { "key", $"{bischool.admin}" } }, _option.Location, _configuration);
  323. // if (coreUser != null && coreUser.id != null)
  324. // {
  325. // CreateSchoolInfo createSchoolInfo = new CreateSchoolInfo()
  326. // {
  327. // province = bischool.province,
  328. // id = "",
  329. // name = bischool.name,
  330. // city = bischool.city,
  331. // aname = "",
  332. // createCount = 0,
  333. // };
  334. // //生成学校ID
  335. // bool tempStaus = true;
  336. // do
  337. // {
  338. // createSchoolInfo = await SchoolCode.GenerateSchoolCode(createSchoolInfo, _dingDing, _environment);
  339. // var schoolStatu = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{createSchoolInfo.id}", new PartitionKey($"Base"));
  340. // if (schoolStatu.Status != 200) tempStaus = false;
  341. // else createSchoolInfo.createCount = createSchoolInfo.createCount >= 3 ? createSchoolInfo.createCount = 3 : createSchoolInfo.createCount += 1;
  342. // } while (tempStaus);
  343. // if (createSchoolInfo.id != null)
  344. // {
  345. // string campusId = Guid.NewGuid().ToString();
  346. // School upSchool = new()
  347. // {
  348. // id = createSchoolInfo.id,
  349. // name = bischool.name,
  350. // size = bischool.size == 0 ? 100 : bischool.size,
  351. // code = "Base",
  352. // campuses = new List<Campus> { new Campus { name = bischool.name, id = campusId } },
  353. // region = bischool.region,
  354. // province = bischool.province,
  355. // city = bischool.city,
  356. // dist = bischool.dist,
  357. // address = bischool.address,
  358. // picture = "https://teammodelstorage.blob.core.chinacloudapi.cn/0-public/school/bbf54fb3-3fc8-43ae-a358-107281c174cc.png",
  359. // timeZone = new TEAMModelOS.SDK.Models.TimeZone { label = "(UTC+08:00) 北京,重庆,香港特别行政区,乌鲁木齐", value = "+08:00" },
  360. // type = string.IsNullOrEmpty(bischool.type.ToString()) ? 1 : bischool.type,
  361. // pk = "School",
  362. // ttl = -1,
  363. // areaId = area == null ? "" : area.id,
  364. // standard = area == null ? "" : area.standard,
  365. // schoolCode = createSchoolInfo.id,
  366. // period = PresetSchoolPeriod(bischool.period, foundSchools.lang, campusId),
  367. // scale = bischool.size >= 300 ? 500 : 0,
  368. // createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
  369. // };
  370. // stringBuilder.Append($"创建学校:{upSchool.name}【{upSchool.id}】");
  371. // noticeDD.Append($"【ID:{upSchool.id}|名称:{upSchool.name}】 ");
  372. // upSc.Add(upSchool.id);
  373. // //创建学校
  374. // await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<School>(upSchool, new PartitionKey(upSchool.code));
  375. // //创建学校管理员
  376. // Teacher teacher = null;
  377. // var resTeache = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemStreamAsync($"{coreUser.id}", new PartitionKey("Base"));
  378. // if (resTeache.Status == 200)
  379. // {
  380. // using var tchJson = await JsonDocument.ParseAsync(resTeache.ContentStream);
  381. // teacher = tchJson.ToObject<Teacher>();
  382. // //教师存在,在该教师信息中添加要管理的学校信息
  383. // teacher.schools.Add(new Teacher.TeacherSchool { areaId = string.IsNullOrEmpty(bischool.areaId) ? "" : bischool.areaId, schoolId = createSchoolInfo.id, name = bischool.name, status = "join", time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() });
  384. // //await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, coreUser.id, new PartitionKey("Base"));
  385. // SchoolTeacher schoolTeacher = new()
  386. // {
  387. // id = coreUser.id,
  388. // code = $"Teacher-{createSchoolInfo.id}",
  389. // roles = new List<string> { "admin", "teacher" },
  390. // job = "管理员",
  391. // name = teacher.name,
  392. // picture = teacher.picture,
  393. // status = "join",
  394. // createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  395. // pk = "Teacher",
  396. // ttl = -1
  397. // };
  398. // stringBuilder.Append($"教师信息:{schoolTeacher.name}【{schoolTeacher.id}】,教师权限:{string.Join(",", schoolTeacher.roles)}");
  399. // await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey(teacher.code));
  400. // await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<SchoolTeacher>(schoolTeacher, new PartitionKey(schoolTeacher.code));
  401. // }
  402. // else
  403. // {
  404. // //不存在 新建教师和新建要管理的学校信息
  405. // Teacher addteacher = new()
  406. // {
  407. // id = coreUser.id,
  408. // pk = "Base",
  409. // code = "Base",
  410. // name = $"{coreUser.name}",
  411. // picture = $"{coreUser.picture}",
  412. // //创建账号并第一次登录IES5则默认赠送1G
  413. // size = 1,
  414. // defaultSchool = createSchoolInfo.id,
  415. // createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  416. // schools = new List<Teacher.TeacherSchool>() { new Teacher.TeacherSchool { schoolId = createSchoolInfo.id, name = bischool.name, status = "join", time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() } }
  417. // };
  418. // stringBuilder.Append($"没有该教师信息创建的教师信息:{addteacher.name}【{addteacher.id}】");
  419. // await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").CreateItemAsync<Teacher>(addteacher, new PartitionKey("Base"));
  420. // SchoolTeacher schoolTeacher = new()
  421. // {
  422. // id = coreUser.id,
  423. // code = $"Teacher-{createSchoolInfo.id}",
  424. // roles = new List<string> { "admin", "teacher" },
  425. // job = "管理员",
  426. // name = $"{coreUser.name}",
  427. // picture = "",
  428. // status = "join",
  429. // createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  430. // pk = "Teacher",
  431. // ttl = -1
  432. // };
  433. // stringBuilder.Append($"教师权限:{string.Join(",", schoolTeacher.roles)}");
  434. // await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<SchoolTeacher>(schoolTeacher, new PartitionKey(schoolTeacher.code));
  435. // }
  436. // }
  437. // }
  438. // else userScs.Add(bischool);
  439. // }
  440. // else cutArea.Add(bischool);
  441. // }
  442. // else schools.Add(bischool);
  443. //}
  444. #endregion
  445. }
  446. else return Ok(new { state = 1, message = "创校信息为空" });
  447. if (upSc.Count > 1)
  448. await _dingDing.SendBotMsg($"BI,{_option.Location} \n 批量建校信息:{noticeDD}", GroupNames.成都开发測試群組);
  449. else if (upSc.Count == 1)
  450. await _dingDing.SendBotMsg($"BI,{_option.Location} \n 单个建校信息:{noticeDD}", GroupNames.成都开发測試群組);
  451. ////v2通知
  452. //Teacher targetTeacher = await cosmosClient.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemAsync<Teacher>($"{_tmdId}", new PartitionKey($"Base"));
  453. //_coreAPIHttpService.PushNotify(new List<IdNameCode> { new IdNameCode { id = targetTeacher.id, name = targetTeacher.name, code = targetTeacher.lang } }, "create-school", Constant.NotifyType_IES5_Management, new Dictionary<string, object> { { "tmdname", $"{_tmdName}" }, { "schooName", $"{vsSql}" } }, _option.Location, _configuration, _dingDing, _environment.ContentRootPath);
  454. //保存操作记录
  455. await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "school-batchAdd", stringBuilder?.ToString(), _dingDing, httpContext: HttpContext);
  456. if (schools.Count == foundSchools.biSchools.Count || userScs.Count == foundSchools.biSchools.Count)
  457. return Ok(new { state = RespondCode.CreateFailed, message = "已有部分学校批量创建成功;学校已经重复/学校信息有误!请检查学校信息!", schools, userScs });
  458. else
  459. {
  460. if (schools.Count > 0 || userScs.Count > 0 || cutArea.Count > 0)
  461. return Ok(new { state = RespondCode.Created, message = "已有部分学校批量创建成功;学校已经重复/学校信息有误/区域已在研修不能加区!请检查学校信息!", schools, userScs, cutArea });
  462. else
  463. return Ok(new { state = RespondCode.Ok, message = "批量创校已全部完成", scInfos });
  464. }
  465. }
  466. catch (Exception ex)
  467. {
  468. await _dingDing.SendBotMsg($"BI,{_option.Location} /batchschool/batch-school \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  469. return BadRequest();
  470. }
  471. }
  472. /// <summary>
  473. /// 依据学校编号查询学校信息;若是没有传学校编号,则查询所有学校信息 //已对接
  474. /// </summary>
  475. /// <param name="jsonElement"></param>
  476. /// <returns></returns>
  477. [ProducesDefaultResponseType]
  478. [HttpPost("get-schoolsinfo")]
  479. public async Task<IActionResult> GetSchoolsInfo(JsonElement jsonElement)
  480. {
  481. try
  482. {
  483. jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
  484. jsonElement.TryGetProperty("role", out JsonElement role);
  485. jsonElement.TryGetProperty("scId", out JsonElement scId);
  486. jsonElement.TryGetProperty("name", out JsonElement name);
  487. jsonElement.TryGetProperty("order", out JsonElement order);
  488. jsonElement.TryGetProperty("province", out JsonElement province);
  489. jsonElement.TryGetProperty("city", out JsonElement city);
  490. jsonElement.TryGetProperty("dist", out JsonElement dist);
  491. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  492. var cosmosClient = _azureCosmos.GetCosmosClient();
  493. ////分开部署,就不需要,一站多用时,取消注释
  494. //if ($"{site}".Equals(BIConst.Global))
  495. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  496. int scCnt = 0;
  497. int? pageSize = 100; //默认不指定返回大小
  498. string continuationToken = string.Empty; //返给前端分页token
  499. string pageToken = default;//接受前端的分页Tolen
  500. bool iscontinuation = false;//是否需要进行分页查询,默认不分页
  501. List<AssistSchool> schoolAssists = new(); //返回学校列表集合
  502. List<string> schoolIds = new();
  503. StringBuilder stringBuilder = new("select c.id,c.code,c.schoolCode,c.name,c.region,c.province,c.city,c.dist,c.size,c.address,c.picture,c.type,c.scale,c.areaId,c.standard from c ");
  504. StringBuilder scCntSql = new($"select value(count(c.id)) from c");
  505. if (jsonElement.TryGetProperty("pageSize", out JsonElement jsonPageSize))
  506. {
  507. if (!jsonPageSize.ValueKind.Equals(JsonValueKind.Undefined) && !jsonPageSize.ValueKind.Equals(JsonValueKind.Null) && jsonPageSize.TryGetInt32(out int tempPageSize))
  508. pageSize = tempPageSize;
  509. }
  510. if (pageSize != null && pageSize.Value > 0)
  511. iscontinuation = true;
  512. if (jsonElement.TryGetProperty("contToken", out JsonElement ContToken))
  513. pageToken = ContToken.GetString();
  514. if (!string.IsNullOrEmpty($"{scId}") && string.IsNullOrEmpty($"{name}"))
  515. {
  516. stringBuilder.Append($" where c.id='{scId}'");
  517. scCntSql.Append($" where c.id='{scId}'");
  518. }
  519. if (string.IsNullOrEmpty($"{scId}") && !string.IsNullOrEmpty($"{name}"))
  520. {
  521. stringBuilder.Append($" where Contains(c.name,'{name}')");
  522. scCntSql.Append($" where Contains(c.name,'{name}')");
  523. }
  524. if (!string.IsNullOrEmpty($"{province}") && string.IsNullOrEmpty($"{city}") && string.IsNullOrEmpty($"{dist}"))
  525. {
  526. stringBuilder.Append($" where Contains(c.province,'{province}')");
  527. scCntSql.Append($" where Contains(c.province,'{province}')");
  528. }
  529. if (!string.IsNullOrEmpty($"{city}") && !string.IsNullOrEmpty($"{city}") && string.IsNullOrEmpty($"{dist}"))
  530. {
  531. stringBuilder.Append($" where Contains(c.province,'{province}') and Contains(c.city,'{city}')");
  532. scCntSql.Append($" where Contains(c.province,'{province}') and Contains(c.city,'{city}')");
  533. }
  534. if (!string.IsNullOrEmpty($"{dist}") && !string.IsNullOrEmpty($"{city}") && !string.IsNullOrEmpty($"{dist}"))
  535. {
  536. stringBuilder.Append($" where Contains(c.province,'{province}') and Contains(c.city,'{city}') and Contains(c.dist,'{dist}')");
  537. scCntSql.Append($" where Contains(c.province,'{province}') and Contains(c.city,'{city}') and Contains(c.dist,'{dist}')");
  538. }
  539. if ($"{order}".Equals("desc"))
  540. stringBuilder.Append(" order by c.createTime desc");
  541. if (!string.IsNullOrEmpty($"{tmdId}"))
  542. {
  543. schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}", roles: !string.IsNullOrEmpty($"{role}") ? $"{role}" : "assist", isMany: true);
  544. string scsSql = BICommonWay.ManyScSql("c.id", schoolIds);
  545. scCntSql.Append($" where {scsSql}");
  546. scCnt = await CommonFind.GetSqlValueCount(cosmosClient, "School", scCntSql.ToString(), "Base");
  547. foreach (var id in schoolIds)
  548. {
  549. StringBuilder sqlTxt = new($"select c.id,c.code,c.schoolCode,c.name,c.region,c.province,c.city,c.dist,c.size,c.address,c.picture,c.type,c.scale,c.areaId,c.standard from c where c.id='{id}'");
  550. if ($"{order}".Equals("desc"))
  551. sqlTxt.Append(" order by c.createTime desc");
  552. else
  553. sqlTxt.Append(" order by c.createTime asc");
  554. await foreach (var itemSchool in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<AssistSchool>(queryText: sqlTxt.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  555. {
  556. schoolAssists.Add(itemSchool);
  557. }
  558. }
  559. }
  560. else
  561. {
  562. scCnt = await CommonFind.GetSqlValueCount(cosmosClient, "School", scCntSql.ToString(), "Base");
  563. await foreach (var itemSchool in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: stringBuilder.ToString(), continuationToken: pageToken, requestOptions: new QueryRequestOptions() { MaxItemCount = pageSize, PartitionKey = new PartitionKey("Base") }))
  564. {
  565. using var json = await JsonDocument.ParseAsync(itemSchool.ContentStream);
  566. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt16() > 0)
  567. {
  568. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  569. {
  570. schoolAssists.Add(obj.ToObject<AssistSchool>());
  571. }
  572. if (iscontinuation)
  573. {
  574. continuationToken = itemSchool.GetContinuationToken();
  575. break;
  576. }
  577. }
  578. }
  579. }
  580. //if (schoolIds.Count > 0)
  581. //{
  582. // scCnt = await CommonFind.GetSqlValueCount(cosmosClient, "School", scCntSql.ToString(), "Base");
  583. // foreach (var id in schoolIds)
  584. // {
  585. // StringBuilder sqlTxt = new($"select c.id,c.code,c.schoolCode,c.name,c.region,c.province,c.city,c.dist,c.size,c.address,c.picture,c.type,c.scale,c.areaId,c.standard from c where c.id='{id}'");
  586. // if ($"{order}".Equals("desc"))
  587. // sqlTxt.Append(" order by c.createTime desc");
  588. // await foreach (var itemSchool in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<AssistSchool>(queryText: sqlTxt.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  589. // {
  590. // schoolAssists.Add(itemSchool);
  591. // }
  592. // }
  593. //}
  594. //else
  595. //{
  596. // if (!string.IsNullOrEmpty($"{scId}") && string.IsNullOrEmpty($"{name}"))
  597. // {
  598. // stringBuilder.Append($" where c.id='{scId}'");
  599. // scCntSql.Append($" where c.id='{scId}'");
  600. // }
  601. // if (string.IsNullOrEmpty($"{scId}") && !string.IsNullOrEmpty($"{name}"))
  602. // {
  603. // stringBuilder.Append($" where Contains(c.name,'{name}')");
  604. // scCntSql.Append($" where Contains(c.name,'{name}')");
  605. // }
  606. // if (!string.IsNullOrEmpty($"{province}") && string.IsNullOrEmpty($"{city}") && string.IsNullOrEmpty($"{dist}"))
  607. // {
  608. // stringBuilder.Append($" where Contains(c.province,'{province}')");
  609. // scCntSql.Append($" where Contains(c.province,'{province}')");
  610. // }
  611. // if (!string.IsNullOrEmpty($"{city}") && !string.IsNullOrEmpty($"{city}") && string.IsNullOrEmpty($"{dist}"))
  612. // {
  613. // stringBuilder.Append($" where Contains(c.province,'{province}') and Contains(c.city,'{city}')");
  614. // scCntSql.Append($" where Contains(c.province,'{province}') and Contains(c.city,'{city}')");
  615. // }
  616. // if (!string.IsNullOrEmpty($"{dist}") && !string.IsNullOrEmpty($"{city}") && !string.IsNullOrEmpty($"{dist}"))
  617. // {
  618. // stringBuilder.Append($" where Contains(c.province,'{province}') and Contains(c.city,'{city}') and Contains(c.dist,'{dist}')");
  619. // scCntSql.Append($" where Contains(c.province,'{province}') and Contains(c.city,'{city}') and Contains(c.dist,'{dist}')");
  620. // }
  621. // if ($"{order}".Equals("desc"))
  622. // stringBuilder.Append(" order by c.createTime desc");
  623. // scCnt = await CommonFind.GetSqlValueCount(cosmosClient, "School", scCntSql.ToString(), "Base");
  624. // await foreach (var itemSchool in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: stringBuilder.ToString(), continuationToken: pageToken, requestOptions: new QueryRequestOptions() { MaxItemCount = pageSize, PartitionKey = new PartitionKey("Base") }))
  625. // {
  626. // using var json = await JsonDocument.ParseAsync(itemSchool.ContentStream);
  627. // if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt16() > 0)
  628. // {
  629. // foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  630. // {
  631. // schoolAssists.Add(obj.ToObject<AssistSchool>());
  632. // }
  633. // if (iscontinuation)
  634. // {
  635. // continuationToken = itemSchool.GetContinuationToken();
  636. // break;
  637. // }
  638. // }
  639. // }
  640. //}
  641. foreach (var item in schoolAssists)
  642. {
  643. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(item.id, new PartitionKey("ProductSum"));
  644. if (response.Status == 200)
  645. {
  646. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  647. if (json.RootElement.TryGetProperty("serial", out JsonElement serial) && !serial.ValueKind.Equals(JsonValueKind.Null))
  648. item.serial = serial.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  649. if (json.RootElement.TryGetProperty("service", out JsonElement service) && !service.ValueKind.Equals(JsonValueKind.Null))
  650. item.service = service.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  651. if (json.RootElement.TryGetProperty("hard", out JsonElement hard) && !hard.ValueKind.Equals(JsonValueKind.Null))
  652. item.hard = hard.ToObject<List<SchoolProductSumDataHard>>().Select(x => x.prodCode).ToList();
  653. }
  654. item.assists = await CommonFind.FindSchoolRoles(cosmosClient, item.id, "assist");
  655. item.scAdmin = await CommonFind.FindSchoolRoles(cosmosClient, item.id, "admin");
  656. item.lessonCount = await CommonFind.GetSqlValueCount(cosmosClient, "School", $"select value(count(c.id)) from c ", $"LessonRecord-{item.id}");
  657. }
  658. //schoolAssists.ForEach(async school =>
  659. //{
  660. // var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(school.id, new PartitionKey("ProductSum"));
  661. // if (response.Status == 200)
  662. // {
  663. // using var json = await JsonDocument.ParseAsync(response.ContentStream);
  664. // if (json.RootElement.TryGetProperty("serial", out JsonElement serial) && !serial.ValueKind.Equals(JsonValueKind.Null))
  665. // {
  666. // school.serial = serial.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  667. // }
  668. // if (json.RootElement.TryGetProperty("service", out JsonElement service) && !service.ValueKind.Equals(JsonValueKind.Null))
  669. // {
  670. // school.service = service.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  671. // }
  672. // if (json.RootElement.TryGetProperty("hard", out JsonElement hard) && !hard.ValueKind.Equals(JsonValueKind.Null))
  673. // {
  674. // school.hard = hard.ToObject<List<SchoolProductSumDataHard>>().Select(x => x.prodCode).ToList();
  675. // }
  676. // }
  677. // school.assists = await CommonFind.FindSchoolRoles(cosmosClient, school.id, "assist");
  678. // school.lessonCount = await CommonFind.GetSqlValueCount(cosmosClient, "School", $"select value(count(c.id)) from c ", $"LessonRecord-{school.id}");
  679. //});
  680. return Ok(new { state = 200, scCnt, continuationToken, schoolAssists });
  681. }
  682. catch (Exception ex)
  683. {
  684. await _dingDing.SendBotMsg($"BI,{_option.Location} /batchschool/get-schoolsinfo \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  685. return BadRequest();
  686. }
  687. }
  688. /// <summary>
  689. /// 所有信息
  690. /// </summary>
  691. /// <param name="jsonElement"></param>
  692. /// <returns></returns>
  693. [ProducesDefaultResponseType]
  694. [HttpPost("get-allscinfo")]
  695. public async Task<IActionResult> GetAllScsInfo(JsonElement jsonElement)
  696. {
  697. try
  698. {
  699. jsonElement.TryGetProperty("tmdId", out JsonElement tmdId);
  700. jsonElement.TryGetProperty("role", out JsonElement role);
  701. jsonElement.TryGetProperty("scId", out JsonElement scId);
  702. jsonElement.TryGetProperty("name", out JsonElement name);
  703. jsonElement.TryGetProperty("order", out JsonElement order);
  704. jsonElement.TryGetProperty("province", out JsonElement province);
  705. jsonElement.TryGetProperty("city", out JsonElement city);
  706. jsonElement.TryGetProperty("dist", out JsonElement dist);
  707. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  708. var cosmosClient = _azureCosmos.GetCosmosClient();
  709. ////分开部署,就不需要,一站多用时,取消注释
  710. //if ($"{site}".Equals(BIConst.Global))
  711. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  712. int scCnt = 0;
  713. List<AssistSchool> schoolAssists = new(); //返回学校列表集合
  714. List<string> schoolIds = new();
  715. StringBuilder stringBuilder = new("select c.id,c.code,c.schoolCode,c.name,c.region,c.province,c.city,c.dist,c.size,c.address,c.picture,c.type,c.scale,c.areaId,c.standard from c ");
  716. StringBuilder scCntSql = new($"select value(count(c.id)) from c");
  717. if (!string.IsNullOrEmpty($"{scId}") && string.IsNullOrEmpty($"{name}"))
  718. {
  719. stringBuilder.Append($" where c.id='{scId}'");
  720. scCntSql.Append($" where c.id='{scId}'");
  721. }
  722. if (string.IsNullOrEmpty($"{scId}") && !string.IsNullOrEmpty($"{name}"))
  723. {
  724. stringBuilder.Append($" where Contains(c.name,'{name}')");
  725. scCntSql.Append($" where Contains(c.name,'{name}')");
  726. }
  727. if (!string.IsNullOrEmpty($"{province}") && string.IsNullOrEmpty($"{city}") && string.IsNullOrEmpty($"{dist}"))
  728. {
  729. stringBuilder.Append($" where Contains(c.province,'{province}')");
  730. scCntSql.Append($" where Contains(c.province,'{province}')");
  731. }
  732. if (!string.IsNullOrEmpty($"{city}") && !string.IsNullOrEmpty($"{city}") && string.IsNullOrEmpty($"{dist}"))
  733. {
  734. stringBuilder.Append($" where Contains(c.province,'{province}') and Contains(c.city,'{city}')");
  735. scCntSql.Append($" where Contains(c.province,'{province}') and Contains(c.city,'{city}')");
  736. }
  737. if (!string.IsNullOrEmpty($"{dist}") && !string.IsNullOrEmpty($"{city}") && !string.IsNullOrEmpty($"{dist}"))
  738. {
  739. stringBuilder.Append($" where Contains(c.province,'{province}') and Contains(c.city,'{city}') and Contains(c.dist,'{dist}')");
  740. scCntSql.Append($" where Contains(c.province,'{province}') and Contains(c.city,'{city}') and Contains(c.dist,'{dist}')");
  741. }
  742. if (!string.IsNullOrEmpty($"{tmdId}"))
  743. {
  744. schoolIds = await CommonFind.FindSchoolIds(cosmosClient, $"{tmdId}", roles: !string.IsNullOrEmpty($"{role}") ? $"{role}" : "assist", isMany: true);
  745. string scsSql = BICommonWay.ManyScSql("c.id", schoolIds);
  746. scCntSql.Append($" where {scsSql}");
  747. scCnt = await CommonFind.GetSqlValueCount(cosmosClient, "School", scCntSql.ToString(), "Base");
  748. foreach (var id in schoolIds)
  749. {
  750. StringBuilder sqlTxt = new($"select c.id,c.code,c.schoolCode,c.name,c.region,c.province,c.city,c.dist,c.size,c.address,c.picture,c.type,c.scale,c.areaId,c.standard from c where c.id='{id}'");
  751. if ($"{order}".Equals("desc"))
  752. sqlTxt.Append(" order by c.createTime desc");
  753. await foreach (var itemSchool in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<AssistSchool>(queryText: sqlTxt.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  754. {
  755. schoolAssists.Add(itemSchool);
  756. }
  757. }
  758. }
  759. else
  760. {
  761. if ($"{order}".Equals("desc"))
  762. stringBuilder.Append(" order by c.createTime desc");
  763. scCnt = await CommonFind.GetSqlValueCount(cosmosClient, "School", scCntSql.ToString(), "Base");
  764. await foreach (var itemSchool in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: stringBuilder.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  765. {
  766. using var json = await JsonDocument.ParseAsync(itemSchool.ContentStream);
  767. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt16() > 0)
  768. {
  769. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  770. {
  771. schoolAssists.Add(obj.ToObject<AssistSchool>());
  772. }
  773. }
  774. }
  775. }
  776. foreach (var item in schoolAssists)
  777. {
  778. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(item.id, new PartitionKey("ProductSum"));
  779. if (response.Status == 200)
  780. {
  781. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  782. if (json.RootElement.TryGetProperty("serial", out JsonElement serial) && !serial.ValueKind.Equals(JsonValueKind.Null))
  783. item.serial = serial.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  784. if (json.RootElement.TryGetProperty("service", out JsonElement service) && !service.ValueKind.Equals(JsonValueKind.Null))
  785. item.service = service.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  786. if (json.RootElement.TryGetProperty("hard", out JsonElement hard) && !hard.ValueKind.Equals(JsonValueKind.Null))
  787. item.hard = hard.ToObject<List<SchoolProductSumDataHard>>().Select(x => x.prodCode).ToList();
  788. }
  789. item.assists = await CommonFind.FindSchoolRoles(cosmosClient, item.id, "assist");
  790. item.scAdmin = await CommonFind.FindSchoolRoles(cosmosClient, item.id, "admin");
  791. item.lessonCount = await CommonFind.GetSqlValueCount(cosmosClient, "School", $"select value(count(c.id)) from c ", $"LessonRecord-{item.id}");
  792. }
  793. return Ok(new { state = 200, scCnt, schoolAssists });
  794. }
  795. catch (Exception ex)
  796. {
  797. await _dingDing.SendBotMsg($"BI,{_option.Location} /batchschool/get-allscinfo() \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  798. return BadRequest();
  799. }
  800. }
  801. /// <summary>
  802. /// 使用yieId 关键字 本地效率未测出
  803. /// </summary>
  804. /// <param name="cosmosClient"></param>
  805. /// <param name="schoolAssists"></param>
  806. /// <returns></returns>
  807. private async IAsyncEnumerable<List<AssistSchool>> GetSchools(CosmosClient cosmosClient, List<AssistSchool> schoolAssists)
  808. {
  809. List<AssistSchool> tempSchoolAssists = new();
  810. foreach (var temp in schoolAssists)
  811. {
  812. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(temp.id, new PartitionKey("ProductSum"));
  813. if (response.Status == 200)
  814. {
  815. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  816. if (json.RootElement.TryGetProperty("serial", out JsonElement serial) && !serial.ValueKind.Equals(JsonValueKind.Null))
  817. {
  818. temp.serial = serial.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  819. }
  820. if (json.RootElement.TryGetProperty("service", out JsonElement service) && !service.ValueKind.Equals(JsonValueKind.Null))
  821. {
  822. temp.service = service.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  823. }
  824. if (json.RootElement.TryGetProperty("hard", out JsonElement hard) && !hard.ValueKind.Equals(JsonValueKind.Null))
  825. {
  826. temp.hard = hard.ToObject<List<SchoolProductSumDataHard>>().Select(x => x.prodCode).ToList();
  827. }
  828. }
  829. temp.assists = await CommonFind.FindSchoolRoles(cosmosClient, temp.id, "assist");
  830. tempSchoolAssists.Add(temp);
  831. }
  832. yield return tempSchoolAssists;
  833. }
  834. /// <summary>
  835. /// 取得学校所有顾问列表
  836. /// </summary>
  837. /// <returns></returns>
  838. [ProducesDefaultResponseType]
  839. [HttpPost("get-schoolassist")]
  840. public async Task<IActionResult> GetSchoolAssist(JsonElement jsonElement)
  841. {
  842. try
  843. {
  844. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  845. string schoolId = (jsonElement.TryGetProperty("schoolId", out JsonElement _schoolId)) ? _schoolId.GetString() : string.Empty;
  846. Dictionary<string, List<Dictionary<string, string>>> haveSchoolManger = new();
  847. string managerWhereOption = (!string.IsNullOrWhiteSpace(schoolId)) ? $" AND c.code = 'Teacher-{schoolId}'" : string.Empty;
  848. //查询学校的顾问
  849. string managerSql = $"SELECT DISTINCT REPLACE(c.code, 'Teacher-', '') AS schoolId, c.id, c.name FROM c WHERE ARRAY_CONTAINS(c.roles, 'assist', true) AND c.pk = 'Teacher' AND c.status = 'join'{managerWhereOption}";
  850. var cosmosClient = _azureCosmos.GetCosmosClient();
  851. //if ($"{site}".Equals(BIConst.Global))
  852. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  853. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: managerSql, requestOptions: new QueryRequestOptions() { }))
  854. {
  855. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  856. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  857. {
  858. string id = obj.GetProperty("id").GetString(); //管理员ID
  859. string name = obj.GetProperty("name").GetString(); //管理员姓名
  860. string tempSchoolId = obj.GetProperty("schoolId").GetString(); //学校ID
  861. Dictionary<string, string> managerDic = new();
  862. managerDic.Add("id", id);
  863. managerDic.Add("name", name);
  864. if (haveSchoolManger.ContainsKey(tempSchoolId))
  865. {
  866. haveSchoolManger[tempSchoolId].Add(managerDic);
  867. }
  868. else
  869. {
  870. List<Dictionary<string, string>> managerList = new List<Dictionary<string, string>>();
  871. managerList.Add(managerDic);
  872. haveSchoolManger.Add(tempSchoolId, managerList);
  873. }
  874. }
  875. }
  876. //管理模组学校
  877. List<string> baseModuleSchoos = new List<string>();
  878. string baseWhereOption = (!string.IsNullOrEmpty(schoolId)) ? $" and c.id='{schoolId}'" : string.Empty;
  879. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: $"select c.id from c join serviceProduct in c.service.product where serviceProduct.prodCode = 'IPDYZYLC' {baseWhereOption}", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Product") }))
  880. {
  881. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  882. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  883. {
  884. string tempSchoolId = obj.GetProperty("id").GetString(); //学校ID
  885. baseModuleSchoos.Add(tempSchoolId);
  886. }
  887. }
  888. //学校信息
  889. List<object> schools = new List<object>();
  890. string schoolWhereOption = (!string.IsNullOrEmpty(schoolId)) ? $" where c.id='{schoolId}'" : string.Empty;
  891. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: $"select c.id,c.name,c.period,c.schoolCode,c.region,c.province,c.city,c.picture from c {schoolWhereOption}", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  892. {
  893. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  894. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  895. {
  896. dynamic schoolExpando = new ExpandoObject();
  897. schoolExpando.id = obj.GetProperty("id").GetString();
  898. schoolExpando.name = obj.GetProperty("name").GetString();
  899. //schoolExpando.period = obj.GetProperty("period");
  900. schoolExpando.schoolCode = obj.GetProperty("schoolCode").GetString();
  901. schoolExpando.region = obj.GetProperty("region").GetString();
  902. schoolExpando.province = obj.GetProperty("province").GetString();
  903. schoolExpando.city = obj.GetProperty("city").GetString();
  904. schoolExpando.picture = obj.GetProperty("picture").GetString();
  905. if (haveSchoolManger.ContainsKey(schoolExpando.id))
  906. {
  907. schoolExpando.hasMarger = true;
  908. schoolExpando.managers = haveSchoolManger[schoolExpando.id];
  909. }
  910. else
  911. {
  912. schoolExpando.hasMarger = false;
  913. schoolExpando.managers = new List<object>();
  914. }
  915. schoolExpando.hasBaseModule = (baseModuleSchoos.Contains(schoolExpando.id)) ? true : false;
  916. schools.Add(schoolExpando);
  917. }
  918. }
  919. return Ok(new { state = 200, schools });
  920. }
  921. catch (Exception ex)
  922. {
  923. await _dingDing.SendBotMsg($"BI,{_option.Location} /batchschool/get-schools \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  924. return BadRequest();
  925. }
  926. }
  927. /// <summary>
  928. /// 修改学校信息和顾问信息 //已经对接
  929. /// </summary>
  930. /// <param name="jsonElement"></param>
  931. /// <returns></returns>
  932. [ProducesDefaultResponseType]
  933. [AuthToken(Roles = "admin,rdc")]
  934. [HttpPost("upd-schoolassist")]
  935. public async Task<IActionResult> UpdSchoolAssist(JsonElement jsonElement)
  936. {
  937. try
  938. {
  939. if (!jsonElement.TryGetProperty("schoolId", out JsonElement _schoolId)) return BadRequest();
  940. if (!jsonElement.TryGetProperty("name", out JsonElement schoolName)) return BadRequest();
  941. if (!jsonElement.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
  942. if (!jsonElement.TryGetProperty("standard", out JsonElement standard)) return BadRequest();
  943. //if (!jsonElement.TryGetProperty("period", out JsonElement period)) return BadRequest();
  944. if (!jsonElement.TryGetProperty("picture", out JsonElement picture)) return BadRequest();
  945. if (!jsonElement.TryGetProperty("size", out JsonElement size)) return BadRequest();
  946. if (!jsonElement.TryGetProperty("scale", out JsonElement scale)) return BadRequest();
  947. jsonElement.TryGetProperty("assistId", out JsonElement _assistId); //对接V2.0 删除该信息
  948. if (!jsonElement.TryGetProperty("type", out JsonElement _type)) return BadRequest();
  949. jsonElement.TryGetProperty("province", out JsonElement province);
  950. jsonElement.TryGetProperty("city", out JsonElement city);
  951. jsonElement.TryGetProperty("dist", out JsonElement dist);
  952. jsonElement.TryGetProperty("address", out JsonElement address);
  953. jsonElement.TryGetProperty("assist", out JsonElement assist);
  954. List<IdInfo> idInfos = assist.ToObject<List<IdInfo>>();
  955. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  956. var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);
  957. List<string> assistId = _assistId.ToObject<List<string>>();
  958. //List<string> periodS = period.ToObject<List<string>>();
  959. Dictionary<string, List<Dictionary<string, string>>> haveSchoolManger = new();
  960. var cosmosClient = _azureCosmos.GetCosmosClient();
  961. var tableClient = _azureStorage.GetCloudTableClient();
  962. var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
  963. //if ($"{site}".Equals(BIConst.Global))
  964. //{
  965. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  966. // tableClient = _azureStorage.GetCloudTableClient(BIConst.Global);
  967. // blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.Global);
  968. //}
  969. School tempShool = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>($"{_schoolId}", new PartitionKey("Base"));
  970. if (tempShool != null)
  971. {
  972. List<Period> periods = new();
  973. string campusId = Guid.NewGuid().ToString();
  974. //periodS.ForEach(x =>
  975. //{
  976. // periods.Add(new Period { id = Guid.NewGuid().ToString(), name = x.ToString(), campusId = campusId });
  977. //});
  978. //tempShool.period = periods;
  979. tempShool.size = !string.IsNullOrEmpty($"{size}") ? int.Parse($"{size}") : tempShool.size;
  980. tempShool.scale = !string.IsNullOrEmpty($"{scale}") ? int.Parse($"{scale}") : tempShool.scale;
  981. tempShool.picture = $"{picture}";
  982. tempShool.type = int.Parse($"{_type}");
  983. tempShool.name = $"{schoolName}";
  984. tempShool.areaId = $"{areaId}";
  985. tempShool.standard = $"{standard}";
  986. tempShool.province = string.IsNullOrEmpty($"{province}") ? tempShool.province : $"{province}";
  987. tempShool.city = string.IsNullOrEmpty($"{city}") ? tempShool.city : $"{city}";
  988. tempShool.dist = string.IsNullOrEmpty($"{dist}") ? tempShool.dist : $"{dist}";
  989. tempShool.address = string.IsNullOrEmpty($"{address}") ? tempShool.address : $"{address}";
  990. //修改学校
  991. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<School>(tempShool, tempShool.id, new PartitionKey("Base"));
  992. //创建学校信息中间件
  993. _ = _httpTrigger.RequestHttpTrigger(new { school = $"{tempShool}" }, _option.Location, "set-sc-birelation");
  994. //修改学校教师关联的信息
  995. string sql = $"SELECT distinct value(c) FROM c join A1 in c.schools where A1.schoolId='{tempShool.id}'";
  996. List<Teacher> teachers = new();
  997. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
  998. {
  999. teachers.Add(item);
  1000. }
  1001. foreach (var item in teachers)
  1002. {
  1003. Teacher.TeacherSchool teacherSchool = item.schools.Find(x => x.schoolId.Equals(tempShool.id));
  1004. if (teacherSchool != null)
  1005. {
  1006. teacherSchool.name = tempShool.name;
  1007. teacherSchool.picture = tempShool.picture;
  1008. teacherSchool.areaId = tempShool.areaId;
  1009. }
  1010. await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync(item, item.id, new PartitionKey($"Base"));
  1011. }
  1012. ////需要重大修改后保留
  1013. if (idInfos.Count > 0)
  1014. {
  1015. BIRelation biRel = new();
  1016. var respRel = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(tempShool.id,new PartitionKey("BIRel"));
  1017. if (respRel.Status == 200)
  1018. {
  1019. using var fileJson = await JsonDocument.ParseAsync(respRel.ContentStream);
  1020. biRel = fileJson.ToObject<BIRelation>();
  1021. }
  1022. else
  1023. biRel.id = tempShool.id;
  1024. string aName = null;
  1025. if (!string.IsNullOrEmpty($"{tempShool.areaId}"))
  1026. aName = await CosmosQueryHelper.GetStr(cosmosClient, "Normal", $"select value(c.name) from c where c.id='{tempShool.areaId}'", "Base-Area");
  1027. biRel.name = tempShool.name;
  1028. biRel.picture = tempShool.picture;
  1029. biRel.region = tempShool.region;
  1030. biRel.province = tempShool.province;
  1031. biRel.city = tempShool.city;
  1032. biRel.dist = tempShool.dist;
  1033. biRel.address = tempShool.address;
  1034. biRel.areaId = tempShool.areaId;
  1035. biRel.size = tempShool.size;
  1036. biRel.scale = tempShool.scale;
  1037. biRel.upDate = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  1038. biRel.areaName = aName;
  1039. foreach (var item in idInfos)
  1040. {
  1041. var tempAss = biRel.assists.Find(f => f.Equals(item.id));
  1042. if (tempAss == null)
  1043. biRel.assists.Add(item);
  1044. }
  1045. if (respRel.Status == 200)
  1046. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<BIRelation>(biRel, biRel.id, new PartitionKey("BIRel"));
  1047. else
  1048. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<BIRelation>(biRel, new PartitionKey("BIRel"));
  1049. }
  1050. ////需要重大修改后移除
  1051. //if (assistId.Count > 0)
  1052. //{
  1053. // //修改学校顾问
  1054. // string sqlTxt = $"SELECT value(c) From c WHERE ARRAY_CONTAINS(c.roles,'assist',true)";
  1055. // List<SchoolTeacher> schoolTeachers = new();
  1056. // await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<SchoolTeacher>(queryText: sqlTxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Teacher-{tempShool.id}") }))
  1057. // {
  1058. // if (!assistId.Contains(item.id))
  1059. // {
  1060. // if (item.roles.Contains("assist"))
  1061. // {
  1062. // item.roles.Remove("assist");
  1063. // if (item.roles.Count > 0)
  1064. // {
  1065. // await cosmosClient.GetContainer("TEAMModelOS", "School").ReplaceItemAsync<SchoolTeacher>(item, item.id, new PartitionKey(item.code));
  1066. // }
  1067. // else
  1068. // {
  1069. // await cosmosClient.GetContainer("TEAMModelOS", "School").DeleteItemAsync<SchoolTeacher>(item.id, new PartitionKey(item.code));
  1070. // }
  1071. // }
  1072. // }
  1073. // }
  1074. // foreach (var itemTeacher in assistId)
  1075. // {
  1076. // Teacher tempTeacher = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>($"{itemTeacher}", new PartitionKey("Base"));
  1077. // if (tempTeacher != null)
  1078. // {
  1079. // var haveTeacher = tempTeacher.schools.Find(x => x.schoolId.Equals($"{_schoolId}"));
  1080. // if (haveTeacher == null)
  1081. // {
  1082. // Teacher.TeacherSchool teacherSchool = new()
  1083. // {
  1084. // schoolId = tempShool.id,
  1085. // name = tempShool.name,
  1086. // status = "join",
  1087. // time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  1088. // picture = tempShool.picture,
  1089. // areaId = tempShool.areaId
  1090. // };
  1091. // tempTeacher.schools.Add(teacherSchool);
  1092. // //给醍摩豆顾问添加学校
  1093. // await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(tempTeacher, tempTeacher.id, new PartitionKey($"Base"));
  1094. // ////不存在则在原来的基础上添加顾问角色
  1095. // //SchoolTeacher addSchoolTeacher = new()
  1096. // //{
  1097. // // id = itemTeacher,
  1098. // // code = $"Teacher-{tempShool.id}",
  1099. // // pk = "Teacher",
  1100. // // status = "join",
  1101. // // roles = new List<string>() { "assist" },
  1102. // // name = tempTeacher.name,
  1103. // // job = $"{tempShool.name}-顾问",
  1104. // // size = 0,
  1105. // // createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
  1106. // //};
  1107. // //var resScTch = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{itemTeacher}", new PartitionKey($"Teacher-{tempShool.id}"));
  1108. // //if(resScTch.)
  1109. // ////添加学校学校顾问
  1110. // //await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<SchoolTeacher>(addSchoolTeacher, new PartitionKey($"Teacher-{tempShool.id}"));
  1111. // }
  1112. // //查询该教师是否存在该校
  1113. // SchoolTeacher schoolTeacher = null;
  1114. // var resScTch = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{itemTeacher}", new PartitionKey($"Teacher-{tempShool.id}"));
  1115. // if (resScTch.Status == 200)
  1116. // {
  1117. // using var tchJson = await JsonDocument.ParseAsync(resScTch.ContentStream);
  1118. // schoolTeacher = tchJson.ToObject<SchoolTeacher>();
  1119. // }
  1120. // if (schoolTeacher != null)
  1121. // {
  1122. // if (!schoolTeacher.roles.Contains("assist"))
  1123. // {
  1124. // schoolTeacher.roles.Add("assist");
  1125. // //添加顾问权限
  1126. // await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<SchoolTeacher>(schoolTeacher, schoolTeacher.id, new PartitionKey($"Teacher-{tempShool.id}"));
  1127. // }
  1128. // }
  1129. // else
  1130. // {
  1131. // SchoolTeacher addSchoolTeacher = new()
  1132. // {
  1133. // id = itemTeacher,
  1134. // code = $"Teacher-{tempShool.id}",
  1135. // pk = "Teacher",
  1136. // status = "join",
  1137. // roles = new List<string>() { "assist" },
  1138. // name = tempTeacher.name,
  1139. // job = $"{tempShool.name}-顾问",
  1140. // size = 0,
  1141. // createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
  1142. // };
  1143. // //添加学校顾问
  1144. // await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<SchoolTeacher>(addSchoolTeacher, new PartitionKey($"Teacher-{tempShool.id}"));
  1145. // }
  1146. // }
  1147. // }
  1148. //}
  1149. }
  1150. //保存操作记录
  1151. await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "school-update", $"{_tmdName}【{_tmdId}】修改学校功能,修改的学校:{_schoolId},{_type},{picture},{size},{string.Join("|", assistId.ToArray())}", _dingDing, httpContext: HttpContext);
  1152. return Ok(new { state = 200 });
  1153. }
  1154. catch (Exception ex)
  1155. {
  1156. await _dingDing.SendBotMsg($"BI, {_option.Location} /batchschool/upd-schoolassist \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  1157. return BadRequest();
  1158. }
  1159. }
  1160. /// <summary>
  1161. /// 查询区域的学校
  1162. /// </summary>
  1163. /// <param name="jsonElement"></param>
  1164. /// <returns></returns>
  1165. [ProducesDefaultResponseType]
  1166. [HttpPost("get-schooldist")]
  1167. public async Task<IActionResult> GetSchoolDist(JsonElement jsonElement)
  1168. {
  1169. try
  1170. {
  1171. if (!jsonElement.TryGetProperty("dist", out JsonElement _dist)) return BadRequest();
  1172. //jsonElement.TryGetProperty("site", out JsonElement site); //分开部署,就不需要,一站多用时,取消注释
  1173. var cosmosClient = _azureCosmos.GetCosmosClient();
  1174. //if ($"{site}".Equals(BIConst.Global))
  1175. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  1176. string sqltxt = $"SELECT * FROM c where c.dist='{_dist}'";
  1177. List<School> schools = new List<School>();
  1178. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<School>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  1179. {
  1180. schools.Add(item);
  1181. }
  1182. return Ok(new { state = 200, schools });
  1183. }
  1184. catch (Exception ex)
  1185. {
  1186. await _dingDing.SendBotMsg($"BI,{_option.Location} /batchschool/get-schooldist \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  1187. return BadRequest();
  1188. }
  1189. }
  1190. /// <summary>
  1191. /// 分页学校和顾问信息
  1192. /// </summary>
  1193. /// <param name="jsonElement"></param>
  1194. /// <returns></returns>
  1195. [ProducesDefaultResponseType]
  1196. [HttpPost("get-schools")]
  1197. public async Task<IActionResult> GetSchools(JsonElement jsonElement)
  1198. {
  1199. //List<School> schools = new List<School>();
  1200. List<AssistSchool> schoolAssists = new List<AssistSchool>();
  1201. if (!jsonElement.TryGetProperty("endPosition", out JsonElement endPosition)) return BadRequest();
  1202. if (!jsonElement.TryGetProperty("pageSize", out JsonElement pageSize)) return BadRequest();
  1203. //jsonElement.TryGetProperty("site", out JsonElement site); //分开部署,就不需要,一站多用时,取消注释
  1204. var cosmosClient = _azureCosmos.GetCosmosClient();
  1205. //if ($"{site}".Equals(BIConst.Global))
  1206. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  1207. string sqltxt = $"SELECT * FROM c order by c.id offset {endPosition} limit {pageSize}";
  1208. await foreach (var itemSchool in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<School>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  1209. {
  1210. AssistSchool schoolAssist = new()
  1211. {
  1212. id = itemSchool.id,
  1213. code = itemSchool.code,
  1214. schoolCode = itemSchool.schoolCode,
  1215. name = itemSchool.name,
  1216. region = itemSchool.region,
  1217. province = itemSchool.province,
  1218. city = itemSchool.city,
  1219. dist = itemSchool.dist,
  1220. size = itemSchool.size,
  1221. address = itemSchool.address,
  1222. picture = itemSchool.picture,
  1223. type = itemSchool.type,
  1224. scale = itemSchool.scale,
  1225. areaId = itemSchool.areaId,
  1226. standard = itemSchool.standard
  1227. };
  1228. schoolAssist.assists = await CommonFind.FindSchoolRoles(cosmosClient, itemSchool.id, "assist");
  1229. schoolAssists.Add(schoolAssist);
  1230. }
  1231. return Ok(new { state = 200, schoolAssists });
  1232. }
  1233. /// <summary>
  1234. /// 创校前检查数据
  1235. /// </summary>
  1236. /// <param name="jsonElement"></param>
  1237. /// <returns></returns>
  1238. [ProducesDefaultResponseType]
  1239. [HttpPost("get-checlkexist")]
  1240. public async Task<IActionResult> GetCheckExist(JsonElement jsonElement)
  1241. {
  1242. if (!jsonElement.TryGetProperty("scNames", out JsonElement _scNames)) return BadRequest();
  1243. if (!jsonElement.TryGetProperty("accounts", out JsonElement _accounts)) return BadRequest();
  1244. if (!jsonElement.TryGetProperty("areaIds", out JsonElement _areaIds)) return BadRequest();
  1245. jsonElement.TryGetProperty("schools", out JsonElement schools);
  1246. var cosmosClient = _azureCosmos.GetCosmosClient();
  1247. List<CreateSchoolInfo> cSchools = new();
  1248. if (!string.IsNullOrEmpty($"{schools}"))
  1249. cSchools = schools.ToObject<List<CreateSchoolInfo>>();
  1250. List<string> scNames = _scNames.ToObject<List<string>>();
  1251. List<string> accounts = _accounts.ToObject<List<string>>();
  1252. List<string> areaIds = _areaIds.ToObject<List<string>>();
  1253. List<string> existScNames = new(); //存在的学校
  1254. List<string> noAccounts = new(); // 不存在的账户
  1255. List<string> noAreaIds = new(); //不存在的学区
  1256. List<string> synPro = new(); //已同步省平台
  1257. List<CreateSchoolInfo> createScInfo = new(); //学校简码信息
  1258. if (scNames.Count > 0)
  1259. {
  1260. foreach (var item in scNames)
  1261. {
  1262. //查询学校名称是否全字段匹配
  1263. await foreach (var sc in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<string>(queryText: $"select value(c.name) from c where c.name='{item}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  1264. {
  1265. existScNames.Add(item);
  1266. }
  1267. }
  1268. }
  1269. if (accounts.Count > 0)
  1270. {
  1271. var content = new StringContent(_accounts.ToString(), Encoding.UTF8, "application/json");
  1272. string json = await _coreAPIHttpService.GetUserInfos(content);
  1273. List<TmdUserinfo> tmdInfos = json.ToObject<List<TmdUserinfo>>();
  1274. accounts.ForEach(ac =>
  1275. {
  1276. TmdUserinfo noTmdInfo = null;
  1277. tmdInfos.ForEach(tmd =>
  1278. {
  1279. if (!string.IsNullOrEmpty(tmd.id))
  1280. if (tmd.id.Equals($"{ac}"))
  1281. noTmdInfo = tmd;
  1282. if (!string.IsNullOrEmpty(tmd.mobile))
  1283. if (tmd.mobile.Equals($"{ac}"))
  1284. noTmdInfo = tmd;
  1285. if (!string.IsNullOrEmpty(tmd.mail))
  1286. if (tmd.mail.Equals($"{ac}"))
  1287. noTmdInfo = tmd;
  1288. });
  1289. //noTmdInfo = tmdInfos.Find(f => f.id.Equals($"{ac}") || f.mail.Equals($"{ac}") || f.mobile.Equals($"{ac}"));
  1290. if (noTmdInfo == null)
  1291. noAccounts.Add(ac);
  1292. });
  1293. }
  1294. if (areaIds.Count > 0)
  1295. {
  1296. foreach (var item in areaIds)
  1297. {
  1298. //查询区是否存在
  1299. var respAreaId = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemStreamAsync($"{item}", new PartitionKey("Base-Area"));
  1300. if (respAreaId.Status != 200)
  1301. {
  1302. noAreaIds.Add(item);
  1303. }
  1304. //查询去是否同步省平台
  1305. var responseSet = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemStreamAsync($"{item}", new PartitionKey("AreaSetting"));
  1306. if (responseSet.Status == 200)
  1307. {
  1308. using var fileJson = await JsonDocument.ParseAsync(responseSet.ContentStream);
  1309. AreaSetting delSet = fileJson.ToObject<AreaSetting>();
  1310. if (!string.IsNullOrEmpty(delSet.accessConfig))
  1311. synPro.Add(item);
  1312. }
  1313. }
  1314. }
  1315. foreach (var item in cSchools)
  1316. {
  1317. CreateSchoolInfo createSchoolInfo = item;
  1318. //生成学校ID
  1319. bool tempStaus = true;
  1320. do
  1321. {
  1322. createSchoolInfo = await SchoolCode.GenerateSchoolCode(createSchoolInfo, _dingDing, _environment);
  1323. var schoolStatu = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{createSchoolInfo.id}", new PartitionKey($"Base"));
  1324. if (schoolStatu.Status != 200) tempStaus = false;
  1325. else createSchoolInfo.createCount = createSchoolInfo.createCount >= 3 ? createSchoolInfo.createCount = 3 : createSchoolInfo.createCount += 1;
  1326. } while (tempStaus);
  1327. createScInfo.Add(createSchoolInfo);
  1328. }
  1329. if (existScNames.Count > 0 || noAccounts.Count > 0 || noAreaIds.Count > 0 || synPro.Count > 0)
  1330. return Ok(new { state = RespondCode.Created, existScNames, noAccounts, noAreaIds, synPro, createScInfo });
  1331. else
  1332. return Ok(new { state = RespondCode.Ok, createScInfo });
  1333. }
  1334. /// <summary>
  1335. /// 批量创校前检查数据
  1336. /// </summary>
  1337. /// <param name="jsonElement"></param>
  1338. /// <returns></returns>
  1339. [ProducesDefaultResponseType]
  1340. [HttpPost("get-checkexists")]
  1341. public async Task<IActionResult> GetCheckExists(JsonElement jsonElement)
  1342. {
  1343. if (!jsonElement.TryGetProperty("checkScs", out JsonElement checkScs)) return BadRequest();
  1344. List<BISchool> bISchools = checkScs.ToObject<List<BISchool>>();
  1345. var cosmosClient = _azureCosmos.GetCosmosClient();
  1346. List<BISchool> existScNames = new(); //存在的学校
  1347. List<BISchool> noAccounts = new(); // 不存在的账户
  1348. List<BISchool> noAreaIds = new(); //不存在的学区
  1349. List<BISchool> synPro = new(); //已同步省平台
  1350. List<BISchool> createScInfo = new(); //学校简码信息
  1351. foreach (BISchool bISchool in bISchools)
  1352. {
  1353. //查询学校名称是否全字段匹配
  1354. await foreach (var sc in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<string>(queryText: $"select value(c.name) from c where c.name='{bISchool.name}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  1355. {
  1356. existScNames.Add(bISchool);
  1357. }
  1358. var content = new StringContent(bISchool.admin.ToJsonString(), Encoding.UTF8, "application/json");
  1359. string json = await _coreAPIHttpService.GetUserInfos(content);
  1360. List<TmdUserinfo> tmdInfos = json.ToObject<List<TmdUserinfo>>();
  1361. bISchool.admin.ForEach(ac =>
  1362. {
  1363. TmdUserinfo noTmdInfo = null;
  1364. tmdInfos.ForEach(tmd =>
  1365. {
  1366. if (!string.IsNullOrEmpty(tmd.id))
  1367. if (tmd.id.Equals($"{ac}"))
  1368. noTmdInfo = tmd;
  1369. if (!string.IsNullOrEmpty(tmd.mobile))
  1370. if (tmd.mobile.Equals($"{ac}"))
  1371. noTmdInfo = tmd;
  1372. if (!string.IsNullOrEmpty(tmd.mail))
  1373. if (tmd.mail.Equals($"{ac}"))
  1374. noTmdInfo = tmd;
  1375. });
  1376. //noTmdInfo = tmdInfos.Find(f => f.id.Equals($"{ac}") || f.mail.Equals($"{ac}") || f.mobile.Equals($"{ac}"));
  1377. if (noTmdInfo == null)
  1378. noAccounts.Add(bISchool);
  1379. });
  1380. if (!string.IsNullOrEmpty(bISchool.areaId))
  1381. {
  1382. //查询区是否存在
  1383. var respAreaId = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemStreamAsync($"{bISchool.areaId}", new PartitionKey("Base-Area"));
  1384. if (respAreaId.Status != 200)
  1385. {
  1386. noAreaIds.Add(bISchool);
  1387. }
  1388. //查询去是否同步省平台
  1389. var responseSet = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemStreamAsync($"{bISchool.areaId}", new PartitionKey("AreaSetting"));
  1390. if (responseSet.Status == 200)
  1391. {
  1392. using var fileJson = await JsonDocument.ParseAsync(responseSet.ContentStream);
  1393. AreaSetting delSet = fileJson.ToObject<AreaSetting>();
  1394. if (!string.IsNullOrEmpty(delSet.accessConfig))
  1395. synPro.Add(bISchool);
  1396. }
  1397. }
  1398. CreateSchoolInfo createSchoolInfo = new CreateSchoolInfo()
  1399. {
  1400. province = bISchool.province,
  1401. id = "",
  1402. name = bISchool.name,
  1403. city = bISchool.city,
  1404. aname = "",
  1405. createCount = 0,
  1406. };
  1407. //生成学校ID
  1408. bool tempStaus = true;
  1409. do
  1410. {
  1411. createSchoolInfo = await SchoolCode.GenerateSchoolCode(createSchoolInfo, _dingDing, _environment);
  1412. var schoolStatu = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{createSchoolInfo.id}", new PartitionKey($"Base"));
  1413. if (schoolStatu.Status != 200) tempStaus = false;
  1414. else createSchoolInfo.createCount = createSchoolInfo.createCount >= 3 ? createSchoolInfo.createCount = 3 : createSchoolInfo.createCount += 1;
  1415. } while (tempStaus);
  1416. bISchool.id = createSchoolInfo.id;
  1417. createScInfo.Add(bISchool);
  1418. }
  1419. if (existScNames.Count > 0 || noAccounts.Count > 0 || noAreaIds.Count > 0 || synPro.Count > 0)
  1420. return Ok(new { state = RespondCode.Created, existScNames, noAccounts, noAreaIds, synPro, createScInfo });
  1421. else
  1422. return Ok(new { state = RespondCode.Ok, createScInfo });
  1423. }
  1424. /// <summary>
  1425. /// 添加多个学校添加多个管理员
  1426. /// </summary>
  1427. /// <param name="jsonElement"></param>
  1428. /// <returns></returns>
  1429. [ProducesDefaultResponseType]
  1430. [HttpPost("set-batchmanage")]
  1431. public async Task<IActionResult> SetBatchManage(JsonElement jsonElement)
  1432. {
  1433. if (!jsonElement.TryGetProperty("scIds", out JsonElement _scIds)) return BadRequest();
  1434. if (!jsonElement.TryGetProperty("manages", out JsonElement _manages)) return BadRequest();
  1435. var cosmosClient = _azureCosmos.GetCosmosClient();
  1436. List<string> scIds = _scIds.ToObject<List<string>>();
  1437. List<string> manages = _manages.ToObject<List<string>>();
  1438. List<ExistScManage> existScManages = new();
  1439. if (scIds.Count > 0 && manages.Count > 0)
  1440. {
  1441. foreach (var scId in scIds)
  1442. {
  1443. foreach (var msId in manages)
  1444. {
  1445. //不存在则在原来的基础上添加顾问角色
  1446. Teacher tempTeacher = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>($"{msId}", new PartitionKey("Base"));
  1447. if (tempTeacher != null)
  1448. {
  1449. var response = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{msId}", new PartitionKey($"Teacher-{scId}"));
  1450. if (response.Status == 200)
  1451. {
  1452. using var tchJson = await JsonDocument.ParseAsync(response.ContentStream);
  1453. SchoolTeacher tchSc = tchJson.ToObject<SchoolTeacher>();
  1454. if (tchSc.roles.Contains("admin"))
  1455. {
  1456. tchSc.roles.Add("admin");
  1457. //添加顾问权限
  1458. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<SchoolTeacher>(tchSc, tchSc.id, new PartitionKey($"Teacher-{scId}"));
  1459. }
  1460. else
  1461. existScManages.Add(new ExistScManage() { scId = scId, tmdId = msId });
  1462. }
  1463. else
  1464. {
  1465. SchoolTeacher addSchoolTeacher = new()
  1466. {
  1467. id = tempTeacher.id,
  1468. code = $"Teacher-{scId}",
  1469. pk = "Teacher",
  1470. status = "join",
  1471. roles = new List<string>() { "admin" },
  1472. name = tempTeacher.name,
  1473. job = $"管理员",
  1474. size = 0,
  1475. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
  1476. };
  1477. var haveTeacher = tempTeacher.schools.Find(x => x.schoolId.Equals($"{scId}"));
  1478. if (haveTeacher == null)
  1479. {
  1480. School school = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemAsync<School>(scId, new PartitionKey("Base"));
  1481. //教师存在,在该教师信息中添加要管理的学校信息
  1482. tempTeacher.schools.Add(new Teacher.TeacherSchool { areaId = string.IsNullOrEmpty(school.areaId) ? "" : school.areaId, schoolId = school.id, name = school.name, status = "join", time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() });
  1483. tempTeacher = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(tempTeacher, msId, new PartitionKey("Base"));
  1484. }
  1485. //添加学校学校管理员
  1486. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<SchoolTeacher>(addSchoolTeacher, new PartitionKey($"Teacher-{scId}"));
  1487. }
  1488. }
  1489. else
  1490. {
  1491. CoreUser coreUser = await _coreAPIHttpService.GetUserInfo(new Dictionary<string, string> { { "key", $"{msId}" } }, _option.Location, _configuration);
  1492. Teacher teacher = new() { id = coreUser.id, name = coreUser.name, picture = coreUser.picture, pk = "Base", code = "Base", size = 1, createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() };
  1493. var responseSc = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(scId, new PartitionKey("Base"));
  1494. if (responseSc.Status == 200)
  1495. {
  1496. using var tchJson = await JsonDocument.ParseAsync(responseSc.ContentStream);
  1497. School scInfo = tchJson.ToObject<School>();
  1498. teacher.schools.Add(new() { schoolId = scInfo.id, name = scInfo.name, status = "join", time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(), picture = scInfo.picture, areaId = scInfo.areaId });
  1499. }
  1500. teacher = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").CreateItemAsync<Teacher>(teacher, new PartitionKey("Base"));
  1501. SchoolTeacher addSchoolTeacher = new()
  1502. {
  1503. id = coreUser.id,
  1504. code = $"Teacher-{scId}",
  1505. pk = "Teacher",
  1506. status = "join",
  1507. roles = new List<string>() { "admin" },
  1508. name = coreUser.name,
  1509. job = $"管理员",
  1510. size = 0,
  1511. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
  1512. };
  1513. //添加学校学校管理员
  1514. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<SchoolTeacher>(addSchoolTeacher, new PartitionKey($"Teacher-{scId}"));
  1515. }
  1516. }
  1517. }
  1518. }
  1519. if (existScManages.Count > 0)
  1520. return Ok(new { state = RespondCode.Created, existScManages });
  1521. else
  1522. return Ok(new { state = RespondCode.Ok });
  1523. }
  1524. /// <summary>
  1525. /// 批量设置学校集合中学校多个管理员
  1526. /// </summary>
  1527. /// <param name="jsonElement"></param>
  1528. /// <returns></returns>
  1529. [ProducesDefaultResponseType]
  1530. [AuthToken(Roles = "admin")]
  1531. [HttpPost("batch-scmanage")]
  1532. public async Task<IActionResult> BatchScManage(JsonElement jsonElement)
  1533. {
  1534. if (!jsonElement.TryGetProperty("scManages", out JsonElement _scManages)) return BadRequest();
  1535. var cosmosClient = _azureCosmos.GetCosmosClient();
  1536. List<ScManages> scManages = _scManages.ToObject<List<ScManages>>();
  1537. List<ScManages> error = new(); //异常数据
  1538. foreach (var item in scManages)
  1539. {
  1540. School school = new();
  1541. var resSc = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{item.id}", new PartitionKey("Base"));
  1542. if (resSc.Status == 200)
  1543. {
  1544. using var sJson = await JsonDocument.ParseAsync(resSc.ContentStream);
  1545. school = sJson.ToObject<School>();
  1546. //CoreUser coreUser = await _coreAPIHttpService.GetUserInfo(new Dictionary<string, string> { { "key", $"19940828843" } }, _option.Location, _configuration);
  1547. var content = new StringContent(item.mobiles.ToArray().ToJsonString(), Encoding.UTF8, "application/json");
  1548. string json = await _coreAPIHttpService.GetUserInfos(content);
  1549. List<TmdUserinfo> tmdInfos = json.ToObject<List<TmdUserinfo>>();
  1550. Teacher teacher = new();
  1551. foreach (var tmd in tmdInfos)
  1552. {
  1553. var respone = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemStreamAsync($"{tmd.id}", new PartitionKey("Base"));
  1554. if (respone.Status == 200)
  1555. {
  1556. using var tchJson = await JsonDocument.ParseAsync(respone.ContentStream);
  1557. teacher = tchJson.ToObject<Teacher>();
  1558. var response = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{tmd.id}", new PartitionKey($"Teacher-{item.id}"));
  1559. if (response.Status == 200)
  1560. {
  1561. using var scTchJson = await JsonDocument.ParseAsync(response.ContentStream);
  1562. SchoolTeacher tchSc = scTchJson.ToObject<SchoolTeacher>();
  1563. if (tchSc.roles.Contains("admin"))
  1564. {
  1565. tchSc.roles.Add("admin");
  1566. //添加顾问权限
  1567. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<SchoolTeacher>(tchSc, tchSc.id, new PartitionKey($"Teacher-{item.id}"));
  1568. }
  1569. else
  1570. {
  1571. var exsitI = error.Find(f => f.id.Equals(item.id));
  1572. if (exsitI != null)
  1573. {
  1574. var replacts = error.Where(w => w.id.Equals(item.id)).FirstOrDefault();
  1575. replacts.mobiles.Add($"{item.id}");
  1576. }
  1577. else
  1578. error.Add(new ScManages { id = item.id, name = item.name, mobiles = new List<string>() { $"{tmd.id}" } });
  1579. }
  1580. }
  1581. else
  1582. {
  1583. SchoolTeacher addSchoolTeacher = new()
  1584. {
  1585. id = tmd.id,
  1586. code = $"Teacher-{item.id}",
  1587. pk = "Teacher",
  1588. status = "join",
  1589. roles = new List<string>() { "admin" },
  1590. name = tmd.name,
  1591. job = $"管理员",
  1592. size = 0,
  1593. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
  1594. };
  1595. var haveTeacher = teacher.schools.Find(x => x.schoolId.Equals($"{item.id}"));
  1596. if (haveTeacher == null)
  1597. {
  1598. //教师存在,在该教师信息中添加要管理的学校信息
  1599. teacher.schools.Add(new Teacher.TeacherSchool { areaId = string.IsNullOrEmpty(school.areaId) ? "" : school.areaId, schoolId = school.id, name = school.name, status = "join", time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() });
  1600. teacher = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey("Base"));
  1601. }
  1602. //添加学校学校顾问
  1603. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<SchoolTeacher>(addSchoolTeacher, new PartitionKey($"Teacher-{item.id}"));
  1604. }
  1605. }
  1606. else
  1607. {
  1608. teacher = new()
  1609. {
  1610. id = $"{tmd.id}",
  1611. name = $"{tmd.name}",
  1612. picture = $"{tmd.picture}",
  1613. pk = "Base",
  1614. code = "Base",
  1615. size = 1,
  1616. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  1617. schools = new List<Teacher.TeacherSchool>() { new Teacher.TeacherSchool { schoolId = $"{school.id}", name = $"{school.name}", status = "join", time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(), picture = school.province, areaId = school.areaId } }
  1618. };
  1619. teacher = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Teacher").CreateItemAsync<Teacher>(teacher, new PartitionKey("Base"));
  1620. SchoolTeacher addSchoolTeacher = new()
  1621. {
  1622. id = tmd.id,
  1623. code = $"Teacher-{item.id}",
  1624. pk = "Teacher",
  1625. status = "join",
  1626. roles = new List<string>() { "admin" },
  1627. name = tmd.name,
  1628. job = $"管理员",
  1629. size = 0,
  1630. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
  1631. };
  1632. //添加学校学校管理员
  1633. await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<SchoolTeacher>(addSchoolTeacher, new PartitionKey($"Teacher-{item.id}"));
  1634. }
  1635. }
  1636. }
  1637. else
  1638. error.Add(new ScManages { id = item.id, name = item.name, mobiles = new List<string>() });
  1639. }
  1640. return Ok(new { state = RespondCode.Ok, error });
  1641. }
  1642. #region 预设学校基础信息 多语言
  1643. /// <summary>
  1644. /// 预设学校基础信息 多语言
  1645. /// </summary>
  1646. /// <param name="period"></param>
  1647. /// <param name="Language"></param>
  1648. /// <param name="campusId"></param>
  1649. /// <returns></returns>
  1650. public List<Period> PresetSchoolPeriod(List<PeriodType> period, string Language, string campusId)
  1651. {
  1652. var builder = $"{_environment.ContentRootPath}/JsonFile/Preset/LangSchoolConfig.json";
  1653. StreamReader streamReader = new(new FileStream(builder, FileMode.Open, FileAccess.Read, FileShare.ReadWrite), Encoding.UTF8);
  1654. StringBuilder stringBuilder = new();
  1655. string text;
  1656. while ((text = streamReader.ReadLine()) != null)
  1657. {
  1658. stringBuilder.Append(text.ToString());
  1659. }
  1660. streamReader.Close();
  1661. string input = stringBuilder.ToString();
  1662. List<SchoolConfig> schoolConfigs = input.ToObject<List<SchoolConfig>>();
  1663. SchoolConfig schoolConfig = schoolConfigs.Find(x => x.Lang.Contains($"{Language}"));
  1664. if (schoolConfig == null)
  1665. {
  1666. if (Language.Contains("en"))
  1667. schoolConfig = schoolConfigs.Find(x => x.Lang.Contains("en-US"));
  1668. else
  1669. schoolConfig = schoolConfigs.Find(x => x.Lang.Contains("zh-CN"));
  1670. }
  1671. List<Period> periods = new();
  1672. if (period.Count > 0)
  1673. {
  1674. period.ForEach(x =>
  1675. {
  1676. periods.Add(new Period
  1677. {
  1678. id = Guid.NewGuid().ToString(),
  1679. name = x.pidName,
  1680. campusId = campusId,
  1681. semesters = new List<Semester>() { new Semester { name = schoolConfig.semester[0].term, start = schoolConfig.semester[0].start, month = schoolConfig.semester[0].month, day = schoolConfig.semester[0].day, id = Guid.NewGuid().ToString() },
  1682. new Semester { name = schoolConfig.semester[1].term, start = schoolConfig.semester[1].start, month = schoolConfig.semester[1].month, day = schoolConfig.semester[1].day, id = Guid.NewGuid().ToString() } },
  1683. subjects = new List<Subject>() {
  1684. new Subject { id=Guid.NewGuid().ToString(),name=schoolConfig.PresetSubject[0].name,type=schoolConfig.PresetSubject[0].type },
  1685. new Subject { id=Guid.NewGuid().ToString(),name=schoolConfig.PresetSubject[1].name,type=schoolConfig.PresetSubject[1].type },
  1686. new Subject { id=Guid.NewGuid().ToString(),name=schoolConfig.PresetSubject[2].name,type=schoolConfig.PresetSubject[2].type }
  1687. },
  1688. grades = schoolConfig.grades,
  1689. analysis = new Analysis()
  1690. {
  1691. type = new List<ExamSimple>() { new ExamSimple { id = Guid.NewGuid().ToString(), name = schoolConfig.PresetExam[0].type[0].name },
  1692. new ExamSimple { id = Guid.NewGuid().ToString(), name = schoolConfig.PresetExam[0].type[1].name },
  1693. new ExamSimple { id = Guid.NewGuid().ToString(), name = schoolConfig.PresetExam[0].type[2].name },
  1694. new ExamSimple { id = Guid.NewGuid().ToString(), name = schoolConfig.PresetExam[0].type[3].name } },
  1695. income = schoolConfig.PresetExam[0].income,
  1696. eugenics = schoolConfig.PresetExam[0].eugenics,
  1697. touch = schoolConfig.PresetExam[0].touch
  1698. },
  1699. periodType = x.pidType
  1700. });
  1701. });
  1702. }
  1703. else
  1704. {
  1705. periods.Add(new Period
  1706. {
  1707. id = Guid.NewGuid().ToString(),
  1708. name = "默认学段",
  1709. campusId = campusId,
  1710. semesters = new List<Semester>() { new Semester { name = schoolConfig.semester[0].term, start = schoolConfig.semester[0].start, month = schoolConfig.semester[0].month, day = schoolConfig.semester[0].day, id = Guid.NewGuid().ToString() },
  1711. new Semester { name = schoolConfig.semester[1].term, start = schoolConfig.semester[1].start, month = schoolConfig.semester[1].month, day = schoolConfig.semester[1].day, id = Guid.NewGuid().ToString() } },
  1712. subjects = new List<Subject>() {
  1713. new Subject { id=Guid.NewGuid().ToString(),name=schoolConfig.PresetSubject[0].name,type=schoolConfig.PresetSubject[0].type },
  1714. new Subject { id=Guid.NewGuid().ToString(),name=schoolConfig.PresetSubject[1].name,type=schoolConfig.PresetSubject[1].type },
  1715. new Subject { id=Guid.NewGuid().ToString(),name=schoolConfig.PresetSubject[2].name,type=schoolConfig.PresetSubject[2].type }
  1716. },
  1717. grades = schoolConfig.grades,
  1718. analysis = new Analysis()
  1719. {
  1720. type = new List<ExamSimple>() { new ExamSimple { id = Guid.NewGuid().ToString(), name = schoolConfig.PresetExam[0].type[0].name },
  1721. new ExamSimple { id = Guid.NewGuid().ToString(), name = schoolConfig.PresetExam[0].type[1].name },
  1722. new ExamSimple { id = Guid.NewGuid().ToString(), name = schoolConfig.PresetExam[0].type[2].name },
  1723. new ExamSimple { id = Guid.NewGuid().ToString(), name = schoolConfig.PresetExam[0].type[3].name } },
  1724. income = schoolConfig.PresetExam[0].income,
  1725. eugenics = schoolConfig.PresetExam[0].eugenics,
  1726. touch = schoolConfig.PresetExam[0].touch
  1727. }
  1728. });
  1729. }
  1730. return periods;
  1731. }
  1732. #endregion
  1733. //public class SchoolAssist
  1734. //{
  1735. // public string id { get; set; }
  1736. // public string code { get; set; }
  1737. // public string schoolCode { get; set; }
  1738. // public string name { get; set; }
  1739. // public string region { get; set; }
  1740. // public string province { get; set; }
  1741. // public string city { get; set; }
  1742. // public string dist { get; set; }
  1743. // public int size { get; set; }
  1744. // public string address { get; set; }
  1745. // public string picture { get; set; }
  1746. // public int type { get; set; }
  1747. // public int scale { get; set; }
  1748. // public string standard { get; set; }
  1749. // public string areaId { get; set; }
  1750. // public List<SchoolTeacherRoles> assists { get; set; }
  1751. // public int serial { get; set; } //软体
  1752. // public int service { get; set; } //服务
  1753. // public int hard { get; set; } //硬体
  1754. // //public List<SchoolProductSumData> serial { get; set; } //软体
  1755. // //public List<SchoolProductSumData> service { get; set; } //服务
  1756. // //public List<SchoolProductSumDataHard> hard { get; set; } //硬体
  1757. //}
  1758. /// <summary>
  1759. /// 创建多个学校实体
  1760. /// </summary>
  1761. public record FoundSchools()
  1762. {
  1763. /// <summary>
  1764. /// 语系
  1765. /// </summary>
  1766. public string lang { get; set; }
  1767. /// <summary>
  1768. /// 站点
  1769. /// </summary>
  1770. public string site { get; set; }
  1771. /// <summary>
  1772. /// 批量创校的数据结构
  1773. /// </summary>
  1774. public List<BISchool> biSchools { get; set; } = new List<BISchool>();
  1775. }
  1776. /// <summary>
  1777. /// 批量创校的数据结构
  1778. /// </summary>
  1779. public record BISchool()
  1780. {
  1781. public string id { get; set; }
  1782. /// <summary>
  1783. /// 学校名称
  1784. /// </summary>
  1785. public string name { get; set; }
  1786. /// <summary>
  1787. /// 学校管理员
  1788. /// </summary>
  1789. public List<string> admin { get; set; }
  1790. /// <summary>
  1791. /// 学校的学段
  1792. /// </summary>
  1793. public List<PeriodType> period { get; set; }
  1794. /// <summary>
  1795. /// 学校空间大小
  1796. /// </summary>
  1797. public int size { get; set; }
  1798. /// <summary>
  1799. /// 地区
  1800. /// </summary>
  1801. public string region { get; set; }
  1802. /// <summary>
  1803. /// 省份
  1804. /// </summary>
  1805. public string province { get; set; }
  1806. /// <summary>
  1807. /// 城市
  1808. /// </summary>
  1809. public string city { get; set; }
  1810. /// <summary>
  1811. /// 县,区,郡
  1812. /// </summary>
  1813. public string dist { get; set; }
  1814. /// <summary>
  1815. /// 学校详细地址
  1816. /// </summary>
  1817. public string address { get; set; }
  1818. /// <summary>
  1819. /// 学校类型
  1820. /// </summary>
  1821. public int type { get; set; }
  1822. /// <summary>
  1823. /// 区域ID
  1824. /// </summary>
  1825. public string areaId { get; set; }
  1826. /// <summary>
  1827. /// 区域标准
  1828. /// </summary>
  1829. public string standard { get; set; }
  1830. }
  1831. /// <summary>
  1832. /// 学段类型和学段名称
  1833. /// </summary>
  1834. public record PeriodType
  1835. {
  1836. public string pidType { get; set; }
  1837. public string pidName { get; set; }
  1838. }
  1839. /// <summary>
  1840. /// 存在的学校
  1841. /// </summary>
  1842. public record ExistScManage
  1843. {
  1844. public string scId { get; set; }
  1845. public string tmdId { get; set; }
  1846. }
  1847. /// <summary>
  1848. /// 管理员
  1849. /// </summary>
  1850. public record ScManages
  1851. {
  1852. public string id { get; set; }
  1853. public string name { get; set; }
  1854. public List<string> mobiles { get; set; }
  1855. }
  1856. }
  1857. }