sendthread.cpp

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

// SendThread.cpp : implementation file
//

#include "stdafx.h"
#include "HWCmppAPI.h"
#include "SendThread.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);

/////////////////////////////////////////////////////////////////////////////
// CSendThread

IMPLEMENT_DYNCREATE(CSendThread, CWinThread)

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

CSendThread::~CSendThread()
{
	m_bIfRun = FALSE;
}

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

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

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

/////////////////////////////////////////////////////////////////////////////
// CSendThread message handlers

BOOL CSendThread::Init(int nID, CString strQueueUp, CString strQueueDown, char * chIcpId, CHWCmppAPIDlg* pParent)
{
	if(m_bInit == TRUE)
	{
		return TRUE;
	}
	this->m_nID = nID;
	if(!m_queueRW.InitInstance(strQueueUp, strQueueDown)){
		return FALSE;
	}
	if(chIcpId){
		strcpy(m_chIcpId, chIcpId);
	}
	else{
		return FALSE;
	}
	if(pParent)
	{
		m_pParent = (CHWCmppAPIDlg*)pParent;
		SetIfShowMsg(this->m_pParent->m_bIsShowMsg);
	}
	else{
		return FALSE;
	}
	m_bInit = TRUE;
	return TRUE;
}

void CSendThread::Start()
{
	m_bIfRun = TRUE;
	::PostThreadMessage(this->m_nThreadID,WM_USER+500,0,0);
}

void CSendThread::Stop()
{
	m_bIfRun = FALSE;
}

LRESULT CSendThread::OnSendLoop(WPARAM w,LPARAM l)
{
	CString strLable = "";
	_variant_t vBody;
	vBody.Clear();
	long lPri = 0;
	int nRet = -1;
	BOOL bSendSuccess = TRUE; 

	while(m_bIfRun)
	{
/*		//test
		this->m_pParent->PostMessage(WM_USER+600, 1, 1);//MT++, RC++
		ShowMsg("OnSendLoop!!!");	
*/
		if(m_queueRW.ReadQueue(strLable,vBody,lPri,1))
		{
//			GfWriteLog("InitLable:"+strLable);
			__int32 nMsgID = (__int32)CLable::GetMsgId(strLable);
			CString strGateID;
			
			int MsgFormat = CLable::GetMsgFormat(strLable);
//			if( ::CLable::GetFormatType(MsgFormat) == 0 )//0-text, 1-Binary, x－expand。 Linbo Comment 2002-11-21 11:25:50
			if( ::CLable::GetCodeType(strLable) == 0 )//0-text, 1-Binary, x－expand。 Linbo Comment 2002-11-21 11:25:50
			{
				_bstr_t bstrBody(vBody);
				int msglenbstr=bstrBody.length()*2;	  //长度大	unicode长度
				
				CString strBody;
				strBody=(const char*)bstrBody;
				int msglenstr=strBody.GetLength();	  //不同长度 ascii长度
				
				if(msglenbstr==2*msglenstr)
				{//纯英文
					nRet = SendSM(1, 1, CLable::GetSrcId(strLable), CLable::GetDestId(strLable), CLable::GetFeePhone(strLable),
						(char*)(const char*)strBody, msglenstr,
						0, MsgFormat, CLable::GetFeetype(strLable),CLable::GetFeecode(strLable),
						CLable::GetSevId(strLable), nMsgID, lPri, strGateID);		
				}
				else
				{//含中文或纯中文
					if(msglenstr >140)
					{
					//	strBody = (const wchar_t *)bstrBody;
						strBody.Left(140);
						msglenbstr  = 140;
					}
					nRet = SendSM(1, 1, CLable::GetSrcId(strLable), CLable::GetDestId(strLable), CLable::GetFeePhone(strLable),
						(char*)(const char*)strBody, msglenstr, 
						0, MsgFormat, CLable::GetFeetype(strLable),CLable::GetFeecode(strLable),
						CLable::GetSevId(strLable), nMsgID, lPri, strGateID);
				}
				bSendSuccess = !nRet;	
			}
			
			else //if(Body.vt==(VT_ARRAY|VT_UI1))	//binary
			{
				char BinaryBuf[1500] = {0};
				_bstr_t bstrBody(vBody);
				CString strBody = (const char*)bstrBody;
				long BodySize = strBody.GetLength()/2;
				
				memcpy(BinaryBuf,(LPCSTR)strBody,strBody.GetLength());
				
				if(CVariantBufConvert::ConvertToBinary((char*)BinaryBuf, BodySize, (char*)BinaryBuf))
				{			
					int packnum=BodySize/140;
					if(BodySize%140)
					{
						packnum++;
					}
					
					for(int i=1;i<=packnum;i++)
					{				
						nRet = SendSM(packnum, i, CLable::GetSrcId(strLable), CLable::GetDestId(strLable), CLable::GetFeePhone(strLable),
							BinaryBuf+(i-1)*140, (i==packnum ? (packnum==1?BodySize:BodySize%140) : (packnum==1?BodySize:140)),
							1, MsgFormat, CLable::GetFeetype(strLable),CLable::GetFeecode(strLable),
							CLable::GetSevId(strLable), nMsgID, lPri, strGateID);
						if(nRet != 0)
						{
							bSendSuccess = FALSE;
						}
					}
				}			
			}
			if(bSendSuccess == TRUE){
				this->m_pParent->PostMessage(WM_USER+600, 1, 1);//MT++, RC++
			}
			else
			{
				this->m_pParent->PostMessage(WM_USER+600, 1, 0);//MT++, RC=RC
			}
			strLable.Format("TYPE:Receipt;MsgId:%d;GateId:%s;Status:%d;",nMsgID, strGateID, (int)(!bSendSuccess));			
			vBody.SetString("");
			m_queueRW.WriteQueue(strLable,vBody, lPri);
			strLable.Format("TYPE:Receipt;MsgId:%d;GateId:%s;Status:%d;",nMsgID, strGateID, nRet);
			ShowMsg(strLable);			
			
		}
		else{
			::Sleep(100);
		}
		::Sleep(10);//每次处理完后休息
	}
	return 0; 
}

