recv.c

石器2最新代码,需要MYSQL数据库,CYGWIN环境完整可编译.

	case 3:	//fmpk_list
		{
			int j=0;
			log( "reload FMPK_LIST !\n" );
			FMPK_InitList();
			FMPK_LoadList();
			for( j=0; j<FMPKLIST_MAXNUM; j++){ 
				for (i=0; i<MAXCONNECTION; i++){
					if( gs[i].use && gs[i].name[0] )
						saacproto_ACLoadFmPk_send(i, FMPK_GetData( j) );
				}
			}
		}
		break;
	}
}

#ifdef _AC_SEND_FM_PK		 // WON ADD 庄园对战列表储存在AC
#ifdef _ACFMPK_LIST
void saacproto_ACLoadFmPk_recv(int fd, int fmpks_pos)
{
	if( fmpks_pos < 0 || fmpks_pos > MAX_FMPOINT) return;
	saacproto_ACLoadFmPk_send( fd, FMPK_GetData( fmpks_pos-1) );
}

void saacproto_ACSendFmPk_recv(int fd, int fmpks_pos, int userindex, int flg, char *data)
{
	extern  gmsv gs[MAXCONNECTION];
	char buf[1024];
	int i=0;
	sprintf( buf, "%d|%s", fmpks_pos, data);

	if( ( userindex != -1 && FMPK_GetTypeFlg( fmpks_pos-1) == 1 )||
		FMPK_SetData( fmpks_pos-1, flg, buf, strlen( buf)) != 1 ){
		if(userindex != -1) saacproto_ACSendFmPk_send( fd, userindex, 0);
		log("err ACSendFmPk_send(%d, %d)\n", userindex, 0);
		return;
	}
	FMPK_BackUpList();
	for (i=0; i<MAXCONNECTION; i++){
		if( gs[i].use && gs[i].name[0] ){
			saacproto_ACLoadFmPk_send(i, FMPK_GetData( fmpks_pos-1) );
		}
	}
	//送确认讯息
	if(userindex != -1) saacproto_ACSendFmPk_send( fd, userindex, 1);
}
#else
void saacproto_ACLoadFmPk_recv(int fd, int fmpks_pos)
{
	if(fmpks_pos > MAX_FMPOINT){
		log("\n fmpks_pos(%d) too big", fmpks_pos);
	}	
	saacproto_ACLoadFmPk_send(fd, fm_pk_list[fmpks_pos-1]);
}
void saacproto_ACSendFmPk_recv(int fd, int fmpks_pos, char *data)
{
	extern  gmsv gs[MAXCONNECTION];
	int i=0;

	if( (fmpks_pos>MAX_FMPOINT) || (fmpks_pos<1) ){
		log("\n fmpks_pos(%d) err !!", fmpks_pos);
	}		
	sprintf(fm_pk_list[fmpks_pos-1], "%d|%s", fmpks_pos, data);

	for (i=0; i<MAXCONNECTION; i++){
		if (gs[i].use && gs[i].name[0] && i!=fd){
			saacproto_ACLoadFmPk_send(i, fm_pk_list[fmpks_pos-1]);
		}
	}

	save_fm_pk_list();
}
#endif

#endif

void saacproto_ACManorPKAck_recv(int fd, char *data)
{
#ifdef _FAMILY

#ifdef _AC_SEND_FM_PK		 // WON ADD 庄园对战列表储存在AC
	// 不处理
#else
	extern gmsv gs[MAXCONNECTION];
	int i;

	for (i=0; i<MAXCONNECTION; i++) 
	{
		if (gs[i].use && gs[i].name[0]) 
		{
			saacproto_ACManorPKAck_send(i, data);
		}
	}
#endif

#endif
}

