Compare commits
11 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
 linkeyu
|
694944cb5e | ||
|
linkeyu
|
27ff7936a5 | ||
|
linkeyu
|
47a7960100 | ||
|
linkeyu
|
7ca55d0dcb | ||
 zuochenyong
|
d29dce91fa | ||
|
linkeyu
|
2dfdc721b3 | ||
|
linkeyu
|
bce720df9e | ||
|
linkeyu
|
17ddf7ff1e | ||
|
linkeyu
|
ecf8150cfc | ||
|
linkeyu
|
1559d4faf0 | ||
|
linkeyu
|
9d32234015 |
@@ -32,6 +32,20 @@ server {
|
||||
proxy_read_timeout 60s;
|
||||
}
|
||||
|
||||
# 新手引导视频上传:视频比图片大一个量级,单独放宽到 100MB(对齐后端
|
||||
# settings.GUIDE_VIDEO_MAX_BYTES)。不放宽全站上限,避免其它接口被大 body 打。
|
||||
# 上传大文件耗时长,读超时同步放宽到 300s。
|
||||
location = /admin/api/guide-video/video {
|
||||
client_max_body_size 100m;
|
||||
proxy_pass http://127.0.0.1:8771;
|
||||
proxy_set_header Host $host;
|
||||
proxy_set_header X-Forwarded-For $remote_addr;
|
||||
proxy_set_header X-Forwarded-Proto $scheme;
|
||||
proxy_read_timeout 300s;
|
||||
proxy_send_timeout 300s;
|
||||
proxy_request_buffering off;
|
||||
}
|
||||
|
||||
# 用户上传媒体(上报截图 / 反馈截图 / 反馈二维码)由 App 后端(:8770)的 /media 托管。
|
||||
# admin 页面要展示这些图,经此同域反代过去(免跨域 + 免 https 页面引 http 图被拦)。
|
||||
# 前提:App 后端与本 admin 同机;若分机,把 127.0.0.1:8770 换成 App 后端可达地址。
|
||||
|
||||
@@ -76,16 +76,28 @@ const REWARD_STATUS_HINT: Record<string, string> = {
|
||||
|
||||
const PLAYBACK_STATUS_TAG: Record<string, { color: string; label: string }> = {
|
||||
completed: { color: 'green', label: '已完成' },
|
||||
too_short: { color: 'gold', label: '未满10秒' },
|
||||
too_short: { color: 'gold', label: '观看时长不足' },
|
||||
closed_early: { color: 'default', label: '提前关闭' },
|
||||
unknown: { color: 'default', label: '未知' },
|
||||
};
|
||||
|
||||
const ZERO_REVENUE_REWARD_VIDEO_STATUSES = new Set(['closed_early', 'too_short']);
|
||||
|
||||
function rewardStatuses(row: AdRevenueRow): string[] {
|
||||
if (row.sub_rewards?.length) return row.sub_rewards.map((reward) => reward.status);
|
||||
return row.status ? [row.status] : [];
|
||||
}
|
||||
|
||||
function effectiveRevenueYuan(row: AdRevenueRow): number {
|
||||
if (
|
||||
row.ad_type === 'reward_video'
|
||||
&& rewardStatuses(row).some((status) => ZERO_REVENUE_REWARD_VIDEO_STATUSES.has(status))
|
||||
) {
|
||||
return 0;
|
||||
}
|
||||
return row.row_revenue_yuan ?? row.revenue_yuan;
|
||||
}
|
||||
|
||||
function rewardStatusTag(row: AdRevenueRow) {
|
||||
const statuses = rewardStatuses(row);
|
||||
if (!row.has_reward || statuses.length === 0) {
|
||||
@@ -147,7 +159,7 @@ function playbackStatusTag(row: AdRevenueRow) {
|
||||
const hint = entries
|
||||
.map(([status, count]) => `${PLAYBACK_STATUS_TAG[status].label} ${count} 条`)
|
||||
.join('；');
|
||||
return { color: 'purple', label: '混合状态', hint: `${hint}。` };
|
||||
return { color: 'purple', label: '部分完成', hint: `${hint}。` };
|
||||
}
|
||||
|
||||
const fmtFactorRange = (a: number | null, b: number | null) => {
|
||||
@@ -546,10 +558,8 @@ export default function AdRevenueReportPage() {
|
||||
width: 110,
|
||||
align: 'right',
|
||||
// 一次比价/领券聚合行用 row_revenue_yuan(该次发奖广告 eCPM 折算之和),其它行用展示侧 revenue_yuan
|
||||
render: (v: number, r: AdRevenueRow) => {
|
||||
const rev = r.row_revenue_yuan ?? v;
|
||||
return rev.toFixed(4);
|
||||
},
|
||||
// 激励视频提前关闭/时长不足时防御性显示 0，与后端有效收益口径一致。
|
||||
render: (_v: number, r: AdRevenueRow) => effectiveRevenueYuan(r).toFixed(4),
|
||||
},
|
||||
{
|
||||
title: '发奖状态',
|
||||
@@ -695,7 +705,7 @@ export default function AdRevenueReportPage() {
|
||||
<br />
|
||||
<br />
|
||||
「预估收益」为客户端在广告展示(onAdShow)时上报 eCPM 折算的预估值(每千次展示 ÷1000
|
||||
累加),<b>只要广告展示就计入、不论是否看完发奖</b>;穿山甲会过滤无效/过短曝光,故预估值可能偏高,
|
||||
累加);<b>激励视频提前关闭或播放时长不足时按 0 计</b>,其他有效展示按 eCPM 折算。穿山甲仍可能过滤无效曝光,
|
||||
<b>实际收益一律以穿山甲后台结算为准</b>。测试应用多为 0。「广告位ID / 来源应用」为本期新增,历史记录留空。
|
||||
<br />
|
||||
<br />
|
||||
|
||||
@@ -0,0 +1,222 @@
|
||||
'use client';
|
||||
|
||||
import { useEffect, useState } from 'react';
|
||||
import { Button, Card, Space, Spin, Switch, Tag, Typography, Upload, message } from 'antd';
|
||||
import { DeleteOutlined, UploadOutlined } from '@ant-design/icons';
|
||||
import { api, errMsg } from '@/lib/api';
|
||||
import { canDo } from '@/lib/auth';
|
||||
import { mediaUrl } from '@/lib/media';
|
||||
import type { GuideVideoConfig as GuideCfg } from '@/lib/types';
|
||||
|
||||
const { Text } = Typography;
|
||||
|
||||
/** 后端 media.save_guide_video 只认 MP4 魔数;这里先在浏览器挡一道,省得白传 100MB。 */
|
||||
const MAX_BYTES = 100 * 1024 * 1024;
|
||||
|
||||
/**
|
||||
* 领券等候浮层的「新手引导视频」配置。
|
||||
*
|
||||
* 用户点首页「一键自动领取」→ 出等候浮层,浮层下方那块位置**前 3 次**放这支引导视频
|
||||
* (而不是广告),每次固定发 120 金币;播完若浮层还开着,自动接着放广告(原逻辑)。
|
||||
* 「系统配置 → 领券引导视频」tab 的一个区块。
|
||||
*
|
||||
* 后台只管两件事:**开关** 和 **换片**。次数(3)/ 金币(120)走服务端默认值,产品已拍板不再
|
||||
* 开放配置,所以这里不渲染输入框、PATCH 也不带这两个字段(后端仍保留字段与默认值)。
|
||||
*/
|
||||
export default function GuideVideoConfig() {
|
||||
const [cfg, setCfg] = useState<GuideCfg | null>(null);
|
||||
const [loading, setLoading] = useState(true);
|
||||
const [saving, setSaving] = useState(false);
|
||||
const [uploading, setUploading] = useState(false);
|
||||
|
||||
// 本地编辑态,保存时一次性 PATCH
|
||||
const [enabled, setEnabled] = useState(true);
|
||||
|
||||
const canEdit = canDo(['operator']);
|
||||
|
||||
const sync = (c: GuideCfg) => {
|
||||
setCfg(c);
|
||||
setEnabled(c.enabled);
|
||||
};
|
||||
|
||||
const load = async () => {
|
||||
setLoading(true);
|
||||
try {
|
||||
const { data } = await api.get<GuideCfg>('/admin/api/guide-video');
|
||||
sync(data);
|
||||
} finally {
|
||||
setLoading(false);
|
||||
}
|
||||
};
|
||||
useEffect(() => {
|
||||
load();
|
||||
}, []);
|
||||
|
||||
const save = async () => {
|
||||
setSaving(true);
|
||||
try {
|
||||
const { data } = await api.patch<GuideCfg>('/admin/api/guide-video', { enabled });
|
||||
sync(data);
|
||||
message.success('已保存，用户下一次进入领券浮层即生效');
|
||||
} catch (e) {
|
||||
message.error(errMsg(e));
|
||||
} finally {
|
||||
setSaving(false);
|
||||
}
|
||||
};
|
||||
|
||||
// antd Upload:beforeUpload 里自行 POST(multipart),返回 false 阻止其默认上传。
|
||||
const beforeUpload = (file: File) => {
|
||||
// 有些系统给 .mp4 的 type 是空串,不能只看 type,再兜一层扩展名。
|
||||
const looksMp4 = file.type === 'video/mp4' || /\.mp4$/i.test(file.name);
|
||||
if (!looksMp4) {
|
||||
message.error('仅支持 MP4 视频（H.264 编码）');
|
||||
return Upload.LIST_IGNORE;
|
||||
}
|
||||
if (file.size > MAX_BYTES) {
|
||||
message.error('视频不能超过 100MB');
|
||||
return Upload.LIST_IGNORE;
|
||||
}
|
||||
void uploadVideo(file);
|
||||
return false;
|
||||
};
|
||||
|
||||
const uploadVideo = async (file: File) => {
|
||||
const form = new FormData();
|
||||
form.append('file', file);
|
||||
setUploading(true);
|
||||
try {
|
||||
const { data } = await api.post<GuideCfg>('/admin/api/guide-video/video', form);
|
||||
sync(data);
|
||||
message.success('引导视频已更新，用户下一次进入领券浮层即生效');
|
||||
} catch (e) {
|
||||
message.error(errMsg(e));
|
||||
} finally {
|
||||
setUploading(false);
|
||||
}
|
||||
};
|
||||
|
||||
const removeVideo = async () => {
|
||||
setUploading(true);
|
||||
try {
|
||||
const { data } = await api.delete<GuideCfg>('/admin/api/guide-video/video');
|
||||
sync(data);
|
||||
message.success('已移除引导视频，领券浮层恢复为只放广告');
|
||||
} catch (e) {
|
||||
message.error(errMsg(e));
|
||||
} finally {
|
||||
setUploading(false);
|
||||
}
|
||||
};
|
||||
|
||||
return (
|
||||
<Card
|
||||
size="small"
|
||||
title="领券引导视频（App 领券等候浮层，前 3 次替代广告）"
|
||||
style={{ marginBottom: 16 }}
|
||||
extra={
|
||||
cfg?.updated_at ? (
|
||||
<Text type="secondary" style={{ fontSize: 12 }}>
|
||||
更新于 {new Date(cfg.updated_at).toLocaleString('zh-CN')}
|
||||
</Text>
|
||||
) : null
|
||||
}
|
||||
>
|
||||
<p style={{ color: '#999', marginTop: 0 }}>
|
||||
用户点「一键自动领取」后出现的等候浮层，下方那块广告位<b>前 3 次</b>改放这支引导视频。
|
||||
视频<b>不可快进</b>；播完或中途关闭都算看完，各发一次 <b>120 金币</b>；播完若浮层还开着，会自动接着放广告。
|
||||
次数<b>按账号</b>计（换设备不重置），<b>视频一开播就算用掉一次</b>。
|
||||
次数与金币走固定值、后台不开放调整；这里只管<b>开关</b>和<b>换片</b>，每次改动进审计日志。
|
||||
</p>
|
||||
{loading || !cfg ? (
|
||||
<Spin style={{ display: 'block', margin: '24px 0' }} />
|
||||
) : (
|
||||
<Space align="start" size={32} wrap>
|
||||
{/* 左:视频预览 */}
|
||||
<div>
|
||||
<Text type="secondary" style={{ fontSize: 12 }}>
|
||||
当前引导视频
|
||||
</Text>
|
||||
<div style={{ marginTop: 8, width: 240 }}>
|
||||
{cfg.video_url ? (
|
||||
// eslint-disable-next-line jsx-a11y/media-has-caption
|
||||
<video
|
||||
src={mediaUrl(cfg.video_url)}
|
||||
controls
|
||||
style={{
|
||||
width: 240,
|
||||
maxHeight: 420,
|
||||
borderRadius: 12,
|
||||
background: '#000',
|
||||
border: '1px solid #f0f0f0',
|
||||
}}
|
||||
/>
|
||||
) : (
|
||||
<div
|
||||
style={{
|
||||
width: 240,
|
||||
height: 320,
|
||||
borderRadius: 12,
|
||||
border: '1px dashed #d9d9d9',
|
||||
display: 'flex',
|
||||
alignItems: 'center',
|
||||
justifyContent: 'center',
|
||||
color: '#bbb',
|
||||
fontSize: 13,
|
||||
textAlign: 'center',
|
||||
padding: 16,
|
||||
}}
|
||||
>
|
||||
未上传视频
|
||||
<br />
|
||||
（领券浮层照旧只放广告）
|
||||
</div>
|
||||
)}
|
||||
</div>
|
||||
{!enabled && cfg.video_url && (
|
||||
<div style={{ color: '#fa8c16', fontSize: 12, marginTop: 6 }}>
|
||||
当前为「关闭」：浮层不放引导视频，直接放广告
|
||||
</div>
|
||||
)}
|
||||
</div>
|
||||
|
||||
{/* 右:编辑控件 */}
|
||||
<Space direction="vertical" size="middle" style={{ minWidth: 360 }}>
|
||||
<Space>
|
||||
<span>启用引导视频：</span>
|
||||
<Switch checked={enabled} disabled={!canEdit} onChange={setEnabled} />
|
||||
{!enabled && <Tag color="orange">已关闭</Tag>}
|
||||
</Space>
|
||||
|
||||
<Space wrap>
|
||||
<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 && (
|
||||
<Button
|
||||
icon={<DeleteOutlined />}
|
||||
danger
|
||||
loading={uploading}
|
||||
disabled={!canEdit}
|
||||
onClick={removeVideo}
|
||||
>
|
||||
移除视频
|
||||
</Button>
|
||||
)}
|
||||
<Text type="secondary" style={{ fontSize: 12 }}>
|
||||
MP4（H.264），≤100MB
|
||||
</Text>
|
||||
</Space>
|
||||
|
||||
<Button type="primary" loading={saving} disabled={!canEdit} onClick={save}>
|
||||
保存开关
|
||||
</Button>
|
||||
{!canEdit && <Text type="secondary">仅 operator / super_admin 可修改</Text>}
|
||||
</Space>
|
||||
</Space>
|
||||
)}
|
||||
</Card>
|
||||
);
|
||||
}
|
||||
@@ -6,6 +6,7 @@ import { api, errMsg } from '@/lib/api';
|
||||
import HomeMarqueeSeeds from './HomeMarqueeSeeds';
|
||||
import HomeStatsConfig from './HomeStatsConfig';
|
||||
import FeedbackQrConfig from './FeedbackQrConfig';
|
||||
import GuideVideoConfig from './GuideVideoConfig';
|
||||
|
||||
interface ConfigItem {
|
||||
key: string;
|
||||
@@ -164,6 +165,7 @@ export default function ConfigPage() {
|
||||
},
|
||||
{ key: 'welfare', label: '福利页', children: welfareConfig },
|
||||
{ key: 'feedback-qr', label: '反馈二维码', children: <FeedbackQrConfig /> },
|
||||
{ key: 'guide-video', label: '领券引导视频', children: <GuideVideoConfig /> },
|
||||
]}
|
||||
/>
|
||||
</div>
|
||||
|
||||
@@ -149,6 +149,9 @@ function PointScorePopover({ row }: { row: CouponDataRow }) {
|
||||
return <Typography.Text type="secondary">-</Typography.Text>;
|
||||
}
|
||||
const score = `${row.point_success_count}/${row.point_total_count}`;
|
||||
const scoreWithRate = `${score}（${(
|
||||
row.point_success_count / row.point_total_count * 100
|
||||
).toFixed(1)}%）`;
|
||||
const scoreColor =
|
||||
row.point_success_count === row.point_total_count
|
||||
? STATUS_TAG.completed.color
|
||||
@@ -220,7 +223,7 @@ function PointScorePopover({ row }: { row: CouponDataRow }) {
|
||||
)}
|
||||
>
|
||||
<Button type="link" size="small" style={{ height: 'auto', padding: 0, color: scoreColor }}>
|
||||
{score}
|
||||
{scoreWithRate}
|
||||
</Button>
|
||||
</Popover>
|
||||
);
|
||||
@@ -602,9 +605,9 @@ export default function CouponDataPage() {
|
||||
render: (v: number | null) => fmtSec(v),
|
||||
},
|
||||
{
|
||||
title: '百分比',
|
||||
title: '单券成功率',
|
||||
key: 'point_success_rate',
|
||||
width: 110,
|
||||
width: 150,
|
||||
render: (_: unknown, r: CouponDataRow) => <PointScorePopover row={r} />,
|
||||
},
|
||||
{
|
||||
|
||||
@@ -1065,14 +1065,14 @@ export default function DashboardPage() {
|
||||
value={fmtInt(periodData?.coins.reward_video_coin_total)}
|
||||
delta={rewardVideoCoinRatio.value}
|
||||
deltaTone={rewardVideoCoinRatio.tone}
|
||||
hint="独立统计看视频发放，不再重复计入领券奖励。"
|
||||
hint="普通看视频与历史签到膨胀的实发金币之和，不再重复计入领券奖励或常规任务。"
|
||||
/>
|
||||
<StatCard
|
||||
title="常规任务金币"
|
||||
value={fmtInt(regularTaskCoinTotal)}
|
||||
delta={regularTaskCoinRatio.value}
|
||||
deltaTone={regularTaskCoinRatio.tone}
|
||||
hint="每日签到、历史签到膨胀、通知/其他任务、上报更低价和反馈采纳的实发金币之和。"
|
||||
hint="每日签到、通知/其他任务、上报更低价和反馈采纳的实发金币之和。"
|
||||
/>
|
||||
<StatCard
|
||||
title="本期提现金额"
|
||||
|
||||
@@ -4,11 +4,15 @@ import { useEffect, useState } from 'react';
|
||||
import type { ColumnsType } from 'antd/es/table';
|
||||
import type { SorterResult } from 'antd/es/table/interface';
|
||||
import {
|
||||
App,
|
||||
Button,
|
||||
Card,
|
||||
DatePicker,
|
||||
Form,
|
||||
Image,
|
||||
Input,
|
||||
InputNumber,
|
||||
Modal,
|
||||
Select,
|
||||
Space,
|
||||
Statistic,
|
||||
@@ -17,10 +21,12 @@ import {
|
||||
Typography,
|
||||
} from 'antd';
|
||||
import type { Dayjs } from 'dayjs';
|
||||
import { api } from '@/lib/api';
|
||||
import { api, errMsg } from '@/lib/api';
|
||||
import { canDo } from '@/lib/auth';
|
||||
import { formatWallTime } from '@/lib/format';
|
||||
import { refreshReviewBadge } from '@/lib/reviewBadge';
|
||||
import { BULK_REVIEW_MAX, bulkFailureReasonText, failedReviewIds } from '@/lib/bulkAction';
|
||||
import type { BulkReviewResult } from '@/lib/bulkAction';
|
||||
import { usePagedList } from '@/lib/usePagedList';
|
||||
import type { Feedback, FeedbackSummary } from '@/lib/types';
|
||||
import FeedbackHandleDrawer from './FeedbackHandleDrawer';
|
||||
@@ -28,6 +34,7 @@ import UserRecordsDrawer from '@/components/UserRecordsDrawer';
|
||||
|
||||
const { Text, Paragraph } = Typography;
|
||||
const { RangePicker } = DatePicker;
|
||||
const REWARD_MAX = 10000;
|
||||
|
||||
// 截图是 app-server 的 /media 相对路径,本地由 :8770 提供(NEXT_PUBLIC_MEDIA_BASE);生产同域走 nginx 代理。
|
||||
const MEDIA_BASE = process.env.NEXT_PUBLIC_MEDIA_BASE || '';
|
||||
@@ -155,6 +162,8 @@ const RECORD_COLUMNS: ColumnsType<Feedback> = [
|
||||
];
|
||||
|
||||
export default function FeedbacksPage() {
|
||||
const { message } = App.useApp();
|
||||
const [bulkForm] = Form.useForm();
|
||||
// 筛选草稿:点「查询」才应用(避免输入即刷新)
|
||||
const [status, setStatus] = useState<string | undefined>();
|
||||
const [source, setSource] = useState<string | undefined>();
|
||||
@@ -171,6 +180,19 @@ export default function FeedbacksPage() {
|
||||
usePagedList<Feedback>('/admin/api/feedbacks', filters);
|
||||
|
||||
const canReview = canDo(['operator']);
|
||||
const [selectedRowKeys, setSelectedRowKeys] = useState<number[]>([]);
|
||||
const [bulkAction, setBulkAction] = useState<'approve' | 'reject' | null>(null);
|
||||
const [bulkSubmitting, setBulkSubmitting] = useState(false);
|
||||
const selectedFeedbacks = items.filter(
|
||||
(item) => selectedRowKeys.includes(item.id) && isPending(item.status),
|
||||
);
|
||||
|
||||
useEffect(() => {
|
||||
const visiblePendingIds = new Set(
|
||||
items.filter((item) => isPending(item.status)).map((item) => item.id),
|
||||
);
|
||||
setSelectedRowKeys((keys) => keys.filter((id) => visiblePendingIds.has(id)));
|
||||
}, [items]);
|
||||
|
||||
const [summary, setSummary] = useState<FeedbackSummary | null>(null);
|
||||
const loadSummary = async () => {
|
||||
@@ -236,6 +258,61 @@ export default function FeedbacksPage() {
|
||||
const sortOrderOf = (field: SortField) =>
|
||||
sortBy === field ? (sortOrder === 'asc' ? 'ascend' : 'descend') : null;
|
||||
|
||||
const openBulkModal = (action: 'approve' | 'reject') => {
|
||||
if (!selectedFeedbacks.length) return;
|
||||
if (selectedFeedbacks.length > BULK_REVIEW_MAX) {
|
||||
message.warning(`单次最多审核 ${BULK_REVIEW_MAX} 条反馈`);
|
||||
return;
|
||||
}
|
||||
bulkForm.resetFields();
|
||||
setBulkAction(action);
|
||||
};
|
||||
|
||||
const submitBulkReview = async () => {
|
||||
if (!bulkAction || !selectedFeedbacks.length) return;
|
||||
const values = await bulkForm.validateFields();
|
||||
const targets = selectedFeedbacks;
|
||||
setBulkSubmitting(true);
|
||||
try {
|
||||
const { data } = await api.post<BulkReviewResult>(
|
||||
`/admin/api/feedbacks/bulk/${bulkAction}`,
|
||||
bulkAction === 'approve'
|
||||
? {
|
||||
ids: targets.map((item) => item.id),
|
||||
reward_coins: values.reward_coins,
|
||||
note: values.note?.trim() || null,
|
||||
reply: values.reply?.trim() || null,
|
||||
}
|
||||
: {
|
||||
ids: targets.map((item) => item.id),
|
||||
reason: values.reason.trim(),
|
||||
note: values.note?.trim() || null,
|
||||
reply: values.reply?.trim() || null,
|
||||
},
|
||||
);
|
||||
const failedIds = failedReviewIds(data);
|
||||
setSelectedRowKeys(failedIds);
|
||||
setBulkAction(null);
|
||||
bulkForm.resetFields();
|
||||
if (failedIds.length) reload();
|
||||
else onPageChange(1, pageSize);
|
||||
loadSummary();
|
||||
refreshReviewBadge('/feedbacks');
|
||||
const label = bulkAction === 'approve' ? '批量采纳' : '批量拒绝';
|
||||
if (failedIds.length) {
|
||||
message.warning(
|
||||
`${label}完成：成功 ${data.success} 条，失败 ${failedIds.length} 条；失败项已保留勾选${bulkFailureReasonText(data)}`,
|
||||
);
|
||||
} else {
|
||||
message.success(`${label}完成：成功 ${data.success} 条`);
|
||||
}
|
||||
} catch (e) {
|
||||
message.error(errMsg(e));
|
||||
} finally {
|
||||
setBulkSubmitting(false);
|
||||
}
|
||||
};
|
||||
|
||||
const columns: ColumnsType<Feedback> = [
|
||||
{
|
||||
title: '用户ID',
|
||||
@@ -411,16 +488,58 @@ export default function FeedbacksPage() {
|
||||
<Button onClick={resetFilters}>重置</Button>
|
||||
</Space>
|
||||
|
||||
{canReview && (
|
||||
<Space wrap style={{ display: 'flex', marginBottom: 12 }}>
|
||||
<Text>已选 <Text strong>{selectedFeedbacks.length}</Text> 条待审核反馈</Text>
|
||||
<Button
|
||||
type="primary"
|
||||
disabled={!selectedFeedbacks.length || selectedFeedbacks.length > BULK_REVIEW_MAX}
|
||||
onClick={() => openBulkModal('approve')}
|
||||
>
|
||||
批量采纳
|
||||
</Button>
|
||||
<Button
|
||||
danger
|
||||
disabled={!selectedFeedbacks.length || selectedFeedbacks.length > BULK_REVIEW_MAX}
|
||||
onClick={() => openBulkModal('reject')}
|
||||
>
|
||||
批量拒绝
|
||||
</Button>
|
||||
{!!selectedFeedbacks.length && (
|
||||
<Button onClick={() => setSelectedRowKeys([])}>取消选择</Button>
|
||||
)}
|
||||
</Space>
|
||||
)}
|
||||
|
||||
<Table
|
||||
rowKey="id"
|
||||
columns={columns}
|
||||
dataSource={items}
|
||||
rowSelection={
|
||||
canReview
|
||||
? {
|
||||
selectedRowKeys,
|
||||
onChange: (keys) => {
|
||||
const ids = keys as number[];
|
||||
if (ids.length > BULK_REVIEW_MAX) {
|
||||
message.warning(`单次最多选择 ${BULK_REVIEW_MAX} 条待审核反馈`);
|
||||
}
|
||||
setSelectedRowKeys(ids.slice(0, BULK_REVIEW_MAX));
|
||||
},
|
||||
getCheckboxProps: (record) => ({
|
||||
disabled: !isPending(record.status),
|
||||
name: `选择反馈 #${record.id}`,
|
||||
}),
|
||||
}
|
||||
: undefined
|
||||
}
|
||||
loading={loading}
|
||||
pagination={{
|
||||
current: page,
|
||||
pageSize,
|
||||
total,
|
||||
showSizeChanger: true,
|
||||
pageSizeOptions: [10, 20, 50],
|
||||
showTotal: (t) => `共 ${t} 条反馈`,
|
||||
onChange: onPageChange,
|
||||
}}
|
||||
@@ -428,6 +547,88 @@ export default function FeedbacksPage() {
|
||||
scroll={{ x: 1720 }}
|
||||
/>
|
||||
|
||||
<Modal
|
||||
title={
|
||||
bulkAction === 'approve'
|
||||
? `批量采纳 ${selectedFeedbacks.length} 条反馈`
|
||||
: `批量拒绝 ${selectedFeedbacks.length} 条反馈`
|
||||
}
|
||||
open={bulkAction != null}
|
||||
okText={bulkAction === 'approve' ? '批量采纳并发金币' : '确认批量拒绝'}
|
||||
okButtonProps={{ danger: bulkAction === 'reject' }}
|
||||
confirmLoading={bulkSubmitting}
|
||||
onOk={submitBulkReview}
|
||||
onCancel={() => {
|
||||
if (bulkSubmitting) return;
|
||||
setBulkAction(null);
|
||||
bulkForm.resetFields();
|
||||
}}
|
||||
destroyOnHidden
|
||||
>
|
||||
<Text type="secondary">
|
||||
下列设置会统一应用到已选的 {selectedFeedbacks.length}
|
||||
条反馈。批量操作前请确认每条内容适用相同处理结果。
|
||||
</Text>
|
||||
<Form form={bulkForm} layout="vertical" preserve={false} style={{ marginTop: 16 }}>
|
||||
{bulkAction === 'approve' ? (
|
||||
<Form.Item
|
||||
name="reward_coins"
|
||||
label={`每条奖励金币（必填，1 ~ ${REWARD_MAX}）`}
|
||||
rules={[
|
||||
{ required: true, message: '请输入每条反馈的奖励金币' },
|
||||
{ type: 'number', min: 1, max: REWARD_MAX, message: `请输入 1 ~ ${REWARD_MAX}` },
|
||||
]}
|
||||
>
|
||||
<InputNumber
|
||||
min={1}
|
||||
max={REWARD_MAX}
|
||||
style={{ width: '100%' }}
|
||||
placeholder="每条反馈发放相同金币"
|
||||
/>
|
||||
</Form.Item>
|
||||
) : (
|
||||
<Form.Item
|
||||
name="reason"
|
||||
label="未采纳原因（必填，用户可见）"
|
||||
rules={[
|
||||
{ required: true, whitespace: true, message: '请填写未采纳原因' },
|
||||
{ max: 256, message: '最多 256 字' },
|
||||
]}
|
||||
>
|
||||
<Input.TextArea
|
||||
rows={3}
|
||||
maxLength={256}
|
||||
showCount
|
||||
placeholder="同一原因将发送给全部已选用户"
|
||||
/>
|
||||
</Form.Item>
|
||||
)}
|
||||
<Form.Item
|
||||
name="note"
|
||||
label={
|
||||
bulkAction === 'approve'
|
||||
? '采纳要点 / 审核备注（选填，内部）'
|
||||
: '内部备注（选填）'
|
||||
}
|
||||
rules={[{ max: 256, message: '最多 256 字' }]}
|
||||
>
|
||||
<Input.TextArea rows={2} maxLength={256} showCount />
|
||||
</Form.Item>
|
||||
<Form.Item
|
||||
name="reply"
|
||||
label="给用户的回复（选填，用户可见）"
|
||||
rules={[{ max: 256, message: '最多 256 字' }]}
|
||||
>
|
||||
<Input.TextArea
|
||||
rows={2}
|
||||
maxLength={256}
|
||||
showCount
|
||||
placeholder="同一回复将发送给全部已选用户"
|
||||
/>
|
||||
</Form.Item>
|
||||
</Form>
|
||||
</Modal>
|
||||
|
||||
<FeedbackHandleDrawer
|
||||
feedback={drawerFb}
|
||||
open={drawerOpen}
|
||||
|
||||
@@ -17,6 +17,7 @@ import {
|
||||
NotificationOutlined,
|
||||
ProfileOutlined,
|
||||
SafetyCertificateOutlined,
|
||||
SecurityScanOutlined,
|
||||
SettingOutlined,
|
||||
ShareAltOutlined,
|
||||
TeamOutlined,
|
||||
@@ -95,6 +96,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: '埋点日志' },
|
||||
|
||||
@@ -23,6 +23,8 @@ import { api, errMsg } from '@/lib/api';
|
||||
import { canDo } from '@/lib/auth';
|
||||
import { mediaUrl } from '@/lib/media';
|
||||
import { refreshReviewBadge } from '@/lib/reviewBadge';
|
||||
import { BULK_REVIEW_MAX, bulkFailureReasonText, failedReviewIds } from '@/lib/bulkAction';
|
||||
import type { BulkReviewResult } from '@/lib/bulkAction';
|
||||
import { usePagedList } from '@/lib/usePagedList';
|
||||
import type { PriceReport, PriceReportSummary } from '@/lib/types';
|
||||
import UserRecordsDrawer from '@/components/UserRecordsDrawer';
|
||||
@@ -132,7 +134,10 @@ export default function PriceReportsPage() {
|
||||
const [activeStatus, setActiveStatus] = useState('pending');
|
||||
const [summary, setSummary] = useState<PriceReportSummary | null>(null);
|
||||
const [rejecting, setRejecting] = useState<PriceReport | null>(null);
|
||||
const [bulkRejecting, setBulkRejecting] = useState<PriceReport[]>([]);
|
||||
const [rejectReason, setRejectReason] = useState('');
|
||||
const [rejectSubmitting, setRejectSubmitting] = useState(false);
|
||||
const [selectedRowKeys, setSelectedRowKeys] = useState<number[]>([]);
|
||||
// 提交时间列服务端排序(默认按提交时间倒序,最新在前)
|
||||
const [sortBy, setSortBy] = useState<SortField>('created_at');
|
||||
const [sortOrder, setSortOrder] = useState<'asc' | 'desc'>('desc');
|
||||
@@ -165,6 +170,16 @@ export default function PriceReportsPage() {
|
||||
};
|
||||
|
||||
const canReview = canDo(['operator']);
|
||||
const selectedReports = items.filter(
|
||||
(item) => selectedRowKeys.includes(item.id) && item.status === 'pending',
|
||||
);
|
||||
|
||||
useEffect(() => {
|
||||
const visiblePendingIds = new Set(
|
||||
items.filter((item) => item.status === 'pending').map((item) => item.id),
|
||||
);
|
||||
setSelectedRowKeys((keys) => keys.filter((id) => visiblePendingIds.has(id)));
|
||||
}, [items]);
|
||||
|
||||
const loadSummary = async () => {
|
||||
try {
|
||||
@@ -183,6 +198,49 @@ export default function PriceReportsPage() {
|
||||
loadSummary();
|
||||
};
|
||||
|
||||
const reportBulkResult = (label: string, result: BulkReviewResult) => {
|
||||
const failedIds = failedReviewIds(result);
|
||||
setSelectedRowKeys(failedIds);
|
||||
refreshReviewBadge('/price-reports');
|
||||
loadSummary();
|
||||
if (failedIds.length) reload();
|
||||
else onPageChange(1, pageSize);
|
||||
if (failedIds.length) {
|
||||
message.warning(
|
||||
`${label}完成：成功 ${result.success} 条，失败 ${failedIds.length} 条；失败项已保留勾选${bulkFailureReasonText(result)}`,
|
||||
);
|
||||
} else {
|
||||
message.success(`${label}完成：成功 ${result.success} 条`);
|
||||
}
|
||||
};
|
||||
|
||||
const bulkApprove = () => {
|
||||
const targets = selectedReports;
|
||||
if (!targets.length) return;
|
||||
if (targets.length > BULK_REVIEW_MAX) {
|
||||
message.warning(`单次最多审核 ${BULK_REVIEW_MAX} 条记录`);
|
||||
return;
|
||||
}
|
||||
modal.confirm({
|
||||
title: `确认批量通过 ${targets.length} 条低价上报？`,
|
||||
icon: <CheckCircleOutlined style={{ color: '#52c41a' }} />,
|
||||
content: `通过后将向每位用户发放 1000 金币，共发放 ${targets.length * 1000} 金币。请确认已逐条核实截图。`,
|
||||
okText: '批量通过并发金币',
|
||||
onOk: async () => {
|
||||
try {
|
||||
const { data } = await api.post<BulkReviewResult>(
|
||||
'/admin/api/price-reports/bulk/approve',
|
||||
{ ids: targets.map((item) => item.id) },
|
||||
);
|
||||
reportBulkResult('批量通过', data);
|
||||
} catch (e) {
|
||||
message.error(errMsg(e));
|
||||
throw e;
|
||||
}
|
||||
},
|
||||
});
|
||||
};
|
||||
|
||||
const approve = (r: PriceReport) => {
|
||||
modal.confirm({
|
||||
title: '确认通过该上报?',
|
||||
@@ -214,21 +272,38 @@ export default function PriceReportsPage() {
|
||||
};
|
||||
|
||||
const confirmReject = async () => {
|
||||
if (!rejecting) return;
|
||||
const targets = bulkRejecting.length ? bulkRejecting : rejecting ? [rejecting] : [];
|
||||
if (!targets.length) return;
|
||||
if (targets.length > BULK_REVIEW_MAX) {
|
||||
message.warning(`单次最多审核 ${BULK_REVIEW_MAX} 条记录`);
|
||||
return;
|
||||
}
|
||||
const reason = rejectReason.trim();
|
||||
if (!reason) {
|
||||
message.warning('请填写拒绝理由');
|
||||
return;
|
||||
}
|
||||
setRejectSubmitting(true);
|
||||
try {
|
||||
await api.post(`/admin/api/price-reports/${rejecting.id}/reject`, { reason });
|
||||
refreshReviewBadge('/price-reports');
|
||||
message.success('已拒绝');
|
||||
if (bulkRejecting.length) {
|
||||
const { data } = await api.post<BulkReviewResult>(
|
||||
'/admin/api/price-reports/bulk/reject',
|
||||
{ ids: targets.map((item) => item.id), reason },
|
||||
);
|
||||
reportBulkResult('批量拒绝', data);
|
||||
} else {
|
||||
await api.post(`/admin/api/price-reports/${targets[0].id}/reject`, { reason });
|
||||
refreshReviewBadge('/price-reports');
|
||||
message.success('已拒绝');
|
||||
refreshAfterChange();
|
||||
}
|
||||
setRejecting(null);
|
||||
setBulkRejecting([]);
|
||||
setRejectReason('');
|
||||
refreshAfterChange();
|
||||
} catch (e) {
|
||||
message.error(errMsg(e));
|
||||
} finally {
|
||||
setRejectSubmitting(false);
|
||||
}
|
||||
};
|
||||
|
||||
@@ -393,10 +468,56 @@ export default function PriceReportsPage() {
|
||||
onChange={setActiveStatus}
|
||||
items={STATUS_TABS.map((t) => ({ key: t.key, label: t.label }))}
|
||||
/>
|
||||
{canReview && (
|
||||
<Space wrap style={{ marginBottom: 16 }}>
|
||||
<Text>已选 <Text strong>{selectedReports.length}</Text> 条待审核记录</Text>
|
||||
<Button
|
||||
type="primary"
|
||||
icon={<CheckCircleOutlined />}
|
||||
disabled={!selectedReports.length || selectedReports.length > BULK_REVIEW_MAX}
|
||||
onClick={bulkApprove}
|
||||
>
|
||||
批量通过
|
||||
</Button>
|
||||
<Button
|
||||
danger
|
||||
icon={<CloseCircleOutlined />}
|
||||
disabled={!selectedReports.length || selectedReports.length > BULK_REVIEW_MAX}
|
||||
onClick={() => {
|
||||
setRejecting(null);
|
||||
setBulkRejecting(selectedReports);
|
||||
setRejectReason('');
|
||||
}}
|
||||
>
|
||||
批量拒绝
|
||||
</Button>
|
||||
{!!selectedReports.length && (
|
||||
<Button onClick={() => setSelectedRowKeys([])}>取消选择</Button>
|
||||
)}
|
||||
</Space>
|
||||
)}
|
||||
<Table
|
||||
rowKey="id"
|
||||
columns={columns}
|
||||
dataSource={items}
|
||||
rowSelection={
|
||||
canReview
|
||||
? {
|
||||
selectedRowKeys,
|
||||
onChange: (keys) => {
|
||||
const ids = keys as number[];
|
||||
if (ids.length > BULK_REVIEW_MAX) {
|
||||
message.warning(`单次最多选择 ${BULK_REVIEW_MAX} 条待审核记录`);
|
||||
}
|
||||
setSelectedRowKeys(ids.slice(0, BULK_REVIEW_MAX));
|
||||
},
|
||||
getCheckboxProps: (record) => ({
|
||||
disabled: record.status !== 'pending',
|
||||
name: `选择低价上报 #${record.id}`,
|
||||
}),
|
||||
}
|
||||
: undefined
|
||||
}
|
||||
loading={loading}
|
||||
onChange={onTableChange}
|
||||
pagination={{
|
||||
@@ -404,6 +525,7 @@ export default function PriceReportsPage() {
|
||||
pageSize,
|
||||
total,
|
||||
showSizeChanger: true,
|
||||
pageSizeOptions: [10, 20, 50],
|
||||
showTotal: (t) => `共 ${t} 条`,
|
||||
onChange: onPageChange,
|
||||
}}
|
||||
@@ -412,21 +534,25 @@ export default function PriceReportsPage() {
|
||||
</Card>
|
||||
|
||||
<Modal
|
||||
title="拒绝上报"
|
||||
open={!!rejecting}
|
||||
title={bulkRejecting.length ? `批量拒绝 ${bulkRejecting.length} 条低价上报` : '拒绝上报'}
|
||||
open={!!(rejecting || bulkRejecting.length)}
|
||||
okText="确认拒绝"
|
||||
confirmLoading={rejectSubmitting}
|
||||
okButtonProps={{ danger: true, icon: <CloseCircleOutlined /> }}
|
||||
onOk={confirmReject}
|
||||
onCancel={() => {
|
||||
setRejecting(null);
|
||||
setBulkRejecting([]);
|
||||
setRejectReason('');
|
||||
}}
|
||||
>
|
||||
{rejecting && (
|
||||
{(rejecting || bulkRejecting.length > 0) && (
|
||||
<Space direction="vertical" style={{ width: '100%' }}>
|
||||
<Text>
|
||||
用户 #{rejecting.user_id} · {rejecting.store_name || '-'}
|
||||
</Text>
|
||||
{bulkRejecting.length ? (
|
||||
<Text type="secondary">以下原因会统一应用到已选的 {bulkRejecting.length} 条记录。</Text>
|
||||
) : rejecting ? (
|
||||
<Text>用户 #{rejecting.user_id} · {rejecting.store_name || '-'}</Text>
|
||||
) : null}
|
||||
<Space wrap>
|
||||
{REJECT_TEMPLATES.map((tpl) => (
|
||||
<Button size="small" key={tpl} onClick={() => setRejectReason(tpl)}>
|
||||
|
||||
@@ -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;
|
||||
}
|
||||
}
|
||||
@@ -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>
|
||||
);
|
||||
}
|
||||
+153
-185
@@ -29,7 +29,6 @@ import {
|
||||
CheckCircleOutlined,
|
||||
ClearOutlined,
|
||||
CloseCircleOutlined,
|
||||
FilterOutlined,
|
||||
ReloadOutlined,
|
||||
SearchOutlined,
|
||||
SortAscendingOutlined,
|
||||
@@ -86,42 +85,6 @@ const STATUS_TABS = [
|
||||
];
|
||||
|
||||
const REJECT_TEMPLATES = ['账号异常', '提现金额异常', '微信实名不匹配', '风控拦截', '其他原因'];
|
||||
const QUICK_FILTER_OPTIONS = [
|
||||
{ value: 'abnormal', label: '异常单' },
|
||||
{ value: 'failed', label: '打款失败' },
|
||||
{ value: 'overdue_reviewing', label: '待审核超30分钟' },
|
||||
{ value: 'pending_overdue', label: '打款中超15分钟' },
|
||||
{ value: 'today', label: '今日申请' },
|
||||
{ value: 'high_risk', label: '高风险用户' },
|
||||
];
|
||||
const QUICK_FILTER_STATUS: Record<string, string> = {
|
||||
abnormal: 'all',
|
||||
failed: 'failed',
|
||||
overdue_reviewing: 'reviewing',
|
||||
pending_overdue: 'pending',
|
||||
high_risk: 'all',
|
||||
};
|
||||
const SORT_OPTIONS = [
|
||||
{ value: 'created_at', label: '申请时间' },
|
||||
{ value: 'amount_cents', label: '提现金额' },
|
||||
];
|
||||
// 提现类型:coin_cash=福利页提现(金币兑换现金) / invite_cash=邀请提现(邀请奖励金)
|
||||
const SOURCE_LABEL: Record<string, string> = {
|
||||
coin_cash: '福利页提现',
|
||||
invite_cash: '邀请提现',
|
||||
};
|
||||
const SOURCE_COLOR: Record<string, string> = {
|
||||
coin_cash: 'blue',
|
||||
invite_cash: 'purple',
|
||||
};
|
||||
const SOURCE_OPTIONS = [
|
||||
{ value: 'coin_cash', label: '福利页提现' },
|
||||
{ value: 'invite_cash', label: '邀请提现' },
|
||||
];
|
||||
const DATE_FIELD_OPTIONS = [
|
||||
{ value: 'created_at', label: '申请时间' },
|
||||
{ value: 'updated_at', label: '更新时间' },
|
||||
];
|
||||
|
||||
function statusTag(status: string) {
|
||||
return <Tag color={STATUS_COLOR[status]}>{STATUS_LABEL[status] || status}</Tag>;
|
||||
@@ -142,7 +105,7 @@ function actionLabel(action: string) {
|
||||
'withdraw.approve': '审核通过',
|
||||
'withdraw.reject': '审核拒绝',
|
||||
'withdraw.refresh': '查单刷新',
|
||||
'withdraw.reconcile': '批量对账',
|
||||
'withdraw.reconcile': '处理超时订单',
|
||||
};
|
||||
return labels[action] || action;
|
||||
}
|
||||
@@ -182,8 +145,11 @@ export default function WithdrawsPage() {
|
||||
const [activeStatus, setActiveStatus] = useState('reviewing');
|
||||
const [summary, setSummary] = useState<WithdrawSummary | null>(null);
|
||||
const [health, setHealth] = useState<WxpayHealthCheck | null>(null);
|
||||
const [healthLoading, setHealthLoading] = useState(false);
|
||||
const [healthCheckedAt, setHealthCheckedAt] = useState<number | null>(null);
|
||||
const [ledger, setLedger] = useState<WithdrawLedgerCheck | null>(null);
|
||||
const [ledgerLoading, setLedgerLoading] = useState(false);
|
||||
const [ledgerCheckedAt, setLedgerCheckedAt] = useState<number | null>(null);
|
||||
const [drawerOpen, setDrawerOpen] = useState(false);
|
||||
const [detail, setDetail] = useState<WithdrawDetail | null>(null);
|
||||
const [detailLoading, setDetailLoading] = useState(false);
|
||||
@@ -194,21 +160,15 @@ export default function WithdrawsPage() {
|
||||
const [searchDraft, setSearchDraft] = useState('');
|
||||
const [keyword, setKeyword] = useState('');
|
||||
const [dateRange, setDateRange] = useState<[Dayjs, Dayjs] | null>(null);
|
||||
const [dateField, setDateField] = useState<'created_at' | 'updated_at'>('created_at');
|
||||
const [sortBy, setSortBy] = useState<'created_at' | 'amount_cents'>('created_at');
|
||||
const [sortOrder, setSortOrder] = useState<'asc' | 'desc'>('desc');
|
||||
const [quickFilter, setQuickFilter] = useState<string | undefined>(undefined);
|
||||
const [source, setSource] = useState<string | undefined>(undefined);
|
||||
|
||||
const filters: Record<string, unknown> = {};
|
||||
if (activeStatus !== 'all') filters.status = activeStatus;
|
||||
if (source) filters.source = source;
|
||||
if (keyword.trim()) filters.keyword = keyword.trim();
|
||||
if (dateRange?.[0]) filters.date_from = dateRange[0].startOf('day').toISOString();
|
||||
if (dateRange?.[1]) filters.date_to = dateRange[1].endOf('day').toISOString();
|
||||
if (quickFilter) filters.quick_filter = quickFilter;
|
||||
filters.date_field = dateField;
|
||||
filters.sort_by = sortBy;
|
||||
filters.date_field = 'created_at';
|
||||
filters.sort_by = 'created_at';
|
||||
filters.sort_order = sortOrder;
|
||||
const filterKey = JSON.stringify(filters);
|
||||
const { items, total, page, pageSize, loading, onChange: onPageChange, reload } =
|
||||
@@ -223,27 +183,7 @@ export default function WithdrawsPage() {
|
||||
setSearchDraft('');
|
||||
setKeyword('');
|
||||
setDateRange(null);
|
||||
setDateField('created_at');
|
||||
setSortBy('created_at');
|
||||
setSortOrder('desc');
|
||||
setQuickFilter(undefined);
|
||||
setSource(undefined);
|
||||
};
|
||||
|
||||
const applyQuickFilter = (value?: string) => {
|
||||
setQuickFilter(value);
|
||||
const targetStatus = value ? QUICK_FILTER_STATUS[value] : undefined;
|
||||
if (targetStatus) setActiveStatus(targetStatus);
|
||||
};
|
||||
|
||||
const changeStatus = (status: string) => {
|
||||
setActiveStatus(status);
|
||||
setQuickFilter((current) => {
|
||||
if (!current) return current;
|
||||
const targetStatus = QUICK_FILTER_STATUS[current];
|
||||
if (!targetStatus || status === targetStatus) return current;
|
||||
return undefined;
|
||||
});
|
||||
};
|
||||
|
||||
const loadSummary = useCallback(async () => {
|
||||
@@ -255,21 +195,36 @@ export default function WithdrawsPage() {
|
||||
}
|
||||
}, []);
|
||||
|
||||
const loadHealth = useCallback(async () => {
|
||||
const loadHealth = useCallback(async (showFeedback = false) => {
|
||||
setHealthLoading(true);
|
||||
try {
|
||||
const { data } = await api.get<WxpayHealthCheck>('/admin/api/withdraws/health-check');
|
||||
setHealth(data);
|
||||
setHealthCheckedAt(Date.now());
|
||||
if (showFeedback) {
|
||||
message.success(data.ok ? '检测完成，微信提现配置正常' : '检测完成，仍有配置项需要处理');
|
||||
}
|
||||
} catch (e) {
|
||||
message.error(errMsg(e));
|
||||
} finally {
|
||||
setHealthLoading(false);
|
||||
}
|
||||
}, []);
|
||||
|
||||
// 账本校验是全表对账、相对重,故只在进页时拉一次 + 提供手动按钮,不随每次写操作重算。
|
||||
const loadLedger = useCallback(async () => {
|
||||
const loadLedger = useCallback(async (showFeedback = false) => {
|
||||
setLedgerLoading(true);
|
||||
try {
|
||||
const { data } = await api.get<WithdrawLedgerCheck>('/admin/api/withdraws/ledger-check');
|
||||
setLedger(data);
|
||||
setLedgerCheckedAt(Date.now());
|
||||
if (showFeedback) {
|
||||
if (data.ok) {
|
||||
message.success('校验完成，现金账本正常');
|
||||
} else {
|
||||
message.warning('校验完成，发现现金账本异常');
|
||||
}
|
||||
}
|
||||
} catch (e) {
|
||||
message.error(errMsg(e));
|
||||
} finally {
|
||||
@@ -465,15 +420,16 @@ export default function WithdrawsPage() {
|
||||
|
||||
const reconcile = () => {
|
||||
modal.confirm({
|
||||
title: '批量对账?',
|
||||
content: '扫描超过 15 分钟仍处于打款中的提现单，逐单向微信查实并归一化。',
|
||||
okText: '开始对账',
|
||||
title: '处理超时打款订单？',
|
||||
content:
|
||||
'将检查超过 15 分钟仍处于“打款中”的订单：微信已成功则更新为“已到账”；失败则退款；仍待用户确认的老单将撤销并退款；仍在处理中则保持不变。',
|
||||
okText: '开始处理',
|
||||
onOk: async () => {
|
||||
try {
|
||||
const { data } = await api.post<{ checked: number; resolved: number }>(
|
||||
'/admin/api/withdraws/reconcile',
|
||||
);
|
||||
message.success(`对账完成: 检查 ${data.checked} 单，解决 ${data.resolved} 单`);
|
||||
message.success(`处理完成：检查 ${data.checked} 单，更新 ${data.resolved} 单`);
|
||||
await refreshAfterChange();
|
||||
} catch (e) {
|
||||
message.error(errMsg(e));
|
||||
@@ -501,12 +457,6 @@ export default function WithdrawsPage() {
|
||||
width: 120,
|
||||
render: (v: number) => <Text strong>{yuan(v)}</Text>,
|
||||
},
|
||||
{
|
||||
title: '提现类型',
|
||||
dataIndex: 'source',
|
||||
width: 110,
|
||||
render: (v: string) => <Tag color={SOURCE_COLOR[v] || 'default'}>{SOURCE_LABEL[v] || v}</Tag>,
|
||||
},
|
||||
{
|
||||
title: '累计提现',
|
||||
dataIndex: 'cumulative_success_cents',
|
||||
@@ -652,51 +602,78 @@ export default function WithdrawsPage() {
|
||||
: '',
|
||||
].filter(Boolean)
|
||||
: [];
|
||||
const payoutReady = Boolean(
|
||||
health?.wxpay_configured && health.private_key_loadable && health.public_key_loadable,
|
||||
);
|
||||
const hasBlockingPayoutIssue = Boolean(health && !payoutReady);
|
||||
|
||||
return (
|
||||
<div>
|
||||
<Space style={{ width: '100%', justifyContent: 'space-between', marginBottom: 16 }}>
|
||||
<div>
|
||||
<h2 style={{ marginBottom: 4 }}>提现审核</h2>
|
||||
<Text type="secondary">审核通过会立即发起微信打款，拒绝会退回用户现金余额。</Text>
|
||||
<Text type="secondary">
|
||||
针对赚钱页面的账户。审核通过会立即发起微信提现，拒绝会退回用户现金余额。
|
||||
</Text>
|
||||
</div>
|
||||
{canManage && (
|
||||
<Button danger icon={<ReloadOutlined />} onClick={reconcile}>
|
||||
批量对账
|
||||
处理超时订单
|
||||
</Button>
|
||||
)}
|
||||
</Space>
|
||||
|
||||
{(health || ledger) && (
|
||||
{(hasBlockingPayoutIssue || (ledger && !ledger.ok)) && (
|
||||
<Space direction="vertical" style={{ width: '100%', marginBottom: 16 }}>
|
||||
{health && (
|
||||
{health && hasBlockingPayoutIssue && (
|
||||
<Alert
|
||||
showIcon
|
||||
type={health.ok ? 'success' : 'warning'}
|
||||
message={health.ok ? '微信提现配置正常' : '微信提现配置需检查'}
|
||||
type="warning"
|
||||
message="当前环境无法执行微信打款"
|
||||
description={
|
||||
health.ok
|
||||
? `自动对账已${health.auto_reconcile_enabled ? '开启' : '关闭'}，每 ${health.auto_reconcile_interval_sec}s 扫描 ${health.auto_reconcile_older_than_minutes} 分钟前的打款中订单`
|
||||
: health.issues.join('；')
|
||||
}
|
||||
/>
|
||||
)}
|
||||
{ledger && (
|
||||
<Alert
|
||||
showIcon
|
||||
type={ledger.ok ? 'success' : 'error'}
|
||||
message={ledger.ok ? '现金账本校验正常' : '现金账本存在异常'}
|
||||
description={
|
||||
ledger.ok
|
||||
? `现金 余额 ${yuan(ledger.cash_balance_total_cents)} / 流水 ${yuan(ledger.cash_transaction_total_cents)}；邀请金 余额 ${yuan(ledger.invite_cash_balance_total_cents)} / 流水 ${yuan(ledger.invite_cash_transaction_total_cents)}`
|
||||
: ledgerIssues.join('；')
|
||||
<Space direction="vertical" size={6}>
|
||||
<Text>微信支付配置不完整，点击“通过并打款”将失败。请联系部署管理员处理。</Text>
|
||||
{healthCheckedAt && (
|
||||
<Text type="secondary">
|
||||
最近检测：{dayjs(healthCheckedAt).format('HH:mm:ss')}
|
||||
</Text>
|
||||
)}
|
||||
<details>
|
||||
<summary style={{ color: '#1677ff', cursor: 'pointer' }}>查看技术详情</summary>
|
||||
<ul style={{ margin: '8px 0 0', paddingInlineStart: 20 }}>
|
||||
{health.issues.map((issue) => (
|
||||
<li key={issue} style={{ marginBottom: 4, overflowWrap: 'anywhere' }}>
|
||||
{issue}
|
||||
</li>
|
||||
))}
|
||||
</ul>
|
||||
</details>
|
||||
</Space>
|
||||
}
|
||||
action={
|
||||
<Button
|
||||
size="small"
|
||||
icon={<ReloadOutlined />}
|
||||
loading={healthLoading}
|
||||
onClick={() => void loadHealth(true)}
|
||||
>
|
||||
重新检测
|
||||
</Button>
|
||||
}
|
||||
/>
|
||||
)}
|
||||
{ledger && !ledger.ok && (
|
||||
<Alert
|
||||
showIcon
|
||||
type="error"
|
||||
message="现金账本存在异常"
|
||||
description={ledgerIssues.join('；')}
|
||||
action={
|
||||
<Button
|
||||
size="small"
|
||||
icon={<ReloadOutlined />}
|
||||
loading={ledgerLoading}
|
||||
onClick={() => void loadLedger()}
|
||||
onClick={() => void loadLedger(true)}
|
||||
>
|
||||
重新校验
|
||||
</Button>
|
||||
@@ -706,6 +683,36 @@ export default function WithdrawsPage() {
|
||||
</Space>
|
||||
)}
|
||||
|
||||
{(health || ledger) && (
|
||||
<Space
|
||||
size={12}
|
||||
wrap
|
||||
style={{ width: '100%', justifyContent: 'flex-end', marginBottom: 12 }}
|
||||
>
|
||||
{health && payoutReady && <Tag color="success">微信打款可用</Tag>}
|
||||
{ledger?.ok && (
|
||||
<Space size={6}>
|
||||
<CheckCircleOutlined style={{ color: '#52c41a' }} />
|
||||
<Text strong>账本正常</Text>
|
||||
{ledgerCheckedAt && (
|
||||
<Text type="secondary">
|
||||
· {dayjs(ledgerCheckedAt).format('HH:mm:ss')} 校验
|
||||
</Text>
|
||||
)}
|
||||
<Button
|
||||
type="link"
|
||||
size="small"
|
||||
icon={<ReloadOutlined />}
|
||||
loading={ledgerLoading}
|
||||
onClick={() => void loadLedger(true)}
|
||||
>
|
||||
重新校验
|
||||
</Button>
|
||||
</Space>
|
||||
)}
|
||||
</Space>
|
||||
)}
|
||||
|
||||
<Row gutter={12} style={{ marginBottom: 16 }}>
|
||||
<Col xs={24} sm={12}>
|
||||
<Card size="small">
|
||||
@@ -722,7 +729,7 @@ export default function WithdrawsPage() {
|
||||
<Card>
|
||||
<Tabs
|
||||
activeKey={activeStatus}
|
||||
onChange={changeStatus}
|
||||
onChange={setActiveStatus}
|
||||
items={STATUS_TABS.map((tab) => {
|
||||
const count = summaryCount(summary, tab.key);
|
||||
return {
|
||||
@@ -744,89 +751,55 @@ export default function WithdrawsPage() {
|
||||
align="start"
|
||||
style={{
|
||||
width: '100%',
|
||||
justifyContent: 'space-between',
|
||||
marginBottom: 12,
|
||||
paddingBottom: 12,
|
||||
borderBottom: '1px solid #f0f0f0',
|
||||
}}
|
||||
>
|
||||
<Space wrap>
|
||||
<Input.Search
|
||||
allowClear
|
||||
enterButton="搜索"
|
||||
prefix={<SearchOutlined />}
|
||||
placeholder="用户手机号"
|
||||
value={searchDraft}
|
||||
style={{ width: 240 }}
|
||||
onChange={(e) => {
|
||||
const value = e.target.value;
|
||||
setSearchDraft(value);
|
||||
if (!value) setKeyword('');
|
||||
}}
|
||||
onSearch={(value) => setKeyword(value.trim())}
|
||||
/>
|
||||
<Select
|
||||
value={source}
|
||||
allowClear
|
||||
placeholder="提现类型"
|
||||
style={{ width: 140 }}
|
||||
options={SOURCE_OPTIONS}
|
||||
onChange={(value?: string) => setSource(value)}
|
||||
/>
|
||||
<Select
|
||||
value={quickFilter}
|
||||
allowClear
|
||||
placeholder="快捷筛选"
|
||||
style={{ width: 170 }}
|
||||
suffixIcon={<FilterOutlined />}
|
||||
options={QUICK_FILTER_OPTIONS}
|
||||
onChange={applyQuickFilter}
|
||||
/>
|
||||
<Select
|
||||
value={dateField}
|
||||
style={{ width: 120 }}
|
||||
options={DATE_FIELD_OPTIONS}
|
||||
onChange={(value: 'created_at' | 'updated_at') => setDateField(value)}
|
||||
/>
|
||||
<RangePicker
|
||||
value={dateRange}
|
||||
allowClear
|
||||
style={{ width: 260 }}
|
||||
presets={[
|
||||
{ label: '今天', value: [dayjs().startOf('day'), dayjs().endOf('day')] },
|
||||
{
|
||||
label: '最近7天',
|
||||
value: [dayjs().subtract(6, 'day').startOf('day'), dayjs().endOf('day')],
|
||||
},
|
||||
{
|
||||
label: '最近30天',
|
||||
value: [dayjs().subtract(29, 'day').startOf('day'), dayjs().endOf('day')],
|
||||
},
|
||||
]}
|
||||
onChange={(values) => setDateRange(values as [Dayjs, Dayjs] | null)}
|
||||
/>
|
||||
</Space>
|
||||
<Space wrap>
|
||||
<Select
|
||||
value={sortBy}
|
||||
style={{ width: 130 }}
|
||||
suffixIcon={<SortAscendingOutlined />}
|
||||
options={SORT_OPTIONS}
|
||||
onChange={(value: 'created_at' | 'amount_cents') => setSortBy(value)}
|
||||
/>
|
||||
<Select
|
||||
value={sortOrder}
|
||||
style={{ width: 96 }}
|
||||
options={[
|
||||
{ value: 'desc', label: '倒序' },
|
||||
{ value: 'asc', label: '正序' },
|
||||
]}
|
||||
onChange={(value: 'asc' | 'desc') => setSortOrder(value)}
|
||||
/>
|
||||
<Button icon={<ClearOutlined />} onClick={resetFilters}>
|
||||
重置
|
||||
</Button>
|
||||
</Space>
|
||||
<Input.Search
|
||||
allowClear
|
||||
enterButton="搜索"
|
||||
prefix={<SearchOutlined />}
|
||||
placeholder="用户手机号"
|
||||
value={searchDraft}
|
||||
style={{ width: 240 }}
|
||||
onChange={(e) => {
|
||||
const value = e.target.value;
|
||||
setSearchDraft(value);
|
||||
if (!value) setKeyword('');
|
||||
}}
|
||||
onSearch={(value) => setKeyword(value.trim())}
|
||||
/>
|
||||
<RangePicker
|
||||
value={dateRange}
|
||||
allowClear
|
||||
style={{ width: 260 }}
|
||||
presets={[
|
||||
{ label: '今天', value: [dayjs().startOf('day'), dayjs().endOf('day')] },
|
||||
{
|
||||
label: '最近7天',
|
||||
value: [dayjs().subtract(6, 'day').startOf('day'), dayjs().endOf('day')],
|
||||
},
|
||||
{
|
||||
label: '最近30天',
|
||||
value: [dayjs().subtract(29, 'day').startOf('day'), dayjs().endOf('day')],
|
||||
},
|
||||
]}
|
||||
onChange={(values) => setDateRange(values as [Dayjs, Dayjs] | null)}
|
||||
/>
|
||||
<Select
|
||||
value={sortOrder}
|
||||
style={{ width: 96 }}
|
||||
suffixIcon={<SortAscendingOutlined />}
|
||||
options={[
|
||||
{ value: 'desc', label: '倒序' },
|
||||
{ value: 'asc', label: '正序' },
|
||||
]}
|
||||
onChange={(value: 'asc' | 'desc') => setSortOrder(value)}
|
||||
/>
|
||||
<Button icon={<ClearOutlined />} onClick={resetFilters}>
|
||||
重置
|
||||
</Button>
|
||||
</Space>
|
||||
{canManage && selectedOrders.length > 0 && (
|
||||
<Space
|
||||
@@ -898,7 +871,7 @@ export default function WithdrawsPage() {
|
||||
showTotal: (t) => `共 ${t} 条`,
|
||||
onChange: onPageChange,
|
||||
}}
|
||||
scroll={{ x: 1460 }}
|
||||
scroll={{ x: 1350 }}
|
||||
onRow={(record) => ({
|
||||
onClick: () => openDetail(record),
|
||||
style: { cursor: 'pointer' },
|
||||
@@ -930,11 +903,6 @@ export default function WithdrawsPage() {
|
||||
<Descriptions.Item label="金额">
|
||||
<Text strong>{yuan(detail.order.amount_cents)}</Text>
|
||||
</Descriptions.Item>
|
||||
<Descriptions.Item label="提现类型">
|
||||
<Tag color={SOURCE_COLOR[detail.order.source] || 'default'}>
|
||||
{SOURCE_LABEL[detail.order.source] || detail.order.source}
|
||||
</Tag>
|
||||
</Descriptions.Item>
|
||||
<Descriptions.Item label="提现实名">
|
||||
{detail.order.user_name || '-'}
|
||||
</Descriptions.Item>
|
||||
|
||||
@@ -0,0 +1,33 @@
|
||||
export interface BulkReviewItemResult {
|
||||
id: number;
|
||||
ok: boolean;
|
||||
status: string | null;
|
||||
error: string | null;
|
||||
}
|
||||
|
||||
export interface BulkReviewResult {
|
||||
total: number;
|
||||
success: number;
|
||||
failed: number;
|
||||
items: BulkReviewItemResult[];
|
||||
}
|
||||
|
||||
export const BULK_REVIEW_MAX = 50;
|
||||
|
||||
export function failedReviewIds(result: BulkReviewResult): number[] {
|
||||
return result.items.filter((item) => !item.ok).map((item) => item.id);
|
||||
}
|
||||
|
||||
export function bulkFailureReasonText(result: BulkReviewResult): string {
|
||||
const reasons = Array.from(
|
||||
new Set(
|
||||
result.items
|
||||
.filter((item) => !item.ok)
|
||||
.map((item) => item.error?.trim())
|
||||
.filter((reason): reason is string => Boolean(reason)),
|
||||
),
|
||||
);
|
||||
if (!reasons.length) return '';
|
||||
const visible = reasons.slice(0, 3);
|
||||
return `；原因：${visible.join('；')}${reasons.length > visible.length ? '；…' : ''}`;
|
||||
}
|
||||
+99
-1
@@ -218,6 +218,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;
|
||||
@@ -317,6 +403,18 @@ export interface FeedbackQrConfig {
|
||||
updated_at: string | null;
|
||||
}
|
||||
|
||||
/** 领券等候浮层的「新手引导视频」配置(前 3 次用它替代广告,每次固定 120 金币)。
|
||||
* 后台只开放 enabled + 换片;下面几个字段接口仍返回,但页面不展示、也不回传。 */
|
||||
export interface GuideVideoConfig {
|
||||
enabled: boolean;
|
||||
video_url: string | null; // /media/guide_video/xxx.mp4;null = 未配片(浮层照旧只放广告)
|
||||
max_plays: number; // 每个账号前 N 次浮层放引导视频(服务端默认 3,后台不开放调整)
|
||||
reward_coin: number; // 每次固定金币(服务端默认 120,播完 / 中途关闭都发)
|
||||
updated_at: string | null;
|
||||
total_plays: number; // 只读统计:全站已播次数(后台不再展示)
|
||||
granted_plays: number; // 只读统计:其中已发币次数(后台不再展示)
|
||||
}
|
||||
|
||||
export interface AuditLog {
|
||||
id: number;
|
||||
admin_id: number;
|
||||
@@ -488,7 +586,7 @@ export interface AdRevenueRow {
|
||||
has_impression: boolean; // 是否有广告展示(信息流逐条展示=true,纯发奖行=false)
|
||||
impressions: number; // 本行展示条数 1/0(供日汇总、趋势图复用)
|
||||
ecpm: string | null; // 分/千次;展示行取展示值,纯发奖行取发奖采用值
|
||||
revenue_yuan: number; // 本次展示预估收益(元);纯发奖行=0
|
||||
revenue_yuan: number; // 本次有效展示预估收益(元);纯发奖、激励视频提前关闭/时长不足=0
|
||||
row_revenue_yuan?: number | null; // 主表逐行显示用:一次比价/领券聚合行=该次发奖广告 eCPM 折算之和;其它行空(回退 revenue_yuan)
|
||||
adn: string | null; // 实际填充 ADN;纯发奖行为空
|
||||
slot_id: string | null; // 底层 mediation rit;纯发奖行为空
|
||||
|
||||
Reference in New Issue
Block a user