3453 lines
No EOL
121 KiB
C++
3453 lines
No EOL
121 KiB
C++
#include "stdafx.h"
|
|
#include "DNGameServerManager.h"
|
|
#include "DNRUDPGameServer.h"
|
|
#include "DNGameRoom.h"
|
|
#include "DNPvPGameRoom.h"
|
|
#include "DNDLGameRoom.h"
|
|
#include "DNUserSession.h"
|
|
#include "Log.h"
|
|
#include "DNMasterConnection.h"
|
|
#include "DNMasterConnectionManager.h"
|
|
#include "DNDBConnection.h"
|
|
#include "DNDBConnectionManager.h"
|
|
#include "TaskManager.h"
|
|
#include "DnGameTask.h"
|
|
#include "DnItemTask.h"
|
|
#include "DnPartyTask.h"
|
|
#include "PerfCheck.h"
|
|
#include "DnScriptManager.h"
|
|
#include "DNServiceConnection.h"
|
|
#include "Util.h"
|
|
#include "SpinBuffer.h"
|
|
#include "NoticeSystem.h"
|
|
#include "DNFarmUserSession.h"
|
|
#include "DNGuildSystem.h"
|
|
#include "DNGameDataManager.h"
|
|
#ifdef _USE_VOICECHAT
|
|
#include "DNVoiceChat.h"
|
|
#endif
|
|
#include "DNFarmGameRoom.h"
|
|
#include "SecondarySkill.h"
|
|
#include "SecondarySkillRepository.h"
|
|
#include "NpcReputationProcessor.h"
|
|
#if defined( PRE_THREAD_ROOMDESTROY )
|
|
#include "DNBackGroundLoader.h"
|
|
#endif // #if defined( PRE_THREAD_ROOMDESTROY )
|
|
#include "PvPGameMode.h"
|
|
#if defined( PRE_PRIVATECHAT_CHANNEL )
|
|
#include "DnPrivateChatManager.h"
|
|
#include "DNPrivateChatChannel.h"
|
|
#endif
|
|
#include "DNMissionSystem.h"
|
|
#if defined(PRE_ADD_DWC)
|
|
#include "LadderStats.h"
|
|
#endif
|
|
|
|
extern TGameConfig g_Config;
|
|
const int s_nServerSecureFrame = 20;
|
|
|
|
CDNRUDPGameServer::CDNRUDPGameServer(CDNGameServerManager * pManager, const char * pExternalProbeIP, unsigned short nExternalProbePort)
|
|
{
|
|
m_iGameServerID = 0;
|
|
m_iUDPAddr = 0;
|
|
m_iUDPPort = 0;
|
|
m_pServerManager = pManager;
|
|
|
|
char namelist[256];
|
|
int l = gethostname(namelist, sizeof(namelist));
|
|
struct hostent * hh = gethostbyname(namelist);
|
|
m_iUDPAddr = *((unsigned long*)hh->h_addr_list[0]);
|
|
|
|
#ifdef _USE_NATPROBE
|
|
_strcpy(m_szExternalProbeIP, _countof(m_szExternalProbeIP), pExternalProbeIP, (int)strlen(pExternalProbeIP));
|
|
m_nExternalProbePort = nExternalProbePort;
|
|
#else
|
|
memset(m_szExternalProbeIP, 0, sizeof(m_szExternalProbeIP));
|
|
m_nExternalProbePort = 0;
|
|
#endif
|
|
|
|
m_dwChangeSaveTick = m_dwLastSaveTick = 0;
|
|
|
|
m_pStoredPacketBuffer = new (std::nothrow) CRawSpinBuffer( 1, 1024*1024*10 );
|
|
m_pChangeSaveBuffer = new CBuffer(1024 * 1024 * 10);
|
|
m_pLastSaveBuffer = new CBuffer(1024 * 1024 * 10);
|
|
|
|
m_bIsAcceptRoom = true;
|
|
m_bIsCloseService = false;
|
|
m_bIsAllFlushSaveData = false;
|
|
|
|
m_dwPreviewTime = timeGetTime();
|
|
m_nVecFPSList.reserve( 20 * 120 ); // 2盒悼救狼 橇肺颇老 历厘
|
|
|
|
ResetTimer();
|
|
|
|
m_bFrameAlert = false;
|
|
m_uiFrameAlertCount = 0;
|
|
m_bZeroPopulation = false;
|
|
m_uiConnectReqCount = 0;
|
|
m_uiConnectSuccessCount = 0;
|
|
m_nFrameReportPivot = 0;
|
|
#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
m_nFrameReportLogPivot = 0;
|
|
#endif //#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
}
|
|
|
|
CDNRUDPGameServer::~CDNRUDPGameServer()
|
|
{
|
|
// 2009.01.20 辫逛
|
|
// Thread 沥惑辆丰 饶 器牢磐 檬扁拳
|
|
Close();
|
|
|
|
// 2009.02.24 辫逛
|
|
// 皋葛府秦力 眠啊
|
|
delete m_pStoredPacketBuffer;
|
|
delete m_pChangeSaveBuffer;
|
|
delete m_pLastSaveBuffer;
|
|
m_pServerManager = NULL;
|
|
}
|
|
|
|
bool CDNRUDPGameServer::Start(int iPort, int iServerID, int nAffinity)
|
|
{
|
|
m_iGameServerID = iServerID;
|
|
if (Open(iServerID, nAffinity, iPort, false, g_Config.bUseCmd) == false)
|
|
{
|
|
_tprintf(_T("GameServer Port Open Failed [ID:%d][Port:%d]\n"), iServerID, iPort);
|
|
return false;
|
|
}
|
|
|
|
SOCKADDR_IN addr;
|
|
//橇肺宏甫 烹秦 郴 寇何 器飘客 林家甫 茫扁困秦 距 4檬埃 筋酒 壕聪促.
|
|
if (m_nExternalProbePort > 0)
|
|
{
|
|
for(int i=0; m_iUDPPort == 0 && i < 4000; i+=4000/10)
|
|
{
|
|
addr.sin_family = AF_INET;
|
|
addr.sin_port = ntohs(m_nExternalProbePort);
|
|
addr.sin_addr.S_un.S_addr = inet_addr(m_szExternalProbeIP);
|
|
if (sendto(m_hSocket, "ping", 4, 0, (struct sockaddr *)&addr, sizeof(addr)) == -1)
|
|
g_Log.Log(LogType::_ERROR, L"PROBE_SEND_ERR ProbePort[%d] ErrNum(%d)\n", m_nExternalProbePort, GetLastError());
|
|
Sleep(4000/10);
|
|
}
|
|
|
|
if (m_iUDPPort == 0)
|
|
{//救登搁 弊成 掘嚼聪促
|
|
int iLen = sizeof(addr);
|
|
getsockname(m_hSocket, (struct sockaddr*)&addr, &iLen);
|
|
m_iUDPPort = ntohs(addr.sin_port);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
GetHostAddr();
|
|
m_iUDPAddr = inet_addr(GetPublicIP());
|
|
m_iUDPPort = iPort;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
void CDNRUDPGameServer::GetAddress(unsigned long * pAddr, unsigned short * pPort)
|
|
{
|
|
*pAddr = m_iUDPAddr;
|
|
*pPort = m_iUDPPort;
|
|
}
|
|
|
|
#if defined( PRE_WORLDCOMBINE_PARTY )
|
|
void CDNRUDPGameServer::StoreExternalBuffer(UINT nAccountDBID, int iMainCmd, int iSubCmd, const char * pPacket, int iSize, BYTE cType, USHORT nMasterID, int iWorldSetID/*=0*/ )
|
|
|
|
#else
|
|
void CDNRUDPGameServer::StoreExternalBuffer(UINT nAccountDBID, int iMainCmd, int iSubCmd, const char * pPacket, int iSize, BYTE cType, USHORT nMasterID)
|
|
#endif // #if defined( PRE_WORLDCOMBINE_PARTY )
|
|
{
|
|
_STORE_BUFFER_HEADER StorePacketHeader;
|
|
StorePacketHeader.iBufSize = static_cast<unsigned short>(sizeof(StorePacketHeader)+ iSize);
|
|
StorePacketHeader.iSize = iSize;
|
|
StorePacketHeader.nAccountDBID = nAccountDBID;
|
|
StorePacketHeader.iMainCmd = iMainCmd;
|
|
StorePacketHeader.iSubCmd = iSubCmd;
|
|
StorePacketHeader.cMsgType = cType;
|
|
StorePacketHeader.nMasterID = nMasterID;
|
|
#if defined( PRE_WORLDCOMBINE_PARTY )
|
|
StorePacketHeader.iWorldSetID = iWorldSetID;
|
|
#endif // #if defined( PRE_WORLDCOMBINE_PARTY )
|
|
|
|
// CRawBuffer 绰 荐悼栏肺 遏皋目聪硫 备泅秦拎具茄促.
|
|
m_pStoredPacketBuffer->Lock();
|
|
|
|
int Ret = 0;
|
|
if( (Ret = m_pStoredPacketBuffer->Push( &StorePacketHeader, sizeof(StorePacketHeader) )) < 0 )
|
|
_DANGER_POINT();
|
|
|
|
if( Ret > 0 && iSize > 0 )
|
|
{
|
|
if( (Ret = m_pStoredPacketBuffer->Push( pPacket, iSize )) < 0 )
|
|
_DANGER_POINT();
|
|
}
|
|
|
|
m_pStoredPacketBuffer->UnLock();
|
|
}
|
|
|
|
int CDNRUDPGameServer::Send(int iNetID, int iMainCmd, int iSubCmd, const void * pPacket, int iSize, int iPrior, BYTE cSeq)
|
|
{
|
|
DNGAME_PACKET packet;
|
|
int enlen = EncodeGamePacket(&packet, iMainCmd, iSubCmd, pPacket, iSize, cSeq);
|
|
return CRUDPSocketFrame::Send(iNetID, (char*)&packet, enlen, iPrior);
|
|
}
|
|
|
|
bool CDNRUDPGameServer::AddConnect(int iNetID, CDNUserSession * pSession)
|
|
{
|
|
std::map <int, CDNUserSession*>::iterator ii = m_ClientList.find(iNetID);
|
|
if (ii == m_ClientList.end())
|
|
{
|
|
bool bRet = pSession->RUDPConnected(iNetID); //notice to session
|
|
if (bRet)
|
|
{
|
|
m_ClientList[iNetID] = pSession; //insert managed conteiner
|
|
return true;
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
void CDNRUDPGameServer::RemoveConnection(int nGameRoomID, int nNetID, UINT nAccountDBID, UINT nSessionID)
|
|
{
|
|
if (nNetID != 0)
|
|
{
|
|
std::map <int, CDNUserSession*>::iterator in;
|
|
in = m_ClientList.find(nNetID);
|
|
if (in != m_ClientList.end())
|
|
m_ClientList.erase(in);
|
|
}
|
|
|
|
std::map <unsigned int, CDNUserSession*>::iterator is, ia;
|
|
is = m_VerifyList.find(nSessionID);
|
|
if (is != m_VerifyList.end())
|
|
m_VerifyList.erase(is);
|
|
else
|
|
{
|
|
#if defined( STRESS_TEST )
|
|
#else
|
|
_DANGER_POINT();
|
|
#endif // #if defined( STRESS_TEST )
|
|
}
|
|
|
|
ia = m_ConnectList.find(nAccountDBID);
|
|
if (ia != m_ConnectList.end())
|
|
m_ConnectList.erase(ia);
|
|
else _DANGER_POINT();
|
|
|
|
m_pServerManager->RemoveGameUser(nGameRoomID, nAccountDBID, nSessionID, this);
|
|
DisConnect(nNetID);
|
|
}
|
|
|
|
void CDNRUDPGameServer::SendRestoreMaster(char cWorldSetID)
|
|
{
|
|
CDNRUDPGameServer::tRestoreMaster restore;
|
|
memset(&restore, 0, sizeof(restore));
|
|
|
|
restore.cWorldSetID = cWorldSetID;
|
|
restore.nStep = _RESTORESTEP_SENDUSER;
|
|
|
|
m_RestoreSync.Lock();
|
|
m_RestoreMaster.push_back(restore);
|
|
m_RestoreSync.UnLock();
|
|
}
|
|
|
|
#ifdef PRE_ADD_CHAGNESERVER_LOGGING
|
|
bool CDNRUDPGameServer::AddSaveSendData(int nMainCmd, char *pData, int iLen)
|
|
{
|
|
int nRet = ERROR_DB;
|
|
switch (nMainCmd)
|
|
{
|
|
case QUERY_CHANGESERVERUSERDATA:
|
|
nRet = m_pChangeSaveBuffer->Push(pData, iLen);
|
|
break;
|
|
|
|
case QUERY_LASTUPDATEUSERDATA:
|
|
nRet = m_pLastSaveBuffer->Push(pData, iLen);
|
|
break;
|
|
|
|
default:
|
|
g_Log.Log(LogType::_ERROR, L"AddSaveSendData [MCMD:%d][LEN:%d]\n", nMainCmd, iLen);
|
|
break;
|
|
}
|
|
|
|
if (nRet != ERROR_NONE)
|
|
{
|
|
g_Log.Log(LogType::_ERROR, L"AddSaveSendData [MCMD:%d][LEN:%d]\n", nMainCmd, iLen);
|
|
}
|
|
return nRet == ERROR_NONE ? true : false;
|
|
}
|
|
#else //#ifdef PRE_ADD_CHAGNESERVER_LOGGING
|
|
void CDNRUDPGameServer::AddSaveSendData(int nMainCmd, char *pData, int iLen)
|
|
{
|
|
switch (nMainCmd)
|
|
{
|
|
case QUERY_CHANGESERVERUSERDATA:
|
|
m_pChangeSaveBuffer->Push(pData, iLen);
|
|
break;
|
|
|
|
case QUERY_LASTUPDATEUSERDATA:
|
|
m_pLastSaveBuffer->Push(pData, iLen);
|
|
break;
|
|
}
|
|
}
|
|
#endif //#ifdef PRE_ADD_CHAGNESERVER_LOGGING
|
|
|
|
CDNGameRoom * CDNRUDPGameServer::GetRoom(unsigned int iRoomID)
|
|
{
|
|
std::map <unsigned int, CDNGameRoom*>::iterator ii = m_GameRoomList.find(iRoomID);
|
|
if (ii != m_GameRoomList.end())
|
|
return (*ii).second;
|
|
return NULL;
|
|
}
|
|
|
|
CDNUserSession * CDNRUDPGameServer::GetSession(unsigned int iUID)
|
|
{
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii = m_VerifyList.find(iUID);
|
|
if (ii != m_VerifyList.end())
|
|
return (*ii).second;
|
|
return NULL;
|
|
}
|
|
|
|
bool CDNRUDPGameServer::Accept(int iNetID, SOCKADDR_IN *pAddr, const void * pData, int iLen)
|
|
{
|
|
if (m_nExternalProbePort != 0 &&
|
|
pAddr->sin_port == ntohs(m_nExternalProbePort) &&
|
|
pAddr->sin_addr.S_un.S_addr == inet_addr(m_szExternalProbeIP))
|
|
{
|
|
struct _RETURN_UDP_ADDR
|
|
{
|
|
unsigned short port[2];
|
|
unsigned long addr[2];
|
|
} * packet = (_RETURN_UDP_ADDR*) pData;
|
|
|
|
_ASSERT(pAddr->sin_port == ntohs(m_nExternalProbePort) &&
|
|
pAddr->sin_addr.S_un.S_addr == inet_addr(m_szExternalProbeIP));
|
|
|
|
if (iLen == sizeof(*packet) &&
|
|
packet->port[0] == packet->port[1] &&
|
|
packet->addr[0] == packet->addr[1] &&
|
|
m_iUDPPort == 0)
|
|
{
|
|
m_iUDPPort = packet->port[0];
|
|
m_iUDPAddr = packet->addr[0];
|
|
|
|
g_Log.Log(LogType::_ERROR, L"UDP External Addr Recv [%d.%d.%d.%d (%d)] => [%d.%d.%d.%d (%d)]\n",
|
|
pAddr->sin_addr.S_un.S_un_b.s_b1, pAddr->sin_addr.S_un.S_un_b.s_b2,
|
|
pAddr->sin_addr.S_un.S_un_b.s_b3, pAddr->sin_addr.S_un.S_un_b.s_b4,
|
|
ntohs(pAddr->sin_port),
|
|
((unsigned char*)&m_iUDPAddr)[0], ((unsigned char*)&m_iUDPAddr)[1],
|
|
((unsigned char*)&m_iUDPAddr)[2], ((unsigned char*)&m_iUDPAddr)[3],
|
|
m_iUDPPort);
|
|
}
|
|
return false;
|
|
}
|
|
|
|
DNGAME_PACKET TestPacket;
|
|
int iPacketLen;
|
|
iPacketLen = CheckPacket(pData, iLen, &TestPacket);
|
|
if (CalcGamePacketSize((unsigned char *)&TestPacket, iPacketLen) == iPacketLen)
|
|
if (DecodeGamePacket(&TestPacket) == true)
|
|
if (TestPacket.header == CS_SYSTEM && TestPacket.sub_header == eSystem::CS_CONNECT_REQUEST)
|
|
return true;
|
|
return false;
|
|
}
|
|
|
|
void CDNRUDPGameServer::DisConnected(int iNetID, bool bForce, bool bUnreachable)
|
|
{
|
|
//rudp窜俊辑 谗扁扁父 茄芭促 捞力...tcp啊 谗败具 角犁肺 谗辫阑 贸府窍绊 rudp啊 沥惑利捞瘤 臼篮 惑炔俊辑 谗板阑 版快
|
|
//犁楷搬殿阑 蜡档窍磊 老沥矫埃悼救 弊贰档 救等促搁 tcp肺父 悼累窍芭唱 谗绢滚府档废 窍磊
|
|
std::map <int, CDNUserSession*>::iterator ii = m_ClientList.find(iNetID);
|
|
if (ii != m_ClientList.end())
|
|
{
|
|
CDNUserSession * pSession = (*ii).second;
|
|
m_ClientList.erase(ii);
|
|
if (!pSession) return;
|
|
if (bForce)
|
|
{
|
|
if (bUnreachable)
|
|
pSession->DetachConnection(L"CDNRUDPGameServer::DisConnected Unreachable");
|
|
else
|
|
pSession->DetachConnection(L"CDNRUDPGameServer::DisConnected");
|
|
}
|
|
else
|
|
pSession->RudpDisConnected();
|
|
|
|
if (bUnreachable)
|
|
g_Log.Log(LogType::_ERROR, pSession, L"Connect|Unreachable AID[%d]\n", pSession->GetAccountDBID());
|
|
}
|
|
}
|
|
|
|
void CDNRUDPGameServer::ResetTimer()
|
|
{
|
|
m_dwLastUpdateTime = timeGetTime();
|
|
m_nCallCount = 0;
|
|
m_nFPS = 0;
|
|
|
|
ResetFPSHistory();
|
|
}
|
|
|
|
void CDNRUDPGameServer::TimeEvent()
|
|
{
|
|
DWORD dwLocalTime = timeGetTime();
|
|
|
|
if( dwLocalTime - m_dwPreviewTime >= 50 ) {
|
|
#ifndef _SKIP_BLOCK
|
|
m_pServerManager->FlushConnectionBuffer(dwLocalTime);
|
|
#endif
|
|
PROFILE_TIME_TEST_BLOCK_START( "CDNRUDPGameServer::TimeEvent()" );
|
|
SendRestoreMaster();
|
|
StoredProcess();
|
|
IdleProcess();
|
|
PROFILE_TIME_TEST_BLOCK_END();
|
|
|
|
m_dwPreviewTime += 50;
|
|
m_nCallCount++;
|
|
|
|
#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
DWORD dwStartTime = dwLocalTime;
|
|
dwLocalTime = timeGetTime();
|
|
|
|
if (bIsFrameAlert())
|
|
{
|
|
if (m_nFrameReportLogPivot < DELAYED_PRCESS_LOG_COUNT && dwLocalTime - dwStartTime > 0)
|
|
{
|
|
g_Log.Log(LogType::_GAMESERVERDELAY, L"[%d] Report|Frame Elapsed Check SID:[%d] CallTick[%d] CallCount[%d] Elapsed[%d]\n", g_Config.nManagedID, GetServerID(), dwStartTime, m_nCallCount, dwLocalTime - dwStartTime);
|
|
|
|
if (g_pServiceConnection)
|
|
{
|
|
WCHAR wszBuf[GAMEDELAYSIZE] = {0,};
|
|
wsprintf( wszBuf, L"[%d] Report|Frame Elapsed Check SID:[%d] Call[%d] Elapsed[%d]", g_Config.nManagedID, GetServerID(), dwStartTime, dwLocalTime - dwStartTime);
|
|
g_pServiceConnection->SendGameDelayedReport(wszBuf);
|
|
}
|
|
}
|
|
m_nFrameReportLogPivot++;
|
|
}
|
|
else
|
|
{
|
|
m_nFrameReportLogPivot = 0;
|
|
}
|
|
#else //#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
dwLocalTime = timeGetTime();
|
|
#endif //#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
if( dwLocalTime - m_dwLastUpdateTime >= 1000 ) {
|
|
m_nFPS = m_nCallCount;
|
|
m_nCallCount = 0;
|
|
m_dwLastUpdateTime = dwLocalTime;
|
|
|
|
if( m_nFPS < m_nMinFPS ) m_nMinFPS = m_nFPS;
|
|
if( m_nFPS > m_nMaxFPS ) m_nMaxFPS = m_nFPS;
|
|
m_nVecFPSList.push_back( m_nFPS );
|
|
m_nTotalFPS += m_nFPS;
|
|
}
|
|
|
|
#ifdef PRE_ADD_THREADAFFINITY
|
|
CDNRUDPGameServer::CheckAffinitySetting(dwLocalTime);
|
|
#endif //#ifdef PRE_ADD_THREADAFFINITY
|
|
g_pDataManager->DoUpdate(dwLocalTime, GetServerID());
|
|
}
|
|
}
|
|
|
|
bool CDNRUDPGameServer::IsAcceptRoom()
|
|
{
|
|
return m_bIsAcceptRoom;
|
|
}
|
|
|
|
void CDNRUDPGameServer::CheckAcceptRoom()
|
|
{
|
|
if( m_nVecFPSList.empty() ) {
|
|
m_bIsAcceptRoom = true;
|
|
return;
|
|
}
|
|
|
|
int nAveFrame = m_nTotalFPS / (int)m_nVecFPSList.size();
|
|
if( nAveFrame < 17 )
|
|
{
|
|
m_bIsAcceptRoom = false;
|
|
return;
|
|
}
|
|
|
|
#if defined( _CH )
|
|
if( m_uiConnectReqCount > 2000 )
|
|
#else
|
|
if( m_uiConnectReqCount > 1000 )
|
|
#endif
|
|
{
|
|
float fConnectRate = m_uiConnectSuccessCount/static_cast<float>(m_uiConnectReqCount);
|
|
#if defined( _CH )
|
|
if( fConnectRate <= 0.96 )
|
|
#else
|
|
if( fConnectRate <= 0.97 )
|
|
#endif // #if defined( _CH )
|
|
{
|
|
if( m_bIsAcceptRoom )
|
|
g_Log.Log(LogType::_ENTERGAMECHECK, L"[%d] ConnectRate:%d 捞惑栏肺 立加力茄!!! %d/%d \n", g_Config.nManagedID, static_cast<int>(fConnectRate*100),m_uiConnectSuccessCount, m_uiConnectReqCount );
|
|
m_bIsAcceptRoom = false;
|
|
|
|
if (g_pServiceConnection)
|
|
g_pServiceConnection->SendReportUnrecoverBlock(true);
|
|
return;
|
|
}
|
|
else
|
|
{
|
|
if( !m_bIsAcceptRoom )
|
|
{
|
|
if (g_pServiceConnection)
|
|
g_pServiceConnection->SendReportUnrecoverBlock(false);
|
|
|
|
g_Log.Log(LogType::_ENTERGAMECHECK, L"[%d] ConnectRate:%d 捞惑栏肺 立加力茄秦力!!! %d/%d \n", g_Config.nManagedID, static_cast<int>(fConnectRate*100),m_uiConnectSuccessCount, m_uiConnectReqCount );
|
|
}
|
|
}
|
|
}
|
|
|
|
m_bIsAcceptRoom = true;
|
|
}
|
|
|
|
void CDNRUDPGameServer::ResetFPSHistory()
|
|
{
|
|
m_nMinFPS = 20;
|
|
m_nMaxFPS = 0;
|
|
m_nTotalFPS = 0;
|
|
m_nVecFPSList.clear();
|
|
|
|
// m_nTotalProfile = 0;
|
|
// m_nLastProfile = 0;
|
|
}
|
|
|
|
void CDNRUDPGameServer::IdleProcess()
|
|
{
|
|
//霸烙冯狼 积己苞 鞍篮 寇何 捞亥飘俊 狼茄 单捞鸥 函炼啊 乐阑 荐 乐澜! 悼扁拳 林狼!
|
|
unsigned long iCurTick = g_nPerfCounter = timeGetTime();
|
|
if (m_nFrameReportPivot == 0)
|
|
m_nFrameReportPivot = iCurTick;
|
|
|
|
#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
DWORD dwStartTime = 0;
|
|
#endif //#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
|
|
//冯狼 积己篮 胶配绢靛皋技瘤贸府俊辑 惯积捞 邓聪促. 窍唱狼 静饭靛俊辑 悼累窍骨肺 悼扁拳啊 鞘夸 绝摆烈 巩力惯积窍搁.........????????????? oops..
|
|
if( !m_GameRoomList.empty() )
|
|
{
|
|
std::map <unsigned int, CDNGameRoom*>::iterator ii;
|
|
for (ii = m_GameRoomList.begin(); ii != m_GameRoomList.end();)
|
|
{ //阿冯阑 橇肺技胶 胶抛捞飘肺 函版窍绊 家戈林扁甫 橇肺技胶 救栏肺 函版钦矫促.
|
|
if ( (*ii).second->GetRoomState() == _GAME_STATE_DESTROYED )
|
|
{ //冯昏力
|
|
CDNGameRoom * pRoom = (*ii).second;
|
|
UINT nRoomID = pRoom->GetRoomID();
|
|
|
|
#if defined( PRE_THREAD_ROOMDESTROY )
|
|
if( InterlockedCompareExchange( &pRoom->m_lRoomDestroyInterLocked, CDNGameRoom::eRoomDestoryStep::PushQueue, CDNGameRoom::eRoomDestoryStep::None ) == CDNGameRoom::eRoomDestoryStep::None )
|
|
{
|
|
if( g_pBackLoader->PushToDestroyProcess( pRoom ) == true )
|
|
{
|
|
#if defined( _WORK )
|
|
std::cout << "PushToDestroyProcess RoomID=" << nRoomID << std::endl;
|
|
#endif // #if defined( _WORK )
|
|
}
|
|
else
|
|
{
|
|
g_Log.Log(LogType::_ERROR, L"[%d] PushToDestroyProcess RoomID:%d Failed!\n", g_Config.nManagedID, nRoomID);
|
|
}
|
|
|
|
++ii;
|
|
continue;
|
|
}
|
|
else if( InterlockedCompareExchange( &pRoom->m_lRoomDestroyInterLocked, CDNGameRoom::eRoomDestoryStep::Max, CDNGameRoom::eRoomDestoryStep::Destroyed ) != CDNGameRoom::eRoomDestoryStep::Destroyed )
|
|
{
|
|
#if defined( _WORK )
|
|
//std::cout << "PushToDestroyProcess Waiting RoomID=" << nRoomID << std::endl;
|
|
#endif // #if defined( _WORK )
|
|
++ii;
|
|
continue;
|
|
}
|
|
|
|
#if defined( _WORK )
|
|
std::cout << "PushToDestroyProcess Destroyed RoomID=" << nRoomID << std::endl;
|
|
#endif // #if defined( _WORK )
|
|
|
|
#else
|
|
pRoom->FinalizeGameRoom();
|
|
#endif // #if defined( PRE_THREAD_ROOMDESTROY )
|
|
|
|
bool bCrashed = pRoom->IsRoomCrash();
|
|
SAFE_DELETE(pRoom);
|
|
ii = m_GameRoomList.erase(ii);
|
|
|
|
m_pServerManager->RemoveGameRoom(nRoomID, this, bCrashed);
|
|
g_Log.Log(LogType::_NORMAL, L"[%d] _GAME_STATE_DESTROYED RoomID:%d \n", g_Config.nManagedID, nRoomID);
|
|
}
|
|
else
|
|
{
|
|
CScopeInterlocked Scope( &((*ii).second->m_lRoomProcessInterLocked) );
|
|
|
|
//昏力等霸 酒聪搁 橇肺技教
|
|
if ((*ii).second->IsRoomCrash() == false)
|
|
{
|
|
#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
dwStartTime = timeGetTime();
|
|
#endif //#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
(*ii).second->TcpProcess();
|
|
(*ii).second->Process();
|
|
#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
(*ii).second->m_dwProcessElapsedTime = timeGetTime() - dwStartTime;
|
|
#endif //#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
}
|
|
ii++;
|
|
}
|
|
}
|
|
|
|
//Reporting To MasterServer Process Count
|
|
if (iCurTick - m_nFrameReportPivot > DELAYED_PRCESS_CHECKTICK)
|
|
{
|
|
// FPS 弥家蔼 : m_nMinFPS
|
|
// FPS 弥措蔼 : m_nMaxFPS
|
|
// FPS 乞闭蔼 : m_nTotalFPS / m_nVecFPSList.size()
|
|
// FPS 洒胶配府 : m_nVecFPSList
|
|
// Profile 弥家蔼 : m_nMinProfile
|
|
// Profile 弥措蔼 : m_nMaxProfile
|
|
// Profile 乞闭蔼 : m_nTotalProfile / m_nVecProfileList.size();
|
|
// Profile 洒胶配府 : m_nVecProfileList
|
|
// 茄锅 焊郴绊 ResetFPSHistory() 秦林伙~
|
|
int nAvrF = m_nVecFPSList.size() == 0 ? 0 : m_nTotalFPS / (int)m_nVecFPSList.size();
|
|
if (g_pMasterConnectionManager)
|
|
{
|
|
g_pMasterConnectionManager->SendGameFrame(m_iGameServerID, m_pServerManager->GetRoomCount(), (int)m_GameRoomList.size(), (int)m_ClientList.size(), \
|
|
m_nMinFPS, m_nMaxFPS, nAvrF, IsAcceptRoom());
|
|
}
|
|
|
|
if( nAvrF < 17 )
|
|
{
|
|
m_bFrameAlert = true;
|
|
m_uiFrameAlertCount = 1;
|
|
g_Log.Log(LogType::_GAMESERVERDELAY, L"[%d] Report|Frame Delayed SID:[%d] RoomCnt:[%d] UserCnt:[%d] AvrF:[%d] MinF:[%d]\n", g_Config.nManagedID, GetServerID(), (int)m_GameRoomList.size(), (int)m_ClientList.size(), nAvrF, m_nMinFPS);
|
|
|
|
if (g_pServiceConnection)
|
|
{
|
|
WCHAR wszBuf[GAMEDELAYSIZE] = {0,};
|
|
wsprintf( wszBuf, L"[%d] Report|Frame Delayed SID:[%d] RoomCnt:[%d] UserCnt:[%d] AvrF:[%d] MinF:[%d]", g_Config.nManagedID, GetServerID(), (int)m_GameRoomList.size(), (int)m_ClientList.size(), nAvrF, m_nMinFPS);
|
|
g_pServiceConnection->SendGameDelayedReport(wszBuf);
|
|
}
|
|
|
|
for( std::map<unsigned int, CDNGameRoom*>::iterator itor=m_GameRoomList.begin(); itor!=m_GameRoomList.end(); ++ itor )
|
|
{
|
|
CDNGameRoom* pRoom = (*itor).second;
|
|
if( pRoom && pRoom->GetGameTask() )
|
|
{
|
|
int iFps = pRoom->GetGameTask()->m_pFrameSync ? static_cast<int>(pRoom->GetGameTask()->m_pFrameSync->GetFps()) : -1;
|
|
#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
if (pRoom->m_dwProcessElapsedTime > 0)
|
|
g_Log.Log(LogType::_GAMESERVERDELAY, L"[%d] Report|Frame Delayed MapIndex=%d UserCount=%d FPS=%d Elapsed=%d\n", g_Config.nManagedID, pRoom->GetGameTask()->GetMapTableID(), pRoom->GetUserCount(), iFps, pRoom->m_dwProcessElapsedTime );
|
|
#else //#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
g_Log.Log(LogType::_GAMESERVERDELAY, L"[%d] Report|Frame Delayed MapIndex=%d UserCount=%d FPS=%d\n", g_Config.nManagedID, pRoom->GetGameTask()->GetMapTableID(), pRoom->GetUserCount(), iFps );
|
|
#endif //#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
if (g_pServiceConnection)
|
|
{
|
|
WCHAR wszBuf[GAMEDELAYSIZE] = {0,};
|
|
#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
if (pRoom->m_dwProcessElapsedTime > 0)
|
|
wsprintf( wszBuf, L"[%d] Report|Frame Delayed MapIndex=%d UserCount=%d FPS=%d Elapsed=%d", g_Config.nManagedID, pRoom->GetGameTask()->GetMapTableID(), pRoom->GetUserCount(), iFps, pRoom->m_dwProcessElapsedTime);
|
|
#else //#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
wsprintf( wszBuf, L"[%d] Report|Frame Delayed MapIndex=%d UserCount=%d FPS=%d", g_Config.nManagedID, pRoom->GetGameTask()->GetMapTableID(), pRoom->GetUserCount(), iFps);
|
|
#endif //#ifdef PRE_ADD_FRAMEDELAY_LOG
|
|
g_pServiceConnection->SendGameDelayedReport(wszBuf);
|
|
}
|
|
}
|
|
}
|
|
|
|
#ifdef PRE_ADD_THREADAFFINITY
|
|
CDNRUDPGameServer::EnableAffinitySetting();
|
|
#endif //#ifdef PRE_ADD_THREADAFFINITY
|
|
}
|
|
else
|
|
{
|
|
m_bFrameAlert = false;
|
|
if( m_uiFrameAlertCount )
|
|
{
|
|
if( ++m_uiFrameAlertCount >= 5 )
|
|
{
|
|
m_uiFrameAlertCount = 0;
|
|
g_Log.Log(LogType::_GAMESERVERDELAY, L"[Alert][%d] Report|Frame Delayed SID:[%d] RoomCnt:[%d] UserCnt:[%d] AvrF:[%d]\n", g_Config.nManagedID, GetServerID(), (int)m_GameRoomList.size(), (int)m_ClientList.size(), nAvrF);
|
|
|
|
if (g_pServiceConnection)
|
|
{
|
|
WCHAR wszBuf[GAMEDELAYSIZE] = {0,};
|
|
wsprintf( wszBuf, L"[Alert][%d] Report|Frame Delayed SID:[%d] RoomCnt:[%d] UserCnt:[%d] AvrF:[%d]", g_Config.nManagedID, GetServerID(), (int)m_GameRoomList.size(), (int)m_ClientList.size(), nAvrF);
|
|
g_pServiceConnection->SendGameDelayedReport(wszBuf);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
m_nFrameReportPivot = iCurTick;
|
|
|
|
CheckAcceptRoom();
|
|
ResetFPSHistory();
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (iCurTick - m_nFrameReportPivot > DELAYED_PRCESS_CHECKTICK)
|
|
{
|
|
CheckAcceptRoom();
|
|
if (g_pMasterConnectionManager)
|
|
g_pMasterConnectionManager->SendGameFrame( m_iGameServerID, 0, 0, 0, 20, 20, 20, m_bIsAcceptRoom );
|
|
m_nFrameReportPivot = iCurTick;
|
|
ResetFPSHistory();
|
|
}
|
|
}
|
|
|
|
//db俊 诀单捞飘 且波 贸府窍绊
|
|
DataBaseUpdate(iCurTick);
|
|
}
|
|
|
|
void CDNRUDPGameServer::StoredProcess()
|
|
{
|
|
CScopeRoomListInterLocked RoomListScope( m_GameRoomList );
|
|
|
|
ScopeSpinBufferSwitch Scope( m_pStoredPacketBuffer );
|
|
|
|
char* pBuffer = Scope.pGetBuffer();
|
|
UINT uiSize = Scope.uiGetSize();
|
|
|
|
while( uiSize )
|
|
{
|
|
_STORE_BUFFER_HEADER* pHeader = (_STORE_BUFFER_HEADER*)pBuffer;
|
|
char* pDataBuffer = pBuffer+sizeof(_STORE_BUFFER_HEADER);
|
|
|
|
if( pHeader->cMsgType == EXTERNALTYPE_DATABASE )
|
|
{
|
|
if( DataBaseParsePacket( pHeader->iMainCmd, pHeader->iSubCmd, pDataBuffer, pHeader->iSize ) == false )
|
|
{
|
|
bool bError = true;
|
|
switch( pHeader->iMainCmd )
|
|
{
|
|
case MAINCMD_AUTH:
|
|
{
|
|
switch (pHeader->iSubCmd)
|
|
{
|
|
case QUERY_RESETAUTH:
|
|
{
|
|
bError = false;
|
|
break;
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
|
|
case MAINCMD_STATUS:
|
|
{
|
|
switch( pHeader->iSubCmd )
|
|
{
|
|
case QUERY_CHANGESTAGEUSERDATA:
|
|
case QUERY_LASTUPDATEUSERDATA:
|
|
{
|
|
bError = false;
|
|
break;
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
case MAINCMD_PVP:
|
|
{
|
|
switch( pHeader->iSubCmd )
|
|
{
|
|
case QUERY_ADD_PVP_LADDERRESULT:
|
|
{
|
|
bError = false;
|
|
break;
|
|
}
|
|
#if defined( PRE_WORLDCOMBINE_PVP )
|
|
case QUERY_ADD_WORLDPVPROOM:
|
|
{
|
|
TAAddWorldPvPRoom* pPacket = reinterpret_cast<TAAddWorldPvPRoom*>(pDataBuffer);
|
|
CDNGameRoom * pRoom = GetRoom(pPacket->nRoomID);
|
|
if ( pRoom )
|
|
{
|
|
pRoom->SetWorldPvPRoomDBIndex(pPacket->nPvPRoomDBIndex);
|
|
if( pPacket->nAccountDBID > 0)
|
|
{
|
|
pRoom->SetWorldPvPRoomData(pPacket->Data, pPacket->nAccountDBID);
|
|
}
|
|
}
|
|
|
|
bError = false;
|
|
}
|
|
break;
|
|
#endif
|
|
#if defined( PRE_PVP_GAMBLEROOM )
|
|
case QUERY_ADD_GAMBLEROOM:
|
|
{
|
|
TAAddGambleRoom* pPacket = reinterpret_cast<TAAddGambleRoom*>(pDataBuffer);
|
|
CDNGameRoom * pRoom = GetRoom(pPacket->nRoomID);
|
|
if ( pRoom )
|
|
{
|
|
pRoom->SetGambleRoomDBID( pPacket->nGambleDBID );
|
|
}
|
|
|
|
bError = false;
|
|
}
|
|
break;
|
|
#endif
|
|
}
|
|
break;
|
|
}
|
|
case MAINCMD_GUILD:
|
|
{
|
|
switch( pHeader->iSubCmd )
|
|
{
|
|
case QUERY_GET_GUILDREWARDITEM:
|
|
{
|
|
bError = false;
|
|
|
|
DBGetGuildRewardItem *pPacket = reinterpret_cast<DBGetGuildRewardItem*>(pDataBuffer);
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
TGuildRewardItem *RewardItemInfo = pGuild->GetGuildRewardItem();
|
|
|
|
std::vector <std::pair<UINT, INT64>> aList;
|
|
pGuild->GetMemberList (aList);
|
|
|
|
if (aList.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = aList.begin ();
|
|
|
|
for (; iter != aList.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->SendGuildRewardItem(RewardItemInfo);
|
|
pSession->SetGuildRewardItem(RewardItemInfo);
|
|
#if defined( PRE_ADD_GUILDREWARDITEM )
|
|
pSession->ApplyGuildRewardSkill();
|
|
#endif
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
break;
|
|
#if defined (PRE_ADD_DONATION)
|
|
case MAINCMD_DONATION:
|
|
{
|
|
switch( pHeader->iSubCmd )
|
|
{
|
|
case QUERY_DONATION_TOP_RANKER:
|
|
{
|
|
TADonationTopRanker* pPacket = reinterpret_cast<TADonationTopRanker*>(pDataBuffer);
|
|
|
|
for each (std::map<unsigned int, CDNUserSession*>::value_type v in m_ConnectList)
|
|
{
|
|
CDNUserSession* pSession = v.second;
|
|
if (pSession->GetWorldSetID() != pPacket->cWorldID)
|
|
continue;
|
|
|
|
if (pSession->GetState() != SESSION_STATE_GAME_PLAY)
|
|
continue;
|
|
|
|
pSession->SendWorldSystemMsg(WORLDCHATTYPE_DONATION, 0, pPacket->wszCharacterName, 0);
|
|
}
|
|
|
|
bError = false;
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
break;
|
|
#endif // #if defined (PRE_ADD_DONATION)
|
|
#if defined( PRE_PARTY_DB )
|
|
case MAINCMD_PARTY:
|
|
{
|
|
switch( pHeader->iSubCmd )
|
|
{
|
|
case QUERY_ADDPARTYANDMEMBERGAME:
|
|
{
|
|
TAAddPartyAndMemberGame* pPacket = reinterpret_cast<TAAddPartyAndMemberGame*>(pDataBuffer);
|
|
if(pPacket->nRetCode == ERROR_NONE)
|
|
{
|
|
CDNGameRoom * pRoom = GetRoom(pPacket->Data.PartyData.iRoomID);
|
|
if ( pRoom )
|
|
const_cast<Party::Data&>(pRoom->GetPartyStructData()) = pPacket->Data.PartyData;
|
|
}
|
|
bError = false;
|
|
break;
|
|
}
|
|
case QUERY_MODPARTY:
|
|
{
|
|
TAModParty* pPacket = reinterpret_cast<TAModParty*>(pDataBuffer);
|
|
if( pPacket->nRetCode != ERROR_NONE )
|
|
break;
|
|
|
|
CDNGameRoom * pRoom = GetRoom(pPacket->iRoomID);
|
|
if ( pRoom )
|
|
{
|
|
const_cast<Party::Data&>(pRoom->GetPartyStructData()) = pPacket->PartyData;
|
|
pRoom->SendRefreshParty(0,NULL);
|
|
}
|
|
bError = false;
|
|
break;
|
|
}
|
|
case QUERY_OUTPARTY:
|
|
{
|
|
bError = false;
|
|
}
|
|
break;
|
|
#if defined( PRE_WORLDCOMBINE_PARTY )
|
|
case QUERY_ADDWORLDPARTY:
|
|
{
|
|
TAAddParty* pPacket = reinterpret_cast<TAAddParty*>(pDataBuffer);
|
|
if(pPacket->nRetCode == ERROR_NONE)
|
|
{
|
|
CDNGameRoom * pRoom = GetRoom(pPacket->Data.PartyData.iRoomID);
|
|
if ( pRoom )
|
|
const_cast<Party::Data&>(pRoom->GetPartyStructData()) = pPacket->Data.PartyData;
|
|
}
|
|
|
|
if( g_pMasterConnectionManager)
|
|
{
|
|
CDNGameRoom * pRoom = GetRoom(pPacket->Data.PartyData.iRoomID);
|
|
if ( pRoom )
|
|
g_pMasterConnectionManager->SendDelWorldParty(pRoom->GetWorldSetID(), pRoom->GetWorldPartyPrimaryIndex() );
|
|
}
|
|
|
|
bError = false;
|
|
}
|
|
break;
|
|
#endif
|
|
}
|
|
break;
|
|
}
|
|
#endif
|
|
|
|
#if defined(PRE_ADD_DWC)
|
|
case MAINCMD_DWC:
|
|
{
|
|
switch(pHeader->iSubCmd )
|
|
{
|
|
case QUERY_ADD_DWC_RESULT:
|
|
{
|
|
TAAddPvPDWCResult* pPacket = reinterpret_cast<TAAddPvPDWCResult*>(pDataBuffer);
|
|
if(pPacket->nRetCode != ERROR_NONE )
|
|
_DANGER_POINT();
|
|
|
|
CDNGameRoom * pRoom = GetRoom(pPacket->nRoomID);
|
|
if ( pRoom && pRoom->GetPvPGameMode() )
|
|
{
|
|
pRoom->GetPvPGameMode()->SendFinishDWCGameMode();
|
|
|
|
if( g_pMasterConnectionManager)
|
|
g_pMasterConnectionManager->SendUpdateDWCScore(pRoom->GetWorldSetID(), pPacket->nTeamID, pPacket->DWCScore);
|
|
}
|
|
|
|
bError = false;
|
|
}
|
|
break;
|
|
case QUERY_GET_DWC_SCORELIST:
|
|
{
|
|
TAGetListDWCScore* pPacket = reinterpret_cast<TAGetListDWCScore*>(pDataBuffer);
|
|
if(pPacket->nRetCode != ERROR_NONE )
|
|
_DANGER_POINT();
|
|
|
|
CDNPvPGameRoom * pRoom = static_cast<CDNPvPGameRoom*>(GetRoom(pPacket->nRoomID));
|
|
if (pRoom)
|
|
{
|
|
LadderSystem::CDWCStatsRepository* pRepository = pRoom->GetDWCStatsRepositoryPtr();
|
|
if( pRepository ) //DWC 楷嚼葛靛绰 pRepository 积己 救窃
|
|
pRepository->OnRecvDWCScore( pPacket->nATeamID, &pPacket->ATeamInfo, pPacket->nBTeamID, &pPacket->BTeamInfo );
|
|
|
|
pRoom->SendDWCTeamNameInfo(pPacket->ATeamInfo.wszTeamName, pPacket->BTeamInfo.wszTeamName);
|
|
}
|
|
bError = false;
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
break;
|
|
#endif
|
|
}
|
|
if( bError )
|
|
_DANGER_POINT();
|
|
}
|
|
}
|
|
else if( pHeader->cMsgType == EXTERNALTYPE_CASH )
|
|
{
|
|
if( CashParsePacket( pHeader->iMainCmd, pHeader->iSubCmd, pDataBuffer, pHeader->iSize ) == false )
|
|
_DANGER_POINT();
|
|
}
|
|
else if (pHeader->cMsgType == EXTERNALTYPE_SERVICEMANAGER)
|
|
{
|
|
switch (pHeader->iMainCmd)
|
|
{
|
|
case IN_DESTROY:
|
|
{
|
|
DestroyAllGameRoom();
|
|
break;
|
|
}
|
|
case NETSERVICE_SCHEDULE_SERVERCLOSE:
|
|
{
|
|
TScheduleServiceClose * pClose = (TScheduleServiceClose*)pDataBuffer;
|
|
|
|
__time64_t _tNow;
|
|
time(&_tNow);
|
|
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii;
|
|
for (ii = m_ConnectList.begin(); ii != m_ConnectList.end(); ii++) {
|
|
(*ii).second->SendCloseService(_tNow, pClose->_tOderedTime, pClose->_tCloseTime);
|
|
}
|
|
break;
|
|
}
|
|
case NETSERVICE_UPDATEFARM:
|
|
{
|
|
TUpdateFarm * pUpdateFarm = (TUpdateFarm*)pDataBuffer;
|
|
std::map <unsigned int, CDNGameRoom*>::iterator ii;
|
|
for (ii = m_GameRoomList.begin(); ii != m_GameRoomList.end(); ii++)
|
|
{
|
|
if ((*ii).second->bIsFarmRoom())
|
|
(*ii).second->SetFarmActivation(pUpdateFarm->bForceStart);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else if (pHeader->cMsgType == EXTERNALTYPE_MASTER)
|
|
{
|
|
switch( pHeader->iMainCmd )
|
|
{
|
|
case IN_DESTROY:
|
|
{
|
|
#if defined( PRE_WORLDCOMBINE_PARTY )
|
|
DestroyAllFarmGameRoom( pHeader->iWorldSetID );
|
|
#else
|
|
DestroyAllFarmGameRoom();
|
|
#endif // #if defined( PRE_WORLDCOMBINE_PARTY )
|
|
break;
|
|
}
|
|
case MAGA_REQROOMID: //MasterServer GameRoomId Request
|
|
{
|
|
RequestedCreateGameRoomFromMaster( (char)pHeader->nMasterID, pDataBuffer );
|
|
break;
|
|
}
|
|
case MAGA_REQTUTORIALROOMID: //MasterServer GameRoomId Request
|
|
{
|
|
RequestedCreateGameRoomFromMaster( (char)pHeader->nMasterID, pDataBuffer, true );
|
|
break;
|
|
}
|
|
case MAGA_VILLAGESTATE: //贸府 函版钦浆促
|
|
{
|
|
MAGAVillageState *pState = (MAGAVillageState*)pDataBuffer;
|
|
|
|
RequestedVillageState( pState );
|
|
break;
|
|
}
|
|
|
|
case MAGA_NOTICE:
|
|
{
|
|
MANotice * pPacket = (MANotice*)pDataBuffer;
|
|
|
|
if (pPacket->nLen > CHATLENMAX-1) break;
|
|
WCHAR wszChatMsg[CHATLENMAX] = { 0, };
|
|
_wcscpy(wszChatMsg, CHATLENMAX, pPacket->wszNoticeMsg, pPacket->nLen);
|
|
|
|
//鸥涝俊 蝶弗 傍瘤啊 腹酒 历辑 窍唱肺 烹钦
|
|
switch (pPacket->Info.nNoticeType)
|
|
{
|
|
case _NOTICETYPE_WORLD:
|
|
{
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii;
|
|
for (ii = m_ConnectList.begin(); ii != m_ConnectList.end(); ii++)
|
|
if ((*ii).second->GetWorldSetID() == pHeader->nMasterID)
|
|
(*ii).second->SendNotice(wszChatMsg, pPacket->nLen, pPacket->Info.nSlideShowSec);
|
|
}
|
|
break;
|
|
case _NOTICETYPE_EACHSERVER:
|
|
{
|
|
if (g_pServiceConnection && pPacket->Info.nManagedID != 0)
|
|
if (pPacket->Info.nManagedID == g_pServiceConnection->GetManagedID())
|
|
{
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii;
|
|
for (ii = m_ConnectList.begin(); ii != m_ConnectList.end(); ii++)
|
|
if ((*ii).second->GetWorldSetID() == pHeader->nMasterID)
|
|
(*ii).second->SendNotice(wszChatMsg, pPacket->nLen, pPacket->Info.nSlideShowSec);
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
break;
|
|
}
|
|
|
|
case MAGA_CANCELNOTICE:
|
|
{
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii;
|
|
for (ii = m_ConnectList.begin(); ii != m_ConnectList.end(); ii++)
|
|
(*ii).second->SendNoticeCancel();
|
|
break;
|
|
}
|
|
|
|
case MAGA_CHAT:
|
|
{
|
|
MAChat * pPacket = (MAChat*)pDataBuffer;
|
|
|
|
if (pPacket->wChatLen > CHATLENMAX-1 || pPacket->wChatLen <= 0) break;
|
|
WCHAR wszChatMsg[CHATLENMAX] = { 0, };
|
|
_wcscpy(wszChatMsg, CHATLENMAX, pPacket->wszChatMsg, pPacket->wChatLen);
|
|
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii;
|
|
for (ii = m_ConnectList.begin(); ii != m_ConnectList.end(); ii++)
|
|
{
|
|
if ((*ii).second->GetWorldSetID() == pHeader->nMasterID)
|
|
{
|
|
#if defined(PRE_ADD_DWC)
|
|
#if defined(PRE_ADD_WORLD_MSG_RED)
|
|
if( (pPacket->cType == CHATTYPE_WORLD || pPacket->cType == CHATTYPE_WORLD_POPMSG) && (*ii).second->IsDWCCharacter()) // 岿靛 皋技瘤 : DWC 纳腐茄抛 救焊辰促
|
|
#else // #if defined(PRE_ADD_WORLD_MSG_RED)
|
|
if(pPacket->cType == CHATTYPE_WORLD && (*ii).second->IsDWCCharacter()) // 岿靛 皋技瘤 : DWC 纳腐茄抛 救焊辰促
|
|
#endif // #if defined(PRE_ADD_WORLD_MSG_RED)
|
|
continue;
|
|
#endif
|
|
if ((*ii).second->GetState() == SESSION_STATE_GAME_PLAY )
|
|
(*ii).second->SendChat(static_cast<eChatType>(pPacket->cType), pPacket->wChatLen, pPacket->wszFromCharacterName, wszChatMsg);
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
|
|
case MAGA_WORLDSYSTEMMSG:
|
|
{
|
|
MAWorldSystemMsg * pPacket = (MAWorldSystemMsg*)pDataBuffer;
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii;
|
|
for (ii = m_ConnectList.begin(); ii != m_ConnectList.end(); ii++)
|
|
{
|
|
if ((*ii).second->GetWorldSetID() == pHeader->nMasterID)
|
|
{
|
|
#if defined(PRE_ADD_DWC)
|
|
if((*ii).second->IsDWCCharacter()) //矫胶袍 皋技瘤 : DWC 纳腐茄抛 救焊辰促
|
|
continue;
|
|
#endif
|
|
if ((*ii).second->GetState() == SESSION_STATE_GAME_PLAY )
|
|
(*ii).second->SendWorldSystemMsg(pPacket->cType, pPacket->nID, pPacket->wszFromCharacterName, pPacket->nValue, pPacket->wszToCharacterName);
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
|
|
#if defined( PRE_PRIVATECHAT_CHANNEL )
|
|
case MAGA_PRIVATECHANNELCHAT:
|
|
{
|
|
MAPrivateChannelChat * pPacket = (MAPrivateChannelChat*)pDataBuffer;
|
|
CDNPrivateChaChannel* pPrivateChatChannel = g_pPrivateChatChannelManager->GetPrivateChannelInfo( pPacket->cWorldSetID, pPacket->nChannelID );
|
|
|
|
if(pPrivateChatChannel)
|
|
{
|
|
std::list<TPrivateChatChannelMember> MemberList;
|
|
MemberList.clear();
|
|
pPrivateChatChannel->GetPrivateChannelMember(MemberList);
|
|
|
|
for(std::list<TPrivateChatChannelMember>::iterator itor = MemberList.begin();itor != MemberList.end();itor++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID(itor->nAccountDBID);
|
|
if (!pSession) continue;
|
|
|
|
pSession->SendChat( CHATTYPE_PRIVATECHANNEL, pPacket->wChatLen, pPacket->wszFromCharacterName, pPacket->wszChatMsg );
|
|
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
#endif
|
|
case MAGA_RESRECALL:
|
|
{
|
|
MAGAResRecall* pPacket = reinterpret_cast<MAGAResRecall*>(pDataBuffer);
|
|
if( _CmdRecall( pPacket ) == false )
|
|
{
|
|
#if defined(PRE_ADD_MULTILANGUAGE)
|
|
std::wstring wString = boost::io::str( boost::wformat( GetEtUIXML().GetUIString(CEtUIXML::idCategory1,4413, pPacket->cRecallerSelectedLang) ) );
|
|
#else //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
std::wstring wString = boost::io::str( boost::wformat( GetEtUIXML().GetUIString(CEtUIXML::idCategory1,4413) ) );
|
|
#endif //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
g_pMasterConnectionManager->SendChat( (char)pHeader->nMasterID, CHATTYPE_GM, pPacket->uiAccountDBID, wString.c_str(), static_cast<short>(wString.size()) );
|
|
}
|
|
break;
|
|
}
|
|
|
|
//=============================================================================================================
|
|
// PvP Start
|
|
//=============================================================================================================
|
|
|
|
case MAGA_PVP_GAMEMODE:
|
|
{
|
|
InitializePvPGameMode( reinterpret_cast<MAGAPVP_GAMEMODE*>(pDataBuffer) );
|
|
break;
|
|
}
|
|
#if defined(PRE_ADD_PVP_TOURNAMENT)
|
|
case MAGA_PVP_TOURNAMENT_INFO :
|
|
{
|
|
MAGAPVP_TOURNAMENT_INFO * pPacket = (MAGAPVP_TOURNAMENT_INFO*)pDataBuffer;
|
|
|
|
CDNGameRoom * pRoom = GetRoom(pPacket->nGameRoomID);
|
|
if (pRoom && pRoom->GetPvPGameMode() )
|
|
{
|
|
pRoom->GetPvPGameMode()->SetTournamentUserInfo(pPacket);
|
|
}
|
|
else
|
|
_DANGER_POINT();
|
|
break;
|
|
}
|
|
#endif
|
|
case MAGA_BREAKINTOROOM:
|
|
{
|
|
RequestedBreakintoGameRoomFromMaster( (char)pHeader->nMasterID, reinterpret_cast<MAGABreakIntoRoom*>(pDataBuffer) );
|
|
break;
|
|
}
|
|
case MAGA_PVP_MEMBERUSERSTATE:
|
|
{
|
|
MAGAPVPChangeUserState * pPacket = (MAGAPVPChangeUserState*)pDataBuffer;
|
|
|
|
CDNGameRoom * pRoom = GetRoom(pPacket->nPvPRoomID);
|
|
if (pRoom)
|
|
pRoom->SendPvPUserState(pPacket->nAccountDBID, pPacket->uiUserState);
|
|
else
|
|
_DANGER_POINT();
|
|
break;
|
|
}
|
|
case MAGA_PVP_FORCESTOP:
|
|
{
|
|
MAGAForceStopPvP * pPacket = (MAGAForceStopPvP*)pDataBuffer;
|
|
|
|
CDNGameRoom * pRoom = GetRoom(pPacket->nGameRoomID);
|
|
if (pRoom)
|
|
{
|
|
if (pPacket->nForceWinGuildDBID == 0)
|
|
{
|
|
//捞犯霸 磺霸搁 搬苞贸府登瘤 臼澜
|
|
pRoom->OnSendPvPLobby();
|
|
}
|
|
else
|
|
{
|
|
if (pRoom->GetPvPGameMode())
|
|
{
|
|
//窍扁傈俊 固府 铰磊评汲沥 秦初绊 窍绰霸 亮阑淀
|
|
pRoom->GetPvPGameMode()->SetForceWinGuild(pPacket->nForceWinGuildDBID); //赣 捞繁芭?
|
|
pRoom->GetPvPGameMode()->OnCheckFinishRound(PvPCommon::FinishReason::OpponentTeamForceWin);
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
_DANGER_POINT();
|
|
}
|
|
break;
|
|
}
|
|
case MAGA_PVP_ALLSTOPGUILDWAR :
|
|
{
|
|
for( std::map<unsigned int, CDNGameRoom*>::iterator itor=m_GameRoomList.begin(); itor!=m_GameRoomList.end(); ++ itor )
|
|
{
|
|
CDNGameRoom* pRoom = (*itor).second;
|
|
if( pRoom && pRoom->bIsGuildWarSystem() )
|
|
{
|
|
// 弊成 搬苞郴瘤 富绊 磺荤滚覆..
|
|
pRoom->GetPvPGameMode()->FinishGameMode(PvPCommon::Team::Max, PvPCommon::FinishReason::TimeOver);
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
|
|
//=============================================================================================================
|
|
// PvP End
|
|
//=============================================================================================================
|
|
case MAGA_MASTERSYSTEM_SYNC_SIMPLEINFO:
|
|
{
|
|
MasterSystem::MAGASyncSimpleInfo* pPacket = reinterpret_cast<MasterSystem::MAGASyncSimpleInfo*>(pDataBuffer);
|
|
|
|
CDNUserSession* pSession = GetSessionByADBID( pPacket->uiAccountDBID );
|
|
if( pSession )
|
|
{
|
|
if( pSession->CheckDBConnection() == false )
|
|
break;
|
|
|
|
pSession->GetDBConnection()->QueryGetMasterSystemSimpleInfo( pSession->GetDBThreadID(), pSession, true, pPacket->EventCode );
|
|
pSession->QueryGetMasterSystemCountInfo( true );
|
|
}
|
|
break;
|
|
}
|
|
case MAGA_MASTERSYSTEM_SYNC_JOIN:
|
|
{
|
|
MasterSystem::MAGASyncJoin* pPacket = reinterpret_cast<MasterSystem::MAGASyncJoin*>(pDataBuffer);
|
|
|
|
CDNUserSession* pSession = GetSessionByADBID( pPacket->uiAccountDBID );
|
|
if( pSession )
|
|
pSession->SendMasterSystemJoin( ERROR_NONE, true, pPacket->bIsAddPupil, false );
|
|
break;
|
|
}
|
|
case MAGA_MASTERSYSTEM_SYNC_LEAVE:
|
|
{
|
|
MasterSystem::MAGASyncLeave* pPacket = reinterpret_cast<MasterSystem::MAGASyncLeave*>(pDataBuffer);
|
|
|
|
CDNUserSession* pSession = GetSessionByADBID( pPacket->uiAccountDBID );
|
|
if( pSession )
|
|
pSession->SendMasterSystemLeave( ERROR_NONE, pPacket->bIsDelPupil );
|
|
break;
|
|
}
|
|
case MAGA_MASTERSYSTEM_SYNC_GRADUATE:
|
|
{
|
|
MasterSystem::MAGASyncGraduate* pPacket = reinterpret_cast<MasterSystem::MAGASyncGraduate*>(pDataBuffer);
|
|
|
|
CDNUserSession* pSession = GetSessionByADBID( pPacket->uiAccountDBID );
|
|
if( pSession )
|
|
pSession->SendMasterSystemGraduate( pPacket->wszCharName );
|
|
break;
|
|
}
|
|
case MAGA_MASTERSYSTEM_SYNC_CONNECT:
|
|
{
|
|
MasterSystem::MAGASyncConnect* pPacket = reinterpret_cast<MasterSystem::MAGASyncConnect*>(pDataBuffer);
|
|
|
|
CDNUserSession* pSession = GetSessionByADBID( pPacket->uiAccountDBID );
|
|
if( pSession )
|
|
pSession->SendMasterSystemConnect( pPacket->bIsConnect, pPacket->wszCharName );
|
|
break;
|
|
}
|
|
#if defined( PRE_ADD_NPC_REPUTATION_SYSTEM )
|
|
case MAGA_SYNC_SYSTEMMAIL:
|
|
{
|
|
MAGASyncSystemMail* pPacket = reinterpret_cast<MAGASyncSystemMail*>(pDataBuffer);
|
|
CDNUserSession* pSession = GetSessionByADBID( pPacket->uiAccountDBID );
|
|
if( pSession )
|
|
pSession->SendNotifyMail( pPacket->iTotalMailCount, pPacket->iNotReadMailCount, pPacket->i7DaysLeftMailCount, true );
|
|
break;
|
|
}
|
|
#endif // #if defined( PRE_ADD_NPC_REPUTATION_SYSTEM )
|
|
case MAGA_FARM_SYNC:
|
|
{
|
|
MAGAFarmSync* pPacket = reinterpret_cast<MAGAFarmSync*>(pDataBuffer);
|
|
CDNUserSession* pSession = GetSessionByADBID( pPacket->uiAccountDBID );
|
|
if( pSession && pSession->GetCharacterDBID() == pPacket->biCharacterDBID )
|
|
{
|
|
if( pSession->GetGameRoom() && pSession->GetGameRoom()->bIsFarmRoom() )
|
|
{
|
|
switch( pPacket->Type )
|
|
{
|
|
case Farm::ServerSyncType::FIELDCOUNT:
|
|
{
|
|
pSession->GetDBConnection()->QueryGetFieldCountByCharacter( pSession->GetDBThreadID(), pSession->GetWorldSetID(), pSession->GetAccountDBID(), pSession->GetCharacterDBID(), true );
|
|
break;
|
|
}
|
|
case Farm::ServerSyncType::FIELDLIST:
|
|
{
|
|
static_cast<CDNFarmUserSession*>(pSession)->SetUpdateFieldListFlag( true );
|
|
break;
|
|
}
|
|
case Farm::ServerSyncType::WAREHOUSE_ITEMCOUNT:
|
|
{
|
|
pSession->GetDBConnection()->QueryGetCountHarvestDepotItem( pSession );
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
case MAGA_FARM_SYNC_ADDWATER:
|
|
{
|
|
MAGAFarmSyncAddWater* pPacket = reinterpret_cast<MAGAFarmSyncAddWater*>(pDataBuffer);
|
|
CDNUserSession* pSession = GetSessionByADBID( pPacket->uiAccountDBID );
|
|
if( pSession )
|
|
{
|
|
if( pSession->GetGameRoom() && pSession->GetGameRoom()->bIsFarmRoom() )
|
|
{
|
|
// 焊炼胶懦 槛访摹
|
|
CSecondarySkill* pSkill = pSession->GetSecondarySkillRepository()->Get( SecondarySkill::SubType::CultivationSkill );
|
|
if( pSkill )
|
|
{
|
|
pSession->SendFarmAddWaterAnotherUser( pPacket->wszCharName );
|
|
int nAddPoint = pPacket->iAddPoint;
|
|
CNpcReputationProcessor::CheckAndCalcUnionBenefit( pSession, TStoreBenefitData::CultivateProficiencyUp, nAddPoint );
|
|
pSession->GetSecondarySkillRepository()->AddExp( pSkill->GetSkillID(), nAddPoint );
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
|
|
// Guild
|
|
case MAGA_DISMISSGUILD: // 辨靛 秦眉 舅覆
|
|
{
|
|
MADismissGuild *pPacket = reinterpret_cast<MADismissGuild*>(pDataBuffer);
|
|
}
|
|
break;
|
|
|
|
case MAGA_ADDGUILDMEMBER: // 辨靛盔 眠啊 舅覆
|
|
{
|
|
MAAddGuildMember *pPacket = reinterpret_cast<MAAddGuildMember*>(pDataBuffer);
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
std::vector <std::pair<UINT, INT64>> aList;
|
|
pGuild->GetMemberList (aList);
|
|
|
|
if (aList.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = aList.begin ();
|
|
|
|
for (; iter != aList.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->SendInviteGuildMemberAck (pPacket->nAccountDBID, pPacket->nCharacterDBID, pPacket->wszCharacterName, ERROR_NONE, 0, 0, pPacket->nJob, pPacket->cLevel, &pPacket->Location, &pPacket->GuildUID);
|
|
}
|
|
|
|
}
|
|
break;
|
|
|
|
case MAGA_DELGUILDMEMBER: // 辨靛盔 力芭 (呕硼/眠规) 舅覆
|
|
{
|
|
MADelGuildMember *pPacket = reinterpret_cast<MADelGuildMember*>(pDataBuffer);
|
|
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
std::vector <std::pair<UINT, INT64>> aList;
|
|
pGuild->GetMemberList (aList);
|
|
|
|
if (aList.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = aList.begin ();
|
|
|
|
for (; iter != aList.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
if (!pPacket->bIsExiled)
|
|
pSession->SendLeaveGuildMember(pPacket->nAccountDBID, pPacket->nCharacterDBID, ERROR_NONE, &pPacket->GuildUID, false);
|
|
else
|
|
{
|
|
pSession->SendExileGuildMember(pPacket->nAccountDBID, pPacket->nCharacterDBID, ERROR_NONE, &pPacket->GuildUID);
|
|
|
|
// 辨靛 矫阿沥焊 檬扁拳
|
|
if (pPacket->nAccountDBID == pSession->GetAccountDBID())
|
|
{
|
|
pSession->ResetGuildSelfView();
|
|
pSession->SendExileGuildMember(pSession->GetAccountDBID(), pSession->GetCharacterDBID(), ERROR_NONE, &pPacket->GuildUID);
|
|
}
|
|
}
|
|
}
|
|
|
|
if (pPacket->bIsExiled) {
|
|
// 眠规老 版快 辨靛盔 格废俊辑绰 捞固 力芭等 惑怕捞骨肺 傈眉 荤侩磊甫 措惑栏肺 茫酒具 窃 (20100210 b4nfter)
|
|
|
|
CDNUserSession *pSession = GetSessionByADBID(pPacket->nAccountDBID);
|
|
if (pSession && pSession->GetGuildUID().IsSet() && pGuild->GetUID() == pSession->GetGuildUID()) {
|
|
pSession->ResetGuildSelfView();
|
|
pSession->SendExileGuildMember(pSession->GetAccountDBID(), pSession->GetCharacterDBID(), ERROR_NONE, &pPacket->GuildUID);
|
|
pSession->GetItem()->RemoveGuildReversionItem( true );
|
|
pSession->GetItem()->RemoveGuildReversionVehicleItemData( true );
|
|
pSession->SendGuildRewardItem(NULL);
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
|
|
case MAGA_CHANGEGUILDINFO: // 辨靛 沥焊 函版 舅覆
|
|
{
|
|
MAChangeGuildInfo *pPacket = reinterpret_cast<MAChangeGuildInfo*>(pDataBuffer);
|
|
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
|
|
std::vector <std::pair<UINT, INT64>> aList;
|
|
pGuild->GetMemberList (aList);
|
|
|
|
if (aList.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = aList.begin ();
|
|
|
|
for (; iter != aList.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->SendChangeGuildInfo(pPacket->nAccountDBID, pPacket->nCharacterDBID, pPacket->btGuildUpdate, ERROR_NONE, pPacket->Int1, pPacket->Int2, pPacket->Int64, pPacket->Text, &pPacket->GuildUID);
|
|
}
|
|
}
|
|
break;
|
|
|
|
case MAGA_CHANGEGUILDMEMBERINFO: // 辨靛盔 沥焊 函版 舅覆
|
|
{
|
|
MAChangeGuildMemberInfo *pPacket = reinterpret_cast<MAChangeGuildMemberInfo*>(pDataBuffer);
|
|
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
|
|
std::vector <std::pair<UINT, INT64>> aList;
|
|
pGuild->GetMemberList (aList);
|
|
|
|
if (aList.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = aList.begin ();
|
|
|
|
for (; iter != aList.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->SendChangeGuildMemberInfo(pPacket->nReqAccountDBID, pPacket->nReqCharacterDBID, pPacket->nChgAccountDBID, pPacket->nChgCharacterDBID, pPacket->btGuildMemberUpdate, ERROR_NONE, pPacket->Int1, pPacket->Int2, pPacket->Int64, pPacket->Text, &pPacket->GuildUID);
|
|
|
|
switch(pPacket->btGuildMemberUpdate)
|
|
{
|
|
// 流鞭 函版 (辨靛厘 ℃ 辨靛盔 ?)
|
|
case GUILDMEMBUPDATE_TYPE_ROLE:
|
|
{
|
|
if (pPacket->nChgAccountDBID == pSession->GetAccountDBID())
|
|
{
|
|
pSession->GetGuildSelfView().btGuildRole = static_cast<BYTE>(pPacket->Int1);
|
|
|
|
// 辨靛 矫阿沥焊 盎脚
|
|
pSession->RefreshGuildSelfView();
|
|
}
|
|
}
|
|
break;
|
|
|
|
// 辨靛厘 困烙 (辨靛厘 ℃ 辨靛盔 ?)
|
|
case GUILDMEMBUPDATE_TYPE_GUILDMASTER:
|
|
{
|
|
if (pPacket->nChgAccountDBID == pSession->GetAccountDBID())
|
|
{
|
|
pSession->GetGuildSelfView().btGuildRole = static_cast<BYTE>(GUILDROLE_TYPE_MASTER);
|
|
|
|
// 辨靛 矫阿沥焊 盎脚
|
|
pSession->RefreshGuildSelfView();
|
|
}
|
|
}
|
|
break;
|
|
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
|
|
case MAGA_REFRESHGUILDSELFVIEW: // 辨靛 矫阿沥焊 (俺牢/窜眉) 函版 舅覆
|
|
{
|
|
MARefreshGuildSelfView *pPacket = reinterpret_cast<MARefreshGuildSelfView*>(pDataBuffer);
|
|
DN_ASSERT(NULL != pPacket, "Invalid!");
|
|
DN_ASSERT(pPacket->GuildUID.IsSet(), "Invalid!");
|
|
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
if (0 != pPacket->nAccountDBID && 0 != pPacket->nCharacterDBID)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (pPacket->nAccountDBID);
|
|
if (pSession && pGuild->GetUID() == pSession->GetGuildUID())
|
|
{
|
|
pSession->SetGuildSelfView(pGuild->GetInfo()->GuildView);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
std::vector <std::pair<UINT, INT64>> aList;
|
|
pGuild->GetMemberList (aList);
|
|
|
|
if (aList.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = aList.begin ();
|
|
|
|
for (; iter != aList.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->SetGuildSelfView(pGuild->GetInfo()->GuildView);
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
|
|
case MAGA_GUILDCHAT: // 辨靛 盲泼 舅覆
|
|
{
|
|
MAGuildChat *pPacket = reinterpret_cast<MAGuildChat*>(pDataBuffer);
|
|
DN_ASSERT(NULL != pPacket, "Invalid!");
|
|
DN_ASSERT(pPacket->GuildUID.IsSet(), "Invalid!");
|
|
DN_ASSERT(LONG_MAX == pPacket->nManagedID, "Invalid!");
|
|
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
|
|
std::vector <std::pair<UINT, INT64>> aList;
|
|
pGuild->GetMemberList (aList);
|
|
|
|
if (aList.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = aList.begin ();
|
|
|
|
for (; iter != aList.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->SendGuildChat(pPacket->GuildUID, pPacket->nAccountDBID, pPacket->nCharacterDBID, pPacket->wszChatMsg, pPacket->nLen);
|
|
}
|
|
}
|
|
break;
|
|
|
|
#ifdef PRE_ADD_DOORS_GUILDCHAT_DISCONNECT
|
|
case MAGA_GUILDCHAT_MOBILE:
|
|
{
|
|
MADoorsGuildChat *pPacket = reinterpret_cast<MADoorsGuildChat*>(pDataBuffer);
|
|
DN_ASSERT(NULL != pPacket, "Invalid!");
|
|
DN_ASSERT(pPacket->GuildUID.IsSet(), "Invalid!");
|
|
DN_ASSERT(LONG_MAX == pPacket->nManagedID, "Invalid!");
|
|
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
if (pGuild->IsMemberExist(pPacket->nCharacterDBID, NULL))
|
|
{
|
|
std::vector <std::pair<UINT, INT64>> aList;
|
|
pGuild->GetMemberList (aList);
|
|
|
|
if (aList.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = aList.begin ();
|
|
|
|
for (; iter != aList.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->SendDoorsGuildChat(pPacket->GuildUID, pPacket->nCharacterDBID, pPacket->wszChatMsg, pPacket->nLen);
|
|
}
|
|
return;
|
|
}
|
|
_DANGER_POINT_MSG(L"辨靛牢盔捞 酒囱单 葛官老俊辑 皋技瘤啊 甸绢吭促");
|
|
}
|
|
break;
|
|
#endif //#ifdef PRE_ADD_DOORS_GUILDCHAT_DISCONNECT
|
|
case MAGA_CHANGEGUILDNAME : // 辨靛疙 函版
|
|
{
|
|
MAGuildChangeName *pPacket = reinterpret_cast<MAGuildChangeName*>(pDataBuffer);
|
|
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
|
|
std::vector <std::pair<UINT, INT64>> aList;
|
|
pGuild->GetMemberList (aList);
|
|
|
|
if (aList.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = aList.begin ();
|
|
|
|
for (; iter != aList.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->SendChangeGuildName(pPacket->wszGuildName);
|
|
_wcscpy( pSession->GetGuildSelfView().wszGuildName, _countof(pSession->GetGuildSelfView().wszGuildName), pPacket->wszGuildName, (int)wcslen(pPacket->wszGuildName) );
|
|
pSession->RefreshGuildSelfView();
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_CHANGEGUILDMARK:
|
|
{
|
|
MAGuildChangeMark *pPacket = reinterpret_cast<MAGuildChangeMark*>(pDataBuffer);
|
|
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
|
|
std::vector <std::pair<UINT, INT64>> aList;
|
|
pGuild->GetMemberList (aList);
|
|
|
|
if (aList.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = aList.begin ();
|
|
|
|
for (; iter != aList.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->SendChangeGuildMark(pPacket);
|
|
pSession->GetGuildSelfView().wGuildMark = pPacket->wMark;
|
|
pSession->GetGuildSelfView().wGuildMarkBG = pPacket->wMarkBG;
|
|
pSession->GetGuildSelfView().wGuildMarkBorder = pPacket->wMarkBorder;
|
|
pSession->RefreshGuildSelfView();
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_GUILDLEVELUP:
|
|
{
|
|
MAGuildLevelUp *pPacket = reinterpret_cast<MAGuildLevelUp*>(pDataBuffer);
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
std::vector <std::pair<UINT, INT64>> aList;
|
|
pGuild->GetMemberList (aList);
|
|
|
|
if (aList.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = aList.begin ();
|
|
for (; iter != aList.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
|
|
pSession->SendGuildLevelUp(pPacket->nLevel);
|
|
}
|
|
}
|
|
break;
|
|
|
|
case MAGA_UPDATEGUILDEXP:
|
|
{
|
|
MAGuildExp *pPacket = reinterpret_cast<MAGuildExp*>(pDataBuffer);
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
|
|
std::vector <std::pair<UINT, INT64>> aList;
|
|
pGuild->GetMemberList (aList);
|
|
|
|
if (aList.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = aList.begin ();
|
|
for (; iter != aList.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
if (pPacket->cPointType == GUILDPOINTTYPE_STAGE)
|
|
{
|
|
if (pSession->GetCharacterDBID() == pPacket->biCharacterDBID)
|
|
{
|
|
pSession->SendUpdateGuildExp(ERROR_NONE, pPacket->cPointType, pPacket->nPointValue, pPacket->nGuildExp, pPacket->biCharacterDBID, pPacket->nMissionID);
|
|
break;
|
|
}
|
|
}
|
|
else
|
|
pSession->SendUpdateGuildExp(ERROR_NONE, pPacket->cPointType, pPacket->nPointValue, pPacket->nGuildExp, pPacket->biCharacterDBID, pPacket->nMissionID);
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_ENROLLGUILDWAR: // 辨靛傈 脚没 舅覆
|
|
{
|
|
MAEnrollGuildWar *pPacket = reinterpret_cast<MAEnrollGuildWar*>(pDataBuffer);
|
|
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
|
|
std::vector <std::pair<UINT, INT64>> vGuildMember;
|
|
pGuild->GetMemberList (vGuildMember);
|
|
|
|
if (vGuildMember.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = vGuildMember.begin ();
|
|
|
|
for (; iter != vGuildMember.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->GetGuildSelfView().wWarSchduleID = pPacket->wScheduleID;
|
|
pSession->GetGuildSelfView().cTeamColorCode = pPacket->cTeamColorCode;
|
|
pSession->RefreshGuildSelfView();
|
|
|
|
pSession->SendEnrollGuildWar(ERROR_NONE, pPacket->wScheduleID, pPacket->cTeamColorCode);
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_CHANGE_GUILDWAR_STEP:
|
|
{
|
|
MAChangeGuildWarStep * pPacket = (MAChangeGuildWarStep*)pDataBuffer;
|
|
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii;
|
|
for (ii = m_ConnectList.begin(); ii != m_ConnectList.end(); ii++)
|
|
{
|
|
(*ii).second->SendGuildWarEvent(pPacket->wScheduleID, pPacket->cEventStep, pPacket->cEventType);
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_SETGUILDWAR_PRE_WIN_GUILD :
|
|
{
|
|
MAGuildWarPreWinGuild *pPacket = reinterpret_cast<MAGuildWarPreWinGuild*>(pDataBuffer);
|
|
for( std::map <unsigned int, CDNGameRoom*>::iterator itor=m_GameRoomList.begin() ; itor!=m_GameRoomList.end() ; ++itor )
|
|
{
|
|
CDNGameRoom* pRoom = (*itor).second;
|
|
if( pRoom && pRoom->bIsFarmRoom() == true && pRoom->GetRoomState() == _GAME_STATE_PLAY )
|
|
{
|
|
static_cast<CDNFarmGameRoom*>(pRoom)->OnStartGuildWarFinal();
|
|
}
|
|
}
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
|
|
std::vector <std::pair<UINT, INT64>> vGuildMember;
|
|
pGuild->GetMemberList (vGuildMember);
|
|
|
|
if (vGuildMember.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = vGuildMember.begin ();
|
|
|
|
for (; iter != vGuildMember.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->SendGuildWarPreWinGuild(pPacket->bPreWin);
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_SETGUILDWAR_TOURNAMENTWIN :
|
|
{
|
|
MASetGuildWarTournamentWin *pPacket = reinterpret_cast<MASetGuildWarTournamentWin*>(pDataBuffer);
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii;
|
|
|
|
SCGuildWarTournamentWin GuildWarTournamentWin;
|
|
memset(&GuildWarTournamentWin, 0, sizeof(GuildWarTournamentWin));
|
|
GuildWarTournamentWin.cMatchTypeCode = pPacket->cMatchTypeCode;
|
|
memcpy(GuildWarTournamentWin.wszGuildName, pPacket->wszGuildName, sizeof(GuildWarTournamentWin.wszGuildName));
|
|
|
|
for (ii = m_ConnectList.begin(); ii != m_ConnectList.end(); ii++)
|
|
{
|
|
(*ii).second->SendGuildWarTournamentWin(&GuildWarTournamentWin);
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_GUILDRECRUIT_MEMBER :
|
|
{
|
|
MAGuildRecruitMember *pPacket = reinterpret_cast<MAGuildRecruitMember*>(pDataBuffer);
|
|
CDNUserSession* pSession = GetSessionByADBID( pPacket->uiAccountDBID );
|
|
if( pSession )
|
|
{
|
|
if(pPacket->cAcceptType == GuildRecruitSystem::AcceptType::AcceptOn)
|
|
{
|
|
pSession->SetGuildSelfView(TGuildSelfView(pPacket->GuildView, GUILDROLE_TYPE_JUNIOR));
|
|
if (pSession->GetGuildUID().IsSet())
|
|
{
|
|
CDNGuildBase* pGuild = g_pGuildManager->At(pSession->GetGuildUID());
|
|
if (!pGuild)
|
|
{
|
|
if (pSession->GetDBConnection() && pSession->GetDBConnection()->GetActive())
|
|
{
|
|
pSession->GetDBConnection()->QueryGetGuildInfo(pSession, pSession->GetGuildUID().nDBID, true);
|
|
pSession->GetDBConnection()->QueryGetGuildRewardItem( pSession->GetDBThreadID(), pSession->GetWorldSetID(), pSession->GetAccountDBID(), pSession->GetGuildUID().nDBID );
|
|
}
|
|
}
|
|
}
|
|
pSession->GetEventSystem()->OnEvent( EventSystem::OnGuildJoin );
|
|
}
|
|
pSession->SendGuildRecruitMemberResult(ERROR_NONE, pPacket->GuildView.wszGuildName, (GuildRecruitSystem::AcceptType::eType)pPacket->cAcceptType);
|
|
}
|
|
break;
|
|
}
|
|
break;
|
|
case MAGA_GUILD_ADD_REWARDITEM:
|
|
{
|
|
MAGuildRewardItem *pPacket = reinterpret_cast<MAGuildRewardItem*>(pDataBuffer);
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
TGuildRewardItem RewardItemInfo;
|
|
memset( &RewardItemInfo, 0, sizeof(RewardItemInfo) );
|
|
pGuild->AddGuildRewardItem( pPacket->nItemID, pPacket->m_tExpireDate, RewardItemInfo );
|
|
|
|
std::vector <std::pair<UINT, INT64>> vGuildMember;
|
|
pGuild->GetMemberList (vGuildMember);
|
|
|
|
if (vGuildMember.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = vGuildMember.begin ();
|
|
|
|
for (; iter != vGuildMember.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->SendAddGuildRewardItem(RewardItemInfo);
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_GUILD_EXTEND_GUILDSIZE:
|
|
{
|
|
MAExtendGuildSize *pPacket = reinterpret_cast<MAExtendGuildSize*>(pDataBuffer);
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
pGuild->SetInfo()->wGuildSize = pPacket->nGuildSize;
|
|
|
|
std::vector <std::pair<UINT, INT64>> vGuildMember;
|
|
pGuild->GetMemberList (vGuildMember);
|
|
|
|
if (vGuildMember.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = vGuildMember.begin ();
|
|
|
|
for (; iter != vGuildMember.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->SendExtendGuildSize(pPacket->nGuildSize);
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_CHANGE_CHARACTERNAME:
|
|
{
|
|
MAChangeCharacterName *pPacket = reinterpret_cast<MAChangeCharacterName*>(pDataBuffer);
|
|
std::map <unsigned int, CDNGameRoom*>::iterator ii;
|
|
for (ii = m_GameRoomList.begin(); ii != m_GameRoomList.end(); ii++)
|
|
{
|
|
if ((*ii).second->bIsFarmRoom())
|
|
(*ii).second->UpdateCharacterName(pPacket);
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_GUILDMEMBLOGINLIST: // 辨靛盔 肺弊牢 格废 舅覆
|
|
{
|
|
MAGuildMemberLoginList *pPacket = reinterpret_cast<MAGuildMemberLoginList*>(pDataBuffer);
|
|
|
|
CDNGuildBase* pGuild = g_pGuildManager->At (pPacket->GuildUID);
|
|
|
|
// 磊盔炼荤
|
|
if (!pGuild)
|
|
break;
|
|
|
|
#if !defined( PRE_ADD_NODELETEGUILD )
|
|
CDetachAutoEx<CDNGuildBase> AutoDetach (pGuild);
|
|
if (FALSE == pGuild->IsEnable()) break;
|
|
#endif
|
|
|
|
std::vector <std::pair<UINT, INT64>> List;
|
|
pGuild->GetMemberList (List);
|
|
|
|
if (List.empty())
|
|
break;
|
|
|
|
std::vector <std::pair<UINT, INT64>>::iterator iter = List.begin ();
|
|
for (; iter != List.end (); iter++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID (iter->first);
|
|
if (!pSession || !pSession->GetGuildUID().IsSet() || pGuild->GetUID() != pSession->GetGuildUID() || (iter->second != pSession->GetCharacterDBID()))
|
|
continue;
|
|
|
|
pSession->SendGuildMemberLoginList(pPacket->GuildUID, pPacket->nCount, pPacket->List);
|
|
}
|
|
}
|
|
break;
|
|
|
|
case MAGA_ZEROPOPULATION:
|
|
{
|
|
MAGAZeroPopulation * pPacket = (MAGAZeroPopulation*)pDataBuffer;
|
|
m_bZeroPopulation = pPacket->bZeroPopulation;
|
|
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii;
|
|
for (ii = m_ConnectList.begin(); ii != m_ConnectList.end(); ii++)
|
|
(*ii).second->SendZeroPopulation(pPacket->bZeroPopulation);
|
|
break;
|
|
}
|
|
|
|
case MAGA_ASSIGN_PERIODQUEST:
|
|
{
|
|
MAGAAssginPeriodQuest * pPacket = (MAGAAssginPeriodQuest*)pDataBuffer;
|
|
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii;
|
|
for (ii = m_ConnectList.begin(); ii != m_ConnectList.end(); ii++)
|
|
{
|
|
(*ii).second->GetQuest()->OnPeriodEvent(pPacket->nQuestID, pPacket->bFlag);
|
|
(*ii).second->SendAssginPeriodQuest(pPacket->nQuestID, pPacket->bFlag);
|
|
}
|
|
break;
|
|
}
|
|
|
|
case MAGA_NOTICE_PERIODQUEST:
|
|
{
|
|
MAGANoticePeriodQuest * pPacket = (MAGANoticePeriodQuest*)pDataBuffer;
|
|
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii;
|
|
for (ii = m_ConnectList.begin(); ii != m_ConnectList.end(); ii++)
|
|
{
|
|
if ((*ii).second->GetWorldSetID() == pPacket->cWorldSetID)
|
|
(*ii).second->SendPeriodQuestNotice(pPacket->nItemID, pPacket->nNoticeCount);
|
|
}
|
|
|
|
break;
|
|
}
|
|
case MAGA_CHECK_LASTDUNGEONINFO:
|
|
{
|
|
MAGACheckLastDungeonInfo* pPacket = reinterpret_cast<MAGACheckLastDungeonInfo*>(pDataBuffer);
|
|
|
|
CDNGameRoom* pGameRoom = GetRoom( pPacket->iRoomID );
|
|
|
|
bool bIsCheck = false;
|
|
if( pGameRoom )
|
|
bIsCheck = pGameRoom->bIsBackupPartyInfo( pPacket->biCharacterDBID );
|
|
g_pMasterConnectionManager->SendCheckLastDungeonInfo( pPacket->cWorldSetID, pPacket->uiAccountDBID, pPacket->biCharacterDBID, bIsCheck, bIsCheck ? pGameRoom->GetPartyName() : NULL );
|
|
break;
|
|
}
|
|
case MAGA_DELETE_BACKUPDUNGEONINFO:
|
|
{
|
|
MAGADeleteBackupDungeonInfo* pPacket = reinterpret_cast<MAGADeleteBackupDungeonInfo*>(pDataBuffer);
|
|
|
|
CDNGameRoom* pGameRoom = GetRoom( pPacket->iRoomID );
|
|
if( pGameRoom )
|
|
pGameRoom->DelBackupPartyInfo( pPacket->biCharacterDBID );
|
|
break;
|
|
}
|
|
|
|
#if defined( PRE_WORLDCOMBINE_PARTY )
|
|
case MAGA_GET_WORLDPARTYMEMBER:
|
|
{
|
|
SendWorldPartyMember( (char)pHeader->nMasterID, reinterpret_cast<MAGetWorldPartyMember*>(pDataBuffer) );
|
|
}
|
|
break;
|
|
#endif
|
|
#if defined( PRE_ADD_BESTFRIEND )
|
|
case MAGA_CANCEL_BESTFRIEND:
|
|
{
|
|
MACancelBestFriend *pPacket = (MACancelBestFriend*)pDataBuffer;
|
|
|
|
CDNUserSession *pSession = GetSessionByADBID(pPacket->nAccountDBID);
|
|
if (!pSession) break;
|
|
|
|
pSession->GetDBConnection()->QueryGetBestFriend(pSession->GetDBThreadID(), pSession, true);
|
|
|
|
pSession->SendCancelBestFriend(ERROR_NONE, pPacket->wszFromName, pPacket->bCancel);
|
|
}
|
|
break;
|
|
case MAGA_CLOSE_BESTFRIEND:
|
|
{
|
|
MACloseBestFriend *pPacket = (MACloseBestFriend*)pDataBuffer;
|
|
|
|
CDNUserSession *pSession = GetSessionByADBID(pPacket->nAccountDBID);
|
|
if (!pSession) break;
|
|
|
|
pSession->SendCloseBestFriend(ERROR_NONE, pPacket->wszFromName);
|
|
|
|
pSession->CloseBestFirend();
|
|
}
|
|
break;
|
|
case MAGA_LEVELUP_BESTFRIEND:
|
|
{
|
|
MALevelUpBestFriend *pPacket = (MALevelUpBestFriend*)pDataBuffer;
|
|
|
|
CDNUserSession *pSession = GetSessionByADBID(pPacket->nAccountDBID);
|
|
if (!pSession) break;
|
|
|
|
pSession->BestFriendChangeLevel(pPacket->cLevel);
|
|
}
|
|
break;
|
|
#endif
|
|
#if defined( PRE_PRIVATECHAT_CHANNEL )
|
|
case MAGA_PRIVATECHATCHANNEL_MEMBERADD:
|
|
{
|
|
MAAddPrivateChannelMember *pPacket = (MAAddPrivateChannelMember*)pDataBuffer;
|
|
|
|
CDNPrivateChaChannel* pPrivateChatChannel = g_pPrivateChatChannelManager->GetPrivateChannelInfo( pPacket->cWorldSetID, pPacket->nPrivateChatChannelID );
|
|
|
|
if(pPrivateChatChannel)
|
|
{
|
|
std::list<TPrivateChatChannelMember> MemberList;
|
|
MemberList.clear();
|
|
pPrivateChatChannel->GetPrivateChannelMember(MemberList);
|
|
|
|
for(std::list<TPrivateChatChannelMember>::iterator itor = MemberList.begin();itor != MemberList.end();itor++)
|
|
{
|
|
if(itor->nAccountDBID == pPacket->Member.nAccountDBID )
|
|
continue;
|
|
|
|
CDNUserSession *pSession = GetSessionByADBID(itor->nAccountDBID);
|
|
if (!pSession) continue;
|
|
|
|
pSession->SendPrivateChatChannelMemberAdd(ERROR_NONE, pPacket->Member);
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_PRIVATECHATCHANNEL_MEMBERINVITE:
|
|
{
|
|
MAInvitePrivateChannelMember *pPacket = (MAInvitePrivateChannelMember*)pDataBuffer;
|
|
|
|
CDNUserSession *pSession = GetSessionByADBID(pPacket->nInviteAccountDBID);
|
|
if (!pSession) break;
|
|
if(pSession)
|
|
{
|
|
if(pSession->GetPrivateChannelID())
|
|
{
|
|
if(g_pMasterConnectionManager)
|
|
{
|
|
g_pMasterConnectionManager->SendInvitePrivateChatChannelResult(pSession->GetWorldSetID(), ERROR_ALREADY_JOINCHANNEL, pPacket->nMasterAccountDBID);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
pSession->SetPrivateChannelID(pPacket->nPrivateChatChannelID);
|
|
pSession->GetDBConnection()->QueryInvitePrivateChatChannelMember(pSession, pPacket->nPrivateChatChannelID, pPacket->nMasterAccountDBID);
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_PRIVATECHATCHANNEL_MEMBERINVITERESULT:
|
|
{
|
|
MAInvitePrivateChannelMemberResult *pPacket = (MAInvitePrivateChannelMemberResult*)pDataBuffer;
|
|
|
|
CDNUserSession *pSession = GetSessionByADBID(pPacket->nMasterAccountDBID);
|
|
if (!pSession) break;
|
|
pSession->SendPrivateChatChannelInviteResult(pPacket->nRet);
|
|
}
|
|
break;
|
|
case MAGA_PRIVATECHATCHANNEL_MEMBERDEL:
|
|
{
|
|
MADelPrivateChannelMember *pPacket = (MADelPrivateChannelMember*)pDataBuffer;
|
|
|
|
CDNPrivateChaChannel* pPrivateChatChannel = g_pPrivateChatChannelManager->GetPrivateChannelInfo( pPacket->cWorldSetID, pPacket->nPrivateChatChannelID );
|
|
|
|
if(pPrivateChatChannel)
|
|
{
|
|
std::list<TPrivateChatChannelMember> MemberList;
|
|
MemberList.clear();
|
|
pPrivateChatChannel->GetPrivateChannelMember(MemberList);
|
|
|
|
for(std::list<TPrivateChatChannelMember>::iterator itor = MemberList.begin();itor != MemberList.end();itor++)
|
|
{
|
|
if(itor->biCharacterDBID == pPacket->biCharacterDBID )
|
|
continue;
|
|
|
|
CDNUserSession *pSession = GetSessionByADBID(itor->nAccountDBID);
|
|
if (!pSession) continue;
|
|
|
|
if(pPacket->eType == PrivateChatChannel::Common::KickMember)
|
|
pSession->SendPrivateChatChannelMemberKick(ERROR_NONE, pPacket->biCharacterDBID, pPacket->wszName );
|
|
else
|
|
pSession->SendPrivateChatChannelMemberDel(ERROR_NONE, pPacket->biCharacterDBID, pPacket->wszName );
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_PRIVATECHATCHANNEL_MEMBERKICKRESULT:
|
|
{
|
|
MAKickPrivateChannelMemberResult* pPacket = (MAKickPrivateChannelMemberResult*)pDataBuffer;
|
|
CDNUserSession *pSession = GetSessionByADBID(pPacket->nAccountDBID);
|
|
if( pSession )
|
|
{
|
|
pSession->SendPrivateChatChannelKickResult(ERROR_NONE, true);
|
|
pSession->SetPrivateChannelID(0);
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_PRIVATECHATCHANNEL_MOD:
|
|
{
|
|
MAModPrivateChannel* pPacket = (MAModPrivateChannel*)pDataBuffer;
|
|
if( g_pPrivateChatChannelManager )
|
|
{
|
|
CDNPrivateChaChannel* pPrivateChatChannel = g_pPrivateChatChannelManager->GetPrivateChannelInfo(pPacket->cWorldSetID, pPacket->nPrivateChatChannelID);
|
|
if( pPrivateChatChannel )
|
|
{
|
|
std::list<TPrivateChatChannelMember> MemberList;
|
|
MemberList.clear();
|
|
pPrivateChatChannel->GetPrivateChannelMember(MemberList);
|
|
|
|
CDNUserSession* pSession = NULL;
|
|
WCHAR MasterName[NAMELENMAX];
|
|
memset(MasterName, 0, sizeof(MasterName));
|
|
pPrivateChatChannel->GetMasterCharacterName(MasterName);
|
|
|
|
for(std::list<TPrivateChatChannelMember>::iterator itor = MemberList.begin(); itor != MemberList.end();itor++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID(itor->nAccountDBID);
|
|
if(pSession)
|
|
{
|
|
pSession->SendPrivateChatChannelInfoMod( ERROR_NONE, pPacket->eType, MasterName, pPacket->biCharacterDBID );
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_PRIVATECHATCHANNEL_MODMEMBERNAME:
|
|
{
|
|
MAModPrivateChannelMemberName* pPacket = (MAModPrivateChannelMemberName*)pDataBuffer;
|
|
if( g_pPrivateChatChannelManager )
|
|
{
|
|
CDNPrivateChaChannel* pPrivateChatChannel = g_pPrivateChatChannelManager->GetPrivateChannelInfo(pPacket->cWorldSetID, pPacket->nPrivateChatChannelID);
|
|
if( pPrivateChatChannel )
|
|
{
|
|
TPrivateChatChannelMember Member = pPrivateChatChannel->GetPrivateChannelMember( pPacket->biCharacterDBID );
|
|
if( Member.biCharacterDBID <= 0)
|
|
break;
|
|
std::list<TPrivateChatChannelMember> MemberList;
|
|
MemberList.clear();
|
|
pPrivateChatChannel->GetPrivateChannelMember(MemberList);
|
|
|
|
CDNUserSession* pSession = NULL;
|
|
for(std::list<TPrivateChatChannelMember>::iterator itor = MemberList.begin(); itor != MemberList.end();itor++)
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID(itor->nAccountDBID);
|
|
if(pSession)
|
|
{
|
|
pSession->SendPrivateChatChannelMemberAdd(ERROR_NONE, Member);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
#endif
|
|
#if defined(PRE_ADD_MUTE_USERCHATTING)
|
|
case MAGA_MUTE_USERCHAT:
|
|
{
|
|
MAMuteUserChat* pPacket = (MAMuteUserChat*)pDataBuffer;
|
|
|
|
CDNUserSession *pSession = GetSessionByADBID(pPacket->uiMuteUserAccountID);
|
|
if(pSession)
|
|
pSession->ModCommonVariableData(CommonVariable::Type::MuteChatting, pPacket->nMuteMinute);
|
|
|
|
break;
|
|
}
|
|
#endif // #if defined(PRE_ADD_MUTE_USERCHATTING)
|
|
#if defined( PRE_ALTEIAWORLD_EXPLORE )
|
|
case MAGA_ALTEIAWORLD_SENDTICKET:
|
|
{
|
|
MAAlteiaWorldSendTicket* pPacket = (MAAlteiaWorldSendTicket*)pDataBuffer;
|
|
CDNUserSession *pSession = GetSessionByADBID(pPacket->nAccountDBID);
|
|
if(pSession)
|
|
{
|
|
int nMaxSendTicketCount = static_cast<int>(CGlobalWeightTable::GetInstance().GetValue( CGlobalWeightTable::AlteiaWorldSendTicketCount ));
|
|
pSession->GetDBConnection()->QueryAddAlteiaWorldSendTicketList(pSession, pPacket->biSendCharacterDBID, pPacket->wszSendCharacterName, nMaxSendTicketCount );
|
|
}
|
|
else
|
|
{
|
|
if (g_pMasterConnectionManager)
|
|
g_pMasterConnectionManager->SendAddAlteiaWorldSendTicketResult( pPacket->cWorldSetID, ERROR_ALTEIAWORLD_NOTEXIST_RECVCHARACTER, pPacket->biSendCharacterDBID );
|
|
}
|
|
|
|
}
|
|
break;
|
|
#endif
|
|
#if defined(PRE_ADD_CHNC2C)
|
|
case MAGA_C2C_CHAR_ADDCOIN :
|
|
{
|
|
MAC2CAddCoin* pPacket = (MAC2CAddCoin*)pDataBuffer;
|
|
CDNUserSession* pSession = GetSessionByADBID(pPacket->uiAccountDBID);
|
|
if( pSession && pSession->GetCharacterDBID() == pPacket->biCharacterDBID )
|
|
{
|
|
pSession->GetDBConnection()->QueryTransferGameMoney(pSession->GetDBThreadID(), pSession->GetWorldSetID(), pSession->GetAccountDBID(), pSession->GetCharacterDBID(),
|
|
pPacket->biAddCoin, pPacket->szSeqID, pPacket->szBookID);
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_C2C_CHAR_REDUCECOIN :
|
|
{
|
|
MAC2CReduceCoin* pPacket = (MAC2CReduceCoin*)pDataBuffer;
|
|
CDNUserSession* pSession = GetSessionByADBID(pPacket->uiAccountDBID);
|
|
if( pSession && pSession->GetCharacterDBID() == pPacket->biCharacterDBID )
|
|
{
|
|
pSession->GetDBConnection()->QueryKeepGameMoney(pSession->GetDBThreadID(), pSession->GetWorldSetID(), pSession->GetAccountDBID(), pSession->GetCharacterDBID(),
|
|
pPacket->biReduceCoin, pPacket->szSeqID, pPacket->szBookID);
|
|
}
|
|
}
|
|
break;
|
|
#endif
|
|
#if defined(PRE_ADD_DWC)
|
|
case MAGA_ADD_DWCTEAMMEMBER:
|
|
{
|
|
MAAddDWCTeamMember* pPacket = (MAAddDWCTeamMember*)pDataBuffer;
|
|
CDNUserSession* pSession = GetSessionByADBID(pPacket->nTartgetUserAccountDBID);
|
|
if( pSession )
|
|
{
|
|
pSession->SendInviteDWCTeamMemberAck( pPacket->nAccountDBID, pPacket->biCharacterDBID, pPacket->wszCharacterName, ERROR_NONE, 0 , 0, pPacket->nJob, &pPacket->Location, pPacket->nTeamID );
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_DEL_DWCTEAMMEMB:
|
|
{
|
|
MALeaveDWCTeamMember* pPacket = (MALeaveDWCTeamMember*)pDataBuffer;
|
|
CDNUserSession* pSession = GetSessionByADBID(pPacket->nTartgetUserAccountDBID);
|
|
if( pSession )
|
|
{
|
|
pSession->SendLeaveDWCTeamMember( pPacket->nTeamID, pPacket->biLeaveUserCharacterDBID, pPacket->wszCharacterName, pPacket->nRet);
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_DISMISS_DWCTEAM:
|
|
{
|
|
MADismissDWCTeam* pPacket = (MADismissDWCTeam*)pDataBuffer;
|
|
CDNUserSession* pSession = GetSessionByADBID(pPacket->nTartgetUserAccountDBID);
|
|
if( pSession )
|
|
{
|
|
pSession->SendDismissDWCTeam( pPacket->nTeamID, pPacket->nRet );
|
|
}
|
|
}
|
|
break;
|
|
case MAGA_CHANGE_DWCTEAMMEMB_STATE:
|
|
{
|
|
MAChangeDWCTeamMemberState* pPacket = (MAChangeDWCTeamMemberState*)pDataBuffer;
|
|
CDNUserSession* pSession = GetSessionByADBID(pPacket->nTartgetUserAccountDBID);
|
|
if( pSession )
|
|
{
|
|
pSession->SendChangeDWCTeamMemberState( pPacket->nTeamID, pPacket->biCharacterDBID, &pPacket->Location );
|
|
}
|
|
}
|
|
break;
|
|
#endif
|
|
default:
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID(pHeader->nAccountDBID);
|
|
if (pSession)
|
|
pSession->MasterMessageProcess( pHeader->iMainCmd, pHeader->iSubCmd, pDataBuffer, pHeader->iSize );
|
|
else
|
|
//唱棵 荐 乐绰 巴档 乐嚼聪促 啊阐 肺弊 犬牢~
|
|
g_Log.Log(LogType::_ERROR, L"Session Not Found [AID:%u] [MC:%d] [SC:%d]\n", pHeader->nAccountDBID, pHeader->iMainCmd, pHeader->iSubCmd);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
else
|
|
g_Log.Log(LogType::_ERROR, L"Unknown Ext MessageType Check [Type:%d]\n", pHeader->cMsgType);
|
|
|
|
uiSize -= pHeader->iBufSize;
|
|
pBuffer += pHeader->iBufSize;
|
|
}
|
|
}
|
|
|
|
bool CDNRUDPGameServer::GameRoomDataBaseParsePacket(int iMainCmd, int iSubCmd, const void * pPacket, int iLen)
|
|
{
|
|
switch( iMainCmd )
|
|
{
|
|
case MAINCMD_DARKLAIR:
|
|
{
|
|
switch (iSubCmd)
|
|
{
|
|
case QUERY_UPDATE_DARKLAIR_RESULT:
|
|
{
|
|
TAUpdateDarkLairResult* pData = reinterpret_cast<TAUpdateDarkLairResult*>(const_cast<void*>(pPacket));
|
|
CDNGameRoom* pGameRoom = GetRoom( pData->iRoomID );
|
|
if( pGameRoom )
|
|
pGameRoom->OnDBMessageProcess( iMainCmd, iSubCmd, static_cast<char*>(const_cast<void*>(pPacket)), iLen );
|
|
|
|
return true;
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
case MAINCMD_FARM:
|
|
{
|
|
switch (iSubCmd)
|
|
{
|
|
case QUERY_GETLIST_FIELD:
|
|
{
|
|
TAGetListField* pData = reinterpret_cast<TAGetListField*>(const_cast<void*>(pPacket));
|
|
CDNGameRoom * pFarmRoom = (CDNFarmGameRoom*)GetRoom(pData->iRoomID);
|
|
if (pFarmRoom)
|
|
{
|
|
if (pFarmRoom->GetFarmIndex() > 0)
|
|
((CDNFarmGameRoom*)pFarmRoom)->OnDBMessageProcess(iMainCmd, iSubCmd, reinterpret_cast<char*>(pData), iLen);
|
|
else
|
|
_DANGER_POINT(); //捞矾搁 救掸促.
|
|
}
|
|
return true;
|
|
}
|
|
|
|
case QUERY_GETLIST_FARM:
|
|
{
|
|
TAGetListFarm * pData = (TAGetListFarm*)pPacket;
|
|
|
|
for (int i = 0; i < pData->cCount && i < Farm::Max::FARMCOUNT; i++)
|
|
{
|
|
std::map <unsigned int, CDNGameRoom*>::iterator ii;
|
|
for (ii = m_GameRoomList.begin(); ii != m_GameRoomList.end(); ii++)
|
|
{
|
|
if ((*ii).second->bIsFarmRoom() && (*ii).second->GetFarmIndex() == pData->Farms[i].iFarmDBID)
|
|
{
|
|
(*ii).second->SetFarmActivation(pData->Farms[i].bStartActivate);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
// 酒贰 TA~ 幅狼 菩哦狼 弥惑困函荐绰 馆靛矫 RoomID 捞绢具茄促!!!!!!
|
|
case QUERY_ADD_FIELD:
|
|
case QUERY_DEL_FIELD:
|
|
case QUERY_HARVEST:
|
|
case QUERY_ADD_FIELD_ATTACHMENT:
|
|
case QUERY_GET_FIELDITEMCOUNT:
|
|
case QUERY_GETLIST_FIELD_FORCHARACTER:
|
|
case QUERY_ADD_FIELD_FORCHARACTER:
|
|
case QUERY_DEL_FIELD_FORCHARACTER:
|
|
case QUERY_ADD_FIELD_FORCHARACTER_ATTACHMENT:
|
|
case QUERY_HARVEST_FORCHARACTER:
|
|
{
|
|
int iRoomID;
|
|
memcpy( &iRoomID, static_cast<const char*>(pPacket)+sizeof(TAHeader), sizeof(int) );
|
|
|
|
CDNGameRoom* pGameRoom = GetRoom( iRoomID );
|
|
if( pGameRoom && pGameRoom->bIsFarmRoom() )
|
|
{
|
|
static_cast<CDNFarmGameRoom*>(pGameRoom)->OnDBMessageProcess( iMainCmd, iSubCmd, reinterpret_cast<char*>(const_cast<void*>(pPacket)), iLen );
|
|
}
|
|
|
|
return true;
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
bool CDNRUDPGameServer::CashParsePacket(int iMainCmd, int iSubCmd, const void * pPacket, int iLen)
|
|
{
|
|
UINT nAccountDBID;
|
|
memcpy(&nAccountDBID, pPacket, sizeof(UINT));
|
|
|
|
CDNUserSession *pSession = GetSessionByADBID(nAccountDBID); //key = uid 积己等 技记 按眉府胶飘
|
|
if (pSession)
|
|
{
|
|
if ((pSession->GetState() >= SESSION_STATE_READY && pSession->GetState() <= SESSION_STATE_READY_TO_LOGIN))
|
|
pSession->CashMessageProcess(iMainCmd, iSubCmd, (char*)pPacket, iLen);
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
bool CDNRUDPGameServer::DataBaseParsePacket(int iMainCmd, int iSubCmd, const void * pPacket, int iLen)
|
|
{
|
|
if( GameRoomDataBaseParsePacket( iMainCmd, iSubCmd, pPacket, iLen ) )
|
|
return true;
|
|
|
|
UINT nAccountDBID;
|
|
memcpy(&nAccountDBID, pPacket, sizeof(UINT));
|
|
|
|
CDNUserSession *pSession = GetSessionByADBID(nAccountDBID); //key = uid 积己等 技记 按眉府胶飘
|
|
if (pSession)
|
|
{
|
|
if ((pSession->GetState() >= SESSION_STATE_READY && pSession->GetState() <= SESSION_STATE_READY_TO_LOGIN))
|
|
pSession->DBMessageProcess(iMainCmd, iSubCmd, (char*)pPacket, iLen);
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
void CDNRUDPGameServer::DataBaseUpdate(unsigned long CurTick)
|
|
{
|
|
TQUpdateCharacter Update;
|
|
CDNDBConnection *pDBCon = NULL;
|
|
|
|
if (m_pChangeSaveBuffer->GetCount() > 0){
|
|
if (CurTick >= m_dwChangeSaveTick + 50){
|
|
if (m_pChangeSaveBuffer->View((char*)&Update, sizeof(TQUpdateCharacter)) == 0){
|
|
CDNUserSession* pSession = GetUserSession( Update.nAccountDBID );
|
|
if( pSession )
|
|
{
|
|
pDBCon = pSession->GetDBConnection();
|
|
}
|
|
else
|
|
{
|
|
pDBCon = g_pDBConnectionManager->GetDBConnection( Update.uiDBRandomSeed, Update.cThreadID );
|
|
}
|
|
if (pDBCon)
|
|
{
|
|
pDBCon->QueryDelExpireitem(Update.cThreadID, Update.cWorldSetID, Update.nAccountDBID, Update.biCharacterDBID);
|
|
pDBCon->AddSendData(MAINCMD_STATUS, QUERY_CHANGESERVERUSERDATA, (char*)&Update, sizeof(TQUpdateCharacter));
|
|
m_pChangeSaveBuffer->Skip(sizeof(TQUpdateCharacter));
|
|
}
|
|
#ifdef PRE_ADD_CHAGNESERVER_LOGGING
|
|
else
|
|
{
|
|
g_Log.Log(LogType::_ERROR, L"ExternalDoUpdate pDBCon == NULL [ADBID:%d]\n", Update.nAccountDBID);
|
|
}
|
|
#endif //#ifdef PRE_ADD_CHAGNESERVER_LOGGING
|
|
}
|
|
m_dwChangeSaveTick = CurTick;
|
|
}
|
|
}
|
|
|
|
if (m_pLastSaveBuffer->GetCount() > 0){
|
|
if (CurTick >= m_dwLastSaveTick + 50){
|
|
if (m_pLastSaveBuffer->View((char*)&Update, sizeof(TQUpdateCharacter)) == 0){
|
|
CDNUserSession* pSession = GetUserSession( Update.nAccountDBID );
|
|
if( pSession )
|
|
{
|
|
pDBCon = pSession->GetDBConnection();
|
|
}
|
|
else
|
|
{
|
|
pDBCon = g_pDBConnectionManager->GetDBConnection( Update.uiDBRandomSeed, Update.cThreadID );
|
|
}
|
|
if (pDBCon){
|
|
pDBCon->AddSendData(MAINCMD_STATUS, QUERY_LASTUPDATEUSERDATA, (char*)&Update, sizeof(TQUpdateCharacter));
|
|
m_pLastSaveBuffer->Skip(sizeof(TQUpdateCharacter));
|
|
}
|
|
#ifdef PRE_ADD_CHAGNESERVER_LOGGING
|
|
else
|
|
{
|
|
g_Log.Log(LogType::_ERROR, L"ExternalDoUpdate pDBCon == NULL [ADBID:%d]\n", Update.nAccountDBID);
|
|
}
|
|
#endif //#ifdef PRE_ADD_CHAGNESERVER_LOGGING
|
|
}
|
|
m_dwLastSaveTick = CurTick;
|
|
}
|
|
}
|
|
|
|
if (m_bIsCloseService)
|
|
{
|
|
if (m_GameRoomList.empty())
|
|
if (m_pChangeSaveBuffer->GetCount() <= 0 && m_pLastSaveBuffer->GetCount() <= 0)
|
|
{
|
|
m_bIsAllFlushSaveData = true;
|
|
m_bIsCloseService = false;
|
|
m_pServerManager->CheckCloseGameServer(this);
|
|
}
|
|
}
|
|
}
|
|
|
|
void CDNRUDPGameServer::Parse(int iMainCmd, int iSubCmd, const void * pData, int iLen, int iNetID, BYTE cSeqLevel)
|
|
{
|
|
//rudp窜俊辑 甸绢坷绰 皋技瘤 颇胶涝聪促 角犁 菩哦阑 颇教篮 阿 技记窜栏肺 逞辫.
|
|
std::map <int, CDNUserSession*>::iterator ii = m_ClientList.find(iNetID); //key = netid 角犁 牧池飘等 按眉府胶飘
|
|
if (ii != m_ClientList.end())
|
|
{
|
|
if ((*ii).second->IsConnected())
|
|
{
|
|
//沥焊啊 乐促搁 捞固牧池记登绢 乐绰 惑怕扼绊 焊搁 邓聪促. 官肺 皋技瘤菩莫 绊绊教~
|
|
if ((*ii).second->GetGameRoom())
|
|
(*ii).second->GetGameRoom()->OnDispatchMessage((*ii).second, iMainCmd, iSubCmd, (char*)pData, iLen, cSeqLevel);
|
|
else _DANGER_POINT();
|
|
}
|
|
#ifdef PRE_MOD_INDUCE_TCPCONNECT
|
|
else if (iMainCmd == CS_SYSTEM && iSubCmd == eSystem::CS_TCP_CONNECT_REQ)
|
|
{
|
|
(*ii).second->RecvReqTCPConnect();
|
|
}
|
|
#endif //#ifdef PRE_MOD_INDUCE_TCPCONNECT
|
|
}
|
|
else
|
|
{
|
|
//绝促搁 弥檬狼 牧池记涝聪促. 八刘 截况 壕矫促.
|
|
CSConnectRequest * pMsg = (CSConnectRequest*)pData;
|
|
if (sizeof(CSConnectRequest) == iLen && iMainCmd == CS_SYSTEM && iSubCmd == eSystem::CS_CONNECT_REQUEST)
|
|
{
|
|
//磊 沥惑利栏肺 甸绢 吭嚼聪促.
|
|
//八刘截况 壕聪促. 牧池记 八刘阑 且 荐 乐绰 蜡老茄 扁雀 涝聪促.
|
|
std::map <unsigned int , CDNUserSession*>::iterator ic = m_VerifyList.find(pMsg->nSessionID);
|
|
if (ic == m_VerifyList.end())
|
|
{
|
|
//备扼里捞! rudp connection沥焊父 朝妨凛聪促. 技记狼 家戈篮 冯窜俊辑 贸府~
|
|
DisConnect(iNetID);
|
|
g_Log.Log(LogType::_ERROR, L"Connect|RUDP Illegal Connect [SID:%d]\n", pMsg->nSessionID);
|
|
return;
|
|
}
|
|
if (AddConnect(iNetID, (*ic).second) == true)
|
|
{
|
|
#ifdef PRE_MOD_INDUCE_TCPCONNECT
|
|
(*ic).second->SendReqTCPConnect(timeGetTime());
|
|
#else //#ifdef PRE_MOD_INDUCE_TCPCONNECT
|
|
(*ic).second->SendPacket(SC_SYSTEM, eSystem::SC_TCP_CONNECT_REQ, NULL, 0, _RELIABLE);
|
|
g_Log.Log(LogType::_GAMECONNECTLOG, (*ic).second, L"[%d] CS_CONNECT_REQUEST\n", g_Config.nManagedID );
|
|
#endif //#ifdef PRE_MOD_INDUCE_TCPCONNECT
|
|
++m_uiConnectReqCount;
|
|
}
|
|
else
|
|
{
|
|
DisConnect(iNetID);
|
|
g_Log.Log(LogType::_ERROR, L"RUDP AddConnect Error sid:[%d]\n", pMsg->nSessionID);
|
|
}
|
|
}
|
|
else
|
|
DisConnect(iNetID);
|
|
}
|
|
}
|
|
|
|
void CDNRUDPGameServer::Recv(int iNetID, void * pData, int iLen)
|
|
{
|
|
for( int i=0 ; i<iLen ; )
|
|
{
|
|
void* pSrc = static_cast<char*>(pData)+i;
|
|
int iPacketLen = CalcGamePacketSize(pSrc, iLen-i);
|
|
if( iLen < iPacketLen+i )
|
|
break;
|
|
|
|
DNGAME_PACKET* pPacket = static_cast<DNGAME_PACKET*>(pSrc);
|
|
if(DecodeGamePacket(pPacket) == true)
|
|
{
|
|
Parse(pPacket->header, pPacket->sub_header, pPacket->data, pPacket->datasize, iNetID, pPacket->seq);
|
|
}
|
|
|
|
i += iPacketLen;
|
|
}
|
|
}
|
|
|
|
CDNUserSession * CDNRUDPGameServer::GetSessionByADBID(unsigned int nAccountDBID)
|
|
{
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii = m_ConnectList.find(nAccountDBID);
|
|
if (ii != m_ConnectList.end())
|
|
return (*ii).second;
|
|
return NULL;
|
|
}
|
|
|
|
CDNGameRoom * CDNRUDPGameServer::CreateGameRoom(MAGAReqRoomID * pPacket)
|
|
{
|
|
if (m_bIsCloseService) return NULL; //霸烙辑滚啊 摧洒绰 吝 涝聪促.
|
|
|
|
unsigned int nRoomID = m_pServerManager->GenRoomID(this);
|
|
if (nRoomID == 0)
|
|
return NULL;
|
|
|
|
CDNGameRoom* pRoom = NULL;
|
|
switch( pPacket->GameTaskType ) {
|
|
case GameTaskType::Normal:
|
|
pRoom = new IBoostPoolDNGameRoom(this, nRoomID, pPacket );
|
|
break;
|
|
case GameTaskType::PvP:
|
|
pRoom = new CDNPvPGameRoom( this, nRoomID, pPacket );
|
|
break;
|
|
case GameTaskType::DarkLair:
|
|
pRoom = new CDNDLGameRoom(this, nRoomID, pPacket );
|
|
break;
|
|
case GameTaskType::Farm:
|
|
{
|
|
#if defined( _WORK )
|
|
if( g_Config.bDisableFarm )
|
|
return NULL;
|
|
#endif // #if defined( _WORK )
|
|
pRoom = new CDNFarmGameRoom( this, nRoomID, pPacket );
|
|
break;
|
|
}
|
|
}
|
|
|
|
if( pRoom == NULL )
|
|
{
|
|
m_pServerManager->RemoveGameRoom(nRoomID, this);
|
|
return NULL;
|
|
}
|
|
|
|
pRoom->SetPartyKickedMemberList( pPacket->nKickedMemberList );
|
|
|
|
m_GameRoomList[pRoom->GetRoomID()] = pRoom;
|
|
unsigned int iRoomID = pRoom->GetRoomID();
|
|
|
|
#if defined( PRE_PARTY_DB )
|
|
pRoom->SetPartyRoomID(iRoomID);
|
|
#endif
|
|
|
|
return pRoom;
|
|
}
|
|
|
|
CDNGameRoom * CDNRUDPGameServer::CreateGameRoom(MAGAReqTutorialRoomID * pPacket)
|
|
{
|
|
if (m_bIsCloseService) return NULL; //霸烙辑滚啊 摧洒绰 吝 涝聪促.
|
|
unsigned int nRoomID = m_pServerManager->GenRoomID(this);
|
|
if (nRoomID == 0)
|
|
return NULL;
|
|
|
|
MAGAReqRoomID Packet;
|
|
memset( &Packet, 0, sizeof(Packet) );
|
|
|
|
Packet.GameTaskType = GameTaskType::Normal;
|
|
Packet.cReqGameIDType = REQINFO_TYPE_SINGLE;
|
|
Packet.InstanceID = pPacket->nAccountDBID;
|
|
Packet.cMemberCount = 1;
|
|
Packet.nMapIndex = pPacket->nTutorialMapIndex;
|
|
Packet.cGateNo = pPacket->cTutorialGateNo;
|
|
Packet.nRandomSeed = pPacket->nRandomSeed;
|
|
#if defined( PRE_PARTY_DB )
|
|
Packet.PartyData.Clear();
|
|
#else
|
|
Packet.ItemLootRule = ITEMLOOTRULE_NONE;
|
|
#endif
|
|
Packet.bDirectConnect = true;
|
|
|
|
CDNGameRoom* pRoom = new IBoostPoolDNGameRoom(this, nRoomID, &Packet );
|
|
if( pRoom == NULL )
|
|
{
|
|
m_pServerManager->RemoveGameRoom(nRoomID, this);
|
|
return NULL;
|
|
}
|
|
|
|
m_GameRoomList[pRoom->GetRoomID()] = pRoom;
|
|
unsigned int iRoomID = pRoom->GetRoomID();
|
|
|
|
return pRoom;
|
|
}
|
|
|
|
bool CDNRUDPGameServer::VerifyUserIDs(UINT nAccountDBID, UINT nSessionID)
|
|
{
|
|
//檬扁 柳涝矫 酒捞叼甸 八刘涝聪促. 咯扁辑 fail捞 登搁 蜡历 技记捞 沥惑利栏肺 酒流 谗辫 贸府啊 登瘤 臼篮 疤聪促.
|
|
std::map <unsigned int, CDNUserSession*>::iterator ii = m_ConnectList.find(nAccountDBID);
|
|
if (ii != m_ConnectList.end()) return false;
|
|
ii = m_VerifyList.find(nSessionID);
|
|
if (ii != m_VerifyList.end()) return false;
|
|
return m_pServerManager->VerifyUserIDs(nAccountDBID, nSessionID);
|
|
}
|
|
|
|
void CDNRUDPGameServer::RequestedCreateGameRoomFromMaster(char cWorldSetID, char * pData, bool bTutorial)
|
|
{
|
|
if (bTutorial){ // Login俊辑 tutorial
|
|
MAGAReqTutorialRoomID *pReqRoomID = (MAGAReqTutorialRoomID*)pData;
|
|
|
|
//蜡历狼 酒捞叼甸阑 犬牢钦聪促. (酒流 谗辫贸府啊 救登绢 乐阑 荐 乐澜)
|
|
#if !defined( STRESS_TEST )
|
|
if (VerifyUserIDs(pReqRoomID->nAccountDBID, pReqRoomID->nSessionID) == false)
|
|
{
|
|
g_Log.Log(LogType::_ERROR, cWorldSetID, 0, 0, 0, L"VerifyUserIDs Fail ADBID[%d] SID[%d]\n", pReqRoomID->nAccountDBID, pReqRoomID->nSessionID);
|
|
g_pMasterConnectionManager->SendSetTutorialRoomID(cWorldSetID, pReqRoomID->nAccountDBID, GetServerID(), 0, pReqRoomID->nLoginServerID);
|
|
return ;
|
|
}
|
|
#endif // #if defined( STRESS_TEST )
|
|
|
|
CDNGameRoom* pRoom = CreateGameRoom(pReqRoomID);
|
|
if (!pRoom)
|
|
{
|
|
g_pMasterConnectionManager->SendSetTutorialRoomID(cWorldSetID, pReqRoomID->nAccountDBID, GetServerID(), 0, pReqRoomID->nLoginServerID);
|
|
_DANGER_POINT();
|
|
return;
|
|
}
|
|
|
|
// Room WorldID 汲沥
|
|
pRoom->m_iWorldID = pReqRoomID->cWorldSetID;
|
|
|
|
//冯积己 肯丰 RUDP肺 牧池飘瞪 赤籍甸狼 按眉甫 积己秦 初嚼聪促.
|
|
int nSize = 0;
|
|
CDNUserSession * pSession = pRoom->CreateGameSession(pReqRoomID->wszAccountName, pReqRoomID->nAccountDBID, pReqRoomID->nSessionID, pReqRoomID->biCharacterDBID, 0, pReqRoomID->cWorldSetID, 0, true,
|
|
#if defined(PRE_ADD_MULTILANGUAGE)
|
|
bTutorial, pReqRoomID->bAdult, PCBang::Grade::None, pReqRoomID->cSelectedLanguage );
|
|
#else //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
bTutorial, pReqRoomID->bAdult, PCBang::Grade::None );
|
|
#endif //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
if (pSession != NULL)
|
|
{
|
|
BYTE cThreadID = 0;
|
|
CDNDBConnection* pDBCon = NULL;
|
|
pRoom->CopyDBConnectionInfo( pDBCon, cThreadID );
|
|
pSession->SetDBConInfo( pDBCon, cThreadID );
|
|
m_ConnectList[pReqRoomID->nAccountDBID] = pSession;
|
|
m_VerifyList[pReqRoomID->nSessionID] = pSession;
|
|
m_pServerManager->AddGameUser(pRoom->GetRoomID(), pReqRoomID->nAccountDBID, pReqRoomID->nSessionID, this); //扁夯技泼篮 付胶磐牧池飘 窜俊辑狼 立加栏肺 固缝聪促.
|
|
}
|
|
else
|
|
_DANGER_POINT();
|
|
|
|
g_pMasterConnectionManager->SendSetTutorialRoomID(cWorldSetID, pReqRoomID->nAccountDBID, GetServerID(), pRoom->GetRoomID(), pReqRoomID->nLoginServerID);
|
|
g_Log.Log(LogType::_NORMAL, cWorldSetID, 0, 0, 0, L"Report|[RoomCnt:%d][RoomID:%d MAGA_REQTUTORIALROOMID] ADBID:%u SID:%u RandomSeed:%d Map:%d GateNo:%d\r\n", \
|
|
g_pGameServerManager->GetRoomCount(), pRoom->GetRoomID(), pReqRoomID->nAccountDBID, pReqRoomID->nSessionID, pReqRoomID->nRandomSeed, pReqRoomID->nTutorialMapIndex, pReqRoomID->cTutorialGateNo);
|
|
}
|
|
else
|
|
{
|
|
MAGAReqRoomID* pReqRoomID = reinterpret_cast<MAGAReqRoomID*>(pData);
|
|
|
|
if (pReqRoomID->nEventRoomIndex > 0)
|
|
g_Log.Log(LogType::_PVPROOM, pReqRoomID->cWorldSetID, 0, 0, 0, L"RequestedCreateGameRoomFromMaster - Recv Packet [Index:%d][Event:%d] \r\n", static_cast<UINT>(pReqRoomID->InstanceID), pReqRoomID->nEventRoomIndex);
|
|
|
|
//蜡历狼 酒捞叼甸阑 犬牢钦聪促. (酒流 谗辫贸府啊 救登绢 乐阑 荐 乐澜)
|
|
for( int i=0; i <pReqRoomID->cMemberCount ; ++i )
|
|
{
|
|
#if !defined( STRESS_TEST )
|
|
if (VerifyUserIDs(pReqRoomID->arrMemberInfo[i].MemberAccountDBID, pReqRoomID->arrMemberInfo[i].MemberSessionID) == false)
|
|
{
|
|
g_Log.Log(LogType::_GAMECONNECTLOG, cWorldSetID, pReqRoomID->arrMemberInfo[i].MemberAccountDBID, pReqRoomID->arrMemberInfo[i].biMemberCharacterDBID, 0, L"VerifyUserIDs Fail!!\n" );
|
|
g_Log.Log(LogType::_NORMAL, cWorldSetID, 0, 0, 0, L"VerifyUserIDs Fail ADBID[%d] SID[%d]\n", pReqRoomID->arrMemberInfo[i].MemberAccountDBID, pReqRoomID->arrMemberInfo[i].MemberSessionID);
|
|
g_pMasterConnectionManager->SendSetRoomID( cWorldSetID, pReqRoomID->GameTaskType, pReqRoomID->cReqGameIDType, pReqRoomID->InstanceID, GetServerID(), 0, pReqRoomID->cVillageID, NULL );
|
|
return ;
|
|
}
|
|
#endif // #if defined( STRESS_TEST )
|
|
}
|
|
#if defined( PRE_WORLDCOMBINE_PVP )
|
|
if( pReqRoomID->eWorldReqType > WorldPvPMissionRoom::Common::NoneType )
|
|
{
|
|
pReqRoomID->cMemberCount = 0;
|
|
}
|
|
#endif
|
|
|
|
CDNGameRoom* pRoom = CreateGameRoom(pReqRoomID);
|
|
if( pRoom )
|
|
{
|
|
// Room WorldID 汲沥
|
|
pRoom->m_iWorldID = pReqRoomID->cWorldSetID;
|
|
|
|
if (pReqRoomID->cReqGameIDType == REQINFO_TYPE_FARM)
|
|
{
|
|
pRoom->SetSync2SyncStateTemplateMethod(timeGetTime());
|
|
#if defined( _TH ) || defined( _WORK )
|
|
g_Log.Log(LogType::_FARM, pReqRoomID->cWorldSetID, 0, 0, 0, L"Create Farm DBID:%I64d \r\n", pReqRoomID->InstanceID );
|
|
#endif
|
|
return;
|
|
}
|
|
|
|
if (pReqRoomID->nEventRoomIndex > 0)
|
|
g_Log.Log(LogType::_PVPROOM, pReqRoomID->cWorldSetID, 0, 0, 0, L"RequestedCreateGameRoomFromMaster - Success to create room [Index:%d][Event:%d] \r\n", static_cast<UINT>(pReqRoomID->InstanceID), pReqRoomID->nEventRoomIndex);
|
|
|
|
if (pReqRoomID->cReqGameIDType == REQINFO_TYPE_PVP && pReqRoomID->nGuildDBID[0] > 0 && pReqRoomID->cMemberCount == 0)
|
|
{
|
|
//PvP吝 辨靛傈(矫胶袍积己)牢版快 蜡历啊 绝捞档 矫累且 荐 乐促.
|
|
SendSetGameRoomID(cWorldSetID, pRoom, pReqRoomID, NULL);
|
|
pRoom->SetSync2PvPModeStateTemplateMethod(timeGetTime());
|
|
return;
|
|
}
|
|
//冯积己 肯丰 RUDP肺 牧池飘瞪 赤籍甸狼 按眉甫 积己秦 初嚼聪促.
|
|
for( int i=0; i <pReqRoomID->cMemberCount ; ++i )
|
|
{
|
|
WCHAR wszAccountName[IDLENMAX];
|
|
_wcscpy( wszAccountName, _countof(wszAccountName), pReqRoomID->arrMemberInfo[i].wszAccountName, (int)wcslen(pReqRoomID->arrMemberInfo[i].wszAccountName) );
|
|
|
|
#if defined(PRE_ADD_MULTILANGUAGE)
|
|
CDNUserSession* pSession = pRoom->CreateGameSession( wszAccountName, pReqRoomID->arrMemberInfo[i].MemberAccountDBID, \
|
|
pReqRoomID->arrMemberInfo[i].MemberSessionID, pReqRoomID->arrMemberInfo[i].biMemberCharacterDBID, pReqRoomID->arrMemberInfo[i].MemberTeam, \
|
|
pReqRoomID->cWorldSetID, pReqRoomID->cVillageID, \
|
|
pReqRoomID->arrMemberInfo[i].MemberAccountDBID == pReqRoomID->nLeaderAccountDBID ? true : false, bTutorial, \
|
|
pReqRoomID->arrMemberInfo[i].bAdult, pReqRoomID->arrMemberInfo[i].cPCBangGrade, pReqRoomID->arrMemberInfo[i].cSelectedLanguage, &pReqRoomID->arrMemberInfo[i].VoiceInfo );
|
|
#else //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
CDNUserSession* pSession = pRoom->CreateGameSession( wszAccountName, pReqRoomID->arrMemberInfo[i].MemberAccountDBID, \
|
|
pReqRoomID->arrMemberInfo[i].MemberSessionID, pReqRoomID->arrMemberInfo[i].biMemberCharacterDBID, pReqRoomID->arrMemberInfo[i].MemberTeam, \
|
|
pReqRoomID->cWorldSetID, pReqRoomID->cVillageID, \
|
|
pReqRoomID->arrMemberInfo[i].MemberAccountDBID == pReqRoomID->nLeaderAccountDBID ? true : false, bTutorial, \
|
|
pReqRoomID->arrMemberInfo[i].bAdult, pReqRoomID->arrMemberInfo[i].cPCBangGrade, &pReqRoomID->arrMemberInfo[i].VoiceInfo );
|
|
#endif //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
|
|
if( pSession )
|
|
{
|
|
BYTE cThreadID = 0;
|
|
CDNDBConnection* pDBCon = NULL;
|
|
pRoom->CopyDBConnectionInfo( pDBCon, cThreadID );
|
|
pSession->SetDBConInfo( pDBCon, cThreadID );
|
|
|
|
if( !pRoom->bIsFarmRoom() )
|
|
{
|
|
pSession->SetPartyMemberIndex(pReqRoomID->arrMemberInfo[i].cMemberIndex);
|
|
pRoom->SetPartyMemberIndex(pSession->GetPartyMemberIndex(), pSession->GetSessionID(), pSession->GetTeam());
|
|
}
|
|
#if defined(_ID)
|
|
pSession->SetIDNPcCafeInfo(pReqRoomID->arrMemberInfo[i].szMacAddress, pReqRoomID->arrMemberInfo[i].szKey);
|
|
#endif
|
|
m_ConnectList[pReqRoomID->arrMemberInfo[i].MemberAccountDBID] = pSession;
|
|
m_VerifyList[pReqRoomID->arrMemberInfo[i].MemberSessionID] = pSession;
|
|
m_pServerManager->AddGameUser(pRoom->GetRoomID(), pReqRoomID->arrMemberInfo[i].MemberAccountDBID, pReqRoomID->arrMemberInfo[i].MemberSessionID, this ); //扁夯技泼篮 付胶磐牧池飘 窜俊辑狼 立加栏肺 固缝聪促.
|
|
pSession->SetPvPFatigueOption(pReqRoomID->arrMemberInfo[i].bPvPFatigue);
|
|
pSession->SetPvPUserState(pReqRoomID->arrMemberInfo[i].uiPvPUserState);
|
|
}
|
|
else
|
|
_DANGER_POINT();
|
|
}
|
|
|
|
UINT nMemberArr[PARTYMAX];
|
|
memset(&nMemberArr, 0, sizeof(nMemberArr));
|
|
for (int i = 0; i < pReqRoomID->cMemberCount; i++)
|
|
{
|
|
if (pReqRoomID->arrMemberInfo[i].MemberAccountDBID <= 0) continue;
|
|
nMemberArr[i] = pReqRoomID->arrMemberInfo[i].MemberAccountDBID;
|
|
}
|
|
|
|
#if defined( PRE_WORLDCOMBINE_PVP )
|
|
if( pRoom->bIsWorldPvPRoom() )
|
|
{
|
|
// 固记冯牢 版快 咯扁辑 霸烙葛靛 汲沥 秦淋
|
|
InitialzeWorldPvPGameMode(pRoom, pReqRoomID);
|
|
// DB俊 历厘
|
|
pRoom->AddDBWorldPvPRoom( &pReqRoomID->MissonRoomData, pReqRoomID->arrMemberInfo[0].MemberAccountDBID );
|
|
}
|
|
#endif
|
|
#if defined( PRE_PVP_GAMBLEROOM )
|
|
if( pReqRoomID->cGambleType > 0 )
|
|
{
|
|
pRoom->CreateGambleRoom( pReqRoomID->cGambleType, pReqRoomID->nGamblePrice );
|
|
}
|
|
#endif
|
|
if( pReqRoomID->cReqGameIDType == REQINFO_TYPE_LADDER )
|
|
static_cast<CDNPvPGameRoom*>(pRoom)->SetPvPLadderMatchType( pReqRoomID->MatchType );
|
|
|
|
if (pReqRoomID->nEventRoomIndex > 0)
|
|
g_Log.Log(LogType::_PVPROOM, pReqRoomID->cWorldSetID, 0, 0, 0, L"RequestedCreateGameRoomFromMaster - Before SendSetRoomID [Index:%d][Event:%d] \r\n", static_cast<UINT>(pReqRoomID->InstanceID), pReqRoomID->nEventRoomIndex);
|
|
|
|
SendSetGameRoomID(cWorldSetID, pRoom, pReqRoomID, nMemberArr);
|
|
}
|
|
else //积己 磺废车酱!
|
|
{
|
|
g_pMasterConnectionManager->SendSetRoomID( cWorldSetID, pReqRoomID->GameTaskType, pReqRoomID->cReqGameIDType, pReqRoomID->InstanceID, GetServerID(), 0, pReqRoomID->cVillageID, NULL );
|
|
_DANGER_POINT();
|
|
}
|
|
}
|
|
}
|
|
|
|
void CDNRUDPGameServer::RequestedBreakintoGameRoomFromMaster( char cWorldSetID, MAGABreakIntoRoom* pPacket )
|
|
{
|
|
CDNGameRoom* pRoom = GetRoom( pPacket->iGameRoomID );
|
|
if( pRoom )
|
|
{
|
|
CDnGameTask* pGameTask = pRoom->GetGameTask();
|
|
if( pRoom->GetRoomState() != _GAME_STATE_PLAY || pGameTask==NULL || pGameTask->IsWaitPlayCutScene() )
|
|
{
|
|
if( pPacket->BreakIntoType == BreakInto::Type::GMTrace )
|
|
{
|
|
#if defined(PRE_ADD_MULTILANGUAGE)
|
|
std::wstring wString = boost::io::str( boost::wformat( GetEtUIXML().GetUIString(CEtUIXML::idCategory1,3433, pPacket->cSelectedLanguage) ) );
|
|
#else //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
std::wstring wString = boost::io::str( boost::wformat( GetEtUIXML().GetUIString(CEtUIXML::idCategory1,3433) ) );
|
|
#endif //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
g_pMasterConnectionManager->SendChat(pRoom->m_iWorldID, CHATTYPE_GM, pPacket->uiAccountDBID, const_cast<WCHAR*>(wString.c_str()), static_cast<short>(wString.size()) );
|
|
}
|
|
else if( pPacket->BreakIntoType == BreakInto::Type::WorldZoneParty )
|
|
{
|
|
if (pRoom->bIsPvPRoom() == false)
|
|
g_pMasterConnectionManager->SendInvitedMemberReturnMsg(pRoom->m_iWorldID, pPacket->uiAccountDBID, ERROR_PARTY_JOINFAIL);
|
|
}
|
|
else if( pPacket->BreakIntoType == BreakInto::Type::PartyRestore )
|
|
{
|
|
#if defined( PRE_PARTY_DB )
|
|
g_pMasterConnectionManager->SendConfirmLastDungeonInfo( pRoom->m_iWorldID, ERROR_CANT_RESTORE_PARTY_STATE, pPacket->uiAccountDBID, pPacket->BreakIntoType );
|
|
#else
|
|
g_pMasterConnectionManager->SendConfirmLastDungeonInfo( pRoom->m_iWorldID, ERROR_CANT_RESTORE_PARTY_STATE, pPacket->uiAccountDBID );
|
|
#endif // #if defined( PRE_PARTY_DB )
|
|
}
|
|
#if defined( PRE_PARTY_DB )
|
|
else if( pPacket->BreakIntoType == BreakInto::Type::PartyJoin )
|
|
{
|
|
g_pMasterConnectionManager->SendConfirmLastDungeonInfo( pRoom->m_iWorldID, ERROR_PARTY_JOINFAIL, pPacket->uiAccountDBID, pPacket->BreakIntoType );
|
|
}
|
|
#endif // #if defined( PRE_PARTY_DB )
|
|
return;
|
|
} // if( pRoom->GetRoomState() != _GAME_STATE_PLAY || pGameTask==NULL || pGameTask->IsWaitPlayCutScene() )
|
|
|
|
#if defined( PRE_WORLDCOMBINE_PVP )
|
|
if( pRoom->bIsWorldPvPRoom() )
|
|
{
|
|
if( !pRoom->CheckWorldPvPRoomBreakInto( pPacket ) )
|
|
return;
|
|
}
|
|
#endif
|
|
if( pRoom->bIsLadderRoom() )
|
|
{
|
|
if( pPacket->BreakIntoType==BreakInto::Type::GMTrace )
|
|
{
|
|
g_pMasterConnectionManager->SendInvitedMemberReturnMsg(pRoom->m_iWorldID, pPacket->uiAccountDBID, ERROR_PARTY_GM_JOINFAIL_LADDERROOM);
|
|
return;
|
|
}
|
|
DWORD dwCount = pRoom->GetUserCount( PvPCommon::Team::Observer );
|
|
if( dwCount >= LadderSystem::Common::MaxObserver )
|
|
{
|
|
g_pMasterConnectionManager->SendSetRoomID( cWorldSetID, pRoom->m_GameTaskType, REQINFO_TYPE_LADDER_OBSERVER, pPacket->uiAccountDBID, GetServerID(), 0, pPacket->cVillageID, NULL );
|
|
return;
|
|
}
|
|
}
|
|
|
|
if( pPacket->BreakIntoType==BreakInto::Type::PartyRestore )
|
|
{
|
|
if( pRoom->bIsBackupPartyInfo( pPacket->biCharacterDBID ) == false )
|
|
{
|
|
#if defined( PRE_PARTY_DB )
|
|
g_pMasterConnectionManager->SendConfirmLastDungeonInfo( cWorldSetID, ERROR_CANT_EXSIT_BACKUPPARTYINFO, pPacket->uiAccountDBID, pPacket->BreakIntoType );
|
|
#else
|
|
g_pMasterConnectionManager->SendConfirmLastDungeonInfo( cWorldSetID, ERROR_CANT_EXSIT_BACKUPPARTYINFO, pPacket->uiAccountDBID);
|
|
#endif
|
|
return;
|
|
}
|
|
}
|
|
|
|
WCHAR wszAccountName[IDLENMAX];
|
|
_wcscpy( wszAccountName, _countof(wszAccountName), pPacket->wszAccountName, (int)wcslen(pPacket->wszAccountName) );
|
|
|
|
CDNUserSession* pSession = pRoom->CreateBreakIntoGameSession( wszAccountName, pPacket->wszCharacterName, pPacket->uiAccountDBID, pPacket->uiSessionID, pPacket->biCharacterDBID, pPacket->uiTeam,
|
|
#if defined(PRE_ADD_MULTILANGUAGE)
|
|
pPacket->cWorldSetID, pPacket->cVillageID, pPacket->bAdult, pPacket->cPCBangGrade, pPacket->BreakIntoType, pPacket->cSelectedLanguage );
|
|
#else //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
pPacket->cWorldSetID, pPacket->cVillageID, pPacket->bAdult, pPacket->cPCBangGrade, pPacket->BreakIntoType );
|
|
#endif //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
if( pSession )
|
|
{
|
|
#if defined(_ID)
|
|
pSession->SetIDNPcCafeInfo(pPacket->szMacAddress, pPacket->szKey);
|
|
#endif //#if defined(_ID)
|
|
m_ConnectList[pPacket->uiAccountDBID] = pSession;
|
|
m_VerifyList[pPacket->uiSessionID] = pSession;
|
|
pSession->SetPvPFatigueOption(pPacket->bPvPFatigue);
|
|
pSession->SetPvPUserState(pPacket->uiPvPUserState);
|
|
pSession->SetPartyMemberIndex(pPacket->cPvPTeamIndex);
|
|
if( m_pServerManager )
|
|
m_pServerManager->AddGameUser( pRoom->GetRoomID(), pPacket->uiAccountDBID, pPacket->uiSessionID, this ); //扁夯技泼篮 付胶磐牧池飘 窜俊辑狼 立加栏肺 固缝聪促.
|
|
else
|
|
_DANGER_POINT();
|
|
}
|
|
else
|
|
{
|
|
if( pPacket->BreakIntoType==BreakInto::Type::PartyRestore )
|
|
{
|
|
#if defined( PRE_PARTY_DB )
|
|
g_pMasterConnectionManager->SendConfirmLastDungeonInfo( pPacket->cWorldSetID, ERROR_CANT_EXSIT_BACKUPPARTYINFO, pPacket->uiAccountDBID, pPacket->BreakIntoType );
|
|
#else
|
|
g_pMasterConnectionManager->SendConfirmLastDungeonInfo( pPacket->cWorldSetID, ERROR_CANT_EXSIT_BACKUPPARTYINFO, pPacket->uiAccountDBID );
|
|
#endif
|
|
return;
|
|
}
|
|
#if defined( PRE_PARTY_DB )
|
|
else if( pPacket->BreakIntoType == BreakInto::Type::PartyJoin )
|
|
{
|
|
g_pMasterConnectionManager->SendConfirmLastDungeonInfo( pRoom->m_iWorldID, ERROR_PARTY_JOINFAIL, pPacket->uiAccountDBID, pPacket->BreakIntoType );
|
|
return;
|
|
}
|
|
#endif // #if defined( PRE_PARTY_DB )
|
|
|
|
// 抄涝且 荐 绝绰 版快捞促. 俊矾 烹焊秦林磊.
|
|
int nReqType = REQINFO_TYPE_SINGLE;
|
|
if( pRoom->bIsPvPRoom() )
|
|
nReqType = pRoom->bIsLadderRoom() ? REQINFO_TYPE_LADDER_OBSERVER : REQINFO_TYPE_PVP_BREAKINTO;
|
|
g_pMasterConnectionManager->SendSetRoomID( cWorldSetID, pRoom->m_GameTaskType, nReqType, pPacket->uiAccountDBID, GetServerID(), 0, pPacket->cVillageID, NULL );
|
|
return;
|
|
}
|
|
|
|
// 款康磊抄涝
|
|
// 橇肺配鸥涝俊辑 丑厘抄涝篮 蜡历肺 埃林茄促.
|
|
if( pRoom->bIsFarmRoom() )
|
|
{
|
|
pSession->SetGMTrace( false );
|
|
}
|
|
else
|
|
{
|
|
pSession->SetGMTrace( pPacket->BreakIntoType==BreakInto::Type::GMTrace ? true : false );
|
|
}
|
|
|
|
if( g_pMasterConnectionManager )
|
|
{
|
|
int nReqType = REQINFO_TYPE_SINGLE;
|
|
if (pRoom->bIsPvPRoom()) //pvp扼搁 抄涝
|
|
nReqType = pRoom->bIsLadderRoom() ? REQINFO_TYPE_LADDER_OBSERVER : REQINFO_TYPE_PVP_BREAKINTO;
|
|
else if (pRoom->GetPartyIndex() > 0) //颇萍檬措 肚绰 gm狼 抄涝
|
|
nReqType = pPacket->BreakIntoType==BreakInto::Type::GMTrace ? REQINFO_TYPE_SINGLE : REQINFO_TYPE_PARTY_BREAKINTO; //GM狼 抄涝捞扼搁 弊成 教臂贸烦(捞贰具 付阑肺 捞悼矫 颇萍啊 救旦)
|
|
|
|
if( pPacket->BreakIntoType==BreakInto::Type::PartyRestore )
|
|
{
|
|
#if defined( PRE_PARTY_DB )
|
|
g_pMasterConnectionManager->SendConfirmLastDungeonInfo( cWorldSetID, ERROR_NONE, pPacket->uiAccountDBID, pPacket->BreakIntoType );
|
|
#else
|
|
g_pMasterConnectionManager->SendConfirmLastDungeonInfo( cWorldSetID, ERROR_NONE, pPacket->uiAccountDBID );
|
|
#endif
|
|
}
|
|
g_pMasterConnectionManager->SendSetRoomID( cWorldSetID, pRoom->m_GameTaskType, nReqType, pPacket->uiAccountDBID, GetServerID(), pRoom->GetRoomID(), pPacket->cVillageID, NULL, nReqType == REQINFO_TYPE_PARTY_BREAKINTO ? pRoom->GetPartyIndex() : 0 );
|
|
}
|
|
else
|
|
_DANGER_POINT();
|
|
}
|
|
else
|
|
{
|
|
if (pPacket->BreakIntoType==BreakInto::Type::WorldZoneParty)
|
|
g_pMasterConnectionManager->SendInvitedMemberReturnMsg(pPacket->cWorldSetID, pPacket->uiAccountDBID, ERROR_PARTY_JOINFAIL);
|
|
else if( pPacket->BreakIntoType==BreakInto::Type::PartyRestore )
|
|
#if defined( PRE_PARTY_DB )
|
|
g_pMasterConnectionManager->SendConfirmLastDungeonInfo( pPacket->cWorldSetID, ERROR_CANT_EXSIT_BACKUPPARTYINFO, pPacket->uiAccountDBID, pPacket->BreakIntoType );
|
|
#else
|
|
g_pMasterConnectionManager->SendConfirmLastDungeonInfo( pPacket->cWorldSetID, ERROR_CANT_EXSIT_BACKUPPARTYINFO, pPacket->uiAccountDBID );
|
|
#endif // #if defined( PRE_PARTY_DB )
|
|
}
|
|
}
|
|
|
|
void CDNRUDPGameServer::SendRestoreMaster()
|
|
{
|
|
if (m_RestoreMaster.empty()) return;
|
|
|
|
m_RestoreSync.Lock();
|
|
std::vector <tRestoreMaster>::iterator ii;
|
|
for (ii = m_RestoreMaster.begin(); ii != m_RestoreMaster.end(); )
|
|
{
|
|
if ((*ii).nStep == _RESTORESTEP_SENDUSER) //蜡历甫 焊辰促.
|
|
{
|
|
std::map <unsigned int, CDNUserSession*>::iterator is;
|
|
for (is = m_ConnectList.begin(); is != m_ConnectList.end(); is++)
|
|
{
|
|
if ((*is).second->IsConnected() && (*is).second->GetWorldSetID() == (*ii).cWorldSetID)
|
|
g_pMasterConnectionManager->SendAddUserList((*is).second->GetWorldSetID(), (*is).second);
|
|
}
|
|
(*ii).nStep = _RESTORESTEP_END;
|
|
}
|
|
else if ((*ii).nStep == _RESTORESTEP_END)
|
|
{
|
|
g_pMasterConnectionManager->SendEndofVillageInfo((*ii).cWorldSetID, GetServerID());
|
|
ii = m_RestoreMaster.erase(ii);
|
|
}
|
|
}
|
|
|
|
m_RestoreSync.UnLock();
|
|
}
|
|
|
|
void CDNRUDPGameServer::DestroyAllGameRoom()
|
|
{
|
|
//葛电霸烙冯狼 惑怕甫 叼胶飘肺捞肺 官操绊 歹捞惑狼 规积己阑 阜绰促.
|
|
if (m_bIsCloseService) return;
|
|
m_bIsCloseService = true; //敲贰弊甫 官操绊
|
|
std::map <unsigned int, CDNGameRoom*>::iterator ii;
|
|
for (ii = m_GameRoomList.begin(); ii != m_GameRoomList.end(); ii++)
|
|
{
|
|
(*ii).second->DestroyGameRoom();
|
|
}
|
|
}
|
|
|
|
|
|
#if defined( PRE_WORLDCOMBINE_PARTY )
|
|
void CDNRUDPGameServer::DestroyAllFarmGameRoom( int iWorldSetID )
|
|
#else
|
|
void CDNRUDPGameServer::DestroyAllFarmGameRoom()
|
|
#endif // #if defined( PRE_WORLDCOMBINE_PARTY )
|
|
{
|
|
std::map <unsigned int, CDNGameRoom*>::iterator ii;
|
|
for (ii = m_GameRoomList.begin(); ii != m_GameRoomList.end(); ii++)
|
|
{
|
|
#if defined( PRE_WORLDCOMBINE_PARTY )
|
|
if ((*ii).second->bIsFarmRoom() && (*ii).second->GetWorldSetID() == iWorldSetID )
|
|
#else
|
|
if ((*ii).second->bIsFarmRoom())
|
|
#endif // #if defined( PRE_WORLDCOMBINE_PARTY )
|
|
{
|
|
(*ii).second->DestroyGameRoom(true);
|
|
}
|
|
}
|
|
}
|
|
|
|
void CDNRUDPGameServer::SendSetGameRoomID(char cWorldSetID, CDNGameRoom * pRoom, MAGAReqRoomID * pReqRoomID, UINT * pPartyMember)
|
|
{
|
|
if (pReqRoomID == NULL || pRoom == NULL)
|
|
{
|
|
_DANGER_POINT();
|
|
return;
|
|
}
|
|
|
|
#if defined( PRE_WORLDCOMBINE_PARTY )
|
|
#if defined( PRE_WORLDCOMBINE_PVP )
|
|
bool bRet = g_pMasterConnectionManager->SendSetRoomID( cWorldSetID, pReqRoomID->GameTaskType, pReqRoomID->cReqGameIDType, pReqRoomID->InstanceID, GetServerID(), pRoom->GetRoomID(), pReqRoomID->cVillageID, pPartyMember, 0, pReqRoomID->PartyData.Type, pReqRoomID->eWorldReqType );
|
|
#else // #if defined( PRE_WORLDCOMBINE_PVP )
|
|
bool bRet = g_pMasterConnectionManager->SendSetRoomID( cWorldSetID, pReqRoomID->GameTaskType, pReqRoomID->cReqGameIDType, pReqRoomID->InstanceID, GetServerID(), pRoom->GetRoomID(), pReqRoomID->cVillageID, pPartyMember, 0, pReqRoomID->PartyData.Type );
|
|
#endif // #if defined( PRE_WORLDCOMBINE_PVP )
|
|
#else
|
|
bool bRet = g_pMasterConnectionManager->SendSetRoomID( cWorldSetID, pReqRoomID->GameTaskType, pReqRoomID->cReqGameIDType, pReqRoomID->InstanceID, GetServerID(), pRoom->GetRoomID(), pReqRoomID->cVillageID, pPartyMember );
|
|
#endif
|
|
if( bRet )
|
|
{
|
|
#if defined( STRESS_TEST )
|
|
#else
|
|
g_Log.Log(LogType::_NORMAL, cWorldSetID, 0, 0, 0, L"Report|[RoomCnt:%d][RoomID:%d MAGA_REQROOMID] ADBID:%u PartyIndex:%d RandomSeed:%d Map:%d GateNo:%d UCNT:%d\r\n", \
|
|
g_pGameServerManager->GetRoomCount(), pRoom->GetRoomID(), pReqRoomID->nLeaderAccountDBID, pRoom->GetPartyIndex(), \
|
|
pReqRoomID->nRandomSeed, pReqRoomID->nMapIndex, pReqRoomID->cGateNo, pReqRoomID->cMemberCount );
|
|
#endif // #if defined( STRESS_TEST )
|
|
}
|
|
else
|
|
{
|
|
g_Log.Log(LogType::_ERROR, cWorldSetID, 0, 0, 0, L"Report|[RoomCnt:%d][RoomID:%d MAGA_REQROOMID] ADBID:%u PartyIndex:%d RandomSeed:%d Map:%d GateNo:%d UCNT:%d\r\n", \
|
|
g_pGameServerManager->GetRoomCount(), pRoom->GetRoomID(), pReqRoomID->nLeaderAccountDBID, pRoom->GetPartyIndex(), \
|
|
pReqRoomID->nRandomSeed, pReqRoomID->nMapIndex, pReqRoomID->cGateNo, pReqRoomID->cMemberCount );
|
|
g_Log.Log(LogType::_GAMECONNECTLOG, cWorldSetID, 0, 0, 0, L"ErrorReport|[RoomCnt:%d][RoomID:%d MAGA_REQROOMID] ADBID:%u PartyIndex:%d RandomSeed:%d Map:%d GateNo:%d UCNT:%d\r\n", \
|
|
g_pGameServerManager->GetRoomCount(), pRoom->GetRoomID(), pReqRoomID->nLeaderAccountDBID, pRoom->GetPartyIndex(), \
|
|
pReqRoomID->nRandomSeed, pReqRoomID->nMapIndex, pReqRoomID->cGateNo, pReqRoomID->cMemberCount );
|
|
}
|
|
}
|
|
|
|
void CDNRUDPGameServer::InitializePvPGameMode( const MAGAPVP_GAMEMODE* pPacket )
|
|
{
|
|
CDNGameRoom* pRoom = GetRoom( pPacket->iGameRoomID );
|
|
if( pRoom )
|
|
{
|
|
if( pRoom->bIsPvPRoom()&& pRoom->GetPvPIndex() == pPacket->uiPvPIndex )
|
|
{
|
|
if( pRoom->InitializePvPGameMode( pPacket ) == false )
|
|
_ASSERT(0);
|
|
}
|
|
else
|
|
_DANGER_POINT();
|
|
}
|
|
else
|
|
_DANGER_POINT();
|
|
}
|
|
|
|
void CDNRUDPGameServer::RequestedVillageState( MAGAVillageState *pPacket )
|
|
{
|
|
CDNUserSession *pSession = GetSessionByADBID(pPacket->nAccountDBID);
|
|
if (pSession == NULL) return;
|
|
|
|
CDNGameRoom *pRoom = GetRoom( pPacket->nRoomID );
|
|
if( pRoom ) {
|
|
CDnGameTask *pTask = (CDnGameTask *)pRoom->GetTaskMng()->GetTask( "GameTask" );
|
|
if( pTask ) {
|
|
pTask->OnRecvVillageState( pSession, pPacket );
|
|
}
|
|
}
|
|
}
|
|
|
|
bool CDNRUDPGameServer::_CmdRecall( MAGAResRecall* pPacket )
|
|
{
|
|
CDNUserSession* pRecallSession = GetSessionByADBID( pPacket->uiRecallAccountDBID );
|
|
if( !pRecallSession || !pRecallSession->GetGameRoom() )
|
|
return false;
|
|
|
|
|
|
CDNGameRoom::PartyStruct * pStruct = pRecallSession->GetGameRoom()->GetPartyData( pRecallSession );
|
|
if( !pStruct )
|
|
return false;
|
|
|
|
if( pStruct->nEnteredGateIndex != -1 )
|
|
{
|
|
#if defined(PRE_ADD_MULTILANGUAGE)
|
|
std::wstring wString = boost::io::str( boost::wformat( GetEtUIXML().GetUIString(CEtUIXML::idCategory1,4415, pPacket->cRecallerSelectedLang) ) % pRecallSession->GetCharacterName() );
|
|
#else //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
std::wstring wString = boost::io::str( boost::wformat( GetEtUIXML().GetUIString(CEtUIXML::idCategory1,4415) ) % pRecallSession->GetCharacterName() );
|
|
#endif //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
return g_pMasterConnectionManager->SendChat(pRecallSession->GetWorldSetID(), CHATTYPE_GM, pPacket->uiAccountDBID, wString.c_str(), static_cast<short>(wString.size()) );
|
|
}
|
|
|
|
CDnGameTask* pGameTask = pRecallSession->GetGameRoom()->GetGameTask();
|
|
if( !pGameTask )
|
|
return false;
|
|
|
|
if( !pGameTask->IsSyncComplete() )
|
|
{
|
|
#if defined(PRE_ADD_MULTILANGUAGE)
|
|
std::wstring wString = boost::io::str( boost::wformat( GetEtUIXML().GetUIString(CEtUIXML::idCategory1,4416, pPacket->cRecallerSelectedLang) ) % pRecallSession->GetCharacterName() );
|
|
#else //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
std::wstring wString = boost::io::str( boost::wformat( GetEtUIXML().GetUIString(CEtUIXML::idCategory1,4416) ) % pRecallSession->GetCharacterName() );
|
|
#endif //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
return g_pMasterConnectionManager->SendChat(pRecallSession->GetWorldSetID(), CHATTYPE_GM, pPacket->uiAccountDBID, wString.c_str(), static_cast<short>(wString.size()) );
|
|
}
|
|
|
|
if( pRecallSession->GetState() != SESSION_STATE_GAME_PLAY )
|
|
{
|
|
#if defined(PRE_ADD_MULTILANGUAGE)
|
|
std::wstring wString = boost::io::str( boost::wformat( GetEtUIXML().GetUIString(CEtUIXML::idCategory1,4417, pPacket->cRecallerSelectedLang) ) % pRecallSession->GetCharacterName() % static_cast<int>(pRecallSession->GetState() ) );
|
|
#else //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
std::wstring wString = boost::io::str( boost::wformat( GetEtUIXML().GetUIString(CEtUIXML::idCategory1,4417) ) % pRecallSession->GetCharacterName() % static_cast<int>(pRecallSession->GetState() ) );
|
|
#endif //#if defined(PRE_ADD_MULTILANGUAGE)
|
|
return g_pMasterConnectionManager->SendChat(pRecallSession->GetWorldSetID(), CHATTYPE_GM, pPacket->uiAccountDBID, wString.c_str(), static_cast<short>(wString.size()) );
|
|
}
|
|
|
|
return ( pRecallSession->CmdAbandonStage( false, true, false, pPacket->iRecallMapIndex ) == ERROR_NONE ) ? true : false;
|
|
}
|
|
|
|
#if defined( PRE_WORLDCOMBINE_PARTY )
|
|
void CDNRUDPGameServer::SendWorldPartyMember(char cWorldSetID, MAGetWorldPartyMember* pPacket)
|
|
{
|
|
CDNGameRoom* pRoom = GetRoom( pPacket->iRoomID );
|
|
Party::MemberData MemberData[PARTYCOUNTMAX];
|
|
memset(MemberData, 0, sizeof(Party::MemberData)*PARTYCOUNTMAX);
|
|
|
|
if( pRoom )
|
|
{
|
|
if( Party::bIsWorldCombineParty( pRoom->GetPartyType()) )
|
|
{
|
|
if (CDnWorld::GetInstance(pRoom).GetMapType() == GlobalEnum::eMapTypeEnum::MAP_WORLDMAP)
|
|
{
|
|
int nCount = 0;
|
|
for(DWORD i=0;i<pRoom->GetUserCount();i++)
|
|
{
|
|
CDNUserSession *pSession = pRoom->GetUserData(i);
|
|
if(pSession)
|
|
{
|
|
MemberData[nCount].biCharacterDBID = pSession->GetCharacterDBID();
|
|
_wcscpy(MemberData[nCount].wszCharName, _countof(MemberData[nCount].wszCharName), pSession->GetCharacterName(), (int)wcslen(pSession->GetCharacterName()));
|
|
MemberData[nCount].cLevel = pSession->GetLevel();
|
|
MemberData[nCount].cJob = pSession->GetUserJob();
|
|
MemberData[nCount].bLeader = false;
|
|
MemberData[nCount].nWorldSetID = pSession->GetWorldSetID();
|
|
nCount++;
|
|
}
|
|
}
|
|
g_pMasterConnectionManager->SendWorldPartyMember(cWorldSetID, pPacket->nAccountDBID, pPacket->biCharacterDBID, pPacket->PartyID, nCount, MemberData, ERROR_NONE);
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
|
|
g_pMasterConnectionManager->SendWorldPartyMember(cWorldSetID, pPacket->nAccountDBID, pPacket->biCharacterDBID, pPacket->PartyID, 0, MemberData, ERROR_PARTY_JOINFAIL);
|
|
}
|
|
#endif
|
|
|
|
#if defined( PRE_WORLDCOMBINE_PVP )
|
|
|
|
void CDNRUDPGameServer::InitialzeWorldPvPGameMode( CDNGameRoom * pRoom, MAGAReqRoomID * pReqRoomID )
|
|
{
|
|
SYSTEMTIME st;
|
|
GetLocalTime( &st );
|
|
char szSN[MAX_PATH];
|
|
|
|
MAGAPVP_GAMEMODE GameMode;
|
|
memset(&GameMode, 0, sizeof(GameMode));
|
|
GameMode.iGameRoomID = pRoom->GetRoomID();
|
|
GameMode.uiPvPIndex = (UINT)pReqRoomID->InstanceID;
|
|
GameMode.uiPvPGameModeTableID = pReqRoomID->MissonRoomData.cModeID;
|
|
GameMode.uiWinCondition = pReqRoomID->MissonRoomData.nWinCondition;
|
|
GameMode.uiPlayTimeSec = pReqRoomID->MissonRoomData.nPlayTime;
|
|
GameMode.unGameModeCheck = PvPCommon::Check::AllCheck;
|
|
sprintf( szSN, "%.4d%.2d%.2d%.2d%.2d%.2d%.3d%", st.wYear, st.wMonth, st.wDay, st.wHour, st.wMinute, st.wSecond, st.wMilliseconds );
|
|
GameMode.biSNMain = _atoi64( szSN );
|
|
sprintf( szSN, "%.2d%.2d%.4d", pReqRoomID->cWorldSetID, pReqRoomID->cVillageID, pReqRoomID->InstanceID );
|
|
GameMode.iSNSub = atoi( szSN );
|
|
GameMode.cIsPWRoom = 0;
|
|
GameMode.unRoomOptionBit = pReqRoomID->MissonRoomData.unRoomOptionBit;
|
|
|
|
GameMode.cMaxUser = pReqRoomID->MissonRoomData.cMaxPlayers;
|
|
GameMode.bIsGuildWar = false;
|
|
#ifdef PRE_ADD_COLOSSEUM_BEGINNER
|
|
GameMode.cPvPChannelType = pReqRoomID->MissonRoomData.nChannelType;
|
|
#endif //#ifdef PRE_ADD_COLOSSEUM_BEGINNER
|
|
GameMode.nStartPlayer = pReqRoomID->MissonRoomData.nStartPlayers;
|
|
InitializePvPGameMode(&GameMode);
|
|
}
|
|
#endif |