|
|
@ -163,12 +163,12 @@ public class FactoryXxlJob { |
|
|
|
.filter(staorderPackagesEntity -> { |
|
|
|
.filter(staorderPackagesEntity -> { |
|
|
|
|
|
|
|
|
|
|
|
List<StaorderPackagesEntity> list = staorderPackagesService.lambdaQuery() |
|
|
|
List<StaorderPackagesEntity> list = staorderPackagesService.lambdaQuery() |
|
|
|
.eq(StaorderPackagesEntity::getIsDeleted, 0) |
|
|
|
|
|
|
|
.eq(StaorderPackagesEntity::getTcPoa014, staorderPackagesEntity.getTcPoa014()).list(); |
|
|
|
.eq(StaorderPackagesEntity::getTcPoa014, staorderPackagesEntity.getTcPoa014()).list(); |
|
|
|
// 验证查询处理的包件中是否包含当前循环的包件
|
|
|
|
// 验证查询处理的包件中是否包含当前循环的包件
|
|
|
|
boolean exists = list.stream() |
|
|
|
boolean exists = list.stream() |
|
|
|
.anyMatch(t -> t.getPackagenum().equals(staorderPackagesEntity.getPackagenum())); |
|
|
|
.anyMatch(t -> t.getPackagenum().equals(staorderPackagesEntity.getPackagenum())); |
|
|
|
|
|
|
|
log.info("staorderPackagesEntity.getPackagenum() {}", staorderPackagesEntity.getPackagenum()); |
|
|
|
|
|
|
|
log.info("exists", exists); |
|
|
|
if (!exists) { |
|
|
|
if (!exists) { |
|
|
|
// 更新订单ID
|
|
|
|
// 更新订单ID
|
|
|
|
for (StationOrderEntity v : finalDataList) { |
|
|
|
for (StationOrderEntity v : finalDataList) { |
|
|
@ -177,11 +177,13 @@ public class FactoryXxlJob { |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
log.info("existingPackageNumbers {}", existingPackageNumbers); |
|
|
|
|
|
|
|
|
|
|
|
return !exists && !existingPackageNumbers.contains(staorderPackagesEntity.getPackagenum()); |
|
|
|
return !exists && !existingPackageNumbers.contains(staorderPackagesEntity.getPackagenum()); |
|
|
|
}) |
|
|
|
}) |
|
|
|
.collect(Collectors.toList()); |
|
|
|
.collect(Collectors.toList()); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
log.info("filteredStaorderPackagesEntityList {}", filteredStaorderPackagesEntityList.size()); |
|
|
|
// 插入数据库
|
|
|
|
// 插入数据库
|
|
|
|
if (!filteredStaorderPackagesEntityList.isEmpty()) { |
|
|
|
if (!filteredStaorderPackagesEntityList.isEmpty()) { |
|
|
|
staorderPackagesService.saveBatch(filteredStaorderPackagesEntityList); |
|
|
|
staorderPackagesService.saveBatch(filteredStaorderPackagesEntityList); |
|
|
|