feat(platform): surface dashboard action queue

vehicle-data-platform/apps/web/src/pages/Dashboard.tsx

@@ -1,6 +1,6 @@
 import { Button, Card, Col, Form, Row, Select, Space, Spin, Table, Tag, Toast, Typography } from '@douyinfe/semi-ui';
 import { IconSearch } from '@douyinfe/semi-icons';
-import { useEffect, useState } from 'react';
+import { useEffect, useMemo, useState } from 'react';
 import { api } from '../api/client';
 import type { DashboardSummary, LinkHealth, ProtocolStat, QualityIssueRow, ServiceStatusStat, VehicleCoverageRow, VehicleRealtimeRow, VehicleServiceSummary } from '../api/types';
 import { PageHeader } from '../components/PageHeader';
@@ -163,6 +163,35 @@ export function Dashboard({ onOpenVehicle, onOpenQuality, onOpenVehicles }: { on
     { label: '身份未绑定', value: formatCount(serviceSummary?.identityRequiredVehicles), filters: { serviceStatus: 'identity_required' } }
   ];
   const missingSourceCounts = new Map((serviceSummary?.missingSources ?? []).map((item) => [item.protocol, item.count]));
+  const serviceActionQueue = useMemo<Array<{ label: string; count: number; filters: Record<string, string>; detail: string }>>(() => {
+    const items: Array<{ label: string; count: number; filters: Record<string, string>; detail: string }> = [];
+    if ((serviceSummary?.noDataVehicles ?? 0) > 0) {
+      items.push({
+        label: '确认平台转发',
+        count: serviceSummary?.noDataVehicles ?? 0,
+        filters: { serviceStatus: 'no_data' },
+        detail: '车辆没有形成任何来源证据，优先确认上游平台是否持续转发。'
+      });
+    }
+    if ((serviceSummary?.identityRequiredVehicles ?? 0) > 0) {
+      items.push({
+        label: '维护身份绑定',
+        count: serviceSummary?.identityRequiredVehicles ?? 0,
+        filters: { serviceStatus: 'identity_required' },
+        detail: '已有数据但无法稳定归并到 VIN，会影响车辆服务聚合。'
+      });
+    }
+    for (const source of serviceSummary?.missingSources ?? []) {
+      if (source.count <= 0) continue;
+      items.push({
+        label: `补齐 ${source.protocol} 来源`,
+        count: source.count,
+        filters: { serviceStatus: 'degraded', missingProtocol: source.protocol },
+        detail: `${source.protocol} 来源缺失会降低跨来源定位、里程和实时判断可信度。`
+      });
+    }
+    return items;
+  }, [serviceSummary]);
 
   return (
     <div className="vp-page">
@@ -191,6 +220,23 @@ export function Dashboard({ onOpenVehicle, onOpenQuality, onOpenVehicles }: { on
             <Tag color={(summary?.kafkaLag ?? 0) > 0 ? 'orange' : 'green'}>Kafka Lag {formatLag(summary?.kafkaLag)}</Tag>
           </Space>
         </Card>
+        {serviceActionQueue.length > 0 ? (
+          <Card bordered title="车辆服务处置队列" style={{ marginBottom: 16 }}>
+            <div className="vp-action-grid">
+              {serviceActionQueue.map((item) => (
+                <div key={`${item.label}-${item.count}`} className="vp-action-item">
+                  <div>
+                    <Tag color="orange">{item.label} {item.count.toLocaleString()}</Tag>
+                    <Typography.Text type="secondary" style={{ display: 'block', marginTop: 8 }}>{item.detail}</Typography.Text>
+                  </div>
+                  <Button size="small" theme="light" type="warning" onClick={() => onOpenVehicles(item.filters)}>
+                    {item.label} {item.count.toLocaleString()}
+                  </Button>
+                </div>
+              ))}
+            </div>
+          </Card>
+        ) : null}
         <Row gutter={16}>
           <Col span={8}>
             <Card title="车辆服务状态" bordered>

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

@@ -207,6 +207,83 @@ test('dashboard presents one vehicle service operating posture', async () => {
   expect(screen.getByText('7 质量关注')).toBeInTheDocument();
 });
 
+test('dashboard shows vehicle service action queue', async () => {
+  window.history.replaceState(null, '', '/#/dashboard');
+  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: 0, capacityFindings: [], redisOnlineKeys: 0, tdengineWritable: true, mysqlWritable: true, runtime: { requestTimeoutMs: 5000 } },
+          traceId: 'trace-test',
+          timestamp: 1783094400000
+        })
+      } as Response;
+    }
+    if (path.includes('/api/dashboard/summary')) {
+      return {
+        ok: true,
+        json: async () => ({
+          data: {
+            onlineVehicles: 3,
+            activeToday: 4,
+            frameToday: 1286320,
+            issueVehicles: 7,
+            kafkaLag: 0,
+            protocols: [],
+            serviceStatuses: [],
+            linkHealth: []
+          },
+          traceId: 'trace-test',
+          timestamp: 1783094400000
+        })
+      } as Response;
+    }
+    if (path.includes('/api/vehicle-service/summary')) {
+      return {
+        ok: true,
+        json: async () => ({
+          data: {
+            totalVehicles: 1033,
+            boundVehicles: 1024,
+            onlineVehicles: 208,
+            singleSourceVehicles: 391,
+            multiSourceVehicles: 181,
+            noDataVehicles: 461,
+            identityRequiredVehicles: 9,
+            serviceStatuses: [],
+            protocols: [],
+            missingSources: [{ protocol: 'YUTONG_MQTT', count: 983 }]
+          },
+          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();
+  expect(screen.getByRole('button', { name: '确认平台转发 461' })).toBeInTheDocument();
+  expect(screen.getByRole('button', { name: '维护身份绑定 9' })).toBeInTheDocument();
+  expect(screen.getByRole('button', { name: '补齐 YUTONG_MQTT 来源 983' })).toBeInTheDocument();
+
+  fireEvent.click(screen.getByRole('button', { name: '确认平台转发 461' }));
+  await waitFor(() => {
+    expect(window.location.hash).toBe('#/vehicles?serviceStatus=no_data');
+  });
+});
+
 test.each([
   { buttonName: '查看在线车辆', expectedHash: '#/vehicles?online=online' },
   { buttonName: '查看多源车辆', expectedHash: '#/vehicles?coverage=multi' },