Compare commits

..

5 Commits

Author SHA1 Message Date
linkeyu 4cd92539a7 功能:完善提现审核与用户管理页面 2026-07-26 11:36:35 +08:00
linkeyu 694944cb5e 优化:移除提现类型字段 (#73)
## 修改内容
- 删除提现审核 6 个状态子页面共用的提现类型筛选项
- 删除列表和详情抽屉中的提现类型字段
- 筛选栏仅保留:用户手机号、开始时间-结束时间、倒序、重置
- 日期与排序字段固定为申请时间,并同步清理无用前端状态和请求参数
- 同步收窄表格横向滚动宽度

## 后端评估
- 无需后端改动
- source 仍是提现账本分流、扣款、退款与对账所需的业务字段,保留 API 兼容性

## 本地验证
- npx tsc --noEmit
- npm run build
- git diff --check

---------

Co-authored-by: guke <guke@wonderable.ai>
Co-authored-by: linkeyu <798648091@qq.com>
Reviewed-on: #73
Co-authored-by: linkeyu <linkeyu@wonderable.ai>
Co-committed-by: linkeyu <linkeyu@wonderable.ai>
2026-07-25 18:29:50 +08:00
linkeyu 27ff7936a5 功能:新增风控监控后台页面 (#74)
## 修改内容
- 在监控审计导航中新增风控监控入口
- 新增短信、一键登录、比价三类报警汇总与分页列表
- 支持展开事实明细、忽略、封禁、解除、重置报警及规则阈值编辑
- 新增待处理 / 已封禁视图;已封禁行可直接解除并恢复业务权限
- 按事件状态约束操作按钮,避免已处理记录误触发 409
- 增加响应式布局、横向表格与操作反馈

## 后端依赖
- WonderableAI/shaguabijia-app-server#174

## 验证
- npx tsc --noEmit
- npm run build
- 本地 review:状态切换重置分页与旧数据、解除成功自动刷新

---------

Co-authored-by: linkeyu <798648091@qq.com>
Reviewed-on: #74
Co-authored-by: linkeyu <linkeyu@wonderable.ai>
Co-committed-by: linkeyu <linkeyu@wonderable.ai>
2026-07-25 17:56:29 +08:00
linkeyu 47a7960100 文案:更新提现审核页副标题 (#72)
## 修改内容
- 提现审核页副标题补充针对赚钱页面的账户说明
- 将微信打款明确为微信提现

## 本地验证
- npx tsc --noEmit
- npm run build

---------

Co-authored-by: linkeyu <798648091@qq.com>
Reviewed-on: #72
Co-authored-by: linkeyu <linkeyu@wonderable.ai>
Co-committed-by: linkeyu <linkeyu@wonderable.ai>
2026-07-25 15:15:16 +08:00
linkeyu 7ca55d0dcb 优化:明确提现审核状态与超时订单处理 (#71)
## 改动说明

- 将支付配置阻断问题改为明确、可操作的提示,技术详情默认折叠。
- 为支付配置检测和现金账本校验增加加载状态、精确时间与完成反馈。
- 账本正常时使用紧凑状态展示,异常时才显示醒目提示。
- 将“批量对账”改为“处理超时订单”,在确认弹窗中说明查单、更新状态、撤销和退款行为。
- 移除自动查单关闭提示,避免把非阻断运维状态展示成业务问题。
- 审计记录中的操作名称同步调整为“处理超时订单”。

## 验证

- `npx tsc --noEmit`
- Next.js 本地页面编译通过。
- 实际验证重新检测、重新校验和超时订单确认弹窗,浏览器控制台无错误。

## 后端配套

- WonderableAI/shaguabijia-app-server#170

---------

Co-authored-by: guke <guke@wonderable.ai>
Co-authored-by: linkeyu <798648091@qq.com>
Reviewed-on: #71
Co-authored-by: linkeyu <linkeyu@wonderable.ai>
Co-committed-by: linkeyu <linkeyu@wonderable.ai>
2026-07-24 14:51:26 +08:00
13 changed files with 2860 additions and 1148 deletions
@@ -15,6 +15,8 @@ interface UserOverviewResp {
id: number;
phone: string;
nickname: string | null;
is_high_risk: boolean;
high_risk_note: string | null;
status: string;
wechat_nickname: string | null;
created_at: string;
@@ -49,6 +51,8 @@ export default function UserAdRevenueDrawer({ open, onClose, userId, phone }: Pr
id: o.user.id,
phone: o.user.phone,
nickname: o.user.nickname,
is_high_risk: o.user.is_high_risk,
high_risk_note: o.user.high_risk_note,
status: o.user.status,
wechat_nickname: o.user.wechat_nickname, // 概览接口已返回微信昵称
wechat_avatar_url: null,
+5
View File
@@ -0,0 +1,5 @@
import { WithdrawReviewPage } from '../withdraws/WithdrawReviewPage';
export default function InviteWithdrawsPage() {
return <WithdrawReviewPage mode="invite" />;
}
+12 -3
View File
@@ -17,6 +17,7 @@ import {
NotificationOutlined,
ProfileOutlined,
SafetyCertificateOutlined,
SecurityScanOutlined,
SettingOutlined,
ShareAltOutlined,
TeamOutlined,
@@ -74,7 +75,8 @@ const NAV_GROUPS: NavGroup[] = [
icon: <MoneyCollectOutlined />,
label: '奖励审核',
children: [
{ key: '/withdraws', icon: <MoneyCollectOutlined />, label: '提现审核' },
{ key: '/invite-withdraws', icon: <MoneyCollectOutlined />, label: '邀请提现审核' },
{ key: '/withdraws', icon: <MoneyCollectOutlined />, label: '其他提现审核' },
{ key: '/price-reports', icon: <FlagOutlined />, label: '低价审核' },
{ key: '/feedbacks', icon: <MessageOutlined />, label: '用户反馈' },
],
@@ -95,6 +97,7 @@ const NAV_GROUPS: NavGroup[] = [
icon: <FileSearchOutlined />,
label: '监控审计',
children: [
{ key: '/risk-monitor', icon: <SecurityScanOutlined />, label: '风控监控' },
{ key: '/device-liveness', icon: <HeartOutlined />, label: '设备存活' },
{ key: '/analytics-health', icon: <LineChartOutlined />, label: '埋点成功率' },
{ key: '/event-logs', icon: <DatabaseOutlined />, label: '埋点日志' },
@@ -142,8 +145,13 @@ export default function MainLayout({ children }: { children: React.ReactNode })
const version = (reviewRefreshVersion.current[key] ?? 0) + 1;
reviewRefreshVersion.current[key] = version;
let count: number;
if (key === '/withdraws') {
count = (await api.get<WithdrawSummary>('/admin/api/withdraws/summary')).data.reviewing_count;
if (key === '/withdraws' || key === '/invite-withdraws') {
const source = key === '/invite-withdraws' ? 'invite_cash' : 'coin_cash';
count = (
await api.get<WithdrawSummary>('/admin/api/withdraws/summary', {
params: { source },
})
).data.reviewing_count;
} else if (key === '/price-reports') {
count = (await api.get<PriceReportSummary>('/admin/api/price-reports/summary')).data.pending;
} else {
@@ -156,6 +164,7 @@ export default function MainLayout({ children }: { children: React.ReactNode })
const refreshSafely = (key: ReviewBadgeKey) => refresh(key).catch(() => {});
void Promise.all([
refreshSafely('/withdraws'),
refreshSafely('/invite-withdraws'),
refreshSafely('/price-reports'),
refreshSafely('/feedbacks'),
]);
+356
View File
@@ -0,0 +1,356 @@
.page {
min-height: calc(100vh - 112px);
margin: -24px;
padding: 0 16px 28px;
background: #f5f5f3;
color: #171717;
}
.hero {
display: flex;
align-items: center;
justify-content: space-between;
min-height: 72px;
margin: 0 -16px 18px;
padding: 0 24px;
border-bottom: 1px solid #e8e8e6;
background: #fff;
}
.titleCluster,
.brandLine,
.updated,
.rule,
.deviceCell,
.actionGroup,
.factRow {
display: flex;
align-items: center;
}
.back {
margin-right: 18px;
color: #555;
font-size: 13px;
}
.brandMark {
display: inline-flex;
align-items: center;
justify-content: center;
width: 34px;
height: 34px;
margin-right: 12px;
border-radius: 10px;
background: #ffd400;
color: #111;
font-size: 17px;
font-weight: 800;
}
.title {
margin: 0;
font-size: 18px;
font-weight: 700;
line-height: 1.2;
}
.subtitle {
margin-top: 3px;
color: #929292;
font-size: 12px;
}
.updated {
gap: 7px;
color: #898989;
font-size: 12px;
}
.updatedMeta {
display: flex;
align-items: center;
gap: 7px;
}
.dot {
width: 8px;
height: 8px;
border-radius: 50%;
background: #9b9b9b;
}
.summaryGrid {
display: grid;
grid-template-columns: repeat(3, minmax(0, 1fr));
gap: 14px;
margin-bottom: 16px;
}
.statusToolbar {
display: flex;
align-items: center;
justify-content: space-between;
gap: 16px;
margin-bottom: 2px;
padding: 12px 16px;
border: 1px solid #ecece8;
border-radius: 12px;
background: #fff;
}
.statusToolbar > div {
display: flex;
flex-direction: column;
gap: 2px;
}
.statusToolbar strong {
color: #222;
font-size: 14px;
}
.statusToolbar span {
color: #888;
font-size: 12px;
}
.summaryCard {
min-height: 148px;
padding: 26px 24px 20px;
border: 1px solid #eeeeeb;
border-radius: 16px;
background: #fff;
box-shadow: 0 1px 2px rgba(0, 0, 0, 0.02);
}
.summaryTitle {
margin-bottom: 4px;
color: #111;
font-size: 14px;
font-weight: 700;
}
.summaryValue {
color: #ee3737;
font-size: 38px;
font-weight: 800;
line-height: 1.08;
font-variant-numeric: tabular-nums;
}
.summaryUnit {
margin-left: 5px;
color: #202020;
font-size: 16px;
font-weight: 600;
}
.summarySub {
margin: 8px 0 8px;
color: #969696;
font-size: 13px;
}
.rule {
width: fit-content;
padding: 4px 8px;
border: 0;
border-radius: 6px;
background: #f6f6f4;
color: #111;
cursor: pointer;
font-family: inherit;
font-size: 12px;
font-weight: 600;
transition: background 0.18s ease, box-shadow 0.18s ease;
}
.rule:hover,
.rule:focus-visible {
background: #fff3bf;
box-shadow: 0 0 0 2px rgba(255, 212, 0, 0.3);
outline: none;
}
.rule strong {
margin-left: 4px;
color: #df2727;
}
.ruleEditIcon {
margin-left: 7px;
color: #777;
font-size: 11px;
}
.ruleDialogIntro {
margin: 0 0 16px;
padding: 10px 12px;
border-radius: 8px;
background: #faf8ef;
color: #666;
font-size: 12px;
line-height: 1.7;
}
.ruleSettings {
border-top: 1px solid #f0f0ed;
}
.ruleSettingRow {
display: grid;
grid-template-columns: minmax(0, 1fr) 140px;
gap: 20px;
align-items: center;
padding: 16px 0;
border-bottom: 1px solid #f0f0ed;
}
.ruleSettingCopy {
display: flex;
flex-direction: column;
gap: 5px;
}
.ruleSettingCopy strong {
color: #222;
font-size: 14px;
}
.ruleSettingCopy span {
color: #888;
font-size: 12px;
line-height: 1.55;
}
.ruleValueEditor {
display: flex;
align-items: center;
justify-content: flex-end;
gap: 8px;
color: #666;
}
.ruleValueEditor :global(.ant-input-number) {
width: 110px;
}
.section {
margin-top: 14px;
padding: 20px 20px 16px;
border: 1px solid #ecece8;
border-radius: 16px;
background: #fff;
box-shadow: 0 1px 2px rgba(0, 0, 0, 0.02);
}
.sectionTitle {
margin: 0 0 10px;
font-size: 15px;
font-weight: 700;
}
.deviceCell {
gap: 7px;
}
.mono {
max-width: 210px;
overflow: hidden;
font-family: ui-monospace, SFMono-Regular, Menlo, Consolas, monospace;
font-size: 12px;
text-overflow: ellipsis;
white-space: nowrap;
}
.copyButton {
height: 25px !important;
padding: 0 7px !important;
color: #777 !important;
font-size: 12px !important;
}
.actionGroup {
justify-content: flex-end;
gap: 6px;
white-space: nowrap;
}
.expandButton {
border-color: #ffd400 !important;
background: #ffd400 !important;
color: #111 !important;
font-weight: 600;
}
.detailWrap {
padding: 12px 16px 6px;
border-radius: 10px;
background: #fafaf8;
}
.factRow {
gap: 8px;
margin-bottom: 12px;
}
.fact {
padding: 6px 10px;
border: 1px solid #ecece7;
border-radius: 8px;
background: #fff;
color: #666;
font-size: 12px;
}
.fact strong {
margin: 0 3px;
color: #111;
font-size: 14px;
}
.price {
white-space: nowrap;
font-variant-numeric: tabular-nums;
}
.na {
color: #aaa;
}
.footerNote {
margin-top: 16px;
padding: 16px 20px;
border: 1px dashed #dcdcd8;
border-radius: 14px;
background: rgba(255, 255, 255, 0.42);
color: #666;
font-size: 12px;
line-height: 1.8;
}
.footerNote strong {
color: #222;
}
@media (max-width: 900px) {
.summaryGrid {
grid-template-columns: 1fr;
}
.hero {
align-items: flex-start;
padding-top: 16px;
padding-bottom: 16px;
}
.updatedMeta {
display: none;
}
.statusToolbar {
align-items: flex-start;
flex-direction: column;
}
}
+902
View File
@@ -0,0 +1,902 @@
'use client';
import { useCallback, useEffect, useMemo, useRef, useState } from 'react';
import {
App,
Button,
Empty,
InputNumber,
Modal,
Segmented,
Skeleton,
Table,
Tag,
Tooltip,
} from 'antd';
import type { ColumnsType } from 'antd/es/table';
import {
ClearOutlined,
CopyOutlined,
DownOutlined,
EditOutlined,
ReloadOutlined,
RightOutlined,
} from '@ant-design/icons';
import dayjs from 'dayjs';
import { api, errMsg } from '@/lib/api';
import { formatUtcTime, utcDayjs } from '@/lib/format';
import type {
RiskDetailItem,
RiskDetailPage,
RiskIncidentItem,
RiskIncidentPage,
RiskKind,
RiskMonitorSummary,
RiskResetResponse,
RiskRuleConfig,
RiskSummaryCard,
} from '@/lib/types';
import styles from './page.module.css';
const KIND_META: Record<
RiskKind,
{ title: string; summaryTitle: string; totalLabel: string; unit: string }
> = {
sms: {
title: '短信',
summaryTitle: '触发短信报警的设备',
totalLabel: '今日短信下发共',
unit: '台',
},
oneclick: {
title: '一键登录',
summaryTitle: '触发一键登录报警的设备',
totalLabel: '今日一键登录共',
unit: '台',
},
compare: {
title: '比价',
summaryTitle: '触发比价报警的账户',
totalLabel: '今日比价共',
unit: '个',
},
};
const integer = (value: number) => new Intl.NumberFormat('zh-CN').format(value);
const LIST_PAGE_SIZE = 20;
const RISK_KINDS: RiskKind[] = ['sms', 'oneclick', 'compare'];
type IncidentStatus = 'open' | 'blocked';
const RULE_LIMITS: Record<RiskKind, { min: number; max: number; help: string }> = {
sms: {
min: 1,
max: 5,
help: '统计成功下发;最高5次,与现有每设备每小时发送上限一致。',
},
oneclick: {
min: 1,
max: 100000,
help: '成功和失败均计入,同一设备按北京时间自然日累计。',
},
compare: {
min: 1,
max: 100,
help: '同一账户按北京时间自然日累计;最高100次,与比价每日上限一致。',
},
};
const utcTime = (value: string | null, withDate = true) =>
formatUtcTime(value, withDate ? 'MM-DD HH:mm' : 'HH:mm');
const eventMoment = (value: string, kind: RiskKind) =>
kind === 'compare' ? dayjs(value) : utcDayjs(value).tz('Asia/Shanghai');
const eventTime = (value: string | null, kind: RiskKind, withDate = true) =>
value ? eventMoment(value, kind).format(withDate ? 'MM-DD HH:mm' : 'HH:mm') : '-';
function period(item: RiskIncidentItem): string {
const start = eventMoment(item.first_event_at, item.kind);
const end = eventMoment(item.last_event_at, item.kind);
if (start.isSame(end, 'day')) {
return `${start.format('YYYY-MM-DD HH:mm')}${end.format('HH:mm')}`;
}
return `${start.format('YYYY-MM-DD HH:mm')}${end.format('YYYY-MM-DD HH:mm')}`;
}
function DeviceId({
value,
onCopy,
}: {
value: string | null;
onCopy: (value: string) => void;
}) {
if (!value) return <span className={styles.na}>-</span>;
return (
<span className={styles.deviceCell}>
<Tooltip title={value}>
<span className={styles.mono}>{value}</span>
</Tooltip>
<Button
className={styles.copyButton}
size="small"
icon={<CopyOutlined />}
onClick={() => onCopy(value)}
>
</Button>
</span>
);
}
function DetailTable({
detail,
loading,
page,
onPage,
}: {
detail?: RiskDetailPage;
loading: boolean;
page: number;
onPage: (page: number) => void;
}) {
if (loading || !detail) return <Skeleton active paragraph={{ rows: 4 }} />;
let columns: ColumnsType<RiskDetailItem>;
if (detail.kind === 'sms') {
columns = [
{
title: '发送时间',
dataIndex: 'occurred_at',
width: 150,
render: (v) => eventTime(v, detail.kind),
},
{ title: '手机号', dataIndex: 'phone', width: 140, render: (v) => v || '-' },
{
title: '完成验证',
dataIndex: 'verified',
width: 100,
render: (v) => (v ? <Tag color="success"></Tag> : <Tag></Tag>),
},
{
title: '登录账号',
key: 'account',
render: (_, row) => row.username || (row.user_id ? `U${row.user_id}` : '-'),
},
{
title: '账号注册时间',
dataIndex: 'account_registered_at',
width: 150,
render: (v) => utcTime(v),
},
];
} else if (detail.kind === 'oneclick') {
columns = [
{
title: '登录时间',
dataIndex: 'occurred_at',
width: 150,
render: (v) => eventTime(v, detail.kind),
},
{ title: '手机号', dataIndex: 'phone', width: 140, render: (v) => v || '-' },
{
title: '登录账号',
key: 'account',
render: (_, row) => row.username || (row.user_id ? `U${row.user_id}` : '-'),
},
{
title: '账号注册时间',
dataIndex: 'account_registered_at',
width: 150,
render: (v) => utcTime(v),
},
{
title: '结果',
dataIndex: 'outcome',
width: 100,
render: (v) =>
v === 'success' ? <Tag color="success"></Tag> : <Tag color="error"></Tag>,
},
{ title: '失败原因', dataIndex: 'reason', render: (v) => v || '-' },
];
} else {
const priceColumn = (platform: string) => ({
title: platform,
key: platform,
width: 100,
render: (_: unknown, row: RiskDetailItem) => {
const value = row.prices?.[platform];
return value == null ? (
<span className={styles.na}></span>
) : (
<span className={styles.price}>¥{value.toFixed(2)}</span>
);
},
});
columns = [
{
title: '触发时间',
dataIndex: 'occurred_at',
width: 150,
render: (v) => eventTime(v, detail.kind),
},
{
title: '店铺 / 菜品',
key: 'shop',
render: (_, row) => (
<span>{[row.store_name, row.product_names].filter(Boolean).join(' · ') || '-'}</span>
),
},
priceColumn('美团'),
priceColumn('淘宝'),
priceColumn('京东'),
{
title: '节省',
dataIndex: 'saved_amount_yuan',
width: 90,
render: (v) => (v == null ? '-' : <span className={styles.price}>{v.toFixed(2)} </span>),
},
{
title: '状态',
dataIndex: 'status',
width: 90,
render: (v) =>
v === 'success' ? <Tag color="success"></Tag> : <Tag color="error"></Tag>,
},
];
}
return (
<div className={styles.detailWrap}>
<div className={styles.factRow}>
<span className={styles.fact}>
{KIND_META[detail.kind].title}
<strong>{integer(detail.event_count)}</strong>
</span>
{detail.distinct_accounts != null && (
<span className={styles.fact}>
<strong>{integer(detail.distinct_accounts)}</strong>
</span>
)}
</div>
<Table
rowKey="id"
size="small"
columns={columns}
dataSource={detail.items}
scroll={{ x: detail.kind === 'compare' ? 1000 : 720 }}
pagination={{
current: page,
pageSize: 20,
total: detail.total,
showSizeChanger: false,
onChange: onPage,
}}
/>
</div>
);
}
export default function RiskMonitorPage() {
const { message, modal } = App.useApp();
const [summary, setSummary] = useState<RiskMonitorSummary | null>(null);
const [lists, setLists] = useState<Partial<Record<RiskKind, RiskIncidentPage>>>({});
const [listPage, setListPage] = useState<Record<RiskKind, number>>({
sms: 1,
oneclick: 1,
compare: 1,
});
const [incidentStatus, setIncidentStatus] = useState<IncidentStatus>('open');
const listPageRef = useRef(listPage);
const [loading, setLoading] = useState(true);
const [expanded, setExpanded] = useState<Set<number>>(new Set());
const [details, setDetails] = useState<Record<number, RiskDetailPage>>({});
const [detailLoading, setDetailLoading] = useState<Set<number>>(new Set());
const [detailPage, setDetailPage] = useState<Record<number, number>>({});
const [acting, setActing] = useState<number | null>(null);
const [ruleOpen, setRuleOpen] = useState(false);
const [ruleSaving, setRuleSaving] = useState(false);
const [resetting, setResetting] = useState(false);
const [ruleDraft, setRuleDraft] = useState<Record<RiskKind, number>>({
sms: 5,
oneclick: 20,
compare: 100,
});
const loadAll = useCallback(async (quiet = false) => {
if (!quiet) setLoading(true);
try {
const pages = listPageRef.current;
const [summaryRes, smsRes, oneclickRes, compareRes] = await Promise.all([
api.get<RiskMonitorSummary>('/admin/api/risk-monitor/summary'),
api.get<RiskIncidentPage>('/admin/api/risk-monitor/incidents/sms', {
params: {
status: incidentStatus,
cursor: (pages.sms - 1) * LIST_PAGE_SIZE,
limit: LIST_PAGE_SIZE,
},
}),
api.get<RiskIncidentPage>('/admin/api/risk-monitor/incidents/oneclick', {
params: {
status: incidentStatus,
cursor: (pages.oneclick - 1) * LIST_PAGE_SIZE,
limit: LIST_PAGE_SIZE,
},
}),
api.get<RiskIncidentPage>('/admin/api/risk-monitor/incidents/compare', {
params: {
status: incidentStatus,
cursor: (pages.compare - 1) * LIST_PAGE_SIZE,
limit: LIST_PAGE_SIZE,
},
}),
]);
setSummary(summaryRes.data);
setLists({
sms: smsRes.data,
oneclick: oneclickRes.data,
compare: compareRes.data,
});
} catch (error) {
void message.error(errMsg(error, '风控数据加载失败'));
} finally {
setLoading(false);
}
}, [incidentStatus, message]);
const changeListPage = useCallback(
async (kind: RiskKind, page: number) => {
const nextPages = { ...listPageRef.current, [kind]: page };
listPageRef.current = nextPages;
setListPage(nextPages);
try {
const { data } = await api.get<RiskIncidentPage>(
`/admin/api/risk-monitor/incidents/${kind}`,
{
params: {
status: incidentStatus,
cursor: (page - 1) * LIST_PAGE_SIZE,
limit: LIST_PAGE_SIZE,
},
},
);
setLists((current) => ({ ...current, [kind]: data }));
} catch (error) {
void message.error(errMsg(error, '风险列表加载失败'));
}
},
[incidentStatus, message],
);
const changeIncidentStatus = useCallback((status: IncidentStatus) => {
const firstPage = { sms: 1, oneclick: 1, compare: 1 };
listPageRef.current = firstPage;
setListPage(firstPage);
setLists({});
setExpanded(new Set());
setDetails({});
setDetailLoading(new Set());
setDetailPage({});
setIncidentStatus(status);
}, []);
useEffect(() => {
void loadAll();
const timer = window.setInterval(() => void loadAll(true), 60 * 60 * 1000);
const onFocus = () => void loadAll(true);
window.addEventListener('focus', onFocus);
return () => {
window.clearInterval(timer);
window.removeEventListener('focus', onFocus);
};
}, [loadAll]);
const copy = useCallback(
async (value: string) => {
await navigator.clipboard.writeText(value);
void message.success('设备 ID 已复制');
},
[message],
);
const openRuleSettings = useCallback(() => {
if (summary) {
const current = Object.fromEntries(
summary.cards.map((card) => [card.kind, card.threshold]),
) as Record<RiskKind, number>;
setRuleDraft(current);
}
setRuleOpen(true);
}, [summary]);
const saveRules = useCallback(async () => {
setRuleSaving(true);
try {
const payload: RiskRuleConfig = {
sms_hourly_threshold: ruleDraft.sms,
oneclick_daily_threshold: ruleDraft.oneclick,
compare_daily_threshold: ruleDraft.compare,
};
await api.patch<RiskRuleConfig>('/admin/api/risk-monitor/rules', payload);
setRuleOpen(false);
void message.success('规则已保存,并已重新核算当前时段');
await loadAll(true);
} catch (error) {
void message.error(errMsg(error, '规则保存失败'));
} finally {
setRuleSaving(false);
}
}, [loadAll, message, ruleDraft]);
const resetAlerts = useCallback(() => {
modal.confirm({
title: '确认重置全部报警?',
content:
'短信、一键登录、比价三类待处理报警将归零,并从确认时刻重新累计。历史流水会保留,已封禁的设备和账户不会解封。',
okText: '确认重置',
okButtonProps: { danger: true },
cancelText: '取消',
async onOk() {
setResetting(true);
try {
const { data } = await api.post<RiskResetResponse>(
'/admin/api/risk-monitor/reset',
);
listPageRef.current = { sms: 1, oneclick: 1, compare: 1 };
setListPage({ sms: 1, oneclick: 1, compare: 1 });
setExpanded(new Set());
setDetails({});
setDetailPage({});
if (data.reset_incident_count > 0) {
void message.success(
`已重置 ${integer(data.reset_incident_count)} 条报警,并从 0 重新累计`,
);
} else {
void message.success('当前无待处理报警,新的累计基线已生效');
}
await loadAll(true);
} catch (error) {
void message.error(errMsg(error, '报警重置失败'));
throw error;
} finally {
setResetting(false);
}
},
});
}, [loadAll, message, modal]);
const loadDetail = useCallback(
async (kind: RiskKind, incidentId: number, page = 1) => {
setDetailLoading((current) => new Set(current).add(incidentId));
try {
const { data } = await api.get<RiskDetailPage>(
`/admin/api/risk-monitor/incidents/${kind}/${incidentId}/details`,
{ params: { cursor: (page - 1) * 20, limit: 20 } },
);
setDetails((current) => ({ ...current, [incidentId]: data }));
setDetailPage((current) => ({ ...current, [incidentId]: page }));
} catch (error) {
void message.error(errMsg(error, '风险明细加载失败'));
} finally {
setDetailLoading((current) => {
const next = new Set(current);
next.delete(incidentId);
return next;
});
}
},
[message],
);
const toggle = useCallback(
(row: RiskIncidentItem) => {
const willOpen = !expanded.has(row.incident_id);
setExpanded((current) => {
const next = new Set(current);
if (willOpen) next.add(row.incident_id);
else next.delete(row.incident_id);
return next;
});
if (willOpen && !details[row.incident_id]) {
void loadDetail(row.kind, row.incident_id);
}
},
[details, expanded, loadDetail],
);
const runAction = useCallback(
(row: RiskIncidentItem, action: 'ignore' | 'block') => {
const verb = action === 'block' ? '封禁' : '忽略';
modal.confirm({
title: `确认${verb}${row.subject_type === 'device' ? '设备' : '账户'}`,
content:
action === 'block'
? row.subject_type === 'device'
? '封禁后,该设备发送短信和一键登录会被直接拒绝,不影响它登录过的账户。'
: '封禁后,该账户不能发起比价、领取任务奖励或提现,现有金币和现金不会清零。'
: '忽略后,本风险事件会移出待处理列表,事实流水仍会保留。',
okText: verb,
okButtonProps: { danger: action === 'block' },
cancelText: '取消',
async onOk() {
setActing(row.incident_id);
try {
await api.post(`/admin/api/risk-monitor/incidents/${row.incident_id}/${action}`, {
reason: `风控监控页人工${verb}`,
});
void message.success(`${verb}成功`);
setExpanded((current) => {
const next = new Set(current);
next.delete(row.incident_id);
return next;
});
if (
(lists[row.kind]?.items.length ?? 0) === 1
&& listPageRef.current[row.kind] > 1
) {
const nextPages = {
...listPageRef.current,
[row.kind]: listPageRef.current[row.kind] - 1,
};
listPageRef.current = nextPages;
setListPage(nextPages);
}
await loadAll(true);
} catch (error) {
void message.error(errMsg(error));
throw error;
} finally {
setActing(null);
}
},
});
},
[lists, loadAll, message, modal],
);
const revokeRestriction = useCallback(
(row: RiskIncidentItem) => {
if (!row.restriction_id) {
void message.error('未找到有效的封禁记录,请刷新后重试');
return;
}
modal.confirm({
title: `确认解除该${row.subject_type === 'device' ? '设备' : '账户'}的封禁?`,
content:
row.subject_type === 'device'
? '解除后,该设备可以重新发送短信验证码和使用一键登录。'
: '解除后,该账户可以重新发起比价、领取任务奖励和提现。',
okText: '解除封禁',
cancelText: '取消',
async onOk() {
setActing(row.incident_id);
try {
await api.post(
`/admin/api/risk-monitor/restrictions/${row.restriction_id}/revoke`,
);
void message.success('解除封禁成功');
setExpanded((current) => {
const next = new Set(current);
next.delete(row.incident_id);
return next;
});
if (
(lists[row.kind]?.items.length ?? 0) === 1
&& listPageRef.current[row.kind] > 1
) {
const nextPages = {
...listPageRef.current,
[row.kind]: listPageRef.current[row.kind] - 1,
};
listPageRef.current = nextPages;
setListPage(nextPages);
}
await loadAll(true);
} catch (error) {
void message.error(errMsg(error, '解除封禁失败'));
throw error;
} finally {
setActing(null);
}
},
});
},
[lists, loadAll, message, modal],
);
const columns = useCallback(
(kind: RiskKind): ColumnsType<RiskIncidentItem> => {
const actionColumn = {
title: '操作',
key: 'actions',
align: 'right' as const,
fixed: 'right' as const,
width: 180,
render: (_: unknown, row: RiskIncidentItem) => {
const open = expanded.has(row.incident_id);
return (
<span className={styles.actionGroup}>
<Button
className={styles.expandButton}
size="small"
loading={detailLoading.has(row.incident_id)}
icon={open ? <DownOutlined /> : <RightOutlined />}
onClick={() => toggle(row)}
>
{open ? '收起' : '展开'}
</Button>
{row.status === 'open' && (
<>
<Button
size="small"
danger
loading={acting === row.incident_id}
onClick={() => runAction(row, 'block')}
>
</Button>
<Button
size="small"
loading={acting === row.incident_id}
onClick={() => runAction(row, 'ignore')}
>
</Button>
</>
)}
{row.status === 'blocked' && (
<Button
size="small"
loading={acting === row.incident_id}
disabled={!row.restriction_id}
onClick={() => revokeRestriction(row)}
>
</Button>
)}
</span>
);
},
};
if (kind === 'compare') {
return [
{ title: '账户手机号', dataIndex: 'phone', width: 130, render: (v) => v || '-' },
{
title: '注册时间',
dataIndex: 'registered_at',
width: 105,
render: (v) => utcTime(v),
},
{
title: '常用设备',
dataIndex: 'common_device_id',
width: 180,
render: (v) => <DeviceId value={v} onCopy={copy} />,
},
{ title: '触发时段', key: 'period', width: 180, render: (_, row) => period(row) },
{
title: '首次触发',
dataIndex: 'triggered_at',
width: 125,
render: (v) => eventTime(v, kind),
},
actionColumn,
];
}
return [
{ title: '设备型号', dataIndex: 'device_model', width: 120, render: (v) => v || '-' },
{
title: '设备 ID',
dataIndex: 'subject_id',
width: 190,
render: (v) => <DeviceId value={v} onCopy={copy} />,
},
{
title: '首次使用',
dataIndex: 'first_used_at',
width: 110,
render: (v) => eventTime(v, kind),
},
{ title: '触发时段', key: 'period', width: 180, render: (_, row) => period(row) },
{
title: '首次触发',
dataIndex: 'triggered_at',
width: 110,
render: (v) => eventTime(v, kind),
},
actionColumn,
];
},
[acting, copy, detailLoading, expanded, revokeRestriction, runAction, toggle],
);
const cards = useMemo(() => {
if (!summary) return [];
const byKind = Object.fromEntries(summary.cards.map((card) => [card.kind, card]));
return RISK_KINDS
.map((kind) => byKind[kind])
.filter(Boolean) as RiskSummaryCard[];
}, [summary]);
return (
<main className={styles.page}>
<header className={styles.hero}>
<div className={styles.titleCluster}>
<span className={styles.back}> </span>
<span className={styles.brandMark}></span>
<div>
<h1 className={styles.title}></h1>
<div className={styles.subtitle}> / / </div>
</div>
</div>
<div className={styles.updated}>
<span className={styles.updatedMeta}>
<span>{summary ? dayjs(summary.date).format('YYYY-MM-DD') : '---- -- --'}</span>
<span></span>
<span className={styles.dot} />
<span></span>
</span>
<Button
type="text"
size="small"
icon={<ReloadOutlined />}
loading={loading}
aria-label="刷新风控数据"
onClick={() => void loadAll()}
/>
<Tooltip title="三类待处理报警归零,历史流水和封禁状态不变">
<Button
size="small"
icon={<ClearOutlined />}
loading={resetting}
onClick={resetAlerts}
>
</Button>
</Tooltip>
</div>
</header>
{loading && !summary ? (
<Skeleton active paragraph={{ rows: 10 }} />
) : (
<>
<section className={styles.summaryGrid}>
{cards.map((card) => {
const meta = KIND_META[card.kind];
return (
<article key={card.kind} className={styles.summaryCard}>
<div className={styles.summaryTitle}>{meta.summaryTitle}</div>
<div>
<span className={styles.summaryValue}>{card.alert_subject_count}</span>
<span className={styles.summaryUnit}>{meta.unit}</span>
</div>
<div className={styles.summarySub}>
{meta.totalLabel} {integer(card.today_total)}
</div>
<button
type="button"
className={styles.rule}
onClick={openRuleSettings}
aria-label={`编辑${meta.title}告警规则`}
>
<span>{card.rule_text.replace(/≥.*$/, '')}</span>
<strong> {card.threshold} </strong>
<EditOutlined className={styles.ruleEditIcon} />
</button>
</article>
);
})}
</section>
<div className={styles.statusToolbar}>
<div>
<strong></strong>
<span>
{incidentStatus === 'open'
? '查看待处理报警,可执行封禁或忽略'
: '查看当前已封禁主体,可恢复其业务权限'}
</span>
</div>
<Segmented
value={incidentStatus}
options={[
{ label: '待处理', value: 'open' },
{ label: '已封禁', value: 'blocked' },
]}
onChange={(value) => changeIncidentStatus(value as IncidentStatus)}
/>
</div>
{RISK_KINDS.map((kind) => {
const data = lists[kind]?.items ?? [];
return (
<section key={kind} className={styles.section}>
<h2 className={styles.sectionTitle}>{KIND_META[kind].title}</h2>
<Table
rowKey="incident_id"
size="middle"
columns={columns(kind)}
dataSource={data}
tableLayout="fixed"
scroll={{ x: kind === 'compare' ? 900 : 890 }}
locale={{
emptyText: (
<Empty
description={
incidentStatus === 'open'
? '当前没有待处理风险'
: '当前没有已封禁主体'
}
/>
),
}}
pagination={{
current: listPage[kind],
pageSize: LIST_PAGE_SIZE,
total: lists[kind]?.total ?? 0,
hideOnSinglePage: true,
showSizeChanger: false,
onChange: (page) => void changeListPage(kind, page),
}}
expandable={{
expandedRowKeys: [...expanded],
showExpandColumn: false,
expandedRowRender: (row) => (
<DetailTable
detail={details[row.incident_id]}
loading={detailLoading.has(row.incident_id)}
page={detailPage[row.incident_id] || 1}
onPage={(page) => void loadDetail(row.kind, row.incident_id, page)}
/>
),
}}
/>
</section>
);
})}
<footer className={styles.footerNote}>
<strong></strong>
线
</footer>
</>
)}
<Modal
title="风控规则设置"
open={ruleOpen}
okText="保存并立即生效"
cancelText="取消"
confirmLoading={ruleSaving}
onOk={() => void saveRules()}
onCancel={() => setRuleOpen(false)}
destroyOnHidden
>
<p className={styles.ruleDialogIntro}>
</p>
<div className={styles.ruleSettings}>
{RISK_KINDS.map((kind) => {
const meta = KIND_META[kind];
const limits = RULE_LIMITS[kind];
return (
<div key={kind} className={styles.ruleSettingRow}>
<div className={styles.ruleSettingCopy}>
<strong>{meta.summaryTitle}</strong>
<span>{limits.help}</span>
</div>
<div className={styles.ruleValueEditor}>
<InputNumber
min={limits.min}
max={limits.max}
precision={0}
value={ruleDraft[kind]}
onChange={(value) => {
if (value == null) return;
setRuleDraft((current) => ({ ...current, [kind]: value }));
}}
/>
<span></span>
</div>
</div>
);
})}
</div>
</Modal>
</main>
);
}
+65 -10
View File
@@ -13,6 +13,11 @@ import { formatUtcTime } from '@/lib/format';
import { usePagedList } from '@/lib/usePagedList';
import { AdjustCashModal, AdjustCoinModal } from '@/components/AdjustBalanceModals';
import { DeleteUserModal } from '@/components/DeleteUserModal';
import {
clearUserRisk,
UserRiskModal,
type RiskUser,
} from '@/components/UserRiskModal';
import type { UserListItem } from '@/lib/types';
const { RangePicker } = DatePicker;
@@ -49,6 +54,7 @@ export default function UsersPage() {
const [coinUser, setCoinUser] = useState<UserListItem | null>(null);
const [cashUser, setCashUser] = useState<UserListItem | null>(null);
const [delUser, setDelUser] = useState<UserListItem | null>(null);
const [riskUser, setRiskUser] = useState<RiskUser | null>(null);
const [selectedRowKeys, setSelectedRowKeys] = useState<Key[]>([]);
// 筛选/排序变化后清空已选(避免选中项跨筛选错位)
@@ -134,6 +140,22 @@ export default function UsersPage() {
});
};
const markNormalRisk = (u: UserListItem) => {
modal.confirm({
title: `确认将用户 ${u.phone} 标记为非高风险?`,
content: '确认后将清空当前高风险备注。',
onOk: async () => {
try {
await clearUserRisk(u.id);
message.success('已标记为非高风险');
reload();
} catch (error) {
message.error(errMsg(error));
}
},
});
};
// 一次性操作:点一下把该用户标记为「未看过引导」,下次打开 App 重看一遍,看完后端自动恢复(只触发这一次)。
// 用户尚未重看前可「撤销」(把 force_onboarding 置回 false),纠正误点。
const setForceOnboarding = (u: UserListItem, enable: boolean) => {
@@ -213,26 +235,38 @@ export default function UsersPage() {
};
const columns: ColumnsType<UserListItem> = [
{ title: 'ID', dataIndex: 'id', width: 80, sorter: true, sortOrder: sortOrderOf('id') },
{ title: '手机号', dataIndex: 'phone', width: 130 },
{ title: 'ID', dataIndex: 'id', width: 60, sorter: true, sortOrder: sortOrderOf('id') },
{ title: '手机号', dataIndex: 'phone', width: 115 },
{
title: '昵称',
dataIndex: 'nickname',
width: 150,
width: 130,
ellipsis: true,
render: (v: string | null) => v || '-',
},
{ title: '渠道', dataIndex: 'register_channel', width: 90 },
{
title: '用户标识',
dataIndex: 'is_high_risk',
width: 95,
render: (_: boolean, user: UserListItem) => (
<Tooltip title={user.is_high_risk ? user.high_risk_note || '暂无高风险备注' : undefined}>
<Tag color={user.is_high_risk ? 'red' : 'default'}>
{user.is_high_risk ? '高风险' : '非高风险'}
</Tag>
</Tooltip>
),
},
{ title: '渠道', dataIndex: 'register_channel', width: 70 },
{
title: '状态',
dataIndex: 'status',
width: 90,
width: 80,
render: (s: string) => <Tag color={STATUS_COLOR[s]}>{s}</Tag>,
},
{
title: '注册时间',
dataIndex: 'created_at',
width: 160,
width: 140,
sorter: true,
sortOrder: sortOrderOf('created_at'),
render: (v: string) => formatUtcTime(v),
@@ -245,7 +279,7 @@ export default function UsersPage() {
</Tooltip>
),
dataIndex: 'last_active_at',
width: 160,
width: 140,
sorter: true,
// 关掉 antd 默认的「点击升序/降序」表头提示,否则与上面自定义口径 Tooltip 同时弹出互相遮挡
showSorterTooltip: false,
@@ -256,9 +290,14 @@ export default function UsersPage() {
title: '操作',
key: 'op',
fixed: 'right',
width: 340,
width: 540,
render: (_: unknown, u: UserListItem) => (
<Space wrap={false} onClick={(e) => e.stopPropagation()}>
<Space
size={6}
wrap={false}
style={{ whiteSpace: 'nowrap' }}
onClick={(e) => e.stopPropagation()}
>
<a onClick={() => router.push(`/users/${u.id}`)}></a>
{canCoins && <a onClick={() => setCoinUser(u)}></a>}
{canCoins && <a onClick={() => setCashUser(u)}></a>}
@@ -270,6 +309,16 @@ export default function UsersPage() {
{u.debug_trace_enabled ? '关调试链接' : '开调试链接'}
</a>
)}
{canStatus &&
u.status !== 'deleted' &&
(u.is_high_risk ? (
<>
<a onClick={() => setRiskUser(u)}></a>
<a onClick={() => markNormalRisk(u)}></a>
</>
) : (
<a onClick={() => setRiskUser(u)}></a>
))}
{canStatus &&
u.status !== 'deleted' &&
(u.force_onboarding ? (
@@ -392,7 +441,7 @@ export default function UsersPage() {
showTotal: (t) => `${t} 个用户`,
onChange: onPageChange,
}}
scroll={{ x: 1200 }}
scroll={{ x: 1400 }}
onChange={onTableChange}
/>
@@ -404,6 +453,12 @@ export default function UsersPage() {
onClose={() => setDelUser(null)}
onDone={reload}
/>
<UserRiskModal
user={riskUser}
open={!!riskUser}
onClose={() => setRiskUser(null)}
onDone={reload}
/>
</div>
);
}
+51 -20
View File
@@ -4,11 +4,13 @@ import { useCallback, useEffect, useState } from 'react';
import {
DatePicker,
Descriptions,
Input,
Radio,
Space,
Table,
Tag,
Typography,
Tooltip,
message,
} from 'antd';
import type { ColumnsType } from 'antd/es/table';
@@ -39,12 +41,18 @@ const PAGE_SIZE = 10; // 金币记录每页条数
interface Props {
userId: number;
user: WithdrawUserSnapshot | null;
withdrawSource?: 'coin_cash' | 'invite_cash';
// 统计区字段集:withdraw(默认,提现详情:含提现细分) / ad(广告收益详情:只看看广告观看统计,对齐参考图 6 项)
statsVariant?: 'withdraw' | 'ad';
}
/** 用户看广告/提现详情:基本信息 + 互斥时间筛选 + 统计区(按 statsVariant 取字段集)+ 金币发放记录表。 */
export default function UserRewardPanel({ userId, user, statsVariant = 'withdraw' }: Props) {
export default function UserRewardPanel({
userId,
user,
withdrawSource,
statsVariant = 'withdraw',
}: Props) {
const [mode, setMode] = useState<'all' | 'range'>('all'); // all=注册至今 / range=自定义区间
const [range, setRange] = useState<[Dayjs, Dayjs] | null>(null);
const [stats, setStats] = useState<UserRewardStats | null>(null);
@@ -69,7 +77,10 @@ export default function UserRewardPanel({ userId, user, statsVariant = 'withdraw
setStatsLoading(true);
try {
const { data } = await api.get<UserRewardStats>(`/admin/api/users/${userId}/reward-stats`, {
params: JSON.parse(paramsKey),
params: {
...JSON.parse(paramsKey),
...(withdrawSource ? { withdraw_source: withdrawSource } : {}),
},
});
setStats(data);
} catch (e) {
@@ -77,7 +88,7 @@ export default function UserRewardPanel({ userId, user, statsVariant = 'withdraw
} finally {
setStatsLoading(false);
}
}, [userId, paramsKey]);
}, [userId, paramsKey, withdrawSource]);
const loadRecords = useCallback(
async (p: number) => {
@@ -135,6 +146,13 @@ export default function UserRewardPanel({ userId, user, statsVariant = 'withdraw
<Space size="large" wrap>
<span>
<Text strong>{user?.phone || '-'}</Text>
{user && (
<Tooltip title={user.is_high_risk ? user.high_risk_note || '暂无高风险备注' : undefined}>
<Tag color={user.is_high_risk ? 'red' : 'default'} style={{ marginInlineStart: 8 }}>
{user.is_high_risk ? '高风险' : '非高风险'}
</Tag>
</Tooltip>
)}
</span>
<span>
<Text strong>{user?.nickname || '-'}</Text>
@@ -160,6 +178,7 @@ export default function UserRewardPanel({ userId, user, statsVariant = 'withdraw
<RangePicker
size="small"
disabled={mode !== 'range'}
allowEmpty={[true, true]}
value={range}
onChange={(v) => setRange(v as [Dayjs, Dayjs] | null)}
/>
@@ -168,7 +187,7 @@ export default function UserRewardPanel({ userId, user, statsVariant = 'withdraw
{/* 统计区(受时间筛选;现金余额为当前快照)。ad 视图只保留看广告观看统计(对齐参考图 6 项) */}
<Descriptions bordered size="small" column={2} style={{ marginBottom: 8 }}>
<Descriptions.Item label="累计提现">
<Descriptions.Item label="累计成功提现">
{stats ? yuan(stats.withdraw_success_cents) : '-'}
</Descriptions.Item>
<Descriptions.Item label="现金余额">
@@ -176,40 +195,40 @@ export default function UserRewardPanel({ userId, user, statsVariant = 'withdraw
</Descriptions.Item>
{statsVariant === 'ad' ? (
<>
<Descriptions.Item label="激励视频观看数">
<Descriptions.Item label="激励视频成功发奖次数">
{stats?.reward_video_count ?? '-'}
</Descriptions.Item>
{/* eCPM 均按元展示(reward_video / feed avg_ecpm 原始为分/千次,÷100 转元) */}
<Descriptions.Item label="平均激励视频ECPM">
<Descriptions.Item label="预估平均激励视频ECPM">
{stats ? `${(stats.reward_video_avg_ecpm / 100).toFixed(2)} 元/千` : '-'}
</Descriptions.Item>
<Descriptions.Item label="draw信息流视频观看数">
<Descriptions.Item label="Draw信息流奖励份数">
{stats?.feed_count ?? '-'}
</Descriptions.Item>
<Descriptions.Item label="平均draw信息流ECPM">
<Descriptions.Item label="预估平均Draw信息流ECPM">
{stats ? `${(stats.feed_avg_ecpm / 100).toFixed(2)} 元/千` : '-'}
</Descriptions.Item>
</>
) : (
<>
<Descriptions.Item label="提现总次数">{stats?.withdraw_total ?? '-'}</Descriptions.Item>
<Descriptions.Item label="传统任务提现">
<Descriptions.Item label="提现申请总次数">{stats?.withdraw_total ?? '-'}</Descriptions.Item>
<Descriptions.Item label="传统任务累计收益">
{stats ? yuan(stats.traditional_task_cash_cents) : '-'}
</Descriptions.Item>
<Descriptions.Item label="累计激励视频数">
<Descriptions.Item label="激励视频成功发奖次数">
{stats?.reward_video_count ?? '-'}
</Descriptions.Item>
<Descriptions.Item label="平均激励视频ECPM">
<Descriptions.Item label="预估平均激励视频ECPM">
{stats ? `${stats.reward_video_avg_ecpm} 分/千` : '-'}
</Descriptions.Item>
<Descriptions.Item label="激励视频提现">
<Descriptions.Item label="激励视频累计收益">
{stats ? yuan(stats.reward_video_cash_cents) : '-'}
</Descriptions.Item>
<Descriptions.Item label="累计信息流广告数">{stats?.feed_count ?? '-'}</Descriptions.Item>
<Descriptions.Item label="平均信息流广告ECPM">
<Descriptions.Item label="信息流奖励份数">{stats?.feed_count ?? '-'}</Descriptions.Item>
<Descriptions.Item label="预估平均信息流广告ECPM">
{stats ? `${stats.feed_avg_ecpm} 分/千` : '-'}
</Descriptions.Item>
<Descriptions.Item label="信息流广告提现">
<Descriptions.Item label="信息流广告累计收益">
{stats ? yuan(stats.feed_cash_cents) : '-'}
</Descriptions.Item>
</>
@@ -217,12 +236,24 @@ export default function UserRewardPanel({ userId, user, statsVariant = 'withdraw
</Descriptions>
<Text type="secondary" style={{ fontSize: 12 }}>
{statsVariant === 'ad'
? '统计随上方时间筛选(现金余额除外,为当前快照);eCPM 均按元展示(原始分/千次 ÷100)。'
: '统计随上方时间筛选(现金余额除外,为当前快照);eCPM 单位分/千次,同金币审计。'}
? '统计随上方时间筛选(现金余额除外,为当前快照);次数仅统计成功发奖记录,信息流按奖励份数统计;eCPM 为预估值。'
: '统计随上方时间筛选(现金余额除外,为当前快照);提现按申请提交时间统计;累计收益为已发金币按当前汇率折算,不代表实际已提现金额;eCPM 为预估值。'}
</Text>
{/* 金币记录 */}
<h4 style={{ margin: '16px 0 8px' }}></h4>
{user?.is_high_risk && (
<div style={{ marginTop: 16 }}>
<Text strong></Text>
<Input.TextArea
readOnly
value={user.high_risk_note || ''}
rows={3}
style={{ marginTop: 8 }}
/>
</div>
)}
{/* 主要金币发放记录 */}
<h4 style={{ margin: '16px 0 8px' }}></h4>
<Table
rowKey={(r) => `${r.source}-${r.created_at}-${r.coin}-${r.ecpm ?? ''}`}
size="small"
File diff suppressed because it is too large Load Diff
File diff suppressed because it is too large Load Diff
+18 -5
View File
@@ -1,13 +1,26 @@
'use client';
import { useEffect } from 'react';
import { useRouter } from 'next/navigation';
import { getToken } from '@/lib/auth';
export default function Home() {
const router = useRouter();
useEffect(() => {
router.replace(getToken() ? '/dashboard' : '/login');
}, [router]);
return null;
window.location.replace(getToken() ? '/dashboard' : '/login');
}, []);
return (
<main
style={{
minHeight: '100vh',
display: 'flex',
alignItems: 'center',
justifyContent: 'center',
background: '#f0f2f5',
color: '#595959',
fontFamily: 'system-ui, sans-serif',
}}
>
</main>
);
}
+81
View File
@@ -0,0 +1,81 @@
'use client';
import { useEffect, useState } from 'react';
import { App, Input, Modal } from 'antd';
import { api, errMsg } from '@/lib/api';
export type RiskUser = {
id: number;
phone: string;
is_high_risk: boolean;
high_risk_note: string | null;
};
type Props = {
user: RiskUser | null;
open: boolean;
onClose: () => void;
onDone: () => void | Promise<void>;
};
export function UserRiskModal({ user, open, onClose, onDone }: Props) {
const { message } = App.useApp();
const [note, setNote] = useState('');
const [saving, setSaving] = useState(false);
useEffect(() => {
if (open) setNote(user?.high_risk_note ?? '');
}, [open, user]);
const save = async () => {
if (!user) return;
const trimmed = note.trim();
if (!trimmed) {
message.warning('请输入标记为高风险的原因');
return;
}
setSaving(true);
try {
await api.post(`/admin/api/users/${user.id}/risk`, {
is_high_risk: true,
note: trimmed,
});
message.success(user.is_high_risk ? '高风险备注已更新' : '已标记为高风险');
await onDone();
onClose();
} catch (error) {
message.error(errMsg(error));
} finally {
setSaving(false);
}
};
return (
<Modal
title="高风险备注"
open={open}
okText="保存"
confirmLoading={saving}
onOk={save}
onCancel={onClose}
destroyOnHidden
>
<Input.TextArea
autoFocus
rows={5}
maxLength={500}
showCount
value={note}
placeholder="请输入标记为高风险的原因"
onChange={(event) => setNote(event.target.value)}
/>
</Modal>
);
}
export async function clearUserRisk(userId: number) {
await api.post(`/admin/api/users/${userId}/risk`, {
is_high_risk: false,
note: null,
});
}
+5 -1
View File
@@ -1,4 +1,8 @@
export type ReviewBadgeKey = '/withdraws' | '/price-reports' | '/feedbacks';
export type ReviewBadgeKey =
| '/invite-withdraws'
| '/withdraws'
| '/price-reports'
| '/feedbacks';
export const REVIEW_BADGE_REFRESH_EVENT = 'review-badge-refresh';
+112 -21
View File
@@ -52,6 +52,8 @@ export interface UserListItem {
status: string;
// 调试链接权限:开了的用户在 App 比价结果页/记录页可复制 price.shaguabijia.com 的 trace 调试链接
debug_trace_enabled: boolean;
is_high_risk: boolean;
high_risk_note: string | null;
// 运营「一键开启新手引导」:true = 该用户下次打开 App 会被强制重走新手引导,走完自动取消
force_onboarding: boolean;
wechat_openid: string | null;
@@ -143,7 +145,6 @@ export interface WithdrawOrder {
amount_cents: number;
// 提现类型:coin_cash(福利页提现,金币兑换现金) / invite_cash(邀请提现,邀请奖励金)
source: string;
user_name: string | null;
status: string; // reviewing / pending / success / failed / rejected
wechat_state: string | null;
transfer_bill_no: string | null;
@@ -157,6 +158,8 @@ export interface WithdrawOrder {
export interface WithdrawListItem extends WithdrawOrder {
phone: string | null;
nickname: string | null;
is_high_risk: boolean;
high_risk_note: string | null;
cumulative_success_cents: number; // 累计成功提现(分)
}
@@ -174,6 +177,8 @@ export interface WithdrawUserSnapshot {
id: number;
phone: string;
nickname: string | null;
is_high_risk: boolean;
high_risk_note: string | null;
status: string;
wechat_nickname: string | null;
wechat_avatar_url: string | null;
@@ -184,14 +189,34 @@ export interface WithdrawUserSnapshot {
withdraw_success_cents: number;
}
export interface InviteeDetail {
user_id: number;
phone: string;
registered_at: string;
invite_success: boolean;
first_compare_store: string | null;
first_compare_products: string | null;
first_order_store: string | null;
first_order_products: string | null;
first_order_amount_cents: number | null;
}
export interface InviteOverview {
invite_total: number;
invite_success_total: number;
items: InviteeDetail[];
}
export interface WithdrawDetail {
order: WithdrawOrder;
user: WithdrawUserSnapshot | null;
cumulative_success_cents: number;
risk_flags: string[];
risk_score: number;
recent_withdraws: WithdrawOrder[];
recent_cash_transactions: CashTxn[];
audit_logs: AuditLog[];
invite_overview: InviteOverview | null;
}
// 提现详情抽屉「用户统计区」:按时间窗口算的提现 + 看广告行为统计。
@@ -218,6 +243,92 @@ export interface UserCoinRecord {
coin: number;
}
// ===== 风控监控 =====
export type RiskKind = 'sms' | 'oneclick' | 'compare';
export interface RiskSummaryCard {
kind: RiskKind;
alert_subject_count: number;
today_total: number;
threshold: number;
rule_text: string;
}
export interface RiskMonitorSummary {
date: string;
updated_at: string;
cards: RiskSummaryCard[];
}
export interface RiskRuleConfig {
sms_hourly_threshold: number;
oneclick_daily_threshold: number;
compare_daily_threshold: number;
}
export interface RiskResetResponse {
ok: boolean;
reset_at: string;
reset_incident_count: number;
reset_counts: Record<RiskKind, number>;
}
export interface RiskIncidentItem {
incident_id: number;
kind: RiskKind;
subject_type: 'device' | 'user';
subject_id: string;
device_model: string | null;
first_used_at: string | null;
phone: string | null;
user_id: number | null;
registered_at: string | null;
common_device_id: string | null;
window_start: string;
window_end: string;
first_event_at: string;
triggered_at: string;
last_event_at: string;
event_count: number;
status: 'open' | 'ignored' | 'blocked' | 'resolved';
restricted: boolean;
restriction_id: number | null;
}
export interface RiskIncidentPage {
items: RiskIncidentItem[];
next_cursor: number | null;
total: number;
}
export interface RiskDetailItem {
id: number;
occurred_at: string;
outcome: string;
phone: string | null;
user_id: number | null;
username: string | null;
account_registered_at: string | null;
verified: boolean | null;
reason: string | null;
store_name: string | null;
product_names: string | null;
prices: Record<string, number | null> | null;
saved_amount_yuan: number | null;
status: string | null;
}
export interface RiskDetailPage {
kind: RiskKind;
incident_id: number;
event_count: number;
distinct_accounts: number | null;
items: RiskDetailItem[];
next_cursor: number | null;
total: number;
}
export interface WithdrawBulkItemResult {
out_bill_no: string;
ok: boolean;
@@ -232,26 +343,6 @@ export interface WithdrawBulkResult {
items: WithdrawBulkItemResult[];
}
export interface WithdrawLedgerCheck {
ok: boolean;
// 普通现金账(coin_cash)
cash_balance_total_cents: number;
cash_transaction_total_cents: number;
balance_diff_cents: number;
missing_withdraw_txn_count: number;
missing_refund_txn_count: number;
duplicate_refund_txn_count: number;
refund_txn_on_non_terminal_count: number;
// 邀请奖励金账(invite_cash:与普通现金物理隔离,各自对账)
invite_cash_balance_total_cents: number;
invite_cash_transaction_total_cents: number;
invite_balance_diff_cents: number;
invite_missing_withdraw_txn_count: number;
invite_missing_refund_txn_count: number;
invite_duplicate_refund_txn_count: number;
invite_refund_txn_on_non_terminal_count: number;
}
export interface WxpayHealthCheck {
ok: boolean;
wxpay_configured: boolean;