diff --git a/src/main/java/com/biutag/supervisiondata/service/impl/GBaseJJDServiceImpl.java b/src/main/java/com/biutag/supervisiondata/service/impl/GBaseJJDServiceImpl.java index e946285..2236d95 100644 --- a/src/main/java/com/biutag/supervisiondata/service/impl/GBaseJJDServiceImpl.java +++ b/src/main/java/com/biutag/supervisiondata/service/impl/GBaseJJDServiceImpl.java @@ -76,7 +76,6 @@ public class GBaseJJDServiceImpl implements GBaseJJDService { List personals = new ArrayList<>(); // 过滤数据 List idCodes1 = new ArrayList<>(); - List mobiles1 = new ArrayList<>(); Map> jjdMap = new HashMap<>(); diff --git a/src/main/java/com/biutag/supervisiondata/service/impl/GBaseSHRWFRServiceImpl.java b/src/main/java/com/biutag/supervisiondata/service/impl/GBaseSHRWFRServiceImpl.java index 13bef97..5b6805e 100644 --- a/src/main/java/com/biutag/supervisiondata/service/impl/GBaseSHRWFRServiceImpl.java +++ b/src/main/java/com/biutag/supervisiondata/service/impl/GBaseSHRWFRServiceImpl.java @@ -142,30 +142,26 @@ public class GBaseSHRWFRServiceImpl implements GBaseSHRWFRService { List> idCode = IntStream.range(0, (idCards2.size() + 9999) / 10000) .mapToObj(i -> idCards2.subList(i * 10000, Math.min((i + 1) * 10000, idCards2.size()))) .toList(); - int count = 0; - log.info("身份证开始: {}", idCode.size()); + int count = idCode.size(); for (List arr : idCode) { List list = gBaseSYRKXXRepository.list(new LambdaQueryWrapper() .select(GBaseSYRKXX::getLxdh, GBaseSYRKXX::getGmsfhm, GBaseSYRKXX::getXm, GBaseSYRKXX::getXbdm, GBaseSYRKXX::getSspcsdm) .in(GBaseSYRKXX::getGmsfhm, arr)); sFms.addAll(list); - count++; - log.info("身份证进度 | {}", count); + log.info("身份证进度 | {}", --count); } }), CompletableFutureUtil.runSyncObject(() -> { List> mobile = IntStream.range(0, (mobiles2.size() + 9999) / 10000) .mapToObj(i -> mobiles2.subList(i * 10000, Math.min((i + 1) * 10000, mobiles2.size()))) .toList(); - int count = 0; - log.info("手机号开始: {}", mobile.size()); + int count = mobile.size(); for (List arr : mobile) { List list = gBaseSYRKXXRepository.list(new LambdaQueryWrapper() .select(GBaseSYRKXX::getLxdh, GBaseSYRKXX::getGmsfhm, GBaseSYRKXX::getXm, GBaseSYRKXX::getXbdm, GBaseSYRKXX::getSspcsdm) .in(GBaseSYRKXX::getLxdh, arr)); lXfs.addAll(list); - count++; - log.info("手机号进度 | {}", count); + log.info("手机号进度 | {}", --count); } }) ).join(); @@ -180,10 +176,8 @@ public class GBaseSHRWFRServiceImpl implements GBaseSHRWFRService { if(ajjbxx == null) { continue; } - GBaseSYRKXX rkxx = null; - if(gBaseSHRXX.getGmsfhm() != null) { - rkxx = idCodeMap.get(gBaseSHRXX.getGmsfhm()); - } + GBaseSYRKXX rkxx = Optional.ofNullable(gBaseSHRXX.getGmsfhm()).map(idCodeMap::get) + .orElse(null); if(gBaseSHRXX.getLxdh() != null && rkxx == null) { List rkxxList = mobileMap.get(gBaseSHRXX.getLxdh()); if(rkxxList != null) { @@ -208,9 +202,7 @@ public class GBaseSHRWFRServiceImpl implements GBaseSHRWFRService { } if(person.getIdCode() != null) { - List tmp = Optional.ofNullable(shrMap.get(person.getIdCode())).orElse(new ArrayList<>()); - tmp.add(ajjbxx); - shrMap.put(person.getIdCode(), tmp); + shrMap.computeIfAbsent(person.getIdCode(), k -> new ArrayList<>()).add(ajjbxx); } personals.add(person); } @@ -246,10 +238,7 @@ public class GBaseSHRWFRServiceImpl implements GBaseSHRWFRService { } } } - - List tmp = Optional.ofNullable(shrMap.get(person.getIdCode())).orElse(new ArrayList<>()); - tmp.add(ajjbxx); - shrMap.put(person.getIdCode(), tmp); + shrMap.computeIfAbsent(person.getIdCode(), k -> new ArrayList<>()).add(ajjbxx); personals.add(person); } }