recvthread.cpp

C++语言开发的受机短信相关的源程序

// RecvThread.cpp : implementation file
//

#include "stdafx.h"
#include "HWCmppAPI.h"
#include "RecvThread.h"
#include "DataConvert.h"
#include "define.h"



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

extern void GfWriteLog(CString str);

/////////////////////////////////////////////////////////////////////////////
// CRecvThread

IMPLEMENT_DYNCREATE(CRecvThread, CWinThread)

CRecvThread::CRecvThread()
{
	m_bIfRun = FALSE;
	this->m_bAutoDelete = TRUE;
	SetIfShowMsg(FALSE);
	m_bInit = FALSE;
}

CRecvThread::~CRecvThread()
{
	m_bIfRun = FALSE;

}

BOOL CRecvThread::InitInstance()
{
	// TODO:  perform and per-thread initialization here
	::CoInitialize(NULL);
	return TRUE;
}

int CRecvThread::ExitInstance()
{
	// TODO:  perform any per-thread cleanup here
	CoUninitialize();
//	::Sleep(50);
//	::PostThreadMessage(this->m_nThreadID,WM_QUIT,0,0);
	return CWinThread::ExitInstance();
}

BEGIN_MESSAGE_MAP(CRecvThread, CWinThread)
	//{{AFX_MSG_MAP(CRecvThread)
		// NOTE - the ClassWizard will add and remove mapping macros here.
	//}}AFX_MSG_MAP
	ON_THREAD_MESSAGE(WM_USER+505,OnRecvLoop)
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CRecvThread message handlers

void CRecvThread::Start()
{
	m_bIfRun = TRUE;
	::PostThreadMessage(this->m_nThreadID,WM_USER+505,0,0);
//	this->m_pParent->ShowMsg("Recv thread start!");
}

void CRecvThread::Stop()
{
	m_bIfRun = FALSE;
//	::PostThreadMessage(this->m_nThreadID,WM_QUIT,0,0);
}

