| | |
| | | return WaylineJobStatusEnum.UNKNOWN; |
| | | } |
| | | |
| | | @Override |
| | | public WaylineJobEntity getLatestJob(String workspaceId, WaylineJobQueryParam waylineJobQueryParam) { |
| | | // List<WaylineJobEntity> waylineJobEntities = mapper.selectList(new LambdaQueryWrapper<>(WaylineJobEntity.class) |
| | | // .eq(WaylineJobEntity::getWorkspaceId, workspaceId) |
| | | // .eq(WaylineJobEntity::getDockSn, waylineJobQueryParam.getDockSn()) |
| | | // //获取状态为待执行 |
| | | // .eq(WaylineJobEntity::getStatus,1) |
| | | // .orderByDesc(WaylineJobEntity::getBeginTime) |
| | | // ); |
| | | |
| | | WaylineJobEntity waylineJobEntity = mapper.getLatest(workspaceId,waylineJobQueryParam); |
| | | |
| | | |
| | | return waylineJobEntity; |
| | | } |
| | | |
| | | private void pauseJob(String workspaceId, String dockSn, String jobId, WaylineJobStatusEnum statusEnum) { |
| | | if (WaylineJobStatusEnum.PAUSED == statusEnum && jobId.equals(waylineRedisService.getPausedWaylineJobId(dockSn))) { |
| | | waylineRedisService.setPausedWaylineJob(dockSn, jobId); |