BatchSchoolController.cs 115 KB

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