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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
Intercessor.cpp
资源名称：SwordOnline.rar　[点击查看]
上传用户：dzyhzl
上传日期：2019-04-29
资源大小：56270k
文件大小：12k
源码类别：

模拟服务器

开发平台：

C/C++

Intercessor.cpp：源码内容
  1. // Intercessor.cpp : Defines the entry point for the application.
  2. //
  4. #include "stdafx.h"
  5. #include "resource.h"
  6. #include "Network.h"
  7. #include "PlayerManager.h"
  9. #include "KProtocolDef.h"
  10. #include "../../Sword3PaySys/S3AccServer/AccountLoginDef.h"
  12. #include "macro.h"
  13. #include "Event.h"
  14. #include "string.h"
  15. #include "Buffer.h"
  17. using OnlineGameLib::Win32::CEvent;
  18. using OnlineGameLib::Win32::_tstring;
  19. using OnlineGameLib::Win32::CBuffer;
  20. using OnlineGameLib::Win32::CPackager;
  22. #define WM_ENTER_AFFIRM ( WM_USER + 0x100 )
  23. #define WM_LEAVE_AFFIRM ( WM_USER + 0x200 )
  24. #define WM_SERVER_LOGIN_SUCCESSFUL ( WM_USER + 0x300 )
  25. #define WM_SERVER_LOGIN_FAILED ( WM_USER + 0x400 )
  27. #define BUFFER_LENGTH 100
  29. enum enumServerLoginErrorCode
  30. {
  31. enumConnectFailed = 0xA1,
  32. enumUsrNamePswdErr,
  33. enumIPPortErr,
  34. enumException
  35. };
  37. const DWORD g_dwServerIdentify = 0xAEFC07B5;
  39. /*
  40.  * Global variable
  41.  */
  43. HINSTANCE g_hInst;
  45. CEvent g_theWorkingTutorEvent( NULL, false, false, _T("Working_Tutor_Event") );
  47. CNetwork g_theNetwork;
  49. CPlayerManager *g_pPlayerManager = NULL;
  51. /*
  52.  * Helper function
  53.  */
  54. bool LoginSystem( HINSTANCE hInstance );
  56. BOOL CALLBACK MainWndProc( HWND hwnd, UINT msg, WPARAM wParam, LPARAM lParam );
  58. UINT MainDialog();
  59. void InitMainDlg( HWND hDlg );
  60. void CloseMainDlg( HWND hDlg );
  62. BOOL CALLBACK LoginDlgProc(HWND hwndDlg, UINT message, WPARAM wParam, LPARAM lParam);
  64. /*
  65.  * WinMain
  66.  */
  67. int APIENTRY WinMain(HINSTANCE hInstance,
  68.                      HINSTANCE hPrevInstance,
  69.                      LPSTR     lpCmdLine,
  70.                      int       nCmdShow)
  71. {
  72. int nRet = 0;
  74. g_hInst = hInstance;
  76. g_theNetwork.Create();
  78. /*
  79.  * To affirm account that it is used to check the application
  80.  */
  81. if ( LoginSystem( hInstance ) )
  82. {
  83. g_pPlayerManager = new CPlayerManager( 50, g_theNetwork );
  85. ASSERT( g_pPlayerManager );
  87. MainDialog();
  88. }
  90. g_theNetwork.Destroy();
  91. return nRet;
  92. }
  94. /*
  95.  * Log on to system
  96.  */
  97. bool LoginSystem( HINSTANCE hInstance )
  98. {
  99. if ( WM_SERVER_LOGIN_SUCCESSFUL == ::DialogBox( hInstance,
  100. MAKEINTRESOURCE( IDD_DLG_LOGIN ),
  101. NULL,
  102. ( DLGPROC )LoginDlgProc ) )
  103. {
  104. return true;
  105. }
  107. return false;
  108. }
  110. UINT MainDialog()
  111. {
  112. /*
  113.  * Create the main window as dialog. 
  114.  */
  115. HWND hwndMain = ::CreateDialog( g_hInst, 
  116. MAKEINTRESOURCE( IDD_DLG_INTERCESSOR ),
  117. NULL, 
  118. (DLGPROC) MainWndProc );
  120. ASSERT( hwndMain );
  122. ::ShowWindow( hwndMain, SW_SHOWNORMAL );
  123. ::UpdateWindow( hwndMain );
  126. BOOL bRet;
  127. MSG msg;
  129. while ( ( bRet = ::GetMessage( &msg, NULL, 0, 0 ) ) != 0 )
  130. {
  131. if ( !IsWindow( hwndMain ) || !IsDialogMessage( hwndMain, &msg ) )
  132. {
  133. ::TranslateMessage( &msg );
  134. ::DispatchMessage( &msg );
  135. }
  136. }
  138. return msg.wParam;
  139. }
  141. void InitMainDlg( HWND hDlg )
  142. {
  143. ::SetDlgItemText( hDlg, IDC_EDIT_ACCSVRIP, g_theNetwork.GetAccSvrIP() );
  144. ::SetDlgItemInt( hDlg, IDC_EDIT_ACCSVRPORT, g_theNetwork.GetAccSvrPort(), FALSE );
  146. ::SetDlgItemText( hDlg, IDC_EDIT_ROLESVRIP, g_theNetwork.GetRoleSvrIP() );
  147. ::SetDlgItemInt( hDlg, IDC_EDIT_ROLESVRPORT, g_theNetwork.GetRoleSvrPort(), FALSE );
  149. ::SetDlgItemInt( hDlg, IDC_EDIT_CLIENT_PORT, g_theNetwork.GetClientOpenPort(), FALSE );
  151. ::SetDlgItemInt( hDlg, IDC_EDIT_GAMESVR_PORT, g_theNetwork.GetGameSvrOpenPort(), FALSE );
  152. }
  154. void CloseMainDlg( HWND hDlg )
  155. {
  156. _tstring sBuffer;
  158. sBuffer.resize( BUFFER_LENGTH );
  160. ::GetDlgItemText( hDlg, IDC_EDIT_ROLESVRIP, const_cast< char * >( sBuffer.c_str() ), BUFFER_LENGTH );
  161. g_theNetwork.SetRoleSvrIP( sBuffer.c_str() );
  163. UINT nValue = 0;
  164. BOOL bTranslated = TRUE;
  166. nValue = ::GetDlgItemInt( hDlg, IDC_EDIT_ROLESVRPORT, &bTranslated, FALSE );
  167. g_theNetwork.SetRoleSvrPort( nValue );
  169. nValue = ::GetDlgItemInt( hDlg, IDC_EDIT_CLIENT_PORT, &bTranslated, FALSE );
  170. g_theNetwork.SetClientOpenPort( nValue );
  172. nValue = ::GetDlgItemInt( hDlg, IDC_EDIT_GAMESVR_PORT, &bTranslated, FALSE );
  173. g_theNetwork.SetGameSvrOpenPort( nValue );
  174. }
  176. DWORD WINAPI ServerLoginRoutine( LPVOID lpParam ) 
  177. {
  178. HWND hwndDlg = ( HWND )lpParam;
  180. ASSERT( hwndDlg );
  182. /*
  183.  * Ask for log on to the account server
  184.  */
  186. UINT nPort = 0;
  187. _tstring sBuffer, sUsername, sPassword;
  189. sBuffer.resize( MAX_PATH + 1 );
  191. ::GetDlgItemText( hwndDlg, IDC_EDIT_LOGONTO_IP, const_cast< char * >( sBuffer.c_str() ), MAX_PATH );
  193. BOOL bTranslated = TRUE;
  195. nPort = ::GetDlgItemInt( hwndDlg, IDC_EDIT_LOGONTO_PORT, &bTranslated, TRUE );
  197. IClient *pAccSvrClient = g_theNetwork.CreateAccSvrClient( sBuffer.c_str(),  nPort );
  199. if ( !pAccSvrClient )
  200. {
  201. ::PostMessage( hwndDlg, WM_SERVER_LOGIN_FAILED, enumConnectFailed, 0L );
  203. SAFE_RELEASE( pAccSvrClient );
  204. return 1L;
  205. }
  207. sUsername.resize( BUFFER_LENGTH );
  208. ::GetDlgItemText( hwndDlg, IDC_EDIT_USERNAME, const_cast< char * >( sUsername.c_str() ), BUFFER_LENGTH );
  210. sPassword.resize( BUFFER_LENGTH );
  211. ::GetDlgItemText( hwndDlg, IDC_EDIT_PASSWORD, const_cast< char * >( sPassword.c_str() ), BUFFER_LENGTH );
  213. /*
  214.  * Send a login command
  215.  */
  216. CBuffer *pBuffer = CNetwork::m_theGlobalAllocator.Allocate();
  218. BYTE *pData = const_cast< BYTE * >( pBuffer->GetBuffer() );
  220. const size_t datalength = sizeof( KAccountUserLoginInfo ) + 1;
  222. KAccountUserLoginInfo serlogin;
  223. serlogin.Size = sizeof( KAccountUserLoginInfo );
  225. serlogin.Type = AccountUserLoginInfo;
  226. serlogin.Version = ACCOUNT_CURRENT_VERSION;
  227. serlogin.Operate = g_dwServerIdentify;
  229. strcpy( serlogin.Account, sUsername.c_str() );
  230. strcpy( serlogin.Password, sPassword.c_str() );
  232. *pData = c2s_gatewayverify;
  233. memcpy( pData + 1, &serlogin, sizeof( KAccountUserLoginInfo ) );
  235. pBuffer->Use( datalength );
  237. pAccSvrClient->SendPackToServer( ( const void * )pData, datalength );
  239. SAFE_RELEASE( pBuffer );
  241. /*
  242.  * Wait for write back
  243.  */
  244. while ( pAccSvrClient )
  245. {
  246. size_t nLen = 0;
  248. const void *pData = pAccSvrClient->GetPackFromServer( nLen );
  250. if ( !pData || 0 == nLen )
  251. {
  252. ::Sleep( 1 );
  254. continue;
  255. }
  257. BYTE cProtocol = CPackager::Peek( pData );
  259. switch ( cProtocol )
  260. {
  261. case s2c_gatewayverify:
  262. {
  263. KAccountUserReturn* pReturn = ( KAccountUserReturn * )( ( ( char * )pData ) + 1 );
  265. nLen--;
  266. if ( pReturn &&
  267. ( g_dwServerIdentify == pReturn->Operate ) && 
  268. ( nLen == sizeof( KAccountUserReturn ) ) )
  269. {
  270. if ( ACTION_SUCCESS == pReturn->nReturn )
  271. {
  272. ::PostMessage( hwndDlg, WM_SERVER_LOGIN_SUCCESSFUL, 0L, 0L );
  273. }
  274. else if ( E_ACCOUNT_OR_PASSWORD == pReturn->nReturn )
  275. {
  276. ::PostMessage( hwndDlg, WM_SERVER_LOGIN_FAILED, enumUsrNamePswdErr, 0L );
  277. }
  278. else if ( E_ADDRESS_OR_PORT == pReturn->nReturn )
  279. {
  280. ::PostMessage( hwndDlg, WM_SERVER_LOGIN_FAILED, enumIPPortErr, 0L );
  281. }
  282. else
  283. {
  284. ::PostMessage( hwndDlg, WM_SERVER_LOGIN_FAILED, enumException, 0L );
  285. }
  287. SAFE_RELEASE( pAccSvrClient );
  288. return 1L;
  289. }
  290. }
  291. break;
  293. default:
  295. ASSERT( FALSE );
  297. break;
  298. }
  299. }
  301. SAFE_RELEASE( pAccSvrClient );
  303. return 0L;
  304. }
  306. void EnterToAffirm( HWND hwndDlg )
  307. {
  308. ::EnableWindow( ::GetDlgItem( hwndDlg, IDC_EDIT_USERNAME ), FALSE );
  309. ::EnableWindow( ::GetDlgItem( hwndDlg, IDC_EDIT_PASSWORD ), FALSE );
  310. ::EnableWindow( ::GetDlgItem( hwndDlg, IDC_EDIT_LOGONTO_IP ), FALSE );
  311. ::EnableWindow( ::GetDlgItem( hwndDlg, IDC_EDIT_LOGONTO_PORT ), FALSE );
  312. ::EnableWindow( ::GetDlgItem( hwndDlg, IDOK ), FALSE );
  313. ::EnableWindow( ::GetDlgItem( hwndDlg, IDCANCEL ), FALSE );
  315. /*
  316.  * Start up a listening thread to wait a required confirm from the account server
  317.  */
  318. DWORD dwThreadID = 0;
  320. HANDLE hThread = ::CreateThread( NULL, 0, ServerLoginRoutine, ( void * )hwndDlg, 0, &dwThreadID );
  322. SAFE_CLOSEHANDLE( hThread );
  323. }
  325. void LeaveToAffirm( HWND hwndDlg )
  326. {
  327. ::EnableWindow( ::GetDlgItem( hwndDlg, IDC_EDIT_USERNAME ), TRUE );
  328. ::EnableWindow( ::GetDlgItem( hwndDlg, IDC_EDIT_PASSWORD ), TRUE );
  329. ::EnableWindow( ::GetDlgItem( hwndDlg, IDC_EDIT_LOGONTO_IP ), TRUE );
  330. ::EnableWindow( ::GetDlgItem( hwndDlg, IDC_EDIT_LOGONTO_PORT ), TRUE );
  331. ::EnableWindow( ::GetDlgItem( hwndDlg, IDOK ), TRUE );
  332. ::EnableWindow( ::GetDlgItem( hwndDlg, IDCANCEL ), TRUE );
  333. }
  335. bool CheckUserInfo( HWND hwndDlg )
  336. {
  337. UINT nLen = 0;
  338. _tstring sBuffer;
  340. sBuffer.resize( MAX_PATH + 1 );
  342. if ( 0 == ( nLen = ::GetDlgItemText( hwndDlg, IDC_EDIT_USERNAME, const_cast< char * >( sBuffer.c_str() ), MAX_PATH ) ) )
  343. {
  344. ::SetFocus( ::GetDlgItem( hwndDlg, IDC_EDIT_USERNAME ) );
  346. ::MessageBox( hwndDlg, "Please input a valid username!", "Warning", MB_ICONASTERISK );
  348. return false;
  349. }
  351. if ( 0 == ( nLen = ::GetDlgItemText( hwndDlg, IDC_EDIT_LOGONTO_IP, const_cast< char * >( sBuffer.c_str() ), MAX_PATH ) ) )
  352. {
  353. ::SetFocus( ::GetDlgItem( hwndDlg, IDC_EDIT_LOGONTO_IP ) );
  355. ::MessageBox( hwndDlg, "Please input a valid IP!", "Warning", MB_ICONASTERISK );
  357. return false;
  358. }
  360. BOOL bTranslated = FALSE;
  362. if ( 0 == ( nLen = ::GetDlgItemInt( hwndDlg, IDC_EDIT_LOGONTO_PORT, &bTranslated, TRUE ) ) )
  363. {
  364. ::SetFocus( ::GetDlgItem( hwndDlg, IDC_EDIT_LOGONTO_PORT ) );
  366. ::MessageBox( hwndDlg, "Please input a valid port!", "Warning", MB_ICONASTERISK );
  368. return false;
  369. }
  371. return true;
  372. }
  374. BOOL CALLBACK LoginDlgProc( HWND hwndDlg, UINT message, WPARAM wParam, LPARAM lParam )
  375. {
  376. _tstring sBuffer;
  378.     switch (message)
  379.     {
  380. case WM_SERVER_LOGIN_SUCCESSFUL:
  382. ::EndDialog( hwndDlg, WM_SERVER_LOGIN_SUCCESSFUL );
  384. break;
  386. case WM_SERVER_LOGIN_FAILED:
  388. switch( wParam )
  389. {
  390. case enumUsrNamePswdErr:
  392. sBuffer.resize( MAX_PATH );
  394. ::LoadString( g_hInst, IDS_NAMEPSWD_ERROR, const_cast< char * >( sBuffer.c_str() ), MAX_PATH );
  396. ::MessageBox( hwndDlg, sBuffer.c_str(), NULL, MB_ICONEXCLAMATION );
  398. ::PostMessage( hwndDlg, WM_LEAVE_AFFIRM, 0L, 0L );
  400. break;
  402. case enumConnectFailed:
  403. case enumIPPortErr:
  405. sBuffer.resize( MAX_PATH );
  407. ::LoadString( g_hInst, IDS_NETWORK_ERROR, const_cast< char * >( sBuffer.c_str() ), MAX_PATH );
  409. ::MessageBox( hwndDlg, sBuffer.c_str(), NULL, MB_ICONEXCLAMATION );
  411. ::PostMessage( hwndDlg, WM_LEAVE_AFFIRM, 0L, 0L );
  413. break;
  415. case enumException:
  416. default:
  418. ::MessageBox( hwndDlg, "Exception!", NULL, MB_ICONEXCLAMATION );
  420. ::EndDialog( hwndDlg, WM_SERVER_LOGIN_FAILED );
  422. break;
  423. }
  425. break;
  427. case WM_ENTER_AFFIRM:
  429. EnterToAffirm( hwndDlg );
  431. break;
  433. case WM_LEAVE_AFFIRM:
  435. LeaveToAffirm( hwndDlg );
  437. break;
  439. case WM_INITDIALOG:
  441. ::SetFocus( ::GetDlgItem( hwndDlg, IDC_EDIT_USERNAME ) );
  443. // TEMPORAL
  444. ::SetDlgItemText( hwndDlg, IDC_EDIT_LOGONTO_IP, "192.168.26.1" );
  445. ::SetDlgItemInt( hwndDlg, IDC_EDIT_LOGONTO_PORT, 5002, FALSE );
  447. break;
  449. case WM_COMMAND:
  451. switch ( LOWORD( wParam ) )
  452. {
  453. case IDOK:
  455. if ( CheckUserInfo( hwndDlg ) )
  456. {
  457. ::PostMessage( hwndDlg, WM_ENTER_AFFIRM, 0L, 0L );
  458. }
  460. break;
  462. case IDCANCEL:
  464. ::EndDialog( hwndDlg, WM_SERVER_LOGIN_FAILED );
  466. return TRUE; 
  467. } 
  468.     }
  470.     return FALSE;
  471. }
  473. /*
  474.  *
  475.  * MainWndProc() - Main window callback procedure.
  476.  *  
  477.  */
  479. BOOL CALLBACK MainWndProc( HWND hwnd, 
  480.                            UINT msg,
  481.                            WPARAM wParam,
  482.                            LPARAM lParam )
  483. {
  484. switch ( msg )
  485. {
  486. case WM_INITDIALOG:
  488. /*
  489.  * Initialize
  490.  */
  491. InitMainDlg( hwnd );
  493. return TRUE;
  495. break;
  497. case WM_CLOSE:
  499. CloseMainDlg( hwnd );
  501. if ( g_pPlayerManager )
  502. {
  503. g_pPlayerManager->Destroy();
  504. }
  506. ::DestroyWindow( hwnd );
  507. ::PostQuitMessage( 0 );
  509. return TRUE;
  511. break;
  513. case WM_COMMAND:
  515. switch (wParam)
  516. {
  517. case IDOK:
  519. ::EnableWindow( GetDlgItem( hwnd, IDOK ), FALSE );
  521. if ( !g_pPlayerManager->Create() )
  522. {
  523. ::EnableWindow( GetDlgItem( hwnd, IDOK ), TRUE );
  525. g_pPlayerManager->Destroy();
  526. }
  528. break;
  530. case IDCANCEL:
  532. ::PostMessage( hwnd, WM_CLOSE, 0L, 0L );
  534. break;
  535. }
  537. break;
  539. default:
  541. break;
  543. }
  545. /*
  546.  * Clean up any unused messages by calling DefWindowProc
  547.  */
  548. return FALSE;
  549. //return ::DefWindowProc( hwnd, msg, wParam, lParam );
  550. }