From 9dfef527a34aff55313021130bfd8491f9d7c18c Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Tue, 24 May 2022 17:09:02 +0800 Subject: [PATCH] msg cache --- pkg/common/db/redisModel.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/common/db/redisModel.go b/pkg/common/db/redisModel.go index 93ac28d80..2e1363b4d 100644 --- a/pkg/common/db/redisModel.go +++ b/pkg/common/db/redisModel.go @@ -273,9 +273,10 @@ func (d *DataBases) SetMessageToCache(msgList []*pbChat.MsgDataToMQ, uid string) log2.NewWarn("", utils.GetSelfFuncName(), "Pb2Map failed", *msg.MsgData, uid, err.Error()) continue } + log2.NewDebug("", "m", m) _, err = d.Exec("hmset", key, redis.Args{}.Add().AddFlat(m)...) if err != nil { - log2.NewWarn("", utils.GetSelfFuncName(), "redis failed", "args:", key, *msg, uid) + log2.NewWarn("", utils.GetSelfFuncName(), "redis failed", "args:", key, *msg, uid, m) failedList = append(failedList, *msg) } }