|
|
|
@ -125,7 +125,7 @@ public class NodeDataPushListener {
|
|
|
|
|
Map<String, FactoryNodePushEntity> pushEntityMap = new HashMap<>(); |
|
|
|
|
if (CollUtil.isNotEmpty(pushEntities)) { |
|
|
|
|
pushEntityMap = pushEntities.stream().filter(pushEntity -> { |
|
|
|
|
return pushEntity.getNode().equals(FactoryNodeEnums.FINAL_NET_ARRIVE_CAR.getCode()); |
|
|
|
|
return StrUtil.equals(pushEntity.getNode(),FactoryNodeEnums.END_WAREHOUSE_UNLOADING.getCode().toString()); |
|
|
|
|
}).collect(Collectors.toMap(FactoryNodePushEntity::getOrderCode, v -> v)); |
|
|
|
|
} |
|
|
|
|
JSONObject mainJson = JSONUtil.parseObj(main); |
|
|
|
@ -191,7 +191,7 @@ public class NodeDataPushListener {
|
|
|
|
|
Map<String, FactoryNodePushEntity> pushEntityMap = new HashMap<>(); |
|
|
|
|
if (CollUtil.isNotEmpty(pushEntities)) { |
|
|
|
|
pushEntityMap = pushEntities.stream().filter(pushEntity -> { |
|
|
|
|
return pushEntity.getNode().equals(FactoryNodeEnums.END_WAREHOUSE_UNLOADING.getCode()); |
|
|
|
|
return StrUtil.equals(pushEntity.getNode(),FactoryNodeEnums.END_WAREHOUSE_UNLOADING.getCode().toString()); |
|
|
|
|
}).collect(Collectors.toMap(FactoryNodePushEntity::getPackageCode, v -> v)); |
|
|
|
|
} |
|
|
|
|
for (PushData pushData : content) { |
|
|
|
|