12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849 |
- 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;
- }
- }
- }
|