using System;
using System.Net;
using System.Security.Cryptography;
using HslCommunication;
using HslCommunication.Profinet.Siemens;
using iTextSharp.text.pdf;
using iWare_SCADA_BusinessLogical.Utils;
using iWare_SCADA_Model;

namespace iWare_SCADA_BusinessLogical
{
    /// <summary>
    /// 西么子PLC
    /// </summary>
    public class Siemens_HslCommunicationService : PLCService
    {
        private SiemensS7Net siemensTcpNet = null;
        private readonly SiemensPLCS _cpu;
        private readonly string _ip;
        private readonly int _port;
        public Siemens_HslCommunicationService(HslCommunicationParam hslcpParam)
        {
            _cpu = hslcpParam.cpu;
            _ip = hslcpParam.ip;
            _port = hslcpParam.port;

            _LogType = LogType.HslCommunicationService;
        }
        /// <summary>
        /// 打开连接
        /// </summary>
        /// <returns></returns>
        public override MessageModel OpenService()
        {
            MessageModel fre = new MessageModel();
            try
            {
                //创建连接对象
                siemensTcpNet = new SiemensS7Net(_cpu, _ip);
                siemensTcpNet.IpAddress = _ip;
                siemensTcpNet.Port = Convert.ToInt16(_port);
                //siemensTcpNet.Rack = Convert.ToInt16(tb_Rack.Text);
                //siemensTcpNet
                //不记录日志！！！！否则文件太大导致问题！
                //siemensTcpNet.LogNet = new HslCommunication.LogNet.LogNetSingle("Siemens_HslCommunicationService_logs.txt");

                OperateResult operateResult = siemensTcpNet.ConnectServer();
                if (operateResult.IsSuccess)
                {
                    base.IsConnected = true;
                    fre.result = true;
                    return fre;
                }
                base.IsConnected = false;
                fre.result = false;
                fre.resMsg = "打开失败," + operateResult.Message;
                return fre;
            }
            catch (Exception ex)
            {
                base.IsConnected = false;
                Log4NetHelper.WriteErrorLog(_LogType, "初始化西门子PLC出现异常", ex);
                throw ex;
            }
        }

        public override MessageModel WriteValuePointNew(string dbNumber, string offset, object value)
        {//此方法不再使用西门子PLC
            if (dbNumber.IndexOf(SystemValue.PLCDBADDRESS_SEPARATE.ToString()) > -1)
            {
                throw new Exception("参数不正确，不应该带" + SystemValue.PLCDBADDRESS_SEPARATE.ToString());
            }
            MessageModel fre = new MessageModel();
            OperateResult operateResult = null;
            //Type proObjType = proObj.GetType();
            var address = GetAddress(dbNumber, offset, value.GetType());
            try
            {
                if (value is bool)
                {
                    bool myData = Convert.ToBoolean(value);
                    operateResult = siemensTcpNet.Write(address, myData);
                }
                else if (value is int)
                {
                    operateResult = siemensTcpNet.Write(address, Int16.Parse(value.ToString()));
                }
                else if (value is short)
                {
                    operateResult = siemensTcpNet.Write(address, (short)value);
                }
                else if (value is string)
                {
                    operateResult = siemensTcpNet.Write(address, (string)value);
                }
                else if (value is char)
                {
                    operateResult = siemensTcpNet.Write(address, (char)value);
                }
                else if (value is double|| value is float)
                {
                    operateResult = siemensTcpNet.Write(address, (double)value);
                }
                else
                {
                    operateResult = siemensTcpNet.Write(address, value.ToString());
                }
                if (!operateResult.IsSuccess)
                {
                    Log4NetHelper.WriteErrorLog(_LogType, String.Format("写入出现异常:" + operateResult.Message + "，地址:{0},值:{1}", address, value.ToString()), null);
                    fre.result = false;
                    fre.resMsg = "写入失败:" + operateResult.Message;
                }
                else
                {
                    fre.result = true;
                    //Log4NetHelper.WriteInfoLog(_LogType, String.Format("写入成功，写入地址:{0},值:{1}", address, value.ToString()));
                }
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(_LogType, String.Format("写入出现异常:" + ex.Message + "，地址:{0},值:{1}", address, value.ToString()), ex);
                fre.result = false;
                fre.resMsg = "写入失败:" + ex.Message;
            }
            return fre;
        }
        /// <summary>
        /// 写入
        /// </summary>
        /// <param name="address">地址</param>
        /// <param name="value">值</param>
        /// <returns></returns>
        public override MessageModel WriteValuePoint(string dbNumber, string offset, object value, Object proObj)
        {//此方法不再使用西门子PLC
            if (dbNumber.IndexOf(SystemValue.PLCDBADDRESS_SEPARATE.ToString()) > -1)
            {
                throw new Exception("参数不正确，不应该带" + SystemValue.PLCDBADDRESS_SEPARATE.ToString());
            }
            MessageModel fre = new MessageModel();
            OperateResult operateResult = null;
            Type proObjType = proObj.GetType();
            var address = GetAddress(dbNumber, offset, value.GetType());
            try
            {
                if (proObjType == typeof(Boolean))
                {//布尔类型
                    bool myData = Convert.ToBoolean(value);
                    operateResult = siemensTcpNet.Write(address, myData);
                }
                //浮点
                else if (proObjType == typeof(double) || proObjType == typeof(float))
                {
                    double MyData = Convert.ToDouble(value);
                    operateResult = siemensTcpNet.Write(address, MyData);

                }
                //整数
                else if (proObjType == typeof(Int16) || proObjType == typeof(short))
                {
                    short MyData = Convert.ToInt16(value);
                    operateResult = siemensTcpNet.Write(address, MyData);//此处需要注意，短整型的此处不确定是否会报错，需要测试
                    //operateResult = siemensTcpNet.Write(address, MyData.ConvertToUshort());
                }
                //双整数
                else if (proObjType == typeof(Int32))
                {
                    int myData = Convert.ToInt32(value);
                    operateResult = siemensTcpNet.Write(address, myData);
                }
                //Char
                else if (proObjType == typeof(Char))
                {//char要转换成int类型，写给PLC
                    int myData = Convert.ToInt32(value);
                    byte b = (byte)myData;
                    operateResult = siemensTcpNet.Write(address, b);
                }
                //String
                else if (proObjType == typeof(String))
                {
                    operateResult = siemensTcpNet.Write(address, value.ToString());
                }
                else
                {
                    operateResult = siemensTcpNet.Write(address, value.ToString());
                }
                if (!operateResult.IsSuccess)
                {
                    Log4NetHelper.WriteErrorLog(_LogType, String.Format("写入出现异常:" + operateResult.Message + "，地址:{0},值:{1}", address, value.ToString()), null);
                    fre.result = false;
                    fre.resMsg = "写入失败:" + operateResult.Message;
                }
                else
                {
                    fre.result = true;
                    //Log4NetHelper.WriteInfoLog(_LogType, String.Format("写入成功，写入地址:{0},值:{1}", address, value.ToString()));
                }
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(_LogType, String.Format("写入出现异常:" + ex.Message + "，地址:{0},值:{1}", address, value.ToString()), ex);
                fre.result = false;
                fre.resMsg = "写入失败:" + ex.Message;
            }
            return fre;
        }

