InitController.cs 91 KB

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