ttydoc.cpp

本代码主要实现串口程序的仿真与演示

// TTYDoc.cpp : implementation of the CTTYDoc class
//
#include "stdafx.h"
#include "TTY.h"
#include "CommSetDlg.h"
#include "TTYDoc.h"
#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif

/////////////////////////////////////////////////////////////////////////////
// CTTYDoc

IMPLEMENT_DYNCREATE(CTTYDoc, CDocument)

BEGIN_MESSAGE_MAP(CTTYDoc, CDocument)
	//{{AFX_MSG_MAP(CTTYDoc)
	ON_COMMAND(ID_API_CONNECT, OnApiConnect)
	ON_COMMAND(ID_API_DISCONNECT, OnApiDisconnect)
	ON_COMMAND(ID_API_SETTINGS, OnApiSettings)
	ON_UPDATE_COMMAND_UI(ID_API_CONNECT, OnUpdateApiConnect)
	ON_UPDATE_COMMAND_UI(ID_API_DISCONNECT, OnUpdateApiDisconnect)
	ON_UPDATE_COMMAND_UI(ID_API_SETTINGS, OnUpdateApiSettings)
	//}}AFX_MSG_MAP
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CTTYDoc construction/destruction

CTTYDoc::CTTYDoc()
{
	// TODO: add one-time construction code here
m_bConnected=FALSE;
m_pThread=NULL;
m_nBaud=9600;
m_nDataBits=8;
m_bEcho=FALSE;
m_bNewLine=FALSE;
m_nParity=0;
m_sPort="COM2";
m_nStopBits=0;
}

CTTYDoc::~CTTYDoc()
{
 if(m_bConnected)
    CloseConnection();
if(m_hPostMsgEvent)
  CloseHandle(m_hPostMsgEvent);
  if(m_osRead.hEvent)
      CloseHandle(m_osRead.hEvent);
   if(m_osWrite.hEvent)
          CloseHandle(m_osWrite.hEvent);

}


BOOL CTTYDoc::OnNewDocument()
{
	if (!CDocument::OnNewDocument())
		return FALSE;

	((CEditView*)m_viewList.GetHead())->SetWindowText(NULL);

	// TODO: add reinitialization code here
	// (SDI documents will reuse this document)
	   	if((m_hPostMsgEvent=CreateEvent(NULL,TRUE,TRUE,NULL))==NULL)
	return FALSE;
	memset(&m_osRead,0,sizeof(OVERLAPPED));
   memset(&m_osWrite,0,sizeof(OVERLAPPED));
if((m_osRead.hEvent=CreateEvent(NULL,TRUE,FALSE,NULL))==NULL)
	return FALSE;
if((m_osWrite.hEvent=CreateEvent(NULL,TRUE,FALSE,NULL))==NULL)
	return FALSE;

	return TRUE;
}



/////////////////////////////////////////////////////////////////////////////
// CTTYDoc serialization

void CTTYDoc::Serialize(CArchive& ar)
{
	// CEditView contains an edit control which handles all serialization
	((CEditView*)m_viewList.GetHead())->SerializeRaw(ar);
}

/////////////////////////////////////////////////////////////////////////////
// CTTYDoc diagnostics

#ifdef _DEBUG
void CTTYDoc::AssertValid() const
{
	CDocument::AssertValid();
}

void CTTYDoc::Dump(CDumpContext& dc) const
{
	CDocument::Dump(dc);
}
#endif //_DEBUG

/////////////////////////////////////////////////////////////////////////////
// CTTYDoc commands

/*BOOL CTTYDoc::CanCloseFrame(CFrameWnd *pFrame)
{
SetModifiedFlag(FALSE);
return CDocument::CanCloseFrame(pFrame);
} */

UINT CommWatchProc(LPVOID pParam)
{ PCOMM pComm = (PCOMM)pParam;
	OVERLAPPED os;
DWORD dwMask,dwTrans;
 COMSTAT ComStat;
DWORD dwErrorFlags;
CTTYDoc *pDoc=(CTTYDoc*)pParam;
memset(&os,0,sizeof(OVERLAPPED));
os.hEvent=CreateEvent(NULL,TRUE,FALSE,NULL);
if(os.hEvent==NULL)
{	AfxMessageBox("不能创立设置");
return(UINT)-1;}
while(pDoc->m_bConnected)
{ClearCommError(pDoc->m_hCom,&dwErrorFlags,&ComStat);
if(ComStat.cbInQue)
{ ResetEvent(pDoc->m_hPostMsgEvent);
PostMessage(pDoc->m_hTermWnd,WM_COMMNOTIFY,EV_RXCHAR,0);
continue;
}
dwMask=0;
if(!WaitCommEvent(pDoc->m_hCom,&dwMask,&os))
{if(GetLastError()==ERROR_IO_PENDING)
 GetOverlappedResult(pDoc->m_hCom,&os,&dwTrans,TRUE);
else
{CloseHandle(os.hEvent);
return(UINT)-1;}
}
}
CloseHandle(os.hEvent);
return 0;

}
DWORD CTTYDoc::ReadComm(char *buf, DWORD dwLength)
{DWORD length=0;
 COMSTAT ComStat;
  DWORD dwErrorFlags;
  ClearCommError(m_hCom,&dwErrorFlags,&ComStat);
  length=min(dwLength,ComStat.cbInQue);

   ReadFile(m_hCom,buf,length,&length,&m_osRead);
   return length;
}
DWORD CTTYDoc::WriteComm(char *buf, DWORD dwLength)
{ BOOL fState;
 DWORD length=dwLength;
 COMSTAT ComStat;
  DWORD dwErrorFlags;
  ClearCommError(m_hCom,&dwErrorFlags,&ComStat);
   fState=WriteFile(m_hCom,buf,length,&length,&m_osWrite);
   if(!fState)
   { if(GetLastError()==ERROR_IO_PENDING)
   {GetOverlappedResult(m_hCom,&m_osWrite,&length,TRUE);}
   else
	   length=0;
   }
          return length;
}
void CTTYDoc::OnApiConnect() 
{
	// TODO: Add your command handler code here
	if (!OpenConnection())
		AfxMessageBox("不能打开连接");
}
void CTTYDoc::OnUpdateApiConnect(CCmdUI* pCmdUI) 
{
	// TODO: Add your command update UI handler code here
	pCmdUI->Enable(!m_bConnected);

}

void CTTYDoc::OnApiDisconnect() 
{
	// TODO: Add your command handler code here
	CloseConnection();
}
void CTTYDoc::OnUpdateApiDisconnect(CCmdUI* pCmdUI) 
{
	// TODO: Add your command update UI handler code here
	pCmdUI->Enable(!m_bConnected);
}

