using HslCommunication;
using HslCommunication.Core.Address;
using HslCommunication.Profinet.Siemens;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Net.NetworkInformation;
using System.Text;
using System.Threading;
using WIDESEA_Common;
using WIDESEA_Common.CutomerModel;
using WIDESEA_Core.Extensions;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services.Repositories;
using WIDESEA_WCS.WCSClient.Delta;
using WIDESEA_WCS.WCSClient.Melsec;
using WIDESEA_WCS.WCSClient.Omron;
using WIDESEA_WCS.WCSClient.Siemens;

namespace WIDESEA_WCS.WCSClient
{
    public class PLCClient
    {
        /// <summary>
        /// PLC连接名称
        /// </summary>
        public string PLCName { get; set; }

        /// <summary>
        /// PLC类型
        /// </summary>
        public string PLCType { get; set; }

        /// <summary>
        /// 西门子 PLC
        /// </summary>
        public SiemensPLCClient SiemensPLCClient { get; set; }

        /// <summary>
        /// 欧姆龙 PLC
        /// </summary>
        public OmronPLCClient OmronPLCClient { get; set; }

        public OmronCIPPLCClient OmronCIPPLCClient { get; set; }

        /// <summary>
        /// 三菱 PLC
        /// </summary>
        public MelsecPLCClient MelsecPLCClient { get; set; }

        /// <summary>
        /// 三菱 PLC5010端口
        /// </summary>
        public MelsecPLCClient5010 MelsecPLCClient5010 { get; set; }

        /// <summary>
        /// 三菱 PLC5011端口
        /// </summary>
        public MelsecPLCClient5011 MelsecPLCClient5011 { get; set; }

        public MelsecPLCClient5002 MelsecPLCClient5002 { get; set; }

        /// <summary>
        /// 台达PLC
        /// </summary>
        public DeltaPLCClient DeltaPLCClient { get; set; }

        /// <summary>
        /// 设备类型
        /// </summary>
        public string EquipType { get; set; }

        /// <summary>
        /// 设备编号
        /// </summary>
        public string PLCDescroption { get; set; }
        /// <summary>
        /// 下料地址
        /// </summary>
        public string PLCDownLoc { get; set; }

        /// <summary>
        /// 是否已连接
        /// </summary>
        public bool IsConnected { get; set; } = false;

