319 lines
13 KiB
C#
319 lines
13 KiB
C#
using System;
|
|
using System.Collections.Concurrent;
|
|
using System.ComponentModel.Design;
|
|
using System.Text;
|
|
using TouchSocket.Core;
|
|
using TouchSocket.Sockets;
|
|
using WCS.BLL.Tool;
|
|
|
|
|
|
namespace WCS.BLL
|
|
{
|
|
/// <summary>
|
|
/// 对TouchSocket的封装 主要完成TCP的连接 状态更新 发送接收通信
|
|
/// </summary>
|
|
public class TCPClient
|
|
{
|
|
public string RemoteIPHost { get; set; } = "127.0.0.1:20002";
|
|
|
|
public string BindIPHost { get; set; } = "127.0.0.1:20003";
|
|
|
|
public string ShelfTypeName { get; set; }
|
|
public bool IsOnline { get; set; } = false;
|
|
|
|
//第一次连接是否已连接
|
|
public bool IsFirstConnected { get; set; } = false;
|
|
|
|
//can模块协议前缀
|
|
public readonly byte[] Prefix = new byte[] { 0x08, 0x00, 0x00 };
|
|
//can模块协议前缀长度
|
|
public readonly int PreFixLength = 3;
|
|
//协议数据部分长度
|
|
public readonly int DataLength = 10;
|
|
|
|
public ConcurrentDictionary<int, MessageDto> MessageList { get; set; } = new ConcurrentDictionary<int, MessageDto>();
|
|
|
|
public TcpClient tcpClient { get; set; }
|
|
|
|
public object receivdLockObject = new object();
|
|
public object sendLockObject = new object();
|
|
|
|
public bool Connect()
|
|
{
|
|
try
|
|
{
|
|
tcpClient.Connect();//调用连接，当连接不成功时，会抛出异常。
|
|
return true;
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
//连接失败
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 初始化配置连接
|
|
/// </summary>
|
|
/// <param name="remoteIPHost"></param>
|
|
public TCPClient(string remoteIPHost, string bindIPHost, string shelfTypeName)
|
|
{
|
|
try
|
|
{
|
|
RemoteIPHost = remoteIPHost;
|
|
BindIPHost = bindIPHost;
|
|
ShelfTypeName = shelfTypeName;
|
|
|
|
tcpClient = new TcpClient();
|
|
|
|
if (string.IsNullOrEmpty(BindIPHost))
|
|
{
|
|
//载入配置
|
|
tcpClient.Setup(new TouchSocketConfig()
|
|
.SetRemoteIPHost(new IPHost(RemoteIPHost))
|
|
//.SetBindIPHost(BindIPHost)
|
|
.ConfigurePlugins(a =>
|
|
{
|
|
//配置断线重连
|
|
a.UseReconnection(-1, true, 1000);
|
|
a.Add<HeartbeatAndReceivePlugin>();
|
|
})
|
|
.ConfigureContainer(a =>
|
|
{
|
|
//添加控制台日志注入
|
|
a.AddConsoleLogger();
|
|
}));
|
|
}
|
|
else
|
|
{
|
|
//载入配置
|
|
tcpClient.Setup(new TouchSocketConfig()
|
|
.SetRemoteIPHost(new IPHost(RemoteIPHost))
|
|
.SetBindIPHost(new IPHost(BindIPHost))
|
|
.ConfigurePlugins(a =>
|
|
{
|
|
//配置断线重连
|
|
a.UseReconnection(-1, true, 1000);
|
|
a.Add<HeartbeatAndReceivePlugin>();
|
|
})
|
|
.ConfigureContainer(a =>
|
|
{
|
|
//添加控制台日志注入
|
|
a.AddConsoleLogger();
|
|
}));
|
|
}
|
|
|
|
//添加接收事件 匹配已发送的指令
|
|
tcpClient.Received += (client, e) =>
|
|
{
|
|
var data = e.ByteBlock.Buffer.Take((int)e.ByteBlock.Length).ToArray();
|
|
Task.Run(() =>
|
|
{
|
|
Logs.Write($"【校验发送接收 开始】{ShelfTypeName}" + BitConverter.ToString(data), LogsType.InstructionResend);
|
|
if (ShelfTypeName == "信息化货架")
|
|
{
|
|
//协议拆包
|
|
var len = data.Length;
|
|
//灯控制统一返回的是 FF-00-00-0A-00-02-D7-B5
|
|
if (len == 8)
|
|
{
|
|
if (data[4] == 0x00 && data[0] == 0xFF && data[1] == 0x00 && (data[5] == 0x01 || data[5] == 0x02))
|
|
{
|
|
//查询当前板子是否有待验证的指令
|
|
var message = new MessageDto();
|
|
var firstMessage = MessageList.Select(t => new { Id = t.Key, Value = t.Value })
|
|
.OrderBy(t => t.Value.CreateTime)
|
|
.FirstOrDefault();
|
|
if (firstMessage != null)
|
|
{
|
|
MessageList.TryRemove(firstMessage.Id, out message);
|
|
Logs.Write($"【信息化货架】以下指令已不重发：{BitConverter.ToString(firstMessage.Value.Message)}", LogsType.InstructionResend);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else if (ShelfTypeName == "液晶货架")
|
|
{
|
|
Logs.Write($"【液晶货架】接收到指令{BitConverter.ToString(data)}", LogsType.InstructionResend);
|
|
}
|
|
//智能货架
|
|
else
|
|
{
|
|
var len = data.Length;
|
|
for (int index = 0; index < data.Length - PreFixLength; index++)
|
|
{
|
|
//协议拆包 通过前缀校验是否为完整数据包
|
|
var prefixInData = data.Skip(index).Take(PreFixLength);
|
|
var isEqual = prefixInData.SequenceEqual(Prefix);
|
|
if (isEqual)
|
|
{
|
|
var dataTemp = data.Skip(index).Take(PreFixLength + DataLength).ToArray();
|
|
if (dataTemp.Length < PreFixLength + DataLength)//拆包后不满足一条指令的长度
|
|
{
|
|
continue;
|
|
}
|
|
//获取返回指令的板子ID
|
|
var boardId = (dataTemp[PreFixLength + 0] << 8) + dataTemp[PreFixLength + 1];
|
|
//查询当前板子是否有待验证的指令
|
|
var message = new MessageDto();
|
|
MessageList.TryGetValue(boardId, out message);
|
|
//功能位校验 功能位相同视为已响应指令 删除对应的指令
|
|
if (message?.Message[PreFixLength + 2] == dataTemp[PreFixLength + 2])
|
|
{
|
|
MessageList.TryRemove(boardId, out message);
|
|
}
|
|
index += (PreFixLength + DataLength - 2);//每次循环index会+1 所以这里-1
|
|
}
|
|
}
|
|
}
|
|
Logs.Write($"【校验发送接收 结束】{ShelfTypeName}" + BitConverter.ToString(data), LogsType.InstructionResend);
|
|
});
|
|
return null;
|
|
};
|
|
|
|
tcpClient.Connected += (client, e) =>
|
|
{
|
|
this.IsOnline = true;
|
|
return EasyTask.CompletedTask;
|
|
};
|
|
|
|
tcpClient.Disconnected += (client, e) =>
|
|
{
|
|
this.IsOnline = false;
|
|
return EasyTask.CompletedTask;
|
|
};
|
|
|
|
//配置数据重发机制
|
|
Task.Run(async () =>
|
|
{
|
|
while (true)
|
|
{
|
|
try
|
|
{
|
|
//TODO如果指令已发两次 则取消重发
|
|
await Task.Delay(100);
|
|
if (MessageList.Count > 0)
|
|
{
|
|
var failedMessage = MessageList.Where(t => t.Value.LastSendTime < DateTime.Now.AddSeconds(-1))
|
|
.ToList();
|
|
foreach (var message in failedMessage)
|
|
{
|
|
Logs.Write("【指令重发】" + BitConverter.ToString(message.Value.Message) + "指令超时1s未响应", LogsType.InstructionResend);
|
|
}
|
|
MessageList.RemoveWhen(t => t.Value.SendTimes >= 2);
|
|
foreach (var item in MessageList)
|
|
{
|
|
if (item.Value.LastSendTime < DateTime.Now.AddSeconds(-1))
|
|
{
|
|
|
|
Send(item.Value.Message);
|
|
item.Value.SendTimes++;
|
|
item.Value.LastSendTime = DateTime.Now;
|
|
Logs.Write("【指令重发】" + BitConverter.ToString(item.Value.Message) + "已进行重发", LogsType.InstructionResend);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
catch
|
|
{
|
|
}
|
|
}
|
|
});
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
}
|
|
}
|
|
|
|
public void ReConnectAsync()
|
|
{
|
|
tcpClient.TryConnectAsync();
|
|
}
|
|
|
|
|
|
public void Send(byte[] message, bool IsReSend = false)
|
|
{
|
|
try
|
|
{
|
|
var boardId = (message[3] << 8) + message[4];
|
|
|
|
if (boardId != 2047 && IsReSend == false)
|
|
{
|
|
MessageList.TryAdd(boardId, new MessageDto()
|
|
{
|
|
ID = boardId,
|
|
Message = message,
|
|
SendTimes = 1
|
|
});
|
|
}
|
|
|
|
lock (sendLockObject)
|
|
{
|
|
tcpClient.Send(message);
|
|
|
|
var clientIpHost = tcpClient.IP + ":" + tcpClient.Port;
|
|
Logs.Write($"【发送{clientIpHost}】{BitConverter.ToString(message)}", LogsType.Instructions);
|
|
|
|
//发送自带15ms间隔
|
|
Thread.Sleep(18);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Logs.Write("【发送指令时发生异常】" + ex.Message, LogsType.Instructions);
|
|
//因异常断连时（网线已经被断了） 手动重连一次
|
|
if (ex is NotConnectedException)
|
|
{
|
|
Task.Run(() =>
|
|
{
|
|
ReConnectAsync();
|
|
});
|
|
}
|
|
throw ex;
|
|
}
|
|
}
|
|
|
|
//生成协议明细
|
|
public byte[] GenerateMessage(int boardId, byte[] data)
|
|
{
|
|
var message = new byte[Prefix.Length + 2 + data.Length];
|
|
var boardIdData = BitConverter.GetBytes(unchecked((short)boardId));
|
|
// 检查是否需要交换字节
|
|
if (BitConverter.IsLittleEndian)
|
|
{
|
|
// 如果是小端序系统，则交换字节
|
|
byte temp = boardIdData[0];
|
|
boardIdData[0] = boardIdData[1];
|
|
boardIdData[1] = temp;
|
|
}
|
|
|
|
Buffer.BlockCopy(Prefix, 0, message, 0, Prefix.Length);
|
|
Buffer.BlockCopy(boardIdData, 0, message, Prefix.Length, boardIdData.Length);
|
|
Buffer.BlockCopy(data, 0, message, Prefix.Length + boardIdData.Length, data.Length);
|
|
return message;
|
|
}
|
|
|
|
}
|
|
|
|
//发送指令的记录
|
|
public class MessageDto
|
|
{
|
|
public int ID { get; set; }
|
|
/// <summary>
|
|
/// 最后一次发送时间
|
|
/// </summary>
|
|
public DateTime LastSendTime { get; set; } = DateTime.Now;
|
|
|
|
public DateTime CreateTime { get; set; } = DateTime.Now;
|
|
/// <summary>
|
|
/// 发送内容
|
|
/// </summary>
|
|
public byte[] Message { get; set; }
|
|
/// <summary>
|
|
/// 发送次数
|
|
/// </summary>
|
|
public int SendTimes { get; set; } = 0;//第几次发送
|
|
}
|
|
|
|
}
|