Browse Source

feat(all): 修改梦天回推逻辑

dist.1.3.0
zhaoqiaobo 2 months ago
parent
commit
7b5c9aa456
  1. 4
      blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java

4
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(), Function.identity(),
(existing, replacement) -> existing (existing, replacement) -> existing
)); ));
// 按包件分组
CentralStkInConfirmVO confirmVO = CentralStkInConfirmVO.builder() CentralStkInConfirmVO confirmVO = CentralStkInConfirmVO.builder()
.senderCode(senderCode) .senderCode(senderCode)
.operatingTime(operatorTime) .operatingTime(operatorTime)
@ -169,8 +170,7 @@ public class NodeDataPushListener {
.orderCode(mtPushDataDTO.getOrderCode()) .orderCode(mtPushDataDTO.getOrderCode())
.outWarehouseType(mtPushDataDTO.getOutWarehouseType()) .outWarehouseType(mtPushDataDTO.getOutWarehouseType())
.packageVOS( .packageVOS(
content.stream() mtPushDataDTOS1.stream()
.filter(pushData -> StrUtil.equals(pushData.getOrderCode(), mtPushDataDTO.getOrderCode()))
.map(pushData -> { .map(pushData -> {
return CentralStkInConfirmPackageVO.builder() return CentralStkInConfirmPackageVO.builder()
.packageCode(pushData.getPackageCode()) .packageCode(pushData.getPackageCode())

Loading…
Cancel
Save