        public PLCClient(string type, dt_plcinfohead plcinfohead)
        {
            PLCType = type;
            switch (type)
            {
                case "SiemensPLCClient":
                    SiemensPLCClient = new SiemensPLCClient(HslCommunication.Profinet.Siemens.SiemensPLCS.S1200)
                    {
                        PLCIPAddress = plcinfohead.plcinfo_ip,
                        PLCName = plcinfohead.plcinfo_name,
                        PLCDescroption = plcinfohead.plcinfo_remark,
                        PLCDBItems = dt_plcinfodetailRepository.Instance.Find(x => x.plcdetail_headid == plcinfohead.plcinfo_id).Select(x => new DBItemGroup { ItemAddress = x.plcdetail_db.Trim() + "." + x.plcdetail_value.Trim(), ItemDataType = x.plcdetail_valtype.Trim(), ItemName = x.plcdetail_name.Trim(), ItemOperatorType = x.plcdetail_opratortype?.Trim(), EquipNum = x.plcdetail_number.Trim(), Remark = x.plcdetail_remark.Trim() }).ToList(),
                        //Slot = 0
                    };
                    break;
                case "OmronPLCClient":
                    OmronPLCClient = new OmronPLCClient()
                    {
                        PLCIPAddress = plcinfohead.plcinfo_ip,
                        PLCName = plcinfohead.plcinfo_name,
                        PLCDescroption = plcinfohead.plcinfo_remark,
                        PLCDBItems = dt_plcinfodetailRepository.Instance.Find(x => x.plcdetail_headid == plcinfohead.plcinfo_id).Select(x => new DBItemGroup { ItemAddress = x.plcdetail_db.Trim() + "." + x.plcdetail_value.Trim(), ItemDataType = x.plcdetail_valtype.Trim(), ItemName = x.plcdetail_name.Trim(), ItemOperatorType = x.plcdetail_opratortype?.Trim(), EquipNum = x.plcdetail_number.Trim(), Remark = x.plcdetail_remark.Trim() }).ToList()
                    };
                    break;
                case "MecselPLCClient":
                    MelsecPLCClient = new MelsecPLCClient()
                    {
                        PLCIPAddress = plcinfohead.plcinfo_ip,
                        PLCName = plcinfohead.plcinfo_name,
                        PLCDescroption = plcinfohead.plcinfo_remark,
                        PLCDBItems = dt_plcinfodetailRepository.Instance.Find(x => x.plcdetail_headid == plcinfohead.plcinfo_id).Select(x => new DBItemGroup { ItemAddress = x.plcdetail_db.Trim() + "." + x.plcdetail_value.Trim(), ItemDataType = x.plcdetail_valtype.Trim(), ItemName = x.plcdetail_name.Trim(), ItemOperatorType = x.plcdetail_opratortype?.Trim(), EquipNum = x.plcdetail_number.Trim(), Remark = x.plcdetail_remark.Trim() }).ToList()
                    };
                    break;
                case "DeltaPLCClient":
                    DeltaPLCClient = new DeltaPLCClient()
                    {
                        PLCIPAddress = plcinfohead.plcinfo_ip,
                        PLCName = plcinfohead.plcinfo_name,
                        PLCDescroption = plcinfohead.plcinfo_remark,
                        PLCDBItems = dt_plcinfodetailRepository.Instance.Find(x => x.plcdetail_headid == plcinfohead.plcinfo_id).Select(x => new DBItemGroup { ItemAddress = x.plcdetail_db.Trim() + "." + x.plcdetail_value.Trim(), ItemDataType = x.plcdetail_valtype.Trim(), ItemName = x.plcdetail_name.Trim(), ItemOperatorType = x.plcdetail_opratortype?.Trim(), EquipNum = x.plcdetail_number.Trim(), Remark = x.plcdetail_remark.Trim() }).ToList()
                    };
                    break;
                case "MecselPLCClient5010":
                    MelsecPLCClient5010 = new MelsecPLCClient5010()
                    {
                        PLCIPAddress = plcinfohead.plcinfo_ip,
                        PLCName = plcinfohead.plcinfo_name,
                        PLCDescroption = plcinfohead.plcinfo_remark,
                        PLCDBItems = dt_plcinfodetailRepository.Instance.Find(x => x.plcdetail_headid == plcinfohead.plcinfo_id).Select(x => new DBItemGroup { ItemAddress = x.plcdetail_db.Trim() + "." + x.plcdetail_value.Trim(), ItemDataType = x.plcdetail_valtype.Trim(), ItemName = x.plcdetail_name.Trim(), ItemOperatorType = x.plcdetail_opratortype?.Trim(), EquipNum = x.plcdetail_number.Trim(), Remark = x.plcdetail_remark.Trim() }).ToList()
                    };
                    break;
                case "MecselPLCClient5011":
                    MelsecPLCClient5011 = new MelsecPLCClient5011()
                    {
                        PLCIPAddress = plcinfohead.plcinfo_ip,
                        PLCName = plcinfohead.plcinfo_name,
                        PLCDescroption = plcinfohead.plcinfo_remark,
                        PLCDBItems = dt_plcinfodetailRepository.Instance.Find(x => x.plcdetail_headid == plcinfohead.plcinfo_id).Select(x => new DBItemGroup { ItemAddress = x.plcdetail_db.Trim() + "." + x.plcdetail_value.Trim(), ItemDataType = x.plcdetail_valtype.Trim(), ItemName = x.plcdetail_name.Trim(), ItemOperatorType = x.plcdetail_opratortype?.Trim(), EquipNum = x.plcdetail_number.Trim(), Remark = x.plcdetail_remark.Trim() }).ToList()
                    };
                    break;
                case "MecselPLCClient5002":
                    MelsecPLCClient5002 = new MelsecPLCClient5002()
                    {
                        PLCIPAddress = plcinfohead.plcinfo_ip,
                        PLCName = plcinfohead.plcinfo_name,
                        PLCDescroption = plcinfohead.plcinfo_remark,
                        PLCDBItems = dt_plcinfodetailRepository.Instance.Find(x => x.plcdetail_headid == plcinfohead.plcinfo_id).Select(x => new DBItemGroup { ItemAddress = x.plcdetail_db.Trim() + "." + x.plcdetail_value.Trim(), ItemDataType = x.plcdetail_valtype.Trim(), ItemName = x.plcdetail_name.Trim(), ItemOperatorType = x.plcdetail_opratortype?.Trim(), EquipNum = x.plcdetail_number.Trim(), Remark = x.plcdetail_remark.Trim() }).ToList()
                    };
                    break;
                case "OmronCIPPLCClient":
                    OmronCIPPLCClient = new OmronCIPPLCClient()
                    {
                        PLCIPAddress = plcinfohead.plcinfo_ip,
                        PLCName = plcinfohead.plcinfo_name,
                        PLCDescroption = plcinfohead.plcinfo_remark,
                        PLCDBItems = dt_plcinfodetailRepository.Instance.Find(x => x.plcdetail_headid == plcinfohead.plcinfo_id).Select(x => new DBItemGroup { ItemAddress = x.plcdetail_db.Trim() , ItemDataType = x.plcdetail_valtype.Trim(), ItemName = x.plcdetail_name.Trim(), ItemOperatorType = x.plcdetail_opratortype?.Trim(), EquipNum = x.plcdetail_number.Trim(), Remark = x.plcdetail_remark.Trim() }).ToList()
                    };
                    break;
            }
        }

        #region 连接PLC,将短连接切换成长连接模式
        /// <summary>
        /// 连接PLC
        /// </summary>
        public string Connect()
        {
            string str = "";
            switch (PLCType)
            {
                case "SiemensPLCClient":
                    str = SiemensPLCClient.Connect();
                    IsConnected = SiemensPLCClient.IsConnected;
                    break;
                case "OmronPLCClient":
                    str = OmronPLCClient.Connect();
                    IsConnected = OmronPLCClient.IsConnected;
                    break;
                case "MecselPLCClient":
                    str = MelsecPLCClient.Connect();
                    IsConnected = MelsecPLCClient.IsConnected;
                    break;
                case "DeltaPLCClient":
                    str = DeltaPLCClient.Connect();
                    IsConnected = DeltaPLCClient.IsConnected;
                    break;
                case "MecselPLCClient5010":
                    str = MelsecPLCClient5010.Connect();
                    IsConnected = MelsecPLCClient5010.IsConnected;
                    break;
                case "MecselPLCClient5011":
                    str = MelsecPLCClient5011.Connect();
                    IsConnected = MelsecPLCClient5011.IsConnected;
                    break;
                case "MecselPLCClient5002":
                    str = MelsecPLCClient5002.Connect();
                    IsConnected = MelsecPLCClient5002.IsConnected;
                    break;
                case "OmronCIPPLCClient":
                    str = OmronCIPPLCClient.Connect();
                    IsConnected = OmronCIPPLCClient.IsConnected;
                    break;
            }
            return str;
        }
        #endregion

        #region 断开与PLC的连接,将短连接切换成长连接模式
        /// <summary>
        /// 断开与PLC的连接
        /// </summary>
        public void Disconnect()
        {
            switch (PLCType)
            {
                case "SiemensPLCClient1111":
                    SiemensPLCClient.Disconnect();
                    IsConnected = SiemensPLCClient.IsConnected;
                    break;
                case "OmronPLCClient":
                    OmronPLCClient.Disconnect();
                    IsConnected = OmronPLCClient.IsConnected;
                    break;
                case "MecselPLCClient5010":
                    MelsecPLCClient.Disconnect();
                    IsConnected = MelsecPLCClient.IsConnected;
                    break;
                case "MecselPLCClient5011":
                    MelsecPLCClient5011.Disconnect();
                    IsConnected = MelsecPLCClient5011.IsConnected;
                    break;
                case "MecselPLCClient5002":
                    MelsecPLCClient5002.Disconnect();
                    IsConnected = MelsecPLCClient5002.IsConnected;
                    break;
                case "OmronCIPPLCClient":
                    OmronCIPPLCClient.Disconnect();
                    IsConnected = OmronCIPPLCClient.IsConnected;
                    break;
            }
        }
        #endregion

        #region 根据名称/描述读取PLC数据
        /// <summary>
        /// 根据名称/描述读取PLC数据
        /// </summary>
        /// <param name="itemName">名称/描述（数据库中plcdetail_name列）</param>
        /// <returns></returns>
        public virtual object ReadValue(string itemName)
        {
            object result = null;
            switch (PLCType)
            {
                case "SiemensPLCClient":
                    result = SiemensPLCClient.ReadValue(itemName);
                    break;
                case "OmronPLCClient":
                    result = OmronPLCClient.ReadValue(itemName);
                    break;
                case "MelsecPLCClient":
                    result = MelsecPLCClient.ReadValue(itemName);
                    break;
            }
            return result;
        }
        #endregion
        public virtual object ReadBarcodeValue(string itemName)
        {
            object result = null;
            switch (PLCType)
            {
                case "SiemensPLCClient":
                    result = SiemensPLCClient.ReadBarcodeValue(itemName);
                    break;
                case "OmronPLCClient":
                    result = OmronPLCClient.ReadValue(itemName);
                    break;
                case "MelsecPLCClient":
                    result = MelsecPLCClient.ReadValue(itemName);
                    break;
            }
            return result;
        }

        #region 根据PLCDBItem读取PLC数据
        /// <summary>
        /// 根据PLCDBItem读取PLC数据
        /// </summary>
        /// <param name="item"></param>
        /// <returns></returns>
        public virtual object ReadValue(DBItemGroup item)
        {
            object result = null;
            switch (PLCType)
            {
                case "SiemensPLC":
                    result = SiemensPLCClient.ReadValue(item);
                    break;
                case "OmronPLC":
                    result = OmronPLCClient.ReadValue(item);
                    break;
                case "MelsecPLC":
                    result = MelsecPLCClient.ReadValue(item);
                    break;
            }
            return result;
        }
        #endregion

        #region 根据设备编号读取PLC数据
        /// <summary>
        /// 根据设备编号读取PLC数据
        /// </summary>
        /// <param name="equipNum">设备编号</param>
        /// <returns>json字符串</returns>
        public object ReadValues(string equipNum)
        {
            object result = null;
            switch (PLCType)
            {
                case "SiemensPLC":
                    result = SiemensPLCClient.ReadValues(equipNum);
                    break;
                case "OmronPLC":
                    result = OmronPLCClient.ReadValues(equipNum);
                    break;
                case "MelsecPLC":
                    result = MelsecPLCClient.ReadValues(equipNum);
                    break;
            }
            return result;

        }
        #endregion

        #region 根据名称/描述读取PLC数据返回设备编号和值的JSON字符串
        /// <summary>
        /// 根据名称/描述读取PLC数据返回设备编号和值的JSON字符串
        /// </summary>
        /// <param name="itemName">名称/描述（数据库中plcdetail_name列）</param>
        /// <returns>json字符串</returns>
        public string ReadValuesByItemName(string itemName)
        {
            object result = null;
            switch (PLCType)
            {
                case "SiemensPLC":
                    result = SiemensPLCClient.ReadValues(itemName);
                    break;
                case "OmronPLC":
                    result = OmronPLCClient.ReadValues(itemName);
                    break;
                case "MelsecPLC":
                    result = MelsecPLCClient.ReadValues(itemName);
                    break;
            }
            return result.Serialize();

        }
        #endregion

