using log4net;
using OnlineStore.Common;
using OnlineStore.LoadCSVLibrary;
using System;
using System.Collections.Generic;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Timers;

namespace OnlineStore.DeviceLibrary
{
    /// <summary>
    /// 流水线自动料仓-流水线类
    /// </summary>
    public partial class LineBean : KTK_Store
    {
        
        /// <summary>
        /// 是否没有扫到码
        /// </summary>
        public bool isNotScanCode = false;

        /// <summary>
        /// 灯闪烁定时器
        /// </summary>
        private System.Timers.Timer ledProcessTimer = null; 
        /// <summary>
        /// 分出一个线程，专门处理急停，报警，气压检测，工单信号检测等处理
        /// </summary>
        private System.Timers.Timer IoCheckTimer = null;
     
        /// <summary>
        /// 流水线下所有的移载装置
        /// </summary>
        public Dictionary<int, MoveEquip> MoveEquipMap { get; set; }

        public Dictionary <int,FeedingEquip> FeedingEquipMap { get; set; }
        public Dictionary<int, ProvidingEquip> ProvidingEquipMap { get; set; }
        public Dictionary<int, DischargeLine> DisLineMap { get; set; }

        public Dictionary<int ,EquipBase> AllEquipMap { get; set; }

        /// <summary>
        /// 流水线配置
        /// </summary>
        public Line_Config Config { get; set; }

        #region  初始化

        private bool canStart = false;
        public LineBean(Line_Config lineConfig, Dictionary<int, MoveEquip_Config> configList, Dictionary<int, FeedingEquip_Config> feedMap,
            Dictionary<int, ProvidingEquip_Config> providMap, Dictionary<int, DischargeLine_Config> disLineMap)
        {
            if (lineConfig.IOSingle_TimerOut <= 0)
            {
                lineConfig.IOSingle_TimerOut = 5000;
            }
            Init();
            InitTimer();
            baseConfig = lineConfig;
            this.Config = lineConfig;
            this.DeviceID = lineConfig.Id;
            SW41_MoveInfo = new LineMoveInfo(DeviceID, "横移轨道-41");
            SW23_MoveInfo = new LineMoveInfo(DeviceID, "横移轨道-23");
            MoveInfo = new LineMoveInfo(DeviceID, "流水线-Move ");
            Name = (" 流水线_" + Config.CID + " ").ToUpper();

            AllEquipMap = new Dictionary<int, EquipBase>();
            MoveEquipMap = new Dictionary<int, MoveEquip>();
            FeedingEquipMap = new Dictionary<int, FeedingEquip>();
            ProvidingEquipMap = new Dictionary<int, ProvidingEquip>();
            DisLineMap = new Dictionary<int, DischargeLine>();
            List<string> ioList = new List<string>();

            AddDeviceName(ioList, Config.IOIPList);
            foreach (MoveEquip_Config config in configList.Values)
            {
                MoveEquip equip = new MoveEquip(lineConfig.CID, config);

                AddDeviceName(ioList, config.IOIPList);
                MoveEquipMap.Add(config.Id, equip);
                AllEquipMap.Add(config.Id, equip);
            }
            foreach (FeedingEquip_Config config in feedMap.Values)
            {
                FeedingEquip equip = new FeedingEquip(lineConfig.CID, config);

                AddDeviceName(ioList, config.IOIPList);
                FeedingEquipMap.Add(config.Id, equip);
                AllEquipMap.Add(config.Id, equip);
            }
            foreach (ProvidingEquip_Config config in providMap.Values)
            {
                ProvidingEquip equip = new ProvidingEquip(lineConfig.CID, config);

                AddDeviceName(ioList, config.IOIPList);
                ProvidingEquipMap.Add(config.Id, equip);
                AllEquipMap.Add(config.Id, equip);
            }
            foreach (DischargeLine_Config config in disLineMap.Values)
            {
                DischargeLine equip = new DischargeLine(lineConfig.CID, config);

                AddDeviceName(ioList, config.IOIPList);
                DisLineMap.Add(config.Id, equip);
                AllEquipMap.Add(config.Id, equip);
            }
            IOManager.Init();
            //先初始化设备

            //初始化摄像机配置  
            CodeManager.LoadConfig();

            Task.Factory.StartNew(delegate
            {
                //连接rfip
                RFIDManager.ConnectRFIOList(new List<string>(DeviceConfig.ProRFIpMap.Values));
                Thread.Sleep(5);
                IOManager.instance.ConnectionIOList(ioList);
                //Thread.Sleep(10);
                //AIManager.ConnectionIP(Config.AIDevice_IP);

                addLastDI(IO_Type.Airpressure_Check, IOValue(IO_Type.Airpressure_Check));
                addLastDI(IO_Type.SuddenStop_BTN, IOValue(IO_Type.SuddenStop_BTN));
                addLastDI(IO_Type.Reset_BTN, IOValue(IO_Type.Reset_BTN));
                addLastDI(IO_Type.Start_BTN, IOValue(IO_Type.Start_BTN));

                mainTimer.Enabled = true;
                IoCheckTimer.Enabled = true;
                canStart = true;
            });
        }


