serialappdlg.cpp

实现两台机器之间的串口通信！可以对串口进行调试！

// SerialAppDlg.cpp : implementation file
//

#include "stdafx.h"
#include "SerialAppDlg.h"

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

int CSerialAppDlg::file=0;
int CSerialAppDlg::msg=0;
 

/////////////////////////////////////////////////////////////////////////////
// CSerialAppDlg dialog


CSerialAppDlg::CSerialAppDlg(CWnd* pParent /*=NULL*/)
	: CExpandingDialog(CSerialAppDlg::IDD, pParent,IDC_DEFAULTBOX,IDC_DETAILS,
			_T("Show >>"),_T("Hide <<"))
{
	//{{AFX_DATA_INIT(CSerialAppDlg)
		// NOTE: the ClassWizard will add member initialization here
	//}}AFX_DATA_INIT

	m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
	m_strReceived.Empty();
	m_nComm=0;
	m_nBandRate=19200;
	m_nDataBits=8;
	m_nStopBits=1;
	m_cParity='N';
	m_strInitial1="`0123456789abcdefghijklmnopqrstuvwxyz!@#$%^&*()-=\\_+|;':\",./<>?";
	m_strInitial2="凝点控制系统倾闪苯氨冷滤国家标准企业大连理工大学大唐科学仪器测量与设定";
	m_strInitial2+="系统设定时钟继电器测试打印机温度显示定时器设定给定点设定";
	m_strInitial2+="系统标定结果查询室温浴槽序号参数值存储退出传感器倾倒复位接通断开";
	m_strInitial2+="通道零点满量程定向修改试验结果偏移量样品标号开启电源按";
	m_strInitial2+="运行停止菜单确认键上下左右阀泵";
	m_strInitial2+="背光显示状态日月年时分秒热电阻倾斜";
	m_strInitial2+="太低大小不能测量出采样准备好是否关闭全部结束第一次发现误差开路短";
	m_strInitial2+="日期时间有无文件名称";

	fsend=fopen("C:\\fsend","wb");
	frec=fopen("C:\\frec","wb");

//	MessageBox(m_strInitial1);
}


CSerialAppDlg::~CSerialAppDlg()
{
	CExpandingDialog::~CExpandingDialog();
	
	//to debug
	fclose(fsend);
	fclose(frec);
}

void CSerialAppDlg::DoDataExchange(CDataExchange* pDX)
{
	CExpandingDialog::DoDataExchange(pDX);
	//{{AFX_DATA_MAP(CSerialAppDlg)
	DDX_Control(pDX, IDC_PROGRESS, m_ProgressCtrl);
	DDX_Control(pDX, IDC_MSG, m_wndInput);
//	DDX_Control(pDX, IDC_BTNSEND, m_btnSend);
	DDX_Control(pDX, IDC_CHAT, m_wndShow);
	//}}AFX_DATA_MAP
}


BEGIN_MESSAGE_MAP(CSerialAppDlg, CExpandingDialog)
	//{{AFX_MSG_MAP(CSerialAppDlg)
	ON_WM_PAINT()
	ON_COMMAND(ID_CONFIG, OnConfig)
	ON_COMMAND(ID_CONNECT, OnConnect)
	ON_COMMAND(ID_DISCONNECT, OnDisconnect)
	ON_BN_CLICKED(IDC_BTNSEND, OnBtnsend)
	ON_MESSAGE(WM_COMM_RXCHAR, OnReceiveByte)
	ON_MESSAGE(WM_COMM_CTS_DETECTED, OnCTSDetected)
	ON_MESSAGE(WM_MSG_READ, OnReadProcess)
	ON_BN_CLICKED(IDC_SENDFILE_RADIO, OnSendfileRadio)
	ON_BN_CLICKED(IDC_FILESTART, OnFilestart)
	ON_BN_CLICKED(IDC_SENDFILECHOOSE, OnSendfilechoose)
	ON_BN_CLICKED(IDC_RECFILECHOOSE, OnRecfilechoose)
	ON_BN_CLICKED(IDC_RECFILE_RADIO, OnRecfileRadio)
	//}}AFX_MSG_MAP
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CSerialAppDlg message handlers

void CSerialAppDlg::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
	{
		CExpandingDialog::OnPaint();
	}

}

