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

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

模拟服务器

开发平台：

C/C++

KPlayer.cpp：源码内容
  1. }
  2. else
  3. {
  4. sDecision.m_btDecision = 3;
  5. }
  6. if (g_pClient)
  7. g_pClient->SendPackToServer(&sDecision, sizeof(TRADE_DECISION_COMMAND));
  8. }
  9. #endif
  11. #ifndef _SERVER
  12. //-------------------------------------------------------------------------
  13. // 功能：收到服务器通知有人申请加入队伍
  14. //-------------------------------------------------------------------------
  15. void KPlayer::s2cApplyAddTeam(BYTE* pProtocol)
  16. {
  17. // 状态检查 (还需要检查 npc 的队伍开放状态 not end)
  18. if ( !m_cTeam.m_nFlag || m_cTeam.m_nFigure != TEAM_CAPTAIN)
  19. {
  20. ApplySelfTeamInfo();
  21. return;
  22. }
  24. // 寻找 npc
  25. PLAYER_APPLY_ADD_TEAM *pAddTeam = (PLAYER_APPLY_ADD_TEAM*)pProtocol;
  26. int nNpcNo = NpcSet.SearchID(pAddTeam->m_dwTarNpcID);
  27. if (nNpcNo == 0)
  28. return;
  30. int i, nFreeListNo;
  31. // 如果已经存在，更新
  32. for (i = 0; i < MAX_TEAM_APPLY_LIST; i++)
  33. {
  34. if (m_cTeam.m_sApplyList[i].m_dwNpcID == pAddTeam->m_dwTarNpcID)
  35. {
  36. m_cTeam.m_sApplyList[i].m_nLevel = Npc[nNpcNo].m_Level;
  37. m_cTeam.m_sApplyList[i].m_dwTimer = MAX_APPLY_TEAM_TIME;
  38. strcpy(m_cTeam.m_sApplyList[i].m_szName, Npc[nNpcNo].Name);
  39. m_cTeam.UpdateInterface();
  40. return;
  41. }
  42. }
  43. // 寻找申请人list空位
  44. for (i = 0; i < MAX_TEAM_APPLY_LIST; i++)
  45. {
  46. if (m_cTeam.m_sApplyList[i].m_dwNpcID == 0)
  47. {
  48. nFreeListNo = i;
  49. break;
  50. }
  51. }
  52. if (i >= MAX_TEAM_APPLY_LIST) // 没找到申请人空位
  53. return;
  55. m_cTeam.m_sApplyList[nFreeListNo].m_dwNpcID = pAddTeam->m_dwTarNpcID;
  56. m_cTeam.m_sApplyList[nFreeListNo].m_nLevel = Npc[nNpcNo].m_Level;
  57. m_cTeam.m_sApplyList[nFreeListNo].m_dwTimer = MAX_APPLY_TEAM_TIME;
  58. strcpy(m_cTeam.m_sApplyList[nFreeListNo].m_szName, Npc[nNpcNo].Name);
  60. m_cTeam.UpdateInterface();
  62. KSystemMessage sMsg;
  63. sprintf(sMsg.szMessage, MSG_TEAM_APPLY_ADD, Npc[nNpcNo].Name);
  64. sMsg.eType = SMT_TEAM;
  65. sMsg.byConfirmType = SMCT_UI_TEAM_APPLY;
  66. sMsg.byPriority = 3;
  67. sMsg.byParamSize = sizeof(KUiPlayerItem);
  69. KUiPlayerItem player;
  70. strcpy(player.Name, Npc[nNpcNo].Name);
  71. player.nIndex = 0;
  72. player.uId = pAddTeam->m_dwTarNpcID;
  73. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, (int)&player);
  75. return;
  76. }
  77. #endif
  79. #ifdef _SERVER
  80. //-------------------------------------------------------------------------
  81. // 功能：加入门派
  82. //-------------------------------------------------------------------------
  83. BOOL KPlayer::AddFaction(char *lpszFactionName)
  84. {
  85. if ( !m_cFaction.AddFaction(Npc[m_nIndex].m_Series, lpszFactionName) )
  86. return FALSE;
  88. // 改变阵营
  89. Npc[m_nIndex].SetCamp(m_cFaction.GetGurFactionCamp());
  91. // 给客户端发消息
  92. SendFactionData();
  94. return TRUE;
  95. }
  96. #endif
  98. #ifdef _SERVER
  99. //-------------------------------------------------------------------------
  100. // 功能：加入门派
  101. //-------------------------------------------------------------------------
  102. BOOL KPlayer::AddFaction(int nFactionID)
  103. {
  104. if ( !m_cFaction.AddFaction(Npc[m_nIndex].m_Series, nFactionID) )
  105. return FALSE;
  107. // 改变阵营
  108. Npc[m_nIndex].SetCamp(m_cFaction.GetGurFactionCamp());
  110. // 给客户端发消息
  111. SendFactionData();
  113. return TRUE;
  114. }
  115. #endif
  117. #ifdef _SERVER
  118. //-------------------------------------------------------------------------
  119. // 功能：离开门派
  120. //-------------------------------------------------------------------------
  121. BOOL KPlayer::LeaveCurFaction()
  122. {
  123. m_cFaction.LeaveFaction();
  125. // 改变阵营
  126. Npc[m_nIndex].SetCamp(camp_free);
  128. // 给客户端发消息
  129. PLAYER_LEAVE_FACTION sLeave;
  130. sLeave.ProtocolType = s2c_playerleavefaction;
  131. g_pServer->PackDataToClient(m_nNetConnectIdx, (BYTE*)&sLeave, sizeof(PLAYER_LEAVE_FACTION));
  133. return TRUE;
  134. }
  135. #endif
  137. #ifdef _SERVER
  138. //-------------------------------------------------------------------------
  139. // 功能：开放当前门派某个等级的技能
  140. //-------------------------------------------------------------------------
  141. BOOL KPlayer::CurFactionOpenSkill(int nLevel)
  142. {
  143. if ( !m_cFaction.OpenCurSkillLevel(nLevel, &Npc[m_nIndex].m_SkillList) )
  144. return FALSE;
  146. PLAYER_FACTION_SKILL_LEVEL sLevel;
  147. sLevel.ProtocolType = s2c_playerfactionskilllevel;
  148. sLevel.m_btCurFactionID = m_cFaction.m_nCurFaction;
  149. sLevel.m_btLevel = nLevel;
  150. g_pServer->PackDataToClient(m_nNetConnectIdx, (BYTE*)&sLevel, sizeof(PLAYER_FACTION_SKILL_LEVEL));
  152. return TRUE;
  153. }
  154. #endif
  156. #ifdef _SERVER
  157. //-------------------------------------------------------------------------
  158. // 功能：清空任务临时变量
  159. //-------------------------------------------------------------------------
  160. void KPlayer::TaskClearTempVal()
  161. {
  162. this->m_cTask.ClearTempVar();
  163. }
  164. #endif
  166. #ifdef _SERVER
  167. //-------------------------------------------------------------------------
  168. // 功能：得到任务完成情况
  169. //-------------------------------------------------------------------------
  170. int KPlayer::TaskGetSaveVal(int nNo)
  171. {
  172. return this->m_cTask.GetSaveVal(nNo);
  173. }
  174. #endif
  176. #ifdef _SERVER
  177. //-------------------------------------------------------------------------
  178. // 功能：设定任务完成情况
  179. //-------------------------------------------------------------------------
  180. void KPlayer::TaskSetSaveVal(int nNo, BOOL bFlag)
  181. {
  182. this->m_cTask.SetSaveVal(nNo, bFlag);
  183. }
  184. #endif
  186. #ifdef _SERVER
  187. //-------------------------------------------------------------------------
  188. // 功能：得到任务临时过程控制变量值
  189. //-------------------------------------------------------------------------
  190. int KPlayer::TaskGetClearVal(int nNo)
  191. {
  192. return this->m_cTask.GetClearVal(nNo);
  193. }
  194. #endif
  196. #ifdef _SERVER
  197. //-------------------------------------------------------------------------
  198. // 功能：设定任务临时过程控制变量值
  199. //-------------------------------------------------------------------------
  200. void KPlayer::TaskSetClearVal(int nNo, int nVal)
  201. {
  202. this->m_cTask.SetClearVal(nNo, nVal);
  203. }
  204. #endif
  207. #ifndef _SERVER
  208. void KPlayer::SetDefaultImmedSkill()
  209. {
  210. //获取玩家左右键技能为默认物理技能
  211. int nDetailType = Player[CLIENT_PLAYER_INDEX].m_ItemList.GetWeaponType();
  212. int nParticularType = Player[CLIENT_PLAYER_INDEX].m_ItemList.GetWeaponParticular();
  214. //近身武器
  215. if (nDetailType == 0)
  216. {
  217. Player[CLIENT_PLAYER_INDEX].SetLeftSkill(g_nMeleeWeaponSkill[nParticularType]);
  218. Player[CLIENT_PLAYER_INDEX].SetRightSkill(g_nMeleeWeaponSkill[nParticularType]);
  219. }//远程武器
  220. else if (nDetailType == 1)
  221. {
  222. Player[CLIENT_PLAYER_INDEX].SetLeftSkill(g_nRangeWeaponSkill[nParticularType]);
  223. Player[CLIENT_PLAYER_INDEX].SetRightSkill(g_nRangeWeaponSkill[nParticularType]);
  224. }//空手
  225. else if (nDetailType == -1)
  226. {
  227. Player[CLIENT_PLAYER_INDEX].SetLeftSkill(g_nHandSkill);
  228. Player[CLIENT_PLAYER_INDEX].SetRightSkill(g_nHandSkill);
  229. }
  230. }
  232. void KPlayer::SetLeftSkill(int nSkillID)
  233. {
  234. if (Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].m_SkillList.GetCurrentLevel(nSkillID) <= 0) return;
  235. m_nLeftSkillID = nSkillID;
  237. KUiGameObject Info;
  238. Info.uGenre = CGOG_SKILL_SHORTCUT;
  239. Info.uId = m_nLeftSkillID;
  240. CoreDataChanged(GDCNI_PLAYER_IMMED_ITEMSKILL, (unsigned int)&Info, -1);
  241. }
  243. void KPlayer::SetRightSkill(int nSkillID)
  244. {
  245. if (Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].m_SkillList.GetCurrentLevel(nSkillID) <= 0) return;
  246. m_nRightSkillID = nSkillID;
  247. // 检查是否是光环技能
  248. ISkill * pOrdinSkill = g_SkillManager.GetSkill(nSkillID, 1);
  249. if (!pOrdinSkill) 
  250.         return;
  252. if (pOrdinSkill->IsAura())
  253. {
  254. Npc[m_nIndex].SetAuraSkill(nSkillID);
  255. }
  256. else
  257. {
  258. Npc[m_nIndex].SetAuraSkill(0);
  259. }
  261. KUiGameObject Info;
  262. Info.uGenre = CGOG_SKILL_SHORTCUT;
  263. Info.uId = m_nRightSkillID;
  264. CoreDataChanged(GDCNI_PLAYER_IMMED_ITEMSKILL, (unsigned int)&Info, -2);
  265. }
  267. void KPlayer::UpdateWeaponSkill()
  268. {
  269. if (m_nLeftSkillID > 0)
  270. {
  271. ISkill * pISkill = g_SkillManager.GetSkill(m_nLeftSkillID, 1);
  272. if (!pISkill) 
  273.             return;
  275. if (pISkill->IsPhysical())
  276. {
  277. SetLeftSkill(Npc[m_nIndex].GetCurActiveWeaponSkill());
  278. }
  280. }
  281. if (m_nRightSkillID > 0)
  282. {
  283. ISkill * pISkill = (KSkill *) g_SkillManager.GetSkill(m_nRightSkillID, 1);
  284. if (!pISkill) 
  285.             return;
  287. if (pISkill->IsPhysical())
  288. {
  289. SetRightSkill(Npc[m_nIndex].GetCurActiveWeaponSkill());
  290. }
  291. }
  292. }
  293. #endif
  295. #ifndef _SERVER
  296. //-------------------------------------------------------------------------
  297. // 功能：设定当前聊天频道
  298. //-------------------------------------------------------------------------
  299. void KPlayer::SetChatCurChannel(int nChannelNo)
  300. {
  301. m_cChat.SetCurChannel(nChannelNo);
  302. }
  303. #endif
  305. #ifndef _SERVER
  306. //-------------------------------------------------------------------------
  307. // 功能：邀请加入队伍
  308. //-------------------------------------------------------------------------
  309. void KPlayer::TeamInviteAdd(DWORD dwNpcID)
  310. {
  311. m_cTeam.InviteAdd(dwNpcID);
  312. }
  313. #endif
  315. #ifdef _SERVER
  316. //-------------------------------------------------------------------------
  317. // 功能：收到客户端发来的聊天语句
  318. //-------------------------------------------------------------------------
  319. void KPlayer::ServerSendChat(BYTE* pProtocol)
  320. {
  321. m_cChat.ServerSendChat(m_nPlayerIndex, pProtocol);
  322. }
  323. #endif
  325. #ifdef _SERVER
  326. //-------------------------------------------------------------------------
  327. // 功能：收到客户端要求增加基本属性点(0=Strength 1=Dexterity 2=Vitality 3=Engergy)
  328. //-------------------------------------------------------------------------
  329. void KPlayer::AddBaseAttribute(BYTE* pProtocol)
  330. {
  331. PLAYER_ADD_BASE_ATTRIBUTE_COMMAND *pAdd = (PLAYER_ADD_BASE_ATTRIBUTE_COMMAND*)pProtocol;
  332. switch (pAdd->m_btAttribute)
  333. {
  334. case ATTRIBUTE_STRENGTH:
  335. AddBaseStrength(pAdd->m_nAddNo);
  336. break;
  337. case ATTRIBUTE_DEXTERITY:
  338. AddBaseDexterity(pAdd->m_nAddNo);
  339. break;
  340. case ATTRIBUTE_VITALITY:
  341. AddBaseVitality(pAdd->m_nAddNo);
  342. break;
  343. case ATTRIBUTE_ENGERGY:
  344. AddBaseEngergy(pAdd->m_nAddNo);
  345. break;
  346. }
  347. }
  348. #endif
  350. #define MAX_ORDINSKILL_LEVEL_ALWAYS  20//不包括其它情况对技能等级的变动之外的，一般最大技能等级
  351. #ifdef _SERVER
  352. //-------------------------------------------------------------------------
  353. // 功能：收到客户端要求增加某个技能的点数
  354. //-------------------------------------------------------------------------
  355. void KPlayer::AddSkillPoint(BYTE* pProtocol)
  356. {
  357. PLAYER_ADD_SKILL_POINT_COMMAND *pAdd = (PLAYER_ADD_SKILL_POINT_COMMAND*)pProtocol;
  359. int nSkillIndex, nSkillLevel;
  361. nSkillIndex = Npc[m_nIndex].m_SkillList.FindSame(pAdd->m_nSkillID);
  362. if (nSkillIndex == 0)
  363. return;
  364. nSkillLevel = Npc[m_nIndex].m_SkillList.GetSkillIdxLevel(nSkillIndex);
  367. if (m_nSkillPoint >= pAdd->m_nAddPoint && nSkillIndex )//&& nSkillLevel + pAdd->m_nAddPoint <= MAX_SKILLLEVEL
  368. {
  369. ISkill * pSkill = NULL;
  370. if (nSkillLevel == 0)
  371. {
  372. pSkill =  g_SkillManager.GetSkill(pAdd->m_nSkillID, 1);
  373. }
  374. else
  375. {
  376. pSkill =  g_SkillManager.GetSkill(pAdd->m_nSkillID, nSkillLevel);
  377. }
  379. if (pSkill)
  380. {
  381. //有对应的技能升级脚本,优先执行脚本
  382. if (pSkill->GetSkillLevelUpScriptId())
  383. {
  384. ExecuteScript(pSkill->GetSkillLevelUpScriptId(), "main", pAdd->m_nAddPoint);
  385. nSkillLevel = Npc[m_nIndex].m_SkillList.GetSkillIdxLevel(nSkillIndex);
  386. }
  387. else
  388. {
  389. /*
  390. 技能升级的常规
  391. 1。所有能够加点的技能，最高只能加到20级。
  392. 2。假设一个玩家的等级是x,一个技能的基本学习等级是y，那么他能够学习这个技能的最高等级是x-y。
  393. 3。使用技能需要加入一些情况的判断，第一，是否是骑马状态；第二，他装备的武器的详细类别是否为指定数值，-1表示没有需求。
  394. */
  395. switch(pSkill->GetSkillStyle())
  396. {
  397. case SKILL_SS_Missles: // 子弹类 本技能用于发送子弹类
  398. case SKILL_SS_Melee:
  399. case SKILL_SS_InitiativeNpcState: // 主动类 本技能用于改变当前Npc的主动状态
  400. case SKILL_SS_PassivityNpcState: // 被动类 本技能用于改变Npc的被动状态
  401. {
  402. int nWantToBeLevel = nSkillLevel + pAdd->m_nAddPoint;
  403. //Limit2
  404. if (nWantToBeLevel <= g_SkillManager.GetSkillMaxLevel(pAdd->m_nSkillID) && nWantToBeLevel <= Npc[m_nIndex].m_Level - ((KSkill*)pSkill)->GetSkillReqLevel() + 1)
  405. {
  406. if ( !Npc[m_nIndex].m_SkillList.IncreaseLevel(nSkillIndex, pAdd->m_nAddPoint) )
  407. return;
  408. m_nSkillPoint -= pAdd->m_nAddPoint;
  409. nSkillLevel += pAdd->m_nAddPoint;
  410. }
  411. else
  412. {
  413. if (nWantToBeLevel >=  g_SkillManager.GetSkillMaxLevel(pAdd->m_nSkillID))
  414. {
  415. char szMsg[100];
  416. sprintf(szMsg, "您的%s技能等级已经达到极限，不能再升级了。", pSkill->GetSkillName());
  417. KPlayerChat::SendSystemInfo(1, m_nPlayerIndex, "技能升级消息", (char *) szMsg, strlen(szMsg) );
  418. }
  419. else 
  420. {
  421. char szMsg[100];
  422. sprintf(szMsg, "您的战斗技能必须达到%d级才能升级%s技能。", ((KSkill *)pSkill)->GetSkillReqLevel() -1 +  pAdd->m_nAddPoint + nSkillLevel,  ((KSkill*)pSkill)->GetSkillName());
  423. KPlayerChat::SendSystemInfo(1, m_nPlayerIndex, "技能升级消息", (char *) szMsg, strlen(szMsg) );
  424. }
  426. }
  427. }
  428. break;
  430. case SKILL_SS_Thief:
  431. {
  432. return;
  433. }break;
  435. }
  437. }
  439. // 把当前此技能的点数和剩余技能点发给客户端
  440. PLAYER_SKILL_LEVEL_SYNC sSkill;
  441. sSkill.ProtocolType = s2c_playerskilllevel;
  442. sSkill.m_nSkillID = pAdd->m_nSkillID;
  443. sSkill.m_nSkillLevel = nSkillLevel;
  444. sSkill.m_nLeavePoint = m_nSkillPoint;
  445. g_pServer->PackDataToClient(m_nNetConnectIdx, (BYTE*)&sSkill, sizeof(PLAYER_SKILL_LEVEL_SYNC));
  446. }
  447. }
  450. }
  451. #endif
  453. #ifdef _SERVER
  454. //-------------------------------------------------------------------------
  455. // 功能：服务器端拣物品
  456. //-------------------------------------------------------------------------
  457. BOOL KPlayer::ServerPickUpItem(BYTE* pProtocol)
  458. {
  459. PLAYER_PICKUP_ITEM_COMMAND *pPickUp = (PLAYER_PICKUP_ITEM_COMMAND*)pProtocol;
  461. int nObjIndex, nNpcX, nNpcY, nObjX, nObjY;
  462. nObjIndex = ObjSet.FindID(pPickUp->m_nObjID);
  463. if (nObjIndex == 0)
  464. return FALSE;
  466. if (Object[nObjIndex].m_nBelong != -1)
  467. {
  468. if (!m_cTeam.m_nFlag)
  469. {
  470. if (Object[nObjIndex].m_nBelong != m_nPlayerIndex)
  471. {
  472. SHOW_MSG_SYNC sMsg;
  473. sMsg.ProtocolType = s2c_msgshow;
  474. if (Object[nObjIndex].m_nKind == Obj_Kind_Money)
  475. sMsg.m_wMsgID = enumMSG_ID_MONEY_CANNOT_PICKUP;
  476. else
  477. sMsg.m_wMsgID = enumMSG_ID_OBJ_CANNOT_PICKUP;
  478. sMsg.m_wLength = sizeof(SHOW_MSG_SYNC) - 1 - sizeof(LPVOID);
  479. g_pServer->PackDataToClient(m_nNetConnectIdx, &sMsg, sMsg.m_wLength + 1);
  480. return FALSE;
  481. }
  482. }
  483. else
  484. {
  485. if (Object[nObjIndex].m_nKind == Obj_Kind_Money)
  486. {
  487. if (Object[nObjIndex].m_nBelong != m_nPlayerIndex &&
  488. !g_Team[m_cTeam.m_nID].CheckIn(Object[nObjIndex].m_nBelong))
  489. {
  490. SHOW_MSG_SYNC sMsg;
  491. sMsg.ProtocolType = s2c_msgshow;
  492. sMsg.m_wMsgID = enumMSG_ID_MONEY_CANNOT_PICKUP;
  493. sMsg.m_wLength = sizeof(SHOW_MSG_SYNC) - 1 - sizeof(LPVOID);
  494. g_pServer->PackDataToClient(m_nNetConnectIdx, &sMsg, sMsg.m_wLength + 1);
  495. return FALSE;
  496. }
  497. }
  498. else if (Object[nObjIndex].m_nKind == Obj_Kind_Item)
  499. {
  500. if (Object[nObjIndex].m_nItemDataID <= 0 || Object[nObjIndex].m_nItemDataID >= MAX_ITEM)
  501. {
  502. _ASSERT(0);
  503. return FALSE;
  504. }
  505. if ((Item[Object[nObjIndex].m_nItemDataID].GetGenre() == item_task && Object[nObjIndex].m_nBelong != m_nPlayerIndex) ||
  506. !g_Team[m_cTeam.m_nID].CheckIn(Object[nObjIndex].m_nBelong))
  507. {
  508. SHOW_MSG_SYNC sMsg;
  509. sMsg.ProtocolType = s2c_msgshow;
  510. sMsg.m_wMsgID = enumMSG_ID_OBJ_CANNOT_PICKUP;
  511. sMsg.m_wLength = sizeof(SHOW_MSG_SYNC) - 1 - sizeof(LPVOID);
  512. g_pServer->PackDataToClient(m_nNetConnectIdx, &sMsg, sMsg.m_wLength + 1);
  513. return FALSE;
  514. }
  515. }
  516. else
  517. {
  518. return FALSE;
  519. }
  520. }
  521. }
  522. // 判断距离
  523. if (Object[nObjIndex].m_nSubWorldID != Npc[m_nIndex].m_SubWorldIndex)
  524. return FALSE;
  525. SubWorld[Object[nObjIndex].m_nSubWorldID].Map2Mps(
  526. Object[nObjIndex].m_nRegionIdx,
  527. Object[nObjIndex].m_nMapX,
  528. Object[nObjIndex].m_nMapY,
  529. Object[nObjIndex].m_nOffX,
  530. Object[nObjIndex].m_nOffY,
  531. &nObjX,
  532. &nObjY);
  533. SubWorld[Npc[m_nIndex].m_SubWorldIndex].Map2Mps(
  534. Npc[m_nIndex].m_RegionIndex,
  535. Npc[m_nIndex].m_MapX,
  536. Npc[m_nIndex].m_MapY,
  537. Npc[m_nIndex].m_OffX,
  538. Npc[m_nIndex].m_OffY,
  539. &nNpcX,
  540. &nNpcY);
  541. if ( PLAYER_PICKUP_SERVER_DISTANCE < (nNpcX - nObjX) * (nNpcX - nObjX) + (nNpcY - nObjY) * (nNpcY - nObjY))
  542. {
  543. SHOW_MSG_SYNC sMsg;
  544. sMsg.ProtocolType = s2c_msgshow;
  545. sMsg.m_wMsgID = enumMSG_ID_OBJ_TOO_FAR;
  546. sMsg.m_wLength = sizeof(SHOW_MSG_SYNC) - 1 - sizeof(LPVOID);
  547. g_pServer->PackDataToClient(m_nNetConnectIdx, &sMsg, sMsg.m_wLength + 1);
  548. return FALSE;
  549. }
  551. switch (Object[nObjIndex].m_nKind)
  552. {
  553. case Obj_Kind_Item: // 掉在地上的装备
  554. {
  555. int nItemIdx = m_ItemList.Add(Object[nObjIndex].m_nItemDataID, pPickUp->m_btPosType, pPickUp->m_btPosX, pPickUp->m_btPosY);
  556. if (nItemIdx <= 0 || nItemIdx >= MAX_PLAYER_ITEM)
  557. return FALSE;
  558. if (Object[nObjIndex].m_nItemDataID <= 0 || Object[nObjIndex].m_nItemDataID >= MAX_ITEM)
  559. return FALSE;
  560. // 给客户端发送获得装备的消息
  561. SHOW_MSG_SYNC sMsg;
  562. sMsg.ProtocolType = s2c_msgshow;
  563. sMsg.m_wMsgID = enumMSG_ID_GET_ITEM;
  564. sMsg.m_lpBuf = (LPVOID)Item[Object[nObjIndex].m_nItemDataID].GetID();
  565. sMsg.m_wLength = sizeof(SHOW_MSG_SYNC) - 1;
  566. g_pServer->PackDataToClient(m_nNetConnectIdx, &sMsg, sMsg.m_wLength + 1);
  567. sMsg.m_lpBuf = 0;
  569. // 去掉Object[nObjIndex]与道具的关联。避免ItemSet的Remove被Object的Remove调用
  570. Object[nObjIndex].m_nItemDataID = 0;
  571. Object[nObjIndex].m_nItemWidth = 0;
  572. Object[nObjIndex].m_nItemHeight = 0;
  573. Object[nObjIndex].Remove(FALSE);
  575. }
  576. break;
  577. case Obj_Kind_Money: // 掉在地上的钱
  578. if ( !Earn(Object[nObjIndex].m_nMoneyNum) )
  579. return FALSE;
  580. Object[nObjIndex].SyncRemove(TRUE);
  581. if (Object[nObjIndex].m_nRegionIdx >= 0)
  582. SubWorld[Object[nObjIndex].m_nSubWorldID].m_Region[Object[nObjIndex].m_nRegionIdx].RemoveObj(nObjIndex);
  583. ObjSet.Remove(nObjIndex);
  584. break;
  585. }
  587. return TRUE;
  588. }
  589. #endif
  591. #ifdef _SERVER
  592. //-------------------------------------------------------------------------
  593. // 功能：收到客户端要求使用某个物品(鼠标右键点击)
  594. //-------------------------------------------------------------------------
  595. void KPlayer::EatItem(BYTE* pProtocol)
  596. {
  597. PLAYER_EAT_ITEM_COMMAND *pEat = (PLAYER_EAT_ITEM_COMMAND*)pProtocol;
  599. m_ItemList.EatMecidine(pEat->m_btPlace, pEat->m_btX, pEat->m_btY);
  600. }
  601. #endif
  603. #ifdef _SERVER
  604. //-------------------------------------------------------------------------
  605. // 功能：收到客户端要求使用某个物品(鼠标右键点击)
  606. //-------------------------------------------------------------------------
  607. //void KPlayer::UseItem(BYTE* pProtocol)
  608. //{
  609. // PLAYER_USE_ITEM_COMMAND *pItem = (PLAYER_USE_ITEM_COMMAND*)pProtocol;
  610. //}
  611. #endif
  613. #ifdef _SERVER
  614. void KPlayer::ServerMoveItem(BYTE* pProtocol)
  615. {
  616. PLAYER_MOVE_ITEM_COMMAND *pMove = (PLAYER_MOVE_ITEM_COMMAND*)pProtocol;
  617. ItemPos DownPos, UpPos;
  619. DownPos.nPlace = pMove->m_btDownPos;
  620. DownPos.nX = pMove->m_btDownX;
  621. DownPos.nY = pMove->m_btDownY;
  622. UpPos.nPlace = pMove->m_btUpPos;
  623. UpPos.nX = pMove->m_btUpX;
  624. UpPos.nY = pMove->m_btUpY;
  626. //EXCHANGE_ITEM_RESPONE eir;
  627. //eir.ProtocolType = s2c_exchangerespone;
  629. if (this->CheckTrading() && DownPos.nPlace == pos_traderoom)
  630. {
  631. if (this->m_cTrade.m_nTradeLock)
  632. return;
  633. }
  635. m_ItemList.ExchangeItem(&DownPos, &UpPos);
  637. BYTE byFinished = s2c_itemexchangefinish;
  638. if (g_pServer)
  639. g_pServer->PackDataToClient(m_nNetConnectIdx, &byFinished, sizeof(BYTE));
  640. }
  641. #endif
  643. #ifdef _SERVER
  644. void KPlayer::ServerThrowAwayItem(BYTE* pProtocol)
  645. {
  646. PLAYER_THROW_AWAY_ITEM_COMMAND *pThrow = (PLAYER_THROW_AWAY_ITEM_COMMAND*)pProtocol;
  647. KMapPos sMapPos;
  649. if ( !this->m_ItemList.Hand() )
  650. return;
  652. int nItemIdx = m_ItemList.m_Hand;
  653. GetAboutPos(&sMapPos);
  654. if (m_ItemList.Remove(nItemIdx))
  655. {
  656. int nObj;
  657. KObjItemInfo sInfo;
  658. sInfo.m_nItemID = nItemIdx;
  659. sInfo.m_nItemWidth = Item[nItemIdx].GetWidth();
  660. sInfo.m_nItemHeight = Item[nItemIdx].GetHeight();
  661. sInfo.m_nMoneyNum = 0;
  662. strcpy(sInfo.m_szName, Item[nItemIdx].m_CommonAttrib.szItemName);
  663. sInfo.m_nColorID = 0;
  664. sInfo.m_nMovieFlag = 1;
  665. sInfo.m_nSoundFlag = 1;
  667. nObj = ObjSet.Add(Item[nItemIdx].GetObjIdx(), sMapPos, sInfo);
  668. if (nObj >= 0)
  669. {
  670. if (Item[nItemIdx].GetGenre() == item_task)
  671. {
  672. Object[nObj].SetEntireBelong(this->m_nPlayerIndex);
  673. }
  674. else
  675. {
  676. Object[nObj].SetItemBelong(-1);
  677. }
  678. }
  679. }
  680. }
  681. #endif
  683. #ifdef _SERVER
  684. //-------------------------------------------------------------------------
  685. // 功能：收到客户端消息设定聊天订阅频道
  686. //-------------------------------------------------------------------------
  687. void KPlayer::ChatSetTakeChannel(BYTE* pProtocol)
  688. {
  689. CHAT_SET_CHANNEL_COMMAND *pChannel = (CHAT_SET_CHANNEL_COMMAND*)pProtocol;
  690. this->m_cChat.SetTakeChannel(pChannel->m_dwTakeChannel);
  691. }
  692. #endif
  694. #ifdef _SERVER
  695. //-------------------------------------------------------------------------
  696. // 功能：收到客户端请求转发聊天添加好友信息
  697. //-------------------------------------------------------------------------
  698. void KPlayer::ChatTransmitApplyAddFriend(BYTE* pProtocol)
  699. {
  700. CHAT_APPLY_ADD_FRIEND_COMMAND *pAdd = (CHAT_APPLY_ADD_FRIEND_COMMAND*)pProtocol;
  701. int nPlayerIdx = FindAroundPlayer(pAdd->m_dwTargetNpcID);
  702. if (nPlayerIdx < 0)
  703. return;
  705. m_cChat.m_nAddFriendList[m_cChat.m_nListPos++] = nPlayerIdx;
  706. m_cChat.m_nListPos %= CHAT_APPLY_ADD_FRIEND_LIST;
  708. CHAT_APPLY_ADD_FRIEND_SYNC sAdd;
  709. sAdd.ProtocolType = s2c_chatapplyaddfriend;
  710. sAdd.m_nSrcPlayerIdx = m_nPlayerIndex;
  711. strcpy(sAdd.m_szSourceName, Npc[m_nIndex].Name);
  712. memset(sAdd.m_szInfo, 0, sizeof(sAdd.m_szInfo));
  713. memcpy(sAdd.m_szInfo, pAdd->m_szInfo, pAdd->m_wLength + 1 + sizeof(pAdd->m_szInfo) - sizeof(CHAT_APPLY_ADD_FRIEND_COMMAND));
  714. g_pServer->PackDataToClient(Player[nPlayerIdx].m_nNetConnectIdx, (BYTE*)&sAdd, sizeof(CHAT_APPLY_ADD_FRIEND_SYNC));
  715. }
  716. #endif
  718. #ifdef _SERVER
  719. //-------------------------------------------------------------------------
  720. // 功能：收到客户端消息添加聊天好友
  721. //-------------------------------------------------------------------------
  722. BOOL KPlayer::ChatAddFriend(BYTE* pProtocol)
  723. {
  724. CHAT_ADD_FRIEND_COMMAND *pAdd = (CHAT_ADD_FRIEND_COMMAND*)pProtocol;
  726. if (pAdd->m_nTargetPlayerIdx < 0 || pAdd->m_nTargetPlayerIdx >= MAX_PLAYER)
  727. goto AddFalse;
  728. if ( !Player[pAdd->m_nTargetPlayerIdx].m_nIndex )
  729. goto AddFalse;
  730. int i;
  731. for (i = 0; i < CHAT_APPLY_ADD_FRIEND_LIST; i++)
  732. {
  733. if (m_nPlayerIndex == Player[pAdd->m_nTargetPlayerIdx].m_cChat.m_nAddFriendList[i])
  734. break;
  735. }
  736. if (i >= CHAT_APPLY_ADD_FRIEND_LIST)
  737. goto AddFalse;
  739. m_cChat.AddFriendData(m_nPlayerIndex, pAdd->m_nTargetPlayerIdx);
  740. Player[pAdd->m_nTargetPlayerIdx].m_cChat.AddFriendData(pAdd->m_nTargetPlayerIdx, m_nPlayerIndex);
  742. return TRUE;
  744. AddFalse:
  745. CHAT_ADD_FRIEND_FAIL_SYNC sFail;
  746. sFail.ProtocolType = s2c_chataddfriendfail;
  747. sFail.m_nTargetPlayerIdx = pAdd->m_nTargetPlayerIdx;
  748. g_pServer->PackDataToClient(m_nNetConnectIdx, (BYTE*)&sFail, sizeof(CHAT_ADD_FRIEND_FAIL_SYNC));
  750. return FALSE;
  751. }
  752. #endif
  754. #ifdef _SERVER
  755. //-------------------------------------------------------------------------
  756. // 功能：收到客户端消息拒绝添加聊天好友
  757. //-------------------------------------------------------------------------
  758. void KPlayer::ChatRefuseFriend(BYTE* pProtocol)
  759. {
  760. CHAT_REFUSE_FRIEND_COMMAND *pRefuse = (CHAT_REFUSE_FRIEND_COMMAND*)pProtocol;
  762. if (pRefuse->m_nTargetPlayerIdx < 0 || pRefuse->m_nTargetPlayerIdx >= MAX_PLAYER)
  763. return;
  764. if (Player[pRefuse->m_nTargetPlayerIdx].m_nIndex == 0)
  765. return;
  766. for (int i = 0; i < CHAT_APPLY_ADD_FRIEND_LIST; i++)
  767. {
  768. if (m_nPlayerIndex == Player[pRefuse->m_nTargetPlayerIdx].m_cChat.m_nAddFriendList[i])
  769. {
  770. CHAT_REFUSE_FRIEND_SYNC sRefuse;
  771. sRefuse.ProtocolType = s2c_chatrefusefriend;
  772. g_StrCpy(sRefuse.m_szName, Npc[m_nIndex].Name);
  773. sRefuse.m_wLength = sizeof(CHAT_REFUSE_FRIEND_SYNC) - 1 - sizeof(sRefuse.m_szName) + strlen(sRefuse.m_szName);
  775. g_pServer->PackDataToClient(Player[pRefuse->m_nTargetPlayerIdx].m_nNetConnectIdx, (BYTE*)&sRefuse, sRefuse.m_wLength + 1);
  776. return;
  777. }
  778. }
  779. }
  780. #endif
  782. #ifdef _SERVER
  783. //-------------------------------------------------------------------------
  784. // 功能：玩家登录时收到客户端请求重新发送所有聊天好友数据（带名字）
  785. //-------------------------------------------------------------------------
  786. void KPlayer::ChatResendAllFriend(BYTE* pProtocol)
  787. {
  788. if ( m_cChat.m_nSyncState != 1)
  789. return;
  790. m_cChat.m_nSyncState = 2;
  791. m_cChat.m_pStateSendPos = (CChatFriend*)m_cChat.m_cFriendTeam[0].m_cEveryOne.GetHead();
  792. if ( !m_cChat.m_pStateSendPos )
  793. m_cChat.m_nSyncState = 0;
  794. }
  795. #endif
  797. #ifdef _SERVER
  798. //-------------------------------------------------------------------------
  799. // 功能：玩家登录时收到客户端请求发送某个聊天好友数据（带名字）
  800. //-------------------------------------------------------------------------
  801. void KPlayer::ChatSendOneFriendData(BYTE* pProtocol)
  802. {
  803. CHAT_APPLY_SEND_ONE_FRIEND_NAME_COMMAND *pApply = (CHAT_APPLY_SEND_ONE_FRIEND_NAME_COMMAND*)pProtocol;
  805. m_cChat.ResendOneFriendData(pApply->m_dwID, m_nPlayerIndex);
  806. }
  807. #endif
  809. #ifdef _SERVER
  810. //-------------------------------------------------------------------------
  811. // 功能：收到客户端申请删除某个聊天好友
  812. //-------------------------------------------------------------------------
  813. void KPlayer::ChatDeleteFriend(BYTE* pProtocol)
  814. {
  815. CHAT_DELETE_FRIEND_COMMAND *pDelete = (CHAT_DELETE_FRIEND_COMMAND*)pProtocol;
  817. m_cChat.DeleteFriend(pDelete->m_dwID, m_dwID);
  818. }
  819. #endif
  821. #ifdef _SERVER
  822. //-------------------------------------------------------------------------
  823. // 功能：收到客户端申请再次删除某个聊天好友
  824. //-------------------------------------------------------------------------
  825. void KPlayer::ChatRedeleteFriend(BYTE* pProtocol)
  826. {
  827. CHAT_REDELETE_FRIEND_COMMAND *pDelete = (CHAT_REDELETE_FRIEND_COMMAND*)pProtocol;
  829. this->m_cChat.RedeleteFriend(pDelete->m_dwID, m_nPlayerIndex);
  830. }
  831. #endif
  833. #ifdef _SERVER
  834. //-------------------------------------------------------------------------
  835. // 功能：收到客户端申请进入待交易状态
  836. //-------------------------------------------------------------------------
  837. void KPlayer::TradeApplyOpen(BYTE* pProtocol)
  838. {
  839. if ( CheckTrading() )
  840. return;
  841. TRADE_APPLY_OPEN_COMMAND *pApply = (TRADE_APPLY_OPEN_COMMAND*)pProtocol;
  842. char szSentence[MAX_SENTENCE_LENGTH];
  843. int nLength = pApply->m_wLength - (sizeof(TRADE_APPLY_OPEN_COMMAND) - 1 - sizeof(pApply->m_szSentence));
  844. if (nLength >= MAX_SENTENCE_LENGTH)
  845. nLength = MAX_SENTENCE_LENGTH - 1;
  846. memset(szSentence, 0, sizeof(szSentence));
  847. memcpy(szSentence, pApply->m_szSentence, nLength);
  849. switch (m_cMenuState.m_nState)
  850. {
  851. case PLAYER_MENU_STATE_NORMAL:
  852. case PLAYER_MENU_STATE_TRADEOPEN:
  853. m_cMenuState.SetState(m_nPlayerIndex, PLAYER_MENU_STATE_TRADEOPEN, szSentence, nLength);
  854. break;
  855. case PLAYER_MENU_STATE_TEAMOPEN:
  856. if (m_cTeam.m_nFlag && m_cTeam.m_nID >= 0)
  857. g_Team[m_cTeam.m_nID].SetTeamClose();
  858. m_cMenuState.SetState(m_nPlayerIndex, PLAYER_MENU_STATE_TRADEOPEN, szSentence, nLength);
  859. break;
  860. }
  861. }
  862. #endif
  864. #ifdef _SERVER
  865. //-------------------------------------------------------------------------
  866. // 功能：收到客户端申请取消待交易状态
  867. //-------------------------------------------------------------------------
  868. void KPlayer::TradeApplyClose(BYTE* pProtocol)
  869. {
  870. m_cMenuState.SetState(m_nPlayerIndex, PLAYER_MENU_STATE_NORMAL);
  871. }
  872. #endif
  874. #ifdef _SERVER
  875. //-------------------------------------------------------------------------
  876. // 功能：收到客户端申请开始交易
  877. //-------------------------------------------------------------------------
  878. void KPlayer::TradeApplyStart(BYTE* pProtocol)
  879. {
  880. if (this->CheckTrading())
  881. return;
  883. TRADE_APPLY_START_COMMAND *pStart = (TRADE_APPLY_START_COMMAND*)pProtocol;
  885. int nPlayer;
  886. nPlayer = FindAroundPlayer(pStart->m_dwID);
  887. if (nPlayer < 0)
  888. return;
  889. if (Player[nPlayer].m_cMenuState.m_nState != PLAYER_MENU_STATE_TRADEOPEN)
  890. return;
  891. this->m_cTrade.m_nApplyIdx = nPlayer;
  893. TRADE_APPLY_START_SYNC sApply;
  894. sApply.ProtocolType = s2c_tradeapplystart;
  895. sApply.m_nDestIdx = this->m_nPlayerIndex;
  896. sApply.m_dwNpcId = Npc[m_nIndex].m_dwID;
  897. if (g_pServer)
  898. g_pServer->PackDataToClient(Player[nPlayer].m_nNetConnectIdx, (BYTE*)&sApply, sizeof(TRADE_APPLY_START_SYNC));
  899. }
  900. #endif
  902. #ifdef _SERVER
  903. //-------------------------------------------------------------------------
  904. // 功能：
  905. //-------------------------------------------------------------------------
  906. void KPlayer::TradeMoveMoney(BYTE* pProtocol)
  907. {
  908. if ( !CheckTrading() )
  909. return;
  910. if (this->m_cTrade.m_nTradeLock)
  911. return;
  913. int nMoney;
  914. TRADE_MOVE_MONEY_COMMAND *pMoney = (TRADE_MOVE_MONEY_COMMAND*)pProtocol;
  915. if (pMoney->m_nMoney < 0 || pMoney->m_nMoney > m_ItemList.GetEquipmentMoney())
  916. nMoney = 0;
  917. else
  918. nMoney = pMoney->m_nMoney;
  919. m_ItemList.TradeMoveMoney(nMoney);
  920. }
  921. #endif
  923. #ifdef _SERVER
  924. //-------------------------------------------------------------------------
  925. // 功能：执行或取消交易
  926. //-------------------------------------------------------------------------
  927. void KPlayer::TradeDecision(BYTE* pProtocol)
  928. {
  929. if ( !CheckTrading() )
  930. return;
  932. TRADE_DECISION_COMMAND *pDecision = (TRADE_DECISION_COMMAND*)pProtocol;
  934. if (pDecision->m_btDecision == 2) // 己方锁定
  935. {
  936. if (this->m_cTrade.m_nTradeLock == 0)
  937. {
  938. this->m_cTrade.m_nTradeLock = 1;
  939. this->m_cTrade.m_nTradeState = 0;
  940. Player[m_cTrade.m_nTradeDest].m_cTrade.m_nTradeState = 0;
  941. }
  943. SyncTradeState();
  944. return;
  945. }
  946. else if (pDecision->m_btDecision == 3) // 锁定取消
  947. {
  948. if (this->m_cTrade.m_nTradeLock == 1)
  949. {
  950. // 取消己方锁定的同时也取消了对方的锁定
  951. this->m_cTrade.m_nTradeLock = 0;
  952. this->m_cTrade.m_nTradeState = 0;
  953. Player[m_cTrade.m_nTradeDest].m_cTrade.m_nTradeLock = 0;
  954. Player[m_cTrade.m_nTradeDest].m_cTrade.m_nTradeState = 0;
  955. }
  956. SyncTradeState();
  957. return;
  958. }
  959. else if (pDecision->m_btDecision == 4) // 取消确定
  960. {
  961. if (m_cTrade.m_nTradeLock == 1 && Player[m_cTrade.m_nTradeDest].m_cTrade.m_nTradeLock == 1)
  962. {
  963. m_cTrade.m_nTradeState = 0;
  964. SyncTradeState();
  965. }
  966. return;
  967. }
  968. else if (pDecision->m_btDecision == 0) // 取消交易
  969. {
  970. int nDestIdx;
  971. nDestIdx = this->m_cTrade.m_nTradeDest;
  972. // 取消交易的数据恢复
  973. this->m_ItemList.RecoverTrade();
  974. this->m_ItemList.ClearRoom(room_trade);
  975. this->m_ItemList.ClearRoom(room_trade1);
  976. this->m_cTrade.Release();
  977. Player[nDestIdx].m_ItemList.RecoverTrade();
  978. Player[nDestIdx].m_ItemList.ClearRoom(room_trade);
  979. Player[nDestIdx].m_ItemList.ClearRoom(room_trade1);
  980. Player[nDestIdx].m_cTrade.Release();
  982. TRADE_DECISION_SYNC sSync;
  983. sSync.ProtocolType = s2c_tradedecision;
  984. sSync.m_btDecision = 0;
  985. g_pServer->PackDataToClient(m_nNetConnectIdx, (BYTE*)&sSync, sizeof(TRADE_DECISION_SYNC));
  986. g_pServer->PackDataToClient(Player[nDestIdx].m_nNetConnectIdx, (BYTE*)&sSync, sizeof(TRADE_DECISION_SYNC));
  988. // 取消交易的状态恢复(备份状态一定不会是 trading)(己方)
  989. this->m_cMenuState.RestoreBackupState(m_nPlayerIndex);
  991. // 取消交易的状态恢复(备份状态一定不会是 trading)(对方)
  992. Player[nDestIdx].m_cMenuState.RestoreBackupState(nDestIdx);
  994. return;
  995. }
  996. else if (pDecision->m_btDecision == 1) // 执行交易
  997. {
  998. // 如果双方没有同时锁定，不能确定
  999. if (this->m_cTrade.m_nTradeLock != 1 ||
  1000. Player[m_cTrade.m_nTradeDest].m_cTrade.m_nTradeLock != 1)
  1001. {
  1002. SyncTradeState();
  1003. return;
  1004. }
  1005. // 对方还没确定，通知对方自己已确定
  1006. else if (Player[m_cTrade.m_nTradeDest].m_cTrade.m_nTradeState == 0)
  1007. {
  1008. m_cTrade.m_nTradeState = 1;
  1010. SyncTradeState();
  1012. return;
  1013. }
  1014. // 对方已确定，执行交易
  1015. else
  1016. {
  1017. // 执行交易之前，先检测一下是否有错误
  1018. // -------------------- 检查 money --------------------
  1019. int nSM1, nSM2, nDM1, nDM2;
  1020. int nDestIdx = m_cTrade.m_nTradeDest;
  1021. nSM1 = m_ItemList.GetMoney(room_equipment);
  1022. nSM2 = m_ItemList.GetMoney(room_trade);
  1023. nDM1 = Player[nDestIdx].m_ItemList.GetMoney(room_equipment);
  1024. nDM2 = Player[nDestIdx].m_ItemList.GetMoney(room_trade);
  1025. if (nSM2 < 0 || nSM1 + nDM2 - nSM2 < 0)
  1026. {
  1027. this->m_ItemList.TradeMoveMoney(0);
  1028. // 通知客户端钱有问题 not end
  1029. return;
  1030. }
  1031. if (nDM2 < 0 || nDM1 + nSM2 - nDM2 < 0)
  1032. {
  1033. Player[nDestIdx].m_ItemList.TradeMoveMoney(0);
  1034. // 通知客户端钱有问题 not end
  1035. return;
  1036. }
  1037. // ------------------ 检查 money end ------------------
  1039. // --------- 检查双方物品栏能否接受买进的物品 ---------
  1040. int nSelfCanGet, nDestCanGet;
  1042. // 判断己方物品栏能否接受买进的物品
  1043. Player[nDestIdx].m_ItemList.GetTradeRoomItemInfo();
  1044. nSelfCanGet = m_ItemList.TradeCheckCanPlace();
  1045. ItemSet.BackItemInfo();
  1047. // 判断对方物品栏能否接受买进的物品
  1048. this->m_ItemList.GetTradeRoomItemInfo();
  1049. nDestCanGet = Player[nDestIdx].m_ItemList.TradeCheckCanPlace();
  1051. if (!nSelfCanGet || !nDestCanGet)
  1052. {
  1053. if (!nSelfCanGet)
  1054. {
  1055. this->m_cTrade.m_nTradeState = 0;
  1057. // 通知客户端买进的东西放不下
  1058. SHOW_MSG_SYNC sMsg;
  1059. sMsg.ProtocolType = s2c_msgshow;
  1060. sMsg.m_wLength = sizeof(SHOW_MSG_SYNC) - 1 - sizeof(LPVOID);
  1061. sMsg.m_wMsgID = enumMSG_ID_TRADE_SELF_ROOM_FULL;
  1062. g_pServer->PackDataToClient(m_nNetConnectIdx, &sMsg, sMsg.m_wLength + 1);
  1063. sMsg.m_wMsgID = enumMSG_ID_TRADE_DEST_ROOM_FULL;
  1064. g_pServer->PackDataToClient(Player[nDestIdx].m_nNetConnectIdx, &sMsg, sMsg.m_wLength + 1);
  1065. }
  1066. if (!nDestCanGet)
  1067. {
  1068. Player[nDestIdx].m_cTrade.m_nTradeState = 0;
  1070. // 通知客户端买进的东西放不下
  1071. SHOW_MSG_SYNC sMsg;
  1072. sMsg.ProtocolType = s2c_msgshow;
  1073. sMsg.m_wLength = sizeof(SHOW_MSG_SYNC) - 1 - sizeof(LPVOID);
  1074. sMsg.m_wMsgID = enumMSG_ID_TRADE_SELF_ROOM_FULL;
  1075. g_pServer->PackDataToClient(Player[nDestIdx].m_nNetConnectIdx, &sMsg, sMsg.m_wLength + 1);
  1076. sMsg.m_wMsgID = enumMSG_ID_TRADE_DEST_ROOM_FULL;
  1077. g_pServer->PackDataToClient(m_nNetConnectIdx, &sMsg, sMsg.m_wLength + 1);
  1078. }
  1079. SyncTradeState();
  1080. return;
  1081. }
  1082. // ------- 检查双方物品栏能否接受买进的物品 end -------
  1084. // 通知客户端交易完成
  1085. TRADE_DECISION_SYNC sSync;
  1086. sSync.ProtocolType = s2c_tradedecision;
  1087. sSync.m_btDecision = 1;
  1088. g_pServer->PackDataToClient(m_nNetConnectIdx, (BYTE*)&sSync, sizeof(TRADE_DECISION_SYNC));
  1089. g_pServer->PackDataToClient(Player[nDestIdx].m_nNetConnectIdx, (BYTE*)&sSync, sizeof(TRADE_DECISION_SYNC));
  1091. // 服务器端结束交易状态
  1092. m_cMenuState.SetState(m_nPlayerIndex, PLAYER_MENU_STATE_NORMAL);
  1093. Player[nDestIdx].m_cMenuState.SetState(nDestIdx, PLAYER_MENU_STATE_NORMAL);
  1094. this->m_cTrade.Release();
  1095. Player[nDestIdx].m_cTrade.Release();
  1097. // 交易中金钱的交换
  1098. if (nSM2 <= nDM2)
  1099. {
  1100. this->Earn(nDM2 - nSM2);
  1101. Player[nDestIdx].Pay(nDM2 - nSM2);
  1102. }
  1103. else
  1104. {
  1105. this->Pay(nSM2 - nDM2);
  1106. Player[nDestIdx].Earn(nSM2 - nDM2);
  1107. }
  1109. //--------------- 交易中物品的交换 ---------------------
  1110. // 对方的物品给己方
  1111. int nPos;
  1112. nPos = 0;
  1113. while (1)
  1114. {
  1115. if (nPos >= TRADE_ROOM_WIDTH * TRADE_ROOM_HEIGHT)
  1116. break;
  1117. if (!ItemSet.m_psBackItemInfo[nPos].m_nIdx)
  1118. break;
  1119. // 对方去除此物品
  1120. Player[nDestIdx].m_ItemList.Remove(ItemSet.m_psBackItemInfo[nPos].m_nIdx);
  1121. // 己方得到此物品
  1122. m_ItemList.Add(
  1123. ItemSet.m_psBackItemInfo[nPos].m_nIdx,
  1124. pos_equiproom,
  1125. ItemSet.m_psBackItemInfo[nPos].m_nX,
  1126. ItemSet.m_psBackItemInfo[nPos].m_nY);
  1127. nPos++;
  1128. }
  1129. // 己方的物品给对方
  1130. nPos = 0;
  1131. while (1)
  1132. {
  1133. if (nPos >= TRADE_ROOM_WIDTH * TRADE_ROOM_HEIGHT)
  1134. break;
  1135. if (!ItemSet.m_psItemInfo[nPos].m_nIdx)
  1136. break;
  1137. // 己方去除此物品
  1138. this->m_ItemList.Remove(ItemSet.m_psItemInfo[nPos].m_nIdx);
  1139. // 对方得到此物品
  1140. Player[nDestIdx].m_ItemList.Add(
  1141. ItemSet.m_psItemInfo[nPos].m_nIdx,
  1142. pos_equiproom,
  1143. ItemSet.m_psItemInfo[nPos].m_nX,
  1144. ItemSet.m_psItemInfo[nPos].m_nY);
  1145. nPos++;
  1146. }
  1147. //------------- 交易中物品的交换 end -------------------
  1148. return;
  1149. }
  1150. }
  1151. }
  1152. #endif
  1154. #ifdef _SERVER
  1155. //-------------------------------------------------------------------------
  1156. // 功能：执行或取消交易
  1157. //-------------------------------------------------------------------------
  1158. void KPlayer::c2sTradeReplyStart(BYTE* pProtocol)
  1159. {
  1160. if (this->CheckTrading())
  1161. return;
  1162. if (!pProtocol)
  1163. return;
  1164. TRADE_REPLY_START_COMMAND *pReply = (TRADE_REPLY_START_COMMAND*)pProtocol;
  1166. int nPlayerIdx = pReply->m_nDestIdx;
  1167. if (nPlayerIdx <= 0 || nPlayerIdx >= MAX_PLAYER)
  1168. return;
  1169. if (Player[nPlayerIdx].m_nIndex <= 0)
  1170. return;
  1171. if (Player[nPlayerIdx].m_cTrade.m_nApplyIdx != this->m_nPlayerIndex)
  1172. return;
  1174. // 拒绝
  1175. if (pReply->m_bDecision == 0)
  1176. {
  1177. SHOW_MSG_SYNC sMsg;
  1178. sMsg.ProtocolType = s2c_msgshow;
  1179. sMsg.m_wMsgID = enumMSG_ID_TRADE_REFUSE_APPLY;
  1180. sMsg.m_wLength = sizeof(SHOW_MSG_SYNC) - 1;
  1181. sMsg.m_lpBuf = (LPVOID)Npc[m_nIndex].m_dwID;
  1182. g_pServer->PackDataToClient(Player[nPlayerIdx].m_nNetConnectIdx, &sMsg, sMsg.m_wLength + 1);
  1183. sMsg.m_lpBuf = 0;
  1184. return;
  1185. }
  1187. if (this->m_cMenuState.m_nState != PLAYER_MENU_STATE_TRADEOPEN)
  1188. {
  1189. return;
  1190. }
  1192. // 如果处于队伍开放状态，关闭之
  1193. if (Player[nPlayerIdx].m_cMenuState.m_nState == PLAYER_MENU_STATE_TEAMOPEN)
  1194. {
  1195. PLAYER_TEAM_OPEN_CLOSE sClose;
  1196. sClose.m_btOpenClose = 0;
  1197. Player[nPlayerIdx].SetTeamState((BYTE*)&sClose);
  1198. }
  1199. // 打坐的话，要站起来
  1200. if (Npc[m_nIndex].m_Doing == do_sit)
  1201. {
  1202. Npc[m_nIndex].SendCommand(do_stand);
  1203. }
  1204. if (Npc[Player[nPlayerIdx].m_nIndex].m_Doing == do_sit)
  1205. {
  1206. Npc[Player[nPlayerIdx].m_nIndex].SendCommand(do_stand);
  1207. }
  1209. // 服务器的处理：改变状态，备份数据
  1210. this->m_ItemList.StartTrade();
  1211. this->m_cTrade.Release();
  1212. this->m_cTrade.StartTrade(nPlayerIdx);
  1213. this->m_cMenuState.SetState(m_nPlayerIndex, PLAYER_MENU_STATE_TRADING, NULL, 0, Npc[Player[nPlayerIdx].m_nIndex].m_dwID);
  1215. Player[nPlayerIdx].m_ItemList.StartTrade();
  1216. Player[nPlayerIdx].m_cTrade.Release();
  1217. Player[nPlayerIdx].m_cTrade.StartTrade(m_nPlayerIndex);
  1218. Player[nPlayerIdx].m_cMenuState.SetState(nPlayerIdx, PLAYER_MENU_STATE_TRADING, NULL, 0, Npc[m_nIndex].m_dwID);
  1219. }
  1220. #endif
  1222. //-------------------------------------------------------------------------
  1223. // 功能：给交易双方的客户端发送交易状态信息
  1224. //-------------------------------------------------------------------------
  1225. #ifdef _SERVER
  1226. void KPlayer::SyncTradeState()
  1227. {
  1228. if ( !CheckTrading() )
  1229. return;
  1231. TRADE_STATE_SYNC sSync;
  1232. sSync.ProtocolType = s2c_tradepressoksync;
  1233. sSync.m_btSelfLock = this->m_cTrade.m_nTradeLock;
  1234. sSync.m_btDestLock = Player[m_cTrade.m_nTradeDest].m_cTrade.m_nTradeLock;
  1235. sSync.m_btSelfOk = m_cTrade.m_nTradeState;
  1236. sSync.m_btDestOk = Player[m_cTrade.m_nTradeDest].m_cTrade.m_nTradeState;
  1237. g_pServer->PackDataToClient(m_nNetConnectIdx, (BYTE*)&sSync, sizeof(TRADE_STATE_SYNC));
  1239. sSync.m_btSelfLock = Player[m_cTrade.m_nTradeDest].m_cTrade.m_nTradeLock;
  1240. sSync.m_btDestLock = m_cTrade.m_nTradeLock;
  1241. sSync.m_btSelfOk = Player[m_cTrade.m_nTradeDest].m_cTrade.m_nTradeState;
  1242. sSync.m_btDestOk = m_cTrade.m_nTradeState;
  1243. g_pServer->PackDataToClient(Player[m_cTrade.m_nTradeDest].m_nNetConnectIdx, (BYTE*)&sSync, sizeof(TRADE_STATE_SYNC));
  1244. }
  1245. #endif
  1247. //-------------------------------------------------------------------------
  1248. // 功能：发送自己装备在身上的装备信息给别人看
  1249. //-------------------------------------------------------------------------
  1250. #ifdef _SERVER
  1251. void KPlayer::SendEquipItemInfo(int nTargetPlayer)
  1252. {
  1253. if (nTargetPlayer <= 0 || nTargetPlayer >= MAX_PLAYER || Player[nTargetPlayer].m_nIndex <= 0)
  1254. return;
  1256. int nIdx, i, j;
  1257. SViewItemInfo *pInfo;
  1258. VIEW_EQUIP_SYNC sView;
  1260. sView.ProtocolType = s2c_viewequip;
  1261. sView.m_dwNpcID = Npc[m_nIndex].m_dwID;
  1262. for (i = 0; i < itempart_num; i++)
  1263. {
  1264. nIdx = m_ItemList.m_EquipItem[i];
  1265. pInfo = &sView.m_sInfo[i];
  1266. if (nIdx <= 0)
  1267. {
  1268. memset(pInfo, 0, sizeof(SViewItemInfo));
  1269. continue;
  1270. }
  1271. pInfo->m_nID = Item[nIdx].GetID();
  1272. pInfo->m_btGenre = Item[nIdx].GetGenre();
  1273. pInfo->m_btDetail = Item[nIdx].GetDetailType();
  1274. pInfo->m_btParticur = Item[nIdx].GetParticular();
  1275. pInfo->m_btSeries = Item[nIdx].GetSeries();
  1276. pInfo->m_btLevel = Item[nIdx].GetLevel();
  1277. pInfo->m_btLuck = Item[nIdx].m_GeneratorParam.nLuck;
  1278. pInfo->m_dwRandomSeed = Item[nIdx].m_GeneratorParam.uRandomSeed;
  1279. pInfo->m_wVersion = Item[nIdx].m_GeneratorParam.nVersion;
  1280. for (j = 0; j < 6; j++)
  1281. pInfo->m_btMagicLevel[j] = (BYTE)Item[nIdx].m_GeneratorParam.nGeneratorLevel[j];
  1282. }
  1284. g_pServer->PackDataToClient(Player[nTargetPlayer].m_nNetConnectIdx, (BYTE*)&sView, sizeof(sView));
  1285. }
  1286. #endif
  1288. #ifdef _SERVER
  1289. //-------------------------------------------------------------------------
  1290. // 功能：主角与传送门的相关的函数
  1291. //-------------------------------------------------------------------------
  1292. void KPlayer::UseTownPortal()
  1293. {
  1294. if (m_nPlayerIndex <= 0)
  1295. return;
  1296. if (m_nIndex <= 0)
  1297. return;
  1298. if (Npc[m_nIndex].m_SubWorldIndex < 0)
  1299. return;
  1301. if (!Npc[m_nIndex].m_FightMode)
  1302. {
  1303. return;
  1304. }
  1306. m_sPortalPos.m_nSubWorldId = SubWorld[Npc[m_nIndex].m_SubWorldIndex].m_SubWorldID;
  1307. Npc[m_nIndex].GetMpsPos(&m_sPortalPos.m_nMpsX, &m_sPortalPos.m_nMpsY);
  1308. m_sPortalPos.m_nTime = TOWN_PORTAL_TIME;
  1310. Npc[m_nIndex].ChangeWorld(m_sDeathRevivalPos.m_nSubWorldID, m_sDeathRevivalPos.m_nMpsX, m_sDeathRevivalPos.m_nMpsY);
  1311. Npc[m_nIndex].SetFightMode(0);
  1312. }
  1314. void KPlayer::BackToTownPortal()
  1315. {
  1316. if (m_nPlayerIndex <= 0)
  1317. return;
  1318. if (m_nIndex <= 0)
  1319. return;
  1320. if (m_sPortalPos.m_nTime <= 0)
  1321. return;
  1323. Npc[m_nIndex].ChangeWorld(m_sPortalPos.m_nSubWorldId, m_sPortalPos.m_nMpsX, m_sPortalPos.m_nMpsY);
  1324. m_sPortalPos.m_nSubWorldId = 0;
  1325. m_sPortalPos.m_nTime = 0;
  1326. m_sPortalPos.m_nMpsX = 0;
  1327. m_sPortalPos.m_nMpsY = 0;
  1328. Npc[m_nIndex].SetFightMode(TRUE);
  1329. }
  1330. #endif
  1332. #ifdef _SERVER
  1333. //-------------------------------------------------------------------------
  1334. // 功能：主角死后重生
  1335. //-------------------------------------------------------------------------
  1336. void KPlayer::Revive(int nType)
  1337. {
  1338. int nSubWorldID = 0;
  1339. int nMpsX = 0, nMpsY = 0;
  1341. NPC_REVIVE_SYNC Sync;
  1342. Sync.ProtocolType = s2c_playerrevive;
  1343. Sync.ID = Npc[m_nIndex].m_dwID;
  1344. Sync.Type = nType;
  1345. g_pServer->PackDataToClient(m_nNetConnectIdx, (const void*)&Sync, sizeof(NPC_REVIVE_SYNC));
  1346. Npc[m_nIndex].BroadCastRevive(nType);
  1348. switch(nType)
  1349. {
  1350. case REMOTE_REVIVE_TYPE:
  1351. GetDeathRevivalPos(&nSubWorldID, &nMpsX, &nMpsY);
  1352. Npc[m_nIndex].ChangeWorld(nSubWorldID, nMpsX, nMpsY);
  1353. Npc[m_nIndex].m_FightMode = 0;
  1354. break;
  1355. case LOCAL_REVIVE_TYPE:
  1356. Npc[m_nIndex].m_FightMode = 1;
  1357. break;
  1358. default:
  1359. break;
  1360. }
  1362. Npc[m_nIndex].m_CurrentLife = Npc[m_nIndex].m_CurrentLifeMax;
  1363. Npc[m_nIndex].m_CurrentMana = Npc[m_nIndex].m_CurrentManaMax;
  1364. Npc[m_nIndex].m_CurrentStamina = Npc[m_nIndex].m_CurrentStaminaMax;
  1365. //RestoreLiveData();
  1366. Npc[m_nIndex].SendCommand(do_revive);
  1367. }
  1370. void KPlayer::RestoreLiveData()
  1371. {
  1372. Npc[m_nIndex].RestoreNpcBaseInfo();
  1373. }
  1375. BOOL KPlayer::Pay(int nMoney)
  1376. {
  1377. if (nMoney < 0)
  1378. return FALSE;
  1380. return m_ItemList.CostMoney(nMoney);
  1381. }
  1383. BOOL KPlayer::PrePay(int nMoney)
  1384. {
  1385. if (nMoney < 0)
  1386. return FALSE;
  1388. if (Pay(nMoney))
  1389. {
  1390. m_nPrePayMoney = nMoney;
  1391. return TRUE;
  1392. }
  1393. else
  1394. {
  1395. return FALSE;
  1396. }
  1397. }
  1399. BOOL KPlayer::Earn(int nMoney)
  1400. {
  1401. if (nMoney < 0)
  1402. return FALSE;
  1403. return m_ItemList.AddMoney(room_equipment, nMoney);
  1404. }
  1406. //当服务器从数据库中获得玩家全部数据，并加载之后，使该玩家有效
  1407. void KPlayer::LaunchPlayer()
  1408. {
  1409. int nSubWorld = Npc[m_nIndex].m_SubWorldIndex;
  1410. int nRegion = Npc[m_nIndex].m_RegionIndex;
  1411. int nX = Npc[m_nIndex].m_MapX;
  1412. int nY = Npc[m_nIndex].m_MapY;
  1413. int nOffX = Npc[m_nIndex].m_OffX;
  1414. int nOffY = Npc[m_nIndex].m_OffY;
  1415. SubWorld[nSubWorld].AddPlayer(nRegion, m_nPlayerIndex);
  1416. m_ulLastSaveTime = g_SubWorldSet.GetGameTime();
  1417. if (SubWorld[nSubWorld].m_Region[nRegion].GetBarrierMin(nX, nY, nOffX, nOffY, FALSE) != Obstacle_NULL)
  1418. {
  1419. Npc[m_nIndex].ChangeWorld(m_sLoginRevivalPos.m_nSubWorldID, m_sLoginRevivalPos.m_nMpsX, m_sLoginRevivalPos.m_nMpsY);
  1420. }
  1422. }
  1423. #endif
  1426. BOOL KPlayer::ExecuteScript(char * ScriptFileName, char * szFunName, int nParam)
  1427. {
  1428. if (!ScriptFileName || !ScriptFileName[0] || !szFunName  || !szFunName[0]) return FALSE;
  1429. return ExecuteScript(g_FileName2Id(ScriptFileName), szFunName, nParam);
  1430. }
  1431. #define MAX_TRYEXECUTESCRIPT_COUNT 5
  1432. BOOL KPlayer::ExecuteScript(DWORD dwScriptId,  char * szFunName, int nParam)
  1433. {
  1434. /* bool bCanExecuteScript = true;
  1436.   //当前脚本未置空
  1437.   if (m_bWaitingPlayerFeedBack)
  1438.   {
  1439. if (Npc[m_nIndex].m_ActionScriptID && (dwScriptId != Npc[m_nIndex].m_ActionScriptID))
  1440. {
  1441. m_btTryExecuteScriptTimes ++;
  1442. if (m_btTryExecuteScriptTimes <= MAX_TRYEXECUTESCRIPT_COUNT)//最大尝试执行脚本的次数。如果超过后，就执行当前脚本，并放弃原来的脚本。
  1443. {
  1444. bCanExecuteScript = false;
  1445. }
  1446. else
  1447. {
  1448. m_btTryExecuteScriptTimes = 0;
  1449. m_bWaitingPlayerFeedBack = false;
  1450. Npc[m_nIndex].m_ActionScriptID = 0;
  1451. }
  1452. }
  1453. }
  1455.   if (!bCanExecuteScript) return FALSE;
  1456. */
  1457. try
  1458. {
  1459. m_btTryExecuteScriptTimes = 0;
  1460. bool bExecuteScriptMistake = true;
  1461. KLuaScript * pScript = (KLuaScript* )g_GetScript(dwScriptId);
  1462. if (pScript)
  1463. {
  1464. Npc[m_nIndex].m_ActionScriptID = dwScriptId;
  1465. Lua_PushNumber(pScript->m_LuaState, m_nPlayerIndex);
  1466. pScript->SetGlobalName(SCRIPT_PLAYERINDEX);
  1468. Lua_PushNumber(pScript->m_LuaState, m_dwID);
  1469. pScript->SetGlobalName(SCRIPT_PLAYERID);
  1471. Lua_PushNumber(pScript->m_LuaState, Npc[m_nIndex].m_SubWorldIndex);
  1472. pScript->SetGlobalName(SCRIPT_SUBWORLDINDEX);
  1473. int nTopIndex = 0;
  1475. pScript->SafeCallBegin(&nTopIndex);
  1476. if (pScript->CallFunction(szFunName,0, "d", nParam)) 
  1477. {
  1478. bExecuteScriptMistake = false;
  1479. }
  1480. pScript->SafeCallEnd(nTopIndex);
  1481. }
  1483. if (bExecuteScriptMistake)
  1484. {
  1485. m_bWaitingPlayerFeedBack = false;
  1486. m_btTryExecuteScriptTimes = 0;
  1487. Npc[m_nIndex].m_ActionScriptID = 0;
  1488. return FALSE;
  1489. }
  1491. return TRUE;
  1492. }
  1493. catch(...)
  1494. {
  1495. printf("Exception Have Caught When Execute Script[%d]!!!!!", dwScriptId);
  1496. m_bWaitingPlayerFeedBack = false;
  1497. m_btTryExecuteScriptTimes = 0;
  1498. Npc[m_nIndex].m_ActionScriptID = 0;
  1499. return FALSE;
  1500. }
  1501. return TRUE;
  1502. }
  1504. BOOL KPlayer::ExecuteScript(DWORD dwScriptId, char * szFunName, char *  szParams)
  1505. {
  1506. /*bool bCanExecuteScript = true;
  1508.   //当前脚本未置空
  1509.   if (m_bWaitingPlayerFeedBack)
  1510.   {
  1511. if (Npc[m_nIndex].m_ActionScriptID && (dwScriptId != Npc[m_nIndex].m_ActionScriptID))
  1512. {
  1513. m_btTryExecuteScriptTimes ++;
  1514. if (m_btTryExecuteScriptTimes <= MAX_TRYEXECUTESCRIPT_COUNT)//最大尝试执行脚本的次数。如果超过后，就执行当前脚本，并放弃原来的脚本。
  1515. {
  1516. bCanExecuteScript = false;
  1517. }
  1518. else
  1519. {
  1520. m_btTryExecuteScriptTimes = 0;
  1521. m_bWaitingPlayerFeedBack = false;
  1522. Npc[m_nIndex].m_ActionScriptID = 0;
  1523. }
  1524. }
  1525. }
  1527.   bCanExecuteScript = true;//test
  1528.   
  1529. if (!bCanExecuteScript) return FALSE;
  1530. */
  1532. try
  1533. {
  1534. m_btTryExecuteScriptTimes = 0;
  1535. bool bExecuteScriptMistake = true;
  1536. KLuaScript * pScript = (KLuaScript* )g_GetScript(dwScriptId);
  1537. int nTopIndex = 0;
  1539. if (pScript)
  1540. {
  1541. Npc[m_nIndex].m_ActionScriptID = dwScriptId;
  1542. Lua_PushNumber(pScript->m_LuaState, m_nPlayerIndex);
  1543. pScript->SetGlobalName(SCRIPT_PLAYERINDEX);
  1545. Lua_PushNumber(pScript->m_LuaState, m_dwID);
  1546. pScript->SetGlobalName(SCRIPT_PLAYERID);
  1548. Lua_PushNumber(pScript->m_LuaState, Npc[m_nIndex].m_SubWorldIndex);
  1549. pScript->SetGlobalName(SCRIPT_SUBWORLDINDEX);
  1551. pScript->SafeCallBegin(&nTopIndex);
  1553. if ( (!szParams) || !szParams[0]) 
  1554. {
  1555. if (pScript->CallFunction(szFunName, 0,""))
  1556. {
  1557. bExecuteScriptMistake = false;
  1558. }
  1559. }
  1560. else
  1561. {
  1562. if (pScript->CallFunction(szFunName,0, "sd", szParams,0)) 
  1563. {
  1564. bExecuteScriptMistake = false;
  1565. }
  1566. }
  1567. pScript->SafeCallEnd(nTopIndex);
  1568. }
  1570. if (bExecuteScriptMistake)
  1571. {
  1572. m_bWaitingPlayerFeedBack = false;
  1573. m_btTryExecuteScriptTimes = 0;
  1574. Npc[m_nIndex].m_ActionScriptID = 0;
  1575. return FALSE;
  1576. }
  1577. return TRUE;
  1578. }
  1579. catch(...)
  1580. {
  1581. printf("Exception Have Caught When Execute Script[%d]!!!!!", dwScriptId);
  1582. m_bWaitingPlayerFeedBack = false;
  1583. m_btTryExecuteScriptTimes = 0;
  1584. Npc[m_nIndex].m_ActionScriptID = 0;
  1585. return FALSE;
  1586. }
  1587. return TRUE;
  1588. }
  1591. BOOL KPlayer::ExecuteScript(char * ScriptFileName, char * szFunName, char *  szParams)
  1592. {
  1593. if (!ScriptFileName || !ScriptFileName[0] || !szFunName  || !szFunName[0]) return FALSE;
  1594. DWORD dwScriptId = g_FileName2Id(ScriptFileName);
  1595. return ExecuteScript(dwScriptId, szFunName, szParams);
  1596. }
  1598. BOOL KPlayer::DoScript(char * ScriptCommand)
  1599. {
  1600. if (NULL == ScriptCommand) return FALSE;
  1601. KLuaScript *Script = new KLuaScript;
  1602. Script->Init();
  1603. Script->RegisterFunctions(GameScriptFuns, g_GetGameScriptFunNum());
  1605. //GM Standand Script Functions 
  1606. Script->Load("\script\gmscript.lua");
  1609. Lua_PushNumber(Script->m_LuaState, m_nPlayerIndex);
  1610. Script->SetGlobalName(SCRIPT_PLAYERINDEX);
  1611. Lua_PushNumber(Script->m_LuaState, m_dwID);
  1612. Script->SetGlobalName(SCRIPT_PLAYERID);
  1614. Lua_PushNumber(Script->m_LuaState, Npc[m_nIndex].m_SubWorldIndex);
  1615. Script->SetGlobalName(SCRIPT_SUBWORLDINDEX);
  1617. if (Script->LoadBuffer((PBYTE)ScriptCommand, strlen(ScriptCommand))) 
  1618. {
  1619. BOOL bResult = Script->ExecuteCode();
  1620. delete Script; //Question!
  1621. return bResult;
  1622. }
  1623. delete Script; //Question!
  1624. return FALSE;
  1625. }
  1628. void KPlayer::DoScriptAction(PLAYER_SCRIPTACTION_SYNC * pUIInfo) //要求显示某个UI界面
  1629. {
  1630. if (!pUIInfo) return;
  1632. //服务器端脚本时
  1633. if (pUIInfo->m_bParam2 == 1)
  1634. {
  1635. #ifdef _SERVER
  1636. pUIInfo->ProtocolType = (BYTE)s2c_scriptaction;
  1637. pUIInfo->m_wProtocolLong = sizeof(PLAYER_SCRIPTACTION_SYNC) - MAX_SCIRPTACTION_BUFFERNUM + pUIInfo->m_nBufferLen - 1;
  1638. g_pServer->PackDataToClient(m_nNetConnectIdx, (BYTE*)pUIInfo, pUIInfo->m_wProtocolLong + 1 );
  1639. #else
  1640. }
  1641. else //客户端脚本要求显示脚本 直接运行
  1642. {
  1643. OnScriptAction((PLAYER_SCRIPTACTION_SYNC *)pUIInfo);
  1644. #endif
  1645. }
  1647. }
  1649. //服务器端获知玩家选择了某项后，处理~~
  1650. void KPlayer::ProcessPlayerSelectFromUI(BYTE* pProtocol) // 处理当玩家从选择菜单选择某项时的操作
  1651. {
  1652. PLAYER_SELECTUI_COMMAND * pSelUI = (PLAYER_SELECTUI_COMMAND*) pProtocol;
  1653. m_bWaitingPlayerFeedBack = false;
  1654. //如果返回负数，表示退出该脚本执行环境
  1655. if (pSelUI->nSelectIndex < 0) m_nAvailableAnswerNum = 0;
  1656. if (m_nAvailableAnswerNum > pSelUI->nSelectIndex)
  1657. {
  1658. if (m_szTaskAnswerFun[pSelUI->nSelectIndex][0])
  1659. {
  1660. // g_SetFilePath("\script");
  1661. if (m_nIndex)
  1662. {
  1663. ExecuteScript(Npc[m_nIndex].m_ActionScriptID, m_szTaskAnswerFun[pSelUI->nSelectIndex], pSelUI->nSelectIndex);
  1664. }
  1665. }
  1666. }
  1667. }
  1669. #ifndef _SERVER
  1670. //玩家在界面交互后，选择了某项后，向服务器端发送
  1671. void KPlayer::OnSelectFromUI(PLAYER_SELECTUI_COMMAND * pSelectUI, UIInfo eUIInfo) //当玩家从选择框中选择某项后，将向服务器发送
  1672. {
  1673. if (!pSelectUI) return;
  1675. switch(eUIInfo)
  1676. {
  1677. case UI_SELECTDIALOG:
  1678. {
  1679. if (g_bUISelIntelActiveWithServer)
  1680. {
  1681. pSelectUI->ProtocolType = (BYTE)c2s_playerselui;
  1682. if (g_pClient)
  1683. g_pClient->SendPackToServer((BYTE*)pSelectUI, sizeof(PLAYER_SELECTUI_COMMAND));
  1684. }
  1685. else
  1686. {
  1687. ProcessPlayerSelectFromUI((BYTE *)pSelectUI); // 处理当玩家从选择菜单选择某项时的操作
  1688. }
  1689. }
  1690. break;
  1691. case UI_TALKDIALOG:
  1692. {
  1693. if (g_bUISpeakActiveWithServer)
  1694. {
  1695. pSelectUI->ProtocolType = (BYTE)c2s_playerselui;
  1696. if (g_pClient)
  1697. g_pClient->SendPackToServer((BYTE*)pSelectUI, sizeof(PLAYER_SELECTUI_COMMAND));
  1698. }
  1699. else
  1700. {
  1701. ProcessPlayerSelectFromUI((BYTE *)pSelectUI); // 处理当玩家从选择菜单选择某项时的操作
  1702. }
  1704. }break;
  1705. }
  1706. }
  1707. #endif
  1709. //-------------------------------------------------------------------------
  1710. // 功能：获得通知某好友上线了
  1711. //-------------------------------------------------------------------------
  1712. void KPlayer::ChatFriendOnLine(DWORD dwID, int nFriendIdx)
  1713. {
  1714. if (nFriendIdx <= 0)
  1715. return;
  1716. for (int i = 0; i < MAX_FRIEND_TEAM; i++)
  1717. {
  1718. if (m_cChat.m_cFriendTeam[i].m_nFriendNo == 0)
  1719. continue;
  1720. CChatFriend *pFriend;
  1721. pFriend = (CChatFriend*)m_cChat.m_cFriendTeam[i].m_cEveryOne.GetHead();
  1722. while (pFriend)
  1723. {
  1724. if (pFriend->m_dwID == dwID)
  1725. {
  1726. pFriend->m_nPlayerIdx = nFriendIdx;
  1727. #ifdef _SERVER
  1728. CHAT_FRIEND_ONLINE_SYNC sFriend;
  1729. sFriend.ProtocolType = s2c_chatfriendonline;
  1730. sFriend.m_dwID = dwID;
  1731. sFriend.m_nPlayerIdx = nFriendIdx;
  1732. g_pServer->PackDataToClient(m_nNetConnectIdx, (BYTE*)&sFriend, sizeof(CHAT_FRIEND_ONLINE_SYNC));
  1733. #else
  1734. // 通知界面有好友上线
  1735. KUiPlayerItem sPlayer;
  1736. strcpy(sPlayer.Name, pFriend->m_szName);
  1737. sPlayer.uId = dwID;
  1738. sPlayer.nIndex = nFriendIdx;
  1739. sPlayer.nData = CHAT_S_ONLINE;
  1740. CoreDataChanged(GDCNI_CHAT_FRIEND_STATUS, (unsigned int)&sPlayer, i);
  1742. KSystemMessage sMsg;
  1743. sprintf(sMsg.szMessage, MSG_CHAT_FRIEND_ONLINE, pFriend->m_szName);
  1744. sMsg.eType = SMT_NORMAL;
  1745. sMsg.byConfirmType = SMCT_NONE;
  1746. sMsg.byPriority = 0;
  1747. sMsg.byParamSize = 0;
  1748. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  1749. #endif
  1750. return;
  1751. }
  1752. pFriend = (CChatFriend*)pFriend->GetNext();
  1753. }
  1754. }
  1755. #ifdef _SERVER
  1756. // 如果没找到，说明本方已经删除了对方，必须通知对方删除
  1757. Player[nFriendIdx].m_cChat.DeleteFriendData(m_dwID, nFriendIdx);
  1758. #endif
  1759. }
  1761. // 获得当前门派名称
  1762. void KPlayer::GetFactionName(char *lpszName, int nSize)
  1763. {
  1764. this->m_cFaction.GetCurFactionName(lpszName);
  1765. return;
  1766. }
  1767. #ifdef _SERVER
  1768. void KPlayer::S2CExecuteScript(char * ScriptName, char * szParam = NULL)
  1769. {
  1770. if (!ScriptName || (!ScriptName[0])) return; 
  1772. PLAYER_SCRIPTACTION_SYNC  ScriptAction;
  1773. ScriptAction.m_nOperateType = SCRIPTACTION_EXESCRIPT;
  1774. ScriptAction.ProtocolType = s2c_scriptaction;
  1775. char * script = NULL;
  1776. if (szParam == NULL || szParam[0] == 0) 
  1777. {
  1778. ScriptAction.m_nBufferLen = strlen(ScriptName) + 1 ;
  1779. strcpy(ScriptAction.m_pContent, ScriptName);
  1780. }
  1781. else
  1782. {
  1783. ScriptAction.m_nBufferLen = strlen(ScriptName) + 2 + strlen(szParam);
  1784. sprintf(ScriptAction.m_pContent, "%s|%s", ScriptName, szParam);
  1785. }
  1786. ScriptAction.m_wProtocolLong = sizeof(PLAYER_SCRIPTACTION_SYNC) - 300 + ScriptAction.m_nBufferLen - 1;
  1787. g_pServer->PackDataToClient(m_nNetConnectIdx, (BYTE*)&ScriptAction, sizeof(PLAYER_SCRIPTACTION_SYNC) - 300 + ScriptAction.m_nBufferLen);
  1789. }
  1790. #endif
  1792. #ifndef _SERVER
  1793. void KPlayer::OnScriptAction(PLAYER_SCRIPTACTION_SYNC * pMsg)
  1794. {
  1795. PLAYER_SCRIPTACTION_SYNC * pScriptAction = (PLAYER_SCRIPTACTION_SYNC *)pMsg;
  1796. char szString[1000];
  1798. switch(pScriptAction->m_nOperateType)
  1799. {
  1800. case SCRIPTACTION_UISHOW:
  1801. {
  1802. switch(pScriptAction->m_bUIId)
  1803. {
  1804. case UI_SELECTDIALOG://通知客户端显示选择窗口
  1805. {
  1806. KUiQuestionAndAnswer *pQuest = NULL;
  1807. if (pScriptAction->m_nBufferLen <= 0) break;
  1809. if (pScriptAction->m_bOptionNum <= 0)
  1810. pQuest = (KUiQuestionAndAnswer *)malloc(sizeof(KUiQuestionAndAnswer));
  1811. else
  1812. pQuest = (KUiQuestionAndAnswer *)malloc(sizeof(KUiQuestionAndAnswer) + sizeof(KUiAnswer) * (pScriptAction->m_bOptionNum - 1));
  1814. char strContent[1024];
  1815. char * pAnswer = NULL;
  1816. pQuest->AnswerCount = 0;
  1817. //主信息为字符串
  1818. if (pScriptAction->m_bParam1 == 0)
  1819. {
  1820. g_StrCpyLen(strContent, pScriptAction->m_pContent,  pScriptAction->m_nBufferLen + 1);
  1821. pAnswer = strstr(strContent, "|");
  1822. if (!pAnswer)
  1823. {
  1824. pScriptAction->m_bOptionNum = 0;
  1825. pQuest->AnswerCount = 0;
  1826. }
  1827. else
  1828. *pAnswer++ = 0;
  1830. g_StrCpyLen(pQuest->Question, strContent, sizeof(pQuest->Question));
  1831. pQuest->QuestionLen = TEncodeText(pQuest->Question, strlen(pQuest->Question));
  1832. }
  1833. //主信息为数字标识
  1834. else 
  1835. {
  1836. g_StrCpyLen(pQuest->Question, g_GetStringRes(*(int *)pScriptAction->m_pContent, szString, 1000), sizeof(pQuest->Question));
  1837. pQuest->QuestionLen = TEncodeText(pQuest->Question, strlen(pQuest->Question));
  1839. g_StrCpyLen(strContent, pScriptAction->m_pContent + sizeof(int), pScriptAction->m_nBufferLen - sizeof(int) + 1);
  1840. pAnswer = strContent + 1;
  1841. }
  1843. for (int i = 0; i < pScriptAction->m_bOptionNum; i ++)
  1844. {
  1845. char * pNewAnswer = strstr(pAnswer, "|");
  1847. if (pNewAnswer)
  1848. {
  1849. *pNewAnswer = 0;
  1850. strcpy(pQuest->Answer[i].AnswerText, pAnswer);
  1851. pQuest->Answer[i].AnswerLen = -1;
  1852. pAnswer = pNewAnswer + 1;
  1853. }
  1854. else
  1855. {
  1856. strcpy(pQuest->Answer[i].AnswerText, pAnswer);
  1857. pQuest->Answer[i].AnswerLen = -1;
  1858. pQuest->AnswerCount = i + 1;
  1859. break;
  1860. }
  1861. }
  1863. g_bUISelIntelActiveWithServer = pScriptAction->m_bParam2;
  1864. g_bUISelLastSelCount = pQuest->AnswerCount;
  1865. CoreDataChanged(GDCNI_QUESTION_CHOOSE,(unsigned int) pQuest, 0);
  1866. free(pQuest);
  1867. pQuest = NULL;
  1868. }
  1869. break;
  1871. case UI_TALKDIALOG: 
  1872. {
  1873. BOOL bUsingSpeakId = pScriptAction->m_bParam1;
  1874. int  nSentenceCount = pScriptAction->m_bOptionNum;
  1875. if (nSentenceCount <= 0) return ;
  1876. KUiInformationParam *pSpeakList  = new KUiInformationParam[nSentenceCount];
  1877. memset(pSpeakList, 0, sizeof(KUiInformationParam) * nSentenceCount);
  1879. char * pAnswer = new char [pScriptAction->m_nBufferLen + 1];
  1880. char * pBackupAnswer = pAnswer;
  1881. g_StrCpyLen(pAnswer, pScriptAction->m_pContent, pScriptAction->m_nBufferLen + 1);
  1883. int nCount = 0;
  1884. for (int i = 0; i < pScriptAction->m_bOptionNum; i ++)
  1885. {
  1886. char * pNewAnswer = strstr(pAnswer, "|");
  1888. if (pNewAnswer)
  1889. {
  1890. *pNewAnswer = 0;
  1891. if (!bUsingSpeakId)
  1892. {
  1893. strcpy(pSpeakList[i].sInformation, pAnswer);
  1895. }
  1896. else
  1897. {
  1898. strcpy(pSpeakList[i].sInformation, g_GetStringRes(atoi(pAnswer), szString, sizeof(szString)));
  1899. }
  1902. if (i < pScriptAction->m_bOptionNum - 1)
  1903. strcpy(pSpeakList[i].sConfirmText, "继续");
  1904. else 
  1905. {
  1906. strcpy(pSpeakList[i].sConfirmText, "完成");
  1907. if (pScriptAction->m_nParam == 1)
  1908. pSpeakList[i].bNeedConfirmNotify = TRUE;
  1910. }
  1911. pSpeakList[i].nInforLen = TEncodeText(pSpeakList[i].sInformation, strlen(pSpeakList[i].sInformation));
  1912. pAnswer = pNewAnswer + 1;
  1913. }
  1914. else
  1915. {
  1916. if (!bUsingSpeakId)
  1917. {
  1918. strcpy(pSpeakList[i].sInformation, pAnswer);
  1919. }
  1920. else
  1921. {
  1922. strcpy(pSpeakList[i].sInformation, g_GetStringRes(atoi(pAnswer), szString ,sizeof(szString)));
  1923. }
  1925. strcpy(pSpeakList[i].sConfirmText, "完成");
  1927. if (pScriptAction->m_nParam == 1)
  1928. pSpeakList[i].bNeedConfirmNotify = TRUE;
  1930. pSpeakList[i].nInforLen = TEncodeText(pSpeakList[i].sInformation, strlen(pSpeakList[i].sInformation));
  1931. nCount++;
  1932. break;
  1933. }
  1934. nCount ++;
  1935. }
  1936. if (pBackupAnswer)
  1937. {
  1938. delete []pBackupAnswer;
  1939. pBackupAnswer = NULL;
  1940. }
  1941. g_bUISpeakActiveWithServer = pScriptAction->m_bParam2;
  1942. CoreDataChanged(GDCNI_SPEAK_WORDS,(unsigned int)pSpeakList, nCount);
  1943. if (pSpeakList)
  1944. {
  1945. delete pSpeakList;
  1946. pSpeakList = NULL;
  1947. }
  1948. }
  1949. break;
  1950. case UI_NOTEINFO:
  1951. {
  1952. if (pScriptAction->m_nBufferLen <= 0) 
  1953. break;
  1954. KMissionRecord Record;
  1955. //主信息为字符串
  1956. if (pScriptAction->m_bParam1 == 0)
  1957. {
  1958. g_StrCpyLen(Record.sContent, pScriptAction->m_pContent,  pScriptAction->m_nBufferLen - sizeof(int) - 1);
  1959. Record.uValue = *(unsigned int*) (pScriptAction->m_pContent + pScriptAction->m_nBufferLen - sizeof(int));
  1960. }
  1961. else
  1962. {
  1963. g_GetStringRes(*(int *)pScriptAction->m_pContent, Record.sContent ,sizeof(Record.sContent));
  1964. Record.uValue = *(unsigned int* ) (Record.sContent + sizeof(int));
  1965. }
  1968. Record.nContentLen = TEncodeText(Record.sContent, strlen(Record.sContent));
  1970. CoreDataChanged(GDCNI_MISSION_RECORD, (unsigned long)&Record, 0);
  1972. }
  1973. break;
  1974. case UI_MSGINFO:
  1975. {
  1976. if (pScriptAction->m_nBufferLen <= 0) 
  1977. break;
  1979. char strContent[1024];
  1980. //主信息为字符串
  1981. if (pScriptAction->m_bParam1 == 0)
  1982. {
  1983. g_StrCpyLen(strContent, pScriptAction->m_pContent,  pScriptAction->m_nBufferLen + 1);
  1984. }
  1985. else
  1986. {
  1987. g_GetStringRes(*(int *)pScriptAction->m_pContent, strContent ,sizeof(strContent));
  1988. }
  1990. KSystemMessage sMsg;
  1991. sMsg.eType = SMT_PLAYER;
  1992. sMsg.byConfirmType = SMCT_MSG_BOX;
  1993. sMsg.byPriority = 0;
  1994. sMsg.byParamSize = 0;
  1995. g_StrCpyLen(sMsg.szMessage, strContent, sizeof(sMsg.szMessage));
  1997. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  1998. //CoreDataChanged(GDCNI_MISSION_RECORD, (unsigned int)strContent, strlen(strContent));
  2000. }break;
  2002. case UI_NEWSINFO:
  2003. {
  2004. if (pScriptAction->m_nBufferLen <= 0) 
  2005. break;
  2006. switch(pScriptAction->m_bOptionNum) //OPtionNum代表是哪一种News类型
  2007. {
  2008. case NEWSMESSAGE_NORMAL:
  2009. {
  2011. KNewsMessage News;
  2012. News.nType = NEWSMESSAGE_NORMAL;
  2014. char strContent[1024];
  2015. //主信息为字符串
  2016. if (pScriptAction->m_bParam1 == 0)
  2017. {
  2018. g_StrCpyLen(strContent, pScriptAction->m_pContent,  pScriptAction->m_nBufferLen + 1);
  2019. }
  2020. else
  2021. {
  2022. g_GetStringRes(*(int *)pScriptAction->m_pContent, strContent ,sizeof(strContent));
  2023. }
  2025. g_StrCpyLen(News.sMsg,  strContent, sizeof(News.sMsg));
  2027. News.nMsgLen = TEncodeText(News.sMsg, strlen(News.sMsg));
  2028. CoreDataChanged(GDCNI_NEWS_MESSAGE, (unsigned int)&News, 0);
  2029. }
  2030. break;
  2031. //STRING|STRINGID + TIME(INT)
  2032. case NEWSMESSAGE_COUNTING:
  2033. {
  2034. KNewsMessage News;
  2035. News.nType = pScriptAction->m_bOptionNum;
  2037. char strContent[1024];
  2038. int nTime = 0;
  2039. //主信息为字符串
  2040. if (pScriptAction->m_bParam1 == 0)
  2041. {
  2042. g_StrCpyLen(strContent, pScriptAction->m_pContent,  pScriptAction->m_nBufferLen - sizeof(int) + 1);
  2043. }
  2044. else
  2045. {
  2046. g_GetStringRes(*(int *)pScriptAction->m_pContent, strContent ,sizeof(strContent));
  2047. }
  2049. g_StrCpyLen(News.sMsg,  strContent, sizeof(News.sMsg));
  2050. News.nMsgLen = TEncodeText(News.sMsg, strlen(News.sMsg));
  2051. SYSTEMTIME systime;
  2053. memset(&systime, 0, sizeof(SYSTEMTIME));
  2054. systime.wSecond = *(int *)((pScriptAction->m_pContent + pScriptAction->m_nBufferLen - sizeof(int)));
  2056. CoreDataChanged(GDCNI_NEWS_MESSAGE, (unsigned int)&News, (unsigned int)&systime);
  2058. }break;
  2060. case NEWSMESSAGE_TIMEEND:
  2061. {
  2062. KNewsMessage News;
  2063. News.nType = pScriptAction->m_bOptionNum;
  2065. char strContent[1024];
  2066. int nTime = 0;
  2067. //主信息为字符串
  2068. if (pScriptAction->m_bParam1 == 0)
  2069. {
  2070. g_StrCpyLen(strContent, pScriptAction->m_pContent,  pScriptAction->m_nBufferLen - sizeof(SYSTEMTIME) + 1);
  2071. }
  2072. else
  2073. {
  2074. g_GetStringRes(*(int *)pScriptAction->m_pContent, strContent ,sizeof(strContent));
  2075. }
  2077. g_StrCpyLen(News.sMsg,  strContent, sizeof(News.sMsg));
  2078. News.nMsgLen = TEncodeText(News.sMsg, strlen(News.sMsg));
  2079. SYSTEMTIME systime;
  2080. systime = *(SYSTEMTIME*)((pScriptAction->m_pContent + pScriptAction->m_nBufferLen - sizeof(SYSTEMTIME)));
  2081. CoreDataChanged(GDCNI_NEWS_MESSAGE, (unsigned int)&News, (unsigned int)&systime);
  2083. }break;
  2085. }
  2087. }break;
  2088. case UI_PLAYMUSIC:
  2089. {
  2090. char szMusicFile[MAX_PATH];
  2091. memcpy(szMusicFile, pScriptAction->m_pContent, pScriptAction->m_nBufferLen);
  2092. szMusicFile[pScriptAction->m_nBufferLen] = 0;
  2093. g_SubWorldSet.m_cMusic.ScriptPlay(szMusicFile);
  2094. }break;
  2096. case UI_OPENTONGUI:
  2097. {
  2098. Player[CLIENT_PLAYER_INDEX].m_cTong.OpenCreateInterface();
  2099. break;
  2100. }
  2101. }
  2102. } break;
  2103. case SCRIPTACTION_EXESCRIPT://要求客户端调用某个脚本
  2104. {
  2105. if (pScriptAction->m_nBufferLen <= 0 ) break;
  2106. char szScriptInfo[1000];
  2107. g_StrCpyLen(szScriptInfo, pScriptAction->m_pContent,pScriptAction->m_nBufferLen + 1);
  2108. char * pDivPos = strstr(szScriptInfo, "/");
  2109. if (pDivPos) *pDivPos++ = 0; 
  2110. if (pDivPos)
  2111. ExecuteScript(szScriptInfo, "OnCall", pDivPos);
  2112. else
  2113. ExecuteScript(szScriptInfo, "OnCall", "");
  2114. }
  2115. break;
  2116. }
  2119. }
  2120. #endif
  2122. #ifdef _SERVER
  2123. int KPlayer::AddTempTaskValue(void* pData)
  2124. {
  2125. memcpy(m_cTask.nClear, pData, sizeof(int) * MAX_TEMP_TASK);
  2126. return 1;
  2127. }
  2129. //客户端请求与某个Npc对话
  2130. //服务器版本
  2131. void KPlayer::DialogNpc(BYTE * pProtocol)
  2132. {
  2133. //if (m_nAvailableAnswerNum > 0) return ;
  2134. PLAYER_DIALOG_NPC_COMMAND * pDialogNpc = (PLAYER_DIALOG_NPC_COMMAND*) pProtocol;
  2135. int nIdx = 0;
  2136. if (pDialogNpc->nNpcId < 0) return;
  2137. nIdx = FindAroundNpc(pDialogNpc->nNpcId);//NpcSet.SearchID(pDialogNpc->nNpcId);
  2138. if (nIdx > 0) 
  2139. {
  2140. int distance = NpcSet.GetDistance(nIdx, m_nIndex);
  2141. // 小于对话半径就开始对话
  2142. if ((Npc[nIdx].m_Kind == kind_dialoger) ||
  2143. (NpcSet.GetRelation(m_nIndex, nIdx) == relation_none))
  2144. {
  2145. if (distance <= Npc[nIdx].m_DialogRadius * 2) // 放大server对话半径
  2146. {
  2147. if (Npc[nIdx].ActionScript[0])
  2148. {
  2149. ExecuteScript(Npc[nIdx].m_ActionScriptID, "main", "");
  2150. }
  2151. }
  2152. }
  2153. }
  2154. }
  2155. #endif
  2157. #ifndef _SERVER
  2158. void KPlayer::s2cTradeChangeState(BYTE* pMsg)
  2159. {
  2160. TRADE_CHANGE_STATE_SYNC *pTrade = (TRADE_CHANGE_STATE_SYNC*)pMsg;
  2163. switch (m_cMenuState.m_nState)
  2164. {
  2165. case PLAYER_MENU_STATE_NORMAL: // 当前客户端 NORMAL
  2166. case PLAYER_MENU_STATE_TRADEOPEN: // 当前客户端 TRADEOPEN
  2167. if (pTrade->m_btState == 0)
  2168. {
  2169. m_cMenuState.SetState(PLAYER_MENU_STATE_NORMAL);
  2170. CoreDataChanged(GDCNI_TRADE_OPER_DATA, 0, 0);
  2171. }
  2172. else if (pTrade->m_btState == 1)
  2173. {
  2174. m_cMenuState.SetState(PLAYER_MENU_STATE_TRADEOPEN);
  2175. CoreDataChanged(GDCNI_TRADE_OPER_DATA, 0, 0);
  2176. }
  2177. else if (pTrade->m_btState == 2)
  2178. {
  2179. m_cMenuState.SetState(PLAYER_MENU_STATE_TRADING);
  2180. m_cTrade.StartTrade(pTrade->m_dwNpcID);
  2181. m_ItemList.StartTrade();
  2183. // 通知界面进入交易界面
  2184. KUiPlayerItem sTradePlayer;
  2185. int nIdx;
  2187. nIdx = NpcSet.SearchID(pTrade->m_dwNpcID);
  2188. if (nIdx > 0)
  2189. strcpy(sTradePlayer.Name, Npc[nIdx].Name);
  2190. else
  2191. sTradePlayer.Name[0] = 0;
  2192. sTradePlayer.nIndex = 0;
  2193. sTradePlayer.uId = 0;
  2194. sTradePlayer.nData = 0;
  2195. CoreDataChanged(GDCNI_TRADE_START, (unsigned int)(&sTradePlayer), 0);
  2197. if (Npc[m_nIndex].m_Doing == do_sit)
  2198. {
  2199. Npc[m_nIndex].SendCommand(do_stand);
  2200. }
  2201. }
  2202. break;
  2203. case PLAYER_MENU_STATE_TEAMOPEN: // 当前客户端 TEAMOPEN
  2204. g_Team[0].SetTeamClose();
  2205. if (pTrade->m_btState == 0)
  2206. {
  2207. m_cMenuState.SetState(PLAYER_MENU_STATE_NORMAL);
  2208. CoreDataChanged(GDCNI_TRADE_OPER_DATA, 0, 0);
  2209. }
  2210. else if (pTrade->m_btState == 1)
  2211. {
  2212. m_cMenuState.SetState(PLAYER_MENU_STATE_TRADEOPEN);
  2213. CoreDataChanged(GDCNI_TRADE_OPER_DATA, 0, 0);
  2214. }
  2215. else if (pTrade->m_btState == 2)
  2216. {
  2217. m_cMenuState.SetState(PLAYER_MENU_STATE_TRADING);
  2218. m_cTrade.StartTrade(pTrade->m_dwNpcID);
  2219. m_ItemList.StartTrade();
  2221. // 通知界面进入交易界面
  2222. KUiPlayerItem sTradePlayer;
  2223. int nIdx;
  2225. nIdx = NpcSet.SearchID(pTrade->m_dwNpcID);
  2226. if (nIdx > 0)
  2227. strcpy(sTradePlayer.Name, Npc[nIdx].Name);
  2228. else
  2229. sTradePlayer.Name[0] = 0;
  2230. sTradePlayer.Name[0] = 0;
  2231. sTradePlayer.nIndex = 0;
  2232. sTradePlayer.uId = 0;
  2233. sTradePlayer.nData = 0;
  2234. CoreDataChanged(GDCNI_TRADE_START, (unsigned int)(&sTradePlayer), 0);
  2236. if (Npc[m_nIndex].m_Doing == do_sit)
  2237. {
  2238. Npc[m_nIndex].SendCommand(do_stand);
  2239. }
  2240. }
  2241. break;
  2242. case PLAYER_MENU_STATE_TRADING: // 当前客户端 TRADING
  2243. // 当客户端处于 TRADING 时，不应该收到此协议
  2244. if (pTrade->m_btState == 0)
  2245. {
  2246. m_cMenuState.SetState(PLAYER_MENU_STATE_NORMAL);
  2247. CoreDataChanged(GDCNI_TRADE_OPER_DATA, 0, 0);
  2248. }
  2249. else if (pTrade->m_btState == 1)
  2250. {
  2251. m_cMenuState.SetState(PLAYER_MENU_STATE_TRADEOPEN);
  2252. CoreDataChanged(GDCNI_TRADE_OPER_DATA, 0, 0);
  2253. }
  2254. else if (pTrade->m_btState == 2) // 客户端此时不应该在这个状态，客户端已出错
  2255. {
  2256. m_cMenuState.m_nState = PLAYER_MENU_STATE_TRADING;
  2257. m_cMenuState.m_nTradeDest = pTrade->m_dwNpcID;
  2258. m_cMenuState.m_nTradeState = 0;
  2259. m_cMenuState.m_nTradeDestState = 0;
  2260. this->m_ItemList.RecoverTrade();
  2261. this->m_ItemList.BackupTrade();
  2262. this->m_ItemList.ClearRoom(room_trade);
  2263. this->m_ItemList.ClearRoom(room_trade1);
  2265. // 通知界面进入交易界面
  2266. KUiPlayerItem sTradePlayer;
  2267. int nIdx;
  2269. nIdx = NpcSet.SearchID(pTrade->m_dwNpcID);
  2270. if (nIdx > 0)
  2271. strcpy(sTradePlayer.Name, Npc[nIdx].Name);
  2272. else
  2273. sTradePlayer.Name[0] = 0;
  2274. sTradePlayer.Name[0] = 0;
  2275. sTradePlayer.nIndex = 0;
  2276. sTradePlayer.uId = 0;
  2277. sTradePlayer.nData = 0;
  2278. CoreDataChanged(GDCNI_TRADE_START, (unsigned int)(&sTradePlayer), 0);
  2280. if (Npc[m_nIndex].m_Doing == do_sit)
  2281. {
  2282. Npc[m_nIndex].SendCommand(do_stand);
  2283. }
  2284. }
  2285. break;
  2286. }
  2287. }
  2288. #endif
  2290. #ifndef _SERVER
  2291. void KPlayer::s2cLevelUp(BYTE* pMsg)
  2292. {
  2293. PLAYER_LEVEL_UP_SYNC *pLevel = (PLAYER_LEVEL_UP_SYNC*)pMsg;
  2295. if ((DWORD)Npc[m_nIndex].m_Level < (DWORD)pLevel->m_btLevel && m_nExp < PlayerSet.m_cLevelAdd.GetLevelExp(Npc[m_nIndex].m_Level))
  2296. {
  2297. KSystemMessage sMsg;
  2298. sprintf(sMsg.szMessage, MSG_GET_EXP, PlayerSet.m_cLevelAdd.GetLevelExp(Npc[m_nIndex].m_Level) - m_nExp);
  2299. sMsg.eType = SMT_NORMAL;
  2300. sMsg.byConfirmType = SMCT_NONE;
  2301. sMsg.byPriority = 0;
  2302. sMsg.byParamSize = 0;
  2303. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  2304. }
  2306. m_nExp = 0;
  2307. Npc[m_nIndex].m_Level = (DWORD)pLevel->m_btLevel;
  2308. m_nNextLevelExp = PlayerSet.m_cLevelAdd.GetLevelExp(Npc[m_nIndex].m_Level);
  2310. // -------------------------- 等级增加时各项属性同步 ----------------------
  2311. // 同步未分配属性点
  2312. if (pLevel->m_nAttributePoint > m_nAttributePoint)
  2313. {
  2314. KSystemMessage Msg;
  2315. sprintf(Msg.szMessage, MSG_GET_ATTRIBUTE_POINT, pLevel->m_nAttributePoint - m_nAttributePoint);
  2316. Msg.eType = SMT_PLAYER;
  2317. Msg.byConfirmType = SMCT_UI_ATTRIBUTE;
  2318. Msg.byPriority = 3;
  2319. Msg.byParamSize = 0;
  2320. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&Msg, NULL);
  2321. }
  2322. m_nAttributePoint = pLevel->m_nAttributePoint;
  2324. // 同步未分配技能点
  2325. if (m_nSkillPoint < pLevel->m_nSkillPoint)
  2326. {
  2327. KSystemMessage Msg;
  2328. sprintf(Msg.szMessage, MSG_GET_SKILL_POINT, pLevel->m_nSkillPoint - m_nSkillPoint);
  2329. Msg.eType = SMT_PLAYER;
  2330. Msg.byConfirmType = SMCT_UI_SKILLS;
  2331. Msg.byPriority = 3;
  2332. Msg.byParamSize = 0;
  2333. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&Msg, NULL);
  2334. }
  2335. m_nSkillPoint = pLevel->m_nSkillPoint;
  2337. // 处理生命、体力、内力值（影响基本生命、体力、内力最大值的因素：等级、属性点，影响当前生命最大值的因素：装备、技能、药物（临时））
  2338. Npc[m_nIndex].m_LifeMax = pLevel->m_nBaseLifeMax;
  2339. Npc[m_nIndex].m_StaminaMax = pLevel->m_nBaseStaminaMax;
  2340. Npc[m_nIndex].m_ManaMax = pLevel->m_nBaseManaMax;
  2341. // Npc[m_nIndex].ResetLifeReplenish();
  2342. Npc[m_nIndex].m_CurrentLifeMax = Npc[m_nIndex].m_LifeMax;
  2343. Npc[m_nIndex].m_CurrentStaminaMax = Npc[m_nIndex].m_StaminaMax;
  2344. Npc[m_nIndex].m_CurrentManaMax = Npc[m_nIndex].m_ManaMax;
  2346. // 处理各种抗性的变化 火、冰、毒、电、物理
  2347. Npc[m_nIndex].m_FireResist = PlayerSet.m_cLevelAdd.GetFireResist(Npc[m_nIndex].m_Series, Npc[m_nIndex].m_Level);
  2348. Npc[m_nIndex].m_CurrentFireResist = Npc[m_nIndex].m_FireResist;
  2349. Npc[m_nIndex].m_ColdResist = PlayerSet.m_cLevelAdd.GetColdResist(Npc[m_nIndex].m_Series, Npc[m_nIndex].m_Level);
  2350. Npc[m_nIndex].m_CurrentColdResist = Npc[m_nIndex].m_ColdResist;
  2351. Npc[m_nIndex].m_PoisonResist = PlayerSet.m_cLevelAdd.GetPoisonResist(Npc[m_nIndex].m_Series, Npc[m_nIndex].m_Level);
  2352. Npc[m_nIndex].m_CurrentPoisonResist = Npc[m_nIndex].m_PoisonResist;
  2353. Npc[m_nIndex].m_LightResist = PlayerSet.m_cLevelAdd.GetLightResist(Npc[m_nIndex].m_Series, Npc[m_nIndex].m_Level);
  2354. Npc[m_nIndex].m_CurrentLightResist = Npc[m_nIndex].m_LightResist;
  2355. Npc[m_nIndex].m_PhysicsResist = PlayerSet.m_cLevelAdd.GetPhysicsResist(Npc[m_nIndex].m_Series, Npc[m_nIndex].m_Level);
  2356. Npc[m_nIndex].m_CurrentPhysicsResist = Npc[m_nIndex].m_PhysicsResist;
  2357. Npc[m_nIndex].m_FireResistMax = BASE_FIRE_RESIST_MAX;
  2358. Npc[m_nIndex].m_ColdResistMax = BASE_COLD_RESIST_MAX;
  2359. Npc[m_nIndex].m_PoisonResistMax = BASE_POISON_RESIST_MAX;
  2360. Npc[m_nIndex].m_LightResistMax = BASE_LIGHT_RESIST_MAX;
  2361. Npc[m_nIndex].m_PhysicsResistMax = BASE_PHYSICS_RESIST_MAX;
  2362. Npc[m_nIndex].m_CurrentFireResistMax = Npc[m_nIndex].m_FireResistMax;
  2363. Npc[m_nIndex].m_CurrentColdResistMax = Npc[m_nIndex].m_ColdResistMax;
  2364. Npc[m_nIndex].m_CurrentPoisonResistMax = Npc[m_nIndex].m_PoisonResistMax;
  2365. Npc[m_nIndex].m_CurrentLightResistMax = Npc[m_nIndex].m_LightResistMax;
  2366. Npc[m_nIndex].m_CurrentPhysicsResistMax = Npc[m_nIndex].m_PhysicsResistMax;
  2368. int nOldCurCamp = Npc[m_nIndex].m_CurrentCamp;
  2369. // 根据装备、技能信息更新当前数据
  2370. this->UpdataCurData();
  2371. SetNpcPhysicsDamage();
  2372. Npc[m_nIndex].m_CurrentCamp = nOldCurCamp;
  2374. // 生命、体力、内力值加满
  2375. Npc[m_nIndex].m_CurrentLife = Npc[m_nIndex].m_CurrentLifeMax;
  2376. Npc[m_nIndex].m_CurrentStamina = Npc[m_nIndex].m_CurrentStaminaMax;
  2377. Npc[m_nIndex].m_CurrentMana = Npc[m_nIndex].m_CurrentManaMax;
  2379. // 客户端队伍中自己的等级加一
  2380. if (this->m_cTeam.m_nFlag)
  2381. {
  2382. if (m_cTeam.m_nFigure == TEAM_CAPTAIN)
  2383. {
  2384. g_Team[0].m_nMemLevel[0] = Npc[m_nIndex].m_Level;
  2385. }
  2386. else
  2387. {
  2388. for (int i = 0; i < MAX_TEAM_MEMBER; i++)
  2389. {
  2390. if ((DWORD)g_Team[0].m_nMember[i] == Npc[m_nIndex].m_dwID)
  2391. {
  2392. g_Team[0].m_nMemLevel[i] = Npc[m_nIndex].m_Level;
  2393. break;
  2394. }
  2395. }
  2396. }
  2397. }
  2399. KSystemMessage Msg;
  2401. Msg.byConfirmType = SMCT_CLICK;
  2402. Msg.byParamSize = 0;
  2403. Msg.byPriority = 1;
  2404. Msg.eType = SMT_PLAYER;
  2405. sprintf(Msg.szMessage, MSG_LEVEL_UP, Npc[m_nIndex].m_Level);
  2406. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&Msg, NULL);
  2408. Npc[this->m_nIndex].SetInstantSpr(enumINSTANT_STATE_LEVELUP);
  2409. }
  2410. #endif
  2412. #ifndef _SERVER
  2413. void KPlayer::s2cGetCurAttribute(BYTE* pMsg)
  2414. {
  2415. PLAYER_ATTRIBUTE_SYNC *pAttribute = (PLAYER_ATTRIBUTE_SYNC*)pMsg;
  2416. m_nAttributePoint = pAttribute->m_nLeavePoint;
  2417. int nData;
  2418. switch (pAttribute->m_btAttribute)
  2419. {
  2420. case ATTRIBUTE_STRENGTH:
  2421. nData = pAttribute->m_nBasePoint - m_nStrength;
  2422. m_nStrength = pAttribute->m_nBasePoint;
  2423. m_nCurStrength = pAttribute->m_nCurPoint;
  2424. UpdataCurData();
  2425. SetNpcPhysicsDamage();
  2426. break;
  2427. case ATTRIBUTE_DEXTERITY:
  2428. nData = pAttribute->m_nBasePoint - m_nDexterity;
  2429. m_nDexterity = pAttribute->m_nBasePoint;
  2430. SetNpcAttackRating();
  2431. SetNpcDefence();
  2432. UpdataCurData();
  2433. SetNpcPhysicsDamage();
  2434. break;
  2435. case ATTRIBUTE_VITALITY:
  2436. nData = pAttribute->m_nBasePoint - m_nVitality;
  2437. m_nVitality = pAttribute->m_nBasePoint;
  2438. Npc[m_nIndex].AddBaseLifeMax(PlayerSet.m_cLevelAdd.GetLifePerVitality(Npc[m_nIndex].m_Series) * nData);
  2439. Npc[m_nIndex].AddBaseStaminaMax(PlayerSet.m_cLevelAdd.GetStaminaPerVitality(Npc[m_nIndex].m_Series) * nData);
  2440. UpdataCurData();
  2441. break;
  2442. case ATTRIBUTE_ENGERGY:
  2443. nData = pAttribute->m_nBasePoint - m_nEngergy;
  2444. m_nEngergy = pAttribute->m_nBasePoint;
  2445. Npc[m_nIndex].AddBaseManaMax(PlayerSet.m_cLevelAdd.GetManaPerEnergy(Npc[m_nIndex].m_Series) * nData);
  2446. UpdataCurData();
  2447. break;
  2448. }
  2449. CoreDataChanged(GDCNI_PLAYER_RT_ATTRIBUTE, 0, 0);
  2450. }
  2451. #endif
  2453. #ifndef _SERVER
  2454. void KPlayer::s2cSetExp(int nExp)
  2455. {
  2456. if (nExp > m_nExp)
  2457. {
  2458. KSystemMessage sMsg;
  2459. sprintf(sMsg.szMessage, MSG_GET_EXP, nExp - m_nExp);
  2460. sMsg.eType = SMT_NORMAL;
  2461. sMsg.byConfirmType = SMCT_NONE;
  2462. sMsg.byPriority = 0;
  2463. sMsg.byParamSize = 0;
  2464. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  2465. }
  2466. else if (nExp < m_nExp)
  2467. {
  2468. KSystemMessage sMsg;
  2469. sprintf(sMsg.szMessage, MSG_DEC_EXP, m_nExp - nExp);
  2470. sMsg.eType = SMT_NORMAL;
  2471. sMsg.byConfirmType = SMCT_NONE;
  2472. sMsg.byPriority = 0;
  2473. sMsg.byParamSize = 0;
  2474. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  2475. }
  2477. this->m_nExp = nExp;
  2478. }
  2479. #endif
  2481. #ifndef _SERVER
  2482. void KPlayer::s2cSyncMoney(BYTE* pMsg)
  2483. {
  2484. PLAYER_MONEY_SYNC *pMoney = (PLAYER_MONEY_SYNC*)pMsg;
  2486. if ( CheckTrading() )
  2487. {
  2488. if (pMoney->m_nMoney1 >= pMoney->m_nMoney3)
  2489. {
  2490. m_ItemList.SetMoney(pMoney->m_nMoney1 - pMoney->m_nMoney3, pMoney->m_nMoney2, pMoney->m_nMoney3);
  2491. }
  2492. else
  2493. {
  2494. m_ItemList.SetMoney(0, pMoney->m_nMoney2 + pMoney->m_nMoney1 - pMoney->m_nMoney3, pMoney->m_nMoney3);
  2495. }
  2496. m_cTrade.m_nTradeState = 0;
  2497. m_cTrade.m_nTradeDestState = 0;
  2498. m_cTrade.m_nBackEquipMoney = pMoney->m_nMoney1;
  2499. m_cTrade.m_nBackRepositoryMoney = pMoney->m_nMoney2;
  2500. }
  2501. else
  2502. {
  2503. // 捡钱一定是到room_equipment
  2504. int nMoney1 = m_ItemList.GetMoney(room_equipment);
  2505. if (pMoney->m_nMoney1 - nMoney1 > 0)
  2506. {
  2507. KSystemMessage sMsg;
  2508. sMsg.eType = SMT_NORMAL;
  2509. sMsg.byConfirmType = SMCT_NONE;
  2510. sMsg.byPriority = 0;
  2511. sMsg.byParamSize = 0;
  2512. sprintf(sMsg.szMessage, MSG_EARN_MONEY, pMoney->m_nMoney1 - nMoney1);
  2513. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  2514. }
  2515. m_ItemList.SetMoney(pMoney->m_nMoney1, pMoney->m_nMoney2, pMoney->m_nMoney3);
  2516. }
  2517. }
  2518. #endif
  2520. #ifndef _SERVER
  2521. //---------------------------------------------------------------------
  2522. // 功能：收到服务器通知有人申请交易
  2523. //---------------------------------------------------------------------
  2524. void KPlayer::s2cTradeApplyStart(BYTE* pMsg)
  2525. {
  2526. if (!pMsg)
  2527. return;
  2528. TRADE_APPLY_START_SYNC *pApply = (TRADE_APPLY_START_SYNC*)pMsg;
  2529. int nNpcIdx;
  2530. nNpcIdx = NpcSet.SearchID(pApply->m_dwNpcId);
  2531. if (nNpcIdx == 0)
  2532. return;
  2534. KSystemMessage sMsg;
  2535. KUiPlayerItem sPlayer;
  2537. strcpy(sPlayer.Name, Npc[nNpcIdx].Name);
  2538. sPlayer.nIndex = pApply->m_nDestIdx;
  2539. sPlayer.uId = pApply->m_dwNpcId;
  2540. sPlayer.nData = 0;
  2542. sprintf(sMsg.szMessage, MSG_TRADE_GET_APPLY, Npc[nNpcIdx].Name);
  2543. sMsg.eType = SMT_SYSTEM;
  2544. sMsg.byConfirmType = SMCT_UI_TRADE;
  2545. sMsg.byPriority = 3;
  2546. sMsg.byParamSize = sizeof(KUiPlayerItem);
  2547. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, (int)&sPlayer);
  2548. }
  2549. #endif
  2551. #ifndef _SERVER
  2552. void KPlayer::s2cTradeMoneySync(BYTE* pMsg)
  2553. {
  2554. TRADE_MONEY_SYNC *pMoney = (TRADE_MONEY_SYNC*)pMsg;
  2556. m_ItemList.SetRoomMoney(room_trade1, pMoney->m_nMoney);
  2558. // 通知界面
  2559. KUiObjAtRegion sMoney;
  2560. sMoney.Obj.uGenre = CGOG_MONEY;
  2561. sMoney.Obj.uId = pMoney->m_nMoney;
  2562. CoreDataChanged(GDCNI_TRADE_DESIRE_ITEM, (unsigned int)&sMoney, 0);
  2563. }
  2564. #endif
  2566. #ifndef _SERVER
  2567. //---------------------------------------------------------------------
  2568. // 功能：收到服务器通知交易完成或取消
  2569. //---------------------------------------------------------------------
  2570. void KPlayer::s2cTradeDecision(BYTE* pMsg)
  2571. {
  2572. TRADE_DECISION_SYNC *pSync = (TRADE_DECISION_SYNC*)pMsg;
  2573. if (pSync->m_btDecision == 1) // 完成交易
  2574. {
  2575. KSystemMessage sMsg;
  2576. sprintf(sMsg.szMessage, MSG_TRADE_SUCCESS, m_cTrade.m_szDestName);
  2577. sMsg.eType = SMT_NORMAL;
  2578. sMsg.byConfirmType = SMCT_NONE;
  2579. sMsg.byPriority = 0;
  2580. sMsg.byParamSize = 0;
  2581. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  2583. // 交给ItemList.Remove来清除 modify by spe 03/06/14
  2584. //m_ItemList.ClearRoom(room_trade);
  2585. m_ItemList.RemoveAllInOneRoom(room_trade1);
  2586. //m_ItemList.ClearRoom(room_trade1);
  2587. m_ItemList.ClearRoom(room_tradeback);
  2588. this->m_cTrade.Release();
  2589. m_cMenuState.SetState(PLAYER_MENU_STATE_NORMAL);
  2591. // 通知界面交易结束
  2592. CoreDataChanged(GDCNI_TRADE_END, 0, 0);
  2594. m_ItemList.MenuSetMouseItem();
  2595. }
  2596. else if (pSync->m_btDecision == 0) // 取消交易
  2597. {
  2598. if ( !CheckTrading() )
  2599. return;
  2601. KSystemMessage sMsg;
  2602. sprintf(sMsg.szMessage, MSG_TRADE_FAIL, m_cTrade.m_szDestName);
  2603. sMsg.eType = SMT_NORMAL;
  2604. sMsg.byConfirmType = SMCT_NONE;
  2605. sMsg.byPriority = 0;
  2606. sMsg.byParamSize = 0;
  2607. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  2609. // 取消交易的数据恢复
  2610. m_ItemList.RecoverTrade();
  2611. m_ItemList.SetMoney(m_cTrade.m_nBackEquipMoney, m_cTrade.m_nBackRepositoryMoney, 0);
  2612. m_ItemList.ClearRoom(room_trade);
  2613. m_ItemList.RemoveAllInOneRoom(room_trade1);
  2614. // m_ItemList.ClearRoom(room_trade1);
  2615. m_ItemList.ClearRoom(room_tradeback);
  2616. m_cTrade.Release();
  2617. m_cMenuState.SetState(PLAYER_MENU_STATE_NORMAL);
  2619. // 通知界面交易结束
  2620. CoreDataChanged(GDCNI_TRADE_END, 0, 0);
  2621. // 更新物品面版
  2622. CoreDataChanged(GDCNI_CONTAINER_OBJECT_CHANGED, UOC_ITEM_TAKE_WITH, 0);
  2624. m_ItemList.MenuSetMouseItem();
  2625. }
  2626. }
  2627. #endif
  2629. #ifndef _SERVER
  2630. void KPlayer::SyncCurPlayer(BYTE* pMsg)
  2631. {
  2632. m_ItemList.RemoveAll();
  2634. CURPLAYER_SYNC* PlaySync = (CURPLAYER_SYNC *)pMsg;
  2635. this->m_nIndex = NpcSet.SearchID(PlaySync->m_dwID);
  2636. this->m_dwID = g_FileName2Id(Npc[m_nIndex].Name); 
  2638. Npc[m_nIndex].m_Kind = kind_player;
  2639. Npc[m_nIndex].m_Level = (DWORD)PlaySync->m_btLevel;
  2640. Npc[m_nIndex].m_nSex = PlaySync->m_btSex;
  2641. Npc[m_nIndex].m_Series  = PlaySync->m_btSeries;
  2642. Npc[m_nIndex].SetPlayerIdx(CLIENT_PLAYER_INDEX);
  2644. m_nAttributePoint = PlaySync->m_wAttributePoint;
  2645. m_nSkillPoint = PlaySync->m_wSkillPoint;
  2646. m_nStrength = PlaySync->m_wStrength;
  2647. m_nDexterity = PlaySync->m_wDexterity;
  2648. m_nVitality = PlaySync->m_wVitality;
  2649. m_nEngergy = PlaySync->m_wEngergy;
  2650. m_nLucky = PlaySync->m_wLucky;
  2652. m_nCurStrength = m_nStrength;
  2653. m_nCurDexterity = m_nDexterity;
  2654. m_nCurVitality = m_nVitality;
  2655. m_nCurEngergy = m_nEngergy;
  2656. m_nCurLucky = m_nLucky;
  2657. SetFirstDamage();
  2658. SetBaseAttackRating();
  2659. SetBaseDefence();
  2660. Npc[m_nIndex].m_ActionScriptID = 0;
  2661. Npc[m_nIndex].m_TrapScriptID = 0;
  2662. m_nExp = PlaySync->m_nExp;
  2663. m_nNextLevelExp = PlayerSet.m_cLevelAdd.GetLevelExp(PlaySync->m_btLevel);
  2664. m_dwLeadExp = PlaySync->m_dwLeadExp;
  2665. m_dwLeadLevel = PlayerSet.m_cLeadExp.GetLevel(m_dwLeadExp);
  2666. m_dwNextLevelLeadExp = PlayerSet.m_cLeadExp.GetLevelExp(m_dwLeadLevel);
  2668. m_cFaction.m_nCurFaction = (char)PlaySync->m_btCurFaction;
  2669. m_cFaction.m_nFirstAddFaction = (char)PlaySync->m_btFirstFaction;
  2670. m_cFaction.m_nAddTimes = PlaySync->m_nFactionAddTimes;
  2672. m_nWorldStat = (int)PlaySync->m_wWorldStat;
  2673. m_nSectStat = (int)PlaySync->m_wSectStat;
  2675. m_ItemList.Init(CLIENT_PLAYER_INDEX);
  2676. m_ItemList.SetMoney(PlaySync->m_nMoney1, PlaySync->m_nMoney2, 0);
  2678. Npc[m_nIndex].m_LifeMax = PlaySync->m_wLifeMax;
  2679. Npc[m_nIndex].m_ManaMax = PlaySync->m_wManaMax;
  2680. Npc[m_nIndex].m_StaminaMax = PlaySync->m_wStaminaMax;
  2681. Npc[m_nIndex].m_LifeReplenish = PLAYER_LIFE_REPLENISH;
  2682. Npc[m_nIndex].m_ManaReplenish = PLAYER_MANA_REPLENISH;
  2683. Npc[m_nIndex].m_StaminaGain = PLAYER_STAMINA_GAIN;
  2684. Npc[m_nIndex].m_StaminaLoss = PLAYER_STAMINA_LOSS;
  2686. SetBaseResistData();
  2687. SetBaseSpeedAndRadius();
  2689. Npc[m_nIndex].RestoreNpcBaseInfo();
  2691. m_BuyInfo.Clear();
  2692. m_cMenuState.Release();
  2693. m_cChat.Release();
  2694. memset(m_szTaskAnswerFun, 0, sizeof(m_szTaskAnswerFun));
  2695. m_nAvailableAnswerNum = 0;
  2697. Npc[m_nIndex].m_Experience = 0;
  2698. memset(Npc[m_nIndex].m_szChatBuffer, 0, sizeof(Npc[m_nIndex].m_szChatBuffer));
  2699. Npc[m_nIndex].m_nCurChatTime = 0;
  2701. m_RunStatus = 1;
  2702. m_nLeftSkillID = 0;
  2703. m_nLeftSkillLevel = 0;
  2704. m_nRightSkillID = 0;
  2705. m_nRightSkillLevel = 0;
  2706. m_nPeapleIdx = 0;
  2707. m_nObjectIdx = 0;
  2708. m_MouseDown[0] = 0;
  2709. m_MouseDown[1] = 0;
  2711. Npc[m_nIndex].m_SyncSignal = 0;
  2712. //Npc[m_nIndex].RestoreLiveData();
  2713. // SubWorld[0].AddPlayer(Npc[m_nIndex].m_RegionIndex, 0);//m_Region[Npc[m_nIndex].m_RegionIndex].AddPlayer(0);// m_WorldMessage.Send(GWM_PLAYER_ADD, Npc[m_nIndex].m_RegionIndex, 0);
  2714. }
  2715. #endif
  2717. BOOL KPlayer::CheckTrading()
  2718. {
  2719. return (m_cMenuState.m_nState == PLAYER_MENU_STATE_TRADING);
  2720. }
  2722. void KPlayer::SetFirstDamage()
  2723. {
  2724. int nDamageBase;
  2727. nDamageBase = m_nCurStrength / STRENGTH_SET_DAMAGE_VALUE + 1;
  2729. Npc[m_nIndex].m_PhysicsDamage.nValue[0] = nDamageBase;
  2730. Npc[m_nIndex].m_PhysicsDamage.nValue[2] = nDamageBase;
  2731. Npc[m_nIndex].m_PhysicsDamage.nValue[1] = 0;
  2733. Npc[m_nIndex].m_CurrentFireDamage.nValue[0] = 0;
  2734. Npc[m_nIndex].m_CurrentFireDamage.nValue[1] = 0;
  2735. Npc[m_nIndex].m_CurrentFireDamage.nValue[2] = 0;
  2737. Npc[m_nIndex].m_CurrentColdDamage.nValue[0] = 0;
  2738. Npc[m_nIndex].m_CurrentColdDamage.nValue[1] = 0;
  2739. Npc[m_nIndex].m_CurrentColdDamage.nValue[2] = 0;
  2741. Npc[m_nIndex].m_CurrentLightDamage.nValue[0] = 0;
  2742. Npc[m_nIndex].m_CurrentLightDamage.nValue[1] = 0;
  2743. Npc[m_nIndex].m_CurrentLightDamage.nValue[2] = 0;
  2745. Npc[m_nIndex].m_CurrentPoisonDamage.nValue[0] = 0;
  2746. Npc[m_nIndex].m_CurrentPoisonDamage.nValue[1] = 0;
  2747. Npc[m_nIndex].m_CurrentPoisonDamage.nValue[2] = 0;
  2749. }
  2751. void KPlayer::SetBaseAttackRating()
  2752. {
  2753. Npc[m_nIndex].m_AttackRating = m_nDexterity * 4 - 28;
  2754. }
  2756. void KPlayer::SetBaseDefence()
  2757. {
  2758. Npc[m_nIndex].m_Defend = m_nDexterity >> 2;
  2759. }
  2761. void KPlayer::SetBaseResistData()
  2762. {
  2763. Npc[m_nIndex].m_FireResist = PlayerSet.m_cLevelAdd.GetFireResist(Npc[m_nIndex].m_Series, Npc[m_nIndex].m_Level);
  2764. Npc[m_nIndex].m_ColdResist = PlayerSet.m_cLevelAdd.GetColdResist(Npc[m_nIndex].m_Series, Npc[m_nIndex].m_Level);
  2765. Npc[m_nIndex].m_PoisonResist = PlayerSet.m_cLevelAdd.GetPoisonResist(Npc[m_nIndex].m_Series, Npc[m_nIndex].m_Level);
  2766. Npc[m_nIndex].m_LightResist = PlayerSet.m_cLevelAdd.GetLightResist(Npc[m_nIndex].m_Series, Npc[m_nIndex].m_Level);
  2767. Npc[m_nIndex].m_PhysicsResist = PlayerSet.m_cLevelAdd.GetPhysicsResist(Npc[m_nIndex].m_Series, Npc[m_nIndex].m_Level);
  2768. Npc[m_nIndex].m_FireResistMax = BASE_FIRE_RESIST_MAX;
  2769. Npc[m_nIndex].m_ColdResistMax = BASE_COLD_RESIST_MAX;
  2770. Npc[m_nIndex].m_PoisonResistMax = BASE_POISON_RESIST_MAX;
  2771. Npc[m_nIndex].m_LightResistMax = BASE_LIGHT_RESIST_MAX;
  2772. Npc[m_nIndex].m_PhysicsResistMax = BASE_PHYSICS_RESIST_MAX;
  2773. }
  2775. void KPlayer::SetBaseSpeedAndRadius()
  2776. {
  2777. Npc[m_nIndex].m_WalkSpeed = BASE_WALK_SPEED;
  2778. Npc[m_nIndex].m_RunSpeed = BASE_RUN_SPEED;
  2779. Npc[m_nIndex].m_AttackSpeed = BASE_ATTACK_SPEED;
  2780. Npc[m_nIndex].m_CastSpeed = BASE_CAST_SPEED;
  2781. Npc[m_nIndex].m_VisionRadius = BASE_VISION_RADIUS;
  2782. Npc[m_nIndex].m_HitRecover = BASE_HIT_RECOVER;
  2783. }
  2785. #ifndef _SERVER
  2786. //客户端版本
  2787. void KPlayer::DialogNpc(int nIndex)
  2788. {
  2789. if (nIndex > 0 && Npc[nIndex].m_Index > 0)
  2790. {
  2791. if (Npc[nIndex].ActionScript[0])
  2792. {
  2793. ExecuteScript(Npc[nIndex].m_ActionScriptID,"main","");
  2794. }
  2795. else
  2796. {
  2797. PLAYER_DIALOG_NPC_COMMAND DialogNpcCmd;
  2798. DialogNpcCmd.nNpcId = Npc[nIndex].m_dwID;
  2799. DialogNpcCmd.ProtocolType = c2s_dialognpc;
  2800. if (g_pClient)
  2801. g_pClient->SendPackToServer(&DialogNpcCmd, sizeof(PLAYER_DIALOG_NPC_COMMAND));
  2803. }
  2804. }
  2805. }
  2806. #endif
  2808. #ifndef _SERVER
  2809. void KPlayer::CheckObject(int nIdx)
  2810. {
  2811. /* enum // 物件类型
  2812. {
  2813. Obj_Kind_MapObj = 0, // 地图物件，主要用于地图动画
  2814. Obj_Kind_Body, // npc 的尸体
  2815. Obj_Kind_Box, // 宝箱
  2816. Obj_Kind_Item, // 掉在地上的装备
  2817. Obj_Kind_Money, // 掉在地上的钱
  2818. Obj_Kind_LoopSound, // 循环音效
  2819. Obj_Kind_RandSound, // 随机音效
  2820. Obj_Kind_Light, // 光源（3D模式中发光的东西）
  2821. Obj_Kind_Door, // 门类
  2822. Obj_Kind_Trap, // 陷阱
  2823. Obj_Kind_Prop, // 小道具，可重生
  2824. Obj_Kind_Num, // 物件的种类数
  2825. };*/
  2827. switch(Object[nIdx].m_nKind)
  2828. {
  2829. case Obj_Kind_Item:
  2830. case Obj_Kind_Money:
  2831. PickUpObj(nIdx);
  2832. Npc[m_nIndex].m_nObjectIdx = 0;
  2833. break;
  2834. case Obj_Kind_Box:
  2835. case Obj_Kind_Door:
  2836. case Obj_Kind_Trap:
  2837. case Obj_Kind_Prop:
  2838. this->ObjMouseClick(nIdx);
  2839. Npc[m_nIndex].m_nObjectIdx = 0;
  2840. break;
  2841. default:
  2842. break;
  2843. }
  2844. m_nObjectIdx = 0;
  2845. m_nPickObjectIdx = 0;
  2846. }
  2847. #endif
  2849. #ifndef _SERVER
  2850. void KPlayer::DrawSelectInfo()
  2851. {
  2852. if (m_nIndex <= 0)
  2853. return;
  2855. if (m_nPeapleIdx)
  2856. {
  2857. // Npc[m_nPeapleIdx].DrawBorder();
  2858. if (Npc[m_nPeapleIdx].m_Kind == kind_player)
  2859. {
  2860. if (!NpcSet.CheckShowName())
  2861. {
  2862. Npc[m_nPeapleIdx].PaintInfo(Npc[m_nPeapleIdx].GetNpcPate(), true);
  2863. }
  2864. }
  2865. else if (Npc[m_nPeapleIdx].m_Kind == kind_dialoger)
  2866. {
  2867. if (!NpcSet.CheckShowName())
  2868. {
  2869. Npc[m_nPeapleIdx].PaintInfo(Npc[m_nPeapleIdx].GetNpcPate(), true);
  2870. }
  2871. }
  2872. else
  2873. {
  2874. Npc[m_nPeapleIdx].DrawBlood();
  2875. }
  2877. return;
  2878. }
  2879. if (m_nObjectIdx)
  2880. {
  2881. if (!ObjSet.CheckShowName())
  2882. Object[m_nObjectIdx].DrawInfo();
  2883. // Object[m_nObjectIdx].DrawBorder();
  2884. return;
  2885. }
  2886. }
  2887. #endif
  2889. #ifndef _SERVER
  2890. void KPlayer::GetEchoDamage(int* nMin, int* nMax, int nType)
  2891. {
  2892. int nSkillId;
  2893. *nMin = 0;
  2894. *nMax = 0;
  2896. if (m_nIndex <= 0 || m_nIndex >= MAX_NPC 
  2897. || nType < 0 || nType > 1 
  2898. || NULL == nMin || NULL == nMax)
  2899. return;
  2901. nSkillId = (0 == nType)?m_nLeftSkillID:m_nRightSkillID;
  2902. int nLevel = Npc[m_nIndex].m_SkillList.GetCurrentLevel(nSkillId);
  2904. if (nSkillId <= 0 ||nLevel <= 0 || nLevel >= MAX_SKILLLEVEL)
  2905. return;
  2907. KMagicAttrib* pMagicData = NULL;
  2909. KSkill * pOrdinSkill = (KSkill *) g_SkillManager.GetSkill(nSkillId, nLevel);
  2910. if (!pOrdinSkill) 
  2911.         return ;
  2913. switch(pOrdinSkill->GetSkillStyle())
  2914. {
  2915. case SKILL_SS_Missles: // 子弹类 本技能用于发送子弹类
  2916. case SKILL_SS_Melee:
  2917. case SKILL_SS_InitiativeNpcState: // 主动类 本技能用于改变当前Npc的主动状态
  2918. case SKILL_SS_PassivityNpcState: // 被动类 本技能用于改变Npc的被动状态
  2919. {
  2920. }
  2921. break;
  2922. default:
  2923. return;
  2924. }
  2926. BOOL bIsPhysical = pOrdinSkill->IsPhysical();
  2929. pMagicData = pOrdinSkill->GetDamageAttribs();
  2931. if (!pMagicData)
  2932. return;
  2936. int nMinNpcDamage = Npc[m_nIndex].m_PhysicsDamage.nValue[0] + Npc[m_nIndex].m_CurrentAddPhysicsDamage;
  2937. int nMaxNpcDamage = Npc[m_nIndex].m_PhysicsDamage.nValue[2] + Npc[m_nIndex].m_CurrentAddPhysicsDamage;
  2938. // Skip attackrating
  2939. pMagicData++;
  2940. // Skip ignoredefense
  2941. pMagicData++;
  2942. // Calc physics damage
  2943. if (magic_physicsenhance_p == pMagicData->nAttribType)
  2944. {
  2945. *nMin += nMinNpcDamage * (100 + pMagicData->nValue[0]) / 100;
  2946. *nMax += nMaxNpcDamage * (100 + pMagicData->nValue[0]) / 100;
  2948. int nEnhance;
  2949. if (equip_meleeweapon == m_ItemList.GetWeaponType())
  2950. {
  2951. nEnhance = Npc[m_nIndex].m_CurrentMeleeEnhance[m_ItemList.GetWeaponParticular()];
  2952. }
  2953. else if (equip_rangeweapon == m_ItemList.GetWeaponType())
  2954. {
  2955. nEnhance = Npc[m_nIndex].m_CurrentRangeEnhance;
  2956. }
  2957. else 
  2958. {
  2959. nEnhance = Npc[m_nIndex].m_CurrentHandEnhance;
  2960. }
  2961. *nMin += nMinNpcDamage * nEnhance / 100;
  2962. *nMax += nMaxNpcDamage * nEnhance / 100;
  2963. }
  2964. else if (magic_physicsdamage_v == pMagicData->nAttribType)
  2965. {
  2966. *nMin += pMagicData->nValue[0];
  2967. *nMax += pMagicData->nValue[2];
  2968. }
  2969. pMagicData++;
  2970. // Calc cold damage
  2971. if (magic_colddamage_v == pMagicData->nAttribType)
  2972. {
  2973. *nMin += pMagicData->nValue[0];
  2974. *nMax += pMagicData->nValue[2];
  2975. }
  2976. if (bIsPhysical)
  2977. {
  2978. *nMin += Npc[m_nIndex].m_CurrentColdDamage.nValue[0];
  2979. *nMax += Npc[m_nIndex].m_CurrentColdDamage.nValue[2];
  2980. }
  2981. pMagicData++;
  2982. // Calc fire damage
  2983. if (magic_firedamage_v == pMagicData->nAttribType)
  2984. {
  2985. *nMin += pMagicData->nValue[0];
  2986. *nMax += pMagicData->nValue[2];
  2987. }
  2988. if (bIsPhysical)
  2989. {
  2990. *nMin += Npc[m_nIndex].m_CurrentFireDamage.nValue[0];
  2991. *nMax += Npc[m_nIndex].m_CurrentFireDamage.nValue[2];
  2992. }
  2993. pMagicData++;
  2994. // Calc lighting damage
  2995. if (magic_lightingdamage_v == pMagicData->nAttribType)
  2996. {
  2997. *nMin += pMagicData->nValue[0];
  2998. *nMax += pMagicData->nValue[2];
  2999. }
  3000. if (bIsPhysical)
  3001. {
  3002. *nMin += Npc[m_nIndex].m_CurrentLightDamage.nValue[0];
  3003. *nMax += Npc[m_nIndex].m_CurrentLightDamage.nValue[2];
  3004. }
  3005. pMagicData++;
  3006. // Calc poison damage
  3007. if (magic_poisondamage_v == pMagicData->nAttribType)
  3008. {
  3009. if (pMagicData->nValue[2] > 0)
  3010. {
  3011. int nPoisonDamage = (pMagicData->nValue[0] * pMagicData->nValue[1] / pMagicData->nValue[2]);
  3012. *nMin += nPoisonDamage;
  3013. *nMax += nPoisonDamage;
  3014. }
  3015. }
  3016. if (bIsPhysical)
  3017. {
  3018. if (Npc[m_nIndex].m_CurrentPoisonDamage.nValue[2] > 0)
  3019. {
  3020. int nPoisonDamage = (Npc[m_nIndex].m_CurrentPoisonDamage.nValue[0]
  3021. * Npc[m_nIndex].m_CurrentPoisonDamage.nValue[1] 
  3022. / Npc[m_nIndex].m_CurrentPoisonDamage.nValue[2]);
  3023. *nMin += nPoisonDamage;
  3024. *nMax += nPoisonDamage;
  3025. }
  3026. }
  3027. pMagicData++;
  3028. // Calc magic damage
  3029. if (magic_magicdamage_v == pMagicData->nAttribType)
  3030. {
  3031. *nMin += pMagicData->nValue[0];
  3032. *nMax += pMagicData->nValue[2];
  3033. }
  3034. }
  3035. #endif
  3036. void KPlayer::SetNpcDamageAttrib()
  3037. {
  3038. SetNpcPhysicsDamage();
  3039. }
  3041. #ifdef _SERVER
  3042. void KPlayer::TobeExchangeServer(DWORD dwMapID, int nX, int nY)
  3043. {
  3044. if (!m_dwID || m_nNetConnectIdx == -1)
  3045. return;
  3047. m_sExchangePos.m_dwMapID = dwMapID;
  3048. m_sExchangePos.m_nX = nX;
  3049. m_sExchangePos.m_nY = nY;
  3050. m_bExchangeServer = TRUE;
  3051. }
  3052. #endif
  3054. /*
  3055. #ifdef _SERVER
  3056. void KPlayer::UpdateEnterGamePos(DWORD dwSubWorldID, int nX, int nY, int nFightMode)
  3057. {
  3058. TRoleData* pData = (TRoleData *)&m_SaveBuffer;
  3059. pData->BaseInfo.cFightMode = nFightMode;
  3060. pData->BaseInfo.cUseRevive = 0;
  3061. pData->BaseInfo.ientergameid = dwSubWorldID;
  3062. pData->BaseInfo.ientergamex = nX;
  3063. pData->BaseInfo.ientergamey = nY;
  3064. }
  3065. #endif
  3066. */
  3068. #ifdef _SERVER
  3069. BOOL KPlayer::IsExchangingServer()
  3070. {
  3071. return m_bExchangeServer;
  3072. }
  3073. #endif
  3075. #ifdef _SERVER
  3076. void KPlayer::SetLastNetOperationTime(int nTime)
  3077. {
  3078. if (m_nNetConnectIdx == -1 || m_dwID == 0 || m_nIndex <= 0)
  3079. return;
  3081. m_nLastNetOperationTime = nTime;
  3082. if (m_bSleepMode)
  3083. {
  3084. m_bSleepMode = FALSE;
  3085. NPC_SLEEP_SYNC SleepSync;
  3086. SleepSync.ProtocolType = s2c_npcsleepmode;
  3087. SleepSync.bSleep = m_bSleepMode;
  3088. SleepSync.NpcID = Npc[m_nIndex].m_dwID;
  3089. Npc[m_nIndex].SendDataToNearRegion(&SleepSync, sizeof(NPC_SLEEP_SYNC));
  3090. }
  3091. }
  3092. #endif
  3094. #ifdef _SERVER
  3095. BOOL KPlayer::CreateTong(int nCamp, char *lpszTongName)
  3096. {
  3097. return this->m_cTong.Create(nCamp, lpszTongName);
  3098. }
  3099. #endif
  3101. #ifdef _SERVER
  3102. void KPlayer::RepairItem(DWORD dwItemID)
  3103. {
  3104. int nIdx = m_ItemList.SearchID(dwItemID);
  3105. int nCost = Item[nIdx].GetRepairPrice();
  3106. if (!nCost)
  3107. return;
  3108. int nMaxDur = Item[nIdx].GetMaxDurability();
  3109. int nDur = Item[nIdx].GetDurability();
  3110. if (Pay(nCost) && m_nNetConnectIdx >= 0)
  3111. {
  3112. Item[nIdx].SetDurability(nMaxDur);
  3113. ITEM_DURABILITY_CHANGE IDC;
  3114. IDC.ProtocolType = s2c_itemdurabilitychange;
  3115. IDC.dwItemID = dwItemID;
  3116. IDC.nChange = nMaxDur - nDur;
  3117. if (g_pServer)
  3118. g_pServer->PackDataToClient(m_nNetConnectIdx, &IDC, sizeof(ITEM_DURABILITY_CHANGE));
  3119. }
  3120. }
  3121. #endif
  3123. #ifdef _SERVER
  3124. void KPlayer::SetExtPoint(int nPoint, int nChangePoint)
  3125. {
  3126. m_nExtPoint = nPoint;
  3127. m_nChangeExtPoint = nChangePoint;
  3128. }
  3130. int KPlayer::GetExtPoint()
  3131. {
  3132. return m_nExtPoint;
  3133. }
  3135. BOOL KPlayer::PayExtPoint(int nPoint)
  3136. {
  3137. if (m_nExtPoint < nPoint)
  3138. return FALSE;
  3140. m_nExtPoint -= nPoint;
  3141. m_nChangeExtPoint += nPoint;
  3142. return TRUE;
  3143. }
  3145. int KPlayer::GetExtPointChanged()
  3146. {
  3147. return m_nChangeExtPoint;
  3148. }
  3149. #endif
  3150. // 物品相应的操作：
  3151. //     获得物品：1、从地上拣物品 2、脚本控制直接给 3、交易 4、player 之间赠
  3152. //               送(通过交易实现)
  3153. //         客户端鼠标点在物件上，然后客户端通过物件得出物品id、应该出现在装备栏或者
  3154. //         物品栏的位置或者跟随鼠标的计算，把计算结果发给服务器；服务器收到后首先判
  3155. //         断玩家与物品的位置关系，然后检查客户端的计算结果是否正确，然后进行相应的
  3156. //         处理，把处理结果发给客户端
  3157. //     物品的位置调整：客户端处理好物品来源位置、鼠标上物品目的位置，然后发给服务器，
  3158. //     服务器确认后通知客户端最终确定的操作（如果成功，把协议原样发回去）；如果有数
  3159. //     值等其他变化，另外通知客户端；
  3160. //     使用物品：1、吃药 2、装备（鼠标右键点击）
  3161. //         客户端向服务器端申请吃什么位置的药，同时客户端的相应数值先作相应变化，服
  3162. //         务器收到客户端申请后，处理完相应数据，通过player同步的方式通知客户端数据
  3163. //         的变化；
  3164. //         装备：鼠标右键点在一个装备上，自动处理装备上、卸下的位置信息，发给服务器，
  3165. //         服务器处理完后原样发回来；
  3167. // 交易的处理还没有