void CTTYDoc::OnApiSettings() 
{
	// TODO: Add your command handler code here
CCommSetDlg dlg;
CString str;
dlg.m_bConnected=m_bConnected;
dlg.m_sPort=m_sPort;
str.Format("%d",m_nBaud);
dlg.m_sBaud=str;
str.Format("%d",m_nDataBits);
dlg.m_sDataBits=str;
dlg.m_nParity=m_nParity;
dlg.m_nStopBits=m_nStopBits;
dlg.m_bEcho=m_bEcho;
dlg.m_bNewLine=m_bNewLine;
  if(dlg.DoModal()==IDOK)
  {m_sPort=dlg.m_sPort;
   m_nBaud=atoi(dlg.m_sBaud);
   m_nDataBits=atoi(dlg.m_sDataBits);
   m_nParity=dlg.m_nParity;
   m_nStopBits=dlg.m_nStopBits;
	m_bEcho=dlg.m_bEcho;
	m_bNewLine=dlg.m_bNewLine;
	if(m_bConnected)
		if(!ConfigConnection())
			AfxMessageBox("不能实现设置");
  }
}
void CTTYDoc::OnUpdateApiSettings(CCmdUI* pCmdUI) 
{
	// TODO: Add your command update UI handler code here
	
}
BOOL CTTYDoc::ConfigConnection()
{ DCB dcb;
  if(!GetCommState(m_hCom,&dcb))
	  return FALSE;
    dcb.fBinary=TRUE;
	dcb.BaudRate=m_nBaud;
	dcb.ByteSize=m_nDataBits;
	dcb.fParity=TRUE;
	switch(m_nParity)
	{ case 0:
	  dcb.Parity=NOPARITY;
	   break;
	   case 1:
       dcb.Parity=EVENPARITY;
	   break;
	   case 2:
       dcb.Parity=ODDPARITY;
	   break;
	   default:;}
	switch(m_nStopBits)
	{ case 0:
	  dcb.StopBits=ONESTOPBIT;
	   break;
	   case 1:
       dcb.StopBits=ONE5STOPBITS;
	   break;
	   case 2:
       dcb.StopBits=TWOSTOPBITS;
	   break;
	   default:;}
	dcb.fOutxCtsFlow=TRUE;
	dcb.fRtsControl=TRUE;
	dcb.fInX=dcb.fOutX=TRUE;
	dcb.XonChar=XON;
	dcb.XoffLim=XOFF;
	dcb.XonLim=50;
	dcb.XoffLim=50;
	return SetCommState(m_hCom,&dcb);
}
BOOL CTTYDoc::OpenConnection()
{ COMMTIMEOUTS TimeOuts;
  POSITION firstViewPos;
   CView *pView;
    firstViewPos=GetFirstViewPosition();
  pView=GetNextView(firstViewPos);
  m_hTermWnd=pView->GetSafeHwnd();
  if(m_bConnected)
	  return FALSE;
  m_hCom=CreateFile(m_sPort,GENERIC_READ|GENERIC_WRITE,0,NULL,OPEN_EXISTING,FILE_ATTRIBUTE_NORMAL|FILE_FLAG_OVERLAPPED,NULL);
  if(m_hCom==INVALID_HANDLE_VALUE)
	  return FALSE;
	  SetupComm(m_hCom,MAXBLOCK,MAXBLOCK);
  SetCommMask(m_hCom,EV_RXCHAR);
  TimeOuts.ReadIntervalTimeout=MAXDWORD;
TimeOuts.ReadTotalTimeoutConstant=0;
TimeOuts.ReadTotalTimeoutMultiplier=0;
TimeOuts.WriteTotalTimeoutConstant=50;
TimeOuts.WriteTotalTimeoutMultiplier=2000;
SetCommTimeouts(m_hCom,&TimeOuts);
if(ConfigConnection())
/*AfxBeginThread(CommWatchProc,
Thread func
(LPVOID)pComm, // pParam
THREAD-PRIORITY-NORMAL, // Priority
(UINT)0, // StackSize
(DWORD)CREATE-SUSPENDED, // 挂起线程
(LPSECURITY-ATTRIBUTES)NULL );*/
{ m_pThread=AfxBeginThread(CommWatchProc,(LPVOID)pComm,THREAD_PRIORITY_NORMAL,(UINT)0,(DWORD)CREATE_SUSPENDED,NULL);
 if(m_pThread==NULL)
 {CloseHandle(m_hCom);
 return FALSE;}
  else
  {m_bConnected=TRUE;
   m_pThread->ResumeThread();
  }
}
else
{CloseHandle(m_hCom);
return FALSE;}
return FALSE;
}
void CTTYDoc::CloseConnection()
 { if(!m_bConnected)
 return;
   m_bConnected=FALSE;
   SetEvent(m_hPostMsgEvent);
   SetCommMask(m_hCom,0);
   WaitForSingleObject(m_pThread->m_hThread,INFINITE);
   m_pThread=NULL;
   CloseHandle(m_hCom);
}


BOOL CTTYDoc::CanCloseFrame(CFrameWnd* pFrame) 
{
	// TODO: Add your specialized code here and/or call the base class
	SetModifiedFlag(FALSE);
	return CDocument::CanCloseFrame(pFrame);
}