From cd9acb3678a2c11cbf0d7e6bc52ba51e78c68a3e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?=
 <8605635+zhang3064194730@user.noreply.gitee.com>
Date: Thu, 30 Oct 2025 10:43:23 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BF=90=E8=90=A5=E7=AB=AF=E5=85=85=E5=80=BC?=
 =?UTF-8?q?=20=E5=88=86=E8=B4=A6=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../czg/service/account/service/impl/ShopInfoServiceImpl.java | 1 +
 .../market/service/impl/MkDistributionUserServiceImpl.java    | 4 +++-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/ShopInfoServiceImpl.java b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/ShopInfoServiceImpl.java
index ad6e1a674..2cd6bf822 100644
--- a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/ShopInfoServiceImpl.java
+++ b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/ShopInfoServiceImpl.java
@@ -447,6 +447,7 @@ public class ShopInfoServiceImpl extends ServiceImpl<ShopInfoMapper, ShopInfo> i
         return list(queryWrapper);
     }
 
+    @CacheEvict(key = "#id")
     @Override
     public BigDecimal updateAmount(Long id, BigDecimal amount) {
         ShopInfo shopInfo = getShopInfo(id);
diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionUserServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionUserServiceImpl.java
index bf3e3f964..0bec33805 100644
--- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionUserServiceImpl.java
+++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionUserServiceImpl.java
@@ -580,6 +580,7 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
         if (currentShopUser.getDistributionUserId() != null) {
             MkDistributionUser parent = getOne(new QueryWrapper().eq(MkDistributionUser::getId, currentDistributionUser.getDistributionLevelId()));
             if (parent == null) {
+                log.info("上级分销员不存在: {}", currentDistributionUser.getDistributionLevelId());
                 return;
             }
             try {
@@ -626,6 +627,7 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
 
         if (delayTime == null) {
             mkDistributionFlow.setStatus(TableValueConstant.DistributionFlow.Status.SUCCESS.getCode());
+            log.info("即时分销开始");
             try {
                 updateShopInfoAmount(currentDistributionUser.getShopId(), rewardAmount, mkDistributionFlow.getId());
                 updateIncome(BigDecimal.ZERO, rewardAmount, BigDecimal.ZERO, currentDistributionUser.getId(), shopUser.getUserId(), shopUser.getMainShopId(), currentLevel  == 1 ? 1 : 2);
@@ -634,8 +636,8 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
                 distributionFlowService.updateById(mkDistributionFlow);
             }
         }else {
+            log.info("延时分销开始");
             updateIncome(rewardAmount, BigDecimal.ZERO, BigDecimal.ZERO, currentDistributionUser.getId(), shopUser.getUserId(), shopUser.getMainShopId(), currentLevel  == 1 ? 1 : 2);
-
         }
     }