TEAMModelOS/TEAMModelFunction/NoticeServiceBus.cs

using Azure.Messaging.ServiceBus;
using Microsoft.Azure.WebJobs;
using System;
using System.Collections.Generic;
using System.Text;
using System.Text.Json;
using System.Threading.Tasks;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK.Helper.Common.CollectionHelper;
using TEAMModelOS.SDK.Models;

namespace TEAMModelFunction
{
   
    public class NoticeServiceBus
    {
        private readonly AzureCosmosFactory _azureCosmos;
        private readonly AzureStorageFactory _azureStorage;
        private readonly AzureServiceBusFactory _serviceBus;
        private readonly DingDing _dingDing;
        public NoticeServiceBus(AzureCosmosFactory azureCosmos, DingDing dingDing,AzureStorageFactory azureStorage, AzureServiceBusFactory serviceBus)
        {
            _azureStorage = azureStorage;
            _azureCosmos = azureCosmos;
            _dingDing = dingDing;
            _serviceBus = serviceBus;
        }
        //[FunctionName("Notice")]
        //public async  Task Notice([ServiceBusTrigger("active-task", "notice", Connection = "Azure:ServiceBus:ConnectionString")] string msg) {
        //    var client = _azureCosmos.GetCosmosClient();
        //    try {
        //        await _dingDing.SendBotMsg($"NoticeServiceBus-Notice：\n发起通知{msg}", GroupNames.成都开发測試群組);
        //        List<Task<string>> tasks = new List<Task<string>>();
        //        List<Task> sessionTasks = new List<Task>();
        //        var jsonMsg = JsonDocument.Parse(msg);
        //        Notice notice = msg.ToObject<Notice>();
        //        var blobcntr = "";
        //        if (notice.scope.Equals("school"))
        //        {
        //            blobcntr = notice.school;
        //        }
        //        else {
        //            blobcntr = notice.creatorId;
        //        }
        //        var urlNotice = $"{notice.sid}.json";
        //        var blobNotice = new { 
        //            notice.sid, 
        //            notice.scode,
        //            notice.spk,
        //            notice.scope,
        //            notice.school,
        //            notice.type,
        //            notice.level,
        //            notice.data,
        //            notice.stime,
        //            notice.etime,
        //            notice.creatorId
        //        };
        //        tasks.Add(_azureStorage.UploadFileByContainer(blobcntr, blobNotice.ToJsonString(), "notice", urlNotice));
        //        var urlReceiver = $"{notice.sid}_receiver.json";
        //        var blobReceiver = new
        //        {
        //            notice.stuids,
        //            notice.tmdids
        //        };
        //        tasks.Add(_azureStorage.UploadFileByContainer(blobcntr, blobReceiver.ToJsonString(), "notice", urlReceiver));
        //        long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
        //        // "ttl":2592000,不能超过30天（2592000），一天（3600），一周（25200）
        //        long ttl = notice.etime - now;
        //        long day30 = 2592000L * 1000;
        //        if (ttl > day30) {
        //            ttl = day30;
        //        }
        //        if (notice.stuids.IsNotEmpty()) {
        //            //  List<Receiver> receivers = new List<Receiver>();
        //            foreach (var stu in notice.stuids) {
        //                Receiver receiver = new Receiver
        //                {
        //                    id = notice.sid,
        //                    pk = "Receiver",
        //                    status = 0,
        //                    school = stu.schoolId,
        //                    scope = "school",
        //                    code = $"Receiver-{stu.schoolId}-{stu.id}",
        //                    ttl = (int)ttl,
        //                    ctime= now,
        //                    urlNotice=$"notice/{urlNotice}"
        //                };
        //                await client.GetContainer("TEAMModelOS", "Student").UpsertItemAsync<Receiver>(receiver,new Azure.Cosmos.PartitionKey(receiver.code));
        //                //  /student/{stuid}/receive/{notice.sid}.json
        //                //存放通知到学生容器空间
        //                var url = $"{stu.id}/receive/{notice.sid}.json";
        //                tasks.Add(_azureStorage.UploadFileByContainer(blobcntr, receiver.ToJsonString(), "student", url));
        //                var messageBlob = new ServiceBusMessage(notice.ToJsonString()) { SessionId =$"{stu.schoolId}-{stu.id}"};
        //                messageBlob.ApplicationProperties.Add("name", "Receiver");
        //                sessionTasks.Add(_serviceBus.GetServiceBusClient().SendMessageAsync("active-task", messageBlob));
        //            }
        //        }
        //        if (notice.tmdids.IsNotEmpty())
        //        {
        //            foreach (var tmdid in notice.tmdids)
        //            {
        //                Receiver receiver = new Receiver
        //                {
        //                    id = notice.sid,
        //                    pk = "Receiver",
        //                    status = 0,
        //                    //school = stu.schoolId,
        //                    scope = "school",
        //                    code = $"Receiver-{tmdid}",
        //                    ttl = (int)ttl,
        //                    ctime = now,
        //                    urlNotice = $"notice/{urlNotice}"
        //                };
        //                await client.GetContainer("TEAMModelOS", "Teacher").UpsertItemAsync<Receiver>(receiver, new Azure.Cosmos.PartitionKey(receiver.code));
        //                //  /student/{stuid}/receive/{notice.sid}.json
        //                //存放通知到学生容器空间
        //                var url = $"{notice.sid}.json";
        //                tasks.Add(_azureStorage.UploadFileByContainer(blobcntr, receiver.ToJsonString(), "receive", url));
        //                var messageBlob = new ServiceBusMessage(notice.ToJsonString()) { SessionId = $"{tmdid}" };
        //                messageBlob.ApplicationProperties.Add("name", "Receiver");
        //                sessionTasks.Add(_serviceBus.GetServiceBusClient().SendMessageAsync("active-task", messageBlob));
        //            }
        //        }
        //        await Task.WhenAll(sessionTasks);
        //        await Task.WhenAll(tasks);
        //    } catch (Exception ex) {
        //         await _dingDing.SendBotMsg($"NoticeServiceBus-Notice\n{ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
        //    }
        //}
    }
}