Forráskód Böngészése

rename cache keys.

deason 2 éve
szülő
commit
754d3fc7f4

+ 4 - 3
examcloud-core-oe-student-api-provider/src/main/java/cn/com/qmth/examcloud/core/oe/student/api/controller/ExamCaptureController.java

@@ -3,6 +3,7 @@ package cn.com.qmth.examcloud.core.oe.student.api.controller;
 import cn.com.qmth.examcloud.api.commons.security.bean.User;
 import cn.com.qmth.examcloud.commons.exception.StatusException;
 import cn.com.qmth.examcloud.commons.util.UrlUtil;
+import cn.com.qmth.examcloud.core.oe.student.base.OeConstants;
 import cn.com.qmth.examcloud.core.oe.student.base.bean.CompareFaceSyncInfo;
 import cn.com.qmth.examcloud.core.oe.student.bean.task.GetExamCaptureResultDomain;
 import cn.com.qmth.examcloud.core.oe.student.bean.task.SaveExamCaptureQueueInfo;
@@ -104,12 +105,12 @@ public class ExamCaptureController extends ControllerSupport {
         compareFaceSyncInfo.setFileUrl(fileUrl);
         compareFaceSyncInfo.setProcessTime(System.currentTimeMillis() - startTime);
 
-        redisClient.set(CacheConstants.CACHE_OE_SYNC_FACE_COMPARE_RESULT + user.getUserId(), compareFaceSyncInfo, 5 * 60);
+        redisClient.set(CacheConstants.CACHE_OE_SYNC_FACE_COMPARE_RESULT + user.getUserId(), compareFaceSyncInfo, OeConstants.TIME_OUT_5_MINUTE);
         return compareFaceSyncInfo;
     }
 
     private boolean isFaceApiLimitSeconds(String userKey) {
-        String cacheKey = "$FACE_API_LIMIT:S_" + userKey;
+        String cacheKey = CacheConstants.CACHE_OE_FACE_API_LIMIT_SECOND + userKey;
         Long count = redisTemplate.opsForValue().increment(cacheKey);
 
         // 限制请求:1次/2秒
@@ -122,7 +123,7 @@ public class ExamCaptureController extends ControllerSupport {
     }
 
     private boolean isFaceApiLimitMinutes(String userKey) {
-        String cacheKey = "$FACE_API_LIMIT:M_" + userKey;
+        String cacheKey = CacheConstants.CACHE_OE_FACE_API_LIMIT_MINUTE + userKey;
         Long count = redisTemplate.opsForValue().increment(cacheKey);
 
         // 限制请求:50次/10分钟

+ 13 - 0
examcloud-core-oe-student-base/src/main/java/cn/com/qmth/examcloud/core/oe/student/base/OeConstants.java

@@ -0,0 +1,13 @@
+package cn.com.qmth.examcloud.core.oe.student.base;
+
+public interface OeConstants {
+
+
+    int TIME_OUT_5_MINUTE = 60 * 5;
+
+    int TIME_OUT_1_DAY = 60 * 60 * 24;
+
+    int TIME_OUT_7_DAY = 60 * 60 * 24 * 7;
+
+
+}

+ 4 - 5
examcloud-core-oe-student-service/src/main/java/cn/com/qmth/examcloud/core/oe/student/service/impl/TempConfigServiceImpl.java

@@ -1,6 +1,7 @@
 package cn.com.qmth.examcloud.core.oe.student.service.impl;
 
 import cn.com.qmth.examcloud.core.oe.student.service.TempConfigService;
+import cn.com.qmth.examcloud.support.CacheConstants;
 import cn.com.qmth.examcloud.web.redis.RedisClient;
 import com.google.common.collect.Lists;
 import org.apache.commons.collections4.CollectionUtils;
@@ -16,8 +17,6 @@ public class TempConfigServiceImpl implements TempConfigService {
 
     private static final Logger log = LoggerFactory.getLogger(TempConfigServiceImpl.class);
 
-    private static final String DISABLED_ORG_ID_CACHE_KEY = "$DISABLED_ORG_ID";
-
     @Autowired
     private RedisClient redisClient;
 
@@ -26,7 +25,7 @@ public class TempConfigServiceImpl implements TempConfigService {
      */
     @Override
     public List<Long> getDisabledRootOrgIdsForOldApi() {
-        List<Long> rootOrgIds = redisClient.get(DISABLED_ORG_ID_CACHE_KEY, List.class);
+        List<Long> rootOrgIds = redisClient.get(CacheConstants.CACHE_OE_OLD_API_BLACK_LIST, List.class);
         if (rootOrgIds == null) {
             return Lists.newArrayList();
         }
@@ -40,10 +39,10 @@ public class TempConfigServiceImpl implements TempConfigService {
     @Override
     public void updateDisabledRootOrgIdsForOldApi(List<Long> rootOrgIds) {
         if (CollectionUtils.isEmpty(rootOrgIds)) {
-            redisClient.delete(DISABLED_ORG_ID_CACHE_KEY);
+            redisClient.delete(CacheConstants.CACHE_OE_OLD_API_BLACK_LIST);
             log.warn("updateDisabledRootOrgIdsForOldApi ids is empty");
         } else {
-            redisClient.set(DISABLED_ORG_ID_CACHE_KEY, rootOrgIds);
+            redisClient.set(CacheConstants.CACHE_OE_OLD_API_BLACK_LIST, rootOrgIds);
             log.warn("updateDisabledRootOrgIdsForOldApi ids={}", rootOrgIds);
         }
     }