From 74b0e14b13bddcad1016c1fa09acad7036af2ba3 Mon Sep 17 00:00:00 2001 From: "lisai17@sina.com" Date: Fri, 24 Sep 2021 14:27:27 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E9=A6=96=E9=A1=B5=E7=BC=93?= =?UTF-8?q?=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/ssjygl/jobs/LoadStatCacheJob.java | 43 +++++++++++++++++++ .../com/cowr/service/ssjygl/main/Config.java | 3 ++ .../ssjygl/overall/OverallCacheService.java | 1 + .../ssjygl/overall/OverallController.java | 11 ++--- .../src/main/resources/job.properties | 7 ++- 5 files changed, 57 insertions(+), 8 deletions(-) create mode 100644 ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/jobs/LoadStatCacheJob.java diff --git a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/jobs/LoadStatCacheJob.java b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/jobs/LoadStatCacheJob.java new file mode 100644 index 0000000..cbdbc1c --- /dev/null +++ b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/jobs/LoadStatCacheJob.java @@ -0,0 +1,43 @@ +package com.cowr.service.ssjygl.jobs; + +import com.cowr.service.ssjygl.overall.OverallCacheService; +import com.cowr.ssjygl.overall.OverallService; +import com.jfinal.log.Log; +import com.jfinal.plugin.activerecord.Record; +import com.jfinal.plugin.redis.Redis; +import org.quartz.Job; +import org.quartz.JobExecutionContext; +import org.quartz.JobExecutionException; + +import java.util.List; + +public class LoadStatCacheJob implements Job { + private static Log log = Log.getLog(LoadStatCacheJob.class); + + public void load() { + try { + String statkey = OverallCacheService.me.overallmapkey("stat"); + Record statcachedata = Redis.use().get(statkey); + if (statcachedata == null) { + statcachedata = OverallCacheService.me.stat(null); + + Redis.use().setex(statkey, OverallCacheService.statExpireAt, statcachedata); + } + + String lastOrderkey = OverallCacheService.me.overallmapkey("lastOrder"); + List lastOrdercachedata = Redis.use().get(lastOrderkey); + if (lastOrdercachedata == null) { + lastOrdercachedata = OverallService.me.lastOrder(null); + + Redis.use().setex(lastOrderkey, OverallCacheService.statExpireAt, lastOrdercachedata); + } + } catch (Exception e) { + log.error(e.getMessage(), e); + } + } + + @Override + public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { + load(); + } +} diff --git a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/main/Config.java b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/main/Config.java index f3b79dc..5703146 100644 --- a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/main/Config.java +++ b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/main/Config.java @@ -22,6 +22,7 @@ import com.cowr.service.ssjygl.driver.DriverController; import com.cowr.service.ssjygl.invoice.invalidverify.InvoiceInvalidVerifyController; import com.cowr.service.ssjygl.invoice.log.InvoiceLogController; import com.cowr.service.ssjygl.invoice.receive.InvoiceReceiveController; +import com.cowr.service.ssjygl.jobs.LoadStatCacheJob; import com.cowr.service.ssjygl.netty.NettyServer; import com.cowr.service.ssjygl.order.invalidverify.OrderInvalidVerifyController; import com.cowr.service.ssjygl.order.ordercluster.OrderclusterController; @@ -318,6 +319,8 @@ public class Config extends JFinalConfig { } SyncTaskService.me.start(); + + new LoadStatCacheJob().load(); } catch (Exception e) { log.error(e.getMessage(), e); } diff --git a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/overall/OverallCacheService.java b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/overall/OverallCacheService.java index 11ceb6e..7dfba07 100644 --- a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/overall/OverallCacheService.java +++ b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/overall/OverallCacheService.java @@ -4,6 +4,7 @@ import com.cowr.common.Const; import com.cowr.service.ssjygl.main.Config; public class OverallCacheService extends com.cowr.ssjygl.overall.OverallService { + public static final int statExpireAt = 1800; // 超时时间，单位秒 public static OverallCacheService me = new OverallCacheService(); public static final String tablename = "overall"; diff --git a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/overall/OverallController.java b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/overall/OverallController.java index 6fff83b..50edc92 100644 --- a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/overall/OverallController.java +++ b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/overall/OverallController.java @@ -10,7 +10,6 @@ import com.jfinal.plugin.redis.Redis; import java.util.List; public class OverallController extends Controller { - private static final int statExpireAt = 600; // 超时时间，单位秒 public void stat() { String key = OverallCacheService.me.overallmapkey("stat"); @@ -18,7 +17,7 @@ public class OverallController extends Controller { if (cachedata == null) { cachedata = OverallCacheService.me.stat(null); - Redis.use().setex(key, statExpireAt, cachedata); + Redis.use().setex(key, OverallCacheService.statExpireAt, cachedata); } renderJson(Result.success(cachedata)); @@ -45,14 +44,12 @@ public class OverallController extends Controller { } public void lastOrder() { - Integer supermarket_id = getInt("supermarket_id"); - - String key = OverallCacheService.me.overallmapkey("lastOrder_" + supermarket_id); + String key = OverallCacheService.me.overallmapkey("lastOrder"); List cachedata = Redis.use().get(key); if (cachedata == null) { - cachedata = OverallService.me.lastOrder(supermarket_id); + cachedata = OverallService.me.lastOrder(null); - Redis.use().setex(key, statExpireAt, cachedata); + Redis.use().setex(key, OverallCacheService.statExpireAt, cachedata); } renderJson(Result.success(cachedata)); diff --git a/ssjygl-xsx-service/src/main/resources/job.properties b/ssjygl-xsx-service/src/main/resources/job.properties index d6ef128..2eb094f 100644 --- a/ssjygl-xsx-service/src/main/resources/job.properties +++ b/ssjygl-xsx-service/src/main/resources/job.properties @@ -27,4 +27,9 @@ statsms.enable=true # 检查异常数据 checkexceptiondata.job=com.cowr.service.ssjygl.jobs.CheckExceptionDataJob checkexceptiondata.cron= 0 3 * * * ? -checkexceptiondata.enable=true \ No newline at end of file +checkexceptiondata.enable=true + +# 加载首页缓存数据 +loadstat.job=com.cowr.service.ssjygl.jobs.LoadStatCacheJob +loadstat.cron= 0 */30 * * * ? +loadstat.enable=true \ No newline at end of file