using System;
using System.Collections.Generic;
using System.Windows.Forms;
using MachineDll;
using System.Data;
namespace Interface
{
    public class Interactive : Form, IReceiveData
    {
        private bool _IsAllFinish;
        private readonly TheMachine theMachine;
        private int _SuccessCount;
        private int _FailureCount;
        private DataTable table1;
        private double _TestTime;
        private System.Timers.Timer timer1;
        private System.ComponentModel.IContainer components;
        private double fluidHeight;
        private double heatTemp;
        private double suggestHeatTemp;
        private double suggestHeight;
        private double washUpperLimit;
        private double conductance;
        private bool IsStatic;
        private bool m_ifHeat;
        private Queue objQ;
        public Interactive(bool ifHeat, double testTime, double SuggestHeight, double SuggestHeatTemp, 
            double WashUpperLimit, bool isStatic,string port)
        {
            m_ifHeat = ifHeat;
            _IsAllFinish = false;
            _TestTime = testTime;
            IsStatic = isStatic;
            suggestHeight=SuggestHeight;
            suggestHeatTemp = SuggestHeatTemp;
            washUpperLimit = WashUpperLimit;
            //可以异步调用界面的控件
            CheckForIllegalCrossThreadCalls = false;
            theMachine = GetMachineFromMe.GetMachine;
            SerialPortSetting.PortName = port;

            if (theMachine.StartConnection())
            {
                theMachine.AddClients(this);
                if (theMachine.StartReading())
                {
                    Init();
                }
            }
        }
        private double sum;
        private double MaxData;
        private double MinData;
        private double AverageData;
        private int count; //供测试用
        private int tempCompare = 0;//初始为0；1：大；2：小

        private void Init()
        {
            table1 = new DataTable();
            DataColumnCollection columns = table1.Columns;
            columns.Add("ColTestTime", typeof(System.DateTime));
            columns.Add("ColData", typeof(System.Double));
            sum = 0;
            MaxData = 0;
            MinData = 100;
            
            System.Threading.Thread.Sleep(3000);
            if (_IsStart)
            {
                //读取液位数据
                fluidHeight = GetFluidHeight();

                tempCompare = 0;
                //  液位判断：
                //《建议进水高度：v4开，p2开，其余关
                // 》建议进水高度：V5开，其余关
                //直至
                //＝建议进水高度：下一步
                count = 16;
                JudgeHeight();

                //温度读取，加热判断：
                heatTemp = GetHeatTemp();
                //y：比较设定温度：》设定温度：V2,V3,P1开，其余关
                //                 《设定温度：V2,V3,P1开，TK开
                //                  直至
                //                 ＝设定温度：
                tempCompare = 0;
                if (m_ifHeat)
                {
                    count = 16;
                    JudgeHeatTemp();
                }
                    //n：》30：V2，v3，p1开，其余关
                    //   《＝30：
                else
                {
                    count = 8;
                    JudgeAssignHeatTemp();
                }
                //过滤极限：
                //n：V2，v3，p1开，d读书，其余关
                //直至y：
                conductance = GetConductance();

                count = 8;
                JudgeWashUpperLimit();

                IsLast = true;
            }
        }

        private void GetData()
        {
            DataRow dr;
            dr = table1.NewRow();
            dr["ColTestTime"] = DateTime.Now;
            dr["ColData"] = ConductanceA;
            table1.Rows.Add(dr);
            sum = sum + ConductanceA;
            if (ConductanceA > MaxData)
            {
                MaxData = ConductanceA;
            }
            if (ConductanceA < MinData)
            {
                MinData = ConductanceA;
            }
            AverageData = sum / 30;
        }

        public bool IsStart
        {
            get
            {
                return _IsStart;
            }
        }
        public bool IsAllFinish
        {
            get
            {
                return _IsAllFinish;
            }
        }
        public bool IsFinish
        {
            get
            {
                return _IsFinish;
            }
        }
        public DataTable ReTable
        {
            get
            {
                return table1;
            }
        }
        public double ReAverageData
        {
            get
            {
                return AverageData;
            }
        }
        public double ReMaxData
        {
            get
            {
                return MaxData;
            }
        }
        public double ReMinData
        {
            get
            {
                return MinData;
            }
        }
        public void CloseRead()
        {
            theMachine.StopReading();
            theMachine.RemoveClients(this);
            theMachine.CloseConnection();
        }
        #region IReceiveData 成员

