| | |
| | | @SaCheckPermission("system:oss:upload") |
| | | @Log(title = "OSS对象存储", businessType = BusinessType.INSERT) |
| | | @PostMapping(value = "/upload", consumes = MediaType.MULTIPART_FORM_DATA_VALUE) |
| | | public R<SysOssUploadVo> upload(@RequestPart("file") MultipartFile file) { |
| | | public R<SysOssUploadVo> upload(@RequestPart("file") MultipartFile file) throws IOException { |
| | | if (ObjectUtil.isNull(file)) { |
| | | return R.fail("上传文件不能为空"); |
| | | } |
| | |
| | | |
| | | |
| | | //添加队列数据 |
| | | QueueUtils.addDelayedQueueObject("OSS", oss.getOssId().toString(), 1, TimeUnit.HOURS); |
| | | QueueUtils.addDelayedQueueObject("OSS", oss.getOssId().toString(), 300, TimeUnit.SECONDS); |
| | | log.info("通道: {} , 发送数据: {}", "OSS", oss.getOssId()); |
| | | SysOssUploadVo uploadVo = new SysOssUploadVo(); |
| | | uploadVo.setUrl(oss.getUrl()); |
| | |
| | | @DeleteMapping("/{ossIds}/{password}") |
| | | public R<Void> remove(@NotEmpty(message = "主键不能为空") |
| | | @PathVariable Long[] ossIds, |
| | | @PathVariable String password) { |
| | | @PathVariable String password) throws Exception { |
| | | return ossService.deleteWithValidByIds(List.of(ossIds), true,password) ? R.ok() : R.fail("提取码错误!"); |
| | | } |
| | | |
| | |
| | | return R.ok("操作成功"); |
| | | } |
| | | |
| | | /** |
| | | * 同步 |
| | | * @param |
| | | * @return |
| | | */ |
| | | @PostMapping(value = "/synchronization") |
| | | public R synchronization(SynchronousRequest request) { |
| | | if (ObjectUtil.isNull(request.getFile())) { |
| | | return R.fail("上传文件不能为空"); |
| | | } |
| | | log.info("ossId:{}",request.getOssId()); |
| | | SysOssVo oss = ossService.upload2(request); |
| | | return R.ok(); |
| | | } |
| | | |
| | | } |