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

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

模拟服务器

开发平台：

C/C++

KPlayerChat.cpp：源码内容
  1. //---------------------------------------------------------------------------
  2. // Sword3 Engine (c) 2002 by Kingsoft
  3. //
  4. // File: KPlayerChat.cpp
  5. // Date: 2002.10.05
  6. // Code: 边城浪子
  7. // Desc: PlayerChat Class
  8. //---------------------------------------------------------------------------
  10. #ifdef _STANDALONE
  11. #include <string>
  12. #endif
  14. #include "KCore.h"
  15. #ifdef _SERVER
  16. //#include "KNetServer.h"
  17. //#include "../MultiServer/Heaven/Interface/iServer.h"
  18. #include "KGMCommand.h"
  19. #else
  20. //#include "KNetClient.h"
  21. #include "../../Headers/IClient.h"
  22. #include "CoreShell.h"
  23. #endif
  24. #include "KNpc.h"
  25. #include "KNpcSet.h"
  26. #include "KSubWorld.h"
  27. #include "KPlayer.h"
  28. #include "KPlayerSet.h"
  29. #include "KPlayerTeam.h"
  30. #include "KPlayerChat.h"
  31. #include "MsgGenreDef.h"
  32. #include "CoreUseNameDef.h"
  34. #include "malloc.h"
  35. #ifdef _SERVER
  36. #include "KNewProtocolProcess.h"
  37. #endif
  38. #include "KTongProtocol.h"
  41. #define CHAT_TEAM_DEFAULT_NAME "我的好友"
  43. DWORD g_dwChannelOr[CHAT_CUR_CHANNEL_NUM] =
  44. {
  45. 0x00000000, // CHAT_CUR_CHANNEL_NONE
  46. 0x00000001, // CHAT_CUR_CHANNEL_ALL
  47. 0x00000002, // CHAT_CUR_CHANNEL_SCREEN
  48. 0x00000004, // CHAT_CUR_CHANNEL_SINGLE
  49. 0x00000008, // CHAT_CUR_CHANNEL_TEAM
  50. 0x00000010, // CHAT_CUR_CHANNEL_FACTION
  51. 0x00000020, // CHAT_CUR_CHANNEL_TONG
  52. 0x00000040, // CHAT_CUR_CHANNEL_SCREENSINGLE
  53. 0x00000080, // CHAT_CUR_CHANNEL_SYSTEM
  54. };
  56. DWORD g_dwChannelAnd[CHAT_CUR_CHANNEL_NUM] =
  57. {
  58. 0xffffffff, // CHAT_CUR_CHANNEL_NONE
  59. 0xfffffffe, // CHAT_CUR_CHANNEL_ALL
  60. 0xfffffffd, // CHAT_CUR_CHANNEL_SCREEN
  61. 0xfffffffb, // CHAT_CUR_CHANNEL_SINGLE
  62. 0xfffffff7, // CHAT_CUR_CHANNEL_TEAM
  63. 0xffffffef, // CHAT_CUR_CHANNEL_FACTION
  64. 0xffffffdf, // CHAT_CUR_CHANNEL_TONG
  65. 0xffffffbf, // CHAT_CUR_CHANNEL_SCREENSINGLE
  66. 0xffffff7f, // CHAT_CUR_CHANNEL_SYSTEM
  67. };
  69. //---------------------------------------------------------------------------
  70. // 功能：清空
  71. //---------------------------------------------------------------------------
  72. void KPlayerChat::Release()
  73. {
  74. #ifndef _SERVER
  75. m_btIniLoadFlag = FALSE;
  76. m_nCurChannel = CHAT_CUR_CHANNEL_SCREEN;
  77. CChatApplyListNode *pNode;
  78. pNode = (CChatApplyListNode*)m_cApplyAddList.GetHead();
  79. while (pNode)
  80. {
  81. m_cApplyAddList.RemoveHead();
  82. delete pNode;
  83. pNode = (CChatApplyListNode*)m_cApplyAddList.GetHead();
  84. }
  85. m_nLoginGetFirstOneFriendFlag = 0;
  86. #else
  87. memset(m_nAddFriendList, 0, sizeof(this->m_nAddFriendList));
  88. m_nListPos = 0;
  89. m_nSyncState = 0;
  90. m_pStateSendPos = NULL;
  91. m_nTimer = CHAT_SPEED;
  92. #endif
  93. m_dwTakeChannel = 0;
  94. this->SetTakeChannel(g_dwChannelOr[CHAT_CUR_CHANNEL_SCREEN]);
  95. m_dwTargetID = 0;
  96. m_nTargetIdx = 0;
  97. for (int i = 0; i < MAX_FRIEND_TEAM; i++)
  98. {
  99. m_cFriendTeam[i].Release();
  100. }
  101. strcpy(m_cFriendTeam[0].m_szTeamName, CHAT_TEAM_DEFAULT_NAME);
  102. }
  104. BOOL KPlayerChat::CheckExist(DWORD dwID)
  105. {
  106. CChatFriend *pNode;
  107. for (int i = 0; i < MAX_FRIEND_TEAM; i++)
  108. {
  109. if (m_cFriendTeam[i].m_nFriendNo <= 0)
  110. continue;
  111. pNode = (CChatFriend*)m_cFriendTeam[i].m_cEveryOne.GetHead();
  112. while (pNode)
  113. {
  114. if (pNode->m_dwID == dwID)
  115. return TRUE;
  116. pNode = (CChatFriend*)pNode->GetNext();
  117. }
  118. }
  119. return FALSE;
  120. }
  122. BOOL KPlayerChat::CheckExist(char *lpszName)
  123. {
  124. if (!lpszName || !lpszName[0])
  125. return FALSE;
  126. CChatFriend *pNode;
  127. for (int i = 0; i < MAX_FRIEND_TEAM; i++)
  128. {
  129. if (m_cFriendTeam[i].m_nFriendNo <= 0)
  130. continue;
  131. pNode = (CChatFriend*)m_cFriendTeam[i].m_cEveryOne.GetHead();
  132. while (pNode)
  133. {
  134. if (strcmp(lpszName, pNode->m_szName) == 0)
  135. return TRUE;
  136. pNode = (CChatFriend*)pNode->GetNext();
  137. }
  138. }
  139. return FALSE;
  140. }
  142. CChatFriend* KPlayerChat::GetFriendNode(DWORD dwID)
  143. {
  144. CChatFriend *pNode;
  145. for (int i = 0; i < MAX_FRIEND_TEAM; i++)
  146. {
  147. if (m_cFriendTeam[i].m_nFriendNo <= 0)
  148. continue;
  149. pNode = (CChatFriend*)m_cFriendTeam[i].m_cEveryOne.GetHead();
  150. while (pNode)
  151. {
  152. if (pNode->m_dwID == dwID)
  153. {
  154. return pNode;
  155. }
  156. pNode = (CChatFriend*)pNode->GetNext();
  157. }
  158. }
  159. return NULL;
  160. }
  162. int KPlayerChat::GetTeamNo(DWORD dwID)
  163. {
  164. CChatFriend *pNode;
  165. for (int i = 0; i < MAX_FRIEND_TEAM; i++)
  166. {
  167. if (i != 0 && !m_cFriendTeam[i].m_szTeamName[0])
  168. continue;
  169. if (m_cFriendTeam[i].m_nFriendNo <= 0)
  170. continue;
  171. pNode = (CChatFriend*)m_cFriendTeam[i].m_cEveryOne.GetHead();
  172. while (pNode)
  173. {
  174. if (pNode->m_dwID == dwID)
  175. {
  176. return i;
  177. }
  178. pNode = (CChatFriend*)pNode->GetNext();
  179. }
  180. }
  181. return -1;
  182. }
  184. BOOL KPlayerChat::GetName(DWORD dwID, char *lpszName)
  185. {
  186. if ( !lpszName )
  187. return FALSE;
  188. CChatFriend *pNode;
  189. for (int i = 0; i < MAX_FRIEND_TEAM; i++)
  190. {
  191. if (m_cFriendTeam[i].m_nFriendNo <= 0)
  192. continue;
  193. pNode = (CChatFriend*)m_cFriendTeam[i].m_cEveryOne.GetHead();
  194. while (pNode)
  195. {
  196. if (pNode->m_dwID == dwID)
  197. {
  198. g_StrCpy(lpszName, pNode->m_szName);
  199. return TRUE;
  200. }
  201. pNode = (CChatFriend*)pNode->GetNext();
  202. }
  203. }
  204. return FALSE;
  205. }
  207. #ifndef _SERVER
  208. //---------------------------------------------------------------------------
  209. // 功能：设定当前发送频道
  210. //---------------------------------------------------------------------------
  211. void KPlayerChat::SetCurChannel(int nChannelNo, DWORD dwID, int nIdx)
  212. {
  213. if (nChannelNo <= CHAT_CUR_CHANNEL_NONE || nChannelNo >= CHAT_CUR_CHANNEL_NUM)
  214. return;
  215. switch (nChannelNo)
  216. {
  217. case CHAT_CUR_CHANNEL_SINGLE:
  218. m_nCurChannel = nChannelNo;
  219. this->m_dwTargetID = dwID;
  220. this->m_nTargetIdx = nIdx;
  221. break;
  222. case CHAT_CUR_CHANNEL_SCREENSINGLE:
  223. m_nCurChannel = nChannelNo;
  224. this->m_dwTargetID = dwID;
  225. this->m_nTargetIdx = nIdx;
  226. break;
  227. case CHAT_CUR_CHANNEL_SYSTEM:
  228. // 检测玩家身份，确定是否可以设定为此频道 not end
  229. m_nCurChannel = nChannelNo;
  230. break;
  231. default:
  232. m_nCurChannel = nChannelNo;
  233. break;
  234. }
  235. CoreDataChanged(GDCNI_SEND_CHAT_CHANNEL, 0, 0);
  236. }
  237. #endif
  239. #ifndef _SERVER
  240. //---------------------------------------------------------------------------
  241. // 功能：增加订阅频道
  242. //---------------------------------------------------------------------------
  243. void KPlayerChat::AddChannel(int nChannelNo)
  244. {
  245. if (CHAT_CUR_CHANNEL_NONE >= nChannelNo || nChannelNo >= CHAT_CUR_CHANNEL_NUM)
  246. return;
  247. switch (nChannelNo)
  248. {
  249. case CHAT_CUR_CHANNEL_ALL:
  250. // 玩家身份判断，普通玩家默认订阅此频道，不能取消 not end
  251. m_dwTakeChannel |= g_dwChannelOr[nChannelNo];
  252. break;
  253. default:
  254. m_dwTakeChannel |= g_dwChannelOr[nChannelNo];
  255. break;
  256. }
  258. this->SaveTakeChannelInfo(Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].Name);
  259. SendTakeChannel();
  260. }
  261. #endif
  263. #ifndef _SERVER
  264. //---------------------------------------------------------------------------
  265. // 功能：取消订阅频道
  266. //---------------------------------------------------------------------------
  267. void KPlayerChat::SubChannel(int nChannelNo)
  268. {
  269. if (CHAT_CUR_CHANNEL_NONE >= nChannelNo || nChannelNo >= CHAT_CUR_CHANNEL_NUM)
  270. return;
  272. switch (nChannelNo)
  273. {
  274. case CHAT_CUR_CHANNEL_ALL:
  275. case CHAT_CUR_CHANNEL_SYSTEM:
  276. case CHAT_CUR_CHANNEL_SCREEN:
  277. // 玩家身份判断，普通玩家默认订阅此频道，不能取消 not end
  278. break;
  279. default:
  280. m_dwTakeChannel &= g_dwChannelAnd[nChannelNo];
  281. break;
  282. }
  284. this->SaveTakeChannelInfo(Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].Name);
  285. SendTakeChannel();
  286. }
  287. #endif
  289. #ifndef _SERVER
  290. //---------------------------------------------------------------------------
  291. // 功能：客户端发送订阅频道给服务器
  292. //---------------------------------------------------------------------------
  293. void KPlayerChat::SendTakeChannel()
  294. {
  295. CHAT_SET_CHANNEL_COMMAND sChannel;
  297. sChannel.ProtocolType = c2s_chatsetchannel;
  298. sChannel.m_dwTakeChannel = this->m_dwTakeChannel;
  300. if (g_pClient)
  301. g_pClient->SendPackToServer(&sChannel, sizeof(CHAT_SET_CHANNEL_COMMAND));
  302. }
  303. #endif
  305. #ifndef _SERVER
  306. //---------------------------------------------------------------------------
  307. // 功能：客户端发送聊天语句给服务器
  308. //---------------------------------------------------------------------------
  309. void KPlayerChat::SendSentence(KUiMsgParam *pMsg, char *lpszSentence)
  310. {
  311. if (!lpszSentence || !pMsg || pMsg->nMsgLength <= 0)
  312. return;
  313. int nLength = pMsg->nMsgLength;
  314. if (nLength >= MAX_SENTENCE_LENGTH)
  315. nLength = MAX_SENTENCE_LENGTH - 1;
  317. if (pMsg->eGenre == MSG_G_CHAT)
  318. {
  319. PLAYER_SEND_CHAT_COMMAND sChat;
  320. sChat.ProtocolType = c2s_playersendchat;
  321. sChat.m_wLength = sizeof(PLAYER_SEND_CHAT_COMMAND) - 1 - sizeof(sChat.m_szSentence) + nLength + pMsg->cChatPrefixLen;
  322. sChat.m_btCurChannel = this->m_nCurChannel;
  323. sChat.m_btType = pMsg->eGenre;
  324. sChat.m_btChatPrefixLen = pMsg->cChatPrefixLen;
  325. sChat.m_wSentenceLen = nLength;
  326. sChat.m_dwTargetID = m_dwTargetID;
  327. sChat.m_nTargetIdx = m_nTargetIdx;
  328. memcpy(&sChat.m_szSentence[0], (char*)pMsg->cChatPrefix, pMsg->cChatPrefixLen);
  329. memcpy(&sChat.m_szSentence[pMsg->cChatPrefixLen], lpszSentence, nLength);
  331. if (g_pClient)
  332. g_pClient->SendPackToServer(&sChat, sChat.m_wLength + 1);
  334. if (m_nCurChannel == CHAT_CUR_CHANNEL_SINGLE)
  335. {
  336. char szName[32];
  337. szName[0] = 0;
  338. if (GetName(m_dwTargetID, szName))
  339. {
  340. if (szName[0])
  341. m_cRecorder.SaveSentenceSingle(Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].Name, szName, Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].Name, lpszSentence);
  342. }
  343. }
  344. else
  345. {
  346. this->m_cRecorder.SaveSentenceChannel(Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].Name, Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].Name, lpszSentence);
  347. }
  348. }
  349. else if (pMsg->eGenre == MSG_G_CMD) // not end
  350. {
  351. }
  352. }
  353. #endif
  355. #ifndef _SERVER
  356. //---------------------------------------------------------------------------
  357. // 功能：客户端发送聊天语句给服务器(QQ专用)
  358. //---------------------------------------------------------------------------
  359. void KPlayerChat::QQSendSentence(DWORD dwID, int nIdx, KUiMsgParam *pMsg, char *lpszSentence)
  360. {
  361. if (!lpszSentence || !pMsg || pMsg->nMsgLength <= 0)
  362. return;
  363. int nLength = pMsg->nMsgLength;
  364. if (nLength >= MAX_SENTENCE_LENGTH)
  365. nLength = MAX_SENTENCE_LENGTH - 1;
  367. PLAYER_SEND_CHAT_COMMAND sChat;
  368. sChat.ProtocolType = c2s_playersendchat;
  369. sChat.m_wLength = sizeof(PLAYER_SEND_CHAT_COMMAND) - 1 - sizeof(sChat.m_szSentence) + nLength + pMsg->cChatPrefixLen;
  370. sChat.m_btCurChannel = CHAT_CUR_CHANNEL_SINGLE;
  371. sChat.m_btType = pMsg->eGenre;
  372. sChat.m_btChatPrefixLen = pMsg->cChatPrefixLen;
  373. sChat.m_wSentenceLen = nLength;
  374. sChat.m_dwTargetID = dwID;
  375. sChat.m_nTargetIdx = nIdx;
  376. memcpy(&sChat.m_szSentence[0], (char*)pMsg->cChatPrefix, pMsg->cChatPrefixLen);
  377. memcpy(&sChat.m_szSentence[pMsg->cChatPrefixLen], lpszSentence, nLength);
  379. if (g_pClient)
  380. g_pClient->SendPackToServer(&sChat, sChat.m_wLength + 1);
  382. char szName[32];
  383. szName[0] = 0;
  384. if (GetName(dwID, szName))
  385. {
  386. if (szName[0])
  387. m_cRecorder.SaveSentenceSingle(Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].Name, szName, Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].Name, lpszSentence);
  388. }
  389. }
  390. #endif
  392. //---------------------------------------------------------------------------
  393. // 功能：服务器收到客户端发来的订阅聊天频道信息
  394. //---------------------------------------------------------------------------
  395. void KPlayerChat::SetTakeChannel(DWORD dwChannel)
  396. {
  397. // 玩家身份判断，不同玩家系统赋予的权限不同 not end
  398. m_dwTakeChannel = dwChannel | g_dwChannelOr[CHAT_CUR_CHANNEL_ALL] | g_dwChannelOr[CHAT_CUR_CHANNEL_SCREEN] | g_dwChannelOr[CHAT_CUR_CHANNEL_SYSTEM];
  399. }
  401. #ifdef _SERVER
  402. //---------------------------------------------------------------------------
  403. // 功能：服务器收到客户端发来的聊天信息
  404. //---------------------------------------------------------------------------
  405. void KPlayerChat::ServerSendChat(int nPlayerIdx, BYTE* pProtocol)
  406. {
  407. if (!pProtocol)
  408. return;
  410. PLAYER_SEND_CHAT_COMMAND *pChat = (PLAYER_SEND_CHAT_COMMAND*)pProtocol;
  411. int nLen = pChat->m_wSentenceLen;
  412. if (pChat->m_btCurChannel <= CHAT_CUR_CHANNEL_NONE || pChat->m_btCurChannel >= CHAT_CUR_CHANNEL_NUM)
  413. return;
  414. if (pChat->m_btChatPrefixLen > CHAT_MSG_PREFIX_MAX_LEN || pChat->m_wSentenceLen >= MAX_SENTENCE_LENGTH)
  415. return;
  416. if (pChat->m_wLength != sizeof(PLAYER_SEND_CHAT_COMMAND) - 1 - sizeof(pChat->m_szSentence) + pChat->m_btChatPrefixLen + pChat->m_wSentenceLen)
  417. {
  418. g_DebugLog("[chat]聊天数据包错误！");
  419. return;
  420. }
  422. if (pChat->m_btType == MSG_G_CHAT)
  423. {
  424. switch (pChat->m_btCurChannel)
  425. {
  426. case CHAT_CUR_CHANNEL_ALL:
  427. {
  428. // 检查玩家权限，普通玩家没有这个权限 not end
  429. break;
  431. if (m_nTimer < CHAT_SPEED)
  432. break;
  433. m_nTimer = 0;
  435. PLAYER_SEND_CHAT_SYNC sChat;
  436. sChat.ProtocolType = s2c_playersendchat;
  437. sChat.m_btCurChannel = pChat->m_btCurChannel;
  438. sChat.m_btNameLen = strlen(Npc[Player[nPlayerIdx].m_nIndex].Name);
  439. sChat.m_btChatPrefixLen = pChat->m_btChatPrefixLen;
  440. sChat.m_wSentenceLen = pChat->m_wSentenceLen;
  441. sChat.m_dwSourceID = Player[nPlayerIdx].m_dwID; // 发送者的player id 可能需要根据玩家身份改动
  442. sChat.m_wLength = sizeof(PLAYER_SEND_CHAT_SYNC) - 1 - sizeof(sChat.m_szSentence) + sChat.m_btNameLen + sChat.m_btChatPrefixLen + sChat.m_wSentenceLen;
  443. memcpy(&sChat.m_szSentence[0], Npc[Player[nPlayerIdx].m_nIndex].Name, sChat.m_btNameLen); // 可能需要根据玩家身份改动
  444. memcpy(&sChat.m_szSentence[sChat.m_btNameLen], &pChat->m_szSentence[0], sChat.m_btChatPrefixLen);
  445. memcpy(&sChat.m_szSentence[sChat.m_btNameLen + sChat.m_btChatPrefixLen], &pChat->m_szSentence[pChat->m_btChatPrefixLen], sChat.m_wSentenceLen); // 可能需要根据玩家身份改动
  446. int nTargetIdx;
  447. nTargetIdx = PlayerSet.GetFirstPlayer();
  448. while (nTargetIdx)
  449. {
  450. g_pServer->PackDataToClient(Player[nTargetIdx].m_nNetConnectIdx, (BYTE*)&sChat, sChat.m_wLength + 1);
  451. nTargetIdx = PlayerSet.GetNextPlayer();
  452. }
  453. }
  454. break;
  455. case CHAT_CUR_CHANNEL_SCREEN:
  456. {
  457. if (m_nTimer < CHAT_SPEED)
  458. break;
  459. m_nTimer = 0;
  461. PLAYER_SEND_CHAT_SYNC sChat;
  462. sChat.ProtocolType = s2c_playersendchat;
  463. sChat.m_btCurChannel = pChat->m_btCurChannel;
  464. sChat.m_btNameLen = strlen(Npc[Player[nPlayerIdx].m_nIndex].Name);
  465. sChat.m_btChatPrefixLen = pChat->m_btChatPrefixLen;
  466. sChat.m_wSentenceLen = pChat->m_wSentenceLen;
  467. sChat.m_dwSourceID = Npc[Player[nPlayerIdx].m_nIndex].m_dwID; // 此处传的是发送者的 npc id
  468. sChat.m_wLength = sizeof(PLAYER_SEND_CHAT_SYNC) - 1 - sizeof(sChat.m_szSentence) + sChat.m_btNameLen + sChat.m_btChatPrefixLen + sChat.m_wSentenceLen;
  469. memcpy(&sChat.m_szSentence[0], Npc[Player[nPlayerIdx].m_nIndex].Name, sChat.m_btNameLen); // 可能需要根据玩家身份改动
  470. memcpy(&sChat.m_szSentence[sChat.m_btNameLen], &pChat->m_szSentence[0], sChat.m_btChatPrefixLen);
  471. memcpy(&sChat.m_szSentence[sChat.m_btNameLen + sChat.m_btChatPrefixLen], &pChat->m_szSentence[pChat->m_btChatPrefixLen], sChat.m_wSentenceLen); // 可能需要根据玩家身份改动
  472. #ifdef _CHAT_SCRIPT_OPEN
  473. if (TextGMFilter(nPlayerIdx,(const char *) (pChat->m_szSentence + pChat->m_btChatPrefixLen), sChat.m_wSentenceLen))
  474. return;
  475. #endif
  476. Npc[Player[nPlayerIdx].m_nIndex].SendDataToNearRegion((BYTE*)&sChat, sChat.m_wLength + 1);
  477. }
  478. break;
  479. case CHAT_CUR_CHANNEL_SINGLE:
  480. {
  481. DWORD dwCheckID = 0;
  482. int nIndex = 0;
  483. if (pChat->m_nTargetIdx <= 0 || pChat->m_nTargetIdx >= MAX_PLAYER)
  484. {
  485. int nSubWorld = Npc[Player[nPlayerIdx].m_nIndex].m_SubWorldIndex;
  486. int nRegion = Npc[Player[nPlayerIdx].m_nIndex].m_RegionIndex;
  487. nIndex = SubWorld[nSubWorld].m_Region[nRegion].FindPlayer(pChat->m_dwTargetID);
  488. if (nIndex <= 0)
  489. {
  490. for (int i = 0; i < 8; i++)
  491. {
  492. int nConRegion = SubWorld[nSubWorld].m_Region[nRegion].m_nConnectRegion[i];
  493. if (nConRegion == -1)
  494. continue;
  495. nIndex = SubWorld[nSubWorld].m_Region[nConRegion].FindPlayer(pChat->m_dwTargetID);
  496. if (nIndex > 0)
  497. break;
  498. }
  499. if (nIndex <= 0)
  500. return;
  501. }
  502. dwCheckID = Player[nIndex].m_dwID;
  503. // return;
  504. }
  505. else
  506. {
  507. dwCheckID = pChat->m_dwTargetID;
  508. nIndex = pChat->m_nTargetIdx;
  509. }
  510. if (Player[nIndex].m_nIndex == 0 || 
  511. Player[nIndex].m_dwID != dwCheckID)
  512. return;
  513. PLAYER_SEND_CHAT_SYNC sChat;
  514. sChat.ProtocolType = s2c_playersendchat;
  515. sChat.m_btCurChannel = pChat->m_btCurChannel;
  516. sChat.m_btNameLen = 0;
  517. sChat.m_btChatPrefixLen = pChat->m_btChatPrefixLen;
  518. sChat.m_wSentenceLen = pChat->m_wSentenceLen;
  519. sChat.m_dwSourceID = Player[nPlayerIdx].m_dwID;
  520. sChat.m_wLength = sizeof(PLAYER_SEND_CHAT_SYNC) - 1 - sizeof(sChat.m_szSentence) + sChat.m_btNameLen + sChat.m_btChatPrefixLen + sChat.m_wSentenceLen;
  521. // QQ聊天不传名字
  522. // memcpy(&sChat.m_szSentence[0], Npc[Player[nPlayerIdx].m_nIndex].Name, sChat.m_btNameLen);
  523. memcpy(&sChat.m_szSentence[sChat.m_btNameLen], &pChat->m_szSentence[0], sChat.m_btChatPrefixLen);
  524. memcpy(&sChat.m_szSentence[sChat.m_btNameLen + sChat.m_btChatPrefixLen], &pChat->m_szSentence[pChat->m_btChatPrefixLen], sChat.m_wSentenceLen); // 可能需要根据玩家身份改动
  525. g_pServer->PackDataToClient(Player[nIndex].m_nNetConnectIdx, (BYTE*)&sChat, sChat.m_wLength + 1);
  526. }
  527. break;
  528. case CHAT_CUR_CHANNEL_TEAM:
  529. {
  530. if (m_nTimer < CHAT_SPEED)
  531. break;
  532. m_nTimer = 0;
  534. if ( !Player[nPlayerIdx].m_cTeam.m_nFlag ) // 不在队伍中
  535. return;
  536. PLAYER_SEND_CHAT_SYNC sChat;
  537. sChat.ProtocolType = s2c_playersendchat;
  538. sChat.m_btCurChannel = pChat->m_btCurChannel;
  539. sChat.m_btNameLen = strlen(Npc[Player[nPlayerIdx].m_nIndex].Name);
  540. sChat.m_btChatPrefixLen = pChat->m_btChatPrefixLen;
  541. sChat.m_wSentenceLen = pChat->m_wSentenceLen;
  542. sChat.m_dwSourceID = Npc[Player[nPlayerIdx].m_nIndex].m_dwID; // 此处传的是发送者的 npc id
  543. sChat.m_wLength = sizeof(PLAYER_SEND_CHAT_SYNC) - 1 - sizeof(sChat.m_szSentence) + sChat.m_btNameLen + sChat.m_btChatPrefixLen + sChat.m_wSentenceLen;
  544. memcpy(&sChat.m_szSentence[0], Npc[Player[nPlayerIdx].m_nIndex].Name, sChat.m_btNameLen); // 可能需要根据玩家身份改动
  545. memcpy(&sChat.m_szSentence[sChat.m_btNameLen], &pChat->m_szSentence[0], sChat.m_btChatPrefixLen);
  546. memcpy(&sChat.m_szSentence[sChat.m_btNameLen + sChat.m_btChatPrefixLen], &pChat->m_szSentence[pChat->m_btChatPrefixLen], sChat.m_wSentenceLen); // 可能需要根据玩家身份改动
  547. int nTargetIdx;
  548. // 给队长发
  549. nTargetIdx = g_Team[Player[nPlayerIdx].m_cTeam.m_nID].m_nCaptain;
  550. if (nTargetIdx != nPlayerIdx && (Player[nTargetIdx].m_cChat.m_dwTakeChannel & g_dwChannelOr[CHAT_CUR_CHANNEL_TEAM]))
  551. g_pServer->PackDataToClient(Player[nTargetIdx].m_nNetConnectIdx, (BYTE*)&sChat, sChat.m_wLength + 1);
  552. // 给队员发
  553. for (int i = 0; i < MAX_TEAM_MEMBER; i++)
  554. {
  555. nTargetIdx = g_Team[Player[nPlayerIdx].m_cTeam.m_nID].m_nMember[i];
  556. if (nTargetIdx < 0 || nTargetIdx == nPlayerIdx)
  557. continue;
  558. if (Player[nTargetIdx].m_cChat.m_dwTakeChannel & g_dwChannelOr[CHAT_CUR_CHANNEL_TEAM])
  559. g_pServer->PackDataToClient(Player[nTargetIdx].m_nNetConnectIdx, (BYTE*)&sChat, sChat.m_wLength + 1);
  560. }
  561. }
  562. break;
  563. case CHAT_CUR_CHANNEL_FACTION:
  564. {
  565. if (m_nTimer < CHAT_SPEED)
  566. break;
  567. m_nTimer = 0;
  569. int nFaction = Player[nPlayerIdx].m_cFaction.m_nCurFaction;
  570. if ( nFaction < 0) // 不在门派中
  571. return;
  572. PLAYER_SEND_CHAT_SYNC sChat;
  573. sChat.ProtocolType = s2c_playersendchat;
  574. sChat.m_btCurChannel = pChat->m_btCurChannel;
  575. sChat.m_btNameLen = strlen(Npc[Player[nPlayerIdx].m_nIndex].Name);
  576. sChat.m_btChatPrefixLen = pChat->m_btChatPrefixLen;
  577. sChat.m_wSentenceLen = pChat->m_wSentenceLen;
  578. sChat.m_dwSourceID = Npc[Player[nPlayerIdx].m_nIndex].m_dwID; // 此处传的是发送者的 npc id
  579. sChat.m_wLength = sizeof(PLAYER_SEND_CHAT_SYNC) - 1 - sizeof(sChat.m_szSentence) + sChat.m_btNameLen + sChat.m_btChatPrefixLen + sChat.m_wSentenceLen;
  580. memcpy(&sChat.m_szSentence[0], Npc[Player[nPlayerIdx].m_nIndex].Name, sChat.m_btNameLen); // 可能需要根据玩家身份改动
  581. memcpy(&sChat.m_szSentence[sChat.m_btNameLen], &pChat->m_szSentence[0], sChat.m_btChatPrefixLen);
  582. memcpy(&sChat.m_szSentence[sChat.m_btNameLen + sChat.m_btChatPrefixLen], &pChat->m_szSentence[pChat->m_btChatPrefixLen], sChat.m_wSentenceLen); // 可能需要根据玩家身份改动
  583. int nTargetIdx;
  584. nTargetIdx = PlayerSet.GetFirstPlayer();
  585. while (nTargetIdx)
  586. {
  587. if (Player[nTargetIdx].m_cFaction.m_nCurFaction == nFaction && (Player[nTargetIdx].m_cChat.m_dwTakeChannel & g_dwChannelOr[CHAT_CUR_CHANNEL_FACTION]))
  588. g_pServer->PackDataToClient(Player[nTargetIdx].m_nNetConnectIdx, (BYTE*)&sChat, sChat.m_wLength + 1);
  589. nTargetIdx = PlayerSet.GetNextPlayer();
  590. }
  591. }
  592. break;
  593. case CHAT_CUR_CHANNEL_TONG:
  594. {
  595. if (m_nTimer < CHAT_SPEED)
  596. break;
  597. m_nTimer = 0;
  599. }
  600. break;
  601. case CHAT_CUR_CHANNEL_SCREENSINGLE:
  602. {
  603. if (m_nTimer < CHAT_SPEED)
  604. break;
  605. m_nTimer = 0;
  607. int nTargetIdx;
  608. nTargetIdx = Player[nPlayerIdx].FindAroundPlayer(pChat->m_dwTargetID);
  609. if (nTargetIdx == -1)
  610. return;
  611. if ( !Player[nTargetIdx].m_cChat.CheckTalkChannel(CHAT_CUR_CHANNEL_SCREENSINGLE) )
  612. {
  613. CHAT_SCREENSINGLE_ERROR_SYNC sError;
  614. sError.ProtocolType = s2c_chatscreensingleerror;
  615. sError.m_btError = 0;
  616. memset(sError.m_szName, 0, sizeof(sError.m_szName));
  617. g_StrCpy(sError.m_szName, Npc[Player[nTargetIdx].m_nIndex].Name);
  618. sError.m_wLength = 2 + 1 + strlen(sError.m_szName);
  619. g_pServer->PackDataToClient(Player[nPlayerIdx].m_nNetConnectIdx, (BYTE*)&sError, sError.m_wLength + 1);
  620. return;
  621. }
  622. PLAYER_SEND_CHAT_SYNC sChat;
  623. sChat.ProtocolType = s2c_playersendchat;
  624. sChat.m_btCurChannel = pChat->m_btCurChannel;
  625. sChat.m_btNameLen = strlen(Npc[Player[nPlayerIdx].m_nIndex].Name);
  626. sChat.m_btChatPrefixLen = pChat->m_btChatPrefixLen;
  627. sChat.m_wSentenceLen = pChat->m_wSentenceLen;
  628. sChat.m_dwSourceID = Npc[Player[nPlayerIdx].m_nIndex].m_dwID; // 此处传的是发送者的 npc id
  629. sChat.m_wLength = sizeof(PLAYER_SEND_CHAT_SYNC) - 1 - sizeof(sChat.m_szSentence) + sChat.m_btNameLen + sChat.m_btChatPrefixLen + sChat.m_wSentenceLen;
  630. memcpy(&sChat.m_szSentence[0], Npc[Player[nPlayerIdx].m_nIndex].Name, sChat.m_btNameLen); // 可能需要根据玩家身份改动
  631. memcpy(&sChat.m_szSentence[sChat.m_btNameLen], &pChat->m_szSentence[0], sChat.m_btChatPrefixLen);
  632. memcpy(&sChat.m_szSentence[sChat.m_btNameLen + sChat.m_btChatPrefixLen], &pChat->m_szSentence[pChat->m_btChatPrefixLen], sChat.m_wSentenceLen); // 可能需要根据玩家身份改动
  633. g_pServer->PackDataToClient(Player[nTargetIdx].m_nNetConnectIdx, (BYTE*)&sChat, sChat.m_wLength + 1);
  634. }
  635. break;
  636. case CHAT_CUR_CHANNEL_SYSTEM:
  637. // 在此种情况下普通玩家不允许使用此频道 not end
  638. if (pChat->m_dwTargetID == 0) // to all
  639. {
  640. char szSentence[MAX_SENTENCE_LENGTH], szPrefix[CHAT_MSG_PREFIX_MAX_LEN];
  641. memcpy(szSentence, &pChat->m_szSentence[pChat->m_btChatPrefixLen], nLen); // 可能需要根据玩家身份改动
  642. szSentence[nLen] = 0;
  643. memcpy(szPrefix, &pChat->m_szSentence[0], pChat->m_btChatPrefixLen);
  644. KPlayerChat::SendSystemInfo(0, 0, MESSAGE_SYSTEM_ANNOUCE_HEAD, szSentence, nLen);
  645. }
  646. else
  647. {
  648. char szSentence[MAX_SENTENCE_LENGTH], szPrefix[CHAT_MSG_PREFIX_MAX_LEN];
  649. int nIdx;
  650. memcpy(szSentence, &pChat->m_szSentence[pChat->m_btChatPrefixLen], nLen); // 可能需要根据玩家身份改动
  651. szSentence[nLen] = 0;
  652. memcpy(szPrefix, &pChat->m_szSentence[0], pChat->m_btChatPrefixLen);
  653. nIdx = PlayerSet.FindSame(pChat->m_dwTargetID);
  654. if (nIdx > 0)
  655. KPlayerChat::SendSystemInfo(1, nIdx, MESSAGE_SYSTEM_ANNOUCE_HEAD, szSentence, nLen);
  656. }
  657. break;
  658. }
  659. }
  660. else if (pChat->m_btType == MSG_G_CMD)
  661. {
  662. }
  663. else
  664. {
  665. return;
  666. }
  667. }
  668. #endif
  670. #ifndef _SERVER
  671. //---------------------------------------------------------------------------
  672. // 功能：客户端收到聊天语句
  673. //---------------------------------------------------------------------------
  674. void KPlayerChat::GetChat(PLAYER_SEND_CHAT_SYNC *pChat)
  675. {
  676. if (!pChat)
  677. return;
  679. char szBuf[MAX_SENTENCE_LENGTH];
  680. KUiMsgParam Param;
  682. Param.cChatPrefixLen = pChat->m_btChatPrefixLen;
  683. Param.nMsgLength = pChat->m_wSentenceLen;
  684. memcpy(szBuf, &pChat->m_szSentence[pChat->m_btNameLen + pChat->m_btChatPrefixLen], pChat->m_wSentenceLen);
  685. szBuf[pChat->m_wSentenceLen] = 0;
  686. memset(Param.cChatPrefix, 0, sizeof(Param.cChatPrefix));
  687. memset(Param.szName, 0, sizeof(Param.szName));
  689. switch (pChat->m_btCurChannel)
  690. {
  691. case CHAT_CUR_CHANNEL_ALL:
  692. {
  693. if (pChat->m_dwSourceID == Player[CLIENT_PLAYER_INDEX].m_dwID)
  694. return;
  695. memcpy(Param.cChatPrefix, &pChat->m_szSentence[pChat->m_btNameLen], pChat->m_btChatPrefixLen);
  696. memcpy(Param.szName, &pChat->m_szSentence[0], pChat->m_btNameLen);
  697. Param.szName[pChat->m_btNameLen] = 0;
  698. CoreDataChanged(GDCNI_MSG_ARRIVAL, (unsigned int)szBuf, (int)&Param);
  699. }
  700. break;
  701. case CHAT_CUR_CHANNEL_SCREEN:
  702. {
  703. if (pChat->m_dwSourceID == Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].m_dwID)
  704. return;
  705. int nTalker = NpcSet.SearchID(pChat->m_dwSourceID);
  706. if (nTalker == 0)
  707. return;
  709. memcpy(Param.cChatPrefix, &pChat->m_szSentence[pChat->m_btNameLen], pChat->m_btChatPrefixLen);
  710. memcpy(Param.szName, &pChat->m_szSentence[0], pChat->m_btNameLen);
  711. Param.szName[pChat->m_btNameLen] = 0;
  713. CoreDataChanged(GDCNI_MSG_ARRIVAL, (unsigned int)szBuf, (int)&Param);
  714. }
  715. break;
  716. case CHAT_CUR_CHANNEL_SINGLE:
  717. {
  718. if (pChat->m_dwSourceID == Player[CLIENT_PLAYER_INDEX].m_dwID)
  719. return;
  720. CChatFriend *pFriend = NULL;
  721. pFriend = this->GetFriendNode(pChat->m_dwSourceID);
  722. if ( pFriend == NULL )
  723. {
  724. // TODO: Temp change by wanli
  725. /* CHAT_REDELETE_FRIEND_COMMAND sApply;
  726. sApply.ProtocolType = c2s_chatredeletefriend;
  727. sApply.m_dwID = pChat->m_dwSourceID;
  728. if (g_pClient)
  729. g_pClient->SendPackToServer(&sApply, sizeof(CHAT_REDELETE_FRIEND_COMMAND));
  730. break;*/
  731. int nIndex = NpcSet.SearchNameID(pChat->m_dwSourceID);
  732. if (nIndex == 0)
  733. break;
  734. KUiChatMessage sMsg;
  735. sMsg.nContentLen = pChat->m_wSentenceLen;
  736. memcpy(sMsg.szContent, &pChat->m_szSentence[pChat->m_btNameLen + pChat->m_btChatPrefixLen], sMsg.nContentLen);
  737. sMsg.szContent[sMsg.nContentLen] = 0;
  738. if (pChat->m_btChatPrefixLen == 4)
  739. {
  740. ((char*)(&sMsg.uColor))[3] = pChat->m_szSentence[pChat->m_btNameLen];
  741. ((char*)(&sMsg.uColor))[2] = pChat->m_szSentence[pChat->m_btNameLen + 1];
  742. ((char*)(&sMsg.uColor))[1] = pChat->m_szSentence[pChat->m_btNameLen + 2];
  743. ((char*)(&sMsg.uColor))[0] = pChat->m_szSentence[pChat->m_btNameLen + 3];
  744. }
  745. else
  746. {
  747. sMsg.uColor = 0;
  748. }
  749. KUiPlayerItem sPlayer;
  750. strcpy(sPlayer.Name, Npc[nIndex].Name);
  751. sPlayer.uId = pChat->m_dwSourceID;
  752. sPlayer.nIndex = 0;
  753. sPlayer.nData = 0;
  755. CoreDataChanged(GDCNI_CHAT_MESSAGE, (unsigned int)&sMsg, (int)&sPlayer);
  756. break;
  757. }
  759. KUiChatMessage sMsg;
  760. sMsg.nContentLen = pChat->m_wSentenceLen;
  761. memcpy(sMsg.szContent, &pChat->m_szSentence[pChat->m_btNameLen + pChat->m_btChatPrefixLen], sMsg.nContentLen);
  762. sMsg.szContent[sMsg.nContentLen] = 0;
  763. if (pChat->m_btChatPrefixLen == 4)
  764. {
  765. ((char*)(&sMsg.uColor))[3] = pChat->m_szSentence[pChat->m_btNameLen];
  766. ((char*)(&sMsg.uColor))[2] = pChat->m_szSentence[pChat->m_btNameLen + 1];
  767. ((char*)(&sMsg.uColor))[1] = pChat->m_szSentence[pChat->m_btNameLen + 2];
  768. ((char*)(&sMsg.uColor))[0] = pChat->m_szSentence[pChat->m_btNameLen + 3];
  769. }
  770. else
  771. {
  772. sMsg.uColor = 0;
  773. }
  775. KUiPlayerItem sPlayer;
  776. strcpy(sPlayer.Name, pFriend->m_szName);
  777. sPlayer.uId = pFriend->m_dwID;
  778. sPlayer.nIndex = pFriend->m_nPlayerIdx;
  779. sPlayer.nData = 0;
  781. CoreDataChanged(GDCNI_CHAT_MESSAGE, (unsigned int)&sMsg, (int)&sPlayer);
  782. }
  783. break;
  784. case CHAT_CUR_CHANNEL_TEAM:
  785. {
  786. if (pChat->m_dwSourceID == Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].m_dwID)
  787. return;
  788. memcpy(Param.cChatPrefix, &pChat->m_szSentence[pChat->m_btNameLen], pChat->m_btChatPrefixLen);
  789. memcpy(Param.szName, &pChat->m_szSentence[0], pChat->m_btNameLen);
  790. Param.szName[pChat->m_btNameLen] = 0;
  791. CoreDataChanged(GDCNI_MSG_ARRIVAL, (unsigned int)szBuf, (int)&Param);
  792. }
  793. break;
  794. case CHAT_CUR_CHANNEL_FACTION:
  795. {
  796. if (pChat->m_dwSourceID == Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].m_dwID)
  797. return;
  798. memcpy(Param.cChatPrefix, &pChat->m_szSentence[pChat->m_btNameLen], pChat->m_btChatPrefixLen);
  799. memcpy(Param.szName, &pChat->m_szSentence[0], pChat->m_btNameLen);
  800. Param.szName[pChat->m_btNameLen] = 0;
  801. CoreDataChanged(GDCNI_MSG_ARRIVAL, (unsigned int)szBuf, (int)&Param);
  802. }
  803. break;
  804. case CHAT_CUR_CHANNEL_TONG:
  805. {
  806. if (pChat->m_dwSourceID == Player[CLIENT_PLAYER_INDEX].m_dwID)
  807. return;
  808. memcpy(Param.cChatPrefix, &pChat->m_szSentence[pChat->m_btNameLen], pChat->m_btChatPrefixLen);
  809. memcpy(Param.szName, &pChat->m_szSentence[0], pChat->m_btNameLen);
  810. Param.szName[pChat->m_btNameLen] = 0;
  811. CoreDataChanged(GDCNI_MSG_ARRIVAL, (unsigned int)szBuf, (int)&Param);
  812. }
  813. break;
  814. case CHAT_CUR_CHANNEL_SCREENSINGLE:
  815. {
  816. memcpy(Param.cChatPrefix, &pChat->m_szSentence[pChat->m_btNameLen], pChat->m_btChatPrefixLen);
  817. memcpy(Param.szName, &pChat->m_szSentence[0], pChat->m_btNameLen);
  818. Param.szName[pChat->m_btNameLen] = 0;
  819. CoreDataChanged(GDCNI_MSG_ARRIVAL, (unsigned int)szBuf, (int)&Param);
  820. }
  821. break;
  822. case CHAT_CUR_CHANNEL_SYSTEM:
  823. {
  824. memcpy(Param.cChatPrefix, &pChat->m_szSentence[pChat->m_btNameLen], pChat->m_btChatPrefixLen);
  825. memcpy(Param.szName, &pChat->m_szSentence[0], pChat->m_btNameLen);
  826. Param.szName[pChat->m_btNameLen] = 0;
  827. CoreDataChanged(GDCNI_MSG_ARRIVAL, (unsigned int)szBuf, (int)&Param);
  828. }
  829. break;
  830. }
  832. // 保存聊天纪录
  833. if (pChat->m_btCurChannel == CHAT_CUR_CHANNEL_SINGLE)
  834. {
  835. char szName[32], szSentence[MAX_SENTENCE_LENGTH];
  836. memcpy(szName, &pChat->m_szSentence[0], pChat->m_btNameLen);
  837. szName[pChat->m_btNameLen] = 0;
  838. memcpy(szSentence, &pChat->m_szSentence[pChat->m_btNameLen + pChat->m_btChatPrefixLen], pChat->m_wSentenceLen);
  839. szSentence[pChat->m_wSentenceLen] = 0;
  840. m_cRecorder.SaveSentenceSingle(Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].Name, szName, szName, szSentence);
  841. }
  842. else
  843. {
  844. char szName[32], szSentence[MAX_SENTENCE_LENGTH];
  845. memcpy(szName, &pChat->m_szSentence[0], pChat->m_btNameLen);
  846. szName[pChat->m_btNameLen] = 0;
  847. memcpy(szSentence, &pChat->m_szSentence[pChat->m_btNameLen + pChat->m_btChatPrefixLen], pChat->m_wSentenceLen);
  848. szSentence[pChat->m_wSentenceLen] = 0;
  849. m_cRecorder.SaveSentenceChannel(Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].Name, szName, szSentence);
  850. }
  851. }
  852. #endif
  854. #ifndef _SERVER
  855. //---------------------------------------------------------------------------
  856. // 功能：申请添加聊天好友
  857. //---------------------------------------------------------------------------
  858. void KPlayerChat::ApplyAddFriend(DWORD dwNpcID, char *lpszSentence/* = NULL*/)
  859. {
  860. if (dwNpcID <= 0)
  861. return;
  863. char szName[32];
  864. szName[0] = 0;
  865. if (this->GetName(dwNpcID, szName))
  866. {
  867. // 通知界面此人已经是他的好友了
  868. KSystemMessage sMsg;
  869. sprintf(sMsg.szMessage, MSG_CHAT_FRIEND_HAD_IN, szName);
  870. sMsg.eType = SMT_FRIEND;
  871. sMsg.byConfirmType = SMCT_CLICK;
  872. sMsg.byPriority = 1;
  873. sMsg.byParamSize = 0;
  874. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  875. return;
  876. }
  878. CHAT_APPLY_ADD_FRIEND_COMMAND sAdd;
  879. sAdd.ProtocolType = c2s_chatapplyaddfriend;
  880. sAdd.m_dwTargetNpcID = dwNpcID;
  881. memset(sAdd.m_szInfo, 0, sizeof(sAdd.m_szInfo));
  882. if (lpszSentence)
  883. {
  884. if (strlen(lpszSentence) < sizeof(sAdd.m_szInfo))
  885. strcpy(sAdd.m_szInfo, lpszSentence);
  886. else
  887. memcpy(sAdd.m_szInfo, lpszSentence, sizeof(sAdd.m_szInfo) - 1);
  888. }
  889. sAdd.m_wLength = sizeof(CHAT_APPLY_ADD_FRIEND_COMMAND) - 1 - sizeof(sAdd.m_szInfo) + strlen(sAdd.m_szInfo);
  890. if (g_pClient)
  891. g_pClient->SendPackToServer(&sAdd, sAdd.m_wLength + 1);
  892. }
  893. #endif
  895. #ifndef _SERVER
  896. //---------------------------------------------------------------------------
  897. // 功能：界面获取聊天好友添加申请人信息
  898. //---------------------------------------------------------------------------
  899. BOOL KPlayerChat::GetApplyOneInfo(int *lpnPlayerIdx, char *lpszName, char *lpszInfo)
  900. {
  901. if ( m_cApplyAddList.IsEmpty() )
  902. return FALSE;
  903. if (!lpnPlayerIdx || !lpszName || !lpszInfo)
  904. return FALSE;
  906. CChatApplyListNode *pApply = NULL;
  907. BOOL bFind = FALSE;
  908. pApply = (CChatApplyListNode*)m_cApplyAddList.GetHead();
  909. while (pApply)
  910. {
  911. if ( !pApply->m_nAccessFlag )
  912. {
  913. bFind = TRUE;
  914. break;
  915. }
  916. pApply = (CChatApplyListNode*)pApply->GetNext();
  917. }
  918. if ( !bFind )
  919. return FALSE;
  921. pApply->m_nAccessFlag = 1;
  922. *lpnPlayerIdx = pApply->m_nPlayerIdx;
  923. strcpy(lpszName, pApply->m_szName);
  924. strcpy(lpszInfo, pApply->m_szInfo);
  926. return TRUE;
  927. }
  928. #endif
  930. #ifndef _SERVER
  931. //---------------------------------------------------------------------------
  932. // 功能：保存所有好友分组信息
  933. // char *lpszName : 人名
  934. //---------------------------------------------------------------------------
  935. void KPlayerChat::SaveTeamInfo(char *lpszName)
  936. {
  937. if (!lpszName || !lpszName[0])
  938. return;
  940. // 产生出相应路径
  941. char szPath[MAX_PATH], szBuf[MAX_PATH];
  942. g_StrCpy(szPath, CHAT_PATH);
  943. g_StrCat(szPath, "\");
  944. g_StrCat(szPath, lpszName);
  945. g_CreatePath(szPath);
  946. // g_SetFilePath(szPath);
  948. KIniFile cTeam;
  949. char szKey[32], szSect[64];
  950. int i;
  952. // 保存组名
  953. for (i = 0; i < MAX_FRIEND_TEAM; i++)
  954. {
  955. sprintf(szKey, "%d", i);
  956. cTeam.WriteString("TeamName", szKey, m_cFriendTeam[i].m_szTeamName);
  957. }
  958. // 保存每个组成员信息
  959. for (i = 0; i < MAX_FRIEND_TEAM; i++)
  960. {
  961. if ( !m_cFriendTeam[i].m_szTeamName[0] )
  962. continue;
  963. sprintf(szSect, "T_%s", m_cFriendTeam[i].m_szTeamName);
  964. cTeam.WriteInteger(szSect, "FriendNo", m_cFriendTeam[i].m_nFriendNo);
  966. int j = 0;
  967. CChatFriend *pOne;
  968. pOne = (CChatFriend*)m_cFriendTeam[i].m_cEveryOne.GetHead();
  969. while (pOne)
  970. {
  971. sprintf(szKey, "%d", j);
  972. cTeam.WriteString(szSect, szKey, pOne->m_szName);
  973. pOne = (CChatFriend*)pOne->GetNext();
  974. j++;
  975. }
  976. }
  977. g_UnitePathAndName(szPath, CHAT_TEAM_INFO_FILE_NAME, szBuf);
  978. cTeam.Save(szBuf);
  979. }
  980. #endif
  982. #ifndef _SERVER
  983. //---------------------------------------------------------------------------
  984. // 功能：保存频道订阅信息
  985. // char *lpszName : 人名
  986. //---------------------------------------------------------------------------
  987. void KPlayerChat::SaveTakeChannelInfo(char *lpszName)
  988. {
  989. if (!lpszName || !lpszName[0])
  990. return;
  992. // 产生出相应路径
  993. char szPath[MAX_PATH], szBuf[MAX_PATH];
  994. g_StrCpy(szPath, CHAT_PATH);
  995. g_StrCat(szPath, "\");
  996. g_StrCat(szPath, lpszName);
  997. g_CreatePath(szPath);
  998. // g_SetFilePath(szPath);
  1000. KIniFile cChannel;
  1002. cChannel.WriteInteger("Channel", "Channel", this->m_dwTakeChannel);
  1003. g_UnitePathAndName(szPath, CHAT_CHANNEL_INFO_FILE_NAME, szBuf);
  1004. cChannel.Save(szBuf);
  1005. }
  1006. #endif
  1008. #ifndef _SERVER
  1009. //---------------------------------------------------------------------------
  1010. // 功能：载入频道订阅信息
  1011. // char *lpszName : 人名
  1012. //---------------------------------------------------------------------------
  1013. void KPlayerChat::LoadTakeChannelInfo(char *lpszName)
  1014. {
  1015. if (!lpszName || !lpszName[0])
  1016. return;
  1018. // 产生出相应路径
  1019. char szPath[MAX_PATH], szBuf[MAX_PATH];
  1020. DWORD dwTakeChannel;
  1022. g_StrCpy(szPath, CHAT_PATH);
  1023. g_StrCat(szPath, "\");
  1024. g_StrCat(szPath, lpszName);
  1025. g_CreatePath(szPath);
  1026. // g_SetFilePath(szPath);
  1028. this->SetTakeChannel(g_dwChannelOr[CHAT_CUR_CHANNEL_SCREEN]);
  1030. KIniFile cChannel;
  1032. g_UnitePathAndName(szPath, CHAT_CHANNEL_INFO_FILE_NAME, szBuf);
  1033. if (!cChannel.Load(szBuf))
  1034. {
  1035. m_dwTakeChannel |= g_dwChannelOr[CHAT_CUR_CHANNEL_TEAM] | g_dwChannelOr[CHAT_CUR_CHANNEL_FACTION] | g_dwChannelOr[CHAT_CUR_CHANNEL_SCREENSINGLE];
  1036. this->SaveTakeChannelInfo(lpszName);
  1037. this->SendTakeChannel();
  1038. return;
  1039. }
  1040. cChannel.GetInteger("Channel", "Channel", this->m_dwTakeChannel, (int*)&dwTakeChannel);
  1042. this->SetTakeChannel(dwTakeChannel);
  1043. this->SendTakeChannel();
  1044. }
  1045. #endif
  1047. #ifndef _SERVER
  1048. /*---------------------------------------------------------------------------
  1049. ** 功能：判断某个ID的好友在哪个组里
  1050. ** dwID 被判断的 id
  1051. **  lpszName 本客户端玩家名字
  1052. **  lpszGetName 被判断的 id 的名字
  1053. **-------------------------------------------------------------------------*/
  1054. int KPlayerChat::CheckTeamNo(char *lpszName, char *lpszGetName)
  1055. {
  1056. int i;
  1057. if (!lpszName || !lpszName[0] || !lpszGetName || !lpszGetName[0])
  1058. return -1;
  1059. if (m_btIniLoadFlag == FALSE)
  1060. {
  1061. if (!lpszName || !lpszName[0])
  1062. return -1;
  1063. // 产生出相应路径
  1064. char szPath[MAX_PATH], szBuf[MAX_PATH];
  1065. g_StrCpy(szPath, CHAT_PATH);
  1066. g_StrCat(szPath, "\");
  1067. g_StrCat(szPath, lpszName);
  1068. g_CreatePath(szPath);
  1069. // g_SetFilePath(szPath);
  1071. g_UnitePathAndName(szPath, CHAT_TEAM_INFO_FILE_NAME, szBuf);
  1072. if ( !m_cTeamInfo.Load(szBuf) )
  1073. {
  1074. this->SaveTeamInfo(lpszName);
  1075. // g_SetFilePath(szPath);
  1076. m_cTeamInfo.Load(szBuf);
  1077. }
  1078. else
  1079. {
  1080. char szKey[32], szTemp[32];
  1081. strcpy(m_cFriendTeam[0].m_szTeamName, CHAT_TEAM_DEFAULT_NAME);
  1082. for (i = 1; i < MAX_FRIEND_TEAM; i++)
  1083. {
  1084. sprintf(szKey, "%d", i);
  1085. m_cTeamInfo.GetString("TeamName", szKey, "", szTemp, sizeof(szTemp));
  1086. if ( szTemp[0] )
  1087. {
  1088. strcpy(this->m_cFriendTeam[i].m_szTeamName, szTemp);
  1089. }
  1090. else
  1091. {
  1092. this->m_cFriendTeam[i].m_szTeamName[0] = 0;
  1093. }
  1094. }
  1095. }
  1096. m_btIniLoadFlag = TRUE;
  1097. }
  1099. char szKey[32], szTemp[32], szSect[64];
  1100. int nFriendNo, j;
  1101. for (i = 0; i < MAX_FRIEND_TEAM; i++)
  1102. {
  1103. sprintf(szKey, "%d", i);
  1104. m_cTeamInfo.GetString("TeamName", szKey, "", szTemp, sizeof(szTemp));
  1105. if ( !szTemp[0] )
  1106. continue;
  1107. sprintf(szSect, "T_%s", szTemp);
  1108. m_cTeamInfo.GetInteger(szSect, "FriendNo", 0, &nFriendNo);
  1109. for (j = 0; j < nFriendNo; j++)
  1110. {
  1111. sprintf(szKey, "%d", j);
  1112. m_cTeamInfo.GetString(szSect, szKey, "", szTemp, sizeof(szTemp));
  1113. if (strcmp(szTemp, lpszGetName) == 0)
  1114. return i;
  1115. }
  1116. }
  1118. return -1;
  1119. }
  1120. #endif
  1122. #ifndef _SERVER
  1123. //---------------------------------------------------------------------------
  1124. // 功能：载入组名(初始化的时候调用，其他时候不允许调用)
  1125. //---------------------------------------------------------------------------
  1126. void KPlayerChat::LoadTeamName(char *lpszPlayerName)
  1127. {
  1128. if (m_btIniLoadFlag)
  1129. return;
  1130. if (!lpszPlayerName || !lpszPlayerName[0])
  1131. return;
  1133. this->Release();
  1135. // 产生出相应路径
  1136. char szPath[MAX_PATH], szBuf[MAX_PATH];
  1137. KIniFile cIni;
  1139. g_StrCpy(szPath, CHAT_PATH);
  1140. g_StrCat(szPath, "\");
  1141. g_StrCat(szPath, lpszPlayerName);
  1142. g_CreatePath(szPath);
  1143. // g_SetFilePath(szPath);
  1145. g_UnitePathAndName(szPath, CHAT_TEAM_INFO_FILE_NAME, szBuf);
  1146. if (!cIni.Load(szBuf))
  1147. {
  1148. this->SaveTeamInfo(lpszPlayerName);
  1149. return;
  1150. }
  1152. char szKey[32], szTemp[32];
  1153. strcpy(m_cFriendTeam[0].m_szTeamName, CHAT_TEAM_DEFAULT_NAME);
  1154. for (int i = 1; i < MAX_FRIEND_TEAM; i++)
  1155. {
  1156. sprintf(szKey, "%d", i);
  1157. cIni.GetString("TeamName", szKey, "", szTemp, sizeof(szTemp));
  1158. if ( !szTemp[0] )
  1159. continue;
  1160. strcpy(this->m_cFriendTeam[i].m_szTeamName, szTemp);
  1161. }
  1163. }
  1164. #endif
  1166. #ifndef _SERVER
  1167. //---------------------------------------------------------------------------
  1168. // 功能：添加一个成员
  1169. //---------------------------------------------------------------------------
  1170. void KPlayerChat::AddOne(DWORD dwID, int nPlayerIdx, char *lpszName, int nTeamNo)
  1171. {
  1172. if (!lpszName || !lpszName[0])
  1173. return;
  1174. if (nTeamNo < 0 || nTeamNo >= MAX_FRIEND_TEAM)
  1175. return;
  1176. CChatFriend *pFriend;
  1177. pFriend = new CChatFriend;
  1178. pFriend->m_dwID = dwID;
  1179. pFriend->m_nPlayerIdx = nPlayerIdx;
  1180. g_StrCpy(pFriend->m_szName, lpszName);
  1181. m_cFriendTeam[nTeamNo].m_cEveryOne.AddTail(pFriend);
  1182. m_cFriendTeam[nTeamNo].m_nFriendNo++;
  1184. // 通知界面
  1185. // CoreDataChanged(GDCNI_CHAT_GROUP, 0, 0);
  1186. CoreDataChanged(GDCNI_CHAT_FRIEND, 0, nTeamNo);
  1187. }
  1188. #endif
  1190. #ifndef _SERVER
  1191. //---------------------------------------------------------------------------
  1192. // 功能：判断某个playeridx是否好友
  1193. //---------------------------------------------------------------------------
  1194. BOOL KPlayerChat::CheckIsFriend(int nPlayerIdx)
  1195. {
  1196. for (int i = 0; i < MAX_FRIEND_TEAM; i++)
  1197. {
  1198. if (m_cFriendTeam[i].m_nFriendNo == 0)
  1199. continue;
  1200. CChatFriend *pFriend;
  1201. pFriend = (CChatFriend*)m_cFriendTeam[i].m_cEveryOne.GetHead();
  1202. while (pFriend)
  1203. {
  1204. if (pFriend->m_nPlayerIdx == nPlayerIdx)
  1205. return TRUE;
  1206. pFriend = (CChatFriend*)pFriend->GetNext();
  1207. }
  1208. }
  1209. return FALSE;
  1210. }
  1211. #endif
  1213. #ifdef _SERVER
  1214. //---------------------------------------------------------------------------
  1215. // 功能：玩家登陆的时候从数据库获得数据时专用
  1216. // 参数：nSelfIdx 本玩家自己在Player中的位置 dwID  好友ID  lpszName  好友名字
  1217. //---------------------------------------------------------------------------
  1218. void KPlayerChat::DataBaseAddOne(int nSelfIdx, DWORD dwID, char *lpszName)
  1219. {
  1220. this->m_cFriendTeam[0].DataBaseAddOne(nSelfIdx, dwID, lpszName);
  1221. }
  1222. #endif
  1224. #ifdef _SERVER
  1225. //---------------------------------------------------------------------------
  1226. // 功能：添加好友数据
  1227. //---------------------------------------------------------------------------
  1228. void KPlayerChat::AddFriendData(int nSelfIdx, int nDestIdx)
  1229. {
  1230. if (this->CheckExist(Player[nDestIdx].m_dwID))
  1231. return;
  1232. CChatFriend *pFriend = NULL;
  1233. pFriend = new CChatFriend;
  1234. if ( !pFriend )
  1235. return;
  1236. pFriend->m_dwID = Player[nDestIdx].m_dwID;
  1237. pFriend->m_nPlayerIdx = nDestIdx;
  1238. g_StrCpy(pFriend->m_szName, Npc[Player[nDestIdx].m_nIndex].Name);
  1239. m_cFriendTeam[0].m_cEveryOne.AddTail(pFriend);
  1240. m_cFriendTeam[0].m_nFriendNo++;
  1242. CHAT_ADD_FRIEND_SYNC sAdd;
  1243. sAdd.ProtocolType = s2c_chataddfriend;
  1244. sAdd.m_dwID = Player[nDestIdx].m_dwID;
  1245. sAdd.m_nIdx = nDestIdx;
  1246. memset(sAdd.m_szName, 0, 32);
  1247. g_StrCpy(sAdd.m_szName, Npc[Player[nDestIdx].m_nIndex].Name);
  1249. g_pServer->PackDataToClient(Player[nSelfIdx].m_nNetConnectIdx, (BYTE*)&sAdd, sizeof(CHAT_ADD_FRIEND_SYNC));
  1250. }
  1251. #endif
  1253. #ifdef _SERVER
  1254. //---------------------------------------------------------------------------
  1255. // 功能：重新发送某个好友数据
  1256. //  dwID 好友 id   nPlayerIdx 玩家自己
  1257. //---------------------------------------------------------------------------
  1258. void KPlayerChat::ResendOneFriendData(DWORD dwID, int nPlayerIdx)
  1259. {
  1260. BOOL bFind = FALSE;
  1261. CChatFriend *pFriend;
  1262. pFriend = (CChatFriend*)m_cFriendTeam[0].m_cEveryOne.GetHead();
  1263. while (pFriend)
  1264. {
  1265. if (pFriend->m_dwID == dwID)
  1266. {
  1267. bFind = TRUE;
  1268. break;
  1269. }
  1270. pFriend = (CChatFriend*)pFriend->GetNext();
  1271. }
  1272. if ( !bFind )
  1273. return;
  1274. CHAT_ONE_FRIEND_DATA_SYNC sData;
  1275. sData.ProtocolType = s2c_chatonefrienddata;
  1276. sData.m_dwID = dwID;
  1277. sData.m_nPlayerIdx = pFriend->m_nPlayerIdx;
  1278. memset(sData.m_szName, 0, sizeof(sData.m_szName));
  1279. g_StrCpy(sData.m_szName, pFriend->m_szName);
  1281. g_pServer->PackDataToClient(Player[nPlayerIdx].m_nNetConnectIdx, (BYTE*)&sData, sizeof(CHAT_ONE_FRIEND_DATA_SYNC));
  1282. }
  1283. #endif
  1285. #ifdef _SERVER
  1286. //---------------------------------------------------------------------------
  1287. // 功能：玩家登录时加载数据库玩家好友数据完成后自动依次发送好友数据给客户端
  1288. //---------------------------------------------------------------------------
  1289. BOOL KPlayerChat::SyncFriendData(int nPlayerIdx, unsigned int &nParam)
  1290. {
  1291. BOOL bRet = FALSE;
  1292. if ( !m_nSyncState ) // 平时不做任何处理 m_nSyncState == 0
  1293. return TRUE;
  1295. if ( m_nSyncState == 1 ) // 玩家刚登录，发送不带名字的聊天好友数据
  1296. {
  1297. if ( !m_pStateSendPos )
  1298. {
  1299. m_nSyncState = 0;
  1300. nParam = 2;
  1301. return TRUE;
  1302. }
  1304. CHAT_LOGIN_FRIEND_NONAME_SYNC sFriend;
  1305. sFriend.ProtocolType = s2c_chatloginfriendnoname;
  1306. sFriend.m_dwID = m_pStateSendPos->m_dwID;
  1307. sFriend.m_nPlayerIdx = m_pStateSendPos->m_nPlayerIdx;
  1308. if (SUCCEEDED(g_pServer->PackDataToClient(Player[nPlayerIdx].m_nNetConnectIdx, (BYTE*)&sFriend, sizeof(CHAT_LOGIN_FRIEND_NONAME_SYNC))))
  1309. {
  1310. bRet = TRUE;
  1311. }
  1312. else
  1313. {
  1314. printf("player Packing friend sync data failed...n");
  1315. bRet = FALSE;
  1316. }
  1318. m_pStateSendPos = (CChatFriend*)m_pStateSendPos->GetNext();
  1319. return bRet;
  1320. }
  1322. if ( m_nSyncState == 2 ) // 玩家刚登录，发送带名字的聊天好友数据(玩家客户端没有好友分组和名字信息)
  1323. {
  1324. if ( !m_pStateSendPos )
  1325. {
  1326. m_nSyncState = 0;
  1327. nParam = 2;
  1328. return TRUE;
  1329. }
  1331. CHAT_LOGIN_FRIEND_NAME_SYNC sFriend;
  1332. sFriend.ProtocolType = s2c_chatloginfriendname;
  1333. sFriend.m_dwID = m_pStateSendPos->m_dwID;
  1334. sFriend.m_nPlayerIdx = m_pStateSendPos->m_nPlayerIdx;
  1335. g_StrCpy(sFriend.m_szName, m_pStateSendPos->m_szName);
  1336. sFriend.m_wLength = sizeof(CHAT_LOGIN_FRIEND_NAME_SYNC) - 1 - sizeof(sFriend.m_szName) + strlen(sFriend.m_szName);
  1337. if (SUCCEEDED(g_pServer->PackDataToClient(Player[nPlayerIdx].m_nNetConnectIdx, (BYTE*)&sFriend, sFriend.m_wLength + 1)))
  1338. {
  1339. bRet = TRUE;
  1340. }
  1341. else
  1342. {
  1343. printf("player Packing friend 2 sync data failed...n");
  1344. bRet = FALSE;
  1345. }
  1347. m_pStateSendPos = (CChatFriend*)m_pStateSendPos->GetNext();
  1348. return bRet;
  1349. }
  1350. return TRUE;
  1351. }
  1352. #endif
  1354. #ifdef _SERVER
  1355. //---------------------------------------------------------------------------
  1356. // 功能：玩家登录时加载数据库玩家好友数据完成后调用次方法开始发送给客户端好友数据
  1357. //---------------------------------------------------------------------------
  1358. void KPlayerChat::StartSendFriendData()
  1359. {
  1360. this->SetTakeChannel(g_dwChannelOr[CHAT_CUR_CHANNEL_SCREEN]);
  1361. m_pStateSendPos = (CChatFriend*)m_cFriendTeam[0].m_cEveryOne.GetHead();
  1362. m_nSyncState = 2;
  1363. }
  1364. #endif
  1366. #ifdef _SERVER
  1367. //---------------------------------------------------------------------------
  1368. // 功能：删除某个好友数据（会通知对方相应处理）
  1369. //---------------------------------------------------------------------------
  1370. void KPlayerChat::DeleteFriend(DWORD dwID, DWORD dwSelfID)
  1371. {
  1372. CChatFriend *pFriend;
  1373. pFriend = (CChatFriend*)m_cFriendTeam[0].m_cEveryOne.GetHead();
  1374. while (pFriend)
  1375. {
  1376. if (pFriend->m_dwID == dwID)
  1377. {
  1378. pFriend->Remove();
  1379. m_cFriendTeam[0].m_nFriendNo--;
  1381. // 通知被删除方执行相应处理
  1382. if (pFriend->m_nPlayerIdx)
  1383. { // 如果对方在线，id 正确
  1384. if (pFriend->m_nPlayerIdx < MAX_PLAYER && Player[pFriend->m_nPlayerIdx].m_nIndex && Player[pFriend->m_nPlayerIdx].m_dwID == dwID)
  1385. {
  1386. Player[pFriend->m_nPlayerIdx].m_cChat.DeleteFriendData(dwSelfID, pFriend->m_nPlayerIdx);
  1387. }
  1388. }
  1390. delete pFriend;
  1391. return;
  1392. }
  1393. pFriend = (CChatFriend*)pFriend->GetNext();
  1394. }
  1395. }
  1396. #endif
  1398. #ifdef _SERVER
  1399. //---------------------------------------------------------------------------
  1400. // 功能：删除某个好友数据（会通知自己客户端）
  1401. //---------------------------------------------------------------------------
  1402. void KPlayerChat::DeleteFriendData(DWORD dwID, int nSelfIndex)
  1403. {
  1404. CChatFriend *pFriend;
  1405. pFriend = (CChatFriend*)this->m_cFriendTeam[0].m_cEveryOne.GetHead();
  1406. while (pFriend)
  1407. {
  1408. if (pFriend->m_dwID == dwID)
  1409. {
  1410. pFriend->Remove();
  1411. delete pFriend;
  1412. m_cFriendTeam[0].m_nFriendNo--;
  1413. // 通知客户端
  1414. CHAT_DELETE_FRIEND_SYNC sDelete;
  1415. sDelete.ProtocolType = s2c_chatdeletefriend;
  1416. sDelete.m_dwID = dwID;
  1417. g_pServer->PackDataToClient(Player[nSelfIndex].m_nNetConnectIdx, (BYTE*)&sDelete, sizeof(CHAT_DELETE_FRIEND_SYNC));
  1419. return;
  1420. }
  1421. pFriend = (CChatFriend*)pFriend->GetNext();
  1422. }
  1423. }
  1424. #endif
  1426. #ifdef _SERVER
  1427. //---------------------------------------------------------------------------
  1428. // 功能：再次删除某好友
  1429. //---------------------------------------------------------------------------
  1430. void KPlayerChat::RedeleteFriend(DWORD dwID, int nSelfIndex)
  1431. {
  1432. if( !CheckExist(dwID) )
  1433. {
  1434. int nIdx;
  1435. nIdx = PlayerSet.FindSame(dwID);
  1436. if (nIdx > 0)
  1437. Player[nIdx].m_cChat.DeleteFriendData(Player[nSelfIndex].m_dwID, nIdx);
  1438. }
  1439. }
  1440. #endif
  1442. #ifdef _SERVER
  1443. //---------------------------------------------------------------------------
  1444. // 功能：本玩家下线
  1445. //---------------------------------------------------------------------------
  1446. void KPlayerChat::OffLine(DWORD dwSelfID)
  1447. {
  1448. CChatFriend *pNode;
  1449. pNode = (CChatFriend*)m_cFriendTeam[0].m_cEveryOne.GetHead();
  1450. while (pNode)
  1451. {
  1452. if (pNode->m_nPlayerIdx)
  1453. {
  1454. Player[pNode->m_nPlayerIdx].m_cChat.GetMsgOffLine(dwSelfID, pNode->m_nPlayerIdx);
  1455. }
  1456. pNode = (CChatFriend*)pNode->GetNext();
  1457. }
  1458. }
  1459. #endif
  1461. #ifdef _SERVER
  1462. //---------------------------------------------------------------------------
  1463. // 功能：得到通知有好友下线
  1464. //---------------------------------------------------------------------------
  1465. void KPlayerChat::GetMsgOffLine(DWORD dwID, int nSelfIdx)
  1466. {
  1467. CChatFriend *pNode;
  1468. pNode = (CChatFriend*)m_cFriendTeam[0].m_cEveryOne.GetHead();
  1469. while (pNode)
  1470. {
  1471. if (pNode->m_nPlayerIdx && pNode->m_dwID == dwID)
  1472. {
  1473. pNode->m_nPlayerIdx = 0;
  1474. // 通知客户端
  1475. CHAT_FRIEND_OFFLINE_SYNC sSync;
  1476. sSync.ProtocolType = s2c_chatfriendoffline;
  1477. sSync.m_dwID = dwID;
  1478. g_pServer->PackDataToClient(Player[nSelfIdx].m_nNetConnectIdx, (BYTE*)&sSync, sizeof(CHAT_FRIEND_OFFLINE_SYNC));
  1479. return;
  1480. }
  1481. pNode = (CChatFriend*)pNode->GetNext();
  1482. }
  1483. }
  1484. #endif
  1486. #ifdef _SERVER
  1487. //---------------------------------------------------------------------------
  1488. // 功能：聊天时间计数加一
  1489. //---------------------------------------------------------------------------
  1490. void KPlayerChat::TimerAdd()
  1491. {
  1492. this->m_nTimer++;
  1493. }
  1494. #endif
  1496. #ifndef _SERVER
  1497. //---------------------------------------------------------------------------
  1498. // 功能：添加组，返回第几组，if return value == -1 失败
  1499. //---------------------------------------------------------------------------
  1500. int KPlayerChat::AddTeam(char *lpszPlayerName, char *lpszTeamName)
  1501. {
  1502. if (!lpszPlayerName || !lpszPlayerName[0])
  1503. return -1;
  1504. if (!lpszTeamName || !lpszTeamName[0])
  1505. return -1;
  1507. int i;
  1508. // 判断是否有同名组
  1509. for (i = 0; i < MAX_FRIEND_TEAM; i++)
  1510. {
  1511. if (strcmp(lpszTeamName, m_cFriendTeam[i].m_szTeamName) == 0)
  1512. {
  1513. KSystemMessage sMsg;
  1514. sprintf(sMsg.szMessage, MSG_CHAT_CREATE_TEAM_FAIL1);
  1515. sMsg.eType = SMT_NORMAL;
  1516. sMsg.byConfirmType = SMCT_NONE;
  1517. sMsg.byPriority = 0;
  1518. sMsg.byParamSize = 0;
  1519. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  1520. sprintf(sMsg.szMessage, MSG_CHAT_CREATE_TEAM_FAIL2);
  1521. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  1522. return -1;
  1523. }
  1524. }
  1526. // 第 0 组是默认拥有的组
  1527. for (i = 1; i < MAX_FRIEND_TEAM; i++)
  1528. {
  1529. if ( !m_cFriendTeam[i].m_szTeamName[0] && m_cFriendTeam[i].m_nFriendNo == 0)
  1530. {
  1531. g_StrCpy(m_cFriendTeam[i].m_szTeamName, lpszTeamName);
  1532. SaveTeamInfo(lpszPlayerName);
  1533. return i;
  1534. }
  1535. }
  1537. KSystemMessage sMsg;
  1538. sprintf(sMsg.szMessage, MSG_CHAT_CREATE_TEAM_FAIL1);
  1539. sMsg.eType = SMT_NORMAL;
  1540. sMsg.byConfirmType = SMCT_NONE;
  1541. sMsg.byPriority = 0;
  1542. sMsg.byParamSize = 0;
  1543. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  1544. sprintf(sMsg.szMessage, MSG_CHAT_CREATE_TEAM_FAIL3);
  1545. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  1546. return -1;
  1547. }
  1548. #endif
  1550. #ifndef _SERVER
  1551. //---------------------------------------------------------------------------
  1552. // 功能：组改名
  1553. //---------------------------------------------------------------------------
  1554. BOOL KPlayerChat::RenameTeam(int nTeamNo, char *lpszTeamName, char *lpszPlayerName)
  1555. {
  1556. if (!lpszPlayerName || !lpszPlayerName[0])
  1557. return FALSE;
  1558. if (!lpszTeamName || !lpszTeamName[0])
  1559. return FALSE;
  1560. if (nTeamNo < 1 || nTeamNo >= MAX_FRIEND_TEAM)
  1561. return FALSE;
  1562. if (!m_cFriendTeam[nTeamNo].m_szTeamName[0])
  1563. return FALSE;
  1564. if (strlen(lpszTeamName) >= sizeof(m_cFriendTeam[nTeamNo].m_szTeamName))
  1565. return FALSE;
  1567. int i;
  1568. // 判断是否有同名组
  1569. for (i = 0; i < MAX_FRIEND_TEAM; i++)
  1570. {
  1571. if (i == nTeamNo)
  1572. continue;
  1573. if (strcmp(lpszTeamName, m_cFriendTeam[i].m_szTeamName) == 0)
  1574. {
  1575. KSystemMessage sMsg;
  1576. sprintf(sMsg.szMessage, MSG_CHAT_RENAME_TEAM_FAIL);
  1577. sMsg.eType = SMT_NORMAL;
  1578. sMsg.byConfirmType = SMCT_NONE;
  1579. sMsg.byPriority = 0;
  1580. sMsg.byParamSize = 0;
  1581. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  1582. sprintf(sMsg.szMessage, MSG_CHAT_CREATE_TEAM_FAIL2);
  1583. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  1584. return FALSE;
  1585. }
  1586. }
  1588. g_StrCpy(m_cFriendTeam[nTeamNo].m_szTeamName, lpszTeamName);
  1589. SaveTeamInfo(lpszPlayerName);
  1591. return TRUE;
  1592. }
  1593. #endif
  1595. #ifndef _SERVER
  1596. //---------------------------------------------------------------------------
  1597. // 功能：删除组，返回成功与否
  1598. //---------------------------------------------------------------------------
  1599. BOOL KPlayerChat::DeleteTeam(int nTeamNo, char *lpszPlayerName)
  1600. {
  1601. if (!lpszPlayerName || !lpszPlayerName[0])
  1602. return FALSE;
  1603. if (nTeamNo == 0)
  1604. {
  1605. KSystemMessage sMsg;
  1606. sprintf(sMsg.szMessage, MSG_CHAT_DELETE_TEAM_FAIL1);
  1607. sMsg.eType = SMT_NORMAL;
  1608. sMsg.byConfirmType = SMCT_NONE;
  1609. sMsg.byPriority = 0;
  1610. sMsg.byParamSize = 0;
  1611. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  1612. sprintf(sMsg.szMessage, MSG_CHAT_DELETE_TEAM_FAIL2);
  1613. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  1614. return FALSE;
  1615. }
  1616. if (nTeamNo < 1 || nTeamNo >= MAX_FRIEND_TEAM)
  1617. return FALSE;
  1619. if (!this->m_cFriendTeam[nTeamNo].m_szTeamName[0])
  1620. return FALSE;
  1622. CChatFriend *pFriend;
  1623. pFriend = (CChatFriend*)m_cFriendTeam[nTeamNo].m_cEveryOne.GetHead();
  1624. while (pFriend)
  1625. {
  1626. m_cFriendTeam[nTeamNo].m_cEveryOne.RemoveHead();
  1627. m_cFriendTeam[0].m_cEveryOne.AddTail(pFriend);
  1628. m_cFriendTeam[0].m_nFriendNo++;
  1629. pFriend = (CChatFriend*)m_cFriendTeam[nTeamNo].m_cEveryOne.GetHead();
  1630. }
  1631. m_cFriendTeam[nTeamNo].m_szTeamName[0] = 0;
  1632. m_cFriendTeam[nTeamNo].m_nFriendNo = 0;
  1633. SaveTeamInfo(lpszPlayerName);
  1635. return TRUE;
  1636. }
  1637. #endif
  1639. #ifndef _SERVER
  1640. //---------------------------------------------------------------------------
  1641. // 功能：把一个好友从一个组移动到另一个组
  1642. //---------------------------------------------------------------------------
  1643. BOOL KPlayerChat::OneFriendChangeTeam(DWORD dwID, int nSrcTeam, int nDestTeam)
  1644. {
  1645. if (nSrcTeam < 0 || nSrcTeam >= MAX_FRIEND_TEAM)
  1646. return FALSE;
  1647. if (nDestTeam < 0 || nDestTeam >= MAX_FRIEND_TEAM)
  1648. return FALSE;
  1649. if ( !m_cFriendTeam[nDestTeam].m_szTeamName[0] )
  1650. return FALSE;
  1652. CChatFriend *pFriend;
  1653. pFriend = (CChatFriend*)m_cFriendTeam[nSrcTeam].m_cEveryOne.GetHead();
  1654. while (pFriend)
  1655. {
  1656. if (pFriend->m_dwID == dwID)
  1657. {
  1658. pFriend->Remove();
  1659. m_cFriendTeam[nSrcTeam].m_nFriendNo--;
  1660. m_cFriendTeam[nDestTeam].m_cEveryOne.AddTail(pFriend);
  1661. m_cFriendTeam[nDestTeam].m_nFriendNo++;
  1663. this->SaveTeamInfo(Npc[Player[CLIENT_PLAYER_INDEX].m_nIndex].Name);
  1665. return TRUE;
  1666. }
  1667. pFriend = (CChatFriend*)pFriend->GetNext();
  1668. }
  1670. return FALSE;
  1671. }
  1672. #endif
  1674. #ifndef _SERVER
  1675. //---------------------------------------------------------------------------
  1676. // 功能：得到通知有好友下线
  1677. //---------------------------------------------------------------------------
  1678. void KPlayerChat::GetMsgOffLine(DWORD dwID)
  1679. {
  1680. CChatFriend *pFriend;
  1681. for (int i = 0; i < MAX_FRIEND_TEAM; i++)
  1682. {
  1683. pFriend = (CChatFriend*)this->m_cFriendTeam[i].m_cEveryOne.GetHead();
  1684. while (pFriend)
  1685. {
  1686. if (pFriend->m_dwID == dwID)
  1687. {
  1688. pFriend->m_nPlayerIdx = 0;
  1689. // 通知界面有好友下线
  1690. KUiPlayerItem sPlayer;
  1691. strcpy(sPlayer.Name, pFriend->m_szName);
  1692. sPlayer.uId = dwID;
  1693. sPlayer.nIndex = 0;
  1694. sPlayer.nData = CHAT_S_DISCONNECT;
  1695. CoreDataChanged(GDCNI_CHAT_FRIEND_STATUS, (unsigned int)&sPlayer, i);
  1697. KSystemMessage sMsg;
  1698. sprintf(sMsg.szMessage, MSG_CHAT_FRIEND_OFFLINE, pFriend->m_szName);
  1699. sMsg.eType = SMT_NORMAL;
  1700. sMsg.byConfirmType = SMCT_NONE;
  1701. sMsg.byPriority = 0;
  1702. sMsg.byParamSize = 0;
  1703. CoreDataChanged(GDCNI_SYSTEM_MESSAGE, (unsigned int)&sMsg, 0);
  1705. return;
  1706. }
  1707. pFriend = (CChatFriend*)pFriend->GetNext();
  1708. }
  1709. }
  1710. }
  1711. #endif
  1713. #ifndef _SERVER
  1714. //---------------------------------------------------------------------------
  1715. // 功能：判断是否订阅了某个频道
  1716. //---------------------------------------------------------------------------
  1717. BOOL KPlayerChat::CheckTakeChannel(int nChannelNo)
  1718. {
  1719. if (nChannelNo < CHAT_CUR_CHANNEL_NONE || nChannelNo >= CHAT_CUR_CHANNEL_NUM)
  1720. return FALSE;
  1721. return (this->m_dwTakeChannel & g_dwChannelOr[nChannelNo]);
  1722. }
  1723. #endif
  1725. #ifndef _SERVER
  1726. //---------------------------------------------------------------------------
  1727. // 功能：客户端申请删除某好友
  1728. //---------------------------------------------------------------------------
  1729. void KPlayerChat::ApplyDeleteFriend(DWORD dwID, int nTeamNo, char *lpszSelfName)
  1730. {
  1731. if (!lpszSelfName || !lpszSelfName[0])
  1732. return;
  1733. if (nTeamNo < 0 || nTeamNo >= MAX_FRIEND_TEAM)
  1734. return;
  1735. CChatFriend *pFriend;
  1737. pFriend = (CChatFriend*)m_cFriendTeam[nTeamNo].m_cEveryOne.GetHead();
  1738. while (pFriend)
  1739. {
  1740. if (pFriend->m_dwID == dwID)
  1741. {
  1742. pFriend->Remove();
  1743. delete pFriend;
  1744. m_cFriendTeam[nTeamNo].m_nFriendNo--;
  1745. SaveTeamInfo(lpszSelfName);
  1747. CHAT_DELETE_FRIEND_COMMAND sDelete;
  1748. sDelete.ProtocolType = c2s_chatdeletefriend;
  1749. sDelete.m_dwID = dwID;
  1750. if (g_pClient)
  1751. g_pClient->SendPackToServer(&sDelete, sizeof(CHAT_DELETE_FRIEND_COMMAND));
  1753. // CoreDataChanged(GDCNI_CHAT_GROUP, 0, 0);
  1754. CoreDataChanged(GDCNI_CHAT_FRIEND, 0, nTeamNo);
  1756. return;
  1757. }
  1758. pFriend = (CChatFriend*)pFriend->GetNext();
  1759. }
  1761. }
  1762. #endif
  1764. BOOL KPlayerChat::CheckTalkChannel(int nChannel)
  1765. {
  1766. if (nChannel <= CHAT_CUR_CHANNEL_NONE || nChannel >= CHAT_CUR_CHANNEL_NUM)
  1767. return FALSE;
  1768. return (this->m_dwTakeChannel & g_dwChannelOr[nChannel]);
  1769. }
  1771. //---------------------------------------------------------------------------
  1772. // 功能：发送系统消息
  1773. //  nType == 0 给全体玩家发送 nType == 1 给某个特定玩家发送
  1774. //  dwTargetID:  if (nType == 1) 目标玩家在 player 数组中的位置
  1775. //  lpszSendName:  发送者名字，可能是 系统消息、通知、警告、注意 等等 长度不超过 32
  1776. //  lpszSentence:  需要发送的语句
  1777. //  nSentenceLength:  需要发送语句的长度
  1778. //---------------------------------------------------------------------------
  1779. #ifdef _SERVER
  1780. void KPlayerChat::SendSystemInfo(int nType, int nTargetIdx, char *lpszSendName, char *lpszSentence, int nSentenceLength)
  1781. {
  1782. if (!lpszSendName || !lpszSentence)
  1783. return;
  1784. if (nSentenceLength >= MAX_SENTENCE_LENGTH)
  1785. nSentenceLength = MAX_SENTENCE_LENGTH;
  1788. BOOL bAll = nType == 0;
  1791. size_t chatsize = sizeof(CHAT_CHANNELCHAT_SYNC) + nSentenceLength;
  1792. size_t pckgsize = sizeof(tagExtendProtoHeader) + chatsize;
  1794. #ifdef WIN32
  1795. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)_alloca(pckgsize);
  1796. #else
  1797. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)(new char[pckgsize]);
  1798. #endif
  1799. pExHeader->ProtocolType = s2c_extendchat;
  1800. pExHeader->wLength = pckgsize - 1;
  1802. CHAT_CHANNELCHAT_SYNC* pCccSync= (CHAT_CHANNELCHAT_SYNC*)(pExHeader + 1);
  1803. pCccSync->ProtocolType = chat_channelchat;
  1804. pCccSync->wSize = chatsize - 1;
  1805. pCccSync->packageID = -1;
  1806. strncpy(pCccSync->someone, lpszSendName, _NAME_LEN - 1); // 可能需要根据玩家身份改动
  1807. pCccSync->channelid = -1;
  1808. pCccSync->sentlen = nSentenceLength;
  1809. memcpy(pCccSync + 1, lpszSentence, nSentenceLength);
  1811. if (bAll) // 给全体玩家发送
  1812. {
  1813. int nTargetIdx;
  1814. nTargetIdx = PlayerSet.GetFirstPlayer();
  1815. while (nTargetIdx)
  1816. {
  1817. g_pServer->PackDataToClient(Player[nTargetIdx].m_nNetConnectIdx, pExHeader, pckgsize);
  1818. nTargetIdx = PlayerSet.GetNextPlayer();
  1819. }
  1820. }
  1821. else // 给某个特定玩家发送
  1822. {
  1823. if (nTargetIdx <= 0)
  1824. {
  1825. #ifndef WIN32
  1826. if (pExHeader)
  1827. delete ((char*)pExHeader);
  1828. #endif
  1829. return;
  1830. }
  1831. g_pServer->PackDataToClient(Player[nTargetIdx].m_nNetConnectIdx, pExHeader, pckgsize);
  1832. }
  1834. #ifndef WIN32
  1835. if (pExHeader)
  1836. delete ((char*)pExHeader);
  1837. #endif
  1838. return;
  1841. /*
  1842. if (!lpszSendName || !lpszSentence)
  1843. return;
  1844. if (nSentenceLength >= MAX_SENTENCE_LENGTH)
  1845. nSentenceLength = MAX_SENTENCE_LENGTH;
  1846. if (nType == 0) // 给全体玩家发送
  1847. {
  1848. PLAYER_SEND_CHAT_SYNC sChat;
  1849. sChat.ProtocolType = s2c_playersendchat;
  1850. sChat.m_btCurChannel = CHAT_CUR_CHANNEL_SYSTEM;
  1851. sChat.m_dwSourceID = 0; // 发送者的player id 可能需要根据玩家身份改动
  1852. sChat.m_btNameLen = strlen(lpszSendName);
  1853. if (sChat.m_btNameLen >= 32)
  1854. sChat.m_btNameLen = 31;
  1855. if (lpszPrefix && nPrefixLen > 0)
  1856. {
  1857. sChat.m_btChatPrefixLen = nPrefixLen;
  1858. if (sChat.m_btChatPrefixLen >= CHAT_MSG_PREFIX_MAX_LEN)
  1859. sChat.m_btChatPrefixLen = CHAT_MSG_PREFIX_MAX_LEN - 1;
  1860. }
  1861. else
  1862. {
  1863. sChat.m_btChatPrefixLen = 0;
  1864. }
  1865. sChat.m_wSentenceLen = nSentenceLength;
  1866. sChat.m_wLength = sizeof(PLAYER_SEND_CHAT_SYNC) - 1 - sizeof(sChat.m_szSentence) + sChat.m_btNameLen + sChat.m_btChatPrefixLen + sChat.m_wSentenceLen;
  1867. memcpy(&sChat.m_szSentence[0], lpszSendName, sChat.m_btNameLen); // 可能需要根据玩家身份改动
  1868. if (lpszPrefix)
  1869. memcpy(&sChat.m_szSentence[sChat.m_btNameLen], lpszPrefix, sChat.m_btChatPrefixLen);
  1870. memcpy(&sChat.m_szSentence[sChat.m_btNameLen + sChat.m_btChatPrefixLen], lpszSentence, sChat.m_wSentenceLen); // 可能需要根据玩家身份改动
  1871. int nTargetIdx;
  1872. nTargetIdx = PlayerSet.GetFirstPlayer();
  1873. while (nTargetIdx)
  1874. {
  1875. g_pServer->PackDataToClient(Player[nTargetIdx].m_nNetConnectIdx, (BYTE*)&sChat, sChat.m_wLength + 1);
  1876. nTargetIdx = PlayerSet.GetNextPlayer();
  1877. }
  1878. }
  1879. else // 给某个特定玩家发送
  1880. {
  1881. int nIdx;
  1882. nIdx = nTargetIdx;
  1883. // nIdx = PlayerSet.FindSame(dwTargetID);
  1884. if (nIdx <= 0)
  1885. return;
  1886. PLAYER_SEND_CHAT_SYNC sChat;
  1887. sChat.ProtocolType = s2c_playersendchat;
  1888. sChat.m_btCurChannel = CHAT_CUR_CHANNEL_SYSTEM;
  1889. sChat.m_dwSourceID = 0; // 发送者的player id 可能需要根据玩家身份改动
  1890. sChat.m_btNameLen = strlen(lpszSendName);
  1891. if (sChat.m_btNameLen >= 32)
  1892. sChat.m_btNameLen = 31;
  1893. if (lpszPrefix && nPrefixLen > 0)
  1894. {
  1895. sChat.m_btChatPrefixLen = nPrefixLen;
  1896. if (sChat.m_btChatPrefixLen >= CHAT_MSG_PREFIX_MAX_LEN)
  1897. sChat.m_btChatPrefixLen = CHAT_MSG_PREFIX_MAX_LEN - 1;
  1898. }
  1899. else
  1900. {
  1901. sChat.m_btChatPrefixLen = 0;
  1902. }
  1903. sChat.m_wSentenceLen = nSentenceLength;
  1904. sChat.m_wLength = sizeof(PLAYER_SEND_CHAT_SYNC) - 1 - sizeof(sChat.m_szSentence) + sChat.m_btNameLen + sChat.m_btChatPrefixLen + sChat.m_wSentenceLen;
  1905. memcpy(&sChat.m_szSentence[0], lpszSendName, sChat.m_btNameLen); // 可能需要根据玩家身份改动
  1906. if (lpszPrefix)
  1907. memcpy(&sChat.m_szSentence[sChat.m_btNameLen], lpszPrefix, sChat.m_btChatPrefixLen);
  1908. memcpy(&sChat.m_szSentence[sChat.m_btNameLen + sChat.m_btChatPrefixLen], lpszSentence, sChat.m_wSentenceLen); // 可能需要根据玩家身份改动
  1909. g_pServer->PackDataToClient(Player[nIdx].m_nNetConnectIdx, (BYTE*)&sChat, sChat.m_wLength + 1);
  1910. }
  1911. */
  1912. }
  1913. #endif
  1915. #ifdef _SERVER
  1916. void KPlayerChat::SendGlobalSystemInfo(char *lpszSendName, char *lpszSentence, int nSentenceLength)
  1917. {
  1918. if (!lpszSendName || !lpszSentence)
  1919. return;
  1920. if (nSentenceLength >= MAX_SENTENCE_LENGTH)
  1921. nSentenceLength = MAX_SENTENCE_LENGTH;
  1923. size_t chatsize = sizeof(CHAT_CHANNELCHAT_SYNC) + nSentenceLength;
  1924. size_t pckgsize = sizeof(tagExtendProtoHeader) + chatsize;
  1926. #ifdef WIN32
  1927. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)_alloca(pckgsize);
  1928. #else
  1929. tagExtendProtoHeader* pExHeader = (tagExtendProtoHeader*)(new char[pckgsize]);
  1930. #endif
  1931. pExHeader->ProtocolType = s2c_extendchat;
  1932. pExHeader->wLength = pckgsize - 1;
  1934. CHAT_CHANNELCHAT_SYNC* pCccSync= (CHAT_CHANNELCHAT_SYNC*)(pExHeader + 1);
  1935. pCccSync->ProtocolType = chat_channelchat;
  1936. pCccSync->wSize = chatsize - 1;
  1937. pCccSync->packageID = -1;
  1938. strncpy(pCccSync->someone, lpszSendName, _NAME_LEN - 1); // 可能需要根据玩家身份改动
  1939. pCccSync->channelid = -1;
  1940. pCccSync->sentlen = nSentenceLength;
  1941. memcpy(pCccSync + 1, lpszSentence, nSentenceLength);
  1943. g_NewProtocolProcess.BroadcastGlobal(pExHeader, pckgsize);
  1945. #ifndef WIN32
  1946. if (pExHeader)
  1947. delete ((char*)pExHeader);
  1948. #endif
  1949. }
  1950. #endif
  1952. #ifdef _SERVER
  1953. void KPlayerChat::SendInfoToGM(char *lpszAccName, char *lpszRoleName, char *lpszSentence, int nSentenceLength)
  1954. {
  1955. if (!lpszAccName ||
  1956. !lpszRoleName ||
  1957. !lpszSentence)
  1958. return;
  1959. if (nSentenceLength >= MAX_SENTENCE_LENGTH)
  1960. nSentenceLength = MAX_SENTENCE_LENGTH;
  1962. size_t chatsize = sizeof(CHAT_MSG_EX) + nSentenceLength;
  1963. size_t pckgsize = sizeof(RELAY_ASKWAY_DATA) + chatsize;
  1966. #ifdef WIN32
  1967. RELAY_ASKWAY_DATA* pExHeader = (RELAY_ASKWAY_DATA*)_alloca(pckgsize);
  1968. #else
  1969. RELAY_ASKWAY_DATA* pExHeader = (RELAY_ASKWAY_DATA*)(new char[pckgsize]);
  1970. #endif
  1971. pExHeader->ProtocolFamily = pf_relay;
  1972. pExHeader->ProtocolID = relay_c2c_askwaydata;
  1973. pExHeader->nFromIP = 0;
  1974. pExHeader->nFromRelayID = 0;
  1975. pExHeader->seekRelayCount = 0;
  1976. pExHeader->seekMethod = rm_gm;
  1977. pExHeader->wMethodDataLength = 0;
  1978. pExHeader->routeDateLength = chatsize;
  1980. CHAT_MSG_EX* pChatMsgEx= (CHAT_MSG_EX*)(pExHeader + 1);
  1981. pChatMsgEx->ProtocolFamily = pf_playercommunity;
  1982. pChatMsgEx->ProtocolID = playercomm_channelchat;
  1983. strcpy(pChatMsgEx->m_szSourceName, lpszRoleName);
  1984. strcpy(pChatMsgEx->m_szAccountName, lpszAccName);
  1985. pChatMsgEx->SentenceLength = nSentenceLength;
  1986. memcpy(pChatMsgEx + 1, lpszSentence, nSentenceLength);
  1988. g_NewProtocolProcess.PushMsgInTransfer(pExHeader, pckgsize);
  1990. #ifndef WIN32
  1991. if (pExHeader)
  1992. delete ((char*)pExHeader);
  1993. #endif
  1994. }
  1995. #endif
  1997. #ifdef _SERVER
  1998. void KPlayerChat::SendInfoToIP(DWORD nIP, DWORD nID, char *lpszAccName, char *lpszRoleName, char *lpszSentence, int nSentenceLength)
  1999. {
  2000. if (!lpszAccName ||
  2001. !lpszRoleName ||
  2002. !lpszSentence)
  2003. return;
  2004. if (nSentenceLength >= MAX_SENTENCE_LENGTH)
  2005. nSentenceLength = MAX_SENTENCE_LENGTH;
  2007. size_t chatsize = sizeof(CHAT_MSG_EX) + nSentenceLength;
  2008. size_t pckgsize = sizeof(RELAY_DATA) + chatsize;
  2011. #ifdef WIN32
  2012. RELAY_DATA* pExHeader = (RELAY_DATA*)_alloca(pckgsize);
  2013. #else
  2014. RELAY_DATA* pExHeader = (RELAY_DATA*)(new char[pckgsize]);
  2015. #endif
  2016. pExHeader->ProtocolFamily = pf_relay;
  2017. pExHeader->ProtocolID = relay_c2c_data;
  2018. pExHeader->nToIP = nIP;
  2019. pExHeader->nToRelayID = nID;
  2020. pExHeader->nFromIP = 0;
  2021. pExHeader->nFromRelayID = 0;
  2022. pExHeader->routeDateLength = chatsize;
  2024. CHAT_MSG_EX* pChatMsgEx= (CHAT_MSG_EX*)(pExHeader + 1);
  2025. pChatMsgEx->ProtocolFamily = pf_playercommunity;
  2026. pChatMsgEx->ProtocolID = playercomm_channelchat;
  2027. strcpy(pChatMsgEx->m_szSourceName, lpszRoleName);
  2028. strcpy(pChatMsgEx->m_szAccountName, lpszAccName);
  2029. pChatMsgEx->SentenceLength = nSentenceLength;
  2030. memcpy(pChatMsgEx + 1, lpszSentence, nSentenceLength);
  2032. g_NewProtocolProcess.PushMsgInTransfer(pExHeader, pckgsize);
  2034. #ifndef WIN32
  2035. if (pExHeader)
  2036. delete ((char*)pExHeader);
  2037. #endif
  2038. }
  2039. #endif
  2041. #ifdef _SERVER
  2042. #define BROTHER_UNITNAME "亲人n"
  2043. void KPlayerChat::MakeBrother(const STRINGLIST& brothers)
  2044. {
  2045. if (brothers.size() == 0)
  2046. return;
  2048. static const size_t max_packagesize = 1000;
  2049. char buffer[max_packagesize]; //max package size
  2050. size_t maxsize = max_packagesize - 1; //留个0的位置
  2051. size_t basesize = sizeof(FRIEND_ASSOCIATEBEVY);
  2053. FRIEND_ASSOCIATEBEVY* pGf = (FRIEND_ASSOCIATEBEVY*)(buffer);
  2054. pGf->ProtocolFamily = pf_friend;
  2055. pGf->ProtocolID = friend_c2s_associatebevy;
  2057. int nG = strlen(BROTHER_UNITNAME) + 1;
  2058. strcpy(buffer + basesize, BROTHER_UNITNAME);
  2059. basesize += nG;
  2061. size_t cursor = basesize;
  2063. for (STRINGLIST::const_iterator itFriend = brothers.begin(); itFriend != brothers.end(); itFriend++)
  2064. {
  2065. std::string dst = *itFriend;
  2066. size_t appendsize = dst.size() + 1;
  2068. if (cursor + appendsize > maxsize)
  2069. {
  2070. buffer[cursor++] = specOver; //加个结尾,发走
  2072. g_NewProtocolProcess.PushMsgInTong(buffer, cursor);
  2074. cursor = basesize; //从头开始
  2075. }
  2077. strcpy(buffer + cursor, dst.c_str());
  2078. cursor += appendsize;
  2079. }
  2081. if (cursor > basesize)
  2082. {
  2083. buffer[cursor++] = specOver;
  2085. g_NewProtocolProcess.PushMsgInTong(buffer, cursor);
  2086. }
  2087. }
  2088. #endif
  2090. #ifdef _SERVER
  2091. #define ENEMY_UNITNAME  "仇人n"
  2092. void KPlayerChat::MakeEnemy(char* szPlayer, char* szEnemy)
  2093. {
  2094. if (!szPlayer || szPlayer[0] == 0 ||
  2095. !szEnemy || szEnemy[0] == 0)
  2096. return;
  2098. int nG = strlen(ENEMY_UNITNAME) + 1;
  2099. int nP = strlen(szPlayer) + 1;
  2100. int nE = strlen(szEnemy) + 1;
  2101. size_t fsize = sizeof(FRIEND_ASSOCIATE) + nG + nP + nE;
  2103. #ifdef WIN32
  2104. FRIEND_ASSOCIATE* pCccSync = (FRIEND_ASSOCIATE*)_alloca(fsize);
  2105. #else
  2106. FRIEND_ASSOCIATE* pCccSync = (FRIEND_ASSOCIATE*)(new char[fsize]);
  2107. #endif
  2108. pCccSync->ProtocolFamily = pf_friend;
  2109. pCccSync->ProtocolID = friend_c2s_associate;
  2110. pCccSync->bidir = 0;
  2111. char* pBuf = (char*)(pCccSync + 1);
  2112. strcpy(pBuf, ENEMY_UNITNAME);
  2113. pBuf += nG;
  2114. strcpy(pBuf, szPlayer);
  2115. pBuf += nP;
  2116. strcpy(pBuf, szEnemy);
  2117. pBuf += nE;
  2119. g_NewProtocolProcess.PushMsgInTong(pCccSync, fsize);
  2121. #ifndef WIN32
  2122. if (pCccSync)
  2123. delete ((char*)pCccSync);
  2124. #endif
  2125. }
  2126. #endif
  2128. #ifndef _SERVER
  2129. //---------------------------------------------------------------------------
  2130. // 功能：发送可选择聊天频道列表给界面
  2131. //---------------------------------------------------------------------------
  2132. int KPlayerChat::SendSelectChannelList(KUiChatChannel *pList, int nCount)
  2133. {
  2134. // 根据玩家不同的身份作不同的处理 not end
  2136. int i, nTempCount = 0;
  2137. // 目前开放大部分功能
  2138. if (!pList || nCount <= 0)
  2139. {
  2140. for (i = CHAT_CUR_CHANNEL_NONE + 1; i < CHAT_CUR_CHANNEL_NUM; i++)
  2141. {
  2142. switch (i)
  2143. {
  2144. case CHAT_CUR_CHANNEL_ALL:
  2145. // 一般人不能使用这个频道
  2146. // nTempCount++;
  2147. break;
  2148. case CHAT_CUR_CHANNEL_SCREEN:
  2149. // 这个频道始终开放
  2150. nTempCount++;
  2151. break;
  2152. case CHAT_CUR_CHANNEL_SINGLE:
  2153. // QQ聊天使用，不用于选择
  2154. break;
  2155. case CHAT_CUR_CHANNEL_TEAM:
  2156. // 组对才可以选
  2157. if (Player[CLIENT_PLAYER_INDEX].m_cTeam.m_nFlag)
  2158. nTempCount++;
  2159. break;
  2160. case CHAT_CUR_CHANNEL_FACTION:
  2161. // 一般人不能使用这个频道
  2162. nTempCount++;
  2163. break;
  2164. case CHAT_CUR_CHANNEL_TONG:
  2165. // 帮派目前还没有
  2166. break;
  2167. case CHAT_CUR_CHANNEL_SCREENSINGLE:
  2168. // 这个频道不是用来选择的，通过别的操作自动选定
  2169. break;
  2170. case CHAT_CUR_CHANNEL_SYSTEM:
  2171. // 服务器使用，客户端不提供
  2172. break;
  2173. default:
  2174. break;
  2175. }
  2176. }
  2177. return nTempCount;
  2178. }
  2180. for (i = CHAT_CUR_CHANNEL_NONE + 1; i < CHAT_CUR_CHANNEL_NUM; i++)
  2181. {
  2182. if (nTempCount >= nCount)
  2183. break;
  2184. switch (i)
  2185. {
  2186. case CHAT_CUR_CHANNEL_ALL:
  2187. // 一般人不能使用这个频道
  2188. /*
  2189. pList[nTempCount].nChannelNo = CHAT_CUR_CHANNEL_ALL;
  2190. pList[nTempCount].uChannelId = 0;
  2191. pList[nTempCount].nChannelIndex = 0;
  2192. memset(pList[nTempCount].cTitle, 0, sizeof(pList[nTempCount].cTitle));
  2193. strcpy(pList[nTempCount].cTitle, CHAT_CHANNEL_NAME_ALL);
  2194. nTempCount++;
  2195. */
  2196. break;
  2197. case CHAT_CUR_CHANNEL_SCREEN:
  2198. // 这个频道始终开放
  2199. pList[nTempCount].nChannelNo = CHAT_CUR_CHANNEL_SCREEN;
  2200. pList[nTempCount].uChannelId = 0;
  2201. pList[nTempCount].nChannelIndex = 0;
  2202. memset(pList[nTempCount].cTitle, 0, sizeof(pList[nTempCount].cTitle));
  2203. strcpy(pList[nTempCount].cTitle, CHAT_CHANNEL_NAME_SCREEN);
  2204. nTempCount++;
  2205. break;
  2206. case CHAT_CUR_CHANNEL_SINGLE:
  2207. // QQ聊天使用，不用于选择
  2208. break;
  2209. case CHAT_CUR_CHANNEL_TEAM:
  2210. // 组队才可以选
  2211. if (Player[CLIENT_PLAYER_INDEX].m_cTeam.m_nFlag)
  2212. {
  2213. pList[nTempCount].nChannelNo = CHAT_CUR_CHANNEL_TEAM;
  2214. pList[nTempCount].uChannelId = 0;
  2215. pList[nTempCount].nChannelIndex = 0;
  2216. memset(pList[nTempCount].cTitle, 0, sizeof(pList[nTempCount].cTitle));
  2217. strcpy(pList[nTempCount].cTitle, CHAT_CHANNEL_NAME_TEAM);
  2218. nTempCount++;
  2219. }
  2220. break;
  2221. case CHAT_CUR_CHANNEL_FACTION:
  2222. // 一般人不能使用这个频道
  2223. if (Player[CLIENT_PLAYER_INDEX].m_cFaction.GetCurFactionNo() >= 0)
  2224. {
  2225. pList[nTempCount].nChannelNo = CHAT_CUR_CHANNEL_FACTION;
  2226. pList[nTempCount].uChannelId = 0;
  2227. pList[nTempCount].nChannelIndex = 0;
  2228. memset(pList[nTempCount].cTitle, 0, sizeof(pList[nTempCount].cTitle));
  2229. strcpy(pList[nTempCount].cTitle, CHAT_CHANNEL_NAME_FACTION);
  2230. nTempCount++;
  2231. }
  2232. break;
  2233. case CHAT_CUR_CHANNEL_TONG:
  2234. // 帮派目前还没有
  2235. break;
  2236. case CHAT_CUR_CHANNEL_SCREENSINGLE:
  2237. // 这个频道不是用来选择的，通过别的操作自动选定
  2238. break;
  2239. case CHAT_CUR_CHANNEL_SYSTEM:
  2240. // 服务器使用，客户端不提供
  2241. break;
  2242. default:
  2243. break;
  2244. }
  2245. }
  2246. if (nTempCount < nCount)
  2247. memset(&pList[nTempCount], 0, sizeof(KUiChatChannel) * (nCount - nTempCount));
  2249. return nTempCount;
  2250. }
  2251. #endif
  2253. #ifndef _SERVER
  2254. //---------------------------------------------------------------------------
  2255. // 功能：发送可订阅聊天频道列表给界面
  2256. //---------------------------------------------------------------------------
  2257. int KPlayerChat::SendTakeChannelList(KUiChatChannel *pList, int nCount)
  2258. {
  2259. // 根据玩家身份的不同作不同的处理 not end
  2261. int i, nTempCount = 0;
  2262. // 目前开放大部分功能
  2263. if (!pList || nCount <= 0)
  2264. {
  2265. for (i = CHAT_CUR_CHANNEL_NONE + 1; i < CHAT_CUR_CHANNEL_NUM; i++)
  2266. {
  2267. switch (i)
  2268. {
  2269. case CHAT_CUR_CHANNEL_ALL:
  2270. // 这个频道默认订阅，不能取消
  2271. break;
  2272. case CHAT_CUR_CHANNEL_SCREEN:
  2273. // 这个频道默认订阅，不能取消
  2274. break;
  2275. case CHAT_CUR_CHANNEL_SINGLE:
  2276. // QQ聊天使用，默认订阅，不能取消
  2277. break;
  2278. case CHAT_CUR_CHANNEL_TEAM:
  2279. // 这个频道如果订阅了，只有在组队情况下才起作用
  2280. nTempCount++;
  2281. break;
  2282. case CHAT_CUR_CHANNEL_FACTION:
  2283. // 这个频道如果订阅了，只有在门派中才起作用
  2284. nTempCount++;
  2285. break;
  2286. case CHAT_CUR_CHANNEL_TONG:
  2287. // 帮派目前还没有
  2288. break;
  2289. case CHAT_CUR_CHANNEL_SCREENSINGLE:
  2290. // 这个频道如果不订阅，别人就无法直接在屏幕内联系你
  2291. nTempCount++;
  2292. break;
  2293. case CHAT_CUR_CHANNEL_SYSTEM:
  2294. // 服务器使用，默认订阅，不能取消
  2295. break;
  2296. default:
  2297. break;
  2298. }
  2299. }
  2300. return nTempCount;
  2301. }
  2303. for (i = CHAT_CUR_CHANNEL_NONE + 1; i < CHAT_CUR_CHANNEL_NUM; i++)
  2304. {
  2305. if (nTempCount >= nCount)
  2306. break;
  2307. switch (i)
  2308. {
  2309. case CHAT_CUR_CHANNEL_ALL:
  2310. // 这个频道默认订阅，不能取消
  2311. break;
  2312. case CHAT_CUR_CHANNEL_SCREEN:
  2313. // 这个频道默认订阅，不能取消
  2314. break;
  2315. case CHAT_CUR_CHANNEL_SINGLE:
  2316. // QQ聊天使用，默认订阅，不能取消
  2317. break;
  2318. case CHAT_CUR_CHANNEL_TEAM:
  2319. pList[nTempCount].nChannelNo = i;
  2320. pList[nTempCount].uChannelId = 0;
  2321. pList[nTempCount].nChannelIndex = this->CheckTakeChannel(i);
  2322. memset(pList[nTempCount].cTitle, 0, sizeof(pList[nTempCount].cTitle));
  2323. strcpy(pList[nTempCount].cTitle, CHAT_TAKE_CHANNEL_NAME_TEAM);
  2324. nTempCount++;
  2325. break;
  2326. case CHAT_CUR_CHANNEL_FACTION:
  2327. pList[nTempCount].nChannelNo = i;
  2328. pList[nTempCount].uChannelId = 0;
  2329. pList[nTempCount].nChannelIndex = this->CheckTakeChannel(i);
  2330. memset(pList[nTempCount].cTitle, 0, sizeof(pList[nTempCount].cTitle));
  2331. strcpy(pList[nTempCount].cTitle, CHAT_TAKE_CHANNEL_NAME_FACTION);
  2332. nTempCount++;
  2333. break;
  2334. case CHAT_CUR_CHANNEL_TONG:
  2335. // 帮派目前还没有
  2336. break;
  2337. case CHAT_CUR_CHANNEL_SCREENSINGLE:
  2338. pList[nTempCount].nChannelNo = i;
  2339. pList[nTempCount].uChannelId = 0;
  2340. pList[nTempCount].nChannelIndex = this->CheckTakeChannel(i);
  2341. memset(pList[nTempCount].cTitle, 0, sizeof(pList[nTempCount].cTitle));
  2342. strcpy(pList[nTempCount].cTitle, CHAT_TAKE_CHANNEL_NAME_SCREENSINGLE);
  2343. nTempCount++;
  2344. break;
  2345. case CHAT_CUR_CHANNEL_SYSTEM:
  2346. // 服务器使用，默认订阅，不能取消
  2347. break;
  2348. default:
  2349. break;
  2350. }
  2351. }
  2352. if (nTempCount < nCount)
  2353. memset(&pList[nTempCount], 0, sizeof(KUiChatChannel) * (nCount - nTempCount));
  2355. return nTempCount;
  2356. }
  2357. #endif
  2359. #ifndef _SERVER
  2360. //---------------------------------------------------------------------------
  2361. // 功能：获得当前使用聊天频道信息
  2362. //---------------------------------------------------------------------------
  2363. int KPlayerChat::GetCurChannel(KUiChatChannel *pList)
  2364. {
  2365. if (!pList)
  2366. return FALSE;
  2367. pList->nChannelNo = this->m_nCurChannel;
  2368. pList->uChannelId = this->m_dwTargetID;
  2369. pList->nChannelIndex = this->m_nTargetIdx;
  2370. switch (m_nCurChannel)
  2371. {
  2372. case CHAT_CUR_CHANNEL_ALL:
  2373. strcpy(pList->cTitle, CHAT_CHANNEL_NAME_ALL);
  2374. break;
  2375. case CHAT_CUR_CHANNEL_SCREEN:
  2376. strcpy(pList->cTitle, CHAT_CHANNEL_NAME_SCREEN);
  2377. break;
  2378. case CHAT_CUR_CHANNEL_SINGLE:
  2379. strcpy(pList->cTitle, CHAT_CHANNEL_NAME_SINGLE);
  2380. break;
  2381. case CHAT_CUR_CHANNEL_TEAM:
  2382. strcpy(pList->cTitle, CHAT_CHANNEL_NAME_TEAM);
  2383. break;
  2384. case CHAT_CUR_CHANNEL_FACTION:
  2385. strcpy(pList->cTitle, CHAT_CHANNEL_NAME_FACTION);
  2386. break;
  2387. case CHAT_CUR_CHANNEL_TONG:
  2388. strcpy(pList->cTitle, CHAT_CHANNEL_NAME_TONG);
  2389. break;
  2390. case CHAT_CUR_CHANNEL_SCREENSINGLE:
  2391. {
  2392. int nIdx;
  2393. nIdx = NpcSet.SearchID(this->m_dwTargetID);
  2394. if (nIdx > 0)
  2395. {
  2396. strcpy(pList->cTitle, Npc[nIdx].Name);
  2397. }
  2398. else
  2399. {
  2400. strcpy(pList->cTitle, CHAT_CHANNEL_NAME_SCREENSINGLE);
  2401. }
  2402. }
  2403. break;
  2404. case CHAT_CUR_CHANNEL_SYSTEM:
  2405. strcpy(pList->cTitle, CHAT_CHANNEL_NAME_SYSTEM);
  2406. break;
  2407. }
  2408. return TRUE;
  2409. }
  2410. #endif
  2412. #ifndef _SERVER
  2413. //---------------------------------------------------------------------------
  2414. // 功能：获得某个分组信息，返回下一个有效组编号(如果是最后一个有效组，返回-1)
  2415. //---------------------------------------------------------------------------
  2416. int KPlayerChat::IGetTeamInfo(int nTeamNo, KUiChatGroupInfo *psTeamInfo)
  2417. {
  2418. if (nTeamNo < 0 || nTeamNo >= MAX_FRIEND_TEAM || !psTeamInfo)
  2419. return -1;
  2421. for (int i = nTeamNo; i < MAX_FRIEND_TEAM; i++)
  2422. {
  2423. if (m_cFriendTeam[i].m_szTeamName[0])
  2424. {
  2425. strcpy(psTeamInfo->szTitle, this->m_cFriendTeam[i].m_szTeamName);
  2426. psTeamInfo->nNumFriend = this->m_cFriendTeam[i].m_nFriendNo;
  2427. return i;
  2428. }
  2429. }
  2430. return -1;
  2431. }
  2432. #endif
  2434. #ifndef _SERVER
  2435. //---------------------------------------------------------------------------
  2436. // 功能：获得某个分组的所有成员的信息
  2437. //---------------------------------------------------------------------------
  2438. int KPlayerChat::IGetTeamFriendInfo(int nTeamNo, KUiPlayerItem *pList)
  2439. {
  2440. if (nTeamNo < 0 || nTeamNo >= MAX_FRIEND_TEAM || !pList)
  2441. return 0;
  2442. if (!m_cFriendTeam[nTeamNo].m_szTeamName[0] || m_cFriendTeam[nTeamNo].m_nFriendNo <= 0)
  2443. return 0;
  2445. int nRet = 0;
  2446. CChatFriend *pNode = NULL;
  2447. pNode = (CChatFriend*)m_cFriendTeam[nTeamNo].m_cEveryOne.GetHead();
  2448. while (pNode)
  2449. {
  2450. strcpy(pList[nRet].Name, pNode->m_szName);
  2451. if (pNode->m_nPlayerIdx)
  2452. pList[nRet].nData = CHAT_S_ONLINE;
  2453. else
  2454. pList[nRet].nData = CHAT_S_DISCONNECT;
  2455. pList[nRet].nIndex = pNode->m_nPlayerIdx;
  2456. pList[nRet].uId = pNode->m_dwID;
  2458. pNode = (CChatFriend*)pNode->GetNext();
  2460. nRet++;
  2461. }
  2463. return nRet;
  2464. }
  2465. #endif
  2471. //---------------------------------------------------------------------------
  2472. // 功能：构造函数
  2473. //---------------------------------------------------------------------------
  2474. CChatFriendTeam::CChatFriendTeam()
  2475. {
  2476. m_nFriendNo = 0;
  2477. memset(m_szTeamName, 0, 32);
  2478. }
  2480. //---------------------------------------------------------------------------
  2481. // 功能：清空
  2482. //---------------------------------------------------------------------------
  2483. void CChatFriendTeam::Release()
  2484. {
  2485. m_nFriendNo = 0;
  2486. memset(m_szTeamName, 0, 32);
  2487. CChatFriend *pFriend = NULL;
  2488. pFriend = (CChatFriend*)m_cEveryOne.GetHead();
  2489. while (pFriend)
  2490. {
  2491. m_cEveryOne.RemoveHead();
  2492. delete pFriend;
  2493. pFriend = (CChatFriend*)m_cEveryOne.GetHead();
  2494. }
  2495. }
  2497. #ifdef _SERVER
  2498. //---------------------------------------------------------------------------
  2499. // 功能：玩家登陆的时候从数据库获得数据时专用
  2500. //---------------------------------------------------------------------------
  2501. void CChatFriendTeam::DataBaseAddOne(int nSelfIdx, DWORD dwID, char *lpszName)
  2502. {
  2503. if (!lpszName || !lpszName[0])
  2504. return;
  2506. // 判断好友是否在线
  2507. CChatFriend *pFriend = NULL;
  2508. pFriend = new CChatFriend;
  2509. if ( !pFriend )
  2510. return;
  2511. pFriend->m_dwID = dwID;
  2512. pFriend->m_nPlayerIdx = PlayerSet.FindSame(dwID);
  2513. g_StrCpy(pFriend->m_szName, lpszName);
  2514. m_cEveryOne.AddTail(pFriend);
  2515. m_nFriendNo++;
  2517. // 通知好友自己上线了
  2518. if (pFriend->m_nPlayerIdx > 0)
  2519. Player[pFriend->m_nPlayerIdx].ChatFriendOnLine(Player[nSelfIdx].m_dwID, nSelfIdx);
  2520. }
  2521. #endif
  2523. #ifndef _SERVER
  2524. void KCHAT_RECORDER::SetTime()
  2525. {
  2526. SYSTEMTIME sTime;
  2527. GetLocalTime(&sTime);
  2528. sprintf(m_szDay, "%04d.%02d.%02d", sTime.wYear, sTime.wMonth, sTime.wDay);
  2529. sprintf(m_szTime, "%02d:%02d:%02d", sTime.wHour, sTime.wMinute, sTime.wSecond);
  2530. }
  2532. void KCHAT_RECORDER::SaveSentenceSingle(char *lpszSelfName, char *lpszTarget, char *lpszTalkerName, char *lpszSentence)
  2533. {
  2534. // 暂时关闭
  2535. return;
  2537. if (!lpszSelfName || !lpszTarget || !lpszTalkerName || !lpszSentence)
  2538. return;
  2539. if (!lpszSelfName[0] || !lpszTarget[0] || !lpszTalkerName[0] || !lpszSentence[0])
  2540. return;
  2542. // 产生出相应路径
  2543. char szPath[MAX_PATH], szBuf[MAX_PATH], szName[MAX_PATH];
  2544. g_StrCpy(szPath, CHAT_PATH);
  2545. g_StrCat(szPath, "\");
  2546. g_StrCat(szPath, lpszSelfName);
  2547. g_CreatePath(szPath);
  2548. // g_SetFilePath(szPath);
  2550. SetTime();
  2552. KFile cFile;
  2553. sprintf(szName, "%s.rcd", lpszTarget);
  2554. g_UnitePathAndName(szPath, szName, szBuf);
  2555. if ( !cFile.Append(szBuf) )
  2556. return;
  2557. cFile.Write(m_szDay, sizeof(m_szDay) - 1);
  2558. cFile.Write("  ", 2);
  2559. cFile.Write(this->m_szTime, sizeof(m_szTime) - 1);
  2560. cFile.Write("  ", 2);
  2561. cFile.Write(lpszTalkerName, strlen(lpszTalkerName));
  2562. cFile.Write("rn", 1);
  2563. if (strlen(lpszSentence) < MAX_SENTENCE_LENGTH)
  2564. cFile.Write(lpszSentence, strlen(lpszSentence));
  2565. else
  2566. cFile.Write(lpszSentence, MAX_SENTENCE_LENGTH - 1);
  2567. cFile.Write("rn", 1);
  2568. cFile.Close();
  2569. }
  2571. void KCHAT_RECORDER::SaveSentenceChannel(char *lpszSelfName, char *lpszTalkerName, char *lpszSentence)
  2572. {
  2573. // 暂时关闭
  2574. return;
  2576. if (!lpszSelfName || !lpszTalkerName || !lpszSentence)
  2577. return;
  2578. if (!lpszSelfName[0] || !lpszTalkerName[0] || !lpszSentence[0])
  2579. return;
  2581. SetTime();
  2582. m_szDay[4] = '_';
  2583. m_szDay[7] = '_';
  2585. // 产生出相应路径
  2586. char szPath[MAX_PATH], szName[MAX_PATH], szBuf[MAX_PATH];
  2587. g_StrCpy(szPath, CHAT_PATH);
  2588. g_StrCat(szPath, "\");
  2589. g_StrCat(szPath, lpszSelfName);
  2590. g_StrCat(szPath, "\");
  2591. g_StrCat(szPath, m_szDay);
  2592. g_CreatePath(szPath);
  2593. // g_SetFilePath(szPath);
  2595. sprintf(szName, "%s.rcd", m_szDay);
  2596. g_UnitePathAndName(szPath, szName, szBuf);
  2597. KFile cFile;
  2598. if ( !cFile.Append(szBuf) )
  2599. return;
  2600. cFile.Write(m_szTime, sizeof(m_szTime) - 1);
  2601. cFile.Write("  ", 2);
  2602. cFile.Write(lpszTalkerName, strlen(lpszTalkerName));
  2603. cFile.Write("rn", 1);
  2604. if (strlen(lpszSentence) < MAX_SENTENCE_LENGTH)
  2605. cFile.Write(lpszSentence, strlen(lpszSentence));
  2606. else
  2607. cFile.Write(lpszSentence, MAX_SENTENCE_LENGTH - 1);
  2608. cFile.Write("rn", 1);
  2609. cFile.Close();
  2610. }
  2611. #endif