feat(LibraryPoster): 优化对多路径媒体库的处理

Author: awordx

app/modules/libraryposter/poster.py

@@ -31,6 +31,30 @@ def __init__(
         self.__title_font_path = Path(title_font_path)
         self.__subtitle_font_path = Path(subtitle_font_path)
         self.__configs = configs
+    async def fetch_items(
+            self,
+            parent_id: str,
+            user_id: str,
+            max_depth: int = 1,
+            current_depth: int = 0
+    ) -> AsyncGenerator[dict[str, Any], None]:
+        url = f"{self.__server_url}/Users/{user_id}/Items?ParentId={parent_id}&api_key={self.__api_key}"
+        resp = await RequestUtils.get(url)
+
+        if not resp or resp.status_code != 200:
+            return
+        for item in resp.json().get("Items", []):
+            if item.get("IsFolder", False) and current_depth < max_depth:
+                # 递归获取子项
+                async for sub_item in self.fetch_items(
+                        parent_id=item["Id"],
+                        user_id=user_id,
+                        max_depth=max_depth,
+                        current_depth=current_depth + 1
+                ):
+                    yield sub_item
+            else:
+                yield item
 
     async def get_users(self) -> list[dict[str, Any]]:
         """
@@ -81,6 +105,8 @@ async def get_library_items(
         :param user_id: 用户 ID（可选）
         :return: 媒体库项目列表
         """
+        max_depth = 0
+        all_items = []
         if not user_id:
             users = await self.get_users()
             if not users:
@@ -96,8 +122,13 @@ async def get_library_items(
                 f"获取 {library_id} 媒体库信息失败, 状态码: {resp.status_code if resp else '无响应'}"
             )
             return []
-
-        return resp.json()["Items"]
+        while len(all_items) < 15 and max_depth <= 5:
+            async for item in self.fetch_items(library_id, user_id, max_depth=max_depth):
+                all_items.append(item)
+                if len(all_items) >= 15:
+                    break
+            max_depth += 1
+        return all_items
 
     async def download_item_image(
         self,