From 5ab0f641af1d010f85b38f588e1cd9a586808f41 Mon Sep 17 00:00:00 2001
From: sjh <shujiehao@foxmail.com>
Date: Mon, 9 Dec 2024 11:07:24 +0800
Subject: [PATCH] =?UTF-8?q?=E5=B0=8F=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../event/ApplicationEvent.java               |  1 +
 .../pojo/constants/Default.java               |  2 +
 .../supervisiondata/service/PointService.java |  3 ++
 .../service/impl/PointServiceImpl.java        | 49 ++++++++++++++++++-
 4 files changed, 54 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java
index 265a561..278f15d 100644
--- a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java
+++ b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java
@@ -151,6 +151,7 @@ public class ApplicationEvent {
             pointService.syncFatherDie(initDomain(List.of(119)));
             pointService.syncMotherDie(initDomain(List.of(120)));
             pointService.syncChildNo(initDomain(List.of(121)));
+//            pointService.syncXIDU(initDomain(List.of(122)));// 未完成
 
             // *********暂时不要**********
 //            riskTaskService.caseModelTask(initDomain(List.of(35)));
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 3e2c0fd..278a97b 100644
--- a/src/main/java/com/biutag/supervisiondata/pojo/constants/Default.java
+++ b/src/main/java/com/biutag/supervisiondata/pojo/constants/Default.java
@@ -126,4 +126,6 @@ public class Default {
 
     public static final String CHILDNO = "行为人子女数";
 
+    public static final String DRUG = "吸食毒品";
+
 }
diff --git a/src/main/java/com/biutag/supervisiondata/service/PointService.java b/src/main/java/com/biutag/supervisiondata/service/PointService.java
index 902578b..4bd55cf 100644
--- a/src/main/java/com/biutag/supervisiondata/service/PointService.java
+++ b/src/main/java/com/biutag/supervisiondata/service/PointService.java
@@ -98,4 +98,7 @@ public interface PointService {
 
     // 行为人子女数
     void syncChildNo(TaskParamDomain domain);
+
+    // 吸食毒品
+    void syncXIDU(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 472a70c..5bd4255 100644
--- a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java
+++ b/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java
@@ -526,6 +526,53 @@ public class PointServiceImpl implements PointService {
         taskRepository.updateById(updateTask);
     }
 
+    @Override
+    public void syncXIDU(TaskParamDomain domain) {
+        /*
+        RiskTask task = createTask(domain.getPersons().size(), 122);
+        taskRepository.save(task);
+
+        Map<String, RiskModelTaskClue> oldMap = domain.getOldMap(task.getModelId(), true);
+        Map<String, Integer> idCode = new HashMap<>();
+        List<GBaseCSCZRK> list = new ArrayList<>();
+        log.info("模型122开始查询");
+        for (List<String> idCard : domain.getIdCards()) {
+            list.addAll(cSCZRKRepository.getBaseMapper().selectChildNo(idCard));
+        }
+        log.info("模型122查询结果数：{}", 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 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("吸食毒品")
+                    .eventTime(LocalDateTime.now())
+                    .personId(personal.getId())
+                    .sourceData("发现该人员吸食毒品，增加风险分5分")
+                    .build();
+            toInsert.add(createClue(task.getModelId(), 5, task.getId(), data));
+        }
+        if (!toInsert.isEmpty()) {
+            modelTaskClueService.saveClues(toInsert, Default.DRUG);
+        }
+        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 syncChildNo(TaskParamDomain domain) {
         RiskTask task = createTask(domain.getPersons().size(), 121);
@@ -571,7 +618,7 @@ public class PointServiceImpl implements PointService {
             toInsert.add(createClue(task.getModelId(), realScore, task.getId(), data));
         }
         if (!toInsert.isEmpty()) {
-            modelTaskClueService.saveClues(toInsert, Default.FAMILYDIE);
+            modelTaskClueService.saveClues(toInsert, Default.CHILDNO);
         }
         RiskTask updateTask = new RiskTask();
         updateTask.setId(task.getId());