From f3f7d7afb59741b5fca50d0576a1d5bf3004c0f4 Mon Sep 17 00:00:00 2001 From: sjh Date: Thu, 5 Dec 2024 18:03:20 +0800 Subject: [PATCH] =?UTF-8?q?=E6=88=B7=E7=B1=8D=E7=B1=BB=E5=9E=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../event/ApplicationEvent.java | 1 + .../mapper/dwd/GBaseCSCZRKMapper.java | 4 ++ .../pojo/constants/Default.java | 2 + .../pojo/entity/dwd/GBaseCSCZRK.java | 4 ++ .../supervisiondata/service/PointService.java | 3 ++ .../service/impl/PointServiceImpl.java | 46 +++++++++++++++++++ 6 files changed, 60 insertions(+) diff --git a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java index 46496f4..cd5588c 100644 --- a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java +++ b/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(); 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 89fe70b..f655cf1 100644 --- a/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java +++ b/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java @@ -15,4 +15,8 @@ public interface GBaseCSCZRKMapper extends BaseMapper { @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 selectMotherEducation(); + + // 户籍类型 + @Select("select gmsfhm, hlxmc from dwd_ry_kxgxzyk_csczrk where hlxmc is not null") + List selectDomicileType(); } diff --git a/src/main/java/com/biutag/supervisiondata/pojo/constants/Default.java b/src/main/java/com/biutag/supervisiondata/pojo/constants/Default.java index 4496c98..a81b1fd 100644 --- a/src/main/java/com/biutag/supervisiondata/pojo/constants/Default.java +++ b/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 = "户籍类型"; } 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 5fd9eed..dfe5484 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 @@ -75,6 +75,10 @@ public class GBaseCSCZRK implements Serializable { @TableField("mqgmsfzhm") String mqgmsfzhm; + // 户籍类型名称 + @TableField("hlxmc") + String hlxmc; + @TableField(exist = false) String fatherEducation; diff --git a/src/main/java/com/biutag/supervisiondata/service/PointService.java b/src/main/java/com/biutag/supervisiondata/service/PointService.java index 70d94f5..a79d166 100644 --- a/src/main/java/com/biutag/supervisiondata/service/PointService.java +++ b/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); /** 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 e399cfa..1072141 100644 --- a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java +++ b/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 oldMap = domain.getOldMap(task.getModelId(), true); + Map idCode = new HashMap<>(); + List list = cSCZRKRepository.getBaseMapper().selectDomicileType(); + log.info("模型104查询结果数：{}", list.size()); + Map personalMap = domain.getPersons().stream().collect(Collectors.toMap(RiskPersonal::getIdCode, Function.identity(), (old, newVal) -> newVal)); + List 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);