This commit is contained in:
aozhiwei 2020-06-16 15:39:50 +08:00
parent 12e6f6d7fb
commit c4913f6fdb
5 changed files with 71 additions and 0 deletions

View File

@ -1,6 +1,10 @@
#include "precompile.h"
#include <a8/openssl.h>
#include "cachemgr.h"
#include "app.h"
#include "jsondatamgr.h"
void CacheMgr::Init()
{
@ -14,7 +18,20 @@ void CacheMgr::UnInit()
void CacheMgr::_SS_IM_UserOnline(f8::MsgHdr& hdr, const ss::SS_IM_UserOnline& msg)
{
for (auto& user_info : msg.user_infos()) {
unsigned int code = a8::openssl::Crc32
(
(unsigned char*)user_info.base_data().account_id().data(),
user_info.base_data().account_id().size()
);
int instance_id = code % JsonDataMgr::Instance()->GetMasterSvrNum() + 1;
if (App::Instance()->instance_id == instance_id) {
Friend* friend_data = GetFriendData(user_info.base_data().account_id());
if (friend_data) {
}
}
}
}
void CacheMgr::_SS_IM_UserOffline(f8::MsgHdr& hdr, const ss::SS_IM_UserOffline& msg)

View File

@ -39,3 +39,8 @@ std::shared_ptr<a8::XObject> JsonDataMgr::GetConf()
}
return masterserver_cluster_json_[App::Instance()->instance_id - 1];
}
int JsonDataMgr::GetMasterSvrNum()
{
return masterserver_cluster_json_.Size();
}

View File

@ -11,6 +11,7 @@ class JsonDataMgr : public a8::Singleton<JsonDataMgr>
void UnInit();
std::shared_ptr<a8::XObject> GetConf();
int GetMasterSvrNum();
std::string ip;
int listen_port = 0;

View File

@ -0,0 +1,26 @@
#include "precompile.h"
#include "typeconvert.h"
#include "cs_proto.pb.h"
#include "ss_proto.pb.h"
void TypeConvert::Convert(const BaseUserData& base_data, ss::MFBaseUserDataDB& base_data_pb)
{
}
void TypeConvert::Convert(const ss::MFBaseUserDataDB& base_data_pb, const BaseUserData& base_data)
{
}
void TypeConvert::Convert(const BaseUserData& base_data, cs::MFBaseUserData& base_data_pb)
{
}
void TypeConvert::Convert(const UserTempCustomData& temp_custom_data,
cs::MFUserTempCustomData& tmpe_custom_data_pb)
{
}

View File

@ -0,0 +1,22 @@
#pragma once
namespace cs
{
class MFBaseUserData;
class MFUserTempCustomData;
}
namespace ss
{
class MFBaseUserDataDB;
}
class TypeConvert
{
public:
static void Convert(const BaseUserData& base_data, ss::MFBaseUserDataDB& base_data_pb);
static void Convert(const ss::MFBaseUserDataDB& base_data_pb, const BaseUserData& base_data);
static void Convert(const BaseUserData& base_data, cs::MFBaseUserData& base_data_pb);
static void Convert(const UserTempCustomData& temp_custom_data,
cs::MFUserTempCustomData& tmpe_custom_data_pb);
};