repos_ecs/源数据/PC环境监控/tryto v1.0.0.3/只运行 IDE/IDE/IDE.cpp

// IDE.cpp : 定义应用程序的类行为。
//

#include "stdafx.h"
//#include <vld.h>
#include "IDE.h"
#include "MainFrm.h"

#include "ChildFrm.h"
#include "IDEDoc.h"
#include "IDEView.h"
#include "SysLib.h"
#include ".\ide.h"
#include "StartupDlg.h"
#include "Login.h"
#include "gooddc.h"
#include "public.h"
#include "md5class.h"
//#include "conv.h"

#ifdef _DEBUG
#define new DEBUG_NEW
#endif

HANDLE  g_hScriptThread = NULL;		//线程对象
#if IS_MULTHREAD_REQUEST
HANDLE *g_pFreshVarThread = NULL;
#else
HANDLE g_hFreshVarThread = NULL;
HANDLE g_hFreshVarCurPicThread = NULL;
#endif
HANDLE g_hReConnectSrvThread = NULL;

INT g_nFreshVarThreadCount = 0;

DWORD WINAPI FreshVarThread( void *pData );
DWORD WINAPI FreshVarCurPicThread( void *pData );
DWORD WINAPI ReConnectSrvThread( void *pData );

extern CStringArray g_saCurPicVar;
extern CRITICAL_SECTION  g_CSLimit;
// CIDEApp

BEGIN_MESSAGE_MAP(CIDEApp, CWinApp)
	ON_COMMAND(ID_APP_ABOUT, OnAppAbout)
	// 基于文件的标准文档命令
	ON_COMMAND(ID_FILE_NEW, CWinApp::OnFileNew)
	ON_COMMAND(ID_FILE_OPEN, CWinApp::OnFileOpen)
	// 标准打印设置命令
	ON_COMMAND(ID_FILE_PRINT_SETUP, CWinApp::OnFilePrintSetup)
	ON_COMMAND(ID_APP_EXIT, OnAppExit)
END_MESSAGE_MAP()


// CIDEApp 构造

CIDEApp::CIDEApp()
{
	// TODO: 在此处添加构造代码，
	// 将所有重要的初始化放置在 InitInstance 中
}


// 唯一的一个 CIDEApp 对象

CIDEApp theApp;

CMainFrame *g_pMainFrm = NULL;

int InitClientTTS()
{
	CHAR strFile[MAX_FILE_LENGTH + 1] = "";

	wsprintf(strFile, "%s\\TTSDll.dll", g_strDirectory);
	//wsprintf(strFile, "E:\\Work\\version\\new_server\\dll\\TTSDll.dll");
	g_hTTSModule = AfxLoadLibrary(strFile);
	if (NULL != g_hTTSModule)
	{
		pStoneUDllRegisterTTS = (MySTONEU_DLLRegisterTTS)::GetProcAddress(g_hTTSModule, "STONEU_DLLRegisterTTS");
		pStoneUDllUnRegisterTTS = (MySTONEU_DLLUnRegisterTTS)::GetProcAddress(g_hTTSModule, "STONEU_DLLUnRegisterTTS");		
		pStoneUDLLTxtToWav = (MySTONEU_DLLTxtToWav)::GetProcAddress(g_hTTSModule, "STONEU_DLLTxtToWav");
	}

	if( ( NULL != g_hTTSModule ) && ( NULL != pStoneUDllRegisterTTS ) )
	{
		pStoneUDllRegisterTTS();
	}
	else
	{
		FreeLibrary( g_hTTSModule );
		g_hTTSModule = NULL;
	}

	return 0;
}

int UnInitClientTTS()
{
	if( NULL != g_hTTSModule && NULL != pStoneUDllUnRegisterTTS )
	{
		pStoneUDllUnRegisterTTS();
		AfxFreeLibrary( g_hTTSModule );
		g_hTTSModule = NULL;
	}

	return 0;
}

