ECS / WCS_LiuzhouZhituo · Files

using HHECS.Bll;
using HHECS.Common;
using HHECS.Controls;
using HHECS.Model;
using HHECS.OPC;
using HHECS.View.Win;
using S7.Net;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Diagnostics;
using System.Linq;
using System.Runtime.Remoting;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Data;
using System.Windows.Documents;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Imaging;
using System.Windows.Shapes;

namespace HHECS.View
{
    /// <summary>
    /// Main.xaml 的交互逻辑
    /// </summary>
    public partial class WinMain : BaseWindow
    {
        #region 属性

        /// <summary>
        /// OPC地址
        /// </summary>
        public string PLCIP { get; set; }
        public OPCHelp PLC { get; set; }

        /// <summary>
        /// 时钟同步锁
        /// </summary>
        private object locker = new object();

        /// <summary>
        /// 子窗体
        /// </summary>
        public Dictionary<string, Window> ChildrenWin { get; set; } = new Dictionary<string, Window>();

        /// <summary>
        /// 主控时钟
        /// </summary>
        private System.Timers.Timer timer = new System.Timers.Timer();

        /// <summary>
        /// 结束时钟标志
        /// </summary>
        private bool stop = false;

        /// <summary>
        /// 用于创建设备PLC
        /// </summary>
        public List<Plc> PLCs { get; set; } = new List<Plc>();

        /// <summary>
        /// 设备
        /// </summary>
        public List<Equipment> Equipments { get; set; }

        /// <summary>
        /// 设备属性
        /// </summary>
        public List<EquipmentProp> EquipmentProps { get; set; }

        /// <summary>
        /// 设备类型
        /// </summary>
        public List<EquipmentType> EquipmentTypes { get; set; }

        /// <summary>
        /// 设备属性模板
        /// </summary>
        public List<EquipmentTypePropTemplate> EquipmentTypePropTemplates { get; set; }

        /// <summary>
        /// 堆垛机处理类
        /// </summary>
        public List<StockerExcute> StockerExcutes { get; set; } = new List<StockerExcute>();

        /// <summary>
        /// 站台处理类
        /// </summary>
        public List<StationExcute> StationExcutes { get; set; } = new List<StationExcute>();

        /// <summary>
        /// 日志监控
        /// </summary>
        public LogInfo LogInfo { get; set; }

        /// <summary>
        /// 堆垛机监控
        /// </summary>
        public StockerMonitor StockerMonitor { get; set; }

        /// <summary>
        /// 站台模型监控类
        /// </summary>
        public List<StationModel> StationModels { get; set; } = new List<StationModel>();

        int tempCount;

        #endregion

        public WinMain()
        {
            InitializeComponent();
        }

