A5-R3-R4C dormant ModelPolicy v2 execution seam

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$R04VJDB.txt

@@ -0,0 +1 @@
+restore 0000006d-00000000-000050bf-708b24b133fed5049ff96a4fcb126551

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$R2MQAX1.pdf

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:40017ada62558766946a1de340fdfc3f332d42322cc3b1819ae4e9a4396bff98
+size 1211510

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RA7J9YA.docx

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:be51e4935cc545417d84b1adb3f4ff634349da099c1634e9f120fdbb91cc7f53
+size 1046928

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RALBAPU.txt

@@ -0,0 +1,2140 @@
+/* ============================================================
+ * SmartPaper Authentication Worker
+ *
+ * 已实现：
+ * 1. 支付宝扫码授权
+ * 2. RSA2调用 alipay.system.oauth.token
+ * 3. 创建或匹配SmartPaper用户
+ * 4. Hugging Face创建登录请求
+ * 5. Hugging Face轮询扫码状态
+ * 6. 签发8小时短期登录会话
+ * 7. 验证会话
+ * 8. 注销会话
+ *
+ * 固定业务规则：
+ * - 每位用户每天免费3篇论文
+ * - 9.9元增加3篇长期有效论文
+ *
+ * 尚未实现：
+ * - 每日免费篇数的实际扣减
+ * - 论文生成任务与自动排队
+ * - 支付订单和自动增加论文
+ * ============================================================ */
+
+const LOGIN_REQUEST_TTL_MS = 10 * 60 * 1000;
+const SESSION_TTL_MS = 8 * 60 * 60 * 1000;
+
+const DAILY_FREE_PAPERS = 3;
+const PAYMENT_AMOUNT_FEN = 990;
+const PAYMENT_BONUS_PAPERS = 3;
+
+
+/* ============================================================
+ * 响应工具
+ * ============================================================ */
+
+function commonHeaders(contentType) {
+  return {
+    "Content-Type": contentType,
+    "Cache-Control": "no-store",
+    "X-Content-Type-Options": "nosniff",
+    "Referrer-Policy": "no-referrer",
+    "X-Frame-Options": "DENY",
+  };
+}
+
+
+function jsonResponse(data, status = 200) {
+  return new Response(
+    JSON.stringify(data, null, 2),
+    {
+      status,
+      headers: commonHeaders(
+        "application/json; charset=utf-8"
+      ),
+    }
+  );
+}
+
+
+function htmlResponse(title, body, status = 200) {
+  return new Response(
+    `<!doctype html>
+    <html lang="zh-CN">
+      <head>
+        <meta charset="utf-8">
+
+        <meta
+          name="viewport"
+          content="width=device-width, initial-scale=1"
+        >
+
+        <title>${escapeHtml(title)}</title>
+
+        <style>
+          :root {
+            color-scheme: light dark;
+          }
+
+          body {
+            max-width: 760px;
+            margin: 50px auto;
+            padding: 0 20px;
+            font-family:
+              Arial,
+              "Microsoft YaHei",
+              "PingFang SC",
+              sans-serif;
+            line-height: 1.8;
+          }
+
+          h1 {
+            margin-top: 0;
+            font-size: 28px;
+          }
+
+          .card {
+            padding: 28px;
+            border: 1px solid #8885;
+            border-radius: 14px;
+            background: #8881;
+          }
+
+          .success {
+            color: #21a33b;
+          }
+
+          .error {
+            color: #d83b3b;
+          }
+
+          .button {
+            display: inline-block;
+            margin-top: 16px;
+            padding: 11px 20px;
+            border-radius: 8px;
+            background: #1677ff;
+            color: #ffffff;
+            text-decoration: none;
+            font-weight: 600;
+          }
+
+          .button:hover {
+            background: #0d63d7;
+          }
+
+          code {
+            word-break: break-all;
+            padding: 2px 5px;
+            border-radius: 4px;
+            background: #8882;
+          }
+
+          .muted {
+            opacity: 0.72;
+            font-size: 14px;
+          }
+
+          .links {
+            margin-top: 26px;
+          }
+        </style>
+      </head>
+
+      <body>
+        ${body}
+      </body>
+    </html>`,
+    {
+      status,
+      headers: commonHeaders(
+        "text/html; charset=utf-8"
+      ),
+    }
+  );
+}
+
+
+function escapeHtml(value) {
+  return String(value ?? "")
+    .replaceAll("&", "&amp;")
+    .replaceAll("<", "&lt;")
+    .replaceAll(">", "&gt;")
+    .replaceAll('"', "&quot;")
+    .replaceAll("'", "&#039;");
+}
+
+
+/* ============================================================
+ * 请求工具
+ * ============================================================ */
+
+async function readJsonBody(request) {
+  try {
+    return await request.json();
+  } catch {
+    return null;
+  }
+}
+
+
+function extractServiceKey(request) {
+  const authorization =
+    request.headers.get("Authorization") || "";
+
+  if (authorization.startsWith("Bearer ")) {
+    return authorization.slice(7).trim();
+  }
+
+  return (
+    request.headers.get(
+      "X-SmartPaper-Service-Key"
+    ) || ""
+  ).trim();
+}
+
+
+/* ============================================================
+ * 随机数、摘要和HMAC
+ * ============================================================ */
+
+function randomToken(byteLength = 32) {
+  const bytes = new Uint8Array(byteLength);
+  crypto.getRandomValues(bytes);
+
+  let binary = "";
+
+  for (const byte of bytes) {
+    binary += String.fromCharCode(byte);
+  }
+
+  return btoa(binary)
+    .replaceAll("+", "-")
+    .replaceAll("/", "_")
+    .replaceAll("=", "");
+}
+
+
+async function sha256Bytes(value) {
+  const encoded =
+    new TextEncoder().encode(String(value));
+
+  return new Uint8Array(
+    await crypto.subtle.digest(
+      "SHA-256",
+      encoded
+    )
+  );
+}
+
+
+async function sha256Hex(value) {
+  const bytes = await sha256Bytes(value);
+
+  return [...bytes]
+    .map((byte) =>
+      byte.toString(16).padStart(2, "0")
+    )
+    .join("");
+}
+
+
+async function importHmacKey(secret) {
+  return crypto.subtle.importKey(
+    "raw",
+    new TextEncoder().encode(secret),
+    {
+      name: "HMAC",
+      hash: "SHA-256",
+    },
+    false,
+    ["sign"]
+  );
+}
+
+
+async function hmacHex(value, secret) {
+  if (!secret) {
+    throw new Error(
+      "SESSION_SIGNING_SECRET未配置。"
+    );
+  }
+
+  const key = await importHmacKey(secret);
+
+  const signature =
+    await crypto.subtle.sign(
+      "HMAC",
+      key,
+      new TextEncoder().encode(value)
+    );
+
+  return [...new Uint8Array(signature)]
+    .map((byte) =>
+      byte.toString(16).padStart(2, "0")
+    )
+    .join("");
+}
+
+
+async function constantTimeTextEqual(
+  valueA,
+  valueB
+) {
+  const bytesA = await sha256Bytes(valueA);
+  const bytesB = await sha256Bytes(valueB);
+
+  if (bytesA.length !== bytesB.length) {
+    return false;
+  }
+
+  let difference = 0;
+
+  for (let i = 0; i < bytesA.length; i += 1) {
+    difference |= bytesA[i] ^ bytesB[i];
+  }
+
+  return difference === 0;
+}
+
+
+async function isAuthorizedServiceRequest(
+  request,
+  env
+) {
+  if (!env.SMARTPAPER_SERVICE_KEY) {
+    return false;
+  }
+
+  const suppliedKey =
+    extractServiceKey(request);
+
+  if (!suppliedKey) {
+    return false;
+  }
+
+  return constantTimeTextEqual(
+    suppliedKey,
+    env.SMARTPAPER_SERVICE_KEY
+  );
+}
+
+
+async function requireServiceRequest(
+  request,
+  env
+) {
+  const authorized =
+    await isAuthorizedServiceRequest(
+      request,
+      env
+    );
+
+  if (!authorized) {
+    return jsonResponse(
+      {
+        ok: false,
+        error: "unauthorized",
+      },
+      401
+    );
+  }
+
+  return null;
+}
+
+
+/* ============================================================
+ * 时间工具
+ * ============================================================ */
+
+function getBeijingTimestamp() {
+  const parts =
+    new Intl.DateTimeFormat(
+      "zh-CN",
+      {
+        timeZone: "Asia/Shanghai",
+        year: "numeric",
+        month: "2-digit",
+        day: "2-digit",
+        hour: "2-digit",
+        minute: "2-digit",
+        second: "2-digit",
+        hourCycle: "h23",
+      }
+    ).formatToParts(new Date());
+
+  const values = Object.fromEntries(
+    parts
+      .filter((part) =>
+        part.type !== "literal"
+      )
+      .map((part) => [
+        part.type,
+        part.value,
+      ])
+  );
+
+  return (
+    `${values.year}-${values.month}-${values.day} ` +
+    `${values.hour}:${values.minute}:${values.second}`
+  );
+}
+
+
+function isExpired(isoDate) {
+  if (!isoDate) {
+    return true;
+  }
+
+  const timestamp = Date.parse(isoDate);
+
+  return (
+    Number.isNaN(timestamp) ||
+    timestamp <= Date.now()
+  );
+}
+
+
+/* ============================================================
+ * RSA2应用私钥和支付宝签名
+ * ============================================================ */
+
+function normalizePrivateKey(
+  privateKeyText
+) {
+  return String(privateKeyText ?? "")
+    .replaceAll("\\n", "\n")
+    .replace(
+      /-----BEGIN PRIVATE KEY-----/g,
+      ""
+    )
+    .replace(
+      /-----END PRIVATE KEY-----/g,
+      ""
+    )
+    .replace(
+      /-----BEGIN RSA PRIVATE KEY-----/g,
+      ""
+    )
+    .replace(
+      /-----END RSA PRIVATE KEY-----/g,
+      ""
+    )
+    .replace(/\s+/g, "");
+}
+
+
+function base64ToBytes(base64Text) {
+  const normalized =
+    String(base64Text ?? "")
+      .replace(/\s+/g, "");
+
+  const binary = atob(normalized);
+
+  const bytes =
+    new Uint8Array(binary.length);
+
+  for (
+    let index = 0;
+    index < binary.length;
+    index += 1
+  ) {
+    bytes[index] =
+      binary.charCodeAt(index);
+  }
+
+  return bytes;
+}
+
+
+function arrayBufferToBase64(buffer) {
+  const bytes = new Uint8Array(buffer);
+
+  let binary = "";
+
+  for (
+    let index = 0;
+    index < bytes.length;
+    index += 1
+  ) {
+    binary += String.fromCharCode(
+      bytes[index]
+    );
+  }
+
+  return btoa(binary);
+}
+
+
+async function importAlipayPrivateKey(
+  privateKeyText
+) {
+  const normalizedKey =
+    normalizePrivateKey(privateKeyText);
+
+  if (!normalizedKey) {
+    throw new Error(
+      "Cloudflare中没有配置支付宝应用私钥。"
+    );
+  }
+
+  let keyBytes;
+
+  try {
+    keyBytes =
+      base64ToBytes(normalizedKey);
+  } catch {
+    throw new Error(
+      "支付宝应��私钥不是有效的Base64格式。"
+    );
+  }
+
+  try {
+    return await crypto.subtle.importKey(
+      "pkcs8",
+      keyBytes,
+      {
+        name: "RSASSA-PKCS1-v1_5",
+        hash: "SHA-256",
+      },
+      false,
+      ["sign"]
+    );
+  } catch (error) {
+    throw new Error(
+      "无法导入支付宝应用私钥。" +
+      "请确认该值是与支付宝应用公钥配对的" +
+      "RSA2 PKCS8应用私钥。" +
+      ` 原始错误：${String(error)}`
+    );
+  }
+}
+
+
+function buildAlipaySignContent(
+  parameters
+) {
+  return Object.entries(parameters)
+    .filter(([key, value]) => (
+      key !== "sign" &&
+      value !== undefined &&
+      value !== null &&
+      value !== ""
+    ))
+    .sort(([keyA], [keyB]) => {
+      if (keyA < keyB) return -1;
+      if (keyA > keyB) return 1;
+      return 0;
+    })
+    .map(([key, value]) =>
+      `${key}=${String(value)}`
+    )
+    .join("&");
+}
+
+
+async function createAlipaySignature(
+  parameters,
+  privateKeyText
+) {
+  const contentToSign =
+    buildAlipaySignContent(parameters);
+
+  const privateKey =
+    await importAlipayPrivateKey(
+      privateKeyText
+    );
+
+  const signature =
+    await crypto.subtle.sign(
+      {
+        name: "RSASSA-PKCS1-v1_5",
+      },
+      privateKey,
+      new TextEncoder().encode(
+        contentToSign
+      )
+    );
+
+  return arrayBufferToBase64(
+    signature
+  );
+}
+
+
+/* ============================================================
+ * 配置检查
+ * ============================================================ */
+
+function getMissingConfiguration(env) {
+  const requiredVariables = [
+    "ALIPAY_APP_ID",
+    "ALIPAY_APP_PRIVATE_KEY",
+    "ALIPAY_GATEWAY",
+    "ALIPAY_REDIRECT_URI",
+    "SESSION_SIGNING_SECRET",
+    "SMARTPAPER_SERVICE_KEY",
+  ];
+
+  const missing =
+    requiredVariables.filter(
+      (name) => !env[name]
+    );
+
+  if (!env.DB) {
+    missing.push("DB binding");
+  }
+
+  return missing;
+}
+
+
+/* ============================================================
+ * 支付宝登录请求
+ * ============================================================ */
+
+function buildAlipayAuthorizationUrl(
+  env,
+  state
+) {
+  const authorizationUrl = new URL(
+    "https://openauth.alipay.com/oauth2/publicAppAuthorize.htm"
+  );
+
+  authorizationUrl.searchParams.set(
+    "app_id",
+    env.ALIPAY_APP_ID
+  );
+
+  authorizationUrl.searchParams.set(
+    "scope",
+    "auth_user"
+  );
+
+  authorizationUrl.searchParams.set(
+    "redirect_uri",
+    env.ALIPAY_REDIRECT_URI
+  );
+
+  authorizationUrl.searchParams.set(
+    "state",
+    state
+  );
+
+  return authorizationUrl.toString();
+}
+
+
+async function createLoginRequestRecord(env) {
+  const state = randomToken(32);
+  const pollToken = randomToken(32);
+
+  const stateHash =
+    await sha256Hex(state);
+
+  const pollTokenHash =
+    await hmacHex(
+      pollToken,
+      env.SESSION_SIGNING_SECRET
+    );
+
+  const loginRequestId =
+    crypto.randomUUID();
+
+  const expiresAt = new Date(
+    Date.now() + LOGIN_REQUEST_TTL_MS
+  ).toISOString();
+
+  await env.DB.prepare(
+    `INSERT INTO oauth_states
+      (
+        state_hash,
+        login_request_id,
+        status,
+        created_at,
+        expires_at,
+        poll_token_hash
+      )
+     VALUES
+      (
+        ?,
+        ?,
+        'waiting',
+        CURRENT_TIMESTAMP,
+        ?,
+        ?
+      )`
+  )
+    .bind(
+      stateHash,
+      loginRequestId,
+      expiresAt,
+      pollTokenHash
+    )
+    .run();
+
+  return {
+    state,
+    pollToken,
+    loginRequestId,
+    expiresAt,
+    authorizationUrl:
+      buildAlipayAuthorizationUrl(
+        env,
+        state
+      ),
+  };
+}
+
+
+async function handleManualAlipayLogin(env) {
+  const loginRequest =
+    await createLoginRequestRecord(env);
+
+  return Response.redirect(
+    loginRequest.authorizationUrl,
+    302
+  );
+}
+
+
+/* ============================================================
+ * auth_code换取支付宝用户标识
+ * ============================================================ */
+
+async function exchangeAlipayAuthCode(
+  authCode,
+  env
+) {
+  const parameters = {
+    app_id: env.ALIPAY_APP_ID,
+    method:
+      "alipay.system.oauth.token",
+    format: "JSON",
+    charset: "utf-8",
+    sign_type: "RSA2",
+    timestamp:
+      getBeijingTimestamp(),
+    version: "1.0",
+    grant_type:
+      "authorization_code",
+    code: authCode,
+  };
+
+  parameters.sign =
+    await createAlipaySignature(
+      parameters,
+      env.ALIPAY_APP_PRIVATE_KEY
+    );
+
+  const requestBody =
+    new URLSearchParams();
+
+  for (
+    const [key, value]
+    of Object.entries(parameters)
+  ) {
+    requestBody.set(
+      key,
+      String(value)
+    );
+  }
+
+  const response = await fetch(
+    env.ALIPAY_GATEWAY,
+    {
+      method: "POST",
+      headers: {
+        "Content-Type":
+          "application/x-www-form-urlencoded;charset=utf-8",
+      },
+      body: requestBody.toString(),
+    }
+  );
+
+  const rawText =
+    await response.text();
+
+  let payload;
+
+  try {
+    payload = JSON.parse(rawText);
+  } catch {
+    throw new Error(
+      "支付宝返回了无法解析的内容。" +
+      `HTTP状态码：${response.status}`
+    );
+  }
+
+  const tokenData =
+    payload
+      .alipay_system_oauth_token_response;
+
+  const errorData =
+    payload.error_response;
+
+  if (errorData) {
+    throw new Error(
+      `支付宝接口错误：` +
+      `${errorData.sub_code ||
+        errorData.code ||
+        "unknown"}；` +
+      `${errorData.sub_msg ||
+        errorData.msg ||
+        "未知错误"}`
+    );
+  }
+
+  if (!response.ok || !tokenData) {
+    throw new Error(
+      "支付宝令牌接口没有返回预期结果。"
+    );
+  }
+
+  if (
+    tokenData.code &&
+    String(tokenData.code) !== "10000"
+  ) {
+    throw new Error(
+      `支付宝接口错误：` +
+      `${tokenData.sub_code ||
+        tokenData.code}；` +
+      `${tokenData.sub_msg ||
+        tokenData.msg ||
+        "未知错误"}`
+    );
+  }
+
+  const openId =
+    tokenData.open_id || null;
+
+  const userId =
+    tokenData.user_id ||
+    tokenData.alipay_user_id ||
+    null;
+
+  if (!openId && !userId) {
+    throw new Error(
+      "支付宝授权成功，" +
+      "但没有返回open_id或user_id。"
+    );
+  }
+
+  return {
+    openId,
+    userId,
+  };
+}
+
+
+/* ============================================================
+ * 用户账户
+ * ============================================================ */
+
+async function findExistingUser(
+  env,
+  openId,
+  alipayUserId
+) {
+  if (openId) {
+    const userByOpenId =
+      await env.DB.prepare(
+        `SELECT
+           id,
+           role,
+           status,
+           bonus_papers
+         FROM users
+         WHERE alipay_open_id = ?
+         LIMIT 1`
+      )
+        .bind(openId)
+        .first();
+
+    if (userByOpenId) {
+      return userByOpenId;
+    }
+  }
+
+  if (alipayUserId) {
+    const userByUserId =
+      await env.DB.prepare(
+        `SELECT
+           id,
+           role,
+           status,
+           bonus_papers
+         FROM users
+         WHERE alipay_user_id = ?
+         LIMIT 1`
+      )
+        .bind(alipayUserId)
+        .first();
+
+    if (userByUserId) {
+      return userByUserId;
+    }
+  }
+
+  return null;
+}
+
+
+async function findOrCreateSmartPaperUser(
+  env,
+  openId,
+  alipayUserId
+) {
+  const existingUser =
+    await findExistingUser(
+      env,
+      openId,
+      alipayUserId
+    );
+
+  if (existingUser) {
+    await env.DB.prepare(
+      `UPDATE users
+       SET
+         alipay_open_id =
+           COALESCE(?, alipay_open_id),
+
+         alipay_user_id =
+           COALESCE(?, alipay_user_id),
+
+         updated_at =
+           CURRENT_TIMESTAMP,
+
+         last_login_at =
+           CURRENT_TIMESTAMP
+
+       WHERE id = ?`
+    )
+      .bind(
+        openId,
+        alipayUserId,
+        existingUser.id
+      )
+      .run();
+
+    return {
+      id: existingUser.id,
+      role: existingUser.role,
+      status: existingUser.status,
+      bonusPapers:
+        existingUser.bonus_papers ?? 0,
+      isNew: false,
+    };
+  }
+
+  try {
+    const insertResult =
+      await env.DB.prepare(
+        `INSERT INTO users
+          (
+            alipay_open_id,
+            alipay_user_id,
+            role,
+            status,
+            bonus_papers,
+            created_at,
+            updated_at,
+            last_login_at
+          )
+         VALUES
+          (
+            ?,
+            ?,
+            'user',
+            'active',
+            0,
+            CURRENT_TIMESTAMP,
+            CURRENT_TIMESTAMP,
+            CURRENT_TIMESTAMP
+          )`
+      )
+        .bind(
+          openId,
+          alipayUserId
+        )
+        .run();
+
+    return {
+      id:
+        insertResult.meta.last_row_id,
+      role: "user",
+      status: "active",
+      bonusPapers: 0,
+      isNew: true,
+    };
+  } catch (error) {
+    const userAfterConflict =
+      await findExistingUser(
+        env,
+        openId,
+        alipayUserId
+      );
+
+    if (userAfterConflict) {
+      return {
+        id: userAfterConflict.id,
+        role: userAfterConflict.role,
+        status:
+          userAfterConflict.status,
+        bonusPapers:
+          userAfterConflict
+            .bonus_papers ?? 0,
+        isNew: false,
+      };
+    }
+
+    throw error;
+  }
+}
+
+
+function formatUser(user) {
+  return {
+    id:
+      `U${String(user.id)
+        .padStart(6, "0")}`,
+    numeric_id: user.id,
+    role: user.role,
+    status: user.status,
+    bonus_papers:
+      user.bonus_papers ??
+      user.bonusPapers ??
+      0,
+    daily_free_limit:
+      DAILY_FREE_PAPERS,
+  };
+}
+
+
+/* ============================================================
+ * 支付宝回调
+ * ============================================================ */
+
+async function handleAlipayCallback(
+  request,
+  env
+) {
+  const url = new URL(request.url);
+
+  const authCode =
+    url.searchParams.get("auth_code");
+
+  const state =
+    url.searchParams.get("state");
+
+  const returnedAppId =
+    url.searchParams.get("app_id");
+
+  if (!authCode) {
+    return htmlResponse(
+      "支付宝授权失败",
+      `
+      <div class="card">
+        <h1 class="error">
+          未收到授权码
+        </h1>
+
+        <p>
+          用户可能取消了授权，
+          或支付宝应用权限尚未生效。
+        </p>
+
+        <a
+          class="button"
+          href="/alipay/login"
+        >
+          重新登录
+        </a>
+      </div>
+      `,
+      400
+    );
+  }
+
+  if (!state) {
+    return htmlResponse(
+      "支付宝授权失败",
+      `
+      <div class="card">
+        <h1 class="error">
+          缺少state参数
+        </h1>
+
+        <p>
+          为保护登录安全，
+          本次请求已被拒绝。
+        </p>
+      </div>
+      `,
+      400
+    );
+  }
+
+  const stateHash =
+    await sha256Hex(state);
+
+  const stateRecord =
+    await env.DB.prepare(
+      `SELECT
+         state_hash,
+         login_request_id,
+         status,
+         expires_at
+       FROM oauth_states
+       WHERE state_hash = ?
+       LIMIT 1`
+    )
+      .bind(stateHash)
+      .first();
+
+  if (!stateRecord) {
+    return htmlResponse(
+      "支付宝授权失败",
+      `
+      <div class="card">
+        <h1 class="error">
+          登录请求不存在
+        </h1>
+      </div>
+      `,
+      400
+    );
+  }
+
+  if (
+    stateRecord.status !== "waiting"
+  ) {
+    return htmlResponse(
+      "支付宝授权失败",
+      `
+      <div class="card">
+        <h1 class="error">
+          登录请求已经使用
+        </h1>
+
+        <a
+          class="button"
+          href="/alipay/login"
+        >
+          创建新请求
+        </a>
+      </div>
+      `,
+      409
+    );
+  }
+
+  if (isExpired(stateRecord.expires_at)) {
+    await env.DB.prepare(
+      `UPDATE oauth_states
+       SET status = 'expired'
+       WHERE state_hash = ?`
+    )
+      .bind(stateHash)
+      .run();
+
+    return htmlResponse(
+      "支付宝授权失败",
+      `
+      <div class="card">
+        <h1 class="error">
+          登录请求已经过期
+        </h1>
+
+        <a
+          class="button"
+          href="/alipay/login"
+        >
+          重新登录
+        </a>
+      </div>
+      `,
+      410
+    );
+  }
+
+  if (
+    returnedAppId &&
+    returnedAppId !==
+      env.ALIPAY_APP_ID
+  ) {
+    return htmlResponse(
+      "支付宝授权失败",
+      `
+      <div class="card">
+        <h1 class="error">
+          APPID不匹配
+        </h1>
+      </div>
+      `,
+      400
+    );
+  }
+
+  const claimResult =
+    await env.DB.prepare(
+      `UPDATE oauth_states
+       SET
+         status = 'exchanging',
+         used_at = CURRENT_TIMESTAMP
+       WHERE state_hash = ?
+         AND status = 'waiting'`
+    )
+      .bind(stateHash)
+      .run();
+
+  if (
+    !claimResult.success ||
+    claimResult.meta.changes !== 1
+  ) {
+    return htmlResponse(
+      "支付宝授权失败",
+      `
+      <div class="card">
+        <h1 class="error">
+          登录请求已经被处理
+        </h1>
+      </div>
+      `,
+      409
+    );
+  }
+
+  let alipayIdentity;
+
+  try {
+    alipayIdentity =
+      await exchangeAlipayAuthCode(
+        authCode,
+        env
+      );
+  } catch (error) {
+    await env.DB.prepare(
+      `UPDATE oauth_states
+       SET status =
+         'token_exchange_failed'
+       WHERE state_hash = ?`
+    )
+      .bind(stateHash)
+      .run();
+
+    return htmlResponse(
+      "支付宝身份交换失败",
+      `
+      <div class="card">
+        <h1 class="error">
+          未能取得支付宝用户标识
+        </h1>
+
+        <p>
+          <code>
+            ${escapeHtml(String(error))}
+          </code>
+        </p>
+
+        <a
+          class="button"
+          href="/alipay/login"
+        >
+          创建新请求
+        </a>
+      </div>
+      `,
+      500
+    );
+  }
+
+  let smartPaperUser;
+
+  try {
+    smartPaperUser =
+      await findOrCreateSmartPaperUser(
+        env,
+        alipayIdentity.openId,
+        alipayIdentity.userId
+      );
+  } catch (error) {
+    await env.DB.prepare(
+      `UPDATE oauth_states
+       SET status =
+         'user_creation_failed'
+       WHERE state_hash = ?`
+    )
+      .bind(stateHash)
+      .run();
+
+    return htmlResponse(
+      "SmartPaper账户创建失败",
+      `
+      <div class="card">
+        <h1 class="error">
+          无法建立用户账户
+        </h1>
+
+        <p>
+          <code>
+            ${escapeHtml(String(error))}
+          </code>
+        </p>
+      </div>
+      `,
+      500
+    );
+  }
+
+  if (
+    smartPaperUser.status !== "active"
+  ) {
+    await env.DB.prepare(
+      `UPDATE oauth_states
+       SET
+         status = 'user_blocked',
+         user_id = ?
+       WHERE state_hash = ?`
+    )
+      .bind(
+        smartPaperUser.id,
+        stateHash
+      )
+      .run();
+
+    return htmlResponse(
+      "SmartPaper账户不可用",
+      `
+      <div class="card">
+        <h1 class="error">
+          账户已被停用
+        </h1>
+      </div>
+      `,
+      403
+    );
+  }
+
+  await env.DB.prepare(
+    `UPDATE oauth_states
+     SET
+       status = 'authenticated',
+       user_id = ?
+     WHERE state_hash = ?
+       AND status = 'exchanging'`
+  )
+    .bind(
+      smartPaperUser.id,
+      stateHash
+    )
+    .run();
+
+  return htmlResponse(
+    "支付宝身份识别成功",
+    `
+    <div class="card">
+      <h1 class="success">
+        支付宝身份识别成功
+      </h1>
+
+      <p>
+        SmartPaper用户：
+        <strong>
+          ${escapeHtml(
+            formatUser(
+              smartPaperUser
+            ).id
+          )}
+        </strong>
+      </p>
+
+      <p>
+        请返回电脑上的SmartPaper页面。
+        系统将自动完成登录。
+      </p>
+
+      <p class="muted">
+        本页面不会显示支付宝用户标识、
+        访问令牌或SmartPaper会话令牌。
+      </p>
+    </div>
+    `
+  );
+}
+
+
+/* ============================================================
+ * Hugging Face创建登录请求
+ * POST /login/create
+ * ============================================================ */
+
+async function handleLoginCreate(
+  request,
+  env
+) {
+  const unauthorized =
+    await requireServiceRequest(
+      request,
+      env
+    );
+
+  if (unauthorized) {
+    return unauthorized;
+  }
+
+  const loginRequest =
+    await createLoginRequestRecord(env);
+
+  return jsonResponse({
+    ok: true,
+    status: "waiting",
+    login_request_id:
+      loginRequest.loginRequestId,
+    poll_token:
+      loginRequest.pollToken,
+    authorization_url:
+      loginRequest.authorizationUrl,
+    qr_content:
+      loginRequest.authorizationUrl,
+    expires_at:
+      loginRequest.expiresAt,
+    poll_interval_seconds: 2,
+  });
+}
+
+
+/* ============================================================
+ * Hugging Face查询登录状态
+ * POST /login/status
+ * ============================================================ */
+
+async function handleLoginStatus(
+  request,
+  env
+) {
+  const unauthorized =
+    await requireServiceRequest(
+      request,
+      env
+    );
+
+  if (unauthorized) {
+    return unauthorized;
+  }
+
+  const body =
+    await readJsonBody(request);
+
+  const loginRequestId =
+    String(
+      body?.login_request_id || ""
+    ).trim();
+
+  const pollToken =
+    String(
+      body?.poll_token || ""
+    ).trim();
+
+  if (
+    !loginRequestId ||
+    !pollToken
+  ) {
+    return jsonResponse(
+      {
+        ok: false,
+        error: "invalid_request",
+        required: [
+          "login_request_id",
+          "poll_token",
+        ],
+      },
+      400
+    );
+  }
+
+  const pollTokenHash =
+    await hmacHex(
+      pollToken,
+      env.SESSION_SIGNING_SECRET
+    );
+
+  let record =
+    await env.DB.prepare(
+      `SELECT
+         login_request_id,
+         status,
+         user_id,
+         expires_at,
+         session_issued_at
+       FROM oauth_states
+       WHERE login_request_id = ?
+         AND poll_token_hash = ?
+       LIMIT 1`
+    )
+      .bind(
+        loginRequestId,
+        pollTokenHash
+      )
+      .first();
+
+  if (!record) {
+    return jsonResponse(
+      {
+        ok: false,
+        error:
+          "login_request_not_found",
+      },
+      404
+    );
+  }
+
+  if (
+    isExpired(record.expires_at) &&
+    ![
+      "completed",
+      "authenticated",
+      "issuing",
+    ].includes(record.status)
+  ) {
+    await env.DB.prepare(
+      `UPDATE oauth_states
+       SET status = 'expired'
+       WHERE login_request_id = ?
+         AND poll_token_hash = ?`
+    )
+      .bind(
+        loginRequestId,
+        pollTokenHash
+      )
+      .run();
+
+    return jsonResponse(
+      {
+        ok: false,
+        status: "expired",
+      },
+      410
+    );
+  }
+
+  if (
+    record.status === "waiting" ||
+    record.status === "exchanging" ||
+    record.status === "issuing"
+  ) {
+    return jsonResponse({
+      ok: true,
+      status: "pending",
+    });
+  }
+
+  if (
+    [
+      "expired",
+      "token_exchange_failed",
+      "user_creation_failed",
+      "user_blocked",
+    ].includes(record.status)
+  ) {
+    return jsonResponse(
+      {
+        ok: false,
+        status: "failed",
+        reason: record.status,
+      },
+      400
+    );
+  }
+
+  if (record.status === "completed") {
+    return jsonResponse(
+      {
+        ok: false,
+        status: "already_delivered",
+        message:
+          "该登录结果已经领取，请重新扫码登录。",
+      },
+      409
+    );
+  }
+
+  if (
+    record.status !== "authenticated" ||
+    !record.user_id
+  ) {
+    return jsonResponse(
+      {
+        ok: false,
+        status: "invalid_state",
+        current_status:
+          record.status,
+      },
+      409
+    );
+  }
+
+  const user =
+    await env.DB.prepare(
+      `SELECT
+         id,
+         role,
+         status,
+         bonus_papers
+       FROM users
+       WHERE id = ?
+       LIMIT 1`
+    )
+      .bind(record.user_id)
+      .first();
+
+  if (!user) {
+    return jsonResponse(
+      {
+        ok: false,
+        error: "user_not_found",
+      },
+      404
+    );
+  }
+
+  if (user.status !== "active") {
+    await env.DB.prepare(
+      `UPDATE oauth_states
+       SET status = 'user_blocked'
+       WHERE login_request_id = ?`
+    )
+      .bind(loginRequestId)
+      .run();
+
+    return jsonResponse(
+      {
+        ok: false,
+        error: "user_blocked",
+      },
+      403
+    );
+  }
+
+  const claimResult =
+    await env.DB.prepare(
+      `UPDATE oauth_states
+       SET status = 'issuing'
+       WHERE login_request_id = ?
+         AND poll_token_hash = ?
+         AND status = 'authenticated'
+         AND session_issued_at IS NULL`
+    )
+      .bind(
+        loginRequestId,
+        pollTokenHash
+      )
+      .run();
+
+  if (
+    !claimResult.success ||
+    claimResult.meta.changes !== 1
+  ) {
+    return jsonResponse({
+      ok: true,
+      status: "pending",
+    });
+  }
+
+  const sessionToken =
+    randomToken(48);
+
+  const sessionHash =
+    await hmacHex(
+      sessionToken,
+      env.SESSION_SIGNING_SECRET
+    );
+
+  const sessionExpiresAt =
+    new Date(
+      Date.now() + SESSION_TTL_MS
+    ).toISOString();
+
+  try {
+    await env.DB.batch([
+      env.DB.prepare(
+        `INSERT INTO login_sessions
+          (
+            session_hash,
+            user_id,
+            created_at,
+            expires_at,
+            revoked_at
+          )
+         VALUES
+          (
+            ?,
+            ?,
+            CURRENT_TIMESTAMP,
+            ?,
+            NULL
+          )`
+      ).bind(
+        sessionHash,
+        user.id,
+        sessionExpiresAt
+      ),
+
+      env.DB.prepare(
+        `UPDATE oauth_states
+         SET
+           status = 'completed',
+           session_issued_at =
+             CURRENT_TIMESTAMP
+         WHERE login_request_id = ?
+           AND status = 'issuing'`
+      ).bind(loginRequestId),
+    ]);
+  } catch (error) {
+    await env.DB.prepare(
+      `UPDATE oauth_states
+       SET status = 'authenticated'
+       WHERE login_request_id = ?
+         AND status = 'issuing'`
+    )
+      .bind(loginRequestId)
+      .run();
+
+    throw error;
+  }
+
+  return jsonResponse({
+    ok: true,
+    status: "authenticated",
+    session_token: sessionToken,
+    session_expires_at:
+      sessionExpiresAt,
+    user: formatUser(user),
+  });
+}
+
+
+/* ============================================================
+ * 验证SmartPaper会话
+ * POST /session/verify
+ * ============================================================ */
+
+async function handleSessionVerify(
+  request,
+  env
+) {
+  const unauthorized =
+    await requireServiceRequest(
+      request,
+      env
+    );
+
+  if (unauthorized) {
+    return unauthorized;
+  }
+
+  const body =
+    await readJsonBody(request);
+
+  const sessionToken =
+    String(
+      body?.session_token || ""
+    ).trim();
+
+  if (!sessionToken) {
+    return jsonResponse(
+      {
+        ok: false,
+        error:
+          "session_token_required",
+      },
+      400
+    );
+  }
+
+  const sessionHash =
+    await hmacHex(
+      sessionToken,
+      env.SESSION_SIGNING_SECRET
+    );
+
+  const session =
+    await env.DB.prepare(
+      `SELECT
+         s.session_hash,
+         s.expires_at,
+         s.revoked_at,
+
+         u.id,
+         u.role,
+         u.status,
+         u.bonus_papers
+
+       FROM login_sessions AS s
+
+       INNER JOIN users AS u
+         ON u.id = s.user_id
+
+       WHERE s.session_hash = ?
+       LIMIT 1`
+    )
+      .bind(sessionHash)
+      .first();
+
+  if (!session) {
+    return jsonResponse(
+      {
+        ok: false,
+        valid: false,
+        error: "invalid_session",
+      },
+      401
+    );
+  }
+
+  if (session.revoked_at) {
+    return jsonResponse(
+      {
+        ok: false,
+        valid: false,
+        error: "session_revoked",
+      },
+      401
+    );
+  }
+
+  if (isExpired(session.expires_at)) {
+    return jsonResponse(
+      {
+        ok: false,
+        valid: false,
+        error: "session_expired",
+      },
+      401
+    );
+  }
+
+  if (session.status !== "active") {
+    return jsonResponse(
+      {
+        ok: false,
+        valid: false,
+        error: "user_blocked",
+      },
+      403
+    );
+  }
+
+  return jsonResponse({
+    ok: true,
+    valid: true,
+    session_expires_at:
+      session.expires_at,
+    user: formatUser(session),
+  });
+}
+
+
+/* ============================================================
+ * 注销SmartPaper会话
+ * POST /logout
+ * ============================================================ */
+
+async function handleLogout(
+  request,
+  env
+) {
+  const unauthorized =
+    await requireServiceRequest(
+      request,
+      env
+    );
+
+  if (unauthorized) {
+    return unauthorized;
+  }
+
+  const body =
+    await readJsonBody(request);
+
+  const sessionToken =
+    String(
+      body?.session_token || ""
+    ).trim();
+
+  if (!sessionToken) {
+    return jsonResponse(
+      {
+        ok: false,
+        error:
+          "session_token_required",
+      },
+      400
+    );
+  }
+
+  const sessionHash =
+    await hmacHex(
+      sessionToken,
+      env.SESSION_SIGNING_SECRET
+    );
+
+  await env.DB.prepare(
+    `UPDATE login_sessions
+     SET revoked_at =
+       COALESCE(
+         revoked_at,
+         CURRENT_TIMESTAMP
+       )
+     WHERE session_hash = ?`
+  )
+    .bind(sessionHash)
+    .run();
+
+  return jsonResponse({
+    ok: true,
+    logged_out: true,
+  });
+}
+
+
+/* ============================================================
+ * Worker主入口
+ * ============================================================ */
+
+export default {
+  async fetch(request, env) {
+    const url = new URL(request.url);
+
+    try {
+      if (request.method === "OPTIONS") {
+        return new Response(null, {
+          status: 204,
+        });
+      }
+
+      if (url.pathname === "/health") {
+        const missing =
+          getMissingConfiguration(env);
+
+        return jsonResponse({
+          ok: missing.length === 0,
+          service:
+            "smartpaper-auth",
+          stage:
+            "smartpaper-session-backend",
+          configuration_ready:
+            missing.length === 0,
+          missing,
+          rules: {
+            daily_free_papers:
+              DAILY_FREE_PAPERS,
+            payment_amount_fen:
+              PAYMENT_AMOUNT_FEN,
+            payment_bonus_papers:
+              PAYMENT_BONUS_PAPERS,
+            session_hours: 8,
+          },
+          time:
+            new Date().toISOString(),
+        });
+      }
+
+      if (url.pathname === "/db-test") {
+        if (!env.DB) {
+          return jsonResponse(
+            {
+              ok: false,
+              error:
+                "DB binding is missing",
+            },
+            500
+          );
+        }
+
+        const result =
+          await env.DB.prepare(
+            "SELECT 1 AS connected"
+          ).first();
+
+        return jsonResponse({
+          ok: true,
+          database:
+            "smartpaper-db",
+          connected:
+            result?.connected === 1,
+        });
+      }
+
+      if (url.pathname === "/privacy") {
+        return htmlResponse(
+          "SmartPaper隐私说明",
+          `
+          <div class="card">
+            <h1>
+              SmartPaper隐私说明
+            </h1>
+
+            <p>
+              SmartPaper使用支付宝授权返回的
+              用户唯一标识建立用户账户。
+            </p>
+
+            <p>
+              该标识用于用户登录、
+              每日免费3篇论文的额度管理、
+              长期有效论文管理、任务排队、
+              失败退还和异常滥用防范。
+            </p>
+
+            <p>
+              SmartPaper原则上不收集身份证号码、
+              真实姓名、手机号、通讯录或其他
+              与上述目的无关的信息。
+            </p>
+
+            <p>
+              当前页面为开发测试阶段隐私说明。
+            </p>
+          </div>
+          `
+        );
+      }
+
+      if (
+        url.pathname === "/alipay/login" &&
+        request.method === "GET"
+      ) {
+        return await handleManualAlipayLogin(
+          env
+        );
+      }
+
+      if (
+        url.pathname ===
+          "/alipay/callback" &&
+        request.method === "GET"
+      ) {
+        return await handleAlipayCallback(
+          request,
+          env
+        );
+      }
+
+      if (
+        url.pathname ===
+          "/login/create" &&
+        request.method === "POST"
+      ) {
+        return await handleLoginCreate(
+          request,
+          env
+        );
+      }
+
+      if (
+        url.pathname ===
+          "/login/status" &&
+        request.method === "POST"
+      ) {
+        return await handleLoginStatus(
+          request,
+          env
+        );
+      }
+
+      if (
+        url.pathname ===
+          "/session/verify" &&
+        request.method === "POST"
+      ) {
+        return await handleSessionVerify(
+          request,
+          env
+        );
+      }
+
+      if (
+        url.pathname === "/logout" &&
+        request.method === "POST"
+      ) {
+        return await handleLogout(
+          request,
+          env
+        );
+      }
+
+      if (
+        url.pathname === "/" &&
+        request.method === "GET"
+      ) {
+        return htmlResponse(
+          "SmartPaper支付宝登录测试",
+          `
+          <div class="card">
+            <h1>
+              SmartPaper支付宝登录测试
+            </h1>
+
+            <p>
+              支付宝用户识别和SmartPaper
+              8小时会话后端已经启用。
+            </p>
+
+            <p>
+              点击按钮后，
+              请使用手机支付宝扫码并确认授权。
+            </p>
+
+            <a
+              class="button"
+              href="/alipay/login"
+            >
+              开始支付宝扫码登录测试
+            </a>
+
+            <p class="links">
+              <a href="/health">
+                检查Worker
+              </a>
+
+              &nbsp;|&nbsp;
+
+              <a href="/db-test">
+                检查数据库
+              </a>
+
+              &nbsp;|&nbsp;
+
+              <a href="/privacy">
+                查看隐私说明
+              </a>
+            </p>
+          </div>
+          `
+        );
+      }
+
+      return jsonResponse(
+        {
+          ok: false,
+          error: "not_found",
+          path: url.pathname,
+        },
+        404
+      );
+    } catch (error) {
+      console.error(error);
+
+      return jsonResponse(
+        {
+          ok: false,
+          error: "internal_error",
+          detail: String(error),
+        },
+        500
+      );
+    }
+  },
+};

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/.gitattributes

@@ -0,0 +1,35 @@
+*.7z filter=lfs diff=lfs merge=lfs -text
+*.arrow filter=lfs diff=lfs merge=lfs -text
+*.bin filter=lfs diff=lfs merge=lfs -text
+*.bz2 filter=lfs diff=lfs merge=lfs -text
+*.ckpt filter=lfs diff=lfs merge=lfs -text
+*.ftz filter=lfs diff=lfs merge=lfs -text
+*.gz filter=lfs diff=lfs merge=lfs -text
+*.h5 filter=lfs diff=lfs merge=lfs -text
+*.joblib filter=lfs diff=lfs merge=lfs -text
+*.lfs.* filter=lfs diff=lfs merge=lfs -text
+*.mlmodel filter=lfs diff=lfs merge=lfs -text
+*.model filter=lfs diff=lfs merge=lfs -text
+*.msgpack filter=lfs diff=lfs merge=lfs -text
+*.npy filter=lfs diff=lfs merge=lfs -text
+*.npz filter=lfs diff=lfs merge=lfs -text
+*.onnx filter=lfs diff=lfs merge=lfs -text
+*.ot filter=lfs diff=lfs merge=lfs -text
+*.parquet filter=lfs diff=lfs merge=lfs -text
+*.pb filter=lfs diff=lfs merge=lfs -text
+*.pickle filter=lfs diff=lfs merge=lfs -text
+*.pkl filter=lfs diff=lfs merge=lfs -text
+*.pt filter=lfs diff=lfs merge=lfs -text
+*.pth filter=lfs diff=lfs merge=lfs -text
+*.rar filter=lfs diff=lfs merge=lfs -text
+*.safetensors filter=lfs diff=lfs merge=lfs -text
+saved_model/**/* filter=lfs diff=lfs merge=lfs -text
+*.tar.* filter=lfs diff=lfs merge=lfs -text
+*.tar filter=lfs diff=lfs merge=lfs -text
+*.tflite filter=lfs diff=lfs merge=lfs -text
+*.tgz filter=lfs diff=lfs merge=lfs -text
+*.wasm filter=lfs diff=lfs merge=lfs -text
+*.xz filter=lfs diff=lfs merge=lfs -text
+*.zip filter=lfs diff=lfs merge=lfs -text
+*.zst filter=lfs diff=lfs merge=lfs -text
+*tfevents* filter=lfs diff=lfs merge=lfs -text

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/.streamlit/config.toml

@@ -0,0 +1,8 @@
+[server]
+enableCORS = false
+enableXsrfProtection = false
+enableWebsocketCompression = false
+maxUploadSize = 1024
+
+[browser]
+gatherUsageStats = false

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/.streamlit/desktop.ini

@@ -0,0 +1,2 @@
+[.ShellClassInfo]
+IconResource=C:\Program Files\Google\Drive File Stream\129.0.1.0\GoogleDriveFS.exe,27

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/HF_COMMIT_SHA.txt

@@ -0,0 +1 @@
+af60fe1bdcbab60f47f06586cca03210f7f61026

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/Plaintext

@@ -0,0 +1,11 @@
+project_root/
+├── app.py                 (主应用入口：UI界面与流程调度)
+├── config.py              (静态配置：提示词字典与基础参数)
+├── core/
+│   └── pipeline_agent.py  (核心大脑：SSciPipelineAgent 类)
+│   ├── rag_engine.py       🌟 [新建] 专门负责处理 20+ 篇大体量文献的切块与按需检索
+│   ├── meta_extractor.py   🌟 [新建] 专门负责从文献中榨取 JSON 格式的黄金价值数据
+│   └── qualitative_engine.py 🌟 [新建] 专门定性研究
+└── utils/
+    ├── file_parser.py     (工具：PDF/Word/Excel解析)
+    └── docx_builder.py    (工具：Markdown转Word渲染器)

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/README.md

@@ -0,0 +1,14 @@
+---
+title: Agent Article
+emoji: 📊
+colorFrom: blue
+colorTo: green
+sdk: streamlit
+app_file: app.py
+pinned: false
+short_description: Agent Article
+sdk_version: 1.38.0
+python_version: 3.11
+---
+
+Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/app.py

