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 d8c9ad75..fad56cc3 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
@@ -176,6 +176,7 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
             Map<String, Object> distributionUser = new HashMap<>();
             distributionUser.put("distributionId", mkDistributionUser.getId());
             distributionUser.put("inviteCode", mkDistributionUser.getInviteCode());
+            distributionUser.put("consumeAmount", mkDistributionUser.getConsumeAmount());
             distributionUser.put("status", mkDistributionUser.getStatus() == 9);
             distributionUser.put("totalIncome", mkDistributionUser.getTotalIncome());
             distributionUser.put("pendingIncome", mkDistributionUser.getPendingIncome());
@@ -290,6 +291,8 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
                     newDistributionUser.setDistributionLevelId(levelConfig.getId());
                     newDistributionUser.setDistributionLevelName(levelConfig.getName());
                 }
+            } else if ("cost".equals(mkDistributionConfig.getUpgradeType())) {
+                costUpgradeLevel(parent.getId(), parent.getShopId());
             }
         }
         this.updateById(newDistributionUser);
@@ -415,6 +418,12 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
         param.setId(param.getId());
         param.setUserId(shopUser.getUserId());
         param.setInviteCode(CzgRandomUtils.randomString(10));
+        BigDecimal totalAmount = orderInfoService.getOneAs(QueryWrapper.create()
+                .select("sum(pay_amount)")
+                .eq(OrderInfo::getShopId, param.getShopId())
+                .eq(OrderInfo::getStatus, OrderStatusEnums.DONE.getCode())
+                .eq(OrderInfo::getUserId, param.getUserId()), BigDecimal.class);
+        param.setConsumeAmount(totalAmount);
         save(param);
         ShopUser shopUser2 = new ShopUser();
         shopUser2.setId(shopUser.getId());