/*
--------------------------------------------
  define the other constants
--------------------------------------------
*/
#define WIN32_LEAN_AND_MEAN
#define MAX_FIELDS			26
#define MAX_OUTRES			400
#define SINGLEQUOTES		39
#define PERCENT 37
#define	MSQL_UNKNOWN_TYPE	 0
#define MSQL_CHAR            1
#define MSQL_NUMERIC         2
#define MSQL_DECIMAL         3
#define MSQL_INTEGER         4		
#define MSQL_SMALLINT        5
#define MSQL_FLOAT           6		
#define MSQL_REAL            7
#define MSQL_DOUBLE          8
#define MSQL_DATETIME        9
#define MSQL_VARCHAR        12


typedef struct
{
    char m_destination[41];
	char m_sn[11];
	char m_dayvalue[20];
	char m_packettype[3];
	char m_requesttype[3];
	char m_oprcode[7];
	char m_source[41];
	char m_message[513];
}CCENTEMP;

typedef struct 
{
	char qysjz[20];
	char ckzbh[5];
	char rkzbh[5];
	char cxdmz[3];
	int  sfjez;
	int  sfdmz;
}CBZXFLDYB;

typedef struct
{
    char qysjz[20];
	char ckzbh[6];
	char rkzbh[6];
	char cxdmz[3];
	int  sfjez;
	int  sfdmz;
}CBZSFBZDY;
/////////////table 1
typedef struct
{
	char qyrqz[20];
	char bcdmz[2];
	char bcmcz[11];
	char qssjz[6];
	char zzsjz[6];
}CBZBCDMDY;

/////////////table 2
typedef struct
{
	char sfzbh[5];
	char sfzmc[11];
	char xhzzz[5];
}CBZRKZBHB;

///////////table 3
typedef struct
{
	char sfzbh[5];
	char ygghz[6];
	char ygxmz[11];
	char ygxbz[3];
	char ygzwz[11];
	char ygmmz[9];
}CBZSFYGXX;
/////////////table 4
typedef struct
{
	char sbdmz[3];
	char bcdmz[21];
}CBZSBDMDY;
////////////////table 5
typedef struct
{
	char sfqkz[9];
	int msdmz;
}CBCDSQMS;
/////////////table 6
typedef struct
{
	char qyrqz[20];
	char yhqsj[6];
	char yhzsj[6];
	double yhflz;
	char yhjsf[2];
}CBZCLYHXX;

typedef struct
{
	char rkzbh[6];
	char rksjz[20];
	char cxdmz[2];
	char cldmz[2];
	char pkdmz[2];
}CICKQUERY;

typedef struct
{
    char sfzbh[5];
	char zbrqz[20];
	char sfygh[6];
	char sfyxm[9];
	char gbhzz[2];
}CBZSFYPBB;

///////////bad IC
typedef struct
{
	char ksyzz[6];
	char kdmzz[2];
	char kbhzz[11];
	char bzzzz[51];
}CBZKHMDXX;

typedef struct
{
	char zyrkz[5];
	char ckcdh[3];
	char sfzbh[5];
}CBZSFZYZZ;

typedef struct
{
	char sfzbh[5];
	char ckcdh[3];
	char zyzhz[5];
}CBZZYZHZZ;
typedef struct
{
    char cwsjz[6];
}CBZSFCWSJ;

typedef struct
{
    char qysjz[20]; 
}CBZSFSJDY;

typedef struct
{
   char dyrqz[20];
   char qszhz[5];
   char zzzhz[5];
   char yzbhz[3];
   char rkzhz[5];
   char ckzhz[5];
}CBZYZLJBZ;

typedef struct
{
   char yzbhz[3];
   char sfzbh[5];
   int  sfzxh;
}CBZYZZPXB;

typedef struct
{
    char dysjz[20];
	char ksyzz[11];
	char phone[14];
	char cpbhz[11];
	char ickbh[11];
	char cxdmz[2];
	char cldmz[2];
	char yzbhz[3];
	char yhqsz[5];
	char yhzzz[5];
	char qssjz[20];
	char zzsjz[20];
	double yhflz;
}CBZCZYHXX;

