WordPress REST API 上传原始图片数据并避免空白媒体库问题

if (isset($product['priority_web_image'])) {
    $image_name = $product['priority_web_image']['filename'];
    $data = $product['priority_web_image']['data']; // 假设这是原始图片数据，可能是base64编码
    $ext = substr($image_name, strpos($image_name, ".") + 1);
    if ($ext == 'jpg') {
        $ext = 'jpeg';
    }
    $mime_type = 'image/'.$ext;

    $headers = [
        'Authorization' => 'Bearer '.$result_auth->access_token,
        "cache-control" => "no-cache",
        "Content-Type"  =>  $mime_type, // 看起来正确
        "Content-Disposition" => "attachement;filename=".$image_name, // 看起来正确
    ];

    $body = [
        "source_url"  =>  $data, // 问题所在：将原始数据作为表单参数
        "slug"        =>  "image_test_pimcore",
        "status"      =>  "future",
        "title"       =>  $image_name,
        "media_type"  => "image",
        "mime_type"   =>  $mime_type
    ];

    $options = [
        "headers"      =>  $headers,
        "form_params"  =>  $body, // Guzzle会将此转换为x-www-form-urlencoded或multipart/form-data
    ];
    // ... 发送请求
}

<?php

/**
 * 上传原始图片数据到WordPress媒体库
 *
 * @param string $base64_data 图片的base64编码数据
 * @param string $image_name 原始文件名（包含扩展名）
 * @param string $access_token WordPress认证Bearer Token
 * @param string $wp_api_url WordPress站点API基础URL (e.g., 'https://your-wordpress-site.com')
 * @return object|null API响应对象或null
 */
function uploadImageToWordPress(string $base64_data, string $image_name, string $access_token, string $wp_api_url)
{
    // 1. 创建临时文件存储图片原始数据
    // 这是一个关键步骤，因为cURL通常需要从文件路径读取内容，
    // 或者直接将原始二进制数据作为POSTFIELDS。
    // 如果$base64_data已经是原始二进制，可以跳过base64_decode。
    // 这里假设$base64_data是base64编码的。
    $temp_dir = sys_get_temp_dir();
    $filepath = $temp_dir . '/' . uniqid('wp_image_') . '_' . $image_name;

    // 确保目录可写
    if (!is_writable($temp_dir)) {
        error_log("Temporary directory not writable: " . $temp_dir);
        return null;
    }

    // 将base64解码后的数据写入临时文件
    $decoded_data = base64_decode($base64_data);
    if ($decoded_data === false) {
        error_log("Failed to decode base64 data for image: " . $image_name);
        return null;
    }

    if (file_put_contents($filepath, $decoded_data) === false) {
        error_log("Failed to write image data to temporary file: " . $filepath);
        return null;
    }

    // 确保临时文件存在
    if (!file_exists($filepath)) {
        error_log("Temporary image file does not exist after creation: " . $filepath);
        return null;
    }

    // 2. 读取文件内容以准备上传
    $file_content = file_get_contents($filepath);
    if ($file_content === false) {
        error_log("Failed to read content from temporary file: " . $filepath);
        // 清理临时文件
        unlink($filepath);
        return null;
    }

    // 3. 构建cURL请求
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); // 返回响应内容而不是直接输出
    curl_setopt($ch, CURLOPT_URL, $wp_api_url . '/wp-json/wp/v2/media/'); // WordPress媒体API端点
    curl_setopt($ch, CURLOPT_POST, 1); // 设置为POST请求
    curl_setopt($ch, CURLOPT_POSTFIELDS, $file_content); // 关键：直接将文件内容作为请求体

    // 设置HTTP头
    // Content-Disposition 头是必须的，用于告知API文件名
    // Authorization 头用于认证
    // Content-Type 头可以根据文件扩展名自动推断，或者明确指定
    $headers = [
        "Content-Disposition: attachment; filename=\"$image_name\"",
        'Authorization: Bearer ' . $access_token,
        // 如果需要，可以明确设置Content-Type，例如：
        // "Content-Type: " . mime_content_type($filepath),
    ];
    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);

    // 4. 执行cURL请求并处理响应
    $result = curl_exec($ch);
    $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);

    if (curl_errno($ch)) {
        error_log('cURL Error: ' . curl_error($ch));
        $api_response = null;
    } else {
        $api_response = json_decode($result);
        if ($http_code >= 400) {
            error_log("WordPress API Error (HTTP $http_code): " . ($result ?? 'No response body'));
            // 可以进一步解析$api_response来获取详细错误信息
        }
    }

    curl_close($ch);

    // 5. 清理临时文件
    unlink($filepath);

    return $api_response;
}

