TEAMModelOS/TEAMModelFunction/CourseServiceBus.cs

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;
        }
        /// <summary>
        /// 完善课程变更
        /// </summary>
        /// <data msg>
        /// "ids":["s111","t111"]//学生
        /// "opt":"join/leave",//状态
        /// "no":"CLASS001"//教室编号
        /// "source":1/2  //学生名单数据来源 1是不同学校的学生账号，2是扫码加入的醍摩豆ID
        ///// </data>
        /// <param name="msg"></param>
        /// <returns></returns>
        //[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<CourseChange>();
        //        //根据新增名单获取 新增的学生id 及timdid
        //        (List<string> addTmdids, List<Students> addStudents)= await TriggerStuActivity.GetStuList(client,courseChange.addList,courseChange.school);
        //        //根据新增名单获取 新增的学生id 及timdid
        //        (List<string>delTmdids, List<Students> 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.醍摩豆服務運維群組);
        //    }
        //}

    }
}