Fixed some file types

git-svn-id: https://rathena.svn.sourceforge.net/svnroot/rathena/athena@172 54d463be-8e91-2dee-dedb-b68131a5f0ec

1 files changed, 755 insertions, 755 deletions

diff --git a/src/char_sql/int_party.c b/src/char_sql/int_party.c
index 12e2385c9..84de078c9 100644
--- a/src/char_sql/int_party.c
+++ b/src/char_sql/int_party.c
@@ -1,755 +1,755 @@
-//

-// original code from athena

-// SQL conversion by hack

-//

-

-#include "char.h"

-#include "strlib.h"

-#include "socket.h"	

-#include <stdio.h>

-#include <stdlib.h>

-#include <string.h>

-

-static struct party *party_pt;

-static int party_newid=100;

-

-int mapif_party_broken(int party_id,int flag);

-int party_check_empty(struct party *p);

-int mapif_parse_PartyLeave(int fd,int party_id,int account_id);

-

-// Save party to mysql

-int inter_party_tosql(int party_id,struct party *p)

-{

-	// 'party' ('party_id','name','exp','item','leader')

-	

-	char t_name[100];

-	char t_member[24];

-	int party_member = 0, party_online_member = 0;

-	int party_exist = 0;

-	int leader_id = 0;

-	int i = 0;

-	

-	printf("(\033[1;64m%d\033[0m)    Request save party - ",party_id);

-	

-	jstrescapecpy(t_name, p->name);

-	

-	if (p==NULL || party_id==0 || p->party_id ==0 || party_id!=p->party_id) {

-		printf("- Party pointer or party_id error \n");

-		return 0;

-	}

-	

-	// Check if party exists	

-	sprintf(tmp_sql,"SELECT count(*) FROM `%s` WHERE `party_id`='%d'",party_db, party_id);

-	if(mysql_query(&mysql_handle, tmp_sql) ) {

-		printf("DB server Error - %s\n", mysql_error(&mysql_handle) );

-		return 0;

-	}

-	sql_res = mysql_store_result(&mysql_handle) ;

-	if (sql_res!=NULL && mysql_num_rows(sql_res)>0) {

-		sql_row = mysql_fetch_row(sql_res);

-		party_exist =  atoi (sql_row[0]);

-		//printf("- Check if party %d exists : %s\n",party_id,party_exist==0?"No":"Yes");

-	}

-	mysql_free_result(sql_res) ; //resource free

-

-	if (party_exist >0){

-		// Check members in party

-		sprintf(tmp_sql,"SELECT count(*) FROM `%s` WHERE `party_id`='%d'",char_db, party_id);

-		if(mysql_query(&mysql_handle, tmp_sql) ) {

-			printf("DB server Error - %s\n", mysql_error(&mysql_handle) );

-			return 0;

-		}

-		sql_res = mysql_store_result(&mysql_handle) ;

-		if (sql_res!=NULL && mysql_num_rows(sql_res)>0) {

-			sql_row = mysql_fetch_row(sql_res);

-			

-			party_member =  atoi (sql_row[0]);

-		//	printf("- Check members in party %d : %d \n",party_id,party_member);

-

-		}

-		mysql_free_result(sql_res) ; //resource free

-	

-		party_online_member = 0;

-		i=0;

-		while (i<MAX_PARTY){

-			if (p->member[i].account_id>0) party_online_member++;

-			i++;

-		}

-		

-		//if (party_online_member==0) printf("- No member online \n"); else printf("- Some member %d online \n", party_online_member);

-			

-		if (party_member <= 0 && party_online_member == 0) {

-

-			// Delete the party, if has no member.

-			sprintf(tmp_sql,"DELETE FROM `%s` WHERE `party_id`='%d'",party_db, party_id);

-			if(mysql_query(&mysql_handle, tmp_sql) ) {

-				printf("DB server Error - %s\n", mysql_error(&mysql_handle) );

-			}

-		//	printf("No member in party %d, break it \n",party_id);

-			memset(p, 0, sizeof(struct party));

-			return 0;

-		} else {

-			// Update party information, if exists

-			

-			int i=0;

-				

-			for (i=0;i<MAX_PARTY;i++){

-

-				if (p->member[i].account_id>0){

-					sprintf(tmp_sql,"UPDATE `%s` SET `party_id`='%d', `online`='%d' WHERE `account_id`='%d' AND `name`='%s'",

-						char_db, party_id, p->member[i].online, p->member[i].account_id,jstrescapecpy(t_member,p->member[i].name));	

-					//printf("%s",tmp_sql);

-					if(mysql_query(&mysql_handle, tmp_sql) ) {

-						printf("DB server Error (update `char`)- %s\n", mysql_error(&mysql_handle) );

-					}

-				}

-			}

-			

-			

-			sprintf(tmp_sql,"UPDATE `%s` SET `name`='%s', `exp`='%d', `item`='%d', `leader_id`=`leader_id` WHERE `party_id`='%d'",

-				party_db, t_name,p->exp,p->item,party_id);	

-			if(mysql_query(&mysql_handle, tmp_sql) ) {

-				printf("DB server Error (inset/update `party`)- %s\n", mysql_error(&mysql_handle) );

-			}

-

-			

-		//	printf("- Update party %d information \n",party_id);

-		}

-	} else {

-		// Add new party, if not exist

-		int i = 0;

-		while (i<MAX_PARTY&&((p->member[i].account_id>0&&p->member[i].leader==0)||(p->member[i].account_id<0))) i++;

-		if (i<MAX_PARTY) leader_id = p->member[i].account_id;

-		sprintf(tmp_sql,"INSERT INTO `%s`  (`party_id`, `name`, `exp`, `item`, `leader_id`) VALUES ('%d', '%s', '%d', '%d', '%d')",

-			party_db, party_id, t_name, p->exp, p->item,leader_id);

-		if(mysql_query(&mysql_handle, tmp_sql) ) {

-			printf("DB server Error (inset/update `party`)- %s\n", mysql_error(&mysql_handle) );

-			return 0;

-		}

-		

-		sprintf(tmp_sql,"UPDATE `%s` SET `party_id`='%d', `online`='1'  WHERE `account_id`='%d' AND `name`='%s'",

-			char_db, party_id,leader_id, jstrescapecpy(t_member,p->member[i].name));	

-		if(mysql_query(&mysql_handle, tmp_sql) ) {

-			printf("DB server Error (inset/update `party`)- %s\n", mysql_error(&mysql_handle) );

-		}

-		

-		//printf("- Insert new party %d  \n",party_id);	

-	}

-	

-	printf("Party save success\n");

-	return 0;	

-

-}

-

-// Read party from mysql

-int inter_party_fromsql(int party_id,struct party *p)

