cmppapi_test.cpp

这只是在移动下载的cmpp协议和一些参考资料

// cmppapi_test.cpp : Defines the entry point for the console application.
//

#include "stdafx.h"

//包含需要的文件.
#include "md5.h"
#include "cmpp.h"

#pragma comment(lib, "cmppapi.lib")

#define CMPP_IMPORT

//用一全局变量记录SubmitResp中的MsgId,用于测试Cancel命令.
unsigned _int64 g_nMsgid = 0;

CMPP_LINKID g_stLinkId;

void LogWrite(LPCTSTR sLogItem, ...)
{
	char buffer[1024];
	ZeroMemory(buffer, 1024);

	va_list arglist;						
	va_start( arglist, sLogItem );
	_vsnprintf( buffer, 1024, sLogItem, arglist );
	va_end(arglist);

	printf(buffer);
}

void	LogHex(CString szpre, char *msgContent, int nSize)
{
	int		ix	=	0;
	CString strOut;
	CString strsingle;
	strOut.Empty();
	strsingle.Empty();

	if ( !AfxIsValidAddress(msgContent, nSize) )
	{
		printf("输入参数无效(LogHex)\n");
		return;
	 }

	try
	{
		if (nSize>1000) nSize = 1000; 
		printf( szpre );
		while(ix<nSize)
		{
			strsingle.Format("%02x ", (unsigned char)msgContent[ix++]);
			strOut += strsingle;
		}
		strOut += "\n";
		printf( strOut );
	}
	catch(...)
	{
		printf("LogHex失败.\n");
	}

	return;
}

void OnSmgMsg(CMPP_SMGTOSP css)
{
	printf("这是消息处理函数打印出来的:**smg msg,len = %d, cmd = 0x%08x, seq = %d**\n", \
		css.pk_head.nTotalLength, css.pk_head.nCommandId, css.pk_head.nSeqId);

	if (css.pk_head.nCommandId == 0x80000004) {
		g_nMsgid = css.pk_body.pk_submitresp.nMsgid;

		printf("Submit Response, Result:%d.\n", css.pk_body.pk_submitresp.nResult);
	}
	else if (css.pk_head.nCommandId == 0x00000005) {
		printf("Deliver Msg, len:%d, content:%s, msgfmt:%d, msisdn:%s, linkid:%s %s %d.\n", \
			css.pk_body.pk_deliver.uchMsglength, css.pk_body.pk_deliver.MO_Msg_Content.sMsgcontent, \
			css.pk_body.pk_deliver.uchMsgfmt, css.pk_body.pk_deliver.sSrcterminalid, \
			GetSubStr(css.pk_body.pk_deliver.stLinkid.sMiscid, 4), GetSubStr(css.pk_body.pk_deliver.stLinkid.sDateTime, 12), css.pk_body.pk_deliver.stLinkid.nSeqId);

		memcpy(&g_stLinkId, &css.pk_body.pk_deliver.stLinkid, 20);

		if (css.pk_body.pk_deliver.uchRegisteredDelivery == 1) {
			LogHex("状态报告(stat):", css.pk_body.pk_deliver.MO_Msg_Content.csr.sStat, 7);
		}
	}
	return;
}

void OutProgramInfo()
{
	printf("\n*****************************************************************************\n");
	printf("**软件名称 - <<中国移动通信CMPP3.0短消息网关开发接口库>> V3.01 客户端例程.\n");
	printf("**作者主页 - http://www.zealware.com\n");
	printf("**联系方式 - Email:[e-mail]\n");
	printf("**授权方式 - Used Free,SourceCode On Sale.\n");
	printf("**********************Published By PrinceToad Jul.04.04.*********************\n\n");
}