        private Byte[] _ReceiveValue;
        public void NewReceiveData(int receivedCount, Byte[] receiveValue)
        {
            _IsStart = true;
            if (receivedCount == 1)
            {
                timer1 = new System.Timers.Timer();
                timer1.Elapsed += new System.Timers.ElapsedEventHandler(theout);
                timer1.Interval = (int)_TestTime * 1000;
                timer1.Start();
            }
            _ReceiveValue = receiveValue;
            NewGetData();
        }

        private void NewGetData()
        {
            DataRow dr;
            dr = table1.NewRow();
            dr["ColTestTime"] = DateTime.Now;
            double tempData=ChangeData();
            dr["ColData"] = tempData;
            table1.Rows.Add(dr);
            sum = sum + tempData;
            if (tempData > MaxData)
            {
                MaxData = tempData;
            }
            if (tempData < MinData)
            {
                MinData = tempData;
            }
            AverageData = sum / 30;
        }
        private double ChangeData()
        {
            double returnValue = 0;
            string temp = Convert.ToChar(_ReceiveValue[0]).ToString();
            for (int i = 1; i < _ReceiveValue.Length;i++ )
            {
                if (Convert.ToChar(_ReceiveValue[i]).ToString() == "+")
                {
                    break;
                }
                temp = temp + Convert.ToChar(_ReceiveValue[i]);
            }
            double.TryParse(temp, returnValue);
            return returnValue;
        }
        private int ConductanceA;
        private int TemperatureB;
        private int PressureC;
        private int ProportionD;
        private bool IsLast=false;
        private bool _IsStart = false;
        private bool _IsFinish = false;
        private int LastStep = 0;
        public void ReceiveData(int receivedCount, BuffType receiveDtype, int _FirstBuff, int _SecondBuff)
        {
            _IsStart = true;
            switch (receiveDtype)
            {
                case BuffType.ConductanceA:
                    ConductanceA = CalculateFrequency(_FirstBuff, _SecondBuff);
                    if (IsFinish)
                    {
                        GetData();
                    }
                    _SuccessCount++;
                    break;
                case BuffType.TemperatureB:
                    TemperatureB = CalculateFrequency(_FirstBuff, _SecondBuff);
                    _SuccessCount++;
                    break;
                case BuffType.PressureC:
                    PressureC = CalculateFrequency(_FirstBuff, _SecondBuff);
                    _SuccessCount++;
                    break;
                case BuffType.ProportionD:
                    ProportionD = CalculateFrequency(_FirstBuff, _SecondBuff);
                    _SuccessCount++;
                    break;
                case BuffType.InvalidData:
                    _FailureCount++;
                    break;
            }
            //完成一个读数流程 且到最后一步还没有完成操作时
            if (_SuccessCount % 4 == 0 && IsLast && !_IsFinish)
            {
                if (LastStep == 0)
                {
                    CreateOperationQuery();
                    LastStep = LastStep + 1;
                }
                GetOperation(objQ.Pop().ToString());
                if (objQ.IsNull)
                {
                    _IsFinish = true;
                    timer1 = new System.Timers.Timer();
                    timer1.Elapsed += new System.Timers.ElapsedEventHandler(theout);
                    timer1.Interval = (int)_TestTime * 1000;
                    timer1.Start();
                }
            }
        }

        private int CalculateFrequency(int _FirstBuff, int _SecondBuff)
        {
            return _SecondBuff * 256 + _FirstBuff;
        }

        #endregion
        /// <summary>
        /// 通过外界读取液位数据
        /// </summary>
        /// <returns></returns>
        public double GetFluidHeight()
        {
            return (double)PressureC;
        }
        /// <summary>
        /// 加热温度
        /// </summary>
        /// <returns></returns>
        public double GetHeatTemp()
        {
            return (double)TemperatureB;
        }
        /// <summary>
        /// 电导
        /// </summary>
        /// <returns></returns>
        public double GetConductance()
        {
            return (double)ConductanceA;
        }