int CSendThread::SendSM(BYTE byPKTotal, BYTE byPKNum, CString strSrc, CString strDest, CString strFeePhone, char *chMsg, int nMsgLen, BYTE byType, int nFormat, int nFeeType, int nFeeCode, CString strSevID, __int32 nMsgID, long nPriority, CString &strGateID)
{
//移至最开始,要完成长度检查、切分、内容为空的检查

	int nTemp = strSrc.GetLength();
	if(nTemp == 0 || nTemp >=21){
		return -2;
	}	
	if(nFeeType<0||nFeeType>5)
		return -3;
	if(nFeeCode<0||nFeeCode>1000)
		return -4;
	if(strSevID.GetLength()>10)
		return -5;

	int  nRet = -1;
	BYTE	chGateID[23];
	memset(chGateID, 0, sizeof(chGateID));
	__int64	nGateID = 0;
	unsigned char chFCS;
	unsigned long lSM_ID;
	CString strFeeType;
	CString strFeeCode;

	strFeeType.Format("%d", nFeeType);
	if(strFeeType.GetLength() == 1){
		strFeeType = "0"+strFeeType;
	}
	strFeeCode.Format("%d", nFeeCode);

	if(byType == 0)//text
	{
		try
		{
			nRet = SubmitAExEx(/*OrgTON*/2, /*OrgNPI*/1, /*OrgAddr*/strSrc,
			/*DestTON*/2, /*DestNPI*/1, /*LPCTSTR DestAddr*/strDest, 
			/*unsigned char PRI*//*(int)(nPriority >0)*/1, /*unsigned char RD*/0, /*unsigned char RP*/0, 
			/*unsigned char SRR*//*(nFeeType==3)? 2:1*/1, /*unsigned char MR*/0, /*!!!!unsigned char DCS*/nFormat, 
			/*unsigned char PID!!!协议类型*/0, /*LPCTSTR Schedule*/NULL, /*LPCTSTR Expire*/NULL, 
			/*unsigned long Default_ID*/0, /*unsigned char UDHI!!!!表示UserData是否是结构*/0, /*unsigned long UDLen*/nMsgLen,
			/*LPCTSTR UserData*/chMsg, /*LPCTSTR ServiceSubType*/strSevID, 
			/*unsigned char* byMsgID*/chGateID, /*unsigned char byPKTotal*//*byPKTotal*/1, 
			/*unsigned char byPKNumber*//*byPKNum*/1, /*unsigned char byMsglevel*/0, 
			/*unsigned char byFeeUserType*/3, /*LPCTSTR sSPID*/m_chIcpId, /*LPCTSTR sFeeType*/strFeeType, 
			/*LPCTSTR sFeeAddr*/strFeePhone, /*LPCTSTR sFeeCode*/strFeeCode,/*unsigned char byUserNum*/1, 
			/*LPCTSTR sDestAddrs*/strDest,	/*unsigned long* SM_ID*/&lSM_ID, /*unsigned char* FCS*/&chFCS);		
		}
		catch(...)
		{
		}
	}
	else if(byType == 1)//binary
	{
		BYTE	byPID = 0;
		BYTE	byUDHI = 1;//40;
		BYTE	byDCS = nFormat;
//		this->BinPro(nFormat, byPID, byUDHI, byDCS);
		try
		{
			nRet = SubmitAExEx(/*OrgTON*/2, /*OrgNPI*/1, /*OrgAddr*/strSrc,
			/*DestTON*/2, /*DestNPI*/1, /*LPCTSTR DestAddr*/strDest, 
			/*unsigned char PRI*//*(int)(nPriority >0)*/1, /*unsigned char RD*/0, /*unsigned char RP*/0, 
			/*unsigned char SRR*//*nFeeType == 3 ? 2:1*/1, /*unsigned char MR*/0, /*!!!!unsigned char DCS*/byDCS, 
			/*unsigned char PID!!!协议类型*/byPID, /*LPCTSTR Schedule*/NULL, /*LPCTSTR Expire*/NULL, 
			/*unsigned long Default_ID*/0, /*unsigned char UDHI!!!!表示UserData是否是结构*/byUDHI, /*unsigned long UDLen*/nMsgLen,
			/*LPCTSTR UserData*/chMsg, /*LPCTSTR ServiceSubType*/strSevID, 
			/*unsigned char* byMsgID*/chGateID, /*unsigned char byPKTotal*/byPKTotal, 
			/*unsigned char byPKNumber*/byPKNum, /*unsigned char byMsglevel*/0, 
			/*unsigned char byFeeUserType*/3, /*LPCTSTR sSPID*/m_chIcpId, /*LPCTSTR sFeeType*/strFeeType, 
			/*LPCTSTR sFeeAddr*/strFeePhone, /*LPCTSTR sFeeCode*/strFeeCode,/*unsigned char byUserNum*/1, 
			/*LPCTSTR sDestAddrs*/strDest,	/*unsigned long* SM_ID*/&lSM_ID, /*unsigned char* FCS*/&chFCS);
		}
		catch(...)
		{
		}
	}
	else
	{
		nRet =-2;
	}

	if(nRet == 0)
	{
	//	strGateID = chGateID;
		CDataConvert::BYTE8ToDeintGateid(chGateID, strGateID);
	}

	else
	//if(nRet != 0)
	{
		CString strSend;
		strSend.Format("\nSendSM Ret:%d,MsgID:%d,SevID:%s, FeeType:%s, FeeCode:%s, GateID:%s, Dest:%s, Src:%s,FeePhone:%s, Body:%s, MsgLen:%d, Format:%d,SM_ID:%d, FCS:%d,SPID:%s",
			nRet,nMsgID,strSevID,strFeeType, strFeeCode, strGateID, strDest, strSrc,	strFeePhone,chMsg,nMsgLen,nFormat, lSM_ID, chFCS, m_chIcpId);
		::GfWriteLog(strSend);
	}	

	return nRet;
}

