受到刑事处罚、受到行政处罚 改变数据来源

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.syncCriminalPunishment(initDomain(List.of(115)));
-//            pointService.syncAdministrativePunishment(initDomain(List.of(116)));
+            pointService.syncAdministrativePunishment(initDomain(List.of(116)));
 //            pointService.syncParentsDivorce(initDomain(List.of(117)));
 //            gBaseJJDService.syncOtherContradict(initDomain(List.of(75)));
 //            pointService.syncFamilyDie(initDomain(List.of(118)));

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();
 }

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(","));
+            String context = wfrxxList.stream().map(GBaseWFRXX::getAjbh).collect(Collectors.joining(","));
-            score = Math.min(wfrwfxxList.size(), 5);
+            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));
         }