fix(mileage): 交投高里程车辆标红

src/server/routes/mileage/cache.ts

@@ -65,6 +65,41 @@ interface MileageRow {
   source: string;
 }
 
+interface TargetRow {
+  id: number;
+  target_name: string;
+  plate_number: string;
+}
+
+async function fetchTargetRows(): Promise<TargetRow[]> {
+  return pool.execute(
+    `SELECT t.id, t.target_name, v.plate_number
+     FROM tab_mileage_assessment_target t
+     JOIN tab_mileage_assessment_vehicle v ON v.target_id = t.id AND v.is_deleted = 0
+     WHERE t.is_deleted = 0`
+  ).then(([rows]) => rows as TargetRow[]);
+}
+
+function buildTargetPlatesMap(targetRows: TargetRow[]): Map<string, Set<string>> {
+  const targetPlatesMap = new Map<string, Set<string>>();
+  for (const r of targetRows) {
+    const set = targetPlatesMap.get(r.target_name) || new Set();
+    set.add(r.plate_number);
+    targetPlatesMap.set(r.target_name, set);
+  }
+  return targetPlatesMap;
+}
+
+function buildPlateTargetNamesMap(targetRows: TargetRow[]): Map<string, string[]> {
+  const map = new Map<string, string[]>();
+  for (const r of targetRows) {
+    const list = map.get(r.plate_number) || [];
+    list.push(r.target_name);
+    map.set(r.plate_number, list);
+  }
+  return map;
+}
+
 async function fetchBizTotalMileageMap(): Promise<Map<string, number>> {
   // v_vehicle_daily_stats.total_km 对 G7S 数据源常为 NULL（G7 只回传日增量），
   // 业务库 tab_mileage_assessment_vehicle.vehicle_total_mileage 是累加后的权威累计值，
@@ -115,6 +150,7 @@ function mergeVehicles(
   yesterdayMap: Map<string, number>,
   bizTotalMap: Map<string, number>,
   latestPgTotalMap: Map<string, number>,
+  targetNamesByPlate: Map<string, string[]>,
 ): CachedVehicle[] {
   const mileageMap = new Map<string, MileageRow>();
   for (const row of mileageRows) {
@@ -147,6 +183,7 @@ function mergeVehicles(
       entity: info?.entity || null,
       project: info?.project || null,
       region: regionMap[m.plate] || null,
+      targetNames: targetNamesByPlate.get(m.plate) || [],
       yesterdayKm: yesterdayMap.get(m.plate) || 0,
     };
   });
@@ -184,25 +221,16 @@ export async function refreshMonitoringCache(): Promise<void> {
         return map;
       })(),
       fetchVehicleInfoMap(),
-      pool.execute(
-        `SELECT t.id, t.target_name, v.plate_number
-         FROM tab_mileage_assessment_target t
-         JOIN tab_mileage_assessment_vehicle v ON v.target_id = t.id AND v.is_deleted = 0
-         WHERE t.is_deleted = 0`
-      ).then(([rows]) => rows as { id: number; target_name: string; plate_number: string }[]),
+      fetchTargetRows(),
       fetchBizTotalMileageMap(),
       fetchLatestPgTotalMileageMap(),
     ]);
 
-    const targetPlatesMap = new Map<string, Set<string>>();
-    for (const r of targetRows) {
-      const set = targetPlatesMap.get(r.target_name) || new Set();
-      set.add(r.plate_number);
-      targetPlatesMap.set(r.target_name, set);
-    }
+    const targetPlatesMap = buildTargetPlatesMap(targetRows);
+    const targetNamesByPlate = buildPlateTargetNamesMap(targetRows);
     const targetNames = Array.from(targetPlatesMap.keys());
 
-    const vehicles = mergeVehicles(mileageRows, infoMap, yesterdayMap, bizTotalMap, latestPgTotalMap);
+    const vehicles = mergeVehicles(mileageRows, infoMap, yesterdayMap, bizTotalMap, latestPgTotalMap, targetNamesByPlate);
     const totalToday = vehicles.reduce((sum, v) => sum + v.dailyKm, 0);
     const totalAll = vehicles.reduce((sum, v) => sum + (v.totalKm || 0), 0);
 
@@ -221,7 +249,7 @@ export async function refreshMonitoringCache(): Promise<void> {
 }
 
 export async function queryDateMileage(dateStr: string): Promise<CachedVehicle[]> {
-  const [mileageRows, yesterdayRows, infoMap, bizTotalMap, latestPgTotalMap] = await Promise.all([
+  const [mileageRows, yesterdayRows, infoMap, targetRows, bizTotalMap, latestPgTotalMap] = await Promise.all([
     mileagePool.execute(
       'SELECT plate, vin, daily_km, total_km, source FROM v_vehicle_daily_stats WHERE stat_date = ?',
       [dateStr]
@@ -231,6 +259,7 @@ export async function queryDateMileage(dateStr: string): Promise<CachedVehicle[]
       [dateStr]
     ).then(([r]) => r as { plate: string; daily_km: string }[]),
     fetchVehicleInfoMap(),
+    fetchTargetRows(),
     fetchBizTotalMileageMap(),
     fetchLatestPgTotalMileageMap(dateStr),
   ]);
@@ -242,7 +271,14 @@ export async function queryDateMileage(dateStr: string): Promise<CachedVehicle[]
     if (km > existing) yesterdayMap.set(r.plate, km);
   }
 
-  return mergeVehicles(mileageRows, infoMap, yesterdayMap, bizTotalMap, latestPgTotalMap);
+  return mergeVehicles(
+    mileageRows,
+    infoMap,
+    yesterdayMap,
+    bizTotalMap,
+    latestPgTotalMap,
+    buildPlateTargetNamesMap(targetRows),
+  );
 }
 
 export function buildDateFilters(vehicles: CachedVehicle[]): MonitoringFilters {

src/server/routes/mileage/types.ts

@@ -15,6 +15,7 @@ export interface CachedVehicle {
   entity: string | null;
   project: string | null;
   region: string | null;
+  targetNames: string[];
   yesterdayKm: number;
 }