/*删除多余的redis键：ANALYSE_REQUEST_ID和REQUEST_UUID*/

inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/service/impl/AnalyseResponseServiceImpl.java

@@ -108,6 +108,9 @@ public class AnalyseResponseServiceImpl implements IAnalyseResponseService {
                 return;
             }
             //redisService.setCacheObject(keyId, "123456789");
+        } else {
+            log.info("ANALYSE_REQUEST_ID: DEL {} FROM REDIS!", keyId);
+            redisService.deleteObject(keyId);
         }
 
         String patrolTaskIdObj = redisService.getCacheObject(keyId);

inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/AnalyseRequestServiceImpl.java

@@ -56,7 +56,7 @@ public class AnalyseRequestServiceImpl implements IAnalyseRequestService {
         String requestId = StringUtils.isNotEmpty(analyseReq.getRequestId()) ?
                 analyseReq.getRequestId() : UUID.randomUUID().toString().trim().replaceAll(StringUtils.DASH, StringUtils.EMPTY);
         String taskPatrolId = analyseReq.getTaskPatrolId();
-        redisService.setCacheObject(RedisConst.REQUEST_UUID + requestId, taskPatrolId, requestTimeout, TimeUnit.DAYS);
+        // redisService.setCacheObject(RedisConst.REQUEST_UUID + requestId, taskPatrolId, requestTimeout, TimeUnit.DAYS);
         //log.info("CALL_REMOTE_ANALYZE isFilter: {}, requestId: {}, taskPatrolId: {}", isFilter, requestId, taskPatrolId);
 
         analyseReq.setRequestId(requestId);
@@ -88,6 +88,11 @@ public class AnalyseRequestServiceImpl implements IAnalyseRequestService {
             analyseReq.setObjectList(Collections.singletonList(analyseReqItem));
             if (checkOldInfraredType(typeList)) {
                 log.info("ANALYSIS_FILTER_URL_OLD_INFRARED requestId: {}, analyseReq: {}", requestId, analyseReq);
+                if (testMode) {
+                    delayQueueService.submitRequest(AnalyseConstants.ALGORITHM_REQUEST_DELAY_QUEUE, analyseReq.getRequestId(), (3L), TimeUnit.MINUTES);
+                } else {
+                    delayQueueService.submitRequest(AnalyseConstants.ALGORITHM_REQUEST_DELAY_QUEUE, analyseReq.getRequestId(), requestTimeout, TimeUnit.DAYS);
+                }
                 sendCompensateRequest(analyseReq);
                 return;
             }