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 dbb0545a..b7b08bf1 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
@@ -634,6 +634,11 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void refund(String orderNo) {
+        long count = distributionFlowService.count(new QueryWrapper().eq(MkDistributionFlow::getOrderNo, orderNo).eq(MkDistributionFlow::getStatus, TableValueConstant.DistributionFlow.Status.PENDING.getCode()));
+        if (count >= 1) {
+            log.warn("此分销已经退款");
+            return;
+        }
         distributionFlowService.list(new QueryWrapper().eq(MkDistributionFlow::getOrderNo, orderNo).ne(MkDistributionFlow::getStatus, TableValueConstant.DistributionFlow.Status.REFUND.getCode())).forEach(item -> {
             MkDistributionFlow refundFlow = BeanUtil.copyProperties(item, MkDistributionFlow.class);
             refundFlow.setStatus(TableValueConstant.DistributionFlow.Status.REFUND.getCode());