1

platformapi/mtwmapi/im_test.go

@@ -31,6 +31,44 @@ var rdb = redis.NewClient(&redis.Options{
 	DB:       0,
 })
 
+type UserMessageList struct {
+	VendorID      int    `json:"vendorID"`      //平台品牌 1-美团 3-饿了么
+	UserID        string `json:"userID"`        //用户ID
+	NewMessageNum int    `json:"NewMessageNum"` //新消息数量
+	LatestMsg     string `json:"latestMsg"`     //最新一条消息
+	LatestTime    int    `json:"latestTime"`    //最新一条消息发送时间
+}
+
+//测试redis的set
+func TestRdbSet(t *testing.T) {
+	retVal := UserMessageList{}
+	key := "testAddSet"
+	ans := make(map[int][]interface{}, 0)
+	val := []string{"{\"vendorID\":1,\"userID\":\"11555094096\",\"NewMessageNum\":0,\"latestMsg\":\"e3nfwts/Ibi9y+kbb28FFIfoNRDLajJQzUT0DpTkWtY=\",\"latestTime\":1694163546}", "{\"vendorID\":2,\"userID\":\"11555094096\",\"NewMessageNum\":0,\"latestMsg\":\"e3nfwts/Ibi9y+kbb28FFIfoNRDLajJQzUT0DpTkWtY=\",\"latestTime\":1694684389}", "{\"vendorID\":3,\"userID\":\"11555094096\",\"NewMessageNum\":0,\"latestMsg\":\"e3nfwts/Ibi9y+kbb28FFIfoNRDLajJQzUT0DpTkWtY=\",\"latestTime\":1694684389}"}
+	for k, v := range val {
+		_ = json.Unmarshal([]byte(v), &retVal)
+		if time.Now().Unix()-int64(retVal.LatestTime) < 3600*6 {
+			ans[k] = append(ans[k], v)
+			//rdb.SAdd(key, v)
+		} else {
+			continue
+		}
+	}
+	fmt.Printf("all 1=%s", rdb.SMembers(key).Val())
+
+	//for _, v := range rdb.SMembers(key).Val() {
+	//	_ = json.Unmarshal([]byte(v), &retVal)
+	//	if time.Now().Unix()-int64(retVal.LatestTime) < 3600*6 {
+	//		//ans[k] = append(ans[k], v)
+	//		rdb.SAdd(key, v)
+	//	} else {
+	//		rdb.SRem(key, v)
+	//	}
+	//}
+	//fmt.Printf("all 2=%s", rdb.SMembers(key).Val())
+	//fmt.Printf("ans=%s", utils.Format4Output(ans, false))
+}
+
 func TestSendMsg(t *testing.T) {
 	data := PushContentReq{
 		AppID:      589,