| | |
|---|
| | | import com.dji.sample.wayline.service.IWaylineJobBreakPointService; |
|---|
| | | import com.dji.sample.wayline.service.IWaylineJobService; |
|---|
| | | import com.dji.sample.wayline.service.IWaylineRedisService; |
|---|
| | | import com.dji.sample.wayline.util.ErrorCodeUtil; |
|---|
| | | import com.fasterxml.jackson.core.type.TypeReference; |
|---|
| | | import com.fasterxml.jackson.databind.ObjectMapper; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | |
|---|
| | | jobEntity.setParentId(parentId); |
|---|
| | | |
|---|
| | | return this.insertWaylineJob(jobEntity); |
|---|
| | | } |
|---|
| | | @Override |
|---|
| | | public String getWaylineId(String jobId){ |
|---|
| | | WaylineJobEntity waylineJob=mapper.selectOne(new LambdaQueryWrapper<WaylineJobEntity>().select(WaylineJobEntity::getFileId).eq(WaylineJobEntity::getJobId,jobId)); |
|---|
| | | return waylineJob.getFileId(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<String> getJobNamesByPartialName(String partialJobName) { |
|---|
| | | LambdaQueryWrapper<WaylineJobEntity> queryWrapper = new LambdaQueryWrapper<>(); |
|---|
| | | queryWrapper.like(WaylineJobEntity::getName, partialJobName); |
|---|
| | | return mapper.selectList(queryWrapper).stream() |
|---|
| | | .map(WaylineJobEntity::getName) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | public WaylineJobStatusEnum getWaylineState(String dockSn) { |
|---|
| | | Optional<DeviceDTO> dockOpt = deviceRedisService.getDeviceOnline(dockSn); |
|---|
| | | if (dockOpt.isEmpty() || !StringUtils.hasText(dockOpt.get().getChildDeviceSn())) { |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<String> getJobId(String jobName) { |
|---|
| | | public List<String> getJobIds(String jobNames) { |
|---|
| | | List<String> names = getJobNamesByPartialName(jobNames); |
|---|
| | | // 使用 LambdaQueryWrapper 进行查询 |
|---|
| | | List<Object> jobIdList = mapper.selectObjs( |
|---|
| | | new LambdaQueryWrapper<WaylineJobEntity>() |
|---|
| | | .select(WaylineJobEntity::getJobId) |
|---|
| | | .eq(WaylineJobEntity::getName, jobName) |
|---|
| | | .in(WaylineJobEntity::getName, names) // 使用 IN 子句 |
|---|
| | | ); |
|---|
| | | |
|---|
| | | // 将 Object 类型的 jobId 转换为 String 类型，并放入 List<String> 中 |
|---|