        public override MessageModel WriteValuePoint(string fullAddress, object value, object proObj)
        {
            var arr = fullAddress.Split(SystemValue.PLCDBADDRESS_SEPARATE);
            string dbNumber = arr[0];
            string offset = arr[1];
            return WriteValuePoint(dbNumber, offset, value, proObj);
        }

        /// <summary>
        /// 读取
        /// </summary>
        /// <param name="dbNumber">DB块名</param>
        /// <param name="offset">偏移量</param>
        /// <param name="type"></param>
        /// <returns></returns>
        public override object ReadValuePoint(string dbNumber, string offset, int stringlen, Type type = default(Type))
        {
            if (dbNumber.IndexOf(SystemValue.PLCDBADDRESS_SEPARATE.ToString()) > -1)
            {
                throw new Exception("参数不正确，不应该带" + SystemValue.PLCDBADDRESS_SEPARATE.ToString());
            }
            var address = GetAddress(dbNumber, offset, type);
            try
            {
                if (type == typeof(bool))
                {//布尔要转换成1和0写入
                    bool MyPlcData = siemensTcpNet.ReadBool(address).Content;
                    return MyPlcData;
                }
                //浮点
                else if (type == typeof(double) || type == typeof(float))
                {
                    var MyPlcData = siemensTcpNet.ReadFloat(address).Content;
                    return MyPlcData;

                }
                //整数
                else if (type == typeof(short))
                {
                    int MyPlcData = siemensTcpNet.ReadInt16(address).Content;
                    return MyPlcData;
                }
                //双整数
                else if (type == typeof(Int32))
                {
                    long MyPlcData = siemensTcpNet.ReadInt32(address).Content;
                    return MyPlcData;
                }
                //Char
                else if (type == typeof(Char))
                {//char要转换成int类型，写给PLC
                    char MyPlcData = (char)(siemensTcpNet.ReadByte(address).Content);
                    return MyPlcData.ToString();
                }
                //String
                else if (type == typeof(String))
                {
                    var data = siemensTcpNet.ReadString(address, (ushort)stringlen);
                    var MyPlcData = siemensTcpNet.ReadString(address, (ushort)stringlen).Content;
                    //write.Message = siemensTcpNet.ReadString(write.Name).Message;

                    //string MyPlcData = siemensTcpNet.ReadString(address).Content;
                    return MyPlcData == null ? "" : MyPlcData.ToString();
                }
                else
                {
                    var MyPlcData = siemensTcpNet.ReadString(address).Content;
                    return MyPlcData == null ? "" : MyPlcData.ToString();
                }
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(_LogType, String.Format("读取出现异常:" + ex.Message + "，地址:{0}", address), ex);
                throw;
            }
        }
        /// <summary>
        /// 读取
        /// </summary>
        /// <param name="dbNumber">DB块名</param>
        /// <param name="offset">偏移量</param>
        /// <param name="type"></param>
        /// <returns></returns>
        public override object ReadValuePoint(string dbNumber, string offset, Type type = default(Type))
        {
            if (dbNumber.IndexOf(SystemValue.PLCDBADDRESS_SEPARATE.ToString()) > -1)
            {
                throw new Exception("参数不正确，不应该带" + SystemValue.PLCDBADDRESS_SEPARATE.ToString());
            }
            var address = GetAddress(dbNumber, offset, type);
            try
            {
                if (type == typeof(bool))
                {//布尔要转换成1和0写入
                    var MyPlcData11 = siemensTcpNet.ReadBool(address);
                    bool MyPlcData = siemensTcpNet.ReadBool(address).Content;
                    return MyPlcData;
                }
                //浮点
                else if (type == typeof(double) || type == typeof(float))
                {
                    var MyPlcData = siemensTcpNet.ReadFloat(address).Content;
                    return MyPlcData;

                }
                //整数
                else if (type == typeof(short))
                {
                    int MyPlcData = siemensTcpNet.ReadInt16(address).Content;
                    return MyPlcData;
                }
                //双整数
                else if (type == typeof(Int32))
                {
                    long MyPlcData = siemensTcpNet.ReadInt32(address).Content;
                    return MyPlcData;
                }
                //Char
                else if (type == typeof(Char))
                {//char要转换成int类型，写给PLC
                    char MyPlcData = (char)(siemensTcpNet.ReadByte(address).Content);
                    return MyPlcData.ToString();
                }
                //String
                else if (type == typeof(String))
                {
                    string MyPlcData = siemensTcpNet.ReadString(address).Content;
                    return MyPlcData == null ? "" : MyPlcData.ToString();
                }
                else
                {
                    var MyPlcData = siemensTcpNet.ReadString(address).Content;
                    return MyPlcData == null ? "" : MyPlcData.ToString();
                }
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(_LogType, String.Format("读取出现异常:" + ex.Message + "，地址:{0}", address), ex);
                throw;
            }
        }


