From 5d1ca83851e79ce5b022c54e6792a4eed8e5585b Mon Sep 17 00:00:00 2001
From: gaowdong <gaowdong@bonus.com>
Date: Wed, 30 Apr 2025 09:34:54 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=87=8F=E9=92=B1=E5=8C=85=E4=BD=99?=
 =?UTF-8?q?=E9=A2=9D=E4=BF=9D=E6=8A=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../core/account/business/AccWalletInfoBusiness.java        | 3 +++
 .../core/account/service/impl/AccWalletInfoServiceImpl.java | 6 ++++++
 2 files changed, 9 insertions(+)

diff --git a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/business/AccWalletInfoBusiness.java b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/business/AccWalletInfoBusiness.java
index 12acc0f..a5066d8 100644
--- a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/business/AccWalletInfoBusiness.java
+++ b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/business/AccWalletInfoBusiness.java
@@ -52,6 +52,8 @@ public class AccWalletInfoBusiness {
     IAccTradeService accTradeService;
     @Autowired
     IAccTradeWalletDetailService accTradeWalletDetailService;
+
+    //此方法不可以直接调用，须通过service中的方法调用
     @Transactional(rollbackFor = Exception.class)
     public void addAccWalletBalance(WalletUpdateDTO walletUpdateDTO) {
         log.info("新增钱包入参: {}", JacksonUtil.writeValueAsString(walletUpdateDTO));
@@ -70,6 +72,7 @@ public class AccWalletInfoBusiness {
         log.info("新增钱包结束");
     }
 
+    //此方法不可以直接调用，须通过service中的方法调用
     @Transactional(rollbackFor = Exception.class)
     public void clearAccWalletBalance(WalletUpdateDTO walletUpdateDTO) {
         log.info("扣减钱包入参: {}", JacksonUtil.writeValueAsString(walletUpdateDTO));
diff --git a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/service/impl/AccWalletInfoServiceImpl.java b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/service/impl/AccWalletInfoServiceImpl.java
index 5e75fa2..f7f1d72 100644
--- a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/service/impl/AccWalletInfoServiceImpl.java
+++ b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/service/impl/AccWalletInfoServiceImpl.java
@@ -180,6 +180,9 @@ public class AccWalletInfoServiceImpl implements IAccWalletInfoService {
     @Override
     public void addAccWalletBalance(WalletUpdateDTO walletUpdateDTO) {
         if(!walletUpdateDTO.isBatch()) {
+            if(Objects.isNull(walletUpdateDTO.getUserId())) {
+                throw new ServiceException("用户编号不能为空");
+            }
             AccRedisUtils.lockUpdateAccWalletBalance(walletUpdateDTO.getUserId());
         }
         try {
@@ -197,6 +200,9 @@ public class AccWalletInfoServiceImpl implements IAccWalletInfoService {
     @Override
     public void clearAccWalletBalance(WalletUpdateDTO walletUpdateDTO) {
         if(!walletUpdateDTO.isBatch()) {
+            if(Objects.isNull(walletUpdateDTO.getUserId())) {
+                throw new ServiceException("用户编号不能为空");
+            }
             AccRedisUtils.lockUpdateAccWalletBalance(walletUpdateDTO.getUserId());
         }
         try {