feat:手动整理API支持后台

This commit is contained in:
jxxghp
2024-12-25 20:38:00 +08:00
parent a600f2f05b
commit 0ac43fd3c7
2 changed files with 9 additions and 4 deletions

View File

@@ -58,11 +58,13 @@ def query_queue(_: schemas.TokenPayload = Depends(verify_token)) -> Any:
@router.post("/manual", summary="手动转移", response_model=schemas.Response)
def manual_transfer(transer_item: ManualTransferItem,
background: bool = False,
db: Session = Depends(get_db),
_: schemas.TokenPayload = Depends(get_current_active_superuser)) -> Any:
"""
手动转移,文件或历史记录,支持自定义剧集识别格式
:param transer_item: 手工整理项
:param background: 后台运行
:param db: 数据库
:param _: Token校验
"""
@@ -139,7 +141,8 @@ def manual_transfer(transer_item: ManualTransferItem,
scrape=transer_item.scrape,
library_type_folder=transer_item.library_type_folder,
library_category_folder=transer_item.library_category_folder,
force=force
force=force,
background=background
)
# 失败
if not state:

View File

@@ -1032,7 +1032,8 @@ class TransferChain(ChainBase, metaclass=Singleton):
scrape: bool = None,
library_type_folder: bool = None,
library_category_folder: bool = None,
force: bool = False) -> Tuple[bool, Union[str, list]]:
force: bool = False,
background: bool = False) -> Tuple[bool, Union[str, list]]:
"""
手动整理,支持复杂条件,带进度显示
:param fileitem: 文件项
@@ -1049,6 +1050,7 @@ class TransferChain(ChainBase, metaclass=Singleton):
:param library_type_folder: 是否按类型建立目录
:param library_category_folder: 是否按类别建立目录
:param force: 是否强制整理
:param background: 是否后台运行
"""
logger.info(f"手动整理:{fileitem.path} ...")
if tmdbid or doubanid:
@@ -1079,7 +1081,7 @@ class TransferChain(ChainBase, metaclass=Singleton):
library_type_folder=library_type_folder,
library_category_folder=library_category_folder,
force=force,
background=False
background=background
)
if not state:
return False, errmsg
@@ -1100,7 +1102,7 @@ class TransferChain(ChainBase, metaclass=Singleton):
library_type_folder=library_type_folder,
library_category_folder=library_category_folder,
force=force,
background=False)
background=background)
return state, errmsg
def send_transfer_message(self, meta: MetaBase, mediainfo: MediaInfo,