浏览代码

给新玩法准备异步

lizhen_gitee 1 年之前
父节点
当前提交
9463c44a14
共有 2 个文件被更改,包括 10 次插入10 次删除
  1. 2 2
      app/Http/Controllers/Controller.php
  2. 8 8
      app/Jobs/GrabgiftJob.php

+ 2 - 2
app/Http/Controllers/Controller.php

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

+ 8 - 8
app/Jobs/GrabgiftJob.php

@@ -10,6 +10,7 @@ use Illuminate\Queue\SerializesModels;
 
 use Illuminate\Support\Facades\Redis;
 use Illuminate\Support\Facades\Log;
+use \GatewayClient\Gateway;
 
 class GrabgiftJob implements ShouldQueue
 {
@@ -43,15 +44,14 @@ class GrabgiftJob implements ShouldQueue
         $seat_number = $this->params['seat_number'];
 
         //开奖了,旧的一期结束了
-        $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->del('ttkge_grabgift_num_'.$grab_id);
+        $this->redis->del('ttkge_grabgift_data_'.$grab_id);
+        $this->redis->del('ttkge_grabgift_'.$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_'.$new_grab_id,$seat_number);
+        $this->redis->set('ttkge_grabgift_lastgrabid',$new_grab_id);
 
-        $this->redis->set('kge_grabgift_lock',0);
+        $this->redis->set('ttkge_grabgift_lock',0);
 
         $data = [
             'grab_id' => $new_grab_id,
@@ -64,7 +64,7 @@ class GrabgiftJob implements ShouldQueue
     /**
      * 房间中全民抢礼物,全服通告
      */
-    public static function sendGrabgift($type,$data)
+    public function sendGrabgift($type,$data)
     {
         $messageData = [
             'type'    => $type,