Files
UHD_Media_Tool/apps/web/app/routes/console/downloads.tsx
T
rootandClaude Opus 5.5 ceb66f8c77 feat: v0.3.8–v0.3.14 工作区汇总(依赖升级、整理来源、手动入库、原地入库等)
生产 v0.3.8~v0.3.13 均由 8013196 加工作区修改构建部署,此前未提交;本提交补齐源码,
并含未部署的 v0.3.14 原地入库。中间各版本源码状态未保存,无法逐版拆分,详见
docs/plan/17-full-upgrade.md 与 docs/plan/18-organize-release.md。

- v0.3.8 全面升级:Deno workspace 依赖、Router 8 / Vite 8、camofox 1.18.0 / Node 24、
  PostgreSQL 18.6、备份客户端 18.6、演示 qB 5.2.4
- v0.3.9 媒体整理:分类规则、整理来源与目录快照(0059)、文件管理整理入口
- v0.3.10 手动下载与入库:独立手动下载、详情页资源下载、TMDB / Local 元数据兜底
  (metadata.resolve_organize)、正常多版本 / 一次性洗版(0060)
- v0.3.11 搜索详情与桌面黑边修复
- v0.3.12 列表分页、搜索历史、首页概况
- v0.3.13 统一整理弹窗与队列
- v0.3.14 原地入库(0061,未部署)

同批审计修复:
- 刮削入队:确认原记录存在后才删重放产生的新记录;写回 run 关联失败时保持 queued,
  由处理器补关联(对齐 MP 先登记、只在入队失败时记失败)
- 识别升级链只在结果更确定时采用,不再用 no_match 顶替原有歧义候选
- bluray_dir 资产以原盘目录本身为刮削根(MP 同做法)
- metadata.resolve_organize 登记到入库排障 Skill 与能力地图
- db/src/types.ts 按迁移重新生成;contracts 整理动作枚举顺序与数据库对齐
- 测试:原地入库用例改为直接查记录表;domain 测试模板补 version
- 前端:通知铃铛弹层与用户菜单统一样式;站点卡片共用卡头、底栏贴底、分页间距

依赖升级证据只提交摘要文件,registry-snapshot.json 移至 .local/(SHA-256 记于文档)。

Co-Authored-By: Claude Opus 5.5 <[email protected]>
2026-10-02 15:47:17 +08:00

178 lines
6.9 KiB
TypeScript