#ifdef _WAEI_KICK
void saacproto_ACKick_recv( int ti ,char* id, int lock,int mesgid )
{
	if( ti != -1 )	{
		if( !is_game_server_login(ti) ){	//MAXCONNECTION
			saacproto_ACKick_send( ti , 0 , "not login" , mesgid );
			return;
		}
	}
	sprintf(retdata, "ACTION !!");
	//"LSLOCK","KICK","DEUNLOCK","UNLOCKALL","LOCK","TYPE", "UNLOCK"
	switch( lock)	{
	case 0://LSLOCK
		break;
	case 1:		//跨星球踢人 KICK
		{
			int i;
			for(i=0;i<MAXCONNECTION;i++)	{
				if( is_game_server_login(i) ){
					saacproto_ACKick_send( i , 1 , id , mesgid );
				}
			}
		}
		break;
	case 2:		//DEUNLOCK
		break;
	case 3:	//UNLOCKALL
		{
			extern gmsv gs[MAXCONNECTION];

			DeleteMemLockServer( gs[ti].name);
			sprintf(retdata, "GM UNLOCK ALL");
		}
		break;
	case 4: //LOCK
		  if ( lockUser( getGSName( ti ) , id , "0" , lock , result,sizeof(result),
					retdata ,sizeof( retdata ) , "0" , "0") < 0 ) {
				sprintf(retdata, "LOCK USER !!");
		  }
		break;
	case 5:	//查询玩家状态 TYPE
		{
			char buf[4096];
			if (GetMemLockState(getHash(id) & 0xff, id, buf)) {
				sprintf(retdata, "USR LOCKED: %s", buf);
			} else {
				sprintf(retdata, "USR UNLOCKED: %s", buf);
			}
		}
		break;
	case 6:		//MEMORY UNLOCK; UNLOCK
		{
			char result[100], retdata[100], process[16];
			int ret = 0;
	    ret = lockUser(  getGSName(ti), id , "0" , 0 , result , sizeof( result ) ,
                       retdata , sizeof( retdata ) , "0" , "0");
			if( strcmp( result , SUCCESSFUL ) == 0 ){
				log( "解锁账号 %s 成功！\n" , id );
			} else {
				log( "解锁账号 %s 失败！\n" , id );
				return;
			}

			snprintf( process , sizeof(process) , "%d" , ret );
			dummyCallback(ti,0,id,"dummy",charname,process,"",mesgid,0);
		}
		break;
		case 10:	//跨星球踢人不含load该星球
		{
			int i;
			for(i=0;i<MAXCONNECTION;i++)	{
				if( is_game_server_login(i) && i != ti ){
					saacproto_ACKick_send( i , 1 , id , mesgid );
				}
			}
		}
	}
    saacproto_ACKick_send( ti, 0, retdata, mesgid );
}

#endif

#ifdef _SEND_EFFECT		   // WON ADD 送下雪、下雨等特效
void SendEffect(char *effect)
{
    extern gmsv gs[MAXCONNECTION];
	int i;

	for (i=0; i<MAXCONNECTION; i++) {
		if (gs[i].use && gs[i].name[0]) {
				saacproto_SendEffect_send(i, effect);
		}
	}
}
#endif

#ifdef _AC_SEND_FM_PK		 // WON ADD 庄园对战列表储存在AC
void load_fm_pk_list()
{
	int i;
	char *filename={"data/family/fm_pk_list.txt"};
	FILE *fp;	

	if( !(fp=fopen(filename, "r"))  ){
		return;
	}

	for( i=0; i<FMPKLIST_MAXNUM; i++){
		char buf[256];
		if( fscanf( fp, "%s", buf) == EOF ) break;
		buf[strlen(buf)+1] = 0;
		memcpy( fm_pk_list[i], buf, strlen(buf)+1);				
	}

	fclose( fp);
	log("\n");
}

void save_fm_pk_list()
{
	int i;
	char *filename={"data/family/fm_pk_list.txt"};
	FILE *fp;	

	if( !(fp=fopen(filename, "w"))  ){
		return;
	}

	for( i=0; i<FMPKLIST_MAXNUM; i++){	
		fprintf(fp, "%s\n", fm_pk_list[i]);
	}

	fclose( fp);

}
#endif

