wk.c

石器时代8.0服务端完整源代码。可以直接编译

#include <stdio.h>
#include <stdlib.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <sys/socket.h>
#include <unistd.h>
#include <strings.h>
#include <time.h>
#include <sys/time.h>
#include <netinet/tcp.h>
#include <signal.h>
#include <sys/types.h>
#include <time.h>
#include <sys/time.h>
#include <errno.h>
#include <sys/wait.h>
#include <getopt.h>
#include <signal.h>
#include <string.h>
#include "TCPIP.h"
#include "tools.h"
#include "version.h"

static int WORK_TYPE = 0;
#ifdef _FIX_WORKS
#define ACADDRESS "127.0.0.1"
#define ACPORT 9400
static int afd;
int LoginToAC();
int Ac_message_accept( char *buf, int slen);

#endif

#define PROD_ID	"8904001"
unsigned long myIP;

int mainsockfd;
int port = -1;
int debug = 0;
int timeout = 7200;
char logdir[1024];

int csd=-1;
char WGSAddress[1024];
int WGSPort = -1;
#define BUF_SIZE 4096
int zap=0;
int additional_process=0;

#ifdef _ADD_AC_IP				 // WON ADD 加AC_IP至通讯协定中
char AC_IP[20];
#endif


void sigpipe(int i)
{
	csd=0;
	signal(SIGPIPE,sigpipe);
}

void sigusr1(int i)
{
	if (csd>0) close(csd);
	csd=TCPconnect(WGSAddress,WGSPort);
	signal(SIGUSR1,sigusr1);
}

void sigusr2(int i)
{
	zap=1-zap;
	additional_process=time(0)/256;
	signal(SIGUSR2,sigusr2);
}

void sigterm(int i)
{
	signal(SIGTERM,sigterm);
}

void writeLog( char *msg );

char *dummy[7][2]={
    {"SYSOP","GoodNight" },
    {"SYSOP1","Good1" },
    {"SYSOP2","Good2" },
    {"SYSOP3","cary" },
    {"SYSOP4","Good4" },
    {"SYSOP5","Good5" },
    {"SYSOP6","Good6" }};

static int checkCSconnect( void)
{
	int num = 0;
	while( csd <= 0 && num < 10 ){
		csd = TCPconnect(WGSAddress,WGSPort);
		if( csd <= 0 ) sleep( 6);
		num++;
	}
	if( csd <= 0 ){
		char buf[256];
		sprintf( buf, "无法连接到 %s:%d !\n", WGSAddress, WGSPort);
		Log( buf);
		return -1;
	}
	return 1;
}

