ln-bi/src/server/routes/mileage.ts

import { Hono } from 'hono';
import pool from '../db.js';
import mileagePool from '../mileage-db.js';

const app = new Hono();

// 车辆关联信息 SQL（客户名、部门、经理）
const VEHICLE_INFO_SQL = `SELECT
    truck.plate_number AS plate,
    cus.customer_name AS customer,
    dep.dep_name AS department,
    u.user_name AS manager,
    dic_status.dic_name AS rent_status,
    org_truck.org_name AS entity,
    c.project_name AS project
FROM tab_truck truck
LEFT JOIN tab_truck_status_info si ON si.truck_id = truck.id AND si.is_deleted = 0
LEFT JOIN tab_contract c ON c.id = si.contract_id AND c.is_deleted = 0
LEFT JOIN tab_customer cus ON cus.id = c.customer_id AND cus.is_deleted = 0
LEFT JOIN tab_user u ON u.id = c.bd AND u.is_deleted = 0
LEFT JOIN tab_department dep ON dep.id = u.dep_id AND dep.is_deleted = 0
LEFT JOIN tab_dic dic_status ON dic_status.parent_code = 'dic_truck_rent_status'
      AND dic_status.dic_code = truck.truck_rent_status AND dic_status.is_deleted = 0
LEFT JOIN tab_org org_truck ON org_truck.id = truck.org_id AND org_truck.is_deleted = 0
WHERE truck.is_deleted = 0 AND truck.is_operation = 1`;

// ========== 实时监控缓存（每2分钟刷新） ==========
interface CachedVehicle {
  plate: string;
  vin: string;
  dailyKm: number;
  totalKm: number | null;
  source: string;
  isOnline: boolean;
  isDataSynced: boolean;
  customer: string | null;
  department: string | null;
  manager: string | null;
  rentStatus: string | null;
  entity: string | null;
  project: string | null;
}

interface MonitoringCache {
  vehicles: CachedVehicle[];
  stats: { totalToday: number; totalAll: number; onlineCount: number; vehicleCount: number };
  filters: { departments: string[]; customers: string[]; plates: string[]; projects: string[]; entities: string[] };
  updatedAt: string;
}

let monitoringCache: MonitoringCache | null = null;

async function refreshMonitoringCache() {
  try {
    console.log('[mileage] refreshing monitoring cache...');
    const start = Date.now();

    // 并行查询两个数据库
    const [mileageResult, infoRows] = await Promise.all([
      (async () => {
        const [dateRows] = await mileagePool.execute(
          'SELECT MAX(stat_date) as latest FROM v_vehicle_daily_stats'
        ) as any;
        const latestDate = dateRows[0]?.latest;
        if (!latestDate) return [];
        const [rows] = await mileagePool.execute(
          `SELECT plate, vin, daily_km, total_km, source
           FROM v_vehicle_daily_stats WHERE stat_date = ?`,
          [latestDate]
        ) as any;
        return rows;
      })(),
      pool.execute(VEHICLE_INFO_SQL).then(([rows]) => rows as any[]),
    ]);

    // 车辆关联信息 map
    const infoMap = new Map<string, any>();
    for (const row of infoRows) {
      infoMap.set(row.plate, row);
    }

    // 去重：同一 plate 取 daily_km 最大的
    const mileageMap = new Map<string, any>();
    for (const row of mileageResult) {
      const existing = mileageMap.get(row.plate);
      if (!existing || Number(row.daily_km) > Number(existing.daily_km)) {
        mileageMap.set(row.plate, row);
      }
    }

    // 合并
    const vehicles: CachedVehicle[] = Array.from(mileageMap.values()).map((m: any) => {
      const info = infoMap.get(m.plate);
      const dailyKm = Number(m.daily_km) || 0;
      const source = m.source || 'NONE';
      return {
        plate: m.plate,
        vin: m.vin,
        dailyKm,
        totalKm: m.total_km !== null ? Number(m.total_km) : null,
        source,
        isOnline: source !== 'NONE' && dailyKm > 0,
        isDataSynced: source !== 'NONE',
        customer: info?.customer || null,
        department: info?.department || null,
        manager: info?.manager || null,
        rentStatus: info?.rent_status || null,
        entity: info?.entity || null,
        project: info?.project || null,
      };
    });

    // 预计算统计信息
    const totalToday = vehicles.reduce((sum, v) => sum + v.dailyKm, 0);
    const totalAll = vehicles.reduce((sum, v) => sum + (v.totalKm || 0), 0);
    const onlineCount = vehicles.filter(v => v.isOnline).length;

    // 预提取筛选选项
    const departments = Array.from(new Set(vehicles.map(v => v.department).filter(Boolean))) as string[];
    const customers = Array.from(new Set(vehicles.map(v => v.customer).filter(Boolean))) as string[];
    const plates = vehicles.map(v => v.plate);
    const projects = Array.from(new Set(vehicles.map(v => v.project).filter(Boolean))) as string[];
    const entities = Array.from(new Set(vehicles.map(v => v.entity).filter(Boolean))) as string[];

    monitoringCache = {
      vehicles,
      stats: { totalToday, totalAll, onlineCount, vehicleCount: vehicles.length },
      filters: { departments, customers, plates, projects, entities },
      updatedAt: new Date().toISOString(),
    };

    console.log(`[mileage] cache refreshed: ${vehicles.length} vehicles in ${Date.now() - start}ms`);
  } catch (e) {
    console.error('[mileage] cache refresh error:', e);
  }
}

