data-sharing/src/DataSharing.YiBin/SendTaskDataService.cs

using DataSharing.DataExchange;
using DataSharing.Province;
using DataSharing.SendTask;
using DataSharing.YiBin.Enterprise;
using DataSharing.YiBin.OtherPlatformsYB;
using Microsoft.Extensions.Logging;

namespace DataSharing.YiBin
{
    /// <summary>
    /// 执行推送任务
    /// </summary>
    public class SendTaskDataService : ISendTaskDataService
    {
        private readonly ILogger<SendTaskDataService> _logger;
        private readonly IPusherProviderService _pusherProviderService;
        private readonly IEnterprisePusherProviderService _enterprisePusherProviderService;
        private readonly IDataExchangePusherProviderService _dataExchangePusherProviderService;
        private readonly IZzptPusherProviderService _zzptPusherProviderService;

        /// <summary>
        /// 
        /// </summary>
        /// <param name="logger"></param>
        /// <param name="pusherProviderService"></param>
        /// <param name="enterprisePusherProviderService"></param>
        /// <param name="dataExchangePusherProviderService"></param>
        /// <param name="zzptPusherProviderService"></param>
        public SendTaskDataService(ILogger<SendTaskDataService> logger,
         IPusherProviderService pusherProviderService,
         IEnterprisePusherProviderService enterprisePusherProviderService,
         IDataExchangePusherProviderService dataExchangePusherProviderService,
         IZzptPusherProviderService zzptPusherProviderService)
        {
            _logger = logger;
            _pusherProviderService = pusherProviderService;
            _enterprisePusherProviderService = enterprisePusherProviderService;
            _dataExchangePusherProviderService = dataExchangePusherProviderService;
            _zzptPusherProviderService = zzptPusherProviderService;
        }

        /// <summary>
        /// 执行推送任务
        /// </summary>
        /// <param name="dto"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public async Task SendTask(DsSendTask dto, CancellationToken cancellationToken)
        {
            if (dto is null)
                return;

            switch (dto.PlatformSource)
            {
                case Share.Enums.EPlatformSource.Province:
                    await _pusherProviderService.SendProvinceDataPusher(dto, cancellationToken);
                    break;
                case Share.Enums.EPlatformSource.Police110:
                    break;
                case Share.Enums.EPlatformSource.CityDataExchange:
                    await _dataExchangePusherProviderService.SendDataExchangeDataPusher(dto, cancellationToken);
                    break;
                case Share.Enums.EPlatformSource.ConvergenceMedia:
                    break;
                case Share.Enums.EPlatformSource.Enterprise:
                    await _enterprisePusherProviderService.SendEnterpriseDataPusher(dto, cancellationToken);
                    break;
                case Share.Enums.EPlatformSource.ZZPT:
                    await _zzptPusherProviderService.SendDataPusher(dto, cancellationToken);
                    break;
                default:
                    break;
            }
        }

    }
}