TeacherService.cs 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341
  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.SDK.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. namespace TEAMModelOS.Services
  28. {
  29. public static class TeacherService
  30. {
  31. public static async Task<TeacherInfo> TeacherInfo(AzureCosmosFactory _azureCosmos, Teacher teacher, string name, string picture, string id,
  32. AzureStorageFactory _azureStorage, Option _option,AzureRedisFactory _azureRedis,string ip, HttpTrigger _httpTrigger,string lang )
  33. {
  34. List<object> schools = new List<object>();
  35. List<AreaDto> areas = new List<AreaDto>();
  36. string defaultschool = null;
  37. //TODO 取得Teacher 個人相關數據(課程清單、虛擬教室清單、歷史紀錄清單等),學校數據另外API處理,多校切換時不同
  38. var client = _azureCosmos.GetCosmosClient();
  39. int total = 0;
  40. int tsize = 0;
  41. List<Area> areasDbs = new List<Area>();
  42. List<AreaSetting> areaSettings = new List<AreaSetting>();
  43. try
  44. {
  45. if (teacher == null)
  46. {
  47. teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(id, new PartitionKey("Base"));
  48. if (!string.IsNullOrWhiteSpace(lang) && string.IsNullOrWhiteSpace(teacher.lang)) {
  49. teacher.lang = lang;
  50. }
  51. teacher.name = $"{name}";
  52. teacher.picture = $"{picture}";
  53. }
  54. else
  55. {
  56. name = teacher.name;
  57. picture = teacher.picture;
  58. id = teacher.id;
  59. }
  60. ///教师的个人空间
  61. tsize = teacher.size;
  62. ///教师的总空间 包含 个人空间和学校赠送的空间累加
  63. total = teacher.size;
  64. HashSet<string> areaIds = new HashSet<string>();
  65. if (teacher.areas.IsNotEmpty())
  66. {
  67. teacher.areas.ForEach(x => {
  68. areaIds.Add(x.areaId);
  69. });
  70. }
  71. if (teacher.schools.IsNotEmpty())
  72. {
  73. teacher.schools.ForEach(x => {
  74. if (!string.IsNullOrEmpty(x.areaId))
  75. {
  76. areaIds.Add(x.areaId);
  77. }
  78. });
  79. }
  80. if (areaIds.Count > 0)
  81. {
  82. string queryText = $"select value(c) from c where c.id in ({string.Join(",", areaIds.Select(x => $"'{x}'"))})";
  83. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Area>(queryText: queryText, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base-Area") }))
  84. {
  85. areasDbs.Add(item);
  86. }
  87. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AreaSetting>(queryText: queryText, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("AreaSetting") }))
  88. {
  89. areaSettings.Add(item);
  90. }
  91. }
  92. if (teacher.areas.IsNotEmpty())
  93. {
  94. foreach (var areat in teacher.areas)
  95. {
  96. Area area = areasDbs.Find(x => x.id.Equals(areat.areaId));
  97. AreaSetting setting = null;
  98. if (area != null)
  99. {
  100. setting = areaSettings.Find(x => x.id.Equals(areat.areaId));
  101. }
  102. int access = 0;
  103. if (setting != null && !string.IsNullOrWhiteSpace(setting.accessConfig))
  104. {
  105. access = 1;
  106. }
  107. //if (setting != null)
  108. //{
  109. // setting.accessConfig = null;
  110. //}
  111. areas.Add(new AreaDto { areaId = area.id, name = area.name, standard = area.standard, standardName = area.standardName, setting = setting, access = access });
  112. }
  113. }
  114. //检查是否有加入学校,如果加入学校,则当个人空间size是0G的时候,则免费获得一个G空间,但无论加入多少个学校,只能获取一次 1G的免费空间。没有加入学校则默认0G空间,除非自己购买空间
  115. if (teacher.schools.IsNotEmpty())
  116. {
  117. foreach (var sc in teacher.schools)
  118. {
  119. string statusNow = sc.status != null ? sc.status : "";
  120. if (statusNow.Equals("join") || statusNow.Equals("invite") || statusNow.Equals("request"))
  121. {
  122. dynamic schoolExtobj = new ExpandoObject();
  123. schoolExtobj.schoolId = sc.schoolId;
  124. schoolExtobj.name = sc.name;
  125. schoolExtobj.status = sc.status;
  126. schoolExtobj.time = sc.time;
  127. schoolExtobj.picture = sc.picture;
  128. schoolExtobj.areaId = $"{sc.areaId}";
  129. Area area = null;
  130. int access = 0;
  131. if (!string.IsNullOrEmpty($"{sc.areaId}"))
  132. {
  133. area = areasDbs.Find(x => x.id.Equals(sc.areaId));
  134. AreaSetting setting = null;
  135. if (area != null)
  136. {
  137. setting = areaSettings.Find(x => x.id.Equals(sc.areaId));
  138. }
  139. if (setting != null && !string.IsNullOrWhiteSpace(setting.accessConfig))
  140. {
  141. access = 1;
  142. }
  143. }
  144. if (area != null)
  145. {
  146. schoolExtobj.area = new { area.name, area.id, area.institution, area.provName, area.code, area.cityCode, area.cityName, area.standard, area.provCode, area.pk, access };
  147. }
  148. else
  149. {
  150. schoolExtobj.area = area;
  151. }
  152. var sctch = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(id, new PartitionKey($"Teacher-{sc.schoolId}"));
  153. if (sctch.Status == 200 && sctch != null && sctch.ContentStream != null)
  154. {
  155. var jsonDoc = await JsonDocument.ParseAsync(sctch.ContentStream);
  156. SchoolTeacher schoolTeacher = jsonDoc.RootElement.ToObject<SchoolTeacher>();
  157. if (schoolTeacher.name == null || schoolTeacher.picture == null || !schoolTeacher.name.Equals($"{name}") || !schoolTeacher.picture.Equals($"{picture}"))
  158. {
  159. schoolTeacher.name = $"{name}";
  160. schoolTeacher.picture = $"{picture}";
  161. await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync(schoolTeacher, id, new PartitionKey($"Teacher-{sc.schoolId}"));
  162. }
  163. if (jsonDoc.RootElement.TryGetProperty("size", out JsonElement _size) && _size.ValueKind.Equals(JsonValueKind.Number))
  164. {
  165. total += _size.GetInt32();
  166. schoolExtobj.size = _size.GetInt32();
  167. }
  168. else { schoolExtobj.size = 0; }
  169. }
  170. else
  171. {
  172. schoolExtobj.size = 0;
  173. }
  174. //if (statusNow.Equals("join"))
  175. //{
  176. // await TmdUserService.JoinSchool(client, teacher.id, teacher.picture, teacher.name, sc.schoolId, sc.name);
  177. //}
  178. schools.Add(schoolExtobj);
  179. }
  180. }
  181. //如果包含任何申请,邀请,加入学校的记录 且个人空间未分配2G 则默认分配个人空间至2G.
  182. if (teacher.size < 2 && teacher.schools.Count > 0)
  183. {
  184. teacher.size = 2;
  185. }
  186. //如果未包含任何申请,邀请,加入学校的记录 且 个人空间没有分配1G 则默认赠送一个G
  187. if (teacher.schools.Count == 0 && teacher.size < 1)
  188. {
  189. teacher.size = 1;
  190. }
  191. }
  192. if (string.IsNullOrEmpty(teacher.defaultSchool) && teacher.schools.IsNotEmpty())
  193. {
  194. var tech = teacher.schools.FindAll(x => x.status.Equals("join"));
  195. if (tech.IsNotEmpty())
  196. {
  197. teacher.defaultSchool = teacher.schools[0].schoolId;
  198. }
  199. }
  200. if (!string.IsNullOrEmpty(teacher.defaultSchool))
  201. {
  202. if (teacher.schools.IsNotEmpty())
  203. {
  204. var tech = teacher.schools.FindAll(x => x.status.Equals("join") && x.schoolId.Equals(teacher.defaultSchool));
  205. if (!tech.IsNotEmpty())
  206. {
  207. var techde = teacher.schools.FindAll(x => x.status.Equals("join"));
  208. if (techde.IsNotEmpty())
  209. {
  210. teacher.defaultSchool = techde[0].schoolId;
  211. }
  212. else
  213. {
  214. teacher.defaultSchool = null;
  215. }
  216. }
  217. }
  218. else
  219. {
  220. teacher.defaultSchool = null;
  221. }
  222. }
  223. await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, id, new PartitionKey("Base"));
  224. //預設學校ID
  225. defaultschool = teacher.defaultSchool;
  226. }
  227. catch (CosmosException ex)
  228. {
  229. if (ex.Status == 404 && teacher == null)
  230. {
  231. //如果沒有,則初始化Teacher基本資料到Cosmos
  232. teacher = new Teacher
  233. {
  234. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  235. id = id,
  236. pk = "Base",
  237. code = "Base",
  238. name = name?.ToString(),
  239. picture = picture?.ToString(),
  240. //创建账号并第一次登录IES5则默认赠送1G
  241. size = 1,
  242. defaultSchool = null,
  243. schools = new List<Teacher.TeacherSchool>(),
  244. };
  245. var container = _azureStorage.GetBlobContainerClient(id);
  246. await container.CreateIfNotExistsAsync(PublicAccessType.None); //嘗試創建Teacher私有容器,如存在則不做任何事,保障容器一定存在
  247. teacher = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").CreateItemAsync<Teacher>(teacher, new PartitionKey("Base"));
  248. total = teacher.size;
  249. tsize = teacher.size;
  250. }
  251. }
  252. catch (Exception ex)
  253. {
  254. throw new Exception($"{ex.Message}\n{ex.StackTrace}");
  255. }
  256. //私人課程
  257. List<object> courses = new List<object>();
  258. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryStreamIterator(queryText: $"select value(c) from c ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Course-{id}") }))
  259. {
  260. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  261. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  262. {
  263. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  264. {
  265. courses.Add(obj.ToObject<object>());
  266. }
  267. }
  268. }
  269. List<string> roles = new List<string>() { "teacher" };
  270. Area areaa = null;
  271. if (areas.Count > 0)
  272. {
  273. roles.Add("area");
  274. if (!string.IsNullOrEmpty($"{areas[0]}"))
  275. {
  276. areaa = areasDbs.Find(x => x.Equals(areas[0].areaId));
  277. }
  278. }
  279. //換取AuthToken,提供給前端
  280. var auth_token = JwtAuthExtension.CreateAuthToken(_option.HostName, id, name?.ToString(), picture?.ToString(), _option.JwtSecretKey, Website: "IES", scope: Constant.ScopeTeacher, standard: areaa != null ? areaa.standard : "", roles: roles.ToArray(), expire: 1);
  281. //用户在线记录
  282. try
  283. {
  284. _ = _httpTrigger.RequestHttpTrigger(new { school = defaultschool, scope = $"{Constant.ScopeTeacher}", id=$"{id}", ip=$"{ip}", expire=1 }, _option.Location, "online-record");
  285. }
  286. catch { }
  287. //取得Teacher Blob 容器位置及SAS
  288. await _azureStorage.GetBlobContainerClient(id).CreateIfNotExistsAsync(PublicAccessType.None); //嘗試創建Teacher私有容器,如存在則不做任何事,保障容器一定存在
  289. var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS(id, BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List | BlobContainerSasPermissions.Delete);
  290. 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);
  291. return new TeacherInfo
  292. {
  293. auth_token = auth_token,
  294. blob_uri = blob_uri,
  295. blob_sas = blob_sas,
  296. schools = schools,
  297. defaultschool = defaultschool,
  298. courses = courses,
  299. total = total,
  300. osblob_sas = osblob_sas,
  301. osblob_uri = osblob_uri,
  302. tsize = tsize,
  303. areas = areas,
  304. teacher = teacher
  305. };
  306. }
  307. }
  308. public record AreaDto
  309. {
  310. //areaId = area.id, name = area.name, area.standard, area.standardName
  311. public string areaId { get; set; }
  312. public string name { get; set; }
  313. public string standard { get; set; }
  314. public string standardName { get; set; }
  315. //public string accessConfig { get; set; }
  316. public AreaSetting setting { get; set; }
  317. public int access { get; set; } = 0;
  318. }
  319. public record TeacherInfo
  320. {
  321. public string auth_token { get; set; }
  322. public string blob_uri { get; set; }
  323. public string blob_sas { get; set; }
  324. public List<object> schools { get; set; } = new List<object>();
  325. public string defaultschool { get; set; }
  326. public List<object> courses { get; set; } = new List<object>();
  327. public int total { get; set; }
  328. public string osblob_uri { get; set; }
  329. public string osblob_sas { get; set; }
  330. public int tsize { get; set; }
  331. public List<AreaDto> areas { get; set; } = new List<AreaDto>();
  332. public Teacher teacher { get; set; }
  333. }
  334. }