cmpp.cpp

提供vc版短信网关源码

#include<vector.h>
#include "main.h"
#include "cmpp.h"
#include "md5.h"
unsigned int sequenceid;
//----------------------------------------------------------------------------
int CMPPInt(AnsiString ServerIP,int ServerPort)
{
Form1->Client->Host = ServerIP;
Form1->Client->Port = ServerPort;
Form1->Client->Active = true;
//do{
//  Application->ProcessMessages();
//}while(intClientError == 1);
return 0;   //SOCKET 返回值;
}
//----------------------------------------------------------------------------
int CMPPConnect(AnsiString UserName,AnsiString PassWord)
{
if (Form1->Client->Socket->Connected == false)
   return 1;
CMPP_CONNECT_tag *bufdata;int md5Len;
AnsiString timestamp=PassWord+FormatDateTime("MMDDHHMMSS", Now());
md5Len = UserName.Length()+9+timestamp.Length();
unsigned char md5source[29]; MD5_CTX md5;//MD5源字串
bufdata=new(CMPP_CONNECT_tag);
memset(bufdata,0,sizeof(CMPP_CONNECT_tag));
memset(md5source,0,md5Len);
bufdata->Total_Length = htonl(39);
bufdata->Command_Id = htonl(CMPP_CONNECT);
if (sequenceid == 123456789i32)
{
   sequenceid = 1;
}else{
   sequenceid++;
}
bufdata->Sequence_Id = htonl(sequenceid);
StrPCopy(bufdata->Source_Addr,UserName);
StrPCopy(md5source,UserName);
for (int i=0;i<timestamp.Length();i++)
    md5source[i+UserName.Length()+9]=timestamp.c_str()[i];
md5.MD5Update(md5source,md5Len);
md5.MD5Final(md5source);
strcpy(bufdata->AuthenticatorSource,md5source);
bufdata->Version = htonl(0x20);
bufdata->Timestamp = htonl(StrToInt(FormatDateTime("MMDDHHMMSS", Now())));
Form1->Client->Socket->SendBuf(bufdata,39);
delete [] bufdata;
delete [] md5source;
return 0;
}
//----------------------------------------------------------------------------
int CMPPSubmit(AnsiString icpid,AnsiString phone,AnsiString msg,byte msgFrm,
        AnsiString serviceid,AnsiString feecode,AnsiString feetype,byte SRR,
        AnsiString feephone,AnsiString src_id)
{
if (Form1->Client->Socket->Connected == false)
   return 1;
CMPP_SUBMIT_tag *bufdata;
bufdata=new(CMPP_SUBMIT_tag); memset(bufdata,0,sizeof(CMPP_SUBMIT_tag));
bufdata->Total_Length = htonl(159+msg.Length());
//bufdata->Total_Length = htonl(299);
bufdata->Command_Id = htonl(CMPP_SUBMIT);
if (sequenceid == 123456789i32)
{
   sequenceid = 1;
}else{
   sequenceid++;
}
bufdata->Sequence_Id = htonl(sequenceid);
bufdata->Pk_total = 1;
bufdata->Pk_number = 1;
bufdata->Registered_Delivery = htonl(SRR);
bufdata->Msg_level = 1;
strcpy(bufdata->Service_Id,serviceid.c_str());
bufdata->Fee_UserType = 3;
strcpy(bufdata->Fee_terminal_Id,feephone.c_str());
bufdata->TP_pId = 0;
bufdata->TP_udhi = 0;
bufdata->Msg_Fmt = msgFrm;
strcpy(bufdata->Msg_src,icpid.c_str());
strcpy(bufdata->FeeType,feetype.c_str());
strcpy(bufdata->FeeCode,feecode.c_str());
strcpy(bufdata->ValId_Time,"");
strcpy(bufdata->At_Time,"");
strcpy(bufdata->Src_Id,src_id.c_str());
bufdata->DestUsr_tl = 1;
strcpy(bufdata->Dest_terminal_Id,phone.c_str());
bufdata->Msg_Length = msg.Length();
strcpy(bufdata->Msg_Content,msg.c_str());
Form1->Client->Socket->SendBuf(bufdata,159+msg.Length());
Sleep(100);
delete [] bufdata;
Sleep(100);
return 0;
}
//----------------------------------------------------------------------------
int CMPPDeliverGet(CMPP_DELIVER_tag *bufdata,AnsiString &msg,unsigned __int64 &msg_id,
        AnsiString &Dest_Id,AnsiString &Src_terminal_Id,byte &Registered_Delivery)
{
msg=bufdata->Msg_Content;
msg_id = bufdata->Msg_Id;
Dest_Id = bufdata->Dest_Id;
Src_terminal_Id = bufdata->Src_terminal_Id;
Registered_Delivery = bufdata->Registered_Delivery;
return 0;
}
//----------------------------------------------------------------------------
int CMPPDeliverResp(unsigned int DelivSequenceid,unsigned __int64 DelivMsg_id)
{
if (Form1->Client->Socket->Connected == false)
    return 1;
CMPP_DELIVER_RESP_tag *bufdata;
bufdata=new(CMPP_DELIVER_RESP_tag);memset(bufdata,0,21);
bufdata->Total_Length = htonl(sizeof(CMPP_DELIVER_RESP_tag));
bufdata->Command_Id = htonl(CMPP_DELIVER_RESP);
bufdata->Sequence_Id = DelivSequenceid;
bufdata->Msg_Id = DelivMsg_id;
bufdata->Result = 0;
Form1->Client->Socket->SendBuf(bufdata,21);
free(bufdata);
return 0;
}
//----------------------------------------------------------------------------
int CMPPActiveTest()
{
  if (Form1->Client->Socket->Connected == false)
      return 1;
  CMPP_ACTIVE_TEST_tag *bufdata;
  bufdata=new(CMPP_ACTIVE_TEST_tag);
  memset(bufdata,0,sizeof(CMPP_ACTIVE_TEST_tag));
  bufdata->Total_Length = htonl(sizeof(CMPP_ACTIVE_TEST_tag));
  bufdata->Command_Id = htonl(CMPP_ACTIVE_TEST);
  if (sequenceid == 123456789i32)
  {
     sequenceid = 1;
  }else{
     sequenceid++;
  }
  bufdata->Sequence_Id = htonl(sequenceid);
  Form1->Client->Socket->SendBuf(bufdata,12);
  Sleep(100);
  free(bufdata);
  Sleep(100);
  return 0;
}
//----------------------------------------------------------------------------
int CMPPActiveResp(unsigned int ActivSequenceid)
{
if (Form1->Client->Socket->Connected == false)
    return 1;
CMPP_ACTIVE_TEST_RESP_tag *bufdata;
bufdata=new(CMPP_ACTIVE_TEST_RESP_tag);memset(bufdata,0,sizeof(CMPP_ACTIVE_TEST_RESP_tag));
bufdata->Total_Length = htonl(sizeof(CMPP_ACTIVE_TEST_RESP_tag));
bufdata->Command_Id = htonl(CMPP_ACTIVE_TEST_RESP);
bufdata->Sequence_Id = ActivSequenceid;
bufdata->Reserved = htonl(0);
Form1->Client->Socket->SendBuf(bufdata,13);
Sleep(100);
free(bufdata);
Sleep(100);
return 0;
}
//----------------------------------------------------------------------------
int CMPPTerminateResp(unsigned int TerminSequenceid)
{
if (Form1->Client->Socket->Connected == false)
    return 1;
CMPP_TERMINATE_RESP_tag *bufdata;
bufdata=new(CMPP_TERMINATE_RESP_tag);memset(bufdata,0,12);
bufdata->Total_Length = htonl(12);
bufdata->Command_Id = htonl(CMPP_TERMINATE_RESP);
bufdata->Sequence_Id = TerminSequenceid;
Form1->Client->Socket->SendBuf(bufdata,13);
Sleep(100);
free(bufdata);
Sleep(100);
return 0;
}
//----------------------------------------------------------------------------
int CMPPTerminate()
{
if (Form1->Client->Socket->Connected == false)
   return 1;
CMPP_TERMINATE_tag *bufdata;
bufdata=new(CMPP_TERMINATE_tag);memset(bufdata,0,sizeof(CMPP_TERMINATE_tag));
bufdata->Total_Length=htonl(sizeof(CMPP_TERMINATE_tag));
bufdata->Command_Id=htonl(CMPP_TERMINATE);
if (sequenceid == 123456789i32)
{
   sequenceid = 1;
}else{
   sequenceid++;
}
bufdata->Sequence_Id=htonl(sequenceid);
Form1->Client->Socket->SendBuf(bufdata,12);
delete [] bufdata;
return 0;
}
//----------------------------------------------------------------------------