外部测试内部绑定ok

2026-04-12 13:16:50 +08:00
parent a95247cd01
commit 0029147bc4
31 changed files with 2826 additions and 124 deletions
@@ -7,6 +7,12 @@ import {
  getAgisoShopsFilePath,
  saveAgisoShopConfigMap,
 } from '../platforms/agiso/shop-config-service.js'
+import {
+  getOrderFulfillmentBindingConfigs,
+  getOrderFulfillmentBindingsFilePath,
+  saveOrderFulfillmentBindingConfigs,
+} from '../order/fulfillment-binding-config-service.js'
+import { getFulfillmentProfileByKey } from '../../repositories/fulfillment-profile-repo.js'
 import { getClaimTokenById, updateClaimToken } from '../../repositories/claim-token-repo.js'
 import {
  createInventoryItems,
@@ -31,6 +37,8 @@ import { formatFenToAmount, normalizeFen, parseAmountToFen } from '../../utils/m
 import { nowIso } from '../../utils/time.js'
 import { reserveInventoryForTask } from '../order/inventory-service.js'
 import { replayAgisoTradeWebhookEvent } from '../order/webhook-service.js'
+import { syncConfiguredFulfillmentBindings } from '../bootstrap/fulfillment-bootstrap-service.js'
+import { normalizeProductName } from '../order/product-match-service.js'
 import { normalizeDateQuery, normalizePage, normalizePageSize, safeParseJson } from './admin-query-utils.js'

 export async function getAdminDashboardSummary() {
@@ -294,6 +302,7 @@ export async function getAdminInventoryItems(query = {}) {
    page,
    pageSize,
    skuCode: String(query.skuCode || '').trim(),
+    credentialType: String(query.credentialType || '').trim(),
    status: String(query.status || '').trim(),
    batchNo: String(query.batchNo || '').trim(),
  })
@@ -581,6 +590,145 @@ export function updateAdminAgisoShopConfigs(payload = {}) {
  }
 }

+export async function getAdminFulfillmentBindingConfigs() {
+  const bindings = getOrderFulfillmentBindingConfigs()
+  const rowsResult = await query(
+    `
+      SELECT
+        o.provider,
+        o.platform,
+        o.shop_id,
+        MAX(CASE WHEN trim(o.shop_name) != '' THEN o.shop_name ELSE '' END) AS shop_name,
+        COALESCE(NULLIF(oi.item_snapshot_json ->> 'externalItemId', ''), '') AS external_item_id,
+        COALESCE(NULLIF(oi.item_snapshot_json ->> 'externalSkuCode', ''), '') AS external_sku_code,
+        COALESCE(NULLIF(oi.item_snapshot_json ->> 'externalSkuName', ''), '') AS external_sku_name,
+        MAX(oi.created_at) AS latest_seen_at,
+        COUNT(*)::int AS order_item_count
+      FROM order_items oi
+      JOIN orders o ON o.id = oi.order_id
+      WHERE
+        COALESCE(NULLIF(oi.item_snapshot_json ->> 'externalItemId', ''), '') != ''
+        OR COALESCE(NULLIF(oi.item_snapshot_json ->> 'externalSkuCode', ''), '') != ''
+        OR COALESCE(NULLIF(oi.item_snapshot_json ->> 'externalSkuName', ''), '') != ''
+      GROUP BY
+        o.provider,
+        o.platform,
+        o.shop_id,
+        external_item_id,
+        external_sku_code,
+        external_sku_name
+      ORDER BY latest_seen_at DESC, o.platform ASC, o.shop_id ASC, external_sku_code ASC
+      LIMIT 200
+    `,
+  )
+
+  return {
+    filePath: getOrderFulfillmentBindingsFilePath(),
+    bindings: bindings.map(mapAdminFulfillmentBindingConfigItem),
+    observedProducts: rowsResult.rows.map((row) => {
+      const item = {
+        provider: String(row.provider || '').trim(),
+        platform: String(row.platform || '').trim(),
+        shopId: String(row.shop_id || '').trim(),
+        shopName: String(row.shop_name || '').trim(),
+        externalItemId: String(row.external_item_id || '').trim(),
+        externalSkuCode: String(row.external_sku_code || '').trim(),
+        externalSkuName: String(row.external_sku_name || '').trim(),
+        latestSeenAt: row.latest_seen_at || null,
+        orderItemCount: Number(row.order_item_count || 0),
+      }
+
+      return {
+        ...item,
+        configured: bindings.some((binding) => matchesObservedProduct(binding, item)),
+      }
+    }),
+  }
+}
+
+export async function updateAdminFulfillmentBindingConfigs(payload = {}) {
+  const bindingsInput = Array.isArray(payload.bindings) ? payload.bindings : []
+  await validateAdminFulfillmentBindingConfigs(bindingsInput)
+  const saved = saveOrderFulfillmentBindingConfigs(bindingsInput)
+  await syncConfiguredFulfillmentBindings()
+
+  return {
+    filePath: getOrderFulfillmentBindingsFilePath(),
+    bindings: saved.map(mapAdminFulfillmentBindingConfigItem),
+  }
+}
+
+async function validateAdminFulfillmentBindingConfigs(bindings = []) {
+  if (!Array.isArray(bindings)) {
+    throw createHttpError('履约配置格式不正确', {
+      statusCode: 400,
+      errorCode: 'admin_fulfillment_bindings_invalid_payload',
+    })
+  }
+
+  const seenKeys = new Set()
+
+  for (const [index, rawBinding] of bindings.entries()) {
+    if (!isPlainObject(rawBinding)) {
+      throw createHttpError(`第 ${index + 1} 条规则格式不正确`, {
+        statusCode: 400,
+        errorCode: 'admin_fulfillment_bindings_invalid_item',
+      })
+    }
+
+    const provider = String(rawBinding.provider || 'agiso').trim() || 'agiso'
+    const platform = String(rawBinding.platform || '').trim()
+    const shopId = String(rawBinding.shopId || '').trim()
+    const skuCode = String(rawBinding.skuCode || '').trim()
+    const profileKey = String(rawBinding.profileKey || '').trim() || 'manual_review'
+    const match = isPlainObject(rawBinding.match) ? rawBinding.match : {}
+    const externalItemId = String(match.externalItemId || '').trim()
+    const externalSkuCode = String(match.externalSkuCode || '').trim()
+    const externalSkuName = String(match.externalSkuName || '').trim()
+
+    if (!skuCode) {
+      throw createHttpError(`第 ${index + 1} 条规则缺少内部履约 SKU`, {
+        statusCode: 400,
+        errorCode: 'admin_fulfillment_bindings_missing_sku_code',
+      })
+    }
+
+    if (!externalItemId && !externalSkuCode && !externalSkuName) {
+      throw createHttpError(`第 ${index + 1} 条规则至少需要一种外部匹配条件`, {
+        statusCode: 400,
+        errorCode: 'admin_fulfillment_bindings_missing_match_condition',
+      })
+    }
+
+    const profile = await getFulfillmentProfileByKey(profileKey)
+    if (!profile) {
+      throw createHttpError(`第 ${index + 1} 条规则使用了不存在的履约方式: ${profileKey}`, {
+        statusCode: 400,
+        errorCode: 'admin_fulfillment_bindings_invalid_profile_key',
+      })
+    }
+
+    const uniqueKey = [
+      provider,
+      platform,
+      shopId,
+      externalItemId,
+      externalSkuCode,
+      normalizeProductName(externalSkuName),
+      skuCode,
+    ].join('::')
+
+    if (seenKeys.has(uniqueKey)) {
+      throw createHttpError(`第 ${index + 1} 条规则与其它规则重复，请调整匹配条件或内部履约 SKU`, {
+        statusCode: 409,
+        errorCode: 'admin_fulfillment_bindings_duplicate_rule',
+      })
+    }
+
+    seenKeys.add(uniqueKey)
+  }
+}
+
 export async function retryAdminTask(taskId) {
  const task = await getRequiredTask(taskId)
  const now = nowIso()
@@ -934,6 +1082,55 @@ function mapAdminTaskSummary(task, bindingSummary = createEmptyTaskBindingSummar
  }
 }

