| | |
| | | return ResponseResult.error("任务不存在,jobId: " + jobId); |
| | | } |
| | | if (waylineJobDTO.get().getTaskType() == 3) { |
| | | // 已经执行完的子任务是否删除,或者清掉父任务ID,和正常任务一起显示在列表中。 |
| | | // 已经执行完的子任务一起全部删除 |
| | | this.deleteTask(jobId); |
| | | log.info("删除循环任务已经完成,主任务ID:{}。", waylineJobDTO.get().getJobId()); |
| | | List<WaylineJobDTO> waylineParentIds = this.getJobByJobParentId(jobId); |
| | | if (!waylineParentIds.isEmpty()) { |
| | | for (WaylineJobDTO waylineJob : waylineParentIds) { |
| | | this.deleteTask(waylineJob.getJobId()); |
| | | RedisOpsUtils.zRemove(RedisConst.WAYLINE_JOB_TIMED_EXECUTE, dockSn + RedisConst.DELIMITER + waylineJob.getJobId()); |
| | | log.info("删除循环子任务已经完成,子任务ID:{}。", waylineJob.getJobId()); |
| | | } |
| | | } |
| | | return ResponseResult.success(); |
| | | } |
| | | } |