From 8a0da27a077c58c00089f7bdd3dafa7d6594625b Mon Sep 17 00:00:00 2001 From: Marek Frniak Date: Mon, 20 Apr 2026 12:39:51 +0200 Subject: [PATCH] Fixed RegValve + FlowMetersInParallel - incorrect NominalFreq sum --- TBF/Rig/Uni/FlowMetersInParallel/FlowMeter.cs | 165 ++++-------------- .../Uni/FlowMetersInParallel/FlowMeterCfg.cs | 5 +- TBF/Rig/Uni/RegValve/SetRegValvePositionOp.cs | 15 +- 3 files changed, 39 insertions(+), 146 deletions(-) diff --git a/TBF/Rig/Uni/FlowMetersInParallel/FlowMeter.cs b/TBF/Rig/Uni/FlowMetersInParallel/FlowMeter.cs index d95adec57..b0afb1924 100644 --- a/TBF/Rig/Uni/FlowMetersInParallel/FlowMeter.cs +++ b/TBF/Rig/Uni/FlowMetersInParallel/FlowMeter.cs @@ -1,12 +1,11 @@ -using log4net; -using SchematicDrawing; -using SharedComponents; -/// +/// /// Copyright (c) 2021-2022 Sensus Slovensko a.s. /// using System; using System.Collections.Generic; -using System.Diagnostics; +using log4net; +using SchematicDrawing; +using SharedComponents; using TBF.Boxes; using TBF.Rig.ControlBoard.Uni; using TBF.Rig.GenericDevices; @@ -77,10 +76,7 @@ namespace TBF.Rig.Uni.FlowMetersInParallel if (!string.IsNullOrEmpty(flowMeterCfg.Flowmeter2)) flowMtr2 = TbfComponents.FindComponent(flowMeterCfg.Flowmeter2) as IFlowMeterSingle; if (!string.IsNullOrEmpty(flowMeterCfg.Flowmeter3)) flowMtr3 = TbfComponents.FindComponent(flowMeterCfg.Flowmeter3) as IFlowMeterSingle; - LiveLogDiag.Log1("{0} >> Initialize() >> ----------------------initialising------------------------", Name); - nominalFlow = 0; - nominalFreq = 0; flowMetersCount = 0; flowMetersBitfield = 0; @@ -90,49 +86,31 @@ namespace TBF.Rig.Uni.FlowMetersInParallel nominalFreq += flowMtr1.NominalFreq; flowMetersBitfield |= (4 << flowMtr1.Idx1); flowMetersCount++; - - LiveLogDiag.Log1( - "{0} >> Initialize() >> flowMtr1.NominalFlow = {1} m3/h flowMtr1.NominalFreq = {2} Hz", - Name, flowMtr1.NominalFlow, flowMtr1.NominalFreq); } - if (flowMtr2 != null) { nominalFlow += flowMtr2.NominalFlow; nominalFreq += flowMtr2.NominalFreq; flowMetersBitfield |= (4 << flowMtr2.Idx1); flowMetersCount++; - - LiveLogDiag.Log1( - "{0} >> Initialize() >> flowMtr2.NominalFlow = {1} m3/h flowMtr2.NominalFreq = {2} Hz", - Name, flowMtr2.NominalFlow, flowMtr2.NominalFreq); } - if (flowMtr3 != null) { nominalFlow += flowMtr3.NominalFlow; nominalFreq += flowMtr3.NominalFreq; flowMetersBitfield |= (4 << flowMtr3.Idx1); flowMetersCount++; - - LiveLogDiag.Log1( - "{0} >> Initialize() >> flowMtr3.NominalFlow = {1} m3/h flowMtr3.NominalFreq = {2} Hz", - Name, flowMtr3.NominalFlow, flowMtr3.NominalFreq); } - if (flowMetersCount == 0) throw new Exception("Missing flowmeters"); MsrdValLimHi = nominalFlow; - ltrPerPulse = nominalFlow / (3.6 * nominalFreq); + nominalFreq = nominalFreq / flowMetersCount; - LiveLogDiag.Log1( - "{0} >> Initialize() >> nominalFlow = {1} m3/h nominalFreq = {2} Hz bitfield = 0x{3:X2} ltrPerPulse = {4}", - Name, nominalFlow, nominalFreq, flowMetersBitfield, ltrPerPulse); + ltrPerPulse = nominalFlow / (3.6 * nominalFreq); /// Nominal freq. is sum of particular nominal frquencies - log.FatalFormat( - "{0} initialized: nom.flow={1} m3/h nom.freq={2} Hz bitfield=0x{3:X2}", - Name, nominalFlow, nominalFreq, flowMetersBitfield); + log.FatalFormat("{0} initialized: {1} nom.flow={2} m3/h nom.freq={3} Hz bitfield=0x{4:X2}", + Name, nominalFlow, nominalFreq, flowMetersBitfield); } public double ReadFlow() @@ -141,69 +119,42 @@ namespace TBF.Rig.Uni.FlowMetersInParallel if (flowMtr1 != null) { - double contrib1 = flowMtr1.NominalFlow * uniCB.Data.ReferenceFreq[flowMtr1.Idx1] / flowMtr1.NominalFreq; - flowByNewFormulaSum += contrib1; - - LiveLogDiag.Log1( - "{0} >> ReadFlow() >> FM1: NominalFlow={1} m3/h RefFreq[1]={2} Hz NominalFreq={3} Hz Contribution={4} m3/h", - Name, flowMtr1.NominalFlow, uniCB.Data.ReferenceFreq[1], flowMtr1.NominalFreq, contrib1); + flowByNewFormulaSum += flowMtr1.NominalFlow * uniCB.Data.ReferenceFreq[1] / flowMtr1.NominalFreq; } - if (flowMtr2 != null) { - double contrib2 = flowMtr2.NominalFlow * uniCB.Data.ReferenceFreq[flowMtr2.Idx1] / flowMtr2.NominalFreq; - flowByNewFormulaSum += contrib2; - - LiveLogDiag.Log1( - "{0} >> ReadFlow() >> FM2: NominalFlow={1} m3/h RefFreq[2]={2} Hz NominalFreq={3} Hz Contribution={4} m3/h", - Name, flowMtr2.NominalFlow, uniCB.Data.ReferenceFreq[2], flowMtr2.NominalFreq, contrib2); + flowByNewFormulaSum += flowMtr2.NominalFlow * uniCB.Data.ReferenceFreq[2] / flowMtr2.NominalFreq; } - if (flowMtr3 != null) { - double contrib3 = flowMtr3.NominalFlow * uniCB.Data.ReferenceFreq[flowMtr3.Idx1] / flowMtr3.NominalFreq; - flowByNewFormulaSum += contrib3; - - LiveLogDiag.Log1( - "{0} >> ReadFlow() >> FM3: NominalFlow={1} m3/h RefFreq[3]={2} Hz NominalFreq={3} Hz Contribution={4} m3/h", - Name, flowMtr3.NominalFlow, uniCB.Data.ReferenceFreq[3], flowMtr3.NominalFreq, contrib3); + flowByNewFormulaSum += flowMtr3.NominalFlow * uniCB.Data.ReferenceFreq[3] / flowMtr3.NominalFreq; } - - LiveLogDiag.Log1( - "{0} >> ReadFlow() >> return = flowByNewFormulaSum = {1} m3/h", - Name, flowByNewFormulaSum); - LiveLogDiag.Log1( - "{0} >> FM1: Idx1={1}, RefFreq[1]={2}, RefFreq[Idx1]={3}", - Name, - flowMtr1.Idx1, - uniCB.Data.ReferenceFreq[1], - uniCB.Data.ReferenceFreq[flowMtr1.Idx1]); - - return flowByNewFormulaSum; + return flowByNewFormulaSum/*ReadFrequency() * nominalFlow / nominalFreq*/; } public double ReadFrequency() { - double freq = uniCB.RefFrequency; - LiveLogDiag.Log1("{0} >> ReadFrequency() >> return = {1} Hz", Name, freq); - return freq; + return uniCB.RefFrequency; } /// - /// Events: FlowDone, Error + /// Events: FlowDone, Error /// + /// Reference to a variable for the flow in Bar + /// ReadFlowOp instance reference casted to IOperaton public IOperation ReadFlowOp(ref DoubleBox flow) { - LiveLogDiag.Log1("{0} >> ReadFlowOp(ref DoubleBox) >> operation created", Name); return new ReadFlowOp(this, ref flow); } /// - /// Events: flowDone, Error + /// Events: flowDone, Error /// + /// Reference to a variable for the flow in Bar + /// Event returned when measurement done + /// ReadFlowOp instance reference casted to IOperaton public IOperation ReadFlowOp(ref DoubleBox flow, Event flowDone) { - LiveLogDiag.Log1("{0} >> ReadFlowOp(ref DoubleBox, Event) >> operation created", Name); return new ReadFlowOp(this, ref flow, flowDone); } @@ -223,98 +174,42 @@ namespace TBF.Rig.Uni.FlowMetersInParallel if (flowMtr1 != null) rng1 = Math.Max(0, flowMtr1.GetRange(test.TempLimLo, test.TempLimHi)); if (flowMtr2 != null) rng2 = Math.Max(0, flowMtr2.GetRange(test.TempLimLo, test.TempLimHi)); if (flowMtr3 != null) rng3 = Math.Max(0, flowMtr3.GetRange(test.TempLimLo, test.TempLimHi)); - - LiveLogDiag.Log1( - "{0} >> StartStatistics() >> flowRawSum={1} flowSum={2} timeSum={3} rng1={4} rng2={5} rng3={6}", - Name, flowRawSum, flowSum, timeSum, rng1, rng2, rng3); } public void UpdateStatistics(int timeDelta) { double tempFlow; - if (flowMtr1 != null) { - tempFlow = flowMtr1.ReadFlow(); - flowRawSum += timeDelta * tempFlow; - flowSum += timeDelta * flowMtr1.CorrectedFlow(tempFlow, rng1); - - LiveLogDiag.Log1( - "{0} >> UpdateStatistics() >> FM1: timeDelta={1} tempFlow={2} corrected={3}", - Name, timeDelta, tempFlow, flowMtr1.CorrectedFlow(tempFlow, rng1)); + flowRawSum += timeDelta * (tempFlow = flowMtr1.ReadFlow()); + flowSum += timeDelta * flowMtr1.CorrectedFlow(tempFlow, rng1); ; } - if (flowMtr2 != null) { - tempFlow = flowMtr2.ReadFlow(); - flowRawSum += timeDelta * tempFlow; - flowSum += timeDelta * flowMtr2.CorrectedFlow(tempFlow, rng2); - - LiveLogDiag.Log1( - "{0} >> UpdateStatistics() >> FM2: timeDelta={1} tempFlow={2} corrected={3}", - Name, timeDelta, tempFlow, flowMtr2.CorrectedFlow(tempFlow, rng2)); + flowRawSum += timeDelta * (tempFlow = flowMtr2.ReadFlow()); + flowSum += timeDelta * flowMtr2.CorrectedFlow(tempFlow, rng2); ; } - if (flowMtr3 != null) { - tempFlow = flowMtr3.ReadFlow(); - flowRawSum += timeDelta * tempFlow; - flowSum += timeDelta * flowMtr3.CorrectedFlow(tempFlow, rng3); - - LiveLogDiag.Log1( - "{0} >> UpdateStatistics() >> FM3: timeDelta={1} tempFlow={2} corrected={3}", - Name, timeDelta, tempFlow, flowMtr3.CorrectedFlow(tempFlow, rng3)); + flowRawSum += timeDelta * (tempFlow = flowMtr3.ReadFlow()); + flowSum += timeDelta * flowMtr3.CorrectedFlow(tempFlow, rng3); ; } timeSum += timeDelta; - - LiveLogDiag.Log1( - "{0} >> UpdateStatistics() >> flowRawSum={1} flowSum={2} timeSum={3}", - Name, flowRawSum, flowSum, timeSum); } public void StopStatistics() { flowRawSum /= Convert.ToDouble(timeSum); flowSum /= Convert.ToDouble(timeSum); - - LiveLogDiag.Log1( - "{0} >> StopStatistics() >> flowRawSum={1:F3} m3/h flowSum={2:F3} m3/h", - Name, flowRawSum, flowSum); - - log.WarnFormat( - "StopStatistics() flowRawSum = {0:F3} m3/h flowSum = {1:F3} m3/h", - flowRawSum, flowSum); + log.WarnFormat("StopStatistics() flowRawSum = {0:F3} m3/h flowSum = {1:F3} m3/h", flowRawSum, flowSum); } public double LtrPerPulseCorrected(double flow, float temperature) { - double ltrPerPulseCorrected = (flowRawSum == 0) - ? LtrPerPulse - : LtrPerPulse * flowSum / flowRawSum; - - LiveLogDiag.Log1( - "{0} >> LtrPerPulseCorrected() >> flow={1} m3/h flowRawSum={2} flowSum={3} temperature={4} C ltrPerPulseCorrected={5}", - Name, flow, flowRawSum, flowSum, temperature, ltrPerPulseCorrected); - - log.WarnFormat( - "LtrPerPulseCorrected() flow = {0} m3/h flowRawSum = {1} m3/h flowSum = {2} m3/h temperature = {3} C ltrPerPulseCorrected = {4}", - flow, flowRawSum, flowSum, temperature, ltrPerPulseCorrected); - + double ltrPerPulseCorrected = (flowRawSum == 0) ? LtrPerPulse : LtrPerPulse * flowSum / flowRawSum; + log.WarnFormat("LtrPerPulseCorrected() flow = {0} m3/h flowRawSum = {1} m3/h flowSum = {2} m3/h temperature = {3} C ltrPerPulseCorrected = {4}", flow, flowRawSum, flowSum, temperature, ltrPerPulseCorrected); return ltrPerPulseCorrected; } - - /// - /// Logging - /// For activation use compilation condition: LIVELOGDIAG_FlowMeter_cs - /// - static class LiveLogDiag - { - [Conditional("LIVELOGDIAG_FlowMeter_cs")] - public static void Log1(string format, params object[] args) - { - LiveLogCache.Instance.AddLog("FlowMeter.cs LOG>> " + string.Format(format, args)); - } - } } -} \ No newline at end of file +} diff --git a/TBF/Rig/Uni/FlowMetersInParallel/FlowMeterCfg.cs b/TBF/Rig/Uni/FlowMetersInParallel/FlowMeterCfg.cs index 77c6da489..4326218c6 100644 --- a/TBF/Rig/Uni/FlowMetersInParallel/FlowMeterCfg.cs +++ b/TBF/Rig/Uni/FlowMetersInParallel/FlowMeterCfg.cs @@ -54,9 +54,6 @@ namespace TBF.Rig.Uni.FlowMetersInParallel [XmlIgnore] public double MsrdValLimHi { get; set; } - [XmlIgnore] - public bool IsOffline { get; set; } - private IEnumerable flowMeters; @@ -81,6 +78,8 @@ namespace TBF.Rig.Uni.FlowMetersInParallel public string ComponentName { get { return Name; } } + public bool IsOffline { get => throw new NotImplementedException(); set => throw new NotImplementedException(); } + public void InitializeAll() { Flowmeter1 = "I11"; diff --git a/TBF/Rig/Uni/RegValve/SetRegValvePositionOp.cs b/TBF/Rig/Uni/RegValve/SetRegValvePositionOp.cs index fbc94082e..c81e97844 100644 --- a/TBF/Rig/Uni/RegValve/SetRegValvePositionOp.cs +++ b/TBF/Rig/Uni/RegValve/SetRegValvePositionOp.cs @@ -30,7 +30,7 @@ namespace TBF.Rig.Uni.RegValve OpState opState; /// Set by the constructor - readonly UniCB cBoard; + readonly UniCB uniCB; readonly RegValve regV; readonly int regValveNr; readonly double posLoPct; @@ -45,24 +45,23 @@ namespace TBF.Rig.Uni.RegValve /// Set required water flow. /// Events: FlowSet, FlowTimeOut /// - /// Control board device + /// Control board device /// Regulation valve component /// Lower limit of the position to be achieved /// Upper limit of the position to be achieved /// Timeout in sec. for setting the flow /// Only Elde.Valve flow are used, other flow on the lists are ignored - public SetRegValvePositionOp(UniCB cBoard, RegValve regValve, double posLoPct, double posHiPct, int timeout) + public SetRegValvePositionOp(UniCB uniCB, RegValve regV, double posLoPct, double posHiPct, int timeout) { - this.cBoard = cBoard; - if (this.cBoard == null) throw new ArgumentNullException("ctrlBoard"); + this.uniCB = uniCB; + if (this.uniCB == null) throw new ArgumentNullException("ctrlBoard"); - this.regV = regValve as RegValve; - if (this.regV == null) throw new ArgumentNullException("regValve is null or not Elde"); + this.regV = regV as RegValve; + if (this.regV == null) throw new ArgumentNullException("regValve is null or not Uni"); this.regValveNr = this.regV.Idx1; this.posLoPct = posLoPct; this.posHiPct = posHiPct; - this.timeout = timeout; log.Debug(this.ToString());