|
|
@@ -273,8 +273,10 @@ class SocketServer extends Command
|
|
|
// 推送消息给对方
|
|
|
$msgData['nickname'] = MemberModel::where(['id'=> $fromUid])->value('nickname');
|
|
|
$msgData['time_text'] = dateFormat($msgData['create_time']);
|
|
|
- $this->sendMsg($frameId, ['success' => true, 'op' => 'push_live', 'scene'=> $scene, 'data' => $msgData, 'message' => '发送成功：' . $frameId]);
|
|
|
+ //$this->sendMsg($frameId, ['success' => true, 'op' => 'push_live', 'scene'=> $scene, 'data' => $msgData, 'message' => '发送成功：' . $frameId]);
|
|
|
$fids = RedisService::get("chats:bindFds:{$chatKey}");
|
|
|
+ $fids = array_values($fids);
|
|
|
+ $fids = array_unique($fids);
|
|
|
if($fids){
|
|
|
foreach($fids as $fd){
|
|
|
$this->sendMsg($fd, ['success' => true, 'op' => 'push_live' ,'scene'=> $scene, 'data' => $msgData, 'message' => '推送消息成功：' . $fd]);
|
