1

app/Exceptions/Handler.php

@@ -100,6 +100,7 @@ class Handler extends ExceptionHandler
             ];
             try{
                 MqTool::pushLogMessage(json_encode($mqMessage),"daogouLogKey");
+                LoggerFactoryUtil::setIsPush(1);
             }catch (\Exception $exception){}finally{}
         }
         //异常处理

app/Http/Controllers/BaseController.php

@@ -5,6 +5,7 @@ namespace App\Http\Controllers;
 
 
 use App\Exceptions\ValidateException;
+use App\Models\WechatAccountModel;
 use Illuminate\Http\Request;
 
 /**
@@ -103,4 +104,10 @@ class BaseController extends Controller
         $data = json_decode(file_get_contents("./swagger.json"),true);
         return $data;
     }
+
+    public function test()
+    {
+        $data = WechatAccountModel::findByWechatAppCode("fanbuting");
+        return $data;
+    }
 }

app/Http/Middleware/RequestLogMiddleware.php

@@ -77,7 +77,9 @@ class RequestLogMiddleware
                 "uniqueTraceId"=>$traceId
             ];
             try{
-                MqTool::pushLogMessage(json_encode($mqMessage),"daogouLogKey");
+                if(LoggerFactoryUtil::getIsPush()==0){
+                    MqTool::pushLogMessage(json_encode($mqMessage),"daogouLogKey");
+                }
             }catch (\Exception $exception){}finally{}
         }
         return $response;

app/Http/Utils/LoggerFactoryUtil.php

@@ -36,6 +36,28 @@ class LoggerFactoryUtil extends BaseUtil
      */
     private static $requestId;
 
+    /**
+     * 是否推送日志
+     * @var int
+     */
+    private static $isPush=0;
+
+    /**
+     * @return int
+     */
+    public static function getIsPush(): int
+    {
+        return self::$isPush;
+    }
+
+    /**
+     * @param int $isPush
+     */
+    public static function setIsPush(int $isPush): void
+    {
+        self::$isPush = $isPush;
+    }
+
     /**
      * @return string
      */

routes/api.php

@@ -25,4 +25,7 @@ Route::get("/loadswagger","BaseController@loadSwagger");
 
 
 //校验微信服务器
-Route::any("/checkServer/{code}","WechatController@checkServer");
+Route::any("/checkServer/{code}","WechatController@checkServer");
+
+
+Route::get("/test","BaseController@test");