/*!	\file		CSerial.cpp
	\brief		CSerial類實現文件
	\author		陳華毅
	\version	1.0

	這個類完成處理串口操作。通過 \a OpenComm()讀取打開串口；
			通過\a CloseComm()從關閉串口。
	\defgroup	CSERIAL_IMPLEMENT	CSerial類實現說明
*/

#include "stdafx.h"
#include "GPRS.h"
#include "Serial.h"

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

//@{Group: CSERIAL_IMPLEMENT

CSerial::CSerial()
{

}

CSerial::~CSerial()
{

}


DWORD CSerial::InitDCB()
{
	DCB dcb;

	dcb.fBinary = TRUE;		/* Win32不支持非二進制串行傳輸模式，必須為TRUE */
	dcb.fParity = FALSE;	/* 不啟用奇偶校驗 */
	dcb.BaudRate = 115200;
	dcb.ByteSize = 8;
	dcb.Parity = NOPARITY;
	dcb.StopBits = ONESTOPBIT;

	/* 控制位 */
	dcb.fRtsControl = RTS_CONTROL_DISABLE;
	dcb.fOutxCtsFlow = FALSE;
	dcb.fOutX = FALSE;		/* 設為TRUE指定XON/XOFF控制被用于控制串行輸出 */
	dcb.fInX = FALSE;		/* 設為TRUE指定XON/XOFF控制被用于控制串行輸入 */

	/* XON/XOFF流控制設置 */
	dcb.fInX=dcb.fOutX = FALSE;
	dcb.XonChar = 0x11;
	dcb.XoffChar = 0x13;
	dcb.XonLim = 500;
	dcb.XoffLim = 500;

	return SetCommState(m_hFile,&dcb);
}

DWORD CSerial::ReadComm(BYTE *pData, DWORD dwLength)
{
	DWORD length=0;
	DWORD dwRealRead=0;
	COMSTAT ComStat;
	DWORD dwErrorFlags;

	BOOL Status;

	/* 檢測串口緩存內數據 */
	ClearCommError(m_hFile,&dwErrorFlags,&ComStat);
	length = min(dwLength, ComStat.cbInQue);

	Status = ReadFile(m_hFile, pData, length, &dwRealRead, NULL);
	if(Status == FALSE)
	{
		DWORD error;
		MessageBox(NULL,TEXT("Read file failed"),NULL, MB_OK);
		error = GetLastError();
		/* 超時退出 */
		if(error == ERROR_TIMEOUT)
		{
			return dwRealRead;
		}
		
	}
	return dwRealRead;
}

BOOL CSerial::CloseComm()
{
	if (m_hFile)
	{
		/* 結束線程中WaitCommEvent的等待 */
		SetCommMask(m_hFile, 0);

		/* 清除端口上指定信號的狀態 */
		EscapeCommFunction(m_hFile, CLRDTR);
		EscapeCommFunction(m_hFile, CLRRTS);

		/* 清除驅動程序內部的發送和接收隊列 */
		PurgeComm(m_hFile, PURGE_TXCLEAR | PURGE_RXCLEAR);
		CloseHandle(m_hFile);
		m_hFile = INVALID_HANDLE_VALUE;
		return TRUE;
	} else{
		::MessageBox(NULL, TEXT("Close Comm Failed!"), NULL, MB_OK);
		return FALSE;
	}
}


BOOL CSerial::OpenComm()
{
	COMMTIMEOUTS TimeOuts;
	CString str ;
	m_hFile = CreateFile(TEXT("COM1:"), GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);

	if (INVALID_HANDLE_VALUE == m_hFile)
	{
		MessageBox(NULL, TEXT("OpenComm failed"), NULL, MB_OK);
		str.Format(TEXT("%d"),GetLastError());
		MessageBox(NULL, str, NULL, MB_OK) ;
	}

	/* 設置串口接收和發送緩沖大小 */
	if (!SetupComm(m_hFile, 1024, 1024)) 
	{
		MessageBox(NULL,TEXT("SetupComm failed\r\n"), NULL, MB_OK);
		return FALSE;
	}

    /* 設置事件和超時時間 */
    if(!SetCommMask(m_hFile, EV_RXCHAR)) 
	{
		MessageBox(NULL, TEXT("SetupCommMask failed\r\n"), NULL, MB_OK);
		return FALSE;
	}
	TimeOuts.ReadIntervalTimeout = MAXDWORD;
	TimeOuts.ReadTotalTimeoutMultiplier = 0;
	TimeOuts.ReadTotalTimeoutConstant = 0;
	TimeOuts.WriteTotalTimeoutMultiplier = 100;
	TimeOuts.WriteTotalTimeoutConstant = 1000;

	SetCommTimeouts(m_hFile,&TimeOuts);
	if (!InitDCB())
	{
		MessageBox(NULL, TEXT("config comm failed"), NULL, MB_OK);
	}
	return TRUE;
}


DWORD CSerial::WriteComm(BYTE *pData, DWORD dwLength)
{
	BOOL fState;
	DWORD length = dwLength;
	DWORD dwRealWrite;
	DWORD dwErrorFlags;

	ClearCommError(m_hFile, &dwErrorFlags, NULL);
	fState = WriteFile(m_hFile, pData, length, &dwRealWrite, NULL);

	if(FALSE == fState)
	{
		MessageBox(NULL, TEXT("Write comm failed"), NULL, MB_OK);
		dwRealWrite = 0;
	}
	return dwRealWrite;

}