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 {