IESCosmosDBTrigger.cs 7.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147
  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. LeaseDatabaseName ="Lease",
  47. LeaseContainerName = "lease",
  48. LeaseContainerPrefix = "TEAMModelOS",
  49. CreateLeaseContainerIfNotExists = true,StartFromBeginning =false)] IReadOnlyList<JsonElement> input)
  50. {
  51. if (input != null && input.Count > 0)
  52. {
  53. _logger.LogInformation("Documents modified: " + input.Count);
  54. _logger.LogInformation("First document Id: " +JsonSerializer.Serialize(input[0]));
  55. var client = _azureCosmos.GetCosmosClient();
  56. foreach (var element in input) {
  57. element.TryGetProperty("_ts", out JsonElement _ts);
  58. element.TryGetProperty("id", out JsonElement _id);
  59. //_logger.LogInformation($"过期数据=>时间戳:{_ts.GetInt64()}-id:{_id}");
  60. //return;
  61. //if (JsonValueKind.Number.Equals(_ts.ValueKind) && 1719331200>_ts.GetInt64()) {
  62. // _logger.LogInformation($"过期数据=>时间戳:{_ts.GetInt64()}-id:{_id}" );
  63. // return;
  64. //}
  65. _logger.LogInformation("变化参数 " + element);
  66. element.TryGetProperty("pk", out JsonElement jsond);
  67. if (!string.IsNullOrWhiteSpace($"{jsond}"))
  68. {
  69. if ($"{jsond}".Equals("Receiver", StringComparison.OrdinalIgnoreCase)
  70. || $"{jsond}".Equals("Notice", StringComparison.OrdinalIgnoreCase)
  71. || $"{jsond}".Equals("ExamClassResult", StringComparison.OrdinalIgnoreCase))
  72. {
  73. ///通知接收者的变更
  74. continue;
  75. }
  76. //else if ($"{jsond}".Equals("StatsNotice", StringComparison.OrdinalIgnoreCase))
  77. //{
  78. // var sert = 012;
  79. //}
  80. else
  81. {
  82. TriggerData data = element.ToObject<TriggerData>();
  83. ///活动类型的变更
  84. #if DEBUG
  85. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-CosmosDBTrigger,{data.pk}触发变更\n{data.ToJsonString()}",
  86. GroupNames.醍摩豆服務運維群組);
  87. #endif
  88. switch (data.pk)
  89. {
  90. case "Exam":
  91. await TriggerExam.Trigger(_coreAPIHttpService, _azureCosmos, _serviceBus, _azureStorage, _dingDing, client, element, data, _httpClient, _configuration, _httpTrigger, _azureRedis);
  92. break;
  93. case "Vote":
  94. await TriggerVote.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  95. break;
  96. case "Survey":
  97. await TriggerSurvey.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  98. break;
  99. case "Correct":
  100. await TriggerCorrect.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis);
  101. break;
  102. case "ExamLite":
  103. await TriggerExamLite.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  104. break;
  105. case "Study":
  106. await TriggerStudy.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  107. break;
  108. case "Homework":
  109. await TriggerHomework.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration);
  110. break;
  111. case "Art":
  112. await TriggerArt.Trigger(_coreAPIHttpService, _serviceBus, _azureStorage, _dingDing, client, element, data, _azureRedis, _configuration, _httpTrigger);
  113. break;
  114. case "ExamImport":
  115. await TriggerExamImport.Trigger(_coreAPIHttpService, _azureCosmos, _serviceBus, _azureStorage, _dingDing, client, element, data, _httpClient, _configuration, _azureRedis);
  116. break;
  117. case "QuotaImport":
  118. await TriggerQuotaImport.Trigger(_coreAPIHttpService, _azureCosmos, _serviceBus, _azureStorage, _dingDing, client, element, data, _httpClient, _configuration, _azureRedis);
  119. break;
  120. }
  121. }
  122. }
  123. }
  124. }
  125. }
  126. }
  127. public class TriggerData
  128. {
  129. public string pk { get; set; }
  130. public int? status { get; set; }
  131. public string name { get; set; }
  132. public long startTime { get; set; }
  133. public long endTime { get; set; }
  134. public string school { get; set; }
  135. public string code { get; set; }
  136. public string creatorId { get; set; }
  137. public string progress { get; set; }
  138. public string scope { get; set; }
  139. public int ttl { get; set; }
  140. public string id { get; set; }
  141. public int? publish { get; set; }
  142. }
  143. }