| | |
| | | import com.dji.sample.common.model.CustomClaim; |
| | | import com.dji.sample.common.model.PaginationData; |
| | | import com.dji.sample.common.model.ResponseResult; |
| | | import com.dji.sample.log.aspect.SysLogAnnotation; |
| | | import com.dji.sample.wayline.model.dto.WaylineJobDTO; |
| | | import com.dji.sample.wayline.model.param.CreateJobParam; |
| | | import com.dji.sample.wayline.model.param.UpdateJobParam; |
| | |
| | | * @throws SQLException |
| | | */ |
| | | @PostMapping("/{workspace_id}/flight-tasks") |
| | | @SysLogAnnotation(operModul = "计划库", operType = "新增", operDesc = "创建计划") |
| | | public ResponseResult createJob(HttpServletRequest request, @Valid @RequestBody CreateJobParam param, |
| | | @PathVariable(name = "workspace_id") String workspaceId) throws SQLException { |
| | | CustomClaim customClaim = (CustomClaim)request.getAttribute(TOKEN_CLAIM); |
| | |
| | | * @throws SQLException |
| | | */ |
| | | @PostMapping("/{workspace_id}/flight-tasks-condition") |
| | | @SysLogAnnotation(operModul = "计划库", operType = "新增", operDesc = "创建航路任务(重复定时和连续执行)") |
| | | public ResponseResult createJobCondition(HttpServletRequest request, @Valid @RequestBody CreateJobParam param, |
| | | @PathVariable(name = "workspace_id") String workspaceId) throws SQLException { |
| | | CustomClaim customClaim = (CustomClaim)request.getAttribute(TOKEN_CLAIM); |
| | |
| | | * @return |
| | | */ |
| | | @GetMapping("/{workspace_id}/jobs") |
| | | @SysLogAnnotation(operModul = "计划库", operType = "查询", operDesc = "分页查询") |
| | | public ResponseResult<PaginationData<WaylineJobDTO>> getJobs(@RequestParam(defaultValue = "1") Long page, |
| | | @RequestParam(name = "page_size", defaultValue = "10") Long pageSize, |
| | | @PathVariable(name = "workspace_id") String workspaceId, WaylineJobQueryParam waylineJobQueryParam){ |
| | |
| | | * @throws SQLException |
| | | */ |
| | | @DeleteMapping("/{workspace_id}/jobs") |
| | | @SysLogAnnotation(operModul = "计划库", operType = "删除", operDesc = "发送命令取消作业") |
| | | public ResponseResult publishCancelJob(@RequestParam(name = "job_id") Set<String> jobIds, |
| | | @PathVariable(name = "workspace_id") String workspaceId) throws SQLException { |
| | | waylineJobService.cancelFlightTask(workspaceId, jobIds); |
| | |
| | | * @return |
| | | */ |
| | | @PostMapping("/{workspace_id}/jobs/{job_id}/media-highest") |
| | | @SysLogAnnotation(operModul = "计划库", operType = "修改", operDesc = "将此作业的媒体文件设置为立即上传") |
| | | public ResponseResult uploadMediaHighestPriority(@PathVariable(name = "workspace_id") String workspaceId, |
| | | @PathVariable(name = "job_id") String jobId) { |
| | | waylineJobService.uploadMediaHighestPriority(workspaceId, jobId); |
| | |
| | | } |
| | | |
| | | @PutMapping("/{workspace_id}/jobs/{job_id}") |
| | | @SysLogAnnotation(operModul = "计划库", operType = "修改", operDesc = "修改") |
| | | public ResponseResult updateJobStatus(@PathVariable(name = "workspace_id") String workspaceId, |
| | | @PathVariable(name = "job_id") String jobId, |
| | | @Valid @RequestBody UpdateJobParam param) { |