BOOL CSerialAppDlg::OnInitDialog() 
{
	CExpandingDialog::OnInitDialog();
	
	// TODO: Add extra initialization here
		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

	CenterWindow();

	//create the tool bar
	if(!m_wndToolBar.Create(this,
				WS_CHILD|WS_VISIBLE|CBRS_TOP|CBRS_TOOLTIPS|CBRS_FLYBY|CBRS_HIDE_INPLACE|CBRS_SIZE_DYNAMIC)
				||!m_wndToolBar.LoadToolBar(IDR_MAINFRAME)){
		TRACE0("Failed to create the tool bar!\n");
		return -1;
	}
	m_wndToolBar.GetToolBarCtrl().ModifyStyle(0,TBSTYLE_FLAT);
	m_wndToolBar.MoveWindow(6,4,385,30);

	DWORD dwExStyle = TBSTYLE_EX_DRAWDDARROWS;
	m_wndToolBar.GetToolBarCtrl().SendMessage(TB_SETEXTENDEDSTYLE, 0, (LPARAM)dwExStyle);
	
	DWORD dwStyle = m_wndToolBar.GetButtonStyle(m_wndToolBar.CommandToIndex(ID_CONNECT));
	dwStyle |= TBSTYLE_DROPDOWN;
	m_wndToolBar.SetButtonStyle(m_wndToolBar.CommandToIndex(ID_CONNECT), dwStyle);


	// init the port
	if (m_Port.InitPort(this, 1, 9600 ))
		;
//		m_Port.StartMonitoring();
	else
	{
		AfxMessageBox("Can't init COM1");
		return FALSE;
	}

	return TRUE;  // return TRUE unless you set the focus to a control
	              // EXCEPTION: OCX Property Pages should return FALSE
}

void CSerialAppDlg::OnConfig() 
{
	// TODO: Add your command handler code here
	CConfigDlg* dlg = new CConfigDlg(this, &m_Port);
	dlg->m_strSendBuffer.Format("%d", m_Port.GetWriteBufferSize());
	
	DWORD dwCommEvents = m_Port.GetCommEvents();

	if (dlg->DoModal() == IDOK)
	{

		switch(dlg->m_strComm[3])
		{
		case '1':
			m_nComm=0;
			break;
		case '2':
			m_nComm=1;
			break;
		case '3':
			m_nComm=2;
			break;
		case '4':
			m_nComm=3;
			break;
		default:
			break;
		}
		m_Port.m_nPortNr=m_nComm+1;
		
		this->m_nBandRate=	m_Port.m_dcb.BaudRate=	atoi(dlg->m_strBaudRate);
		this->m_cParity=	dlg->m_strParity[0];
		switch(m_cParity)
		{
		case 'N':
			m_Port.m_dcb.Parity=NOPARITY;
			break;
		case 'O':
			m_Port.m_dcb.Parity=ODDPARITY;
			break;
		case 'E':
			m_Port.m_dcb.Parity=EVENPARITY;
			break;
		case 'M':
			m_Port.m_dcb.Parity=MARKPARITY;
			break;
		case 'S':
			m_Port.m_dcb.Parity=SPACEPARITY;
			break;
		default:
			break;		
		}

		this->m_nDataBits=	m_Port.m_dcb.ByteSize=	atoi(dlg->m_strDataBits);
		this->m_nStopBits=	m_Port.m_dcb.StopBits=	atoi(dlg->m_strStopBits);
		this->m_dwCommEvents=	dwCommEvents;
		this->m_nSendBuffer=m_Port.m_nWriteBufferSize=	atoi(dlg->m_strSendBuffer);
		if(m_Port.m_szWriteBuffer)
			delete m_Port.m_szWriteBuffer;
		m_Port.m_szWriteBuffer=new BYTE[m_Port.m_nWriteBufferSize];

		if(!(m_Port.InitPort(this,m_nComm+1,m_nBandRate,m_cParity,m_nDataBits,m_nStopBits)))
		{
			char error[100];
			sprintf(error,"COM%d被占用或没有该COM口,请改用其它COM口！",m_nComm);
			AfxMessageBox(error);
		}
	}
	
	delete dlg;
}

void CSerialAppDlg::OnConnect() 
{
	// TODO: Add your command handler code here

	if(m_Port.m_bThreadAlive) return;
	if (m_Port.InitPort(this, m_nComm + 1, m_nBandRate, m_cParity, m_nDataBits, m_nStopBits ))
	{
		m_Port.StartMonitoring();
		m_wndShow.ShowMessage("Status: ","串口已打开");
	}
	else
	{
		// port not found
		AfxMessageBox("该COM口不可用，请改用其它COM口");
	}
}