// CIDEApp 初始化
HANDLE hMutex;
BOOL CIDEApp::InitInstance()
{
	// 如果一个运行在 Windows XP 上的应用程序清单指定要
	// 使用 ComCtl32.dll 版本 6 或更高版本来启用可视化方式，
	//则需要 InitCommonControls()。否则，将无法创建窗口。
	CString StrName="StoneU_IDE";
	hMutex=OpenMutex(MUTEX_ALL_ACCESS,FALSE,StrName);
	if(hMutex==NULL)
	{
		hMutex=::CreateMutex(NULL,NULL,StrName);
	}
	else
	{
		MessageBox(NULL,"IDE已经打开！","温馨提示",MB_ICONINFORMATION);
		return FALSE;
	}

	InitializeCriticalSection(&g_CSLimit);
	InitCommonControls();

	CoInitialize( NULL );

	CWinApp::InitInstance();

	//// 初始化 OLE 库
	if (!AfxOleInit())
	{
		AfxMessageBox(IDP_OLE_INIT_FAILED);
		return FALSE;
	}
	AfxEnableControlContainer();
	// 标准初始化
	// 如果未使用这些功能并希望减小
	// 最终可执行文件的大小，则应移除下列
	// 不需要的特定初始化例程
	// 更改用于存储设置的注册表项
	// TODO: 应适当修改该字符串，
	// 例如修改为公司或组织名
	SetRegistryKey(g_strAppwizardCreateApp);
	LoadStdProfileSettings(4);  // 加载标准 INI 文件选项(包括 MRU)

	// START GDI+ SUB SYSTEM
	GdiplusStartup(&m_gdiplusToken, &m_gdiplusStartupInput, NULL);

	MTVERIFY( g_hRunObject = ::CreateEvent(
        NULL,           /* Security */
        TRUE,           /* Manual event */
        0,              /* Clear on creation */
        "IDE::g_hRunObject") );

	//InitPrintQueue();
	GetSysData();

	if( !g_FindProcess( "eBusShortCut.exe" ) )
	{
		CString sTemp;
		sTemp = g_strDirectory;
		sTemp += "\\eBusShortCut.exe";//
		ShellExecute( NULL, NULL, sTemp,0,NULL, SW_SHOWNORMAL );
	}

    CString strFileName;
	strFileName.Format("%s\\log4crc", g_strDirectory); 
	///设置日志配置文件名
	LOG4C_PARAM_CFG_FILE_NAME(strFileName);
	///设置日志级别
	LOG4C_PARAM_LOG_LEVEL("unknown");
	///设置日志文件大小
	LOG4C_PARAM_LOG_FILE_SIZE(10240);
	///设置生成日志文件个数，达到最大个数将自动覆盖最旧的日志
	LOG4C_PARAM_LOG_FILE_NUM(5);
	///设置每次记录日志都重新读取日志配置文件
	LOG4C_PARAM_REREAD_LOG_CFG_FILE(1);
	///带参数日志模块初始化,以上所有设置了的参数都将生效，没有设置的采用缺省值
	LOG4C_INIT_WITH_PARAM();

	LOG4C((LOG_NOTICE, "系统成功启动!"));

	CHAR strFile[MAX_FILE_LENGTH + 1] = "";
 	if( strcmp(g_strLanguage, "CHS") == 0 )
	{
		wsprintf(strFile, "%s\\ChineseRes.dll", g_strDirectory);
	}
	else if( strcmp(g_strLanguage, "CHT") == 0 )
	{
		wsprintf(strFile, "%s\\TaiwanRes.dll", g_strDirectory);
	}
	else if( strcmp(g_strLanguage, "ENG") == 0 )
	{
		wsprintf(strFile, "%s\\EnglishRes.dll", g_strDirectory);
	}
	
	g_hLangDLL = ::LoadLibrary(strFile);
	AfxSetResourceHandle(g_hLangDLL);

	GetResourceString();

	if( g_nIsDemo == 0 )
	{
		if( !CDBConnection::GetInstancePtr()->OpenDataBase(g_strConnectString) )
		{
			MessageBox(NULL,g_strMsgDBConnectionFail, g_strTip, MB_ICONWARNING);
			return FALSE;
		}
		CDBConnection::GetInstancePtr()->DBConnectionCheckThreadStart();
		CDBInterface::GetInstancePtr()->SetDBType(g_strDBType);
	}

	CStartupDlg dlg;
	dlg.Create(IDD_STARTUP);
	char* lpBmpFile = "Bitmap\\tryto.bmp";
	BITMAPFILEHEADER bf;
	BITMAPINFOHEADER bi;
	FILE* fp = fopen(lpBmpFile,"rb");
	if (fp)
	{
		fread(&bf,sizeof(bf),1,fp);
		fread(&bi,sizeof(bi),1,fp);
		fclose(fp);
		int nCX = GetSystemMetrics(SM_CXSCREEN);
		int nCY = GetSystemMetrics(SM_CYSCREEN);
		int nW = bi.biWidth;
		int nH = bi.biHeight;
		dlg.MoveWindow((nCX-nW)/2,(nCY-nH)/2,nW,nH);
	}
	dlg.ShowWindow(TRUE);
	CDC* pDC = dlg.GetDC();
	CRect rect;
	dlg.GetClientRect(rect);
	
	int screenx=GetSystemMetrics(SM_CXSCREEN);
	int screeny=GetSystemMetrics(SM_CYSCREEN);
	DisplayBMP(pDC, 0, 0, rect.Width(), rect.Height(), lpBmpFile, FALSE);

	dlg.ReleaseDC(pDC);
	Sleep(3000);
	dlg.ShowWindow(FALSE);

	PMS_InitSDK();
	CDBInterface::GetInstancePtr()->AddGroupToDll();
	CDBInterface::GetInstancePtr()->AddUserToDll();

	if( g_nIsDemo == 0 )
	{
		// 登录
		int nRet = IsNoDlgLogin();
		if( nRet!=1 )
		{
			CLogin udlg;
			if( udlg.DoModal() != IDOK )
			{
				return FALSE;
			}

			CString sContent;
			sContent.Format("用戶< %s >登录",udlg.m_sUserID );
			CDBInterface::GetInstancePtr()->InsertLogRecord( LOG_LOGIN,0,"",(char *)(LPCTSTR)sContent );

			//检查控制，设置是否有密码
			CHAR strFile[MAX_FILE_LENGTH + 1] = "";
			wsprintf(strFile, "%s\\clientset.ini", g_strDirectory);

			CHAR strPwd[MAX_PASSWORD_LENGTH + 1] = "";				
			GetPrivateProfileString("User", "ControlPwd","", strPwd,sizeof(strPwd), strFile );
			if( (CString)strPwd=="d41d8cd98f00b204e9800998ecf8427e" )
				g_bHaveControlPwd = false;
		}
	}
	if( g_nIsDemo == 0 )
	{
		if( g_nAlarmModeIsSound == 1 )
		{
			InitClientTTS(); 
		}
	}

	// 注册应用程序的文档模板。文档模板
	// 将用作文档、框架窗口和视图之间的连接
	CMultiDocTemplate* pDocTemplate;
	pDocTemplate = new CMultiDocTemplate(IDR_MAINFRAME,
		RUNTIME_CLASS(CIDEDoc),
		RUNTIME_CLASS(CChildFrame), // 自定义 MDI 子框架
		RUNTIME_CLASS(CIDEView));
	AddDocTemplate(pDocTemplate);

	// 创建主 MDI 框架窗口
	CMainFrame* pMainFrame = new CMainFrame;
	pMainFrame->m_pDoc = (CIDEDoc *)pDocTemplate->CreateNewDocument();
	if (!pMainFrame || !pMainFrame->LoadFrame(IDR_MAINFRAME))
	{
		MessageBox(NULL,"资源文件不对1", g_strTip, MB_ICONWARNING);
		return FALSE;
	}
	m_pMainWnd = pMainFrame;


	// 仅当具有后缀时才调用 DragAcceptFiles
	// 在 MDI 应用程序中，这应在设置 m_pMainWnd 之后立即发生
	// 分析标准外壳命令、DDE、打开文件操作的命令行
	CCommandLineInfo cmdInfo;
	ParseCommandLine(cmdInfo);
	// 调度在命令行中指定的命令。如果
	// 用 /RegServer、/Register、/Unregserver 或 /Unregister 启动应用程序，则返回 FALSE。
	cmdInfo.m_nShellCommand = CCommandLineInfo::FileNothing;
	if (!ProcessShellCommand(cmdInfo))
	{
		MessageBox(NULL,"资源文件不对2", g_strTip, MB_ICONWARNING);
		return FALSE;
	}

	// 主窗口已初始化，因此显示它并对其进行更新
	m_pMainWnd->SetWindowText(g_strStoneuIspcms);
	pMainFrame->ShowWindow(m_nCmdShow);
	//if( g_bFullScreen )
	//{
	//	m_pMainWnd->ShowWindow(SW_SHOWMAXIMIZED);//窗口最大化 关于全屏
	//}
	pMainFrame->UpdateWindow();

	g_pMainFrm = pMainFrame;

	if( g_nIsDemo == 0 )
	{
#if IS_MULTHREAD_REQUEST	
		// 每个串口或IP 一个变量刷新线程
		int nFreshVarThreadCount = 0;
		int nChannelSize = pDevicesManager->m_channels.GetSize();
		for( int i = 0; i < nChannelSize; i++ )
		{
			CChannel *pChannel = pDevicesManager->m_channels[i];
			int nDeviceSize = pChannel->m_Devices.GetSize();
			for( int j = 0; j < nDeviceSize; j++ )
			{
				CDevice *pDevice = pChannel->m_Devices[j];
				nFreshVarThreadCount++;
			}
		}

		g_pFreshVarThread = new HANDLE[nFreshVarThreadCount];
		for( int i = 0; i < nChannelSize; i++ )
		{
			CChannel *pChannel = pDevicesManager->m_channels[i];
			int nDeviceSize = pChannel->m_Devices.GetSize();
			for( int j = 0; j < nDeviceSize; j++ )
			{
				CDevice *pDevice = pChannel->m_Devices[j];
				MTVERIFY( g_pFreshVarThread[g_nFreshVarThreadCount] = 
					::CreateThread(
									NULL, 
									0, 
									FreshVarThread, 
									(char *)(LPCTSTR)pDevice->m_strUID, 
									0, 
									0) );
				g_nFreshVarThreadCount++;
			}
		}
#else
		//MTVERIFY( g_hFreshVarThread = 
		//	::CreateThread(
		//					NULL, 
		//					0, 
		//					FreshVarThread, 
		//					0, 
		//					0, 
		//					0) );

		MTVERIFY( g_hFreshVarCurPicThread = 
			::CreateThread(
							NULL, 
							0, 
							FreshVarCurPicThread, 
							0, 
							0, 
							0) );
#endif

		MTVERIFY( g_hReConnectSrvThread = ::CreateThread(NULL, 0, ReConnectSrvThread, 0, 0, 0) );

		DWORD thredid;
		g_hScriptThread = (HANDLE) ::CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)ScriptRunProc,NULL,0,&thredid);		//脚本处理
	}

	return TRUE;
}

int CIDEApp::ExitInstance()
{
	// TODO: 在此添加专用代码和/或调用基类
	LOG4C((LOG_NOTICE, "ExitInstance!"));

	if( g_hRunObject )
		MTVERIFY( SetEvent( g_hRunObject ) );

	if( pDevicesManager != NULL )
	{
		if( g_nIsDemo == 0 )
		{
			//if (g_bStartRun)
			{
#if 1
				for( int iPortIndex=0;iPortIndex<2;iPortIndex++ )
				{
					CString sPortTemp;
					sPortTemp.Format("%d",atoi(g_strServerPort)+iPortIndex );
					pDevicesManager->DisConnection(sPortTemp);
				}
#else
				int nVarSize = pVariantsManager->m_analog.GetSize();
				int nVarUseSize=0;
				for( int i=0;i<nVarSize;i++ )
				{
					if( pVariantsManager->m_analog.GetAt(i)->m_pDevice==NULL )
						continue;
					if( pVariantsManager->m_analog.GetAt(i)->m_pDevice->m_bUsed )
						nVarUseSize++;
				}
				int nPortSize = nVarUseSize/VARNUM2PORT;
				if( nPortSize%VARNUM2PORT==0 && nPortSize>0 )
					nPortSize--;
				for( int iPortIndex=0;iPortIndex<=nPortSize;iPortIndex++ )
				{
					CString sPortTemp;
					sPortTemp.Format("%d",atoi(g_strServerPort)+iPortIndex );
					pDevicesManager->DisConnection(sPortTemp);
				}
#endif
			}
		}

	}
	if( g_nIsDemo == 0 )
	{
		if( g_nAlarmModeIsSound == 1 )
		{
			UnInitClientTTS();
		}
		if( g_hScriptThread != NULL )
		{
			if( g_hScriptThread )
			{
				MTVERIFY( WaitForSingleObject( g_hScriptThread, INFINITE ) != WAIT_FAILED );
				MTVERIFY( CloseHandle(g_hScriptThread) );
			}
			g_hScriptThread = NULL;

			// 清除脚本队列
			POSITION pos = g_ScriptParamList.GetHeadPosition();
			while (pos != NULL)
			{
				POSITION tmpPos = pos;
				ScriptParam* pScriptParam = g_ScriptParamList.GetNext( pos );
				g_ScriptParamList.RemoveAt( tmpPos );
				delete pScriptParam; 
			}
		}

#if IS_MULTHREAD_REQUEST
		for( int i = 0; i < g_nFreshVarThreadCount; i++ )
		{
			if( g_pFreshVarThread[i] != NULL )
			{
				MTVERIFY( WaitForSingleObject( g_pFreshVarThread[i], INFINITE ) != WAIT_FAILED );
				MTVERIFY( CloseHandle( g_pFreshVarThread[i] ) );
				g_pFreshVarThread[i] = NULL;
			}
		}

		if( g_pFreshVarThread )
		{
			delete []g_pFreshVarThread;
			g_pFreshVarThread = NULL;
		}
#else
		if( g_hFreshVarThread != NULL )
		{
			MTVERIFY( WaitForSingleObject( g_hFreshVarThread, INFINITE ) != WAIT_FAILED );
			MTVERIFY( CloseHandle( g_hFreshVarThread ) );
			g_hFreshVarThread = NULL;
		}
		if( g_hFreshVarCurPicThread != NULL )
		{
			MTVERIFY( WaitForSingleObject( g_hFreshVarCurPicThread, INFINITE ) != WAIT_FAILED );
			MTVERIFY( CloseHandle( g_hFreshVarCurPicThread ) );
			g_hFreshVarCurPicThread = NULL;
		}
#endif

		if( g_hReConnectSrvThread != NULL )
		{
			MTVERIFY( WaitForSingleObject( g_hReConnectSrvThread, INFINITE ) != WAIT_FAILED );
			MTVERIFY( CloseHandle( g_hReConnectSrvThread ) );
			g_hReConnectSrvThread = NULL;
		}
	}
	if( pDevicesManager != NULL )
	{
		//chn mem
#if 1
		for( int iPortIndex=0;iPortIndex<2;iPortIndex++ )
		{
			CString sPortTemp;
			sPortTemp.Format("%d",atoi(g_strServerPort)+iPortIndex );
			pDevicesManager->Release( sPortTemp );
		}
#else
		int nVarSize = pVariantsManager->m_analog.GetSize();
		int nVarUseSize=0;
		for( int i=0;i<nVarSize;i++ )
		{
			if( pVariantsManager->m_analog.GetAt(i)->m_pDevice==NULL )
				continue;
			if( pVariantsManager->m_analog.GetAt(i)->m_pDevice->m_bUsed )
				nVarUseSize++;
		}
		int nPortSize = nVarUseSize/VARNUM2PORT;
		if( nPortSize%VARNUM2PORT==0 && nPortSize>0 )
			nPortSize--;
		for( int iPortIndex=0;iPortIndex<=nPortSize;iPortIndex++ )
		{
			CString sPortTemp;
			sPortTemp.Format("%d",atoi(g_strServerPort)+iPortIndex );
			pDevicesManager->Release( sPortTemp );
		}
#endif
		delete pDevicesManager;
		pDevicesManager = NULL;
	}

	//chn mem
	CDBInterface::GetInstancePtr()->Release();

	if( pVariantsManager != NULL )
	{
		delete pVariantsManager;
		pVariantsManager = NULL;
	}

	if( pEventServer != NULL )
	{
		delete pEventServer;
		pEventServer = NULL;
	}

	if( g_hRunObject )
		MTVERIFY( CloseHandle( g_hRunObject ) );

	//UninitPrintQueue();
	if( g_nIsDemo == 0 )
	{
		CDBConnection::GetInstancePtr()->DBConnectionCheckThreadStop();
		//DBConnectionThreadEnd();

		//chn mem
		CDBConnection::GetInstancePtr()->Release();
	}

	if(g_hLangDLL)
	{
		AfxFreeLibrary(g_hLangDLL);
	}
	
	LOG4C((LOG_NOTICE, "系统成功退出!"));

	///关闭日志模块防止内存/资源泄漏
	LOG4C_FINI(); 

	// Shutdown GDI+ subystem
	GdiplusShutdown(m_gdiplusToken);

	//释放权限所占的内存
	PMS_UnInitSDK();

	::CloseHandle( hMutex );
	hMutex = NULL;

	DeleteCriticalSection( &g_CSLimit );

	CoUninitialize();
	
	return CWinApp::ExitInstance();
}

