using HslCommunication;
using NetTaste;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using WIDESEA_Common.Tools;
using WIDESEA_Core.EFDbContext;
using WIDESEA_Services.IRepositories;
using WIDESEA_Services.Repositories;
using WIDESEA_WCS.WCSClient;

namespace WIDESEA_WCS.SchedulerExecute.AGV
{
    public partial class heartbeatRK
    {
        private static int lockObj1 = 0;
        public static void heartbeatWork()
        {
            if (lockObj1 == 0)
            {
                lockObj1 = 1;
                {
                    string rksb = "入壳机1";
                    //心跳
                    Task.Run(() =>
                    {

                        while (true)
                        {
                            try
                            {
                                Thread.Sleep(200);
                                if (WCSService.Clients == null)
                                {
                                    continue;
                                }
                                PLCClient rkplc = WCSService.Clients.Find(v => v.PLCName == rksb);
                                if (rkplc == null)
                                {
                                    continue;
                                }

                                PLCClient agvplc = WCSService.Clients.Find(v => v.PLCName == "组装AGV调度");
                                if (agvplc == null)
                                {
                                    continue;
                                }
                                #region 入壳机一号心跳
                                WriteLog.GetLog().Write($"--------------{rksb}心跳传递开始,时间：{DateTime.Now}--------------{Environment.NewLine}", $"{rksb}心跳传递");
                                // 读取入壳机1号设备心跳
                                bool R_RK1_XT =Convert.ToBoolean(rkplc.ModbusPLCClient.ModbusTcpNetClient.ReadInt16("5300").Content);

                                // 入壳机1号设备心跳—写入—》组装AGV调度心跳
                                OperateResult W_AGV_XT = agvplc.SiemensPLCClient.SiemensS7NetClient.Write("DB1002.3600.0", R_RK1_XT);
                                
                                // 读取组装AGV调度心跳
                                OperateResult<bool> R_AGV_XT = agvplc.SiemensPLCClient.SiemensS7NetClient.ReadBool("DB1002.3700.0");

                                Int16 readValue = Convert.ToInt16(R_AGV_XT.Content);
                                // 组装AGV调度—写入—》入壳机1号设备心跳
                                OperateResult W_RK1_XT = rkplc.ModbusPLCClient.ModbusTcpNetClient.Write("5300", readValue);
                                
                                WriteLog.GetLog().Write($"--------------{rksb}心跳传递结束,时间：{DateTime.Now}--------------{Environment.NewLine}", $"{rksb}心跳传递");
                                #endregion
                            }
                            catch (Exception ex) { }
                        }

                    });
                    //上料口
                    Task.Run(() =>
                    {
                        while (true)
                        {
                            try
                            {
                                if (WCSService.Clients == null)
                                {
                                    continue;
                                }
                                PLCClient rkplc = WCSService.Clients.Find(v => v.PLCName == rksb);
                                if (rkplc == null)
                                {
                                    continue;
                                }

                                PLCClient agvplcZZ = WCSService.Clients.Find(v => v.PLCName == "组装AGV调度");
                                if (agvplcZZ == null)
                                {
                                    continue;
                                }
                                #region 上料口
                                WriteLog.GetLog().Write($"{rksb}上料口信息传递开始,时间：{DateTime.Now} --------------{Environment.NewLine}", $"{rksb}上料口信息传递");
                                //入壳机1号报警
                                bool GYC_RBJ =Convert.ToBoolean(rkplc.ModbusPLCClient.ModbusTcpNetClient.ReadInt16("5302").Content);
                                // AGV获取入壳机1号报警信号
                                OperateResult AGVC_WBJ = agvplcZZ.SiemensPLCClient.SiemensS7NetClient.Write("DB1002.3692", GYC_RBJ);
                                // AGV报警信号
                                OperateResult<bool> AGVC_RBJ = agvplcZZ.SiemensPLCClient.SiemensS7NetClient.ReadBool("DB1002.3792");
                                Int16 RBJ = Convert.ToInt16(AGVC_RBJ.Content);
                                //入壳机1号获取AGV报警信号
                                OperateResult GFC_WBJ = rkplc.ModbusPLCClient.ModbusTcpNetClient.Write("5304", RBJ);
                                //读取agv上料口逻辑
                                OperateResult<Int16> R_up_bzR = agvplcZZ.SiemensPLCClient.SiemensS7NetClient.ReadInt16("DB1002.3790");
                                //写入入壳机1号上料口对接流程步骤
                                OperateResult W_ProcessStep_up = rkplc.ModbusPLCClient.ModbusTcpNetClient.Write("5307", R_up_bzR.Content);
                                //读取入壳机1号步序
                                OperateResult<Int16> R_ProcessSteps_up = rkplc.ModbusPLCClient.ModbusTcpNetClient.ReadInt16("5306");
                                //将步序写入agv
                                OperateResult W_stationDockSteps_up = agvplcZZ.SiemensPLCClient.SiemensS7NetClient.Write("DB1002.3690", R_ProcessSteps_up.Content);
                                WriteLog.GetLog().Write($"{rksb}上料口信息传递结束,时间：{DateTime.Now}--------------{Environment.NewLine}", $"{rksb}上料口信息传递");
                                #endregion
                            }
                            catch (Exception ex)
                            {

                            }
                            Thread.Sleep(200);
                        }
                    });
                    //下料口
                    Task.Run(() =>
                    {
                        while (true)
                        {
                            try
                            {
                                if (WCSService.Clients == null)
                                {
                                    continue;
                                }
                                PLCClient rkplc = WCSService.Clients.Find(v => v.PLCName == rksb);
                                if (rkplc == null)
                                {
                                    continue;
                                }
                                PLCClient agvplc = WCSService.Clients.Find(v => v.PLCName == "组装AGV调度");
                                if (agvplc == null)
                                {
                                    continue;
                                }
                                #region 下料口
                                //入壳机1号口报警
                                WriteLog.GetLog().Write($"{rksb}下料口信息传递开始,时间：{DateTime.Now}--------------{Environment.NewLine}", $"{rksb}下料口信息传递");
                                //入壳机1号报警
                                bool GYC_RBJ = Convert.ToBoolean(rkplc.ModbusPLCClient.ModbusTcpNetClient.ReadInt16("5302").Content);
                                // AGV获取入壳机1号报警信号
                                OperateResult AGV_WBJ = agvplc.SiemensPLCClient.SiemensS7NetClient.Write("DB1002.3892", GYC_RBJ);
                                // AGV报警信号
                                OperateResult<bool> AGV_RBJ = agvplc.SiemensPLCClient.SiemensS7NetClient.ReadBool("DB1002.3992");
                                int RBJ = Convert.ToInt32(AGV_RBJ.Content);
                                //入壳机1号获取AGV报警信号
                                OperateResult GFC_WBJ = rkplc.ModbusPLCClient.ModbusTcpNetClient.Write("5304", RBJ);
                                // 读取agv下料口请求进入
                                OperateResult<Int16> R_Down1_bzR = agvplc.SiemensPLCClient.SiemensS7NetClient.ReadInt16("DB1002.3990");
                                // 写入入壳机1号下料口AGV请求进入
                                OperateResult W_ProcessSteps1 = rkplc.ModbusPLCClient.ModbusTcpNetClient.Write("5309", R_Down1_bzR.Content);
                                // 读取入壳机1号下料口是否允许AGV请求进入
                                OperateResult<Int16> R_ProcessSteps1 = rkplc.ModbusPLCClient.ModbusTcpNetClient.ReadInt16("5308");
                                OperateResult W_stationDockSteps1 = agvplc.SiemensPLCClient.SiemensS7NetClient.Write("DB1002.3890", R_ProcessSteps1.Content);
                                WriteLog.GetLog().Write($"{rksb}下料口信息传递结束,时间：{DateTime.Now}--------------{Environment.NewLine}", $"{rksb}下料口信息传递");
                                #endregion
                            }
                            catch (Exception ex) { }
                            Thread.Sleep(200);
                        }
                    });
                }

                {
                    string rksb = "入壳机2";
                    //心跳
                    Task.Run(() =>
                    {

                        while (true)
                        {
                            try
                            {
                                Thread.Sleep(200);
                                if (WCSService.Clients == null)
                                {
                                    continue;
                                }
                                PLCClient rkplc = WCSService.Clients.Find(v => v.PLCName == rksb);
                                if (rkplc == null)
                                {
                                    continue;
                                }

                                PLCClient agvplc = WCSService.Clients.Find(v => v.PLCName == "组装AGV调度");
                                if (agvplc == null)
                                {
                                    continue;
                                }
                                #region 入壳机二号心跳
                                WriteLog.GetLog().Write($"--------------{rksb}心跳传递开始,时间：{DateTime.Now} --------------{Environment.NewLine}", $"{rksb}心跳传递");
                                // 读取入壳机2号设备心跳
                                bool R_RK2_XT = Convert.ToBoolean(rkplc.ModbusPLCClient.ModbusTcpNetClient.ReadInt16("5300").Content);

                                // 入壳机2号设备心跳—写入—》组装AGV调度心跳
                                OperateResult W_AGV_XT = agvplc.SiemensPLCClient.SiemensS7NetClient.Write("DB1002.4000.0", R_RK2_XT);

                                // 读取组装AGV调度心跳
                                OperateResult<bool> R_AGV_XT = agvplc.SiemensPLCClient.SiemensS7NetClient.ReadBool("DB1002.4100.0");

                                Int16 readValue = Convert.ToInt16(R_AGV_XT.Content);
                                // 组装AGV调度—写入—》入壳机2号设备心跳
                                OperateResult W_RK2_XT = rkplc.ModbusPLCClient.ModbusTcpNetClient.Write("5300", readValue);

                                WriteLog.GetLog().Write($"--------------{rksb}心跳传递结束,时间：{DateTime.Now} --------------{Environment.NewLine}", $"{rksb}心跳传递");
                                #endregion
                            }
                            catch (Exception ex) { }
                        }

                    });
                    //上料口
                    Task.Run(() =>
                    {
                        while (true)
                        {
                            try
                            {
                                if (WCSService.Clients == null)
                                {
                                    continue;
                                }
                                PLCClient rkplc = WCSService.Clients.Find(v => v.PLCName == rksb);
                                if (rkplc == null)
                                {
                                    continue;
                                }

                                PLCClient agvplcZZ = WCSService.Clients.Find(v => v.PLCName == "组装AGV调度");
                                if (agvplcZZ == null)
                                {
                                    continue;
                                }
                                #region 上料口
                                WriteLog.GetLog().Write($"-------------- {rksb}上料口信息传递开始,时间：{DateTime.Now} --------------{Environment.NewLine}", $"{rksb}上料口信息传递");
                                //入壳机2号报警
                                bool GYC_RBJ = Convert.ToBoolean(rkplc.ModbusPLCClient.ModbusTcpNetClient.ReadInt16("5302").Content);
                                // AGV获取入壳机2号报警信号
                                OperateResult AGVC_WBJ = agvplcZZ.SiemensPLCClient.SiemensS7NetClient.Write("DB1002.4092", GYC_RBJ);
                                // AGV报警信号
                                OperateResult<bool> AGVC_RBJ = agvplcZZ.SiemensPLCClient.SiemensS7NetClient.ReadBool("DB1002.4192");
                                Int16 RBJ = Convert.ToInt16(AGVC_RBJ.Content);
                                //入壳机2号获取AGV报警信号
                                OperateResult GFC_WBJ = rkplc.ModbusPLCClient.ModbusTcpNetClient.Write("5304", RBJ);
                                //读取agv上料口逻辑
                                OperateResult<Int16> R_up_bzR = agvplcZZ.SiemensPLCClient.SiemensS7NetClient.ReadInt16("DB1002.4190");
                                //写入入壳机2号上料口对接流程步骤
                                OperateResult W_ProcessStep_up = rkplc.ModbusPLCClient.ModbusTcpNetClient.Write("5307", R_up_bzR.Content);
                                //读取入壳机2号步序
                                OperateResult<Int16> R_ProcessSteps_up = rkplc.ModbusPLCClient.ModbusTcpNetClient.ReadInt16("5306");
                                //将步序写入agv
                                OperateResult W_stationDockSteps_up = agvplcZZ.SiemensPLCClient.SiemensS7NetClient.Write("DB1002.4090", R_ProcessSteps_up.Content);
                                WriteLog.GetLog().Write($"-------------- {rksb}上料口信息传递结束,时间：{DateTime.Now} -------------- {Environment.NewLine}", $"{rksb}上料口信息传递");
                                #endregion
                            }
                            catch (Exception ex)
                            {

                            }
                            Thread.Sleep(200);
                        }
                    });
                    //下料口
                    Task.Run(() =>
                    {
                        while (true)
                        {
                            try
                            {
                                if (WCSService.Clients == null)
                                {
                                    continue;
                                }
                                PLCClient rkplc = WCSService.Clients.Find(v => v.PLCName == rksb);
                                if (rkplc == null)
                                {
                                    continue;
                                }

                                PLCClient agvplc = WCSService.Clients.Find(v => v.PLCName == "组装AGV调度");
                                if (agvplc == null)
                                {
                                    continue;
                                }
                                #region 下料口
                                WriteLog.GetLog().Write($"{rksb}下料口信息传递开始,时间：{DateTime.Now} --------------{Environment.NewLine}", $"{rksb}下料口信息传递");
                                //入壳机2号报警
                                bool GYC_RBJ = Convert.ToBoolean(rkplc.ModbusPLCClient.ModbusTcpNetClient.ReadInt16("5302").Content);
                                // AGV获取入壳机2号报警信号
                                OperateResult AGV_WBJ = agvplc.SiemensPLCClient.SiemensS7NetClient.Write("DB1002.4292", GYC_RBJ);
                                // AGV报警信号
                                OperateResult<bool> AGV_RBJ = agvplc.SiemensPLCClient.SiemensS7NetClient.ReadBool("DB1002.4392");
                                int RBJ = Convert.ToInt32(AGV_RBJ.Content);
                                //入壳机2号获取AGV报警信号
                                OperateResult GFC_WBJ = rkplc.ModbusPLCClient.ModbusTcpNetClient.Write("5304", RBJ);
                                // 读取agv下料口请求进入
                                OperateResult<Int16> R_Down1_bzR = agvplc.SiemensPLCClient.SiemensS7NetClient.ReadInt16("DB1002.4390");
                                // 写入入壳机2号下料口AGV请求进入
                                OperateResult W_ProcessSteps1 = rkplc.ModbusPLCClient.ModbusTcpNetClient.Write("5309", R_Down1_bzR.Content);
                                // 读取入壳机2号下料口是否允许AGV请求进入
                                OperateResult<Int16> R_ProcessSteps1 = rkplc.ModbusPLCClient.ModbusTcpNetClient.ReadInt16("5308");
                                OperateResult W_stationDockSteps1 = agvplc.SiemensPLCClient.SiemensS7NetClient.Write("DB1002.4290", R_ProcessSteps1.Content);
                                WriteLog.GetLog().Write($"{rksb}下料口信息传递结束,时间：{DateTime.Now} --------------{Environment.NewLine}", $"{rksb}下料口信息传递");
                                #endregion
                            }
                            catch (Exception ex) { }
                            Thread.Sleep(200);
                        }
                    });
                }
            }
        }
    }
}