123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715 |
- using Azure.Cosmos;
- using Azure.Storage.Blobs.Models;
- using Azure.Storage.Sas;
- using Microsoft.AspNetCore.Http;
- using Microsoft.AspNetCore.Mvc;
- using Microsoft.Extensions.Options;
- using System;
- using System.Collections.Generic;
- using System.Dynamic;
- using System.IdentityModel.Tokens.Jwt;
- using System.IO;
- using System.Linq;
- using System.Text.Json;
- using System.Threading.Tasks;
- using TEAMModelOS.Models;
- using TEAMModelOS.SDK.Models;
- using TEAMModelOS.SDK.DI;
- using TEAMModelOS.SDK.Extension;
- using TEAMModelOS.Filter;
- using TEAMModelOS.SDK.Models.Cosmos;
- using HTEXLib.COMM.Helpers;
- using TEAMModelOS.SDK.Models.Service;
- using Microsoft.Extensions.Configuration;
- using System.Net.Http;
- using TEAMModelOS.SDK;
- using static TEAMModelOS.SDK.Models.Teacher;
- using TEAMModelOS.Services;
- namespace TEAMModelOS.Controllers
- {
- [ProducesResponseType(StatusCodes.Status200OK)]
- [ProducesResponseType(StatusCodes.Status400BadRequest)]
- //[Authorize(Roles = "IES5")]
- [Route("teacher/init")]
- [ApiController]
- public class InitController : ControllerBase
- {
- private readonly AzureCosmosFactory _azureCosmos;
- private readonly AzureStorageFactory _azureStorage;
- private readonly DingDing _dingDing;
- private readonly Option _option;
- private readonly IConfiguration _configuration;
- private readonly NotificationService _notificationService;
- public InitController(AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, DingDing dingDing, IOptionsSnapshot<Option> option, IConfiguration configuration, NotificationService notificationService)
- {
- _azureCosmos = azureCosmos;
- _azureStorage = azureStorage;
- _dingDing = dingDing;
- _option = option?.Value;
- _configuration = configuration;
- _notificationService = notificationService;
- }
- /// <summary>
- /// 修改教师信息
- /// </summary>
- /// <param name="request"></param>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- [HttpPost("set-teacher-info")]
- [AuthToken(Roles = "admin,teacher,area")]
- public async Task<IActionResult> SetTeacherInfo(JsonElement request)
- {
- var client = _azureCosmos.GetCosmosClient();
- if (!request.TryGetProperty("opt", out JsonElement _opt))
- {
- return BadRequest();
- }
- var (userid, name, _, school) = HttpContext.GetAuthTokenInfo();
- try
- {
- Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(userid, new PartitionKey("Base"));
- switch (true)
- {
- //修改默认学校
- case bool when $"{_opt}".Equals("UpdateDefaultSchool", StringComparison.OrdinalIgnoreCase) && (request.TryGetProperty("defaultSchool", out JsonElement _defaultSchool)):
- if (teacher.schools.Select(x => x.schoolId).Contains($"{_defaultSchool}") && !string.IsNullOrEmpty($"{_defaultSchool}"))
- {
- teacher.defaultSchool = $"{_defaultSchool}";
- await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, userid, new PartitionKey("Base"));
- return Ok(new { teacher, status = 1 });
- }
- else
- {
- return BadRequest(new { status = -1, msg = "您未加入该学校!" });
- }
- case bool when $"{_opt}".Equals("TransferAdminRole", StringComparison.OrdinalIgnoreCase) && (request.TryGetProperty("targerTecher", out JsonElement _targetTecher)):
- if (!string.IsNullOrEmpty(school) && !string.IsNullOrEmpty($"{_targetTecher}"))
- {
- SchoolTeacher schoolTeacher = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<SchoolTeacher>(userid, new PartitionKey($"Teacher-{school}"));
- if (schoolTeacher.roles.IsNotEmpty() && schoolTeacher.roles.Contains("admin"))
- {
- schoolTeacher.roles.Remove("admin");
- SchoolTeacher newSchoolTeacher = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<SchoolTeacher>($"{_targetTecher}", new PartitionKey($"Teacher-{school}"));
- if (!newSchoolTeacher.roles.Contains("admin"))
- {
- newSchoolTeacher.roles.Add("admin");
- newSchoolTeacher = await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<SchoolTeacher>(newSchoolTeacher, $"{_targetTecher}", new PartitionKey($"Teacher-{school}"));
- }
- await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<SchoolTeacher>(schoolTeacher, userid, new PartitionKey($"Teacher-{school}"));
- string code = "transfer-admin";
- School schoolBase = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>(school, new PartitionKey($"Base"));
- Notification notification = new Notification
- {
- hubName = "hita",
- type = "msg",
- from = $"ies5:{_option.Location}:{school}",
- to = new List<string> { $"{_targetTecher}" },
- label = $"{code}_school",
- body = new { location = _option.Location, biz = code, tmdid = userid, tmdname = name, schoolcode = $"{school}", schoolname = $"{schoolBase.name}", status = 1, time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() }.ToJsonString(),
- expires = DateTimeOffset.UtcNow.AddDays(7).ToUnixTimeSeconds()
- };
- if (notification != null)
- {
- var url = _configuration.GetValue<string>("HaBookAuth:CoreService:sendnotification");
- var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
- var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
- var location = _option.Location;
- await _notificationService.SendNotification(clientID, clientSecret, location, url, notification);
- }
- return Ok(new { status = 1 });
- }
- else
- {
- return BadRequest(new { status = -1, msg = "当前登录账号没有admin权限" });
- }
- }
- else
- {
- return BadRequest(new { status = -1, msg = "参数异常!" });
- }
- }
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/init/set-teacher-info()\n{ex.Message}{ex.StackTrace}{request.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
- return BadRequest("teacher not exist");
- }
- return BadRequest();
- }
- //TODO 此API需處理對應前端返回的相關數據
- [ProducesDefaultResponseType]
- [HttpPost("get-teacher-info")]
- public async Task<IActionResult> GetTeacherInfo(JsonElement request)
- {
- try
- {
- if (!request.TryGetProperty("id_token", out JsonElement id_token)) return BadRequest();
- var jwt = new JwtSecurityToken(id_token.GetString());
- //TODO 此驗證IdToken先簡單檢查,後面需向Core ID新API,驗證Token
- if (!jwt.Payload.Iss.Equals("account.teammodel", StringComparison.OrdinalIgnoreCase)) return BadRequest();
- var id = jwt.Payload.Sub;
- jwt.Payload.TryGetValue("name", out object name);
- jwt.Payload.TryGetValue("picture", out object picture);
- Teacher teacher = null;
- TeacherInfo teacherInfo= await TeacherService.GetTeacherInfo(_azureCosmos, teacher, $"{name}", $"{picture}", id, _azureStorage, _option);
- return Ok(new { location = _option.Location, teacherInfo. auth_token, teacherInfo. blob_uri, teacherInfo.blob_sas, teacherInfo.schools, teacherInfo.defaultschool, teacherInfo. courses,
- teacherInfo.total,
- teacherInfo.osblob_uri,
- teacherInfo.osblob_sas,
- teacherInfo.tsize, status = 200,
- teacherInfo. areas });
- }
- catch (CosmosException ex)
- {
- await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/GetTeacherInfo()\n{ex.Message}{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/GetTeacherInfo()\n{ex.Message}{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- //TODO 此API需處理對應前端返回的相關數據
- [ProducesDefaultResponseType]
- [HttpPost("get-school-info")]
- public async Task<IActionResult> GetSchoolInfo(JsonElement request)
- {
- try
- {
- if (!request.TryGetProperty("id_token", out JsonElement id_token)) return BadRequest();
- if (!request.TryGetProperty("school_code", out JsonElement _school_code)) return BadRequest();
- string school_code = $"{_school_code}";
- var jwt = new JwtSecurityToken(id_token.GetString());
- if (!jwt.Payload.Iss.Equals("account.teammodel", StringComparison.Ordinal)) return BadRequest();
- var id = jwt.Payload.Sub;
- var client = _azureCosmos.GetCosmosClient();
- //權限token
- jwt.Payload.TryGetValue("name", out object name);
- jwt.Payload.TryGetValue("picture", out object picture);
- List<string> roles = new List<string>();
- List<string> permissions = new List<string>();
- int size = 0;
- Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(id, new PartitionKey("Base"));
- var areas = teacher.areas;
- if (school_code.Equals(teacher.defaultSchool) && teacher.schools.IsNotEmpty() && !teacher.schools.Select(x => x.schoolId).Contains(school_code))
- {
- school_code = teacher.schools[0].schoolId;
- teacher.defaultSchool = school_code;
- teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, id, new PartitionKey("Base"));
- }
- var response = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(id, new PartitionKey($"Teacher-{school_code}"));
- if (response.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(response.ContentStream);
- if (json.RootElement.TryGetProperty("size", out JsonElement _size) && _size.ValueKind == JsonValueKind.Number)
- {
- size = _size.GetInt32();
- }
- if (json.RootElement.TryGetProperty("roles", out JsonElement _roles) && _roles.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _roles.EnumerateArray())
- {
- roles.Add(obj.GetString());
- }
- }
- if (json.RootElement.TryGetProperty("permissions", out JsonElement _permissions) && _permissions.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _permissions.EnumerateArray())
- {
- permissions.Add(obj.GetString());
- }
- }
- }
- else //無此學校資料
- {
- }
- if (roles.Count == 0)
- {
- roles.Add("teacher");
- roles.Add("student");
- }
- //TODO JJ,调整为取得学校基础设置数据,取代下方學校學制、年級
- School school_base = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>($"{school_code}", new PartitionKey("Base"));
- foreach (var period in school_base.period)
- {
- try
- {
- await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<ItemCond>($"{period.id}", new PartitionKey($"ItemCond-{school_code}"));
- }
- catch (CosmosException)
- {
- ItemCond itemCond = new ItemCond
- {
- id = period.id,
- pk = "ItemCond",
- code = $"ItemCond-{school_code}",
- ttl = -1,
- };
- await client.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<ItemCond>(itemCond, new PartitionKey($"ItemCond-{school_code}"));
- }
- }
- if (areas.Count > 0)
- {
- roles.Add("area");
- }
- //TODO JJ,更新Token时,在取得学校资讯时,没有传入schoolId
- var auth_token = JwtAuthExtension.CreateAuthToken(_option.HostName, id, name?.ToString(), picture?.ToString(), _option.JwtSecretKey, scope: Constant.ScopeTeacher, schoolID: school_code.ToString(), standard: school_base.standard, roles: roles.ToArray(), permissions: permissions.ToArray());
- //取得班级
- List<object> school_classes = new List<object>();
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: $"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, ARRAY_LENGTH(c.students) AS studCount FROM c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Class-{school_code}") }))
- {
- var jsonc = await JsonDocument.ParseAsync(item.ContentStream);
- foreach (var classeinfo in jsonc.RootElement.GetProperty("Documents").EnumerateArray())
- {
- school_classes.Add(classeinfo.ToObject<object>());
- }
- }
- //取得教室
- List<Room> school_rooms = new List<Room>();
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Room>(queryText: $"select value(c) from c ",
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Room-{school_code}") }))
- {
- school_rooms.Add(item);
- }
- //List<object> periods = new List<object>();
- //List<object> grades = new List<object>();
- //var responsesch = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(school_code.ToString(), new PartitionKey($"Base"));
- //if (responsesch.Status == 200)
- //{
- // var jsons = await JsonDocument.ParseAsync(responsesch.ContentStream);
- // if (jsons.RootElement.TryGetProperty("period", out JsonElement periodJobj))
- // {
- // foreach (var periodinfo in periodJobj.EnumerateArray())
- // {
- // dynamic periodExtobj = new ExpandoObject();
- // periodExtobj.id = periodinfo.GetProperty("id");
- // periodExtobj.name = periodinfo.GetProperty("name");
- // periods.Add(periodExtobj);
- // if (periodinfo.TryGetProperty("grades", out JsonElement gradesJobj))
- // {
- // foreach (var gradeinfo in gradesJobj.EnumerateArray())
- // {
- // dynamic gradeExtobj = new ExpandoObject();
- // gradeExtobj.id = gradeinfo.GetProperty("id");
- // gradeExtobj.name = gradeinfo.GetProperty("name");
- // gradeExtobj.periodId = periodinfo.GetProperty("id");
- // grades.Add(gradeExtobj);
- // }
- // }
- // }
- // }
- //}
- //該老師排定的學校課程
- List<object> school_courses = new List<object>();
- var query = $"SELECT distinct value(c) FROM c JOIN A1 IN c.schedule where A1.teacherId='{id}'";
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Course-{school_code}") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
- {
- school_courses.Add(obj.ToObject<object>());
- }
- }
- }
- //校本課綱 [式樣未定 先不取]
-
- //取得School Blob 容器位置及SAS
- string school_code_blob = school_code.ToLower();
- var container = _azureStorage.GetBlobContainerClient(school_code_blob);
- await container.CreateIfNotExistsAsync(PublicAccessType.None); //嘗試創建School容器,如存在則不做任何事,保障容器一定存在
- 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);
- ///https://teammodelstorage.blob.core.chinacloudapi.cn/teammodelos
- 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);
- return Ok(new { auth_token, blob_uri, blob_sas, school_base, school_courses, school_classes, school_rooms, size, osblob_uri, osblob_sas, status = 200, areas });
- }
- catch (CosmosException ex)
- {
- HttpContext.Request.Headers.TryGetValue("referer", out var referer);
- await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/init/get-school-info()\n{ex.Message}{ex.StackTrace}{request.ToJsonString()}\n{referer}", GroupNames.醍摩豆服務運維群組);
- return Ok(new { status = ex.Status });
- }
- catch (Exception ex)
- {
- HttpContext.Request.Headers.TryGetValue("referer", out var referer);
- await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/init/get-school-info()\n{ex.Message}{ex.StackTrace}{request.ToJsonString()}\n{referer}", GroupNames.醍摩豆服務運維群組);
- return Ok(new { status = 500 });
- }
- }
- /// <summary>
- /// 取得學校所有列表
- /// </summary>
- /// <param name="request"></param>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- //[AuthToken(Roles = "teacher")]
- [HttpPost("get-school-list")]
- public async Task<IActionResult> GetSchoolList(JsonElement request)
- {
- try
- {
- //輸入值
- string sqlSchoolId = (request.TryGetProperty("schoolId", out JsonElement reqSchoolId)) ? reqSchoolId.GetString() : string.Empty;
- bool sqlHasManager = (request.TryGetProperty("manager", out JsonElement reqHasManager)) ? reqHasManager.GetBoolean() : false;
- bool sqlHasMBaseModule = (request.TryGetProperty("base", out JsonElement reqHasBaseModule)) ? reqHasBaseModule.GetBoolean() : false;
- var client = _azureCosmos.GetCosmosClient();
- //有管理者的學校
- Dictionary<string, List<Dictionary<string, string>>> managerSchDic = new Dictionary<string, List<Dictionary<string, string>>>();
- string managerWhereOption = (!string.IsNullOrWhiteSpace(sqlSchoolId)) ? $" AND c.code = 'Teacher-{sqlSchoolId}'" : string.Empty;
- 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}";
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: managerSql, requestOptions: new QueryRequestOptions() { }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
- {
- string id = obj.GetProperty("id").GetString(); //管理者ID
- string name = obj.GetProperty("name").GetString(); //管理者姓名
- string schoolId = obj.GetProperty("schoolId").GetString(); //學校ID
- Dictionary<string, string> managerDic = new Dictionary<string, string>();
- managerDic.Add("id", id);
- managerDic.Add("name", name);
- if (managerSchDic.ContainsKey(schoolId))
- {
- managerSchDic[schoolId].Add(managerDic);
- }
- else
- {
- List<Dictionary<string, string>> managerList = new List<Dictionary<string, string>>();
- managerList.Add(managerDic);
- managerSchDic.Add(schoolId, managerList);
- }
- }
- }
- //有管理模組的學校
- List<string> baseModuleSchList = new List<string>();
- string baseModuleWhereOption = (!string.IsNullOrWhiteSpace(sqlSchoolId)) ? $" AND c.id = '{sqlSchoolId}'" : string.Empty;
- 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") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
- {
- string schoolId = obj.GetProperty("id").GetString(); //學校ID
- baseModuleSchList.Add(schoolId);
- }
- }
- //學校資料
- List<object> schools = new List<object>();
- string schoolWhereOption = (!string.IsNullOrWhiteSpace(sqlSchoolId)) ? $" WHERE c.id = '{sqlSchoolId}'" : string.Empty;
- 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") }))
- {
- var jsons = await JsonDocument.ParseAsync(item.ContentStream);
- if (jsons.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- foreach (var obj in jsons.RootElement.GetProperty("Documents").EnumerateArray())
- {
- dynamic schoolExtobj = new ExpandoObject();
- schoolExtobj.id = obj.GetProperty("id").GetString(); //學校ID
- schoolExtobj.name = obj.GetProperty("name");
- schoolExtobj.region = obj.GetProperty("region");
- schoolExtobj.province = obj.GetProperty("province");
- schoolExtobj.city = obj.GetProperty("city");
- schoolExtobj.picture = obj.GetProperty("picture");
- if (managerSchDic.ContainsKey(schoolExtobj.id))
- {
- schoolExtobj.hasManager = true;
- schoolExtobj.managers = managerSchDic[schoolExtobj.id];
- }
- else
- {
- schoolExtobj.hasManager = false;
- schoolExtobj.managers = new List<object>();
- }
- schoolExtobj.hasBaseModule = (baseModuleSchList.Contains(schoolExtobj.id)) ? true : false;
- //學校輸出結果加入篩選
- if ((sqlHasManager && sqlHasMBaseModule) && (schoolExtobj.hasManager && schoolExtobj.hasBaseModule))
- {
- schools.Add(schoolExtobj);
- }
- else if (sqlHasManager && schoolExtobj.hasManager)
- {
- schools.Add(schoolExtobj);
- }
- else if (sqlHasMBaseModule && schoolExtobj.hasBaseModule)
- {
- schools.Add(schoolExtobj);
- }
- else if (!sqlHasManager && !sqlHasMBaseModule)
- {
- schools.Add(schoolExtobj);
- }
- }
- }
- }
- return Ok(new { schools });
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"IES5,{_option.Location},Teacher/init/get-school-info()\n{ex.Message}{ex.StackTrace}{request.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- /// <summary>
- /// 申請或同意邀請加入學校
- /// </summary>
- ///
- /// <param name="requert"></param>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- [AuthToken(Roles = "teacher")]
- [HttpPost("join-school")]
- public async Task<IActionResult> JoinSchool(JsonElement requert)
- {
- try
- {
- if (!requert.TryGetProperty("grant_type", out JsonElement grant_type)) return BadRequest(); //"invite":學校邀請 "request":老師申請 "join":"成為學校老師",leave 离开,cancel 取消。
- if (!requert.TryGetProperty("school_code", out JsonElement school_code)) return BadRequest();
- if (!requert.TryGetProperty("school_name", out JsonElement school_name)) return BadRequest();
- ///当邀请某个老师加入学校则需要知道是谁邀请的
- //if (!requert.TryGetProperty("school_admin", out JsonElement school_admin)) return BadRequest();
- string authtoken = HttpContext.GetXAuth("AuthToken");
- if (string.IsNullOrEmpty(authtoken)) return BadRequest();
- var jwt = new JwtSecurityToken(authtoken);
- var id = jwt.Payload.Sub;
- var schoolcode = jwt.Payload.Azp;
- var Claims = jwt.Payload.Claims;
- jwt.Payload.TryGetValue("name", out object name);
- jwt.Payload.TryGetValue("picture", out object picture);
- var client = _azureCosmos.GetCosmosClient();
- //在老師表找出老師,處理該學校狀態 (老師基本資料應該要存在)
- Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(id, new PartitionKey("Base"));
- if (teacher.schools == null)
- teacher.schools = new List<Teacher.TeacherSchool>();
- var school = teacher.schools?.FirstOrDefault(x => x.schoolId.Equals(school_code.GetString(), StringComparison.OrdinalIgnoreCase));
- School schoolBase = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>($"{school_code}", new PartitionKey("Base"));
- if (school != null)
- school.status = grant_type.GetString();
- else
- {
- long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- 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 });
- }
- if (grant_type.GetString().Equals("leave") || grant_type.GetString().Equals("cancel"))
- {
- if (teacher.schools.IsNotEmpty())
- {
- //获取之前已经加入的学校或者申请的学校
- var inSchools = teacher.schools.Where(x => x.schoolId == school_code.GetString()).ToList();
- if (inSchools.IsNotEmpty())
- {
- inSchools.ForEach(x => teacher.schools.Remove(x));
- }
- }
- if (teacher.schools.Count > 0 && teacher.size <= 1)
- {
- teacher.size = 2;
- }
- if (!string.IsNullOrEmpty(teacher.defaultSchool) && teacher.defaultSchool.Equals($"{school_code}"))
- {
- if (teacher.schools.IsNotEmpty())
- {
- teacher.defaultSchool = teacher.schools[0].schoolId;
- }
- else
- {
- teacher.defaultSchool = null;
- }
- }
- await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, id, new PartitionKey("Base"));
- var sresponse = await client.GetContainer(Constant.TEAMModelOS, "School").DeleteItemStreamAsync(id, new PartitionKey($"Teacher-{school_code}"));
- //await TmdUserService.LeaveSchool(client, teacher.id, school.schoolId);
- return Ok(new { stauts = 1 });
- }
- else
- {
- var dft = new List<string>() { "content-read", "exercise-read", "knowledge-read", "syllabus-read" };
- if (teacher.schools.Count > 0 && teacher.size <= 1)
- {
- teacher.size = 2;
- }
- await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, id, new PartitionKey("Base"));
- //在學校表處理該學校教師帳號的狀態
- var sresponse = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(id, new PartitionKey($"Teacher-{school_code}"));
- if (sresponse.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
- SchoolTeacher steacher = json.ToObject<SchoolTeacher>();
- steacher.status = grant_type.GetString();
- if (grant_type.ToString().Equals("join"))
- {
- if (steacher.permissions.IsNotEmpty())
- {
- foreach (var d in dft)
- {
- if (!steacher.permissions.Contains(d))
- {
- steacher.permissions.Add(d);
- }
- }
- }
- else
- {
- steacher.permissions = dft;
- }
- }
- var response = await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync(steacher, id, new PartitionKey($"Teacher-{school_code}"));
- }
- else
- {
- SchoolTeacher st = new SchoolTeacher()
- {
- pk = "Teacher",
- code = $"Teacher-{school_code}",
- createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
- id = id,
- name = name.ToString(),
- picture = picture?.ToString(),
- permissions = grant_type.ToString().Equals("join") ? dft : null,
- roles = new List<string>() { "teacher" },
- size = 0,
- status = grant_type.GetString()
- };
- var response = await client.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync(st, new PartitionKey($"Teacher-{school_code}"));
- }
- if (grant_type.ToString().Equals("join"))
- {
- await TmdUserService.JoinSchool(client, teacher.id, teacher.picture, teacher.name, school.schoolId, school.name);
- }
- Notification notification = null;
- List<SchoolTeacher> teachers = new List<SchoolTeacher>();
- var queryslt = $"SELECT value(c) FROM c join A1 in c.roles where A1 in ('admin')";
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<SchoolTeacher>(queryText: queryslt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Teacher-{school_code}") }))
- {
- teachers.Add(item);
- }
- if (teachers.IsNotEmpty())
- {
- string code = grant_type.GetString();
- if (grant_type.GetString().Equals("join"))
- {
- code = "invite-join";
- }
- notification = new Notification
- {
- hubName = "hita",
- type = "msg",
- from = $"ies5:{_option.Location}:private",
- to = teachers.Select(x => x.id).ToList(),
- label = $"{code}_school",
- body = new { location = _option.Location, biz = code, tmdid = id, tmdname = name.ToString(), schoolcode = $"{school_code}", schoolname = $"{school_name}", status = 1, time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() }.ToJsonString(),
- expires = DateTimeOffset.UtcNow.AddDays(7).ToUnixTimeSeconds()
- };
- }
- if (notification != null)
- {
- var url = _configuration.GetValue<string>("HaBookAuth:CoreService:sendnotification");
- var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
- var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
- var location = _option.Location;
- var code = await _notificationService.SendNotification(clientID, clientSecret, location, url, notification);
- }
- return Ok(new { stauts = 1 });
- }
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"TEAMModel,{_option.Location},Init/JoinSchool()\n{ex.Message}{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- //課綱的model先記在下面,待式樣確定後再轉換
- private List<SyllabusNode> CreateSyllabusTree(List<Syllabus> syllabuses)
- {
- List<SyllabusNode> nodes = new List<SyllabusNode>();
- foreach (var syllabus in syllabuses)
- {
- if (syllabus.pid.Equals(""))
- nodes.Add(new SyllabusNode { id = syllabus.id, name = syllabus.name });
- else
- {
- CreateNode(nodes, syllabus);
- }
- }
- return nodes;
- }
- private void CreateNode(List<SyllabusNode> nodes, Syllabus parent)
- {
- foreach (var node in nodes)
- {
- if (node.id == parent.pid)
- {
- node.children.Add(new SyllabusNode { id = parent.id, name = parent.name });
- }
- else
- {
- CreateNode(node.children, parent);
- }
- }
- }
- public class SyllabusRole
- {
- public string id { get; set; }
- public string name { get; set; }
- public object period { get; set; }
- public object semester { get; set; }
- public object grade { get; set; }
- public object subject { get; set; }
- public int resourceCount { get; set; }
- public int itemCount { get; set; }
- public object structure { get; set; }
- }
- public class Syllabus
- {
- public string id { get; set; }
- public string name { get; set; }
- public string pid { get; set; }
- public int order { get; set; }
- }
- public class SyllabusNode
- {
- public string id { get; set; }
- public string name { get; set; }
- public List<SyllabusNode> children { get; set; }
- public SyllabusNode()
- {
- children = new List<SyllabusNode>();
- }
- }
- }
- }
|