瀏覽代碼

测试socket

lizhen_gitee 6 天之前
父節點
當前提交
12d9917b39
共有 3 個文件被更改,包括 7 次插入7 次删除
  1. 1 1
      app/Http/Controllers/Api/AskController.php
  2. 5 5
      app/Jobs/GatewayJob.php
  3. 1 1
      app/Wen/Utils/GatewayUtils.php

+ 1 - 1
app/Http/Controllers/Api/AskController.php

@@ -23,7 +23,7 @@ class AskController extends BaseController
         $uid = $request->uid;
         $uid = $request->uid;
         $oid = 4395;
         $oid = 4395;
         $websocket_id = GatewayUtils::uid2client_id($oid);
         $websocket_id = GatewayUtils::uid2client_id($oid);
-        $websocket_id = 111;
+        $websocket_id = 'all';
         if($websocket_id){
         if($websocket_id){
             GatewayUtils::success($websocket_id, 5, ['chat_content'=>_mini_emoji($chat_content, true), 'chat_image'=>$chat_image,
             GatewayUtils::success($websocket_id, 5, ['chat_content'=>_mini_emoji($chat_content, true), 'chat_image'=>$chat_image,
                 'from_user'=>UserUtils::get_cached_user($uid) ]);
                 'from_user'=>UserUtils::get_cached_user($uid) ]);

+ 5 - 5
app/Jobs/GatewayJob.php

@@ -35,13 +35,13 @@ class GatewayJob implements ShouldQueue
     public function handle()
     public function handle()
     {
     {
         if(_empty_($this->client_id)){
         if(_empty_($this->client_id)){
-            //return;
+            return;
         }
         }
 
 
-//        if($this->client_id == 'all'){
+        if($this->client_id == 'all'){
             Gateway::sendToAll($this->msg);
             Gateway::sendToAll($this->msg);
-//        }else{
-//            Gateway::sendToClient($this->client_id, $this->msg);
-//        }
+        }else{
+            Gateway::sendToClient($this->client_id, $this->msg);
+        }
     }
     }
 }
 }

+ 1 - 1
app/Wen/Utils/GatewayUtils.php

@@ -240,7 +240,7 @@ class GatewayUtils{
     public static function success($client_id, $mode, $data = [],$code =200)
     public static function success($client_id, $mode, $data = [],$code =200)
     {
     {
         if(_empty_($client_id)){
         if(_empty_($client_id)){
-           // return false;
+            return false;
         }
         }
         if(!in_array($mode, [0, 1, 2, 3, 4, 5, 12, 13])){
         if(!in_array($mode, [0, 1, 2, 3, 4, 5, 12, 13])){
             return false;
             return false;