CAN驱动修改优化

UIShare/GlobalVariable/CANSignalBroadcaster.cs

@@ -1,131 +1,191 @@
 using Model.Models;
 using Prism.Events;
 using System;
+using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Linq;
-using System.Text;
-using TSMasterCAN;
+using System.Threading;
+using System.Threading.Tasks;
 using UIShare.PubEvent;
+using UIShare.UIViewModel;
 
 namespace UIShare.GlobalVariable
 {
     /// <summary>
     /// CAN 信号广播器（全局单例）：
-    /// 统一订阅 GlobalInfo.CanPool 中所有已实例化的 ZLGCANFD 设备，
-    /// 将 DBC 解码后的信号值广播给所有引用该 CAN 设备的作用域，
-    /// 并同步检查各作用域 ValueLimitList 的超限报警。
+    /// 不再订阅 CAN 实体实例的事件，改为从所有已注册的 <see cref="CANMonitoringService"/> 
+    /// 的 RealTimeSignals 字典中轮询读取信号值，并通过 <see cref="HardwareDataReportedEvent"/> 广播。
     /// </summary>
-    public class CANSignalBroadcaster : IDisposable
+    public class CANSignalBroadcaster
     {
         private readonly IEventAggregator _eventAggregator;
-        private readonly GlobalInfo _globalInfo;
-        private bool _disposed;
+        private readonly SystemConfig _systemConfig;
 
-        /// <summary>已订阅解码事件的 CANFD 实例 → 委托 映射</summary>
-        private readonly Dictionary<CAN, Action<uint, DBCMessage>> _handlers = new();
-        public CANSignalBroadcaster(GlobalInfo globalInfo, IEventAggregator eventAggregator)
+        /// <summary>全局已注册的 CANMonitoringService 实例列表（静态，跨作用域共享）</summary>
+        private static readonly ConcurrentDictionary<CANMonitoringService, byte> _registeredServices = new();
+
+        private CancellationTokenSource? _cts;
+        private Task? _broadcastTask;
+
+        /// <summary>广播轮询间隔（毫秒）</summary>
+        public int PollingIntervalMs { get; set; } = 100;
+
+        public CANSignalBroadcaster(SystemConfig systemConfig, IEventAggregator eventAggregator)
         {
-            _globalInfo = globalInfo;
+            _systemConfig = systemConfig;
             _eventAggregator = eventAggregator;
         }
 
-        /// <summary>
-        /// 扫描 GlobalInfo.CanPool 中已创建的 CANFD 实例并订阅解码事件。
-        /// 幂等：已订阅的实例不会重复订阅。
-        /// </summary>
-        public void Discover()
+        #region 服务注册（供 CANMonitoringService 调用）
+
+        /// <summary>注册一个 CANMonitoringService，使其信号纳入广播</summary>
+        public static void RegisterService(CANMonitoringService service)
         {
-            if (_disposed) return;
-
-            foreach (var kvp in _globalInfo.CanPool)
-            {
-                string fingerprint = kvp.Key;
-                var lazy = kvp.Value;
-                if (!lazy.IsValueCreated || lazy.Value == null) continue;
-
-                var canfd = lazy.Value;
-                if (_handlers.ContainsKey(canfd)) continue;
-
-                // 使用闭包捕获指纹，回调时即可区分不同 CAN 卡
-                Action<uint, DBCMessage> handler = (channel, msg) => OnDbcMessageDecoded(fingerprint, channel, msg);
-                canfd.OnDbcMessageDecoded += handler;
-                _handlers[canfd] = handler;
-            }
+            _registeredServices.TryAdd(service, 0);
         }
 
-        /// <summary>
-        /// 启动广播器（目前 Discover 已完成订阅，此处保留以兼容 HardwareDataBroadcaster 的使用模式）。
-        /// </summary>
+        /// <summary>注销一个 CANMonitoringService</summary>
+        public static void UnregisterService(CANMonitoringService service)
+        {
+            _registeredServices.TryRemove(service, out _);
+        }
+
+        #endregion
+
+        #region 启动 / 停止
+
+        /// <summary>启动广播（幂等：多次调用只启动一次）</summary>
         public void Start()
         {
-            Discover();
+            if (_broadcastTask != null && !_broadcastTask.IsCompleted) return;
+
+            _cts = new CancellationTokenSource();
+            _broadcastTask = Task.Run(() => BroadcastLoop(_cts.Token));
         }
 
-        /// <summary>
-        /// DBC 解码回调：提取所有信号，向引用该 CAN 设备的作用域广播，并检查报警。
-        /// </summary>
-        private void OnDbcMessageDecoded(string canFingerprint, uint channel, DBCMessage msg)
+        /// <summary>停止广播</summary>
+        public void Stop()
         {
-            if (_disposed) return;
+            _cts?.Cancel();
+            _broadcastTask = null;
+        }
 
-            string signalFingerprint = BuildFingerprint(canFingerprint, channel);
-            var now = DateTime.Now;
+        /// <summary>兼容旧接口：Discover 已无需执行任何操作</summary>
+        public void Discover() { }
 
-            // 获取引用该 CAN 设备的所有作用域
-            var scopes = GetScopesForFingerprint(canFingerprint);
-            if (scopes.Count == 0) return;
+        #endregion
 
-            for (int i = 0; i < msg.nSignalCount; i++)
+        #region 广播核心逻辑
+
+        /// <summary>
+        /// 轮询所有已注册的 CANMonitoringService 的 RealTimeSignals，
+        /// 结合 ConfigurationList 映射出 MessageID/Channel，广播 HardwareDataReportedEvent。
+        /// </summary>
+        private async Task BroadcastLoop(CancellationToken ct)
+        {
+            while (!ct.IsCancellationRequested)
             {
-                var signal = msg.vSignals[i];
-                string signalName = Encoding.Default.GetString(signal.strName).TrimEnd('\0');
-                if (string.IsNullOrEmpty(signalName)) continue;
-
-                double physicalValue = signal.nRawvalue * signal.nFactor + signal.nOffset;
-                string methodName = BuildMethodName(msg.nID, signalName);
-
-                foreach (var scope in scopes)
+                try
                 {
-                    _eventAggregator.GetEvent<HardwareDataReportedEvent>().Publish(new HardwareReportArgs
-                    {
-                        Scope = scope,
-                        HardwareFingerprint = signalFingerprint,
-                        MethodName = methodName,
-                        Value = physicalValue,
-                        Time = now
-                    });
+                    // 预构建信号名 → 配置 的映射（避免内层循环重复查找）
+                    var configMap = BuildConfigMap();
 
-                    string MonitorStatus = ValueLimitAlarmHelper.CheckAlarm(scope, signalFingerprint, methodName, physicalValue, _globalInfo);
-                    if (MonitorStatus != "" && MonitorStatus != "未报警")
+                    string scope = _systemConfig.Title;
+
+                    foreach (var service in _registeredServices.Keys)
                     {
-                        _eventAggregator.GetEvent<AlarmEvent>().Publish((scope,canFingerprint, MonitorStatus));
+                        if (service.IsStopped) continue;
+
+                        foreach (var kvp in service.RealTimeSignals)
+                        {
+                            if (ct.IsCancellationRequested) return;
+
+                            // 信号 Key 格式: "{channel}/{MessageName}/{SignalName}"
+                            if (!TryParseSignalKey(kvp.Key, out int channel, out string? messageName, out string? signalName))
+                                continue;
+
+                            // 从配置映射中查找对应的 MessageID
+                            if (!configMap.TryGetValue($"{channel}/{messageName}/{signalName}", out var cfg))
+                                continue;
+
+                            string canFingerprint = $"CAN:{channel}";
+                            string fingerprint = BuildFingerprint(canFingerprint, (uint)channel);
+                            string methodName = BuildMethodName((uint)cfg.MessageID, signalName);
+
+                            // 广播信号值
+                            _eventAggregator.GetEvent<HardwareDataReportedEvent>().Publish(new HardwareReportArgs
+                            {
+                                Scope = scope,
+                                HardwareFingerprint = fingerprint,
+                                MethodName = methodName,
+                                Value = kvp.Value,
+                                Time = DateTime.Now
+                            });
+
+                            // 报警检查
+                            string alarmStatus = ValueLimitAlarmHelper.CheckAlarm(fingerprint, methodName, kvp.Value, _systemConfig);
+                            if (!string.IsNullOrEmpty(alarmStatus) && alarmStatus != "未报警")
+                            {
+                                _eventAggregator.GetEvent<AlarmEvent>().Publish((scope, canFingerprint, alarmStatus));
+                            }
+                        }
                     }
+
+                    await Task.Delay(PollingIntervalMs, ct);
+                }
+                catch (OperationCanceledException) { break; }
+                catch (Exception ex)
+                {
+                    Logger.LoggerHelper.Error($"CANSignalBroadcaster 广播异常: {ex.Message}");
+                    await Task.Delay(1000, ct); // 异常后等待一段时间再重试
                 }
             }
         }
 
-        /// <summary>获取指定硬件指纹当前被哪些作用域引用</summary>
-        private List<string> GetScopesForFingerprint(string fingerprint)
+        /// <summary>
+        /// 从 SystemConfig.ConfigurationList 构建 "channel/MessageName/SignalName" → CANSignalConfig 的映射
+        /// </summary>
+        private Dictionary<string, CANSignalConfig> BuildConfigMap()
         {
-            if (_globalInfo.DeviceAndScopeDic.TryGetValue(fingerprint, out var lazy))
+            var map = new Dictionary<string, CANSignalConfig>(StringComparer.OrdinalIgnoreCase);
+            if (_systemConfig?.ConfigurationList == null) return map;
+
+            foreach (var cfg in _systemConfig.ConfigurationList)
             {
-                var scopeList = lazy.Value;
-                lock (scopeList) return scopeList.ToList();
+                if (string.IsNullOrEmpty(cfg.SignalName) || string.IsNullOrEmpty(cfg.MessageName)) continue;
+                string key = $"{cfg.Channel}/{cfg.MessageName}/{cfg.SignalName}";
+                map.TryAdd(key, cfg); // 第一个匹配的优先
             }
-            return new List<string>();
+            return map;
         }
 
-        /// <summary>
-        /// 生成 CAN 信号的 DisplayName 格式："{MessageName}.{SignalName}"
-        /// </summary>
+        /// <summary>解析信号 Key: "{channel}/{MessageName}/{SignalName}"</summary>
+        private static bool TryParseSignalKey(string key, out int channel, out string? messageName, out string? signalName)
+        {
+            channel = 0;
+            messageName = null;
+            signalName = null;
+
+            var parts = key.Split('/');
+            if (parts.Length < 3) return false;
+
+            if (!int.TryParse(parts[0], out channel)) return false;
+            messageName = parts[1];
+            signalName = parts[2];
+            return !string.IsNullOrEmpty(messageName) && !string.IsNullOrEmpty(signalName);
+        }
+
+        #endregion
+
+        #region 静态工具方法（保持向后兼容）
+
+        /// <summary>生成 CAN 信号的 DisplayName 格式："{MessageName}.{SignalName}"</summary>
         public static string BuildDisplayName(string messageName, string signalName)
         {
             return $"{messageName}.{signalName}";
         }
 
-        /// <summary>
-        /// 生成 CAN 信号的 MethodName 格式："{MessageId:X}.{SignalName}"
-        /// </summary>
+        /// <summary>生成 CAN 信号的 MethodName 格式："{MessageId:X}.{SignalName}"</summary>
         public static string BuildMethodName(uint messageId, string signalName)
         {
             return $"{messageId:X}.{signalName}";
@@ -140,17 +200,6 @@ namespace UIShare.GlobalVariable
             return $"{canDeviceFingerprint}:{channel}";
         }
 
-        public void Dispose()
-        {
-            if (_disposed) return;
-            _disposed = true;
-
-            foreach (var kvp in _handlers)
-            {
-                if (kvp.Key != null)
-                    kvp.Key.OnDbcMessageDecoded -= kvp.Value;
-            }
-            _handlers.Clear();
-        }
+        #endregion
     }
 }