1002-添加好友申请

app/Amqp/Consumer/MqConsumer.php

@@ -154,6 +154,10 @@ class MqConsumer extends ConsumerMessage
                     $this->messageController->sendUserMessage($data);
                     return Result::ACK;
                     break;
+                case 1002:
+                    $this->messageController->sendUserMessage($data);
+                    return Result::ACK;
+                    break;
                 default:
                     // 调用数据处理服务
                     $result = $this->chatServiceClient->addChatRecords($data);

app/Controller/MessageController.php

@@ -51,6 +51,7 @@ class MessageController extends AbstractController
             $server = \Hyperf\Context\ApplicationContext::getContainer()->get(\Swoole\Server::class);
             $redisClient = new RedisService();
             $fd = $redisClient->findFd((int)$data['user_id']);
+//            var_dump("用户信息：",$fd,$data['user_id'],$data);
             if ($fd && $server->isEstablished((int)$fd)) {
                 $server->push((int)$fd, json_encode($data));
             }
@@ -92,7 +93,7 @@ class MessageController extends AbstractController
         $redisClient = new RedisService();
         $message = [
             'talk_type' => 1,
-            'title' => $userInfo['data']['remark'],
+            'title' => isset($userInfo['data']['remark']) && $userInfo['data']['remark'] != '' ? $userInfo['data']['remark'] : '好友',
             'content' => $data['content'],
             'messageType' => 1,
             'receiver_id'=> $data['user_id'],