MQTT推送

application/common/controller/Push.php

@@ -75,6 +75,8 @@ class Push
     const PUSH_ROOM_PAN_XLH_PROGRESS      = 8000;
     //小时榜
     const PUSH_ROOM_PAN_HOUR_PROGRESS     = 8001;
+    //红包
+    const PUSH_ROOM_PAN_RED_PROGRESS      = 8002;
 
     public $user_id, $room_id, $topic_room, $topic_client;
 
@@ -307,6 +309,12 @@ class Push
         $this->push(self::PUSH_ROOM_PAN_HOUR_PROGRESS, $topic, $data);
     }
 
+    //红包来了
+    public function redpacketArrive($data){
+        $topic = 'qx_redpacket_arrive';
+        $this->push(self::PUSH_ROOM_PAN_RED_PROGRESS, $topic, $data);
+    }
+
 
 
 //    =========================================秘地使用结束=====================================================

application/common/model/Redpacket.php

@@ -2,6 +2,7 @@
 
 namespace app\common\model;
 
+use app\common\controller\Push;
 use think\Model;
 use think\Db;
 
@@ -130,6 +131,8 @@ class Redpacket extends Model
                 'text' => ''
             ];
             model('api/Chat')->sendMsg(1060,$data['room_id'],$text);
+            $push = new Push(UID, $data['room_id']);
+            $push->redpacketArrive($data);
 
             return ['code' => 1, 'msg' => '发红包成功', 'data' => $redpacketId];