delphi 短信

獨孤求財 2012-03-20

展開全文

delphi 短信

時間:2011-5-26來源:yang 作者: peng點擊: 9次

//傳輸文件的服務器端
//這個程序在服務器端要一直開著，否則客戶端連接不了服務器
//客戶--->左右軟件--->巨瀾短信網(wǎng)關

unit uServer;

interface

uses
Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
Dialogs, StdCtrls, ExtCtrls, IdBaseComponent, IdComponent, IdTCPServer,
ComCtrls,uImpTxt, DB,ADODB,IniFiles;

type
//********************************************************************

//自定義類型
THandle = Integer;
JL_HANDLE = Integer;
PJL_HANDLE = ^JL_HANDLE;

//以HTTP方式登陸返回操作句柄，當調用退出登陸時，此句柄自動失效。// 參數(shù)說明
T_JL_TCPLogin = function(strHost: Pchar; // strHost: 主機名稱或者IP地址： ‘http://www./ 不用改變
nPort: Integer; // nPort: 端口號： 6688 不用改變
strUserId: Pchar; // strUserId: 用戶名
strPassword: Pchar; // strPassword: 用戶密碼
nType: Integer; // nType連接類型，為 1 表示只發(fā)送，為 2表示即可發(fā)送也可接收默認為 2
pRtnHandle: PJL_HANDLE): Integer stdcall; // pRtnHandle：返回操作句柄

//退出登陸，此句柄自動失效
T_JL_Logout = function(pHandle: JL_HANDLE): Integer stdcall; // pRtnHandle：登陸時的操作句柄

//群發(fā)短信息
T_JL_SendMsg = function(pHandle: JL_HANDLE; //操作句柄
strFromPhone: Pchar; // strFromPhone 短消息發(fā)送者手機號碼
strToPhone: Pchar; // strToPhone 目的手機號碼，如果有多個號碼，用逗號進行分割，如13900000000, 13911111111, ...
strContent: Pchar; // strContent 信息內容，信息長度不超過140字節(jié)，否則將返回 JL_ERR_CONTENT
strSendTime: Pchar): Integer stdcall; // strSendTime 定時發(fā)送時間。格式：yyyy-mm-dd hh:mm:ss 為空時，表示立即發(fā)送

//單發(fā)短信息
T_JL_SingleSendMsg = function(pHandle: JL_HANDLE; //操作句柄
strSerNo: PChar; //自定義編號-以對應相應的狀態(tài)報告
strFromPhone: Pchar; // strFromPhone 短消息發(fā)送者手機號碼
strToPhone: Pchar; // strToPhone 目的手機號碼，如果有多個號碼，用逗號進行分割，如13900000000, 13911111111, ...
strContent: Pchar; // strContent 信息內容，信息長度不超過140字節(jié)，否則將返回 JL_ERR_CONTENT
strSendTime: Pchar): Integer stdcall; // strSendTime 定時發(fā)送時間。格式：yyyy-mm-dd hh:mm:ss 為空時，表示立即發(fā)送

//查詢帳戶余額 -參數(shù)：fBalance：返回金額，單位為元
T_JL_GetAccountBalance = function(pHandle: JL_HANDLE; fBalance: PSingle): Integer stdcall;

// 查詢單價 -參數(shù)：fPrice：返回金額，單位為元
T_JL_GetAccountPrice = function(Handle: JL_HANDLE; fPrice: PSingle): Integer stdcall;

// 修改用戶密碼
T_JL_ModifyPassword = function(pHandle: JL_HANDLE; // 操作句柄
strNewPassword: Pchar): Integer stdcall; //strNewPassword：新的密碼

// 接收短信返回的狀態(tài)報告 pstrPhone [21] pstrDescribe[255]
T_JL_GetOneReport = function(pHandle: JL_HANDLE; // 操作句柄
pstrSerNo: PChar; //用戶自定義序列（單發(fā)時用戶傳過去的參數(shù)）
pnReqID: PInteger; //返回MO短信ID
pstrPhone: Pchar; //字符串緩沖區(qū)，大小至少為21字節(jié)，返回接收手機號碼
pnStatus: PInteger; // 返回短信息接收狀態(tài) 0：發(fā)送失敗 1：信息已發(fā)送到網(wǎng)關 3：信息已發(fā)送到手機
pstrDescribe: Pchar): Integer stdcall; //字符串緩沖區(qū)，大小至少為256字節(jié)，返回狀態(tài)描述

