2025-11-15 zwy 定时任务，根据循环任务每天生成定时任务

zhaowenyu

2025-11-15 5541af096786f61ae36697a794886a829b165dcf

2025-11-15 zwy 定时任务，根据循环任务每天生成定时任务

 ard-sample/src/main/java/com/ard/sample/wayline/service/impl/WaylineLoopTaskServiceImpl.java

New file
@@ -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;
    }
}