diff --git a/service/imService.go b/service/imService.go index 71c21d0..eca1aed 100644 --- a/service/imService.go +++ b/service/imService.go @@ -2,7 +2,6 @@ package service import ( "errors" - "fmt" "strconv" "time" "videoplayer/dao" @@ -19,7 +18,6 @@ func CreateGeneralMessageService(from_id, to_id, msg_type, group_id int, content //判断是否是好友,判断是否存在缓存,不存在则设置缓存,存在则判断是否是好友 if worker.IsContainKey("user_"+strconv.Itoa(from_id)+"_friends") == false { //设置好友缓存 - fmt.Println("设置好友缓存:", from_id, to_id) isSuccess := SetFriendCache(from_id) //设置失败,直接查询数据库 if !isSuccess { @@ -320,6 +318,6 @@ func SetGroupCache(group_id int) bool { for _, user := range users { ids = append(ids, strconv.Itoa(user.UserID)) } - res := worker.SetRedisSet("group_"+strconv.Itoa(group_id)+"_groups", ids, time.Hour*12) + res := worker.SetRedisSet("group_"+strconv.Itoa(group_id)+"_users", ids, time.Hour*12) return res }