?? main.pas
字號:
//文件名稱：YiDong_Cmpp.pas
//文件標識：tYD_Cmpp類
//當前版本：1.0
//作 者：邵青山,李朔剛
//mail: sqs@minefont.com lshuogang@sohu.com
//完成日期：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.
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -