Add DataBaseListen Middleware

Fix Exception get code and message

Signed-off-by: cyd622 <luffywang622@gmail.com>

Author: cyd622

src/Jobs/SaveUserTokenJob.php

@@ -10,15 +10,14 @@
 namespace Cyd622\LaravelApi\Jobs;
 
 use Illuminate\Bus\Queueable;
-use Illuminate\Queue\SerializesModels;
-use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Support\Facades\Cache;
 
 class SaveUserTokenJob implements ShouldQueue
 {
-    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+    use Dispatchable, InteractsWithQueue, Queueable;
     protected $user;
     protected $token;
 

src/Middleware/DataBaseListenMiddleware.php

@@ -0,0 +1,83 @@
+<?php
+
+namespace Cyd622\LaravelApi\Middleware;
+
+use Closure;
+use Illuminate\Database\Events\QueryExecuted;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\App;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Str;
+use Monolog\Handler\RotatingFileHandler;
+use Monolog\Logger;
+
+class DataBaseListenMiddleware
+{
+    /**
+     * @param Request $request
+     * @param Closure $next
+     * @return mixed
+     * @throws \Exception
+     */
+    public function handle(Request $request, Closure $next)
+    {
+        $logMaxFiles = config('laravel_api.middleware.database_listen.log_max_files', 30);
+        $logFile = storage_path('logs/database/sql.log');
+        if (version_compare(App::version(), '5.6.0', '>=')) {
+            // 5.6以上
+            if (!config('logging.channels.database')) {
+                $config = [
+                    'driver' => 'daily',
+                    'path' => $logFile,
+                    'days' => $logMaxFiles
+                ];
+                config(['logging.channels.database' => $config]);
+            }
+
+            $logger = Log::channel('database');
+
+        } else {
+            // 低于5.6版本手动分割日志
+            $logger = new Logger(App::environment());
+            $logger->pushHandler(new RotatingFileHandler($logFile, $logMaxFiles));
+        }
+
+        DB::listen(function (QueryExecuted $query) use ($logger, $request) {
+            $listenType = config('laravel_api.middleware.database_listen.listen_type', [
+                'select',
+                'update',
+                'delete',
+                'insert',
+            ]);
+
+            if (Str::startsWith($query->sql, $listenType)) {
+                $sqlWithPlaceholders = str_replace(['%', '?'], ['%%', '%s'], $query->sql);
+                $bindings = $query->connection->prepareBindings($query->bindings);
+                $pdo = $query->connection->getPdo();
+                $realSql = vsprintf($sqlWithPlaceholders, array_map([$pdo, 'quote'], $bindings));
+                $duration = $this->formatDuration($query->time / 1000);
+                $logger->debug(sprintf('[%s] %s | %s: %s', $duration, $realSql, $request->method(), $request->getRequestUri()));
+            }
+        });
+
+        return $next($request);
+    }
+
+    /**
+     * Format duration.
+     *
+     * @param float $seconds
+     *
+     * @return string
+     */
+    private function formatDuration($seconds)
+    {
+        if ($seconds < 0.001) {
+            return round($seconds * 1000000) . 'μs';
+        } elseif ($seconds < 1) {
+            return round($seconds * 1000, 2) . 'ms';
+        }
+        return round($seconds, 2) . 's';
+    }
+}

src/Response/ExceptionReport.php

@@ -179,15 +179,19 @@ public function report()
         }
 
         // 如果什么都拿不到默认就500了
-        $httpCode = $httpCode ?? 500;
+        $httpCode = $httpCode ?? config('laravel_api.exception.default_http_code', 500);
 
-        $statusCode = data_get($reportMessage, 'status_code', $httpCode);
+        $statusCode = data_get($reportMessage, 'status_code');
+        if (!$statusCode && method_exists($this->exception, 'getCode')) {
+            $statusCode = $this->exception->getCode();
+        }
+        $statusCode = $statusCode ?: $httpCode;
 
         // 非生产环境显示错误详情
         if (config('app.env') != 'production') {
             $message = $this->exception->getMessage() ?: data_get($reportMessage, 'msg', 'error');
         } else {
-            $message = data_get($reportMessage, 'msg', 'error');
+            $message = data_get($reportMessage, 'msg', $this->exception->getMessage());
         }
 
         // 表单验证异常返回的是数组,这里返回第一个错误消息

src/config.php

@@ -4,17 +4,29 @@
 use Symfony\Component\HttpKernel\Exception\UnauthorizedHttpException;
 
 return [
-    'response'=>[
+    'response' => [
         // 页码信息返回字段
-        'page_info'=>[
+        'page_info' => [
             'current_page',
             'last_page',
             'per_page',
             'total',
         ],
     ],
+    'middleware' => [
+        'database_listen' => [
+            'log_max_files' => 30,
+            'listen_type' => [
+                'select',
+                'update',
+                'delete',
+                'insert',
+            ]
+        ],
+    ],
     'exception' => [
-        'do_report'=>[
+        'default_http_code' => 500,
+        'do_report' => [
             UnauthorizedHttpException::class => [
                 'msg' => '未授权或Token签名失效',
                 'http_code' => 401,