测试socket

app/Http/Controllers/Api/AskController.php

@@ -11,11 +11,24 @@ use App\Http\Controllers\Api\Traits\PayTrait;
 use App\Wen\Utils\Settings;
 use App\Wen\Utils\UserUtils;
 use App\Models\WxSlideshow;
+use App\Wen\Utils\GatewayUtils;
 
 class AskController extends BaseController
 {
     use PayTrait;
 
+    public function test(Request $request){
+        $chat_content = '你好';
+        $chat_image = '';
+        $uid = $request->uid;
+        $oid = 4101;
+        $websocket_id = GatewayUtils::uid2client_id($oid);
+        if($websocket_id){
+            GatewayUtils::success($websocket_id, 5, ['chat_content'=>_mini_emoji($chat_content, true), 'chat_image'=>$chat_image,
+                'from_user'=>UserUtils::get_cached_user($uid) ]);
+        }
+    }
+
     public function config(Request $request){
         $result = [
             'askorder_default_question' => Settings::get('askorder_default_question', ''),

app/Jobs/GatewayJob.php

@@ -38,10 +38,10 @@ class GatewayJob implements ShouldQueue
             return;
         }
 
-        if($this->client_id == 'all'){
+//        if($this->client_id == 'all'){
             Gateway::sendToAll($this->msg);
-        }else{
-            Gateway::sendToClient($this->client_id, $this->msg);
-        }
+//        }else{
+//            Gateway::sendToClient($this->client_id, $this->msg);
+//        }
     }
 }

app/Routes/api/v1.php

@@ -480,6 +480,7 @@ Route::group(
     Route::post('/blogger/lists',[BloggerController::class, 'lists']);
     //咨询，文字描述
     Route::post('/ask/config', [AskController::class, 'config']);
+    Route::post('/ask/test', [AskController::class, 'test']);
 
 
     // 测试