T_JL_GetOneSM = function(pHandle: JL_HANDLE; // 操作句柄
pnMsgID: PInteger; //信息id
strFrom: Pchar; //返回發(fā)送者的手機號碼字符串緩沖區(qū)，大小至少為21字節(jié)
strCreateTime: Pchar; // 返回發(fā)送時間字符串緩沖區(qū)，大小至少為20字節(jié)
strContent: Pchar): Integer stdcall; //返回消息內容字符串緩沖區(qū)，大小至少為256字節(jié)。

T_JL_GetOneSM_Ex = function(pHandle: JL_HANDLE; // 操作句柄
pnMsgID: PInteger; //信息id
strFrom: Pchar; //返回發(fā)送者的手機號碼字符串緩沖區(qū)，大小至少為21字節(jié)
strTo: Pchar; //字符串緩沖區(qū)，大小至少為21字節(jié)，返回來源端口號
strCreateTime: Pchar; // 返回發(fā)送時間字符串緩沖區(qū)，大小至少為20字節(jié)
strContent: Pchar): Integer stdcall; //返回消息內容字符串緩沖區(qū)，大小至少為256字節(jié)。

//********************************************************************
type
TFormServer = class(TForm)
IdTCPServer1: TIdTCPServer;
BtnStart: TButton;
StatusBar1: TStatusBar;
BtnStop: TButton;
LabeledEdit1: TLabeledEdit;
ListBox1: TListBox;
ADOQuery1: TADOQuery;
ADOQuery2: TADOQuery;
ADOConnection1: TADOConnection;
ADOQuery3: TADOQuery;
ADOQuery4: TADOQuery;
procedure IdTCPServer1Execute(AThread: TIdPeerThread);
procedure BtnStartClick(Sender: TObject);
procedure FormClose(Sender: TObject; var Action: TCloseAction);
procedure BtnStopClick(Sender: TObject);
procedure IdTCPServer1Connect(AThread: TIdPeerThread);
procedure ShowResultMsg(num: Integer);
private
{ Private declarations }
public
{ Public declarations }
OneHandle: THandle; //定義一個句柄變量
pRtnHandle: JL_HANDLE; //定義一個句柄變量
JL_TCPLogin: T_JL_TCPLogin; //登陸
JL_Logout: T_JL_Logout; //退出
JL_GetAccountPrice: T_JL_GetAccountPrice; //單價／條
JL_GetAccountBalance: T_JL_GetAccountBalance; //帳戶余額
JL_ModifyPassword: T_JL_ModifyPassword; //修改密碼
JL_GetOneSM: T_JL_GetOneSM; //收取回復信息(HTTP)
JL_GetOneSM_Ex: T_JL_GetOneSM_Ex; //收取回復信息(TCP)
JL_GetOneReport: T_JL_GetOneReport; //收取狀態(tài)報告
JL_SingleSendMsg: T_JL_SingleSendMsg; //單發(fā)信息
JL_SendMsg: T_JL_SendMsg; // 群發(fā)信息
end;

var
FormServer: TFormServer;

const
FFileName=‘d:\sms.txt‘; //參數(shù)有待放進INI文件中
FPort=9925;
FUserName=‘‘; //登錄巨瀾短信網(wǎng)關用戶名和密碼
FPWS=‘‘;

implementation

uses uCommFunc;

{$R *.dfm}

