You've already forked FrameTour-BE
refactor(storage): 移除视频片段上传中的本地存储适配器直接操作
- 删除了 VptController 中的本地存储适配器设置 URL 和访问权限代码 - 删除了 WvpController 中的本地存储适配器设置 URL 和访问权限代码 - 将存储操作统一到被动存储操作器中处理 - 简化了控制器中的文件对象处理逻辑
This commit is contained in:
@@ -47,10 +47,6 @@ public class VptController {
|
|||||||
}
|
}
|
||||||
@PostMapping("/scenic/{scenicId}/{taskId}/success")
|
@PostMapping("/scenic/{scenicId}/{taskId}/success")
|
||||||
public ApiResponse<String> success(@PathVariable("scenicId") Long scenicId, @PathVariable("taskId") Long taskId, @RequestBody FileObject fileObject) {
|
public ApiResponse<String> success(@PathVariable("scenicId") Long scenicId, @PathVariable("taskId") Long taskId, @RequestBody FileObject fileObject) {
|
||||||
IStorageAdapter adapter = scenicService.getScenicLocalStorageAdapter(scenicId);
|
|
||||||
String filename = StorageUtil.joinPath(StorageConstant.VIDEO_PIECE_PATH, taskId.toString() + ".mp4");
|
|
||||||
fileObject.setUrl(adapter.getUrl(filename));
|
|
||||||
adapter.setAcl(StorageAcl.PUBLIC_READ, filename);
|
|
||||||
VptPassiveStorageOperator.onReceiveResult(taskId, fileObject);
|
VptPassiveStorageOperator.onReceiveResult(taskId, fileObject);
|
||||||
return ApiResponse.success("success");
|
return ApiResponse.success("success");
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -48,10 +48,6 @@ public class WvpController {
|
|||||||
}
|
}
|
||||||
@PostMapping("/scenic/{scenicId}/{taskId}/success")
|
@PostMapping("/scenic/{scenicId}/{taskId}/success")
|
||||||
public ApiResponse<String> success(@PathVariable("scenicId") Long scenicId, @PathVariable("taskId") Long taskId, @RequestBody FileObject fileObject) {
|
public ApiResponse<String> success(@PathVariable("scenicId") Long scenicId, @PathVariable("taskId") Long taskId, @RequestBody FileObject fileObject) {
|
||||||
IStorageAdapter adapter = scenicService.getScenicLocalStorageAdapter(scenicId);
|
|
||||||
String filename = StorageUtil.joinPath(StorageConstant.VIDEO_PIECE_PATH, taskId.toString() + ".mp4");
|
|
||||||
fileObject.setUrl(adapter.getUrl(filename));
|
|
||||||
adapter.setAcl(StorageAcl.PUBLIC_READ, filename);
|
|
||||||
WvpPassiveStorageOperator.onReceiveResult(taskId, fileObject);
|
WvpPassiveStorageOperator.onReceiveResult(taskId, fileObject);
|
||||||
return ApiResponse.success("success");
|
return ApiResponse.success("success");
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user