feat(accounts): 添加账户导入对话框功能

- 实现了支持多种导入方式的对话框组件
- 添加了 Access Token 文本导入和 TXT 文件批量导入功能
- 集成了 Session JSON 和 CPA JSON 文件导入方式
- 实现了导入过程中的 Token 解析和验证机制
- 添加了导入确认对话框防止误操作
- 集成了 Toast 提示反馈导入结果

README.md

@@ -49,12 +49,13 @@ POST /v1/images/generations
 
 ```bash
 git clone git@github.com:basketikun/chatgpt2api.git
-cp config.example.json config.json
-# 编辑 config.json密钥
+# 首次启动会自动生成 config.json，也可以手动复制后修改
+# cp config.example.json config.json
+# 可按需编辑 config.json 的密钥和 `refresh_account_interval_minute`
 docker compose up -d
 ```
 
 ## 社区支持
 学 AI , 上 L 站
 
-[LinuxDO](https://linux.do)
+[LinuxDO](https://linux.do)

config.example.json

@@ -1,4 +1,4 @@
 {
-  "auth-key": "replace-with-your-auth-key",
-  "tls-verify": true
+  "auth-key": "chatgpt2api",
+  "refresh_account_interval_minute": 60
 }

services/account_service.py

@@ -361,7 +361,7 @@ class AccountService:
 
         headers, impersonate = self._build_remote_headers(access_token)
         print(f"[account-refresh] start {access_token[:12]}...")
-        session = Session(impersonate=impersonate, verify=config.tls_verify)
+        session = Session(impersonate=impersonate, verify=True)
         session.headers.update(headers)
         try:
             with ThreadPoolExecutor(max_workers=2) as executor:

services/api.py

@@ -13,6 +13,7 @@ from pydantic import BaseModel, Field
 from services.account_service import account_service
 from services.config import config
 from services.backend_service import BackendService
+from services.chat_image_service import ChatImageService
 from services.image_service import ImageGenerationError
 from services.version import get_app_version
 
@@ -70,6 +71,8 @@ def require_auth_key(authorization: str | None) -> None:
 
 
 def start_limited_account_watcher(stop_event: Event) -> Thread:
+    interval_seconds = config.refresh_account_interval_minute * 60
+
     def worker() -> None:
         while not stop_event.is_set():
             try:
@@ -79,7 +82,7 @@ def start_limited_account_watcher(stop_event: Event) -> Thread:
                     account_service.refresh_accounts(limited_tokens)
             except Exception as exc:
                 print(f"[account-limited-watcher] fail {exc}")
-            stop_event.wait(300)
+            stop_event.wait(interval_seconds)
 
     thread = Thread(target=worker, name="limited-account-watcher", daemon=True)
     thread.start()
@@ -114,6 +117,7 @@ def resolve_web_asset(requested_path: str) -> Path | None:
 
 def create_app() -> FastAPI:
     service = BackendService(account_service)
+    chat_image_service = ChatImageService(service)
     app_version = get_app_version()
 
     @asynccontextmanager
@@ -245,6 +249,14 @@ def create_app() -> FastAPI:
         except ImageGenerationError as exc:
             raise HTTPException(status_code=502, detail={"error": str(exc)}) from exc
 
+    @router.post("/v1/chat/completions")
+    async def create_chat_completion(
+            body: dict[str, object],
+            authorization: str | None = Header(default=None),
+    ):
+        require_auth_key(authorization)
+        return await run_in_threadpool(chat_image_service.create_image_completion, body)
+
     app.include_router(router)
 
     @app.get("/{full_path:path}", include_in_schema=False)

services/chat_image_service.py

@@ -0,0 +1,174 @@
+from __future__ import annotations
+
+import time
+import uuid
+
+from fastapi import HTTPException
+
+from services.backend_service import BackendService
+from services.image_service import ImageGenerationError
+
+
+IMAGE_MODELS = {"gpt-image-1", "gpt-image-2"}
+
+
+class ChatImageService:
+    def __init__(self, backend_service: BackendService):
+        self.backend_service = backend_service
+
+    def is_image_chat_request(self, body: dict[str, object]) -> bool:
+        model = str(body.get("model") or "").strip()
+        modalities = body.get("modalities")
+        if model in IMAGE_MODELS:
+            return True
+        if isinstance(modalities, list):
+            normalized = {str(item or "").strip().lower() for item in modalities}
+            return "image" in normalized
+        return False
+
+    def create_image_completion(self, body: dict[str, object]) -> dict[str, object]:
+        if not self.is_image_chat_request(body):
+            raise HTTPException(
+                status_code=400,
+                detail={"error": "only image generation requests are supported on this endpoint"},
+            )
+
+        if bool(body.get("stream")):
+            raise HTTPException(status_code=400, detail={"error": "stream is not supported for image generation"})
+
+        model = str(body.get("model") or "gpt-image-1").strip() or "gpt-image-1"
+        n = self._parse_image_count(body.get("n"))
+        prompt = self._extract_chat_prompt(body)
+        if not prompt:
+            raise HTTPException(status_code=400, detail={"error": "prompt is required"})
+
+        try:
+            image_result = self.backend_service.generate_with_pool(prompt, model, n)
+        except ImageGenerationError as exc:
+            raise HTTPException(status_code=502, detail={"error": str(exc)}) from exc
+
+        return self._build_chat_image_completion(model, prompt, image_result)
+
+    def _extract_prompt_from_message_content(self, content: object) -> str:
+        if isinstance(content, str):
+            return content.strip()
+        if not isinstance(content, list):
+            return ""
+
+        parts: list[str] = []
+        for item in content:
+            if not isinstance(item, dict):
+                continue
+            item_type = str(item.get("type") or "").strip()
+            if item_type == "text":
+                text = str(item.get("text") or "").strip()
+                if text:
+                    parts.append(text)
+                continue
+            if item_type == "input_text":
+                text = str(item.get("input_text") or "").strip()
+                if text:
+                    parts.append(text)
+        return "\n".join(parts).strip()
+
+    def _extract_chat_prompt(self, body: dict[str, object]) -> str:
+        direct_prompt = str(body.get("prompt") or "").strip()
+        if direct_prompt:
+            return direct_prompt
+
+        messages = body.get("messages")
+        if not isinstance(messages, list):
+            return ""
+
+        prompt_parts: list[str] = []
+        for message in messages:
+            if not isinstance(message, dict):
+                continue
+            role = str(message.get("role") or "").strip().lower()
+            if role != "user":
+                continue
+            prompt = self._extract_prompt_from_message_content(message.get("content"))
+            if prompt:
+                prompt_parts.append(prompt)
+
+        return "\n".join(prompt_parts).strip()
+
+    def _parse_image_count(self, raw_value: object) -> int:
+        try:
+            value = int(raw_value or 1)
+        except (TypeError, ValueError) as exc:
+            raise HTTPException(status_code=400, detail={"error": "n must be an integer"}) from exc
+        if value < 1 or value > 4:
+            raise HTTPException(status_code=400, detail={"error": "n must be between 1 and 4"})
+        return value
+
+    def _build_chat_image_completion(
+            self,
+            model: str,
+            prompt: str,
+            image_result: dict[str, object],
+    ) -> dict[str, object]:
+        created = int(image_result.get("created") or time.time())
+        image_items = image_result.get("data") if isinstance(image_result.get("data"), list) else []
+
+        markdown_images = []
+        images_payload = []
+        content_parts = []
+
+        for index, item in enumerate(image_items, start=1):
+            if not isinstance(item, dict):
+                continue
+            b64_json = str(item.get("b64_json") or "").strip()
+            revised_prompt = str(item.get("revised_prompt") or prompt).strip()
+            if not b64_json:
+                continue
+            image_data_url = f"data:image/png;base64,{b64_json}"
+            markdown_images.append(f"![image_{index}]({image_data_url})")
+            images_payload.append(
+                {
+                    "b64_json": b64_json,
+                    "revised_prompt": revised_prompt,
+                    "url": image_data_url,
+                }
+            )
+            content_parts.append(
+                {
+                    "type": "image_url",
+                    "image_url": {
+                        "url": image_data_url,
+                    },
+                }
+            )
+
+        text_content = "\n\n".join(markdown_images) if markdown_images else "Image generation completed."
+        content_parts.insert(
+            0,
+            {
+                "type": "text",
+                "text": text_content,
+            },
+        )
+
+        return {
+            "id": f"chatcmpl-{uuid.uuid4().hex}",
+            "object": "chat.completion",
+            "created": created,
+            "model": model,
+            "choices": [
+                {
+                    "index": 0,
+                    "message": {
+                        "role": "assistant",
+                        "content": text_content,
+                        "content_parts": content_parts,
+                        "images": images_payload,
+                    },
+                    "finish_reason": "stop",
+                }
+            ],
+            "usage": {
+                "prompt_tokens": 0,
+                "completion_tokens": 0,
+                "total_tokens": 0,
+            },
+        }

services/config.py

@@ -2,13 +2,16 @@ from __future__ import annotations
 
 import json
 import os
+import shutil
 from dataclasses import dataclass
 from pathlib import Path
+from typing import cast
 
 
 BASE_DIR = Path(__file__).resolve().parents[1]
 DATA_DIR = BASE_DIR / "data"
 CONFIG_FILE = BASE_DIR / "config.json"
+CONFIG_EXAMPLE_FILE = BASE_DIR / "config.example.json"
 
 
 @dataclass(frozen=True)
@@ -17,51 +20,48 @@ class AppSettings:
     host: str
     port: int
     accounts_file: Path
-    tls_verify: bool
+    refresh_account_interval_minute: int
 
+def _load_json_object(path: Path, *, name: str) -> dict[str, object]:
+    text = path.read_text(encoding="utf-8").strip()
+    if not text:
+        return {}
 
-def _parse_bool(value: object, *, default: bool) -> bool:
-    if value is None:
-        return default
-    if isinstance(value, bool):
-        return value
-    text = str(value).strip().lower()
-    if text in {"1", "true", "yes", "on"}:
-        return True
-    if text in {"0", "false", "no", "off"}:
-        return False
-    raise ValueError("config 'tls-verify' must be a boolean")
+    loaded = json.loads(text)
+    if not isinstance(loaded, dict):
+        raise ValueError(f"{name} must be a JSON object")
+    return loaded
+
+
+def _ensure_config_file() -> None:
+    if CONFIG_FILE.exists():
+        return
+    if not CONFIG_EXAMPLE_FILE.exists():
+        return
+    shutil.copyfile(CONFIG_EXAMPLE_FILE, CONFIG_FILE)
 
 
 def _load_settings() -> AppSettings:
     DATA_DIR.mkdir(parents=True, exist_ok=True)
-    raw_config: dict[str, object] = {}
+    _ensure_config_file()
 
+    raw_config: dict[str, object] = {}
+    if CONFIG_EXAMPLE_FILE.exists():
+        raw_config.update(_load_json_object(CONFIG_EXAMPLE_FILE, name="config.example.json"))
     if CONFIG_FILE.exists():
-        text = CONFIG_FILE.read_text(encoding="utf-8").strip()
-        if text:
-            loaded = json.loads(text)
-            if not isinstance(loaded, dict):
-                raise ValueError("config.json must be a JSON object")
-            raw_config = loaded
+        raw_config.update(_load_json_object(CONFIG_FILE, name="config.json"))
 
     auth_key = str(os.getenv("CHATGPT2API_AUTH_KEY") or raw_config.get("auth-key") or "").strip()
     if not auth_key:
-        raise ValueError(
-            "config.json must contain a non-empty 'auth-key' or CHATGPT2API_AUTH_KEY must be set"
-        )
-
-    tls_verify = _parse_bool(
-        os.getenv("CHATGPT2API_TLS_VERIFY", raw_config.get("tls-verify")),
-        default=True,
-    )
+        raise ValueError("config.example.json must contain a non-empty 'auth-key'")
+    refresh_account_interval_minute = cast(int, raw_config.get("refresh_account_interval_minute", 5))
 
     return AppSettings(
         auth_key=auth_key,
         host="0.0.0.0",
         port=8000,
         accounts_file=DATA_DIR / "accounts.json",
-        tls_verify=tls_verify,
+        refresh_account_interval_minute=refresh_account_interval_minute,
     )
 
 

services/image_service.py

@@ -12,7 +12,6 @@ from typing import Optional
 from curl_cffi.requests import Session
 
 from services.account_service import account_service
-from services.config import config
 from services import proof_of_work
 
 
@@ -89,7 +88,7 @@ def _new_session(access_token: str) -> tuple[Session, dict]:
     fp = _build_fp(access_token)
     session = Session(
         impersonate=fp.get("impersonate") or "edge101",
-        verify=config.tls_verify,
+        verify=True,
     )
     session.headers.update(
         {

web/src/app/accounts/components/account-import-dialog.tsx

@@ -0,0 +1,544 @@
+"use client";
+
+import { useRef, useState, type ChangeEvent } from "react";
+import {
+  ArrowLeft,
+  ExternalLink,
+  FileJson,
+  FileText,
+  Files,
+  KeyRound,
+  LoaderCircle,
+  Upload,
+} from "lucide-react";
+import { toast } from "sonner";
+
+import { Button } from "@/components/ui/button";
+import { Card, CardContent } from "@/components/ui/card";
+import {
+  Dialog,
+  DialogContent,
+  DialogDescription,
+  DialogFooter,
+  DialogHeader,
+  DialogTitle,
+} from "@/components/ui/dialog";
+import { Textarea } from "@/components/ui/textarea";
+import { createAccounts, type Account } from "@/lib/api";
+import { cn } from "@/lib/utils";
+
+type ImportMethod = "menu" | "token" | "session" | "cpa";
+
+type AccountImportDialogProps = {
+  disabled?: boolean;
+  onImported: (items: Account[]) => void;
+};
+
+type PendingCpaImport = {
+  tokens: string[];
+  parsedFileCount: number;
+  errorCount: number;
+};
+
+const sessionUrl = "https://chatgpt.com/api/auth/session";
+
+function splitTokens(value: string) {
+  return value
+    .split(/\r?\n/)
+    .map((item) => item.trim())
+    .filter(Boolean);
+}
+
+function getSessionAccessToken(value: unknown) {
+  const token = (value as { accessToken?: unknown })?.accessToken;
+  return typeof token === "string" ? token.trim() : "";
+}
+
+function getCpaAccessToken(value: unknown) {
+  const token = (value as { access_token?: unknown })?.access_token;
+  return typeof token === "string" ? token.trim() : "";
+}
+
+function readFileAsText(file: File) {
+  return new Promise<string>((resolve, reject) => {
+    const reader = new FileReader();
+    reader.onload = () => resolve(typeof reader.result === "string" ? reader.result : "");
+    reader.onerror = () => reject(reader.error ?? new Error(`读取文件失败: ${file.name}`));
+    reader.readAsText(file);
+  });
+}
+
+function MethodCard({
+  title,
+  description,
+  icon: Icon,
+  onClick,
+}: {
+  title: string;
+  description: string;
+  icon: typeof KeyRound;
+  onClick: () => void;
+}) {
+  return (
+    <button
+      type="button"
+      onClick={onClick}
+      className="w-full rounded-2xl border border-stone-200 bg-white p-0 text-left transition hover:border-stone-300 hover:bg-stone-50"
+    >
+      <Card className="rounded-2xl border-0 bg-transparent shadow-none">
+        <CardContent className="flex items-start gap-4 p-4">
+          <div className="rounded-xl bg-stone-100 p-3 text-stone-700">
+            <Icon className="size-5" />
+          </div>
+          <div className="space-y-1">
+            <div className="text-sm font-semibold text-stone-900">{title}</div>
+            <div className="text-sm leading-6 text-stone-500">{description}</div>
+          </div>
+        </CardContent>
+      </Card>
+    </button>
+  );
+}
+
+export function AccountImportDialog({ disabled, onImported }: AccountImportDialogProps) {
+  const [open, setOpen] = useState(false);
+  const [method, setMethod] = useState<ImportMethod>("menu");
+  const [tokenInput, setTokenInput] = useState("");
+  const [sessionInput, setSessionInput] = useState("");
+  const [isSubmitting, setIsSubmitting] = useState(false);
+  const [pendingCpaImport, setPendingCpaImport] = useState<PendingCpaImport | null>(null);
+  const [confirmOpen, setConfirmOpen] = useState(false);
+
+  const txtInputRef = useRef<HTMLInputElement | null>(null);
+  const cpaInputRef = useRef<HTMLInputElement | null>(null);
+
+  const resetState = () => {
+    setMethod("menu");
+    setTokenInput("");
+    setSessionInput("");
+    setPendingCpaImport(null);
+    setConfirmOpen(false);
+  };
+
+  const handleOpenChange = (nextOpen: boolean) => {
+    setOpen(nextOpen);
+    if (!nextOpen) {
+      resetState();
+    }
+  };
+
+  const submitTokens = async (tokens: string[], successText?: string) => {
+    const normalizedTokens = tokens.map((item) => item.trim()).filter(Boolean);
+
+    if (normalizedTokens.length === 0) {
+      toast.error("请先提供至少一个可用 Token");
+      return;
+    }
+
+    setIsSubmitting(true);
+    try {
+      const data = await createAccounts(normalizedTokens);
+      onImported(data.items);
+      setOpen(false);
+      resetState();
+
+      if ((data.errors?.length ?? 0) > 0) {
+        const firstError = data.errors?.[0]?.error;
+        toast.error(
+          `${successText ?? "导入完成"}，新增 ${data.added ?? 0} 个，已刷新 ${data.refreshed ?? 0} 个，失败 ${data.errors?.length ?? 0} 个${firstError ? `，首个错误：${firstError}` : ""}`,
+        );
+      } else {
+        toast.success(
+          `${successText ?? "导入完成"}，新增 ${data.added ?? 0} 个，跳过 ${data.skipped ?? 0} 个重复项，已自动刷新账号信息`,
+        );
+      }
+    } catch (error) {
+      const message = error instanceof Error ? error.message : "导入账户失败";
+      toast.error(message);
+    } finally {
+      setIsSubmitting(false);
+    }
+  };
+
+  const handleImportTokenText = async () => {
+    await submitTokens(splitTokens(tokenInput), "Access Token 导入完成");
+  };
+
+  const handleTxtSelected = async (event: ChangeEvent<HTMLInputElement>) => {
+    const file = event.target.files?.[0];
+    event.target.value = "";
+
+    if (!file) {
+      return;
+    }
+
+    try {
+      const content = await readFileAsText(file);
+      const tokens = splitTokens(content);
+
+      if (tokens.length === 0) {
+        toast.error("TXT 文件里没有读取到有效 Token");
+        return;
+      }
+
+      setTokenInput((prev) => {
+        const next = [...splitTokens(prev), ...tokens];
+        return next.join("\n");
+      });
+      toast.success(`已从 ${file.name} 读取 ${tokens.length} 个 Token`);
+    } catch (error) {
+      const message = error instanceof Error ? error.message : "读取 TXT 文件失败";
+      toast.error(message);
+    }
+  };
+
+  const handleImportSessionJson = async () => {
+    if (!sessionInput.trim()) {
+      toast.error("请先粘贴完整 Session JSON");
+      return;
+    }
+
+    try {
+      const payload = JSON.parse(sessionInput) as unknown;
+      const token = getSessionAccessToken(payload);
+
+      if (!token) {
+        toast.error("未从 Session JSON 中提取到 accessToken");
+        return;
+      }
+
+      await submitTokens([token], "Session JSON 导入完成");
+    } catch (error) {
+      const message = error instanceof Error ? error.message : "Session JSON 解析失败";
+      toast.error(message);
+    }
+  };
+
+  const handleCpaSelected = async (event: ChangeEvent<HTMLInputElement>) => {
+    const files = Array.from(event.target.files ?? []);
+    event.target.value = "";
+
+    if (files.length === 0) {
+      return;
+    }
+
+    try {
+      const results = await Promise.all(
+        files.map(async (file) => {
+          const raw = await readFileAsText(file);
+          const parsed = JSON.parse(raw) as unknown;
+          const token = getCpaAccessToken(parsed);
+          return {
+            token,
+          };
+        }),
+      );
+
+      const tokens = results.map((item) => item.token).filter((item): item is string => Boolean(item));
+      const parsedFileCount = tokens.length;
+      const errorCount = results.length - parsedFileCount;
+
+      if (parsedFileCount === 0) {
+        toast.error("这些 CPA JSON 文件里没有读取到可用 access_token");
+        return;
+      }
+
+      setPendingCpaImport({
+        tokens,
+        parsedFileCount,
+        errorCount,
+      });
+      setConfirmOpen(true);
+    } catch (error) {
+      const message = error instanceof Error ? error.message : "读取 CPA JSON 文件失败";
+      toast.error(message);
+    }
+  };
+
+  const renderMethodBody = () => {
+    if (method === "token") {
+      const tokenCount = splitTokens(tokenInput).length;
+
+      return (
+        <div className="space-y-4">
+          <div className="flex items-center justify-between">
+            <button
+              type="button"
+              onClick={() => setMethod("menu")}
+              className="inline-flex items-center gap-1 text-sm text-stone-500 transition hover:text-stone-800"
+            >
+              <ArrowLeft className="size-4" />
+              返回导入方式
+            </button>
+            <span className="text-xs text-stone-400">当前识别 {tokenCount} 个 Token</span>
+          </div>
+          <div className="space-y-2">
+            <label className="text-sm font-medium text-stone-700">Access Token 列表</label>
+            <Textarea
+              placeholder="每行一个 Access Token..."
+              value={tokenInput}
+              onChange={(event) => setTokenInput(event.target.value)}
+              className="min-h-56 resize-none rounded-xl border-stone-200"
+            />
+          </div>
+          <div className="rounded-2xl border border-dashed border-stone-200 bg-stone-50 p-4">
+            <div className="flex flex-col gap-3 sm:flex-row sm:items-center sm:justify-between">
+              <div className="space-y-1">
+                <div className="text-sm font-medium text-stone-800">从 TXT 文件导入</div>
+                <div className="text-sm leading-6 text-stone-500">支持 `.txt`，文件内容也是一行一个 Token。</div>
+              </div>
+              <Button
+                type="button"
+                variant="outline"
+                className="rounded-xl border-stone-200 bg-white"
+                onClick={() => txtInputRef.current?.click()}
+                disabled={isSubmitting}
+              >
+                <FileText className="size-4" />
+                选择 TXT
+              </Button>
+            </div>
+          </div>
+          <input
+            ref={txtInputRef}
+            type="file"
+            accept=".txt,text/plain"
+            className="hidden"
+            onChange={(event) => void handleTxtSelected(event)}
+          />
+        </div>
+      );
+    }
+
+    if (method === "session") {
+      return (
+        <div className="space-y-4">
+          <button
+            type="button"
+            onClick={() => setMethod("menu")}
+            className="inline-flex items-center gap-1 text-sm text-stone-500 transition hover:text-stone-800"
+          >
+            <ArrowLeft className="size-4" />
+            返回导入方式
+          </button>
+          <div className="rounded-2xl border border-stone-200 bg-stone-50 p-4 text-sm leading-6 text-stone-600">
+            打开
+            {" "}
+            <a
+              href={sessionUrl}
+              target="_blank"
+              rel="noreferrer"
+              className="inline-flex items-center gap-1 font-medium text-stone-900 underline underline-offset-4"
+            >
+              {sessionUrl}
+              <ExternalLink className="size-3.5" />
+            </a>
+            ，复制页面返回的完整 JSON，系统会自动提取其中的 `accessToken` 导入。
+          </div>
+          <div className="rounded-2xl border border-amber-200 bg-amber-50 p-4 text-sm leading-6 text-amber-900">
+            <div className="font-medium">风险提示</div>
+            <div>
+              不要使用自己的大号，尽量使用不常用的小号进行导入，避免出现封号风险。本项目不承担任何封号风险责任。
+            </div>
+          </div>
+          <div className="space-y-2">
+            <label className="text-sm font-medium text-stone-700">Session JSON</label>
+            <Textarea
+              placeholder='粘贴完整 JSON，例如包含 "accessToken" 的对象...'
+              value={sessionInput}
+              onChange={(event) => setSessionInput(event.target.value)}
+              className="min-h-56 resize-none rounded-xl border-stone-200 font-mono text-xs"
+            />
+          </div>
+        </div>
+      );
+    }
+
+    if (method === "cpa") {
+      return (
+        <div className="space-y-4">
+          <button
+            type="button"
+            onClick={() => setMethod("menu")}
+            className="inline-flex items-center gap-1 text-sm text-stone-500 transition hover:text-stone-800"
+          >
+            <ArrowLeft className="size-4" />
+            返回导入方式
+          </button>
+          <div className="rounded-2xl border border-dashed border-stone-200 bg-stone-50 p-5">
+            <div className="space-y-2">
+              <div className="text-sm font-medium text-stone-800">多选本地 CPA JSON 文件</div>
+              <div className="text-sm leading-6 text-stone-500">
+                每个文件应为一个 JSON 对象。系统会从对象中自动提取 `access_token` 或 `accessToken`，
+              </div>
+            </div>
+            <Button
+              type="button"
+              className="mt-4 rounded-xl bg-stone-950 text-white hover:bg-stone-800"
+              onClick={() => cpaInputRef.current?.click()}
+              disabled={isSubmitting}
+            >
+              <Files className="size-4" />
+              选择多个 JSON 文件
+            </Button>
+          </div>
+          <input
+            ref={cpaInputRef}
+            type="file"
+            accept=".json,application/json"
+            multiple
+            className="hidden"
+            onChange={(event) => void handleCpaSelected(event)}
+          />
+          {pendingCpaImport ? (
+            <div className="rounded-2xl border border-stone-200 bg-white p-4 text-sm leading-6 text-stone-600">
+              最近一次读取到 {pendingCpaImport.parsedFileCount} 个 Token
+              {pendingCpaImport.errorCount > 0 ? `，另有 ${pendingCpaImport.errorCount} 个文件未提取成功` : ""}。
+            </div>
+          ) : null}
+        </div>
+      );
+    }
+
+    return (
+      <div className="space-y-3">
+        <MethodCard
+          title="导入 Access Token"
+          description="支持直接粘贴，一行一个；也支持从 TXT 文件读取，一行一个。"
+          icon={KeyRound}
+          onClick={() => setMethod("token")}
+        />
+        <MethodCard
+          title="导入 Session JSON"
+          description="从 chatgpt.com 的 session 接口复制完整 JSON，自动提取 accessToken。"
+          icon={FileJson}
+          onClick={() => setMethod("session")}
+        />
+        <MethodCard
+          title="导入 CPA JSON 文件"
+          description="支持一次多选多个本地 JSON 文件，逐个读取对象里的 access_token 后导入。"
+          icon={Files}
+          onClick={() => setMethod("cpa")}
+        />
+      </div>
+    );
+  };
+
+  const footerDisabled = disabled || isSubmitting;
+
+  return (
+    <>
+      <Dialog open={open} onOpenChange={handleOpenChange}>
+        <Button
+          className="h-10 rounded-xl bg-stone-950 px-4 text-white hover:bg-stone-800"
+          onClick={() => setOpen(true)}
+          disabled={disabled}
+        >
+          <Upload className="size-4" />
+          导入
+        </Button>
+        <DialogContent showCloseButton={false} className="rounded-2xl p-6">
+          <DialogHeader className="gap-2">
+            <DialogTitle>
+              {method === "menu"
+                ? "导入账户"
+                : method === "token"
+                  ? "导入 Access Token"
+                  : method === "session"
+                    ? "导入 Session JSON"
+                    : "导入 CPA JSON"}
+            </DialogTitle>
+            <DialogDescription className="text-sm leading-6">
+              {method === "menu"
+                ? "选择一种导入方式。导入成功后会自动拉取邮箱、类型和额度。"
+                : method === "token"
+                  ? "支持手动粘贴或从 TXT 文件导入，一行一个 Token。"
+                  : method === "session"
+                    ? "粘贴完整 Session JSON，系统会自动提取 accessToken。"
+                    : "支持一次读取多个本地 JSON 文件，并在提交前做数量确认。"}
+            </DialogDescription>
+          </DialogHeader>
+
+          {renderMethodBody()}
+
+          <DialogFooter className="pt-2">
+            <Button
+              variant="secondary"
+              className="h-10 rounded-xl bg-stone-100 px-5 text-stone-700 hover:bg-stone-200"
+              onClick={() => setOpen(false)}
+              disabled={footerDisabled}
+            >
+              取消
+            </Button>
+            {method === "token" ? (
+              <Button
+                className="h-10 rounded-xl bg-stone-950 px-5 text-white hover:bg-stone-800"
+                onClick={() => void handleImportTokenText()}
+                disabled={footerDisabled}
+              >
+                {isSubmitting ? <LoaderCircle className="size-4 animate-spin" /> : null}
+                导入 Token
+              </Button>
+            ) : null}
+            {method === "session" ? (
+              <Button
+                className="h-10 rounded-xl bg-stone-950 px-5 text-white hover:bg-stone-800"
+                onClick={() => void handleImportSessionJson()}
+                disabled={footerDisabled}
+              >
+                {isSubmitting ? <LoaderCircle className="size-4 animate-spin" /> : null}
+                导入 JSON
+              </Button>
+            ) : null}
+            {method === "cpa" ? (
+              <Button
+                className={cn(
+                  "h-10 rounded-xl bg-stone-950 px-5 text-white hover:bg-stone-800",
+                  !pendingCpaImport ? "hidden" : "",
+                )}
+                onClick={() => setConfirmOpen(true)}
+                disabled={footerDisabled || !pendingCpaImport}
+              >
+                查看导入确认
+              </Button>
+            ) : null}
+          </DialogFooter>
+        </DialogContent>
+      </Dialog>
+
+      <Dialog open={confirmOpen} onOpenChange={setConfirmOpen}>
+        <DialogContent className="rounded-2xl p-6">
+          <DialogHeader className="gap-2">
+            <DialogTitle>确认导入 CPA Token</DialogTitle>
+            <DialogDescription className="text-sm leading-6">
+              {pendingCpaImport
+                ? `确认识别到 ${pendingCpaImport.parsedFileCount} 个 Token，是否确认导入？`
+                : "尚未读取到可导入的 Token。"}
+              {pendingCpaImport?.errorCount
+                ? `，另有 ${pendingCpaImport.errorCount} 个文件未提取成功。`
+                : "。"}
+            </DialogDescription>
+          </DialogHeader>
+          <DialogFooter className="pt-2">
+            <Button
+              variant="secondary"
+              className="h-10 rounded-xl bg-stone-100 px-5 text-stone-700 hover:bg-stone-200"
+              onClick={() => setConfirmOpen(false)}
+              disabled={isSubmitting}
+            >
+              返回
+            </Button>
+            <Button
+              className="h-10 rounded-xl bg-stone-950 px-5 text-white hover:bg-stone-800"
+              onClick={() => void submitTokens(pendingCpaImport?.tokens ?? [], "CPA JSON 导入完成")}
+              disabled={isSubmitting || !pendingCpaImport}
+            >
+              {isSubmitting ? <LoaderCircle className="size-4 animate-spin" /> : null}
+              确认导入
+            </Button>
+          </DialogFooter>
+        </DialogContent>
+      </Dialog>
+    </>
+  );
+}

web/src/app/accounts/page.tsx

@@ -13,7 +13,6 @@ import {
   Download,
   LoaderCircle,
   Pencil,
-  Plus,
   RefreshCw,
   Search,
   Trash2,
@@ -32,7 +31,6 @@ import {
   DialogFooter,
   DialogHeader,
   DialogTitle,
-  DialogTrigger,
 } from "@/components/ui/dialog";
 import { Input } from "@/components/ui/input";
 import {
@@ -42,9 +40,7 @@ import {
   SelectTrigger,
   SelectValue,
 } from "@/components/ui/select";
-import { Textarea } from "@/components/ui/textarea";
 import {
-  createAccounts,
   deleteAccounts,
   fetchAccounts,
   refreshAccounts,
@@ -55,6 +51,8 @@ import {
 } from "@/lib/api";
 import { cn } from "@/lib/utils";
 
+import { AccountImportDialog } from "./components/account-import-dialog";
+
 const accountTypeOptions: { label: string; value: AccountType | "all" }[] = [
   { label: "全部类型", value: "all" },
   { label: "Free", value: "Free" },
@@ -168,15 +166,12 @@ export default function AccountsPage() {
   const [statusFilter, setStatusFilter] = useState<AccountStatus | "all">("all");
   const [page, setPage] = useState(1);
   const [pageSize, setPageSize] = useState("10");
-  const [open, setOpen] = useState(false);
-  const [newTokens, setNewTokens] = useState("");
   const [editingAccount, setEditingAccount] = useState<Account | null>(null);
   const [editType, setEditType] = useState<AccountType>("Free");
   const [editStatus, setEditStatus] = useState<AccountStatus>("正常");
   const [editQuota, setEditQuota] = useState("0");
   const [isLoading, setIsLoading] = useState(true);
   const [isRefreshing, setIsRefreshing] = useState(false);
-  const [isSubmitting, setIsSubmitting] = useState(false);
   const [isDeleting, setIsDeleting] = useState(false);
   const [isUpdating, setIsUpdating] = useState(false);
 
@@ -258,41 +253,6 @@ export default function AccountsPage() {
     return items;
   }, [pageCount, safePage]);
 
-  const handleAddAccounts = async () => {
-    const tokens = newTokens
-      .split(/\r?\n/)
-      .map((item) => item.trim())
-      .filter(Boolean);
-
-    if (tokens.length === 0) {
-      toast.error("请先粘贴至少一个 Access Token");
-      return;
-    }
-
-    setIsSubmitting(true);
-    try {
-      const data = await createAccounts(tokens);
-      setAccounts(normalizeAccounts(data.items));
-      setSelectedIds([]);
-      setOpen(false);
-      setNewTokens("");
-      setPage(1);
-      if ((data.errors?.length ?? 0) > 0) {
-        const firstError = data.errors?.[0]?.error;
-        toast.error(
-          `新增 ${data.added ?? 0} 个账户，已刷新 ${data.refreshed ?? 0} 个，失败 ${data.errors?.length ?? 0} 个${firstError ? `，首个错误：${firstError}` : ""}`,
-        );
-      } else {
-        toast.success(`新增 ${data.added ?? 0} 个账户，跳过 ${data.skipped ?? 0} 个重复项，已自动刷新账号信息`);
-      }
-    } catch (error) {
-      const message = error instanceof Error ? error.message : "新增账户失败";
-      toast.error(message);
-    } finally {
-      setIsSubmitting(false);
-    }
-  };
-
   const handleDeleteTokens = async (tokens: string[]) => {
     if (tokens.length === 0) {
       toast.error("请先选择要删除的账户");
@@ -394,7 +354,7 @@ export default function AccountsPage() {
             variant="outline"
             className="h-10 rounded-xl border-stone-200 bg-white/80 px-4 text-stone-700 hover:bg-white"
             onClick={() => void loadAccounts()}
-            disabled={isLoading || isRefreshing || isSubmitting || isDeleting}
+            disabled={isLoading || isRefreshing || isDeleting}
           >
             <RefreshCw className={cn("size-4", isLoading ? "animate-spin" : "")} />
             刷新
@@ -403,56 +363,19 @@ export default function AccountsPage() {
             variant="outline"
             className="h-10 rounded-xl border-stone-200 bg-white/80 px-4 text-stone-700 hover:bg-white"
             onClick={() => void handleRefreshAccounts(accounts.map((item) => item.access_token))}
-            disabled={isLoading || isRefreshing || isSubmitting || isDeleting || accounts.length === 0}
+            disabled={isLoading || isRefreshing || isDeleting || accounts.length === 0}
           >
             <RefreshCw className={cn("size-4", isRefreshing ? "animate-spin" : "")} />
             一键刷新所有账号信息和额度
           </Button>
-          <Dialog open={open} onOpenChange={setOpen}>
-            <DialogTrigger asChild>
-              <Button className="h-10 rounded-xl bg-stone-950 px-4 text-white hover:bg-stone-800">
-                <Plus className="size-4" />
-                新增
-              </Button>
-            </DialogTrigger>
-            <DialogContent showCloseButton={false} className="rounded-2xl p-6">
-              <DialogHeader className="gap-2">
-                <DialogTitle>新增账户</DialogTitle>
-                <DialogDescription className="text-sm leading-6">
-                  每行一个 Access Token。保存后会自动拉取邮箱、类型和额度。
-                </DialogDescription>
-              </DialogHeader>
-              <div className="space-y-4">
-                <div className="space-y-2">
-                  <label className="text-sm font-medium text-stone-700">Token 列表</label>
-                  <Textarea
-                    placeholder="粘贴 Token，每行一个..."
-                    value={newTokens}
-                    onChange={(event) => setNewTokens(event.target.value)}
-                    className="min-h-48 resize-none rounded-xl border-stone-200"
-                  />
-                </div>
-              </div>
-              <DialogFooter className="pt-2">
-                <Button
-                  variant="secondary"
-                  className="h-10 rounded-xl bg-stone-100 px-5 text-stone-700 hover:bg-stone-200"
-                  onClick={() => setOpen(false)}
-                  disabled={isSubmitting}
-                >
-                  取消
-                </Button>
-                <Button
-                  className="h-10 rounded-xl bg-stone-950 px-5 text-white hover:bg-stone-800"
-                  onClick={() => void handleAddAccounts()}
-                  disabled={isSubmitting}
-                >
-                  {isSubmitting ? <LoaderCircle className="size-4 animate-spin" /> : null}
-                  新增账户
-                </Button>
-              </DialogFooter>
-            </DialogContent>
-          </Dialog>
+          <AccountImportDialog
+            disabled={isLoading || isRefreshing || isDeleting}
+            onImported={(items) => {
+              setAccounts(normalizeAccounts(items));
+              setSelectedIds([]);
+              setPage(1);
+            }}
+          />
           <Button
             variant="outline"
             className="h-10 rounded-xl border-stone-200 bg-white/80 px-4 text-stone-700 hover:bg-white"

web/src/app/layout.tsx

@@ -14,7 +14,7 @@ export default function RootLayout({
   children: React.ReactNode;
 }>) {
   return (
-    <html lang="zh-CN">
+    <html lang="zh-CN" suppressHydrationWarning>
       <body
         className="antialiased"
         style={{