Compare commits

..

3 Commits

Author SHA1 Message Date
linkeyu 0f921f9e16 fix: 按统一口径展示逐平台比价状态 2026-08-01 10:23:15 +08:00
linkeyu 0c75c4f65a fix: 补齐比价状态展示映射 2026-08-01 09:55:39 +08:00
linkeyu ca7c3f27f0 功能:新增统一限制白名单管理页面 (#99)
## 需求背景
新增统一白名单管理页面,让运营人员能够查看和调整全局限制,并按手机号或设备批量配置临时不限或风险免告警。

## 主要改动
- 新增白名单导航与完整管理页面
- 全局限制按五类分页展示并支持修改
- 白名单按主体聚合,展示各分类数量及悬浮明细
- 支持手机号与设备搜索、批量多选限制项和统一有效期
- 支持手动筛选、十条分页、主体点击编辑及启用开关
- 风控监控增加快捷加入白名单入口
- 旧引导视频配置页与统一限制入口保持一致

## 验证
- Next.js 生产构建通过
- TypeScript 类型检查通过
- 共 26 个页面完成静态/动态构建
- 已与后端 PR #207 配套验证

---------

Co-authored-by: linkeyu <798648091@qq.com>
Reviewed-on: #99
Co-authored-by: linkeyu <linkeyu@wonderable.ai>
Co-committed-by: linkeyu <linkeyu@wonderable.ai>
2026-07-31 17:08:13 +08:00
10 changed files with 1520 additions and 160 deletions
+1 -1
View File
@@ -3,7 +3,7 @@
"version": "0.1.0",
"private": true,
"scripts": {
"dev": "next dev -p 3002",
"dev": "next dev -p 3001",
"build": "next build",
"start": "next start -p 3001",
"lint": "next lint"
+203 -17
View File
@@ -19,18 +19,153 @@ import type {
const { RangePicker } = DatePicker;
const STATUS_COLOR: Record<string, string> = { success: 'green', failed: 'red', cancelled: 'default' };
const STATUS_LABEL: Record<string, string> = { success: '成功', failed: '失败', cancelled: '中途退出' };
// 「卡在哪一步」: platform_results[*].status 翻成人话(找店/加菜/起送/读价)
const STUCK_LABEL: Record<string, string> = {
success: '成功',
store_not_found: '没找到店',
items_not_found: '菜没匹配上',
below_minimum: '未达起送',
unsupported: '平台不支持',
failed: '失败',
// 主状态只对外呈现生命周期口径;below_minimum/store_closed 是迁移前历史兼容值。
const STATUS_COLOR: Record<string, string> = {
success: 'green',
below_minimum: 'green',
failed: 'red',
store_closed: 'red',
store_not_found: 'red',
items_not_found: 'red',
no_delivery: 'red',
unsupported: 'red',
cancelled: 'default',
running: 'blue',
};
const STATUS_LABEL: Record<string, string> = {
success: '成功',
below_minimum: '成功',
failed: '失败',
store_closed: '失败',
store_not_found: '失败',
items_not_found: '失败',
no_delivery: '失败',
unsupported: '失败',
cancelled: '中途退出',
running: '进行中',
};
type PlatformResultRow = Record<string, unknown> & {
platform_id?: string;
platform_name?: string;
status?: string;
reason?: string;
};
function isRecord(value: unknown): value is Record<string, unknown> {
return value != null && typeof value === 'object' && !Array.isArray(value);
}
function platformResultRows(
platforms: Record<string, unknown>[] | null | undefined,
rawPayload: Record<string, unknown> | null | undefined,
): PlatformResultRow[] {
if ((platforms?.length ?? 0) > 0) return platforms as PlatformResultRow[];
const rawPlatforms = rawPayload?.platforms;
if (Array.isArray(rawPlatforms)) {
const rows = rawPlatforms.filter(isRecord) as PlatformResultRow[];
if (rows.length > 0) return rows;
}
// 灰度期旧记录没有 platforms,才回退 platform_results。这里的 success/source 是旧枚举,
// 展示时兼容折算为逐平台成功态 ok。
const resultValue = rawPayload?.platform_results;
if (Array.isArray(resultValue)) return resultValue.filter(isRecord) as PlatformResultRow[];
if (isRecord(resultValue)) {
return Object.entries(resultValue).flatMap(([platformId, result]) => (
isRecord(result) ? [{ platform_id: platformId, ...result } as PlatformResultRow] : []
));
}
return [];
}
function stringList(value: unknown): string[] {
return Array.isArray(value) ? value.filter((item): item is string => typeof item === 'string') : [];
}
function hasDishDiff(row: PlatformResultRow): boolean {
if (typeof row.has_dish_diff === 'boolean') return row.has_dish_diff;
const items = Array.isArray(row.items) ? row.items.filter(isRecord) : [];
return items.some((item) => item.similar === true)
|| stringList(row.approx_dish_names).length > 0
|| stringList(row.skipped_dish_names).length > 0
|| Number(row.skipped_dish_count || 0) > 0;
}
type PlatformDisplay = {
label: string;
color: string;
rawStatus: string;
category: string;
dishDiff: boolean;
fallbackReason: string;
};
function platformDisplay(row: PlatformResultRow): PlatformDisplay {
const rawStatus = typeof row.status === 'string' && row.status ? row.status : 'unknown';
const legacySource = rawStatus === 'source';
const normalizedStatus = rawStatus === 'success' || legacySource ? 'ok' : rawStatus;
const dishDiff = hasDishDiff(row);
if (normalizedStatus === 'ok') {
const isSource = row.role === 'source' || row.is_user_original === true || legacySource;
const isLowest = row.is_best === true && !dishDiff;
return {
label: '成功',
color: 'green',
rawStatus,
category: isLowest ? '#1 全网最低赢家' : isSource ? '#2 原选择' : '#3 其他成功',
dishDiff,
fallbackReason: dishDiff ? '已比出价格,但存在菜品差异,仅供参考' : '已成功比出价格',
};
}
const known: Record<string, Omit<PlatformDisplay, 'rawStatus' | 'dishDiff'>> = {
below_minimum: { label: '未满起送', color: 'gold', category: '#5 未满起送', fallbackReason: '购物车未达到起送门槛' },
store_closed: { label: '门店打烊', color: 'orange', category: '#6 门店打烊', fallbackReason: '门店当前已打烊,无法比价' },
items_not_found: { label: '商品未找到', color: 'orange', category: '#7 没有您点的商品', fallbackReason: '该店没有找到本次所选商品' },
store_not_found: { label: '店铺未找到', color: 'orange', category: '#8 无对应商家', fallbackReason: '未找到可对应的商家' },
failed: { label: '比价失败', color: 'red', category: '#9 失败兜底', fallbackReason: '本平台比价流程未完成' },
unsupported: { label: '比价失败', color: 'red', category: '#9 失败兜底', fallbackReason: '当前版本暂不支持该平台' },
no_delivery: { label: '单点不配送', color: 'orange', category: '表外 · 单点不配送', fallbackReason: '所选商品不支持单点配送' },
not_installed: { label: '未安装', color: 'default', category: '#10 端侧本地 · 未安装', fallbackReason: '该状态仅由 App 端根据装机情况补齐' },
not_compared_this_time: { label: '本次未比', color: 'default', category: '#11 端侧本地 · 未选择', fallbackReason: '该状态仅由 App 端根据本次勾选情况补齐' },
};
const mapped = known[normalizedStatus];
if (mapped) return { ...mapped, rawStatus, dishDiff: false };
return {
label: '比价失败',
color: 'red',
rawStatus,
category: '#9 未知状态兜底',
dishDiff: false,
fallbackReason: `端侧未识别状态 ${rawStatus},按比价失败兜底`,
};
}
function dishDiffSummary(row: PlatformResultRow): string | null {
if (!hasDishDiff(row)) return null;
const parts: string[] = [];
const items = Array.isArray(row.items) ? row.items.filter(isRecord) : [];
const similarPairs = items
.filter((item) => item.similar === true && typeof item.name === 'string')
.map((item) => (typeof item.orig === 'string' ? `${item.orig}${item.name}` : String(item.name)));
if (similarPairs.length) parts.push(`近似替换:${similarPairs.join('、')}`);
const approx = stringList(row.approx_dish_names);
if (approx.length) parts.push(`规格近似:${approx.join('、')}`);
const skipped = stringList(row.skipped_dish_names);
if (skipped.length) parts.push(`完全缺失:${skipped.join('、')}`);
if (!skipped.length && Number(row.skipped_dish_count || 0) > 0) {
parts.push(`缺少 ${Number(row.skipped_dish_count)} 个菜品`);
}
return parts.join('') || '存在菜品差异';
}
function complexSpecSummary(row: PlatformResultRow): string | null {
const names = stringList(row.complex_spec_dish_names);
return names.length > 0 ? `复杂规格需核对:${names.join('、')}` : null;
}
const fmtMs = (ms: number | null) => (ms == null ? '-' : `${(ms / 1000).toFixed(1)}s`);
const cents = (c: number | null) => (c == null ? '-' : yuan(c));
@@ -369,8 +504,7 @@ export default function ComparisonRecordsPage() {
},
];
const platformResults =
(detail?.raw_payload?.platform_results as Record<string, unknown>[] | undefined) || [];
const platformResults = platformResultRows(detail?.platforms, detail?.raw_payload);
return (
<div>
@@ -423,6 +557,7 @@ export default function ComparisonRecordsPage() {
{ value: 'success', label: '成功' },
{ value: 'failed', label: '失败' },
{ value: 'cancelled', label: '中途退出' },
{ value: 'running', label: '进行中' },
]}
/>
<Button type="primary" onClick={search}></Button>
@@ -579,16 +714,67 @@ export default function ComparisonRecordsPage() {
)}
{platformResults.length > 0 && (
<Card size="small" title="逐平台结局(卡在哪一步)">
<Card size="small" title="逐平台结果卡片判定">
<Typography.Paragraph type="secondary" style={{ marginBottom: 12 }}>
platforms[].status=ok is_bestrolehas_dish_diff #10 #11
App
</Typography.Paragraph>
<Table
size="small"
rowKey={(_, i) => String(i)}
pagination={false}
dataSource={platformResults}
scroll={{ x: 1050 }}
columns={[
{ title: '平台', dataIndex: 'platform_name', render: (v, r: Record<string, unknown>) => (v as string) || (r.platform_id as string) || '-' },
{ title: '结局', dataIndex: 'status', render: (s: string) => <Tag color={s === 'success' ? 'green' : 'orange'}>{STUCK_LABEL[s] || s || '-'}</Tag> },
{ title: '说明', dataIndex: 'reason', render: (v) => (v as string) || '-' },
{
title: '平台', dataIndex: 'platform_name', width: 150,
render: (v, r: PlatformResultRow) => (v as string) || r.platform_id || '-',
},
{
title: '逐平台状态', dataIndex: 'status', width: 135,
render: (_, r: PlatformResultRow) => {
const display = platformDisplay(r);
return (
<Space direction="vertical" size={0}>
<Tag color={display.color}>{display.label}</Tag>
<Typography.Text type="secondary" code>{display.rawStatus}</Typography.Text>
</Space>
);
},
},
{
title: '卡片分类', key: 'category', width: 210,
render: (_, r: PlatformResultRow) => {
const display = platformDisplay(r);
const hasComplexSpec = complexSpecSummary(r) != null;
return (
<Space size={[4, 4]} wrap>
<Tag color={display.color}>{display.category}</Tag>
{display.dishDiff ? <Tag color="gold">#4 </Tag> : null}
{hasComplexSpec ? <Tag color="blue"></Tag> : null}
</Space>
);
},
},
{
title: '价格', dataIndex: 'price', width: 90,
render: (v) => (typeof v === 'number' ? `¥${v.toFixed(2)}` : '-'),
},
{
title: '说明 / 判定字段', key: 'reason',
render: (_, r: PlatformResultRow) => {
const display = platformDisplay(r);
const diff = dishDiffSummary(r);
const complexSpec = complexSpecSummary(r);
return (
<Space direction="vertical" size={0}>
<span>{typeof r.reason === 'string' && r.reason ? r.reason : display.fallbackReason}</span>
{diff ? <Typography.Text type="warning">{diff}</Typography.Text> : null}
{complexSpec ? <Typography.Text type="secondary">{complexSpec}</Typography.Text> : null}
</Space>
);
},
},
]}
/>
</Card>
+83 -110
View File
@@ -2,12 +2,9 @@
import { useEffect, useState } from 'react';
import {
Alert,
Button,
Card,
Descriptions,
InputNumber,
Popconfirm,
Space,
Spin,
Switch,
@@ -24,10 +21,6 @@ import type { GuideVideoConfig as GuideCfg } from '@/lib/types';
const { Text } = Typography;
const MAX_BYTES = 100 * 1024 * 1024;
const MIN_PLAYS = 1;
const MAX_PLAYS = 50;
const MIN_REWARD_COIN = 10;
const MAX_REWARD_COIN = 10000;
type Scene = 'coupon' | 'comparison';
const META: Record<Scene, { title: string; action: string }> = {
@@ -35,29 +28,16 @@ const META: Record<Scene, { title: string; action: string }> = {
comparison: { title: '开始比价引导视频', action: '开始比价' },
};
function formatDuration(durationMs: number | null | undefined) {
if (durationMs == null || !Number.isFinite(durationMs)) return '—';
return `${(durationMs / 1000).toFixed(3).replace(/\.?0+$/, '')}`;
}
function SceneConfig({ scene }: { scene: Scene }) {
const meta = META[scene];
const [cfg, setCfg] = useState<GuideCfg | null>(null);
const [loading, setLoading] = useState(true);
const [saving, setSaving] = useState(false);
const [uploading, setUploading] = useState(false);
const [enabled, setEnabled] = useState(false);
const [enabled, setEnabled] = useState(true);
const [maxPlays, setMaxPlays] = useState(3);
const [rewardCoin, setRewardCoin] = useState(100);
const canEdit = canDo(['operator']);
const configValid =
Number.isInteger(maxPlays) &&
maxPlays >= MIN_PLAYS &&
maxPlays <= MAX_PLAYS &&
Number.isInteger(rewardCoin) &&
rewardCoin >= MIN_REWARD_COIN &&
rewardCoin <= MAX_REWARD_COIN &&
rewardCoin % 10 === 0;
const sync = (value: GuideCfg) => {
setCfg(value);
@@ -69,7 +49,9 @@ function SceneConfig({ scene }: { scene: Scene }) {
const load = async () => {
setLoading(true);
try {
const { data } = await api.get<GuideCfg>('/admin/api/guide-video', { params: { scene } });
const { data } = await api.get<GuideCfg>('/admin/api/guide-video', {
params: { scene },
});
sync(data);
} catch (e) {
message.error(errMsg(e));
@@ -83,15 +65,15 @@ function SceneConfig({ scene }: { scene: Scene }) {
}, [scene]);
const save = async () => {
if (!configValid) {
message.error('请检查配置:播放次数为 1~50,每次金币为 10~10000 且必须是 10 的倍数');
return;
}
setSaving(true);
try {
const { data } = await api.patch<GuideCfg>(
'/admin/api/guide-video',
{ enabled, max_plays: maxPlays, reward_coin: rewardCoin },
{
enabled,
reward_coin: rewardCoin,
...(scene === 'comparison' ? { max_plays: maxPlays } : {}),
},
{ params: { scene } },
);
sync(data);
@@ -116,7 +98,7 @@ function SceneConfig({ scene }: { scene: Scene }) {
sync(data);
message.success(`${meta.title}已更新`);
} catch (e) {
message.error(`${errMsg(e)},原视频和配置未改变`);
message.error(errMsg(e));
} finally {
setUploading(false);
}
@@ -124,7 +106,7 @@ function SceneConfig({ scene }: { scene: Scene }) {
const beforeUpload = (file: File) => {
if (file.type !== 'video/mp4' && !/\.mp4$/i.test(file.name)) {
message.error('仅支持 MP4 视频(H.264 或 HEVC/H.265 编码)');
message.error('仅支持 MP4 视频(H.264 编码)');
return Upload.LIST_IGNORE;
}
if (file.size > MAX_BYTES) {
@@ -156,11 +138,20 @@ function SceneConfig({ scene }: { scene: Scene }) {
size="small"
title={meta.title}
style={{ marginBottom: 16 }}
extra={cfg?.updated_at ? <Text type="secondary"> {new Date(cfg.updated_at).toLocaleString('zh-CN')}</Text> : null}
extra={
cfg?.updated_at ? (
<Text type="secondary">
{new Date(cfg.updated_at).toLocaleString('zh-CN')}
</Text>
) : null
}
>
<p style={{ color: '#777', marginTop: 0 }}>
Android {meta.action}
1/10 1/10 退
Android {meta.action} {cfg?.max_plays ?? 3}{' '}
广
{scene === 'coupon' &&
'领券引导视频的播放次数上限请在「监控审计 → 限制策略」中调整。'}
</p>
{loading || !cfg ? (
<Spin style={{ display: 'block', margin: '24px 0' }} />
@@ -172,115 +163,97 @@ function SceneConfig({ scene }: { scene: Scene }) {
<video
src={mediaUrl(cfg.video_url)}
controls
style={{ width: 240, maxHeight: 420, borderRadius: 12, background: '#000' }}
style={{
width: 240,
maxHeight: 420,
borderRadius: 12,
background: '#000',
}}
/>
) : (
<div style={{ height: 280, border: '1px dashed #d9d9d9', borderRadius: 12, display: 'grid', placeItems: 'center', color: '#aaa' }}>
<div
style={{
height: 280,
border: '1px dashed #d9d9d9',
borderRadius: 12,
display: 'grid',
placeItems: 'center',
color: '#aaa',
}}
>
</div>
)}
</div>
<Space direction="vertical" size="middle" style={{ minWidth: 390 }}>
{cfg.analysis_status === 'invalid' || cfg.analysis_error ? (
<Alert
type="error"
showIcon
message="视频分析异常,当前场景不可启用"
description={cfg.analysis_error || '请重新上传符合要求的视频'}
/>
) : null}
<Space>
<span></span>
<Switch
checked={enabled}
disabled={!canEdit || (!enabled && cfg.analysis_status !== 'valid')}
disabled={!canEdit}
onChange={setEnabled}
/>
{!enabled && <Tag color="orange"></Tag>}
{!enabled && cfg.analysis_status !== 'valid' && <Text type="secondary"></Text>}
</Space>
{scene === 'comparison' && (
<Space>
<span></span>
<InputNumber
min={0}
max={50}
precision={0}
value={maxPlays}
disabled={!canEdit}
onChange={(value) => setMaxPlays(value ?? 0)}
/>
<Text type="secondary"> N 3</Text>
</Space>
)}
<Space>
<span></span>
<span></span>
<InputNumber
min={MIN_PLAYS}
max={MAX_PLAYS}
min={0}
max={10000}
precision={0}
status={maxPlays < MIN_PLAYS || maxPlays > MAX_PLAYS ? 'error' : undefined}
value={maxPlays}
disabled={!canEdit}
onChange={(v) => setMaxPlays(v ?? MIN_PLAYS)}
/>
<Text type="secondary"> 150 3</Text>
</Space>
<Space>
<span></span>
<InputNumber
min={MIN_REWARD_COIN}
max={MAX_REWARD_COIN}
step={10}
precision={0}
status={
rewardCoin < MIN_REWARD_COIN ||
rewardCoin > MAX_REWARD_COIN ||
rewardCoin % 10 !== 0
? 'error'
: undefined
}
value={rewardCoin}
disabled={!canEdit}
onChange={(v) => setRewardCoin(v ?? MIN_REWARD_COIN)}
onChange={(value) => setRewardCoin(value ?? 0)}
/>
<Text type="secondary">1010000 10 100</Text>
<Text type="secondary"> 100</Text>
</Space>
{cfg.video_url ? (
<Descriptions size="small" bordered column={2}>
<Descriptions.Item label="总时长">{formatDuration(cfg.duration_ms)}</Descriptions.Item>
<Descriptions.Item label="单圈时长">
{formatDuration(cfg.circle_duration_ms ?? (cfg.duration_ms == null ? null : cfg.duration_ms / 10))}
</Descriptions.Item>
<Descriptions.Item label="单圈金币">
{rewardCoin === cfg.reward_coin ? cfg.reward_per_circle : rewardCoin / cfg.circle_count}
</Descriptions.Item>
<Descriptions.Item label="编码">
{cfg.video_codec || '—'} / {cfg.audio_codec || '无'}
</Descriptions.Item>
<Descriptions.Item label="分析状态" span={2}>
<Tag color={cfg.analysis_status === 'valid' ? 'green' : 'orange'}>
{cfg.analysis_status === 'valid'
? '分析完成'
: cfg.analysis_status === 'invalid'
? '分析异常'
: '未上传'}
</Tag>
</Descriptions.Item>
</Descriptions>
) : null}
<Space wrap>
<Upload accept="video/mp4,.mp4" showUploadList={false} beforeUpload={beforeUpload} disabled={!canEdit}>
<Button icon={<UploadOutlined />} loading={uploading} disabled={!canEdit}>
<Upload
accept="video/mp4,.mp4"
showUploadList={false}
beforeUpload={beforeUpload}
disabled={!canEdit}
>
<Button
icon={<UploadOutlined />}
loading={uploading}
disabled={!canEdit}
>
{cfg.video_url ? '更换视频' : '上传视频'}
</Button>
</Upload>
{cfg.video_url && (
<Popconfirm
title={`确认移除${meta.title}`}
description="移除后该场景的新播放将无法使用引导视频,已经开始的播放不受影响。"
okText="确认移除"
cancelText="取消"
okButtonProps={{ danger: true }}
onConfirm={removeVideo}
disabled={!canEdit}
>
<Button icon={<DeleteOutlined />} danger loading={uploading} disabled={!canEdit}>
</Button>
</Popconfirm>
<Button icon={<DeleteOutlined />} danger loading={uploading} disabled={!canEdit} onClick={removeVideo}>
</Button>
)}
<Text type="secondary">MP4H.264 HEVC/H.265 AAC30180 100MB</Text>
<Text type="secondary">MP4H.264100MB</Text>
</Space>
<Button type="primary" loading={saving} disabled={!canEdit || !configValid} onClick={save}>
<Button
type="primary"
loading={saving}
disabled={!canEdit}
onClick={save}
>
</Button>
<Text type="secondary">
{cfg.total_plays} {cfg.granted_plays}
</Text>
</Space>
</Space>
)}
+2
View File
@@ -4,6 +4,7 @@ import { useEffect, useRef, useState } from 'react';
import { usePathname, useRouter } from 'next/navigation';
import {
BarChartOutlined,
ControlOutlined,
DashboardOutlined,
DatabaseOutlined,
FileSearchOutlined,
@@ -105,6 +106,7 @@ const NAV_GROUPS: NavGroup[] = [
{ key: '/analytics-health', icon: <LineChartOutlined />, label: '埋点成功率' },
{ key: '/event-logs', icon: <DatabaseOutlined />, label: '埋点日志' },
{ key: '/audit-logs', icon: <FileSearchOutlined />, label: '审计日志' },
{ key: '/limit-whitelist', icon: <ControlOutlined />, label: '限制策略' },
],
},
];
File diff suppressed because it is too large Load Diff
+75 -6
View File
@@ -19,10 +19,12 @@ import {
CopyOutlined,
DownOutlined,
EditOutlined,
PlusCircleOutlined,
ReloadOutlined,
RightOutlined,
} from '@ant-design/icons';
import dayjs from 'dayjs';
import { useRouter } from 'next/navigation';
import { api, errMsg } from '@/lib/api';
import { formatUtcTime, utcDayjs } from '@/lib/format';
import type {
@@ -69,8 +71,8 @@ type IncidentStatus = 'open' | 'blocked';
const RULE_LIMITS: Record<RiskKind, { min: number; max: number; help: string }> = {
sms: {
min: 1,
max: 5,
help: '统计成功下发;最高5次,与现有每设备每小时发送上限一致。',
max: 100000,
help: '统计成功下发;告警阈值与短信硬限制分别配置。',
},
oneclick: {
min: 1,
@@ -79,8 +81,8 @@ const RULE_LIMITS: Record<RiskKind, { min: number; max: number; help: string }>
},
compare: {
min: 1,
max: 100,
help: '同一账户按北京时间自然日累计;最高100次,与比价每日上限一致。',
max: 100000,
help: '同一账户按北京时间自然日累计;告警阈值与比价硬限制分别配置。',
},
};
const utcTime = (value: string | null, withDate = true) =>
@@ -271,6 +273,7 @@ function DetailTable({
}
export default function RiskMonitorPage() {
const router = useRouter();
const { message, modal } = App.useApp();
const [summary, setSummary] = useState<RiskMonitorSummary | null>(null);
const [lists, setLists] = useState<Partial<Record<RiskKind, RiskIncidentPage>>>({});
@@ -597,6 +600,40 @@ export default function RiskMonitorPage() {
[lists, loadAll, message, modal],
);
const addToWhitelist = useCallback(
(row: RiskIncidentItem) => {
const isCompare = row.kind === 'compare';
const subjectValue = isCompare ? row.phone : row.subject_id;
if (!isCompare && subjectValue?.startsWith('legacy-ip:')) {
void message.error(
'旧客户端未上报真实设备 ID,无法加入设备白名单,请升级客户端后重试',
);
return;
}
if (!subjectValue) {
void message.error(
isCompare
? '该风险记录没有关联手机号,暂时无法加入白名单'
: '该风险记录没有设备 ID,暂时无法加入白名单',
);
return;
}
const ruleCode: Record<RiskKind, string> = {
sms: 'risk.sms.hourly',
oneclick: 'risk.oneclick.daily',
compare: 'risk.compare.daily',
};
const params = new URLSearchParams({
create: '1',
subject_type: isCompare ? 'phone' : 'device',
subject_value: subjectValue,
rule_code: ruleCode[row.kind],
});
router.push(`/limit-whitelist?${params.toString()}`);
},
[message, router],
);
const columns = useCallback(
(kind: RiskKind): ColumnsType<RiskIncidentItem> => {
const actionColumn = {
@@ -604,9 +641,18 @@ export default function RiskMonitorPage() {
key: 'actions',
align: 'right' as const,
fixed: 'right' as const,
width: 180,
width: 280,
render: (_: unknown, row: RiskIncidentItem) => {
const open = expanded.has(row.incident_id);
const whitelistUnavailableReason =
row.kind === 'compare'
? row.phone
? undefined
: '该风险记录没有关联手机号,暂时无法加入白名单'
: row.subject_id.startsWith('legacy-ip:')
? '旧客户端未上报真实设备 ID,无法加入设备白名单'
: undefined;
const canAddToWhitelist = !whitelistUnavailableReason;
return (
<span className={styles.actionGroup}>
<Button
@@ -618,6 +664,20 @@ export default function RiskMonitorPage() {
>
{open ? '收起' : '展开'}
</Button>
<Tooltip
title={whitelistUnavailableReason}
>
<span>
<Button
size="small"
icon={<PlusCircleOutlined />}
disabled={!canAddToWhitelist}
onClick={() => addToWhitelist(row)}
>
</Button>
</span>
</Tooltip>
{row.status === 'open' && (
<>
<Button
@@ -700,7 +760,16 @@ export default function RiskMonitorPage() {
actionColumn,
];
},
[acting, copy, detailLoading, expanded, revokeRestriction, runAction, toggle],
[
acting,
addToWhitelist,
copy,
detailLoading,
expanded,
revokeRestriction,
runAction,
toggle,
],
);
const cards = useMemo(() => {
+85 -13
View File
@@ -414,23 +414,17 @@ export interface FeedbackQrConfig {
updated_at: string | null;
}
/** 领券/比价等候浮层的引导视频配置。视频分析结果均由服务端 ffprobe 生成。 */
/** 领券等候浮层的「新手引导视频配置(前 3 次用它替代广告,默认每次固定 100 金币)。
* 后台只开放 enabled + 换片;下面几个字段接口仍返回,但页面不展示、也不回传。 */
export interface GuideVideoConfig {
scene: 'coupon' | 'comparison';
enabled: boolean;
video_url: string | null;
max_plays: number;
reward_coin: number;
video_url: string | null; // /media/guide_video/xxx.mp4;null = 未配片(浮层照旧只放广告)
max_plays: number; // 每个账号前 N 次浮层放引导视频(服务端默认 3,后台不开放调整)
reward_coin: number; // 每次固定金币(服务端默认 100,播完 / 中途关闭都发)
updated_at: string | null;
duration_ms: number | null;
circle_duration_ms: number | null;
circle_count: 10;
reward_per_circle: number;
video_codec: string | null;
audio_codec: string | null;
analysis_status: 'missing' | 'valid' | 'invalid';
analysis_error: string | null;
config_version: number;
total_plays: number; // 只读统计:全站已播次数(后台不再展示)
granted_plays: number; // 只读统计:其中已发币次数(后台不再展示)
}
export interface AuditLog {
@@ -524,6 +518,7 @@ export interface ComparisonRecordDetail extends ComparisonRecordListItem {
skipped_dish_count: number | null;
device_id: string | null;
items: { name: string; qty?: number; specs?: string[] }[];
platforms: Record<string, unknown>[];
comparison_results: Record<string, unknown>[];
skipped_dish_names: string[];
device_manufacturer: string | null;
@@ -901,3 +896,80 @@ export interface HealthTrendPoint extends HealthMetrics {
export interface HealthBreakdownRow extends HealthMetrics {
key: string; // 维度值(event 名 / app_ver / oem);缺失为 "(unknown)"
}
// ===== 统一限制策略 / 白名单 =====
export type LimitSubjectType = 'phone' | 'device';
export type LimitPolicyMode =
| 'inherit'
| 'override'
| 'unlimited'
| 'suppress_alert';
export interface LimitRule {
code: string;
label: string;
group: string;
global_limit: number;
default_limit: number;
window_label: string;
subject_types: LimitSubjectType[];
allowed_modes: LimitPolicyMode[];
min_value: number;
max_value: number;
supports_reset: boolean;
alert_only: boolean;
}
export interface LimitDeviceCandidate {
device_id: string;
source: string;
source_label: string;
user_id: number | null;
username: string | null;
phone: string | null;
nickname: string | null;
device_model: string | null;
last_active_at: string;
}
export interface LimitOverride {
id: number;
subject_type: LimitSubjectType;
subject_value: string;
rule_code: string;
rule_label: string;
rule_group: string;
mode: LimitPolicyMode;
limit_value: number | null;
global_limit: number;
effective_limit: number | null;
enabled: boolean;
starts_at: string | null;
expires_at: string | null;
reset_at: string | null;
reason: string | null;
status: 'active' | 'scheduled' | 'expired' | 'disabled';
created_by_admin_id: number | null;
created_at: string;
updated_at: string;
}
export interface LimitOverrideList {
items: LimitOverride[];
total: number;
}
export interface LimitSubject {
subject_type: LimitSubjectType;
subject_value: string;
group_counts: Record<string, number>;
total_rules: number;
items: LimitOverride[];
created_at: string;
updated_at: string;
}
export interface LimitSubjectList {
items: LimitSubject[];
total: number;
}
+7 -2
View File
@@ -15,6 +15,7 @@ export function usePagedList<T>(
url: string,
filters: Record<string, unknown>,
initialPageSize = 20,
offsetParam: 'cursor' | 'offset' = 'cursor',
) {
const [items, setItems] = useState<T[]>([]);
const [total, setTotal] = useState(0);
@@ -31,7 +32,11 @@ export function usePagedList<T>(
requestSeq.current = seq;
setLoading(true);
try {
const params = { ...JSON.parse(filtersKey), limit: ps, cursor: (p - 1) * ps };
const params = {
...JSON.parse(filtersKey),
limit: ps,
[offsetParam]: (p - 1) * ps,
};
const { data } = await api.get<CursorPage<T>>(url, { params });
if (requestSeq.current !== seq) return; // 丢弃过期响应(快速切页/筛选)
setItems(data.items);
@@ -40,7 +45,7 @@ export function usePagedList<T>(
if (requestSeq.current === seq) setLoading(false);
}
},
[url, filtersKey],
[url, filtersKey, offsetParam],
);
// 筛选变化:回第 1 页重载
+8 -8
View File
@@ -1,5 +1,5 @@
#!/usr/bin/env bash
# 一键启动傻瓜比价本地联调:用户侧 API(8772) + 运营后台 API(8773) + 运营后台前端(3002)。
# 一键启动傻瓜比价本地联调:用户侧 API(8770) + 运营后台 API(8771) + 运营后台前端(3001)。
# 跨平台:Windows(Git Bash)与 macOS 通用。停止用 ./stop.sh。
#
# 路径相对本脚本推导(本脚本在 shaguabijia-admin-web 内,server 是它的同级目录),
@@ -93,19 +93,19 @@ start_uvicorn() {
}
# 用户侧绑 0.0.0.0,真机/模拟器可经局域网 IP 访问;后台只本机用,绑 127.0.0.1
start_uvicorn "user-api" "app.main:app" 8772 "0.0.0.0"
start_uvicorn "admin-api" "app.admin.main:admin_app" 8773 "127.0.0.1"
start_uvicorn "user-api" "app.main:app" 8770 "0.0.0.0"
start_uvicorn "admin-api" "app.admin.main:admin_app" 8771 "127.0.0.1"
if port_in_use 3002; then
echo "↺ admin-web 已在 :3002(跳过)"
if port_in_use 3001; then
echo "↺ admin-web 已在 :3001(跳过)"
else
cd "$WEB_DIR" || exit 1
nohup npm run dev > "$LOG_DIR/admin-web.log" 2>&1 &
echo "$!" > "$LOG_DIR/admin-web.pid"
echo "✅ admin-web 起在 :3002 (日志 $LOG_DIR/admin-web.log)"
echo "✅ admin-web 起在 :3001 (日志 $LOG_DIR/admin-web.log)"
fi
echo ""
echo "⏳ 前端首次编译要几秒,然后开 👉 http://localhost:3002 (admin / admin12345)"
echo " 用户侧 API: http://127.0.0.1:8772 | 后台 API: http://127.0.0.1:8773/admin/docs"
echo "⏳ 前端首次编译要几秒,然后开 👉 http://localhost:3001 (admin / admin12345)"
echo " 用户侧 API: http://127.0.0.1:8770 | 后台 API: http://127.0.0.1:8771/admin/docs"
echo " 看日志: tail -f $LOG_DIR/admin-web.log | 停止: bash \"$SCRIPT_DIR/stop.sh\""
+3 -3
View File
@@ -1,5 +1,5 @@
#!/usr/bin/env bash
# 停止 start.sh 起的三个服务:用户侧 API(8772) + 后台 API(8773) + 前端(3002)。
# 停止 start.sh 起的三个服务:用户侧 API(8770) + 后台 API(8771) + 前端(3001)。
# 双保险:先按 start.sh 落的 PID 文件杀,再按端口兜底(Windows 走 PowerShell,mac 走 lsof)。
# (PG 若由 brew 自启,本脚本不停它。)
SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
@@ -32,8 +32,8 @@ kill_port() {
fi
}
for port in 8772 8773 3002; do
for port in 8770 8771 3001; do
kill_port "$port"
done
echo "✅ 已停止(用户侧 8772 / 后台 8773 / 前端 3002)。"
echo "✅ 已停止(用户侧 8770 / 后台 8771 / 前端 3001)。"