monitordoc.cpp

模拟了tec2000的所有功能

//***********************************************************************************
//本页内容包括串口通信的主要类CMonitorDoc，完成文件的导入导出以及监控串口接收缓冲区的功能。
//其中全局监控线程函数CommThread和界面视图类CMonitorview结合在一起完成Tec2000的监控功能，主要是A，
//G,D,E等监控命令,OnFileExport()和OnFileImport()完成文件的导入导出功能
// 
//                        版本：V3.0
//                        作者：徐胜强(031221112)
//                        日期：2005年12月5日
//
//
//********************************************************************************************


#include "stdafx.h"
#include "Monitor.h"
 #include "MonitorDoc.h"

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

/////////////////////////////////////////////////////////////////////////////
// CMonitorDoc

IMPLEMENT_DYNCREATE(CMonitorDoc, CDocument)

BEGIN_MESSAGE_MAP(CMonitorDoc, CDocument)
	//{{AFX_MSG_MAP(CMonitorDoc)
 	ON_COMMAND(ID_CONNECT, OnConnect)
	ON_UPDATE_COMMAND_UI(ID_CONNECT, OnUpdateConnect)
 	ON_COMMAND(ID_DISCONNECT, OnDisconnect)
	ON_UPDATE_COMMAND_UI(ID_DISCONNECT, OnUpdateDisconnect)
	ON_COMMAND(ID_FILE_EXPORT, OnFileExport)
	ON_UPDATE_COMMAND_UI(ID_FILE_EXPORT, OnUpdateFileExport)
	ON_COMMAND(ID_FILE_IMPORT, OnFileImport)
	ON_UPDATE_COMMAND_UI(ID_FILE_IMPORT, OnUpdateFileImport)
	ON_COMMAND(ID_SETTINGS, OnSettings)
	ON_UPDATE_COMMAND_UI(ID_SETTINGS, OnUpdateSettings)
	//}}AFX_MSG_MAP
 END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CMonitorDoc construction/destruction
//构造函数，提供串口的默认配置
CMonitorDoc::CMonitorDoc()
{
 // TODO: add one-time construction code here
	m_bConnected=FALSE;
	m_pThread=NULL;
	m_nBaud=9600;
	m_nDataBits=8;
	m_nParity=0;
	m_sPort="COM1";
	m_nStopBits=0;

}
//析构函数
CMonitorDoc::~CMonitorDoc()
{
	if(m_bConnected)
		CloseConnection();
	//删除事件句柄
	if(m_hPostMsgEvent)
	 CloseHandle(m_hPostMsgEvent);
	if(m_ovRead.hEvent)
		CloseHandle(m_ovRead.hEvent);
	if(m_ovWrite.hEvent)
		CloseHandle(m_ovWrite.hEvent);
}

 BOOL CMonitorDoc::OnNewDocument()
{
	if (!CDocument::OnNewDocument())
		return FALSE;
    this->SetTitle("UnConnected");
	((CEditView*)m_viewList.GetHead())->SetWindowText(NULL);
	// TODO: add reinitialization code here
	// (SDI documents will reuse this document)
	//为WM_COMMNOTIFY消息创建事件对象,手工重置,初始化为有信号的
	if((m_hPostMsgEvent=CreateEvent(NULL,TRUE,TRUE,NULL))==NULL)
		return FALSE;
	memset(&m_ovRead,0,sizeof(OVERLAPPED));
	memset(&m_ovWrite,0,sizeof(OVERLAPPED));
	//为重叠读操作创建事件对象,手工重置,初始化为无信号的						
	if((m_ovRead.hEvent=CreateEvent(NULL,TRUE,FALSE,NULL))==NULL)
		return FALSE;
	//为重写写操作创建事件对象,手工重置,初始化为无信号的
	if((m_ovWrite.hEvent=CreateEvent(NULL,TRUE,FALSE,NULL))==NULL)
		return FALSE;
	return TRUE;
}



/////////////////////////////////////////////////////////////////////////////
// CMonitorDoc serialization

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

/////////////////////////////////////////////////////////////////////////////
// CMonitorDoc diagnostics

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

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