void CIDEApp::OnAppExit()
{
	// TODO: 在此添加命令处理程序代码
	CMainFrame *pMainFrm=(CMainFrame*)m_pMainWnd;
	pMainFrm->m_nViewCount = 0;
	pMainFrm->OnSuperEnd();	
}


// 用于应用程序“关于”菜单项的 CAboutDlg 对话框

class CAboutDlg : public CDialog
{
public:
	CAboutDlg();

// 对话框数据
	enum { IDD = IDD_ABOUTBOX };

protected:
	virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV 支持

// 实现
protected:
	DECLARE_MESSAGE_MAP()
public:
	virtual BOOL OnInitDialog();
};

CAboutDlg::CAboutDlg() : CDialog(CAboutDlg::IDD)
{
}

void CAboutDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialog::DoDataExchange(pDX);
}

BOOL CAboutDlg::OnInitDialog()
{
	CDialog::OnInitDialog();

	// TODO:  在此添加额外的初始化
	CString str;
	str.Format("Ver：%s",g_strVersion );
	GetDlgItem(IDC_STA_VERSION)->SetWindowText(str);

	return TRUE;  // return TRUE unless you set the focus to a control
	// 异常: OCX 属性页应返回 FALSE
}

BEGIN_MESSAGE_MAP(CAboutDlg, CDialog)
END_MESSAGE_MAP()

