repos_ecs/源数据/PC环境监控/tryto v1.0.0.3/MFCService/Service/MainPro.cpp

#include "stdafx.h"
#include "ascprocess.h"
#include "Global.h"
#include "struct.h"
#include "MainPro.h"
#include "rtuprocess.h"
#include "tcpprocess.h"
#include "icpdasprocess.h"
#include "SnmpProcess.h"
#include "upsParadigmProcess.h"
#include "stulzprocess.h"
#include "NoticeQueue.h"
#include "DaiKinProcess.h"
#include "PowerwareProcess.h"
#include "greeprocess.h"
#include "CarelProcess.h"
#include "Client2SrvType.h"
#include "SysLib.h"
#include "Separate.h"
#include "MostDevice.h"
#include "Const.h"
#include "ping.h"

CRITICAL_SECTION g_csDevOnlineReadOneData;
#define		DATA_CHANGE_FLAG		0.01//0.00001

#if IS_USER_MUL_THREAD_REQUEST
HANDLE g_hRequestDataThread[MAX_DLL_TYPE] = {0};
CString g_strPort[MAX_DLL_TYPE];
#else
HANDLE g_hRequestDataThread = NULL;
#endif
HANDLE g_hReConnectCommThread = NULL;

INT g_nRequestDataThreadCount = 0;

INT g_nTimingSendFinished = 0;
HANDLE g_hTimingSendSmsThread = NULL;

HANDLE g_hDevOnlineThread = NULL;

HANDLE g_hVoiceNoticeThread = NULL;
HANDLE g_hOutputThread = NULL;
HANDLE g_hGetDatePlanThread = NULL;

INT g_nRtuThreadIndex = RTU_THREAD_START;			//预留100个Modbus Rtu设备，每个串口一个处理线程
INT g_nAscThreadIndex = ASC_THREAD_START;			//预留100个Modbus Asc设备，每个串口一个处理线程
INT g_nTcpThreadIndex = TCP_THREAD_START;			//预留100个Modbus Tcp设备，每个IP一个处理线程
INT g_nSnmpThreadIndex = SNMP_THREAD_START;			//预留200个Snmp设备，每个IP一个处理线程
INT g_nMostDeviceIndex = MOSTDEVICE_THREAD_START;	//预留100个MostDevice类型有设备，每个IP一个处理线程
INT g_nIcpdasIndex = ICPDAS_THREAD_START;			//预留10个泓格设备，每个串口一个处理线程
INT g_nParadigmIndex = PARADIGM_THREAD_START;		//预留10个Paradigm设备，每个串口一个处理线程
INT g_nStulzIndex = STULZ_THREAD_START;				//预留10个Stulz设备，每个串口一个处理线程
INT g_nDaiKinIndex = DAIKIN_THREAD_START;			//预留10个Dinkin设备，每个串口一个处理线程
INT g_nPowerwareIndex = POWERWARE_THREAD_START;		//预留10个Powerware设备，每个串口一个处理线程
INT g_nGreeIndex = GREE_THREAD_START;				//预留10个Gree设备，每个串口一个处理线程
INT g_nCarelIndex = CAREL_THREAD_START;				//预留10个Carel设备，每个串口一个处理线程
INT g_nScantakIndex = SCANTAK_THREAD_START;			//预留10个Scantak设备，每个串口一个处理线程
INT g_nDeltaIndex = DELTA_THREAD_START;				//预留10个Delta设备，每个串口一个处理线程


// 该结构体用于网络设备;
typedef struct __TCP_THREAD_STRUCT
{
	int nTcpTheadIndex;		// 每一个网络设备对应的一个线程ID索引;(每一个ip就一个线程)
	CString strUid;			// 与索引相联的网络设备UID;
}TcpThreadStruct;

INT g_nTcpThreadStructIndex = 0;		// 供g_tcpThreadStruct数组使用,下标号;
TcpThreadStruct g_tcpThreadStruct[MAX_TCP_THREAD];

DWORD WINAPI RequestDataThreadProc(void *pPara);
DWORD WINAPI ReConnectCommThreadProc(void *Para);
DWORD WINAPI TimingSendSmsThread(void *pPara);
DWORD WINAPI DevOnlineThreadProc(void *pPara);
DWORD WINAPI VoiceNoticeThreadProc(void *pPara);
DWORD WINAPI OutputThreadProc(void *pPara);
DWORD WINAPI GetDatePlanThreadProc(void *pPara);

// 获取实际波特率
INT GetCommRate(int nRate);

// 获取实际数据位
INT GetCommDataBit(int nDataBitIndex);

// 以下查找串口是否使用的13个函数,由函数主函数StartMain调用;
BOOL FindRtuCommPort(CString strPort);
BOOL FindAscCommPort(CString strPort);
BOOL FindTcpCommPort(CString strPort);
BOOL FindMostDeviceCommPort(CString strPort);
BOOL FindIcpdasCommPort(CString strPort);
BOOL FindParadigmCommPort(CString strPort);
BOOL FindStulzCommPort(CString strPort);
BOOL FindDaiKinCommPort(CString strPort);
BOOL FindPowerwareCommPort(CString strPort);
BOOL FindGreeCommPort(CString strPort);
BOOL FindCarelCommPort(CString strPort);
BOOL FindScanTakCommPort(CString strPort);
BOOL FindDeltaCommPort(CString strPort);

