// ATModem.cpp: implementation of the CYsATModem class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "YsATModem.h"


#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif
UINT CYsATModem::WaitThread(LPVOID lpvoid)
{
	CYsATModem* pThis=(CYsATModem*)lpvoid;
	pThis->DetectConnect();
	return 1;
}

//檢測modem是否就續
UINT CYsATModem::DetectModemThread(LPVOID pParam)
{
	TRACE(_T("in Detect Thread"));
	CYsATModem* pThis=(CYsATModem*)pParam;
	DWORD dwEvent;
	DWORD dwTime;
	int iRing=0;

	pThis->m_bCD=0;

	while(1==pThis->WaitEvent(&dwEvent,INFINITE))
	{
		if(dwEvent&EV_DSR)
		{
			pThis->SetEvent(0);
			//糟啦,modem壞啦!!!
			TRACE(_T("My God!!! the modem broken!!!\n"));
			pThis->Purge(PURGE_ALL);
			pThis->ChangeMode(MODE_UNMODEM);
			TRACE(_T("Quit Detect Thread"));
			return 1;
		}
		else if(dwEvent&EV_RING)//win95不支持這種通知
		{
			//這里有個問題,如果對方撥號一聲后,掛斷,計數器沒清零,第二次就會出問題
			if(iRing>0)
			{
				if(GetTickCount()-dwTime>10000) 
					iRing=0;//如果兩次響鈴大于10秒鐘,重設為0
			}
			dwTime=GetTickCount();
			iRing++;
			CString s;
			s.Format("ring count=%d %d Mode=%d\n",iRing,pThis->m_nRingCount,pThis->m_nMode);
			TRACE(s);
			if(pThis->m_nMode==MODE_COMMAND)
			{
				if(iRing>=pThis->m_nRingCount)
				{
					iRing=0;
#ifdef USER_ANSWER
					Sleep(500);
					pThis->SendAT(CMD_ATA);
#endif				
					AfxBeginThread(WaitThread,pThis);
				}
			}
		}
		else if(dwEvent&EV_RLSD)
		{
			CString s;
			s.Format("\nCD燈改變 @@@  %d -%d\n",pThis->m_nMode,pThis->m_bCD);
			TRACE(s);
			if(pThis->m_nMode==MODE_DATA)
			{
				pThis->m_bCD=FALSE;
				TRACE("Modem Disconnect!!!!\n");

				ResetEvent(pThis->m_hConnected);
				pThis->ChangeMode(MODE_COMMAND);

				pThis->HangUp();
				if(pThis->m_Thread)
				{
					if(WAIT_OBJECT_0!=WaitForSingleObject(pThis->m_Thread->m_hThread,10000))
					{
						TerminateThread(pThis->m_Thread->m_hThread,-11);
					}
					delete pThis->m_Thread;
					pThis->m_Thread=NULL;
				}
			}
			else if(pThis->m_nMode==MODE_CONNECTING)
			{
				pThis->m_bCD=TRUE;

				pThis->StopRead();

				pThis->Purge(PURGE_ALL);
				pThis->m_Thread = AfxBeginThread(CYsATModem::ReadCommThread,(LPVOID)pThis);
				if(!pThis->m_Thread)
				{
					pThis->ChangeMode(MODE_COMMAND);
					pThis->SetLastError(_TEXT("Start read comm thread error"));
					return FALSE;
				}
				pThis->m_Thread->m_bAutoDelete=FALSE;
				::SetEvent(pThis->m_hConnected);
				pThis->ChangeMode(MODE_DATA);
				TRACE("Modem connect!!!!\n");
				//無處理
			}
			else pThis->m_bCD=FALSE;//如果正在撥號的時候斷線,可能會出現CD變化?
		}
	}
	TRACE(_T("Quit Detect Thread"));
	return 1;
}

