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

1

Browse Source
This commit is contained in:
aozhiwei 2020-09-27 19:25:26 +08:00
parent ddd47200e3
commit f84cfa8dd4
2 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/imserver/player.h
View File

@ -132,12 +132,13 @@ class Player
long long GuildId(); long long GuildId();
int GetFriendNum(); int GetFriendNum();
void SaveToDB(a8::XParams param, f8::AsyncDBOnOkFunc on_ok, f8::AsyncDBOnErrorFunc on_error);
private: private:
void FillFriendList(::google::protobuf::RepeatedPtrField< ::cs::MFUserInfo >* friend_list); void FillFriendList(::google::protobuf::RepeatedPtrField< ::cs::MFUserInfo >* friend_list);
void FillBlackList(::google::protobuf::RepeatedPtrField< ::cs::MFUserInfo >* black_list); void FillBlackList(::google::protobuf::RepeatedPtrField< ::cs::MFUserInfo >* black_list);
void ForwardGroupCMMsg(f8::MsgHdr& hdr, long long hash_code); void ForwardGroupCMMsg(f8::MsgHdr& hdr, long long hash_code);
void ForwardGuildCMMsg(f8::MsgHdr& hdr, long long guild_id); void ForwardGuildCMMsg(f8::MsgHdr& hdr, long long guild_id);
void SaveToDB(a8::XParams param, f8::AsyncDBOnOkFunc on_ok, f8::AsyncDBOnErrorFunc on_error);
void FillApplyList(const cs::MFPaging& paging, cs::SMFriendApplyList& respmsg); void FillApplyList(const cs::MFPaging& paging, cs::SMFriendApplyList& respmsg);
void MarkDirty(); void MarkDirty();
void OnDataVersion1Change(); void OnDataVersion1Change();

15
server/imserver/playermgr.cc
View File

@ -207,6 +207,21 @@ void PlayerMgr::_SS_IM_GuildMemberQuitRequest(f8::MsgHdr& hdr, const ss::SS_IM_G
Player* hum = GetPlayerByAccountId(msg.target_id()); Player* hum = GetPlayerByAccountId(msg.target_id());
if (hum) { if (hum) {
hum->UpdateGuildData(0, 0); hum->UpdateGuildData(0, 0);
hum->SaveToDB(a8::XParams()
.SetSender(hdr.socket_handle)
.SetParam1(msg.seqid()),
[] (a8::XParams& param, const f8::DataSet* data_set)
{
int socket_handle = param.sender;
long long seqid = param.param1;
ss::SS_IM_GuildMemberQuitRequest respmsg;
respmsg.set_seqid(seqid);
IMListener::Instance()->SendMsg(socket_handle, respmsg);
},
[] (a8::XParams& param, int error_code, const std::string& error_msg)
{
});
} }
} }