INT StartMain()
{
	//INT iCount = GetDevProperty();
	// 初始化该结构体数组 , 每个网络设备的信息;
	for( int i = 0; i < MAX_TCP_THREAD; i++ )
	{
		// g_tcpThreadStruct存放TCP线程索引和设备uid; 
		g_tcpThreadStruct[i].nTcpTheadIndex = 0;
		g_tcpThreadStruct[i].strUid = "";
	}

	// 从数据库中获取设备信息;
	CDBInterface::GetInstancePtr()->GetDevInfo();

	// 初始化设备在线采集数据 互斥量;
	InitializeCriticalSection( &g_csDevOnlineReadOneData );

	// **********************************************加载各种采集I/O设备动态库**********************************************;
	// 改进:加载动态库时,应该考虑如何根据设备信息来动态加载,而不是一次全部加载;
	LoadAscDLL(g_strDirectory);
	LoadRtuDll(g_strDirectory);
	LoadTcpDll(g_strDirectory);
	LoadIcpdasDll(g_strDirectory);
	LoadSnmpDll(g_strDirectory);
	LoadParadigmDll(g_strDirectory);
	LoadStulzDll(g_strDirectory);
	LoadDaiKinDll(g_strDirectory);
	LoadPowerwareDll(g_strDirectory);
	LoadGreeDll(g_strDirectory);
	LoadCarelDll(g_strDirectory);
	LoadSeparateDll(g_strDirectory);
	LoadMostDeviceDll(g_strDirectory);

	// 获取设备总数;
	int iSize = (int)g_pDevicesManager->m_Devices.GetSize();
	//int iVarCount = 0;

#if IS_USER_MUL_THREAD_REQUEST // 是否使用多线程请求; 现在 == 1, 未知这段代码有何用?;
	int nDllType[MAX_DLL_TYPE] = {0};
	for( int i = 0; i < MAX_DLL_TYPE; i++ )
	{
		nDllType[i] = 0;					// ?未知该变量意义 ;
		g_hRequestDataThread[i] = NULL;		// 线程句柄; 
		g_strPort[i] = "";					// 通信端口;
	}
#endif


	/************************************************************************/
		/* 
		0.循环所有设备->next;
		1.判断设备类型->next;
		2.打开串口 ->next;
		3.判断是否使用->next;
		4.创建串口线程->end; 
		*/
	/************************************************************************/
	int iVarCount = 0;  // 存储所有变量总数;
	// 遍历所有设备,创建对应串口线程,进行设备采集;
	int nBaudRate, nDataBit;
	for( int i = 0; i < iSize; i++ )
	{
		CDevice *pDev = g_pDevicesManager->m_Devices[i];

		char chDllName[MAX_PATH] = {0};
		char szIniName[MAX_PATH] = {0};

		strcpy(chDllName, (char *)(LPCTSTR)pDev->m_strProtocoldllname);
		strcpy(szIniName, (char *)(LPCTSTR)pDev->m_strIniName);

		StrLower(chDllName,chDllName);
		StrLower(szIniName, szIniName);

		//LOG4C((LOG_NOTICE, "Devive = %s, IniName = %s", pDev->m_strDeviceName, szIniName));

		nBaudRate = GetCommRate( pDev->m_iBaudrate );

		nDataBit = GetCommDataBit( pDev->m_iDatabit );

		iVarCount += pDev->m_Vars.GetSize();

		/************************************************************************/
		/* 
		1.判断设备类型->next;
		2.打开串口 ->next;
		3.判断是否使用->next;
		4.创建串口线程->end; 
		*/
		/************************************************************************/
		// == 0 RTU设备;
		if( pDev->m_bySpecialdevice == 0 )
		{
			if (!InitRtuComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,	nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
				pDev->m_bCommStatus = FALSE;	// 打开串口失败;
			else
				pDev->m_bCommStatus = TRUE;		// 打开串口成功;

			// 如果该 设备变量个数大于0,进行数据采集,创建线程;
			if( pDev->m_Vars.GetSize() >= 1 )
			{
				DWORD dwThreadId;
				CString strPort;
				strPort.Format("%d", pDev->m_iPort);

				// 判断串口是否已经使用(是否存在数组里),未使用继续执行代码;
				if( FALSE == FindRtuCommPort(strPort) )
				{
					g_strPort[g_nRtuThreadIndex] = strPort;
					if( g_hRequestDataThread[g_nRtuThreadIndex] == NULL )
					{
						// 一个串口一个线程;
						MTVERIFY( g_hRequestDataThread[g_nRtuThreadIndex] = 
								CreateThread(	
										NULL, 
										0, 
										(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
										(char *)(LPCTSTR)g_strPort[g_nRtuThreadIndex], 
										0, 
										&dwThreadId) );
						g_nRtuThreadIndex++;
					}
				}
			}
		}
		// == 1,ASC设备;
		else if( pDev->m_bySpecialdevice == 1 )
		{
			if (!InitAscComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
				nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
			{
				LOG4C((LOG_NOTICE, "device name:%s open com%d lost！", pDev->m_strDeviceName,pDev->m_iPort));
				pDev->m_bCommStatus = FALSE;
			}
			else
			{
				LOG4C((LOG_NOTICE, "device name:%s open com%d success！", pDev->m_strDeviceName,pDev->m_iPort));
				pDev->m_bCommStatus = TRUE;
			}

			if( pDev->m_Vars.GetSize() >= 1 )
			{
				CString strPort;
				strPort.Format("%d", pDev->m_iPort);
				if( FALSE == FindAscCommPort(strPort) )
				{
					g_strPort[g_nAscThreadIndex].Format("%d", pDev->m_iPort);
					DWORD dwThreadId;
					MTVERIFY( g_hRequestDataThread[g_nAscThreadIndex] = 
							CreateThread(	
									NULL, 
									0, 
									(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
									(char *)(LPCTSTR)g_strPort[g_nAscThreadIndex], 
									0, 
									&dwThreadId) );

					g_nAscThreadIndex++;
				}
			}
		}
		// == 2,网络设备;
		else if( pDev->m_bySpecialdevice == 2 )
		{
			if (!InitTcpNet(pDev->m_iDevideaddr, pDev->m_iIpport, (char *)(LPCTSTR)pDev->m_strIp))
			{
				LOG4C((LOG_NOTICE, "device name:%s open com%d lost！", pDev->m_strDeviceName,pDev->m_iPort));
				pDev->m_bCommStatus = FALSE;			
			}
			else
			{
				LOG4C((LOG_NOTICE, "device name:%s open com%d success！", pDev->m_strDeviceName,pDev->m_iPort));
				pDev->m_bCommStatus = TRUE;
			}

			if( pDev->m_Vars.GetSize() >= 1 )
			{
				DWORD dwThreadId;
				MTVERIFY( g_hRequestDataThread[g_nTcpThreadIndex] = 
						CreateThread(	
								NULL, 
								0, 
								(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
								(char *)(LPCTSTR)pDev->m_strUid, 
								0, 
								&dwThreadId) );

				g_tcpThreadStruct[g_nTcpThreadStructIndex].nTcpTheadIndex = g_nTcpThreadIndex;
				g_tcpThreadStruct[g_nTcpThreadStructIndex].strUid = pDev->m_strUid;

				g_nTcpThreadStructIndex++;
				g_nTcpThreadIndex++;
			}
		}
		else if( pDev->m_bySpecialdevice == 3 )
		{
			int iPingResult = 0;
			// ping 10 次，如果都是timeout, 认为设备已断线
			for( int iPingIndex = 0; iPingIndex <  10; iPingIndex++ )
			{
				if( Ping(2000, pDev->m_strIp) == 0 )
				{
					iPingResult = 0;
					break;
				}
				else
				{
					iPingResult = 1;
				}
			}

			if( 1 == iPingResult )   // 设备已断线
			{
				pDev->m_bCommStatus = FALSE;					
			}
			else
			{
				pDev->m_bCommStatus = TRUE;
			}

			if( pDev->m_Vars.GetSize() >= 1 )
			{
				DWORD dwThreadId;
				MTVERIFY( g_hRequestDataThread[g_nSnmpThreadIndex] = 
						CreateThread(	
								NULL, 
								0, 
								(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
								(char *)(LPCTSTR)pDev->m_strUid, 
								0, 
								&dwThreadId) );

				g_nSnmpThreadIndex++; 
			}
		}
		else if( pDev->m_bySpecialdevice == 4 )
		{
			if ( strcmp(chDllName, "icpdas.dll") == 0 )
			{
				if (!InitIcpdasComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
									nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
				{
					LOG4C((LOG_NOTICE, "device name:%s, port:%d, addr=%d, baudrate=%d, databit=%d, stopbit=%d, paritybit=%d open com lost！", 
						pDev->m_strDeviceName, pDev->m_iPort, pDev->m_iDevideaddr, nBaudRate, nDataBit, pDev->m_iStopbit, pDev->m_iParitybit));
					pDev->m_bCommStatus = FALSE;		
				}
				else
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d success！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = TRUE;
				}

				CString strPort;
				strPort.Format("%d", pDev->m_iPort);
				if( FALSE == FindIcpdasCommPort(strPort) )
				{
					g_strPort[g_nIcpdasIndex].Format("%d", pDev->m_iPort);
					if( pDev->m_Vars.GetSize() >= 1 )
					{
						//LOG4C((LOG_NOTICE, "create thread by hg module port = com%s", g_strPort[g_nIcpdasIndex] ));
						DWORD dwThreadId;
						MTVERIFY( g_hRequestDataThread[g_nIcpdasIndex] = 
								CreateThread(	
										NULL, 
										0, 
										(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
										(char *)(LPCTSTR)g_strPort[g_nIcpdasIndex], 
										0, 
										&dwThreadId) );

						g_nIcpdasIndex++;
					}
				}
			}
			else if ( strcmp(chDllName, "upsparadigm.dll") == 0 ) 
			{
				if (!InitParadigmComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
									nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d lost！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = FALSE;					
				}
				else
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d success！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = TRUE;
				}

				CString strPort;
				strPort.Format("%d", pDev->m_iPort);
				if( FALSE == FindParadigmCommPort(strPort) )
				{
					g_strPort[g_nParadigmIndex].Format("%d", pDev->m_iPort);
					if( pDev->m_Vars.GetSize() >= 1 )
					{
						DWORD dwThreadId;
						MTVERIFY( g_hRequestDataThread[g_nParadigmIndex] = 
								CreateThread(	
										NULL, 
										0, 
										(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
										(char *)(LPCTSTR)g_strPort[g_nParadigmIndex], 
										0, 
										&dwThreadId) );

						g_nParadigmIndex++;
					}
				}
			}
			else if ( strcmp(chDllName, "stulz.dll") == 0 ) 
			{
				if (!InitStulzComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
									nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d lost！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = FALSE;				
				}
				else
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d success！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = TRUE;
				}

				CString strPort;
				strPort.Format("%d", pDev->m_iPort);
				if( FALSE == FindStulzCommPort(strPort) )
				{
					g_strPort[g_nStulzIndex].Format("%d", pDev->m_iPort);
					if( pDev->m_Vars.GetSize() >= 1 )
					{
						DWORD dwThreadId;
						MTVERIFY( g_hRequestDataThread[g_nStulzIndex] = 
								CreateThread(	
										NULL, 
										0, 
										(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
										(char *)(LPCTSTR)g_strPort[g_nStulzIndex], 
										0, 
										&dwThreadId) );

						g_nStulzIndex++;
					}
				}
			}
			else if ( strcmp(chDllName, "daikin.dll") == 0 ) 
			{
				if( !InitDaiKinComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
					nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000) )
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d lost！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = FALSE;
				}
				else
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d success！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = TRUE;
				}

				CString strPort;
				strPort.Format("%d", pDev->m_iPort);
				if( FALSE == FindDaiKinCommPort(strPort) )
				{
					g_strPort[g_nDaiKinIndex].Format("%d", pDev->m_iPort);
					if( pDev->m_Vars.GetSize() >= 1 )
					{
						DWORD dwThreadId;
						MTVERIFY( g_hRequestDataThread[g_nDaiKinIndex] = 
								CreateThread(	
										NULL, 
										0, 
										(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
										(char *)(LPCTSTR)g_strPort[g_nDaiKinIndex], 
										0, 
										&dwThreadId) );

						g_nDaiKinIndex++;
					}
				}
			}
			else if ( strcmp(chDllName, "powerware.dll") == 0 ) 
			{
				if( !InitPowerwareComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
					nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000) )
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d lost！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = FALSE;
				}
				else
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d success！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = TRUE;
				}

				CString strPort;
				strPort.Format("%d", pDev->m_iPort);
				if( FALSE == FindPowerwareCommPort(strPort) )
				{
					g_strPort[g_nPowerwareIndex].Format("%d", pDev->m_iPort);
					if( pDev->m_Vars.GetSize() >= 1 )
					{
						DWORD dwThreadId;
						MTVERIFY( g_hRequestDataThread[g_nPowerwareIndex] = 
								CreateThread(	
										NULL, 
										0, 
										(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
										(char *)(LPCTSTR)g_strPort[g_nPowerwareIndex], 
										0, 
										&dwThreadId) );

						g_nPowerwareIndex++;
					}
				}
			}
			else if ( strcmp(chDllName, "gree.dll") == 0 ) 
			{
				if (!InitGreeComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
					nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d lost！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = FALSE;
				}
				else
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d success！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = TRUE;
				}

				CString strPort;
				strPort.Format("%d", pDev->m_iPort);
				if( FALSE == FindGreeCommPort(strPort) )
				{
					g_strPort[g_nGreeIndex].Format("%d", pDev->m_iPort);
					if( pDev->m_Vars.GetSize() >= 1 )
					{
						DWORD dwThreadId;
						MTVERIFY( g_hRequestDataThread[g_nGreeIndex] = 
								CreateThread(	
										NULL, 
										0, 
										(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
										(char *)(LPCTSTR)g_strPort[g_nGreeIndex], 
										0, 
										&dwThreadId) );

						g_nGreeIndex++; 
					}
				}
			}
			else if ( strcmp(chDllName, "carel.dll") == 0 ) 
			{
				if (!InitCarelComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
					nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d lost！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = FALSE;
				}
				else
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d success！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = TRUE;
				}

				CString strPort;
				strPort.Format("%d", pDev->m_iPort);
				if( FALSE == FindCarelCommPort(strPort) )
				{
					g_strPort[g_nCarelIndex].Format("%d", pDev->m_iPort);
					if( pDev->m_Vars.GetSize() >= 1 )
					{
						DWORD dwThreadId;
						MTVERIFY( g_hRequestDataThread[g_nCarelIndex] = 
								CreateThread(	
										NULL, 
										0, 
										(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
										(char *)(LPCTSTR)g_strPort[g_nCarelIndex], 
										0, 
										&dwThreadId) );

						g_nCarelIndex++;
					}
				}
			}
			else if( strcmp( chDllName, "scantak_3c.dll" ) == 0 )
			{
				if (!InitSeparateComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
					nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d lost！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = FALSE;
				}
				else
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d success！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = TRUE;
				}

				CString strPort;
				strPort.Format("%d", pDev->m_iPort);
				if( FALSE == FindScanTakCommPort(strPort) )
				{
					g_strPort[g_nScantakIndex].Format("%d", pDev->m_iPort);
					if( pDev->m_Vars.GetSize() >= 1 )
					{
						DWORD dwThreadId;
						MTVERIFY( g_hRequestDataThread[g_nScantakIndex] = 
								CreateThread(	
										NULL, 
										0, 
										(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
										(char *)(LPCTSTR)g_strPort[g_nScantakIndex], 
										0, 
										&dwThreadId) );

						g_nScantakIndex++;
					}
				}
			}
			else if( strcmp( chDllName, "delta.dll" ) == 0 )
			{
				if (!InitSeparateComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
					nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d lost！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = FALSE;
				}
				else
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d success！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = TRUE;
				}

				CString strPort;
				strPort.Format("%d", pDev->m_iPort);
				if( FALSE == FindDeltaCommPort(strPort) )
				{
					g_strPort[g_nDeltaIndex].Format("%d", pDev->m_iPort);
					if( pDev->m_Vars.GetSize() >= 1 )
					{
						DWORD dwThreadId;
						MTVERIFY( g_hRequestDataThread[g_nDeltaIndex] = 
								CreateThread(	
										NULL, 
										0, 
										(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
										(char *)(LPCTSTR)g_strPort[g_nDeltaIndex], 
										0, 
										&dwThreadId) );

						g_nDeltaIndex++;
					}
				}
			}
			else if ( strcmp(szIniName, "upsuh31.ini") == 0 ||
				strcmp(szIniName, "emerson_cm.ini") == 0 ||
				strcmp(szIniName, "dme3000.ini") == 0 ||
				strcmp(szIniName, "paradigm200a_rectifier.ini") == 0 ||
				strcmp(szIniName, "paradigm200a_inverter.ini") == 0 ||
				strcmp(szIniName, "paradigm200b.ini") == 0 ||
				strcmp(szIniName, "hipulseigmnet.ini") == 0 ||
				strcmp(szIniName, "hipulsecdt.ini") == 0 ||
				strcmp(szIniName, "prostar.ini") == 0 ||
				strcmp(szIniName, "joton.ini") == 0 ||
				strcmp(szIniName, "hiross.ini") == 0 ||
				strcmp(szIniName, "upslink.ini") == 0 ||
				strcmp(szIniName, "upsapcsilcon.ini") == 0 ||
				strcmp(szIniName, "ul33.ini") == 0 || 
				strcmp(szIniName, "hipulse_u.ini") == 0 || 
				strcmp(szIniName, "kehua.ini") == 0 || 
				strcmp(szIniName, "secups.ini") == 0 ||
				strcmp(szIniName, "upsuh11.ini") == 0 ||
                strcmp(szIniName, "weibo.ini") == 0 ||
                strcmp(szIniName, "sda_ii.ini") == 0 ||
				strcmp(szIniName, "daikin.ini") == 0 ||
				strcmp(szIniName, "scantak_3c.ini") == 0 ||
				strcmp(szIniName, "delta.ini") == 0 ||
				strcmp(szIniName, "m84c5z.ini") == 0 ||
				strcmp(szIniName, "upsnxr.ini") == 0 ||
				strcmp(szIniName, "batteryadu.ini") == 0 ||
				strcmp(szIniName, "upsmonitorlan.ini") == 0 ||
				strcmp(szIniName, "sk6000.ini") == 0 ||
				strcmp(szIniName, "batteryadu2000.ini") == 0 ||
				strcmp(szIniName, "santak_shiwei.ini") == 0 ||
				strcmp(szIniName, "santak_q4.ini") == 0 ||
				strcmp(szIniName, "ups_nxl.ini") == 0 ||
				strcmp(szIniName, "twoul33.ini") == 0 ||
				strcmp(szIniName, "oumai.ini") == 0 ||
				strcmp(szIniName, "santak_3a3120ks.ini") == 0 ||
				strcmp(szIniName, "tmaster.ini") == 0  ||
				strcmp(szIniName, "st_6c20ks.ini") == 0 ||
				strcmp(szIniName, "ea800.ini") == 0 ||
				strcmp(szIniName, "jb1501a64p.ini") == 0||
				strcmp(szIniName, "st_3c340ks.ini") == 0||
				strcmp(szIniName, "delta_v1.54.ini") == 0||
				strcmp(szIniName, "icp_i7017.ini") == 0 ||
				strcmp(szIniName, "fad.ini") == 0 ||
				strcmp(szIniName, "itrustadapt.ini" ) == 0  ||
				strcmp(szIniName, "uha3r_0200l.ini") == 0)
			{
				//LOG4C((LOG_NOTICE, "Enter InitMostDeviceComm szIniName = %s", szIniName));
				if (!InitMostDeviceComm(g_strDirectory,  szIniName, pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
					nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d lost！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = FALSE;
				}
				else
				{
					LOG4C((LOG_NOTICE, "device name:%s open com%d success！", pDev->m_strDeviceName,pDev->m_iPort));
					pDev->m_bCommStatus = TRUE;
				}

				//LOG4C((LOG_NOTICE, "Leave InitMostDeviceComm szIniName = %s", szIniName));
				CString strPort;
				strPort.Format("%d", pDev->m_iPort);
				if( FALSE == FindMostDeviceCommPort(strPort) )
				{
					g_strPort[g_nMostDeviceIndex].Format("%d", pDev->m_iPort);
					if( pDev->m_Vars.GetSize() >= 1 )
					{
						DWORD dwThreadId;
						MTVERIFY( g_hRequestDataThread[g_nMostDeviceIndex] = 
								CreateThread(	
										NULL, 
										0, 
										(LPTHREAD_START_ROUTINE)RequestDataThreadProc, 
										(char *)(LPCTSTR)g_strPort[g_nMostDeviceIndex], 
										0, 
										&dwThreadId) );

						g_nMostDeviceIndex++;
					}
				}
			}
			else if ( 0 == strcmp(szIniName, "stu2000.dll") )
			{
			}
		}
	}

	LOG4C((LOG_NOTICE, "iVarCount = %d", iVarCount));
	// 每MAX_SINGLE_TCP_VAR_NUM个变量，建立一个监听端口
#if 0
	int nSocketIndex = 1;
	if( iVarCount > MAX_SINGLE_TCP_VAR_NUM )
	{
		while( iVarCount / (nSocketIndex  * MAX_SINGLE_TCP_VAR_NUM) != 0 )
		{
			if( NULL == g_pServerSocket[nSocketIndex] )
			{
				g_pServerSocket[nSocketIndex] = new CServerSocket();
				CString strPort;
				strPort.Format("%d", SOCKET_SERVER_PORT + nSocketIndex);
				LOG4C((LOG_NOTICE, "Create Port %s success", strPort));
				g_pServerSocket[nSocketIndex]->SvrStart(strPort);
				nSocketIndex++;
			}
		}
	}
#else
	int nSocketIndex = 1;
	
	if( NULL == g_pServerSocket[nSocketIndex] )
	{
		g_pServerSocket[nSocketIndex] = new CServerSocket();
		CString strPort;
		strPort.Format("%d", SOCKET_SERVER_PORT + nSocketIndex);
		LOG4C((LOG_NOTICE, "Create Port %s success", strPort));
		g_pServerSocket[nSocketIndex]->SvrStart(strPort);
	}
#endif

	// 实时监控设备是否在线;
	if( g_hDevOnlineThread == NULL )
	{
		DWORD dwThreadId;
		MTVERIFY( g_hDevOnlineThread = 	CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)DevOnlineThreadProc, 0, 0, &dwThreadId) );
	}

	// 实时监控,超时值外设备断开进行重连;
	if( g_hReConnectCommThread == NULL )
	{
		DWORD dwThreadId;
		MTVERIFY( g_hReConnectCommThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ReConnectCommThreadProc, NULL, 0, &dwThreadId) );
	}

	// 定时发送系统正常运行短信;
	if( g_hTimingSendSmsThread == NULL )
	{
		DWORD dwThreadId;
		if( g_nSendSms==1 || g_nSendNotice==1 )
		{
			MTVERIFY( g_hTimingSendSmsThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)TimingSendSmsThread, NULL, 0, &dwThreadId) );
		}
	}

	// 实时监控报警,发送报警信息;
	if( g_hVoiceNoticeThread == NULL )
	{
		DWORD dwThreadId;
		MTVERIFY( g_hVoiceNoticeThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)VoiceNoticeThreadProc, NULL, 0, &dwThreadId) );
	}

	// 对外输出,供第三方使用;
	if( g_hOutputThread == NULL )
	{
		if( 1 == g_nOutputEnable )
		{
			DWORD dwThreadId;
			MTVERIFY( g_hOutputThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)OutputThreadProc, NULL, 0, &dwThreadId) );
		}
	}

	// 时间计划;
	if( g_hGetDatePlanThread == NULL )
	{
		DWORD dwThreadId;
		MTVERIFY( g_hGetDatePlanThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)GetDatePlanThreadProc, NULL, 0, &dwThreadId) );
	}

	return 0;
}