//------返回錯誤列表--------------------------------------------------
procedure tformserver.ShowResultMsg(num: Integer);
begin
case num of
0: MessageBox(Handle, ‘正常!‘, ‘Surge‘, MB_ICONASTERISK);
-1: MessageBox(Handle, ‘EPID錯誤‘, ‘Surge‘, MB_ICONHAND);
-2: MessageBox(Handle, ‘無該用戶‘, ‘Surge‘, MB_ICONHAND);
-3: MessageBox(Handle, ‘注冊碼錯‘, ‘Surge‘, MB_ICONHAND);
-4: MessageBox(Handle, ‘用戶被停用‘, ‘Surge‘, MB_ICONHAND);
-5: MessageBox(Handle, ‘未注冊成功‘, ‘Surge‘, MB_ICONHAND);
-6: MessageBox(Handle, ‘超出使用日期‘, ‘Surge‘, MB_ICONHAND);
-7: MessageBox(Handle, ‘費用不足‘, ‘Surge‘, MB_ICONHAND);
-8: MessageBox(Handle, ‘源手機錯誤‘, ‘Surge‘, MB_ICONHAND);
-9: MessageBox(Handle, ‘目的手機錯誤‘, ‘Surge‘, MB_ICONHAND);
-10: MessageBox(Handle, ‘信息內容錯誤‘, ‘Surge‘, MB_ICONHAND);
-11: MessageBox(Handle, ‘連接失敗‘, ‘Surge‘, MB_ICONHAND);
-12: MessageBox(Handle, ‘系統(tǒng)內部錯誤或者無效的客戶狀態(tài)‘, ‘Surge‘, MB_ICONHAND);
-13: MessageBox(Handle, ‘客戶權限不對‘, ‘Surge‘, MB_ICONHAND);
-14: MessageBox(Handle, ‘不是從指定的IP處登錄‘, ‘Surge‘, MB_ICONHAND);
-15: MessageBox(Handle, ‘賬號已經(jīng)登錄(TCP)‘, ‘Surge‘, MB_ICONHAND);
-16: MessageBox(Handle, ‘內部通訊錯誤‘, ‘Surge‘, MB_ICONHAND);
-17: MessageBox(Handle, ‘無可用的MT通道‘, ‘Surge‘, MB_ICONHAND);
-18: MessageBox(Handle, ‘不支持該功能‘, ‘Surge‘, MB_ICONHAND);
-19: MessageBox(Handle, ‘未定義錯誤‘, ‘Surge‘, MB_ICONHAND); //-------------未定義錯誤
-20: MessageBox(Handle, ‘未知錯誤‘, ‘Surge‘, MB_ICONHAND);
-21: MessageBox(Handle, ‘請求過于頻繁‘, ‘Surge‘, MB_ICONHAND);
-22: MessageBox(Handle, ‘信息內容有非法關鍵字‘, ‘Surge‘, MB_ICONHAND);
-23: MessageBox(Handle, ‘錯誤的產(chǎn)品ID‘, ‘Surge‘, MB_ICONHAND);
-24: MessageBox(Handle, ‘發(fā)送失敗－Agent 斷線‘, ‘Surge‘, MB_ICONHAND);
-25: MessageBox(Handle, ‘發(fā)送失?。璖MSC 斷線‘, ‘Surge‘, MB_ICONHAND);
-26: MessageBox(Handle, ‘發(fā)送失?。瑼gent 與 SMSC 之間斷線‘, ‘Surge‘, MB_ICONHAND);
-27: MessageBox(Handle, ‘錯誤的指令或格式‘, ‘Surge‘, MB_ICONHAND);
else
MessageBox(Handle, ‘未知錯誤‘, ‘Surge‘, MB_ICONHAND);
end;
end;

procedure TFormServer.IdTCPServer1Execute(AThread: TIdPeerThread);
//const
// c_sql=‘select * from sms_msg_server ‘+ //status:0/1/2 待發(fā)/成功/失敗
// ‘ where status=0 or status=2 ‘; //待發(fā)和曾經(jīng)發(fā)送失敗的都要發(fā)
var
AFileStream: TFileStream;
cmd:string;
DllPaht: string; // DLL的地址
rtn: Integer; //巨瀾的函數(shù)是否執(zhí)行成功
mtel:string; //手機號碼
content:string; //短信內容
SendTimes:Integer;//發(fā)送次數(shù)
i:Integer; //單條發(fā)送次數(shù)
iSuccess:Integer; //發(fā)送成功條數(shù)
price:Double; //短信單價
money:Double; //發(fā)送短信金額
INIFile:TIniFile;
MyCs:TRTLCriticalSection;//臨界區(qū)

