From e788503426f32c1e79a56b000640021a4482e9ce Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?=
 <8605635+zhang3064194730@user.noreply.gitee.com>
Date: Wed, 29 Oct 2025 15:41:24 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=86=E9=94=80=E8=AE=B0=E5=BD=95=E5=AD=97?=
 =?UTF-8?q?=E6=AE=B5=E8=A1=A5=E9=BD=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../market/service/impl/MkDistributionAmountFlowServiceImpl.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionAmountFlowServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionAmountFlowServiceImpl.java
index d29ee59c..1928145e 100644
--- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionAmountFlowServiceImpl.java
+++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionAmountFlowServiceImpl.java
@@ -75,6 +75,7 @@ public class MkDistributionAmountFlowServiceImpl extends ServiceImpl<MkDistribut
                 .leftJoin(ShopUser.class).on(ShopUser::getId, OrderInfo::getUserId)
                 .eq(MkDistributionAmountFlow::getShopId, shopId)
                 .select(OrderInfo::getOrderNo)
+                .eq(MkDistributionAmountFlow::getType, TableValueConstant.DistributionAmountFlow.Type.OPEN.getCode())
                 .select(ShopUser::getPhone, ShopUser::getNickName);
         if (startTime != null) {
             queryWrapper.ge(MkDistributionAmountFlow::getCreateTime, startTime);