From 13ff00c210374d47f92a9b6f405ae8cc753c49fb Mon Sep 17 00:00:00 2001 From: sjh Date: Fri, 6 Dec 2024 17:10:43 +0800 Subject: [PATCH] =?UTF-8?q?=E7=88=B6=E6=AF=8D=E5=A9=9A=E5=A7=BB=E5=8F=98?= =?UTF-8?q?=E6=95=85?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../event/ApplicationEvent.java | 4 +- .../mapper/dwd/GBaseCSCZRKMapper.java | 13 +++ .../pojo/constants/Default.java | 6 +- .../supervisiondata/service/PointService.java | 6 ++ .../service/impl/PointServiceImpl.java | 90 +++++++++++++++++++ 5 files changed, 117 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java index 8f1af79..1f7afa3 100644 --- a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java +++ b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java @@ -133,12 +133,14 @@ public class ApplicationEvent { // pointService.syncControlNoPower(initDomain(List.of(48))); // pointService.syncPointCall(initDomain(List.of(50))); // pointService.syncOilBuy(initDomain(List.of(52))); -// pointService.syncIsPetition(initDomain(List.of(111))); + pointService.syncIsPetition(initDomain(List.of(40))); // 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.syncParentsDivorce(initDomain(List.of(117))); +// pointService.syncFamilyDie(initDomain(List.of(118))); // 未完成 }); } 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 6aa6d69..9a4e116 100644 --- a/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java +++ b/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseCSCZRKMapper.java @@ -24,4 +24,17 @@ public interface GBaseCSCZRKMapper extends BaseMapper { + "" + "") List selectDomicileType(List idNos); + + // 父母婚姻变故 + @Select("") + List selectParentsDivorce(List idNos); } 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 7299914..ce9f590 100644 --- a/src/main/java/com/biutag/supervisiondata/pojo/constants/Default.java +++ b/src/main/java/com/biutag/supervisiondata/pojo/constants/Default.java @@ -90,7 +90,7 @@ public class Default { public static final String CAR_IG ="有车因素"; - public static final String IS_PETITION = "是否上访"; + public static final String IS_PETITION = "信访、投诉-信访局信访"; public static final String FATHER_EDUCATION = "父亲文化程度"; @@ -101,4 +101,8 @@ public class Default { public static final String CRIMINALPUNISHMENT = "受到刑事处罚"; public static final String ADMINISTRATIVEPUNISHMENT = "受到行政处罚"; + + public static final String PARENTSDIVORCE = "父母离婚"; + + public static final String FAMILYDIE = "亲近家人死亡"; } diff --git a/src/main/java/com/biutag/supervisiondata/service/PointService.java b/src/main/java/com/biutag/supervisiondata/service/PointService.java index 9e2dfa1..82227b3 100644 --- a/src/main/java/com/biutag/supervisiondata/service/PointService.java +++ b/src/main/java/com/biutag/supervisiondata/service/PointService.java @@ -60,4 +60,10 @@ public interface PointService { // 行政处罚 void syncAdministrativePunishment(TaskParamDomain domain); + + // 父母婚姻变故 + void syncParentsDivorce(TaskParamDomain domain); + + // 亲近家人死亡 + void syncFamilyDie(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 a30b39b..b0ab96c 100644 --- a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java +++ b/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java @@ -321,6 +321,96 @@ public class PointServiceImpl implements PointService { taskRepository.updateById(updateTask); } + @Override + public void syncParentsDivorce(TaskParamDomain domain) { + RiskTask task = createTask(domain.getPersons().size(), 117); + taskRepository.save(task); + + Map oldMap = domain.getOldMap(task.getModelId(), true); + Map idCode = new HashMap<>(); + List list = new ArrayList<>(); + log.info("模型117开始查询"); + for (List idCard : domain.getIdCards()) { + list.addAll(cSCZRKRepository.getBaseMapper().selectParentsDivorce(idCard)); + } + log.info("模型117查询结果数：{}", 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); + ClueData data = ClueData.builder() + .name(personal.getName()) + .id(personal.getId().toString()) + .idCode(personal.getIdCode()) + .tag("父母婚姻变故") + .personId(personal.getId()) + .sourceData("发现该人员父母离婚，增加风险分5分") + .build(); + toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + } + if (!toInsert.isEmpty()) { + modelTaskClueService.saveClues(toInsert, Default.PARENTSDIVORCE); + } + 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 syncFamilyDie(TaskParamDomain domain) { + /* + RiskTask task = createTask(domain.getPersons().size(), 118); + taskRepository.save(task); + + Map oldMap = domain.getOldMap(task.getModelId(), true); + Map idCode = new HashMap<>(); + List list = new ArrayList<>(); + log.info("模型118开始查询"); + for (List idCard : domain.getIdCards()) { +// list.addAll(cSCZRKRepository.getBaseMapper().selectDomicileType(idCard)); + } + log.info("模型118查询结果数：{}", 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); + ClueData data = ClueData.builder() + .name(personal.getName()) + .id(personal.getId().toString()) + .idCode(personal.getIdCode()) + .tag("亲近家人死亡") + .personId(personal.getId()) + .sourceData("发现该人员亲近家人死亡，增加风险分5分") + .build(); + toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + } + if (!toInsert.isEmpty()) { + modelTaskClueService.saveClues(toInsert, Default.FAMILYDIE); + } + 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 syncDomicileType(TaskParamDomain domain) { RiskTask task = createTask(domain.getPersons().size(), 114);