Browse Source

MessageTransferProtocolLog

feature/x1-web-request
root 1 week ago
parent
commit
feaf4c5b2e
  1. 4
      src/X1.WebSocket/Handlers/ProtocolMessageHandler.cs
  2. 11
      src/X1.WebSocket/Models/MessageTransferProtocolLog.cs
  3. 6
      src/X1.WebSocket/Models/ProtocolMessage.cs

4
src/X1.WebSocket/Handlers/ProtocolMessageHandler.cs

@ -96,7 +96,7 @@ namespace CellularManagement.WebSocket.Handlers
/// 处理协议日志数组 /// 处理协议日志数组
/// </summary> /// </summary>
/// <param name="protocolLogs">协议日志数组</param> /// <param name="protocolLogs">协议日志数组</param>
private void ProcessProtocolLogs(TransferProtocolLog[] protocolLogs) private void ProcessProtocolLogs(MessageTransferProtocolLog[] protocolLogs)
{ {
var processedCount = 0; var processedCount = 0;
var errorCount = 0; var errorCount = 0;
@ -130,7 +130,7 @@ namespace CellularManagement.WebSocket.Handlers
/// 处理单个协议日志 /// 处理单个协议日志
/// </summary> /// </summary>
/// <param name="log">协议日志</param> /// <param name="log">协议日志</param>
private void ProcessSingleProtocolLog(TransferProtocolLog log) private void ProcessSingleProtocolLog(MessageTransferProtocolLog log)
{ {
var logInfo = new var logInfo = new
{ {

11
src/X1.WebSocket/Models/TransferProtocolLog.cs → src/X1.WebSocket/Models/MessageTransferProtocolLog.cs

@ -6,7 +6,12 @@ using System.Threading.Tasks;
namespace X1.WebSocket.Models namespace X1.WebSocket.Models
{ {
public class TransferProtocolLog /// <summary>
/// 消息传输协议日志模型
/// 用于在WebSocket传输层中传输协议日志数据
/// 与CoreAgent.ProtocolClient中的TransferProtocolLog区分开
/// </summary>
public class MessageTransferProtocolLog
{ {
/// <summary> /// <summary>
/// 主键ID /// 主键ID
@ -16,7 +21,7 @@ namespace X1.WebSocket.Models
/// <summary> /// <summary>
/// 协议层类型 /// 协议层类型
/// </summary> /// </summary>
public ProtocolLayer LayerType { get; set; } public string LayerType { get; set; } = string.Empty;
/// <summary> /// <summary>
/// 消息详情集合(JSON格式存储) /// 消息详情集合(JSON格式存储)
@ -89,5 +94,7 @@ namespace X1.WebSocket.Models
get => TimeSpan.FromMilliseconds(TimeMs); get => TimeSpan.FromMilliseconds(TimeMs);
set => TimeMs = (long)value.TotalMilliseconds; set => TimeMs = (long)value.TotalMilliseconds;
} }
} }
} }

6
src/X1.WebSocket/Models/ProtocolMessage.cs

@ -29,7 +29,7 @@ namespace CellularManagement.WebSocket.Models
/// 初始化协议消息的新实例 /// 初始化协议消息的新实例
/// </summary> /// </summary>
/// <param name="messages">协议日志消息数组</param> /// <param name="messages">协议日志消息数组</param>
public ProtocolMessage(TransferProtocolLog[] messages) public ProtocolMessage(MessageTransferProtocolLog[] messages)
{ {
Payload = new ProtocolPayload(messages); Payload = new ProtocolPayload(messages);
} }
@ -45,13 +45,13 @@ namespace CellularManagement.WebSocket.Models
/// 协议日志消息数组 /// 协议日志消息数组
/// 存储要传输的协议日志数据 /// 存储要传输的协议日志数据
/// </summary> /// </summary>
public TransferProtocolLog[] Message { get; set; } = Array.Empty<TransferProtocolLog>(); public MessageTransferProtocolLog[] Message { get; set; } = Array.Empty<MessageTransferProtocolLog>();
/// <summary> /// <summary>
/// 初始化协议载荷的新实例 /// 初始化协议载荷的新实例
/// </summary> /// </summary>
/// <param name="messages">协议日志消息数组</param> /// <param name="messages">协议日志消息数组</param>
public ProtocolPayload(TransferProtocolLog[] messages) public ProtocolPayload(MessageTransferProtocolLog[] messages)
{ {
Message = messages; Message = messages;
} }

Loading…
Cancel
Save