From c266a048f1053691e35bc80b2e8596897df03986 Mon Sep 17 00:00:00 2001 From: Aether Date: Sun, 28 Sep 2025 17:19:23 +0800 Subject: [PATCH] .. --- app/JsonRpc/Service/DataService.php | 1 - .../PHP/Hyperf/RpcException/ApiExceptionHandler.php | 10 ++++++++++ .../Hyperf/RpcException/JsonRpcExceptionHandler.php | 10 ++++++++++ 3 files changed, 20 insertions(+), 1 deletion(-) diff --git a/app/JsonRpc/Service/DataService.php b/app/JsonRpc/Service/DataService.php index a212fa1..3447530 100644 --- a/app/JsonRpc/Service/DataService.php +++ b/app/JsonRpc/Service/DataService.php @@ -40,7 +40,6 @@ class DataService implements DataServiceInterface { $this->campusValidator->scene('create', $data)->check(); $campus = $this->campusModel->create($data); - // $this->tran return $campus->id; } diff --git a/extend/Aether/PHP/Hyperf/RpcException/ApiExceptionHandler.php b/extend/Aether/PHP/Hyperf/RpcException/ApiExceptionHandler.php index 3394dc6..4fb0b84 100644 --- a/extend/Aether/PHP/Hyperf/RpcException/ApiExceptionHandler.php +++ b/extend/Aether/PHP/Hyperf/RpcException/ApiExceptionHandler.php @@ -10,14 +10,24 @@ use Hyperf\ExceptionHandler\ExceptionHandler; use Hyperf\HttpMessage\Stream\SwooleStream; use Psr\Http\Message\MessageInterface; use Psr\Http\Message\ResponseInterface; +use Psr\Log\LoggerInterface; use Throwable; use function Hyperf\support\env; class ApiExceptionHandler extends ExceptionHandler { + + protected LoggerInterface $logger; + + public function __construct(LoggerInterface $logger) + { + $this->logger = $logger; + } + public function handle(Throwable $throwable, ResponseInterface $response): MessageInterface|ResponseInterface { + $this->logger->error($throwable->getMessage()); // 业务异常 if ($throwable instanceof BusinessException) { $code = $throwable->getCode(); diff --git a/extend/Aether/PHP/Hyperf/RpcException/JsonRpcExceptionHandler.php b/extend/Aether/PHP/Hyperf/RpcException/JsonRpcExceptionHandler.php index f865c32..c10c513 100644 --- a/extend/Aether/PHP/Hyperf/RpcException/JsonRpcExceptionHandler.php +++ b/extend/Aether/PHP/Hyperf/RpcException/JsonRpcExceptionHandler.php @@ -11,10 +11,18 @@ use Hyperf\Rpc\Contract\ResponseInterface; use Psr\Container\ContainerExceptionInterface; use Psr\Container\NotFoundExceptionInterface; use Psr\Http\Message\MessageInterface; +use Psr\Log\LoggerInterface; use Throwable; class JsonRpcExceptionHandler { + protected LoggerInterface $logger; + + public function __construct(LoggerInterface $logger) + { + $this->logger = $logger; + } + /** * JSON-RPC 异常处理. * @throws ContainerExceptionInterface @@ -25,6 +33,8 @@ class JsonRpcExceptionHandler $responseContents = $response->getBody()->getContents(); $responseContents = json_decode($responseContents, true); if (! empty($responseContents['error'])) { + $this->logger->error($responseContents['error']); + $port = null; $config = ApplicationContext::getContainer()->get(ConfigInterface::class); $servers = $config->get('server.servers');