#include "caSocket.h"
#include "stdlib.h"
#include "stdio.h"
#include "process.h"
#include "DealAll.h"
#include "Dlodbc.h"
#include "dhodbc.h"

#define BUFLEN 18000
#define PACKLEN	2400
caSocket m_Socket;		// Our winSocket wrapper class
BOOL m_bConnected;		// Boolean representing state of application
caSocket abc;
DBCONN dbconn[MAXDBCONN];


void FirstThread(void *AcceptSocket)
{
	char szRcvBuf[BUFLEN]; 
	char szSndBuf[BUFLEN];
	CASTHEAD *casthead;
	caSocket def;
	int	nRtn;
	int OutDataLen;
	def.m_hSocket = *(SOCKET *)AcceptSocket;
	nRtn = def.ExpRead(szRcvBuf,BUFLEN);
	printf("recv nTotal = %d\n",nRtn);
	nRtn = DealAll(szRcvBuf,nRtn,szSndBuf,BUFLEN,&OutDataLen);
//	memset(szRcvBuf,'8',sizeof(szRcvBuf));
	casthead = (CASTHEAD *)szSndBuf;
//	casthead->nType += 1;
	nRtn = def.ExpWrite(szSndBuf,OutDataLen);
		printf("Snd %d\n",nRtn);
	nRtn = def.Close();
	nRtn = FreeHdNum();
	_endthread();
}

void main()
{


	int nRtn,i=0,nTotal=0;
	SOCKET AcceptSocket;
	SQLHDBC hdbc=NULL; 
	unsigned char	databasename[30]="fgog";                                                            
	unsigned char	username[30]="ca";                                                                  
	unsigned char	password[30]="fourgold";                                                            
         
	
	for(i=0;i<MAXDBCONN;i++)
	{
		hdbc=ConnectDB(databasename, 4, username, 2, password, 8);
		if(hdbc != NULL)
		{
			dbconn[i].handle = (long)hdbc;
		}
		else
		{
			printf("conn db error\n");
			return;
		}
	}

	/*
	DWORD dwSerialNum;
	nRtn = DBGetSetSerial(&dwSerialNum);
	ISUCERT* p=NULL;
	DBInsertCertReq(p,dwSerialNum);
	

	DBInsertCert(111,(unsigned char *)"asdfasdfasdf",12);
	*/

	if( abc.Create() != ERR_SUCCESS ) // Create the socket
		return;
	nRtn = abc.Bind("192.168.0.67",6768);
	nRtn = abc.Listen(5);
	

	while(1)
	{
		AcceptSocket = abc.Accept();
		if(AcceptSocket == ERR_WSAERROR)
			continue;
		_beginthread(FirstThread,0,(void *) &AcceptSocket);
	}
	
}