1. #include "stdafx.h"
  2. #include "Cache.h"
  4. #include "QID.h"
  5. #include "ClientManager.h"
  6. #ifdef __AUCTION__
  7. #include "AuctionManager.h"
  8. #endif
  9. #include "Main.h"
  11. extern CPacketInfo g_item_info;
  12. extern int g_iPlayerCacheFlushSeconds;
  13. extern int g_iItemCacheFlushSeconds;
  14. extern int g_test_server;
  15. // MYSHOP_PRICE_LIST
  16. extern int g_iItemPriceListTableCacheFlushSeconds;
  17. // END_OF_MYSHOP_PRICE_LIST
  18. //
  19. extern int g_item_count;
  20. const int auctionMinFlushSec = 1800;
  22. CItemCache::CItemCache()
  23. {
  24. m_expireTime = MIN(1800, g_iItemCacheFlushSeconds);
  25. }
  27. CItemCache::~CItemCache()
  28. {
  29. }
  31. // ÀÌ°Å ÀÌ»óÇѵ¥...
  32. // Delete¸¦ ÇßÀ¸¸é, Cacheµµ ÇØÁ¦ÇØ¾ß ÇÏ´Â°Í ¾Æ´Ñ°¡???
  33. // ±Ùµ¥ Cache¸¦ ÇØÁ¦ÇÏ´Â ºÎºĞÀÌ ¾ø¾î.
  34. // ¸ø ãÀº °Ç°¡?
  35. // ÀÌ·¸°Ô ÇسõÀ¸¸é, °è¼Ó ½Ã°£ÀÌ µÉ ¶§¸¶´Ù ¾ÆÀÌÅÛÀ» °è¼Ó Áö¿ö...
  36. // ÀÌ¹Ì »ç¶óÁø ¾ÆÀÌÅÛÀε¥... È®Àλç»ì??????
  37. // fixme
  38. // by rtsummit
  39. void CItemCache::Delete()
  40. {
  41. if (m_data.vnum == 0)
  42. return;
  44. //char szQuery[QUERY_MAX_LEN];
  45. //szQuery[QUERY_MAX_LEN] = '\0';
  46. if (g_test_server)
  47. sys_log(0, "ItemCache::Delete : DELETE %u", m_data.id);
  49. m_data.vnum = 0;
  50. m_bNeedQuery = true;
  51. m_lastUpdateTime = time(0);
  52. OnFlush();
  54. //m_bNeedQuery = false;
  55. //m_lastUpdateTime = time(0) - m_expireTime; // ¹Ù·Î ŸÀӾƿô µÇµµ·Ï ÇÏÀÚ.
  56. }
  58. void CItemCache::OnFlush()
  59. {
  60. if (m_data.vnum == 0) // vnumÀÌ 0ÀÌ¸é »èÁ¦Ç϶ó°í Ç¥½ÃµÈ °ÍÀÌ´Ù.
  61. {
  62. char szQuery[QUERY_MAX_LEN];
  63. snprintf(szQuery, sizeof(szQuery), "DELETE FROM item%s WHERE id=%u", GetTablePostfix(), m_data.id);
  64. CDBManager::instance().ReturnQuery(szQuery, QID_ITEM_DESTROY, 0, NULL);
  66. if (g_test_server)
  67. sys_log(0, "ItemCache::Flush : DELETE %u %s", m_data.id, szQuery);
  68. }
  69. else
  70. {
  71. long alSockets[ITEM_SOCKET_MAX_NUM];
  72. TPlayerItemAttribute aAttr[ITEM_ATTRIBUTE_MAX_NUM];
  73. bool isSocket = false, isAttr = false;
  75. memset(&alSockets, 0, sizeof(long) * ITEM_SOCKET_MAX_NUM);
  76. memset(&aAttr, 0, sizeof(TPlayerItemAttribute) * ITEM_ATTRIBUTE_MAX_NUM);
  78. TPlayerItem * p = &m_data;
  80. if (memcmp(alSockets, p->alSockets, sizeof(long) * ITEM_SOCKET_MAX_NUM))
  81. isSocket = true;
  83. if (memcmp(aAttr, p->aAttr, sizeof(TPlayerItemAttribute) * ITEM_ATTRIBUTE_MAX_NUM))
  84. isAttr = true;
  86. char szColumns[QUERY_MAX_LEN];
  87. char szValues[QUERY_MAX_LEN];
  88. char szUpdate[QUERY_MAX_LEN];
  90. int iLen = snprintf(szColumns, sizeof(szColumns), "id, owner_id, window, pos, count, vnum");
  92. int iValueLen = snprintf(szValues, sizeof(szValues), "%u, %u, %d, %d, %u, %u",
  93. p->id, p->owner, p->window, p->pos, p->count, p->vnum);
  95. int iUpdateLen = snprintf(szUpdate, sizeof(szUpdate), "owner_id=%u, window=%d, pos=%d, count=%u, vnum=%u",
  96. p->owner, p->window, p->pos, p->count, p->vnum);
  98. if (isSocket)
  99. {
  100. iLen += snprintf(szColumns + iLen, sizeof(szColumns) - iLen, ", socket0, socket1, socket2, socket3");
  101. iValueLen += snprintf(szValues + iValueLen, sizeof(szValues) - iValueLen,
  102. ", %lu, %lu, %lu, %lu", p->alSockets[0], p->alSockets[1], p->alSockets[2], p->alSockets[3]);
  103. iUpdateLen += snprintf(szUpdate + iUpdateLen, sizeof(szUpdate) - iUpdateLen,
  104. ", socket0=%lu, socket1=%lu, socket2=%lu, socket3=%lu", p->alSockets[0], p->alSockets[1], p->alSockets[2], p->alSockets[3]);
  105. }
  107. if (isAttr)
  108. {
  109. iLen += snprintf(szColumns + iLen, sizeof(szColumns) - iLen,
  110. ", attrtype0, attrvalue0, attrtype1, attrvalue1, attrtype2, attrvalue2, attrtype3, attrvalue3"
  111. ", attrtype4, attrvalue4, attrtype5, attrvalue5, attrtype6, attrvalue6");
  113. iValueLen += snprintf(szValues + iValueLen, sizeof(szValues) - iValueLen,
  114. ", %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d",
  115. p->aAttr[0].bType, p->aAttr[0].sValue,
  116. p->aAttr[1].bType, p->aAttr[1].sValue,
  117. p->aAttr[2].bType, p->aAttr[2].sValue,
  118. p->aAttr[3].bType, p->aAttr[3].sValue,
  119. p->aAttr[4].bType, p->aAttr[4].sValue,
  120. p->aAttr[5].bType, p->aAttr[5].sValue,
  121. p->aAttr[6].bType, p->aAttr[6].sValue);
  123. iUpdateLen += snprintf(szUpdate + iUpdateLen, sizeof(szUpdate) - iUpdateLen,
  124. ", attrtype0=%d, attrvalue0=%d"
  125. ", attrtype1=%d, attrvalue1=%d"
  126. ", attrtype2=%d, attrvalue2=%d"
  127. ", attrtype3=%d, attrvalue3=%d"
  128. ", attrtype4=%d, attrvalue4=%d"
  129. ", attrtype5=%d, attrvalue5=%d"
  130. ", attrtype6=%d, attrvalue6=%d",
  131. p->aAttr[0].bType, p->aAttr[0].sValue,
  132. p->aAttr[1].bType, p->aAttr[1].sValue,
  133. p->aAttr[2].bType, p->aAttr[2].sValue,
  134. p->aAttr[3].bType, p->aAttr[3].sValue,
  135. p->aAttr[4].bType, p->aAttr[4].sValue,
  136. p->aAttr[5].bType, p->aAttr[5].sValue,
  137. p->aAttr[6].bType, p->aAttr[6].sValue);
  138. }
  140. char szItemQuery[QUERY_MAX_LEN + QUERY_MAX_LEN];
  141. snprintf(szItemQuery, sizeof(szItemQuery), "REPLACE INTO item%s (%s) VALUES(%s)", GetTablePostfix(), szColumns, szValues);
  143. if (g_test_server)
  144. sys_log(0, "ItemCache::Flush :REPLACE (%s)", szItemQuery);
  146. CDBManager::instance().ReturnQuery(szItemQuery, QID_ITEM_SAVE, 0, NULL);
  148. //g_item_info.Add(p->vnum);
  149. ++g_item_count;
  150. }
  152. m_bNeedQuery = false;
  153. }
  155. //
  156. // CPlayerTableCache
  157. //
  158. CPlayerTableCache::CPlayerTableCache()
  159. {
  160. m_expireTime = MIN(1800, g_iPlayerCacheFlushSeconds);
  161. }
  163. CPlayerTableCache::~CPlayerTableCache()
  164. {
  165. }
  167. void CPlayerTableCache::OnFlush()
  168. {
  169. if (g_test_server)
  170. sys_log(0, "PlayerTableCache::Flush : %s", m_data.name);
  172. char szQuery[QUERY_MAX_LEN];
  173. CreatePlayerSaveQuery(szQuery, sizeof(szQuery), &m_data);
  174. CDBManager::instance().ReturnQuery(szQuery, QID_PLAYER_SAVE, 0, NULL);
  175. }
  177. // MYSHOP_PRICE_LIST
  178. //
  179. // CItemPriceListTableCache class implementation
  180. //
  182. const int CItemPriceListTableCache::s_nMinFlushSec = 1800;
  184. CItemPriceListTableCache::CItemPriceListTableCache()
  185. {
  186. m_expireTime = MIN(s_nMinFlushSec, g_iItemPriceListTableCacheFlushSeconds);
  187. }
  189. void CItemPriceListTableCache::UpdateList(const TItemPriceListTable* pUpdateList)
  190. {
  191. //
  192. // ÀÌ¹Ì Ä³½ÌµÈ ¾ÆÀÌÅÛ°ú Áߺ¹µÈ ¾ÆÀÌÅÛÀ» ã°í Áߺ¹µÇÁö ¾Ê´Â ÀÌÀü Á¤º¸´Â tmpvec ¿¡ ³Ö´Â´Ù.
  193. //
  195. std::vector<TItemPriceInfo> tmpvec;
  197. for (uint idx = 0; idx < m_data.byCount; ++idx)
  198. {
  199. const TItemPriceInfo* pos = pUpdateList->aPriceInfo;
  200. for (; pos != pUpdateList->aPriceInfo + pUpdateList->byCount && m_data.aPriceInfo[idx].dwVnum != pos->dwVnum; ++pos)
  201. ;
  203. if (pos == pUpdateList->aPriceInfo + pUpdateList->byCount)
  204. tmpvec.push_back(m_data.aPriceInfo[idx]);
  205. }
  207. //
  208. // pUpdateList ¸¦ m_data ¿¡ º¹»çÇÏ°í ³²Àº °ø°£À» tmpvec ÀÇ ¾Õ¿¡¼­ ºÎÅÍ ³²Àº ¸¸Å­ º¹»çÇÑ´Ù.
  209. //
  211. if (pUpdateList->byCount > SHOP_PRICELIST_MAX_NUM)
  212. {
  213. sys_err("Count overflow!");
  214. return;
  215. }
  217. m_data.byCount = pUpdateList->byCount;
  219. thecore_memcpy(m_data.aPriceInfo, pUpdateList->aPriceInfo, sizeof(TItemPriceInfo) * pUpdateList->byCount);
  221. int nDeletedNum; // »èÁ¦µÈ °¡°İÁ¤º¸ÀÇ °¹¼ö
  223. if (pUpdateList->byCount < SHOP_PRICELIST_MAX_NUM)
  224. {
  225. size_t sizeAddOldDataSize = SHOP_PRICELIST_MAX_NUM - pUpdateList->byCount;
  227. if (tmpvec.size() < sizeAddOldDataSize)
  228. sizeAddOldDataSize = tmpvec.size();
  230. thecore_memcpy(m_data.aPriceInfo + pUpdateList->byCount, &tmpvec[0], sizeof(TItemPriceInfo) * sizeAddOldDataSize);
  231. m_data.byCount += sizeAddOldDataSize;
  233. nDeletedNum = tmpvec.size() - sizeAddOldDataSize;
  234. }
  235. else
  236. nDeletedNum = tmpvec.size();
  238. m_bNeedQuery = true;
  240. sys_log(0,
  241. "ItemPriceListTableCache::UpdateList : OwnerID[%u] Update [%u] Items, Delete [%u] Items, Total [%u] Items",
  242. m_data.dwOwnerID, pUpdateList->byCount, nDeletedNum, m_data.byCount);
  243. }
  245. void CItemPriceListTableCache::OnFlush()
  246. {
  247. char szQuery[QUERY_MAX_LEN];
  249. //
  250. // ÀÌ Ä³½ÃÀÇ ¼ÒÀ¯ÀÚ¿¡ ´ëÇÑ ±âÁ¸¿¡ DB ¿¡ ÀúÀåµÈ ¾ÆÀÌÅÛ °¡°İÁ¤º¸¸¦ ¸ğµÎ »èÁ¦ÇÑ´Ù.
  251. //
  253. snprintf(szQuery, sizeof(szQuery), "DELETE FROM myshop_pricelist%s WHERE owner_id = %u", GetTablePostfix(), m_data.dwOwnerID);
  254. CDBManager::instance().ReturnQuery(szQuery, QID_ITEMPRICE_DESTROY, 0, NULL);
  256. //
  257. // ij½ÃÀÇ ³»¿ëÀ» ¸ğµÎ DB ¿¡ ¾´´Ù.
  258. //
  260. for (int idx = 0; idx < m_data.byCount; ++idx)
  261. {
  262. snprintf(szQuery, sizeof(szQuery),
  263. #ifdef ENABLE_CHEQUE_SYSTEM
  264. "INSERT INTO myshop_pricelist%s(owner_id, item_vnum, price, cheque) VALUES(%u, %u, %u, %u)",
  265. GetTablePostfix(), m_data.dwOwnerID, m_data.aPriceInfo[idx].dwVnum, m_data.aPriceInfo[idx].price.dwPrice, m_data.aPriceInfo[idx].price.byChequePrice);
  266. #else
  267. "INSERT INTO myshop_pricelist%s(owner_id, item_vnum, price) VALUES(%u, %u, %u)",
  268. GetTablePostfix(), m_data.dwOwnerID, m_data.aPriceInfo[idx].dwVnum, m_data.aPriceInfo[idx].dwPrice);
  269. #endif
  270. CDBManager::instance().ReturnQuery(szQuery, QID_ITEMPRICE_SAVE, 0, NULL);
  271. }
  273. sys_log(0, "ItemPriceListTableCache::Flush : OwnerID[%u] Update [%u]Items", m_data.dwOwnerID, m_data.byCount);
  275. m_bNeedQuery = false;
  276. }
  277. // END_OF_MYSHOP_PRICE_LIST
  278. #ifdef __AUCTION__
  279. CAuctionItemInfoCache::CAuctionItemInfoCache()
  280. {
  281. m_expireTime = MIN (auctionMinFlushSec, g_iItemCacheFlushSeconds);
  282. }
  284. CAuctionItemInfoCache::~CAuctionItemInfoCache()
  285. {
  287. }
  289. void CAuctionItemInfoCache::Delete()
  290. {
  291. if (m_data.item_num == 0)
  292. return;
  294. if (g_test_server)
  295. sys_log(0, "CAuctionItemInfoCache::Delete : DELETE %u", m_data.item_id);
  297. m_data.item_num = 0;
  298. m_bNeedQuery = true;
  299. m_lastUpdateTime = time(0);
  300. OnFlush();
  301. delete this;
  302. }
  304. void CAuctionItemInfoCache::OnFlush()
  305. {
  306. char szQuery[QUERY_MAX_LEN];
  308. if (m_data.item_num == 0)
  309. {
  310. snprintf(szQuery, sizeof(szQuery), "DELETE FROM auction where item_id = %d", m_data.item_id);
  311. CDBManager::instance().AsyncQuery(szQuery);
  312. }
  313. else
  314. {
  315. snprintf(szQuery, sizeof(szQuery), "REPLACE INTO auction VALUES (%u, %d, %d, %u, \"%s\", %u, %u, %u, %u)",
  316. m_data.item_num, m_data.offer_price, m_data.price, m_data.offer_id, m_data.shown_name, (DWORD)m_data.empire, (DWORD)m_data.expired_time,
  317. m_data.item_id, m_data.bidder_id);
  319. CDBManager::instance().AsyncQuery(szQuery);
  320. }
  321. }
  323. CSaleItemInfoCache::CSaleItemInfoCache()
  324. {
  325. m_expireTime = MIN (auctionMinFlushSec, g_iItemCacheFlushSeconds);
  326. }
  328. CSaleItemInfoCache::~CSaleItemInfoCache()
  329. {
  330. }
  332. void CSaleItemInfoCache::Delete()
  333. {
  334. }
  336. void CSaleItemInfoCache::OnFlush()
  337. {
  338. char szQuery[QUERY_MAX_LEN];
  340. snprintf(szQuery, sizeof(szQuery), "REPLACE INTO sale VALUES (%u, %d, %d, %u, \"%s\", %u, %u, %u, %u)",
  341. m_data.item_num, m_data.offer_price, m_data.price, m_data.offer_id, m_data.shown_name, (DWORD)m_data.empire, (DWORD)m_data.expired_time,
  342. m_data.item_id, m_data.wisher_id);
  344. CDBManager::instance().AsyncQuery(szQuery);
  345. }
  347. CWishItemInfoCache::CWishItemInfoCache()
  348. {
  349. m_expireTime = MIN (auctionMinFlushSec, g_iItemCacheFlushSeconds);
  350. }
  352. CWishItemInfoCache::~CWishItemInfoCache()
  353. {
  354. }
  356. void CWishItemInfoCache::Delete()
  357. {
  358. }
  360. void CWishItemInfoCache::OnFlush()
  361. {
  362. char szQuery[QUERY_MAX_LEN];
  364. snprintf(szQuery, sizeof(szQuery), "REPLACE INTO wish VALUES (%u, %d, %d, %u, \"%s\", %u, %d)",
  365. m_data.item_num, m_data.offer_price, m_data.price, m_data.offer_id, m_data.shown_name, (DWORD)m_data.empire, (DWORD)m_data.expired_time);
  367. CDBManager::instance().AsyncQuery(szQuery);
  368. }
  369. #endif