134 lines
3.5 KiB
C++
134 lines
3.5 KiB
C++
#include "precompile.h"
|
|
|
|
#include <a8/timer.h>
|
|
|
|
#include "asynctaskmgr.h"
|
|
#include "app.h"
|
|
#include "player.h"
|
|
#include "playermgr.h"
|
|
|
|
#include "cs_proto.pb.h"
|
|
#include "ss_proto.pb.h"
|
|
|
|
struct QueryUserStatusTask
|
|
{
|
|
long long seqid = 0;
|
|
std::string account_id;
|
|
int socket_handle = 0;
|
|
Player* hum = nullptr;
|
|
std::map<std::string, bool> users;
|
|
|
|
void Done()
|
|
{
|
|
if (PlayerMgr::Instance()->GetPlayerByAccountId(account_id) != hum) {
|
|
return;
|
|
}
|
|
if (hum->socket_handle != socket_handle) {
|
|
return;
|
|
}
|
|
cs::SMQueryUserStatus msg;
|
|
for (auto& pair : users) {
|
|
cs::MFUserStatus* user = msg.add_status_list();
|
|
user->set_account_id(pair.first);
|
|
user->set__online(pair.second ? 1 : 0);
|
|
}
|
|
hum->SendMsg(msg);
|
|
}
|
|
};
|
|
|
|
struct RecommandFriendTask
|
|
{
|
|
|
|
};
|
|
|
|
void AsyncTaskMgr::Init()
|
|
{
|
|
|
|
}
|
|
|
|
void AsyncTaskMgr::UnInit()
|
|
{
|
|
|
|
}
|
|
|
|
void AsyncTaskMgr::CreateQueryUserStatusTask(Player* hum, std::vector<std::string>& account_ids)
|
|
{
|
|
QueryUserStatusTask* task = new QueryUserStatusTask();
|
|
task->account_id = hum->AccountId();
|
|
task->socket_handle = hum->socket_handle;
|
|
task->hum = hum;
|
|
{
|
|
ss::SS_IM_QueryUserOnlineState msg;
|
|
hum->FillIMMsgConext(msg.mutable_context());
|
|
for (auto& account_id : account_ids) {
|
|
msg.add_account_ids(account_id);
|
|
}
|
|
hum->SendSSMsg(hum->myself, msg);
|
|
|
|
for (auto& account_id : account_ids) {
|
|
task->users[account_id] = false;
|
|
}
|
|
task->seqid = msg.context().seqid();
|
|
query_user_status_tasks_[task->seqid] = task;
|
|
}
|
|
a8::Timer::Instance()->AddDeadLineTimer
|
|
(
|
|
200,
|
|
a8::XParams()
|
|
.SetSender(task),
|
|
[] (const a8::XParams& param)
|
|
{
|
|
QueryUserStatusTask* task = (QueryUserStatusTask*)param.sender.GetUserData();
|
|
task->Done();
|
|
},
|
|
[] (const a8::XParams& param)
|
|
{
|
|
QueryUserStatusTask* task = (QueryUserStatusTask*)param.sender.GetUserData();
|
|
AsyncTaskMgr::Instance()->RemoveQueryUserStatusTask(task->seqid);
|
|
}
|
|
);
|
|
}
|
|
|
|
void AsyncTaskMgr::_SS_IM_PushUserOnlineState(f8::MsgHdr& hdr, const ss::SS_IM_PushUserOnlineState& msg)
|
|
{
|
|
QueryUserStatusTask* task = GetQueryUserStatusTask(msg.context().seqid());
|
|
if (task) {
|
|
for (auto& user : msg.user_infos()) {
|
|
if (task->users.find(user.base_data().account_id()) !=
|
|
task->users.end()) {
|
|
task->users[user.base_data().account_id()] = true;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
QueryUserStatusTask* AsyncTaskMgr::GetQueryUserStatusTask(long long seqid)
|
|
{
|
|
auto itr = query_user_status_tasks_.find(seqid);
|
|
return itr != query_user_status_tasks_.end() ? itr->second : nullptr;
|
|
}
|
|
|
|
void AsyncTaskMgr::RemoveQueryUserStatusTask(long long seqid)
|
|
{
|
|
auto itr = query_user_status_tasks_.find(seqid);
|
|
if (itr != query_user_status_tasks_.end()) {
|
|
delete itr->second;
|
|
query_user_status_tasks_.erase(itr);
|
|
}
|
|
}
|
|
|
|
RecommandFriendTask* AsyncTaskMgr::GetRecommandFriendTask(long long seqid)
|
|
{
|
|
auto itr = recommand_friend_tasks_.find(seqid);
|
|
return itr != recommand_friend_tasks_.end() ? itr->second : nullptr;
|
|
}
|
|
|
|
void AsyncTaskMgr::RemoveRecommandFriendTask(long long seqid)
|
|
{
|
|
auto itr = recommand_friend_tasks_.find(seqid);
|
|
if (itr != recommand_friend_tasks_.end()) {
|
|
delete itr->second;
|
|
recommand_friend_tasks_.erase(itr);
|
|
}
|
|
}
|