apps/web/src/api/products/index.ts

@@ -13,6 +13,8 @@ export type {
   VideoItem,
 } from "./types"
 
+export type { RecomputeDedupResponse } from "./products"
+
 // 工具函数
 export { mapVideoToProductItem } from "./utils"
 
@@ -25,4 +27,5 @@ export {
   updateReviewStatus,
   batchDownload,
   getBatchDownloadStatus,
+  recomputeDedup,
 } from "./products"

apps/web/src/api/products/products.ts

@@ -78,3 +78,18 @@ export const getBatchDownloadStatus = async (jobId: string): Promise<BatchDownlo
   console.warn("[getBatchDownloadStatus] 后端暂无批量下载状态端点", jobId)
   return { job_id: jobId, status: "processing", progress: 0 }
 }
+
+/** 重新计算存量视频查重率（异步） */
+export interface RecomputeDedupResponse {
+  enqueued: number
+  total_scanned: number
+  skipped: number
+  message: string
+}
+
+export const recomputeDedup = async (videoIds?: string[]): Promise<RecomputeDedupResponse> => {
+  const response = await apiClient.post("/videos/recompute-dedup", {
+    video_ids: videoIds,
+  })
+  return response.data
+}

apps/web/src/pages/products/ProductLibrary.tsx

@@ -11,7 +11,7 @@
  * 产品卡片 → components/ProductCard（内联视频播放）
  */
 import React from "react"
-import { VideoCameraOutlined, DownloadOutlined } from "@ant-design/icons"
+import { VideoCameraOutlined, DownloadOutlined, ReloadOutlined } from "@ant-design/icons"
 import { Button } from "@/components/ui"
 import { ProductCard } from "./components/ProductCard"
 import { ProductFilterBar } from "./components/ProductFilterBar"
@@ -19,6 +19,7 @@ import { ProductBatchBar } from "./components/ProductBatchBar"
 import { ProductEmptyState } from "./components/ProductEmptyState"
 import { useProductList } from "./hooks/useProductList"
 import { useProductActions } from "./hooks/useProductActions"
+import { useRecomputeDedup } from "./hooks/product-actions/useRecomputeDedup"
 import "./products.css"
 
 const ProductLibrary: React.FC = () => {
@@ -67,6 +68,8 @@ const ProductLibrary: React.FC = () => {
     setPlayingProduct: () => {}, // 不再使用弹窗播放
   })
 
+  const { recomputeDedup, isRecomputing } = useRecomputeDedup()
+
   // ── Loading 状态 ──
   if (isLoading) {
     return <ProductEmptyState type="loading" />
@@ -94,6 +97,15 @@ const ProductLibrary: React.FC = () => {
           <Button buttonType="ghost" buttonSize="sm" icon={<DownloadOutlined />}>
             批量导出
           </Button>
+          <Button
+            buttonType="ghost"
+            buttonSize="sm"
+            icon={<ReloadOutlined />}
+            loading={isRecomputing}
+            onClick={recomputeDedup}
+          >
+            重新查重
+          </Button>
         </div>
       </div>
 

apps/web/src/pages/products/hooks/product-actions/useRecomputeDedup.ts

@@ -0,0 +1,27 @@
+import { useMutation, useQueryClient } from "@tanstack/react-query"
+import { message } from "antd"
+import { recomputeDedup } from "@/api/products"
+
+export function useRecomputeDedup() {
+  const queryClient = useQueryClient()
+
+  const mutation = useMutation({
+    mutationFn: () => recomputeDedup(),
+    onSuccess: (data) => {
+      queryClient.invalidateQueries({ queryKey: ["products"] })
+      if (data.enqueued > 0) {
+        message.success(`已提交 ${data.enqueued} 个视频的查重任务，后台处理中`)
+      } else {
+        message.info("所有视频查重率已是最新，无需重算")
+      }
+    },
+    onError: () => {
+      message.error("查重任务提交失败，请稍后重试")
+    },
+  })
+
+  return {
+    recomputeDedup: () => mutation.mutate(),
+    isRecomputing: mutation.isPending,
+  }
+}

apps/web/src/test/pages/ProductLibrary.test.tsx

@@ -102,6 +102,7 @@ vi.mock("@ant-design/icons", () => ({
   SearchOutlined: () => <span />,
   ShareAltOutlined: () => <span />,
   VideoCameraOutlined: () => <span />,
+  ReloadOutlined: () => <span />,
 }))
 
 vi.mock("@/store/authStore", () => ({