void CSendThread::BinPro(int nFormat, BYTE &byPID, BYTE &byUDHI, BYTE &byDCS)
{
	switch(nFormat)
	{
//		packSubmit.msg_mode = packSubmit.msg_mode |1;//要求状态报告
	case 2:
		{
			break;
		}
	case 3:
		{
			break;
		}
	case 4:	//Nokia
		{
			break;
		}
	case 5:
		{
			break;
		}
	case 8://Nokia  --> binary format
		{
			break;
		}
	case 9://Siemens --> 
		{
			byPID = 0;
			byUDHI = 0;
			byDCS = 245;//0xF5;
			break;
		}
	case 10://Motorola ringtone --> ASCII FORMAT
		{
			byPID = 0;
			byUDHI = 1;//40;
			byDCS = 4;
			break;
		}
	case 11://Motorola big picture, EMS picture, EMS ringtone, 松下 picture. --> binary format, TP_UDHI=1.
		{
			byPID = 0;
			byUDHI = 1;
			byDCS = 4;
			break;
		}
	case 12://Alcatel	picture and ringtone.  -- TP_UDHI=1, TP_PID=7D, TP_DCS=0XF5.
		{		
			byPID = 125;//0x7d
			byUDHI = 1;//40;
			byDCS = 245;//0xf5
		}
	default:
		{
			byPID = 0;
			byUDHI = 40;
			byDCS = 4;
			break;
		}
	}

}

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

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

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