@@ -0,0 +1,1378 @@
+# -*- coding: utf-8 -*-
+"""Smart Draft - Dual Track (AMJ Empirical vs ASQ Qualitative)"""
+from core.meta_extractor import extract_golden_metadata
+from core.rag_engine import initialize_rag
+from core.qualitative_engine import get_qualitative_engine
+from core.quantitative_engine import get_quantitative_engine
+from core.production_guard import build_validated_package, replace_abstract
+import streamlit as st
+
+st.set_page_config(
+    page_title="Article Agent",
+    page_icon="📊",
+    layout="wide",
+    initial_sidebar_state="collapsed",
+)
+
+import warnings
+warnings.filterwarnings("ignore", message="coroutine 'expire_cache' was never awaited")
+
+import os
+import streamlit.components.v1 as components
+import time
+import re
+import math
+import json
+import secrets
+from datetime import datetime, timezone, timedelta
+from concurrent.futures import ThreadPoolExecutor
+
+from config import APP_CONFIG, AMJ_PROMPTS, ASQ_PROMPTS
+from utils.file_parser import extract_text_from_files
+from core.pipeline_agent import SSciPipelineAgent
+from managed_auth import (
+    require_alipay_login,
+    render_logged_in_account,
+    start_generation_task,
+    heartbeat_generation_task,
+    finish_generation_task,
+    render_payment_purchase,
+)
+from i18n import LANGUAGE_OPTIONS, get_amj_csv_template, get_asq_txt_template, get_output_suffix, get_target_flag, get_target_language, tr
+
+os.environ["STREAMLIT_SERVER_ENABLE_CORS"] = "false"
+os.environ["STREAMLIT_SERVER_ENABLE_XSRF_PROTECTION"] = "false"
+
+WORKSPACE_DIR = APP_CONFIG.get("workspace_dir", ".workspace")
+os.makedirs(WORKSPACE_DIR, exist_ok=True)
+LEGACY_CHECKPOINT_FILE = os.path.join(WORKSPACE_DIR, "snapshot.json")
+CHECKPOINT_FILE = LEGACY_CHECKPOINT_FILE
+
+META_SECTIONS_BLACKLIST = set(APP_CONFIG["blacklists"]["meta_sections"])
+
+
+def update_heartbeat():
+    """Refresh the authoritative Cloudflare/D1 task lease only."""
+    now = time.time()
+    task = st.session_state.get("sp_generation_task") or {}
+    task_id = str(task.get("task_id") or "").strip()
+    interval = max(3, int(APP_CONFIG.get("task_heartbeat_interval_seconds", 5)))
+    last_remote = float(st.session_state.get("sp_last_task_heartbeat") or 0.0)
+    if not task_id or now - last_remote < interval:
+        return
+    try:
+        heartbeat_generation_task(
+            task_id,
+            current_node=str(st.session_state.get("sp_current_node") or "")[:240],
+        )
+        st.session_state["sp_last_task_heartbeat"] = now
+    except Exception:
+        # The hidden browser bridge continues heartbeats independently. A single
+        # transient UI heartbeat must not interrupt model generation.
+        pass
+
+
+def is_system_busy():
+    """D1 is the sole concurrency authority; no duplicate Hugging Face file lock."""
+    return False
+
+
+def clear_heartbeat():
+    """Backward-compatible no-op after removal of the duplicate local lock."""
+    return None
+
+
+def stream_with_heartbeat(generator):
+    """Refresh the D1 lease while streaming model output."""
+    last_beat = time.time()
+    for chunk in generator:
+        now = time.time()
+        if now - last_beat > 5:
+            update_heartbeat()
+            last_beat = now
+        yield chunk
+
+
+def clean_trailing_references(text, keywords=("reference", "references", "reference list", "参考文献")):
+    lines = text.split('\n')
+    for i in range(len(lines)-1, max(-1, len(lines)-100), -1):
+        if any(re.match(rf'^##?\s*{kw}', lines[i], re.IGNORECASE) for kw in keywords):
+            return '\n'.join(lines[:i]).strip()
+    return text.strip()
+
+def clean_markdown_headings(text):
+    return re.sub(r'(?m)^#+\s+(.*)$', r'**\1**', text)
+
+def _read_runtime_secret(name):
+    # Read a Hugging Face/Streamlit secret and remove copied whitespace.
+    value = os.environ.get(name, "")
+    if not value:
+        try:
+            value = st.secrets.get(name, "")
+        except Exception:
+            value = ""
+    return str(value or "").strip()
+
+
+global_ds_key = _read_runtime_secret("DEEPSEEK_API_KEY")
+global_s2_key = _read_runtime_secret("S2_API_KEY")
+
+WECHAT_BLOCKER_JS = """<script>try{var ua=navigator.userAgent.toLowerCase();if(ua.indexOf('micromessenger')!==-1){var parentDoc=window.parent.document;if(!parentDoc.getElementById('wx-blocker')){var overlay=parentDoc.createElement('div');overlay.id='wx-blocker';overlay.style.cssText='position:fixed;top:0;left:0;width:100vw;height:100vh;background:#1a365d;z-index:9999999;color:white;display:flex;flex-direction:column;align-items:center;justify-content:center;text-align:center;font-family:sans-serif;padding:30px;box-sizing:border-box;';overlay.innerHTML='<h2 style="font-size:26px;margin-bottom:15px;font-weight:bold;">环境受限 / Restricted</h2><p style="font-size:18px;line-height:1.6;color:#e2e8f0;max-width:100%;">为了保障最终双语 ZIP 压缩包正常下载，<b>本系统禁止在微信内直接运行</b>。<br><br>👉 <b>请点击右上角 [···] 菜单，选择“在浏览器打开” (Open in Browser)</b></p>';parentDoc.body.appendChild(overlay);}}}catch(e){}</script>"""
+components.html(WECHAT_BLOCKER_JS, height=0, width=0)
+
+
+def inject_file_uploader_i18n(language: str) -> None:
+    """Localize Streamlit uploaders without modifying their React structure."""
+    payload = {
+        "browse": tr(language, "browse_files"),
+        "uploaders": [
+            {
+                "title": tr(language, "drop_docs"),
+                "limit": tr(language, "limit_docs"),
+            },
+            {
+                "title": tr(language, "drop_data"),
+                "limit": tr(language, "limit_data"),
+            },
+            {
+                "title": tr(language, "drop_docs"),
+                "limit": tr(language, "limit_docs"),
+            },
+            {
+                "title": tr(language, "drop_interviews"),
+                "limit": tr(language, "limit_interviews"),
+            },
+        ],
+    }
+
+    script = f"""
+    <script>
+    (() => {{
+      const payload = {json.dumps(payload, ensure_ascii=False)};
+      const parentDocument = window.parent.document;
+
+      function leafTextElements(root) {{
+        return Array.from(
+          root.querySelectorAll("p, span, small, div")
+        ).filter((element) => (
+          element.children.length === 0 &&
+          element.textContent.trim().length > 0
+        ));
+      }}
+
+      function replaceTextSafely(element, value) {{
+        if (element && element.textContent.trim() !== value) {{
+          element.textContent = value;
+        }}
+      }}
+
+      function applyUploaderTranslations() {{
+        const zones = parentDocument.querySelectorAll(
+          '[data-testid="stFileUploaderDropzone"]'
+        );
+
+        zones.forEach((zone, index) => {{
+          const config = payload.uploaders[index];
+          if (!config) return;
+
+          const instructions = zone.querySelector(
+            '[data-testid="stFileUploaderDropzoneInstructions"]'
+          );
+
+          if (instructions) {{
+            const leaves = leafTextElements(instructions);
+            replaceTextSafely(leaves[0], config.title);
+            replaceTextSafely(leaves[1], config.limit);
+          }}
+
+          const button = zone.querySelector("button");
+          if (button) {{
+            const buttonLeaves = leafTextElements(button);
+            const textTarget = buttonLeaves[buttonLeaves.length - 1];
+
+            replaceTextSafely(textTarget, payload.browse);
+            button.setAttribute("aria-label", payload.browse);
+            button.setAttribute("title", payload.browse);
+          }}
+        }});
+      }}
+
+      [0, 100, 300, 700, 1400, 2500].forEach((delay) => {{
+        window.setTimeout(applyUploaderTranslations, delay);
+      }});
+    }})();
+    </script>
+    """
+
+    components.html(script, height=0, width=0)
+
+
+
+def inject_wechat_browser_notice() -> None:
+    """Warn immediately when SmartPaper is opened inside WeChat or WeCom."""
+    script = """
+    <script>
+    (() => {
+      const parentWindow = window.parent;
+      const parentDocument = parentWindow.document;
+      const userAgent = String(
+        parentWindow.navigator.userAgent || navigator.userAgent || ""
+      );
+
+      const isWechat =
+        /MicroMessenger|WeChat|wxwork/i.test(userAgent);
+
+      const noticeId = "smartpaper-wechat-browser-notice";
+      const existingNotice = parentDocument.getElementById(noticeId);
+
+      if (!isWechat) {
+        if (existingNotice) existingNotice.remove();
+        return;
+      }
+
+      if (existingNotice) return;
+
+      const overlay = parentDocument.createElement("div");
+      overlay.id = noticeId;
+      overlay.style.cssText = [
+        "position:fixed",
+        "inset:0",
+        "z-index:2147483647",
+        "display:flex",
+        "align-items:center",
+        "justify-content:center",
+        "padding:24px",
+        "background:rgba(8,12,20,.96)",
+        "box-sizing:border-box"
+      ].join(";");
+
+      const card = parentDocument.createElement("div");
+      card.style.cssText = [
+        "width:min(620px,100%)",
+        "padding:30px",
+        "border:1px solid rgba(148,163,184,.35)",
+        "border-radius:18px",
+        "background:#111827",
+        "color:#f8fafc",
+        "font-family:Arial,'Microsoft YaHei','PingFang SC',sans-serif",
+        "line-height:1.7",
+        "box-shadow:0 20px 50px rgba(0,0,0,.38)"
+      ].join(";");
+
+      const title = parentDocument.createElement("h2");
+      title.textContent = "请在浏览器中打开 / Open in Browser";
+      title.style.cssText =
+        "margin:0 0 14px;font-size:24px;color:#ffffff;";
+
+      const chinese = parentDocument.createElement("p");
+      chinese.textContent =
+        "微信内置页面可能无法正常完成登录和文件操作。请点击右上角“…”并选择“在浏览器打开”。";
+      chinese.style.cssText = "margin:0 0 12px;font-size:16px;";
+
+      const english = parentDocument.createElement("p");
+      english.textContent =
+        "The WeChat in-app page may not complete sign-in or file operations correctly. Tap “…” in the top-right corner and choose “Open in Browser.”";
+      english.style.cssText =
+        "margin:0 0 20px;font-size:15px;color:#cbd5e1;";
+
+      const copyButton = parentDocument.createElement("button");
+      copyButton.type = "button";
+      copyButton.textContent = "复制网址 / Copy link";
+      copyButton.style.cssText = [
+        "width:100%",
+        "padding:12px 16px",
+        "border:0",
+        "border-radius:10px",
+        "background:#1677ff",
+        "color:#ffffff",
+        "font-size:16px",
+        "font-weight:700",
+        "cursor:pointer"
+      ].join(";");
+
+      copyButton.addEventListener("click", async () => {
+        const url = parentWindow.location.href;
+
+        try {
+          await parentWindow.navigator.clipboard.writeText(url);
+          copyButton.textContent = "已复制 / Copied";
+        } catch (_) {
+          const textarea = parentDocument.createElement("textarea");
+          textarea.value = url;
+          textarea.style.position = "fixed";
+          textarea.style.opacity = "0";
+          parentDocument.body.appendChild(textarea);
+          textarea.focus();
+          textarea.select();
+          parentDocument.execCommand("copy");
+          textarea.remove();
+          copyButton.textContent = "已复制 / Copied";
+        }
+
+        parentWindow.setTimeout(() => {
+          copyButton.textContent = "复制网址 / Copy link";
+        }, 1800);
+      });
+
+      card.appendChild(title);
+      card.appendChild(chinese);
+      card.appendChild(english);
+      card.appendChild(copyButton);
+      overlay.appendChild(card);
+      parentDocument.body.appendChild(overlay);
+    })();
+    </script>
+    """
+
+    components.html(script, height=0, width=0)
+
+
+if "is_running" not in st.session_state: st.session_state.is_running = False
+if "start_pipeline" not in st.session_state: st.session_state.start_pipeline = False
+if "resume_pipeline" not in st.session_state: st.session_state.resume_pipeline = False
+if "zip_buffer" not in st.session_state: st.session_state.zip_buffer = None
+if "run_mode" not in st.session_state: st.session_state.run_mode = "amj"
+if "sp_generation_task" not in st.session_state: st.session_state.sp_generation_task = None
+if "sp_generation_idempotency_key" not in st.session_state: st.session_state.sp_generation_idempotency_key = ""
+if "sp_last_task_heartbeat" not in st.session_state: st.session_state.sp_last_task_heartbeat = 0.0
+if "sp_current_node" not in st.session_state: st.session_state.sp_current_node = ""
+if "sp_pending_task_finalization" not in st.session_state: st.session_state.sp_pending_task_finalization = None
+if "sp_pending_package" not in st.session_state: st.session_state.sp_pending_package = None
+if "sp_terminal_notice" not in st.session_state: st.session_state.sp_terminal_notice = None
+
+
+def _safe_user_workspace_key(value):
+    cleaned = re.sub(r"[^A-Za-z0-9_.-]", "_", str(value or "").strip())
+    return cleaned[:80] or "anonymous"
+
+
+def _load_recoverable_checkpoint():
+    """Return a validated checkpoint for the current authenticated user only."""
+    if not os.path.isfile(CHECKPOINT_FILE):
+        return None
+    try:
+        with open(CHECKPOINT_FILE, "r", encoding="utf-8") as handle:
+            state = json.load(handle)
+    except Exception:
+        return None
+    required = {
+        "topic", "keywords", "target_lang", "words",
+        "agent_state", "adaptive_structure", "completed_sections",
+    }
+    if not isinstance(state, dict) or not required.issubset(state):
+        return None
+    if not isinstance(state.get("adaptive_structure"), list):
+        return None
+    if not isinstance(state.get("completed_sections"), list):
+        return None
+    return state
+
+
+def _new_generation_idempotency_key() -> str:
+    return f"gen_{int(time.time() * 1000)}_{secrets.token_urlsafe(18)}"
+
+
+def _prepare_new_generation_request() -> None:
+    st.session_state["sp_generation_idempotency_key"] = _new_generation_idempotency_key()
+    st.session_state["sp_generation_task"] = None
+    st.session_state["sp_last_task_heartbeat"] = 0.0
+    st.session_state["sp_current_node"] = "task_start"
+    st.session_state["zip_buffer"] = None
+    st.session_state["zip_filename"] = ""
+    st.session_state["sp_pending_task_finalization"] = None
+    st.session_state["sp_pending_package"] = None
+    st.session_state["sp_terminal_notice"] = None
+
+
+def _begin_managed_generation_task(*, is_resume: bool, loaded_state: dict | None, mode: str, language: str):
+    checkpoint_key = ""
+    if is_resume and isinstance(loaded_state, dict):
+        checkpoint_key = str(loaded_state.get("managed_task_idempotency_key") or "").strip()
+
+    idempotency_key = checkpoint_key or str(
+        st.session_state.get("sp_generation_idempotency_key") or ""
+    ).strip()
+    if not idempotency_key:
+        idempotency_key = _new_generation_idempotency_key()
+
+    response = start_generation_task(
+        idempotency_key=idempotency_key,
+        mode=mode,
+        interface_language=language,
+    )
+    task = dict(response.get("task") or {})
+    if not task.get("task_id"):
+        raise RuntimeError("task_start_missing_task_id")
+
+    st.session_state["sp_generation_idempotency_key"] = idempotency_key
+    st.session_state["sp_generation_task"] = task
+    st.session_state["sp_last_task_heartbeat"] = time.time()
+    return task, idempotency_key
+
+
+def _task_output_dir(task_id: str) -> str:
+    root = globals().get("_user_workspace") or os.path.join(WORKSPACE_DIR, "users", "anonymous")
+    path = os.path.join(root, "tasks", _safe_user_workspace_key(task_id), "outputs")
+    os.makedirs(path, exist_ok=True)
+    return path
+
+
+def _checkpoint_state_for_update() -> dict:
+    if not os.path.isfile(CHECKPOINT_FILE):
+        return {}
+    try:
+        with open(CHECKPOINT_FILE, "r", encoding="utf-8") as handle:
+            value = json.load(handle)
+        return value if isinstance(value, dict) else {}
+    except Exception:
+        return {}
+
+
+def _write_checkpoint_state(value: dict) -> None:
+    if not isinstance(value, dict) or not value:
+        return
+    os.makedirs(os.path.dirname(CHECKPOINT_FILE), exist_ok=True)
+    temporary = CHECKPOINT_FILE + ".tmp"
+    with open(temporary, "w", encoding="utf-8") as handle:
+        json.dump(value, handle, ensure_ascii=False)
+    os.replace(temporary, CHECKPOINT_FILE)
+
+
+def _persist_pending_finalization() -> None:
+    pending = st.session_state.get("sp_pending_task_finalization")
+    if not isinstance(pending, dict):
+        return
+    state = _checkpoint_state_for_update()
+    if not state:
+        return
+    state["pending_task_finalization"] = pending
+    package = st.session_state.get("sp_pending_package")
+    if isinstance(package, dict):
+        state["pending_package"] = package
+    _write_checkpoint_state(state)
+
+
+def _restore_pending_finalization() -> None:
+    if isinstance(st.session_state.get("sp_pending_task_finalization"), dict):
+        return
+    state = _checkpoint_state_for_update()
+    pending = state.get("pending_task_finalization") if isinstance(state, dict) else None
+    if not isinstance(pending, dict):
+        return
+    st.session_state["sp_pending_task_finalization"] = pending
+    package = state.get("pending_package")
+    if isinstance(package, dict):
+        st.session_state["sp_pending_package"] = package
+    task_id = str(pending.get("task_id") or "").strip()
+    if task_id and not st.session_state.get("sp_generation_task"):
+        st.session_state["sp_generation_task"] = {"task_id": task_id}
+
+
+def _remove_pending_checkpoint_metadata(*, delete_checkpoint=False, detach_task=False) -> None:
+    if delete_checkpoint:
+        try:
+            os.remove(CHECKPOINT_FILE)
+        except OSError:
+            pass
+        return
+    state = _checkpoint_state_for_update()
+    if not state:
+        return
+    state.pop("pending_task_finalization", None)
+    state.pop("pending_package", None)
+    if detach_task:
+        state["managed_task_idempotency_key"] = ""
+        state["managed_task_id"] = ""
+    _write_checkpoint_state(state)
+
+
+def _prune_user_output_packages(max_files: int = 5) -> None:
+    root = globals().get("_user_workspace")
+    if not root or not os.path.isdir(root):
+        return
+    packages = []
+    for current_root, _, names in os.walk(os.path.join(root, "tasks")):
+        for name in names:
+            if name.endswith(".zip") and not name.startswith(".pending_"):
+                path = os.path.join(current_root, name)
+                try:
+                    packages.append((os.path.getmtime(path), path))
+                except OSError:
+                    pass
+    packages.sort()
+    while len(packages) > max_files:
+        _, old_path = packages.pop(0)
+        try:
+            os.remove(old_path)
+        except OSError:
+            pass
+
+
+def _process_pending_task_finalization():
+    pending = st.session_state.get("sp_pending_task_finalization")
+    if not isinstance(pending, dict):
+        return None
+    task_id = str(pending.get("task_id") or "").strip()
+    status = str(pending.get("status") or "").strip().lower()
+    if not task_id or status not in {"completed", "failed", "cancelled", "resumable"}:
+        raise RuntimeError("invalid_pending_task_finalization")
+
+    package_bytes = None
+    package = st.session_state.get("sp_pending_package")
+    if status == "completed":
+        if not isinstance(package, dict):
+            raise RuntimeError("validated_package_metadata_missing")
+        pending_path = str(package.get("pending_path") or "").strip()
+        if not pending_path or not os.path.isfile(pending_path):
+            raise RuntimeError("validated_package_file_missing")
+        with open(pending_path, "rb") as handle:
+            package_bytes = handle.read()
+        if not package_bytes:
+            raise RuntimeError("validated_package_file_empty")
+
+    response = finish_generation_task(
+        task_id,
+        status=status,
+        safe_error_code=str(pending.get("safe_error_code") or "")[:80],
+        safe_error_detail=str(pending.get("safe_error_detail") or "")[:800],
+        current_node=str(pending.get("current_node") or "")[:240],
+    )
+
+    if status == "completed":
+        filename = str(package.get("filename") or "SmartPaper.zip")
+        pending_path = str(package.get("pending_path") or "")
+        final_path = os.path.join(_task_output_dir(task_id), os.path.basename(filename))
+        try:
+            os.replace(pending_path, final_path)
+        except OSError:
+            # The bytes were read and validated before quota commit, so the user
+            # can still download even if the local archival rename fails.
+            final_path = pending_path
+        st.session_state["zip_buffer"] = package_bytes
+        st.session_state["zip_filename"] = os.path.basename(filename)
+        st.session_state["sp_terminal_notice"] = {"kind": "success"}
+        _prune_user_output_packages()
+    elif status in {"failed", "cancelled"}:
+        st.session_state["sp_terminal_notice"] = {
+            "kind": "error" if status == "failed" else "warning",
+            "message": str(pending.get("safe_error_detail") or "")[:800],
+        }
+
+    _remove_pending_checkpoint_metadata(
+        delete_checkpoint=bool(pending.get("delete_checkpoint")),
+        detach_task=bool(pending.get("detach_checkpoint")),
+    )
+    if status == "resumable":
+        st.session_state["sp_generation_task"] = dict(response.get("task") or {"task_id": task_id})
+    else:
+        st.session_state["sp_generation_task"] = None
+        st.session_state["sp_generation_idempotency_key"] = ""
+        st.session_state["sp_last_task_heartbeat"] = 0.0
+    st.session_state["sp_pending_task_finalization"] = None
+    st.session_state["sp_pending_package"] = None
+    return response
+
+
+def _finish_managed_generation_task(
+    status: str,
+    *,
+    safe_error_code: str = "",
+    safe_error_detail: str = "",
+    current_node: str = "",
+    delete_checkpoint: bool = False,
+    detach_checkpoint: bool = False,
+):
+    task = st.session_state.get("sp_generation_task") or {}
+    task_id = str(task.get("task_id") or "").strip()
+    if not task_id:
+        return None
+    pending = {
+        "task_id": task_id,
+        "status": str(status or "").strip().lower(),
+        "safe_error_code": str(safe_error_code or "")[:80],
+        "safe_error_detail": str(safe_error_detail or "")[:800],
+        "current_node": str(current_node or "")[:240],
+        "delete_checkpoint": bool(delete_checkpoint),
+        "detach_checkpoint": bool(detach_checkpoint),
+    }
+    st.session_state["sp_pending_task_finalization"] = pending
+    _persist_pending_finalization()
+    return _process_pending_task_finalization()
+
+
+def _quota_start_error_message(language: str, error: Exception) -> str:
+    raw = str(error or "")
+    return tr(language, "quota_exhausted") if "payment_required" in raw else raw
+
+
+inject_wechat_browser_notice()
+
+DEFAULT_TOPIC = "Generative Artificial Intelligence in Ubiquitous Learning: Evaluating a Chatbot-based Recommendation Engine for Personalized and Context-aware Education"
+DEFAULT_KEYWORDS = "Ubiquitous computing; Context awareness; Deep learning; Personalized educational; Educational technologies; HCI; Recommendation system; LLMs; Generative AI; ChatGPT; Prompting engineering; Few-shot prompting"
+
+_fragment = getattr(st, "fragment", None) or getattr(st, "experimental_fragment", None)
+if _fragment is None:
+    def _fragment(function):
+        return function
+
+
+def _current_language_code() -> str:
+    choice = st.session_state.get("interface_language_choice")
+    return LANGUAGE_OPTIONS.get(choice, "zh")
+
+
+# Public access uses Alipay only. Password, legacy, and pilot login paths are not exposed.
+authenticated_user = require_alipay_login(_current_language_code())
+
+# Checkpoints are user-scoped. The former global snapshot.json could cause one
+# user or an old run to trigger a false recovery notice for another session.
+_user_workspace = os.path.join(
+    WORKSPACE_DIR,
+    "users",
+    _safe_user_workspace_key(authenticated_user.get("id")),
+)
+os.makedirs(_user_workspace, exist_ok=True)
+CHECKPOINT_FILE = os.path.join(_user_workspace, "snapshot.json")
+_restore_pending_finalization()
+_process_pending_task_finalization()
+
+
+@_fragment
+def render_workspace_controls(user):
+    """Render controls in an isolated rerun scope for fast language switching."""
+    top_toolbar = st.container()
+
+    with top_toolbar:
+        language_col, account_col = st.columns([5.4, 4.6])
+
+        with language_col:
+            lang_choice = st.radio(
+                "Language",
+                list(LANGUAGE_OPTIONS.keys()),
+                index=0,
+                horizontal=True,
+                label_visibility="collapsed",
+                key="interface_language_choice",
+            )
+
+        lang_code = LANGUAGE_OPTIONS[lang_choice]
+        st.session_state["sp_lang_code"] = lang_code
+        st.session_state["sp_target_lang"] = get_target_language(lang_code)
+        st.session_state["sp_output_suffix"] = get_output_suffix(lang_code)
+        st.session_state["sp_target_flag"] = get_target_flag(lang_code)
+
+        with account_col:
+            render_logged_in_account(lang_code, user)
+
+    # Cross-device global busy check remains unchanged in function, but all visible text is localized.
+    is_my_session = st.session_state.get("is_running", False) or \
+                    st.session_state.get("start_pipeline", False) or \
+                    st.session_state.get("resume_pipeline", False)
+    ui_blocked = (not is_my_session and is_system_busy())
+    st.session_state["sp_ui_blocked"] = ui_blocked
+    if ui_blocked:
+        st.markdown(
+            f"<h3 style='text-align:center;color:#e6a23c;'>{tr(lang_code, 'system_busy_title')}</h3>",
+            unsafe_allow_html=True,
+        )
+        st.warning(tr(lang_code, "system_busy_warning"))
+        st.info(tr(lang_code, "system_busy_info"))
+        return
+
+    st.markdown(f"<div class='main-title'><h2>{tr(lang_code, 'title')}</h2></div>", unsafe_allow_html=True)
+
+    if _load_recoverable_checkpoint() is not None and not (st.session_state.is_running or st.session_state.resume_pipeline or st.session_state.start_pipeline):
+        st.warning(tr(lang_code, "checkpoint_warning"))
+        colA, colB = st.columns([1, 1])
+        if colA.button(tr(lang_code, "resume"), key="resume_task"):
+            if is_system_busy():
+                st.warning(tr(lang_code, "busy_short"))
+            else:
+                checkpoint_state = _load_recoverable_checkpoint() or {}
+                checkpoint_key = str(checkpoint_state.get("managed_task_idempotency_key") or "").strip()
+                st.session_state["sp_generation_idempotency_key"] = checkpoint_key or _new_generation_idempotency_key()
+                st.session_state["sp_generation_task"] = None
+                st.session_state["sp_last_task_heartbeat"] = 0.0
+                update_heartbeat()
+                st.session_state.resume_pipeline = True
+                st.session_state.start_pipeline = False
+                st.rerun()
+
+        if colB.button(tr(lang_code, "clear"), key="clear_task"):
+            if is_system_busy():
+                st.warning(tr(lang_code, "busy_short"))
+            else:
+                checkpoint_state = _load_recoverable_checkpoint() or {}
+                checkpoint_task_id = str(checkpoint_state.get("managed_task_id") or "").strip()
+                if checkpoint_task_id:
+                    st.session_state["sp_generation_task"] = {"task_id": checkpoint_task_id}
+                    try:
+                        _finish_managed_generation_task(
+                            "cancelled",
+                            safe_error_code="E_USER_CLEARED_CHECKPOINT",
+                            safe_error_detail="User cleared the recoverable checkpoint.",
+                            current_node="checkpoint_clear",
+                            delete_checkpoint=True,
+                        )
+                    except Exception as exc:
+                        st.error(str(exc))
+                        return
+                else:
+                    try:
+                        os.remove(CHECKPOINT_FILE)
+                    except OSError:
+                        pass
+                clear_heartbeat()
+                st.rerun()
+        st.markdown("---")
+
+    st.text_input(
+        tr(lang_code, "topic_label"),
+        value=DEFAULT_TOPIC,
+        disabled=st.session_state.is_running,
+        key="sp_topic",
+    )
+    st.text_input(
+        tr(lang_code, "keywords_label"),
+        value=DEFAULT_KEYWORDS,
+        disabled=st.session_state.is_running,
+        key="sp_keywords",
+    )
+    st.number_input(
+        tr(lang_code, "words_label"),
+        min_value=12000,
+        max_value=25000,
+        value=20000,
+        step=1000,
+        disabled=st.session_state.is_running,
+        key="sp_words",
+    )
+
+    tab_amj, tab_asq = st.tabs([tr(lang_code, "tab_amj"), tr(lang_code, "tab_asq")])
+
+    with tab_amj:
+        st.markdown(tr(lang_code, "amj_config"))
+        st.info(tr(lang_code, "amj_info"))
+        st.file_uploader(
+            tr(lang_code, "upload_reference"),
+            type=["pdf", "doc", "docx"],
+            accept_multiple_files=True,
+            key="up_amj_ref",
+            disabled=st.session_state.is_running,
+        )
+        st.file_uploader(
+            tr(lang_code, "upload_stats"),
+            type=["csv", "xlsx", "xls"],
+            key="up_amj_data",
+            disabled=st.session_state.is_running,
+        )
+
+        with st.expander(tr(lang_code, "amj_expander")):
+            st.markdown(tr(lang_code, "amj_hint"))
+            amj_csv_template = get_amj_csv_template(lang_code)
+            st.code(amj_csv_template, language="csv")
+            st.download_button(
+                label=tr(lang_code, "download_amj_template"),
+                data=amj_csv_template,
+                file_name="AMJ_Data_Template.csv",
+                mime="text/csv",
+                use_container_width=True,
+            )
+
+        if st.button(tr(lang_code, "start_amj"), disabled=st.session_state.is_running, key="btn_amj"):
+            if is_system_busy():
+                st.warning(tr(lang_code, "busy_short"))
+            else:
+                _prepare_new_generation_request()
+                update_heartbeat()
+                st.session_state.run_mode = "amj"
+                st.session_state.start_pipeline = True
+                st.rerun()
+
+    with tab_asq:
+        st.markdown(tr(lang_code, "asq_config"))
+        st.info(tr(lang_code, "asq_info"))
+        st.file_uploader(
+            tr(lang_code, "upload_reference"),
+            type=["pdf", "doc", "docx"],
+            accept_multiple_files=True,
+            key="up_asq_ref",
+            disabled=st.session_state.is_running,
+        )
+        st.file_uploader(
+            tr(lang_code, "upload_interviews"),
+            type=["txt", "pdf", "doc", "docx"],
+            key="up_asq_data",
+            disabled=st.session_state.is_running,
+        )
+
+        with st.expander(tr(lang_code, "asq_expander")):
+            st.markdown(tr(lang_code, "asq_hint"))
+            asq_txt_template = get_asq_txt_template(lang_code)
+            st.code(asq_txt_template, language="text")
+            st.download_button(
+                label=tr(lang_code, "download_asq_template"),
+                data=asq_txt_template,
+                file_name="ASQ_Interview_Template.txt",
+                mime="text/plain",
+                use_container_width=True,
+            )
+
+        if st.button(tr(lang_code, "start_asq"), disabled=st.session_state.is_running, key="btn_asq"):
+            if is_system_busy():
+                st.warning(tr(lang_code, "busy_short"))
+            else:
+                _prepare_new_generation_request()
+                update_heartbeat()
+                st.session_state.run_mode = "asq"
+                st.session_state.start_pipeline = True
+                st.rerun()
+
+    # Localize Streamlit built-in uploader text after the uploaders are rendered.
+    inject_file_uploader_i18n(lang_code)
+
+
+render_workspace_controls(authenticated_user)
+
+lang_code = str(st.session_state.get("sp_lang_code") or _current_language_code())
+target_lang = str(st.session_state.get("sp_target_lang") or get_target_language(lang_code))
+output_suffix = str(st.session_state.get("sp_output_suffix") or get_output_suffix(lang_code))
+target_flag = str(st.session_state.get("sp_target_flag") or get_target_flag(lang_code))
+
+topic = str(st.session_state.get("sp_topic") or DEFAULT_TOPIC)
+keywords = str(st.session_state.get("sp_keywords") or DEFAULT_KEYWORDS)
+words = int(st.session_state.get("sp_words") or 20000)
+uploaded_papers_amj = st.session_state.get("up_amj_ref") or []
+uploaded_data_amj = st.session_state.get("up_amj_data")
+uploaded_papers_asq = st.session_state.get("up_asq_ref") or []
+uploaded_interviews = st.session_state.get("up_asq_data")
+
+if st.session_state.get("sp_ui_blocked"):
+    st.stop()
+
+if st.session_state.get("sp_payment_required") and not (st.session_state.start_pipeline or st.session_state.resume_pipeline):
+    render_payment_purchase(lang_code)
+
+_terminal_notice = st.session_state.pop("sp_terminal_notice", None)
+if isinstance(_terminal_notice, dict) and _terminal_notice.get("kind") in {"error", "warning"}:
+    _message = str(_terminal_notice.get("message") or "").strip()
+    if _message:
+        (st.error if _terminal_notice.get("kind") == "error" else st.warning)(_message)
+
+progress_bar = st.empty()
+monitor_ui = st.empty()
+
+def render_monitor(agent, phase, current_sec="", details=""):
+    st.session_state["sp_current_node"] = str(current_sec or phase or "")[:240]
+    monitor_ui.markdown(f"""
+    <div class='log-box'>
+        <div><b>{tr(lang_code, 'monitor_pipeline')}:</b> {phase}</div><div><b>{tr(lang_code, 'monitor_node')}:</b> {current_sec}</div><div><b>{tr(lang_code, 'monitor_log')}:</b> {details}</div><hr>
+        <div><b>{tr(lang_code, 'monitor_compute')}:</b></div>
+        <div style='display: flex; gap: 8px;'>
+            <span style='background: #fef3c7; padding: 4px 8px; border-radius: 4px; color: black;'>🧠 DeepSeek: <b>{agent.ds_calls}</b></span>   
+            <span style='background: #dbeafe; padding: 4px 8px; border-radius: 4px; color: black;'>📚 S2: <b>{agent.s2_calls}</b></span>
+            <span style='background: #d1fae5; padding: 4px 8px; border-radius: 4px; color: black;'>🌐 OpenAlex: <b>{agent.oa_calls}</b></span>
+        </div>
+    </div>
+    """, unsafe_allow_html=True)
+
+FLAG_MAP = {"Simplified Chinese (简体中文)": "🇨🇳", "Russian (Русский)": "🇷🇺", "Kazakh (Қазақша)": "🇰🇿"}
+
+if st.session_state.start_pipeline or st.session_state.resume_pipeline:
+    if not global_ds_key: 
+        st.error(tr(lang_code, "api_key_missing"))
+        st.stop()
+        
+    if st.session_state.get("is_running", False):
+        recoverable_state = _load_recoverable_checkpoint()
+        st.session_state.is_running = False
+        st.session_state.start_pipeline = False
+        st.session_state.resume_pipeline = bool(recoverable_state)
+        if recoverable_state:
+            st.toast(tr(lang_code, "resume_toast"), icon="⚡")
+            update_heartbeat()
+            st.rerun()
+        # A normal page rerun without a valid checkpoint is not a recovery event.
+        # Keep the already-rendered writing interface and show no recovery toast.
+        clear_heartbeat()
+        st.stop()
+
+    is_resume = st.session_state.resume_pipeline
+    loaded_state = _load_recoverable_checkpoint() if is_resume else None
+    if is_resume and loaded_state is None:
+        is_resume = False
+
+    try:
+        managed_task, managed_task_key = _begin_managed_generation_task(
+            is_resume=is_resume,
+            loaded_state=loaded_state,
+            mode=st.session_state.run_mode,
+            language=lang_code,
+        )
+    except Exception as exc:
+        clear_heartbeat()
+        st.session_state.is_running = False
+        st.session_state.start_pipeline = False
+        st.session_state.resume_pipeline = False
+        st.error(_quota_start_error_message(lang_code, exc))
+        if "payment_required" in str(exc):
+            st.session_state["sp_payment_required"] = True
+            render_payment_purchase(lang_code)
+        st.stop()
+
+    st.session_state.is_running = True
+    agent = SSciPipelineAgent(global_ds_key, global_s2_key)
+    SAFE_CHUNK_WORDS = agent.chunk_words_default
+    qual_engine = get_qualitative_engine(agent)
+    quant_engine = get_quantitative_engine()
+    completion_finalization_attempted = False
+
+    try:
+        update_heartbeat()
+                
+        if is_resume and loaded_state:
+            pb = progress_bar.progress(50, text=tr(lang_code, "resume_loading"))
+            state = loaded_state
+            state["managed_task_idempotency_key"] = managed_task_key
+            state["managed_task_id"] = managed_task.get("task_id", "")
+            topic = state["topic"]
+            keywords = state["keywords"]
+            target_lang = state["target_lang"]
+            words = state["words"]
+            user_data_md = state["user_data_md"]
+            data_metadata = state.get("data_metadata", {})
+            user_lit_context = state["user_lit_context"]
+            
+            agent.load_state(state["agent_state"])
+            adaptive_structure = state["adaptive_structure"]
+            completed_sections = state["completed_sections"]
+            full_draft_en = state["full_draft_en"]
+            full_draft_translated = state["full_draft_translated"]
+            synthesis_result = state["synthesis_result"]
+            refs_text = state["refs_text"]
+            context_tail = state["context_tail"]
+            
+            st.session_state.run_mode = state.get("run_mode", "amj")
+            if st.session_state.run_mode == "amj":
+                APP_CONFIG.update(AMJ_PROMPTS)
+            else:
+                APP_CONFIG.update(ASQ_PROMPTS)
+                
+            st.success(tr(lang_code, "resume_success", done=len(completed_sections), total=len(adaptive_structure)))
+            render_monitor(agent, tr(lang_code, "resume_phase"), tr(lang_code, "state_check"), tr(lang_code, "history_restored"))
+            
+        else:
+            pb = progress_bar.progress(1, text=tr(lang_code, "pipeline_start"))
+            user_lit_context = ""
+            user_data_md = ""
+            data_metadata = {}
+            
+            if st.session_state.run_mode == "amj":
+                if uploaded_papers_amj:
+                    user_lit_context = extract_text_from_files(uploaded_papers_amj[:20])
+                    with st.status(tr(lang_code, "literature_extract"), expanded=True) as status:
+                        ph = st.empty()
+                        all_paper_texts = [extract_text_from_files([f]) for f in uploaded_papers_amj[:20]]
+                        
+                        future = ThreadPoolExecutor(max_workers=1).submit(extract_golden_metadata, agent, all_paper_texts)
+                        dot_count = 0
+                        while not future.done():
+                            update_heartbeat()
+                            ph.markdown(tr(lang_code, "literature_deep") + " ⏳" * (dot_count % 4))
+                            time.sleep(1)
+                            dot_count += 1
+                            
+                        agent.global_memory["core_golden_metadata"] = future.result()
+                        st.session_state.rag_engine = initialize_rag(all_paper_texts)
+                        status.update(label=tr(lang_code, "literature_done"), state="complete", expanded=False)
+                
+                with st.spinner(tr(lang_code, "extract_quant")):
+                    update_heartbeat()
+                    _, user_data_md, msg, data_metadata = quant_engine.resolve_empirical_data(uploaded_data_amj, lang_code)
+                    st.info(msg)
+                    
+            elif st.session_state.run_mode == "asq":
+                if uploaded_papers_asq:
+                    user_lit_context = extract_text_from_files(uploaded_papers_asq[:20])
+                    with st.status(tr(lang_code, "literature_extract"), expanded=True) as status:
+                        ph = st.empty()
+                        all_paper_texts = [extract_text_from_files([f]) for f in uploaded_papers_asq[:20]]
+                        
+                        future = ThreadPoolExecutor(max_workers=1).submit(extract_golden_metadata, agent, all_paper_texts)
+                        dot_count = 0
+                        while not future.done():
+                            update_heartbeat()
+                            ph.markdown(tr(lang_code, "literature_deep") + " ⏳" * (dot_count % 4))
+                            time.sleep(1)
+                            dot_count += 1
+                            
+                        agent.global_memory["core_golden_metadata"] = future.result()
+                        st.session_state.rag_engine = initialize_rag(all_paper_texts)
+                        status.update(label=tr(lang_code, "literature_done"), state="complete", expanded=False)
+                
+                update_heartbeat()
+                raw_interviews = extract_text_from_files([uploaded_interviews]) if uploaded_interviews else ""
+                user_data_md, msg, data_metadata = qual_engine.resolve_qualitative_data(topic, keywords, raw_interviews)
+                st.info(msg or tr(lang_code, "qualitative_ready"))
+
+            state = {
+                "topic": topic, "keywords": keywords, "target_lang": target_lang, "words": words,
+                "user_data_md": user_data_md, "data_metadata": data_metadata, "user_lit_context": user_lit_context,
+                "completed_sections": [], "full_draft_en": "", "full_draft_translated": "",
+                "context_tail": "", "run_mode": st.session_state.run_mode, "interface_language": lang_code,
+                "managed_task_idempotency_key": managed_task_key,
+                "managed_task_id": managed_task.get("task_id", ""),
+            }
+
+            pb.progress(5, text=tr(lang_code, "config_route"))
+            
+            if st.session_state.run_mode == "amj":
+                APP_CONFIG.update(AMJ_PROMPTS)
+                state["prompt_config"] = AMJ_PROMPTS
+            else:
+                APP_CONFIG.update(ASQ_PROMPTS)
+                state["prompt_config"] = ASQ_PROMPTS
+
+            pb.progress(10, text=tr(lang_code, "literature_search"))
+            def sync_monitor_ui():
+                update_heartbeat()
+                render_monitor(agent, tr(lang_code, "search_phase"), "S2 + OpenAlex", tr(lang_code, "search_detail"))
+            
+            target_refs_count = 50
+            refs_text = agent.fetch_references_parallel(topic, keywords, min_required=target_refs_count, progress_callback=sync_monitor_ui)
+            
+            if len(agent.citation_map) < target_refs_count:
+                raise RuntimeError(
+                    tr(lang_code, "refs_insufficient", count=len(agent.citation_map), required=target_refs_count)
+                )
+            else: 
+                st.success(tr(lang_code, "refs_success", count=len(agent.citation_map)))
+
+            with st.spinner(tr(lang_code, "rag_sync")):
+                update_heartbeat()
+                if hasattr(st.session_state, "rag_engine") and st.session_state.rag_engine is not None:
+                    st.session_state.rag_engine._initialize_chunks([refs_text])
+                else:
+                    st.session_state.rag_engine = initialize_rag([refs_text])
+            st.success(tr(lang_code, "rag_done"))
+
+            if user_lit_context:
+                pb.progress(11, text=tr(lang_code, "core_literature_parsing"))
+                update_heartbeat()
+                core_refs = agent.parse_user_core_literature(user_lit_context)
+                if core_refs:
+                    refs_text = "【USER PROVIDED CORE LITERATURE】\n" + core_refs + "\n\n【RETRIEVED LITERATURE】\n" + refs_text
+                    st.success(tr(lang_code, "core_refs_done"))
+
+            state["refs_text"] = refs_text
+
+            pb.progress(12, text=tr(lang_code, "synthesis_progress"))
+            with st.status(tr(lang_code, "synthesis_status"), expanded=True) as status:
+                ph = st.empty()
+                synthesis_result = ph.write_stream(stream_with_heartbeat(agent.stream_synthesize_literature(topic, refs_text, user_core_literature=user_lit_context)))
+                synthesis_result = re.sub(r'<think>.*?</think>', '', synthesis_result, flags=re.DOTALL).strip()
+                status.update(label=tr(lang_code, "synthesis_done"), state="complete", expanded=False)
+            state["synthesis_result"] = synthesis_result
+            
+            pb.progress(14, text=tr(lang_code, "anchor_progress"))
+            with st.status(tr(lang_code, "anchor_status"), expanded=True) as status:
+                ph = st.empty()
+                anchor_response = ph.write_stream(stream_with_heartbeat(agent.stream_generate_anchors(topic, keywords, synthesis_result, refs_text, data_evidence=user_data_md, mode=st.session_state.run_mode)))
+                status.update(label=tr(lang_code, "anchor_done"), state="complete", expanded=False)
+            
+            # ==========================================================
+            # [核心修复] 必须先剔除 <think> 标签！防止正则匹配到模型在思考时引用提示词的空占位符
+            # ==========================================================
+            anchor_response_clean = re.sub(r'<think>.*?</think>', '', anchor_response, flags=re.DOTALL).strip()
+            
+            abstract_match = re.search(r'-+\s*ABSTRACT\s*-+\s*(.*?)(?=\s*-+\s*CONCLUSION\s*-+|$)', anchor_response_clean, re.DOTALL | re.IGNORECASE)
+            conclusion_match = re.search(r'-+\s*CONCLUSION\s*-+\s*(.*?)$', anchor_response_clean, re.DOTALL | re.IGNORECASE)
+            abstract_anchor = abstract_match.group(1).strip() if abstract_match else anchor_response_clean.strip()
+            conclusion_anchor = conclusion_match.group(1).strip() if conclusion_match else ""
+            agent.global_memory["abstract_anchor"] = abstract_anchor
+            agent.global_memory["conclusion_anchor"] = conclusion_anchor
+            # ==========================================================
+            
+            pb.progress(15, text=tr(lang_code, "outline_progress"))
+            update_heartbeat()
+            plan = agent.generate_outline(topic, keywords, mode=st.session_state.run_mode, data_metadata=data_metadata)
+            en_topic = str(plan.get("en_topic", topic))
+            structure = plan.get("structure", [])
+
+            en_abstract_clean = clean_markdown_headings(re.sub(r'(?i)^abstract[:\s]*', '', str(abstract_anchor)).strip())
+            trans_abstract_clean = ""
+
+            loc_abs = {"Simplified Chinese (简体中文)": "摘要", "Russian (Русский)": "Аннотация", "Kazakh (Қазақша)": "Түйіндеме"}.get(target_lang, "Abstract")
+            loc_kw = {"Simplified Chinese (简体中文)": "关键词", "Russian (Русский)": "Ключевые слова", "Kazakh (Қазақша)": "Кілт сөздер"}.get(target_lang, "Keywords")
+
+            full_draft_en = f"# {en_topic}\n\n## Abstract\n{en_abstract_clean}\n\n## Keywords\n{keywords}\n\n"
+            full_draft_translated = f"# {topic}\n\n## {loc_abs}\n{trans_abstract_clean}\n\n## {loc_kw}\n{keywords}\n\n"
+
+            adaptive_structure = agent.build_generation_tasks(structure, int(words), SAFE_CHUNK_WORDS)
+            for task in adaptive_structure:
+                task["is_first"] = bool(task.get("section_first"))
+
+            with st.spinner(tr(lang_code, "jit_status")):
+                update_heartbeat()
+                jit_texts = agent.prefetch_jit_literature(topic, keywords, adaptive_structure)
+                if jit_texts:
+                    if hasattr(st.session_state, "rag_engine") and st.session_state.rag_engine is not None:
+                        st.session_state.rag_engine._initialize_chunks([jit_texts])
+                    else:
+                        st.session_state.rag_engine = initialize_rag([jit_texts])
+                    st.success(tr(lang_code, "jit_done"))
+
+            state["adaptive_structure"] = adaptive_structure
+            state["agent_state"] = agent.export_state()
+            state["full_draft_en"] = full_draft_en
+            state["full_draft_translated"] = full_draft_translated
+            completed_sections = []
+            context_tail = ""
+            
+            os.makedirs(WORKSPACE_DIR, exist_ok=True)
+            with open(CHECKPOINT_FILE, "w", encoding="utf-8") as f: 
+                json.dump(state, f, ensure_ascii=False)
+
+        total_steps = len(adaptive_structure)
+        current_step = len(completed_sections)
+        st.markdown("---")
+        ui_blocks = []
+        target_flag = FLAG_MAP.get(target_lang, "🌐")
+
+        for sec in adaptive_structure:
+            display_name = sec["display_name"]
+            st.markdown(f"### ⚙️ {display_name}")
+            col_en, col_trans = st.columns(2)
+            with col_en:
+                st.markdown(tr(lang_code, "english_draft"))
+                en_ph = st.empty()
+            with col_trans:
+                st.markdown(tr(lang_code, "target_draft", flag=target_flag))
+                trans_ph = st.empty()
+            if display_name in completed_sections:
+                en_ph.success(tr(lang_code, "restored"))
+                trans_ph.info(tr(lang_code, "translation_waiting"))
+            else:
+                en_ph.info(tr(lang_code, "waiting"))
+                trans_ph.info(tr(lang_code, "translation_waiting"))
+            ui_blocks.append({"sec": sec, "en_ph": en_ph, "trans_ph": trans_ph})
+
+        generation_aborted = False
+        generation_failure_code = ""
+        generation_failure_detail = ""
+        accumulated_deviation = 0
+        remaining_sections = sum(1 for item in adaptive_structure if item["display_name"] not in completed_sections)
+        all_cite_keys = list(agent.citation_map.keys())
+        valid_chunks = [item for item in adaptive_structure if not any(word in item["section"].lower() for word in ["abstract","keyword","appendix"])]
+        allocation_map = {}
+        current_cite_idx = 0
+        for idx, item in enumerate(valid_chunks):
+            count = max(1, math.ceil(len(all_cite_keys) / max(1, len(valid_chunks))))
+            allocation_map[item["display_name"]] = all_cite_keys[current_cite_idx:] if idx == len(valid_chunks)-1 else all_cite_keys[current_cite_idx:current_cite_idx+count]
+            current_cite_idx += count
+
+        for block in ui_blocks:
+            if generation_aborted:
+                break
+            sec = block["sec"]
+            en_ph = block["en_ph"]
+            trans_ph = block["trans_ph"]
+            sec_title = sec["section"]
+            display_name = sec["display_name"]
+            if display_name in completed_sections:
+                continue
+            remaining_sections = max(0, remaining_sections - 1)
+            adjustment = -accumulated_deviation / remaining_sections if remaining_sections else 0
+            adjusted_target = min(int(SAFE_CHUNK_WORDS * 1.5), max(80, int(sec["target_words"] + adjustment)))
+            is_quarantined = any(word in sec_title.lower() for word in ["abstract","keyword","conclusion","references","appendix"])
+            assigned_tags = ", ".join(allocation_map.get(display_name, [])) or "the single most relevant source"
+            citation_rule = "NO IN-TEXT CITATIONS ALLOWED IN THIS SECTION." if is_quarantined else f"Use claim-specific citation. Each sentence may contain at most one source tag. Candidate tags: {assigned_tags}. <AVAILABLE_CITATIONS>{refs_text}</AVAILABLE_CITATIONS>"
+            memory_context = agent._build_memory_context(sec_title, 2500)
+            memory_block = f"\n<GLOBAL_MEMORY>\n{memory_context}\n</GLOBAL_MEMORY>\n" if memory_context else ""
+            if getattr(st.session_state, "rag_engine", None) is not None:
+                snippets = st.session_state.rag_engine.get_relevant_context(display_name)
+                if snippets:
+                    memory_block += f"\n<TARGETED_RAG>\n{snippets}\n</TARGETED_RAG>\n"
+            subsection = sec.get("subsection")
+            heading_directive = "Do not output the section heading; it will be inserted by the system."
+            if subsection:
+                heading_directive += f" Do not output the subsection heading '{subsection}'; it will also be inserted by the system. Use level-3 headings only when analytically necessary."
+            elif sec_title.lower() in {"introduction", "conclusion"}:
+                heading_directive += " Do not use additional headings."
+            else:
+                heading_directive += " Use level-2 or level-3 headings only when they clarify the argument; never use level-4 headings or numbered headings."
+            table_rule = "Present statistical evidence in standard Markdown tables with plain-text captions." if sec["is_method_or_result"] and st.session_state.run_mode == "amj" else ""
+            required_content = str(sec.get("required_content") or "")
+            concepts = ", ".join(sec.get("concepts") or [])
+            qualitative_rule = f"Assigned qualitative concepts: {concepts}. Use only their assigned representative quotations and do not repeat a quotation already used elsewhere." if concepts else ""
+            data_injection = f"\n<RESEARCH_EVIDENCE>\n{user_data_md}\n</RESEARCH_EVIDENCE>\n" if user_data_md and sec["is_method_or_result"] else ""
+            completed_label = ", ".join(completed_sections)
+            anti_repeat = f"Already completed: {completed_label}. Do not restate their background, gap, or contribution." if completed_label else ""
+            sys_prompt = APP_CONFIG.get("sys_academic_writer", "") + "\n" + APP_CONFIG.get("deep_refinement_directive", "")
+            user_prompt = f"""Write the assigned English manuscript unit.
+Section: {sec_title}
+Subsection: {subsection or 'None'}
+Target length: {int(adjusted_target*0.9)}-{int(adjusted_target*1.1)} words.
+{heading_directive}
+{citation_rule}
+{table_rule}
+{required_content}
+{qualitative_rule}
+{anti_repeat}
+{memory_block}
+Literature synthesis: {synthesis_result}
+{data_injection}
+Previous tail: {context_tail[-2500:]}
+Output only final academic prose. Do not report the word count."""
+            if agent._count_tokens(sys_prompt) + agent._count_tokens(user_prompt) > 60000:
+                user_prompt = agent._truncate_context(user_prompt, 60000 - agent._count_tokens(sys_prompt))
+            render_monitor(agent, tr(lang_code, "drafting_phase", current=current_step+1, total=total_steps), display_name, tr(lang_code, "target_words", words=adjusted_target, engine=tr(lang_code, "engine_amj") if st.session_state.run_mode=="amj" else tr(lang_code, "engine_asq")))
+            try:
+                with st.status(tr(lang_code, "draft_status", name=display_name), expanded=True) as status:
+                    update_heartbeat()
+                    en_raw = en_ph.write_stream(stream_with_heartbeat(agent.stream_deepseek(sys_prompt, user_prompt, max_tokens=7000, model_role="writing", thinking=False, allow_fallback=False)))
+                    status.update(label=tr(lang_code, "draft_done", name=display_name), state="complete", expanded=False)
+                en_raw = re.sub(r'<think>.*?</think>', '', str(en_raw), flags=re.S).strip()
+                en_raw = re.sub(rf'(?im)^#\s*{re.escape(sec_title)}\s*\n+', '', en_raw).strip()
+                if subsection:
+                    en_raw = re.sub(rf'(?im)^##\s*{re.escape(subsection)}\s*\n+', '', en_raw).strip()
+                en_raw = re.sub(r'(?m)^(#{2,3})\s+[\d\.\s一二三四五六七八九十、]+\s*(.*)', r'\1 \2', en_raw)
+                en_raw = re.sub(r'(?m)^#{4,}\s+(.*)', r'**\1**', en_raw)
+                en_raw = re.sub(r'(?m)^#\s+(.+)$', r'## \1', en_raw)
+                if st.session_state.run_mode == "asq" and user_data_md and "appendix" not in sec_title.lower():
+                    quote_dict = {tag: quote for quote, tag in re.findall(r'"([^"]+)"\s*\[(QUOTE-\d+)\]', user_data_md)}
+                    for tag, quote in quote_dict.items():
+                        en_raw = en_raw.replace(tag, f'"{quote}"')
+                en_raw = agent.polish_academic_section(en_raw, display_name, abstract=False)
+                prefix = ""
+                if sec.get("section_first"):
+                    prefix += f"# {sec_title}\n\n"
+                if sec.get("subsection_first") and subsection:
+                    prefix += f"## {subsection}\n\n"
+                en_with_headings = prefix + en_raw
+                en_resolved = agent.audit_and_resolve_citations(en_with_headings, section_name=display_name, quarantine=is_quarantined)
+                en_ph.markdown(en_resolved)
+                trans_ph.info(tr(lang_code, "translation_waiting"))
+                full_draft_en += en_resolved + "\n\n"
+                agent._extract_memory_from_text(en_raw, sec_title)
+                words_tail = en_raw.split()
+                context_tail = " ".join(words_tail[-200:])
+                actual_words = len(en_raw.split())
+                accumulated_deviation += actual_words - adjusted_target
+                current_step += 1
+                completed_sections.append(display_name)
+                state.update({
+                    "completed_sections": completed_sections,
+                    "full_draft_en": full_draft_en,
+                    "full_draft_translated": "",
+                    "context_tail": context_tail,
+                    "agent_state": agent.export_state(),
+                    "data_metadata": data_metadata,
+                })
+                with open(CHECKPOINT_FILE, "w", encoding="utf-8") as checkpoint:
+                    json.dump(state, checkpoint, ensure_ascii=False)
+                st.caption(tr(lang_code, "word_count", actual=actual_words, target=adjusted_target, deviation=accumulated_deviation))
+                pb.progress(min(15 + int((current_step/max(1,total_steps))*75), 90), text=tr(lang_code, "section_complete_progress", name=display_name))
+            except Exception as error:
+                en_ph.error(tr(lang_code, "node_error"))
+                st.error(tr(lang_code, "node_error_detail", error=error))
+                generation_aborted = True
+                generation_failure_code = "E_GENERATION_NODE_FAILED"
+                generation_failure_detail = str(error)[:800]
+
+        if generation_aborted:
+            _finish_managed_generation_task(
+                "failed",
+                safe_error_code=generation_failure_code or "E_GENERATION_INTERRUPTED",
+                safe_error_detail=generation_failure_detail or "Generation stopped; quota was released and the checkpoint was retained for a fresh retry.",
+                current_node=str(st.session_state.get("sp_current_node") or "generation"),
+                detach_checkpoint=True,
+            )
+
+        if not generation_aborted and full_draft_en.strip():
+            pb.progress(91, text=tr(lang_code, "pack_docx"))
+            update_heartbeat()
+            full_draft_en = clean_trailing_references(full_draft_en, ["Reference","References","Reference List"])
+            # The final abstract is derived from the completed English manuscript and frozen evidence.
+            final_abstract = agent.generate_final_abstract(topic, keywords, full_draft_en, data_evidence=user_data_md, mode=st.session_state.run_mode)
+            full_draft_en = replace_abstract(full_draft_en, final_abstract)
+            agent.validate_manuscript_structure(full_draft_en, adaptive_structure, translated=False)
+            if st.session_state.run_mode == "asq":
+                repeated_quotes = agent.find_repeated_qualitative_quotes(full_draft_en, data_metadata)
+                if repeated_quotes:
+                    raise RuntimeError(f"Repeated qualitative quotations: {repeated_quotes[:5]}")
+            # Only sources actually cited in the manuscript enter the reference list.
+            references = []
+            seen_refs = set()
+            for tag in sorted(agent.used_citations, key=agent._citation_tag_number):
+                ref = str((agent.citation_map.get(tag) or {}).get("ref") or "").strip()
+                if ref and ref not in seen_refs:
+                    references.append(f"- {ref}")
+                    seen_refs.add(ref)
+            if not references:
+                raise RuntimeError("No cited references remained after citation validation.")
+            full_draft_en = full_draft_en.rstrip() + "\n\n# References\n" + "\n\n".join(references)
+
+            pb.progress(94, text=tr(lang_code, "translation_running"))
+            update_heartbeat()
+            full_draft_translated = agent.translate_locked_manuscript(full_draft_en, target_lang)
+            agent.validate_translation_alignment(full_draft_en, full_draft_translated)
+
+            bj_time = datetime.now(timezone(timedelta(hours=8))).strftime("%Y%m%d_%H%M")
+            package = build_validated_package(
+                english_markdown=full_draft_en,
+                translated_markdown=full_draft_translated,
+                english_filename=f"Research_EN_{bj_time}.docx",
+                translated_filename=f"Research_{output_suffix}_{bj_time}.docx",
+                data_metadata=data_metadata,
+                mode=st.session_state.run_mode,
+                citation_audit=agent.citation_audit_log,
+                literature_metrics=agent.get_source_metrics(),
+            )
+            generated_zip_bytes = package.zip_bytes
+            generated_zip_filename = f"SmartPaper_{bj_time}.zip"
+
+            # Persist the already validated package in the current user's task
+            # directory before asking Worker/D1 to commit quota. The download is
+            # exposed only after the browser receives completed+committed.
+            task_id = str((st.session_state.get("sp_generation_task") or {}).get("task_id") or "").strip()
+            if not task_id:
+                raise RuntimeError("package_task_id_missing")
+            pending_path = os.path.join(_task_output_dir(task_id), ".pending_" + generated_zip_filename)
+            with open(pending_path, "wb") as output_file:
+                output_file.write(generated_zip_bytes)
+            st.session_state["sp_pending_package"] = {
+                "pending_path": pending_path,
+                "filename": generated_zip_filename,
+            }
+            completion_finalization_attempted = True
+            _finish_managed_generation_task(
+                "completed",
+                current_node="package_validated",
+                delete_checkpoint=True,
+            )
+            pb.progress(100, text=tr(lang_code, "complete"))
+            render_monitor(agent, tr(lang_code, "complete"), "✅", tr(lang_code, "document_generated"))
+            
+    except Exception as e:
+        if not completion_finalization_attempted:
+            try:
+                _finish_managed_generation_task(
+                    "failed",
+                    safe_error_code="E_GENERATION_FAILED",
+                    safe_error_detail=str(e)[:800],
+                    current_node=str(st.session_state.get("sp_current_node") or "generation"),
+                    detach_checkpoint=True,
+                )
+            except Exception:
+                pass
+        st.error(tr(lang_code, "startup_error", error=e))
+    finally:
+        clear_heartbeat()
+        st.session_state.is_running = False
+        st.session_state.start_pipeline = False
+        st.session_state.resume_pipeline = False
+
+if st.session_state.zip_buffer:
+    st.success(tr(lang_code, "success"))
+    st.download_button(label=tr(lang_code, "download"), data=st.session_state.zip_buffer, file_name=st.session_state.zip_filename, mime="application/zip")

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/config.py

