定时任务处理一天以前的

fiveep-controller/src/main/java/com/bizmatics/controller/web/JobController.java

@@ -0,0 +1,26 @@
+package com.bizmatics.controller.web;
+
+import com.bizmatics.service.job.RatAnalogTask;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Date;
+
+/**
+ * @author yq
+ * @date 2021/8/25 15:37
+ */
+@RestController
+public class JobController {
+
+    @Autowired
+    public RatAnalogTask ratAnalogTask;
+
+    @RequestMapping("addHadJobByDate")
+    public void addHadJobByDate(@RequestParam(required = false) Date startTime,
+                                @RequestParam(required = false) Date endTime){
+        ratAnalogTask.addHadJobByDate(startTime,endTime);
+    }
+}

fiveep-service/src/main/java/com/bizmatics/service/job/RatAnalogTask.java

@@ -6,7 +6,6 @@ import com.bizmatics.model.HadSiteStatic;
 import com.bizmatics.model.HtAnalogData;
 import com.bizmatics.persistence.mapper.HadSiteStaticMapper;
 import com.bizmatics.persistence.mapper.HtAnalogDataMapper;
-import com.bizmatics.service.SiteService;
 import com.bizmatics.service.util.Arith;
 import com.bizmatics.service.vo.CommonIcoVO;
 import com.bizmatics.service.vo.TimeShareVO;
@@ -28,8 +27,6 @@ public class RatAnalogTask {
 
     @Autowired
     private HtAnalogDataMapper htAnalogDataMapper;
-    @Autowired
-    private SiteService siteService;
 
     @Autowired
     private HadSiteStaticMapper hadSiteStaticMapper;
@@ -43,13 +40,17 @@ public class RatAnalogTask {
     @Scheduled(cron = "0 0 0 */1 * ?")
     public void addHadJob(){
         Date newDate = new Date();
+        newDate = DateUtils.addDays(newDate,-1);
         Date dayStartTime = DateUtils.getDayStartTime(newDate);
         Date dayEndTime = DateUtils.getDayEndTime(newDate);
+        log.info("addHadJob---startTime"+DateUtils.format(dayStartTime));
+        log.info("addHadJob---endTime"+DateUtils.format(dayEndTime));
         addHadJobByDate(dayStartTime,dayEndTime);
     }
 
     public void addHadJobByDate(Date startTime,Date endTime){
         List<Map<String, Object>> dateList = htAnalogDataMapper.getDateList(startTime,endTime);
+        log.info("addHadJob---总记录"+DateUtils.format(dateList.size()));
         for (Map<String,Object> map:dateList) {
             long currentTimeMillis = System.currentTimeMillis();
             int siteId = Integer.parseInt(map.get("siteId").toString());
@@ -59,9 +60,9 @@ public class RatAnalogTask {
             addTime(date,siteId,hadSiteStatic);
             hadSiteStaticMapper.insert(hadSiteStatic);
             long currentTimeMillis1 = System.currentTimeMillis();
-            log.info("处理一条数据需要的时间"+(currentTimeMillis1-currentTimeMillis));
+            log.info("addHadJob---处理一条数据需要的时间"+(currentTimeMillis1-currentTimeMillis));
         }
-        log.info("定时任务处理完成");
+        log.info("addHadJob---定时任务处理完成");
     }
 
     /**