argument('action'); $package = $this->argument('package'); $route = $this->argument('route'); switch ($action) { case 'list': return $this->listMappings(); case 'show': return $this->showPackage($package); case 'test': return $this->testRoute($package, $route); default: $this->error("未知操作: {$action}"); return 1; } } /** * 列出所有映射关系 * * @return int */ protected function listMappings(): int { $service = new WebhookDispatchService(); $packages = $service->getRegisteredPackages(); if (empty($packages)) { $this->info('没有注册的包'); return 0; } $this->info('已注册的包列表:'); $this->newLine(); $headers = ['包名', '处理器数量', '映射类型', '描述']; $rows = []; foreach ($packages as $packageName => $info) { $rows[] = [ $packageName, $info['handler_count'], '一对一精确匹配', "包含 {$info['handler_count']} 个专门的Webhook处理器", ]; } $this->table($headers, $rows); return 0; } /** * 显示指定包的详细信息 * * @param string|null $package 包名 * @return int */ protected function showPackage(?string $package): int { if (!$package) { $this->error('请指定包名'); return 1; } $service = new WebhookDispatchService(); $packages = $service->getRegisteredPackages(); if (!isset($packages[$package])) { $this->error("包 {$package} 不存在"); return 1; } $packageInfo = $packages[$package]; $this->info("包信息: {$package}"); $this->newLine(); // 显示基本信息 $this->line("名称: {$packageInfo['name']}"); $this->line("处理器数量: {$packageInfo['handler_count']}"); $this->newLine(); // 显示处理器列表 $this->info('注册的处理器 (一对一映射):'); if (empty($packageInfo['handlers'])) { $this->line(' 无'); } else { $handlerHeaders = ['路由', '处理器类', '专门处理']; $handlerRows = []; // 使用反射获取处理器映射 $reflection = new \ReflectionClass(WebhookDispatchService::class); $property = $reflection->getProperty('packageHandlers'); $property->setAccessible(true); $handlers = $property->getValue()[$package] ?? []; foreach ($handlers as $route => $handlerClass) { $handlerRows[] = [ $route, $handlerClass, $this->getHandlerDescription($route), ]; } $this->table($handlerHeaders, $handlerRows); } return 0; } /** * 获取处理器描述 * * @param string $route 路由 * @return string */ protected function getHandlerDescription(string $route): string { $descriptions = [ 'register' => '用户注册通知', 'deposit' => '充值操作通知', 'withdraw' => '提取操作通知', 'check' => '余额检查通知', ]; return $descriptions[$route] ?? '未知操作'; } /** * 测试路由匹配 * * @param string|null $package 包名 * @param string|null $route 路由 * @return int */ protected function testRoute(?string $package, ?string $route): int { if (!$package || !$route) { $this->error('请指定包名和路由'); return 1; } $this->info("测试路由匹配: {$package}/{$route}"); $this->newLine(); try { $service = new WebhookDispatchService(); // 使用反射获取处理器映射 $reflection = new \ReflectionClass($service); $property = $reflection->getProperty('packageHandlers'); $property->setAccessible(true); $handlers = $property->getValue()[$package] ?? []; if (isset($handlers[$route])) { $handlerClass = $handlers[$route]; $this->info('找到匹配的处理器:'); $this->line("路由: {$route}"); $this->line("处理器类: {$handlerClass}"); $this->line("映射类型: 一对一精确匹配"); $this->line("支持方法: POST (Webhook标准)"); $this->line("专门处理: " . $this->getHandlerDescription($route)); // 检查处理器类是否存在 if (class_exists($handlerClass)) { $this->line("类状态: 已加载"); } else { $this->error("类状态: 未找到"); } } else { $this->error('没有找到匹配的处理器'); $this->line('可用路由: ' . implode(', ', array_keys($handlers))); } } catch (\Exception $e) { $this->error("测试失败: {$e->getMessage()}"); return 1; } return 0; } }