From 911ca038ae045e2b5bc8b6dff82b873a6acf2834 Mon Sep 17 00:00:00 2001
From: wangw <1594593906@qq.com>
Date: Wed, 29 Oct 2025 16:25:57 +0800
Subject: [PATCH] =?UTF-8?q?=E5=B1=95=E7=A4=BA/=E7=BB=91=E5=AE=9A=E5=85=B3?=
 =?UTF-8?q?=E7=B3=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/MkDistributionUserServiceImpl.java    | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

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 b249d901..46bc14c5 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
@@ -260,6 +260,14 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
         if (parent.getStatus() == 9) {
             throw new CzgException("绑定失败该邀请人分销身份已被取消");
         }
+        ShopUser parentShopUser = shopUserService.getById(parent.getId());
+        AssertUtil.isNull(parentShopUser, "邀请人不存在");
+        if (parentShopUser.getDistributionUserId() != null && parentShopUser.getDistributionUserId().equals(shopUser.getId())) {
+            throw new CzgException("存在绑定关系，不可绑定");
+        }
+        if (parentShopUser.getDistributionUserParentId() != null && parentShopUser.getDistributionUserParentId().equals(shopUser.getId())) {
+            throw new CzgException("存在绑定关系，不可绑定");
+        }
         ShopUser newShopUser = new ShopUser();
         newShopUser.setId(shopUser.getId());
         newShopUser.setDistributionUserId(parent.getId());
@@ -284,7 +292,7 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
                 }
                 MkDistributionLevelConfig levelConfig = levelConfigService.getOne(QueryWrapper.create()
                         .eq(MkDistributionLevelConfig::getShopId, parent.getShopId())
-                        .le(MkDistributionLevelConfig::getInviteCount, parent.getInviteCount())
+                        .le(MkDistributionLevelConfig::getInviteCount, newDistributionUser.getInviteCount())
                         .gt(MkDistributionLevelConfig::getId, parent.getDistributionLevelId())
                         .orderBy(MkDistributionLevelConfig::getId).asc().limit(1));
                 if (levelConfig != null) {