定时任务

pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>cn.quantgroup</groupId>
         <artifactId>commons-parent</artifactId>
-        <version>0.2.5.4</version>
+        <version>0.2.6</version>
     </parent>
 
     <groupId>cn.quantgroup</groupId>
@@ -239,12 +239,17 @@
             <artifactId>idgenerator-spring-boot-starter</artifactId>
         </dependency>
 
-
         <dependency>
             <groupId>com.dangdang</groupId>
             <artifactId>elastic-job-lite-spring-shaded</artifactId>
             <version>2.1.5</version>
         </dependency>
+
+        <dependency>
+            <groupId>cn.quantgroup</groupId>
+            <artifactId>elastic-job-lite-spring-boot-starter</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>cn.quantgroup</groupId>
             <artifactId>enoch-agent-spring-boot-starter</artifactId>

src/main/java/com/service/statistics/impl/QueryStatisticsServiceImpl.java

@@ -3,25 +3,20 @@ package com.service.statistics.impl;
 import com.emums.Corporation;
 import com.emums.DataSource;
 import com.entity.jpa.QueryStatisticsEntry;
+import com.google.common.base.Splitter;
 import com.google.common.collect.Lists;
 import com.jpa.repository.QueryStatisticsRepository;
 import com.model.QueryStatisticsModel;
-import com.service.report.ReportService;
 import com.service.statistics.GetReportAndSearchNum;
 import com.service.statistics.QueryStatisticsService;
 import com.util.ApplicationContextHelper;
 import com.util.DateUtil;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.ApplicationContext;
-import org.springframework.data.domain.Example;
 import org.springframework.stereotype.Service;
-import shaded.com.google.common.base.Splitter;
+
 
 import javax.annotation.Resource;
 import java.sql.Timestamp;
-import java.time.LocalDate;
-import java.time.format.DateTimeFormatter;
-import java.util.Calendar;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;

src/main/java/com/timer/QueryStatisticsTimer.java

 package com.timer;
 
+import cn.quantgroup.tech.elastic.job.lite.annotation.ElasticSimpleJob;
+import com.dangdang.ddframe.job.api.ShardingContext;
+import com.dangdang.ddframe.job.api.simple.SimpleJob;
 import com.service.statistics.QueryStatisticsService;
-import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
@@ -13,20 +15,23 @@ import java.util.Calendar;
  * @description：统计定时器
  * @modified By：
  * @version: 1.0
+ *每天凌晨泡一下
  */
+
 @Component
-public class QueryStatisticsTimer {
+@ElasticSimpleJob(cron = "0  1  0  *  * ?", jobName = "QueryStatisticsTimer")
+public class QueryStatisticsTimer implements SimpleJob {
 
     @Resource
     private QueryStatisticsService queryStatisticsService;
 
-    @Scheduled(cron = "0  0  0  *  * ?")
-    public void run() {
+
+    @Override
+    public void execute(ShardingContext shardingContext) {
         Calendar calendar = Calendar.getInstance();
 
         calendar.add(Calendar.DATE, -1);
 
         queryStatisticsService.doStatisticsSave(calendar.getTime());
     }
-
 }