TEAMModelOS/TEAMModelOS.Service/Services/Learn/Implements/ServiceBusService.cs

using Microsoft.Azure.ServiceBus;
using System;
using System.Collections.Generic;
using System.Reflection;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using TEAMModelOS.SDK.Helper.Common.CollectionHelper;
using TEAMModelOS.SDK.Helper.Common.DateTimeHelper;
using TEAMModelOS.SDK.Helper.Common.JsonHelper;
using TEAMModelOS.SDK.Module.AzureCosmosDBV3;
using TEAMModelOS.SDK.Module.AzureServiceBus;
using TEAMModelOS.Service.Services.Learn.Interfaces;

namespace TEAMModelOS.Service.Services.Learn.Implements
{
    
    public class ServiceBusService : IServiceBusService
    {
        private readonly IAzureServiceBusService _serviceBus;
        public ServiceBusService(IAzureServiceBusService azureServiceBus)
        {
            _serviceBus = azureServiceBus;
        }        

        public async Task<long> SendMessage<T>(string TopicName, string info, long startTime, int status)
        {
            ITopicClient topicClient = _serviceBus.GetTopClient(TopicName).topicClient;
            //设定开始时间
            Dictionary<string, object> dict = new Dictionary<string, object>() {
                    { "name",typeof(T).Name},
                    { "info",info},
                    { "status",status}
                };
            var message = new Message(Encoding.UTF8.GetBytes(dict.ToApiJson()));
            long time = startTime - new DateTimeOffset(DateTime.UtcNow).ToUnixTimeMilliseconds();
            if (time <= 0)
            {
                return -1;
            }
            message.MessageId = Guid.NewGuid().ToString();
            DateTime timer = DateTimeHelper.ConvertToDateTime(startTime);
            long SequenceNumber = await topicClient.ScheduleMessageAsync(message, new DateTimeOffset(timer));
            await topicClient.SendAsync(message);
            //await topicClient.CloseAsync();
            return SequenceNumber;
        }
    }
}