        private void AddDeviceName(List<string> targetList, List<string> list)
        {
            foreach (string str in list)
            {
                if (!targetList.Contains(str))
                {
                    targetList.Add(str);
                }
            }
        }
        public void InitTimer()
        {

            ledProcessTimer = new System.Timers.Timer();
            ledProcessTimer.Interval = 1000;
            ledProcessTimer.Elapsed += LedProcess;
            ledProcessTimer.AutoReset = true;
            ledProcessTimer.Enabled = false;

            IoCheckTimer = new System.Timers.Timer();
            IoCheckTimer.Interval = 200;
            IoCheckTimer.Elapsed += IoCheckTimerProcess;
            IoCheckTimer.AutoReset = true;
            IoCheckTimer.Enabled = false;
        }

        #endregion

        public override bool StartRun(bool isDebug=false)
        {
            IsScanCode = false;
            if (!canStart)
            {
                SetWarnMsg("启动失败：设备未初始化完成");
                return false;
            }
            if (MoveEquipMap == null)
            {
                SetWarnMsg("启动失败：未加载到移栽信息");
                return false;
            }
            if (IOValue(IO_Type.SuddenStop_BTN).Equals(IO_VALUE.LOW))
            {
                SetWarnMsg("启动失败：急停未开"); 
            }
            else if (IOValue(IO_Type.Airpressure_Check).Equals(IO_VALUE.LOW))
            {
                SetWarnMsg("启动失败：没有气压信号"); 
            }
            else
            {
                LogUtil.info( Name + "开始启动，启动时间：" + StartTime.ToString());
                runStatus = LineRunStatus.HomeMoving;
                StartTime = DateTime.Now;

                LineServer.StartServer(ConfigAppSettings.GetIntValue(Setting_Init.TCPServerPort));
                RHomeOp();

                foreach (MoveEquip moveEquip in this.AllEquipMap.Values)
                {
                    EquipStartRun(moveEquip);
                }
               
                ledProcessTimer.Enabled = true;
                IoCheckTimer.Enabled = true;
                mainTimer.Enabled = true;
                return true;
            }
            return false;
        } 
        private void EquipStartRun(EquipBase moveEquip)
        {
            if (moveEquip.IsDebug)
            {
                moveEquip.OpenStopCylinder();
            }
            else
            {
                bool result = moveEquip.StartRun();
            }

        }
        private void RHomeOp()
        {
            TrayManager.SidesWayStateMap = new Dictionary<int, int>();
            alarmType = LineAlarmType.None;
            mainTimer.Enabled = false;
            IoCheckTimer.Enabled = false;
            isInprocess = false;
            isInSuddenDown = false;
            isNoAirCheck = false;
            alarmType = LineAlarmType.None;
            TrayManager.TrayErrorMsg = "";
            WarnMsg = ""; 
            PreIsHasProcess = true;

            if (TrayManager.ErrorStoreId > 0)
            {
                if (MoveEquipMap.ContainsKey(TrayManager.ErrorStoreId))
                {
                    MoveEquipMap[TrayManager.ErrorStoreId].preTrayNum = 0;
                }
            }
            TrayManager.ErrorStoreId = -1;

            WriteDrivetMotorRun( IO_VALUE.LOW);
            //NG气缸后退
            CylinderMove(null, IO_Type.NGCylinder_Before, IO_Type.NGCylinder_After);

            ////阻挡都上升
            //IOMove(IO_Type.FL_StopCylinder_Down1, IO_VALUE.LOW);
            //IOMove(IO_Type.FL_StopCylinder_Down2, IO_VALUE.LOW);
            //横移轨道下降
            SideWayReset();
        }
      

