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

fix telegram

Browse Source
This commit is contained in:
jxxghp
2023-06-13 08:29:35 +08:00
parent 3d410e6d0b
commit 6e2f40cae6
1 changed files with 15 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
app/modules/telegram/telegram.py
View File

@ -51,11 +51,15 @@ class Telegram(metaclass=Singleton):
""" """
定义线程函数来运行 infinity_polling 定义线程函数来运行 infinity_polling
""" """
_bot.infinity_polling(long_polling_timeout=5) try:
_bot.infinity_polling(long_polling_timeout=5)
except Exception as err:
logger.error(f"Telegram消息接收服务异常：{err}")
# 启动线程来运行 infinity_polling # 启动线程来运行 infinity_polling
self._polling_thread = threading.Thread(target=run_polling) self._polling_thread = threading.Thread(target=run_polling)
self._polling_thread.start() self._polling_thread.start()
logger.info("Telegram消息接收服务启动")
def send_msg(self, title: str, text: str = "", image: str = "", userid: str = "") -> Optional[bool]: def send_msg(self, title: str, text: str = "", image: str = "", userid: str = "") -> Optional[bool]:
""" """
@ -104,17 +108,17 @@ class Telegram(metaclass=Singleton):
image = media.get_message_image() image = media.get_message_image()
if media.vote_average: if media.vote_average:
caption = "%s\n%s. [%s](%s)\n_%s，%s_" % (caption, caption = "%s\n%s. [%s](%s)\n_%s，%s_" % (caption,
index, index,
media.get_title_string(), media.get_title_string(),
media.get_detail_url(), media.get_detail_url(),
f"类型：{media.type.value}", f"类型：{media.type.value}",
f"评分：{media.vote_average}") f"评分：{media.vote_average}")
else: else:
caption = "%s\n%s. [%s](%s)\n_%s_" % (caption, caption = "%s\n%s. [%s](%s)\n_%s_" % (caption,
index, index,
media.get_title_string(), media.get_title_string(),
media.get_detail_url(), media.get_detail_url(),
f"类型：{media.type.value}") f"类型：{media.type.value}")
index += 1 index += 1
if userid: if userid:
@ -214,3 +218,4 @@ class Telegram(metaclass=Singleton):
if self._bot: if self._bot:
self._bot.stop_polling() self._bot.stop_polling()
self._polling_thread.join() self._polling_thread.join()
logger.info("Telegram消息接收服务已停止")