liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

升级聊天私聊频道为跨服系统

Browse Source
This commit is contained in:
liwei1dao 2022-10-19 10:08:51 +08:00
parent fd572e6f92
commit 1a3030da01
2 changed files with 27 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
modules/chat/api_send.go
View File

@ -87,26 +87,25 @@ func (this *apiComp) Send(session comm.IUserSession, req *pb.ChatSendReq) (code
return return
} }
break break
case pb.ChatChannel_Private: // case pb.ChatChannel_Private:
msg.Ruid = req.TargetId // msg.Ruid = req.TargetId
if err = this.module.PushUser(msg); err != nil { // if err = this.module.PushUser(msg); err != nil {
code = pb.ErrorCode_DBError // code = pb.ErrorCode_DBError
return // return
} // }
session.SendMsg(string(this.module.GetType()), "message", &pb.ChatMessagePush{Chat: msg}) // session.SendMsg(string(this.module.GetType()), "message", &pb.ChatMessagePush{Chat: msg})
break // break
// case pb.ChatChannel_CrossServer: // case pb.ChatChannel_CrossServer:
// if userexpand, err = this.module.ModuleUser.GetUserExpand(session.GetUserId()); err != nil { // if userexpand, err = this.module.ModuleUser.GetUserExpand(session.GetUserId()); err != nil {
// code = pb.ErrorCode_DBError // code = pb.ErrorCode_DBError
// return // return
// } // }
// msg.ChannelId = userexpand.Chatchannel //指定频道 // msg.ChannelId = userexpand.Chatchannel //指定频道
// if err = this.module.modelChat.addChatMsg(fmt.Sprintf("%s-%d", crosschatkey, userexpand.Chatchannel), int64(max_chat), msg); err != nil { // if err = this.module.modelChat.addChatMsg(fmt.Sprintf("%s-%d", crosschatkey, userexpand.Chatchannel), int64(max_chat), msg); err != nil {
// code = pb.ErrorCode_DBError // code = pb.ErrorCode_DBError
// return // return
// } // }
// this.module.PushToUsers(userexpand.Chatchannel, msg) // this.module.PushToUsers(userexpand.Chatchannel, msg)
break
default: default:
code = pb.ErrorCode_ReqParameterError code = pb.ErrorCode_ReqParameterError
this.module.Errorf("getlist no support channel:%d ", req.Channel) this.module.Errorf("getlist no support channel:%d ", req.Channel)

8
modules/chat/api_sendcross.go
View File

@ -87,6 +87,14 @@ func (this *apiComp) SendCross(session comm.IUserSession, req *pb.ChatSendCrossR
// } // }
// session.SendMsg(string(this.module.GetType()), "message", &pb.ChatMessagePush{Chat: msg}) // session.SendMsg(string(this.module.GetType()), "message", &pb.ChatMessagePush{Chat: msg})
// break // break
case pb.ChatChannel_Private:
msg.Ruid = req.TargetId
if err = this.module.PushUser(msg); err != nil {
code = pb.ErrorCode_DBError
return
}
session.SendMsg(string(this.module.GetType()), "message", &pb.ChatMessagePush{Chat: msg})
break
case pb.ChatChannel_CrossServer: case pb.ChatChannel_CrossServer:
if userexpand, err = this.module.ModuleUser.GetUserExpand(session.GetUserId()); err != nil { if userexpand, err = this.module.ModuleUser.GetUserExpand(session.GetUserId()); err != nil {
code = pb.ErrorCode_DBError code = pb.ErrorCode_DBError