刑事处罚罪名

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)));

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

@@ -148,4 +148,8 @@ public interface GBaseJJDMapper extends BaseMapper<GBaseJJD> {
             " where (bjnr like '%欺凌%' or cjqk like '%欺凌%') " +
             " and SUBSTR(jqxzdm, 1, 2) != '99' and bjsj >= #{start} ")
     List<GBaseJJD> 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<GBaseJJD> selectAllContradict(@Param("start")String start);
 }

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

@@ -33,7 +33,7 @@ public interface GBaseWFRXXMapper extends BaseMapper<GBaseWFRXX> {
      * @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<GBaseWFRXX> selectFiveYearsCombatCrime(@Param("startTime")String startTime, @Param("endTime")String endTime);

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;
     /**
      * 职业名称
      */

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);
 }

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<GBaseJJD> 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<GBaseJJD> result = gBaseJJDRepository.getBaseMapper().selectAllContradict(startTime);
+
+        Map<String, List<GBaseJJD>> jjdMap = new HashMap<>();
+        Map<String, List<GBaseJJD>> 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<String, List<GBaseJJD>> findTargetJJD(List<GBaseJJD> jjdList) {
 
         Map<String, List<GBaseJJD>> fatherIdCodeMap = new WeakHashMap<>();

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<WdpcGrjdZblx> lxList = zblxRepository.list(new LambdaQueryWrapper<WdpcGrjdZblx>()
+                .eq(WdpcGrjdZblx::getLxdm, "15"));
+        Map<String, WdpcGrjdZblx> 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<GBaseWFRXX> 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<RiskModelTaskClue> oldList = Optional.ofNullable(domain.getMap().get(task.getModelId())).orElse(new ArrayList<>());
+        // 按人分
+        Map<String, List<RiskModelTaskClue>> personOldMap = oldList.stream().collect(Collectors.groupingBy(RiskModelTaskClue::getIdCode));
+
+        Map<String, List<GBaseWFRXX>> wfrMap = xxList.stream().collect(Collectors.groupingBy(GBaseWFRXX::getZjhm));
 
+        List<RiskModelTaskClue> toInsert = new ArrayList<>();
+
+        for (RiskPersonal person : domain.getPersons()) {
+            List<GBaseWFRXX> wfxxList = wfrMap.get(person.getIdCode());
+            if (wfxxList == null) {
+                continue;
+            }
+            List<RiskModelTaskClue> olds = Optional.ofNullable(personOldMap.get(person.getIdCode())).orElse(new ArrayList<>());
+            Map<String, RiskModelTaskClue> 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;