This commit is contained in:
jxxghp
2025-06-11 07:07:55 +08:00
parent 35d9cc1d40
commit 64eba46a67
3 changed files with 8 additions and 10 deletions

View File

@@ -27,15 +27,12 @@ class MediaChain(ChainBase):
媒体信息处理链,单例运行 媒体信息处理链,单例运行
""" """
def __init__(self): @staticmethod
super().__init__() def _get_scraping_switchs() -> dict:
self._systemconfig = SystemConfigOper()
def _get_scraping_switchs(self) -> dict:
""" """
获取刮削开关配置 获取刮削开关配置
""" """
switchs = self._systemconfig.get(SystemConfigKey.ScrapingSwitchs) or {} switchs = SystemConfigOper().get(SystemConfigKey.ScrapingSwitchs) or {}
# 默认配置 # 默认配置
default_switchs = { default_switchs = {
'movie_nfo': True, # 电影NFO 'movie_nfo': True, # 电影NFO
@@ -63,13 +60,14 @@ class MediaChain(ChainBase):
switchs[key] = default_value switchs[key] = default_value
return switchs return switchs
def set_scraping_switchs(self, switchs: dict) -> bool: @staticmethod
def set_scraping_switchs(switchs: dict) -> bool:
""" """
设置刮削开关配置 设置刮削开关配置
:param switchs: 开关配置字典 :param switchs: 开关配置字典
:return: 是否设置成功 :return: 是否设置成功
""" """
return self._systemconfig.set(SystemConfigKey.ScrapingSwitchs, switchs) return SystemConfigOper().set(SystemConfigKey.ScrapingSwitchs, switchs)
def metadata_nfo(self, meta: MetaBase, mediainfo: MediaInfo, def metadata_nfo(self, meta: MetaBase, mediainfo: MediaInfo,
season: Optional[int] = None, episode: Optional[int] = None) -> Optional[str]: season: Optional[int] = None, episode: Optional[int] = None) -> Optional[str]:

View File

@@ -306,7 +306,6 @@ class QbittorrentModule(_ModuleBase, _DownloaderBase[Qbittorrent]):
)) ))
else: else:
return None return None
return ret_torrents
def transfer_completed(self, hashs: str, downloader: Optional[str] = None) -> None: def transfer_completed(self, hashs: str, downloader: Optional[str] = None) -> None:
""" """
@@ -318,6 +317,7 @@ class QbittorrentModule(_ModuleBase, _DownloaderBase[Qbittorrent]):
if not server: if not server:
return None return None
server.set_torrents_tag(ids=hashs, tags=['已整理']) server.set_torrents_tag(ids=hashs, tags=['已整理'])
return None
def remove_torrents(self, hashs: Union[str, list], delete_file: Optional[bool] = True, def remove_torrents(self, hashs: Union[str, list], delete_file: Optional[bool] = True,
downloader: Optional[str] = None) -> Optional[bool]: downloader: Optional[str] = None) -> Optional[bool]:

View File

@@ -292,7 +292,6 @@ class TransmissionModule(_ModuleBase, _DownloaderBase[Transmission]):
)) ))
else: else:
return None return None
return ret_torrents
def transfer_completed(self, hashs: str, downloader: Optional[str] = None) -> None: def transfer_completed(self, hashs: str, downloader: Optional[str] = None) -> None:
""" """
@@ -312,6 +311,7 @@ class TransmissionModule(_ModuleBase, _DownloaderBase[Transmission]):
else: else:
tags = ['已整理'] tags = ['已整理']
server.set_torrent_tag(ids=hashs, tags=tags) server.set_torrent_tag(ids=hashs, tags=tags)
return None
def remove_torrents(self, hashs: Union[str, list], delete_file: Optional[bool] = True, def remove_torrents(self, hashs: Union[str, list], delete_file: Optional[bool] = True,
downloader: Optional[str] = None) -> Optional[bool]: downloader: Optional[str] = None) -> Optional[bool]: