//各位大哥，小弟我刚刚接触VC。想搞一个串口的程序，网上借鉴了一下。但发送没有问题。接受框中不能显示接受的数据。请大家帮忙看一下。小弟不胜感激qq：24250469 e-mail：[email protected]// SCommTestDlg.cpp : implementation file
//#include "stdafx.h"
#include "SCommTest.h"
#include "SCommTestDlg.h"#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif/////////////////////////////////////////////////////////////////////////////
// CAboutDlg dialog used for App Aboutclass CAboutDlg : public CDialog
{
public:
CAboutDlg();// Dialog Data
//{{AFX_DATA(CAboutDlg)
enum { IDD = IDD_ABOUTBOX };
//}}AFX_DATA // ClassWizard generated virtual function overrides
//{{AFX_VIRTUAL(CAboutDlg)
protected:
virtual void DoDataExchange(CDataExchange* pDX); // DDX/DDV support
//}}AFX_VIRTUAL// Implementation
protected:
//{{AFX_MSG(CAboutDlg)
//}}AFX_MSG
DECLARE_MESSAGE_MAP()
};CAboutDlg::CAboutDlg() : CDialog(CAboutDlg::IDD)
{
//{{AFX_DATA_INIT(CAboutDlg)
//}}AFX_DATA_INIT
}void CAboutDlg::DoDataExchange(CDataExchange* pDX)
{
CDialog::DoDataExchange(pDX);
//{{AFX_DATA_MAP(CAboutDlg)
//}}AFX_DATA_MAP
}BEGIN_MESSAGE_MAP(CAboutDlg, CDialog)
//{{AFX_MSG_MAP(CAboutDlg)
// No message handlers
//}}AFX_MSG_MAP
END_MESSAGE_MAP()/////////////////////////////////////////////////////////////////////////////
// CSCommTestDlg dialogCSCommTestDlg::CSCommTestDlg(CWnd* pParent /*=NULL*/)
: CDialog(CSCommTestDlg::IDD, pParent)
{
//{{AFX_DATA_INIT(CSCommTestDlg)
m_strRXData = _T("");
m_strTXData = _T("");
m_rxdedit = _T("");
//}}AFX_DATA_INIT
// Note that LoadIcon does not require a subsequent DestroyIcon in Win32
m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
}void CSCommTestDlg::DoDataExchange(CDataExchange* pDX)
{
CDialog::DoDataExchange(pDX);
//{{AFX_DATA_MAP(CSCommTestDlg)
DDX_Control(pDX, IDC_MSCOMM1, m_ctrlComm);
DDX_Text(pDX, IDC_EDIT_RXDATA, m_strRXData);
DDX_Text(pDX, IDC_EDIT_TXDATA, m_strTXData);
DDX_Text(pDX, IDC_EDIT1, m_rxdedit);
//}}AFX_DATA_MAP
}BEGIN_MESSAGE_MAP(CSCommTestDlg, CDialog)
//{{AFX_MSG_MAP(CSCommTestDlg)
ON_WM_SYSCOMMAND()
ON_WM_PAINT()
ON_WM_QUERYDRAGICON()
ON_BN_CLICKED(IDC_BUTTON_MANUALSEND, OnButtonManualsend)
ON_EN_CHANGE(IDC_EDIT1, OnChangeEdit1)
//}}AFX_MSG_MAP
END_MESSAGE_MAP()/////////////////////////////////////////////////////////////////////////////
// CSCommTestDlg message handlersBOOL CSCommTestDlg::OnInitDialog()
{
CDialog::OnInitDialog(); // Add "About..." menu item to system menu. // IDM_ABOUTBOX must be in the system command range.
ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
ASSERT(IDM_ABOUTBOX < 0xF000); CMenu* pSysMenu = GetSystemMenu(FALSE);
if (pSysMenu != NULL)
{
CString strAboutMenu;
strAboutMenu.LoadString(IDS_ABOUTBOX);
if (!strAboutMenu.IsEmpty())
{
pSysMenu->AppendMenu(MF_SEPARATOR);
pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
}
} // Set the icon for this dialog. The framework does this automatically
// when the application's main window is not a dialog
SetIcon(m_hIcon, TRUE); // Set big icon
SetIcon(m_hIcon, FALSE); // Set small icon
// TODO: Add extra initialization here
if(m_ctrlComm.GetPortOpen())
m_ctrlComm.SetPortOpen(FALSE); m_ctrlComm.SetCommPort(1); //选择com1
// m_ctrlComm.SetCommPort(2); //选择com2 if( !m_ctrlComm.GetPortOpen())
m_ctrlComm.SetPortOpen(TRUE);//打开串口
else
AfxMessageBox("cannot open serial port"); m_ctrlComm.SetSettings("9600,n,8,1"); //波特率9600，无校验，8个数据位，1个停止位
m_ctrlComm.SetRThreshold(1);
//参数1表示每当串口接收缓冲区中有多于或等于1个字符时将引发一个接收数据的OnComm事件
// m_ctrlComm.SetRTSEnable(TRUE); // Must be set RTS is true. m_ctrlComm.SetInputMode(1); m_ctrlComm.SetInputLen(0); //设置当前接收区数据长度为0
m_ctrlComm.GetInput();//先预读缓冲区以清除残留数据
//UpdateData(FALSE);
return TRUE; // return TRUE unless you set the focus to a control
}void CSCommTestDlg::OnSysCommand(UINT nID, LPARAM lParam)
{
if ((nID & 0xFFF0) == IDM_ABOUTBOX)
{
CAboutDlg dlgAbout;
dlgAbout.DoModal();
}
else
{
CDialog::OnSysCommand(nID, lParam);
}
}// If you add a minimize button to your dialog, you will need the code below
// to draw the icon. For MFC applications using the document/view model,
// this is automatically done for you by the framework.void CSCommTestDlg::OnPaint()
{
if (IsIconic())
{
CPaintDC dc(this); // device context for painting SendMessage(WM_ICONERASEBKGND, (WPARAM) dc.GetSafeHdc(), 0); // Center icon in client rectangle
int cxIcon = GetSystemMetrics(SM_CXICON);
int cyIcon = GetSystemMetrics(SM_CYICON);
CRect rect;
GetClientRect(&rect);
int x = (rect.Width() - cxIcon + 1) / 2;
int y = (rect.Height() - cyIcon + 1) / 2; // Draw the icon
dc.DrawIcon(x, y, m_hIcon);
}
else
{
CDialog::OnPaint();
}
}// The system calls this to obtain the cursor to display while the user drags
// the minimized window.
HCURSOR CSCommTestDlg::OnQueryDragIcon()
{
return (HCURSOR) m_hIcon;
}BEGIN_EVENTSINK_MAP(CSCommTestDlg, CDialog)
//{{AFX_EVENTSINK_MAP(CSCommTestDlg)
ON_EVENT(CSCommTestDlg, IDC_MSCOMM1, 1 /* OnComm */, OnComm, VTS_NONE)
//}}AFX_EVENTSINK_MAP
END_EVENTSINK_MAP()/*************************************************************************/
void CSCommTestDlg::OnComm()
{
// TODO: Add your control notification handler code here
VARIANT variant_inp; COleSafeArray safearray_inp;
LONG len,k;
BYTE rxdata[2048]; //设置BYTE数组 An 8-bit integerthat is not signed.
CString strtemp;
if(m_ctrlComm.GetCommEvent()==2) //事件值为2表示接收缓冲区内有字符
{
variant_inp=m_ctrlComm.GetInput(); //读缓冲区
variant_inp.Attach ( m_ctrlComm.GetInput());
safearray_inp=variant_inp; //VARIANT型变量转换为ColeSafeArray型变量
len=safearray_inp.GetOneDimSize(); //得到有效数据长度
for(k=0;k<len;k++) safearray_inp.GetElement(&k,rxdata+k);//转换为BYTE型数组
for(k=0;k<len;k++)//{} //将数组转换为Cstring型变量
{
BYTE bt=*(char*)(rxdata+k); //字符型
strtemp.Format("%c",bt); //将字符送入临时变量strtemp存放
m_strRXData+=strtemp; //加入接收编辑框对应字符串
}
}
UpdateData(FALSE); //更新编辑框内容}
void CSCommTestDlg::OnButtonManualsend()
{
// TODO: Add your control notification handler code here
UpdateData(TRUE); //读取编辑框内容
m_ctrlComm.SetOutput(COleVariant(m_strTXData));//发送数据
}
//#include "stdafx.h"
#include "SCommTest.h"
#include "SCommTestDlg.h"#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif/////////////////////////////////////////////////////////////////////////////
// CAboutDlg dialog used for App Aboutclass CAboutDlg : public CDialog
{
public:
CAboutDlg();// Dialog Data
//{{AFX_DATA(CAboutDlg)
enum { IDD = IDD_ABOUTBOX };
//}}AFX_DATA // ClassWizard generated virtual function overrides
//{{AFX_VIRTUAL(CAboutDlg)
protected:
virtual void DoDataExchange(CDataExchange* pDX); // DDX/DDV support
//}}AFX_VIRTUAL// Implementation
protected:
//{{AFX_MSG(CAboutDlg)
//}}AFX_MSG
DECLARE_MESSAGE_MAP()
};CAboutDlg::CAboutDlg() : CDialog(CAboutDlg::IDD)
{
//{{AFX_DATA_INIT(CAboutDlg)
//}}AFX_DATA_INIT
}void CAboutDlg::DoDataExchange(CDataExchange* pDX)
{
CDialog::DoDataExchange(pDX);
//{{AFX_DATA_MAP(CAboutDlg)
//}}AFX_DATA_MAP
}BEGIN_MESSAGE_MAP(CAboutDlg, CDialog)
//{{AFX_MSG_MAP(CAboutDlg)
// No message handlers
//}}AFX_MSG_MAP
END_MESSAGE_MAP()/////////////////////////////////////////////////////////////////////////////
// CSCommTestDlg dialogCSCommTestDlg::CSCommTestDlg(CWnd* pParent /*=NULL*/)
: CDialog(CSCommTestDlg::IDD, pParent)
{
//{{AFX_DATA_INIT(CSCommTestDlg)
m_strRXData = _T("");
m_strTXData = _T("");
m_rxdedit = _T("");
//}}AFX_DATA_INIT
// Note that LoadIcon does not require a subsequent DestroyIcon in Win32
m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
}void CSCommTestDlg::DoDataExchange(CDataExchange* pDX)
{
CDialog::DoDataExchange(pDX);
//{{AFX_DATA_MAP(CSCommTestDlg)
DDX_Control(pDX, IDC_MSCOMM1, m_ctrlComm);
DDX_Text(pDX, IDC_EDIT_RXDATA, m_strRXData);
DDX_Text(pDX, IDC_EDIT_TXDATA, m_strTXData);
DDX_Text(pDX, IDC_EDIT1, m_rxdedit);
//}}AFX_DATA_MAP
}BEGIN_MESSAGE_MAP(CSCommTestDlg, CDialog)
//{{AFX_MSG_MAP(CSCommTestDlg)
ON_WM_SYSCOMMAND()
ON_WM_PAINT()
ON_WM_QUERYDRAGICON()
ON_BN_CLICKED(IDC_BUTTON_MANUALSEND, OnButtonManualsend)
ON_EN_CHANGE(IDC_EDIT1, OnChangeEdit1)
//}}AFX_MSG_MAP
END_MESSAGE_MAP()/////////////////////////////////////////////////////////////////////////////
// CSCommTestDlg message handlersBOOL CSCommTestDlg::OnInitDialog()
{
CDialog::OnInitDialog(); // Add "About..." menu item to system menu. // IDM_ABOUTBOX must be in the system command range.
ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
ASSERT(IDM_ABOUTBOX < 0xF000); CMenu* pSysMenu = GetSystemMenu(FALSE);
if (pSysMenu != NULL)
{
CString strAboutMenu;
strAboutMenu.LoadString(IDS_ABOUTBOX);
if (!strAboutMenu.IsEmpty())
{
pSysMenu->AppendMenu(MF_SEPARATOR);
pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
}
} // Set the icon for this dialog. The framework does this automatically
// when the application's main window is not a dialog
SetIcon(m_hIcon, TRUE); // Set big icon
SetIcon(m_hIcon, FALSE); // Set small icon
// TODO: Add extra initialization here
if(m_ctrlComm.GetPortOpen())
m_ctrlComm.SetPortOpen(FALSE); m_ctrlComm.SetCommPort(1); //选择com1
// m_ctrlComm.SetCommPort(2); //选择com2 if( !m_ctrlComm.GetPortOpen())
m_ctrlComm.SetPortOpen(TRUE);//打开串口
else
AfxMessageBox("cannot open serial port"); m_ctrlComm.SetSettings("9600,n,8,1"); //波特率9600，无校验，8个数据位，1个停止位
m_ctrlComm.SetRThreshold(1);
//参数1表示每当串口接收缓冲区中有多于或等于1个字符时将引发一个接收数据的OnComm事件
// m_ctrlComm.SetRTSEnable(TRUE); // Must be set RTS is true. m_ctrlComm.SetInputMode(1); m_ctrlComm.SetInputLen(0); //设置当前接收区数据长度为0
m_ctrlComm.GetInput();//先预读缓冲区以清除残留数据
//UpdateData(FALSE);
return TRUE; // return TRUE unless you set the focus to a control
}void CSCommTestDlg::OnSysCommand(UINT nID, LPARAM lParam)
{
if ((nID & 0xFFF0) == IDM_ABOUTBOX)
{
CAboutDlg dlgAbout;
dlgAbout.DoModal();
}
else
{
CDialog::OnSysCommand(nID, lParam);
}
}// If you add a minimize button to your dialog, you will need the code below
// to draw the icon. For MFC applications using the document/view model,
// this is automatically done for you by the framework.void CSCommTestDlg::OnPaint()
{
if (IsIconic())
{
CPaintDC dc(this); // device context for painting SendMessage(WM_ICONERASEBKGND, (WPARAM) dc.GetSafeHdc(), 0); // Center icon in client rectangle
int cxIcon = GetSystemMetrics(SM_CXICON);
int cyIcon = GetSystemMetrics(SM_CYICON);
CRect rect;
GetClientRect(&rect);
int x = (rect.Width() - cxIcon + 1) / 2;
int y = (rect.Height() - cyIcon + 1) / 2; // Draw the icon
dc.DrawIcon(x, y, m_hIcon);
}
else
{
CDialog::OnPaint();
}
}// The system calls this to obtain the cursor to display while the user drags
// the minimized window.
HCURSOR CSCommTestDlg::OnQueryDragIcon()
{
return (HCURSOR) m_hIcon;
}BEGIN_EVENTSINK_MAP(CSCommTestDlg, CDialog)
//{{AFX_EVENTSINK_MAP(CSCommTestDlg)
ON_EVENT(CSCommTestDlg, IDC_MSCOMM1, 1 /* OnComm */, OnComm, VTS_NONE)
//}}AFX_EVENTSINK_MAP
END_EVENTSINK_MAP()/*************************************************************************/
void CSCommTestDlg::OnComm()
{
// TODO: Add your control notification handler code here
VARIANT variant_inp; COleSafeArray safearray_inp;
LONG len,k;
BYTE rxdata[2048]; //设置BYTE数组 An 8-bit integerthat is not signed.
CString strtemp;
if(m_ctrlComm.GetCommEvent()==2) //事件值为2表示接收缓冲区内有字符
{
variant_inp=m_ctrlComm.GetInput(); //读缓冲区
variant_inp.Attach ( m_ctrlComm.GetInput());
safearray_inp=variant_inp; //VARIANT型变量转换为ColeSafeArray型变量
len=safearray_inp.GetOneDimSize(); //得到有效数据长度
for(k=0;k<len;k++) safearray_inp.GetElement(&k,rxdata+k);//转换为BYTE型数组
for(k=0;k<len;k++)//{} //将数组转换为Cstring型变量
{
BYTE bt=*(char*)(rxdata+k); //字符型
strtemp.Format("%c",bt); //将字符送入临时变量strtemp存放
m_strRXData+=strtemp; //加入接收编辑框对应字符串
}
}
UpdateData(FALSE); //更新编辑框内容}
void CSCommTestDlg::OnButtonManualsend()
{
// TODO: Add your control notification handler code here
UpdateData(TRUE); //读取编辑框内容
m_ctrlComm.SetOutput(COleVariant(m_strTXData));//发送数据
}
{
// TODO: Add your control notification handler code here
VARIANT variant_inp; COleSafeArray safearray_inp;
LONG len,k;
BYTE rxdata[2048]; //设置BYTE数组 An 8-bit integerthat is not signed.
CString strtemp; if(m_ctrlComm.GetCommEvent()==2) //事件值为2表示接收缓冲区内有字符
{
variant_inp=m_ctrlComm.GetInput(); //读缓冲区
variant_inp.Attach ( m_ctrlComm.GetInput());
safearray_inp=variant_inp; //VARIANT型变量转换为ColeSafeArray型变量
len=safearray_inp.GetOneDimSize(); //得到有效数据长度 for(k=0;k <len;k++) safearray_inp.GetElement(&k,rxdata+k);//转换为BYTE型数组
for(k=0;k <len;k++)//{} //将数组转换为Cstring型变量
{
BYTE bt=*(char*)(rxdata+k); //字符型
strtemp.Format("%c",bt); //将字符送入临时变量strtemp存放
m_strRXData+=strtemp; //加入接收编辑框对应字符串
}
}
UpdateData(FALSE); //更新编辑框内容 } 我跟踪调试了，发现if(m_ctrlComm.GetCommEvent()==2)有事件触发，但len=safearray_inp.GetOneDimSize(); //得到有效数据长度为0。不明白
// Serial.cpp#include "stdafx.h"
#include "Serial.h"
#include "Data.h"/***********************************************
串行端口类
***********************************************/
CSerial::CSerial()
{
m_nPort = 0;
m_nBaud = 0;
m_nDatabits = 0;
m_nStopbits = 0;
m_nParity = 0; memset( &m_OverlappedRead, 0, sizeof( OVERLAPPED ) );
memset( &m_OverlappedWrite, 0, sizeof( OVERLAPPED ) );
m_hIDComDev = NULL;
m_bOpened = FALSE;
}CSerial::~CSerial()
{
Close();
}BOOL CSerial::Open( int nPort, int nBaud, BYTE nDatabits, BYTE nStopbits, BYTE nParity )
{
if( m_bOpened ) return( TRUE ); char szPort[15];
char szComParams[50];
DCB dcb; wsprintf( szPort, "\\\\.\\COM%d", nPort );
m_hIDComDev = CreateFile( szPort, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL | FILE_FLAG_OVERLAPPED, NULL );
if( m_hIDComDev == INVALID_HANDLE_VALUE ) return( FALSE ); memset( &m_OverlappedRead, 0, sizeof( OVERLAPPED ) );
memset( &m_OverlappedWrite, 0, sizeof( OVERLAPPED ) ); COMMTIMEOUTS CommTimeOuts;
CommTimeOuts.ReadIntervalTimeout = 0xFFFFFFFF;
CommTimeOuts.ReadTotalTimeoutMultiplier = 0;
CommTimeOuts.ReadTotalTimeoutConstant = 0;
CommTimeOuts.WriteTotalTimeoutMultiplier = 0;
CommTimeOuts.WriteTotalTimeoutConstant = 0;
SetCommTimeouts( m_hIDComDev, &CommTimeOuts ); wsprintf( szComParams, "COM%d:%d,n,8,1", nPort, nBaud ); m_OverlappedRead.hEvent = CreateEvent( NULL, TRUE, FALSE, NULL );
m_OverlappedWrite.hEvent = CreateEvent( NULL, TRUE, FALSE, NULL ); dcb.DCBlength = sizeof( DCB );
GetCommState( m_hIDComDev, &dcb ); dcb.BaudRate = nBaud;
dcb.fParity = TRUE;
dcb.fOutxCtsFlow = FALSE;
dcb.fOutxDsrFlow = FALSE;
dcb.fDtrControl = DTR_CONTROL_ENABLE;
dcb.fDsrSensitivity = FALSE;
dcb.fTXContinueOnXoff = FALSE;
dcb.fOutX = FALSE;
dcb.fInX = FALSE;
dcb.fErrorChar = FALSE;
dcb.fNull = FALSE;
dcb.fRtsControl = RTS_CONTROL_ENABLE;
dcb.fAbortOnError = FALSE;
dcb.XonLim = 512;
dcb.XoffLim = 1024;
dcb.ByteSize = nDatabits;
dcb.Parity = nParity;
dcb.StopBits = 0; //(0--1 stop,1--1.5 stop,2--2 stop). Stopbits;
if( !SetCommState( m_hIDComDev, &dcb ) ||
!SetupComm( m_hIDComDev, 10000, 10000 ) ||
m_OverlappedRead.hEvent == NULL ||
m_OverlappedWrite.hEvent == NULL )
{
DWORD dwError = GetLastError();
if( m_OverlappedRead.hEvent != NULL )
CloseHandle( m_OverlappedRead.hEvent );
if( m_OverlappedWrite.hEvent != NULL )
CloseHandle( m_OverlappedWrite.hEvent );
CloseHandle( m_hIDComDev );
return( FALSE );
}
m_bOpened = TRUE; DWORD dwMask;
if(GetCommMask(m_hIDComDev,&dwMask))
{
dwMask =dwMask | EV_RXCHAR ;
if(!SetCommMask(m_hIDComDev,dwMask))
return FALSE;
} return( TRUE );
}
BOOL CSerial::Close( void )
{ if( !m_bOpened || m_hIDComDev == NULL )
return( TRUE ); if( m_OverlappedRead.hEvent != NULL )
{
CloseHandle( m_OverlappedRead.hEvent );
m_OverlappedRead.hEvent = NULL;
}
if( m_OverlappedWrite.hEvent != NULL )
{
CloseHandle( m_OverlappedWrite.hEvent );
m_OverlappedWrite.hEvent = NULL;
}
if(m_hIDComDev != NULL)
CloseHandle( m_hIDComDev );
m_bOpened = FALSE;
m_hIDComDev = NULL; return( TRUE );}BOOL CSerial::WriteCommByte( unsigned char ucByte )
{
BOOL bWriteStat;
DWORD dwBytesWritten; bWriteStat = WriteFile( m_hIDComDev, (LPSTR) &ucByte, 1, &dwBytesWritten, &m_OverlappedWrite );
if( !bWriteStat && ( GetLastError() == ERROR_IO_PENDING ) ) {
if( WaitForSingleObject( m_OverlappedWrite.hEvent, 1000 ) ) dwBytesWritten = 0;
else {
GetOverlappedResult( m_hIDComDev, &m_OverlappedWrite, &dwBytesWritten, FALSE );
m_OverlappedWrite.Offset += dwBytesWritten;
}
} return( TRUE );}
{
BOOL bWriteStat;
DWORD dwBytesWritten; bWriteStat = WriteFile( m_hIDComDev, buf, len, &dwBytesWritten, &m_OverlappedWrite );
if( !bWriteStat && ( GetLastError() == ERROR_IO_PENDING ) )
{
if( WaitForSingleObject( m_OverlappedWrite.hEvent, 1000 ) )
dwBytesWritten = 0;
else {
GetOverlappedResult( m_hIDComDev, &m_OverlappedWrite, &dwBytesWritten, FALSE );
m_OverlappedWrite.Offset += dwBytesWritten;
}
}
else
return FALSE;
return( TRUE );}int CSerial::SendData(const char *buffer, int size,int opt )
{
//buffer 数据缓冲区
//size 数据长度
//opt 数据写方式 0: 单字节写 1:多字节写
if( !m_bOpened || m_hIDComDev == NULL )
return( 0 ); DWORD dwBytesWritten = 0;
int i;
PurgeComm(m_hIDComDev,PURGE_TXCLEAR | PURGE_RXCLEAR);
DWORD dwError;
COMSTAT cs;
ClearCommError(m_hIDComDev,&dwError,&cs);
if(opt==0) {
for( i=0; i<size; i++ ){
WriteCommByte( buffer[i] );
dwBytesWritten++;
}
}
else {
if(WriteCommStr(buffer,size))
dwBytesWritten=size;
else
dwBytesWritten=0;
}
return( (int) dwBytesWritten );}int CSerial::ReadDataWaiting( void )
{
if( !m_bOpened || m_hIDComDev == NULL )
return( 0 ); DWORD dwErrorFlags;
COMSTAT ComStat; ClearCommError( m_hIDComDev, &dwErrorFlags, &ComStat ); return( (int) ComStat.cbInQue );}int CSerial::ReadData( char *buffer, int limit )
{ if( !m_bOpened || m_hIDComDev == NULL ) return( 0 ); BOOL bReadStatus;
DWORD dwBytesRead, dwErrorFlags;
COMSTAT ComStat; ClearCommError( m_hIDComDev, &dwErrorFlags, &ComStat );
if( !ComStat.cbInQue ) return( 0 ); dwBytesRead = (DWORD) ComStat.cbInQue;
if( limit < (int) dwBytesRead ) dwBytesRead = (DWORD) limit; bReadStatus = ReadFile( m_hIDComDev, buffer, dwBytesRead, &dwBytesRead, &m_OverlappedRead );
if( !bReadStatus ){
if( GetLastError() == ERROR_IO_PENDING ){
WaitForSingleObject( m_OverlappedRead.hEvent, 2000 );
return( (int) dwBytesRead );
}
return( 0 );
} return( (int) dwBytesRead );}int CSerial::ReadEvent(char* buffer,int limit,short ReadType)
{
DWORD nBytesRead,dwError;
COMSTAT cs;
short rc=0;
ClearCommError(m_hIDComDev,&dwError,&cs);
if( !cs.cbInQue ) return( 0 );
nBytesRead = (DWORD) cs.cbInQue;
if( limit < (int) nBytesRead ) nBytesRead = (DWORD) limit;
if(ReadFile(m_hIDComDev,buffer,nBytesRead ,&nBytesRead,&m_OverlappedRead))
rc=(short)nBytesRead;
else
rc=0;
return rc;}
short CSerial::ModifyBaud(int port, int nbaud)
{
DCB dcb;
char msg[50];
if(m_hIDComDev==NULL)
{
m_bOpened=FALSE;
return -1;
}
GetCommState(m_hIDComDev,&dcb);
wsprintf(msg,"COM%d:%d,n,8,1",port,nbaud);
if(BuildCommDCB(msg,&dcb))
{
if(SetCommState(m_hIDComDev,&dcb))
return 0;
}
else
return -1;
return -1;
}short CSerial::ModifyBaud(int port,int nBaud,BYTE nDatabits,BYTE nStopbits,BYTE nParity)
{
DCB dcb;
char msg[50];
if(m_hIDComDev==NULL)
{
m_bOpened=FALSE;
return -1;
}
GetCommState(m_hIDComDev,&dcb);
wsprintf(msg,"COM%d:%d,%d,%d,%d",port,nBaud,nParity,nDatabits,nStopbits);
if(BuildCommDCB(msg,&dcb))
{
if(SetCommState(m_hIDComDev,&dcb))
return 0;
}
else
return -1;
return -1;
}
int CSerial::SendCmd(const char* cmd,int len)
{
//命令改成一串发
// if(SendData(cmd, len,0)==len)// Modify by yewg 2005-01-20
if(SendData(cmd, len,1)==len)
return 0;
else
return -1;
}int CSerial::ClearBuffer(void)
{
int flag=0;
DWORD dwError;
COMSTAT cs;
ClearCommError(m_hIDComDev,&dwError,&cs);
if( !cs.cbInQue ) return( 0 );
if(cs.cbInQue>512)//缓冲区中有大量的非法数据
flag=1;
if((dwError&CE_BREAK)
||(dwError&CE_FRAME)
||(dwError&CE_IOE)
||(dwError&CE_OVERRUN)
||(dwError&CE_RXOVER)
||(dwError&CE_RXPARITY)
||(dwError&CE_TXFULL))
flag=2;//通信错误
PurgeComm(m_hIDComDev,PURGE_RXCLEAR);
return flag;
}
BOOL CSerial::Open(int nPort, DCB *pDcb)
{
if( m_bOpened ) return( TRUE );
char szPort[15];
// char szComParams[50];
DCB dcb;
wsprintf( szPort, "\\\\.\\COM%d", nPort );
m_hIDComDev = CreateFile( szPort, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL | FILE_FLAG_OVERLAPPED, NULL );
if( m_hIDComDev == INVALID_HANDLE_VALUE ) return( FALSE );
memset( &m_OverlappedRead, 0, sizeof( OVERLAPPED ) );
memset( &m_OverlappedWrite, 0, sizeof( OVERLAPPED ) );
COMMTIMEOUTS CommTimeOuts;
CommTimeOuts.ReadIntervalTimeout = 0xFFFFFFFF;
CommTimeOuts.ReadTotalTimeoutMultiplier = 0;
CommTimeOuts.ReadTotalTimeoutConstant = 0;
CommTimeOuts.WriteTotalTimeoutMultiplier = 0;
CommTimeOuts.WriteTotalTimeoutConstant = 0;
SetCommTimeouts( m_hIDComDev, &CommTimeOuts );
// wsprintf( szComParams, "COM%d:%d,n,8,1", nPort, nBaud );
m_OverlappedRead.hEvent = CreateEvent( NULL, TRUE, FALSE, NULL );
m_OverlappedWrite.hEvent = CreateEvent( NULL, TRUE, FALSE, NULL );
dcb.DCBlength = sizeof( DCB );
GetCommState( m_hIDComDev, &dcb );
dcb.BaudRate = pDcb->BaudRate;
dcb.fParity = pDcb->fParity;
dcb.fOutxCtsFlow = pDcb->fOutxCtsFlow;
dcb.fOutxDsrFlow = pDcb->fOutxDsrFlow;
dcb.fDtrControl = pDcb->fDtrControl;
dcb.fDsrSensitivity = pDcb->fDsrSensitivity;
dcb.fTXContinueOnXoff = pDcb->fTXContinueOnXoff;
dcb.fOutX = pDcb->fOutX;
dcb.fInX = pDcb->fInX;
dcb.fErrorChar = pDcb->fErrorChar;
dcb.fNull = pDcb->fNull;
dcb.fRtsControl = pDcb->fRtsControl;
dcb.fAbortOnError = pDcb->fAbortOnError;
dcb.XonLim = pDcb->XonLim;
dcb.XoffLim = pDcb->XoffLim;
dcb.ByteSize = pDcb->ByteSize;
dcb.Parity = pDcb->Parity;
dcb.StopBits = pDcb->StopBits; //(0--1 stop,1--1.5 stop,2--2 stop). Stopbits;
if( !SetCommState( m_hIDComDev, &dcb ) ||
!SetupComm( m_hIDComDev, 10000, 10000 ) ||
m_OverlappedRead.hEvent == NULL ||
m_OverlappedWrite.hEvent == NULL )
{
DWORD dwError = GetLastError();
if( m_OverlappedRead.hEvent != NULL )
CloseHandle( m_OverlappedRead.hEvent );
if( m_OverlappedWrite.hEvent != NULL )
CloseHandle( m_OverlappedWrite.hEvent );
CloseHandle( m_hIDComDev );
return( FALSE );
}
m_bOpened = TRUE;
DWORD dwMask;
if(GetCommMask(m_hIDComDev,&dwMask))
{
dwMask =dwMask | EV_RXCHAR ;
if(!SetCommMask(m_hIDComDev,dwMask))
return FALSE;
}
return( TRUE );
}