@@ -129,6 +165,8 @@ import { ElMessage, ElMessageBox } from 'element-plus'
import { Search, RefreshLeft, Download } from '@element-plus/icons-vue'
import { listSybProducts, getSybProduct, reparseSybProduct, reparseSybProductsBatch, correctSybProduct, importSybProducts, getSybSyncRun } from '@/api/goauto/syb-products'
import { listSybShops } from '@/api/goauto/syb-shops'
+import { listDevices } from '@/api/goauto/devices'
+import { createPurchaseTasksBatch, previewPurchaseTasks } from '@/api/goauto/purchase-tasks'
export default {
name: 'GoAutoSybProducts',
@@ -136,6 +174,10 @@ export default {
data() {
return {
loading: false, products: [], selectedProducts: [], total: 0,
+ batchMode: 'purchase', purchaseReadiness: {}, purchaseReadinessLoading: false,
+ purchaseDevices: [],
+ purchaseDialog: { open: false, loading: false, saving: false, ids: [], deviceId: null, items: [], eligibleCount: 0, skippedCount: 0 },
+ purchaseResult: { open: false, items: [], createdCount: 0, failedCount: 0 },
query: { page: 1, pageSize: 20, keyword: '', parseStatus: '' },
importDialog: { open: false, saving: false, range: null, spanDays: 0 },
activeRun: null, syncPollTimer: null,
@@ -147,6 +189,8 @@ export default {
},
computed: {
isAdmin() { return (this.$store.getters.roles || []).includes('admin') },
+ canPurchase() { const roles = this.$store.getters.roles || []; return roles.includes('admin') || roles.includes('purchaser') },
+ firstCreatedTaskId() { return this.purchaseResult.items.find(item => item.taskId)?.taskId || null },
formattedRaw() {
if (!this.detail.item) return ''
try { return JSON.stringify(JSON.parse(this.detail.item.rawJson), null, 2) } catch { return this.detail.item.rawJson }
@@ -160,7 +204,7 @@ export default {
this.importDialog.spanDays = Math.round((to - from) / 86400000) + 1
}
},
- created() { this.load() },
+ created() { if (!this.canPurchase) this.batchMode = 'reparse'; this.load() },
beforeUnmount() { this.stopSyncPolling() },
methods: {
async load() {
@@ -171,6 +215,7 @@ export default {
const r = await listSybProducts(this.query)
this.products = r.data.items
this.total = r.data.total
+ await this.loadPurchaseReadiness()
} finally {
this.loading = false
}
@@ -178,6 +223,20 @@ export default {
search() { this.query.page = 1; this.load() },
reset() { this.query = { page: 1, pageSize: 20, keyword: '', parseStatus: '' }; this.load() },
handleSelectionChange(rows) { this.selectedProducts = rows },
+ changeBatchMode() { this.selectedProducts = []; this.$refs.productTable?.clearSelection() },
+ rowSelectable(row) { return this.batchMode !== 'purchase' || (this.canPurchase && this.purchaseReady(row).eligible) },
+ purchaseReady(row) { return this.purchaseReadiness[row.id] || { sybProductId: row.id, eligible: false, reason: this.purchaseReadinessLoading ? '正在检查' : '请刷新后重试' } },
+ purchasePriceText(item) { if (item.minUnitPriceCent === undefined || item.maxUnitPriceCent === undefined) return ''; return `允许单价 ¥${(item.minUnitPriceCent / 100).toFixed(2)}～¥${(item.maxUnitPriceCent / 100).toFixed(2)}` },
+ purchaseActionLabel(item) { return { open_mapping: '去匹配', open_shopee: '查看蝦皮商品', open_pdd: '查看 PDD 商品', open_task: '查看任务', reparse: '查看并处理', select_device: '重新选择设备', refresh: '刷新' }[item.nextAction] || '' },
+ async loadPurchaseReadiness() {
+ this.purchaseReadiness = {}
+ if (!this.canPurchase || !this.products.length) return
+ this.purchaseReadinessLoading = true
+ try {
+ const r = await previewPurchaseTasks({ sybProductIds: this.products.map(item => item.id) })
+ this.purchaseReadiness = Object.fromEntries(r.data.items.map(item => [item.sybProductId, item]))
+ } finally { this.purchaseReadinessLoading = false }
+ },
priceText(row) { if (row.unitPriceCent === null || row.unitPriceCent === undefined) return '—'; return `¥${(row.unitPriceCent / 100).toFixed(2)}` },
parseMeta(status) { return { success: { label: '成功', type: 'success' }, uncertain: { label: '存疑', type: 'warning' }, failed: { label: '失败', type: 'danger' }}[status] || { label: status || '-', type: 'info' } },
reparseOutcomeLabel(outcome) { return { reparsed: '已更新', skipped_manual: '已跳过（人工确认）', unchanged: '无变化' }[outcome] || outcome },
@@ -188,6 +247,49 @@ export default {
const route = this.$router.resolve({ path: '/shopee-products/index', query: { productId: shopeeProductId }})
window.open(route.href, '_blank', 'noopener')
},
+ openPurchaseTask(taskId) { this.$router.push({ path: '/purchase-tasks/index', query: { taskId }}) },
+ runPurchaseNextAction(row, readiness) {
+ if (readiness.nextAction === 'open_mapping' || readiness.nextAction === 'open_shopee') return this.openShopeeDetail(row.shopeeProductId)
+ if (readiness.nextAction === 'open_pdd') return this.openShopeeDetail(row.shopeeProductId)
+ if (readiness.nextAction === 'open_task' && readiness.activeTaskId) return this.openPurchaseTask(readiness.activeTaskId)
+ if (readiness.nextAction === 'reparse') return this.openDetail(row.sybProductId || row.id)
+ if (readiness.nextAction === 'select_device') { this.purchaseResult.open = false; return this.load() }
+ if (readiness.nextAction === 'refresh') return this.load()
+ },
+
+ // ---------------- 批量创建采购任务 ----------------
+ async openSinglePurchase(row) {
+ this.$refs.productTable?.clearSelection()
+ this.$refs.productTable?.toggleRowSelection(row, true)
+ await this.openPurchaseBatch()
+ },
+ async openPurchaseBatch() {
+ const ids = this.selectedProducts.map(item => item.id)
+ this.purchaseDialog = { open: true, loading: true, saving: false, ids, deviceId: null, items: [], eligibleCount: 0, skippedCount: 0 }
+ try {
+ const [preview, devices] = await Promise.all([
+ previewPurchaseTasks({ sybProductIds: ids }),
+ listDevices({ page: 1, pageSize: 100, status: 'online' })
+ ])
+ this.applyPurchasePreview(preview.data)
+ const required = ['purchase.live.v1', 'purchase.address-update.v1', 'purchase.order-create.v1', 'purchase.spec-probe.v1']
+ this.purchaseDevices = devices.data.items.filter(device => device.selectable && required.every(capability => (device.capabilities || []).includes(capability)))
+ } finally { this.purchaseDialog.loading = false }
+ },
+ applyPurchasePreview(data) { this.purchaseDialog.items = data.items; this.purchaseDialog.eligibleCount = data.eligibleCount; this.purchaseDialog.skippedCount = data.skippedCount },
+ async refreshPurchasePreview() {
+ this.purchaseDialog.loading = true
+ try { const r = await previewPurchaseTasks({ sybProductIds: this.purchaseDialog.ids, deviceId: this.purchaseDialog.deviceId || undefined }); this.applyPurchasePreview(r.data) } finally { this.purchaseDialog.loading = false }
+ },
+ async submitPurchaseBatch() {
+ this.purchaseDialog.saving = true
+ try {
+ const r = await createPurchaseTasksBatch({ requestId: crypto.randomUUID(), sybProductIds: this.purchaseDialog.ids, deviceId: this.purchaseDialog.deviceId || undefined })
+ this.purchaseResult = { open: true, items: r.data.items, createdCount: r.data.createdCount, failedCount: r.data.failedCount }
+ this.purchaseDialog.open = false
+ await this.load()
+ } finally { this.purchaseDialog.saving = false }
+ },
// ---------------- 从 SYB 导入 ----------------
disableFutureDate(date) { return date.getTime() > Date.now() },
@@ -308,7 +410,9 @@ export default {
.link{color:#1677ff;cursor:pointer}
.scope-note{margin-top:12px;font-size:12px;color:#b91c1c}
.notice{margin-bottom:16px}
+.compact-notice{margin-bottom:12px}
.dialog-form{margin-bottom:8px}
+.purchase-summary{display:flex;flex-wrap:wrap;gap:12px 24px;margin-bottom:16px;padding:12px 16px;border:1px solid #dbeafe;border-radius:8px;background:#f8fafc}.purchase-summary strong{font-variant-numeric:tabular-nums;color:#1e40af}.success-text{color:#166534}.danger-text,.purchase-reason{color:#b91c1c}.purchase-reason{margin-top:4px;font-size:12px;line-height:1.45}.purchase-settings{margin-bottom:12px}.field-help{margin-left:12px;color:#909399;font-size:12px}.ellipsis{overflow:hidden;text-overflow:ellipsis;white-space:nowrap}
.purchase-note{margin:0 0 16px}
.drawer-body{padding:0 4px 24px}
.split{display:grid;grid-template-columns:1fr 1fr;gap:24px}