學校periodId修正batch

TEAMModelOS.SDK/Models/Service/FixDataService.cs

@@ -11,6 +11,7 @@ using TEAMModelOS.SDK.DI;
 using TEAMModelOS.SDK.Extension;
 using TEAMModelOS.SDK;
 using HTEXLib.COMM.Helpers;
+using TEAMModelOS.SDK.Models.Cosmos.Common;
 
 namespace TEAMModelOS.SDK.Models.Service
 {
@@ -24,7 +25,8 @@ namespace TEAMModelOS.SDK.Models.Service
         /// <param name="_azureStorage"></param>
         /// <param name="data"></param>
         /// <returns></returns>
-        public static async Task<List<Student>> FixStudentInfo(CosmosClient client, DingDing _dingDing, AzureStorageFactory _azureStorage, JsonElement data) {
+        public static async Task<List<Student>> FixStudentInfo(CosmosClient client, DingDing _dingDing, AzureStorageFactory _azureStorage, JsonElement data)
+        {
             var code = data.GetProperty("code").GetString();
             var ids = data.GetProperty("ids").ToObject<List<string>>();
             var dict = data.GetProperty("dict").ToObject<Dictionary<string, object>>();
@@ -33,11 +35,14 @@ namespace TEAMModelOS.SDK.Models.Service
             await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Student")
                             .GetItemQueryIterator<Student>(
                                 queryText: queryText,
-                                requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-{code}") })) {
-                foreach (var key in dict.Keys) {
-                    switch (key) {
+                                requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-{code}") }))
+            {
+                foreach (var key in dict.Keys)
+                {
+                    switch (key)
+                    {
                         case "classId":
-                            item.classId =$"{ dict[key]}";
+                            item.classId = $"{ dict[key]}";
                             break;
                         case "periodId":
                             item.periodId = $"{ dict[key]}";
@@ -53,7 +58,7 @@ namespace TEAMModelOS.SDK.Models.Service
                         default:
                             break;
                     }
-                  await  client.GetContainer(Constant.TEAMModelOS, "Student").ReplaceItemAsync<Student>(item, item.id, new PartitionKey(item.code));
+                    await client.GetContainer(Constant.TEAMModelOS, "Student").ReplaceItemAsync<Student>(item, item.id, new PartitionKey(item.code));
                     students.Add(item);
                 }
             }
@@ -67,9 +72,10 @@ namespace TEAMModelOS.SDK.Models.Service
         /// <param name="_azureStorage"></param>
         /// <param name="data"></param>
         /// <returns></returns>
-        public  static  async   Task FixBlobContent(CosmosClient client, DingDing _dingDing, AzureStorageFactory _azureStorage, JsonElement data)
+        public static async Task FixBlobContent(CosmosClient client, DingDing _dingDing, AzureStorageFactory _azureStorage, JsonElement data)
         {
-            if (data.TryGetProperty("doPrivate", out JsonElement _doPrivate)&& $"{_doPrivate}".Equals("yes",StringComparison.OrdinalIgnoreCase)) {
+            if (data.TryGetProperty("doPrivate", out JsonElement _doPrivate) && $"{_doPrivate}".Equals("yes", StringComparison.OrdinalIgnoreCase))
+            {
                 foreach (var cnt in _azureStorage.GetBlobServiceClient().GetBlobContainers())
                 {
                     if (cnt.Name.Length == 10 && int.TryParse(cnt.Name, out _))
@@ -79,15 +85,18 @@ namespace TEAMModelOS.SDK.Models.Service
                 }
             }
             List<School> schools = new List<School>();
-            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<School>(queryText: "select value(c) from c", requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") })) {
+            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<School>(queryText: "select value(c) from c", requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
+            {
                 schools.Add(item);
             }
-            foreach (var school in schools) {
+            foreach (var school in schools)
+            {
                 await doFixBlob(client, _azureStorage, school.id, "school");
             }
         }
-        private static async Task doFixBlob(CosmosClient client, AzureStorageFactory _azureStorage,string name,string scope) {
-            List<string> prefixs = new List<string>() { "audio", "doc", "image", "other", "res", "video"};
+        private static async Task doFixBlob(CosmosClient client, AzureStorageFactory _azureStorage, string name, string scope)
+        {
+            List<string> prefixs = new List<string>() { "audio", "doc", "image", "other", "res", "video" };
             var ContainerClient = _azureStorage.GetBlobContainerClient($"{name}");
             var tb = "Teacher";
             if (scope != "private")
@@ -142,5 +151,249 @@ namespace TEAMModelOS.SDK.Models.Service
                 }
             }
         }
+
+        /// <summary>
+        /// 修復學校基本資料
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="schoolCode"></param>
+        /// <returns></returns>
+        public static async Task<List<string>> FixSchoolPeriodId(CosmosClient client, string schoolCode)
+        {
+            List<string> periodIdList = new List<string>();
+            await foreach (School schinfo in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<School>(queryText: $"SELECT value(c) FROM c WHERE c.id = '{schoolCode}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
+            {
+                int periodIndex = 0;
+                foreach (Period periodNow in schinfo.period)
+                {
+                    if (periodNow.id.Equals("上學期") || periodNow.id.Equals("上学期") || periodNow.id.Equals("First semester"))
+                    {
+                        string periodId = Guid.NewGuid().ToString();
+                        schinfo.period[periodIndex].id = periodId;
+                        periodIdList.Add(periodId);
+                    }
+                    periodIndex++;
+                }
+                await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<School>(schinfo, schinfo.id, new PartitionKey("Base"));
+            }
+            return periodIdList;
+        }
+
+        /// <summary>
+        /// 修復學校班級資料
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="schoolCode"></param>
+        /// <param name="dataDic"></param>
+        /// <returns></returns>
+        public static async Task<List<string>> FixClassInfo(CosmosClient client, string schoolCode, Dictionary<string,string> dataDic)
+        {
+            List<string> classIdList = new List<string>();
+            await foreach (Class classinfo in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Class>(queryText: $"SELECT value(c) FROM c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Class-{schoolCode}") }))
+            {
+                foreach (KeyValuePair<string, string> item in dataDic)
+                {
+                    switch (item.Key)
+                    {
+                        case "periodId":
+                            classinfo.periodId = item.Value;
+                            break;
+                    }
+                }
+                await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<Class>(classinfo, classinfo.id, new PartitionKey($"Class-{schoolCode}"));
+                classIdList.Add(classinfo.id);
+            }
+            return classIdList;
+        }
+
+        /// <summary>
+        /// 修復學校課程資料
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="schoolCode"></param>
+        /// <param name="dataDic"></param>
+        /// <returns></returns>
+        public static async Task<List<string>> FixCourseInfo(CosmosClient client, string schoolCode, Dictionary<string, string> dataDic)
+        {
+            List<string> courseIdList = new List<string>();
+            await foreach (Course courseinfo in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Course>(queryText: $"SELECT value(c) FROM c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Course-{schoolCode}") }))
+            {
+                foreach (KeyValuePair<string, string> item in dataDic)
+                {
+                    switch (item.Key)
+                    {
+                        case "periodId":
+                            courseinfo.period.id = item.Value;
+                            break;
+                    }
+                }
+                await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<Course>(courseinfo, courseinfo.id, new PartitionKey($"Course-{schoolCode}"));
+                courseIdList.Add(courseinfo.id);
+            }
+            return courseIdList;
+        }
+
+        /// <summary>
+        /// 修復學校知識點資料
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="schoolCode"></param>
+        /// <param name="dataDic"></param>
+        /// <returns></returns>
+        public static async Task<List<string>> FixKnowledgeInfo(CosmosClient client, string schoolCode, Dictionary<string, string> dataDic)
+        {
+            List<string> knowledgeIdList = new List<string>();
+            await foreach (Knowledge knowledgeinfo in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Knowledge>(queryText: $"SELECT value(c) FROM c WHERE c.pk = 'Knowledge' AND c.owner = '{schoolCode}'", requestOptions: new QueryRequestOptions() {}))
+            {
+                foreach (KeyValuePair<string, string> item in dataDic)
+                {
+                    switch (item.Key)
+                    {
+                        case "periodId":
+                            knowledgeinfo.periodId = item.Value;
+                            break;
+                    }
+                }
+                await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<Knowledge>(knowledgeinfo, knowledgeinfo.id, new PartitionKey($"{knowledgeinfo.code}"));
+                knowledgeIdList.Add(knowledgeinfo.id);
+            }
+            return knowledgeIdList;
+        }
+
+        /// <summary>
+        /// 修復學校試卷資料
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="schoolCode"></param>
+        /// <param name="dataDic"></param>
+        /// <returns></returns>
+        public static async Task<List<string>> FixPaperInfo(CosmosClient client, string schoolCode, Dictionary<string, string> dataDic)
+        {
+            List<string> paperIdList = new List<string>();
+            await foreach (Paper paperinfo in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Paper>(queryText: $"SELECT value(c) FROM c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{schoolCode}") }))
+            {
+                foreach (KeyValuePair<string, string> item in dataDic)
+                {
+                    switch (item.Key)
+                    {
+                        case "periodId":
+                            paperinfo.periodId = item.Value;
+                            break;
+                    }
+                }
+                await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<Paper>(paperinfo, paperinfo.id, new PartitionKey($"Paper-{schoolCode}"));
+                paperIdList.Add(paperinfo.id);
+            }
+            return paperIdList;
+        }
+
+        /// <summary>
+        /// 修復學校課綱資料
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="schoolCode"></param>
+        /// <param name="dataDic"></param>
+        /// <returns></returns>
+        public static async Task<List<string>> FixVolumeInfo(CosmosClient client, string schoolCode, Dictionary<string, string> dataDic)
+        {
+            List<string> volumeIdList = new List<string>();
+            await foreach (Volume volumeinfo in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Volume>(queryText: $"SELECT value(c) FROM c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Volume-{schoolCode}") }))
+            {
+                foreach (KeyValuePair<string, string> item in dataDic)
+                {
+                    switch (item.Key)
+                    {
+                        case "periodId":
+                            volumeinfo.periodId = item.Value;
+                            break;
+                    }
+                }
+                await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<Volume>(volumeinfo, volumeinfo.id, new PartitionKey($"Volume-{schoolCode}"));
+                volumeIdList.Add(volumeinfo.id);
+            }
+            return volumeIdList;
+        }
+
+        /// <summary>
+        /// 修復學校試題資料
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="schoolCode"></param>
+        /// <param name="dataDic"></param>
+        /// <returns></returns>
+        public static async Task<List<string>> FixItemInfo(CosmosClient client, string schoolCode, Dictionary<string, string> dataDic)
+        {
+            List<string> itemIdList = new List<string>();
+            await foreach (ItemInfo iteminfo in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<ItemInfo>(queryText: $"SELECT value(c) FROM c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Item-{schoolCode}") }))
+            {
+                foreach (KeyValuePair<string, string> item in dataDic)
+                {
+                    switch (item.Key)
+                    {
+                        case "periodId":
+                            iteminfo.periodId = item.Value;
+                            break;
+                    }
+                }
+                await client.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<ItemInfo>(iteminfo, iteminfo.id, new PartitionKey($"Item-{schoolCode}"));
+                itemIdList.Add(iteminfo.id);
+            }
+            return itemIdList;
+        }
+
+        /// <summary>
+        /// 修復學校評測資料
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="schoolCode"></param>
+        /// <param name="dataDic"></param>
+        /// <returns></returns>
+        public static async Task<List<string>> FixExamInfo(CosmosClient client, string schoolCode, Dictionary<string, string> dataDic)
+        {
+            List<string> examIdList = new List<string>();
+            await foreach (ExamInfo examinfo in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryIterator<ExamInfo>(queryText: $"SELECT value(c) FROM c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Exam-{schoolCode}") }))
+            {
+                foreach (KeyValuePair<string, string> item in dataDic)
+                {
+                    switch (item.Key)
+                    {
+                        case "periodId":
+                            examinfo.period.id = item.Value;
+                            break;
+                    }
+                }
+                await client.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync<ExamInfo>(examinfo, examinfo.id, new PartitionKey($"Exam-{schoolCode}"));
+                examIdList.Add(examinfo.id);
+            }
+            return examIdList;
+        }
+
+        /// <summary>
+        /// 修復學生資料
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="schoolCode"></param>
+        /// <param name="dataDic"></param>
+        /// <returns></returns>
+        public static async Task<List<string>> FixStudentInfo(CosmosClient client, string schoolCode, Dictionary<string, string> dataDic)
+        {
+            List<string> studentIdList = new List<string>();
+            await foreach (Student studentinfo in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: $"SELECT value(c) FROM c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-{schoolCode}") }))
+            {
+                foreach (KeyValuePair<string, string> item in dataDic)
+                {
+                    switch (item.Key)
+                    {
+                        case "periodId":
+                            studentinfo.periodId = item.Value;
+                            break;
+                    }
+                }
+                await client.GetContainer(Constant.TEAMModelOS, "Student").ReplaceItemAsync<Student>(studentinfo, studentinfo.id, new PartitionKey($"Base-{schoolCode}"));
+                studentIdList.Add(studentinfo.id);
+            }
+            return studentIdList;
+        }
+
     }
 }

