main.pas

华为网关cmppDelphi的源码

//文件名称：YiDong_Cmpp.pas
//文件标识：tYD_Cmpp类
//当前版本：1.0
//作    者：邵青山,李朔刚
//mail: [e-mail] [e-mail]
//完成日期：2003年5月27日
unit main;

interface

uses
    Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
    Dialogs, StdCtrls, ExtCtrls, ScktComp, md5, CMPP_Protocol, cmpp, winsock;

type
    TFrmMain = class( TForm )
        Memo1: TMemo;
        Panel1: TPanel;
        Label1: TLabel;
        eIp: TEdit;
        Label4: TLabel;
        eSpid: TEdit;
        Label5: TLabel;
        eShaSec: TEdit;
        Label6: TLabel;
        eSourceAdd: TEdit;
        Label2: TLabel;
        Label3: TLabel;
        eMsg: TEdit;
        eTel: TEdit;
        Panel2: TPanel;
        bInit: TButton;
        bTerminate: TButton;
        bSubmit: TButton;
        bActiveTest: TButton;
        ClientSocket1: TClientSocket;
    Label7: TLabel;
        procedure ClientSocket1Error( Sender: TObject; Socket: TCustomWinSocket;
            ErrorEvent: TErrorEvent; var ErrorCode: Integer );
        procedure bInitClick( Sender: TObject );
        procedure bSubmitClick( Sender: TObject );
        procedure bTerminateClick( Sender: TObject );
        procedure ClientSocket1Read( Sender: TObject; Socket: TCustomWinSocket );
    private
        { Private declarations }
    public
        { Public declarations }
        Cmpp_Sequence_ID: integer;
        function Cmpp_lsh: integer;
        procedure bCmpp_Init( cSocket: TCustomWinSocket );
        //procedure bCmpp_Terminate( cSocket: TCustomWinSocket );
        procedure bCmpp_Submit( cSocket: TCustomWinSocket; cCMPP_SUBMIT: tCMPP_SUBMIT_tag );
        procedure bCmpp_ActiveTest( cSocket: TCustomWinSocket );
        procedure CmppRead_CONNECT_RESP( ReadSock: TCustomWinSocket;
            Cmpp_Head: tCMPP_HEAD_tag );
        procedure CmppRead_CONNECT( ReadSock: TCustomWinSocket;
            Cmpp_Head: tCMPP_HEAD_tag );
        procedure CmppRead_TERMINATE(ReadSock: TCustomWinSocket;
          Cmpp_Head: tCMPP_HEAD_tag);
        procedure CmppRead_DELIVER(ReadSock: TCustomWinSocket;
            Cmpp_Head: tCMPP_HEAD_tag);
        procedure CmppRead_SUBMIT_RESP(ReadSock: TCustomWinSocket;
          Cmpp_Head: tCMPP_HEAD_tag);

    end;

var
    FrmMain: TFrmMain;

implementation

{$R *.dfm}

procedure TFrmMain.ClientSocket1Error( Sender: TObject;
    Socket: TCustomWinSocket; ErrorEvent: TErrorEvent;
    var ErrorCode: Integer );
begin
    ErrorCode := 0;
end;

procedure TFrmMain.bInitClick( Sender: TObject );
begin
    bCmpp_Init( ClientSocket1.Socket );
end;

procedure TFrmMain.bCmpp_Init( cSocket: TCustomWinSocket );
type
    T_init = packed record
        head: TCMPP_HEAD_tag;
        body: TCMPP_CONNECT_tag;
    end;
var
    bInit: T_init;
    int1, int2, int3, LengthI, i: integer;
    md5str: md5digest;
    md5_con: MD5Context;
    timestr: string;
    str1: array[0..31] of char;
    Md5UpLen: Integer; //MD5Update Length;
    timestr1: TDateTime;
