CourseServiceBus.cs 1.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. using Microsoft.Azure.WebJobs;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Text;
  5. using System.Text.Json;
  6. using System.Threading.Tasks;
  7. using TEAMModelOS.SDK.DI;
  8. using TEAMModelOS.SDK.Extension;
  9. using TEAMModelOS.SDK.Models.Cosmos.Common;
  10. namespace TEAMModelFunction
  11. {
  12. public class CourseServiceBus
  13. {
  14. private readonly AzureCosmosFactory _azureCosmos;
  15. private readonly DingDing _dingDing;
  16. public CourseServiceBus(AzureCosmosFactory azureCosmos, DingDing dingDing)
  17. {
  18. _azureCosmos = azureCosmos;
  19. _dingDing = dingDing;
  20. }
  21. /// <summary>
  22. /// 完善课程变更
  23. /// </summary>
  24. /// <data msg>
  25. /// "ids":["s111","t111"]//学生
  26. /// "opt":"join/leave",//状态
  27. /// "no":"CLASS001"//教室编号
  28. /// "source":1/2 //学生名单数据来源 1是不同学校的学生账号,2是扫码加入的醍摩豆ID
  29. /// </data>
  30. /// <param name="msg"></param>
  31. /// <returns></returns>
  32. //[FunctionName("Course")]
  33. //public async Task StuList([ServiceBusTrigger("active-task", "course", Connection = "Azure:ServiceBus:ConnectionString")] string msg)
  34. //{
  35. // try
  36. // {
  37. // // await _dingDing.SendBotMsg($"ServiceBus,Blob(){msg}", GroupNames.醍摩豆服務運維群組);
  38. // var jsonMsg = JsonDocument.Parse(msg);
  39. // msg.ToObject<StuCourse>();
  40. // }
  41. // catch (Exception ex)
  42. // {
  43. // await _dingDing.SendBotMsg($"ServiceBus,Blob()\n{ex.Message}{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  44. // }
  45. //}
  46. }
  47. }