        public override bool Reset()
        {
            mainTimer.Enabled = false;
            IoCheckTimer.Enabled = false;
            bool isNeedAllReset = false;
            if (isInSuddenDown || isNoAirCheck)
            {
                TrayManager.LineNeedEmptyTrayNum = 0;
                isNeedAllReset = true;
                LogUtil.error( Name + "收到复位信号，在急停中或没有气压中，强制所有设备复位，清理出库需要的托盘数量~");
            }
            else if ((runStatus == LineRunStatus.HomeMoving || runStatus == LineRunStatus.Reset) && alarmType.Equals(LineAlarmType.None))
            {
                LogUtil.error( Name + "收到复位信号，已经在复位或原点返回中，且当前无报警，不处理复位");
                return false;
            }

            //停止运动
            MoveInfo.EndMove(); 

            runStatus = LineRunStatus.Reset;

            //重置通用处理
            RHomeOp();

            foreach (MoveEquip equip in AllEquipMap.Values)
            {
                EquipReset(equip, isNeedAllReset);
            }
            
            IoCheckTimer.Enabled = true;
            mainTimer.Enabled = true;
            return true;
        }
        private void EquipReset(EquipBase equip,bool isNeedAllReset)
        {
            //调试状态不再重置
            if (!equip.IsDebug)
            {
                if (isNeedAllReset || TrayManager.ErrorStoreId.Equals(equip.DeviceID) || (!equip.alarmType.Equals(LineAlarmType.None)))
                {
                    LogUtil.info(Name + "收到复位信号，" + equip.Name + " 需要复位");
                    equip.Reset();
                }
                else
                {
                    LogUtil.info(Name + "收到复位信号，" + equip.Name + " 正常无报警，不需要复位");
                }
            }
            else
            {
                LogUtil.info(Name + "收到复位信号，" + equip.Name + " 调试中，需要下降阻挡气缸");
                equip.OpenStopCylinder();
            }
        }
     

        public override void StopRun()
        {
            IoCheckTimer.Enabled = false; 
            mainTimer.Enabled = false;
            ledProcessTimer.Enabled = false;
             
            //停止运行时，把阻挡气缸上升
            StopMove();
            runStatus = LineRunStatus.Wait;

            LineServer.StopServer();
            TimeSpan span = DateTime.Now - StartTime;
            LogUtil.info( Name + ",停止运行，总运行时间：" + span.ToString());
        }

        public override void Alarm(LineAlarmType alarmType )
        {
            if (this.alarmType.Equals(alarmType))
            {
                return;
            }
           // SaveAlarmInfo(alarmType, alarmDetial, alarmMsg, storeMoveType);
            this.alarmType = alarmType;
            if (alarmType == LineAlarmType.SuddenStop)
            {
                isInSuddenDown = true;
            }
            else if (alarmType.Equals(LineAlarmType.NoAirCheck))
            {
                isNoAirCheck = true;
            }

            if (alarmType == LineAlarmType.SuddenStop || alarmType.Equals(LineAlarmType.NoAirCheck))
            { 
                LogUtil.error(WarnMsg);
                StopMove();
            }
            IOMove(IO_Type.Alarm_HddLed, IO_VALUE.HIGH); 
        }

        #region 休眠处理
        private DateTime LastNoOperateTime = DateTime.Now;
        public bool IsSleep = false;
        private bool PreIsHasProcess = true;
        private bool isHasProcess()
        {
            if (isInSuddenDown || isNoAirCheck)
            {
                return true;
            }
            if (!runStatus.Equals(LineRunStatus.Runing))
            {
                return true;
            }
            if (TrayManager.IsHasFull())
            {
                return true;
            }
            ////判断是否有操作
            //if (IOValue(IO_Type.InStore_TrayCheck1).Equals(IO_VALUE.HIGH) || IOValue(IO_Type.InStore_TrayCheck2).Equals(IO_VALUE.HIGH))
            //{
            //    return true;
            //}
            if (MoveInfo.MoveType.Equals(LineMoveType.None).Equals(false))
            {
                return true;
            }
            if (SW41_MoveInfo.MoveType.Equals(LineMoveType.None).Equals(false))
            {
                return true;
            }
            if (SW23_MoveInfo.MoveType.Equals(LineMoveType.None).Equals(false))
            {
                return true;
            }
            foreach (MoveEquip move in AllEquipMap.Values)
            {
                if (!move.IsDebug && (!move.runStatus.Equals(LineRunStatus.Runing)))
                {
                    return true;
                }
            }
            return false;

        }