        public override object ReadValuePointV2(string fullAddress, Type type = default(Type), int stringlen=0)
        {
            if (fullAddress.IndexOf(SystemValue.PLCDBADDRESS_SEPARATE.ToString()) > -1)
            {
                throw new Exception("参数不正确，不应该带" + SystemValue.PLCDBADDRESS_SEPARATE.ToString());
            }
            var address = fullAddress;

            try
            {
                if (type == typeof(bool))
                {//布尔要转换成1和0写入
                    bool MyPlcData = siemensTcpNet.ReadBool(address).Content;
                    return MyPlcData;
                }
                //浮点
                else if (type == typeof(double) || type == typeof(float))
                {
                    var MyPlcData = siemensTcpNet.ReadFloat(address).Content;
                    return MyPlcData;

                }
                //整数
                else if (type == typeof(short))
                {
                    int MyPlcData = siemensTcpNet.ReadInt16(address).Content;
                    return MyPlcData;
                }
                //双整数
                else if (type == typeof(Int32))
                {
                    long MyPlcData = siemensTcpNet.ReadInt32(address).Content;
                    return MyPlcData;
                }
                //Char
                else if (type == typeof(Char))
                {//char要转换成int类型，写给PLC
                    char MyPlcData = (char)(siemensTcpNet.ReadByte(address).Content);
                    return MyPlcData.ToString();
                }
                //String
                else if (type == typeof(String))
                {
                    var data = siemensTcpNet.ReadString(address, (ushort)stringlen);
                    var MyPlcData = siemensTcpNet.ReadString(address, (ushort)stringlen).Content;
                    //write.Message = siemensTcpNet.ReadString(write.Name).Message;

                    //string MyPlcData = siemensTcpNet.ReadString(address).Content;
                    return MyPlcData == null ? "" : MyPlcData.ToString();
                }
                else
                {
                    var MyPlcData = siemensTcpNet.ReadString(address).Content;
                    return MyPlcData == null ? "" : MyPlcData.ToString();
                }
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(_LogType, String.Format("读取出现异常:" + ex.Message + "，地址:{0}", address), ex);
                throw;
            }
        }
        public override object ReadValuePoint(string fullAddress, Type type = default(Type))
        {
            var arr = fullAddress.Split(SystemValue.PLCDBADDRESS_SEPARATE);
            string dbNumber = arr[0];
            string offset = arr[1];
            return ReadValuePoint(dbNumber, offset, type);
        }


        public override string GetAddress(string dbNumber, string offset, Type type = default(Type))
        {
            return "DB" + dbNumber + "." + offset;
        }

        public override void Close()
        {
            if (siemensTcpNet != null)
                siemensTcpNet.ConnectClose();
        }
    }
}