From e76fb4c86bc5ee11a2f90da7f057824bfceb4604 Mon Sep 17 00:00:00 2001
From: kami <605128600@qq.com>
Date: Tue, 26 Nov 2024 16:42:50 +0800
Subject: [PATCH] =?UTF-8?q?1=E7=82=B9=E5=8D=8A=E6=89=A7=E8=A1=8C=E6=89=93?=
 =?UTF-8?q?=E7=94=B5=E8=AF=9D=E6=AC=A1=E6=95=B0=E7=9A=84=E6=A8=A1=E5=9E=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../supervisiondata/task/TaskService.java     | 35 ++++++++++++++++++-
 1 file changed, 34 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/biutag/supervisiondata/task/TaskService.java b/src/main/java/com/biutag/supervisiondata/task/TaskService.java
index 189c20d..c97695d 100644
--- a/src/main/java/com/biutag/supervisiondata/task/TaskService.java
+++ b/src/main/java/com/biutag/supervisiondata/task/TaskService.java
@@ -1,9 +1,21 @@
 package com.biutag.supervisiondata.task;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.biutag.supervisiondata.pojo.domain.TaskParamDomain;
+import com.biutag.supervisiondata.pojo.entity.mine.RiskModelTaskClue;
+import com.biutag.supervisiondata.pojo.entity.mine.RiskPersonal;
+import com.biutag.supervisiondata.repository.RiskModelTaskClueRepository;
+import com.biutag.supervisiondata.repository.RiskPersonalRepository;
+import com.biutag.supervisiondata.service.PointService;
+import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
 
 /**
  * @author kami on 2024-07-25 10:52:39
@@ -14,9 +26,30 @@ import org.springframework.stereotype.Component;
 @Slf4j
 public class TaskService {
 
+    @Resource
+    private PointService pointService;
+
+    @Resource
+    private RiskPersonalRepository riskPersonalRepository;
+
+    @Resource
+    private RiskModelTaskClueRepository riskModelTaskClueRepository;
 
-    @Scheduled(cron = "0 0/10 * * * ?")
+    /**
+     * 1点半执行
+     */
+    @Scheduled(cron = "0 30 01 * * ?")
     public void ageModel() {
+        pointService.syncPointCall(initDomain());
+    }
+
+    TaskParamDomain initDomain() {
+        List<RiskPersonal> persons = riskPersonalRepository.list();
+        List<RiskModelTaskClue> clues = riskModelTaskClueRepository.list(new LambdaQueryWrapper<RiskModelTaskClue>()
+                .eq(RiskModelTaskClue::getDel, 0));
+        Map<Integer, List<RiskModelTaskClue>> map = clues.stream().collect(Collectors.groupingBy(RiskModelTaskClue::getModelId));
+        TaskParamDomain domain = new TaskParamDomain(persons, map);
+        return domain;
     }
 
 }