-{

-	int leader_id=0;

-	printf("(\033[1;64m%d\033[0m)    Request load party - ",party_id);

-	

-	memset(p, 0, sizeof(struct party));

-	

-	sprintf(tmp_sql,"SELECT `party_id`, `name`,`exp`,`item`, `leader_id` FROM `%s` WHERE `party_id`='%d'",party_db, party_id);

-	if(mysql_query(&mysql_handle, tmp_sql) ) {

-		printf("DB server Error (select `party`)- %s\n", mysql_error(&mysql_handle) );

-		return 0;

-	}

-	

-	sql_res = mysql_store_result(&mysql_handle) ;

-	if (sql_res!=NULL && mysql_num_rows(sql_res)>0) {

-		sql_row = mysql_fetch_row(sql_res);

-	//	printf("- Read party %d from MySQL\n",party_id);

-		p->party_id = party_id;

-		strcpy(p->name, sql_row[1]);

-		p->exp = atoi(sql_row[2]);

-		p->item = atoi(sql_row[3]);

-		leader_id = atoi(sql_row[4]);

-	} else {

-		mysql_free_result(sql_res);

-	//	printf("- Cannot find party %d \n",party_id);

-		return 0;

-	}

-		

-	mysql_free_result(sql_res);

-	

-	// Load members

-	sprintf(tmp_sql,"SELECT `account_id`, `name`,`base_level`,`last_map`,`online` FROM `%s` WHERE `party_id`='%d'",char_db, party_id);

-	if(mysql_query(&mysql_handle, tmp_sql) ) {

-		printf("DB server Error (select `party`)- %s\n", mysql_error(&mysql_handle) );

-		return 0;

-	}

-	sql_res = mysql_store_result(&mysql_handle) ;

-	if (sql_res!=NULL && mysql_num_rows(sql_res)>0) {

-		int i;

-		for(i=0;(sql_row = mysql_fetch_row(sql_res));i++){

-			struct party_member *m = &p->member[i];

-			m->account_id = atoi(sql_row[0]);

-			if (m->account_id == leader_id) m->leader = 1; else m->leader = 0;

-			strncpy(m->name,sql_row[1],sizeof(m->name));

-			m->lv = atoi(sql_row[2]);

-			strncpy(m->map,sql_row[3],sizeof(m->map));

-			m->online = atoi(sql_row[4]);

-		}

-	//	printf("- %d members found in party %d \n",i,party_id);

-	}

-	mysql_free_result(sql_res);

-		

-	

-	printf("Party load success\n");

-	return 0;

-	

-}

-

-int inter_party_sql_init(){

-	int i;

-	

-	//memory alloc

-	printf("interserver party memory initialize.... (%d byte)\n",sizeof(struct party));

-	party_pt = calloc(sizeof(struct party), 1);

-	

-	sprintf(tmp_sql,"UPDATE `%s` SET `online`='0'", char_db);	

-	if(mysql_query(&mysql_handle, tmp_sql) ) {

-		printf("DB server Error (update `char`)- %s\n", mysql_error(&mysql_handle) );

-	}

-	

-	sprintf (tmp_sql , "SELECT count(*) FROM `%s`",party_db);

-	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);

-	printf("total party data -> '%s'.......\n",sql_row[0]);

-	i = atoi (sql_row[0]);

-	mysql_free_result(sql_res);

-

-	if (i > 0) {

-		//set party_newid

-		sprintf (tmp_sql , "SELECT max(`party_id`) FROM `%s`", party_db);

-		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);

-		party_newid = atoi (sql_row[0])+1;

-		mysql_free_result(sql_res);

-	}

-	

-	printf("set party_newid: %d.......\n",party_newid);

-	

-	return 0;

-}

-

-

-// Search for the party according to its name

-struct party* search_partyname(char *str)

-{

-	struct party *p=NULL;

-	int leader_id = 0;

-	char t_name[24];

-	

-	sprintf(tmp_sql,"SELECT `party_id`, `name`,`exp`,`item`,`leader_id` FROM `%s` WHERE `name`='%s'",party_db, jstrescapecpy(t_name,str));	

-	if(mysql_query(&mysql_handle, tmp_sql) ) {

-			printf("DB server Error (select `party`)- %s\n", mysql_error(&mysql_handle) );

-	}

-	sql_res = mysql_store_result(&mysql_handle) ;

-	if (sql_res==NULL || mysql_num_rows(sql_res)<=0) { mysql_free_result(sql_res); return p; }

-	sql_row = mysql_fetch_row(sql_res);

-	p = party_pt;

-	p->party_id = atoi(sql_row[0]);

-	strcpy(p->name, sql_row[1]);

-	p->exp = atoi(sql_row[2]);

-	p->item = atoi(sql_row[3]);

-	leader_id = atoi(sql_row[4]);

-	mysql_free_result(sql_res);

-

-	// Load members

-	sprintf(tmp_sql,"SELECT `account_id`, `name`,`base_level`,`last_map`,`online` FROM `%s` WHERE `party_id`='%d'",char_db, p->party_id);

-	if(mysql_query(&mysql_handle, tmp_sql) ) {

-		printf("DB server Error (select `party`)- %s\n", mysql_error(&mysql_handle) );

-		return 0;

-	}

-	sql_res = mysql_store_result(&mysql_handle) ;

-	if (sql_res!=NULL && mysql_num_rows(sql_res)>0) {

-		int i;

-		for(i=0;(sql_row = mysql_fetch_row(sql_res));i++){

-			struct party_member *m = &p->member[i];

-			m->account_id = atoi(sql_row[0]);

-			if (m->account_id == leader_id) m->leader = 1; else m->leader = 0;

-			strncpy(m->name,sql_row[1],sizeof(m->name));

-			m->lv = atoi(sql_row[2]);

-			strncpy(m->map,sql_row[3],sizeof(m->map));

-			m->online = atoi(sql_row[4]);

-		}

-		printf("- %d members found in party %d \n",i,p->party_id);

-	}

-	mysql_free_result(sql_res);

-

-	return p;

-}

-

-// EXP公平分配できるかチェック

-int party_check_exp_share(struct party *p)

-{

-	int i;

-	int maxlv=0,minlv=0x7fffffff;

-	for(i=0;i<MAX_PARTY;i++){

-		int lv=p->member[i].lv;

-		if( p->member[i].online ){

-			if( lv < minlv ) minlv=lv;

-			if( maxlv < lv ) maxlv=lv;

-		}

-	}

-	return (maxlv==0 || maxlv-minlv<=party_share_level);

-}

-// Is there any member in the party?

-int party_check_empty(struct party *p)

-{

-	int i;

-	if (p==NULL||p->party_id==0) return 1;

-//	printf("party check empty %08X\n",(int)p);

-	for(i=0;i<MAX_PARTY;i++){

-//		printf("%d acc=%d\n",i,p->member[i].account_id);

-		if(p->member[i].account_id>0){

-			return 0;

-		}

-	}

-	// If there is no member, then break the party

-	mapif_party_broken(p->party_id,0);

-	inter_party_tosql(p->party_id,p);

-	return 1;

-}

-

-

-// Check if a member is in two party, not necessary :)

-int party_check_conflict(int party_id,int account_id,char *nick)

-{

-	return 0;

-}

-

-//-------------------------------------------------------------------

-// map serverへの通信

-

-// パーティ作成可否

-int mapif_party_created(int fd,int account_id,struct party *p)

-{

-	WFIFOW(fd,0)=0x3820;

-	WFIFOL(fd,2)=account_id;

-	if(p!=NULL){

-		WFIFOB(fd,6)=0;

-		WFIFOL(fd,7)=p->party_id;

-		memcpy(WFIFOP(fd,11),p->name,24);

-		printf("int_party: created! %d %s\n",p->party_id,p->name);

-	}else{

-		WFIFOB(fd,6)=1;

-		WFIFOL(fd,7)=0;

-		memcpy(WFIFOP(fd,11),"error",24);

-	}

-	WFIFOSET(fd,35);

-	return 0;

-}

-

-// パーティ情報見つからず

-int mapif_party_noinfo(int fd,int party_id)

