pa/eqemu-server
2
0
Fork 0
mirror of https://github.com/EQEmu/Server.git synced 2026-03-07 07:12:25 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

LogMerchantTransaction converted to QueryDatabase

Browse Source
This commit is contained in:
Arthur Ice 2014-08-28 00:10:55 -07:00
parent 1bc06c9c24
commit 0a9732a267
1 changed files with 35 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
queryserv/database.cpp
View File

@ -306,33 +306,43 @@ void Database::LogPlayerMove(QSPlayerLogMove_Struct* QS, uint32 items) {
void Database::LogMerchantTransaction(QSMerchantLogTransaction_Struct* QS, uint32 items) { void Database::LogMerchantTransaction(QSMerchantLogTransaction_Struct* QS, uint32 items) {
/* Merchant transactions are from the perspective of the merchant, not the player -U */ /* Merchant transactions are from the perspective of the merchant, not the player -U */
char errbuf[MYSQL_ERRMSG_SIZE]; std::string query = StringFormat("INSERT INTO `qs_merchant_transaction_record` SET `time` = NOW(), "
char* query = 0; "`zone_id` = '%i', `merchant_id` = '%i', `merchant_pp` = '%i', "
uint32 lastid = 0; "`merchant_gp` = '%i', `merchant_sp` = '%i', `merchant_cp` = '%i', "
if(!RunQuery(query, MakeAnyLenString(&query, "INSERT INTO `qs_merchant_transaction_record` SET `time`=NOW(), " "`merchant_items` = '%i', `char_id` = '%i', `char_pp` = '%i', "
"`zone_id`='%i', `merchant_id`='%i', `merchant_pp`='%i', `merchant_gp`='%i', `merchant_sp`='%i', `merchant_cp`='%i', `merchant_items`='%i', " "`char_gp` = '%i', `char_sp` = '%i', `char_cp` = '%i', "
"`char_id`='%i', `char_pp`='%i', `char_gp`='%i', `char_sp`='%i', `char_cp`='%i', `char_items`='%i'", "`char_items` = '%i'",
QS->zone_id, QS->merchant_id, QS->merchant_money.platinum, QS->merchant_money.gold, QS->merchant_money.silver, QS->merchant_money.copper, QS->merchant_count, QS->zone_id, QS->merchant_id, QS->merchant_money.platinum,
QS->char_id, QS->char_money.platinum, QS->char_money.gold, QS->char_money.silver, QS->char_money.copper, QS->char_count), QS->merchant_money.gold, QS->merchant_money.silver,
errbuf, 0, 0, &lastid)) { QS->merchant_money.copper, QS->merchant_count, QS->char_id,
_log(QUERYSERV__ERROR, "Failed Transaction Log Record Insert: %s", errbuf); QS->char_money.platinum, QS->char_money.gold, QS->char_money.silver,
_log(QUERYSERV__ERROR, "%s", query); QS->char_money.copper, QS->char_count);
auto results = QueryDatabase(query);
if(!results.Success()) {
_log(QUERYSERV__ERROR, "Failed Transaction Log Record Insert: %s", results.ErrorMessage().c_str());
_log(QUERYSERV__ERROR, "%s", query.c_str());
} }
if(items > 0) { if(items == 0)
for(int i = 0; i < items; i++) { return;
if(!RunQuery(query, MakeAnyLenString(&query, "INSERT INTO `qs_merchant_transaction_record_entries` SET `event_id`='%i', "
"`char_slot`='%i', `item_id`='%i', `charges`='%i', `aug_1`='%i', " int lastIndex = results.LastInsertedID();
"`aug_2`='%i', `aug_3`='%i', `aug_4`='%i', `aug_5`='%i'",
lastid, QS->items[i].char_slot, QS->items[i].item_id, QS->items[i].charges, QS->items[i].aug_1, for(int i = 0; i < items; i++) {
QS->items[i].aug_2, QS->items[i].aug_3, QS->items[i].aug_4, QS->items[i].aug_5, query = StringFormat("INSERT INTO `qs_merchant_transaction_record_entries` SET `event_id` = '%i', "
errbuf, 0, 0))) { "`char_slot` = '%i', `item_id` = '%i', `charges` = '%i', `aug_1` = '%i', "
_log(QUERYSERV__ERROR, "Failed Transaction Log Record Entry Insert: %s", errbuf); "`aug_2` = '%i', `aug_3` = '%i', `aug_4` = '%i', `aug_5` = '%i'",
_log(QUERYSERV__ERROR, "%s", query); lastIndex, QS->items[i].char_slot, QS->items[i].item_id, QS->items[i].charges,
} QS->items[i].aug_1, QS->items[i].aug_2, QS->items[i].aug_3, QS->items[i].aug_4,
} QS->items[i].aug_5);
} results = QueryDatabase(query);
safe_delete_array(query); if(!results.Success()) {
_log(QUERYSERV__ERROR, "Failed Transaction Log Record Entry Insert: %s", results.ErrorMessage().c_str());
_log(QUERYSERV__ERROR, "%s", query.c_str());
}
}
} }
void Database::GeneralQueryReceive(ServerPacket *pack) { void Database::GeneralQueryReceive(ServerPacket *pack) {