using Bro.Common.Helper;
using Bro.UI.Model.Winform;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Configuration;
using System.IO;
using WeifenLuo.WinFormsUI.Docking;
using static Bro.Common.Helper.EnumHelper;

namespace Bro.UI.Config.MenuForms
{
    [DockOption(DockState.DockRight, 230, 0)]
    [MenuNode("Statistic", "生产信息", 2, "View1", true)]
    public partial class FrmStatistic : MenuFrmBase
    {
        #region Properties
        private int qty_OK = 0;
        private int qty_NG = 0;
        private int qty_All = 0;

        private float qty_ok_rate = 0;
        private float qty_ng_rate = 0;

        private float ct = 0;
        private int uph = 0;

        private DateTime? startTime = null;
        private TimeSpan runTime = new TimeSpan();
        private TimeSpan idleTime = new TimeSpan();
        private TimeSpan downTime = new TimeSpan();
        private TimeSpan availableTime = new TimeSpan();
        private int qty_OEE = 0;
        private int qty_OEE_OK = 0;
        private float oee = 0;

        public int Qty_OK
        {
            get => qty_OK;
            set
            {
                qty_OK = value;

                this.Invoke(new Action(() =>
                {
                    lblOKNum.Text = qty_OK.ToString();
                }));

                Qty_All = Qty_OK + Qty_NG;
                Qty_OK_Rate = Qty_All == 0 ? 0 : (float)Qty_OK / (float)Qty_All;
                Qty_NG_Rate = Qty_All == 0 ? 0 : (float)Qty_NG / (float)Qty_All;
            }
        }

        public int Qty_NG
        {
            get => qty_NG;
            set
            {
                qty_NG = value;

                this.Invoke(new Action(() =>
                {
                    lblNGNum.Text = qty_NG.ToString();
                }));

                Qty_All = Qty_OK + Qty_NG;
                Qty_OK_Rate = Qty_All == 0 ? 0 : (float)Qty_OK / (float)Qty_All;
                Qty_NG_Rate = Qty_All == 0 ? 0 : (float)Qty_NG / (float)Qty_All;
            }
        }

        public int Qty_All
        {
            get => qty_All;
            set
            {
                qty_All = value;
                this.Invoke(new Action(() =>
                {
                    lblTotalNum.Text = qty_All.ToString();
                }));
            }
        }

        public float Qty_OK_Rate
        {
            get => qty_ok_rate;
            set
            {
                qty_ok_rate = value;

                this.Invoke(new Action(() =>
                {
                    lblOKRate.Text = $"{(qty_ok_rate * 100).ToString("f2")}%";
                }));
            }
        }

        public float Qty_NG_Rate
        {
            get => qty_ng_rate;
            set
            {
                qty_ng_rate = value;

                this.Invoke(new Action(() =>
                {
                    lblNGRate.Text = $"{(qty_ng_rate * 100).ToString("f2")}%";
                }));
            }
        }

        public float CT
        {
            get => ct;
            set
            {
                ct = value;

                this.Invoke(new Action(() =>
                {
                    lblCT.Text = $"{ct.ToString("f3")} s";
                }));
            }
        }

        public int UPH
        {
            get => uph;
            set
            {
                uph = value;

                this.Invoke(new Action(() =>
                {
                    lblUPH.Text = $"{uph} pcs/hr";
                }));
            }
        }

        public DateTime? StartTime
        {
            get => startTime;
            set
            {
                startTime = value;

                this.Invoke(new Action(() =>
                {
                    lblStartTime.Text = (startTime != null ? startTime.Value.ToString("yyyy-MM-dd HH:mm:ss") : "");
                }));
            }
        }

        public TimeSpan RunTime
        {
            get => runTime;
            set
            {
                runTime = value;

                this.Invoke(new Action(() =>
                {
                    lblRunTime.Text = runTime.ToString();
                }));
            }
        }

        public TimeSpan IdleTime
        {
            get => idleTime;
            set
            {
                idleTime = value;

                this.Invoke(new Action(() =>
                {
                    lblIdleTime.Text = idleTime.ToString();
                }));
                GetRunTime();
            }
        }

        public TimeSpan DownTime
        {
            get => downTime;
            set
            {
                downTime = value;

                this.Invoke(new Action(() =>
                {
                    lblDownTime.Text = downTime.ToString();
                }));
                GetRunTime();
            }
        }

        private void GetRunTime()
        {
            RunTime = AvailableTime + IdleTime + DownTime;
        }

