From 673c0e6118b2c3dc3b6baa104694e697cfe37f29 Mon Sep 17 00:00:00 2001 From: zhaoqiaobo <583671871@qq.com> Date: Thu, 1 Aug 2024 14:05:02 +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 --- .../factorydata/mengtian/mq/NodeDataPushListener.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) 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 32ed3cf30..adadf388f 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 @@ -45,6 +45,7 @@ import org.springframework.transaction.annotation.Transactional; import java.util.List; import java.util.Map; +import java.util.function.Function; import java.util.stream.Collectors; /** @@ -151,7 +152,12 @@ public class NodeDataPushListener { for (Map.Entry> stringListEntry : collect.entrySet()) { String senderCode = stringListEntry.getKey(); List mtPushDataDTOS1 = stringListEntry.getValue(); - Map mtPushDataDTOMap = mtPushDataDTOS1.stream().collect(Collectors.toMap(MtPushDataDTO::getOrderCode, mtPushDataDTO -> mtPushDataDTO)); + Map mtPushDataDTOMap = mtPushDataDTOS1.stream() + .collect(Collectors.toMap( + MtPushDataDTO::getOrderCode, + Function.identity(), + (existing, replacement) -> existing + )); CentralStkInConfirmVO confirmVO = CentralStkInConfirmVO.builder() .senderCode(senderCode) .operatingTime(operatorTime)