TEAMModelOS/Controllers/XTest/FixDataController.cs

@@ -341,5 +341,59 @@ namespace TEAMModelOS.Controllers
                 return BadRequest();
             }
         }
+
+        /// <summary>
+        /// 修正學段ID非英數邏輯
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        [ProducesDefaultResponseType]
+        //[AuthToken(Roles = "teacher")]
+        [HttpPost("fix-periodid")]
+        public async Task<IActionResult> FixPeriodid(JsonElement data)
+        {
+            try
+            {
+                if (!data.TryGetProperty("school_code", out JsonElement school_code)) return BadRequest();
+                string schoolCode = school_code.GetString();
+                var client = _azureCosmos.GetCosmosClient();
+                //學校 Base
+                List<string> periodList = await FixDataService.FixSchoolPeriodId(client, schoolCode);
+                if (periodList.Count > 0)
+                {
+                    string periodId = periodList[0]; //修正的問題校都只有一個學段，以第一個學段ID為其餘資料的學段ID
+                    Dictionary<string, string> dataDic = new Dictionary<string, string>();
+                    dataDic["periodId"] = periodId;
+                    //班級 Class
+                    List<string> fixClassIdList = await FixDataService.FixClassInfo(client, schoolCode, dataDic);
+                    //課程 Course
+                    List<string> fixCourseIdList = await FixDataService.FixCourseInfo(client, schoolCode, dataDic);
+                    //知識點 Knowledge
+                    List<string> fixKnowledgeIdList = await FixDataService.FixKnowledgeInfo(client, schoolCode, dataDic);
+                    //試題 Item
+                    List<string> fixItemIdList = await FixDataService.FixItemInfo(client, schoolCode, dataDic);
+                    //試卷 Paper
+                    List<string> fixPaperIdList = await FixDataService.FixPaperInfo(client, schoolCode, dataDic);
+                    //課綱 Volume
+                    List<string> fixVolumeIdList = await FixDataService.FixVolumeInfo(client, schoolCode, dataDic);
+                    //評測 Exam
+                    List<string> fixExamIdList = await FixDataService.FixExamInfo(client, schoolCode, dataDic);
+                    //學生 Student
+                    List<string> fixStudentIdList = await FixDataService.FixStudentInfo(client, schoolCode, dataDic);
+
+                    return Ok(new { schoolCode, fixClassIdList, fixCourseIdList, fixKnowledgeIdList, fixItemIdList, fixPaperIdList, fixVolumeIdList, fixExamIdList, fixStudentIdList });
+                }
+                else
+                {
+                    string message = "No period is changed";
+                    return Ok(new { message });
+                }
+            }
+            catch (Exception ex)
+            {
+                //await _dingDing.SendBotMsg($"TEAMModelFunction，ActivityHttpTrigger，fix-periodid()\n{ex.Message}{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
+                return BadRequest();
+            }
+        }
     }
 }