+function mapAdminFulfillmentBindingConfigItem(item) {
+  const match = item?.match || {}
+  return {
+    provider: String(item?.provider || '').trim(),
+    platform: String(item?.platform || '').trim(),
+    shopId: String(item?.shopId || '').trim(),
+    skuCode: String(item?.skuCode || '').trim(),
+    skuName: String(item?.skuName || '').trim(),
+    profileKey: String(item?.profileKey || '').trim(),
+    enabled: item?.enabled !== false,
+    priority: Number(item?.priority || 100),
+    config: item?.config || {},
+    match: {
+      externalSkuCode: String(match.externalSkuCode || '').trim(),
+      externalItemId: String(match.externalItemId || '').trim(),
+      externalSkuName: String(match.externalSkuName || '').trim(),
+      config: match.config || {},
+    },
+  }
+}
+
+function matchesObservedProduct(binding, observed) {
+  const provider = String(binding?.provider || '').trim()
+  const platform = String(binding?.platform || '').trim()
+  const shopId = String(binding?.shopId || '').trim()
+  const match = binding?.match || {}
+  const externalSkuCode = String(match.externalSkuCode || '').trim()
+  const externalItemId = String(match.externalItemId || '').trim()
+  const externalSkuName = String(match.externalSkuName || '').trim()
+
+  if (provider && provider !== String(observed?.provider || '').trim()) {
+    return false
+  }
+
+  if (platform && platform !== String(observed?.platform || '').trim()) {
+    return false
+  }
+
+  if (shopId && shopId !== String(observed?.shopId || '').trim()) {
+    return false
+  }
+
+  return (
+    (externalSkuCode && externalSkuCode === String(observed?.externalSkuCode || '').trim())
+    || (externalItemId && externalItemId === String(observed?.externalItemId || '').trim())
+    || (externalSkuName && externalSkuName === String(observed?.externalSkuName || '').trim())
+  )
+}
+
 async function mapAdminWebhookEvent(item, { includeRaw = false } = {}) {
  const headers = normalizeRecord(safeParseJson(item.headers_json))
  const query = normalizeRecord(safeParseJson(item.query_json))
@@ -1666,6 +1863,10 @@ function normalizeRecord(value) {
  return value && typeof value === 'object' && !Array.isArray(value) ? value : {}
 }

+function isPlainObject(value) {
+  return Boolean(value) && typeof value === 'object' && !Array.isArray(value)
+}
+
 function extractWebhookPayload(body) {
  const normalizedBody = normalizeRecord(body)
  const rawJson = String(normalizedBody.json || normalizedBody.JSON || '').trim()