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

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

模拟服务器

开发平台：

C/C++

KPlayerSet.cpp：源码内容
  1. //#include <objbase.h>
  2. //#include <crtdbg.h>
  3. #include "KCore.h"
  4. #include "KPlayer.h"
  5. #include "KNpc.h"
  6. #include "KNpcSet.h"
  7. #include "KSubWorld.h"
  8. #include "GameDataDef.h"
  9. #include "KProtocolProcess.h"
  10. #ifdef _SERVER
  11. //#include "KNetServer.h"
  12. //#include "../MultiServer/Heaven/Interface/iServer.h"
  13. #include "KSubWorldSet.h"
  14. #include "CoreServerShell.h"
  15. #endif
  16. #include "KPlayerSet.h"
  17. #include "Text.h"
  18. #include "CoreUseNameDef.h"
  20. #define PLAYER_FIRST_LUCKY 0
  22. KPlayerSet PlayerSet;
  24. KPlayerSet::KPlayerSet()
  25. {
  26. #ifdef _SERVER
  27. m_pWelcomeMsg = NULL;
  28. m_ulNextSaveTime = 0;
  29. m_ulDelayTimePerSave = 0;
  30. m_ulMaxSaveTimePerPlayer = 0;
  31. #endif
  32. }
  34. BOOL KPlayerSet::Init()
  35. {
  36. int i;
  38. #ifdef _SERVER
  39. m_nNumPlayer = 0;
  40. m_ulNextSaveTime = 0;
  41. m_ulMaxSaveTimePerPlayer = 60 * 20 * 30;
  42. m_ulDelayTimePerSave = m_ulMaxSaveTimePerPlayer / MAX_PLAYER;
  43. #endif
  45. // 优化查找表
  46. m_FreeIdx.Init(MAX_PLAYER);
  47. m_UseIdx.Init(MAX_PLAYER);
  49. // 开始时所有的数组元素都为空
  50. for (i = MAX_PLAYER - 1; i > 0; i--)
  51. {
  52. m_FreeIdx.Insert(i);
  53. }
  55. if ( !m_cLevelAdd.Init() )
  56. return FALSE;
  57. if ( !m_cLeadExp.Init() )
  58. return FALSE;
  59. for (i = 0; i < MAX_PLAYER; i++)
  60. {
  61. Player[i].Release();
  62. Player[i].SetPlayerIndex(i);
  63. #ifdef _SERVER
  64. Player[i].m_cPK.Init(i);
  65. #endif
  66. Player[i].m_cTong.Init(i);
  67. Player[i].m_ItemList.Init(i);
  68. Player[i].m_Node.m_nIndex = i;
  69. }
  71. if ( !m_cNewPlayerAttribute.Init() )
  72. return FALSE;
  74. #ifdef _SERVER
  76. KTabFile cPKParam;
  78. memset(m_sPKPunishParam, 0, sizeof(m_sPKPunishParam));
  79. // g_SetFilePath("\");
  80. if (!cPKParam.Load(defPK_PUNISH_FILE))
  81. return FALSE;
  82. for (i = 0; i < MAX_DEATH_PUNISH_PK_VALUE + 1; i++)
  83. {
  84. cPKParam.GetInteger(i + 2, 2, 1, &m_sPKPunishParam[i].m_nExp);
  85. cPKParam.GetInteger(i + 2, 3, 1, &m_sPKPunishParam[i].m_nMoney);
  86. cPKParam.GetInteger(i + 2, 4, 1, &m_sPKPunishParam[i].m_nItem);
  87. cPKParam.GetInteger(i + 2, 5, 1, &m_sPKPunishParam[i].m_nEquip);
  88. }
  89. #endif
  91. // 帮会参数
  92. KIniFile cTongFile;
  93. if (cTongFile.Load(defPLAYER_TONG_PARAM_FILE))
  94. {
  95. cTongFile.GetInteger("TongCreate", "Level", 60, &m_sTongParam.m_nLevel);
  96. cTongFile.GetInteger("TongCreate", "LeadLevel", 10, &m_sTongParam.m_nLeadLevel);
  97. cTongFile.GetInteger("TongCreate", "Money", 500000, &m_sTongParam.m_nMoney);
  98. }
  99. else
  100. {
  101. m_sTongParam.m_nLevel = 60;
  102. m_sTongParam.m_nLeadLevel = 10;
  103. m_sTongParam.m_nMoney = 500000;
  104. }
  106. return TRUE;
  107. }
  109. int KPlayerSet::FindFree()
  110. {
  111. return m_FreeIdx.GetNext(0);
  112. }
  114. int KPlayerSet::FindSame(DWORD dwID)
  115. {
  116. int nUseIdx = 0;
  118. nUseIdx = m_UseIdx.GetNext(0);
  119. while(nUseIdx)
  120. {
  121. if (Player[nUseIdx].m_dwID == dwID)
  122. return nUseIdx;
  123. nUseIdx = m_UseIdx.GetNext(nUseIdx);
  124. }
  125. return 0;
  126. }
  128. int KPlayerSet::GetFirstPlayer()
  129. {
  130. m_nListCurIdx = m_UseIdx.GetNext(0);
  131. return m_nListCurIdx;
  132. }
  134. int KPlayerSet::GetNextPlayer()
  135. {
  136. if ( !m_nListCurIdx )
  137. return 0;
  138. m_nListCurIdx = m_UseIdx.GetNext(m_nListCurIdx);
  139. return m_nListCurIdx;
  140. }
  142. #ifdef _SERVER
  143. int KPlayerSet::Add(LPSTR szPlayerID, void* pGuid)
  144. {
  145. if (!pGuid || !szPlayerID || !szPlayerID[0])
  146. return 0;
  148. int i;
  149. /*
  150. DWORD dwID = g_FileName2Id(szPlayerID);
  151. i = FindSame(dwID);
  152. if (i)
  153. return 0;
  154. */
  155. DWORD dwID = g_FileName2Id(szPlayerID);
  157. i = FindFree();
  159. if (i)
  160. {
  161. Player[i].m_dwID = dwID;
  162. Player[i].m_nNetConnectIdx = -1;
  163. Player[i].m_dwLoginTime = g_SubWorldSet.GetGameTime();
  164. memcpy(&Player[i].m_Guid, pGuid, sizeof(GUID));
  165. Player[i].SetPlayerIndex(i);
  166. m_FreeIdx.Remove(i);
  167. m_UseIdx.Insert(i);
  168. m_nNumPlayer ++;
  169. return i;
  170. }
  171. return 0;
  172. }
  174. int KPlayerSet::Broadcasting(char* pMessage, int nLen)
  175. {
  176. if ( !pMessage || nLen <= 0 || nLen >= MAX_SENTENCE_LENGTH)
  177. return 0;
  178. if (!g_pServer)
  179. return 0;
  180. g_pServer->PreparePackSink();
  181. KPlayerChat::SendSystemInfo(0, 0, MESSAGE_SYSTEM_ANNOUCE_HEAD, pMessage, nLen);
  182. g_pServer->SendPackToClient(-1);
  183. return 1;
  184. }
  187. void KPlayerSet::SendWelcomeMsg(int nPlayerIndex)
  188. {
  189. //====通知有人加入====
  190. char szBuffer[MAX_SENTENCE_LENGTH];
  191. int nLength;
  192. static int nMsg = 0;
  193. const char* Msgs[3] =
  194. { "我<color=green>%s<color=restore>来也，你等快来朝拜。",
  195. "<color=green>%s<color=restore>脚踏凌波微步，飘然而至。",
  196. "一道闪光，<color=green>%s<color=restore>从天而降。" };
  198. memset(szBuffer, 0, sizeof(szBuffer));
  199. sprintf(szBuffer, Msgs[nMsg], Player[nPlayerIndex].m_PlayerName);
  200. nMsg++;
  201. nMsg %= 3;
  202. nLength = TEncodeText(szBuffer, strlen(szBuffer));
  203. KPlayerChat::SendSystemInfo(0, 0, MESSAGE_SYSTEM_ANNOUCE_HEAD, szBuffer, nLength);
  205. //====发送欢迎消息
  206. if (m_pWelcomeMsg)
  207. {
  208. int *pAMsg = (int*)m_pWelcomeMsg;
  209. int nCount =  *pAMsg;
  210. pAMsg ++;
  211. for (int i = 0; i < nCount; i++)
  212. {
  213. int nLen = *pAMsg;
  214. KPlayerChat::SendSystemInfo(1, nPlayerIndex, "吴府管家", (((char*)pAMsg) + sizeof(int)), nLen);
  215. pAMsg = (int*)(((char*)pAMsg) + nLen + sizeof(int));
  216. }
  217. }
  218. }
  220. void KPlayerSet::ReloadWelcomeMsg()
  221. {
  222. return;
  223. /*    欢迎信息文本文件格式要求：
  224. 每行为一条信息。  Msg:信息内容
  225. 控制信息内容的长度，使每条信息经过编码後长度不大于MAX_SENTENCE_LENGTH
  226. */
  228. if (m_pWelcomeMsg)
  229. {
  230. free (m_pWelcomeMsg);
  231. m_pWelcomeMsg = NULL;
  232. }
  233. KFile File;
  234. char Head[8];
  235. if (File.Open("\Msg\WelcomeMsg.txt") == FALSE)
  236. return;
  238. int nLen = File.Size();
  239. m_pWelcomeMsg = malloc(nLen + sizeof(int));
  240. if (m_pWelcomeMsg == NULL)
  241. return;
  243. *(int*)m_pWelcomeMsg = 0;
  244. char* pSearchBegin = (char*)m_pWelcomeMsg + sizeof(int);
  245. int* pLineHeader = (int*)pSearchBegin;
  246. File.Read(pLineHeader, nLen);
  247. File.Close();
  249. char* pMsgHeader;
  250. while(pMsgHeader = (char*)memchr(pSearchBegin, ':', nLen))
  251. {
  252. pMsgHeader++; //跳过那个冒号
  253. nLen -= pMsgHeader -pSearchBegin; //冒号后的剩余长度
  254. if (nLen <= 0)
  255. break;
  256. int nSkipLen = pMsgHeader - (char*)pLineHeader - sizeof(int);
  257. pSearchBegin = pMsgHeader;
  258. if (nSkipLen < 0)
  259. continue;
  260. if (nSkipLen > 0)
  261. memset(&pLineHeader[1], 0, nSkipLen);
  262. char* pMsgTail = (char*)memchr(pSearchBegin, 0x0d, nLen); //查找行结尾
  263. int nMsgLen;
  264. if (pMsgTail)
  265. {
  266. *pMsgTail = 0;
  267. pMsgTail++;
  268. if ((pMsgTail < pSearchBegin + nLen) && *pMsgTail == 0x0a)
  269. {
  270. *pMsgTail = 0;
  271. pMsgTail++;
  272. }
  273. nMsgLen = pMsgTail - pSearchBegin;
  274. pSearchBegin = pMsgTail;
  275. }
  276. else
  277. {
  278. nMsgLen = nLen;
  279. }
  280. nLen -= nMsgLen;
  281. nMsgLen = TEncodeText((char*)&pLineHeader[1], nMsgLen + nSkipLen);
  282. if (nMsgLen > 0)
  283. {
  284. *pLineHeader = nMsgLen;
  285. pLineHeader = (int*)(((char*)pLineHeader) + sizeof(int) + (*pLineHeader));
  286. (*(int*)m_pWelcomeMsg) ++;
  287. }
  288. if (pMsgTail == NULL || nLen <= 0)
  289. break;
  290. }
  291. if ((int*)m_pWelcomeMsg == 0)
  292. {
  293. free(m_pWelcomeMsg);
  294. m_pWelcomeMsg = NULL;
  295. }
  296. }
  298. void KPlayerSet::PrepareRemove(int nIndex)
  299. {
  300. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  301. return;
  303. g_DebugLog("SERVER:Player[%s] has been removed!", Npc[Player[nIndex].m_nIndex].Name);
  304. // 通知聊天好友自己下线了
  305. Player[nIndex].m_cChat.OffLine(Player[nIndex].m_dwID);
  306. // 如果组队，离开队伍
  307. PLAYER_APPLY_LEAVE_TEAM sLeaveTeam;
  308. sLeaveTeam.ProtocolType = c2s_teamapplyleave;
  309. Player[nIndex].LeaveTeam((BYTE*)&sLeaveTeam);
  310. // 如果交易正在进行，取消交易
  311. TRADE_DECISION_COMMAND sTrade;
  312. sTrade.ProtocolType = c2s_tradedecision;
  313. sTrade.m_btDecision = 0;
  314. Player[nIndex].TradeDecision((BYTE*)&sTrade);
  315. // PK状态取消
  316. Player[nIndex].m_cPK.CloseAll();
  318. // Player[nIndex].Save();
  319. Player[nIndex].WaitForRemove();
  320. }
  322. void KPlayerSet::PrepareLoginFailed(int nIndex)
  323. {
  324. if (nIndex <= 0 || nIndex >= MAX_PLAYER)
  325. return;
  327. g_DebugLog("SERVER:Player[%s] has been removed!", Npc[Player[nIndex].m_nIndex].Name);
  328. // 通知聊天好友自己下线了
  329. Player[nIndex].m_cChat.OffLine(Player[nIndex].m_dwID);
  330. // 如果组队，离开队伍
  331. PLAYER_APPLY_LEAVE_TEAM sLeaveTeam;
  332. sLeaveTeam.ProtocolType = c2s_teamapplyleave;
  333. Player[nIndex].LeaveTeam((BYTE*)&sLeaveTeam);
  334. // 如果交易正在进行，取消交易
  335. TRADE_DECISION_COMMAND sTrade;
  336. sTrade.ProtocolType = c2s_tradedecision;
  337. sTrade.m_btDecision = 0;
  338. Player[nIndex].TradeDecision((BYTE*)&sTrade);
  339. // PK状态取消
  340. Player[nIndex].m_cPK.CloseAll();
  341. // 帮会状态处理
  342. Player[nIndex].m_cTong.Clear();
  344. // 利用TimeOut来清Player
  345. Player[nIndex].m_nNetConnectIdx = -1;
  346. Player[nIndex].m_dwLoginTime = 0;
  347. }
  349. void KPlayerSet::PrepareExchange(int i)
  350. {
  351. if (!Player[i].m_bExchangeServer || !Npc[Player[i].m_nIndex].m_bExchangeServer)
  352. return;
  354. // 清除PK状态
  355. Player[i].m_cPK.CloseAll();
  357. // 离队
  358. PLAYER_APPLY_LEAVE_TEAM sLeaveTeam;
  359. sLeaveTeam.ProtocolType = c2s_teamapplyleave;
  360. Player[i].LeaveTeam((BYTE*)&sLeaveTeam);
  362. // 如果交易正在进行，取消交易
  363. TRADE_DECISION_COMMAND sTrade;
  364. sTrade.ProtocolType = c2s_tradedecision;
  365. sTrade.m_btDecision = 0;
  366. Player[i].TradeDecision((BYTE*)&sTrade);
  368. Player[i].Save();
  369. // Player[i].UpdateEnterGamePos(Player[i].m_sExchangePos.m_dwMapID,
  370. // Player[i].m_sExchangePos.m_nX,
  371. // Player[i].m_sExchangePos.m_nY,
  372. // Npc[Player[i].m_nIndex].m_FightMode);
  373. }
  376. void KPlayerSet::RemoveQuiting(int nIndex)
  377. {
  378. if (Player[nIndex].m_nNetConnectIdx == -1 || Player[nIndex].m_dwID == 0)
  379. return;
  381. if (Player[nIndex].IsWaitingRemove())
  382. {
  383. if (Player[nIndex].m_nIndex > 0) // have npc
  384. {
  385. int nRegion = Npc[Player[nIndex].m_nIndex].m_RegionIndex;
  386. int nSubWorld = Npc[Player[nIndex].m_nIndex].m_SubWorldIndex;
  388. if (nSubWorld >= 0 && nRegion >= 0)
  389. {
  390. SubWorld[nSubWorld].RemovePlayer(nRegion, nIndex);
  391. SubWorld[nSubWorld].m_MissionArray.RemovePlayer(nIndex);
  392. SubWorld[nSubWorld].m_Region[nRegion].RemoveNpc(Player[nIndex].m_nIndex);
  393. SubWorld[nSubWorld].m_Region[nRegion].DecRef(Npc[Player[nIndex].m_nIndex].m_MapX, Npc[Player[nIndex].m_nIndex].m_MapY, obj_npc);
  394. }
  395. NpcSet.Remove(Player[nIndex].m_nIndex);
  396. }
  397. // 帮会状态处理
  398. Player[nIndex].m_cTong.Clear();
  400. Player[nIndex].m_ItemList.RemoveAll();
  401. Player[nIndex].m_dwID = 0;
  402. Player[nIndex].m_nIndex = 0;
  403. Player[nIndex].m_nNetConnectIdx = -1;
  404. Player[nIndex].Release();
  406. m_FreeIdx.Insert(nIndex);
  407. m_UseIdx.Remove(nIndex);
  408. m_nNumPlayer --;
  409. }
  410. }
  412. void KPlayerSet::RemoveLoginTimeOut(int nIndex)
  413. {
  414. if (Player[nIndex].IsLoginTimeOut())
  415. {
  416. if (Player[nIndex].m_nIndex > 0)
  417. {
  418. int nRegion = Npc[Player[nIndex].m_nIndex].m_RegionIndex;
  419. int nSubWorld = Npc[Player[nIndex].m_nIndex].m_SubWorldIndex;
  421. /* if (nSubWorld >= 0)
  422. SubWorld[nSubWorld].RemovePlayer(nRegion, nIndex);*/
  424. if (nSubWorld >= 0 && nRegion >= 0)
  425. {
  426. SubWorld[nSubWorld].m_Region[nRegion].RemoveNpc(Player[nIndex].m_nIndex);
  427. SubWorld[nSubWorld].m_Region[nRegion].DecRef(Npc[Player[nIndex].m_nIndex].m_MapX, Npc[Player[nIndex].m_nIndex].m_MapY, obj_npc);
  428. }
  429. NpcSet.Remove(Player[nIndex].m_nIndex);
  430. }
  431. Player[nIndex].m_ItemList.RemoveAll();
  432. Player[nIndex].m_dwID = 0;
  433. Player[nIndex].m_nIndex = 0;
  434. Player[nIndex].m_nNetConnectIdx = -1;
  435. Player[nIndex].LoginTimeOut();
  437. m_FreeIdx.Insert(nIndex);
  438. m_UseIdx.Remove(nIndex);
  439. m_nNumPlayer --;
  440. }
  441. }
  443. void KPlayerSet::RemoveExchanging(int nIndex)
  444. {
  445. if (Player[nIndex].m_nNetConnectIdx == -1)
  446. return;
  448. if (Player[nIndex].IsExchangingServer())
  449. {
  450. int nRegion = Npc[Player[nIndex].m_nIndex].m_RegionIndex;
  451. int nSubWorld = Npc[Player[nIndex].m_nIndex].m_SubWorldIndex;
  453. if (nSubWorld >= 0 && nRegion >= 0)
  454. {
  455. SubWorld[nSubWorld].RemovePlayer(nRegion, nIndex);
  456. SubWorld[nSubWorld].m_MissionArray.RemovePlayer(nIndex);
  457. SubWorld[nSubWorld].m_Region[nRegion].RemoveNpc(Player[nIndex].m_nIndex);
  458. SubWorld[nSubWorld].m_Region[nRegion].DecRef(Npc[Player[nIndex].m_nIndex].m_MapX, Npc[Player[nIndex].m_nIndex].m_MapY, obj_npc);
  459. }
  461. if (Player[nIndex].m_nIndex > 0)
  462. NpcSet.Remove(Player[nIndex].m_nIndex);
  464. Player[nIndex].m_ItemList.RemoveAll();
  465. Player[nIndex].m_dwID = 0;
  466. Player[nIndex].m_nIndex = 0;
  467. Player[nIndex].m_nNetConnectIdx = -1;
  468. Player[nIndex].Release();
  470. m_FreeIdx.Insert(nIndex);
  471. m_UseIdx.Remove(nIndex);
  472. m_nNumPlayer --;
  473. }
  474. }
  475. #endif
  477. /*
  478. int KPlayerSet::FindClient(int nClient)
  479. {
  480. int i;
  482. i = m_UseIdx.GetNext(0);
  483. while(i)
  484. {
  485. if (Player[i].m_nNetConnectIdx == nClient)
  486. return i;
  487. i = m_UseIdx.GetNext(i);
  488. }
  489. return 0;
  490. }
  491. */
  493. #ifdef _SERVER
  494. void KPlayerSet::ProcessClientMessage(int nIndex, const char* pChar, int nSize)
  495. {
  496. if (nIndex <= 0 && nIndex >= MAX_PLAYER)
  497. return;
  499. int i = Player[nIndex].m_nNetConnectIdx;
  501. if (i >= 0)
  502. {
  503. // _ASSERT(g_CoreServerShell.CheckProtocolSize(pChar, nSize));
  504. if (Player[nIndex].m_dwID && !Player[nIndex].m_bExchangeServer)
  505. g_ProtocolProcess.ProcessNetMsg(nIndex, (BYTE*)pChar);
  506. }
  507. }
  508. #endif
  510. //---------------------------------------------------------------------------
  511. // 功能：构造函数
  512. //---------------------------------------------------------------------------
  513. KLevelAdd::KLevelAdd()
  514. {
  515. memset(m_nLevelExp, 0, sizeof(int) * MAX_LEVEL);
  516. memset(m_nLifePerLevel, 0, sizeof(int) * series_num);
  517. memset(m_nManaPerLevel, 0, sizeof(int) * series_num);
  518. memset(m_nStaminaPerLevel, 0, sizeof(int) * series_num);
  519. memset(m_nLifePerVitality, 0, sizeof(int) * series_num);
  520. memset(m_nStaminaPerVitality, 0, sizeof(int) * series_num);
  521. memset(m_nManaPerEnergy, 0, sizeof(int) * series_num);
  522. }
  524. //---------------------------------------------------------------------------
  525. // 功能：初始化
  526. //---------------------------------------------------------------------------
  527. BOOL KLevelAdd::Init()
  528. {
  529. int i;
  530. KTabFile LevelExp;
  531. if ( !LevelExp.Load(PLAYER_LEVEL_EXP_FILE) )
  532. return FALSE;
  533. for (i = 0; i < MAX_LEVEL; i++)
  534. {
  535. LevelExp.GetInteger(i + 2, 2, 0, &m_nLevelExp[i]);
  536. }
  538. KTabFile LevelAdd;
  539. if ( !LevelAdd.Load(PLAYER_LEVEL_ADD_FILE) )
  540. return FALSE;
  541. for (i = 0; i < series_num; i++)
  542. {
  543. LevelAdd.GetInteger(i + 2, 2, 0, &m_nLifePerLevel[i]);
  544. LevelAdd.GetInteger(i + 2, 3, 0, &m_nStaminaPerLevel[i]);
  545. LevelAdd.GetInteger(i + 2, 4, 0, &m_nManaPerLevel[i]);
  546. LevelAdd.GetInteger(i + 2, 5, 0, &m_nLifePerVitality[i]);
  547. LevelAdd.GetInteger(i + 2, 6, 0, &m_nStaminaPerVitality[i]);
  548. LevelAdd.GetInteger(i + 2, 7, 0, &m_nManaPerEnergy[i]);
  549. LevelAdd.GetInteger(i + 2, 8, 0, &m_nLeadExpShare[i]);
  550. LevelAdd.GetInteger(i + 2, 9, 0, &m_nFireResistPerLevel[i]);
  551. LevelAdd.GetInteger(i + 2, 10, 0, &m_nColdResistPerLevel[i]);
  552. LevelAdd.GetInteger(i + 2, 11, 0, &m_nPoisonResistPerLevel[i]);
  553. LevelAdd.GetInteger(i + 2, 12, 0, &m_nLightResistPerLevel[i]);
  554. LevelAdd.GetInteger(i + 2, 13, 0, &m_nPhysicsResistPerLevel[i]);
  555. }
  557. return TRUE;
  558. }
  560. //---------------------------------------------------------------------------
  561. // 功能：获得某等级的升级经验
  562. // 参数：nLevel  目标等级
  563. //---------------------------------------------------------------------------
  564. int KLevelAdd::GetLevelExp(int nLevel)
  565. {
  566. if (nLevel < 1 || nLevel > MAX_LEVEL)
  567. return 0;
  568. return m_nLevelExp[nLevel - 1];
  569. }
  571. //---------------------------------------------------------------------------
  572. // 功能：获得每个系升级加生命点
  573. //---------------------------------------------------------------------------
  574. int KLevelAdd::GetLifePerLevel(int nSeries)
  575. {
  576. if (nSeries < 0 || nSeries >= series_num)
  577. return 0;
  578. return m_nLifePerLevel[nSeries];
  579. }
  581. //---------------------------------------------------------------------------
  582. // 功能：获得每个系升级加体力点
  583. //---------------------------------------------------------------------------
  584. int KLevelAdd::GetStaminaPerLevel(int nSeries)
  585. {
  586. if (nSeries < 0 || nSeries >= series_num)
  587. return 0;
  588. return m_nStaminaPerLevel[nSeries];
  589. }
  591. //---------------------------------------------------------------------------
  592. // 功能：获得每个系升级加内力点
  593. //---------------------------------------------------------------------------
  594. int KLevelAdd::GetManaPerLevel(int nSeries)
  595. {
  596. if (nSeries < 0 || nSeries >= series_num)
  597. return 0;
  598. return m_nManaPerLevel[nSeries];
  599. }
  601. //---------------------------------------------------------------------------
  602. // 功能：每个系活力点增加一点后生命点增长
  603. //---------------------------------------------------------------------------
  604. int KLevelAdd::GetLifePerVitality(int nSeries)
  605. {
  606. if (nSeries < 0 || nSeries >= series_num)
  607. return 0;
  608. return m_nLifePerVitality[nSeries];
  609. }
  611. //---------------------------------------------------------------------------
  612. // 功能：每个系活力点增加一点后体力点增长
  613. //---------------------------------------------------------------------------
  614. int KLevelAdd::GetStaminaPerVitality(int nSeries)
  615. {
  616. if (nSeries < 0 || nSeries >= series_num)
  617. return 0;
  618. return m_nStaminaPerVitality[nSeries];
  619. }
  621. //---------------------------------------------------------------------------
  622. // 功能：每个系精力点增加一点后内力点增长
  623. //---------------------------------------------------------------------------
  624. int KLevelAdd::GetManaPerEnergy(int nSeries)
  625. {
  626. if (nSeries < 0 || nSeries >= series_num)
  627. return 0;
  628. return m_nManaPerEnergy[nSeries];
  629. }
  631. //---------------------------------------------------------------------------
  632. // 功能：每个系精力点增加一点后内力点增长
  633. //---------------------------------------------------------------------------
  634. int KLevelAdd::GetLeadExpShare(int nSeries)
  635. {
  636. if (nSeries < 0 || nSeries >= series_num)
  637. return 0;
  638. return m_nLeadExpShare[nSeries];
  639. }
  641. //---------------------------------------------------------------------------
  642. // 功能：每个系某个等级的基本火抗性
  643. //---------------------------------------------------------------------------
  644. int KLevelAdd::GetFireResist(int nSeries, int nLevel)
  645. {
  646. if (nSeries < 0 || nSeries >= series_num)
  647. return 0;
  648. if (nLevel <= 0 || nLevel >= MAX_LEVEL)
  649. return 0;
  650. return (m_nFireResistPerLevel[nSeries] * nLevel / 100);
  651. }
  653. //---------------------------------------------------------------------------
  654. // 功能：每个系某个等级的基本冰抗性
  655. //---------------------------------------------------------------------------
  656. int KLevelAdd::GetColdResist(int nSeries, int nLevel)
  657. {
  658. if (nSeries < 0 || nSeries >= series_num)
  659. return 0;
  660. if (nLevel <= 0 || nLevel >= MAX_LEVEL)
  661. return 0;
  662. return (m_nColdResistPerLevel[nSeries] * nLevel / 100);
  663. }
  665. //---------------------------------------------------------------------------
  666. // 功能：每个系某个等级的基本毒抗性
  667. //---------------------------------------------------------------------------
  668. int KLevelAdd::GetPoisonResist(int nSeries, int nLevel)
  669. {
  670. if (nSeries < 0 || nSeries >= series_num)
  671. return 0;
  672. if (nLevel <= 0 || nLevel >= MAX_LEVEL)
  673. return 0;
  674. return (m_nPoisonResistPerLevel[nSeries] * nLevel / 100);
  675. }
  677. //---------------------------------------------------------------------------
  678. // 功能：每个系某个等级的基本电抗性
  679. //---------------------------------------------------------------------------
  680. int KLevelAdd::GetLightResist(int nSeries, int nLevel)
  681. {
  682. if (nSeries < 0 || nSeries >= series_num)
  683. return 0;
  684. if (nLevel <= 0 || nLevel >= MAX_LEVEL)
  685. return 0;
  686. return (m_nLightResistPerLevel[nSeries] * nLevel / 100);
  687. }
  689. //---------------------------------------------------------------------------
  690. // 功能：每个系某个等级的基本物理抗性
  691. //---------------------------------------------------------------------------
  692. int KLevelAdd::GetPhysicsResist(int nSeries, int nLevel)
  693. {
  694. if (nSeries < 0 || nSeries >= series_num)
  695. return 0;
  696. if (nLevel <= 0 || nLevel >= MAX_LEVEL)
  697. return 0;
  698. return (m_nPhysicsResistPerLevel[nSeries] * nLevel / 100);
  699. }
  701. //---------------------------------------------------------------------------
  702. // 功能：构造函数
  703. //---------------------------------------------------------------------------
  704. KTeamLeadExp::KTeamLeadExp()
  705. {
  706. for (int i = 0; i < MAX_LEAD_LEVEL; i++)
  707. {
  708. m_sPerLevel[i].m_dwExp = 0;
  709. m_sPerLevel[i].m_dwMemNum = 1;
  710. }
  711. }
  713. //---------------------------------------------------------------------------
  714. // 功能：初始化，读取统率力数据
  715. //---------------------------------------------------------------------------
  716. BOOL KTeamLeadExp::Init()
  717. {
  718. int i;
  719. KTabFile LevelExp;
  721. if ( !LevelExp.Load(PLAYER_LEVEL_LEAD_EXP_FILE) )
  722. return FALSE;
  723. for (i = 0; i < MAX_LEAD_LEVEL; i++)
  724. {
  725. LevelExp.GetInteger(i + 2, 2, 0, (int*)&m_sPerLevel[i].m_dwExp);
  726. LevelExp.GetInteger(i + 2, 3, 1, (int*)&m_sPerLevel[i].m_dwMemNum);
  727. }
  729. return TRUE;
  730. }
  732. //---------------------------------------------------------------------------
  733. // 功能：传入经验获得等级数
  734. //---------------------------------------------------------------------------
  735. int KTeamLeadExp::GetLevel(DWORD dwExp, int nCurLeadLevel)
  736. {
  737. if (dwExp <= 0)
  738. return 1;
  739. if (nCurLeadLevel > 0)
  740. {
  741. if (nCurLeadLevel >= MAX_LEAD_LEVEL)
  742. return MAX_LEAD_LEVEL;
  743. if (dwExp < m_sPerLevel[nCurLeadLevel - 1].m_dwExp)
  744. return nCurLeadLevel;
  745. if (dwExp < m_sPerLevel[nCurLeadLevel].m_dwExp)
  746. return nCurLeadLevel + 1;
  747. }
  748. for (int i = 0; i < MAX_LEAD_LEVEL; i++)
  749. {
  750. if (dwExp < m_sPerLevel[i].m_dwExp)
  751. {
  752. return i + 1;
  753. }
  754. }
  755. return MAX_LEAD_LEVEL;
  756. }
  758. //---------------------------------------------------------------------------
  759. // 功能：传入经验获得可带队员数
  760. //---------------------------------------------------------------------------
  761. int KTeamLeadExp::GetMemNumFromExp(DWORD dwExp)
  762. {
  763. int nGetLevel;
  764. nGetLevel = GetLevel(dwExp);
  765. return m_sPerLevel[nGetLevel - 1].m_dwMemNum;
  766. }
  768. //---------------------------------------------------------------------------
  769. // 功能：传入等级获得可带队员数
  770. //---------------------------------------------------------------------------
  771. int KTeamLeadExp::GetMemNumFromLevel(int nLevel)
  772. {
  773. if (1 <= nLevel && nLevel <= MAX_LEAD_LEVEL)
  774. return m_sPerLevel[nLevel - 1].m_dwMemNum;
  775. return 1;
  776. }
  778. //---------------------------------------------------------------------------
  779. // 功能：传入等级获得升级所需经验值
  780. //---------------------------------------------------------------------------
  781. int KTeamLeadExp::GetLevelExp(int nLevel)
  782. {
  783. if (1 <= nLevel && nLevel <= MAX_LEAD_LEVEL)
  784. return this->m_sPerLevel[nLevel - 1].m_dwExp;
  785. return 0;
  786. }
  788. #ifdef _SERVER
  789. void KPlayerSet::Activate()
  790. {
  791. }
  792. #endif
  794. KNewPlayerAttribute::KNewPlayerAttribute()
  795. {
  796. memset(m_nStrength, 0, sizeof(m_nStrength));
  797. memset(m_nDexterity, 0, sizeof(m_nDexterity));
  798. memset(m_nVitality, 0, sizeof(m_nVitality));
  799. memset(m_nEngergy, 0, sizeof(m_nEngergy));
  800. memset(m_nLucky, 0, sizeof(m_nLucky));
  801. }
  803. BOOL KNewPlayerAttribute::Init()
  804. {
  805. char szSeries[5][16] = {"metal", "wood", "water", "fire", "earth"};
  806. KIniFile AttributeFile;
  808. if ( !AttributeFile.Load(BASE_ATTRIBUTE_FILE_NAME) )
  809. return FALSE;
  811. for (int i = 0; i < series_num; i++)
  812. {
  813. AttributeFile.GetInteger(szSeries[i], "Strength", 0, &m_nStrength[i]);
  814. AttributeFile.GetInteger(szSeries[i], "Dexterity", 0, &m_nDexterity[i]);
  815. AttributeFile.GetInteger(szSeries[i], "Vitality", 0, &m_nVitality[i]);
  816. AttributeFile.GetInteger(szSeries[i], "Engergy", 0, &m_nEngergy[i]);
  817. AttributeFile.GetInteger(szSeries[i], "Lucky", PLAYER_FIRST_LUCKY, &m_nLucky[i]);
  818. }
  820. return TRUE;
  821. }
  823. #ifdef _SERVER
  824. BOOL KPlayerSet::GetPlayerName(int nIndex, char* szName)
  825. {
  826. // int i = FindClient(nClient);
  828. int i = nIndex;
  830. if (!szName)
  831. return FALSE;
  833. if (i <= 0 || i >= MAX_PLAYER)
  834. {
  835. szName[0] = 0;
  836. return FALSE;
  837. }
  838. strcpy(szName, Player[i].m_PlayerName);
  839. return TRUE;
  840. }
  841. #endif
  843. #ifdef _SERVER
  844. BOOL KPlayerSet::GetPlayerAccount(int i, char* szName)
  845. {
  846. // int i = FindClient(nClient);
  847. if (!szName)
  848. return FALSE;
  850. if (i <= 0 || i >= MAX_PLAYER)
  851. {
  852. szName[0] = 0;
  853. return FALSE;
  854. }
  856. strcpy(szName, Player[i].m_AccoutName);
  857. return TRUE;
  858. }
  859. #endif
  862. #ifdef _SERVER
  863. int KPlayerSet::AttachPlayer(const unsigned long lnID, GUID* pGuid)
  864. {
  865. if (lnID >= MAX_PLAYER || NULL == pGuid)
  866. return 0;
  868. int nUseIdx = m_UseIdx.GetPrev(0);
  869. while(nUseIdx)
  870. {
  871. if (Player[nUseIdx].m_nNetConnectIdx == -1)
  872. {
  873. if (0 == memcmp(&Player[nUseIdx].m_Guid, pGuid, sizeof(GUID)))
  874. {
  875. Player[nUseIdx].m_nNetConnectIdx = lnID;
  876. Player[nUseIdx].m_ulLastSaveTime = g_SubWorldSet.m_nLoopRate;
  877. /// Player[nUseIdx].m_dwLoginTime = -1;
  878. return nUseIdx;
  879. }
  880. // else
  881. // {
  882. // g_DebugLog("[error]Attach to a connected player named %s", Player[nUseIdx].m_PlayerName);
  883. // return 0;
  884. // }
  885. }
  886. nUseIdx = m_UseIdx.GetPrev(nUseIdx);
  887. }
  888. return 0;
  889. }
  890. #endif
  892. #ifdef _SERVER
  893. int KPlayerSet::GetPlayerIndexByGuid(GUID* pGuid)
  894. {
  895. int nUseIdx = m_UseIdx.GetNext(0);
  896. while(nUseIdx)
  897. {
  898. if (0 == memcmp(&Player[nUseIdx].m_Guid, pGuid, sizeof(GUID)))
  899. {
  900. if (Player[nUseIdx].m_nNetConnectIdx != -1)
  901. {
  902. return nUseIdx;
  903. }
  904. else
  905. {
  906. g_DebugLog("[error]Find Guid to a disconnect player");
  907. return 0;
  908. }
  909. }
  910. nUseIdx = m_UseIdx.GetNext(nUseIdx);
  911. }
  912. return 0;
  913. }
  914. #endif
  916. #ifdef _SERVER
  917. void KPlayerSet::AutoSave()
  918. {
  919. unsigned long uTime = g_SubWorldSet.GetGameTime();
  921. if (uTime >= m_ulNextSaveTime)
  922. {
  923. int nUseIdx = m_UseIdx.GetNext(0);
  924. while(nUseIdx)
  925. {
  926. if (Player[nUseIdx].CanSave() && uTime - Player[nUseIdx].m_ulLastSaveTime >= m_ulMaxSaveTimePerPlayer)
  927. {
  928. if (Player[nUseIdx].Save())
  929. {
  930. Player[nUseIdx].m_uMustSave = SAVE_REQUEST;
  931. // Player[nUseIdx].m_ulLastSaveTime = uTime;
  932. m_ulNextSaveTime += m_ulDelayTimePerSave;
  933. }
  934. break;
  935. }
  936. nUseIdx = m_UseIdx.GetNext(nUseIdx);
  937. }
  938. }
  939. }
  940. #endif