        public TimeSpan AvailableTime
        {
            get => availableTime;
            set
            {
                availableTime = value;

                this.Invoke(new Action(() =>
                {
                    lblAvailableTime.Text = availableTime.ToString();
                }));
                GetRunTime();
            }
        }

        public int Qty_OEE
        {
            get => qty_OEE;
            set
            {
                qty_OEE = value;

                this.Invoke(new Action(() =>
                {
                    lblOEE_Total.Text = qty_OEE.ToString();
                }));
            }
        }

        public int Qty_OEE_OK
        {
            get => qty_OEE_OK;
            set
            {
                qty_OEE_OK = value;

                this.Invoke(new Action(() =>
                {
                    lblOEE_OK.Text = qty_OEE_OK.ToString();
                }));
            }
        }

        public float OEE
        {
            get => oee;
            set
            {
                oee = value;

                this.Invoke(new Action(() =>
                {
                    lblOEE_Rate.Text = $"{(oee * 100).ToString("f2")}%";
                }));
            }
        }

        public int IdealUPH
        {
            get => (int)nudDemandUPH.Value;
            set
            {
                this.Invoke(new Action(() =>
                {
                    nudDemandUPH.Value = value;
                }));
            }
        }
        #endregion

        #region Timer
        System.Threading.Timer _availableTimer = null;
        System.Threading.Timer _idleTimer = null;
        System.Threading.Timer _downTimer = null;
        System.Threading.Timer _checkIdleTimer = null;
        System.Threading.Timer _calculateTimer = null;

        private RunState? currentState = null;
        public RunState? CurrentState
        {
            get => currentState;
            set
            {
                if (value != null)
                {
                    if (currentState != value.Value)
                    {
                        switch (value.Value)
                        {
                            case RunState.Stop:
                                _availableTimer.Change(-1, -1);
                                _idleTimer.Change(-1, -1);
                                _downTimer.Change(-1, -1);
                                break;
                            case RunState.Running:
                                _idleTimer.Change(-1, -1);
                                _downTimer.Change(-1, -1);
                                _availableTimer.Change(0, 1000);
                                break;
                            case RunState.Idle:
                                _availableTimer.Change(-1, -1);
                                _downTimer.Change(-1, -1);
                                _idleTimer.Change(0, 1000);
                                break;
                            case RunState.Down:
                                _idleTimer.Change(-1, -1);
                                _availableTimer.Change(-1, -1);
                                _downTimer.Change(0, 1000);
                                break;
                        }

                        currentState = value;
                    }
                }
            }
        }
        #endregion

        int _idleThreshold = 30;
        public FrmStatistic()
        {
            InitializeComponent();

            this.Load += (s, e) =>
            {
                ReadNumRecords();

                string idealUPHStr = ConfigurationManager.AppSettings["IdealUPH"];
                if (!string.IsNullOrWhiteSpace(idealUPHStr) && int.TryParse(idealUPHStr, out int idealUPHSetting))
                {
                    IdealUPH = idealUPHSetting;
                }
                else
                {
                    IdealUPH = 5000;
                }
            };

            string idleThresholdStr = ConfigurationManager.AppSettings["IdleThreshold"];
            if (!string.IsNullOrWhiteSpace(idleThresholdStr) && int.TryParse(idleThresholdStr, out int idleTTemp))
            {
                _idleThreshold = idleTTemp;
            }
            else
            {
                _idleThreshold = 30;
            }
        }

        public override void OnProcessUpdated()
        {
            Process.OnProcessStateChanged -= Process_OnProcessStateChanged;
            Process.OnProcessStateChanged += Process_OnProcessStateChanged;

            Process.OnAlarmUpdate -= Process_OnAlarmUpdate;
            Process.OnAlarmUpdate += Process_OnAlarmUpdate;

            Process.OnUpdateResult = UpdateResultOK;
            Process.OnUpdateCT = UpdateCT;

            _availableTimer = new System.Threading.Timer(AvailableTimerCallBack, null, -1, -1);
            _idleTimer = new System.Threading.Timer(IdleTimerCallBack, null, -1, -1);
            _downTimer = new System.Threading.Timer(DownTimerCallBack, null, -1, -1);
            _checkIdleTimer = new System.Threading.Timer(CheckIdle, null, -1, -1);

            _calculateTimer = new System.Threading.Timer(Calculation, null, 1000 * 60, 1000 * 60);
        }

