给新玩法准备异步

app/Http/Controllers/Controller.php

@@ -20,7 +20,8 @@ class Controller extends BaseController
     public function grabgift(Request $request){
         $params = $request->all();
         //(new GrabgiftJob($params))->handle();
-        dispatch(new GrabgiftJob($params))->delay(3);//加入队列
+        dispatch((new GrabgiftJob($params))->delay(3));//加入队列
+
     }
 
     public function test(){

app/Jobs/GrabgiftJob.php

@@ -17,7 +17,6 @@ class GrabgiftJob implements ShouldQueue
     use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
 
     protected $params;
-    protected $redis;
 
 
     /**
@@ -28,7 +27,7 @@ class GrabgiftJob implements ShouldQueue
     public function __construct($params)
     {
         $this->params = $params;
-        $this->redis  = Redis::connection();
+
         Log::info(date('Y-m-d H:i:d').':'.json_encode($params));
     }
 
@@ -44,15 +43,16 @@ class GrabgiftJob implements ShouldQueue
         $seat_number = $this->params['seat_number'];
         $price       = $this->params['price'];
 
+        $redis  = Redis::connection();
         //开奖了，旧的一期结束了
-        $this->redis->del('kge_grabgift_num_'.$grab_id);
-        $this->redis->del('kge_grabgift_data_'.$grab_id);
-        $this->redis->del('kge_grabgift_'.$grab_id);
+        $redis->del('kge_grabgift_num_'.$grab_id);
+        $redis->del('kge_grabgift_data_'.$grab_id);
+        $redis->del('kge_grabgift_'.$grab_id);
         //新的一期开始了
-        $this->redis->set('kge_grabgift_'.$new_grab_id,$seat_number);
-        $this->redis->set('kge_grabgift_lastgrabid',$new_grab_id);
+        $redis->set('kge_grabgift_'.$new_grab_id,$seat_number);
+        $redis->set('kge_grabgift_lastgrabid',$new_grab_id);
 
-        $this->redis->set('kge_grabgift_lock',0);
+        $redis->set('kge_grabgift_lock',0);
 
         $data = [
             'grab_id' => $new_grab_id,