修复118模型2

src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java

@@ -62,29 +62,29 @@ public interface GBaseCSCZRKMapper extends BaseMapper<GBaseCSCZRK> {
             + "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<GBaseCSCZRK> selectFamilyPeople1();
+            + "LIMIT #{limit} OFFSET #{offset}")
+    List<GBaseCSCZRK> 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<GBaseCSCZRK> selectFamilyPeople2();
+            + "LIMIT #{limit} OFFSET #{offset}")
+    List<GBaseCSCZRK> 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<GBaseCSCZRK> selectFamilyPeople3();
+            + "LIMIT #{limit} OFFSET #{offset}")
+    List<GBaseCSCZRK> 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<GBaseCSCZRK> selectFamilyPeople4();
+            + "LIMIT #{limit} OFFSET #{offset}")
+    List<GBaseCSCZRK> 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<GBaseCSCZRK> selectFather();

src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java

@@ -1455,14 +1455,45 @@ public class PointServiceImpl implements PointService {
         Map<String, RiskModelTaskClue> oldMap = domain.getOldMap(task.getModelId(), true);
         Map<String, Integer> idCode = new HashMap<>();
         List<String> list = new ArrayList<>();
+        List<GBaseCSCZRK> familyPeople = new ArrayList<>();
         log.info("模型118开始查询");
-        List<GBaseCSCZRK> familyPeople = new ArrayList<>(cSCZRKRepository.getBaseMapper().selectFamilyPeople1());
+        int pageSize = 100000;
+        int pageNumber1 = 1;
+        List<GBaseCSCZRK> 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<GBaseCSCZRK> 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<GBaseCSCZRK> 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<GBaseCSCZRK> 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<String, List<String>> familyMap = familyPeople.stream().collect(Collectors.groupingBy(GBaseCSCZRK::getGmsfhm,
                 Collectors.mapping(GBaseCSCZRK::getFamilyId, Collectors.toList())));