From 92c9e5735879df539e92089d1a4f808814d74c5d Mon Sep 17 00:00:00 2001
From: sjh <shujiehao@foxmail.com>
Date: Wed, 18 Dec 2024 10:03:51 +0800
Subject: [PATCH 1/3] =?UTF-8?q?=E5=8F=97=E5=88=B0=E5=88=91=E4=BA=8B?=
 =?UTF-8?q?=E5=A4=84=E7=BD=9A=E3=80=81=E5=8F=97=E5=88=B0=E8=A1=8C=E6=94=BF?=
 =?UTF-8?q?=E5=A4=84=E7=BD=9A=20=E6=94=B9=E5=8F=98=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E6=9D=A5=E6=BA=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../event/ApplicationEvent.java               |  4 +--
 .../mapper/dwd/GBaseWFRXXMapper.java          | 15 +++++++++-
 .../service/impl/PointServiceImpl.java        | 28 ++++++++++---------
 3 files changed, 31 insertions(+), 16 deletions(-)

diff --git a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java
index dbdd793..07d5b85 100644
--- a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java
+++ b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java
@@ -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/mapper/dwd/GBaseWFRXXMapper.java b/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseWFRXXMapper.java
index f6b3f2a..3a2fcbf 100644
--- a/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseWFRXXMapper.java
+++ b/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseWFRXXMapper.java
@@ -2,7 +2,6 @@ package com.biutag.supervisiondata.mapper.dwd;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.biutag.supervisiondata.pojo.domain.WFSHPerson;
-import com.biutag.supervisiondata.pojo.entity.dwd.GBaseSHRXX;
 import com.biutag.supervisiondata.pojo.entity.dwd.GBaseWFRXX;
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Select;
@@ -57,4 +56,18 @@ public interface GBaseWFRXXMapper extends BaseMapper<GBaseWFRXX> {
     @Select(" select a.zjhm as zjhm, a.zydm as zydm from dwd_ry_zfba_wfryxx as a inner join csga_wdpcdb.wdpc_person as b " +
             " on a.zjhm = b.id_code where  a.zydm is not null ")
     List<GBaseWFRXX> selectWork();
+
+    @Select("select b.ajbh, b.zjhm " +
+            "from dwd_asj_zfba_ajjbxx a " +
+            "join dwd_ry_zfba_wfryxx b on a.ajbh = b.ajbh " +
+            "inner join csga_wdpcdb.wdpc_person c on b.zjhm = c.id_code " +
+            "where a.ajbzdm = 1;")
+    List<GBaseWFRXX> selectCriminalPunishment();
+
+    @Select("select b.ajbh, b.zjhm " +
+            "from dwd_asj_zfba_ajjbxx a " +
+            "join dwd_ry_zfba_wfryxx b on a.ajbh = b.ajbh " +
+            "inner join csga_wdpcdb.wdpc_person c on b.zjhm = c.id_code " +
+            "where a.ajbzdm = 2;")
+    List<GBaseWFRXX> selectAdministrativePunishment();
 }
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 7922399..0d37994 100644
--- a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java
+++ b/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java
@@ -94,6 +94,8 @@ public class PointServiceImpl implements PointService {
     private final GBaseJszxxbRepository jszxxbRepository;
     private final RiskModelTaskClueRepository riskModelTaskClueRepository;
 
+    private final GBaseWFRXXRepository wFRXXRepository;
+
     @Override
     public void personPullAndSave() {
         riskPersonalService.formatAndSave(getPersons(), Default.POINT_POEPLE);
@@ -341,14 +343,14 @@ public class PointServiceImpl implements PointService {
         Map<String, RiskModelTaskClue> oldMap = domain.getOldMap(task.getModelId(), true);
         Map<String, Integer> idCode = new HashMap<>();
         log.info("模型116开始查询");
-        List<GBaseGAXZCFJDS> list = gAXZCFJDSRepository.getBaseMapper().selectAdministrativePunishment();
+        List<GBaseWFRXX> list = wFRXXRepository.getBaseMapper().selectAdministrativePunishment();
         log.info("模型116查询结果数：{}", list.size());
-        Map<String, List<GBaseGAXZCFJDS>> gAXZCFJDSMap = list.stream().collect(Collectors.groupingBy(GBaseGAXZCFJDS::getZjhm));
+        Map<String, List<GBaseWFRXX>> gAXZCFJDSMap = list.stream().collect(Collectors.groupingBy(GBaseWFRXX::getZjhm));
         Map<String, RiskPersonal> personalMap = domain.getPersons().stream().collect(Collectors.toMap(RiskPersonal::getIdCode, Function.identity(), (old, newVal) -> newVal));
         List<RiskModelTaskClue> toInsert = new ArrayList<>();
-        for (Map.Entry<String, List<GBaseGAXZCFJDS>> entry : gAXZCFJDSMap.entrySet()) {
+        for (Map.Entry<String, List<GBaseWFRXX>> entry : gAXZCFJDSMap.entrySet()) {
             String zjhm = entry.getKey();
-            List<GBaseGAXZCFJDS> wfrwfxxList = entry.getValue();
+            List<GBaseWFRXX> wfrwfxxList = entry.getValue();
             RiskPersonal personal = personalMap.get(zjhm);
             if (personal == null) continue;
             if (idCode.get(zjhm) != null) continue;
@@ -356,7 +358,7 @@ public class PointServiceImpl implements PointService {
 
             idCode.put(zjhm, 1);
             int score;
-            String context = wfrwfxxList.stream().map(GBaseGAXZCFJDS::getAjbh).collect(Collectors.joining(","));
+            String context = wfrwfxxList.stream().map(GBaseWFRXX::getAjbh).collect(Collectors.joining(","));
             score = Math.min(wfrwfxxList.size(), 5);
             ClueData data = ClueData.builder()
                     .name(personal.getName())
@@ -390,14 +392,14 @@ public class PointServiceImpl implements PointService {
         Map<String, RiskModelTaskClue> oldMap = domain.getOldMap(task.getModelId(), true);
         Map<String, Integer> idCode = new HashMap<>();
         log.info("模型115开始查询");
-        List<GBaseWFRWFXX> list = wFRWFXXRepository.getBaseMapper().selectCriminalPunishment();
+        List<GBaseWFRXX> list = wFRXXRepository.getBaseMapper().selectCriminalPunishment();
         log.info("模型115查询结果数：{}", list.size());
-        Map<String, List<GBaseWFRWFXX>> wfrwfxxMap = list.stream().collect(Collectors.groupingBy(GBaseWFRWFXX::getZjhm));
+        Map<String, List<GBaseWFRXX>> wfrxxMap = list.stream().collect(Collectors.groupingBy(GBaseWFRXX::getZjhm));
         Map<String, RiskPersonal> personalMap = domain.getPersons().stream().collect(Collectors.toMap(RiskPersonal::getIdCode, Function.identity(), (old, newVal) -> newVal));
         List<RiskModelTaskClue> toInsert = new ArrayList<>();
-        for (Map.Entry<String, List<GBaseWFRWFXX>> entry : wfrwfxxMap.entrySet()) {
+        for (Map.Entry<String, List<GBaseWFRXX>> entry : wfrxxMap.entrySet()) {
             String zjhm = entry.getKey();
-            List<GBaseWFRWFXX> wfrwfxxList = entry.getValue();
+            List<GBaseWFRXX> wfrxxList = entry.getValue();
             RiskPersonal personal = personalMap.get(zjhm);
             if (personal == null) continue;
             if (idCode.get(zjhm) != null) continue;
@@ -405,17 +407,17 @@ public class PointServiceImpl implements PointService {
 
             idCode.put(zjhm, 1);
             int score;
-            String context = wfrwfxxList.stream().map(GBaseWFRWFXX::getAjbh).collect(Collectors.joining(","));
-            score = Math.min(wfrwfxxList.size(), 5);
+            String context = wfrxxList.stream().map(GBaseWFRXX::getAjbh).collect(Collectors.joining(","));
+            score = Math.min(wfrxxList.size(), 5);
             ClueData data = ClueData.builder()
                     .name(personal.getName())
                     .id(personal.getId().toString())
                     .idCode(personal.getIdCode())
-                    .tags(List.of("受到" + wfrwfxxList.size() + "个刑事处罚"))
+                    .tags(List.of("受到" + wfrxxList.size() + "个刑事处罚"))
                     .score(score)
                     .eventTime(LocalDateTime.now())
                     .personId(personal.getId())
-                    .sourceData("发现该人员涉及" + wfrwfxxList.size() + "个刑事案件，案件编号为：“" + context + "”")
+                    .sourceData("发现该人员涉及" + wfrxxList.size() + "个刑事案件，案件编号为：“" + context + "”")
                     .build();
             toInsert.add(DataUtil.createClueData(task, data));
         }

From caf6d904347d9699c94e4ae5cfb5107a478cbc63 Mon Sep 17 00:00:00 2001
From: sjh <shujiehao@foxmail.com>
Date: Wed, 18 Dec 2024 11:51:30 +0800
Subject: [PATCH 2/3] =?UTF-8?q?=E9=87=8D=E6=9E=84118=E6=A8=A1=E5=9E=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../event/ApplicationEvent.java               |  2 +-
 .../mapper/dwd/GBaseCSCZRKMapper.java         | 11 +++++
 .../pojo/entity/dwd/GBaseCSCZRK.java          |  6 +++
 .../service/impl/PointServiceImpl.java        | 42 +++++++++++--------
 4 files changed, 43 insertions(+), 18 deletions(-)

diff --git a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java
index 07d5b85..3c3d67f 100644
--- a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java
+++ b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java
@@ -145,7 +145,7 @@ public class ApplicationEvent {
             pointService.syncAdministrativePunishment(initDomain(List.of(116)));
 //            pointService.syncParentsDivorce(initDomain(List.of(117)));
 //            gBaseJJDService.syncOtherContradict(initDomain(List.of(75)));
-//            pointService.syncFamilyDie(initDomain(List.of(118)));
+            pointService.syncFamilyDie(initDomain(List.of(118)));
 //            pointService.syncFatherDie(initDomain(List.of(119)));
 //            pointService.syncMotherDie(initDomain(List.of(120)));
 //            pointService.syncChildNo(initDomain(List.of(121)));
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 14b912f..403d60f 100644
--- a/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java
+++ b/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java
@@ -25,6 +25,17 @@ public interface GBaseCSCZRKMapper extends BaseMapper<GBaseCSCZRK> {
             + "on (a.fqgmsfzhm = b.male_id_code or a.mqgmsfzhm = b.female_id_code)) a inner join csga_wdpcdb.wdpc_person b on a.gmsfhm = b.id_code;")
     List<GBaseCSCZRK> selectParentsDivorce();
 
+    @Select("select a.gmsfhm, a.hh, a.fqgmsfzhm, a.mqgmsfzhm from dwd_ry_kxgxzyk_csczrk a inner join csga_wdpcdb.wdpc_person b on a.gmsfhm = b.id_code;")
+    List<GBaseCSCZRK> selectRiskHH();
+
+    @Select("<script>"
+            + "select distinct gmsfhm, hh from dwd_ry_kxgxzyk_csczrk where hh in "
+            + "<foreach item='item' index='index' collection='list' open='(' separator=',' close=')'>"
+            + "#{item}"
+            + "</foreach>"
+            + "</script>")
+    List<GBaseCSCZRK> selectFamilyByHh(List<String> hhPart);
+
     // 亲近家人死亡
     @Select("<script>"
             + "select distinct gmsfhm from dwd_ry_kxgxzyk_csczrk where gmsfhm not in "
diff --git a/src/main/java/com/biutag/supervisiondata/pojo/entity/dwd/GBaseCSCZRK.java b/src/main/java/com/biutag/supervisiondata/pojo/entity/dwd/GBaseCSCZRK.java
index d73cdae..a5d1d03 100644
--- a/src/main/java/com/biutag/supervisiondata/pojo/entity/dwd/GBaseCSCZRK.java
+++ b/src/main/java/com/biutag/supervisiondata/pojo/entity/dwd/GBaseCSCZRK.java
@@ -89,6 +89,12 @@ public class GBaseCSCZRK implements Serializable {
     @TableField("score")
     Integer score;
 
+    /**
+     * 户号
+     */
+    @TableField("`hh`")
+    String hh;
+
     @TableField(exist = false, value = "family_id")
     String familyId;
 
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 0d37994..8ef8cdc 100644
--- a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java
+++ b/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java
@@ -1400,30 +1400,38 @@ public class PointServiceImpl implements PointService {
 
         Map<String, RiskModelTaskClue> oldMap = domain.getOldMap(task.getModelId(), true);
         Map<String, Integer> idCode = new HashMap<>();
-        List<GBaseCSCZRK> list = new ArrayList<>();
+        List<String> list = new ArrayList<>();
         log.info("模型118开始查询");
-        List<WdpcHZCRYXX> wdpcHZCRYXXS = hZCRYXXRepository.list(new LambdaQueryWrapper<WdpcHZCRYXX>().select(WdpcHZCRYXX::getIdCode));
+        List<GBaseCSCZRK> riskHHs = cSCZRKRepository.getBaseMapper().selectRiskHH();
+        log.info("模型118查询到{}条户号", riskHHs.size());
         // 切割 每次查10000条
-        List<List<WdpcHZCRYXX>> wdpcHZCRYXXSParts = IntStream.range(0, (wdpcHZCRYXXS.size() + 9999) / 10000)
-                .mapToObj(i -> wdpcHZCRYXXS.subList(i * 10000, Math.min((i + 1) * 10000, wdpcHZCRYXXS.size())))
+        List<List<GBaseCSCZRK>> riskHHsParts = IntStream.range(0, (riskHHs.size() + 9999) / 10000)
+                .mapToObj(i -> riskHHs.subList(i * 10000, Math.min((i + 1) * 10000, riskHHs.size())))
                 .toList();
-        int i = 1;
-        for (List<WdpcHZCRYXX> wdpcHZCRYXXSPart : wdpcHZCRYXXSParts) {
-            List<String> ids = wdpcHZCRYXXSPart.stream().map(WdpcHZCRYXX::getIdCode).toList();
-            list.addAll(cSCZRKRepository.getBaseMapper().selectFamilyDiePeople(ids));
-            log.info("模型118查询完成{}", i);
-            i++;
-        }
-        log.info("模型118查询结果数：{}", list.size());
+        for (List<GBaseCSCZRK> riskHHsPart : riskHHsParts) {
+            List<String> idCodePart = riskHHsPart.stream().map(GBaseCSCZRK::getGmsfhm).toList();
+            List<String> fatherCodePart = riskHHsPart.stream().map(GBaseCSCZRK::getFqgmsfzhm).filter(Objects::nonNull).toList();
+            List<String> motherCodePart = riskHHsPart.stream().map(GBaseCSCZRK::getMqgmsfzhm).filter(Objects::nonNull).toList();
+            List<String> hhPart = riskHHsPart.stream().map(GBaseCSCZRK::getHh).toList();
+            List<GBaseCSCZRK> familys = cSCZRKRepository.getBaseMapper().selectFamilyByHh(hhPart);
+            log.info("模型118查询到{}条familys", familys.size());
+            List<String> familyIds = familys.stream().map(GBaseCSCZRK::getGmsfhm).filter(v -> !idCodePart.contains(v) && !fatherCodePart.contains(v) && !motherCodePart.contains(v)).toList();
+            List<String> wdpcHZCRYXXS = hZCRYXXRepository.getBaseMapper().selectHZCPeople(familyIds);
+            log.info("模型118查询到{}条HZCPeople", wdpcHZCRYXXS.size());
+            List<String> 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());
+            log.info("模型118当前listSize：{}", list.size());
+        }
+        log.info("模型118查询完毕，结果数：{}", list.size());
         Map<String, RiskPersonal> personalMap = domain.getPersons().stream().collect(Collectors.toMap(RiskPersonal::getIdCode, Function.identity(), (old, newVal) -> newVal));
         List<RiskModelTaskClue> toInsert = new ArrayList<>();
-        for (GBaseCSCZRK domicileType : list) {
-            RiskPersonal personal = personalMap.get(domicileType.getGmsfhm());
+        for (String domicileType : list) {
+            RiskPersonal personal = personalMap.get(domicileType);
             if (personal == null) continue;
-            if (idCode.get(domicileType.getGmsfhm()) != null) continue;
-            if (oldMap.get(domicileType.getGmsfhm()) != null) continue;
+            if (idCode.get(domicileType) != null) continue;
+            if (oldMap.get(domicileType) != null) continue;
 
-            idCode.put(domicileType.getGmsfhm(), 1);
+            idCode.put(domicileType, 1);
                 ClueData data = ClueData.builder()
                         .name(personal.getName())
                         .id(personal.getId().toString())

From 3ae8e6ed972437a0f66aa8ef8c4d65ceb4553d36 Mon Sep 17 00:00:00 2001
From: sjh <shujiehao@foxmail.com>
Date: Wed, 18 Dec 2024 11:53:25 +0800
Subject: [PATCH 3/3] =?UTF-8?q?=E9=87=8D=E6=9E=84118=E6=A8=A1=E5=9E=8B2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../biutag/supervisiondata/service/impl/PointServiceImpl.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 8ef8cdc..5b9dd8f 100644
--- a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java
+++ b/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java
@@ -1418,7 +1418,7 @@ public class PointServiceImpl implements PointService {
             List<String> familyIds = familys.stream().map(GBaseCSCZRK::getGmsfhm).filter(v -> !idCodePart.contains(v) && !fatherCodePart.contains(v) && !motherCodePart.contains(v)).toList();
             List<String> wdpcHZCRYXXS = hZCRYXXRepository.getBaseMapper().selectHZCPeople(familyIds);
             log.info("模型118查询到{}条HZCPeople", wdpcHZCRYXXS.size());
-            List<String> targetHHs = familys.stream().filter(v -> !wdpcHZCRYXXS.contains(v.getGmsfhm())).map(GBaseCSCZRK::getHh).toList();
+            List<String> 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());
             log.info("模型118当前listSize：{}", list.size());
         }