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 84b5a0512..d2c77481f 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
@@ -30,9 +30,12 @@ import com.czg.market.service.*;
 import com.czg.market.vo.InviteUserVO;
 import com.czg.market.vo.MkDistributionConfigVO;
 import com.czg.order.dto.MkDistributionPayDTO;
+import com.czg.order.entity.OrderInfo;
 import com.czg.order.entity.OrderPayment;
+import com.czg.order.service.OrderInfoService;
 import com.czg.order.service.OrderPaymentService;
 import com.czg.sa.StpKit;
+import com.czg.service.market.enums.OrderStatusEnums;
 import com.czg.service.market.mapper.MkDistributionUserMapper;
 import com.czg.utils.AssertUtil;
 import com.czg.utils.CzgRandomUtils;
@@ -47,6 +50,7 @@ import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.dubbo.config.annotation.DubboReference;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
 import java.util.*;
@@ -88,6 +92,8 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
     @DubboReference
     private OrderPaymentService orderPaymentService;
     @DubboReference
+    private OrderInfoService orderInfoService;
+    @DubboReference
     private ShopInfoService shopInfoService;
 
     @Override
@@ -210,14 +216,18 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
     }
 
     @Override
+    @Transactional
     public void bindInviteUser(MkDistributionUserDTO param) {
         ShopUser shopUser = shopUserService.getById(param.getId());
         AssertUtil.isNull(shopUser, "店铺用户不存在");
-        if(shopUser.getDistributionUserId() != null){
+        if (shopUser.getDistributionUserId() != null) {
             throw new CzgException("店铺用户已绑定分销员");
         }
         MkDistributionUser parent = getOne(QueryWrapper.create().eq(MkDistributionUser::getInviteCode, param.getInviteCode()));
         AssertUtil.isNull(parent, "邀请人不存在");
+        if (parent.getStatus() == 9) {
+            throw new CzgException("绑定失败该邀请人分销身份已被取消");
+        }
         ShopUser newShopUser = new ShopUser();
         newShopUser.setId(shopUser.getId());
         newShopUser.setDistributionUserId(parent.getId());
@@ -226,21 +236,28 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
         MkDistributionUser newDistributionUser = new MkDistributionUser();
         newDistributionUser.setId(parent.getId());
         newDistributionUser.setInviteCount(parent.getInviteCount() + 1);
-        if (parent.getStatus() != 9) {
-            MkDistributionConfig mkDistributionConfig = mkDistributionConfigService.getOne(QueryWrapper.create()
-                    .eq(MkDistributionConfig::getShopId, parent.getShopId()));
-            if (mkDistributionConfig != null) {
-                if ("invite".equals(mkDistributionConfig.getUpgradeType())) {
-                    MkDistributionLevelConfig levelConfig = levelConfigService.getOne(QueryWrapper.create()
-                            .eq(MkDistributionLevelConfig::getShopId, parent.getShopId())
-                            .le(MkDistributionLevelConfig::getInviteCount, parent.getInviteCount())
-                            .gt(MkDistributionLevelConfig::getId, parent.getDistributionLevelId())
-                            .orderBy(MkDistributionLevelConfig::getLevel).desc().limit(1));
-                    if (levelConfig != null) {
-                        newDistributionUser.setDistributionLevelId(levelConfig.getId());
-                        newDistributionUser.setDistributionLevelName(levelConfig.getName());
+        MkDistributionConfig mkDistributionConfig = mkDistributionConfigService.getOne(QueryWrapper.create()
+                .eq(MkDistributionConfig::getShopId, parent.getShopId()));
+        if (mkDistributionConfig != null) {
+            if ("invite".equals(mkDistributionConfig.getUpgradeType())) {
+                if (mkDistributionConfig.getInviteConsume() == 1) {
+                    long count = orderInfoService.count(QueryWrapper.create()
+                            .eq(OrderInfo::getUserId, shopUser.getId())
+                            .eq(OrderInfo::getShopId, parent.getShopId())
+                            .eq(OrderInfo::getStatus, OrderStatusEnums.DONE.getCode()));
+                    if (count < 1) {
+                        throw new CzgException("绑定失败,被邀请人需要成功支付一笔订单");
                     }
                 }
+                MkDistributionLevelConfig levelConfig = levelConfigService.getOne(QueryWrapper.create()
+                        .eq(MkDistributionLevelConfig::getShopId, parent.getShopId())
+                        .le(MkDistributionLevelConfig::getInviteCount, parent.getInviteCount())
+                        .gt(MkDistributionLevelConfig::getId, parent.getDistributionLevelId())
+                        .orderBy(MkDistributionLevelConfig::getId).asc().limit(1));
+                if (levelConfig != null) {
+                    newDistributionUser.setDistributionLevelId(levelConfig.getId());
+                    newDistributionUser.setDistributionLevelName(levelConfig.getName());
+                }
             }
         }
         this.updateById(newDistributionUser);
@@ -329,7 +346,7 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
         ShopUser shopUser = shopUserService.getById(param.getId());
         AssertUtil.isNull(shopUser, "店铺用户ID不能为空");
         boolean isExits = shopUser.checkDistributionShops(param.getShopId().toString());
-        if(isExits){
+        if (isExits) {
             throw new CzgException("该用户已被添加为分销员,不可重复添加");
         }
         MkDistributionConfig config = mkDistributionConfigService.getOne(