redis key任务执行中状态60秒自动清除

inspect-job/src/main/java/com/inspect/job/task/JobMainTask.java

@@ -1408,7 +1408,7 @@ public class JobMainTask {
         String immediatelyExecTaskTime = DateUtils.parseDateToStr(DateUtils.yyyyMMddHHmmss, new Date());
         redisService.setCacheObject(RedisConst.IMMEDIATELY_EXEC_TASK_TIME, immediatelyExecTaskTime, 60L, TimeUnit.SECONDS);
         log.info(Color.CYAN + "[JOB IMMEDIATE] TASK_CURRENT_CODE: {}, value: {}" + Color.END, RedisConst.TASK_CURRENT_CODE, RedisConst.TASK_CODE + patrolTask.getTaskCode() + StringUtils.AT + immediatelyExecTaskTime);
-        redisService.setCacheObject(RedisConst.TASK_CURRENT_CODE, RedisConst.TASK_CODE + patrolTask.getTaskCode() + StringUtils.AT + immediatelyExecTaskTime);
+        redisService.setCacheObject(RedisConst.TASK_CURRENT_CODE, RedisConst.TASK_CODE + patrolTask.getTaskCode() + StringUtils.AT + immediatelyExecTaskTime, 60L, TimeUnit.SECONDS);
         taskStartInitialize();
         log.info(Color.CYAN + "[JOB IMMEDIATE] TASK REC CNT: {}" + Color.END, cameraPatrolTasks.size());
         setRedisRecordCount(cameraPatrolTasks.size());
@@ -1931,7 +1931,7 @@ public class JobMainTask {
             List<PatrolTask> patrolTaskList = JSON.parseArray(redisService.getCacheObject(redisKey), PatrolTask.class);
             if (patrolTaskList != null && !patrolTaskList.isEmpty()) {
                 log.info(Color.GREEN + "[JOB] ADD NEW TASK [{}], TASK LIST SIZE: {}" + Color.END, redisKey, patrolTaskList.size());
-                redisService.setCacheObject(RedisConst.TASK_CURRENT_CODE, redisKey);
+                redisService.setCacheObject(RedisConst.TASK_CURRENT_CODE, redisKey, 60L, TimeUnit.SECONDS);
                 taskStartInitialize();
                 execEveryDayTask(patrolTaskList);
             }

inspect-main/inspect-main-task-exec/src/main/java/com/inspect/exec/controller/PatrolTaskExecController.java

@@ -867,7 +867,7 @@ public class PatrolTaskExecController extends BaseController {
 
     private void extracted(String key, String taskCode) {
         log.info(Color.RED + "[EXEC] Add new task [{}]" + Color.END, key);
-        redisService.setCacheObject(RedisConst.TASK_CURRENT_CODE, key);
+        redisService.setCacheObject(RedisConst.TASK_CURRENT_CODE, key, 60L, TimeUnit.SECONDS);
         log.info("[EXEC] key: {}", key);
         List<PatrolTask> cameraPatrolTasks = redisService.getCacheObject(key);
         if (!cameraPatrolTasks.isEmpty()) {