-{

-	WFIFOW(fd,0)=0x3821;

-	WFIFOW(fd,2)=8;

-	WFIFOL(fd,4)=party_id;

-	WFIFOSET(fd,8);

-	printf("int_party: info not found %d\n",party_id);

-	return 0;

-}

-// パーティ情報まとめ送り

-int mapif_party_info(int fd,struct party *p)

-{

-	unsigned char buf[1024];

-	WBUFW(buf,0)=0x3821;

-	memcpy(buf+4,p,sizeof(struct party));

-	WBUFW(buf,2)=4+sizeof(struct party);

-	if(fd<0)

-		mapif_sendall(buf,WBUFW(buf,2));

-	else

-		mapif_send(fd,buf,WBUFW(buf,2));

-//	printf("int_party: info %d %s\n",p->party_id,p->name);

-	return 0;

-}

-// パーティメンバ追加可否

-int mapif_party_memberadded(int fd,int party_id,int account_id,int flag)

-{

-	WFIFOW(fd,0)=0x3822;

-	WFIFOL(fd,2)=party_id;

-	WFIFOL(fd,6)=account_id;

-	WFIFOB(fd,10)=flag;

-	WFIFOSET(fd,11);

-	return 0;

-}

-// パーティ設定変更通知

-int mapif_party_optionchanged(int fd,struct party *p,int account_id,int flag)

-{

-	unsigned char buf[16];

-	WBUFW(buf,0)=0x3823;

-	WBUFL(buf,2)=p->party_id;

-	WBUFL(buf,6)=account_id;

-	WBUFW(buf,10)=p->exp;

-	WBUFW(buf,12)=p->item;

-	WBUFB(buf,14)=flag;

-	if(flag==0)

-		mapif_sendall(buf,15);

-	else

-		mapif_send(fd,buf,15);

-	//printf("int_party: option changed %d %d %d %d %d\n",p->party_id,account_id,p->exp,p->item,flag);

-	return 0;

-}

-// パーティ脱退通知

-int mapif_party_leaved(int party_id,int account_id,char *name)

-{

-	unsigned char buf[64];

-	WBUFW(buf,0)=0x3824;

-	WBUFL(buf,2)=party_id;

-	WBUFL(buf,6)=account_id;

-	memcpy(WBUFP(buf,10),name,24);

-	mapif_sendall(buf,34);

-	//printf("int_party: party leaved %d %d %s\n",party_id,account_id,name);

-	return 0;

-}

-// パーティマップ更新通知

-int mapif_party_membermoved(struct party *p,int idx)

-{

-	unsigned char buf[32];

-	WBUFW(buf,0)=0x3825;

-	WBUFL(buf,2)=p->party_id;

-	WBUFL(buf,6)=p->member[idx].account_id;

-	memcpy(WBUFP(buf,10),p->member[idx].map,16);

-	WBUFB(buf,26)=p->member[idx].online;

-	WBUFW(buf,27)=p->member[idx].lv;

-	mapif_sendall(buf,29);

-	return 0;

-}

-// パーティ解散通知

-int mapif_party_broken(int party_id,int flag)

-{

-	unsigned char buf[16];

-	WBUFW(buf,0)=0x3826;

-	WBUFL(buf,2)=party_id;

-	WBUFB(buf,6)=flag;

-	mapif_sendall(buf,7);

-	//printf("int_party: broken %d\n",party_id);

-	return 0;

-}

-// パーティ内発言

-int mapif_party_message(int party_id,int account_id,char *mes,int len)

-{

-	unsigned char buf[512];

-	WBUFW(buf,0)=0x3827;

-	WBUFW(buf,2)=len+12;

-	WBUFL(buf,4)=party_id;

-	WBUFL(buf,8)=account_id;

-	memcpy(WBUFP(buf,12),mes,len);

-	mapif_sendall(buf,len+12);

-	return 0;

-}

-

-//-------------------------------------------------------------------

-// map serverからの通信

-

-

-// Create Party

-int mapif_parse_CreateParty(int fd,int account_id,char *name,char *nick,char *map,int lv)

-{

-	struct party *p;

-	if( (p=search_partyname(name))!=NULL){

-//		printf("int_party: same name party exists [%s]\n",name);

-		mapif_party_created(fd,account_id,NULL);

-		return 0;

-	}

-	p=party_pt;

-	if(p==NULL){

-		printf("int_party: out of memory !\n");

-		mapif_party_created(fd,account_id,NULL);

-		return 0;

-	}

-	memset(p,0,sizeof(struct party));

-	p->party_id=party_newid++;

-	memcpy(p->name,name,24);

-	p->exp=0;

-	p->item=0;

-	p->member[0].account_id=account_id;

-	memcpy(p->member[0].name,nick,24);

-	memcpy(p->member[0].map,map,16);

-	p->member[0].leader=1;

-	p->member[0].online=1;

-	p->member[0].lv=lv;

-	

-	inter_party_tosql(p->party_id,p);

-	

-	mapif_party_created(fd,account_id,p);

-	mapif_party_info(fd,p);

-	

-	return 0;

-}

-// パーティ情報要求

-int mapif_parse_PartyInfo(int fd,int party_id)

-{

-	struct party *p = party_pt;

-	if(p==NULL){

-		printf("int_party: out of memory !\n");

-		return 0;

-	}

-	inter_party_fromsql(party_id, p);

-	

-	if(p->party_id >= 0)

-		mapif_party_info(fd,p);

-	else

-		mapif_party_noinfo(fd,party_id);

-	return 0;

-}

-// パーティ追加要求

-int mapif_parse_PartyAddMember(int fd,int party_id,int account_id,char *nick,char *map,int lv)

-{

-	struct party *p;

-	int i;

-	

-	p = party_pt;

-	if(p==NULL){

-		printf("int_party: out of memory !\n");

-		return 0;

-	}

-	inter_party_fromsql(party_id, p);

-	

-	if(p->party_id <= 0){

-		mapif_party_memberadded(fd,party_id,account_id,1);

-		return 0;

-	}

-	

-	for(i=0;i<MAX_PARTY;i++){

-		if(p->member[i].account_id==0){

-			int flag=0;

-			

-			p->member[i].account_id=account_id;

-			memcpy(p->member[i].name,nick,24);

-			memcpy(p->member[i].map,map,16);

-			p->member[i].leader=0;

-			p->member[i].online=1;

-			p->member[i].lv=lv;

-			mapif_party_memberadded(fd,party_id,account_id,0);

-			mapif_party_info(-1,p);

-

-			if( p->exp>0 && !party_check_exp_share(p) ){

-				p->exp=0;

-				flag=0x01;

-			}

-			if(flag)

-				mapif_party_optionchanged(fd,p,0,0);

-				

-			inter_party_tosql(party_id, p);

-			return 0;

-		}

-	}

-	mapif_party_memberadded(fd,party_id,account_id,1);

-	//inter_party_tosql(party_id, p);

-	return 0;

-}

-// パーティー設定変更要求

-int mapif_parse_PartyChangeOption(int fd,int party_id,int account_id,int exp,int item)

-{

-	struct party *p;

-	int flag=0;

-	

-	p = party_pt;

-	if(p==NULL){

-		printf("int_party: out of memory !\n");

-		return 0;

-	}

-	

-	inter_party_fromsql(party_id, p);

-	

-	if(p->party_id <= 0){

-		return 0;

-	}

-	

-	p->exp=exp;

-	if( exp>0 && !party_check_exp_share(p) ){

-		flag|=0x01;

-		p->exp=0;

-	}

-	

-	p->item=item;

-

-	mapif_party_optionchanged(fd,p,account_id,flag);

-	inter_party_tosql(party_id, p);

-	return 0;

-}

