sharing/src/Sharing.Province/Handlers/XieTong/SendRemindCaseInfoHandler.cs

using MapsterMapper;
using MediatR;
using Sharing.Notifications.XieTong;
using Sharing.Province.Dtos.XieTong.Send;
using Sharing.Province.XieTong.Receive;
using XF.Domain.Repository;

namespace Sharing.Province.Handlers.XieTong
{
    /// <summary>
    /// 服务工单催单
    /// </summary>
    public class SendRemindCaseInfoHandler : INotificationHandler<SendRemindCaseInfoNotification>
    {
        private readonly IChannelConfigurationManager _channelConfigurationManager;
        private readonly PusherProvider _pusherProvider;
        private readonly IMapper _mapper;
        private readonly IRepository<RemindCaseInfo> _remindCaseInfoRepository;

        /// <summary>
        /// 
        /// </summary>
        /// <param name="channelConfigurationManager"></param>
        /// <param name="pusherProvider"></param>
        /// <param name="mapper"></param>
        /// <param name="remindCaseInfoRepository"></param>
        public SendRemindCaseInfoHandler(IChannelConfigurationManager channelConfigurationManager, PusherProvider pusherProvider, IMapper mapper
            , IRepository<RemindCaseInfo> remindCaseInfoRepository)
        {
            _channelConfigurationManager = channelConfigurationManager;
            _pusherProvider = pusherProvider;
            _mapper = mapper;
            _remindCaseInfoRepository = remindCaseInfoRepository;
        }

        /// <summary>
        /// 服务工单催单 
        /// </summary>
        /// <param name="notification"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public async Task Handle(SendRemindCaseInfoNotification notification, CancellationToken cancellationToken = default)
        {
            var pusher = _pusherProvider.CreatePusher(_channelConfigurationManager);

            var dataReceive = _mapper.Map<RemindCaseInfoInfo>(notification.Data);

            var request = new SendRemindCaseInfoRequest();
            request.ForeachClass(dataReceive);
            request.SetData(dataReceive);

            var response = await pusher.PushSendRemindCaseInfoAsync(request, cancellationToken);

            //如果推送成功修改数据状态
            if (response != null)
            {
                if (response.Code == "1")
                    notification.Data.SyncState = "1";
                else
                    notification.Data.SyncState = "2";

                notification.Data.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
                await _remindCaseInfoRepository.UpdateAsync(notification.Data);
            }
        }
    }
}