TEAMModelOS/TEAMModelOS/Controllers/Teacher/InitController.cs

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;
using Microsoft.AspNetCore.Authorization;
using System.Diagnostics;
using Microsoft.Extensions.Logging;
using System.Text;
using Microsoft.Azure.Cosmos.Table;
using TEAMModelOS.SDK.DI.CoreAPI;

namespace TEAMModelOS.Controllers
{
    [ProducesResponseType(StatusCodes.Status200OK)]
    [ProducesResponseType(StatusCodes.Status400BadRequest)]

    [Route("teacher/init")]
    [ApiController]
    public class InitController : ControllerBase
    {
        private readonly AzureCosmosFactory _azureCosmos;
        private readonly AzureStorageFactory _azureStorage;
        private readonly AzureRedisFactory _azureRedis;
        private readonly DingDing _dingDing;
        private readonly Option _option;
        private readonly IConfiguration _configuration;
        private readonly NotificationService _notificationService;
        private readonly CoreAPIHttpService _coreAPIHttpService;
        private readonly IPSearcher _searcher;
        private readonly ILogger<InitController> _logger;
        private readonly HttpTrigger _httpTrigger;

        public InitController(ILogger<InitController> logger, IPSearcher searcher, CoreAPIHttpService coreAPIHttpService, AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, AzureRedisFactory azureRedis, DingDing dingDing, IOptionsSnapshot<Option> option, IConfiguration configuration, NotificationService notificationService, HttpTrigger httpTrigger)
        {
            _searcher = searcher;
            _azureCosmos = azureCosmos;
            _azureStorage = azureStorage;
            _azureRedis = azureRedis;
            _dingDing = dingDing;
            _option = option?.Value;
            _configuration = configuration;
            _notificationService = notificationService;
            _coreAPIHttpService = coreAPIHttpService;
            _logger = logger;
            _httpTrigger = httpTrigger;
        }
        /// <summary>
        /// 修改教师信息
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("GetUserInfo")]
        //[Authorize(Roles = "IES")]
        public async Task<IActionResult> GetUserInfo(JsonElement request)
        {
            if (!request.TryGetProperty("key", out JsonElement key)) return BadRequest();

            var location = _option.Location;
            //https://api2-rc.teammodel.cn
            CoreUser core = await _coreAPIHttpService.GetUserInfo(new Dictionary<string, string>()
                {      { "key",$"{key}" }
                }, location, _configuration
                );
            if (core != null)
            {
                var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
                TmdidImplicit tmdidImplicit = await _coreAPIHttpService.Implicit(new Dictionary<string, string> {   { "grant_type", "implicit" },
                                        { "client_id",clientID },
                                        { "account",core.id },
                                        { "nonce",Guid.NewGuid().ToString()} }, _option.Location, _configuration);
                if (tmdidImplicit != null && !string.IsNullOrEmpty(tmdidImplicit.id_token))
                {
                    return Ok(new { coreUser = core, tmdidImplicit });
                }
            }
            return Ok(new { coreUser = core });

        }



