TEAMModelOS/TEAMModelOS/Controllers/Client/HiTeachController.cs

using Azure.Cosmos;
using Azure.Storage.Blobs.Models;
using Azure.Storage.Sas;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Options;
using System;
using System.Collections.Generic;
using System.IdentityModel.Tokens.Jwt;
using System.IO;
using System.Linq;
using System.Text;
using System.Text.Json;
using System.Threading.Tasks;
using TEAMModelOS.Models;
using TEAMModelOS.Filter;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.Extension;
using Microsoft.Azure.Cosmos.Table;
using TEAMModelOS.SDK.Models;
using System.Dynamic;
using HTEXLib.COMM.Helpers;
using StackExchange.Redis;
using TEAMModelOS.SDK.Models.Cosmos.Common;
using TEAMModelOS.SDK;
using Microsoft.Extensions.Configuration;
using Azure.Messaging.ServiceBus;
using TEAMModelOS.SDK.Services;
using TEAMModelOS.SDK.Models.Service;

namespace TEAMModelOS.Controllers.Client
{
    [ProducesResponseType(StatusCodes.Status200OK)]
    [ProducesResponseType(StatusCodes.Status400BadRequest)]
    //[Authorize(Roles = "HiTeach")]
    [Route("hiteach")]
    [ApiController]

    public class HiTeachController : ControllerBase
    {
        private readonly AzureStorageFactory _azureStorage;
        private readonly AzureRedisFactory _azureRedis;
        private readonly AzureCosmosFactory _azureCosmos;
        private readonly DingDing _dingDing;
        private readonly Option _option;
        private readonly SnowflakeId _snowflakeId;
        private readonly AzureServiceBusFactory _serviceBus;
        private readonly IConfiguration _configuration;
        private readonly CoreAPIHttpService _coreAPIHttpService;
        private readonly IPSearcher _searcher;
        private readonly HttpTrigger _httpTrigger;

        public HiTeachController(
            AzureStorageFactory azureStorage,
            AzureRedisFactory azureRedis,
            AzureCosmosFactory azureCosmos,
            DingDing dingDing,
            SnowflakeId snowflakeId,
            IOptionsSnapshot<Option> option,
            AzureServiceBusFactory serviceBus,
            IConfiguration configuration,
            CoreAPIHttpService coreAPIHttpService, IPSearcher searcher, HttpTrigger httpTrigger)
        {
            _azureStorage = azureStorage;
            _azureRedis = azureRedis;
            _azureCosmos = azureCosmos;
            _dingDing = dingDing;
            _snowflakeId = snowflakeId;
            _option = option?.Value;
            _serviceBus = serviceBus;
            _configuration = configuration;
            _coreAPIHttpService = coreAPIHttpService;
            _searcher = searcher;
            _httpTrigger = httpTrigger;
        }
        /// <summary>
        /// 更新课堂记录
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("update-lesson-record")]
        public async Task<IActionResult> UpdateLessonRecord(JsonElement request)
        {
            var client = _azureCosmos.GetCosmosClient();
            if (!request.TryGetProperty("lesson_id", out JsonElement _lessonId)) return BadRequest();
            if (!request.TryGetProperty("tmdid", out JsonElement _tmdid)) return BadRequest();
            request.TryGetProperty("name", out JsonElement name);
            request.TryGetProperty("school", out JsonElement _school);
            if (!request.TryGetProperty("scope", out JsonElement _scope)) return BadRequest();
            request.TryGetProperty("grant_types", out JsonElement _grant_types);
            string tbname;
            string code;

            if (_scope.GetString().Equals("school") && !string.IsNullOrWhiteSpace(_school.GetString()))
            {
                code = $"LessonRecord-{_school}";
                tbname = "School";
            }
            else if ($"{_scope}".Equals("private"))
            {

                code = $"LessonRecord";
                tbname = "Teacher";
            }
            else
            {
                return BadRequest();
            }
            try
            {
                LessonRecord lessonRecord = await client.GetContainer(Constant.TEAMModelOS, tbname).ReadItemAsync<LessonRecord>($"{_lessonId}", new PartitionKey(code));
                List<LessonUpdate> updates = new List<LessonUpdate>() { new LessonUpdate { grant_type = "up-base" } };
                if (_grant_types.ValueKind.Equals(JsonValueKind.Array))
                {
                    updates = _grant_types.ToObject<List<LessonUpdate>>();
                    if (!updates.Select(x => x.grant_type).Contains("up-base"))
                    {
                        updates.Add(new LessonUpdate { grant_type = "up-base" });
                    }
                }
                if (!string.IsNullOrWhiteSpace($"{name}"))
                {
                    lessonRecord.name = $"{name}";
                    await client.GetContainer(Constant.TEAMModelOS, tbname).ReplaceItemAsync<LessonRecord>(lessonRecord, $"{_lessonId}", new PartitionKey(code));
                }
                var ActiveTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
                string msg = null;
                msg = new { lesson_id = $"{_lessonId}", tmdid = $"{_tmdid}", grant_types = updates, school = $"{_school}", scope = $"{_scope}" }.ToJsonString();
                var messageChange = new ServiceBusMessage(msg);
                messageChange.ApplicationProperties.Add("name", "LessonRecordEvent");
                //await _dingDing.SendBotMsg($"{_option.Location},课堂id:{_lessonId} 更新事件,{msg}", GroupNames.醍摩豆服務運維群組);
                await _serviceBus.GetServiceBusClient().SendMessageAsync(ActiveTask, messageChange);
                return Ok(new { status = 200 });
            }
            catch (CosmosException ex) when (ex.Status == 404)
            {
                return BadRequest("课堂记录不存在");
            }
            catch (Exception ex)
            {
                return BadRequest();
            }
        }

