using iWareOpc.Cache.Entity;
using iWareOpc.Properties;
using iWareOpc.Utils;
using OpcAccess.Access.Entity;
using OpcAccess.Access.Service;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace iWareOpc.Opc.Service
{
    public class OpcService
    {
        private static object Lock = new object();

        private OpcService() { }

        private static OpcService Instance = null;

        /// <summary>
        /// 获取单例的方法
        /// </summary>
        /// <returns>Opc的单例实体</returns>
        public static OpcService GetInstance()
        {
            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new OpcService();
                    }
                }
            }
            return Instance;
        }

        /// <summary>
        /// 根据ip，群获取opc服务
        /// </summary>
        /// <param name="ip"></param>
        /// <param name="opcGroups"></param>
        /// <returns></returns>
        public OpcAccessService GetOpcAccessService(string ip, List<OpcGroupEntity> opcGroups)
        {
            var opcAccessService = new OpcAccessService(ip);
            opcAccessService.Init(opcGroups);
            return opcAccessService;
        }

        /// <summary>
        /// 写入OPC值
        /// </summary>
        /// <param name="groupName">组名</param>
        /// <param name="itemName">项名</param>
        /// <param name="value">写入值</param>
        /// <returns>是否写入成功</returns>
        public bool WriteValue(string groupName, string itemName, object value)
        {
            
            try
            {
                return CacheEntity.OpcAccessService.WriteValuePoint(groupName, itemName, value);
            }
            catch (Exception ex)
            {
                LogTextHelper.WriteLog(Resources.LogDir,this.ToString(),"WriteValue",ex.Message);
                return false;
            }
        }


        /// <summary>
        /// 批量写入OPC值
        /// </summary>
        /// <param name="groupName">组名</param>
        /// <param name="itemNames">项目名列表</param>
        /// <param name="values">写入值列表</param>
        /// <returns>是否写入成功</returns>
        public bool WriteValue(string groupName, List<string> itemNames, List<object> values)
        {
            
            try
            {
                return CacheEntity.OpcAccessService.WriteValuePoint(groupName, itemNames, values);
            }
            catch (Exception ex)
            {
                LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "WriteValue", ex.Message);
                return false;
            }
        }

        /// <summary>
        /// 读取地址的值
        /// </summary>
        /// <param name="groupName">组名</param>
        /// <param name="itemName">项目名</param>
        /// <returns>读到的值</returns>
        public object ReadValue(string groupName, string itemName)
        {
            
            try
            {
                
                var opcData = CacheEntity.OpcAccessService.ReadValuePoint(groupName, itemName);

                return opcData == null ? null : opcData.ItemValue;

            }
            catch (Exception ex)
            {
                LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "ReadValue", ex.Message);
                return null;
            }


        }

        /// <summary>
        /// 批量读取地址的值
        /// </summary>
        /// <param name="groupName">组名</param>
        /// <param name="itemNames">项目名</param>
        /// <returns>读到的值列表</returns>
        public List<object> ReadValue(string groupName, List<string> itemNames)
        {
           
            try
            {
                var values = new List<object>();

                var opcDatas = CacheEntity.OpcAccessService.ReadValuePoint(groupName, itemNames);

                opcDatas.ForEach(x => values.Add(x.ItemValue));
                
                return values;

            }
            catch (Exception ex)
            {
                LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "ReadValues", ex.Message);
                return new List<object>();
            }
        }
    }
}