737 lines
21 KiB
C++
737 lines
21 KiB
C++
#include "StdAfx.h"
|
||
#include "../base/Container.hpp"
|
||
using namespace jxInterSrvComm::DbServerProto; //数据服务器和逻辑服务器的命令码
|
||
|
||
CTopTitleMgr::CTopTitleMgr()
|
||
{
|
||
m_nDelay = 0;
|
||
m_nRefCount = 0;
|
||
m_nUpdateTime = 0;
|
||
}
|
||
|
||
CTopTitleMgr::~CTopTitleMgr()
|
||
{
|
||
for (int i=0; i < MAX_RANK_COUNT;i++ )
|
||
{
|
||
RANKUSERLIST& list = m_rankActorList[i];
|
||
list.empty();
|
||
}
|
||
m_RawRankList.empty();
|
||
m_CsRankList.empty();
|
||
}
|
||
|
||
|
||
bool CTopTitleMgr::Initialize()
|
||
{
|
||
//LoadCsRank();
|
||
return true;
|
||
}
|
||
|
||
void CTopTitleMgr::RunOne(TICKCOUNT nCurrTickCount)
|
||
{
|
||
// int nNowTime = time(NULL);
|
||
// if (nNowTime >= m_nUpdateTime)
|
||
// {
|
||
// //UpdateRawRankList();
|
||
// //UpdateVocNpcStatue(stRsVocation);
|
||
// UpdateBaseRankData();
|
||
// Load();
|
||
// m_nUpdateTime = nNowTime + 60*10;
|
||
// }
|
||
}
|
||
|
||
// void CTopTitleMgr::Load()
|
||
// {
|
||
// CDataClient* pDbClient = GetLogicServer()->GetDbClient();
|
||
// if (pDbClient->connected())
|
||
// {
|
||
// CDataPacket& DataPacket = pDbClient->allocProtoPacket(jxInterSrvComm::DbServerProto::dcLoadBaseRank);
|
||
// int nServerId = GetLogicServer()->GetServerIndex();
|
||
// DataPacket << nServerId << nServerId;
|
||
// GetLogicServer()->GetDbClient()->flushProtoPacket(DataPacket);
|
||
// }
|
||
// }
|
||
|
||
|
||
// void CTopTitleMgr::UpdateBaseRankData()
|
||
// {
|
||
// // 增加头衔排行榜引用计数
|
||
// AddTopRankRef();
|
||
|
||
// CDataClient* pDbClient = GetLogicServer()->GetDbClient();
|
||
// if (pDbClient->connected())
|
||
// {
|
||
// CDataPacket &DataPacket =pDbClient->allocProtoPacket(jxInterSrvComm::DbServerProto::dcSaveBaseRank);
|
||
// int nServerId = GetLogicServer()->GetServerIndex();
|
||
// DataPacket << nServerId << nServerId;
|
||
// GetLogicServer()->GetDbClient()->flushProtoPacket(DataPacket);
|
||
// }
|
||
// }
|
||
|
||
void CTopTitleMgr::maintainTopTitle()
|
||
{
|
||
// const int FIRST_TOP = 1; //排行榜第一名
|
||
// int nRankIndex = 0;
|
||
// int nTitle =0;
|
||
// int nJobTipIndex = 0;
|
||
// for (int i =0; i< MAX_TOP_TITLE_COUNT; i++)
|
||
// {
|
||
// if (i ==0)
|
||
// {
|
||
// nRankIndex = rtMagicianLevel;//第一法师
|
||
// nTitle = MAX_TOP_TITLE_MASTER;
|
||
// nJobTipIndex = tpJobNameMagician;
|
||
// }
|
||
// else if (i == 1)
|
||
// {
|
||
// nRankIndex = rtWarriorLevel;//第一战士
|
||
// nTitle = MAX_TOP_TITLE_WARRIOR;
|
||
// nJobTipIndex = tpJobNameWarrior;
|
||
// }
|
||
// else if (i == 2)
|
||
// {
|
||
// nRankIndex = rtWizardLevel;//第一道士
|
||
// nTitle = MAX_TOP_TITLE_WIZARD;
|
||
// nJobTipIndex = tpJobNameWizard;
|
||
// }
|
||
|
||
// unsigned int nOldActorId = (unsigned int)GetGlobalLogicEngine()->GetMiscMgr().GetSystemStaticVarValue(szTopTitleRand[i],0);
|
||
// PTOPTITLERANKINFO pRankInfo = GetActorInfoByCsRank(nRankIndex,FIRST_TOP);
|
||
// unsigned int nActorId = pRankInfo != NULL ? pRankInfo->m_nActorId:0;
|
||
|
||
// GetGlobalLogicEngine()->GetMiscMgr().SetSystemStaticVarValue(szTopTitleRand[i],nActorId);
|
||
|
||
// if (nOldActorId > 0 && nActorId != nOldActorId)
|
||
// {
|
||
// CActor *oldActor = GetGlobalLogicEngine()->GetEntityMgr()->GetEntityPtrByActorID(nOldActorId);
|
||
// if(oldActor != NULL)
|
||
// {
|
||
// oldActor->GetNewTitleSystem().delNewTitle(nTitle);
|
||
// }
|
||
// }
|
||
// if (nActorId > 0 && nActorId != nOldActorId)
|
||
// {
|
||
// CActor *pActor = GetGlobalLogicEngine()->GetEntityMgr()->GetEntityPtrByActorID(nActorId);
|
||
// if(pActor != NULL)
|
||
// {
|
||
// // pActor->GetNewTitleSystem().addNewTitle(nTitle);
|
||
// pActor->GetNewTitleSystem().SetCurNewTitle(nTitle);
|
||
// }
|
||
// char msg[256];
|
||
// LPCTSTR pFormat = GetLogicServer()->GetDataProvider()->GetOldTipmsgConfig().GetTipmsg(tpMaintainTopTitle);
|
||
// LPCTSTR pJogName = GetLogicServer()->GetDataProvider()->GetOldTipmsgConfig().GetTipmsg(nJobTipIndex);
|
||
// sprintf(msg, pFormat, pRankInfo->m_sName, pJogName);
|
||
// GetGlobalLogicEngine()->GetEntityMgr()->BroadcastTipmsg(msg,ttScreenCenter + ttChatWindow);
|
||
// }
|
||
|
||
|
||
// }
|
||
|
||
}
|
||
|
||
//获取排行榜的第几名的角色id
|
||
unsigned int CTopTitleMgr::GetActorIdByCsRank(INT_PTR nRankIndex,int nRank)
|
||
{
|
||
PTOPTITLERANKINFO pRankInfo = GetActorInfoByCsRank(nRankIndex,nRank);
|
||
if (pRankInfo)
|
||
{
|
||
return pRankInfo->m_nActorId;
|
||
}
|
||
return 0;
|
||
}
|
||
PTOPTITLERANKINFO CTopTitleMgr::GetActorInfoByCsRank(INT_PTR nRankIndex,int nRank)
|
||
{
|
||
if(MAX_RANK_COUNT <= nRankIndex)
|
||
return NULL;
|
||
RANKUSERLIST& list = m_rankActorList[nRankIndex];
|
||
if(list.count() < nRank)
|
||
{
|
||
return NULL;
|
||
}
|
||
for(INT_PTR j=0; j< list.count();j ++ )
|
||
{
|
||
TOPTITLERANKINFO &data = list[j];
|
||
if(data.m_nRank == nRank)
|
||
{
|
||
return &data;
|
||
}
|
||
}
|
||
return NULL;
|
||
}
|
||
void CTopTitleMgr::OnDbReturnData(INT_PTR nCmd,char * data,SIZE_T size)
|
||
{
|
||
// if (nCmd == jxInterSrvComm::DbServerProto::dcSaveBaseRank)
|
||
// {
|
||
// CDataPacketReader inPacket(data, size);
|
||
// int nRawServerId = 0, nLoginServerId = 0;
|
||
// BYTE nErrorCode;
|
||
// inPacket >> nRawServerId >> nLoginServerId >> nErrorCode;
|
||
// if (nErrorCode != jxInterSrvComm::DbServerProto::reSucc)
|
||
// {
|
||
// OutputMsg(rmError,_T("Save BaseRank Error!code=%d"),nErrorCode);
|
||
// return;
|
||
// }
|
||
// // else
|
||
// // {
|
||
// // // 减少更新排行榜引用计数
|
||
// // ReleaseTopRankRef();
|
||
// // }
|
||
// }
|
||
|
||
// // 读取排行榜入内存
|
||
// if (nCmd == dcLoadBaseRank)
|
||
// {
|
||
// CDataPacketReader inPacket(data, size);
|
||
// int nRawServerId = 0, nLoginServerId = 0;
|
||
// BYTE nErrorCode;
|
||
// inPacket >> nRawServerId >> nLoginServerId >> nErrorCode;
|
||
// if (nErrorCode == jxInterSrvComm::DbServerProto::reSucc)
|
||
// {
|
||
// int nCount = 0;
|
||
// inPacket >> nCount;
|
||
// //初始化
|
||
// for (INT_PTR i = 0; i < MAX_RANK_COUNT; i++)
|
||
// {
|
||
// RANKUSERLIST& list = m_rankActorList[i];
|
||
// list.clear();
|
||
// }
|
||
// for (INT_PTR i = 0; i < nCount; i ++)
|
||
// {
|
||
// TOPTITLERANKINFO info;
|
||
// inPacket >> info.m_nActorId >> info.m_nRankId >> info.m_nRank >> info.m_nValue>> info.m_nParam;
|
||
// inPacket.readString(info.m_sName,ArrayCount(info.m_sName));
|
||
// INT_PTR nRankIndex = (INT_PTR)(info.m_nRankId);
|
||
// if ((nRankIndex < MAX_RANK_COUNT) && (nRankIndex >= 0) )
|
||
// {
|
||
// RANKUSERLIST& list = m_rankActorList[nRankIndex];
|
||
// list.add(info);
|
||
// }
|
||
|
||
// }
|
||
// m_bInit = true;
|
||
|
||
// //更新在线玩家头衔
|
||
// //SetOnlineActorHeadTitle();
|
||
|
||
// //ResetOfflineUser();
|
||
|
||
// //标记更新雕像嘀嗒
|
||
// TICKCOUNT nCurrTime = GetGlobalLogicEngine()->getTickCount();
|
||
// //m_nDelay = nCurrTime + 30000;
|
||
// m_nDelay = nCurrTime + 60*10;
|
||
|
||
// int nMaxTopLevel = GetGlobalLogicEngine()->GetMiscMgr().GetSystemStaticVarValue(szTopMaxLevel);
|
||
// int nToplevel = GetTopLevel();
|
||
// if(nToplevel > nMaxTopLevel)
|
||
// SetTopMaxLevel(nToplevel);
|
||
// }
|
||
// else
|
||
// {
|
||
// OutputMsg(rmError,_T("Load TopTitleRank Error!code=%d"),nErrorCode);
|
||
// return;
|
||
// }
|
||
// }
|
||
|
||
}
|
||
|
||
|
||
|
||
//依据type 发送rank
|
||
// void CTopTitleMgr::SendTopRankData(CActor * m_pEntity)
|
||
// {
|
||
|
||
// // if(type > MAX_RANK_COUNT)
|
||
// // return;
|
||
// if(!m_bInit)
|
||
// {
|
||
// UpdateBaseRankData();
|
||
// Load();
|
||
// return;
|
||
// }
|
||
// int nDays = GetLogicServer()->GetDaysSinceOpenServer();
|
||
// if(nDays > 1)
|
||
// {
|
||
// if(m_pEntity == NULL) return;
|
||
// CActorPacket AP;
|
||
// CDataPacket& DataPacket = m_pEntity->AllocPacket(AP);
|
||
// //CVector<CRanking*>& List = GetGlobalLogicEngine()->GetRankingMgr().GetList();
|
||
// DataPacket << (BYTE)enMiscSystemID << (BYTE)sRankData;
|
||
// DataPacket << (BYTE)MAX_RANK_COUNT;
|
||
// // int rankNum = m_rankActorList.size();
|
||
// for(int i = 0; i < MAX_RANK_COUNT; i++)
|
||
// {
|
||
// DataPacket << (BYTE)i;
|
||
// RANKUSERLIST& rank = m_rankActorList[i];
|
||
// int count = rank.count();
|
||
// DataPacket << (BYTE)count;
|
||
// for(int j = 0; j < count; j++)
|
||
// {
|
||
// int k = j+1;
|
||
// DataPacket << (BYTE)k;
|
||
// unsigned int actorid = rank[j].m_nActorId;
|
||
// DataPacket << (unsigned int)actorid;
|
||
// DataPacket << (int )rank[j].m_nValue;
|
||
// DataPacket << (int )rank[j].m_nParam;
|
||
// DataPacket.writeString(rank[j].m_sName);
|
||
// }
|
||
// }
|
||
// AP.flush();
|
||
// }
|
||
// }
|
||
|
||
//重置玩家的离线消息，将请求
|
||
void CTopTitleMgr::ResetOfflineUser()
|
||
{
|
||
// COfflineUserMgr & mgr = GetGlobalLogicEngine()->GetOfflineUserMgr();
|
||
// mgr.RemoveAllUser(); //先全部清除
|
||
// mgr.RemoveAllUserHero(); //清除全部英雄信息
|
||
// for (INT_PTR i = 0; i < MAX_RANK_COUNT; i++)
|
||
// {
|
||
// RANKUSERLIST& list = m_rankActorList[i];
|
||
// for(INT_PTR j=0; j< list.count();j ++ )
|
||
// {
|
||
// TOPTITLERANKINFO &data = list[j];
|
||
// if (data.m_nActorId <= 0)
|
||
// continue;
|
||
// if (data.m_nRankId >= rtHeroLevel && data.m_nRankId <= rtWizardHeroBp)
|
||
// {
|
||
// if (data.m_nParam <= 0)
|
||
// continue;
|
||
// mgr.LoadUserHero(data.m_nActorId, data.m_nParam);
|
||
// }
|
||
// else if (data.m_nRankId == rtMagicItemBp)
|
||
// {
|
||
// //mgr.LoadMagicData(data.m_nActorId);
|
||
// }
|
||
// else
|
||
// {
|
||
// mgr.LoadUser(data.m_nActorId);
|
||
// }
|
||
// }
|
||
// }
|
||
}
|
||
|
||
bool CTopTitleMgr::SetOnlineActorHeadTitle()
|
||
{
|
||
bool bSet = false;
|
||
CVector<void*> pEntityList;
|
||
pEntityList.clear();
|
||
GetGlobalLogicEngine()->GetEntityMgr()->GetOnlineAcotrPtrList(pEntityList);
|
||
INT_PTR nCount = pEntityList.count();
|
||
for (INT_PTR i = 0; i < nCount; i++)
|
||
{
|
||
CActor *pActor = (CActor *)pEntityList[i];
|
||
if (pActor && pActor->GetType() == enActor)
|
||
{
|
||
// if (pActor->OnGetIsTestSimulator()
|
||
// || pActor->OnGetIsSimulator() )
|
||
// {
|
||
// continue;
|
||
// }
|
||
bSet = SetRankHeadTitle(pActor);
|
||
}
|
||
}
|
||
return bSet;
|
||
}
|
||
|
||
|
||
// void CTopTitleMgr::UpdateRankData()
|
||
// {
|
||
// // 清空引用计数
|
||
// m_nRefCount = 0;
|
||
// this->UpdateBaseRankData();
|
||
// //GetGlobalLogicEngine()->GetCampComponent().UpdateWorldCampContrRankEveryDay();
|
||
// }
|
||
|
||
void CTopTitleMgr::ResetNpcStatue()
|
||
{
|
||
// CMiscProvider &provider = GetLogicServer()->GetDataProvider()->GetMiscConfig();
|
||
// CVector<NPCSTATUE> *pNpcStatueList = provider.GetNpcStatueList();
|
||
// for (int i = 0; i < pNpcStatueList->count(); i++)
|
||
// {
|
||
// NPCSTATUE npc = pNpcStatueList->get(i);
|
||
// CNpc *pNpc = CNpc::GetNpcPtr(npc.sSceneName, npc.sNpcName);
|
||
// if (pNpc)
|
||
// {
|
||
// //pNpc->ChangeShowName(g_nRadius, npc.sNpcName);
|
||
// //pNpc->SetProperty<UINT>(PROP_ENTITY_ID, 0);
|
||
// // 设置属性
|
||
// //pNpc->SetModelId(0);
|
||
// //pNpc->SetWeaponAppearId(0);
|
||
// //pNpc->SetTitle(npc.sTitle);
|
||
// }
|
||
// }
|
||
}
|
||
|
||
bool CTopTitleMgr::SetNpcStatue(INT_PTR nType, INT_PTR nActorId, LPCTSTR sName, INT_PTR nSex, INT_PTR nParam)
|
||
{
|
||
// CMiscProvider &provider = GetLogicServer()->GetDataProvider()->GetMiscConfig();
|
||
// PNPCSTATUE pStatue = provider.GetNpcStatue(nType, nParam);
|
||
// if (pStatue == NULL) return false;
|
||
// CNpc *pNpc = CNpc::GetNpcPtr(pStatue->sSceneName, pStatue->sNpcName);
|
||
// if (pNpc == NULL)
|
||
// {
|
||
// OutputMsg(rmError, "set npc statue error, npc can not be found!npcName=%s", pStatue->sNpcName);
|
||
// return false;
|
||
// }
|
||
// if (nActorId == 0)
|
||
// {
|
||
// pNpc->ChangeShowName(g_nRadius, (LPCTSTR)pStatue->sNpcName);
|
||
// }
|
||
// else
|
||
// {
|
||
// pNpc->ChangeShowName(g_nRadius, sName);
|
||
// }
|
||
|
||
// pNpc->SetProperty<unsigned int>(PROP_ENTITY_ID, (unsigned int)nActorId);
|
||
// INT_PTR nModelId = pStatue->nMaleModelId;
|
||
// if (nSex == 1)
|
||
// nModelId = pStatue->nFemaleModelId;
|
||
// pNpc->ChangeModel(g_nRadius, (int)nModelId);
|
||
|
||
return true;
|
||
}
|
||
|
||
void CTopTitleMgr::UpdateRawRankList()
|
||
{
|
||
// INT_PTR nServerId = GetLogicServer()->GetServerIndex();
|
||
// COfflineUserMgr &mgr = GetGlobalLogicEngine()->GetOfflineUserMgr();
|
||
// m_RawRankList.clear();
|
||
// for (INT_PTR i = rtWarriorBp; i <= rtWizardBp; ++ i)
|
||
// {
|
||
// if (m_rankActorList[i].count() == 0)
|
||
// continue;
|
||
// TOPTITLERANKINFO &info = m_rankActorList[i][0];
|
||
// COfflineUser *pUser = mgr.GetUserByActorId(info.m_nActorId, true);
|
||
// INT_PTR nVocation = pUser->nVocation;
|
||
// if (nVocation <= enVocNone || nVocation >= enMaxVocCount)
|
||
// continue;
|
||
// RANKDATA tmpData;
|
||
// tmpData.nActorId = info.m_nActorId;
|
||
// strcpy(tmpData.sName, pUser->name);
|
||
// tmpData.sName[sizeof(tmpData.sName)-1] = 0;
|
||
// tmpData.nSex = pUser->nSex;
|
||
// tmpData.nVocation = pUser->nVocation;
|
||
// tmpData.nServerId = (int)nServerId;
|
||
// tmpData.nValue = pUser->nBattlePower;
|
||
|
||
// m_RawRankList.add(tmpData);
|
||
// }
|
||
|
||
// m_nDelay = 0;
|
||
}
|
||
|
||
void CTopTitleMgr::UpdateVocNpcStatue(INT_PTR nType)
|
||
{
|
||
if (nType != stRsVocation && nType != stCsVocation) return;
|
||
COfflineUserMgr &offMgr = GetGlobalLogicEngine()->GetOfflineUserMgr();
|
||
CVector<NPCSTATUE> *pNpcList = GetLogicServer()->GetDataProvider()->GetMiscConfig().GetNpcStatueList();
|
||
for (INT_PTR i = 0; i < pNpcList->count(); ++ i)
|
||
{
|
||
NPCSTATUE npc = pNpcList->get(i);
|
||
if ((INT_PTR)npc.btType != nType)
|
||
continue;
|
||
bool bSet = false;
|
||
if (nType == stRsVocation)
|
||
{
|
||
for (INT_PTR j = 0; j < m_RawRankList.count(); ++ j)
|
||
{
|
||
PRANKDATA pData = &m_RawRankList[j];
|
||
if (pData->nVocation == (unsigned int)npc.btParam)
|
||
{
|
||
SetNpcStatue(nType, pData->nActorId, pData->sName, pData->nSex, pData->nVocation);
|
||
bSet = true;
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
else
|
||
{
|
||
for (INT_PTR j = 0; j < m_CsRankList.count(); ++ j)
|
||
{
|
||
PRANKDATA pData = &m_CsRankList[j];
|
||
if (pData->nVocation == (unsigned int)npc.btParam)
|
||
{
|
||
SetNpcStatue(nType, pData->nActorId, pData->sName, pData->nSex, pData->nVocation);
|
||
bSet = true;
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
|
||
if (!bSet)
|
||
{
|
||
SetNpcStatue(nType, 0, npc.sNpcName, 0, npc.btParam);
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
void CTopTitleMgr::SaveCsRank()
|
||
{
|
||
CLogicSSClient *pSSClient = GetLogicServer()->GetSessionClient();
|
||
CDataPacket &packet = pSSClient->allocProtoPacket(jxInterSrvComm::SessionServerProto::cSaveCsRank);
|
||
INT_PTR nCount = m_RawRankList.count();
|
||
packet << (WORD)nCount;
|
||
for (INT_PTR i = 0; i < nCount; i++)
|
||
{
|
||
RANKDATA data = m_RawRankList[i];
|
||
packet.writeBuf(&data, sizeof(RANKDATA));
|
||
}
|
||
pSSClient->flushProtoPacket(packet);
|
||
OutputMsg(rmTip, _T("发消息给Session保存跨服排行榜！"));
|
||
}
|
||
|
||
void CTopTitleMgr::LoadCsRank()
|
||
{
|
||
CLogicSSClient *pSSClient = GetLogicServer()->GetSessionClient();
|
||
CDataPacket &packet = pSSClient->allocProtoPacket(jxInterSrvComm::SessionServerProto::cLoadCsRank);
|
||
pSSClient->flushProtoPacket(packet);
|
||
OutputMsg(rmTip, _T("发消息给Session获取跨服排行榜！"));
|
||
}
|
||
|
||
void CTopTitleMgr::ClearCsRank(INT_PTR nServerId)
|
||
{
|
||
CLogicSSClient *pSSClient = GetLogicServer()->GetSessionClient();
|
||
CDataPacket &packet = pSSClient->allocProtoPacket(jxInterSrvComm::SessionServerProto::cClearCsRank);
|
||
packet << (int)nServerId;
|
||
pSSClient->flushProtoPacket(packet);
|
||
OutputMsg(rmTip, _T("发消息给Session清除跨服排行榜！ServerId=%d"), nServerId);
|
||
}
|
||
|
||
void CTopTitleMgr::BroadLogicToSaveCsRank()
|
||
{
|
||
char buff[256] = {0};
|
||
CDataPacket packet(buff, sizeof(buff));
|
||
WORD nCmd = (WORD)jxInterSrvComm::SessionServerProto::lcBroadToSaveCsRank;
|
||
CLogicSSClient *pSSClient = GetLogicServer()->GetSessionClient();
|
||
pSSClient->BroadMsgToLogicClient(nCmd, packet.getMemoryPtr(), packet.getLength());
|
||
}
|
||
|
||
void CTopTitleMgr::BroadLogicToLoadCsRank()
|
||
{
|
||
char buff[256] = {0};
|
||
CDataPacket packet(buff, sizeof(buff));
|
||
WORD nCmd = (WORD)jxInterSrvComm::SessionServerProto::lcBroadToLoadCsRank;
|
||
CLogicSSClient *pSSClient = GetLogicServer()->GetSessionClient();
|
||
pSSClient->BroadMsgToLogicClient(nCmd, packet.getMemoryPtr(), packet.getLength());
|
||
}
|
||
|
||
void CTopTitleMgr::OnSSDBReturnData(INT_PTR nCmd,INT_PTR nErrorCode,CDataPacketReader &reader)
|
||
{
|
||
if (jxInterSrvComm::SessionServerProto::sLoadCsRank == nCmd)
|
||
{
|
||
if (nErrorCode != jxInterSrvComm::SessionServerProto::neSuccess)
|
||
{
|
||
OutputMsg(rmError, "LoadCsRank Error! Code=%d", nErrorCode);
|
||
return;
|
||
}
|
||
|
||
int nCount = 0;
|
||
m_CsRankList.clear();
|
||
reader >> nCount;
|
||
for (INT_PTR i = 0; i < nCount; i++)
|
||
{
|
||
RANKDATA data;
|
||
reader.readBuf(&data, sizeof(RANKDATA));
|
||
m_CsRankList.add(data);
|
||
}
|
||
|
||
//更新NPC雕像
|
||
UpdateVocNpcStatue(stCsVocation);
|
||
}
|
||
}
|
||
|
||
void CTopTitleMgr::OnOtherLogicServerRetData(int nCmd, int nOtherServerId, CDataPacketReader &reader)
|
||
{
|
||
switch (nCmd)
|
||
{
|
||
case jxInterSrvComm::SessionServerProto::lcSaveOfflineData:
|
||
{
|
||
SetUserOfflineData(reader);
|
||
}
|
||
break;
|
||
case jxInterSrvComm::SessionServerProto::lcLoadOfflineData:
|
||
{
|
||
unsigned int nActorId = 0;
|
||
reader >> nActorId;
|
||
ReturnUserOfflineData(nOtherServerId, nActorId);
|
||
}
|
||
break;
|
||
case jxInterSrvComm::SessionServerProto::lcBroadToSaveCsRank:
|
||
{
|
||
SaveCsRank();
|
||
}
|
||
break;
|
||
case jxInterSrvComm::SessionServerProto::lcBroadToLoadCsRank:
|
||
{
|
||
LoadCsRank();
|
||
}
|
||
break;
|
||
/*
|
||
case jxInterSrvComm::SessionServerProto::lcClearHundredServerCsRank:
|
||
{
|
||
GetGlobalLogicEngine()->GetMiscMgr().ClearHundredCrossRank();
|
||
break;
|
||
}
|
||
case jxInterSrvComm::SessionServerProto::lcBroadTreasureAuctionCsRank:
|
||
{
|
||
//GetGlobalLogicEngine()->GetMiscMgr().OtherWuYiAuctionRankToLocal(reader);
|
||
break;
|
||
}
|
||
*/
|
||
}
|
||
}
|
||
|
||
void CTopTitleMgr::SetUserOfflineData(CDataPacketReader &reader)
|
||
{
|
||
// unsigned int nActorId = 0;
|
||
// reader >> nActorId;
|
||
// if (nActorId <= 0)
|
||
// return;
|
||
// bool isExit;
|
||
// COfflineUserMgr &mgr = GetGlobalLogicEngine()->GetOfflineUserMgr();
|
||
// COfflineUser *pUser = mgr.AddOffLineUser(nActorId, isExit);
|
||
// if (!isExit && pUser)
|
||
// {
|
||
// mgr.OnLoadActorBasic(nActorId, reader);
|
||
// mgr.OnLoadActorOther(nActorId, reader);
|
||
// }
|
||
}
|
||
|
||
void CTopTitleMgr::LoadUserOfflineData(int nDestServerId, unsigned int nActorId)
|
||
{
|
||
// if (nActorId <= 0 || nDestServerId <= 0)
|
||
// return;
|
||
|
||
// //本服的不需要跨服请求
|
||
// if (GetLogicServer()->GetServerIndex() == nDestServerId)
|
||
// {
|
||
// COfflineUser *pUser = GetGlobalLogicEngine()->GetOfflineUserMgr().GetUserByActorId(nActorId, true);
|
||
// return;
|
||
// }
|
||
// //有数据不需要请求
|
||
// if (GetGlobalLogicEngine()->GetOfflineUserMgr().GetUserByActorId(nActorId))
|
||
// {
|
||
// return;
|
||
// }
|
||
// char buff[256] = {0};
|
||
// CDataPacket packet(buff, sizeof(buff));
|
||
// WORD nCmd = (WORD)jxInterSrvComm::SessionServerProto::lcLoadOfflineData;
|
||
// packet << (unsigned int)nActorId;
|
||
// CLogicSSClient *pSSClient = GetLogicServer()->GetSessionClient();
|
||
// pSSClient->SendMsgToDestLogicClient(nCmd, nDestServerId, packet.getMemoryPtr(), packet.getLength());
|
||
}
|
||
|
||
void CTopTitleMgr::ReturnUserOfflineData(int nDestServerId, unsigned int nActorId)
|
||
{
|
||
// if (nActorId <= 0)
|
||
// return;
|
||
// int nRawServerId = GetLogicServer()->GetServerIndex();
|
||
// if (nDestServerId == nRawServerId)
|
||
// return;
|
||
// COfflineUser *pUser = GetGlobalLogicEngine()->GetOfflineUserMgr().GetUserByActorId(nActorId, true);
|
||
// if (pUser == NULL || pUser->name[0] == '\0')
|
||
// return;
|
||
// CLogicSSClient *pSSClient = GetLogicServer()->GetSessionClient();
|
||
// CDataPacket &packet = pSSClient->allocProtoPacket(jxInterSrvComm::SessionServerProto::cBroadcastOr1SrvMessage);
|
||
// packet << (int)nDestServerId << (int)nRawServerId;
|
||
// packet << (WORD)jxInterSrvComm::SessionServerProto::lcSaveOfflineData;
|
||
// packet << nActorId;
|
||
// packet.writeBuf(pUser, sizeof(ActorOfflineMsg));
|
||
// //packet << pUser->gemData;
|
||
// INT_PTR nPos = packet.getPosition();
|
||
// packet << (int)0;
|
||
// int nCount = 0;
|
||
// for(INT_PTR i = 0; i < CEquipVessel::EquipmentCount; i++)
|
||
// {
|
||
// CUserItem *pUserItem = pUser->equips.m_Items[i];
|
||
// if (pUserItem)
|
||
// {
|
||
// ((CUserItem)*pUserItem) >> packet;
|
||
// // packet.writeBuf(pUserItem, sizeof(CUserItem));
|
||
// nCount++;
|
||
// }
|
||
// }
|
||
// int *pCount = (int *)packet.getPositionPtr(nPos);
|
||
// *pCount = (int)nCount;
|
||
// pSSClient->flushProtoPacket(packet);
|
||
}
|
||
|
||
int CTopTitleMgr::GetServerIdByCsRank(unsigned int nActorId)
|
||
{
|
||
if (nActorId <= 0)
|
||
return 0;
|
||
for (INT_PTR i = 0; i < m_CsRankList.count(); i++)
|
||
{
|
||
RANKDATA &data = m_CsRankList[i];
|
||
if (data.nActorId == nActorId)
|
||
{
|
||
return data.nServerId;
|
||
}
|
||
}
|
||
return 0;
|
||
}
|
||
|
||
|
||
bool CTopTitleMgr::SetRankHeadTitle(CActor *pActor)
|
||
{
|
||
if (pActor == NULL) return false;
|
||
unsigned int nActorId = pActor->GetId();
|
||
CVector<TOPTITLECONFIG> &tTitleList = GetLogicServer()->GetDataProvider()->GetAchieveConfig().GetTopTitleList();
|
||
INT_PTR nConfigCount = tTitleList.count();
|
||
if (nConfigCount <= 0) return false;
|
||
for (INT_PTR i = 0; i < nConfigCount; ++i)
|
||
{
|
||
TOPTITLECONFIG &tTitleConfig = tTitleList[i];
|
||
INT_PTR nRankIndex = (INT_PTR)(tTitleConfig.nRankId);
|
||
if (nRankIndex < 0 || nRankIndex >= MAX_RANK_COUNT)
|
||
continue;
|
||
RANKUSERLIST &data = m_rankActorList[nRankIndex];
|
||
INT_PTR nRankCount = data.count();
|
||
INT_PTR nMinRank = __min(tTitleConfig.nMinRank, tTitleConfig.nMaxRank);
|
||
INT_PTR nMaxRank = __max(tTitleConfig.nMinRank, tTitleConfig.nMaxRank);
|
||
|
||
bool bSetFlag = false;
|
||
for (INT_PTR j = 0; j < nRankCount; ++j)
|
||
{
|
||
TOPTITLERANKINFO& info = data[j];
|
||
if (info.m_nActorId == nActorId && info.m_nRank >= nMinRank && info.m_nRank <= nMaxRank)
|
||
{
|
||
bSetFlag = true;
|
||
pActor->SetHeadTitle(tTitleConfig.nTitleId, true);
|
||
break;
|
||
}
|
||
}
|
||
|
||
if (!bSetFlag)
|
||
pActor->SetHeadTitle(tTitleConfig.nTitleId, false);
|
||
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
|
||
void CTopTitleMgr::SetTopMaxLevel(int nLevel)
|
||
{
|
||
if(nLevel > nMaxTopLevel)
|
||
{
|
||
nMaxTopLevel = nLevel;
|
||
GetGlobalLogicEngine()->GetMiscMgr().SetSystemStaticVarValue(szTopMaxLevel,nMaxTopLevel);
|
||
}
|
||
|
||
}
|
||
|
||
|
||
|
||
int CTopTitleMgr::GetTopLevel()
|
||
{
|
||
RANKUSERLIST& list = m_rankActorList[rtAllLevel];
|
||
if(list.count() <= 0 )
|
||
{
|
||
return 1;
|
||
}
|
||
return list[0].m_nValue;
|
||
}
|