PunkHPX8/Framework/Common/IOCore/IOModuleManager.cs

using Aitex.Core.RT.Log;
using Aitex.Core.RT.SCCore;
using Aitex.Core.Util;
using MECF.Framework.Common.Beckhoff.ModuleIO;
using MECF.Framework.Common.Device.Festo;
using MECF.Framework.Common.Device.Galil;
using MECF.Framework.Common.Device.Wago;
using MECF.Framework.Common.TwinCat;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace MECF.Framework.Common.IOCore
{
    public class IOModuleManager : Singleton<IOModuleManager>   
    {
        #region 内部变量
        /// <summary>
        /// 模块变量更新委托字典(key-模块.变量,value-变量委托事件
        /// </summary>
        private Dictionary<string, BeckhoffDelegate.OnUpdateModuleVariableValue> _moduleVariableActionDic = new Dictionary<string, BeckhoffDelegate.OnUpdateModuleVariableValue>();
        /// <summary>
        /// 变量数值字典（key-io变量名称,value-数值)
        /// </summary>
        private Dictionary<string, object> _nameVariableValueDic = new Dictionary<string, object>();
        /// <summary>
        /// Festo名称集合
        /// </summary>
        private List<string> _festoIONames = new List<string>();
        /// <summary>
        /// Wago IO集合
        /// </summary>
        private List<string> _wagoIONames = new List<string>();
        /// <summary>
        /// 倍福IO集合
        /// </summary>
        private List<string> _beckhoffIONames = new List<string>();
        #endregion
        /// <summary>
        /// 初始化
        /// </summary>
        public void Initialize()
        {
            BeckhoffManager.Instance.Initialize(_beckhoffIONames);
            FestoControllerCfgManager.Instance.Initialize(_festoIONames);
            WagoControllerCfgManager.Instance.Initialize(_wagoIONames);
        }
        /// <summary>
        /// 写IO数值
        /// </summary>
        /// <param name="name"></param>
        /// <param name="value"></param>
        /// <returns></returns>
        public bool WriteIoValue(string name, object value)
        {
            if (_festoIONames.Contains(name))
            {
                return FestoControllerCfgManager.Instance.SetDoValue(name, (bool)value);
            }
            else if (_wagoIONames.Contains(name))
            {
                return WagoControllerCfgManager.Instance.WriteIOValue(name, value);
            }
            else if (_beckhoffIONames.Contains(name))
            {
                return BeckhoffIOManager.Instance.WriteIoValue(name, value);
            }
            else
            {
                return false;
            }
        }

        /// <summary>
        /// 注册变量数值发生变化回调
        /// </summary>
        /// <param name="moduleName"></param>
        /// <param name="variable"></param>
        /// <param name="onUpdateModuleVariableValue"></param>
        public void SubscribeModuleVariable(string moduleName, string variable, BeckhoffDelegate.OnUpdateModuleVariableValue onUpdateModuleVariableValue)
        {
            string name = $"{moduleName}.{variable}";
            _moduleVariableActionDic[name] = onUpdateModuleVariableValue;
            //根据模块变量名称获取相应的IO变量名称
            
            string ioName = BeckhoffModuleIOManager.Instance.GetIoNameByInnerModuleName(name);
            if (!string.IsNullOrEmpty(ioName))
            {
                if (_nameVariableValueDic.ContainsKey(ioName))
                {
                    _moduleVariableActionDic[name].Invoke(variable, _nameVariableValueDic[ioName]);
                }
            }
            else
            {
                if (_nameVariableValueDic.ContainsKey(name))
                {
                    _moduleVariableActionDic[name].Invoke(variable, _nameVariableValueDic[name]);
                }
            }
        }
        /// <summary>
        /// 更新IO数值
        /// </summary>
        /// <param name="name"></param>
        /// <param name="value"></param>
        public void UpdateIoValue(string name, object value)
        {
            bool _enableRead = SC.GetValue<bool>("Twincat.EnableReadLog");
            if (_enableRead)
            {
                LOG.WriteBackgroundLog(eEvent.INFO_TWINCAT, "System", $"read {name} value {value}");
            }
            _nameVariableValueDic[name] = value;
            //根据io变量名称获取模块变量名称
            string innerModuleName = BeckhoffModuleIOManager.Instance.GetInnerModuleNameByIOName(name);
            if (!string.IsNullOrEmpty(innerModuleName))
            {
                if (_moduleVariableActionDic.ContainsKey(innerModuleName))
                {
                    string[] strAry = innerModuleName.Split('.');
                    if (strAry.Length != 0)
                    {
                        _moduleVariableActionDic[innerModuleName].Invoke(strAry[strAry.Length - 1], value);
                    }
                }
            }
            else
            {
                if (_moduleVariableActionDic.ContainsKey(name))
                {
                    string[] strAry = name.Split('.');
                    if (strAry.Length != 0)
                    {
                        _moduleVariableActionDic[name].Invoke(strAry[strAry.Length - 1], value);
                    }
                }
            }
        }
    }
}