From 11ff251eb2a354d1da1c1d7c566a767d5905bb71 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 15 Apr 2024 11:19:43 +0800 Subject: [PATCH] 1 --- server/imserver/cache/cachemgr.go | 4 ++++ server/imserver/common/types.go | 1 + server/imserver/player/player.go | 12 +++++++++++- 3 files changed, 16 insertions(+), 1 deletion(-) diff --git a/server/imserver/cache/cachemgr.go b/server/imserver/cache/cachemgr.go index 0f5945b4..0030ec94 100644 --- a/server/imserver/cache/cachemgr.go +++ b/server/imserver/cache/cachemgr.go @@ -179,6 +179,10 @@ func (this *cacheMgr) AsyncSearch(sinceId int64, q string, pbUsers *[]*cs.MFUser }) } +func (this *cacheMgr) AsyncRecommendList(int32, string, *[]*cs.MFUser, func(int32, string)) { + +} + func (this *cacheMgr) getUser(accountId string) *userProfile { if val, ok := this.userHash[accountId]; ok { return val diff --git a/server/imserver/common/types.go b/server/imserver/common/types.go index 679942f2..b89360da 100644 --- a/server/imserver/common/types.go +++ b/server/imserver/common/types.go @@ -108,6 +108,7 @@ type CacheMgr interface { AsyncGetUsersAndFillMFUser([]string, *[]*cs.MFUser, func(int32, string)) AsyncGetUsersAndFillMFGuildMember([]string, *[]*cs.MFGuildMember, func(int32, string)) AsyncSearch(int64, string, *[]*cs.MFUser, func(int32, string, int64)) + AsyncRecommendList(int32, string, *[]*cs.MFUser, func(int32, string)) } type DbLogMgr interface { diff --git a/server/imserver/player/player.go b/server/imserver/player/player.go index 2b07ffe5..b691dc7a 100644 --- a/server/imserver/player/player.go +++ b/server/imserver/player/player.go @@ -324,7 +324,17 @@ func (this *player) CMInviteFriendMsg(hdr *f5.MsgHdr, msg *cs.CMInviteFriendMsg) func (this *player) CMRecommendList(hdr *f5.MsgHdr, msg *cs.CMRecommendList) { rspMsg := new(cs.SMRecommendList) - this.SendMsg(rspMsg) + GetCacheMgr().AsyncRecommendList( + msg.GetType(), + this.GetAccountId(), + &rspMsg.Users, + func (errCode int32, errMsg string) { + if errCode != 0 { + this.SendMsg(rspMsg.Err(500, "server internal error")) + return + } + this.SendMsg(rspMsg) + }) } func (this *player) CMSendChatMsg(hdr *f5.MsgHdr, msg *cs.CMSendChatMsg) {