push message modify

4 years ago · 1944b24fba
parent 8e10533681
commit 1944b24fba
1 changed files with 2 additions and 2 deletions
--- a/internal/msg_gateway/gate/rpc_server.go
+++ b/internal/msg_gateway/gate/rpc_server.go
@ -94,8 +94,8 @@ func (r *RPCServer) OnlinePushMsg(_ context.Context, in *pbRelay.OnlinePushMsgRe
 	}
 	//Single chat sender synchronization message
 	if in.MsgData.GetSessionType() == constant.SingleChatType {
-		for k, v := range ws.getSingleUserAllConn(recvID) {
-			_ = sendMsgToUser(v, replyBytes.Bytes(), in, k, recvID)
+		for k, v := range ws.getSingleUserAllConn(in.MsgData.SendID) {
+			_ = sendMsgToUser(v, replyBytes.Bytes(), in, k, in.MsgData.SendID)
 		}
 	}
 	if !tag {