main.~pas

delphi版cmpp网关

//文件名称：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,
  ComCtrls;

type
        TFrmMain = class( TForm )
        Memo1: TMemo;
        Panel1: TPanel;
        Label1: TLabel;
        eIp: TEdit;
        edport: 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;
        StatusBar1: TStatusBar;
        Label8: TLabel;
        SP_CODE: TEdit;
        Label9: TLabel;

        procedure ClientSocket1Error( Sender: TObject; Socket: TCustomWinSocket;
            ErrorEvent: TErrorEvent; var ErrorCode: Integer );
        procedure bInitClick( Sender: TObject );
        procedure bSubmitClick( Sender: TObject );
        procedure ClientSocket1Read( Sender: TObject; Socket: TCustomWinSocket );
        procedure ClientSocket1Disconnect(Sender: TObject;
        Socket: TCustomWinSocket);
       procedure bTerminateClick(Sender: TObject);

    private
        { Private declarations }
    public
        { Public declarations }
        Cmpp_Sequence_ID: integer;
        function Cmpp_lsh: integer;
      //  procedure bCmpp_Terminate ( cSocket: TCustomWinSocket );
        procedure bCmpp_Init( 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;

function TFrmMain.Cmpp_lsh: integer;
begin
    Result := Cmpp_Sequence_ID;
    inc( Cmpp_Sequence_ID );
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 := strToint(edport.text);
        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 );
       // showmessage(str1);
        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 := $30;
        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;


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;//Unsigned Integer相同Msg_Id的信息总条数，从1开始
        Pk_number := 1;//相同Msg_Id的信息序号，从1开始
        Registered_Delivery := 1;
        Msg_level := 0;
        strpcopy( Service_Id, '-DB' );
        Fee_UserType := 0; //计费用户类型字段0：对目的终端MSISDN计费；1：对源终端MSISDN计费；2：对SP计费;3：表示本字段无效，对谁计费参见Fee_terminal_Id字段。
        Strpcopy( Fee_terminal_Id, '' ); //:array[0..20] of char;  //被计费用户的号码（如本字节填空，则表示本字段无效，对谁计费参见Fee_Userstruct字段，本字段与Fee_Userstruct字段互斥）
        Fee_terminal_type:=0; //被计费用户的号码类型，0：真实号码；1：伪码。
        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, sp_code.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号码
        Dest_terminal_type:=1;//接收短信的用户的号码类型，0：真实号码；1：伪码。
        Msg_Length := length(eSpid.Text); //byte;//信息长度(Msg_Fmt值为0时：<160个字节；其它<=140个字节)
        strpcopy( Msg_Content, eMsg.Text ); //:array[0..MSG_LENGTH-1] of char; //信息内容