WordPress 网站用户账号同步方案详解

<?php
/**
 * WordPress 站点用户同步自定义代码
 * 注意：替换以下配置为你的实际信息
 */

// === 配置项 ===
define('SYNC_TARGET_URL', 'https://目标站点域名/wp-json/wp/v2'); // 目标站点的 REST API 地址
define('SYNC_API_USER', '你的管理员用户名'); // 目标站点的管理员账号
define('SYNC_API_PASS', '你的管理员密码/应用密码'); // 目标站点的应用密码（推荐）

// 1. 用户注册时同步
add_action('user_register', 'sync_new_user_to_another_site', 10, 1);
function sync_new_user_to_another_site($user_id) {
    // 获取新用户数据
    $user = get_user_by('ID', $user_id);
    $user_data = [
        'username' => $user->user_login,
        'email'    => $user->user_email,
        'password' => wp_generate_password(), // 若需同步密码，需特殊处理（不建议明文）
        'role'     => $user->roles[0] ?? 'subscriber'
    ];
    
    // 调用目标站点 API 创建用户
    sync_user_data($user_data);
}

// 2. 用户登录时同步（确保状态一致）
add_action('wp_login', 'sync_user_on_login', 10, 2);
function sync_user_on_login($user_login, $user) {
    $user_data = [
        'username' => $user->user_login,
        'email'    => $user->user_email,
        'role'     => $user->roles[0] ?? 'subscriber'
    ];
    sync_user_data($user_data, 'update'); // 登录时更新用户信息
}

// 3. 核心同步函数（发送数据到目标站点）
function sync_user_data($user_data, $action = 'create') {
    // 验证配置
    if (empty(SYNC_TARGET_URL) || empty(SYNC_API_USER) || empty(SYNC_API_PASS)) {
        error_log('用户同步配置未完成');
        return false;
    }

    // 构建请求参数
    $args = [
        'headers' => [
            'Authorization' => 'Basic ' . base64_encode(SYNC_API_USER . ':' . SYNC_API_PASS),
            'Content-Type'  => 'application/json'
        ],
        'body'    => json_encode($user_data),
        'timeout' => 30,
        'sslverify' => false // 本地测试可关闭，生产环境建议开启
    ];

    // 发送请求
    if ($action === 'create') {
        $response = wp_remote_post(SYNC_TARGET_URL . '/users', $args); // 创建用户
    } else {
        // 更新用户：先查询目标站点是否存在该用户
        $user_exists = wp_remote_get(SYNC_TARGET_URL . '/users?search=' . $user_data['username'], [
            'headers' => $args['headers']
        ]);
        $user_exists_data = json_decode(wp_remote_retrieve_body($user_exists), true);
        if (!empty($user_exists_data[0]['id'])) {
            $response = wp_remote_post(SYNC_TARGET_URL . '/users/' . $user_exists_data[0]['id'], $args); // 更新用户
        } else {
            $response = wp_remote_post(SYNC_TARGET_URL . '/users', $args); // 不存在则创建
        }
    }

    // 检查响应
    if (is_wp_error($response)) {
        error_log('用户同步失败：' . $response->get_error_message());
        return false;
    }
    return true;
}