diff --git a/pkg/common/db/newRedisModel.go b/pkg/common/db/newRedisModel.go index a62f14cc7..9ef4f1ec4 100644 --- a/pkg/common/db/newRedisModel.go +++ b/pkg/common/db/newRedisModel.go @@ -31,12 +31,8 @@ func (d *DataBases) NewSetMessageToCache(msgList []*pbChat.MsgDataToMQ, uid stri } log2.NewDebug(operationID, "convert map is ", s) fmt.Println("ts", s) - m := make(map[string]interface{}) - for k, v := range s { - m[k] = v - } - //err = d.rdb.HMSet(context.Background(), key, m).Err() - err = d.rdb.HMSet(context.Background(), "12", map[string]interface{}{"1": 2, "343": false}).Err() + err = d.rdb.HMSet(context.Background(), key, s).Err() + //err = d.rdb.HMSet(context.Background(), "12", map[string]interface{}{"1": 2, "343": false}).Err() if err != nil { return err log2.NewWarn(operationID, utils.GetSelfFuncName(), "redis failed", "args:", key, *msg, uid, s, err.Error()) diff --git a/pkg/common/db/redisModel_test.go b/pkg/common/db/redisModel_test.go index 4832dbb09..4e3b0213d 100644 --- a/pkg/common/db/redisModel_test.go +++ b/pkg/common/db/redisModel_test.go @@ -55,7 +55,6 @@ func Test_NewSetMessageToCache(t *testing.T) { msg.MsgData = &data messageList := []*pbChat.MsgDataToMQ{&msg} err := DB.NewSetMessageToCache(messageList, uid, "cacheTest") - //err := DB.rdb.HMSet(context.Background(), "12", map[string]interface{}{"1": 2}).Err() assert.Nil(t, err) }