/*************************2001.10.30 ycat *********************************************
FUNCTION: UINT CYsATModem::ReadCommThread(LPVOID pParam)

PURPOSE: 線程函數，把串口讀入緩沖區的字符，寫到自己維護的緩沖區中,并判斷斷線

PARAMETERS:
		pParam：指向CYsATModem類

RETURN VALUE:

COMMENTS: 斷線的處理，也許還要改進
**********************************************************************/
UINT CYsATModem::ReadCommThread(LPVOID pParam)
{
	//judge if no carrier
	char strJudge[]=ECHO_NOCARRIER;
	//current judge string position
	int iJudge=0;
	int iJudgeSize=strlen(strJudge);

	TRACE("Start Thread\n");
	CYsATModem* pThis=(CYsATModem*)pParam;

	DWORD dwInterTimeOut=INFINITE;//讀每個字符之間的等待時間

	int i;
	BYTE chRead;
	DWORD dwHaveRead;
	while(1)
	{
		do 
		{
			//read one char
			i=pThis->ReadComm(&chRead,1,&dwHaveRead,dwInterTimeOut);
			if (1==i)
			{
				TRACE(_TEXT("##:%02x\n"),chRead,chRead);
				pThis->m_pQueue->Put(&chRead);
			}
			else if(i==-3)
			{
				TRACE(_TEXT("stop event set!~\n"));
				//user hangup
				i=TRUE;
				goto Exit;
			}
			else if(i==-1) //非超時
			{
				TRACE(_TEXT("in Function Read Error code%d\n"),i);
				i=FALSE;
				goto Exit;
			}
		}
		while(dwHaveRead);
	}//while
Exit:
	TRACE(_TEXT("End Read comm Thread\n"));

	if(!i) TRACE(_TEXT("there are some error occur in thread\n"));
	return i;
}
//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

CYsATModem::CYsATModem()
{
	m_nRingCount=2;
	m_bInit=FALSE;
	m_bTestMode=FALSE;
	ChangeMode(MODE_UNINITIALIZE);

	m_pQueue=new CYsQueue<BYTE>(QUEUE_SIZE);

	m_Thread=NULL;
	//順序不能變
	pstrCmdString[0]=ECHO_OK;
	pstrCmdString[1]=ECHO_CONNECT;
	pstrCmdString[2]=ECHO_RING;
	pstrCmdString[3]=ECHO_NOCARRIER;
	pstrCmdString[4]=ECHO_ERROR;
	pstrCmdString[5]=ECHO_CONNECT1200;
	pstrCmdString[6]=ECHO_NODIALTONE;
	pstrCmdString[7]=ECHO_BUSY;
	pstrCmdString[8]=ECHO_NOANSWER;
	m_hConnected=CreateEvent(NULL,TRUE,FALSE,NULL);
	ResetError();
}


CYsATModem::~CYsATModem()
{
#ifndef USER_ANSWER
	if(m_nMode==MODE_COMMAND)
		SendAT(CMD_ATS0);
#endif
	//because m_Thread->m_bAutoDelete set FALSE
	if(m_pQueue)delete m_pQueue;
}

/*************************2001.10.30 ycat *********************************************
/*************************2002.04.15 ycat *********************************************

FUNCTION: BOOL CYsATModem::DialUp(LPTSTR strDial,int iTime)

PURPOSE: 用AT命令建立連接

PARAMETERS:
		strDial:要撥號的號碼
		iTime:如果不為0,如果當前狀態為連接狀態,或線路忙(轉成等待方式),等待的時間
RETURN VALUE:
    如果操作成功，返回TRUE,如果失敗返回FALSE

COMMENTS: 
	1)發送ATDXXX后，會段時間等待，連接字符串的返回,
		如果另一邊一撥號成功就發送數據，很可能會導致數據丟失
	2)對電話號碼的支持有待測試,特別字符
**********************************************************************/
BOOL CYsATModem::DialUp(LPCTSTR strDial)
{
	if(m_bTestMode)return TRUE;
	if(m_nMode==MODE_UNINITIALIZE||m_nMode==MODE_UNMODEM)
		if(m_bInit)
		{
			if(!InitModem(m_nPort,m_iBaud,2,m_hWnd))
				return FALSE;
		}
	if(m_nMode==MODE_DATA)
	{
		return TRUE;//have connected
	}
	if(m_nMode==MODE_CONNECTING)//connecting
	{
		//wait connect success
		if(WAIT_OBJECT_0==WaitForSingleObject(m_hConnected,DIALTIME_START))
			return TRUE;//have connected
		return FALSE;
	}
	if(m_nMode!=MODE_COMMAND)//MODE_DIALING MODE_WAITRING
		return FALSE;

	CHAR strTemp[200];
	lstrcpy(strTemp,CMD_ATD);
	lstrcat(strTemp,(LPCTSTR)strDial);
	SendAT(strTemp);

	return DetectConnect();
}
/*************************2001.10.30 ycat *********************************************
FUNCTION: int CYsATModem::DetectConnect()

PURPOSE: 檢測連接

PARAMETERS:
RETURN VALUE:
    如果操作成功，返回TRUE,如果失敗返回FALSE
COMMENTS: 
**********************************************************************/
int CYsATModem::DetectConnect()
{
	if(m_nMode!=MODE_COMMAND) return FALSE;
	ChangeMode(MODE_CONNECTING);
	CHAR strTemp[200];
	Sleep(3000);
	
	//讀字符
	DWORD dwRead;
	int nErr;
	int nRet=FALSE;

	Purge(PURGE_ALL);
	TRACE("\n  Clear  \n");
	memset(strTemp,0,200);
	nErr=this->ReadComm((PBYTE)strTemp,200,&dwRead,DIALTIME_START,DIALTIME_INTER);
	TRACE(strTemp);
/*	if(nErr!=-2)
	{
		goto Exit;
	}
	strTemp[dwRead]='\0';

	i=CheckString(strTemp);
	
	//find AT command string 
	if(i==CODE_CONNECT)		nRet=TRUE;
	else if(i==CODE_CANNTFIND)//can't fine AT command string
	{
		TRACE(_TEXT("Unknow string %s\n"),strTemp);
		goto Exit;
	}
	else// if(i==CODE_BUSY||i==CODE_NODIALTONE)
	{
		goto Exit;
	}
	if(m_nMode!=MODE_CONNECTING) return m_bCD;//可能中間運行了hangup()*/
//Exit:
	if(!m_bCD)
	{
		SendAT(CMD_AT);//打斷連接
		Sleep(500);
		Purge(PURGE_ALL);
		ChangeMode(MODE_COMMAND);
	}
	else ChangeMode(MODE_DATA);
	return m_bCD;
}

