Fix

main.py

@@ -357,41 +357,10 @@ async def perform_task_action(
         await update.callback_query.edit_message_text(f"你选择了取消任务：{file_id}")
 
 
-# 在 FastAPI 中启动 Telegram Bot 的异步任务
-async def run_telegram_bot():
-    # 创建 Application 对象
-    global TG_BOT_APPLICATION
-    TG_BOT_APPLICATION = (
-        Application.builder().base_url(TG_BASE_URL).token(TG_BOT_TOKEN).build()
-    )
-    # await TG_BOT_APPLICATION.bot.delete_webhook()
-    await TG_BOT_APPLICATION.bot.set_webhook(TG_WEBHOOK_URL)
-    await TG_BOT_APPLICATION.initialize()
-    # 将命令处理函数添加到 dispatcher
-    TG_BOT_APPLICATION.add_handler(CommandHandler("start", start))
-    TG_BOT_APPLICATION.add_handler(CommandHandler("help", help))
-    TG_BOT_APPLICATION.add_handler(CommandHandler("quota", quota))
-    TG_BOT_APPLICATION.add_handler(CommandHandler("emptytrash", tg_emptytrash))
-    TG_BOT_APPLICATION.add_handler(CommandHandler("tasks", tg_show_task))
-    TG_BOT_APPLICATION.add_handler(
-        CallbackQueryHandler(handle_tasks_operation, pattern="^delete_task:")
-    )
-    # 处理取消任务操作
-    TG_BOT_APPLICATION.add_handler(
-        CallbackQueryHandler(handle_task_cancel, pattern="^cancel_task")
-    )
-    # 处理确认操作（确认删除、复制等）
-    TG_BOT_APPLICATION.add_handler(
-        CallbackQueryHandler(handle_task_confirmation, pattern="^confirm_task")
-    )
-
-    # 启动机器人
-    await TG_BOT_APPLICATION.run_polling()
-
-
 @app.on_event("startup")
 async def init_client():
     global THUNDERX_CLIENT
+    global TG_BOT_APPLICATION
     if not os.path.exists("thunderx.txt"):
         THUNDERX_CLIENT = PikPakApi(
             username=THUNDERX_USERNAME,
@@ -421,7 +390,29 @@ async def init_client():
     if TG_BOT_TOKEN is None:
         print("未设置TG_BOT_TOKEN无法实现TG机器人功能！")
     else:
-        asyncio.create_task(run_telegram_bot())
+        TG_BOT_APPLICATION = (
+            Application.builder().base_url(TG_BASE_URL).token(TG_BOT_TOKEN).build()
+        )
+        # await TG_BOT_APPLICATION.bot.delete_webhook()
+        await TG_BOT_APPLICATION.bot.set_webhook(TG_WEBHOOK_URL)
+        await TG_BOT_APPLICATION.initialize()
+        # 将命令处理函数添加到 dispatcher
+        TG_BOT_APPLICATION.add_handler(CommandHandler("start", start))
+        TG_BOT_APPLICATION.add_handler(CommandHandler("help", help))
+        TG_BOT_APPLICATION.add_handler(CommandHandler("quota", quota))
+        TG_BOT_APPLICATION.add_handler(CommandHandler("emptytrash", tg_emptytrash))
+        TG_BOT_APPLICATION.add_handler(CommandHandler("tasks", tg_show_task))
+        TG_BOT_APPLICATION.add_handler(
+            CallbackQueryHandler(handle_tasks_operation, pattern="^delete_task:")
+        )
+        # 处理取消任务操作
+        TG_BOT_APPLICATION.add_handler(
+            CallbackQueryHandler(handle_task_cancel, pattern="^cancel_task")
+        )
+        # 处理确认操作（确认删除、复制等）
+        TG_BOT_APPLICATION.add_handler(
+            CallbackQueryHandler(handle_task_confirmation, pattern="^confirm_task")
+        )
 
 
 # FastAPI 路由：接收来自 Telegram 的 Webhook 回调