        /// <summary>
        /// 创建课堂开课记录
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        // [AuthToken(Roles = "teacher,admin")]
        [HttpPost("create-lesson-record")]
        public async Task<IActionResult> CreateLessonRecord(JsonElement request)
        {
            if (!request.TryGetProperty("lesson", out JsonElement _lesson)) return BadRequest();
            var client = _azureCosmos.GetCosmosClient();
            LessonRecord lessonRecord = _lesson.ToObject<LessonRecord>();
            if (!string.IsNullOrEmpty(lessonRecord.scope) && !string.IsNullOrEmpty(lessonRecord.tmdid) && !string.IsNullOrEmpty(lessonRecord.id))
            {
                RedisValue value = default;
                string tbname = null;
              
                if (lessonRecord.scope.Equals("school") && !string.IsNullOrEmpty(lessonRecord.school))
                {
                    lessonRecord.code = $"LessonRecord-{lessonRecord.school}";
                    tbname = "School";
                    
                   
                }
                if (lessonRecord.scope.Equals("private"))
                {
                    lessonRecord.code = $"LessonRecord";
                    tbname = "Teacher";
                   
                }
                if (tbname == null)
                {
                    return BadRequest("参数异常：scope应为school或private，scope=school  ,school字段不能为空");
                }
                if (lessonRecord.startTime == 0)
                {
                    lessonRecord.startTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
                }
                lessonRecord.pk = "LessonRecord";
                try
                {
                    await client.GetContainer(Constant.TEAMModelOS, tbname).CreateItemAsync(lessonRecord, new PartitionKey(lessonRecord.code));
                   
                    var ActiveTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
                    var messageChange = new ServiceBusMessage(lessonRecord.ToJsonString());
                    messageChange.ApplicationProperties.Add("name", "LessonRecordEvent");
                    await _serviceBus.GetServiceBusClient().SendMessageAsync(ActiveTask, messageChange);
                    return Ok(new { status = 200  });
                }
                catch (Exception ex)
                {
                    await _dingDing.SendBotMsg($"IES5，{_option.Location}， hiteach/create-lesson-record:()\n{ex.Message}\n{ex.StackTrace}{request.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
                    return BadRequest();
                }
            }
            else
            {
                return BadRequest();
            }
        }
        [ProducesDefaultResponseType]
        [HttpPost("get-teacher-info")]
        public async Task<IActionResult> GetTeacherInfo()
        {
            //Debug
            //string json = System.Text.Json.JsonSerializer.Serialize(id_token);
            try
            {
                string id_token = HttpContext.GetXAuth("IdToken");
                (string ip, string region) = await LoginService.LoginIp(HttpContext, _searcher);
                if (string.IsNullOrEmpty(id_token)) return BadRequest();
                var jwt = new JwtSecurityToken(id_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);
                int total = 0;
                List<object> schools = new List<object>();
                string defaultschool = null;
                //TODK 取得Teacher 個人相關數據(課程清單、虛擬教室清單、歷史紀錄清單等)，學校數據另外API處理，多校切換時不同
                var client = _azureCosmos.GetCosmosClient();
                var response = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemStreamAsync(id, new PartitionKey("Base"));
                if (response.Status == 200)
                {
                    var jsonsc = await JsonDocument.ParseAsync(response.ContentStream);
                    if (jsonsc.RootElement.TryGetProperty("size", out JsonElement size) && size.ValueKind.Equals(JsonValueKind.Number))
                    {
                        total = int.Parse($"{size}");
                        
                    }
                    if (jsonsc.RootElement.TryGetProperty("schools", out JsonElement value))
                    {
                        foreach (var obj in value.EnumerateArray())
                        {
                            string statusNow = obj.GetProperty("status").ToString();
                            if (statusNow.Equals("join")) //成為老師的才放入
                            {
                                dynamic schoolExtobj = new ExpandoObject();
                                var schoolJson = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{obj.GetProperty("schoolId")}", new PartitionKey("Base"));
                                var school = await JsonDocument.ParseAsync(schoolJson.ContentStream);
                                schoolExtobj.schoolId = obj.GetProperty("schoolId");
                                schoolExtobj.name = school.RootElement.GetProperty("name");
                                schoolExtobj.status = obj.GetProperty("status");
                                schoolExtobj.picture = school.RootElement.GetProperty("picture");
                                schools.Add(schoolExtobj);
                                var sctch = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(id, new PartitionKey($"Teacher-{obj.GetProperty("schoolId")}"));
                                if (sctch.Status == 200 && sctch != null && sctch.ContentStream != null) {
                                    var jsonDoc = await JsonDocument.ParseAsync(sctch.ContentStream);
                                    SchoolTeacher schoolTeacher = jsonDoc.RootElement.ToObject<SchoolTeacher>();
                                    total += schoolTeacher.size;
                                }
                            }
                        }
                    }
                   
                    //預設學校ID
                    if (jsonsc.RootElement.TryGetProperty("defaultSchool", out JsonElement valueD) && !string.IsNullOrEmpty(valueD.ToString()))
                    {
                        defaultschool = valueD.ToString();
                    }
                }
                else
                {
                    //如果沒有，則初始化Teacher基本資料到Cosmos
                    Teacher teacher = new Teacher
                    {
                        createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
                        id = id,
                        pk = "Base",
                        code = "Base",
                        name = name?.ToString(),
                        picture = picture?.ToString(),
                        //创建账号并第一次登录IES5则默认赠送1G
                        size = 1,
                        defaultSchool = null,
                        schools = new List<Teacher.TeacherSchool>(),
                    };
                    total = 1;
                    teacher = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").CreateItemAsync<Teacher>(teacher, new PartitionKey("Base"));
                }

               
                //老師個人課程清單
                List<object> courses = new List<object>();
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryStreamIterator(queryText: $"SELECT c.id, c.name, c.schedule, c.scope FROM c ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Course-{id}") }))
                {
                    var jsontcs = await JsonDocument.ParseAsync(item.ContentStream);
                    if (jsontcs.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in jsontcs.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            dynamic courseExtobj = new ExpandoObject();
                            courseExtobj.id = Convert.ToString(obj.GetProperty("id"));
                            courseExtobj.name = Convert.ToString(obj.GetProperty("name"));
                            courseExtobj.scope = Convert.ToString(obj.GetProperty("scope"));
                            List<object> classes = new List<object>();
                            if (obj.TryGetProperty("schedule", out JsonElement schedule))
                            {
                                foreach (var scheduleobj in schedule.EnumerateArray())
                                {
                                    dynamic classExtobj = new ExpandoObject();
                                    classExtobj.id = null;
                                    classExtobj.code = null;
                                    classExtobj.teacher = null;
                                    if (scheduleobj.TryGetProperty("teacherId", out JsonElement teacherId) && !string.IsNullOrWhiteSpace(Convert.ToString(teacherId)))
                                    {
                                        await foreach (var teaitem in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryStreamIterator(queryText: $"SELECT c.id, c.name FROM c WHERE c.id = '{teacherId}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
                                        {
                                            var jsontea = await JsonDocument.ParseAsync(teaitem.ContentStream);
                                            foreach (var teaobj in jsontea.RootElement.GetProperty("Documents").EnumerateArray())
                                            {
                                                classExtobj.teacher = new ExpandoObject();
                                                classExtobj.teacher = teaobj.ToObject<object>();
                                            }
                                        }
                                    }
                                    classExtobj.scope = "private";
                                    int stuCount = 0;
                                    string stuListId = Convert.ToString(scheduleobj.GetProperty("stulist"));
                                    classExtobj.stuListId = stuListId;
                                    await foreach (var stuitem in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryStreamIterator(queryText: $"SELECT c.id, c.name, c.tcount, c.scount  FROM c WHERE c.id = '{stuListId}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("GroupList") }))
                                    {
                                        //取得學生總數
                                        var jsonstu = await JsonDocument.ParseAsync(stuitem.ContentStream);
                                        foreach (var stuobj in jsonstu.RootElement.GetProperty("Documents").EnumerateArray())
                                        {
                                            classExtobj.name = stuobj.GetProperty("name");
                                            stuCount += stuobj.GetProperty("scount").GetInt32();
                                            stuCount += stuobj.GetProperty("tcount").GetInt32();
                                        }
                                    }
                                    classExtobj.stuCnt = stuCount;
                                    classExtobj.grpCnt = 0;
                                    classExtobj.gradeId = null;
                                    classExtobj.year = 0;

                                    classes.Add(classExtobj);
                                }
                            }
                            courseExtobj.classes = classes;

                            courses.Add(courseExtobj);
                        }
                    }
                }

                //取得老師個人評測 
                List<object> exams = new List<object>();
                //取得評測ID List (HiTeach只取source='1'(課中评量) && progress = 'going'(進行中))
                List<string> examIdList = new List<string>();
                await foreach (var exam in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryStreamIterator(queryText: $"SELECT c.id FROM c where (c.status<>404 or IS_DEFINED(c.status) = false ) and  c.source = '1' AND c.progress = 'going'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Exam-{id}") }))
                {
                    using var json = await JsonDocument.ParseAsync(exam.ContentStream);
                    if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            examIdList.Add(obj.GetProperty("id").GetString());
                        }
                    }
                }
                //取得有作答的評測班級
                Dictionary<string, List<string>> examClassFinDic = new Dictionary<string, List<string>>();
                await foreach (var exam in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryStreamIterator(queryText: $"SELECT  c.examId, c.info.id as classId FROM c where (c.status<>404 or IS_DEFINED(c.status) = false ) and  ARRAY_CONTAINS({JsonSerializer.Serialize(examIdList)}, c.examId) AND c.progress=true", requestOptions: new QueryRequestOptions() { }))
                {
                    var jsonecr = await JsonDocument.ParseAsync(exam.ContentStream);
                    if (jsonecr.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in jsonecr.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            string examId = obj.GetProperty("examId").ToString();
                            string classId = obj.GetProperty("classId").ToString();
                            if (examClassFinDic.ContainsKey(examId) && !examClassFinDic[examId].Contains(classId))
                            {
                                examClassFinDic[examId].Add(classId);
                            }
                            else
                            {
                                List<string> classIdList = new List<string>();
                                classIdList.Add(classId);
                                examClassFinDic.Add(examId, classIdList);
                            }
                        }
                    }
                }
                //取得評測資料
                await foreach (var exam in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryStreamIterator(queryText: $"SELECT c.code, c.id, c.name, c.createTime, c.startTime, c.endTime ,c.year, c.source, c.type, c.progress, c.stuCount, c.scope, c.owner, c.period, c.grades, c.subjects, c.classes, c.stuLists, ARRAY(SELECT p.id, p.code, p.name, p.blob, p.scope FROM p IN c.papers) AS papers FROM c WHERE ARRAY_CONTAINS({JsonSerializer.Serialize(examIdList)}, c.id)", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Exam-{id}") }))
                {
                    var jsonex = await JsonDocument.ParseAsync(exam.ContentStream);
                    if (jsonex.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in jsonex.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            dynamic examExtobj = new ExpandoObject();
                            string examId = obj.GetProperty("id").GetString();
                            examExtobj.code = obj.GetProperty("code");
                            examExtobj.id = examId;
                            examExtobj.name = obj.GetProperty("name");
                            examExtobj.createTime = obj.GetProperty("createTime");
                            examExtobj.startTime = obj.GetProperty("startTime");
                            examExtobj.endTime = obj.GetProperty("endTime");
                            examExtobj.year = obj.GetProperty("year");
                            examExtobj.source = obj.GetProperty("source");
                            examExtobj.type = obj.GetProperty("type");
                            examExtobj.progress = obj.GetProperty("progress");
                            examExtobj.stuCount = obj.GetProperty("stuCount");
                            examExtobj.scope = obj.GetProperty("scope");
                            examExtobj.owner = obj.GetProperty("owner");
                            examExtobj.period = obj.GetProperty("period");
                            examExtobj.grades = obj.GetProperty("grades");
                            examExtobj.subjects = obj.GetProperty("subjects");
                            examExtobj.classes = (obj.TryGetProperty("classes", out JsonElement classes)) ? classes.ToObject<List<string>>() : new List<string>();
                            examExtobj.stuLists = (obj.TryGetProperty("stuLists", out JsonElement stuLists)) ? stuLists.ToObject<List<string>>() : new List<string>();
                            examExtobj.finishClasses = (examClassFinDic.ContainsKey(examId)) ? examClassFinDic[examId] : new List<string>();
                            examExtobj.papers = obj.GetProperty("papers");
                            //examExtobj = obj.ToObject<object>();
                            exams.Add(examExtobj);
                        }
                    }
                }
                //用户在线记录
                try
                {
                    _ = _httpTrigger.RequestHttpTrigger(new { school = defaultschool, scope = $"{Constant.ScopeTeacher}", id = $"{id}", ip = $"{ip}", expire = 1 }, _option.Location, "online-record");
                }
                catch { }

                //取得Teacher Blob 容器位置及SAS 
                var container = _azureStorage.GetBlobContainerClient(id);
                await container.CreateIfNotExistsAsync(PublicAccessType.None); //嘗試創建Teacher私有容器，如存在則不做任何事，保障容器一定存在
                var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS(id, BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List | BlobContainerSasPermissions.Delete);
                var (blob_uri_read, blob_sas_read) = _azureStorage.GetBlobContainerSAS(id, BlobContainerSasPermissions.Read);
                var (blob_uri_write, blob_sas_write) = _azureStorage.GetBlobContainerSAS(id, BlobContainerSasPermissions.Write);

                 RedisValue redisValue = default;
                long blobsize = 0;
                _azureRedis.GetRedisClient(8).HashGet($"Blob:Record", id);
                if (redisValue != default && !redisValue.IsNullOrEmpty)
                {
                    JsonElement record = redisValue.ToString().ToObject<JsonElement>();
                    if (record.TryGetInt64(out blobsize))
                    {
                    }
                }
                else
                {
                    var messageBlob = new ServiceBusMessage(new { id = Guid.NewGuid().ToString(), progress = "update", name = $"{id}" }.ToJsonString()); ;
                    messageBlob.ApplicationProperties.Add("name", "BlobRoot");
                    var ActiveTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
                    await _serviceBus.GetServiceBusClient().SendMessageAsync(ActiveTask, messageBlob);
                }
                double blobUsed = blobsize / 1073741824.0 ; //1073741824  1G
                return Ok(new { blob_uri, blob_sas, blob_sas_read, blob_sas_write, schools, defaultschool, courses, exams , blobTotal=total, blobUsed });

            }
            catch (Exception ex)
            {
                // await _dingDing.SendBotMsg($"CoreAPI2，{_option.Location}，hiteach/GetTeacherInfo()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
                return BadRequest();
            }
        }


        [ProducesDefaultResponseType]
        [HttpPost("get-school-info")]
        public async Task<IActionResult> GetSchoolInfo(JsonElement requert)
        {
            try
            {
                string id_token = HttpContext.GetXAuth("IdToken");
                (string ip, string region) = await LoginService.LoginIp(HttpContext, _searcher);
                if (string.IsNullOrEmpty(id_token)) return BadRequest();
                if (!requert.TryGetProperty("school_code", out JsonElement school_code)) return BadRequest();
                var jwt = new JwtSecurityToken(id_token);
                if (!jwt.Payload.Iss.Equals("account.teammodel", StringComparison.Ordinal)) return BadRequest();
                var id = jwt.Payload.Sub;

                var client = _azureCosmos.GetCosmosClient();

                //取得學校學段、年級、科目、考試類型
                List<object> periods = new List<object>();
                List<object> grades = new List<object>();
                List<object> subjects = new List<object>();
                List<object> examTypes = new List<object>();
                int total = 0;
                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("size", out JsonElement _size) && _size.ValueKind.Equals(JsonValueKind.Number)) {
                        total = int.Parse($"{_size}");
                    }
                    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))
                            {
                                int gradeIndex = 0;
                                foreach (var gradeName in gradesJobj.EnumerateArray()) //2021-06-09 [式樣]grades改為array(string)
                                {
                                    dynamic gradeExtobj = new ExpandoObject();
                                    gradeExtobj.id = gradeIndex.ToString();
                                    gradeExtobj.name = gradeName;
                                    gradeExtobj.periodId = periodinfo.GetProperty("id");
                                    grades.Add(gradeExtobj);
                                    gradeIndex++;
                                }
                            }
                            if (periodinfo.TryGetProperty("subjects", out JsonElement subjectsJobj))
                            {
                                foreach (var subjectinfo in subjectsJobj.EnumerateArray())
                                {
                                    dynamic subjectExtobj = new ExpandoObject();
                                    subjectExtobj.id = subjectinfo.GetProperty("id");
                                    subjectExtobj.name = subjectinfo.GetProperty("name");
                                    subjectExtobj.periodId = periodinfo.GetProperty("id");
                                    subjects.Add(subjectExtobj);
                                }
                            }
                            if (periodinfo.TryGetProperty("analysis", out JsonElement periodanalysisJobj))
                            {
                                if (periodanalysisJobj.TryGetProperty("type", out JsonElement examTypeJobj))
                                {
                                    foreach (var examType in examTypeJobj.EnumerateArray())
                                    {
                                        examTypes.Add(examType.ToObject<object>());
                                    }
                                }
                            }
                        }
                    }
                }
                else //無此學校資料
                {
                    return BadRequest();
                }
               
                //該老師排定的學校課程
                List<object> courses = new List<object>();
                List<string> classIds = new List<string>(); //班級ID列表 篩選校園評測用
                List<string> groupIds = new List<string>(); //團體ID列表 篩選校園評測用
                var query = $"SELECT c.id, c.name, c.scope, c.subject, schedule.classId AS scheduleClassId, schedule.teacher AS scheduleTeacher, schedule.stulist AS scheduleStulist, schedule.time AS scheduleTime, schedule.notice AS scheduleNotice FROM c JOIN schedule IN c.schedule WHERE schedule.teacherId = '{id}'";
                //var query = $"SELECT c.id, c.name, c.teacher, cc.course, c.scope FROM c JOIN cc IN c.courses JOIN cct IN cc.teachers WHERE cct.id = '{id}'";
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Course-{school_code}") }))
                {
                    var jsoncs = await JsonDocument.ParseAsync(item.ContentStream);
                    if (jsoncs.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in jsoncs.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            //班級
                            string classIdNow = string.Empty;
                            if (obj.TryGetProperty("scheduleClassId", out JsonElement scheduleClassId))
                            {
                                classIdNow = Convert.ToString(scheduleClassId);
                            }
                            dynamic classExtobj = new ExpandoObject();
                            classExtobj.id = null;
                            classExtobj.code = null;
                            classExtobj.name = null;
                            classExtobj.scope = null;
                            classExtobj.gradeId = null;
                            classExtobj.year = 0;
                            classExtobj.teacher = null;
                            classExtobj.stuListId = null;
                            classExtobj.stuCnt = 0;
                            classExtobj.grpCnt = 0;
                            if (!string.IsNullOrWhiteSpace(classIdNow))
                            {
                                var querycl = $"SELECT c.code, c.id, c.name, c.teacher, c.gradeId, c.year FROM c WHERE c.id = '{classIdNow}'";
                                await foreach (var itemcl in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: querycl, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Class-{school_code}") }))
                                {
                                    var jsoncl = await JsonDocument.ParseAsync(itemcl.ContentStream);
                                    foreach (var objcl in jsoncl.RootElement.GetProperty("Documents").EnumerateArray())
                                    {
                                        classIds.Add(Convert.ToString(objcl.GetProperty("id")));
                                        classExtobj.id = Convert.ToString(objcl.GetProperty("id"));
                                        classExtobj.code = Convert.ToString(objcl.GetProperty("code"));
                                        classExtobj.name = Convert.ToString(objcl.GetProperty("name"));
                                        //classExtobj.scope = Convert.ToString(objcl.GetProperty("scope")); //2021-07-16 廢除class.scope
                                        classExtobj.gradeId = (objcl.TryGetProperty("gradeId", out JsonElement gradeIdJson)) ? Convert.ToString(gradeIdJson) : null; //2021-06-01 [式樣]class去除gradeId，改以year代替
                                        classExtobj.year = (objcl.TryGetProperty("year", out JsonElement yearJson)) ? yearJson.GetInt32() : 0;
                                        classExtobj.teacher = objcl.GetProperty("teacher");
                                        classExtobj.stuCnt = 0;
                                        classExtobj.grpCnt = 0;
                                        var queryclstc = $"SELECT Count(1) AS stuCnt FROM c WHERE c.classId = '{classIdNow}'";
                                        await foreach (var itemclstc in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryStreamIterator(queryText: queryclstc, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-{school_code}") }))
                                        {
                                            var jsonclstc = await JsonDocument.ParseAsync(itemclstc.ContentStream);
                                            foreach (var objstc in jsonclstc.RootElement.GetProperty("Documents").EnumerateArray())
                                            {
                                                classExtobj.stuCnt = objstc.GetProperty("stuCnt").GetUInt32();
                                            }
                                        }
                                        var queryclgp = $"SELECT c.groupId FROM c WHERE c.classId = '{classIdNow}' AND IS_NULL(c.groupId)=false GROUP BY c.groupId";
                                        await foreach (var itemgp in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryStreamIterator(queryText: queryclgp, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-{school_code}") }))
                                        {
                                            var jsongp = await JsonDocument.ParseAsync(itemgp.ContentStream);
                                            if (jsongp.RootElement.TryGetProperty("_count", out JsonElement gpcount) && gpcount.GetUInt32() > 0)
                                            {
                                                classExtobj.grpCnt = gpcount.GetUInt32();
                                            }
                                        }
                                    }
                                }
                            }
                            var stuListId = obj.GetProperty("scheduleStulist");
                            if (!stuListId.ValueKind.Equals(JsonValueKind.Null) && !string.IsNullOrWhiteSpace(stuListId.GetString()))
                            {
                                classExtobj.stuListId = Convert.ToString(stuListId);
                                await foreach (var stuitem in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: $"SELECT c.code, c.id, c.name, c.year, c.tcount, c.scount FROM c WHERE c.id = '{stuListId}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{school_code}") }))
                                {
                                    var jsonstu = await JsonDocument.ParseAsync(stuitem.ContentStream);
                                    foreach (var stuobj in jsonstu.RootElement.GetProperty("Documents").EnumerateArray())
                                    {
                                        groupIds.Add(Convert.ToString(stuobj.GetProperty("id")));
                                        classExtobj.id = Convert.ToString(stuobj.GetProperty("id"));
                                        classExtobj.code = Convert.ToString(stuobj.GetProperty("code"));
                                        classExtobj.name = Convert.ToString(stuobj.GetProperty("name"));
                                        classExtobj.gradeId = null;
                                        classExtobj.year = (stuobj.TryGetProperty("year", out JsonElement yearJson)) ? yearJson.GetInt32() : 0;
                                        classExtobj.teacher = null;
                                        classExtobj.stuCnt += stuobj.GetProperty("tcount").GetInt32();
                                        classExtobj.stuCnt += stuobj.GetProperty("scount").GetInt32();
                                    }
                                }
                            }
                            //課程
                            //var scheduleTeacherInfo = obj.GetProperty("scheduleTeacher");
                            string courseIdNow = obj.GetProperty("id").ToString();
                            var courseExist = courses.Where((dynamic x) => x.id == courseIdNow).FirstOrDefault();
                            if (courseExist == null)
                            {
                                dynamic courseExtobj = new ExpandoObject();
                                courseExtobj.id = courseIdNow;
                                courseExtobj.name = obj.GetProperty("name").ToString();
                                courseExtobj.scope = obj.GetProperty("scope").ToString();
                                courseExtobj.classes = new List<object>();
                                courseExtobj.subject = obj.GetProperty("subject");
                                //classExtobj.teacher = scheduleTeacherInfo;
                                if (!string.IsNullOrWhiteSpace(classExtobj.id))
                                {
                                    courseExtobj.classes.Add(classExtobj);
                                }
                                courses.Add(courseExtobj);
                            }
                            else
                            {
                                //classExtobj.teacher = scheduleTeacherInfo;
                                if (!string.IsNullOrWhiteSpace(classExtobj.id))
                                {
                                    courseExist.classes.Add(classExtobj);
                                }
                            }
                        }
                    }
                }

                //取得校園評測 (HiTeach只取source='1'(課中评量) && progress = 'going'(進行中)) && 排定的學校課程班級
                List<object> exams = new List<object>();
                string classSqlString = "";
                if (classIds.Count > 0 || groupIds.Count > 0)
                {
                    if (classIds.Count > 0)
                    {
                        foreach (string classId in classIds)
                        {
                            if (!string.IsNullOrWhiteSpace(classSqlString))
                            {
                                classSqlString += " OR ";
                            }
                            classSqlString += $"ARRAY_CONTAINS(c.classes, '{classId}')";
                        }
                    }
                    if (groupIds.Count > 0)
                    {
                        foreach (string groupId in groupIds)
                        {
                            if (!string.IsNullOrWhiteSpace(classSqlString))
                            {
                                classSqlString += " OR ";
                            }
                            classSqlString += $"ARRAY_CONTAINS(c.classes, '{groupId}')";
                        }
                    }
                }
                else //無分配任何課程教室，校園評測不取
                {
                    classSqlString += "c.id = '0'";
                }
                classSqlString = $"AND ({classSqlString})";
                //取得評測ID List
                List<string> examIdList = new List<string>();
                await foreach (var exam in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryStreamIterator(queryText: $"SELECT c.id FROM c WHERE c.source = '1' AND c.progress = 'going' {classSqlString}", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Exam-{school_code}") }))
                {
                    using var json = await JsonDocument.ParseAsync(exam.ContentStream);
                    if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            examIdList.Add(obj.GetProperty("id").GetString());
                        }
                    }
                }
                //取得有作答的評測班級
                Dictionary<string, List<string>> examClassFinDic = new Dictionary<string, List<string>>();
                await foreach (var exam in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryStreamIterator(queryText: $"SELECT  c.examId, c.info.id as classId FROM c WHERE ARRAY_CONTAINS({JsonSerializer.Serialize(examIdList)}, c.examId) AND c.progress=true", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"ExamClassResult-{school_code}") }))
                {
                    var jsonecr = await JsonDocument.ParseAsync(exam.ContentStream);
                    if (jsonecr.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in jsonecr.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            string examId = obj.GetProperty("examId").ToString();
                            string classId = obj.GetProperty("classId").ToString();
                            if (examClassFinDic.ContainsKey(examId) && !examClassFinDic[examId].Contains(classId))
                            {
                                examClassFinDic[examId].Add(classId);
                            }
                            else
                            {
                                List<string> classIdList = new List<string>();
                                classIdList.Add(classId);
                                examClassFinDic.Add(examId, classIdList);
                            }
                        }
                    }
                }
                //取得評測資料
                await foreach (var exam in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryStreamIterator(queryText: $"SELECT c.code, c.id, c.name, c.createTime, c.startTime, c.endTime ,c.year, c.source, c.type, c.progress, c.stuCount, c.scope, c.owner, c.period, c.grades, c.subjects, c.classes, c.stuLists, ARRAY(SELECT p.id, p.code, p.name, p.blob, p.scope FROM p IN c.papers) AS papers FROM c WHERE ARRAY_CONTAINS({JsonSerializer.Serialize(examIdList)}, c.id)", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Exam-{school_code}") }))
                {
                    var jsonex = await JsonDocument.ParseAsync(exam.ContentStream);
                    if (jsonex.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in jsonex.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            dynamic examExtobj = new ExpandoObject();
                            string examId = obj.GetProperty("id").GetString();
                            examExtobj.code = obj.GetProperty("code");
                            examExtobj.id = examId;
                            examExtobj.name = obj.GetProperty("name");
                            examExtobj.createTime = obj.GetProperty("createTime");
                            examExtobj.startTime = obj.GetProperty("startTime");
                            examExtobj.endTime = obj.GetProperty("endTime");
                            examExtobj.year = obj.GetProperty("year");
                            examExtobj.source = obj.GetProperty("source");
                            examExtobj.type = obj.GetProperty("type");
                            examExtobj.progress = obj.GetProperty("progress");
                            examExtobj.stuCount = obj.GetProperty("stuCount");
                            examExtobj.scope = obj.GetProperty("scope");
                            examExtobj.owner = obj.GetProperty("owner");
                            examExtobj.period = obj.GetProperty("period");
                            examExtobj.grades = obj.GetProperty("grades");
                            examExtobj.subjects = obj.GetProperty("subjects");
                            examExtobj.classes = (obj.TryGetProperty("classes", out JsonElement classes)) ? classes.ToObject<List<string>>() : new List<string>();
                            examExtobj.stuLists = (obj.TryGetProperty("stuLists", out JsonElement stuLists)) ? stuLists.ToObject<List<string>>() : new List<string>();
                            examExtobj.finishClasses = (examClassFinDic.ContainsKey(examId)) ? examClassFinDic[examId] : new List<string>();
                            examExtobj.papers = obj.GetProperty("papers");
                            //examExtobj = obj.ToObject<object>();
                            exams.Add(examExtobj);
                        }
                    }
                }

                //用户在线记录
                try
                {
                    _ = _httpTrigger.RequestHttpTrigger(new { school = school_code.GetString(), scope = $"{Constant.ScopeTeacher}", id = $"{id}", ip = $"{ip}", expire = 1 }, _option.Location, "online-record");
                }
                catch { }

                //取得School Blob 容器位置及SAS
                string school_code_blob = school_code.GetString().ToLower();
                var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS(school_code_blob, BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List | BlobContainerSasPermissions.Write); //讀列
                var (blob_uri_read, blob_sas_read) = _azureStorage.GetBlobContainerSAS(school_code_blob, BlobContainerSasPermissions.Read); //讀
                var (blob_uri_write, blob_sas_write) = _azureStorage.GetBlobContainerSAS(school_code_blob, BlobContainerSasPermissions.Write); //寫

                RedisValue redisValue = default;
                long teach = 0;
                long blobsize = 0;
                _azureRedis.GetRedisClient(8).HashGet($"Blob:Record", $"{school_code}");
                if (redisValue != default && !redisValue.IsNullOrEmpty)
                {
                    JsonElement record = redisValue.ToString().ToObject<JsonElement>();
                    if (record.TryGetInt64(out blobsize))
                    {
                    }
                }
                else
                {
                    var messageBlob = new ServiceBusMessage(new { id = Guid.NewGuid().ToString(), progress = "update", name = $"{school_code}" }.ToJsonString()); ;
                    messageBlob.ApplicationProperties.Add("name", "BlobRoot");
                    var ActiveTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
                    await _serviceBus.GetServiceBusClient().SendMessageAsync(ActiveTask, messageBlob);
                }

                //计算分配给学校教师的空间
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: $"SELECT sum(c.size) as size FROM c ",
                    requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Teacher-{school_code}") }))
                {
                    var json = await JsonDocument.ParseAsync(item.ContentStream);
                    foreach (var elmt in json.RootElement.GetProperty("Documents").EnumerateArray())
                    {
                        if (elmt.TryGetProperty("size", out JsonElement _size) && _size.ValueKind.Equals(JsonValueKind.Number))
                        {
                            teach = _size.GetInt32();
                            break;
                        }
                    }
                }
                double blobUsed = blobsize / 1073741824.0 + teach; //1073741824  1G
                return Ok(new { blob_uri, blob_sas, blob_sas_read, blob_sas_write, periods, grades, subjects, courses, examTypes, exams, blobTotal = total, blobUsed});
            }
            catch (Exception ex)
            {
                // await _dingDing.SendBotMsg($"CoreAPI2，{_option.Location}，hiteach/GetTeacherInfo()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
                return BadRequest();
            }
        }

        //取得試卷
        [ProducesDefaultResponseType]
        [HttpPost("get-paper")]
        public async Task<IActionResult> GetPaperList(JsonElement request)
        {
            try
            {
                //Header驗證
                string id_token = HttpContext.GetXAuth("IdToken");
                if (string.IsNullOrEmpty(id_token)) return BadRequest();
                var jwt = new JwtSecurityToken(id_token);
                if (!jwt.Payload.Iss.Equals("account.teammodel", StringComparison.Ordinal)) return BadRequest();
                var id = jwt.Payload.Sub;
                var client = _azureCosmos.GetCosmosClient();
                //參數
                if (!request.TryGetProperty("grant_type", out JsonElement grant_type)) return BadRequest();
                string partitionid = string.Empty;
                string container = string.Empty;
                if (grant_type.ToString().Equals("school"))
                {
                    if (!request.TryGetProperty("school_code", out JsonElement school_code_json))
                    {
                        return BadRequest();
                    }
                    else
                    {
                        partitionid = school_code_json.ToString();
                        container = "School";
                    }
                }
                else
                {
                    partitionid = id.ToString();
                    container = "Teacher";
                }
                //SQL文
                List<object> papers = new List<object>();
                string queryWhere = " WHERE 1=1 ";
                string queryOption = string.Empty;
                //學段
                if (request.TryGetProperty("periodId", out JsonElement periodId) && container.Equals("School"))
                {
                    queryWhere += $" AND c.periodId = '{periodId}'";
                }
                //年級
                if (request.TryGetProperty("gradeId", out JsonElement gradeIds) && gradeIds.GetArrayLength() > 0 && container.Equals("School"))
                {
                    string queryOptionForGrade = string.Empty;
                    for (int i = 0; i < gradeIds.GetArrayLength(); i++)
                    {
                        if (!string.IsNullOrWhiteSpace(queryOptionForGrade))
                        {
                            queryOptionForGrade += " OR ";
                        }
                        queryOptionForGrade += $" ARRAY_CONTAINS(c.gradeIds, '{gradeIds[i]}', true)";
                    }
                    queryWhere += $" AND ( {queryOptionForGrade} )";
                }
                //科目ID
                if (request.TryGetProperty("subjectId", out JsonElement subjectId) && container.Equals("School"))
                {
                    queryWhere += $" AND c.subjectId = '{subjectId}'";
                }
                //科目名稱
                if (request.TryGetProperty("subjectName", out JsonElement subjectName))
                {
                    queryWhere += $" AND c.subjectName = '{subjectName}'";
                }
                //試卷ID
                if (request.TryGetProperty("id", out JsonElement paperId))
                {
                    queryWhere += $" AND c.id = '{paperId}'";
                }
                int perpage = 0; //每頁幾條
                if (request.TryGetProperty("perpage", out JsonElement perpage_json)) perpage = perpage_json.GetInt32();
                int page = 0; //目前第幾頁
                if (request.TryGetProperty("page", out JsonElement page_json))
                {
                    if (page_json.GetInt32() > 0)
                    {
                        page = page_json.GetInt32() - 1;
                    }
                }
                string order = "createTime"; //排序項目
                if (request.TryGetProperty("order", out JsonElement order_json))
                {
                    if (order_json.ToString().Equals("useCount"))
                    {
                        order = order_json.ToString();
                    }
                }
                queryOption += $" Order By c." + order + " DESC ";
                if (perpage > 0)
                {
                    queryOption += $" OFFSET {perpage * page} LIMIT {perpage}";
                }

                //資料取得
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, container).GetItemQueryStreamIterator(queryText: $"SELECT c.code, c.id, c.periodId, c.gradeIds, c.subjectId, c.subjectName, c.name, REPLACE(c.blob, 'index.json', '') AS blob, c.score, c.useCount, ARRAY_LENGTH(c.scoring) AS itemCount, c.createTime, c.scope From c {queryWhere + queryOption}", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{partitionid}") }))
                {
                    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())
                        {
                            papers.Add(obj.ToObject<object>());
                        }
                    }
                }

                //總件數
                int totalCount = 0;
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, container).GetItemQueryStreamIterator(queryText: $"SELECT VALUE COUNT(1) From c {queryWhere}", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{partitionid}") }))
                {
                    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())
                        {
                            totalCount = obj.GetInt32();
                        }
                    }
                }

                return Ok(new { papers, totalCount });
            }
            catch (Exception ex)
            {
                return BadRequest();
            }
        }

        //取得試題
        [ProducesDefaultResponseType]
        [HttpPost("get-item")]
        public async Task<IActionResult> GetItemList(JsonElement request)
        {
            try
            {
                //Header驗證
                string id_token = HttpContext.GetXAuth("IdToken");
                if (string.IsNullOrEmpty(id_token)) return BadRequest();
                var jwt = new JwtSecurityToken(id_token);
                if (!jwt.Payload.Iss.Equals("account.teammodel", StringComparison.Ordinal)) return BadRequest();
                var id = jwt.Payload.Sub;
                var client = _azureCosmos.GetCosmosClient();
                //參數
                if (!request.TryGetProperty("grant_type", out JsonElement grant_type)) return BadRequest();
                string partitionid = string.Empty;
                string container = string.Empty;
                if (grant_type.ToString().Equals("school"))
                {
                    if (!request.TryGetProperty("school_code", out JsonElement school_code_json))
                    {
                        return BadRequest();
                    }
                    else
                    {
                        partitionid = school_code_json.ToString();
                        container = "School";
                    }
                }
                else
                {
                    partitionid = id.ToString();
                    container = "Teacher";
                }
                //SQL文
                List<object> items = new List<object>();
                string queryWhere = " WHERE 1=1 ";
                string queryOption = string.Empty;
                //學段
                if (request.TryGetProperty("periodId", out JsonElement periodId) && container.Equals("School"))
                {
                    queryWhere += $" AND c.periodId = '{periodId}'";
                }
                //年級
                if (request.TryGetProperty("gradeId", out JsonElement gradeIds) && gradeIds.GetArrayLength() > 0 && container.Equals("School"))
                {
                    string queryOptionForGrade = string.Empty;
                    for (int i = 0; i < gradeIds.GetArrayLength(); i++)
                    {
                        if (!string.IsNullOrWhiteSpace(queryOptionForGrade))
                        {
                            queryOptionForGrade += " OR ";
                        }
                        queryOptionForGrade += $" ARRAY_CONTAINS(c.gradeIds, '{gradeIds[i]}', true)";
                    }
                    queryWhere += $" AND ( {queryOptionForGrade} )";
                }
                //科目ID
                if (request.TryGetProperty("subjectId", out JsonElement subjectId) && container.Equals("school"))
                {
                    queryWhere += $" AND c.subjectId = '{subjectId}'";
                }
                //科目名稱
                if (request.TryGetProperty("subjectName", out JsonElement subjectName))
                {
                    queryWhere += $" AND c.subjectName = '{subjectName}'";
                }
                //題型
                int dummy = 0;
                if (request.TryGetProperty("type", out JsonElement type))
                {
                    queryWhere += $" AND c.type = '{type}'";
                }
                //難度
                dummy = 0;
                if (request.TryGetProperty("level", out JsonElement level) && int.TryParse(level.ToString(), out dummy))
                {
                    queryWhere += $" AND c.level = {level}";
                }
                //層次
                if (request.TryGetProperty("field", out JsonElement field) && int.TryParse(field.ToString(), out dummy))
                {
                    queryWhere += $" AND c.field = {field}";
                }
                int perpage = 0; //每頁幾條
                if (request.TryGetProperty("perpage", out JsonElement perpage_json)) perpage = perpage_json.GetInt32();
                int page = 0; //目前第幾頁
                if (request.TryGetProperty("page", out JsonElement page_json))
                {
                    if (page_json.GetInt32() > 0)
                    {
                        page = page_json.GetInt32() - 1;
                    }
                }
                string order = "createTime"; //排序項目
                if (request.TryGetProperty("order", out JsonElement order_json))
                {
                    if (order_json.ToString().Equals("useCount"))
                    {
                        order = order_json.ToString();
                    }
                }
                queryOption += $" Order By c." + order + " DESC ";
                if (perpage > 0)
                {
                    queryOption += $" OFFSET {perpage * page} LIMIT {perpage}";
                }

                //資料取得
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, container).GetItemQueryStreamIterator(queryText: $"SELECT c.id, c.periodId, c.gradeIds, c.subjectId, c.subjectName, c.blob, c.field, c.level, c.type, c.useCount, c.createTime From c {queryWhere + queryOption}", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Item-{partitionid}") }))
                {
                    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())
                        {
                            items.Add(obj.ToObject<object>());
                        }
                    }
                }

                //總件數
                int totalCount = 0;
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, container).GetItemQueryStreamIterator(queryText: $"SELECT VALUE COUNT(1) From c {queryWhere}", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Item-{partitionid}") }))
                {
                    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())
                        {
                            totalCount = obj.GetInt32();
                        }
                    }
                }

                return Ok(new { items, totalCount });
            }
            catch (Exception ex)
            {
                return BadRequest();
            }
        }

        //取得知識點
        [ProducesDefaultResponseType]
        [HttpPost("get-knowledge")]
        public async Task<IActionResult> GetKnowledgePointList(JsonElement request)
        {
            var client = _azureCosmos.GetCosmosClient();
            if (!request.TryGetProperty("school_code", out JsonElement school_code)) return BadRequest();
            //知識點
            List<object> points = new List<object>();
            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: $"SELECT c.id, c.name, c.subjectId FROM c WHERE c.type = 'point'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Knowledge-{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())
                    {
                        points.Add(obj.ToObject<object>());
                    }
                }
            }

            return Ok(points);
        }

        //取得課綱
        [ProducesDefaultResponseType]
        [HttpPost("get-syllabus")]
        public async Task<IActionResult> GetSyllabusList(JsonElement request)
        {
            //Header驗證
            string id_token = HttpContext.GetXAuth("IdToken");
            if (string.IsNullOrEmpty(id_token)) return BadRequest();
            var jwt = new JwtSecurityToken(id_token);
            if (!jwt.Payload.Iss.Equals("account.teammodel", StringComparison.OrdinalIgnoreCase)) return BadRequest();
            var id = jwt.Payload.Sub;
            //參數驗證
            if (!request.TryGetProperty("grant_type", out JsonElement grant_type)) return BadRequest();
            string grantType = (grant_type.GetString().Equals("school")) ? "school" : "private";
            JsonElement school_code = new JsonElement();
            if (grantType == "school" && !request.TryGetProperty("school_code", out school_code)) return BadRequest();
            string dataId = (grantType.Equals("school")) ? school_code.GetString() : id;
            string container = (grantType.Equals("school")) ? "School" : "Teacher";
            string periodId = (request.TryGetProperty("periodId", out JsonElement periodIdJobj)) ? periodIdJobj.GetString() : String.Empty;
            string subjectId = (request.TryGetProperty("subjectId", out JsonElement subjectIdJobj)) ? subjectIdJobj.GetString() : String.Empty;
            string volumeId = (request.TryGetProperty("volumeId", out JsonElement volumeIdJobj)) ? volumeIdJobj.GetString() : String.Empty;
            string syllabusId = (request.TryGetProperty("syllabusId", out JsonElement syllabusIdJobj)) ? syllabusIdJobj.GetString() : String.Empty;
            int display = (request.TryGetProperty("display", out JsonElement displayJobj)) ? displayJobj.GetInt32() : 0;
            var client = _azureCosmos.GetCosmosClient();

            //取得卷前置作業：有給syllabusId，取得該課綱的卷ID
            string volumeIdFromSyllabusId = String.Empty;
            if (!string.IsNullOrWhiteSpace(syllabusId))
            {
                await foreach (string volid in client.GetContainer(Constant.TEAMModelOS, container).GetItemQueryIterator<string>(queryText: $"SELECT value(c.volumeId) FROM c WHERE c.id = '{syllabusId}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Syllabus-{dataId}") }))
                {
                    volumeIdFromSyllabusId = volid;
                }
            }

            //取得卷
            List<object> volumes = new List<object>();
            List<Volume> volumeList = new List<Volume>();
            List<string> volumeIdList = new List<string>();
            string queryTextVol = String.Empty;
            List<string> WhereVol = new List<string>();
            if (!String.IsNullOrWhiteSpace(periodId)) WhereVol.Add($" c.periodId = '{periodId}' ");
            if (!String.IsNullOrWhiteSpace(subjectId)) WhereVol.Add($" c.subjectId = '{subjectId}' ");
            if (!String.IsNullOrWhiteSpace(volumeId)) WhereVol.Add($" c.id = '{volumeId}' ");
            if (!String.IsNullOrWhiteSpace(volumeIdFromSyllabusId)) WhereVol.Add($" c.id = '{volumeIdFromSyllabusId}' ");
            foreach (string Where in WhereVol)
            {
                queryTextVol += (String.IsNullOrWhiteSpace(queryTextVol)) ? $" WHERE {Where} " : $" AND {Where} ";
            }
            queryTextVol = "SELECT * FROM c " + queryTextVol;
            await foreach (var itemv in client.GetContainer(Constant.TEAMModelOS, container).GetItemQueryStreamIterator(queryText: queryTextVol, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Volume-{dataId}") }))
            {
                var jsons = await JsonDocument.ParseAsync(itemv.ContentStream);
                if (jsons.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                {
                    foreach (var obj in jsons.RootElement.GetProperty("Documents").EnumerateArray())
                    {
                        Volume volExtobj = obj.ToObject<Volume>();
                        volumeList.Add(volExtobj);
                        volumeIdList.Add(volExtobj.id);
                    }
                }
            }
            //取得課綱 ※display=1時不取任何課綱
            List<SyllabusTreeNode> treeNodes = new List<SyllabusTreeNode>();
            if (!display.Equals(1))
            {
                string queryTextSyl = $"SELECT value(c) FROM c WHERE ARRAY_CONTAINS({JsonSerializer.Serialize(volumeIdList)}, c.volumeId, true)";
                if (!string.IsNullOrWhiteSpace(syllabusId)) queryTextSyl += $" AND c.id = '{syllabusId}'";
                await foreach (Syllabus items in client.GetContainer(Constant.TEAMModelOS, container).GetItemQueryIterator<Syllabus>(queryText: queryTextSyl, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Syllabus-{dataId}") }))
                {
                    List<SyllabusTree> trees = SyllabusService.ListToTree(items.children);
                    SyllabusTreeNode tree = new SyllabusTreeNode() { id = items.id, scope = items.scope, trees = trees, volumeId = items.volumeId, auth = items.auth, codeval = $"{id}" };
                    treeNodes.Add(tree);
                }
            }

            //輸出結果
            foreach (Volume volumeRow in volumeList)
            {
                dynamic volumeExtobj = new ExpandoObject();
                volumeExtobj.periodId = volumeRow.periodId;
                volumeExtobj.subjectId = volumeRow.subjectId;
                volumeExtobj.volumeId = volumeRow.id;
                volumeExtobj.gradeId = volumeRow.gradeId;
                volumeExtobj.semesterId = volumeRow.semesterId;
                volumeExtobj.name = volumeRow.name;
                volumeExtobj.creatorId = volumeRow.creatorId;
                volumeExtobj.creatorName = volumeRow.creatorName;
                volumeExtobj.school = volumeRow.school;
                volumeExtobj.scope = volumeRow.scope;
                volumeExtobj.syllabusIds = volumeRow.syllabusIds; //課綱內容ID
                volumeExtobj.auth = volumeRow.auth;     //授權教師
                List<SyllabusTreeNode> treesInVol = treeNodes.Where(t => t.volumeId == volumeRow.id).ToList();
                volumeExtobj.syllabus = treesInVol;
                volumes.Add(volumeExtobj);
            }

            return Ok(volumes);
        }

        //取得某班級的學生成員
        [ProducesDefaultResponseType]
        [HttpPost("get-students-list")]
        public async Task<IActionResult> GetStudentsList(JsonElement request)
        {
            string id_token = HttpContext.GetXAuth("IdToken");
            if (string.IsNullOrWhiteSpace(id_token)) return BadRequest();
            var jwt = new JwtSecurityToken(id_token);
            if (!jwt.Payload.Iss.Equals("account.teammodel", StringComparison.Ordinal)) return BadRequest();
            var id = jwt.Payload.Sub;
            if (!request.TryGetProperty("grant_type", out JsonElement grant_type)) return BadRequest();
            request.TryGetProperty("class_code", out JsonElement class_code);
            request.TryGetProperty("stulist_id", out JsonElement stulist_id);
            string classId = Convert.ToString(class_code);
            string stulist = Convert.ToString(stulist_id);
            if (string.IsNullOrWhiteSpace(classId) && string.IsNullOrWhiteSpace(stulist)) return BadRequest();
            request.TryGetProperty("school_code", out JsonElement school_code);
            if (grant_type.GetString().Equals("school") && string.IsNullOrWhiteSpace(Convert.ToString(school_code))) return BadRequest();

            var client = _azureCosmos.GetCosmosClient();
            List<ClassStudents> students = new List<ClassStudents>();
            Dictionary<string, string> irsDic = new Dictionary<string, string>(); //key:學生ID或TMID value:irs號碼
            string container = (grant_type.GetString().Equals("school")) ? "School" : "Teacher";

            List<string> listids = new List<string>();
            if (!string.IsNullOrWhiteSpace(stulist))
            {
                listids.Add(stulist);
            }
            else if (!string.IsNullOrWhiteSpace(classId))
            {
                listids.Add(classId);
            }
            (List<RMember> memberList, List<RGroupList> groupList) = await GroupListService.GetStutmdidListids(_coreAPIHttpService, client, _dingDing, listids, $"{school_code}");
            if (memberList.IsNotEmpty())
            {
                foreach (RMember member in memberList)
                {
                    ClassStudents strdentRow = new ClassStudents();
                    strdentRow.nickname = member.nickname;
                    strdentRow.id = member.id;
                    strdentRow.name = member.name;
                    strdentRow.no = member.no;
                    strdentRow.schoolId = member.code;
                    strdentRow.groupId = member.groupId;
                    strdentRow.groupName = member.groupName;
                    strdentRow.irs = member.irs;
                    strdentRow.type = member.type;
                    students.Add(strdentRow);
                }
            }
            #region 舊代碼 不使用
            ////Case 1 取得stulist成員 (有stulist_id則優先取)
            //if (grant_type.GetString().Equals("private")  && string.IsNullOrWhiteSpace(stulist) && !string.IsNullOrWhiteSpace(classId)) //若private，且classId不為空，stulist為空，有可能HiTeach無法判別是若classId還是stulist
            //{
            //    stulist = classId;
            //}
            //if (!string.IsNullOrWhiteSpace(stulist))
            //{
            //    string pk = (grant_type.GetString() .Equals("school")) ? $"GroupList-{school_code}" : $"GroupList";
            //    var querystl = $"SELECT c.members FROM c WHERE c.id = '{stulist}'";
            //    Dictionary<string, List<string>> stuDic = new Dictionary<string, List<string>>();
            //    List<string> tmidList = new List<string>();
            //    await foreach (var item in client.GetContainer(Constant.TEAMModelOS, container).GetItemQueryStreamIterator(queryText: querystl, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey(pk) }))
            //    {
            //        var json = await JsonDocument.ParseAsync(item.ContentStream);
            //        if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
            //        {
            //            foreach (var stuObj in json.RootElement.GetProperty("Documents").EnumerateArray())
            //            {
            //                foreach (var studentObj in stuObj.GetProperty("members").EnumerateArray())
            //                {
            //                    string stuCode = studentObj.GetProperty("code").ToString();
            //                    string stuId = studentObj.GetProperty("id").ToString();
            //                    int stuType = studentObj.GetProperty("type").GetInt32();
            //                    string irs = studentObj.GetProperty("irs").ToString();
            //                    //取得學校班級學生ID表
            //                    if (stuType.Equals(2))
            //                    {
            //                        if (stuDic.ContainsKey(stuCode) && !stuDic[stuCode].Contains(stuId))
            //                        {
            //                            if (!stuDic[stuCode].Contains(stuId))
            //                            {
            //                                stuDic[stuCode].Add(stuId);
            //                            }
            //                        }
            //                        else
            //                        {
            //                            List<string> stuIdList = new List<string>();
            //                            stuIdList.Add(stuId);
            //                            stuDic.Add(stuCode, stuIdList);
            //                        }
            //                    }
            //                    //取得TMID加入學生ID表
            //                    else if(stuType.Equals(1) && !tmidList.Contains(stuId))
            //                    {
            //                        tmidList.Add(stuId);
            //                    }
            //                    //IRS號碼表 (irs無值不取)
            //                    if (!irsDic.ContainsKey(stuId) && !string.IsNullOrWhiteSpace(irs))
            //                    {
            //                        irsDic.Add(stuId, irs);
            //                    }
            //                }
            //            }
            //        }
            //    }
            //    //取得學校班級學生資料
            //    if (stuDic.Count > 0)
            //    {
            //        foreach (KeyValuePair<string, List<string>> stuDicRow in stuDic)
            //        {
            //            string stuCode = $"Base-{stuDicRow.Key}";
            //            List<string> stuIdList = stuDicRow.Value;
            //            var queryst = $"SELECT c.id, c.name, null AS no, c.schoolId, c.irs FROM c WHERE ARRAY_CONTAINS({JsonSerializer.Serialize(stuIdList)}, c.id)";
            //            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryStreamIterator(queryText: queryst, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey(stuCode) }))
            //            {
            //                using var json = await JsonDocument.ParseAsync(item.ContentStream);
            //                if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
            //                {
            //                    foreach (var stuObj in json.RootElement.GetProperty("Documents").EnumerateArray())
            //                    {
            //                        students.Add(stuObj.ToObject<ClassStudents>());
            //                    }
            //                }   
            //            }
            //        }
            //    }
            //    //取得TMID用戶資料
            //    List<ClassStudents> tmids = new List<ClassStudents>();
            //    if (tmidList.Count > 0)
            //    {
            //        var querytmct = $"SELECT c.id, c.name, null AS no, null AS schoolId, c.irs FROM c WHERE ARRAY_CONTAINS({JsonSerializer.Serialize(tmidList)}, c.id)";
            //        await foreach (var itemtm in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryStreamIterator(queryText: querytmct, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
            //        {
            //            using var json = await JsonDocument.ParseAsync(itemtm.ContentStream);
            //            if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
            //            {
            //                foreach (var stuObj in json.RootElement.GetProperty("Documents").EnumerateArray())
            //                {
            //                    tmids.Add(stuObj.ToObject<ClassStudents>());
            //                }
            //                //排序
            //                tmids = tmids.OrderBy(x => tmidList.IndexOf(x.id)).ToList();
            //            }
            //        }
            //    }
            //    students = students.Concat(tmids).ToList();
            //}
            ////Case 2 取得班級固定成員 條件：有school_code、有classId、無stulist
            //if (!string.IsNullOrWhiteSpace(Convert.ToString(school_code)) && students.Count == 0 && !string.IsNullOrWhiteSpace(classId))
            //{
            //    var query = $"SELECT c.id, c.name, c.no, c.schoolId, c.groupId, c.groupName, c.irs FROM c WHERE c.classId = '{classId}'";
            //    await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-{school_code}") }))
            //    {
            //        using var jsonst = await JsonDocument.ParseAsync(item.ContentStream);
            //        if (jsonst.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
            //        {
            //            foreach (var stuObj in jsonst.RootElement.GetProperty("Documents").EnumerateArray())
            //            {
            //                students.Add(stuObj.ToObject<ClassStudents>());
            //            }
            //        }
            //    }
            //}
            ////IRS號碼補足 邏輯：若irsDic數 = students數、全放入
            //if(students.Count.Equals(irsDic.Count))
            //{
            //    for (int i = 0; i < students.Count; i++)
            //    {
            //        if (irsDic.ContainsKey(students[i].id))
            //        {
            //            students[i].irs = irsDic[students[i].id];
            //        }
            //    }
            //}
            #endregion

            //取得分組資訊
            List<ClassGroups> groups = new List<ClassGroups>();
            foreach (ClassStudents studentInfo in students)
            {
                if (!string.IsNullOrWhiteSpace(studentInfo.groupId))
                {
                    ClassGroups groupRow = groups.Where(g => g.id == studentInfo.groupId).FirstOrDefault();
                    if (groupRow != null) //已有此group資訊 => 追加學生ID
                    {
                        if (!groupRow.studentIds.Contains(studentInfo.id))
                        {
                            groupRow.studentIds.Add(studentInfo.id);
                        }
                    }
                    else //無此group資訊
                    {
                        ClassGroups groupAdd = new ClassGroups();
                        groupAdd.id = studentInfo.groupId;
                        groupAdd.name = studentInfo.groupName;
                        groupAdd.studentIds = new List<string>();
                        groupAdd.studentIds.Add(studentInfo.id);
                        groups.Add(groupAdd);
                    }
                }
            }

            return Ok(new { students, groups });
        }

        [ProducesDefaultResponseType]
        [HttpPost("start-lesson")]
        public async Task<IActionResult> StartLesson(JsonElement request)
        {
            //醍摩豆ID驗證
            string teacherId = string.Empty;
            string id_token = HttpContext.GetXAuth("IdToken");
            if (!string.IsNullOrWhiteSpace(id_token))
            {
                var jwt = new JwtSecurityToken(id_token);
                if (!jwt.Payload.Iss.Equals("account.teammodel", StringComparison.OrdinalIgnoreCase)) return BadRequest();
                teacherId = jwt.Payload.Sub;
            }
            if (string.IsNullOrWhiteSpace(teacherId)) return BadRequest(); //無醍摩豆ID，BadRequest
            //取得授課ID
            string lesson_code = _snowflakeId.NextId().ToString();
            //bool get_lesson_id = (string.IsNullOrWhiteSpace(Convert.ToString(lesson_id)) || Convert.ToString(lesson_id) != lesson_code) ? false : true;
            //string tableName = "TeacherLesson";
            return Ok(new { lesson_code });
        }

        //上傳評測結果
        //錯誤代碼：error = 1001 message = "Paper blob copy failure."
        //          error = 1002 message = "Student answers blob upload failure."
        [ProducesDefaultResponseType]
        [HttpPost("upd-exam-result")]
        public async Task<IActionResult> UploadExamResult(JsonElement request)
        {
            try
            {
                string message = "";
                int error = 0;

                string id_token = HttpContext.GetXAuth("IdToken");
                if (string.IsNullOrWhiteSpace(id_token)) return BadRequest();
                var jwt = new JwtSecurityToken(id_token);
                if (!jwt.Payload.Iss.Equals("account.teammodel", StringComparison.Ordinal)) return BadRequest();
                var id = jwt.Payload.Sub;

                if (!request.TryGetProperty("exam", out JsonElement exam)) return BadRequest();
                if (!request.TryGetProperty("examClassResult", out JsonElement examClassResult)) return BadRequest();
                bool blobUploaded = (request.TryGetProperty("blobUploaded", out JsonElement blobUploadedJson)) ? blobUploadedJson.GetBoolean() : false;
                bool recordSwitch = (request.TryGetProperty("recordSwitch", out JsonElement recordSwitchJson)) ? recordSwitchJson.GetBoolean() : false;

                //ExamInfo ExamInfoFromReq = exam.ToObject<ExamInfo>();
                string strExam = JsonSerializer.Serialize(exam);
                if (strExam.Contains("\"publish\":\"0\""))
                {
                    strExam = strExam.Replace("\"publish\":\"0\"", "\"publish\":0");
                }
                ExamInfo ExamInfoFromReq = JsonSerializer.Deserialize<ExamInfo>(strExam);
                string examId = ExamInfoFromReq.id;
                string excode = ExamInfoFromReq.code;
                //ExamInfo dbExamInfo = exam.ToObject<ExamInfo>();
                ExamInfo dbExamInfo = JsonSerializer.Deserialize<ExamInfo>(strExam);

                var queryex = $"SELECT * FROM c WHERE c.id = '{examId}'";
                await foreach (var itemex in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryStreamIterator(queryText: queryex, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"{excode}") }))
                {
                    var jsonex = await JsonDocument.ParseAsync(itemex.ContentStream);
                    if (jsonex.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in jsonex.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            string strExamDb = JsonSerializer.Serialize(obj);
                            if (strExamDb.Contains("\"publish\":\"0\""))
                            {
                                strExamDb = strExamDb.Replace("\"publish\":\"0\"", "\"publish\":0");
                            }
                            dbExamInfo = JsonSerializer.Deserialize<ExamInfo>(strExamDb);
                            //dbExamInfo = obj.ToObject<ExamInfo>();
                        }
                    }
                }
                if (string.IsNullOrWhiteSpace(dbExamInfo.id))
                {
                    dbExamInfo = ExamInfoFromReq;
                }

                //Boolean isTestFlg = (_option.Location.Contains("Test") || _option.Location.Contains("Dep")) ? true : false;
                //ExamInfo內容取得、調整  [2021-7-13 廢除，給予HiTeach學校Blob寫入權限，API不再對Blob做搬運]
                //※規則  owner:"school" => 校園評測  "teacher" => 個人評測 
                //※規則  scope:"school" => 校本班級  "private" => 個人班級 
                //※規則  BLOB容器: scope:"school" => {學校ID}下   scope:"private" => {個人ID}下
                string blobContainer = (!string.IsNullOrWhiteSpace(dbExamInfo.school) && dbExamInfo.scope.Equals("school")) ? dbExamInfo.school : id; //blob容器
                //dbExamInfo.source = "1"; //評測來源固定為  1:課中評量(不應由API擅自變更)

                //試卷List
                List<Dictionary<string, string>> recordPaperInfo = new List<Dictionary<string, string>>();
                int paperIndex = 0;
                foreach (PaperSimple paperInfo in ExamInfoFromReq.papers)
                {
                    string paperBlobPath = (!paperInfo.blob.EndsWith("/")) ? paperInfo.blob + "/" : paperInfo.blob;
                    paperBlobPath = (paperInfo.blob.StartsWith("/")) ? paperBlobPath.Remove(0, 1) : paperBlobPath;
                    string subjectId = dbExamInfo.subjects[paperIndex].id;
                    recordPaperInfo.Add(new Dictionary<string, string>() { { "id", paperInfo.id }, { "blob", paperBlobPath }, { "subjectId", subjectId }, { "itemcount", paperInfo.point.Count.ToString() } });
                    paperIndex++;
                }

                //取得課堂紀錄下的試卷資料(blob)、複製到評測紀錄下
                bool paperDataCopyErrFlg = false; //試卷資料拷貝錯誤Flag  true:拷貝錯誤  [2021-7-13 (測試站)不再對Blob做搬運 永為false]
                //Blob搬運 (待HiTeach完善後刪除)
                if (!blobUploaded)
                {
                    foreach (Dictionary<string, string> recordPaperInfoDic in recordPaperInfo)
                    {
                        string targetScope = dbExamInfo.scope; //評測對象 school：校本班級  private：私人課程
                        var blobPrivateContainer = _azureStorage.GetBlobContainerClient(id);
                        string sourceBlobPath = recordPaperInfoDic["blob"];
                        string destBlobPath = $"exam/{dbExamInfo.id}/paper/{recordPaperInfoDic["subjectId"]}/"; //拷貝對象路徑 path:exam/{評測ID}/paper/{subjectID}/  ※2022-1-6 式樣變更[原]/paper/{試卷ID}/ [新]/paper/{subjectID}/
                        if (targetScope.Equals("school")) //校本
                        {
                            string schoolId = dbExamInfo.school;
                            var blobSchoolContainer = _azureStorage.GetBlobContainerClient(schoolId);
                            var sourceBlobContainer = (recordSwitch) ? blobSchoolContainer : blobPrivateContainer;
                            Azure.Pageable<BlobItem> sourceBlobs = sourceBlobContainer.GetBlobs(prefix: sourceBlobPath);
                            if (sourceBlobs.Count() > 0)
                            {
                                foreach (var blob in sourceBlobs)
                                {
                                    var sourceFileBlob = sourceBlobContainer.GetBlobClient(blob.Name);
                                    if (sourceFileBlob.Exists())
                                    {
                                        var sourceFileUri = sourceBlobContainer.GetBlobClient(blob.Name).Uri;
                                        string fileName = blob.Name.Replace(sourceBlobPath, "");
                                        string destBlobFilePath = $"{destBlobPath}{fileName}";
                                        await blobSchoolContainer.GetBlobClient(destBlobFilePath).StartCopyFromUriAsync(sourceFileUri);
                                    }
                                    else
                                    {
                                        paperDataCopyErrFlg = true;
                                    }
                                }
                            }
                        }
                        else //私人
                        {
                            var sourceBlobContainer = blobPrivateContainer;
                            Azure.Pageable<BlobItem> sourceBlobs = sourceBlobContainer.GetBlobs(prefix: sourceBlobPath);
                            if (sourceBlobs.Count() > 0)
                            {
                                foreach (var blob in sourceBlobs)
                                {
                                    var sourceFileBlob = sourceBlobContainer.GetBlobClient(blob.Name);
                                    if (sourceFileBlob.Exists())
                                    {
                                        var sourceFileUri = sourceBlobContainer.GetBlobClient(blob.Name).Uri;
                                        string fileName = blob.Name.Replace(sourceBlobPath, "");
                                        string destBlobFilePath = $"{destBlobPath}{fileName}";
                                        await blobPrivateContainer.GetBlobClient(destBlobFilePath).StartCopyFromUriAsync(sourceFileUri);
                                    }
                                    else
                                    {
                                        paperDataCopyErrFlg = true;
                                    }
                                }
                            }
                        }
                        //替換 Exam.papers.blob
                        PaperSimple paperInfoNow = dbExamInfo.papers.Where((PaperSimple p) => p.id == recordPaperInfoDic["id"]).FirstOrDefault();
                        string destBlobPathForDocument = (destBlobPath.EndsWith("/")) ? destBlobPath.Remove(destBlobPath.Length - 1, 1) : destBlobPath;
                        destBlobPathForDocument = (!destBlobPathForDocument.StartsWith("/")) ? "/" + destBlobPathForDocument : destBlobPathForDocument;
                        paperInfoNow.blob = destBlobPathForDocument;
                    }
                }

                //ExamClassResult內容調整
                bool studentAnswerCopyErrFlg = false; //學生作答資料拷貝錯誤Flag  true:拷貝錯誤 [2021-7-13 不再對Blob做搬運 永為false]
                //Blob搬運 (待HiTeach完善後刪除)
                if (!blobUploaded)
                {
                    List<ExamClassResultStudentAnswerArrayOld> dbExamClassResultList = examClassResult.ToObject<List<ExamClassResultStudentAnswerArrayOld>>();
                    foreach (ExamClassResultStudentAnswerArrayOld examClassResultRow in dbExamClassResultList)
                    {
                        //以subjectId及classId(info.id)取得DB中的ExamClassResult
                        ExamClassResult examClassResultUpd = new ExamClassResult();
                        string exclcode = examClassResultRow.code;
                        string classId = examClassResultRow.info.id;
                        string subjectId = examClassResultRow.subjectId;
                        var querycr = $"SELECT * FROM c WHERE c.examId = '{examId}' AND c.info.id = '{classId}' AND c.subjectId = '{subjectId}'";
                        await foreach (var itemcr in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryStreamIterator(queryText: querycr, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"{exclcode}") }))
                        {
                            var jsontcr = await JsonDocument.ParseAsync(itemcr.ContentStream);
                            if (jsontcr.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                            {
                                foreach (var obj in jsontcr.RootElement.GetProperty("Documents").EnumerateArray())
                                {
                                    examClassResultUpd = obj.ToObject<ExamClassResult>();
                                    examClassResultUpd.progress = examClassResultRow.progress;
                                    examClassResultUpd.studentIds = examClassResultRow.studentIds;
                                    examClassResultUpd.studentAnswers = new List<List<string>>();
                                    examClassResultUpd.studentScores = examClassResultRow.studentScores;
                                    examClassResultUpd.status = examClassResultRow.status;
                                    examClassResultUpd.sum = examClassResultRow.sum;
                                }
                            }
                        }
                        //無法取得既有ExamClassResult，新建
                        if (string.IsNullOrWhiteSpace(examClassResultUpd.id))
                        {
                            examClassResultUpd.pk = examClassResultRow.pk;
                            examClassResultUpd.code = examClassResultRow.code;
                            examClassResultUpd.id = examClassResultRow.id;
                            examClassResultUpd.school = examClassResultRow.school;
                            examClassResultUpd.examId = examClassResultRow.examId;
                            examClassResultUpd.subjectId = examClassResultRow.subjectId;
                            examClassResultUpd.gradeId = examClassResultRow.gradeId;
                            examClassResultUpd.year = examClassResultRow.year;
                            examClassResultUpd.info = examClassResultRow.info;
                            examClassResultUpd.progress = examClassResultRow.progress;
                            examClassResultUpd.studentIds = examClassResultRow.studentIds;
                            examClassResultUpd.studentAnswers = new List<List<string>>(); //學生作答Blob位置
                            examClassResultUpd.studentScores = examClassResultRow.studentScores;
                            examClassResultUpd.status = examClassResultRow.status;
                            examClassResultUpd.scope = examClassResultRow.scope;
                            examClassResultUpd.sum = examClassResultRow.sum;
                        }
                        //examClassResult.studentAnswers (1)將學生答案上傳blob後轉換內容為blob路徑   //[2021-7-13 不再對Blob做搬運] (2)將學生答案放入examClassResult.ans
                        if (examClassResultRow.studentIds != null && examClassResultRow.studentIds.Count > 0 && examClassResultRow.studentAnswersArray != null && examClassResultRow.studentAnswersArray.Count > 0)
                        {
                            for (int i = 0; i < examClassResultRow.studentAnswersArray.Count; i++)
                            {
                                string studentId = examClassResultRow.studentIds[i];
                                string fileName = examId + "/" + subjectId + "/" + studentId;
                                string blob = fileName + "/" + "ans.json";
                                var uploadFileResult = await _azureStorage.GetBlobContainerClient(blobContainer).UploadFileByContainer(examClassResultRow.studentAnswersArray[i].ToJsonString(), "exam", blob, false);
                                if (string.IsNullOrWhiteSpace(uploadFileResult))
                                {
                                    studentAnswerCopyErrFlg = true;
                                }
                                //studentAnswers
                                List<string> studenrAnswerRow = new List<string>();
                                studenrAnswerRow.Add(blob);
                                examClassResultUpd.studentAnswers.Add(studenrAnswerRow);
                            }
                            //examClassResult.ans 將學生答案放入
                            examClassResultUpd.ans = examClassResultRow.studentAnswersArray;
                        }
                        //批註欄位處理
                        Dictionary<string, string> paperStatusNow = recordPaperInfo.Where((Dictionary<string, string> p) => p.TryGetValue("subjectId", out string paperStatusSubjectId) && paperStatusSubjectId.Equals(subjectId)).FirstOrDefault();
                        int itemCount = Convert.ToInt32(paperStatusNow["itemcount"]);
                        if (examClassResultUpd.mark.Count != examClassResultUpd.studentIds.Count || (examClassResultUpd.mark.ElementAtOrDefault(0) != null && examClassResultUpd.mark[0].Count != itemCount)) //第一層:學生數不符 OR 第二層:第一位學生批註數!=試卷題數 => 批註格式不符
                        {
                            examClassResultUpd.mark = this.createEmptyMark(examClassResultUpd.studentIds.Count, itemCount);
                        }

                        //UPDATE ExamClassResult
                        var examClassResultResponse = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Common").UpsertItemAsync(examClassResultUpd, new PartitionKey(examClassResultUpd.code));
                    }
                }
                else
                {
                    List<ExamClassResultStudentAnswerArray> dbExamClassResultList = examClassResult.ToObject<List<ExamClassResultStudentAnswerArray>>();
                    foreach (ExamClassResultStudentAnswerArray examClassResultRow in dbExamClassResultList)
                    {
                        //以subjectId及classId(info.id)取得DB中的ExamClassResult
                        ExamClassResult examClassResultUpd = new ExamClassResult();
                        string exclcode = examClassResultRow.code;
                        string classId = examClassResultRow.info.id;
                        string subjectId = examClassResultRow.subjectId;
                        var querycr = $"SELECT * FROM c WHERE c.examId = '{examId}' AND c.info.id = '{classId}' AND c.subjectId = '{subjectId}'";
                        await foreach (var itemcr in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryStreamIterator(queryText: querycr, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"{exclcode}") }))
                        {
                            var jsontcr = await JsonDocument.ParseAsync(itemcr.ContentStream);
                            if (jsontcr.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                            {
                                foreach (var obj in jsontcr.RootElement.GetProperty("Documents").EnumerateArray())
                                {
                                    examClassResultUpd = obj.ToObject<ExamClassResult>();
                                    examClassResultUpd.progress = examClassResultRow.progress;
                                    examClassResultUpd.studentIds = examClassResultRow.studentIds;
                                    examClassResultUpd.studentAnswers = new List<List<string>>();
                                    examClassResultUpd.studentScores = examClassResultRow.studentScores;
                                    examClassResultUpd.status = examClassResultRow.status;
                                    examClassResultUpd.sum = examClassResultRow.sum;
                                }
                            }
                        }
                        //無法取得既有ExamClassResult，新建
                        if (string.IsNullOrWhiteSpace(examClassResultUpd.id))
                        {
                            examClassResultUpd.pk = examClassResultRow.pk;
                            examClassResultUpd.code = examClassResultRow.code;
                            examClassResultUpd.id = examClassResultRow.id;
                            examClassResultUpd.school = examClassResultRow.school;
                            examClassResultUpd.examId = examClassResultRow.examId;
                            examClassResultUpd.subjectId = examClassResultRow.subjectId;
                            examClassResultUpd.gradeId = examClassResultRow.gradeId;
                            examClassResultUpd.year = examClassResultRow.year;
                            examClassResultUpd.info = examClassResultRow.info;
                            examClassResultUpd.progress = examClassResultRow.progress;
                            examClassResultUpd.studentIds = examClassResultRow.studentIds;
                            examClassResultUpd.studentAnswers = new List<List<string>>();
                            examClassResultUpd.studentScores = examClassResultRow.studentScores;
                            examClassResultUpd.status = examClassResultRow.status;
                            examClassResultUpd.scope = examClassResultRow.scope;
                            examClassResultUpd.sum = examClassResultRow.sum;
                        }
                        //學生作答Blob位置[2021-7-13 不再對Blob做搬運 學生答案直接寫入DB]
                        examClassResultUpd.studentAnswers = examClassResultRow.studentAnswersArray;
                        //學生作答答案 (從blob取得學生答案、放入ans欄位)
                        string targetScope = dbExamInfo.scope; //評測對象 school：校本班級  private：私人課程
                        var targetBlobContainer = _azureStorage.GetBlobContainerClient(id);
                        string blobCntr = id;
                        if (targetScope.Equals("school")) //校本
                        {
                            string schoolId = dbExamInfo.school;
                            blobCntr = schoolId;
                        }
                        targetBlobContainer = _azureStorage.GetBlobContainerClient(blobCntr);
                        if (examClassResultRow.studentAnswersArray.Count > 0)
                        {
                            foreach (List<string> studentAnswerBlobPath in examClassResultRow.studentAnswersArray)
                            {
                                string stuAnswerBlobPath = studentAnswerBlobPath.FirstOrDefault();
                                if (stuAnswerBlobPath != null)
                                {
                                    StringBuilder builder = new StringBuilder();
                                    builder.Append("exam").Append("/").Append(stuAnswerBlobPath);
                                    var Download = await targetBlobContainer.GetBlobClient(builder.ToString()).DownloadAsync();
                                    var json = await JsonDocument.ParseAsync(Download.Value.Content);
                                    var Record = json.RootElement.ToObject<List<List<string>>>();
                                    examClassResultUpd.ans.Add(Record);
                                }
                            }
                        }

                        //批註欄位處理
                        Dictionary<string, string> paperStatusNow = recordPaperInfo.Where((Dictionary<string, string> p) => p.TryGetValue("subjectId", out string subjectId) && subjectId.Equals(examClassResultUpd.subjectId)).FirstOrDefault();
                        int itemCount = Convert.ToInt32(paperStatusNow["itemcount"]);
                        if (examClassResultUpd.mark.Count != examClassResultUpd.studentIds.Count || (examClassResultUpd.mark.ElementAtOrDefault(0) != null && examClassResultUpd.mark[0].Count != itemCount)) //第一層:學生數不符 OR 第二層:第一位學生批註數!=試卷題數 => 批註格式不符
                        {
                            examClassResultUpd.mark = this.createEmptyMark(examClassResultUpd.studentIds.Count, itemCount);
                        }

                        //UPDATE ExamClassResult
                        var examClassResultResponse = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Common").UpsertItemAsync(examClassResultUpd, new PartitionKey(examClassResultUpd.code));
                    }
                }

                //UPDATE Exam
                await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Common").UpsertItemAsync(dbExamInfo, new PartitionKey(dbExamInfo.code));

                //錯誤處理
                if (paperDataCopyErrFlg)  //試卷Blob拷貝失敗
                {
                    error = 1001;
                    message = "Paper blob copy failure.";
                }
                else if (studentAnswerCopyErrFlg)  //學生作答資料上傳blob失敗
                {
                    error = 1002;
                    message = "Student answers blob upload failure.";
                }
                return Ok(new { error, message });
            }
            catch (CosmosException cex)
            {
                return BadRequest(cex.Message);
            }
            catch (StorageException bex)
            {
                return BadRequest(bex.Message);
            }
            catch (Exception ex)
            {
                return BadRequest(ex.Message);
            }
        }

        private List<List<List<Details>>> createEmptyMark(int studentNum, int itemNum)
        {
            List<List<List<Details>>> mark = new List<List<List<Details>>>();
            for (int i = 0; i < studentNum; i++)
            {
                List<List<Details>> markRow = new List<List<Details>>();
                for (int j = 0; j < itemNum; j++)
                {
                    markRow.Add(new List<Details>());
                }
                mark.Add(markRow);
            }
            return mark;
        }

        public class ClassStudents
        {
            public string id { get; set; }
            public string name { get; set; }
            public string no { get; set; }
            public string schoolId { get; set; }
            public string groupId { get; set; }
            public string groupName { get; set; }
            public string irs { get; set; }
            public int type { get; set; } //类型 1 tmdid,2 student
            public string nickname { get; set; }
        }
        public class ClassGroups
        {
            public ClassGroups()
            {
                studentIds = new List<string>();
            }
            public string id { get; set; }
            public string name { get; set; }
            public List<string> studentIds { get; set; }
        }

        //ExamClassResult 學生作答紀錄(舊式 正式站暫時用這個)
        public class ExamClassResultStudentAnswerArrayOld : ExamClassResult
        {
            public List<List<List<string>>> studentAnswersArray { get; set; }
        }
        //ExamClassResult 學生作答紀錄
        public class ExamClassResultStudentAnswerArray : ExamClassResult
        {
            public List<List<string>> studentAnswersArray { get; set; }
        }

    }
}