CyberX8/CyberX8_RT/Devices/Reservoir/ReservoirDiReplenHelper.cs

using Aitex.Core.RT.Log;
using Aitex.Core.RT.SCCore;
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()
        {
            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)
                {
                    _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)
        {
            lock (_locker)
            {
                _persistentValue.TotalReplen = _persistentValue.LastTotalReplen + (int)DateTime.Now.Subtract(_persistentValue.DiReplenTime).TotalSeconds;
            }
            if (DateTime.Now.Subtract(_persistentValue.DiReplenTime).TotalSeconds >= replenSecond)
            {
                bool result = direplenOffAction("", null);
                if (result)
                {
                    _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 AutoDiReplenMonitorTimeOut(Func<string, object[], bool> direplenOffAction)
        {
            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)
                {
                    LOG.WriteLog(eEvent.WARN_RESERVOIR, _module, $"Direplen time over {diValveMaxOnTimePerFill} min");
                    _persistentValue.LastTotalReplen = _persistentValue.TotalReplen;
                    _persistentValue.IsDiReplenOn = false;
                    ReservoirsPersistentManager.Instance.UpdatePersistentValue(_module);
                }
                return result;
            }
            return false;
        }
        /// <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 false;
        }
    }
}