feat(scheduling): add algorithm pure functions and export mapRegion

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

src/server/routes/scheduling/algorithm.ts

@@ -0,0 +1,185 @@
+import type {
+  EnrichedVehicle, InventoryVehicle, SchedulingSuggestion,
+  CandidateVehicle, VehicleClassification, SchedulingSummary,
+} from './types.js';
+
+// ---------------------------------------------------------------------------
+// 1. Vehicle type compatibility
+// ---------------------------------------------------------------------------
+
+export function isTypeCompatible(sourceType: string, candidateType: string): boolean {
+  if (sourceType === candidateType) return true;
+  // Cold-chain 4.5T can replace plain-cargo 4.5T
+  if (candidateType === '4.5T冷链' && (sourceType === '4.5T冷链' || sourceType === '4.5T普货')) return true;
+  return false;
+}
+
+// ---------------------------------------------------------------------------
+// 2. Vehicle classification
+// ---------------------------------------------------------------------------
+
+export function classifyVehicle(
+  currentYearIsQualified: boolean,
+  predictedYearEnd: number,
+  yearTarget: number,
+): VehicleClassification {
+  if (currentYearIsQualified || predictedYearEnd / yearTarget >= 1.2) return 'qualified';
+  if (predictedYearEnd / yearTarget < 0.6) return 'hopeless';
+  return 'normal';
+}
+
+// ---------------------------------------------------------------------------
+// 3. Helper – convert EnrichedVehicle to SchedulingVehicleInfo shape
+// ---------------------------------------------------------------------------
+
+import type { SchedulingVehicleInfo } from './types.js';
+
+export function toVehicleInfo(v: EnrichedVehicle): SchedulingVehicleInfo {
+  return {
+    plateNumber: v.plateNumber,
+    targetId: v.targetId,
+    targetName: v.targetName,
+    vehicleType: v.vehicleType,
+    totalMileage: v.totalMileage,
+    completionRate: v.completionRate,
+    yearTarget: v.yearTarget,
+    region: v.region,
+    province: v.province,
+    customer: v.customer,
+    customerAvgDaily: v.customerAvgDaily,
+    predictedYearEnd: v.predictedYearEnd,
+    daysLeft: v.daysLeft,
+  };
+}
+
+// ---------------------------------------------------------------------------
+// 4. Main algorithm – generate scheduling suggestions
+// ---------------------------------------------------------------------------
+
+export function generateSuggestions(
+  vehicles: EnrichedVehicle[],
+  inventoryVehicles: InventoryVehicle[],
+): { suggestions: SchedulingSuggestion[]; summary: SchedulingSummary } {
+  const qualified = vehicles.filter((v) => v.classification === 'qualified');
+  const hopeless = vehicles.filter((v) => v.classification === 'hopeless');
+
+  const suggestions: SchedulingSuggestion[] = [];
+
+  // --- rescue_hopeless (high priority) ---
+  for (const vehicle of hopeless) {
+    const candidates: CandidateVehicle[] = inventoryVehicles
+      .filter(
+        (inv) =>
+          isTypeCompatible(vehicle.vehicleType, inv.vehicleType) &&
+          inv.region === vehicle.region &&
+          inv.completionRate >= 0.8,
+      )
+      .map((inv) => {
+        const mileageGap = (inv.yearTarget ?? 0) - inv.totalMileage;
+        const predictedAfterSwap =
+          inv.totalMileage + vehicle.customerAvgDaily * vehicle.daysLeft;
+        const canQualifyAfterSwap =
+          inv.yearTarget != null && predictedAfterSwap >= inv.yearTarget;
+        return {
+          plateNumber: inv.plateNumber,
+          targetId: inv.targetId,
+          targetName: inv.targetName,
+          vehicleType: inv.vehicleType,
+          totalMileage: inv.totalMileage,
+          completionRate: inv.completionRate,
+          yearTarget: inv.yearTarget,
+          region: inv.region,
+          province: inv.province,
+          mileageGap,
+          predictedAfterSwap,
+          canQualifyAfterSwap,
+        };
+      })
+      .sort((a, b) => {
+        if (a.canQualifyAfterSwap !== b.canQualifyAfterSwap)
+          return a.canQualifyAfterSwap ? -1 : 1;
+        return b.completionRate - a.completionRate;
+      })
+      .slice(0, 5);
+
+    const reason = `${vehicle.customer}日均里程仅 ${Math.round(vehicle.customerAvgDaily)} KM，该车达标概率 ${Math.round((vehicle.predictedYearEnd / vehicle.yearTarget) * 100)}%，建议替换为已达标车辆，将此车调配给高里程客户。`;
+
+    suggestions.push({
+      id: `hopeless-${vehicle.plateNumber}`,
+      priority: 'high',
+      type: 'rescue_hopeless',
+      currentVehicle: toVehicleInfo(vehicle),
+      candidates,
+      reason,
+    });
+  }
+
+  // --- replace_qualified (medium priority) ---
+  for (const vehicle of qualified) {
+    if (vehicle.customerAvgDaily <= vehicle.dailyRequiredMileage) continue;
+
+    const candidates: CandidateVehicle[] = inventoryVehicles
+      .filter(
+        (inv) =>
+          isTypeCompatible(vehicle.vehicleType, inv.vehicleType) &&
+          inv.region === vehicle.region,
+      )
+      .map((inv) => {
+        const mileageGap = (inv.yearTarget ?? 0) - inv.totalMileage;
+        const predictedAfterSwap =
+          inv.totalMileage + vehicle.customerAvgDaily * vehicle.daysLeft;
+        const canQualifyAfterSwap =
+          inv.yearTarget != null && predictedAfterSwap >= inv.yearTarget;
+        return {
+          plateNumber: inv.plateNumber,
+          targetId: inv.targetId,
+          targetName: inv.targetName,
+          vehicleType: inv.vehicleType,
+          totalMileage: inv.totalMileage,
+          completionRate: inv.completionRate,
+          yearTarget: inv.yearTarget,
+          region: inv.region,
+          province: inv.province,
+          mileageGap,
+          predictedAfterSwap,
+          canQualifyAfterSwap,
+        };
+      })
+      .sort((a, b) => {
+        if (a.canQualifyAfterSwap !== b.canQualifyAfterSwap)
+          return a.canQualifyAfterSwap ? -1 : 1;
+        return b.mileageGap - a.mileageGap;
+      })
+      .slice(0, 5);
+
+    const reason = `${vehicle.customer}日均里程 ${Math.round(vehicle.customerAvgDaily)} KM（高里程），该车已达标（完成率 ${Math.round(vehicle.completionRate * 100)}%），建议换上里程缺口大的车辆以加速达标。`;
+
+    suggestions.push({
+      id: `qualified-${vehicle.plateNumber}`,
+      priority: 'medium',
+      type: 'replace_qualified',
+      currentVehicle: toVehicleInfo(vehicle),
+      candidates,
+      reason,
+    });
+  }
+
+  // Sort: high priority first
+  suggestions.sort((a, b) => {
+    if (a.priority === b.priority) return 0;
+    return a.priority === 'high' ? -1 : 1;
+  });
+
+  const estimatedGain = suggestions.filter((s) =>
+    s.candidates.some((c) => c.canQualifyAfterSwap),
+  ).length;
+
+  const summary: SchedulingSummary = {
+    qualifiedCount: qualified.length,
+    hopelessCount: hopeless.length,
+    suggestionCount: suggestions.length,
+    estimatedGain,
+  };
+
+  return { suggestions, summary };
+}

src/server/routes/vehicles.ts

@@ -91,7 +91,7 @@ WHERE truck.is_deleted = 0
 const REGIONS = ['嘉兴', '广东', '北京', '新疆', '其他'] as const;
 const INVENTORY_REGIONS = ['江浙沪', '广东', '新疆', '其它'] as const;
 
-function mapRegion(province: string | null, city: string | null): string {
+export function mapRegion(province: string | null, city: string | null): string {
   if (!province && !city) return '其他';
   const loc = (city || province || '').trim();
   if (loc.includes('嘉兴') || loc.includes('浙江') || loc.includes('上海') || loc.includes('江苏')) return '嘉兴';