InitController.cs 86 KB

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