using System;
using System.IO;
using NewLife.Net.Sockets;
namespace NewLife.Net.SGIP
{
/// <summary>SGIP客户端</summary>
public class SGIPClient : Netbase
{
#region 属性
#region 基本属性
private ISocketClient _Client;
/// <summary>TCP客户端</summary>
public ISocketClient Client { get { return _Client; } set { _Client = value; } }
private String _IP;
/// <summary>IP地址</summary>
public String IP { get { return _IP; } set { _IP = value; } }
private Int32 _Port;
/// <summary>端口</summary>
public Int32 Port { get { return _Port; } set { _Port = value; } }
private UInt32 _SrcNodeSequence;
/// <summary>源节点</summary>
public UInt32 SrcNodeSequence { get { return _SrcNodeSequence; } set { _SrcNodeSequence = value; } }
#endregion
#region 登录属性
private String _SystemID;
/// <summary>帐号名</summary>
public String SystemID { get { return _SystemID; } set { _SystemID = value; } }
private String _Password;
/// <summary>密码</summary>
public String Password { get { return _Password; } set { _Password = value; } }
private Boolean _Logined = false;
/// <summary>是否已登录</summary>
public Boolean Logined { get { return _Logined; } set { _Logined = value; } }
#endregion
#region 发信息属性
private String _SPNumber;
/// <summary>SP的接入号码。</summary>
public String SPNumber { get { return _SPNumber; } set { _SPNumber = value; } }
private String _CorpID;
/// <summary>企业代码。取值范围：0～99999。</summary>
public String CorpID { get { return _CorpID; } set { _CorpID = value; } }
private String _ServiceType;
/// <summary>业务代码</summary>
public String ServiceType { get { return _ServiceType; } set { _ServiceType = value; } }
#endregion
#endregion
#region 登录
/// <summary>登录。发送Bind指令，接收Bind_Resp响应</summary>
/// <returns></returns>
public Boolean Login()
{
WriteLog(String.Format("正在连接服务器…… {0}:{1}", IP, Port));
var client = new TcpSession();
Client = client;
try
{
//client.Connect(IP, Port);
//client.Connect(IP, Port);
client.Remote.Host = IP;
client.Remote.Port = Port;
}
catch (Exception ex)
{
var str = IP + ":" + Port.ToString();
throw new NetException("连接网关服务器" + str + "出错，请确定网络是否畅通！" + ex.Message, ex);
}
var cmd = new SGIPBind();
cmd.LoginName = SystemID;
cmd.LoginPassowrd = Password;
cmd.LoginType = LoginTypes.SpToSmg;
WriteLog("正在登录……");
var session = client as ISocketSession;
session.Send(cmd.GetStream().ReadBytes());
var pk = client.Receive();
var resp = SGIPEntity.Read(pk.GetStream()) as SGIPResponse;
if (resp == null) throw new Exception("登录失败！服务器没有响应！");
if (resp.Result != SGIPErrorCodes.Success) throw new Exception("登录失败！" + resp.Result.GetDescription());
//登录完成，开始读取指令
client.Received += Client_Received;
client.Open();
Logined = true;
WriteLog("登录成功！");
return true;
}
void Client_Received(Object sender, ReceivedEventArgs e)
{
}
#endregion
#region 发信息
/// <summary>发信息</summary>
/// <param name="target">目标对象</param>
/// <param name="content"></param>
public void SendMessage(String target, String content)
{
if (String.IsNullOrEmpty(target) || String.IsNullOrEmpty(content)) return;
if (!target.StartsWith("86")) target = "86" + target;
var cmd = new SGIPSubmit();
var id = SystemID;
if (id.Length > 4) id = SystemID.Substring(4);
cmd.SPNumber = SPNumber + id + "4888";
cmd.ChargeNumber = new String('0', 21);
cmd.UserCount = 1;
cmd.UserNumber = target;
cmd.CorpId = CorpID;
cmd.ServiceType = ServiceType;
cmd.FeeType = FeeTypes.FreeSend;
cmd.FeeValue = "0";
cmd.GivenValue = "0";
cmd.AgentFlag = SubmitAgentFlags.SouldIncome;
cmd.MorelatetoMTFlag = SubmitMorelatetoMTFlags.NormalFirst;
cmd.Priority = 0;
cmd.ExpireTime = "";
cmd.ScheduleTime = "";
cmd.ReportFlag = SubmitReportFlags.Always;
cmd.TP_pid = 0;
cmd.TP_udhi = 0;
cmd.MessageCoding = SGIPMessageCodings.Gbk;
//cmd.MessageCoding = MessageCodings.Ascii;
cmd.MessageType = 0;
//cmd.MessageLength = (UInt32)content.Length;
cmd.MessageContent = content;
WriteLog("正在向" + target + "发信息……");
//Submit_Resp resp = Send(cmd) as Submit_Resp;
Send(cmd);
}
/// <summary>传递信息</summary>
/// <param name="target">目标对象</param>
/// <param name="content"></param>
/// <returns></returns>
public void DeliverMessage(String target, String content)
{
if (String.IsNullOrEmpty(target) || String.IsNullOrEmpty(content)) return;
if (!target.StartsWith("86")) target = "86" + target;
var cmd = new SGIPDeliver();
cmd.UserNumber = target;
cmd.SPNumber = SPNumber + SystemID.Substring(4) + "4888";
cmd.TP_pid = 0;
cmd.TP_udhi = 0;
cmd.MessageCoding = SGIPMessageCodings.Gbk;
cmd.MessageLength = (UInt32)content.Length;
cmd.MessageContent = content;
WriteLog("正在向" + target + "分发信息……");
//Deliver_Resp resp = Send(cmd) as Deliver_Resp;
Send(cmd);
}
#endregion
#region 退出
/// <summary>退出</summary>
/// <returns></returns>
public Boolean Logout()
{
if (Logined)
{
WriteLog("正在注销……");
if (Client != null && Client.Client.Connected)
{
try
{
Write(new SGIPUnbind());
WriteLog("注销成功！");
}
catch (Exception ex)
{
WriteLog("注销失败！" + ex.Message);
}
}
Logined = false;
}
Client?.Close("注销");
return true;
}
#endregion
#region 发命令
/// <summary>发送指令，返回响应</summary>
/// <param name="command">指令</param>
/// <returns>响应</returns>
private SGIPEntity Send(SGIPEntity command)
{
Write(command);
return null;
}
#endregion
#region 读写命令
/// <summary>读命令</summary>
/// <returns></returns>
private SGIPEntity Read()
{
if (Client == null || !Client.Client.Connected) throw new InvalidOperationException("没有连接到服务器！");
try
{
var cmd = SGIPEntity.Read(Client.Receive().GetStream());
if (cmd == null) throw new Exception("获取命令失败！");
WriteLog("收包：" + cmd.ToString());
return cmd;
}
catch (IOException ex)
{
throw new InvalidOperationException("读命令失败！", ex);
}
}
/// <summary>写命令</summary>
/// <param name="cmd"></param>
private void Write(SGIPEntity cmd)
{
if (Client == null || !Client.Client.Connected) throw new InvalidOperationException("没有连接到服务器！");
if (cmd.SrcNodeSequence < 1) cmd.SrcNodeSequence = SrcNodeSequence;
try
{
try
{
Client.Send(cmd.GetStream().ReadBytes());
}
catch (Exception ex)
{
throw new Exception("发送" + cmd.Command + "指令失败！", ex);
}
WriteLog("发包：" + cmd);
}
catch (IOException ex)
{
throw new InvalidOperationException("写" + cmd.Command + "命令失败！", ex);
}
}
#endregion
}
}
|