|
|
@@ -0,0 +1,203 @@
|
|
|
+using Azure.Cosmos;
|
|
|
+using Microsoft.Azure.WebJobs;
|
|
|
+using System;
|
|
|
+using System.Collections.Generic;
|
|
|
+using System.Text;
|
|
|
+using System.Text.Json;
|
|
|
+using System.Threading.Tasks;
|
|
|
+using TEAMModelOS.SDK.DI;
|
|
|
+using TEAMModelOS.SDK.Extension;
|
|
|
+using TEAMModelOS.SDK.Helper.Common.CollectionHelper;
|
|
|
+using TEAMModelOS.SDK.Models;
|
|
|
+using TEAMModelOS.SDK.Models.Cosmos.Common;
|
|
|
+
|
|
|
+namespace TEAMModelFunction
|
|
|
+{
|
|
|
+ public class MQActivity {
|
|
|
+
|
|
|
+ public string id { get; set; }
|
|
|
+ public string code { get; set; }
|
|
|
+ public string owner { get; set; }
|
|
|
+ public List<string> classes { get; set; }
|
|
|
+ //如果已经完成则不写入？？？
|
|
|
+ public string progress { get; set; }
|
|
|
+ public string scope { get; set; }
|
|
|
+ public string school { get; set; }
|
|
|
+ public string creatorId { get; set; }
|
|
|
+ public string pk { get; set; }
|
|
|
+ public string name { get; set; }
|
|
|
+ public List<string> subjects { get; set; }
|
|
|
+ public string blob { get; set; }
|
|
|
+ public long startTime { get; set; }
|
|
|
+ public long endTime { get; set; }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ public class StuListServiceBus
|
|
|
+ {
|
|
|
+ private readonly AzureCosmosFactory _azureCosmos;
|
|
|
+ private readonly DingDing _dingDing;
|
|
|
+ public StuListServiceBus(AzureCosmosFactory azureCosmos, DingDing dingDing)
|
|
|
+ {
|
|
|
+ _azureCosmos = azureCosmos;
|
|
|
+ _dingDing = dingDing;
|
|
|
+ }
|
|
|
+ /// <summary>
|
|
|
+ /// 完善课程变更,StuListChange, originCode是学校编码 则表示名单是学校自定义名单，如果是tmdid则表示醍摩豆的私有名单，scope=school,private。
|
|
|
+ /// </summary>
|
|
|
+ /// <data msg>
|
|
|
+ /// CourseChange
|
|
|
+ ///// </data>
|
|
|
+ /// <param name="msg"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ [FunctionName("StuList")]
|
|
|
+ public async Task StuList([ServiceBusTrigger("active-task", "stulist", Connection = "Azure:ServiceBus:ConnectionString")] string msg)
|
|
|
+ {
|
|
|
+ var client = _azureCosmos.GetCosmosClient();
|
|
|
+ try
|
|
|
+ {
|
|
|
+ await _dingDing.SendBotMsg($"ServiceBus,StuList:{msg}", GroupNames.醍摩豆服務運維群組);
|
|
|
+ var jsonMsg = JsonDocument.Parse(msg);
|
|
|
+ StuListChange stuListChange = msg.ToObject<StuListChange>();
|
|
|
+ //名单变动修改学生课程关联信息
|
|
|
+ await FixStuCourse(client, stuListChange);
|
|
|
+ //Vote投票 Survey问卷 Exam评测 Learn学习活动 Homework作业活动
|
|
|
+ //TODO名单变动修改学生问卷关联信息
|
|
|
+ await FixActivity(client, stuListChange, "Survey");
|
|
|
+ //TODO名单变动修改学生投票关联信息
|
|
|
+ await FixActivity(client, stuListChange, "Vote");
|
|
|
+ //TODO名单变动修改学生评测关联信息
|
|
|
+ await FixActivity(client, stuListChange, "Exam");
|
|
|
+ //学习活动
|
|
|
+ await FixActivity(client, stuListChange, "Learn");
|
|
|
+ //作业活动
|
|
|
+ await FixActivity(client, stuListChange, "Homework");
|
|
|
+ }
|
|
|
+ catch (Exception ex)
|
|
|
+ {
|
|
|
+ await _dingDing.SendBotMsg($"StuListServiceBus-StuList\n{ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public async Task FixActivity(CosmosClient client, StuListChange stuListChange, string type) {
|
|
|
+ var query = $"SELECT distinct c.owner, c.id,c.code, c.classes,c.subjects,c.progress,c.scope,c.startTime,c.school,c.creatorId,c.name,c.pk ,c.endTime FROM c join A1 in c.classes where c.pk='{type}' and A1 in('{stuListChange.listid}') ";
|
|
|
+ List<MQActivity> datas = new List<MQActivity>();
|
|
|
+ await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryIterator<MQActivity>(queryText: query,
|
|
|
+ requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"{type}-{stuListChange.originCode}") }))
|
|
|
+ {
|
|
|
+ datas.Add(item);
|
|
|
+ }
|
|
|
+ foreach (MQActivity activity in datas) {
|
|
|
+ //已经完结的不在允许加入
|
|
|
+ if (activity.progress.Equals("finish")) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ //学生新加入名单的
|
|
|
+ foreach (Students students in stuListChange.stujoin)
|
|
|
+ {
|
|
|
+ var stucourse = new StuActivity
|
|
|
+ {
|
|
|
+ id = activity.id,
|
|
|
+ scode = activity.code,
|
|
|
+ name = activity.name,
|
|
|
+ code = $"Activity-{activity.school}-{students.id}",
|
|
|
+ scope = activity.scope,
|
|
|
+ school = activity.school,
|
|
|
+ creatorId = activity.creatorId,
|
|
|
+ pk = "Activity",
|
|
|
+ type = type,
|
|
|
+ subjects = type.Equals("Exam") ? activity.subjects : new List<string>() { "" },
|
|
|
+ startTime = activity.startTime,
|
|
|
+ endTime = activity.endTime
|
|
|
+ };
|
|
|
+ await client.GetContainer("TEAMModelOS", "Student").UpsertItemAsync(stucourse, new PartitionKey(stucourse.code));
|
|
|
+ }//tmd新加入的
|
|
|
+ foreach (string tmdid in stuListChange.tmdjoin)
|
|
|
+ {
|
|
|
+ var stucourse = new StuActivity
|
|
|
+ {
|
|
|
+ id = activity.id,
|
|
|
+ scode = activity.code,
|
|
|
+ name = activity.name,
|
|
|
+ code = $"Activity-{tmdid}",
|
|
|
+ scope = activity.scope,
|
|
|
+ school = activity.school,
|
|
|
+ creatorId = activity.creatorId,
|
|
|
+ pk = "Activity",
|
|
|
+ type = type,
|
|
|
+ subjects= type.ToLower().Equals("Exam")?activity.subjects:new List<string>() {"" }
|
|
|
+ };
|
|
|
+ await client.GetContainer("TEAMModelOS", "Teacher").UpsertItemAsync(stucourse, new PartitionKey(stucourse.code));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public async Task FixStuCourse(CosmosClient client, StuListChange stuListChange) {
|
|
|
+ //1.查找学校或教师的课程是否包含该名单的课程。
|
|
|
+ var query = $"select distinct c.code,c.id,c.no,c.name,c.scope, c.creatorId,c.school from c join A0 in c.schedule where A0.stulist = '{stuListChange.listid}'";
|
|
|
+ List<Course> courses = new List<Course>();
|
|
|
+ if (stuListChange.scope.Equals("school"))
|
|
|
+ {
|
|
|
+ await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<Course>(queryText: query,
|
|
|
+ requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Course-{stuListChange.originCode}") }))
|
|
|
+ {
|
|
|
+ courses.Add(item);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ await foreach (var item in client.GetContainer("TEAMModelOS", "Teacher").GetItemQueryIterator<Course>(queryText: query,
|
|
|
+ requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Course-{stuListChange.originCode}") }))
|
|
|
+ {
|
|
|
+ courses.Add(item);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //2.获取课程的id 并尝试添加或移除对应的学生课程记录StuCourse。
|
|
|
+ foreach (var course in courses)
|
|
|
+ {
|
|
|
+ //学生新加入名单的
|
|
|
+ foreach (Students students in stuListChange.stujoin)
|
|
|
+ {
|
|
|
+ var stucourse = new StuCourse
|
|
|
+ {
|
|
|
+ id = course.id,
|
|
|
+ scode = course.code,
|
|
|
+ name = course.name,
|
|
|
+ code = $"Course-{course.school}-{students.id}",
|
|
|
+ scope = course.scope,
|
|
|
+ school = course.school,
|
|
|
+ creatorId = course.creatorId,
|
|
|
+ pk = "Course"
|
|
|
+ };
|
|
|
+ await client.GetContainer("TEAMModelOS", "Student").UpsertItemAsync(course, new PartitionKey(course.code));
|
|
|
+ }
|
|
|
+ //tmd新加入的
|
|
|
+ foreach (string tmdid in stuListChange.tmdjoin)
|
|
|
+ {
|
|
|
+ var stucourse = new StuCourse
|
|
|
+ {
|
|
|
+ id = course.id,
|
|
|
+ scode = course.code,
|
|
|
+ name = course.name,
|
|
|
+ code = $"Course-{tmdid}",
|
|
|
+ scope = course.scope,
|
|
|
+ school = course.school,
|
|
|
+ creatorId = course.creatorId,
|
|
|
+ pk = "Course"
|
|
|
+ };
|
|
|
+ await client.GetContainer("TEAMModelOS", "Teacher").UpsertItemAsync(course, new PartitionKey(course.code));
|
|
|
+ }
|
|
|
+ //移除名单的。 在点击相关的课程，再去二次校验是否存在，不存在则再去删除。
|
|
|
+ //foreach (var delStu in stuListChange.stuleave)
|
|
|
+ //{
|
|
|
+ // await client.GetContainer("TEAMModelOS", "Student").DeleteItemStreamAsync(course.id, new PartitionKey($"Course-{course.school}-{delStu.id}"));
|
|
|
+ //}
|
|
|
+ //foreach (var delTmd in stuListChange.tmdhleave)
|
|
|
+ //{
|
|
|
+ // await client.GetContainer("TEAMModelOS", "Teacher").DeleteItemStreamAsync(course.id, new PartitionKey($"Course-{delTmd}"));
|
|
|
+ //}
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
CrazyIter_Bin