2025-12-16 zwy 优化-删除任务时，正在执行中的任务不能删除

zhaowenyu

2025-12-16 4cd6c6c06d16b1e80600b6e7e812152444ed3e48

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

@@ -269,8 +269,7 @@
        try{
            String json = objectMapper.writeValueAsString(response);
            log.info("机场下发航线任务的参数response：{}", json);
        }
        catch (Exception e){
        } catch (Exception e) {
            log.error("机场下发航线任务的参数response异常：{}", e.getMessage());
        }

@@ -367,8 +366,7 @@
        try{
            String json = objectMapper.writeValueAsString(flightTask);
            log.info("机场下发循环任务子任务-定时任务的航线任务的参数flightTask：{}", json);
        }
        catch (Exception e){
        } catch (Exception e) {
            log.error("机场下发循环任务子任务-定时任务的航线任务的参数flightTask异常：{}", e.getMessage());
        }

@@ -460,8 +458,7 @@
        try{
            String json = objectMapper.writeValueAsString(response);
            log.info("机场下发-执行飞行任务-的参数response：{}", json);
        }
        catch (Exception e){
        } catch (Exception e) {
            log.error("机场下发-执行飞行任务-的参数response异常：{}", e.getMessage());
        }

@@ -500,7 +497,9 @@
     */
    @Override
    public ResponseResult cancelFlightTask(Collection<String> jobIds) {
        List<WaylineJobDTO> waylineJobs = getJobsByConditions(jobIds, WaylineJobStatusEnum.PENDING);
//        List<WaylineJobDTO> waylineJobs = getJobsByConditions(jobIds, WaylineJobStatusEnum.PENDING);
        List<WaylineJobDTO> waylineJobs = getJobsByConditions(jobIds, WaylineJobStatusEnum.IN_PROGRESS);

//        ResponseResult.error(errorCode, CommonErrorEnum.getMsgByCode(errorCode)));
//        Set<String> waylineJobIds = waylineJobs.stream().map(WaylineJobDTO::getJobId).collect(Collectors.toSet());
//        // Check if the task status is correct.
@@ -674,6 +673,7 @@
                        new LambdaQueryWrapper<WaylineJobEntity>()
                                // 不过滤状态,
                                //.eq(Objects.nonNull(status), WaylineJobEntity::getStatus, status.getVal())
                                .ne(WaylineJobEntity::getStatus, status.getVal())
                                .and(!CollectionUtils.isEmpty(jobIds),
                                        wrapper -> jobIds.forEach(id -> wrapper.eq(WaylineJobEntity::getJobId, id).or())))
                .stream()
@@ -792,7 +792,7 @@

    /**
     * 获取所有待定状态的定时任务，未执行即将要执行的。
     * */
     */
    public List<WaylineJobEntity> selectScheduledTaskList(){
        // "1":"定时任务"
        return mapper.selectList(new LambdaQueryWrapper<WaylineJobEntity>()
@@ -901,8 +901,7 @@
        try{
            String json = objectMapper.writeValueAsString(builder.build());
            log.info("机场通过flighttask_resource_get获取航线文件的参数flightTask：{}", json);
        }
        catch (Exception e){
        } catch (Exception e) {
            log.error("机场通过flighttask_resource_get获取航线文件的参数flightTask异常：{}", e.getMessage());
        }

@@ -1004,8 +1003,7 @@
                    fileName = Optional.ofNullable(ardRouteInfo.getName()).orElse("");
                }
            }
        }
        catch (Exception e) {
        } catch (Exception e) {
            log.info("获取航线名称失败，fileId:{},异常原因：{}", fileId,e.getMessage());
            fileName = "";
        }