diff --git a/internal/rpc/msg/query_msg.go b/internal/rpc/msg/query_msg.go index 66f2f0810..e69de29bb 100644 --- a/internal/rpc/msg/query_msg.go +++ b/internal/rpc/msg/query_msg.go @@ -1,37 +0,0 @@ -package msg - -//func (rpc *msgServer) 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 { -// if err != go_redis.Nil { -// promePkg.PromeAdd(promePkg.MsgPullFromRedisFailedCounter, len(failedSeqList)) -// log.Error(req.OperationID, "get message from redis exception", err.Error(), failedSeqList) -// } else { -// log.Debug(req.OperationID, "get message from redis is nil", failedSeqList) -// } -// msgList, err1 := commonDB.DB.GetSuperGroupMsgBySeqListMongo(req.GroupID, failedSeqList, req.OperationID) -// if err1 != nil { -// promePkg.PromeAdd(promePkg.MsgPullFromMongoFailedCounter, len(failedSeqList)) -// log.Error(req.OperationID, "GetSuperGroupMsg data error", req.String(), err.Error()) -// resp.ErrCode = 201 -// resp.ErrMsg = err.Error() -// return resp, nil -// } else { -// promePkg.PromeAdd(promePkg.MsgPullFromMongoSuccessCounter, len(msgList)) -// redisMsgList = append(redisMsgList, msgList...) -// for _, m := range msgList { -// resp.MsgData = m -// } -// -// } -// } else { -// promePkg.PromeAdd(promePkg.MsgPullFromRedisSuccessCounter, len(redisMsgList)) -// for _, m := range redisMsgList { -// resp.MsgData = m -// } -// } -// log.Debug(req.OperationID, utils.GetSelfFuncName(), resp.String()) -// return resp, nil -//}