From 51aeed0c1ccf6a507b21577e869b42c760f8bd73 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Sun, 27 Sep 2020 20:46:24 +0800 Subject: [PATCH] 1 --- server/imserver/dbhelper.cc | 21 ++++++++++++++++++++- server/imserver/player.cc | 4 ---- 2 files changed, 20 insertions(+), 5 deletions(-) diff --git a/server/imserver/dbhelper.cc b/server/imserver/dbhelper.cc index d0f2378..8d75388 100644 --- a/server/imserver/dbhelper.cc +++ b/server/imserver/dbhelper.cc @@ -128,7 +128,22 @@ void DBHelper::ConfirmGuild(Player* hum, long long guild_id) Player* hum = PlayerMgr::Instance()->GetPlayerByAccountId(param.sender.GetString()); if (hum) { hum->UpdateGuildData(param.param1, kGuildOwner); - hum->SaveToDB(a8::XParams(), nullptr, nullptr); + hum->SaveToDB + (a8::XParams() + .SetSender(hum->AccountId()), + [] (a8::XParams& param, const f8::DataSet* data_set) + { + Player* hum = PlayerMgr::Instance()->GetPlayerByAccountId(param.sender.GetString()); + if (hum) { + cs::SMGuildCreate respmsg; + hum->SendMsg(respmsg); + } + }, + [] (a8::XParams& param, int error_code, const std::string& error_msg) + { + + } + ); std::string ip; int port = 0; @@ -157,6 +172,10 @@ void DBHelper::ConfirmGuild(Player* hum, long long guild_id) }; + std::string guild_data; + { + + } a8::XObject conn_info = DBEngine::Instance()->GetConnInfo(guild_id); DBEngine::Instance()->ExecAsyncScript ( diff --git a/server/imserver/player.cc b/server/imserver/player.cc index e72ddf6..a0d9c17 100644 --- a/server/imserver/player.cc +++ b/server/imserver/player.cc @@ -672,15 +672,11 @@ void Player::_CMGuildCreate(f8::MsgHdr& hdr, const cs::CMGuildCreate& msg) Player* hum = PlayerMgr::Instance()->GetPlayerBySocket(msg_context->socket_handle); if (hum && hum->AccountId() == msg_context->account_id) { - cs::SMGuildCreate respmsg; - respmsg.set_errcode(data.At("errcode")->AsXValue()); - respmsg.set_errmsg(data.At("errmsg")->AsXValue()); if (data.At("errcode") == 0) { DBHelper::Instance()->ConfirmGuild(hum, msg_context->guild_id); } else { hum->ShowErrorMsg(data.At("errmsg")->AsXValue().GetString()); } - hum->SendMsg(respmsg); } A8_SAFE_DELETE(msg_context);