<?php

namespace ThirdParty\Urs\Request;

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

/**
 * URS获取用户下级统计请求类
 *
 * 专门处理获取用户下级统计请求，遵循"一个Request类只完成一种请求"的原则
 * 获取用户下级人数统计（支持1级和3级）
 */
class UrsGetUserLevelCountRequest extends BaseRequest
{
    /**
     * 构造函数
     */
    public function __construct()
    {
        // 使用'urs'作为服务代码，需要在thirdparty_services表中注册
        parent::__construct('urs');
    }

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

        if (!isset($params['level']) || !in_array($params['level'], [1, 3])) {
            throw new \Exception('level参数必须是1或3');
        }

        // 获取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 = [
            'userId' => (int)$params['userId'],
            'level' => (int)$params['level']
        ];

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

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

        // 发送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;
    }
}