|
|
@@ -181,6 +181,7 @@ class WebSocketController implements OnMessageInterface, OnOpenInterface, OnClos
|
|
|
$fd = $redisClient->findFd((int) $val['user_id']);
|
|
|
if ($server->isEstablished((int) $fd)) {
|
|
|
var_dump($fd, $val['user_id']);
|
|
|
+ $result['user_name'] = $val['group_name']??'';
|
|
|
$server->push((int) $fd, json_encode($result));
|
|
|
var_dump($val, '-------------44----');
|
|
|
try {
|
|
|
@@ -191,7 +192,6 @@ class WebSocketController implements OnMessageInterface, OnOpenInterface, OnClos
|
|
|
$chatdata['group_receiver_id'] = $val['user_id'];
|
|
|
$chatdata['is_read'] = 1;
|
|
|
$chatdata['action'] = 'said';
|
|
|
- $chatdata['group_name'] = $val['group_name']??'';
|
|
|
$message = new MqProducer($chatdata);
|
|
|
$producer = ContextApplicationContext::getContainer()->get(Producer::class);
|
|
|
$re = $producer->produce($message);
|
|
|
@@ -203,7 +203,6 @@ class WebSocketController implements OnMessageInterface, OnOpenInterface, OnClos
|
|
|
$chatdata['group_receiver_id'] = $result['user_id'];
|
|
|
$chatdata['is_read'] = 0;
|
|
|
$chatdata['action'] = 'recieved';
|
|
|
- $chatdata['group_name'] = $val['group_name']??'';
|
|
|
$message = new MqProducer($chatdata);
|
|
|
$producer = ContextApplicationContext::getContainer()->get(Producer::class);
|
|
|
$re = $producer->produce($message);
|
rkljw