// $Id: char-converter.c,v 1.1.1.1 2004/09/10 17:45:03 MagicalTux Exp $ // original : char2.c 2003/03/14 11:58:35 Rev.1.5 #include #include #include #include #include #include #include #include #include #include #include #include #define STORAGE_MEMINC 16 #include "char.h" #include "strlib.h" #ifdef MEMWATCH #include "memwatch.h" #endif char pet_txt[256] = "save/pet.txt"; char storage_txt[256] = "save/storage.txt"; MYSQL mysql_handle; MYSQL_RES *sql_res; MYSQL_ROW sql_row; int sql_fields, sql_cnt; char tmp_sql[65535]; int db_server_port = 3306; char db_server_ip[16] = "127.0.0.1"; char db_server_id[32] = "ragnarok"; char db_server_pw[32] = "ragnarok"; char db_server_logindb[32] = "ragnarok"; struct storage *storage = NULL; struct mmo_map_server server[MAX_MAP_SERVERS]; int server_fd[MAX_MAP_SERVERS]; int login_fd; char userid[24]; char passwd[24]; char server_name[20]; char login_ip_str[16]; int login_port = 6900; char char_ip_str[16]; int char_ip; int char_port = 6121; int char_maintenance; int char_new; char char_txt[256]; char t_name[256]; #define CHAR_STATE_WAITAUTH 0 #define CHAR_STATE_AUTHOK 1 struct char_session_data { int state; int account_id, login_id1, login_id2, sex; int found_char[9]; }; #define AUTH_FIFO_SIZE 256 struct { int account_id, char_id, login_id1, char_pos, delflag, sex; } auth_fifo[AUTH_FIFO_SIZE]; int auth_fifo_pos = 0; int char_id_count = 100000; struct mmo_charstatus *char_dat; int char_num, char_max; int max_connect_user = 0; int autosave_interval = DEFAULT_AUTOSAVE_INTERVAL; // 초기 위치(conf 파일로부터 재설정 가능) struct point start_point = { "new_1-1.gat", 53, 111 }; int inter_pet_fromstr (char *str, struct s_pet *p) { int s; int tmp_int[16]; char tmp_str[256]; memset (p, 0, sizeof (struct s_pet)); // printf("sscanf pet main info\n"); s = sscanf (str, "%d, %d,%[^\t]\t%d, %d, %d, %d, %d, %d, %d, %d, %d", &tmp_int[0], &tmp_int[1], tmp_str, &tmp_int[2], &tmp_int[3], &tmp_int[4], &tmp_int[5], &tmp_int[6], &tmp_int[7], &tmp_int[8], &tmp_int[9], &tmp_int[10]); if (s != 12) return 1; p->pet_id = tmp_int[0]; p->class = tmp_int[1]; memcpy (p->name, tmp_str, 24); p->account_id = tmp_int[2]; p->char_id = tmp_int[3]; p->level = tmp_int[4]; p->egg_id = tmp_int[5]; p->equip = tmp_int[6]; p->intimate = tmp_int[7]; p->hungry = tmp_int[8]; p->rename_flag = tmp_int[9]; p->incuvate = tmp_int[10]; if (p->hungry < 0) p->hungry = 0; else if (p->hungry > 100) p->hungry = 100; if (p->intimate < 0) p->intimate = 0; else if (p->intimate > 1000) p->intimate = 1000; return 0; } //--------------------------------------------------------- int inter_pet_tosql (int pet_id, struct s_pet *p) { //`pet` (`pet_id`, `class`,`name`,`account_id`,`char_id`,`level`,`egg_id`,`equip`,`intimate`,`hungry`,`rename_flag`,`incuvate`) char tmp_sql[65535]; MYSQL_RES *sql_res; MYSQL_ROW sql_row; jstrescapecpy (t_name, p->name); if (p->hungry < 0) p->hungry = 0; else if (p->hungry > 100) p->hungry = 100; if (p->intimate < 0) p->intimate = 0; else if (p->intimate > 1000) p->intimate = 1000; sprintf (tmp_sql, "SELECT * FROM `pet` WHERE `pet_id`='%d'", pet_id); if (mysql_query (&mysql_handle, tmp_sql)) { printf ("DB server Error - %s\n", mysql_error (&mysql_handle)); } sql_res = mysql_store_result (&mysql_handle); sql_row = mysql_fetch_row (sql_res); //row fetching if (!sql_row) //no row -> insert sprintf (tmp_sql, "INSERT INTO `pet` (`pet_id`, `class`,`name`,`account_id`,`char_id`,`level`,`egg_id`,`equip`,`intimate`,`hungry`,`rename_flag`,`incuvate`) VALUES ('%d', '%d', '%s', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d')", p->pet_id, p->class, t_name, p->account_id, p->char_id, p->level, p->egg_id, p->equip, p->intimate, p->hungry, p->rename_flag, p->incuvate); else //row reside -> updating sprintf (tmp_sql, "UPDATE `pet` SET `class`='%d',`name`='%s',`account_id`='%d',`char_id`='%d',`level`='%d',`egg_id`='%d',`equip`='%d',`intimate`='%d',`hungry`='%d',`rename_flag`='%d',`incuvate`='%d' WHERE `pet_id`='%d'", p->class, t_name, p->account_id, p->char_id, p->level, p->egg_id, p->equip, p->intimate, p->hungry, p->rename_flag, p->incuvate, p->pet_id); mysql_free_result (sql_res); //resource free if (mysql_query (&mysql_handle, tmp_sql)) { printf ("DB server Error - %s\n", mysql_error (&mysql_handle)); } printf ("pet dump success! - %d:%s\n", pet_id, p->name); return 0; } int storage_tosql (int account_id, struct storage *p) { // id -> DB dump // storage {`account_id`/`id`/`nameid`/`amount`/`equip`/`identify`/`refine`/`attribute`/`card0`/`card1`/`card2`/`card3`} int i, j; j = 0; //printf ("starting storage dump to DB - id: %d\n", account_id); //delete old data. sprintf (tmp_sql, "DELETE FROM `storage` WHERE `account_id`='%d'", account_id); if (mysql_query (&mysql_handle, tmp_sql)) { printf ("DB server Error - %s\n", mysql_error (&mysql_handle)); } //printf ("all storage item was deleted ok\n"); for (i = 0; i < MAX_STORAGE; i++) { //printf ("save storage num: %d (%d:%d)\n",i, p->storage[i].nameid , p->storage[i].amount); if ((p->storage[i].nameid) && (p->storage[i].amount)) { sprintf (tmp_sql, "INSERT INTO `storage` (`account_id`,`nameid`,`amount`,`equip`,`identify`,`refine`,`attribute`,`card0`,`card1`,`card2`,`card3`,`broken`) VALUES ('%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d')", p->account_id, p->storage[i].nameid, p->storage[i].amount, p->storage[i].equip, p->storage[i].identify, p->storage[i].refine, p->storage[i].attribute, p->storage[i].card[0], p->storage[i].card[1], p->storage[i].card[2], p->storage[i].card[3], p->storage[i].broken); //printf ("%s\n",tmp_sql); if (mysql_query (&mysql_handle, tmp_sql)) { printf ("DB server Error - %s\n", mysql_error (&mysql_handle)); } j++; } } printf ("storage dump to DB - id: %d (total: %d)\n", account_id, j); return 0; } // char to storage int storage_fromstr (char *str, struct storage *p) { int tmp_int[256]; int set, next, len, i; set = sscanf (str, "%d, %d%n", &tmp_int[0], &tmp_int[1], &next); p->storage_amount = tmp_int[1]; if (set != 2) return 0; if (str[next] == '\n' || str[next] == '\r') return 1; next++; for (i = 0; str[next] && str[next] != '\t'; i++) { if (sscanf (str + next, "%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d%n", &tmp_int[0], &tmp_int[1], &tmp_int[2], &tmp_int[3], &tmp_int[4], &tmp_int[5], &tmp_int[6], &tmp_int[7], &tmp_int[8], &tmp_int[9], &tmp_int[10], &tmp_int[11], &len) == 12) { p->storage[i].id = tmp_int[0]; p->storage[i].nameid = tmp_int[1]; p->storage[i].amount = tmp_int[2]; p->storage[i].equip = tmp_int[3]; p->storage[i].identify = tmp_int[4]; p->storage[i].refine = tmp_int[5]; p->storage[i].attribute = tmp_int[6]; p->storage[i].card[0] = tmp_int[7]; p->storage[i].card[1] = tmp_int[8]; p->storage[i].card[2] = tmp_int[9]; p->storage[i].card[3] = tmp_int[10]; p->storage[i].broken = tmp_int[11]; next += len; if (str[next] == ' ') next++; } else if (sscanf (str + next, "%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d%n", &tmp_int[0], &tmp_int[1], &tmp_int[2], &tmp_int[3], &tmp_int[4], &tmp_int[5], &tmp_int[6], &tmp_int[7], &tmp_int[8], &tmp_int[9], &tmp_int[10], &len) == 11) { p->storage[i].id = tmp_int[0]; p->storage[i].nameid = tmp_int[1]; p->storage[i].amount = tmp_int[2]; p->storage[i].equip = tmp_int[3]; p->storage[i].identify = tmp_int[4]; p->storage[i].refine = tmp_int[5]; p->storage[i].attribute = tmp_int[6]; p->storage[i].card[0] = tmp_int[7]; p->storage[i].card[1] = tmp_int[8]; p->storage[i].card[2] = tmp_int[9]; p->storage[i].card[3] = tmp_int[10]; p->storage[i].broken = 0; next += len; if (str[next] == ' ') next++; } else return 0; } return 1; } ///////////////////////////////// int mmo_char_fromstr (char *str, struct mmo_charstatus *p) { int tmp_int[256]; int set, next, len, i; // initilialise character memset (p, '\0', sizeof (struct mmo_charstatus)); // If it's not char structure of version 1008 and after if ((set = sscanf (str, "%d\t%d,%d\t%[^\t]\t%d,%d,%d\t%d,%d,%d\t%d,%d,%d,%d\t%d,%d,%d,%d,%d,%d\t%d,%d" "\t%d,%d,%d\t%d,%d,%d\t%d,%d,%d\t%d,%d,%d,%d,%d" "\t%[^,],%d,%d\t%[^,],%d,%d,%d%n", &tmp_int[0], &tmp_int[1], &tmp_int[2], p->name, // &tmp_int[3], &tmp_int[4], &tmp_int[5], &tmp_int[6], &tmp_int[7], &tmp_int[8], &tmp_int[9], &tmp_int[10], &tmp_int[11], &tmp_int[12], &tmp_int[13], &tmp_int[14], &tmp_int[15], &tmp_int[16], &tmp_int[17], &tmp_int[18], &tmp_int[19], &tmp_int[20], &tmp_int[21], &tmp_int[22], &tmp_int[23], // &tmp_int[24], &tmp_int[25], &tmp_int[26], &tmp_int[27], &tmp_int[28], &tmp_int[29], &tmp_int[30], &tmp_int[31], &tmp_int[32], &tmp_int[33], &tmp_int[34], p->last_point.map, &tmp_int[35], &tmp_int[36], // p->save_point.map, &tmp_int[37], &tmp_int[38], &tmp_int[39], &next)) != 43) { tmp_int[39] = 0; // partner id // If not char structure from version 384 to 1007 if ((set = sscanf (str, "%d\t%d,%d\t%[^\t]\t%d,%d,%d\t%d,%d,%d\t%d,%d,%d,%d\t%d,%d,%d,%d,%d,%d\t%d,%d" "\t%d,%d,%d\t%d,%d,%d\t%d,%d,%d\t%d,%d,%d,%d,%d" "\t%[^,],%d,%d\t%[^,],%d,%d%n", &tmp_int[0], &tmp_int[1], &tmp_int[2], p->name, // &tmp_int[3], &tmp_int[4], &tmp_int[5], &tmp_int[6], &tmp_int[7], &tmp_int[8], &tmp_int[9], &tmp_int[10], &tmp_int[11], &tmp_int[12], &tmp_int[13], &tmp_int[14], &tmp_int[15], &tmp_int[16], &tmp_int[17], &tmp_int[18], &tmp_int[19], &tmp_int[20], &tmp_int[21], &tmp_int[22], &tmp_int[23], // &tmp_int[24], &tmp_int[25], &tmp_int[26], &tmp_int[27], &tmp_int[28], &tmp_int[29], &tmp_int[30], &tmp_int[31], &tmp_int[32], &tmp_int[33], &tmp_int[34], p->last_point.map, &tmp_int[35], &tmp_int[36], // p->save_point.map, &tmp_int[37], &tmp_int[38], &next)) != 42) { // It's char structure of a version before 384 tmp_int[26] = 0; // pet id set = sscanf (str, "%d\t%d,%d\t%[^\t]\t%d,%d,%d\t%d,%d,%d\t%d,%d,%d,%d\t%d,%d,%d,%d,%d,%d\t%d,%d" "\t%d,%d,%d\t%d,%d\t%d,%d,%d\t%d,%d,%d,%d,%d" "\t%[^,],%d,%d\t%[^,],%d,%d%n", &tmp_int[0], &tmp_int[1], &tmp_int[2], p->name, // &tmp_int[3], &tmp_int[4], &tmp_int[5], &tmp_int[6], &tmp_int[7], &tmp_int[8], &tmp_int[9], &tmp_int[10], &tmp_int[11], &tmp_int[12], &tmp_int[13], &tmp_int[14], &tmp_int[15], &tmp_int[16], &tmp_int[17], &tmp_int[18], &tmp_int[19], &tmp_int[20], &tmp_int[21], &tmp_int[22], &tmp_int[23], // &tmp_int[24], &tmp_int[25], // &tmp_int[27], &tmp_int[28], &tmp_int[29], &tmp_int[30], &tmp_int[31], &tmp_int[32], &tmp_int[33], &tmp_int[34], p->last_point.map, &tmp_int[35], &tmp_int[36], // p->save_point.map, &tmp_int[37], &tmp_int[38], &next); set += 2; //printf("char: old char data ver.1\n"); // Char structure of version 1007 or older } else { set++; //printf("char: old char data ver.2\n"); } // Char structure of version 1008+ } else { //printf("char: new char data ver.3\n"); } if (set != 43) return 0; p->char_id = tmp_int[0]; p->account_id = tmp_int[1]; p->char_num = tmp_int[2]; p->class = tmp_int[3]; p->base_level = tmp_int[4]; p->job_level = tmp_int[5]; p->base_exp = tmp_int[6]; p->job_exp = tmp_int[7]; p->zeny = tmp_int[8]; p->hp = tmp_int[9]; p->max_hp = tmp_int[10]; p->sp = tmp_int[11]; p->max_sp = tmp_int[12]; p->str = tmp_int[13]; p->agi = tmp_int[14]; p->vit = tmp_int[15]; p->int_ = tmp_int[16]; p->dex = tmp_int[17]; p->luk = tmp_int[18]; p->status_point = tmp_int[19]; p->skill_point = tmp_int[20]; p->option = tmp_int[21]; p->karma = tmp_int[22]; p->manner = tmp_int[23]; p->party_id = tmp_int[24]; p->guild_id = tmp_int[25]; p->pet_id = tmp_int[26]; p->hair = tmp_int[27]; p->hair_color = tmp_int[28]; p->clothes_color = tmp_int[29]; p->weapon = tmp_int[30]; p->shield = tmp_int[31]; p->head_top = tmp_int[32]; p->head_mid = tmp_int[33]; p->head_bottom = tmp_int[34]; p->last_point.x = tmp_int[35]; p->last_point.y = tmp_int[36]; p->save_point.x = tmp_int[37]; p->save_point.y = tmp_int[38]; p->partner_id = tmp_int[39]; // Some checks for (i = 0; i < char_num; i++) { if (char_dat[i].char_id == p->char_id) { printf ("\033[1;31mmmo_auth_init: ******Error: a character has an identical id to another.\n"); printf (" character id #%d -> new character not readed.\n", p->char_id); printf (" Character saved in log file.\033[0m\n"); return -1; } else if (strcmp (char_dat[i].name, p->name) == 0) { printf ("\033[1;31mmmo_auth_init: ******Error: character name already exists.\n"); printf (" character name '%s' -> new character not readed.\n", p->name); printf (" Character saved in log file.\033[0m\n"); return -2; } } if (str[next] == '\n' || str[next] == '\r') return 1; // 륷딮긢�[�^ next++; for (i = 0; str[next] && str[next] != '\t'; i++) { set = sscanf (str + next, "%[^,],%d,%d%n", p->memo_point[i].map, &tmp_int[0], &tmp_int[1], &len); if (set != 3) return -3; p->memo_point[i].x = tmp_int[0]; p->memo_point[i].y = tmp_int[1]; next += len; if (str[next] == ' ') next++; } next++; for (i = 0; str[next] && str[next] != '\t'; i++) { if (sscanf (str + next, "%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d%n", &tmp_int[0], &tmp_int[1], &tmp_int[2], &tmp_int[3], &tmp_int[4], &tmp_int[5], &tmp_int[6], &tmp_int[7], &tmp_int[8], &tmp_int[9], &tmp_int[10], &tmp_int[11], &len) == 12) { // do nothing, it's ok } else if (sscanf (str + next, "%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d%n", &tmp_int[0], &tmp_int[1], &tmp_int[2], &tmp_int[3], &tmp_int[4], &tmp_int[5], &tmp_int[6], &tmp_int[7], &tmp_int[8], &tmp_int[9], &tmp_int[10], &len) == 11) { tmp_int[11] = 0; // broken doesn't exist in this version -> 0 } else // invalid structure return -4; p->inventory[i].id = tmp_int[0]; p->inventory[i].nameid = tmp_int[1]; p->inventory[i].amount = tmp_int[2]; p->inventory[i].equip = tmp_int[3]; p->inventory[i].identify = tmp_int[4]; p->inventory[i].refine = tmp_int[5]; p->inventory[i].attribute = tmp_int[6]; p->inventory[i].card[0] = tmp_int[7]; p->inventory[i].card[1] = tmp_int[8]; p->inventory[i].card[2] = tmp_int[9]; p->inventory[i].card[3] = tmp_int[10]; p->inventory[i].broken = tmp_int[11]; next += len; if (str[next] == ' ') next++; } next++; for (i = 0; str[next] && str[next] != '\t'; i++) { if (sscanf (str + next, "%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d%n", &tmp_int[0], &tmp_int[1], &tmp_int[2], &tmp_int[3], &tmp_int[4], &tmp_int[5], &tmp_int[6], &tmp_int[7], &tmp_int[8], &tmp_int[9], &tmp_int[10], &tmp_int[11], &len) == 12) { // do nothing, it's ok } else if (sscanf (str + next, "%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d%n", &tmp_int[0], &tmp_int[1], &tmp_int[2], &tmp_int[3], &tmp_int[4], &tmp_int[5], &tmp_int[6], &tmp_int[7], &tmp_int[8], &tmp_int[9], &tmp_int[10], &len) == 11) { tmp_int[11] = 0; // broken doesn't exist in this version -> 0 } else // invalid structure return -5; p->cart[i].id = tmp_int[0]; p->cart[i].nameid = tmp_int[1]; p->cart[i].amount = tmp_int[2]; p->cart[i].equip = tmp_int[3]; p->cart[i].identify = tmp_int[4]; p->cart[i].refine = tmp_int[5]; p->cart[i].attribute = tmp_int[6]; p->cart[i].card[0] = tmp_int[7]; p->cart[i].card[1] = tmp_int[8]; p->cart[i].card[2] = tmp_int[9]; p->cart[i].card[3] = tmp_int[10]; p->cart[i].broken = tmp_int[11]; next += len; if (str[next] == ' ') next++; } next++; for (i = 0; str[next] && str[next] != '\t'; i++) { set = sscanf (str + next, "%d,%d%n", &tmp_int[0], &tmp_int[1], &len); if (set != 2) return -6; p->skill[tmp_int[0]].id = tmp_int[0]; p->skill[tmp_int[0]].lv = tmp_int[1]; next += len; if (str[next] == ' ') next++; } next++; for (i = 0; str[next] && str[next] != '\t' && str[next] != '\n' && str[next] != '\r'; i++) { // global_reg렳몧댥멟궻athena.txt뚚듂궻궫귕덇돒'\n'�`긃긞긏 set = sscanf (str + next, "%[^,],%d%n", p->global_reg[i].str, &p->global_reg[i].value, &len); if (set != 2) { // because some scripts are not correct, the str can be "". So, we must check that. // If it's, we must not refuse the character, but just this REG value. // Character line will have something like: nov_2nd_cos,9 ,9 nov_1_2_cos_c,1 (here, ,9 is not good) if (str[next] == ',' && sscanf (str + next, ",%d%n", &p->global_reg[i].value, &len) == 1) i--; else return -7; } next += len; if (str[next] == ' ') next++; } p->global_reg_num = i; return 1; } //========================================================================================================== int mmo_char_tosql (int char_id, struct mmo_charstatus *p) { int i, save_flag; save_flag = char_id; printf ("request save char data... (%d)\n", char_id); //`char`( `char_id`,`account_id`,`char_num`,`name`,`class`,`base_level`,`job_level`,`base_exp`,`job_exp`,`zeny`, //9 //`str`,`agi`,`vit`,`int`,`dex`,`luk`, //15 //`max_hp`,`hp`,`max_sp`,`sp`,`status_point`,`skill_point`, //21 //`option`,`karma`,`manner`,`party_id`,`guild_id`,`pet_id`, //27 //`hair`,`hair_color`,`clothes_color`,`weapon`,`shield`,`head_top`,`head_mid`,`head_bottom`, //35 //`last_map`,`last_x`,`last_y`,`save_map`,`save_x`,`save_y`) sprintf (tmp_sql, "INSERT INTO `char` SET `char_id`='%d', `account_id`='%d', `char_num`='%d', `name`='%s', `class`='%d', `base_level`='%d', `job_level`='%d'," "`base_exp`='%d', `job_exp`='%d', `zeny`='%d'," "`max_hp`='%d',`hp`='%d',`max_sp`='%d',`sp`='%d',`status_point`='%d',`skill_point`='%d'," "`str`='%d',`agi`='%d',`vit`='%d',`int`='%d',`dex`='%d',`luk`='%d'," "`option`='%d',`karma`='%d',`manner`='%d',`party_id`='%d',`guild_id`='%d',`pet_id`='%d'," "`hair`='%d',`hair_color`='%d',`clothes_color`='%d',`weapon`='%d',`shield`='%d',`head_top`='%d',`head_mid`='%d',`head_bottom`='%d'," "`last_map`='%s',`last_x`='%d',`last_y`='%d',`save_map`='%s',`save_x`='%d',`save_y`='%d', `partner_id` = '%d'", char_id, p->account_id, p->char_num, p->name, p->class, p->base_level, p->job_level, p->base_exp, p->job_exp, p->zeny, p->max_hp, p->hp, p->max_sp, p->sp, p->status_point, p->skill_point, p->str, p->agi, p->vit, p->int_, p->dex, p->luk, p->option, p->karma, p->manner, p->party_id, p->guild_id, p->pet_id, p->hair, p->hair_color, p->clothes_color, p->weapon, p->shield, p->head_top, p->head_mid, p->head_bottom, p->last_point.map, p->last_point.x, p->last_point.y, p->save_point.map, p->save_point.x, p->save_point.y, p->partner_id); if (mysql_query (&mysql_handle, tmp_sql)) { printf ("DB server Error (update `char`)- %s\n", mysql_error (&mysql_handle)); } //`memo` (`memo_id`,`char_id`,`map`,`x`,`y`) sprintf (tmp_sql, "DELETE FROM `memo` WHERE `char_id`='%d'", char_id); if (mysql_query (&mysql_handle, tmp_sql)) { printf ("DB server Error (delete `memo`)- %s\n", mysql_error (&mysql_handle)); } //insert here. for (i = 0; i < 10; i++) { if (p->memo_point[i].map[0]) { sprintf (tmp_sql, "INSERT INTO `memo`(`char_id`,`map`,`x`,`y`) VALUES ('%d', '%s', '%d', '%d')", char_id, p->memo_point[i].map, p->memo_point[i].x, p->memo_point[i].y); if (mysql_query (&mysql_handle, tmp_sql)) printf ("DB server Error (insert `memo`)- %s\n", mysql_error (&mysql_handle)); } } //`inventory` (`id`,`char_id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`, `card0`, `card1`, `card2`, `card3`, `broken`) sprintf (tmp_sql, "DELETE FROM `inventory` WHERE `char_id`='%d'", char_id); if (mysql_query (&mysql_handle, tmp_sql)) { printf ("DB server Error (delete `inventory`)- %s\n", mysql_error (&mysql_handle)); } //insert here. for (i = 0; i < MAX_INVENTORY; i++) { if (p->inventory[i].nameid) { sprintf (tmp_sql, "INSERT INTO `inventory`(`id`,`char_id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`, `card0`, `card1`, `card2`, `card3`, `broken`)" " VALUES ('%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d')", p->inventory[i].id, char_id, p->inventory[i].nameid, p->inventory[i].amount, p->inventory[i].equip, p->inventory[i].identify, p->inventory[i].refine, p->inventory[i].attribute, p->inventory[i].card[0], p->inventory[i].card[1], p->inventory[i].card[2], p->inventory[i].card[3], p->inventory[i].broken); if (mysql_query (&mysql_handle, tmp_sql)) printf ("DB server Error (insert `inventory`)- %s\n", mysql_error (&mysql_handle)); } } //`cart_inventory` (`id`,`char_id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`, `card0`, `card1`, `card2`, `card3`, `broken`) sprintf (tmp_sql, "DELETE FROM `cart_inventory` WHERE `char_id`='%d'", char_id); if (mysql_query (&mysql_handle, tmp_sql)) { printf ("DB server Error (delete `cart_inventory`)- %s\n", mysql_error (&mysql_handle)); } //insert here. for (i = 0; i < MAX_CART; i++) { if (p->cart[i].nameid) { sprintf (tmp_sql, "INSERT INTO `cart_inventory`(`id`,`char_id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`, `card0`, `card1`, `card2`, `card3`, `broken`)" " VALUES ('%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d' )", p->cart[i].id, char_id, p->cart[i].nameid, p->cart[i].amount, p->cart[i].equip, p->cart[i].identify, p->cart[i].refine, p->cart[i].attribute, p->cart[i].card[0], p->cart[i].card[1], p->cart[i].card[2], p->cart[i].card[3], p->cart[i].broken); if (mysql_query (&mysql_handle, tmp_sql)) { printf ("DB server Error (insert `cart_inventory`)- %s\n", mysql_error (&mysql_handle)); } } } //`skill` (`char_id`, `id`, `lv`) sprintf (tmp_sql, "DELETE FROM `skill` WHERE `char_id`='%d'", char_id); if (mysql_query (&mysql_handle, tmp_sql)) { printf ("DB server Error (delete `skill`)- %s\n", mysql_error (&mysql_handle)); } //insert here. for (i = 0; i < MAX_SKILL; i++) { if (p->skill[i].id) { if (p->skill[i].id && p->skill[i].flag != 1) { sprintf (tmp_sql, "INSERT INTO `skill`(`char_id`,`id`, `lv`) VALUES ('%d', '%d', '%d')", char_id, p->skill[i].id, (p->skill[i].flag == 0) ? p->skill[i].lv : p->skill[i].flag - 2); if (mysql_query (&mysql_handle, tmp_sql)) { printf ("DB server Error (insert `skill`)- %s\n", mysql_error (&mysql_handle)); } } } } //`global_reg_value` (`char_id`, `str`, `value`) sprintf (tmp_sql, "DELETE FROM `global_reg_value` WHERE `char_id`='%d'", char_id); if (mysql_query (&mysql_handle, tmp_sql)) { printf ("DB server Error (delete `global_reg_value`)- %s\n", mysql_error (&mysql_handle)); } //insert here. for (i = 0; i < p->global_reg_num; i++) { if (p->global_reg[i].value != 0) { sprintf (tmp_sql, "INSERT INTO `global_reg_value` (`char_id`, `str`, `value`) VALUES ('%d', '%s','%d')", char_id, p->global_reg[i].str, p->global_reg[i].value); if (mysql_query (&mysql_handle, tmp_sql)) { printf ("DB server Error (insert `global_reg_value`)- %s\n", mysql_error (&mysql_handle)); } } } printf ("saving char is done... (%d)\n", char_id); save_flag = 0; return 0; } //========================================================================================================== int mmo_char_init (void) { char line[65536]; struct s_pet *p; int ret; int i = 0, set, tmp_int[2], c = 0; char input; FILE *fp; //DB connection initialized mysql_init (&mysql_handle); printf ("Connect DB server.... (inter server)\n"); if (!mysql_real_connect (&mysql_handle, db_server_ip, db_server_id, db_server_pw, db_server_logindb, db_server_port, (char *) NULL, 0)) { //pointer check printf ("%s\n", mysql_error (&mysql_handle)); exit (1); } else { printf ("connect success! (inter server)\n"); } printf ("Warning : Make sure you backup your databases before continuing!\n"); printf ("\nDo you wish to convert your Character Database to SQL? (y/n) : "); input = getchar (); if (input == 'y' || input == 'Y') { printf ("\nConverting Character Database...\n"); fp = fopen_ ("save/athena.txt", "r"); char_dat = malloc (sizeof (char_dat[0]) * 256); char_max = 256; if (fp == NULL) return 0; while (fgets (line, 65535, fp)) { if (char_num >= char_max) { char_max += 256; char_dat = realloc (char_dat, sizeof (char_dat[0]) * char_max); } memset (&char_dat[char_num], 0, sizeof (char_dat[0])); ret = mmo_char_fromstr (line, &char_dat[char_num]); if (ret) { mmo_char_tosql (char_dat[char_num].char_id, &char_dat[char_num]); printf ("convert %d -> DB\n", char_dat[char_num].char_id); if (char_dat[char_num].char_id >= char_id_count) char_id_count = char_dat[char_num].char_id + 1; char_num++; } } printf ("char data convert end\n"); fclose_ (fp); } while (getchar () != '\n'); printf ("\nDo you wish to convert your Storage Database to SQL? (y/n) : "); input = getchar (); if (input == 'y' || input == 'Y') { printf ("\nConverting Storage Database...\n"); fp = fopen_ (storage_txt, "r"); if (fp == NULL) { printf ("cant't read : %s\n", storage_txt); return 0; } while (fgets (line, 65535, fp)) { set = sscanf (line, "%d,%d", &tmp_int[0], &tmp_int[1]); if (set == 2) { if (i == 0) { storage = malloc (sizeof (struct storage)); } else { storage = realloc (storage, sizeof (struct storage) * (i + 1)); } memset (&storage[i], 0, sizeof (struct storage)); storage[i].account_id = tmp_int[0]; storage_fromstr (line, &storage[i]); storage_tosql (tmp_int[0], &storage[i]); //to sql. (dump) i++; } } fclose_ (fp); } while (getchar () != '\n'); printf ("\nDo you wish to convert your Pet Database to SQL? (y/n) : "); input = getchar (); if (input == 'y' || input == 'Y') { printf ("\nConverting Pet Database...\n"); if ((fp = fopen_ (pet_txt, "r")) == NULL) return 1; p = malloc (sizeof (struct s_pet)); while (fgets (line, sizeof (line), fp)) { if (p == NULL) { printf ("int_pet: out of memory!\n"); exit (0); } if (inter_pet_fromstr (line, p) == 0 && p->pet_id > 0) { //pet dump inter_pet_tosql (p->pet_id, p); } else { printf ("int_pet: broken data [%s] line %d\n", pet_txt, c); } c++; } fclose_ (fp); } return 0; } int inter_config_read (const char *cfgName) { printf ("start reading interserver configuration: %s\n", cfgName); int i; char line[1024], w1[1024], w2[1024]; FILE *fp; fp = fopen_ (cfgName, "r"); if (fp == NULL) { printf ("file not found: %s\n", cfgName); return 1; } while (fgets (line, 1020, fp)) { i = sscanf (line, "%[^:]:%s", w1, w2); if (i != 2) continue; if (strcmpi (w1, "storage_txt") == 0) { printf ("set storage_txt : %s\n", w2); strncpy (storage_txt, w2, sizeof (storage_txt)); } else if (strcmpi (w1, "pet_txt") == 0) { printf ("set pet_txt : %s\n", w2); strncpy (pet_txt, w2, sizeof (pet_txt)); } //add for DB connection else if (strcmpi (w1, "db_server_ip") == 0) { strcpy (db_server_ip, w2); printf ("set db_server_ip : %s\n", w2); } else if (strcmpi (w1, "db_server_port") == 0) { db_server_port = atoi (w2); printf ("set db_server_port : %s\n", w2); } else if (strcmpi (w1, "db_server_id") == 0) { strcpy (db_server_id, w2); printf ("set db_server_id : %s\n", w2); } else if (strcmpi (w1, "db_server_pw") == 0) { strcpy (db_server_pw, w2); printf ("set db_server_pw : %s\n", w2); } else if (strcmpi (w1, "db_server_logindb") == 0) { strcpy (db_server_logindb, w2); printf ("set db_server_logindb : %s\n", w2); } } fclose_ (fp); printf ("success reading interserver configuration\n"); return 0; } int char_config_read (const char *cfgName) { printf ("start reading interserver configuration: %s\n", cfgName); int i; char line[1024], w1[1024], w2[1024]; FILE *fp; fp = fopen_ (cfgName, "r"); if (fp == NULL) { printf ("file not found: %s\n", cfgName); return 1; } while (fgets (line, 1020, fp)) { if (line[0] == '/' && line[1] == '/') continue; i = sscanf (line, "%[^:]:%s", w1, w2); if (i != 2) continue; if (strcmpi (w1, "char_txt") == 0) { printf ("set char_txt : %s\n", w2); strcpy (char_txt, w2); } } fclose_ (fp); printf ("reading configure done.....\n"); return 0; } int do_init (int argc, char **argv) { char_config_read ((argc > 1) ? argv[1] : CHAR_CONF_NAME); inter_config_read ((argc > 2) ? argv[2] : inter_cfgName); mmo_char_init (); printf ("all conversion success!\n"); exit (0); return 0; }