| | |
| | | if (WaylineTaskTypeEnum.IMMEDIATE == waylineJob.getTaskType()) { |
| | | boolean isExecuted = executeFlightTask(waylineJob.getWorkspaceId(), waylineJob.getJobId()); |
| | | if (!isExecuted) { |
| | | return ResponseResult.error("执行任务失败"); |
| | | return ResponseResult.error("当前状态不支持飞行,请检查是否已有正在执行的飞行任务!"); |
| | | } |
| | | } |
| | | |
| | |
| | | .map(this::entity2Dto) |
| | | .collect(Collectors.toList()); |
| | | |
| | | // 是否需要断点续飞 |
| | | records.forEach(wjd -> wjd.setBreakPoint(waylineJobBreakPointService.count( |
| | | new LambdaQueryWrapper<WaylineJobBreakPointEntity>().eq(WaylineJobBreakPointEntity::getJobId,wjd.getJobId())) > 0)); |
| | | |
| | | |
| | | return new PaginationData<WaylineJobDTO>(records, new Pagination(pageData)); |
| | | } |
| | | |