From 7b5c9aa45658660621d74ec5892be1d3b3285b3e Mon Sep 17 00:00:00 2001
From: zhaoqiaobo <583671871@qq.com>
Date: Thu, 1 Aug 2024 14:28:54 +0800
Subject: [PATCH] =?UTF-8?q?feat(all):=20=E4=BF=AE=E6=94=B9=E6=A2=A6?=
 =?UTF-8?q?=E5=A4=A9=E5=9B=9E=E6=8E=A8=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../logpm/factorydata/mengtian/mq/NodeDataPushListener.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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