void CSerialAppDlg::OnDisconnect() 
{
	// TODO: Add your command handler code here
	m_Port.StopMonitoring();
}

void CSerialAppDlg::OnBtnsend() 
{
	// TODO: Add your control notification handler code here
	CString str;
	m_wndInput.GetWindowText(str);
	WriteMsg(str);
	m_wndShow.ShowMessageThis(str);
	m_wndInput.SetWindowText("");
}

LONG CSerialAppDlg::OnReceiveByte(UINT wParam,LONG lParam)
{
	if(CSerialAppDlg::file==1)
	{
		m_strReceived+=(char)wParam;
		return 0;
	}
	switch((char)wParam)
	{
	case 3:				//STR[0]:
		if(msg==0)
		{
			msg=1;
			m_strReceived.Empty();	//to clear the buffer ;maybe need edit
		}
		else if(msg==1)
		{
			msg=0;
			::SendMessage(m_hWnd, WM_MSG_READ, (WPARAM) 0, (LPARAM) 0);
		}
		break;
	case 1:			//SYN[0]:	//message中不可能出现SYN[0],所以未加if(msg==0)语句校验
		if(file==0)
		{
			m_strReceived.Empty();
			m_strReceived+=(char)wParam;
			CSerialAppDlg::file=1;
//			this->WriteCommBlock((unsigned char*)ACK,1);
			CWinThread * fileThread=AfxBeginThread(CSerialAppDlg::ReceiveThread,this,THREAD_PRIORITY_HIGHEST); 
		}
		break;
	
	default:
		m_strReceived+=(char)wParam;
		break;
	}	
	return 0;
}


LONG CSerialAppDlg::OnReadProcess(UINT wParam,LONG lParam)
{
	UINT length;
	if(wParam==0)
		length=nSendBuffer;
	else
		length=wParam;
	BYTE* pBlock=new BYTE[length];
	memset(pBlock,0,length);

	int nRead=ReadCommBlock(pBlock,length);
	m_wndShow.ShowMessageThat(CString(pBlock));
	return nRead;
}

LONG CSerialAppDlg::OnCTSDetected(UINT wParam,LONG lParam)
{
	return 0;
}


int CSerialAppDlg::ReadCommBlock(unsigned char* pBlock, int nMaxLength)
{
	//maybe need delay
//?	memset(pBlock,0,nMaxLength);
	if(!m_Port.m_bBlockRead)
	{
		if(m_strReceived.GetLength()==0) return 0;
	
		int nRec=m_strReceived.GetLength();
		int nLength = (nMaxLength>nRec)? nRec : nMaxLength;
		CString strCopy= m_strReceived;
		char *temp=strCopy.GetBuffer(m_strReceived.GetLength()+1);
		memcpy((char*)pBlock,temp,nLength);

		//to debug
		fwrite(pBlock,1,nLength,frec);
	
		strCopy.ReleaseBuffer();

		m_strReceived.Delete(0,nLength);
		return nLength;
	}
	else
	{
		int templen=nPackSize+2;
		BYTE* pRead=CSerialPortEx::ReadBlock(&m_Port,templen);
		memcpy(pBlock,pRead,templen);

		fwrite(pBlock,1,templen,frec);
		
		delete pRead;
		return templen;
	}
}


//DEL void CSerialAppDlg::TransFile(char *pBlock, int length)
//DEL {
//DEL 	
//DEL }