// 示例用法：
// $product_image_data = [
//     'filename' => 'my_product_image.jpg',
//     'data' => 'iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAQAAAC1HAwCAAAAC0lEQVR42mNkYAAAAAYAAjCB0C8AAAAASUVORK5CYII=' // 示例base64编码的1x1像素透明GIF
// ];
// $auth_token = 'YOUR_BEARER_TOKEN';
// $wp_site_url = 'https://your-wordpress-site.com';

// if (isset($product_image_data)) {
//     $image_name_to_upload = $product_image_data['filename'];
//     $raw_image_data_base64 = $product_image_data['data'];

//     $response = uploadImageToWordPress($raw_image_data_base64, $image_name_to_upload, $auth_token, $wp_site_url);

//     if ($response && isset($response->id)) {
//         echo "图片上传成功！媒体ID: " . $response->id . "\n";
//         echo "图片URL: " . $response->source_url . "\n";
//     } else {
//         echo "图片上传失败。\n";
//         print_r($response);
//     }
// }
?>

<?php
use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;

/**
 * 使用Guzzle上传原始图片数据到WordPress媒体库
 *
 * @param string $base64_data 图片的base64编码数据
 * @param string $image_name 原始文件名（包含扩展名）
 * @param string $access_token WordPress认证Bearer Token
 * @param string $wp_api_url WordPress站点API基础URL (e.g., 'https://your-wordpress-site.com')
 * @return object|null API响应对象或null
 */
function uploadImageWithGuzzle(string $base64_data, string $image_name, string $access_token, string $wp_api_url)
{
    $client = new Client();
    $temp_dir = sys_get_temp_dir();
    $filepath = $temp_dir . '/' . uniqid('wp_image_') . '_' . $image_name;

    $decoded_data = base64_decode($base64_data);
    if ($decoded_data === false || file_put_contents($filepath, $decoded_data) === false) {
        error_log("Failed to prepare image data for Guzzle upload: " . $image_name);
        return null;
    }

    try {
        $response = $client->request('POST', $wp_api_url . '/wp-json/wp/v2/media/', [
            'headers' => [
                'Authorization'     => 'Bearer ' . $access_token,
                'Content-Disposition' => 'attachment; filename="' . $image_name . '"',
                // Guzzle通常会根据'body'的内容自动设置Content-Type，
                // 但如果需要明确，可以添加 'Content-Type' => mime_content_type($filepath),
            ],
            'body' => fopen($filepath, 'r'), // 关键：使用fopen将文件流作为请求体
            // 或者直接使用字符串：'body' => $decoded_data, 但对于大文件不推荐
        ]);

        $api_response = json_decode($response->getBody()->getContents());
        return $api_response;

    } catch (RequestException $e) {
        error_log("Guzzle Request Error: " . $e->getMessage());
        if ($e->hasResponse()) {
            error_log("Guzzle Response: " . $e->getResponse()->getBody()->getContents());
        }
        return null;
    } finally {
        // 清理临时文件
        if (file_exists($filepath)) {
            unlink($filepath);
        }
    }
}

// 示例用法与cURL类似
// require 'vendor/autoload.php'; // 如果使用Composer
// $product_image_data = [
//     'filename' => 'guzzle_test_image.jpg',
//     'data' => 'iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAQAAAC1HAwCAAAAC0lEQVR42mNkYAAAAAYAAjCB0C8AAAAASUVORK5CYII='
// ];
// $auth_token = 'YOUR_BEARER_TOKEN';
// $wp_site_url = 'https://your-wordpress-site.com';

// if (isset($product_image_data)) {
//     $image_name_to_upload = $product_image_data['filename'];
//     $raw_image_data_base64 = $product_image_data['data'];

//     $response = uploadImageWithGuzzle($raw_image_data_base64, $image_name_to_upload, $auth_token, $wp_site_url);

//     if ($response && isset($response->id)) {
//         echo "Guzzle 图片上传成功！媒体ID: " . $response->id . "\n";
//         echo "Guzzle 图片URL: " . $response->source_url . "\n";
//     } else {
//         echo "Guzzle 图片上传失败。\n";
//         print_r($response);
//     }
// }
?>