procedure UpdateStatusDate; //更新狀態(tài)時間(不論成功或者失敗)
begin
with ADOQuery3 do
begin
Close;
sql.Clear;
SQL.Text:=‘update sms_msg_server set status_date=:statusdate ‘+
‘ mtel:=:mtel and ‘+
‘ create_date=:createdate ‘; //create_date是唯一的
Parameters.ParamByName(‘status_date‘).Value:=Now;
Parameters.ParamByName(‘mtel‘).Value:=ADOQuery2.fieldbyname(‘mtel‘).AsString;
Parameters.ParamByName(‘create_date‘).Value:=ADOQuery2.fieldbyname(‘create_date‘).AsDateTime;
ExecSQL;
end;
end;

begin
InitializeCriticalSection(MyCs);//初始化臨界區(qū)
with AThread.Connection do
begin
cmd := UpperCase(ReadLn);
if cmd=‘BEGIN‘ then
begin
EnterCriticalSection(MyCs); //進入臨界區(qū),從流生成文本文件，以及將該文本文件寫進數(shù)據(jù)表這一段要使用臨界區(qū)保護
try
AFileStream := TFileStream.Create(FFileName, fmCreate);//建立文件流準備接收
try
ReadStream(AFileStream, -1, true); //讀入全部直到結束connect
Application.ProcessMessages;
finally
AFileStream.Free; //釋放文件流
end;
if not TxtToDataset(ADOQuery1,FFileName,‘,‘) then //將文本文件寫入數(shù)據(jù)庫
Application.MessageBox(‘文本寫入數(shù)據(jù)庫失敗‘, ‘錯誤‘, MB_OK +
MB_ICONSTOP);
finally
LeaveCriticalSection(MyCs); //離開臨界區(qū)
end;
//將短信發(fā)送給巨瀾短信網(wǎng)關
//登錄巨瀾
if (OneHandle=0) or (pRtnHandle=0) then begin //未登錄
DllPaht := ExtractFilePath(Application.ExeName) + ‘\JL_ISP.dll‘; //獲得DLL的地址
OneHandle := LoadLibrary(Pchar(DllPaht)); //動態(tài)載入DLL，并返回其句柄
try
if OneHandle <> 0 then //如果載入DLL成功則獲取DLL函數(shù)的地址
begin
@JL_TCPLogin := GetProcAddress(OneHandle, ‘JL_TCPLogin‘);
@JL_Logout := GetProcAddress(OneHandle, ‘JL_Logout‘);
@JL_GetAccountPrice := GetProcAddress(OneHandle, ‘JL_GetAccountPrice‘);
@JL_GetAccountBalance := GetProcAddress(OneHandle, ‘JL_GetAccountBalance‘);
@JL_ModifyPassword := GetProcAddress(OneHandle, ‘JL_ModifyPassword‘);
@JL_GetOneReport := GetProcAddress(OneHandle, ‘JL_GetOneReport‘);
@JL_GetOneSM := GetProcAddress(OneHandle, ‘JL_GetOneSM‘);
@JL_GetOneSM_Ex := GetProcAddress(OneHandle, ‘JL_GetOneSM_Ex‘);
@JL_SingleSendMsg := GetProcAddress(OneHandle, ‘JL_SingleSendMsg‘);
@JL_SendMsg := GetProcAddress(OneHandle, ‘JL_SendMsg‘);
end;
if not (@JL_TCPLogin = nil) then //登錄巨瀾服務器
begin
rtn := JL_TCPLogin( //函數(shù)定義見Type部分。
‘http://www./
6688,
Pchar(fusername),
Pchar(fpws),
2,
@pRtnHandle);
ShowResultMsg(rtn);
if rtn <> 0 then
begin
pRtnHandle := 0;
OneHandle := 0;
end;
end
else
RaiseLastOSError; //報錯
except
MessageBox(Handle, ‘系統(tǒng)嚴重錯誤，請重新登陸！!‘, ‘Surge‘, MB_ICONASTERISK);
end;
end;
//單條短信循環(huán)發(fā)送
with ADOQuery2 do
begin
Close;
SQL.Clear;
SQL.Text:=‘select * from sms_msg_server ‘+ //status:0/1/2 待發(fā)/成功/失敗
‘ where status=0 or status=2 ‘; //發(fā)送待發(fā)和發(fā)送失敗的短信
Open;
end;
if ADOQuery2.IsEmpty then exit;
iSuccess:=0; //初始化發(fā)送成功短信條數(shù)變量
ADOQuery2.First;
while not ADOQuery2.Eof do
begin
//發(fā)送前要檢查客戶的剩余短信條數(shù)，等于0則不允許發(fā)送，跳轉下一條記錄
with ADOQuery4 do
begin
Close;
SQL.Clear;
SQL.Text:=‘ select user_leftamounts from sms_user ‘+
‘ where user_name=:username ‘;
Parameters.ParamByName(‘user_name‘).Value:=ADOQuery2.fieldbyname(‘shop_name‘).AsString;
Open;
end;
if ADOQuery4.FieldByName(‘user_leftamounts‘).Value<=0 then //帳戶余額不足
begin
Application.MessageBox(PChar(ADOQuery2.fieldbyname(‘shop_name‘).AsString+‘的余額已不足‘),
‘警告‘, MB_OK + MB_ICONWARNING);
exit;
end;

