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..2d6c6a6 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); @@ -1291,7 +1287,6 @@ public class JobMainTask { // } // } // } - // 任务分拆异步执行V1.0 // private void prePointExecImmediate(final PatrolTaskExecRecord patrolTaskExecRecord, List patrolTaskInfoList) { // int batchSize = taskBatchSize; @@ -1308,7 +1303,6 @@ public class JobMainTask { // index++; // } // } - private int calcTaskAlgorithmTotalNumber(List patrolTaskInfoList, String specifiedAlg) { int totalAlgorithmNumber = 0; for (PatrolTaskInfo patrolTaskInfo : patrolTaskInfoList) { @@ -1517,7 +1511,6 @@ public class JobMainTask { // try (InputStream in = connection.getInputStream()) { // Files.copy(in, Paths.get("/test.jpg")); // } - /** * 将图片上传到ftp */ @@ -2039,12 +2032,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 +2088,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()) @@ -2106,7 +2103,7 @@ public class JobMainTask { continue; } String isEnable = patrolTasks.get(0).getIsEnable(); - log.debug("---execEveryDayTask isEnable: {}, taskCode: {}", isEnable, taskCode); + log.debug("---execEveryDayTask isEnable: {}, taskCode: {}", isEnable, taskCode); if (isTaskSlotEmpty(taskCode) && "0".equals(isEnable)) { log.debug(Color.YELLOW + "[JOB] TASK_CODE: {}" + Color.END, taskCode); // long currentTime = System.currentTimeMillis(); @@ -2117,14 +2114,12 @@ public class JobMainTask { // long planTime = DateUtils.parse(DateUtils.yyyyMMddHHmmss2, fixedStartTime).getTime(); // long fixedDays = TimeUnit.MILLISECONDS.toDays(planTime); // long fixedStartMinutes = TimeUnit.MILLISECONDS.toMinutes(planTime); - String fixedStartTime = keywords[2]; SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // 解析字符串为 Date Date fixedDate = sdf.parse(fixedStartTime); Date currentDate = new Date(); // 当前时间 - // 比较时间(精确到分钟) SimpleDateFormat minuteFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm"); String fixedMinute = minuteFormat.format(fixedDate); @@ -2159,4 +2154,4 @@ public class JobMainTask { log.error("error", e); } } -} +} \ No newline at end of file