diff --git a/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/abs/CacheAbs.java b/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/abs/CacheAbs.java index 1e8cd12..7286440 100644 --- a/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/abs/CacheAbs.java +++ b/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/abs/CacheAbs.java @@ -26,11 +26,11 @@ public abstract class CacheAbs> implements Cache { // this.redisService = redisService; // } - @Autowired - public CacheAbs(RedisService redisService) { -// if (redisService==null) redisService = new RedisService(); - this.redisService = redisService; - } +// @Autowired +// public CacheAbs(RedisService redisService) { +//// if (redisService==null) redisService = new RedisService(); +// this.redisService = redisService; +// } /** * 根据key获取值 diff --git a/muyu-modules/muyu-etl/muyu-etl-cache/src/main/java/com/muyu/cache/AssetCache.java b/muyu-modules/muyu-etl/muyu-etl-cache/src/main/java/com/muyu/cache/AssetCache.java index 77670a1..27e3c57 100644 --- a/muyu-modules/muyu-etl/muyu-etl-cache/src/main/java/com/muyu/cache/AssetCache.java +++ b/muyu-modules/muyu-etl/muyu-etl-cache/src/main/java/com/muyu/cache/AssetCache.java @@ -17,9 +17,9 @@ import java.util.List; public class AssetCache extends CacheAbs> { - public AssetCache(RedisService redisService) { - super(redisService); - } +// public AssetCache(RedisService redisService) { +// super(redisService); +// } @Override public String preKey() { diff --git a/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/EtlApplicationRunner.java b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/EtlApplicationRunner.java index d1dba41..6472b05 100644 --- a/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/EtlApplicationRunner.java +++ b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/EtlApplicationRunner.java @@ -25,11 +25,14 @@ public class EtlApplicationRunner implements ApplicationRunner { @Autowired private BasicConfigInfoService basicConfigInfoService; +// @Autowired +// private RedisService redisService; + + @Autowired - private RedisService redisService; + private AssetCache assetCache ; - AssetCache assetCache = new AssetCache(redisService); @Override public void run(ApplicationArguments args) throws Exception { List basicConfigInfos = basicConfigInfoService.selectBasicConfigInfoList(new BasicConfigInfo() {{ @@ -40,11 +43,11 @@ public class EtlApplicationRunner implements ApplicationRunner { @Scheduled(zone = "0 0/10 * * * ? *") public void delay(){ - if (!redisService.hasKey(assetCache.preKey()+"basic")) try { - throw new ServletException("过期了"); - } catch (ServletException e) { - throw new RuntimeException(e); - } - redisService.expire(assetCache.preKey()+"basic",10, TimeUnit.MINUTES); +// if (!redisService.hasKey(assetCache.preKey()+"basic")) try { +// throw new ServletException("过期了"); +// } catch (ServletException e) { +// throw new RuntimeException(e); +// } +// redisService.expire(assetCache.preKey()+"basic",10, TimeUnit.MINUTES); } }