codfrm/MoviePilot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix #193

Browse Source
This commit is contained in:
jxxghp
2023-09-05 16:43:02 +08:00
parent c69762d4c9
commit 4cb7a488a9
1 changed files with 16 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
app/chain/transfer.py
View File

@ -323,13 +323,6 @@ class TransferChain(ChainBase):
mediainfo=file_mediainfo, mediainfo=file_mediainfo,
transferinfo=transferinfo transferinfo=transferinfo
) )
# 广播事件
self.eventmanager.send_event(EventType.TransferComplete, {
'meta': file_meta,
'mediainfo': file_mediainfo,
'transferinfo': transferinfo
})
# 更新进度 # 更新进度
processed_num += 1 processed_num += 1
self.progress.update(value=processed_num / total_num * 100, self.progress.update(value=processed_num / total_num * 100,
@ -337,21 +330,30 @@ class TransferChain(ChainBase):
key=ProgressKey.FileTransfer) key=ProgressKey.FileTransfer)
# 目录或文件转移完成 # 目录或文件转移完成
self.progress.update(value=100,
text=f"所有文件转移完成，正在执行后续处理 ...",
key=ProgressKey.FileTransfer)
for mkey, media in medias.items(): for mkey, media in medias.items():
meta = metas[mkey] transfer_meta = metas[mkey]
transferinfo = transfers[mkey] transfer_info = transfers[mkey]
# 刷新媒体库 # 刷新媒体库
self.refresh_mediaserver(mediainfo=media, file_path=transferinfo.target_path) self.refresh_mediaserver(mediainfo=media, file_path=transfer_info.target_path)
# 刮削 # 刮削
self.scrape_metadata(path=transferinfo.target_path, mediainfo=media) self.scrape_metadata(path=transfer_info.target_path, mediainfo=media)
# 发送通知 # 发送通知
se_str = None se_str = None
if media.type == MediaType.TV: if media.type == MediaType.TV:
se_str = f"{meta.season} {StringUtils.format_ep(season_episodes[mkey])}" se_str = f"{transfer_meta.season} {StringUtils.format_ep(season_episodes[mkey])}"
self.send_transfer_message(meta=meta, self.send_transfer_message(meta=transfer_meta,
mediainfo=media, mediainfo=media,
transferinfo=transferinfo, transferinfo=transfer_info,
season_episode=se_str) season_episode=se_str)
# 广播事件
self.eventmanager.send_event(EventType.TransferComplete, {
'meta': transfer_meta,
'mediainfo': media,
'transferinfo': transfer_info
})
# 结束进度 # 结束进度
logger.info(f"{path} 转移完成，共 {total_num} 个文件，" logger.info(f"{path} 转移完成，共 {total_num} 个文件，"
f"成功 {total_num - len(err_msgs)} 个，失败 {len(err_msgs)} 个") f"成功 {total_num - len(err_msgs)} 个，失败 {len(err_msgs)} 个")