户籍类型

src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java

@@ -133,6 +133,7 @@ public class ApplicationEvent {
             pointService.syncIsPetition(initDomain(List.of(101)));
             pointService.syncFatherEducation(initDomain(List.of(102)));
             pointService.syncMotherEducation(initDomain(List.of(103)));
+            pointService.syncDomicileType(initDomain(List.of(104)));
             //暂时废弃该保安
             //gBaseBAService.baModelTask(initDomain(List.of(37)));
             //personalService.syncOrg();

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

@@ -15,4 +15,8 @@ public interface GBaseCSCZRKMapper extends BaseMapper<GBaseCSCZRK> {
     @Select("select a.gmsfhm, b.whcdmc motherEducation from dwd_ry_kxgxzyk_csczrk a left join dwd_ry_kxgxzyk_csczrk b "
             + "on a.mqgmsfzhm = b.gmsfhm where a.mqgmsfzhm is not null and b.whcdmc is not null and a.mqgmsfzhm != a.gmsfhm")
     List<GBaseCSCZRK> selectMotherEducation();
+
+    // 户籍类型
+    @Select("select gmsfhm, hlxmc from dwd_ry_kxgxzyk_csczrk where hlxmc is not null")
+    List<GBaseCSCZRK> selectDomicileType();
 }

src/main/java/com/biutag/supervisiondata/pojo/constants/Default.java

@@ -95,4 +95,6 @@ public class Default {
     public static final String FATHER_EDUCATION = "父亲文化程度";
 
     public static final String MOTHER_EDUCATION = "母亲文化程度";
+
+    public static final String DOMICILETYPE = "户籍类型";
 }

src/main/java/com/biutag/supervisiondata/pojo/entity/dwd/GBaseCSCZRK.java

@@ -75,6 +75,10 @@ public class GBaseCSCZRK implements Serializable {
     @TableField("mqgmsfzhm")
     String mqgmsfzhm;
 
+    // 户籍类型名称
+    @TableField("hlxmc")
+    String hlxmc;
+
     @TableField(exist = false)
     String fatherEducation;
 

src/main/java/com/biutag/supervisiondata/service/PointService.java

@@ -44,6 +44,9 @@ public interface PointService {
     // 母亲文化程度
     void syncMotherEducation(TaskParamDomain domain);
 
+    // 户籍类型
+    void syncDomicileType(TaskParamDomain domain);
+
     void syncSecurity(TaskParamDomain domain);
 
     /**

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

@@ -237,6 +237,52 @@ public class PointServiceImpl implements PointService {
         taskRepository.updateById(updateTask);
     }
 
+
+    @Override
+    public void syncDomicileType(TaskParamDomain domain) {
+        RiskTask task = createTask(domain.getPersons().size(), 104);
+        taskRepository.save(task);
+
+        Map<String, RiskModelTaskClue> oldMap = domain.getOldMap(task.getModelId(), true);
+        Map<String, Integer> idCode = new HashMap<>();
+        List<GBaseCSCZRK> list = cSCZRKRepository.getBaseMapper().selectDomicileType();
+        log.info("模型104查询结果数：{}", 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());
+            if (personal == null) continue;
+            if (idCode.get(domicileType.getGmsfhm()) != null) continue;
+            if (oldMap.get(domicileType.getGmsfhm()) != null) continue;
+
+            idCode.put(domicileType.getGmsfhm(), 1);
+            if (domicileType.getHlxmc().equals("非农业集体户口") ||
+                    domicileType.getHlxmc().equals("非农业家庭户口") ||
+                    domicileType.getHlxmc().equals("地方城镇居民户口")) {
+                continue;
+            }
+            ClueData data = ClueData.builder()
+                    .name(personal.getName())
+                    .id(personal.getId().toString())
+                    .idCode(personal.getIdCode())
+                    .tag("户籍类型")
+                    .personId(personal.getId())
+                    .sourceData("发现该人员户籍类型为" + domicileType.getGmsfhm() + "，增加风险分5分")
+                    .build();
+            toInsert.add(createClue(task.getModelId(), 5, task.getId(), data));
+        }
+        if (!toInsert.isEmpty()) {
+            modelTaskClueService.saveClues(toInsert, Default.DOMICILETYPE);
+        }
+        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);
+    }
+
     @Override
     public void syncFatherEducation(TaskParamDomain domain) {
         RiskTask task = createTask(domain.getPersons().size(), 102);