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.醍摩豆服務運維群組);
// }
//}
}
}