www.pudn.com > [Server]Distribute.rar > DistributeDBMsgParser.cpp
#include "stdafx.h"
#include "DistributeDBMsgParser.h"
#include "DataBase.h"
#include "CommonDBMsgParser.h"
#include "UserTable.h"
#include "ServerTable.h"
#include "Network.h"
#include "UserManager.h"
extern int g_nServerSetNum;
extern DWORD g_dwMaxUser;
DBMsgFunc g_DBMsgFunc[] =
{
NULL,
RLoginCheckQuery,
RIpCheckQuery, /// eIpCheckQuery (GM아이피에 대한 체크)
RCheckMaxUser,
RLoginCheckQueryTest,
RTest,
};
void LoginCheckInit()
{
g_DB.FreeQuery(0, 0, "EXEC %s", "MP_CHARACTER_LoginInit");
/* 아직 추가하지 말것... 프로시져 수정후 추가 (LBS)
char txt[128];
sprintf(txt, "EXEC %s %d", "up_Server_ResetLoginMember", g_nServerSetNum);
g_DB.LoginQuery(eQueryType_FreeQuery, 0, 0, txt);
*/
}
/*
void LoginCheckDelete(DWORD UserID)//, DWORD dwConnectionIndex)
{
char txt[128];
sprintf(txt, "EXEC %s %d", "Up_Member_CheckOut", UserID);
g_DB.LoginQuery(eQueryType_FreeQuery, eNull, 0, txt);
}
BOOL LoginCheckQuery(char* id, char* pw, DWORD AuthKey, DWORD dwConnectionIndex)
{
char guery[128];
// id,pw,AuthKey,ServerGroupNum
sprintf(guery, "EXEC %s \'%s\', \'%s\', %d, %d", "Up_Member_CheckIn", id, pw, AuthKey, 1);
if(g_DB.LoginQuery(eQueryType_FreeQuery, eLoginCheckQuery, dwConnectionIndex, guery) == FALSE)
{
g_Console.Log(eLogDisplay,4,"DB is Busy ID:%d ConnectionIndex:%d",id,dwConnectionIndex);
return FALSE;
}
g_Console.Log(eLogDisplay,4,"IDPW_QUERY ID: %s, ConnectionIndex: %d",id,dwConnectionIndex);
return TRUE;
}
*/
BOOL IPCheckQuery(char* ip, DWORD AuthKey, DWORD dwConnectionIndex)
{
char query[128];
sprintf(query, "EXEC %s \'%s\', %d", "Up_Ip_CheckIn", ip, AuthKey);
if(g_DB.LoginQuery(eQueryType_FreeQuery, eIpCheckQuery, dwConnectionIndex, query) == FALSE)
{
g_Console.Log(eLogDisplay,4,"DB is Busy(IP_CHECK) IP:%s ConnectionIndex:%d", ip, dwConnectionIndex);
return FALSE;
}
// g_Console.Log(eLogDisplay,4,"IP_QUERY IP: %s, ConnectionIndex: %d", ip, dwConnectionIndex);
return TRUE;
}
void LoginError(DWORD dwConnectionIdx, DWORD AuthKey,DWORD ErrorCode,DWORD dwParam)
{
MSG_DWORD2 msguser;
msguser.Category = MP_USERCONN;
msguser.Protocol = MP_USERCONN_LOGIN_NACK;
msguser.dwData1 = ErrorCode;
msguser.dwData2 = dwParam;
g_pUserTable->SendToUser(dwConnectionIdx, AuthKey, &msguser, sizeof(msguser) );
// g_Console.Log(eLogDisplay,4," LOGINERROR Errorcode: %d, ConnectionIndex: %d",ErrorCode,dwConnectionIdx);
}
void RIpCheckQuery(LPQUERY pData, LPDBMESSAGE pMessage)
{
if(pMessage->dwResult == 0)
{
// DB Error(DB is busy)
return;
}
WORD Ecode =atoi((char*)pData->Data[0]);
DWORD AuthKey = atoi((char*)pData->Data[1]);
DWORD dwConnectionIdx = pMessage->dwID;
USERINFO* pUserInfo = g_pUserTable->FindUser(dwConnectionIdx);
if( pUserInfo == NULL ) //이미 나갔다.
return;
if( pUserInfo->dwUniqueConnectIdx != AuthKey ) // 이미 나가고 다른 넘이 들어온 경우
return;
if( Ecode == 0 )
{
LoginError( dwConnectionIdx, AuthKey, LOGIN_ERROR_INVALID_IP );
LoginCheckDelete( pUserInfo->dwUserID );
//LoginCheckDelete( pUserInfo->dwUserID);
return;
}
// 성공
SERVERINFO* FastInfo = g_pServerTable->GetFastServer( AGENT_SERVER );
if(FastInfo == NULL)
{
LoginError( dwConnectionIdx, AuthKey, LOGIN_ERROR_NOAGENTSERVER );
LoginCheckDelete( pUserInfo->dwUserID );
pUserInfo->dwUserID = 0;
return;
}
MSG_DWORD2BYTE msg;
msg.Category = MP_USERCONN;
msg.Protocol = MP_USERCONN_NOTIFY_USERLOGIN_SYN;
msg.dwObjectID = pUserInfo->dwUserID;
msg.dwData1 = AuthKey;
msg.dwData2 = dwConnectionIdx;
msg.bData = pUserInfo->UserLevel;
g_Network.Send2Server(FastInfo->dwConnectionIndex,(char*)&msg,sizeof(msg));
}
DWORD testTime[1024];
BOOL LoginCheckQueryTest(char* id, char* pw, DWORD AuthKey, DWORD dwConnectionIndex)
{
char guery[128];
sprintf(guery, "EXEC %s \'%s\', \'%s\', %d, %d", "Up_Member_CheckIn", id, pw, AuthKey, 1);
if(g_DB.LoginQuery(101, eLoginCheckQueryTest, dwConnectionIndex, guery) == FALSE)
{
g_Console.Log(eLogDisplay,4,"DB is Busy ID:%d ConnectionIndex:%d",id,dwConnectionIndex);
return FALSE;
}
g_Console.Log(eLogDisplay,4,"IDPW_QUERY ID: %s, ConnectionIndex: %d",id,dwConnectionIndex);
return TRUE;
}
void RLoginCheckQueryTest(LPQUERY pData, LPDBMESSAGE pMessage)
{
DWORD AuthKey =atoi((char*)pData->Data[2]);
testTime[AuthKey-1] = GetTickCount() - pMessage->dwID;
g_Console.Log(eLogDisplay,4,"IDPW TestReceived ID: %d Time: %d",AuthKey,testTime[AuthKey-1]);
if(AuthKey == 1024)
{
FILE* fp = fopen("test.txt","w");
for(int n=0;n<1024;++n)
fprintf(fp,"%d ElapsedTime: %d\n",n+1,testTime[n]);
fclose(fp);
}
}
//* MemberDB 교체 작업 2004.03.22
void LoginCheckDelete(DWORD UserID)
{
char txt[128];
sprintf(txt, "EXEC %s %d", "Up_GameLogout", UserID);
g_DB.LoginQuery(eQueryType_FreeQuery, eNull, 0, txt);
}
//*/
//* MemberDB 교체 작업 2004.03.22
BOOL LoginCheckQuery(char* id, char* pw, char* ip, WORD ServerNo, DWORD AuthKey, DWORD dwConnectionIndex, DWORD dwMaxUser, WORD ServerNum)
{
char guery[128];
// id,pw,AuthKey,ServerGroupNum
// MaxUser검사할때
sprintf(guery, "EXEC %s \'%s\', \'%s\', \'%s\', %d, \'%d\', %d, %d, %d",
"up_gameloginadult_free", id, pw, ip, ServerNo, AuthKey, dwMaxUser, gUserMGR.GetLimitAge(), ServerNum);
if(g_DB.LoginQuery(eQueryType_FreeQuery, eLoginCheckQuery, dwConnectionIndex, guery, FALSE) == FALSE)
{
g_Console.Log(eLogDisplay,4,"DB is Busy ID:%d ConnectionIndex:%d",id,dwConnectionIndex);
LoginError( dwConnectionIndex, AuthKey, LOGIN_ERROR_DISTSERVERISBUSY );
return FALSE;
}
return TRUE;
}
//*/
//* MemberDB 교체 작업 2004.03.22
void RLoginCheckQuery(LPQUERY pData, LPDBMESSAGE pMessage)
{
DWORD stateNo = atoi((char*)pData->Data[0]);
WORD ServerNo = atoi((char*)pData->Data[1]);
DWORD UserIdx = atoi((char*)pData->Data[2]);
/////////////////////////////////////////////////////////
// 결제 관련 변수 (아직 사용안함.)
// WORD Type = atoi((char*)pData->Data[3]); //결제방식
// WORD time = atoi((char*)pData->Data[4]); //남은시간??
// WORD bTen = atoi((char*)pData->Data[5]); //체험판여부
/////////////////////////////////////////////////////////
DWORD AuthKey = atoi((char*)pData->Data[6]);
BYTE UserLevel = atoi((char*)pData->Data[7]);
WORD AgentNo = atoi((char*)pData->Data[8]);
DWORD dwConnectionIdx = pMessage->dwID;
USERINFO* pUserInfo = g_pUserTable->FindUser(dwConnectionIdx);
if(pUserInfo == NULL) // 이미 나간경우
{
LoginCheckDelete(UserIdx);
return;
}
ASSERT(pUserInfo->dwConnectionIndex == dwConnectionIdx);
if(pUserInfo->UserLevel == eUSERLEVEL_PROGRAMMER)
{
//////////////////////////////////////////////////////////////////////////
// testcode
FILE* fp = fopen("loginchk.txt","a");
fprintf(fp,"RLOGIN_Q %d\t%d\t%d\t%d\t%d\n",UserIdx,dwConnectionIdx,(DWORD)pUserInfo,pUserInfo->dwUniqueConnectIdx,AuthKey);
fclose(fp);
//////////////////////////////////////////////////////////////////////////
}
if(pUserInfo->dwUniqueConnectIdx != AuthKey) // 이미 나가고 다른 넘이 들어온 경우
{
LoginCheckDelete(UserIdx);
return;
}
pUserInfo->dwUserID = UserIdx;
pUserInfo->UserLevel = UserLevel;
pUserInfo->State = stateNo;
// 이곳에서 만약 잘못된 UserIdx가 넘어온 경우
// g_Console.Log(eLogDisplay, 4, "ID/PW Check Received dwConnectionIdx:%d",dwConnectionIdx);
switch(stateNo)
{
case 1: // 접속 성공.
{
// 유저레벨 검사
if(gUserMGR.IsValidUserLevel(UserLevel) == FALSE)
{
LoginError(dwConnectionIdx,AuthKey,LOGIN_ERROR_INVALIDUSERLEVEL);
DisconnectUser(dwConnectionIdx);
LoginCheckDelete(UserIdx); // 수정요!!!
return;
}
// g_Console.Log(eLogDisplay, 4, " ID/PW Success : dwConnectionIdx: %d",dwConnectionIdx);
if( UserLevel == eUSERLEVEL_GM )
{
char strIP[16] = {0,};
WORD wPort;
g_Network.GetUserAddress( dwConnectionIdx, strIP, &wPort );
IPCheckQuery( strIP, AuthKey, dwConnectionIdx );
}
else
{
SERVERINFO* pAgentServer = g_pServerTable->GetServer(AGENT_SERVER, AgentNo);
if(pAgentServer == NULL)
{
LoginError(dwConnectionIdx,AuthKey,LOGIN_ERROR_NOAGENTSERVER);
DisconnectUser(dwConnectionIdx);
LoginCheckDelete(UserIdx); //OnDisconnectUser에서 호출하는데.. 혹시나해서.
return;
}
MSG_DWORD2BYTE msg;
msg.Category = MP_USERCONN;
msg.Protocol = MP_USERCONN_NOTIFY_USERLOGIN_SYN;
msg.dwObjectID = UserIdx;
msg.dwData1 = AuthKey;
msg.dwData2 = dwConnectionIdx;
msg.bData = UserLevel;
g_Network.Send2Server(pAgentServer->dwConnectionIndex,(char*)&msg,sizeof(msg));
}
}
break;
case 2: // ID없음.
{
LoginError(dwConnectionIdx,AuthKey,LOGIN_ERROR_WRONGIDPW);
}
break;
case 3: // 비밀번호오류.
{
LoginError(dwConnectionIdx,AuthKey,LOGIN_ERROR_WRONGIDPW);
}
break;
case 4: // 게임에 접속중.
{
if(g_nServerSetNum == ServerNo)
{
MSG_DWORD msg;
msg.Category = MP_USERCONN;
msg.Protocol = MP_USERCONN_NOTIFY_OVERLAPPEDLOGIN;
msg.dwData = UserIdx;
g_Network.Broadcast2AgentServer((char*)&msg,sizeof(msg));
LoginError(dwConnectionIdx,AuthKey,LOGIN_ERROR_OVERLAPPEDLOGIN,0);
}
else
{
LoginError(dwConnectionIdx,AuthKey,LOGIN_ERROR_OVERLAPPEDLOGININOTHERSERVER,ServerNo);
}
}
break;
case 5: // 블럭된 계정. @state_num = 6이면 계정블럭 (웹 관리모드에서 사용)
{
LoginError(dwConnectionIdx,AuthKey,LOGIN_ERROR_BLOCKUSERLEVEL);
}
break;
case 7: // DB Connection Error
{
ASSERTMSG(0, "login check error ret 0");
}
break;
case 8: // 인원초과
{
LoginError( dwConnectionIdx, AuthKey, LOGIN_ERROR_MAXUSER );
}
break;
case 14:
{
LoginError( dwConnectionIdx, AuthKey, LOGIN_ERROR_NOT_CLOSEBETAWINNER );
}
break;
case 15: //성인섭에 미성년자가 들어오려고 했다.
{
LoginError( dwConnectionIdx, AuthKey, LOGIN_ERROR_MINOR_INADULTSERVER );
}
break;
case 50: // 회원탈퇴한 계정임.
{
LoginError(dwConnectionIdx,AuthKey,LOGIN_ERROR_SECEDEDACCOUNT);
}
break;
default:
{
ASSERT(0);
}
}
}
//*/
BOOL CheckMaxUser( char* id, char* pw, WORD ServerNo, DWORD AuthKey, DWORD dwConnectionIdx )
{
char guery[128];
sprintf( guery, "EXEC %s \'%s\', \'%s\', %d, %d", "Up_CheckMaxUser", id, pw, ServerNo, AuthKey );
if( g_DB.LoginQuery(eQueryType_FreeQuery, eCheckMaxUser, dwConnectionIdx, guery) == FALSE )
{
g_Console.Log( eLogDisplay, 4, "DB is Busy" );
return FALSE;
}
return TRUE;
}
void RCheckMaxUser( LPQUERY pData, LPDBMESSAGE pMessage )
{
char id[20] = {0,};
char pwd[20] = {0,};
DWORD MaxUser = atoi((char*)pData->Data[0]);
DWORD AuthKey = atoi((char*)pData->Data[3]);
SafeStrCpy(id, (char*)pData->Data[1], 20);
SafeStrCpy(pwd, (char*)pData->Data[2], 20);
DWORD dwConnectionIdx = pMessage->dwID;
USERINFO* pUserInfo = g_pUserTable->FindUser(dwConnectionIdx);
if(pUserInfo == NULL) // 이미 나간경우
return;
if(pUserInfo->dwUniqueConnectIdx != AuthKey) // 이미 나가고 다른 넘이 들어온 경우
return;
if( g_dwMaxUser <= MaxUser )
{
LoginError( dwConnectionIdx, AuthKey, LOGIN_ERROR_MAXUSER );
return;
}
// MemberDB 교체에 따른 2004.03.22
char ip[20] = {0,};
WORD port = 0;
g_Network.GetUserAddress(dwConnectionIdx, ip, &port);
// LoginCheckQuery(id, pwd, ip, g_nServerSetNum, AuthKey, dwConnectionIdx);
}
enum CHItem // 캐릭터 아이템 정보를 받을때 사용
{
eCI_ObjectID = 0, eCI_DBIDX, eCI_IDX, eCI_Position, eCI_QPosition, eCI_Durability
};
void RTest(LPQUERY pData, LPDBMESSAGE pMessage)
{
}