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

fix

Browse Source
This commit is contained in:
jxxghp
2023-06-09 18:38:40 +08:00
parent 13b1ab4aac
commit 77b755da5f
1 changed files with 11 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -35,15 +35,15 @@ class Telegram(metaclass=Singleton):
def echo_all(message): def echo_all(message):
RequestUtils(timeout=5).post_res(self._ds_url, json=message.json) RequestUtils(timeout=5).post_res(self._ds_url, json=message.json)
def run_polling(): def run_polling():
""" """
定义线程函数来运行 infinity_polling 定义线程函数来运行 infinity_polling
""" """
_bot.infinity_polling(long_polling_timeout=5) _bot.infinity_polling(long_polling_timeout=5)
# 启动线程来运行 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()
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]:
""" """
@@ -183,5 +183,6 @@ class Telegram(metaclass=Singleton):
""" """
停止Telegram消息接收服务 停止Telegram消息接收服务
""" """
self._bot.stop_polling() if not self._bot:
self._polling_thread.join() self._bot.stop_polling()
self._polling_thread.join()