From 6f14c195e877f63ac7bdf11eee8f658b5fc330e8 Mon Sep 17 00:00:00 2001 From: YunaiV Date: Mon, 5 Oct 2026 22:43:06 +0800 Subject: [PATCH] refactor(pay): 精简钱包余额流水修复代码 --- yudao-module-pay/src/main/java/cn/iocoder/yudao/module/pay/service/wallet/PayWalletServiceImpl.java | 18 +++++++----------- 1 file changed, 7 insertions(+), 11 deletions(-) diff --git a/yudao-module-pay/src/main/java/cn/iocoder/yudao/module/pay/service/wallet/PayWalletServiceImpl.java b/yudao-module-pay/src/main/java/cn/iocoder/yudao/module/pay/service/wallet/PayWalletServiceImpl.java index 6f92ca5..d091b96 100644 --- a/yudao-module-pay/src/main/java/cn/iocoder/yudao/module/pay/service/wallet/PayWalletServiceImpl.java +++ b/yudao-module-pay/src/main/java/cn/iocoder/yudao/module/pay/service/wallet/PayWalletServiceImpl.java @@ -153,7 +153,7 @@ public class PayWalletServiceImpl implements PayWalletService { // 2. 加锁，更新钱包余额（目的：避免钱包流水的并发更新时，余额变化不连贯） return lockRedisDAO.lock(walletId, UPDATE_TIMEOUT_MILLIS, () -> { - // 2.1 扣除余额（CAS 原子扣减，先于重读，确保重读拿到扣减后最新值） + // 2.1 扣除余额 int updateCounts; switch (bizType) { case PAYMENT: { @@ -173,16 +173,13 @@ public class PayWalletServiceImpl implements PayWalletService { throw exception(WALLET_BALANCE_NOT_ENOUGH); } - // 2.2 CAS 后重读钱包（事务内读自身更新，拿到扣减后最新余额；锁外预读的 balance 在并发时已过期， - // 且 @Transactional REPEATABLE READ 下 CAS 前重读仍读事务快照旧值，须 CAS 后重读） + // 2.2 更新后重新查询钱包，避免使用锁外读取的旧余额生成流水 PayWalletDO currentWallet = getWallet(walletId); // 3. 生成钱包流水 - // 情况一：充值退款：balance 在冻结时已扣，updateWhenRechargeRefund 只扣 freeze_price，balance 不变，afterBalance=当前余额 - // 情况二：消费支付：updateWhenConsumption 从 balance 扣 price，CAS 后重读的 balance 即扣减后值，afterBalance=当前余额 - Integer afterBalance = currentWallet.getBalance(); + // 充值退款时，余额已在冻结时扣除，本次只扣冻结金额。https://t.zsxq.com/OJk9m WalletTransactionCreateReqBO bo = new WalletTransactionCreateReqBO().setWalletId(payWallet.getId()) - .setPrice(-price).setBalance(afterBalance).setBizId(String.valueOf(bizId)) + .setPrice(-price).setBalance(currentWallet.getBalance()).setBizId(String.valueOf(bizId)) .setBizType(bizType.getType()).setTitle(bizType.getDescription()); return walletTransactionService.createWalletTransaction(bo); }); @@ -202,7 +199,7 @@ public class PayWalletServiceImpl implements PayWalletService { // 2. 加锁，更新钱包余额（目的：避免钱包流水的并发更新时，余额变化不连贯） return lockRedisDAO.lock(walletId, UPDATE_TIMEOUT_MILLIS, () -> { - // 2.1 更新钱包金额（CAS 原子加，先于重读，确保重读拿到加值后最新值） + // 2.1 更新钱包金额 switch (bizType) { case PAYMENT_REFUND: { // 退款更新 walletMapper.updateWhenConsumptionRefund(payWallet.getId(), price); @@ -221,11 +218,10 @@ public class PayWalletServiceImpl implements PayWalletService { } } - // 2.2 CAS 后重读钱包（事务内读自身更新，拿到加值后最新余额；锁外预读的 balance 在并发时已过期， - // 且 @Transactional REPEATABLE READ 下 CAS 前重读仍读事务快照旧值，须 CAS 后重读） + // 2.2 更新后重新查询钱包，避免使用锁外读取的旧余额生成流水 PayWalletDO currentWallet = getWallet(walletId); - // 3. 生成钱包流水（afterBalance = CAS 后最新余额，无需再 +price） + // 3. 生成钱包流水 WalletTransactionCreateReqBO transactionCreateReqBO = new WalletTransactionCreateReqBO() .setWalletId(payWallet.getId()).setPrice(price).setBalance(currentWallet.getBalance()) .setBizId(bizId).setBizType(bizType.getType()).setTitle(bizType.getDescription()); -- libgit2 0.21.4