Compare commits

..

9 Commits

Author SHA1 Message Date
john e07686f29d feat(admin): show user subscription plan and token quota in user pages
Expose active subscription summary on user list and detail so operators can see plan type, total/used/remaining tokens without opening billing subscriptions.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-09-07 16:22:08 +08:00
john c1aa1ba459 Add independent Cursor channel feature toggles in admin UI.
Replace free-text intent allowlist with per-capability switches aligned with Memind runtime policy schema.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-08-31 09:40:53 +08:00
john 86c7c5fb08 docs(admin): clarify subscription quota uses margin multiplier in billing UI
Co-authored-by: Cursor <cursoragent@cursor.com>
2026-08-28 20:31:38 +08:00
john ec38ee086d Add dedicated admin page for TKMind Cursor experience channel (H5 + WeChat).
Centralize whitelist and channel toggles away from the WeChat page so Cursor stays an opt-in path for selected users only.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-08-28 15:27:10 +08:00
john 70433a3dcd feat(wechat): add intent router and Cursor executor admin controls
Expose WeChat routing policy and Cursor experience channel settings in md.tkmind.cn with matching admin-api routes.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-08-26 21:56:15 +08:00
john 80c2091baf feat(billing): add all/A/B tabs for formula user filter
Replace the formula assignment dropdown with tab buttons so admins can
quickly view all users or filter by billing formula A or B.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-08-24 11:36:13 +08:00
john f9f8b541dc fix(deploy): load vite preview config for md.tkmind.cn host
LaunchAgent web startup must use vite-preview.config.mjs so preview
allowedHosts includes md.tkmind.cn instead of blocking nginx requests.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-08-22 08:55:07 +08:00
john f6bb02254e feat(billing): add formula A/B admin UI and subscription renew status
Expose dual metering formula editing with batch user assignment, show
auto-renew and pending-recharge states in subscriptions, and document
billing acceptance checks for production rollout.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-08-22 08:45:43 +08:00
john a503fa9cbe fix(deploy): add LaunchAgent prod runner scripts for adm api and web
Restore the missing run-memind-adm-*-prod.sh entrypoints expected by 103
LaunchAgents so admin services can restart cleanly after reboot.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-08-16 08:57:00 +08:00
19 changed files with 1563 additions and 182 deletions
+28
View File
@@ -0,0 +1,28 @@
# 计费赠金 / A-B 计量 / 包月补扣 — 业务验收清单
## 1. 新用户赠金
- [ ] 新注册用户钱包仅入账 **5 元**,流水备注为「新用户赠送」
- [ ] 余额消耗至 1 元以下时,**不再**出现「新用户低余额自动赠送」流水或站内通知
- [ ] 生产环境可设置 `H5_LOW_BALANCE_GIFT_AMOUNT_CENTS=0` 锁定关闭
## 2. 计量公式 A / B
- [ ] 管理后台「计费中心 → 计量公式」可分别编辑并保存公式 A、公式 B
- [ ] 修改公式 A 不影响已分配到公式 B 的用户扣费
- [ ] 批量分配可将用户划入 A 或 B,用户列表显示当前公式
- [ ] Portal 对话扣费在数秒内按用户所属公式生效(无需重启)
## 3. 包月自动续费补扣
- [ ] 到期且开启自动续费、余额不足:套餐过期降为免费,**自动续费标记保持开启**
- [ ] 订阅列表显示「待补扣」(已过期 + 自动续费开启)
- [ ] 用户充值后余额足够:自动扣款并恢复套餐,无需等待小时任务
- [ ] 小时任务对仍开启自动续费且已过期的订阅持续重试
## 发布顺序
1. Memind103 Portal 8081)— schema + 扣费/续费运行时
2. memind_adm5174 / 8085)— 管理后台 UI 与 API
发布前分别执行各仓库 `bash scripts/check-release-ready.sh`
+8
View File
@@ -0,0 +1,8 @@
#!/usr/bin/env bash
set -euo pipefail
ROOT="$(cd "$(dirname "$0")/.." && pwd)"
export ADM_API_PORT="${ADM_API_PORT:-8085}"
export NODE_BIN="${NODE_BIN:-/opt/homebrew/opt/node@24/bin/node}"
export PATH="/opt/homebrew/opt/node@24/bin:/opt/homebrew/bin:/usr/local/bin:/usr/bin:/bin:${PATH}"
cd "${ROOT}"
exec "${NODE_BIN}" server/index.mjs
+18
View File
@@ -0,0 +1,18 @@
#!/usr/bin/env bash
set -euo pipefail
ROOT="$(cd "$(dirname "$0")/.." && pwd)"
export ADM_PORT="${ADM_PORT:-5174}"
export ADM_WEB_HOST="${ADM_WEB_HOST:-0.0.0.0}"
export ADM_DEV_BACKEND="${ADM_DEV_BACKEND:-http://127.0.0.1:8085}"
export NODE_BIN="${NODE_BIN:-/opt/homebrew/opt/node@24/bin/node}"
export PATH="/opt/homebrew/opt/node@24/bin:/opt/homebrew/bin:/usr/local/bin:/usr/bin:/bin:${PATH}"
cd "${ROOT}"
if [[ ! -d dist ]]; then
echo "dist/ missing; run npm run build first" >&2
exit 1
fi
exec "${NODE_BIN}" ./node_modules/vite/bin/vite.js preview \
--config scripts/vite-preview.config.mjs \
--host 0.0.0.0 \
--port "${ADM_PORT}" \
--strictPort
+10 -1
View File
@@ -12,7 +12,16 @@ export default defineConfig(({ mode }) => {
host: env.ADM_WEB_HOST ?? env.ADM_API_HOST ?? '127.0.0.1',
port: Number(env.ADM_PORT ?? 5174),
strictPort: true,
allowedHosts: ['md.tkmind.cn', 'gadm.tkmind.cn', 'localhost', '127.0.0.1', '10.10.0.2', '58.38.22.103'],
// Behind nginx/Caddy on md.tkmind.cn; allow production hostnames explicitly.
allowedHosts: [
'md.tkmind.cn',
'gadm.tkmind.cn',
'localhost',
'127.0.0.1',
'10.10.0.2',
'58.38.22.103',
'.tkmind.cn',
],
proxy: {
'/api': backend,
'/auth': backend,
+120 -6
View File
@@ -108,6 +108,8 @@ export function createAdminApp(services) {
skillRuntimeConfigService,
billingConfigService,
wechatScheduleLlmConfigService,
wechatIntentRouterConfigService,
wechatCursorExecutorPolicyService,
adminSystemTestService,
systemTestAccountService,
wordFilterService,
@@ -288,13 +290,36 @@ export function createAdminApp(services) {
role: typeof req.query.role === 'string' ? req.query.role.trim() : '',
status: typeof req.query.status === 'string' ? req.query.status.trim() : '',
});
if (subscriptionService?.getActiveSubscription && Array.isArray(result.users) && result.users.length) {
result.users = await Promise.all(
result.users.map(async (user) => {
if (user.role !== 'user') return user;
const sub = await subscriptionService.getActiveSubscription(user.id);
if (!sub) return { ...user, subscription: null };
return {
...user,
subscription: {
planType: sub.planType,
status: sub.status,
periodTokensLimit: sub.periodTokensLimit,
periodTokensUsed: sub.periodTokensUsed,
expiresAt: sub.expiresAt,
},
};
}),
);
}
res.json(result);
});
adminApi.get('/users/:userId', requireAdmin, async (req, res) => {
const user = await userAuth.getUserPublic(req.params.userId);
if (!user) return res.status(404).json({ message: '用户不存在' });
res.json({ user });
let subscription = null;
if (subscriptionService?.getActiveSubscription && user.role === 'user') {
subscription = await subscriptionService.getActiveSubscription(req.params.userId);
}
res.json({ user, subscription });
});
adminApi.get('/summary', requireAdmin, async (_req, res) => {
@@ -395,6 +420,79 @@ export function createAdminApp(services) {
res.json(result);
});
adminApi.get('/wechat/intent-router/config', requireAdmin, async (_req, res) => {
if (!wechatIntentRouterConfigService?.getConfig) {
return res.status(503).json({ message: '微信意图路由配置未启用' });
}
const config = await wechatIntentRouterConfigService.getConfig();
return res.json({ config });
});
adminApi.get('/wechat/intent-router/runtime', requireAdmin, async (_req, res) => {
if (!wechatIntentRouterConfigService?.getRuntimeState) {
return res.status(503).json({ message: '微信意图路由配置未启用' });
}
return res.json(await wechatIntentRouterConfigService.getRuntimeState());
});
const updateWechatIntentRouterConfig = async (req, res) => {
if (!wechatIntentRouterConfigService?.updateConfig) {
return res.status(503).json({ message: '微信意图路由配置未启用' });
}
const config = await wechatIntentRouterConfigService.updateConfig(req.body ?? {}, {
updatedBy: req.currentUser.id,
});
return res.json({ config });
};
adminApi.put('/wechat/intent-router/config', requireAdmin, updateWechatIntentRouterConfig);
adminApi.patch('/wechat/intent-router/config', requireAdmin, updateWechatIntentRouterConfig);
adminApi.get('/wechat/cursor-executor/config', requireAdmin, async (_req, res) => {
if (!wechatCursorExecutorPolicyService?.getAdminConfig) {
return res.status(503).json({ message: '微信 Cursor 体验通道未启用' });
}
return res.json(await wechatCursorExecutorPolicyService.getAdminConfig());
});
adminApi.get('/wechat/cursor-executor/runtime', requireAdmin, async (_req, res) => {
if (!wechatCursorExecutorPolicyService?.getRuntimeState) {
return res.status(503).json({ message: '微信 Cursor 体验通道未启用' });
}
return res.json(await wechatCursorExecutorPolicyService.getRuntimeState());
});
const updateWechatCursorExecutorConfig = async (req, res) => {
if (!wechatCursorExecutorPolicyService?.updateAdminConfig) {
return res.status(503).json({ message: '微信 Cursor 体验通道未启用' });
}
const result = await wechatCursorExecutorPolicyService.updateAdminConfig(
req.body?.config ?? req.body ?? {},
{ updatedBy: req.currentUser.id },
);
return res.json(result);
};
adminApi.put('/wechat/cursor-executor/config', requireAdmin, updateWechatCursorExecutorConfig);
adminApi.patch('/wechat/cursor-executor/config', requireAdmin, updateWechatCursorExecutorConfig);
adminApi.get('/cursor-executor-channel/config', requireAdmin, async (_req, res) => {
if (!wechatCursorExecutorPolicyService?.getAdminConfig) {
return res.status(503).json({ message: 'TKMind 智趣体验通道未启用' });
}
return res.json(await wechatCursorExecutorPolicyService.getAdminConfig());
});
adminApi.get('/cursor-executor-channel/runtime', requireAdmin, async (_req, res) => {
if (!wechatCursorExecutorPolicyService?.getRuntimeState) {
return res.status(503).json({ message: 'TKMind 智趣体验通道未启用' });
}
return res.json(await wechatCursorExecutorPolicyService.getRuntimeState());
});
adminApi.put('/cursor-executor-channel/config', requireAdmin, updateWechatCursorExecutorConfig);
adminApi.patch('/cursor-executor-channel/config', requireAdmin, updateWechatCursorExecutorConfig);
adminApi.get('/mindspace/config', requireAdmin, async (_req, res) => {
if (!loadMindSpaceConfig) return res.status(503).json({ message: 'MindSpace 配置未启用' });
const config = await loadMindSpaceConfig(pool);
@@ -660,11 +758,12 @@ export function createAdminApp(services) {
res.json(await skillRuntimeConfigService.getPublicRuntimeConfig());
});
adminApi.get('/billing/config', requireAdmin, async (_req, res) => {
adminApi.get('/billing/config', requireAdmin, async (req, res) => {
if (!billingConfigService?.getAdminConfig) {
return res.status(503).json({ message: '计费公式配置服务未启用' });
}
return res.json(await billingConfigService.getAdminConfig());
const formula = req.query.formula ? String(req.query.formula) : undefined;
return res.json(await billingConfigService.getAdminConfig({ formula }));
});
const updateBillingConfig = async (req, res) => {
@@ -672,9 +771,10 @@ export function createAdminApp(services) {
return res.status(503).json({ message: '计费公式配置服务未启用' });
}
try {
const formula = req.body?.formula ? String(req.body.formula) : undefined;
return res.json(await billingConfigService.updateAdminConfig(
req.body?.config ?? req.body ?? {},
{ updatedBy: req.currentUser.id },
{ updatedBy: req.currentUser.id, formula },
));
} catch (error) {
if (error?.code === 'BILLING_CONFIG_ENV_LOCKED') {
@@ -687,11 +787,25 @@ export function createAdminApp(services) {
adminApi.put('/billing/config', requireAdmin, updateBillingConfig);
adminApi.patch('/billing/config', requireAdmin, updateBillingConfig);
adminApi.get('/billing/runtime', requireAdmin, async (_req, res) => {
adminApi.post('/billing/formula-assignments', requireAdmin, async (req, res) => {
if (!billingConfigService?.assignBillingFormula) {
return res.status(503).json({ message: '计费公式配置服务未启用' });
}
const { userIds, formula } = req.body ?? {};
const result = await billingConfigService.assignBillingFormula(userIds, formula);
if (!result.ok) {
return res.status(400).json(result);
}
return res.json(result);
});
adminApi.get('/billing/runtime', requireAdmin, async (req, res) => {
if (!billingConfigService?.getRuntimeState) {
return res.status(503).json({ message: '计费公式配置服务未启用' });
}
return res.json(await billingConfigService.getRuntimeState());
const formula = req.query.formula ? String(req.query.formula) : undefined;
const userId = req.query.userId ? String(req.query.userId) : undefined;
return res.json(await billingConfigService.getRuntimeState({ formula, userId }));
});
adminApi.get('/system-tests/accounts', requireAdmin, async (_req, res) => {
+20 -1
View File
@@ -28,8 +28,15 @@ function createServices({ role = 'admin' } = {}) {
getMe: async () => ({ id: 'admin-id', username: 'admin', role }),
},
billingConfigService: {
getAdminConfig: async () => ({
getAdminConfig: async ({ formula = 'A' } = {}) => ({
config: stored,
formulas: { A: stored, B: stored },
formulaMeta: {
A: { source: 'env', updatedAt: null, updatedBy: null },
B: { source: 'env', updatedAt: null, updatedBy: null },
},
activeFormula: formula,
defaultFormula: 'A',
source: 'env',
updatedAt: null,
updatedBy: null,
@@ -39,12 +46,24 @@ function createServices({ role = 'admin' } = {}) {
stored = { ...stored, ...(patch.config ?? patch) };
return {
config: stored,
formulas: { A: stored, B: stored },
formulaMeta: {
A: { source: 'admin-db', updatedAt: Date.now(), updatedBy: context?.updatedBy ?? null },
B: { source: 'admin-db', updatedAt: null, updatedBy: null },
},
activeFormula: context?.formula ?? 'A',
defaultFormula: 'A',
source: 'admin-db',
updatedAt: Date.now(),
updatedBy: context?.updatedBy ?? null,
formula: '最终扣费 = 上游成本(USD) × 汇率 × 毛利倍数',
};
},
assignBillingFormula: async (userIds, formula) => ({
ok: true,
updated: userIds.length,
formula,
}),
getRuntimeState: async () => ({
source: 'admin-db',
config: stored,
+9
View File
@@ -43,6 +43,10 @@ export async function bootstrapAdminServices() {
const { createAssetGatewayConfigService } = await importMemind('asset-gateway.mjs');
const { ensureAssetGatewaySchema } = await importMemind('db.mjs');
const { createWechatScheduleLlmConfigService } = await importMemind('wechat-schedule-llm-config.mjs');
const { createWechatIntentRouterConfigService } = await importMemind('wechat-intent-router-config.mjs');
const { createWechatCursorExecutorAdminConfigService } = await importMemind(
'wechat-cursor-executor-admin-config.mjs',
);
const { createAdminSystemTestService } = await importMemind('admin-system-tests.mjs');
const { createOpsApi } = await importMemind('admin-routes.mjs');
const { createWordFilterService, ensureWordFilterSchema } = await importMemind('word-filter.mjs');
@@ -126,6 +130,8 @@ export async function bootstrapAdminServices() {
const wechatScheduleLlmConfigService = createWechatScheduleLlmConfigService(pool, {
env: process.env,
});
const wechatIntentRouterConfigService = createWechatIntentRouterConfigService(pool);
const wechatCursorExecutorPolicyService = createWechatCursorExecutorAdminConfigService(pool);
const adminSystemTestService = createAdminSystemTestService({
pool,
userAuth,
@@ -165,6 +171,7 @@ export async function bootstrapAdminServices() {
getPlanAsync: (planType) => planCatalogService.getPlan(planType),
});
subscriptionService._planCatalogService = planCatalogService;
userAuth.setSubscriptionService(subscriptionService);
const { createPageTemplateCatalogService } = await importMemind('page-template-catalog.mjs');
const templateCatalogService = createPageTemplateCatalogService(pool, {
userAuth,
@@ -197,6 +204,8 @@ export async function bootstrapAdminServices() {
skillRuntimeConfigService,
billingConfigService,
wechatScheduleLlmConfigService,
wechatIntentRouterConfigService,
wechatCursorExecutorPolicyService,
adminSystemTestService,
systemTestAccountService,
wordFilterService,
+4
View File
@@ -112,6 +112,8 @@ ready
skillRuntimeConfigService,
billingConfigService,
wechatScheduleLlmConfigService,
wechatIntentRouterConfigService,
wechatCursorExecutorPolicyService,
adminSystemTestService,
systemTestAccountService,
wordFilterService,
@@ -142,6 +144,8 @@ ready
skillRuntimeConfigService,
billingConfigService,
wechatScheduleLlmConfigService,
wechatIntentRouterConfigService,
wechatCursorExecutorPolicyService,
adminSystemTestService,
systemTestAccountService,
wordFilterService,
+2
View File
@@ -17,6 +17,7 @@ import { TemplateCatalogPage } from './admin/pages/TemplateCatalogPage';
import { UserDetailPage } from './admin/pages/UserDetailPage';
import { UsersPage } from './admin/pages/UsersPage';
import { WechatPage } from './admin/pages/WechatPage';
import { CursorChannelPage } from './admin/pages/CursorChannelPage';
import { AssetGatewayPage } from './admin/pages/AssetGatewayPage';
import { BlockedWordsPage } from './admin/pages/BlockedWordsPage';
import { AnalyticsConfigPage } from './admin/pages/AnalyticsConfigPage';
@@ -137,6 +138,7 @@ function AdminApp({ user, onLogout }: { user: PortalUser; onLogout: () => void }
<Route path="orchestrator" element={<OrchestratorPage />} />
<Route path="providers" element={<ProvidersPage />} />
<Route path="wechat" element={<WechatPage />} />
<Route path="cursor-channel" element={<CursorChannelPage />} />
<Route path="asset-gateway" element={<AssetGatewayPage />} />
<Route path="blocked-words" element={<BlockedWordsPage />} />
<Route path="*" element={<Navigate to="/" replace />} />
+1
View File
@@ -30,6 +30,7 @@ const NAV_SECTIONS: NavSection[] = [
{
label: '平台配置',
items: [
{ to: '/cursor-channel', label: '智趣体验通道' },
{ to: '/wechat', label: '服务号' },
{ to: '/mindspace', label: 'MindSpace 配置' },
{ to: '/analytics', label: 'Analytics 配置' },
+385 -162
View File
@@ -1,6 +1,7 @@
import { useCallback, useEffect, useRef, useState } from 'react';
import { useLocation, useNavigate } from 'react-router-dom';
import {
assignBillingFormula,
cancelUserSubscription,
createSubscriptionPlan,
deleteSubscriptionPlan,
@@ -22,6 +23,7 @@ import type {
AdminSubscription,
AdminUserRow,
BillingAdminConfig,
BillingFormulaKey,
LedgerEntry,
PlanDefinition,
UsageRecord,
@@ -175,11 +177,304 @@ const DEFAULT_BILLING_FORMULA: BillingAdminConfig = {
costEstimateOutputUsdPer1M: 1.1,
};
const FORMULA_TABS: BillingFormulaKey[] = ['A', 'B'];
function FormulaConfigForm({
formulaKey,
draft,
source,
updatedAt,
envLocked,
saving,
onDraftChange,
onSave,
}: {
formulaKey: BillingFormulaKey;
draft: BillingAdminConfig;
source: string;
updatedAt: number | null;
envLocked: boolean;
saving: boolean;
onDraftChange: (next: BillingAdminConfig) => void;
onSave: (event: React.FormEvent) => void;
}) {
const patchNumber = (key: keyof BillingAdminConfig, value: string) => {
const num = Number(value);
onDraftChange({
...draft,
[key]: Number.isFinite(num) ? num : draft[key],
});
};
return (
<form className="admin-form" onSubmit={onSave}>
<p className="muted">
{formulaKey} · {SOURCE_LABELS[source] ?? source}
{updatedAt
? ` · 更新于 ${new Date(updatedAt).toLocaleString('zh-CN', { hour12: false })}`
: ''}
</p>
<label className="inline-check">
<input
type="checkbox"
checked={draft.useBackendCost}
disabled={envLocked}
onChange={(event) => onDraftChange({ ...draft, useBackendCost: event.target.checked })}
/>
<span>
<strong></strong>
<span className="muted"> USD </span>
</span>
</label>
<label>
<span>USDCNY</span>
<input
type="number"
min="0.01"
step="0.01"
disabled={envLocked}
value={draft.usdCnyRate}
onChange={(e) => patchNumber('usdCnyRate', e.target.value)}
/>
</label>
<label>
<span></span>
<input
type="number"
min="0.01"
step="0.01"
disabled={envLocked}
value={draft.marginMultiplier}
onChange={(e) => patchNumber('marginMultiplier', e.target.value)}
/>
</label>
<label>
<span></span>
<input
type="number"
min="1"
step="1"
disabled={envLocked}
value={draft.minBillCents}
onChange={(e) => patchNumber('minBillCents', e.target.value)}
/>
</label>
<h3>Token 退</h3>
<label>
<span> / 1k tokens</span>
<input
type="number"
min="0"
step="0.01"
disabled={envLocked}
value={draft.inputCentsPer1k}
onChange={(e) => patchNumber('inputCentsPer1k', e.target.value)}
/>
</label>
<label>
<span> / 1k tokens</span>
<input
type="number"
min="0"
step="0.01"
disabled={envLocked}
value={draft.outputCentsPer1k}
onChange={(e) => patchNumber('outputCentsPer1k', e.target.value)}
/>
</label>
<h3>Finish cost </h3>
<label className="inline-check">
<input
type="checkbox"
checked={draft.costEstimateFromTokens}
disabled={envLocked || !draft.useBackendCost}
onChange={(event) => onDraftChange({
...draft,
costEstimateFromTokens: event.target.checked,
})}
/>
<span>
<strong> Token </strong>
<span className="muted"> </span>
</span>
</label>
<label>
<span>USD / 1M</span>
<input
type="number"
min="0"
step="0.01"
disabled={envLocked || !draft.useBackendCost}
value={draft.costEstimateInputUsdPer1M}
onChange={(e) => patchNumber('costEstimateInputUsdPer1M', e.target.value)}
/>
</label>
<label>
<span>USD / 1M</span>
<input
type="number"
min="0"
step="0.01"
disabled={envLocked || !draft.useBackendCost}
value={draft.costEstimateOutputUsdPer1M}
onChange={(e) => patchNumber('costEstimateOutputUsdPer1M', e.target.value)}
/>
</label>
<p className="muted">
USD × {draft.usdCnyRate} × {draft.marginMultiplier}
Token × {draft.marginMultiplier}
</p>
<button type="submit" className="send-btn" disabled={saving || envLocked}>
{saving ? '保存中…' : `保存计量公式 ${formulaKey}`}
</button>
</form>
);
}
function FormulaAssignmentSection() {
const { users, reload, error, setError } = useAdminUsers();
const [selected, setSelected] = useState<string[]>([]);
const [formulaFilter, setFormulaFilter] = useState<'all' | BillingFormulaKey>('all');
const [search, setSearch] = useState('');
const [assigning, setAssigning] = useState(false);
const [message, setMessage] = useState<string | null>(null);
const filteredUsers = users.filter((user) => {
if (user.role !== 'user') return false;
const formula = user.billingFormula ?? 'A';
if (formulaFilter !== 'all' && formula !== formulaFilter) return false;
if (!search.trim()) return true;
const q = search.toLowerCase();
return user.username.toLowerCase().includes(q) || user.displayName.toLowerCase().includes(q);
});
const toggleUser = (userId: string) => {
setSelected((prev) => (
prev.includes(userId) ? prev.filter((id) => id !== userId) : [...prev, userId]
));
};
const toggleAll = () => {
const ids = filteredUsers.map((user) => user.id);
const allSelected = ids.length > 0 && ids.every((id) => selected.includes(id));
setSelected((prev) => (
allSelected ? prev.filter((id) => !ids.includes(id)) : [...new Set([...prev, ...ids])]
));
};
const handleAssign = async (formula: BillingFormulaKey) => {
if (!selected.length) return;
setAssigning(true);
setMessage(null);
setError(null);
try {
const result = await assignBillingFormula(selected, formula);
setMessage(`已将 ${result.updated} 位用户分配到计量公式 ${formula}`);
setSelected([]);
await reload();
} catch (err) {
setError(err instanceof Error ? err.message : '批量分配失败');
} finally {
setAssigning(false);
}
};
return (
<section className="admin-card">
<h2></h2>
<p className="muted"> A B使 A</p>
{error && <p className="banner banner-error">{error}</p>}
{message && <p className="banner banner-info">{message}</p>}
<div className="admin-tabs billing-formula-filter-tabs" role="tablist" aria-label="按计量公式筛选用户">
{(['all', 'A', 'B'] as const).map((key) => (
<button
key={key}
type="button"
role="tab"
aria-selected={formulaFilter === key}
className={`admin-tab${formulaFilter === key ? ' active' : ''}`}
onClick={() => setFormulaFilter(key)}
>
{key === 'all' ? '全部' : `公式 ${key}`}
</button>
))}
</div>
<div className="billing-toolbar">
<input
className="users-search-input"
placeholder="搜索用户名 / 显示名"
value={search}
onChange={(event) => setSearch(event.target.value)}
/>
<button type="button" className="ghost-btn" onClick={() => void reload()} disabled={assigning}>
</button>
<button type="button" className="send-btn" disabled={!selected.length || assigning} onClick={() => void handleAssign('A')}>
A
</button>
<button type="button" className="send-btn" disabled={!selected.length || assigning} onClick={() => void handleAssign('B')}>
B
</button>
</div>
<div className="admin-table-wrap">
<table className="admin-table">
<thead>
<tr>
<th>
<input
type="checkbox"
checked={filteredUsers.length > 0 && filteredUsers.every((user) => selected.includes(user.id))}
onChange={toggleAll}
/>
</th>
<th></th>
<th></th>
<th></th>
</tr>
</thead>
<tbody>
{filteredUsers.map((user) => (
<tr key={user.id}>
<td>
<input
type="checkbox"
checked={selected.includes(user.id)}
onChange={() => toggleUser(user.id)}
/>
</td>
<td>
<span>{user.displayName}</span>
<span className="muted"> @{user.username}</span>
</td>
<td><strong>{user.billingFormula ?? 'A'}</strong></td>
<td className="billing-num">¥{formatYuan(user.balanceCents)}</td>
</tr>
))}
</tbody>
</table>
</div>
{filteredUsers.length === 0 ? <p className="muted billing-empty"></p> : null}
</section>
);
}
function FormulaTab() {
const [draft, setDraft] = useState<BillingAdminConfig>(DEFAULT_BILLING_FORMULA);
const [source, setSource] = useState('default');
const [updatedAt, setUpdatedAt] = useState<number | null>(null);
const [formula, setFormula] = useState<string>('');
const [activeFormula, setActiveFormula] = useState<BillingFormulaKey>('A');
const [drafts, setDrafts] = useState<Record<BillingFormulaKey, BillingAdminConfig>>({
A: DEFAULT_BILLING_FORMULA,
B: DEFAULT_BILLING_FORMULA,
});
const [meta, setMeta] = useState<Record<BillingFormulaKey, { source: string; updatedAt: number | null }>>({
A: { source: 'default', updatedAt: null },
B: { source: 'default', updatedAt: null },
});
const [formulaText, setFormulaText] = useState('');
const [envLocked, setEnvLocked] = useState(false);
const [loading, setLoading] = useState(true);
const [saving, setSaving] = useState(false);
@@ -190,11 +485,22 @@ function FormulaTab() {
setLoading(true);
setError(null);
try {
const result = await getBillingConfig();
setDraft(result.config);
setSource(result.source ?? 'default');
setUpdatedAt(result.updatedAt ?? null);
setFormula(result.formula ?? '');
const result = await getBillingConfig('A');
setDrafts({
A: result.formulas?.A ?? result.config,
B: result.formulas?.B ?? result.config,
});
setMeta({
A: {
source: result.formulaMeta?.A?.source ?? result.source ?? 'default',
updatedAt: result.formulaMeta?.A?.updatedAt ?? result.updatedAt ?? null,
},
B: {
source: result.formulaMeta?.B?.source ?? result.source ?? 'default',
updatedAt: result.formulaMeta?.B?.updatedAt ?? null,
},
});
setFormulaText(result.formula ?? '');
setEnvLocked(Boolean(result.envOverrideActive));
} catch (err) {
setError(err instanceof Error ? err.message : '加载计量公式失败');
@@ -207,16 +513,9 @@ function FormulaTab() {
void load();
}, [load]);
const patchNumber = (key: keyof BillingAdminConfig, value: string) => {
const num = Number(value);
setDraft((prev) => ({
...prev,
[key]: Number.isFinite(num) ? num : prev[key],
}));
};
const handleSave = async (e: React.FormEvent) => {
e.preventDefault();
const draft = drafts[activeFormula];
if (envLocked) {
setError('当前环境已锁定为仅读 envH5_BILLING_CONFIG_SOURCE=env),无法保存。');
return;
@@ -228,7 +527,7 @@ function FormulaTab() {
if (
draft.useBackendCost
&& !window.confirm(
`确认保存成本模式扣费?\n最终扣费 = 上游成本(USD) × ${draft.usdCnyRate} × ${draft.marginMultiplier}`,
`确认保存公式 ${activeFormula} 成本模式扣费?\n最终扣费 = 上游成本(USD) × ${draft.usdCnyRate} × ${draft.marginMultiplier}`,
)
) {
return;
@@ -237,13 +536,24 @@ function FormulaTab() {
setError(null);
setMessage(null);
try {
const result = await updateBillingConfig(draft);
setDraft(result.config);
setSource(result.source ?? 'admin-db');
setUpdatedAt(result.updatedAt ?? null);
setFormula(result.formula ?? '');
const result = await updateBillingConfig(draft, activeFormula);
setDrafts({
A: result.formulas?.A ?? drafts.A,
B: result.formulas?.B ?? drafts.B,
});
setMeta({
A: {
source: result.formulaMeta?.A?.source ?? result.source ?? 'admin-db',
updatedAt: result.formulaMeta?.A?.updatedAt ?? result.updatedAt ?? null,
},
B: {
source: result.formulaMeta?.B?.source ?? result.source ?? 'admin-db',
updatedAt: result.formulaMeta?.B?.updatedAt ?? result.updatedAt ?? null,
},
});
setFormulaText(result.formula ?? '');
setEnvLocked(Boolean(result.envOverrideActive));
setMessage('计量公式已保存。Portal 扣费会在数秒内读取新配置,无需重启。');
setMessage(`计量公式 ${activeFormula} 已保存。Portal 扣费会在数秒内读取新配置,无需重启。`);
} catch (err) {
setError(err instanceof Error ? err.message : '保存失败');
} finally {
@@ -252,144 +562,45 @@ function FormulaTab() {
};
return (
<section className="admin-card">
<h2></h2>
<p className="muted">
= (USD) × × 退 Token
</p>
{loading ? <p className="muted"></p> : null}
{error && <p className="banner banner-error">{error}</p>}
{message && <p className="banner banner-info">{message}</p>}
{!loading ? (
<form className="admin-form" onSubmit={handleSave}>
<p className="muted">
{SOURCE_LABELS[source] ?? source}
{updatedAt
? ` · 更新于 ${new Date(updatedAt).toLocaleString('zh-CN', { hour12: false })}`
: ''}
</p>
{formula ? <p className="muted">{formula}</p> : null}
<label className="inline-check">
<input
type="checkbox"
checked={draft.useBackendCost}
disabled={envLocked}
onChange={(event) => setDraft((prev) => ({ ...prev, useBackendCost: event.target.checked }))}
/>
<span>
<strong></strong>
<span className="muted"> USD </span>
</span>
</label>
<label>
<span>USDCNY</span>
<input
type="number"
min="0.01"
step="0.01"
disabled={envLocked}
value={draft.usdCnyRate}
onChange={(e) => patchNumber('usdCnyRate', e.target.value)}
/>
</label>
<label>
<span></span>
<input
type="number"
min="0.01"
step="0.01"
disabled={envLocked}
value={draft.marginMultiplier}
onChange={(e) => patchNumber('marginMultiplier', e.target.value)}
/>
</label>
<label>
<span></span>
<input
type="number"
min="1"
step="1"
disabled={envLocked}
value={draft.minBillCents}
onChange={(e) => patchNumber('minBillCents', e.target.value)}
/>
</label>
<h3>Token 退</h3>
<label>
<span> / 1k tokens</span>
<input
type="number"
min="0"
step="0.01"
disabled={envLocked}
value={draft.inputCentsPer1k}
onChange={(e) => patchNumber('inputCentsPer1k', e.target.value)}
/>
</label>
<label>
<span> / 1k tokens</span>
<input
type="number"
min="0"
step="0.01"
disabled={envLocked}
value={draft.outputCentsPer1k}
onChange={(e) => patchNumber('outputCentsPer1k', e.target.value)}
/>
</label>
<h3>Finish cost </h3>
<label className="inline-check">
<input
type="checkbox"
checked={draft.costEstimateFromTokens}
disabled={envLocked || !draft.useBackendCost}
onChange={(event) => setDraft((prev) => ({
...prev,
costEstimateFromTokens: event.target.checked,
}))}
/>
<span>
<strong> Token </strong>
<span className="muted"> </span>
</span>
</label>
<label>
<span>USD / 1M</span>
<input
type="number"
min="0"
step="0.01"
disabled={envLocked || !draft.useBackendCost}
value={draft.costEstimateInputUsdPer1M}
onChange={(e) => patchNumber('costEstimateInputUsdPer1M', e.target.value)}
/>
</label>
<label>
<span>USD / 1M</span>
<input
type="number"
min="0"
step="0.01"
disabled={envLocked || !draft.useBackendCost}
value={draft.costEstimateOutputUsdPer1M}
onChange={(e) => patchNumber('costEstimateOutputUsdPer1M', e.target.value)}
/>
</label>
<p className="muted">
USD × {draft.usdCnyRate} × {draft.marginMultiplier}
</p>
<button type="submit" className="send-btn" disabled={saving || envLocked}>
{saving ? '保存中…' : '保存计量公式'}
</button>
</form>
) : null}
</section>
<>
<section className="admin-card">
<h2></h2>
<p className="muted">
A / B A B
</p>
{formulaText ? <p className="muted">{formulaText}</p> : null}
<div className="admin-tabs" role="tablist">
{FORMULA_TABS.map((key) => (
<button
key={key}
type="button"
role="tab"
aria-selected={activeFormula === key}
className={`admin-tab${activeFormula === key ? ' active' : ''}`}
onClick={() => setActiveFormula(key)}
>
{key}
</button>
))}
</div>
{loading ? <p className="muted"></p> : null}
{error && <p className="banner banner-error">{error}</p>}
{message && <p className="banner banner-info">{message}</p>}
{!loading ? (
<FormulaConfigForm
formulaKey={activeFormula}
draft={drafts[activeFormula]}
source={meta[activeFormula].source}
updatedAt={meta[activeFormula].updatedAt}
envLocked={envLocked}
saving={saving}
onDraftChange={(next) => setDrafts((prev) => ({ ...prev, [activeFormula]: next }))}
onSave={handleSave}
/>
) : null}
</section>
<FormulaAssignmentSection />
</>
);
}
@@ -1545,6 +1756,12 @@ function SubscriptionsTab() {
};
const STATUS_LABEL: Record<string, string> = { active: '有效', expired: '已到期', cancelled: '已取消' };
const autoRenewLabel = (row: AdminSubscription) => {
if (!row.autoRenew) return '未开启';
if (row.status === 'active') return '已开启';
if (row.status === 'expired') return '待补扣';
return '—';
};
return (
<>
@@ -1637,6 +1854,7 @@ function SubscriptionsTab() {
<th></th>
<th></th>
<th></th>
<th></th>
<th style={{ textAlign: 'right' }}>Token </th>
<th style={{ textAlign: 'right' }}></th>
<th></th>
@@ -1657,6 +1875,11 @@ function SubscriptionsTab() {
{STATUS_LABEL[row.status] ?? row.status}
</span>
</td>
<td>
<span className={row.autoRenew && row.status === 'expired' ? 'text-error' : undefined}>
{autoRenewLabel(row)}
</span>
</td>
<td className="billing-num">
{row.periodTokensUsed.toLocaleString()}
{row.periodTokensLimit > 0 && (
+624
View File
@@ -0,0 +1,624 @@
import { useCallback, useEffect, useMemo, useState } from 'react';
import { Link } from 'react-router-dom';
import {
getWechatCursorExecutorConfig,
getWechatCursorExecutorRuntime,
listAdminUsers,
patchWechatCursorExecutorConfig,
} from '../../api/client';
import type {
AdminUserRow,
CursorChannelFeatureKey,
CursorChannelFeatures,
WechatCursorExecutorAdminConfig,
WechatCursorExecutorRuntimeState,
} from '../../types';
import { formatTime } from '../utils/format';
type CursorChannelForm = {
enabled: boolean;
h5Enabled: boolean;
wechatEnabled: boolean;
selectedUserIds: string[];
manualAllowlistEntries: string[];
features: CursorChannelFeatures;
fallbackToDeepseek: boolean;
};
const FEATURE_OPTIONS: Array<{
key: CursorChannelFeatureKey;
label: string;
description: string;
}> = [
{
key: 'pageGenerate',
label: '页面生成',
description: 'H5 / 服务号 page.generate 与页面落盘任务走 Cursor。',
},
{
key: 'pageData',
label: '问卷 Page Data',
description: 'H5 问卷收集、PG 持久化与相关分析页走 Cursor。',
},
{
key: 'excelAnalysis',
label: 'Excel 分析',
description: 'H5 表格分析与结果页走 Cursor。',
},
{
key: 'chatBridge',
label: '普通聊天(Chat Bridge',
description: '白名单用户的 Goose 会话 LLM 走 Cursor Chat Bridge;需服务端 MEMIND_CURSOR_CHAT_BRIDGE_ENABLED=1。',
},
{
key: 'scheduledTasks',
label: '定时任务执行',
description: '到点自动任务(新闻/天气等)走 Cursor 而非 Goose Session。',
},
];
function defaultFeatures(): CursorChannelFeatures {
return {
pageGenerate: { enabled: true },
pageData: { enabled: false },
excelAnalysis: { enabled: false },
chatBridge: { enabled: false },
scheduledTasks: { enabled: false },
};
}
function normalizeFeatures(
config: WechatCursorExecutorAdminConfig | undefined,
): CursorChannelFeatures {
const base = defaultFeatures();
const raw = config?.features;
if (raw) {
for (const option of FEATURE_OPTIONS) {
base[option.key] = {
enabled: Boolean(raw[option.key]?.enabled),
};
}
return base;
}
const intents = Array.isArray(config?.intentAllowlist) ? config.intentAllowlist : ['page.generate'];
base.pageGenerate.enabled = intents.includes('page.generate');
return base;
}
const USER_ID_PATTERN =
/^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i;
function userMatchesAllowlistToken(user: AdminUserRow, token: string) {
const normalized = token.trim().toLowerCase();
if (!normalized) return false;
const identities = [user.id, user.username, user.slug, user.publishSlug, user.displayName]
.map((value) => String(value ?? '').trim().toLowerCase())
.filter(Boolean);
return identities.includes(normalized);
}
function resolveAllowlistTokens(tokens: string[], users: AdminUserRow[]) {
const selectedUserIds: string[] = [];
const manualAllowlistEntries: string[] = [];
const seenIds = new Set<string>();
for (const rawToken of tokens) {
const token = String(rawToken ?? '').trim();
if (!token) continue;
const matchedUser = users.find((user) => userMatchesAllowlistToken(user, token));
if (matchedUser) {
if (!seenIds.has(matchedUser.id)) {
seenIds.add(matchedUser.id);
selectedUserIds.push(matchedUser.id);
}
continue;
}
if (USER_ID_PATTERN.test(token)) {
if (!seenIds.has(token)) {
seenIds.add(token);
selectedUserIds.push(token);
}
continue;
}
manualAllowlistEntries.push(token);
}
return { selectedUserIds, manualAllowlistEntries };
}
function configToForm(
config: WechatCursorExecutorAdminConfig | undefined,
users: AdminUserRow[] = [],
): CursorChannelForm {
const tokens = Array.isArray(config?.userAllowlist) ? config.userAllowlist : [];
const channels = Array.isArray(config?.channelAllowlist) ? config.channelAllowlist : ['h5', 'wechat_mp'];
const { selectedUserIds, manualAllowlistEntries } = resolveAllowlistTokens(tokens, users);
return {
enabled: Boolean(config?.enabled),
h5Enabled: channels.includes('h5'),
wechatEnabled: channels.includes('wechat_mp'),
selectedUserIds,
manualAllowlistEntries,
features: normalizeFeatures(config),
fallbackToDeepseek: config?.fallbackToDeepseek !== false,
};
}
function formToAllowlist(form: CursorChannelForm) {
const manual = form.manualAllowlistEntries.map((item) => item.trim()).filter(Boolean);
return [...new Set([...form.selectedUserIds, ...manual])];
}
function formToChannelAllowlist(form: CursorChannelForm) {
const channels: string[] = [];
if (form.h5Enabled) channels.push('h5');
if (form.wechatEnabled) channels.push('wechat_mp');
return channels;
}
function CursorAllowlistPickerModal({
open,
users,
selectedUserIds,
busy,
onClose,
onConfirm,
}: {
open: boolean;
users: AdminUserRow[];
selectedUserIds: string[];
busy?: boolean;
onClose: () => void;
onConfirm: (nextIds: string[]) => void;
}) {
const [search, setSearch] = useState('');
const [draftIds, setDraftIds] = useState<string[]>(selectedUserIds);
const [pickerUsers, setPickerUsers] = useState<AdminUserRow[]>(users);
const [loadingUsers, setLoadingUsers] = useState(false);
useEffect(() => {
if (!open) return;
setDraftIds(selectedUserIds);
setSearch('');
setPickerUsers(users);
}, [open, selectedUserIds, users]);
useEffect(() => {
if (!open) return;
const timer = window.setTimeout(() => {
void (async () => {
setLoadingUsers(true);
try {
const result = await listAdminUsers({
page: 1,
pageSize: 500,
status: 'active',
search: search.trim() || undefined,
});
setPickerUsers(result.items);
} catch {
setPickerUsers(users);
} finally {
setLoadingUsers(false);
}
})();
}, search.trim() ? 250 : 0);
return () => window.clearTimeout(timer);
}, [open, search, users]);
if (!open) return null;
const visibleIds = pickerUsers.map((user) => user.id);
const allVisibleSelected =
visibleIds.length > 0 && visibleIds.every((id) => draftIds.includes(id));
return (
<div
className="modal-backdrop"
role="presentation"
onMouseDown={(event) => {
if (event.target === event.currentTarget) onClose();
}}
>
<div
className="modal-box"
role="dialog"
aria-modal="true"
aria-labelledby="cursor-allowlist-picker-title"
style={{ maxWidth: 720, width: 'min(720px, calc(100vw - 32px))' }}
onMouseDown={(event) => event.stopPropagation()}
>
<div className="modal-head">
<div>
<h3 id="cursor-allowlist-picker-title"></h3>
<p className="muted" style={{ margin: '6px 0 0', fontSize: 13 }}>
TKMind DeepSeek/Goose
</p>
</div>
<button type="button" className="modal-close" onClick={onClose} aria-label="关闭">
×
</button>
</div>
<div className="wechat-toolbar" style={{ marginBottom: 12 }}>
<input
value={search}
onChange={(event) => setSearch(event.target.value)}
placeholder="搜索用户名、昵称或 userId"
style={{ flex: 1, minWidth: 220 }}
autoFocus
/>
<button
type="button"
className="ghost-btn"
disabled={loadingUsers || pickerUsers.length === 0}
onClick={() => {
setDraftIds((current) => {
if (allVisibleSelected) {
return current.filter((id) => !visibleIds.includes(id));
}
return [...new Set([...current, ...visibleIds])];
});
}}
>
{allVisibleSelected ? '取消全选当前列表' : '全选当前列表'}
</button>
</div>
<div className="cursor-allowlist-picker-list">
{loadingUsers ? <p className="muted"></p> : null}
{!loadingUsers && pickerUsers.length === 0 ? (
<p className="muted"></p>
) : null}
{pickerUsers.map((user) => (
<label key={user.id} className="cursor-allowlist-picker-row">
<input
type="checkbox"
checked={draftIds.includes(user.id)}
onChange={() => {
setDraftIds((current) =>
current.includes(user.id)
? current.filter((id) => id !== user.id)
: [...current, user.id],
);
}}
/>
<span>
{user.displayName || user.username}
<span className="muted"> @{user.username}</span>
</span>
</label>
))}
</div>
<div className="modal-actions">
<button type="button" className="ghost-btn" onClick={onClose} disabled={busy}>
</button>
<button
type="button"
className="primary-btn"
disabled={busy}
onClick={() => onConfirm(draftIds)}
>
({draftIds.length})
</button>
</div>
</div>
</div>
);
}
export function CursorChannelPage() {
const [users, setUsers] = useState<AdminUserRow[]>([]);
const [form, setForm] = useState<CursorChannelForm | null>(null);
const [savedForm, setSavedForm] = useState<CursorChannelForm | null>(null);
const [runtime, setRuntime] = useState<WechatCursorExecutorRuntimeState | null>(null);
const [pickerOpen, setPickerOpen] = useState(false);
const [loading, setLoading] = useState(true);
const [saving, setSaving] = useState(false);
const [error, setError] = useState<string | null>(null);
const [notice, setNotice] = useState<string | null>(null);
const dirty = useMemo(() => {
if (!form || !savedForm) return false;
return JSON.stringify(form) !== JSON.stringify(savedForm);
}, [form, savedForm]);
const selectedUsers = useMemo(() => {
if (!form) return [];
const byId = new Map(users.map((user) => [user.id, user]));
return form.selectedUserIds.map((userId) => ({
userId,
user: byId.get(userId) ?? null,
}));
}, [form, users]);
const load = useCallback(async () => {
setLoading(true);
setError(null);
try {
const [nextUsers, nextConfig, nextRuntime] = await Promise.all([
listAdminUsers({ page: 1, pageSize: 200, status: 'active' }),
getWechatCursorExecutorConfig().catch(() => null),
getWechatCursorExecutorRuntime().catch(() => null),
]);
setUsers(nextUsers.items);
const nextForm = configToForm(nextConfig?.config, nextUsers.items);
setForm(nextForm);
setSavedForm(nextForm);
setRuntime(nextRuntime);
} catch (err) {
setError(err instanceof Error ? err.message : '加载失败');
} finally {
setLoading(false);
}
}, []);
useEffect(() => {
void load();
}, [load]);
const handleSave = async () => {
if (!form) return;
setSaving(true);
setError(null);
setNotice(null);
try {
const channelAllowlist = formToChannelAllowlist(form);
if (form.enabled && channelAllowlist.length === 0) {
throw new Error('启用体验通道时,至少选择一个接入渠道(H5 或服务号)');
}
if (form.enabled && formToAllowlist(form).length === 0) {
throw new Error('启用体验通道时,至少选择一名白名单用户');
}
const result = await patchWechatCursorExecutorConfig({
enabled: form.enabled,
userAllowlist: formToAllowlist(form),
channelAllowlist,
features: form.features,
fallbackToDeepseek: form.fallbackToDeepseek,
});
const nextForm = configToForm(result.config, users);
setForm(nextForm);
setSavedForm(nextForm);
setRuntime(await getWechatCursorExecutorRuntime().catch(() => null));
setNotice('TKMind 智趣体验通道已保存。未在白名单内的用户不受影响。');
} catch (err) {
setError(err instanceof Error ? err.message : '保存失败');
} finally {
setSaving(false);
}
};
return (
<div className="admin-page">
<div className="admin-page-head">
<h2>TKMind </h2>
<p className="muted">
DeepSeek/Goose Cursor H5
</p>
</div>
{error && <p className="banner banner-error">{error}</p>}
{notice && <p className="banner banner-info">{notice}</p>}
<section className="admin-card">
<h3></h3>
<ul className="muted" style={{ margin: '8px 0 0', paddingLeft: 20, lineHeight: 1.7 }}>
<li>
<strong></strong>
</li>
<li>
<strong>H5 / </strong> H5 page.generate
</li>
<li>
<strong></strong>Excel Bridge DeepSeek/Goose
</li>
<li> DeepSeek/Goose </li>
</ul>
<p className="muted" style={{ marginTop: 12 }}>
<code>MEMIND_CURSOR_EXECUTOR_ENABLED=1</code> Tool Gateway Memind{' '}
<code>.env.example</code>
</p>
</section>
{form ? (
<section className="admin-card">
<div className="admin-card-head">
<div>
<h2></h2>
<p className="muted" style={{ marginTop: 6 }}>
</p>
</div>
<button
type="button"
className="ghost-btn"
onClick={() => void handleSave()}
disabled={loading || saving || !dirty}
>
{saving ? '保存中…' : dirty ? '保存配置' : '已保存'}
</button>
</div>
<div className="admin-form" style={{ marginTop: 16 }}>
<label>
<input
type="checkbox"
checked={form.enabled}
disabled={loading || saving}
onChange={(event) =>
setForm((current) => current && { ...current, enabled: event.target.checked })
}
/>{' '}
</label>
<fieldset style={{ border: 'none', padding: 0, margin: '12px 0' }}>
<legend className="muted" style={{ marginBottom: 8 }}>
</legend>
<label style={{ display: 'block', marginBottom: 8 }}>
<input
type="checkbox"
checked={form.h5Enabled}
disabled={loading || saving}
onChange={(event) =>
setForm((current) => current && { ...current, h5Enabled: event.target.checked })
}
/>{' '}
H5
</label>
<label style={{ display: 'block' }}>
<input
type="checkbox"
checked={form.wechatEnabled}
disabled={loading || saving}
onChange={(event) =>
setForm((current) => current && { ...current, wechatEnabled: event.target.checked })
}
/>{' '}
</label>
</fieldset>
<label>
<input
type="checkbox"
checked={form.fallbackToDeepseek}
disabled={loading || saving}
onChange={(event) =>
setForm((current) =>
current && { ...current, fallbackToDeepseek: event.target.checked },
)
}
/>{' '}
Cursor 退 DeepSeek / Goose
</label>
<fieldset style={{ border: 'none', padding: 0, margin: '12px 0' }}>
<legend className="muted" style={{ marginBottom: 8 }}>
</legend>
{FEATURE_OPTIONS.map((option) => (
<label key={option.key} style={{ display: 'block', marginBottom: 10 }}>
<input
type="checkbox"
checked={form.features[option.key]?.enabled ?? false}
disabled={loading || saving || !form.enabled}
onChange={(event) =>
setForm((current) =>
current
? {
...current,
features: {
...current.features,
[option.key]: { enabled: event.target.checked },
},
}
: current,
)
}
/>{' '}
<strong>{option.label}</strong>
<span className="muted" style={{ display: 'block', marginLeft: 22, fontSize: 13 }}>
{option.description}
</span>
</label>
))}
</fieldset>
<label>
<div className="wechat-toolbar" style={{ marginTop: 8, marginBottom: 8 }}>
<button
type="button"
className="ghost-btn"
disabled={loading || saving}
onClick={() => setPickerOpen(true)}
>
</button>
{form.selectedUserIds.length > 0 ? (
<button
type="button"
className="ghost-btn"
disabled={loading || saving}
onClick={() =>
setForm((current) => current && { ...current, selectedUserIds: [] })
}
>
</button>
) : null}
</div>
{selectedUsers.length > 0 ? (
<div className="cursor-allowlist-chips">
{selectedUsers.map(({ userId, user }) => (
<span key={userId} className="cursor-allowlist-chip">
<span>
{user ? user.displayName || user.username : userId}
{user ? <span className="muted"> @{user.username}</span> : null}
</span>
<button
type="button"
className="cursor-allowlist-chip-remove"
aria-label="移出白名单"
disabled={loading || saving}
onClick={() =>
setForm((current) =>
current
? {
...current,
selectedUserIds: current.selectedUserIds.filter((id) => id !== userId),
}
: current,
)
}
>
×
</button>
</span>
))}
</div>
) : (
<p className="muted" style={{ margin: 0 }}>
<Link to="/users"></Link>
</p>
)}
</label>
{runtime ? (
<p className="muted" style={{ marginTop: 12 }}>
{runtime.policy.enabled ? '已开启' : '已关闭'}
{' · '}
{runtime.policy.userAllowlist.length}
{' · '}
{(runtime.policy.channelAllowlist ?? []).join('、') || '无'}
{' · '}
{' '}
{FEATURE_OPTIONS.filter((item) => runtime.policy.features?.[item.key]?.enabled)
.map((item) => item.label)
.join('、') || '无'}
{' · '}
{runtime.source}
{runtime.updatedAt ? ` · 更新 ${formatTime(runtime.updatedAt)}` : ''}
</p>
) : null}
</div>
</section>
) : null}
{form ? (
<CursorAllowlistPickerModal
open={pickerOpen}
users={users}
selectedUserIds={form.selectedUserIds}
busy={loading || saving}
onClose={() => setPickerOpen(false)}
onConfirm={(nextIds) => {
setForm((current) => current && { ...current, selectedUserIds: nextIds });
setPickerOpen(false);
}}
/>
) : null}
</div>
);
}
+126 -4
View File
@@ -1,12 +1,27 @@
import { useEffect, useState } from 'react';
import { Link, Navigate, useParams } from 'react-router-dom';
import { getAdminUser, rechargeUser, updateAdminUser, fetchUserImageQuota, setUserImageQuota, fetchAdminTemplateCatalog, grantUserPageTemplate } from '../../api/client';
import {
getAdminUser,
listSubscriptionPlans,
rechargeUser,
updateAdminUser,
fetchUserImageQuota,
setUserImageQuota,
fetchAdminTemplateCatalog,
grantUserPageTemplate,
} from '../../api/client';
import { CapabilitySettings } from '../../components/CapabilitySettings';
import { PolicySettings } from '../../components/PolicySettings';
import { SkillSettings } from '../../components/SkillSettings';
import { useAdminUsers } from '../hooks/useAdminUsers';
import { formatYuan } from '../utils/format';
import type { AdminTemplateCatalogItem, ImageQuotaView, PortalUser } from '../../types';
import { formatTime, formatYuan } from '../utils/format';
import {
formatTokenCount,
formatTokenQuota,
resolvePlanLabel,
subscriptionStatusLabel,
} from '../utils/subscription';
import type { AdminSubscription, AdminTemplateCatalogItem, ImageQuotaView, PlanDefinition, PortalUser } from '../../types';
function formatBytes(bytes: number) {
if (bytes < 1024) return `${bytes} B`;
@@ -18,6 +33,8 @@ export function UserDetailPage() {
const { userId = '' } = useParams();
const { users, reload, setError } = useAdminUsers();
const [user, setUser] = useState<PortalUser | null>(null);
const [subscription, setSubscription] = useState<AdminSubscription | null>(null);
const [plans, setPlans] = useState<PlanDefinition[]>([]);
const [loading, setLoading] = useState(true);
const [error, setLocalError] = useState<string | null>(null);
const [message, setMessage] = useState<string | null>(null);
@@ -42,9 +59,10 @@ export function UserDetailPage() {
setLoading(true);
setLocalError(null);
void getAdminUser(userId)
.then((nextUser) => {
.then(({ user: nextUser, subscription: nextSubscription }) => {
if (cancelled) return;
setUser(nextUser);
setSubscription(nextSubscription);
})
.catch((err) => {
if (cancelled) return;
@@ -64,6 +82,20 @@ export function UserDetailPage() {
};
}, [userId, users]);
useEffect(() => {
let cancelled = false;
void listSubscriptionPlans()
.then((nextPlans) => {
if (!cancelled) setPlans(nextPlans);
})
.catch(() => {
if (!cancelled) setPlans([]);
});
return () => {
cancelled = true;
};
}, []);
useEffect(() => {
if (!user || user.role !== 'user') {
setImageQuota(null);
@@ -173,6 +205,17 @@ export function UserDetailPage() {
: `剩余 ${imageQuota.remaining ?? 0} / 总计 ${imageQuota.total ?? 0}(套餐 ${imageQuota.limit} + 充值 ${imageQuota.bonus},已用 ${imageQuota.used}`
: '';
const activePlanType = subscription?.planType ?? user?.planType ?? 'free';
const planLabel = resolvePlanLabel(activePlanType, plans);
const tokenLimit = subscription?.periodTokensLimit ?? 0;
const tokenUsed = subscription?.periodTokensUsed ?? 0;
const tokenRemaining = tokenLimit === 0 ? null : Math.max(0, tokenLimit - tokenUsed);
const tokenQuotaSummary = subscription
? formatTokenQuota(tokenLimit, tokenUsed)
: activePlanType !== 'free'
? '无有效订阅记录'
: '免费用户,无套餐额度';
const handleTemplateGrant = async (skillName: string) => {
if (!user) return;
setMessage(null);
@@ -273,6 +316,46 @@ export function UserDetailPage() {
)}
</dd>
</div>
<div>
<dt></dt>
<dd>
<select
className="admin-select"
value={user.billingFormula ?? 'A'}
onChange={(event) => {
const billingFormula = event.target.value as 'A' | 'B';
setLocalError(null);
void updateAdminUser(user.id, { billingFormula }).then((nextUser) => {
setUser(nextUser);
setMessage(`已切换到计量公式 ${billingFormula}`);
void reload();
}).catch((err) => {
setLocalError(err instanceof Error ? err.message : '计量公式更新失败');
});
}}
>
<option value="A"> A</option>
<option value="B"> B</option>
</select>
</dd>
</div>
<div>
<dt></dt>
<dd>
{planLabel}
{subscription && (
<span className="muted">
{' '}
· {subscriptionStatusLabel(subscription.status)}
{subscription.expiresAt ? ` · 到期 ${formatTime(subscription.expiresAt)}` : ''}
</span>
)}
</dd>
</div>
<div>
<dt>Token </dt>
<dd>{tokenQuotaSummary}</dd>
</div>
<div>
<dt></dt>
<dd className="mono">{user.workspaceRoot}</dd>
@@ -282,6 +365,45 @@ export function UserDetailPage() {
{user.role === 'user' && (
<>
<section className="admin-card">
<h2> Token </h2>
<dl className="admin-dl">
<div>
<dt></dt>
<dd>
{planLabel}
<span className="muted mono"> ({activePlanType})</span>
</dd>
</div>
<div>
<dt></dt>
<dd>{subscription ? subscriptionStatusLabel(subscription.status) : '无有效订阅'}</dd>
</div>
<div>
<dt></dt>
<dd>{subscription?.expiresAt ? formatTime(subscription.expiresAt) : '—'}</dd>
</div>
<div>
<dt>Token </dt>
<dd>{tokenLimit === 0 ? '无限' : formatTokenCount(tokenLimit)}</dd>
</div>
<div>
<dt>Token </dt>
<dd>{formatTokenCount(tokenUsed)}</dd>
</div>
<div>
<dt>Token </dt>
<dd>{tokenRemaining == null ? '无限' : formatTokenCount(tokenRemaining)}</dd>
</div>
</dl>
<p className="muted">
{' '}
<Link to="/billing/subscriptions"> · </Link>
</p>
</section>
<section className="admin-card">
<h2></h2>
<form className="admin-form" onSubmit={handleRecharge}>
+16 -2
View File
@@ -1,10 +1,11 @@
import { useCallback, useEffect, useState } from 'react';
import { Link } from 'react-router-dom';
import { createAdminUser, listAdminUsers, updateAdminUser } from '../../api/client';
import { createAdminUser, listAdminUsers, listSubscriptionPlans, updateAdminUser } from '../../api/client';
import type { PagedResult } from '../../api/client';
import type { AdminUserRow } from '../../types';
import type { AdminUserRow, PlanDefinition } from '../../types';
import { Pagination } from '../../components/Pagination';
import { formatYuan } from '../utils/format';
import { resolvePlanLabel, summarizeSubscription } from '../utils/subscription';
const PAGE_SIZE = 20;
@@ -25,6 +26,7 @@ export function UsersPage() {
const [pending, setPending] = useState({ search: '', role: '', status: '' });
const [showCreate, setShowCreate] = useState(false);
const [plans, setPlans] = useState<PlanDefinition[]>([]);
const [newUser, setNewUser] = useState({ username: '', password: '', displayName: '', workspaceRoot: '', balanceCents: 500 });
const [creating, setCreating] = useState(false);
@@ -46,6 +48,12 @@ export function UsersPage() {
// eslint-disable-next-line react-hooks/exhaustive-deps
}, []);
useEffect(() => {
void listSubscriptionPlans()
.then(setPlans)
.catch(() => setPlans([]));
}, []);
const handleQuery = () => {
setCommitted(pending);
void load(1, pending);
@@ -171,6 +179,8 @@ export function UsersPage() {
<th></th>
<th></th>
<th></th>
<th></th>
<th>Token </th>
<th></th>
<th></th>
<th></th>
@@ -190,6 +200,10 @@ export function UsersPage() {
{user.status === 'active' ? '正常' : user.status === 'disabled' ? '禁用' : '封禁'}
</span>
</td>
<td>{resolvePlanLabel(user.subscription?.planType ?? user.planType ?? 'free', plans)}</td>
<td className="billing-num">
{summarizeSubscription(user.subscription, user.planType)}
</td>
<td className="billing-num">¥{formatYuan(user.balanceCents)}</td>
<td className="billing-num">
{user.spaceQuotaBytes
+13
View File
@@ -1,4 +1,5 @@
import { useCallback, useEffect, useMemo, useState } from 'react';
import { Link } from 'react-router-dom';
import {
cancelWechatDigest,
clearWechatRoute,
@@ -559,6 +560,18 @@ export function WechatPage() {
</section>
) : null}
<section className="admin-card">
<h2>TKMind </h2>
<p className="muted" style={{ marginTop: 6 }}>
Cursor H5
</p>
<p style={{ marginTop: 12 }}>
<Link to="/cursor-channel" className="ghost-btn">
</Link>
</p>
</section>
<section className="admin-card">
<div className="admin-card-head">
<h2></h2>
+36
View File
@@ -0,0 +1,36 @@
import type { AdminSubscription, PlanDefinition, UserSubscriptionSummary } from '../../types';
export function formatTokenCount(value: number) {
return value.toLocaleString('zh-CN');
}
export function formatTokenQuota(limit: number, used: number) {
if (limit === 0) {
return `已用 ${formatTokenCount(used)} / 无限`;
}
const remaining = Math.max(0, limit - used);
return `${formatTokenCount(remaining)} / ${formatTokenCount(limit)}(已用 ${formatTokenCount(used)}`;
}
export function resolvePlanLabel(planType: string, plans: PlanDefinition[]) {
return plans.find((plan) => plan.planType === planType)?.name ?? planType;
}
export function subscriptionStatusLabel(status: AdminSubscription['status']) {
if (status === 'active') return '有效';
if (status === 'expired') return '已到期';
if (status === 'cancelled') return '已取消';
return status;
}
export function summarizeSubscription(
subscription: Pick<UserSubscriptionSummary, 'planType' | 'periodTokensLimit' | 'periodTokensUsed'> | null | undefined,
fallbackPlanType?: string,
) {
if (!subscription) {
return fallbackPlanType && fallbackPlanType !== 'free'
? `${fallbackPlanType}(无有效订阅)`
: '免费 / 无订阅';
}
return formatTokenQuota(subscription.periodTokensLimit, subscription.periodTokensUsed);
}
+41 -6
View File
@@ -58,6 +58,9 @@ import type {
WechatIntentRouterAdminConfig,
WechatIntentRouterConfigState,
WechatIntentRouterRuntimeState,
WechatCursorExecutorAdminConfig,
WechatCursorExecutorAdminConfigState,
WechatCursorExecutorRuntimeState,
WechatMessage,
WechatWebNotification,
MindSearchConfig,
@@ -474,6 +477,23 @@ export async function getWechatIntentRouterRuntime(): Promise<WechatIntentRouter
return portalFetch<WechatIntentRouterRuntimeState>('/admin-api/wechat/intent-router/runtime');
}
export async function getWechatCursorExecutorConfig(): Promise<WechatCursorExecutorAdminConfigState> {
return portalFetch<WechatCursorExecutorAdminConfigState>('/admin-api/cursor-executor-channel/config');
}
export async function patchWechatCursorExecutorConfig(
patch: Partial<WechatCursorExecutorAdminConfig>,
): Promise<WechatCursorExecutorAdminConfigState> {
return portalFetch<WechatCursorExecutorAdminConfigState>('/admin-api/cursor-executor-channel/config', {
method: 'PATCH',
body: JSON.stringify({ config: patch }),
});
}
export async function getWechatCursorExecutorRuntime(): Promise<WechatCursorExecutorRuntimeState> {
return portalFetch<WechatCursorExecutorRuntimeState>('/admin-api/cursor-executor-channel/runtime');
}
export async function getAssetGatewayConfig(): Promise<AssetGatewayConfig> {
return portalFetch('/admin-api/asset-gateway/config');
}
@@ -857,9 +877,11 @@ export async function listAdminUsers(params?: {
return { items: result.users ?? [], total, page: result.page ?? 1, pageSize, totalPages: Math.ceil(total / pageSize) };
}
export async function getAdminUser(userId: string): Promise<PortalUser> {
const result = await portalFetch<{ user: PortalUser }>(`/admin-api/users/${userId}`);
return result.user;
export async function getAdminUser(userId: string): Promise<{ user: PortalUser; subscription: AdminSubscription | null }> {
const result = await portalFetch<{ user: PortalUser; subscription?: AdminSubscription | null }>(
`/admin-api/users/${userId}`,
);
return { user: result.user, subscription: result.subscription ?? null };
}
export async function createAdminUser(payload: {
@@ -887,6 +909,7 @@ export async function updateAdminUser(
balanceCents: number;
spaceQuotaBytes: number;
role: 'user' | 'admin';
billingFormula: 'A' | 'B';
}>,
): Promise<PortalUser> {
const result = await portalFetch<{ user: PortalUser }>(`/admin-api/users/${userId}`, {
@@ -1409,16 +1432,28 @@ export async function syncSubscriptionPlansToProduction(): Promise<PlanSyncResul
return result.sync;
}
export async function getBillingConfig(): Promise<BillingAdminConfigResponse> {
return portalFetch('/admin-api/billing/config');
export async function getBillingConfig(formula: 'A' | 'B' = 'A'): Promise<BillingAdminConfigResponse> {
const q = formula === 'B' ? '?formula=B' : '';
return portalFetch(`/admin-api/billing/config${q}`);
}
export async function updateBillingConfig(
config: BillingAdminConfig,
formula: 'A' | 'B' = 'A',
): Promise<BillingAdminConfigResponse> {
return portalFetch('/admin-api/billing/config', {
method: 'PUT',
body: JSON.stringify({ config }),
body: JSON.stringify({ config, formula }),
});
}
export async function assignBillingFormula(
userIds: string[],
formula: 'A' | 'B',
): Promise<{ ok: boolean; updated: number; formula: 'A' | 'B'; message?: string }> {
return portalFetch('/admin-api/billing/formula-assignments', {
method: 'POST',
body: JSON.stringify({ userIds, formula }),
});
}
+31
View File
@@ -879,6 +879,37 @@ body,
padding-top: 4px;
}
.cursor-allowlist-chips {
display: flex;
flex-wrap: wrap;
gap: 8px;
}
.cursor-allowlist-chip {
display: inline-flex;
align-items: center;
gap: 8px;
padding: 6px 10px;
border: 1px solid var(--color-border-input, #e7dfd1);
border-radius: 999px;
background: var(--color-bg-subtle, rgba(0, 0, 0, 0.02));
font-size: 13px;
}
.cursor-allowlist-chip-remove {
border: 0;
background: transparent;
color: var(--color-text-muted, #68716c);
cursor: pointer;
font-size: 16px;
line-height: 1;
padding: 0 2px;
}
.cursor-allowlist-chip-remove:hover {
color: var(--color-text, #1f2421);
}
.global-model-card {
margin-bottom: 16px;
padding: 14px;
+71
View File
@@ -18,6 +18,7 @@ export type PortalUser = {
balanceCents: number;
totalCreditCents?: number;
tokensUsed: number;
billingFormula?: 'A' | 'B';
spaceQuotaBytes?: number;
spaceUsedBytes?: number;
spaceReservedBytes?: number;
@@ -43,7 +44,17 @@ export type AuthStatus = {
unrestricted?: boolean;
};
export type UserSubscriptionSummary = {
planType: string;
status: 'active' | 'expired' | 'cancelled';
periodTokensLimit: number;
periodTokensUsed: number;
expiresAt: number;
};
export type AdminUserRow = PortalUser & {
billingFormula?: 'A' | 'B';
subscription?: UserSubscriptionSummary | null;
createdAt: number;
updatedAt: number;
};
@@ -344,6 +355,53 @@ export type WechatIntentRouterRuntimeState = {
config: WechatIntentRouterAdminConfig;
};
export type CursorChannelFeatureKey =
| 'pageGenerate'
| 'pageData'
| 'excelAnalysis'
| 'chatBridge'
| 'scheduledTasks';
export type CursorChannelFeatures = Record<
CursorChannelFeatureKey,
{ enabled: boolean }
>;
export type WechatCursorExecutorAdminConfig = {
enabled: boolean;
userAllowlist: string[];
channelAllowlist: string[];
intentAllowlist: string[];
features?: CursorChannelFeatures;
fallbackToDeepseek: boolean;
meta?: {
notes?: string;
};
};
export type WechatCursorExecutorAdminConfigState = {
config: WechatCursorExecutorAdminConfig;
updatedAt?: number | null;
updatedBy?: string | null;
source?: string;
};
export type WechatCursorExecutorRuntimeState = {
source: string;
updatedAt: number | null;
updatedBy: string | null;
config: WechatCursorExecutorAdminConfig;
policy: {
enabled: boolean;
userAllowlist: string[];
channelAllowlist: string[];
intentAllowlist: string[];
features?: CursorChannelFeatures;
fallbackToDeepseek: boolean;
source?: string;
};
};
export type MindSpaceSeoGeoConfig = {
enabled: boolean;
seo: {
@@ -676,8 +734,20 @@ export type BillingAdminConfig = {
costEstimateOutputUsdPer1M: number;
};
export type BillingFormulaKey = 'A' | 'B';
export type BillingFormulaMeta = {
updatedAt: number | null;
updatedBy: string | null;
source?: string;
};
export type BillingAdminConfigResponse = {
config: BillingAdminConfig;
formulas?: Record<BillingFormulaKey, BillingAdminConfig>;
formulaMeta?: Record<BillingFormulaKey, BillingFormulaMeta>;
activeFormula?: BillingFormulaKey;
defaultFormula?: BillingFormulaKey;
updatedAt: number | null;
updatedBy: string | null;
source?: string;
@@ -722,6 +792,7 @@ export type AdminSubscription = {
periodImagesLimit: number;
periodImagesUsed: number;
periodImagesBonus?: number;
autoRenew?: boolean;
note: string | null;
createdAt: number;
};