From 4140a246b073e2c46ae6be82faf46a5468cf3fea Mon Sep 17 00:00:00 2001
From: kami <605128600@qq.com>
Date: Tue, 26 Nov 2024 16:37:28 +0800
Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E7=82=B9=E4=BA=BA=E5=91=98=E6=89=93?=
 =?UTF-8?q?=E7=94=B5=E8=AF=9D=E5=8F=AA=E5=81=9A=E5=A2=9E=E9=87=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/PointServiceImpl.java        | 19 ++++++++++++++-----
 1 file changed, 14 insertions(+), 5 deletions(-)

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 438303a..1e94cf8 100644
--- a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java
+++ b/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java
@@ -104,7 +104,7 @@ public class PointServiceImpl implements PointService {
             }
         }
         if (!toInsert.isEmpty()) {
-            modelTaskClueService.saveClues(toInsert, Default.POINT_POEPLE);
+            modelTaskClueService.saveClues(toInsert, Default.POINT_IG);
         }
         RiskTask updateTask = new RiskTask();
         updateTask.setId(task.getId());
@@ -166,7 +166,7 @@ public class PointServiceImpl implements PointService {
         }
 
         if (!toInsert.isEmpty()) {
-            modelTaskClueService.saveClues(toInsert, Default.VIOLENCE);
+            modelTaskClueService.saveClues(toInsert, Default.VIOLENCE_IG);
         }
         RiskTask updateTask = new RiskTask();
         updateTask.setId(task.getId());
@@ -216,7 +216,7 @@ public class PointServiceImpl implements PointService {
         }
 
         if (!toInsert.isEmpty()) {
-            modelTaskClueService.saveClues(toInsert, Default.KILL_SELF);
+            modelTaskClueService.saveClues(toInsert, Default.KILL_IG);
         }
         RiskTask updateTask = new RiskTask();
         updateTask.setId(task.getId());
@@ -254,6 +254,9 @@ public class PointServiceImpl implements PointService {
                     .build();
             toInsert.add(createClue(task.getModelId(), 2, task.getId(), data));
         }
+        if(!toInsert.isEmpty()) {
+            modelTaskClueService.saveClues(toInsert, Default.IMPORT_IG);
+        }
         RiskTask updateTask = new RiskTask();
         updateTask.setId(task.getId());
         updateTask.setInsertSize(toInsert.size());
@@ -295,7 +298,7 @@ public class PointServiceImpl implements PointService {
         }
         if (!toInsert.isEmpty()) {
             log.info("增加特定对象日常管控不到位人员:{}", toInsert.size());
-            modelTaskClueService.saveClues(toInsert, Default.NO_CONTROLLER);
+            modelTaskClueService.saveClues(toInsert, Default.CONTROLLER_IG);
         }
         RiskTask updateTask = new RiskTask();
         updateTask.setId(task.getId());
@@ -321,6 +324,8 @@ public class PointServiceImpl implements PointService {
 
 
         List<RiskModelTaskClue> toInsert = new ArrayList<>();
+
+        Map<String, RiskModelTaskClue> oldMap = domain.getOldMap(task.getModelId(), true);
         Map<String, List<RiskPersonal>> aMAP = person.stream().collect(Collectors.groupingBy(RiskPersonal::getIdCode));
         RedisDao.getInstance().removeListAll(Default.CALL_REDIS);
         List<RiskTest> tmp = new ArrayList<>();
@@ -329,6 +334,9 @@ public class PointServiceImpl implements PointService {
                 continue;
             }
             RiskPersonal personal = entry.getValue().getFirst();
+            if(oldMap.get(personal.getIdCode()) != null) {
+                continue;
+            }
             String[] str = personal.getMobileNumber().split(",");
             int num = 0;
             int noUsefulNum = 0;
@@ -388,13 +396,14 @@ public class PointServiceImpl implements PointService {
                     .build();
             toInsert.add(createClue(task.getModelId(), 4, task.getId(), data));
         }
+        riskTestRepository.getBaseMapper().truncateTable();
         if (!tmp.isEmpty()) {
             riskTestRepository.saveBatch(tmp);
         }
 
         if (!toInsert.isEmpty()) {
             log.info("增加特定对象日常管控不到位人员:{}", toInsert.size());
-            modelTaskClueService.saveClues(toInsert, Default.MUCH_CALL);
+            modelTaskClueService.saveClues(toInsert, Default.CONTROLLER_IG);
         }
 
         RiskTask updateTask = new RiskTask();