如何正确同步WooCommerce产品变体到自定义数据库表？

1. 正确遍历父产品的变体 #

要捕获变体，必须先通过WooCommerce官方API获取可变产品的所有变体ID，再逐个实例化变体对象，避免和父产品逻辑混淆：

• 先筛选出所有variable类型的产品
• 用get_children()方法获取当前父产品的所有变体ID列表
• 循环每个变体ID，通过wc_get_product()实例化WC_Product_Variation对象

2. 正确提取变体核心字段 #

变体对象本身的ID就是variation_id，关联父产品ID用get_parent_id()获取，价格和SKU直接调用变体专属方法：

• 变体ID：$variation->get_id()
• 父产品ID：$variation->get_parent_id()
• 常规价格：$variation->get_regular_price()
• 促销价格：$variation->get_sale_price()
• SKU：$variation->get_sku()

3. 数据库插入/更新的正确逻辑 #

以product_id + variation_id作为唯一标识，先检查记录是否存在，存在则更新，不存在则插入，同时用wpdb->prepare()防止SQL注入：

function sync_product_price_history() {
    global $wpdb;
    $table_name = $wpdb->prefix . 'product_price_history'; // 替换为你的自定义表名

    // 1. 先处理价格历史移位（将day_1→day_2，day_2→day_3...day_29→day_30）
    $shift_query = "UPDATE $table_name SET ";
    for ($i = 29; $i >= 1; $i--) {
        $shift_query .= "day_{$i}_sale = day_" . ($i - 1) . "_sale, day_{$i} = day_" . ($i - 1) . ", ";
    }
    $shift_query = rtrim($shift_query, ', ') . ";";
    $wpdb->query($shift_query);

    // 2. 获取所有可变产品
    $variable_products = wc_get_products([
        'type' => 'variable',
        'limit' => -1,
        'status' => 'publish'
    ]);

    foreach ($variable_products as $parent_product) {
        $parent_id = $parent_product->get_id();

        // 同步父产品（variation_id设为0标识父产品）
        $parent_data = [
            'product_id' => $parent_id,
            'variation_id' => 0,
            'sku' => $parent_product->get_sku() ?: '',
            'day_1' => $parent_product->get_regular_price(),
            'day_1_sale' => $parent_product->get_sale_price() ?: 0
        ];
        $wpdb->replace(
            $table_name,
            $parent_data,
            ['%d', '%d', '%s', '%f', '%f'] // 对应字段格式，需与表结构匹配
        );

        // 3. 同步所有变体
        $variation_ids = $parent_product->get_children();
        foreach ($variation_ids as $variation_id) {
            $variation = wc_get_product($variation_id);
            if (!$variation instanceof WC_Product_Variation) continue;

            $variation_data = [
                'product_id' => $parent_id,
                'variation_id' => $variation_id, // 这里传入正确的变体ID
                'sku' => $variation->get_sku() ?: '',
                'day_1' => $variation->get_regular_price(),
                'day_1_sale' => $variation->get_sale_price() ?: 0
            ];

            // 用replace简化存在则更新、不存在则插入的逻辑
            $wpdb->replace(
                $table_name,
                $variation_data,
                ['%d', '%d', '%s', '%f', '%f']
            );
        }
    }
}
// 绑定到WP每日定时任务
add_action('wp_daily', 'sync_product_price_history');

4. 常见错误排查 #

• 确保自定义表的variation_id字段类型为BIGINT(20)，允许存储非零值（父产品用0标识）
• 不要直接用父产品的get_id()替代变体ID，必须从变体对象中获取
• 检查是否过滤了publish状态的产品，避免同步草稿或 trash 状态的无效变体

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