1. Service.h veya CommonDefines.h
  2. Ekle:
  3. #define REBOOT_LATER_RELOAD_ITEMS_PLAYER // Kaybolan Eşyaların Geri Yüklenmesi
  8. ClinetManagerPlayer.cpp
  9. Arat:
  10. bool CreateItemTableFromRes(MYSQL_RES * res, std::vector<TPlayerItem> * pVec, DWORD dwPID)
  11. {
  12. if (!res)
  13. {
  14. pVec->clear();
  15. return true;
  16. }
  18. int rows;
  20. if ((rows = mysql_num_rows(res)) <= 0) // µ¥ÀÌÅÍ ¾øÀ½
  21. {
  22. pVec->clear();
  23. return true;
  24. }
  26. pVec->resize(rows);
  28. Altına Ekle:
  30. #ifdef REBOOT_LATER_RELOAD_ITEMS_PLAYER
  31. std::vector<DWORD> m_recovery;
  32. std::vector<DWORD>::iterator it;
  34. char queryStr[256];
  35. bool bIsLoaded = false;
  36. sprintf(queryStr, "SELECT load_items FROM player WHERE id = %d", dwPID);
  37. std::unique_ptr<SQLMsg> pkMsg(CDBManager::instance().DirectQuery(queryStr));
  38. SQLResult * pRes = pkMsg->Get();
  39. if (pRes->uiNumRows)
  40. {
  41. MYSQL_ROW row = mysql_fetch_row(pRes->pSQLResult);
  42. bIsLoaded = atoi(row[0]);
  43. if (!bIsLoaded)
  44. {
  45. sprintf(queryStr, "UPDATE player SET load_items = 1 WHERE id = %d", dwPID);
  46. CDBManager::instance().DirectQuery(queryStr);
  47. }
  48. }
  50. for (int i = 0; i < rows; ++i)
  51. {
  52. MYSQL_ROW row = mysql_fetch_row(res);
  53. DWORD dwCount = 0;
  54. DWORD dwReelPos = 0;
  55. if (!bIsLoaded)
  56. {
  57. it = find(m_recovery.begin(), m_recovery.end(), atoi(row[0]));
  58. if (it != m_recovery.end())
  59. continue;
  60. sprintf(queryStr, "SELECT * FROM item WHERE pos = %d and vnum = %d and window = %d and owner_id = %d", atoi(row[2]), atoi(row[4]), atoi(row[1]), dwPID);
  61. std::unique_ptr<SQLMsg> pkMsg(CDBManager::instance().DirectQuery(queryStr));
  62. pRes = pkMsg->Get();
  63. if (pRes->uiNumRows > 1)
  64. {
  65. MYSQL_ROW row2 = mysql_fetch_row(pRes->pSQLResult);
  66. while ((row2 = mysql_fetch_row(pRes->pSQLResult)) != NULL)
  67. {
  68. dwCount += atoi(row2[4]);
  69. sprintf(queryStr, "DELETE FROM item WHERE id = %d", atoi(row2[0]));
  70. CDBManager::instance().DirectQuery(queryStr);
  71. m_recovery.push_back(atoi(row2[0]));
  72. }
  73. }
  75. sprintf(queryStr, "SELECT id FROM item WHERE pos = %d and window = %d and owner_id = %d", atoi(row[2]), atoi(row[1]), dwPID);
  76. std::unique_ptr<SQLMsg> pkMsg2(CDBManager::instance().DirectQuery(queryStr));
  77. pRes = pkMsg2->Get();
  78. if (pRes->uiNumRows > 1)
  79. {
  80. DWORD dwPos = atoi(row[2]);
  81. for (int i = 0; i < 180; ++i)
  82. {
  83. dwPos++;
  84. sprintf(queryStr, "SELECT id FROM item WHERE window = %d and owner_id = %d and pos = %d", atoi(row[1]), dwPID, dwPos);
  85. std::unique_ptr<SQLMsg> pkMsg3(CDBManager::instance().DirectQuery(queryStr));
  86. SQLResult * pRes2 = pkMsg3->Get();
  87. if (!pRes2->uiNumRows)
  88. break;
  89. }
  90. sprintf(queryStr, "UPDATE item SET pos = %d WHERE id = %d", dwPos, atoi(row[0]));
  91. CDBManager::instance().DirectQuery(queryStr);
  92. dwReelPos = dwPos;
  93. }
  94. }
  95. TPlayerItem & item = pVec->at(i);
  97. int cur = 0;
  99. str_to_number(item.id, row[cur++]);
  100. str_to_number(item.window, row[cur++]);
  101. if (dwReelPos)
  102. {
  103. item.pos = dwReelPos;
  104. cur++;
  105. }
  106. else
  107. str_to_number(item.pos, row[cur++]);
  108. str_to_number(item.count, row[cur++]);
  109. item.count += dwCount;
  110. str_to_number(item.vnum, row[cur++]);
  111. str_to_number(item.is_basic, row[cur++]);
  112. #ifdef __ENABLE_CHANGELOOK_SYSTEM__
  113. str_to_number(item.transmutation, row[cur++]);
  114. #endif
  115. str_to_number(item.alSockets[0], row[cur++]);
  116. str_to_number(item.alSockets[1], row[cur++]);
  117. str_to_number(item.alSockets[2], row[cur++]);
  118. str_to_number(item.alSockets[3], row[cur++]);
  119. #ifdef ENABLE_PET_SYSTEM
  120. str_to_number(item.alSockets[4], row[cur++]);
  121. str_to_number(item.alSockets[5], row[cur++]);
  122. #endif
  124. for (int j = 0; j < ITEM_ATTRIBUTE_MAX_NUM; j++)
  125. {
  126. str_to_number(item.aAttr[j].bType, row[cur++]);
  127. str_to_number(item.aAttr[j].sValue, row[cur++]);
  128. }
  130. #ifdef __ENABLE_SOULBIND_SYSTEM__
  131. str_to_number(item.sealbind, row[cur++]);
  132. #endif
  133. item.owner = dwPID;
  134. }
  135. #else
  136. for (int i = 0; i < rows; ++i)
  137. {
  138. MYSQL_ROW row = mysql_fetch_row(res);
  139. TPlayerItem & item = pVec->at(i);
  141. int cur = 0;
  143. // Check all SELECT syntax on item table before change this function!!!
  144. // Check all SELECT syntax on item table before change this function!!!
  145. // Check all SELECT syntax on item table before change this function!!!
  146. str_to_number(item.id, row[cur++]);
  147. str_to_number(item.window, row[cur++]);
  148. str_to_number(item.pos, row[cur++]);
  149. str_to_number(item.count, row[cur++]);
  150. str_to_number(item.vnum, row[cur++]);
  151. str_to_number(item.is_basic, row[cur++]);
  152. #ifdef __ENABLE_CHANGELOOK_SYSTEM__
  153. str_to_number(item.transmutation, row[cur++]);
  154. #endif
  155. str_to_number(item.alSockets[0], row[cur++]);
  156. str_to_number(item.alSockets[1], row[cur++]);
  157. str_to_number(item.alSockets[2], row[cur++]);
  158. str_to_number(item.alSockets[3], row[cur++]);
  159. #ifdef ENABLE_PET_SYSTEM
  160. str_to_number(item.alSockets[4], row[cur++]);
  161. str_to_number(item.alSockets[5], row[cur++]);
  162. #endif
  164. for (int j = 0; j < ITEM_ATTRIBUTE_MAX_NUM; j++)
  165. {
  166. str_to_number(item.aAttr[j].bType, row[cur++]);
  167. str_to_number(item.aAttr[j].sValue, row[cur++]);
  168. }
  170. #ifdef __ENABLE_SOULBIND_SYSTEM__
  171. str_to_number(item.sealbind, row[cur++]);
  172. #endif
  173. #ifdef ENABLE_RENTITEM_SYSTEM
  174. str_to_number(item.dwRentTime, row[cur++]);
  175. str_to_number(item.dwRentOwner, row[cur++]);
  176. #endif
  177. item.owner = dwPID;
  178. }
  179. #endif
  180. return true;
  181. }