begin
    try
        ClientSocket1.Active := False;
        ClientSocket1.Address := eIP.Text;
        ClientSocket1.Port := 7890;
        ClientSocket1.Active:=true;
        timestr1:= now;
        while (now-timestr1)< 5/86400 do
        begin
            if ClientSocket1.Active then break;
            application.ProcessMessages;
        end;
        if not ClientSocket1.Active then
        begin
            memo1.Lines.Add( 'socket未打开' );
            exit;
        end;
    except
        on e: exception do
        begin
            memo1.Lines.Add( 'socket异常:' + e.Message );
            exit;
        end;
    end;
    try
        int1 := SizeOf( TCMPP_HEAD_tag );
        int2 := SizeOf( TCMPP_CONNECT_tag );
        int3 := int1 + int2;
        FillChar( bInit.head, int1, 0 );
        FillChar( bInit.body, int2, 0 );
        DateTimeToString( timestr, 'MMDDHHMMSS', now );
        StrPCopy( str1, trim( eSourceAdd.Text ) + '000000000' + trim( eShaSec.Text ) + timestr );
        LengthI := Length( trim( eSourceAdd.Text ) );
        for i := LengthI to ( LengthI + 8 ) do
            str1[i] := #0;
        Md5UpLen := LengthI + 9 + Length( trim( eShaSec.Text ) ) + 10;
        MD5Init( md5_con );
        MD5Update( md5_con, str1, Md5UpLen );
        MD5Final( md5_con, md5str );
        bInit.head.Total_Length := htonl( int3 );
        bInit.head.Command_ID := htonl( CMPP_CONNECT );
        bInit.head.Sequence_ID := htonl( Cmpp_lsh );
        StrPCopy( bInit.body.Source_Addr, eSourceAdd.text );
        move( md5str, bInit.body.AuthenticatorSource, 16 );
        bInit.body.Version := $20;
        bInit.body.Timestamp := htonl( StrToInt( timestr ) );
        if cSocket.SendBuf( bInit, int3 ) <> int3 then
        begin
            memo1.Lines.Add( '发送连接操作失败' );
            exit;
        end;
        memo1.Lines.Add( '发送连接操作成功,正等待响应消息' );
    except
        on e: exception do
            memo1.Lines.Add( '发送连接操作失败,错误信息' + e.Message );
    end; //try-except
end;

function TFrmMain.Cmpp_lsh: integer;
begin
    Result := Cmpp_Sequence_ID;
    inc( Cmpp_Sequence_ID );
end;

procedure TFrmMain.bCmpp_ActiveTest( cSocket: TCustomWinSocket );
begin
    //
end;

procedure TFrmMain.bCmpp_Submit( cSocket: TCustomWinSocket; cCMPP_SUBMIT: tCMPP_SUBMIT_tag );
var
    Cmpp_Submit_StoI: TCmpp_Submit_StoI;
    SizeIni1: integer;
begin
    try
        SizeIni1 := Sizeof( Cmpp_Submit_StoI );
        FillChar( Cmpp_Submit_StoI, SizeIni1, 0 );
        Move( cCMPP_SUBMIT, Cmpp_Submit_StoI.body, SizeOf( tCMPP_SUBMIT_tag ) );
        with Cmpp_Submit_StoI do
        begin
            head.Total_Length := htonl( SizeOf( Cmpp_Submit_StoI ) );
            head.Command_Id := htonl( CMPP_SUBMIT );
            head.Sequence_Id := htonl( Cmpp_LSH );
        end;
        if cSocket.SendBuf( Cmpp_Submit_StoI, SizeIni1 ) <> SizeIni1 then
        begin
            memo1.Lines.Add( '发送Cmpp_Submit_StoI包错误' );
            exit;
        end;
        memo1.Lines.Add( '发送Cmpp_Submit_StoI包成功，正等待返回信息' );
    except
        on e: exception do
        begin
            memo1.Lines.Add( '发送Cmpp_Submit_StoI包异常:' + e.Message );
        end;
    end;
end;

procedure TFrmMain.bSubmitClick( Sender: TObject );
var
    CMPP_SUBMIT_tag: TCMPP_SUBMIT_tag;
