From 5ac0de509c1b7a72fce74cdc3355094c964e7737 Mon Sep 17 00:00:00 2001 From: yinhuaiwei Date: Fri, 4 Sep 2026 17:19:13 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E5=9B=A0=E8=AE=A1?= =?UTF-8?q?=E5=88=92=E4=BB=BB=E5=8A=A1=E8=BF=87=E5=A4=9A=E5=88=A4=E6=96=AD?= =?UTF-8?q?=EF=BC=8C=E5=AF=BC=E8=87=B4=E4=BB=BB=E5=8A=A1=E9=94=99=E8=BF=87?= =?UTF-8?q?=E4=B8=8B=E5=8F=91=E6=97=B6=E9=97=B4=E6=9C=AA=E6=89=A7=E8=A1=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/inspect/job/task/JobMainTask.java | 28 +++++++++---------- 1 file changed, 14 insertions(+), 14 deletions(-) diff --git a/inspect-job/src/main/java/com/inspect/job/task/JobMainTask.java b/inspect-job/src/main/java/com/inspect/job/task/JobMainTask.java index 16cc616..30d3198 100644 --- a/inspect-job/src/main/java/com/inspect/job/task/JobMainTask.java +++ b/inspect-job/src/main/java/com/inspect/job/task/JobMainTask.java @@ -35,6 +35,7 @@ import java.net.URLConnection; import java.net.URLEncoder; import java.text.DecimalFormat; import java.text.SimpleDateFormat; +import java.time.LocalDate; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.*; @@ -1173,16 +1174,11 @@ public class JobMainTask { .isEnable("1") .build(); List presetPosList = taskExecClient.selectPatrolPresetPosList(patrolPresetPos); - PatrolPresetPos presetPos = !presetPosList.isEmpty() ? presetPosList.get(0) : - PatrolPresetPos.builder().presetPosId("1") - .presetPosCode("1") - .channelCode("ffffffffffffffffff#ffffffffffffffffffffffffffffffff") - .channelId("999999") - .patrolPointId(1234567890L) - .channelType("vl") - .isEnable("1") - .eqpBookId("1") - .build(); + if (presetPosList.isEmpty()) { + log.info("getInfosByRecord: {} PatrolPresetPos no found", patrolTaskInfo.getDeviceId()); + continue; + } + PatrolPresetPos presetPos = presetPosList.get(0); String deviceCode = "ffffffffffffffffff"; try { String[] channelCodeList = presetPos.getChannelCode().split(StringUtils.HASHTAG); @@ -2039,12 +2035,14 @@ public class JobMainTask { List patrolTaskControlList = new ArrayList<>(); for (PatrolTask patrolTask : patrolTaskList) { log.debug("EXTRACT_REDIS_TASK devType: {}", patrolTask.getDevType()); - if(StringUtils.isNotEmpty(patrolTask.getDevType()) + // 添加可见光任务 + if (StringUtils.isNotEmpty(patrolTask.getDevType()) && patrolTask.getDevType().contains("2")) { patrolTaskListEx.add(patrolTask); } - if(StringUtils.isNotEmpty(patrolTask.getDevType()) + // 添加无人机/机器狗任务 + if (StringUtils.isNotEmpty(patrolTask.getDevType()) && (patrolTask.getDevType().contains("0") || patrolTask.getDevType().contains("1"))) { patrolTaskControlList.add(patrolTask); } @@ -2093,8 +2091,10 @@ public class JobMainTask { @SuppressWarnings({"unused"}) public void execEveryDayTask() { log.debug("***************************** JobTaskTimer execEveryDayTask *************************************"); - - Collection redisKeys = redisService.keys(RedisConst.TASK_CODE_EX); + String today = LocalDate.now().toString(); + String key = RedisConst.TASK_CODE_EX + today + "*"; + Collection redisKeys = redisService.keys(key); + log.info("TodayTask key:{}, size:{}", key, redisKeys.size()); for (String redisKey : redisKeys) { try { //redisKey = RedisConst.TASK_CODE + task.getTaskCode() + StringUtils.AT + DateUtils.format(DateUtils.yyyyMMddHHmmss2, task.getFixedStartTime())