commanager.cpp

能够实现联通和移动短消息群发的软件

// ComManager.cpp: implementation of the CComManager class.
// 创建人：  杨祖明
// 创建时间：2001-11-20
// 功能：    通信接口管理类
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "AppDemo.h"
#include "ComManager.h"
#include "BaseSocket.h"
#include "ConstDef.h"
#include "DataDef.h"
#include "AppDemoView.h"
#include "MainFrm.h"
#include "ado.h"
#include "string.h"

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

extern CADODatabase db;
//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////
DWORD WINAPI CheckListThread(LPVOID lpParam);
//应用信息
extern STRUCT_APP_INFO   gStructAppInfo;
//平台服务器信息
extern STRUCT_SERVER_INFO gStructServerInfo;

BOOL AFXAPI CompareElements(const STRUCT_SUBMIT_QUEUE* pElement1,const STRUCT_SUBMIT_QUEUE* pElement2)
{
	return (pElement1->dwSeqID == pElement2->dwSeqID);
}

BOOL AFXAPI CompareElements(const STRUCT_SUBMITRSP_QUEUE* pElement1,const STRUCT_SUBMITRSP_QUEUE* pElement2)
{
	return (pElement1->dwPlatID == pElement2->dwPlatID);
}

CComManager::CComManager()
{
	m_bThreadEnd = FALSE;
	m_pClientSocket = NULL;
	DWORD dwThreadID;
	HANDLE hCheckList = CreateThread(NULL,0,CheckListThread,
										this,0,&dwThreadID);
	if(hCheckList == NULL)
	{
		//创建列表检测线程失败
	}
}

CComManager::~CComManager()
{
	m_bThreadEnd = TRUE;
	if(m_pClientSocket)
	{
		delete m_pClientSocket;
		m_pClientSocket = NULL;
	}
}

