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

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

模拟服务器

开发平台：

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. *******************************************************************************/
  12. #pragma once
  14. //#include <Windows.h>
  15. #include "stdafx.h"
  16. #include <objbase.h>
  17. #include <initguid.h>
  18. #include "Win32Exception.h"
  19. //#include "KWin32.h"
  20. // that fucking macro defined here
  21. #include "Player.h"
  22. //#include "....Sword3PaySysS3AccServerAccountLoginDef.h"
  23. #include "....s3clientloginLoginDef.h"
  24. //#include "....CoresrcMsgGenreDef.h"
  25. #include "KProtocolDef.h"
  26. #include "KRelayProtocol.h"
  27. #include "KProtocol.h"
  28. #include "md5.h"
  30. using namespace OnlineGameLib::Win32;
  32. extern int g_nLoginLogoutFlag;
  33. extern int g_nDeleteRoleFlag;
  35. extern int g_nAddRoleFlag;
  36. extern int g_nAddRoleGender;
  37. extern int g_nAddRoleSeries;
  38. extern int g_nAddRolePlaceID;
  39. extern char g_szGMCommandList[MAX_GM_COUNT][MAX_GM_SIZE];
  40. //#define _DETAIL_PROTOCOL_DEBUG_
  41. //#define _GENERAL_DEBUG_
  43. CCriticalSection g_csPlayerList;
  44. //extern int g_nProtocolSize[MAX_PROTOCOL_NUM];
  45. //#define g_nGameProtocolSize g_nProtocolSize
  46. int g_nGameProtocolSize[MAX_PROTOCOL_NUM] = 
  47. {
  48. -1, // s2c_login,
  49. -1, // s2c_logout,
  50. sizeof(BYTE), // s2c_syncend,
  51. sizeof(CURPLAYER_SYNC), // s2c_synccurplayer,
  52. -1, // s2c_synccurplayerskill
  53. sizeof(CURPLAYER_NORMAL_SYNC),// s2c_synccurplayernormal
  54. -1, // s2c_newplayer,
  55. -1, // s2c_removeplayer,
  56. sizeof(WORLD_SYNC), // s2c_syncworld,
  57. sizeof(PLAYER_SYNC), // s2c_syncplayer,
  58. sizeof(PLAYER_NORMAL_SYNC), // s2c_syncplayermin,
  59. -1, //sizeof(NPC_SYNC), // s2c_syncnpc,
  60. sizeof(NPC_NORMAL_SYNC), // s2c_syncnpcmin,
  61. sizeof(NPC_PLAYER_TYPE_NORMAL_SYNC), // s2c_syncnpcminplayer,
  63. -1,//sizeof(OBJ_ADD_SYNC), // s2c_objadd,
  64. sizeof(OBJ_SYNC_STATE), // s2c_syncobjstate,
  65. sizeof(OBJ_SYNC_DIR), // s2c_syncobjdir,
  66. sizeof(OBJ_SYNC_REMOVE), // s2c_objremove,
  67. sizeof(OBJ_SYNC_TRAP_ACT), // s2c_objTrapAct,
  69. sizeof(NPC_REMOVE_SYNC), // s2c_npcremove,
  70. sizeof(NPC_WALK_SYNC), // s2c_npcwalk,
  71. sizeof(NPC_RUN_SYNC), // s2c_npcrun,
  72. -1, // s2c_npcattack,
  73. -1, // s2c_npcmagic,
  74. sizeof(NPC_JUMP_SYNC), // s2c_npcjump,
  75. -1, // s2c_npctalk,
  76. sizeof(NPC_HURT_SYNC), // s2c_npchurt,
  77. sizeof(NPC_DEATH_SYNC), // s2c_npcdeath,
  78. sizeof(NPC_CHGCURCAMP_SYNC),// s2c_npcchgcurcamp,
  79. sizeof(NPC_CHGCAMP_SYNC), // s2c_npcchgcamp,
  80. sizeof(NPC_SKILL_SYNC), // s2c_skillcast,
  81. -1, // s2c_playertalk,
  82. sizeof(PLAYER_EXP_SYNC), // s2c_playerexp,
  84. sizeof(PLAYER_SEND_TEAM_INFO), // s2c_teaminfo,
  85. sizeof(PLAYER_SEND_SELF_TEAM_INFO), // s2c_teamselfinfo,
  86. sizeof(PLAYER_APPLY_TEAM_INFO_FALSE), // s2c_teamapplyinfofalse,
  87. sizeof(PLAYER_SEND_CREATE_TEAM_SUCCESS),// s2c_teamcreatesuccess,
  88. sizeof(PLAYER_SEND_CREATE_TEAM_FALSE), // s2c_teamcreatefalse,
  89. sizeof(PLAYER_TEAM_OPEN_CLOSE), // s2c_teamopenclose,
  90. sizeof(PLAYER_APPLY_ADD_TEAM), // s2c_teamgetapply,
  91. sizeof(PLAYER_TEAM_ADD_MEMBER), // s2c_teamaddmember,
  92. sizeof(PLAYER_LEAVE_TEAM), // s2c_teamleave,
  93. sizeof(PLAYER_TEAM_CHANGE_CAPTAIN), // s2c_teamchangecaptain,
  94. sizeof(PLAYER_FACTION_DATA), // s2c_playerfactiondata,
  95. sizeof(PLAYER_LEAVE_FACTION), // s2c_playerleavefaction,
  96. sizeof(PLAYER_FACTION_SKILL_LEVEL), // s2c_playerfactionskilllevel,
  97. -1,//sizeof(PLAYER_SEND_CHAT_SYNC), // s2c_playersendchat,
  98. sizeof(PLAYER_LEAD_EXP_SYNC), // s2c_playersyncleadexp
  99. sizeof(PLAYER_LEVEL_UP_SYNC), // s2c_playerlevelup
  100. sizeof(PLAYER_TEAMMATE_LEVEL_SYNC), // s2c_teammatelevel
  101. sizeof(PLAYER_ATTRIBUTE_SYNC), // s2c_playersyncattribute
  102. sizeof(PLAYER_SKILL_LEVEL_SYNC), // s2c_playerskilllevel
  103. sizeof(ITEM_SYNC), // s2c_syncitem
  104. sizeof(ITEM_REMOVE_SYNC), // s2c_removeitem
  105. sizeof(PLAYER_MONEY_SYNC), // s2c_syncmoney
  106. sizeof(PLAYER_MOVE_ITEM_SYNC), // s2c_playermoveitem
  107. -1, // s2c_playershowui
  108. sizeof(CHAT_APPLY_ADD_FRIEND_SYNC), // s2c_chatapplyaddfriend
  109. sizeof(CHAT_ADD_FRIEND_SYNC), // s2c_chataddfriend
  110. -1,//sizeof(CHAT_REFUSE_FRIEND_SYNC), // s2c_chatrefusefriend
  111. sizeof(CHAT_ADD_FRIEND_FAIL_SYNC), // s2c_chataddfriendfail
  112. sizeof(CHAT_LOGIN_FRIEND_NONAME_SYNC), // s2c_chatloginfriendnoname
  113. -1,//sizeof(CHAT_LOGIN_FRIEND_NAME_SYNC), // s2c_chatloginfriendname
  114. sizeof(CHAT_ONE_FRIEND_DATA_SYNC), // s2c_chatonefrienddata
  115. sizeof(CHAT_FRIEND_ONLINE_SYNC), // s2c_chatfriendinline
  116. sizeof(CHAT_DELETE_FRIEND_SYNC), // s2c_chatdeletefriend
  117. sizeof(CHAT_FRIEND_OFFLINE_SYNC), // s2c_chatfriendoffline
  118. sizeof(ROLE_LIST_SYNC), // s2c_syncrolelist
  119. sizeof(TRADE_CHANGE_STATE_SYNC), // s2c_tradechangestate
  120. -1, // NPC_SET_MENU_STATE_SYNC    s2c_npcsetmenustate
  121. sizeof(TRADE_MONEY_SYNC), // s2c_trademoneysync
  122. sizeof(TRADE_DECISION_SYNC), // s2c_tradedecision
  123. -1, // sizeof(CHAT_SCREENSINGLE_ERROR_SYNC)s2c_chatscreensingleerror
  124. sizeof(NPC_SYNC_STATEINFO), // s2c_syncnpcstate,
  125. -1, // sizeof(TEAM_INVITE_ADD_SYNC)    s2c_teaminviteadd
  126. sizeof(TRADE_STATE_SYNC), // s2c_tradepressoksync
  127. sizeof(PING_COMMAND), // s2c_ping
  128. sizeof(NPC_SIT_SYNC), // s2c_npcsit
  129. sizeof(SALE_BOX_SYNC), // s2c_opensalebox
  130. sizeof(NPC_SKILL_SYNC), // s2cDirectlyCastSkill
  131. -1, // s2c_msgshow
  132. -1, // s2c_syncstateeffect
  133. sizeof(BYTE), // s2c_openstorebox
  134. sizeof(NPC_REVIVE_SYNC), // s2c_playerrevive
  135. sizeof(NPC_REQUEST_FAIL), // s2c_requestnpcfail
  136. sizeof(TRADE_APPLY_START_SYNC), // s2c_tradeapplystart
  137. sizeof(tagNewDelRoleResponse), // s2c_rolenewdelresponse
  138. sizeof(ITEM_AUTO_MOVE_SYNC), // s2c_ItemAutoMove
  139. sizeof(BYTE), // s2c_itemexchangefinish
  140. sizeof(SYNC_WEATHER), // s2c_changeweather
  141. sizeof(PK_NORMAL_FLAG_SYNC), // s2c_pksyncnormalflag
  142. -1,//sizeof(PK_ENMITY_STATE_SYNC), // s2c_pksyncenmitystate
  143. -1,//sizeof(PK_EXERCISE_STATE_SYNC), // s2c_pksyncexercisestate
  144. sizeof(PK_VALUE_SYNC), // s2c_pksyncpkvalue
  145. sizeof(NPC_SLEEP_SYNC), // s2c_npcsleepmode
  146. sizeof(VIEW_EQUIP_SYNC), // s2c_viewequip
  147. sizeof(LADDER_DATA), // s2c_ladderresult
  148. -1, // s2c_ladderlist
  149. sizeof(TONG_CREATE_SYNC), // s2c_tongcreate
  150. sizeof(PING_COMMAND), // s2c_replyclientping
  151. sizeof(NPC_GOLD_CHANGE_SYNC), // s2c_npcgoldchange
  152. sizeof(ITEM_DURABILITY_CHANGE), // s2c_itemdurabilitychange
  153. };
  155. using OnlineGameLib::Win32::CPackager;
  156. using OnlineGameLib::Win32::CLibrary;
  157. using OnlineGameLib::Win32::_tstring;
  159. #if defined _USE_RAINBOW
  160. CLibrary CPlayer::s_theRainbowLib( "rainbow.dll" );
  161. #else
  162. //#include "IClient.h"
  163. #endif
  164. // 跟踪角色的名字
  165. extern char *g_pRoleName;
  166. // 跟踪的角色的ID
  167. DWORD CPlayer::m_dwTargetID = ( DWORD )( -1 );
  169. // The timer of chat.. 
  170. // the value is 0.8 * 50
  171. const int g_nChatTimer = 40;
  173. const char *g_szText[] = {
  174. "%s, who are you??",
  175. "Shut up your fucking mouth, %s!",
  176. "%s, I love you..",
  177. "Oh, %s, what a fucking day today, isn't it??",
  178. "you looks like a white, fat, stupid pig, %s, I swear.",
  179. "Michael Jackson is the king of POP",
  180. "Michael Jordan is the king of Ball",
  181. "who knows what dangdangdangdangdangdang, dangdangdangdangdangdang is?",
  182. "dangdangdangdangdangdang, dangdangdangdangdangdang is ...。。。oooOOO Only you, can get the bible with me.",
  183. "Only you, can kill the ghost.",
  184. "Only you, can protect me, prevent the fishes eatting me....",
  185. "%s, Do you have any brothers? Please speak, I just wanna get a friend before death..",
  186. "We are both Athena's saint. We should fight for the love and justice of the world.",
  187. "%s, What fucking you are doing??",
  188. "Oh, shit!! %s, I meet Michael Jordan today, ohhhhh!",
  189. "Note: Don't trust benchmarks more than you trust politicians. Trust my benchmarks even less.",
  190. "%s, I think it's time for sleeping.",
  191. "Linus Benedict Torvalds: Read The Fucking Source Code!" 
  192. };
  194. const int g_TextNumber = 17;
  196. struct tagRGB
  197. {
  198. char r;
  199. char g;
  200. char b;
  201. };
  203. #pragma warning( disable : 4305 4309 )
  205. const tagRGB g_rgbText[] = {
  206. { 140, 255, 206 },
  207. { 255, 227, 33 },
  208. { 255, 130, 41 },
  209. { 255, 0, 0 },
  210. { 255, 113, 206 },
  211. { 0, 134, 255 },
  212. { 255, 251, 181 },
  213. { 255, 255, 255 },
  214. { 0, 211, 33 }
  215. };
  217. const int g_rgbNumber = 9;
  219. CPlayer::CPlayer( const char *pSrvIP, unsigned short nPort, const char *pAccName )
  220. : m_hQuit( NULL, true, false, pAccName )
  221. , m_pClientToGateWay( NULL )
  222. , m_pClientToGameSvr(NULL)
  223. , m_sGatewayIP( pSrvIP )
  224. , m_nGatewayPort( nPort )
  225. , m_sAccName( pAccName )
  226. , m_nStatus( enumStartup ) 
  227. , m_dwID( ( DWORD )( -1 ) )
  228. {
  229.     m_pbyRoleMsg = NULL;
  231. m_ptCurPos.x = 0;
  232. m_ptCurPos.y = 0;
  234. m_ptTagPos.x = 0;
  235. m_ptTagPos.y = 0;
  237.     m_RandValue = rand();
  239.     m_uGameServerLoopCount = 0;
  241.     m_nShutDownGatewayFlag = false;
  243. // The initialization of all flags goes here.
  244. // flying comment
  245. m_nMoveRange = 800;
  246. m_nFlgSetPos = 0;
  247. m_nFlgSetAttack = 0;
  248. m_nFlgSilence = 0;
  249. m_nFlgChatTimer = 0;
  250. m_nFlgGMDone = false;
  252. m_nChatTimer = 0;
  253. m_dwNpcID = 0;
  254. m_nFlgAI = 0;
  255. m_nDoing = 0;
  256. m_nTeamLeader = 0;
  257. memset(&m_ptTarget, 0, sizeof(POINT));
  258. memset(&m_ptBirth, 0, sizeof(POINT));
  259. memset(&m_ptOffset, 0, sizeof(POINT));
  260. memset(&m_player, 0, sizeof(PLAYER_INFO));
  261. memset(szGMCommand, 0, 128);
  262. // 机器人运动偏移量
  263. m_ptOffset.x = 500;
  264. m_ptOffset.y = 300;
  265. m_nGMChannelID = 0;
  266. m_nCurChannel = 0;
  267. // ext size
  268. g_nGameProtocolSize[s2c_extend - s2c_clientbegin - 1] = -1;
  269. g_nGameProtocolSize[s2c_extendchat - s2c_clientbegin - 1] = -1;
  270. g_nGameProtocolSize[s2c_extendfriend - s2c_clientbegin - 1] = -1;
  271. g_nGameProtocolSize[s2c_extendtong - s2c_clientbegin - 1] = -1;
  272. }
  274. CPlayer::~CPlayer()
  275. {
  276. Free();
  277. }
  279. //******************************************************************************
  280. /*! fn     void CPlayer::Free()
  281. *   brief  释放和Server的连接
  282. *******************************************************************************/
  283. void CPlayer::Free()
  284. {
  285. // 关闭到网关的连接
  286. ShutdownGateway();
  288. // 关闭到游戏服务器的连接
  289. ShutdownGameSvr();
  291. // 退出工作线程
  292. m_hQuit.Set();
  294.     if (m_pbyRoleMsg)
  295.     {
  296.         delete []m_pbyRoleMsg;
  297.         m_pbyRoleMsg = NULL;
  298.     }
  300.     try
  301.     {
  302.     if ( !Wait( 500000 ) )
  303.     {
  304.     Terminate();
  305.     }
  306.     }
  307.     catch (...) 
  308.     {
  309.     }
  310. }
  312. //******************************************************************************
  313. /*! fn     bool CPlayer::ConnectToGateway()
  314. *   brief  连接到网关
  315. *******************************************************************************/
  316. bool CPlayer::ConnectToGateway()
  317. {
  318. #if defined _USE_RAINBOW
  319. pfnCreateClientInterface pClientFactroyFun = ( pfnCreateClientInterface )( s_theRainbowLib.GetProcAddress( _T( "CreateInterface" ) ) );
  321. IClientFactory *pClientFactory = NULL;
  323. if ( pClientFactroyFun && SUCCEEDED( pClientFactroyFun( IID_IClientFactory, reinterpret_cast< void ** >( &pClientFactory ) ) ) )
  324. {
  325. pClientFactory->SetEnvironment( 1024 * 256 );
  327. pClientFactory->CreateClientInterface( IID_IESClient, reinterpret_cast< void ** >( &m_pClientToGateWay ) );
  329. SAFE_RELEASE( pClientFactory );
  330. }
  331. else
  332. return false;
  333. #else
  334. // zcj's client goes here.
  335. #endif
  336. if ( m_pClientToGateWay )
  337. {
  338. int nRetCode = 0;
  339. nRetCode = m_pClientToGateWay->Startup();
  340. #if defined _USE_RAINBOW
  341. m_pClientToGateWay->RegisterMsgFilter( ( void * )this, ClientEventNotify );
  342. #else
  343. //typedef void (*CALLBACK_CLIENT_EVENT )(void *lpParam, const unsigned long &ulnEventType);
  344. m_pClientToGateWay->RegisterMsgFilter( ( void * )this, ClientEventNotify );
  345. #endif
  346. if ( FAILED( m_pClientToGateWay->ConnectTo( m_sGatewayIP.c_str(), m_nGatewayPort ) ) )
  347. {
  348. m_pClientToGateWay->Cleanup();
  350. SAFE_RELEASE( m_pClientToGateWay );
  352. return false;
  353. }
  354. }
  355. else
  356. return false;
  358. // 启动线程
  359. Start();
  361. SetStatus(enumStartup);
  363. return true;
  364. }
  366. //******************************************************************************
  367. /*! fn     int CPlayer::Run()
  368. *   brief  线程的运行函数
  369. *******************************************************************************/
  371. static long gs_lRandSeed = time(NULL);
  373. int CPlayer::Run()
  374. {
  375. // CCriticalSection::Owner locker( g_csPlayerList );
  376.     srand(InterlockedIncrement(&gs_lRandSeed));
  377. while ( !m_hQuit.Wait( 0 ) )
  378. {
  379. m_nChatTimer++;
  380. ProcessGateway();
  381. ProcessGameSvr();
  382. // Keep the loop per-second to exactly 20 times.
  383. ::Sleep( 50 );
  384. // hardware overflow? what a fucking thing!!
  385. if (m_nChatTimer > g_nChatTimer * 1000)
  386. m_nChatTimer = 0;
  387. }
  389. return 0;
  390. }
  392. //******************************************************************************
  393. /*! fn     void CPlayer::ProcessGateway()
  394. *   brief  处理和网关的通讯
  395. *******************************************************************************/
  396. void CPlayer::ProcessGateway()
  397. {
  398. if (NULL == m_pClientToGateWay)
  399. {
  400. return;
  401. }
  403. ProcessGatewayMsg();
  404. ProcessGatewayLoop();
  405. }
  407. //******************************************************************************
  408. /*! fn     void ProcessGatewayMsg()
  409. *   brief  处理网关发来的消息
  410. *******************************************************************************/
  411. void CPlayer::ProcessGatewayMsg()
  412. {
  413.     if (GetStatus() == enumExitGame)
  414.         return;
  416. size_t datalength = 0;
  417.     bool        bRetCode    = false;
  418. const char *pData = ( const char * )( m_pClientToGateWay->GetPackFromServer( datalength ) );
  419. const char *pMsg = pData;
  420. int nMsgLen = 0;
  422.     // for debug
  423. //    if (datalength > 0) {
  424. //        for (int i = 0; i < datalength; i++)
  425. //            printf("%d_", pData[i]);
  426. //        printf("n");
  427. //    }
  428. // printf("The length of fucking data: %dn", datalength);
  429. while ( pMsg < ( pData + datalength ) )
  430.     {
  431.         if (GetStatus() == enumExitGame)
  432.             return;
  434. BYTE cProtocol = CPackager::Peek( pMsg );
  435. switch ( cProtocol )
  436. {
  437. case s2c_login:
  438.  // 需要错误处理
  439. bRetCode = OnAccountLoginNotify(pMsg);
  440.             if (!bRetCode)
  441.             {
  442.                 Sleep(rand() % 100);
  443.                 SetStatus(enumExitGame);
  444.             }
  446. nMsgLen = *( unsigned short * )( pMsg + sizeof( BYTE ) );
  448. pMsg += sizeof( BYTE ) + nMsgLen;
  449. break;
  451. case s2c_roleserver_getrolelist_result:
  452.         {
  453.             printf("%s: Getrolelist Result ok!n", m_sAccName.c_str());
  454.             
  455.             // Save RoleMsg for next process
  456.             if (m_pbyRoleMsg)
  457.             {
  458.                 delete []m_pbyRoleMsg;
  459.                 m_pbyRoleMsg = NULL;
  460.             }
  462.         const S3DBI_RoleBaseInfo *pRoleList = NULL;
  463.         TProcessData *pPA = ( TProcessData * )pMsg;
  465.          nMsgLen = sizeof(TProcessData) + pPA->nDataLen - 1;
  467.             m_pbyRoleMsg = new unsigned char [0x1000];
  468.             if (!m_pbyRoleMsg)
  469.             {
  470.                 Sleep(rand() % 100);
  471.                 SetStatus(enumExitGame);
  472.                 break;
  473.             }
  475.             memcpy(m_pbyRoleMsg, pMsg, nMsgLen);
  477. nMsgLen = OnGetRoleList((char *)m_pbyRoleMsg);
  478. pMsg += nMsgLen;
  481.             //Sleep(rand() % 10);
  482.             //SetStatus(enumExitGame);
  483. break;
  484.         }
  486.         //case s2c_logout:
  487.         //    OnAccountLogoutNotify(pMsg);
  488.         //    break;
  490. case s2c_rolenewdelresponse:
  491.         {
  492. tagNewDelRoleResponse* pResponse = (tagNewDelRoleResponse*)pMsg;
  494.             printf("%s: Rolenewdelresponse Result %d!n", m_sAccName.c_str(), pResponse->bSucceeded);
  495.             //if (!pResponse->bSucceeded)
  496.             //{
  497.             //  
  498.             //}
  500.             pMsg += sizeof(tagNewDelRoleResponse);
  502.             if (g_nAddRoleFlag || g_nDeleteRoleFlag)
  503.             {
  504.             const S3DBI_RoleBaseInfo *pRoleList = NULL;
  505.             TProcessData *pPA = ( TProcessData * )m_pbyRoleMsg;
  506.     
  507.              int nRoleCount = *( char * )( pPA->pDataBuffer );
  508.                
  509.                 if (g_nDeleteRoleFlag)
  510.                 {
  511.                     if (nRoleCount > 0)
  512.                     {
  513.                         OnGetRoleList((char *)m_pbyRoleMsg);
  514.                         break;
  515.                     }
  516.                 }
  517.                 else if (g_nAddRoleFlag)
  518.                 {
  519.                     if (nRoleCount < 3)
  520.                     {
  521.                         OnGetRoleList((char *)m_pbyRoleMsg);
  522.                         break;
  523.                     }
  524.                 }
  525.             }
  527.             Sleep(rand() % 100);
  528.             SetStatus(enumExitGame);
  530.             break;
  531.         }
  533. case s2c_notifyplayerlogin:
  534.             
  535.             // 暂时不测试登入服务器的动作
  536.             //Sleep(rand() % 100);
  537.             //SetStatus(enumExitGame);
  538.             printf("%s: Notifyplayerlogin...n", m_sAccName.c_str());
  539.             
  540.             bRetCode = OnPlayerLoginNotify(pMsg);
  541.             if (!bRetCode)
  542.             {
  543.                 Sleep(rand() % 100);
  544.                 SetStatus(enumExitGame);
  545.             }
  547.             ShutdownGateway();
  549.             if (GetStatus() == enumExitGame)
  550.                 return;
  552. pMsg += sizeof(tagNotifyPlayerLogin);
  553. break;
  555. default:
  556.             Sleep(rand() % 100);
  557.             SetStatus(enumExitGame);
  558. return;
  559. }
  560. }
  561. }
  563. //******************************************************************************
  564. /*! fn     void CPlayer::ProcessGatewayLoop()
  565. *   brief  向网关发送的命令
  566. *******************************************************************************/
  567. void CPlayer::ProcessGatewayLoop()
  568. {
  569. if ( m_nStatus == enumStartup )
  570. {
  571. LoginGateway();
  572. SetStatus(enumConnectToGateway);
  573. }
  574. }
  576. //******************************************************************************
  577. /*! fn     void CPlayer::ProcessGameSvr()
  578. *   brief  处理和GameSvr的通讯
  579. *******************************************************************************/
  580. void CPlayer::ProcessGameSvr()
  581. {
  582. if (NULL == m_pClientToGameSvr)
  583. {
  584. return;
  585. }
  586. // Bug is in "ProcessGameSvrMsg"
  587. ProcessGameSvrMsg();
  588. ProcessGameSvrLoop();
  589. }
  591. //******************************************************************************
  592. /*! fn     void CPlayer::ProcessGameSvrMsg()
  593. *   brief  处理和游戏Server发来的消息
  594. *******************************************************************************/
  595. void CPlayer::ProcessGameSvrMsg()
  596. {
  597. char *pData = NULL;
  598. char *pMsg = NULL;
  599. char* pGetData = NULL;
  600. unsigned int nGetLength;
  602. pData = (char *)( m_pClientToGameSvr->GetPackFromServer( nGetLength ) );
  603. pMsg = pData;
  604. while (nGetLength)
  605. {
  606. while ( pMsg < ( pData + nGetLength ) )
  607. {
  608. #ifdef _GENERAL_DEBUG_
  609. printf("%d ==== %dn", pMsg, pData + nGetLength);
  610. #endif
  611. BYTE cProtocol = CPackager::Peek( pMsg );
  612. /*
  613. if ( !pData )
  614. { 
  615. return 0; 
  616. } 
  617. return *( ( const BYTE * )pData + index ); 
  618. */
  620. switch ( cProtocol )
  621. {
  623. case s2c_syncend:
  624. SyncEnd();
  625.             
  626. printf("%s: Enter Game Server SyncEnd!n", m_sAccName.c_str());
  628. if (g_nLoginLogoutFlag)
  629. {
  630. Sleep(rand() % 600);
  632. ShutdownGameSvr();
  634. SetStatus(enumExitGame);
  635. }
  636. break;
  637. case s2c_syncworld:
  638. {
  639. WORLD_SYNC *pWorldSync = (WORLD_SYNC *)pMsg;
  640. //pWorldSync->SubWorld
  641. #ifdef _DETAIL_PROTOCOL_DEBUG_
  642. printf("Protocol: SyncWorldn");
  643. #endif
  644. }
  645. break;
  647. case s2c_syncplayer:
  648. #ifdef _DETAIL_PROTOCOL_DEBUG_
  649. printf("Protocol: SyncPlayern");
  650. #endif
  651. break;
  653. case s2c_syncnpc:
  654. {
  655. NPC_SYNC *pPS = ( NPC_SYNC * )pMsg;
  656. #ifdef _DETAIL_PROTOCOL_DEBUG_
  657. printf("Protocol: SyncNpcn");
  658. #endif
  659. printf("NPC ID: %dn", pPS->ID);
  660. if ( pPS && ( '' != g_pRoleName[0] ) )
  661. {
  662. if ( 0 == memcmp( ( const char * )pPS->m_szName, g_pRoleName, sizeof( g_pRoleName ) ) )
  663. {
  664. m_dwTargetID = pPS->ID;
  665. }
  666. else
  667. {
  668. if (m_nFlgSetAttack)
  669. {
  670. ProcessNpcSync((NPC_NORMAL_SYNC*)pPS);
  671. }
  672. }
  673. }
  675. }
  676. break;
  677. case s2c_syncnpcmin:
  678. // {
  679. // NPC_NORMAL_SYNC *pNS = (NPC_NORMAL_SYNC *)pMsg;
  680. //#ifdef _DETAIL_PROTOCOL_DEBUG_
  681. // printf("Protocol: SyncNpcMin [%d]n");
  682. //#endif
  683. // printf("NPC Found: ID [%d]tCamp [%d]tDoing [%d]n",
  684. // pNS->ID, pNS->Camp, pNS->Doing);
  685. // if ( ( DWORD )( -1 ) != m_dwID )
  686. // {
  687. // if ( pNS && pNS->ID == m_dwID )
  688. // {
  689. // m_ptCurPos.x = pNS->MapX;
  690. // m_ptCurPos.y = pNS->MapY;
  691. // }
  692. // else if ( pNS && pNS->ID == m_dwTargetID )
  693. // {
  694. // m_ptTagPos.x = pNS->MapX;
  695. // m_ptTagPos.y = pNS->MapY;
  696. // }
  697. // else
  698. // {
  699. // // flying add this
  700. // // Auto attack against an NPC
  701. // if (m_nFlgSetAttack)
  702. // {
  703. // printf("XXXXXXXX A NPC will be attacked!!!!n");
  704. // ProcessNpcSync(pNS);
  705. // }
  706. // }
  707. // if ( ( DWORD )( -1 ) == m_dwTargetID && '' != g_pRoleName[0] )
  708. // {
  709. // if (
  710. // (rand() % 200) < (rand() % 100)
  711. // )
  712. // {
  713. // NPC_REQUEST_COMMAND nrc;
  714. //
  715. // nrc.ProtocolType = c2s_requestnpc;
  716. // nrc.ID = pNS->ID;
  717. //
  718. // m_pClientToGameSvr->SendPackToServer( reinterpret_cast< char * >( &nrc ), 
  719. // sizeof( NPC_REQUEST_COMMAND ) );
  720. // }
  721. // }
  722. // }
  723. // }
  724. break;
  725. case s2c_synccurplayer:
  726. {
  727. CURPLAYER_SYNC *pCS = (CURPLAYER_SYNC *)pMsg;
  728. #ifdef _DETAIL_PROTOCOL_DEBUG_
  729. printf("Protocol: SyncPlayern");
  730. #endif
  731. if ( pCS )
  732. {
  733. m_dwID = pCS->m_dwID;
  734. }
  735. }
  736. break;
  738. case s2c_syncnpcminplayer:
  739. {
  740. #ifdef _DETAIL_PROTOCOL_DEBUG_
  741. printf("Protocol: SyncNpcMinPlayern");
  742. #endif
  743. if ( ( DWORD )( -1 ) != m_dwID )
  744. {
  745. NPC_PLAYER_TYPE_NORMAL_SYNC *pNPTNS = (NPC_PLAYER_TYPE_NORMAL_SYNC *)pMsg;
  747. if ( pNPTNS && pNPTNS->m_dwNpcID == m_dwID )
  748. {
  749. m_ptCurPos.x = pNPTNS->m_dwMapX;
  750. m_ptCurPos.y = pNPTNS->m_dwMapY;
  751. }
  752. else if ( pNPTNS && pNPTNS->m_dwNpcID == m_dwTargetID )
  753. {
  754. m_ptTagPos.x = pNPTNS->m_dwMapX;
  755. m_ptTagPos.y = pNPTNS->m_dwMapY;
  756. }
  757. }
  758. }
  759. break;
  761. case s2c_skillcast:
  762. {
  763. NPC_SKILL_SYNC *pNpcSkillSync = (NPC_SKILL_SYNC *)pMsg;
  764. #ifdef _DETAIL_PROTOCOL_DEBUG_
  765. printf("Protocol: SkillCastn");
  766. #endif
  767. if (pNpcSkillSync->ID == m_dwTargetID)  // 如果主角攻击，大家一起配合
  768. {
  769. NPC_SKILL_COMMAND NpcSkillCmd;
  771. NpcSkillCmd.ProtocolType = c2s_npcskill;
  772. NpcSkillCmd.nSkillID = pNpcSkillSync->nSkillID;
  774. NpcSkillCmd.nMpsX = pNpcSkillSync->nMpsX;
  775. NpcSkillCmd.nMpsY = pNpcSkillSync->nMpsY;
  776. ASSERT(m_pClientToGameSvr);
  777. m_pClientToGameSvr->SendPackToServer( reinterpret_cast< char * >( &NpcSkillCmd ), 
  778. sizeof( NPC_SKILL_COMMAND ) );
  779. }
  780. }
  781. // flying add this branch
  782. // the robot has killed his "enemy NPC", oh yeah!!!! -_-|
  783. case s2c_npcdeath:
  784. {
  785. NPC_DEATH_SYNC* death = (NPC_DEATH_SYNC*) pMsg;
  786. #ifdef _DETAIL_PROTOCOL_DEBUG_
  787. printf("Protocol: NpcDeathn");
  788. #endif
  789. if (death->ID == m_dwID)
  790. {
  791. // do revive
  792. //printf("ACTION: Die!! Revive at the local place!n");
  793. NPC_REVIVE_COMMAND ReviveCmd;
  795. ReviveCmd.ProtocolType = c2s_playerrevive;
  796. //ReviveCmd.ReviveType = LOCAL_REVIVE_TYPE;
  797. ASSERT(m_pClientToGameSvr);
  798. m_pClientToGameSvr->SendPackToServer((BYTE *)&ReviveCmd, sizeof(NPC_REVIVE_COMMAND));
  799. }
  800. else if (death->ID == m_dwNpcID)
  801. {
  802. //printf("ACTION: %d Die!!!n", m_dwNpcID);
  803. m_nDoing = do_none;
  804. m_dwNpcID = 0;
  805. }
  806. }
  807. break;
  808. // flying add this branch
  809. // 组队相关
  810. // 入队邀请
  811. case s2c_teaminviteadd:
  812. {
  813. #ifdef _DETAIL_PROTOCOL_DEBUG_
  814. printf("Protocol: TeamInviteAddn");
  815. #endif
  816. TEAM_INVITE_ADD_SYNC* pSync = (TEAM_INVITE_ADD_SYNC *) pMsg;
  817. TEAM_REPLY_INVITE_COMMAND sReply;
  818. sReply.ProtocolType = c2s_teamreplyinvite;
  819. sReply.m_nIndex = pSync->m_nIdx;
  820. sReply.m_btResult = true;
  821. ASSERT(m_pClientToGameSvr);
  822. m_pClientToGameSvr->SendPackToServer(&sReply, sizeof(TEAM_REPLY_INVITE_COMMAND));
  823. }
  824. break;
  825. // 更换队长了
  826. case s2c_teamchangecaptain:
  827. {
  828. #ifdef _DETAIL_PROTOCOL_DEBUG_
  829. printf("Protocol: TeamChangeCaptainn");
  830. #endif
  831. PLAYER_TEAM_CHANGE_CAPTAIN* pData = (PLAYER_TEAM_CHANGE_CAPTAIN*)pMsg;
  832. m_nTeamLeader = pData->m_dwCaptainID;
  833. // 反馈拒绝信息
  834. }
  835. break;
  836. // 离队邀请（叫你走人）
  837. case s2c_teamleave:
  838. {
  839. #ifdef _DETAIL_PROTOCOL_DEBUG_
  840. printf("Protocol: TeamLeaven");
  841. #endif
  842. PLAYER_LEAVE_TEAM* pData = (PLAYER_LEAVE_TEAM*)pMsg;
  843. if (pData->m_dwNpcID == m_dwID)
  844. m_nTeamLeader = 0;
  845. }
  846. break;
  848. // 跨服务器
  849. case s2c_notifyplayerexchange:
  850. {
  851. #ifdef _DETAIL_PROTOCOL_DEBUG_
  852. printf("Protocol: NotifyPlayerExchangen");
  853. #endif
  854. ProcessSwitchGameServer((void *)pMsg);
  855. }
  856. break;
  857. // linux服务器开始测试了
  858. case s2c_ping:
  859. {
  860. PING_COMMAND* pData = (PING_COMMAND*)pMsg;
  861. if (pData == NULL)
  862. printf("Ping command data error!n");
  863. else
  864. {
  865. SendPing(pData->m_dwTime);
  866. }
  867. }
  868. break;
  869. // 服务端同步装备
  870. case s2c_syncitem:
  871. break;
  872. // 获取玩家聊天信息
  873. case s2c_playersendchat:
  874. {
  875. PLAYER_SEND_CHAT_SYNC* pData = (PLAYER_SEND_CHAT_SYNC *)pMsg;
  876. #ifdef _DETAIL_PROTOCOL_DEBUG_
  877. printf("Protocol: SyncSendChatn");
  878. #endif
  879. }
  880. break;
  881. // 扩展协议
  882. case s2c_extend:
  883. #ifdef _DETAIL_PROTOCOL_DEBUG_
  884. printf("Extend Protocol: [%d]n", cProtocol);
  885. #endif
  886. ProcessExtProtocol((char *)pMsg);
  887. break;
  888. default:
  889. #ifdef _DETAIL_PROTOCOL_DEBUG_
  890. printf("Ignored Protocol: [%d]n", cProtocol);
  891. #endif
  892. break;
  893. }
  894. /*
  895.  * Get next protocol
  896.  */
  897. int nProtocolSize = g_nGameProtocolSize[ cProtocol - s2c_clientbegin - 1 ];
  899. if ( nProtocolSize >= 0 )
  900. {
  901. pMsg += nProtocolSize;
  902. }
  903. else
  904. {
  905. unsigned short usMsgSize = *( unsigned short * )( pMsg + sizeof( BYTE ) );
  906. pMsg += sizeof( BYTE ) + usMsgSize;
  907. }
  908. } // while ( pMsg < ( pData + nGetLength ) )
  909. pData = (char *)( m_pClientToGameSvr->GetPackFromServer( nGetLength ) );
  910. #ifdef _GENERAL_DEBUG_
  911. printf("%d bytes m_pClientToGameSvr->GetPackFromServern", nGetLength);
  912. #endif
  913. pMsg = pData;
  914. } // while (nGetLength)
  915. }
  917. //******************************************************************************
  918. /*! fn     int CPlayer::ProcessExtProtocol(void* pMsg)
  919. *   brief  处理扩展协议
  920. *******************************************************************************/
  921. // flying add this
  922. int CPlayer::ProcessExtProtocol(char* pMsg)
  923. {
  924. int nResult = false;
  925. int nProtoType = 0;
  926. // int wLength = 0;
  927. char* pData = NULL;
  928. pData = pMsg + sizeof(tagExtendProtoHeader);
  930. EXTEND_HEADER* pHeader = (EXTEND_HEADER*)pData;
  931. ASSERT(pHeader->ProtocolFamily == pf_playercommunity);
  933. if (pMsg == NULL)
  934. goto Exit0;
  936. switch (pHeader->ProtocolID)
  937. {
  938. // query channel id result:
  939. case playercomm_s2c_notifychannelid:
  940. {
  941. // get the result first
  942. PLAYERCOMM_NOTIFYCHANNELID* pResult = (PLAYERCOMM_NOTIFYCHANNELID *)pData;
  943. m_nCurChannel = pResult->channelid;
  944. // subcribe the chat channel
  945. char szBuffer[sizeof(tagExtendProtoHeader) + sizeof(PLAYERCOMM_SUBSCRIBE)];
  946. tagExtendProtoHeader Header;
  947. PLAYERCOMM_SUBSCRIBE setChannel;
  948. Header.ProtocolType = c2s_extend;
  949. Header.wLength = sizeof(tagExtendProtoHeader) + sizeof(CHAT_SET_CHANNEL_COMMAND) - 1;
  950. setChannel.ProtocolFamily = pf_playercommunity;
  951. setChannel.ProtocolID = playercomm_c2s_subscribe;
  952. setChannel.channelid = m_nCurChannel;
  953. setChannel.subscribe = true;
  954. memcpy(szBuffer, &Header, sizeof(tagExtendProtoHeader));
  955. memcpy(szBuffer + sizeof(tagExtendProtoHeader), &setChannel, sizeof(PLAYERCOMM_SUBSCRIBE));
  956. m_pClientToGameSvr->SendPackToServer( szBuffer , 
  957. sizeof(tagExtendProtoHeader) + sizeof( PLAYERCOMM_SUBSCRIBE ) );
  958. }
  959. break;
  960. default:
  961. break;
  962. }
  963. nResult = true;
  964. Exit0:
  965. return nResult;
  966. }
  968. //******************************************************************************
  969. /*! fn     void CPlayer::ProcessSwitchGameServer()
  970. *   brief  切换游戏服务器
  971. *******************************************************************************/
  972. // flying add this
  973. int CPlayer::ProcessSwitchGameServer(void* lpBuffer)
  974. {
  975. int nResult = false;
  977. tagNotifyPlayerExchange* pInfo = (tagNotifyPlayerExchange*)lpBuffer;
  978. //_ASSERT(pInfo && pInfo->cProtocol == s2c_notifyplayerexchange);
  979. DWORD dwIp = pInfo->nIPAddr;
  980. int nPort = pInfo->nPort;
  981. GUID guid;
  982. guid = pInfo->guid;
  983. printf("Switch game server: %d : %dn", dwIp, nPort);
  984. if (dwIp && nPort)
  985. {
  986. // the first step is to close the connection from gameserver
  987. m_pClientToGameSvr->Shutdown();
  988. // 开始与GameSvr进行连接
  989. if (ConnectToGameSvr((char *)&dwIp, nPort, guid))
  990. goto Exit1;
  991. else
  992. goto Exit0;
  993. }
  994. else
  995. {
  996. goto Exit0;
  997. }
  998. Exit1:
  999. nResult = true;
  1000. Exit0:
  1001. return nResult;
  1002. }
  1004. //******************************************************************************
  1005. /*! fn     void CPlayer::ProcessGameSvrLoop()
  1006. *   brief  处理向游戏世界发送消息
  1007. *******************************************************************************/
  1008. void CPlayer::ProcessGameSvrLoop()
  1009. {
  1010. int nRandom = 0;
  1011. //#define SEED 65530
  1012. #define SEED 1024
  1013. if( NULL == m_pClientToGameSvr)
  1014. return;
  1015. nRandom = rand();
  1016. //if ( rand() % 65530 < 5 )
  1017. // flying use this instead.
  1018. if (m_nFlgChatTimer)
  1019. {
  1020. // TODO: Timer-chat goes here.
  1021. if (m_nChatTimer % 40 == 0)
  1022. {
  1023. char szSpeakText[128];
  1024. int nIndex = rand() % g_TextNumber;
  1025. printf("Chat timern");
  1026. sprintf(szSpeakText, (const char *)g_szText[nIndex], g_pRoleName);
  1027. SpeakWord(szSpeakText, strlen(szSpeakText));
  1028. }
  1029. }
  1030. if (nRandom % SEED < 4)
  1031. {
  1032. if (m_nFlgSilence == 0 && m_nFlgChatTimer == 0)
  1033. {
  1034. char szSpeakText[128];
  1035. int nIndex = rand() % g_TextNumber;
  1037. sprintf(szSpeakText, (const char *)g_szText[nIndex], g_pRoleName);
  1038. SpeakWord(szSpeakText, strlen(szSpeakText));
  1039. //printf("Speakingn");
  1040. }
  1041. }
  1042. // cast...
  1043. else if ( nRandom % SEED < 256)
  1044. {
  1045. CastSkill();
  1046. }
  1047. // flying add this branch, to walk randomly
  1048. else if ( nRandom % SEED < 512)
  1049. {
  1050. NPC_WALK_COMMAND cmd;
  1051. //cmd.CmdKind = do_walk;
  1052. //printf("ACTION: Robot walk, haha!n");
  1053. cmd.ProtocolType = c2s_npcwalk;
  1054. if (rand() % 2)
  1055. cmd.nMpsX = m_ptCurPos.x + rand() % m_ptOffset.x;
  1056. else
  1057. cmd.nMpsX = m_ptCurPos.x - rand() % m_ptOffset.x;
  1058. if (rand() % 2)
  1059. cmd.nMpsY = m_ptCurPos.y + rand() % m_ptOffset.y;
  1060. else
  1061. cmd.nMpsY = m_ptCurPos.y - rand() % m_ptOffset.y;
  1062. //printf("Walk...n");
  1063. m_pClientToGameSvr->SendPackToServer( reinterpret_cast< char * >( &cmd ), 
  1064. sizeof( NPC_WALK_COMMAND ) );
  1065. //printf("Walk donen");
  1066. }
  1067. else
  1068. {
  1069.         m_uGameServerLoopCount++;
  1070.         if ((m_uGameServerLoopCount % 5) == 0)
  1071.         {
  1072.      WalkTo();
  1073.         }
  1074. }
  1075. // 定时ping一把
  1076. return;
  1077. }
  1079. //******************************************************************************
  1080. /*! fn     void CPlayer::SendPing()
  1081. *   brief  发送ping命令而已，所以不对外提供。
  1082. *******************************************************************************/
  1083. // flying add this
  1084. void CPlayer::SendPing(DWORD dTime)
  1085. {
  1086. PING_CLIENTREPLY_COMMAND PingCmd;
  1088. PingCmd.ProtocolType = c2s_ping;
  1089. PingCmd.m_dwReplyServerTime = dTime;
  1090. PingCmd.m_dwClientTime = GetTickCount();
  1091. if (m_pClientToGameSvr)
  1092. {
  1093. m_pClientToGameSvr->SendPackToServer((BYTE*)&PingCmd, sizeof(PING_CLIENTREPLY_COMMAND));
  1094. printf("Reply ping command: [%d]....n", dTime);
  1095. }
  1096. }
  1098. //******************************************************************************
  1099. /*! fn     void CPlayer::ProcessNpcSync(NPC_SYNC* pPS)
  1100. *   brief  处理NPC同步
  1101. *******************************************************************************/
  1102. // flying add this
  1103. int CPlayer::ProcessNpcSync(NPC_NORMAL_SYNC* pPS)
  1104. {
  1105. int nResult = false;
  1106. // 自己
  1107. if (pPS->ID == m_dwID)
  1108. {
  1109. m_player.nCamp = pPS->Camp;
  1110. goto Exit1;
  1111. }
  1112. // 普通战斗NPC
  1113. //if (pPS->m_btKind == kind_normal)
  1114. if (pPS->Camp == 0)
  1115. {
  1116. if (m_nDoing == do_skill || m_nDoing == do_attack)
  1117. goto Exit0;
  1118. m_nDoing = do_skill;
  1119. m_dwNpcID = pPS->ID;
  1120.         NPC_SKILL_COMMAND NpcSkillCmd;
  1122.         NpcSkillCmd.ProtocolType = c2s_npcskill;
  1123.         NpcSkillCmd.nSkillID = pPS->ID;
  1125.         NpcSkillCmd.nMpsX = pPS->MapX;
  1126.         NpcSkillCmd.nMpsY = pPS->MapY;
  1128.         m_pClientToGameSvr->SendPackToServer( reinterpret_cast< char * >( &NpcSkillCmd ), 
  1129. sizeof( NPC_SKILL_COMMAND ) );
  1130. goto Exit1;
  1131. }
  1132. goto Exit0;
  1133. Exit1:
  1134. nResult = true;
  1135. Exit0:
  1136. return nResult;
  1137. }
  1139. //******************************************************************************
  1140. /*! fn     void CPlayer::ProcessPlayerSync(NPC_PLAYER_TYPE_NORMAL_SYNC* pPS)
  1141. *   brief  处理NPC同步
  1142. *******************************************************************************/
  1143. // flying add this
  1144. int CPlayer::ProcessPlayerSync(NPC_PLAYER_TYPE_NORMAL_SYNC* pPS)
  1145. {
  1146. int nResult = false;
  1147. m_nDoing = pPS->m_byDoing;
  1149. nResult = true;
  1150. //Exit0:
  1151. return nResult;
  1152. }
  1154. //******************************************************************************
  1155. /*! fn     int CPlayer::SetSilence(int nSilence)
  1156. *   brief  设定机器人沉默
  1157. *******************************************************************************/
  1158. // add by flying
  1159. int CPlayer::SetChatTimer(int nTimer)
  1160. {
  1161. m_nFlgChatTimer = nTimer;
  1162. return true;
  1163. }
  1165. //******************************************************************************
  1166. /*! fn     int CPlayer::SetSilence(int nSilence)
  1167. *   brief  设定机器人沉默
  1168. *******************************************************************************/
  1169. // add by flying
  1170. int CPlayer::SetSilence(int nSilence)
  1171. {
  1172. m_nFlgSilence = nSilence;
  1173. return true;
  1174. }
  1176. //******************************************************************************
  1177. /*! fn     int CPlayer::SetAttack()
  1178. *   brief  设定机器人自动攻击NPC
  1179. *******************************************************************************/
  1180. // add by flying
  1181. int CPlayer::SetAttack()
  1182. {
  1183. m_nFlgSetAttack = 1;
  1184. return true;
  1185. }
  1187. //******************************************************************************
  1188. /*! fn     void CPlayer::SetPos()
  1189. *   brief  通过GM指令移动机器人
  1190. *******************************************************************************/
  1191. // add by flying
  1192. int CPlayer::SetPos(int nX, int nY)
  1193. {
  1194. int nResult = false;
  1195. m_nFlgSetPos = 1;
  1196. m_ptCurPos.x = nX;
  1197. m_ptCurPos.y = nY;
  1198. nResult = true;
  1199. //Exit0:
  1200. return nResult;
  1201. }
  1203. //******************************************************************************
  1204. /*! fn     void CPlayer::DoSetPos()
  1205. *   brief  通过GM指令移动机器人
  1206. *******************************************************************************/
  1207. // add by flying
  1208. int CPlayer::DoSetPos()
  1209. {
  1210. int nResult = false;
  1211. char szGmCommand[128];
  1212. // 判断XY的合法性，待定
  1214. memset(szGmCommand, 0, 128);
  1215. // 这里需要具体的Gm指令 ?gm ds SetPos(x, y)
  1216. sprintf(szGmCommand, "?gm ds SetPos(%d, %d)", m_ptCurPos.x, m_ptCurPos.y);
  1217. //printf("CM: %sn", szGmCommand);
  1218. SpeakWord(szGmCommand, strlen(szGmCommand));
  1219. m_nFlgSetPos = 0;
  1220. nResult = true;
  1221. return nResult;
  1222. }
  1224. //******************************************************************************
  1225. /*! fn     void CPlayer::LoginGateway()
  1226. *   brief  向网关发出登陆请求
  1227. *******************************************************************************/
  1228. void CPlayer::LoginGateway()
  1229. {
  1230. _tstring buffer;
  1231. KLoginAccountInfo lai;
  1232. char szTempPasswd[64];
  1234. ZeroMemory( &lai, sizeof( KLoginAccountInfo ) );
  1235. memset(szTempPasswd, 0, 64);
  1236. // 填充帐号
  1237. size_t used = sizeof( lai.Account );
  1238. used = ( used > m_sAccName.length() ) ? m_sAccName.length() : used;
  1239. memcpy( lai.Account, m_sAccName.c_str(), used );
  1241. // 填充密码
  1242. used = sizeof( lai.Password );
  1243. used = ( used > m_sAccName.length() ) ? m_sAccName.length() : used;
  1244. //memcpy( (void *)&(lai.Password), m_sAccName.c_str(), used );
  1245. memcpy(szTempPasswd, m_sAccName.c_str(), used);
  1246. KSG_StringToMD5String(lai.Password.szPassword, szTempPasswd);
  1248.     #ifdef USE_KPROTOCOL_VERSION
  1249.     // Add By Freeway Chen in 2003.7.1
  1250.     lai.ProtocolVersion = KPROTOCOL_VERSION;
  1251.     #endif
  1253. // 其他信息
  1254. lai.Param = LOGIN_A_LOGIN | LOGIN_R_REQUEST;
  1255. lai.Size = sizeof( lai );
  1257. buffer.resize( lai.Size + 1/* protocol id */ );
  1259. BYTE bProtocol = c2s_login;
  1260. memcpy( const_cast< char * >( buffer.c_str() ), &bProtocol, sizeof( BYTE ) );
  1261. memcpy( const_cast< char * >( buffer.c_str() + 1 ), &lai, sizeof( lai ) );
  1263. // 向网关发送请求
  1264. m_pClientToGateWay->SendPackToServer( buffer.c_str(), buffer.size() );
  1266. return;
  1267. }
  1269. // 
  1270. //******************************************************************************
  1271. /*! fn     bool CPlayer::OnAccountLoginNotify(const char* pMsg)
  1272. *   brief  处理网关发回的帐号登陆请求的结果
  1273. *******************************************************************************/
  1274. bool CPlayer::OnAccountLoginNotify(const char* pMsg)
  1275. {
  1276. KLoginAccountInfo *pLAI = ( KLoginAccountInfo * )( ( const BYTE * )pMsg + 1 );
  1277. bool bRet = false;
  1279. // if ( ( pLAI->Param | LOGIN_A_LOGIN ) &&
  1280. //  0 == m_sAccName.compare( pLAI->Account ) &&
  1281. //  0 == m_sAccName.compare( pLAI->Password ) )
  1282. if ( ( pLAI->Param | LOGIN_A_LOGIN ) &&
  1283.  0 == m_sAccName.compare( pLAI->Account ))
  1284. {
  1285. if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_ACCOUNT_OR_PASSWORD_ERROR )
  1286. {
  1287.             printf("%s: An incorrect account or password!n", m_sAccName.c_str());
  1288. }
  1289. else if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_FAILED )
  1290. {
  1291.             printf("%s: Login failed!n", m_sAccName.c_str());
  1292. }
  1293. else if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_ACCOUNT_EXIST )
  1294. {
  1295.             printf("%s: Login failed! your accout was existed!n", m_sAccName.c_str());
  1296. }
  1297. else if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_TIMEOUT )
  1298. {
  1299.             printf("%s: Login failed! no money!n", m_sAccName.c_str());
  1300. }
  1301. // // comment by flying
  1302. // else if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_INVALID_PROTOCOLVERSION )
  1303. // {
  1304. //            printf("%s: Login failed! Invalid Protocol Version!n", m_sAccName.c_str());
  1305. // }
  1306. else if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_SUCCESS )
  1307. {
  1308.             printf("%s: Login ok!n", m_sAccName.c_str());
  1309. bRet = true;
  1310. }
  1311. }
  1312. return bRet;
  1313. }
  1315. // 
  1316. //******************************************************************************
  1317. /*! fn     bool CPlayer::OnAccountLogoutNotify(const char* pMsg)
  1318. *   brief  处理网关发回的帐号登出请求的结果
  1319. *******************************************************************************/
  1320. //bool CPlayer::OnAccountLogoutNotify(const char* pMsg)
  1321. //{
  1322. //
  1323. //    return true;
  1324. //}
  1327. //******************************************************************************
  1328. /*! fn     int CPlayer::OnGetRoleListRole(const char* pMsg)
  1329. *   brief  响应网关发来的消息，选择角色列表
  1330. *******************************************************************************/
  1331. int CPlayer::OnGetRoleList(const char* pMsg)
  1332. {
  1333. int nRoleCount = 0;
  1334. int nSelRoleIndex = 0;
  1336. S3DBI_RoleBaseInfo *pRoleList = NULL;
  1337. TProcessData *pPA = ( TProcessData * )pMsg;
  1339.     int nMsgLen = sizeof(TProcessData) + pPA->nDataLen - 1;
  1341. nRoleCount = *( char * )( pPA->pDataBuffer );
  1343. pRoleList = (S3DBI_RoleBaseInfo * )( ( const char * )( pPA->pDataBuffer ) + 1/* sizeof( char ) */ );
  1344. const size_t datalength = sizeof( S3DBI_RoleBaseInfo ) * nRoleCount;
  1346.     int nAction = 0;
  1348.     if (g_nDeleteRoleFlag)
  1349.     {
  1350.         nAction = 2;
  1351.     }
  1352.     else if (g_nAddRoleFlag)
  1353.     {
  1354.         nAction = 1;
  1355.     }
  1356.     else
  1357.     {
  1358.         if (nRoleCount > 0)
  1359.             nAction = 0;
  1360.         else
  1361.             nAction = 1;
  1362.     }
  1365.     switch (nAction) 
  1366.     {
  1367.     case 0:     // 选择角色
  1368.     {
  1369.         if (nRoleCount > 0)
  1370.         {
  1371.             nSelRoleIndex = rand() % nRoleCount;
  1372.         }
  1373.         
  1374.         if (nSelRoleIndex < nRoleCount)
  1375.         {
  1376.             // Add by Freeway Chen for Old Version BiShop
  1377.             if (nSelRoleIndex >= 3)
  1378.                 nSelRoleIndex = 2;
  1380.             printf("%s : Select Character %d/%d(%s)!n", m_sAccName.c_str(), nSelRoleIndex, nRoleCount, pRoleList[nSelRoleIndex].szName);
  1381.         }
  1382.         else
  1383.         {
  1384.             printf("%s : Select Empty Character!n", m_sAccName.c_str());
  1385.         }
  1387.     tagDBSelPlayer tDBSP;
  1388.     tDBSP.cProtocol = c2s_dbplayerselect;
  1390.     size_t nRoleNameLen = strlen( pRoleList[nSelRoleIndex].szName );
  1391.     memcpy( tDBSP.szRoleName, pRoleList[nSelRoleIndex].szName, nRoleNameLen );
  1392.     tDBSP.szRoleName[nRoleNameLen] = '';
  1394.     m_pClientToGateWay->SendPackToServer( &tDBSP, sizeof( tagDBSelPlayer ) );
  1395.         break;
  1396.     } // case 0:     // 选择角色
  1398.     case 1:     // 增加角色
  1399.     {
  1400.         if (nRoleCount >= 3)
  1401.             break;
  1403.         // 创建角色
  1404.         const int cnAddressIDCount = 5;
  1405.         static int s_AddressIDTable[cnAddressIDCount] = 
  1406.         {
  1407.             1,      // 凤翔
  1408.             20,     // 江津村
  1409.             45,     // 天忍教
  1410.             53,     // 巴陵县
  1411.             81      // 武当
  1412.         };
  1414.         int nNameLen = 0;
  1415.     char Data[sizeof(TProcessData) + sizeof(NEW_PLAYER_COMMAND)];
  1416.     TProcessData* pNetCommand = (TProcessData*)&Data;
  1417.     NEW_PLAYER_COMMAND* pInfo = (NEW_PLAYER_COMMAND*)pNetCommand->pDataBuffer;
  1418.     if (g_nAddRoleGender == -1)
  1419.             pInfo->m_btRoleNo = rand() % 2;     // 男女
  1420.         else 
  1421.             pInfo->m_btRoleNo = g_nAddRoleGender;     // 男女
  1422.         
  1423.         if (g_nAddRoleSeries == -1)    
  1424.         pInfo->m_btSeries = rand() % 5;     // 五行
  1425.         else
  1426.         pInfo->m_btSeries = g_nAddRoleSeries;     // 五行
  1428.         if (g_nAddRolePlaceID == -1)
  1429.         pInfo->m_NativePlaceId = s_AddressIDTable[rand() % cnAddressIDCount];
  1430.         else
  1431.             pInfo->m_NativePlaceId = g_nAddRolePlaceID;
  1433.         int nNameRand = rand() % 100;
  1434.     sprintf(pInfo->m_szName, "%s_%d", m_sAccName.c_str(), nNameRand);
  1435.         nNameLen = strlen(pInfo->m_szName);
  1436.     
  1437.     pNetCommand->nProtoId = c2s_newplayer;
  1438.     pNetCommand->nDataLen = sizeof(NEW_PLAYER_COMMAND) - sizeof(pInfo->m_szName) + nNameLen + 1/* sizeof( '' ) */;
  1439.     pNetCommand->ulIdentity = 0;
  1441.         printf("%s : Add Character %d(%s)!n", m_sAccName.c_str(), nRoleCount, pInfo->m_szName);
  1443.     m_pClientToGateWay->SendPackToServer(&Data, sizeof(TProcessData) - sizeof(pNetCommand->pDataBuffer) + pNetCommand->nDataLen);
  1445.         if (nRoleCount < 3)
  1446.         {
  1447.             memcpy((void *)pRoleList[nRoleCount].szName, pInfo->m_szName, nNameLen + 1);
  1449.             (*(char *)(pPA->pDataBuffer))++;
  1451.             nRoleCount++;
  1452.         }
  1454.         break;    
  1455.     }   // case 1:     // 增加角色
  1457.     case 2:     // 删除角色
  1458.     {
  1459.         if (nRoleCount > 0)
  1460.         {
  1461.             nSelRoleIndex = rand() % nRoleCount;
  1462.         }
  1463.         
  1464.         if (nSelRoleIndex < nRoleCount)
  1465.         {
  1466.             printf("%s : Del Character %d/%d(%s)!n", m_sAccName.c_str(), nSelRoleIndex, nRoleCount, pRoleList[nSelRoleIndex].szName);
  1467.         tagDBDelPlayer tDBDP;
  1468.             tDBDP.cProtocol = c2s_roleserver_deleteplayer;
  1469.             strcpy(tDBDP.szAccountName, m_sAccName.c_str());
  1470.             //strcpy(tDBDP.szPassword,    m_sAccName.c_str());
  1471.             strcpy(tDBDP.szRoleName,    pRoleList[nSelRoleIndex].szName);
  1473.         m_pClientToGateWay->SendPackToServer(&tDBDP, sizeof(tDBDP));
  1475.             while (nSelRoleIndex < (nRoleCount - 1))
  1476.             {
  1477.                 pRoleList[nSelRoleIndex] = pRoleList[nSelRoleIndex + 1]; 
  1478.                 
  1479.                 nSelRoleIndex++;
  1480.             }
  1482.             (*(char *)(pPA->pDataBuffer))--;
  1483.         }
  1484.         else
  1485.         {
  1486.             printf("%s : Del Empry Character!n", m_sAccName.c_str());
  1487.             
  1488.             Sleep(rand() % 10);
  1489.             SetStatus(enumExitGame);
  1490.         }
  1492.         break;    
  1493.     }   // case 2:     // 删除角色
  1496.     default :
  1497.         Sleep(rand() % 10);
  1498.         SetStatus(enumExitGame);
  1499.     
  1501.     }   // switch
  1504. return nMsgLen;
  1505. }
  1507. //******************************************************************************
  1508. /*! fn     bool CPlayer::OnPlayerLoginNotify(const char* pMsg)
  1509. *   brief  处理网关发来的消息，响应角色进入游戏的通告
  1510. *******************************************************************************/
  1511. bool CPlayer::OnPlayerLoginNotify(const char* pMsg)
  1512. {
  1513. tagNotifyPlayerLogin *pNPL = ( tagNotifyPlayerLogin * )pMsg;
  1515.     if (!pNPL->bPermit)
  1516.         return false;
  1518. const char *pIPAddr = OnlineGameLib::Win32::net_ntoa( pNPL->nIPAddr );
  1520. return ConnectToGameSvr( pIPAddr, pNPL->nPort, pNPL->guid );
  1521. }
  1523. //******************************************************************************
  1524. /*! fn     bool CPlayer::ConnectToGameSvr( const char *pIPAddr, unsigned short nPort, GUID &guid )
  1525. *   brief  处理网关发来的消息，客户连接到网关
  1526. *******************************************************************************/
  1527. bool CPlayer::ConnectToGameSvr( const char *pIPAddr, unsigned short nPort, GUID &guid )
  1528. {
  1529.     if (nPort == 0)
  1530.         return false;
  1531. #if defined _USE_RAINBOW
  1532. pfnCreateClientInterface pFactroyFun = ( pfnCreateClientInterface )( s_theRainbowLib.GetProcAddress( "CreateInterface" ) );
  1534. IClientFactory *pClientFactory = NULL;
  1536. if ( pFactroyFun && SUCCEEDED( pFactroyFun( IID_IClientFactory, reinterpret_cast< void ** >( &pClientFactory ) ) ) )
  1537. {
  1538. pClientFactory->SetEnvironment( 1024 * 256 );
  1540. pClientFactory->CreateClientInterface( IID_IESClient, reinterpret_cast< void ** >( &m_pClientToGameSvr ) );
  1542. pClientFactory->Release();
  1543. }
  1545. if ( !m_pClientToGameSvr )
  1546. {
  1547. //::MessageBox(NULL, "Initialization failed! Don't find a correct rainbow.dll", "Error", MB_OK);
  1548.         printf("Initialization failed! Don't find a correct rainbow.dlln");
  1550. return false;
  1551. }
  1552. #else
  1553. //m_pClientToGameSvr = 
  1554. #endif
  1555. /*
  1556.  * Create a connection
  1557.  */
  1558. m_pClientToGameSvr->Startup();
  1560. //pGameSvrClient->RegisterMsgFilter( reinterpret_cast< void * >( pClient ), NULL );
  1561. #if defined _USE_RAINBOW
  1562.     HRESULT h = m_pClientToGameSvr->RegisterMsgFilter( ( void * )this, GameServerToClientEventNotify );
  1563. #else
  1564. m_pClientToGameSvr->RegisterMsgFilter( ( void * )this, GameServerToClientEventNotify );
  1565. #endif
  1566. if ( FAILED( m_pClientToGameSvr->ConnectTo( pIPAddr, nPort ) ) )
  1567. {
  1568. //::MessageBox(NULL, "Connection failed! Don't connect to game server.", "Error", MB_OK);
  1569.         printf("Connection failed! Don't connect to game server.n");
  1571. return false;
  1572. }
  1574. tagLogicLogin ll;
  1576. ll.cProtocol = c2s_logiclogin;
  1577. memcpy( &ll.guid, &guid, sizeof( GUID ) );
  1579. m_pClientToGameSvr->SendPackToServer( &ll, sizeof( tagLogicLogin ) );
  1581. ShutdownGateway();
  1583. return true;
  1584. }
  1586. //******************************************************************************
  1587. /*! fn     void CPlayer::SyncEnd()
  1588. *   brief  响应游戏服务器发来的消息，初始同步结束
  1589. *           登入或者切换服务器的时候产生这个消息。
  1590. * SyncWorld, SyncNpc, SyncPlayer, SyncCurPlayer, SyncCurPlayerSkill
  1591. * SyncEnd, SyncNpcMinPlayer
  1592. *******************************************************************************/
  1593. void CPlayer::SyncEnd()
  1594. {
  1595. SetStatus( enumPlayGame );
  1597. BYTE cSyscEndFlag = c2s_syncend;
  1599. m_pClientToGameSvr->SendPackToServer( reinterpret_cast< char * >( &cSyscEndFlag ), sizeof( BYTE ) );
  1600. // flying add the following code
  1601. // Initialize the "birth position"
  1602. if (m_nFlgSetPos)
  1603. DoSetPos();
  1604. // Query channel
  1605. QueryDefaultChannel("\S", 3);
  1606. // Execute GM Commands
  1607. SendGMCommand();
  1608. }
  1611. //******************************************************************************
  1612. /*! fn     void CPlayer::QueryDefaultChannel()
  1613. *   brief  查询默认频道
  1614. *******************************************************************************/
  1615. void CPlayer::QueryDefaultChannel(char* szName, int nSize)
  1616. {
  1617. if (szName == NULL || strlen(szName)==0)
  1618. return;
  1619. char szBuffer[sizeof(tagExtendProtoHeader) + sizeof(PLAYERCOMM_QUERYCHANNELID)];
  1620. tagExtendProtoHeader Header;
  1621. PLAYERCOMM_QUERYCHANNELID setChannel;
  1622. Header.ProtocolType = c2s_extend;
  1623. Header.wLength = sizeof(tagExtendProtoHeader) + sizeof(PLAYERCOMM_QUERYCHANNELID) - 1;
  1624. setChannel.ProtocolFamily = pf_playercommunity;
  1625. setChannel.ProtocolID = playercomm_c2s_querychannelid;
  1626. // Public Channel
  1627. memcpy(setChannel.channel, szName, nSize);
  1628. memcpy(szBuffer, &Header, sizeof(tagExtendProtoHeader));
  1629. memcpy(szBuffer + sizeof(tagExtendProtoHeader), &setChannel, sizeof(PLAYERCOMM_QUERYCHANNELID));
  1630. m_pClientToGameSvr->SendPackToServer( szBuffer , 
  1631. sizeof(tagExtendProtoHeader) + sizeof( PLAYERCOMM_QUERYCHANNELID ) );
  1632. }
  1634. static inline unsigned _RandValue(unsigned uHoldRand)
  1635. {
  1636.     uHoldRand = uHoldRand * 214013L + 2531011L;
  1637.      
  1638.     return uHoldRand;
  1639. }
  1641. //******************************************************************************
  1642. /*! fn     void CPlayer::WalkTo()
  1643. *   brief  机器人行走
  1644. *******************************************************************************/
  1645. void CPlayer::WalkTo()
  1646. {
  1647. if ( ( DWORD )( -1 ) != m_dwTargetID && m_ptTagPos.x && m_ptTagPos.y )
  1648. {
  1649. if ( abs( m_ptCurPos.x - m_ptTagPos.x ) > 16 ||
  1650. abs( m_ptCurPos.y - m_ptTagPos.y ) >  16 )
  1651. {
  1652.             NPC_RUN_COMMAND     nrc;
  1654.             nrc.ProtocolType = c2s_npcrun;
  1655.             nrc.nMpsX = m_ptTagPos.x + ((_RandValue(m_RandValue)             % 9) - 5) * 32;
  1656. nrc.nMpsY = m_ptTagPos.y + ((_RandValue(_RandValue(m_RandValue)) % 9) - 5) * 32;
  1657. m_pClientToGameSvr->SendPackToServer( reinterpret_cast< BYTE * >( &nrc ), sizeof( nrc ) );
  1658. }
  1659. }
  1660. }
  1662. //******************************************************************************
  1663. /*! fn     void CPlayer::CastSkill()
  1664. *   brief  发送技能
  1665. *******************************************************************************/
  1666. void CPlayer::CastSkill()
  1667. {
  1668. char* szGMAddMana = "?gm ds RestoreMana()";
  1669. if (!m_nFlgGMDone)
  1670. return;
  1671. // skill casting implementation goes here
  1672. NPC_SKILL_COMMAND NpcSkillCmd;
  1674. NpcSkillCmd.ProtocolType = c2s_npcskill;
  1675. NpcSkillCmd.nSkillID = 1;
  1677. NpcSkillCmd.nMpsX = m_ptTagPos.x + ((_RandValue(m_RandValue) % 9) - 5) * 32;
  1678. NpcSkillCmd.nMpsY = m_ptTagPos.y + ((_RandValue(_RandValue(m_RandValue)) % 9) - 5) * 32;;
  1679. ASSERT(m_pClientToGameSvr);
  1680. m_pClientToGameSvr->SendPackToServer( reinterpret_cast< char * >( &NpcSkillCmd ), 
  1681. sizeof( NPC_SKILL_COMMAND ) );
  1682. SpeakWord(szGMAddMana, strlen(szGMAddMana));
  1683. }
  1685. //******************************************************************************
  1686. /*! fn     void CPlayer::SendGMCommand()
  1687. *   brief  发送GM指令
  1688. *******************************************************************************/
  1689. void CPlayer::SendGMCommand()
  1690. {
  1691. if (m_nFlgGMDone)
  1692. return;
  1693. printf("Try to send GM command_S_.........n");
  1694. for (int i = 0; i < MAX_GM_COUNT; i++)
  1695. {
  1696. if (g_szGMCommandList[i][0] == 0)
  1697. break;
  1698. SpeakWord((char *)g_szGMCommandList[i], strlen((char *)szGMCommand));
  1699. printf("--> %sn", g_szGMCommandList[i]);
  1700. Sleep(20);
  1702. }
  1703. printf("GM Completed...............n");
  1704. m_nFlgGMDone = true;
  1705. return;
  1706. }
  1708. //******************************************************************************
  1709. /*! fn     void CPlayer::SpeakWord( const char *pText, size_t size  )
  1710. *   brief  随机聊天
  1711. *******************************************************************************/
  1712. void CPlayer::SpeakWord( const char *pText, size_t size /*0*/ )
  1713. {
  1714. if ( NULL == pText || 0 == size )
  1715. {
  1716. return;
  1717. }
  1719. size_t dataLength = size;
  1721. if ( 0 == dataLength )
  1722. {
  1723. dataLength = strlen(pText);
  1724. }
  1725. // New protocol
  1726. int nPackSize = sizeof(tagExtendProtoHeader) + sizeof(CHAT_CHANNELCHAT_CMD) + dataLength;
  1727. char *ProtocolBuffer = (char*)malloc(nPackSize);
  1728. int nProtocolOffset = 0;
  1730. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)ProtocolBuffer;
  1731. pExHeader->ProtocolType = c2s_extendchat;
  1732. pExHeader->wLength = nPackSize - 1;
  1733. nProtocolOffset += sizeof(tagExtendProtoHeader);
  1735. CHAT_CHANNELCHAT_CMD* pCccCmd = (CHAT_CHANNELCHAT_CMD*)(ProtocolBuffer + nProtocolOffset);
  1736. pCccCmd->ProtocolType = chat_channelchat;
  1737. pCccCmd->wSize = dataLength - 1;
  1738. pCccCmd->packageID = -1;
  1739. pCccCmd->filter = 1;
  1740. if (strncmp(pText, "?gm ds", 6) == 0)
  1741. pCccCmd->channelid = m_nGMChannelID;
  1742. else
  1743. pCccCmd->channelid = m_nCurChannel;
  1744. pCccCmd->cost = 0;
  1745. pCccCmd->sentlen = dataLength;
  1746. nProtocolOffset += sizeof(CHAT_CHANNELCHAT_CMD);
  1747. memcpy(pCccCmd + 1, pText, dataLength);
  1748. nProtocolOffset += dataLength;
  1750. if (m_pClientToGameSvr)
  1751. m_pClientToGameSvr->SendPackToServer(ProtocolBuffer, nProtocolOffset);
  1752. free(ProtocolBuffer);
  1753. }
  1755. //******************************************************************************
  1756. /*! fn     void ShutdownGateway()
  1757. *   brief  切断与网关的连接
  1758. *******************************************************************************/
  1759. void CPlayer::ShutdownGateway()
  1760. {
  1762.     m_nShutDownGatewayFlag = true;
  1764. // 关闭到网关的连接
  1765. if ( m_pClientToGateWay )
  1766. {
  1767. m_pClientToGateWay->Cleanup();
  1769. SAFE_RELEASE( m_pClientToGateWay );
  1770. }
  1771.     //SetStatus(enumExitGame);
  1772. }
  1774. //******************************************************************************
  1775. /*! fn     void ShutdownGateway()
  1776. *   brief  切断与网关的连接
  1777. *******************************************************************************/
  1778. void CPlayer::ShutdownGameSvr()
  1779. {
  1780. // 关闭到网关的连接
  1781. if ( m_pClientToGameSvr )
  1782. {
  1783. m_pClientToGameSvr->Cleanup();
  1785. SAFE_RELEASE( m_pClientToGameSvr );
  1786. }
  1787. }
  1789. #if defined _USE_RAINBOW
  1790. void __stdcall CPlayer::ClientEventNotify(
  1791. LPVOID lpParam,
  1792. const unsigned long &ulnEventType )
  1793. #else
  1794. void CPlayer::ClientEventNotify(
  1795. LPVOID lpParam,
  1796. const unsigned long &ulnEventType )
  1797. #endif
  1798. {
  1799. CPlayer *pPlayer = ( CPlayer * )lpParam;
  1801. ASSERT( pPlayer );
  1803. try
  1804. {
  1805. pPlayer->_ClientEventNotify( ulnEventType );
  1806. }
  1807. catch(...)
  1808. {
  1809. //::MessageBeep( -1 );
  1810. }
  1811. }
  1813. void CPlayer::_ClientEventNotify( const unsigned long &ulnEventType )
  1814. {
  1815. switch( ulnEventType )
  1816. {
  1817. case enumServerConnectCreate:
  1819. //::MessageBeep( -1 );
  1821. break;
  1823. case enumServerConnectClose:
  1824.         if (!m_nShutDownGatewayFlag)
  1825.         {
  1826.             // 如果不是主动断开网络的连接，说明是被网关踢掉
  1827.             SetStatus(enumExitGame);
  1828.         }
  1830. //::MessageBeep( -1 );
  1832. break;
  1833. }
  1834. }
  1836. #if defined _USE_RAINBOW
  1837. void __stdcall CPlayer::GameServerToClientEventNotify(
  1838. LPVOID lpParam,
  1839. const unsigned long &ulnEventType )
  1840. #else
  1841. void CPlayer::GameServerToClientEventNotify(
  1842. LPVOID lpParam,
  1843. const unsigned long &ulnEventType )
  1844. #endif
  1845. {
  1846. CPlayer *pPlayer = ( CPlayer * )lpParam;
  1848. ASSERT( pPlayer );
  1850. try
  1851. {
  1852. pPlayer->_GameServerToClientEventNotify( ulnEventType );
  1853. }
  1854. catch(...)
  1855. {
  1856. //::MessageBeep( -1 );
  1857. }
  1858. }
  1860. void CPlayer::_GameServerToClientEventNotify( const unsigned long &ulnEventType )
  1861. {
  1862. switch( ulnEventType )
  1863. {
  1864. case enumServerConnectCreate:
  1866. //::MessageBeep( -1 );
  1868. break;
  1870. case enumServerConnectClose:
  1871.         SetStatus(enumExitGame);
  1873. //::MessageBeep( -1 );
  1875. break;
  1876. }
  1877. }
  1879. int CPlayer::KSG_StringToMD5String(char szDestMD5String[64], const char cszSrcString[])
  1880. {
  1881.     int nResult = false;
  1882.     md5_state_t md5_state;
  1883.     unsigned char MD5Value[16];
  1884.     int nSrcStringLen = 0;
  1886.     if (!szDestMD5String)
  1887.         goto Exit0;
  1889.     szDestMD5String[0] = '';
  1891.     if  (!cszSrcString)
  1892.        goto Exit0;
  1894.     nSrcStringLen = strlen(cszSrcString);
  1896.     if (!nSrcStringLen)
  1897.         goto Exit0;
  1899.     md5_init(&md5_state);
  1901.     md5_append(&md5_state, (unsigned char *)cszSrcString, nSrcStringLen);
  1903.     md5_finish(&md5_state, MD5Value);
  1906.     sprintf(
  1907.         szDestMD5String,
  1908.         "%02X%02X%02X%02X%02X%02X%02X%02X%02X%02X%02X%02X%02X%02X%02X%02X",
  1909.         MD5Value[ 0], MD5Value[ 1], MD5Value[ 2], MD5Value[ 3],
  1910.         MD5Value[ 4], MD5Value[ 5], MD5Value[ 6], MD5Value[ 7],
  1911.         MD5Value[ 8], MD5Value[ 9], MD5Value[10], MD5Value[11],
  1912.         MD5Value[12], MD5Value[13], MD5Value[14], MD5Value[15]
  1913.     );
  1915.     nResult = true;
  1916. Exit0:
  1917.     return nResult;
  1918. }