        /// <summary>
        /// 《建议进水高度：v4开，p2开，其余关
        /// </summary>
        public void CreatFluidGreaterSuggestQuery()
        {
            objQ = new Queue();
            objQ.Push(
                /// 打开V4阀
                    "theMachine.GetControllor.OpenP11()");
            objQ.Push(
                /// 打开P2泵
                    "theMachine.GetControllor.OpenP15()");
            objQ.Push(
                /// P10口置0,关闭V5阀
                    "theMachine.GetControllor.CloseP10()");
            objQ.Push(
                /// 关闭V3,2阀
                    "theMachine.GetControllor.CloseP12()");
            objQ.Push(
                /// 关闭V1阀
                    "theMachine.GetControllor.CloseP13()");
            objQ.Push(
                /// 关闭P1泵
                    "theMachine.GetControllor.CloseP14()");
            objQ.Push(
                /// 关闭P1.6口
                    "theMachine.GetControllor.CloseP16()");
            objQ.Push(
                /// 关闭P1.7口
                    "theMachine.GetControllor.CloseP17()");           
        }
        /// <summary>
        /// 》建议进水高度：V5开，其余关
        /// </summary>
        public void CreatFluidSmallerSuggestQuery()
        {
            objQ = new Queue();
            objQ.Push(
                    /// P10口置1,打开V5阀
                    "theMachine.GetControllor.OpenP10()");
            objQ.Push(
                    /// 关闭V4阀
                    "theMachine.GetControllor.CloseP11()");
            objQ.Push(
                    /// 关闭V3,2阀
                    "theMachine.GetControllor.CloseP12()");
            objQ.Push(
                    /// 关闭V1阀
                    "theMachine.GetControllor.CloseP13()");
            objQ.Push(
                    /// 关闭P1泵
                    "theMachine.GetControllor.CloseP14()");
            objQ.Push(
                    /// 关闭P2泵
                    "theMachine.GetControllor.CloseP15()");
            objQ.Push(
                    /// 关闭P1.6口
                    "theMachine.GetControllor.CloseP16()");
            objQ.Push(
                    /// 关闭P1.7口
                    "theMachine.GetControllor.CloseP17()");
        }
        /// <summary>
        /// 》设定温度：V2,V3,P1开，其余关  
        /// </summary>
        public void CreatHeatTempGreaterSuggestQuery()
        {
            objQ = new Queue();
            objQ.Push(
                    /// 打开V3,2阀
                    "theMachine.GetControllor.OpenP12()");
            objQ.Push(
                    /// 打开P1泵
                    "theMachine.GetControllor.OpenP14()");
            objQ.Push(
                    /// P10口置0,关闭V5阀
                    "theMachine.GetControllor.CloseP10()");
            objQ.Push(
                    /// 关闭V4阀
                    "theMachine.GetControllor.CloseP11()");
            objQ.Push(
                    /// 关闭V1阀
                    "theMachine.GetControllor.CloseP13()");
            objQ.Push(
                    /// 关闭P2泵
                    "theMachine.GetControllor.CloseP15()");
            objQ.Push(
                    /// 关闭P1.6口
                    "theMachine.GetControllor.CloseP16()");
            objQ.Push(
                    /// 关闭P1.7口
                    "theMachine.GetControllor.CloseP17()");
        }
        /// <summary>
        /// 《设定温度：V2,V3,P1开，TK开 
        /// </summary>
        public void CreatHeatTempSmallerSuggestQuery()
        {
            objQ = new Queue();
            objQ.Push(
                    /// 打开V3,2阀
                    "theMachine.GetControllor.OpenP12()");
            objQ.Push(
                    /// 打开P1泵
                    "theMachine.GetControllor.OpenP14()");
            objQ.Push(
                    /// P10口置0,关闭V5阀
                    "theMachine.GetControllor.CloseP10()");
            objQ.Push(
                    /// 关闭V4阀
                    "theMachine.GetControllor.CloseP11()");
            objQ.Push(
                    /// 关闭V1阀
                    "theMachine.GetControllor.CloseP13()");
            objQ.Push(
                    /// 关闭P2泵
                    "theMachine.GetControllor.CloseP15()");
            objQ.Push(
                    /// 关闭P1.6口
                    "theMachine.GetControllor.CloseP16()");
            objQ.Push(
                    /// 关闭P1.7口
                    "theMachine.GetControllor.CloseP17()");
        }
        /// <summary>
        /// V2，v3，p1开，d读书，其余关
        /// </summary>
        public void CreatWashUpperLimitGreaterConductanceQuery()
        {
            objQ = new Queue();
            objQ.Push(
                    /// 打开V3,2阀
                    "theMachine.GetControllor.OpenP12()");
            objQ.Push(
                    /// 打开P1泵
                    "theMachine.GetControllor.OpenP14()");
            objQ.Push(
                    /// P10口置0,关闭V5阀
                    "theMachine.GetControllor.CloseP10()");
            objQ.Push(
                    /// 关闭V4阀
                    "theMachine.GetControllor.CloseP11()");
            objQ.Push(
                    /// 关闭V1阀
                    "theMachine.GetControllor.CloseP13()");
            objQ.Push(
                    /// 关闭P2泵
                    "theMachine.GetControllor.CloseP15()");
            objQ.Push(
                    /// 关闭P1.6口
                    "theMachine.GetControllor.CloseP16()");
            objQ.Push(
                    /// 关闭P1.7口
                    "theMachine.GetControllor.CloseP17()");
        }
        /// <summary>
        /// 动态：v2，v3，p1开，d读数，其余关
        /// </summary>
        public double DynamicOperation()
        {
            IsLast = true;
            /// 打开V3,2阀
            theMachine.GetControllor.OpenP12();
            /// 打开P1泵
            theMachine.GetControllor.OpenP14();
            /// P10口置0,关闭V5阀
            theMachine.GetControllor.CloseP10();
            /// 关闭V4阀
            theMachine.GetControllor.CloseP11();
            /// 关闭V1阀
            theMachine.GetControllor.CloseP13();
            /// 关闭P2泵
            theMachine.GetControllor.CloseP15();
            /// 关闭P1.6口
            theMachine.GetControllor.CloseP16();
            /// 关闭P1.7口
            theMachine.GetControllor.CloseP17();
            return (double)ConductanceA;
            //动态：v2，v3，p1开，d读数，其余关
        }
        /// <summary>
        /// 静态：P1,V1开，d读数，其余关
        /// </summary>
        public double StaticOperation()
        {
            IsLast = true;
            /// 打开V1阀
            theMachine.GetControllor.OpenP13();
            /// 打开P1泵
            theMachine.GetControllor.OpenP14();

            /// P10口置0,关闭V5阀
            theMachine.GetControllor.CloseP10();
            /// 关闭V4阀
            theMachine.GetControllor.CloseP11();
            /// 关闭V3,2阀
            theMachine.GetControllor.CloseP12();
            /// 关闭P2泵
            theMachine.GetControllor.CloseP15();
            /// 关闭P1.6口
            theMachine.GetControllor.CloseP16();
            /// 关闭P1.7口
            theMachine.GetControllor.CloseP17();

            return (double)ConductanceA;

            //静态：P1,V1开，d读数，其余关
        }

