fix douban sync

This commit is contained in:
jxxghp
2023-06-07 21:58:42 +08:00
parent d79d5d1d7e
commit 08ae0a434a
3 changed files with 9 additions and 3 deletions

View File

@ -354,9 +354,6 @@ class CommonChain(_ChainBase):
if not no_exists:
no_exists = {}
if not mediainfo.seasons:
logger.error(f"媒体信息中没有季集信息:{mediainfo.get_title_string()}")
return False, {}
if mediainfo.type == MediaType.MOVIE:
# 电影
exists_movies: Optional[dict] = self.run_module("media_exists", mediainfo)
@ -365,6 +362,9 @@ class CommonChain(_ChainBase):
return True, {}
return False, {}
else:
if not mediainfo.seasons:
logger.error(f"媒体信息中没有季集信息:{mediainfo.get_title_string()}")
return False, {}
# 电视剧
exists_tvs: Optional[dict] = self.run_module("media_exists", mediainfo)
if not exists_tvs:

View File

@ -60,6 +60,7 @@ class DoubanSyncChain(_ChainBase):
if not doubaninfo:
logger.warn(f'未获取到豆瓣信息,标题:{title}豆瓣ID{douban_id}')
continue
logger.info(f'获取到豆瓣信息,标题:{title}豆瓣ID{douban_id}')
# 识别媒体信息
meta = MetaInfo(doubaninfo.get("original_title") or doubaninfo.get("title"))
if doubaninfo.get("year"):
@ -75,6 +76,7 @@ class DoubanSyncChain(_ChainBase):
if exist_flag:
logger.info(f'{mediainfo.get_title_string()} 媒体库中已存在')
continue
logger.info(f'{mediainfo.get_title_string()} 媒体库中不存在,开始搜索 ...')
# 搜索
contexts = self.searchchain.process(meta=meta, mediainfo=mediainfo)
if not contexts:

View File

@ -85,6 +85,7 @@ class UserMessageChain(_ChainBase):
self.common.post_message(
title=f"{mediainfo.type.value} {mediainfo.get_title_string()} 媒体库中已存在", userid=userid)
return
logger.info(f"{mediainfo.get_title_string()} 媒体库中不存在,开始搜索 ...")
# 搜索种子
contexts = self.searchchain.process(meta=self._current_meta, mediainfo=mediainfo)
if not contexts:
@ -98,6 +99,7 @@ class UserMessageChain(_ChainBase):
}
self._current_page = 0
# 发送种子数据
logger.info(f"搜索到 {len(contexts)} 条数据,开始发送选择消息 ...")
self.__post_torrents_message(items=contexts[:self._page_size], userid=userid)
elif cache_type == "Subscribe":
@ -130,6 +132,7 @@ class UserMessageChain(_ChainBase):
else:
# 下载种子
torrent: TorrentInfo = cache_list[int(text) - 1]
logger.info(f"开始下载种子:{torrent.title} - {torrent.enclosure}")
meta: MetaBase = MetaInfo(torrent.title)
torrent_file, _, _, _, error_msg = self.torrent.download_torrent(
url=torrent.enclosure,
@ -242,6 +245,7 @@ class UserMessageChain(_ChainBase):
meta.year = year
self._current_meta = meta
# 开始搜索
logger.info(f"开始搜索:{meta.get_name()}")
medias: Optional[List[MediaInfo]] = self.run_module('search_medias', meta=meta)
if not medias:
self.common.post_message(title=f"{meta.get_name()} 没有找到对应的媒体信息!", userid=userid)