接口验证中间件

app/Http/Controllers/strategy/InfoController.php

+<?php
+
+namespace App\Http\Controllers\strategy;
+
+use Illuminate\Http\Request;
+use App\Http\Controllers\Controller;
+use App\Http\Controllers\BaseController;
+
+class InfoController extends BaseController
+{
+    public function strategyLists(Request $request){
+        dd('策略列表数据');
+    }
+}

app/Http/Middleware/CheckApiKey.php

@@ -6,8 +6,11 @@ use Closure;
 use App\Http\models\users;
 use Illuminate\Support\Facades\Log;
 use App\User;
+use Illuminate\Support\Facades\DB;
+use App\Http\Controllers\Tool;
 class CheckApiKey
 {
+    use Tool;
     /**
      * Handle an incoming request.
      *
@@ -18,7 +21,14 @@ class CheckApiKey
     public function handle($request, Closure $next)
     {
         try {
-            $url=$request->url;
+            $url=$request->url;            
+            $api_key=$request->api_key;
+            $user_sn=$request->user_sn;
+            
+            if (empty($url) || empty($api_key) || empty($user_sn)){
+                return $this->errorWithInfo('参数验证不通过', 401);
+            }
+            
             $param = $request->except(['url','client_info_json','source','aes','upload','fail_recall_of_reason']);
             
             Log::channel('api')->info('API_PARAM:'.json_encode($param));
@@ -29,19 +39,16 @@ class CheckApiKey
             
             if(strcmp($url,$md_url)){
                 if($_SERVER['REQUEST_SCHEME'] == 'http'){
-                    return response()->json(array('code'=> 10001,'msg'=>'验证url失败'));
+                    return $this->errorWithInfo('验证url失败', 401);
                 }
             }
 
-            $api_key=$request->api_key;
-            $user_sn=$request->user_sn;
-            
-            $user = Users::where('user_sn',$param['user_sn'])->first();
+            $user = DB::table('users')->where('user_sn',$param['user_sn'])->first();
 
             if(empty($user->parent_sn)){
                 $the_expired = $user->expired;
             }else{
-                $puser = Users::where('user_name',$user->parent_sn)->select('expired')->first();
+                $puser = DB::table('users')->where('user_name',$user->parent_sn)->select('expired')->first();
                 $the_expired = $puser->expired;
             }
 
@@ -49,13 +56,13 @@ class CheckApiKey
             $expiredDate =strtotime($the_expired. ' 00:00:00');
         
             if(empty($the_expired) || $expiredDate - $todayDate <= 0){
-                 return response()->json(array('code'=> 20008,'msg'=>'您的账号已过期，请联系管理员处理'));
+                 return $this->errorWithInfo('您的账号已过期，请联系管理员处理', 401);
             }
   
             $request->attributes->add(['user'=>$user]);//添加参数
         }catch (\Exception $e){
-            Log::info($e->getFile().'-'.$e->getLine().'-'.$e->getMessage());
-            return response()->json(array('code'=> 500,'msg'=>$e->getMessage().'-'.$e->getLine()));
+            Log::channel('api')->error($e->getFile().'-'.$e->getLine().'-'.$e->getMessage());
+            return $this->errorWithInfo('验证异常', 401);
         }   
         return $next($request);
     }

database/seeds/DatabaseSeeder.php

@@ -63,7 +63,7 @@ class DatabaseSeeder extends Seeder
             });
         }
         
-        $tableName = 'task_data';//任务数据（任务已建未建）
+        $tableName = 'strategy_task';//任务数据（任务已建未建）
         if(!Schema::hasTable($tableName)){
             //创建表语句
             Schema::create($tableName, function (Blueprint $table){

routes/api.php

@@ -18,11 +18,10 @@ Route::middleware('auth:api')->get('/user', function (Request $request) {
 });
 
 //接口路由
-Route::match(['get', 'post'],'login', 'LoginApiController@index');
-Route::match(['get', 'post'],'loginc', 'LoginCheckController@index');
+Route::post('login', 'LoginApiController@index');
 
-Route::group(['middleware' => 'check.apikey','prefix' => 'api'], function () {
-    
+Route::group(['middleware' => 'check.apikey','namespace' => 'strategy'], function () {
+    Route::match(['get', 'post'],'strategyLists', 'InfoController@strategyLists');//初始化
 });