1. #include "stdafx.h"
  2. #include "constants.h"
  3. #include "config.h"
  4. #include "log.h"
  6. #include "char.h"
  7. #include "desc.h"
  8. #include "item.h"
  9. #include "locale_service.h"
  11. static char __escape_hint[1024];
  13. LogManager::LogManager() : m_bIsConnect(false)
  14. {
  15. }
  17. LogManager::~LogManager()
  18. {
  19. }
  21. bool LogManager::Connect(const char * host, const int port, const char * user, const char * pwd, const char * db)
  22. {
  23. if (m_sql.Setup(host, user, pwd, db, g_stLocale.c_str(), false, port))
  24. m_bIsConnect = true;
  26. return m_bIsConnect;
  27. }
  29. void LogManager::Query(const char* c_pszFormat, ...)
  30. {
  31. char szQuery[4096];
  32. va_list args;
  34. va_start(args, c_pszFormat);
  35. vsnprintf(szQuery, sizeof(szQuery), c_pszFormat, args);
  36. va_end(args);
  38. if (test_server)
  39. sys_log(0, "LOG: %s", szQuery);
  41. std::string sQuery(szQuery);
  42. m_sql.AsyncQuery(sQuery.substr(0, sQuery.find_first_of(";") == -1 ? sQuery.length() : sQuery.find_first_of(";")).c_str());
  43. }
  45. void LogManager::ItemLog(DWORD dwPID, DWORD x, DWORD y, DWORD dwItemID, const char * c_pszText, const char * c_pszHint, const char * c_pszIP, DWORD dwVnum)
  46. {
  47. m_sql.EscapeString(__escape_hint, sizeof(__escape_hint), c_pszHint, strlen(c_pszHint));
  49. Query("INSERT DELAYED INTO log%s (type, time, who, x, y, what, how, hint, ip, vnum) VALUES('ITEM', NOW(), %u, %u, %u, %u, '%s', '%s', '%s', %u)",
  50. get_table_postfix(), dwPID, x, y, dwItemID, c_pszText, __escape_hint, c_pszIP, dwVnum);
  51. }
  53. void LogManager::ItemLog(LPCHARACTER ch, LPITEM item, const char * c_pszText, const char * c_pszHint)
  54. {
  55. if (NULL == ch || NULL == item)
  56. {
  57. sys_err("character or item nil (ch %p item %p text %s)", get_pointer(ch), get_pointer(item), c_pszText);
  58. return;
  59. }
  61. ItemLog(ch->GetPlayerID(), ch->GetX(), ch->GetY(), item->GetID(),
  62. NULL == c_pszText ? "" : c_pszText,
  63. c_pszHint, ch->GetDesc() ? ch->GetDesc()->GetHostName() : "",
  64. item->GetOriginalVnum());
  65. }
  67. void LogManager::ItemLog(LPCHARACTER ch, int itemID, int itemVnum, const char * c_pszText, const char * c_pszHint)
  68. {
  69. ItemLog(ch->GetPlayerID(), ch->GetX(), ch->GetY(), itemID, c_pszText, c_pszHint, ch->GetDesc() ? ch->GetDesc()->GetHostName() : "", itemVnum);
  70. }
  72. void LogManager::CharLog(DWORD dwPID, DWORD x, DWORD y, DWORD dwValue, const char * c_pszText, const char * c_pszHint, const char * c_pszIP)
  73. {
  74. m_sql.EscapeString(__escape_hint, sizeof(__escape_hint), c_pszHint, strlen(c_pszHint));
  76. Query("INSERT DELAYED INTO log%s (type, time, who, x, y, what, how, hint, ip) VALUES('CHARACTER', NOW(), %u, %u, %u, %u, '%s', '%s', '%s')",
  77. get_table_postfix(), dwPID, x, y, dwValue, c_pszText, __escape_hint, c_pszIP);
  78. }
  80. void LogManager::CharLog(LPCHARACTER ch, DWORD dw, const char * c_pszText, const char * c_pszHint)
  81. {
  82. if (ch)
  83. CharLog(ch->GetPlayerID(), ch->GetX(), ch->GetY(), dw, c_pszText, c_pszHint, ch->GetDesc() ? ch->GetDesc()->GetHostName() : "");
  84. else
  85. CharLog(0, 0, 0, dw, c_pszText, c_pszHint, "");
  86. }
  88. void LogManager::LoginLog(bool isLogin, DWORD dwAccountID, DWORD dwPID, BYTE bLevel, BYTE bJob, DWORD dwPlayTime)
  89. {
  90. Query("INSERT DELAYED INTO loginlog%s (type, time, channel, account_id, pid, level, job, playtime) VALUES (%s, NOW(), %d, %u, %u, %d, %d, %u)",
  91. get_table_postfix(), isLogin ? "'LOGIN'" : "'LOGOUT'", g_bChannel, dwAccountID, dwPID, bLevel, bJob, dwPlayTime);
  92. }
  94. void LogManager::MoneyLog(BYTE type, DWORD vnum, int gold)
  95. {
  96. if (type == MONEY_LOG_RESERVED || type >= MONEY_LOG_TYPE_MAX_NUM)
  97. {
  98. sys_err("TYPE ERROR: type %d vnum %u gold %d", type, vnum, gold);
  99. return;
  100. }
  102. Query("INSERT DELAYED INTO money_log%s VALUES (NOW(), %d, %d, %d)", get_table_postfix(), type, vnum, gold);
  103. }
  105. void LogManager::HackLog(const char * c_pszHackName, const char * c_pszLogin, const char * c_pszName, const char * c_pszIP)
  106. {
  107. m_sql.EscapeString(__escape_hint, sizeof(__escape_hint), c_pszHackName, strlen(c_pszHackName));
  109. Query("INSERT INTO hack_log (time, login, name, ip, server, why) VALUES(NOW(), '%s', '%s', '%s', '%s', '%s')", c_pszLogin, c_pszName, c_pszIP, g_stHostname.c_str(), __escape_hint);
  110. }
  112. void LogManager::HackLog(const char * c_pszHackName, LPCHARACTER ch)
  113. {
  114. if (ch->GetDesc())
  115. {
  116. HackLog(c_pszHackName,
  117. ch->GetDesc()->GetAccountTable().login,
  118. ch->GetName(),
  119. ch->GetDesc()->GetHostName());
  120. }
  121. }
  123. void LogManager::HackCRCLog(const char * c_pszHackName, const char * c_pszLogin, const char * c_pszName, const char * c_pszIP, DWORD dwCRC)
  124. {
  125. Query("INSERT INTO hack_crc_log (time, login, name, ip, server, why, crc) VALUES(NOW(), '%s', '%s', '%s', '%s', '%s', %u)", c_pszLogin, c_pszName, c_pszIP, g_stHostname.c_str(), c_pszHackName, dwCRC);
  126. }
  128. void LogManager::PCBangLoginLog(DWORD dwPCBangID, const char* c_szPCBangIP, DWORD dwPlayerID, DWORD dwPlayTime)
  129. {
  130. Query("INSERT INTO pcbang_loginlog (time, pcbang_id, ip, pid, play_time) VALUES (NOW(), %u, '%s', %u, %u)",
  131. dwPCBangID, c_szPCBangIP, dwPlayerID, dwPlayTime);
  132. }
  134. void LogManager::GoldBarLog(DWORD dwPID, DWORD dwItemID, GOLDBAR_HOW eHow, const char* c_pszHint)
  135. {
  136. char szHow[32+1];
  138. switch (eHow)
  139. {
  140. case PERSONAL_SHOP_BUY:
  141. snprintf(szHow, sizeof(szHow), "'BUY'");
  142. break;
  144. case PERSONAL_SHOP_SELL:
  145. snprintf(szHow, sizeof(szHow), "'SELL'");
  146. break;
  148. case SHOP_BUY:
  149. snprintf(szHow, sizeof(szHow), "'SHOP_BUY'");
  150. break;
  152. case SHOP_SELL:
  153. snprintf(szHow, sizeof(szHow), "'SHOP_SELL'");
  154. break;
  156. case EXCHANGE_TAKE:
  157. snprintf(szHow, sizeof(szHow), "'EXCHANGE_TAKE'");
  158. break;
  160. case EXCHANGE_GIVE:
  161. snprintf(szHow, sizeof(szHow), "'EXCHANGE_GIVE'");
  162. break;
  164. case QUEST:
  165. snprintf(szHow, sizeof(szHow), "'QUEST'");
  166. break;
  168. default:
  169. snprintf(szHow, sizeof(szHow), "''");
  170. break;
  171. }
  173. Query("INSERT DELAYED INTO goldlog%s (date, time, pid, what, how, hint) VALUES(CURDATE(), CURTIME(), %u, %u, %s, '%s')",
  174. get_table_postfix(), dwPID, dwItemID, szHow, c_pszHint);
  175. }
  177. void LogManager::CubeLog(DWORD dwPID, DWORD x, DWORD y, DWORD item_vnum, DWORD item_uid, int item_count, bool success)
  178. {
  179. Query("INSERT DELAYED INTO cube%s (pid, time, x, y, item_vnum, item_uid, item_count, success) "
  180. "VALUES(%u, NOW(), %u, %u, %u, %u, %d, %d)",
  181. get_table_postfix(), dwPID, x, y, item_vnum, item_uid, item_count, success?1:0);
  182. }
  184. void LogManager::SpeedHackLog(DWORD pid, DWORD x, DWORD y, int hack_count)
  185. {
  186. Query("INSERT INTO speed_hack%s (pid, time, x, y, hack_count) "
  187. "VALUES(%u, NOW(), %u, %u, %d)",
  188. get_table_postfix(), pid, x, y, hack_count);
  189. }
  191. void LogManager::ChangeNameLog(DWORD pid, const char *old_name, const char *new_name, const char *ip)
  192. {
  193. Query("INSERT DELAYED INTO change_name%s (pid, old_name, new_name, time, ip) "
  194. "VALUES(%u, '%s', '%s', NOW(), '%s') ",
  195. get_table_postfix(), pid, old_name, new_name, ip);
  196. }
  198. void LogManager::GMCommandLog(DWORD dwPID, const char* szName, const char* szIP, BYTE byChannel, const char* szCommand)
  199. {
  200. m_sql.EscapeString(__escape_hint, sizeof(__escape_hint), szCommand, strlen(szCommand));
  202. Query("INSERT DELAYED INTO command_log%s (userid, server, ip, port, username, command, date ) "
  203. "VALUES(%u, 999, '%s', %u, '%s', '%s', NOW()) ",
  204. get_table_postfix(), dwPID, szIP, byChannel, szName, __escape_hint);
  205. }
  207. void LogManager::RefineLog(DWORD pid, const char* item_name, DWORD item_id, int item_refine_level, int is_success, const char* how)
  208. {
  209. m_sql.EscapeString(__escape_hint, sizeof(__escape_hint), item_name, strlen(item_name));
  211. Query("INSERT INTO refinelog%s (pid, item_name, item_id, step, time, is_success, setType) VALUES(%u, '%s', %u, %d, NOW(), %d, '%s')",
  212. get_table_postfix(), pid, __escape_hint, item_id, item_refine_level, is_success, how);
  213. }
  216. void LogManager::ShoutLog(BYTE bChannel, BYTE bEmpire, const char * pszText)
  217. {
  218. m_sql.EscapeString(__escape_hint, sizeof(__escape_hint), pszText, strlen(pszText));
  220. Query("INSERT INTO shout_log%s VALUES(NOW(), %d, %d,'%s')", get_table_postfix(), bChannel, bEmpire, __escape_hint);
  221. }
  223. void LogManager::LevelLog(LPCHARACTER pChar, unsigned int level, unsigned int playhour)
  224. {
  225. if (true == LC_IsEurope())
  226. {
  227. DWORD aid = 0;
  229. if (NULL != pChar->GetDesc())
  230. {
  231. aid = pChar->GetDesc()->GetAccountTable().id;
  232. }
  234. Query("REPLACE INTO levellog%s (name, level, time, account_id, pid, playtime) VALUES('%s', %u, NOW(), %u, %u, %d)",
  235. get_table_postfix(), pChar->GetName(), level, aid, pChar->GetPlayerID(), playhour);
  236. }
  237. else
  238. {
  239. Query("REPLACE INTO levellog%s (name, level, time, playtime) VALUES('%s', %u, NOW(), %d)",
  240. get_table_postfix(), pChar->GetName(), level, playhour);
  241. }
  242. }
  244. void LogManager::BootLog(const char * c_pszHostName, BYTE bChannel)
  245. {
  246. Query("INSERT INTO bootlog (time, hostname, channel) VALUES(NOW(), '%s', %d)",
  247. c_pszHostName, bChannel);
  248. }
  250. void LogManager::VCardLog(DWORD vcard_id, DWORD x, DWORD y, const char * hostname, const char * giver_name, const char * giver_ip, const char * taker_name, const char * taker_ip)
  251. {
  252. Query("INSERT DELAYED INTO vcard_log (vcard_id, x, y, hostname, giver_name, giver_ip, taker_name, taker_ip) VALUES(%u, %u, %u, '%s', '%s', '%s', '%s', '%s')",
  253. vcard_id, x, y, hostname, giver_name, giver_ip, taker_name, taker_ip);
  254. }
  256. void LogManager::FishLog(DWORD dwPID, int prob_idx, int fish_id, int fish_level, DWORD dwMiliseconds, DWORD dwVnum, DWORD dwValue)
  257. {
  258. Query("INSERT INTO fish_log%s VALUES(NOW(), %u, %d, %u, %d, %u, %u, %u)",
  259. get_table_postfix(),
  260. dwPID,
  261. prob_idx,
  262. fish_id,
  263. fish_level,
  264. dwMiliseconds,
  265. dwVnum,
  266. dwValue);
  267. }
  269. void LogManager::QuestRewardLog(const char * c_pszQuestName, DWORD dwPID, DWORD dwLevel, int iValue1, int iValue2)
  270. {
  271. Query("INSERT INTO quest_reward_log%s VALUES('%s',%u,%u,2,%u,%u,NOW())",
  272. get_table_postfix(),
  273. c_pszQuestName,
  274. dwPID,
  275. dwLevel,
  276. iValue1,
  277. iValue2);
  278. }
  280. void LogManager::DetailLoginLog(bool isLogin, LPCHARACTER ch)
  281. {
  282. if (NULL == ch->GetDesc())
  283. return;
  285. if (true == isLogin)
  286. {
  287. Query("INSERT INTO loginlog2(type, is_gm, login_time, channel, account_id, pid, ip, client_version) "
  288. "VALUES('INVALID', %s, NOW(), %d, %u, %u, inet_aton('%s'), '%s')",
  289. ch->IsGM() == true ? "'Y'" : "'N'",
  290. g_bChannel,
  291. ch->GetDesc()->GetAccountTable().id,
  292. ch->GetPlayerID(),
  293. ch->GetDesc()->GetHostName(),
  294. ch->GetDesc()->GetClientVersion());
  295. }
  296. else
  297. {
  298. Query("SET @i = (SELECT MAX(id) FROM loginlog2 WHERE account_id=%u AND pid=%u)",
  299. ch->GetDesc()->GetAccountTable().id,
  300. ch->GetPlayerID());
  302. Query("UPDATE loginlog2 SET type='VALID', logout_time=NOW(), playtime=TIMEDIFF(logout_time,login_time) WHERE id=@i");
  303. }
  304. }
  306. void LogManager::DragonSlayLog(DWORD dwGuildID, DWORD dwDragonVnum, DWORD dwStartTime, DWORD dwEndTime)
  307. {
  308. Query( "INSERT INTO dragon_slay_log%s VALUES( %d, %d, FROM_UNIXTIME(%d), FROM_UNIXTIME(%d) )",
  309. get_table_postfix(),
  310. dwGuildID, dwDragonVnum, dwStartTime, dwEndTime);
  311. }
  313. void LogManager::HackShieldLog(unsigned long ErrorCode, LPCHARACTER ch)
  314. {
  315. struct in_addr st_addr;
  317. #ifndef __WIN32__
  318. if (0 == inet_aton(ch->GetDesc()->GetHostName(), &st_addr))
  319. #else
  320. unsigned long in_address;
  321. in_address = inet_addr(ch->GetDesc()->GetHostName());
  322. st_addr.s_addr = in_address;
  323. if (INADDR_NONE == in_address)
  324. #endif
  325. {
  326. Query( "INSERT INTO hackshield_log(time, account_id, login, pid, name, reason, ip) "
  327. "VALUES(NOW(), %u, '%s', %u, '%s', %u, 0)",
  328. ch->GetDesc()->GetAccountTable().id, ch->GetDesc()->GetAccountTable().login,
  329. ch->GetPlayerID(), ch->GetName(),
  330. ErrorCode);
  331. }
  332. else
  333. {
  334. Query( "INSERT INTO hackshield_log(time, account_id, login, pid, name, reason, ip) "
  335. "VALUES(NOW(), %u, '%s', %u, '%s', %u, inet_aton('%s'))",
  336. ch->GetDesc()->GetAccountTable().id, ch->GetDesc()->GetAccountTable().login,
  337. ch->GetPlayerID(), ch->GetName(),
  338. ErrorCode,
  339. ch->GetDesc()->GetHostName());
  340. }
  341. }

asdad