diff --git a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java
index adadf388f..a5275a53a 100644
--- a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java
+++ b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java
@@ -158,6 +158,7 @@ public class NodeDataPushListener {
 							Function.identity(),
 							(existing, replacement) -> existing
 						));
+					// 按包件分组
 					CentralStkInConfirmVO confirmVO = CentralStkInConfirmVO.builder()
 						.senderCode(senderCode)
 						.operatingTime(operatorTime)
@@ -169,8 +170,7 @@ public class NodeDataPushListener {
 									.orderCode(mtPushDataDTO.getOrderCode())
 									.outWarehouseType(mtPushDataDTO.getOutWarehouseType())
 									.packageVOS(
-										content.stream()
-											.filter(pushData -> StrUtil.equals(pushData.getOrderCode(), mtPushDataDTO.getOrderCode()))
+										mtPushDataDTOS1.stream()
 											.map(pushData -> {
 												return CentralStkInConfirmPackageVO.builder()
 													.packageCode(pushData.getPackageCode())