#ifdef _TIMEOUTKICK
static int doKN( char *id , char *pas , char *flag , char *process , char *deadline)
#else
static int doKN( char *id , char *pas , char *flag , char *process)
#endif
{
	char buffer[BUF_SIZE],idbuf[BUF_SIZE],pasbuf[BUF_SIZE],m[BUF_SIZE];
	char *ptr;
	int ret, x, baka;
	struct timeval tv;
	fd_set rfds;
	int iProcess;

	int length;

	if (zap) return(0);
		
	again:

	if (csd<=0) csd=TCPconnect(WGSAddress,WGSPort);

	if (csd<=0) {sleep(1); return(-1); }
	else {

		tv.tv_sec=0;
		tv.tv_usec=1000;
		FD_ZERO(&rfds);
		FD_SET(csd,&rfds);
		x=select(1024,&rfds,0,0,&tv);

		if (x<0){ return(-100);}
			
		if (x>0) {
			ret=read(csd,buffer,BUF_SIZE-8);

			if (ret<=0) { close(csd); sleep(1); csd=0; goto again; }
		}

		strcpy(idbuf,xchange(id));
		strcpy(pasbuf,xchange(pas));
		iProcess = atoi( process );

		switch (*flag) {
		case '1': // Login
		
#ifdef _FIX_MESSAGE                // WON ADD 修改封包内容		

#ifdef _ADD_AC_IP				 // WON ADD 加AC_IP至通讯协定中
			sprintf(buffer,"&;5;6;%s;%s;0;%s;",idbuf,pasbuf, AC_IP);
#else
			sprintf(buffer,"&;5;6;%s;%s;0;",idbuf,pasbuf);
#endif

#else
			sprintf(buffer,"&;9999;5;J;%s;%s;",idbuf,pasbuf);
#endif
			Log( buffer);
			baka=90000+bakayaro(id);
			break;
		case '4': // Delete

#ifdef _FIX_MESSAGE                // WON ADD 修改封包内容		

#ifdef _ADD_AC_IP				 // WON ADD 加AC_IP至通讯协定中
			sprintf(buffer,"删除人物：%s %s %s\n",idbuf,pasbuf, AC_IP);
#else
			sprintf(buffer,"删除人物：%s %s\n",idbuf,pasbuf);
#endif

#else		
			sprintf(buffer,"&;9999;5;J;%s;%s;",idbuf,pasbuf);
#endif
			Log( buffer);
			baka=90000+bakayaro(id);
			break;
		case '2': // Game Start
#ifdef _TIMEOUTKICK
		case '5': // recheck WGS deadline
#endif

#ifdef _FIX_MESSAGE                // WON ADD 修改封包内容		

#ifdef _ADD_AC_IP				 // WON ADD 加AC_IP至通讯协定中
			sprintf(buffer,"进入游戏：%s %s %s\n",idbuf,pasbuf, AC_IP);
#else
			sprintf(buffer,"进入游戏：%s %s\n",idbuf,pasbuf);
#endif

#else				
			sprintf(buffer,"&;9999;6;6;%s;%s;%d;",idbuf,pasbuf,iProcess+additional_process);
#endif
			Log( buffer);
			baka=10000+bakayaro(id);			
			break;
		case '3': // Game End
		
#ifdef _FIX_MESSAGE                // WON ADD 修改封包内容		

#ifdef _ADD_AC_IP				 // WON ADD 加AC_IP至通讯协定中
			sprintf(buffer,"退出游戏：%s %s\n",idbuf, AC_IP);
#else
			sprintf(buffer,"退出游戏：%s\n",idbuf);
#endif

#else				
			sprintf(buffer,"&;9999;5;7;%s;%d;",idbuf,iProcess+additional_process);
#endif
			Log( buffer);
			baka=20000+bakayaro(id);
			break;
		default:
			return(-100);
		}
		//Log("<BW>");
		//Log(buffer);
		ret=write(afd,buffer,strlen(buffer));
		//Log("<AW>");

		// Write error
		if (ret<0) { close(csd); sleep(1); csd=0; goto again; }

		// Line busy
		if (ret==0) { sleep(1); return(-103); }

		tv.tv_sec=0;
		tv.tv_usec=0;
		FD_ZERO(&rfds);
		FD_SET(csd,&rfds);
		//Log ("<BS>");
		x=select(1024,&rfds,0,0,&tv);
		//Log ("<AS>");
		if (x<0) return(-101);
		if (x==0) return(0);
		//Log ("<BR>");
		ret=read(csd,buffer,BUF_SIZE-8);
		//Log ("<AR>");
		snprintf( m, sizeof(m), "ret: %d ", ret );
		Log( m );
		// Read error
		if (ret<=0) { close(csd); sleep(1); csd=0; return(-104); }
		buffer[ret]=0; 

		snprintf( m,sizeof(m) ," WGS: %s\n",buffer);
		Log( m );

		strtok(buffer,";"); // Get &
		length = atoi( strtok(0,";")); // Get length
		ptr=strtok(0,";"); // Get Flag

		if (ptr==0) return(-105);

		if (ptr[0]=='K') {

			int payType;

#ifndef _FIX_MESSAGE                // WON ADD 修改封包内容	
			if (atoi(ptr+1)!=baka){
				char buff1[256];
				sprintf( buff1, "%d != %d\n", atoi(ptr+1), baka);
				Log(buff1);
				return(-100);
			}
#endif

#ifdef _TIMEOUTKICK

			payType = atoi( strtok(0,";"));
			
			if( *flag == '1' || *flag == '4' ) { // GameLogin or Char Delete
				strtok(0,";"); // get Point
			}
			
			if( strcmp( strtok(0,";"), idbuf)) {  // get PlayerAccount
				//Log(" 回传帐号不符! ");
				//return(-106);
			}

			switch( payType) {
			case 1: // 包月制
				strcpy( deadline ,"0");
				Log(" 包月 ");
				break;
			case 2: // 时段制
				//strtok(0,";"); // get PlayerAccount
				strcpy( deadline ,strtok(0,";"));
				Log(" 时段 ");
				break;
			case 0:
				strcpy( deadline ,"0");
				Log(" 结束 ");
				break;
			}

#endif

			switch (*flag) {
			case '1': // List
				Log("用户登陆\n");
				break;
			case '4': // Delete
				Log("删除人物\n");
				break;
			case '2':
				Log("进入游戏\n");
				break;
			case '3':
				Log("退出游戏\n");	
				break;
#ifdef _TIMEOUTKICK
			case '5':
				Log("Deadline recheck\n");
				break;
#endif
			default:
				Log("Strange but passed\n");
				break;
			}
			return(0); // Authencation passed
		}

#ifdef _FIX_MESSAGE                // WON ADD 修改封包内容
		// 回传错误码
		else if (ptr[0]=='E'){
			char err_code[10];
			int i, err_num=0, login_star=-1;
#ifdef _TIMEOUTKICK
			if( length != 3 )
				strtok(0,";"); // Get 1
			if( *flag != '1' && *flag != '4') {
				if( strcmp( strtok(0,";"), idbuf)) {  // get PlayerAccount
					//Log(" 回传帐号不符! ");
					//return(-106);
				}
			}
			strcpy( deadline ,"0");
#endif
			ptr=strtok(0,";"); 
			
			for(i=0; i<9; i++){
				if (ptr[i] == ' ' )	break;
				err_code[i]=ptr[i];			
			}

			err_num=atoi(err_code);

			if( err_num == 203 ){			// 203 不同星系
					login_star=atoi(ptr+i);
					Log("203");
					// 回传已登入的星系代码
					if(login_star != -1)
						return(login_star+2030);
			}
			else if( err_num == 204 ){		// 204 同星系	
					Log("204");
					if( *flag == '5')
						Log(" 时段未到 ");
					return(204);
			}else{
				char msg[256];
				sprintf( msg, "won test 1 ==> err_num(%d)", err_num);
				Log( msg );
				return(err_num);
			}

			
		}
#endif

		return(-106);
	}
}
#ifndef _FIX_WORKS  
static int createMainSocket( int port )
{
    int s,r;
    struct sockaddr_in sin;

    s = socket( AF_INET , SOCK_STREAM , 0 );
    if( s < 0 ){
        fprintf( stderr, "socket error" );
        return s;
    }

    sin.sin_family = AF_INET;
    sin.sin_port = htons( port );
    sin.sin_addr.s_addr = htonl(INADDR_ANY);

    if( (r = bind( s , (struct sockaddr*) &sin , sizeof( sin )) ) <0 ){
        fprintf(stderr, "绑定失败" );
        return r;
    }
    listen( s , 5 );

    return s;

}
#endif
static void remove_r( char *s )
{
    int i;
    for(i=0;;i++){
        if(s[i]=='\r')s[i] =0;
        if( s[i]==0)break;
    }
}

static void easyGetTokenFromString( char *src,int count,char*output,int len )
{
    int i;
    int counter = 0;

    if( len <= 0 )return;

#define ISSPACETAB( c )   ( (c) == ' ' || (c) == '\t' )

    for(i=0;;i++){
        if( src[i]=='\0'){
            output[0] = '\0';
            return;
        }
        if( i > 0 && ! ISSPACETAB( src[i-1] ) &&
            ! ISSPACETAB(  src[i] ) ){
            continue;
        }

        if( ! ISSPACETAB( src[i]) ){
            counter++;
            if( counter == count){