数据统计-数据初始化

lift-batch-service/src/main/java/cn/com/ty/lift/batch/applet/constants/DataStatisticsConstants.java

@@ -10,6 +10,11 @@ import java.util.Map;
  */
 public class DataStatisticsConstants {
 
+    /**
+     * 时间格式
+     */
+    public static final String DATA_STATISTICS_TIME_FORMAT = "yyyy-MM-dd HH:mm:ss";
+
     /**
      * 急修数据字段常量
      */

lift-batch-service/src/main/java/cn/com/ty/lift/batch/applet/util/DataStatisticsUtil.java

@@ -1,5 +1,6 @@
 package cn.com.ty.lift.batch.applet.util;
 
+import cn.com.ty.lift.batch.applet.constants.DataStatisticsConstants;
 import cn.com.ty.lift.batch.applet.dao.model.BaseDataModel;
 import cn.com.ty.lift.batch.applet.dao.model.request.CommonRequest;
 import com.google.common.collect.Maps;
@@ -8,6 +9,7 @@ import org.springframework.data.redis.core.RedisTemplate;
 import java.math.BigDecimal;
 import java.time.Duration;
 import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -149,7 +151,7 @@ public class DataStatisticsUtil {
     /**
      * 根据map的key排序
      *
-     * @param map 待排序的map
+     * @param map    待排序的map
      * @param isDesc 是否降序，true：降序，false：升序
      * @return 排序好的map
      */
@@ -168,7 +170,7 @@ public class DataStatisticsUtil {
     /**
      * 根据map的value排序
      *
-     * @param map 待排序的map
+     * @param map    待排序的map
      * @param isDesc 是否降序，true：降序，false：升序
      * @return 排序好的map
      */
@@ -184,4 +186,29 @@ public class DataStatisticsUtil {
         return result;
     }
 
+    /**
+     * @param yearInterval 年份间隔 正值:之后的年份 负值:之前的年份
+     * @return
+     * @description 初始化commonRequest请求对象
+     * @date 2020/2/10 12:07 下午
+     */
+    public static CommonRequest initCommonRequest(Long yearInterval) {
+        CommonRequest commonRequest = new CommonRequest();
+        LocalDateTime now = LocalDateTime.now();
+        //获取时间间隔前的时间
+        LocalDateTime beforeTime = now.plusYears(yearInterval);
+        //获取格式化后的时间字符串
+        //起始时间
+        commonRequest.setStartTimeDate(beforeTime);
+        commonRequest.setStartTimeStr(beforeTime.format(
+                DateTimeFormatter.ofPattern(DataStatisticsConstants.DATA_STATISTICS_TIME_FORMAT)
+        ));
+        //终止时间
+        commonRequest.setEndTimeDate(now);
+        commonRequest.setEndTimeStr(now.format(
+                DateTimeFormatter.ofPattern(DataStatisticsConstants.DATA_STATISTICS_TIME_FORMAT)
+        ));
+        return commonRequest;
+    }
+
 }

lift-batch-service/src/main/java/cn/com/ty/lift/batch/config/AppletDataSchedulingConfig.java

@@ -1,7 +1,11 @@
 package cn.com.ty.lift.batch.config;
 
+import cn.com.ty.lift.batch.applet.util.DataInitUtil;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+
+import javax.annotation.Resource;
 
 /**
  * @author huangyuan
@@ -11,4 +15,14 @@ import org.springframework.scheduling.annotation.EnableScheduling;
 @Configuration
 @EnableScheduling
 public class AppletDataSchedulingConfig {
+
+    @Resource
+    private DataInitUtil dataInitUtil;
+
+    //定时刷新redis中的数据，每天凌晨两点执行
+    @Scheduled(cron = "0 0 2 * * ?")
+    public void flushRedisCacheData(){
+        dataInitUtil.initAppletData();
+    }
+
 }