        private void Init()
        {
            //时钟初始化
            InitTimer();

            //日志初始化
            Logger.LogWrite += Logger_LogWrite;
            this.WindowState = WindowState.Maximized;
            this.Lab1.Content = $"欢迎：{AppSession.User.UserName}   {DateTime.Now.ToLocalTime()}";
            //日志
            LogInfo = new LogInfo(1350, 600);

            //堆垛机监控
            StockerMonitor = new StockerMonitor(30, 2, false, 1700, 150);
            this.StockerView.Content = StockerMonitor;
            StockerInfo stockerInfo = new StockerInfo(500, 600)
            {
                ControlName = "stocker1"
            };
            stockerInfo.DoubleInEvent += StockerInfo_DoubleInEvent;
            stockerInfo.EmptyOutEvent += StockerInfo_EmptyOutEvent;
            stockerInfo.OverrideTask += StockerInfo_OverrideTask;
            stockerInfo.ForkErrorEvent += StockerInfo_ForkErrorEvent;
            stockerInfo.DeleteTask += StockerInfo_DeleteTask;
            this.EquipmentPanel.Children.Add(stockerInfo);
            //SPMain.Children.Add(stockerInfo);
            this.EquipmentPanel.Children.Add(LogInfo);
            //this.SPMain.Children.Add(LogInfo);

            //LED
            AppSession.LEDExcute.BeginSendInfo();

            #region 基础数据
            var result1 = AppSession.Bll.GetCommonModelByCondition<Equipment>("where disable = 0");
            var result2 = AppSession.Bll.GetCommonModelByCondition<EquipmentProp>("");
            var result3 = AppSession.Bll.GetCommonModelByCondition<EquipmentType>("");
            var result4 = AppSession.Bll.GetCommonModelByCondition<EquipmentTypePropTemplate>("");
            if (!result1.Success || !result2.Success || !result3.Success || !result4.Success)
            {
                MessageBox.Show("初始化设备信息异常");
                Btn_BeginExcute.IsEnabled = false;
                Btn_EndExcute.IsEnabled = false;
                return;
            }
            Equipments = result1.Data;
            EquipmentProps = result2.Data;
            EquipmentTypes = result3.Data;
            EquipmentTypePropTemplates = result4.Data;

            //组合逻辑外键
            Equipments.ForEach(t =>
            {
                t.EquipmentType = EquipmentTypes.FirstOrDefault(i => i.Id == t.EquipmentTypeId);
                t.EquipmentProps.AddRange(EquipmentProps.Where(i => i.EquipmentId == t.Id).ToList());
            });
            EquipmentProps.ForEach(t =>
            {
                t.Equipment = Equipments.FirstOrDefault(i => i.Id == t.EquipmentId);
                //组合地址
                t.Address = $"S7:[{t.Equipment.ConnectName}]{t.Address}";

                t.EquipmentTypePropTemplate = EquipmentTypePropTemplates.FirstOrDefault(i => i.Id == t.EquipmentTypePropTemplateId);
            });
            //判断逻辑外键是否组合完毕
            if (Equipments.Count(t => t.EquipmentType == null || t.EquipmentProps.Count == 0) > 0)
            {
                MessageBox.Show("初始化设备信息失败，请检查基础数据");
                Btn_BeginExcute.IsEnabled = false;
                Btn_EndExcute.IsEnabled = false;
                return;
            }
            //if (EquipmentProps.Count(t => t.Equipment == null || t.EquipmentTypePropTemplate == null) > 0)
            //{
            //    MessageBox.Show("初始化设备属性失败，请检查基础数据");
            //    Btn_BeginExcute.IsEnabled = false;
            //    Btn_EndExcute.IsEnabled = false;
            //    return;
            //}
            //组合站监控类
            Equipments.ForEach(t =>
            {
                if (t.EquipmentType.Code.Contains("Station"))
                {
                    StationModels.Add(new StationModel()
                    {
                        Name = t.Name
                    });
                }
            });
            this.DGStation.ItemsSource = StationModels;

            //组合处理类
            EquipmentTypes.ForEach(t =>
            {
                if (t.Code == "stocker")
                {
                    StockerExcutes.Add(new SingeForkStockerExcute() { EquipmentType = t });
                }
                if (t.Code == "StationForPortOut")
                {
                    StationExcutes.Add(new StationOutExcute() { EquipmentType = t });
                }
                if (t.Code == "StationForPortInOrOut")
                {
                    StationExcutes.Add(new StationInOrOutExcute() { EquipmentType = t });
                }
                if (t.Code == "StationForPortIn")
                {
                    StationExcutes.Add(new StationInExcute() { EquipmentType = t });
                }
                if (t.Code == "StationForStockerIn")
                {
                    StationExcutes.Add(new StationForStockerInExcute() { EquipmentType = t });
                }
                if (t.Code == "StationForStockerOut")
                {
                    StationExcutes.Add(new StationForStockerOutExcute() { EquipmentType = t });
                }
                if (t.Code == "StationForStockerInOrOut")
                {
                    StationExcutes.Add(new StationForStockerInOrOutExcute() { EquipmentType = t });
                }
            });

            #endregion

            #region OPC

            try
            {
                PLCIP = ConfigurationManager.AppSettings["OPCServerIP"];
                PLC = new OPCHelp(PLCIP);
            }
            catch (Exception ex)
            {
                MessageBox.Show("未能获取到OPC配置，请检查。", "注意", MessageBoxButton.OK, MessageBoxImage.Error);
            }

            //组合Dataitem和Plc
            //try
            //{
            //    Equipments.ForEach(t =>
            //    {
            //        if (PLCs.Count(i => i.IP == t.IP) == 0)
            //        {
            //            PLCs.Add(new Plc(CpuType.S71500, t.IP, 0, 1));
            //        }
            //    });
            //    Equipments.ForEach(a => a.EquipmentProps.Where(t => t.EquipmentTypePropTemplate.PropType == "PLC").ToList().ForEach(t =>
            //    {
            //        t.DataItem = S7Helper.FromAddress(t.Address);
            //    }));
            //    //打开PLC
            //    PLCs.ForEach(t => t.Open());
            //}
            //catch (PlcException plcex)
            //{
            //    string error = $"打开通讯连接出现异常:{plcex.Message};请检查网络配置，然后重启本程序！";
            //    MessageBox.Show(error);
            //    Logger.Log(error, LogLevel.Error);
            //    return;
            //}
            //catch (Exception ex)
            //{
            //    MessageBox.Show("组合数据地址时发生错误，请检查数据地址是否配置正确。");
            //    Btn_BeginExcute.IsEnabled = false;
            //    Btn_EndExcute.IsEnabled = false;
            //    return;
            //}

            #endregion

            #region 与WMS心跳
            Task.Run(async () =>
            {
                while (true)
                {
                    await Task.Delay(30000);
                    var temp = AppSession.Bll.HeartBeat();
                    if (!temp.Success)
                    {
                        stop = true;
                        Logger.Log($"与WMS失去连接,请检查网络情况,处理停止:{temp.Msg}", LogLevel.Warning);
                    }
                }
            });
            #endregion

        }


