InitController.cs 83 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414
  1. using Azure.Cosmos;
  2. using Azure.Storage.Blobs.Models;
  3. using Azure.Storage.Sas;
  4. using Microsoft.AspNetCore.Http;
  5. using Microsoft.AspNetCore.Mvc;
  6. using Microsoft.Extensions.Options;
  7. using System;
  8. using System.Collections.Generic;
  9. using System.Dynamic;
  10. using System.IdentityModel.Tokens.Jwt;
  11. using System.IO;
  12. using System.Linq;
  13. using System.Text.Json;
  14. using System.Threading.Tasks;
  15. using TEAMModelOS.Models;
  16. using TEAMModelOS.SDK.Models;
  17. using TEAMModelOS.SDK.DI;
  18. using TEAMModelOS.SDK.Extension;
  19. using TEAMModelOS.Filter;
  20. using TEAMModelOS.SDK.Models.Cosmos;
  21. using HTEXLib.COMM.Helpers;
  22. using TEAMModelOS.SDK.Models.Service;
  23. using Microsoft.Extensions.Configuration;
  24. using System.Net.Http;
  25. using TEAMModelOS.SDK;
  26. using static TEAMModelOS.SDK.Models.Teacher;
  27. using TEAMModelOS.Services;
  28. using Microsoft.AspNetCore.Authorization;
  29. using System.Diagnostics;
  30. using Microsoft.Extensions.Logging;
  31. using System.Text;
  32. using Microsoft.Azure.Cosmos.Table;
  33. using Microsoft.AspNetCore.Hosting;
  34. using DocumentFormat.OpenXml.Office2010.Excel;
  35. using DocumentFormat.OpenXml.Drawing.Charts;
  36. using static TEAMModelOS.Controllers.FixDataController;
  37. using IdCode = TEAMModelOS.SDK.Models.IdCode;
  38. using TEAMModelOS.SDK.Models.Service.BI;
  39. namespace TEAMModelOS.Controllers
  40. {
  41. [ProducesResponseType(StatusCodes.Status200OK)]
  42. [ProducesResponseType(StatusCodes.Status400BadRequest)]
  43. [Route("teacher/init")]
  44. [ApiController]
  45. public class InitController : ControllerBase
  46. {
  47. private readonly AzureCosmosFactory _azureCosmos;
  48. private readonly AzureStorageFactory _azureStorage;
  49. private readonly AzureRedisFactory _azureRedis;
  50. private readonly DingDing _dingDing;
  51. private readonly Option _option;
  52. private readonly IConfiguration _configuration;
  53. private readonly CoreAPIHttpService _coreAPIHttpService;
  54. private readonly IPSearcher _searcher;
  55. private readonly ILogger<InitController> _logger;
  56. private readonly HttpTrigger _httpTrigger;
  57. private readonly IWebHostEnvironment _environment;
  58. public InitController(IWebHostEnvironment environment,ILogger<InitController> logger, IPSearcher searcher, CoreAPIHttpService coreAPIHttpService, AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, AzureRedisFactory azureRedis, DingDing dingDing, IOptionsSnapshot<Option> option, IConfiguration configuration, HttpTrigger httpTrigger)
  59. {
  60. _searcher = searcher;
  61. _azureCosmos = azureCosmos;
  62. _azureStorage = azureStorage;
  63. _azureRedis = azureRedis;
  64. _dingDing = dingDing;
  65. _option = option?.Value;
  66. _configuration = configuration;
  67. _coreAPIHttpService = coreAPIHttpService;
  68. _logger = logger;
  69. _httpTrigger = httpTrigger;
  70. _environment = environment;
  71. }
  72. /// <summary>
  73. /// 修改教师信息
  74. /// </summary>
  75. /// <param name="request"></param>
  76. /// <returns></returns>
  77. [ProducesDefaultResponseType]
  78. [HttpPost("GetUserInfo")]
  79. //[Authorize(Roles = "IES")]
  80. public async Task<IActionResult> GetUserInfo(JsonElement request)
  81. {
  82. if (!request.TryGetProperty("key", out JsonElement key)) return BadRequest();
  83. var location = _option.Location;
  84. //https://api2-rc.teammodel.cn
  85. CoreUser core = await _coreAPIHttpService.GetUserInfo(new Dictionary<string, string>()
  86. { { "key",$"{key}" }
  87. }, location, _configuration
  88. );
  89. if (core != null)
  90. {
  91. var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
  92. TmdidImplicit tmdidImplicit = await _coreAPIHttpService.Implicit(new Dictionary<string, string> { { "grant_type", "implicit" },
  93. { "client_id",clientID },
  94. { "account",core.id },
  95. { "nonce",Guid.NewGuid().ToString()} }, _option.Location, _configuration);
  96. if (tmdidImplicit != null && !string.IsNullOrEmpty(tmdidImplicit.id_token))
  97. {
  98. return Ok(new { coreUser = core, tmdidImplicit });
  99. }
  100. }
  101. return Ok(new { coreUser = core });
  102. }
  103. /// <summary>
  104. /// 修改教师信息
  105. /// </summary>
  106. /// <param name="request"></param>
  107. /// <returns></returns>
  108. [ProducesDefaultResponseType]
  109. [HttpPost("set-teacher-info")]
  110. [AuthToken(Roles = "admin,teacher,area")]
  111. [Authorize(Roles = "IES")]
  112. public async Task<IActionResult> SetTeacherInfo(JsonElement request)
  113. {
  114. var client = _azureCosmos.GetCosmosClient();
  115. var tableClient = _azureStorage.GetCloudTableClient();
  116. var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
  117. if (!request.TryGetProperty("opt", out JsonElement _opt))
  118. {
  119. return BadRequest();
  120. }
  121. var (userid, name, _, school) = HttpContext.GetAuthTokenInfo();
  122. try
  123. {
  124. switch (true)
  125. {
  126. //修改常用语系
  127. case bool when $"{_opt}".Equals("UpdateLang", StringComparison.OrdinalIgnoreCase) && (request.TryGetProperty("lang", out JsonElement lang)):
  128. {
  129. Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(userid, new PartitionKey("Base"));
  130. if (!string.IsNullOrEmpty($"{lang}"))
  131. {
  132. teacher.lang = $"{lang}";
  133. await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, userid, new PartitionKey("Base"));
  134. return Ok(new { teacher, status = 1 });
  135. }
  136. else
  137. {
  138. return BadRequest(new { status = -1, msg = "语系参数为空!" });
  139. }
  140. }
  141. //修改默认学校
  142. case bool when $"{_opt}".Equals("UpdateDefaultSchool", StringComparison.OrdinalIgnoreCase) && (request.TryGetProperty("defaultSchool", out JsonElement _defaultSchool)):
  143. {
  144. Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(userid, new PartitionKey("Base"));
  145. if (teacher.schools.Select(x => x.schoolId).Contains($"{_defaultSchool}") && !string.IsNullOrEmpty($"{_defaultSchool}"))
  146. {
  147. teacher.defaultSchool = $"{_defaultSchool}";
  148. await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, userid, new PartitionKey("Base"));
  149. return Ok(new { teacher, status = 1 });
  150. }
  151. else
  152. {
  153. return BadRequest(new { status = -1, msg = "您未加入该学校!" });
  154. }
  155. }
  156. //修改教师的最大课例保存数量
  157. case bool when $"{_opt}".Equals("UpdateLessonLimit", StringComparison.OrdinalIgnoreCase) && (request.TryGetProperty("lessonLimit", out JsonElement _lessonLimit)):
  158. {
  159. Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(userid, new PartitionKey("Base"));
  160. teacher.lessonLimit = int.Parse($"{_lessonLimit}");
  161. await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, userid, new PartitionKey("Base"));
  162. return Ok(new { teacher, status = 1 });
  163. }
  164. //修改教师设置自动将课例发布给谁的设置
  165. case bool when $"{_opt}".Equals("UpdateLessonShow", StringComparison.OrdinalIgnoreCase) && (request.TryGetProperty("lessonShow", out JsonElement _lessonShow)):
  166. {
  167. Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(userid, new PartitionKey("Base"));
  168. teacher.lessonShow = _lessonShow.Deserialize<List<string>>();
  169. await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, userid, new PartitionKey("Base"));
  170. return Ok(new { teacher, status = 1 });
  171. }
  172. //设置教师的科目信息
  173. case bool when $"{_opt}".Equals("SetTeacherSubject", StringComparison.OrdinalIgnoreCase) && request.TryGetProperty("targerTecher", out JsonElement _targetTecher)
  174. && request.TryGetProperty("subjectIds", out JsonElement _subjectIds):
  175. if (_subjectIds.ValueKind.Equals(JsonValueKind.Array))
  176. {
  177. if (_targetTecher.ValueKind.Equals(JsonValueKind.Array))
  178. {
  179. List<string> targetTechers = _targetTecher.ToObject<List<string>>();
  180. List<SchoolTeacher> schoolTeachers = new List<SchoolTeacher>();
  181. foreach (string targetTecher in targetTechers)
  182. {
  183. try
  184. {
  185. SchoolTeacher schoolTeacher = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<SchoolTeacher>($"{targetTecher}", new PartitionKey($"Teacher-{school}"));
  186. schoolTeacher.subjectIds = _subjectIds.ToObject<List<string>>();
  187. await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<SchoolTeacher>(schoolTeacher, $"{targetTecher}", new PartitionKey($"Teacher-{school}"));
  188. schoolTeachers.Add(schoolTeacher);
  189. }
  190. catch (Exception ex)
  191. {
  192. await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/init/set-teacher-info:SetTeacherSubject()\n{ex.Message}\n{ex.StackTrace}{request.ToJsonString()}-{targetTecher}", GroupNames.醍摩豆服務運維群組);
  193. }
  194. }
  195. return Ok(new { status = 1, schoolTeachers });
  196. }
  197. else
  198. {
  199. try
  200. {
  201. SchoolTeacher schoolTeacher = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<SchoolTeacher>($"{_targetTecher}", new PartitionKey($"Teacher-{school}"));
  202. schoolTeacher.subjectIds = _subjectIds.ToObject<List<string>>();
  203. await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<SchoolTeacher>(schoolTeacher, $"{_targetTecher}", new PartitionKey($"Teacher-{school}"));
  204. return Ok(new { status = 1, schoolTeacher });
  205. }
  206. catch (Exception ex)
  207. {
  208. await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/init/set-teacher-info:SetTeacherSubject()\n{ex.Message}\n{ex.StackTrace}{request.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
  209. return Ok(new { error = -1, msg = "设置失败" });
  210. }
  211. }
  212. }
  213. else
  214. {
  215. return Ok(new { error = -1, msg = "设置失败" });
  216. }
  217. ///移交管理员
  218. case bool when $"{_opt}".Equals("TransferAdminRole", StringComparison.OrdinalIgnoreCase) && (request.TryGetProperty("targerTecher", out JsonElement _targetTecher)):
  219. if (!string.IsNullOrEmpty(school) && !string.IsNullOrEmpty($"{_targetTecher}"))
  220. {
  221. StringBuilder strMsg = new($"{name}【{userid}】将");
  222. SchoolTeacher schoolTeacher = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<SchoolTeacher>(userid, new PartitionKey($"Teacher-{school}"));
  223. if (schoolTeacher.roles.IsNotEmpty() && schoolTeacher.roles.Contains("admin"))
  224. {
  225. schoolTeacher.roles.Remove("admin");
  226. SchoolTeacher newSchoolTeacher = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<SchoolTeacher>($"{_targetTecher}", new PartitionKey($"Teacher-{school}"));
  227. if (!newSchoolTeacher.roles.Contains("admin"))
  228. {
  229. newSchoolTeacher.roles.Add("admin");
  230. newSchoolTeacher = await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<SchoolTeacher>(newSchoolTeacher, $"{_targetTecher}", new PartitionKey($"Teacher-{school}"));
  231. }
  232. await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<SchoolTeacher>(schoolTeacher, userid, new PartitionKey($"Teacher-{school}"));
  233. string code = "transfer-admin";
  234. School schoolBase = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>(school, new PartitionKey($"Base"));
  235. strMsg.Append($"学校{schoolBase.name}[{schoolBase.id}] 的管理员权限移交给");
  236. Teacher targetTeacher = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemAsync<Teacher>($"{_targetTecher}", new PartitionKey($"Base"));
  237. strMsg.Append($"{targetTeacher.name}[{targetTeacher.id}]");
  238. _coreAPIHttpService.PushNotify(new List<IdNameCode> { new IdNameCode { id= targetTeacher.id,name= targetTeacher.name,code=targetTeacher.lang} }, "transfer-admin_school", Constant.NotifyType_IES5_Management,
  239. new Dictionary<string, object> { { "tmdname", name },{ "schoolName", schoolBase.name }, { "schoolId", $"{school}" } , { "tmdid", userid } }, _option.Location, _configuration, _dingDing, _environment.ContentRootPath);
  240. // _ = _azureStorage.SaveLog("transfer-admin-role", new { request, userid, name, school, schoolName = schoolBase.name, targetTecher = _targetTecher, }.ToJsonString(), bizId: $"{userid}-{schoolBase.id}-{_targetTecher}", httpContext: HttpContext, dingDing: _dingDing, scope: "school");
  241. //保存日志
  242. Dictionary<string, object> replaceData = new() { { "oName" ,$"{name}" }, { "oId", $"{userid}" }, { "scName", $"{schoolBase.name}" }, { "scId", $"{schoolBase.id}" } , { "tName", $"{targetTeacher.name}" }, { "tId", $"{targetTeacher.id}" } };
  243. _ = _azureStorage.SaveLogLang("transfer-admin-role", _environment.ContentRootPath, replaceData, _dingDing, bizId: $"{userid}-{schoolBase.id}-{_targetTecher}", httpContext: HttpContext, scope: "school");
  244. //保存管理员移交至BI
  245. await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "school-transfer-admin", strMsg?.ToString(), _dingDing, twebsite: "IES5", httpContext: HttpContext);
  246. return Ok(new { status = 1 });
  247. }
  248. else
  249. {
  250. return BadRequest(new { status = -1, msg = "当前登录账号没有admin权限" });
  251. }
  252. }
  253. else
  254. {
  255. return BadRequest(new { status = -1, msg = "参数异常!" });
  256. }
  257. //修改教师其他信息。
  258. case bool when $"{_opt}".Equals("UpdateMoreInfo", StringComparison.OrdinalIgnoreCase) && (request.TryGetProperty("teacherInfo", out JsonElement _teacherInfo)):
  259. var techinfo = _teacherInfo.Deserialize<UpdateTeacherInfo>();
  260. TeacherImport teacherImport = null;
  261. long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  262. if (techinfo != null && ! string.IsNullOrWhiteSpace(techinfo.id)) {
  263. try
  264. {
  265. SchoolTeacher schoolTeacher = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<SchoolTeacher>(techinfo.id, new PartitionKey($"Teacher-{school}"));
  266. schoolTeacher.subjectIds =techinfo.subjectIds!=null ? techinfo.subjectIds : schoolTeacher.subjectIds;
  267. schoolTeacher.job = techinfo.job!=null ? techinfo.job : schoolTeacher.job;
  268. schoolTeacher.periodId = techinfo.periodId!=null ? techinfo.periodId : schoolTeacher.periodId;
  269. await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<SchoolTeacher>(schoolTeacher, techinfo.id, new PartitionKey($"Teacher-{school}"));
  270. Azure.Response response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemStreamAsync($"{school}", new PartitionKey("TeacherImport"));
  271. if (response.Status == 200)
  272. {
  273. teacherImport = JsonDocument.Parse(response.Content).RootElement.Deserialize<TeacherImport>();
  274. var teacherImportInfo= teacherImport.teachers.Find(x =>!string.IsNullOrWhiteSpace(x.id) && x.id.Equals(techinfo.id));
  275. if (teacherImportInfo == null)
  276. {
  277. teacherImport.teachers.Add(new ImportTeacher
  278. {
  279. time = now,
  280. status = schoolTeacher.status,
  281. name = schoolTeacher.name,
  282. iname = techinfo.iname,
  283. picture = schoolTeacher.picture,
  284. tmdid = schoolTeacher.id,
  285. note = techinfo.note,
  286. id = techinfo.id
  287. });
  288. }
  289. else
  290. {
  291. teacherImportInfo.tmdid = schoolTeacher.id;
  292. teacherImportInfo.picture = schoolTeacher.picture;
  293. teacherImportInfo.status = schoolTeacher.status;
  294. teacherImportInfo.name = schoolTeacher.name;
  295. teacherImportInfo.iname= techinfo.iname !=null ? techinfo.iname:teacherImportInfo.iname;
  296. teacherImportInfo.note = techinfo.note != null ? techinfo.note : teacherImportInfo.note;
  297. }
  298. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReplaceItemAsync(teacherImport, $"{school}", new PartitionKey("TeacherImport"));
  299. }
  300. else {
  301. teacherImport = new TeacherImport { id = $"{school}", code = "TeacherImport", pk = "TeacherImport", teachers = new List<ImportTeacher> { new ImportTeacher {
  302. time = now,
  303. status = schoolTeacher.status,
  304. name = schoolTeacher.name,
  305. iname = techinfo.iname,
  306. picture = schoolTeacher.picture,
  307. tmdid = schoolTeacher.id,
  308. note = techinfo.note,
  309. id = techinfo.id
  310. } } };
  311. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).CreateItemAsync(teacherImport, new PartitionKey("TeacherImport"));
  312. }
  313. return Ok(new { status = 1 });
  314. }
  315. catch (Exception ex)
  316. {
  317. await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/init/set-teacher-info:SetTeacherSubject()\n{ex.Message}\n{ex.StackTrace}{request.ToJsonString()}\n{school}", GroupNames.醍摩豆服務運維群組);
  318. }
  319. }
  320. return BadRequest(new { status = -1, msg = "参数异常!" });
  321. case bool when $"{_opt}".Equals("QuitSchool", StringComparison.OrdinalIgnoreCase) && request.TryGetProperty("schoolCode", out JsonElement _schoolCode) :
  322. School qschool= await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemAsync<School>($"{_schoolCode}", new PartitionKey("Base"));
  323. string sql = $"select value c from c where c.code='Teacher-{_schoolCode}' and c.status='join' and (c.id ='{userid}' or array_contains(c.roles,'admin'))";
  324. List<SchoolTeacher> adminTeachers = new List<SchoolTeacher>();
  325. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).GetItemQueryIterator<SchoolTeacher>(queryText: sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Teacher-{_schoolCode}") }))
  326. {
  327. adminTeachers.Add(item);
  328. }
  329. var steacher= adminTeachers.Find(z => z.id.Equals(userid));
  330. if (steacher != null)
  331. {
  332. if (!steacher.roles.Contains("admin"))
  333. {
  334. var tmdadmin = adminTeachers.FindAll(z => z.roles.Contains("admin") && !z.id.Equals(userid));
  335. if (tmdadmin.IsNotEmpty()) {
  336. List<IdNameCode> ids = new List<IdNameCode>();
  337. string sqlAdmin = $"select c.id,c.lang as code ,c.name from c where c.id in ({string.Join(",",tmdadmin.Select(z=>$"'{z.id}'"))}) ";
  338. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
  339. .GetItemQueryIterator<IdNameCode>(queryText: sqlAdmin, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Base") }))
  340. {
  341. ids.Add(item);
  342. }
  343. _coreAPIHttpService.PushNotify(ids, $"quit_school", Constant.NotifyType_IES5_Management,
  344. new Dictionary<string, object> { { "tmdname", name }, { "schoolName", qschool.name }, { "schoolId", $"{_schoolCode}" }, { "tmdid", userid } }, _option.Location, _configuration, _dingDing, _environment.ContentRootPath);
  345. return Ok(new { status =0, msg = "申请成功!" });
  346. }
  347. else {
  348. return Ok(new { status = 3, msg = "暂无管理员处理!" });
  349. }
  350. }
  351. else
  352. {
  353. return Ok(new { status = 2, msg = "请先移交管理员后再申请退出学校!" });
  354. }
  355. }
  356. else {
  357. Teacher qteacher = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemAsync<Teacher>($"{userid}", new PartitionKey("Base"));
  358. var a = qteacher.schools.RemoveAll(z => z.schoolId.Equals($"{_schoolCode}"));
  359. if (a > 0)
  360. {
  361. qteacher.defaultSchool = null;
  362. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReplaceItemAsync<Teacher>(qteacher,qteacher.id, new PartitionKey("Base"));
  363. return Ok(new { status = 4, msg = "退出成功!" });
  364. }
  365. else {
  366. return Ok(new { status = 1, msg = "未加入学校!" });
  367. }
  368. }
  369. }
  370. }
  371. catch (Exception ex)
  372. {
  373. await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/init/set-teacher-info()\n{ex.Message}\n{ex.StackTrace}{request.ToJsonString()}\n{school}", GroupNames.醍摩豆服務運維群組);
  374. return BadRequest("teacher not exist");
  375. }
  376. return BadRequest();
  377. }
  378. public class UpdateTeacherInfo {
  379. public string id { get; set; }
  380. public string iname { get; set; }
  381. public string periodId { get; set; }
  382. public List<string> subjectIds { get; set; } = new List<string>();
  383. public string job { get; set; }
  384. public string note { get; set; }
  385. }
  386. //TODO 此API需處理對應前端返回的相關數據
  387. [ProducesDefaultResponseType]
  388. [Authorize(Roles = "IES")]
  389. [HttpPost("get-teacher-info")]
  390. public async Task<IActionResult> GetTeacherInfo(JsonElement request)
  391. {
  392. string head_lang = "";
  393. if (HttpContext.Request.Headers.TryGetValue("lang", out var _lang)) {
  394. head_lang = $"{_lang}";
  395. }
  396. string OAuthShow_domain = HttpContext?.Request?.Host.Host;
  397. if (OAuthShow_domain.Equals("teammodelos.chinacloudsites.cn"))
  398. {
  399. OAuthShow_domain = _option.HostName;
  400. }
  401. if (_option.Location.Equals("China"))
  402. {
  403. OAuthShow_domain = _option.HostName;
  404. }
  405. if (OAuthShow_domain.Equals("localhost"))
  406. {
  407. OAuthShow_domain = "test.teammodel.cn";
  408. }
  409. if (!request.TryGetProperty("id_token", out JsonElement id_token)) return BadRequest();
  410. var jwt = new JwtSecurityToken(id_token.GetString());
  411. //TODO 此驗證IdToken先簡單檢查,後面需向Core ID新API,驗證Token
  412. var id = jwt.Payload.Sub;
  413. jwt.Payload.TryGetValue("name", out object name);
  414. jwt.Payload.TryGetValue("picture", out object picture);
  415. jwt.Payload.TryGetValue("lang", out object _jwtlang);
  416. head_lang = !string.IsNullOrWhiteSpace($"{_jwtlang}") ? $"{_jwtlang}" : head_lang;
  417. (string ip, string region) = await LoginService.LoginIp(HttpContext, _searcher);
  418. try
  419. {
  420. Teacher teacher = null;
  421. TeacherInfo teacherInfo = await TeacherService.TeacherInfo(_azureCosmos, teacher, $"{name}", $"{picture}", id, _azureStorage, _option, _azureRedis, ip, _httpTrigger, $"{_lang}");
  422. teacherInfo.areas.ForEach(x => { if (x.setting != null) { x.setting.accessConfig = x.setting.accessConfig; } });
  423. LoginService.LoginLog(HttpContext, _option, _logger, _dingDing, ip, region, id, $"{name}", 200);
  424. int lessonLimit = teacherInfo.teacher.lessonLimit;
  425. if (teacherInfo.teacher.lessonLimit == 0)
  426. {
  427. //未设置的的采用系统设置的默认值30
  428. lessonLimit = Constant.private_lesson_limit;
  429. }
  430. var table = _azureStorage.GetCloudTableClient().GetTableReference("IESOAuth");
  431. List<string> Codes = new List<string>();
  432. if (!string.IsNullOrWhiteSpace(id))
  433. {
  434. Codes.Add($" Code {QueryComparisons.Equal} '{id}' ");
  435. }
  436. string qurey = $"PartitionKey {QueryComparisons.Equal} 'OAuthShow' and Domain {QueryComparisons.Equal} '{OAuthShow_domain}' and ( { string.Join(" or ", Codes)} ) ";
  437. var result = await table.ExecuteQuerySegmentedAsync(new TableQuery<OAuthShow>().Where(qurey), null);
  438. List<OAuthShow> shows = result.Results;
  439. string lang = !string.IsNullOrWhiteSpace(teacherInfo.teacher.lang) ? teacherInfo.teacher.lang : head_lang;
  440. if (string.IsNullOrWhiteSpace(lang))
  441. {
  442. if (_option.Location.Contains("China"))
  443. {
  444. lang = "zh-cn";
  445. }
  446. else
  447. {
  448. lang = "en-us";
  449. }
  450. }
  451. else {
  452. if (lang.Equals("null")) {
  453. if (_option.Location.Contains("China"))
  454. {
  455. lang = "zh-cn";
  456. }
  457. else
  458. {
  459. lang = "en-us";
  460. }
  461. }
  462. }
  463. return Ok(new
  464. {
  465. lang=lang,
  466. privateShows = shows?.FindAll(x => x.Scope.Equals("private")).Select(x => new { x.Type, x.Status, x.Scope, x.Code }),
  467. location = _option.Location,
  468. teacherInfo.auth_token,
  469. teacherInfo.blob_uri,
  470. teacherInfo.blob_sas,
  471. teacherInfo.schools,
  472. teacherInfo.defaultschool,
  473. teacherInfo.defaultschoolPeriod,
  474. teacherInfo.courses,
  475. teacherInfo.total,
  476. teacherInfo.osblob_uri,
  477. teacherInfo.osblob_sas,
  478. teacherInfo.tsize,
  479. status = 200,
  480. teacherInfo.areas,
  481. lessonLimit,
  482. teacherInfo.teacher.lessonShow
  483. });
  484. }
  485. catch (CosmosException ex)
  486. {
  487. LoginService.LoginLog(HttpContext, _option, _logger, _dingDing, ip, region, id, $"{name}", 500);
  488. await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/GetTeacherInfo()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  489. return BadRequest();
  490. }
  491. catch (Exception ex)
  492. {
  493. LoginService.LoginLog(HttpContext, _option, _logger, _dingDing, ip, region, id, $"{name}", 500);
  494. _ = _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/GetTeacherInfo()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  495. return BadRequest();
  496. }
  497. }
  498. //TODO 此API需處理對應前端返回的相關數據
  499. [ProducesDefaultResponseType]
  500. [Authorize(Roles = "IES")]
  501. [HttpPost("get-school-info")]
  502. public async Task<IActionResult> GetSchoolInfo(JsonElement request)
  503. {
  504. string OAuthShow_domain = HttpContext?.Request?.Host.Host;
  505. if (OAuthShow_domain.Equals("teammodelos.chinacloudsites.cn") ) {
  506. OAuthShow_domain = _option.HostName;
  507. }
  508. if (_option.Location.Equals("China"))
  509. {
  510. OAuthShow_domain = _option.HostName;
  511. }
  512. if (OAuthShow_domain.Equals("localhost")) {
  513. OAuthShow_domain = "test.teammodel.cn";
  514. }
  515. try
  516. {
  517. if (!request.TryGetProperty("id_token", out JsonElement id_token)) return BadRequest();
  518. if (!request.TryGetProperty("school_code", out JsonElement _school_code)) return BadRequest();
  519. string school_code = $"{_school_code}";
  520. var jwt = new JwtSecurityToken(id_token.GetString());
  521. var id = jwt.Payload.Sub;
  522. var client = _azureCosmos.GetCosmosClient();
  523. //權限token
  524. jwt.Payload.TryGetValue("name", out object name);
  525. jwt.Payload.TryGetValue("picture", out object picture);
  526. List<string> roles = new List<string>();
  527. List<string> permissions = new List<string>();
  528. int size = 0;
  529. Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(id, new PartitionKey("Base"));
  530. List<AreaDto> areas = new List<AreaDto>();
  531. HashSet<string> areaIds = new HashSet<string>();
  532. if (teacher.areas.IsNotEmpty())
  533. {
  534. teacher.areas.ForEach(x => {
  535. areaIds.Add(x.areaId);
  536. });
  537. }
  538. if (teacher.schools.IsNotEmpty())
  539. {
  540. teacher.schools.ForEach(x => {
  541. if (!string.IsNullOrEmpty(x.areaId))
  542. {
  543. areaIds.Add(x.areaId);
  544. }
  545. });
  546. }
  547. List<Area> areasDbs = new List<Area>();
  548. List<AreaSetting> areaSettings = new List<AreaSetting>();
  549. if (areaIds.Count > 0)
  550. {
  551. string queryText = $"select value(c) from c where c.id in ({string.Join(",", areaIds.Select(x => $"'{x}'"))})";
  552. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Area>(queryText: queryText, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base-Area") }))
  553. {
  554. areasDbs.Add(item);
  555. }
  556. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AreaSetting>(queryText: queryText, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("AreaSetting") }))
  557. {
  558. areaSettings.Add(item);
  559. }
  560. }
  561. if (teacher.areas.IsNotEmpty())
  562. {
  563. foreach (var areat in teacher.areas)
  564. {
  565. Area area = areasDbs.Find(x => x.id.Equals(areat.areaId));
  566. AreaSetting setting = null;
  567. if (area != null)
  568. {
  569. setting = areaSettings.Find(x => x.id.Equals(areat.areaId));
  570. }
  571. int access = 0;
  572. if (setting != null && !string.IsNullOrWhiteSpace(setting.accessConfig))
  573. {
  574. access = 1;
  575. }
  576. //if (setting != null)
  577. //{
  578. // setting.accessConfig = null;
  579. //}
  580. areas.Add(new AreaDto { areaId = area.id, name = area.name, standard = area.standard, standardName = area.standardName, setting = setting, access = access });
  581. }
  582. }
  583. if (school_code.Equals(teacher.defaultSchool) && teacher.schools.IsNotEmpty() && !teacher.schools.Select(x => x.schoolId).Contains(school_code))
  584. {
  585. school_code = teacher.schools[0].schoolId;
  586. teacher.defaultSchool = school_code;
  587. teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, id, new PartitionKey("Base"));
  588. }
  589. var response = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(id, new PartitionKey($"Teacher-{school_code}"));
  590. string defaultPeriodId = "";
  591. if (response.Status == 200)
  592. {
  593. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  594. if (json.RootElement.TryGetProperty("size", out JsonElement _size) && _size.ValueKind == JsonValueKind.Number)
  595. {
  596. size = _size.GetInt32();
  597. }
  598. if (json.RootElement.TryGetProperty("periodId", out JsonElement _periodId))
  599. {
  600. defaultPeriodId =$"{_periodId}";
  601. }
  602. if (json.RootElement.TryGetProperty("roles", out JsonElement _roles) && _roles.ValueKind != JsonValueKind.Null)
  603. {
  604. foreach (var obj in _roles.EnumerateArray())
  605. {
  606. roles.Add(obj.GetString());
  607. }
  608. }
  609. if (json.RootElement.TryGetProperty("permissions", out JsonElement _permissions) && _permissions.ValueKind != JsonValueKind.Null)
  610. {
  611. foreach (var obj in _permissions.EnumerateArray())
  612. {
  613. permissions.Add(obj.GetString());
  614. }
  615. }
  616. }
  617. else //無此學校資料
  618. {
  619. }
  620. if (roles.Count == 0)
  621. {
  622. //助理,管家
  623. //roles.Add("assist");
  624. roles.Add("teacher");
  625. }
  626. //TODO JJ,调整为取得学校基础设置数据,取代下方學校學制、年級
  627. School school_base = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>($"{school_code}", new PartitionKey("Base"));
  628. foreach (var period in school_base.period)
  629. {
  630. try
  631. {
  632. await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<ItemCond>($"{period.id}", new PartitionKey($"ItemCond-{school_code}"));
  633. }
  634. catch (CosmosException)
  635. {
  636. ItemCond itemCond = new ItemCond
  637. {
  638. id = period.id,
  639. pk = "ItemCond",
  640. code = $"ItemCond-{school_code}",
  641. ttl = -1,
  642. };
  643. try
  644. {
  645. await client.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<ItemCond>(itemCond, new PartitionKey($"ItemCond-{school_code}"));
  646. }
  647. catch (CosmosException ex) when (ex.Status == 409)
  648. {
  649. continue;
  650. }
  651. }
  652. }
  653. string currAreaId = "";
  654. dynamic currArea = new ExpandoObject();
  655. if (!string.IsNullOrEmpty(school_base.areaId))
  656. {
  657. try
  658. {
  659. Area area = areasDbs.Find(x => x.id.Equals(school_base.areaId));
  660. AreaSetting setting = null;
  661. if (area != null)
  662. {
  663. //setting =await client.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<AreaSetting>(school_base.areaId, new PartitionKey("AreaSetting"));
  664. setting = areaSettings.Find(x => x.id.Equals(school_base.areaId));
  665. }
  666. int access = 0;
  667. AccessConfig accessConfig = null;
  668. if (setting != null && !string.IsNullOrWhiteSpace(setting.accessConfig))
  669. {
  670. access = 1;
  671. accessConfig = setting.accessConfig.ToObject<AccessConfig>();
  672. }
  673. //if (setting!=null&& !string.IsNullOrEmpty(setting.accessConfig)) {
  674. // setting.accessConfig = null;
  675. //}
  676. currArea = new
  677. {
  678. areaId = area?.id,
  679. name = area?.name,
  680. standard = area?.standard,
  681. standardName = area?.standardName,
  682. setting = setting,
  683. access = access,
  684. //submitType=accessConfig?.submitType,
  685. homeworkType = accessConfig != null && accessConfig.homeworkType.IsNotEmpty() ? accessConfig.homeworkType : new List<string> { "pdf" },
  686. };
  687. currAreaId = area?.id;
  688. }
  689. catch (CosmosException)
  690. {
  691. //数据库捞不到数据
  692. }
  693. }
  694. if (areas.Count > 0)
  695. {
  696. roles.Add("area");
  697. }
  698. //TODO JJ,更新Token时,在取得学校资讯时,没有传入schoolId
  699. var auth_token = JwtAuthExtension.CreateAuthToken(_option.HostName, id, name?.ToString(), picture?.ToString(), _option.JwtSecretKey, Website: "IES", scope: Constant.ScopeTeacher, schoolID: school_code.ToString(), areaId: currAreaId, standard: school_base.standard, roles: roles.ToArray(), permissions: permissions.ToArray(), expire: 1);
  700. //取得班级
  701. (List < Class > school_classes,_) = await SchoolService.DoGraduateClasses(_httpTrigger, _azureCosmos, null, school_base, _option,_dingDing);
  702. //取得教室
  703. List<Room> school_rooms = new List<Room>();
  704. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Room>(queryText: $"select value(c) from c ",
  705. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Room-{school_code}") }))
  706. {
  707. school_rooms.Add(item);
  708. }
  709. //該老師排定的學校課程
  710. List<object> school_courses = new List<object>();
  711. var query = $"SELECT distinct value(c) FROM c JOIN A1 IN c.schedule where A1.teacherId='{id}'";
  712. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Course-{school_code}") }))
  713. {
  714. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  715. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  716. {
  717. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  718. {
  719. school_courses.Add(obj.ToObject<object>());
  720. }
  721. }
  722. }
  723. List<SchoolProductSumData> services = new List<SchoolProductSumData>();
  724. //获取HiTeachCC的授权
  725. int cc_avaliable = 0;
  726. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<int>("select value count(1) from c where c.prodCode='LZLL6ZEI'",
  727. requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Product-{school_code}") }))
  728. {
  729. cc_avaliable = item;
  730. }
  731. services.Add(new SchoolProductSumData { prodCode = "LZLL6ZEI", avaliable = cc_avaliable });
  732. Azure.Response productSumResponse = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(school_code, new PartitionKey("ProductSum"));
  733. if (productSumResponse.Status == 200)
  734. {
  735. var doc = JsonDocument.Parse(productSumResponse.Content);
  736. //if (doc.RootElement.TryGetProperty("serial", out JsonElement serial))
  737. //{
  738. // serials = serial.ToObject<List<SchoolProductSumData>>();
  739. //}
  740. if (doc.RootElement.TryGetProperty("service", out JsonElement service))
  741. {
  742. services .AddRange(service.ToObject<List<SchoolProductSumData>>());
  743. }
  744. }
  745. //校本課綱 [式樣未定 先不取]
  746. //取得School Blob 容器位置及SAS
  747. string school_code_blob = school_code.ToLower();
  748. var container = _azureStorage.GetBlobContainerClient(school_code_blob);
  749. await container.CreateIfNotExistsAsync(PublicAccessType.None); //嘗試創建School容器,如存在則不做任何事,保障容器一定存在
  750. var (blob_uri, blob_sas) = (roles.Contains("admin") || permissions.Contains("schoolAc-upd")) ? _azureStorage.GetBlobContainerSAS(school_code_blob, BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List | BlobContainerSasPermissions.Delete) : _azureStorage.GetBlobContainerSAS(school_code_blob, BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List | BlobContainerSasPermissions.Write);
  751. ///https://teammodelstorage.blob.core.chinacloudapi.cn/teammodelos
  752. var (osblob_uri, osblob_sas) = roles.Contains("area") ? _azureStorage.GetBlobContainerSAS("teammodelos", BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List | BlobContainerSasPermissions.Delete) : _azureStorage.GetBlobContainerSAS("teammodelos", BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);
  753. areas.ForEach(x => { { if (x.setting != null) { x.setting.accessConfig = x.setting.accessConfig; } } });
  754. int lessonLimit = teacher.lessonLimit;
  755. if (teacher.lessonLimit == 0)
  756. {
  757. //未设置的的采用系统设置的默认值30
  758. lessonLimit = Constant.private_lesson_limit;
  759. }
  760. var table = _azureStorage.GetCloudTableClient().GetTableReference("IESOAuth");
  761. List<string> Codes = new List<string>();
  762. if (!string.IsNullOrWhiteSpace(id))
  763. {
  764. Codes.Add($" Code {QueryComparisons.Equal} '{id}' ");
  765. }
  766. if (!string.IsNullOrWhiteSpace(school_code))
  767. {
  768. Codes.Add($" Code {QueryComparisons.Equal} '{school_code}' ");
  769. }
  770. if (!string.IsNullOrWhiteSpace(currAreaId))
  771. {
  772. Codes.Add($" Code {QueryComparisons.Equal} '{currAreaId}' ");
  773. }
  774. string tbqurey = $"PartitionKey {QueryComparisons.Equal} 'OAuthShow' and Domain {QueryComparisons.Equal} '{OAuthShow_domain}' and ( { string.Join(" or ", Codes)} ) ";
  775. var result = await table.ExecuteQuerySegmentedAsync(new TableQuery<OAuthShow>().Where(tbqurey), null);
  776. List<OAuthShow> shows = result.Results;
  777. List<OAuthShow> schoolShow = new List<OAuthShow>();
  778. List<OAuthShow> areaShow = new List<OAuthShow>();
  779. var schoolShows = shows?.Where(y => !y.Scope.Equals("private"));
  780. if (schoolShows.Any())
  781. {
  782. //剩下的area 和school 的。统一处理为school的,并去重。
  783. schoolShows.ToList().ForEach(y => { y.Scope = "school"; y.Code = school_code; });
  784. schoolShows.GroupBy(x => $"{x.Type}{x.Scope}").Select(s => new { key = s.Key, list = s.ToList() }).ToList().ForEach(z => {
  785. schoolShow.Add(z.list.First());
  786. });
  787. }
  788. //只有管理员才能进行艺术评价相关设置关联。
  789. List<IdCode> hasArt = new List<IdCode>();
  790. if (roles.Contains("admin"))
  791. {
  792. if (schoolShows.Where(x => x.Type.Equals("art")).Any())
  793. {
  794. school_base?.period.ForEach(x => {
  795. var has_music = x?.subjects.Find(x => !string.IsNullOrWhiteSpace(x.bindId) && x.bindId.Equals("subject_music"));
  796. if (has_music == null)
  797. {
  798. hasArt.Add(new IdCode { id = x.id, code = "subject_music" });
  799. }
  800. var has_painting = x.subjects.Find(x => !string.IsNullOrWhiteSpace(x.bindId) && x.bindId.Equals("subject_painting"));
  801. if (has_painting == null)
  802. {
  803. hasArt.Add(new IdCode { id = x.id, code = "subject_painting" });
  804. }
  805. });
  806. }
  807. }
  808. List<OAuthShow> areaShows = new List<OAuthShow>();
  809. //处理区级是否有艺术评价模组授权
  810. if (areas.IsNotEmpty())
  811. {
  812. List<string> area_Codes = new List<string>();
  813. areas.ForEach(x => {
  814. area_Codes.Add($" Code {QueryComparisons.Equal} '{x.areaId}' ");
  815. });
  816. string area_tbqurey = $"PartitionKey {QueryComparisons.Equal} 'OAuthShow' and Domain {QueryComparisons.Equal} '{OAuthShow_domain}' and Type {QueryComparisons.Equal} 'art' and ( {string.Join(" or ", area_Codes)} ) ";
  817. var area_result = await table.ExecuteQuerySegmentedAsync(new TableQuery<OAuthShow>().Where(area_tbqurey), null);
  818. areaShows = area_result.Results;
  819. }
  820. //学校版本处理
  821. _ = BISchoolService.UpSchoolEdition(client, _dingDing, services.Select(s => s.prodCode).ToList(), $"{school_code}");
  822. return Ok(new
  823. {
  824. privateShows = shows?.FindAll(x => x.Scope.Equals("private")).Select(x => new { x.Type, x.Status, x.Scope, x.Code }),
  825. schoolShows = schoolShow.Select(x => new { x.Type, x.Status, x.Scope, x.Code }),
  826. areaShows = areaShows.Select(x => new { x.Type, x.Status, x.Scope, x.Code }),
  827. auth_token,
  828. blob_uri,
  829. blob_sas,
  830. school_base,
  831. school_courses,
  832. school_classes,
  833. school_rooms,
  834. size,
  835. osblob_uri,
  836. osblob_sas,
  837. status = 200,
  838. areas,
  839. currArea,
  840. lessonLimit,
  841. teacher.lessonShow,
  842. defaultPeriodId,
  843. productSum = new
  844. {
  845. //serial = serials,
  846. service = services
  847. }
  848. });
  849. }
  850. catch (CosmosException ex)
  851. {
  852. HttpContext.Request.Headers.TryGetValue("referer", out var referer);
  853. HttpContext.Request.Headers.TryGetValue("sec-ch-ua", out var chua);
  854. HttpContext.Request.Headers.TryGetValue("sec-ch-ua-platform", out var platform);
  855. HttpContext.Request.Headers.TryGetValue("user-agent", out var useragent);
  856. await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/init/get-school-info()\n{ex.Message}\n{ex.StackTrace}\n{request.ToJsonString()}\nreferer:{referer}\nsec-ch-ua:{chua}\nsec-ch-ua-platform:{platform}\nuser-agent:{useragent}", GroupNames.醍摩豆服務運維群組);
  857. return BadRequest(new { status = ex.Status });
  858. }
  859. catch (Exception ex)
  860. {
  861. HttpContext.Request.Headers.TryGetValue("referer", out var referer);
  862. HttpContext.Request.Headers.TryGetValue("sec-ch-ua", out var chua);
  863. HttpContext.Request.Headers.TryGetValue("sec-ch-ua-platform", out var platform);
  864. HttpContext.Request.Headers.TryGetValue("user-agent", out var useragent);
  865. await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/init/get-school-info()\n{ex.Message}\n{ex.StackTrace}\n{request.ToJsonString()}\nreferer:{referer}\nsec-ch-ua:{chua}\nsec-ch-ua-platform:{platform}\nuser-agent:{useragent}", GroupNames.醍摩豆服務運維群組);
  866. return BadRequest(new { status = 500 });
  867. }
  868. }
  869. /// <summary>
  870. /// 取得學校所有列表
  871. /// </summary>
  872. /// <param name="request"></param>
  873. /// <returns></returns>
  874. [ProducesDefaultResponseType]
  875. //[AuthToken(Roles = "teacher")]
  876. [HttpPost("get-school-list")]
  877. public async Task<IActionResult> GetSchoolList(JsonElement request)
  878. {
  879. try
  880. {
  881. //輸入值
  882. string sqlSchoolId = (request.TryGetProperty("schoolId", out JsonElement reqSchoolId)) ? reqSchoolId.GetString() : string.Empty;
  883. bool sqlHasManager = (request.TryGetProperty("manager", out JsonElement reqHasManager)) ? reqHasManager.GetBoolean() : false;
  884. bool sqlHasMBaseModule = (request.TryGetProperty("base", out JsonElement reqHasBaseModule)) ? reqHasBaseModule.GetBoolean() : false;
  885. var client = _azureCosmos.GetCosmosClient();
  886. //有管理者的學校
  887. Dictionary<string, List<Dictionary<string, string>>> managerSchDic = new Dictionary<string, List<Dictionary<string, string>>>();
  888. string managerWhereOption = (!string.IsNullOrWhiteSpace(sqlSchoolId)) ? $" AND c.code = 'Teacher-{sqlSchoolId}'" : string.Empty;
  889. string managerSql = $"SELECT DISTINCT REPLACE(c.code, 'Teacher-', '') AS schoolId, c.id, c.name FROM c WHERE ARRAY_CONTAINS(c.roles, 'admin', true) AND c.pk = 'Teacher' AND c.status = 'join'{managerWhereOption}";
  890. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: managerSql, requestOptions: new QueryRequestOptions() { }))
  891. {
  892. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  893. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  894. {
  895. string id = obj.GetProperty("id").GetString(); //管理者ID
  896. string name = obj.GetProperty("name").GetString(); //管理者姓名
  897. string schoolId = obj.GetProperty("schoolId").GetString(); //學校ID
  898. Dictionary<string, string> managerDic = new Dictionary<string, string>();
  899. managerDic.Add("id", id);
  900. managerDic.Add("name", name);
  901. if (managerSchDic.ContainsKey(schoolId))
  902. {
  903. managerSchDic[schoolId].Add(managerDic);
  904. }
  905. else
  906. {
  907. List<Dictionary<string, string>> managerList = new List<Dictionary<string, string>>();
  908. managerList.Add(managerDic);
  909. managerSchDic.Add(schoolId, managerList);
  910. }
  911. }
  912. }
  913. //有管理模組的學校
  914. List<string> baseModuleSchList = new List<string>();
  915. string baseModuleWhereOption = (!string.IsNullOrWhiteSpace(sqlSchoolId)) ? $" AND c.id = '{sqlSchoolId}'" : string.Empty;
  916. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: $"SELECT c.id FROM c JOIN serviceProduct IN c.service.product WHERE serviceProduct.prodCode = 'IPDYZYLC'{baseModuleWhereOption}", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Product") }))
  917. {
  918. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  919. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  920. {
  921. string schoolId = obj.GetProperty("id").GetString(); //學校ID
  922. baseModuleSchList.Add(schoolId);
  923. }
  924. }
  925. //學校資料
  926. List<object> schools = new List<object>();
  927. string schoolWhereOption = (!string.IsNullOrWhiteSpace(sqlSchoolId)) ? $" WHERE c.id = '{sqlSchoolId}'" : string.Empty;
  928. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: $"SELECT c.id, c.name, c.region, c.province, c.city, c.picture FROM c {schoolWhereOption}", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  929. {
  930. var jsons = await JsonDocument.ParseAsync(item.ContentStream);
  931. if (jsons.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  932. {
  933. foreach (var obj in jsons.RootElement.GetProperty("Documents").EnumerateArray())
  934. {
  935. dynamic schoolExtobj = new ExpandoObject();
  936. schoolExtobj.id = obj.GetProperty("id").GetString(); //學校ID
  937. schoolExtobj.name = obj.GetProperty("name");
  938. schoolExtobj.region = obj.GetProperty("region");
  939. schoolExtobj.province = obj.GetProperty("province");
  940. schoolExtobj.city = obj.GetProperty("city");
  941. schoolExtobj.picture = obj.GetProperty("picture");
  942. if (managerSchDic.ContainsKey(schoolExtobj.id))
  943. {
  944. schoolExtobj.hasManager = true;
  945. schoolExtobj.managers = managerSchDic[schoolExtobj.id];
  946. }
  947. else
  948. {
  949. schoolExtobj.hasManager = false;
  950. schoolExtobj.managers = new List<object>();
  951. }
  952. schoolExtobj.hasBaseModule = (baseModuleSchList.Contains(schoolExtobj.id)) ? true : false;
  953. //學校輸出結果加入篩選
  954. if ((sqlHasManager && sqlHasMBaseModule) && (schoolExtobj.hasManager && schoolExtobj.hasBaseModule))
  955. {
  956. schools.Add(schoolExtobj);
  957. }
  958. else if (sqlHasManager && schoolExtobj.hasManager)
  959. {
  960. schools.Add(schoolExtobj);
  961. }
  962. else if (sqlHasMBaseModule && schoolExtobj.hasBaseModule)
  963. {
  964. schools.Add(schoolExtobj);
  965. }
  966. else if (!sqlHasManager && !sqlHasMBaseModule)
  967. {
  968. schools.Add(schoolExtobj);
  969. }
  970. }
  971. }
  972. }
  973. return Ok(new { schools });
  974. }
  975. catch (Exception ex)
  976. {
  977. await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/init/get-school-info()\n{ex.Message}\n{ex.StackTrace}{request.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
  978. return BadRequest();
  979. }
  980. }
  981. /// <summary>
  982. /// 申請或同意邀請加入學校
  983. /// </summary>
  984. ///
  985. /// <param name="request"></param>
  986. /// <returns></returns>
  987. [ProducesDefaultResponseType]
  988. [AuthToken(Roles = "teacher")]
  989. [HttpPost("join-school")]
  990. [Authorize(Roles = "IES")]
  991. public async Task<IActionResult> JoinSchool(JsonElement request)
  992. {
  993. try
  994. {
  995. if (!request.TryGetProperty("grant_type", out JsonElement grant_type)) return BadRequest(); //"invite":學校邀請 "request":老師申請 "join":"成為學校老師",leave 离开,cancel 取消。
  996. if (!request.TryGetProperty("school_code", out JsonElement school_code)) return BadRequest();
  997. if (!request.TryGetProperty("school_name", out JsonElement school_name)) return BadRequest();
  998. ///当邀请某个老师加入学校则需要知道是谁邀请的
  999. //if (!request.TryGetProperty("school_admin", out JsonElement school_admin)) return BadRequest();
  1000. string authtoken = HttpContext.GetXAuth("AuthToken");
  1001. if (string.IsNullOrEmpty(authtoken)) return BadRequest();
  1002. var jwt = new JwtSecurityToken(authtoken);
  1003. var id = jwt.Payload.Sub;
  1004. var schoolcode = jwt.Payload.Azp;
  1005. var Claims = jwt.Payload.Claims;
  1006. jwt.Payload.TryGetValue("name", out object name);
  1007. jwt.Payload.TryGetValue("picture", out object picture);
  1008. var client = _azureCosmos.GetCosmosClient();
  1009. //在老師表找出老師,處理該學校狀態 (老師基本資料應該要存在)
  1010. Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(id, new PartitionKey("Base"));
  1011. if (teacher.schools == null)
  1012. teacher.schools = new List<Teacher.TeacherSchool>();
  1013. var school = teacher.schools?.FirstOrDefault(x => x.schoolId.Equals(school_code.GetString(), StringComparison.OrdinalIgnoreCase));
  1014. School schoolBase = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>($"{school_code}", new PartitionKey("Base"));
  1015. if (school != null)
  1016. school.status = grant_type.GetString();
  1017. else
  1018. {
  1019. long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  1020. teacher.schools.Add(new Teacher.TeacherSchool() { areaId = schoolBase.areaId, picture = schoolBase.picture, schoolId = school_code.GetString(), name = school_name.GetString(), status = grant_type.GetString(), time = now });
  1021. }
  1022. if (grant_type.GetString().Equals("leave") || grant_type.GetString().Equals("cancel"))
  1023. {
  1024. if (teacher.schools.IsNotEmpty())
  1025. {
  1026. //获取之前已经加入的学校或者申请的学校
  1027. var inSchools = teacher.schools.Where(x => x.schoolId == school_code.GetString()).ToList();
  1028. if (inSchools.IsNotEmpty())
  1029. {
  1030. inSchools.ForEach(x => teacher.schools.Remove(x));
  1031. }
  1032. }
  1033. if (teacher.schools.Count > 0 && teacher.size <= 1)
  1034. {
  1035. teacher.size = 2;
  1036. }
  1037. if (!string.IsNullOrEmpty(teacher.defaultSchool) && teacher.defaultSchool.Equals($"{school_code}"))
  1038. {
  1039. if (teacher.schools.IsNotEmpty())
  1040. {
  1041. teacher.defaultSchool = teacher.schools[0].schoolId;
  1042. }
  1043. else
  1044. {
  1045. teacher.defaultSchool = null;
  1046. }
  1047. }
  1048. await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, id, new PartitionKey("Base"));
  1049. var sresponse = await client.GetContainer(Constant.TEAMModelOS, "School").DeleteItemStreamAsync(id, new PartitionKey($"Teacher-{school_code}"));
  1050. Azure.Response response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemStreamAsync($"{school_code}", new PartitionKey("TeacherImport"));
  1051. TeacherImport teacherImport = null;
  1052. if (response.Status == 200)
  1053. {
  1054. teacherImport = JsonDocument.Parse(response.Content).RootElement.Deserialize<TeacherImport>();
  1055. var tchs = teacherImport?.teachers?.RemoveAll(x => !string.IsNullOrWhiteSpace(x.id) && x.id.Equals(id));
  1056. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReplaceItemAsync(teacherImport, $"{school_code}", new PartitionKey("TeacherImport"));
  1057. }
  1058. return Ok(new { stauts = 1 });
  1059. }
  1060. else
  1061. {
  1062. var dft = new List<string>() { "content-read", "exercise-read", "knowledge-read", "syllabus-read" };
  1063. if (teacher.schools.Count > 0 && teacher.size <= 1)
  1064. {
  1065. teacher.size = 2;
  1066. }
  1067. await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, id, new PartitionKey("Base"));
  1068. //在學校表處理該學校教師帳號的狀態
  1069. var sresponse = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(id, new PartitionKey($"Teacher-{school_code}"));
  1070. if (sresponse.Status == 200)
  1071. {
  1072. using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
  1073. SchoolTeacher steacher = json.ToObject<SchoolTeacher>();
  1074. steacher.status = grant_type.GetString();
  1075. if (grant_type.ToString().Equals("join"))
  1076. {
  1077. if (steacher.permissions.IsNotEmpty())
  1078. {
  1079. foreach (var d in dft)
  1080. {
  1081. if (!steacher.permissions.Contains(d))
  1082. {
  1083. steacher.permissions.Add(d);
  1084. }
  1085. }
  1086. }
  1087. else
  1088. {
  1089. steacher.permissions = dft;
  1090. }
  1091. }
  1092. var response = await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync(steacher, id, new PartitionKey($"Teacher-{school_code}"));
  1093. }
  1094. else
  1095. {
  1096. SchoolTeacher st = new SchoolTeacher()
  1097. {
  1098. pk = "Teacher",
  1099. code = $"Teacher-{school_code}",
  1100. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  1101. id = id,
  1102. name = name.ToString(),
  1103. picture = picture?.ToString(),
  1104. permissions = grant_type.ToString().Equals("join") ? dft : null,
  1105. roles = new List<string>() { "teacher" },
  1106. size = 0,
  1107. status = grant_type.GetString()
  1108. };
  1109. var response = await client.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync(st, new PartitionKey($"Teacher-{school_code}"));
  1110. }
  1111. Azure.Response responseImport = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemStreamAsync($"{school_code}", new PartitionKey("TeacherImport"));
  1112. TeacherImport teacherImport = null;
  1113. if ($"{grant_type}".Equals("request"))
  1114. {
  1115. if (responseImport.Status == 200)
  1116. {
  1117. teacherImport = JsonDocument.Parse(responseImport.Content).RootElement.Deserialize<TeacherImport>();
  1118. var tchs = teacherImport?.teachers?.FindAll(x => !string.IsNullOrWhiteSpace(x.iname) && x.iname.Equals($"{name}") && string.IsNullOrWhiteSpace(x.id));
  1119. if (tchs.IsNotEmpty())
  1120. {
  1121. var tch = tchs[0];
  1122. string ujson = null;
  1123. var content = new StringContent(new List<string> { $"{id}" }.ToJsonString(), Encoding.UTF8, "application/json");
  1124. ujson = await _coreAPIHttpService.GetUserInfos(content);
  1125. List<CoreUser> coreUsers = new List<CoreUser>();
  1126. if (!string.IsNullOrWhiteSpace(ujson))
  1127. {
  1128. coreUsers = ujson.ToObject<List<CoreUser>>();
  1129. }
  1130. if (coreUsers.IsNotEmpty())
  1131. {
  1132. tch.phone = coreUsers[0].mobile;
  1133. tch.email = coreUsers[0].mail;
  1134. }
  1135. tch.id = $"{id}";
  1136. tch.picture = $"{picture}";
  1137. tch.status = $"{grant_type}";
  1138. tch.time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  1139. tch.tmdid = id;
  1140. tch.name = $"{name }";
  1141. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReplaceItemAsync(teacherImport, $"{school_code}", new PartitionKey("TeacherImport"));
  1142. }
  1143. }
  1144. }
  1145. if (grant_type.ToString().Equals("join"))
  1146. {
  1147. if (responseImport.Status == 200)
  1148. {
  1149. teacherImport = JsonDocument.Parse(responseImport.Content).RootElement.Deserialize<TeacherImport>();
  1150. teacherImport?.teachers.ForEach(x => {
  1151. if (!string.IsNullOrWhiteSpace(x.id) && !string.IsNullOrWhiteSpace(teacher.id) && x.id.Equals(teacher.id))
  1152. {
  1153. x.name = teacher.name;
  1154. x.status = "join";
  1155. x.time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  1156. x.picture = teacher.picture;
  1157. }
  1158. });
  1159. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReplaceItemAsync(teacherImport, $"{school_code}", new PartitionKey("TeacherImport"));
  1160. await TmdUserService.JoinSchool(client, teacher.id, teacher.picture, teacher.name, school.schoolId, school.name);
  1161. }
  1162. }
  1163. List<SchoolTeacher> teachers = new List<SchoolTeacher>();
  1164. var queryslt = $"SELECT value(c) FROM c join A1 in c.roles where A1 in ('admin')";
  1165. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<SchoolTeacher>(queryText: queryslt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Teacher-{school_code}") }))
  1166. {
  1167. teachers.Add(item);
  1168. }
  1169. string code = grant_type.GetString();
  1170. if (grant_type.GetString().Equals("join"))
  1171. {
  1172. code = "invite-join";
  1173. }
  1174. if (teachers.IsNotEmpty()) {
  1175. string sql = $"select c.id, c.name ,c.lang as code from c where c.id in ({string.Join(",", teachers.Select(x => $"'{x.id}'"))})";
  1176. List<IdNameCode> idNameCodes = new List<IdNameCode>();
  1177. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
  1178. .GetItemQueryIterator<IdNameCode>(queryText: sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
  1179. {
  1180. idNameCodes.Add(item);
  1181. }
  1182. _coreAPIHttpService.PushNotify(idNameCodes, $"{code}_school", Constant.NotifyType_IES5_Management,
  1183. new Dictionary<string, object> {{ "tmdname", name }, { "schoolName", schoolBase.name }, { "schoolId",$"{school_code}" },{ "tmdid",id} }, _option.Location,_configuration,_dingDing, _environment.ContentRootPath) ;
  1184. }
  1185. return Ok(new { stauts = 1 });
  1186. }
  1187. }
  1188. catch (Exception ex)
  1189. {
  1190. await _dingDing.SendBotMsg($"TEAMModel,{_option.Location},Init/JoinSchool()\n{ex.Message}\n{ex.StackTrace}\n{request.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
  1191. return BadRequest();
  1192. }
  1193. }
  1194. /// <summary>
  1195. /// 通过学段获取学校班级、教室信息; 教师id获取课程信息
  1196. /// </summary>
  1197. /// <param name="jsonElement"></param>
  1198. /// <returns></returns>
  1199. [ProducesDefaultResponseType]
  1200. [HttpPost("get-info-prdid")]
  1201. [Authorize(Roles="IES")]
  1202. public async Task<IActionResult> GetInfoByPeriodId(JsonElement jsonElement)
  1203. {
  1204. string OAuthShow_domain = HttpContext?.Request?.Host.Host;
  1205. if (OAuthShow_domain.Equals("teammodelos.chinacloudsites.cn"))
  1206. {
  1207. OAuthShow_domain = _option.HostName;
  1208. }
  1209. if (_option.Location.Equals("China"))
  1210. {
  1211. OAuthShow_domain = _option.HostName;
  1212. }
  1213. if (OAuthShow_domain.Equals("localhost"))
  1214. {
  1215. OAuthShow_domain = "test.teammodel.cn";
  1216. }
  1217. try
  1218. {
  1219. if (!jsonElement.TryGetProperty("id_token", out JsonElement id_token)) return BadRequest();
  1220. if (!jsonElement.TryGetProperty("school_code", out JsonElement school_code)) return BadRequest();
  1221. jsonElement.TryGetProperty("periodId", out JsonElement _periodId);
  1222. var jwt = new JwtSecurityToken(id_token.GetString());
  1223. var tchId = jwt.Payload.Sub;
  1224. var client = _azureCosmos.GetCosmosClient();
  1225. string periodId = null;
  1226. if (!string.IsNullOrEmpty($"{_periodId}"))
  1227. periodId = $"{_periodId}";
  1228. else
  1229. {
  1230. School school_base = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>($"{school_code}", new PartitionKey("Base"));
  1231. periodId = school_base.period[0].id;
  1232. }
  1233. //获取班级信息
  1234. List<object> school_Classes = new();
  1235. string classesSql = $"SELECT c.id,c.x,c.y,c.name,c.year,c.teacher,c.periodId,c.gradeId,c.room,c.sn,c.no,c.style,c.status,c.openType,c.school, c.graduate, ARRAY_LENGTH(c.students) AS studCount FROM c where c.graduate = 0 or IS_DEFINED(c.graduate) = false and c.periodId='{periodId}'";
  1236. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: classesSql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Class-{school_code}") }))
  1237. {
  1238. var jsonc = await JsonDocument.ParseAsync(item.ContentStream);
  1239. foreach (var classeinfo in jsonc.RootElement.GetProperty("Documents").EnumerateArray())
  1240. {
  1241. school_Classes.Add(classeinfo.ToObject<object>());
  1242. }
  1243. }
  1244. //获取教师的课程
  1245. List<object> school_Courses = new();
  1246. var query = $"SELECT value(c) FROM c JOIN A1 IN c.schedule where A1.teacherId='{tchId}' and c.period.id='{periodId}'";
  1247. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Course-{school_code}") }))
  1248. {
  1249. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  1250. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  1251. {
  1252. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  1253. {
  1254. school_Courses.Add(obj.ToObject<object>());
  1255. }
  1256. }
  1257. }
  1258. //获取教室
  1259. List<Room> school_Rooms = new();
  1260. //string roomSql = $"select value(c) from c where c.periodId = '{periodId}'"; //注释原因:教室暂时不绑定学段信息
  1261. string roomSql = $"select value(c) from c";
  1262. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Room>(queryText: roomSql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Room-{school_code}") }))
  1263. {
  1264. school_Rooms.Add(item);
  1265. }
  1266. //获取学校行政班
  1267. List<GroupListDto> school_GroupList = new();
  1268. string glSql = $"select c.id,c.code,c.name,c.no,c.periodId,c.scope,c.school,c.creatorId,c.type,c.year,c.tcount,c.scount,c.leader ,c.froms ,c.joinLock from c";
  1269. string schoolglSql = $"{glSql} where c.periodId ='{periodId}'";
  1270. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<GroupListDto>(queryText: schoolglSql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{school_code}") }))
  1271. {
  1272. school_GroupList.Add(item);
  1273. }
  1274. //获取个人行政班
  1275. List<GroupListDto> personal_GroupList = new();
  1276. string pglSql = $"{glSql} where c.creatorId='{tchId}'";
  1277. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<GroupListDto>(queryText: pglSql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("GroupList") }))
  1278. {
  1279. personal_GroupList.Add(item);
  1280. }
  1281. return Ok(new { status = 200, school_Classes, school_Courses, school_Rooms, school_GroupList, personal_GroupList });
  1282. }
  1283. catch (Exception ex)
  1284. {
  1285. await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/init/get-info-prdid()\n{ex.Message}\n{ex.StackTrace}\n{jsonElement.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
  1286. return BadRequest(new { status = 500 });
  1287. }
  1288. }
  1289. //課綱的model先記在下面,待式樣確定後再轉換
  1290. private List<SyllabusNode> CreateSyllabusTree(List<Syllabus> syllabuses)
  1291. {
  1292. List<SyllabusNode> nodes = new List<SyllabusNode>();
  1293. foreach (var syllabus in syllabuses)
  1294. {
  1295. if (syllabus.pid.Equals(""))
  1296. nodes.Add(new SyllabusNode { id = syllabus.id, name = syllabus.name });
  1297. else
  1298. {
  1299. CreateNode(nodes, syllabus);
  1300. }
  1301. }
  1302. return nodes;
  1303. }
  1304. private void CreateNode(List<SyllabusNode> nodes, Syllabus parent)
  1305. {
  1306. foreach (var node in nodes)
  1307. {
  1308. if (node.id == parent.pid)
  1309. {
  1310. node.children.Add(new SyllabusNode { id = parent.id, name = parent.name });
  1311. }
  1312. else
  1313. {
  1314. CreateNode(node.children, parent);
  1315. }
  1316. }
  1317. }
  1318. public class SyllabusRole
  1319. {
  1320. public string id { get; set; }
  1321. public string name { get; set; }
  1322. public object period { get; set; }
  1323. public object semester { get; set; }
  1324. public object grade { get; set; }
  1325. public object subject { get; set; }
  1326. public int resourceCount { get; set; }
  1327. public int itemCount { get; set; }
  1328. public object structure { get; set; }
  1329. }
  1330. public class Syllabus
  1331. {
  1332. public string id { get; set; }
  1333. public string name { get; set; }
  1334. public string pid { get; set; }
  1335. public int order { get; set; }
  1336. }
  1337. public class SyllabusNode
  1338. {
  1339. public string id { get; set; }
  1340. public string name { get; set; }
  1341. public List<SyllabusNode> children { get; set; }
  1342. public SyllabusNode()
  1343. {
  1344. children = new List<SyllabusNode>();
  1345. }
  1346. }
  1347. }
  1348. }