diff --git a/internal/push/push_to_client.go b/internal/push/push_to_client.go index 801718f49..91f183f66 100644 --- a/internal/push/push_to_client.go +++ b/internal/push/push_to_client.go @@ -188,6 +188,7 @@ func (p *Pusher) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.MsgData, if err != nil { continue } + log.ZDebug(ctx, "push result", "reply", reply) if reply != nil && reply.SinglePushResult != nil { wsResults = append(wsResults, reply.SinglePushResult...) } diff --git a/internal/rpc/msg/send_pull.go b/internal/rpc/msg/send_pull.go index b2ff41e35..eba6edf20 100644 --- a/internal/rpc/msg/send_pull.go +++ b/internal/rpc/msg/send_pull.go @@ -63,7 +63,7 @@ func (m *msgServer) sendMsgSingleChat(ctx context.Context, req *msg.SendMsgReq) return nil, err } conversationID := utils.GetConversationIDByMsg(req.MsgData) - isSend, err := m.modifyMessageByUserMessageReceiveOpt(ctx, req.MsgData.RecvID, req.MsgData.SendID, constant.SingleChatType, req) + isSend, err := m.modifyMessageByUserMessageReceiveOpt(ctx, req.MsgData.RecvID, conversationID, constant.SingleChatType, req) if err != nil { return nil, err }