feat: 添加 lastSyncAt 字段到概览数据，优化数据获取逻辑

Author: sxjeru

app/api/overview/route.ts

@@ -11,6 +11,7 @@ type CachedOverview = {
     empty: boolean;
     days: number;
     timezone: string;
+    lastSyncAt: string | null;
     meta?: Awaited<ReturnType<typeof getOverview>>["meta"];
     filters?: Awaited<ReturnType<typeof getOverview>>["filters"];
   };
@@ -84,7 +85,7 @@ export async function GET(request: Request) {
       }
     }
 
-    const { overview, empty, days: appliedDays, meta, filters, timezone } = await getOverview(days, {
+    const { overview, empty, days: appliedDays, meta, filters, timezone, lastSyncAt } = await getOverview(days, {
       model: model || undefined,
       route: route || undefined,
       source: source || undefined,
@@ -96,7 +97,7 @@ export async function GET(request: Request) {
       timezone: config.timezone
     });
 
-    const payload = { overview, empty, days: appliedDays, meta, filters, timezone };
+    const payload = { overview, empty, days: appliedDays, meta, filters, timezone, lastSyncAt };
     setCached(cacheKey, payload);
     return NextResponse.json(payload, { status: 200 });
   } catch (error) {

app/page.tsx

@@ -27,6 +27,7 @@ type OverviewAPIResponse = {
   empty: boolean;
   days: number;
   timezone?: string;
+  lastSyncAt?: string | null;
   meta?: OverviewMeta;
   filters?: { models: string[]; routes: string[]; names: string[] };
 };
@@ -815,6 +816,12 @@ export default function DashboardPage() {
         setRouteOptions(Array.from(new Set(data.filters?.routes ?? [])));
         setNameOptions(Array.from(new Set(data.filters?.names ?? [])));
         setAppliedDays(data.days ?? rangeDays);
+        if (data.lastSyncAt) {
+          const dbTime = new Date(data.lastSyncAt);
+          if (Number.isFinite(dbTime.getTime())) {
+            setLastSyncTime((prev) => (!prev || dbTime > prev ? dbTime : prev));
+          }
+        }
       } catch (err) {
         if (!active) return;
         const error = err as Error;

lib/queries/overview.ts

@@ -85,7 +85,7 @@ function normalizePageSize(value?: number | null) {
 export async function getOverview(
   daysInput?: number,
   opts?: { model?: string | null; route?: string | null; source?: string | null; name?: string | null; page?: number | null; pageSize?: number | null; start?: string | Date | null; end?: string | Date | null; timezone?: string | null }
-): Promise<{ overview: UsageOverview; empty: boolean; days: number; meta: OverviewMeta; filters: { models: string[]; routes: string[]; sources: string[]; names: string[] }; timezone: string }> {
+): Promise<{ overview: UsageOverview; empty: boolean; days: number; meta: OverviewMeta; filters: { models: string[]; routes: string[]; sources: string[]; names: string[] }; timezone: string; lastSyncAt: string | null }> {
   const startDate = parseDateInput(opts?.start);
   const endDate = parseDateInput(opts?.end);
   const hasCustomRange = startDate && endDate && endDate >= startDate;
@@ -236,6 +236,10 @@ export async function getOverview(
     .groupBy(credentialNameExpr)
     .orderBy(credentialNameExpr);
 
+  const lastSyncAtPromise: Promise<{ v: Date | null }[]> = db
+    .select({ v: sql<Date | null>`max(${usageRecords.syncedAt})` })
+    .from(usageRecords);
+
   const [
     totalsRowResult,
     priceRows,
@@ -247,7 +251,8 @@ export async function getOverview(
     availableModelsRows,
     availableRoutesRows,
     availableSourcesRows,
-    availableNamesRows
+    availableNamesRows,
+    lastSyncAtRows
   ] = await Promise.all([
     totalsPromise,
     pricePromise,
@@ -259,7 +264,8 @@ export async function getOverview(
     availableModelsPromise,
     availableRoutesPromise,
     availableSourcesPromise,
-    availableNamesPromise
+    availableNamesPromise,
+    lastSyncAtPromise
   ]);
 
   const totalsRow =
@@ -371,6 +377,7 @@ export async function getOverview(
     days,
     meta: { page, pageSize, totalModels, totalPages },
     filters,
-    timezone: tz
+    timezone: tz,
+    lastSyncAt: (() => { const d = lastSyncAtRows[0]?.v; return d ? new Date(d).toISOString() : null; })()
   };
 }