znyc.cloudcar/Zncy.CloudCar.WeChat.Service/Mediator/TextMessageEventCommand.cs

using MediatR;
using SKIT.FlurlHttpClient.Wechat.Api;
using SKIT.FlurlHttpClient.Wechat.Api.Events;
using Zncy.CloudCar.WeChat.Service.Models;
using Zncy.CloudCar.WeChat.Service.Services.HttpClients;
using Znyc.CloudCar.Utility.Helper;

namespace Zncy.CloudCar.WeChat.Service.Mediator
{
    /// <summary>
    /// 表示 TEXT 事件的数据
    /// </summary>
    public class TextMessageEventCommand : IRequest<WeChatApiCallBack>
    {
#pragma warning disable CS8618 // 在退出构造函数时，不可为 null 的 属性“EventObj”必须包含非 null 值。请考虑将 属性 声明为可以为 null。
        public TextMessageEvent EventObj { get; set; }
#pragma warning restore CS8618 // 在退出构造函数时，不可为 null 的 属性“EventObj”必须包含非 null 值。请考虑将 属性 声明为可以为 null。
    }

    public class TextMessageEventCommandHandler : IRequestHandler<TextMessageEventCommand, WeChatApiCallBack>
    {
        private readonly IWeChatApiHttpClientFactory _weChatApiHttpClientFactory;

        public TextMessageEventCommandHandler(IWeChatApiHttpClientFactory weChatApiHttpClientFactory)
        {
            _weChatApiHttpClientFactory = weChatApiHttpClientFactory;
        }

        public Task<WeChatApiCallBack> Handle(TextMessageEventCommand request, CancellationToken cancellationToken)
        {
            var jm = new WeChatApiCallBack() { Status = true };
            if (request.EventObj != null)
            {
                var client = _weChatApiHttpClientFactory.CreateWxOpenClient();
                var replyModel = new TransferCustomerServiceReply()
                {
                    ToUserName = request.EventObj.FromUserName,
                    FromUserName = request.EventObj.ToUserName,
                    CreateTimestamp = CommonHelper.GetTimeStampByTotalSeconds()
                };
                var replyXml = client.SerializeEventToXml(replyModel);
                jm.Data = replyXml;
            }
            return Task.FromResult(jm);
        }
    }
}