/*************************2001.10.30 ycat *********************************************
FUNCTION: BOOL InitModem(UINT nPort,HWND hWnd)

PURPOSE: 生成串口文件句柄，
		 發送AT命令查看Modem是否正常,
		 生成一個掛起的收數線程

PARAMETERS:
		nPort:串口號,com1為1,com2為2
		hWnd:用來接收消息的窗口
RETURN VALUE:
    如果操作成功，返回TRUE,如果失敗返回FALSE

COMMENTS: 
**********************************************************************/
BOOL CYsATModem::InitModem(UINT nPort,UINT uBaud,int iRingCount,HWND hWnd)
{
	m_bCD=FALSE;
	m_nRingCount=iRingCount;
	if(!m_bTestMode)
	{
		if(m_nMode!=MODE_UNINITIALIZE&&m_nMode!=MODE_UNMODEM) return TRUE;


	}

	//create comm
	if(!Create(nPort))
	{
		SetLastError(_TEXT("創建通信端口失敗"));
		//SetLastError(_TEXT("Create Comm error"));
		return FALSE;
	}
	if(!SetComm(uBaud))
	{
		SetLastError(_TEXT("Set comm error"));
		return FALSE;
	}

	m_hWnd=hWnd;

	//clear comm buffer
	if(!Purge(PURGE_ALL))
	{
		return FALSE;
	}
	m_pQueue->Clear();
	if(m_bTestMode) return TRUE;

	ChangeMode(MODE_UNMODEM);

	int i;
	TCHAR buffer[50];
	DWORD length=0;

	//send ATZ0,復位命令
	if(!SendAT(CMD_ATZ0))
	{
		return FALSE;
	}
	//if echo don't open then must timeout
	i=ReadComm((PBYTE)buffer,11,&length,WAITTIME);

	if(i!=1&&i!=-2)
	{
		SetLastError(_TEXT("讀串口失敗"));
		//SetLastError(_TEXT("Read comm error"));
		return FALSE;
	}
	buffer[length]='\0';
	i=CheckString(buffer);
	if(i!=CODE_OK)
	{
		SetLastError(_TEXT("Cann't find OK string"));
		return FALSE;

	}

	//取消回顯
	if(!SendAT(CMD_ATE))
	{
		return FALSE;
	}
	i=ReadComm((PBYTE)buffer,10,&length,WAITTIME);
	if(1!=i)
	{
		SetLastError(_TEXT("讀串口失敗"));
		//SetLastError(_TEXT("Read comm error"));
		return FALSE;
	}
	buffer[length]='\0';
	i=CheckString(buffer);
	if(i!=CODE_OK)
	{
		SetLastError(_TEXT("Cann't find OK string"));
		return FALSE;
	}

#ifndef USER_ANSWER
	TCHAR temp[10];