diff --git a/internal/msggateway/hub_server.go b/internal/msggateway/hub_server.go index 7350cac72..6f0660f36 100644 --- a/internal/msggateway/hub_server.go +++ b/internal/msggateway/hub_server.go @@ -5,6 +5,7 @@ import ( "github.com/OpenIMSDK/Open-IM-Server/pkg/common/config" "github.com/OpenIMSDK/Open-IM-Server/pkg/common/constant" + "github.com/OpenIMSDK/Open-IM-Server/pkg/common/log" "github.com/OpenIMSDK/Open-IM-Server/pkg/common/prome" "github.com/OpenIMSDK/Open-IM-Server/pkg/common/tokenverify" "github.com/OpenIMSDK/Open-IM-Server/pkg/discoveryregistry" @@ -90,6 +91,7 @@ func (s *Server) SuperGroupOnlineBatchPushOneMsg(ctx context.Context, req *msgga if !ok { continue } + log.ZDebug(ctx, "SuperGroupOnlineBatchPushOneMsg", "clients", clients) for _, client := range clients { if client != nil { temp := &msggateway.SingleMsgToUserPlatform{ 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 }