test

main.py

@@ -320,7 +320,6 @@ async def tg_show_task(update: Update, context: CallbackContext):
 
 # 处理任务操作的回调
 async def handle_tasks_operation(update: Update, context: CallbackContext):
-    logging.debug(f"Received callback: {update.callback_query.data}")  # 打印回调数据
     query = update.callback_query
     await query.answer()
 
@@ -358,10 +357,41 @@ 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,
@@ -391,29 +421,7 @@ async def init_client():
     if TG_BOT_TOKEN is None:
         print("未设置TG_BOT_TOKEN无法实现TG机器人功能！")
     else:
-        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")
-        )
+        asyncio.create_task(run_telegram_bot())
 
 
 # FastAPI 路由：接收来自 Telegram 的 Webhook 回调