@@ -0,0 +1,404 @@
+# -*- coding: utf-8 -*-
+import os
+
+def load_config():
+    base_config = {
+        # --- 基础运行参数 ---
+        "lit_target_papers": int(os.environ.get("LIT_TARGET_PAPERS", "80")),
+        "lit_per_page": int(os.environ.get("LIT_PER_PAGE", "100")),
+        "lit_max_workers": int(os.environ.get("LIT_MAX_WORKERS", "5")),
+        "chunk_words_default": int(os.environ.get("CHUNK_WORDS_DEFAULT", "1500")),
+        "search_max_retries": max(1, int(os.environ.get("SEARCH_MAX_RETRIES", "4"))),
+        "translation_batch_tokens": max(800, int(os.environ.get("TRANSLATION_BATCH_TOKENS", "2500"))),
+        "translation_glossary_term_limit": max(10, int(os.environ.get("TRANSLATION_GLOSSARY_TERM_LIMIT", "40"))),
+        "translation_min_coverage_ratio": float(os.environ.get("TRANSLATION_MIN_COVERAGE_RATIO", "0.25")),
+        "translation_min_block_ratio_zh": float(os.environ.get("TRANSLATION_MIN_BLOCK_RATIO_ZH", "0.28")),
+        "translation_min_block_ratio_cyrillic": float(os.environ.get("TRANSLATION_MIN_BLOCK_RATIO_CYRILLIC", "0.65")),
+        "translation_max_block_ratio": float(os.environ.get("TRANSLATION_MAX_BLOCK_RATIO", "2.20")),
+        "openalex_email": os.environ.get("OPENALEX_EMAIL", "").strip(),
+        
+        # --- RAG 与解析配置 ---
+        "rag_chunk_size": int(os.environ.get("RAG_CHUNK_SIZE", "3000")),
+        "rag_top_k": int(os.environ.get("RAG_TOP_K", "3")),
+        "max_extract_chars": int(os.environ.get("MAX_EXTRACT_CHARS", "150000")),
+        "api_timeouts": {
+            "standard": (15, 180),
+            "stream": (15, 300),
+            "search": 15
+        },
+        
+        # --- API 节点配置 ---
+        "deepseek_api_url": os.environ.get(
+            "DEEPSEEK_API_URL",
+            "https://api.deepseek.com/chat/completions",
+        ),
+        # Model names are centralized here and can be upgraded in HF Variables.
+        # Application and engine code select a task role, never a concrete model.
+        "deepseek_models": {
+            "reasoning": os.environ.get(
+                "DEEPSEEK_MODEL_REASONING",
+                "deepseek-v4-pro",
+            ),
+            "writing": os.environ.get(
+                "DEEPSEEK_MODEL_WRITING",
+                "deepseek-v4-pro",
+            ),
+            "translation": os.environ.get(
+                "DEEPSEEK_MODEL_TRANSLATION",
+                "deepseek-v4-pro",
+            ),
+            "fast": os.environ.get(
+                "DEEPSEEK_MODEL_FAST",
+                "deepseek-v4-flash",
+            ),
+            "fallback": os.environ.get(
+                "DEEPSEEK_MODEL_FALLBACK",
+                "deepseek-v4-flash",
+            ),
+        },
+        "deepseek_task_settings": {
+            "reasoning": {
+                "thinking": True,
+                "reasoning_effort": os.environ.get(
+                    "DEEPSEEK_REASONING_EFFORT",
+                    "high",
+                ),
+                "allow_fallback": False,
+            },
+            "writing": {
+                "thinking": False,
+                "reasoning_effort": "high",
+                "allow_fallback": False,
+            },
+            "translation": {
+                "thinking": False,
+                "reasoning_effort": "high",
+                "allow_fallback": False,
+            },
+            "fast": {
+                "thinking": False,
+                "reasoning_effort": "low",
+                "allow_fallback": True,
+            },
+        },
+        "deepseek_max_retries": int(
+            os.environ.get("DEEPSEEK_MAX_RETRIES", "3")
+        ),
+        "deepseek_show_reasoning": os.environ.get(
+            "DEEPSEEK_SHOW_REASONING",
+            "false",
+        ).strip().lower() in {"1", "true", "yes", "on"},
+        # Citation-semantic audit repairs only affected sentences. Technical
+        # failures fall back to deterministic single-source recovery and are
+        # recorded in the audit log instead of terminating the whole paper.
+        "citation_semantic_audit": {
+            "enabled": os.environ.get(
+                "CITATION_SEMANTIC_AUDIT_ENABLED",
+                "true",
+            ).strip().lower() in {"1", "true", "yes", "on"},
+            "batch_size": max(
+                1,
+                int(os.environ.get("CITATION_SEMANTIC_BATCH_SIZE", "5")),
+            ),
+            "candidate_limit": max(
+                3,
+                int(os.environ.get("CITATION_SEMANTIC_CANDIDATE_LIMIT", "10")),
+            ),
+            "fail_closed": os.environ.get(
+                "CITATION_SEMANTIC_FAIL_CLOSED",
+                "false",
+            ).strip().lower() in {"1", "true", "yes", "on"},
+            "technical_retries": max(
+                1,
+                int(os.environ.get("CITATION_SEMANTIC_TECHNICAL_RETRIES", "2")),
+            ),
+            "json_repair_retries": max(
+                0,
+                int(os.environ.get("CITATION_SEMANTIC_JSON_REPAIR_RETRIES", "1")),
+            ),
+        },
+        # Task/lease settings are consumed by the HF client. The Worker remains
+        # the authoritative source for task ownership and lock expiry.
+        "task_heartbeat_interval_seconds": max(
+            3,
+            int(os.environ.get("SMARTPAPER_TASK_HEARTBEAT_SECONDS", "5")),
+        ),
+        "manuscript_quality": {
+            "abstract_max_words": int(os.environ.get("ABSTRACT_MAX_WORDS", "200")),
+            "abstract_max_numeric_mentions": int(os.environ.get("ABSTRACT_MAX_NUMERIC_MENTIONS", "6")),
+            "forbidden_phrases": [
+                "delve into", "intricate", "paramount", "overarching",
+                "pivotal", "foster", "seamlessly", "multifaceted",
+                "beacon", "landscape", "underscore", "robust",
+                "firstly", "secondly", "moreover", "furthermore",
+                "in conclusion", "to summarize", "as an ai",
+                "ai-generated", "this response",
+            ],
+        },
+        "openalex_api_url": os.environ.get("OPENALEX_API_URL", "https://api.openalex.org/works"),
+        "s2_api_url": os.environ.get("S2_API_URL", "https://api.semanticscholar.org/graph/v1"),
+        
+        # --- UI 多语言标签 ---
+        "ui_labels": {
+            "中文": {"title": "📊 工商管理论文智能体", "btn_generate": "🚀 生成初稿", "btn_download": "📥 下载文件", "topic_label": "📝 论文名称", "keywords_label": "🔍 关键字", "words_label": "📏 目标总单词数 (12000-25000单词)", "success": "🎉 流水线推演完毕！双语文档已就绪。"},
+            "English": {"title": "📊 Business Administration Article Agent", "btn_generate": "🚀 Generate Draft", "btn_download": "📥 Download", "topic_label": "📝 Article Title", "keywords_label": "🔍 Keywords", "words_label": "📏 Target Word Count", "success": "🎉 Task complete!"},
+            "Русский": {"title": "📊 Агент статей по бизнес-администрированию", "btn_generate": "🚀 Черновик", "btn_download": "📥 Скачать", "topic_label": "📝 Тема", "keywords_label": "🔍 Ключевые слова", "words_label": "📏 Количество слов", "success": "🎉 Задача выполнена!"},
+            "Қазақша": {"title": "📊 Бизнес-басқару жөніндегі ғылыми мақала агенті", "btn_generate": "🚀 Жоба дайындау", "btn_download": "📥 Жүктеу", "topic_label": "📝 Мақала атауы", "keywords_label": "🔍 Түйін сөздер", "words_label": "📏 Мақсатты сөз саны", "success": "🎉 Тапсырма аяқталды!"}
+        },
+        "target_lang_map": {
+            "中文": "Simplified Chinese (简体中文)",
+            "English": "Simplified Chinese (简体中文)",
+            "Русский": "Russian (Русский)",
+            "Қазақша": "Kazakh (Қазақша)"
+        },
+
+        "workspace_dir": ".workspace",
+        
+        "docx_styles": {
+            "font_name": "Times New Roman",
+            "font_size_pt": 12,
+            "code_font": "Courier New",
+            "code_size_pt": 11
+        },
+        
+        "blacklists": {
+            "meta_sections": [
+                "abstract", "keyword", "keywords", "摘要", "关键词", "关键字", 
+                "reference", "references", "reference list", "参考文献", 
+                "acknowledgment", "acknowledgements", "致谢",
+                "аннотация", "ключевые слова", "түйіндеме", "кілт сөздер"
+            ]
+        },
+
+        # =====================================================================
+        # Canonical manuscript structures. Top-level titles are deterministic:
+        # the model may write content, but it may not rename, remove, or reorder
+        # required sections.
+        # =====================================================================
+        "amj_schema": [
+            {
+                "section_id": "introduction",
+                "section": "Introduction",
+                "weight": 0.10,
+                "subsections": [],
+            },
+            {
+                "section_id": "theory",
+                "section": "Theoretical Background and Hypotheses",
+                "weight": 0.27,
+                "subsections": [
+                    {"subsection_id": "conceptual_background", "title": "Conceptual Background and Research Gap", "share": 0.23},
+                    {"subsection_id": "theoretical_mechanisms", "title": "Theoretical Mechanisms", "share": 0.27},
+                    {"subsection_id": "hypothesis_development", "title": "Hypothesis Development", "share": 0.35},
+                    {"subsection_id": "integrated_model", "title": "Integrated Research Model", "share": 0.15},
+                ],
+            },
+            {
+                "section_id": "methodology",
+                "section": "Methodology",
+                "weight": 0.20,
+                "subsections": [
+                    {"subsection_id": "research_design", "title": "Research Design and Context", "share": 0.18},
+                    {"subsection_id": "sample_data", "title": "Sample and Data Collection", "share": 0.20},
+                    {"subsection_id": "measures", "title": "Measures and Construct Operationalization", "share": 0.25},
+                    {"subsection_id": "analysis_strategy", "title": "Analytical Strategy", "share": 0.22},
+                    {"subsection_id": "validity_bias", "title": "Validity, Bias, and Robustness Procedures", "share": 0.15},
+                ],
+            },
+            {
+                "section_id": "results",
+                "section": "Results",
+                "weight": 0.23,
+                "subsections": [
+                    {"subsection_id": "measurement_results", "title": "Descriptive Statistics and Measurement Assessment", "share": 0.34},
+                    {"subsection_id": "hypothesis_results", "title": "Hypothesis and Association Tests", "share": 0.46},
+                    {"subsection_id": "additional_results", "title": "Additional Analyses and Robustness Checks", "share": 0.20},
+                ],
+            },
+            {
+                "section_id": "discussion",
+                "section": "Discussion",
+                "weight": 0.15,
+                "subsections": [
+                    {"subsection_id": "interpretation", "title": "Interpretation of the Findings", "share": 0.30},
+                    {"subsection_id": "theoretical_contributions", "title": "Theoretical Contributions", "share": 0.30},
+                    {"subsection_id": "practical_implications", "title": "Practical Implications", "share": 0.20},
+                    {"subsection_id": "limitations", "title": "Limitations and Future Research", "share": 0.20},
+                ],
+            },
+            {
+                "section_id": "conclusion",
+                "section": "Conclusion",
+                "weight": 0.05,
+                "subsections": [],
+            },
+        ],
+        "asq_schema": [
+            {
+                "section_id": "introduction",
+                "section": "Introduction",
+                "weight": 0.10,
+                "subsections": [],
+            },
+            {
+                "section_id": "theoretical_framing",
+                "section": "Theoretical Framing",
+                "weight": 0.18,
+                "subsections": [
+                    {"subsection_id": "phenomenon_puzzle", "title": "Phenomenon and Theoretical Puzzle", "share": 0.35},
+                    {"subsection_id": "conceptual_tension", "title": "Relevant Literature and Conceptual Tension", "share": 0.40},
+                    {"subsection_id": "research_question", "title": "Research Question and Analytical Focus", "share": 0.25},
+                ],
+            },
+            {
+                "section_id": "methods",
+                "section": "Research Setting and Methods",
+                "weight": 0.17,
+                "subsections": [
+                    {"subsection_id": "research_setting", "title": "Research Setting", "share": 0.24},
+                    {"subsection_id": "data_collection", "title": "Data Sources and Collection", "share": 0.28},
+                    {"subsection_id": "analytic_procedure", "title": "Analytical Procedure", "share": 0.30},
+                    {"subsection_id": "trustworthiness", "title": "Trustworthiness, Ethics, and Reflexivity", "share": 0.18},
+                ],
+            },
+            {
+                "section_id": "findings",
+                "section": "Findings",
+                "weight": 0.30,
+                "dynamic_subsections": "qualitative_themes",
+                "subsections": [
+                    {"subsection_id": "emergent_model", "title": "Emergent Process Model", "share": 0.18},
+                ],
+            },
+            {
+                "section_id": "discussion",
+                "section": "Discussion",
+                "weight": 0.15,
+                "subsections": [
+                    {"subsection_id": "interpretation", "title": "Interpretation of the Emergent Findings", "share": 0.30},
+                    {"subsection_id": "theoretical_contributions", "title": "Theoretical Contributions", "share": 0.30},
+                    {"subsection_id": "boundaries", "title": "Boundary Conditions and Transferability", "share": 0.20},
+                    {"subsection_id": "practical_implications", "title": "Practical Implications", "share": 0.20},
+                ],
+            },
+            {
+                "section_id": "conclusion",
+                "section": "Conclusion",
+                "weight": 0.05,
+                "subsections": [],
+            },
+            {
+                "section_id": "appendix",
+                "section": "Appendix: Data Structure and Evidence",
+                "weight": 0.05,
+                "subsections": [],
+            },
+        ],
+        "manuscript_validation": {
+            "minimum_total_ratio": 0.85,
+            "maximum_total_ratio": 1.15,
+            "minimum_section_words": 120,
+            "minimum_conclusion_words": 120,
+            "minimum_qualitative_themes": 3,
+            "minimum_qualitative_quotes": 8,
+        },
+
+        "prompt_templates": {
+            "meta_extract": """You are an expert academic data extractor. Read the provided text and extract the core metadata.
+CRITICAL: You MUST output ONLY a valid JSON object. Do not include markdown formatting or explanations.
+
+{
+  "paper_title": "<String: Exact title>",
+  "core_theory": "<String: Max 5 words, e.g., 'Social Exchange Theory'>",
+  "variables": {
+    "IV": "<String: Independent Variables>",
+    "DV": "<String: Dependent Variables>",
+    "Mediators": "<String or 'N/A'>",
+    "Moderators": "<String or 'N/A'>"
+  },
+  "methodology": {
+    "sample_size": "<Integer or 'N/A'>",
+    "context": "<String: Max 10 words, e.g., 'US Tech Industry'>",
+    "analysis_tool": "<String: e.g., 'SEM, PLS, OLS'>"
+  },
+  "key_findings": "<String: Strict ONE-SENTENCE summary emphasizing causality>",
+  "future_gaps": "<String: Explicit limitations or future directions>"
+}""",
+            "synthesis_system": "You are a top-tier academic researcher in Business Administration.",
+            "synthesis_user": """Topic: {topic}{user_injection}
+Literature Metadata:
+<LIT_DATA>
+{refs_text}
+</LIT_DATA>
+
+[SYNTHESIS MANDATE: THEMATIC INTEGRATION]
+1. You MUST NOT summarize papers sequentially (e.g., "A found X. B found Y.").
+2. Synthesize by THEME or THEORETICAL TENSION rather than paper-by-paper summaries.
+3. Apply claim-specific citation: each sentence may contain at most one [CITE-XX] tag. Never group multiple sources in one parenthesis or sentence. If sources support different claims, use separate sentences; if they support the same claim, select the single most direct source.
+4. Explicitly highlight theoretical conflicts or consensus.
+5. Conclude by revealing a specific blind spot that necessitates our current research.
+{directive}"""
+        }
+    }
+
+    # =====================================================================
+    # 定量引擎 (AMJ 风格) - 保持原样，极致严谨与假设推演
+    # =====================================================================
+    amj_prompts = {
+        "sys_academic_writer": """You are a distinguished, highly cited scholar writing a manuscript for the Academy of Management Journal (AMJ). Your writing must exhibit unparalleled theoretical rigor, causal depth, and academic authority.
+[CRITICAL LANGUAGE MANDATE]: You MUST generate all responses strictly in ACADEMIC ENGLISH. Even if the user provides topic, data, or context in Chinese or another language, your final output MUST be in English.
+[ABSOLUTE ANTI-AI-TONE MANDATES]:
+1. CRITICAL: NEVER use these cliché AI words: delve into, intricate, paramount, overarching, pivotal, foster, seamlessly, multifaceted, beacon, landscape, underscore, robust.
+2. CRITICAL: NEVER use robotic transition phrases (e.g., Firstly, Moreover, Furthermore, In conclusion, To summarize). Use conceptual bridges instead.
+3. NATURAL SYNTAX: Vary sentence structure only where the argument requires it. Avoid artificial short-long sentence alternation and repetitive templates.
+4. ACADEMIC HEDGING: Use strategic hedging (e.g., 'This suggests a tendency toward X, bounded by Y').
+5. NO SWEEPING GENERALIZATIONS: Every sentence must carry specific theoretical weight or empirical fact.
+6. FOCUS ON CAUSALITY: You MUST articulate the exact theoretical mechanism driving the relationship.
+7. ACADEMIC REGISTER: Use concise, accurate, and rigorous language. Concepts must be explicit, hierarchy clear, and reasoning logically traceable.
+8. PROHIBITED RHETORIC: Never use metaphors, analogies, rhetorical questions, literary embellishment, or promotional claims.
+9. ABSTRACT DISCIPLINE: In abstracts, report only the minimum numerical evidence needed to convey the main finding; do not crowd the abstract with coefficients or test statistics.
+10. STRUCTURAL DISCIPLINE: Cover only the assigned section and subsection. Do not recreate earlier sections, invent alternative headings, or omit required analytical elements.
+11. CLAIM-SPECIFIC CITATION: Each sentence may contain at most one [CITE-XX] tag. Never group multiple references in one parenthesis or sentence. Separate distinct source-supported claims into separate sentences; when sources support the same claim, retain only the single most direct source. Every cited sentence must express a claim directly supported by the cited source evidence.
+""",
+        "deep_refinement_directive": "Produce a final, polished section ready for top-tier submission. Ensure flawless logical flow without meta-commentary. Apply claim-specific citation: use at most one [CITE-XX] tag per sentence, never combine sources in one parenthesis, and cite only the single most direct source when multiple sources support the same claim.\n[SELF-REFLECTION]: Before drafting, critically analyze common AI clichés related to this topic and actively suppress them in your output.",
+        "deep_synthesis_directive": "Structure this synthesis to expose a critical theoretical tension: Consensus vs Paradox, Competing Perspectives, Theoretical Blind Spot.",
+        "hypothesis_development_directive": "Construct a rigorous causal chain: 1. Base Theory. 2. Mechanism (Mediator logic). 3. Boundary Condition (Moderator logic). 4. Hypothesis Phrasing (italicized).",
+        "methodological_defense_directive": "Write with extreme defensive precision: Justify Contextual Relevance, Detail Endogeneity & Bias Mitigation, Measurement Validity, and Analytical Strategy.",
+        "discussion_depth_directive": "Elevate findings back to grand theory. Explicitly state how the study extends, refines, or challenges named theories. Provide counter-intuitive implications.",
+        "conclusion_anchor_directive": "1. Conceptual Pivot. 2. Mechanism Summary. 3. Call to Action for the next decade.",
+        "anchor_generation_directive": "Generate a STRUCTURED ABSTRACT (max 200 words) mimicking an AMJ abstract, and a CONCLUSION ANCHOR (approx. 150 words). Output format:\n---ABSTRACT---\n...\n---CONCLUSION---\n...",
+        "empirical_data_logic": "Maintain strict adherence to APA 7th edition reporting standards. Include plausible degrees of freedom, exact p-values, confidence intervals, and effect sizes.",
+    }
+
+    # =====================================================================
+    # 定性引擎 (ASQ 风格) - 聚焦现象描述、意义建构与语录引用
+    # =====================================================================
+    asq_prompts = {
+        "sys_academic_writer": """You are a senior editor and distinguished qualitative researcher writing for Administrative Science Quarterly (ASQ). 
+Your writing style is phenomenon-driven, deeply narrative, and theoretically rich.
+[CRITICAL LANGUAGE MANDATE]: You MUST generate all responses strictly in ACADEMIC ENGLISH. 
+[ABSOLUTE ASQ MANDATES]:
+1. FOCUS ON THE PUZZLE: Embrace counter-intuitive empirical phenomena and paradoxes.
+2. THICK DESCRIPTION: Use descriptive, evocative language to ground your qualitative findings in reality.
+3. SENSEMAKING: Focus on how organizational actors interpret, negotiate, and construct their reality.
+4. NO FORMAL HYPOTHESES: DO NOT use 'Hypothesis 1' phrasing. Use 'Propositions' or conceptual emergent models instead.
+5. NO AI CLICHES: Strictly avoid 'delve', 'tapestry', 'multifaceted', 'beacon', 'landscape'.
+6. ACADEMIC REGISTER: Use concise, accurate, and rigorous language with explicit concepts and logically ordered claims.
+7. PROHIBITED RHETORIC: Never use metaphors, analogies, rhetorical questions, literary embellishment, or promotional claims. Use concrete evidence-based description rather than decorative prose.
+8. ABSTRACT DISCIPLINE: Keep numerical details to the minimum needed to communicate the empirical puzzle, main finding, and contribution.
+9. CLAIM-SPECIFIC CITATION: Each sentence may contain at most one [CITE-XX] tag. Never group multiple references in one parenthesis or sentence. Separate distinct source-supported claims into separate sentences; when sources support the same claim, retain only the single most direct source. Every cited sentence must express a claim directly supported by the cited source evidence.""",
+        "deep_refinement_directive": "Ensure logical flow and focus on the emergent theoretical model. Write in continuous, engaging paragraphs. Apply claim-specific citation: use at most one [CITE-XX] tag per sentence, never combine sources in one parenthesis, and cite only the single most direct source when several sources support the same claim.",
+        "deep_synthesis_directive": "Structure this synthesis to highlight a critical empirical puzzle or theoretical paradox that qualitative investigation can unravel.",
+        "hypothesis_development_directive": "Develop the theoretical framing. DO NOT use formal hypotheses. Detail the conceptual gaps and frame the overarching research questions or theoretical propositions.",
+        "methodological_defense_directive": "Detail the research setting vividly. Justify data sources (interviews, ethnographic observations, archives), and rigorously explain the step-by-step coding process (e.g., Gioia methodology).",
+        "discussion_depth_directive": "Elevate the emergent qualitative findings back to grand theory. Contrast your inductive process model with existing linear or variance-based theories.",
+        "conclusion_anchor_directive": "Summarize the theoretical contribution, the resolution of the empirical puzzle, and the sensemaking implications.",
+        "anchor_generation_directive": "Generate a NARRATIVE ABSTRACT (max 200 words) mimicking an ASQ abstract (focusing on the puzzle, setting, and emergent model), and a CONCLUSION ANCHOR (approx. 150 words). Output format:\n---ABSTRACT---\n...\n---CONCLUSION---\n...",
+        "empirical_data_logic": "Present findings as a compelling narrative. You MUST integrate representative quotes seamlessly into the text to provide raw evidence for each 1st-order concept and 2nd-order theme. Ensure the voice of the informants is central.",
+    }
+
+    generic_prompts = amj_prompts.copy()
+    return base_config, amj_prompts, asq_prompts, generic_prompts
+
+DEFAULT_CONFIG, AMJ_PROMPTS, ASQ_PROMPTS, GENERIC_PROMPTS = load_config()
+APP_CONFIG = DEFAULT_CONFIG.copy()

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/core/desktop.ini

