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

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

模拟服务器

开发平台：

C/C++

TongConnect.cpp：源码内容
  1. // TongConnect.cpp: implementation of the CTongConnect class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "TongConnect.h"
  7. #include "TongServer.h"
  8. #include "S3Relay.h"
  9. #include "Global.h"
  10. #include "malloc.h"
  13. //-------------------------- tong struct size ---------------------------
  14. int g_nTongPSSize[defTONG_PROTOCOL_SERVER_NUM] = 
  15. {
  16. -1, // enumC2S_TONG_CREATE
  17. -1, // enumC2S_TONG_ADD_MEMBER
  18. sizeof(STONG_GET_TONG_HEAD_INFO_COMMAND), // enumC2S_TONG_GET_HEAD_INFO
  19. sizeof(STONG_GET_MANAGER_INFO_COMMAND), // enumC2S_TONG_GET_MANAGER_INFO
  20. sizeof(STONG_GET_MEMBER_INFO_COMMAND), // enumC2S_TONG_GET_MEMBER_INFO
  21. sizeof(STONG_INSTATE_COMMAND), // enumC2S_TONG_INSTATE
  22. sizeof(STONG_KICK_COMMAND), // enumC2S_TONG_KICK
  23. sizeof(STONG_LEAVE_COMMAND), // enumC2S_TONG_LEAVE
  24. sizeof(STONG_CHANGE_MASTER_COMMAND), // enumC2S_TONG_CHANGE_MASTER
  25. sizeof(STONG_ACCEPT_MASTER_COMMAND), // enumC2S_TONG_ACCEPT_MASTER
  26. sizeof(STONG_GET_LOGIN_DATA_COMMAND), // enumC2S_TONG_GET_LOGIN_DATA
  27. };
  29. //------------------------- tong struct size end ---------------------------
  32. //////////////////////////////////////////////////////////////////////
  33. // Construction/Destruction
  34. //////////////////////////////////////////////////////////////////////
  36. CTongConnect::CTongConnect(CTongServer* pTongServer, unsigned long id)
  37. : CNetConnect(pTongServer, id)
  38. {
  40. }
  42. CTongConnect::~CTongConnect()
  43. {
  45. }
  48. void CTongConnect::OnClientConnectCreate()
  49. {
  50. rTRACE("tong connect create: %s", _ip2a(GetIP()));
  51. }
  53. void CTongConnect::OnClientConnectClose()
  54. {
  55. rTRACE("tong connect close: %s", _ip2a(GetIP()));
  56. }
  59. void CTongConnect::RecvPackage(const void* pData, size_t size)
  60. {
  61. EXTEND_HEADER* pHeader = (EXTEND_HEADER*)pData;
  63. if (pHeader->ProtocolFamily == pf_tong)
  64. {
  65. Proc0_Tong(pData, size);
  66. }
  67. else if (pHeader->ProtocolFamily == pf_friend)
  68. {
  69. Proc0_Friend(pData, size);
  70. }
  71. }
  74. BOOL CTongConnect::PassToSomeone(DWORD ip, unsigned long id, DWORD nameid, const void* pData, size_t size)
  75. {
  76. CNetConnectDup conndup;
  77. if (GetIP() == ip)
  78. conndup = *this;
  79. else
  80. {
  81. conndup = g_TongServer.FindTongConnectByIP(ip);
  82. if (!conndup.IsValid())
  83. return FALSE;
  84. }
  86. size_t pckgsize = sizeof(EXTEND_PASSTOSOMEONE) + size;
  87. EXTEND_PASSTOSOMEONE* pEps = (EXTEND_PASSTOSOMEONE*)_alloca(pckgsize);
  88. pEps->ProtocolFamily = pf_extend;
  89. pEps->ProtocolID = extend_s2c_passtosomeone;
  90. pEps->nameid = nameid;
  91. pEps->lnID = id;
  92. pEps->datasize = size;
  93. memcpy(pEps + 1, pData, size);
  95. conndup.SendPackage(pEps, pckgsize);
  97. return TRUE;
  98. }
  100. //--------------------------------------------------------------------
  101. // 功能：帮会协议处理，收到 game server 发来的与帮会有关的协议
  102. //--------------------------------------------------------------------
  103. void CTongConnect::Proc0_Tong(const void* pData, size_t size)
  104. {
  105. if (!pData)
  106. return;
  108. // 协议长度检测
  109. if (size < sizeof(EXTEND_HEADER))
  110. return;
  111. EXTEND_HEADER* pHeader = (EXTEND_HEADER*)pData;
  112. if (pHeader->ProtocolID >= enumC2S_TONG_NUM)
  113. return;
  114. if (g_nTongPSSize[pHeader->ProtocolID] < 0)
  115. {
  116. if (size <= sizeof(EXTEND_HEADER) + 2)
  117. return;
  118. WORD wLength = *((WORD*)((BYTE*)pData + sizeof(EXTEND_HEADER)));
  119. if (wLength != size)
  120. return;
  121. }
  122. else if (g_nTongPSSize[pHeader->ProtocolID] != size)
  123. {
  124. return;
  125. }
  127. switch (pHeader->ProtocolID)
  128. {
  129. case enumC2S_TONG_CREATE:
  130. {
  131. char szPlayerName[64], szTongName[64];
  132. STONG_CREATE_COMMAND *pTongCreate = (STONG_CREATE_COMMAND*)pData;
  133. int nCamp = pTongCreate->m_btCamp;
  135. memcpy(szTongName, &pTongCreate->m_szBuffer[0], pTongCreate->m_btTongNameLength);
  136. szTongName[pTongCreate->m_btTongNameLength] = 0;
  137. memcpy(szPlayerName, &pTongCreate->m_szBuffer[pTongCreate->m_btTongNameLength], pTongCreate->m_btPlayerNameLength);
  138. szPlayerName[pTongCreate->m_btPlayerNameLength] = 0;
  140. // 建立帮会
  141. int nErrorID = g_cTongSet.Create(nCamp, szPlayerName, szTongName);
  142. if (nErrorID == 0)
  143. {
  144. STONG_CREATE_SUCCESS_SYNC sSync;
  145. sSync.ProtocolFamily = pf_tong;
  146. sSync.ProtocolID = enumS2C_TONG_CREATE_SUCCESS;
  147. sSync.m_dwPlayerNameID = pTongCreate->m_dwPlayerNameID;
  148. sSync.m_dwParam = pTongCreate->m_dwParam;
  149. sSync.m_btCamp = pTongCreate->m_btCamp;
  150. sSync.m_btTongNameLength = pTongCreate->m_btTongNameLength;
  151. memcpy(sSync.m_szTongName, pTongCreate->m_szBuffer, sSync.m_btTongNameLength);
  152. sSync.m_wLength = sizeof(STONG_CREATE_SUCCESS_SYNC) - sizeof(sSync.m_szTongName) + sSync.m_btTongNameLength;
  154. this->SendPackage((const void *)&sSync, sSync.m_wLength);
  155. }
  156. // 建立失败
  157. else
  158. {
  159. STONG_CREATE_FAIL_SYNC sSync;
  160. sSync.ProtocolFamily = pf_tong;
  161. sSync.ProtocolID = enumS2C_TONG_CREATE_FAIL;
  162. sSync.m_dwPlayerNameID = pTongCreate->m_dwPlayerNameID;
  163. sSync.m_dwParam = pTongCreate->m_dwParam;
  164. sSync.m_btFailID = nErrorID;
  166. this->SendPackage((const void *)&sSync, sizeof(STONG_CREATE_FAIL_SYNC));
  167. }
  168. }
  169. break;
  171. // 添加成员
  172. case enumC2S_TONG_ADD_MEMBER:
  173. {
  174. char szPlayerName[64], szTongName[64];
  175. STONG_ADD_MEMBER_COMMAND *pAdd = (STONG_ADD_MEMBER_COMMAND*)pData;
  177. memcpy(szTongName, &pAdd->m_szBuffer[0], pAdd->m_btTongNameLength);
  178. szTongName[pAdd->m_btTongNameLength] = 0;
  179. memcpy(szPlayerName, &pAdd->m_szBuffer[pAdd->m_btTongNameLength], pAdd->m_btPlayerNameLength);
  180. szPlayerName[pAdd->m_btPlayerNameLength] = 0;
  182. int nRet = g_cTongSet.AddMember(szPlayerName, szTongName);
  183. // 成员添加成功
  184. if (nRet >= 0)
  185. {
  186. STONG_ADD_MEMBER_SUCCESS_SYNC sSync;
  187. sSync.ProtocolFamily = pf_tong;
  188. sSync.ProtocolID = enumS2C_TONG_ADD_MEMBER_SUCCESS;
  189. sSync.m_dwPlayerNameID = pAdd->m_dwPlayerNameID;
  190. sSync.m_dwParam = pAdd->m_dwParam;
  191. sSync.m_btCamp = g_cTongSet.GetTongCamp(nRet);
  192. g_cTongSet.GetMasterName(nRet, sSync.m_szMasterName);
  193. g_cTongSet.GetMemberTitle(nRet, sSync.m_szTitleName);
  194. strcpy(sSync.m_szTongName, szTongName);
  196. this->SendPackage((const void *)&sSync, sizeof(sSync));
  197. }
  198. // 成员添加不成功
  199. else
  200. {
  201. STONG_ADD_MEMBER_FAIL_SYNC sSync;
  202. sSync.ProtocolFamily = pf_tong;
  203. sSync.ProtocolID = enumS2C_TONG_ADD_MEMBER_FAIL;
  204. sSync.m_dwPlayerNameID = pAdd->m_dwPlayerNameID;
  205. sSync.m_dwParam = pAdd->m_dwParam;
  206. sSync.m_btFailID = nRet;
  208. this->SendPackage((const void *)&sSync, sizeof(STONG_ADD_MEMBER_FAIL_SYNC));
  209. }
  210. }
  211. break;
  212. // 获得帮会信息
  213. case enumC2S_TONG_GET_HEAD_INFO:
  214. {
  215. STONG_GET_TONG_HEAD_INFO_COMMAND *pGet = (STONG_GET_TONG_HEAD_INFO_COMMAND*)pData;
  216. STONG_HEAD_INFO_SYNC sInfo;
  217. if (g_cTongSet.GetTongHeadInfo(pGet->m_dwTongNameID, &sInfo))
  218. {
  219. sInfo.m_dwParam = pGet->m_dwParam;
  220. sInfo.m_dwNpcID = pGet->m_dwNpcID;
  221. this->SendPackage((const void *)&sInfo, sInfo.m_wLength);
  222. }
  223. }
  224. break;
  225. case enumC2S_TONG_GET_MANAGER_INFO:
  226. {
  227. STONG_GET_MANAGER_INFO_COMMAND *pGet = (STONG_GET_MANAGER_INFO_COMMAND*)pData;
  228. STONG_MANAGER_INFO_SYNC sInfo;
  229. if (g_cTongSet.GetTongManagerInfo(pGet, &sInfo))
  230. this->SendPackage((const void *)&sInfo, sInfo.m_wLength);
  231. }
  232. break;
  233. case enumC2S_TONG_GET_MEMBER_INFO:
  234. {
  235. STONG_GET_MEMBER_INFO_COMMAND *pGet = (STONG_GET_MEMBER_INFO_COMMAND*)pData;
  236. STONG_MEMBER_INFO_SYNC sInfo;
  237. if (g_cTongSet.GetTongMemberInfo(pGet, &sInfo))
  238. this->SendPackage((const void *)&sInfo, sInfo.m_wLength);
  239. }
  240. break;
  241. case enumC2S_TONG_INSTATE:
  242. {
  243. STONG_INSTATE_COMMAND *pInstate = (STONG_INSTATE_COMMAND*)pData;
  244. STONG_INSTATE_SYNC sSync;
  245. sSync.ProtocolID = 0;
  246. g_cTongSet.Instate(pInstate, &sSync);
  247. if (sSync.ProtocolID != 0)
  248. this->SendPackage((const void *)&sSync, sizeof(sSync));
  249. }
  250. break;
  251. case enumC2S_TONG_KICK:
  252. {
  253. STONG_KICK_COMMAND *pKick = (STONG_KICK_COMMAND*)pData;
  254. STONG_KICK_SYNC sKick;
  255. sKick.ProtocolID = 0;
  256. g_cTongSet.Kick(pKick, &sKick);
  257. if (sKick.ProtocolID != 0)
  258. this->SendPackage((const void *)&sKick, sizeof(sKick));
  259. }
  260. break;
  261. case enumC2S_TONG_LEAVE:
  262. {
  263. STONG_LEAVE_COMMAND *pLeave = (STONG_LEAVE_COMMAND*)pData;
  264. STONG_LEAVE_SYNC sLeave;
  265. sLeave.ProtocolID = 0;
  266. g_cTongSet.Leave(pLeave, &sLeave);
  267. if (sLeave.ProtocolID != 0)
  268. this->SendPackage((const void *)&sLeave, sizeof(sLeave));
  269. }
  270. break;
  271. case enumC2S_TONG_CHANGE_MASTER:
  272. {
  273. STONG_CHANGE_MASTER_COMMAND *pChange = (STONG_CHANGE_MASTER_COMMAND*)pData;
  275. char szName[32];
  276. STONG_ONE_LEADER_INFO sInfo;
  277. memcpy(szName, pChange->m_szName, sizeof(pChange->m_szName));
  278. szName[31] = 0;
  280. if (!g_cTongSet.SearchOne(pChange->m_dwTongNameID, szName, &sInfo))
  281. {
  282. STONG_CHANGE_MASTER_FAIL_SYNC sFail;
  283. sFail.ProtocolFamily = pf_tong;
  284. sFail.ProtocolID = enumS2C_TONG_CHANGE_MASTER_FAIL;
  285. sFail.m_dwParam = pChange->m_dwParam;
  286. sFail.m_btFailID = 2;
  287. sFail.m_dwTongNameID = pChange->m_dwTongNameID;
  288. memcpy(sFail.m_szName, szName, sizeof(szName));
  289. this->SendPackage((const void *)&sFail, sizeof(sFail));
  290. break;
  291. }
  293. {{
  294. CNetConnectDup conndup;
  295. DWORD nameid = 0;
  296. unsigned long param = 0;
  297. if (g_HostServer.FindPlayerByRole(NULL, std::_tstring(szName), &conndup, NULL, &nameid, &param))
  298. {
  299. CNetConnectDup tongconndup = g_TongServer.FindTongConnectByIP(conndup.GetIP());
  300. if (tongconndup.IsValid())
  301. {
  302. STONG_CHECK_GET_MASTER_POWER_SYNC sCheck;
  303. sCheck.ProtocolFamily = pf_tong;
  304. sCheck.ProtocolID = enumS2C_TONG_CHECK_CHANGE_MASTER_POWER;
  305. sCheck.m_dwTongNameID = pChange->m_dwTongNameID;
  306. sCheck.m_btFigure = pChange->m_btFigure;
  307. sCheck.m_btPos = pChange->m_btPos;
  308. sCheck.m_dwParam = param;
  309. memcpy(sCheck.m_szName, szName, sizeof(szName));
  311. tongconndup.SendPackage((const void *)&sCheck, sizeof(sCheck));
  312. }
  313. break;
  314. }
  316. // 不在线 not find 或者 tong is not connect 当作不在线
  317. STONG_CHANGE_MASTER_FAIL_SYNC sFail;
  318. sFail.ProtocolFamily = pf_tong;
  319. sFail.ProtocolID = enumS2C_TONG_CHANGE_MASTER_FAIL;
  320. sFail.m_dwParam = pChange->m_dwParam;
  321. sFail.m_btFailID = 0;
  322. sFail.m_dwTongNameID = pChange->m_dwTongNameID;
  323. memcpy(sFail.m_szName, szName, sizeof(szName));
  324. this->SendPackage((const void *)&sFail, sizeof(sFail));
  325. }}
  327. }
  328. break;
  330. case enumC2S_TONG_ACCEPT_MASTER:
  331. {
  332. STONG_ACCEPT_MASTER_COMMAND *pAccept = (STONG_ACCEPT_MASTER_COMMAND*)pData;
  333. g_cTongSet.AcceptMaster(pAccept);
  334. }
  335. break;
  337. case enumC2S_TONG_GET_LOGIN_DATA:
  338. {
  339. STONG_GET_LOGIN_DATA_COMMAND *pLogin = (STONG_GET_LOGIN_DATA_COMMAND*)pData;
  340. STONG_LOGIN_DATA_SYNC sLogin;
  341. sLogin.m_dwParam = 0;
  342. g_cTongSet.GetLoginData(pLogin, &sLogin);
  343. if (sLogin.m_dwParam)
  344. this->SendPackage((const void *)&sLogin, sizeof(sLogin));
  345. }
  346. break;
  348. default:
  349. break;
  350. }
  351. }
  353. void CTongConnect::Proc0_Friend(const void* pData, size_t size)
  354. {
  355. EXTEND_HEADER* pHeader = (EXTEND_HEADER*)pData;
  357. if (pHeader->ProtocolID == friend_c2c_askaddfriend)
  358. {
  359. Proc1_Friend_AskAddFriend(pData, size);
  360. }
  361. else if (pHeader->ProtocolID == friend_c2c_repaddfriend)
  362. {
  363. Proc1_Friend_RepAddFriend(pData, size);
  364. }
  365. else if (pHeader->ProtocolID == friend_c2s_groupfriend)
  366. {
  367. Proc1_Friend_GroupFriend(pData, size);
  368. }
  369. else if (pHeader->ProtocolID == friend_c2s_erasefriend)
  370. {
  371. Proc1_Friend_EraseFriend(pData, size);
  372. }
  373. else if (pHeader->ProtocolID == friend_c2s_asksyncfriendlist)
  374. {
  375. Proc1_Friend_AskSyncFriendList(pData, size);
  376. }
  377. else if (pHeader->ProtocolID == friend_c2s_associate)
  378. {
  379. Proc1_Friend_Associate(pData, size);
  380. }
  381. else if (pHeader->ProtocolID == friend_c2s_associatebevy)
  382. {
  383. Proc1_Friend_AssociateBevy(pData, size);
  384. }
  385. }
  387. void CTongConnect::Proc1_Friend_AskAddFriend(const void* pData, size_t size)
  388. {
  389. ASK_ADDFRIEND_CMD* pAafCmd = (ASK_ADDFRIEND_CMD*)pData;
  390. tagPlusSrcInfo* pSrcInfo = (tagPlusSrcInfo*)((BYTE*)pData + size) - 1;
  392. if (!gIsLegalString(pAafCmd->dstrole, 1, _NAME_LEN))
  393. return;
  395. std::_tstring srcrole;
  396. if (!g_HostServer.FindPlayerByIpParam(NULL, GetIP(), pSrcInfo->lnID, NULL, NULL, &srcrole, NULL))
  397. return;
  399. std::_tstring dstrole(pAafCmd->dstrole);
  401. if (_tstring_equal()(srcrole, dstrole))
  402. return;
  405. BOOL pass = FALSE;
  406. BOOL promise = FALSE;
  408. CNetConnectDup dsthostconndup;
  409. DWORD dstnameid = 0;
  410. unsigned long dstparam = 0;
  411. if (g_HostServer.FindPlayerByRole(NULL, dstrole, &dsthostconndup, NULL, &dstnameid, &dstparam))
  412. {
  413. if (g_FriendMgr.PlayerIsFriend(dstrole, srcrole))
  414. {
  415. g_FriendMgr.PlayerAddFriend(srcrole, dstrole);
  417. promise = TRUE; //默许
  418. }
  419. else
  420. {
  421. if (g_FriendMgr.TrackAddFriend(srcrole, dstrole, pAafCmd->pckgid))
  422. {
  423. ASK_ADDFRIEND_SYNC AafSync;
  424. AafSync.ProtocolFamily = pf_friend;
  425. AafSync.ProtocolID = friend_c2c_askaddfriend;
  426. AafSync.pckgid = pAafCmd->pckgid;
  427. strcpy(AafSync.srcrole, srcrole.c_str());
  429. if (PassToSomeone(dsthostconndup.GetIP(), dstparam, dstnameid, &AafSync, sizeof(ASK_ADDFRIEND_SYNC)))
  430. pass = TRUE;
  431. else
  432. g_FriendMgr.ExtractAddFriend(srcrole, dstrole, pAafCmd->pckgid);
  433. }
  434. }
  435. }
  437. if (!pass)
  438. {
  439. REP_ADDFRIEND_SYNC RafSync;
  440. RafSync.ProtocolFamily = pf_friend;
  441. RafSync.ProtocolID = friend_c2c_repaddfriend;
  442. RafSync.pckgid = pAafCmd->pckgid;
  443. strcpy(RafSync.srcrole, pAafCmd->dstrole);
  444. RafSync.answer = promise ? answerAgree : answerUnable;
  446. PassToSomeone(GetIP(), pSrcInfo->lnID, pSrcInfo->nameid, &RafSync, sizeof(REP_ADDFRIEND_SYNC));
  447. }
  448. }
  450. void CTongConnect::Proc1_Friend_RepAddFriend(const void* pData, size_t size)
  451. {
  452. REP_ADDFRIEND_CMD* pRafCmd = (REP_ADDFRIEND_CMD*)pData;
  453. tagPlusSrcInfo* pSrcInfo = (tagPlusSrcInfo*)((BYTE*)pData + size) - 1;
  455. if (!gIsLegalString(pRafCmd->dstrole, 1, _NAME_LEN))
  456. return;
  458. std::_tstring srcrole;
  459. if (!g_HostServer.FindPlayerByIpParam(NULL, GetIP(), pSrcInfo->lnID, NULL, NULL, &srcrole, NULL))
  460. return;
  462. std::_tstring dstrole(pRafCmd->dstrole);
  464. if (_tstring_equal()(srcrole, dstrole))
  465. return;
  468. if (!g_FriendMgr.ExtractAddFriend(dstrole, srcrole, pRafCmd->pckgid))
  469. return;
  472. if (pRafCmd->answer == answerAgree)
  473. g_FriendMgr.PlayerAddFriend(srcrole, dstrole);
  476. {{
  477. CNetConnectDup dsthostconndup;
  478. DWORD dstnameid = 0;
  479. unsigned long dstparam = 0;
  480. if (g_HostServer.FindPlayerByRole(NULL, dstrole, &dsthostconndup, NULL, &dstnameid, &dstparam))
  481. {
  482. REP_ADDFRIEND_SYNC RafSync;
  483. RafSync.ProtocolFamily = pf_friend;
  484. RafSync.ProtocolID = friend_c2c_repaddfriend;
  485. RafSync.pckgid = pRafCmd->pckgid;
  486. strcpy(RafSync.srcrole, srcrole.c_str());
  487. RafSync.answer = pRafCmd->answer;
  489. PassToSomeone(dsthostconndup.GetIP(), dstparam, dstnameid, &RafSync, sizeof(REP_ADDFRIEND_SYNC));
  490. }
  491. else
  492. {
  493. FRIEND_STATE Fs;
  494. Fs.ProtocolFamily = pf_friend;
  495. Fs.ProtocolID = friend_s2c_friendstate;
  496. Fs.state = stateOffline;
  498. PassToSomeone(GetIP(), pSrcInfo->lnID, pSrcInfo->nameid, &Fs, sizeof(FRIEND_STATE));
  499. }
  500. }}
  501. }
  503. void CTongConnect::Proc1_Friend_GroupFriend(const void* pData, size_t size)
  504. {
  505. GROUP_FRIEND* pGf = (GROUP_FRIEND*)pData;
  506. tagPlusSrcInfo* pSrcInfo = (tagPlusSrcInfo*)((BYTE*)pData + size) - 1;
  508. std::_tstring srcrole;
  509. if (!g_HostServer.FindPlayerByIpParam(NULL, GetIP(), pSrcInfo->lnID, NULL, NULL, &srcrole, NULL))
  510. return;
  512. char* pGroupTag = (char*)(pGf + 1);
  513. if (*pGroupTag != specGroup)
  514. return; //error
  516. char* pGroup = (char*)(pGroupTag + 1);
  518. on_nextgroup:
  519. if (!gIsLegalString(pGroup, 0, _GROUP_NAME_LEN))
  520. return; //error
  522. std::_tstring group(pGroup);
  524. for (char* pRoleTag = pGroup + strlen(pGroup) + 1; ; )
  525. {
  526. if (*pRoleTag == specOver)
  527. return; //success
  528. else if (*pRoleTag == specGroup)
  529. {
  530. pGroup = pRoleTag + 1;
  531. goto on_nextgroup; //next group
  532. }
  533. else if (*pRoleTag == specRole)
  534. {
  535. char* pRole = pRoleTag + 1;
  537. if (!gIsLegalString(pRole, 1, _NAME_LEN))
  538. return; //error
  540. std::_tstring role(pRole);
  541. g_FriendMgr.SetFriendGroup(srcrole, role, group);
  543. pRoleTag = pRole + role.size() + 1;
  544. continue;  //next role
  545. }
  546. else
  547. return; //error
  548. }
  549. }
  551. void CTongConnect::Proc1_Friend_EraseFriend(const void* pData, size_t size)
  552. {
  553. ERASE_FRIEND* pEf = (ERASE_FRIEND*)pData;
  554. tagPlusSrcInfo* pSrcInfo = (tagPlusSrcInfo*)((BYTE*)pData + size) - 1;
  556. if (!gIsLegalString(pEf->friendrole, 1, _NAME_LEN))
  557. return;
  559. std::_tstring srcrole;
  560. if (!g_HostServer.FindPlayerByIpParam(NULL, GetIP(), pSrcInfo->lnID, NULL, NULL, &srcrole, NULL))
  561. return;
  563. g_FriendMgr.PlayerDelFriend(srcrole, std::_tstring(pEf->friendrole));
  564. }
  566. void CTongConnect::Proc1_Friend_AskSyncFriendList(const void* pData, size_t size)
  567. {
  568. ASK_SYNCFRIENDLIST* pAsfl = (ASK_SYNCFRIENDLIST*)pData;
  569. tagPlusSrcInfo* pSrcInfo = (tagPlusSrcInfo*)((BYTE*)pData + size) - 1;
  571. std::_tstring role;
  572. if (!g_HostServer.FindPlayerByIpParam(NULL, GetIP(), pSrcInfo->lnID, NULL, NULL, &role, NULL))
  573. return;
  575. g_FriendMgr.SomeoneSyncFriends(role, pSrcInfo->lnID, pSrcInfo->nameid, CNetConnectDup(*this), pAsfl->full, pAsfl->pckgid);
  576. }
  578. void CTongConnect::Proc1_Friend_Associate(const void* pData, size_t size)
  579. {
  580. FRIEND_ASSOCIATE* pFa = (FRIEND_ASSOCIATE*)pData;
  582. char* szGroup = (char*)(pFa + 1);
  583. if (!gIsLegalString(szGroup, 0, _GROUP_NAME_LEN))
  584. return;
  586. std::_tstring group(szGroup);
  588. char* szRole1 = szGroup + group.size() + 1;
  589. if (!gIsLegalString(szRole1, 1, _NAME_LEN))
  590. return;
  592. std::_tstring role1(szRole1);
  594. char* szRole2 = szRole1 + role1.size() + 1;
  595. if (!gIsLegalString(szRole2, 1, _NAME_LEN))
  596. return;
  598. std::_tstring role2(szRole2);
  600. if (_tstring_equal()(role1, role2))
  601. return;
  604. {{
  605. g_FriendMgr.PlayerAssociate(role1, role2, group, pFa->bidir);
  606. }}
  610. size_t basesize = sizeof(FRIEND_SYNCASSOCIATE) + group.size() + 1;
  611. size_t role1size = role1.size() + 1;
  612. size_t role2size = role2.size() + 1;
  613. size_t maxsize = basesize + (pFa->bidir ? max(role1size, role2size) : role2size) + 1;
  615. FRIEND_SYNCASSOCIATE* pFsa = (FRIEND_SYNCASSOCIATE*)_alloca(maxsize);
  616. pFsa->ProtocolFamily = pf_friend;
  617. pFsa->ProtocolID = friend_s2c_syncassociate;
  619. char* szGroupSync = (char*)(pFsa + 1);
  620. strcpy(szGroupSync, group.c_str());
  622. char* szRoleSync = szGroupSync + group.size() + 1;
  625. {{
  626. CNetConnectDup conndup;
  627. DWORD nameid = 0;
  628. unsigned long param = 0;
  629. if (g_HostServer.FindPlayerByRole(NULL, role1, &conndup, NULL, &nameid, &param))
  630. {
  631. size_t pckgsize = basesize + role2size + 1;
  633. strcpy(szRoleSync, role2.c_str());
  634. szRoleSync[role2size] = 0;
  636. PassToSomeone(conndup.GetIP(), param, nameid, pFsa, pckgsize);
  637. }
  638. }}
  640. if (pFa->bidir)
  641. {
  642. CNetConnectDup conndup2;
  643. DWORD nameid2 = 0;
  644. unsigned long param2 = 0;
  645. if (g_HostServer.FindPlayerByRole(NULL, role2, &conndup2, NULL, &nameid2, &param2))
  646. {
  647. size_t pckgsize2 = basesize + role1size + 1;
  649. strcpy(szRoleSync, role1.c_str());
  650. szRoleSync[role1size] = 0;
  652. PassToSomeone(conndup2.GetIP(), param2, nameid2, pFsa, pckgsize2);
  653. }
  654. }
  655. }
  657. void CTongConnect::Proc1_Friend_AssociateBevy(const void* pData, size_t size)
  658. {
  659. FRIEND_ASSOCIATEBEVY* pFab = (FRIEND_ASSOCIATEBEVY*)pData;
  661. std::_tstring group;
  662. CFriendMgr::_BEVY bevy;
  664. size_t rolessize = 0;
  666. {{
  667. char* szGroup = (char*)(pFab + 1);
  668. if (!gIsLegalString(szGroup, 0, _GROUP_NAME_LEN))
  669. return;
  671. group.assign(szGroup);
  673. char* szRoles = szGroup + group.size() + 1;
  674. while (*szRoles)
  675. {
  676. if (!gIsLegalString(szRoles, 1, _NAME_LEN))
  677. return;
  679. std::_tstring role(szRoles);
  680. bevy.push_back(role);
  682. szRoles += role.size() + 1;
  683. rolessize += role.size() + 1;
  684. }
  686. if (bevy.size() < 2)
  687. return;
  688. }}
  691. g_FriendMgr.PlayerAssociateBevy(bevy, group);
  694. {{
  695. size_t basesize = sizeof(FRIEND_SYNCASSOCIATE) + group.size() + 1;
  696. size_t maxsize = basesize + rolessize + 1;
  698. FRIEND_SYNCASSOCIATE* pFsa = (FRIEND_SYNCASSOCIATE*)_alloca(maxsize);
  699. pFsa->ProtocolFamily = pf_friend;
  700. pFsa->ProtocolID = friend_s2c_syncassociate;
  702. char* szGroupSync = (char*)(pFsa + 1);
  703. strcpy(szGroupSync, group.c_str());
  705. char* szRolesSync = szGroupSync + group.size() + 1;
  708. for (CFriendMgr::_BEVY::iterator itS = bevy.begin(); itS != bevy.end(); itS++)
  709. {
  710. std::_tstring someone = *itS;
  712. CNetConnectDup conndup;
  713. DWORD nameid = 0;
  714. unsigned long param = 0;
  715. if (!g_HostServer.FindPlayerByRole(NULL, someone, &conndup, NULL, &nameid, &param))
  716. continue;
  718. size_t cursor = 0;
  719. for (CFriendMgr::_BEVY::iterator itD = bevy.begin(); itD != bevy.end(); itD++)
  720. {
  721. if (itD == itS)
  722. continue;
  724. std::_tstring dst = *itD;
  726. strcpy(szRolesSync + cursor, dst.c_str());
  727. cursor += dst.size() + 1;
  728. }
  729. szRolesSync[cursor++] = 0;
  731. PassToSomeone(conndup.GetIP(), param, nameid, pFsa, basesize + cursor);
  732. }
  733. }}
  734. }