using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using DBFactory;
using CommonLib;
using System.Threading;
namespace WcfControlMonitorLib
{
    /// <summary>
    /// Creator:Richard.liu
    /// 解析PLC返回的数据
    /// </summary>
    public  class CParsePLCDataMutiConn
    {
        Dictionary<string, Model.MDevice> _devicesInfo;
        string _ReadSubscription = string.Empty;
        CParsePLCDataMutiConn(string readSubscription)
        {
            _ReadSubscription = readSubscription;
            AddDeviceInfo(_ReadSubscription);
        }
        void AddDeviceInfo(string readSubscription)
        {
            
            sql.Remove(0, sql.Length);
            sql.Append(string.Format("select * from T_Base_Device where F_ReadSubscription='{0}' order by F_DeviceIndex asc", readSubscription));
            DataView dv = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
            for (int i = 0; i < dv.Count; i++)
            {
                Model.MDevice devinfo = new Model.MDevice();
                if (dv[i]["F_AppendBarcode"] == DBNull.Value)
                {
                    devinfo.AppendBarcode = 0;
                }
                else
                {
                    devinfo.AppendBarcode = (int)dv[i]["F_AppendBarcode"];
                }
                if (dv[i]["F_BeDetected"] == DBNull.Value)
                {
                    devinfo.BeDetected = null;
                }
                else
                {
                    devinfo.BeDetected = dv[i]["F_BeDetected"].ToString();
                }
                if (dv[i]["F_BindingDevice"] == DBNull.Value)
                {
                    devinfo.BindingDevice = null;
                }
                else
                {
                    devinfo.BindingDevice = dv[i]["F_BindingDevice"].ToString();
                }
                if (dv[i]["F_BindingDeviceOut"] == DBNull.Value)
                {
                    devinfo.BindingDeviceOut = null;
                }
                else
                {
                    devinfo.BindingDeviceOut = dv[i]["F_BindingDeviceOut"].ToString();
                }
                if (dv[i]["F_CommType"] == DBNull.Value)
                {
                    devinfo.CommType = null;
                }
                else
                {
                    devinfo.CommType = dv[i]["F_CommType"].ToString();
                }

                if (dv[i]["F_DBW1Address"] == DBNull.Value)
                {
                    devinfo.Dbw1Address = -1;
                }
                else
                {
                    devinfo.Dbw1Address = (int)(dv[i]["F_DBW1Address"]);
                }
                if (dv[i]["F_DBWSendLength"] == DBNull.Value)
                {
                    devinfo.Dbw1SendLength = 0;
                }
                else
                {
                    devinfo.Dbw1SendLength = (int)dv[i]["F_DBWSendLength"];
                }
                if (dv[i]["F_DBW2Address"] == DBNull.Value)
                {
                    devinfo.Dbw2Address = -1;
                }
                else
                {
                    devinfo.Dbw2Address = (int)dv[i]["F_DBW2Address"];
                }
                if (dv[i]["F_DBWGetLength"] == DBNull.Value)
                {
                    devinfo.Dbw2Getlength = 0;
                }
                else
                {
                    devinfo.Dbw2Getlength = (decimal)dv[i]["F_DBWGetLength"];
                }
                if (dv[i]["F_DeviceIndex"] == DBNull.Value)
                {
                    devinfo.DeviceIndex = 0;
                }
                else
                {
                    devinfo.DeviceIndex = (int)dv[i]["F_DeviceIndex"];
                }
                if (dv[i]["F_DeviceKindIndex"] == DBNull.Value)
                {
                    devinfo.DeviceKind = 0;
                }
                else
                {
                    devinfo.DeviceKind = (int)dv[i]["F_DeviceKindIndex"];
                }
                if (dv[i]["F_DeviceName"] == DBNull.Value)
                {
                    devinfo.DeviceName = null;
                }
                else
                {
                    devinfo.DeviceName = (string)dv[i]["F_DeviceName"];
                }
                if (dv[i]["F_DeviceVisual"] == DBNull.Value)
                {
                    devinfo.DeviceVisual = 0;
                }
                else
                {
                    devinfo.DeviceVisual = (int)dv[i]["F_DeviceVisual"];
                }
                if (dv[i]["F_KeyDevice"] == DBNull.Value)
                {
                    devinfo.IfKeyDevice = '0';

                }
                else
                {
                    devinfo.IfKeyDevice = Convert.ToChar(dv[i]["F_KeyDevice"]);
                }
                if (dv[i]["F_MaxSendCount"] == DBNull.Value)
                {
                    devinfo.MaxSendCount = 0;
                }
                else
                {
                    devinfo.MaxSendCount = (int)dv[i]["F_MaxSendCount"];
                }
                if (dv[i]["F_NeedOptimize"] == DBNull.Value)
                {
                    devinfo.NeedOptimize = '0';
                }
                else
                {
                    devinfo.NeedOptimize = Convert.ToChar(dv[i]["F_NeedOptimize"]);
                }
                if (dv[i]["F_SendInterval"] == DBNull.Value)
                {
                    devinfo.SendInterval = 0;
                }
                else
                {
                    devinfo.SendInterval = (int)dv[i]["F_SendInterval"];
                }
                if (dv[i]["F_LocalIP"] == DBNull.Value)
                {
                    devinfo.LocalIP = "";
                }
                else
                {
                    devinfo.LocalIP = (string)dv[i]["F_LocalIP"];
                }
                if (dv[i]["F_LocalPort"] == DBNull.Value)
                {
                    devinfo.LocalPort = 0;
                }
                else
                {
                    devinfo.LocalPort = (int)dv[i]["F_LocalPort"];
                }
                if (dv[i]["F_RemoteIP"] == DBNull.Value)
                {
                    devinfo.RemoteIP = "";
                }
                else
                {
                    devinfo.RemoteIP = (string)dv[i]["F_RemoteIP"];
                }
                if (dv[i]["F_RemotePort"] == DBNull.Value)
                {
                    devinfo.RemotePort = 0;
                }
                else
                {
                    devinfo.RemotePort = (int)dv[i]["F_RemotePort"];
                }
                if (dv[i]["F_OPCProgID"] == DBNull.Value)
                {
                    devinfo.OPCProgID = "";
                }
                else
                {
                    devinfo.OPCProgID = (string)dv[i]["F_OPCProgID"];
                }
                if (dv[i]["F_ErrorTaskNo"] == DBNull.Value)
                {
                    devinfo.ErrorTaskNo = 0;
                }
                else
                {
                    devinfo.ErrorTaskNo = (int)dv[i]["F_ErrorTaskNo"];
                }
                if (dv[i]["F_SendOutDetect"] == DBNull.Value)
                {
                    devinfo.SendOutDetect = "0";
                }
                else
                {
                    devinfo.SendOutDetect = dv[i]["F_SendOutDetect"].ToString();
                }
                //
                if (dv[i]["F_OnlyDetectIO"] == DBNull.Value)
                {
                    devinfo.OnlyDetectIO = "0";
                }
                else
                {
                    devinfo.OnlyDetectIO = dv[i]["F_OnlyDetectIO"].ToString();
                }
                if (dv[i]["F_UseCommonDB"] == DBNull.Value)
                {
                    devinfo.UseCommonDB = "0";
                }
                else
                {
                    devinfo.UseCommonDB = dv[i]["F_UseCommonDB"].ToString();
                }
                if (dv[i]["F_IfCorrelDoubleFork"] == DBNull.Value)
                {
                    devinfo.IfCorrelDoubleFork = "0";
                }
                else
                {
                    devinfo.IfCorrelDoubleFork = dv[i]["F_IfCorrelDoubleFork"].ToString();
                }
                
                if (dv[i]["F_DoubleFork"] == DBNull.Value)
                {
                    devinfo.DoubleFork = "0";
                }
                else
                {
                    devinfo.DoubleFork = dv[i]["F_DoubleFork"].ToString();
                }
                //20100609
                if (dv[i]["F_SerialPort"] == DBNull.Value)
                {
                    devinfo.SerialPort = 0;
                }
                else
                {
                    devinfo.SerialPort = Convert.ToInt32(dv[i]["F_SerialPort"]);
                }
                //20100609
                if (dv[i]["F_CommSettings"] == DBNull.Value)
                {
                    devinfo.CommSettings = "0";
                }
                else
                {
                    devinfo.CommSettings = dv[i]["F_CommSettings"].ToString();
                }
                //20100714
                if (dv[i]["F_S7Connection"] == DBNull.Value)
                {
                    devinfo.S7Connection = "S7:[S7 connection_1]";
                }
                else
                {
                    devinfo.S7Connection = dv[i]["F_S7Connection"].ToString();
                }
                //20101118
                if (dv[i]["F_SplitByte"] == DBNull.Value)
                {
                    devinfo.SplitByte = -1;
                }
                else
                {
                    devinfo.SplitByte = Convert.ToInt32(dv[i]["F_SplitByte"]);
                }
                if (dv[i]["F_ManTaskReserve"] == DBNull.Value)
                {
                    devinfo.ManTaskReserve = 0;
                }
                else
                {
                    devinfo.ManTaskReserve = Convert.ToInt32(dv[i]["F_ManTaskReserve"]);
                }
                if (dv[i]["F_HaveGoods"] == DBNull.Value)
                {
                    devinfo.LogicHaveGoods = false;
                }
                else
                {
                    devinfo.LogicHaveGoods = Convert.ToInt32(dv[i]["F_HaveGoods"]) == 1 ? true : false;
                }
                if (dv[i]["F_ReadSubscription"] == DBNull.Value)
                {
                    devinfo.ReadSubscription = "0";
                }
                else
                {
                    devinfo.ReadSubscription = dv[i]["F_ReadSubscription"].ToString();
                }
                if (_devicesInfo.ContainsKey(readSubscription) == false)
                {
                    _devicesInfo.Add(readSubscription, devinfo);
                }

            }
        }
        public static event CDeviceStateChangeEventHandler DeviceStateChange;
        public static void OnDeviceStateChange(object sender,CDeviceStateChangeEventArgs e)
        {
            System.Object lockThis = new System.Object();
            lock (lockThis)
            {

                if (DeviceStateChange != null)
                {
                    DeviceStateChange(sender, e);
                }
            }
        }
        int[] AllReturns;//20110216
        /// <summary>
        /// 20110216根据S7Connection标识反馈所有DB2数据的虚拟设备的起始数据区地址
        /// </summary>
        /// <param name="sb">S7Connection标识</param>
        /// <returns></returns>
        int GetDevice28KindDBW2Address(StringBuilder sb)
        {
            DataView dv = dbo.ExceSQL("SELECT F_DBW2Address  FROM T_Base_Device WHERE (F_DeviceKindIndex = 28 and F_S7Connection='" + sb.ToString() + "')").Tables[0].DefaultView;
            if (dv.Count > 0)
            {
                return Convert.ToInt32(dv[0]["F_DBW2Address"]);
            }
            else
            {
                return 0;
            }
        }
        StringBuilder sql = new StringBuilder();
        char[] dd = new char[1] { '.' };//20101124
        string[] sp ;//20101124
        string _CParsePLCError = "";//监控调度类错误说明
        public  string CParsePLCError
        {
            get { return _CParsePLCError; }
            set { _CParsePLCError = value; }
        }
        DBOperator dbo = new DBOperator();
        DBOperator dboRoute = new DBOperator();
        DBOperator dboMan = new DBOperator("ManConnString", "ManDBFactory");
        Thread mythread;
        bool exitThread = false;//20091107
        private  void BeginListen()
        {//20091107
            while (!exitThread  )
            {
                try
                {
                    string dt = DateTime.Now.Second.ToString() + "-" + DateTime.Now.Millisecond.ToString();
                    SetDeviceState();
                    string dt1 = DateTime.Now.Second.ToString() + "-" + DateTime.Now.Millisecond.ToString();
                    
                }
                catch (Exception ex)
                {
                    _CParsePLCError = ex.Message;
                }
                //Thread.Sleep(200);//20100710
            }
        }
        public  void EndListen()
        {//20091107
            exitThread = true;

            if (mythread != null)
            {

                mythread.Abort();
                mythread = null;
            }
            
            
        }
        public  void StartListen()
        {
            //20091107
            exitThread = false;
            mythread = new Thread(new ThreadStart(BeginListen));
            mythread.IsBackground = true;
            mythread.Start();
            //mythreadRoute = new Thread(new ThreadStart(BeginListenRoute));
            //mythreadRoute.IsBackground = true;
            //mythreadRoute.Start();
        }
        /// <summary>
        /// 取得指定光电开关（确认按钮）设备索引的信号（0，1）
        /// </summary>
        /// <param name="deviceIdx">设备索引</param>
        /// <returns>0，1</returns>
        public  int GetDevicePhotoelectric(string S7Connection, int deviceIdx)
        {
            TimeSpan dt = DateTime.Now.TimeOfDay;
            try
            {
                //20110216
                AllReturns = CStaticClass.MutiReadSubscriptionDeviceStateReturns[S7Connection];
                if (AllReturns != null)
                {
                    #region 获取开关量的值

                    sql.Remove(0, sql.Length);
                    sql.Append("SELECT F_DeviceIndex, F_DeviceKindIndex,F_DBWGetLength,").Append(
                        " F_DBW2Address,F_S7Connection FROM T_Base_Device WHERE ((F_DeviceKindIndex = 14)").Append(
                        " OR (F_DeviceKindIndex = 18)) and (F_DBW2Address is not NULL) and F_DeviceIndex=").Append(deviceIdx);
                    DataView dvle = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                    //devinfo = Model.CGetInfo.GetDeviceInfo(deviceIdx);

                    int glen = 0;
                    int IfVis = 0;
                    if (dvle.Count > 0)//(devinfo.DeviceKind == 14) || (devinfo.DeviceKind == 18)
                    {
                        //20110216
                        int temp = Convert.ToInt32(dvle[0]["F_DBW2Address"]) - GetDevice28KindDBW2Address(new StringBuilder(dvle[0]["F_S7Connection"].ToString()));
                        if (Convert.ToInt32((Convert.ToDecimal(dvle[0]["F_DBWGetLength"]) * 8 - 1)) > 7)//devinfo.Dbw2Getlength
                        {
                            glen = Convert.ToInt32((Convert.ToDecimal(dvle[0]["F_DBWGetLength"]) * 8 - 1)) - 8;
                            temp = temp + 1;
                        }
                        else
                        {
                            glen = Convert.ToInt32((Convert.ToDecimal(dvle[0]["F_DBWGetLength"]) * 8 - 1));
                        }
                        if (temp >= 0)
                        {
                            IfVis = CommonClassLib.CCarryConvert.GetBitFromInteger(AllReturns[temp], glen);
                            //if (dvle[0]["F_DeviceKindIndex"].ToString() == "18")
                            //{//配合孙宇光电开关0有探物，1无探物，在这里取反符合正常逻辑
                            //    if (IfVis == 1)
                            //    {
                            //        IfVis = 0;
                            //    }
                            //    else
                            //    {
                            //        IfVis = 1;
                            //    }
                            //}
                            return IfVis;
                        }
                        else
                        {
                            return -1;
                        }

                    }
                    else
                    {
                        return -1;
                    }


                    #endregion


                }
                else
                {
                    return -1;
                }

            }
            catch //(Exception ex)
            {
                //if (FrmControlMonitor.FormInstance.GetObjectText("tsStatus").IndexOf("取得指定光电开关的信号时：" + ex.Message) < 0)
                //{

                //    FrmControlMonitor.FormInstance.FlashPanit("tsStatus", "取得指定光电开关的信号时：" + ex.Message, true);
                //}
                return -1;
            }
            finally
            {
                TimeSpan dt1 = DateTime.Now.TimeOfDay;
            }
        }
        /// <summary>
        /// 20101118根据设备号和bit位，取得F_SplitByte里的光电bit值：0,1
        /// </summary>
        /// <param name="deviceIdx"></param>
        /// <param name="bit"></param>
        /// <returns></returns>
        public  int GetDevicePhotoelectric(string S7Connection, int deviceIdx, int abit)
        {
            TimeSpan dt = DateTime.Now.TimeOfDay;
            try
            {
                //20110216
                AllReturns = CStaticClass.MutiReadSubscriptionDeviceStateReturns[S7Connection];
                if (AllReturns != null)
                {
                    #region 获取开关量的值

                    sql.Remove(0, sql.Length);
                    sql.Append("SELECT F_SplitByte,F_S7Connection  FROM T_Base_Device WHERE  F_DeviceIndex=").Append(deviceIdx).Append(" and F_SplitByte>=0");
                    DataView dvle = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;

                    int glen = 0;
                    int IfVis = 0;
                    if (dvle.Count > 0)
                    {
                        //20110216
                        int temp = Convert.ToInt32(dvle[0]["F_SplitByte"]) - GetDevice28KindDBW2Address(new StringBuilder(dvle[0]["F_S7Connection"].ToString()));
                        if (abit > 7)
                        {
                            glen = abit - 8;
                            temp = temp + 1;
                        }
                        else
                        {
                            glen = abit;
                        }
                        if (temp >= 0)
                        {
                            IfVis = CommonClassLib.CCarryConvert.GetBitFromInteger(AllReturns[temp], glen);
                            //if (dvle[0]["F_DeviceKindIndex"].ToString() == "18")
                            //{//配合孙宇光电开关0有探物，1无探物，在这里取反符合正常逻辑
                            //    if (IfVis == 1)
                            //    {
                            //        IfVis = 0;
                            //    }
                            //    else
                            //    {
                            //        IfVis = 1;
                            //    }
                            //}
                            return IfVis;
                        }
                        else
                        {
                            return -1;
                        }

                    }
                    else
                    {
                        return -1;
                    }


                    #endregion


                }
                else
                {
                    return -1;
                }

            }
            catch
            {

                return -1;
            }
            finally
            {
                TimeSpan dt1 = DateTime.Now.TimeOfDay;
            }
        }
        /// <summary>
        /// //20101124根据【设备号.bit位】的字符串，取得F_SplitByte里的光电bit值：0,1
        /// </summary>
        /// <param name="deviceIdx"></param>
        /// <param name="bit"></param>
        /// <returns></returns>
        public  int GetDevicePhotoelectric(string S7Connection, string devicebit)
        {
            TimeSpan dt = DateTime.Now.TimeOfDay;
            sp = devicebit.Split(dd);
            if (sp.GetLength(0) <= 1) return -1;
            int deviceIdx, abit;
            int.TryParse(sp[0], out deviceIdx);
            int.TryParse(sp[1], out abit);
            try
            {
                //20110216
                AllReturns = CStaticClass.MutiReadSubscriptionDeviceStateReturns[S7Connection];
                if (AllReturns != null)
                {
                    #region 获取开关量的值


                    sql.Remove(0, sql.Length);
                    sql.Append("SELECT F_SplitByte,F_S7Connection  FROM T_Base_Device WHERE  F_DeviceIndex=").Append(deviceIdx).Append(" and F_SplitByte>=0");
                    DataView dvle = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;

                    int glen = 0;
                    int IfVis = 0;
                    if (dvle.Count > 0)
                    {
                        //20110216
                        
                        int temp = Convert.ToInt32(dvle[0]["F_SplitByte"]) - GetDevice28KindDBW2Address(new StringBuilder(dvle[0]["F_S7Connection"].ToString()));
                        if (abit > 7)
                        {
                            glen = abit - 8;
                            temp = temp + 1;
                        }
                        else
                        {
                            glen = abit;
                        }
                        if (temp >= 0)
                        {
                            IfVis = CommonClassLib.CCarryConvert.GetBitFromInteger(AllReturns[temp], glen);
                            //if (dvle[0]["F_DeviceKindIndex"].ToString() == "18")
                            //{//配合孙宇光电开关0有探物，1无探物，在这里取反符合正常逻辑
                            //    if (IfVis == 1)
                            //    {
                            //        IfVis = 0;
                            //    }
                            //    else
                            //    {
                            //        IfVis = 1;
                            //    }
                            //}
                            return IfVis;
                        }
                        else
                        {
                            return -1;
                        }

                    }
                    else
                    {
                        return -1;
                    }


                    #endregion


                }
                else
                {
                    return -1;
                }

            }
            catch (Exception ex)
            {
                CParsePLCError = "取得指定光电开关的信号时：" + ex.Message;

                return -1;
            }
            finally
            {
                TimeSpan dtt = DateTime.Now.TimeOfDay;
            }
        }
        /// <summary>
        /// 取得指定设备索引的设备状态:[0]读写标志;[1]状态;[2]任务号；[3]X坐标;[4]Y坐标;[5]设备索引
        /// </summary>
        /// <param name="deviceIdx">设备索引</param>
        /// <returns></returns>
        public  int[] GetDeviceState(string S7Connection,int deviceIdx)
        {TimeSpan dt0 = DateTime.Now.TimeOfDay;
        TimeSpan dt1;
        TimeSpan dt2 ;
            try
            {
                

                //20110216
                
                dt1 = DateTime.Now.TimeOfDay;
                AllReturns = CStaticClass.MutiReadSubscriptionDeviceStateReturns[S7Connection];
                dt2 = DateTime.Now.TimeOfDay;
                if (AllReturns != null)
                {
                    #region 获取设备状态
                    sql.Remove(0, sql.Length);
                    sql.Append("SELECT F_DeviceIndex, F_DeviceKindIndex,F_DBWGetLength,").Append(
                        " F_DBW2Address,F_S7Connection FROM T_Base_Device WHERE (F_DBW2Address is not NULL) and F_DeviceIndex=").Append(deviceIdx);
                    DataView dvle = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                    //devinfo = Model.CGetInfo.GetDeviceInfo(deviceIdx);

                    if (dvle.Count > 0)//devinfo.Dbw2Address != -1
                    {
                        //20110216
                        int temp = Convert.ToInt32(dvle[0]["F_DBW2Address"]) - GetDevice28KindDBW2Address(new StringBuilder(dvle[0]["F_S7Connection"].ToString()));
                        decimal glen = Convert.ToDecimal(dvle[0]["F_DBWGetLength"]);//devinfo.Dbw2Getlength
                        int[] states = new int[6];
                        switch (dvle[0]["F_DeviceKindIndex"].ToString())//devinfo.DeviceKind.ToString()
                        {

                            #region 其他设备
                            case "1"://堆垛机

                                states[0] = AllReturns[temp];//读写标志
                                states[1] = AllReturns[temp + 1];//状态
                                states[2] = (AllReturns[temp + 2] << 8) + AllReturns[temp + 3];//任务号
                                states[3] = AllReturns[temp + 7] + (AllReturns[temp + 6] << 8) + (AllReturns[temp + 5] << 16) + (AllReturns[temp + 4] << 32);//X坐标
                                states[4] = AllReturns[temp + 11] + (AllReturns[temp + 10] << 8) + (AllReturns[temp + 9] << 16) + (AllReturns[temp + 8] << 32);//Y坐标
                                states[5] = deviceIdx;//设备号索引

                                break;
                            case "2"://输送机
                                states[0] = AllReturns[temp];//读写标志
                                states[1] = AllReturns[temp + 1];//状态
                                states[2] = (AllReturns[temp + 2] << 8) + AllReturns[temp + 3];//任务号
                                states[3] = 0;
                                states[4] = 0;
                                states[5] = deviceIdx;//设备号索引

                                break;
                            case "4"://RGV
                                states[0] = AllReturns[temp];//读写标志
                                states[1] = AllReturns[temp + 1];//状态
                                states[2] = (AllReturns[temp + 2] << 8) + AllReturns[temp + 3];//任务号
                                states[3] = AllReturns[temp + 7] + (AllReturns[temp + 6] << 8) + (AllReturns[temp + 5] << 16) + (AllReturns[temp + 4] << 32);//X坐标
                                states[4] = 0;
                                states[5] = deviceIdx;//设备号索引

                                break;
                            #endregion
                        }


                        return states;
                    }
                    else
                    {
                        return null;
                    }


                    #endregion


                }
                else
                {
                    return null;
                }

            }
            catch //(Exception ex)
            {
                //if (FrmControlMonitor.FormInstance.GetObjectText("tsStatus").IndexOf("取得指定光电开关的信号时：" + ex.Message) < 0)
                //{

                //    FrmControlMonitor.FormInstance.FlashPanit("tsStatus", "取得指定光电开关的信号时：" + ex.Message, true);
                //}
                return null;
            }
            finally
            {
                
            }
        }
        /// <summary>
        /// 设置所有设备的当前动态属性
        /// </summary>
        public  void SetDeviceState()
        {
            try
            {
                
                
                bool updateroute = false;
                if (CStaticClass.routetime.AddSeconds(30) <= DateTime.Now)
                {
                    updateroute = true;
                    CStaticClass.routetime = DateTime.Now;
                }
                
                int[] States;
                foreach (Model.MDevice devinfo1 in _devicesInfo.Values)
                {
                    if (devinfo1.DeviceKind >= 6 && devinfo1.DeviceKind <= 30) continue;
                    string   dt = DateTime.Now.Second.ToString()+"-"+DateTime.Now.Millisecond.ToString();
                    string dt0; string dt1; string dtt;
                    #region 设备被停用
                    
                    sql.Remove(0, sql.Length);
                    sql.Append("SELECT F_DeviceIndex FROM T_Base_Device WHERE (F_LockedState = - 1) and F_DeviceIndex=").Append(devinfo1.DeviceIndex);
                    DataView dvv = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                    if (dvv.Count > 0)
                    {
                        if (updateroute == true)
                        {//20100131
                            UpdateErrorCode(devinfo1.DeviceIndex, 98);
                            AlterRoute(devinfo1.DeviceIndex, 98);
                        }
                        //20090926
                        if (devinfo1.ErrorCode != 98)
                        {
                            UpdateErrorCode(devinfo1.DeviceIndex, 98);
                            AlterRoute(devinfo1.DeviceIndex, 98);
                            devinfo1.RunState = 4;

                        }
                        devinfo1.ErrorCode = 98;
                    }

                    #endregion

                    else
                    {
                        #region 光电开关类（仅延吉有）新版已经取消
                        
                        if ((devinfo1.DeviceKind == 14) || (devinfo1.DeviceKind == 18))
                        {
                            devinfo1.DeviceVisual = GetDevicePhotoelectric(devinfo1.S7Connection,devinfo1.DeviceIndex);
                            continue;
                        }

                        #endregion

                        #region 输送机类

                        if ((devinfo1.DeviceKind == 2) || (devinfo1.DeviceKind == 3) || (devinfo1.DeviceKind == 5)  )
                        {
                            //有些输送机、提升机在调度路径中存在，但是不需要调度来下指令，电器自己控制，只考察是否运行和故障位就可以了
                            if (devinfo1.OnlyDetectIO == "1")
                            {
                                
                                #region 运行位（设备索引+7）
                                devinfo1.RunState = GetDevicePhotoelectric(devinfo1.S7Connection, Convert.ToInt32(devinfo1.DeviceIndex.ToString() + "7"));
                                if (updateroute == true)
                                {//20100131
                                    UpdateErrorCode(devinfo1.DeviceIndex, 0); 
                                    AlterRoute(devinfo1.DeviceIndex, 0);
                                }
                                if (devinfo1.ErrorCode != 0)
                                {
                                    AlterRoute(devinfo1.DeviceIndex, 0);
                                }
                                //20090926
                                int err = 0;
                                //devinfo1.ErrorCode = 0;
                                #endregion

                                

                                #region 故障位（设备索引+6）
                                if (GetDevicePhotoelectric(devinfo1.S7Connection, Convert.ToInt32(devinfo1.DeviceIndex.ToString() + "6")) == 1)
                                {
                                    if (updateroute == true)
                                    {//20100131
                                        UpdateErrorCode(devinfo1.DeviceIndex, 97);
                                        AlterRoute(devinfo1.DeviceIndex, 97);
                                    }
                                    devinfo1.RunState = 2;
                                    if (devinfo1.ErrorCode != 97)
                                    {
                                        UpdateErrorCode(devinfo1.DeviceIndex, 97);
                                        AlterRoute(devinfo1.DeviceIndex, 97);
                                    }
                                    err = 97;
                                    //devinfo1.ErrorCode = 97;
                                                                   
                                }
                                
                                //20100131
                                if (updateroute == true)
                                {//20100131
                                    UpdateErrorCode(devinfo1.DeviceIndex, err);
                                    AlterRoute(devinfo1.DeviceIndex, err);
                                }
                                if (devinfo1.ErrorCode != err)
                                {
                                    UpdateErrorCode(devinfo1.DeviceIndex, err);
                                    AlterRoute(devinfo1.DeviceIndex, err);
                                }
                                //20100131


                                devinfo1.ErrorCode = err;
                                //20090926

                                #endregion

                                
                            }
                            else
                            {

                                States = GetDeviceState(devinfo1.S7Connection, devinfo1.DeviceIndex);
                                if (States == null) continue;
                                
                                if (States[1] >= 30)
                                {
                                    if (updateroute == true)
                                    {//20100131
                                        UpdateErrorCode(devinfo1.DeviceIndex, States[1]);
                                        AlterRoute(devinfo1.DeviceIndex, States[1]);
                                    }
                                    //20100131
                                    
                                    //修改路径表
                                    if (States[1] != devinfo1.ErrorCode)
                                    {
                                        UpdateErrorCode(devinfo1.DeviceIndex, States[1]);
                                        AlterRoute(devinfo1.DeviceIndex, States[1]);
                                    }
                                    
                                    devinfo1.ErrorCode = States[1];
                                    devinfo1.RunState = 2;
                                }

                                else if ((States[1] == 0) || (States[1] == 1) || (States[1] == 2))
                                {
                                    if (updateroute == true)
                                    {//20100131
                                        UpdateErrorCode(devinfo1.DeviceIndex, 0);
                                        AlterRoute(devinfo1.DeviceIndex, States[1]);
                                    }
                                    //20100131
                                    
                                    //修改路径表
                                    if (States[1] != devinfo1.ErrorCode)
                                    {
                                        UpdateErrorCode(devinfo1.DeviceIndex, 0);
                                        AlterRoute(devinfo1.DeviceIndex, States[1]);
                                    }
                                    //20090926
                                    
                                    if (States[1] == 2)
                                    {
                                        //20090920
                                        devinfo1.RunState = 5;
                                    }
                                    else
                                    {
                                        devinfo1.RunState = States[1];
                                    }
                                    //20100131
                                    

                                    //20091006
                                    devinfo1.ErrorCode = States[1];
                                    //20090926
                                }
                                devinfo1.TaskNo = States[2];
                                //20101118
                                if (devinfo1.SplitByte != -1)
                                {
                                    devinfo1.SplitByte_0 = GetDevicePhotoelectric(devinfo1.S7Connection, devinfo1.DeviceIndex, 0);
                                    devinfo1.SplitByte_1 = GetDevicePhotoelectric(devinfo1.S7Connection, devinfo1.DeviceIndex, 1);
                                    devinfo1.SplitByte_2 = GetDevicePhotoelectric(devinfo1.S7Connection, devinfo1.DeviceIndex, 2);
                                    devinfo1.SplitByte_3 = GetDevicePhotoelectric(devinfo1.S7Connection, devinfo1.DeviceIndex, 3);
                                    devinfo1.SplitByte_4 = GetDevicePhotoelectric(devinfo1.S7Connection, devinfo1.DeviceIndex, 4);
                                    devinfo1.SplitByte_5 = GetDevicePhotoelectric(devinfo1.S7Connection, devinfo1.DeviceIndex, 5);
                                    devinfo1.SplitByte_6 = GetDevicePhotoelectric(devinfo1.S7Connection, devinfo1.DeviceIndex, 6);
                                    devinfo1.SplitByte_7 = GetDevicePhotoelectric(devinfo1.S7Connection, devinfo1.DeviceIndex, 7);
                                }
                            }

                        }

                        #endregion

                        #region 移动设备类
                        
                        if ((devinfo1.DeviceKind == 1) || (devinfo1.DeviceKind == 4))
                        {
                            States = GetDeviceState(devinfo1.S7Connection, devinfo1.DeviceIndex);

                            if (States == null) continue;
                            
                            
                            if (States[1] >= 30)
                            {
                                if (updateroute == true)
                                {//20100131
                                    UpdateErrorCode(devinfo1.DeviceIndex, States[1]);
                                    AlterRoute(devinfo1.DeviceIndex, States[1]);
                                }
                                //修改路径表
                                if (States[1] != devinfo1.ErrorCode)
                                {
                                    //20100131
                                    UpdateErrorCode(devinfo1.DeviceIndex, States[1]);
                                    AlterRoute(devinfo1.DeviceIndex, States[1]);
                                }
                                devinfo1.ErrorCode = States[1];
                                devinfo1.RunState = 2;
                            }
                            else if ((States[1] == 0) || (States[1] == 1) || (States[1] == 2))
                            {
                                if (updateroute == true)
                                {//20100131
                                    UpdateErrorCode(devinfo1.DeviceIndex, 0);
                                    AlterRoute(devinfo1.DeviceIndex, States[1]);
                                }
                                //修改路径表
                                if (States[1] != devinfo1.ErrorCode)
                                {
                                    //20100131
                                    UpdateErrorCode(devinfo1.DeviceIndex, 0);
                                    AlterRoute(devinfo1.DeviceIndex, States[1]);
                                }
                                //20090926
                                
                                if (States[1] == 2)
                                {
                                    //20090920
                                    devinfo1.RunState =5;
                                }
                                else
                                {
                                    devinfo1.RunState = States[1];
                                }
                                //20100131
                                devinfo1.ErrorCode = States[1];
                                
                            }
                            devinfo1.TaskNo = States[2];
                            devinfo1.XCoor = States[3];
                            devinfo1.YCoor = States[4];

                        }

                        #endregion

                        if (devinfo1.DeviceKind == 1 || devinfo1.DeviceKind == 2 || devinfo1.DeviceKind == 3 || devinfo1.DeviceKind == 4 || devinfo1.DeviceKind == 5  || devinfo1.DeviceKind == 31)
                        {
                            #region 设备载物

                            int bdv = 0, bdov = 0;
                            //20101118


                            if (devinfo1.BindingDevice != null)
                            {

                                bdv = GetDevicePhotoelectric(devinfo1.S7Connection, devinfo1.BindingDevice);//20101124
                            }
                            if (devinfo1.BindingDeviceOut != null)
                            {

                                bdov = GetDevicePhotoelectric(devinfo1.S7Connection, devinfo1.BindingDeviceOut);//20101124

                            }
                            //20101118
                            if ((bdv + bdov) >= 1)
                            {
                                devinfo1.HaveGoods = true;
                            }
                            else
                            {
                                devinfo1.HaveGoods = false;
                            }

                            #endregion

                            dtt = DateTime.Now.Second.ToString() + "-" + DateTime.Now.Millisecond.ToString();

                            #region 设备逻辑有物


                            sql.Remove(0, sql.Length);
                            sql.Append("SELECT F_HaveGoods FROM T_Base_Device WHERE  F_DeviceIndex=").Append(devinfo1.DeviceIndex);
                            dvv = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                            if (dvv.Count > 0)
                            {
                                if (dvv[0]["F_HaveGoods"].ToString() == "1")
                                {
                                    devinfo1.LogicHaveGoods = true;
                                }
                                else
                                {
                                    devinfo1.LogicHaveGoods = false;
                                }
                            }

                            #endregion

                            dt0 = DateTime.Now.Second.ToString() + "-" + DateTime.Now.Millisecond.ToString();

                            #region 条码和坐标

                            sql.Remove(0, sql.Length);
                            sql.Append("SELECT F_NumParam1,F_NumParam2,F_NumParam3,F_NumParam4,F_NumParam5,F_NumParam6, F_TxtParam FROM T_Monitor_Task WHERE (F_MonitorIndex = ").Append(devinfo1.TaskNo).Append(")");
                            DataView dvb = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                            if (dvb.Count > 0)
                            {
                                if (devinfo1.DeviceKind == 1)
                                {
                                    devinfo1.ArrowLocation = string.Format("{0}排{1}列{2}层", dvb[0]["F_NumParam4"].ToString(), dvb[0]["F_NumParam5"].ToString(), dvb[0]["F_NumParam6"].ToString());
                                }
                                if (devinfo1.DeviceKind == 4)
                                {
                                    devinfo1.ArrowLocation = dvb[0]["F_NumParam1"].ToString();
                                }
                                if (devinfo1.DeviceKind == 2)
                                {
                                    devinfo1.ArrowLocation = dvb[0]["F_NumParam4"].ToString();
                                }
                                devinfo1.Barcode = dvb[0]["F_TxtParam"].ToString();

                            }
                            else
                            {
                                devinfo1.Barcode = "";
                                devinfo1.ArrowLocation = "";
                            }

                            #endregion
                            dvb = null;
                        }
                        dt1 = DateTime.Now.Second.ToString()+"-"+DateTime.Now.Millisecond.ToString();
                        //20091107
                        

                    }
                    
                    Model.CGetInfo.SetDeviceInfo(devinfo1);
                    
                    CDeviceStateChangeEventArgs csce = new CDeviceStateChangeEventArgs(devinfo1);
                    OnDeviceStateChange("CParsePLCData", csce);
                    
                    //20091107
                    dvv = null;
                
                }
                
        
            }
        
            catch(Exception exa)
        
            {

                _CParsePLCError = "解析PLC反馈数据的记录设备状态时发生错误：" + exa.Message;
        
            }
        }
        /// <summary>
        /// 修改本地路径表、反馈给管理的路径表以及提出修改申请
        /// </summary>
        /// <param name="devInx">发生故障的设备索引</param>
        /// <returns></returns>
        public  bool AlterRoute(int devInx, int state)
        {

            
            try
            {
                sql.Remove(0, sql.Length);
                sql.Append("select distinct F_RouteID from T_Base_Route_Device where F_DeviceIndex=" ).Append( devInx);
                DataView dv = dboRoute.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                for (int i = 0; i < dv.Count; i++)
                {
                    if (state >= 30)
                    {
                        //所有子路径都不可用时，方才设定此路径真的不可用
                        sql.Remove(0, sql.Length);
                        sql .Append( " SELECT T_Base_Route_Device.F_RouteIDSub, SUM(T_Base_Device.F_ErrorCode) AS ErrorCodes " ).Append(
                                    " FROM T_Base_Route_Device,T_Base_Device where T_Base_Route_Device.F_DeviceIndex = T_Base_Device.F_DeviceIndex" ).Append(
                                    " and T_Base_Route_Device.F_RouteID=" ).Append( dv[i]["F_RouteID"] ).Append( " GROUP BY T_Base_Route_Device.F_RouteIDSub ");
                        DataView dvr = dboRoute.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                        bool ifUsable = false;
                        for (int kk = 0; kk < dvr.Count; kk++)
                        {
                            if (Convert.ToInt32( dvr[kk]["ErrorCodes"] )<= 0)
                            {
                                ifUsable = true;
                                break;
                            }
                        }
                        if (ifUsable == false)
                        {
                            //20101011
                            sql.Remove(0, sql.Length);
                            sql.Append("update t_base_route set F_Status=0 where f_routeid=" ).Append( dv[i]["F_RouteID"] ).Append( " and F_Status=1 and F_AutoUpdate=1 ");
                            int ups = dboRoute.ExecuteSql(sql.ToString());
                            sql.Remove(0, sql.Length);
                            sql.Append("update IO_CONTROL_ROUTE set CONTROL_ROUTE_STATUS=0 where CONTROL_ROUTE_ID='" ).Append( dv[i]["F_RouteID"] ).Append( "' and CONTROL_ROUTE_STATUS=1");
                            if (ups>0)dboMan.ExceSQL(sql.ToString());
                        }
                        
                    }
                    else
                    {
                        sql.Remove(0, sql.Length);
                        sql.Append("SELECT SUM(T_Base_Device.F_ErrorCode) as errcode FROM T_Base_Device ,T_Base_Route_Device" ).Append(
                            " where T_Base_Device.F_DeviceIndex = T_Base_Route_Device.F_DeviceIndex and T_Base_Route_Device.F_RouteID=").Append(dv[i]["F_RouteID"]);
                        DataView dv1 = dboRoute.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                        if (dv1.Count > 0)
                        {
                            int errcode = 0; int a = 0;
                            if (int.TryParse (dv1[0]["errcode"].ToString(),out a ) == true)
                            {
                                errcode =Convert.ToInt32( dv1[0]["errcode"]);
                            }
                            
                            if (errcode <= 0)
                            {
                                //20101011
                                sql.Remove(0, sql.Length);
                                sql.Append("update t_base_route set F_Status=1 where f_routeid=" ).Append( dv[i]["F_RouteID"] ).Append( " and F_Status=0 and F_AutoUpdate=1 ");
                                int ups= dboRoute.ExecuteSql(sql.ToString());
                                sql.Remove(0, sql.Length);
                                sql.Append("update IO_CONTROL_ROUTE set CONTROL_ROUTE_STATUS=1 where CONTROL_ROUTE_ID='" ).Append( dv[i]["F_RouteID"] ).Append( "' and CONTROL_ROUTE_STATUS=0");
                                if(ups>0)dboMan.ExceSQL(sql.ToString());
                            }
                        }
                        
                        
                    }
                }
                
                
                return true;
            }
            catch (Exception ex)
            {
                _CParsePLCError = "解析PLC反馈数据的修改路径时发生错误：" + ex.Message;
                return false;
            }
        }
        void UpdateErrorCode(int devInx, int errorCode)
        {
            sql.Remove(0, sql.Length);
            sql.Append("UPDATE T_Base_Device SET F_ErrorCode = " ).Append( errorCode ).Append( " WHERE (F_DeviceIndex = " ).Append( devInx ).Append( ")and (F_ErrorCode <> " ).Append( errorCode ).Append( ")");
            dbo.ExceSQL(sql.ToString());
        }
         

       
    }
}