/////////////////////////////////////////////////////////////////////////////
//确认配置，将用户设置或默认设置赋给DCB结构体
 BOOL CMonitorDoc::ConfigConnection()
{
	DCB dcb;
	if(!GetCommState(m_hComm,&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:;
	}
  return SetCommState(m_hComm,&dcb);
}
 //打开串口，启动监控线程
 BOOL CMonitorDoc::OpenConnection()
{
   
	POSITION firstViewPos;
	CView *pView;
	firstViewPos=GetFirstViewPosition();
    pView=GetNextView(firstViewPos);
	m_hTermWnd=pView->GetSafeHwnd();

	COMMTIMEOUTS TimeOuts;
	if(m_bConnected)
		return FALSE;
	m_hComm=CreateFile(m_sPort,                  //串口号
		              GENERIC_READ|GENERIC_WRITE,//允许读和写
					  0,                         //独占串口
					  NULL,                      //安全特性,串口通常设为NULL
		              OPEN_EXISTING,             //串口总是存在的
					  FILE_ATTRIBUTE_NORMAL|     
					  FILE_FLAG_OVERLAPPED,      //重叠(异步)操作
					   NULL);                    
	if(m_hComm==INVALID_HANDLE_VALUE)
		return FALSE;
	SetupComm(m_hComm,MAXBLOCK,MAXBLOCK);
	SetCommMask(m_hComm,EV_RXCHAR);

	TimeOuts.ReadIntervalTimeout=MAXDWORD;
	TimeOuts.ReadTotalTimeoutConstant=0;
    TimeOuts.ReadTotalTimeoutMultiplier=0;
	TimeOuts.WriteTotalTimeoutConstant=100;
	TimeOuts.WriteTotalTimeoutMultiplier=1000;
    SetCommTimeouts(m_hComm,&TimeOuts);

    if(ConfigConnection())
	{
	   m_pThread=AfxBeginThread(CommThread,this,
		   THREAD_PRIORITY_NORMAL,0,CREATE_SUSPENDED,NULL);//???????
	   if(m_pThread==NULL)
	   {
		   CloseHandle(m_hComm);
		   return FALSE;
	   }
      else
	  {
	   m_bConnected=TRUE;
	   m_pThread->ResumeThread();
	  }
   }
   else
   {
	   CloseHandle(m_hComm);
	   return FALSE;
   }
   return TRUE;

}
//关闭串口
void CMonitorDoc::CloseConnection()
{
       if(!m_bConnected) return;
	     m_bConnected=FALSE;
	//结束CommThread()中WaitForSingleObject()的等待
	SetEvent(m_hPostMsgEvent);
	//结束CommThread()中WaitCommEvent()的等待
	SetCommMask(m_hComm,0);
	//等待辅助线程终止
	WaitForSingleObject(m_pThread->m_hThread,INFINITE);
	m_pThread=NULL;
	//关闭串口句柄
	CloseHandle(m_hComm);
}

BOOL  CMonitorDoc::CanCloseFrame(CFrameWnd *pFrame)
{
	SetModifiedFlag(FALSE);
	return CDocument::CanCloseFrame(pFrame);

}

//“串口－－>连接”的命令响应函数
void CMonitorDoc::OnConnect() 
{
	// TODO: Add your command handler code here
	
	if(!OpenConnection())
     AfxMessageBox("Can't open connection");
	else this->SetTitle("Connected");

	
}

void CMonitorDoc::OnUpdateConnect(CCmdUI* pCmdUI) 
{
	// TODO: Add your command update UI handler code here
	pCmdUI->Enable(!m_bConnected);
	
}
//“串口—>断开”的命令响应函数
void CMonitorDoc::OnDisconnect() 
{
	// TODO: Add your command handler code here
	CloseConnection();
	this->SetTitle("UnConnected");
	
}

void CMonitorDoc::OnUpdateDisconnect(CCmdUI* pCmdUI) 
{
	// TODO: Add your command update UI handler code here
	pCmdUI->Enable(m_bConnected);
	
}
//写串口函数
DWORD CMonitorDoc::WritePort(char *buff, DWORD dwlength)
{    
	BOOL fState;
	DWORD length=dwlength;
	COMSTAT ComStat;
	DWORD dwErrorFlags;
	ClearCommError(m_hComm,&dwErrorFlags,&ComStat);
	fState=WriteFile(m_hComm,buff,length,&length,&m_ovWrite);
	if(!fState)
	{
		if(GetLastError()==ERROR_IO_PENDING) //写操作未立即完成,正在后台执行
		{
			GetOverlappedResult(m_hComm,&m_ovWrite,&length,TRUE);//等待写操作完成
		}
       else length=0;
	}
	return length;
}
//读串口函数
DWORD CMonitorDoc::ReadPort(char *buff, DWORD dwLength)
{
	
	DWORD length=dwLength;
	COMSTAT ComStat;
	DWORD dwErrorFlags;
	ClearCommError(m_hComm,&dwErrorFlags,&ComStat);
	length=dwLength>ComStat.cbInQue?ComStat.cbInQue:dwLength;
	ReadFile(m_hComm,buff,length,&length,&m_ovRead);
	return length;
}

//TEC----->PC，文件导出
void CMonitorDoc::OnFileExport()