From 41ca2b65f055b9c7b8f3ce68418423bac15c8e46 Mon Sep 17 00:00:00 2001
From: hwh <332078369@qq.com>
Date: 星期二, 27 八月 2024 17:00:45 +0800
Subject: [PATCH] plc基础信息优化;堆垛机出库逻辑

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

diff --git a/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs b/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs
index ee09096..0eaf3a5 100644
--- a/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs
+++ b/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs
@@ -1,4 +1,5 @@
 锘縰sing Admin.NET.Core.Service;
+using Furion.Logging;
 
 namespace WCS.Application;
 public static class PLCTaskAction
@@ -7,10 +8,10 @@
 
     private static List<WcsPlc> listPlc;
     private static List<WcsDevice> listPlcDevice;
-    private static List<WcsStation> listPlcStation;
+    private static List<WcsPosition> listPlcStation;
 
     private static List<PLCUtil> listPlcUtil = new List<PLCUtil>();
-    private static CancellationTokenSource cts = new CancellationTokenSource();//鍙栨秷绾跨▼鏍囪瘑
+    private static CancellationTokenSource cts;//鍙栨秷绾跨▼鏍囪瘑
 
     public static event EventHandler DeviceValueChangeEvent;
     static PLCTaskAction()
@@ -20,7 +21,7 @@
 
         listPlc = _db.Queryable<WcsPlc>().ToList();
         listPlcDevice = _db.Queryable<WcsDevice>().ToList();
-        listPlcStation = _db.Queryable<WcsStation>().ToList();
+        listPlcStation = _db.Queryable<WcsPosition>().ToList();
     }
     /// <summary>
     /// 鍒濆鍖朠LC杩炴帴
@@ -32,7 +33,7 @@
             cts.Cancel();
             listPlc = _db.Queryable<WcsPlc>().ToList();
             listPlcDevice = _db.Queryable<WcsDevice>().ToList();
-            listPlcStation = _db.Queryable<WcsStation>().ToList();
+            listPlcStation = _db.Queryable<WcsPosition>().ToList();
             //绛夊緟鍑犵閽燂紝鎶婂凡鏈夌嚎绋嬪彇娑堟帀鍐嶈繛鎺�
             Thread.Sleep(5000);
             foreach (var modPlcUtil in listPlcUtil)
@@ -80,37 +81,41 @@
                         }
                         var listDevice = listPlcDevice.Where(s => s.PlcId == _modplc.Id).ToList();
                         //寰幆璇昏澶�
-                        foreach (var modDevice in listDevice)
+                        foreach (var modDevice in listDevice.Where(s => s.Level == DeviceLevelEnum.DB))
                         {
-                            var b = modPlcUtil.Connected();
-                            var (result, value) = modPlcUtil.GetPlcDBValue(modDevice.PosType.Value, modDevice.DbNumber, modDevice.PlcPos);
-                            var c = modPlcUtil.Connected();
+                            var (result, value) = modPlcUtil.GetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.PlcPos);
                             if (result.IsSucceed)
                             {
-                                if (value != 0)
-                                {
-                                    var dto = modDevice.Adapt<WcsDeviceDto>();
-                                    dto.Value = value;
-                                    dto.Type = _modplc.Type;
-                                    dto.PLCUtil = modPlcUtil;
-                                    dto.listStation = listPlcStation.Where(s => s.DeviceId == modDevice.Id).ToList();
-                                    //杩欓噷瑙﹀彂鍊煎彉鏇翠簨浠�
-                                    DeviceValueChangeEvent?.Invoke(dto, EventArgs.Empty);
-                                }
+                                //鏃犳祦绋嬭烦鍑�
+                                if (value == 0)
+                                    continue;
+                                var dto = modDevice.Adapt<WcsDeviceDto>();
+                                dto.Value = value;
+                                dto.Type = _modplc.Type;
+                                dto.PLCUtil = modPlcUtil;
+                                dto.listStation = listPlcStation.Where(s => s.DeviceId == modDevice.Id).ToList();
+                                dto.listDevice = listDevice.Where(s => s.StationNum == modDevice.StationNum).ToList();
+                                //杩欓噷瑙﹀彂鍊煎彉鏇翠簨浠�
+                                DeviceValueChangeEvent?.Invoke(dto, EventArgs.Empty);
                             }
                             else
                             {
                                 //鍒犻櫎褰撳墠杩炴帴 涓嬩竴娆″惊鐜噸鏂拌繛鎺�
+                                Console.WriteLine("杩炴帴鏂紑...");
                                 modPlcUtil.Close();
                                 listPlcUtil.Remove(modPlcUtil);
                             }
                         }
 
-                        Thread.Sleep(100);
+                        Thread.Sleep(3000);
+                    }
+                    catch (OperationCanceledException)
+                    {
+                        Console.WriteLine("涓绾跨▼");
                     }
                     catch (Exception ex)
                     {
-
+                        Log.Error(ex.Message, ex);
                     }
                 }
             }, cts.Token);

--
Gitblit v1.8.0