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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
GateInfo.cpp
资源名称：LegendOfMir2_Server020418.zip　[点击查看]
上传用户：szopptop
上传日期：2013-04-23
资源大小：1047k
文件大小：12k
源码类别：

模拟服务器

开发平台：

Visual C++

GateInfo.cpp：源码内容
  1. #include "stdafx.h"
  2. #include "dbsvr.h"
  3. #include "globalUserList.h"
  4. #include "../def/dbmgr.h"
  5. #include <stdio.h>
  6. #include "tableList.h"
  7. #include "processdbmsg.h"
  9. void GetLoadHumanRcd(CServerInfo* pServerInfo, _LPTLOADHUMAN lpLoadHuman, int nRecog);
  11. extern CWHList<CServerInfo*> g_xServerList;
  12. extern CWHList< GAMESERVERINFO * > g_xGameServerList;
  14. void CGateInfo::ReceiveOpenUser(char *pszPacket)
  15. {
  16. char *pszPos;
  17. int nSocket;
  18. int nLen = memlen(pszPacket);
  20. if (pszPos = (char *)memchr(pszPacket, '/', nLen))
  21. {
  22. nSocket = AnsiStrToVal(pszPacket);
  24. pszPos++;
  26. CUserInfo* pUserInfo = new CUserInfo;
  28. if (pUserInfo)
  29. {
  30. MultiByteToWideChar(CP_ACP, 0, pszPacket, -1, pUserInfo->szSockHandle, sizeof(pUserInfo->szSockHandle)/sizeof(TCHAR));
  31. MultiByteToWideChar(CP_ACP, 0, pszPos, -1, pUserInfo->szAddress, sizeof(pUserInfo->szAddress)/sizeof(TCHAR));
  33. pUserInfo->sock = nSocket;
  34. pUserInfo->nCertification = 0;
  35. pUserInfo->nClientVersion = 0;
  37. ZeroMemory(pUserInfo->szUserID, sizeof(pUserInfo->szUserID));
  39. xUserInfoList.AddNewNode(pUserInfo);
  41. InsertLogMsgParam(IDS_OPEN_USER, pUserInfo->szAddress);
  42. }
  43. } 
  44. }
  46. void CGateInfo::ReceiveCloseUser(char *pszPacket)
  47. {
  48. int nSocket = AnsiStrToVal(pszPacket);
  49. /*
  50. map<SOCKET, CUserInfo, less<SOCKET> >::iterator it = pGateInfo->UserInfoMap.find((SOCKET)nSocket);
  52. if (it != pGateInfo->UserInfoMap.end())
  53. {
  54. InsertLogMsgParam(IDS_CLOSE_USER, it->second.szAddress);
  56. pGateInfo->UserInfoMap.erase(it);
  57. } */
  58. }
  60. void CGateInfo::ReceiveSendUser(char *pszPacket)
  61. {
  62. char *pszPos;//, *pszPos2;
  63. int nSocket;
  64. int nLen = memlen(pszPacket);
  66. if ((pszPos = (char *)memchr(pszPacket, '/', nLen)))// && (pszPos2 = (char *)memchr(pszPacket, '$', nLen)))
  67. {
  68. nSocket = AnsiStrToVal(pszPacket);
  70. pszPos++;
  72. _LPTGATESENDBUFF lpSendUserData = new _TGATESENDBUFF;
  74. lpSendUserData->sock = (SOCKET)nSocket;
  76. memmove(lpSendUserData->szData, pszPos, memlen(pszPos));
  78. m_GateQ.PushQ((BYTE *)lpSendUserData);
  79. }
  80. }
  82. void CGateInfo::SendToGate(SOCKET cSock, char *pszPacket)
  83. {
  84. char szData[256];
  85. WSABUF buf;
  86. DWORD dwSendBytes;
  88. int nLen = memlen(pszPacket) - 1;
  90. szData[0] = '%';
  92. char *pszNext = ValToAnsiStr((int)cSock, &szData[1]);
  94. *pszNext++ = '/';
  95. *pszNext++ = '#';
  97. memmove(pszNext, pszPacket, nLen);
  99. pszNext += nLen;
  101. *pszNext++ = '!';
  102. *pszNext++ = '$';
  103. *pszNext++ = '';
  105. buf.len = pszNext - szData;
  106. buf.buf = szData;
  108. WSASend(sock, &buf, 1, &dwSendBytes, 0, NULL, NULL);
  109. }
  111. void CGateInfo::QueryCharacter(SOCKET s, char *pszPacket)
  112. {
  113. _TQUERYCHR tQueryChr[3];
  114. char szDecodeMsg[128];
  115. int nCnt = 0;
  116. char szQuery[256];
  118. ZeroMemory(tQueryChr, sizeof(tQueryChr));
  120. int nPos = fnDecode6BitBufA(pszPacket, szDecodeMsg, sizeof(szDecodeMsg));
  121. szDecodeMsg[nPos] = '';
  123. char *pszDevide = (char *)memchr(szDecodeMsg, '/', nPos);
  125. if (pszDevide)
  126. {
  127. *pszDevide++ = '';
  129. sprintf( szQuery, "SELECT * FROM TBL_CHARACTER WHERE FLD_LOGINID='%s'", pszDevide );
  131. CRecordset *pRec = GetDBManager()->CreateRecordset();
  133. if (pRec->Execute( szQuery ))
  134. {
  135. while (pRec->Fetch() && nCnt < 3)
  136. {
  137. tQueryChr[nCnt].btClass  = atoi( pRec->Get( "FLD_JOB" ) );
  138. tQueryChr[nCnt].btGender = atoi( pRec->Get( "FLD_GENDER" ) );
  139. strcpy( tQueryChr[nCnt].szName, pRec->Get( "FLD_CHARNAME" ) );
  140. ChangeSpaceToNull( tQueryChr[nCnt].szName );
  142. nCnt++;
  143. }
  144. }
  146. GetDBManager()->DestroyRecordset( pRec );
  148. _TDEFAULTMESSAGE DefaultMsg;
  149. char szEncodeMsg[32];
  150. char szEncodeData[256];
  151. char szEncodePacket[256];
  153. if (nCnt > 0 && nCnt < 3)
  154. {
  155. fnMakeDefMessageA(&DefaultMsg, SM_QUERYCHR, 0, nCnt, 0, 0);
  156. nPos = fnEncodeMessageA(&DefaultMsg, szEncodeMsg, sizeof(szEncodeMsg));
  157. int nPos2 = fnEncode6BitBufA((unsigned char *)tQueryChr, szEncodeData, sizeof(_TQUERYCHR) * nCnt, sizeof(szEncodeData));
  159. memmove(szEncodePacket, szEncodeMsg, nPos);
  160. memmove(&szEncodePacket[nPos], szEncodeData, nPos2);
  161. szEncodePacket[nPos + nPos2] = '';
  163. SendToGate(s, szEncodePacket);
  164. }
  165. else
  166. {
  167. fnMakeDefMessageA(&DefaultMsg, SM_QUERYCHR_FAIL, 0, 0, 0, 0);
  168. nPos = fnEncodeMessageA(&DefaultMsg, szEncodeMsg, sizeof(szEncodeMsg));
  169. szEncodeMsg[nPos] = '';
  171. SendToGate(s, szEncodeMsg);
  172. }
  173. }
  174. }
  176. void CGateInfo::DeleteExistCharacter(SOCKET s, _LPTCREATECHR lpTCreateChr)
  177. {
  178. _TDEFAULTMESSAGE DefaultMsg;
  179. char szEncodeMsg[32];
  180. char szQuery[256];
  181. CRecordset *pRec;
  183. sprintf( szQuery, "DELETE FROM TBL_CHARACTER WHERE FLD_LOGINID='%s' AND FLD_CHARNAME='%s'", lpTCreateChr->szID, lpTCreateChr->szName );
  185. pRec = GetDBManager()->CreateRecordset();
  186. pRec->Execute( szQuery );
  187. GetDBManager()->DestroyRecordset( pRec );
  189. sprintf( szQuery, "DELETE FROM TBL_CHARACTER_GENITEM WHERE FLD_LOGINID='%s' AND FLD_CHARNAME='%s'", lpTCreateChr->szID, lpTCreateChr->szName );
  191. pRec = GetDBManager()->CreateRecordset();
  192. pRec->Execute( szQuery );
  193. GetDBManager()->DestroyRecordset( pRec );
  195. sprintf( szQuery, "DELETE FROM TBL_CHARACTER_ITEM WHERE FLD_LOGINID='%s' AND FLD_CHARNAME='%s'", lpTCreateChr->szID, lpTCreateChr->szName );
  197. pRec = GetDBManager()->CreateRecordset();
  198. pRec->Execute( szQuery );
  199. GetDBManager()->DestroyRecordset( pRec );
  201. sprintf( szQuery, "DELETE FROM TBL_CHARACTER_MAGIC WHERE FLD_LOGINID='%s' AND FLD_CHARNAME='%s'", lpTCreateChr->szID, lpTCreateChr->szName );
  203. pRec = GetDBManager()->CreateRecordset();
  204. pRec->Execute( szQuery );
  205. GetDBManager()->DestroyRecordset( pRec );
  207. fnMakeDefMessageA(&DefaultMsg, SM_DELCHR_SUCCESS, 0, 4, 0, 0);
  208. int nPos = fnEncodeMessageA(&DefaultMsg, szEncodeMsg, sizeof(szEncodeMsg));
  209. szEncodeMsg[nPos] = '';
  211. SendToGate(s, szEncodeMsg);
  212. }
  214. void CGateInfo::MakeNewCharacter(SOCKET s, _LPTCREATECHR lpTCreateChr)
  215. {
  216. //ERROR: 1=> Exist Charname, 2=>Wrong Name, 3=>Not enough Space, 4=>Error
  217. _TDEFAULTMESSAGE DefaultMsg;
  218. char szEncodeMsg[32];
  219. int nPos;
  220. char szQuery[2048];
  222. sprintf( szQuery, "SELECT FLD_CHARNAME FROM TBL_CHARACTER WHERE FLD_CHARNAME='%s'", lpTCreateChr->szName );
  224. CRecordset *pRec = GetDBManager()->CreateRecordset();
  226. pRec->Execute( szQuery );
  228. if (pRec->Fetch())
  229. {
  230. fnMakeDefMessageA(&DefaultMsg, SM_NEWCHR_FAIL, 0, 1, 0, 0);
  231. nPos = fnEncodeMessageA(&DefaultMsg, szEncodeMsg, sizeof(szEncodeMsg));
  232. szEncodeMsg[nPos] = '';
  234. SendToGate(s, szEncodeMsg);
  236. GetDBManager()->DestroyRecordset( pRec );
  238. return;
  239. }
  241. GetDBManager()->DestroyRecordset( pRec );
  243. sprintf( szQuery, "SELECT COUNT(FLD_CHARNAME) AS FLD_COUNT FROM TBL_CHARACTER WHERE FLD_CHARNAME='%s'", lpTCreateChr->szName );
  245. pRec = GetDBManager()->CreateRecordset();
  247. if (pRec->Execute( szQuery ) || pRec->Fetch() )
  248. {
  249. if (atoi(pRec->Get( "FLD_COUNT" )) >= 3)
  250. {
  251. fnMakeDefMessageA(&DefaultMsg, SM_NEWCHR_FAIL, 0, 3, 0, 0);
  252. nPos = fnEncodeMessageA(&DefaultMsg, szEncodeMsg, sizeof(szEncodeMsg));
  253. szEncodeMsg[nPos] = '';
  255. SendToGate(s, szEncodeMsg);
  257. GetDBManager()->DestroyRecordset( pRec );
  259. return;
  260. }
  262. GetDBManager()->DestroyRecordset( pRec );
  264. CTblStartPoint::TABLE *table = GetTblStartPoint()->Get( "4" );
  266. pRec = GetDBManager()->CreateRecordset();
  268. // TBL_CHARACTER 抛捞喉 眠啊
  270. sprintf(szQuery, "INSERT TBL_CHARACTER ("
  271. "FLD_LOGINID, FLD_CHARNAME, FLD_JOB, FLD_GENDER, FLD_LEVEL, FLD_DIRECTION, "
  272. "FLD_ATTACKMODE, FLD_CX, FLD_CY, FLD_MAPNAME, FLD_GOLD, FLD_HAIR, "
  273. "FLD_DRESS_ID, FLD_WEAPON_ID, FLD_LEFTHAND_ID, FLD_RIGHTHAND_ID, FLD_HELMET_ID, "
  274. "FLD_NECKLACE_ID, FLD_ARMRINGL_ID, FLD_ARMRINGR_ID, FLD_RINGL_ID, "
  275. "FLD_RINGR_ID, FLD_EXP) VALUES ( "
  276. "'%s', '%s', %d, %d, 1, 4, "
  277. "1, %d, %d, '%s', 0, 0, "
  278. "'0', '0', '0', '0', '0', "
  279. "'0', '0', '0', '0', "
  280. "'0', 0 )",
  281. lpTCreateChr->szID, lpTCreateChr->szName, lpTCreateChr->btClass, lpTCreateChr->btGender,
  282. table->posX, table->posY, table->mapName);
  283. pRec->Execute( szQuery );
  285. sprintf(szQuery, "INSERT TBL_CHARACTER_GENITEM (FLD_LOGINID, FLD_CHARNAME, FLD_ITEMINDEX) VALUES ('%s', '%s', 'G00080008000')",
  286. lpTCreateChr->szID, lpTCreateChr->szName);
  287. pRec->Execute( szQuery );
  289. GetDBManager()->DestroyRecordset( pRec );
  291. _TLOADHUMAN human;
  292. _TMAKEITEMRCD makeItem;
  293. memset( &human, 0, sizeof( human ) );
  294. memset( &makeItem, 0, sizeof( makeItem ) );
  296. strcpy( human.szUserID, lpTCreateChr->szID );
  297. strcpy( human.szCharName, lpTCreateChr->szName );
  299. // 乞汗 眠啊 (0: 巢, 1: 咯)
  300. makeItem.szStdType = 'B';
  301. makeItem.nStdIndex = lpTCreateChr->btGender ? 34 : 33;
  302. makeItem.nDura = 5000;
  303. makeItem.nDuraMax = 5000;
  304. MakeNewItem( NULL, &human, &makeItem, 0 );
  306. // 格八 眠啊
  307. makeItem.szStdType = 'A';
  308. makeItem.nStdIndex = 7;
  309. makeItem.nDura = 4000;
  310. makeItem.nDuraMax = 4000;
  311. MakeNewItem( NULL, &human, &makeItem, 0 );
  313. fnMakeDefMessageA(&DefaultMsg, SM_NEWCHR_SUCCESS, 0, 0, 0, 0);
  314. nPos = fnEncodeMessageA(&DefaultMsg, szEncodeMsg, sizeof(szEncodeMsg));
  315. szEncodeMsg[nPos] = '';
  317. SendToGate(s, szEncodeMsg);
  319. return;
  320. }
  322. fnMakeDefMessageA(&DefaultMsg, SM_NEWCHR_FAIL, 0, 4, 0, 0);
  323. nPos = fnEncodeMessageA(&DefaultMsg, szEncodeMsg, sizeof(szEncodeMsg));
  324. szEncodeMsg[nPos] = '';
  326. SendToGate(s, szEncodeMsg);
  328. GetDBManager()->DestroyRecordset( pRec );
  329. }
  331. void CGateInfo::GetSelectCharacter(SOCKET s, char *pszPacket)
  332. {
  333. char szDecodeMsg[128];
  334. char szServerIP[32];
  335. char szEncodeMsg[32];
  336. char szEncodeData[64];
  337. char szEncodePacket[256];
  338. _TDEFAULTMESSAGE DefaultMsg;
  340. // ORZ: Load Balancing, 立加荐啊 啊厘 利篮 霸捞飘 辑滚 IP 急琶
  341. GAMESERVERINFO *pBestServer = NULL;
  342. GAMESERVERINFO *pTemp;
  344. // EnterCriticalSection( &g_xGameServerList.m_cs );
  345. for ( PLISTNODE pNode = g_xGameServerList.GetHead();pNode; pNode = g_xGameServerList.GetNext( pNode ) )
  346. {
  347. pTemp = g_xGameServerList.GetData( pNode );
  349. if ( !pBestServer || pTemp->connCnt < pBestServer->connCnt )
  350. {
  351. pBestServer = pTemp;
  352. continue;
  353. }
  354. }
  356. pBestServer->connCnt++;
  357. // LeaveCriticalSection( &g_xGameServerList.m_cs );
  359. strcpy( szServerIP, pBestServer->ip );
  360. // ORZ: from here
  362. int nPos = fnDecode6BitBufA(pszPacket, szDecodeMsg, sizeof(szDecodeMsg));
  363. szDecodeMsg[nPos] = '';
  365. char *pszDevide = (char *)memchr(szDecodeMsg, '/', nPos);
  367. if (pszDevide)
  368. {
  369. *pszDevide++ = '';
  371. // 辑滚 急琶捞 啊瓷窍档废 荐沥
  372. _TLOADHUMAN tLoadHuman;
  373. CServerInfo* pServerInfo;
  375. memcpy(tLoadHuman.szUserID, szDecodeMsg, memlen(szDecodeMsg));
  376. memcpy(tLoadHuman.szCharName, pszDevide, memlen(pszDevide));
  377. ZeroMemory(tLoadHuman.szUserAddr, sizeof(tLoadHuman.szUserAddr));
  378. tLoadHuman.nCertification = 0;
  380. PLISTNODE pListNode = g_xServerList.GetHead();
  382. if (pListNode)
  383. pServerInfo = g_xServerList.GetData(pListNode);
  385. GetLoadHumanRcd(pServerInfo, &tLoadHuman, 0);
  387. fnMakeDefMessageA(&DefaultMsg, SM_STARTPLAY, 0, 0, 0, 0);
  388. nPos = fnEncodeMessageA(&DefaultMsg, szEncodeMsg, sizeof(szEncodeMsg));
  389. int nPos2 = fnEncode6BitBufA((unsigned char *)szServerIP, szEncodeData, memlen(szServerIP) -1, sizeof(szEncodeData));
  391. memmove(szEncodePacket, szEncodeMsg, nPos);
  392. memmove(&szEncodePacket[nPos], szEncodeData, nPos2);
  393. szEncodePacket[nPos + nPos2] = '';
  395. // ORZ: 傈眉 府胶飘俊 眠啊茄促.
  396. // 鞍篮 酒捞叼啊 捞固 粮犁窍芭唱 皋葛府 何练殿狼 捞蜡肺 角菩且 荐 乐促.
  397. // if ( GetGlobalUserList()->Insert( tLoadHuman.szCharName, szServerIP ) )
  398. SendToGate(s, szEncodePacket);
  399. // else
  400. // {
  401. // fnMakeDefMessageA(&DefaultMsg, SM_STARTFAIL, 0, 0, 0, 0);
  402. // nPos = fnEncodeMessageA(&DefaultMsg, szEncodeMsg, sizeof(szEncodeMsg));
  403. // szEncodeMsg[nPos] = '';
  405. // SendToGate(pGateInfo->sock, s, szEncodeMsg);
  406. // }
  407. }
  408. }