        public void CreateOperationQuery()
        {
            objQ = new Queue();
            if (IsStatic)
            {
                objQ.Push(/// 打开V1阀
                    "theMachine.GetControllor.OpenP13()");
            }
            else
            {
                objQ.Push(/// 打开V3,2阀
                    "theMachine.GetControllor.OpenP12()");
            }
            objQ.Push(/// 打开P1泵
                    "theMachine.GetControllor.OpenP14()");
            objQ.Push(/// P10口置0,关闭V5阀
                    "theMachine.GetControllor.CloseP10()");
            objQ.Push(/// 关闭V4阀
                    "theMachine.GetControllor.CloseP11()");
            if (IsStatic)
            {
                objQ.Push(/// 关闭V3,2阀
                    "theMachine.GetControllor.CloseP12()");
            }
            else
            {
                objQ.Push(/// 关闭V1阀
                    "theMachine.GetControllor.CloseP13()");
            }
            objQ.Push(                    /// 关闭P2泵
                    "theMachine.GetControllor.CloseP15()");
            objQ.Push(
                /// 关闭P1.6口
                    "theMachine.GetControllor.CloseP16()");
            objQ.Push(
                /// 关闭P1.7口
                    "theMachine.GetControllor.CloseP17()");
        }

        private void InitializeComponent()
        {
            this.components = new System.ComponentModel.Container();
            this.SuspendLayout();
            // 
            // Interactive
            // 
            this.Name = "Interactive";
            this.ResumeLayout(false);

        }