        #region 堆垛机空出、重入、取货错误和重新下发任务

        /// <summary>
        /// 取货错误
        /// </summary>
        /// <param name="stocker"></param>
        /// <returns></returns>
        private BllResult StockerInfo_ForkErrorEvent(Equipment stocker)
        {
            //if (PLCs == null)
            //{
            //    return BllResultFactory.Error(null, "底层通讯未连接");
            //}
            //var plc = PLCs.FirstOrDefault(t => t.IP == stocker.IP);
            //if (plc == null || plc.IsConnected == false || plc.IsAvailable == false)
            //{
            //    return BllResultFactory.Error(null, "底层通讯未连接");
            //}
            if (PLC == null || PLC.GetConnStatus() == false)
            {
                //AddLogToUI("地址读取失败,请检查通讯连接", 2);
                return BllResultFactory.Error(null, "地址读取失败,请检查通讯连接");
            }
            var taskProp = stocker.EquipmentProps.FirstOrDefault(t => t.EquipmentTypePropTemplateCode == "Fork1TaskNo");
            if (taskProp == null)
            {
                return BllResultFactory.Error(null, $"未找到堆垛机{stocker.Name}的任务属性");
            }
            var taskResult = AppSession.Bll.GetCommonModelByCondition<TaskEntity>($"where id = {taskProp.Value}");
            if (taskResult.Success)
            {
                var task = taskResult.Data[0];
                BllResult result = AppSession.Bll.TaskForkErrorHandle(task.Id);
                if (result.Success)
                {
                    //删除当前堆垛机执行的任务
                    var prop = stocker.EquipmentProps.FirstOrDefault(t => t.EquipmentTypePropTemplateCode == "WCSFork1TaskFlag");
                    prop.Value = ForkTaskFlag.删除任务.GetIndexString();
                    //result = S7Helper.PlcSplitWrite(plc, new List<EquipmentProp>() { prop }, 20);
                    result = PLC.WriteAddress(new List<EquipmentProp>() { prop });
                    if (result.Success)
                    {
                        return BllResultFactory.Sucess(null, "成功");
                    }
                    else
                    {
                        Logger.Log($"通知WMS取货错误处理成功，但是下发{stocker}删除任务{task.Id}失败！", LogLevel.Error);
                        return BllResultFactory.Error($"通知WMS取货错误处理成功，但是下发{stocker}删除任务{task.Id}失败！");
                    }
                }
                else
                {
                    return BllResultFactory.Error($"堆垛机{stocker.Name}的任务{task.Id}处理取货错误失败：{result.Msg}");
                }
            }
            else
            {
                return BllResultFactory.Error(null, $"未找到{stocker.Name}对应的任务Id：{taskProp.Value}");
            }
        }

