#pragma once
|
/*
|
*
|
* ´®¿ÚͨѶͷÎļþ
|
*
|
* Version: V1.01
|
* Date: 2015-06-30
|
* Description:
|
* 2015-07-10 Add Speed Function;
|
* 2015-07-24 ÓÅ»¯ËٶȼÆË㣬ÿ1ÃëÒ»´Î¸ÄΪÿ°ëÃëÒ»´Î
|
*/
|
inline double GetTimeMs()
|
{
|
LARGE_INTEGER perfreq;
|
LARGE_INTEGER percounter1;
|
QueryPerformanceFrequency(&perfreq);
|
QueryPerformanceCounter(&percounter1);
|
|
double time1=(double)percounter1.QuadPart/perfreq.QuadPart;
|
return (time1*1000);
|
};
|
|
class CSerialCom
|
{
|
public:
|
enum Results {
|
R_OK,
|
R_ERR,
|
};
|
HANDLE hCom1;
|
int IsOpened;
|
|
int Port;
|
int BaudRate;
|
CString Settings;
|
|
DWORD dwError;
|
CString strResult;
|
int m_nCountToTry = 2;
|
int m_nCountToWait = 0;
|
|
volatile DWORD TotalSendBytes,TotalRecvBytes;
|
volatile DWORD SendBytes,RecvBytes;
|
volatile DWORD LastSendBytes,LastRecvBytes;
|
volatile DWORD SendSpeed,RecvSpeed;
|
volatile double LastTime;
|
CSerialCom(void)
|
{
|
this->hCom1=INVALID_HANDLE_VALUE;
|
this->IsOpened=0;
|
|
this->Port=0;
|
this->BaudRate=0;
|
this->Settings.Empty();
|
|
this->dwError=0;
|
};
|
~CSerialCom(void)
|
{
|
if (this->IsOpened) {this->Close();}
|
this->hCom1=INVALID_HANDLE_VALUE;
|
};
|
|
int Open()
|
{
|
int j;
|
CString s1,s2;
|
CString ComPortName;
|
if (this->Port==0) {return 0;}
|
if (this->IsOpened) {return -1;}
|
ComPortName.Format(_T("\\\\.\\COM%d"),this->Port);
|
hCom1=CreateFile(ComPortName,GENERIC_READ|GENERIC_WRITE,0,NULL,OPEN_EXISTING,0,NULL);//FILE_ATTRIBUTE_NORMAL|FILE_FLAG_OVERLAPPED
|
if (hCom1==INVALID_HANDLE_VALUE)
|
{
|
dwError=GetLastError();
|
IsOpened=false;
|
FormatMessage(FORMAT_MESSAGE_FROM_SYSTEM,0,dwError,0,s1.GetBuffer(2048),2048,NULL);
|
s1.ReleaseBuffer();
|
|
strResult.Format(_T("Open COM%d Err %d ,%s "),this->Port,this->dwError,s1);
|
return 0;
|
}
|
else
|
{
|
dwError=GetLastError();
|
|
strResult.Format(_T("COM%d OK."),this->Port);
|
LastTime = GetTimeMs();
|
TotalSendBytes = 0; TotalRecvBytes = 0;
|
LastSendBytes = 0; SendBytes = 0; RecvBytes = 0;
|
LastRecvBytes = 0; SendSpeed = 0; RecvSpeed = 0;
|
}
|
|
j=SetupComm(hCom1,256,256);
|
|
DCB dcb1;
|
j=GetCommState(hCom1,&dcb1);
|
BuildCommDCB(Settings,&dcb1);
|
|
dcb1.BaudRate=BaudRate;
|
|
if (Settings.Find(_T("8")) != -1) { dcb1.ByteSize = 8; }
|
else if (Settings.Find(_T("7")) != -1) { dcb1.ByteSize = 8; }
|
else if (Settings.Find(_T("6")) != -1) { dcb1.ByteSize = 8; }
|
else if (Settings.Find(_T("5")) != -1) { dcb1.ByteSize = 8; }
|
|
if (Settings.Find(_T("N")) != -1) { dcb1.fParity = FALSE; dcb1.Parity = NOPARITY;}
|
else if (Settings.Find(_T("O")) != -1) { dcb1.fParity = TRUE; dcb1.Parity = ODDPARITY;}
|
else if (Settings.Find(_T("E")) != -1) { dcb1.fParity = TRUE; dcb1.Parity = EVENPARITY;}
|
else if (Settings.Find(_T("M")) != -1) { dcb1.fParity = TRUE; dcb1.Parity = MARKPARITY;}
|
else if (Settings.Find(_T("S")) != -1) { dcb1.fParity = TRUE; dcb1.Parity = SPACEPARITY;}
|
|
if (Settings.Find(_T("1.5")) != -1) { dcb1.StopBits = ONE5STOPBITS;}
|
else if (Settings.Find(_T("1")) != -1) { dcb1.StopBits = ONESTOPBIT; }
|
else if (Settings.Find(_T("2")) != -1) { dcb1.StopBits = TWOSTOPBITS; }
|
|
dcb1.fDtrControl=0;
|
dcb1.fDsrSensitivity=false;
|
dcb1.fBinary=1;
|
dcb1.fOutxCtsFlow=false;
|
dcb1.fOutxDsrFlow=false;
|
dcb1.fRtsControl=RTS_CONTROL_DISABLE;
|
|
j=SetCommState(hCom1,&dcb1);
|
if (j == 0)
|
{
|
strResult.Format(_T("SetCommState Fail %d %s \r\n"),BaudRate,Settings);
|
CloseHandle(hCom1);
|
IsOpened = false;
|
return 0;
|
}
|
j=GetCommState(hCom1,&dcb1);
|
|
CString strParity;
|
CString strStopBit;
|
|
if (dcb1.Parity == NOPARITY) { strParity = _T("N"); }
|
else if (dcb1.Parity == EVENPARITY) { strParity = _T("E"); }
|
else if (dcb1.Parity == ODDPARITY) { strParity = _T("O"); }
|
else if (dcb1.Parity == MARKPARITY) { strParity = _T("M"); }
|
else if (dcb1.Parity == SPACEPARITY) { strParity = _T("S"); }
|
else { strParity = _T("X"); }
|
|
if (dcb1.StopBits == ONESTOPBIT) { strStopBit = _T("1"); }
|
else if (dcb1.StopBits == ONE5STOPBITS) { strStopBit = _T("1.5"); }
|
else if (dcb1.StopBits == TWOSTOPBITS) { strStopBit = _T("2"); }
|
else { strStopBit = _T("3"); }
|
|
s1.Format(_T("%d %d-%s-%s"), dcb1.BaudRate,dcb1.ByteSize, strParity, strStopBit);
|
strResult += s1;
|
|
COMMTIMEOUTS comtimeout1;
|
COMSTAT comstat1;
|
GetCommTimeouts(hCom1,&comtimeout1);
|
|
comtimeout1.ReadIntervalTimeout=1; //Á½¸ö×Ö·ûÖ®¼äµÄʱ¼ä
|
comtimeout1.ReadTotalTimeoutMultiplier=0; //ÿ¸ö×Ö·ûµÈ´ýµÄʱ¼ä£¬¶Á¶à¸ö×Ö·ûÔòµÈ´ýʱ¼äΪµ¥¸öʱ¼ä³ËÒÔ×Ö·û¸öÊý
|
comtimeout1.ReadTotalTimeoutConstant=1; //¶Áȡʱ£¬ÔÙÁíÍâ¶àµÈ´ýµÄʱ¼ä¡£
|
comtimeout1.WriteTotalTimeoutMultiplier=0; //дÈëʱ£¬Ã¿¸ö×Ö·ûµÈ´ýµÄʱ¼ä£¬Ð´Èë¶à¸ö×Ö·ûÔòµÈ´ýʱ¼äΪµ¥¸öʱ¼ä³ËÒÔ×Ö·û¸öÊý¡£
|
comtimeout1.WriteTotalTimeoutConstant=0; //дÈëʱ£¬ÔÙÁíÍâ¶àµÈ´ýµÄʱ¼ä¡£
|
|
SetCommTimeouts(hCom1,&comtimeout1);
|
j=ClearCommError(hCom1,&dwError,&comstat1);
|
s1.Format(_T("ClearCommError j %d errors %d "),j,dwError);
|
s2=s1;
|
s1.Format(_T("cbInQue %d "),comstat1.cbInQue);
|
s2+=s1;
|
s1.Format(_T("cbOutQue %d "),comstat1.cbOutQue );
|
s2+=s1;
|
|
PurgeComm(hCom1,PURGE_TXABORT|PURGE_RXABORT|PURGE_TXCLEAR|PURGE_TXCLEAR);
|
|
IsOpened = true;
|
return 1;
|
};
|
int Purge()
|
{
|
return PurgeComm(hCom1,PURGE_TXABORT|PURGE_RXABORT|PURGE_TXCLEAR|PURGE_TXCLEAR);
|
}
|
void Close()
|
{
|
LastSendBytes=0;
|
LastRecvBytes=0;
|
SendBytes=0;
|
RecvBytes=0;
|
SendSpeed=0;
|
RecvSpeed=0;
|
|
if (IsOpened)
|
{
|
IsOpened=false;
|
CString s1;
|
strResult.Format(_T("Close COM %d "),this->Port);
|
CloseHandle(hCom1);
|
}
|
};
|
int CSerialCom::CalSpeed()
|
{
|
double thistime = GetTimeMs();
|
double diftime = thistime - LastTime;
|
if (diftime >= 500)
|
{
|
SendSpeed = (DWORD)(SendBytes * 1000 / diftime);
|
RecvSpeed = static_cast<DWORD> (RecvBytes * 1000 / diftime);
|
LastSendBytes = SendBytes; SendBytes = 0;
|
LastRecvBytes = RecvBytes; RecvBytes = 0;
|
LastTime = thistime;
|
}
|
return 0;
|
}
|
int CSerialCom::Send(const char * buffer, int n)
|
{
|
CString s1;
|
int i,j;
|
DWORD numsent;
|
|
if (!IsOpened) {return 0;}
|
|
j=WriteFile(hCom1,buffer,n,&numsent,NULL);
|
|
if (j!=0)
|
{
|
strResult.Format(_T("Send To COM%d OK %dB : "),this->Port,numsent);
|
for (i=0;(unsigned )i<numsent;i++)
|
{
|
strResult.AppendFormat(_T("%c"),buffer[i]);
|
}
|
strResult.AppendFormat(_T("\r\n"));
|
}
|
else
|
{
|
dwError=GetLastError();
|
strResult.Format(_T("Send To COM%d fail. Error:%d SentBytes:%d "),this->Port,dwError,numsent);
|
}
|
SendBytes+=numsent;
|
TotalSendBytes+=numsent;
|
return numsent;
|
};
|
int CSerialCom::Read(char * buffer, int numToRead)
|
{
|
CString s1;
|
int i,j;
|
DWORD numreaded;
|
if (!IsOpened) {return 0;}
|
int len2=0;
|
//Sleep(n/10);
|
int nTryCount2 = 0;
|
for (int i = 0; i < m_nCountToTry; i++)
|
{
|
j = ReadFile(hCom1, buffer+len2, numToRead-len2, &numreaded, NULL);
|
if (j != 0){
|
len2 += numreaded;
|
buffer[len2] = 0;
|
if (len2 >= numToRead) break;
|
nTryCount2 = 0;
|
}
|
else{
|
if (len2 > 0) {
|
nTryCount2++;
|
if (nTryCount2 >= m_nCountToWait) break;
|
}
|
}
|
if (len2 > 0 && nTryCount2 >= m_nCountToWait) break;
|
}
|
numreaded = len2;
|
if (numreaded > 0){
|
strResult.Format(_T("Read From COM%d OK %dB "), this->Port, numreaded);
|
for (i = 0; (unsigned)i < numreaded; i++)
|
{
|
strResult.AppendFormat(_T("%c"), buffer[i]);
|
}
|
strResult.AppendFormat(_T("\r\n"));
|
}
|
else{
|
strResult.Format(_T("Read From COM failed \r\n"));
|
}
|
|
RecvBytes+=numreaded;
|
TotalRecvBytes+=numreaded;
|
|
return numreaded;
|
};
|
};
|
/*
|
ÓëÒÔÍùDOSÏ´®ÐÐͨÐųÌÐò²»Í¬µÄÊÇ£¬Windows²»ÌᳫӦÓóÌÐòÖ±½Ó¿ØÖÆÓ²¼þ£¬¶øÊÇͨ¹ýWindows²Ù×÷ϵͳÌṩµÄÉ豸Çý¶¯³ÌÐòÀ´½øÐÐÊý¾Ý´«µÝ¡£
|
´®ÐпÚÔÚWin 32ÖÐÊÇ×÷ΪÎļþÀ´½øÐд¦ÀíµÄ£¬¶ø²»ÊÇÖ±½Ó¶Ô¶Ë¿Ú½øÐвÙ×÷£¬¶ÔÓÚ´®ÐÐͨÐÅ£¬Win 32 ÌṩÁËÏàÓ¦µÄÎļþI/Oº¯ÊýÓëͨÐź¯Êý£¬
|
ͨ¹ýÁ˽âÕâЩº¯ÊýµÄʹÓ㬿ÉÒÔ±àÖƳö·ûºÏ²»Í¬ÐèÒªµÄͨÐųÌÐò¡£
|
ÓëͨÐÅÉ豸Ïà¹ØµÄ½á¹¹ÓÐCOMMCONFIG £¬COMMPROP£¬COMMTIMEOUTS£¬COMSTAT£¬DCB£¬MODEMDEVCAPS£¬MODEMSETTINGS¹²7¸ö£¬
|
ÓëͨÐÅÓйصÄWindows APIº¯Êý¹²ÓÐ26¸ö£¬Ïêϸ˵Ã÷¿É²Î¿¼MSDN°ïÖúÎļþ¡£ÒÔϽ«½áºÏʵÀý£¬¸ø³öʵÏÖ´®ÐÐͨÐŵÄÈýÖÖ·½·¨¡£
|
|
*/
|
|
