/**
 * 写入密钥到Consul KV
 * API地址：/v1/kv/
 * @param string $k 密钥键名
 * @param string $v 密钥原始值
 * @return bool 写入成功返回true，失败返回false
 */
public function putKVsecret(string $k, string $v): bool
{
    try {
        // 1. 读取Consul基础配置（从框架配置文件获取）
        $baseUri = Config::get('consul.base_uri'); // Consul集群地址（如http://127.0.0.1:8500）
        $kvPoint = Config::get('consul.put_kv');   // KV写入端点前缀（如v1/kv/）
        $token = Config::get('consul.token');      // ACL鉴权令牌（无ACL可省略）

        // 2. 加密密钥值 + 编码键名（避免特殊字符导致的请求异常）
        $encryptedValue = $this->encryptSecret($v); // 自定义加密方法（如SM2国密加密）
        $encodedKey = rawurlencode($k);
        $url = rtrim($baseUri, '/') . '/' . ltrim($kvPoint, '/') . $encodedKey;

        // 3. 发起PUT请求写入Consul（使用Guzzle客户端）
        $client = new Client();
        $response = $client->put($url, [
            'headers' => [
                'Content-Type' => 'text/plain',
                'X-Consul-Token' => $token // 携带ACL令牌鉴权
            ],
            'body' => $encryptedValue,
            'verify' => false, // 生产环境需开启TLS验证，设为证书文件路径（如'/etc/ssl/consul.crt'）
        ]);

        // 4. 校验响应状态与结果
        $statusCode = $response->getStatusCode();
        if ($statusCode !== 200) {
            $responseBody = $response->getBody()->getContents();
            Log::channel("consul")->error(
                "Consul KV写入失败（状态码：{$statusCode}）：{$responseBody}"
            );
            return false;
        }

        $responseBody = $response->getBody()->getContents();
        try {
            $result = json_decode($responseBody, true, 512, JSON_THROW_ON_ERROR);
        } catch (JsonException $e) {
            Log::channel("consul")->error(
                "Consul响应JSON解析失败：{$e->getMessage()}，原始响应：{$responseBody}"
            );
            return false;
        }

        if ($result !== true) {
            Log::channel("consul")->error(
                "Consul返回非预期结果：" . json_encode($result, JSON_UNESCAPED_UNICODE)
            );
            return false;
        }

        return true;

    } catch (\Exception $e) {
        Log::channel("consul")->error(
            "[Consul KV] 写入失败（key: {$k}）：{$e->getMessage()}"
        );
        return false;
    }
}

/**
 * SM2国密加密私有方法
 * @param string $v 待加密的密钥原始值
 * @return string 加密后的字符串
 */
private function encryptSecret(string $v)
{
    $sm2VJson = sm2Encrypt($v)->getContent();
    $sm2 = json_decode($sm2VJson, true);
    return $sm2['data']['e_msg'];
}

<?php
// 应用公共文件
use Rtgm\sm\RtSm2;
use think\facade\Config;
use think\response\Json;

/**
 * SM2加密函数
 * @param string $msg 需要加密的内容
 * @return Json 返回JSON响应
 */
function sm2Encrypt(string $msg): Json
{
    $sm2 = new RtSm2();
    $public_key = Config::get("sm2.publickey");
    $encrypted = $sm2->doEncrypt($msg, $public_key);
    
    if (empty($encrypted)) {
        throw new \Exception("加密结果为空");
    }
    
    return Json([
        'code'  => 200,
        'data'  => [
            'e_msg' => $encrypted,
            'msg'   => "加密成功"
        ]
    ]);
}

/**
 * SM2解密函数
 * @param string $e_msg 需要解密的内容
 * @return Json 返回JSON响应
 */
function sm2Decrypt(string $e_msg): Json
{
    $sm2 = new RtSm2();
    $private_key = Config::get("sm2.privatekey");
    $decrypted = $sm2->doDecrypt($e_msg, $private_key);
    return Json([
        'code'  => 200,
        'data'  => [
            'e_msg' => $decrypted,
            'msg'   => "解密成功"
        ]
    ]);
}

/**
 * 从Consul KV读取密钥
 * @param string $k 密钥键名
 * @param string|null $token 自定义ACL令牌（优先使用，无则用配置中的令牌）
 * @return false|string 读取成功返回密钥原始值，失败返回false
 */
