Files
lserp_cs_6.0/插件库/Lskj.SocketService/AsyncSocketCore/OutgoingDataAssembler.cs
T
cyf ab56a9bcf7 基线 SVN r240
SVN-Revision: r240
2025-02-06 06:46:06 +00:00

226 lines
8.4 KiB
C#

/******************************
* 说明:协议组装器,用来组装往外发送的命令
* 创建人:龚宇超
* 创建日期:2018-01-23
* 修改人:
* 修改日期:
* 修改备注:
* 版本:1.0.0.0
******************************/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
namespace Lskj.SocketService
{
/// <summary>
/// 协议组装器,用来组装往外发送的命令
/// </summary>
public class OutgoingDataAssembler
{
private List<string> _protocolText;
public OutgoingDataAssembler()
{
_protocolText = new List<string>();
}
/// <summary>
/// <para>说明:清除发送数据</para>
/// <para>创建人:龚宇超</para>
/// <para>创建日期:2018-01-24 </para>
/// <para>修改人:</para>
/// <para>修改日期:</para>
/// <para>修改备注:</para>
/// <para>版本:1.0</para>
/// </summary>
public void Clear()
{
_protocolText.Clear();
}
/// <summary>
/// <para>说明:获取发送数据</para>
/// <para>创建人:龚宇超</para>
/// <para>创建日期:2018-01-24 </para>
/// <para>修改人:</para>
/// <para>修改日期:</para>
/// <para>修改备注:</para>
/// <para>版本:1.0</para>
/// </summary>
/// <returns>System.String.</returns>
public string GetProtocolText()
{
string tmpStr = "";
if (_protocolText.Count > 0)
{
tmpStr = _protocolText[0];
for (int i = 1; i < _protocolText.Count; i++)
{
tmpStr = tmpStr + ProtocolKey.ReturnWrap + _protocolText[i];
}
}
return tmpStr;
}
/// <summary>
/// <para>说明:添加Request</para>
/// <para>创建人:龚宇超</para>
/// <para>创建日期:2018-01-24 </para>
/// <para>修改人:</para>
/// <para>修改日期:</para>
/// <para>修改备注:</para>
/// <para>版本:1.0</para>
/// </summary>
public void AddRequest()
{
_protocolText.Add(ProtocolKey.LeftBrackets + ProtocolKey.Request + ProtocolKey.RightBrackets);
}
/// <summary>
/// <para>说明:添加Response</para>
/// <para>创建人:龚宇超</para>
/// <para>创建日期:2018-01-24 </para>
/// <para>修改人:</para>
/// <para>修改日期:</para>
/// <para>修改备注:</para>
/// <para>版本:1.0</para>
/// </summary>
public void AddResponse()
{
_protocolText.Add(ProtocolKey.LeftBrackets + ProtocolKey.Response + ProtocolKey.RightBrackets);
}
/// <summary>
/// <para>说明:添加Command</para>
/// <para>创建人:龚宇超</para>
/// <para>创建日期:2018-01-24 </para>
/// <para>修改人:</para>
/// <para>修改日期:</para>
/// <para>修改备注:</para>
/// <para>版本:1.0</para>
/// </summary>
/// <param name="commandKey">The command key.</param>
public void AddCommand(string commandKey)
{
_protocolText.Add(ProtocolKey.Command + ProtocolKey.EqualSign + commandKey);
}
/// <summary>
/// <para>说明:添加Success标记</para>
/// <para>创建人:龚宇超</para>
/// <para>创建日期:2018-01-24 </para>
/// <para>修改人:</para>
/// <para>修改日期:</para>
/// <para>修改备注:</para>
/// <para>版本:1.0</para>
/// </summary>
public void AddSuccess()
{
_protocolText.Add(ProtocolKey.Code + ProtocolKey.EqualSign + ProtocolCode.Success.ToString());
}
/// <summary>
/// <para>说明:添加Failure</para>
/// <para>创建人:龚宇超</para>
/// <para>创建日期:2018-01-24 </para>
/// <para>修改人:</para>
/// <para>修改日期:</para>
/// <para>修改备注:</para>
/// <para>版本:1.0</para>
/// </summary>
/// <param name="errorCode">The error code.</param>
/// <param name="message">The message.</param>
public void AddFailure(int errorCode, string message)
{
_protocolText.Add(ProtocolKey.Code + ProtocolKey.EqualSign + errorCode.ToString());
_protocolText.Add(ProtocolKey.Message + ProtocolKey.EqualSign + message);
}
/// <summary>
/// <para>说明:添加Key、Value</para>
/// <para>创建人:龚宇超</para>
/// <para>创建日期:2018-01-24 </para>
/// <para>修改人:</para>
/// <para>修改日期:</para>
/// <para>修改备注:</para>
/// <para>版本:1.0</para>
/// </summary>
/// <param name="protocolKey">The protocol key.</param>
/// <param name="value">The value.</param>
public void AddValue(string protocolKey, string value)
{
_protocolText.Add(protocolKey + ProtocolKey.EqualSign + value);
}
/// <summary>
/// <para>说明:添加Key、Value</para>
/// <para>创建人:龚宇超</para>
/// <para>创建日期:2018-01-24 </para>
/// <para>修改人:</para>
/// <para>修改日期:</para>
/// <para>修改备注:</para>
/// <para>版本:1.0</para>
/// </summary>
/// <param name="protocolKey">The protocol key.</param>
/// <param name="value">The value.</param>
public void AddValue(string protocolKey, short value)
{
_protocolText.Add(protocolKey + ProtocolKey.EqualSign + value.ToString());
}
/// <summary>
/// <para>说明:添加Key、Value</para>
/// <para>创建人:龚宇超</para>
/// <para>创建日期:2018-01-24 </para>
/// <para>修改人:</para>
/// <para>修改日期:</para>
/// <para>修改备注:</para>
/// <para>版本:1.0</para>
/// </summary>
/// <param name="protocolKey">The protocol key.</param>
/// <param name="value">The value.</param>
public void AddValue(string protocolKey, int value)
{
_protocolText.Add(protocolKey + ProtocolKey.EqualSign + value.ToString());
}
/// <summary>
/// <para>说明:添加Key、Value</para>
/// <para>创建人:龚宇超</para>
/// <para>创建日期:2018-01-24 </para>
/// <para>修改人:</para>
/// <para>修改日期:</para>
/// <para>修改备注:</para>
/// <para>版本:1.0</para>
/// </summary>
/// <param name="protocolKey">The protocol key.</param>
/// <param name="value">The value.</param>
public void AddValue(string protocolKey, long value)
{
_protocolText.Add(protocolKey + ProtocolKey.EqualSign + value.ToString());
}
/// <summary>
/// <para>说明:添加Key、Value</para>
/// <para>创建人:龚宇超</para>
/// <para>创建日期:2018-01-24 </para>
/// <para>修改人:</para>
/// <para>修改日期:</para>
/// <para>修改备注:</para>
/// <para>版本:1.0</para>
/// </summary>
/// <param name="protocolKey">The protocol key.</param>
/// <param name="value">The value.</param>
public void AddValue(string protocolKey, Single value)
{
_protocolText.Add(protocolKey + ProtocolKey.EqualSign + value.ToString());
}
/// <summary>
/// <para>说明:添加Key、Value</para>
/// <para>创建人:龚宇超</para>
/// <para>创建日期:2018-01-24 </para>
/// <para>修改人:</para>
/// <para>修改日期:</para>
/// <para>修改备注:</para>
/// <para>版本:1.0</para>
/// </summary>
/// <param name="protocolKey">The protocol key.</param>
/// <param name="value">The value.</param>
public void AddValue(string protocolKey, double value)
{
_protocolText.Add(protocolKey + ProtocolKey.EqualSign + value.ToString());
}
}
}