@@ -0,0 +1,2 @@
+[.ShellClassInfo]
+IconResource=C:\Program Files\Google\Drive File Stream\129.0.1.0\GoogleDriveFS.exe,27

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/core/meta_extractor.py

@@ -0,0 +1,52 @@
+# -*- coding: utf-8 -*-
+import json
+import concurrent.futures
+from typing import List, Dict
+import re
+import logging
+from config import APP_CONFIG
+
+class MetaExtractor:
+    def __init__(self, agent):
+        self.agent = agent
+        self.max_workers = APP_CONFIG["lit_max_workers"]
+
+    def extract_single_paper_meta(self, text: str) -> Dict:
+        snippet = self.agent._truncate_context(text, max_tokens=3500)
+        prompt = APP_CONFIG["prompt_templates"]["meta_extract"]
+        
+        try:
+            # 修改点：显式将模型降级为 deepseek-chat (V3)，以获得更快的并行提取速度
+            response = self.agent.call_deepseek(
+                prompt, 
+                snippet, 
+                max_tokens=1000, 
+                model_name="deepseek-chat"
+            )
+            
+            # 强制提取 JSON 部分，过滤模型可能的解释性前缀或后缀
+            json_match = re.search(r'\{.*\}', response, re.DOTALL)
+            if json_match:
+                return json.loads(json_match.group())
+            return {}
+        except Exception as e:
+            logging.error(f"Meta Extraction error: {e}")
+            return {}
+
+    def run_batch_extraction(self, paper_texts: List[str]) -> List[Dict]:
+        golden_db = []
+        # 使用配置中的 lit_max_workers 进行多线程并行提取
+        with concurrent.futures.ThreadPoolExecutor(max_workers=self.max_workers) as executor:
+            future_to_paper = {executor.submit(self.extract_single_paper_meta, text): text for text in paper_texts}
+            for future in concurrent.futures.as_completed(future_to_paper):
+                try:
+                    data = future.result()
+                    if data: 
+                        golden_db.append(data)
+                except Exception as e:
+                    logging.error(f"Batch Future error: {e}")
+        return golden_db
+
+def extract_golden_metadata(agent, paper_texts: List[str]):
+    extractor = MetaExtractor(agent)
+    return extractor.run_batch_extraction(paper_texts)

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/core/production_guard.py

@@ -0,0 +1,182 @@
+# -*- coding: utf-8 -*-
+"""Final-output validation and packaging for SmartPaper."""
+from __future__ import annotations
+
+import hashlib
+import io
+import json
+import re
+import zipfile
+from dataclasses import dataclass
+from typing import Any
+
+from docx import Document
+
+from utils.docx_builder import DocxBuildError, text_to_docx
+
+
+class OutputValidationError(RuntimeError):
+    pass
+
+
+@dataclass(frozen=True)
+class PackageResult:
+    zip_bytes: bytes
+    file_names: tuple[str, ...]
+    manifest: str
+
+
+def replace_abstract(manuscript: str, abstract: str) -> str:
+    value = str(manuscript or "")
+    replacement = f"## Abstract\n{str(abstract or '').strip()}\n\n"
+    updated, count = re.subn(
+        r"(?ms)^##\s+Abstract\s*$\n.*?(?=^##\s+Keywords\s*$)",
+        replacement,
+        value,
+        count=1,
+    )
+    if count != 1:
+        raise OutputValidationError("English abstract block was not found exactly once.")
+    return updated
+
+
+def validate_docx_bytes(data: bytes, *, minimum_paragraphs: int = 8) -> None:
+    if not data or len(data) < 1500:
+        raise OutputValidationError("DOCX output is empty or unexpectedly small.")
+    try:
+        document = Document(io.BytesIO(data))
+    except Exception as exc:
+        raise OutputValidationError(f"DOCX cannot be reopened: {exc}") from exc
+    nonempty = [paragraph.text.strip() for paragraph in document.paragraphs if paragraph.text.strip()]
+    if len(nonempty) < minimum_paragraphs:
+        raise OutputValidationError(
+            f"DOCX contains only {len(nonempty)} nonempty paragraphs; expected at least {minimum_paragraphs}."
+        )
+
+
+def validate_markdown_manuscript(text: str, *, language_name: str) -> None:
+    value = str(text or "").strip()
+    if len(value) < 1000:
+        raise OutputValidationError(f"{language_name} manuscript is incomplete.")
+    if re.search(r"\[?CITE-\d+\]?", value, flags=re.IGNORECASE):
+        raise OutputValidationError(f"{language_name} manuscript still contains unresolved citation tags.")
+    if re.search(r"(?i)\bas an ai(?: language model)?\b|\bai[- ]generated\b", value):
+        raise OutputValidationError(f"{language_name} manuscript contains AI-writing meta-commentary.")
+    if not re.search(r"(?m)^#\s+", value):
+        raise OutputValidationError(f"{language_name} manuscript has no title/section headings.")
+
+
+def build_generation_notes(data_metadata: dict[str, Any], mode: str) -> str:
+    metadata = dict(data_metadata or {})
+    source_type = metadata.get("source_type", "unknown")
+    lines = [
+        "SmartPaper Generation Notes",
+        "",
+        f"Research mode: {mode}",
+        f"Evidence source type: {source_type}",
+        "",
+        "This file is separate from the manuscript. It documents how research evidence was supplied or generated, the applicable boundaries, and the validation steps used before packaging.",
+    ]
+    if metadata.get("disclosure_required"):
+        lines.extend(
+            [
+                "",
+                "Evidence-generation notice:",
+                "The statistical results or qualitative materials used by this run were generated by the system because verified user-provided evidence was unavailable. They were created for drafting and methodological demonstration. They must not be represented as independently collected empirical observations.",
+                "",
+                f"Generation method: {metadata.get('method') or 'Structured evidence generation under the selected quantitative or qualitative engine.'}",
+            ]
+        )
+    study_facts = metadata.get("study_facts")
+    if isinstance(study_facts, dict):
+        lines.extend(["", "Frozen qualitative study facts:", json.dumps(study_facts, ensure_ascii=False, indent=2)])
+    if metadata.get("sample_size") is not None:
+        lines.append(f"Generated sample size: {metadata.get('sample_size')}")
+    if metadata.get("evidence_count") is not None:
+        lines.append(f"Generated/retained qualitative evidence items: {metadata.get('evidence_count')}")
+    themes = metadata.get("themes")
+    if isinstance(themes, list):
+        lines.append(f"Generated/retained qualitative themes: {len(themes)}")
+    parameters = metadata.get("generation_parameters")
+    if isinstance(parameters, dict) and parameters:
+        lines.extend(
+            [
+                "",
+                "Generation parameters and process:",
+                json.dumps(parameters, ensure_ascii=False, indent=2),
+            ]
+        )
+    lines.extend(
+        [
+            "",
+            "Validation boundary:",
+            "The package confirms internal consistency, file integrity, citation resolution, and translation completeness. It does not independently verify external data collection, factual truth beyond the supplied sources, journal acceptance, or the result of any third-party AI-writing detector.",
+        ]
+    )
+    return "\n".join(lines).strip() + "\n"
+
+
+def _manifest(entries: dict[str, bytes]) -> str:
+    rows = []
+    for name in sorted(entries):
+        rows.append(f"{hashlib.sha256(entries[name]).hexdigest()}  {name}")
+    return "\n".join(rows) + "\n"
+
+
+def build_validated_package(
+    *,
+    english_markdown: str,
+    translated_markdown: str,
+    english_filename: str,
+    translated_filename: str,
+    data_metadata: dict[str, Any],
+    mode: str,
+    citation_audit: list[dict[str, Any]],
+    literature_metrics: dict[str, Any],
+) -> PackageResult:
+    validate_markdown_manuscript(english_markdown, language_name="English")
+    validate_markdown_manuscript(translated_markdown, language_name="Target-language")
+
+    try:
+        english_docx = text_to_docx(english_markdown).getvalue()
+        translated_docx = text_to_docx(translated_markdown).getvalue()
+    except DocxBuildError as exc:
+        raise OutputValidationError(str(exc)) from exc
+    validate_docx_bytes(english_docx)
+    validate_docx_bytes(translated_docx)
+
+    entries: dict[str, bytes] = {
+        english_filename: english_docx,
+        translated_filename: translated_docx,
+        "GENERATION_NOTES.txt": build_generation_notes(data_metadata, mode).encode("utf-8"),
+        "CITATION_AUDIT.json": json.dumps(citation_audit or [], ensure_ascii=False, indent=2).encode("utf-8"),
+        "LITERATURE_METRICS.json": json.dumps(literature_metrics or {}, ensure_ascii=False, indent=2).encode("utf-8"),
+    }
+    manifest = _manifest(entries)
+    entries["FILE_MANIFEST_SHA256.txt"] = manifest.encode("utf-8")
+
+    buffer = io.BytesIO()
+    with zipfile.ZipFile(buffer, "w", zipfile.ZIP_DEFLATED) as archive:
+        for name, content in entries.items():
+            archive.writestr(name, content)
+    zip_bytes = buffer.getvalue()
+
+    try:
+        with zipfile.ZipFile(io.BytesIO(zip_bytes), "r") as archive:
+            bad = archive.testzip()
+            if bad:
+                raise OutputValidationError(f"ZIP integrity check failed at {bad}.")
+            names = set(archive.namelist())
+            required = set(entries)
+            if names != required:
+                raise OutputValidationError(
+                    f"ZIP file list mismatch: actual={sorted(names)}, expected={sorted(required)}"
+                )
+            for name in (english_filename, translated_filename):
+                validate_docx_bytes(archive.read(name))
+    except OutputValidationError:
+        raise
+    except Exception as exc:
+        raise OutputValidationError(f"ZIP cannot be reopened: {exc}") from exc
+
+    return PackageResult(zip_bytes=zip_bytes, file_names=tuple(sorted(entries)), manifest=manifest)

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/core/qualitative_engine.py

@@ -0,0 +1,248 @@
+# -*- coding: utf-8 -*-
+"""Qualitative evidence preparation for SmartPaper's ASQ track."""
+
+from __future__ import annotations
+
+import logging
+import re
+
+import streamlit as st
+
+from config import APP_CONFIG
+
+
+class QualitativeEngine:
+    def __init__(self, agent):
+        self.agent = agent
+
+    @staticmethod
+    def _clean_cell(value, default="Not specified"):
+        cleaned = str(value or default).replace("\n", " ").strip()
+        return cleaned or default
+
+    def _build_request(self, topic, keywords, raw_interviews):
+        schema = """Return ONLY one valid JSON object with this schema:
+{
+  "study_facts": {
+    "research_setting": "string",
+    "data_sources": ["string"],
+    "participant_count": integer or null,
+    "interview_count": integer or null,
+    "analysis_method": "string"
+  },
+  "evidence": [
+    {"theme": "2nd-order theme", "concept": "1st-order concept", "quote": "verbatim quote"}
+  ]
+}
+"""
+        if raw_interviews and len(raw_interviews) > 100:
+            return f"""Topic: {topic}
+Keywords: {keywords}
+Analyze the supplied interview or field material.
+
+Rules:
+1. Use only setting, sample, source, and count information supported by the supplied material. Use null or "Not specified" when absent.
+2. Extract up to 15 representative quotations verbatim; do not rewrite quotations.
+3. Build a coherent Gioia-style coding structure.
+4. The study_facts object will become the single source of truth for the entire manuscript.
+
+{schema}
+<QUALITATIVE_MATERIAL>
+{raw_interviews[:30000]}
+</QUALITATIVE_MATERIAL>
+"""
+
+        return f"""Topic: {topic}
+Keywords: {keywords}
+Construct one internally coherent qualitative study design and evidence packet for a complete ASQ-style manuscript when no interview material is supplied.
+
+Rules:
+1. Choose one research setting and keep it fixed.
+2. Choose one participant count, interview count, data-source set, and analysis method; do not create conflicting counts.
+3. Produce exactly 12 natural representative quotations organized into a Gioia-style coding structure.
+4. The study_facts object will become the single source of truth for the entire manuscript.
+5. Avoid decorative language, generic AI phrasing, and repetitive quotation patterns.
+
+{schema}
+"""
+
+    def resolve_qualitative_data(self, topic, keywords, raw_interviews=""):
+        has_user_data = bool(raw_interviews and len(raw_interviews) > 100)
+        prompt = self._build_request(topic, keywords, raw_interviews)
+        model_label = self.agent.model_for("reasoning")
+
+        if has_user_data:
+            status_label = (
+                f"🧠 正在使用 {model_label} 分析访谈材料并冻结研究事实…"
+            )
+            complete_label = "✅ 访谈材料、研究事实与编码结构已完成"
+        else:
+            status_label = (
+                f"🧠 正在使用 {model_label} 构建一致的定性研究证据包…"
+            )
+            complete_label = "✅ 定性研究事实与编码结构已完成"
+
+        with st.status(status_label, expanded=True) as status:
+            placeholder = st.empty()
+            response = placeholder.write_stream(
+                self.agent.stream_deepseek(
+                    "You are a rigorous qualitative research analyst.",
+                    prompt,
+                    model_role="reasoning",
+                    thinking=True,
+                    allow_fallback=False,
+                )
+            )
+            status.update(
+                label=complete_label,
+                state="complete",
+                expanded=False,
+            )
+
+        response = re.sub(
+            r"<think>.*?</think>",
+            "",
+            response,
+            flags=re.DOTALL,
+        ).strip()
+        data = self.agent._extract_json_from_text(response)
+
+        if not isinstance(data, dict):
+            logging.error("Qualitative JSON parsing failed; using safe fallback.")
+            data = {
+                "study_facts": {
+                    "research_setting": "Not specified",
+                    "data_sources": ["Interview or field material"],
+                    "participant_count": None,
+                    "interview_count": None,
+                    "analysis_method": "Gioia-style inductive coding",
+                },
+                "evidence": [
+                    {
+                        "theme": "Sensemaking",
+                        "concept": "Initial uncertainty",
+                        "quote": (
+                            "We did not yet have a shared understanding "
+                            "of how to respond."
+                        ),
+                    }
+                ],
+            }
+
+        facts = data.get("study_facts") or {}
+        evidence = data.get("evidence") or data.get("quotes") or []
+        if not isinstance(evidence, list):
+            evidence = []
+
+        data_sources = facts.get("data_sources") or ["Not specified"]
+        if not isinstance(data_sources, list):
+            data_sources = [data_sources]
+
+        setting = self._clean_cell(facts.get("research_setting"))
+        sources = ", ".join(self._clean_cell(item) for item in data_sources)
+        participants = facts.get("participant_count")
+        interviews = facts.get("interview_count")
+        method = self._clean_cell(
+            facts.get("analysis_method"),
+            "Gioia-style inductive coding",
+        )
+
+        md = (
+            "### Qualitative Study Design Summary\n"
+            "| Field | Frozen value |\n"
+            "| :--- | :--- |\n"
+            f"| Research setting | {setting} |\n"
+            f"| Data sources | {sources} |\n"
+            f"| Participants | {participants if participants is not None else 'Not specified'} |\n"
+            f"| Interviews | {interviews if interviews is not None else 'Not specified'} |\n"
+            f"| Analysis method | {method} |\n\n"
+            "[CONSISTENCY MANDATE]\n"
+            "Use the study-design summary above as the single source of truth. "
+            "Do not change the setting, sample, interview count, data sources, "
+            "or analysis method in any section.\n\n"
+            "### Table: Qualitative Coding Structure (Data Evidence)\n"
+            "| 2nd-order Theme | 1st-order Concept | Representative Quote |\n"
+            "| :--- | :--- | :--- |\n"
+        )
+
+        clean_evidence = []
+        for index, item in enumerate(evidence[:15]):
+            if not isinstance(item, dict):
+                continue
+            quote = self._clean_cell(item.get("quote"), "").replace('"', "'")
+            concept = self._clean_cell(item.get("concept"), "Analysis")
+            theme = self._clean_cell(item.get("theme"), "Observation")
+            if not quote:
+                continue
+            tag = f"QUOTE-{index + 1:02d}"
+            md += f'| {theme} | {concept} | "{quote}" [{tag}] |\n'
+            clean_evidence.append(
+                {
+                    "theme": theme,
+                    "concept": concept,
+                    "quote": quote,
+                    "tag": tag,
+                }
+            )
+
+        theme_map = {}
+        for item in clean_evidence:
+            theme_entry = theme_map.setdefault(
+                item["theme"],
+                {"title": item["theme"], "concepts": [], "evidence": []},
+            )
+            if item["concept"] not in theme_entry["concepts"]:
+                theme_entry["concepts"].append(item["concept"])
+            theme_entry["evidence"].append(
+                {"tag": item["tag"], "quote": item["quote"]}
+            )
+
+        themes = list(theme_map.values())
+        validation = APP_CONFIG.get("manuscript_validation", {})
+        minimum_themes = int(validation.get("minimum_qualitative_themes", 3))
+        minimum_quotes = int(validation.get("minimum_qualitative_quotes", 8))
+        if len(themes) < minimum_themes or len(clean_evidence) < minimum_quotes:
+            raise RuntimeError(
+                "Qualitative evidence packet is incomplete: "
+                f"themes={len(themes)}, quotes={len(clean_evidence)}; "
+                f"required themes>={minimum_themes}, quotes>={minimum_quotes}."
+            )
+
+        metadata = {
+            "mode": "qualitative",
+            "source_type": (
+                "user_provided" if has_user_data else "system_generated"
+            ),
+            "disclosure_required": not has_user_data,
+            "study_facts": {
+                "research_setting": setting,
+                "data_sources": data_sources,
+                "participant_count": participants,
+                "interview_count": interviews,
+                "analysis_method": method,
+            },
+            "evidence_count": len(clean_evidence),
+            "generation_parameters": {
+                "coding_approach": "Gioia-style inductive coding",
+                "requested_quote_count_when_generated": 12,
+                "maximum_retained_quotes": 15,
+                "minimum_themes": minimum_themes,
+                "minimum_quotes": minimum_quotes,
+                "consistency_constraints": [
+                    "one fixed research setting",
+                    "one fixed participant count",
+                    "one fixed interview count",
+                    "one fixed data-source set",
+                    "one fixed analysis method",
+                    "quotation tags must remain unique",
+                ],
+            },
+            "evidence": clean_evidence,
+            "themes": themes,
+        }
+        status_message = "✅ 定性研究事实、摘要锚点输入和Gioia编码证据已准备完成。"
+        return md, status_message, metadata
+
+
+def get_qualitative_engine(agent):
+    return QualitativeEngine(agent)

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/core/quantitative_engine.py