#ifdef _ALLDOMAN // Syu ADD 排行榜NPC
void LOAD_herolist()
{
	FILE *fdb;
	int i, linenum=0;
	
	char filename[256], token[512];

	snprintf( filename , sizeof( filename ) ,"%s/%s" ,	"db/herolist","db_herolist.txt");
	if( !( fdb = fopen ( filename , "r+" ) ) ) {
		log("\nSyu log open db_herolist.txt error!!");
		return ; 
	}else {
		char *addr;
		fread ( &token , sizeof ( token ) , 1 , fdb ) ;
		fclose ( fdb ) ; 
		do {
			for ( i = 0 ; i < MAX_HERO_COLUMN ; i ++ ) {
				easyGetTokenFromBuf( token , "|", i + 1 , Herolist[ linenum ][ i ] , sizeof( Herolist[ linenum ][ i ] ) );
			}
			linenum ++;
			if ( (addr = strstr ( token , "\n" )) ) 
					strcpy ( token , addr + 1 ) ;
			else 
				break;
		} while ( 1 ) ;
	}
}

void SAVE_herolist (int fd)
{
	int i ; 
	FILE *fdb;
	char filename[256];
	snprintf( filename , sizeof( filename ) ,"%s/%s" ,	"db/herolist","db_herolist.txt");
	if( !( fdb = fopen ( filename , "w" ) ) ) {
		log("\nSyu log open db_herolist.txt error!!");
		return ; 
	}else {
		char tmp[256];
		for ( i = 0 ; i < MAX_HERO_LIST ; i ++ ) {
			sprintf( tmp , "%s|%s|%s|%d|%d|%d|%d\n" , 
				Herolist[i][0] , 
				Herolist[i][1] , 
				Herolist[i][2] , 
				atoi (Herolist[i][3]) , 
				atoi (Herolist[i][4]) , 
				atoi (Herolist[i][5]) , 
				atoi (Herolist[i][6]) );				
			fwrite(tmp, strlen(tmp), 1, fdb );
		}
		fclose ( fdb ) ; 
	}
}

void Send_A_herolist( int fd )
{
	FILE *fdb;
	int lens=0;
	char filename[256],buf[256];
	
	
	snprintf( filename , sizeof( filename ) ,"%s/%s" ,	"db/herolist","db_herolist.txt");
	if( !( fdb = fopen ( filename , "r+" ) ) ) {
		log("\n Syu log open db_herolist.txt error!!");
		return ; 
	}else {
		char token[100 * 100];
		memset( token, 0, sizeof(token));
		memset( buf, 0, sizeof(buf));
		while( fgets( buf , sizeof( buf ) , fdb )){
			buf[strlen(buf)] = 0 ;
			if( lens+strlen(buf) >= 65535 ){
				saacproto_UpdataStele_send ( fd , token );
				memset( token, 0, sizeof(token));
				lens = 0;
			}
			strcat( token, buf);
			lens += strlen( buf);
		}
		fclose ( fdb );
		if( strlen( token) > 0 )
			saacproto_UpdataStele_send ( fd , token ); 
	}
}

void Send_S_herolist( char *ocdkey , char *oname , char *ncdkey , char *nname , 
					 char *title , int level , int trns , int floor ) 
{
	int i;
    extern gmsv gs[MAXCONNECTION];

	for (i = 0 ; i < MAXCONNECTION ; i ++ ) {
		if ( gs[i].use && gs[i].name[0] ) {
			saacproto_S_UpdataStele_send( i , ocdkey , oname ,
				ncdkey , nname , title
				, level , trns , floor );
			log("\nSyu log AC Send Single to Gmsv ");
		}
	}		
}
#endif

#define MAXUNlockM 50
#define delaytime (60*3)
UNLockMenus UNlockM[MAXUNlockM];

int UNlockM_Init( void)
{
	int i;
	for( i=0; i<MAXUNlockM; i++)	{
		memset( UNlockM[i].PlayerId, 0, sizeof( UNlockM[i].PlayerId));
		UNlockM[i].use = 0;
		UNlockM[i].time = 0;
	}

	return 1;
}
void reset_UNlockMPlayer( int ti)
{
	memset( UNlockM[ti].PlayerId, 0, sizeof( UNlockM[ti].PlayerId));
	UNlockM[ti].use = 0;
	UNlockM[ti].time = 0;
}

