server/game2006go
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2024-04-15 11:19:43 +08:00
parent ac609a53c6
commit 11ff251eb2
3 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/imserver/cache/cachemgr.go vendored
View File

@ -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 { func (this *cacheMgr) getUser(accountId string) *userProfile {
if val, ok := this.userHash[accountId]; ok { if val, ok := this.userHash[accountId]; ok {
return val return val

1
server/imserver/common/types.go
View File

@ -108,6 +108,7 @@ type CacheMgr interface {
AsyncGetUsersAndFillMFUser([]string, *[]*cs.MFUser, func(int32, string)) AsyncGetUsersAndFillMFUser([]string, *[]*cs.MFUser, func(int32, string))
AsyncGetUsersAndFillMFGuildMember([]string, *[]*cs.MFGuildMember, func(int32, string)) AsyncGetUsersAndFillMFGuildMember([]string, *[]*cs.MFGuildMember, func(int32, string))
AsyncSearch(int64, string, *[]*cs.MFUser, func(int32, string, int64)) AsyncSearch(int64, string, *[]*cs.MFUser, func(int32, string, int64))
AsyncRecommendList(int32, string, *[]*cs.MFUser, func(int32, string))
} }
type DbLogMgr interface { type DbLogMgr interface {

10
server/imserver/player/player.go
View File

@ -324,7 +324,17 @@ func (this *player) CMInviteFriendMsg(hdr *f5.MsgHdr, msg *cs.CMInviteFriendMsg)
func (this *player) CMRecommendList(hdr *f5.MsgHdr, msg *cs.CMRecommendList) { func (this *player) CMRecommendList(hdr *f5.MsgHdr, msg *cs.CMRecommendList) {
rspMsg := new(cs.SMRecommendList) rspMsg := new(cs.SMRecommendList)
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) this.SendMsg(rspMsg)
})
} }
func (this *player) CMSendChatMsg(hdr *f5.MsgHdr, msg *cs.CMSendChatMsg) { func (this *player) CMSendChatMsg(hdr *f5.MsgHdr, msg *cs.CMSendChatMsg) {