@@ -0,0 +1,230 @@
+# -*- coding: utf-8 -*-
+"""Quantitative data preparation for SmartPaper's AMJ track."""
+
+from __future__ import annotations
+
+import re
+
+import numpy as np
+import pandas as pd
+
+from i18n import tr
+from utils.file_parser import extract_data_from_files
+
+
+class QuantitativeEngine:
+    """Keep quantitative preparation isolated from the Streamlit UI."""
+
+    @staticmethod
+    def generate_psd_corr_matrix(n_constructs, max_corr=0.5):
+        if n_constructs == 1:
+            return np.array([[1.0]])
+        base_corr = np.random.uniform(0.2, max_corr - 0.1)
+        matrix = np.random.uniform(
+            base_corr - 0.1,
+            base_corr + 0.1,
+            (n_constructs, n_constructs),
+        )
+        matrix = (matrix + matrix.T) / 2
+        np.fill_diagonal(matrix, 1.0)
+        min_eig = np.min(np.linalg.eigvals(matrix))
+        if min_eig < 0:
+            matrix -= (min_eig - 0.01) * np.eye(n_constructs)
+        diagonal = np.sqrt(np.diag(matrix))
+        return matrix / np.outer(diagonal, diagonal)
+
+    @staticmethod
+    def calculate_validity_metrics(df, constructs_info, true_loadings):
+        metrics = []
+        for construct in constructs_info:
+            construct_name = construct["name"]
+            items = construct["items"]
+            sub_df = df[items]
+            var_total = sub_df.sum(axis=1).var(ddof=1)
+            sum_var = sub_df.var(ddof=1).sum()
+            n_items = len(items)
+            alpha = (
+                0.0
+                if var_total <= 0
+                else (n_items / (n_items - 1))
+                * (1 - sum_var / var_total)
+            )
+            loadings = np.array(true_loadings[construct_name])
+            sum_loadings_sq = np.sum(loadings) ** 2
+            sum_sq_loadings = np.sum(loadings**2)
+            sum_error = np.sum(1 - loadings**2)
+            cr = sum_loadings_sq / (sum_loadings_sq + sum_error)
+            ave = sum_sq_loadings / len(loadings)
+            metrics.append(
+                {
+                    "Construct": construct_name,
+                    "Items": n_items,
+                    "Cronbach's α": round(alpha, 3),
+                    "CR": round(cr, 3),
+                    "AVE": round(ave, 3),
+                }
+            )
+        return pd.DataFrame(metrics)
+
+    def generate_empirical_data_robust(
+        self,
+        construct_names=None,
+        n=300,
+        scale_points=7,
+    ):
+        if not construct_names or len(construct_names) < 2:
+            construct_names = [
+                "Independent_Var",
+                "Mediator_Var",
+                "Dependent_Var",
+            ]
+
+        n_constructs = len(construct_names)
+        corr = self.generate_psd_corr_matrix(n_constructs, max_corr=0.55)
+        latent_scores = np.random.multivariate_normal(
+            mean=[0] * n_constructs,
+            cov=corr,
+            size=n,
+        )
+        data = {}
+        true_loadings = {}
+        constructs_info = []
+        target_mean = scale_points / 2.0 + 0.5
+        target_std = scale_points / 5.0
+
+        for index, construct_name in enumerate(construct_names):
+            true_score = latent_scores[:, index]
+            n_items = np.random.randint(3, 6)
+            loadings = np.random.uniform(0.72, 0.88, n_items)
+            true_loadings[construct_name] = loadings
+            item_names = []
+            for item_index, loading in enumerate(loadings):
+                error = np.random.normal(
+                    0,
+                    np.sqrt(1 - loading**2),
+                    n,
+                )
+                item_score = loading * true_score + error
+                raw_scaled = item_score * target_std + target_mean
+                item_int = np.clip(
+                    np.round(raw_scaled),
+                    1,
+                    scale_points,
+                ).astype(int)
+                column_name = f"{construct_name}_{item_index + 1}"
+                data[column_name] = item_int
+                item_names.append(column_name)
+            constructs_info.append(
+                {"name": construct_name, "items": item_names}
+            )
+
+        df = pd.DataFrame(data)
+        validity_df = self.calculate_validity_metrics(
+            df,
+            constructs_info,
+            true_loadings,
+        )
+        mean_scores = pd.DataFrame(
+            {
+                construct["name"]: df[construct["items"]].mean(axis=1)
+                for construct in constructs_info
+            }
+        )
+        fl_matrix = mean_scores.corr().astype(object)
+
+        for _, row in validity_df.iterrows():
+            construct_name = row["Construct"]
+            sqrt_ave = np.sqrt(row["AVE"])
+            fl_matrix.loc[construct_name, construct_name] = (
+                f"({sqrt_ave:.3f})"
+            )
+
+        for row_index in range(len(fl_matrix.columns)):
+            for column_index in range(row_index + 1, len(fl_matrix.columns)):
+                fl_matrix.iloc[row_index, column_index] = ""
+
+        desc_stats = mean_scores.mean().to_frame("Mean").join(
+            mean_scores.std().to_frame("SD")
+        )
+        return df, validity_df, desc_stats.join(fl_matrix)
+
+    def resolve_empirical_data(self, uploaded_files=None, language="zh"):
+        if uploaded_files:
+            user_md = extract_data_from_files(uploaded_files)
+            if user_md:
+                evidence_sections = [
+                    heading.strip()
+                    for heading in re.findall(
+                        r"(?m)^#{1,3}\s+(.+?)\s*$",
+                        user_md,
+                    )
+                    if heading.strip()
+                ]
+                metadata = {
+                    "mode": "quantitative",
+                    "source_type": "user_provided",
+                    "disclosure_required": False,
+                    "evidence_sections": evidence_sections[:20]
+                    or ["User-provided quantitative evidence"],
+                }
+                return None, user_md, tr(language, "actual_stats_parsed"), metadata
+
+        df, validity_df, fl_matrix_df = self.generate_empirical_data_robust()
+        generated_prompt = f"""### Table 1: Reliability and Convergent Validity
+{validity_df.to_markdown(index=False)}
+### Table 2: Descriptive Statistics and Discriminant Validity (Fornell-Larcker Criterion)
+*Note: Diagonal elements in parentheses are the square roots of AVE.*
+{fl_matrix_df.to_markdown()}
+[STRICT EMPIRICAL INSTRUCTION]
+1. ZERO HALLUCINATION: Report the exact metrics provided above.
+2. VALIDITY DEFENSE: State convergent validity only when the displayed AVE and CR values support it.
+3. DISCRIMINANT DEFENSE: State discriminant validity only when the displayed diagonal and correlation values support it.
+4. CONSISTENCY: Use these tables as the single source of numerical truth throughout the paper.
+"""
+        metadata = {
+            "mode": "quantitative",
+            "source_type": "system_generated",
+            "disclosure_required": True,
+            "sample_size": int(len(df)),
+            "scale_points": 7,
+            "method": (
+                "Positive-semidefinite latent correlation generation, "
+                "indicator loadings, discretization, and derived "
+                "reliability/validity summaries."
+            ),
+            "generation_parameters": {
+                "constructs": [
+                    "Independent_Var",
+                    "Mediator_Var",
+                    "Dependent_Var",
+                ],
+                "sample_size": int(len(df)),
+                "likert_scale_points": 7,
+                "items_per_construct": "random integer from 3 to 5",
+                "indicator_loading_range": [0.72, 0.88],
+                "latent_correlation_control": "positive-semidefinite matrix with maximum target correlation 0.55",
+                "item_generation": "loading × latent score + normally distributed measurement error",
+                "discretization": "round to nearest integer and clamp to 1–7",
+                "reported_summaries": [
+                    "Cronbach alpha",
+                    "composite reliability",
+                    "average variance extracted",
+                    "descriptive statistics",
+                    "Fornell-Larcker matrix",
+                ],
+            },
+            "evidence_sections": [
+                "Reliability and convergent validity",
+                "Descriptive statistics and discriminant validity",
+            ],
+        }
+        return (
+            df,
+            generated_prompt,
+            tr(language, "synthetic_stats_generated"),
+            metadata,
+        )
+
+
+def get_quantitative_engine():
+    return QuantitativeEngine()

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/core/rag_engine.py

@@ -0,0 +1,62 @@
+# -*- coding: utf-8 -*-
+from typing import List
+import numpy as np
+from config import APP_CONFIG
+
+try:
+    from sklearn.feature_extraction.text import TfidfVectorizer
+    from sklearn.metrics.pairwise import cosine_similarity
+    SKLEARN_AVAILABLE = True
+except ImportError:
+    SKLEARN_AVAILABLE = False
+
+class ResearchRAGEngine:
+    def __init__(self, raw_texts: List[str]):
+        self.chunks = []
+        self.vectorizer = None
+        self.tfidf_matrix = None
+        self.chunk_size = APP_CONFIG["rag_chunk_size"]
+        self._initialize_chunks(raw_texts)
+
+    def _initialize_chunks(self, raw_texts: List[str]):
+        for text in raw_texts:
+            for i in range(0, len(text), self.chunk_size):
+                chunk = text[i:i + self.chunk_size].strip()
+                if len(chunk) > 50:
+                    self.chunks.append(chunk)
+                    
+        if SKLEARN_AVAILABLE and self.chunks:
+            self.vectorizer = TfidfVectorizer(stop_words='english', max_df=0.85)
+            try:
+                self.tfidf_matrix = self.vectorizer.fit_transform(self.chunks)
+            except ValueError:
+                self.vectorizer = None
+
+    def get_relevant_context(self, query: str, top_k: int = None) -> str:
+        if not self.chunks: 
+            return ""
+        if top_k is None: 
+            top_k = APP_CONFIG["rag_top_k"]
+        
+        relevant_chunks = []
+        if self.vectorizer and self.tfidf_matrix is not None:
+            query_vec = self.vectorizer.transform([query])
+            similarities = cosine_similarity(query_vec, self.tfidf_matrix).flatten()
+            top_indices = similarities.argsort()[-top_k:][::-1]
+            relevant_chunks = [self.chunks[i] for i in top_indices if similarities[i] > 0.05]
+        else:
+            scores = []
+            query_words = set(query.lower().split())
+            for chunk in self.chunks:
+                chunk_lower = chunk.lower()
+                score = sum(1 for word in query_words if word in chunk_lower)
+                scores.append(score)
+            top_indices = np.argsort(scores)[-top_k:]
+            relevant_chunks = [self.chunks[i] for i in top_indices if scores[i] > 0]
+            
+        if not relevant_chunks: 
+            return ""
+        return "\n--- Target Context Snippet ---\n" + "\n\n".join(relevant_chunks)
+
+def initialize_rag(texts: List[str]):
+    return ResearchRAGEngine(texts)

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/desktop.ini

@@ -0,0 +1,2 @@
+[.ShellClassInfo]
+IconResource=C:\Program Files\Google\Drive File Stream\129.0.1.0\GoogleDriveFS.exe,27

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/i18n.py

