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 24690c3b..5685ebc5 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
@@ -53,13 +53,10 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
     private MkDistributionConfigService mkDistributionConfigService;
     @Resource
     private MkDistributionLevelConfigService levelConfigService;
-    @DubboReference
-    private ShopUserService shopUserService;
     @Resource
     private MkDistributionAmountFlowService distributionAmountFlowService;
-    @Resource
-    private MkDistributionUserService distributionUserService;
-
+    @DubboReference
+    private ShopUserService shopUserService;
     @DubboReference
     private OrderPaymentService orderPaymentService;
     @DubboReference
@@ -177,7 +174,7 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
                 .setType(TableValueConstant.DistributionAmountFlow.Type.OPEN.getCode())
                 .setMainShopId(mainShopId).setShopId(shopId).setAmount(finalAmount).setChangeAmount(amount).setSourceId(sourceId)
                 .setRemark("分销员购买").setOpAccount(StpKit.USER.getAccount()));
-        distributionUserService.addDistributionUser(new MkDistributionUser().setParentId(null).setShopId(shopId)
+        addDistributionUser(new MkDistributionUser().setParentId(null).setShopId(shopId)
                 .setShopUserId(shopUserInfo.getId()).setOpeningMethod("付费开通"));
     }
 }