KinginfoGateway/src/Plugins/ThingsGateway.Foundation.Adapter.OPCDA/Da/OpcServer.cs

using System.Collections.Generic;
using System.Runtime.InteropServices;

using ThingsGateway.Foundation;

namespace OpcDaClient.Da
{
    public class OpcServer : IDisposable
    {

        private bool disposedValue;

        private OpcRcw.Da.IOPCServer m_OpcServer = null;

        public OpcServer(string name, string host = "localhost")
        {
            Name = name;
            if(host.IsNullOrEmpty())
            {
                Host = "localhost";
            }
            else
            {
                Host = host;
            }
        }

        public string Host { get; private set; }
        public bool IsConnected { get; private set; } = false;
        public List<OpcGroup> OpcGroups { get; private set; } = new List<OpcGroup>(10);
        public string Name { get; private set; }

        public ServerStatus ServerStatus { get; private set; } = new ServerStatus();

        public OperResult<OpcGroup> AddGroup(string groupName)
        {
            return AddGroup(groupName, true, 1000, 0);
        }

        /// <returns></returns>
        public OperResult<OpcGroup> AddGroup(string groupName, bool active, int reqUpdateRate, float deadBand)
        {
            if (null == m_OpcServer || IsConnected == false)
                return new OperResult<OpcGroup>("未初始化连接！");
            OpcGroup group = new OpcGroup(groupName, active, reqUpdateRate, deadBand);
            Guid riid = typeof(OpcRcw.Da.IOPCItemMgt).GUID;
            try
            {
                m_OpcServer?.AddGroup(group.Name,
                    group.IsActive ? 1 : 0,//IsActive
                    group.RequestUpdateRate,//RequestedUpdateRate 1000ms
                    group.ClientGroupHandle,
                    group.TimeBias.AddrOfPinnedObject(),
                    group.PercendDeadBand.AddrOfPinnedObject(),
                    group.LCID,
                    out group.serverGroupHandle,
                    out group.revisedUpdateRate,
                    ref riid,
                    out group.groupPointer);
                if (group.groupPointer != null)
                {
                    group.InitIoInterfaces(group.groupPointer);
                    OpcGroups.Add(group);
                }
                else
                {
                    return new OperResult<OpcGroup>("添加OPC组错误，OPC服务器返回null");
                }
                return OperResult.CreateSuccessResult(group);
            }
            catch (Exception ex)
            {
                return new OperResult<OpcGroup>(ex);
            }
        }

        public OperResult Connect()
        {
            if (!string.IsNullOrEmpty(Host) && !string.IsNullOrEmpty(Name))
            {
                var info = Discovery.OpcDiscovery.GetOpcServer(Name, Host);
                if (!info.IsSuccess)
                {
                    return info;
                }
                object o = Comn.ComInterop.CreateInstance(info.Content.CLSID, Host);
                if (o == null)
                {
                    return new(string.Format("{0}{1}无法创建com对象", info.Content.CLSID, Host));
                }
                m_OpcServer = (OpcRcw.Da.IOPCServer)o;
                IsConnected = true;
                return OperResult.CreateSuccessResult();
            }
            return new("应初始化Host与Name");
        }
        public void Dispose()
        {
            Dispose(disposing: true);
            GC.SuppressFinalize(this);
        }

        /// <summary>
        /// 服务器状态
        /// </summary>
        /// <returns></returns>
        public OperResult<ServerStatus> GetServerStatus()
        {
            if (null == m_OpcServer || IsConnected == false)
                return new OperResult<ServerStatus>("未初始化连接！");
            IntPtr statusPtr = IntPtr.Zero;
            try
            {
                m_OpcServer?.GetStatus(out statusPtr);
                OpcRcw.Da.OPCSERVERSTATUS status;
                ServerStatus = new ServerStatus();
                if (statusPtr != IntPtr.Zero)
                {
                    try
                    {
                        object o = Marshal.PtrToStructure(statusPtr, typeof(OpcRcw.Da.OPCSERVERSTATUS));
                        if (null != o)
                        {
                            status = (OpcRcw.Da.OPCSERVERSTATUS)o;
                            ServerStatus.Version = status.wMajorVersion.ToString() + "." + status.wMinorVersion.ToString() + "." + status.wBuildNumber.ToString();
                            ServerStatus.ServerState = status.dwServerState;
                            ServerStatus.StartTime = Comn.Convert.FileTimeToDateTime(status.ftStartTime);
                            ServerStatus.CurrentTime = Comn.Convert.FileTimeToDateTime(status.ftCurrentTime);
                            ServerStatus.LastUpdateTime = Comn.Convert.FileTimeToDateTime(status.ftLastUpdateTime);
                            ServerStatus.VendorInfo = status.szVendorInfo;
                        }
                        IsConnected = true;
                        return OperResult.CreateSuccessResult(ServerStatus);
                    }
                    catch (Exception ex)
                    {
                        IsConnected = false;
                        return new OperResult<ServerStatus>(ex);
                    }

                }
                else
                {
                    IsConnected = false;
                    return new OperResult<ServerStatus>("获取状态失败");
                }
            }
            catch (Exception ex)
            {
                IsConnected = false;
                return new OperResult<ServerStatus>(ex);
            }

        }

        public void RemoveGroup(OpcGroup group)
        {
            if (OpcGroups.Contains(group))
            {
                m_OpcServer?.RemoveGroup(group.ServerGroupHandle, 1);
                OpcGroups.Remove(group);
            }
        }

        protected virtual void Dispose(bool disposing)
        {
            if (!disposedValue)
            {
                try
                {
                    for (int i = 0; i < OpcGroups.Count; i++)
                        RemoveGroup(OpcGroups[i]);
                }
                catch
                {

                }
#pragma warning disable CA1416 // 验证平台兼容性
                if (m_OpcServer != null)
                {
                    Marshal.ReleaseComObject(m_OpcServer);
                    m_OpcServer = null;
                }
#pragma warning restore CA1416 // 验证平台兼容性
                if (disposing)
                {
                    OpcGroups.Clear();
                }
                disposedValue = true;
            }
        }

    }
}