Category

Development Platform
Home > SourceCode/Document > Game Program > Game Server Simulator > View Code
CoreServerShell.cpp
Package: SwordOnline.rar　[view]
Upload User: dzyhzl
Upload Date: 2019-04-29
Package Size: 56270k
Code Size: 33k
Category:

Game Server Simulator

Development Platform:

C/C++

CoreServerShell.cpp：Code Content
  1. /*****************************************************************************************
  2. // 外界访问Core server 接口方法
  3. // Copyright : Kingsoft 2002
  4. // Author :   Wooy (Wu yue)
  5. // CreateTime: 2002-12-20
  6. ------------------------------------------------------------------------------------------
  7. *****************************************************************************************/
  8. #include "KCore.h"
  9. #include "CoreServerShell.h"
  10. #include "KThread.h"
  11. #include "KPlayer.h"
  12. #include "KItemList.h"
  13. #include "KSubWorldSet.h"
  14. #include "KProtocolProcess.h"
  15. #include "KNewProtocolProcess.h"
  16. #include "KPlayerSet.h"
  17. #include "KLadder.h"
  19. #ifdef _STANDALONE
  20. #include "KLadder.cpp"
  21. #endif
  23. //#include "KNetServer.h"
  24. //#include "../MultiServer/Heaven/Interface/iServer.h"
  25. #ifdef _STANDALONE
  26. #include "IClient.h"
  27. #else
  28. #include "../../lib/S3DBInterface.h"
  29. #include "../../Headers/IClient.h"
  30. #include "../../../Headers/IClient.h"
  31. #include "../../../Headers/KGmProtocol.h"
  32. #endif
  34. #include "LuaFuns.h"
  35. #include "KSortScript.h"
  36. #include "KSubWorld.h"
  39. #include "malloc.h"
  41. class CoreServerShell : public iCoreServerShell
  42. {
  43. public:
  44. int  GetLoopRate();
  45. void GetGuid(int nIndex, void* pGuid);
  46. DWORD GetExchangeMap(int nIndex);
  47. bool IsPlayerLoginTimeOut(int nIndex);
  48. void RemovePlayerLoginTimeOut(int nIndex);
  49. bool IsPlayerExchangingServer(int nIndex);
  50. void ProcessClientMessage(int nIndex, const char* pChar, int nSize);
  51. void ProcessNewClientMessage(IClient*, DWORD, DWORD, int nIndex, const char* pChar, int nSize);
  52. void SendNetMsgToTransfer(IClient* pClient);
  53. void SendNetMsgToChat(IClient* pClient);
  54. void SendNetMsgToTong(IClient* pClient);
  55. void ProcessBroadcastMessage(const char* pChar, int nSize);
  56. void ProcessExecuteMessage(const char* pChar, int nSize);
  57. void ClientDisconnect(int nIndex);
  58. void RemoveQuitingPlayer(int nIndex);
  59. void* SavePlayerDataAtOnce(int nIndex);
  60. bool IsCharacterQuiting(int nIndex);
  61. bool CheckProtocolSize(const char* pChar, int nSize);
  62. bool PlayerDbLoading(int nPlayerIndex, int bSyncEnd, int& nStep, unsigned int& nParam);
  63. int  AttachPlayer(const unsigned long lnID, GUID* pGuid);
  64. void GetPlayerIndexByGuid(GUID* pGuid, int* pnIndex, int* plnID);
  65. void AddPlayerToWorld(int nIndex);
  66. void* PreparePlayerForExchange(int nIndex);
  67. void PreparePlayerForLoginFailed(int nIndex);
  68. void RemovePlayerForExchange(int nIndex);
  69. void RecoverPlayerExchange(int nIndex);
  70. int  AddCharacter(int nExtPoint, int nChangeExtPoint, void* pBuffer, GUID* pGuid);
  71. int  AddTempTaskValue(int nIndex, const char* pData);
  72. //向游戏发送操作
  73. int  OperationRequest(unsigned int uOper, unsigned int uParam, int nParam);
  74. //获取连接状况
  75. int  GetConnectInfo(KCoreConnectInfo* pInfo);
  76. //BOOL ValidPingTime(int nIndex);
  77. //从游戏世界获取数据
  78. int  GetGameData(unsigned int uDataId, unsigned int uParam, int nParam);
  79. //日常活动，core如果要寿终正寝则返回0，否则返回非0值
  80. int  Breathe();
  81. //释放接口对象
  82. void Release();
  83. void SetSaveStatus(int nIndex, UINT uStatus);
  84. UINT GetSaveStatus(int nIndex);
  86. BOOL GroupChat(IClient* pClient, DWORD FromIP, unsigned long FromRelayID, DWORD channid, BYTE tgtcls, DWORD tgtid, const void* pData, size_t size);
  87. void SetLadder(void* pData, size_t uSize);
  88. BOOL PayForSpeech(int nIndex, int nType);
  89. private:
  90. int  OnLunch(LPVOID pServer);
  91. int  OnShutdown();
  92. };
  94. static CoreServerShell g_CoreServerShell;
  96. CORE_API void g_InitCore();
  98. #ifndef _STANDALONE
  99. extern "C" __declspec(dllexport)
  100. #endif
  101. iCoreServerShell* CoreGetServerShell()
  102. {
  103. g_InitCore();
  104. return &g_CoreServerShell;
  105. }
  107. void CoreServerShell::Release()
  108. {
  109. g_ReleaseCore();
  110. }
  112. int CoreServerShell::GetLoopRate()
  113. {
  114. return g_SubWorldSet.m_nLoopRate;
  115. }
  117. //获取连接状况
  118. int  CoreServerShell::GetConnectInfo(KCoreConnectInfo* pInfo)
  119. {
  120. if (pInfo)
  121. pInfo->nNumPlayer = PlayerSet.GetPlayerNumber();
  122. return 1;
  123. }
  126. int CoreServerShell::AddCharacter(int nExtPoint, int nChangeExtPoint, void* pBuffer, GUID* pGuid)
  127. {
  128. int nIdx = 0;
  129. const TRoleData* pData = (const TRoleData*)pBuffer;
  131. if (pData && pData->BaseInfo.szName[0])
  132. {
  133. nIdx = PlayerSet.Add((char*)pData->BaseInfo.szName, pGuid);
  134. if (nIdx <= 0 || nIdx >= MAX_PLAYER)
  135. return 0;
  136. strcpy(Player[nIdx].m_AccoutName, pData->BaseInfo.caccname);
  137. strcpy(Player[nIdx].m_PlayerName, pData->BaseInfo.szName);
  138. DWORD dwLen = pData->dwDataLen;
  139. // _ASSERT(dwLen < 64 * 1024);
  140. ZeroMemory(Player[nIdx].m_SaveBuffer, sizeof(Player[nIdx].m_SaveBuffer));
  141. memcpy(Player[nIdx].m_SaveBuffer, pBuffer, dwLen);
  143. Player[nIdx].m_pStatusLoadPlayerInfo = Player[nIdx].m_SaveBuffer;
  144. // 扩展点，用于活动
  145. Player[nIdx].SetExtPoint(nExtPoint, nChangeExtPoint);
  146. return nIdx;
  147. }
  148. return 0;
  149. }
  151. bool CoreServerShell::PlayerDbLoading(int nPlayerIndex, int bSyncEnd, int& nStep, unsigned int& nParam)
  152. {
  153. TRoleData* pData = (TRoleData *)Player[nPlayerIndex].m_pStatusLoadPlayerInfo;
  155. if (bSyncEnd)
  156. {
  157. Player[nPlayerIndex].m_pStatusLoadPlayerInfo = NULL;
  158. nStep = 0;
  159. nParam = 0;
  161. return true;
  162. }
  163. else if (pData)
  164. {
  165. // if (0 == Player[nPlayerIndex].LoadDBPlayerInfo((BYTE *)pData, nStep, nParam))
  166. // {
  167. // // 把玩家的登入状态设置为未登入，等待时延自动清除
  168. // Player[nPlayerIndex].m_nNetConnectIdx = -1;
  169. // Player[nPlayerIndex].m_dwLoginTime = -1;
  170. // return false;
  171. // }
  172. // else
  173. // return true;
  174. return Player[nPlayerIndex].LoadDBPlayerInfo((BYTE *)pData, nStep, nParam);
  175. }
  176. return false;
  177. }
  179. void CoreServerShell::AddPlayerToWorld(int nIndex)
  180. {
  181. // int nIndex = PlayerSet.FindClient(lnID);
  182. Player[nIndex].LaunchPlayer();
  183. }
  185. void CoreServerShell::ProcessClientMessage(int nIndex, const char* pChar, int nSize)
  186. {
  187. PlayerSet.ProcessClientMessage(nIndex, pChar, nSize);
  188. }
  190. void CoreServerShell::ProcessNewClientMessage(IClient* pTransfer,
  191.    DWORD dwFromIP, DWORD dwFromRelayID,
  192.    int nPlayerIndex,
  193.    const char* pChar, int nSize)
  194. {
  195. g_NewProtocolProcess.ProcessNetMsg(pTransfer, dwFromIP, dwFromRelayID,
  196. nPlayerIndex, (BYTE*)pChar, nSize);
  198. }
  200. void CoreServerShell::SendNetMsgToTransfer(IClient* pClient)
  201. {
  202. g_NewProtocolProcess.SendNetMsgToTransfer(pClient);
  203. }
  205. void CoreServerShell::SendNetMsgToChat(IClient* pClient)
  206. {
  207. g_NewProtocolProcess.SendNetMsgToChat(pClient);
  208. }
  210. void CoreServerShell::SendNetMsgToTong(IClient* pClient)
  211. {
  212. g_NewProtocolProcess.SendNetMsgToTong(pClient);
  213. }
  215. void CoreServerShell::ProcessBroadcastMessage(const char* pChar, int nSize)
  216. {
  217. g_NewProtocolProcess.BroadcastLocalServer(pChar, nSize);
  218. }
  220. void CoreServerShell::ProcessExecuteMessage(const char* pChar, int nSize)
  221. {
  222. g_NewProtocolProcess.ExecuteLocalServer(pChar, nSize);
  223. }
  225. void CoreServerShell::ClientDisconnect(int nIndex)
  226. {
  227. // PlayerSet.Remove(nClient);
  228. PlayerSet.PrepareRemove(nIndex);
  229. }
  231. void CoreServerShell::RemoveQuitingPlayer(int nIndex)
  232. {
  233. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  234. return;
  236. if (Player[nIndex].IsWaitingRemove())
  237. {
  238. PlayerSet.RemoveQuiting(nIndex);
  239. }
  240. }
  241. //--------------------------------------------------------------------------
  242. // 功能：从游戏世界获取数据
  243. // 参数：unsigned int uDataId --> 表示获取游戏数据的数据项内容索引，其值为梅举类型
  244. // GAMEDATA_INDEX的取值之一。
  245. //   unsigned int uParam  --> 依据uDataId的取值情况而定
  246. //   int nParam --> 依据uDataId的取值情况而定
  247. // 返回：依据uDataId的取值情况而定。
  248. //--------------------------------------------------------------------------
  249. int CoreServerShell::GetGameData(unsigned int uDataId, unsigned int uParam, int nParam)
  250. {
  251. int nRet = 0;
  252. switch(uDataId)
  253. {
  254. case SGDI_CHARACTER_ACCOUNT:
  255. if (uParam)
  256. {
  257. nRet = PlayerSet.GetPlayerAccount(nParam, (char *)uParam);
  258. if (nRet == FALSE)
  259. ((char *)uParam)[0] = 0;
  260. }
  261. break;
  262. case SGDI_CHARACTER_NAME:
  263. if (uParam)
  264. {
  265. nRet = PlayerSet.GetPlayerName(nParam, (char*)uParam);
  266. if (nRet == FALSE)
  267. ((char *)uParam)[0] = 0;
  268. }
  269. break;
  270. case SGDI_CHARACTER_EXTPOINTCHANGED:
  271. if (uParam)
  272. {
  273. if (uParam >= MAX_PLAYER)
  274. {
  275. nRet = 0;
  276. break;
  277. }
  278. nRet = Player[uParam].GetExtPointChanged();
  279. }
  280. break;
  281. case SGDI_CHARACTER_EXTPOINT:
  282. if (uParam)
  283. {
  284. if (uParam >= MAX_PLAYER)
  285. {
  286. nRet = 0;
  287. break;
  288. }
  289. nRet = Player[uParam].GetExtPoint();
  290. }
  291. break;
  292. case SGDI_LOADEDMAP_ID:
  293. if (uParam)
  294. {
  295. int i;
  296. int nMax = nParam;
  297. if(nMax < MAX_SUBWORLD) nMax = MAX_SUBWORLD;
  298. for (i = 0; i < nMax; i++)
  299. {
  300. if (SubWorld[i].m_SubWorldID != -1)
  301. {
  302. ((char *)uParam)[i] = (char)SubWorld[i].m_SubWorldID;
  303. }
  304. else
  305. {
  306. nRet = i;
  307. break;
  308. }
  309. }
  310. }
  311. break;
  312. case SGDI_CHARACTER_ID:
  313. if (uParam)
  314. {
  315. if (uParam >= MAX_PLAYER)
  316. {
  317. nRet = 0;
  318. break;
  319. }
  321. nRet = Player[uParam].m_dwID;
  322. break;
  323. }
  324. break;
  325. case SGDI_CHARACTER_NETID:
  326. if (uParam)
  327. {
  328. if (uParam >= MAX_PLAYER)
  329. {
  330. nRet = -1;
  331. break;
  332. }
  333. nRet = Player[uParam].m_nNetConnectIdx;
  334. }
  335. break;
  337. // 传入帮会建立参数，返回条件是否成立
  338. // uParam : struct STONG_SERVER_TO_CORE_APPLY_CREATE point
  339. // return : 条件是否成立
  340. case SGDI_TONG_APPLY_CREATE:
  341. if (uParam)
  342. {
  343. STONG_SERVER_TO_CORE_APPLY_CREATE *pApply = (STONG_SERVER_TO_CORE_APPLY_CREATE*)uParam;
  345. int nPlayerIdx;
  346. int nCamp;
  347. char szTongName[defTONG_NAME_MAX_LENGTH + 2];
  349. szTongName[sizeof(szTongName) - 1] = 0;
  350. memcpy(szTongName, pApply->m_szTongName, sizeof(szTongName));
  351. nPlayerIdx = pApply->m_nPlayerIdx;
  352. nCamp = pApply->m_nCamp;
  354. if (nPlayerIdx <= 0 || nPlayerIdx >= MAX_PLAYER)
  355. {
  356. nRet = FALSE;
  357. break;
  358. }
  359. nRet = Player[nPlayerIdx].m_cTong.CheckCreateCondition(nCamp, szTongName);
  360. }
  361. break;
  363. // 申请加入帮会
  364. // uParam : struct STONG_SERVER_TO_CORE_APPLY_ADD point
  365. case SGDI_TONG_APPLY_ADD:
  366. if (uParam)
  367. {
  368. STONG_SERVER_TO_CORE_APPLY_ADD *pAdd = (STONG_SERVER_TO_CORE_APPLY_ADD*)uParam;
  369. if (pAdd->m_nPlayerIdx <= 0 || pAdd->m_nPlayerIdx >= MAX_PLAYER)
  370. break;
  371. Player[pAdd->m_nPlayerIdx].m_cTong.TransferAddApply(pAdd->m_dwNpcID);
  372. }
  373. break;
  375. // 判断加入帮会条件是否合适
  376. // uParam : 传入得 char point ，用于接收帮会名称
  377. // nParam : struct STONG_SERVER_TO_CORE_CHECK_ADD_CONDITION point
  378. case SGDI_TONG_CHECK_ADD_CONDITION:
  379. {
  380. nRet = 0;
  381. STONG_SERVER_TO_CORE_CHECK_ADD_CONDITION *pAdd;
  382. pAdd = (STONG_SERVER_TO_CORE_CHECK_ADD_CONDITION*)nParam;
  383. if (pAdd->m_nSelfIdx <= 0 || pAdd->m_nSelfIdx >= MAX_PLAYER)
  384. break;
  385. if (pAdd->m_nTargetIdx <= 0 || pAdd->m_nTargetIdx >= MAX_PLAYER || g_FileName2Id(Npc[Player[pAdd->m_nTargetIdx].m_nIndex].Name) != pAdd->m_dwNameID)
  386. break;
  387. if (Player[pAdd->m_nSelfIdx].m_cTong.CheckAddCondition(pAdd->m_nTargetIdx))
  388. {
  389. Player[pAdd->m_nSelfIdx].m_cTong.GetTongName((char*)uParam);
  390. nRet = 1;
  391. }
  392. }
  393. break;
  395. // 获得帮会信息
  396. // uParam : 传入的 STONG_SERVER_TO_CORE_GET_INFO point
  397. case SGDI_TONG_GET_INFO:
  398. {
  399. STONG_SERVER_TO_CORE_GET_INFO *pInfo = (STONG_SERVER_TO_CORE_GET_INFO*)uParam;
  400. switch (pInfo->m_nInfoID)
  401. {
  402. case enumTONG_APPLY_INFO_ID_SELF:
  403. {
  404. if (pInfo->m_nSelfIdx <= 0 || pInfo->m_nSelfIdx >= MAX_PLAYER)
  405. break;
  406. Player[pInfo->m_nSelfIdx].m_cTong.SendSelfInfo();
  407. }
  408. break;
  409. case enumTONG_APPLY_INFO_ID_MASTER:
  410. break;
  411. case enumTONG_APPLY_INFO_ID_DIRECTOR:
  412. break;
  413. case enumTONG_APPLY_INFO_ID_MANAGER:
  414. {
  415. nRet = 0;
  416. if (pInfo->m_nSelfIdx <= 0 || pInfo->m_nSelfIdx >= MAX_PLAYER)
  417. break;
  418. if (Player[pInfo->m_nSelfIdx].m_cTong.CanGetManagerInfo((DWORD)pInfo->m_nParam1))
  419. nRet = 1;
  420. }
  421. break;
  422. case enumTONG_APPLY_INFO_ID_MEMBER:
  423. {
  424. nRet = 0;
  425. if (pInfo->m_nSelfIdx <= 0 || pInfo->m_nSelfIdx >= MAX_PLAYER)
  426. break;
  427. if (Player[pInfo->m_nSelfIdx].m_cTong.CanGetMemberInfo((DWORD)pInfo->m_nParam1))
  428. nRet = 1;
  429. }
  430. break;
  431. case enumTONG_APPLY_INFO_ID_ONE:
  432. break;
  434. case enumTONG_APPLY_INFO_ID_TONG_HEAD:
  435. {
  436. nRet = 0;
  437. if (pInfo->m_nSelfIdx <= 0 || pInfo->m_nSelfIdx >= MAX_PLAYER)
  438. break;
  439. int nPlayer;
  440. if (Npc[Player[pInfo->m_nSelfIdx].m_nIndex].m_dwID == (DWORD)pInfo->m_nParam1)
  441. nPlayer = pInfo->m_nSelfIdx;
  442. else
  443. nPlayer = Player[pInfo->m_nSelfIdx].FindAroundPlayer((DWORD)pInfo->m_nParam1);
  444. if (nPlayer == -1)
  445. break;
  446. nRet = Player[nPlayer].m_cTong.GetTongNameID();
  447. }
  448. break;
  449. }
  450. }
  451. break;
  453. // 判断是否有任命权利
  454. // uParam : 传入的 TONG_APPLY_INSTATE_COMMAND point
  455. // nParam : PlayerIndex
  456. case SGDI_TONG_INSTATE_POWER:
  457. if (uParam)
  458. {
  459. nRet = 0;
  460. TONG_APPLY_INSTATE_COMMAND *pApply = (TONG_APPLY_INSTATE_COMMAND*)uParam;
  461. if (nParam <= 0 || nParam >= MAX_PLAYER)
  462. break;
  463. if (Player[nParam].m_nIndex <= 0)
  464. break;
  465. nRet = Player[nParam].m_cTong.CheckInstatePower(pApply);
  466. }
  467. break;
  469. // 被任命，帮会数据变化
  470. // uParam : 传入的 STONG_SERVER_TO_CORE_BE_INSTATED point
  471. case SGDI_TONG_BE_INSTATED:
  472. if (uParam)
  473. {
  474. STONG_SERVER_TO_CORE_BE_INSTATED *pInstated = (STONG_SERVER_TO_CORE_BE_INSTATED*)uParam;
  475. if (pInstated->m_nPlayerIdx <= 0 || pInstated->m_nPlayerIdx >= MAX_PLAYER)
  476. break;
  477. if (Player[pInstated->m_nPlayerIdx].m_nIndex <= 0)
  478. break;
  479. Player[pInstated->m_nPlayerIdx].m_cTong.BeInstated(pInstated);
  480. }
  481. break;
  483. // 判断是否有踢人权利
  484. // uParam : 传入的 TONG_APPLY_KICK_COMMAND point
  485. // nParam : PlayerIndex
  486. case SGDI_TONG_KICK_POWER:
  487. if (uParam)
  488. {
  489. nRet = 0;
  490. TONG_APPLY_KICK_COMMAND *pKick = (TONG_APPLY_KICK_COMMAND*)uParam;
  491. if (nParam <= 0 || nParam >= MAX_PLAYER)
  492. break;
  493. if (Player[nParam].m_nIndex <= 0)
  494. break;
  495. nRet = Player[nParam].m_cTong.CheckKickPower(pKick);
  496. }
  497. break;
  499. // 被踢出帮会
  500. // uParam : 传入的 STONG_SERVER_TO_CORE_BE_KICKED point
  501. case SGDI_TONG_BE_KICKED:
  502. if (uParam)
  503. {
  504. STONG_SERVER_TO_CORE_BE_KICKED *pKicked = (STONG_SERVER_TO_CORE_BE_KICKED*)uParam;
  505. if (pKicked->m_nPlayerIdx <= 0 || pKicked->m_nPlayerIdx >= MAX_PLAYER)
  506. break;
  507. if (Player[pKicked->m_nPlayerIdx].m_nIndex <= 0)
  508. break;
  509. Player[pKicked->m_nPlayerIdx].m_cTong.BeKicked(pKicked);
  510. }
  511. break;
  513. // 离开帮会
  514. // uParam : 传入的 TONG_APPLY_LEAVE_COMMAND point
  515. // nParam : PlayerIndex
  516. case SGDI_TONG_LEAVE_POWER:
  517. if (uParam)
  518. {
  519. nRet = 0;
  520. TONG_APPLY_LEAVE_COMMAND *pLeave = (TONG_APPLY_LEAVE_COMMAND*)uParam;
  521. if (nParam <= 0 || nParam >= MAX_PLAYER)
  522. break;
  523. if (Player[nParam].m_nIndex <= 0)
  524. break;
  525. nRet = Player[nParam].m_cTong.CheckLeavePower(pLeave);
  526. }
  527. break;
  529. // 离开帮会
  530. // uParam : 传入的 STONG_SERVER_TO_CORE_LEAVE point
  531. case SGDI_TONG_LEAVE:
  532. if (uParam)
  533. {
  534. STONG_SERVER_TO_CORE_LEAVE *pLeave = (STONG_SERVER_TO_CORE_LEAVE*)uParam;
  535. if (pLeave->m_nPlayerIdx <= 0 || pLeave->m_nPlayerIdx >= MAX_PLAYER)
  536. break;
  537. if (Player[pLeave->m_nPlayerIdx].m_nIndex <= 0)
  538. break;
  539. Player[pLeave->m_nPlayerIdx].m_cTong.Leave(pLeave);
  540. }
  541. break;
  543. // 离开帮会判断
  544. // uParam : 传入的 TONG_APPLY_CHANGE_MASTER_COMMAND point
  545. // nParam : PlayerIndex
  546. case SGDI_TONG_CHANGE_MASTER_POWER:
  547. if (uParam)
  548. {
  549. nRet = 0;
  550. TONG_APPLY_CHANGE_MASTER_COMMAND *pChange = (TONG_APPLY_CHANGE_MASTER_COMMAND*)uParam;
  551. if (nParam <= 0 || nParam >= MAX_PLAYER)
  552. break;
  553. if (Player[nParam].m_nIndex <= 0)
  554. break;
  555. nRet = Player[nParam].m_cTong.CheckChangeMasterPower(pChange);
  556. }
  557. break;
  559. // 能否接受传位判断
  560. // uParam : 传入的 STONG_SERVER_TO_CORE_CHECK_GET_MASTER_POWER point
  561. case SGDI_TONG_GET_MASTER_POWER:
  562. if (uParam)
  563. {
  564. nRet = 0;
  565. STONG_SERVER_TO_CORE_CHECK_GET_MASTER_POWER *pCheck = (STONG_SERVER_TO_CORE_CHECK_GET_MASTER_POWER*)uParam;
  566. if (pCheck->m_nPlayerIdx <= 0 || pCheck->m_nPlayerIdx >= MAX_PLAYER)
  567. break;
  568. if (Player[pCheck->m_nPlayerIdx].m_nIndex <= 0)
  569. break;
  570. nRet = Player[pCheck->m_nPlayerIdx].m_cTong.CheckGetMasterPower(pCheck);
  571. }
  572. break;
  574. // 传位导致身份改变
  575. // uParam : 传入的 STONG_SERVER_TO_CORE_CHANGE_AS point
  576. case SGDI_TONG_CHANGE_AS:
  577. if (uParam)
  578. {
  579. STONG_SERVER_TO_CORE_CHANGE_AS *pAs = (STONG_SERVER_TO_CORE_CHANGE_AS*)uParam;
  580. if (pAs->m_nPlayerIdx <= 0 || pAs->m_nPlayerIdx >= MAX_PLAYER)
  581. break;
  582. if (Player[pAs->m_nPlayerIdx].m_nIndex <= 0)
  583. break;
  584. Player[pAs->m_nPlayerIdx].m_cTong.ChangeAs(pAs);
  585. }
  586. break;
  588. // 帮主换了
  589. // uParam : 传入的 STONG_SERVER_TO_CORE_CHANGE_MASTER point
  590. case SGDI_TONG_CHANGE_MASTER:
  591. if (uParam)
  592. {
  593. STONG_SERVER_TO_CORE_CHANGE_MASTER *pChange = (STONG_SERVER_TO_CORE_CHANGE_MASTER*)uParam;
  594. int nIdx;
  595. nIdx = PlayerSet.GetFirstPlayer();
  596. while (nIdx)
  597. {
  598. if (Player[nIdx].m_cTong.GetTongNameID() == pChange->m_dwTongNameID)
  599. {
  600. Player[nIdx].m_cTong.ChangeMaster(pChange->m_szName);
  601. }
  602. nIdx = PlayerSet.GetNextPlayer();
  603. }
  604. }
  605. break;
  607. // 获得帮会名字符串转换成的 dword
  608. // nParam : PlayerIndex
  609. case SGDI_TONG_GET_TONG_NAMEID:
  610. {
  611. if (nParam <= 0 || nParam >= MAX_PLAYER)
  612. break;
  613. if (Player[nParam].m_nIndex <= 0)
  614. break;
  615. nRet = Player[nParam].m_cTong.GetTongNameID();
  616. }
  617. break;
  619. // 登陆时候获得帮会信息
  620. // uParam : 传入的 STONG_SERVER_TO_CORE_LOGIN point
  621. case SGDI_TONG_LOGIN:
  622. if (uParam)
  623. {
  624. STONG_SERVER_TO_CORE_LOGIN *pLogin = (STONG_SERVER_TO_CORE_LOGIN*)uParam;
  625. if (pLogin->m_dwParam <= 0 || pLogin->m_dwParam >= MAX_PLAYER)
  626. break;
  627. if (Player[pLogin->m_dwParam].m_nIndex <= 0)
  628. break;
  629. Player[pLogin->m_dwParam].m_cTong.Login(pLogin);
  630. }
  631. break;
  633. // 通知core发送某玩家的帮会信息
  634. // nParam : player index
  635. case SGDI_TONG_SEND_SELF_INFO:
  636. {
  637. if (nParam <= 0 || nParam >= MAX_PLAYER)
  638. break;
  639. if (Player[nParam].m_nIndex <= 0)
  640. break;
  641. Player[nParam].m_cTong.SendSelfInfo();
  642. }
  643. break;
  646. default:
  647. break;
  648. }
  649. return nRet;
  650. }
  652. //--------------------------------------------------------------------------
  653. // 功能：向游戏发送操作
  654. // 参数：unsigned int uDataId --> Core外部客户对core的操作请求的索引定义
  655. // 其值为梅举类型GAMEOPERATION_INDEX的取值之一。
  656. //   unsigned int uParam  --> 依据uOperId的取值情况而定
  657. //   int nParam --> 依据uOperId的取值情况而定
  658. // 返回：如果成功发送操作请求，函数返回非0值，否则返回0值。
  659. //--------------------------------------------------------------------------
  660. int CoreServerShell::OperationRequest(unsigned int uOper, unsigned int uParam, int nParam)
  661. {
  662. int nRet = 1;
  663. switch(uOper)
  664. {
  665. case SSOI_BROADCASTING:
  666. nRet = PlayerSet.Broadcasting((char*)uParam, nParam);
  667. break;
  668. case SSOI_LAUNCH: //启动服务
  669. nRet = OnLunch((LPVOID)uParam);
  670. break;
  671. case SSOI_SHUTDOWN: //关闭服务
  672. nRet = OnShutdown();
  673. break;
  674. case SSOI_RELOAD_WELCOME_MSG:
  675. PlayerSet.ReloadWelcomeMsg();
  676. break;
  678. // relay 帮会创建成功，通知 core 进行相应的处理
  679. case SSOI_TONG_CREATE:
  680. {
  681. STONG_SERVER_TO_CORE_CREATE_SUCCESS *pCreate = (STONG_SERVER_TO_CORE_CREATE_SUCCESS*)uParam;
  682. if (pCreate->m_nPlayerIdx <= 0 || pCreate->m_nPlayerIdx >= MAX_PLAYER)
  683. {
  684. nRet = 0;
  685. break;
  686. }
  687. if (Player[pCreate->m_nPlayerIdx].m_nIndex)
  688. {
  689. DWORD dwID = g_FileName2Id(Npc[Player[pCreate->m_nPlayerIdx].m_nIndex].Name);
  690. if (dwID != pCreate->m_dwPlayerNameID)
  691. {
  692. nRet = 0;
  693. break;
  694. }
  695. }
  696. else
  697. {
  698. nRet = 0;
  699. break;
  700. }
  701. nRet = Player[pCreate->m_nPlayerIdx].CreateTong(pCreate->m_nCamp, pCreate->m_szTongName);
  702. }
  703. break;
  705. case SSOI_TONG_REFUSE_ADD:
  706. if (uParam)
  707. {
  708. STONG_SERVER_TO_CORE_REFUSE_ADD *pRefuse = (STONG_SERVER_TO_CORE_REFUSE_ADD*)uParam;
  709. if (pRefuse->m_nSelfIdx > 0 && pRefuse->m_nSelfIdx <= MAX_PLAYER)
  710. {
  711. Player[pRefuse->m_nSelfIdx].m_cTong.SendRefuseMessage(pRefuse->m_nTargetIdx, pRefuse->m_dwNameID);
  712. }
  713. }
  714. break;
  716. case SSOI_TONG_ADD:
  717. if (uParam)
  718. {
  719. nRet = 0;
  720. STONG_SERVER_TO_CORE_ADD_SUCCESS *pAdd = (STONG_SERVER_TO_CORE_ADD_SUCCESS*)uParam;
  721. if (pAdd->m_nPlayerIdx <= 0 || pAdd->m_nPlayerIdx >= MAX_PLAYER)
  722. break;
  723. if (Player[pAdd->m_nPlayerIdx].m_nIndex <= 0)
  724. break;
  725. if (g_FileName2Id(Npc[Player[pAdd->m_nPlayerIdx].m_nIndex].Name) != pAdd->m_dwPlayerNameID)
  726. break;
  727. Player[pAdd->m_nPlayerIdx].m_cTong.AddTong(
  728. pAdd->m_nCamp,
  729. pAdd->m_szTongName,
  730. pAdd->m_szMasterName,
  731. pAdd->m_szTitleName);
  732. }
  733. break;
  735. default:
  736. nRet = 0;
  737. break;
  738. }
  739. return nRet;
  740. }
  742. int CoreServerShell::OnLunch(LPVOID pServer)
  743. {
  744. g_SetServer(pServer);
  746. // g_SetFilePath("\script");
  747. KLuaScript * pStartScript =(KLuaScript*) g_GetScript("\script\ServerScript.lua");
  748. int i = 0;
  750. if (!pStartScript)
  751. g_DebugLog("Load ServerScript failed!");
  752. else
  753. {
  754. pStartScript->CallFunction("StartGame",0,"");
  755. }
  757. PlayerSet.ReloadWelcomeMsg();
  759. return true;
  760. }
  762. int CoreServerShell::OnShutdown()
  763. {
  764. return true;
  765. }
  767. //日常活动，core如果要寿终正寝则返回0，否则返回非0值
  768. int CoreServerShell::Breathe()
  769. {
  770. g_SubWorldSet.MessageLoop();
  771. g_SubWorldSet.MainLoop();
  772. return true;
  773. }
  775. bool CoreServerShell::CheckProtocolSize(const char* pChar, int nSize)
  776. {
  777. WORD wCheckSize;
  778. BYTE nProtocol = (BYTE)pChar[0];
  780. if (nProtocol >= c2s_end || nProtocol <= c2s_gameserverbegin)
  781. {
  782. g_DebugLog("[error]NetServer:Invalid Protocol!");
  783. return false;
  784. }
  786. if (g_nProtocolSize[nProtocol - c2s_gameserverbegin - 1] == -1)
  787. {
  788. wCheckSize = *(WORD*)&pChar[1] + PROTOCOL_MSG_SIZE;
  789. }
  790. else
  791. {
  792. wCheckSize = g_nProtocolSize[nProtocol - c2s_gameserverbegin - 1];
  793. }
  794. if (wCheckSize != nSize)
  795. {
  796. g_DebugLog("[error]网络接收协议大小不匹配");
  797. #ifndef _WIN32
  798. printf("[error]网络接收协议大小不匹配<%d>, should %d, but %dn", nProtocol, wCheckSize, nSize);
  799. #endif
  800. return false;
  801. }
  802. return true;
  803. }
  806. int CoreServerShell::AttachPlayer(const unsigned long lnID, GUID* pGuid)
  807. {
  808. return PlayerSet.AttachPlayer(lnID, pGuid);
  809. }
  811. void* CoreServerShell::SavePlayerDataAtOnce(int nIndex)
  812. {
  813. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  814. {
  815. return NULL;
  816. }
  818. if (Player[nIndex].Save())
  819. {
  820. Player[nIndex].m_uMustSave = SAVE_REQUEST;
  821. return &Player[nIndex].m_SaveBuffer;
  822. }
  823. else
  824. {
  825. return NULL;
  826. }
  827. }
  829. bool CoreServerShell::IsCharacterQuiting(int nIndex)
  830. {
  831. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  832. {
  833. return FALSE;
  834. }
  835. return Player[nIndex].IsWaitingRemove();
  836. }
  838. bool CoreServerShell::IsPlayerLoginTimeOut(int nIndex)
  839. {
  840. return Player[nIndex].IsLoginTimeOut();
  841. }
  843. void CoreServerShell::RemovePlayerLoginTimeOut(int nIndex)
  844. {
  845. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  846. return;
  847. if (Player[nIndex].IsLoginTimeOut())
  848. {
  849. PlayerSet.RemoveLoginTimeOut(nIndex);
  850. }
  851. }
  854. int CoreServerShell::AddTempTaskValue(int nIndex, const char* pData)
  855. {
  856. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  857. return 0;
  859. return Player[nIndex].AddTempTaskValue((void *)pData);
  860. }
  862. void CoreServerShell::GetPlayerIndexByGuid(GUID* pGuid, int* pnIndex, int* plnID)
  863. {
  864. *pnIndex = PlayerSet.GetPlayerIndexByGuid(pGuid);
  865. if (*pnIndex)
  866. {
  867. *plnID = Player[*pnIndex].m_nNetConnectIdx;
  868. }
  869. else
  870. {
  871. *plnID = -1;
  872. }
  874. if (*plnID == -1)
  875. {
  876. *pnIndex = 0;
  877. }
  878. }
  880. void* CoreServerShell::PreparePlayerForExchange(int nIndex)
  881. {
  882. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  883. return NULL;
  884. PlayerSet.PrepareExchange(nIndex);
  885. return &Player[nIndex].m_SaveBuffer;
  886. }
  888. bool CoreServerShell::IsPlayerExchangingServer(int nIndex)
  889. {
  890. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  891. return false;
  893. return Player[nIndex].IsExchangingServer();
  894. }
  896. void CoreServerShell::RemovePlayerForExchange(int nIndex)
  897. {
  898. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  899. return;
  901. PlayerSet.RemoveExchanging(nIndex);
  902. }
  904. void CoreServerShell::GetGuid(int nIndex, void* pGuid)
  905. {
  906. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  907. return;
  908. memcpy(pGuid, &Player[nIndex].m_Guid, sizeof(GUID));
  909. }
  911. DWORD CoreServerShell::GetExchangeMap(int nIndex)
  912. {
  913. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  914. return -1;
  916. return Player[nIndex].m_sExchangePos.m_dwMapID;
  917. }
  919. void CoreServerShell::RecoverPlayerExchange(int nIndex)
  920. {
  921. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  922. return;
  924. Player[nIndex].m_bExchangeServer = FALSE;
  925. if (Player[nIndex].m_nIndex > 0)
  926. {
  927. KNpc* pNpc = &Npc[Player[nIndex].m_nIndex];
  928. pNpc->m_bExchangeServer = FALSE;
  929. pNpc->m_FightMode = pNpc->m_OldFightMode;
  930. }
  931. Player[nIndex].Earn(Player[nIndex].m_nPrePayMoney);
  932. Player[nIndex].m_nPrePayMoney = 0;
  933. }
  935. void CoreServerShell::SetSaveStatus(int nIndex, UINT uStatus)
  936. {
  937. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  938. return;
  940. Player[nIndex].m_uMustSave = uStatus;
  941. }
  943. UINT CoreServerShell::GetSaveStatus(int nIndex)
  944. {
  945. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  946. return SAVE_IDLE;
  948. return Player[nIndex].m_uMustSave;
  949. }
  952. void CoreServerShell::PreparePlayerForLoginFailed(int nIndex)
  953. {
  954. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  955. return;
  957. PlayerSet.PrepareLoginFailed(nIndex);
  958. }
  959. //BOOL CoreServerShell::ValidPingTime(int nIndex)
  960. //{
  961. // if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  962. // return FALSE;
  963. //
  964. // if (Player[nIndex].m_uLastPingTime == -1)
  965. // return TRUE;
  966. //
  967. //#define MAX_PING_TIME (60 * 20) // 1min
  968. // if (g_SubWorldSet.GetGameTime() - Player[nIndex].m_uLastPingTime > MAX_PING_TIME)
  969. // {
  970. // return FALSE;
  971. // }
  972. // return TRUE;
  973. //}
  975. BOOL CoreServerShell::GroupChat(IClient* pClient, DWORD FromIP, unsigned long FromRelayID, DWORD channid, BYTE tgtcls, DWORD tgtid, const void* pData, size_t size)
  976. {
  977. switch(tgtcls)
  978. {
  980. case tgtcls_team:
  981. {{
  982. if (tgtid < 0 || tgtid >= MAX_TEAM)
  983. return FALSE;
  985. size_t pckgsize = sizeof(tagExtendProtoHeader) + size;
  986. #ifdef WIN32
  987. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)_alloca(pckgsize);
  988. #else
  989. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)(new char[pckgsize]);
  990. #endif
  991. pExHeader->ProtocolType = s2c_extendchat;
  992. pExHeader->wLength = pckgsize - 1;
  993. memcpy(pExHeader + 1, pData, size);
  995. int nTargetIdx;
  996. // 给队长发
  997. nTargetIdx = g_Team[tgtid].m_nCaptain;
  998. // if (FromRelayID != Player[nTargetIdx].m_nNetConnectIdx)
  999. g_pServer->SendData(Player[nTargetIdx].m_nNetConnectIdx, pData, size);
  1000. // 给队员发
  1001. for (int i = 0; i < MAX_TEAM_MEMBER; i++)
  1002. {
  1003. nTargetIdx = g_Team[tgtid].m_nMember[i];
  1004. if (nTargetIdx < 0)
  1005. continue;
  1007. // if (FromRelayID != Player[nTargetIdx].m_nNetConnectIdx)
  1008. g_pServer->PackDataToClient(Player[nTargetIdx].m_nNetConnectIdx, pExHeader, pckgsize);
  1009. }
  1010. #ifndef WIN32
  1011. delete ((char*)pExHeader);
  1012. #endif
  1013. }}
  1014. break;
  1016. case tgtcls_fac:
  1017. {{
  1018. size_t pckgsize = sizeof(tagExtendProtoHeader) + size;
  1019. #ifdef WIN32
  1020. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)_alloca(pckgsize);
  1021. #else
  1022. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)(new char[pckgsize]);
  1023. #endif
  1024. pExHeader->ProtocolType = s2c_extendchat;
  1025. pExHeader->wLength = pckgsize - 1;
  1026. memcpy(pExHeader + 1, pData, size);
  1028. int nTargetIdx;
  1029. nTargetIdx = PlayerSet.GetFirstPlayer();
  1030. while (nTargetIdx)
  1031. {
  1032. if (Player[nTargetIdx].m_cFaction.m_nCurFaction == tgtid
  1033. )// && FromRelayID != Player[nTargetIdx].m_nNetConnectIdx)
  1034. g_pServer->PackDataToClient(Player[nTargetIdx].m_nNetConnectIdx, pExHeader, pckgsize);
  1036. nTargetIdx = PlayerSet.GetNextPlayer();
  1037. }
  1038. #ifndef WIN32
  1039. delete ((char*)pExHeader);
  1040. #endif
  1041. }}
  1042. break;
  1044. case tgtcls_tong:
  1045. {{
  1046. size_t pckgsize = sizeof(tagExtendProtoHeader) + size;
  1047. #ifdef WIN32
  1048. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)_alloca(pckgsize);
  1049. #else
  1050. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)(new char[pckgsize]);
  1051. #endif
  1052. pExHeader->ProtocolType = s2c_extendchat;
  1053. pExHeader->wLength = pckgsize - 1;
  1054. memcpy(pExHeader + 1, pData, size);
  1056. int nTargetIdx;
  1057. nTargetIdx = PlayerSet.GetFirstPlayer();
  1058. while (nTargetIdx)
  1059. {
  1060. if (Player[nTargetIdx].m_cTong.GetTongNameID() == tgtid
  1061. )// && FromRelayID != Player[nTargetIdx].m_nNetConnectIdx)
  1062. g_pServer->PackDataToClient(Player[nTargetIdx].m_nNetConnectIdx, pExHeader, pckgsize);
  1064. nTargetIdx = PlayerSet.GetNextPlayer();
  1065. }
  1066. #ifndef WIN32
  1067. delete ((char*)pExHeader);
  1068. #endif
  1069. }}
  1070. break;
  1072. case tgtcls_scrn:
  1073. {{
  1075. // int nMaxRelayPlayer = (1024 - 32 - sizeof(CHAT_GROUPMAN) - size) / sizeof(WORD);
  1076. // if (nMaxRelayPlayer <= 0)
  1077. // return FALSE;
  1080. int idxNPC = Player[tgtid].m_nIndex;
  1081. int idxSubWorld = Npc[idxNPC].m_SubWorldIndex;
  1082. int idxRegion = Npc[idxNPC].m_RegionIndex;
  1083. // _ASSERT(idxSubWorld >= 0 && idxRegion >= 0);
  1084. int nOX = Npc[idxNPC].m_MapX;
  1085. int nOY = Npc[idxNPC].m_MapY;
  1086. int nTX = 0;
  1087. int nTY = 0;
  1088. if (idxSubWorld < 0 || idxRegion < 0)
  1089. return FALSE;
  1092. // size_t basesize = sizeof(CHAT_GROUPMAN) + size;
  1093. // BYTE buffer[1024];
  1094. //
  1095. // CHAT_GROUPMAN* pCgc = (CHAT_GROUPMAN*)buffer;
  1096. // pCgc->ProtocolType = chat_groupman;
  1097. // pCgc->wChatLength = size;
  1098. // pCgc->byHasIdentify = false;
  1099. //
  1100. // void* pExPckg = pCgc + 1;
  1101. // memcpy(pExPckg, pData, size);
  1102. //
  1103. // WORD* pPlayers = (WORD*)((BYTE*)pExPckg + size);
  1104. //
  1105. //
  1106. // pCgc->wPlayerCount = 0;
  1109. size_t pckgsize = sizeof(tagExtendProtoHeader) + size;
  1110. #ifdef WIN32
  1111. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)_alloca(pckgsize);
  1112. #else
  1113. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)(new char[pckgsize]);
  1114. #endif
  1115. pExHeader->ProtocolType = s2c_extendchat;
  1116. pExHeader->wLength = pckgsize - 1;
  1117. memcpy(pExHeader + 1, pData, size);
  1119. #define MAX_SYNC_RANGE 23
  1120. static POINT POff[9] = 
  1121. {
  1122. {0, 0},
  1123. {0, 32},
  1124. {-16, 32},
  1125. {-16, 0},
  1126. {-16, -32},
  1127. {0, -32},
  1128. {16, -32},
  1129. {16, 0},
  1130. {16, 32},
  1131. };
  1133. KRegion* pRegionBase = &SubWorld[idxSubWorld].m_Region[idxRegion];
  1135. for (int i = -1; i < 8; i++)
  1136. {
  1137. KRegion* pRegion = NULL;
  1138. if (i < 0)
  1139. pRegion = pRegionBase;
  1140. else
  1141. {
  1142. if (pRegionBase->m_nConnectRegion[i] < 0)
  1143. continue;
  1144. pRegion = &SubWorld[idxSubWorld].m_Region[pRegionBase->m_nConnectRegion[i]];
  1145. }
  1146. if (pRegion == NULL)
  1147. continue;
  1150. KIndexNode *pNode = (KIndexNode *)pRegion->m_PlayerList.GetHead();
  1151. while(pNode)
  1152. {
  1153. // _ASSERT(pNode->m_nIndex > 0 && pNode->m_nIndex < MAX_PLAYER);
  1155. //if (FromRelayID != Player[pNode->m_nIndex].m_nNetConnectIdx)
  1156. {
  1157. int nTargetNpc = Player[pNode->m_nIndex].m_nIndex;
  1158. if (nTargetNpc > 0)
  1159. {
  1160. nTX = Npc[nTargetNpc].m_MapX + POff[i + 1].x;
  1161. nTY = Npc[nTargetNpc].m_MapY + POff[i + 1].y;
  1163. if ((nTX - nOX) * (nTX - nOX) + (nTY - nOY) * (nTY - nOY) < MAX_SYNC_RANGE * MAX_SYNC_RANGE)
  1164. g_pServer->PackDataToClient(Player[pNode->m_nIndex].m_nNetConnectIdx, pExHeader, pckgsize);
  1165. }
  1168. // pPlayers[pCgc->wPlayerCount] = (WORD)Player[pNode->m_nIndex].m_nNetConnectIdx;
  1169. // ++ pCgc->wPlayerCount;
  1170. //
  1171. // if (pCgc->wPlayerCount >= nMaxRelayPlayer)
  1172. // {
  1173. // size_t pckgsize = basesize + sizeof(WORD) * pCgc->wPlayerCount;
  1174. // pCgc->wSize = pckgsize - 1;
  1175. //
  1176. // pClient->SendPackToServer(pCgc, pckgsize);
  1177. //
  1178. // pCgc->wPlayerCount = 0;
  1179. // }
  1180. }
  1182. pNode = (KIndexNode *)pNode->GetNext();
  1183. }
  1184. }
  1186. // if (pCgc->wPlayerCount > 0)
  1187. // {
  1188. // size_t pckgsize = basesize + sizeof(WORD) * pCgc->wPlayerCount;
  1189. // pCgc->wSize = pckgsize - 1;
  1190. //
  1191. // pClient->SendPackToServer(pCgc, pckgsize);
  1192. // }
  1194. #ifndef WIN32
  1195. delete (char*)pExHeader;
  1196. #endif
  1197. }}
  1198. break;
  1201. case tgtcls_bc:
  1202. {{
  1203. size_t pckgsize = sizeof(tagExtendProtoHeader) + size;
  1204. #ifdef WIN32
  1205. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)_alloca(pckgsize);
  1206. #else
  1207. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)(new char[pckgsize]);
  1208. #endif
  1209. pExHeader->ProtocolType = s2c_extendchat;
  1210. pExHeader->wLength = pckgsize - 1;
  1211. memcpy(pExHeader + 1, pData, size);
  1213. int nTargetIdx;
  1214. nTargetIdx = PlayerSet.GetFirstPlayer();
  1215. while (nTargetIdx)
  1216. {
  1217. g_pServer->PackDataToClient(Player[nTargetIdx].m_nNetConnectIdx, pExHeader, pckgsize);
  1219. nTargetIdx = PlayerSet.GetNextPlayer();
  1220. }
  1221. #ifndef WIN32
  1222. delete ((char*)pExHeader);
  1223. #endif
  1224. }}
  1225. break;
  1228. default:
  1229. break;
  1230. }
  1231. return TRUE;
  1232. }
  1234. void CoreServerShell::SetLadder(void* pData, size_t uSize)
  1235. {
  1236. Ladder.Init(pData, uSize);
  1237. }
  1239. BOOL CoreServerShell::PayForSpeech(int nIndex, int nType)
  1240. {
  1241. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  1242. return FALSE;
  1244. int nMoney = 0;
  1245. int nNpcIdx = Player[nIndex].m_nIndex;
  1246. if (nNpcIdx <= 0)
  1247. return FALSE;
  1248. if (Player[nIndex].m_nForbiddenFlag & KPlayer::FF_CHAT) //被禁言
  1249. return FALSE;
  1250. int nLevel = Npc[nNpcIdx].m_Level;
  1251. int nMaxMana = Npc[nNpcIdx].m_CurrentManaMax;
  1252. switch (nType)
  1253. {
  1254. case 0: //免费
  1255. return TRUE;
  1256. break;
  1257. case 1: //10元每句
  1258. {
  1259. nMoney = 10;
  1260. return Player[nIndex].Pay(nMoney);
  1261. }
  1262. break;
  1263. case 2: //2: <10Lv ? 不能说 : MaxMana/2/句
  1264. {
  1265. if (nLevel < 10)
  1266. return FALSE;
  1267. return Npc[nNpcIdx].Cost(attrib_mana, nMaxMana / 2);
  1268. }
  1269. break;
  1270. case 3: //3: MaxMana/10/句
  1271. {
  1272. return Npc[nNpcIdx].Cost(attrib_mana, nMaxMana / 10);
  1273. }
  1274. break;
  1275. case 4: //4: <20Lv ? 不能说 : MaxMana*4/5/句
  1276. {
  1277. if (nLevel < 20)
  1278. return FALSE;
  1279. return Npc[nNpcIdx].Cost(attrib_mana, nMaxMana * 4 / 5);
  1280. }
  1281. break;
  1282. default:
  1283. return FALSE; //不认识的类别不发送
  1284. }
  1285. }