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.Models.Cosmos.Common; namespace TEAMModelFunction { public class CourseServiceBus { private readonly AzureCosmosFactory _azureCosmos; private readonly DingDing _dingDing; public CourseServiceBus(AzureCosmosFactory azureCosmos, DingDing dingDing) { _azureCosmos = azureCosmos; _dingDing = dingDing; } /// /// 完善课程变更 /// /// /// "ids":["s111","t1111"]//学生 /// "opt":"join/leave",//状态 /// "no":"CLASS001"//教室编号 /// "source":1/2 //学生名单数据来源 1是不同学校的学生账号,2是扫码加入的醍摩豆ID ///// /// /// //[FunctionName("Course")] //public async Task StuList([ServiceBusTrigger("active-task", "course", Connection = "Azure:ServiceBus:ConnectionString")] string msg) //{ // var client= _azureCosmos.GetCosmosClient(); // try // { // await _dingDing.SendBotMsg($"ServiceBus,CourseChange:{msg}", GroupNames.醍摩豆服務運維群組); // var jsonMsg = JsonDocument.Parse(msg); // CourseChange courseChange= msg.ToObject(); // //根据新增名单获取 新增的学生id 及timdid // (List addTmdids, List addStudents)= await TriggerStuActivity.GetStuList(client,courseChange.addList,courseChange.school); // //根据新增名单获取 新增的学生id 及timdid // (ListdelTmdids, List delStudents) = await TriggerStuActivity.GetStuList(client,courseChange.delList,courseChange.school); // foreach (var addStu in addStudents) { // } // foreach (var addTmd in addTmdids) // { // } // } // catch (Exception ex) // { // await _dingDing.SendBotMsg($"ServiceBus,Blob()\n{ex.Message}{ex.StackTrace}", GroupNames.醍摩豆服務運維群組); // } //} } }