blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-25 19:22:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

cache

Browse Source
This commit is contained in:
wangchuxiao 2022-04-28 17:35:19 +08:00
parent 2751a967e8
commit 20f61042fc
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/rpc/cache/cache.go vendored
View File

@ -118,7 +118,7 @@ func updateAllFriendToCache(userList []db.User) error {
log.NewError("0", utils.GetSelfFuncName(), err.Error())
continue
}
if err := db.DB.AddFriendToCache(user.UserID, friendIDList); err != nil {
if err := db.DB.AddFriendToCache(user.UserID, friendIDList...); err != nil {
log.NewError("0", utils.GetSelfFuncName(), err.Error())
}
}

10
pkg/common/db/redisModel.go
View File

@ -181,13 +181,13 @@ func (d *DataBases) GetUserInfoFromCache(userID string) (*pbCommon.UserInfo, err
return userInfo, err
}
func (d *DataBases) AddFriendToCache(userID string, friendIDList ...interface{}) error {
_, err := d.Exec("SADD", friendRelationCache+userID, friendIDList...)
func (d *DataBases) AddFriendToCache(userID string, friendIDList ...string) error {
_, err := d.Exec("SADD", friendRelationCache+userID, redis.Args{}.Add().AddFlat(friendIDList))
return err
}
func (d *DataBases) ReduceFriendToCache(userID string, friendIDList ...interface{}) error {
_, err := d.Exec("SREM", friendRelationCache+userID, friendIDList...)
_, err := d.Exec("SREM", friendRelationCache+userID, redis.Args{}.Add().AddFlat(friendIDList))
return err
}
@ -197,12 +197,12 @@ func (d *DataBases) GetFriendIDListFromCache(userID string) ([]string, error) {
}
func (d *DataBases) AddBlackUserToCache(userID string, blackList ...interface{}) error {
_, err := d.Exec("SADD", blackListCache+userID, blackList...)
_, err := d.Exec("SADD", blackListCache+userID, redis.Args{}.Add().AddFlat(blackList))
return err
}
func (d *DataBases) ReduceBlackUserFromCache(userID string, blackList ...interface{}) error {
_, err := d.Exec("SREM", blackListCache+userID, blackList...)
_, err := d.Exec("SREM", blackListCache+userID, redis.Args{}.Add().AddFlat(blackList))
return err
}