This commit is contained in:
jxxghp
2024-11-15 16:17:51 +08:00
parent e60d785a11
commit 42dc539df6
2 changed files with 7 additions and 7 deletions
+6 -6
View File
@@ -3,12 +3,12 @@ from typing import List, Union, Optional, Generator
from cachetools import cached, TTLCache from cachetools import cached, TTLCache
from app import schemas
from app.chain import ChainBase from app.chain import ChainBase
from app.core.config import global_vars from app.core.config import global_vars
from app.db.mediaserver_oper import MediaServerOper from app.db.mediaserver_oper import MediaServerOper
from app.helper.service import ServiceConfigHelper from app.helper.service import ServiceConfigHelper
from app.log import logger from app.log import logger
from app.schemas import MediaServerLibrary, MediaServerItem, MediaServerSeasonInfo, MediaServerPlayItem
lock = threading.Lock() lock = threading.Lock()
@@ -22,7 +22,7 @@ class MediaServerChain(ChainBase):
super().__init__() super().__init__()
self.dboper = MediaServerOper() self.dboper = MediaServerOper()
def librarys(self, server: str, username: str = None, hidden: bool = False) -> List[schemas.MediaServerLibrary]: def librarys(self, server: str, username: str = None, hidden: bool = False) -> List[MediaServerLibrary]:
""" """
获取媒体服务器所有媒体库 获取媒体服务器所有媒体库
""" """
@@ -70,25 +70,25 @@ class MediaServerChain(ChainBase):
yield from self.run_module("mediaserver_items", server=server, library_id=library_id, yield from self.run_module("mediaserver_items", server=server, library_id=library_id,
start_index=start_index, limit=limit) start_index=start_index, limit=limit)
def iteminfo(self, server: str, item_id: Union[str, int]) -> schemas.MediaServerItem: def iteminfo(self, server: str, item_id: Union[str, int]) -> MediaServerItem:
""" """
获取媒体服务器项目信息 获取媒体服务器项目信息
""" """
return self.run_module("mediaserver_iteminfo", server=server, item_id=item_id) return self.run_module("mediaserver_iteminfo", server=server, item_id=item_id)
def episodes(self, server: str, item_id: Union[str, int]) -> List[schemas.MediaServerSeasonInfo]: def episodes(self, server: str, item_id: Union[str, int]) -> List[MediaServerSeasonInfo]:
""" """
获取媒体服务器剧集信息 获取媒体服务器剧集信息
""" """
return self.run_module("mediaserver_tv_episodes", server=server, item_id=item_id) return self.run_module("mediaserver_tv_episodes", server=server, item_id=item_id)
def playing(self, server: str, count: int = 20, username: str = None) -> List[schemas.MediaServerPlayItem]: def playing(self, server: str, count: int = 20, username: str = None) -> List[MediaServerPlayItem]:
""" """
获取媒体服务器正在播放信息 获取媒体服务器正在播放信息
""" """
return self.run_module("mediaserver_playing", count=count, server=server, username=username) return self.run_module("mediaserver_playing", count=count, server=server, username=username)
def latest(self, server: str, count: int = 20, username: str = None) -> List[schemas.MediaServerPlayItem]: def latest(self, server: str, count: int = 20, username: str = None) -> List[MediaServerPlayItem]:
""" """
获取媒体服务器最新入库条目 获取媒体服务器最新入库条目
""" """
+1 -1
View File
@@ -76,7 +76,7 @@ class Rclone(StorageBase):
return schemas.FileItem( return schemas.FileItem(
storage=self.schema.value, storage=self.schema.value,
type="dir", type="dir",
path=f"{parent}{item.get('Name')}", path=f"{parent}{item.get('Name')}" + "/",
name=item.get("Name"), name=item.get("Name"),
basename=item.get("Name"), basename=item.get("Name"),
modify_time=StringUtils.str_to_timestamp(item.get("ModTime")) modify_time=StringUtils.str_to_timestamp(item.get("ModTime"))