        /// <summary>
        /// 重新下发
        /// </summary>
        /// <param name="stocker"></param>
        /// <returns></returns>
        private BllResult StockerInfo_OverrideTask(Equipment stocker)
        {

            //if (PLCs == null)
            //{
            //    return BllResultFactory.Error(null, "底层通讯未连接");
            //}
            //var plc = PLCs.FirstOrDefault(t => t.IP == stocker.IP);
            //if (plc == null || plc.IsConnected == false || plc.IsAvailable == false)
            //{
            //    return BllResultFactory.Error(null, "底层通讯未连接");
            //}

            if (PLC == null || PLC.GetConnStatus() == false)
            {
                //AddLogToUI("地址读取失败,请检查通讯连接", 2);
                return BllResultFactory.Error(null, "地址读取失败,请检查通讯连接");
            }
            var taskProp = stocker.EquipmentProps.FirstOrDefault(t => t.EquipmentTypePropTemplateCode == "Fork1TaskNo");
            if (taskProp == null)
            {
                return BllResultFactory.Error(null, $"未找到堆垛机{stocker.Name}的任务属性");
            }
            var taskResult = AppSession.Bll.GetCommonModelByCondition<TaskEntity>($"where id = {taskProp.Value}");
            if (taskResult.Success)
            {
                var task = taskResult.Data[0];
                if (task.LastStatus == TaskEntityStatus.下发堆垛机库内取货任务.GetIndexInt() || task.LastStatus == TaskEntityStatus.下发堆垛机库内放货任务.GetIndexInt() || task.LastStatus == TaskEntityStatus.下发堆垛机库外取货任务.GetIndexInt() || task.LastStatus == TaskEntityStatus.下发堆垛机库外放货任务.GetIndexInt())
                {
                    var prop = stocker.EquipmentProps.FirstOrDefault(t => t.EquipmentTypePropTemplateCode == "WCSFork1TaskFlag");
                    prop.Value = ForkTaskFlag.删除任务.GetIndexString();
                    //var result = S7Helper.PlcSplitWrite(plc, new List<EquipmentProp>() { prop }, 20);
                    var result = PLC.WriteAddress(new List<EquipmentProp>() { prop });
                    if (result.Success)
                    {
                        task.SendAgain = 1;
                        result = AppSession.Bll.UpdateCommonModel<TaskEntity>(task);
                        if (result.Success)
                        {
                            return BllResultFactory.Sucess(null, "成功");
                        }
                        else
                        {
                            Logger.Log($"通知{stocker}删除任务{task.Id}成功，但是更新任务重新下发的表示失败！", LogLevel.Error);
                            return BllResultFactory.Error($"通知{stocker}删除任务{task.Id}成功，但是更新任务重新下发的表示失败！");
                        }
                    }
                    else
                    {
                        Logger.Log($"通知{stocker}删除任务{task.Id}失败", LogLevel.Error);
                        return BllResultFactory.Error($"通知{stocker}删除任务{task.Id}失败");
                    }
                }
                else
                {
                    return BllResultFactory.Error(null, $"{stocker.Name}对应的任务Id：{taskProp.Value}任务状态不能重新下发");
                }
            }
            else
            {
                return BllResultFactory.Error(null, $"未找到{stocker.Name}对应的任务Id：{taskProp.Value}");
            }
        }

        /// <summary>
        /// 空出处理
        /// </summary>
        /// <param name="stocker"></param>
        /// <returns></returns>
        private BllResult StockerInfo_EmptyOutEvent(Equipment stocker)
        {

            //if (PLCs == null)
            //{
            //    return BllResultFactory.Error(null, "底层通讯未连接");
            //}
            //var plc = PLCs.FirstOrDefault(t => t.IP == stocker.IP);
            //if (plc == null || plc.IsConnected == false || plc.IsAvailable == false)
            //{
            //    return BllResultFactory.Error(null, "底层通讯未连接");
            //}
            if (PLC == null || PLC.GetConnStatus() == false)
            {
                //AddLogToUI("地址读取失败,请检查通讯连接", 2);
                return BllResultFactory.Error(null, "地址读取失败,请检查通讯连接");
            }
            var taskProp = stocker.EquipmentProps.FirstOrDefault(t => t.EquipmentTypePropTemplateCode == "Fork1TaskNo");
            var emptyOutProp = stocker.EquipmentProps.FirstOrDefault(t => t.EquipmentTypePropTemplateCode == "Fork1EmptyOut");
            if (taskProp == null | emptyOutProp == null)
            {
                return BllResultFactory.Error(null, $"未找到堆垛机{stocker.Name}的任务和空出属性");
            }
            if (emptyOutProp.Value != "True")
            {
                return BllResultFactory.Error(null, $"堆垛机{stocker.Name}未报空出错误");
            }
            var taskResult = AppSession.Bll.GetCommonModelByCondition<TaskEntity>($"where id = {taskProp.Value}");
            if (taskResult.Success)
            {
                var task = taskResult.Data[0];
                if (task.LastStatus < TaskEntityStatus.任务完成.GetIndexInt())
                {
                    var result = AppSession.Bll.EmptyOutHandle(task);
                    if (result.Success)
                    {
                        var prop = stocker.EquipmentProps.FirstOrDefault(t => t.EquipmentTypePropTemplateCode == "WCSFork1TaskFlag");
                        prop.Value = ForkTaskFlag.删除任务.GetIndexString();
                        //result = S7Helper.PlcSplitWrite(plc, new List<EquipmentProp>() { prop }, 20);
                        result = PLC.WriteAddress(new List<EquipmentProp>() { prop });
                        if (result.Success)
                        {
                            return BllResultFactory.Sucess($"空出处理成功");
                        }
                        else
                        {
                            Logger.Log($"通知{stocker}删除任务{task.Id}失败", LogLevel.Error);
                            return BllResultFactory.Error($"空出处理，调用WMS成功但通知{stocker}删除任务{task.Id}失败");
                        }
                    }
                    else
                    {
                        return BllResultFactory.Error($"空出处理调用WMS失败：{result.Msg}");
                    }
                }
                else
                {
                    return BllResultFactory.Error(null, $"{stocker.Name}对应的任务Id：{taskProp.Value}已完成");
                }
            }
            else
            {
                return BllResultFactory.Error(null, $"未找到{stocker.Name}对应的任务Id：{taskProp.Value}");
            }

        }

