diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java index 5c6ef98e4..9fb040a7a 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java @@ -128,6 +128,8 @@ public class FactoryXxlJob { List staorderPackagesEntityList = map.get(StaorderPackagesEntity.class.getName()); List allDataStaorderPackagesEntity = staorderPackagesService.lambdaQuery().select(StaorderPackagesEntity::getTcPoa014).list(); List allStaorderPackagesEntityUnionId = allDataStaorderPackagesEntity.stream().map(StaorderPackagesEntity::getTcPoa014).collect(Collectors.toList()); + + for (int i = 0; i < staorderPackagesEntityList.size(); i++) { // 找到相同的ID 跳过 if (allStaorderPackagesEntityUnionId.contains(staorderPackagesEntityList.get(i).getTcPoa014())) { @@ -360,9 +362,12 @@ public class FactoryXxlJob { } private List checkDataExit(List dataList, List allDataList) { + XxlJobLogger.log("allDataList {}", allDataList.toArray()); for (int i = 0; i < dataList.size(); i++) { + XxlJobLogger.log("dataList.get(i).getTcWlb008() {}", dataList.get(i).getTcWlb008()); if (allDataList.contains(dataList.get(i).getTcWlb008())) { // 如果存在 需要移除 + XxlJobLogger.log("移除对象 {}", dataList.get(i).getTcWlb008()); dataList.remove(i); } }