update...

潘钊
1 parent 46ef4f6e
Showing 1 changed file with 30 additions and 1 deletions
src/main/java/com/bsth/redis/OilRedisService.java
 package com.bsth.redis;
  
+import com.bsth.Application;
 import com.bsth.entity.OilInfo;
 import com.bsth.redis.util.RedisUtils;
 import com.bsth.repository.OilInfoRepository;
@@ -15,9 +16,11 @@ import org.springframework.core.annotation.Order;
 import org.springframework.data.redis.core.ListOperations;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.serializer.StringRedisSerializer;
+import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;
  
 import java.util.*;
+import java.util.concurrent.TimeUnit;
  
 /**
  * 油量数据Redis缓存
@@ -36,7 +39,7 @@ public class OilRedisService implements CommandLineRunner {
     @Autowired
     RedisUtils redisUtils;
  
-    Logger logger = LoggerFactory.getLogger(this.getClass());
+    static Logger logger = LoggerFactory.getLogger(OilRedisService.class);
  
     private final static String REDIS_KEY_PREFIX = "oil:";
  
@@ -116,8 +119,19 @@ public class OilRedisService implements CommandLineRunner {
         redisTemplate.execute(redisUtils.getUpdateCallback(key, list));
     }
  
+    @Autowired
+    OilRefreshThread oilRefreshThread;
+
     @Override
     public void run(String... strings) throws Exception {
+        //定时刷新油耗信息
+        Application.mainServices.scheduleWithFixedDelay(oilRefreshThread, 20, 60 * 30, TimeUnit.SECONDS);
+    }
+
+    /**
+     * 和数据库同步数据
+     */
+    public void synchData(){
         int cacheDays = Integer.parseInt(ConfigUtil.get("cache.days"));
         //设置key 序列化器
         redisTemplate.setKeySerializer(new StringRedisSerializer());
@@ -128,4 +142,19 @@ public class OilRedisService implements CommandLineRunner {
         //写入redis
         wirte(list);
     }
+
+    @Component
+    public static class OilRefreshThread extends Thread {
+
+        @Autowired
+        OilRedisService oilRedisService;
+        @Override
+        public void run() {
+            try {
+                oilRedisService.synchData();
+            } catch (Exception e) {
+                logger.error("", e);
+            }
+        }
+    }
 }