diff --git a/internal/rpc/msg/query_msg.go b/internal/rpc/msg/query_msg.go index 31a088354..f8a2afc7c 100644 --- a/internal/rpc/msg/query_msg.go +++ b/internal/rpc/msg/query_msg.go @@ -5,11 +5,13 @@ import ( "Open_IM/pkg/common/log" promePkg "Open_IM/pkg/common/prometheus" "Open_IM/pkg/proto/msg" + "Open_IM/pkg/utils" "context" go_redis "github.com/go-redis/redis/v8" ) func (rpc *rpcChat) GetSuperGroupMsg(context context.Context, req *msg.GetSuperGroupMsgReq) (*msg.GetSuperGroupMsgResp, error) { + log.Debug(req.OperationID, utils.GetSelfFuncName(), req.String()) resp := new(msg.GetSuperGroupMsgResp) redisMsgList, failedSeqList, err := commonDB.DB.GetMessageListBySeq(req.GroupID, []uint32{req.Seq}, req.OperationID) if err != nil { @@ -40,6 +42,7 @@ func (rpc *rpcChat) GetSuperGroupMsg(context context.Context, req *msg.GetSuperG resp.MsgData = m } } + log.Debug(req.OperationID, utils.GetSelfFuncName(), resp.String()) return resp, nil }