main.pas

短信收发程序

    try
        ServerSocket.Active:=false;
        if not ServerSocket.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
            CmppRead_CONNECT( Socket, CMPP_HEAD_tag )
        else
        if CMPP_HEAD_tag.Command_ID= CMPP_CONNECT_RESP then
            CmppRead_CONNECT_RESP( Socket, CMPP_HEAD_tag )
        else
        if CMPP_HEAD_tag.Command_ID= CMPP_TERMINATE then
            CmppRead_TERMINATE( Socket, CMPP_HEAD_tag )
        else
        if CMPP_HEAD_tag.Command_ID= CMPP_TERMINATE_RESP then
            memo1.Lines.Add('断开与短信网关的连接')
        else
        if CMPP_HEAD_tag.Command_ID= CMPP_DELIVER then
            CmppRead_DELIVER( Socket, CMPP_HEAD_tag )
        else
        if CMPP_HEAD_tag.Command_ID= CMPP_DELIVER_RESP then
            CmppRead_DELIVER_RESP( Socket, CMPP_HEAD_tag)
        else
        if CMPP_HEAD_tag.Command_ID= CMPP_SUBMIT then
            CmppRead_SUBMIT( Socket, CMPP_HEAD_tag )
        else
        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
       On E : Exception Do memo1.Lines.Add( 'SocketRead,异常:' + e.Message );
    end;
end;


// 读取连接请求，并且返回连接确认信息
procedure TFrmMain.CmppRead_CONNECT( ReadSock: TCustomWinSocket;
    Cmpp_Head: tCMPP_HEAD_tag );
var
  Cmpp_Connect_Resp_ItoS :  tCmpp_Connect_Resp_ItoS;
  Cmpp_Connect      :  TCMPP_CONNECT_tag;
  SizeIni1          :  integer;
begin
  try
     SizeIni1 := SizeOf( Cmpp_Connect );
     FillChar( Cmpp_Connect ,SizeIni1,0);
     if ReadSock.ReceiveBuf( Cmpp_Connect,SizeIni1)<> SizeIni1 then
     begin
        Memo1.Lines.Add('ReceiveBuf Cmpp_Connect Error');
        exit;
     end;
     Memo1.Lines.Add('SP_ID:'+Cmpp_Connect.Source_Addr+' 接入');
     SizeIni1 := SizeOf( Cmpp_Connect_Resp_ItoS );
     FillChar( Cmpp_Connect_Resp_ItoS,SizeIni1,0);
     with Cmpp_Connect_Resp_ItoS do
     begin
         body.Status       := 0;
         strpcopy(body.AuthenticatorISMG,Cmpp_Connect.AuthenticatorSource);
         body.Version      := 8;
         head.Total_Length := htonl( SizeIni1 );
         head.Command_Id := htonl( CMPP_CONNECT_RESP );
         head.Sequence_Id := htonl( Cmpp_LSH );
     end;
     if ReadSock.SendBuf( Cmpp_Connect_Resp_ItoS, SizeIni1 ) <> SizeIni1 then
     begin
         memo1.Lines.Add( '发送Cmpp_Connect_Resp_I2S包错误' );
         exit;
     end;
     memo1.Lines.Add( '发送Cmpp_Connect_Resp_I2S包成功' );
  except
     On E : Exception Do memo1.Lines.Add( '发送Cmpp_Connect_Resp_I2S包异常:' + e.Message );
  end;
end;

// 读取ISMG返回的连接确认信息
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;
    if (CMPP_CONNECT_RESP_tag.Status=0) then
       Memo1.Lines.Add('连接成功')
    else
       Memo1.Lines.Add('连接失败');
end;

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

// 读取ISMG下发的短信类容，并且发送接收确认信息
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_StoI: tCmpp_Deliver_Resp_StoI;
    CMPP_DELIVER_tag: tCMPP_DELIVER_tag;
