UHD_Media_Tool/apps/web/app/routes/console/schedules.tsx

import { useQueryClient } from "@tanstack/react-query";
import { SCHEDULE_CHANGED_EVENT, type ScheduledJob, type ScheduleGroup } from "@umt/contracts";
import { AlertTriangle, CalendarClock, CircleCheck, LoaderCircle, Plus, RotateCw, XCircle } from "lucide-react";
import { useEffect, useRef, useState } from "react";
import { useScheduleBoard } from "~/api/schedules.ts";
import { EmptyState, ErrorState, LoadingState } from "~/components/console/empty-state.tsx";
import { PageHeader } from "~/components/console/page-header.tsx";
import { StatTile } from "~/components/console/stat-tile.tsx";
import { AgentCheckDialog } from "~/components/schedules/agent-check-dialog.tsx";
import { GROUP_LABEL, GROUP_ORDER } from "~/components/schedules/labels.ts";
import { RunsSheet } from "~/components/schedules/runs-sheet.tsx";
import { ScheduleCard } from "~/components/schedules/schedule-card.tsx";
import { Button } from "~/components/ui/button.tsx";
import { qk } from "~/lib/query-keys.ts";
import { useSse } from "~/lib/sse.ts";

export const meta = () => [{ title: "定时任务 · UHD 媒体自动化控制台" }];

/** 每秒一跳的当前时间(倒计时用) */
function useNow(ms = 1000) {
  const [now, setNow] = useState(() => Date.now());
  useEffect(() => {
    const t = setInterval(() => setNow(Date.now()), ms);
    return () => clearInterval(t);
  }, [ms]);
  return now;
}

export default function SchedulesPage() {
  const qc = useQueryClient();
  const board = useScheduleBoard();
  const now = useNow();
  const [history, setHistory] = useState<ScheduledJob | null>(null);
  const [editing, setEditing] = useState<{ job: ScheduledJob | null; key: number } | null>(null);

  // SSE:调度器每次开始/结束一次运行都会发 schedule.changed;1 秒节流
  const timer = useRef<ReturnType<typeof setTimeout> | null>(null);
  useSse([SCHEDULE_CHANGED_EVENT], () => {
    if (timer.current) return;
    timer.current = setTimeout(() => {
      timer.current = null;
      qc.invalidateQueries({ queryKey: qk.all("schedules") });
    }, 1000);
  });
  useEffect(
    () => () => {
      if (timer.current) clearTimeout(timer.current);
    },
    [],
  );

  const data = board.data;
  const items = data?.items ?? [];
  const byGroup = new Map<ScheduleGroup, ScheduledJob[]>();
  for (const g of GROUP_ORDER) byGroup.set(g, []);
  for (const j of items) byGroup.get(j.group)?.push(j);
  const stats = data?.stats;
  const val = (n: number | undefined) => (board.isPending ? "…" : board.isError ? "—" : (n ?? 0));

  return (
    <>
      <PageHeader
        title="定时任务"
        description="周期任务与 Agent 巡检的开关、间隔和运行记录。"
        actions={
          <>
            <Button
              variant="outline"
              size="sm"
              onClick={() => qc.invalidateQueries({ queryKey: qk.all("schedules") })}
              disabled={board.isFetching}
            >
              <RotateCw className={board.isFetching ? "animate-spin" : undefined} />
              刷新
            </Button>
            <Button size="sm" onClick={() => setEditing({ job: null, key: Date.now() })}>
              <Plus />
              新建巡检
            </Button>
          </>
        }
      />

      <div className="mb-3 grid grid-cols-2 gap-2 lg:grid-cols-4">
        <StatTile label="已启用" icon={CircleCheck} value={val(stats?.enabled)} />
        <StatTile
          label="上次失败"
          icon={XCircle}
          tone={(stats?.failed ?? 0) > 0 ? "destructive" : "neutral"}
          value={val(stats?.failed)}
        />
        <StatTile label="运行中" icon={LoaderCircle} value={val(stats?.running)} />
        <StatTile label="全部" icon={CalendarClock} value={val(stats?.total)} />
      </div>

      {data && !data.schedulerOnline ? (
        <p
          role="status"
          className="mb-4 flex items-center gap-2 rounded-tight border border-warning/30 bg-warning/10 px-3 py-2 text-caption text-warning"
        >
          <AlertTriangle className="h-4 w-4 shrink-0" />
          调度器未在线,任务不会按时运行。
        </p>
      ) : (
        <div className="mb-4" />
      )}

      {board.isPending ? (
        <LoadingState rows={6} />
      ) : board.isError ? (
        <ErrorState error={board.error} onRetry={() => board.refetch()} />
      ) : items.length === 0 ? (
        <EmptyState icon={CalendarClock} title="还没有登记的定时任务" description="worker 启动后会自动登记。" />
      ) : (
        <div className="grid items-start gap-4 md:grid-cols-2 xl:grid-cols-3 2xl:grid-cols-5">
          {GROUP_ORDER.map((g) => {
            const jobs = byGroup.get(g) ?? [];
            return (
              <section key={g} aria-label={GROUP_LABEL[g]} className="grid min-w-0 gap-2.5">
                <h2 className="flex items-baseline justify-between px-1 text-caption font-medium text-muted-foreground">
                  <span>{GROUP_LABEL[g]}</span>
                  <span className="tabular-nums">{jobs.length}</span>
                </h2>
                {jobs.length === 0 ? (
                  <p className="rounded-xl border border-dashed border-border/70 px-4 py-6 text-center text-meta text-muted-foreground">
                    {g === "agent" ? "暂无巡检,点「新建巡检」添加。" : "暂无任务。"}
                  </p>
                ) : (
                  jobs.map((j) => (
                    <ScheduleCard
                      key={j.id}
                      job={j}
                      now={now}
                      onHistory={setHistory}
                      onEdit={(job) => setEditing({ job, key: Date.now() })}
                    />
                  ))
                )}
              </section>
            );
          })}
        </div>
      )}

      <RunsSheet job={history} onClose={() => setHistory(null)} />
      {editing ? (
        <AgentCheckDialog key={editing.key} open job={editing.job} onOpenChange={(o) => !o && setEditing(null)} />
      ) : null}
    </>
  );
}