logUtil

Author: fraisier

app/Controller/IndexController.php

@@ -12,6 +12,8 @@
 
 namespace App\Controller;
 
+use App\Constants\ErrCode;
+use App\Exception\BusinessException;
 use App\JsonRpc\UserCenter\Contracts\UserCenterInterface;
 use App\Model\Model;
 use App\Model\User;
@@ -45,6 +47,7 @@ public function index()
         console()->emergency('emergency ----- Hello Hyperf!');
         console()->notice('notice ----- Hello Hyperf!');
         logger()->info('info ----- Hello Hyperf!');
+        throw new BusinessException(ErrCode::SERVER_ERROR);
         return ResponseUtil::success(['count' => 1]);
     }
 

app/Exception/Handler/AppExceptionHandler.php

@@ -32,7 +32,7 @@ public function handle(Throwable $throwable, ResponseInterface $response)
         $this->logger->error(sprintf('%s[%s] in %s', $throwable->getMessage(), $throwable->getLine(), $throwable->getFile()));
         $this->logger->error($throwable->getTraceAsString());
 
-        logger('error')->error(sprintf('%s[%s] in %s', $throwable->getMessage(), $throwable->getLine(), $throwable->getFile()));
+        logger()->error(sprintf('%s[%s] in %s', $throwable->getMessage(), $throwable->getLine(), $throwable->getFile()));
 
         return $response->withHeader('Server', 'hyperf')->withStatus(200)->withBody(new SwooleStream(ResponseUtil::fail(ErrCode::SERVER_ERROR)->getBody()->getContents()));
     }

app/Exception/Handler/AuthExceptionHandler.php

@@ -4,6 +4,7 @@
 namespace App\Exception\Handler;
 
 use App\Constants\ErrCode;
+use App\Kernel\Log\LogUtil;
 use Hyperf\HttpMessage\Stream\SwooleStream;
 use Psr\Http\Message\ResponseInterface;
 use Throwable;
@@ -13,10 +14,12 @@ class AuthExceptionHandler extends \Qbhy\HyperfAuth\AuthExceptionHandler
     public function handle(Throwable $throwable, ResponseInterface $response)
     {
         $this->stopPropagation();
-        return $response->withStatus(200)->withBody(new SwooleStream(json_encode([
+        $response = $response->withStatus(200)->withBody(new SwooleStream(json_encode([
             'code' => ErrCode::UNAUTHORIZED,
             'message' => $throwable->getMessage(),
         ])));
+        LogUtil::logResponse($response);
+        return $response;
     }
 
 }

app/Exception/Handler/BusinessExceptionHandler.php

@@ -13,6 +13,7 @@
 namespace App\Exception\Handler;
 
 use App\Exception\BusinessException;
+use App\Kernel\Log\LogUtil;
 use Hyperf\ExceptionHandler\ExceptionHandler;
 use Hyperf\HttpMessage\Stream\SwooleStream;
 use Swow\Psr7\Message\ResponsePlusInterface;
@@ -23,10 +24,12 @@ class BusinessExceptionHandler extends ExceptionHandler
     public function handle(Throwable $throwable, ResponsePlusInterface $response)
     {
         $this->stopPropagation();
-        return $response->withStatus(200)->withBody(new SwooleStream(json_encode([
+        $response = $response->withStatus(200)->withBody(new SwooleStream(json_encode([
             'code' => $throwable->getCode(),
             'message' => $throwable->getMessage(),
         ])));
+        LogUtil::logResponse($response);
+        return $response;
     }
 
     public function isValid(Throwable $throwable): bool

app/Kernel/Log/LogUtil.php

@@ -6,9 +6,10 @@
 use Hyperf\Codec\Json;
 use Hyperf\Context\Context;
 use Hyperf\HttpServer\Contract\RequestInterface;
-use Hyperf\HttpServer\Contract\ResponseInterface;
+use Psr\Http\Message\ResponseInterface;
 use Stringable;
 use function App\Kernel\console;
+use function App\Kernel\di;
 use function App\Kernel\logger;
 
 /**
@@ -29,18 +30,18 @@ public static function __callStatic($name, $arguments)
         console()->$name(...$arguments);
     }
 
-    public static function logResponse()
+    public static function logResponse(?Responseinterface $response = null)
     {
-        $request = Context::get(RequestInterface::class);
+        $request = di(RequestInterface::class);
         $requestId = Context::get('requestId');
-        $response = Context::get(ResponseInterface::class);
+        $response = $response?:di(\Hyperf\HttpServer\Contract\ResponseInterface::class);
         LogUtil::debug('request=' . Json::encode([
                 'request_id' => $requestId,
                 'uri' => $request->getUri()->getPath(),
                 'method' => $request->getMethod(),
                 'params' => $request->getParsedBody(),
                 'query' => $request->getQueryParams(),
+                'response' => $response->getBody()->getContents(),
             ], JSON_UNESCAPED_SLASHES));
-        LogUtil::debug('response=' . $response->getBody()->getContents());
     }
 }

app/Kernel/functions.php

@@ -20,6 +20,7 @@
 use Psr\Log\LoggerInterface;
 use RuntimeException;
 use Throwable;
+use function Hyperf\Support\env;
 
 /**
  * @template T
@@ -39,8 +40,9 @@ function di(?string $serviceName = null)
     }
 }
 
-function logger($name = 'hyperf', $group = 'default'): LoggerInterface
+function logger($group = 'default'): LoggerInterface
 {
+    $name = env('APP_NAME', 'hyperf');
     return di(LoggerFactory::class)->get($name, $group);
 }