-// パーティ脱退要求

-int mapif_parse_PartyLeave(int fd,int party_id,int account_id)

-{

-	char t_member[24];

-	struct party *p = party_pt;

-	if(p==NULL){

-		printf("int_party: out of memory !\n");

-		return 0;

-	}

-	

-	inter_party_fromsql(party_id, p);

-	

-	if(p->party_id >= 0){

-		int i,j;

-		for(i=0;i<MAX_PARTY;i++){

-			

-			if(p->member[i].account_id==account_id){

-				//printf("p->member[i].account_id = %d , account_id = %d \n",p->member[i].account_id,account_id);

-				mapif_party_leaved(party_id,account_id,p->member[i].name);

-				

-				

-				

-				// Update char information, does the name need encoding?

-				sprintf(tmp_sql,"UPDATE `%s` SET `party_id`='0', `online`='1' WHERE `party_id`='%d' AND `name`='%s'", 

-					char_db, party_id, jstrescapecpy(t_member,p->member[i].name));

-				if(mysql_query(&mysql_handle, tmp_sql) ) {

-					printf("DB server Error (update `char`)- %s\n", mysql_error(&mysql_handle) );

-				}

-//				printf("Delete member %s from MySQL \n", p->member[i].name);	

-						

-				if (p->member[i].leader==1){

-					for(j=0;j<MAX_PARTY;j++)

-					{

-						//printf("j = %d , p->member[j].account_id = %d , p->member[j].account_id = %d \n",j,p->member[j].account_id,p->member[j].account_id);

-						if(p->member[j].account_id>0&&j!=i){

-							mapif_party_leaved(party_id,p->member[j].account_id,p->member[j].name);

-							// Update char information, does the name need encoding?

-							sprintf(tmp_sql,"UPDATE `%s` SET `party_id`='0', `online`='1' WHERE `party_id`='%d' AND `name`='%s'", 

-								char_db, party_id, jstrescapecpy(t_member,p->member[i].name));

-							if(mysql_query(&mysql_handle, tmp_sql) ) {

-								printf("DB server Error (update `char`)- %s\n", mysql_error(&mysql_handle) );

-							}

-//							printf("Delete member %s from MySQL \n", p->member[j].name);	

-						}

-					}

-					// Delete the party, if has no member.

-					sprintf(tmp_sql,"DELETE FROM `%s` WHERE `party_id`='%d'",party_db, party_id);

-					if(mysql_query(&mysql_handle, tmp_sql) ) {

-						printf("DB server Error - %s\n", mysql_error(&mysql_handle) );

-					}

-//					printf("Leader breaks party %d \n",party_id);

-					memset(p, 0, sizeof(struct party));					

-				}else memset(&p->member[i],0,sizeof(struct party_member));

-				

-				break;

-

-			}

-		}

-		if( party_check_empty(p)==0 )

-			mapif_party_info(-1,p);// まだ人がいるのでデータ送信

-		/*

-		else

-			inter_party_tosql(party_id,p);	// Break the party if no member

-		*/

-	}else{

-		sprintf(tmp_sql,"UPDATE `%s` SET `party_id`='0' WHERE `party_id`='%d' AND `account_id`='%d' AND `online`='1'", 

-			char_db, party_id, account_id);	

-		if(mysql_query(&mysql_handle, tmp_sql) ) {

-			printf("DB server Error (update `char`)- %s\n", mysql_error(&mysql_handle) );

-		}

-	}

-	return 0;

-}

-// When member goes to other map

-int mapif_parse_PartyChangeMap(int fd,int party_id,int account_id,char *map,int online,int lv)

-{

-	struct party *p;

-	int i;

-	

-	p = party_pt;

-	if(p==NULL){

-		printf("int_party: out of memory !\n");

-		return 0;

-	}

-	inter_party_fromsql(party_id, p);

-	

-	if(p->party_id <= 0){

-		return 0;

-	}

-	for(i=0;i<MAX_PARTY;i++){

-		if(p->member[i].account_id==account_id){

-			int flag=0;

-			

-			memcpy(p->member[i].map,map,16);

-			p->member[i].online=online;

-			p->member[i].lv=lv;

-			mapif_party_membermoved(p,i);

-

-			if( p->exp>0 && !party_check_exp_share(p) ){

-				p->exp=0;

-				flag=1;

-			}

-			if(flag)

-				mapif_party_optionchanged(fd,p,0,0);

-			break;

-		}

-	}

-	inter_party_tosql(party_id, p);

-	return 0;

-}

-// パーティ解散要求

-int mapif_parse_BreakParty(int fd,int party_id)

-{

-	struct party *p;

-	

-	p = party_pt;

-	if(p==NULL){

-		printf("int_party: out of memory !\n");

-		return 0;

-	}

-	

-	inter_party_fromsql(party_id, p);

-	

-	if(p->party_id <= 0){

-		return 0;

-	}

-	inter_party_tosql(party_id,p);

-	

-	mapif_party_broken(fd,party_id);

-	return 0;

-}

-// パーティメッセージ送信

-int mapif_parse_PartyMessage(int fd,int party_id,int account_id,char *mes,int len)

-{

-	return mapif_party_message(party_id,account_id,mes,len);

-}

-// パーティチェック要求

-int mapif_parse_PartyCheck(int fd,int party_id,int account_id,char *nick)

-{

-	return party_check_conflict(party_id,account_id,nick);

-}

-

-// map server からの通信

-// ・１パケットのみ解析すること

-// ・パケット長データはinter.cにセットしておくこと

-// ・パケット長チェックや、RFIFOSKIPは呼び出し元で行われるので行ってはならない

-// ・エラーなら0(false)、そうでないなら1(true)をかえさなければならない

-int inter_party_parse_frommap(int fd)

-{

-	switch(RFIFOW(fd,0)){

-	case 0x3020: mapif_parse_CreateParty(fd,RFIFOL(fd,2),RFIFOP(fd,6),RFIFOP(fd,30),RFIFOP(fd,54),RFIFOW(fd,70)); break;

-	case 0x3021: mapif_parse_PartyInfo(fd,RFIFOL(fd,2)); break;

-	case 0x3022: mapif_parse_PartyAddMember(fd,RFIFOL(fd,2),RFIFOL(fd,6),RFIFOP(fd,10),RFIFOP(fd,34),RFIFOW(fd,50)); break;

-	case 0x3023: mapif_parse_PartyChangeOption(fd,RFIFOL(fd,2),RFIFOL(fd,6),RFIFOW(fd,10),RFIFOW(fd,12)); break;

-	case 0x3024: mapif_parse_PartyLeave(fd,RFIFOL(fd,2),RFIFOL(fd,6)); break;

-	case 0x3025: mapif_parse_PartyChangeMap(fd,RFIFOL(fd,2),RFIFOL(fd,6),RFIFOP(fd,10),RFIFOB(fd,26),RFIFOW(fd,27)); break;

-	case 0x3026: mapif_parse_BreakParty(fd,RFIFOL(fd,2)); break;

-	case 0x3027: mapif_parse_PartyMessage(fd,RFIFOL(fd,4),RFIFOL(fd,8),RFIFOP(fd,12),RFIFOW(fd,2)-12); break;

-	case 0x3028: mapif_parse_PartyCheck(fd,RFIFOL(fd,2),RFIFOL(fd,6),RFIFOP(fd,10)); break;

-	default:

-		return 0;

-	}

-	return 1;

-}

