diff --git a/nladmin-system/wms-server/src/main/java/org/nl/wms/pm_manage/demand/service/impl/PmDemandServiceImpl.java b/nladmin-system/wms-server/src/main/java/org/nl/wms/pm_manage/demand/service/impl/PmDemandServiceImpl.java
index 5aa4872..2522f9a 100644
--- a/nladmin-system/wms-server/src/main/java/org/nl/wms/pm_manage/demand/service/impl/PmDemandServiceImpl.java
+++ b/nladmin-system/wms-server/src/main/java/org/nl/wms/pm_manage/demand/service/impl/PmDemandServiceImpl.java
@@ -239,7 +239,7 @@ public class PmDemandServiceImpl extends ServiceImpl<PmDemandMapper, PmDemand> i
             throw new BadRequestException("下推失败,单据状态不为已分配不能下推");
         }
         final int disCount = this.count(new LambdaQueryWrapper<PmDemand>()
-                .eq(PmDemand::getId, pmDemandDtos.stream().map(PmDemandDto::getId).collect(Collectors.toList()))
+                .in(PmDemand::getId, pmDemandDtos.stream().map(PmDemandDto::getId).collect(Collectors.toList()))
                 .eq(PmDemand::getStatus,DemandStatus.DIS.getValue()));
         if (disCount<pmDemandDtos.size()){
             throw new BadRequestException("下推失败,单据状态不为已分配不能下推");