From 55360f22ef7b665cb495710270cf0e7c2b08916a 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 11:09:17 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=86=E9=94=80=E5=91=98=E5=BC=80=E9=80=9A?=
 =?UTF-8?q?=E5=9B=9E=E8=B0=83=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/MkDistributionUserServiceImpl.java    | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

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 d112a4c8..6a43269f 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
@@ -541,9 +541,13 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
                 .setType(TableValueConstant.DistributionAmountFlow.Type.OPEN.getCode())
                 .setMainShopId(mainShopId).setShopId(shopId).setAmount(finalAmount).setChangeAmount(amount).setSourceId(sourceId)
                 .setRemark("分销员购买"));
-        addDistributionUser(new MkDistributionUser().setShopId(shopId)
-                .setUserId(shopUserInfo.getUserId())
-                .setId(shopUserInfo.getId()).setOpeningMethod("付费开通"));
+        try {
+            addDistributionUser(new MkDistributionUser().setShopId(shopId)
+                    .setUserId(shopUserInfo.getUserId())
+                    .setId(shopUserInfo.getId()).setOpeningMethod("付费开通"));
+        }catch (Exception e) {
+            log.error("分销员开通失败", e);
+        }
     }