IESCosmosDBTrigger.cs 7.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Text.Json;
  4. using Microsoft.Azure.Functions.Worker;
  5. using Microsoft.Extensions.Configuration;
  6. using Microsoft.Extensions.Logging;
  7. using TEAMModelOS.SDK.DI;
  8. using TEAMModelOS.SDK;
  9. using System.Xml.Linq;
  10. using Microsoft.Azure.Cosmos.Linq;
  11. using TEAMModelOS.SDK.Extension;
  12. using TEAMModelOS.CosmosDBTriggers;
  13. namespace TEAMModelOS.Function
  14. {
  15. public class IESCosmosDBTrigger
  16. {
  17. private readonly ILogger _logger;
  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 readonly IHttpClientFactory _httpClient;
  24. private IConfiguration _configuration { get; set; }
  25. private readonly CoreAPIHttpService _coreAPIHttpService;
  26. private readonly HttpTrigger _httpTrigger;
  27. public IESCosmosDBTrigger(ILoggerFactory loggerFactory, CoreAPIHttpService coreAPIHttpService, AzureCosmosFactory azureCosmos, AzureServiceBusFactory azureServiceBus, AzureStorageFactory azureStorage, DingDing dingDing, AzureRedisFactory azureRedis
  28. , IConfiguration configuration, IHttpClientFactory httpClient, HttpTrigger httpTrigger)
  29. {
  30. _logger = loggerFactory.CreateLogger<IESCosmosDBTrigger>();
  31. _azureCosmos = azureCosmos;
  32. _serviceBus = azureServiceBus;
  33. _azureStorage = azureStorage;
  34. _dingDing = dingDing;
  35. _azureRedis = azureRedis;
  36. _configuration = configuration;
  37. _coreAPIHttpService=coreAPIHttpService;
  38. _httpClient = httpClient;
  39. _httpTrigger = httpTrigger;
  40. }
  41. [Function("Common")]
  42. public async Task Common([CosmosDBTrigger(
  43. databaseName: "TEAMModelOS",
  44. containerName: "Common",
  45. Connection = "Azure:Cosmos:ConnectionString",
  46. LeaseContainerName = "leases",
  47. CreateLeaseContainerIfNotExists = true)] IReadOnlyList<JsonElement> input)
  48. {
  49. if (input != null && input.Count > 0)
  50. {
  51. _logger.LogInformation("Documents modified: " + input.Count);
  52. _logger.LogInformation("First document Id: " +JsonSerializer.Serialize(input[0]));
  53. var client = _azureCosmos.GetCosmosClient();
  54. foreach (var element in input) {
  55. _logger.LogInformation("变化参数 " + element);
  56. element.TryGetProperty("pk", out JsonElement jsond);
  57. if (!string.IsNullOrWhiteSpace($"{jsond}"))
  58. {
  59. if ($"{jsond}".Equals("Receiver", StringComparison.OrdinalIgnoreCase)
  60. || $"{jsond}".Equals("Notice", StringComparison.OrdinalIgnoreCase)
  61. || $"{jsond}".Equals("ExamClassResult", StringComparison.OrdinalIgnoreCase))
  62. {
  63. ///通知接收者的变更
  64. continue;
  65. }
  66. //else if ($"{jsond}".Equals("StatsNotice", StringComparison.OrdinalIgnoreCase))
  67. //{
  68. // var sert = 012;
  69. //}
  70. else
  71. {
  72. TriggerData data = element.ToObject<TriggerData>();
  73. ///活动类型的变更
  74. #if DEBUG
  75. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-CosmosDBTrigger,{data.pk}触发变更\n{data.ToJsonString()}",
  76. GroupNames.醍摩豆服務運維群組);
  77. #endif
  78. switch (data.pk)
  79. {
  80. case "Exam":
  81. await TriggerExam.Trigger(_coreAPIHttpService, _azureCosmos, _serviceBus, _azureStorage, _dingDing, client, element, data, _httpClient, _configuration, _httpTrigger, _azureRedis);
  82. break;
  83. case "Vote":
  84. await TriggerVote.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  85. break;
  86. case "Survey":
  87. await TriggerSurvey.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  88. break;
  89. case "Correct":
  90. await TriggerCorrect.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis);
  91. break;
  92. case "ExamLite":
  93. await TriggerExamLite.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  94. break;
  95. case "Study":
  96. await TriggerStudy.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  97. break;
  98. case "Homework":
  99. await TriggerHomework.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  100. break;
  101. case "Art":
  102. await TriggerArt.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration, _httpTrigger);
  103. break;
  104. case "ExamImport":
  105. await TriggerExamImport.Trigger(_coreAPIHttpService, _azureCosmos, _serviceBus, _azureStorage, _dingDing, client, element, data, _httpClient, _configuration, _azureRedis);
  106. break;
  107. case "QuotaImport":
  108. await TriggerQuotaImport.Trigger(_coreAPIHttpService, _azureCosmos, _serviceBus, _azureStorage, _dingDing, client, element, data, _httpClient, _configuration, _azureRedis);
  109. break;
  110. }
  111. }
  112. }
  113. }
  114. }
  115. }
  116. }
  117. public class TriggerData
  118. {
  119. public string pk { get; set; }
  120. public int? status { get; set; }
  121. public string name { get; set; }
  122. public long startTime { get; set; }
  123. public long endTime { get; set; }
  124. public string school { get; set; }
  125. public string code { get; set; }
  126. public string creatorId { get; set; }
  127. public string progress { get; set; }
  128. public string scope { get; set; }
  129. public int ttl { get; set; }
  130. public string id { get; set; }
  131. public int? publish { get; set; }
  132. }
  133. }