| | |
| | | |
| | | |
| | | //添加队列数据 |
| | | 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()); |
| | |
| | | return R.ok("操作成功"); |
| | | } |
| | | |
| | | /** |
| | | * 同步 |
| | | * @param |
| | | * @return |
| | | */ |
| | | @PostMapping(value = "/synchronization") |
| | | public R synchronization(SynchronousRequest request) { |
| | | if (ObjectUtil.isNull(request.getFile())) { |
| | | return R.fail("上传文件不能为空"); |
| | | } |
| | | log.info("ossId:{},path:{}",request.getOssId(),request.getPath()); |
| | | SysOssVo oss = ossService.upload2(request); |
| | | return R.ok(); |
| | | } |
| | | |
| | | } |