From 5541af096786f61ae36697a794886a829b165dcf Mon Sep 17 00:00:00 2001
From: zhaowenyu <35589726@qq.com>
Date: Sat, 15 Nov 2025 15:35:00 +0800
Subject: [PATCH] 2025-11-15 zwy 定时任务，根据循环任务每天生成定时任务
---
ard-sample/src/main/java/com/ard/sample/wayline/service/impl/WaylineLoopTaskServiceImpl.java | 97 ++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 97 insertions(+), 0 deletions(-)
diff --git a/ard-sample/src/main/java/com/ard/sample/wayline/service/impl/WaylineLoopTaskServiceImpl.java b/ard-sample/src/main/java/com/ard/sample/wayline/service/impl/WaylineLoopTaskServiceImpl.java
new file mode 100644
index 0000000..3222279
--- /dev/null
+++ b/ard-sample/src/main/java/com/ard/sample/wayline/service/impl/WaylineLoopTaskServiceImpl.java
@@ -0,0 +1,97 @@
+package com.ard.sample.wayline.service.impl;
+
+import com.ard.sample.utils.TimestampUtils;
+import com.ard.sample.wayline.model.dto.WaylineJobDTO;
+import com.ard.sample.wayline.model.entity.WaylineJobEntity;
+import com.ard.sample.wayline.model.enums.WaylineJobStatusEnum;
+import com.ard.sample.wayline.model.param.CreateJobParam;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Optional;
+
+@Slf4j
+@Component
+public class WaylineLoopTaskServiceImpl {
+
+ @Autowired
+ private WaylineJobServiceImpl _waylineJobService;
+ @Autowired
+ private TimestampUtils _timestampUtils;
+
+ /**
+ * 定时任务，生成循环任务在有效其内的每天的定时任务
+ * */
+ @Scheduled(cron = "0 0 10 * * ?")
+ public void loopTask() {
+ try {
+ // 执行定时任务逻辑，例如检查并执行已到时间的飞行任务
+ List<WaylineJobEntity> lineList = _waylineJobService.selectList(3L, null, null);
+ for (WaylineJobEntity waylineJobEntity : lineList) {
+ // 获取taskType为3的数据列表，
+ // 判断是否已完成
+ if (waylineJobEntity.getStatus() == WaylineJobStatusEnum.SUCCESS.getVal()) {
+ continue;
+ }
+ // 判断时间是否在有期内,循环任务的逻辑是，开始执行时间+循环次数。
+ Long beginTime = waylineJobEntity.getBeginTime();
+ // 获取循环任务开始的那天的0点0分0秒的时间戳，方便比对时间有效期范围；
+ // 循环任务按每天下发定时任务走，必须要在当次任务执行时间之前执行。
+ Long beginTime_Start = _timestampUtils.getDayStartTimestamp(beginTime);
+ Integer loopSum = waylineJobEntity.getLoopSum();
+ Long endTime = _timestampUtils.plusDaysByMillis(beginTime, loopSum);
+ if (beginTime_Start.compareTo(System.currentTimeMillis()) < 0 && endTime.compareTo(System.currentTimeMillis()) > 0) {
+ // 执行任务逻辑
+ // 如果在有效期内，判断任务是否已存在，如果存在则不生成子任务；新时间组成为：当前时间戳的年月日，主任务时间的时分秒。
+ Long newTime = _timestampUtils.combine(beginTime);
+ List<WaylineJobEntity> jobSum= _waylineJobService.selectList(null, null, waylineJobEntity.getJobId());
+ if(!jobSum.isEmpty() && jobSum.size() >= loopSum)
+ {
+ log.info("循环子任务已经完成，主任务ID：{}。", waylineJobEntity.getJobId());
+ // 循环子任务已经完成，修改主任务状态为已完成，即：status=3.
+ _waylineJobService.updateJob(WaylineJobDTO.builder()
+ .jobId(waylineJobEntity.getJobId())
+ .executeTime(LocalDateTime.now())
+ .status(WaylineJobStatusEnum.SUCCESS.getVal())
+ .completedTime(LocalDateTime.now())
+ .code(0).build());
+ continue;
+ }
+ List<WaylineJobEntity> jobEntities = _waylineJobService.selectList(null, newTime, waylineJobEntity.getJobId());
+ if (!jobEntities.isEmpty()) {
+ log.info("循环子任务已经存在，主任务ID：{}，时间：{}！", waylineJobEntity.getJobId(), _timestampUtils.formatByMillis(newTime));
+ continue;
+ }
+ CreateJobParam param = getCreateJobParam(waylineJobEntity, newTime);
+ Optional<WaylineJobDTO> waylineJobDTO = _waylineJobService.createWaylineJob(param, waylineJobEntity.getUsername(), newTime, newTime);
+ _waylineJobService.publishFlightTaskPrepare(waylineJobDTO);
+ log.info("添加循环子任务成功，任务ID：{}，时间：{}！", waylineJobEntity.getJobId(), _timestampUtils.formatByMillis(newTime));
+ }
+
+ }
+ }
+ catch (Exception e) {
+ e.printStackTrace();
+ log.error("添加循环子任务出现异常，时间：{}！异常原因：{}", _timestampUtils.formatByMillis(System.currentTimeMillis()), e.getMessage());
+ }
+ }
+
+ private CreateJobParam getCreateJobParam(WaylineJobEntity waylineJobEntity, Long newTime) {
+ CreateJobParam param = new CreateJobParam();
+ param.setName(waylineJobEntity.getName() + "-子任务");
+ param.setFileId(waylineJobEntity.getFileId());
+ param.setDockSn(waylineJobEntity.getDockSn());
+ param.setWaylineType(waylineJobEntity.getWaylineType());
+ param.setTaskType(1);
+ param.setExecuteTime(newTime);
+ param.setRthAltitude(waylineJobEntity.getRthAltitude());
+ param.setOutOfControlAction(waylineJobEntity.getOutOfControlAction());
+ param.setParentId(waylineJobEntity.getJobId());
+ param.setLoopSum(null);
+ return param;
+ }
+}
--
Gitblit v1.9.3