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

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

模拟服务器

开发平台：

Visual C++

ProcessDBMsg.cpp：源码内容
  1. #include "stdafx.h"
  2. #include "processdbmsg.h"
  3. #include <stdio.h>
  4. #include "../def/dbmgr.h"
  6. extern CWHQueue g_DBMsgQ;
  8. extern BOOL g_fTerminated;
  10. extern CWHList< GAMESERVERINFO * > g_xGameServerList;
  12. void SendSocket(SOCKET s, int nCertification, char *pszData1, char *pszData2, int nData2Len)
  13. {
  14. int nLen = nData2Len + DEFBLOCKSIZE + 6;
  15. LONG lCert = MAKELONG(nCertification ^ 0xAA, nLen);
  16. char szCert[24];
  17. char szEncodeMsg[8096];
  19. int nCertLen = fnEncode6BitBufA((unsigned char *)&lCert, szCert, sizeof(LONG), sizeof(szCert));
  21. szEncodeMsg[0] = '#';
  22. char *pszPos = ValToAnsiStr(nCertification, &szEncodeMsg[1]);
  24. *pszPos++ = '/';
  26. memmove(pszPos, pszData1, DEFBLOCKSIZE);
  27. pszPos += DEFBLOCKSIZE;
  28. memmove(pszPos, pszData2, nData2Len);
  29. pszPos += nData2Len;
  30. memmove(pszPos, szCert, nCertLen);
  32. pszPos += nCertLen;
  34. *pszPos++ = '!';
  35. *pszPos = '';
  37. int nSendLen = memlen(szEncodeMsg) - 1;
  39. send(s, szEncodeMsg, nSendLen, 0);
  40. }
  42. int GetHorseRcd(char *szName, _LPTHORSERCD lpTHorseRcd)
  43. {
  44. char szQuery[1024];
  45. sprintf( szQuery, "SELECT * FROM TBL_CHARACTER_HORSE WHERE FLD_CHARNAME='%s'", szName );
  47. CRecordset *pRec = GetDBManager()->CreateRecordset();
  48. if ( pRec->Execute( szQuery ) && pRec->Fetch() )
  49. {
  50. strcpy( lpTHorseRcd->szHorseIndex, pRec->Get( "FLD_HORSEINDEX" ) );
  51. lpTHorseRcd->btHorseType = atoi( pRec->Get( "FLD_HORSETYPE" ) );
  52. }
  53. else
  54. {
  55. GetDBManager()->DestroyRecordset( pRec );
  56. return 0;
  57. }
  58. GetDBManager()->DestroyRecordset( pRec );
  60. return 1;
  61. }
  63. void GetHumanGenItemRcd(char *szName, CWHList<_LPTGENITEMRCD> *pxUserGenItemRcdList)
  64. {
  65. char szQuery[128];
  67. sprintf( szQuery, "SELECT * FROM TBL_CHARACTER_GENITEM WHERE FLD_CHARNAME='%s'", szName );
  69. CRecordset *pRec = GetDBManager()->CreateRecordset();
  71. if ( pRec->Execute( szQuery ) )
  72. {
  73. while ( pRec->Fetch() )
  74. {
  75. _LPTGENITEMRCD pItemRcd = new _TGENITEMRCD;
  77. if ( pItemRcd )
  78. {
  79. strcpy( pItemRcd->szItem, pRec->Get( "FLD_ITEMINDEX" ) );
  80. pxUserGenItemRcdList->AddNewNode( pItemRcd );
  81. }
  82. }
  83. }
  85. GetDBManager()->DestroyRecordset( pRec );
  86. }
  88. void GetHumanMagicRcd(char *szName, CWHList<_LPTHUMANMAGICRCD> *pxUserMagicRcdList)
  89. {
  90. char szQuery[1024];
  92. sprintf( szQuery, "SELECT * FROM TBL_CHARACTER_MAGIC WHERE FLD_CHARNAME='%s'", szName );
  94. CRecordset *pRec = GetDBManager()->CreateRecordset();
  96. if (pRec->Execute( szQuery ))
  97. {
  98. while (pRec->Fetch())
  99. {
  100. _LPTHUMANMAGICRCD lptUserMagicRcd = new _THUMANMAGICRCD;
  102. if (lptUserMagicRcd)
  103. {
  104. lptUserMagicRcd->btMagicID = atoi( pRec->Get( "FLD_MAGICID" ) );
  105. lptUserMagicRcd->btLevel = atoi( pRec->Get( "FLD_LEVEL" ) );
  106. lptUserMagicRcd->btUseKey = atoi( pRec->Get( "FLD_USEKEY" ) );
  107. lptUserMagicRcd->nCurrTrain = atoi( pRec->Get( "FLD_CURRTRAIN" ) );
  109. pxUserMagicRcdList->AddNewNode(lptUserMagicRcd);
  110. }
  111. }
  112. }
  114. GetDBManager()->DestroyRecordset( pRec );
  115. }
  117. void GetHumanItemRcd(char *szName, CWHList<_LPTUSERITEMRCD> *pxUserItemRcdList)
  118. {
  119. char szQuery[128];
  121. sprintf( szQuery, "SELECT * FROM TBL_CHARACTER_ITEM WHERE FLD_CHARNAME='%s'", szName );
  123. CRecordset *pRec = GetDBManager()->CreateRecordset();
  125. if ( pRec->Execute( szQuery ) )
  126. {
  127. while ( pRec->Fetch() )
  128. {
  129. _LPTUSERITEMRCD pItem = new _TUSERITEMRCD;
  131. pItem->szMakeIndex[0] = *(pRec->Get( "FLD_STDTYPE" ));
  132. memmove( &pItem->szMakeIndex[1], pRec->Get( "FLD_MAKEDATE" ), 6 );
  133. memmove( &pItem->szMakeIndex[7], pRec->Get( "FLD_MAKEINDEX" ), 5 );
  135. pItem->nStdIndex = atoi( pRec->Get( "FLD_STDINDEX" ) );
  136. pItem->nDura = atoi( pRec->Get( "FLD_DURA" ) );
  137. pItem->nDuraMax = atoi( pRec->Get( "FLD_DURAMAX" ) );
  138. pItem->btValue[0] = atoi( pRec->Get( "FLD_VALUE1" ) );
  139. pItem->btValue[1] = atoi( pRec->Get( "FLD_VALUE2" ) );
  140. pItem->btValue[2] = atoi( pRec->Get( "FLD_VALUE3" ) );
  141. pItem->btValue[3] = atoi( pRec->Get( "FLD_VALUE4" ) );
  142. pItem->btValue[4] = atoi( pRec->Get( "FLD_VALUE5" ) );
  143. pItem->btValue[5] = atoi( pRec->Get( "FLD_VALUE6" ) );
  144. pItem->btValue[6] = atoi( pRec->Get( "FLD_VALUE7" ) );
  145. pItem->btValue[7] = atoi( pRec->Get( "FLD_VALUE8" ) );
  146. pItem->btValue[8] = atoi( pRec->Get( "FLD_VALUE9" ) );
  147. pItem->btValue[9] = atoi( pRec->Get( "FLD_VALUE10" ) );
  148. pItem->btValue[10] = atoi( pRec->Get( "FLD_VALUE11" ) );
  149. pItem->btValue[11] = atoi( pRec->Get( "FLD_VALUE12" ) );
  150. pItem->btValue[12] = atoi( pRec->Get( "FLD_VALUE13" ) );
  152. ZeroMemory(pItem->szPrefixName, sizeof(pItem->szPrefixName));
  153. strcpy( pItem->szPrefixName, pRec->Get( "FLD_PREFIXNAME") );
  155. pxUserItemRcdList->AddNewNode(pItem);
  156. }
  157. }
  158. GetDBManager()->DestroyRecordset( pRec );
  159. }
  161. BOOL GetHumanRcd(char *szName, _LPTHUMANRCD lptHumanRcd, _LPTLOADHUMAN lpLoadHuman)
  162. {
  163. char szQuery[1024];
  165. sprintf( szQuery, "SELECT * FROM TBL_CHARACTER WHERE FLD_CHARNAME='%s'", szName );
  167. CRecordset *pRec = GetDBManager()->CreateRecordset();
  169. if ( pRec->Execute( szQuery ) && pRec->Fetch() )
  170. {
  171. strcpy(lptHumanRcd->szUserID, pRec->Get( "FLD_LOGINID" ) );
  172. ChangeSpaceToNull(lptHumanRcd->szUserID);
  173. strcpy(lptHumanRcd->szCharName, pRec->Get( "FLD_CHARNAME" ) );
  174. ChangeSpaceToNull(lptHumanRcd->szCharName);
  176. lptHumanRcd->btJob = (BYTE)atoi( pRec->Get( "FLD_JOB" ) );
  177. lptHumanRcd->btGender = (BYTE)atoi( pRec->Get( "FLD_GENDER" ) );
  178. lptHumanRcd->szLevel = (BYTE)atoi( pRec->Get( "FLD_LEVEL" ) );
  179. lptHumanRcd->nDirection = (BYTE)atoi( pRec->Get( "FLD_DIRECTION" ) );
  180. lptHumanRcd->nCX = atoi( pRec->Get( "FLD_CX" ) );
  181. lptHumanRcd->nCY = atoi( pRec->Get( "FLD_CY" ) );
  183. lptHumanRcd->btAttackMode = atoi( pRec->Get( "FLD_ATTACKMODE" ) );
  184. lptHumanRcd->nExp = atoi( pRec->Get( "FLD_EXP" ) );
  186. strcpy( lptHumanRcd->szMapName, pRec->Get( "FLD_MAPNAME" ) );
  187. ChangeSpaceToNull( lptHumanRcd->szMapName );
  189. lptHumanRcd->dwGold = atoi( pRec->Get( "FLD_GOLD" ) );
  190. lptHumanRcd->szHair = atoi( pRec->Get( "FLD_HAIR" ) );
  192. memmove( lptHumanRcd->szTakeItem[0], pRec->Get( "FLD_DRESS_ID" ), 12 );
  193. memmove( lptHumanRcd->szTakeItem[1], pRec->Get( "FLD_WEAPON_ID" ), 12 );
  194. memmove( lptHumanRcd->szTakeItem[2], pRec->Get( "FLD_LEFTHAND_ID" ), 12 );
  195. memmove( lptHumanRcd->szTakeItem[3], pRec->Get( "FLD_RIGHTHAND_ID" ), 12 );
  196. memmove( lptHumanRcd->szTakeItem[4], pRec->Get( "FLD_HELMET_ID" ), 12 );
  197. memmove( lptHumanRcd->szTakeItem[5], pRec->Get( "FLD_NECKLACE_ID" ), 12 );
  198. memmove( lptHumanRcd->szTakeItem[6], pRec->Get( "FLD_ARMRINGL_ID" ), 12 );
  199. memmove( lptHumanRcd->szTakeItem[7], pRec->Get( "FLD_ARMRINGR_ID" ), 12 );
  200. memmove( lptHumanRcd->szTakeItem[8], pRec->Get( "FLD_RINGL_ID" ), 12 );
  201. memmove( lptHumanRcd->szTakeItem[9], pRec->Get( "FLD_RINGR_ID" ), 12 );
  203. lptHumanRcd->fIsAdmin = (BYTE)*pRec->Get( "FLD_ISADMIN" );
  204. }
  205. else
  206. {
  207. GetDBManager()->DestroyRecordset( pRec );
  208. return FALSE;
  209. }
  211. GetDBManager()->DestroyRecordset( pRec );
  213. return TRUE;
  214. }
  216. void GetLoadHumanRcd(CServerInfo* pServerInfo, _LPTLOADHUMAN lpLoadHuman, int nRecog)
  217. {
  218. if (!pServerInfo) return;
  220. _TDEFAULTMESSAGE DefMsg;
  222. char szEncodeMsg1[24];
  224. _THUMANRCD tHumanRcd;
  225. CWHList<_LPTUSERITEMRCD> xUserItemRcdList;
  226. CWHList<_LPTHUMANMAGICRCD> xUserMagicRcdList;
  227. CWHList<_LPTGENITEMRCD> xUserGenItemRcdList;
  229. _THORSERCD tHorseRcd;
  230. int nHorse = 0;
  232. char szEncodeMsg2[8096];
  234. if (GetHumanRcd(lpLoadHuman->szCharName, &tHumanRcd, lpLoadHuman)) // Fetch Character Data
  235. {
  236. GetHumanItemRcd(lpLoadHuman->szCharName, &xUserItemRcdList); // Fetch Item Data
  237. GetHumanMagicRcd(lpLoadHuman->szCharName, &xUserMagicRcdList); // Fetch Magic Data
  238. GetHumanGenItemRcd(lpLoadHuman->szCharName, &xUserGenItemRcdList); // Fetch General Item Data
  240. int nCount = xUserItemRcdList.GetCount();
  241. int nMagicCount = xUserMagicRcdList.GetCount();
  242. int nItemCount = xUserGenItemRcdList.GetCount();
  244. if (nCount)
  245. nHorse = GetHorseRcd(lpLoadHuman->szCharName, &tHorseRcd); // Fetch Horse Data
  247. if (nRecog)
  248. fnMakeDefMessageA(&DefMsg, DBR_LOADHUMANRCD, nRecog, MAKEWORD(nCount, nItemCount), nHorse, nMagicCount);
  249. else
  250. fnMakeDefMessageA(&DefMsg, DBR_LOADHUMANRCD2, nRecog, MAKEWORD(nCount, nItemCount), nHorse, nMagicCount);
  252. fnEncodeMessageA(&DefMsg, szEncodeMsg1, sizeof(szEncodeMsg1));
  254. int nPos = fnEncode6BitBufA((unsigned char *)&tHumanRcd, szEncodeMsg2, sizeof(_THUMANRCD), sizeof(szEncodeMsg2));
  256. if (nItemCount)
  257. {
  258. PLISTNODE pListNode = xUserGenItemRcdList.GetHead();
  260. while (pListNode)
  261. {
  262. _LPTGENITEMRCD lptItemRcd = xUserGenItemRcdList.GetData(pListNode);
  264. if (lptItemRcd)
  265. {
  266. nPos += fnEncode6BitBufA((unsigned char *)lptItemRcd, &szEncodeMsg2[nPos], sizeof(_TGENITEMRCD), sizeof(szEncodeMsg2) - nPos);
  268. pListNode = xUserGenItemRcdList.RemoveNode(pListNode);
  269. delete lptItemRcd;
  270. }
  271. else 
  272. pListNode = xUserGenItemRcdList.GetNext(pListNode);
  273. }
  274. }
  276. if (nMagicCount)
  277. {
  278. PLISTNODE pListNode = xUserMagicRcdList.GetHead();
  280. while (pListNode)
  281. {
  282. _LPTHUMANMAGICRCD lptUserMagicRcd = xUserMagicRcdList.GetData(pListNode);
  284. if (lptUserMagicRcd)
  285. {
  286. nPos += fnEncode6BitBufA((unsigned char *)lptUserMagicRcd, &szEncodeMsg2[nPos], sizeof(_THUMANMAGICRCD), sizeof(szEncodeMsg2) - nPos);
  288. pListNode = xUserMagicRcdList.RemoveNode(pListNode);
  289. delete lptUserMagicRcd;
  290. }
  291. else 
  292. pListNode = xUserMagicRcdList.GetNext(pListNode);
  293. }
  294. }
  296. if (nCount)
  297. {
  298. PLISTNODE pListNode = xUserItemRcdList.GetHead();
  300. while (pListNode)
  301. {
  302. _LPTUSERITEMRCD lptUserItemRcd = xUserItemRcdList.GetData(pListNode);
  304. if (lptUserItemRcd)
  305. {
  306. nPos += fnEncode6BitBufA((unsigned char *)lptUserItemRcd, &szEncodeMsg2[nPos], sizeof(_TUSERITEMRCD), sizeof(szEncodeMsg2) - nPos);
  308. pListNode = xUserItemRcdList.RemoveNode(pListNode);
  309. delete lptUserItemRcd;
  310. }
  311. else 
  312. pListNode = xUserItemRcdList.GetNext(pListNode);
  313. }
  315. if (nHorse)
  316. nPos += fnEncode6BitBufA((unsigned char *)&tHorseRcd, &szEncodeMsg2[nPos], sizeof(_THORSERCD), sizeof(szEncodeMsg2) - nPos);
  317. }
  319. szEncodeMsg2[nPos] = '';
  321. SendSocket(pServerInfo->m_sock, lpLoadHuman->nCertification, szEncodeMsg1, szEncodeMsg2, nPos);
  322. }
  323. else
  324. {
  325. fnMakeDefMessageA(&DefMsg, DBR_FAIL, nRecog, 0, 0, 0);
  326. fnEncodeMessageA(&DefMsg, szEncodeMsg1, sizeof(szEncodeMsg1));
  328. SendSocket(pServerInfo->m_sock, lpLoadHuman->nCertification, szEncodeMsg1, "Test", 4);
  329. }
  330. }
  332. char *SaveHumanMagicRcd(char *pszUserID, char *pszCharName, char *pszEncodeRcd, int nCount)
  333. {
  334. char szTmp[1024];
  336. // Delete Magic Data
  337. CRecordset *pRec = GetDBManager()->CreateRecordset();
  338. sprintf(szTmp, "DELETE FROM TBL_CHARACTER_MAGIC WHERE FLD_CHARNAME = '%s'", pszCharName);
  339. pRec->Execute(szTmp);
  340. GetDBManager()->DestroyRecordset( pRec );
  342. // Update Magic Data
  343. char *pszEncode = pszEncodeRcd;
  344. _THUMANMAGICRCD tUserMagicRcd;
  346. for (int i = 0; i < nCount; i++)
  347. {
  348. if ( memlen( pszEncode ) >= MAGICRCDBLOCKSIZE )
  349. {
  350. pRec = GetDBManager()->CreateRecordset();
  352. fnDecode6BitBufA( pszEncode, (char *) &tUserMagicRcd, sizeof( _THUMANMAGICRCD ) );
  354. sprintf(szTmp, "INSERT TBL_CHARACTER_MAGIC(FLD_LOGINID, FLD_CHARNAME, FLD_MAGICID, FLD_LEVEL, FLD_USEKEY, FLD_CURRTRAIN) VALUES "
  355. "( '%s', '%s', %d, %d, %d, %d )",
  356. pszUserID, pszCharName, tUserMagicRcd.btMagicID, tUserMagicRcd.btLevel, tUserMagicRcd.btUseKey, tUserMagicRcd.nCurrTrain);
  358. if ( !pRec->Execute( szTmp ) || pRec->GetRowCount() <= 0 )
  359. InsertLogMsg(_T("SaveHumanMagicRcd 盎脚 坷幅"));
  361. GetDBManager()->DestroyRecordset( pRec );
  363. pszEncode += MAGICRCDBLOCKSIZE + 1;
  364. }
  365. }
  367. return pszEncode;
  368. }
  370. void SaveGenItemRcd(char *pszUserID, char *pszCharName, char *pszEncodeRcd, int nCount)
  371. {
  372. char szTmp[1024];
  374. // Delete Magic Data
  375. CRecordset *pRec = GetDBManager()->CreateRecordset();
  376. sprintf(szTmp, "DELETE FROM TBL_CHARACTER_GENITEM WHERE FLD_CHARNAME = '%s'", pszCharName);
  377. pRec->Execute(szTmp);
  378. GetDBManager()->DestroyRecordset( pRec );
  380. // Update General Item Data
  381. sprintf( szTmp, "FLD_CHARNAME='%s'", pszCharName );
  383. CQueryManager query;
  385. char *pszEncode = pszEncodeRcd;
  386. _TGENITEMRCD tItemRcd;
  388. for (int i = 0; i < nCount; i++)
  389. {
  390. while ( memlen( pszEncode ) >= GENITEMRCDBLOCKSIZE )
  391. {
  392. pRec = GetDBManager()->CreateRecordset();
  394. ZeroMemory(&tItemRcd, sizeof(_TGENITEMRCD));
  396. fnDecode6BitBufA( pszEncode, (char *) &tItemRcd, sizeof( _TGENITEMRCD ) );
  398. sprintf(szTmp, "INSERT TBL_CHARACTER_GENITEM (FLD_LOGINID, FLD_CHARNAME, FLD_ITEMINDEX) VALUES "
  399. "( '%s', '%s', '%s' )", pszUserID, pszCharName, tItemRcd.szItem);
  401. if ( !pRec->Execute( szTmp ) || pRec->GetRowCount() <= 0 )
  402. InsertLogMsg(_T("SaveGenItemRcd 盎脚 坷幅"));
  404. GetDBManager()->DestroyRecordset( pRec );
  406. pszEncode += (GENITEMRCDBLOCKSIZE + 1);
  407. }
  408. }
  409. }
  411. BOOL SaveHumanRcd(CServerInfo* pServerInfo, _LPTLOADHUMAN lpLoadHuman, _LPTHUMANRCD lptHumanRcd, int nRecog)
  412. {
  413. char szSQL[1024];
  414. char szTakeItem[10][13];
  416. ZeroMemory(szTakeItem, sizeof(szTakeItem));
  418. for (int i = 0; i < 10; i++)
  419. memmove(szTakeItem[i], lptHumanRcd->szTakeItem[i], 12);
  421. sprintf(szSQL, "UPDATE TBL_CHARACTER SET FLD_JOB=%d, FLD_GENDER=%d, FLD_LEVEL=%d, FLD_DIRECTION=%d, FLD_CX=%d, FLD_CY=%d, "
  422. "FLD_MAPNAME='%s', FLD_GOLD=%d, FLD_HAIR=%d, FLD_DRESS_ID='%s', FLD_WEAPON_ID='%s', "
  423. "FLD_LEFTHAND_ID='%s', FLD_RIGHTHAND_ID='%s', FLD_HELMET_ID='%s', FLD_NECKLACE_ID='%s', "
  424. "FLD_ARMRINGL_ID='%s', FLD_ARMRINGR_ID='%s', FLD_RINGL_ID='%s', FLD_RINGR_ID='%s', FLD_EXP=%d "
  425. "WHERE FLD_CHARNAME='%s'",
  426. lptHumanRcd->btJob, lptHumanRcd->btGender, lptHumanRcd->szLevel, lptHumanRcd->nDirection,
  427. lptHumanRcd->nCX, lptHumanRcd->nCY, lptHumanRcd->szMapName, lptHumanRcd->dwGold,
  428. lptHumanRcd->szHair, szTakeItem[0], szTakeItem[1], szTakeItem[2], szTakeItem[3], szTakeItem[4], 
  429. szTakeItem[5], szTakeItem[6], szTakeItem[7], szTakeItem[8], szTakeItem[9], lptHumanRcd->nExp,
  430. lpLoadHuman->szCharName);
  432. CRecordset *pRec = GetDBManager()->CreateRecordset();
  434. if (!pRec->Execute( szSQL ) || pRec->GetRowCount() <= 0 )
  435. {
  436. InsertLogMsg(_T("SaveHumanRcd 盎脚 坷幅"));
  437. GetDBManager()->DestroyRecordset( pRec );
  438. return FALSE;
  439. }
  441. GetDBManager()->DestroyRecordset( pRec );
  443. return TRUE;
  444. }
  446. BOOL MakeNewItem(CServerInfo* pServerInfo, _LPTLOADHUMAN lpHumanLoad, _LPTMAKEITEMRCD lpMakeItemRcd, int nRecog)
  447. {
  448. static char  g_szYesterDay[24];
  449. static UINT  g_nItemIndexCnt = 0;
  451. CRecordset *pRec;
  453. char szQuery[1024];
  454. char szDate[24];
  455. GetDate( szDate );
  457. // if (strcmp(szDate, g_szYesterDay) != 0)
  458. // {
  459. sprintf( szQuery, 
  460. "SELECT * FROM TBL_CHARACTER_ITEM WHERE FLD_STDTYPE = '%c' AND "
  461. "FLD_MAKEDATE = '%s' ORDER BY FLD_MAKEINDEX DESC",
  462. lpMakeItemRcd->szStdType, szDate );
  464. pRec = GetDBManager()->CreateRecordset();
  465. if ( pRec->Execute( szQuery ) && pRec->Fetch() )
  466. {
  467. g_nItemIndexCnt = atoi( pRec->Get( "FLD_MAKEINDEX" ) ) + 1;
  468. }
  469. GetDBManager()->DestroyRecordset( pRec );
  471. strcpy( g_szYesterDay, szDate );
  472. // }
  473. // else
  474. // g_nItemIndexCnt++;
  476. char szUserID[32];
  477. char szCharName[32];
  479. if (lpHumanLoad)
  480. {
  481. strcpy(szUserID, lpHumanLoad->szUserID);
  482. strcpy(szCharName, lpHumanLoad->szCharName);
  483. }
  484. else
  485. {
  486. strcpy(szUserID, "0");
  487. strcpy(szCharName, "WEMADE");
  488. }
  490. sprintf(szQuery, "INSERT TBL_CHARACTER_ITEM (FLD_LOGINID, FLD_CHARNAME, FLD_STDTYPE, FLD_MAKEDATE, FLD_MAKEINDEX, "
  491. "FLD_STDINDEX, FLD_DURA, FLD_DURAMAX, FLD_VALUE1, FLD_VALUE2, FLD_VALUE3, FLD_VALUE4, FLD_VALUE5, "
  492. "FLD_VALUE6, FLD_VALUE7, FLD_VALUE8, FLD_VALUE9, FLD_VALUE10, FLD_VALUE11, FLD_VALUE12, FLD_VALUE13, "
  493. "FLD_VALUE14, FLD_LASTOWNER, FLD_LASTACTION, FLD_PREFIXNAME) "
  494. "VALUES( '%s', '%s', '%c', '%s', '%05d', %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, '%s', %d, '%s' )", 
  495. szUserID, szCharName, lpMakeItemRcd->szStdType, g_szYesterDay, g_nItemIndexCnt,
  496. lpMakeItemRcd->nStdIndex, lpMakeItemRcd->nDura, lpMakeItemRcd->nDuraMax, 
  497. lpMakeItemRcd->btValue[0], lpMakeItemRcd->btValue[1], lpMakeItemRcd->btValue[2], lpMakeItemRcd->btValue[3], 
  498. lpMakeItemRcd->btValue[5], lpMakeItemRcd->btValue[5], lpMakeItemRcd->btValue[6], lpMakeItemRcd->btValue[7], 
  499. lpMakeItemRcd->btValue[8], lpMakeItemRcd->btValue[9], lpMakeItemRcd->btValue[10], lpMakeItemRcd->btValue[11], 
  500. lpMakeItemRcd->btValue[12], lpMakeItemRcd->btValue[13], szCharName, 1, "");
  502. pRec = GetDBManager()->CreateRecordset();
  503. if ( !pRec->Execute( szQuery ) || pRec->GetRowCount() <= 0 )
  504. {
  505. GetDBManager()->DestroyRecordset( pRec );
  506. return FALSE;
  507. }
  508. GetDBManager()->DestroyRecordset( pRec );
  510. if ( pServerInfo )
  511. {
  512. // Send Packet to Game Server
  513. _TDEFAULTMESSAGE DefMsg;
  514. _TUSERITEMRCD UserItemRcd;
  516. char szEncodeMsg1[24];
  517. char szEncodeMsg2[128];
  518. int nPos = 0;
  520. if (lpHumanLoad)
  521. fnMakeDefMessageA(&DefMsg, DBR_MAKEITEMRCD, nRecog, 0, 0, 0);
  522. else
  523. fnMakeDefMessageA(&DefMsg, DBR_MAKEITEMRCD2, nRecog, 0, 0, 0);
  525. fnEncodeMessageA(&DefMsg, szEncodeMsg1, sizeof(szEncodeMsg1));
  527. UserItemRcd.szMakeIndex[0] = lpMakeItemRcd->szStdType;
  529. memcpy( &UserItemRcd.szMakeIndex[1], g_szYesterDay, 6 );
  530. sprintf( &UserItemRcd.szMakeIndex[7], "%d", g_nItemIndexCnt );
  532. memcpy(&UserItemRcd.nStdIndex, &lpMakeItemRcd->nStdIndex, sizeof(_TUSERITEMRCD) - sizeof(UserItemRcd.szMakeIndex));
  534. nPos = fnEncode6BitBufA((unsigned char *)&UserItemRcd, szEncodeMsg2, sizeof(_TUSERITEMRCD), sizeof(szEncodeMsg2));
  536. SendSocket(pServerInfo->m_sock, 2, szEncodeMsg1, szEncodeMsg2, nPos);
  537. }
  539. return TRUE;
  540. }
  542. UINT WINAPI ProcessDBMsg(LPVOID lpParameter)
  543. {
  544. while (TRUE)
  545. {
  546. if (g_fTerminated) return 0L;
  548. _LPTSENDBUFF pSendBuff = (_LPTSENDBUFF)g_DBMsgQ.PopQ();
  550. if (pSendBuff)
  551. {
  552. switch (pSendBuff->DefMsg.wIdent)
  553. {
  554. case DB_LOADHUMANRCD:
  555. GetLoadHumanRcd(pSendBuff->pServerInfo, &pSendBuff->HumanLoad, pSendBuff->DefMsg.nRecog);
  556. break;
  557. case DB_SAVEHUMANRCD:
  558. {
  559. SaveHumanRcd(pSendBuff->pServerInfo, &pSendBuff->HumanLoad, (_LPTHUMANRCD)pSendBuff->lpbtAddData, pSendBuff->DefMsg.nRecog);
  560. char *pszData = SaveHumanMagicRcd(pSendBuff->HumanLoad.szUserID, pSendBuff->HumanLoad.szCharName, (char *)pSendBuff->lpbtAddData2, pSendBuff->DefMsg.wParam);
  561. SaveGenItemRcd(pSendBuff->HumanLoad.szUserID, pSendBuff->HumanLoad.szCharName, pszData, pSendBuff->DefMsg.wTag);
  562. break;
  563. }
  564. case DB_MAKEITEMRCD:
  565. MakeNewItem(pSendBuff->pServerInfo, &pSendBuff->HumanLoad, (_LPTMAKEITEMRCD)pSendBuff->lpbtAddData, pSendBuff->DefMsg.nRecog);
  566. break;
  567. case DB_MAKEITEMRCD2:
  568. {
  569. _LPTUSERITEMRCD lptUserItemRcd = (_LPTUSERITEMRCD)pSendBuff->lpbtAddData;
  570. _TMAKEITEMRCD tMakeItemRcd;
  572. tMakeItemRcd.szStdType = lptUserItemRcd->szMakeIndex[0];
  573. tMakeItemRcd.nStdIndex = lptUserItemRcd->nStdIndex;
  574. tMakeItemRcd.nDura = lptUserItemRcd->nDura;
  575. tMakeItemRcd.nDuraMax = lptUserItemRcd->nDuraMax;
  576. memcpy(tMakeItemRcd.btValue, lptUserItemRcd->btValue, sizeof(lptUserItemRcd->btValue));
  578. MakeNewItem(pSendBuff->pServerInfo, NULL, &tMakeItemRcd, pSendBuff->DefMsg.nRecog);
  579. break;
  580. }
  581. } // switch
  583. delete pSendBuff;
  584. } // if (pSendBuff)
  586. SleepEx(1, TRUE);
  587. }
  589. return 0L;
  590. }