        /// <summary>
        /// 重入
        /// </summary>
        /// <param name="location"></param>
        /// <param name="stocker"></param>
        /// <returns></returns>
        private BllResult StockerInfo_DoubleInEvent(Location location, Equipment stocker)
        {
            //if (PLCs == null)
            //{
            //    return BllResultFactory.Error(null, "底层通讯未连接");
            //}
            //var plc = PLCs.FirstOrDefault(t => t.IP == stocker.IP);
            //if (plc == null || plc.IsConnected == false || plc.IsAvailable == false)
            //{
            //    return BllResultFactory.Error(null, "底层通讯未连接");
            //}
            if (PLC == null || PLC.GetConnStatus() == false)
            {
                //AddLogToUI("地址读取失败,请检查通讯连接", 2);
                return BllResultFactory.Error(null, "地址读取失败,请检查通讯连接");
            }
            var addresses = stocker.EquipmentProps;
            //获取任务和是否重入
            var taskProp = addresses.FirstOrDefault(t => t.EquipmentTypePropTemplateCode == "Fork1TaskNo");
            var doubleInProp = addresses.FirstOrDefault(t => t.EquipmentTypePropTemplateCode == "Fork1DoubleIn");
            if (taskProp == null || doubleInProp == null)
            {
                return BllResultFactory.Error(null, $"未找到堆垛机{stocker.Name}的任务和重入属性");
            }
            if (doubleInProp.Value != "True")
            {
                return BllResultFactory.Error(null, $"堆垛机{stocker.Name}未报重入错误");
            }
            var taskResult = AppSession.Bll.GetCommonModelByCondition<TaskEntity>($"where id = {taskProp.Value}");
            if (taskResult.Success)
            {
                var task = taskResult.Data[0];

                if (task.LastStatus < TaskEntityStatus.任务完成.GetIndexInt())
                {
                    //按秋生要求，锁上发生重入的库位；
                    var res = AppSession.Bll.UpdateLocationStatus(task.DestinationLocation, AppSession.WarehouseId, "lock");
                    if (!res.Success)
                    {
                        return BllResultFactory.Error(null, $"堆垛机{stocker.Name}锁定重入库位失败；原因:{res.Msg}");
                    }
                    BllResult temp = AppSession.Bll.TaskDoubleInHandle("1", location.Code, task.Id);
                    if (temp.Success)
                    {
                        var excute = StockerExcutes.FirstOrDefault(t => t.EquipmentType.Id == stocker.EquipmentTypeId);
                        BllResult sendResult = excute.SendTaskToStocker(stocker, PLC, ForkAction.货叉1号, ForkTaskFlag.重新分配入库地址, location.RowIndex.ToString(), location.Line.ToString(), location.Layer.ToString(), "0", task.Id.ToString());
                        if (sendResult.Success)
                        {
                            return BllResultFactory.Sucess(null, "成功");
                        }
                        else
                        {
                            //回滚
                            AppSession.Bll.TaskDoubleInHandle("0", "", task.Id);
                            return BllResultFactory.Error(null, $"处理{stocker.Name}重入失败：{sendResult.Msg}");
                        }
                    }
                    else
                    {
                        return BllResultFactory.Error(null, $"处理{stocker.Name}重入失败：{temp.Msg}");
                    }
                }
                else
                {
                    return BllResultFactory.Error(null, $"{stocker.Name}对应的任务Id：{taskProp.Value}已完成");
                }
            }
            else
            {
                return BllResultFactory.Error(null, $"未找到{stocker.Name}对应的任务Id：{taskProp.Value}");
            }
        }

