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