添加redis缓存

common-client/src/main/java/com/zq/common/config/redis/BaseCacheKeys.java

+package com.zq.common.config.redis;
+
+/**
+ * @author wilmiam
+ * @since 2021-08-09 09:39
+ */
+public abstract class BaseCacheKeys {
+
+    /**
+     * 1440分钟 = 1天
+     * token有效时间（分）
+     */
+    public static final long APP_TOKEN_EXPIRE_MINUTES = 10080;
+    /**
+     * 续期检查时间范围（毫秒）
+     */
+    public static final long APP_TOKEN_DETECT = 172800000;
+    /**
+     * 续期时间（毫秒）
+     */
+    public static final long APP_TOKEN_RENEW = 604800000;
+
+    public static final String PREFIX = "civil.";
+
+    private static final String APP_TOKEN = PREFIX + "app-token.";
+
+    private static final String ADMIN_TOKEN = PREFIX + "admin-token.";
+
+    private static final String LIVE_ADMIN_TOKEN = PREFIX + "live-admin-token.";
+
+    private static final String LIVE_APP_TOKEN = PREFIX + "live-app-token.";
+
+    /**
+     * 构建app端用户token的缓存key
+     *
+     * @param token app登陆后的token
+     * @return
+     */
+    public static String appTokenKey(String token) {
+        return APP_TOKEN + token;
+    }
+
+    /**
+     * 用户当前apptoken的缓存key
+     *
+     * @param userId
+     * @return
+     */
+    public static String liveAppTokenKey(String userId) {
+        return LIVE_APP_TOKEN + userId;
+    }
+}

data-collect-server/src/main/java/com/zq/datacollect/controller/BigScreenController.java

@@ -61,7 +61,7 @@ public class BigScreenController {
     }
     }
 
 
     @ApiOperation("获取单个模型数据统计")
     @ApiOperation("获取单个模型数据统计")
-    @GetMapping(value = "/getModelDetails")
+    @PostMapping(value = "/getModelDetails")
     public ResultVo getModelDetails(@RequestParam("modelName") String modelName) {
     public ResultVo getModelDetails(@RequestParam("modelName") String modelName) {
         return ResultVo.success(bigScreenService.getModelDetails(modelName));
         return ResultVo.success(bigScreenService.getModelDetails(modelName));
     }
     }

dataoperation-server/src/main/java/com/zq/dataoperation/DataoperationApplication.java

@@ -12,8 +12,8 @@ import springfox.documentation.swagger2.annotations.EnableSwagger2;
 @EnableScheduling
 @EnableScheduling
 @EnableDiscoveryClient
 @EnableDiscoveryClient
 @EnableFeignClients(basePackages = "com.zq.dataoperation.feign")
 @EnableFeignClients(basePackages = "com.zq.dataoperation.feign")
-@MapperScan({"com.zq.dataoperation.dao","com.zq.spiderflow.dao","com.zq.datacollect.mapper"})
-@SpringBootApplication//(scanBasePackages = {"com.zq.dataoperation", "com.zq.common.config","com.zq.spiderflow"})
+@MapperScan({"com.zq.dataoperation.dao","com.zq.spiderflow.dao","com.zq.datacollect.mapper","com.zq.common.config"})
+@SpringBootApplication(scanBasePackages = {"com.zq.dataoperation", "com.zq.common.config.redis"})
 public class DataoperationApplication {
 public class DataoperationApplication {
 
 
     public static void main(String[] args) {
     public static void main(String[] args) {

dataoperation-server/src/main/java/com/zq/dataoperation/constant/CacheKeys.java

+package com.zq.dataoperation.constant;
+
+
+import com.zq.common.config.redis.BaseCacheKeys;
+
+/**
+ * @author wilmiam
+ * @since 2022/12/6 9:07
+ */
+public class CacheKeys extends BaseCacheKeys {
+
+    public static String queryResultKey(String parasm) {
+        return PREFIX + "query-result:" + parasm;
+    }
+
+    public static String queryExecuteKey(String uuid) {
+        return PREFIX + "query-execute:" + uuid;
+    }
+
+}

dataoperation-server/src/main/java/com/zq/dataoperation/service/CommonQueryService.java

@@ -4,11 +4,13 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
 import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zq.common.config.redis.RedisUtils;
 import com.zq.common.context.ThreadContext;
 import com.zq.common.context.ThreadContext;
 import com.zq.common.exception.BusinessException;
 import com.zq.common.exception.BusinessException;
 import com.zq.common.utils.AssertUtils;;
 import com.zq.common.utils.AssertUtils;;
 import com.zq.common.vo.PageVo;
 import com.zq.common.vo.PageVo;
 import com.zq.common.vo.ResultVo;
 import com.zq.common.vo.ResultVo;
+import com.zq.dataoperation.constant.CacheKeys;
 import com.zq.dataoperation.dao.CommonQuerySettingDao;
 import com.zq.dataoperation.dao.CommonQuerySettingDao;
 import com.zq.dataoperation.dao.MetaDataMappingDao;
 import com.zq.dataoperation.dao.MetaDataMappingDao;
 import com.zq.dataoperation.dao.QueryDbDao;
 import com.zq.dataoperation.dao.QueryDbDao;
@@ -46,6 +48,9 @@ public class CommonQueryService extends ServiceImpl<CommonQuerySettingDao, Commo
     @Resource
     @Resource
     private DataCollectFeign dataCollectFeign;
     private DataCollectFeign dataCollectFeign;
 
 
+    @Resource
+    private RedisUtils redisUtils;
+
     private static final Logger log = LoggerFactory.getLogger(ThreadContext.class);
     private static final Logger log = LoggerFactory.getLogger(ThreadContext.class);
 
 
     public List<QueryDb> getDatasource() {
     public List<QueryDb> getDatasource() {
@@ -200,6 +205,11 @@ public class CommonQueryService extends ServiceImpl<CommonQuerySettingDao, Commo
             log.warn("抱歉！不支持此查询");
             log.warn("抱歉！不支持此查询");
         }
         }
         AssertUtils.notNull(mapList,"抱歉！无查询结果");
         AssertUtils.notNull(mapList,"抱歉！无查询结果");
+        String key = CacheKeys.queryResultKey(queryId.toString());
+        Object obj = redisUtils.getObj(key);
+        if (obj != null) {
+            return (List<Map<String, Object>>) obj;
+        }
         return mapList;
         return mapList;
     }
     }