优化接口

yanjinhui

4 天以前 d3091b37a593885877f4ed4180d49e5ce259b657

 ÏîÄ¿´úÂë/ºó¶Ë/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SSG/AlarmResetJob.cs

@@ -15,142 +15,246 @@
using WIDESEAWCS_TelescopicService;
using WIDESEAWCS_ISystemServices;
using WIDESEAWCS_Core.Helper;

using Microsoft.AspNetCore.Http;
using System.Collections.Concurrent;
using Microsoft.AspNetCore.Hosting.Server;
using static System.Collections.Specialized.BitVector32;

namespace WIDESEAWCS_Tasks
{
    [DisallowConcurrentExecution]
    public class AlarmResetJob : JobBase, IJob
    {

        private readonly IAlarmResetHsyServer _alarmResetHsyServer;
        private readonly ISys_UserService _UserService;
        WebSocketServer _webSocketServer;
        private readonly Idt_ErrormsginfoService _ErrormsginfoService;
        private readonly AlarmResetHsyServer _alarmResetHsy;
        private readonly IIPaddressServer _cunstomipService;
        //private static readonly object _lockObj = new object(); //加锁


        public AlarmResetJob(Idt_ErrormsginfoService errormsginfoService, WebSocketServer webSocketServer, IAlarmResetHsyServer alarmResetHsyServer, ISys_UserService UserService)
        // å¢žæ·»çš„字典跟踪报警为每个装置 Quartz é»˜è®¤æ¯æ¬¡è°ƒåº¦ä»»åŠ¡æ—¶ä¼šé‡æ–°åˆ›å»º
        private static readonly Dictionary<string, bool> _leftAlarmStates = new Dictionary<string, bool>() //加锁
        {
            ["M109"] = false,//伺服报警
            ["M111"] = false,//其他报警
            ["M110"] = false,//急停报警
            ["M120"] = false,//障碍报警
        };
        private static readonly Dictionary<string, bool> _rightAlarmStates = new Dictionary<string, bool>()
        { 
            ["M109"] = false,//伺服报警
            ["M111"] = false,//其他报警
            ["M110"] = false,//急停报警
            ["M120"] = false,//障碍报警
        };

        public AlarmResetJob(Idt_ErrormsginfoService errormsginfoService, WebSocketServer webSocketServer, IAlarmResetHsyServer alarmResetHsyServer, ISys_UserService UserService, IIPaddressServer cunstomipService)
        {
            _webSocketServer = webSocketServer;
            _alarmResetHsyServer = alarmResetHsyServer;
            _UserService = UserService;
            _ErrormsginfoService = errormsginfoService;
            _cunstomipService = cunstomipService;    
        }

       

