From 48d66a079c307356997fb400d27907ff6d363b7b Mon Sep 17 00:00:00 2001
From: liudl <673013083@qq.com>
Date: 星期一, 20 一月 2025 08:35:37 +0800
Subject: [PATCH] 修改2楼分拣和1楼拆垛时获取拆垛信息接口

---
 Admin.NET/WCS.Application/PLC/PLCTaskAction.cs |   76 +++++++++++++++++++++++++------------
 1 files changed, 51 insertions(+), 25 deletions(-)

diff --git a/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs b/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs
index f2a77a3..311e7ce 100644
--- a/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs
+++ b/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs
@@ -2,7 +2,9 @@
 using DocumentFormat.OpenXml.Drawing;
 using Furion.Logging;
 using Microsoft.AspNetCore.SignalR;
+using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
 using System;
+//using WCS.Application.Util;
 
 namespace WCS.Application;
 public static class PLCTaskAction
@@ -15,6 +17,12 @@
     public static bool boRefresh = false;
     //婕旂ず妯″紡
     public static bool boDemo = false;
+    //婊氱瓛鍙嶈浆
+    public static bool boDrumReversal = false;
+    //鍑哄簱閿佸畾
+    public static bool boOutLock = false;
+    //鍏ュ簱閿佸畾
+    public static bool boEnterLock = false;
 
     public static List<PlcPositionInfo> listPositionInfo = new List<PlcPositionInfo>();
 
@@ -52,15 +60,19 @@
         boOffline = _sysConfigService.GetConfigValue<bool>("sys_Offline").Result;
         boRefresh = _sysConfigService.GetConfigValue<bool>("sys_Refresh").Result;
         boDemo = _sysConfigService.GetConfigValue<bool>("sys_demo").Result;
+        boDrumReversal = _sysConfigService.GetConfigValue<bool>("sys_DrumReversal").Result;
+        boOutLock = _sysConfigService.GetConfigValue<bool>("sys_BoOutLock").Result;
+        boEnterLock = _sysConfigService.GetConfigValue<bool>("sys_BoEnterLock").Result;
     }
     /// <summary>
     /// 鍒濆鍖朠LC杩炴帴
     /// </summary>
     public static void Init()
     {
+        // var strMsg = new HttpService().RequestPackWcs("LN000001");
         cts.Cancel();
         listPlc = _db.Queryable<WcsPlc>()
-            .Where(s => s.Type == PLCTypeEnum.StackingMachine || s.Type == PLCTypeEnum.ConveyorLine || s.Type == PLCTypeEnum.BoxConveyorLine)
+            .Where(s => s.Type == PLCTypeEnum.StackingMachine || s.Type == PLCTypeEnum.ConveyorLine || s.Type == PLCTypeEnum.BoxConveyorLine || s.Type == PLCTypeEnum.StackingRobot)
             .Where(s => s.Enable == YesNoEnum.Y)
             .ToList();
         listPlcDevice = _db.Queryable<WcsDevice>().ToList();
@@ -130,7 +142,7 @@
                         }
                         if (!modPlcUtil.Connected)
                         {
-                            Thread.Sleep(10000);
+                            Thread.Sleep(1000);
                             modPlcUtil.Open();
                             continue;
                         }
@@ -150,7 +162,7 @@
                             {
                                 //Console.WriteLine($"{modPlc.IP}璇诲彇{modDevice.DbNumber}.{modDevice.PlcPos}鐨勫�间负锛歿value}");
                                 //鏃犳祦绋嬭烦鍑�
-                                if (value == 0)
+                                if (value == 0)// && modPlc.Type!= PLCTypeEnum.BoxConveyorLine
                                     continue;
                                 var dto = modDevice.Adapt<WcsDeviceDto>();
                                 dto.Value = value;
@@ -171,7 +183,7 @@
                             }
                         }
 
-                        Thread.Sleep(10000);
+                        Thread.Sleep(1000);
                     }
                     catch (OperationCanceledException)
                     {
@@ -234,7 +246,7 @@
                             HubUtil.PublicPlcConn(modPlc);
                         }
                     }
-                    Thread.Sleep(1000);
+                    Thread.Sleep(10000);
                 }
             }
             catch (OperationCanceledException)
