From bf17ad2051de62b9b49fb72bf6ae14d23bfef62b Mon Sep 17 00:00:00 2001
From: sunpengfei <i@angelzzz.com>
Date: 星期四, 11 九月 2025 10:20:20 +0800
Subject: [PATCH] feat:开发
---
FlexJobApi.UserServer.Application/EnterpriseWallets/Commands/EnterpriseWalletCommandHandler.cs | 113 +++++++++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 107 insertions(+), 6 deletions(-)
diff --git a/FlexJobApi.UserServer.Application/EnterpriseWallets/Commands/EnterpriseWalletCommandHandler.cs b/FlexJobApi.UserServer.Application/EnterpriseWallets/Commands/EnterpriseWalletCommandHandler.cs
index ab40e91..b59fc51 100644
--- a/FlexJobApi.UserServer.Application/EnterpriseWallets/Commands/EnterpriseWalletCommandHandler.cs
+++ b/FlexJobApi.UserServer.Application/EnterpriseWallets/Commands/EnterpriseWalletCommandHandler.cs
@@ -19,11 +19,13 @@
/// </summary>
public class EnterpriseWalletCommandHandler(
IRepository<EnterpriseWallet> rep,
+ IRepository<EnterpriseWalletTransaction> repEnterpriseWalletTransaction,
IRepository<Enterprise> repEnterprise,
AlipayUtils alipayUtils
) :
IRequestHandler<OpenEnterpriseWalletCommand, OpenEnterpriseWalletCommandResult>,
- IRequestHandler<CloseEnterpriseWalletCommand, Guid>
+ IRequestHandler<CloseEnterpriseWalletCommand, Guid>,
+ IRequestHandler<RechargeEnterpriseWalletCommand, RechargeEnterpriseWalletCommandResult>
{
private readonly IRepository<EnterpriseWallet> rep = rep;
private readonly IRepository<Enterprise> repEnterprise = repEnterprise;
@@ -38,18 +40,23 @@
public async Task<OpenEnterpriseWalletCommandResult> Handle(OpenEnterpriseWalletCommand request, CancellationToken cancellationToken)
{
var logier = JwtUtils.GetCurrentLogier();
+ if (logier.Type == EnumUserType.Enterprise)
+ {
+ request.EnterpriseId = logier.EnterpriseId;
+ }
+ if (request.EnterpriseId == null) throw Oops.Oh(EnumErrorCodeType.s400, "璇峰～鍐欎紒涓欼d");
var enterprise = await repEnterprise.AsQueryable().AsNoTracking()
- .Where(it => it.Id == logier.EnterpriseId)
+ .Where(it => it.Id == request.EnterpriseId)
.FirstOrDefaultAsync();
if (enterprise == null) throw Oops.Oh(EnumErrorCodeType.s404, "浼佷笟");
if (!enterprise.IsReal) throw Oops.Oh(EnumErrorCodeType.s510, "璇峰厛瀹炲悕");
var entity = await rep.AsQueryable()
- .Where(it => it.EnterpriseId == logier.EnterpriseId && it.Access == request.Access)
+ .Where(it => it.EnterpriseId == request.EnterpriseId && it.Access == request.Access)
.FirstOrDefaultAsync();
if (entity == null)
{
entity = new EnterpriseWallet();
- entity.EnterpriseId = logier.EnterpriseId!.Value;
+ entity.EnterpriseId = request.EnterpriseId!.Value;
entity.Access = EnumEnterpriseWalletAccess.Alipay;
entity.PersonalProductCode = "FUND_SAFT_SIGN_WITHHOLDING_P";
entity.SignScene = "INDUSTRY|SATF_ACC";
@@ -79,7 +86,7 @@
var response = alipayUtils.UserAgreementPageSign(model, $"/api/user/enterpriseWallet/alipayUserAgreementPageSignNotify");
if (response.IsError) throw Oops.Oh(EnumErrorCodeType.s510, response.SubMsg ?? response.Msg);
var result = new OpenEnterpriseWalletCommandResult();
- result.SignUrl = response.Body;
+ result.SignUrl = response.Body;
return result;
}
@@ -92,8 +99,13 @@
public async Task<Guid> Handle(CloseEnterpriseWalletCommand request, CancellationToken cancellationToken)
{
var logier = JwtUtils.GetCurrentLogier();
+ if (logier.Type == EnumUserType.Enterprise)
+ {
+ request.EnterpriseId = logier.EnterpriseId;
+ }
+ if (request.EnterpriseId == null) throw Oops.Oh(EnumErrorCodeType.s400, "璇峰～鍐欎紒涓欼d");
var entity = await rep.AsQueryable()
- .Where(it => it.EnterpriseId == logier.EnterpriseId && it.Access == request.Access)
+ .Where(it => it.EnterpriseId == request.EnterpriseId && it.Access == request.Access)
.FirstOrDefaultAsync();
if (entity == null) throw Oops.Oh(EnumErrorCodeType.s404, "浼佷笟閽卞寘");
if (entity.SignStatus != EnumEnterpriseWalletSignStatus.Normal) throw Oops.Oh(EnumErrorCodeType.s510, "鏈绾�");
@@ -108,6 +120,95 @@
return entity.Id;
}
+ /// <summary>
+ /// 浼佷笟閽卞寘鍏呭��
+ /// </summary>
+ /// <param name="request"></param>
+ /// <param name="cancellationToken"></param>
+ /// <returns></returns>
+ /// <exception cref="NotImplementedException"></exception>
+ [UnitOfWork(false)]
+ public async Task<RechargeEnterpriseWalletCommandResult> Handle(RechargeEnterpriseWalletCommand request, CancellationToken cancellationToken)
+ {
+ var logier = JwtUtils.GetCurrentLogier();
+ if (logier.Type == EnumUserType.Enterprise)
+ {
+ request.EnterpriseId = logier.EnterpriseId;
+ }
+ if (request.EnterpriseId == null) throw Oops.Oh(EnumErrorCodeType.s400, "璇峰～鍐欎紒涓欼d");
+ var entity = await rep.AsQueryable()
+ .Where(it => it.EnterpriseId == request.EnterpriseId && it.Access == request.Access)
+ .FirstOrDefaultAsync();
+ if (entity == null) throw Oops.Oh(EnumErrorCodeType.s404, "浼佷笟閽卞寘");
+ if (entity.SignStatus != EnumEnterpriseWalletSignStatus.Normal) throw Oops.Oh(EnumErrorCodeType.s510, "鏈绾�");
+ if (entity.AccountBookStatus != EnumEnterpriseWalletAccountBookStatus.Normal) throw Oops.Oh(EnumErrorCodeType.s510, "鏈紑閫氳璐︽湰");
+ await GetBalance(entity);
+ var order = new EnterpriseWalletTransaction();
+ order.Type = EnumEnterpriseWalletTransactionType.Recharge;
+ order.WalletId = entity.Id;
+ order.Amount = request.Amount;
+ order.Remark = request.Remark ?? "鍏呭��";
+ order.ProductCode = "FUND_ACCOUNT_BOOK";
+ order.BizScene = "SATF_DEPOSIT";
+ order.TransactionStatus = EnumWalletTransactionStatus.WaitSubmit;
+ order.Balance = entity.Balance;
+ order.OperatorUserId = logier.Id;
+ order.OperatorTime = DateTime.Now;
+ await SetCode(order);
+ await repEnterpriseWalletTransaction.InsertAsync(order);
+
+ var response = alipayUtils.FundTransPagePay(new AlipayFundTransPagePayModel
+ {
+ OutBizNo = order.Code,
+ TransAmount = order.Amount.ToString(),
+ ProductCode = order.ProductCode,
+ BizScene = order.BizScene,
+ Remark = order.Remark,
+ OrderTitle = order.Remark,
+ TimeExpire = DateTime.Now.AddMinutes(15).ToString("yyyy-MM-dd HH:mm"),
+ PayeeInfo = new Participant
+ {
+ IdentityType = "ACCOUNT_BOOK_ID",
+ Identity = entity.AccountBookId,
+ ExtInfo = new
+ {
+ agreement_no = entity.AgreementNo,
+ }.ToJson(),
+ },
+ }, "/api/user/enterpriseWallet/alipayFundTransOrderChangedNotify");
+ if (response.IsError) throw Oops.Oh(EnumErrorCodeType.s510, response.SubMsg ?? response.Msg);
+ order.TransactionStatus = EnumWalletTransactionStatus.WaitPay;
+ await repEnterpriseWalletTransaction.UpdateAsync(order);
+ return new RechargeEnterpriseWalletCommandResult
+ {
+ PayUrl = response.Body
+ };
+ }
+
+ private async Task GetBalance(EnterpriseWallet entity)
+ {
+ var response = alipayUtils.FundAccountbookQuery(new AlipayFundAccountbookQueryModel
+ {
+ AccountBookId = entity.AccountBookId,
+ SceneCode = "SATF_FUND_BOOK",
+ MerchantUserId = entity.Code,
+ });
+ if (response.IsError) throw Oops.Oh(EnumErrorCodeType.s510, response.SubMsg ?? response.Msg);
+ entity.Balance = response.AvailableAmount.ToDecimal() ?? 0;
+ await rep.UpdateNowAsync(entity);
+ }
+
+ private async Task SetCode(EnterpriseWalletTransaction entity)
+ {
+ entity.Code = $"{DateTime.Now:yyyyMMddHHmmss}{new Random(IDGen.NextID().GetHashCode()).Next(1000, 9999)}";
+ var exist = await repEnterpriseWalletTransaction.AsQueryable().AsNoTracking()
+ .AnyAsync(it => it.Code == entity.Code);
+ if (exist)
+ {
+ await SetCode(entity);
+ }
+ }
+
private async Task SetCode(EnterpriseWallet entity)
{
entity.Code = $"{DateTime.Now:yyyyMMddHHmmss}{new Random(IDGen.NextID().GetHashCode()).Next(1000, 9999)}";
--
Gitblit v1.9.1