        private void Process_OnAlarmUpdate(string alarmMsg)
        {
            if (string.IsNullOrWhiteSpace(alarmMsg))
            {
                if (CurrentState == RunState.Down)
                {
                    CurrentState = RunState.Idle;
                }
            }
            else
            {
                if (CurrentState == RunState.Idle || CurrentState == RunState.Running)
                {
                    CurrentState = RunState.Down;
                }
            }
        }

        private void Process_OnProcessStateChanged(EnumHelper.DeviceState state)
        {
            if (state == EnumHelper.DeviceState.DSOpen)
            {
                StartTime = DateTime.Now;
                CurrentState = RunState.Idle; ;
            }
            else
            {
                CurrentState = RunState.Stop;
            }

            if (state == EnumHelper.DeviceState.DSClose)
            {
                SaveNumRecord();
            }
        }

        private void CheckIdle(object state)
        {
            var idleBack = new TimeSpan(0, 0, _idleThreshold);
            IdleTime = IdleTime.Add(idleBack);
            AvailableTime = AvailableTime.Subtract(idleBack);
            CurrentState = RunState.Idle;
        }

        private void UpdateResultOK(DateTime updateTime, int result)
        {
            CurrentState = RunState.Running;
            _checkIdleTimer.Change(_idleThreshold * 1000, -1); //1分钟没有上传Load认为进入空闲时间

            if (result == 1)
            {
                Qty_OK++;
                Qty_OEE_OK++;
            }
            else
            {
                Qty_NG++;
            }

            Qty_OEE++;
        }

        private void UpdateCT(float ctTime)
        {
            CT = ctTime;
        }

        private void RefreshOEE()
        {
            Calculation(null);
        }

        /// <summary>
        /// 每分钟计算OEE，平均UPH
        /// </summary>
        /// <param name="state"></param>
        private void Calculation(object state)
        {
            if (RunTime.TotalHours == 0)
            {
                UPH = 0;
            }
            else
            {
                UPH = (int)(Qty_OEE / RunTime.TotalHours);
            }

            if (IdealUPH == 0 || RunTime.TotalSeconds == 0 || Qty_OEE == 0)
            {
                OEE = 0;
            }
            else
            {
                OEE = (float)(AvailableTime.TotalSeconds / RunTime.TotalSeconds) * ((float)UPH / (float)IdealUPH) * ((float)Qty_OEE_OK / (float)Qty_OEE);
            }
        }

        private void ClearOEE()
        {
            RunTime = IdleTime = DownTime = new TimeSpan();
            Qty_OEE_OK = Qty_OEE = 0;

            if (Process.ProcessState == EnumHelper.DeviceState.DSOpen)
            {
                StartTime = DateTime.Now;
            }
            else
            {
                StartTime = null;
            }
        }

        private void DownTimerCallBack(object state)
        {
            DownTime = DownTime.Add(new TimeSpan(0, 0, 1));
        }

        private void IdleTimerCallBack(object state)
        {
            IdleTime = IdleTime.Add(new TimeSpan(0, 0, 1));
        }

        private void AvailableTimerCallBack(object state)
        {
            AvailableTime = AvailableTime.Add(new TimeSpan(0, 0, 1));
        }

        private void OnClearQty()
        {
            Qty_OK = Qty_NG = 0;
        }

        string numRecordFile = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Statistic.json");
        static object numLock = new object();
        private void SaveNumRecord()
        {
            lock (numLock)
            {
                using (StreamWriter writer = new StreamWriter(numRecordFile, false, System.Text.Encoding.UTF8))
                {
                    string dataStr = JsonConvert.SerializeObject(new { Qty_OK, Qty_NG });
                    writer.Write(dataStr);
                    writer.Flush();
                }
            }
        }

        private void ReadNumRecords()
        {
            if (File.Exists(numRecordFile))
            {
                lock (numLock)
                {
                    using (StreamReader reader = new StreamReader(numRecordFile, System.Text.Encoding.UTF8))
                    {
                        string dataStr = reader.ReadToEnd();

                        JObject data = JsonConvert.DeserializeObject<JObject>(dataStr);

                        if (data != null)
                        {
                            Qty_OK = data.Value<int>("Qty_OK");
                            Qty_NG = data.Value<int>("Qty_NG");
                        }
                    }
                }
            }
        }

        private void btnClearStatistic_Click(object sender, EventArgs e)
        {
            Qty_OK = Qty_NG = 0;
        }
    }
}