From dd973f741617e3bbf5ecf11747ff71960991549c Mon Sep 17 00:00:00 2001
From: bklLiudl <673013083@qq.com>
Date: 星期二, 15 十月 2024 10:21:19 +0800
Subject: [PATCH] Merge branch 'master' into liudl
---
Admin.NET/WCS.Application/Hub/HubUtil.cs | 102 +++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 102 insertions(+), 0 deletions(-)
diff --git a/Admin.NET/WCS.Application/Hub/HubUtil.cs b/Admin.NET/WCS.Application/Hub/HubUtil.cs
new file mode 100644
index 0000000..fadebde
--- /dev/null
+++ b/Admin.NET/WCS.Application/Hub/HubUtil.cs
@@ -0,0 +1,102 @@
+锘縰sing Microsoft.AspNetCore.SignalR;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using WCS.Application.Hub;
+using WCS.Application.Service.WcsDevice.Dto;
+
+namespace WCS.Application;
+public static class HubUtil
+{
+ private static readonly IHubContext<PlcHub, IPlcHub> _plcHubContext = App.GetService<IHubContext<PlcHub, IPlcHub>>();
+ private static readonly IHubContext<PlcDeviceHub, IPlcDeviceHub> _plcDeviceHubContext = App.GetService<IHubContext<PlcDeviceHub, IPlcDeviceHub>>();
+ private static readonly IHubContext<TaskLogHub, ITaskLogHub> _taskLogHubContext = App.GetService<IHubContext<TaskLogHub, ITaskLogHub>>();
+ private static readonly IHubContext<CheckTaskHub, ICheckTaskHub> _checkTaskHubContext = App.GetService<IHubContext<CheckTaskHub, ICheckTaskHub>>();
+
+ /// <summary>
+ /// 涓嬪彂PLC杩炴帴鐘舵��
+ /// </summary>
+ /// <param name="context"></param>
+ /// <returns></returns>
+ public static async Task PublicPlcConn(WcsPlc context)
+ {
+ if (PLCTaskAction.boRefresh)
+ await _plcHubContext.Clients.All.PublicPlcConn(context);
+ }
+
+ /// <summary>
+ /// 涓嬪彂鎶ヨ淇℃伅
+ /// </summary>
+ /// <param name="context"></param>
+ /// <returns></returns>
+ public static async Task PublicAlarm(List<WcsAlarmInfo> context)
+ {
+ if (PLCTaskAction.boRefresh)
+ await _plcHubContext.Clients.All.PublicAlarm(context);
+ }
+
+ /// <summary>
+ /// 淇敼鏈嶅姟鐘舵��
+ /// </summary>
+ /// <param name="context"></param>
+ public static async Task UpdateService(PLCServiceModel context)
+ {
+ if (PLCTaskAction.boRefresh)
+ await _plcHubContext.Clients.All.UpdateService(context);
+ }
+
+ /// <summary>
+ /// 涓嬪彂鎺у埗鍙颁綅缃俊鎭�
+ /// </summary>
+ /// <param name="context"></param>
+ /// <returns></returns>
+ public static async Task PublicPosition(PlcPositionInfo context)
+ {
+ if (PLCTaskAction.boRefresh)
+ await _plcHubContext.Clients.All.PublicPosition(context);
+ }
+
+ /// <summary>
+ /// 涓嬪彂浠诲姟
+ /// </summary>
+ /// <returns></returns>
+ public static async Task PublicTask(WcsTaskOutput context)
+ {
+ if (PLCTaskAction.boRefresh)
+ await _taskLogHubContext.Clients.All.PublicTask(context);
+ }
+
+ /// <summary>
+ /// 涓嬪彂浠诲姟鏄庣粏
+ /// </summary>
+ /// <returns></returns>
+ public static async Task PublicTaskMonitor(WcsTaskMonitorOutput context)
+ {
+ if (PLCTaskAction.boRefresh)
+ await _taskLogHubContext.Clients.All.PublicTaskMonitor(context);
+ }
+
+ /// <summary>
+ /// 涓嬪彂璁惧淇℃伅
+ /// </summary>
+ /// <param name="context"></param>
+ /// <returns></returns>
+ public static async Task PublicPlcDevice(WcsDeviceOutput context)
+ {
+ if (PLCTaskAction.boRefresh)
+ await _plcDeviceHubContext.Clients.All.PublicPlcDevice(context);
+ }
+
+ /// <summary>
+ /// 涓嬪彂鍒嗘嫞浠诲姟淇℃伅
+ /// </summary>
+ /// <param name="context"></param>
+ /// <returns></returns>
+ public static async Task PublicCheckTask(WcsDeviceTaskOrderDto context)
+ {
+ if (PLCTaskAction.boRefresh)
+ await _checkTaskHubContext.Clients.All.PublicCheckTask(context);
+ }
+}
--
Gitblit v1.8.0