|
|
|
@ -233,6 +233,11 @@ public class FactoryNodePushServiceImpl extends BaseServiceImpl<FactoryNodePushM
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
if (CollUtil.isNotEmpty(updateList)) { |
|
|
|
|
// id相同时,更新 workedNodeCode 最大的那一条数据
|
|
|
|
|
updateList = updateList.stream().collect(Collectors.groupingBy(PackageInfoEntity::getId)).values().stream() |
|
|
|
|
.map(data -> data.get(data.size() - 1)).collect(Collectors.toList()); |
|
|
|
|
// 按 workedNodeCode 正序
|
|
|
|
|
// updateList.sort(Comparator.comparingInt(PackageInfoEntity::getWorkedNodeCode));
|
|
|
|
|
packageInfoService.updateBatchById(updateList); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|