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

$body = [
    "source_url"  =>  $data, // 错误：这里应是外部URL，而非原始数据
    "slug"        =>  "image_test_pimcore",
    "status"      =>  "future",
    "title"       =>  $image_name,
    "media_type"  => "image",
    "mime_type"   =>  $mime_type
];

$options = [
    "headers"      =>  $headers,
    "form_params"  =>  $body, // 错误：form_params用于表单编码数据，而非原始文件内容
];
$result = $this->WPApi->request("POST", "media", $options);

// 假设 $product['priority_web_image']['data'] 包含Base64编码的图片数据
$image_name = $product['priority_web_image']['filename'];
$base64_data = $product['priority_web_image']['data'];

// 解码Base64数据为原始二进制数据
$raw_image_data = base64_decode($base64_data);

if ($raw_image_data === false) {
    // 处理解码失败的情况，例如记录错误或抛出异常
    error_log("Base64 image data decoding failed for: " . $image_name);
    return null;
}

// 获取文件扩展名和MIME类型 (可选，WordPress通常能从文件名推断)
$ext = pathinfo($image_name, PATHINFO_EXTENSION);
if (strtolower($ext) === 'jpg') {
    $ext = 'jpeg'; // 统一处理jpg和jpeg
}
$mime_type = 'image/' . $ext;

use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;

// 假设 $access_token 已通过认证流程获取
// $wordpress_api_url 应是您的WordPress站点URL，例如 'https://your-wordpress-site.com'
$wordpress_api_base_url = 'YOUR_WORDPRESS_SITE_URL';

if (isset($product['priority_web_image'])) {
    $image_name = $product['priority_web_image']['filename'];
    $base64_data = $product['priority_web_image']['data'];

    // 解码Base64数据
    $raw_image_data = base64_decode($base64_data);
    if ($raw_image_data === false) {
        error_log("Base64 decoding failed for image: " . $image_name);
        return null;
    }

    $client = new Client();
    $media_endpoint = $wordpress_api_base_url . '/wp-json/wp/v2/media/';

    try {
        $response = $client->request('POST', $media_endpoint, [
            'headers' => [
                'Authorization' => 'Bearer ' . $access_token,
                // Content-Disposition 头部至关重要，它告诉WordPress文件的名称
                'Content-Disposition' => 'attachment; filename="' . $image_name . '"',
                // Content-Type 头部可选，WordPress通常能从文件名推断
                // 'Content-Type' => $mime_type,
            ],
            'body' => $raw_image_data, // 将原始二进制数据作为请求体发送
            // 您还可以添加其他元数据，例如标题、描述等，但这些通常在图片上传成功后通过PUT请求更新
            // 或者，如果您需要一次性发送，可以考虑使用 multipart/form-data，但对于原始数据上传，直接body更简单
        ]);

        $bodyAry = json_decode($response->getBody()->getContents(), true);
        // 打印或处理API响应，其中包含上传图片的ID、URL等信息
        // echo print_r($bodyAry, true);
        return $bodyAry;

    } catch (RequestException $e) {
        // 处理Guzzle HTTP请求错误
        error_log('Guzzle Error: ' . $e->getMessage());
        if ($e->hasResponse()) {
            error_log('Guzzle Response: ' . $e->getResponse()->getBody()->getContents());
        }
        return null;
    }
}

// 假设 $access_token 已通过认证流程获取
// $wordpress_api_url 应是您的WordPress站点URL，例如 'https://your-wordpress-site.com'
$wordpress_api_base_url = 'YOUR_WORDPRESS_SITE_URL';

if (isset($product['priority_web_image'])) {
    $image_name = $product['priority_web_image']['filename'];
    $base64_data = $product['priority_web_image']['data'];

    // 解码Base64数据
    $raw_image_data = base64_decode($base64_data);
    if ($raw_image_data === false) {
        error_log("Base64 decoding failed for image: " . $image_name);
        return null;
    }

    // 将原始二进制数据写入临时文件
    $temp_filepath = sys_get_temp_dir() . '/' . uniqid() . '_' . $image_name;
    file_put_contents($temp_filepath, $raw_image_data);

    // 确保临时文件存在
    if (!file_exists($temp_filepath)) {
        error_log("Failed to create temporary file: " . $temp_filepath);
        return null;
    }

    // 读取临时文件的内容，作为cURL请求的主体
    $file_content_for_curl = file_get_contents($temp_filepath);

    $ch = curl_init();
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); // 返回响应内容而不是直接输出
    curl_setopt($ch, CURLOPT_URL, $wordpress_api_base_url . '/wp-json/wp/v2/media/');
    curl_setopt($ch, CURLOPT_POST, 1); // 设置为POST请求
    curl_setopt($ch, CURLOPT_POSTFIELDS, $file_content_for_curl); // 将文件内容作为请求主体

    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        "Content-Disposition: attachment; filename=\"$image_name\"", // 关键头部，指定文件名
        'Authorization: Bearer ' . $access_token, // 认证头部
        // 'Content-Type: ' . $mime_type, // 可选头部，指定MIME类型
    ]);

    $result = curl_exec($ch);
    $curl_error = curl_error($ch);
    $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);

    // 清理临时文件
    unlink($temp_filepath);

    if ($curl_error) {
        error_log("cURL Error: " . $curl_error);
        return null;
    }

    if ($http_code >= 400) {
        error_log("API returned HTTP error " . $http_code . ": " . $result);
        return null;
    }

    $api_response = json_decode($result, true);
    // echo print_r($api_response, true);
    return $api_response;
}