import { useQueryClient } from "@tanstack/react-query";
import type { DownloadBoardItem, DownloadBoardRow, DownloadBoardState } from "@umt/contracts";
import { EventType } from "@umt/contracts";
import { RefreshCw } from "lucide-react";
import { useEffect, useMemo, useState } from "react";
import { Link, useSearchParams } from "react-router";
import { useBoardPlanRow, useDownloadBoard, usePlan } from "~/api/downloads.ts";
import { type DataColumn, DataTable } from "~/components/console/data-table.tsx";
import { DetailSheet } from "~/components/console/detail-sheet.tsx";
import { LoadingState } from "~/components/console/empty-state.tsx";
import { consolePath } from "~/components/console/nav.ts";
import { PageHeader } from "~/components/console/page-header.tsx";
import { StatusBadge } from "~/components/console/status-badge.tsx";
import { readBoardState, writeBoardState } from "~/components/downloads/board-format.ts";
import { CacheVolumes } from "~/components/downloads/cache-volumes.tsx";
import {
activeColumns,
BOARD_EMPTY,
BoardSegments,
completedColumns,
TransferLine,
} from "~/components/downloads/download-board.tsx";
import { DownloadDetail } from "~/components/downloads/download-detail.tsx";
import { DROPPED_STATUS, droppedReason } from "~/components/downloads/plan-format.ts";
import { PlanDetail, WhySection } from "~/components/downloads/plan-row.tsx";
import { Button } from "~/components/ui/button.tsx";
import { useSse } from "~/lib/sse.ts";
export const meta = () => [{ title: "下载面板 · UHD 媒体自动化控制台" }];
// DL-2:默认只看进行中;已完成单独一段(本浏览器记住选择)。页面可见时每 4 秒刷新速度,切到后台停。
// DL-3:没提交到下载器的下载(等批准 / 等磁盘空间…)也是「进行中」的行;?plan=<计划 id> 深链打开对应行。
const COMPLETED = new Set(["completed", "importing", "imported"]);
export default function DownloadsPage() {
// SPA 模式:路由组件只在浏览器渲染,可直接读本地记住的分段
const [state, setStateRaw] = useState<DownloadBoardState>(readBoardState);
const setState = (s: DownloadBoardState) => {
setStateRaw(s);
writeBoardState(s);
};
const [openId, setOpenId] = useState<string | null>(null);
const [params, setParams] = useSearchParams();
const deepPlan = params.get("plan");
const qc = useQueryClient();
const board = useDownloadBoard(state);
const deep = useBoardPlanRow(deepPlan);
// 深链:找到行就切到它所在的分段并打开;没有行(已结束的下载)打开结束说明
useEffect(() => {
const row = deep.data;
if (!row) return;
setStateRaw(row.kind === "task" && COMPLETED.has(row.status) ? "completed" : "active");
setOpenId(row.id);
}, [deep.data]);
// 状态变化、阈值事件到达时立即刷新(速度靠轮询)
useSse(
[
EventType.downloadProgress,
EventType.downloadStatusChanged,
EventType.downloadSubmitted,
EventType.downloadThreshold,
],
() => void qc.invalidateQueries({ queryKey: ["downloads"] }),
);
const pages = board.data?.pages;
const allRows = pages?.flatMap((p) => p.items);
const rows: DownloadBoardRow[] | undefined =
state === "completed" ? allRows?.filter((r): r is DownloadBoardItem => r.kind === "task") : allRows;
const first = pages?.[0];
const open = rows?.find((t) => t.id === openId) ?? (deep.data?.id === openId ? deep.data : null) ?? null;
const columns = useMemo(
() => (state === "active" ? activeColumns() : (completedColumns() as unknown as DataColumn<DownloadBoardRow>[])),
[state],
);
const empty = BOARD_EMPTY[state];
const closeDeep = () => {
if (!deepPlan) return;
const next = new URLSearchParams(params);
next.delete("plan");
setParams(next, { replace: true });
};
const endedPlan = deepPlan && deep.isSuccess && deep.data === null ? deepPlan : null;
return (
<>
<PageHeader
title="下载面板"
actions={
<Button variant="outline" size="sm" onClick={() => void qc.invalidateQueries({ queryKey: ["downloads"] })}>
<RefreshCw className={board.isFetching ? "animate-spin" : undefined} />
刷新
</Button>
}
/>
<CacheVolumes />
<div className="mb-3 flex flex-wrap items-center justify-between gap-x-4 gap-y-2">
<BoardSegments value={state} counts={first?.counts} onChange={setState} />
<TransferLine transfer={first?.transfer} />
</div>
<DataTable
paginationKey={state}
columns={columns}
rows={rows}
rowKey={(t) => t.id}
loading={board.isPending}
error={board.error}
onRetry={() => void board.refetch()}
onRowClick={(t) => setOpenId(t.id)}
selectedKey={openId}
hasMore={board.hasNextPage}
onLoadMore={() => void board.fetchNextPage()}
loadingMore={board.isFetchingNextPage}
empty={empty}
/>
<DetailSheet
open={!!open}
onOpenChange={(o) => {
if (o) return;
setOpenId(null);
closeDeep();
}}
width="lg"
title={open?.name ?? ""}
footer={
open?.kind === "task" ? (
<Button asChild variant="outline" size="sm">
<Link to={consolePath("downloads", open.id)}>打开详情页</Link>
</Button>
) : null
}
>
{open?.kind === "task" ? <DownloadDetail task={open} live={open.live} /> : null}
{open?.kind === "plan" ? <PlanDetail p={open} /> : null}
</DetailSheet>
<EndedPlanSheet planId={endedPlan} onClose={closeDeep} />
</>
);
}
/** 深链指向已结束的下载(没提交成功 / 已取消 / 已过期):说明原因与来由;作品的下载历史里也有 */
function EndedPlanSheet({ planId, onClose }: { planId: string | null; onClose: () => void }) {
const plan = usePlan(planId);
const p = plan.data;
const ended = p && (p.status === "failed" || p.status === "cancelled" || p.status === "expired") ? p.status : null;
return (
<DetailSheet
open={!!planId}
onOpenChange={(o) => !o && onClose()}
title={ended ? "这次下载没有提交" : "下载"}
description={p ? (droppedReason(p.statusReason) ?? undefined) : undefined}
>
{plan.isPending ? (
<LoadingState rows={3} />
) : !p ? (
<p className="text-sm text-muted-foreground">没找到这次下载,可能已被清理。</p>
) : (
<div className="space-y-5">
{ended ? (
<StatusBadge tone={DROPPED_STATUS[ended].tone}>{DROPPED_STATUS[ended].label}</StatusBadge>
) : (
<p className="text-sm text-muted-foreground">这次下载已经结束。</p>
)}
<WhySection
planId={p.id}
extraTech={[{ label: "状态原码", value: `${p.status} · ${p.statusReason ?? "—"}` }]}
/>
</div>
)}
</DetailSheet>
);
}