-

-// サーバーから脱退要求（キャラ削除用）

-int inter_party_leave(int party_id,int account_id)

-{

-	return mapif_parse_PartyLeave(-1,party_id,account_id);

-}

-

-

-

+//
+// original code from athena
+// SQL conversion by hack
+//
+
+#include "char.h"
+#include "strlib.h"
+#include "socket.h"	
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+
+static struct party *party_pt;
+static int party_newid=100;
+
+int mapif_party_broken(int party_id,int flag);
+int party_check_empty(struct party *p);
+int mapif_parse_PartyLeave(int fd,int party_id,int account_id);
+
+// Save party to mysql
+int inter_party_tosql(int party_id,struct party *p)
+{
+	// 'party' ('party_id','name','exp','item','leader')
+	
+	char t_name[100];
+	char t_member[24];
+	int party_member = 0, party_online_member = 0;
+	int party_exist = 0;
+	int leader_id = 0;
+	int i = 0;
+	
+	printf("(\033[1;64m%d\033[0m)    Request save party - ",party_id);
+	
+	jstrescapecpy(t_name, p->name);
+	
+	if (p==NULL || party_id==0 || p->party_id ==0 || party_id!=p->party_id) {
+		printf("- Party pointer or party_id error \n");
+		return 0;
+	}
+	
+	// Check if party exists	
+	sprintf(tmp_sql,"SELECT count(*) FROM `%s` WHERE `party_id`='%d'",party_db, party_id);
+	if(mysql_query(&mysql_handle, tmp_sql) ) {
+		printf("DB server Error - %s\n", mysql_error(&mysql_handle) );
+		return 0;
+	}
+	sql_res = mysql_store_result(&mysql_handle) ;
+	if (sql_res!=NULL && mysql_num_rows(sql_res)>0) {
+		sql_row = mysql_fetch_row(sql_res);
+		party_exist =  atoi (sql_row[0]);
+		//printf("- Check if party %d exists : %s\n",party_id,party_exist==0?"No":"Yes");
+	}
+	mysql_free_result(sql_res) ; //resource free
+
+	if (party_exist >0){
+		// Check members in party
+		sprintf(tmp_sql,"SELECT count(*) FROM `%s` WHERE `party_id`='%d'",char_db, party_id);
+		if(mysql_query(&mysql_handle, tmp_sql) ) {
+			printf("DB server Error - %s\n", mysql_error(&mysql_handle) );
+			return 0;
+		}
+		sql_res = mysql_store_result(&mysql_handle) ;
+		if (sql_res!=NULL && mysql_num_rows(sql_res)>0) {
+			sql_row = mysql_fetch_row(sql_res);
+			
+			party_member =  atoi (sql_row[0]);
+		//	printf("- Check members in party %d : %d \n",party_id,party_member);
+
+		}
+		mysql_free_result(sql_res) ; //resource free
+	
+		party_online_member = 0;
+		i=0;
+		while (i<MAX_PARTY){
+			if (p->member[i].account_id>0) party_online_member++;
+			i++;
+		}
+		
+		//if (party_online_member==0) printf("- No member online \n"); else printf("- Some member %d online \n", party_online_member);
+			
+		if (party_member <= 0 && party_online_member == 0) {
+
+			// Delete the party, if has no member.
+			sprintf(tmp_sql,"DELETE FROM `%s` WHERE `party_id`='%d'",party_db, party_id);
+			if(mysql_query(&mysql_handle, tmp_sql) ) {
+				printf("DB server Error - %s\n", mysql_error(&mysql_handle) );
+			}
+		//	printf("No member in party %d, break it \n",party_id);
+			memset(p, 0, sizeof(struct party));
+			return 0;
+		} else {
+			// Update party information, if exists
+			
+			int i=0;
+				
+			for (i=0;i<MAX_PARTY;i++){
+
+				if (p->member[i].account_id>0){
+					sprintf(tmp_sql,"UPDATE `%s` SET `party_id`='%d', `online`='%d' WHERE `account_id`='%d' AND `name`='%s'",
+						char_db, party_id, p->member[i].online, p->member[i].account_id,jstrescapecpy(t_member,p->member[i].name));	
+					//printf("%s",tmp_sql);
+					if(mysql_query(&mysql_handle, tmp_sql) ) {
+						printf("DB server Error (update `char`)- %s\n", mysql_error(&mysql_handle) );
+					}
+				}
+			}
+			
+			
+			sprintf(tmp_sql,"UPDATE `%s` SET `name`='%s', `exp`='%d', `item`='%d', `leader_id`=`leader_id` WHERE `party_id`='%d'",
+				party_db, t_name,p->exp,p->item,party_id);	
+			if(mysql_query(&mysql_handle, tmp_sql) ) {
+				printf("DB server Error (inset/update `party`)- %s\n", mysql_error(&mysql_handle) );
+			}
+
+			
+		//	printf("- Update party %d information \n",party_id);
+		}
+	} else {
+		// Add new party, if not exist
+		int i = 0;
+		while (i<MAX_PARTY&&((p->member[i].account_id>0&&p->member[i].leader==0)||(p->member[i].account_id<0))) i++;
+		if (i<MAX_PARTY) leader_id = p->member[i].account_id;
+		sprintf(tmp_sql,"INSERT INTO `%s`  (`party_id`, `name`, `exp`, `item`, `leader_id`) VALUES ('%d', '%s', '%d', '%d', '%d')",
+			party_db, party_id, t_name, p->exp, p->item,leader_id);
+		if(mysql_query(&mysql_handle, tmp_sql) ) {
+			printf("DB server Error (inset/update `party`)- %s\n", mysql_error(&mysql_handle) );
+			return 0;
+		}
+		
+		sprintf(tmp_sql,"UPDATE `%s` SET `party_id`='%d', `online`='1'  WHERE `account_id`='%d' AND `name`='%s'",
+			char_db, party_id,leader_id, jstrescapecpy(t_member,p->member[i].name));	
+		if(mysql_query(&mysql_handle, tmp_sql) ) {
+			printf("DB server Error (inset/update `party`)- %s\n", mysql_error(&mysql_handle) );
+		}
+		
+		//printf("- Insert new party %d  \n",party_id);	
+	}
+	
+	printf("Party save success\n");
+	return 0;	
+
+}
+
+// Read party from mysql
+int inter_party_fromsql(int party_id,struct party *p)
+{
+	int leader_id=0;
+	printf("(\033[1;64m%d\033[0m)    Request load party - ",party_id);
+	
+	memset(p, 0, sizeof(struct party));
+	
+	sprintf(tmp_sql,"SELECT `party_id`, `name`,`exp`,`item`, `leader_id` FROM `%s` WHERE `party_id`='%d'",party_db, party_id);
+	if(mysql_query(&mysql_handle, tmp_sql) ) {
+		printf("DB server Error (select `party`)- %s\n", mysql_error(&mysql_handle) );
+		return 0;
+	}
+	
+	sql_res = mysql_store_result(&mysql_handle) ;
+	if (sql_res!=NULL && mysql_num_rows(sql_res)>0) {
+		sql_row = mysql_fetch_row(sql_res);
+	//	printf("- Read party %d from MySQL\n",party_id);
+		p->party_id = party_id;
+		strcpy(p->name, sql_row[1]);
+		p->exp = atoi(sql_row[2]);
+		p->item = atoi(sql_row[3]);
+		leader_id = atoi(sql_row[4]);
+	} else {
+		mysql_free_result(sql_res);
+	//	printf("- Cannot find party %d \n",party_id);
+		return 0;
+	}
+		
+	mysql_free_result(sql_res);
+	
+	// Load members
+	sprintf(tmp_sql,"SELECT `account_id`, `name`,`base_level`,`last_map`,`online` FROM `%s` WHERE `party_id`='%d'",char_db, party_id);
+	if(mysql_query(&mysql_handle, tmp_sql) ) {
+		printf("DB server Error (select `party`)- %s\n", mysql_error(&mysql_handle) );
+		return 0;
+	}
+	sql_res = mysql_store_result(&mysql_handle) ;
+	if (sql_res!=NULL && mysql_num_rows(sql_res)>0) {
+		int i;
+		for(i=0;(sql_row = mysql_fetch_row(sql_res));i++){
+			struct party_member *m = &p->member[i];
+			m->account_id = atoi(sql_row[0]);
+			if (m->account_id == leader_id) m->leader = 1; else m->leader = 0;
+			strncpy(m->name,sql_row[1],sizeof(m->name));
+			m->lv = atoi(sql_row[2]);
+			strncpy(m->map,sql_row[3],sizeof(m->map));
+			m->online = atoi(sql_row[4]);
+		}
+	//	printf("- %d members found in party %d \n",i,party_id);
+	}
+	mysql_free_result(sql_res);
+		
+	
+	printf("Party load success\n");
+	return 0;
+	
+}
+
+int inter_party_sql_init(){
+	int i;
+	
+	//memory alloc
+	printf("interserver party memory initialize.... (%d byte)\n",sizeof(struct party));
+	party_pt = calloc(sizeof(struct party), 1);
+	
+	sprintf(tmp_sql,"UPDATE `%s` SET `online`='0'", char_db);	
+	if(mysql_query(&mysql_handle, tmp_sql) ) {
+		printf("DB server Error (update `char`)- %s\n", mysql_error(&mysql_handle) );
+	}
+	
+	sprintf (tmp_sql , "SELECT count(*) FROM `%s`",party_db);
+	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);
+	printf("total party data -> '%s'.......\n",sql_row[0]);
+	i = atoi (sql_row[0]);
+	mysql_free_result(sql_res);
+
+	if (i > 0) {
+		//set party_newid
+		sprintf (tmp_sql , "SELECT max(`party_id`) FROM `%s`", party_db);
+		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);
+		party_newid = atoi (sql_row[0])+1;
+		mysql_free_result(sql_res);
+	}
+	
+	printf("set party_newid: %d.......\n",party_newid);
+	
+	return 0;
+}
+
+
+// Search for the party according to its name
+struct party* search_partyname(char *str)
+{
+	struct party *p=NULL;
+	int leader_id = 0;
+	char t_name[24];
+	
+	sprintf(tmp_sql,"SELECT `party_id`, `name`,`exp`,`item`,`leader_id` FROM `%s` WHERE `name`='%s'",party_db, jstrescapecpy(t_name,str));	
+	if(mysql_query(&mysql_handle, tmp_sql) ) {
+			printf("DB server Error (select `party`)- %s\n", mysql_error(&mysql_handle) );
+	}
+	sql_res = mysql_store_result(&mysql_handle) ;
+	if (sql_res==NULL || mysql_num_rows(sql_res)<=0) { mysql_free_result(sql_res); return p; }
+	sql_row = mysql_fetch_row(sql_res);
+	p = party_pt;
+	p->party_id = atoi(sql_row[0]);
+	strcpy(p->name, sql_row[1]);
+	p->exp = atoi(sql_row[2]);
+	p->item = atoi(sql_row[3]);
+	leader_id = atoi(sql_row[4]);
+	mysql_free_result(sql_res);
+
+	// Load members
+	sprintf(tmp_sql,"SELECT `account_id`, `name`,`base_level`,`last_map`,`online` FROM `%s` WHERE `party_id`='%d'",char_db, p->party_id);
+	if(mysql_query(&mysql_handle, tmp_sql) ) {
+		printf("DB server Error (select `party`)- %s\n", mysql_error(&mysql_handle) );
+		return 0;
+	}
+	sql_res = mysql_store_result(&mysql_handle) ;
+	if (sql_res!=NULL && mysql_num_rows(sql_res)>0) {
+		int i;
+		for(i=0;(sql_row = mysql_fetch_row(sql_res));i++){
+			struct party_member *m = &p->member[i];
+			m->account_id = atoi(sql_row[0]);
+			if (m->account_id == leader_id) m->leader = 1; else m->leader = 0;
+			strncpy(m->name,sql_row[1],sizeof(m->name));
+			m->lv = atoi(sql_row[2]);
+			strncpy(m->map,sql_row[3],sizeof(m->map));
+			m->online = atoi(sql_row[4]);
+		}
+		printf("- %d members found in party %d \n",i,p->party_id);
+	}
+	mysql_free_result(sql_res);
+
+	return p;
+}
+
+// EXP公平分配できるかチェック
+int party_check_exp_share(struct party *p)
+{
+	int i;
+	int maxlv=0,minlv=0x7fffffff;
+	for(i=0;i<MAX_PARTY;i++){
+		int lv=p->member[i].lv;
+		if( p->member[i].online ){
+			if( lv < minlv ) minlv=lv;
+			if( maxlv < lv ) maxlv=lv;
+		}
+	}
+	return (maxlv==0 || maxlv-minlv<=party_share_level);
+}
+// Is there any member in the party?
+int party_check_empty(struct party *p)
+{
+	int i;
+	if (p==NULL||p->party_id==0) return 1;
+//	printf("party check empty %08X\n",(int)p);
+	for(i=0;i<MAX_PARTY;i++){
+//		printf("%d acc=%d\n",i,p->member[i].account_id);
+		if(p->member[i].account_id>0){
+			return 0;
+		}
+	}
+	// If there is no member, then break the party
+	mapif_party_broken(p->party_id,0);
+	inter_party_tosql(p->party_id,p);
+	return 1;
+}
+
+
+// Check if a member is in two party, not necessary :)
+int party_check_conflict(int party_id,int account_id,char *nick)
+{
+	return 0;
+}
+
+//-------------------------------------------------------------------
+// map serverへの通信
+
+// パーティ作成可否
+int mapif_party_created(int fd,int account_id,struct party *p)
+{
+	WFIFOW(fd,0)=0x3820;
+	WFIFOL(fd,2)=account_id;
+	if(p!=NULL){
+		WFIFOB(fd,6)=0;
+		WFIFOL(fd,7)=p->party_id;
+		memcpy(WFIFOP(fd,11),p->name,24);
+		printf("int_party: created! %d %s\n",p->party_id,p->name);
+	}else{
+		WFIFOB(fd,6)=1;
+		WFIFOL(fd,7)=0;
+		memcpy(WFIFOP(fd,11),"error",24);
+	}
+	WFIFOSET(fd,35);
+	return 0;
+}
+
+// パーティ情報見つからず
+int mapif_party_noinfo(int fd,int party_id)
+{
+	WFIFOW(fd,0)=0x3821;
+	WFIFOW(fd,2)=8;
+	WFIFOL(fd,4)=party_id;
+	WFIFOSET(fd,8);
+	printf("int_party: info not found %d\n",party_id);
+	return 0;
+}
+// パーティ情報まとめ送り
+int mapif_party_info(int fd,struct party *p)
+{
+	unsigned char buf[1024];
+	WBUFW(buf,0)=0x3821;
+	memcpy(buf+4,p,sizeof(struct party));
+	WBUFW(buf,2)=4+sizeof(struct party);
+	if(fd<0)
+		mapif_sendall(buf,WBUFW(buf,2));
+	else
+		mapif_send(fd,buf,WBUFW(buf,2));
+//	printf("int_party: info %d %s\n",p->party_id,p->name);
+	return 0;
+}
+// パーティメンバ追加可否
+int mapif_party_memberadded(int fd,int party_id,int account_id,int flag)
+{
+	WFIFOW(fd,0)=0x3822;
+	WFIFOL(fd,2)=party_id;
+	WFIFOL(fd,6)=account_id;
+	WFIFOB(fd,10)=flag;
+	WFIFOSET(fd,11);
+	return 0;
+}
+// パーティ設定変更通知
+int mapif_party_optionchanged(int fd,struct party *p,int account_id,int flag)
+{
+	unsigned char buf[16];
+	WBUFW(buf,0)=0x3823;
+	WBUFL(buf,2)=p->party_id;
+	WBUFL(buf,6)=account_id;
+	WBUFW(buf,10)=p->exp;
+	WBUFW(buf,12)=p->item;
+	WBUFB(buf,14)=flag;
+	if(flag==0)
+		mapif_sendall(buf,15);
+	else
+		mapif_send(fd,buf,15);
+	//printf("int_party: option changed %d %d %d %d %d\n",p->party_id,account_id,p->exp,p->item,flag);
+	return 0;
+}
+// パーティ脱退通知
+int mapif_party_leaved(int party_id,int account_id,char *name)
+{
+	unsigned char buf[64];
+	WBUFW(buf,0)=0x3824;
+	WBUFL(buf,2)=party_id;
+	WBUFL(buf,6)=account_id;
+	memcpy(WBUFP(buf,10),name,24);
+	mapif_sendall(buf,34);
+	//printf("int_party: party leaved %d %d %s\n",party_id,account_id,name);
+	return 0;
+}
+// パーティマップ更新通知
+int mapif_party_membermoved(struct party *p,int idx)
+{
+	unsigned char buf[32];
+	WBUFW(buf,0)=0x3825;
+	WBUFL(buf,2)=p->party_id;
+	WBUFL(buf,6)=p->member[idx].account_id;
+	memcpy(WBUFP(buf,10),p->member[idx].map,16);
+	WBUFB(buf,26)=p->member[idx].online;
+	WBUFW(buf,27)=p->member[idx].lv;
+	mapif_sendall(buf,29);
+	return 0;
+}
+// パーティ解散通知
+int mapif_party_broken(int party_id,int flag)
+{
+	unsigned char buf[16];
+	WBUFW(buf,0)=0x3826;
+	WBUFL(buf,2)=party_id;
+	WBUFB(buf,6)=flag;
+	mapif_sendall(buf,7);
+	//printf("int_party: broken %d\n",party_id);
+	return 0;
+}
+// パーティ内発言
+int mapif_party_message(int party_id,int account_id,char *mes,int len)
+{
+	unsigned char buf[512];
+	WBUFW(buf,0)=0x3827;
+	WBUFW(buf,2)=len+12;
+	WBUFL(buf,4)=party_id;
+	WBUFL(buf,8)=account_id;
+	memcpy(WBUFP(buf,12),mes,len);
+	mapif_sendall(buf,len+12);
+	return 0;
+}
+
+//-------------------------------------------------------------------
+// map serverからの通信
+
+
+// Create Party
+int mapif_parse_CreateParty(int fd,int account_id,char *name,char *nick,char *map,int lv)
+{
+	struct party *p;
+	if( (p=search_partyname(name))!=NULL){
+//		printf("int_party: same name party exists [%s]\n",name);
+		mapif_party_created(fd,account_id,NULL);
+		return 0;
+	}
+	p=party_pt;
+	if(p==NULL){
+		printf("int_party: out of memory !\n");
+		mapif_party_created(fd,account_id,NULL);
+		return 0;
+	}
+	memset(p,0,sizeof(struct party));
+	p->party_id=party_newid++;
+	memcpy(p->name,name,24);
+	p->exp=0;
+	p->item=0;
+	p->member[0].account_id=account_id;
+	memcpy(p->member[0].name,nick,24);
+	memcpy(p->member[0].map,map,16);
+	p->member[0].leader=1;
+	p->member[0].online=1;
+	p->member[0].lv=lv;
+	
+	inter_party_tosql(p->party_id,p);
+	
+	mapif_party_created(fd,account_id,p);
+	mapif_party_info(fd,p);
+	
+	return 0;
+}
+// パーティ情報要求
+int mapif_parse_PartyInfo(int fd,int party_id)
+{
+	struct party *p = party_pt;
+	if(p==NULL){
+		printf("int_party: out of memory !\n");
+		return 0;
+	}
+	inter_party_fromsql(party_id, p);
+	
+	if(p->party_id >= 0)
+		mapif_party_info(fd,p);
+	else
+		mapif_party_noinfo(fd,party_id);
+	return 0;
+}
+// パーティ追加要求
+int mapif_parse_PartyAddMember(int fd,int party_id,int account_id,char *nick,char *map,int lv)
+{
+	struct party *p;
+	int i;
+	
+	p = party_pt;
+	if(p==NULL){
+		printf("int_party: out of memory !\n");
+		return 0;
+	}
+	inter_party_fromsql(party_id, p);
+	
+	if(p->party_id <= 0){
+		mapif_party_memberadded(fd,party_id,account_id,1);
+		return 0;
+	}
+	
+	for(i=0;i<MAX_PARTY;i++){
+		if(p->member[i].account_id==0){
+			int flag=0;
+			
+			p->member[i].account_id=account_id;
+			memcpy(p->member[i].name,nick,24);
+			memcpy(p->member[i].map,map,16);
+			p->member[i].leader=0;
+			p->member[i].online=1;
+			p->member[i].lv=lv;
+			mapif_party_memberadded(fd,party_id,account_id,0);
+			mapif_party_info(-1,p);
+
+			if( p->exp>0 && !party_check_exp_share(p) ){
+				p->exp=0;
+				flag=0x01;
+			}
+			if(flag)
+				mapif_party_optionchanged(fd,p,0,0);
+				
+			inter_party_tosql(party_id, p);
+			return 0;
+		}
+	}
+	mapif_party_memberadded(fd,party_id,account_id,1);
+	//inter_party_tosql(party_id, p);
+	return 0;
+}
+// パーティー設定変更要求
+int mapif_parse_PartyChangeOption(int fd,int party_id,int account_id,int exp,int item)
+{
+	struct party *p;
+	int flag=0;
+	
+	p = party_pt;
+	if(p==NULL){
+		printf("int_party: out of memory !\n");
+		return 0;
+	}
+	
+	inter_party_fromsql(party_id, p);
+	
+	if(p->party_id <= 0){
+		return 0;
+	}
+	
+	p->exp=exp;
+	if( exp>0 && !party_check_exp_share(p) ){
+		flag|=0x01;
+		p->exp=0;
+	}
+	
+	p->item=item;
+
+	mapif_party_optionchanged(fd,p,account_id,flag);
+	inter_party_tosql(party_id, p);
+	return 0;
+}
+// パーティ脱退要求
+int mapif_parse_PartyLeave(int fd,int party_id,int account_id)
+{
+	char t_member[24];
+	struct party *p = party_pt;
+	if(p==NULL){
+		printf("int_party: out of memory !\n");
+		return 0;
+	}
+	
+	inter_party_fromsql(party_id, p);
+	
+	if(p->party_id >= 0){
+		int i,j;
+		for(i=0;i<MAX_PARTY;i++){
+			
+			if(p->member[i].account_id==account_id){
+				//printf("p->member[i].account_id = %d , account_id = %d \n",p->member[i].account_id,account_id);
+				mapif_party_leaved(party_id,account_id,p->member[i].name);
+				
+				
+				
+				// Update char information, does the name need encoding?
+				sprintf(tmp_sql,"UPDATE `%s` SET `party_id`='0', `online`='1' WHERE `party_id`='%d' AND `name`='%s'", 
+					char_db, party_id, jstrescapecpy(t_member,p->member[i].name));
+				if(mysql_query(&mysql_handle, tmp_sql) ) {
+					printf("DB server Error (update `char`)- %s\n", mysql_error(&mysql_handle) );
+				}
+//				printf("Delete member %s from MySQL \n", p->member[i].name);	
+						
+				if (p->member[i].leader==1){
+					for(j=0;j<MAX_PARTY;j++)
+					{
+						//printf("j = %d , p->member[j].account_id = %d , p->member[j].account_id = %d \n",j,p->member[j].account_id,p->member[j].account_id);
+						if(p->member[j].account_id>0&&j!=i){
+							mapif_party_leaved(party_id,p->member[j].account_id,p->member[j].name);
+							// Update char information, does the name need encoding?
+							sprintf(tmp_sql,"UPDATE `%s` SET `party_id`='0', `online`='1' WHERE `party_id`='%d' AND `name`='%s'", 
+								char_db, party_id, jstrescapecpy(t_member,p->member[i].name));
+							if(mysql_query(&mysql_handle, tmp_sql) ) {
+								printf("DB server Error (update `char`)- %s\n", mysql_error(&mysql_handle) );
+							}
+//							printf("Delete member %s from MySQL \n", p->member[j].name);	
+						}
+					}
+					// Delete the party, if has no member.
+					sprintf(tmp_sql,"DELETE FROM `%s` WHERE `party_id`='%d'",party_db, party_id);
+					if(mysql_query(&mysql_handle, tmp_sql) ) {
+						printf("DB server Error - %s\n", mysql_error(&mysql_handle) );
+					}
+//					printf("Leader breaks party %d \n",party_id);
+					memset(p, 0, sizeof(struct party));					
+				}else memset(&p->member[i],0,sizeof(struct party_member));
+				
+				break;
+
+			}
+		}
+		if( party_check_empty(p)==0 )
+			mapif_party_info(-1,p);// まだ人がいるのでデータ送信
+		/*
+		else
+			inter_party_tosql(party_id,p);	// Break the party if no member
+		*/
+	}else{
+		sprintf(tmp_sql,"UPDATE `%s` SET `party_id`='0' WHERE `party_id`='%d' AND `account_id`='%d' AND `online`='1'", 
+			char_db, party_id, account_id);	
+		if(mysql_query(&mysql_handle, tmp_sql) ) {
+			printf("DB server Error (update `char`)- %s\n", mysql_error(&mysql_handle) );
+		}
+	}
+	return 0;
+}
+// When member goes to other map
+int mapif_parse_PartyChangeMap(int fd,int party_id,int account_id,char *map,int online,int lv)
+{
+	struct party *p;
+	int i;
+	
+	p = party_pt;
+	if(p==NULL){
+		printf("int_party: out of memory !\n");
+		return 0;
+	}
+	inter_party_fromsql(party_id, p);
+	
+	if(p->party_id <= 0){
+		return 0;
+	}
+	for(i=0;i<MAX_PARTY;i++){
+		if(p->member[i].account_id==account_id){
+			int flag=0;
+			
+			memcpy(p->member[i].map,map,16);
+			p->member[i].online=online;
+			p->member[i].lv=lv;
+			mapif_party_membermoved(p,i);
+
+			if( p->exp>0 && !party_check_exp_share(p) ){
+				p->exp=0;
+				flag=1;
+			}
+			if(flag)
+				mapif_party_optionchanged(fd,p,0,0);
+			break;
+		}
+	}
+	inter_party_tosql(party_id, p);
+	return 0;
+}
+// パーティ解散要求
+int mapif_parse_BreakParty(int fd,int party_id)
+{
+	struct party *p;
+	
+	p = party_pt;
+	if(p==NULL){
+		printf("int_party: out of memory !\n");
+		return 0;
+	}
+	
+	inter_party_fromsql(party_id, p);
+	
+	if(p->party_id <= 0){
+		return 0;
+	}
+	inter_party_tosql(party_id,p);
+	
+	mapif_party_broken(fd,party_id);
+	return 0;
+}
+// パーティメッセージ送信
+int mapif_parse_PartyMessage(int fd,int party_id,int account_id,char *mes,int len)
+{
+	return mapif_party_message(party_id,account_id,mes,len);
+}
+// パーティチェック要求
+int mapif_parse_PartyCheck(int fd,int party_id,int account_id,char *nick)
+{
+	return party_check_conflict(party_id,account_id,nick);
+}
+
+// map server からの通信
+// ・１パケットのみ解析すること
+// ・パケット長データはinter.cにセットしておくこと
+// ・パケット長チェックや、RFIFOSKIPは呼び出し元で行われるので行ってはならない
+// ・エラーなら0(false)、そうでないなら1(true)をかえさなければならない
+int inter_party_parse_frommap(int fd)
+{
+	switch(RFIFOW(fd,0)){
+	case 0x3020: mapif_parse_CreateParty(fd,RFIFOL(fd,2),RFIFOP(fd,6),RFIFOP(fd,30),RFIFOP(fd,54),RFIFOW(fd,70)); break;
+	case 0x3021: mapif_parse_PartyInfo(fd,RFIFOL(fd,2)); break;
+	case 0x3022: mapif_parse_PartyAddMember(fd,RFIFOL(fd,2),RFIFOL(fd,6),RFIFOP(fd,10),RFIFOP(fd,34),RFIFOW(fd,50)); break;
+	case 0x3023: mapif_parse_PartyChangeOption(fd,RFIFOL(fd,2),RFIFOL(fd,6),RFIFOW(fd,10),RFIFOW(fd,12)); break;
+	case 0x3024: mapif_parse_PartyLeave(fd,RFIFOL(fd,2),RFIFOL(fd,6)); break;
+	case 0x3025: mapif_parse_PartyChangeMap(fd,RFIFOL(fd,2),RFIFOL(fd,6),RFIFOP(fd,10),RFIFOB(fd,26),RFIFOW(fd,27)); break;
+	case 0x3026: mapif_parse_BreakParty(fd,RFIFOL(fd,2)); break;
+	case 0x3027: mapif_parse_PartyMessage(fd,RFIFOL(fd,4),RFIFOL(fd,8),RFIFOP(fd,12),RFIFOW(fd,2)-12); break;
+	case 0x3028: mapif_parse_PartyCheck(fd,RFIFOL(fd,2),RFIFOL(fd,6),RFIFOP(fd,10)); break;
+	default:
+		return 0;
+	}
+	return 1;
+}
+
+// サーバーから脱退要求（キャラ削除用）
+int inter_party_leave(int party_id,int account_id)
+{
+	return mapif_parse_PartyLeave(-1,party_id,account_id);
+}
+
+
+