        #region 根据名称/描述和设备编号读取PLC数据
        /// <summary>
        /// 根据名称/描述和设备编号读取PLC数据
        /// </summary>
        /// <param name="itemName">名称/描述（数据库中plcdetail_name列）</param>
        /// <param name="equipNum">设备编号</param>
        /// <returns></returns>
        public virtual object ReadValue(string itemName, string equipNum)
        {
            object result = null;
            switch (PLCType)
            {
                case "SiemensPLCClient":
                    result = SiemensPLCClient.ReadValue(itemName, equipNum);
                    break;
                case "OmronPLCClient":
                    result = OmronPLCClient.ReadValue(itemName, equipNum);
                    break;
                case "MecselPLCClient":
                    result = MelsecPLCClient.ReadValue(itemName, equipNum);
                    break;
                case "DeltaPLCClient":
                    result = DeltaPLCClient.ReadValue(itemName, equipNum);
                    break;
                case "MecselPLCClient5010":
                    result = MelsecPLCClient5010.ReadValue(itemName, equipNum);
                    break;
                case "MecselPLCClient5002":
                    result = MelsecPLCClient5002.ReadValue(itemName, equipNum);
                    break;
                case "OmronCIPPLCClient":
                    result = OmronCIPPLCClient.ReadValue(itemName, equipNum);
                    break;
            }
            //return result.Serialize();
            return result;
        }
        #endregion

        #region 将数据写入到PLC中
        /// <summary>
        /// 将数据写入到PLC中
        /// </summary>
        /// <param name="itemName">名称/描述（数据库中plcdetail_name列）</param>
        /// <param name="value">写入的值</param>
        /// <returns></returns>
        public virtual bool WriteValue(string itemName, object value)
        {
            bool result = false;
            switch (PLCType)
            {
                case "SiemensPLCClient":
                    result = SiemensPLCClient.WriteValue(itemName, value);
                    break;
                case "OmronPLCClient":
                    result = OmronPLCClient.WriteValue(itemName, value);
                    break;
                case "MelsecPLCClient":
                    result = MelsecPLCClient.WriteValue(itemName, value);
                    break;
            }
            return result;
        }
        #endregion
        public virtual bool WriteBarcodeValue(string itemName, object value)
        {
            bool result = false;
            switch (PLCType)
            {
                case "SiemensPLCClient":
                    result = SiemensPLCClient.WriteBarcodeValue(itemName, value);
                    break;
                case "OmronPLCClient":
                    result = OmronPLCClient.WriteValue(itemName, value);
                    break;
                case "MelsecPLCClient":
                    result = MelsecPLCClient.WriteValue(itemName, value);
                    break;
            }
            return result;
        }
        #region 将数据写入到PLC中
        /// <summary>
        /// 将数据写入到PLC中
        /// </summary>
        /// <param name="itemName">名称/描述（数据库中plcdetail_name列）</param>
        /// <param name="value">写入的值</param>
        /// <returns></returns>
        public virtual bool WriteValue(string itemName, string equipNum, object value)
        {
            bool result = false;
            switch (PLCType)
            {
                case "SiemensPLCClient":
                    result = SiemensPLCClient.WriteValue(itemName, equipNum, value);
                    break;
                case "OmronPLCClient":
                    result = OmronPLCClient.WriteValue(itemName, equipNum, value);
                    break;
                case "MelsecPLCClient":
                    result = MelsecPLCClient.WriteValue(itemName, equipNum, value);
                    break;
                case "MecselPLCClient5010":
                    result = MelsecPLCClient5010.WriteValue(itemName, equipNum, value);
                    break;
                case "MecselPLCClient":
                    result = MelsecPLCClient.WriteValue(itemName, equipNum, value);
                    break;
                case "OmronCIPPLCClient":
                    result = OmronCIPPLCClient.WriteValue(itemName, equipNum, value);
                    break;
            }
            return result;
        }
        #endregion

    }
}