mtel:=ADOQuery2.fieldbyname(‘mtel‘).AsString; //目標手機號
content:=ADOQuery2.fieldbyname(‘content‘).AsString; //短信內容

if (pRtnHandle = 0) or (OneHandle = 0) then //判斷是否登陸
begin
MessageBox(Handle, ‘你還沒有登陸!‘, ‘Surge‘, MB_ICONASTERISK);
exit;
end;

SendTimes:=ADOQuery2.fieldbyname(‘send_times‘).AsInteger; //短信發(fā)送次數(shù)
for i:=1 to sendtimes do
try
rtn := JL_SingleSendMsg(pRtnHandle, //函數(shù)定義見Type部分。
PChar(IntToStr(i)), //自定義編號-以對應相應的狀態(tài)報告,每次發(fā)送應傳入不同的值，用以對應收取到的狀態(tài)報告
‘‘, //擴展端口號
PChar(Trim(mtel)), //群發(fā)時號碼用逗號分隔，TCP協(xié)議一次群發(fā)最多50個號碼。HTTP協(xié)議一次群發(fā)最多100個號碼。
PChar(Trim(content)), //內容長度為按 Unicode characters 類型計算 ,總長度不可以超過70個字(包含簽名)
‘‘); //發(fā)送時間，暫不支持！

