父亲文化程度、母亲文化程度

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

@@ -131,7 +131,8 @@ public class ApplicationEvent {
 //            pointService.syncPointCall(initDomain(List.of(50)));
 //            pointService.syncOilBuy(initDomain(List.of(52)));
             pointService.syncIsPetition(initDomain(List.of(101)));
-
+            pointService.syncFatherEducation(initDomain(List.of(102)));
+            pointService.syncMotherEducation(initDomain(List.of(103)));
             //暂时废弃该保安
             //gBaseBAService.baModelTask(initDomain(List.of(37)));
             //personalService.syncOrg();

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

@@ -0,0 +1,18 @@
+package com.biutag.supervisiondata.mapper.dwd;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.biutag.supervisiondata.pojo.entity.dwd.GBaseCSCZRK;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
+
+public interface GBaseCSCZRKMapper extends BaseMapper<GBaseCSCZRK> {
+
+    @Select("select a.gmsfhm, b.whcdmc fatherEducation from dwd_ry_kxgxzyk_csczrk a left join dwd_ry_kxgxzyk_csczrk b "
+            + "on a.fqgmsfzhm = b.gmsfhm where a.fqgmsfzhm is not null and b.whcdmc is not null and a.fqgmsfzhm != a.gmsfhm")
+    List<GBaseCSCZRK> selectFatherEducation();
+
+    @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();
+}

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

@@ -89,4 +89,8 @@ public class Default {
     public static final String CAR_IG ="有车因素";
 
     public static final String IS_PETITION = "是否上访";
+
+    public static final String FATHER_EDUCATION = "父亲文化程度";
+
+    public static final String MOTHER_EDUCATION = "母亲文化程度";
 }

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

@@ -0,0 +1,83 @@
+package com.biutag.supervisiondata.pojo.entity.dwd;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+@Data
+@TableName("dwd_ry_kxgxzyk_csczrk")
+public class GBaseCSCZRK implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    // 姓名
+    @TableField("xm")
+    String xm;
+
+    // 性别名称
+    @TableField("xbmc")
+    String xbmc;
+
+    // 民族名称
+    @TableField("mzmc")
+    String mzmc;
+
+    // 出生日期
+    @TableField("csrq")
+    LocalDateTime csrq;
+
+    // 住址省市县区代码
+    @TableField("zzssxq")
+    String zzssxq;
+
+    // 住址详址
+    @TableField("zzxz")
+    String zzxz;
+
+    // 出生地-省市县
+    @TableField("csd")
+    String csd;
+
+    // 公民身份证号码
+    @TableField("gmsfhm")
+    String gmsfhm;
+
+    // 文化程度名称
+    @TableField("whcdmc")
+    String whcdmc;
+
+    // 婚姻状况名称
+    @TableField("hyzkmc")
+    String hyzkmc;
+
+    // 职业名称
+    @TableField("zymc")
+    String zymc;
+
+    // 所属派出所机关代码
+    @TableField("sspcsjgdm")
+    String sspcsjgdm;
+
+    // 所属派出所名称
+    @TableField("sspcsmc")
+    String sspcsmc;
+
+    // 父亲身份证号
+    @TableField("fqgmsfzhm")
+    String fqgmsfzhm;
+
+    // 母亲身份证号
+    @TableField("mqgmsfzhm")
+    String mqgmsfzhm;
+
+    @TableField(exist = false)
+    String fatherEducation;
+
+    @TableField(exist = false)
+    String motherEducation;
+}

src/main/java/com/biutag/supervisiondata/repository/GBaseCSCZRKRepository.java

@@ -0,0 +1,10 @@
+package com.biutag.supervisiondata.repository;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.biutag.supervisiondata.mapper.dwd.GBaseCSCZRKMapper;
+import com.biutag.supervisiondata.pojo.entity.dwd.GBaseCSCZRK;
+import org.springframework.stereotype.Service;
+
+@Service
+public class GBaseCSCZRKRepository extends ServiceImpl<GBaseCSCZRKMapper, GBaseCSCZRK> {
+}

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

