NEIntelligentControl-jnxj/NEIntelligentControl2/Models/Messages/FaultPopupBridge.cs

using NEIntelligentControl2.Models.Alarm;
using NEIntelligentControl2.Service.WebSocket;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace NEIntelligentControl2.Models.Messages
{
    internal class FaultPopupBridge : IMessage
    {
        public List<string> MessageTypes { get; set; } = new List<string> { "SubscribePopupAlarm".GetConfiguration() };
        
        public Action<List<FaultInfo>> Messaged { get; set; }
        
        public async Task OnMessage(object message)
        {
            try
            {
                await Task.Run(onmessage);
            }
            catch (Exception e)
            {
                Console.WriteLine($"风机信息WebSocket数据解析失败：{e.Message}");
            }

            void onmessage()
            {
                var ss = message as List<FaultInfo>;
                if (ss == null) return;
                Messaged?.Invoke(ss);
            }
        }
    }
}