@@ -284,26 +296,18 @@
                     {
                         //鎶ヨ鐐逛綅
                         var listAlarm = listAlarmInfo.Where(s => s.PlcIP == modUtil.PlcIP.ToString()).ToList();
-                        //Console.WriteLine("鎶ヨ鐐逛綅鏁帮細" + listAlarm.Count);
                         var listaddress = new Dictionary<string, PLCDataTypeEnum>();
                         foreach (var modAlarm in listAlarm)
                         {
                             listaddress.Add(modAlarm.AlarmCode, PLCDataTypeEnum.Bit);
                         }
-                        //Console.WriteLine($"璇诲彇鐐逛綅{listaddress.Count}涓�");
                         var result = modUtil.GetPlcBatchDBValue(listaddress);
-                        //Console.WriteLine("err" + result.Err);
                         var listPulish = new List<WcsAlarmInfo>();
-                        //娴嬭瘯鎶ヨ
-                        //foreach (var modAlarm in listAlarm)
-                        //{
-                        //    result.Value.Add(modAlarm.AlarmCode, true);
-                        //}
                         foreach (var item in result.Value)
                         {
                             var value = Convert.ToBoolean(item.Value);
-                            //Console.WriteLine(item.Key + "+" + value);
                             var modAlarm = listAlarm.FirstOrDefault(s => s.AlarmCode == item.Key);
+                            var stationNum = modAlarm.StationNum;
                             if (value && modAlarm.Status == YesNoEnum.N)
                             {
                                 //淇敼鎶ヨ鐘舵�佸悓鏃惰褰曟姤璀︽棩蹇�
@@ -312,7 +316,7 @@
                                 listPulish.Add(modAlarm);
                             }
                             //鍙栨秷鎶ヨ
-                            else if (value && modAlarm.Status == YesNoEnum.Y)
+                            else if (!value && modAlarm.Status == YesNoEnum.Y)
                             {
                                 modAlarm.AlarmTime = null;
                                 modAlarm.Status = YesNoEnum.N;
@@ -329,7 +333,8 @@
                                 modLog.Id = 0;
                                 listLog.Add(modLog);
                             }
-                            _db.Insertable(listLog).ExecuteCommand();
+                            if (listLog.Count >= 0)
+                                _db.Insertable(listLog).ExecuteCommand();
                             HubUtil.PublicAlarm(listPulish);
                         }
                     }
@@ -370,8 +375,10 @@
                     {
                         if (modPlcUtil == null)
                             continue;
+                        var plcIp = modPlcUtil.PlcIP;
                         var listDevice = listPlcDevice.Where(s => s.PlcId == modPlcUtil.PlcId && s.DeviceType == DeviceTypeEnum.Show).ToList();
-                        var modPlc = listPlc.FirstOrDefault(s => s.Id == modPlcUtil.PlcId); var listaddress = new Dictionary<string, PLCDataTypeEnum>();
+                        var modPlc = listPlc.FirstOrDefault(s => s.Id == modPlcUtil.PlcId);
+                        var listaddress = new Dictionary<string, PLCDataTypeEnum>();
                         foreach (var modDevice in listDevice)
                         {
                             listaddress.Add(modDevice.DbNumber + "." + modDevice.PlcPos, modDevice.PosType);
@@ -397,14 +404,24 @@
                                     {
                                         var value = Convert.ToInt32(item.Value);
                                         var height = Math.Round(value / 790000d * 200).ToInt();
-                                        if (modDevice.BoxHeight != height)
+                                        var modPosition = listPlcPosition.FirstOrDefault(s => s.DeviceId == modDevice.Id && s.Text == "鐩殑宸ヤ綅");
+                                        string EndLocat = "";
+                                        if (modPosition != null)
                                         {
+                                            var (result2, value2) = modPlcUtil.GetPlcDBValue(modPosition.PosType, modDevice.DbNumber, modPosition.PlcPos);
+                                            if (result2.IsSucceed)
+                                                EndLocat = Convert.ToString(value2);
+                                        }
+                                        if (modDevice.BoxHeight != height || modDevice.EndLocat != EndLocat)
+                                        {
+                                            modDevice.EndLocat = EndLocat;
                                             modDevice.BoxHeight = Math.Round(value / 790000d * 200).ToInt();
                                             var modInfo = new PlcPositionInfo()
                                             {
                                                 Type = modPlc.Type,
                                                 StationNum = modDevice.StationNum,
-                                                BoxHeight = modDevice.BoxHeight
+                                                BoxHeight = modDevice.BoxHeight,
+                                                EndLocat = EndLocat,
                                             };
                                             HubUtil.PublicPosition(modInfo);
                                             UpdatePosition(modInfo);
@@ -413,12 +430,21 @@
                                     break;
                                 case PLCTypeEnum.ConveyorLine:
                                     {
-                                        var value = Convert.ToBoolean(item.Value);
-                                        if (value != modDevice.BoHaveItem)
+                                        var bl = false;
+                                        int value = Convert.ToInt32(item.Value);
+                                        if (value <= 30)
                                         {
-                                            modDevice.BoHaveItem = value;
-                                            //涓嬪彂鐘舵��
-                                            var modInfo = new PlcPositionInfo() { Type = modPlc.Type, StationNum = modDevice.StationNum, BoHaveItem = value };
+                                            bl = false;
+                                        }
+                                        else
+                                        {
+                                            bl = true;
+                                        }
+
+                                        if (bl != modDevice.BoHaveItem)
+                                        {
+                                            modDevice.BoHaveItem = bl;
+                                            var modInfo = new PlcPositionInfo() { Type = modPlc.Type, StationNum = modDevice.StationNum.PadLeft(3, '0'), BoHaveItem = bl };
                                             HubUtil.PublicPosition(modInfo);
                                             UpdatePosition(modInfo);
                                         }
@@ -429,7 +455,7 @@
                             }
                         }
                     }
-                    Thread.Sleep(300);
+                    Thread.Sleep(3000);
                 }
                 catch (Exception ex)
                 {

--
Gitblit v1.8.0