diff --git a/app/chain/message.py b/app/chain/message.py index a47700d0..a51341d8 100644 --- a/app/chain/message.py +++ b/app/chain/message.py @@ -130,6 +130,14 @@ class MessageChain(ChainBase): elif cache_type == "Subscribe": # 订阅媒体 mediainfo: MediaInfo = cache_list[int(text) - 1] + # 查询缺失的媒体信息 + exist_flag, _ = self.downloadchain.get_no_exists_info(meta=self._current_meta, + mediainfo=self._current_media) + if exist_flag: + self.post_message(title=f"{self._current_media.title_year}" + f"{self._current_meta.sea} 媒体库中已存在", + userid=userid) + return self.subscribechain.add(title=mediainfo.title, year=mediainfo.year, mtype=mediainfo.type,