From 1073282f9acfe4fca29840a632a412626b50a52a Mon Sep 17 00:00:00 2001 From: sjh Date: Wed, 18 Dec 2024 16:03:39 +0800 Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E6=9E=84118=E6=A8=A1=E5=9E=8B3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../biutag/supervisiondata/event/ApplicationEvent.java | 6 +++--- .../supervisiondata/service/impl/PointServiceImpl.java | 9 ++++++++- 2 files changed, 11 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java index 3c3d67f..7f53a62 100644 --- a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java +++ b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java @@ -101,7 +101,7 @@ public class ApplicationEvent { RedisDao.getInstance().init(redisTemplate); LocalDateTime end = LocalDate.now().minusDays(1).atTime(23,59,59); CompletableFutureUtil.runSync(() -> { -// personalService.init(List.of()); + personalService.init(List.of(115, 116, 118)); // personalService.pullInvestigate(); // personalService.pullPsychosis(); // gBaseSHRWFRService.pullAndSave(LocalDateTime.of(2019,12,6,0,0,0), end); @@ -141,8 +141,8 @@ public class ApplicationEvent { // pointService.syncFatherEducation(initDomain(List.of(112))); // pointService.syncMotherEducation(initDomain(List.of(113))); // pointService.syncDomicileType(initDomain(List.of(114))); - pointService.syncCriminalPunishment(initDomain(List.of(115))); - pointService.syncAdministrativePunishment(initDomain(List.of(116))); +// pointService.syncCriminalPunishment(initDomain(List.of(115))); +// pointService.syncAdministrativePunishment(initDomain(List.of(116))); // pointService.syncParentsDivorce(initDomain(List.of(117))); // gBaseJJDService.syncOtherContradict(initDomain(List.of(75))); pointService.syncFamilyDie(initDomain(List.of(118))); diff --git a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java b/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java index 5b9dd8f..eb7f0e4 100644 --- a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java +++ b/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java @@ -1416,7 +1416,14 @@ public class PointServiceImpl implements PointService { List familys = cSCZRKRepository.getBaseMapper().selectFamilyByHh(hhPart); log.info("模型118查询到{}条familys", familys.size()); List familyIds = familys.stream().map(GBaseCSCZRK::getGmsfhm).filter(v -> !idCodePart.contains(v) && !fatherCodePart.contains(v) && !motherCodePart.contains(v)).toList(); - List wdpcHZCRYXXS = hZCRYXXRepository.getBaseMapper().selectHZCPeople(familyIds); + // 切割 每次查10000条 + List> familyIdsParts = IntStream.range(0, (familyIds.size() + 9999) / 10000) + .mapToObj(i -> familyIds.subList(i * 10000, Math.min((i + 1) * 10000, familyIds.size()))) + .toList(); + List wdpcHZCRYXXS = new ArrayList<>(); + for (List familyIdsPart : familyIdsParts) { + wdpcHZCRYXXS.addAll(hZCRYXXRepository.getBaseMapper().selectHZCPeople(familyIdsPart)); + } log.info("模型118查询到{}条HZCPeople", wdpcHZCRYXXS.size()); List targetHHs = familys.stream().filter(v -> wdpcHZCRYXXS.contains(v.getGmsfhm())).map(GBaseCSCZRK::getHh).toList(); list.addAll(riskHHsPart.stream().filter(v -> targetHHs.contains(v.getHh())).map(GBaseCSCZRK::getGmsfhm).toList());