        /// <summary>
        /// 任务删除
        /// </summary>
        /// <param name="stocker"></param>
        /// <returns></returns>
        private BllResult StockerInfo_DeleteTask(Equipment stocker)
        {
            if (PLC == null || PLC.GetConnStatus() == false)
            {
                //AddLogToUI("地址读取失败,请检查通讯连接", 2);
                return BllResultFactory.Error(null, "地址读取失败,请检查通讯连接");
            }
            var taskProp = stocker.EquipmentProps.FirstOrDefault(t => t.EquipmentTypePropTemplateCode == "Fork1TaskNo");
            if (taskProp == null)
            {
                return BllResultFactory.Error(null, $"未找到堆垛机{stocker.Name}的任务属性");
            }
            //var taskResult = AppSession.Bll.GetCommonModelByCondition<TaskEntity>($"where id = {taskProp.Value}");
            //if (taskResult.Success)
            //{
            //var task = taskResult.Data[0];
            var prop = stocker.EquipmentProps.FirstOrDefault(t => t.EquipmentTypePropTemplateCode == "WCSFork1TaskFlag");
            prop.Value = ForkTaskFlag.删除任务.GetIndexString();
            //var result = S7Helper.PlcSplitWrite(plc, new List<EquipmentProp>() { prop }, 20);
            var result = PLC.WriteAddress(new List<EquipmentProp>() { prop });
            if (result.Success)
            {
                return BllResultFactory.Sucess(null, $"删除任务{taskProp.Value}成功");
            }
            else
            {
                Logger.Log($"通知{stocker}删除任务{taskProp.Value}失败", LogLevel.Error);
                return BllResultFactory.Error($"通知{stocker}删除任务{taskProp.Value}失败");
            }
            //}
            //else
            //{
            //    return BllResultFactory.Error(null, $"未找到{stocker.Name}对应的任务Id：{taskProp.Value}");
            //}

        }
        #endregion

        #region 组件

        /// <summary>
        /// 日志记录
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="args"></param>
        private void Logger_LogWrite(object sender, LogEventArgs args)
        {
            Dispatcher.Invoke(() =>
            {
                switch (args.LogLevel)
                {
                    case LogLevel.Info:
                        LogExecute.WriteInfoLog(args.Content);
                        LogInfo.AddLogs(args.Content, 0);
                        break;
                    case LogLevel.Error:
                        LogExecute.WriteInfoLog(args.Content);
                        LogInfo.AddLogs(args.Content, 3);
                        break;
                    case LogLevel.Warning:
                        LogExecute.WriteInfoLog(args.Content);
                        LogInfo.AddLogs(args.Content, 2);
                        break;
                    case LogLevel.Success:
                        LogExecute.WriteInfoLog(args.Content);
                        LogInfo.AddLogs(args.Content, 1);
                        break;
                    case LogLevel.Exception:
                        LogExecute.WriteExceptionLog(args.Content, args.Exception);
                        LogInfo.AddLogs(args.Content, 3);
                        break;
                    default:
                        break;
                }
            });
        }

        #endregion

        #region 时钟逻辑