begin
    FillChar( CMPP_SUBMIT_tag, SizeOf( CMPP_SUBMIT_tag ), 0 );
    with CMPP_SUBMIT_tag do
    begin
        Pk_total := 1;
        Pk_number := 1;
        Registered_Delivery := 0;
        Msg_level := 0;
        strpcopy( Service_Id, 'hello' );
        Fee_UserType := 0;
        strpcopy( Fee_terminal_Id, '' ); //:array[0..20] of char;  //被计费用户的号码（如本字节填空，则表示本字段无效，对谁计费参见Fee_Userstruct字段，本字段与Fee_Userstruct字段互斥）
        TP_pId := 0; //byte;//GSM协议类型。详细是解释请参考GSM03.40中的9.2.3.9
        TP_udhi := 0; //byte;//GSM协议类型。详细是解释请参考GSM03.40中的9.2.3.23,仅使用1位，右对齐
        Msg_Fmt := 8; //byte;//信息格式  0：ASCII串  3：短信写卡操作  4：二进制信息  8：UCS2编码15：含GB汉字
        strpcopy( Msg_src, eSpid.Text ); //array[0..5] of char;   //信息内容来源(SP_Id)
        strpcopy( FeeType, '01' ); //:array[0..1] of char;   //资费类别01：对"计费用户号码"免费
        strpcopy( FeeCode, '00010' ); //:array[0..5] of char;   //资费代码（以分为单位）
        strpcopy( ValId_Time, '' ); //:array[0..16] of char;  //存活有效期，格式遵循SMPP3.3协议
        strpcopy( At_Time, '' ); //:array[0..16] of char;  //定时发送时间，格式遵循SMPP3.3协议
        strpcopy( Src_Id, eSourceAdd.Text ); //:array[0..20] of char;  //源号码SP的服务代码或前缀为服务代码的长号码, 网关将该号码完整的填到SMPP协议Submit_SM消息相应的source_addr字段，该号码最终在用户手机上显示为短消息的主叫号码
        DestUsr_tl := 1; //byte;//接收信息的用户数量(小于100个用户)
        strpcopy( Dest_terminal_Id, eTel.Text ); //:array[0..20] of char;  //接收短信的MSISDN号码
        Msg_Length := 140; //byte;//信息长度(Msg_Fmt值为0时：<160个字节；其它<=140个字节)
        strpcopy( Msg_Content, eMsg.Text ); //:array[0..MSG_LENGTH-1] of char; //信息内容
        //Reserve             :array[0..7] of char;//保留
    end;
    bCmpp_Submit( ClientSocket1.Socket, CMPP_SUBMIT_tag );
end;

procedure TFrmMain.bTerminateClick( Sender: TObject );
begin
    try
        ClientSocket1.Active:=false;
        if not ClientSocket1.Active then
            memo1.Lines.Add( '关闭不成功，请再试试' )
        else
            memo1.Lines.Add( '关闭成功' );
    except
        on e: exception do
            memo1.Lines.Add( '关闭不成功,异常:' + e.Message );
    end;
end;

procedure TFrmMain.ClientSocket1Read( Sender: TObject;
    Socket: TCustomWinSocket );
var
    ReadBufSize: integer;
    CMPP_HEAD_tag: tCMPP_HEAD_tag;
begin
    try
        FillChar( CMPP_HEAD_tag, sizeof( tCMPP_HEAD_tag ), 0 );
        ReadBufSize := Socket.ReceiveBuf( CMPP_HEAD_tag, sizeof( tCMPP_HEAD_tag ) );
        if ( ReadBufSize = 0 ) or ( ReadBufSize = -1 ) or ( ReadBufSize <> SizeOf( tCMPP_HEAD_tag ) ) then
            exit;
        CMPP_HEAD_tag.Command_Id := ntohl( CMPP_HEAD_tag.Command_Id );

        if CMPP_HEAD_tag.Command_Id = CMPP_CONNECT then //ISMG对SP发起的连接请求
            CmppRead_CONNECT( Socket, CMPP_HEAD_tag );

        if CMPP_HEAD_tag.Command_Id = CMPP_CONNECT_RESP then
            CmppRead_CONNECT_RESP( Socket, CMPP_HEAD_tag );

        if CMPP_HEAD_tag.Command_Id = CMPP_TERMINATE then //短信中心发起的断开连接操作
            CmppRead_TERMINATE( Socket, CMPP_HEAD_tag );

        if CMPP_HEAD_tag.Command_Id = CMPP_TERMINATE_RESP then
            memo1.Lines.Add('断开与短信网关的连接');

        if CMPP_HEAD_tag.Command_Id = CMPP_DELIVER then
            CmppRead_DELIVER( Socket, CMPP_HEAD_tag );

        if CMPP_HEAD_tag.Command_Id = CMPP_SUBMIT_RESP then
            CmppRead_SUBMIT_RESP( Socket, CMPP_HEAD_tag );

        {if CMPP_HEAD_tag.Command_Id = CMPP_ACTIVE_TEST then
            CmppRead_ACTIVE_TEST( Socket, CMPP_HEAD_tag );

        if CMPP_HEAD_tag.Command_Id = CMPP_ACTIVE_TEST_RESP then
            CmppRead_ACTIVE_TEST_RESP( Socket, CMPP_HEAD_tag );   }

    except

    end;
end;

procedure TFrmMain.CmppRead_CONNECT_RESP( ReadSock: TCustomWinSocket;
    Cmpp_Head: tCMPP_HEAD_tag );
var CMPP_CONNECT_RESP_tag:TCMPP_CONNECT_RESP_tag;
begin
    FillChar( CMPP_CONNECT_RESP_tag, SizeOf( CMPP_CONNECT_RESP_tag ), 0 );
    if ReadSock.ReceiveBuf( CMPP_CONNECT_RESP_tag, SizeOf( CMPP_CONNECT_RESP_tag ) ) <> SizeOf( CMPP_CONNECT_RESP_tag ) then
    begin
        Memo1.Lines.Add('ReceiveBuf CMPP_CONNECT_RESP_tag error');
        exit;
    end;
