From ab9b84ee42c872cd2277d2e3a863718355bcc6aa Mon Sep 17 00:00:00 2001
From: sunpengfei <i@angelzzz.com>
Date: 星期一, 15 十二月 2025 16:20:27 +0800
Subject: [PATCH] feat:开发
---
ApiTools.Application/ChannelWallets/Commands/ChannelWalletCommandHandler.cs | 28 ++++++++++++++++++++++++++--
1 files changed, 26 insertions(+), 2 deletions(-)
diff --git a/ApiTools.Application/ChannelWallets/Commands/ChannelWalletCommandHandler.cs b/ApiTools.Application/ChannelWallets/Commands/ChannelWalletCommandHandler.cs
index 50032f2..51d567d 100644
--- a/ApiTools.Application/ChannelWallets/Commands/ChannelWalletCommandHandler.cs
+++ b/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;
+ }
}
}
--
Gitblit v1.9.1