From 628984c09d27bf03a7bc1dbd886ec617f84daf13 Mon Sep 17 00:00:00 2001
From: Gordon <1432970085@qq.com>
Date: Tue, 31 May 2022 14:25:52 +0800
Subject: [PATCH] redis replace go redis

---
 pkg/common/db/newRedisModel.go   |  2 +-
 pkg/common/db/redisModel_test.go | 20 +++++++++++---------
 2 files changed, 12 insertions(+), 10 deletions(-)

diff --git a/pkg/common/db/newRedisModel.go b/pkg/common/db/newRedisModel.go
index 1cbceac01..9aab4ea14 100644
--- a/pkg/common/db/newRedisModel.go
+++ b/pkg/common/db/newRedisModel.go
@@ -31,7 +31,7 @@ func (d *DataBases) NewSetMessageToCache(msgList []*pbChat.MsgDataToMQ, uid stri
 		}
 		log2.NewDebug(operationID, "convert map is ", s)
 		fmt.Println("ts", s)
-		err = d.rdb.HMSet(ctx, key, s).Err()
+		err = d.rdb.HMSet(context.Background(), key, s).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 a11f96bcd..4832dbb09 100644
--- a/pkg/common/db/redisModel_test.go
+++ b/pkg/common/db/redisModel_test.go
@@ -1,6 +1,8 @@
 package db
 
 import (
+	pbChat "Open_IM/pkg/proto/chat"
+	server_api_params "Open_IM/pkg/proto/sdk_ws"
 	"context"
 	"flag"
 	"fmt"
@@ -45,15 +47,15 @@ func Test_HGetAll(t *testing.T) {
 }
 
 func Test_NewSetMessageToCache(t *testing.T) {
-	//var msg pbChat.MsgDataToMQ
-	//var data server_api_params.MsgData
-	//uid := "test_uid"
-	//data.Seq = 11
-	//data.ClientMsgID = "23jwhjsdf"
-	//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()
+	var msg pbChat.MsgDataToMQ
+	var data server_api_params.MsgData
+	uid := "test_uid"
+	data.Seq = 11
+	data.ClientMsgID = "23jwhjsdf"
+	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)
 
 }