From 08e1a341015d585d644cc63d906a783f353554b4 Mon Sep 17 00:00:00 2001 From: kami <605128600@qq.com> Date: Mon, 9 Dec 2024 18:59:27 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=91=E4=BA=8B=E5=A4=84=E7=BD=9A=E7=BD=AA?= =?UTF-8?q?=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../event/ApplicationEvent.java | 30 ++++++---- .../mapper/dwd/GBaseJJDMapper.java | 4 ++ .../mapper/dwd/GBaseWFRXXMapper.java | 2 +- .../pojo/entity/dwd/GBaseWFRXX.java | 5 ++ .../service/GBaseJJDService.java | 5 ++ .../service/impl/GBaseJJDServiceImpl.java | 30 +++++++++- .../service/impl/GBaseSHRWFRServiceImpl.java | 55 ++++++++++++++++++- 7 files changed, 117 insertions(+), 14 deletions(-) diff --git a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java index 41db8d3..7995bab 100644 --- a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java +++ b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java @@ -140,20 +140,28 @@ public class ApplicationEvent { // gBaseSHRWFRService.combatCrime(initDomain(List.of(63))); // gBaseJJDService.syncPoliceAttack(initDomain(List.of(64))); // gBaseJJDService.syncHomeViolence(initDomain(List.of(65,66))); +// pointService.syncPointType(initDomain(List.of(67))); +// gBaseSHRWFRService.hadWork(initDomain(List.of(68))); +// gBaseJJDService.syncParentRelation(initDomain(List.of(69,70))); +// gBaseJJDService.syncLove(initDomain(List.of(71))); +// gBaseJJDService.syncMarryDispute(initDomain(List.of(72))); +// gBaseJJDService.syncNeighborAndColleagueDispute(initDomain(List.of(73))); +// gBaseJJDService.syncBullying(initDomain(List.of(74))); +// gBaseSHRWFRService.crimeName(initDomain(List.of(75))); // pointService.syncIsPetition(initDomain(List.of(111))); // 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))); - pointService.syncFatherDie(initDomain(List.of(119))); - pointService.syncMotherDie(initDomain(List.of(120))); - pointService.syncChildNo(initDomain(List.of(121))); - pointService.syncXIDU(initDomain(List.of(122))); - pointService.syncFiliation(initDomain(List.of(123))); - pointService.syncPetitionContent(initDomain(List.of(124))); +// 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))); +// pointService.syncFatherDie(initDomain(List.of(119))); +// pointService.syncMotherDie(initDomain(List.of(120))); +// pointService.syncChildNo(initDomain(List.of(121))); +// pointService.syncXIDU(initDomain(List.of(122))); +// pointService.syncFiliation(initDomain(List.of(123))); +// pointService.syncPetitionContent(initDomain(List.of(124))); // *********暂时不要********** // riskTaskService.caseModelTask(initDomain(List.of(35))); diff --git a/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseJJDMapper.java b/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseJJDMapper.java index ae2afed..efd8417 100644 --- a/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseJJDMapper.java +++ b/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseJJDMapper.java @@ -148,4 +148,8 @@ public interface GBaseJJDMapper extends BaseMapper { " where (bjnr like '%欺凌%' or cjqk like '%欺凌%') " + " and SUBSTR(jqxzdm, 1, 2) != '99' and bjsj >= #{start} ") List selectBullying(@Param("start")String start); + + @Select(" select jjdbh, bjdh ,bjrzjhm, bjnr, cjqk, bjsj from dwd_asj_zhtx_jjd" + + " where jqxzmc like '%纠纷%' and bjsj >= #{start} ") + List selectAllContradict(@Param("start")String start); } diff --git a/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseWFRXXMapper.java b/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseWFRXXMapper.java index f6e9c71..e0d02f7 100644 --- a/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseWFRXXMapper.java +++ b/src/main/java/com/biutag/supervisiondata/mapper/dwd/GBaseWFRXXMapper.java @@ -33,7 +33,7 @@ public interface GBaseWFRXXMapper extends BaseMapper { * @param endTime 查询结束时间（处警时间） * @return 列表 */ - @Select(" select ajbh,zjhm,sxzm,lrsj from dwd_ry_zfba_wfryxx " + + @Select(" select ajbh,zjhm,sxzm, sxzmdm,lrsj from dwd_ry_zfba_wfryxx " + " where lrsj between #{startTime} and #{endTime} " + " and ajbh is not null and zjhm is not null") List selectFiveYearsCombatCrime(@Param("startTime")String startTime, @Param("endTime")String endTime); diff --git a/src/main/java/com/biutag/supervisiondata/pojo/entity/dwd/GBaseWFRXX.java b/src/main/java/com/biutag/supervisiondata/pojo/entity/dwd/GBaseWFRXX.java index 97b876e..28bef26 100644 --- a/src/main/java/com/biutag/supervisiondata/pojo/entity/dwd/GBaseWFRXX.java +++ b/src/main/java/com/biutag/supervisiondata/pojo/entity/dwd/GBaseWFRXX.java @@ -45,6 +45,11 @@ public class GBaseWFRXX implements Serializable { */ @TableField("sxzm") String sxzm; + /** + * 罪名名称代码 + */ + @TableField("sxzmdm") + String sxzmdm; /** * 职业名称 */ diff --git a/src/main/java/com/biutag/supervisiondata/service/GBaseJJDService.java b/src/main/java/com/biutag/supervisiondata/service/GBaseJJDService.java index d8926a9..e9f6538 100644 --- a/src/main/java/com/biutag/supervisiondata/service/GBaseJJDService.java +++ b/src/main/java/com/biutag/supervisiondata/service/GBaseJJDService.java @@ -60,4 +60,9 @@ public interface GBaseJJDService { * @param domain domain */ void syncBullying(TaskParamDomain domain); + /** + * 其他矛盾纠纷 + * @param domain domain + */ + void syncOtherContradict(TaskParamDomain domain); } diff --git a/src/main/java/com/biutag/supervisiondata/service/impl/GBaseJJDServiceImpl.java b/src/main/java/com/biutag/supervisiondata/service/impl/GBaseJJDServiceImpl.java index 7e26baf..1f39a88 100644 --- a/src/main/java/com/biutag/supervisiondata/service/impl/GBaseJJDServiceImpl.java +++ b/src/main/java/com/biutag/supervisiondata/service/impl/GBaseJJDServiceImpl.java @@ -845,7 +845,6 @@ public class GBaseJJDServiceImpl implements GBaseJJDService { @Override public void syncBullying(TaskParamDomain domain) { String startTime = LocalDateTime.of(2023, 12, 6, 0, 0, 0).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")); - LocalDateTime limit = LocalDateTime.now().minusYears(1); List result = gBaseJJDRepository.getBaseMapper().selectBullying(startTime); // 恋爱创伤 @@ -954,6 +953,35 @@ public class GBaseJJDServiceImpl implements GBaseJJDService { taskRepository.updateTask(task.getId(), toInsert.size(), 0); } + @Override + public void syncOtherContradict(TaskParamDomain domain) { + String startTime = LocalDateTime.of(2023, 12, 6, 0, 0, 0).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")); + List result = gBaseJJDRepository.getBaseMapper().selectAllContradict(startTime); + + Map> jjdMap = new HashMap<>(); + Map> jjdMMap = new HashMap<>(); +// for (GBaseJJD item : result) { +// if (item.getBjrzjhm() != null) { +// jjdMap.computeIfAbsent(item.getBjrzjhm(), k -> new ArrayList<>()).add(item); +// continue; +// } +// String idCards = PatternUtil.takeIdCard(item.getCjqk()); +// if (!idCards.isEmpty()) { +// person.setIdCode(idCards); +// String[] strs = idCards.split(","); +// for (String s : strs) { +// jjdMap.computeIfAbsent(item.getBjrzjhm(), k -> new ArrayList<>()).add(item); +// } +// } else if (item.getBjrlxdh() == null) { +// continue; +// } else { +// mobiles1.add(item.getBjrlxdh()); +// jjdMMap.computeIfAbsent(item.getBjrzjhm(), k -> new ArrayList<>()).add(item); +// } +// personals.add(person); +// } + } + Map> findTargetJJD(List jjdList) { Map> fatherIdCodeMap = new WeakHashMap<>(); diff --git a/src/main/java/com/biutag/supervisiondata/service/impl/GBaseSHRWFRServiceImpl.java b/src/main/java/com/biutag/supervisiondata/service/impl/GBaseSHRWFRServiceImpl.java index aad5a93..04c53dd 100644 --- a/src/main/java/com/biutag/supervisiondata/service/impl/GBaseSHRWFRServiceImpl.java +++ b/src/main/java/com/biutag/supervisiondata/service/impl/GBaseSHRWFRServiceImpl.java @@ -356,14 +356,67 @@ public class GBaseSHRWFRServiceImpl implements GBaseSHRWFRService { } if (!toInsert.isEmpty()) { - clueService.saveClues(toInsert, Default.WF_IG); + clueService.saveClues(toInsert, "B24是否被打击处理"); } taskRepository.updateTask(task.getId(), toInsert.size(), 0); } @Override public void crimeName(TaskParamDomain domain) { + List lxList = zblxRepository.list(new LambdaQueryWrapper() + .eq(WdpcGrjdZblx::getLxdm, "15")); + Map map = lxList.stream().collect(Collectors.toMap(WdpcGrjdZblx::getDmbh, Function.identity(), (val, old) -> val)); + LocalDateTime start = LocalDateTime.of(2019, 12, 6, 0, 0, 0); + LocalDateTime end = LocalDate.now().atTime(0, 0, 0); + + + List xxList = wfrxxRepository.getBaseMapper().selectFiveYearsCombatCrime(start.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")), end.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); + RiskTask task = taskRepository.create(xxList.size(), 75); + + List oldList = Optional.ofNullable(domain.getMap().get(task.getModelId())).orElse(new ArrayList<>()); + // 按人分 + Map> personOldMap = oldList.stream().collect(Collectors.groupingBy(RiskModelTaskClue::getIdCode)); + + Map> wfrMap = xxList.stream().collect(Collectors.groupingBy(GBaseWFRXX::getZjhm)); + List toInsert = new ArrayList<>(); + + for (RiskPersonal person : domain.getPersons()) { + List wfxxList = wfrMap.get(person.getIdCode()); + if (wfxxList == null) { + continue; + } + List olds = Optional.ofNullable(personOldMap.get(person.getIdCode())).orElse(new ArrayList<>()); + Map oldMap = olds.stream().collect(Collectors.toMap(RiskModelTaskClue::getCaseIds, Function.identity(), (val, old) -> val)); + for (GBaseWFRXX xx : wfxxList) { + if (oldMap.get(BhUtil.ajBh(xx.getAjbh())) != null) { + continue; + } + WdpcGrjdZblx zblx = map.get(xx.getSxzmdm()); + if(zblx == null) { + continue; + } + ClueData data = ClueData.builder() + .name(person.getName()) + .id(BhUtil.ajBh(xx.getAjbh())) + .idCode(person.getIdCode()) + .tag(zblx.getDmmc()) + .personId(person.getId()) + .sourceData("该人员有犯罪前科，刑事处罚罪名：" + zblx.getDmmc() + "，案件编号：" + xx.getAjbh() + "，增加风险"+zblx.getScore().intValue()+"5分") + .build(); + try { + data.setEventTime(xx.getLrsj().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime()); + } catch (Exception ignored) { + data.setEventTime(LocalDateTime.now()); + } + toInsert.add(createClue(task.getModelId(), zblx.getScore().intValue(), task.getId(), data)); + } + } + + if (!toInsert.isEmpty()) { + clueService.saveClues(toInsert, "B27刑事处罚罪名"); + } + taskRepository.updateTask(task.getId(), toInsert.size(), 0); } private final WdpcGrjdZblxRepository zblxRepository;