        public Task Execute(IJobExecutionContext context)
        {
            try
            {
                WebSocketSession[] webSocketSessions = _webSocketServer.OnlineSessions;//将所有的连接信息存到这里
                //string clientIp = webSocketSessions[0].Remote.Address.ToString().Replace("::ffff", ""); //获取一个ip地址

                //获取设备号
                // èŽ·å–设备配置
                //OtherDevice serialPortDevice = (OtherDevice)context.JobDetail.JobDataMap.Get("JobParams");
                if (!int.TryParse(AppSettings.Get("DepartmentID"), out int deid))
                foreach (var session in webSocketSessions)
                {
                    Console.WriteLine("配置项 DepartmentID æ— æ³•è½¬æ¢ä¸ºæ•´æ•°");
                }
                var devices = GetDevicesByDeptId(deid);
                if (devices != null)
                {
                    //首先要一直读，如果发生了故障要写到_alarmResetHsyServer中记录下来并且给到前端数据
                    //å·¦plc
                    try
                    string clientIp = session.Remote.Address.ToString().Replace("::ffff:", "");
                    var customip = _cunstomipService.GetStandid(clientIp);
                    if (customip.Status && customip.Data != null)
                    {
                        if (devices.Value.left.IsConnected)
                        //var deid = customip.Data.StationID;
                        var deid = Convert.ToInt32(customip.Data);
                        var devices = GetDevicesByDeptId(deid);



                        //if (!int.TryParse(AppSettings.Get("DepartmentID"), out int deid))
                        //{
                        //    Console.WriteLine("配置项 DepartmentID æ— æ³•è½¬æ¢ä¸ºæ•´æ•°");
                        //}
                        //var devices = GetDevicesByDeptId(deid);



                        if (devices != null)
                        {
                            var leftPLcstuck1 = devices.Value.left.Communicator.Read<bool>("M109"); //卡住报警
                            var leftPLcOher1 = devices.Value.left.Communicator.Read<bool>("M111");  //其他报警 //默认是false
                            var leftPLcNowAdd = devices.Value.left.Communicator.Read<float>("D80");
                            Console.WriteLine($"{devices.Value.left.DeviceName}:卡住报警{leftPLcstuck1}，其他报警{leftPLcOher1}");
                            if (leftPLcstuck1 == true && leftPLcOher1 == false)
                            // Left PLC processing
                            try
                            {
                                string text = $"轨道{deid}：伸缩卡住报警";
                                //报警了在这调用添加方法，并传给前端
                                var reslut = _alarmResetHsyServer.AddAlarmHsy(deid,text, leftPLcstuck1);
                                if (devices.Value.left.IsConnected)
                                {
                                    var leftPLcstuck1 = devices.Value.left.Communicator.Read<bool>("M109"); // Servo alarm
                                    var leftPLcOher1 = devices.Value.left.Communicator.Read<bool>("M111");  // Other alarm
                                    var leftscram = devices.Value.left.Communicator.Read<bool>("M110");     // Emergency stop
                                    var leftstop = devices.Value.left.Communicator.Read<bool>("M120");      // Obstacle stop

                                    var leftPLcNowAdd = devices.Value.left.Communicator.Read<float>("D80"); //当前位置
                                    Console.WriteLine($"{devices.Value.left.DeviceName}:卡住报警{leftPLcstuck1}，其他报警{leftPLcOher1}");


                            }
                            if (leftPLcstuck1 == false && leftPLcOher1 == true)
                            {
                                string text = $"轨道{deid}：其他故障报警";
                                var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, leftPLcstuck1);
                                    // Check and record alarms only when state changes from false to true
                                    if (leftPLcstuck1 && !_leftAlarmStates["M109"])
                                    {
                                        string text = $"检{deid}道左侧警惕机构：伸缩卡住报警";
                                        var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, leftPLcstuck1);
                                        _leftAlarmStates["M109"] = true;
                                    }
                                    else if (!leftPLcstuck1)
                                    {
                                        _leftAlarmStates["M109"] = false;
                                    }

                                    if (leftPLcOher1 && !_leftAlarmStates["M111"])
                                    {
                                        string text = $"检{deid}道左侧警惕机构：其他故障报警";
                                        var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, leftPLcOher1);
                                        _leftAlarmStates["M111"] = true;
                                    }
                                    else if (!leftPLcOher1)
                                    {
                                        _leftAlarmStates["M111"] = false;
                                    }

                                    if (leftscram && !_leftAlarmStates["M110"])
                                    {
                                        string text = $"检{deid}道左侧警惕机构：急停报警";
                                        var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, leftscram);
                                        _leftAlarmStates["M110"] = true;
                                    }
                                    else if (!leftscram)
                                    {
                                        _leftAlarmStates["M110"] = false;
                                    }

                                    if (leftstop && !_leftAlarmStates["M120"])
                                    {
                                        string text = $"检{deid}道左侧警惕机构：遇障碍停止报警";
                                        var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, leftstop);
                                        _leftAlarmStates["M120"] = true;
                                    }
                                    else if (!leftstop)
                                    {
                                        _leftAlarmStates["M120"] = false;
                                    }


                                    _webSocketServer.PublishAllClientPayload(JsonConvert.SerializeObject(new
                                    {
                                        device = "å·¦Plc",
                                        Liftvalue = leftPLcNowAdd
                                    })); //返回当前plc位置
                                }
                            }
                            if (leftPLcstuck1 == true && leftPLcOher1 == true)//如果报警了
                            catch (Exception)
                            {
                                string text = $"轨道{deid}：报警伸缩卡住报警和其他故障报警";
                                var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, leftPLcstuck1);
                                string text = $"轨道{deid}：左PLC未连接";
                                //var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, false);
                            }
                            _webSocketServer.PublishAllClientPayload(JsonConvert.SerializeObject(new

                            // Right PLC processing
                            try
                            {
                                device = "å·¦Plc",
                                Liftvalue = leftPLcNowAdd
                            }));//把D80给前端
                                if (devices.Value.right.IsConnected)
                                {
                                    var rightPLcSuck = devices.Value.right.Communicator.Read<bool>("M109"); // Servo alarm
                                    var rightPLcOher = devices.Value.right.Communicator.Read<bool>("M111"); // Other alarm
                                    var rightscram = devices.Value.right.Communicator.Read<bool>("M110"); // Emergency stop
                                    var rightstop = devices.Value.right.Communicator.Read<bool>("M120");     // Obstacle stop

                                    var rightPLcNowAdd = devices.Value.right.Communicator.Read<float>("D80");
                                    Console.WriteLine($"{devices.Value.right.DeviceName}:卡住报警{rightPLcSuck}，其他报警{rightPLcOher}");


                                    // Check and record alarms only when state changes from false to true
                                    if (rightPLcSuck && !_rightAlarmStates["M109"])
                                    {
                                        string text = $"检{deid}道右侧警惕机构：报警伸缩卡住报警";
                                        var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, rightPLcSuck);
                                        _rightAlarmStates["M109"] = true;
                                    }
                                    else if (!rightPLcSuck)
                                    {
                                        _rightAlarmStates["M109"] = false;
                                    }