//标准cmpp方式，MOMT同一连接的演示例程.
int main(int argc, char* argv[])
{
	int nRetCode = 0;
	unsigned int nSeq = 0;

	OutProgramInfo();

	CCmppClient cmpp;

	printf("Press Any To Start CmppClient.\n");
	system("pause");

	ZeroMemory(&g_stLinkId, sizeof(CMPP_LINKID));
	//1.启动CMPPCLIENT模块.
	//参数的含义(具体可以参考使用手册):网关地址，网关端口，登陆用户名，口令，版本号(最好填0x12)，网关连接类型.
	//网关连接类型(0:标准单连接cmpp方式,如思特奇，华为，标准东软,1:亚信双连接,2:清华声讯双端口)

	//本地测试(由于众所周知的原因，下面真实网关的IP,用户名口令都被屏蔽了,用户可以根据自己的参数进行修改.)
//	nRetCode = cmpp.Start("127.0.0.1", 7890, "901234", "1234", 0x30, 10, OnSmgMsg, 0, LogWrite);

	//连接思特奇
//	nRetCode = cmpp.Start("127.0.0.1", 7890, "901234", "1234", 0x30, 10, OnSmgMsg, 0, LogWrite);
	
	//连接华为
//	nRetCode = cmpp.Start("127.0.0.1", 7890, "901234", "1234", 0x30, 10, OnSmgMsg, 0, LogWrite);
	
	//连接东软(标准)
//	nRetCode = cmpp.Start("127.0.0.1", 7890, "901234", "1234", 0x30, 10, OnSmgMsg, 0, LogWrite);
	
	//连接亚信
	nRetCode = cmpp.Start("127.0.0.1", 7890, "901234", "1234", 0x30, 10, OnSmgMsg, 1, LogWrite);
	
	//连接清华声讯(需要在调用Start函数之前调用SetDoublePort函数设定MOMT端口号)
//	cmpp.SetDoublePort(7910, 7890);
//	nRetCode = cmpp.Start("127.0.0.1", 7890, "901234", "1234", 0x30, 10, OnSmgMsg, 2, LogWrite);

	if (0 != nRetCode) {
		printf("CmppClient Start Failed With Error: %d.\n", nRetCode);
		system("pause");
		return nRetCode;
	}
	else {
		printf("CmppClient Module Start Success,Press Any To Test Submit Command.\n");
		system("pause");
		printf("\n");
	}
	
	//2.测试SUBMIT命令.
	//submit的各参数与cmpp3.0中的submit包内容相对应.
	//这里只负责把submit包发出去，不负责接收submitresp以及可能要求的状态报告，
	//submitresp包和状态报告均须在OnSmgMsg函数中处理.
	
	//得到submit包的流水号,通过与submitresp的流水号比较，得到submit包的MsgId.
	//与状态报告的MsgId比较可以知道此条消息是否已经发到用户手上.
	nSeq = cmpp.GetSeqId();
	
//	int Submit(unsigned _int64 nMsgId, unsigned char uchPKtotal, unsigned char uchPKnumber, \
//		unsigned char uchNeedreport, unsigned char uchMsglevel, char *pchServiceid, \
//		unsigned char uchFeeusertype, char *pchFeeterminalid, unsigned char uchFeeterminaltype, \
//		unsigned char uchTppid, unsigned char uchTpudhi, unsigned char uchMsgfmt, \
//		char *pchMsgsrc, char *pchFeetype, char *pchFeecode, char *pchValidtime, char *pchAttime, \
//		char *pchSrcid, unsigned char uchDestusrtl, char *pchDestterminalid, unsigned char uchDestterminaltype, \
//		unsigned char uchMsglen, char *pchMsgcontent, CMPP_LINKID *stLinkid);
	nRetCode = cmpp.Submit(0, 1, 1, \
		1, 3, "-DB", \
		0, NULL, 0, \
		0, 0, 15, \
		"901234", "02", "000010", NULL, NULL, \
		"4022", 1, "13910273000", 0, \
		4, "test", &g_stLinkId);
	
	printf("Submit result : %d, SeqId = %d\n", nRetCode, nSeq);

	printf("Press Any To Test Query Command.\n\n");
	system("pause");
	printf("\n");

	//3.测试QUERY命令.
	nSeq = cmpp.GetSeqId();

	nRetCode = cmpp.Query("20040124", 0);		//查询总量.
	printf("Query result : %d, SeqId = %d\n", nRetCode, nSeq);
	
	printf("Press Any To Test Cancel Command.\n");
	system("pause");
	printf("\n");

	//4.测试CANCEL命令.
	nSeq = cmpp.GetSeqId();

	nRetCode = cmpp.Cancel(g_nMsgid);
	printf("Cancel result : %d, SeqId = %d\n", nRetCode, nSeq);

	printf("Press Any To Test ActiveTest Command.\n");
	system("pause");
	printf("\n");

	//5.测试ACTIVETEST命令.
	nSeq = cmpp.GetSeqId();

	nRetCode = cmpp.ActiveTest();
	printf("ActiveTest result : %d, SeqId = %d\n", nRetCode, nSeq);

	printf("Press Any To Test Terminate Command And Release CmppClient Module.\n");
	system("pause");
	printf("\n");

	//6.测试TERMINATE命令.
	cmpp.Release();

	printf("Press Any To Exit This Test Program.\n");
	system("pause");
	printf("\n");
	
	return 0;
}