开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
GateInfo.cpp
资源名称：LegendOfMir2_Server020418.zip　[点击查看]
上传用户：szopptop
上传日期：2013-04-23
资源大小：1047k
文件大小：15k
源码类别：

模拟服务器

开发平台：

Visual C++

GateInfo.cpp：源码内容
  1. #include "stdafx.h"
  2. #include "../def/dbmgr.h"
  3. #include <stdio.h>
  5. extern CWHList< GAMESERVERINFO* > g_xGameServerList;
  6. extern char g_szServerList[1024];
  8. int CompareDBString( char *str1, char *str2 )
  9. {
  10. ChangeSpaceToNull( str1 );
  11. ChangeSpaceToNull( str2 );
  13. return strcmp( str1, str2 );
  14. }
  16. int GetCertification() 
  17. { 
  18. static long g_nCertification = 30;
  20. InterlockedIncrement(&g_nCertification);
  22. if (g_nCertification >= 0x7FFFFFFF) 
  23. g_nCertification = 30; 
  25. return g_nCertification; 
  26. }
  28. /* **************************************************************************************
  30. Close
  32. PURPOSE : Send packet to login gate server.
  34. NOTE
  36. 1. Packet construction : Packet % + client socket handle + / # + packet + ! + $
  38.    ************************************************************************************** */
  40. void CGateInfo::Close()
  41. {
  42. PLISTNODE pListNode;
  43. CUserInfo* pUserInfo;
  45. if (xUserInfoList.GetCount())
  46. {
  47. pListNode = xUserInfoList.GetHead();
  49. while (pListNode)
  50. {
  51. pUserInfo = xUserInfoList.GetData(pListNode);
  53. if (pUserInfo)
  54. {
  55. delete pUserInfo;
  56. pUserInfo = NULL;
  58. pListNode = xUserInfoList.RemoveNode(pListNode);
  60. continue;
  61. }
  63. pListNode = xUserInfoList.GetNext(pListNode);
  64. }
  65. }
  67. closesocket(sock);
  68. sock = INVALID_SOCKET;
  69. }
  71. /* **************************************************************************************
  73. SendToGate 
  75. PURPOSE : Send packet to login gate server.
  77. NOTE
  79. 1. Packet construction : Packet % + client socket handle + / # + packet + ! + $
  81.    ************************************************************************************** */
  83. void CGateInfo::SendToGate(SOCKET cSock, char *pszPacket)
  84. {
  85. char szData[256];
  86. WSABUF buf;
  87. DWORD dwSendBytes;
  89. // wsprintf(szData, _TEXT("%%%d/#%s!$"), (int)cSock, pszPacket);
  91. int nLen = memlen(pszPacket) - 1;
  93. szData[0] = '%';
  95. char *pszNext = ValToAnsiStr((int)cSock, &szData[1]);
  97. *pszNext++ = '/';
  98. *pszNext++ = '#';
  100. memmove(pszNext, pszPacket, nLen);
  102. pszNext += nLen;
  104. *pszNext++ = '!';
  105. *pszNext++ = '$';
  106. *pszNext++ = '';
  108. buf.len = pszNext - szData;
  109. buf.buf = szData;
  111. WSASend(sock, &buf, 1, &dwSendBytes, 0, NULL, NULL);
  112. }
  114. /* **************************************************************************************
  116. MakeNewUser
  118. PURPOSE : 
  120. NOTE
  122.    ************************************************************************************** */
  124. void CGateInfo::MakeNewUser(char *pszPacket)
  125. {
  126. char szDecodeMsg[256];
  127. char szEncodeMsg[32];
  128. char *pszID, *pszName, *pszPassword;
  129. _TDEFAULTMESSAGE DefMsg;
  131. fnDecodeMessageA(&DefMsg, pszPacket);
  133. if (DefMsg.wIdent == CM_ADDNEWUSER)
  134. {
  135. int nPos = fnDecode6BitBufA((pszPacket + DEFBLOCKSIZE), szDecodeMsg, sizeof(szDecodeMsg));
  136. szDecodeMsg[nPos] = '';
  138. pszID = &szDecodeMsg[0];
  140. pszName = (char *)memchr(szDecodeMsg, '/', memlen(szDecodeMsg) - 1);
  141. *pszName = '';
  142. pszName++;
  144. pszPassword = (char *)memchr(pszName, '/', memlen(pszName) - 1);
  145. *pszPassword = '';
  146. pszPassword++;
  148. if ((memlen(pszID) - 1) || (memlen(pszName) - 1) || (memlen(pszPassword) - 1))
  149. {
  150. char szQuery[1024];
  151. sprintf( szQuery, 
  152. "INSERT TBL_ACCOUNT( FLD_LOGINID, FLD_PASSWORD, FLD_USERNAME, FLD_CERTIFICATION ) "
  153. "VALUES( '%s', '%s', '%s', 0 )",
  154. pszID, pszPassword, pszName );
  156. CRecordset *pRec = GetDBManager()->CreateRecordset();
  157. if ( pRec->Execute( szQuery ) && pRec->GetRowCount() )
  158. fnMakeDefMessageA( &DefMsg, SM_NEWID_SUCCESS, 0, 0, 0, 0 );
  159. else
  160. fnMakeDefMessageA( &DefMsg, SM_NEWID_FAIL, 0, 0, 0, 0 );
  161. GetDBManager()->DestroyRecordset( pRec );
  162. // -----------------------------------------------------------------------------------
  163. }
  164. else
  165. fnMakeDefMessageA(&DefMsg, SM_NEWID_FAIL, 0, 0, 0, 0);
  167. fnEncodeMessageA(&DefMsg, szEncodeMsg, sizeof(szEncodeMsg));
  169. szDecodeMsg[0] = '#';
  170. memmove(&szDecodeMsg[1], szEncodeMsg, DEFBLOCKSIZE);
  171. szDecodeMsg[DEFBLOCKSIZE + 1] = '!';
  172. szDecodeMsg[DEFBLOCKSIZE + 2] = '';
  174. send(sock, szDecodeMsg, DEFBLOCKSIZE + 2, 0); 
  175. }
  176. }
  178. /* **************************************************************************************
  180. ReceiveServerMsg
  182. PURPOSE : 
  184. NOTE
  186.    ************************************************************************************** */
  188. void CGateInfo::ReceiveServerMsg(char *pszPacket)
  189. {
  190. char *pszPos;
  191. int nCertification;
  192. int nLen = memlen(pszPacket);
  194. if (pszPos = (char *)memchr(pszPacket, '/', nLen))
  195. {
  196. *pszPos++ = '';
  197. nCertification = AnsiStrToVal(pszPos);
  199. char szQuery[256];
  200. sprintf( szQuery, 
  201. "UPDATE TBL_ACCOUNT SET FLD_CERTIFICATION=%d WHERE FLD_LOGINID='%s'", 
  202. nCertification, pszPacket );
  204. CRecordset *pRec = GetDBManager()->CreateRecordset();
  205. pRec->Execute( szQuery );
  206. GetDBManager()->DestroyRecordset( pRec );
  207. }
  208. }
  210. void CGateInfo::ReceiveOpenUser(char *pszPacket)
  211. {
  212. char *pszPos;
  213. int nSocket;
  214. int nLen = memlen(pszPacket);
  216. if (pszPos = (char *)memchr(pszPacket, '/', nLen))
  217. {
  218. nSocket = AnsiStrToVal(pszPacket);
  220. pszPos++;
  222. CUserInfo* pUserInfo = new CUserInfo;
  224. if (pUserInfo)
  225. {
  226. MultiByteToWideChar(CP_ACP, 0, pszPacket, -1, pUserInfo->szSockHandle, sizeof(pUserInfo->szSockHandle)/sizeof(TCHAR));
  227. MultiByteToWideChar(CP_ACP, 0, pszPos, -1, pUserInfo->szAddress, sizeof(pUserInfo->szAddress)/sizeof(TCHAR));
  229. pUserInfo->sock = nSocket;
  230. pUserInfo->nCertification = 0;
  231. pUserInfo->nClientVersion = 0;
  232. pUserInfo->fSelServerOk = FALSE;
  234. ZeroMemory(pUserInfo->szUserID, sizeof(pUserInfo->szUserID));
  236. xUserInfoList.AddNewNode(pUserInfo);
  238. InsertLogMsgParam(IDS_OPEN_USER, pUserInfo->szAddress);
  239. }
  240. } 
  241. }
  243. /* **************************************************************************************
  245. ReceiveCloseUser
  247. PURPOSE : 
  249. NOTE
  251.    ************************************************************************************** */
  253. void CGateInfo::ReceiveCloseUser(char *pszPacket)
  254. {
  255. int nSocket = AnsiStrToVal(pszPacket);
  256. }
  258. /* **************************************************************************************
  260. ReceiveSendUser
  262. PURPOSE : 
  264. NOTE
  266.    ************************************************************************************** */
  268. void CGateInfo::ReceiveSendUser(char *pszPacket)
  269. {
  270. char *pszPos;
  271. int nSocket;
  272. int nLen = memlen(pszPacket);
  274. if ((pszPos = (char *)memchr(pszPacket, '/', nLen)))
  275. {
  276. nSocket = AnsiStrToVal(pszPacket);
  278. pszPos++;
  280. _LPTSENDBUFF lpSendUserData = new _TSENDBUFF;
  282. lpSendUserData->sock = (SOCKET)nSocket;
  284. memmove(lpSendUserData->szData, pszPos, memlen(pszPos));
  286. g_SendToGateQ.PushQ((BYTE *)lpSendUserData);
  287. }
  288. }
  290. /* **************************************************************************************
  292. ProcSelectServer
  294. PURPOSE : 
  296. NOTE
  298.    ************************************************************************************** */
  300. void CGateInfo::ProcSelectServer(SOCKET s, WORD wServerIndex)
  301. {
  302. _TDEFAULTMESSAGE DefMsg;
  303. char szEncodePacket[128];
  304. char szEncodeAllPacket[256];
  305. char szEncodeMsg[24];
  306. char *pServerIP;
  307. GAMESERVERINFO *pServerInfo;
  309. PLISTNODE pListNode = xUserInfoList.GetHead();
  311. while (pListNode)
  312. {
  313. CUserInfo *pUserInfo = xUserInfoList.GetData(pListNode);
  315. if (pUserInfo->sock == s)
  316. {
  317. if (!pUserInfo->fSelServerOk)
  318. {
  319. fnMakeDefMessageA(&DefMsg, SM_SELECTSERVER_OK, 0, pUserInfo->nCertification, 0, 0);
  320. int nPos = fnEncodeMessageA(&DefMsg, szEncodeMsg, sizeof(szEncodePacket));
  321. szEncodeMsg[nPos] = '';
  323. for ( PLISTNODE pNode = g_xGameServerList.GetHead(); pNode; pNode = g_xGameServerList.GetNext( pNode ) )
  324. {
  325. pServerInfo = g_xGameServerList.GetData( pNode );
  327. if ( pServerInfo->index == wServerIndex )
  328. {
  329. pServerIP = pServerInfo->ip;
  330. pServerInfo->connCnt++;
  331. break;
  332. }
  333. }
  335. if ( !pServerIP )
  336. break;
  338. pUserInfo->nServerID = wServerIndex;
  340. int nPos2 = fnEncode6BitBufA((unsigned char *)pServerIP, szEncodePacket, memlen(pServerIP), sizeof(szEncodePacket));
  341. szEncodePacket[nPos2] = '';
  343. memmove(szEncodeAllPacket, szEncodeMsg, nPos);
  344. memmove(&szEncodeAllPacket[nPos], szEncodePacket, nPos2);
  345. szEncodeAllPacket[nPos + nPos2] = '';
  347. SendToGate(s, szEncodeAllPacket);
  349. pUserInfo->fSelServerOk = TRUE;
  351. pListNode = xUserInfoList.RemoveNode(pListNode);
  352. }
  353. }
  354. else
  355. pListNode = xUserInfoList.GetNext(pListNode);
  356. }
  357. }
  359. /* **************************************************************************************
  361. ParseUserEntry
  363. PURPOSE : 
  365. NOTE
  367.    ************************************************************************************** */
  369. bool CGateInfo::ParseUserEntry( char *buf, _AUSERENTRYINFO *userInfo )
  370. {
  371. char seps[] = "01";
  372. char *token = strtok( buf, seps );
  373. int  step   = 0;
  375. __try
  376. {
  377. while ( token )
  378. {
  379. switch ( step++ )
  380. {
  381. case 0: strcpy( userInfo->szLoginID, token );
  382. case 1: strcpy( userInfo->szPassword, token ); 
  383. case 2: strcpy( userInfo->szUserName, token );
  384. case 3: strcpy( userInfo->szSSNo, token );
  385. case 4: strcpy( userInfo->szBirthDay, token ); 
  386. case 5: strcpy( userInfo->szZipCode, token );
  387. case 6: strcpy( userInfo->szAddress1, token ); 
  388. case 7: strcpy( userInfo->szAddress2, token );
  389. case 8: strcpy( userInfo->szPhone, token ); 
  390. case 9: strcpy( userInfo->szMobilePhone, token ); 
  391. case 10: strcpy( userInfo->szEmail, token ); 
  392. case 11: strcpy( userInfo->szQuiz, token ); 
  393. case 12: strcpy( userInfo->szAnswer, token ); 
  394. case 13: strcpy( userInfo->szQuiz2, token ); 
  395. case 14: strcpy( userInfo->szAnswer2, token ); 
  396. }
  398. token = strtok( NULL, seps );
  399. }
  400. }
  401. __except ( EXCEPTION_EXECUTE_HANDLER )
  402. {
  403. return false;
  404. }
  406. return step >= 15;
  407. }
  409. /* **************************************************************************************
  411. ProcAddUser
  413. PURPOSE : 
  415. NOTE
  417.    ************************************************************************************** */
  419. void CGateInfo::ProcAddUser(SOCKET s, char *pszData)
  420. {
  421. char szEntryInfo[2048];
  422. _AUSERENTRYINFO UserEntryInfo;
  423. _TDEFAULTMESSAGE DefMsg;
  424. char szEncodePacket[64];
  426. int len = fnDecode6BitBufA(pszData, (char *)&szEntryInfo, sizeof(szEntryInfo));
  427. szEntryInfo[len] = '';
  429. if ( !ParseUserEntry( szEntryInfo, &UserEntryInfo ) )
  430. fnMakeDefMessageA(&DefMsg, SM_NEWID_FAIL, 0, 0, 0, 0);
  431. else
  432. {
  433. char szQuery[1024];
  434. sprintf( szQuery, 
  435. "SELECT * FROM TBL_ACCOUNT WHERE FLD_LOGINID='%s'",
  436. UserEntryInfo.szLoginID );
  438. CRecordset *pRec = GetDBManager()->CreateRecordset();
  440. if (!pRec->Execute( szQuery ))
  441. fnMakeDefMessageA(&DefMsg, SM_NEWID_FAIL, 0, 0, 0, 0);
  443. if ( pRec->Fetch() )
  444. fnMakeDefMessageA(&DefMsg, SM_NEWID_FAIL, 0, 0, 0, 0);
  445. else
  446. {
  447. GetDBManager()->DestroyRecordset( pRec );
  449. pRec = GetDBManager()->CreateRecordset();
  451. sprintf( szQuery, 
  452. "INSERT TBL_ACCOUNT(FLD_LOGINID, FLD_PASSWORD, FLD_USERNAME, FLD_CERTIFICATION) "
  453. "VALUES( '%s', '%s', '%s', 0 )",
  454. UserEntryInfo.szLoginID, 
  455. UserEntryInfo.szPassword, 
  456. UserEntryInfo.szUserName );
  458. pRec->Execute( szQuery );
  460. sprintf( szQuery,
  461. "INSERT TBL_ACCOUNTADD(FLD_LOGINID, FLD_SSNO, FLD_BIRTHDAY, FLD_ADDRESS1, FLD_ADDRESS2, "
  462.                       "FLD_PHONE, FLD_MOBILEPHONE, FLD_EMAIL, FLD_QUIZ1, FLD_ANSWER1, FLD_QUIZ2, FLD_ANSWER2) "
  463. "VALUES( '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s' )",
  464. UserEntryInfo.szLoginID,
  465. UserEntryInfo.szSSNo,
  466. UserEntryInfo.szBirthDay,
  467. UserEntryInfo.szAddress1,
  468. UserEntryInfo.szAddress2,
  469. UserEntryInfo.szPhone,
  470. UserEntryInfo.szMobilePhone,
  471. UserEntryInfo.szEmail,
  472. UserEntryInfo.szQuiz,
  473. UserEntryInfo.szAnswer,
  474. UserEntryInfo.szQuiz2,
  475. UserEntryInfo.szAnswer2 );
  477. pRec->Execute( szQuery );
  478. }
  480. GetDBManager()->DestroyRecordset( pRec );
  482. fnMakeDefMessageA(&DefMsg, SM_NEWID_SUCCESS, 0, 0, 0, 0);
  484. TCHAR szID[32];
  485. MultiByteToWideChar( CP_ACP, 0, UserEntryInfo.szLoginID, -1, szID, sizeof( szID ) / sizeof( TCHAR ) );
  486. InsertLogMsgParam(IDS_COMPLETENEWUSER, szID);
  487. }
  489. fnEncodeMessageA(&DefMsg, szEncodePacket, sizeof(szEncodePacket));
  490. SendToGate(s, szEncodePacket);
  491. }
  493. /* **************************************************************************************
  495. ProcLogin
  497. PURPOSE : 
  499. NOTE
  501.    ************************************************************************************** */
  503. void CGateInfo::ProcLogin(SOCKET s, char *pszData)
  504. {
  505. char szIDPassword[32];
  506. char *pszID, *pszPassword;
  507. char szEncodePacket[64];
  508. _TDEFAULTMESSAGE DefMsg;
  509. int nPos;
  510. char szQuery[256];
  512. if (memlen(pszData) - 1 <= 0) return;
  514. PLISTNODE pListNode = xUserInfoList.GetHead();
  516. while (pListNode)
  517. {
  518. CUserInfo *pUserInfo = xUserInfoList.GetData(pListNode);
  520. if (pUserInfo->sock == s)
  521. {
  522. int nDecodeLen = fnDecode6BitBufA(pszData, szIDPassword, sizeof(szIDPassword));
  523. szIDPassword[nDecodeLen] = '';
  525. pszID = &szIDPassword[0];
  527. if (pszPassword = (char *)memchr(szIDPassword, '/', sizeof(szIDPassword)))
  528. {
  529. *pszPassword = '';
  530. pszPassword++;
  532. sprintf( szQuery, "SELECT * FROM TBL_ACCOUNT WHERE FLD_LOGINID='%s'", pszID );
  534. CRecordset *pRec = GetDBManager()->CreateRecordset();
  536. if ( !pRec->Execute( szQuery ) || !pRec->Fetch() )
  537. fnMakeDefMessageA( &DefMsg, SM_ID_NOTFOUND, 0, 0, 0, 0 );
  538. else if ( CompareDBString( pszPassword, pRec->Get( "FLD_PASSWORD" ) ) != 0 )
  539. fnMakeDefMessageA( &DefMsg, SM_PASSWD_FAIL, 0, 0, 0, 0 );
  540. else
  541. {
  542. int nCertCode = atoi( pRec->Get( "FLD_CERTIFICATION" ) );
  543. /*
  544. if ( nCertCode > 0 && nCertCode < 30 )
  545. fnMakeDefMessageA(&DefMsg, SM_CERTIFICATION_FAIL, (nCertCode + 1), 0, 0, 0);
  546. else if ( nCertCode >= 30 )
  547. fnMakeDefMessageA(&DefMsg, SM_CERTIFICATION_FAIL, 1, 0, 0, 0);
  548. else*/
  549. {
  550. char szEncodeServerList[512];
  551. char szEncodeAllPacket[1024];
  553. fnMakeDefMessageA(&DefMsg, SM_PASSOK_SELECTSERVER, 0, 1, 0, 0);
  554. nPos = fnEncodeMessageA(&DefMsg, szEncodePacket, sizeof(szEncodePacket));
  555. szEncodePacket[nPos] = '';
  557. int nPos2 = fnEncode6BitBufA((unsigned char *)g_szServerList, szEncodeServerList, memlen(g_szServerList), sizeof(szEncodeServerList));
  558. szEncodeServerList[nPos2] = '';
  560. memmove(szEncodeAllPacket, szEncodePacket, nPos);
  561. memmove(&szEncodeAllPacket[nPos], szEncodeServerList, memlen(szEncodeServerList));
  563. SendToGate(s, szEncodeAllPacket);
  565. GetDBManager()->DestroyRecordset( pRec );
  567. pUserInfo->nCertification = GetCertification();
  569. // pRec = GetDBManager()->CreateRecordset();
  570. // sprintf( szQuery, 
  571. // "UPDATE TBL_ACCOUNT SET FLD_CERTIFICATION=%d WHERE FLD_LOGINID='%s'",
  572. // GetCertification(), pszID );
  573. // pRec->Execute( szQuery );
  575. // GetDBManager()->DestroyRecordset( pRec );
  577. return;
  578. }
  579. }
  581. GetDBManager()->DestroyRecordset( pRec );
  583. nPos = fnEncodeMessageA(&DefMsg, szEncodePacket, sizeof(szEncodePacket));
  584. szEncodePacket[nPos] = '';
  586. SendToGate(s, szEncodePacket);
  587. }
  588. }
  590. pListNode = xUserInfoList.GetNext(pListNode);
  591. }
  592. }