|
|
@ -128,6 +128,8 @@ public class FactoryXxlJob { |
|
|
|
List<StaorderPackagesEntity> staorderPackagesEntityList = map.get(StaorderPackagesEntity.class.getName()); |
|
|
|
List<StaorderPackagesEntity> staorderPackagesEntityList = map.get(StaorderPackagesEntity.class.getName()); |
|
|
|
List<StaorderPackagesEntity> allDataStaorderPackagesEntity = staorderPackagesService.lambdaQuery().select(StaorderPackagesEntity::getTcPoa014).list(); |
|
|
|
List<StaorderPackagesEntity> allDataStaorderPackagesEntity = staorderPackagesService.lambdaQuery().select(StaorderPackagesEntity::getTcPoa014).list(); |
|
|
|
List<String> allStaorderPackagesEntityUnionId = allDataStaorderPackagesEntity.stream().map(StaorderPackagesEntity::getTcPoa014).collect(Collectors.toList()); |
|
|
|
List<String> allStaorderPackagesEntityUnionId = allDataStaorderPackagesEntity.stream().map(StaorderPackagesEntity::getTcPoa014).collect(Collectors.toList()); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
for (int i = 0; i < staorderPackagesEntityList.size(); i++) { |
|
|
|
for (int i = 0; i < staorderPackagesEntityList.size(); i++) { |
|
|
|
// 找到相同的ID 跳过
|
|
|
|
// 找到相同的ID 跳过
|
|
|
|
if (allStaorderPackagesEntityUnionId.contains(staorderPackagesEntityList.get(i).getTcPoa014())) { |
|
|
|
if (allStaorderPackagesEntityUnionId.contains(staorderPackagesEntityList.get(i).getTcPoa014())) { |
|
|
@ -360,9 +362,12 @@ public class FactoryXxlJob { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private List<StationOrderEntity> checkDataExit(List<StationOrderEntity> dataList, List<String> allDataList) { |
|
|
|
private List<StationOrderEntity> checkDataExit(List<StationOrderEntity> dataList, List<String> allDataList) { |
|
|
|
|
|
|
|
XxlJobLogger.log("allDataList {}", allDataList.toArray()); |
|
|
|
for (int i = 0; i < dataList.size(); i++) { |
|
|
|
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())) { |
|
|
|
if (allDataList.contains(dataList.get(i).getTcWlb008())) { |
|
|
|
// 如果存在 需要移除
|
|
|
|
// 如果存在 需要移除
|
|
|
|
|
|
|
|
XxlJobLogger.log("移除对象 {}", dataList.get(i).getTcWlb008()); |
|
|
|
dataList.remove(i); |
|
|
|
dataList.remove(i); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|