kknongchang_2506/app/Module/ThirdParty/Services/BaseRequest.php

<?php

namespace App\Module\ThirdParty\Services;

use App\Module\ThirdParty\Models\ThirdPartyService as ServiceModel;
use App\Module\ThirdParty\Models\ThirdPartyCredential;
use App\Module\ThirdParty\Models\ThirdPartyLog;
use App\Module\ThirdParty\Models\ThirdPartyQuota;
use App\Module\ThirdParty\Enums\SERVICE_STATUS;
use App\Module\ThirdParty\Enums\LOG_LEVEL;
use Illuminate\Support\Facades\Http;
use Illuminate\Support\Facades\Cache;
use Illuminate\Http\Client\Response;

/**
 * 第三方请求基类
 *
 * 抽象化请求概念，不局限于HTTP请求，扩展到调用包的请求方法
 * 基类处理配置读取、配额管理、日志记录等通用功能
 */
abstract class BaseRequest
{
    /**
     * 服务代码
     */
    protected string $serviceCode;

    /**
     * 服务配置
     */
    protected ?ServiceModel $service = null;

    /**
     * 认证凭证
     */
    protected ?ThirdPartyCredential $credential = null;

    /**
     * 请求ID
     */
    protected string $requestId;

    /**
     * 开始时间
     */
    protected float $startTime;

    /**
     * 构造函数
     *
     * @param string $serviceCode 服务代码
     */
    public function __construct(string $serviceCode)
    {
        $this->serviceCode = $serviceCode;
        $this->requestId = uniqid('req_', true);
        $this->startTime = microtime(true);

        // 初始化服务配置
        $this->initializeService();
    }

    /**
     * 初始化服务配置
     *
     * @throws \Exception
     */
    protected function initializeService(): void
    {
        $this->service = ServiceModel::where('code', $this->serviceCode)->first();

        if (!$this->service) {
            throw new \Exception("服务 {$this->serviceCode} 不存在");
        }

        if (!$this->service->canCallApi()) {
            throw new \Exception("服务 {$this->serviceCode} 当前不可用，状态：{$this->service->getStatusLabel()}");
        }

        // 获取认证凭证
        $this->credential = $this->service->getActiveCredential();
        if (!$this->credential) {
            throw new \Exception("服务 {$this->serviceCode} 没有可用的认证凭证");
        }
    }

    /**
     * 执行请求
     *
     * @param array $params 请求参数
     * @return array
     * @throws \Exception
     */
    public function request(array $params = []): array
    {
        // 检查配额
        if (!$this->checkQuota()) {
            throw new \Exception("服务 {$this->serviceCode} 配额已用完");
        }

        try {
            // 执行具体的请求逻辑
            $result = $this->handler($params);

            // 记录成功日志
            $this->logRequest($params, $result, true);

            // 更新配额
            $this->updateQuota();

            // 更新凭证使用统计
            $this->credential->updateUsageStats();

            return $result;

        } catch (\Exception $e) {
            // 记录失败日志
            $this->logRequest($params, ['error' => $e->getMessage()], false);

            throw $e;
        }
    }

    /**
     * 具体的请求处理逻辑（由子类实现）
     *
     * @param array $params 请求参数
     * @return array
     */
    abstract protected function handler(array $params): array;


    /**
     * 检查配额
     *
     * @return bool
     */
    protected function checkQuota(): bool
    {
        return QuotaService::checkQuota($this->service);
    }

    /**
     * 更新配额
     */
    protected function updateQuota(): void
    {
        QuotaService::updateQuota($this->service);
    }

    /**
     * 记录请求日志
     *
     * @param array $params 请求参数
     * @param array $result 响应结果
     * @param bool $success 是否成功
     */
    protected function logRequest(array $params, array $result, bool $success): void
    {
        $responseTime = (int)((microtime(true) - $this->startTime) * 1000);

        ThirdPartyLog::create([
            'service_id' => $this->service->id,
            'credential_id' => $this->credential->id,
            'request_id' => $this->requestId,
            'method' => 'PACKAGE_CALL',
            'url' => $this->serviceCode,
            'request_headers' => json_encode([]),
            'request_body' => json_encode($params),
            'response_status' => $success ? 200 : 500,
            'response_headers' => json_encode([]),
            'response_body' => json_encode($result),
            'response_time' => $responseTime,
            'success' => $success,
            'error_message' => $success ? null : ($result['error'] ?? '未知错误'),
            'level' => $success ? LOG_LEVEL::INFO->value : LOG_LEVEL::ERROR->value,
            'ip_address' => request()->ip(),
            'user_agent' => request()->userAgent(),
            'called_at' => now(),
        ]);
    }

    /**
     * 获取服务配置
     *
     * @param string|null $key 配置键名，为空则返回全部配置
     * @return mixed
     */
    protected function getConfig(?string $key = null)
    {
        $config = $this->service->config ?? [];

        if ($key === null) {
            return $config;
        }

        return $config[$key] ?? null;
    }

    /**
     * 获取服务信息
     *
     * @return ServiceModel
     */
    protected function getService(): ServiceModel
    {
        return $this->service;
    }

    /**
     * 获取认证凭证
     *
     * @return ThirdPartyCredential
     */
    protected function getCredential(): ThirdPartyCredential
    {
        return $this->credential;
    }

    /**
     * 获取请求ID
     *
     * @return string
     */
    protected function getRequestId(): string
    {
        return $this->requestId;
    }
}