// $Id: itemdb.c,v 1.3 2004/09/25 05:32:18 MouseJstr Exp $
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "db.h"
#include "grfio.h"
#include "nullpo.h"
#include "malloc.h"
#include "map.h"
#include "battle.h"
#include "itemdb.h"
#include "script.h"
#include "pc.h"
#ifdef MEMWATCH
#include "memwatch.h"
#endif
#define MAX_RANDITEM 2000
// ** ITEMDB_OVERRIDE_NAME_VERBOSE **
// ��`����ƁAitemdb.txt��grf�Ŗ��O���قȂ�ꍇ�A�\�����܂�.
//#define ITEMDB_OVERRIDE_NAME_VERBOSE 1
static struct dbt* item_db;
static struct random_item_data blue_box[MAX_RANDITEM],violet_box[MAX_RANDITEM],card_album[MAX_RANDITEM],gift_box[MAX_RANDITEM],scroll[MAX_RANDITEM];
static int blue_box_count=0,violet_box_count=0,card_album_count=0,gift_box_count=0,scroll_count=0;
static int blue_box_default=0,violet_box_default=0,card_album_default=0,gift_box_default=0,scroll_default=0;
// Function declarations
static void itemdb_read(void);
static int itemdb_readdb(void);
#ifndef TXT_ONLY
static int itemdb_read_sqldb(void);
#endif /* not TXT_ONLY */
static int itemdb_read_randomitem();
static int itemdb_read_itemavail(void);
static int itemdb_read_itemnametable(void);
static int itemdb_read_noequip(void);
void itemdb_reload(void);
/*==========================================
* ���O�Ō����p
*------------------------------------------
*/
// name = item alias, so we should find items aliases first. if not found then look for "jname" (full name)
int itemdb_searchname_sub(void *key,void *data,va_list ap)
{
struct item_data *item=(struct item_data *)data,**dst;
char *str;
str=va_arg(ap,char *);
dst=va_arg(ap,struct item_data **);
// if( strcmpi(item->name,str)==0 || strcmp(item->jname,str)==0 ||
// memcmp(item->name,str,24)==0 || memcmp(item->jname,str,24)==0 )
if( strcmpi(item->name,str)==0 ) //by lupus
*dst=item;
return 0;
}
/*==========================================
* ���O�Ō����p
*------------------------------------------
*/
int itemdb_searchjname_sub(void *key,void *data,va_list ap)
{
struct item_data *item=(struct item_data *)data,**dst;
char *str;
str=va_arg(ap,char *);
dst=va_arg(ap,struct item_data **);
if( strcmpi(item->jname,str)==0 )
*dst=item;
return 0;
}
/*==========================================
* ���O�Ō���
*------------------------------------------
*/
struct item_data* itemdb_searchname(const char *str)
{
struct item_data *item=NULL;
numdb_foreach(item_db,itemdb_searchname_sub,str,&item);
return item;
}
/*==========================================
* ���n�A�C�e������
*------------------------------------------
*/
int itemdb_searchrandomid(int flags)
{
int nameid=0,i,index,count;
struct random_item_data *list=NULL;
struct {
int nameid,count;
struct random_item_data *list;
} data[] ={
{ 0,0,NULL },
{ blue_box_default ,blue_box_count ,blue_box },
{ violet_box_default,violet_box_count ,violet_box },
{ card_album_default,card_album_count ,card_album },
{ gift_box_default ,gift_box_count ,gift_box },
{ scroll_default ,scroll_count ,scroll },
};
if(flags>=1 && flags<=5){
nameid=data[flags].nameid;
count=data[flags].count;
list=data[flags].list;
if(count > 0) {
for(i=0;i<1000;i++) {
index = rand()%count;
if( rand()%1000000 < list[index].per) {
nameid = list[index].nameid;
break;
}
}
}
}
return nameid;
}
/*==========================================
* DB�̑��݊m�F
*------------------------------------------
*/
struct item_data* itemdb_exists(int nameid)
{
return numdb_search(item_db,nameid);
}
/*==========================================
* DB�̌���
*------------------------------------------
*/
struct item_data* itemdb_search(int nameid)
{
struct item_data *id;
id=numdb_search(item_db,nameid);
if(id) return id;
id=(struct item_data *)aCalloc(1,sizeof(struct item_data));
numdb_insert(item_db,nameid,id);
id->nameid=nameid;
id->value_buy=10;
id->value_sell=id->value_buy/2;
id->weight=10;
id->sex=2;
id->elv=0;
id->class=0xffffffff;
id->flag.available=0;
id->flag.value_notdc=0; //�ꉞ�E�E�E
id->flag.value_notoc=0;
id->flag.no_equip=0;
id->view_id=0;
if(nameid>500 && nameid<600)
id->type=0; //heal item
else if(nameid>600 && nameid<700)
id->type=2; //use item
else if((nameid>700 && nameid<1100) ||
(nameid>7000 && nameid<8000))
id->type=3; //correction
else if(nameid>=1750 && nameid<1771)
id->type=10; //arrow
else if(nameid>1100 && nameid<2000)
id->type=4; //weapon
else if((nameid>2100 && nameid<3000) ||
(nameid>5000 && nameid<6000))
id->type=5; //armor
else if(nameid>4000 && nameid<5000)
id->type=6; //card
return id;
}
/*==========================================
*
*------------------------------------------
*/
int itemdb_isequip(int nameid)
{
int type=itemdb_type(nameid);
if(type==0 || type==2 || type==3 || type==6 || type==10)
return 0;
return 1;
}
/*==========================================
*
*------------------------------------------
*/
int itemdb_isequip2(struct item_data *data)
{
if(data) {
int type=data->type;
if(type==0 || type==2 || type==3 || type==6 || type==10)
return 0;
else
return 1;
}
return 0;
}
/*==========================================
*
*------------------------------------------
*/
int itemdb_isequip3(int nameid)
{
int type=itemdb_type(nameid);
if(type==4 || type==5 || type == 8)
return 1;
return 0;
}
/*==========================================
* �̂Ă���A�C�e����1�A�����łȂ��A�C�e����0
*------------------------------------------
*/
int itemdb_isdropable(int nameid)
{
//�����w�ւ͎̂Ă��Ȃ�
switch(nameid){
case 2634: //�����w��
case 2635: //�����w��
return 0;
}
return 1;
}
//
// ������
//
/*==========================================
*
*------------------------------------------
*/
static int itemdb_read_itemslottable(void)
{
char *buf,*p;
int s;
buf=grfio_read("data\\itemslottable.txt");
if(buf==NULL)
return -1;
s=grfio_size("data\\itemslottable.txt");
buf[s]=0;
for(p=buf;p-buf<s;){
int nameid,equip;
sscanf(p,"%d#%d#",&nameid,&equip);
itemdb_search(nameid)->equip=equip;
p=strchr(p,10);
if(!p) break;
p++;
p=strchr(p,10);
if(!p) break;
p++;
}
free(buf);
return 0;
}
#ifndef TXT_ONLY
/*====================================
* Removed item_value_db, don't re-add
*------------------------------------
*/
static void itemdb_read(void)
{
itemdb_read_itemslottable();
if (db_use_sqldbs)
{
itemdb_read_sqldb();
}
else
{
itemdb_readdb();
}
itemdb_read_randomitem();
itemdb_read_itemavail();
itemdb_read_noequip();
if (!battle_config.item_name_override_grffile)
itemdb_read_itemnametable();
}
#endif /* not TXT_ONLY */
/*==========================================
* �A�C�e���f�[�^�x�[�X�̓ǂݍ���
*------------------------------------------
*/
static int itemdb_readdb(void)
{
FILE *fp;
char line[1024];
int ln=0,lines=0;
int nameid,j;
char *str[32],*p,*np;
struct item_data *id;
int i=0;
char *filename[]={ "db/item_db.txt","db/item_db2.txt" };
for(i=0;i<2;i++){
fp=fopen(filename[i],"r");
if(fp==NULL){
if(i>0)
continue;
printf("can't read %s\n",filename[i]);
exit(1);
}
lines=0;
while(fgets(line,1020,fp)){
lines++;
if(line[0]=='/' && line[1]=='/')
continue;
memset(str,0,sizeof(str));
for(j=0,np=p=line;j<18 && p;j++){
while (*p == '\t' || *p == ' ') p++;
str[j]=p;
p=strchr(p,',');
if(p){ *p++=0; np=p; }
}
if(str[0]==NULL)
continue;
nameid=atoi(str[0]);
if(nameid<=0 || nameid>=20000)
continue;
ln++;
//ID,Name,Jname,Type,Price,Sell,Weight,ATK,DEF,Range,Slot,Job,Gender,Loc,wLV,eLV,View
id=itemdb_search(nameid);
memcpy(id->name,str[1],24);
memcpy(id->jname,str[2],24);
id->type=atoi(str[3]);
// buy��sell*2 �� item_value_db.txt �Ŏw�肵�Ă��������B
id->value_buy=atoi(str[4]);
id->value_sell=atoi(str[5]);
if (id->value_buy == 0 && id->value_sell == 0) {
} else if (id->value_buy == 0) {
id->value_buy=id->value_sell*2;
} else if (id->value_sell == 0) {
id->value_sell=id->value_buy/2;
}
id->weight=atoi(str[6]);
id->atk=atoi(str[7]);
id->def=atoi(str[8]);
id->range=atoi(str[9]);
id->magic_bonus = atoi(str[10]);
id->slot=atoi(str[11]);
id->class=atoi(str[12]);
id->sex=atoi(str[13]);
if(id->equip != atoi(str[14])){
id->equip=atoi(str[14]);
}
id->wlv=atoi(str[15]);
id->elv=atoi(str[16]);
id->look=atoi(str[17]);
id->flag.available=1;
id->flag.value_notdc=0;
id->flag.value_notoc=0;
id->view_id=0;
id->use_script=NULL;
id->equip_script=NULL;
if((p=strchr(np,'{'))==NULL)
continue;
id->use_script = parse_script(p,lines);
if((p=strchr(p+1,'{'))==NULL)
continue;
id->equip_script = parse_script(p,lines);
}
fclose(fp);
printf("read %s done (count=%d)\n",filename[i],ln);
}
return 0;
}
// Removed item_value_db, don't re-add!
/*==========================================
* �����_���A�C�e���o���f�[�^�̓ǂݍ���
*------------------------------------------
*/
static int itemdb_read_randomitem()
{
FILE *fp;
char line[1024];
int ln=0;
int nameid,i,j;
char *str[10],*p;
const struct {
char filename[64];
struct random_item_data *pdata;
int *pcount,*pdefault;
} data[] = {
{"db/item_bluebox.txt", blue_box, &blue_box_count, &blue_box_default },
{"db/item_violetbox.txt", violet_box, &violet_box_count, &violet_box_default },
{"db/item_cardalbum.txt", card_album, &card_album_count, &card_album_default },
{"db/item_giftbox.txt", gift_box, &gift_box_count, &gift_box_default },
{"db/item_scroll.txt", scroll, &scroll_count, &scroll_default },
};
for(i=0;i<sizeof(data)/sizeof(data[0]);i++){
struct random_item_data *pd=data[i].pdata;
int *pc=data[i].pcount;
int *pdefault=data[i].pdefault;
char *fn=data[i].filename;
*pdefault = 0;
if( (fp=fopen(fn,"r"))==NULL ){
printf("can't read %s\n",fn);
continue;
}
while(fgets(line,1020,fp)){
if(line[0]=='/' && line[1]=='/')
continue;
memset(str,0,sizeof(str));
for(j=0,p=line;j<3 && p;j++){
str[j]=p;
p=strchr(p,',');
if(p) *p++=0;
}
if(str[0]==NULL)
continue;
nameid=atoi(str[0]);
if(nameid<0 || nameid>=20000)
continue;
if(nameid == 0) {
if(str[2])
*pdefault = atoi(str[2]);
continue;
}
if(str[2]){
pd[ *pc ].nameid = nameid;
pd[(*pc)++].per = atoi(str[2]);
}
if(ln >= MAX_RANDITEM)
break;
ln++;
}
fclose(fp);
printf("read %s done (count=%d)\n",fn,*pc);
}
return 0;
}
/*==========================================
* �A�C�e���g�p�\�t���O�̃I�[�o�[���C�h
*------------------------------------------
*/
static int itemdb_read_itemavail(void)
{
FILE *fp;
char line[1024];
int ln=0;
int nameid,j,k;
char *str[10],*p;
if( (fp=fopen("db/item_avail.txt","r"))==NULL ){
printf("can't read db/item_avail.txt\n");
return -1;
}
while(fgets(line,1020,fp)){
struct item_data *id;
if(line[0]=='/' && line[1]=='/')
continue;
memset(str,0,sizeof(str));
for(j=0,p=line;j<2 && p;j++){
str[j]=p;
p=strchr(p,',');
if(p) *p++=0;
}
if(str[0]==NULL)
continue;
nameid=atoi(str[0]);
if(nameid<0 || nameid>=20000 || !(id=itemdb_exists(nameid)) )
continue;
k=atoi(str[1]);
if(k > 0) {
id->flag.available = 1;
id->view_id = k;
}
else
id->flag.available = 0;
ln++;
}
fclose(fp);
printf("read db/item_avail.txt done (count=%d)\n",ln);
return 0;
}
/*==========================================
* �A�C�e���̖��O�e�[�u����ǂݍ���
*------------------------------------------
*/
static int itemdb_read_itemnametable(void)
{
char *buf,*p;
int s;
buf=grfio_reads("data\\idnum2itemdisplaynametable.txt",&s);
if(buf==NULL)
return -1;
buf[s]=0;
for(p=buf;p-buf<s;){
int nameid;
char buf2[64];
if( sscanf(p,"%d#%[^#]#",&nameid,buf2)==2 ){
#ifdef ITEMDB_OVERRIDE_NAME_VERBOSE
if( itemdb_exists(nameid) &&
strncmp(itemdb_search(nameid)->jname,buf2,24)!=0 ){
printf("[override] %d %s => %s\n",nameid
,itemdb_search(nameid)->jname,buf2);
}
#endif
memcpy(itemdb_search(nameid)->jname,buf2,24);
}
p=strchr(p,10);
if(!p) break;
p++;
}
free(buf);
printf("read data\\idnum2itemdisplaynametable.txt done.\n");
return 0;
}
#ifdef TXT_ONLY
/*==========================================
* �J�[�h�C���X�g�̃��\�[�X���O�e�[�u����ǂݍ���
*------------------------------------------
*/
static int itemdb_read_cardillustnametable(void)
{
char *buf,*p;
int s;
buf=grfio_reads("data\\num2cardillustnametable.txt",&s);
if(buf==NULL)
return -1;
buf[s]=0;
for(p=buf;p-buf<s;){
int nameid;
char buf2[64];
if( sscanf(p,"%d#%[^#]#",&nameid,buf2)==2 ){
strcat(buf2,".bmp");
memcpy(itemdb_search(nameid)->cardillustname,buf2,64);
// printf("%d %s\n",nameid,itemdb_search(nameid)->cardillustname);
}
p=strchr(p,10);
if(!p) break;
p++;
}
free(buf);
printf("read data\\num2cardillustnametable.txt done.\n");
return 0;
}
#endif /* TXT_ONLY */
/*==========================================
* ���������t�@�C���ǂݏo��
*------------------------------------------
*/
static int itemdb_read_noequip(void)
{
FILE *fp;
char line[1024];
int ln=0;
int nameid,j;
char *str[32],*p;
struct item_data *id;
if( (fp=fopen("db/item_noequip.txt","r"))==NULL ){
printf("can't read db/item_noequip.txt\n");
return -1;
}
while(fgets(line,1020,fp)){
if(line[0]=='/' && line[1]=='/')
continue;
memset(str,0,sizeof(str));
for(j=0,p=line;j<2 && p;j++){
str[j]=p;
p=strchr(p,',');
if(p) *p++=0;
}
if(str[0]==NULL)
continue;
nameid=atoi(str[0]);
if(nameid<=0 || nameid>=20000 || !(id=itemdb_exists(nameid)))
continue;
id->flag.no_equip=atoi(str[1]);
ln++;
}
fclose(fp);
printf("read db/item_noequip.txt done (count=%d)\n",ln);
return 0;
}
#ifndef TXT_ONLY
/*======================================
* SQL
*===================================
*/
static int itemdb_read_sqldb(void)
{
unsigned short nameid;
struct item_data *id;
char script[65535 + 2 + 1]; // Maximum length of MySQL TEXT type (65535) + 2 bytes for curly brackets + 1 byte for terminator
// ----------
sprintf(tmp_sql, "SELECT * FROM `%s`", item_db_db);
// Execute the query; if the query execution succeeded...
if (mysql_query(&mmysql_handle, tmp_sql) == 0)
{
sql_res = mysql_store_result(&mmysql_handle);
// If the storage of the query result succeeded...
if (sql_res)
{
// Parse each row in the query result into sql_row
while ((sql_row = mysql_fetch_row(sql_res)))
{
/* +----+--------------+---------------+------+-----------+------------+--------+--------+---------+-------+-------+------------+---------------+-----------------+--------------+-------------+------+------------+--------------+
| 0 | 1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 | 10 | 11 | 12 | 13 | 14 | 15 | 16 | 17 | 18 |
+----+--------------+---------------+------+-----------+------------+--------+--------+---------+-------+-------+------------+---------------+-----------------+--------------+-------------+------+------------+--------------+
| id | name_english | name_japanese | type | price_buy | price_sell | weight | attack | defence | range | slots | equip_jobs | equip_genders | equip_locations | weapon_level | equip_level | view | script_use | script_equip |
+----+--------------+---------------+------+-----------+------------+--------+--------+---------+-------+-------+------------+---------------+-----------------+--------------+-------------+------+------------+--------------+ */
nameid = atoi(sql_row[0]);
// If the identifier is not within the valid range, process the next row
if (nameid == 0 || nameid >= 20000)
{
continue;
}
// Insert a new row into the item database
/*id = calloc(sizeof(struct item_data), 1);
if (id == NULL)
{
printf("out of memory : itemdb_read_sqldb\n");
exit(1);
}
memset(id, 0, sizeof(struct item_data));
numdb_insert(item_db, (int) nameid, id);*/
// ----------
id=itemdb_search(nameid);
memcpy(id->name, sql_row[1], 25);
memcpy(id->jname, sql_row[2], 25);
id->type = atoi(sql_row[3]);
// If price_buy is not NULL and price_sell is not NULL...
if ((sql_row[4] != NULL) && (sql_row[5] != NULL))
{
id->value_buy = atoi(sql_row[4]);
id->value_sell = atoi(sql_row[5]);
}
// If price_buy is not NULL and price_sell is NULL...
else if ((sql_row[4] != NULL) && (sql_row[5] == NULL))
{
id->value_buy = atoi(sql_row[4]);
id->value_sell = atoi(sql_row[4]) / 2;
}
// If price_buy is NULL and price_sell is not NULL...
else if ((sql_row[4] == NULL) && (sql_row[5] != NULL))
{
id->value_buy = atoi(sql_row[5]) * 2;
id->value_sell = atoi(sql_row[5]);
}
// If price_buy is NULL and price_sell is NULL...
if ((sql_row[4] == NULL) && (sql_row[5] == NULL))
{
id->value_buy = 0;
id->value_sell = 0;
}
id->weight = atoi(sql_row[6]);
id->atk = (sql_row[7] != NULL) ? atoi(sql_row[7]) : 0;
id->def = (sql_row[8] != NULL) ? atoi(sql_row[8]) : 0;
id->range = (sql_row[9] != NULL) ? atoi(sql_row[9]) : 0;
id->slot = (sql_row[10] != NULL) ? atoi(sql_row[10]) : 0;
id->class = (sql_row[11] != NULL) ? atoi(sql_row[11]) : 0;
id->sex = (sql_row[12] != NULL) ? atoi(sql_row[12]) : 0;
id->equip = (sql_row[13] != NULL) ? atoi(sql_row[13]) : 0;
id->wlv = (sql_row[14] != NULL) ? atoi(sql_row[14]) : 0;
id->elv = (sql_row[15] != NULL) ? atoi(sql_row[15]) : 0;
id->look = (sql_row[16] != NULL) ? atoi(sql_row[16]) : 0;
id->view_id = 0;
// ----------
if (sql_row[17] != NULL)
{
if (sql_row[17][0] == '{')
id->use_script = parse_script(sql_row[17], 0);
else {
sprintf(script, "{%s}", sql_row[17]);
id->use_script = parse_script(script, 0);
}
}
else
{
id->use_script = NULL;
}
if (sql_row[18] != NULL)
{
if (sql_row[18][0] == '{')
id->equip_script = parse_script(sql_row[18], 0);
else {
sprintf(script, "{%s}", sql_row[18]);
id->equip_script = parse_script(script, 0);
}
}
else
{
id->equip_script = NULL;
}
// ----------
id->flag.available = 1;
id->flag.value_notdc = 0;
id->flag.value_notoc = 0;
}
// If the retrieval failed, output an error
if (mysql_errno(&mmysql_handle))
{
printf("Database server error (retrieving rows from %s): %s\n", item_db_db, mysql_error(&mmysql_handle));
}
printf("read %s done (count = %lu)\n", item_db_db, (unsigned long) mysql_num_rows(sql_res));
}
else
{
printf("MySQL error (storing query result for %s): %s\n", item_db_db, mysql_error(&mmysql_handle));
}
// Free the query result
mysql_free_result(sql_res);
}
else
{
printf("Database server error (executing query for %s): %s\n", item_db_db, mysql_error(&mmysql_handle));
}
return 0;
}
#endif /* not TXT_ONLY */
/*==========================================
*
*------------------------------------------
*/
static int itemdb_final(void *key,void *data,va_list ap)
{
struct item_data *id;
nullpo_retr(0, id=data);
if(id->use_script)
free(id->use_script);
if(id->equip_script)
free(id->equip_script);
free(id);
return 0;
}
void itemdb_reload(void)
{
/*
<empty item databases>
itemdb_read();
*/
do_init_itemdb();
}
/*==========================================
*
*------------------------------------------
*/
void do_final_itemdb(void)
{
if(item_db){
numdb_final(item_db,itemdb_final);
item_db=NULL;
}
}
/*
static FILE *dfp;
static int itemdebug(void *key,void *data,va_list ap){
// struct item_data *id=(struct item_data *)data;
fprintf(dfp,"%6d",(int)key);
return 0;
}
void itemdebugtxt()
{
dfp=fopen("itemdebug.txt","wt");
numdb_foreach(item_db,itemdebug);
fclose(dfp);
}
*/
#ifdef TXT_ONLY
/*====================================
* Removed item_value_db, don't re-add
*------------------------------------
*/
static void itemdb_read(void)
{
itemdb_read_itemslottable();
itemdb_readdb();
itemdb_read_randomitem();
itemdb_read_itemavail();
itemdb_read_noequip();
itemdb_read_cardillustnametable();
if (!battle_config.item_name_override_grffile)
itemdb_read_itemnametable();
}
#endif /* TXT_ONLY */
/*==========================================
*
*------------------------------------------
*/
int do_init_itemdb(void)
{
item_db = numdb_init();
itemdb_read();
return 0;
}