feat:开发

sunpengfei

昨天 ab9b84ee42c872cd2277d2e3a863718355bcc6aa

 ApiTools.Application/ChannelWallets/Commands/ChannelWalletCommandHandler.cs

@@ -19,15 +19,18 @@
            IDistributedLockProvider distributedLockProvider,
            ChannelWalletRepository channelWalletRepository,
            ChannelWalletTransactionRepository channelWalletTransactionRepository,
            ChannelWalletService channelWalletService
            ChannelWalletService channelWalletService,
            NongYePayUtils nongYePayUtils
        ) :
        IRequestHandler<SaveChannelPingAnPayWalletCommand, SaveChannelPingAnPayWalletCommandResult>,
        IRequestHandler<SubmitChannelWalletTransferCommand, SubmitChannelWalletTransferCommandResult>
        IRequestHandler<SubmitChannelWalletTransferCommand, SubmitChannelWalletTransferCommandResult>,
        IRequestHandler<TestNongYePayCommand, bool>
    {
        private readonly IDistributedLockProvider distributedLockProvider = distributedLockProvider;
        private readonly ChannelWalletRepository channelWalletRepository = channelWalletRepository;
        private readonly ChannelWalletTransactionRepository channelWalletTransactionRepository = channelWalletTransactionRepository;
        private readonly ChannelWalletService channelWalletService = channelWalletService;
        private readonly NongYePayUtils nongYePayUtils = nongYePayUtils;

        /// <summary>
        /// 保存渠道平安银行钱包
@@ -91,6 +94,7 @@
            if (request.Amount > wallet.Balance) throw Oops.Oh(EnumErrorCodeType.s404, "余额不足");

            var transaction = await channelWalletTransactionRepository.GetQueryable()
                .Include(it => it.PingAnPay)
                .Where(it => it.WalletId == wallet.Id && it.OutCode == request.OutCode)
                .FirstOrDefaultAsync();
            if (transaction == null)
@@ -170,5 +174,25 @@
                FailReason = transaction.FailReason,
            };
        }

        /// <summary>
        /// 测试农业银行接口
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public async Task<bool> Handle(TestNongYePayCommand request, CancellationToken cancellationToken)
        {
            var res = await nongYePayUtils.GetBalance(new Core.Utils.NongYePayUtils.Models.NongYePayGetBalanceRequest
            {
                Cmp = new Core.Utils.NongYePayUtils.Models.NongYePayGetBalanceRequestCmp
                {
                    AccountNo = "314101046433493",
                    CurrencyCode = "01",
                    ProvinceCode = "14"
                }
            });
            return true;
        }
    }
}