From 93dfe76b5323418f6e05a91a34bd7205f0308011 Mon Sep 17 00:00:00 2001 From: sjh Date: Tue, 17 Dec 2024 09:59:45 +0800 Subject: [PATCH 1/4] =?UTF-8?q?=E4=BF=AE=E5=A4=8D118=E6=A8=A1=E5=9E=8B2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mapper/dwd/GBaseCSCZRKMapper.java | 16 ++++---- .../service/impl/PointServiceImpl.java | 39 +++++++++++++++++-- 2 files changed, 43 insertions(+), 12 deletions(-) diff --git a/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java b/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java index 77eccd1..34ae364 100644 --- a/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java +++ b/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java @@ -62,29 +62,29 @@ public interface GBaseCSCZRKMapper extends BaseMapper { + "inner join dwd_ry_kxgxzyk_csczrk c ON a.hh = c.hh " + "where a.gmsfhm != c.gmsfhm and (" + "( a.mqgmsfzhm IS NULL AND a.fqgmsfzhm IS NULL ) " - + ")") - List selectFamilyPeople1(); + + "LIMIT #{limit} OFFSET #{offset}") + List selectFamilyPeople1(int offset, int limit); @Select("select distinct a.gmsfhm, c.gmsfhm family_id from dwd_ry_kxgxzyk_csczrk a inner join csga_wdpcdb.wdpc_person b on a.gmsfhm = b.id_code " + "inner join dwd_ry_kxgxzyk_csczrk c ON a.hh = c.hh " + "where a.gmsfhm != c.gmsfhm and (" + "( a.mqgmsfzhm IS NULL AND a.fqgmsfzhm != c.gmsfhm ) " - + ")") - List selectFamilyPeople2(); + + "LIMIT #{limit} OFFSET #{offset}") + List selectFamilyPeople2(int offset, int limit); @Select("select distinct a.gmsfhm, c.gmsfhm family_id from dwd_ry_kxgxzyk_csczrk a inner join csga_wdpcdb.wdpc_person b on a.gmsfhm = b.id_code " + "inner join dwd_ry_kxgxzyk_csczrk c ON a.hh = c.hh " + "where a.gmsfhm != c.gmsfhm and (" + "( a.fqgmsfzhm IS NULL AND a.mqgmsfzhm != c.gmsfhm ) " - + ")") - List selectFamilyPeople3(); + + "LIMIT #{limit} OFFSET #{offset}") + List selectFamilyPeople3(int offset, int limit); @Select("select distinct a.gmsfhm, c.gmsfhm family_id from dwd_ry_kxgxzyk_csczrk a inner join csga_wdpcdb.wdpc_person b on a.gmsfhm = b.id_code " + "inner join dwd_ry_kxgxzyk_csczrk c ON a.hh = c.hh " + "where a.gmsfhm != c.gmsfhm and (" + "(a.fqgmsfzhm IS NOT NULL AND a.mqgmsfzhm IS NOT NULL AND a.fqgmsfzhm != c.gmsfhm AND a.mqgmsfzhm != c.gmsfhm) " - + ")") - List selectFamilyPeople4(); + + "LIMIT #{limit} OFFSET #{offset}") + List selectFamilyPeople4(int offset, int limit); @Select("select distinct a.gmsfhm, a.fqgmsfzhm father_id from dwd_ry_kxgxzyk_csczrk a INNER JOIN csga_wdpcdb.wdpc_person b ON a.gmsfhm = b.id_code where a.fqgmsfzhm is not null;") List selectFather(); 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 890dd60..b430e2c 100644 --- a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java +++ b/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java @@ -1455,14 +1455,45 @@ public class PointServiceImpl implements PointService { Map oldMap = domain.getOldMap(task.getModelId(), true); Map idCode = new HashMap<>(); List list = new ArrayList<>(); + List familyPeople = new ArrayList<>(); log.info("模型118开始查询"); - List familyPeople = new ArrayList<>(cSCZRKRepository.getBaseMapper().selectFamilyPeople1()); + int pageSize = 100000; + int pageNumber1 = 1; + List currentPageResults1; + do { + int offset = (pageNumber1 - 1) * pageSize; + currentPageResults1 = cSCZRKRepository.getBaseMapper().selectFamilyPeople1(offset, pageSize); + log.info("模型118第一部分查询完毕"); + familyPeople.addAll(currentPageResults1); + pageNumber1++; + } while (!currentPageResults1.isEmpty()); log.info("模型118查询familyPeople1结果数：{}", familyPeople.size()); - familyPeople.addAll(cSCZRKRepository.getBaseMapper().selectFamilyPeople2()); + int pageNumber2 = 1; + List currentPageResults2; + do { + int offset = (pageNumber2 - 1) * pageSize; + currentPageResults2 = cSCZRKRepository.getBaseMapper().selectFamilyPeople2(offset, pageSize); + familyPeople.addAll(currentPageResults2); + pageNumber2++; + } while (!currentPageResults2.isEmpty()); log.info("模型118查询familyPeople2结果数：{}", familyPeople.size()); - familyPeople.addAll(cSCZRKRepository.getBaseMapper().selectFamilyPeople3()); + int pageNumber3 = 1; + List currentPageResults3; + do { + int offset = (pageNumber3 - 1) * pageSize; + currentPageResults3 = cSCZRKRepository.getBaseMapper().selectFamilyPeople3(offset, pageSize); + familyPeople.addAll(currentPageResults3); + pageNumber3++; + } while (!currentPageResults3.isEmpty()); log.info("模型118查询familyPeople3结果数：{}", familyPeople.size()); - familyPeople.addAll(cSCZRKRepository.getBaseMapper().selectFamilyPeople4()); + int pageNumber4 = 1; + List currentPageResults4; + do { + int offset = (pageNumber4 - 1) * pageSize; + currentPageResults4 = cSCZRKRepository.getBaseMapper().selectFamilyPeople4(offset, pageSize); + familyPeople.addAll(currentPageResults4); + pageNumber4++; + } while (!currentPageResults4.isEmpty()); log.info("模型118查询familyPeople结果数：{}", familyPeople.size()); Map> familyMap = familyPeople.stream().collect(Collectors.groupingBy(GBaseCSCZRK::getGmsfhm, Collectors.mapping(GBaseCSCZRK::getFamilyId, Collectors.toList()))); From 65f0602b08e037c91c22dc5f7d73db1943a60398 Mon Sep 17 00:00:00 2001 From: sjh Date: Tue, 17 Dec 2024 10:19:26 +0800 Subject: [PATCH 2/4] =?UTF-8?q?=E4=BF=AE=E5=A4=8D118=E6=A8=A1=E5=9E=8B3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java b/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java index 34ae364..14b912f 100644 --- a/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java +++ b/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java @@ -60,28 +60,28 @@ public interface GBaseCSCZRKMapper extends BaseMapper { @Select("select distinct a.gmsfhm, c.gmsfhm family_id from dwd_ry_kxgxzyk_csczrk a inner join csga_wdpcdb.wdpc_person b on a.gmsfhm = b.id_code " + "inner join dwd_ry_kxgxzyk_csczrk c ON a.hh = c.hh " - + "where a.gmsfhm != c.gmsfhm and (" + + "where a.gmsfhm != c.gmsfhm and " + "( a.mqgmsfzhm IS NULL AND a.fqgmsfzhm IS NULL ) " + "LIMIT #{limit} OFFSET #{offset}") List selectFamilyPeople1(int offset, int limit); @Select("select distinct a.gmsfhm, c.gmsfhm family_id from dwd_ry_kxgxzyk_csczrk a inner join csga_wdpcdb.wdpc_person b on a.gmsfhm = b.id_code " + "inner join dwd_ry_kxgxzyk_csczrk c ON a.hh = c.hh " - + "where a.gmsfhm != c.gmsfhm and (" + + "where a.gmsfhm != c.gmsfhm and " + "( a.mqgmsfzhm IS NULL AND a.fqgmsfzhm != c.gmsfhm ) " + "LIMIT #{limit} OFFSET #{offset}") List selectFamilyPeople2(int offset, int limit); @Select("select distinct a.gmsfhm, c.gmsfhm family_id from dwd_ry_kxgxzyk_csczrk a inner join csga_wdpcdb.wdpc_person b on a.gmsfhm = b.id_code " + "inner join dwd_ry_kxgxzyk_csczrk c ON a.hh = c.hh " - + "where a.gmsfhm != c.gmsfhm and (" + + "where a.gmsfhm != c.gmsfhm and " + "( a.fqgmsfzhm IS NULL AND a.mqgmsfzhm != c.gmsfhm ) " + "LIMIT #{limit} OFFSET #{offset}") List selectFamilyPeople3(int offset, int limit); @Select("select distinct a.gmsfhm, c.gmsfhm family_id from dwd_ry_kxgxzyk_csczrk a inner join csga_wdpcdb.wdpc_person b on a.gmsfhm = b.id_code " + "inner join dwd_ry_kxgxzyk_csczrk c ON a.hh = c.hh " - + "where a.gmsfhm != c.gmsfhm and (" + + "where a.gmsfhm != c.gmsfhm and " + "(a.fqgmsfzhm IS NOT NULL AND a.mqgmsfzhm IS NOT NULL AND a.fqgmsfzhm != c.gmsfhm AND a.mqgmsfzhm != c.gmsfhm) " + "LIMIT #{limit} OFFSET #{offset}") List selectFamilyPeople4(int offset, int limit); From 21cd20aca49168c2cc4d4a0b05ff5503a9edbd04 Mon Sep 17 00:00:00 2001 From: sjh Date: Tue, 17 Dec 2024 10:53:26 +0800 Subject: [PATCH 3/4] =?UTF-8?q?=E7=89=B9=E6=AE=8A=E4=BA=BA=E7=BE=A4?= =?UTF-8?q?=E7=B1=BB=E5=9E=8B=E6=A8=A1=E5=9E=8B=E5=8E=BB=E6=8E=89=E7=B2=BE?= =?UTF-8?q?=E7=A5=9E=E7=96=BE=E7=97=85=E3=80=81=E7=8A=AF=E7=BD=AA=E5=89=8D?= =?UTF-8?q?=E7=A7=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/PointServiceImpl.java | 63 +------------------ 1 file changed, 3 insertions(+), 60 deletions(-) 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 b430e2c..c243428 100644 --- a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java +++ b/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java @@ -832,36 +832,15 @@ public class PointServiceImpl implements PointService { Map oldMap = domain.getOldMap(task.getModelId(), true); Map idCode = new HashMap<>(); log.info("模型130开始查询"); - List list1 = jsbryRepository.getBaseMapper().selectByIdNos(); +// List list1 = jsbryRepository.getBaseMapper().selectByIdNos(); List list2 = jZJLBRepository.getBaseMapper().selectForModel129(); ; List list3 = xdryRepository.getBaseMapper().selectXIDU(); List list4 = sqjzryRepository.getBaseMapper().selectByIdNos(); - List list5 = xmsfryRepository.getBaseMapper().selectByIdNos(); - log.info("模型130查询结果数：{},{},{},{},{}", list1.size(), list2.size(), list3.size(), list4.size(), list5.size()); +// List list5 = xmsfryRepository.getBaseMapper().selectByIdNos(); + log.info("模型130查询结果数：{},{},{}", list2.size(), list3.size(), list4.size()); Map personalMap = domain.getPersons().stream().collect(Collectors.toMap(RiskPersonal::getIdCode, Function.identity(), (old, newVal) -> newVal)); List toInsert = new ArrayList<>(); - for (WdpcGrjdJsbry domicileType : list1) { - RiskPersonal personal = personalMap.get(domicileType.getIdCode()); - if (personal == null) continue; - if (idCode.get(domicileType.getIdCode()) != null) continue; - if (oldMap.get(domicileType.getIdCode()) != null) continue; - - idCode.put(domicileType.getIdCode(), 1); - - ClueData data = ClueData.builder() - .name(personal.getName()) - .id(personal.getId().toString()) - .idCode(personal.getIdCode()) - .tags(List.of("精神障碍患者")) - .score(1) - .eventTime(LocalDateTime.now()) - .personId(personal.getId()) - .sourceData("发现该人员于" + getDateString(domicileType.getActualTime()) - + "确诊为为“" + domicileType.getActualId() + "”精神障碍患者") - .build(); - toInsert.add(DataUtil.createClueData(task, data)); - } for (WdpcJZJLB domicileType : list2) { RiskPersonal personal = personalMap.get(domicileType.getIdCode()); if (personal == null) continue; @@ -938,42 +917,6 @@ public class PointServiceImpl implements PointService { .build(); toInsert.add(DataUtil.createClueData(task, data)); } - for (WdpcXmsfry domicileType : list5) { - RiskPersonal personal = personalMap.get(domicileType.getIdCode()); - if (personal == null) continue; - if (idCode.get(domicileType.getIdCode()) != null) continue; - if (oldMap.get(domicileType.getIdCode()) != null) continue; - - idCode.put(domicileType.getIdCode(), 1); - - String context = ""; - if (domicileType.getCrimeName() != null) { - context = context + "，罪名为" + domicileType.getCrimeName(); - } - if (domicileType.getSentenceTime() != null) { - context = context + "，判决日期为" + getDateString(domicileType.getSentenceTime()); - } - if (domicileType.getPrisonBegin() != null) { - context = context + "，服刑开始日期为" + getDateString(domicileType.getPrisonBegin()); - } - if (domicileType.getPrisonEnd() != null) { - context = context + "，服刑结束日期为" + getDateString(domicileType.getPrisonEnd()); - } - if (domicileType.getPrisonOrganization() != null) { - context = context + "，服刑单位为" + domicileType.getPrisonOrganization(); - } - ClueData data = ClueData.builder() - .name(personal.getName()) - .id(personal.getId().toString()) - .idCode(personal.getIdCode()) - .tags(List.of("刑释解教人员")) - .score(5) - .eventTime(LocalDateTime.now()) - .personId(personal.getId()) - .sourceData("发现该人员为刑释解教人员" + context) - .build(); - toInsert.add(DataUtil.createClueData(task, data)); - } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.SPECIALPEOPLETYPE); } From 2d82a86287c0b334f70199dd7f7c67d09db56172 Mon Sep 17 00:00:00 2001 From: sjh Date: Tue, 17 Dec 2024 11:19:07 +0800 Subject: [PATCH 4/4] =?UTF-8?q?=E4=BF=AE=E5=A4=8D118=E6=A8=A1=E5=9E=8B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../event/ApplicationEvent.java | 2 +- .../service/impl/PointServiceImpl.java | 104 +++++++++++++----- 2 files changed, 75 insertions(+), 31 deletions(-) diff --git a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java index 620dadd..ef895cb 100644 --- a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java +++ b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java @@ -159,7 +159,7 @@ public class ApplicationEvent { // pointService.syncFamilySeriousIllness(initDomain(List.of(127))); // pointService.syncPetitionDissatisfied(initDomain(List.of(128))); // pointService.syncIsSpecialPeople(initDomain(List.of(129))); -// pointService.syncSpecialPeopleType(initDomain(List.of(130))); + pointService.syncSpecialPeopleType(initDomain(List.of(130))); // pointService.syncParentsRelationship(initDomain(List.of(131))); // pointService.syncMentalDiseaseDriver(initDomain(List.of(132))); // pointService.syncXIDUDriver(initDomain(List.of(133))); 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 c243428..cf92db1 100644 --- a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java +++ b/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java @@ -27,6 +27,7 @@ import com.biutag.supervisiondata.util.IdCodeUtil; import com.biutag.supervisiondata.util.PatternUtil; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; +import org.jetbrains.annotations.NotNull; import org.springframework.stereotype.Service; import java.text.SimpleDateFormat; @@ -1397,8 +1398,6 @@ public class PointServiceImpl implements PointService { Map oldMap = domain.getOldMap(task.getModelId(), true); Map idCode = new HashMap<>(); - List list = new ArrayList<>(); - List familyPeople = new ArrayList<>(); log.info("模型118开始查询"); int pageSize = 100000; int pageNumber1 = 1; @@ -1406,49 +1405,100 @@ public class PointServiceImpl implements PointService { do { int offset = (pageNumber1 - 1) * pageSize; currentPageResults1 = cSCZRKRepository.getBaseMapper().selectFamilyPeople1(offset, pageSize); - log.info("模型118第一部分查询完毕"); - familyPeople.addAll(currentPageResults1); + log.info("模型118第一部分查询size:{}", currentPageResults1.size()); + if (currentPageResults1.isEmpty()) break; + List familyPeople = new ArrayList<>(currentPageResults1); + Map> familyMap = familyPeople.stream().collect(Collectors.groupingBy(GBaseCSCZRK::getGmsfhm, + Collectors.mapping(GBaseCSCZRK::getFamilyId, Collectors.toList()))); + List familyList = familyPeople.stream().map(GBaseCSCZRK::getFamilyId).toList(); + List list = new ArrayList<>(hZCRYXXRepository.getBaseMapper().selectHZCPeople(familyList)); + log.info("模型118第一部分查询list:{}", list.size()); + List toInsert = getRiskModelTaskClues(domain, familyMap, list, idCode, oldMap, task); + RiskTask updateTask = new RiskTask(); + updateTask.setId(task.getId()); + updateTask.setInsertSize(toInsert.size()); + updateTask.setUpdateSize(0); + updateTask.setState(1); + updateTask.setEndTime(LocalDateTime.now()); + taskRepository.updateById(updateTask); pageNumber1++; } while (!currentPageResults1.isEmpty()); - log.info("模型118查询familyPeople1结果数：{}", familyPeople.size()); + log.info("模型118查询familyPeople1完成"); int pageNumber2 = 1; List currentPageResults2; do { int offset = (pageNumber2 - 1) * pageSize; currentPageResults2 = cSCZRKRepository.getBaseMapper().selectFamilyPeople2(offset, pageSize); - familyPeople.addAll(currentPageResults2); + log.info("模型118第二部分查询size:{}", currentPageResults2.size()); + if (currentPageResults2.isEmpty()) break; + List familyPeople = new ArrayList<>(currentPageResults2); + Map> familyMap = familyPeople.stream().collect(Collectors.groupingBy(GBaseCSCZRK::getGmsfhm, + Collectors.mapping(GBaseCSCZRK::getFamilyId, Collectors.toList()))); + List familyList = familyPeople.stream().map(GBaseCSCZRK::getFamilyId).toList(); + List list = new ArrayList<>(hZCRYXXRepository.getBaseMapper().selectHZCPeople(familyList)); + log.info("模型118第二部分查询list:{}", list.size()); + List toInsert = getRiskModelTaskClues(domain, familyMap, list, idCode, oldMap, task); + RiskTask updateTask = new RiskTask(); + updateTask.setId(task.getId()); + updateTask.setInsertSize(toInsert.size()); + updateTask.setUpdateSize(0); + updateTask.setState(1); + updateTask.setEndTime(LocalDateTime.now()); + taskRepository.updateById(updateTask); pageNumber2++; } while (!currentPageResults2.isEmpty()); - log.info("模型118查询familyPeople2结果数：{}", familyPeople.size()); + log.info("模型118查询familyPeople2完成"); int pageNumber3 = 1; List currentPageResults3; do { int offset = (pageNumber3 - 1) * pageSize; currentPageResults3 = cSCZRKRepository.getBaseMapper().selectFamilyPeople3(offset, pageSize); - familyPeople.addAll(currentPageResults3); + log.info("模型118第三部分查询size:{}", currentPageResults3.size()); + if (currentPageResults3.isEmpty()) break; + List familyPeople = new ArrayList<>(currentPageResults3); + Map> familyMap = familyPeople.stream().collect(Collectors.groupingBy(GBaseCSCZRK::getGmsfhm, + Collectors.mapping(GBaseCSCZRK::getFamilyId, Collectors.toList()))); + List familyList = familyPeople.stream().map(GBaseCSCZRK::getFamilyId).toList(); + List list = new ArrayList<>(hZCRYXXRepository.getBaseMapper().selectHZCPeople(familyList)); + log.info("模型118第三部分查询list:{}", list.size()); + List toInsert = getRiskModelTaskClues(domain, familyMap, list, idCode, oldMap, task); + RiskTask updateTask = new RiskTask(); + updateTask.setId(task.getId()); + updateTask.setInsertSize(toInsert.size()); + updateTask.setUpdateSize(0); + updateTask.setState(1); + updateTask.setEndTime(LocalDateTime.now()); + taskRepository.updateById(updateTask); pageNumber3++; } while (!currentPageResults3.isEmpty()); - log.info("模型118查询familyPeople3结果数：{}", familyPeople.size()); + log.info("模型118查询familyPeople3完成"); int pageNumber4 = 1; List currentPageResults4; do { int offset = (pageNumber4 - 1) * pageSize; - currentPageResults4 = cSCZRKRepository.getBaseMapper().selectFamilyPeople4(offset, pageSize); - familyPeople.addAll(currentPageResults4); + currentPageResults4 = cSCZRKRepository.getBaseMapper().selectFamilyPeople3(offset, pageSize); + log.info("模型118第四部分查询size:{}", currentPageResults4.size()); + if (currentPageResults4.isEmpty()) break; + List familyPeople = new ArrayList<>(currentPageResults4); + Map> familyMap = familyPeople.stream().collect(Collectors.groupingBy(GBaseCSCZRK::getGmsfhm, + Collectors.mapping(GBaseCSCZRK::getFamilyId, Collectors.toList()))); + List familyList = familyPeople.stream().map(GBaseCSCZRK::getFamilyId).toList(); + List list = new ArrayList<>(hZCRYXXRepository.getBaseMapper().selectHZCPeople(familyList)); + log.info("模型118第四部分查询list:{}", list.size()); + List toInsert = getRiskModelTaskClues(domain, familyMap, list, idCode, oldMap, task); + RiskTask updateTask = new RiskTask(); + updateTask.setId(task.getId()); + updateTask.setInsertSize(toInsert.size()); + updateTask.setUpdateSize(0); + updateTask.setState(1); + updateTask.setEndTime(LocalDateTime.now()); + taskRepository.updateById(updateTask); pageNumber4++; } while (!currentPageResults4.isEmpty()); - log.info("模型118查询familyPeople结果数：{}", familyPeople.size()); - Map> familyMap = familyPeople.stream().collect(Collectors.groupingBy(GBaseCSCZRK::getGmsfhm, - Collectors.mapping(GBaseCSCZRK::getFamilyId, Collectors.toList()))); - List familyList = familyPeople.stream().map(GBaseCSCZRK::getFamilyId).toList(); - // 切割 每次查10000条 - List> familyListParts = IntStream.range(0, (familyList.size() + 9999) / 10000) - .mapToObj(i -> familyList.subList(i * 10000, Math.min((i + 1) * 10000, familyList.size()))) - .toList(); - for (List familyListPart : familyListParts) { - list.addAll(hZCRYXXRepository.getBaseMapper().selectHZCPeople(familyListPart)); - } - log.info("模型118查询结果数：{}", list.size()); + log.info("模型118查询familyPeople4完成"); + } + + private @NotNull List getRiskModelTaskClues(TaskParamDomain domain, Map> familyMap, List list, Map idCode, Map oldMap, RiskTask task) { Map personalMap = domain.getPersons().stream().collect(Collectors.toMap(RiskPersonal::getIdCode, Function.identity(), (old, newVal) -> newVal)); List toInsert = new ArrayList<>(); for (Map.Entry> entry : familyMap.entrySet()) { @@ -1481,13 +1531,7 @@ public class PointServiceImpl implements PointService { if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.FAMILYDIE); } - RiskTask updateTask = new RiskTask(); - updateTask.setId(task.getId()); - updateTask.setInsertSize(toInsert.size()); - updateTask.setUpdateSize(0); - updateTask.setState(1); - updateTask.setEndTime(LocalDateTime.now()); - taskRepository.updateById(updateTask); + return toInsert; } @Override