From d5f506ef2f7a9e8feb73e62f57086b5458ffbcbd Mon Sep 17 00:00:00 2001
From: hwh <332078369@qq.com>
Date: 星期三, 18 九月 2024 13:26:31 +0800
Subject: [PATCH] 自刷新功能

---
 Admin.NET/WCS.Application/PLC/PLCTaskAction.cs |   13 ++++++-------
 1 files changed, 6 insertions(+), 7 deletions(-)

diff --git a/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs b/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs
index 2137784..f2a77a3 100644
--- a/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs
+++ b/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs
@@ -20,7 +20,6 @@
 
     private static readonly ISqlSugarClient _db = SqlSugarSetup.ITenant.GetConnectionScope(SqlSugarConst.MainConfigId);
     private static readonly SysCacheService sysCacheService = App.GetRequiredService<SysCacheService>();
-    private static readonly IHubContext<PlcHub, IPlcHub> _plcHubContext = App.GetService<IHubContext<PlcHub, IPlcHub>>();
     private static readonly SysConfigService _sysConfigService = App.GetService<SysConfigService>();
 
     private static List<WcsPlc> listPlc = new List<WcsPlc>();
@@ -79,7 +78,7 @@
             var plc = new PLCUtil(modPlc);
             listPlcUtil.Add(plc);
         }
-        _plcHubContext.Clients.All.UpdateService(new PLCServiceModel()
+        HubUtil.UpdateService(new PLCServiceModel()
         {
             BoRunningState = boRunningState,
             BoOffline = boOffline,
@@ -225,14 +224,14 @@
                             {
                                 //杩炴帴鐘舵�佸彉鏇� 閫氱煡鍓嶇
                                 Console.WriteLine($"閫氱煡鍓嶇鍙樻洿{modPlc.Text} {modPlc.IsConn}");
-                                _plcHubContext.Clients.All.PublicPlcConn(modPlc);
+                                HubUtil.PublicPlcConn(modPlc);
                             }
                             sysCacheService.Set("PLCCONN:" + modPlc.Id, modPlc);
                         }
                         else
                         {
                             sysCacheService.Set("PLCCONN:" + modPlc.Id, modPlc);
-                            _plcHubContext.Clients.All.PublicPlcConn(modPlc);
+                            HubUtil.PublicPlcConn(modPlc);
                         }
                     }
                     Thread.Sleep(1000);
@@ -331,7 +330,7 @@
                                 listLog.Add(modLog);
                             }
                             _db.Insertable(listLog).ExecuteCommand();
-                            _plcHubContext.Clients.All.PublicAlarm(listPulish);
+                            HubUtil.PublicAlarm(listPulish);
                         }
                     }
                     catch (Exception ex)
@@ -407,7 +406,7 @@
                                                 StationNum = modDevice.StationNum,
                                                 BoxHeight = modDevice.BoxHeight
                                             };
-                                            _plcHubContext.Clients.All.PublicPosition(modInfo);
+                                            HubUtil.PublicPosition(modInfo);
                                             UpdatePosition(modInfo);
                                         }
                                     }
@@ -420,7 +419,7 @@
                                             modDevice.BoHaveItem = value;
                                             //涓嬪彂鐘舵��
                                             var modInfo = new PlcPositionInfo() { Type = modPlc.Type, StationNum = modDevice.StationNum, BoHaveItem = value };
-                                            _plcHubContext.Clients.All.PublicPosition(modInfo);
+                                            HubUtil.PublicPosition(modInfo);
                                             UpdatePosition(modInfo);
                                         }
                                     }

--
Gitblit v1.8.0