| | |
| | | package com.ard.sample.wayline.service.impl; |
| | | |
| | | import com.ard.oss.service.impl.OssServiceContext; |
| | | import com.ard.ossdock.service.impl.OssDockServiceContext; |
| | | import com.ard.route.domain.route.ArdRouteInfo; |
| | | import com.ard.route.service.IArdRouteInfoService; |
| | | import com.baomidou.mybatisplus.core.conditions.Wrapper; |
| | |
| | | private IArdRouteInfoService _ardRouteInfoService; |
| | | |
| | | @Resource |
| | | private OssServiceContext _ossService; |
| | | private OssDockServiceContext _ossService; |
| | | |
| | | @Autowired |
| | | private IDeviceService deviceService; |
| | |
| | | // get file url |
| | | // URL url = waylineFileService.getObjectUrl(waylineFile.get().getWaylineId()); |
| | | URL url = null; |
| | | String minioUrl = subStringMinioUrlName(ardRouteOpt.getPath()); |
| | | String minioUrl = subStringMinioUrlName(ardRouteOpt.getPath1()); |
| | | String md5 = ""; |
| | | try (InputStream inputStream = _ossService.getObject(kmzPath, minioUrl)) { |
| | | md5 = DigestUtils.md5Hex(inputStream); |
| | | url = new URL(ardRouteOpt.getPath()); |
| | | url = new URL(ardRouteOpt.getPath1()); |
| | | log.info("机场任务航线文件url地址:{}", url); |
| | | log.info("机场任务航线文件md5值:{}", md5); |
| | | } catch (Exception e) { |
| | |
| | | .file(WaylineTaskFileDTO.builder() |
| | | // .url(url.toString().replace("https://192.168.10.103:9001", "http://192.168.10.103:9011")) |
| | | // .fingerprint(waylineFile.get().getSign()) |
| | | .url(url.toString().replace("https://", "http://") |
| | | .replace("9001", "9011")) |
| | | // .replace("https://", "http://") |
| | | // .replace("9001", "9011") |
| | | .url(url.toString()) |
| | | .fingerprint(md5) |
| | | .build()) |
| | | // .simulateMission(WaylineSimulateMissionDTO.builder() |
| | |
| | | |
| | | // get file url |
| | | URL url = null; |
| | | String minioUrl = subStringMinioUrlName(ardRouteOpt.getPath()); |
| | | String minioUrl = subStringMinioUrlName(ardRouteOpt.getPath1()); |
| | | String md5 = ""; |
| | | try (InputStream inputStream = _ossService.getObject(kmzPath, minioUrl)) { |
| | | md5 = DigestUtils.md5Hex(inputStream); |
| | | url = new URL(ardRouteOpt.getPath()); |
| | | url = new URL(ardRouteOpt.getPath1()); |
| | | log.info("机场通过flightTaskResourceGet获取航线文件地址,jobId: " + jobId + " 返回信息为url:" + url.toString() + " md5:" + md5); |
| | | // } |
| | | // try { |
| | |
| | | // Map<String, Object> jsonResourceGet = new HashMap<>(); |
| | | // jsonResourceGet.put("url", url.toString().replace("https//192.168.10.103:9001", "http//192.168.10.103:9002")); |
| | | // jsonResourceGet.put("fingerprint", md5); |
| | | // .replace("https://", "http://") |
| | | // .replace("9001", "9011") |
| | | |
| | | builder.data(RequestsReply.success(WaylineTaskCreateDTO.builder() |
| | | .file(WaylineTaskFileDTO.builder() |
| | | .url(url.toString().replace("https://", "http://") |
| | | .replace("9001", "9011")) |
| | | .url(url.toString()) |
| | | .fingerprint(md5) |
| | | .build()) |
| | | .build())); |
| | | |
| | | // WaylineTaskFileDTO.builder() |
| | | // .url(url.toString()) |
| | | //// .fingerprint(waylineFile.get().getSign()) |
| | | // .fingerprint(md5) |
| | | // .build() |
| | | |
| | | } catch (NullPointerException | IOException e) { |
| | | e.printStackTrace(); |