// 用于运行对话框的应用程序命令
void CIDEApp::OnAppAbout()
{
	CAboutDlg aboutDlg;
	aboutDlg.DoModal();
}

// My:向服务器请求视图的最新值;
DWORD WINAPI FreshVarThread( void *pData )
{
#if IS_MULTHREAD_REQUEST
	CString strUid = CString((char *)pData);
#else
	CString strUid = "";
#endif
	do
	{
		if (g_bStartRun)
		{
			if( g_bRun )
			{
				//TRACE("设备Uid=%s\r\n", strUid);
				pVariantsManager->Fresh(strUid);
			}
		}
		Sleep(10);
	}while( WaitForSingleObject( g_hRunObject, 10L ) == WAIT_TIMEOUT );
	
	return 0;
}

//读取当前画面的变量  ....My:向服务器请求当前画面最新的变量值;
DWORD WINAPI FreshVarCurPicThread( void *pData )
{
#if IS_MULTHREAD_REQUEST
	CString strUid = CString((char *)pData);
#else
	CString strUid = "";
#endif
	do
	{
		if (g_bStartRun)
		{
			if( g_bRun )
			{
				//TRACE("设备Uid=%s\r\n", strUid);
				EnterCriticalSection( &g_CSLimit );
				pVariantsManager->FreshCurPic( g_saCurPicVar );
				LeaveCriticalSection( &g_CSLimit );
			}
		}
		Sleep(10);
	}while( WaitForSingleObject( g_hRunObject, 10L ) == WAIT_TIMEOUT );
	
	return 0;
}

