修复缓存接口变动
This commit is contained in:
parent
a6e2814016
commit
c33ca9d24c
2
sys/cache/friend.go
vendored
2
sys/cache/friend.go
vendored
@ -26,7 +26,7 @@ type IFriend interface {
|
|||||||
func (this *Cache) Friend_Update(data *pb.Cache_FriendData) (err error) {
|
func (this *Cache) Friend_Update(data *pb.Cache_FriendData) (err error) {
|
||||||
if err = db.Defsys.Friend_SaveOrUpdate(data); err == nil {
|
if err = db.Defsys.Friend_SaveOrUpdate(data); err == nil {
|
||||||
//更新缓存
|
//更新缓存
|
||||||
err = this.redis.Set(getRdsFriendKey(data.UserId), data, 0)
|
_, err = this.redis.Set(getRdsFriendKey(data.UserId), data, 0)
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
2
sys/cache/user.go
vendored
2
sys/cache/user.go
vendored
@ -20,7 +20,7 @@ type IUser interface {
|
|||||||
func (this *Cache) Update(data *pb.Cache_UserData) (err error) {
|
func (this *Cache) Update(data *pb.Cache_UserData) (err error) {
|
||||||
err = db.Defsys.User_Update(data.UserData)
|
err = db.Defsys.User_Update(data.UserData)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
err = this.redis.Set(fmt.Sprintf(Redis_UserCache, data.UserData.Uid), data, -1)
|
_, err = this.redis.Set(fmt.Sprintf(Redis_UserCache, data.UserData.Uid), data, -1)
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user