| | |
| | | } |
| | | |
| | | @Override |
| | | public Integer saveMediaFile(String workspaceId, FileUploadDTO file){ |
| | | public Integer saveMediaFile(String workspaceId, FileUploadDTO file) throws IOException, ImageProcessingException { |
| | | return fileService.saveFile(workspaceId, file); |
| | | } |
| | | |
| | |
| | | BizCodeEnum.FILE_UPLOAD_CALLBACK.getCode(), mediaFileCount); |
| | | } |
| | | |
| | | private Boolean parseMediaFile(FileUploadCallback callback, WaylineJobDTO job) { |
| | | private Boolean parseMediaFile(FileUploadCallback callback, WaylineJobDTO job) throws ImageProcessingException, IOException, FontFormatException { |
| | | // Set the drone sn that shoots the media |
| | | Optional<DeviceDTO> dockDTO = deviceService.getDeviceBySn(job.getDockSn()); |
| | | dockDTO.ifPresent(dock -> callback.getFile().getExt().setSn(dock.getChildDeviceSn())); |
| | |
| | | String objectKey = callback.getFile().getObjectKey(); |
| | | callback.getFile().setPath(objectKey.substring(objectKey.indexOf("/") + 1, objectKey.lastIndexOf("/"))); |
| | | int count =fileService.saveFile(job.getWorkspaceId(), callback.getFile()); |
| | | try { |
| | | fileService.saveMarkFile(job.getWorkspaceId(), callback.getFile()); |
| | | } catch (Exception e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | // fileService.saveFiles(job.getWorkspaceId(), callback.getFile()); |
| | | // fileService.saveZipFile(job.getWorkspaceId(),callback.getFile()); |
| | | return count > 0; |
| | | } |
| | | |
| | | /** |
| | | * Handles the highest priority message about media uploads. |
| | | * |
| | | * 处理有关媒体上传的最高优先级消息。 |
| | | * @param receiver |
| | | * @param headers |
| | | * @return |
| | |
| | | |
| | | return receiver; |
| | | } |
| | | |
| | | @Override |
| | | public MediaFileEntity getMediaFieByTid(String timestamp) { |
| | | return mapper.getMediaFieByTid(timestamp); |
| | | } |
| | | } |