kknongchang_2506/ThirdParty/Urs/Request/UrsGetUserInfoRequest.php

<?php

namespace ThirdParty\Urs\Request;

use App\Module\ThirdParty\Services\BaseRequest;
use ThirdParty\Urs\Util\CryptoService;

/**
 * URS获取用户信息请求类
 *
 * 专门处理获取用户信息请求，遵循"一个Request类只完成一种请求"的原则
 * 根据用户密钥获取用户ID
 */
class UrsGetUserInfoRequest extends BaseRequest
{
    /**
     * 构造函数
     */
    public function __construct()
    {
        // 使用'urs'作为服务代码，需要在thirdparty_services表中注册
        parent::__construct('urs');
    }

    /**
     * 处理获取用户信息请求
     *
     * @param array $params 请求参数，包含userKey字段
     * @return array 返回包含userId的数组
     * @throws \Exception
     */
    protected function handler(array $params): array
    {
        // 验证必需参数
        if (empty($params['userKey'])) {
            throw new \Exception('userKey参数是必填的');
        }

        // 获取URS配置
        $config = $this->getConfig();
        $apiUrl = $config['api_url'] ?? '';
        $appKey = $config['app_key'] ?? '';
        $ecologyId = $config['ecology_id'] ?? 1;

        if (empty($apiUrl) || empty($appKey)) {
            throw new \Exception('URS配置不完整，缺少api_url或app_key');
        }

        // 构建请求数据
        $requestData = [
            'userKey' => $params['userKey']
        ];

        // 使用URS加密服务加密请求数据
        $cryptoService = new CryptoService($appKey);
        $encryptedData = $cryptoService->encrypt($requestData);

        // 构建完整的API URL
        $fullUrl = rtrim($apiUrl, '/') . "/api/ecology/{$ecologyId}/userInfo";

        // 发送HTTP请求到URS
        $response = $this->sendHttpRequest($fullUrl, $encryptedData);

        // 解密响应数据
        if (isset($response['data'], $response['iv'], $response['timestamp'], $response['sign'])) {
            $decryptedResponse = $cryptoService->decrypt($response);
            
            return [
                'success' => true,
                'message' => '获取用户信息成功',
                'data' => $decryptedResponse,
            ];
        }

        // 如果响应格式不正确，直接返回原始响应
        return [
            'success' => false,
            'message' => '响应格式错误',
            'data' => $response,
        ];
    }

    /**
     * 发送HTTP请求
     *
     * @param string $url 请求URL
     * @param array $data 请求数据
     * @return array
     * @throws \Exception
     */
    protected function sendHttpRequest(string $url, array $data): array
    {
        $ch = curl_init();

        curl_setopt_array($ch, [
            CURLOPT_URL => $url,
            CURLOPT_POST => true,
            CURLOPT_POSTFIELDS => json_encode($data),
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_TIMEOUT => 30,
            CURLOPT_HTTPHEADER => [
                'Content-Type: application/json',
                'User-Agent: KKU-ThirdParty-URS/1.0',
            ],
        ]);

        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        $error = curl_error($ch);

        curl_close($ch);

        if ($error) {
            throw new \Exception("HTTP请求失败: {$error}");
        }

        if ($httpCode !== 200) {
            throw new \Exception("HTTP请求失败，状态码: {$httpCode}");
        }

        $decodedResponse = json_decode($response, true);
        if (json_last_error() !== JSON_ERROR_NONE) {
            throw new \Exception("响应JSON解析失败: " . json_last_error_msg());
        }

        return $decodedResponse;
    }
}