end;

procedure TFrmMain.CmppRead_CONNECT( ReadSock: TCustomWinSocket;
    Cmpp_Head: tCMPP_HEAD_tag );
begin
//ISMG对SP发起的连接请求
end;

procedure TFrmMain.CmppRead_TERMINATE(ReadSock: TCustomWinSocket;
  Cmpp_Head: tCMPP_HEAD_tag);
begin
//短信中心发起的断开连接操作
end;

procedure TFrmMain.CmppRead_DELIVER(ReadSock: TCustomWinSocket;
  Cmpp_Head: tCMPP_HEAD_tag);
var
    SizeI1, SizeI2: integer;
    bufferStr : array[0..199] of char;
    bufferSize: Integer;
    CMPP_DELIVER_HEAD_tag: tCMPP_DELIVER_HEAD_tag;
    Cmpp_Deliver_Resp_ItoS: tCmpp_Deliver_Resp_ItoS;
    CMPP_DELIVER_tag: tCMPP_DELIVER_tag;
begin
    SizeI1 := SizeOf(tCmpp_Deliver_Resp_ItoS);    //Cmpp_Deliver_Resp_ItoS
    SizeI2 := SizeOf(tCMPP_DELIVER_HEAD_tag);
    FillChar( Cmpp_Deliver_Resp_ItoS, SizeI1, 0 );
    FillChar( CMPP_DELIVER_HEAD_tag, SizeI2, 0 );
    FillChar( bufferStr, 200, 0 );
    ReadSock.ReceiveBuf(CMPP_DELIVER_HEAD_tag,SizeI2);
    if CMPP_DELIVER_HEAD_tag.Registered_Delivery = 0 then  //收到短信处理
    begin
        FillChar( CMPP_DELIVER_tag, SizeOf(tCMPP_DELIVER_tag), 0);
        bufferSize := CMPP_DELIVER_HEAD_tag.Msg_Length+8;
        if ReadSock.ReceiveBuf(bufferStr,bufferSize) <> bufferSize then
        begin
            memo1.Lines.Add('ReceiveBuf(bufferStr,bufferSize) error');
            exit;
        end;
        Move (bufferStr, CMPP_DELIVER_tag.Msg_Content, bufferSize-8);
        memo1.Lines.Add('收到短信,内容'+CMPP_DELIVER_tag.Msg_Content);
    end
    else if CMPP_DELIVER_HEAD_tag.Registered_Delivery = 1 then//返回状态报告处理
    begin
        bufferSize := CMPP_DELIVER_HEAD_tag.Msg_Length + 8;
        ReadSock.ReceiveBuf( bufferStr, bufferSize );
        memo1.Lines.Add('返回状态报告');
    end
    else
    begin
        //WriteLog.WriteExceptLog( IniBody.OtherLogFileName, DateTimeToStr(now) +
        //    '收到其它短信,Registered_Delivery=' + IntToStr( CMPP_DELIVER_HEAD_tag.Registered_Delivery ));            //memo1.Lines.Add('==============CMPP_CONNECT 发送返回包错误');
        //memo1.Lines.Add('收到其它类型短信');
    end;
    Cmpp_Deliver_Resp_ItoS.Head.Total_Length := htonl( 21 );
    Cmpp_Deliver_Resp_ItoS.Head.Command_Id := htonl(CMPP_DELIVER_RESP);
    Cmpp_Deliver_Resp_ItoS.Head.Sequence_Id := Cmpp_Head.Sequence_Id;
    Cmpp_Deliver_Resp_ItoS.Body.Msg_Id := CMPP_DELIVER_HEAD_tag.Msg_Id;
    Cmpp_Deliver_Resp_ItoS.Body.Result := 0;

end;


procedure TFrmMain.CmppRead_SUBMIT_RESP(ReadSock: TCustomWinSocket;
  Cmpp_Head: tCMPP_HEAD_tag);
var 
    SizeI1: integer;
    CMPP_SUBMIT_RESP_tag: tCMPP_SUBMIT_RESP_tag;
begin
    SizeI1 := SizeOf(CMPP_SUBMIT_RESP_tag);
    FillChar(CMPP_SUBMIT_RESP_tag, SizeI1, 0);
    if ReadSock.ReceiveBuf(CMPP_SUBMIT_RESP_tag, SizeI1) <> SizeI1 then
    begin
        Memo1.Lines.Add('接收短信发送的包体出错');
        exit;
    end;
end;

end.