BOOL CSerialAppDlg::ReceiveFile()
{
	CString path;
	CWnd* pWnd = GetDlgItem(IDC_EDIT_RECFILE);
	pWnd->GetWindowText(path);

	if(path=="")
	{
		CFileDialog dlg(FALSE);
		if(dlg.DoModal()==IDOK)
		{
			path = dlg.GetPathName();
			CWnd* pWnd = GetDlgItem(IDC_EDIT_RECFILE);
			pWnd->SetWindowText(path);
		}
	}
	if(path=="") return FALSE;

	const	int	MAXBLOCK=nPackSize+2; 

	int		step;
	FILE	*RSF;
	long	readlen,templen;
	WORD	check;

	DWORD	nLength,start,ReSendSum,ci;

	BOOL	bTimeout;

	BYTE    abIn[ MAXBLOCK],*buf,*bufp,*old_bufp;

	BOOL    bRet=TRUE; 
   	WORD    nRecord=0;
	WORD	totalRec=0;
	WORD	initRec=10;
	
	ReSendSum=3; 


   	RSF=fopen(path,"wb");//"wb" for append
	if(!RSF)
	{
		return FALSE;
	}
	buf=(BYTE*)new BYTE[MAXBLOCK*initRec];//
	if(!buf)
	{
		fclose(RSF);
		return FALSE;
	}

    step=0;
	totalRec=0;
	
	bufp=buf;
	nLength=0;
	start=GetTickCount();

	bTimeout=FALSE;

	while((nLength==0)&&(!bTimeout)&&(!m_Port.m_bBlockRead))
	{
		nLength=m_strReceived.GetLength();
		bTimeout = (GetTickCount()-start>=SYNTIME);
	}

	if (bTimeout) {
//		SendCommMsg(CSM_TIMEOUT,0);
//		return FALSE;
		bRet=FALSE;
		goto clearrub;
	}

	do{
		switch(step)
		{
			case 0:	
				    nLength = ReadCommBlock( (unsigned char*) abIn, MAXBLOCK );
					if((abIn[0]==SYN[0])) 
					{
						WriteCommBlock( (unsigned char*)ACK, 1);
						step=1;
						ReSendSum=3; 
						start=GetTickCount();					
					}
					break;

			case 1:
					bTimeout=FALSE;
					nLength=0;
					while((nLength<6)&&(!bTimeout))
					{
						nLength = m_strReceived.GetLength();
						bTimeout = (GetTickCount()-start>=RSDTIME);
					}
					if (bTimeout) 
					{
//						SendCommMsg(CSM_TIMEOUT,0);
//						return FALSE;
						bRet=FALSE;
						goto clearrub;
					}

					nLength = ReadCommBlock(abIn, MAXBLOCK );
					if( (nLength==6) &&(abIn[0]==0) && ( (abIn[1]==0) || (abIn[1]==1) )) 
					{	
						
						start=GetTickCount();	
						check=0;
						check+=abIn[2]+(abIn[2]&0x80?0xff00:0);
						check+=abIn[3]+(abIn[3]&0x80?0xff00:0);
						
						if((BYTE(check>>8)==abIn[4])&&(BYTE(check&0xff)==abIn[5]))
						{
							ReSendSum=3; 
							memcpy(bufp,abIn,6);
							bufp+=6;

							if(abIn[1]==1)
							{
								if((abIn[2]==0)&&(abIn[3]==0)&&(abIn[4]==0)&&(abIn[5]==0)) 
								{
									step=4;		//完结
								}
								else
								{
									step=1;
									totalRec=((WORD)abIn[2]<<8)+(WORD)abIn[3];
									if(totalRec>initRec)
									{
										BYTE* newbuf=new BYTE[totalRec*MAXBLOCK];
										if(!newbuf)
										{
											bRet=FALSE;
											goto clearrub;
										}
										memcpy(newbuf,buf,initRec*MAXBLOCK);
										bufp=newbuf+(bufp-buf);
										delete buf;
										buf=newbuf;
										newbuf=NULL;

										this->m_ProgressCtrl.SetRange(0,totalRec);
									}
								}
							}
							
							else
							{
								//当传输只有一个字节的文件时将出现问题
//								if((abIn[3]==1)&&(abIn[4]==0)&&(abIn[5]==1)) 
//								{
//									step=4;
	//?								fwrite("\0\0\0\x1\0\x1",1,6,RSF);
//									//完结
//								}
//								else
//								{	
									step=3;
									templen=(((long)abIn[2]<<8)+(long)abIn[3])+(long)2;
									m_Port.m_bBlockRead=TRUE;
//								}
							}

							WriteCommBlock((unsigned char*)ACK, 1);
							break;
						}
					}
					if(ReSendSum==0)
					{
//						AfxMessageBox("Fail");,0);
//						return FALSE;
						bRet=FALSE;
						goto clearrub;
					}
					step=1;
					ReSendSum--;
					WriteCommBlock((unsigned char*)RESEND, 1);
					break;

					
			//开始下一包，并记录进度
			case 2:
					nLength = ReadCommBlock(abIn, MAXBLOCK );
					if(abIn[0]==SYN[0])
					{	
						start=GetTickCount();
						ReSendSum=3;
						step=1;

						nRecord++;
						if(nRecord)				   
							this->m_ProgressCtrl.SetPos(nRecord);	 
						
						WriteCommBlock( (unsigned char*)ACK, 1);
					}
					break;
			
			//读包内数据
			case 3:
					step=2;
					check=0;
					readlen=0;
					old_bufp=bufp;
					start=GetTickCount();
					do{	
						nLength = ReadCommBlock( (unsigned char*) abIn, MAXBLOCK );