From d0c0bf70346efca3d158662e73d9e8838ffe4a25 Mon Sep 17 00:00:00 2001
From: "2569718930@qq.com" <2569718930@qq.com>
Date: Tue, 9 Jun 2026 12:57:37 +0800
Subject: [PATCH] Fix Telegram bot binding fallback

---
 frontend/components/account/AccountCenter.tsx | 18 +++--
 .../account/__tests__/paymentShell.test.ts    | 21 ++++++
 frontend/components/account/account-copy.ts   | 10 ++-
 .../components/account/useAccountPayment.ts   |  2 +
 frontend/components/account/useBilling.ts     | 67 ++++++++++++++++---
 src/bot/handlers/basic.py                     | 33 +++++++++
 tests/test_bot_basic_handler.py               | 50 ++++++++++++++
 tests/test_web_observability.py               |  4 ++
 web/services/auth_api.py                      |  2 +
 9 files changed, 189 insertions(+), 18 deletions(-)

diff --git a/frontend/components/account/AccountCenter.tsx b/frontend/components/account/AccountCenter.tsx
index dae95610..10d634dd 100644
--- a/frontend/components/account/AccountCenter.tsx
+++ b/frontend/components/account/AccountCenter.tsx
@@ -102,6 +102,7 @@ export function AccountCenter() {
     lastPaymentStartedAt,
     telegramBindOpening,
     telegramBindUrl,
+    telegramBindCommand,
     manualPayment,
     manualTxHash,
     txValidation,
@@ -175,6 +176,7 @@ export function AccountCenter() {
     submitManualPaymentTx,
     validateTxHash,
     handleOverlayCheckout,
+    createTelegramBotBindCommand,
     openTelegramBotBindLink,
   } = useAccountPayment({
     isEn,
@@ -497,9 +499,7 @@ export function AccountCenter() {
     : monthlyReferralLimit * referralRewardPoints;
 
   // ── Telegram bind command ──────────────────────────────
-  const bindCommand = userId
-    ? `/bind ${userId}${email ? ` ${email}` : ""}`
-    : "/bind <supabase_user_id> <email>";
+  const bindCommand = telegramBindCommand || copy.telegramBindCommandPlaceholder;
 
   // ── Copy handler ──────────────────────────────────────
   const handleCopy = (text: string) => {
@@ -509,6 +509,13 @@ export function AccountCenter() {
     });
   };
 
+  const handleCopyTelegramBindCommand = async () => {
+    if (!isAuthenticated || telegramBindOpening) return;
+    const command = await createTelegramBotBindCommand();
+    if (!command) return;
+    handleCopy(command);
+  };
+
   const applyReferralCode = useCallback(async () => {
     const code = referralCodeInput.trim();
     if (!code || referralApplying) return;
@@ -1040,8 +1047,9 @@ export function AccountCenter() {
                         : copy.telegramBotBindLink}
                     </button>
                     <button
-                      onClick={() => handleCopy(bindCommand)}
-                      className="rounded-xl border border-blue-700 bg-blue-600 p-4 text-white shadow-sm transition-all hover:bg-blue-700"
+                      onClick={() => void handleCopyTelegramBindCommand()}
+                      disabled={telegramBindOpening || !isAuthenticated}
+                      className="rounded-xl border border-blue-700 bg-blue-600 p-4 text-white shadow-sm transition-all hover:bg-blue-700 disabled:cursor-not-allowed disabled:opacity-50"
                       title={copy.copyCommand}
                       aria-label={copy.copyCommand}
                     >
diff --git a/frontend/components/account/__tests__/paymentShell.test.ts b/frontend/components/account/__tests__/paymentShell.test.ts
index f5e2cebf..11207c9d 100644
--- a/frontend/components/account/__tests__/paymentShell.test.ts
+++ b/frontend/components/account/__tests__/paymentShell.test.ts
@@ -62,6 +62,10 @@ export function runTests() {
     path.join(accountDir, "usePaymentFlow.ts"),
     "utf8",
   );
+  const useBillingSource = fs.readFileSync(
+    path.join(accountDir, "useBilling.ts"),
+    "utf8",
+  );
   assert(
     (accountCenterSource.includes('import { usePaymentState } from "./usePaymentState";') ||
       hookSource.includes('import { usePaymentState } from "./usePaymentState";')) &&
@@ -193,6 +197,23 @@ export function runTests() {
       accountCenterSource.includes('hasTelegramPanel ? "" : "sm:grid-cols-2"'),
     "payment management must only split into internal columns when it is not already sharing the row with a Telegram panel",
   );
+  assert(
+    !accountCenterSource.includes("`/bind ${userId}${email ? ` ${email}` : \"\"}`") &&
+      !accountCenterSource.includes("/bind <supabase_user_id> <email>"),
+    "Telegram fallback copy must not expose the legacy /bind supabase_user_id command",
+  );
+  assert(
+    accountCenterSource.includes("telegramBindCommand") &&
+      accountCenterSource.includes("createTelegramBotBindCommand") &&
+      accountCenterSource.includes("handleCopyTelegramBindCommand"),
+    "account Telegram fallback copy must generate a fresh one-time /start bind token before copying",
+  );
+  assert(
+    useBillingSource.includes("bot_command") &&
+      useBillingSource.includes("createTelegramBotBindCommand") &&
+      useBillingSource.includes("telegramBindCommand"),
+    "billing hook must persist the backend /start bind token command for Telegram fallback copy",
+  );
   assert(
     !appAnalyticsSource.includes('NEXT_PUBLIC_POLYWEATHER_APP_ANALYTICS === "true"') &&
       !analyticsRouteSource.includes('NEXT_PUBLIC_POLYWEATHER_APP_ANALYTICS === "true"'),
diff --git a/frontend/components/account/account-copy.ts b/frontend/components/account/account-copy.ts
index 12ba113b..9802cec4 100644
--- a/frontend/components/account/account-copy.ts
+++ b/frontend/components/account/account-copy.ts
@@ -46,8 +46,14 @@ export function createAccountCopy(isEn: boolean): Record<string, string> {
         ? "Use one-click Telegram binding first to sync notifications and access. After binding, refresh this page and submit your Telegram group join request."
         : "优先使用「一键绑定 Telegram Bot」同步通知与权限。绑定完成后刷新本页，再提交 Telegram 群组入群申请。",
       telegramFallbackHint: isEn
-        ? "Fallback copy method: only use this if one-click binding does not open Telegram correctly. Copy the command below and send it to @polyyuanbot. After binding, refresh this page to show the group entry."
-        : "兜底复制方式：仅在一键绑定无法正常打开 Telegram 时使用。请复制下方命令并发送给 @polyyuanbot。绑定完成后刷新本页，即可显示入群入口。",
+        ? "Fallback copy method: click Copy to generate a 10-minute one-time /start bind command, send it to @polyyuanbot, then confirm binding in the Bot and refresh this page."
+        : "兜底复制方式：点击复制会生成 10 分钟有效的一次性 /start bind 命令。请把它发送给 @polyyuanbot，并在 Bot 内确认绑定后刷新本页。",
+      telegramBindCommandPlaceholder: isEn
+        ? "Click Copy to generate a one-time /start bind command"
+        : "点击复制生成一次性 /start bind 命令",
+      telegramBindCommandCopied: isEn
+        ? "One-time Telegram bind command generated and copied. Send it to @polyyuanbot, then confirm binding in the Bot."
+        : "一次性 Telegram 绑定命令已生成并复制。请发送给 @polyyuanbot，然后在 Bot 内确认绑定。",
       paymentManualSupport: isEn
         ? "If payment succeeds but Pro is still not activated, email yhrsc30@gmail.com. This project is currently maintained by one developer, so manual recovery may be needed in edge cases."
         : "如果付款成功后 Pro 仍未开通，请发邮件到 yhrsc30@gmail.com。当前项目由我一人维护，极少数边缘情况可能需要人工补开。给你带来的不便，敬请谅解！",
diff --git a/frontend/components/account/useAccountPayment.ts b/frontend/components/account/useAccountPayment.ts
index 8cd5ba9b..e9a599e7 100644
--- a/frontend/components/account/useAccountPayment.ts
+++ b/frontend/components/account/useAccountPayment.ts
@@ -549,6 +549,7 @@ export function useAccountPayment(params: UseAccountPaymentParams) {
     lastPaymentStartedAt,
     telegramBindOpening,
     telegramBindUrl: billing.telegramBindUrl,
+    telegramBindCommand: billing.telegramBindCommand,
     manualPayment,
     manualTxHash,
     txValidation,
@@ -622,6 +623,7 @@ export function useAccountPayment(params: UseAccountPaymentParams) {
     submitManualPaymentTx: paymentFlow.submitManualPaymentTx,
     validateTxHash: paymentFlow.validateTxHash,
     handleOverlayCheckout: paymentFlow.handleOverlayCheckout,
+    createTelegramBotBindCommand: billing.createTelegramBotBindCommand,
     openTelegramBotBindLink: billing.openTelegramBotBindLink,
   };
 }
diff --git a/frontend/components/account/useBilling.ts b/frontend/components/account/useBilling.ts
index 7100f5f7..c573ffd6 100644
--- a/frontend/components/account/useBilling.ts
+++ b/frontend/components/account/useBilling.ts
@@ -23,6 +23,12 @@ import { isTelegramPrivateGroupPriceEligible } from "./telegram-pricing";
 import { trackAppEvent } from "@/lib/app-analytics";
 
 // ============================================================
+type TelegramBotBindPayload = {
+  bot_command?: string;
+  bot_url?: string;
+  start_param?: string;
+};
+
 export interface UseBillingParams {
   isEn: boolean;
   copy: Record<string, string>;
@@ -96,6 +102,7 @@ export function useBilling(params: UseBillingParams) {
   // ── Billing-specific state ────────────────────────────────
   const [reconcileBusy, setReconcileBusy] = useState(false);
   const [telegramBindUrl, setTelegramBindUrl] = useState("");
+  const [telegramBindCommand, setTelegramBindCommand] = useState("");
 
   // ── Derived values ──────────────────────────────────────
   const paymentReadyForRecovery = Boolean(paymentConfig?.enabled && paymentConfig?.configured);
@@ -273,23 +280,59 @@ export function useBilling(params: UseBillingParams) {
     [buildAuthedHeaders, copy, loadPaymentSnapshot, refreshEntitlementAfterPayment, reconcileLatestPayment],
   );
 
-  // ── openTelegramBotBindLink ──────────────────────────────
+  // ── Telegram bot bind helpers ─────────────────────────────
+  const requestTelegramBotBindPayload = useCallback(async () => {
+    const authHeaders = await buildAuthedHeaders(true, false);
+    const res = await fetch("/api/auth/telegram/bot-bind-link", {
+      method: "POST",
+      headers: authHeaders,
+    });
+    if (!res.ok) {
+      const raw = (await res.text()).slice(0, 300);
+      throw new Error(raw || copy.telegramBindFailed);
+    }
+    const data = (await res.json()) as TelegramBotBindPayload;
+    const botUrl = String(data.bot_url || "").trim();
+    const startParam = String(data.start_param || "").trim();
+    const botCommand = String(
+      data.bot_command || (startParam ? `/start ${startParam}` : ""),
+    ).trim();
+    if (!botUrl && !botCommand) throw new Error(copy.telegramBindLinkMissing);
+    setTelegramBindUrl(botUrl);
+    setTelegramBindCommand(botCommand);
+    return { botCommand, botUrl };
+  }, [
+    buildAuthedHeaders,
+    copy.telegramBindFailed,
+    copy.telegramBindLinkMissing,
+  ]);
+
+  const createTelegramBotBindCommand = async () => {
+    setTelegramBindOpening(true);
+    setPaymentError("");
+    setTelegramBindUrl("");
+    setTelegramBindCommand("");
+    try {
+      const { botCommand } = await requestTelegramBotBindPayload();
+      if (!botCommand) throw new Error(copy.telegramBindLinkMissing);
+      setPaymentInfo(copy.telegramBindCommandCopied);
+      return botCommand;
+    } catch (error) {
+      setPaymentError(normalizePaymentError(error).message);
+      return "";
+    } finally {
+      setTelegramBindOpening(false);
+    }
+  };
+
   const openTelegramBotBindLink = async () => {
     setTelegramBindOpening(true);
     setPaymentError("");
     setTelegramBindUrl("");
+    setTelegramBindCommand("");
     const popup = window.open("about:blank", "_blank", "noopener,noreferrer");
     try {
-      const authHeaders = await buildAuthedHeaders(true, false);
-      const res = await fetch("/api/auth/telegram/bot-bind-link", {
-        method: "POST", headers: authHeaders,
-      });
-      if (!res.ok) {
-        const raw = (await res.text()).slice(0, 300);
-        throw new Error(raw || copy.telegramBindFailed);
-      }
-      const data = (await res.json()) as { bot_url?: string };
-      const botUrl = String(data.bot_url || "").trim();
+      const { botUrl } = await requestTelegramBotBindPayload();
       if (!botUrl) throw new Error(copy.telegramBindLinkMissing);
       if (popup && !popup.closed) {
         popup.location.href = botUrl;
@@ -423,9 +466,11 @@ export function useBilling(params: UseBillingParams) {
   return {
     reconcileBusy,
     telegramBindUrl,
+    telegramBindCommand,
     setTelegramBindUrl,
     reconcileLatestPayment,
     handleSubmit409,
+    createTelegramBotBindCommand,
     openTelegramBotBindLink,
     paymentReadyForRecovery,
     hasRecentPaymentRecovery,
diff --git a/src/bot/handlers/basic.py b/src/bot/handlers/basic.py
index 506ddb41..49fae280 100644
--- a/src/bot/handlers/basic.py
+++ b/src/bot/handlers/basic.py
@@ -8,6 +8,7 @@ from typing import Callable
 from loguru import logger  # type: ignore
 
 from src.bot.command_parser import extract_command_name
+from src.bot.command_parser import looks_like_slash_command
 from src.bot.io_layer import BotIOLayer
 from src.bot.observability import CommandTrace
 from src.bot.runtime_coordinator import RuntimeStatus, render_runtime_status_html
@@ -86,6 +87,13 @@ class BasicCommandHandler:
         def _basic_text(message):
             self._dispatch(message)
 
+        @self.bot.message_handler(
+            content_types=["text"],
+            func=self._is_private_text_fallback,
+        )
+        def _private_text_fallback(message):
+            self.handle_private_text_fallback(message)
+
     def _dispatch(self, message: Any) -> None:
         command = extract_command_name(
             getattr(message, "text", None),
@@ -134,6 +142,31 @@ class BasicCommandHandler:
         finally:
             trace.emit()
 
+    @staticmethod
+    def _is_private_text_fallback(message: Any) -> bool:
+        text = str(getattr(message, "text", "") or "").strip()
+        chat_type = str(getattr(getattr(message, "chat", None), "type", "") or "").strip().lower()
+        return bool(text and chat_type == "private" and not looks_like_slash_command(text))
+
+    def handle_private_text_fallback(self, message: Any) -> str:
+        text = str(getattr(message, "text", "") or "").strip()
+        if looks_like_slash_command(text):
+            return "ignored:slash_command"
+        chat_type = str(getattr(getattr(message, "chat", None), "type", "") or "").strip().lower()
+        if chat_type != "private":
+            return "ignored:not_private"
+        self.bot.reply_to(
+            message,
+            (
+                "我收到了，但这不是可执行命令。\n\n"
+                "如果你正在绑定网站账号：请在网页账户页点击“复制兜底命令”，"
+                "然后把生成的 <code>/start bind_...</code> 发到这里。\n\n"
+                "也可以发送 <code>/help</code> 查看可用命令。"
+            ),
+            parse_mode="HTML",
+        )
+        return "replied"
+
     def _prompt_bind_from_web_token(self, message: Any, token: str) -> str:
         if not token:
             self.bot.reply_to(message, "❌ 绑定链接无效，请回到网页重新点击一键绑定。")
diff --git a/tests/test_bot_basic_handler.py b/tests/test_bot_basic_handler.py
index b8005a19..aa8d1973 100644
--- a/tests/test_bot_basic_handler.py
+++ b/tests/test_bot_basic_handler.py
@@ -181,6 +181,56 @@ def test_confirm_bind_callback_consumes_token_and_binds_account():
     assert bound[0]["supabase_user_id"] == "user-1"
 
 
+def test_private_text_fallback_replies_with_binding_help():
+    bot = DummyBot()
+    io_layer = SimpleNamespace(
+        build_welcome_text=lambda: "WELCOME",
+        build_points_rank_text=lambda _user: "TOP",
+    )
+    handler = BasicCommandHandler(
+        bot=bot,
+        io_layer=io_layer,
+        runtime_status_provider=lambda: RuntimeStatus(
+            started_at="2026-03-12 00:00:00 UTC",
+            loops=[],
+            command_access_mode="group_member",
+            protected_commands=["/city", "/deb"],
+            required_group_chat_id="-1001234567890",
+        ),
+    )
+
+    result = handler.handle_private_text_fallback(_message("@polyyuanbot"))
+
+    assert result == "replied"
+    assert len(bot.replies) == 1
+    assert "/start bind_" in bot.replies[0]["text"]
+    assert "/help" in bot.replies[0]["text"]
+
+
+def test_private_text_fallback_ignores_slash_commands():
+    bot = DummyBot()
+    io_layer = SimpleNamespace(
+        build_welcome_text=lambda: "WELCOME",
+        build_points_rank_text=lambda _user: "TOP",
+    )
+    handler = BasicCommandHandler(
+        bot=bot,
+        io_layer=io_layer,
+        runtime_status_provider=lambda: RuntimeStatus(
+            started_at="2026-03-12 00:00:00 UTC",
+            loops=[],
+            command_access_mode="group_member",
+            protected_commands=["/city", "/deb"],
+            required_group_chat_id="-1001234567890",
+        ),
+    )
+
+    result = handler.handle_private_text_fallback(_message("/city seoul"))
+
+    assert result == "ignored:slash_command"
+    assert bot.replies == []
+
+
 def test_basic_handler_markets_returns_summary():
     bot = DummyBot()
     io_layer = SimpleNamespace(
diff --git a/tests/test_web_observability.py b/tests/test_web_observability.py
index db2a07b7..b76d2784 100644
--- a/tests/test_web_observability.py
+++ b/tests/test_web_observability.py
@@ -1805,6 +1805,10 @@ def test_telegram_identity_endpoints_skip_subscription_gate(monkeypatch):
         headers=auth_headers,
     )
     assert link_response.status_code == 200
+    link_payload = link_response.json()
+    assert link_payload["start_param"] == "bind_bind-token"
+    assert link_payload["bot_command"] == "/start bind_bind-token"
+    assert link_payload["bot_url"].endswith("?start=bind_bind-token")
 
 
 def test_auth_me_does_not_reconcile_on_status_probe(monkeypatch):
diff --git a/web/services/auth_api.py b/web/services/auth_api.py
index 9c1b3e13..bc3c506b 100644
--- a/web/services/auth_api.py
+++ b/web/services/auth_api.py
@@ -459,10 +459,12 @@ def create_telegram_bot_bind_link(request: Request) -> Dict[str, Any]:
         or "polyyuanbot"
     ).strip().lstrip("@")
     bot_url = f"https://t.me/{bot_username}?start={start_param}"
+    bot_command = f"/start {start_param}"
     return {
         "ok": True,
         "token": token,
         "start_param": start_param,
+        "bot_command": bot_command,
         "bot_url": bot_url,
         "expires_in_seconds": 600,
     }