        private void WriteDrivetMotorRun(IO_VALUE value)
        {
            IOMove(IO_Type.DriveMotor_Run1, value);
            IOMove(IO_Type.DriveMotor_Run2, value);
            IOMove(IO_Type.DriveMotor_Run3, value);
            IOMove(IO_Type.DriveMotor_Run4, value);
        }
        private void UpdateSleep(bool isS)
        {
            if (isS != IsSleep)
            {
                if (isS)
                {
                    LogUtil.info(Name + "***********更新为休眠状态");
                    WriteDrivetMotorRun(IO_VALUE.LOW);
                }
                else
                {
                    LogUtil.info(Name + "***********更新为工作状态");
                    WriteDrivetMotorRun(IO_VALUE.HIGH);
                }
            }
            IsSleep = isS;
        }
        private void SleepProcess()
        {
            //休眠处理
            //判断所有的盘的都是空盘
            bool isHasO = isHasProcess();

            if (!isHasO)
            {
                if (IsSleep)
                {
                    isNotScanCode = false;
                    return;
                }
                if (PreIsHasProcess.Equals(isHasO))
                {
                    //判断时间是否需要休眠
                    TimeSpan span = DateTime.Now - LastNoOperateTime;
                    if (span.TotalSeconds > Config.Sleep_MSeconds)
                    {
                        LogUtil.info( Name + "***********已经【" + span.TotalSeconds + "】秒没有操作了，开始进入休眠状态");
                        UpdateSleep(true);
                    }
                }
                else
                {
                    PreIsHasProcess = isHasO;
                    LastNoOperateTime = DateTime.Now;
                }
            }
            else
            {
                PreIsHasProcess = isHasO;
                UpdateSleep(false);
            }
        }
        #endregion

        #region 灯光处理 
        private void LedProcess(object sender, ElapsedEventArgs e)
        {
            try
            {
                DateTime time = DateTime.Now;
                SleepProcess();

                //黄灯
                if (isNotScanCode || runStatus.Equals(LineRunStatus.HomeMoving) || runStatus.Equals(LineRunStatus.Reset))
                {
                    //开机执行中时黄灯闪烁
                    if (IsDoValue(IO_Type.RunSign_HddLed, IO_VALUE.HIGH))
                    {
                        IOMove(IO_Type.RunSign_HddLed, IO_VALUE.LOW);
                    }
                    else
                    {
                        IOMove(IO_Type.RunSign_HddLed, IO_VALUE.HIGH);
                    }
                }
                //休眠状态黄灯常亮
                else if (IsSleep)
                {
                    if (IsDoValue(IO_Type.RunSign_HddLed, IO_VALUE.LOW))
                    {
                        IOMove(IO_Type.RunSign_HddLed, IO_VALUE.HIGH);
                    }
                }
                else
                {
                    if (IsDoValue(IO_Type.RunSign_HddLed, IO_VALUE.HIGH))
                    {
                        IOMove(IO_Type.RunSign_HddLed, IO_VALUE.LOW);
                    }
                }

                bool isNeedAlarmLed = false;
                bool isInOut = false;
                if (alarmType.Equals(LineAlarmType.None).Equals(false) || isNoAirCheck || isInSuddenDown || TrayManager.TrayErrorMsg != "")
                {
                    isNeedAlarmLed = true;
                }

                foreach (MoveEquip moveEquip in MoveEquipMap.Values)
                {
                    if (!moveEquip.alarmType.Equals(LineAlarmType.None))
                    {
                        isNeedAlarmLed = true;
                    }
                    if (moveEquip.MoveInfo.MoveType.Equals(LineMoveType.InStore) || moveEquip.MoveInfo.MoveType.Equals(LineMoveType.OutStore))
                    {
                        isInOut = true;
                    }
                }

                //忙碌中，判断是否有移栽在出入库执行，绿灯闪烁
                if (isInOut)
                {
                    if (IsDoValue(IO_Type.AutoRun_HddLed, IO_VALUE.LOW))
                    {
                        IOMove(IO_Type.AutoRun_HddLed, IO_VALUE.HIGH);
                    }
                    else
                    {
                        IOMove(IO_Type.AutoRun_HddLed, IO_VALUE.LOW);
                    }
                }
                else if (IsDoValue(IO_Type.AutoRun_HddLed, IO_VALUE.HIGH))
                {
                    IOMove(IO_Type.AutoRun_HddLed, IO_VALUE.LOW);
                }

                //报警中 ，红灯闪烁
                if (isNeedAlarmLed)
                {
                    if (IsDoValue(IO_Type.Alarm_HddLed, IO_VALUE.LOW))
                    {
                        IOMove(IO_Type.Alarm_HddLed, IO_VALUE.HIGH);
                    }
                    else
                    {
                        IOMove(IO_Type.Alarm_HddLed, IO_VALUE.LOW);
                    }
                }
                else if (IsDoValue(IO_Type.Alarm_HddLed, IO_VALUE.HIGH))
                {
                    IOMove(IO_Type.Alarm_HddLed, IO_VALUE.LOW);
                }

            }
            catch (Exception ex)
            {
                LogUtil.error(Name + "灯处理定时器出错："+ ex.ToString());
            }
            Thread.Sleep(5);
        } 
        #endregion