// 启动时立即刷新，之后每2分钟刷新
refreshMonitoringCache();
setInterval(refreshMonitoringCache, 2 * 60 * 1000);

// GET /monitoring — 从缓存取数据，支持筛选/排序/分页
app.get('/monitoring', (c) => {
  if (!monitoringCache) {
    return c.json({ vehicles: [], stats: { totalToday: 0, totalAll: 0, onlineCount: 0, vehicleCount: 0 }, filters: { departments: [], customers: [], plates: [], projects: [], entities: [] }, total: 0, page: 1, totalPages: 1, updatedAt: new Date().toISOString() });
  }

  const sortBy = c.req.query('sortBy') || 'today';
  const sortOrder = c.req.query('sortOrder') || 'desc';
  const limit = Number(c.req.query('limit')) || 50;
  const page = Number(c.req.query('page')) || 1;
  const search = c.req.query('search') || '';
  const dept = c.req.query('dept') || '';
  const customer = c.req.query('customer') || '';
  const project = c.req.query('project') || '';
  const entity = c.req.query('entity') || '';
  const mileageMin = c.req.query('mileageMin') || '';
  const mileageMax = c.req.query('mileageMax') || '';
  const plate = c.req.query('plate') || '';

  let vehicles = monitoringCache.vehicles;

  // 筛选
  if (search) {
    const q = search.toLowerCase();
    vehicles = vehicles.filter(v =>
      v.plate.toLowerCase().includes(q) ||
      (v.customer || '').toLowerCase().includes(q) ||
      (v.project || '').toLowerCase().includes(q)
    );
  }
  if (dept) vehicles = vehicles.filter(v => v.department === dept);
  if (customer) vehicles = vehicles.filter(v => v.customer === customer);
  if (project) vehicles = vehicles.filter(v => v.project === project);
  if (entity) vehicles = vehicles.filter(v => v.entity === entity);
  if (plate) vehicles = vehicles.filter(v => v.plate === plate);
  if (mileageMin) vehicles = vehicles.filter(v => v.dailyKm >= Number(mileageMin));
  if (mileageMax) vehicles = vehicles.filter(v => v.dailyKm <= Number(mileageMax));

  const total = vehicles.length;

  // 排序
  vehicles = [...vehicles].sort((a, b) => {
    const valA = sortBy === 'today' ? a.dailyKm : (a.totalKm || 0);
    const valB = sortBy === 'today' ? b.dailyKm : (b.totalKm || 0);
    return sortOrder === 'desc' ? valB - valA : valA - valB;
  });

  // 分页
  const offset = (page - 1) * limit;
  const paged = vehicles.slice(offset, offset + limit);

  return c.json({
    vehicles: paged,
    stats: monitoringCache.stats,
    filters: monitoringCache.filters,
    total,
    page,
    totalPages: Math.ceil(total / limit),
    updatedAt: monitoringCache.updatedAt,
  });
});

