using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using S7.Net;
using logtxtWrite;
using System.Threading;
namespace iWareSda_QQJF.OPCService
{
    public class SS7 : PlcS7
    {
        public string heartAdd = "";//心跳DB地址
        int oldHeart = 10;//记录前一秒心跳值(也不知道为啥默认是10)
        int lostHeartTimes = 10;//掉线次数(一开始让它掉线直接重连)
        static CpuType plcType = (CpuType)Enum.Parse(typeof(CpuType), "S71200");

        public SS7(string ip, short rack, short slot,string HeartDb, string name = "", object tag = null)
            : base(plcType, ip, rack, slot)
        {
            this.OpenReadHeart(HeartDb);
        }


        ///// <summary>初始化S7连接
        ///// 
        ///// </summary>
        ///// <returns></returns>
        //public static SS7 s7Init(string IP,string add)
        //{
        //    try
        //    {
        //        SS7 newPLC = new SS7(IP, Convert.ToInt16("0"), Convert.ToInt16("1"), add);
        //        //var code = newPLC.Open();
        //        return newPLC;

        //    }
        //    catch (Exception )
        //    {
        //        logtxt.txtWrite("类名：FormMain/函数名：deviceOpcInit/ OPC初始化失败:"+IP+"初始化异常", 2);
        //    }
        //    return null;
        //}


        /// <summary>
        /// S7写入（暂时写这里）
        /// </summary>
        /// <param name="add"></param>
        /// <param name="value"></param>
        /// <param name="type"></param>
        /// <returns></returns>
        public bool WriteValuePoint(string add, object value)
        {
            if (this.IsConnected)
            {
                object o = new object();
                //bool
                var t = value.GetType();
                if (value.GetType() == typeof(bool))
                {
                    //byte MyData = Convert.ToByte(value);
                    int myData = Convert.ToInt32(value);
                    o = this.Write(add, myData);
                }
                //浮点
                if (value.GetType() == typeof(double) || value.GetType() == typeof(float))
                {
                    double MyData = Convert.ToDouble(value);
                    o = this.Write(add, MyData.ConvertToUInt());

                }
                //整数
                else if (value.GetType() == typeof(Int32) || value.GetType() == typeof(short))
                {
                    short MyData = Convert.ToInt16(value);
                    o = this.Write(add, MyData.ConvertToUshort());
                }
                //双整数
                else if (value.GetType() == typeof(Int32))
                {
                    int myData = Convert.ToInt32(value);
                    o = this.Write(add, myData);
                }
                if (o == null)
                {
                    return false;
                }
                if (o.ToString() == "NoError")
                {
                    return true;
                }
                else
                {
                    return false;
                }
                //return o.ToString();
            }
            else
            {
                return false;
            }
        }

        /// <summary>
        /// S7读取
        /// </summary>
        /// <param name="add"></param>
        /// <param name="type"></param>
        /// <param name="plc"></param>
        /// <returns></returns>
        public object ReadValuePoint(string add)
        {

            object MyPlcData = this.Read(add);
            return MyPlcData;

        }

        /// <summary>
        /// 自检在线
        /// </summary>
        public void IsOnline()
        {
            while (true)
            {
                Thread.Sleep(1000);
                if (!string.IsNullOrEmpty(heartAdd))
                {
                    //int heart = Convert.ToInt32(this.ReadValuePoint(heartAdd));
                    //if (heart == oldHeart)
                    //{
                    //    //掉线次数+1
                    //    lostHeartTimes++;
                    //}
                    //else
                    //{
                    //    lostHeartTimes = 0;
                    //}
                    if (!this.IsConnected)
                    {
                        //连续掉线5次以上为掉线
                        this.Close();
                        //尝试重连
                        Thread.Sleep(100);
                        this.Open();
                       
                    }
                    //oldHeart = heart;
                }
            }
        }

        /// <summary>
        /// //开启自检在线线程
        /// </summary>
        /// <param name="add"></param>
        public void OpenReadHeart(string add)
        {
            heartAdd = add;
            Thread IsOnlineThread = new Thread(this.IsOnline);
            IsOnlineThread.Start();

        }
    }
}