BOOL CRecvThread::Init(int nID,CString strQueueUp, CString strQueueDown, CHWCmppAPIDlg *pParent)
{
	if(m_bInit == TRUE)
	{
		return TRUE;
	}
	m_nID= nID;
	if(!m_queueRW.InitInstance(strQueueUp, strQueueDown)){
		return FALSE;
	}
	if(pParent)
	{
		this->m_pParent = pParent;
		SetIfShowMsg(this->m_pParent->m_bIsShowMsg);
	}
	else{
		return FALSE;
	}
	m_bInit = TRUE;
	return TRUE;
}
LRESULT CRecvThread::OnRecvLoop(WPARAM w,LPARAM l)
{

	CString strLable="";
	CString strBody="";
	
	ULONG ulsm_ID;
	unsigned char byDestTON, byDestNPI, byOrgTON, byOrgNPI, byPRI, byPID, byDCS;
	char sDestAddr[MAX_ADDR_LEN];
	char sOrgAddr[MAX_ADDR_LEN];
	char sTimeStamp[MAX_TIMESTAMP_LEN];
	char sUserData[MAX_UD_LEN];
	unsigned char MsgID[23];
	char sSubmitdate[MAX_SUBMIT_TIME_LEN+1];
	char sDonedate[MAX_DONE_TIME_LEN+1];
	char sStatus[MAX_STATE_LEN+1];
	int iRet;
	unsigned char byRP;
	unsigned char byUDHI;
	unsigned long ulUDLen;
	unsigned char byStatusReport = 0;
	while(m_bIfRun)
	{
/*		//test
		this->m_pParent->PostMessage(WM_USER+601, 1, 1);//MT++, RC++
		ShowMsg("OnRecvLoop!!!fdjfldjfdjfldjf");	
*/
		if(HasDeliverMessage(100) != 0){
			::Sleep(100);
			continue;
		}
		memset(sDestAddr, 0, MAX_ADDR_LEN);
		memset(sOrgAddr, 0, MAX_ADDR_LEN);
		memset(sTimeStamp, 0, MAX_TIMESTAMP_LEN);
		memset(sUserData, 0, MAX_UD_LEN);
		memset(MsgID, 0, 23);
		memset(sSubmitdate, 0, MAX_SUBMIT_TIME_LEN+1);
		memset(sDonedate, 0, MAX_DONE_TIME_LEN+1);
		memset(sStatus, 0, MAX_STATE_LEN+1);

		try
		{
			iRet = GetDeliverSMExExEx(&ulsm_ID, &byDestTON, &byDestNPI, sDestAddr,   
				&byOrgTON,&byOrgNPI, sOrgAddr, &byPRI, &byRP, &byUDHI, &byPID,
				&byDCS,sTimeStamp, &ulUDLen, sUserData, &byStatusReport, MsgID, 
				sSubmitdate, sDonedate, sStatus);
		}
		catch(...)
		{
		}

		if(iRet == 0)
		{
			if(byStatusReport == 1)// report 
			{
				strBody = "";
				CString strGateID;
				CDataConvert::BYTE8ToDeintGateid(MsgID, strGateID);

				if(strcmp(sStatus, "DELIVRD") == 0)//report ok
				{
					strLable.Format("TYPE:Report;GateId:%s;Status:%d", strGateID, 0);
					
					if(!m_queueRW.WriteQueue(strLable, strBody, 0))
					{
						ShowMsg("Report 0 WriteQueue Failed");
						::GfWriteLog("\nReport 0 WriteQueue Failed");	
						GfWriteLog(strLable);//Linbo 2003-1-23 22:39:45 						
					}
					//this->m_nRPNum++;				
					//InterlockedIncrement((long*)&m_nRPNum);
					this->m_pParent->PostMessage(WM_USER+601, 0,1);
				}
				else//report fail
				{
					strLable.Format("TYPE:Report;GateId:%s;Status:%d", strGateID, 1);
					
					if(!m_queueRW.WriteQueue(strLable, strBody, 1))
					{
						ShowMsg("Report 1 WriteQueue Failed");
						::GfWriteLog("\nReport 1 WriteQueue Failed");	
					//	GfWriteLog(strLable);//Linbo 2003-1-23 22:39:45 
					}
					strLable.Format("TYPE:Report;GateId:%s;Status:%s", strGateID, sStatus);
					GfWriteLog(strLable);//Linbo 2003-1-23 22:39:45 
				}	
				ShowMsg(strLable);
			}

			else// Mo
			{
				CString strTemp = sOrgAddr;
				CString strSrc = strTemp.Right(11);			
				strLable.Format("TYPE:MO;SRC:%s;DEST:%s;", strSrc,sDestAddr);
				strBody.Format("%s", sUserData);

				if(!m_queueRW.WriteQueue(strLable, strBody, (long)4))
				{
					ShowMsg("MO WriteQueue Failed");
					::GfWriteLog("\nMO WriteQueue Failed");	
					//Linbo Add 2003-1-23 20:48:31 -->
					//Comments: ...
					::GfWriteLog("Lable:"+strLable);
					::GfWriteLog("Body:"+strBody);
					//Linbo Add 2003-1-23 20:48:31 <--
				}
				//InterlockedIncrement((long*)&m_nMONum);
				//this->m_nMONum++;
				this->m_pParent->PostMessage(WM_USER+601,1, 0);
				ShowMsg(strLable+" "+strBody);				
			}
		}
		else
		{
			::Sleep(10);
//			::GfWriteLog("Recv Data failed.");
		}
		::Sleep(100);//每次处理完后休息
	}
	return 0;
}

void CRecvThread::SetIfShowMsg(BOOL bIsSHow)
{
	m_criticalIsShowMsg.Lock();
 	this->m_bIsShowMsg = bIsSHow;
	m_criticalIsShowMsg.Unlock();
}
BOOL CRecvThread::GetIfShowMsg()
{
	m_criticalIsShowMsg.Lock();
	BOOL bIsShow = m_bIsShowMsg;
	m_criticalIsShowMsg.Unlock();
	return bIsShow;
}

void CRecvThread::ShowMsg(const CString &strMsg)
{
 	if(this->GetIfShowMsg())
	{
		m_strMsg = strMsg;
		m_pParent->SendMessage(WM_USER+605, 0, m_nID);	
	}
}

void CRecvThread::QuitThread()
{
	m_bIfRun = FALSE;
	::PostThreadMessage(this->m_nThreadID,WM_QUIT,0,0);
}