From 57967835bd7f83103d5ec6c1986c696d6bba7d5d Mon Sep 17 00:00:00 2001 From: Gordon <1432970085@qq.com> Date: Tue, 24 May 2022 18:40:57 +0800 Subject: [PATCH] redis add get message --- pkg/common/db/redisModel.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/pkg/common/db/redisModel.go b/pkg/common/db/redisModel.go index e98fe1ce0..fb5241dd7 100644 --- a/pkg/common/db/redisModel.go +++ b/pkg/common/db/redisModel.go @@ -266,14 +266,17 @@ func (d *DataBases) GetGroupMemberIDListFromCache(groupID string) ([]string, err } func (d *DataBases) GetMessageListBySeq(userID string, seqList []uint32, operationID string) (seqMsg []*pbCommon.MsgData, failedSeqList []uint32, errResult error) { for _, v := range seqList { + //MESSAGE_CACHE:169.254.225.224_reliability1653387820_0_1 key := messageCache + userID + "_" + strconv.Itoa(int(v)) - result, err := redis.String(d.Exec("HGETALL", key)) + + result, err := redis.Bytes(d.Exec("HGETALL", key)) if err != nil { errResult = err failedSeqList = append(failedSeqList, v) + log2.NewWarn(operationID, "redis get message error:", err.Error(), v) } else { msg := pbCommon.MsgData{} - err = json.Unmarshal([]byte(result), &msg) + err = json.Unmarshal(result, &msg) if err != nil { errResult = err failedSeqList = append(failedSeqList, v)