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

<?php

namespace App\Module\ThirdParty\Services;

use Illuminate\Http\Request;
use Illuminate\Support\Facades\Log;
use App\Module\ThirdParty\Models\ThirdPartyService as ServiceModel;

/**
 * Webhook分发服务
 * 
 * 负责将Webhook请求分发到对应的第三方包处理器
 * 支持ThirdParty命名空间下的包注册和管理
 */
class WebhookDispatchService
{
    /**
     * 已注册的包处理器映射
     * 格式：['包名' => ['路由' => '处理器类名']]
     *
     * @var array
     */
    protected static array $packageHandlers = [];
    
    /**
     * 分发Webhook请求到指定包的处理器
     *
     * @param string $packageName 包名
     * @param string $handlerRoute Handler路由
     * @param Request $request 请求对象
     * @return array
     * @throws \Exception
     */
    public function dispatch(string $packageName, string $handlerRoute, Request $request): array
    {
        // 只支持POST请求
        if ($request->method() !== 'POST') {
            throw new \Exception("Webhook只支持POST请求，当前方法: {$request->method()}");
        }

        // 获取处理器类
        $handlerClass = $this->getPackageHandler($packageName, $handlerRoute);

        if (!$handlerClass) {
            throw new \Exception("包 {$packageName} 的处理器 {$handlerRoute} 不存在");
        }

        // 检查处理器类是否存在
        if (!class_exists($handlerClass)) {
            throw new \Exception("处理器类 {$handlerClass} 不存在");
        }

        // 检查处理器是否继承自BaseWebhook
        if (!is_subclass_of($handlerClass, BaseWebhook::class)) {
            throw new \Exception("处理器类 {$handlerClass} 必须继承自 BaseWebhook");
        }

        // 获取服务代码
        $serviceCode = $this->getServiceCodeByPackage($packageName);

        // 创建处理器实例
        $handler = new $handlerClass($serviceCode, $request);

        // 执行处理
        $response = $handler->handle($handlerRoute);

        // 返回响应数据
        return $response->getData(true);
    }
    
    /**
     * 注册包处理器
     *
     * @param string $packageName 包名
     * @param string $handlerRoute Handler路由
     * @param string $handlerClass 处理器类名
     */
    public static function registerPackageHandler(string $packageName, string $handlerRoute, string $handlerClass): void
    {
        if (!isset(static::$packageHandlers[$packageName])) {
            static::$packageHandlers[$packageName] = [];
        }

        static::$packageHandlers[$packageName][$handlerRoute] = $handlerClass;

        Log::info("注册包处理器", [
            'package_name' => $packageName,
            'handler_route' => $handlerRoute,
            'handler_class' => $handlerClass,
        ]);
    }
    
    /**
     * 批量注册包处理器
     *
     * @param string $packageName 包名
     * @param array $handlers 处理器映射 ['route' => 'ClassName']
     */
    public static function registerPackageHandlers(string $packageName, array $handlers): void
    {
        foreach ($handlers as $route => $handlerClass) {
            static::registerPackageHandler($packageName, $route, $handlerClass);
        }
    }
    
    /**
     * 获取包的处理器类
     *
     * @param string $packageName 包名
     * @param string $handlerRoute Handler路由
     * @return string|null
     */
    protected function getPackageHandler(string $packageName, string $handlerRoute): ?string
    {
        return static::$packageHandlers[$packageName][$handlerRoute] ?? null;
    }
    
    /**
     * 根据包名获取服务代码
     *
     * @param string $packageName 包名
     * @return string
     * @throws \Exception
     */
    protected function getServiceCodeByPackage(string $packageName): string
    {
        // 查找对应的服务配置
        $service = ServiceModel::where('code', $packageName)->first();

        if (!$service) {
            throw new \Exception("包 {$packageName} 对应的服务配置不存在，请先在thirdparty_services表中注册");
        }

        return $service->code;
    }

    /**
     * 获取已注册的包列表
     *
     * @return array
     */
    public function getRegisteredPackages(): array
    {
        $packages = [];

        foreach (static::$packageHandlers as $packageName => $handlers) {
            $packages[$packageName] = [
                'name' => $packageName,
                'handlers' => array_keys($handlers),
                'handler_count' => count($handlers),
            ];
        }

        return $packages;
    }
    
    /**
     * 获取指定包的处理器列表
     * 
     * @param string $packageName 包名
     * @return array
     */
    public function getPackageHandlers(string $packageName): array
    {
        return static::$packageHandlers[$packageName] ?? [];
    }
    
    /**
     * 检查包是否已注册
     * 
     * @param string $packageName 包名
     * @return bool
     */
    public function isPackageRegistered(string $packageName): bool
    {
        return isset(static::$packageHandlers[$packageName]);
    }
    
    /**
     * 检查包的处理器是否已注册
     * 
     * @param string $packageName 包名
     * @param string $handlerRoute Handler路由
     * @return bool
     */
    public function isHandlerRegistered(string $packageName, string $handlerRoute): bool
    {
        return isset(static::$packageHandlers[$packageName][$handlerRoute]);
    }
    
    /**
     * 注销包处理器
     * 
     * @param string $packageName 包名
     * @param string|null $handlerRoute Handler路由，为空则注销整个包
     */
    public static function unregisterPackageHandler(string $packageName, ?string $handlerRoute = null): void
    {
        if ($handlerRoute === null) {
            // 注销整个包
            unset(static::$packageHandlers[$packageName]);
            Log::info("注销包", ['package_name' => $packageName]);
        } else {
            // 注销指定处理器
            unset(static::$packageHandlers[$packageName][$handlerRoute]);
            Log::info("注销包处理器", [
                'package_name' => $packageName,
                'handler_route' => $handlerRoute,
            ]);
        }
    }
    
    /**
     * 清空所有已注册的包处理器
     */
    public static function clearAllHandlers(): void
    {
        static::$packageHandlers = [];
        Log::info("清空所有包处理器");
    }
}