提交代码

2024-04-25 09:48:38 +08:00
parent aaf7c17562
commit a1199028b3
22 changed files with 861 additions and 196 deletions
--- a/WCS.BLL/Manager/TCPClientManager.cs
+++ b/WCS.BLL/Manager/TCPClientManager.cs
@ -0,0 +1,108 @@
+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 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>().Select(t => t.ClientIp).ToList();
+            foreach (var ip in ips)
+            {
+                var tcpCleint = new TCPClient(ip, "192.168.0.154: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)
+                        {
+                            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 = (data[TcpCleint.PreFixLength + 0] << 8) + data[TcpCleint.PreFixLength + 1];
+                            var lightNumber = Convert.ToInt32(data[TcpCleint.PreFixLength + 3]);
+
+                            //报警灯
+                            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(data, boardId, lightNumber);
+                            }
+                            //货架类型协议返回
+                            else
+                            {
+                                var shelf = ShelfManager.Shelves
+                                                              .Where(t => t.ClientIp == clientIpHost)
+                                                              .Where(t => t.ModuleIds.Contains(boardId))
+                                                              .FirstOrDefault();
+                                var smartShelf = shelf as SmartShelf;
+                                smartShelf?.ProtocolProcess(data, boardId, lightNumber);
+
+                            }
+
+                            //协议处理 判断功能位
+                            //switch (dataTemp[TcpCleint.PreFixLength + 2])
+                            //{
+                            //    case 0x20://进入入库模式信号
+                            //        //GoInInstoreProcess(dataTemp, boardId, lightNumber);
+                            //        break;
+                            //    case 0x03://正常入库信号
+                            //        //InStoreReturnProcess(dataTemp);
+                            //        break;
+                            //    default:
+                            //        ;
+                            //        break;
+                            //}
+                        }
+                    }
+                    return EasyTask.CompletedTask;
+                };
+
+                TCPClients.Add(tcpCleint);
+                tcpCleint.Connect();
+            }
+        }
+
+        public static TCPClient GetTCPClientByIPHost(string IpHost)
+        {
+            return TCPClients.Where(t => t.RemoteIPHost == IpHost).FirstOrDefault();
+        }
+    }
+}