        public void theout(object source, System.Timers.ElapsedEventArgs e)
        {
            CloseRead();
            timer1.Stop();
            _IsAllFinish = true;
        }

        private void GetOperation(string type)
        {
            System.Threading.Thread.Sleep(2900);
            switch (type)
            {
                case "theMachine.GetControllor.OpenP10()":
                    theMachine.GetControllor.OpenP10();
                    break;
                case "theMachine.GetControllor.CloseP10()":
                    theMachine.GetControllor.CloseP10();
                    break;
                case "theMachine.GetControllor.OpenP11()":
                    theMachine.GetControllor.OpenP11();
                    break;
                case "theMachine.GetControllor.CloseP11()":
                    theMachine.GetControllor.CloseP11();
                    break;
                case "theMachine.GetControllor.OpenP12()":
                    theMachine.GetControllor.OpenP12();
                    break;
                case "theMachine.GetControllor.CloseP12()":
                    theMachine.GetControllor.CloseP12();
                    break;
                case "theMachine.GetControllor.OpenP13()":
                    theMachine.GetControllor.OpenP13();
                    break;
                case "theMachine.GetControllor.CloseP13()":
                    theMachine.GetControllor.CloseP13();
                    break;
                case "theMachine.GetControllor.OpenP14()":
                    theMachine.GetControllor.OpenP14();
                    break;
                case "theMachine.GetControllor.CloseP14()":
                    theMachine.GetControllor.CloseP14();
                    break;
                case "theMachine.GetControllor.OpenP15()":
                    theMachine.GetControllor.OpenP15();
                    break;
                case "theMachine.GetControllor.CloseP15()":
                    theMachine.GetControllor.CloseP15();
                    break;
                case "theMachine.GetControllor.OpenP16()":
                    theMachine.GetControllor.OpenP16();
                    break;
                case "theMachine.GetControllor.CloseP16()":
                    theMachine.GetControllor.CloseP16();
                    break;
                case "theMachine.GetControllor.OpenP17()":
                    theMachine.GetControllor.OpenP17();
                    break;
                case "theMachine.GetControllor.CloseP17()":
                    theMachine.GetControllor.CloseP17();
                    break;
                default:
                    break;
            }
        }

        #region judge

