using System.ComponentModel;
using System.Threading;
using VirtualConveyor.Cache.Entity;
using VirtualConveyor.Common.Entity;
using VirtualConveyor.Properties;
using VirtualConveyor.Utils;
namespace VirtualConveyor.HeartBeat.Entity
{
    public class HeartBeatEntity:BindableBase
    {
        /// <summary>
        /// PLC心跳
        /// </summary>
        private int wPlcHeartBeat;

        public int WPlcHeartBeat
        {
            get { return wPlcHeartBeat; }
            set { SetProperty(ref wPlcHeartBeat, value); }
        }

        /// <summary>
        /// 告警信息
        /// </summary>
        private int wAlarmCode;

        public int WAlarmCode
        {
            get { return wAlarmCode; }
            set { SetProperty(ref wAlarmCode, value); }
        }

        /// <summary>
        /// 服务器心跳
        /// </summary>
        private bool serverHeartBeat;

        public bool ServerHeartBeat
        {
            get { return serverHeartBeat; }
            set { SetProperty(ref serverHeartBeat, value); }
        }

        /// <summary>
        /// WCS需要写入的OPC地址
        /// </summary>
        public OpcReadItem  OpcReadItems{ get; set; }


        /// <summary>
        /// WCS需要读取的OPC地址
        /// </summary>
        public OpcWriteItem OpcWriteItems { get; set; }


        /// <summary>
        /// 写入心跳的线程
        /// </summary>
        private Thread WritePlcHeartBeatThread { get; set; }


        public HeartBeatEntity()
        {
            OpcReadItems = new OpcReadItem
            {
                ServerHeartBeat = "S7:[@LOCALSERVER]DB1,X159.0"
            };

            OpcWriteItems = new OpcWriteItem
            {
                PlcHeartBeat = "S7:[@LOCALSERVER]DB1,INT160",
                AlarmCode = "S7:[@LOCALSERVER]DB1,W162" 
            };


            this.PropertyChanged += new PropertyChangedEventHandler(OnPropertyChanged);
            WritePlcHeartBeatThread = new Thread(new ThreadStart(WritePlcHeartBeat));
            ThreadHelper.StartThread(WritePlcHeartBeatThread);
        }


        /// <summary>
        /// 析构函数
        /// </summary>
        ~HeartBeatEntity() 
        {
            LogTextHelper.WriteLine(Resources.LogDir, "{0}的析构函数别调用", this.ToString());
            ThreadHelper.CloseThread(WritePlcHeartBeatThread); 
        }

        public void CloseWritePlcHeartBeatThread() { ThreadHelper.CloseThread(WritePlcHeartBeatThread); }


        /// <summary>
        /// 心跳属性值发生变化时触发的事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnPropertyChanged(object sender, PropertyChangedEventArgs e)
        {
            switch (e.PropertyName)
            {
                case "WPlcHeartBeat":
                    CacheEntity.OpcWcfServiceClient.WriteValue(this.OpcWriteItems.PlcHeartBeat, WPlcHeartBeat);
                    break;
                case "WAlarmCode":
                    CacheEntity.OpcWcfServiceClient.WriteValue(this.OpcWriteItems.AlarmCode, WAlarmCode);
                    break;
                
            }
        }

        /// <summary>
        /// 写入心跳
        /// </summary>
        private void WritePlcHeartBeat()
        {
            while (true)
            {
                WPlcHeartBeat = WPlcHeartBeat > 999 ? 0 : WPlcHeartBeat + 1;
                Thread.Sleep(1000);
            }
        }



    }
}