int UNlockM_isBe( char *id)
{
	int i;
	for( i=0; i<MAXUNlockM; i++)	{
		if( UNlockM[i].use == 0 )continue;
		if( !strcmp( UNlockM[i].PlayerId, id ) ) return 1;
	}
	return 0;
}

//andy add 2002/06/20
int UNlockM_addPlayer( char *id)
{
	int i, post=-1;
	
	for( i=0; i<MAXUNlockM; i++)	{
		if( UNlockM[i].use == 0 ){
			post = i;
			continue;
		}
		if( !strcmp( UNlockM[i].PlayerId, id ) ){
			reset_UNlockMPlayer( i);
			return -1;
		}
	}
	if( post == -1 )return -1;

	memset( UNlockM[post].PlayerId, 0, sizeof( UNlockM[post].PlayerId));
	sprintf( UNlockM[post].PlayerId, "%s", id);
	UNlockM[post].use = 1;
	UNlockM[post].time = time(NULL)+delaytime;

	return post;
}

//andy add 2002/06/20
int UNlockM_UnlockPlayer( void)
{
	int i, nums=0;
	static int UnlockClock = 0;

	if( (++UnlockClock)<60 != 0 ) return 0;

	//log(" UNlockM_UnlockPlayer ");

	UnlockClock =0;
	for( i=0; i<MAXUNlockM; i++)	{
		if( !UNlockM[i].use ) continue;
		if( UNlockM[i].time >= time(NULL) ) continue;
		if( isLocked( UNlockM[i].PlayerId ) ){
			log( "等待解锁玩家: %s 还需锁定!!\n", UNlockM[i].PlayerId);
		}else{
			log( "等待解锁玩家: %s 已经解锁!!\n", UNlockM[i].PlayerId);
		}
		reset_UNlockMPlayer( i);
		nums++;
	}
	//log( "等待解锁玩家: 总计 %d 个用户解锁 !!\n", nums);
	return nums;
}

void saacproto_ACCharLogin_recv( int fd, int clifd, char* id, char* pas, char* ip )
{
	int res;
	
#ifdef _SASQL
	if (strlen(id)==0 || strlen(pas)==0 || strlen(ip)==0){
	  printf("登陆信息有错误！\n");
	  saacproto_ACCharLogin_send( fd, clifd, 0);
	  return;
	}
	if (sasql_chehk_lock(id)){
		printf("该账号%s禁止登陆!\n",id);
	  saacproto_ACCharLogin_send( fd, clifd, 0);
	  return;
	}
	if (sasql_chehk_lock(ip)){
		printf("该IP%s禁止登陆!\n",ip);
	  saacproto_ACCharLogin_send( fd, clifd, 0);
	  return;
	}
	res=sasql_query(id,pas);
	printf("res:%d\n",res);
	if (res==3){
#ifdef _SQL_REGISTER
		if(!sasql_register(id,pas))
#endif
		{
			saacproto_ACCharLogin_send( fd, clifd, 0);
	  	return;
		}
	}else if (res!=1){
		saacproto_ACCharLogin_send( fd, clifd, 0);
	  return;
	}
#endif
	saacproto_ACCharLogin_send( fd , clifd, 1);
}

#ifdef _SASQL
void saacproto_LockLogin_recv( int fd, char* id, char* ip, int flag )
{
	switch (flag){
		case 0:
			if(strlen(id)>0)
				if(sasql_del_lock(id))
					log("成功解除锁定账号:%s\n",id);
			if(strlen(ip)>0)
				if(sasql_del_lock(ip))
					log("成功解除锁定IP:%s\n",ip);
			break;
		case 1:
			if(strlen(id)>0)
				if(!sasql_chehk_lock(id))
					if(sasql_add_lock(id))
						log("成功锁定账号:%s\n",id);
			if(strlen(ip)>0)
				if(!sasql_chehk_lock(ip))
					if(sasql_add_lock(ip))
						log("成功锁定IP:%s\n",ip);
			break;
		default:
			break;
	}
}
#endif