伸缩杆控制系统新库
blame | 历史 | 补丁 | 提交 | 提交对比 | 显示空白
yanjinhui
7 天以前 b9c76ce85e533250cd36de670146530f970859e7 
 ÏîÄ¿´úÂë/ºó¶Ë/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SSG/AlarmResetJob.cs


@@ -15,6 +15,10 @@


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


{


@@ -26,6 +30,7 @@


        WebSocketServer _webSocketServer;


        private readonly Idt_ErrormsginfoService _ErrormsginfoService;


        private readonly AlarmResetHsyServer _alarmResetHsy;


        private readonly IIPaddressServer _cunstomipService;


        //private static readonly object _lockObj = new object(); //加锁






@@ -45,23 +50,44 @@


            ["M120"] = false,//障碍报警


        };




        public AlarmResetJob(Idt_ErrormsginfoService errormsginfoService, WebSocketServer webSocketServer, IAlarmResetHsyServer alarmResetHsyServer, ISys_UserService UserService)


        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


            {


                if (!int.TryParse(AppSettings.Get("DepartmentID"), out int deid))


                WebSocketSession[] webSocketSessions = _webSocketServer.OnlineSessions;//将所有的连接信息存到这里


                //string clientIp = webSocketSessions[0].Remote.Address.ToString().Replace("::ffff", ""); //获取一个ip地址




                foreach (var session in webSocketSessions)


                {


                    Console.WriteLine("配置项 DepartmentID æ— æ³•è½¬æ¢ä¸ºæ•´æ•°");


                }


                    string clientIp = session.Remote.Address.ToString().Replace("::ffff:", "");


                    var customip = _cunstomipService.GetStandid(clientIp);


                    if (customip.Status && customip.Data != null)


                    {


                        //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)


                {


                        // Left PLC processing


@@ -81,7 +107,7 @@


                                // Check and record alarms only when state changes from false to true


                                if (leftPLcstuck1 && !_leftAlarmStates["M109"])


                                {


                                    string text = $"检8道左侧警惕机构：伸缩卡住报警";


                                        string text = $"检{deid}道左侧警惕机构：伸缩卡住报警";


                                    var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, leftPLcstuck1);


                                    _leftAlarmStates["M109"] = true;


                                }


@@ -92,7 +118,7 @@




                                if (leftPLcOher1 && !_leftAlarmStates["M111"])


                                {


                                    string text = $"检8道左侧警惕机构：其他故障报警";


                                        string text = $"检{deid}道左侧警惕机构：其他故障报警";


                                    var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, leftPLcOher1);


                                    _leftAlarmStates["M111"] = true;


                                }


@@ -103,7 +129,7 @@




                                if (leftscram && !_leftAlarmStates["M110"])


                                {


                                    string text = $"检8道左侧警惕机构：急停报警";


                                        string text = $"检{deid}道左侧警惕机构：急停报警";


                                    var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, leftscram);


                                    _leftAlarmStates["M110"] = true;


                                }


@@ -114,7 +140,7 @@




                                if (leftstop && !_leftAlarmStates["M120"])


                                {


                                    string text = $"检8道左侧警惕机构：遇障碍停止报警";


                                        string text = $"检{deid}道左侧警惕机构：遇障碍停止报警";


                                    var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, leftstop);


                                    _leftAlarmStates["M120"] = true;


                                }


@@ -154,7 +180,7 @@


                                // Check and record alarms only when state changes from false to true


                                if (rightPLcSuck && !_rightAlarmStates["M109"])


                                {


                                    string text = $"检8道右侧警惕机构：报警伸缩卡住报警";


                                        string text = $"检{deid}道右侧警惕机构：报警伸缩卡住报警";


                                    var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, rightPLcSuck);


                                    _rightAlarmStates["M109"] = true;


                                }


@@ -165,7 +191,7 @@




                                if (rightPLcOher && !_rightAlarmStates["M111"])


                                {


                                    string text = $"检8道右侧警惕机构：其他故障报警";


                                        string text = $"检{deid}道右侧警惕机构：其他故障报警";


                                    var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, rightPLcOher);


                                    _rightAlarmStates["M111"] = true;


                                }


@@ -176,7 +202,7 @@




                                if (rightscram && !_rightAlarmStates["M110"])


                                {


                                    string text = $"检8道右侧警惕机构：急停报警";


                                        string text = $"检{deid}道右侧警惕机构：急停报警";


                                    var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, rightscram);


                                    _rightAlarmStates["M110"] = true;


                                }


@@ -187,7 +213,7 @@




                                if (rightstop && !_rightAlarmStates["M120"])


                                {


                                    string text = $"检8道右侧警惕机构：遇障碍停止报警";


                                        string text = $"检{deid}道右侧警惕机构：遇障碍停止报警";


                                    var reslut = _alarmResetHsyServer.AddAlarmHsy(deid, text, rightstop);


                                    _rightAlarmStates["M120"] = true;


                                }


@@ -213,15 +239,20 @@


                    _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)


        {


            int baseCode = 1 + (deptId - 1) * 2;