通过REST API同步SQL与WooCommerce时产品价格更新异常

问题现象 #

• Node.js同步服务器返回HTTP 200成功日志，但WooCommerce后台存在以下异常：
  • 部分产品的价格/名称修改未实际保存
  • 部分新建产品状态异常
  • 产品偶尔恢复到之前的状态
  • 无错误日志记录

日志证据 #

2025-04-04T08:57:53.552Z [INFO]: Updated product O-GOSGP6XXZ05 (ID: 58597)
2025-04-04T08:57:54.018Z [DEBUG]: Updated product: Netzbuchsen Lötarbeiten (ID: 62082)
2025-04-04T08:57:54.871Z [INFO]: Updated product O-MOSMGXXXG4 (ID: 31218) 
2025-04-04T08:57:55.391Z [DEBUG]: Updated product: Austausch Display-LCD/LED-Einheit (ID: 30612)

当前同步流程 #

1. 从MySQL获取产品数据
2. 与WooCommerce现有产品对比
3. 通过WooCommerce REST API批量更新/创建
4. 记录成功日志

核心代码片段 #

syncService.js（同步逻辑） #

async function syncProducts() {
  try {
    // 1. Fetch products from both sources
    const sqlProducts = await fetchProducts(); // From SQL
    const wooProducts = await fetchWooCommerceProducts(); // From WooCommerce

    // 2. Compare products
    const { newProducts, updatedProducts } = compareProducts(sqlProducts, wooProducts);

    // 3. Process new products
    for (const product of newProducts) {
      await createWooCommerceProduct({
        name: `${product.device_name} - ${product.repair_type}`,
        sku: product.sku,
        regular_price: product.price.toString(),
        stock_quantity: 10
      });
    }

    // 4. Process updates
    for (const product of updatedProducts) {
      await updateWooCommerceProduct(product.wooId, {
        name: product.repair_type,
        regular_price: product.price.toString()
      });
    }

  } catch (err) {
    logger.error('Sync failed', {
      error: err.message,
      response: err.response?.data
    });
  }
}

wooService.js（API客户端） #

const wooCommerce = axios.create({
  baseURL: `${process.env.WOOCOMMERCE_URL}/wp-json/wc/v3`,
  auth: {
    username: process.env.WOOCOMMERCE_CONSUMER_KEY,
    password: process.env.WOOCOMMERCE_CONSUMER_SECRET
  }
});

// Rate limited to 90 requests/minute
const limiter = new Bottleneck({
  minTime: 60000 / 90
});

async function updateWooCommerceProduct(productId, product) {
  const response = await limiter.schedule(() => 
    wooCommerce.put(`/products/${productId}`, product)
  );
  return response.data;
}

排查与解决方案 #

1. 校验API响应数据一致性 #

当前代码仅判断请求返回200，但未验证返回的产品数据是否与提交的修改一致。WooCommerce API可能因字段校验、插件拦截等原因，返回成功但未实际应用修改。

修复代码：
在updateWooCommerceProduct中添加字段校验逻辑：

async function updateWooCommerceProduct(productId, product) {
  const response = await limiter.schedule(() => 
    wooCommerce.put(`/products/${productId}`, product)
  );
  const returnedProduct = response.data;
  
  // 校验名称是否生效
  if (product.name && returnedProduct.name !== product.name) {
    logger.warn('名称更新未生效', {
      productId,
      提交值: product.name,
      返回值: returnedProduct.name
    });
  }
  // 校验价格是否生效
  if (product.regular_price && returnedProduct.regular_price !== product.regular_price) {
    logger.warn('价格更新未生效', {
      productId,
      提交值: product.regular_price,
      返回值: returnedProduct.regular_price
    });
  }
  return returnedProduct;
}

2. 明确指定产品状态 #

新建产品未设置状态时，默认可能为草稿；更新时若产品处于草稿/私有状态，修改可能不会正常显示或被重置。

修复代码：
创建和更新产品时添加status: 'publish'字段：

// 创建产品
await createWooCommerceProduct({
  name: `${product.device_name} - ${product.repair_type}`,
  sku: product.sku,
  regular_price: product.price.toString(),
  stock_quantity: 10,
  status: 'publish' // 新增状态字段
});

// 更新产品
await updateWooCommerceProduct(product.wooId, {
  name: product.repair_type,
  regular_price: product.price.toString(),
  status: 'publish' // 新增状态字段
});

3. 避免并发同步冲突 #

若存在多进程/多实例同时执行同步，可能导致产品数据被覆盖；WooCommerce缓存也可能延迟更新显示旧数据。

修复方法：

1. 添加同步锁防止并发执行：

let isSyncing = false;
async function syncProducts() {
  if (isSyncing) {
    logger.info('同步已在进行中，跳过本次执行');
    return;
  }
  isSyncing = true;
  try {
    // 原有同步逻辑
  } finally {
    isSyncing = false;
  }
}

2. 更新后触发缓存刷新（针对使用缓存插件的场景）：

// 更新产品后添加缓存刷新请求
await wooCommerce.post(`/products/${productId}/batch`, {
  update: [{ id: productId }]
});

4. 优化产品对比逻辑 #

对比逻辑可能存在SKU匹配不精确、字段差异判断错误的问题，导致无效更新或遗漏更新。

修复代码：

function compareProducts(sqlProducts, wooProducts) {
  const wooSkuMap = new Map(wooProducts.map(p => [p.sku.toLowerCase().trim(), p]));
  const newProducts = [];
  const updatedProducts = [];

  for (const sqlProd of sqlProducts) {
    const trimmedSku = sqlProd.sku.toLowerCase().trim();
    const wooProd = wooSkuMap.get(trimmedSku);
    if (!wooProd) {
      newProducts.push(sqlProd);
    } else {
      // 精确对比需要更新的字段
      const nameMatches = sqlProd.repair_type === wooProd.name;
      const priceMatches = sqlProd.price.toString() === wooProd.regular_price;
      if (!nameMatches || !priceMatches) {
        updatedProducts.push({
          wooId: wooProd.id,
          repair_type: sqlProd.repair_type,
          price: sqlProd.price
        });
      }
    }
  }
  return { newProducts, updatedProducts };
}

5. 排查第三方插件与权限问题 #

• 确认API密钥拥有write_products权限
• 临时禁用产品相关插件（如价格保护、库存管理插件），测试同步是否正常
• 用Postman手动调用相同API请求，验证返回结果是否符合预期

内容的提问来源于stack exchange，提问作者Navitank