/// /// Copyright (c) 2013-2016 Sensus Metering Systems /// using System; using System.Collections.Generic; using log4net; using TBF.Boxes; namespace TBF.BenchControl.Elde.FixedStartRegisterReader { public class RegisterReader : ComponentBase, GenericDevices.IRegisterReader, IOperation { private static readonly ILog log = LogManager.GetLogger(typeof(RegisterReader)); public override string ToString() { return string.Format("FixedStartRegisterReader({0})", Cfg.ToString(1)); } readonly RegisterReaderCfg registerReaderCfg; readonly ControlBoardDev controlBoard; public double PulsesPerLtr { get { return (double)registerReaderCfg.ProcParams.PulsesPerLtr; } } public double LtrsPerPulse { get { return (PulsesPerLtr <= float.Epsilon) ? 1.0 : (1 / PulsesPerLtr); } } double beginWMState; public double BeginWMState { get { return beginWMState; } set { beginWMState = value; } } double endWMState; public double EndWMState { get { return endWMState; } set { endWMState = value; } } public double WMVolume { get { return endWMState - beginWMState; } } public int WMPulses { get { return (int)(WMVolume / LtrsPerPulse); } } int wmRefPulses; public int WMRefPulses { get { return wmRefPulses; } } public RegisterReader() { } public RegisterReader(Generic.IComponentCfg cfg, IList components) : base(cfg) { registerReaderCfg = cfg as RegisterReaderCfg; /// Control board is used to read reference flowmeter pulses controlBoard = (ControlBoardDev)TbfComponents.FindComponent(cfg.ParentName, components); if (controlBoard == null) throw new Exception("Cannot find " + Name + " parent"); Clear(); log.Debug(this.ToString()); } public void Clear() { log.DebugFormat("{0}:Clear()", Name); beginWMState = 0; endWMState = 0; wmRefPulses = 0; } public void TestCompleted() { log.DebugFormat("{0}:TestCompleted()", Name); ReadPulses(); } /// /// Events: Event.ReadRegisterDone /// /// ReadWaterMeter instance reference casted to IOperaton public IOperation ReadRegisterOp() { return this; } private void ReadPulses() { wmRefPulses = (int)controlBoard.EtPulses(0); } /// Start this operation public void Start() { ReadPulses(); } /// Run this operation /// eventDone public Event Run() { ReadPulses(); return Event.ReadRegisterDone; } /// Stop this operation public void Stop() { } } }