@@ -0,0 +1,856 @@
+# -*- coding: utf-8 -*-
+"""SmartPaper user-interface translations.
+
+The Chinese interface is the visual baseline. Other languages replace text only;
+Streamlit component order, icons, layout, and interaction remain unchanged.
+"""
+
+from __future__ import annotations
+
+from typing import Any
+
+
+LANGUAGE_OPTIONS = {
+    "中文": "zh",
+    "English": "en",
+    "Русский": "ru",
+    "Қазақша": "kk",
+}
+
+TARGET_LANGUAGE = {
+    "zh": "Simplified Chinese (简体中文)",
+    # Approved product rule: English UI still delivers English evidence draft + Chinese paper.
+    "en": "Simplified Chinese (简体中文)",
+    "ru": "Russian (Русский)",
+    "kk": "Kazakh (Қазақша)",
+}
+
+OUTPUT_SUFFIX = {
+    "zh": "CN",
+    "en": "CN",
+    "ru": "RU",
+    "kk": "KK",
+}
+
+TARGET_FLAG = {
+    "zh": "🇨🇳",
+    "en": "🇨🇳",
+    "ru": "🇷🇺",
+    "kk": "🇰🇿",
+}
+
+
+
+AMJ_CSV_TEMPLATES = {
+    "zh": """--- 表1：描述性统计与相关系数 ---
+Variables,Mean,SD,1,2,3
+Team Cohesion,4.21,0.85,(0.88),,
+AI Integration,3.95,0.91,0.45**,(0.82),
+Task Performance,4.10,0.78,0.52**,0.38*,(0.85)
+
+--- 表2：信效度检验 ---
+Construct,Items,Cronbach's Alpha,CR,AVE
+Team Cohesion,4,0.89,0.91,0.71
+AI Integration,3,0.85,0.88,0.68
+
+--- 表3：假设检验 ---
+Hypothesis,Path,Beta,T-value,P-value,Supported?
+H1,AI Integration -> Team Cohesion,0.35,4.21,0.000,Yes""",
+    "en": """--- Table 1: Descriptive Statistics and Correlations ---
+Variables,Mean,SD,1,2,3
+Team Cohesion,4.21,0.85,(0.88),,
+AI Integration,3.95,0.91,0.45**,(0.82),
+Task Performance,4.10,0.78,0.52**,0.38*,(0.85)
+
+--- Table 2: Reliability and Validity ---
+Construct,Items,Cronbach's Alpha,CR,AVE
+Team Cohesion,4,0.89,0.91,0.71
+AI Integration,3,0.85,0.88,0.68
+
+--- Table 3: Hypothesis Tests ---
+Hypothesis,Path,Beta,T-value,P-value,Supported?
+H1,AI Integration -> Team Cohesion,0.35,4.21,0.000,Yes""",
+    "ru": """--- Таблица 1: Описательная статистика и корреляции ---
+Переменные,Среднее,SD,1,2,3
+Сплочённость команды,4.21,0.85,(0.88),,
+Интеграция ИИ,3.95,0.91,0.45**,(0.82),
+Результативность задачи,4.10,0.78,0.52**,0.38*,(0.85)
+
+--- Таблица 2: Надёжность и валидность ---
+Конструкт,Пункты,Cronbach's Alpha,CR,AVE
+Сплочённость команды,4,0.89,0.91,0.71
+Интеграция ИИ,3,0.85,0.88,0.68
+
+--- Таблица 3: Проверка гипотез ---
+Гипотеза,Связь,Beta,T-значение,P-значение,Поддержана?
+H1,Интеграция ИИ -> Сплочённость команды,0.35,4.21,0.000,Да""",
+    "kk": """--- 1-кесте: Сипаттамалық статистика және корреляциялар ---
+Айнымалылар,Орташа,SD,1,2,3
+Команда бірлігі,4.21,0.85,(0.88),,
+ЖИ интеграциясы,3.95,0.91,0.45**,(0.82),
+Тапсырма нәтижелілігі,4.10,0.78,0.52**,0.38*,(0.85)
+
+--- 2-кесте: Сенімділік және валидтілік ---
+Конструкт,Тармақтар,Cronbach's Alpha,CR,AVE
+Команда бірлігі,4,0.89,0.91,0.71
+ЖИ интеграциясы,3,0.85,0.88,0.68
+
+--- 3-кесте: Гипотезаларды тексеру ---
+Гипотеза,Байланыс,Beta,T-мәні,P-мәні,Қолдау бар ма?
+H1,ЖИ интеграциясы -> Команда бірлігі,0.35,4.21,0.000,Иә""",
+}
+
+ASQ_TXT_TEMPLATES = {
+    "zh": """[访谈编号]：INT-01
+[受访者岗位]：高级软件工程师
+[访谈日期]：2026-03-12
+[访谈时长]：45分钟
+
+访谈者：生成式AI助手的引入如何改变了团队的日常敏捷站会？
+
+受访者（INT-01）：[在这里输入受访者的完整回答]
+
+访谈者：[在这里输入后续问题]
+
+受访者（INT-01）：[在这里输入后续回答]
+
+--------------------------------------------------
+
+[访谈编号]：INT-02
+[受访者岗位]：敏捷教练
+[访谈日期]：2026-03-15
+[访谈时长]：60分钟
+
+访谈者：[在这里输入问题]
+
+受访者（INT-02）：[在这里输入回答]""",
+    "en": """[Interview ID]: INT-01
+[Informant Role]: Senior Software Engineer
+[Interview Date]: 2026-03-12
+[Interview Duration]: 45 minutes
+
+Interviewer: How did the introduction of a generative-AI assistant change the team's daily stand-up meetings?
+
+Informant (INT-01): [Enter the informant's complete response here]
+
+Interviewer: [Enter the follow-up question here]
+
+Informant (INT-01): [Enter the follow-up response here]
+
+--------------------------------------------------
+
+[Interview ID]: INT-02
+[Informant Role]: Scrum Master
+[Interview Date]: 2026-03-15
+[Interview Duration]: 60 minutes
+
+Interviewer: [Enter the question here]
+
+Informant (INT-02): [Enter the response here]""",
+    "ru": """[Номер интервью]: INT-01
+[Роль информанта]: Старший инженер-программист
+[Дата интервью]: 2026-03-12
+[Продолжительность]: 45 минут
+
+Интервьюер: Как внедрение помощника на основе генеративного ИИ изменило ежедневные стендап-встречи команды?
+
+Информант (INT-01): [Введите полный ответ информанта]
+
+Интервьюер: [Введите уточняющий вопрос]
+
+Информант (INT-01): [Введите последующий ответ]
+
+--------------------------------------------------
+
+[Номер интервью]: INT-02
+[Роль информанта]: Скрам-мастер
+[Дата интервью]: 2026-03-15
+[Продолжительность]: 60 минут
+
+Интервьюер: [Введите вопрос]
+
+Информант (INT-02): [Введите ответ]""",
+    "kk": """[Сұхбат нөмірі]: INT-01
+[Ақпарат берушінің рөлі]: Аға бағдарламалық жасақтама инженері
+[Сұхбат күні]: 2026-03-12
+[Ұзақтығы]: 45 минут
+
+Сұхбат алушы: Генеративті ЖИ көмекшісін енгізу команданың күнделікті стендап жиналыстарына қалай әсер етті?
+
+Ақпарат беруші (INT-01): [Ақпарат берушінің толық жауабын осында енгізіңіз]
+
+Сұхбат алушы: [Қосымша сұрақты осында енгізіңіз]
+
+Ақпарат беруші (INT-01): [Қосымша жауапты осында енгізіңіз]
+
+--------------------------------------------------
+
+[Сұхбат нөмірі]: INT-02
+[Ақпарат берушінің рөлі]: Scrum-мастер
+[Сұхбат күні]: 2026-03-15
+[Ұзақтығы]: 60 минут
+
+Сұхбат алушы: [Сұрақты осында енгізіңіз]
+
+Ақпарат беруші (INT-02): [Жауапты осында енгізіңіз]""",
+}
+
+REFERENCE_HEADINGS = {
+    "zh": "参考文献",
+    "en": "参考文献",
+    "ru": "Список литературы",
+    "kk": "Пайдаланылған әдебиеттер",
+}
+
+
+TEXTS: dict[str, dict[str, str]] = {
+    "zh": {
+        "title": "📊 工商管理论文智能体",
+        "topic_label": "📝 论文名称",
+        "keywords_label": "🔍 关键字",
+        "words_label": "📏 目标总单词数（12000–25000单词）",
+        "success": "🎉 流水线推演完毕！双语文档已就绪。",
+        "download": "📥 下载文件",
+        "system_busy_title": "⏳ 系统忙碌",
+        "system_busy_warning": "🚨 有用户正在生成论文",
+        "system_busy_info": "💡 预计25–35分钟后可正常使用",
+        "checkpoint_warning": "⚠️ 系统检测到上次因网络或意外中断的未完成论文任务。",
+        "resume": "🔄 恢复断点续传",
+        "clear": "🗑️ 清除临时数据",
+        "busy_short": "⏳ 有用户正在生成论文，预计25–35分钟后可用。",
+        "tab_amj": "✨ 定量研究（AMJ 引擎）",
+        "tab_asq": "📝 定性研究（ASQ 引擎）",
+        "amj_config": "### 📊 定量研究配置（Academy of Management Journal Style）",
+        "amj_info": "💡 该模式聚焦理论演绎、假设检验与因果推断。结构锁定为：引言、理论与假设、方法、结果、讨论、结论。",
+        "upload_reference": "1. 上传核心参考论文（可选，仅限PDF/DOCX，建议1–20篇）",
+        "upload_stats": "2. 上传统计结果表（可选，仅限Excel/CSV）",
+        "amj_expander": "💡 不知道怎么整理数据？点击查看并下载：定量数据（CSV）标准模板",
+        "amj_hint": "**⚠️ 核心提示**：请上传**统计结果表**（如信效度、相关系数、路径系数），**请勿**上传成千上万行的原始问卷明细，以免触发系统防超载截断。",
+        "download_amj_template": "📥 一键下载 CSV 数据模板",
+        "start_amj": "🚀 启动 AMJ 模式生成",
+        "asq_config": "### 📝 定性研究配置（Administrative Science Quarterly Style）",
+        "asq_info": "💡 该模式聚焦现象发现、意义建构与扎根理论（Gioia方法）。结构锁定为：引言、理论框架、研究情境与方法、发现（厚数据叙事）、讨论、结论、附录（证据表）。",
+        "upload_interviews": "2. 上传真实访谈/田野资料（可选，仅限TXT/PDF/DOCX）",
+        "asq_expander": "💡 不知道怎么整理访谈？点击查看并下载：定性访谈记录（TXT）标准模板",
+        "asq_hint": "**⚠️ 核心提示**：为了让AI准确提取语录和编码树，请务必标注**受访者角色（Role）**，并采用清晰的**对话格式**。",
+        "download_asq_template": "📥 一键下载 TXT 访谈模板",
+        "start_asq": "🚀 ��动 ASQ 模式生成",
+        "api_key_missing": "❌ 缺少 DEEPSEEK_API_KEY，请配置API密钥。",
+        "resume_toast": "🔄 检测到页面刷新或网络抖动，系统正在自动恢复进度……",
+        "pipeline_start": "⏳ 流水线启动……",
+        "resume_loading": "🔄 正在从本地安全快照恢复状态……",
+        "resume_success": "✅ 断点加载成功！将从节点 {done}/{total} 安全恢复。",
+        "resume_phase": "断点恢复",
+        "state_check": "状态校验",
+        "history_restored": "✅ 已找回历史算力消耗数据",
+        "extract_quant": "⚙️ 正在解析定量实证数据……",
+        "literature_extract": "🧠 正在从文献中提取核心数据并构建RAG索引……",
+        "literature_deep": "**深度文献提炼中，请勿关闭页面**",
+        "literature_done": "✅ 核心文献特征提炼完成！",
+        "config_route": "🕵️ 引擎配置与范式路由……",
+        "literature_search": "📚 智能文献检索……",
+        "search_phase": "文献检索",
+        "search_detail": "深度并发检索中……",
+        "refs_insufficient": "🚨 终止生成：仅整合到 {count} 篇有效文献，未达到 {required} 篇最低要求。",
+        "refs_success": "✅ 文献扩容成功！已获取 {count} 篇有效文献。",
+        "rag_sync": "🧠 正在将API扩容文献同步注入RAG引擎……",
+        "rag_done": "✅ 扩容文献已完成向量化并注入RAG引擎。",
+        "core_refs_done": "✅ 核心参考论文引文已注入最高优先级。",
+        "synthesis_progress": "🧠 文献综合……",
+        "synthesis_status": "🧠 正在综合核心文献并识别研究空白……",
+        "synthesis_done": "✅ 文献综合完成！",
+        "anchor_progress": "⚓ 生成锚点……",
+        "anchor_status": "⚓ 正在推演核心摘要与结论锚点，请耐心等待……",
+        "anchor_done": "✅ 锚点推演完成！",
+        "outline_progress": "📝 大纲设计与路由分发……",
+        "jit_status": "🔄 正在为方法与结果章节预加载专属文献……",
+        "jit_done": "✅ 方法论预加载完成，已注入向量库。",
+        "english_draft": "#### 🇬🇧 英文证据母稿",
+        "target_draft": "#### {flag} 中文论文",
+        "restored": "✅ 已从快照安全恢复",
+        "waiting": "⏳ 等待执行……",
+        "translation_waiting": "⏳ 等待后台异步翻译……",
+        "sync_previous": "⏳ 正在同步保存上一节【{name}】的翻译状态……",
+        "engine_amj": "📊 AMJ 定量引擎",
+        "engine_asq": "📝 ASQ 定性引擎",
+        "drafting_phase": "英文撰写（{current}/{total}）",
+        "target_words": "目标：{words}（{engine}）",
+        "draft_status": "🤖 引擎启动：正在撰写【{name}】……",
+        "api_requested": "📡 已发起 DeepSeek API 请求……",
+        "model_writing": "✍️ 当前节点使用 {model} 执笔……",
+        "draft_done": "✅ 【{name}】撰写完毕！",
+        "word_count": "📊 本章节实际字数：{actual}（目标：{target}），累计偏差：{deviation:+d}",
+        "translation_running": "⏳ 英文已完成，正在后台异步翻译……",
+        "node_error": "🚨 节点异常已中止。",
+        "node_error_detail": "错误代码：{code}｜{error}｜系统已保存断点，可继续恢复。",
+        "task_cancelled": "任务已取消，断点和临时文件已删除。",
+        "task_start_failed": "无法启动论文任务：{error}",
+        "task_recover_failed": "无法恢复上次任务：{error}",
+        "search_source_warning": "{source}检索异常：{error}",
+        "source_metric_summary": "请求{request}·成功{success}·返回{raw}·新增{unique}·重复{duplicate}·错误{errors}",
+        "sync_last": "⏳ 正在同步保存最后一节【{name}】的翻译状态……",
+        "pack_docx": "📦 正在打包DOCX……",
+        "total_words": "📊 全文总字数：{actual}（目标区间：{lower}–{upper}）",
+        "complete": "✅ 完成",
+        "document_generated": "文档已生成",
+        "startup_error": "🚨 启动或恢复异常：{error}",
+        "translation_error": "🚨 后台翻译异常",
+        "monitor_pipeline": "🔄 流水线进度",
+        "monitor_node": "📍 当前节点",
+        "monitor_log": "📝 动作日志",
+        "monitor_compute": "📡 三维算力消耗监控",
+        "actual_stats_parsed": "✅ 已成功解析用户上传的实证数据。",
+        "synthetic_stats_generated": "⚙️ 未上传统计结果，系统已生成可用于论文结构与结果写作的统计数据。",
+        "qualitative_ready": "✅ 定性材料已准备完成。",
+        "core_literature_parsing": "🧠 正在深度解析用户上传的核心文献……",
+        "section_complete_progress": "🇬🇧 【{name}】英文完成，翻译任务已进入后台。",
+        "login_title": "SmartPaper 登录",
+        "service_description": "提供中文、英语、俄语、哈萨克语四种语言服务。",
+        "secure_login_notice": "安全登录仅支持支付宝 App 扫码。登录后系统对数据加密，保护您的隐私。",
+        "secure_login_title": "支付宝安全登录",
+        "secure_login_instructions": "",
+        "secure_login_privacy": "安全登录后，系统会对数据加密，保护您的隐私。",
+        "secure_login_alipay_only": "安全登录仅支持支付宝 App 扫码。",
+        "secure_login_open_current_device": "在当前设备打开支付宝授权",
+        "login_qr_fixed_notice": "专属登录二维码在有效期内保持不变；系统只检查登录状态，不会动态更换二维码。",
+        "login_info": "扫码即可安全登录。授权成功后，系统会自动进入论文写作界面。",
+        "login_creating": "正在创建安全登录请求……",
+        "login_create_error": "无法创建登录请求：{error}",
+        "login_service_timeout": "登录服务响应较慢，请稍后重试。",
+        "login_service_connection_error": "暂时无法连接登录服务，请检查网络后重试。",
+        "login_reconnect": "重新连接登录服务",
+        "login_open": "打开支付宝扫码登录",
+        "login_caption": "请在新页面使用手机支付宝扫码并确认授权。授权完成后，SmartPaper 将自动进入论文写作界面。",
+        "login_auto_waiting": "正在等待支付宝授权。确认授权后将自动进入论文写作界面。",
+        "login_auto_network_wait": "登录服务暂时繁忙，系统正在自动重试：{error}",
+        "login_auto_success": "登录成功，正在进入论文写作界面……",
+        "login_auto_failed": "自动登录未完成：{error}",
+        "login_auto_timeout": "本次登录请求已超时，请重新生成登录请求。",
+        "login_check": "我已完成扫码，检查登录",
+        "login_checking": "正在确认登录状态……",
+        "login_check_error": "登录检查失败：{error}",
+        "login_regenerate": "重新生成登录请求",
+        "login_pending": "支付宝授权尚未完成，请扫码并确认授权。",
+        "account_title": "用户账户",
+        "account_id": "用户编号：**{value}**",
+        "daily_free": "每日免费：**{value}篇**",
+        "bonus_papers": "长期有效额度：**{value}篇**",
+        "account_chip_user": "用户 {value}",
+        "account_chip_free": "免费 {value}篇",
+        "account_chip_bonus": "长期 {value}篇",
+        "logout_short": "退出",
+        "payment_dialog_title": "支付宝付款",
+        "payment_notice": "今日免费额度和长期额度均已用完。支付9.9元可增加3篇长期有效额度。",
+        "quota_exhausted": "今日免费额度和长期额度均已用完。请使用支付宝购买长期额度。",
+        "payment_create": "生成支付宝付款二维码",
+        "payment_creating": "正在创建支付宝订单……",
+        "payment_scan": "请使用支付宝 App 扫码支付。支付成功后点击“查询支付结果”。",
+        "payment_check": "查询支付结果",
+        "payment_paid": "支付成功，已增加3篇长期有效额度。请重新点击生成论文。",
+        "payment_expired": "付款二维码已过期，请重新生成。",
+        "browse_files": "选择文件",
+        "drop_docs": "将文件拖放到此处",
+        "drop_data": "将文件拖放到此处",
+        "drop_interviews": "将文件拖放到此处",
+        "limit_docs": "单个文件上限 1GB · PDF、DOC、DOCX",
+        "limit_data": "单个文件上限 1GB · CSV、XLSX、XLS",
+        "limit_interviews": "单个文件上限 1GB · TXT、PDF、DOC、DOCX",
+        "logout": "退出登录",
+    },
+    "en": {
+        "title": "📊 Business Administration Article Agent",
+        "topic_label": "📝 Article Title",
+        "keywords_label": "🔍 Keywords",
+        "words_label": "📏 Target Word Count (12,000–25,000 words)",
+        "success": "🎉 The pipeline is complete. The bilingual documents are ready.",
+        "download": "📥 Download Files",
+        "system_busy_title": "⏳ System Busy",
+        "system_busy_warning": "🚨 Another user is generating a paper",
+        "system_busy_info": "💡 The system is expected to be available in 25–35 minutes",
+        "checkpoint_warning": "⚠️ An unfinished paper task from a network or unexpected interruption was detected.",
+        "resume": "🔄 Resume from Checkpoint",
+        "clear": "🗑️ Clear Temporary Data",
+        "busy_short": "⏳ Another user is generating a paper. Please try again in about 25–35 minutes.",
+        "tab_amj": "✨ Quantitative Research (AMJ Engine)",
+        "tab_asq": "📝 Qualitative Research (ASQ Engine)",
+        "amj_config": "### 📊 Quantitative Research Configuration (Academy of Management Journal Style)",
+        "amj_info": "💡 This mode focuses on theoretical deduction, hypothesis testing, and causal inference. The structure is fixed as Introduction, Theory and Hypotheses, Method, Results, Discussion, and Conclusion.",
+        "upload_reference": "1. Upload Core Reference Papers (optional; PDF/DOCX only; 1–20 papers recommended)",
+        "upload_stats": "2. Upload Statistical Results Tables (optional; Excel/CSV only)",
+        "amj_expander": "💡 Need help organizing data? View and download the standard quantitative-data CSV template",
+        "amj_hint": "**⚠️ Important**: Upload **statistical results tables** such as reliability, validity, correlations, and path coefficients. Do **not** upload thousands of raw questionnaire rows, which may trigger overload protection.",
+        "download_amj_template": "📥 Download CSV Data Template",
+        "start_amj": "🚀 Start AMJ Generation",
+        "asq_config": "### 📝 Qualitative Research Configuration (Administrative Science Quarterly Style)",
+        "asq_info": "💡 This mode focuses on phenomenon discovery, sensemaking, and grounded theorizing using the Gioia approach. The structure is fixed as Introduction, Theoretical Framing, Research Setting and Methods, Findings, Discussion, Conclusion, and Evidence Appendix.",
+        "upload_interviews": "2. Upload Actual Interview or Field Materials (optional; TXT/PDF/DOCX only)",
+        "asq_expander": "💡 Need help organizing interviews? View and download the standard TXT interview template",
+        "asq_hint": "**⚠️ Important**: Clearly label each **informant role** and use a consistent **dialogue format** so the system can accurately extract quotations and build the coding structure.",
+        "download_asq_template": "📥 Download TXT Interview Template",
+        "start_asq": "🚀 Start ASQ Generation",
+        "api_key_missing": "❌ DEEPSEEK_API_KEY is missing. Configure the API key.",
+        "resume_toast": "🔄 A page refresh or network interruption was detected. Progress is being restored automatically…",
+        "pipeline_start": "⏳ Starting the pipeline…",
+        "resume_loading": "🔄 Restoring the secure local checkpoint…",
+        "resume_success": "✅ Checkpoint restored. Work will resume from node {done}/{total}.",
+        "resume_phase": "Checkpoint recovery",
+        "state_check": "State validation",
+        "history_restored": "✅ Previous compute-usage data restored",
+        "extract_quant": "⚙️ Parsing quantitative results…",
+        "literature_extract": "🧠 Extracting core information and building the RAG index…",
+        "literature_deep": "**Deep literature extraction in progress. Do not close this page**",
+        "literature_done": "✅ Core literature features extracted.",
+        "config_route": "🕵️ Configuring the engine and research paradigm…",
+        "literature_search": "📚 Searching the academic literature…",
+        "search_phase": "Literature search",
+        "search_detail": "Running concurrent searches…",
+        "refs_insufficient": "🚨 Generation stopped: only {count} valid references were integrated; at least {required} are required.",
+        "refs_success": "✅ Literature expansion complete: {count} valid references obtained.",
+        "rag_sync": "🧠 Adding the expanded literature to the RAG engine…",
+        "rag_done": "✅ Expanded literature vectorized and added to the RAG engine.",
+        "core_refs_done": "✅ Core user-provided references assigned highest priority.",
+        "synthesis_progress": "🧠 Synthesizing the literature…",
+        "synthesis_status": "🧠 Synthesizing the literature and identifying the research gap…",
+        "synthesis_done": "✅ Literature synthesis complete.",
+        "anchor_progress": "⚓ Generating anchors…",
+        "anchor_status": "⚓ Developing the abstract and conclusion anchors. Please wait…",
+        "anchor_done": "✅ Anchor development complete.",
+        "outline_progress": "📝 Designing the outline and routing sections…",
+        "jit_status": "🔄 Preloading literature for the Method and Results sections…",
+        "jit_done": "✅ Method literature preloaded and added to the vector store.",
+        "english_draft": "#### 🇬🇧 English Evidence Draft",
+        "target_draft": "#### {flag} Chinese Paper",
+        "restored": "✅ Restored from checkpoint",
+        "waiting": "⏳ Waiting…",
+        "translation_waiting": "⏳ Waiting for background translation…",
+        "sync_previous": "⏳ Saving the translation state for the previous section, 【{name}】…",
+        "engine_amj": "📊 AMJ Quantitative Engine",
+        "engine_asq": "📝 ASQ Qualitative Engine",
+        "drafting_phase": "English drafting ({current}/{total})",
+        "target_words": "Target: {words} words ({engine})",
+        "draft_status": "🤖 Drafting 【{name}】…",
+        "api_requested": "📡 DeepSeek API request submitted…",
+        "model_writing": "✍️ Writing this node with {model}…",
+        "draft_done": "✅ 【{name}】 completed.",
+        "word_count": "📊 Section word count: {actual} (target: {target}); cumulative deviation: {deviation:+d}",
+        "translation_running": "⏳ English draft complete. Background translation is running…",
+        "node_error": "🚨 The node stopped because of an error.",
+        "node_error_detail": "Error code: {code} | {error} | A checkpoint has been saved and can be resumed.",
+        "task_cancelled": "The task was cancelled. Its checkpoint and temporary files were deleted.",
+        "task_start_failed": "The paper task could not be started: {error}",
+        "task_recover_failed": "The previous task could not be recovered: {error}",
+        "search_source_warning": "{source} search error: {error}",
+        "source_metric_summary": "Req {request} · OK {success} · Raw {raw} · New {unique} · Dup {duplicate} · Err {errors}",
+        "sync_last": "⏳ Saving the translation state for the final section, 【{name}】…",
+        "pack_docx": "📦 Packaging DOCX files…",
+        "total_words": "📊 Total English word count: {actual} (target range: {lower}–{upper})",
+        "complete": "✅ Complete",
+        "document_generated": "Documents generated",
+        "startup_error": "🚨 Startup or recovery error: {error}",
+        "translation_error": "🚨 Background translation error",
+        "monitor_pipeline": "🔄 Pipeline progress",
+        "monitor_node": "📍 Current node",
+        "monitor_log": "📝 Activity log",
+        "monitor_compute": "📡 Compute-usage monitor",
+        "actual_stats_parsed": "✅ The uploaded empirical results were parsed successfully.",
+        "synthetic_stats_generated": "⚙️ No statistical results were uploaded. The system generated statistical data for the paper structure and Results section.",
+        "qualitative_ready": "✅ Qualitative materials are ready.",
+        "core_literature_parsing": "🧠 Parsing the uploaded core literature in depth…",
+        "section_complete_progress": "🇬🇧 English section 【{name}】 complete; translation is running in the background.",
+        "login_title": "Sign in to SmartPaper",
+        "service_description": "Services are available in Chinese, English, Russian, and Kazakh.",
+        "secure_login_notice": "Secure sign-in supports the Alipay app only. After sign-in, the system encrypts data to protect your privacy.",
+        "secure_login_title": "Secure Sign-in with Alipay",
+        "secure_login_instructions": "",
+        "secure_login_privacy": "After secure sign-in, the system encrypts your data to protect your privacy.",
+        "secure_login_alipay_only": "Secure sign-in supports the Alipay app only.",
+        "secure_login_open_current_device": "Open Alipay authorization on this device",
+        "login_qr_fixed_notice": "The secure sign-in QR code remains unchanged while valid. SmartPaper checks only the sign-in status and does not replace the QR code dynamically.",
+        "login_info": "Scan to sign in securely. SmartPaper will open the writing interface automatically after authorization.",
+        "login_creating": "Creating a secure sign-in request…",
+        "login_create_error": "Unable to create the sign-in request: {error}",
+        "login_service_timeout": "The sign-in service is taking longer than expected. Please try again.",
+        "login_service_connection_error": "The sign-in service is temporarily unavailable. Check your connection and try again.",
+        "login_reconnect": "Reconnect to Sign-in Service",
+        "login_open": "Open Alipay QR Sign-in",
+        "login_caption": "Use Alipay on your phone to scan and authorize on the new page. SmartPaper will open the writing interface automatically after authorization.",
+        "login_auto_waiting": "Waiting for Alipay authorization. The writing interface will open automatically.",
+        "login_auto_network_wait": "The sign-in service is temporarily busy. Retrying automatically: {error}",
+        "login_auto_success": "Signed in. Opening the paper-writing interface…",
+        "login_auto_failed": "Automatic sign-in was not completed: {error}",
+        "login_auto_timeout": "This sign-in request has expired. Create a new request.",
+        "login_check": "I Have Authorized — Check Sign-in",
+        "login_checking": "Checking sign-in status…",
+        "login_check_error": "Sign-in check failed: {error}",
+        "login_regenerate": "Generate a New Sign-in Request",
+        "login_pending": "Alipay authorization is still pending. Scan the code and confirm authorization.",
+        "account_title": "User Account",
+        "account_id": "User ID: **{value}**",
+        "daily_free": "Daily free allowance: **{value} papers**",
+        "bonus_papers": "Long-term allowance: **{value} papers**",
+        "account_chip_user": "User {value}",
+        "account_chip_free": "Free {value}",
+        "account_chip_bonus": "Bonus {value}",
+        "logout_short": "Sign out",
+        "payment_dialog_title": "Alipay Payment",
+        "payment_notice": "Your daily free quota and long-term quota are exhausted. Pay CNY 9.9 to add three long-term papers.",
+        "quota_exhausted": "Your daily free quota and long-term quota are exhausted. Purchase long-term quota with Alipay.",
+        "payment_create": "Create Alipay QR code",
+        "payment_creating": "Creating the Alipay order…",
+        "payment_scan": "Scan the code with the Alipay app. After payment, select “Check payment result.”",
+        "payment_check": "Check payment result",
+        "payment_paid": "Payment succeeded. Three long-term papers were added. Start the paper again.",
+        "payment_expired": "The payment QR code has expired. Create a new one.",
+        "browse_files": "Choose files",
+        "drop_docs": "Drag and drop files here",
+        "drop_data": "Drag and drop files here",
+        "drop_interviews": "Drag and drop files here",
+        "limit_docs": "Limit 1 GB per file · PDF, DOC, DOCX",
+        "limit_data": "Limit 1 GB per file · CSV, XLSX, XLS",
+        "limit_interviews": "Limit 1 GB per file · TXT, PDF, DOC, DOCX",
+        "logout": "Sign Out",
+    },
+    "ru": {
+        "title": "📊 Интеллектуальный агент для научных статей по управлению бизнесом",
+        "topic_label": "📝 Название статьи",
+        "keywords_label": "🔍 Ключевые слова",
+        "words_label": "📏 Целевой объём (12 000–25 000 слов)",
+        "success": "🎉 Работа конвейера завершена. Двуязычные документы готовы.",
+        "download": "📥 Скачать файлы",
+        "system_busy_title": "⏳ Система занята",
+        "system_busy_warning": "🚨 Другой пользователь формирует статью",
+        "system_busy_info": "💡 Ожидаемое время доступности — через 25–35 минут",
+        "checkpoint_warning": "⚠️ Обнаружена незавершённая задача, прерванная из-за сети или другой ошибки.",
+        "resume": "🔄 Продолжить с контрольной точки",
+        "clear": "🗑️ Удалить временные данные",
+        "busy_short": "⏳ Другой пользователь формирует статью. Повторите попытку примерно через 25–35 минут.",
+        "tab_amj": "✨ Количественное исследование (движок AMJ)",
+        "tab_asq": "📝 Качественное исследование (движок ASQ)",
+        "amj_config": "### 📊 Настройка количественного исследования (стиль Academy of Management Journal)",
+        "amj_info": "💡 Режим ориентирован на теоретическую дедукцию, проверку гипотез и причинно-следственный вывод. Структура фиксирована: введение, теория и гипотезы, метод, результаты, обсуждение и заключение.",
+        "upload_reference": "1. Загрузите основные научные статьи (необязательно; только PDF/DOCX; рекомендуется 1–20 файлов)",
+        "upload_stats": "2. Загрузите таблицы статистических результатов (необязательно; только Excel/CSV)",
+        "amj_expander": "💡 Нужна помощь в подготовке данных? Откройте и скачайте стандартный CSV-шаблон",
+        "amj_hint": "**⚠️ Важно**: загружайте **таблицы статистических результатов** — надёжность, валидность, корреляции и коэффициенты путей. Не загружайте тысячи строк исходных анкет, чтобы не сработала защита от перегрузки.",
+        "download_amj_template": "📥 Скачать CSV-шаблон данных",
+        "start_amj": "🚀 Запустить формирование в режиме AMJ",
+        "asq_config": "### 📝 Настройка качественного исследования (стиль Administrative Science Quarterly)",
+        "asq_info": "💡 Режим ориентирован на выявление феномена, смыслообразование и построение обоснованной теории по подходу Джойя. Структура фиксирована: введение, теоретическая рамка, контекст и методы, результаты, обсуждение, заключение и приложение с доказательствами.",
+        "upload_interviews": "2. Загрузите реальные интервью или полевые материалы (необязател��но; только TXT/PDF/DOCX)",
+        "asq_expander": "💡 Нужна помощь в подготовке интервью? Откройте и скачайте стандартный TXT-шаблон",
+        "asq_hint": "**⚠️ Важно**: укажите **роль информанта** и соблюдайте единый **формат диалога**, чтобы система точно извлекала цитаты и строила структуру кодирования.",
+        "download_asq_template": "📥 Скачать TXT-шаблон интервью",
+        "start_asq": "🚀 Запустить формирование в режиме ASQ",
+        "api_key_missing": "❌ Не задан DEEPSEEK_API_KEY. Настройте ключ API.",
+        "resume_toast": "🔄 Обнаружено обновление страницы или нарушение соединения. Выполняется автоматическое восстановление…",
+        "pipeline_start": "⏳ Запуск конвейера…",
+        "resume_loading": "🔄 Восстановление защищённой локальной контрольной точки…",
+        "resume_success": "✅ Контрольная точка восстановлена. Работа продолжится с узла {done}/{total}.",
+        "resume_phase": "Восстановление",
+        "state_check": "Проверка состояния",
+        "history_restored": "✅ История вычислительных затрат восстановлена",
+        "extract_quant": "⚙️ Обработка количественных результатов…",
+        "literature_extract": "🧠 Извлечение основных сведений и построение индекса RAG…",
+        "literature_deep": "**Выполняется углублённая обработка литературы. Не закрывайте страницу**",
+        "literature_done": "✅ Основные характеристики литературы извлечены.",
+        "config_route": "🕵️ Настройка движка и исследовательской парадигмы…",
+        "literature_search": "📚 Поиск научной литературы…",
+        "search_phase": "Поиск литературы",
+        "search_detail": "Выполняется параллельный поиск…",
+        "refs_insufficient": "🚨 Формирование остановлено: интегрировано только {count} источников; требуется не менее {required}.",
+        "refs_success": "✅ Расширение литературы завершено: получено {count} источников.",
+        "rag_sync": "🧠 Добавление расширенного корпуса литературы в RAG…",
+        "rag_done": "✅ Литература векторизована и добавлена в RAG.",
+        "core_refs_done": "✅ Пользовательским основным источникам назначен высший приоритет.",
+        "synthesis_progress": "🧠 Синтез литературы…",
+        "synthesis_status": "🧠 Синтез литературы и выявление исследовательского пробела…",
+        "synthesis_done": "✅ Синтез литературы завершён.",
+        "anchor_progress": "⚓ Формирование опорных элементов…",
+        "anchor_status": "⚓ Формирование опорных элементов аннотации и заключения. Подождите…",
+        "anchor_done": "✅ Опорные элементы сформированы.",
+        "outline_progress": "📝 Проектирование структуры и распределение разделов…",
+        "jit_status": "🔄 Предварительная загрузка литературы для разделов методов и результатов…",
+        "jit_done": "✅ Методическая литература загружена в векторное хранилище.",
+        "english_draft": "#### 🇬🇧 Английский доказательный черновик",
+        "target_draft": "#### {flag} Русская версия статьи",
+        "restored": "✅ Восстановлено из контрольной точки",
+        "waiting": "⏳ Ожидание выполнения…",
+        "translation_waiting": "⏳ Ожидание фонового перевода…",
+        "sync_previous": "⏳ Сохранение перевода предыдущего раздела 【{name}】…",
+        "engine_amj": "📊 Количественный движок AMJ",
+        "engine_asq": "📝 Качественный движок ASQ",
+        "drafting_phase": "Подготовка английского текста ({current}/{total})",
+        "target_words": "Цель: {words} слов ({engine})",
+        "draft_status": "🤖 Подготовка раздела 【{name}】…",
+        "api_requested": "📡 Запрос к DeepSeek API отправлен…",
+        "model_writing": "✍️ Раздел формируется моделью {model}…",
+        "draft_done": "✅ Раздел 【{name}】 завершён.",
+        "word_count": "📊 Объём раздела: {actual} слов (цель: {target}); накопленное отклонение: {deviation:+d}",
+        "translation_running": "⏳ Английский текст завершён. Выполняется фоновый перевод…",
+        "node_error": "🚨 Выполнение узла остановлено из-за ошибки.",
+        "node_error_detail": "Код ошибки: {code} | {error} | Контрольная точка сохранена; работу можно продолжить.",
+        "task_cancelled": "Задача отменена. Контрольная точка и временные файлы удалены.",
+        "task_start_failed": "Не удалось запустить подготовку статьи: {error}",
+        "task_recover_failed": "Не удалось восстановить предыдущую задачу: {error}",
+        "search_source_warning": "Ошибка поиска {source}: {error}",
+        "source_metric_summary": "Запр. {request} · Усп. {success} · Получ. {raw} · Нов. {unique} · Дуб. {duplicate} · Ош. {errors}",
+        "sync_last": "⏳ Сохранение перевода последнего раздела 【{name}】…",
+        "pack_docx": "📦 Упаковка файлов DOCX…",
+        "total_words": "📊 Общий объём английского текста: {actual} слов (целевой диапазон: {lower}–{upper})",
+        "complete": "✅ Завершено",
+        "document_generated": "Документы сформированы",
+        "startup_error": "🚨 Ошибка запуска или восстановления: {error}",
+        "translation_error": "🚨 Ошибка фонового перевода",
+        "monitor_pipeline": "🔄 Ход конвейера",
+        "monitor_node": "📍 Текущий узел",
+        "monitor_log": "📝 Журнал действий",
+        "monitor_compute": "📡 Монитор вычислительных затрат",
+        "actual_stats_parsed": "✅ Загруженные эмпирические результаты успешно обработаны.",
+        "synthetic_stats_generated": "⚙️ Статистические результаты не загружены. Система сформировала статистические данные для структуры статьи и раздела результатов.",
+        "qualitative_ready": "✅ Качественные материалы подготовлены.",
+        "core_literature_parsing": "🧠 Выполняется углублённая обработка загруженной основной литературы…",
+        "section_complete_progress": "🇬🇧 Английский раздел 【{name}】 завершён; перевод выполняется в фоне.",
+        "login_title": "Вход в SmartPaper",
+        "service_description": "Услуги доступны на китайском, английском, русском и казахском языках.",
+        "secure_login_notice": "Безопасный вход поддерживается только в приложении Alipay. После входа система шифрует данные для защиты вашей конфиденциальности.",
+        "secure_login_title": "Безопасный вход через Alipay",
+        "secure_login_instructions": "",
+        "secure_login_privacy": "После безопасного входа система шифрует данные для защиты вашей конфиденциальности.",
+        "secure_login_alipay_only": "Безопасный вход поддерживается только приложением Alipay.",
+        "secure_login_open_current_device": "Открыть авторизацию Alipay на этом устройстве",
+        "login_qr_fixed_notice": "QR-код входа не меняется в течение срока действия. Система проверяет только статус входа.",
+        "login_info": "Вы можете бесплатно создавать до 3 статей в день.",
+        "login_creating": "Создание защищённого запроса на вход…",
+        "login_create_error": "Не удалось создать запрос на вход: {error}",
+        "login_service_timeout": "Сервис входа отвечает медленнее обычного. Пожалуйста, попробуйте ещё раз.",
+        "login_service_connection_error": "Сервис входа временно недоступен. Проверьте подключение и повторите попытку.",
+        "login_reconnect": "Повторно подключиться к сервису входа",
+        "login_open": "Открыть вход по QR-коду Alipay",
+        "login_caption": "На новой странице отсканируйте QR-код приложением Alipay и подтвердите авторизацию. После этого SmartPaper автоматически откроет интерфейс подготовки статьи.",
+        "login_auto_waiting": "Ожидается подтверждение в Alipay. После авторизации интерфейс подготовки статьи откроется автоматически.",
+        "login_auto_network_wait": "Сервис входа временно занят. Выполняется автоматическая повторная попытка: {error}",
+        "login_auto_success": "Вход выполнен. Открывается интерфейс подготовки статьи…",
+        "login_auto_failed": "Автоматический вход не завершён: {error}",
+        "login_auto_timeout": "Срок действия запроса на вход истёк. Создайте новый запрос.",
+        "login_check": "Авторизация выполнена — проверить вход",
+        "login_checking": "Проверка статуса входа…",
+        "login_check_error": "Ошибка проверки входа: {error}",
+        "login_regenerate": "Создать новый запрос на вход",
+        "login_pending": "Авторизация Alipay ещё не завершена. Отсканируйте код и подтвердите доступ.",
+        "account_title": "Учётная запись",
+        "account_id": "Идентификатор пользователя: **{value}**",
+        "daily_free": "Ежедневно бесплатно: **{value} статьи**",
+        "bonus_papers": "Долгосрочный остаток: **{value} статьи**",
+        "account_chip_user": "Пользователь {value}",
+        "account_chip_free": "Бесплатно {value}",
+        "account_chip_bonus": "Запас {value}",
+        "logout_short": "Выйти",
+        "payment_dialog_title": "Оплата через Alipay",
+        "payment_notice": "Ежедневная бесплатная и долгосрочная квоты исчерпаны. Оплата 9,9 юаня добавляет квоту на три статьи без срока действия.",
+        "quota_exhausted": "Ежедневная бесплатная и долгосрочная квоты исчерпаны. Приобретите долгосрочную квоту через Alipay.",
+        "payment_create": "Создать QR-код для оплаты",
+        "payment_creating": "Создаётся заказ Alipay…",
+        "payment_scan": "Отсканируйте QR-код в приложении Alipay. После оплаты нажмите «Проверить результат оплаты».",
+        "payment_check": "Проверить результат оплаты",
+        "payment_paid": "Оплата прошла успешно. Добавлена долгосрочная квота на три статьи. Запустите создание статьи повторно.",
+        "payment_expired": "Срок действия QR-кода истёк. Создайте новый код.",
+        "browse_files": "Выбрать файлы",
+        "drop_docs": "Перетащите файлы сюда",
+        "drop_data": "Перетащите файлы сюда",
+        "drop_interviews": "Перетащите файлы сюда",
+        "limit_docs": "До 1 ГБ на файл · PDF, DOC, DOCX",
+        "limit_data": "До 1 ГБ на файл · CSV, XLSX, XLS",
+        "limit_interviews": "До 1 ГБ на файл · TXT, PDF, DOC, DOCX",
+        "logout": "Выйти",
+    },
+    "kk": {
+        "title": "📊 Бизнес-басқару жөніндегі ғылыми мақала интеллектуалды агенті",
+        "topic_label": "📝 Мақала атауы",
+        "keywords_label": "🔍 Түйін сөздер",
+        "words_label": "📏 Мақсатты көлем (12 000–25 000 сөз)",
+        "success": "🎉 Жұмыс үдерісі аяқталды. Екі тілдегі құжаттар дайын.",
+        "download": "📥 Файлдарды жүктеу",
+        "system_busy_title": "⏳ Жүйе бос емес",
+        "system_busy_warning": "🚨 Басқа пайд��ланушы мақала дайындап жатыр",
+        "system_busy_info": "💡 Жүйе шамамен 25–35 минуттан кейін қолжетімді болады",
+        "checkpoint_warning": "⚠️ Желі немесе күтпеген үзіліс салдарынан аяқталмаған тапсырма анықталды.",
+        "resume": "🔄 Бақылау нүктесінен жалғастыру",
+        "clear": "🗑️ Уақытша деректерді тазалау",
+        "busy_short": "⏳ Басқа пайдаланушы мақала дайындап жатыр. Шамамен 25–35 минуттан кейін қайталап көріңіз.",
+        "tab_amj": "✨ Сандық зерттеу (AMJ қозғалтқышы)",
+        "tab_asq": "📝 Сапалық зерттеу (ASQ қозғалтқышы)",
+        "amj_config": "### 📊 Сандық зерттеу параметрлері (Academy of Management Journal стилі)",
+        "amj_info": "💡 Бұл режим теориялық дедукцияға, гипотезаларды тексеруге және себеп-салдарлық қорытындыға бағытталған. Құрылымы: кіріспе, теория мен гипотезалар, әдіс, нәтижелер, талқылау және қорытынды.",
+        "upload_reference": "1. Негізгі ғылыми мақалаларды жүктеңіз (міндетті емес; тек PDF/DOCX; 1–20 файл ұсынылады)",
+        "upload_stats": "2. Статистикалық нәтижелер кестесін жүктеңіз (міндетті емес; тек Excel/CSV)",
+        "amj_expander": "💡 Деректерді дайындау керек пе? Сандық деректерге арналған стандартты CSV үлгісін ашып, жүктеңіз",
+        "amj_hint": "**⚠️ Маңызды**: сенімділік, валидтілік, корреляциялар және жол коэффициенттері сияқты **статистикалық нәтижелер кестесін** жүктеңіз. Артық жүктемеден қорғау іске қосылмауы үшін сауалнаманың мыңдаған бастапқы жолдарын жүктемеңіз.",
+        "download_amj_template": "📥 CSV деректер үлгісін жүктеу",
+        "start_amj": "🚀 AMJ режимінде дайындауды бастау",
+        "asq_config": "### 📝 Сапалық зерттеу параметрлері (Administrative Science Quarterly стилі)",
+        "asq_info": "💡 Бұл режим құбылысты анықтауға, мағына қалыптастыруға және Gioia тәсілі бойынша негізделген теория құруға бағытталған. Құрылымы: кіріспе, теориялық негіз, зерттеу ортасы мен әдістері, нәтижелер, талқылау, қорытынды және дәлелдер қосымшасы.",
+        "upload_interviews": "2. Нақты сұхбат немесе далалық материалдарды жүктеңіз (міндетті емес; тек TXT/PDF/DOCX)",
+        "asq_expander": "💡 Сұхбаттарды дайындау керек пе? Стандартты TXT сұхбат үлгісін ашып, жүктеңіз",
+        "asq_hint": "**⚠️ Маңызды**: жүйе дәйексөздерді дәл шығарып, кодтау құрылымын құруы үшін **ақпарат берушінің рөлін** көрсетіп, бірізді **диалог пішімін** қолданыңыз.",
+        "download_asq_template": "📥 TXT сұхбат үлгісін жүктеу",
+        "start_asq": "🚀 ASQ режимінде дайындауды бастау",
+        "api_key_missing": "❌ DEEPSEEK_API_KEY көрсетілмеген. API кілтін баптаңыз.",
+        "resume_toast": "🔄 Бет жаңартылғаны немесе желі үзілісі анықталды. Үдеріс автоматты түрде қалпына келтірілуде…",
+        "pipeline_start": "⏳ Жұмыс үдерісі басталуда…",
+        "resume_loading": "🔄 Қауіпсіз жергілікті бақылау нүктесі қалпына келтірілуде…",
+        "resume_success": "✅ Бақылау нүктесі қалпына келтірілді. Жұмыс {done}/{total} түйінінен жалғасады.",
+        "resume_phase": "Қалпына келтіру",
+        "state_check": "Күйді тексеру",
+        "history_restored": "✅ Бұрынғы есептеу шығындары қалпына келтірілді",
+        "extract_quant": "⚙️ Сандық нәтижелер өңделуде…",
+        "literature_extract": "🧠 Негізгі мәліметтер шығарылып, RAG индексі құрылуда…",
+        "literature_deep": "**Әдебиеттер терең өңделуде. Бетті жаппаңыз**",
+        "literature_done": "✅ Әдебиеттердің негізгі сипаттары шығарылды.",
+        "config_route": "🕵️ Қозғалтқыш пен зерттеу парадигмасы бапталуда…",
+        "literature_search": "📚 Ғылыми әдебиеттер ізделуде…",
+        "search_phase": "Әдебиет іздеу",
+        "search_detail": "Параллель іздеу орындалуда…",
+        "refs_insufficient": "🚨 Дайындау тоқтатылды: тек {count} жарамды дереккөз біріктірілді; кемінде {required} қажет.",
+        "refs_success": "✅ Әдебиеттерді кеңейту аяқталды: {count} жарамды дереккөз алынды.",
+        "rag_sync": "🧠 Кеңейтілген әдебиеттер RAG қозғалтқышына қосылуда…",
+        "rag_done": "✅ Әдебиеттер векторланып, RAG қозғалтқышына қосылды.",
+        "core_refs_done": "✅ Пайдаланушы ұсынған негізгі дереккөздерге ең жоғары басымдық берілді.",
+        "synthesis_progress": "🧠 Әдебиеттер синтезделуде…",
+        "synthesis_status": "🧠 Әдебиеттер синтезделіп, зерттеу олқылығы анықталуда…",
+        "synthesis_done": "✅ Әдебиеттер синтезі аяқталды.",
+        "anchor_progress": "⚓ Тірек мазмұн құрылуда…",
+        "anchor_status": "⚓ Аннотация мен қорытындының тірек мазмұны әзірленуде. Күте тұрыңыз…",
+        "anchor_done": "✅ Тірек мазмұн әзірленді.",
+        "outline_progress": "📝 Құрылым жобаланып, бөлімдер бөлінуде…",
+        "jit_status": "🔄 Әдіс пен нәтижелер бөлімдеріне арналған әдебиеттер алдын ала жүктелуде…",
+        "jit_done": "✅ Әдістемелік әдебиеттер векторлық қорға қосылды.",
+        "english_draft": "#### 🇬🇧 Ағылшын тіліндегі дәлелдік нұсқа",
+        "target_draft": "#### {flag} Қазақ тіліндегі мақала",
+        "restored": "✅ Бақылау нүктесінен қалпына келтірілді",
+        "waiting": "⏳ Орындалуын күтуде…",
+        "translation_waiting": "⏳ Фондық аударма күтілуде…",
+        "sync_previous": "⏳ Алдыңғы 【{name}】 бөлімінің аудармасы сақталуда…",
+        "engine_amj": "📊 AMJ сандық қозғалтқышы",
+        "engine_asq": "📝 ASQ сапалық қозғалтқышы",
+        "drafting_phase": "Ағылшын мәтінін дайындау ({current}/{total})",
+        "target_words": "Мақсат: {words} сөз ({engine})",
+        "draft_status": "🤖 【{name}】 бөлімі дайындалуда…",
+        "api_requested": "📡 DeepSeek API сұрауы жіберілді…",
+        "model_writing": "✍️ Бұл түйінді {model} моделі жазып жатыр…",
+        "draft_done": "✅ 【{name}】 бөлімі аяқталды.",
+        "word_count": "📊 Бөлім көлемі: {actual} сөз (мақсат: {target}); жиынтық ауытқу: {deviation:+d}",
+        "translation_running": "⏳ Ағылшын мәтіні аяқталды. Фондық аударма орындалуда…",
+        "node_error": "🚨 Қате салдарынан түйін тоқтатылды.",
+        "node_error_detail": "Қате коды: {code} | {error} | Бақылау нүктесі сақталды; жұмысты жалғастыруға болады.",
+        "task_cancelled": "Тапсырма тоқтатылды. Бақылау нүктесі мен уақытша файлдар жойылды.",
+        "task_start_failed": "Мақала тапсырмасын бастау мүмкін болмады: {error}",
+        "task_recover_failed": "Алдыңғы тапсырманы қалпына келтіру мүмкін болмады: {error}",
+        "search_source_warning": "{source} іздеу қатесі: {error}",
+        "source_metric_summary": "Сұрау {request} · Сәтті {success} · Нәтиже {raw} · Жаңа {unique} · Қайтал. {duplicate} · Қате {errors}",
+        "sync_last": "⏳ Соңғы 【{name}】 бөлімінің аудармасы сақталуда…",
+        "pack_docx": "📦 DOCX файлдары қапталуда…",
+        "total_words": "📊 Ағылшын мәтінінің жалпы көлемі: {actual} сөз (мақсатты аралық: {lower}–{upper})",
+        "complete": "✅ Аяқталды",
+        "document_generated": "Құжаттар дайындалды",
+        "startup_error": "🚨 Іске қосу немесе қалпына келтіру қатесі: {error}",
+        "translation_error": "🚨 Фондық аударма қатесі",
+        "monitor_pipeline": "🔄 Жұмыс үдерісі",
+        "monitor_node": "📍 Ағымдағы түйін",
+        "monitor_log": "📝 Әрекеттер журналы",
+        "monitor_compute": "📡 Есептеу шығындарының мониторингі",
+        "actual_stats_parsed": "✅ Жүктелген эмпирикалық нәтижелер сәтті өңделді.",
+        "synthetic_stats_generated": "⚙️ Статистикалық нәтижелер жүктелмеді. Жүйе мақала құрылымы мен нәтижелер бөлімі үшін статистикалық деректер дайындады.",
+        "qualitative_ready": "✅ Сапалық материалдар дайындалды.",
+        "core_literature_parsing": "🧠 Жүктелген негізгі әдебиеттер терең өңделуде…",
+        "section_complete_progress": "🇬🇧 【{name}】 ағылшын бөлімі аяқталды; аударма фондық режимде орындалуда.",
+        "login_title": "SmartPaper жүйесіне кіру",
+        "service_description": "Қызмет қытай, ағылшын, орыс және қазақ тілдерінде қолжетімді.",
+        "secure_login_notice": "Қауіпсіз кіру тек Alipay қолданбасы арқылы жүзеге асырылады. Кіргеннен кейін жүйе құпиялылығыңызды қорғау үшін деректерді шифрлайды.",
+        "secure_login_title": "Alipay арқылы қауіпсіз кіру",
+        "secure_login_instructions": "",
+        "secure_login_privacy": "Қауіпсіз кіргеннен кейін жүйе құпиялылығыңызды қорғау үшін деректерді шифрлайды.",
+        "secure_login_alipay_only": "Қауіпсіз кіру тек Alipay қолданбасын қолдайды.",
+        "secure_login_open_current_device": "Осы құрылғыда Alipay рұқсатын ашу",
+        "login_qr_fixed_notice": "Кіру QR-коды жарамдылық мерзімі ішінде өзгермейді. Жүйе тек кіру күйін тексереді.",
+        "login_info": "Күніне 3 мақалаға дейін тегін жасай аласыз.",
+        "login_creating": "Қауіпсіз кіру сұрауы құрылуда…",
+        "login_create_error": "Кіру сұрауын құру мүмкін болмады: {error}",
+        "login_service_timeout": "Кіру қызметі баяу жауап беріп жатыр. Сәл кейінірек қайталап көріңіз.",
+        "login_service_connection_error": "Кіру қызметі уақытша қолжетімсіз. Желіні тексеріп, қайта көріңіз.",
+        "login_reconnect": "Кіру қызметіне қайта қосылу",
+        "login_open": "Alipay QR-коды арқылы кіруді ашу",
+        "login_caption": "Жаңа бетте Alipay қолданбасымен QR-кодты сканерлеп, рұқсатты растаңыз. Рұқсат берілгеннен кейін SmartPaper мақала жазу интерфейсін автоматты түрде ашады.",
+        "login_auto_waiting": "Alipay рұқсатын күтіп тұрмыз. Рұқсат расталғаннан кейін мақала жазу интерфейсі автоматты түрде ашылады.",
+        "login_auto_network_wait": "Кіру қызметі уақытша баяу жұмыс істеуде. Жүйе автоматты түрде қайта әрекет жасап жатыр: {error}",
+        "login_auto_success": "Кіру сәтті аяқталды. Мақала жазу интерфейсі ашылуда…",
+        "login_auto_failed": "Автоматты кіру аяқталмады: {error}",
+        "login_auto_timeout": "Кіру сұрауының мерзімі аяқталды. Жаңа сұрау жасаңыз.",
+        "login_check": "Рұқсат берілді — кіруді тексеру",
+        "login_checking": "Кіру күйі тексерілуде…",
+        "login_check_error": "Кіруді тексеру сәтсіз аяқталды: {error}",
+        "login_regenerate": "Жаңа кіру сұрауын құру",
+        "login_pending": "Alipay рұқсаты әлі аяқталған жоқ. QR-кодты сканерлеп, рұқсатты растаңыз.",
+        "account_title": "Пайдаланушы есептік жазбасы",
+        "account_id": "Пайдалануш�� нөмірі: **{value}**",
+        "daily_free": "Күнделікті тегін: **{value} мақала**",
+        "bonus_papers": "Ұзақ мерзімді қалдық: **{value} мақала**",
+        "account_chip_user": "Пайдаланушы {value}",
+        "account_chip_free": "Тегін {value}",
+        "account_chip_bonus": "Қор {value}",
+        "logout_short": "Шығу",
+        "payment_dialog_title": "Alipay арқылы төлеу",
+        "payment_notice": "Күнделікті тегін және ұзақ мерзімді квота таусылды. 9,9 юань төлегенде мерзімі шектелмеген үш мақала квотасы қосылады.",
+        "quota_exhausted": "Күнделікті тегін және ұзақ мерзімді квота таусылды. Alipay арқылы ұзақ мерзімді квота сатып алыңыз.",
+        "payment_create": "Төлемге арналған QR-код жасау",
+        "payment_creating": "Alipay тапсырысы жасалуда…",
+        "payment_scan": "QR-кодты Alipay қолданбасымен сканерлеңіз. Төлемнен кейін «Төлем нәтижесін тексеру» түймесін басыңыз.",
+        "payment_check": "Төлем нәтижесін тексеру",
+        "payment_paid": "Төлем сәтті өтті. Мерзімі шектелмеген үш мақала квотасы қосылды. Мақала жасауды қайта бастаңыз.",
+        "payment_expired": "QR-кодтың қолданылу мерзімі аяқталды. Жаңа код жасаңыз.",
+        "browse_files": "Файлдарды таңдау",
+        "drop_docs": "Файлдарды осы жерге сүйреп әкеліңіз",
+        "drop_data": "Файлдарды осы жерге сүйреп әкеліңіз",
+        "drop_interviews": "Файлдарды осы жерге сүйреп әкеліңіз",
+        "limit_docs": "Әр файлға 1 ГБ дейін · PDF, DOC, DOCX",
+        "limit_data": "Әр файлға 1 ГБ дейін · CSV, XLSX, XLS",
+        "limit_interviews": "Әр файлға 1 ГБ дейін · TXT, PDF, DOC, DOCX",
+        "logout": "Шығу",
+    },
+}
+
+
+def normalize_language(code: str | None) -> str:
+    code = str(code or "zh").strip().lower()
+    return code if code in TEXTS else "zh"
+
+
+def tr(language: str, key: str, **kwargs: Any) -> str:
+    language = normalize_language(language)
+    template = TEXTS.get(language, {}).get(key)
+    if template is None:
+        template = TEXTS["zh"].get(key, key)
+    return template.format(**kwargs) if kwargs else template
+
+
+def get_target_language(language: str) -> str:
+    return TARGET_LANGUAGE[normalize_language(language)]
+
+
+def get_output_suffix(language: str) -> str:
+    return OUTPUT_SUFFIX[normalize_language(language)]
+
+
+def get_target_flag(language: str) -> str:
+    return TARGET_FLAG[normalize_language(language)]
+
+
+def get_amj_csv_template(language: str) -> str:
+    return AMJ_CSV_TEMPLATES[normalize_language(language)]
+
+
+def get_asq_txt_template(language: str) -> str:
+    return ASQ_TXT_TEMPLATES[normalize_language(language)]
+
+
+def get_reference_heading(language: str) -> str:
+    return REFERENCE_HEADINGS[normalize_language(language)]

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/managed_auth.py