void EndMain()
{
#if IS_USER_MUL_THREAD_REQUEST
	for( int i = 0; i < MAX_DLL_TYPE; i++ )
	{
		if (NULL != g_hRequestDataThread[i])
		{
			MTVERIFY( WaitForSingleObject( g_hRequestDataThread[i], INFINITE ) != WAIT_FAILED );
			MTVERIFY( CloseHandle( g_hRequestDataThread[i] ) );
			g_hRequestDataThread[i] = NULL;
		}
	}
#else
	if (NULL != g_hRequestDataThread)
	{
		MTVERIFY( WaitForSingleObject( g_hRequestDataThread, INFINITE ) != WAIT_FAILED );
		MTVERIFY( CloseHandle( g_hRequestDataThread ) );
		g_hRequestDataThread = NULL;
	}
#endif

	if( NULL != g_hDevOnlineThread )
	{
		MTVERIFY( WaitForSingleObject( g_hDevOnlineThread, INFINITE ) != WAIT_FAILED );
		MTVERIFY( CloseHandle( g_hDevOnlineThread ) );
		g_hDevOnlineThread = NULL;
	}

	if( NULL != g_hReConnectCommThread )
	{
		MTVERIFY( WaitForSingleObject( g_hReConnectCommThread, INFINITE ) != WAIT_FAILED );
		MTVERIFY( CloseHandle( g_hReConnectCommThread ) );
		g_hReConnectCommThread = NULL;
	}

	if( g_hTimingSendSmsThread != NULL )
	{
		MTVERIFY( WaitForSingleObject( g_hTimingSendSmsThread, INFINITE ) != WAIT_FAILED );
		MTVERIFY( CloseHandle( g_hTimingSendSmsThread ) );
		g_hTimingSendSmsThread = NULL;
	}

	if( g_hVoiceNoticeThread != NULL )
	{
		MTVERIFY( WaitForSingleObject( g_hVoiceNoticeThread, INFINITE ) != WAIT_FAILED );
		MTVERIFY( CloseHandle( g_hVoiceNoticeThread ) );
		g_hVoiceNoticeThread = NULL;
	}

	if( 1 == g_nOutputEnable )
	{
		if( NULL != g_hOutputThread )
		{
			MTVERIFY( WaitForSingleObject( g_hOutputThread, INFINITE ) != WAIT_FAILED );
			MTVERIFY( CloseHandle( g_hOutputThread ) );
			g_hOutputThread = NULL;
		}
	}

	if( NULL != g_hGetDatePlanThread )
	{
		MTVERIFY( WaitForSingleObject( g_hGetDatePlanThread, INFINITE ) != WAIT_FAILED );
		MTVERIFY( CloseHandle( g_hGetDatePlanThread ) );
		g_hGetDatePlanThread = NULL;
	}

	DeleteCriticalSection( &g_csDevOnlineReadOneData );
}


//
// 以下12个动态库重连函数,均由线程ReConnectCommThreadProc调用;
// 参数是单个设备 ,当设备状态 = 断开时,以下重连函数执行;;
// 该函数是按变量进行采集.
BOOL ModbusRtuReConnectProc(CDevice *pDev)
{
	BOOL bResult = FALSE;	// 返回结果;
	char chMsg[80] = {0};
	SETBASEPARAM SetBasePara = {0};
	SetBasePara.nAddr = pDev->m_iDevideaddr;
	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	nVarSize = nVarSize<10 ? nVarSize : 10;
	for( int j = 0; j < nVarSize; j++ )
	{
		//if( j > 0 ) break;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue; // 变量 == 1 只写;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		SetBasePara.nRegNum = pBaseVar->m_iRegisterNum;
		SetBasePara.nStartAddr = pBaseVar->m_nRegStartAddr;
		SetBasePara.FuncCode = pBaseVar->m_iFuncID;

		if( pBaseVar->m_nVarTypeID >= SPECIAL_VAR_TYPE_MIN_ID && pBaseVar->m_nVarTypeID <= SPECIAL_VAR_TYPE_MAX_ID )	// 特殊变量
		{
			// RtuRequestSpecData不属于动态接口函数,是本服务的函数处理特殊变量;
			if (RtuRequestSpecData(SetBasePara, pBaseVar->m_iDataLen, pDev->m_iPort, pDev->m_iDevideaddr, 
				(char *)(LPCTSTR)pBaseVar->m_strVarUID, pBaseVar->m_nVarID, pBaseVar->m_nVarTypeID) == 0)
			{
				bResult = TRUE;
				break;
			}
		}
		else
		{
			// 动态库接口函数,处理一般变量;
			if (pRTU_DLLInit(pDev->m_iPort, pDev->m_iDevideaddr, SetBasePara, pBaseVar->m_iDataLen, chMsg)==0)//初始化设备DLL
			{
				bResult = TRUE;
				break;
			}
		}
	}

	return bResult;
}

BOOL ModbusAscReConnectProc(CDevice *pDev)
{
	BOOL bResult = FALSE;
	char chMsg[80] = {0};
	SETBASEPARAM SetBasePara = {0};
	SetBasePara.nAddr = pDev->m_iDevideaddr;
	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	nVarSize = nVarSize<10 ? nVarSize : 10;
	for( int j = 0; j < nVarSize; j++ )
	{
		//if( j > 0 ) break;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		SetBasePara.nRegNum = pBaseVar->m_iRegisterNum;
		SetBasePara.nStartAddr = pBaseVar->m_nRegStartAddr;
		SetBasePara.FuncCode = pBaseVar->m_iFuncID;

		if( pBaseVar->m_nVarTypeID >= SPECIAL_VAR_TYPE_MIN_ID && pBaseVar->m_nVarTypeID <= SPECIAL_VAR_TYPE_MAX_ID )	// 特殊变量
		{
			if (AscRequestSpecData((char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, pBaseVar->m_nVarTypeID) == 0)
			{
				bResult = TRUE;
				break;
			}

		}
		else
		{
			if(pASCDLLInit(pDev->m_iPort, pDev->m_iDevideaddr, SetBasePara, pBaseVar->m_iDataLen, chMsg)==0)//初始化设备DLL
			{
				bResult = TRUE;
				break;
			}
		}
	}

	return bResult;
}

BOOL SnmpReConnectProc(CDevice *pDev)
{
	BOOL bResult = FALSE;
	char chMsg[80] = {0};
	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	nVarSize = nVarSize<10 ? nVarSize : 10;
	for( int j = 0; j < nVarSize; j++ )
	{
		//if( j > 0 ) break;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		if( pSnmpDllGetValue )
		{
			//TRACE("变量值id=%d\r\n", pBaseVar->m_nVarID);
			int nRet = pSnmpDllGetValue((char *)(LPCTSTR)pDev->m_strIp, 
				(char *)(LPCTSTR)pBaseVar->m_strFields,
				(char *)(LPCTSTR)pBaseVar->m_strSnmpoi,
				chMsg);

			if( nRet == 0 )
			{
				bResult = TRUE;
				break;
			}
		}
	}

	return bResult;
}

BOOL IcpdasReConnectProc(CDevice *pDev)
{
	BOOL bResult = FALSE;
	char chMsg[80] = {0};
	SETBASEPARAM SetBasePara = {0};
	SetBasePara.nAddr = pDev->m_iDevideaddr;

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	nVarSize = nVarSize<10 ? nVarSize : 10;
	for( int j = 0; j < nVarSize; j++ )
	{
		//if( j > 0 ) break;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		SetBasePara.nRegNum = pBaseVar->m_iRegisterNum;
		SetBasePara.nStartAddr = pBaseVar->m_nRegStartAddr;
		SetBasePara.FuncCode = pBaseVar->m_iFuncID;

		if (IcpdasRequestData(j, SetBasePara, pBaseVar->m_iDataLen, pDev->m_iPort, pDev->m_iDevideaddr, 
			(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, (char *)(LPCTSTR)pBaseVar->m_strRs232cmd) == 0)
		{
			bResult = TRUE;
			break;
		}
	}

	return bResult;
}

BOOL ParadigmReConnectProc(CDevice *pDev)
{
	BOOL bResult = FALSE;
	char chMsg[80] = {0};

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	nVarSize = nVarSize<10 ? nVarSize : 10;
	for( int j = 0; j < nVarSize; j++ )
	{
		//if( j > 0 ) break;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		if (ParadigmRequestData(pDev->m_iPort, pDev->m_iDevideaddr, 
			(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, (char*)(LPCTSTR)pBaseVar->m_strRs232cmd) == 0)
		{
			bResult = TRUE;
			break;
		}
	}

	return bResult;
}

BOOL StulzReConnectProc(CDevice *pDev)
{
	BOOL bResult = FALSE;
	char chMsg[80] = {0};
	SETBASEPARAM SetBasePara = {0};
	SetBasePara.nAddr = pDev->m_iDevideaddr;

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	nVarSize = nVarSize<10 ? nVarSize : 10;
	for( int j = 0; j < nVarSize; j++ )
	{
		//if( j > 0 ) break;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		SetBasePara.nRegNum = pBaseVar->m_iRegisterNum;
		SetBasePara.nStartAddr = pBaseVar->m_nRegStartAddr;
		SetBasePara.FuncCode = pBaseVar->m_iFuncID;

		if (StulzRequestData(SetBasePara, pBaseVar->m_iDataLen, pDev->m_iPort, pDev->m_iDevideaddr, 
			(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, (char*)(LPCTSTR)pBaseVar->m_strRs232cmd) == 0)
		{
			bResult = TRUE;
			break;
		}
	}

	return bResult;
}

BOOL DaiKinReConnectProc(CDevice *pDev)
{
	BOOL bResult = FALSE;
	char chMsg[80] = {0};
	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	nVarSize = nVarSize<10 ? nVarSize : 10;
	for( int j = 0; j < nVarSize; j++ )
	{
		//if( j > 0 ) break;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		if (DaiKinRequestData(pDev->m_iPort, pDev->m_iDevideaddr, 
			(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, (char*)(LPCTSTR)pBaseVar->m_strRs232cmd) == 0)
		{
			bResult = TRUE;
			break;
		}
	}

	return bResult;
}

BOOL PowerwareReConnectProc(CDevice *pDev)
{
	BOOL bResult = FALSE;
	char chMsg[80] = {0};
	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	nVarSize = nVarSize<10 ? nVarSize : 10;
	for( int j = 0; j < nVarSize; j++ )
	{
		//if( j > 0 ) break;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		if (PowerwareRequestData(pDev->m_iPort, pDev->m_iDevideaddr, 
			(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, (char*)(LPCTSTR)pBaseVar->m_strRs232cmd) == 0)
		{
			bResult = TRUE;
			break;
		}
	}

	return bResult;
}

BOOL GreeReConnectProc(CDevice *pDev)
{
	BOOL bResult = FALSE;
	char chMsg[80] = {0};
	SETBASEPARAM SetBasePara = {0};
	SetBasePara.nAddr = pDev->m_iDevideaddr;

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	nVarSize = nVarSize<10 ? nVarSize : 10;
	for( int j = 0; j < nVarSize; j++ )
	{
		//if( j > 0 ) break;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		SetBasePara.nRegNum = pBaseVar->m_iRegisterNum;
		SetBasePara.nStartAddr = pBaseVar->m_nRegStartAddr;
		SetBasePara.FuncCode = pBaseVar->m_iFuncID;

		if (GreeRequestData(SetBasePara, pBaseVar->m_iDataLen, pDev->m_iPort, pDev->m_iDevideaddr, 
			(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, (char*)(LPCTSTR)pBaseVar->m_strRs232cmd) == 0)
		{
			bResult = TRUE;
			break;
		}
	}

	return bResult;
}

BOOL CarelReConnectProc(CDevice *pDev)
{
	BOOL bResult = FALSE;
	char chMsg[80] = {0};

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	nVarSize = nVarSize<10 ? nVarSize : 10;
	for( int j = 0; j < nVarSize; j++ )
	{
		//if( j > 0 ) break;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		if (CarelRequestData(pDev->m_iPort, pDev->m_iDevideaddr, 
								(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, 
								(char*)(LPCTSTR)pBaseVar->m_strRs232cmd) == 0)
		{
			bResult = TRUE;
			break;
		}
	}

	return bResult;
}

BOOL SeparateReConnectProc(CDevice *pDev)
{
	BOOL bResult = FALSE;
	char chMsg[80] = {0};

	char szIniName[MAX_PATH] = {0};
	strcpy(szIniName, (char *)(LPCTSTR)pDev->m_strIniName);
	StrLower(szIniName, szIniName);

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	nVarSize = nVarSize<10 ? nVarSize : 10;
	for( int j = 0; j < nVarSize; j++ )
	{
		//if( j > 0 ) break;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		if (SeparateRequestData(pDev->m_iPort, pDev->m_iDevideaddr, 
								(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, 
								(char*)(LPCTSTR)pBaseVar->m_strRs232cmd,
								szIniName) == 0)
		{
			bResult = TRUE;
			break;
		}
	}

	return bResult;
}

BOOL MostDeviceReConnectProc(CDevice *pDev)
{
	BOOL bResult = FALSE;
	char chMsg[80] = {0};

	char szIniName[MAX_PATH] = {0};
	strcpy(szIniName, (char *)(LPCTSTR)pDev->m_strIniName);
	StrLower(szIniName, szIniName);

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	nVarSize = nVarSize<10 ? nVarSize : 10;
	for( int j = 0; j < nVarSize; j++ )
	{
		//if( j > 1 ) break;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		if (MostDeviceRequestData(pDev->m_iPort, pDev->m_iDevideaddr, 
								(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, 
								(char*)(LPCTSTR)pBaseVar->m_strRs232cmd,
								szIniName) == 0)	
		{
			bResult = TRUE;
			break;
		}
	}

	return bResult;
}


//
int GetTcpThreadStructIndex(CString strUid)
{
	int nRet = -1;
	for( int i = 0; i < MAX_TCP_THREAD; i++ )
	{
		if( g_tcpThreadStruct[i].strUid.Compare(strUid) == 0 )
		{
			nRet = i;
			break;
		}
	}

	return nRet;
}

