?? ysatmodem.cpp
字號:
// 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是否就續(xù)
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不支持這種通知
{
//這里有個問題,如果對方撥號一聲后,掛斷,計數(shù)器沒清零,第二次就會出問題
if(iRing>0)
{
if(GetTickCount()-dwTime>10000)
iRing=0;//如果兩次響鈴大于10秒鐘,重設(shè)為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;//如果正在撥號的時候斷線,可能會出現(xiàn)CD變化?
}
}
TRACE(_T("Quit Detect Thread"));
return 1;
}
/*************************2001.10.30 ycat *********************************************
FUNCTION: UINT CYsATModem::ReadCommThread(LPVOID pParam)
PURPOSE: 線程函數(shù)，把串口讀入緩沖區(qū)的字符，寫到自己維護(hù)的緩沖區(qū)中,并判斷斷線
PARAMETERS:
pParam：指向CYsATModem類
RETURN VALUE:
COMMENTS: 斷線的處理，也許還要改進(jìn)
**********************************************************************/
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,如果當(dāng)前狀態(tài)為連接狀態(tài),或線路忙(轉(zhuǎn)成等待方式),等待的時間
RETURN VALUE:
如果操作成功，返回TRUE,如果失敗返回FALSE
COMMENTS:
1)發(fā)送ATDXXX后，會段時間等待，連接字符串的返回,
如果另一邊一撥號成功就發(fā)送數(shù)據(jù)，很可能會導(dǎo)致數(shù)據(jù)丟失
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: 生成串口文件句柄，
發(fā)送AT命令查看Modem是否正常,
生成一個掛起的收數(shù)線程
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("創(chuàng)建通信端口失敗"));
//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,復(fù)位命令
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];
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -