TEAMModelOS/TEAMModelFunction/MonitorCosmosDB.cs

using System;
using System.Collections.Generic;
using System.Net.Http;
using System.Text.Json;
using System.Threading.Tasks;
using Azure.Cosmos;
using Azure.Messaging.ServiceBus;
using Microsoft.Azure.Documents;
using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK.Models;

namespace TEAMModelFunction
{
    public class MonitorCosmosDB
    {
        private readonly AzureCosmosFactory _azureCosmos;
        private readonly AzureServiceBusFactory _serviceBus;
        private readonly AzureStorageFactory _azureStorage;
        private readonly DingDing _dingDing;
        private readonly AzureRedisFactory _azureRedis;
        public MonitorCosmosDB( AzureCosmosFactory azureCosmos, AzureServiceBusFactory azureServiceBus, AzureStorageFactory azureStorage, DingDing dingDing, AzureRedisFactory azureRedis)
        {
            _azureCosmos = azureCosmos;
            _serviceBus = azureServiceBus;
            _azureStorage = azureStorage;
            _dingDing = dingDing;
            _azureRedis = azureRedis;
        }

        //[FunctionName("Common")]
        //public async Task Common([HttpTrigger(
        //    databaseName: "TEAMModelOS",
        //    collectionName: "Common",
        //    ConnectionStringSetting = "Azure:Cosmos:ConnectionString",
        //    LeaseCollectionName = "leases")]IReadOnlyList<Document> inputs, ILogger log)

        [FunctionName("Common")]
        public async Task Common([CosmosDBTrigger(
            databaseName: "TEAMModelOS",
            collectionName: "Common",
            ConnectionStringSetting = "Azure:Cosmos:ConnectionString",
            LeaseCollectionName = "leases")]IReadOnlyList<Document> inputs, ILogger log)
        {
            if (inputs != null && inputs.Count > 0)
            {
                log.LogInformation("Documents modified " + inputs.Count);
                log.LogInformation("First document Id " + inputs[0].Id);
                var client = _azureCosmos.GetCosmosClient();

                foreach (var input in inputs)
                {
                    string pk = input.GetPropertyValue<string>("pk");
                    if (!string.IsNullOrWhiteSpace(pk))
                    {
                        int ttl = input.GetPropertyValue<int>("ttl");
                        long stime = input.GetPropertyValue<long>("startTime");
                        long etime = input.GetPropertyValue<long>("endTime");
                        string school = input.GetPropertyValue<string>("school");
                        string code = input.GetPropertyValue<string>("code");
                        string owner = input.GetPropertyValue<string>("owner");
                        string progress = input.GetPropertyValue<string>("progress");
                        string scope = input.GetPropertyValue<string>("scope");
                        string name = input.GetPropertyValue<string>("name");
                        int? status = input.GetPropertyValue<int?>("status");
                        var data = new TriggerData {
                            stime = stime,
                            etime = etime,
                            school = school,
                            code = code,
                            owner = owner,
                            progress = progress,
                            scope = scope,
                            ttl = ttl,
                            id = input.Id,
                            status = status
                        };
                        await _dingDing.SendBotMsg($"CosmosDBTrigger,{pk}触发变更\n{data.ToJsonString()}"  ,
                                        GroupNames.成都开发測試群組);
                        switch (pk)
                        {
                            case "Exam":
                                TriggerExam.Trigger(_azureCosmos, _serviceBus, _azureStorage, _dingDing, client,input,code,stime,etime,school);
                                break;
                            case "Vote":
                                TriggerVote.Trigger( _serviceBus, _azureStorage, _dingDing, client, input, data, _azureRedis);
                                break;
                            case "Survey":
                                TriggerSurvey.Trigger( _serviceBus, _azureStorage, _dingDing, client, input, data, _azureRedis);
                                break;

                        }
                    }
                }
            }
        }
    }
    public class TriggerData {
        public int? status { get; set; }
        public string name { get; set; }
        public long stime { get; set; }
        public long etime { get; set; }
        public string school { get; set; }
        public string code { get; set; }
        public string owner { get; set; }
        public string progress { get; set; }
        public string scope { get; set; }
        public int ttl { get; set; }
        public string id { get; set; }
    }
}