// My:
DWORD WINAPI ReConnectSrvThread( void *pData )
{
	do
	{
		//if (g_bStartRun)
		{
#if 1
			for( int iPortIndex=0;iPortIndex<2;iPortIndex++ )
			{
				CString sPortTemp;
				sPortTemp.Format("%d",atoi(g_strServerPort)+iPortIndex );

				// 判断与服务Socket的连接状态;
				if( FALSE == pDevicesManager->GetSocketStatus(sPortTemp) )
				{
					pVariantsManager->SetSysComunicationVar( 1.0 );

					if( pDevicesManager->GetOpenStatus(sPortTemp) == TRUE )
					{
						pDevicesManager->DisConnection(sPortTemp);
					}

					if( !pDevicesManager->Connection(g_strServerIP, sPortTemp) )
					{
						pDevicesManager->SetSocketStatus(FALSE,sPortTemp);
					}
					else
					{
						pVariantsManager->SetSysComunicationVar( 0.0 );
						pDevicesManager->SetSocketStatus(TRUE,sPortTemp);
					}
				}
			}
#else
			int nVarSize = pVariantsManager->m_analog.GetSize();
			int nVarUseSize=0;
			for( int i=0;i<nVarSize;i++ )
			{
				if( pVariantsManager->m_analog.GetAt(i)->m_pDevice==NULL )
					continue;
				if( pVariantsManager->m_analog.GetAt(i)->m_pDevice->m_bUsed )
					nVarUseSize++;
			}
			int nPortSize = nVarUseSize/VARNUM2PORT;
			if( nPortSize%VARNUM2PORT==0 && nPortSize>0 )
				nPortSize--;
			for( int iPortIndex=0;iPortIndex<=nPortSize;iPortIndex++ )
			{
				CString sPortTemp;
				sPortTemp.Format("%d",atoi(g_strServerPort)+iPortIndex );

				if( FALSE == pDevicesManager->GetSocketStatus(sPortTemp) )
				{
					pVariantsManager->SetSysComunicationVar( 1.0 );

					if( pDevicesManager->GetOpenStatus(sPortTemp) == TRUE )
					{
						pDevicesManager->DisConnection(sPortTemp);
					}

					if( !pDevicesManager->Connection(g_strServerIP, sPortTemp) )
					{
						pDevicesManager->SetSocketStatus(FALSE,sPortTemp);
					}
					else
					{
						pVariantsManager->SetSysComunicationVar( 0.0 );
						pDevicesManager->SetSocketStatus(TRUE,sPortTemp);
					}
				}
			}
#endif
		}
		//Sleep(2000);
	}while( WaitForSingleObject( g_hRunObject, 125L ) == WAIT_TIMEOUT );

	return 0;
}

