repos_ecs/源数据/PC环境监控/MostDevice_94273/MostDevice/CommProcess.cpp

// CommProcess.cpp: implementation of the CCommProcess class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "CommProcess.h"

#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

CCommProcess::CCommProcess()
{
	m_hCom = INVALID_HANDLE_VALUE;
	m_bOpen=FALSE;
}

CCommProcess::~CCommProcess()
{

}

BOOL CCommProcess::OpenComm(PPORTPARAM pPortParam)
{
	m_bOpen=FALSE;
	ASSERT(pPortParam!=NULL);
	if(pPortParam==NULL)
		return FALSE;

	COMMTIMEOUTS   timeout;
	DCB dcb;
	BOOL result;
	int temp=0;
	char tmp[20]="\\\\.\\com";
	char buffer[20];

	m_nPort=pPortParam->PortNo;

	_itoa(m_nPort,buffer,10);
	strcat(tmp,buffer);

	m_hCom = CreateFile(tmp, GENERIC_READ | GENERIC_WRITE,
		0, NULL, OPEN_EXISTING, NULL , NULL);

	int ilastEr = GetLastError();
	//LOG4C((LOG_NOTICE , "CCommProcess::OpenComm Com%d Er = %d",m_nPort,ilastEr));
	if(m_hCom==INVALID_HANDLE_VALUE) 
	{
		//AfxMessageBox( "端口不存在或已坏！" , MB_OK , 0 );
//		ErrorProcess();
		LOG4C((LOG_NOTICE , "CCommProcess::端口不存在或已坏"));
		return FALSE;
	}

	result=SetupComm(m_hCom,1024,1024);
	ASSERT(result);
	if(!result)
		return FALSE;

	result=PurgeComm(m_hCom,PURGE_TXCLEAR|PURGE_RXCLEAR);
	ASSERT(result);
	if(!result)
		return FALSE;

	result=GetCommState(m_hCom, &dcb);
	ASSERT(result);
	if(!result)
		return FALSE;

	dcb.Parity=pPortParam->Parity;
	if(dcb.Parity==NOPARITY)
		dcb.fParity=FALSE;
	else
		dcb.fParity=TRUE;

	//ONESTOPBIT;
	//ONE5STOPBITS;
	//TWOSTOPBITS;

	dcb.BaudRate=pPortParam->BaudRate;
	dcb.ByteSize=pPortParam->ByteSize;
	dcb.StopBits=pPortParam->StopBits;
	if(dcb.ByteSize==8)
		dcb.StopBits=ONESTOPBIT;

	result=SetCommState(m_hCom, &dcb);
	ASSERT(result);
	if(!result)
		return FALSE;

	result=GetCommTimeouts(m_hCom, &timeout);
	ASSERT(result);
	if(!result)
		return FALSE;

	timeout.ReadIntervalTimeout=MAXDWORD;
	timeout.ReadTotalTimeoutMultiplier=0;
	timeout.ReadTotalTimeoutConstant=0;

	timeout.WriteTotalTimeoutMultiplier=0;
	timeout.WriteTotalTimeoutConstant=0;

	result=SetCommTimeouts(m_hCom,&timeout);
	ASSERT(result);
	if(!result)
		return FALSE;

	m_bOpen=TRUE;

	return TRUE;
}

BOOL CCommProcess::CloseComm()
{
	m_bOpen=FALSE;
	if( m_hCom != INVALID_HANDLE_VALUE )
	{
		BOOL bResult = CloseHandle( m_hCom );
		if( !bResult )
		{
			return FALSE;
		}
	}

	m_hCom = INVALID_HANDLE_VALUE;
	return TRUE;
}

int CCommProcess::Read(BYTE *pBuf, int len)
{
	DWORD nTick = GetTickCount();
	if(m_hCom == INVALID_HANDLE_VALUE) 
	{
		return 0;
	}
	if( pBuf == NULL || !::AfxIsValidAddress(pBuf, len, FALSE ) ) 
	{
		return 0;
	}
	if( !m_bOpen ) 
	{
		return 0;
	}

	BOOL bReadStatus;
	DWORD dwBytesRead, dwErrorFlags;
	COMSTAT ComStat;

	ClearCommError( m_hCom, &dwErrorFlags, &ComStat );
	while( ComStat.cbInQue != len ) 
	{
		if( GetTickCount() - nTick > 3000 ) break;
		ClearCommError( m_hCom, &dwErrorFlags, &ComStat );
		Sleep(150);
	}
	//if( !ComStat.cbInQue ) return( 0 );

	dwBytesRead = (DWORD) ComStat.cbInQue;
	if( len < (int) dwBytesRead ) dwBytesRead = (DWORD) len;

	bReadStatus = ReadFile( m_hCom, pBuf, dwBytesRead, &dwBytesRead , NULL);
	if( !bReadStatus )
	{
		DWORD dwError;
		dwError = GetLastError();
		CString strMsg;
		strMsg.Format("ReadFile Error! ErrorCode = %d", dwError);

		PurgeComm(m_hCom, PURGE_TXABORT|
			PURGE_RXABORT|PURGE_TXCLEAR|PURGE_RXCLEAR);
		return 0;
	}

	PurgeComm(m_hCom, PURGE_TXABORT|
		PURGE_RXABORT|PURGE_TXCLEAR|PURGE_RXCLEAR);
	return( (int) dwBytesRead );
}

int CCommProcess::Write(BYTE *pBuf, int len)
{
	if( !m_bOpen )
	{
		return 0;
	}

	if(m_hCom == INVALID_HANDLE_VALUE || len<=0)
	{
		return 0;
	}

	Sleep(100);
	DWORD dwResult = 0; 
	BOOL bResult=WriteFile( m_hCom, pBuf, (DWORD)len, &dwResult, NULL );
	if(bResult)
	{
		return dwResult;
	}
	else
	{
		return 0;
	}
}