        private void Timer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
        {
            lock (locker)
            {
                try
                {
                    Stopwatch stopwatch = new Stopwatch();
                    stopwatch.Restart();
                    #region 是否结束处理

                    if (stop)
                    {
                        if (PLC.GetConnStatus())
                        {
                            PLC.CloseConn();
                        }
                        Dispatcher.Invoke(() =>
                        {
                            Btn_BeginExcute.IsEnabled = true;
                            Btn_EndExcute.IsEnabled = false;
                            timer.Enabled = false;
                        });
                        return;
                    }

                    //if (PLCs.Count > 0 && PLCs.Count(t => t.IsAvailable == false || t.IsConnected == false) > 0)
                    //{
                    //    try
                    //    {
                    //        PLCs.ForEach(t => t.Close());
                    //        PLCs.ForEach(t => t.Open());
                    //    }
                    //    catch (Exception ex)
                    //    {
                    //    }
                    //    if (PLCs.Count > 0 && PLCs.Count(t => t.IsAvailable == false || t.IsConnected == false) > 0)
                    //    {
                    //        PLCs = new List<Plc>();
                    //        Equipments.ForEach(t =>
                    //        {
                    //            if (PLCs.Count(i => i.IP == t.IP) == 0)
                    //            {
                    //                PLCs.Add(new Plc(CpuType.S71500, t.IP, 0, 1));
                    //            }
                    //        });
                    //        PLCs.ForEach(t => t.Open());
                    //        if (PLCs.Count > 0 && PLCs.Count(t => t.IsAvailable == false || t.IsConnected == false) > 0)
                    //        {
                    //            Logger.Log($"连接不可用", LogLevel.Error);
                    //            stop = true;
                    //            return;
                    //        }
                    //    }
                    //}

                    //PLCs = new List<Plc>();
                    //Equipments.ForEach(t =>
                    //{
                    //    if (PLCs.Count(i => i.IP == t.IP) == 0)
                    //    {
                    //        PLCs.Add(new Plc(CpuType.S71500, t.IP, 0, 1));
                    //    }
                    //});
                    //PLCs.ForEach(t => t.Open());
                    //if (PLCs.Count > 0 && PLCs.Count(t => t.IsAvailable == false || t.IsConnected == false) > 0)
                    //{
                    //    Logger.Log($"连接不可用", LogLevel.Error);
                    //    stop = true;
                    //    return;
                    //}

                    #endregion

                    #region 检查是否连接正常
                    if (!PLC.GetConnStatus())
                    {
                        Logger.Log($"失去通讯连接，请关闭连接后重新打开", LogLevel.Error);
                        stop = true;
                        return;
                    }

                    #endregion

                    //读取所有地址值
                    //PLCs.ForEach(t => S7Helper.PlcSplitRead(t, Equipments.Where(i => t.IP == t.IP).SelectMany(i => i.EquipmentProps).Where(a => a.EquipmentTypePropTemplate.PropType == "PLC").ToList(), 10));
                    var result = PLC.ReadAddress(Equipments.SelectMany(t => t.EquipmentProps).Where(a => a.EquipmentTypePropTemplate.PropType == "PLC").ToList());
                    if (!result.Success)
                    {
                        Logger.Log($"读取地址错误：{result.Msg},处理停止，请检查网络配置", LogLevel.Error);
                        stop = true;
                        return;
                    }

                    Dispatcher.Invoke(() =>
                    {
                        foreach (var item in this.EquipmentPanel.Children)
                        {
                            if (item is StockerInfo temp)
                            {
                                var a = Equipments.Find(t => t.Code == temp.ControlName);
                                temp.SetProps(a);
                                StockerMonitor.SetStocker(0, int.TryParse(a.EquipmentProps.Find(t => t.EquipmentTypePropTemplateCode == "CurrentColumn").Value, out int column) == true ? column : 0);
                            }
                            //if (item is StationInfo station)
                            //{
                            //    var a = DeviceEntities.Find(t => t.Code == station.Name);
                            //    station.SetProp(DeviceAddressEntities.FindAll(t => t.DeviceId == a.Id));
                            //}
                        }
                        StationModels.ForEach(t => t.SetProp(Equipments.FirstOrDefault(a => a.Name == t.Name)?.EquipmentProps));
                    });

                    #region 堆垛机处理

                    StockerExcutes.ForEach(t =>
                    {
                        //一般根据堆垛机现在的位置来决定优先执行入库还是出库
                        t.Excute(Equipments.Where(a => a.EquipmentType.Id == t.EquipmentType.Id).ToList(), PLC);
                    });

                    #endregion

                    #region 站台处理

                    StationExcutes.ForEach(t =>
                    {
                        List<Equipment> equipments = Equipments.Where(a => a.EquipmentType.Id == t.EquipmentType.Id).ToList();
                        t.Excute(equipments, PLC);
                    });

                    #endregion

                    //给与50毫秒缓冲时间
                    Thread.Sleep(50);
                    //PLCs?.ForEach(t => t.Close());
                    //Logger.Log( stopwatch.Elapsed.ToString(),LogLevel.Info);
                }
                catch (Exception ex)
                {
                    //发生异常，结束处理
                    //stop = true;
                    Logger.Log($"程序处理出现异常：{ex.Message}；", LogLevel.Exception, ex);
                }
            }
        }