if rtn = 0 then //發(fā)送成功
begin
Inc(iSuccess); //累加發(fā)送成功條數(shù)
ADOQuery3.Connection.BeginTrans; //開始事務
//計算發(fā)送費用
INIFile:=TIniFile.Create(GetINIFile);
try
price:=INIFile.ReadFloat(‘server‘,‘price‘,0.6); //獲取短信的單價
finally
INIFile.Free;
end;
money:=iSuccess*price; //發(fā)送條數(shù)*單價
with ADOQuery3 do //更新用戶余額，剩余條數(shù)
begin
Close;
SQL.Clear;
sql.Text:=‘update sms_user ‘+
‘ set user_leftmoney=user_leftmoney-:money, ‘+
‘ user_leftamounts=user_leftamounts-:amounts ‘+
‘ where user_name=:username ‘;
Parameters.ParamByName(‘user_leftmoney‘).Value:=money;
Parameters.ParamByName(‘user_leftamounts‘).Value:=iSuccess;
Parameters.ParamByName(‘user_name‘).Value:=ADOQuery2.fieldbyname(‘shop_name‘).AsString;
ExecSQL;
end;
with ADOQuery3 do //更新狀態(tài)為發(fā)送成功
begin
Close;
sql.Clear;
SQL.Text:=‘update sms_msg_server set status=1 ‘+
‘ where status=0 and ‘+
‘ mtel:=:mtel and ‘+
‘ create_date=:createdata ‘;
Parameters.ParamByName(‘mtel‘).Value:=ADOQuery2.fieldbyname(‘mtel‘).AsString;
Parameters.ParamByName(‘create_date‘).Value:=ADOQuery2.fieldbyname(‘create_date‘).AsDateTime;
ExecSQL;
end;
UpdateStatusDate; //更新狀態(tài)時間
try
ADOQuery3.Connection.CommitTrans; //提交事務
except
ADOQuery3.Connection.RollbackTrans; //回滾事務
end;
MessageBox(Handle, ‘成功發(fā)送!‘, ‘Surge‘, MB_ICONASTERISK);
end
else //發(fā)送失敗
begin
ADOQuery3.Connection.BeginTrans; //開始事務
with ADOQuery3 do
begin
Close;
sql.Clear;
SQL.Text:=‘update sms_msg_server set status=2 ‘+ //更新狀態(tài)為發(fā)送失敗
‘ where status=0 and ‘+
‘ mtel:=:mtel and ‘+
‘ create_date=:createdate ‘;
Parameters.ParamByName(‘mtel‘).Value:=ADOQuery2.fieldbyname(‘mtel‘).AsString;
Parameters.ParamByName(‘create_date‘).Value:=ADOQuery2.fieldbyname(‘create_date‘).AsDateTime;
ExecSQL;
end;
UpdateStatusDate; //更新狀態(tài)時間
try
ADOQuery3.Connection.CommitTrans; //提交事務
except
ADOQuery3.Connection.RollbackTrans; //回滾事務
end;
ShowResultMsg(rtn); //通過函數(shù)的返回值顯示相應信息
end;
except
on e:exception do
MessageBox(Handle, PChar(e.Message) , ‘Surge‘, MB_ICONASTERISK);
//‘系統(tǒng)嚴重錯誤，請重新登陸！!‘
end;
ADOQuery2.Next; //發(fā)送下一條短信
end;
end;
end;
DeleteCriticalSection(MyCs); //刪除臨界界
end;

procedure TFormServer.BtnStartClick(Sender: TObject); //啟動SOCKET服務端
begin
IdTCPServer1.DefaultPort := strtoint(LabeledEdit1.Text); //端口
if not IdTCPServer1.Active then
try
IdTCPServer1.Active := True;
ListBox1.Items.Add(‘已啟動‘);
except
ListBox1.Items.Add(‘啟動失敗‘);
end;
end;

procedure TFormServer.FormClose(Sender: TObject; var Action: TCloseAction);
begin
IdTCPServer1.Active:=False;
end;

procedure TFormServer.BtnStopClick(Sender: TObject);
begin
IdTCPServer1.Active:=False;
ListBox1.Items.Add(‘已停止‘);
end;

procedure TFormServer.IdTCPServer1Connect(AThread: TIdPeerThread);
begin
ListBox1.Items.Add(‘來自 ‘
+ AThread.Connection.Socket.Binding.PeerIP
+ ‘ 的連接請求已被允許‘);
AThread.Connection.WriteLn(‘歡迎連接到左右軟件短信服務器‘);
end;

end.

本站是提供個人知識管理的網(wǎng)絡存儲空間，所有內容均由用戶發(fā)布，不代表本站觀點。請注意甄別內容中的聯(lián)系方式、誘導購買等信息，謹防詐騙。如發(fā)現(xiàn)有害或侵權內容，請點擊一鍵舉報。

小男孩‘自慰网亚洲一区二区,亚洲一级在线播放毛片,亚洲中文字幕av每天更新,黄aⅴ永久免费无码,91成人午夜在线精品,色网站免费在线观看,亚洲欧洲wwwww在线观看

delphi 短信

delphi 短信