CommonTrigger.cs 6.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121
  1. using Microsoft.Azure.Functions.Worker;
  2. using Microsoft.Extensions.Configuration;
  3. using Microsoft.Extensions.Logging;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Linq;
  7. using System.Text;
  8. using System.Text.Json;
  9. using System.Threading.Tasks;
  10. using TEAMModelOS.SDK;
  11. using TEAMModelOS.SDK.DI;
  12. using TEAMModelOS.SDK.Extension;
  13. using TEAMModelOS.SDK.Models.Service;
  14. namespace TEAMModelOS.FunctionV4
  15. {
  16. public class CommonTrigger
  17. {
  18. private readonly AzureCosmosFactory _azureCosmos;
  19. private readonly AzureServiceBusFactory _serviceBus;
  20. private readonly AzureStorageFactory _azureStorage;
  21. private readonly DingDing _dingDing;
  22. private readonly AzureRedisFactory _azureRedis;
  23. private IConfiguration _configuration { get; set; }
  24. private readonly CoreAPIHttpService _coreAPIHttpService;
  25. public CommonTrigger(CoreAPIHttpService coreAPIHttpService, AzureCosmosFactory azureCosmos, AzureServiceBusFactory azureServiceBus, AzureStorageFactory azureStorage, DingDing dingDing, AzureRedisFactory azureRedis
  26. , IConfiguration configuration
  27. )
  28. {
  29. _azureCosmos = azureCosmos;
  30. _serviceBus = azureServiceBus;
  31. _azureStorage = azureStorage;
  32. _dingDing = dingDing;
  33. _azureRedis = azureRedis;
  34. _configuration = configuration;
  35. _coreAPIHttpService=coreAPIHttpService;
  36. }
  37. [Function("Common")]
  38. public async Task Common([CosmosDBTriggerAttribute(
  39. databaseName: "TEAMModelOS",
  40. containerName: "Common",
  41. Connection = "Azure:Cosmos:ConnectionString",
  42. LeaseContainerName = "leases",
  43. LeaseContainerPrefix = "TEAMModelOS",
  44. CreateLeaseContainerIfNotExists =true)]JsonElement json, FunctionContext context)
  45. { //string JsonElement
  46. if (json.ValueKind.Equals(JsonValueKind.Array)) {
  47. IReadOnlyList<JsonElement> elements = json.ToObject<List<JsonElement>>();
  48. if (elements!=null && elements.Count>0) {
  49. var client = _azureCosmos.GetCosmosClient();
  50. var log = context.GetLogger<CommonTrigger>();
  51. log.LogInformation("Documents modified " + elements.Count);
  52. log.LogInformation("First document Id " + elements[0]);
  53. foreach (var element in elements) {
  54. element.TryGetProperty("pk", out JsonElement jsond);
  55. if (!string.IsNullOrWhiteSpace($"{jsond}"))
  56. {
  57. if ($"{jsond}".Equals("Receiver", StringComparison.OrdinalIgnoreCase) || $"{jsond}".Equals("ExamClassResult", StringComparison.OrdinalIgnoreCase))
  58. {
  59. ///通知接收者的变更
  60. continue;
  61. }
  62. else
  63. {
  64. TriggerData data = element.ToObject<TriggerData>();
  65. ///活动类型的变更
  66. #if DEBUG
  67. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-CosmosDBTrigger,{data.pk}触发变更\n{data.ToJsonString()}",
  68. GroupNames.成都开发測試群組);
  69. #endif
  70. switch (data.pk)
  71. {
  72. case "Exam":
  73. await TriggerExam.Trigger(_coreAPIHttpService,_azureCosmos, _serviceBus, _azureStorage, _dingDing, client, element, data);
  74. break;
  75. case "Vote":
  76. await TriggerVote.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  77. break;
  78. case "Survey":
  79. await TriggerSurvey.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  80. break;
  81. case "Correct":
  82. await TriggerCorrect.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis);
  83. break;
  84. case "ExamLite":
  85. await TriggerExamLite.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  86. break;
  87. case "Study":
  88. await TriggerStudy.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  89. break;
  90. case "Homework":
  91. await TriggerHomework.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  92. break;
  93. }
  94. }
  95. }
  96. }
  97. }
  98. }
  99. }
  100. }
  101. public class TriggerData
  102. {
  103. public string pk { get; set; }
  104. public int? status { get; set; }
  105. public string name { get; set; }
  106. public long startTime { get; set; }
  107. public long endTime { get; set; }
  108. public string school { get; set; }
  109. public string code { get; set; }
  110. public string creatorId { get; set; }
  111. public string progress { get; set; }
  112. public string scope { get; set; }
  113. public int ttl { get; set; }
  114. public string id { get; set; }
  115. public int? publish { get; set; }
  116. }
  117. }