        #endregion

        #region 窗体事件

        /// <summary>
        /// 重连WMS
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Btn_ReConnectWMS_Click(object sender, RoutedEventArgs e)
        {
            AppSession.Client = AppSession.InitHttpClient();
            var temp = AppSession.Bll.GetUserWithRoles(AppSession.User.UserCode, AppSession.User.Password);
            if (temp.Success)
            {
                MessageBox.Show("重连成功");
            }
            else
            {
                MessageBox.Show("重连失败");
            }
        }

        private void InitTimer()
        {
            timer.Interval = AppSession.Interval; //1秒触发一次
            timer.Elapsed += Timer_Elapsed; ;
            timer.AutoReset = true;//每到指定时间Elapsed事件是到时间就触发
            timer.Enabled = false; //指示 Timer 是否应引发 Elapsed 事件。
        }

        private void Window_Loaded(object sender, RoutedEventArgs e)
        {
            AppSession.Bll.Combine(AppSession.MenuOperations.Where(t => t.ParentId == null).ToList(), AppSession.Bll.GetAllMenuOperation().Data.Where(t => t.MenuType == "catalog" || t.MenuType == "menu").ToList());
            MenuMain.ItemsSource = AppSession.MenuOperations.Where(t => t.ParentId == null).OrderBy(t => t.OrderNum).ToList();

            //初始化
            Init();

        }

        private void Window_Closed(object sender, EventArgs e)
        {
            stop = true;
            timer.Enabled = false;
            Thread.Sleep(1000);
            Application.Current.Shutdown();
        }

        private void MenuMain_Checked(object sender, RoutedEventArgs e)
        {
            try
            {
                MenuOperation menu = (MenuOperation)((MenuItem)e.OriginalSource).Header;
                var win = ChildrenWin.FirstOrDefault(t => t.Key == menu.Url).Value;
                if (String.IsNullOrWhiteSpace(menu?.Url) || menu.Url == "#")
                {
                    return;
                }
                if (win == null)
                {
                    win = (Window)Activator.CreateInstance(null, menu.Url).Unwrap();
                    ChildrenWin.Add(menu.Url, win);
                }
                win.Show();
                if (win.WindowState == WindowState.Minimized)
                    win.WindowState = WindowState.Normal;
                win.Activate();
            }
            catch (Exception ex)
            {
                LogExecute.WriteExceptionLog("打开菜单", ex);
                MessageBox.Show("打开菜单出现异常！");
            }
        }

        private void Btn_BeginExcute_Click(object sender, RoutedEventArgs e)
        {
            if (PLC == null)
            {
                MessageBox.Show("PLC连接初始化失败！ 请检查PLC配置然后重启本程序", "注意", MessageBoxButton.OK, MessageBoxImage.Error);
                return;
            }
            if (PLC.OpenConn() == false)
            {
                MessageBox.Show("打开PLC连接失败");
                return;
            }
            PLC.CreateGroup("group1");
            PLC.AddOPCItems(Equipments.SelectMany(t => t.EquipmentProps).ToList());
            stop = false;
            timer.Enabled = true;
            Btn_BeginExcute.IsEnabled = false;
            Btn_EndExcute.IsEnabled = true;
        }

        private void Btn_EndExcute_Click(object sender, RoutedEventArgs e)
        {
            stop = true;
            Btn_BeginExcute.IsEnabled = true;
            Btn_EndExcute.IsEnabled = false;
        }


        #endregion

        private void Btn_LED_Click(object sender, RoutedEventArgs e)
        {
            AppSession.LEDExcute.LeftInfoQueue.Enqueue($"左侧计数{tempCount}\\nhjhkhkj\\n\\n\\n\\n\\n\\n\\n\\n\\n\\n\\ndfsdfdfs\\n\\n\\ndfsdf");
            AppSession.LEDExcute.RightInfoQueue.Enqueue($"右侧计数{tempCount}\\nhjhkhkj");
            tempCount++;
        }


    }
}