// 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';


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


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 );
						if(nLength>0)
						{