| | |
|---|
| | | .rthAltitude(param.getRthAltitude()) |
|---|
| | | .mediaCount(0) |
|---|
| | | .build(); |
|---|
| | | |
|---|
| | | if (StringUtils.hasText(param.getJobId())){ |
|---|
| | | jobEntity.setJobId(param.getJobId()); |
|---|
| | | } |
|---|
| | | return insertWaylineJob(jobEntity); |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | .status(WaylineJobStatusEnum.FAILED.getVal()) |
|---|
| | | .completedTime(LocalDateTime.now()) |
|---|
| | | .code(serviceReply.getResult()).build()); |
|---|
| | | // The conditional task fails and enters the blocking status. |
|---|
| | | // 条件任务失败，进入阻塞状态。 |
|---|
| | | if (WaylineTaskTypeEnum.CONDITION == job.getTaskType() |
|---|
| | | && WaylineErrorCodeEnum.find(serviceReply.getResult()).isBlock()) { |
|---|
| | | waylineRedisService.setBlockedWaylineJob(job.getDockSn(), jobId); |
|---|
