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-11-23 17:30:39 +08:00
parent 942c62661c
commit f014bcfb72
2 changed files with 0 additions and 49 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
server/imserver/asynctaskmgr.cc
View File

@ -216,54 +216,6 @@ void AsyncTaskMgr::CreateRecommandFriendTask(Player* hum)
); );
} }
void AsyncTaskMgr::CreateNewGuildTask(const ss::MFIMMsgConext& context, const cs::CMGuildCreate& msg)
{
auto on_ok =
[] (a8::XParams& param, const f8::DataSet* data_set)
{
};
auto on_error =
[] (a8::XParams& param, int error_code, const std::string& error_msg)
{
};
CreateGuildTask* task = new CreateGuildTask();
{
task->seqid = App::Instance()->NewSeqId();
task->context = context;
task->msg = msg;
}
std::string guild_id = a8::XValue(context.user_info().base_data().guild_id()).GetString();
long long crc32_code = a8::openssl::Crc32(
(unsigned char*)guild_id.data(),
guild_id.size()
);
a8::XObject conn_info = DBEngine::Instance()->GetConnInfo(crc32_code);
DBEngine::Instance()->ExecAsyncScript
(
conn_info,
"INSERT INTO `guild`(guild_id, guild_name, guild_lv, guild_exp, guild_badge, guild_declaration, "
" guild_status, owner_id, creator_id, guild_data, createtime, modifytime)"
"VALUES(%d, '%s', 1, 0, %d, '%s', '%s', %d, '%s', '%s', %d, %d);",
{
guild_id,
msg.guild_name(),
msg.guild_badge(),
msg.guild_declaration(),
kGuildCreatePending,
context.user_info().base_data().account_id(),
context.user_info().base_data().account_id(),
"",
App::Instance()->nowtime,
App::Instance()->nowtime
},
a8::XParams(),
on_ok,
on_error,
crc32_code
);
}
void AsyncTaskMgr::_SS_IM_PushUserOnlineState(f8::MsgHdr& hdr, const ss::SS_IM_PushUserOnlineState& msg) void AsyncTaskMgr::_SS_IM_PushUserOnlineState(f8::MsgHdr& hdr, const ss::SS_IM_PushUserOnlineState& msg)
{ {
QueryUserStatusTask* task = GetQueryUserStatusTask(msg.context().seqid()); QueryUserStatusTask* task = GetQueryUserStatusTask(msg.context().seqid());

1
server/imserver/asynctaskmgr.h
View File

@ -29,7 +29,6 @@ public:
void CreateQueryUserStatusTask(Player* hum, std::vector<std::string>& account_ids); void CreateQueryUserStatusTask(Player* hum, std::vector<std::string>& account_ids);
void CreateRecommandFriendTask(Player* hum); void CreateRecommandFriendTask(Player* hum);
void CreateNewGuildTask(const ss::MFIMMsgConext& context, const cs::CMGuildCreate& msg);
void _SS_IM_PushUserOnlineState(f8::MsgHdr& hdr, const ss::SS_IM_PushUserOnlineState& msg); void _SS_IM_PushUserOnlineState(f8::MsgHdr& hdr, const ss::SS_IM_PushUserOnlineState& msg);
void _SS_IM_RandomUsersResponse(f8::MsgHdr& hdr, const ss::SS_IM_RandomUsersResponse& msg); void _SS_IM_RandomUsersResponse(f8::MsgHdr& hdr, const ss::SS_IM_RandomUsersResponse& msg);