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);