//
CComManager::InitCom(STRUCT_SERVER_INFO	sServerInfo,STRUCT_APPLOGIN_INFO sAppLoginInfo)
{
	if(m_pClientSocket == NULL)
		m_pClientSocket = new CBaseSocket(TRUE);
	else
	{
		if(m_pClientSocket->m_bActive)
		
			ShowInfo("已经登录到平台，连接正常！\r\n");
		else
			ShowInfo("已经登录到平台，此时正在进行重连！\r\n");
		return FALSE;
	}
	//初始化连接接口
	if(!m_pClientSocket->InitClient(sServerInfo,sAppLoginInfo))
	{
		delete m_pClientSocket;
		m_pClientSocket = NULL;
		return FALSE;
	}
	else
		return TRUE;
}
BOOL CComManager::ProcessConnectRsp(char szBuf[])
{
	return TRUE;
}
BOOL CComManager::ProcessDiscRsp(char szBuf[])
{
	delete m_pClientSocket;
	m_pClientSocket = NULL;
	return TRUE;
}
BOOL CComManager::ProcessLinkTestRsp(char szBuf[])
{
	return TRUE;
}
BOOL CComManager::ProcessSubmitRsp(char szBuf[])
{
	char szMsg[512];
	CString Mobil;
	STRUCT_SUBMIT_RSP* psSubmitRsp;
	STRUCT_SUBMIT_QUEUE sTemp;
	STRUCT_SUBMITRSP_QUEUE sSubmitRspElement;
	
	psSubmitRsp = (STRUCT_SUBMIT_RSP*)szBuf;
	//STemp记录发送的短消息根据dwSeqID
	sTemp.dwSeqID = ntohl(psSubmitRsp->sHeader.dwSeqNo);
	m_CSSubmitQueue.Lock();
	POSITION pos = m_SubmitList.Find(sTemp);
	if(pos != NULL)
	{
		long SeqID,MsgID,State;
		CString StrSeqID,StrMsgID,StrState;

		sTemp = m_SubmitList.GetAt(pos);
		Mobil=sTemp.sSubmit.sCMPP12Submit.szDest_terminal_ids;   
		
		m_SubmitList.RemoveAt(pos);
		m_CSSubmitQueue.Unlock();
		sSubmitRspElement.dwPlatID = ntohl(psSubmitRsp->dwPlat_MsgID);
		sSubmitRspElement.cTimeOutLeave = sTemp.cTimeOut;
		memcpy((void*)&sSubmitRspElement.sSubmit,(void*)&sTemp.sSubmit,sizeof(STRUCT_SUBMIT));
		//写数据库的信息 Mobil,SeqID,MsgID,State=0
		SeqID=ntohl(psSubmitRsp->sHeader.dwSeqNo);
		MsgID=ntohl(psSubmitRsp->dwPlat_MsgID);
		State=ntohl(psSubmitRsp->sHeader.dwStatus);
        
		StrSeqID.Format(",%d",SeqID);
		StrMsgID.Format(",%d",MsgID);
		StrState.Format(",%d",State);

		CString SQL;
		SQL="INSERT STATE(MOBIL,SEQID,MSGID,STATE) VALUES('"+Mobil+"'"+StrSeqID+StrMsgID+StrState+")";
		//db.Execute (SQL);

		if(sTemp.sSubmit.sSubmitHeader.cCredibility_Transmit == 1)
		{
			if(State == 0)
			{
				if(sTemp.sSubmit.sSubmitHeader.cReSubmit_Count == 0)
				{
					//非重发
					STRUCT_RECV_CONFIRM sRecvConfirm;
					sRecvConfirm.sHeader.dwCommandId = htonl(CTKP_RECV_CONFIRM);
					//证实消息用psSubmitRsp->dwPlat_MsgID
					sRecvConfirm.sHeader.dwSeqNo = psSubmitRsp->dwPlat_MsgID;
					sRecvConfirm.sHeader.dwTotalLen = htonl(sizeof(STRUCT_RECV_CONFIRM));
					sRecvConfirm.cConfirm_Flag = SUBMIT_RSP_CONFIRM_FLAG;
					//发向平台的Submit_Respone
					if(m_pClientSocket->m_bActive)
						m_pClientSocket->SendMsg((char*)&sRecvConfirm,sizeof(STRUCT_RECV_CONFIRM));
				}

				m_CSSubmitRspQueue.Lock();
				if(m_SubmitRspList.GetCount() >= BUFFER_LEN)
				{
					m_CSSubmitRspQueue.Unlock();
					//SubmitRsp缓冲区满
					return FALSE;
				}
				m_SubmitRspList.AddTail(sSubmitRspElement);
				m_CSSubmitRspQueue.Unlock();
				sprintf(szMsg,"V提交应答:手机:%s 流水号:%d MsgID:%d(需要状态报告)\r\n",Mobil,SeqID,MsgID);
				ShowInfo(szMsg); 
			}
			else
			{
				//可靠发送失败
				sprintf(szMsg,"X提交应答:手机:%s 流水号:%d(失败%x)\r\n",Mobil,ntohl(psSubmitRsp->sHeader.dwSeqNo),ntohl(psSubmitRsp->sHeader.dwStatus));
				ShowInfo(szMsg); 
			}
		}
		else
		{
			//非可靠性发送sTemp.sSubmit.sCMPP12Submit.szMsg_Content
			sprintf(szMsg,"提交应答:手机:%s 流水号:%d MsgID=%d(不要报告),内容:%s\r\n",Mobil,ntohl(psSubmitRsp->sHeader.dwSeqNo),ntohl(psSubmitRsp->dwPlat_MsgID),  sTemp.sSubmit.sCMPP12Submit.szMsg_Content);
			ShowInfo(szMsg); 
		}
	}
	else
	{
		m_CSSubmitQueue.Unlock();
	}
	return TRUE;
}
BOOL CComManager::ProcessMsgReport(char szBuf[])
{
	//确认用户收到没有
	char szMsg[512];
	CString Mobil;
	
	long MsgID,State;
	CString StrMsgID,StrState;
	
	STRUCT_MSG_REPORT* psMsgReport;
	STRUCT_SUBMITRSP_QUEUE sTemp;
	
	psMsgReport = (STRUCT_MSG_REPORT*)szBuf;
	sTemp.dwPlatID = ntohl(psMsgReport->dwPlat_MsgID);
	m_CSSubmitRspQueue.Lock();
	POSITION pos = m_SubmitRspList.Find(sTemp);
	
	if(pos != NULL)
	{
		
		sTemp = m_SubmitRspList.GetAt(pos);
		Mobil=sTemp.sSubmit.sCMPP12Submit.szDest_terminal_ids;   
		/*数据库*/

		MsgID=sTemp.dwPlatID ;
		State=ntohl(psMsgReport->sHeader.dwStatus);
		
		
		StrMsgID.Format("%d",MsgID);
		StrState.Format("%d",State);

		CString SQL;
		SQL="Update STATE set ReState=" + StrState +" where MsgID="+StrMsgID;
		ShowInfo(SQL+"\r\n");
		//db.Execute (SQL);
		
		
		m_SubmitRspList.RemoveAt(pos);
		m_CSSubmitRspQueue.Unlock();

		if(State == 0)
		{
			//收到短消息
			sprintf(szMsg,"状态报告:手机:%s MsgID:%d 内容:%s\r\n",Mobil,sTemp.dwPlatID,sTemp.sSubmit.sCMPP12Submit.szMsg_Content);
			//写库 Mobil,SeqID,MsgID,State=0
			ShowInfo(szMsg); 
			
		}
		else if(State == E_APPRESUBMIT)
		{
			//重发
			STRUCT_SUBMIT_QUEUE sSubmitElement;
			sSubmitElement.cTimeOut = sTemp.cTimeOutLeave;
			sSubmitElement.dwSeqID  = sTemp.dwPlatID;
			if(sTemp.sSubmit.sSubmitHeader.cReSubmit_Count >= 3)
				return FALSE;
			sTemp.sSubmit.sSubmitHeader.cReSubmit_Count++;
			sTemp.sSubmit.sSubmitHeader.sHeader.dwSeqNo = htonl(sTemp.dwPlatID);
			memcpy((void*)&sSubmitElement.sSubmit,(void*)&sTemp.sSubmit,sizeof(STRUCT_SUBMIT));
			if(m_pClientSocket->ReSubmitMsg(sTemp.sSubmit))
			{
				m_CSSubmitQueue.Lock();
				if(m_SubmitList.GetCount() >= BUFFER_LEN)
				{
					m_CSSubmitQueue.Unlock();
					//SubmitRsp缓冲区满
					return FALSE;
				}
				m_SubmitList.AddTail(sSubmitElement);
				m_CSSubmitQueue.Unlock();
			}
		}
		else
		{
			sprintf(szMsg,"状态报告:手机:%s MsgID:%d(失败%x) 内容:\r\n",Mobil,sTemp.dwPlatID,ntohl(psMsgReport->sHeader.dwStatus),sTemp.sSubmit.sCMPP12Submit.szMsg_Content);
			//写库 Mobil,SeqID,MsgID,State
			ShowInfo(szMsg); 
		}
	}
	else