重点人员打电话只做增量

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