public function getKVsecret(string $k, ?string $token = null)
{
    try {
        // 1. 读取Consul基础配置并确定鉴权令牌
        $baseUri = Config::get('consul.base_uri');
        $kvPoint = Config::get('consul.get_kv');
        $configToken = Config::get('consul.token');
        $useToken = $token ?? $configToken;

        // 2. 校验基础配置完整性
        if (empty($baseUri) || empty($kvPoint)) {
            Log::channel("consul")->error("Consul配置不完整（base_uri或get_kv缺失）");
            return false;
        }

        // 3. 编码键名 + 拼接请求地址（?raw=1：直接返回原始值，不包含元数据）
        $encodedKey = rawurlencode($k);
        $url = rtrim($baseUri, '/') . '/' . ltrim($kvPoint, '/') . $encodedKey;
        $url .= '?raw=1';

        // 4. 发起GET请求读取Consul
        $client = new Client();
        $response = $client->get($url, [
            'headers' => [
                'X-Consul-Token' => $useToken, // 携带ACL令牌鉴权
                'Accept' => 'text/plain',
            ],
            'verify' => false, // 生产环境需开启TLS验证，设为证书文件路径
        ]);

        // 5. 校验响应状态与加密值
        $statusCode = $response->getStatusCode();
        if ($statusCode === 404) {
            Log::channel("consul")->error("Consul KV键不存在（key: {$k}）");
            return false;
        }
        if ($statusCode !== 200) {
            $responseBody = $response->getBody()->getContents();
            Log::channel("consul")->error("Consul KV获取失败（key: {$k}，状态码：{$statusCode}）：{$responseBody}");
            return false;
        }

        // 6. 解密并解析原始值
        $encryptedValue = trim($response->getBody()->getContents());
        Log::channel("consul")->info("从Consul读取的原始加密值（key: {$k}）：{$encryptedValue}");

        if (empty($encryptedValue)) {
            Log::channel("consul")->error("Consul返回的加密值为空（key: {$k}）");
            return false;
        }

        // 调用SM2国密解密接口（根据实际加密算法调整）
        $decryptJson = sm2Decrypt($encryptedValue)->getContent();
        Log::channel("consul")->info("sm2Decrypt返回的JSON：{$decryptJson}");

        $decryptData = json_decode($decryptJson, true);
        if (json_last_error() !== JSON_ERROR_NONE) {
            Log::channel("consul")->error("解密响应JSON解析失败（key: {$k}）：" . json_last_error_msg());
            return false;
        }

        // 校验解密结果格式（根据实际解密接口返回调整）
        if (!isset($decryptData['code']) || $decryptData['code'] !== 200 || empty($decryptData['data']['e_msg'])) {
            Log::channel("consul")->error("解密结果无效（key: {$k}）：" . json_encode($decryptData));
            return false;
        }

        $originalValue = $decryptData['data']['e_msg'];
        Log::channel("consul")->info("解密成功，原始值（key: {$k}）：{$originalValue}");
        return $originalValue;

    } catch (GuzzleException $e) {
        Log::channel("consul")->error("[Consul KV] 获取失败（key: {$k}）：{$e->getMessage()}");
        return false;
    } catch (JsonException $e) {
        Log::channel("consul")->error("[Consul KV] 响应解析失败（key: {$k}）：{$e->getMessage()}");
        return false;
    } catch (\Exception $e) {
        Log::channel("consul")->error("[Consul KV] 获取异常（key: {$k}）：{$e->getMessage()}");
        return false;
    }
}

/**
 * 邮箱服务类构造方法
 */
function __construct()
{
    $this->consul = new ConsulUtils(); // 实例化Consul工具类
    $this->emailer = new PHPMailer(true); 

    // 配置邮箱基础参数（非敏感参数可从框架配置读取）
    $this->emailer->isSMTP();                    
    $this->emailer->Host = Config::get("email.host");  
    $this->emailer->SMTPAuth = true;                 
    $this->emailer->Username = Config::get("email.send_user");   
    // 从Consul动态读取邮箱密码（敏感参数）
    $this->emailer->Password = $this->consul->getKVsecret("EmailPassword");     
    $this->emailer->SMTPSecure = Config::get("email.encryption");  
    $this->emailer->Port = Config::get("email.port");          
    $this->emailer->CharSet = 'UTF-8';                  
    $this->emailer->SMTPAutoTLS = true;                  
}