begin
    SizeI1 := SizeOf(tCmpp_Deliver_Resp_StoI);    //Cmpp_Deliver_Resp_ItoS
    SizeI2 := SizeOf(tCMPP_DELIVER_HEAD_tag);
    FillChar( Cmpp_Deliver_Resp_StoI, 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_HEAD_tag.Src_terminal_Id+'到：'+CMPP_DELIVER_HEAD_tag.Dest_Id+'内容:'+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_StoI.Head.Total_Length := htonl( 21 );
    Cmpp_Deliver_Resp_StoI.Head.Command_Id := htonl(CMPP_DELIVER_RESP);
    Cmpp_Deliver_Resp_StoI.Head.Sequence_Id := Cmpp_Head.Sequence_Id;
    Cmpp_Deliver_Resp_StoI.Body.Msg_Id := CMPP_DELIVER_HEAD_tag.Msg_Id;
    Cmpp_Deliver_Resp_StoI.Body.Result := 0;
    if ReadSock.SendBuf( Cmpp_Deliver_Resp_StoI, SizeI1 ) <> SizeI1 then
    begin
       memo1.Lines.Add( '发送Cmpp_Deliver_Resp_I2S包错误' );
       exit;
    end;
end;

// 读SP返回的下发确认信息
procedure TFrmMain.CmppRead_DELIVER_RESP(ReadSock: TCustomWinSocket;
  Cmpp_Head: tCMPP_HEAD_tag);
var
    SizeI1: integer;
    CMPP_DELIVER_RESP_tag: tCMPP_SUBMIT_RESP_tag;
begin
    SizeI1 := SizeOf(CMPP_DELIVER_RESP_tag);
    FillChar(CMPP_DELIVER_RESP_tag, SizeI1, 0);
    if ReadSock.ReceiveBuf(CMPP_DELIVER_RESP_tag, SizeI1) <> SizeI1 then
    begin
        Memo1.Lines.Add('接收短信发送的包体出错');
        exit;
    end;
    Memo1.Lines.Add('短信ID:'+inttostr(Cmpp_Head.Sequence_ID)+'  返回：'+inttostr(CMPP_DELIVER_RESP_tag.Result));
end;

// 读取SP上发的短信类容，并且发送接收确认信息
procedure TFrmMain.CmppRead_SUBMIT(ReadSock: TCustomWinSocket;
  Cmpp_Head: tCMPP_HEAD_tag);
var
    Size    : integer;
    CMPP_SUBMIT_tag: tCMPP_SUBMIT_tag;
    Cmpp_SubMit_Resp_ItoS : tCmpp_SubMit_Resp_ItoS;
begin
    Size := SizeOf(CMPP_SUBMIT_tag);
    FillChar( CMPP_SUBMIT_tag, Size, 0 );
    ReadSock.ReceiveBuf(CMPP_SUBMIT_tag,Size);
    memo1.Lines.Add( '接收短信：从'+CMPP_SUBMIT_tag.Src_Id
                     +' 发到：'+CMPP_SUBMIT_tag.Dest_terminal_Id
                     +' 内容：'+CMPP_SUBMIT_tag.Msg_Content );
    Size := SizeOf(Cmpp_SubMit_Resp_ItoS );
    FillChar( Cmpp_SubMit_Resp_ItoS,Size,0);
    Cmpp_SubMit_Resp_ItoS.Head.Total_Length := htonl( Size );
    Cmpp_SubMit_Resp_ItoS.Head.Command_Id := htonl(CMPP_SUBMIT_RESP);
    Cmpp_SubMit_Resp_ItoS.Head.Sequence_Id := Cmpp_Head.Sequence_Id;
    Cmpp_SubMit_Resp_ItoS.Body.Msg_Id := 1;//CMPP_SUBMIT_tag.Msg_Id;
    Cmpp_SubMit_Resp_ItoS.Body.Result := 0;
    if ReadSock.SendBuf( Cmpp_SubMit_Resp_ItoS, Size ) <> Size then
    begin
       memo1.Lines.Add( '发送Cmpp_SubMit_Resp_I2S包错误' );
       exit;
    end;
    if (memo1.Lines.Count > 1000) then
        memo1.Lines.Clear;
    memo1.Lines.Add( '发送Cmpp_SubMit_Resp_I2S包成功' );
end;

// 读ISMG返回的提交确认信息
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;
    Memo1.Lines.Add('短信ID:'+inttostr(Cmpp_Head.Sequence_ID)+'  返回：'+inttostr(CMPP_SUBMIT_RESP_tag.Result));
end;

procedure TFrmMain.BtnExitClick(Sender: TObject);
begin
    Close;
end;

procedure TFrmMain.ServerSocketClientRead(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
            CmppRead_CONNECT( Socket, CMPP_HEAD_tag )
        else
        if CMPP_HEAD_tag.Command_ID= CMPP_CONNECT_RESP then
            CmppRead_CONNECT_RESP( Socket, CMPP_HEAD_tag )
        else
        if CMPP_HEAD_tag.Command_ID= CMPP_TERMINATE then
            CmppRead_TERMINATE( Socket, CMPP_HEAD_tag )
        else
        if CMPP_HEAD_tag.Command_ID= CMPP_TERMINATE_RESP then
            memo1.Lines.Add('断开与短信网关的连接')
        else
        if CMPP_HEAD_tag.Command_ID= CMPP_DELIVER then
            CmppRead_DELIVER( Socket, CMPP_HEAD_tag )
        else
        if CMPP_HEAD_tag.Command_ID= CMPP_DELIVER_RESP then
            CmppRead_DELIVER_RESP( Socket, CMPP_HEAD_tag)
        else
        if CMPP_HEAD_tag.Command_ID= CMPP_SUBMIT then
            CmppRead_SUBMIT( Socket, CMPP_HEAD_tag )
        else
        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
       On E : Exception Do memo1.Lines.Add( 'SocketRead,异常:' + e.Message );
    end;
end;

end.