@@ -38,6 +38,12 @@ public interface PointService {
     // 是否上访
     void syncIsPetition(TaskParamDomain domain);
 
+    // 父亲文化程度
+    void syncFatherEducation(TaskParamDomain domain);
+
+    // 母亲文化程度
+    void syncMotherEducation(TaskParamDomain domain);
+
     void syncSecurity(TaskParamDomain domain);
 
     /**

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

@@ -11,6 +11,7 @@ import com.biutag.supervisiondata.pojo.database.MuchCall;
 import com.biutag.supervisiondata.pojo.database.PointOrg;
 import com.biutag.supervisiondata.pojo.database.SecurityMan;
 import com.biutag.supervisiondata.pojo.domain.*;
+import com.biutag.supervisiondata.pojo.entity.dwd.GBaseCSCZRK;
 import com.biutag.supervisiondata.pojo.entity.dwd.GBaseOilBuy;
 import com.biutag.supervisiondata.pojo.entity.dwd.GBaseTbDZdrylb;
 import com.biutag.supervisiondata.pojo.entity.dwd.GBaseZDRY;
@@ -61,6 +62,8 @@ public class PointServiceImpl implements PointService {
 
     private final WdpcGrjdXfsjCsRepository wdpcGrjdXfsjCsRepository;
 
+    private final GBaseCSCZRKRepository cSCZRKRepository;
+
     @Override
     public void personPullAndSave(LocalDateTime start, LocalDateTime end) {
         riskPersonalService.formatAndSave(getPersons(), Default.POINT_POEPLE);
@@ -234,6 +237,101 @@ public class PointServiceImpl implements PointService {
         taskRepository.updateById(updateTask);
     }
 
+    @Override
+    public void syncFatherEducation(TaskParamDomain domain) {
+        RiskTask task = createTask(domain.getPersons().size(), 102);
+        taskRepository.save(task);
+
+        Map<String, RiskModelTaskClue> oldMap = domain.getOldMap(task.getModelId(), true);
+        Map<String, Integer> idCode = new HashMap<>();
+        List<GBaseCSCZRK> list = cSCZRKRepository.getBaseMapper().selectFatherEducation();
+        log.info("模型102查询结果数：{}", 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 fatherEducation : list) {
+            RiskPersonal personal = personalMap.get(fatherEducation.getGmsfhm());
+            if (personal == null) continue;
+            if (idCode.get(fatherEducation.getGmsfhm()) != null) continue;
+            if (oldMap.get(fatherEducation.getGmsfhm()) != null) continue;
+
+            idCode.put(fatherEducation.getGmsfhm(), 1);
+            int eduScore = getEduScore(fatherEducation);
+            ClueData data = ClueData.builder()
+                    .name(personal.getName())
+                    .id(personal.getId().toString())
+                    .idCode(personal.getIdCode())
+                    .tag("父亲文化程度")
+                    .personId(personal.getId())
+                    .sourceData("发现该人员父亲文化程度为" + fatherEducation.getFatherEducation() + "，增加风险分" + eduScore + "分")
+                    .build();
+            toInsert.add(createClue(task.getModelId(), eduScore, task.getId(), data));
+        }
+        if (!toInsert.isEmpty()) {
+            modelTaskClueService.saveClues(toInsert, Default.FATHER_EDUCATION);
+        }
+        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 syncMotherEducation(TaskParamDomain domain) {
+        RiskTask task = createTask(domain.getPersons().size(), 103);
+        taskRepository.save(task);
+
+        Map<String, RiskModelTaskClue> oldMap = domain.getOldMap(task.getModelId(), true);
+        Map<String, Integer> idCode = new HashMap<>();
+        List<GBaseCSCZRK> list = cSCZRKRepository.getBaseMapper().selectMotherEducation();
+        log.info("模型103查询结果数：{}", 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 motherEducation : list) {
+            RiskPersonal personal = personalMap.get(motherEducation.getGmsfhm());
+            if (personal == null) continue;
+            if (idCode.get(motherEducation.getGmsfhm()) != null) continue;
+            if (oldMap.get(motherEducation.getGmsfhm()) != null) continue;
+
+            idCode.put(motherEducation.getGmsfhm(), 1);
+            int eduScore = getEduScore(motherEducation);
+            ClueData data = ClueData.builder()
+                    .name(personal.getName())
+                    .id(personal.getId().toString())
+                    .idCode(personal.getIdCode())
+                    .tag("母亲文化程度")
+                    .personId(personal.getId())
+                    .sourceData("发现该人员母亲文化程度为" + motherEducation.getMotherEducation() + "，增加风险分" + eduScore + "分")
+                    .build();
+            toInsert.add(createClue(task.getModelId(), eduScore, task.getId(), data));
+        }
+        if (!toInsert.isEmpty()) {
+            modelTaskClueService.saveClues(toInsert, Default.MOTHER_EDUCATION);
+        }
+        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);
+    }
+
+    private static int getEduScore(GBaseCSCZRK fatherEducation) {
+        return switch (fatherEducation.getFatherEducation()) {
+            case "研究生", "研究生肄业", "研究生毕业", "大学毕业", "大学本科", "大学肄业", "相当大学毕业" -> 1;// 本科
+            case "大学专科和专科学校", "相当专科毕业", "专科毕业", "专科肄业" -> 2;// 大专
+            case "相当高中毕业", "相当中专或中技毕业", "中专中技肄业", "职业高中毕业", "中专毕业", "高中肄业",
+                 "中技毕业", "中等专科学校", "高中", "高中毕业", "农业高中毕业" -> 3;// 高中中专
+            case "农业初中毕业", "技工学校", "技工学校肄业", "技工学校毕业", "初中", "职业初中毕业", "初中毕业",
+                 "初中肆业", "相当初中毕业" -> 4;// 初中
+            case "小学", "小学肄业", "小学毕业", "相当小学毕业", "文盲", "文盲或半文盲", "学龄前儿童" -> 5;// 小学
+            default -> 0;
+        };
+    }
+
     @Override
     public void syncIsPetition(TaskParamDomain domain) {
         RiskTask task = createTask(domain.getPersons().size(), 101);