websocket

.env

@@ -11,15 +11,15 @@ DB_CHARSET=utf8mb4
 DB_COLLATION=utf8mb4_unicode_ci
 DB_PREFIX=
 
-REDIS_HOST=192.168.1.201
-REDIS_AUTH=123456
-REDIS_PORT=6379
+REDIS_HOST=101.254.114.211
+REDIS_AUTH=YPWWnFnNebc7427B
+REDIS_PORT=26739
 REDIS_DB=0
 
-AMQP_HOST=192.168.1.201
-AMQP_PORT=5672
-AMQP_USER=admin
-AMQP_PASSWORD=123456
+AMQP_HOST=103.105.201.2
+AMQP_PORT=5673
+AMQP_USER=rabbitmq
+AMQP_PASSWORD=H8eDTAk6LY7EjJ8y
 
 
 #小程序获取openid

app/Controller/ChatController.php

@@ -22,7 +22,7 @@ use Hyperf\Context\Context;
  * Class ChatController
  * @package App\Controller
  */
-#[AutoController]
+//#[AutoController]
 class ChatController extends AbstractController
 {
     #[Inject]
@@ -53,7 +53,8 @@ class ChatController extends AbstractController
             $errorMessage = $validator->errors()->first();
             return Result::error($errorMessage);
         }
-        $requireData['user_id'] =Context::get("UserId");
+        $requireData['user_id'] = Context::get("UserId");
+        var_dump("用户id：",$requireData);
         $result = $this->chatServiceClient->addContactApply($requireData);
         return $result?Result::success($result['data']):Result::error($result['message']);
     }
@@ -181,10 +182,8 @@ class ChatController extends AbstractController
               $errorMessage = $validator->errors()->first();
               return Result::error($errorMessage);
           }
-          $requireData['user_id'] =Context::get("UserId");
-          $userIdArr = array(json_decode($requireData['user_id_arr']));
-          $requireData['user_id_arr'] = $userIdArr[0];
-          $requireData['user_id_arr'][] =Context::get("UserId");
+          $requireData['user_id'] = Context::get("UserId");
+          $requireData['user_id_arr'] = $requireData['user_id_arr'];
           var_dump($requireData);
           $result = $this->chatServiceClient->addTalkGroup($requireData);
           return $result['code']==200?Result::success($result['data']):Result::error($result['message']);

config/api/chat.php

@@ -1,5 +1,16 @@
 <?php
 
 declare(strict_types=1);
+use App\Controller\ChatController;
 use Hyperf\HttpServer\Router\Router;
+use App\Middleware\Auth\FooMiddleware;
+Router::addGroup(
+    '/chat', function () {
+            Router::get('/addContactApply', [ChatController::class, 'addContactApply']);
+            Router::post('/updateContactApply', [ChatController::class, 'updateContactApply']);
+            Router::get('/getTalkSessionList', [ChatController::class, 'getTalkSessionList']);
+            Router::post('/addTalkGroup', [ChatController::class, 'addTalkGroup']);
+        },
+       ['middleware' => [FooMiddleware::class]]
+);
 

runtime/container/proxy/App_Controller_ChatController.proxy.php

@@ -21,7 +21,7 @@ use Hyperf\Context\Context;
  * Class ChatController
  * @package App\Controller
  */
-#[AutoController]
+//#[AutoController]
 class ChatController extends AbstractController
 {
     use \Hyperf\Di\Aop\ProxyTrait;
@@ -53,6 +53,7 @@ class ChatController extends AbstractController
             return Result::error($errorMessage);
         }
         $requireData['user_id'] = Context::get("UserId");
+        var_dump("用户id：", $requireData);
         $result = $this->chatServiceClient->addContactApply($requireData);
         return $result ? Result::success($result['data']) : Result::error($result['message']);
     }
@@ -145,9 +146,7 @@ class ChatController extends AbstractController
             return Result::error($errorMessage);
         }
         $requireData['user_id'] = Context::get("UserId");
-        $userIdArr = array(json_decode($requireData['user_id_arr']));
-        $requireData['user_id_arr'] = $userIdArr[0];
-        $requireData['user_id_arr'][] = Context::get("UserId");
+        $requireData['user_id_arr'] = $requireData['user_id_arr'];
         var_dump($requireData);
         $result = $this->chatServiceClient->addTalkGroup($requireData);
         return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);