/*
-------------------------------------------
define the fileds amd filed information 
data structure which used in the ODBC access
-------------------------------------------
*/
typedef struct
{
	char fieldname[11];
	short fieldtype;
	unsigned int fieldsize;	
}FIELDINFO;

typedef struct
{
	FIELDINFO m_fieldinfo[MAX_FIELDS];
	int fieldcount;
}TABLE_FIELDSINFO;

typedef struct
{
	char *recordscontent;
	char pack_head[12];
	int totalcount;
	//int totalsendcount;
	int recordlen;
	int packageNO;
	//unsigned long alreasequence;
	int m_errorflag;
	//SENDUNIT failedsendunit[MAX_OUTRES/5];
	int resendtimes;
}OUTRECORDS;

/*
--------------------------------------
the ODBC information
--------------------------------------
*/
typedef struct 
{
	SQLHENV henv;
	SQLHDBC hdbc;
	SQLHSTMT hstmt;
	SQLRETURN retcode;
}DatabaseID;

/*
-------------------------------------
the db source connetion 
-------------------------------------
*/
typedef struct 
{
	SQLCHAR *m_servername;
	SQLCHAR *m_uid;
	SQLCHAR *m_pwd;
}ConnString;

/*
------------------------------------------
the select field data structure
------------------------------------------
*/
typedef struct 
{
	SQLCHAR m_fieldvalue1[20];
	SQLINTEGER   m_fieldvalue2;
	SQLREAL m_fieldvalue3;
	short m_fieldtype;
}BindFieldInfo;

typedef struct
{
	char PACKunit[140];
	unsigned long PACKsequence;
	int tablename_start_endflag;
	int Unit_Recordno;//every unit_package include records
	int SuccessFlag;// 1 success; 0 initialize_val;  2 failed
	short sendtimes;
	unsigned long lastsend_tm;
}SENDUNIT;

int OpenDBS( DatabaseID *m_baseid, ConnString m_constring);
void CloseDBS(DatabaseID *m_baseid);
int InsertSQL( DatabaseID *m_baseid,char * m_tablename,char *m_values);
int DeleteSQL( DatabaseID *m_baseid,char * m_tablename,char *m_condition);
int UpdateSQL( DatabaseID *m_baseid,char * m_tablename,char * m_set,char *m_condition);
int SelectSQL(DatabaseID *m_baseid,char *m_fields,char * m_tablename,char m_condition[]);
int FindUser( DatabaseID *m_baseid,char *m_fields,char * m_tablename,char *m_condition);
int SelectRecord( DatabaseID *m_baseid, TABLE_FIELDSINFO m_fieldsinfo, char *m_tablename,char *m_condition);//OUTRECORDS m_outvalues[]);
int Findtime( DatabaseID *m_baseid,char *m_fields,char * m_tablename,char *m_resulttime);
//nntoll.ini
int SelectSFYDB(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
int SelectSFZDB(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
int SelectShift(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
int SelectAutho(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
int SelectZysfz(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
int SelectZyzhz(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
int SelectSfypb(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
int SelectCwsjz(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
//ofindex.ini and nfindex.ini
int SelectFLSJ(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
int SelectBZLJB(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename,const char* m_filename2,int flag);
int SelectOFLDB(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* rkzh,char* ljrk,char* ljck,const char* m_filename);
int SelectNFLDB(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* rkzh,char* ljrk,char* ljck,const char* m_filename);
int SelectFL(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename,const char* m_filename2,int flag);
//owner.ini
int SelectOWN(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
int SelectYZZXH(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
//otimerate.ini and ntimerate.ini
int SelectCLYH(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
int SelectNCLYH(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
//blackic.ini
int SelectBLACK(DatabaseID *m_baseid,char* m_fields,char* m_tablename,char* m_condition,const char* m_filename);
//local table
int DownRecord(DatabaseID *m_baseid,DatabaseID *m_localbaseid, char **m_tablename,char* m_condition);
int SelectDownFLDB(DatabaseID *m_baseid,DatabaseID m_mDbId,char* m_fields,char* m_tablename,char* m_condition);
int SelectDownNFLDB(DatabaseID *m_baseid,DatabaseID m_mDbId,char* m_fields,char* m_tablename,char* m_condition);
int SelectCZYH(DatabaseID *m_baseid,DatabaseID m_mDbId,char* m_fields,char* m_tablename,char* m_condition);