给新玩法准备异步

app/Http/Controllers/Controller.php

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

app/Jobs/GrabgiftJob.php

@@ -39,22 +39,25 @@ class GrabgiftJob implements ShouldQueue
      */
     public function handle()
     {
-        $grab_id = $this->params['grab_id'];
+        $grab_id     = $this->params['grab_id'];
         $new_grab_id = $this->params['new_grab_id'];
         $seat_number = $this->params['seat_number'];
+        $price       = $this->params['price'];
 
         //开奖了，旧的一期结束了
-        $this->redis->del('ttkge_grabgift_num_'.$grab_id);
-        $this->redis->del('ttkge_grabgift_data_'.$grab_id);
-        $this->redis->del('ttkge_grabgift_'.$grab_id);
+        $this->redis->del('kge_grabgift_num_'.$grab_id);
+        $this->redis->del('kge_grabgift_data_'.$grab_id);
+        $this->redis->del('kge_grabgift_'.$grab_id);
         //新的一期开始了
-        $this->redis->set('ttkge_grabgift_'.$new_grab_id,$seat_number);
-        $this->redis->set('ttkge_grabgift_lastgrabid',$new_grab_id);
+        $this->redis->set('kge_grabgift_'.$new_grab_id,$seat_number);
+        $this->redis->set('kge_grabgift_lastgrabid',$new_grab_id);
 
-        $this->redis->set('ttkge_grabgift_lock',0);
+        $this->redis->set('kge_grabgift_lock',0);
 
         $data = [
             'grab_id' => $new_grab_id,
+            'seat_number' => $seat_number,
+            'price' => $price,
             'kge_grabgift_lock' => 0,
         ];