diff --git a/apps/api/app/services/ai_avatar_render_service.py b/apps/api/app/services/ai_avatar_render_service.py index 9b3db232c..d13af622d 100644 --- a/apps/api/app/services/ai_avatar_render_service.py +++ b/apps/api/app/services/ai_avatar_render_service.py @@ -27,6 +27,7 @@ from packages.domain.video_filter_builder import ( build_cover_extract_command, build_title_drawtext_filter, ) +from packages.shared.storage import get_shared_storage_service logger = logging.getLogger(__name__) @@ -363,8 +364,14 @@ class AiAvatarRenderService: def _upload_to_oss(self, local_path: str, oss_key: str) -> str: """上传文件到 OSS,返回 URL. - 简化实现,实际应调用 OSS SDK。 + 使用 SharedStorageService 统一存储服务。 """ - # TODO: 集成实际 OSS 上传 - logger.info("上传文件到 OSS: %s -> %s", local_path, oss_key) - return f"https://oss.example.com/{oss_key}" + storage = get_shared_storage_service() + url = storage.upload_file_smart(local_path, oss_key) + if url is None: + raise AiAvatarRenderError( + f"上传文件到 OSS 失败: {oss_key}", + code="OSSUploadFailed", + ) + logger.info("上传文件到 OSS 成功: %s -> %s", local_path, url) + return url