        /// <summary>
        /// 液位判断：《建议进水高度：v4开，p2开，其余关// 》建议进水高度：V5开，其余关 //直至＝建议进水高度：下一步
        /// </summary>
        private void JudgeHeight()
        {
            #region 供测试使用
            if (count == 16)
            {
                CreatFluidGreaterSuggestQuery();
            }
            if (count > 8)
            {
                GetOperation(objQ.Pop().ToString());
                count = count - 1;
                JudgeHeight();
            }
            if (count == 8)
            {
                CreatFluidSmallerSuggestQuery();
            }
            if (count > 0 && count <= 8)
            {
                GetOperation(objQ.Pop().ToString());
                count = count - 1;
                JudgeHeight();
            }
            if (count == 0)
            {
                return;
            }
            #endregion
            //if (fluidHeight > suggestHeight)
            //{
            //    if (tempCompare != 1)//如果是第一比较或是上一次是小于
            //    {
            //        CreatFluidGreaterSuggestQuery();
            //    }
            //    GetOperation(objQ.Pop().ToString());
            //    fluidHeight = GetFluidHeight();
            //    tempCompare = 1;
            //    JudgeHeight();
            //}
            //if (fluidHeight < suggestHeight)
            //{
            //    if (tempCompare != 2)//如果是第一比较或是上一次是大于
            //    {
            //        CreatFluidSmallerSuggestQuery();
            //    }
            //    //GetOperation(objQ.Pop().ToString());
            //    fluidHeight = GetFluidHeight();
            //    tempCompare = 2;
            //    JudgeHeight();
            //}
            //if (fluidHeight == suggestHeight)
            //{
            //    return;
            //}
        }
        /// <summary>
        /// 比较设定温度：》设定温度：V2,V3,P1开，其余关  《设定温度：V2,V3,P1开，TK开     直至=设定温度：下一步
        /// </summary>
        private void JudgeHeatTemp()
        {
            #region 供测试使用
            if (count == 16)
            {
                CreatHeatTempGreaterSuggestQuery();
            }
            if (count > 8)
            {
                GetOperation(objQ.Pop().ToString());
                count = count - 1;
                JudgeHeatTemp();
            }
            if (count == 8)
            {
                CreatHeatTempSmallerSuggestQuery();
            }
            if (count > 0 && count <= 8)
            {
                GetOperation(objQ.Pop().ToString());
                count = count - 1;
                JudgeHeatTemp();
            }
            if (count == 0)
            {
                return;
            }
            #endregion
            //if (heatTemp > suggestHeatTemp)
            //{
            //    if (tempCompare != 1)//如果是第一比较或是上一次是小于
            //    {
            //        CreatHeatTempGreaterSuggestQuery();
            //    }
            //    GetOperation(objQ.Pop().ToString());
            //    heatTemp = GetHeatTemp();
            //    tempCompare = 1;
            //    JudgeHeatTemp();
            //}
            //if (heatTemp < suggestHeatTemp)
            //{
            //    if (tempCompare != 2)//如果是第一比较或是上一次是大于
            //    {
            //        CreatHeatTempSmallerSuggestQuery();
            //    }
            //    GetOperation(objQ.Pop().ToString());
            //    heatTemp = GetHeatTemp();
            //    tempCompare = 2;
            //    JudgeHeatTemp();
            //}
            //if (heatTemp == suggestHeatTemp)
            //{
            //    return;
            //}
        }
        /// <summary>
        /// 》30：V2，v3，p1开，其余关   《＝30：：下一步
        /// </summary>
        private void JudgeAssignHeatTemp()
        {
            #region 供测试使用
            if (count == 8)
            {
                CreatHeatTempGreaterSuggestQuery();
            }
            if (count > 0 && count <= 8)
            {
                GetOperation(objQ.Pop().ToString());
                count = count - 1;
                JudgeAssignHeatTemp();
            }
            if (count == 0)
            {
                return;
            }
            #endregion

            //if (heatTemp > 30)
            //{
            //    if (tempCompare != 1)//如果是第一比较
            //    {
            //        CreatHeatTempGreaterSuggestQuery();
            //    }
            //    GetOperation(objQ.Pop().ToString());
            //    tempCompare = 1;
            //    heatTemp = GetHeatTemp();
            //    JudgeAssignHeatTemp();
            //}
            //else
            //{
            //    return;
            //}
        }
        /// <summary>
        /// 过滤极限：
        /// n：V2，v3，p1开，d读书，其余关
        /// 直至y：
        /// </summary>
        private void JudgeWashUpperLimit()
        {
            #region 供测试使用
            if (count == 8)
            {
                CreatWashUpperLimitGreaterConductanceQuery();
            }
            if (count > 0 && count <= 8)
            {
                GetOperation(objQ.Pop().ToString());
                count = count - 1;
                JudgeWashUpperLimit();
            }
            if (count == 0)
            {
                return;
            }
            #endregion

            //if (conductance < washUpperLimit)
            //{
            //    if (tempCompare != 1)//如果是第一比较
            //    {
            //        CreatWashUpperLimitGreaterConductanceQuery();
            //    }
            //    GetOperation(objQ.Pop().ToString());
            //    tempCompare = 1; 
            //    conductance = GetConductance();
            //    JudgeWashUpperLimit();
            //}
            //else
            //{
            //    return;
            //}
        }

        #endregion
    }
}