        private void IoCheckTimerProcess(object sender, ElapsedEventArgs e)
        {
            try
            {
                DateTime time = DateTime.Now;
                if (this.runStatus >= LineRunStatus.HomeMoving)
                {

                    //取新的Io状态
                    IO_VALUE fuweiValue = IOValue(IO_Type.Reset_BTN);
                    IO_VALUE suddenBtn = IOValue(IO_Type.SuddenStop_BTN);
                    IO_VALUE airCheck = IOValue(IO_Type.Airpressure_Check);

                    IO_VALUE lastAir = DILastValueMap[IO_Type.Airpressure_Check];
                    IO_VALUE lastFuwei = DILastValueMap[IO_Type.Reset_BTN];

                    addLastDI(IO_Type.Airpressure_Check, airCheck);
                    addLastDI(IO_Type.SuddenStop_BTN, suddenBtn);
                    addLastDI(IO_Type.Reset_BTN, fuweiValue);

                    //气压检测按钮灭三秒以上才算关闭
                    IO_VALUE airValue = CheckAir(airCheck, lastAir);

                    //急停按钮和气压检测按钮需要一起使用  
                      if (suddenBtn .Equals( IO_VALUE.LOW))
                    {
                        Alarm(LineAlarmType.SuddenStop );
                    }
                    if (fuweiValue.Equals(IO_VALUE.HIGH) && (!fuweiValue.Equals(lastFuwei)))
                    {
                        if (suddenBtn.Equals(IO_VALUE.LOW))
                        {
                            SetWarnMsg("收到复位信号但是急停未开，不处理复位");
                        }
                        else if (airValue.Equals(IO_VALUE.LOW))
                        {
                            SetWarnMsg("收到复位信号但是未检测到气压信号，不处理复位");
                        }
                        else
                        {
                            LogUtil.info( Name + "收到复位信号，开始复位！");
                            Reset();
                        }
                    }

                    //    FeederProcess();

                    //如果驱动电机正转过程中，驱动电机INV1状态 驱动电机INV2状态 有信号，需要报警
                    //if (IOValue(IO_Type.DriveMotor_Run).Equals(IO_VALUE.HIGH))
                    //{
                    //    if (IOValue(IO_Type.DriveMotor_INV1).Equals(IO_VALUE.LOW))
                    //    {
                    //        WarnMsg = "驱动电机INV1状态异常";
                    //        LogUtil.error("驱动电机正转过程中，DriveMotor_INV1 信号LOW，需要报警", 300);
                    //        //Alarm(LineAlarmType.SuddenStop, "1", WarnMsg, LineMoveType.None);

                    //    }
                    //    else if (IOValue(IO_Type.DriveMotor_INV2).Equals(IO_VALUE.LOW))
                    //    {
                    //        WarnMsg = "驱动电机INV2状态异常";
                    //        LogUtil.error("驱动电机正转过程中，DriveMotor_INV2 信号LOW，需要报警", 301);
                    //       // Alarm(LineAlarmType.SuddenStop, "1", WarnMsg, LineMoveType.None);
                    //    }
                    //} 
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(Name + "定时检测报警出错：" + ex.ToString());
            }
            Thread.Sleep(1);
        }
        //public string GetINVMsg()
        //{
        //    if (IOValue(IO_Type.DriveMotor_Run).Equals(IO_VALUE.HIGH))
        //    {
        //        if (IOValue(IO_Type.DriveMotor_INV1).Equals(IO_VALUE.LOW))
        //        {
        //            return "   驱动电机INV1状态异常";
        //        }
        //        else if (IOValue(IO_Type.DriveMotor_INV2).Equals(IO_VALUE.LOW))
        //        {
        //            return "   驱动电机INV2状态异常";
        //        }
        //    }
        //    return "";
        //}
        /// <summary>
        /// 定时处理，监听信号，监听IO
        /// </summary> 
        protected override void mainTimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
        {
            try
            {
                DateTime time = DateTime.Now;
                if (runStatus.Equals(LineRunStatus.Wait))
                {
                    //取新的Io状态
                    IO_VALUE fuweiValue = IOValue(IO_Type.Start_BTN);
                    IO_VALUE lastFuwei = DILastValueMap[IO_Type.Start_BTN];
                    addLastDI(IO_Type.Start_BTN, fuweiValue);
                    bool isAutoStart = ConfigAppSettings.GetIntValue(Setting_Init.App_AutoRun) == 1;

                    //收到复位信号后启动
                    if (isAutoStart && fuweiValue.Equals(IO_VALUE.HIGH) && lastFuwei.Equals(IO_VALUE.LOW))
                    {
                        //没有启动时收到复位按钮，相当于启动按钮
                        LogUtil.info( Name + "没有启动时收到复位按钮，相当于启动按钮，开始调用启动方法！");
                        bool isOk = StartRun();
                        if (!isOk)
                        {
                            LogUtil.error("启动失败，等待下次启动");
                            mainTimer.Enabled = true;
                        }
                    }
                    return;
                }
                //判断急停 
                else if (this.runStatus >= LineRunStatus.HomeMoving)
                {
                    foreach (EquipBase moveEquip in this.AllEquipMap.Values)
                    {
                        if (!moveEquip.IsDebug)
                        {
                            moveEquip.TimerProcess();
                        }
                    }

                    switch (runStatus)
                    {
                        case LineRunStatus.Busy:
                            BusyMoveProcess();
                            break;
                        case LineRunStatus.HomeMoving:
                            ResetProcess();
                            break;
                        case LineRunStatus.Reset:
                            ResetProcess();
                            break;
                        case LineRunStatus.Runing:
                            if ((isInSuddenDown.Equals(false) && isNoAirCheck.Equals(false)))
                            {
                                //出入库定时检测处理
                                InOutTimerProcess();

                                //清理超时异常
                                IOTimeOutProcess();
                            }
                            break;
                        default: break;
                    }

                    SideWayTimerProcess();

                }
            }
            catch (Exception ex)
            {
                LogUtil.error(Name + "主定时器出错：" + ex.ToString());
            }
            Thread.Sleep(1);
        } 
        /// <summary>
        /// 气压检测处理
        /// </summary> 
        private IO_VALUE CheckAir(IO_VALUE airCheck, IO_VALUE lastAir)
        {
            IO_VALUE airValue = IO_VALUE.HIGH;
            if (airCheck == IO_VALUE.LOW && (!isInSuddenDown))
            {
                //判断是否持续了3秒
                if (lastAir == IO_VALUE.LOW)
                {
                    if ((DateTime.Now - lastAirCloseTime).TotalSeconds > Config.AirCheckSeconds)
                    {
                        SetWarnMsg("持续"+Config.AirCheckSeconds+"秒未检测到气压信号");
                        //SendAlarmCode(0, LineAlarm.NoAirCheck);
                        airValue = IO_VALUE.LOW;
                        Alarm(LineAlarmType.NoAirCheck );
                    }
                }
                else
                {
                    lastAirCloseTime = DateTime.Now;
                    isNoAirCheck = false;
                }
            }
            else
            {
                isNoAirCheck = false;
            }
            return airValue;
        }

        #region 扫码枪代码

        /// <summary>
        /// 是否已经扫码
        /// </summary>
        private bool IsScanCode = false;
        private string CodeMsg = "";
        private static string ACCode = "";
        public  void GetCameraCode()
        {
            if (IsInScan())
            {
                LogUtil.info("上次扫码还未执行完毕,请稍后！");
                return;
            }
            Task.Factory.StartNew(delegate
            {

                IsScanCode = true;
                LastScanTime = DateTime.Now;

             
                DateTime date = DateTime.Now;
                //   IOMove(IO_Type.CameraLight_Power, IO_VALUE.HIGH);
              
                List<string> codeList = CodeManager.CameraScan();
                if (codeList.Count <= 0)
                {
                    codeList = CodeManager.CameraScan();
                } 
                List<string> list = new List<string>();
                string outMsg = "";
                string message = "";
                int height = GetHeight();
                int width = GetWidth();
                //= 1 + 123.4x100.5 - 7x12 = CODE  
                foreach (string str in codeList)
                {
                    if (list.Contains(str.Trim()))
                    {
                        continue;
                    }
                    list.Add(str.Trim());
                    //string code = "=1+0x0-" + width + "x" + height + "=" + str.Trim();
                    string code = width + "x" + height + "%3D" + str.Trim();
                    message = message + code + spiltStr;
                }
                if (!outMsg.Equals(""))
                {
                    CodeMsg = "盘尺寸错误，清理二维码【" + message + "】";
                    LogUtil.error("盘尺寸错误，清理二维码【" + message + "】");
                    message = "";
                }
                //  KNDIOMove(IO_Type.CameraLight_Power, IO_VALUE.LOW);
                onCodeReceived( message,height,width);
                IsScanCode = false;
            });
        }

        private string spiltStr = "%23%23";

        private DateTime LastScanTime = DateTime.Now;
        private bool IsInScan()
        {
            if (!IsScanCode)
            {
                return false;
            }
            TimeSpan span = DateTime.Now - LastScanTime;
            if (span.TotalSeconds > 60)
            {
                //大于60秒表示超时了，可以重新开始扫码
                return false;
            }
            return true;
        }
        private void onCodeReceived(string message,int height,int width)
        {
            try
            {
                message = ScanCodeManager.ReplaceCode(message);
                if (String.IsNullOrEmpty(message))
                {
                    isNotScanCode = true;
                    LogUtil.info( Name + "没有收到二维码信息，请重新放入料盘");
                    return;
                }

                isNotScanCode = false;
                if (runStatus.Equals(LineRunStatus.Wait))
                {
                    LogUtil.info( Name + "收到二维码<< " + message + "，暂未开启，不需要发送服务器");
                    return;
                }
                //http://localhost/myproject/service/store/emptyPosForPutin
                //                参数：cids: 多个 cid
                //code: 条码内容
                string server = ConfigAppSettings.GetValue(Setting_Init.http_server) + "?cids=" + LineServer.GetAllCID() + "&code=%3D" + message; 
                LogUtil.info( Name + "收到二维码<< " + message + "，获取入库PosID："+server);

                //发送扫码内容到服务器进行入库操作
                //  Operation operation =LineServer.GetInStoreOperation(message); 
                //   LineGetPosOp op = new LineGetPosOp(LineServer.GetAllCID(), message);

                string resultStr = HttpHelper.Post(server, "");
                LineOperation serverResult = JsonHelper.DeserializeJsonToObject<LineOperation>(resultStr);
                if (serverResult == null)
                {
                    LogUtil.info( Name + "二维码【" + message + "】没有收到服务器反馈！");
                    return;
                }
                else if ((!string.IsNullOrEmpty(serverResult.msg)) || serverResult.result.Equals(0).Equals(false))
                {
                    //如果有提示消息，直接显示提示
                    LogUtil.error( "服务器反馈   二维码【" + message + "】  ：" + serverResult.msg);
                    return;
                }
              
                if (!serverResult.pos.Equals(""))
                { 
                    string posId = serverResult.pos;
                    int plateW = width;
                    int plateH =height;
                    string[] posArray = posId.Split('#');
                    if (!(posArray.Length == 2))
                    {
                        WarnMsg = Name + "入库库位格式错误：二维码【" + message + "】库位【" + posId + "】";
                        LogUtil.error( "服务器反馈   入库库位格式错误：二维码【" + message + "】库位【" + posId + "】");
                        return;
                    }

                    //判断盘是否过高（7*8的盘需要判断，如果盘过高，不让盘通过，直接显示报警信息） 
                    int storeId = int.Parse(posArray[0]);
                    //根据库位号查找移栽
                    MoveEquip moveEquip = MoveEquipMap[storeId];

                    //取盘号
                    string wareNum = serverResult.barcode ;
                    int trayCode = TrayManager.GetTrayNum(0);
                    LogUtil.info( "更新盘空满信息，托盘号【" + trayCode + "】，是否有料盘【" + true + "】,出库入库【" + 1 + "】");
                    TrayManager.UpdateFixtureValue(trayCode, true, ReelType.InStore,wareNum,posId,plateH,plateW);

                    //TODO:判断BOX是否处于可以入库状态，如果调试或急停中，需要返回给服务器；
                    if (LineServer.BoxCanInStore(moveEquip.DeviceID))
                    {
                        InOutParam param = new InOutParam(trayCode, wareNum, posId, plateH, plateW);
                        //  判断PosID是否已经在入库或者在排队列表中，如果已经存在，加入列表失败                         
                        if (IsReviceInPosId(moveEquip, posId))
                        {
                            WarnMsg = moveEquip.Name + "入库库位重复： " + param.ToStr() + " ，入库失败！";
                            moveEquip.WarnMsg = WarnMsg;
                            LogUtil.info( "收到服务器入库命令  " + WarnMsg);
                            return;
                        }



                        LineServer.CheckInStorePos(storeId, param);

                        StartInStoreMove(param);

                    }
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(Name +" "+ ex.ToString());
            }
        }
  

        /// <summary>
        ///是否已经接收到过出库信息
        ///</summary> 
        private bool IsReviceInPosId(MoveEquip moveEquip, string posId)
        {
            bool isReviceInfo = false;
            if (moveEquip.MoveInfo.MoveType.Equals(LineMoveType.InStore) && moveEquip.MoveInfo.MoveParam != null && moveEquip.MoveInfo.MoveParam.PosId.Equals(posId))
            {
                isReviceInfo = true;
            }
            if (!isReviceInfo && moveEquip.waitInStoreList.Count > 0)
            {
                foreach (InOutParam inout in moveEquip.waitInStoreList)
                {
                    if (inout.PosId.Equals(posId) && (!inout.WareCode.Equals("")))
                    {
                        isReviceInfo = true;
                        break;
                    }
                }
            }
            return isReviceInfo;
        }
        #endregion


        public override void StopMove()
        {
            IsScanCode = false;

            foreach (MoveEquip equip in this.AllEquipMap.Values)
            {
                if (!equip.IsDebug)
                {
                    equip.StopRun();
                }
                else
                {
                    equip.CloseCylinderStop();
                }
            }
            MoveInfo.EndMove();

            WriteDrivetMotorRun(  IO_VALUE.LOW);
            IOMove(IO_Type.NGCylinder_After, IO_VALUE.LOW);
            IOMove(IO_Type.NGCylinder_Before, IO_VALUE.LOW);
            IOMove(IO_Type.SW4_MotorRun, IO_VALUE.LOW);
            IOMove(IO_Type.SW4_TopCylinder_Down, IO_VALUE.LOW);
            IOMove(IO_Type.SW4_TopCylinder_Up, IO_VALUE.LOW);
            //IOMove(IO_Type.StopCylinder_Down1, IO_VALUE.LOW);
            //IOMove(IO_Type.StopCylinder_Down2, IO_VALUE.LOW);

            SideWayStop();
        }

        protected override void ResetProcess()
        {
            bool isOk = true;
            //判断是否所有的已经返回完成

            foreach (MoveEquip moveEquip in this.AllEquipMap.Values)
            {
                if ((moveEquip.runStatus.Equals(LineRunStatus.HomeMoving) || moveEquip.runStatus.Equals(LineRunStatus.Reset)) && moveEquip.IsDebug.Equals(false))
                {
                    if (moveEquip.alarmType.Equals(LineAlarmType.None))
                    {
                        isOk = false;
                        break;
                    }
                    else
                    {
                        WarnMsg = moveEquip.Name + "在复位过程中报警，需要重新复位";
                    }
                }
            }
            if (!ResetSingleISOk())
            {
                isOk = false;
            }
            if (isOk)
            {
                PreIsHasProcess = false;
                //打开流水线
                WriteDrivetMotorRun(  IO_VALUE.HIGH);
                //所有原点重置完成
                runStatus = LineRunStatus.Runing;
                LogUtil.info( Name + "所有设备重置完成，打开流水线，开始运转！");
            }
        }
        private bool ResetSingleISOk()
        {
            //气缸需要到位 
            if (IOValue(IO_Type.SW4_TopCylinder_Down).Equals(IO_VALUE.HIGH) &&
                IOValue(IO_Type.NGCylinder_After).Equals(IO_VALUE.HIGH) && 
                    IOValue(IO_Type.SW4_TopCylinder_Up).Equals(IO_VALUE.LOW) &&
                    IOValue(IO_Type.NGCylinder_Before).Equals(IO_VALUE.LOW)
                  )
            {
                return true;
            }
            else
            {
                return false;
            }
        }


        private void SetWarnMsg(string msg)
        {
            WarnMsg = msg;
            LogUtil.error(Name + WarnMsg);
        }
    }
}