From 5d165f4de4834768382208b610d0cafc99657f5d Mon Sep 17 00:00:00 2001 From: ultramage Date: Wed, 5 Mar 2008 17:46:40 +0000 Subject: eol-style:native for recently added files git-svn-id: https://rathena.svn.sourceforge.net/svnroot/rathena/trunk@12305 54d463be-8e91-2dee-dedb-b68131a5f0ec --- src/char_sql/int_auction.c | 666 ++++++++++++++++++++++----------------------- src/char_sql/int_auction.h | 24 +- 2 files changed, 345 insertions(+), 345 deletions(-) (limited to 'src/char_sql') diff --git a/src/char_sql/int_auction.c b/src/char_sql/int_auction.c index 463115b10..40db47e0a 100644 --- a/src/char_sql/int_auction.c +++ b/src/char_sql/int_auction.c @@ -1,333 +1,333 @@ -// Copyright (c) Athena Dev Teams - Licensed under GNU GPL -// For more information, see LICENCE in the main folder - -#include "../common/mmo.h" -#include "../common/malloc.h" -#include "../common/db.h" -#include "../common/showmsg.h" -#include "../common/socket.h" -#include "../common/strlib.h" -#include "../common/sql.h" -#include "../common/timer.h" -#include "char.h" -#include "inter.h" -#include "int_mail.h" - -#include -#include -#include - -// This is set to limit the search result -// On iRO, no one uses auctions, so there is no way to know -#define MAX_SEARCH_RESULTS 30 - -static DBMap* auction_db_ = NULL; // int auction_id -> struct auction_data* - -void auction_delete(struct auction_data *auction); -static int auction_end_timer(int tid, unsigned int tick, int id, int data); - -// Copy Paste from map/mail.c -time_t calc_times(void) -{ - time_t temp = time(NULL); - return mktime(localtime(&temp)); -} - -void auction_save(struct auction_data *auction) -{ - int j; - StringBuf buf; - SqlStmt* stmt; - - if( !auction ) - return; - - StringBuf_Init(&buf); - StringBuf_Printf(&buf, "UPDATE `%s` SET `seller_id` = '%d', `seller_name` = ?, `buyer_id` = '%d', `buyer_name` = ?, `price` = '%d', `buynow` = '%d', `hours` = '%d', `timestamp` = '%d', `nameid` = '%d', `item_name` = ?, `type` = '%d', `refine` = '%d', `attribute` = '%d'", - auction_db, auction->seller_id, auction->buyer_id, auction->price, auction->buynow, auction->hours, auction->timestamp, auction->item.nameid, auction->type, auction->item.refine, auction->item.attribute); - for( j = 0; j < MAX_SLOTS; j++ ) - StringBuf_Printf(&buf, ", `card%d` = '%d'", j, auction->item.card[j]); - StringBuf_Printf(&buf, " WHERE `auction_id` = '%d'", auction->auction_id); - - stmt = SqlStmt_Malloc(sql_handle); - if( SQL_SUCCESS != SqlStmt_PrepareStr(stmt, StringBuf_Value(&buf)) - || SQL_SUCCESS != SqlStmt_BindParam(stmt, 0, SQLDT_STRING, auction->seller_name, strnlen(auction->seller_name, NAME_LENGTH)) - || SQL_SUCCESS != SqlStmt_BindParam(stmt, 1, SQLDT_STRING, auction->buyer_name, strnlen(auction->buyer_name, NAME_LENGTH)) - || SQL_SUCCESS != SqlStmt_BindParam(stmt, 2, SQLDT_STRING, auction->item_name, strnlen(auction->item_name, ITEM_NAME_LENGTH)) - || SQL_SUCCESS != SqlStmt_Execute(stmt) ) - { - SqlStmt_ShowDebug(stmt); - } - - SqlStmt_Free(stmt); - StringBuf_Destroy(&buf); -} - -static bool auction_create(struct auction_data *auction) -{ - int j; - - StringBuf buf; - SqlStmt* stmt; - - if( !auction ) - return false; - - StringBuf_Init(&buf); - StringBuf_Printf(&buf, "INSERT INTO `%s` (`seller_id`,`seller_name`,`buyer_id`,`buyer_name`,`price`,`buynow`,`hours`,`timestamp`,`nameid`,`item_name`,`type`,`refine`,`attribute`", auction_db); - for( j = 0; j < MAX_SLOTS; j++ ) - StringBuf_Printf(&buf, ",`card%d`", j); - StringBuf_Printf(&buf, ") VALUES ('%d',?,'%d',?,'%d','%d','%d','%d','%d',?,'%d','%d','%d'", - auction->seller_id, auction->buyer_id, auction->price, auction->buynow, auction->hours, auction->timestamp, auction->item.nameid, auction->type, auction->item.refine, auction->item.attribute); - for( j = 0; j < MAX_SLOTS; j++ ) - StringBuf_Printf(&buf, ",'%d'", auction->item.card[j]); - StringBuf_AppendStr(&buf, ")"); - - stmt = SqlStmt_Malloc(sql_handle); - if( SQL_SUCCESS != SqlStmt_PrepareStr(stmt, StringBuf_Value(&buf)) - || SQL_SUCCESS != SqlStmt_BindParam(stmt, 0, SQLDT_STRING, auction->seller_name, strnlen(auction->seller_name, NAME_LENGTH)) - || SQL_SUCCESS != SqlStmt_BindParam(stmt, 1, SQLDT_STRING, auction->buyer_name, strnlen(auction->buyer_name, NAME_LENGTH)) - || SQL_SUCCESS != SqlStmt_BindParam(stmt, 2, SQLDT_STRING, auction->item_name, strnlen(auction->item_name, ITEM_NAME_LENGTH)) - || SQL_SUCCESS != SqlStmt_Execute(stmt) ) - { - SqlStmt_ShowDebug(stmt); - auction->auction_id = 0; - } - else - { - struct auction_data *auction_; - - auction->item.amount = 1; - auction->item.identify = 1; - - auction->auction_id = (unsigned int)SqlStmt_LastInsertId(stmt); - auction->auction_end_timer = add_timer( gettick() + ((auction->timestamp - (unsigned int)calc_times) * 1000) , auction_end_timer, auction->auction_id, 0); - - CREATE(auction_, struct auction_data, 1); - memcpy(auction_, auction, sizeof(struct auction_data)); - idb_put(auction_db_, auction_->auction_id, auction_); - } - - SqlStmt_Free(stmt); - StringBuf_Destroy(&buf); - - return (auction->auction_id > 0); -} - -static int auction_end_timer(int tid, unsigned int tick, int id, int data) -{ - struct auction_data *auction; - if( (auction = (struct auction_data *)idb_get(auction_db_, id)) != NULL ) - { - struct mail_message msg; - memset(&msg, 0, sizeof(struct mail_message)); - - msg.send_id = auction->seller_id; - safestrncpy(msg.send_name, auction->seller_name, NAME_LENGTH); - msg.timestamp = (unsigned int)calc_times(); - - if( auction->buyer_id ) - { // Send item to Buyer's Mail (custom messages) - msg.dest_id = auction->buyer_id; - safestrncpy(msg.dest_name, auction->buyer_name, NAME_LENGTH); - safestrncpy(msg.title, "[Auction Winner] Your Item", MAIL_TITLE_LENGTH); - safestrncpy(msg.body, "Thanks, you won the auction!.", MAIL_BODY_LENGTH); - } - else - { // Return item to Seller's Mail (custom messages) - msg.dest_id = auction->seller_id; - safestrncpy(msg.dest_name, auction->seller_name, NAME_LENGTH); - safestrncpy(msg.title, "[Auction Fail] Your Item", MAIL_TITLE_LENGTH); - safestrncpy(msg.body, "Sorry, No one buy your item...", MAIL_BODY_LENGTH); - } - - memcpy(&msg.item, &auction->item, sizeof(struct item)); - - mail_savemessage(&msg); - mapif_Mail_new(&msg); - - if( auction->buyer_id ) - { // Send Money to Seller - memset(&msg, 0, sizeof(struct mail_message)); - - msg.send_id = auction->buyer_id; - safestrncpy(msg.send_name, auction->buyer_name, NAME_LENGTH); - msg.dest_id = auction->seller_id; - safestrncpy(msg.dest_name, auction->seller_name, NAME_LENGTH); - msg.timestamp = (unsigned int)calc_times(); - msg.zeny = auction->price; - - // Custom Messages, need more info - safestrncpy(msg.title, "[Auction] Your Zeny", MAIL_TITLE_LENGTH); - safestrncpy(msg.body, "Thanks, you won the auction!.", MAIL_BODY_LENGTH); - - mail_savemessage(&msg); - mapif_Mail_new(&msg); - } - - auction->auction_end_timer = -1; - auction_delete(auction); - } - - return 0; -} - -void auction_delete(struct auction_data *auction) -{ - unsigned int auction_id = auction->auction_id; - - if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `auction_id` = '%d'", auction_db, auction_id) ) - Sql_ShowDebug(sql_handle); - - if( auction->auction_end_timer != -1 ) - delete_timer(auction->auction_end_timer, auction_end_timer); - - idb_remove(auction_db_, auction_id); -} - -void inter_auctions_fromsql(void) -{ - int i; - struct auction_data *auction; - struct item *item; - char *data; - StringBuf buf; - unsigned int tick = gettick(), endtick, now = (unsigned int)calc_times(); - - StringBuf_Init(&buf); - StringBuf_AppendStr(&buf, "SELECT `auction_id`,`seller_id`,`seller_name`,`buyer_id`,`buyer_name`," - "`price`,`buynow`,`hours`,`timestamp`,`nameid`,`item_name`,`type`,`refine`,`attribute`"); - for( i = 0; i < MAX_SLOTS; i++ ) - StringBuf_Printf(&buf, ",`card%d`", i); - StringBuf_Printf(&buf, " FROM `%s` ORDER BY `auction_id` DESC", auction_db); - - if( SQL_ERROR == Sql_Query(sql_handle, StringBuf_Value(&buf)) ) - Sql_ShowDebug(sql_handle); - - StringBuf_Destroy(&buf); - - while( SQL_SUCCESS == Sql_NextRow(sql_handle) ) - { - CREATE(auction, struct auction_data, 1); - Sql_GetData(sql_handle, 0, &data, NULL); auction->auction_id = atoi(data); - Sql_GetData(sql_handle, 1, &data, NULL); auction->seller_id = atoi(data); - Sql_GetData(sql_handle, 2, &data, NULL); safestrncpy(auction->seller_name, data, NAME_LENGTH); - Sql_GetData(sql_handle, 3, &data, NULL); auction->buyer_id = atoi(data); - Sql_GetData(sql_handle, 4, &data, NULL); safestrncpy(auction->buyer_name, data, NAME_LENGTH); - Sql_GetData(sql_handle, 5, &data, NULL); auction->price = atoi(data); - Sql_GetData(sql_handle, 6, &data, NULL); auction->buynow = atoi(data); - Sql_GetData(sql_handle, 7, &data, NULL); auction->hours = atoi(data); - Sql_GetData(sql_handle, 8, &data, NULL); auction->timestamp = atoi(data); - - item = &auction->item; - Sql_GetData(sql_handle, 9, &data, NULL); item->nameid = atoi(data); - Sql_GetData(sql_handle,10, &data, NULL); safestrncpy(auction->item_name, data, ITEM_NAME_LENGTH); - Sql_GetData(sql_handle,11, &data, NULL); auction->type = atoi(data); - - Sql_GetData(sql_handle,12, &data, NULL); item->refine = atoi(data); - Sql_GetData(sql_handle,13, &data, NULL); item->attribute = atoi(data); - - item->identify = 1; - item->amount = 1; - - for( i = 0; i < MAX_SLOTS; i++ ) - { - Sql_GetData(sql_handle, 14 + i, &data, NULL); - item->card[i] = atoi(data); - } - - if( auction->timestamp > now ) - endtick = ((auction->timestamp - now) * 1000) + tick; - else - endtick = tick + 10000; // 10 Second's to process ended auctions - - auction->auction_end_timer = add_timer(endtick, auction_end_timer, auction->auction_id, 0); - idb_put(auction_db_, auction->auction_id, auction); - } - - Sql_FreeResult(sql_handle); -} - -static void mapif_Auction_sendlist(int fd, int account_id, short count, unsigned char *buf) -{ - int len = (sizeof(struct auction_data) * count) + 8; - - WFIFOHEAD(fd, len); - WFIFOW(fd,0) = 0x3850; - WFIFOW(fd,2) = len; - WFIFOL(fd,4) = account_id; - memcpy(WFIFOP(fd,8), buf, len - 8); - WFIFOSET(fd,len); -} - -static void mapif_parse_Auction_requestlist(int fd) -{ - char searchtext[NAME_LENGTH]; - int account_id = RFIFOL(fd,4), len = sizeof(struct auction_data); - unsigned int price = RFIFOL(fd,10); - short type = RFIFOW(fd,8); - unsigned char buf[MAX_SEARCH_RESULTS * sizeof(struct auction_data)]; - DBIterator* iter; - DBKey key; - struct auction_data *auction; - short i = 0; - - memcpy(searchtext, RFIFOP(fd,14), NAME_LENGTH); - - iter = auction_db_->iterator(auction_db_); - for( auction = iter->first(iter,&key); iter->exists(iter) && i < MAX_SEARCH_RESULTS; auction = iter->next(iter,&key) ) - { - if( (type == 0 && auction->type != IT_ARMOR && auction->type != IT_PETARMOR) || - (type == 1 && auction->type != IT_WEAPON) || - (type == 2 && auction->type != IT_CARD) || - (type == 3 && auction->type != IT_ETC) || - (type == 4 && auction->price > price) || - (type == 5 && strstr(auction->item_name, searchtext)) ) - continue; - - memcpy(WBUFP(buf, i * len), auction, len); - i++; - } - iter->destroy(iter); - - mapif_Auction_sendlist(fd, account_id, i, buf); -} - -static void mapif_parse_Auction_register(int fd) -{ - int account_id = RFIFOL(fd,4); - struct auction_data auction; - - memcpy(&auction, RFIFOP(fd,8), sizeof(struct auction_data)); - auction_create(&auction); -} - -/*========================================== - * Packets From Map Server - *------------------------------------------*/ -int inter_auction_parse_frommap(int fd) -{ - switch(RFIFOW(fd,0)) - { - case 0x3050: mapif_parse_Auction_requestlist(fd); break; - case 0x3051: mapif_parse_Auction_register(fd); break; - default: - return 0; - } - return 1; -} - -int inter_auction_sql_init(void) -{ - auction_db_ = idb_alloc(DB_OPT_RELEASE_DATA); - inter_auctions_fromsql(); - - return 0; -} - -void inter_auction_sql_final(void) -{ - auction_db_->destroy(auction_db_,NULL); - - return; -} +// Copyright (c) Athena Dev Teams - Licensed under GNU GPL +// For more information, see LICENCE in the main folder + +#include "../common/mmo.h" +#include "../common/malloc.h" +#include "../common/db.h" +#include "../common/showmsg.h" +#include "../common/socket.h" +#include "../common/strlib.h" +#include "../common/sql.h" +#include "../common/timer.h" +#include "char.h" +#include "inter.h" +#include "int_mail.h" + +#include +#include +#include + +// This is set to limit the search result +// On iRO, no one uses auctions, so there is no way to know +#define MAX_SEARCH_RESULTS 30 + +static DBMap* auction_db_ = NULL; // int auction_id -> struct auction_data* + +void auction_delete(struct auction_data *auction); +static int auction_end_timer(int tid, unsigned int tick, int id, int data); + +// Copy Paste from map/mail.c +time_t calc_times(void) +{ + time_t temp = time(NULL); + return mktime(localtime(&temp)); +} + +void auction_save(struct auction_data *auction) +{ + int j; + StringBuf buf; + SqlStmt* stmt; + + if( !auction ) + return; + + StringBuf_Init(&buf); + StringBuf_Printf(&buf, "UPDATE `%s` SET `seller_id` = '%d', `seller_name` = ?, `buyer_id` = '%d', `buyer_name` = ?, `price` = '%d', `buynow` = '%d', `hours` = '%d', `timestamp` = '%d', `nameid` = '%d', `item_name` = ?, `type` = '%d', `refine` = '%d', `attribute` = '%d'", + auction_db, auction->seller_id, auction->buyer_id, auction->price, auction->buynow, auction->hours, auction->timestamp, auction->item.nameid, auction->type, auction->item.refine, auction->item.attribute); + for( j = 0; j < MAX_SLOTS; j++ ) + StringBuf_Printf(&buf, ", `card%d` = '%d'", j, auction->item.card[j]); + StringBuf_Printf(&buf, " WHERE `auction_id` = '%d'", auction->auction_id); + + stmt = SqlStmt_Malloc(sql_handle); + if( SQL_SUCCESS != SqlStmt_PrepareStr(stmt, StringBuf_Value(&buf)) + || SQL_SUCCESS != SqlStmt_BindParam(stmt, 0, SQLDT_STRING, auction->seller_name, strnlen(auction->seller_name, NAME_LENGTH)) + || SQL_SUCCESS != SqlStmt_BindParam(stmt, 1, SQLDT_STRING, auction->buyer_name, strnlen(auction->buyer_name, NAME_LENGTH)) + || SQL_SUCCESS != SqlStmt_BindParam(stmt, 2, SQLDT_STRING, auction->item_name, strnlen(auction->item_name, ITEM_NAME_LENGTH)) + || SQL_SUCCESS != SqlStmt_Execute(stmt) ) + { + SqlStmt_ShowDebug(stmt); + } + + SqlStmt_Free(stmt); + StringBuf_Destroy(&buf); +} + +static bool auction_create(struct auction_data *auction) +{ + int j; + + StringBuf buf; + SqlStmt* stmt; + + if( !auction ) + return false; + + StringBuf_Init(&buf); + StringBuf_Printf(&buf, "INSERT INTO `%s` (`seller_id`,`seller_name`,`buyer_id`,`buyer_name`,`price`,`buynow`,`hours`,`timestamp`,`nameid`,`item_name`,`type`,`refine`,`attribute`", auction_db); + for( j = 0; j < MAX_SLOTS; j++ ) + StringBuf_Printf(&buf, ",`card%d`", j); + StringBuf_Printf(&buf, ") VALUES ('%d',?,'%d',?,'%d','%d','%d','%d','%d',?,'%d','%d','%d'", + auction->seller_id, auction->buyer_id, auction->price, auction->buynow, auction->hours, auction->timestamp, auction->item.nameid, auction->type, auction->item.refine, auction->item.attribute); + for( j = 0; j < MAX_SLOTS; j++ ) + StringBuf_Printf(&buf, ",'%d'", auction->item.card[j]); + StringBuf_AppendStr(&buf, ")"); + + stmt = SqlStmt_Malloc(sql_handle); + if( SQL_SUCCESS != SqlStmt_PrepareStr(stmt, StringBuf_Value(&buf)) + || SQL_SUCCESS != SqlStmt_BindParam(stmt, 0, SQLDT_STRING, auction->seller_name, strnlen(auction->seller_name, NAME_LENGTH)) + || SQL_SUCCESS != SqlStmt_BindParam(stmt, 1, SQLDT_STRING, auction->buyer_name, strnlen(auction->buyer_name, NAME_LENGTH)) + || SQL_SUCCESS != SqlStmt_BindParam(stmt, 2, SQLDT_STRING, auction->item_name, strnlen(auction->item_name, ITEM_NAME_LENGTH)) + || SQL_SUCCESS != SqlStmt_Execute(stmt) ) + { + SqlStmt_ShowDebug(stmt); + auction->auction_id = 0; + } + else + { + struct auction_data *auction_; + + auction->item.amount = 1; + auction->item.identify = 1; + + auction->auction_id = (unsigned int)SqlStmt_LastInsertId(stmt); + auction->auction_end_timer = add_timer( gettick() + ((auction->timestamp - (unsigned int)calc_times) * 1000) , auction_end_timer, auction->auction_id, 0); + + CREATE(auction_, struct auction_data, 1); + memcpy(auction_, auction, sizeof(struct auction_data)); + idb_put(auction_db_, auction_->auction_id, auction_); + } + + SqlStmt_Free(stmt); + StringBuf_Destroy(&buf); + + return (auction->auction_id > 0); +} + +static int auction_end_timer(int tid, unsigned int tick, int id, int data) +{ + struct auction_data *auction; + if( (auction = (struct auction_data *)idb_get(auction_db_, id)) != NULL ) + { + struct mail_message msg; + memset(&msg, 0, sizeof(struct mail_message)); + + msg.send_id = auction->seller_id; + safestrncpy(msg.send_name, auction->seller_name, NAME_LENGTH); + msg.timestamp = (unsigned int)calc_times(); + + if( auction->buyer_id ) + { // Send item to Buyer's Mail (custom messages) + msg.dest_id = auction->buyer_id; + safestrncpy(msg.dest_name, auction->buyer_name, NAME_LENGTH); + safestrncpy(msg.title, "[Auction Winner] Your Item", MAIL_TITLE_LENGTH); + safestrncpy(msg.body, "Thanks, you won the auction!.", MAIL_BODY_LENGTH); + } + else + { // Return item to Seller's Mail (custom messages) + msg.dest_id = auction->seller_id; + safestrncpy(msg.dest_name, auction->seller_name, NAME_LENGTH); + safestrncpy(msg.title, "[Auction Fail] Your Item", MAIL_TITLE_LENGTH); + safestrncpy(msg.body, "Sorry, No one buy your item...", MAIL_BODY_LENGTH); + } + + memcpy(&msg.item, &auction->item, sizeof(struct item)); + + mail_savemessage(&msg); + mapif_Mail_new(&msg); + + if( auction->buyer_id ) + { // Send Money to Seller + memset(&msg, 0, sizeof(struct mail_message)); + + msg.send_id = auction->buyer_id; + safestrncpy(msg.send_name, auction->buyer_name, NAME_LENGTH); + msg.dest_id = auction->seller_id; + safestrncpy(msg.dest_name, auction->seller_name, NAME_LENGTH); + msg.timestamp = (unsigned int)calc_times(); + msg.zeny = auction->price; + + // Custom Messages, need more info + safestrncpy(msg.title, "[Auction] Your Zeny", MAIL_TITLE_LENGTH); + safestrncpy(msg.body, "Thanks, you won the auction!.", MAIL_BODY_LENGTH); + + mail_savemessage(&msg); + mapif_Mail_new(&msg); + } + + auction->auction_end_timer = -1; + auction_delete(auction); + } + + return 0; +} + +void auction_delete(struct auction_data *auction) +{ + unsigned int auction_id = auction->auction_id; + + if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `auction_id` = '%d'", auction_db, auction_id) ) + Sql_ShowDebug(sql_handle); + + if( auction->auction_end_timer != -1 ) + delete_timer(auction->auction_end_timer, auction_end_timer); + + idb_remove(auction_db_, auction_id); +} + +void inter_auctions_fromsql(void) +{ + int i; + struct auction_data *auction; + struct item *item; + char *data; + StringBuf buf; + unsigned int tick = gettick(), endtick, now = (unsigned int)calc_times(); + + StringBuf_Init(&buf); + StringBuf_AppendStr(&buf, "SELECT `auction_id`,`seller_id`,`seller_name`,`buyer_id`,`buyer_name`," + "`price`,`buynow`,`hours`,`timestamp`,`nameid`,`item_name`,`type`,`refine`,`attribute`"); + for( i = 0; i < MAX_SLOTS; i++ ) + StringBuf_Printf(&buf, ",`card%d`", i); + StringBuf_Printf(&buf, " FROM `%s` ORDER BY `auction_id` DESC", auction_db); + + if( SQL_ERROR == Sql_Query(sql_handle, StringBuf_Value(&buf)) ) + Sql_ShowDebug(sql_handle); + + StringBuf_Destroy(&buf); + + while( SQL_SUCCESS == Sql_NextRow(sql_handle) ) + { + CREATE(auction, struct auction_data, 1); + Sql_GetData(sql_handle, 0, &data, NULL); auction->auction_id = atoi(data); + Sql_GetData(sql_handle, 1, &data, NULL); auction->seller_id = atoi(data); + Sql_GetData(sql_handle, 2, &data, NULL); safestrncpy(auction->seller_name, data, NAME_LENGTH); + Sql_GetData(sql_handle, 3, &data, NULL); auction->buyer_id = atoi(data); + Sql_GetData(sql_handle, 4, &data, NULL); safestrncpy(auction->buyer_name, data, NAME_LENGTH); + Sql_GetData(sql_handle, 5, &data, NULL); auction->price = atoi(data); + Sql_GetData(sql_handle, 6, &data, NULL); auction->buynow = atoi(data); + Sql_GetData(sql_handle, 7, &data, NULL); auction->hours = atoi(data); + Sql_GetData(sql_handle, 8, &data, NULL); auction->timestamp = atoi(data); + + item = &auction->item; + Sql_GetData(sql_handle, 9, &data, NULL); item->nameid = atoi(data); + Sql_GetData(sql_handle,10, &data, NULL); safestrncpy(auction->item_name, data, ITEM_NAME_LENGTH); + Sql_GetData(sql_handle,11, &data, NULL); auction->type = atoi(data); + + Sql_GetData(sql_handle,12, &data, NULL); item->refine = atoi(data); + Sql_GetData(sql_handle,13, &data, NULL); item->attribute = atoi(data); + + item->identify = 1; + item->amount = 1; + + for( i = 0; i < MAX_SLOTS; i++ ) + { + Sql_GetData(sql_handle, 14 + i, &data, NULL); + item->card[i] = atoi(data); + } + + if( auction->timestamp > now ) + endtick = ((auction->timestamp - now) * 1000) + tick; + else + endtick = tick + 10000; // 10 Second's to process ended auctions + + auction->auction_end_timer = add_timer(endtick, auction_end_timer, auction->auction_id, 0); + idb_put(auction_db_, auction->auction_id, auction); + } + + Sql_FreeResult(sql_handle); +} + +static void mapif_Auction_sendlist(int fd, int account_id, short count, unsigned char *buf) +{ + int len = (sizeof(struct auction_data) * count) + 8; + + WFIFOHEAD(fd, len); + WFIFOW(fd,0) = 0x3850; + WFIFOW(fd,2) = len; + WFIFOL(fd,4) = account_id; + memcpy(WFIFOP(fd,8), buf, len - 8); + WFIFOSET(fd,len); +} + +static void mapif_parse_Auction_requestlist(int fd) +{ + char searchtext[NAME_LENGTH]; + int account_id = RFIFOL(fd,4), len = sizeof(struct auction_data); + unsigned int price = RFIFOL(fd,10); + short type = RFIFOW(fd,8); + unsigned char buf[MAX_SEARCH_RESULTS * sizeof(struct auction_data)]; + DBIterator* iter; + DBKey key; + struct auction_data *auction; + short i = 0; + + memcpy(searchtext, RFIFOP(fd,14), NAME_LENGTH); + + iter = auction_db_->iterator(auction_db_); + for( auction = iter->first(iter,&key); iter->exists(iter) && i < MAX_SEARCH_RESULTS; auction = iter->next(iter,&key) ) + { + if( (type == 0 && auction->type != IT_ARMOR && auction->type != IT_PETARMOR) || + (type == 1 && auction->type != IT_WEAPON) || + (type == 2 && auction->type != IT_CARD) || + (type == 3 && auction->type != IT_ETC) || + (type == 4 && auction->price > price) || + (type == 5 && strstr(auction->item_name, searchtext)) ) + continue; + + memcpy(WBUFP(buf, i * len), auction, len); + i++; + } + iter->destroy(iter); + + mapif_Auction_sendlist(fd, account_id, i, buf); +} + +static void mapif_parse_Auction_register(int fd) +{ + int account_id = RFIFOL(fd,4); + struct auction_data auction; + + memcpy(&auction, RFIFOP(fd,8), sizeof(struct auction_data)); + auction_create(&auction); +} + +/*========================================== + * Packets From Map Server + *------------------------------------------*/ +int inter_auction_parse_frommap(int fd) +{ + switch(RFIFOW(fd,0)) + { + case 0x3050: mapif_parse_Auction_requestlist(fd); break; + case 0x3051: mapif_parse_Auction_register(fd); break; + default: + return 0; + } + return 1; +} + +int inter_auction_sql_init(void) +{ + auction_db_ = idb_alloc(DB_OPT_RELEASE_DATA); + inter_auctions_fromsql(); + + return 0; +} + +void inter_auction_sql_final(void) +{ + auction_db_->destroy(auction_db_,NULL); + + return; +} diff --git a/src/char_sql/int_auction.h b/src/char_sql/int_auction.h index f7826726c..bf26b152c 100644 --- a/src/char_sql/int_auction.h +++ b/src/char_sql/int_auction.h @@ -1,12 +1,12 @@ -// Copyright (c) Athena Dev Teams - Licensed under GNU GPL -// For more information, see LICENCE in the main folder - -#ifndef _INT_AUCTION_SQL_H_ -#define _INT_AUCTION_SQL_H_ - -int inter_auction_parse_frommap(int fd); - -int inter_auction_sql_init(void); -void inter_auction_sql_final(void); - -#endif /* _INT_AUCTION_SQL_H_ */ +// Copyright (c) Athena Dev Teams - Licensed under GNU GPL +// For more information, see LICENCE in the main folder + +#ifndef _INT_AUCTION_SQL_H_ +#define _INT_AUCTION_SQL_H_ + +int inter_auction_parse_frommap(int fd); + +int inter_auction_sql_init(void); +void inter_auction_sql_final(void); + +#endif /* _INT_AUCTION_SQL_H_ */ -- cgit v1.2.3-70-g09d2