From 4d0fa07940c93b54055c793a4811ebba3c89aeee Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" <123456> Date: Wed, 31 May 2023 21:32:32 +0800 Subject: [PATCH] =?UTF-8?q?1.fix=20=E9=87=8D=E5=A4=8D=E6=95=B0=E6=8D=AE=20?= =?UTF-8?q?1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/logpm/factory/jobhandler/FactoryXxlJob.java | 5 +++++ 1 file changed, 5 insertions(+) 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); } }