+
详细信息：
+ {details.steps.map((step: any, i: number) => (
+
[{step.step}/3] {step.name}:{' '}
@@ -117,9 +105,7 @@ export function ResetDataButton({ className }: Props) {
{step.skipped ? '⏭️ 跳过' : step.success ? '✅ 成功' : '❌ 失败'}
{step.deleted !== undefined && (
-
- (删除 {step.deleted} 条记录)
-
+ (删除 {step.deleted} 条记录)
)}
))}
diff --git a/src/components/sync/medusa/BatchSyncProducts.tsx b/src/components/sync/medusa/BatchSyncProducts.tsx
new file mode 100644
index 0000000..899bbc3
--- /dev/null
+++ b/src/components/sync/medusa/BatchSyncProducts.tsx
@@ -0,0 +1,119 @@
+'use client'
+import { useState, useEffect } from 'react'
+import { Button, useSelection } from '@payloadcms/ui'
+import { useRouter } from 'next/navigation'
+
+/**
+ * 批量同步选中商品（普通 / 强制覆盖）
+ * API: POST /api/admin/batch-sync-medusa
+ */
+export function BatchSyncProducts() {
+ const { getQueryParams, toggleAll } = useSelection()
+ const [loading, setLoading] = useState(false)
+ const [message, setMessage] = useState('')
+ const [collectionSlug, setCollectionSlug] = useState('products')
+ const router = useRouter()
+
+ useEffect(() => {
+ if (typeof window !== 'undefined') {
+ setCollectionSlug(
+ window.location.pathname.includes('preorder-products')
+ ? 'preorder-products'
+ : 'products',
+ )
+ }
+ }, [])
+
+ const handle = async (forceUpdate: boolean) => {
+ const queryParams = getQueryParams()
+ let selectedIds: string[] = []
+ if (queryParams && typeof queryParams === 'object') {
+ const where = (queryParams as any).where
+ if (where?.id?.in) selectedIds = where.id.in
+ }
+
+ if (!selectedIds.length) {
+ setMessage('⚠️ 请先勾选要同步的商品（使用列表左侧的复选框）')
+ return
+ }
+
+ if (
+ forceUpdate &&
+ !confirm(`确定要强制更新选中的 ${selectedIds.length} 个商品吗？这将覆盖本地修改。`)
+ )
+ return
+
+ setLoading(true)
+ setMessage('')
+ try {
+ const res = await fetch('/api/admin/batch-sync-medusa', {
+ method: 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify({ ids: selectedIds, collection: collectionSlug, forceUpdate }),
+ })
+ const data = await res.json()
+ if (data.success) {
+ setMessage('✅ ' + (data.message || '批量同步成功！'))
+ toggleAll?.()
+ setTimeout(() => router.refresh(), 1500)
+ } else {
+ setMessage('❌ ' + (data.error || '批量同步失败'))
+ }
+ } catch (err) {
+ setMessage('❌ ' + (err instanceof Error ? err.message : '未知错误'))
+ } finally {
+ setLoading(false)
+ }
+ }
+
+ return (
+
+
+
+
+
+ {message &&
}
+
+ )
+}
+
+function StatusMsg({ text }: { text: string }) {
+ const isError = text.startsWith('❌')
+ const isWarn = text.startsWith('⚠️')
+ return (
+
+ {text}
+
+ )
+}
diff --git a/src/components/sync/medusa/ForceUpdateAll.tsx b/src/components/sync/medusa/ForceUpdateAll.tsx
new file mode 100644
index 0000000..efc3070
--- /dev/null
+++ b/src/components/sync/medusa/ForceUpdateAll.tsx
@@ -0,0 +1,152 @@
+'use client'
+import { useState } from 'react'
+import { Button } from '@payloadcms/ui'
+
+/**
+ * 强制全量更新所有 Medusa 商品（需输入确认码）
+ * API: GET /api/sync/medusa?forceUpdate=true
+ */
+export function ForceUpdateAll() {
+ const [showConfirm, setShowConfirm] = useState(false)
+ const [confirmText, setConfirmText] = useState('')
+ const [loading, setLoading] = useState(false)
+ const [message, setMessage] = useState('')
+
+ const handle = async () => {
+ if (confirmText !== 'FORCE_UPDATE_ALL') {
+ setMessage('❌ 确认字符不正确，请输入: FORCE_UPDATE_ALL')
+ return
+ }
+ setLoading(true)
+ setMessage('')
+ setShowConfirm(false)
+ try {
+ const res = await fetch('/api/sync/medusa?forceUpdate=true')
+ const data = await res.json()
+ if (data.success) {
+ setMessage('✅ ' + (data.message || '强制更新成功！'))
+ setTimeout(() => window.location.reload(), 1500)
+ } else {
+ setMessage('❌ ' + (data.error || data.message || '更新失败'))
+ }
+ } catch (err) {
+ setMessage('❌ ' + (err instanceof Error ? err.message : '未知错误'))
+ } finally {
+ setLoading(false)
+ setConfirmText('')
+ }
+ }
+
+ const cancel = () => {
+ setShowConfirm(false)
+ setConfirmText('')
+ setMessage('')
+ }
+
+ if (showConfirm) {
+ return (
+
+
+
+ ⚠️ 危险操作
+
+
这将强制更新所有商品，覆盖所有本地修改。
+
+ 请输入{' '}
+
+ FORCE_UPDATE_ALL
+ {' '}
+ 确认：
+
+
+
setConfirmText(e.target.value)}
+ placeholder="输入 FORCE_UPDATE_ALL"
+ disabled={loading}
+ style={{
+ width: '100%',
+ padding: '0.4rem 0.5rem',
+ marginBottom: '0.5rem',
+ border: '1px solid var(--theme-elevation-400)',
+ borderRadius: '4px',
+ fontSize: '0.875rem',
+ }}
+ />
+
+
+
+
+ {message &&
}
+
+ )
+ }
+
+ return (
+
+
+ {message && }
+
+ )
+}
+
+function StatusMsg({ text }: { text: string }) {
+ const isError = text.startsWith('❌')
+ const isWarn = text.startsWith('⚠️')
+ return (
+
+ {text}
+
+ )
+}
diff --git a/src/components/sync/medusa/SyncNewProducts.tsx b/src/components/sync/medusa/SyncNewProducts.tsx
new file mode 100644
index 0000000..cee00a1
--- /dev/null
+++ b/src/components/sync/medusa/SyncNewProducts.tsx
@@ -0,0 +1,67 @@
+'use client'
+import { useState } from 'react'
+import { Button } from '@payloadcms/ui'
+
+/**
+ * 从 Medusa 同步尚未导入的新商品
+ * API: GET /api/sync/medusa?forceUpdate=false
+ */
+export function SyncNewProducts() {
+ const [loading, setLoading] = useState(false)
+ const [message, setMessage] = useState('')
+
+ const handle = async () => {
+ setLoading(true)
+ setMessage('')
+ try {
+ const res = await fetch('/api/sync/medusa?forceUpdate=false')
+ const data = await res.json()
+ if (data.success) {
+ setMessage('✅ ' + (data.message || '同步成功！'))
+ setTimeout(() => window.location.reload(), 1500)
+ } else {
+ setMessage('❌ ' + (data.error || data.message || '同步失败'))
+ }
+ } catch (err) {
+ setMessage('❌ ' + (err instanceof Error ? err.message : '未知错误'))
+ } finally {
+ setLoading(false)
+ }
+ }
+
+ return (
+
+
+ {message && }
+
+ )
+}
+
+function StatusMsg({ text }: { text: string }) {
+ const isError = text.startsWith('❌')
+ const isWarn = text.startsWith('⚠️')
+ return (
+
+ {text}
+
+ )
+}
diff --git a/src/components/sync/preorder/HealthCheck.tsx b/src/components/sync/preorder/HealthCheck.tsx
new file mode 100644
index 0000000..4580960
--- /dev/null
+++ b/src/components/sync/preorder/HealthCheck.tsx
@@ -0,0 +1,224 @@
+'use client'
+import React, { useState } from 'react'
+import { Button, Modal } from '@payloadcms/ui'
+
+interface HealthCheckResult {
+ success: boolean
+ timestamp: string
+ summary: { total: number; healthy: number; warnings: number; errors: number }
+ products: Array<{
+ id: string
+ title: string
+ medusaId: string
+ seedId: string
+ status: string
+ severity: 'healthy' | 'warning' | 'error'
+ issues: string[]
+ stats: {
+ orderCount: number
+ fakeOrderCount: number
+ totalDisplayCount: number
+ fundingGoal: number
+ completionPercentage: number
+ }
+ dates: { preorderStartDate: string | null; preorderEndDate: string | null }
+ }>
+ issues: string[]
+}
+
+/**
+ * 预购产品健康检查按钮（含结果弹窗）
+ * API: GET /api/preorders/health-check
+ */
+export function HealthCheck() {
+ const [isOpen, setIsOpen] = useState(false)
+ const [loading, setLoading] = useState(false)
+ const [result, setResult] = useState
(null)
+ const [error, setError] = useState(null)
+
+ const run = async () => {
+ setLoading(true)
+ setError(null)
+ try {
+ const res = await fetch('/api/preorders/health-check')
+ if (!res.ok) throw new Error(`HTTP ${res.status}`)
+ const data = await res.json()
+ setResult(data)
+ setIsOpen(true)
+ } catch (err: any) {
+ setError(err.message || '健康检查失败')
+ } finally {
+ setLoading(false)
+ }
+ }
+
+ const severityIcon = (s: string) =>
+ ({ error: '❌', warning: '⚠️', healthy: '✅' })[s] ?? 'ℹ️'
+
+ const fmtDate = (d: string | null) => {
+ if (!d) return 'N/A'
+ try {
+ return new Date(d).toLocaleDateString('zh-CN', {
+ year: 'numeric',
+ month: '2-digit',
+ day: '2-digit',
+ })
+ } catch {
+ return d
+ }
+ }
+
+ return (
+ <>
+
+
+ {error && ❌ {error}}
+
+
+ {isOpen && result && (
+ setIsOpen(false)}>
+
+
+ 预购产品健康检查
+
+
+ {/* 概览 */}
+
+ {(
+ [
+ { label: '总数', value: result.summary.total, bg: '#EFF6FF', border: '#BFDBFE', text: '#2563EB', bold: '#1E40AF' },
+ { label: '健康', value: result.summary.healthy, bg: '#F0FDF4', border: '#BBF7D0', text: '#16A34A', bold: '#15803D' },
+ { label: '警告', value: result.summary.warnings, bg: '#FEFCE8', border: '#FDE047', text: '#CA8A04', bold: '#A16207' },
+ { label: '错误', value: result.summary.errors, bg: '#FEF2F2', border: '#FECACA', text: '#DC2626', bold: '#B91C1C' },
+ ] as const
+ ).map(({ label, value, bg, border, text, bold }) => (
+
+ ))}
+
+
+
+ 检查时间: {new Date(result.timestamp).toLocaleString('zh-CN')}
+
+
+ {/* 产品列表 */}
+
+ {result.products.map((product) => {
+ const borderColor =
+ product.severity === 'error' ? '#FCA5A5' : product.severity === 'warning' ? '#FCD34D' : '#86EFAC'
+ const bgColor =
+ product.severity === 'error' ? '#FEF2F2' : product.severity === 'warning' ? '#FEFCE8' : '#F0FDF4'
+ return (
+
+
+
+
+ {severityIcon(product.severity)}
+
{product.title}
+
+ {product.status}
+
+
+
+
Medusa ID: {product.medusaId}
+ {product.seedId &&
Seed ID: {product.seedId}
}
+
+
+
+
进度: {product.stats.completionPercentage}%
+
+ {product.stats.totalDisplayCount} / {product.stats.fundingGoal}
+
+
+
+
+
+
+ 开始:{' '}
+ {fmtDate(product.dates.preorderStartDate)}
+
+
+ 结束:{' '}
+ {fmtDate(product.dates.preorderEndDate)}
+
+
+
+ {product.issues.length > 0 && (
+
+
问题:
+
+ {product.issues.map((issue, i) => (
+ -
+ {issue}
+
+ ))}
+
+
+ )}
+
+ )
+ })}
+
+ {result.products.length === 0 && (
+
+ 没有找到预购产品
+
+ )}
+
+
+
+
+
+
+
+
+
+
+
+ {message &&
}
+
+
+
+ 💡 说明：订单计数 = 真实订单计数 + Fake计数
+
+
+ • 真实订单计数：从 Medusa 订单系统同步，只读
+
+
+ • Fake计数：可手动编辑，用于调整显示的进度
+
+
+
+ {text}
+
+ )
+}
diff --git a/src/components/sync/taobao/TaobaoAllSync.tsx b/src/components/sync/taobao/TaobaoAllSync.tsx
new file mode 100644
index 0000000..ff0e5f9
--- /dev/null
+++ b/src/components/sync/taobao/TaobaoAllSync.tsx
@@ -0,0 +1,123 @@
+'use client'
+import { useState } from 'react'
+
+/**
+ * 列表页 — 淘宝全量同步按钮（仅填充空字段 / 强制覆盖所有字段）
+ * API: POST /api/admin/taobao/sync-all
+ */
+export function TaobaoAllSync() {
+ const [loadingNormal, setLoadingNormal] = useState(false)
+ const [loadingForce, setLoadingForce] = useState(false)
+ const [confirmForce, setConfirmForce] = useState(false)
+ const [message, setMessage] = useState(null)
+
+ const busy = loadingNormal || loadingForce
+
+ const run = async (force: boolean) => {
+ const setLoading = force ? setLoadingForce : setLoadingNormal
+ setLoading(true)
+ setMessage(null)
+ setConfirmForce(false)
+ try {
+ const res = await fetch('/api/admin/taobao/sync-all', {
+ method: 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify({ force }),
+ })
+ const data = await res.json()
+ if (!data.success) throw new Error(data.error || '请求失败')
+ setMessage(`✅ ${data.message}`)
+ } catch (err: any) {
+ setMessage(`❌ ${err?.message ?? '未知错误'}`)
+ } finally {
+ setLoading(false)
+ }
+ }
+
+ return (
+
+
+
+
+ {!confirmForce ? (
+
+ ) : (
+ <>
+
+ 确认覆盖所有字段？
+
+
+
+
+ )}
+
+
+ {message &&
}
+
+ {text}
+
+ )
+}
diff --git a/src/components/sync/taobao/TaobaoProductSync.tsx b/src/components/sync/taobao/TaobaoProductSync.tsx
new file mode 100644
index 0000000..2a7d206
--- /dev/null
+++ b/src/components/sync/taobao/TaobaoProductSync.tsx
@@ -0,0 +1,121 @@
+'use client'
+import { useState } from 'react'
+import { useDocumentInfo } from '@payloadcms/ui'
+
+/**
+ * 产品编辑页 — 淘宝信息同步按钮（仅填充空字段 / 强制覆盖）
+ * API: POST /api/admin/taobao/sync-product
+ *
+ * 使用 useDocumentInfo，只能在 Product / PreorderProduct 编辑页使用。
+ */
+export function TaobaoProductSync() {
+ const { id, collectionSlug } = useDocumentInfo()
+ const [loadingNormal, setLoadingNormal] = useState(false)
+ const [loadingForce, setLoadingForce] = useState(false)
+ const [message, setMessage] = useState(null)
+
+ if (!id) return null
+ const isValid = collectionSlug === 'products' || collectionSlug === 'preorder-products'
+ if (!isValid) return null
+
+ const busy = loadingNormal || loadingForce
+
+ const run = async (force: boolean) => {
+ const setLoading = force ? setLoadingForce : setLoadingNormal
+ setLoading(true)
+ setMessage(null)
+ try {
+ const res = await fetch('/api/admin/taobao/sync-product', {
+ method: 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify({ productId: id, collection: collectionSlug, force }),
+ })
+ const data = await res.json()
+ if (!data.success) throw new Error(data.error || '请求失败')
+ setMessage(`✅ ${data.message || '完成'}`)
+ setTimeout(() => window.location.reload(), 1200)
+ } catch (err: any) {
+ setMessage(`❌ ${err?.message ?? '未知错误'}`)
+ } finally {
+ setLoading(false)
+ }
+ }
+
+ return (
+
+
+ 淘宝自动解析
+
+
+
+
+
+
+
+
+ 🔄 更新：仅填充空白字段（标题、封面、价格）
+ ⚡ 强制更新：覆盖已有字段
+
+
+ {message &&
}
+
+ {text}
+
+ )
+}
diff --git a/src/components/views/AdminPanel.tsx b/src/components/views/AdminPanel.tsx
index 5f333b6..cf71ffe 100644
--- a/src/components/views/AdminPanel.tsx
+++ b/src/components/views/AdminPanel.tsx
@@ -2,7 +2,7 @@
import React, { useState } from 'react'
import { Button } from '@payloadcms/ui'
-import { ResetDataButton } from '../sync/ResetDataButton'
+import { ResetData } from '../sync/admin/ResetData'
/**
* 管理员控制面板
@@ -168,7 +168,7 @@ export default function AdminPanel() {
一键重置所有数据：清理 Payload CMS → 清理 Medusa → 重新导入 Medusa seed 数据
-
+
{/* 清理数据库 */}
diff --git a/src/components/views/PreorderHealthCheckButton.tsx b/src/components/views/PreorderHealthCheckButton.tsx
deleted file mode 100644
index 97368a8..0000000
--- a/src/components/views/PreorderHealthCheckButton.tsx
+++ /dev/null
@@ -1,260 +0,0 @@
-'use client'
-
-import React, { useState } from 'react'
-import { Button, Modal } from '@payloadcms/ui'
-
-interface HealthCheckResult {
- success: boolean
- timestamp: string
- summary: {
- total: number
- healthy: number
- warnings: number
- errors: number
- }
- products: Array<{
- id: string
- title: string
- medusaId: string
- seedId: string
- status: string
- severity: 'healthy' | 'warning' | 'error'
- issues: string[]
- stats: {
- orderCount: number
- fakeOrderCount: number
- totalDisplayCount: number
- fundingGoal: number
- completionPercentage: number
- }
- dates: {
- preorderStartDate: string | null
- preorderEndDate: string | null
- }
- }>
- issues: string[]
-}
-
-export const PreorderHealthCheckButton: React.FC = () => {
- const [isOpen, setIsOpen] = useState(false)
- const [loading, setLoading] = useState(false)
- const [result, setResult] = useState