d0zingcat/MoviePilot-Plugins
1
0
Fork 0
mirror of https://github.com/d0zingcat/MoviePilot-Plugins.git synced 2026-05-13 23:16:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: logic

Browse Source
This commit is contained in:
so1ve
2025-02-04 15:22:24 +08:00
parent 2f4df5a77b
commit 5169d8dea4
1 changed files with 21 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
plugins.v2/torrenttransfer/__init__.py
View File

@@ -818,23 +818,21 @@ class TorrentTransfer(_PluginBase):
# 下载成功
logger.info(f"成功添加转移做种任务，种子文件：{torrent_file}")
if self._skipverify:
# 跳过校验
logger.info(f"{download_id} 跳过校验，请自行检查...")
# 请注意这里是故意不自动开始的
# 跳过校验存在直接失败、种子目录相同文件不同等异常情况
# 必须要用户自行二次确认之后才能开始做种
# 否则会出现反复下载刷掉分享率、做假种的情况
# TR会自动校验，QB需要手动校验
if self.downloader_helper.is_downloader("qbittorrent", service=to_service):
if self._skipverify:
if self._autostart:
logger.info(f"{download_id} 跳过校验，开启自动开始，注意观察种子的完整性")
self.__add_recheck_torrents(to_service, download_id)
else:
# 跳过校验
logger.info(f"{download_id} 跳过校验，请自行检查手动开始任务...")
else:
logger.info(f"qbittorrent 开始校验 {download_id} ...")
to_downloader.recheck_torrents(ids=[download_id])
self.__add_recheck_torrents(to_service, download_id)
else:
# 追加校验任务
logger.info(f"添加校验检查任务：{download_id} ...")
if not self._recheck_torrents.get(to_service.name):
self._recheck_torrents[to_service.name] = []
self._recheck_torrents[to_service.name].append(download_id)
# TR会自动校验，QB需要手动校验
if self.downloader_helper.is_downloader("qbittorrent", service=to_service):
logger.info(f"qbittorrent 开始校验 {download_id} ...")
to_downloader.recheck_torrents(ids=[download_id])
self.__add_recheck_torrents(to_service, download_id)
# 删除源种子，不能删除文件！
if self._deletesource:
@@ -867,6 +865,13 @@ class TorrentTransfer(_PluginBase):
logger.info(f"没有需要转移的种子")
logger.info("转移做种任务执行完成")
def __add_recheck_torrents(self, service: ServiceInfo, download_id: str):
# 追加校验任务
logger.info(f"添加校验检查任务：{download_id} ...")
if not self._recheck_torrents.get(service.name):
self._recheck_torrents[service.name] = []
self._recheck_torrents[service.name].append(download_id)
def check_recheck(self):
"""
定时检查下载器中种子是否校验完成，校验完成且完整的自动开始辅种