msg cache

3 years ago · 9dfef527a3
parent df51c8b9a4
commit 9dfef527a3
1 changed files with 2 additions and 1 deletions
--- 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)
 		}
 	}