shishengliang/lingniu-vehicle-ingest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(platform): copy alert priority digest

Browse Source
This commit is contained in:
lingniu
2026-07-04 13:15:57 +08:00
parent 47dfd18462
commit bcc9355400
2 changed files with 135 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
vehicle-data-platform/apps/web/src/pages/Quality.tsx
View File

@@ -266,6 +266,26 @@ function priorityIssueNotificationText(row: PriorityIssueRow) {
].join('\n');
}
function priorityIssueDigestText(rows: PriorityIssueRow[], summary: QualitySummary) {
const p0Count = rows.filter((row) => row.priority === 'P0').length;
const p1Count = rows.filter((row) => row.priority === 'P1').length;
const lines = rows.map((row, index) => [
`${index + 1}. [${row.priority}] ${row.vehicleLabel}`,
` 来源：${qualityProtocolLabel(row.protocol)} / 问题：${qualityIssueLabel(row.issueType)}`,
` 建议动作：${row.actionLabel} / SLA：${row.sla}`,
` 最后时间：${row.lastSeen || '-'} / 详情：${row.detail || '-'}`
].join('\n'));
return [
'【告警优先队列汇总】',
`问题车辆：${summary.issueVehicleCount.toLocaleString()}，问题记录：${summary.issueRecordCount.toLocaleString()}`,
`P0：${p0Count.toLocaleString()} 条，P1：${p1Count.toLocaleString()} 条`,
'',
...lines,
'',
`告警筛选：${qualityShareURL()}`
].join('\n');
}
function ruleStatusColor(count: number, level: string): 'green' | 'orange' | 'red' | 'grey' {
if (count <= 0) return 'green';
if (level === 'P0') return 'red';
@@ -429,6 +449,13 @@ export function Quality({
...(dateTo ? { dateTo } : {})
});
};
const copyPriorityDigest = () => {
if (priorityRows.length === 0) {
Toast.warning('当前没有可复制的优先告警');
return;
}
copyText(priorityIssueDigestText(priorityRows, summary), '优先队列通知汇总');
};
return (
<div className="vp-page">
@@ -491,7 +518,16 @@ export function Quality({
))}
</div>
</Card>
<Card bordered title="处置优先队列" style={{ marginTop: 16 }}>
<Card
bordered
title={(
<Space>
<span>处置优先队列</span>
<Button size="small" disabled={priorityRows.length === 0} onClick={copyPriorityDigest}>复制优先队列通知汇总</Button>
</Space>
)}
style={{ marginTop: 16 }}
>
<Table<PriorityIssueRow>
loading={loadingIssues}
pagination={false}

98
vehicle-data-platform/apps/web/src/test/App.test.tsx
View File

@@ -2536,6 +2536,104 @@ test('copies notification text from quality priority queue', async () => {
expect(writeText).toHaveBeenCalledWith(expect.stringContaining('告警筛选：http://localhost:3000/#/quality'));
});
test('copies priority queue notification digest on quality page', async () => {
window.history.replaceState(null, '', '/#/quality');
const writeText = vi.fn(() => Promise.resolve());
Object.defineProperty(navigator, 'clipboard', {
configurable: true,
value: { writeText }
});
vi.spyOn(globalThis, 'fetch').mockImplementation(async (input) => {
const path = String(input);
if (path.includes('/api/ops/health')) {
return {
ok: true,
json: async () => ({
data: { linkHealth: [], kafkaLag: 0, activeConnections: 120000, capacityFindings: [], redisOnlineKeys: 368, tdengineWritable: true, mysqlWritable: true, runtime: { requestTimeoutMs: 5000 } },
traceId: 'trace-test',
timestamp: 1783094400000
})
} as Response;
}
if (path.includes('/api/quality/summary')) {
return {
ok: true,
json: async () => ({
data: {
issueVehicleCount: 2,
issueRecordCount: 2,
errorCount: 1,
warningCount: 1,
protocols: [{ name: 'VEHICLE_SERVICE', count: 1 }, { name: 'JT808', count: 1 }],
issueTypes: [{ name: 'NO_SOURCE', count: 1 }, { name: 'VIN_MISSING', count: 1 }]
},
traceId: 'trace-test',
timestamp: 1783094400000
})
} as Response;
}
if (path.includes('/api/quality/issues')) {
return {
ok: true,
json: async () => ({
data: {
items: [
{
vin: 'VIN-DIGEST-001',
plate: '粤A汇总1',
phone: '13307795425',
sourceEndpoint: '115.231.168.135:43625',
protocol: 'VEHICLE_SERVICE',
issueType: 'NO_SOURCE',
severity: 'error',
lastSeen: '2026-07-03 20:12:10',
detail: '车辆无任何来源'
},
{
vin: '',
plate: '粤A汇总2',
phone: '13307795426',
sourceEndpoint: '115.231.168.135:43626',
protocol: 'JT808',
issueType: 'VIN_MISSING',
severity: 'warning',
lastSeen: '2026-07-03 20:10:10',
detail: '手机号未映射 VIN'
}
],
total: 2,
limit: 20,
offset: 0
},
traceId: 'trace-test',
timestamp: 1783094400000
})
} as Response;
}
return {
ok: true,
json: async () => ({
data: { items: [], total: 0, limit: 20, offset: 0 },
traceId: 'trace-test',
timestamp: 1783094400000
})
} as Response;
});
render(<App />);
expect(await screen.findByText('处置优先队列')).toBeInTheDocument();
fireEvent.click(screen.getByRole('button', { name: '复制优先队列通知汇总' }));
expect(writeText).toHaveBeenCalledWith(expect.stringContaining('【告警优先队列汇总】'));
expect(writeText).toHaveBeenCalledWith(expect.stringContaining('P0：1 条，P1：1 条'));
expect(writeText).toHaveBeenCalledWith(expect.stringContaining('1. [P0] 粤A汇总1 / VIN-DIGEST-001'));
expect(writeText).toHaveBeenCalledWith(expect.stringContaining('确认平台转发'));
expect(writeText).toHaveBeenCalledWith(expect.stringContaining('2. [P1] 粤A汇总2 / 13307795426'));
expect(writeText).toHaveBeenCalledWith(expect.stringContaining('维护身份绑定'));
expect(writeText).toHaveBeenCalledWith(expect.stringContaining('告警筛选：http://localhost:3000/#/quality'));
});
test('opens realtime map context from quality priority queue', async () => {
window.history.replaceState(null, '', '/#/quality');
vi.spyOn(globalThis, 'fetch').mockImplementation(async (input) => {