        /// <summary>
        /// 修改教师信息
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("set-teacher-info")]
        [AuthToken(Roles = "admin,teacher,area")]
        [Authorize(Roles = "IES")]
        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
            {
               
                switch (true)
                { 
                    //修改常用语系
                    case bool when $"{_opt}".Equals("UpdateLang", StringComparison.OrdinalIgnoreCase) && (request.TryGetProperty("lang", out JsonElement lang)):
                        {
                            Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(userid, new PartitionKey("Base"));
                            if (!string.IsNullOrEmpty($"{lang}"))
                            {
                                teacher.lang = $"{lang}";
                                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("UpdateDefaultSchool", StringComparison.OrdinalIgnoreCase) && (request.TryGetProperty("defaultSchool", out JsonElement _defaultSchool)):
                        {
                            Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(userid, new PartitionKey("Base"));
                            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("UpdateLessonLimit", StringComparison.OrdinalIgnoreCase) && (request.TryGetProperty("lessonLimit", out JsonElement _lessonLimit)):
                        {
                            Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(userid, new PartitionKey("Base"));
                            teacher.lessonLimit = int.Parse($"{_lessonLimit}");
                            await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, userid, new PartitionKey("Base"));
                            return Ok(new { teacher, status = 1 });
                        }
                    //修改教师设置自动将课例发布给谁的设置
                    case bool when $"{_opt}".Equals("UpdateLessonShow", StringComparison.OrdinalIgnoreCase) && (request.TryGetProperty("lessonShow", out JsonElement _lessonShow)):
                        {
                            Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(userid, new PartitionKey("Base"));
                            teacher.lessonShow = _lessonShow.Deserialize<List<string>>();
                            await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, userid, new PartitionKey("Base"));
                            return Ok(new { teacher, status = 1 });
                        }
                    //设置教师的科目信息
                    case bool when $"{_opt}".Equals("SetTeacherSubject", StringComparison.OrdinalIgnoreCase) && request.TryGetProperty("targerTecher", out JsonElement _targetTecher)
                        && request.TryGetProperty("subjectIds", out JsonElement _subjectIds):
                        if (_subjectIds.ValueKind.Equals(JsonValueKind.Array))
                        {

                            if (_targetTecher.ValueKind.Equals(JsonValueKind.Array))
                            {
                                List<string> targetTechers = _targetTecher.ToObject<List<string>>();
                                List<SchoolTeacher> schoolTeachers = new List<SchoolTeacher>();
                                foreach (string targetTecher in targetTechers)
                                {
                                    try
                                    {
                                        SchoolTeacher schoolTeacher = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<SchoolTeacher>($"{targetTecher}", new PartitionKey($"Teacher-{school}"));
                                        schoolTeacher.subjectIds = _subjectIds.ToObject<List<string>>();
                                        await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<SchoolTeacher>(schoolTeacher, $"{targetTecher}", new PartitionKey($"Teacher-{school}"));
                                        schoolTeachers.Add(schoolTeacher);
                                    }
                                    catch (Exception ex)
                                    {
                                        await _dingDing.SendBotMsg($"IES5，{_option.Location}，Teacher/init/set-teacher-info:SetTeacherSubject()\n{ex.Message}\n{ex.StackTrace}{request.ToJsonString()}-{targetTecher}", GroupNames.醍摩豆服務運維群組);
                                    }
                                }
                                return Ok(new { status = 1, schoolTeachers });
                            }
                            else
                            {
                                try
                                {
                                    SchoolTeacher schoolTeacher = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<SchoolTeacher>($"{_targetTecher}", new PartitionKey($"Teacher-{school}"));
                                    schoolTeacher.subjectIds = _subjectIds.ToObject<List<string>>();
                                    await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<SchoolTeacher>(schoolTeacher, $"{_targetTecher}", new PartitionKey($"Teacher-{school}"));
                                    return Ok(new { status = 1, schoolTeacher });
                                }
                                catch (Exception ex)
                                {
                                    await _dingDing.SendBotMsg($"IES5，{_option.Location}，Teacher/init/set-teacher-info:SetTeacherSubject()\n{ex.Message}\n{ex.StackTrace}{request.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
                                    return Ok(new { error = -1, msg = "设置失败" });
                                }

                            }
                        }
                        else
                        {
                            return Ok(new { error = -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);
                                }
                                Teacher targetTeacher = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemAsync<Teacher>($"{_targetTecher}", new PartitionKey($"Base"));
                                _coreAPIHttpService.PushNotify(new List<IdNameCode> { new IdNameCode { id= targetTeacher.id,name= targetTeacher.name,code=targetTeacher.lang} }, "transfer-admin_school", Constant.NotifyType_IES5_Management,
                                    new Dictionary<string, object> { { "tmdname", name },{ "schooName", schoolBase.name } }, _option.Location, _configuration, _dingDing, "");
                                _ = _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");
                                return Ok(new { status = 1 });
                            }
                            else
                            {
                                return BadRequest(new { status = -1, msg = "当前登录账号没有admin权限" });
                            }
                        }
                        else
                        {
                            return BadRequest(new { status = -1, msg = "参数异常！" });
                        }
                    case bool when $"{_opt}".Equals("UpdateMoreInfo", StringComparison.OrdinalIgnoreCase) && (request.TryGetProperty("teacherInfo", out JsonElement _teacherInfo)):
                        var techinfo = _teacherInfo.Deserialize<UpdateTeacherInfo>();
                        TeacherImport teacherImport = null;
                        long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
                        if (techinfo != null && ! string.IsNullOrWhiteSpace(techinfo.id)) {
                            try
                            {
                                SchoolTeacher schoolTeacher = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<SchoolTeacher>(techinfo.id, new PartitionKey($"Teacher-{school}"));
                                schoolTeacher.subjectIds = techinfo.subjectIds;
                                schoolTeacher.job = techinfo.job;
                                await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<SchoolTeacher>(schoolTeacher, techinfo.id, new PartitionKey($"Teacher-{school}"));
                                Azure.Response response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemStreamAsync($"{school}", new PartitionKey("TeacherImport"));
                                if (response.Status == 200)
                                {
                                    teacherImport = JsonDocument.Parse(response.Content).RootElement.Deserialize<TeacherImport>();
                                    var teacherImportInfo= teacherImport.teachers.Find(x =>!string.IsNullOrWhiteSpace(x.id) &&  x.id.Equals(techinfo.id));
                                    if (teacherImportInfo == null)
                                    {
                                        teacherImport.teachers.Add(new ImportTeacher
                                        {
                                            time = now,
                                            status = schoolTeacher.status,
                                            name = schoolTeacher.name,
                                            iname = techinfo.iname,
                                            picture = schoolTeacher.picture,
                                            tmdid = schoolTeacher.id,
                                            note = techinfo.note,
                                            id = techinfo.id
                                        });
                                    }
                                    else
                                    {
                                        teacherImportInfo.tmdid = schoolTeacher.id;
                                        teacherImportInfo.picture = schoolTeacher.picture;
                                        teacherImportInfo.status = schoolTeacher.status;
                                        teacherImportInfo.name = schoolTeacher.name;
                                        teacherImportInfo.iname=techinfo.iname;
                                        teacherImportInfo.note = techinfo.note;
                                    }
                                    await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReplaceItemAsync(teacherImport, $"{school}", new PartitionKey("TeacherImport"));
                                }
                                else {

                                    teacherImport = new TeacherImport { id = $"{school}", code = "TeacherImport", pk = "TeacherImport", teachers = new List<ImportTeacher> { new ImportTeacher {
                                        time = now,
                                        status = schoolTeacher.status,
                                        name = schoolTeacher.name,
                                        iname = techinfo.iname,
                                        picture = schoolTeacher.picture,
                                        tmdid = schoolTeacher.id,
                                        note = techinfo.note,
                                        id = techinfo.id
                                    } } };
                                    await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).CreateItemAsync(teacherImport,   new PartitionKey("TeacherImport"));
                                }
                                return Ok(new { status = 1 });
                            }
                            catch (Exception ex)
                            {
                                await _dingDing.SendBotMsg($"IES5，{_option.Location}，Teacher/init/set-teacher-info:SetTeacherSubject()\n{ex.Message}\n{ex.StackTrace}{request.ToJsonString()}\n{school}", GroupNames.醍摩豆服務運維群組);
                            }
                        }
                        return BadRequest(new { status = -1, msg = "参数异常！" });

                }
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"IES5，{_option.Location}，Teacher/init/set-teacher-info()\n{ex.Message}\n{ex.StackTrace}{request.ToJsonString()}\n{school}", GroupNames.醍摩豆服務運維群組);
                return BadRequest("teacher not exist");

            }
            return BadRequest();

        }

        public class UpdateTeacherInfo { 
            public string id { get; set; }
            public string iname  { get; set; }
            public List<string> subjectIds { get; set; } = new List<string>();
            public string job { get; set; }
            public string note { get; set; }
        }
        //TODO 此API需處理對應前端返回的相關數據
        [ProducesDefaultResponseType]
        [Authorize(Roles = "IES")]
        [HttpPost("get-teacher-info")]
        public async Task<IActionResult> GetTeacherInfo(JsonElement request)
        {
            string lang = "";
            if (HttpContext.Request.Headers.TryGetValue("lang", out var _lang)) {
                lang = $"{_lang}";
            }
            string OAuthShow_domain = HttpContext?.Request?.Host.Host;
            if (OAuthShow_domain.Equals("teammodelos.chinacloudsites.cn"))
            {
                OAuthShow_domain = _option.HostName;
            }
            if (_option.Location.Equals("China"))
            {
                OAuthShow_domain = _option.HostName;
            }
            if (OAuthShow_domain.Equals("localhost"))
            {
                OAuthShow_domain = "test.teammodel.cn";
            }
            if (!request.TryGetProperty("id_token", out JsonElement id_token)) return BadRequest();
            var jwt = new JwtSecurityToken(id_token.GetString());
            //TODO 此驗證IdToken先簡單檢查，後面需向Core ID新API，驗證Token
            var id = jwt.Payload.Sub;
            jwt.Payload.TryGetValue("name", out object name);
            jwt.Payload.TryGetValue("picture", out object picture);
            (string ip, string region) = await LoginService.LoginIp(HttpContext, _searcher);
            try
            {
                Teacher teacher = null;
                TeacherInfo teacherInfo = await TeacherService.TeacherInfo(_azureCosmos, teacher, $"{name}", $"{picture}", id, _azureStorage, _option, _azureRedis, ip, _httpTrigger, $"{_lang}");
                teacherInfo.areas.ForEach(x => { if (x.setting != null) { x.setting.accessConfig = x.setting.accessConfig; } });
                LoginService.LoginLog(HttpContext, _option, _logger, _dingDing, ip, region, id, $"{name}", 200);
                int lessonLimit = teacherInfo.teacher.lessonLimit;
                if (teacherInfo.teacher.lessonLimit == 0)
                {
                    //未设置的的采用系统设置的默认值30
                    lessonLimit = Constant.private_lesson_limit;
                }
                var table = _azureStorage.GetCloudTableClient().GetTableReference("IESOAuth");
                List<string> Codes = new List<string>();
                if (!string.IsNullOrWhiteSpace(id))
                {
                    Codes.Add($" Code {QueryComparisons.Equal} '{id}' ");
                }
                string qurey = $"PartitionKey {QueryComparisons.Equal} 'OAuthShow' and Domain {QueryComparisons.Equal} '{OAuthShow_domain}' and ( { string.Join(" or ", Codes)} )  ";
                var result = await table.ExecuteQuerySegmentedAsync(new TableQuery<OAuthShow>().Where(qurey), null);
                List<OAuthShow> shows = result.Results;

                return Ok(new
                {
                    privateShows = shows?.FindAll(x => x.Scope.Equals("private")).Select(x => new { x.Type, x.Status, x.Scope, x.Code }),
                    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,
                    lessonLimit,
                    teacherInfo.teacher.lessonShow
                });
            }
            catch (CosmosException ex)
            {
                LoginService.LoginLog(HttpContext, _option, _logger, _dingDing, ip, region, id, $"{name}", 500);
                await _dingDing.SendBotMsg($"IES5，{_option.Location}，Teacher/GetTeacherInfo()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
                return BadRequest();
            }
            catch (Exception ex)
            {
                LoginService.LoginLog(HttpContext, _option, _logger, _dingDing, ip, region, id, $"{name}", 500);
                _ = _dingDing.SendBotMsg($"IES5，{_option.Location}，Teacher/GetTeacherInfo()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
                return BadRequest();
            }
        }

        //TODO 此API需處理對應前端返回的相關數據
        [ProducesDefaultResponseType]
        [Authorize(Roles = "IES")]
        [HttpPost("get-school-info")]
        public async Task<IActionResult> GetSchoolInfo(JsonElement request)
        {
            string OAuthShow_domain = HttpContext?.Request?.Host.Host;
            if (OAuthShow_domain.Equals("teammodelos.chinacloudsites.cn") ) {
                OAuthShow_domain = _option.HostName;
            }
            if (_option.Location.Equals("China"))
            {
                OAuthShow_domain = _option.HostName;
            }
            if (OAuthShow_domain.Equals("localhost")) {
                OAuthShow_domain = "test.teammodel.cn";
            }
            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());
                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"));
                List<AreaDto> areas = new List<AreaDto>();
                HashSet<string> areaIds = new HashSet<string>();
                if (teacher.areas.IsNotEmpty())
                {
                    teacher.areas.ForEach(x => {
                        areaIds.Add(x.areaId);
                    });
                }
                if (teacher.schools.IsNotEmpty())
                {
                    teacher.schools.ForEach(x => {
                        if (!string.IsNullOrEmpty(x.areaId))
                        {
                            areaIds.Add(x.areaId);
                        }

                    });
                }
                List<Area> areasDbs = new List<Area>();
                List<AreaSetting> areaSettings = new List<AreaSetting>();
                if (areaIds.Count > 0)
                {
                    string queryText = $"select value(c) from c where c.id in ({string.Join(",", areaIds.Select(x => $"'{x}'"))})";
                    await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Area>(queryText: queryText, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base-Area") }))
                    {
                        areasDbs.Add(item);
                    }
                    await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AreaSetting>(queryText: queryText, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("AreaSetting") }))
                    {
                        areaSettings.Add(item);
                    }
                }
                if (teacher.areas.IsNotEmpty())
                {
                    foreach (var areat in teacher.areas)
                    {

                        Area area = areasDbs.Find(x => x.id.Equals(areat.areaId));
                        AreaSetting setting = null;
                        if (area != null)
                        {
                            setting = areaSettings.Find(x => x.id.Equals(areat.areaId));
                        }

                        int access = 0;
                        if (setting != null && !string.IsNullOrWhiteSpace(setting.accessConfig))
                        {
                            access = 1;
                        }
                        //if (setting != null)
                        //{
                        //    setting.accessConfig = null;
                        //}
                        areas.Add(new AreaDto { areaId = area.id, name = area.name, standard = area.standard, standardName = area.standardName, setting = setting, access = access });
                    }
                }
                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("assist");
                    roles.Add("teacher");
                }
                //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,
                        };
                        try
                        {
                            await client.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<ItemCond>(itemCond, new PartitionKey($"ItemCond-{school_code}"));
                        }
                        catch (CosmosException ex) when (ex.Status == 409)
                        {
                            continue;
                        }
                    }
                }
                string currAreaId = "";
                dynamic currArea = new ExpandoObject();
                if (!string.IsNullOrEmpty(school_base.areaId))
                {
                    try
                    {
                        Area area = areasDbs.Find(x => x.id.Equals(school_base.areaId));
                        AreaSetting setting = null;
                        if (area != null)
                        {
                            //setting =await client.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<AreaSetting>(school_base.areaId, new PartitionKey("AreaSetting"));
                            setting = areaSettings.Find(x => x.id.Equals(school_base.areaId));
                        }

                        int access = 0;
                        AccessConfig accessConfig = null;
                        if (setting != null && !string.IsNullOrWhiteSpace(setting.accessConfig))
                        {
                            access = 1;
                            accessConfig = setting.accessConfig.ToObject<AccessConfig>();
                        }
                        //if (setting!=null&& !string.IsNullOrEmpty(setting.accessConfig)) {
                        //    setting.accessConfig = null;
                        //}
                        currArea = new
                        {
                            areaId = area?.id,
                            name = area?.name,
                            standard = area?.standard,
                            standardName = area?.standardName,
                            setting = setting,
                            access = access,
                            //submitType=accessConfig?.submitType,
                            homeworkType = accessConfig != null && accessConfig.homeworkType.IsNotEmpty() ? accessConfig.homeworkType : new List<string> { "pdf" },
                        };
                        currAreaId = area?.id;
                    }
                    catch (CosmosException)
                    {
                        //数据库捞不到数据

                    }
                }
                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, Website: "IES", scope: Constant.ScopeTeacher, schoolID: school_code.ToString(), areaId: currAreaId, standard: school_base.standard, roles: roles.ToArray(), permissions: permissions.ToArray(), expire: 1);

                //取得班级
                (List < Class > school_classes,_) = await SchoolService.DoGraduateClasses(_httpTrigger, _azureCosmos, null, school_base, _option);
                //取得教室
                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> 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>());
                        }
                    }
                }
                List<SchoolProductSumData> services = new List<SchoolProductSumData>();
                //获取HiTeachCC的授权
                int cc_avaliable = 0;
                await foreach (var item in   client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<int>("select value count(1) from c where c.prodCode='LZLL6ZEI'",
                    requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Product-{school_code}") }))
                {
                    cc_avaliable = item;
                }
                services.Add(new SchoolProductSumData { prodCode = "LZLL6ZEI", avaliable = cc_avaliable });

                Azure.Response productSumResponse = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(school_code, new PartitionKey("ProductSum"));
                if (productSumResponse.Status == 200)
                {
                    var doc = JsonDocument.Parse(productSumResponse.Content);
                    //if (doc.RootElement.TryGetProperty("serial", out JsonElement serial))
                    //{
                    //    serials = serial.ToObject<List<SchoolProductSumData>>();
                    //}
                    if (doc.RootElement.TryGetProperty("service", out JsonElement service))
                    {
                        services .AddRange(service.ToObject<List<SchoolProductSumData>>());
                    }
                }
                //校本課綱 [式樣未定 先不取]

                //取得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);
                areas.ForEach(x => { { if (x.setting != null) { x.setting.accessConfig = x.setting.accessConfig; } } });

                int lessonLimit = teacher.lessonLimit;
                if (teacher.lessonLimit == 0)
                {
                    //未设置的的采用系统设置的默认值30
                    lessonLimit = Constant.private_lesson_limit;
                }
                var table = _azureStorage.GetCloudTableClient().GetTableReference("IESOAuth");
                List<string> Codes = new List<string>();
                if (!string.IsNullOrWhiteSpace(id))
                {
                    Codes.Add($" Code {QueryComparisons.Equal} '{id}' ");
                }
                if (!string.IsNullOrWhiteSpace(school_code))
                {
                    Codes.Add($" Code {QueryComparisons.Equal} '{school_code}' ");
                }
                if (!string.IsNullOrWhiteSpace(currAreaId))
                {
                    Codes.Add($" Code {QueryComparisons.Equal} '{currAreaId}' ");
                }

               
                string tbqurey = $"PartitionKey {QueryComparisons.Equal} 'OAuthShow' and Domain {QueryComparisons.Equal} '{OAuthShow_domain}' and ( { string.Join(" or ", Codes)} )  ";
                var result = await table.ExecuteQuerySegmentedAsync(new TableQuery<OAuthShow>().Where(tbqurey), null);
                List<OAuthShow> shows = result.Results;
                List<OAuthShow> schoolShow = new List<OAuthShow>();
                List<OAuthShow> areaShow = new List<OAuthShow>();
                var schoolShows = shows?.Where(y => !y.Scope.Equals("private"));
               
                if (schoolShows.Any())
                {
                    
                    //剩下的area 和school 的。统一处理为school的，并去重。
                    schoolShows.ToList().ForEach(y => { y.Scope = "school"; y.Code = school_code; });
                    schoolShows.GroupBy(x => $"{x.Type}{x.Scope}").Select(s => new { key = s.Key, list = s.ToList() }).ToList().ForEach(z => {
                        schoolShow.Add(z.list.First());
                    });
                }
                //只有管理员才能进行艺术评价相关设置关联。
                List<IdCode> hasArt = new List<IdCode>();
                if (roles.Contains("admin"))
                {
                    if (schoolShows.Where(x => x.Type.Equals("art")).Any())
                    {
                        school_base?.period.ForEach(x => {
                            var has_music = x?.subjects.Find(x => !string.IsNullOrWhiteSpace(x.bindId) &&  x.bindId.Equals("subject_music"));
                            if (has_music == null)
                            {
                                hasArt.Add(new IdCode { id = x.id, code = "subject_music" });
                            }
                            var has_painting = x.subjects.Find(x => !string.IsNullOrWhiteSpace(x.bindId) && x.bindId.Equals("subject_painting"));
                            if (has_painting == null)
                            {
                                hasArt.Add(new IdCode { id = x.id, code = "subject_painting" });
                            }
                        });
                    }
                }
                List<OAuthShow> areaShows = new List<OAuthShow>();
                //处理区级是否有艺术评价模组授权
                if (areas.IsNotEmpty())
                {
                    List<string> area_Codes = new List<string>();
                    areas.ForEach(x => {
                        area_Codes.Add($" Code {QueryComparisons.Equal} '{x.areaId}' ");
                    });
                    string area_tbqurey = $"PartitionKey {QueryComparisons.Equal} 'OAuthShow' and Domain {QueryComparisons.Equal} '{OAuthShow_domain}' and Type {QueryComparisons.Equal} 'art' and ( {string.Join(" or ", area_Codes)} )  ";
                    var area_result = await table.ExecuteQuerySegmentedAsync(new TableQuery<OAuthShow>().Where(area_tbqurey), null);
                    areaShows = area_result.Results;
                }
                return Ok(new
                {
                    privateShows = shows?.FindAll(x => x.Scope.Equals("private")).Select(x => new { x.Type, x.Status, x.Scope, x.Code }),
                    schoolShows = schoolShow.Select(x => new { x.Type, x.Status, x.Scope, x.Code }),
                    areaShows = areaShows.Select(x => new { x.Type, x.Status, x.Scope, x.Code }),
                    auth_token,
                    blob_uri,
                    blob_sas,
                    school_base,
                    school_courses,
                    school_classes,
                    school_rooms,
                    size,
                    osblob_uri,
                    osblob_sas,
                    status = 200,
                    areas,
                    currArea,
                    lessonLimit,
                    teacher.lessonShow,
                    productSum = new
                    {
                        //serial = serials,
                        service = services
                    }
                });
            }
            catch (CosmosException ex)
            {
                HttpContext.Request.Headers.TryGetValue("referer", out var referer);
                HttpContext.Request.Headers.TryGetValue("sec-ch-ua", out var chua);
                HttpContext.Request.Headers.TryGetValue("sec-ch-ua-platform", out var platform);
                HttpContext.Request.Headers.TryGetValue("user-agent", out var useragent);
                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.醍摩豆服務運維群組);
                return BadRequest(new { status = ex.Status });
            }
            catch (Exception ex)
            {
                HttpContext.Request.Headers.TryGetValue("referer", out var referer);
                HttpContext.Request.Headers.TryGetValue("sec-ch-ua", out var chua);
                HttpContext.Request.Headers.TryGetValue("sec-ch-ua-platform", out var platform);
                HttpContext.Request.Headers.TryGetValue("user-agent", out var useragent);
                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.醍摩豆服務運維群組);
                return BadRequest(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}\n{ex.StackTrace}{request.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 申請或同意邀請加入學校
        /// </summary>
        /// 
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "teacher")]
        [HttpPost("join-school")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> JoinSchool(JsonElement request)
        {
            try
            {
                if (!request.TryGetProperty("grant_type", out JsonElement grant_type)) return BadRequest();  //"invite":學校邀請 "request":老師申請 "join":"成為學校老師"，leave 离开，cancel 取消。
                if (!request.TryGetProperty("school_code", out JsonElement school_code)) return BadRequest();
                if (!request.TryGetProperty("school_name", out JsonElement school_name)) return BadRequest();
                ///当邀请某个老师加入学校则需要知道是谁邀请的
                //if (!request.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}"));

                    Azure.Response response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemStreamAsync($"{school_code}", new PartitionKey("TeacherImport"));
                    TeacherImport teacherImport = null;
                    if (response.Status == 200)
                    {
                        teacherImport = JsonDocument.Parse(response.Content).RootElement.Deserialize<TeacherImport>();
                        var tchs = teacherImport?.teachers?.RemoveAll(x => !string.IsNullOrWhiteSpace(x.id) && x.id.Equals(id));
                        await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReplaceItemAsync(teacherImport, $"{school_code}", new PartitionKey("TeacherImport"));
                    }

                    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}"));
                    }
                    Azure.Response responseImport = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemStreamAsync($"{school_code}", new PartitionKey("TeacherImport"));
                    TeacherImport teacherImport = null;
                    if ($"{grant_type}".Equals("request"))
                    {

                        if (responseImport.Status == 200)
                        {
                            teacherImport = JsonDocument.Parse(responseImport.Content).RootElement.Deserialize<TeacherImport>();
                            var tchs = teacherImport?.teachers?.FindAll(x => !string.IsNullOrWhiteSpace(x.iname) && x.iname.Equals($"{name}") && string.IsNullOrWhiteSpace(x.id));
                            if (tchs.IsNotEmpty())
                            {
                                var tch = tchs[0];
                                string ujson = null;
                                var content = new StringContent(new List<string> { $"{id}" }.ToJsonString(), Encoding.UTF8, "application/json");
                                ujson = await _coreAPIHttpService.GetUserInfos(content);
                                List<CoreUser> coreUsers = new List<CoreUser>();
                                if (!string.IsNullOrWhiteSpace(ujson))
                                {
                                    coreUsers = ujson.ToObject<List<CoreUser>>();
                                }
                                if (coreUsers.IsNotEmpty())
                                {
                                    tch.phone = coreUsers[0].mobile;
                                    tch.email = coreUsers[0].mail;
                                }
                                tch.id = $"{id}";
                                tch.picture = $"{picture}";
                                tch.status = $"{grant_type}";
                                tch.time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
                                tch.tmdid = id;
                                tch.name = $"{name }";
                                await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReplaceItemAsync(teacherImport, $"{school_code}", new PartitionKey("TeacherImport"));
                            }
                        }
                    }
                    if (grant_type.ToString().Equals("join"))
                    {
                        if (responseImport.Status == 200)
                        {
                            teacherImport = JsonDocument.Parse(responseImport.Content).RootElement.Deserialize<TeacherImport>();
                            teacherImport?.teachers.ForEach(x => {
                                if (!string.IsNullOrWhiteSpace(x.id) && !string.IsNullOrWhiteSpace(teacher.id) && x.id.Equals(teacher.id))
                                {
                                    x.name = teacher.name;
                                    x.status = "join";
                                    x.time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
                                    x.picture = teacher.picture;
                                }
                            });
                            await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReplaceItemAsync(teacherImport, $"{school_code}", new PartitionKey("TeacherImport"));
                            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);
                    }
                    string code = grant_type.GetString();
                    if (grant_type.GetString().Equals("join"))
                    {
                        code = "invite-join";
                    }
                    if (teachers.IsNotEmpty())
                    {

                        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 val = await _notificationService.SendNotification(clientID, clientSecret, location, url, notification);
                    }
                    if (teachers.IsNotEmpty()) {
                        string sql = $"select c.id, c.name ,c.lang as code from c where c.id in ({string.Join(",", teachers.Select(x => $"'{x.id}'"))})";
                        List<IdNameCode> idNameCodes = new List<IdNameCode>();
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
                            .GetItemQueryIterator<IdNameCode>(queryText: sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") })) 
                        {
                            idNameCodes.Add(item);
                        }
                        _coreAPIHttpService.PushNotify(idNameCodes, $"{code}_school", Constant.NotifyType_IES5_Management,
                                  new Dictionary<string, object> { { "tmdname", name }, { "schooName", schoolBase.name } }, _option.Location,_configuration,_dingDing, "") ;
                    }
                    return Ok(new { stauts = 1 });
                }
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"TEAMModel，{_option.Location}，Init/JoinSchool()\n{ex.Message}\n{ex.StackTrace}\n{request.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 通过学段获取学校班级、教室信息; 教师id获取课程信息
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-info-prdid")]
        [Authorize(Roles="IES")]
        public async Task<IActionResult> GetInfoByPeriodId(JsonElement jsonElement)
        {
            string OAuthShow_domain = HttpContext?.Request?.Host.Host;
            if (OAuthShow_domain.Equals("teammodelos.chinacloudsites.cn"))
            {
                OAuthShow_domain = _option.HostName;
            }
            if (_option.Location.Equals("China"))
            {
                OAuthShow_domain = _option.HostName;
            }
            if (OAuthShow_domain.Equals("localhost"))
            {
                OAuthShow_domain = "test.teammodel.cn";
            }
            try
            {
                if (!jsonElement.TryGetProperty("id_token", out JsonElement id_token)) return BadRequest();
                if (!jsonElement.TryGetProperty("school_code", out JsonElement school_code)) return BadRequest();
                jsonElement.TryGetProperty("periodId", out JsonElement _periodId);

                var jwt = new JwtSecurityToken(id_token.GetString());
                var tchId = jwt.Payload.Sub;

                var client = _azureCosmos.GetCosmosClient();
                string periodId = null;
                if (!string.IsNullOrEmpty($"{_periodId}"))
                    periodId = $"{_periodId}";
                else
                {
                    School school_base = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>($"{school_code}", new PartitionKey("Base"));
                    periodId = school_base.period[0].id;
                }

                //获取班级信息
                List<object> school_Classes = new();
                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}'";
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: classesSql, 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<object> school_Courses = new();
                var query = $"SELECT value(c) FROM c JOIN A1 IN c.schedule where A1.teacherId='{tchId}' and c.period.id='{periodId}'";
                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>());
                        }
                    }
                }

                //获取教室
                List<Room> school_Rooms = new();
                //string roomSql = $"select value(c) from c where c.periodId = '{periodId}'";   //注释原因：教室暂时不绑定学段信息
                string roomSql = $"select value(c) from c";
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Room>(queryText: roomSql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Room-{school_code}") }))
                {
                    school_Rooms.Add(item);
                }

                //获取学校行政班
                List<GroupListDto> school_GroupList = new();
                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";

                string schoolglSql = $"{glSql} where c.periodId ='{periodId}'";
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<GroupListDto>(queryText: schoolglSql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{school_code}") })) 
                {
                    school_GroupList.Add(item);
                }

                //获取个人行政班
                List<GroupListDto> personal_GroupList = new();
                string pglSql = $"{glSql} where c.creatorId='{tchId}'";
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<GroupListDto>(queryText: pglSql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("GroupList") }))
                {
                    personal_GroupList.Add(item);
                }

                return Ok(new { status = 200, school_Classes, school_Courses, school_Rooms, school_GroupList, personal_GroupList });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"IES5，{_option.Location}，Teacher/init/get-info-prdid()\n{ex.Message}\n{ex.StackTrace}\n{jsonElement.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
                return BadRequest(new { status = 500 });
            }
        }

        //課綱的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>();
            }
        }
    }
}