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

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

模拟服务器

开发平台：

C/C++

Player.cpp：源码内容
  1. //******************************************************************************
  2. /*! file       Player.cpp
  3. *   brief      简要描述
  4. *
  5. * 详细描述
  6. *   author 作者
  7. *   version 版本号
  8. *   date 2003-6-4 11:49:24
  9. *   sa 参考内容
  10. *   todo 将要做的工作
  11. *******************************************************************************/
  13. #include "stdafx.h"
  14. #include <objbase.h>
  15. #include <initguid.h>
  16. #include "Player.h"
  17. #include "....Sword3PaySysS3AccServerAccountLoginDef.h"
  18. #include "....s3clientloginLoginDef.h"
  19. #include "..RobotManagerprotocol.h"
  20. #include "..RobotManagerstruct.h"
  22. //#include "....RoleDBManagerkroledbheader.h"
  23. #include "S3DBInterface.h"
  24. #include "KProtocolDef.h"
  25. #include "KProtocol.h"
  26. #include "Macro.h"
  27. #include "Inifile.h"
  28. #include "Utils.h"
  29. #include "tstring.h"
  30. #include "Library.h"
  31. #include "Console.h"
  32. #include "Robot.h"
  34. CCriticalSection g_csPlayerList;
  36. int g_nGameProtocolSize[MAX_PROTOCOL_NUM] = 
  37. {
  38. -1, // s2c_login,
  39. -1, // s2c_logout,
  40. sizeof(BYTE), // s2c_syncend,
  41. sizeof(CURPLAYER_SYNC), // s2c_synccurplayer,
  42. -1, // s2c_synccurplayerskill
  43. sizeof(CURPLAYER_NORMAL_SYNC),// s2c_synccurplayernormal
  44. -1, // s2c_newplayer,
  45. -1, // s2c_removeplayer,
  46. sizeof(WORLD_SYNC), // s2c_syncworld,
  47. sizeof(PLAYER_SYNC), // s2c_syncplayer,
  48. sizeof(PLAYER_NORMAL_SYNC), // s2c_syncplayermin,
  49. -1, //sizeof(NPC_SYNC), // s2c_syncnpc,
  50. sizeof(NPC_NORMAL_SYNC), // s2c_syncnpcmin,
  51. sizeof(NPC_PLAYER_TYPE_NORMAL_SYNC), // s2c_syncnpcminplayer,
  53. sizeof(OBJ_SYNC_ADD), // s2c_objadd,
  54. sizeof(OBJ_SYNC_STATE), // s2c_syncobjstate,
  55. sizeof(OBJ_SYNC_DIR), // s2c_syncobjdir,
  56. sizeof(OBJ_SYNC_REMOVE), // s2c_objremove,
  57. sizeof(OBJ_SYNC_TRAP_ACT), // s2c_objTrapAct,
  59. sizeof(NPC_REMOVE_SYNC), // s2c_npcremove,
  60. sizeof(NPC_WALK_SYNC), // s2c_npcwalk,
  61. sizeof(NPC_RUN_SYNC), // s2c_npcrun,
  62. -1, // s2c_npcattack,
  63. -1, // s2c_npcmagic,
  64. sizeof(NPC_JUMP_SYNC), // s2c_npcjump,
  65. -1, // s2c_npctalk,
  66. sizeof(NPC_HURT_SYNC), // s2c_npchurt,
  67. sizeof(NPC_DEATH_SYNC), // s2c_npcdeath,
  68. sizeof(NPC_CHGCURCAMP_SYNC),// s2c_npcchgcurcamp,
  69. sizeof(NPC_CHGCAMP_SYNC), // s2c_npcchgcamp,
  70. sizeof(NPC_SKILL_SYNC), // s2c_skillcast,
  71. -1, // s2c_playertalk,
  72. sizeof(PLAYER_EXP_SYNC), // s2c_playerexp,
  74. sizeof(PLAYER_SEND_TEAM_INFO), // s2c_teaminfo,
  75. sizeof(PLAYER_SEND_SELF_TEAM_INFO), // s2c_teamselfinfo,
  76. sizeof(PLAYER_APPLY_TEAM_INFO_FALSE), // s2c_teamapplyinfofalse,
  77. sizeof(PLAYER_SEND_CREATE_TEAM_SUCCESS),// s2c_teamcreatesuccess,
  78. sizeof(PLAYER_SEND_CREATE_TEAM_FALSE), // s2c_teamcreatefalse,
  79. sizeof(PLAYER_TEAM_OPEN_CLOSE), // s2c_teamopenclose,
  80. sizeof(PLAYER_APPLY_ADD_TEAM), // s2c_teamgetapply,
  81. sizeof(PLAYER_TEAM_ADD_MEMBER), // s2c_teamaddmember,
  82. sizeof(PLAYER_LEAVE_TEAM), // s2c_teamleave,
  83. sizeof(PLAYER_TEAM_CHANGE_CAPTAIN), // s2c_teamchangecaptain,
  84. sizeof(PLAYER_FACTION_DATA), // s2c_playerfactiondata,
  85. sizeof(PLAYER_LEAVE_FACTION), // s2c_playerleavefaction,
  86. sizeof(PLAYER_FACTION_SKILL_LEVEL), // s2c_playerfactionskilllevel,
  87. -1,//sizeof(PLAYER_SEND_CHAT_SYNC), // s2c_playersendchat,
  88. sizeof(PLAYER_LEAD_EXP_SYNC), // s2c_playersyncleadexp
  89. sizeof(PLAYER_LEVEL_UP_SYNC), // s2c_playerlevelup
  90. sizeof(PLAYER_TEAMMATE_LEVEL_SYNC), // s2c_teammatelevel
  91. sizeof(PLAYER_ATTRIBUTE_SYNC), // s2c_playersyncattribute
  92. sizeof(PLAYER_SKILL_LEVEL_SYNC), // s2c_playerskilllevel
  93. sizeof(ITEM_SYNC), // s2c_syncitem
  94. sizeof(ITEM_REMOVE_SYNC), // s2c_removeitem
  95. sizeof(PLAYER_MONEY_SYNC), // s2c_syncmoney
  96. sizeof(PLAYER_MOVE_ITEM_SYNC), // s2c_playermoveitem
  97. -1, // s2c_playershowui
  98. sizeof(CHAT_APPLY_ADD_FRIEND_SYNC), // s2c_chatapplyaddfriend
  99. sizeof(CHAT_ADD_FRIEND_SYNC), // s2c_chataddfriend
  100. -1,//sizeof(CHAT_REFUSE_FRIEND_SYNC), // s2c_chatrefusefriend
  101. sizeof(CHAT_ADD_FRIEND_FAIL_SYNC), // s2c_chataddfriendfail
  102. sizeof(CHAT_LOGIN_FRIEND_NONAME_SYNC), // s2c_chatloginfriendnoname
  103. -1,//sizeof(CHAT_LOGIN_FRIEND_NAME_SYNC), // s2c_chatloginfriendname
  104. sizeof(CHAT_ONE_FRIEND_DATA_SYNC), // s2c_chatonefrienddata
  105. sizeof(CHAT_FRIEND_ONLINE_SYNC), // s2c_chatfriendinline
  106. sizeof(CHAT_DELETE_FRIEND_SYNC), // s2c_chatdeletefriend
  107. sizeof(CHAT_FRIEND_OFFLINE_SYNC), // s2c_chatfriendoffline
  108. sizeof(ROLE_LIST_SYNC), // s2c_syncrolelist
  109. sizeof(TRADE_CHANGE_STATE_SYNC), // s2c_tradechangestate
  110. -1, // NPC_SET_MENU_STATE_SYNC    s2c_npcsetmenustate
  111. sizeof(TRADE_MONEY_SYNC), // s2c_trademoneysync
  112. sizeof(TRADE_DECISION_SYNC), // s2c_tradedecision
  113. -1, // sizeof(CHAT_SCREENSINGLE_ERROR_SYNC)s2c_chatscreensingleerror
  114. sizeof(NPC_SYNC_STATEINFO), // s2c_syncnpcstate,
  115. -1, // sizeof(TEAM_INVITE_ADD_SYNC)    s2c_teaminviteadd
  116. sizeof(TRADE_STATE_SYNC), // s2c_tradepressoksync
  117. sizeof(PING_COMMAND), // s2c_ping
  118. sizeof(NPC_SIT_SYNC), // s2c_npcsit
  119. sizeof(SALE_BOX_SYNC), // s2c_opensalebox
  120. sizeof(NPC_SKILL_SYNC), // s2cDirectlyCastSkill
  121. -1, // s2c_msgshow
  122. -1, // s2c_syncstateeffect
  123. sizeof(BYTE), // s2c_openstorebox
  124. sizeof(NPC_REVIVE_SYNC), // s2c_playerrevive
  125. sizeof(NPC_REQUEST_FAIL), // s2c_requestnpcfail
  126. sizeof(TRADE_APPLY_START_SYNC), // s2c_tradeapplystart
  127. sizeof(tagNewDelRoleResponse), // s3c_rolenewdelresponse
  128. };
  130. using OnlineGameLib::Win32::CPackager;
  131. using OnlineGameLib::Win32::CLibrary;
  132. using OnlineGameLib::Win32::_tstring;
  134. CLibrary CPlayer::s_theRainbowLib( "rainbow.dll" );
  135. // 跟踪角色的名字
  136. extern char *g_pRoleName;
  137. // 跟踪的角色的ID
  138. DWORD CPlayer::m_dwTargetID = ( DWORD )( -1 );
  140. const char *g_szText[] = {
  141. "%s, 你是谁?",
  142. "我们坚决拥护%s!",
  143. "%s, 我爱你! *^_^*",
  144. "%s, 我帅吧?",
  145. "我们去打猪吧? %s",
  146. "%s, 我以后就跟定你了!",
  147. "%s, 我们这是去哪?",
  148. "跟着%s走~~~",
  149. "今天的天气不错嘛! %s",
  150. "%s, 你还好吧?",
  151. "看气色不错啊! %s",
  152. "%s, 我和你去野外转转吧",
  153. "你们怎么这么多废话, 跟着%s走就行了",
  154. "%s, 你带我去哪?",
  155. "呵呵, 这么多人, 好爽啊! %s, 你好!",
  156. "%s, 我这是在哪? -_-b",
  157. "%s, 你觉得我漂亮吗?",
  158. "%s" };
  160. const int g_TextNumber = 17;
  162. struct tagRGB
  163. {
  164. char r;
  165. char g;
  166. char b;
  167. };
  169. #pragma warning( disable : 4305 4309 )
  171. const tagRGB g_rgbText[] = {
  172. { 140, 255, 206 },
  173. { 255, 227, 33 },
  174. { 255, 130, 41 },
  175. { 255, 0, 0 },
  176. { 255, 113, 206 },
  177. { 0, 134, 255 },
  178. { 255, 251, 181 },
  179. { 255, 255, 255 },
  180. { 0, 211, 33 }
  181. };
  183. const int g_rgbNumber = 9;
  185. CPlayer::CPlayer( const char *pSrvIP, unsigned short nPort, const char *pAccName )
  186. : m_hQuit( NULL, true, false, pAccName )
  187. , m_pClientToGateWay( NULL )
  188. , m_pClientToGameSvr(NULL)
  189. , m_sGatewayIP( pSrvIP )
  190. , m_nGatewayPort( nPort )
  191. , m_sAccName( pAccName )
  192. , m_nStatus( enumStartup ) 
  193. , m_dwID( ( DWORD )( -1 ) )
  194. {
  196. srand( (unsigned)time( NULL ) );
  198. m_ptCurPos.x = 0;
  199. m_ptCurPos.y = 0;
  201. m_ptTagPos.x = 0;
  202. m_ptTagPos.y = 0;
  203. }
  205. CPlayer::~CPlayer()
  206. {
  207. Free();
  208. }
  210. //******************************************************************************
  211. /*! fn     void CPlayer::Free()
  212. *   brief  释放和Server的连接
  213. *******************************************************************************/
  214. void CPlayer::Free()
  215. {
  216. // 关闭到网关的连接
  217. ShutdownGateway();
  219. // 关闭到游戏服务器的连接
  220. ShutdownGameSvr();
  222. NotifyRobotManager();
  224. // 退出工作线程
  225. m_hQuit.Set();
  227. if ( !Wait( 500000 ) )
  228. {
  229. Terminate();
  230. }
  231. }
  233. //******************************************************************************
  234. /*! fn     void CPlayer::NotifyRobotManager()
  235. *   brief  通知Robot Manager，Robot做帐号回收
  236. *******************************************************************************/
  237. void CPlayer::NotifyRobotManager()
  238. {
  239. tagRobotQuit RobotQuit;
  241. if(NULL == g_pClientToManager)
  242. return;
  244. RobotQuit.cProtocol = enumRobotQuit;
  245. strcpy(RobotQuit.szAccName, m_sAccName.c_str());
  248. g_pClientToManager->SendPackToServer( &RobotQuit, sizeof( RobotQuit ) );
  249. }
  251. //******************************************************************************
  252. /*! fn     bool CPlayer::ConnectToGateway()
  253. *   brief  连接到网关
  254. *******************************************************************************/
  255. bool CPlayer::ConnectToGateway()
  256. {
  257. pfnCreateClientInterface pClientFactroyFun = ( pfnCreateClientInterface )( s_theRainbowLib.GetProcAddress( _T( "CreateInterface" ) ) );
  259. IClientFactory *pClientFactory = NULL;
  261. if ( pClientFactroyFun && SUCCEEDED( pClientFactroyFun( IID_IClientFactory, reinterpret_cast< void ** >( &pClientFactory ) ) ) )
  262. {
  263. pClientFactory->SetEnvironment( 5, 1024 * 256 );
  265. pClientFactory->CreateClientInterface( IID_IESClient, reinterpret_cast< void ** >( &m_pClientToGateWay ) );
  267. SAFE_RELEASE( pClientFactory );
  268. }
  269. else
  270. return false;
  272. if ( m_pClientToGateWay )
  273. {
  274. m_pClientToGateWay->Startup();
  276. m_pClientToGateWay->RegisterMsgFilter( ( void * )this, ClientEventNotify );
  278. if ( FAILED( m_pClientToGateWay->ConnectTo( m_sGatewayIP.c_str(), m_nGatewayPort ) ) )
  279. {
  280. m_pClientToGateWay->Cleanup();
  282. SAFE_RELEASE( m_pClientToGateWay );
  284. return false;
  285. }
  286. }
  287. else
  288. return false;
  290. // 启动线程
  291. Start();
  293. SetStatus(enumStartup);
  295. return true;
  296. }
  298. //******************************************************************************
  299. /*! fn     bool CPlayer::ReConnectGateway()
  300. *   brief  断开与网关和游戏服务器的连接，并再次建立连接
  301. *******************************************************************************/
  302. bool CPlayer::ReConnectGateway()
  303. {
  304. // 关闭到网关的连接
  305. ShutdownGateway();
  307. // 关闭到游戏服务器的连接
  308. ShutdownGameSvr();
  311. pfnCreateClientInterface pClientFactroyFun = ( pfnCreateClientInterface )( s_theRainbowLib.GetProcAddress( _T( "CreateInterface" ) ) );
  313. IClientFactory *pClientFactory = NULL;
  315. if ( pClientFactroyFun && SUCCEEDED( pClientFactroyFun( IID_IClientFactory, reinterpret_cast< void ** >( &pClientFactory ) ) ) )
  316. {
  317. pClientFactory->SetEnvironment( 5, 1024 * 256 );
  319. pClientFactory->CreateClientInterface( IID_IESClient, reinterpret_cast< void ** >( &m_pClientToGateWay ) );
  321. SAFE_RELEASE( pClientFactory );
  322. }
  323. else
  324. return false;
  326. if ( m_pClientToGateWay )
  327. {
  328. m_pClientToGateWay->Startup();
  330. m_pClientToGateWay->RegisterMsgFilter( ( void * )this, ClientEventNotify );
  332. if ( FAILED( m_pClientToGateWay->ConnectTo( m_sGatewayIP.c_str(), m_nGatewayPort ) ) )
  333. {
  334. m_pClientToGateWay->Cleanup();
  336. SAFE_RELEASE( m_pClientToGateWay );
  338. return false;
  339. }
  340. }
  341. else
  342. return false;
  344. SetStatus(enumStartup);
  346. m_dwID = ( ( DWORD )( -1 ) );
  348. m_ptCurPos.x = 0;
  349. m_ptCurPos.y = 0;
  351. m_ptTagPos.x = 0;
  352. m_ptTagPos.y = 0;
  354. return true;
  355. }
  357. //******************************************************************************
  358. /*! fn     int CPlayer::Run()
  359. *   brief  线程的运行函数
  360. *******************************************************************************/
  361. int CPlayer::Run()
  362. {
  363. // CCriticalSection::Owner locker( g_csPlayerList );
  365. while ( !m_hQuit.Wait( 0 ) )
  366. {
  367. ProcessGateway();
  368. ProcessGameSvr();
  370. ::Sleep( 1 );
  371. }
  373. return 0;
  374. }
  376. //******************************************************************************
  377. /*! fn     void CPlayer::ProcessGateway()
  378. *   brief  处理和网关的通讯
  379. *******************************************************************************/
  380. void CPlayer::ProcessGateway()
  381. {
  382. if(NULL == m_pClientToGateWay)
  383. return;
  385. ProcessGatewayMsg();
  386. ProcessGatewayLoop();
  387. }
  389. //******************************************************************************
  390. /*! fn     void ProcessGatewayMsg()
  391. *   brief  处理网关发来的消息
  392. *******************************************************************************/
  393. void CPlayer::ProcessGatewayMsg()
  394. {
  395. size_t datalength = 0;
  396. const char *pData = ( const char * )( m_pClientToGateWay->GetPackFromServer( datalength ) );
  397. const char *pMsg = pData;
  398. int nMsgLen = 0;
  400. while ( pMsg < ( pData + datalength ) )
  401. {
  402. BYTE cProtocol = CPackager::Peek( pMsg );
  404. switch ( cProtocol )
  405. {
  406. case s2c_login:
  407.  // 需要错误处理
  408. /*
  409. if(!OnAccountLoginNotify(pMsg))
  410. {
  411. Free();
  412. return;
  413. }
  414. */
  415. OnAccountLoginNotify(pMsg);
  416. nMsgLen = *( unsigned short * )( pMsg + sizeof( BYTE ) );
  418. pMsg += sizeof( BYTE ) + nMsgLen;
  419. break;
  421. case s2c_roleserver_getrolelist_result:
  422. nMsgLen = OnGetRoleList(pMsg);
  423. pMsg += nMsgLen;
  424. break;
  426. case s2c_notifyplayerlogin:
  427. OnPlayerLoginNotify(pMsg);
  429. pMsg += sizeof(tagNotifyPlayerLogin);
  431. //ReConnectGateway();
  432. break;
  434. default:
  435. return;
  436. }
  437. }
  438. }
  440. //******************************************************************************
  441. /*! fn     void CPlayer::ProcessGatewayLoop()
  442. *   brief  向网关发送的命令
  443. *******************************************************************************/
  444. void CPlayer::ProcessGatewayLoop()
  445. {
  446. if ( m_nStatus == enumStartup )
  447. {
  448. LoginGateway();
  449. SetStatus(enumConnectToGateway);
  450. }
  451. }
  453. //******************************************************************************
  454. /*! fn     void CPlayer::ProcessGameSvr()
  455. *   brief  处理和GameSvr的通讯
  456. *******************************************************************************/
  457. void CPlayer::ProcessGameSvr()
  458. {
  459. if (NULL == m_pClientToGameSvr)
  460. return;
  462. ProcessGameSvrMsg();
  463. ProcessGameSvrLoop();
  464. }
  466. //******************************************************************************
  467. /*! fn     void CPlayer::ProcessGameSvrMsg()
  468. *   brief  处理和游戏Server发来的消息
  469. *******************************************************************************/
  470. void CPlayer::ProcessGameSvrMsg()
  471. {
  472. size_t datalength = 0;
  473. const char *pData = ( const char * )( m_pClientToGameSvr->GetPackFromServer( datalength ) );
  475. const char *pMsg = pData;
  477. while ( pMsg < ( pData + datalength ) )
  478. {
  479. BYTE cProtocol = CPackager::Peek( pMsg );
  481. switch ( cProtocol )
  482. {
  484. case s2c_syncend:
  485. SyncEnd();
  487. //ReConnectGateway();
  488. break;
  490. case s2c_syncplayer:
  491. break;
  493. case s2c_syncnpc:
  494. {
  495. NPC_SYNC *pPS = ( NPC_SYNC * )pMsg;
  497. if ( pPS && ( '' != g_pRoleName[0] ) )
  498. {
  499. if ( 0 == memcmp( ( const char * )pPS->m_szName, g_pRoleName, sizeof( g_pRoleName ) ) )
  500. {
  501. m_dwTargetID = pPS->ID;
  502. }
  503. }
  504. }
  505. break;
  507. case s2c_synccurplayer:
  508. {
  509. /*
  510. CURPLAYER_SYNC *pCS = (CURPLAYER_SYNC *)pMsg;
  512. if ( pCS )
  513. {
  514. m_dwID = pCS->m_dwID;
  515. }
  516. */
  517. //ReConnectGateway();
  518. }
  519. break;
  521. case s2c_syncnpcmin:
  522. {
  523. if ( ( DWORD )( -1 ) != m_dwID )
  524. {
  525. NPC_NORMAL_SYNC *pNS = (NPC_NORMAL_SYNC *)pMsg;
  527. if ( pNS && pNS->ID == m_dwID )
  528. {
  529. m_ptCurPos.x = pNS->MapX;
  530. m_ptCurPos.y = pNS->MapY;
  531. }
  532. else if ( pNS && pNS->ID == m_dwTargetID )
  533. {
  534. m_ptTagPos.x = pNS->MapX;
  535. m_ptTagPos.y = pNS->MapY;
  536. }
  538. if ( ( DWORD )( -1 ) == m_dwTargetID && '' != g_pRoleName[0] )
  539. {
  540. NPC_REQUEST_COMMAND nrc;
  542. nrc.ProtocolType = c2s_requestnpc;
  543. nrc.ID = pNS->ID;
  545. m_pClientToGameSvr->SendPackToServer( reinterpret_cast< char * >( &nrc ), 
  546. sizeof( NPC_REQUEST_COMMAND ) );
  547. }
  548. }
  549. }
  550. break;
  552. case s2c_syncnpcminplayer:
  553. {
  554. if ( ( DWORD )( -1 ) != m_dwID )
  555. {
  556. NPC_PLAYER_TYPE_NORMAL_SYNC *pNPTNS = (NPC_PLAYER_TYPE_NORMAL_SYNC *)pMsg;
  558. if ( pNPTNS && pNPTNS->m_dwNpcID == m_dwID )
  559. {
  560. m_ptCurPos.x = pNPTNS->m_dwMapX;
  561. m_ptCurPos.y = pNPTNS->m_dwMapY;
  562. }
  563. else if ( pNPTNS && pNPTNS->m_dwNpcID == m_dwTargetID )
  564. {
  565. m_ptTagPos.x = pNPTNS->m_dwMapX;
  566. m_ptTagPos.y = pNPTNS->m_dwMapY;
  567. }
  568. }
  569. }
  570. break;
  572. case s2c_playersendchat:
  574. break;
  576. default:
  577. break;
  578. }
  580. /*
  581.  * Get next protocol
  582.  */
  583. int nProtocolSize = g_nGameProtocolSize[ cProtocol - s2c_clientbegin - 1 ];
  585. if ( nProtocolSize >= 0 )
  586. {
  587. pMsg += nProtocolSize;
  588. }
  589. else
  590. {
  591. unsigned short usMsgSize = *( unsigned short * )( pMsg + sizeof( BYTE ) );
  593. pMsg += sizeof( BYTE ) + usMsgSize;
  594. }
  595. }
  596. }
  598. //******************************************************************************
  599. /*! fn     void CPlayer::ProcessGameSvrLoop()
  600. *   brief  处理向游戏世界发送消息
  601. *******************************************************************************/
  602. void CPlayer::ProcessGameSvrLoop()
  603. {
  604. if( NULL == m_pClientToGameSvr)
  605. return;
  607. if ( rand() % 100 < 5 )
  608. {
  609. char szSpeakText[128];
  611. int nIndex = rand() % g_TextNumber;
  613. sprintf( szSpeakText, ( const char * )g_szText[nIndex], g_pRoleName );
  615. SpeakWord( szSpeakText, strlen( szSpeakText ) );
  617. //ReConnectGateway();
  618. }
  619. else
  620. {
  621. WalkTo();
  622. }
  624. return;
  625. }
  627. //******************************************************************************
  628. /*! fn     void CPlayer::LoginGateway()
  629. *   brief  向网关发出登陆请求
  630. *******************************************************************************/
  631. void CPlayer::LoginGateway()
  632. {
  633. _tstring buffer;
  634. KLoginAccountInfo lai;
  636. ZeroMemory( &lai, sizeof( KLoginAccountInfo ) );
  638. // 填充帐号
  639. size_t used = sizeof( lai.Account );
  640. used = ( used > m_sAccName.length() ) ? m_sAccName.length() : used;
  641. memcpy( lai.Account, m_sAccName.c_str(), used );
  643. // 填充密码
  644. used = sizeof( lai.Password );
  645. used = ( used > m_sAccName.length() ) ? m_sAccName.length() : used;
  646. memcpy( lai.Password, m_sAccName.c_str(), used );
  648. // 其他信息
  649. lai.Param = LOGIN_A_LOGIN | LOGIN_R_REQUEST;
  650. lai.Size = sizeof( lai );
  652. buffer.resize( lai.Size + 1/* protocol id */ );
  654. BYTE bProtocol = c2s_login;
  655. memcpy( const_cast< char * >( buffer.c_str() ), &bProtocol, sizeof( BYTE ) );
  656. memcpy( const_cast< char * >( buffer.c_str() + 1 ), &lai, sizeof( lai ) );
  658. // 向网关发送请求
  659. m_pClientToGateWay->SendPackToServer( buffer.c_str(), buffer.size() );
  661. return;
  662. }
  664. // 
  665. //******************************************************************************
  666. /*! fn     bool CPlayer::OnAccountLoginNotify(const char* pMsg)
  667. *   brief  处理网关发回的帐号登陆请求的结果
  668. *******************************************************************************/
  669. bool CPlayer::OnAccountLoginNotify(const char* pMsg)
  670. {
  671. KLoginAccountInfo *pLAI = ( KLoginAccountInfo * )( ( const BYTE * )pMsg + 1 );
  672. bool bRet = false;
  674. if ( ( pLAI->Param | LOGIN_A_LOGIN ) &&
  675.  0 == m_sAccName.compare( pLAI->Account ) &&
  676.  0 == m_sAccName.compare( pLAI->Password ) )
  677. {
  678. if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_ACCOUNT_OR_PASSWORD_ERROR )
  679. {
  680. bRet = false;
  681. //::MessageBox(NULL, "An incorrect account or password!", "Error", MB_OK);
  682. }
  683. else if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_FAILED )
  684. {
  685. bRet = false;
  686. //::MessageBox(NULL, "Login failed!", "Error", MB_OK);
  687. }
  688. else if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_ACCOUNT_EXIST )
  689. {
  690. bRet = false;
  691. //::MessageBox(NULL, "Login failed! your accout was existed!", m_sAccName.c_str(), MB_OK);
  692. }
  693. else if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_TIMEOUT )
  694. {
  695. bRet = false;
  696. //::MessageBox(NULL, "Login failed! no money!", "Error", MB_OK);
  697. }
  698. else if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_SUCCESS )
  699. {
  700. bRet = true;
  701. }
  702. }
  703. return bRet;
  704. }
  706. //******************************************************************************
  707. /*! fn     int CPlayer::OnGetRoleListRole(const char* pMsg)
  708. *   brief  响应网关发来的消息，选择角色列表
  709. *******************************************************************************/
  710. int CPlayer::OnGetRoleList(const char* pMsg)
  711. {
  712. int nRoleCount = 0;
  713. int nSelRoleIndex = 0;
  715. const S3DBI_RoleBaseInfo *pRoleList = NULL;
  716. TProcessData *pPA = ( TProcessData * )pMsg;
  718. nRoleCount = *( char * )( pPA->pDataBuffer );
  720. if( nRoleCount > 0)
  721. {
  722. pRoleList = ( const S3DBI_RoleBaseInfo * )( ( const char * )( pPA->pDataBuffer ) + 1/* sizeof( char ) */ );
  723. const size_t datalength = sizeof( S3DBI_RoleBaseInfo ) * nRoleCount;
  725. /*
  726.  * Send this info to gateway
  727.  */
  728. tagDBSelPlayer tDBSP;
  729. tDBSP.cProtocol = c2s_dbplayerselect;
  731. size_t nRoleNameLen = strlen( pRoleList[nSelRoleIndex].szName );
  732. memcpy( tDBSP.szRoleName, pRoleList[nSelRoleIndex].szName, nRoleNameLen );
  733. tDBSP.szRoleName[nRoleNameLen] = '';
  735. m_pClientToGateWay->SendPackToServer( &tDBSP, sizeof( tagDBSelPlayer ) );
  736. }
  738. int nMsgLen = sizeof(TProcessData) + pPA->nDataLen - 1;
  739. return nMsgLen;
  740. }
  742. //******************************************************************************
  743. /*! fn     bool CPlayer::OnPlayerLoginNotify(const char* pMsg)
  744. *   brief  处理网关发来的消息，响应角色进入游戏的通告
  745. *******************************************************************************/
  746. bool CPlayer::OnPlayerLoginNotify(const char* pMsg)
  747. {
  748. tagNotifyPlayerLogin *pNPL = ( tagNotifyPlayerLogin * )pMsg;
  750. const char *pIPAddr = OnlineGameLib::Win32::net_ntoa( pNPL->nIPAddr );
  752. return ConnectToGameSvr( pIPAddr, pNPL->nPort, pNPL->guid );
  753. }
  755. //******************************************************************************
  756. /*! fn     bool CPlayer::ConnectToGameSvr( const char *pIPAddr, unsigned short nPort, GUID &guid )
  757. *   brief  处理网关发来的消息，客户连接到网关
  758. *******************************************************************************/
  759. bool CPlayer::ConnectToGameSvr( const char *pIPAddr, unsigned short nPort, GUID &guid )
  760. {
  761. pfnCreateClientInterface pFactroyFun = ( pfnCreateClientInterface )( s_theRainbowLib.GetProcAddress( "CreateInterface" ) );
  763. IClientFactory *pClientFactory = NULL;
  765. if ( pFactroyFun && SUCCEEDED( pFactroyFun( IID_IClientFactory, reinterpret_cast< void ** >( &pClientFactory ) ) ) )
  766. {
  767. pClientFactory->SetEnvironment( 50, 1024 * 16 );
  769. pClientFactory->CreateClientInterface( IID_IESClient, reinterpret_cast< void ** >( &m_pClientToGameSvr ) );
  771. pClientFactory->Release();
  772. }
  774. if ( !m_pClientToGameSvr )
  775. {
  776. ::MessageBox(NULL, "Initialization failed! Don't find a correct rainbow.dll", "Error", MB_OK);
  778. return false;
  779. }
  781. /*
  782.  * Create a connection
  783.  */
  784. m_pClientToGameSvr->Startup();
  786. //pGameSvrClient->RegisterMsgFilter( reinterpret_cast< void * >( pClient ), NULL );
  788. if ( FAILED( m_pClientToGameSvr->ConnectTo( pIPAddr, nPort ) ) )
  789. {
  790. //::MessageBox(NULL, "Connection failed! Don't connect to game server.", "Error", MB_OK);
  792. return false;
  793. }
  795. tagLogicLogin ll;
  797. ll.cProtocol = c2s_logiclogin;
  798. memcpy( &ll.guid, &guid, sizeof( GUID ) );
  800. m_pClientToGameSvr->SendPackToServer( &ll, sizeof( tagLogicLogin ) );
  802. ShutdownGateway();
  804. return true;
  805. }
  807. //******************************************************************************
  808. /*! fn     void CPlayer::SyncEnd()
  809. *   brief  响应游戏服务器发来的消息，初始同步结束
  810. * SyncWorld, SyncNpc, SyncPlayer, SyncCurPlayer, SyncCurPlayerSkill
  811. * SyncEnd, SyncNpcMinPlayer
  812. *******************************************************************************/
  813. void CPlayer::SyncEnd()
  814. {
  815. SetStatus( enumPlayGame );
  817. BYTE cSyscEndFlag = c2s_syncend;
  819. m_pClientToGameSvr->SendPackToServer( reinterpret_cast< char * >( &cSyscEndFlag ), sizeof( BYTE ) );
  820. }
  822. //******************************************************************************
  823. /*! fn     void CPlayer::WalkTo()
  824. *   brief  机器人行走
  825. *******************************************************************************/
  826. void CPlayer::WalkTo()
  827. {
  828. if ( ( DWORD )( -1 ) != m_dwTargetID && m_ptTagPos.x && m_ptTagPos.y )
  829. {
  830. if ( abs( m_ptCurPos.x - m_ptTagPos.x ) > 5 * 32 ||
  831. abs( m_ptCurPos.y - m_ptTagPos.y ) > 6 * 32 )
  832. {
  833. NPC_WALK_COMMAND nwc;
  835. nwc.ProtocolType = c2s_npcwalk;
  836. nwc.nMpsX = m_ptTagPos.x;
  837. nwc.nMpsY = m_ptTagPos.y;
  839. m_pClientToGameSvr->SendPackToServer( reinterpret_cast< BYTE * >( &nwc ), sizeof( nwc ) );
  840. }
  841. }
  842. }
  844. //******************************************************************************
  845. /*! fn     void CPlayer::SpeakWord( const char *pText, size_t size  )
  846. *   brief  随机聊天
  847. *******************************************************************************/
  848. void CPlayer::SpeakWord( const char *pText, size_t size /*0*/ )
  849. {
  850. if ( NULL == pText || 0 == size )
  851. {
  852. return;
  853. }
  855. size_t dataLength = size;
  857. if ( 0 == dataLength )
  858. {
  859. dataLength = strlen( pText );
  860. }
  862. PLAYER_SEND_CHAT_COMMAND pscc;
  864. pscc.ProtocolType = c2s_playersendchat;
  865. pscc.m_btCurChannel = 1; // To all
  866. pscc.m_btType = 0; // MSG_G_CHAT
  868. pscc.m_dwTargetID = 0;
  869. pscc.m_nTargetIdx = 0;
  870. pscc.m_btChatPrefixLen = 4;
  872. pscc.m_szSentence[0] = 0x2;
  874. int nIndex = rand() % g_rgbNumber;
  876. pscc.m_szSentence[1] = g_rgbText[nIndex].r;
  877. pscc.m_szSentence[2] = g_rgbText[nIndex].g;
  878. pscc.m_szSentence[3] = g_rgbText[nIndex].b;
  880. memcpy( &( pscc.m_szSentence[4] ), pText, strlen( pText ) );
  881. pscc.m_wSentenceLen = dataLength;
  883. pscc.m_wLength = 
  884. dataLength + 4 +
  885. sizeof( PLAYER_SEND_CHAT_COMMAND ) - 
  886. sizeof( pscc.m_szSentence ) - 
  887. sizeof( BYTE );
  889. m_pClientToGameSvr->SendPackToServer( &pscc, pscc.m_wLength + sizeof( BYTE ) );
  890. }
  892. //******************************************************************************
  893. /*! fn     void ShutdownGateway()
  894. *   brief  切断与网关的连接
  895. *******************************************************************************/
  896. void CPlayer::ShutdownGateway()
  897. {
  898. // 关闭到网关的连接
  899. if ( m_pClientToGateWay )
  900. {
  901. m_pClientToGateWay->Cleanup();
  903. SAFE_RELEASE( m_pClientToGateWay );
  904. }
  905. }
  907. //******************************************************************************
  908. /*! fn     void ShutdownGateway()
  909. *   brief  切断与网关的连接
  910. *******************************************************************************/
  911. void CPlayer::ShutdownGameSvr()
  912. {
  913. // 关闭到网关的连接
  914. if ( m_pClientToGameSvr )
  915. {
  916. m_pClientToGameSvr->Cleanup();
  918. SAFE_RELEASE( m_pClientToGameSvr );
  919. }
  920. }
  922. void __stdcall CPlayer::ClientEventNotify(
  923. LPVOID lpParam,
  924. const unsigned long &ulnEventType )
  925. {
  926. CPlayer *pPlayer = ( CPlayer * )lpParam;
  928. ASSERT( pPlayer );
  930. try
  931. {
  932. pPlayer->_ClientEventNotify( ulnEventType );
  933. }
  934. catch(...)
  935. {
  936. ::MessageBeep( -1 );
  937. }
  938. }
  940. void CPlayer::_ClientEventNotify( const unsigned long &ulnEventType )
  941. {
  942. switch( ulnEventType )
  943. {
  944. case enumServerConnectCreate:
  946. ::MessageBeep( -1 );
  948. break;
  950. case enumServerConnectClose:
  952. ::MessageBeep( -1 );
  954. break;
  955. }
  956. }