//
//以上13个函数,均由线程重连串口ReConnectCommThreadProc调用 ;
// 功能如下:
// 0.判断是否设备是否掉线,掉线则重连串口并采集;
// 1.每个类型设备,首先初始化.判断是否打开了该串口;
// 2.串口打开成功,进行数据采集,存储到变量和设备里;
DWORD WINAPI ReConnectCommThreadProc(void *Para)
{
	do
	{
		int iSize = (int)g_pDevicesManager->m_Devices.GetSize();
		int nBaudRate, nDataBit;
		for( int i = 0; i < iSize; i++ )
		{
			CDevice *pDev = g_pDevicesManager->m_Devices[i];

			char chDllName[MAX_PATH] = {0};
			char szIniName[MAX_PATH] = {0};

			strcpy(chDllName, (char *)(LPCTSTR)pDev->m_strProtocoldllname);
			strcpy(szIniName, (char *)(LPCTSTR)pDev->m_strIniName);

			StrLower(chDllName,chDllName);
			StrLower(szIniName, szIniName);

			nBaudRate = GetCommRate( pDev->m_iBaudrate );

			nDataBit = GetCommDataBit( pDev->m_iDatabit );

			if( pDev->m_bySpecialdevice == 0 )
			{
				// 设备连接状态 = FALSE 断开,进行重连串口;
				if( pDev->m_bCommStatus == FALSE )
				{
					// InitRtuComm初始串口函数 ,调用动态库接口函数进行初始化;
					if (!InitRtuComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,	nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
					{
						// 初始化失败,继续标识为断线;
						pDev->m_bCommStatus = FALSE;
					}
					else
					{
						// 成功初始化串口,进行数据采集操作;
						EnterCriticalSection( &g_csRtuReadOneData );

						// 进行数据的采集;抽取动态函数;
						pDev->m_bCommStatus = ModbusRtuReConnectProc(pDev);
						if( pDev->m_bCommStatus == TRUE )
						{
							LOG4C((LOG_NOTICE, "device name:%s open com success！", pDev->m_strDeviceName));
							pDev->m_dwOnlineTick = GetTickCount();
						}
						LeaveCriticalSection( &g_csRtuReadOneData );
					}
				}
			}
			else if( pDev->m_bySpecialdevice == 1 )
			{
				if( pDev->m_bCommStatus == FALSE )
				{
					if (!InitAscComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
						nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
					{
						pDev->m_bCommStatus = FALSE;
					}
					else
					{
						EnterCriticalSection( &g_csAscReadOneData );
						pDev->m_bCommStatus = ModbusAscReConnectProc(pDev);
						if( pDev->m_bCommStatus == TRUE )
						{
							LOG4C((LOG_NOTICE, "device name:%s open com success！", pDev->m_strDeviceName));
							pDev->m_dwOnlineTick = GetTickCount();
						}
						LeaveCriticalSection( &g_csAscReadOneData );
					}
				}
			}
			else if( pDev->m_bySpecialdevice == 2 )
			{
				if( pDev->m_bCommStatus == FALSE )
				{
					int iPingResult = 0;
					// ping 10 次，如果都是timeout, 认为设备已断线
					for( int iPingIndex = 0; iPingIndex <  10; iPingIndex++ )
					{
						if( Ping(2000, pDev->m_strIp) == 0 )
						{
							iPingResult = 0;
							break;
						}
						else
						{
							iPingResult = 1;
						}
					}

					if( 1 == iPingResult )   // 设备已断线
					{
				
					}
					else
					{
						if (!InitTcpNet(pDev->m_iDevideaddr, pDev->m_iIpport, (char *)(LPCTSTR)pDev->m_strIp))
						{
							EnterCriticalSection( &g_csTcpReadOneData );
							pDev->m_bCommStatus = FALSE;
							LeaveCriticalSection( &g_csTcpReadOneData );
						}
						else
						{
							EnterCriticalSection( &g_csTcpReadOneData );
							pDev->m_dwOnlineTick = GetTickCount();
							pDev->m_bCommStatus = TRUE;
							LeaveCriticalSection( &g_csTcpReadOneData );

							int nIndex = GetTcpThreadStructIndex( pDev->m_strUid );
							if( nIndex != -1 )
							{
								if( g_hRequestDataThread[ g_tcpThreadStruct[nIndex].nTcpTheadIndex ] != NULL )
								{
									ResumeThread( g_hRequestDataThread[ g_tcpThreadStruct[nIndex].nTcpTheadIndex ] );
								}
							}
						}
					}
				}
			}
			else if( pDev->m_bySpecialdevice == 3 )
			{
				// 循环所有变量
				if( pDev->m_bCommStatus == FALSE )
				{
					int iPingResult = 0;
					// ping 10 次，如果都是timeout, 认为设备已断线
					for( int iPingIndex = 0; iPingIndex <  10; iPingIndex++ )
					{
						if( Ping(2000, pDev->m_strIp) == 0 )
						{
							iPingResult = 0;
							break;
						}
						else
						{
							iPingResult = 1;
						}
					}

					if( 1 == iPingResult )   // 设备已断线
					{
				
					}
					else
					{
						EnterCriticalSection( &g_csIcpdasReadOneData );
						pDev->m_dwOnlineTick = GetTickCount();
						pDev->m_bCommStatus = TRUE;
						LeaveCriticalSection( &g_csIcpdasReadOneData );
					}
				}
			}
			else if( pDev->m_bySpecialdevice == 4 )
			{
				if ( strcmp(chDllName, "icpdas.dll") == 0 ) 
				{
					if( pDev->m_bCommStatus == FALSE )
					{
						if (!InitIcpdasComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
											nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
						{
							pDev->m_bCommStatus = FALSE;		
						}
						else
						{
							EnterCriticalSection( &g_csIcpdasReadOneData );
							pDev->m_bCommStatus = IcpdasReConnectProc(pDev);
							if( pDev->m_bCommStatus == TRUE )
							{
								LOG4C((LOG_NOTICE, "device name:%s open com success！", pDev->m_strDeviceName));
								pDev->m_dwOnlineTick = GetTickCount();
							}
							LeaveCriticalSection( &g_csIcpdasReadOneData );
						}
					}
				}
				else if ( strcmp(chDllName, "upsparadigm.dll") == 0 ) 
				{
					if( pDev->m_bCommStatus == FALSE )
					{
						if (!InitParadigmComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
											nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
						{
							pDev->m_bCommStatus = FALSE;					
						}
						else
						{
							EnterCriticalSection( &g_csParadigmReadOneData );
							pDev->m_bCommStatus = ParadigmReConnectProc(pDev);
							if( pDev->m_bCommStatus == TRUE )
							{
								LOG4C((LOG_NOTICE, "device name:%s open com success！", pDev->m_strDeviceName));
								pDev->m_dwOnlineTick = GetTickCount();
							}
							LeaveCriticalSection( &g_csParadigmReadOneData );
						}
					}
				}
				else if ( strcmp(chDllName, "stulz.dll") == 0 ) 
				{
					if( pDev->m_bCommStatus == FALSE )
					{
						if (!InitStulzComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
											nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
						{
							pDev->m_bCommStatus = FALSE;				
						}
						else
						{
							EnterCriticalSection( &g_csStulzReadOneData );
							pDev->m_bCommStatus = StulzReConnectProc(pDev);
							if( pDev->m_bCommStatus == TRUE )
							{
								LOG4C((LOG_NOTICE, "device name:%s open com success！", pDev->m_strDeviceName));
								pDev->m_dwOnlineTick = GetTickCount();
							}
							LeaveCriticalSection( &g_csStulzReadOneData );
						}
					}
				}
				else if ( strcmp(chDllName, "daikin.dll") == 0 ) 
				{
					if( pDev->m_bCommStatus == FALSE )
					{
						if( !InitDaiKinComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
							nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000) )
						{
							pDev->m_bCommStatus = FALSE;
						}
						else
						{
							EnterCriticalSection( &g_csDaiKinReadOneData );
							pDev->m_bCommStatus = DaiKinReConnectProc(pDev);
							if( pDev->m_bCommStatus == TRUE )
							{
								LOG4C((LOG_NOTICE, "device name:%s open com success！", pDev->m_strDeviceName));
								pDev->m_dwOnlineTick = GetTickCount();
							}
							LeaveCriticalSection( &g_csDaiKinReadOneData );
						}
					}
				}
				else if ( strcmp(chDllName, "powerware.dll") == 0 )
				{
					if( pDev->m_bCommStatus == FALSE )
					{
						if( !InitPowerwareComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
							nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000) )
						{
							pDev->m_bCommStatus = FALSE;
						}
						else
						{
							EnterCriticalSection( &g_csPowerwareReadOneData );
							pDev->m_bCommStatus = PowerwareReConnectProc(pDev);
							if( pDev->m_bCommStatus == TRUE )
							{
								LOG4C((LOG_NOTICE, "device name:%s open com success！", pDev->m_strDeviceName));
								pDev->m_dwOnlineTick = GetTickCount();
							}
							LeaveCriticalSection( &g_csPowerwareReadOneData );
						}
					}
				}
				else if ( strcmp(chDllName, "gree.dll") == 0 ) 
				{
					if (pDev->m_bCommStatus == FALSE)
					{
						if (!InitGreeComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
							nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
						{
							pDev->m_bCommStatus = FALSE;
						}
						else
						{
							EnterCriticalSection(&g_csGreeReadOneData);
							pDev->m_bCommStatus = GreeReConnectProc(pDev);
							if( pDev->m_bCommStatus == TRUE )
							{
								LOG4C((LOG_NOTICE, "device name:%s open com success！", pDev->m_strDeviceName));
								pDev->m_dwOnlineTick = GetTickCount();
							}
							LeaveCriticalSection(&g_csGreeReadOneData);
						}
					}
				}
				else if ( strcmp(chDllName, "carel.dll") == 0 )
				{
					if (pDev->m_bCommStatus == FALSE)
					{
						if (!InitCarelComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
							nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
						{
							pDev->m_bCommStatus = FALSE;
						}
						else
						{
							EnterCriticalSection(&g_csCarelReadOneData);
							pDev->m_bCommStatus = CarelReConnectProc(pDev);
							if( pDev->m_bCommStatus == TRUE )
							{
								LOG4C((LOG_NOTICE, "device name:%s open com success！", pDev->m_strDeviceName));
								pDev->m_dwOnlineTick = GetTickCount();
							}
							LeaveCriticalSection(&g_csCarelReadOneData);
						}
					}
				}
				else if ( strcmp(chDllName, "scantak_3c.dll") == 0 )
				{
					if (pDev->m_bCommStatus == FALSE)
					{
						if (!InitSeparateComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
							nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
						{
							pDev->m_bCommStatus = FALSE;
						}
						else
						{
							EnterCriticalSection(&g_csSeparateReadOneData);
							pDev->m_bCommStatus = SeparateReConnectProc(pDev);
							if( pDev->m_bCommStatus == TRUE )
							{
								LOG4C((LOG_NOTICE, "device name:%s open com success！", pDev->m_strDeviceName));
								pDev->m_dwOnlineTick = GetTickCount();
							}
							LeaveCriticalSection(&g_csSeparateReadOneData);
						}
					}
				}
				else if ( strcmp(chDllName, "delta.dll") == 0 )
				{
					if (pDev->m_bCommStatus == FALSE)
					{
						if (!InitSeparateComm(pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
							nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
						{
							pDev->m_bCommStatus = FALSE;
						}
						else
						{
							EnterCriticalSection(&g_csSeparateReadOneData);
							pDev->m_bCommStatus = SeparateReConnectProc(pDev);
							if( pDev->m_bCommStatus == TRUE )
							{
								LOG4C((LOG_NOTICE, "device name:%s open com success！", pDev->m_strDeviceName));
								pDev->m_dwOnlineTick = GetTickCount();
							}
							LeaveCriticalSection(&g_csSeparateReadOneData);
						}
					}
				}
				else if ( strcmp(szIniName, "upsuh31.ini") == 0 ||
					strcmp(szIniName, "emerson_cm.ini") == 0 ||
					strcmp(szIniName, "dme3000.ini") == 0 ||
					strcmp(szIniName, "paradigm200a_rectifier.ini") == 0 ||
					strcmp(szIniName, "paradigm200a_inverter.ini") == 0 ||
					strcmp(szIniName, "paradigm200b.ini") == 0 ||
					strcmp(szIniName, "hipulseigmnet.ini") == 0 ||
					strcmp(szIniName, "hipulsecdt.ini") == 0 ||
					strcmp(szIniName, "prostar.ini") == 0 ||
					strcmp(szIniName, "joton.ini") == 0 ||
					strcmp(szIniName, "hiross.ini") == 0 ||
					strcmp(szIniName, "upslink.ini") == 0 ||
					strcmp(szIniName, "upsapcsilcon.ini") == 0 ||
					strcmp(szIniName, "ul33.ini") == 0 || 
					strcmp(szIniName, "hipulse_u.ini") == 0 || 
					strcmp(szIniName, "kehua.ini") == 0 || 
					strcmp(szIniName, "secups.ini") == 0 ||
					strcmp(szIniName, "upsuh11.ini") == 0 ||
                    strcmp(szIniName, "weibo.ini") == 0 ||
                    strcmp(szIniName, "sda_ii.ini") == 0 ||
					strcmp(szIniName, "daikin.ini") == 0 ||
					strcmp(szIniName, "scantak_3c.ini") == 0 ||
					strcmp(szIniName, "delta.ini") == 0 ||
					strcmp(szIniName, "m84c5z.ini") == 0 ||
					strcmp(szIniName, "upsnxr.ini") == 0 ||
					strcmp(szIniName, "batteryadu.ini") == 0 ||
					strcmp(szIniName, "upsmonitorlan.ini") == 0 ||
					strcmp(szIniName, "sk6000.ini") == 0 ||
					strcmp(szIniName, "batteryadu2000.ini") == 0 ||
					strcmp(szIniName, "santak_shiwei.ini") == 0 || 
					strcmp(szIniName, "santak_q4.ini") == 0 ||
					strcmp(szIniName, "ups_nxl.ini") == 0 ||
					strcmp(szIniName, "twoul33.ini") == 0 ||
					strcmp(szIniName, "oumai.ini") == 0 ||
					strcmp(szIniName, "santak_3a3120ks.ini") == 0 ||
					strcmp(szIniName, "tmaster.ini") == 0 ||
					strcmp(szIniName, "st_6c20ks.ini") == 0||
					strcmp(szIniName, "ea800.ini") == 0 ||
					strcmp(szIniName, "jb1501a64p.ini") == 0||
					strcmp(szIniName, "st_3c340ks.ini") == 0||
					strcmp(szIniName, "delta_v1.54.ini") == 0||
					strcmp(szIniName, "icp_i7017.ini") == 0 ||
					strcmp(szIniName, "fad.ini") == 0 ||
					strcmp(szIniName, "itrustadapt.ini" ) == 0  ||
					strcmp(szIniName, "uha3r_0200l.ini") == 0)
				{
					if (pDev->m_bCommStatus == FALSE)
					{
						if (!InitMostDeviceComm(g_strDirectory,  szIniName, pDev->m_iDevideaddr, pDev->m_iPort, nBaudRate,
							nDataBit, pDev->m_iStopbit, pDev->m_iParitybit, 1000))
						{
							pDev->m_bCommStatus = FALSE;
						}
						else
						{
							EnterCriticalSection(&g_csMostDeviceReadOneData);
							pDev->m_bCommStatus = MostDeviceReConnectProc(pDev);
							if( pDev->m_bCommStatus == TRUE )
							{
								LOG4C((LOG_NOTICE, "device name:%s open com success！", pDev->m_strDeviceName));
								pDev->m_dwOnlineTick = GetTickCount();
							}
							LeaveCriticalSection(&g_csMostDeviceReadOneData);		
						}				
					}
				}
			}
		}
		Sleep(100);  //chn add
	}while( WaitForSingleObject( g_hRunObject, 1250L ) == WAIT_TIMEOUT );

	return 0;
}

//
// 设备是否在线判断线程;
// 1.网络设备通过ping函数来判断是否在线;
// 2.串口设备通过采集数据的超时值来判断是否在线(每个设备都一个超时变量);
DWORD WINAPI DevOnlineThreadProc(void *pPara)
{
	do
	{
		// 1.循环所有设备
		int nDeviceSize = g_pDevicesManager->m_Devices.GetSize();
		for( int i = 0; i < nDeviceSize; i++ )
		{
			CDevice *pDev = g_pDevicesManager->m_Devices[i];
			// 2.循环该设备变量
			int nVarSize = pDev->m_Vars.GetSize();
			for( int j = 0; j < nVarSize; j++ )
			{
				// 3.只判断设备变量中的内存变量(即设备通讯状态变量);
				CBaseVar *pBaseVar = pDev->m_Vars[j];
				if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID )		// 内存变量，判断设备是否在线
				{
					// 4.分别对网络和串口设备进行处理,设定条件成立则设备定义为通讯断线;
					if( pDev->m_bySpecialdevice == 2 || pDev->m_bySpecialdevice == 3 )		// 网络设备
					{
						int iPingResult = 0;
						// 4.1 网络设备ping 10 次，如果都是timeout, 认为设备已断线
						for( int iPingIndex = 0; iPingIndex <  10; iPingIndex++ )
						{
							if( Ping(2000, pDev->m_strIp) == 0 )
							{
								iPingResult = 0;
								break;
							}
							else
							{
								iPingResult = 1;
							}
						}

						// 4.2 对网络设备断线和在线处理;
						if( 1 == iPingResult )   // 设备已断线
						{
							if( pDev->m_bySpecialdevice == 2 )
							{
								// 通过uid获取网络设备线程ID索引;
								int nIndex = GetTcpThreadStructIndex( pDev->m_strUid );
								if( nIndex != -1 )
								{

									// 通过已知线程ID索引,挂起线程;
									if( g_hRequestDataThread[ g_tcpThreadStruct[nIndex].nTcpTheadIndex ] != NULL )
									{
										//LOG4C((LOG_NOTICE, "Enter SuspendThread."));
										SuspendThread( g_hRequestDataThread[ g_tcpThreadStruct[nIndex].nTcpTheadIndex ] );
										//LOG4C((LOG_NOTICE, "Leave SuspendThread."));
									}
								}

								// 关闭该线程所使用的网络资源(如:套接字);
								//LOG4C((LOG_NOTICE, "Enter CloseTcpNet."));
								CloseTcpNet(pDev->m_iDevideaddr, pDev->m_iIpport, (char *)(LPCTSTR)pDev->m_strIp);
								//LOG4C((LOG_NOTICE, "Leave CloseTcpNet."));
							}

							// 设备该设备在线变量;
							//if( pDev->m_bCommStatus == TRUE )
							{
								//LOG4C((LOG_NOTICE, "devname = %s ping timeout", pDev->m_strDeviceName));
								EnterCriticalSection( &g_csDevOnlineReadOneData );
								pBaseVar->m_dbData = 1;
								pBaseVar->m_nStatus = 1;
								pDev->m_bCommStatus = FALSE;
								LeaveCriticalSection( &g_csDevOnlineReadOneData );
							}						
						}
						else
						{
							EnterCriticalSection( &g_csDevOnlineReadOneData );
							pBaseVar->m_dbData = 0;
							pBaseVar->m_nStatus = 0;
							pDev->m_bCommStatus = TRUE;
							LeaveCriticalSection( &g_csDevOnlineReadOneData );//g_csRtuReadOneData
						}
					}
					else	// 串口设备
					{
						if( pDev->m_dwOnlineTick <= 0 )
						{
							pDev->m_dwOnlineTick = GetTickCount();
						}
						
						// 1.判断变量超时值是否超过设定值,超过则设备判定为掉线;
						if( GetTickCount() - pDev->m_dwOnlineTick > 3 * 60 * 1000 && pDev->m_dwOnlineTick > 0 )
						{
							//LOG4C((LOG_NOTICE, "%s %d, 串口通信故障！", pDev->m_strDeviceName,pDev->m_bySpecialdevice));
							//if( pDev->m_bCommStatus == TRUE )
							{
								EnterCriticalSection( &g_csDevOnlineReadOneData );
								pBaseVar->m_dbData = 1;
								pBaseVar->m_nStatus = 1;
								pDev->m_bCommStatus = FALSE;
								LeaveCriticalSection( &g_csDevOnlineReadOneData );
							}
						}
						else if( GetTickCount() - pDev->m_dwOnlineTick < 3 * 60 * 1000 && pDev->m_dwOnlineTick > 0 )
						{
							//LOG4C((LOG_NOTICE, "%s, 串口通信正常！", pDev->m_strDeviceName));
							EnterCriticalSection( &g_csDevOnlineReadOneData );
							pBaseVar->m_dbData = 0;
							pBaseVar->m_nStatus = 0;
							pDev->m_bCommStatus = TRUE;
							LeaveCriticalSection( &g_csDevOnlineReadOneData );
						}
					}
					break;
				}
			}

			Sleep(10);  // 每个设备之间，延时10ms
		}

	}while( WaitForSingleObject( g_hRunObject, 100L ) == WAIT_TIMEOUT );

	return 0;
}

//
// 以下13个动态库采集函数,均由采集线程RequestDataThreadProc调用;
int ModbusRtuProcessProc(CDevice *pDev)
{
	char chMsg[80] = {0};
	SETBASEPARAM SetBasePara = {0};
	SetBasePara.nAddr = pDev->m_iDevideaddr;
	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	for( int j = 0; j < nVarSize; j++ )
	{
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		// 记住上一次读到的数值
		pBaseVar->m_dbLastData = pBaseVar->m_dbData;

		SetBasePara.nRegNum = pBaseVar->m_iRegisterNum;
		SetBasePara.nStartAddr = pBaseVar->m_nRegStartAddr;
		SetBasePara.FuncCode = pBaseVar->m_iFuncID;

		if( pBaseVar->m_nVarTypeID >= SPECIAL_VAR_TYPE_MIN_ID && pBaseVar->m_nVarTypeID <= SPECIAL_VAR_TYPE_MAX_ID )	// 特殊变量
		{
			//TRACE("变量值id=%d\r\n", pBaseVar->m_nVarID);
			int nRet = RtuRequestSpecData(SetBasePara, pBaseVar->m_iDataLen, pDev->m_iPort, pDev->m_iDevideaddr, 
				(char *)(LPCTSTR)pBaseVar->m_strVarUID, pBaseVar->m_nVarID, pBaseVar->m_nVarTypeID);
			if (nRet == 0)
			{

			}
			else if (nRet == 30005)//Modbus rtu设备lrc校验失败
			{
				// 22:41 2012-6-6 tryto:当采集不到数据时,读取变量的初始值为当前值;
				pBaseVar->m_dbData = pBaseVar->m_nReserved1;
				pDev->m_dwOnlineTick = GetTickCount();
			}
			else
			{
				//Sleep(200);
				// 22:41 2012-6-6 tryto:当采集不到数据时,读取变量的初始值为当前值;
				pBaseVar->m_dbData = pBaseVar->m_nReserved1;
				continue;
			}
		}
		else
		{
			int nRet = pRTU_DLLInit(pDev->m_iPort, pDev->m_iDevideaddr, SetBasePara, pBaseVar->m_iDataLen, chMsg);
			if (nRet == 0)//初始化设备DLL
			{
				RtuSingleResponseData((char *)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, chMsg );
			}
			else if (nRet == 30005)//Modbus rtu设备lrc校验失败
			{
				pDev->m_dwOnlineTick = GetTickCount();
			}
			else
			{
				//LOG4C((LOG_NOTICE, "变量（%s），请求失败，错误代码=%d\n", pBaseVar->m_strDesc, nRet));
			}
		}

		if( abs(pBaseVar->m_dbData - pBaseVar->m_dbLastData) < DATA_CHANGE_FLAG )
		{
		}
		else
		{
			pBaseVar->m_bIsChange = TRUE;
		}

		Sleep(1);
	}

	return 0;
}

int ModbusAscProcessProc(CDevice *pDev)
{
	char chMsg[80] = {0};
	SETBASEPARAM SetBasePara = {0};
	SetBasePara.nAddr = pDev->m_iDevideaddr;
	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	for( int j = 0; j < nVarSize; j++ )
	{
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		// 记住上一次读到的数值
		pBaseVar->m_dbLastData = pBaseVar->m_dbData;

		SetBasePara.nRegNum = pBaseVar->m_iRegisterNum;
		SetBasePara.nStartAddr = pBaseVar->m_nRegStartAddr;
		SetBasePara.FuncCode = pBaseVar->m_iFuncID;

		if( pBaseVar->m_nVarTypeID >= SPECIAL_VAR_TYPE_MIN_ID && pBaseVar->m_nVarTypeID <= SPECIAL_VAR_TYPE_MAX_ID )	// 特殊变量
		{
			//TRACE("变量值id=%d\r\n", pBaseVar->m_nVarID);
			int nRet = AscRequestSpecData((char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, pBaseVar->m_nVarTypeID);
			if( nRet==0 )
			{

			}
			else if (nRet == 20005)//Modbus asc设备lrc校验失败
			{
				pDev->m_dwOnlineTick = GetTickCount();
			}
			else
			{
				continue;
			}
		}
		else
		{
			int nRet = pASCDLLInit(pDev->m_iPort, pDev->m_iDevideaddr, SetBasePara, pBaseVar->m_iDataLen, chMsg);//初始化设备DLL
			if( nRet==0 )
			{
				//TRACE("变量值id=%d\r\n", pBaseVar->m_nVarID);
				AscSingleResponseData((char *)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, chMsg);
			}
			else if (nRet == 20005)//Modbus asc设备lrc校验失败
			{
				pDev->m_dwOnlineTick = GetTickCount();
			}
			else if (nRet == 30005)//Modbus rtu设备lrc校验失败
			{
				pDev->m_dwOnlineTick = GetTickCount();
			}
		}

		//if( pBaseVar->m_strName=="Leak2_Alarm" )
		//{
		//	CString s;
		//	s.Format( "Leak2_Alarm=%d",pBaseVar->m_dbData );
		//	LOG4C((LOG_NOTICE, s));
		//}
		//if( pBaseVar->m_strName=="Leak2_Pos" )
		//{
		//	CString s;
		//	s.Format( "Leak2_Pos=%d",pBaseVar->m_dbData );
		//	LOG4C((LOG_NOTICE, s));
		//}

		if( abs(pBaseVar->m_dbData - pBaseVar->m_dbLastData) < DATA_CHANGE_FLAG )
		{
		}
		else
		{
			pBaseVar->m_bIsChange = TRUE;
		}

		Sleep(1);
	}

	return 0;
}

int ModbusTcpProcessProc(CDevice *pDev)
{
	char chMsg[80] = {0};
	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	for( int j = 0; j < nVarSize; j++ )
	{
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		// 记住上一次读到的数值
		pBaseVar->m_dbLastData = pBaseVar->m_dbData;

		if( WaitForSingleObject( g_hRunObject, 5L ) == WAIT_OBJECT_0 )
		{
			MTVERIFY( SetEvent(pDev->m_hSemNet) );
		}

#if 0

		if( WaitForSingleObject(g_hSemNet, 0) == WAIT_OBJECT_0 )	// 有信号才发送数据
		{
			char chRegNum[4] = {0};
			char chStartAddr[4] = {0};
			char chFuncCode[4] = {0}; 

			if (TcpRequestData(pDev->m_iIpport, 
								pDev->m_iDevideaddr, 
								(char *)(LPCTSTR)pDev->m_strIp, 
								pBaseVar->m_iRegisterNum, 
								pBaseVar->m_nRegStartAddr, 
								pBaseVar->m_iFuncID) == 0)
			{
				//TRACE("变量值id=%d\r\n", pBaseVar->m_nVarID);
				int nRet = TcpSingleResponseData((char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID);
				if( nRet == 0 )
				{
					g_nIndex--;
					if( g_nIndex != 0 )
					{
						//TRACE("ModbusTcp数据不同步！\r\n");
					}

					//TRACE(">>>>>>>>>>结束请求一次数据\r\n");
					SetEvent( g_hSemNet );
					//TRACE("变量ID=%d, 请求寄存器地址：%d, 变量值=%.1f\r\n", pReadSnVar->iVarid, atoi(chStartAddr), g_TcpReadOneData.dbData);
					//
				}
				else
				{
					g_nIndex--;
					//TRACE("ModbusTcp响应数据错误！\r\n");
					SetEvent( g_hSemNet );
				}
			}
			else
			{
				//TRACE("没有读到数据\r\n");
			}
		}
#else
#if 0
			char chRegNum[4] = {0};
			char chStartAddr[4] = {0};
			char chFuncCode[4] = {0}; 

			if( WaitForSingleObject(pDev->m_hSemNet, 0) == WAIT_OBJECT_0 )	// 有信号才发送数据
			{
				if (TcpRequestData(pDev->m_iIpport, 
									pDev->m_iDevideaddr, 
									(char *)(LPCTSTR)pDev->m_strIp, 
									pBaseVar->m_iRegisterNum, 
									pBaseVar->m_nRegStartAddr, 
									pBaseVar->m_iFuncID) == 0)
				{
					int nRet = TcpSingleResponseData((char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID);
				}
			}
#else
			char chRegNum[4] = {0};
			char chStartAddr[4] = {0};
			char chFuncCode[4] = {0}; 

			if( WaitForSingleObject(pDev->m_hSemNet, 0) == WAIT_OBJECT_0 )	// 有信号才发送数据
			{
				g_nIndex++;
				ResetEvent( pDev->m_hSemNet );
				if (TcpRequestData(pDev->m_iIpport, 
									pDev->m_iDevideaddr, 
									(char *)(LPCTSTR)pDev->m_strIp, 
									pBaseVar->m_iRegisterNum, 
									pBaseVar->m_nRegStartAddr, 
									pBaseVar->m_iFuncID) == 0)
				{
					int nRet = TcpSingleResponseData((char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID);
					if( nRet == 0 )
					{
						g_nIndex--;
						if( g_nIndex != 0 )
						{
							//TRACE("ModbusTcp数据不同步！\r\n");
						}

						//TRACE(">>>>>>>>>>结束请求一次数据\r\n");
						SetEvent( pDev->m_hSemNet );
						//TRACE("变量ID=%d, 请求寄存器地址：%d, 变量值=%.1f\r\n", pReadSnVar->iVarid, atoi(chStartAddr), g_TcpReadOneData.dbData);
						//
					}
					else if( nRet == 20405 )
					{
						pDev->m_dwOnlineTick = GetTickCount();
					}
					else
					{
						g_nIndex--;
						//TRACE("ModbusTcp响应数据错误！\r\n");
						SetEvent( pDev->m_hSemNet );
					}
				}
				else
				{
					SetEvent( pDev->m_hSemNet );
				}
			}
#endif
#endif

			if( abs(pBaseVar->m_dbData - pBaseVar->m_dbLastData) < DATA_CHANGE_FLAG )
			{
				//LOG4C((LOG_NOTICE, "var desc = %s IsChange = false", pBaseVar->m_strDesc));
			}
			else
			{
				//LOG4C((LOG_NOTICE, "var desc = %s IsChange = true", pBaseVar->m_strDesc));
				pBaseVar->m_bIsChange = TRUE;
			}
			Sleep(1);
	}

	return 0;
}

int SnmpProcessProc(CDevice *pDev)
{
	char chMsg[1024] = {0};
	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	for( int j = 0; j < nVarSize; j++ )
	{
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		// 记住上一次读到的数值
		pBaseVar->m_dbLastData = pBaseVar->m_dbData;

		if( pSnmpDllGetValue )
		{
			//TRACE("变量值id=%d\r\n", pBaseVar->m_nVarID);
			int nRet = pSnmpDllGetValue((char *)(LPCTSTR)pDev->m_strIp, 
				(char *)(LPCTSTR)pBaseVar->m_strFields,
				(char *)(LPCTSTR)pBaseVar->m_strSnmpoi,
				chMsg);

			if( nRet == 0 )
			{
				ParseSnmpData(
					(char *)(LPCTSTR)pDev->m_strUid, 
					pBaseVar->m_nVarID,
					chMsg);
			}
		}

		if( abs(pBaseVar->m_dbData - pBaseVar->m_dbLastData) < DATA_CHANGE_FLAG )
		{
		}
		else
		{
			pBaseVar->m_bIsChange = TRUE;
		}

		Sleep(1);
	}

	return 0;
}

int IcpdasProcessProc(CDevice *pDev)
{
	char chMsg[80] = {0};
	SETBASEPARAM SetBasePara = {0};
	SetBasePara.nAddr = pDev->m_iDevideaddr;

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	for( int j = 0; j < nVarSize; j++ )
	{
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		// 记住上一次读到的数值
		pBaseVar->m_dbLastData = pBaseVar->m_dbData;

		SetBasePara.nRegNum = pBaseVar->m_iRegisterNum;
		SetBasePara.nStartAddr = pBaseVar->m_nRegStartAddr;
		SetBasePara.FuncCode = pBaseVar->m_iFuncID;

		int nRet = IcpdasRequestData(j, SetBasePara, pBaseVar->m_iDataLen, pDev->m_iPort, pDev->m_iDevideaddr, 
			(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, (char *)(LPCTSTR)pBaseVar->m_strRs232cmd);
		if( nRet==0 )
		{

		}
		else if( nRet == 20805 )
		{
			pDev->m_dwOnlineTick = GetTickCount();
		}
		else
		{
			continue;
		}

		if( abs(pBaseVar->m_dbData - pBaseVar->m_dbLastData) < DATA_CHANGE_FLAG )
		{
		}
		else
		{
			pBaseVar->m_bIsChange = TRUE;
		}

		Sleep(1);
	}

	return 0;
}

int ParadigmProcessProc(CDevice *pDev)
{
	char chMsg[80] = {0};

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	for( int j = 0; j < nVarSize; j++ )
	{
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		// 记住上一次读到的数值
		pBaseVar->m_dbLastData = pBaseVar->m_dbData;

		int nRet = ParadigmRequestData(pDev->m_iPort, pDev->m_iDevideaddr, 
			(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, (char*)(LPCTSTR)pBaseVar->m_strRs232cmd);
		if( nRet == 0)
		{
		
		}
		else
		{
			continue;
		}

		if( abs(pBaseVar->m_dbData - pBaseVar->m_dbLastData) < DATA_CHANGE_FLAG )
		{
		}
		else
		{
			pBaseVar->m_bIsChange = TRUE;
		}

		Sleep(1);
	}

	return 0;
}

int StulzProcessProc(CDevice *pDev)
{
	char chMsg[80] = {0};
	SETBASEPARAM SetBasePara = {0};
	SetBasePara.nAddr = pDev->m_iDevideaddr;

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	for( int j = 0; j < nVarSize; j++ )
	{
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		// 记住上一次读到的数值
		pBaseVar->m_dbLastData = pBaseVar->m_dbData;

		SetBasePara.nRegNum = pBaseVar->m_iRegisterNum;
		SetBasePara.nStartAddr = pBaseVar->m_nRegStartAddr;
		SetBasePara.FuncCode = pBaseVar->m_iFuncID;

		int nRet = StulzRequestData(SetBasePara, pBaseVar->m_iDataLen, pDev->m_iPort, pDev->m_iDevideaddr, 
			(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, (char*)(LPCTSTR)pBaseVar->m_strRs232cmd);
		if( nRet==0 )
		{
		
		}
		else if( nRet == 20805 )
		{
			pDev->m_dwOnlineTick = GetTickCount();
		}
		else
		{
			continue;
		}

		if( abs(pBaseVar->m_dbData - pBaseVar->m_dbLastData) < DATA_CHANGE_FLAG )
		{
		}
		else
		{
			pBaseVar->m_bIsChange = TRUE;
		}

		Sleep(1);
	}

	return 0;
}

int DaiKinProcessProc(CDevice *pDev)
{
	char chMsg[80] = {0};
	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	for( int j = 0; j < nVarSize; j++ )
	{
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		// 记住上一次读到的数值
		pBaseVar->m_dbLastData = pBaseVar->m_dbData;

		int nRet = DaiKinRequestData(pDev->m_iPort, pDev->m_iDevideaddr, 
			(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, (char*)(LPCTSTR)pBaseVar->m_strRs232cmd);
		if( nRet == 0)
		{
		
		}
		else if( nRet == 21405 )
		{
			pDev->m_dwOnlineTick = GetTickCount();
		}
		else
		{
			continue;
		}

		if( abs(pBaseVar->m_dbData - pBaseVar->m_dbLastData) < DATA_CHANGE_FLAG )
		{
		}
		else
		{
			pBaseVar->m_bIsChange = TRUE;
		}

		Sleep(1);
	}

	return 0;
}

int PowerwareProcessProc(CDevice *pDev)
{
	char chMsg[80] = {0};
	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	for( int j = 0; j < nVarSize; j++ )
	{
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		// 记住上一次读到的数值
		pBaseVar->m_dbLastData = pBaseVar->m_dbData;

		int nRet = PowerwareRequestData(pDev->m_iPort, pDev->m_iDevideaddr, 
			(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, (char*)(LPCTSTR)pBaseVar->m_strRs232cmd);
		if( nRet == 0)
		{
		
		}
		else if( nRet == 21605 )
		{
			pDev->m_dwOnlineTick = GetTickCount();
		}
		else
		{
			continue;
		}

		if( abs(pBaseVar->m_dbData - pBaseVar->m_dbLastData) < DATA_CHANGE_FLAG )
		{
		}
		else
		{
			pBaseVar->m_bIsChange = TRUE;
		}

		Sleep(1);
	}

	return 0;
}

int GreeProcessProc(CDevice *pDev)
{
	char chMsg[80] = {0};
	SETBASEPARAM SetBasePara = {0};
	SetBasePara.nAddr = pDev->m_iDevideaddr;

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	for( int j = 0; j < nVarSize; j++ )
	{
		if( WaitForSingleObject( g_hRunObject, 5L ) == WAIT_OBJECT_0 ) return 0;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		// 记住上一次读到的数值
		pBaseVar->m_dbLastData = pBaseVar->m_dbData;

		SetBasePara.nRegNum = pBaseVar->m_iRegisterNum;
		SetBasePara.nStartAddr = pBaseVar->m_nRegStartAddr;
		SetBasePara.FuncCode = pBaseVar->m_iFuncID;

		int nRet = GreeRequestData(SetBasePara, pBaseVar->m_iDataLen, pDev->m_iPort, pDev->m_iDevideaddr, 
			(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, (char*)(LPCTSTR)pBaseVar->m_strRs232cmd);
		if( nRet == 0)
		{
		
		}
		else if( nRet == 21805 )
		{
			pDev->m_dwOnlineTick = GetTickCount();
		}
		else
		{
			continue;
		}

		if( abs(pBaseVar->m_dbData - pBaseVar->m_dbLastData) < DATA_CHANGE_FLAG )
		{
		}
		else
		{
			pBaseVar->m_bIsChange = TRUE;
		}

		Sleep(1);
	}

	return 0;
}

int CarelProcessProc(CDevice *pDev)
{
	char chMsg[80] = {0};

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	for( int j = 0; j < nVarSize; j++ )
	{

		if( WaitForSingleObject( g_hRunObject, 5L ) == WAIT_OBJECT_0 ) return 0;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		// 记住上一次读到的数值
		pBaseVar->m_dbLastData = pBaseVar->m_dbData;

		int nRet = CarelRequestData(pDev->m_iPort, pDev->m_iDevideaddr, 
								(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, 
								(char*)(LPCTSTR)pBaseVar->m_strRs232cmd);
		if( nRet == 0)
		{
		
		}
		else if( nRet == 22205 )
		{
			pDev->m_dwOnlineTick = GetTickCount();
		}
		else
		{
			continue;
		}

		if( abs(pBaseVar->m_dbData - pBaseVar->m_dbLastData) < DATA_CHANGE_FLAG )
		{
		}
		else
		{
			pBaseVar->m_bIsChange = TRUE;
		}

		Sleep(1);
	}

	return 0;
}

int SeparateProcessProc(CDevice *pDev)
{
	char chMsg[80] = {0};

	char szIniName[MAX_PATH] = {0};
	strcpy(szIniName, (char *)(LPCTSTR)pDev->m_strIniName);
	StrLower(szIniName, szIniName);

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	for( int j = 0; j < nVarSize; j++ )
	{
		if( WaitForSingleObject( g_hRunObject, 5L ) == WAIT_OBJECT_0 ) return 0;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		// 记住上一次读到的数值
		pBaseVar->m_dbLastData = pBaseVar->m_dbData;

		int nRet = SeparateRequestData(pDev->m_iPort, pDev->m_iDevideaddr, 
								(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, 
								(char*)(LPCTSTR)pBaseVar->m_strRs232cmd,
								szIniName);
		if( nRet == 0)
		{
		
		}
		else if( nRet == 50205 )
		{
			pDev->m_dwOnlineTick = GetTickCount();
		}
		else
		{
			continue;
		}

		if( abs(pBaseVar->m_dbData - pBaseVar->m_dbLastData) < DATA_CHANGE_FLAG )
		{
		}
		else
		{
			pBaseVar->m_bIsChange = TRUE;
		}

		Sleep(1);
	}

	return 0;
}

int MostDeviceProcessProc(CDevice *pDev)
{
	char chMsg[80] = {0};

	char szIniName[MAX_PATH] = {0};
	strcpy(szIniName, (char *)(LPCTSTR)pDev->m_strIniName);
	StrLower(szIniName, szIniName);

	// 循环所有变量
	int nVarSize = pDev->m_Vars.GetSize();
	for( int j = 0; j < nVarSize; j++ )
	{
		if( WaitForSingleObject( g_hRunObject, 0 ) == WAIT_OBJECT_0 ) return 0;
		CBaseVar *pBaseVar = pDev->m_Vars[j];

		// m_bReadOnly == 0只读;   == 1只写 ; == :读写;
		if( pBaseVar->m_bReadOnly == 1 ) continue;
		if( pBaseVar->m_nVarTypeID == ONLINE_VAR_ID || HIGH_PRIORITY_ONLINE_ID == pBaseVar->m_nVarTypeID ) continue;  // 内存变量，在DevOnlineThread处理

		// 记住上一次读到的数值
		pBaseVar->m_dbLastData = pBaseVar->m_dbData;

		int nRet = MostDeviceRequestData(pDev->m_iPort, pDev->m_iDevideaddr, 
								(char*)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID, 
								(char*)(LPCTSTR)pBaseVar->m_strRs232cmd,
								szIniName);
		if( nRet == 0)	
		{
		}
		else if( nRet == 50205 )
		{
			pDev->m_dwOnlineTick = GetTickCount();
		}
		else
		{
			Sleep(1);
			continue;
		}

		// abs(int ) :将参数转为绝对值.
		if( abs(pBaseVar->m_dbData - pBaseVar->m_dbLastData) < DATA_CHANGE_FLAG )
		{
		}
		else
		{
			pBaseVar->m_bIsChange = TRUE;
		}

		Sleep(1);
	}

	return 0;
}

//
// 以上13个采集函数均由采集线程RequestDataThreadProc调用;
// 该线程的参数是外部指定的串口号;
DWORD WINAPI RequestDataThreadProc(void *pPara)
{
#if IS_USER_MUL_THREAD_REQUEST
	CString strName;
	strName = CString((char *)pPara);
	strName.MakeLower();
#endif
	do
	{
		// 循环所有设备
		int nDeviceSize = g_pDevicesManager->m_Devices.GetSize();
		for( int i = 0; i < nDeviceSize; i++ )
		{
			CDevice *pDev = g_pDevicesManager->m_Devices[i];

			char chDllName[MAX_PATH] = {0};
			strcpy(chDllName, (char *)(LPCTSTR)pDev->m_strProtocoldllname);
			StrLower(chDllName,chDllName);

			char szIniName[MAX_PATH] = {0};
			strcpy(szIniName, (char *)(LPCTSTR)pDev->m_strIniName);
			StrLower(szIniName, szIniName);

			char szUid[MAX_PATH] = {0};
			strcpy(szUid, (char *)(LPCTSTR)pDev->m_strUid);
			StrLower(szUid, szUid);
			
			char szPort[MAX_PATH] = {0};
			CString strPort;
			strPort.Format("%d", pDev->m_iPort);
			strcpy(szPort, (char *)(LPCTSTR)strPort);
			StrLower(szPort, szPort);

#if 0
			if( pDev->m_bCommStatus == FALSE ) 
			{
				Sleep(1);
				continue;
			}
#endif

			if( pDev->m_bySpecialdevice == 0 )
			{
#if IS_USER_MUL_THREAD_REQUEST
				if( strName.Compare(szPort) != 0 ) continue;
#endif
				ModbusRtuProcessProc(pDev);
			}
			else if( pDev->m_bySpecialdevice == 1 )
			{
#if IS_USER_MUL_THREAD_REQUEST
				if( strName.Compare(szPort) != 0 ) continue;
#endif
				ModbusAscProcessProc(pDev);
			}
			else if( pDev->m_bySpecialdevice == 2 )
			{
#if IS_USER_MUL_THREAD_REQUEST
				if( strName.Compare(szUid) ) continue;
#endif
				ModbusTcpProcessProc(pDev);
			}
			else if( pDev->m_bySpecialdevice == 3 )
			{
#if IS_USER_MUL_THREAD_REQUEST
				if( strName.Compare(szUid) ) continue;
#endif
				SnmpProcessProc(pDev);
			}
			else if( pDev->m_bySpecialdevice == 4 )
			{
				if ( strcmp(chDllName, "icpdas.dll") == 0 )
				{
#if IS_USER_MUL_THREAD_REQUEST
					if( strName.Compare(szPort) != 0 ) continue;
#endif
					IcpdasProcessProc(pDev);
				}
				else if ( strcmp(chDllName, "upsparadigm.dll") == 0 )
				{
#if IS_USER_MUL_THREAD_REQUEST
					if( strName.Compare(szPort) != 0 ) continue;
#endif
					ParadigmProcessProc(pDev);
				}
				else if ( strcmp(chDllName, "stulz.dll") == 0 )
				{
#if IS_USER_MUL_THREAD_REQUEST
					if( strName.Compare(szPort) != 0 ) continue;
#endif
					StulzProcessProc(pDev);
				}
				else if ( strcmp(chDllName, "daikin.dll") == 0 )
				{
#if IS_USER_MUL_THREAD_REQUEST
					if( strName.Compare(szPort) != 0 ) continue;
#endif
					DaiKinProcessProc(pDev);
				}
				else if ( strcmp(chDllName, "powerware.dll") == 0 )
				{
#if IS_USER_MUL_THREAD_REQUEST
					if( strName.Compare(szPort) != 0 ) continue;
#endif
					PowerwareProcessProc(pDev);
				}
				else if ( strcmp(chDllName, "gree.dll") == 0 )
				{
#if IS_USER_MUL_THREAD_REQUEST
					if( strName.Compare(szPort) != 0 ) continue;
#endif
					GreeProcessProc(pDev);
				}
				else if ( strcmp(chDllName, "carel.dll") == 0 )
				{
#if IS_USER_MUL_THREAD_REQUEST
					if( strName.Compare(szPort) != 0 ) continue;
#endif
					CarelProcessProc(pDev);
				}
				else if ( strcmp(chDllName, "scantak_3c.dll") == 0 )
				{
#if IS_USER_MUL_THREAD_REQUEST
					if( strName.Compare(szPort) != 0 ) continue;
#endif				
					SeparateProcessProc(pDev);
				}
				else if ( strcmp(chDllName, "delta.dll") == 0 )
				{
#if IS_USER_MUL_THREAD_REQUEST
					if( strName.Compare(szPort) != 0 ) continue;
#endif
					//TRACE("变量值id=%d\r\n", pBaseVar->m_nVarID);
					SeparateProcessProc(pDev);
				}
				else if ( strcmp(szIniName, "upsuh31.ini") == 0 ||
					strcmp(szIniName, "emerson_cm.ini") == 0 ||
					strcmp(szIniName, "dme3000.ini") == 0 ||
					strcmp(szIniName, "paradigm200a_rectifier.ini") == 0 ||
					strcmp(szIniName, "paradigm200a_inverter.ini") == 0 ||
					strcmp(szIniName, "paradigm200b.ini") == 0 ||
					strcmp(szIniName, "hipulseigmnet.ini") == 0 ||
					strcmp(szIniName, "hipulsecdt.ini") == 0 ||
					strcmp(szIniName, "prostar.ini") == 0 ||
					strcmp(szIniName, "joton.ini") == 0 ||
					strcmp(szIniName, "hiross.ini") == 0 ||
					strcmp(szIniName, "upslink.ini") == 0 ||
					strcmp(szIniName, "upsapcsilcon.ini") == 0 ||
					strcmp(szIniName, "ul33.ini") == 0 || 
					strcmp(szIniName, "hipulse_u.ini") == 0 || 
					strcmp(szIniName, "kehua.ini") == 0 ||
					strcmp(szIniName, "secups.ini") == 0 ||
					strcmp(szIniName, "upsuh11.ini") == 0 ||
                    strcmp(szIniName, "weibo.ini") == 0 ||
                    strcmp(szIniName, "sda_ii.ini") == 0 ||
					strcmp(szIniName, "daikin.ini") == 0 ||
					strcmp(szIniName, "scantak_3c.ini") == 0 ||
					strcmp(szIniName, "delta.ini") == 0 ||
					strcmp(szIniName, "m84c5z.ini") == 0 ||
					strcmp(szIniName, "upsnxr.ini") == 0 ||
					strcmp(szIniName, "batteryadu.ini") == 0 ||
					strcmp(szIniName, "upsmonitorlan.ini") == 0 ||
					strcmp(szIniName, "sk6000.ini") == 0 ||
					strcmp(szIniName, "batteryadu2000.ini") == 0 ||
					strcmp(szIniName, "santak_shiwei.ini") == 0 ||
					strcmp(szIniName, "santak_q4.ini") == 0 ||
					strcmp(szIniName, "ups_nxl.ini") == 0 ||
					strcmp(szIniName, "twoul33.ini") == 0 ||
					strcmp(szIniName, "oumai.ini") == 0 ||
					strcmp(szIniName, "santak_3a3120ks.ini") == 0 ||
					strcmp(szIniName, "tmaster.ini") == 0 ||
					strcmp(szIniName, "st_6c20ks.ini") == 0 ||
					strcmp(szIniName, "ea800.ini") == 0 ||
					strcmp(szIniName, "jb1501a64p.ini") == 0||
					strcmp(szIniName, "st_3c340ks.ini") == 0||
					strcmp(szIniName, "delta_v1.54.ini") == 0 ||
					strcmp(szIniName, "icp_i7017.ini") == 0 ||
					strcmp(szIniName, "fad.ini") == 0 ||
					strcmp(szIniName, "itrustadapt.ini" ) == 0  ||
					strcmp(szIniName, "uha3r_0200l.ini") == 0)
				{
#if IS_USER_MUL_THREAD_REQUEST
					if( strName.Compare(szPort) != 0 ) continue;
#endif
					//LOG4C((LOG_NOTICE, "Enter MostDeviceProcessProc szIniName = %s", szIniName));
					MostDeviceProcessProc(pDev);
					//LOG4C((LOG_NOTICE, "Leave MostDeviceProcessProc szIniName = %s", szIniName));
				}
			}
		}
	}while( WaitForSingleObject( g_hRunObject, 5L ) == WAIT_TIMEOUT );

	return 0;

}

//
// 定时发送系统运行通知  短信/电话/邮件/传真  线程;
// 应添加如下功能:
// 1.选择按天发送系统信息;
// 2.选择按星期发送系统信息;
// 3.选择按月发送系统信息;
DWORD WINAPI TimingSendSmsThread(void *pPara)
{
	char chTel[MAX_TEL_LENGTH] = {0};			// 电话;
	char chMobile[MAX_TEL_LENGTH] = {0};		// 手机;	
	char chFax[MAX_TEL_LENGTH] = {0};			// 传真;
	char chEmail[MAX_EMAIL_LENGTH] = {0};		// 邮件;

	// 创建容器(最后使用完要释放内存空间);
	list<string> list_tel, list_mobile, list_fax, list_email;
	list<string>::iterator it_tel, it_mobile, it_fax, it_email;

	// 从数据库中获取用户信息;
	int nUserCount = CDBInterface::GetInstancePtr()->GetUserInfoList(list_tel, list_mobile, list_fax, list_email);

	// 无用户,返回;
	if( 0 == nUserCount ) 
		return 0;

	// 有用户,但用户无电话等信息,返回;
	if( 0 == list_tel.size() )
		return 0;

	do
	{
		// 时刻获取当前时间,对比已设定好的时间;
		CTime ctNow = CTime::GetCurrentTime(); 
		int nWeek, nHour, nMinute;
		nWeek = ctNow.GetDayOfWeek();	
		nHour = ctNow.GetHour();
		nMinute = ctNow.GetMinute();
#if 0 //每天发一次
		if( nHour == g_nTimingHours && nMinute == g_nTimingMinutes && g_nTimingEnable == 1 	&& g_nTimingSendFinished == 0 )
		{
			g_nTimingSendFinished = 1;
			char szResultMsg[MAX_EQUIP_DESC + 1] = {0};
			int nResult = -1;
			memset(szResultMsg, 0, sizeof(szResultMsg));
			for( it_tel = list_tel.begin(), it_mobile = list_mobile.begin(), it_fax = list_fax.begin(), it_email = list_email.begin();
				it_tel != list_tel.end(), it_mobile != list_mobile.end(), it_fax != list_fax.end(), it_email != list_email.end(); )
			{
				strcpy(chTel, (*it_tel++).c_str());
				strcpy(chMobile, (*it_mobile++).c_str());
				strcpy(chFax, (*it_fax++).c_str());
				strcpy(chEmail, (*it_email++).c_str());

				// 是否启用短信模块功能;
				if( g_nSendSms==1 ) // g_nSendSms;
				{
					if( strcmp(chMobile, "") != 0 )
					{
						CString strMobileTel;
						strMobileTel.Format("%s",chMobile );
						if( strMobileTel.GetLength()!=11 )		continue;		//判断是不是手机号码 只根据长度

						if (pSmsDllSendSms && g_bSuccesOpen)
						{
								nResult = pSmsDllSendSms(chMobile, (char *)(LPCTSTR)g_strHintSysRun, szResultMsg);
						}
						
						if( nResult != 0 )		// 发送失败
						{
						}
					}
				}

				// 是否启用语音模块功能;
				if( g_nSendNotice == 1 )
				{
					//LOG4C((LOG_NOTICE, "nWeek = %d, nHour = %d, nMinute = %d", nWeek, nHour, nMinute));
					if( strcmp(chTel, "") != 0 )
					{
						LOG4C((LOG_NOTICE, "nWeek = %d, nHour = %d, nMinute = %d, g_strHintSysRun = %s", nWeek, nHour, nMinute, g_strHintSysRun));
						// 继续加入语音发送list
						EnterCriticalSection( &g_csVarNotice );
						InsertSendNoticeList("0.0.0.0", 1, chTel, (char *)(LPCTSTR)g_strHintSysRun);
						LeaveCriticalSection( &g_csVarNotice );
					}
#if 0 //移动电话 不打电话
					if( strcmp(chMobile, "") != 0 )
					{
						//LOG4C((LOG_NOTICE, "nWeek = %d, nHour = %d, nMinute = %d, g_strHintSysRun = %s", nWeek, nHour, nMinute, g_strHintSysRun));
						// 继续加入语音发送list
						EnterCriticalSection( &g_csVarNotice );
						InsertSendNoticeList("0.0.0.0", 1, chMobile, (char *)(LPCTSTR)g_strHintSysRun);
						LeaveCriticalSection( &g_csVarNotice );
					}
#endif
				}
			}
		}
		else
		{
			if( !( nHour == g_nTimingHours && nMinute == g_nTimingMinutes ) )
			{
				g_nTimingSendFinished = 0;
			}
		}
#else //每星期发一次
		if( nWeek == g_nTimingWeeks && nHour == g_nTimingHours 	&& nMinute == g_nTimingMinutes && g_nTimingEnable == 1 && g_nTimingSendFinished == 0 )
		{
			g_nTimingSendFinished = 1;
			char szResultMsg[MAX_EQUIP_DESC + 1] = {0};
			int nResult = -1;
			memset(szResultMsg, 0, sizeof(szResultMsg));
			for( it_tel = list_tel.begin(), it_mobile = list_mobile.begin(), it_fax = list_fax.begin(), it_email = list_email.begin();
				it_tel != list_tel.end(), it_mobile != list_mobile.end(), it_fax != list_fax.end(), it_email != list_email.end(); )
			{
				strcpy(chTel, (*it_tel++).c_str());
				strcpy(chMobile, (*it_mobile++).c_str());
				strcpy(chFax, (*it_fax++).c_str());
				strcpy(chEmail, (*it_email++).c_str());

				// 发送短信;
				if( g_nSendSms==1 )
				{
					if( strcmp(chMobile, "") != 0 )
					{
						CString strMobileTel;
						strMobileTel.Format("%s",chMobile );
						if( strMobileTel.GetLength()!=11 )		continue;		//判断是不是手机号码 只根据长度
						if (pSmsDllSendSms && g_bSuccesOpen)
						{
								nResult = pSmsDllSendSms(chMobile, (char *)(LPCTSTR)g_strHintSysRun, szResultMsg);
						}
					
						if( nResult != 0 )		// 发送失败
						{
						}
					}
				}

				// 发送电话语音;
				if( g_nSendNotice == 1 )
				{
					//LOG4C((LOG_NOTICE, "nWeek = %d, nHour = %d, nMinute = %d", nWeek, nHour, nMinute));
					if( strcmp(chTel, "") != 0 )
					{
						LOG4C((LOG_NOTICE, "nWeek = %d, nHour = %d, nMinute = %d, g_strHintSysRun = %s", nWeek, nHour, nMinute, g_strHintSysRun));
						// 继续加入语音发送list
						EnterCriticalSection( &g_csVarNotice );
						InsertSendNoticeList("0.0.0.0", 1, chTel, (char *)(LPCTSTR)g_strHintSysRun,0);
						LeaveCriticalSection( &g_csVarNotice );
					}
#if 0 //移动电话 不打电话
					if( strcmp(chMobile, "") != 0 )
					{
						//LOG4C((LOG_NOTICE, "nWeek = %d, nHour = %d, nMinute = %d, g_strHintSysRun = %s", nWeek, nHour, nMinute, g_strHintSysRun));
						// 继续加入语音发送list
						EnterCriticalSection( &g_csVarNotice );
						InsertSendNoticeList("0.0.0.0", 1, chMobile, (char *)(LPCTSTR)g_strHintSysRun);
						LeaveCriticalSection( &g_csVarNotice );
					}
#endif
				}
			}
		}
		else
		{
			if( !( nWeek == g_nTimingWeeks && nHour == g_nTimingHours && nMinute == g_nTimingMinutes ) )
			{
				g_nTimingSendFinished = 0;
			}
		}
#endif
	}while( WaitForSingleObject( g_hRunObject, 1250L ) == WAIT_TIMEOUT );


	// 作内存释放;
	for( it_tel = list_tel.begin(), it_mobile = list_mobile.begin(), it_fax = list_fax.begin(), it_email = list_email.begin();
		it_tel != list_tel.end(), it_mobile != list_mobile.end(), it_fax != list_fax.end(), it_email != list_email.end(); )
	{
		list_tel.erase(it_tel++);
		list_mobile.erase(it_mobile++);
		list_fax.erase(it_fax++);
		list_email.erase(it_email++);
	}

	return 0;
}

//
// 语音报警线程;
// 该线程功能如下:
// 1.判断变量值是否改变,改变则将变量发送到所有客户端,并写入数据库sumlog表里,以及写入txt日志文件中;
// 2.判断变量采集是否超时,如果超时,写入变量值到数据库sumlog表里,并写入txt日志文件中;
// 3.判断变量是否有报警选项,有投递到函数VarAlarmNotice进行报警处理过滤;
DWORD WINAPI VoiceNoticeThreadProc(void *pPara)
{
	do
	{
		// 循环所有设备
		int nDeviceSize = g_pDevicesManager->m_Devices.GetSize();
		for( int i = 0; i < nDeviceSize; i++ )
		{
			CDevice *pDev = g_pDevicesManager->m_Devices[i];

			char chDllName[MAX_PATH] = {0};
			strcpy(chDllName, (char *)(LPCTSTR)pDev->m_strProtocoldllname);
			StrLower(chDllName,chDllName);

			char szIniName[MAX_PATH] = {0};
			strcpy(szIniName, (char *)(LPCTSTR)pDev->m_strIniName);
			StrLower(szIniName, szIniName);

			char szUid[MAX_PATH] = {0};
			strcpy(szUid, (char *)(LPCTSTR)pDev->m_strUid);
			StrLower(szUid, szUid);
			
			char szPort[MAX_PATH] = {0};
			CString strPort;
			strPort.Format("%d", pDev->m_iPort);
			strcpy(szPort, (char *)(LPCTSTR)strPort);
			StrLower(szPort, szPort);

			// 循环所有变量
			int nVarSize = pDev->m_Vars.GetSize();
			for( int j = 0; j < nVarSize; j++ )
			{
				CBaseVar *pBaseVar = pDev->m_Vars[j];

				CString strTime;
				CTime tm;
				tm = CTime::GetCurrentTime();
				strTime = tm.Format("%Y-%m-%d %H:%M:%S");	
				int iIndex = 0;

				// 变量的值是否在正常范围
				if(  pBaseVar->m_nVarTypeID != SNMP_NPM_TYPE &&	pBaseVar->m_nVarTypeID != SNMP_STRING_ID )
				{
					if( (int)pBaseVar->m_dbData < pBaseVar->m_nReserved2 || (int)pBaseVar->m_dbData > pBaseVar->m_nReserved3 )
					{
						Sleep(1);
						continue;
					}
				}

#if 0
				if( 1 == g_nSnmpEnable )
				{
					if( 0 == pBaseVar->m_dwCollectTick )
					{
						CString strSetValue;
						strSetValue.Format("%.1f", pBaseVar->m_dbData);

						CString strObjID;
						strObjID.Format("%s.%d", g_strSnmpObjOid, pBaseVar->m_nVarID); 
						pSnmpDllSetValue(
							g_strSnmpIP,
							g_strSnmpField,
							(char *)(LPCTSTR)strObjID,
							"str",
							1,
							300,
							(char *)(LPCTSTR)strSetValue
						);
					}
				}
#endif

				DWORD iTickCount = GetTickCount();
				// 变量值改变;
				if( TRUE == pBaseVar->m_bIsChange )
				{
					// 发送值改变了的变量到所有客户端里?
					g_pServerSocket[1]->AutoSendDataToAllClient( pBaseVar );

					// 变量实时采集,则写入数据库summlog里;
					if( TRUE == pBaseVar->m_bRealTimeflag )
					{
						// 写数据库数据日志表;
						CDBInterface::GetInstancePtr()->EditSummaryRecord(
							(char *)(LPCTSTR)pDev->m_strDeviceName,		// 设备名称
							(char *)(LPCTSTR)strTime,					// 发生时间
							"",											// 备注
							(char *)(LPCTSTR)pBaseVar->m_strDesc,		// 变量描述
							pBaseVar->m_dbData,							// 变量值
							(char *)(LPCTSTR)pDev->m_strUid,			// 设备Uid
							(char *)(LPCTSTR)pBaseVar->m_strName);		// 变量名称
														
						EnterCriticalSection( &g_csRtuReadOneData );
						pBaseVar->m_bIsChange = FALSE;
						LeaveCriticalSection( &g_csRtuReadOneData );
					}

					// 变量实时保存,则保存日志到log.txt文件中;
					if( TRUE == pBaseVar->m_bIsSave )
					{					
						WriteSummaryLog(
							(char *)(LPCTSTR)pDev->m_strDeviceName,		// 设备名称
							(char *)(LPCTSTR)strTime,					// 发生时间
							"",											// 备注
							0,											// 现没有用到
							(char *)(LPCTSTR)pBaseVar->m_strDesc,		// 变量描述
							pBaseVar->m_dbData,							// 变量值
							(char *)(LPCTSTR)pDev->m_strUid,			// 设备Uid
							(char *)(LPCTSTR)pBaseVar->m_strName);		// 变量名称	
					}
				}
				// 变量值没有改变,假如超过了采集频率,且变量有保存选项,同样上一步操作;
				else if ((( iTickCount - pBaseVar->m_dwCollectTick) > pBaseVar->m_nCollectFreq * 1000) && pBaseVar->m_bIsSave )
				{
					// 是否实时采集;
					if( TRUE == pBaseVar->m_bRealTimeflag )
					{
						CDBInterface::GetInstancePtr()->EditSummaryRecord(
							(char *)(LPCTSTR)pDev->m_strDeviceName,		// 设备名称
							(char *)(LPCTSTR)strTime,					// 发生时间
							"",											// 备注
							(char *)(LPCTSTR)pBaseVar->m_strDesc,		// 变量描述
							pBaseVar->m_dbData,							// 变量值
							(char *)(LPCTSTR)pDev->m_strUid,			// 设备Uid
							(char *)(LPCTSTR)pBaseVar->m_strName);		// 变量名称
					}

					// 是否保存;
					if( TRUE == pBaseVar->m_bIsSave )
					{
						WriteSummaryLog(
							(char *)(LPCTSTR)pDev->m_strDeviceName,		// 设备名称
							(char *)(LPCTSTR)strTime,					// 发生时间
							"",											// 备注
							0,											// 现没有用到
							(char *)(LPCTSTR)pBaseVar->m_strDesc,		// 变量描述
							pBaseVar->m_dbData,							// 变量值
							(char *)(LPCTSTR)pDev->m_strUid,			// 设备Uid
							(char *)(LPCTSTR)pBaseVar->m_strName);		// 变量名称	

						EnterCriticalSection(&g_csRtuReadOneData);
						pBaseVar->m_dwCollectTick = GetTickCount();
						LeaveCriticalSection(&g_csRtuReadOneData);
					}
				}

				// m_bReserved2 预留2 是否触发远程报警
				// 是否触发远程报警(在函数VarAlarmNotice进行报警内容组合);
				if( pBaseVar->m_bReserved2 == TRUE )
				{
					VarAlarmNotice(pDev, pBaseVar);
				}
			}
		}
	}while( WaitForSingleObject( g_hRunObject, 5L ) == WAIT_TIMEOUT );

	return 0;
}

//
// 变量输出 == 专为上海烟草局设计 ????
DWORD WINAPI OutputThreadProc(void *pPara)
{
	CString strClock, strTh;
	strClock.Format("%s", g_strOutputClock);
	strTh.Format("%s", g_strOutputFileName);
	//LOG4C((LOG_NOTICE, "%s", strClock));
	//LOG4C((LOG_NOTICE, "%s", strTh));
	CStdioFile fClock;
	CStdioFile fTh;
	bool bfClockResult = false;
	bool bfThResult = false;
	bfClockResult = fClock.Open(strClock, CFile::modeCreate | CFile::modeWrite | CFile::shareDenyWrite);
	bfThResult = fTh.Open(strTh, CFile::modeCreate | CFile::modeWrite | CFile::shareDenyWrite);
	do
	{
		CString strTime;
		CTime tm;
		tm = CTime::GetCurrentTime();
		strTime = tm.Format("%H:%M");
		strTime += "\n";

		if( bfClockResult )
		{
			//fClock.SetLength(0);
			fClock.SeekToBegin();
			fClock.Write(strTime.GetBuffer(), strTime.GetLength());
		}

		if( false == bfThResult )
		{
			Sleep(10);
			continue;
		}

		int iDeviceIndex = -1, iVarIndex = -1;
		char szVarName[MAX_UID + 1] = {0};
		
		int iSeekPos = 0;
		fTh.SeekToBegin();
		for( int iLineIndex1 = 0; iLineIndex1 < g_nOutputLineCount1; iLineIndex1++ )
		{
			// 获取输出行里的变量名;
			SplitStr(g_strOutputLine1, ',', iLineIndex1, szVarName);

			// 根据变量名,uid查找变量;
			BOOL bFind = FindVar( g_strOutputLineUid1, szVarName, iDeviceIndex, iVarIndex );
            if( bFind )
			{
				CDevice *pDev = g_pDevicesManager->m_Devices[iDeviceIndex];
				CBaseVar *pBaseVar = pDev->m_Vars[iVarIndex];

				CString strVarData;
				if( 0 == iLineIndex1 )
				{
					strVarData.Format("%.1f ", pBaseVar->m_dbData);
					fTh.Write(strVarData, strVarData.GetLength());
				}
				else if( 1 == iLineIndex1 )
				{
					strVarData.Format("%.1f%s    \r\n", pBaseVar->m_dbData, pBaseVar->m_strUnit);
					fTh.Write(strVarData, strVarData.GetLength());
				}
				iSeekPos += strVarData.GetLength();
			}
		}

		for( int iLineIndex2 = 0; iLineIndex2 < g_nOutputLineCount2; iLineIndex2++ )
		{
			SplitStr(g_strOutputLine2, ',', iLineIndex2, szVarName);
			BOOL bFind = FindVar( g_strOutputLineUid2, szVarName, iDeviceIndex, iVarIndex );
            if( bFind )
			{
				CDevice *pDev = g_pDevicesManager->m_Devices[iDeviceIndex];
				CBaseVar *pBaseVar = pDev->m_Vars[iVarIndex];

				CString strVarData;
				if( 0 == iLineIndex2 )
				{
					strVarData.Format("%.1f ", pBaseVar->m_dbData);
					fTh.Write(strVarData, strVarData.GetLength());
				}
				else if( 1 == iLineIndex2 )
				{
					strVarData.Format("%.1f%s    \r\n", pBaseVar->m_dbData, pBaseVar->m_strUnit);
					fTh.Write(strVarData, strVarData.GetLength());
				}
				iSeekPos += strVarData.GetLength();
			}
		}

		for( int iLineIndex3 = 0; iLineIndex3 < g_nOutputLineCount3; iLineIndex3++ )
		{
			SplitStr(g_strOutputLine3, ',', iLineIndex3, szVarName);
			BOOL bFind = FindVar( g_strOutputLineUid3, szVarName, iDeviceIndex, iVarIndex );
            if( bFind )
			{
				CDevice *pDev = g_pDevicesManager->m_Devices[iDeviceIndex];
				CBaseVar *pBaseVar = pDev->m_Vars[iVarIndex];

				CString strVarData;
				if( 0 == iLineIndex3 )
				{
					strVarData.Format("%.1f ", pBaseVar->m_dbData);
					fTh.Write(strVarData, strVarData.GetLength());
				}
				else if( 1 == iLineIndex3 )
				{
					strVarData.Format("%.1f%s    \r\n", pBaseVar->m_dbData, pBaseVar->m_strUnit);
					fTh.Write(strVarData, strVarData.GetLength());
				}
				iSeekPos += strVarData.GetLength();
			}
		}
	}while( WaitForSingleObject( g_hRunObject, 100L ) == WAIT_TIMEOUT );

	// 内存释放;
	if( bfClockResult )
	{
		fClock.Close();
	}
	// 内存释放;
	if( bfThResult )
	{
		fTh.Close();
	}

	return 0;
}

//
// 变量时间计划线程;
DWORD WINAPI GetDatePlanThreadProc(void *pPara)
{
	do
	{
		static int nStaticHours = -1;

		CTime time = CTime::GetCurrentTime();
		int nHours = time.GetHour();

		if( nStaticHours!=nHours )
		{
			LOG4C((LOG_NOTICE, _T("GetDatePlanThreadProc")));
			nStaticHours = nHours;
			// 循环所有设备
			int nDeviceSize = g_pDevicesManager->m_Devices.GetSize();
			for( int i = 0; i < nDeviceSize; i++ )
			{
				CDevice *pDev = g_pDevicesManager->m_Devices[i];

				// 循环所有变量
				int nVarSize = pDev->m_Vars.GetSize();
				for( int j = 0; j < nVarSize; j++ )
				{
					CBaseVar *pBaseVar = pDev->m_Vars[j];

					EnterCriticalSection(&g_csRtuReadOneData);
					// 从数据库中获取时间计划???
					pBaseVar->m_bExistDatePlan = CDBInterface::GetInstancePtr()->IsExistDatePlan((char *)(LPCTSTR)pDev->m_strUid, pBaseVar->m_nVarID);
					LeaveCriticalSection(&g_csRtuReadOneData);
				}
			}
		}

	}while( WaitForSingleObject( g_hRunObject, 10 * 1000L ) == WAIT_TIMEOUT );

	return 0;
}

//
// 以下13个查找 串口是否使用 函数,均由主函数StartMain调用;
BOOL FindRtuCommPort(CString strPort)
{
	BOOL bResult = FALSE;
	for( int i = RTU_THREAD_START; i < g_nRtuThreadIndex; i++ )
	{
		if( g_strPort[i].Compare(strPort) == 0 )
		{
			bResult = TRUE;
			break;
		}
	}
	return bResult;
}

BOOL FindAscCommPort(CString strPort)
{
	BOOL bResult = FALSE;
	for( int i = ASC_THREAD_START; i < g_nAscThreadIndex; i++ )
	{
		if( g_strPort[i].Compare(strPort) == 0 )
		{
			bResult = TRUE;
			break;
		}
	}
	return bResult;
}

BOOL FindTcpCommPort(CString strPort)
{
	BOOL bResult = FALSE;
	for( int i = TCP_THREAD_START; i < g_nTcpThreadIndex; i++ )
	{
		if( g_strPort[i].Compare(strPort) == 0 )
		{
			bResult = TRUE;
			break;
		}
	}
	return bResult;
}

BOOL FindMostDeviceCommPort(CString strPort)
{
	BOOL bResult = FALSE;
	for( int i = MOSTDEVICE_THREAD_START; i < g_nMostDeviceIndex; i++ )
	{
		if( g_strPort[i].Compare(strPort) == 0 )
		{
			bResult = TRUE;
			break;
		}
	}
	return bResult;
}

BOOL FindIcpdasCommPort(CString strPort)
{
	BOOL bResult = FALSE;
	for( int i = ICPDAS_THREAD_START; i < g_nIcpdasIndex; i++ )
	{
		if( g_strPort[i].Compare(strPort) == 0 )
		{
			bResult = TRUE;
			break;
		}
	}
	return bResult;
}

BOOL FindParadigmCommPort(CString strPort)
{
	BOOL bResult = FALSE;
	for( int i = PARADIGM_THREAD_START; i < g_nParadigmIndex; i++ )
	{
		if( g_strPort[i].Compare(strPort) == 0 )
		{
			bResult = TRUE;
			break;
		}
	}
	return bResult;
}

BOOL FindStulzCommPort(CString strPort)
{
	BOOL bResult = FALSE;
	for( int i = STULZ_THREAD_START; i < g_nStulzIndex; i++ )
	{
		if( g_strPort[i].Compare(strPort) == 0 )
		{
			bResult = TRUE;
			break;
		}
	}
	return bResult;
}

BOOL FindDaiKinCommPort(CString strPort)
{
	BOOL bResult = FALSE;
	for( int i = DAIKIN_THREAD_START; i < g_nDaiKinIndex; i++ )
	{
		if( g_strPort[i].Compare(strPort) == 0 )
		{
			bResult = TRUE;
			break;
		}
	}
	return bResult;
}

BOOL FindPowerwareCommPort(CString strPort)
{
	BOOL bResult = FALSE;
	for( int i = POWERWARE_THREAD_START; i < g_nPowerwareIndex; i++ )
	{
		if( g_strPort[i].Compare(strPort) == 0 )
		{
			bResult = TRUE;
			break;
		}
	}
	return bResult;
}

BOOL FindGreeCommPort(CString strPort)
{
	BOOL bResult = FALSE;
	for( int i = GREE_THREAD_START; i < g_nGreeIndex; i++ )
	{
		if( g_strPort[i].Compare(strPort) == 0 )
		{
			bResult = TRUE;
			break;
		}
	}
	return bResult;
}

BOOL FindCarelCommPort(CString strPort)
{
	BOOL bResult = FALSE;
	for( int i = CAREL_THREAD_START; i < g_nCarelIndex; i++ )
	{
		if( g_strPort[i].Compare(strPort) == 0 )
		{
			bResult = TRUE;
			break;
		}
	}
	return bResult;
}

BOOL FindScanTakCommPort(CString strPort)
{
	BOOL bResult = FALSE;
	for( int i = SCANTAK_THREAD_START; i < g_nScantakIndex; i++ )
	{
		if( g_strPort[i].Compare(strPort) == 0 )
		{
			bResult = TRUE;
			break;
		}
	}
	return bResult;
}

BOOL FindDeltaCommPort(CString strPort)
{
	BOOL bResult = FALSE;
	for( int i = DELTA_THREAD_START; i < g_nDeltaIndex; i++ )
	{
		if( g_strPort[i].Compare(strPort) == 0 )
		{
			bResult = TRUE;
			break;
		}
	}
	return bResult;
}



// 获取实际波特率
INT GetCommRate(int nRate)
{
	int nBaudRate = 9600;
	switch( nRate )
	{
	case 0:
		nBaudRate = 1200;
		break;
	case 1:
		nBaudRate = 2400;
		break;
	case 2:
		nBaudRate = 4800;
		break;
	case 3:
		nBaudRate = 9600;
		break;
	case 4:
		nBaudRate = 14400;
		break;
	case 5:
		nBaudRate = 19200;
		break;
	case 6:
		nBaudRate = 38400;
		break;
	case 7:
		nBaudRate = 57600;
		break;
	case 8:
		nBaudRate = 115200;
		break;
	case 9:
		nBaudRate = 128000;
		break;
	case 10:
		nBaudRate = 256000;
		break;
	}

	return nBaudRate;
}

// 获取实际数据位
INT GetCommDataBit(int nDataBitIndex)
{
	int nDataBit = 8;
	switch( nDataBitIndex )
	{
	case 0:
		nDataBit = 7;
		break;
	case 1:
		nDataBit = 8;
		break;
	}

	return nDataBit;
}