From 08ae0a434ad7ffaf0cdef9b09167085c55ba4cb6 Mon Sep 17 00:00:00 2001
From: jxxghp <jxxghp@gmail.com>
Date: Wed, 7 Jun 2023 21:58:42 +0800
Subject: [PATCH] fix douban sync

---
 app/chain/common.py       | 6 +++---
 app/chain/douban_sync.py  | 2 ++
 app/chain/user_message.py | 4 ++++
 3 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/app/chain/common.py b/app/chain/common.py
index cee9a15b..9a66ea05 100644
--- a/app/chain/common.py
+++ b/app/chain/common.py
@@ -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:
diff --git a/app/chain/douban_sync.py b/app/chain/douban_sync.py
index ff50e5b2..10fb17a2 100644
--- a/app/chain/douban_sync.py
+++ b/app/chain/douban_sync.py
@@ -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:
diff --git a/app/chain/user_message.py b/app/chain/user_message.py
index d9412e53..c267f496 100644
--- a/app/chain/user_message.py
+++ b/app/chain/user_message.py
@@ -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)