// CIDEApp 消息处理程序

int CIDEApp::IsNoDlgLogin()//是否是没对话框登录 -1：不是 0：失败 1：成功
{
	int nRet = -1;

	CHAR strFile[MAX_FILE_LENGTH + 1] = "";
	wsprintf(strFile, "%s\\clientset.ini", g_strDirectory);

	char RUN[MAX_PATH] = {0};
	memset(RUN, 0, sizeof(RUN));

	//是否是没对话框登录
	if ( GetPrivateProfileString("User", "NoDlgLogin","",RUN, 10, strFile) != 0)
	{
		if( RUN[0] == '0' )
			return nRet;
	}
	WritePrivateProfileString("User", "NoDlgLogin", "0", strFile);

	GetPrivateProfileString("User", "UserID","", g_strLoginUserID,sizeof(g_strLoginUserID), strFile );
	memset(g_strDefaultUserID, 0, sizeof(g_strDefaultUserID) );
	strcpy(g_strDefaultUserID, g_strLoginUserID);

	GetPrivateProfileString("User", "UserPwd","", g_strLoginPwd,sizeof(g_strLoginPwd), strFile );
	memset(g_strDefaultUserPwd, 0, sizeof(g_strDefaultUserPwd) );
	strcpy(g_strDefaultUserPwd, g_strLoginPwd);

	CString sUserID,sUserPwd;
	sUserID = g_strLoginUserID;
	sUserPwd = g_strLoginPwd;
	if( sUserID=="" || sUserPwd=="" )
		return nRet;
	///////////////////////////////////////////////////////////////////////////////
	char Path[_MAX_PATH] = {0};
	strcat(Path, g_strDirectory);
    strcat(Path,"\\");
	strcat(Path, _PROJECTDIR);
	strcat(Path,"\\");
	strcat(Path, "runpara.ini");
	
	//CString str;

	if ( GetPrivateProfileString("RUNPARA", "STARTRUN","",RUN, 10, Path) != 0)
	{
		g_bStartRun = (RUN[0] == '1' ? true:false);
	}

	if ( GetPrivateProfileString("RUNPARA", "FULLSCREEN","",RUN, 10, Path) != 0)
	{
		g_bFullScreen = RUN[0] == '1' ? true:false;
	}

	CMD5 md5;
	md5.setPlainText( (char *)(LPCTSTR)sUserPwd );
	
	if( ( ( strcmp(g_strDefaultUserPwd, "") != 0 ) && (strcmp(g_strLoginUserID, (char*)(LPCTSTR)sUserID) != 0 ) ) ||
		( strcmp(g_strDefaultUserPwd, "") == 0 ) ||
		(strcmp(g_strLoginUserID, (char*)(LPCTSTR)sUserID) != 0 ) ||
		( strcmp(g_strDefaultUserPwd, sUserPwd) != 0 ) ||
		(strcmp(g_strLoginUserID, "") == 0) )
	{
		sUserPwd = CString(md5.getMD5Digest());
	}

	
	nRet = CDBInterface::GetInstancePtr()->ValidateUser((char*)(LPCTSTR)sUserID, (char *)(LPCTSTR)sUserPwd);
	//LOG4C((LOG_NOTICE, "ValidateUser return %d", nRet));
	if( nRet < 1 )
	{
		MessageBox(NULL,g_strMsgUserInvalid, g_strTip, MB_ICONWARNING);
		return 0;
	}

	CHAR chStatus[MAX_STATUS_LENGTH + 1] = {0};
	CDBInterface::GetInstancePtr()->ValidateUserEnable( (char*)(LPCTSTR)sUserID, chStatus );
	if( atoi(chStatus) == 1 )
	{
		MessageBox(NULL,g_strMsgUserDisable, g_strTip, MB_ICONWARNING);
		return 0;
	}

	//cHn add
	CDBInterface::GetInstancePtr()->GetUserIDByName( sUserID,g_nUserID );
	if( g_bStartRun==0 && -1==PMS_VerifyUserPermit( g_nUserID,PMS_EDIT_STATUS_MANAGE,"" ) )
	{
		MessageBox(NULL,g_strNoPermit, g_strTip, MB_ICONWARNING);
		return 0;
	}

	return 1;
}