@@ -0,0 +1,645 @@
+# -*- coding: utf-8 -*-
+"""SmartPaper edge-first authentication and browser task/payment bridge.
+
+Cloudflare owns the durable browser session, quota, tasks, and payments. The
+Hugging Face process verifies the signed edge assertion but does not call the
+Worker over the server-to-server network. Authenticated business operations are
+executed by the user's browser through the same-origin invisible component.
+"""
+from __future__ import annotations
+
+import base64
+import hashlib
+import hmac
+import html
+import io
+import json
+import os
+import secrets
+import time
+from typing import Any, Callable
+from urllib.parse import unquote, urlsplit
+
+import qrcode
+import streamlit as st
+
+from i18n import tr
+from smartpaper_restore_bridge import edge_bridge
+
+EDGE_ASSERTION_COOKIE_NAME = "smartpaper_edge_assertion"
+EDGE_ASSERTION_AUDIENCE = "smartpaper-streamlit"
+ASSERTION_CLOCK_SKEW_SECONDS = 30
+
+
+def _runtime_value(name: str) -> str:
+    value = os.environ.get(name, "")
+    if not value:
+        try:
+            value = st.secrets.get(name, "")
+        except Exception:
+            value = ""
+    return str(value or "").strip()
+
+
+def _api_base() -> str:
+    value = str(st.session_state.get("sp_auth_api_origin") or "").strip().rstrip("/")
+    if not value:
+        value = _runtime_value("SMARTPAPER_AUTH_API").rstrip("/")
+    parsed = urlsplit(value)
+    if (
+        parsed.scheme != "https"
+        or not parsed.netloc
+        or parsed.username is not None
+        or parsed.password is not None
+        or parsed.path not in ("", "/")
+        or parsed.query
+        or parsed.fragment
+    ):
+        raise RuntimeError("SMARTPAPER_AUTH_API must be an HTTPS origin.")
+    return f"https://{parsed.netloc}"
+
+
+def _service_key() -> str:
+    value = _runtime_value("SMARTPAPER_SERVICE_KEY")
+    if not value:
+        raise RuntimeError("SMARTPAPER_SERVICE_KEY is not configured.")
+    return value
+
+
+def _context_cookie(name: str) -> str:
+    try:
+        cookies = st.context.cookies
+        value = cookies.get(name, "")
+        if value:
+            return unquote(str(value).strip())
+        target = name.lower()
+        for key, item in cookies.items():
+            if str(key).lower() == target:
+                return unquote(str(item or "").strip())
+    except Exception:
+        return ""
+    return ""
+
+
+def _decode_b64url(value: str) -> bytes:
+    return base64.urlsafe_b64decode(value + "=" * (-len(value) % 4))
+
+
+def _verify_edge_assertion(token: str) -> dict[str, Any]:
+    try:
+        encoded, supplied_signature = token.split(".", 1)
+    except ValueError as exc:
+        raise RuntimeError("invalid_edge_assertion") from exc
+    expected_signature = hmac.new(
+        _service_key().encode("utf-8"),
+        encoded.encode("ascii"),
+        hashlib.sha256,
+    ).hexdigest()
+    if not hmac.compare_digest(expected_signature, supplied_signature):
+        raise RuntimeError("invalid_edge_assertion_signature")
+    try:
+        payload = json.loads(_decode_b64url(encoded).decode("utf-8"))
+    except Exception as exc:
+        raise RuntimeError("invalid_edge_assertion_payload") from exc
+    now = int(time.time())
+    if payload.get("ver") != 1 or payload.get("aud") != EDGE_ASSERTION_AUDIENCE:
+        raise RuntimeError("invalid_edge_assertion_claims")
+    api_origin = str(payload.get("api_origin") or "").strip().rstrip("/")
+    parsed = urlsplit(api_origin)
+    if (
+        parsed.scheme != "https"
+        or not parsed.netloc
+        or parsed.username is not None
+        or parsed.password is not None
+        or parsed.path not in ("", "/")
+        or parsed.query
+        or parsed.fragment
+    ):
+        raise RuntimeError("invalid_edge_assertion_origin")
+    issued_at = int(payload.get("iat") or 0)
+    expires_at = int(payload.get("exp") or 0)
+    if issued_at > now + ASSERTION_CLOCK_SKEW_SECONDS or expires_at <= now - ASSERTION_CLOCK_SKEW_SECONDS:
+        raise RuntimeError("expired_edge_assertion")
+    if expires_at - issued_at > 9 * 60 * 60:
+        raise RuntimeError("invalid_edge_assertion_lifetime")
+    user = payload.get("user") or {}
+    if not isinstance(user, dict) or not user.get("id") or user.get("status") != "active":
+        raise RuntimeError("invalid_edge_assertion_identity")
+    payload["api_origin"] = f"https://{parsed.netloc}"
+    return payload
+
+
+def _clear_generation_session_state() -> None:
+    for key in (
+        "sp_generation_task", "sp_current_node", "sp_last_task_heartbeat",
+        "sp_generation_idempotency_key", "zip_buffer", "zip_filename",
+        "is_running", "start_pipeline", "resume_pipeline", "run_mode",
+        "rag_engine", "up_amj_ref", "up_amj_data", "up_asq_ref",
+        "up_asq_data", "sp_payment_required", "sp_payment_order",
+        "sp_payment_request_id",
+    ):
+        st.session_state.pop(key, None)
+
+
+def _clear_session() -> None:
+    for key in (
+        "sp_session_expires_at", "sp_user",
+        "sp_last_verified_at", "sp_edge_assertion", "sp_auth_api_origin",
+    ):
+        st.session_state.pop(key, None)
+
+
+def require_alipay_login(language: str = "zh") -> dict[str, Any]:
+    """Return the user authenticated by the Cloudflare edge gateway."""
+    token = _context_cookie(EDGE_ASSERTION_COOKIE_NAME)
+    if token and token == st.session_state.get("sp_edge_assertion") and st.session_state.get("sp_user"):
+        return dict(st.session_state["sp_user"])
+    if not token:
+        _clear_session()
+        st.stop()
+    try:
+        payload = _verify_edge_assertion(token)
+    except Exception:
+        _clear_session()
+        st.stop()
+    user = dict(payload["user"])
+    st.session_state["sp_edge_assertion"] = token
+    st.session_state["sp_session_expires_at"] = payload["exp"]
+    st.session_state["sp_user"] = user
+    st.session_state["sp_auth_api_origin"] = str(payload["api_origin"]).rstrip("/")
+    st.session_state["sp_last_verified_at"] = time.time()
+    return user
+
+
+def _bridge_key(prefix: str, value: str) -> str:
+    digest = hashlib.sha256(str(value).encode("utf-8")).hexdigest()[:20]
+    return f"{prefix}_{digest}"
+
+
+def _edge_call(
+    action: str,
+    command_id: str,
+    payload: dict[str, Any] | None = None,
+    *,
+    fire_and_forget: bool = False,
+    key_prefix: str = "sp_edge",
+) -> dict[str, Any] | None:
+    return edge_bridge(
+        action=action,
+        command_id=command_id,
+        api_origin=_api_base(),
+        payload=payload or {},
+        fire_and_forget=fire_and_forget,
+        key=_bridge_key(key_prefix, command_id),
+    )
+
+
+def _raise_edge_error(result: dict[str, Any], fallback: str) -> None:
+    message = (
+        result.get("message")
+        or result.get("reason")
+        or result.get("error")
+        or fallback
+    )
+    raise RuntimeError(str(message))
+
+
+def _merge_quota_into_session(result: dict[str, Any]) -> None:
+    """Refresh the approved account card immediately after a quota mutation."""
+    quota = result.get("quota")
+    if not isinstance(quota, dict):
+        return
+    user = dict(st.session_state.get("sp_user") or {})
+    for key in (
+        "quota_date",
+        "daily_free_limit",
+        "daily_free_reserved",
+        "daily_free_used",
+        "daily_free_remaining",
+        "bonus_papers",
+    ):
+        if key in quota:
+            user[key] = quota[key]
+    if user:
+        st.session_state["sp_user"] = user
+        st.session_state["sp_account_revision"] = int(
+            st.session_state.get("sp_account_revision") or 0
+        ) + 1
+
+
+def get_account_snapshot(*, block: bool = False) -> dict[str, Any] | None:
+    bucket = int(time.time() // 30)
+    revision = int(st.session_state.get("sp_account_revision") or 0)
+    command_id = f"account:{revision}:{bucket}"
+    result = _edge_call("account", command_id, {}, key_prefix="sp_account")
+    if result is None:
+        if block:
+            st.stop()
+        return None
+    if not result.get("ok"):
+        if block:
+            _raise_edge_error(result, "account_query_failed")
+        return None
+    user = result.get("user")
+    if isinstance(user, dict):
+        st.session_state["sp_user"] = dict(user)
+    return result
+
+
+def start_generation_task(*, idempotency_key: str, mode: str, interface_language: str) -> dict[str, Any]:
+    normalized = str(idempotency_key or "").strip()
+    if not normalized:
+        raise RuntimeError("idempotency_key_required")
+    result = _edge_call(
+        "task_start",
+        normalized,
+        {
+            "idempotency_key": normalized,
+            "mode": str(mode or "").strip().lower(),
+            "interface_language": str(interface_language or "zh").strip(),
+        },
+        key_prefix="sp_task_start",
+    )
+    if result is None:
+        st.stop()
+    if not result.get("ok"):
+        _raise_edge_error(result, "task_start_failed")
+    _merge_quota_into_session(result)
+    return dict(result)
+
+
+def recover_generation_task() -> dict[str, Any]:
+    command_id = f"recover:{int(time.time() // 10)}"
+    result = _edge_call("task_recover", command_id, {}, key_prefix="sp_task_recover")
+    if result is None:
+        st.stop()
+    if not result.get("ok"):
+        _raise_edge_error(result, "task_recover_failed")
+    return dict(result)
+
+
+def heartbeat_generation_task(task_id: str, *, current_node: str = "") -> dict[str, Any]:
+    normalized = str(task_id or "").strip()
+    if not normalized:
+        raise RuntimeError("task_id_required")
+    bucket = int(time.time() // 20)
+    _edge_call(
+        "task_heartbeat",
+        f"heartbeat:{normalized}:{bucket}",
+        {"task_id": normalized, "current_node": str(current_node or "")[:240]},
+        fire_and_forget=True,
+        key_prefix="sp_task_heartbeat",
+    )
+    return {"ok": True, "queued": True, "cancel_requested": False}
+
+
+def generation_task_status(task_id: str) -> dict[str, Any]:
+    normalized = str(task_id or "").strip()
+    command_id = f"status:{normalized}:{int(time.time() // 5)}"
+    result = _edge_call(
+        "task_status", command_id, {"task_id": normalized}, key_prefix="sp_task_status"
+    )
+    if result is None:
+        st.stop()
+    if not result.get("ok"):
+        _raise_edge_error(result, "task_status_failed")
+    return dict(result)
+
+
+def finish_generation_task(
+    task_id: str,
+    *,
+    status: str,
+    safe_error_code: str = "",
+    safe_error_detail: str = "",
+    current_node: str = "",
+) -> dict[str, Any]:
+    """Finalize a task only after the browser receives Worker/D1 confirmation."""
+    normalized_task = str(task_id or "").strip()
+    normalized_status = str(status or "").strip().lower()
+    if not normalized_task:
+        raise RuntimeError("task_id_required")
+    if normalized_status not in {"completed", "failed", "cancelled", "resumable"}:
+        raise RuntimeError("invalid_finish_status")
+    command_id = f"finish:{normalized_task}:{normalized_status}"
+    result = _edge_call(
+        "task_finish",
+        command_id,
+        {
+            "task_id": normalized_task,
+            "status": normalized_status,
+            "safe_error_code": str(safe_error_code or "")[:80],
+            "safe_error_detail": str(safe_error_detail or "")[:800],
+            "current_node": str(current_node or "")[:240],
+        },
+        fire_and_forget=False,
+        key_prefix="sp_task_finish",
+    )
+    if result is None:
+        st.stop()
+    if not result.get("ok"):
+        _raise_edge_error(result, "task_finish_failed")
+    task = dict(result.get("task") or {})
+    reservation = dict(result.get("reservation") or {})
+    if str(task.get("task_id") or "") != normalized_task:
+        raise RuntimeError("task_finish_confirmation_mismatch")
+    if str(task.get("status") or "").lower() != normalized_status:
+        raise RuntimeError("task_finish_status_not_confirmed")
+    expected_reservation = {
+        "completed": "committed",
+        "failed": "released",
+        "cancelled": "released",
+        "resumable": "reserved",
+    }[normalized_status]
+    if str(reservation.get("status") or "").lower() != expected_reservation:
+        raise RuntimeError("task_quota_finalization_not_confirmed")
+    _merge_quota_into_session(result)
+    return dict(result)
+
+
+def cancel_generation_task(task_id: str | None = None) -> dict[str, Any]:
+    """Cancel synchronously so quota release is confirmed before local cleanup."""
+    normalized = str(task_id or "").strip()
+    command_id = f"cancel:{normalized or 'latest'}"
+    result = _edge_call(
+        "task_cancel",
+        command_id,
+        {"task_id": normalized} if normalized else {},
+        fire_and_forget=False,
+        key_prefix="sp_task_cancel",
+    )
+    if result is None:
+        st.stop()
+    if not result.get("ok"):
+        _raise_edge_error(result, "task_cancel_failed")
+    reservation = result.get("reservation")
+    if result.get("cancelled") and reservation and str(reservation.get("status") or "").lower() != "released":
+        raise RuntimeError("task_cancel_quota_not_released")
+    _merge_quota_into_session(result)
+    return dict(result)
+
+
+def logout_alipay_session(on_logout: Callable[[str, str], None] | None = None) -> None:
+    user_id = str((st.session_state.get("sp_user") or {}).get("id") or "")
+    task = st.session_state.get("sp_generation_task") or {}
+    task_id = str(task.get("task_id") or "")
+    if on_logout is not None:
+        try:
+            on_logout(user_id, task_id)
+        except Exception:
+            pass
+    _clear_session()
+    _clear_generation_session_state()
+
+
+def create_payment_order(idempotency_key: str) -> dict[str, Any]:
+    normalized = str(idempotency_key or "").strip()
+    result = _edge_call(
+        "pay_create",
+        normalized,
+        {"idempotency_key": normalized},
+        key_prefix="sp_pay_create",
+    )
+    if result is None:
+        st.stop()
+    if not result.get("ok"):
+        _raise_edge_error(result, "payment_create_failed")
+    return dict(result)
+
+
+def payment_order_status(merchant_order_no: str) -> dict[str, Any]:
+    order_no = str(merchant_order_no or "").strip()
+    command_id = f"pay-status:{order_no}:{int(time.time() // 3)}"
+    result = _edge_call(
+        "pay_status",
+        command_id,
+        {"merchant_order_no": order_no},
+        key_prefix="sp_pay_status",
+    )
+    if result is None:
+        st.stop()
+    if not result.get("ok"):
+        _raise_edge_error(result, "payment_status_failed")
+    return dict(result)
+
+
+def _qr_png_bytes(value: str) -> bytes:
+    image = qrcode.make(str(value))
+    buffer = io.BytesIO()
+    image.save(buffer, format="PNG")
+    return buffer.getvalue()
+
+
+def _render_payment_purchase_body(language: str) -> None:
+    st.warning(tr(language, "payment_notice"))
+
+    if st.button(tr(language, "payment_create"), key="sp_create_payment_order"):
+        st.session_state["sp_payment_request_id"] = (
+            f"pay_{int(time.time() * 1000)}_{secrets.token_urlsafe(12)}"
+        )
+
+    request_id = str(st.session_state.get("sp_payment_request_id") or "").strip()
+    order = st.session_state.get("sp_payment_order")
+    if request_id and not order:
+        st.info(tr(language, "payment_creating"))
+        order_result = create_payment_order(request_id)
+        order = dict(order_result.get("order") or {})
+        if not order.get("merchant_order_no") or not order.get("qr_code"):
+            raise RuntimeError("payment_order_missing_qr_code")
+        st.session_state["sp_payment_order"] = order
+
+    order = st.session_state.get("sp_payment_order") or {}
+    qr_code = str(order.get("qr_code") or "").strip()
+    if qr_code:
+        st.image(_qr_png_bytes(qr_code), width=280)
+        st.caption(tr(language, "payment_scan"))
+        if st.button(tr(language, "payment_check"), key="sp_check_payment_status"):
+            status_result = payment_order_status(order.get("merchant_order_no", ""))
+            updated = dict(status_result.get("order") or {})
+            st.session_state["sp_payment_order"] = updated
+            if updated.get("status") == "paid" and updated.get("credit_applied"):
+                user = status_result.get("user")
+                if isinstance(user, dict):
+                    st.session_state["sp_user"] = dict(user)
+                    st.session_state["sp_account_revision"] = int(
+                        st.session_state.get("sp_account_revision") or 0
+                    ) + 1
+                st.session_state["sp_payment_required"] = False
+                st.session_state["sp_payment_order"] = None
+                st.session_state["sp_payment_request_id"] = ""
+                st.success(tr(language, "payment_paid"))
+            elif updated.get("status") in {"closed", "failed"}:
+                st.session_state["sp_payment_order"] = None
+                st.session_state["sp_payment_request_id"] = ""
+                st.warning(tr(language, "payment_expired"))
+
+
+def render_payment_purchase(language: str) -> None:
+    """Show payment in a modal so the approved normal-page layout is unchanged."""
+    dialog_factory = getattr(st, "dialog", None)
+    if callable(dialog_factory):
+        @dialog_factory(tr(language, "payment_dialog_title"))
+        def _payment_dialog():
+            _render_payment_purchase_body(language)
+        _payment_dialog()
+        return
+    # Compatibility fallback for older Streamlit builds.
+    _render_payment_purchase_body(language)
+
+
+def render_logged_in_account(
+    language: str,
+    user: dict[str, Any] | None = None,
+    on_logout: Callable[[str, str], None] | None = None,
+) -> None:
+    """Render the approved responsive account summary with live quota values."""
+    live = get_account_snapshot(block=False)
+    if live and isinstance(live.get("user"), dict):
+        user = dict(live["user"])
+    else:
+        user = user or st.session_state.get("sp_user", {})
+    user_id = user.get("id", "—")
+    free_remaining = user.get("daily_free_remaining", user.get("daily_free_limit", 3))
+    bonus_papers = user.get("bonus_papers", 0)
+
+    st.markdown(
+        """
+        <style>
+        section[data-testid="stSidebar"] {
+            display: none !important;
+        }
+
+        [data-testid="collapsedControl"] {
+            display: none !important;
+        }
+
+        .sp-account-card {
+            display: flex;
+            align-items: center;
+            justify-content: center;
+            gap: clamp(0.3rem, 0.55vw, 0.58rem);
+            width: 100%;
+            min-width: 0;
+            min-height: 2.85rem;
+            padding: 0.48rem clamp(0.55rem, 0.85vw, 0.9rem);
+            border: 1px solid rgba(148, 163, 184, 0.30);
+            border-radius: 13px;
+            background: rgba(30, 41, 59, 0.58);
+            color: var(--text-color, #f3f4f6);
+            font-size: clamp(0.76rem, 0.84vw, 0.92rem);
+            font-weight: 500;
+            line-height: 1.25;
+            white-space: nowrap;
+            overflow: visible;
+            box-sizing: border-box;
+        }
+
+        .sp-account-card span {
+            display: inline-block;
+            white-space: nowrap;
+        }
+
+        .sp-account-separator {
+            flex: 0 0 auto;
+            opacity: 0.48;
+        }
+
+        div[data-testid="stMarkdownContainer"]:has(.sp-logout-link) {
+            width: 100%;
+        }
+
+        div[data-testid="stMarkdownContainer"]:has(.sp-logout-link) p {
+            width: 100%;
+            margin: 0;
+        }
+
+        .sp-logout-link {
+            display: flex;
+            align-items: center;
+            justify-content: center;
+            width: 100%;
+            min-width: 6.8rem;
+            min-height: 2.85rem;
+            padding: 0.45rem 0.72rem;
+            border: 1px solid rgba(148, 163, 184, 0.30);
+            border-radius: 0.5rem;
+            background: transparent;
+            color: var(--text-color, #f3f4f6) !important;
+            text-decoration: none !important;
+            white-space: nowrap !important;
+            overflow-wrap: normal !important;
+            word-break: keep-all !important;
+            line-height: 1.15;
+            font-size: clamp(0.78rem, 0.82vw, 0.92rem);
+            font-weight: 400;
+            box-sizing: border-box;
+            cursor: pointer;
+            transition: border-color 120ms ease, background-color 120ms ease;
+        }
+
+        .sp-logout-link:hover {
+            border-color: rgba(255, 75, 75, 0.78);
+            background: rgba(255, 255, 255, 0.035);
+            color: var(--text-color, #f3f4f6) !important;
+        }
+
+        .sp-logout-link:focus-visible {
+            outline: 2px solid rgba(255, 75, 75, 0.85);
+            outline-offset: 2px;
+        }
+
+        @media (max-width: 1150px) {
+            .sp-account-card {
+                font-size: 0.75rem;
+                gap: 0.3rem;
+                padding-left: 0.48rem;
+                padding-right: 0.48rem;
+            }
+
+            .sp-logout-link {
+                min-width: 5.8rem;
+                font-size: 0.78rem;
+                padding-left: 0.46rem;
+                padding-right: 0.46rem;
+            }
+        }
+
+        @media (max-width: 760px) {
+            .sp-account-card {
+                justify-content: flex-start;
+                overflow-x: auto;
+                scrollbar-width: none;
+            }
+
+            .sp-account-card::-webkit-scrollbar {
+                display: none;
+            }
+        }
+        </style>
+        """,
+        unsafe_allow_html=True,
+    )
+
+    info_col, logout_col = st.columns([5.9, 1.65])
+    with info_col:
+        st.markdown(
+            f"""
+            <div class="sp-account-card">
+              <span>{html.escape(tr(language, 'account_chip_user', value=user_id))}</span>
+              <span class="sp-account-separator">•</span>
+              <span>{html.escape(tr(language, 'account_chip_free', value=free_remaining))}</span>
+              <span class="sp-account-separator">•</span>
+              <span>{html.escape(tr(language, 'account_chip_bonus', value=bonus_papers))}</span>
+            </div>
+            """,
+            unsafe_allow_html=True,
+        )
+    with logout_col:
+        logout_label = html.escape(tr(language, "logout_short"))
+        logout_help = html.escape(tr(language, "logout"), quote=True)
+        st.markdown(
+            f'<a class="sp-logout-link" href="/edge/logout" target="_self" '
+            f'rel="nofollow" role="button" aria-label="{logout_help}" '
+            f'title="{logout_help}">{logout_label}</a>',
+            unsafe_allow_html=True,
+        )

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/requirements.txt

@@ -0,0 +1,14 @@
+streamlit==1.38.0
+requests>=2.31,<3
+python-docx>=1.1,<2
+pandas>=2.1,<3
+numpy>=1.26,<3
+scikit-learn>=1.4,<2
+tiktoken>=0.7,<1
+langdetect==1.0.9
+mistune>=3,<4
+beautifulsoup4>=4.12,<5
+PyMuPDF>=1.24,<2
+openpyxl>=3.1,<4
+tabulate>=0.9,<1
+qrcode[pil]>=8,<9

$RECYCLE.BIN/S-1-5-21-2308098342-1360407909-2433281377-1001/$RD7299H/smartpaper_restore_bridge/__init__.py

@@ -0,0 +1,81 @@
+# -*- coding: utf-8 -*-
+"""Invisible browser bridge for SmartPaper recovery and edge API calls.
+
+The component is served by Streamlit through the public Cloudflare origin. It
+therefore allows the authenticated browser to call same-origin Worker endpoints
+with the existing HttpOnly browser cookie. No service key or cookie value is
+passed to Python or JavaScript arguments.
+"""
+
+from __future__ import annotations
+
+from pathlib import Path
+from typing import Any
+
+import streamlit.components.v1 as components
+
+_FRONTEND_DIR = Path(__file__).resolve().parent / "frontend"
+_FRONTEND_ENTRY = _FRONTEND_DIR / "index.html"
+if not _FRONTEND_ENTRY.is_file():
+    raise RuntimeError("SmartPaper restore bridge frontend is missing.")
+
+_COMPONENT = components.declare_component(
+    "smartpaper_restore_bridge",
+    path=str(_FRONTEND_DIR),
+)
+
+
+def restore_bridge(
+    *,
+    action: str,
+    command_id: str,
+    token: str = "",
+    expires_at: str = "",
+    key: str = "sp_restore_bridge",
+) -> dict[str, Any] | None:
+    """Backward-compatible recovery-token storage operation."""
+    value = _COMPONENT(
+        action=str(action or "read"),
+        command_id=str(command_id or ""),
+        token=str(token or ""),
+        expires_at=str(expires_at or ""),
+        api_origin="",
+        payload={},
+        fire_and_forget=False,
+        height=0,
+        default=None,
+        key=key,
+    )
+    return value if isinstance(value, dict) else None
+
+
+def edge_bridge(
+    *,
+    action: str,
+    command_id: str,
+    api_origin: str,
+    payload: dict[str, Any] | None = None,
+    fire_and_forget: bool = False,
+    key: str = "sp_edge_bridge",
+) -> dict[str, Any] | None:
+    """Execute one authenticated same-origin Worker command in the browser.
+
+    The first synchronous invocation usually returns ``None``. Streamlit reruns
+    after the browser completes the request and then returns the result. Only
+    non-terminal heartbeat calls may use ``fire_and_forget=True``. Task
+    completion, failure, cancellation, payment, and account mutations remain
+    synchronous so Python receives the Worker/D1 postcondition.
+    """
+    value = _COMPONENT(
+        action=str(action or ""),
+        command_id=str(command_id or ""),
+        token="",
+        expires_at="",
+        api_origin=str(api_origin or ""),
+        payload=dict(payload or {}),
+        fire_and_forget=bool(fire_and_forget),
+        height=0,
+        default=None,
+        key=key,
+    )
+    return value if isinstance(value, dict) else None