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 32db55c17..ac737a11a 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
@@ -546,10 +546,10 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
         ShopUser shopUserInfo = shopUserService.getById(shopUserId);
         Long mainShopId = shopInfoService.getMainIdByShopId(shopId);
 //        BigDecimal finalAmount = shopInfoService.updateAmount(shopId, amount);
-//        distributionAmountFlowService.save(new MkDistributionAmountFlow()
-//                .setType(TableValueConstant.DistributionAmountFlow.Type.OPEN.getCode())
-//                .setMainShopId(mainShopId).setShopId(shopId).setAmount(finalAmount).setChangeAmount(amount).setSourceId(sourceId)
-//                .setRemark("分销员购买"));
+        distributionAmountFlowService.save(new MkDistributionAmountFlow()
+                .setType(TableValueConstant.DistributionAmountFlow.Type.OPEN.getCode())
+                .setMainShopId(mainShopId).setShopId(shopId).setAmount(amount).setChangeAmount(amount).setSourceId(sourceId)
+                .setRemark("分销员购买"));
         try {
             addDistributionUser(new MkDistributionUser().setShopId(shopId)
                     .setUserId(shopUserInfo.getUserId())