From a3adf3d016eda9757b0c5899e961364efce9b65f Mon Sep 17 00:00:00 2001 From: htjcAdmin Date: Fri, 5 Sep 2025 13:24:29 +0800 Subject: [PATCH] =?UTF-8?q?/*=E5=88=A0=E9=99=A4=E5=A4=9A=E4=BD=99=E7=9A=84?= =?UTF-8?q?redis=E9=94=AE=EF=BC=9AANALYSE=5FREQUEST=5FID=E5=92=8CREQUEST?= =?UTF-8?q?=5FUUID*/?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../analysis/service/impl/AnalyseResponseServiceImpl.java | 3 +++ .../partrolresult/service/AnalyseRequestServiceImpl.java | 7 ++++++- 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/service/impl/AnalyseResponseServiceImpl.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/service/impl/AnalyseResponseServiceImpl.java index 6c04d24..b3c41da 100644 --- a/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/service/impl/AnalyseResponseServiceImpl.java +++ b/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); diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/AnalyseRequestServiceImpl.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/AnalyseRequestServiceImpl.java index 7765c8a..067c7e7 100644 --- a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/AnalyseRequestServiceImpl.java +++ b/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; }