GithubBackup/MoviePilot
1
0
Fork 0
mirror of https://github.com/jxxghp/MoviePilot.git synced 2026-09-05 15:38:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(subscribe): update subscription state after download

Browse Source
This commit is contained in:
InfinityPacer
2024-12-11 15:47:45 +08:00
parent a1d8af6521
commit f4dc7a133e
1 changed files with 14 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/chain/subscribe.py
+14 -5
View File
@@ -403,12 +403,16 @@ class SubscribeChain(ChainBase, metaclass=Singleton):
source=self.get_subscribe_source_keyword(subscribe) source=self.get_subscribe_source_keyword(subscribe)
) )
# 同步外部修改，更新订阅信息
subscribe = self.subscribeoper.get(subscribe.id)
# 判断是否应完成订阅 # 判断是否应完成订阅
self.finish_subscribe_or_not(subscribe=subscribe, meta=meta, mediainfo=mediainfo, if subscribe:
downloads=downloads, lefts=lefts) self.finish_subscribe_or_not(subscribe=subscribe, meta=meta, mediainfo=mediainfo,
downloads=downloads, lefts=lefts)
finally: finally:
# 如果状态为N则更新为R # 如果状态为N则更新为R
if subscribe.state == 'N': if subscribe and subscribe.state == 'N':
self.subscribeoper.update(subscribe.id, {'state': 'R'}) self.subscribeoper.update(subscribe.id, {'state': 'R'})
# 手动触发时发送系统消息 # 手动触发时发送系统消息
@@ -794,9 +798,14 @@ class SubscribeChain(ChainBase, metaclass=Singleton):
downloader=subscribe.downloader, downloader=subscribe.downloader,
source=self.get_subscribe_source_keyword(subscribe) source=self.get_subscribe_source_keyword(subscribe)
) )
# 同步外部修改，更新订阅信息
subscribe = self.subscribeoper.get(subscribe.id)
# 判断是否要完成订阅 # 判断是否要完成订阅
self.finish_subscribe_or_not(subscribe=subscribe, meta=meta, mediainfo=mediainfo, if subscribe:
downloads=downloads, lefts=lefts) self.finish_subscribe_or_not(subscribe=subscribe, meta=meta, mediainfo=mediainfo,
downloads=downloads, lefts=lefts)
logger.debug(f"match Lock released at {datetime.now()}") logger.debug(f"match Lock released at {datetime.now()}")
def check(self): def check(self):