117 lines
5.4 KiB
C#
117 lines
5.4 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Security.Cryptography.X509Certificates;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
using TouchSocket.Core;
|
||
using TouchSocket.Sockets;
|
||
using WCS.BLL.HardWare;
|
||
using WCS.DAL.Db;
|
||
using WCS.DAL.DbModels;
|
||
|
||
namespace WCS.BLL.Manager
|
||
{
|
||
public static class TCPClientManager
|
||
{
|
||
/// <summary>
|
||
/// 货架类型的TCP连接管理
|
||
/// </summary>
|
||
public static List<TCPClient> TCPClients = new List<TCPClient>();
|
||
public static void InitTcpClient()
|
||
{
|
||
var ips = DbHelp.db.Queryable<ShelfInfo>().Where(t => t.ShelfCode.Contains("C")).Select(t => t.ClientIp).ToList();
|
||
foreach (var ip in ips)
|
||
{
|
||
var tcpCleint = new TCPClient(ip, "192.168.9.183:20003");
|
||
|
||
|
||
//var tcpCleint = new TCPClient("192.168.0.183:20002", "192.168.0.183:20003");
|
||
//配置断线重连
|
||
|
||
tcpCleint.tcpClient.Received += (client, e) =>
|
||
{
|
||
|
||
var clientIpHost = client.IP + ":" + client.Port;
|
||
var TcpCleint = TCPClientManager.GetTCPClientByIPHost(clientIpHost);
|
||
if (TcpCleint == null)
|
||
{
|
||
//TO DO
|
||
return EasyTask.CompletedTask;
|
||
}
|
||
|
||
var data = e.ByteBlock.Buffer.Take((int)e.ByteBlock.Length).ToArray();
|
||
e.ByteBlock.Clear();
|
||
var len = data.Length;
|
||
for (int index = 0; index < data.Length - TcpCleint.PreFixLength; index++)
|
||
{
|
||
//协议拆包 通过前缀校验是否为完整数据包
|
||
var prefixInData = data.Skip(index).Take(TcpCleint.PreFixLength);
|
||
var isEqual = prefixInData.SequenceEqual(TcpCleint.Prefix);
|
||
if (isEqual)
|
||
{
|
||
Logs.Write("协议处理1！");
|
||
var dataTemp = data.Skip(index).Take(TcpCleint.PreFixLength + TcpCleint.DataLength).ToArray();
|
||
if (dataTemp.Length < TcpCleint.PreFixLength + TcpCleint.DataLength)//拆包后不满足一条指令的长度
|
||
{
|
||
continue;
|
||
}
|
||
index += (TcpCleint.PreFixLength + TcpCleint.DataLength - 1);//每次循环index会+1 所以这里-1
|
||
//获取板子ID
|
||
var boardId = (dataTemp[TcpCleint.PreFixLength + 0] << 8) + dataTemp[TcpCleint.PreFixLength + 1];
|
||
var lightNumber = Convert.ToInt32(dataTemp[TcpCleint.PreFixLength + 3]);
|
||
|
||
Logs.Write("协议处理2！");
|
||
//报警灯
|
||
if (dataTemp[TcpCleint.PreFixLength + 2] == 0x20)
|
||
{
|
||
var shelf = ShelfManager.Shelves.Where(t => t.ClientIp == clientIpHost)
|
||
.Where(t => t.LightId == boardId)
|
||
.FirstOrDefault();
|
||
var smartShelf = shelf as SmartShelf;
|
||
smartShelf?.ProtocolProcess(dataTemp, boardId, lightNumber);
|
||
}
|
||
//!= 0x20 货架类型协议返回
|
||
else
|
||
{
|
||
Logs.Write("协议处理3！");
|
||
var shelf = ShelfManager.Shelves
|
||
.Where(t => t.ClientIp == clientIpHost)
|
||
.Where(t => t.ModuleIds.Contains(boardId))
|
||
.FirstOrDefault();
|
||
var smartShelf = shelf as SmartShelf;
|
||
smartShelf?.ProtocolProcess(dataTemp, boardId, lightNumber);
|
||
|
||
}
|
||
|
||
//协议处理 判断功能位
|
||
//switch (dataTemp[TcpCleint.PreFixLength + 2])
|
||
//{
|
||
// case 0x20://进入入库模式信号
|
||
// //GoInInstoreProcess(dataTemp, boardId, lightNumber);
|
||
// break;
|
||
// case 0x03://正常入库信号
|
||
// //InStoreReturnProcess(dataTemp);
|
||
// break;
|
||
// default:
|
||
// ;
|
||
// break;
|
||
//}
|
||
}
|
||
}
|
||
Logs.Write("协议处理完毕！");
|
||
return EasyTask.CompletedTask;
|
||
};
|
||
|
||
TCPClients.Add(tcpCleint);
|
||
tcpCleint.Connect();
|
||
}
|
||
}
|
||
|
||
public static TCPClient GetTCPClientByIPHost(string IpHost)
|
||
{
|
||
return TCPClients.Where(t => t.RemoteIPHost == IpHost).FirstOrDefault();
|
||
}
|
||
}
|
||
}
|