#ifndef _DBCONNECTIONTHREAD_H
#define _DBCONNECTIONTHREAD_H

#include "ado.h"
#include <list>
using namespace std;

extern HANDLE m_hDBConnectionThread;
extern BOOL m_bDBConnectionTerminate;
extern DWORD m_dwDBConnectionThreadId;

extern BOOL DBConnectionThreadStart();
extern BOOL DBConnectionThreadEnd();
extern DWORD WINAPI DBConnectionThreadProc(LPVOID lpParameter);
extern VOID DBCheckConnection();

extern INT GetMaxID( CHAR *pTableName, CHAR *pFieldName, CHAR *pMaxID );
extern INT GetVarMaxID( CHAR *pMaxID );

extern INT InsertVarInfo(int nID, CHAR *pUid, CHAR *pVarName, CHAR *pDesc, int nVarTypeID, int nDataLen,
				  CHAR *pOnDesc, CHAR *pOffDesc, int nMaxValues, int nMinValues,
				  int nMaxScale, int nMinScale, int nLowerLimit, int nUpperLimit, 
				  int nNormalState, CHAR *pSetValue, int nRearm, int nOffset, CHAR *pUnit,
				  int nCollentFreq, float fCoef, int nWarnLevel, int nReadOnly, int nIsSave,
				  int nRealtimeFlag, int nRecCurve, int nIsDDE, int nRegNum, int nFuncID,
				  int nChildID, int nVarItemID, CHAR *pSnmpOid, CHAR *pField, int nDevID,
				  int nRegStartAddr, CHAR *pRs232Cmd, CHAR *pRs232Type, int nRs232Index,
				  int nIdentifyTime, int nReDetectTime, int nNormIsNotice,
				  char *pStrReserved1, char *pStrReserved2, char *pStrReserved3, char *pStrReserved4,
				  char *pStrReserved5, char *pStrReserved6, char *pStrReserved7, char *pStrReserved8,
				  char *pStrReserved9, char *pStrReserved10,
				  int nReserved1, int nReserved2, int nReserved3, int nReserved4, int nReserved5,
				  int nReserved6, int nReserved7, int nReserved8, int nReserved9, int nReserved10,
				  int bReserved1, int bReserved2, int bReserved3, int bReserved4, int bReserved5,
				  int bReserved6, int bReserved7, int bReserved8, int bReserved9, int bReserved10);

//获取t_dev_variant_item资料
extern INT GetVarItem( CHAR *pUid, int nVarItemID );

//插入Bit位表
extern INT InsertVarItemInfo(int nID, CHAR *pUid, int nStartBit, int nEndBit);

//更新Bit位表
extern INT UpdateVarItemInfo(int nID, CHAR *pUid, int nStartBit, int nEndBit);

//插入变量状态描述
extern INT InsertVarStatusInfo(int nID, CHAR *pUid, int nVarID, int nStatusID, CHAR *pStatusDesc);

//获取变量报警状态最大的ID
extern INT GetVarStatusMaxID( CHAR *pMaxID );

//删除变量状态描述
extern INT DeleteVarStatusInfo(CHAR *pUid, int nVarID);

//插入数据记录
extern INT InsertDataRecord(
									CHAR* pDevName,				// 设备名称
									CHAR* pHappenTime,			// 发生时间
									CHAR* pVarName,				// 变量名称
									CHAR *pVarDesc,				// 变量描述
									double dbCurrValue			// 当前值
								);

//插入控制器记录
INT InsertControlInfo(
									int nbrandtype,
									CHAR* scontrolname,	
									CHAR* ssn,
									int nwordmode,
									int ncomport,
									CHAR* sip,			
									CHAR* sport,					
									int  nforbid,
									int  ndoorconut,
									CHAR* sdoor1,
									CHAR* sdoor2,
									CHAR* sdoor3,
									CHAR* sdoor4,
									CHAR* sdoor5,
									CHAR* sdoor6,
									CHAR* sdoor7,
									CHAR* sdoor8
								);
//更新控制器记录
INT UpdateControlInfo(
									int nID,
									int nbrandtype,
									CHAR* scontrolname,	
									CHAR* ssn,
									int nwordmode,
									int ncomport,
									CHAR* sip,			
									CHAR* sport,					
									int  nforbid,
									int  ndoorconut,
									CHAR* sdoor1,
									CHAR* sdoor2,
									CHAR* sdoor3,
									CHAR* sdoor4,
									CHAR* sdoor5,
									CHAR* sdoor6,
									CHAR* sdoor7,
									CHAR* sdoor8
								);
//插入卡记录
INT InsertCardInfo(
									CHAR* susername,	
									CHAR* scardnumber,
									CHAR* sclass,			
									CHAR* sjobnumber,					
									CHAR* sremarks
								);
//插入卡记录_导入
INT InsertCardInfo_INPUT(
									CHAR* susername,	
									CHAR* scardnumber,
									CHAR* sclass,			
									CHAR* sjobnumber,					
									CHAR* sremarks
								);
//更新卡记录
INT UpdateCardInfo(
									int nID,
									CHAR* susername,	
									CHAR* scardnumber,
									CHAR* sclass,			
									CHAR* sjobnumber,					
									CHAR* sremarks
								);
//插入进出记录
INT InsertRecordInfo(
									CHAR* scardnumber,	
									CHAR* speople,
									CHAR* sinout,			
									CHAR* sinfo,					
									CHAR* stime
								);

//清空表
INT CleanTable( CHAR *pTableName );
//删除表中的项
INT DelItemFromTable( CHAR *pTableName,CHAR* iItem,int nData );
//表中是否存在
bool IsExistItem( CHAR *pTableName,CHAR* iItem,CHAR* sData );
bool IsExistItem( CHAR *pTableName,CHAR* iItem,CHAR* sData,int iID );

int GetFieldValueList1(char *pSql,list<string>& list1);
int GetFieldValueList2(char *pSql,list<string>& list1,list<string>& list2);
int GetFieldValueList3(char *pSql,list<string>& list1,list<string>& list2,list<string>& list3);
int GetFieldValueList6(char *pSql,list<string>& list1,list<string>& list2,list<string>& list3,list<string>& list4,list<string>& list5,list<string>& list6);
int GetFieldValueList9(char *pSql,list<string>& list1,list<string>& list2,list<string>& list3,list<string>& list4,list<string>& list5,list<string>& list6,list<string>& list7,list<string>& list8,list<string>& list9);
int GetFieldValueList13(char *pSql,list<string>& list1,list<string>& list2,list<string>& list3,list<string>& list4,list<string>& list5,list<string>& list6,
					   list<string>& list7,list<string>& list8,list<string>& list9,list<string>& list10,list<string>& list11,list<string>& list12,list<string>& list13);
int GetFieldValueList30(char *pSql,list<string>& list1,list<string>& list2,list<string>& list3,list<string>& list4,list<string>& list5,list<string>& list6,
					   list<string>& list7,list<string>& list8,list<string>& list9,list<string>& list10,list<string>& list11,list<string>& list12,list<string>& list13
					   ,list<string>& list14,list<string>& list15,list<string>& list16,list<string>& list17,list<string>& list18,list<string>& list19,list<string>& list20
					   ,list<string>& list21,list<string>& list22,list<string>& list23,list<string>& list24,list<string>& list25
					   ,list<string>& list26,list<string>& list27,list<string>& list28,list<string>& list29,list<string>& list30);
INT UpdateVarSnmpStatus( int nID, bool bStatus );
#endif