CyberX8/CyberX8_RT/Devices/Reservoir/ReservoirDiReplenHelper.cs

using Aitex.Core.RT.Device;
using Aitex.Core.RT.Log;
using Aitex.Core.RT.SCCore;
using CyberX8_RT.Devices.Facilities;
using MECF.Framework.Common.Alarm;
using MECF.Framework.Common.Persistent.Reservoirs;
using MECF.Framework.Common.RecipeCenter;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;

namespace CyberX8_RT.Devices.Reservoir
{
    public class ReservoirDiReplenHelper
    {
        #region 内部变量
        /// <summary>
        /// 模块名称
        /// </summary>
        private string _module;
        /// <summary>
        /// 持久化对象
        /// </summary>
        private ReservoirsPersistentValue _persistentValue;
        /// <summary>
        /// 锁
        /// </summary>
        private object _locker = new object();
        #endregion
        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="module"></param>
        /// <param name="persistentValue"></param>
        /// <param name="resRecipe"></param>
        public ReservoirDiReplenHelper(string module, ReservoirsPersistentValue persistentValue)
        {
            _module = module;
            _persistentValue = persistentValue;
        }
        /// <summary>
        /// 监控
        /// </summary>
        public void MonitorPeriodTime(Action<bool> timeOutAction)
        {
            double levelHysteresis = SC.GetValue<double>("Reservoir.LevelHysteresis");
            double diValveMaxOnTimePeriod = SC.GetValue<double>($"Reservoir.{_module}.DIValveMaxOnTimePeriod");
            //没有在注水
            if (_persistentValue != null && !_persistentValue.IsDiReplenOn)
            {
                //超过时间
                if (DateTime.Now.Subtract(_persistentValue.PeriodStartTime).TotalMinutes >= diValveMaxOnTimePeriod * 60)
                {
                    LOG.WriteLog(eEvent.INFO_RESERVOIR, _module, $"Time is over config DIValveMaxOnTimePeriod:{diValveMaxOnTimePeriod} hour. Restart timer");
                    timeOutAction(false);
                    _persistentValue.PeriodStartTime = DateTime.Now;
                    _persistentValue.TotalReplen = 0;
                    _persistentValue.LastTotalReplen = 0;
                    ReservoirsPersistentManager.Instance.UpdatePersistentValue(_module);
                }
            }
        }
        /// <summary>
        /// 监控手动注水
        /// </summary>
        public bool MonitorManualDiReplenComplete(int replenSecond, Func<string, object[], bool> direplenOffAction, Action<bool> timeOutAction)
        {
            lock (_locker)
            {
                _persistentValue.TotalReplen = _persistentValue.LastTotalReplen + (int)DateTime.Now.Subtract(_persistentValue.DiReplenTime).TotalSeconds;
            }
            //周期内累计补水超时
            double diValveMaxOnTime = SC.GetValue<double>($"Reservoir.{_module}.DIValveMaxOnTime");
            if (_persistentValue.TotalReplen >= diValveMaxOnTime * 60)
            {
                bool result = direplenOffAction("", null);
                if (result)
                {
                    timeOutAction(true);
                    LOG.WriteLog(eEvent.WARN_RESERVOIR, _module, $"Direplen time over config DIValveMaxOnTime:{diValveMaxOnTime} min");
                    _persistentValue.LastTotalReplen = _persistentValue.TotalReplen;
                    _persistentValue.IsDiReplenOn = false;
                    ReservoirsPersistentManager.Instance.UpdatePersistentValue(_module);
                }
                return result;
            }
            if (DateTime.Now.Subtract(_persistentValue.DiReplenTime).TotalSeconds >= replenSecond)
            {
                bool result = direplenOffAction("", null);
                if (result)
                {
                    timeOutAction(true);
                    _persistentValue.LastTotalReplen = _persistentValue.TotalReplen;
                    _persistentValue.IsDiReplenOn = false;
                    ReservoirsPersistentManager.Instance.UpdatePersistentValue(_module);
                    LOG.WriteLog(eEvent.INFO_RESERVOIR, _module, "Manual Direplen complete");
                }
                return result;
            }
            return false;
        }
        /// <summary>
        /// 自动注水超时
        /// </summary>
        /// <returns></returns>
        public (bool, DIReplenFaultType) AutoDiReplenMonitorTimeOut(Func<string, object[], bool> direplenOffAction, Action<bool> timeOutAction)
        {
            lock (_locker)
            {
                _persistentValue.TotalReplen = _persistentValue.LastTotalReplen + (int)DateTime.Now.Subtract(_persistentValue.DiReplenTime).TotalSeconds;
            }
            //单次自动补水超时
            double diValveMaxOnTimePerFill = SC.GetValue<double>($"Reservoir.{_module}.DIValveMaxOnTimePerFill");
            if (DateTime.Now.Subtract(_persistentValue.DiReplenTime).TotalSeconds >= diValveMaxOnTimePerFill * 60)
            {
                bool result = direplenOffAction("", null);
                if (result)
                {
                    AlarmListManager.Instance.AddWarn(_module, $"", $"{_module} Direplen time over config DIValveMaxOnTimePerFill:{diValveMaxOnTimePerFill} min");
                    LOG.WriteLog(eEvent.WARN_RESERVOIR, _module, $"Direplen time over conifg DIValveMaxOnTimePerFill:{diValveMaxOnTimePerFill} min");
                    //补水超时关闭总的补水阀
                    SystemFacilities systemFacilities = DEVICE.GetDevice<SystemFacilities>("System.Facilities");
                    if (systemFacilities != null)
                    {
                        if (systemFacilities.DIReplenEnable) systemFacilities.DiReplenDisableOperation("DiReplenDisableOperation", null);
                    }
                    _persistentValue.LastTotalReplen = _persistentValue.TotalReplen;
                    _persistentValue.IsDiReplenOn = false;
                    ReservoirsPersistentManager.Instance.UpdatePersistentValue(_module);
                }
                return (result, DIReplenFaultType.PerFillTimeOut);
            }
            //累计补水超时
            double diValveMaxOnTime = SC.GetValue<double>($"Reservoir.{_module}.DIValveMaxOnTime");
            if (_persistentValue.TotalReplen >= diValveMaxOnTime * 60)
            {
                bool result = direplenOffAction("", null);
                if (result)
                {
                    timeOutAction(true);
                    AlarmListManager.Instance.AddWarn(_module, $"", $"{_module} Direplen time over config DIValveMaxOnTime:{diValveMaxOnTime} min");
                    LOG.WriteLog(eEvent.WARN_RESERVOIR, _module, $"Direplen time over conifg DIValveMaxOnTime:{diValveMaxOnTime} min");
                    _persistentValue.LastTotalReplen = _persistentValue.TotalReplen;
                    _persistentValue.IsDiReplenOn = false;
                    ReservoirsPersistentManager.Instance.UpdatePersistentValue(_module);
                }
                return (result, DIReplenFaultType.MaxTimeOut);
            }
            return (false, DIReplenFaultType.None);
        }
        /// <summary>
        /// 自动注水是否结束
        /// </summary>
        /// <param name="level"></param>
        /// <param name="recipeLevel"></param>
        /// <param name="direplenOffAction"></param>
        /// <returns></returns>
        public bool AutoDiReplenMonitorComplete(double level, double recipeLevel, bool replenEnable,
            int direplenTimeRate, int direplenCurrentRate, Func<string, object[], bool> direplenOffAction)
        {
            double levelHysteresis = SC.GetValue<double>("Reservoir.LevelHysteresis");
            //按液位补水
            if (replenEnable && direplenTimeRate == 0 && direplenCurrentRate == 0 &&
                level >= recipeLevel)
            {
                LOG.WriteLog(eEvent.INFO_RESERVOIR, _module, "Auto replen complete");
                bool result = direplenOffAction("", null);
                if (result)
                {
                    _persistentValue.LastTotalReplen = _persistentValue.TotalReplen;
                    _persistentValue.IsDiReplenOn = false;
                    ReservoirsPersistentManager.Instance.UpdatePersistentValue(_module);
                    return result;
                }
            }
            return false;
        }
        public enum DIReplenFaultType
        {
            None,
            MaxTimeOut,
            PerFillTimeOut
        }
    }
}