| | |
| | | package com.ard.sample.wayline.service.impl; |
| | | |
| | | import com.ard.oss.service.impl.OssServiceContext; |
| | | import com.ard.route.domain.route.ArdRouteInformation; |
| | | import com.ard.route.service.IArdRouteInformationService; |
| | | import com.ard.route.domain.route.ArdRouteInfo; |
| | | import com.ard.route.service.IArdRouteInfoService; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | |
| | | import com.ard.sample.wayline.model.enums.WaylineMethodEnum; |
| | | import com.ard.sample.wayline.model.enums.WaylineTaskTypeEnum; |
| | | import com.ard.sample.wayline.model.param.CreateJobParam; |
| | | import com.ard.sample.wayline.service.IWaylineFileService; |
| | | import com.ard.sample.wayline.service.IWaylineJobService; |
| | | import com.fasterxml.jackson.core.type.TypeReference; |
| | | import com.fasterxml.jackson.databind.ObjectMapper; |
| | |
| | | import javax.annotation.Resource; |
| | | import java.io.IOException; |
| | | import java.io.InputStream; |
| | | import java.net.MalformedURLException; |
| | | import java.net.URL; |
| | | import java.sql.SQLException; |
| | | import java.time.Instant; |
| | |
| | | import java.util.stream.Collectors; |
| | | |
| | | import static com.ard.route.util.ToolUtils.kmzPath; |
| | | import static com.ard.route.util.ToolUtils.subStringMinioUrlName; |
| | | |
| | | /** |
| | | * @author sean |
| | |
| | | // private IWaylineFileService waylineFileService; |
| | | |
| | | @Autowired |
| | | private IArdRouteInformationService _ardRouteInformationService; |
| | | private IArdRouteInfoService _ardRouteInfoService; |
| | | |
| | | @Resource |
| | | private OssServiceContext _ossService; |
| | |
| | | // return ResponseResult.error("机场任务航线不存在!"); |
| | | // } |
| | | // 换航线表 |
| | | ArdRouteInformation ardRouteOpt = _ardRouteInformationService.selectArdRouteInformationById(waylineJob.getFileId()); |
| | | ArdRouteInfo ardRouteOpt = _ardRouteInfoService.selectArdRouteInfoById(waylineJob.getFileId()); |
| | | if (ardRouteOpt == null) { |
| | | return ResponseResult.error("机场任务航线不存在!"); |
| | | } |
| | |
| | | // get file url |
| | | // URL url = waylineFileService.getObjectUrl(waylineFile.get().getWaylineId()); |
| | | URL url= null; |
| | | String minioUrl = ardRouteOpt.getMinioUpPath(); |
| | | String minioUrl = subStringMinioUrlName(ardRouteOpt.getUpPath()); |
| | | String md5 = ""; |
| | | try (InputStream inputStream = _ossService.getObject(kmzPath,minioUrl)) |
| | | { |
| | |
| | | // } |
| | | // 修改航线文件名称,从ard_route_information航线表中取; |
| | | // 换航线表 |
| | | ArdRouteInformation ardRouteOpt = _ardRouteInformationService.selectArdRouteInformationById(waylineJob.getFileId()); |
| | | ArdRouteInfo ardRouteOpt = _ardRouteInfoService.selectArdRouteInfoById(waylineJob.getFileId()); |
| | | if (ardRouteOpt == null) { |
| | | builder.data(RequestsReply.error(CommonErrorEnum.ILLEGAL_ARGUMENT)); |
| | | messageSender.publish(topic, builder.build()); |
| | |
| | | |
| | | // get file url |
| | | URL url = null; |
| | | String minioUrl = ardRouteOpt.getMinioUpPath(); |
| | | String minioUrl = subStringMinioUrlName(ardRouteOpt.getUpPath()); |
| | | String md5 = ""; |
| | | try (InputStream inputStream = _ossService.getObject(kmzPath,minioUrl)) |
| | | { |
| | |
| | | .fileId(entity.getFileId()) |
| | | // .fileName(waylineFileService.getWaylineByWaylineId(entity.getFileId()) |
| | | // .orElse(WaylineFileDTO.builder().build()).getName()) |
| | | .fileName(_ardRouteInformationService.selectArdRouteInformationById(entity.getFileId()) |
| | | .getFileName()) |
| | | .fileName(_ardRouteInfoService.selectArdRouteInfoById(entity.getFileId()) |
| | | .getName()) |
| | | .dockSn(entity.getDockSn()) |
| | | .dockName(deviceService.getDeviceBySn(entity.getDockSn()) |
| | | .orElse(DeviceDTO.builder().build()).getNickname()) |