From ea69c2714d8ab4394d4e29b9ceccb7411954f03a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?=
 <8605635+zhang3064194730@user.noreply.gitee.com>
Date: Thu, 30 Oct 2025 14:53:05 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=86=E9=94=80=E8=AE=B0=E5=BD=95=E5=A1=AB?=
 =?UTF-8?q?=E5=85=85userId?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/czg/market/entity/MkDistributionFlow.java  | 1 +
 .../market/service/impl/MkDistributionUserServiceImpl.java       | 1 +
 2 files changed, 2 insertions(+)

diff --git a/cash-common/cash-common-service/src/main/java/com/czg/market/entity/MkDistributionFlow.java b/cash-common/cash-common-service/src/main/java/com/czg/market/entity/MkDistributionFlow.java
index 35b4fcfa..9f526299 100644
--- a/cash-common/cash-common-service/src/main/java/com/czg/market/entity/MkDistributionFlow.java
+++ b/cash-common/cash-common-service/src/main/java/com/czg/market/entity/MkDistributionFlow.java
@@ -113,4 +113,5 @@ public class MkDistributionFlow implements Serializable {
     private BigDecimal commission;
     private BigDecimal parentCommission;
     private LocalDateTime deliverTime;
+    private Long userId;
 }
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 22daf004..d3f25f05 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
@@ -594,6 +594,7 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
         ShopUser shopUser = shopUserService.getById(currentDistributionUser.getId());
         MkDistributionFlow mkDistributionFlow = new MkDistributionFlow().setShopUserId(currentDistributionUser.getId())
                 .setShopId(currentDistributionUser.getShopId()).setDistributionUserId(currentDistributionUser.getId())
+                .setUserId(shopUser.getUserId())
                 .setNickName(shopUser.getNickName()).setSourceShopUserId(orderSourceShopUser.getId()).setSourceNickName(orderSourceShopUser.getNickName())
                 .setCommission(finalCommission).setParentCommission(parentLevel != null ? parentLevel.getLevelOneCommission() : null)
                 .setLevelId(currentDistributionUser.getDistributionLevelId()).setLevel(currentLevel == 1 ? 1 : 2).setOrderNo(orderNo)