// GET /targets — 考核项目列表 + 汇总
app.get('/targets', async (c) => {
  try {
    const [targets] = await pool.execute(
      'SELECT * FROM tab_mileage_assessment_target WHERE is_deleted = 0 ORDER BY id'
    ) as any;

    const [vehicleStats] = await pool.execute(`
      SELECT
        target_id,
        COUNT(*) as total,
        SUM(today_mileage) as today_total,
        SUM(current_mileage) as cumulative_total,
        AVG(completion_rate) as avg_completion,
        SUM(CASE WHEN is_qualified = 1 THEN 1 ELSE 0 END) as qualified_count,
        SUM(CASE WHEN current_year_is_qualified = 1 THEN 1 ELSE 0 END) as year_qualified_count,
        SUM(CASE WHEN completion_rate >= 0.5 THEN 1 ELSE 0 END) as half_qualified_count,
        SUM(current_year_mileage_task) as current_year_target,
        SUM(current_year_mileage) as current_year_completed,
        MAX(current_year_assessment_end_date) as year_end_date
      FROM tab_mileage_assessment_vehicle
      WHERE is_deleted = 0
      GROUP BY target_id
    `) as any;

    const statsMap = new Map<number, any>();
    for (const s of vehicleStats) {
      statsMap.set(s.target_id, s);
    }

    // 查询每个 target 的不同考核区间
    const [periodRows] = await pool.execute(`
      SELECT target_id,
             DATE_FORMAT(assessment_start_date, '%Y-%m-%d') as start_date,
             DATE_FORMAT(assessment_end_date, '%Y-%m-%d') as end_date,
             COUNT(*) as cnt
      FROM tab_mileage_assessment_vehicle
      WHERE is_deleted = 0
      GROUP BY target_id, assessment_start_date, assessment_end_date
      ORDER BY target_id, assessment_start_date
    `) as any;

    const periodsMap = new Map<number, string[]>();
    for (const p of periodRows) {
      const list = periodsMap.get(p.target_id) || [];
      list.push(`${p.start_date} ~ ${p.end_date} (${p.cnt}台)`);
      periodsMap.set(p.target_id, list);
    }

    const now = new Date();
    const result = targets.map((t: any) => {
      const s = statsMap.get(t.id) || {};
      const currentYearTarget = Number(s.current_year_target) || 0;
      const currentYearCompleted = Number(s.current_year_completed) || 0;
      const remaining = Math.max(0, currentYearTarget - currentYearCompleted);
      const yearEnd = s.year_end_date ? new Date(s.year_end_date) : now;
      const daysLeft = Math.max(1, Math.ceil((yearEnd.getTime() - now.getTime()) / 86400000));
      const dailyTarget = remaining / daysLeft;

      const periods = periodsMap.get(t.id) || [];
      if (periods.length === 0) {
        const startDate = t.default_start_date
          ? new Date(t.default_start_date).toISOString().split('T')[0]
          : '';
        const endDate = t.default_end_date
          ? new Date(t.default_end_date).toISOString().split('T')[0]
          : '';
        if (startDate || endDate) periods.push(`${startDate} ~ ${endDate}`);
      }

      return {
        id: t.id,
        targetName: t.target_name,
        vehicleCount: Number(s.total) || t.vehicle_count,
        totalMileagePerVehicle: Number(t.total_mileage_per_vehicle),
        annualMileagePerVehicle: Number(t.annual_mileage_per_vehicle),
        assessmentYears: t.assessment_years,
        periods,
        todayTotal: Number(s.today_total) || 0,
        cumulativeTotal: Number(s.cumulative_total) || 0,
        avgCompletion: (Number(s.avg_completion) || 0) * 100,
        qualifiedCount: Number(s.qualified_count) || 0,
        yearQualifiedCount: Number(s.year_qualified_count) || 0,
        halfQualifiedCount: Number(s.half_qualified_count) || 0,
        currentYearTarget,
        currentYearCompleted,
        remaining,
        daysLeft,
        dailyTarget: Math.round(dailyTarget * 10) / 10,
      };
    });

    return c.json(result);
  } catch (e) {
    console.error('targets error:', e);
    return c.json([], 500);
  }
});

// GET /target/:id/vehicles — 某项目的车辆明细
app.get('/target/:id/vehicles', async (c) => {
  const targetId = c.req.param('id');
  try {
    const [rows] = await pool.execute(
      `SELECT plate_number, today_mileage, vehicle_total_mileage,
              completion_rate, is_qualified, current_year_is_qualified,
              daily_required_mileage
       FROM tab_mileage_assessment_vehicle
       WHERE target_id = ? AND is_deleted = 0
       ORDER BY today_mileage DESC`,
      [targetId]
    ) as any;

    const result = rows.map((r: any) => ({
      plateNumber: r.plate_number,
      todayMileage: Number(r.today_mileage) || 0,
      totalMileage: Number(r.vehicle_total_mileage) || 0,
      completionRate: Number(r.completion_rate) || 0,
      isQualified: r.is_qualified === 1,
      currentYearIsQualified: r.current_year_is_qualified === 1,
      dailyRequiredMileage: Number(r.daily_required_mileage) || 0,
    }));

    return c.json(result);
  } catch (e) {
    console.error('target vehicles error:', e);
    return c.json([], 500);
  }
});

// GET /trend — 7天里程趋势
app.get('/trend', async (c) => {
  const targetId = c.req.query('targetId');
  const days = Number(c.req.query('days')) || 7;
  try {
    let plates: string[] = [];
    if (targetId) {
      const [vehicleRows] = await pool.execute(
        'SELECT plate_number FROM tab_mileage_assessment_vehicle WHERE target_id = ? AND is_deleted = 0',
        [targetId]
      ) as any;
      plates = vehicleRows.map((r: any) => r.plate_number);
      if (plates.length === 0) return c.json([]);
    }

    let sql = `
      SELECT DATE_FORMAT(stat_date, '%m-%d') as date, SUM(daily_km) as mileage
      FROM v_vehicle_daily_stats
      WHERE stat_date >= DATE_SUB(CURDATE(), INTERVAL ? DAY) AND stat_date < CURDATE()
    `;
    const params: any[] = [days];

    if (plates.length > 0) {
      sql += ` AND plate IN (${plates.map(() => '?').join(',')})`;
      params.push(...plates);
    }

    sql += ' GROUP BY stat_date ORDER BY stat_date';

    const [rows] = await mileagePool.execute(sql, params) as any;

    const result = rows.map((r: any) => ({
      date: r.date,
      mileage: Math.round(Number(r.mileage) || 0),
    }));

    return c.json(result);
  } catch (e) {
    console.error('trend error:', e);
    return c.json([], 500);
  }
});

export default app;