                                    if (rightPLcOher && !_rightAlarmStates["M111"])
                                    {
                                        string text = $"检{deid}道右侧警惕机构：其他故障报警";
                                        var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, rightPLcOher);
                                        _rightAlarmStates["M111"] = true;
                                    }
                                    else if (!rightPLcOher)
                                    {
                                        _rightAlarmStates["M111"] = false;
                                    }

                                    if (rightscram && !_rightAlarmStates["M110"])
                                    {
                                        string text = $"检{deid}道右侧警惕机构：急停报警";
                                        var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, rightscram);
                                        _rightAlarmStates["M110"] = true;
                                    }
                                    else if (!rightscram)
                                    {
                                        _rightAlarmStates["M110"] = false;
                                    }

                                    if (rightstop && !_rightAlarmStates["M120"])
                                    {
                                        string text = $"检{deid}道右侧警惕机构：遇障碍停止报警";
                                        var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, rightstop);
                                        _rightAlarmStates["M120"] = true;
                                    }
                                    else if (!rightstop)
                                    {
                                        _rightAlarmStates["M120"] = false;
                                    }

                                    _webSocketServer.PublishAllClientPayload(JsonConvert.SerializeObject(new
                                    {
                                        device = "右Plc",
                                        Rightvalue = rightPLcNowAdd
                                    }));
                                }
                            }
                            catch (Exception)
                            {
                                string text = $"轨道{deid}：右PLC未连接";
                                //var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, false);
                            }

                            var alrt = _alarmResetHsyServer.GetWebSocketInfo(deid);
                            _webSocketServer.PublishAllClientPayload(JsonConvert.SerializeObject(alrt)); //返回所有的报警表的信息
                        }
                    }
                    catch (Exception)
                    {
                        string text = $"轨道{deid}：左PLC未连接";
                        //var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, false);//添加数据
                    }
                    
                    try
                    {
                        if (devices.Value.right.IsConnected)//是否连接上
                        {
                            //右plc
                            var rightPLcSuck = devices.Value.right.Communicator.Read<bool>("M109"); //卡住报警
                            var rightPLcOher = devices.Value.right.Communicator.Read<bool>("M111");//其他报警
                            var rightPLcNowAdd = devices.Value.right.Communicator.Read<float>("D80");
                            Console.WriteLine($"{devices.Value.right.DeviceName}:卡住报警{rightPLcSuck}，其他报警{rightPLcOher}");
                            if (rightPLcSuck == true && rightPLcOher == false)
                            {
                                string text = $"轨道{deid}：报警伸缩卡住报警";
                                //报警了在这调用添加方法，并传给前端
                                var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, rightPLcSuck);
                                // _webSocketServer.PublishAllClientPayload(JsonConvert.SerializeObject(reslut));//websocketserver这种只能传给前端json格式
                            }
                            if (rightPLcOher == false && rightPLcSuck == true)
                            {
                                string text = $"轨道{deid}：其他故障报警";
                                var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, rightPLcOher);
                            }
                            if (rightPLcSuck == true && rightPLcOher == true)//如果报警了
                            {
                                string text = $"轨道{deid}：报警伸缩卡住报警和其他故障报警";
                                var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, rightPLcOher);//添加数据
                            }
                            _webSocketServer.PublishAllClientPayload(JsonConvert.SerializeObject(new {
                                device="右Plc",
                                Rightvalue= rightPLcNowAdd
                            }));//把D80给前端

                        }
                    }
                    catch (Exception)
                    {
                        string text = $"轨道{deid}：右PLC未连接";
                        //var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, false);//添加数据
                    }
                    var alrt = _alarmResetHsyServer.GetWebSocketInfo(deid);
                    _webSocketServer.PublishAllClientPayload(JsonConvert.SerializeObject(alrt));
                    
                }
            }

                       
            catch (Exception ex)
            {
                _ErrormsginfoService.UpdateErrorMsg(ex.Message, 1);
                Console.WriteLine("错误信息：" + ex.Message);
                Console.WriteLine(ex.StackTrace);
            }

            return Task.CompletedTask;

        }


        public (OtherDevice left, OtherDevice right)? GetDevicesByDeptId(int deptId)
        {
            // å·¦è®¾å¤‡å·ï¼š1 -> 001，2 -> 003，3 -> 005...
            int baseCode = 1 + (deptId - 1) * 2;
            string leftCode = $"SSG{baseCode.ToString("D3")}";
            string rightCode = $"SSG{(baseCode + 1).ToString("D3")}";
@@ -158,13 +262,7 @@
            var left = (OtherDevice)Storage.Devices.Find(x => x.DeviceCode == leftCode);
            var right = (OtherDevice)Storage.Devices.Find(x => x.DeviceCode == rightCode);

            
            //if (left == null || right == null)
            //    return null;

            return (left, right);
        }
    }
}


}