Write ThermalHouse results when em controlled

CHANGELOG.md

@@ -79,6 +79,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Simulation stopping at unhandled messages in `DBFSAlgorithm` [#821](https://github.com/ie3-institute/simona/issues/821)
 - Not stopping correctly on failed power flow if configured  to stop [#800](https://github.com/ie3-institute/simona/issues/800)
 - Finally fixing `RuntimeEventListenerSpec` [#849](https://github.com/ie3-institute/simona/issues/849)
+- Fixed result output for thermal houses and cylindrical storages [#844](https://github.com/ie3-institute/simona/issues/844)
 
 ## [3.0.0] - 2023-08-07
 

src/main/scala/edu/ie3/simona/agent/participant/ParticipantAgent.scala

@@ -37,6 +37,7 @@ import edu.ie3.simona.agent.{SimonaAgent, ValueStore}
 import edu.ie3.simona.config.SimonaConfig
 import edu.ie3.simona.event.notifier.NotifierConfig
 import edu.ie3.simona.exceptions.agent.InconsistentStateException
+import edu.ie3.simona.io.result.AccompaniedSimulationResult
 import edu.ie3.simona.model.participant.ModelState.ConstantState
 import edu.ie3.simona.model.participant.{
   CalcRelevantData,
@@ -799,7 +800,7 @@ abstract class ParticipantAgent[
       data: CD,
       lastState: MS,
       setPower: squants.Power,
-  ): (MS, PD, FlexChangeIndicator)
+  ): (MS, AccompaniedSimulationResult[PD], FlexChangeIndicator)
 
   /** Determining the reply to an [[RequestAssetPowerMessage]], send this answer
     * and stay in the current state. If no reply can be determined (because an

src/main/scala/edu/ie3/simona/agent/participant/ParticipantAgentFundamentals.scala

@@ -832,7 +832,7 @@ protected trait ParticipantAgentFundamentals[
 
     flexStateData.emAgent ! FlexCtrlCompletion(
       baseStateData.modelUuid,
-      result.toApparentPower,
+      result.primaryData.toApparentPower,
       flexChangeIndicator.changesAtNextActivation,
       nextActivation,
     )
@@ -854,22 +854,22 @@ protected trait ParticipantAgentFundamentals[
     */
   protected def handleCalculatedResult(
       baseStateData: ParticipantModelBaseStateData[PD, CD, MS, M],
-      result: PD,
+      result: AccompaniedSimulationResult[PD],
       currentTick: Long,
   ): ParticipantModelBaseStateData[PD, CD, MS, M] = {
 
     // announce last result to listeners
     announceSimulationResult(
       baseStateData,
       currentTick,
-      AccompaniedSimulationResult(result),
+      result,
     )(baseStateData.outputConfig)
 
     baseStateData.copy(
       resultValueStore = ValueStore.updateValueStore(
         baseStateData.resultValueStore,
         currentTick,
-        result,
+        result.primaryData,
       )
     )
   }

src/main/scala/edu/ie3/simona/agent/participant/evcs/EvcsAgentFundamentals.scala

@@ -7,6 +7,7 @@
 package edu.ie3.simona.agent.participant.evcs
 
 import edu.ie3.datamodel.models.input.system.EvcsInput
+import edu.ie3.datamodel.models.result.ResultEntity
 import edu.ie3.datamodel.models.result.system.{
   EvcsResult,
   SystemParticipantResult,
@@ -39,6 +40,7 @@ import edu.ie3.simona.exceptions.agent.{
   InconsistentStateException,
   InvalidRequestException,
 }
+import edu.ie3.simona.io.result.AccompaniedSimulationResult
 import edu.ie3.simona.model.participant.FlexChangeIndicator
 import edu.ie3.simona.model.participant.evcs.EvcsModel
 import edu.ie3.simona.model.participant.evcs.EvcsModel.{
@@ -59,7 +61,7 @@ import org.apache.pekko.actor.typed.scaladsl.adapter.ClassicActorRefOps
 import org.apache.pekko.actor.typed.{ActorRef => TypedActorRef}
 import org.apache.pekko.actor.{ActorRef, FSM}
 import squants.energy.Megawatts
-import squants.{Dimensionless, Each}
+import squants.{Dimensionless, Each, Power}
 
 import java.time.ZonedDateTime
 import java.util.UUID
@@ -243,16 +245,23 @@ protected trait EvcsAgentFundamentals
       ],
       data: EvcsRelevantData,
       lastState: EvcsState,
-      setPower: squants.Power,
-  ): (EvcsState, ApparentPower, FlexChangeIndicator) = {
+      setPower: Power,
+  ): (
+      EvcsState,
+      AccompaniedSimulationResult[ApparentPower],
+      FlexChangeIndicator,
+  ) = {
     /* Calculate the power */
     val voltage = getAndCheckNodalVoltage(baseStateData, tick)
 
     val reactivePower = baseStateData.model.calculateReactivePower(
       setPower,
       voltage,
     )
-    val result = ApparentPower(setPower, reactivePower)
+    val result = AccompaniedSimulationResult(
+      ApparentPower(setPower, reactivePower),
+      Seq.empty[ResultEntity],
+    )
 
     /* Handle the request within the model */
     val (updatedState, flexChangeIndicator) =
@@ -674,7 +683,7 @@ protected trait EvcsAgentFundamentals
         EvcsState,
         EvcsModel,
       ],
-      result: ApparentPower,
+      result: AccompaniedSimulationResult[ApparentPower],
       currentTick: Long,
   ): ParticipantModelBaseStateData[
     ApparentPower,

src/main/scala/edu/ie3/simona/agent/participant/fixedfeedin/FixedFeedInAgentFundamentals.scala

@@ -7,6 +7,7 @@
 package edu.ie3.simona.agent.participant.fixedfeedin
 
 import edu.ie3.datamodel.models.input.system.FixedFeedInInput
+import edu.ie3.datamodel.models.result.ResultEntity
 import edu.ie3.datamodel.models.result.system.{
   FixedFeedInResult,
   SystemParticipantResult,
@@ -34,6 +35,7 @@ import edu.ie3.simona.exceptions.agent.{
   InconsistentStateException,
   InvalidRequestException,
 }
+import edu.ie3.simona.io.result.AccompaniedSimulationResult
 import edu.ie3.simona.model.participant.CalcRelevantData.FixedRelevantData
 import edu.ie3.simona.model.participant.ModelState.ConstantState
 import edu.ie3.simona.model.participant.{
@@ -231,15 +233,22 @@ protected trait FixedFeedInAgentFundamentals
       data: FixedRelevantData.type,
       lastState: ConstantState.type,
       setPower: squants.Power,
-  ): (ConstantState.type, ApparentPower, FlexChangeIndicator) = {
+  ): (
+      ConstantState.type,
+      AccompaniedSimulationResult[ApparentPower],
+      FlexChangeIndicator,
+  ) = {
     /* Calculate result */
     val voltage = getAndCheckNodalVoltage(baseStateData, tick)
 
     val reactivePower = baseStateData.model.calculateReactivePower(
       setPower,
       voltage,
     )
-    val result = ApparentPower(setPower, reactivePower)
+    val result = AccompaniedSimulationResult(
+      ApparentPower(setPower, reactivePower),
+      Seq.empty[ResultEntity],
+    )
 
     /* Handle the request within the model */
     val (updatedState, flexChangeIndicator) =

src/main/scala/edu/ie3/simona/agent/participant/hp/HpAgentFundamentals.scala

@@ -51,7 +51,7 @@ import edu.ie3.simona.ontology.messages.services.WeatherMessage.WeatherData
 import edu.ie3.util.quantities.PowerSystemUnits.PU
 import edu.ie3.util.quantities.QuantityUtils.RichQuantityDouble
 import edu.ie3.util.scala.quantities.DefaultQuantities._
-import edu.ie3.util.scala.quantities.{Megavars, ReactivePower}
+import edu.ie3.util.scala.quantities.ReactivePower
 import org.apache.pekko.actor.typed.scaladsl.adapter.ClassicActorRefOps
 import org.apache.pekko.actor.typed.{ActorRef => TypedActorRef}
 import org.apache.pekko.actor.{ActorRef, FSM}
@@ -147,7 +147,11 @@ trait HpAgentFundamentals
       data: HpRelevantData,
       lastState: HpState,
       setPower: squants.Power,
-  ): (HpState, ApparentPowerAndHeat, FlexChangeIndicator) = {
+  ): (
+      HpState,
+      AccompaniedSimulationResult[ApparentPowerAndHeat],
+      FlexChangeIndicator,
+  ) = {
     /* Determine needed information */
     val voltage =
       getAndCheckNodalVoltage(baseStateData, tick)
@@ -176,13 +180,18 @@ trait HpAgentFundamentals
       .handleControlledPowerChange(relevantData, modelState, setPower)
 
     /* Calculate power results */
-    val result = baseStateData.model.calculatePower(
+    val power = baseStateData.model.calculatePower(
       tick,
       voltage,
       updatedState,
       relevantData,
     )
 
+    val accompanyingResults = baseStateData.model.thermalGrid.results(
+      updatedState.thermalGridState
+    )(baseStateData.startDate)
+    val result = AccompaniedSimulationResult(power, accompanyingResults)
+
     (updatedState, result, flexChangeIndicator)
   }
 

src/main/scala/edu/ie3/simona/agent/participant/load/LoadAgentFundamentals.scala

@@ -7,6 +7,7 @@
 package edu.ie3.simona.agent.participant.load
 
 import edu.ie3.datamodel.models.input.system.LoadInput
+import edu.ie3.datamodel.models.result.ResultEntity
 import edu.ie3.datamodel.models.result.system.{
   LoadResult,
   SystemParticipantResult,
@@ -31,6 +32,7 @@ import edu.ie3.simona.agent.state.AgentState.Idle
 import edu.ie3.simona.config.SimonaConfig.LoadRuntimeConfig
 import edu.ie3.simona.event.notifier.NotifierConfig
 import edu.ie3.simona.exceptions.agent.InconsistentStateException
+import edu.ie3.simona.io.result.AccompaniedSimulationResult
 import edu.ie3.simona.model.SystemComponent
 import edu.ie3.simona.model.participant.CalcRelevantData.LoadRelevantData
 import edu.ie3.simona.model.participant.ModelState.ConstantState
@@ -261,15 +263,22 @@ protected trait LoadAgentFundamentals[LD <: LoadRelevantData, LM <: LoadModel[
       data: LD,
       lastState: ConstantState.type,
       setPower: squants.Power,
-  ): (ConstantState.type, ApparentPower, FlexChangeIndicator) = {
+  ): (
+      ConstantState.type,
+      AccompaniedSimulationResult[ApparentPower],
+      FlexChangeIndicator,
+  ) = {
     /* Calculate result */
     val voltage = getAndCheckNodalVoltage(baseStateData, tick)
 
     val reactivePower = baseStateData.model.calculateReactivePower(
       setPower,
       voltage,
     )
-    val result = ApparentPower(setPower, reactivePower)
+    val result = AccompaniedSimulationResult(
+      ApparentPower(setPower, reactivePower),
+      Seq.empty[ResultEntity],
+    )
 
     /* Handle the request within the model */
     val (updatedState, flexChangeIndicator) =

src/main/scala/edu/ie3/simona/agent/participant/pv/PvAgentFundamentals.scala

@@ -7,6 +7,7 @@
 package edu.ie3.simona.agent.participant.pv
 
 import edu.ie3.datamodel.models.input.system.PvInput
+import edu.ie3.datamodel.models.result.ResultEntity
 import edu.ie3.datamodel.models.result.system.{
   PvResult,
   SystemParticipantResult,
@@ -270,15 +271,22 @@ protected trait PvAgentFundamentals
       data: PvRelevantData,
       lastState: ConstantState.type,
       setPower: squants.Power,
-  ): (ConstantState.type, ApparentPower, FlexChangeIndicator) = {
+  ): (
+      ConstantState.type,
+      AccompaniedSimulationResult[ApparentPower],
+      FlexChangeIndicator,
+  ) = {
     /* Calculate result */
     val voltage = getAndCheckNodalVoltage(baseStateData, tick)
 
     val reactivePower = baseStateData.model.calculateReactivePower(
       setPower,
       voltage,
     )
-    val result = ApparentPower(setPower, reactivePower)
+    val result = AccompaniedSimulationResult(
+      ApparentPower(setPower, reactivePower),
+      Seq.empty[ResultEntity],
+    )
 
     /* Handle the request within the model */
     val (updatedState, flexChangeIndicator) =

src/main/scala/edu/ie3/simona/agent/participant/storage/StorageAgentFundamentals.scala

@@ -7,6 +7,7 @@
 package edu.ie3.simona.agent.participant.storage
 
 import edu.ie3.datamodel.models.input.system.StorageInput
+import edu.ie3.datamodel.models.result.ResultEntity
 import edu.ie3.datamodel.models.result.system.{
   StorageResult,
   SystemParticipantResult,
@@ -36,6 +37,7 @@ import edu.ie3.simona.exceptions.agent.{
   AgentInitializationException,
   InvalidRequestException,
 }
+import edu.ie3.simona.io.result.AccompaniedSimulationResult
 import edu.ie3.simona.model.participant.StorageModel.{
   StorageRelevantData,
   StorageState,
@@ -259,15 +261,14 @@ trait StorageAgentFundamentals
         StorageState,
         StorageModel,
       ],
-      result: ApparentPower,
+      result: AccompaniedSimulationResult[ApparentPower],
       currentTick: Long,
   ): ParticipantModelBaseStateData[
     ApparentPower,
     StorageRelevantData,
     StorageState,
     StorageModel,
   ] = {
-
     // announce last result to listeners
     if (baseStateData.outputConfig.simulationResultInfo) {
       val uuid = baseStateData.modelUuid
@@ -289,8 +290,8 @@ trait StorageAgentFundamentals
       val storageResult = new StorageResult(
         dateTime,
         uuid,
-        result.p.toMegawatts.asMegaWatt,
-        result.q.toMegavars.asMegaVar,
+        result.primaryData.p.toMegawatts.asMegaWatt,
+        result.primaryData.q.toMegavars.asMegaVar,
         soc,
       )
 
@@ -301,7 +302,7 @@ trait StorageAgentFundamentals
       resultValueStore = ValueStore.updateValueStore(
         baseStateData.resultValueStore,
         currentTick,
-        result,
+        result.primaryData,
       )
     )
   }
@@ -332,7 +333,11 @@ trait StorageAgentFundamentals
       data: StorageRelevantData,
       lastState: StorageState,
       setPower: Power,
-  ): (StorageState, ApparentPower, FlexChangeIndicator) = {
+  ): (
+      StorageState,
+      AccompaniedSimulationResult[ApparentPower],
+      FlexChangeIndicator,
+  ) = {
     val (updatedState, flexChangeIndicator) =
       baseStateData.model.handleControlledPowerChange(data, lastState, setPower)
     // In edge cases, the model does not accept the given set power
@@ -345,11 +350,13 @@ trait StorageAgentFundamentals
       voltage,
     )
 
-    (
-      updatedState,
-      ApparentPower(updatedSetPower, reactivePower),
-      flexChangeIndicator,
-    )
+    val apparentPower = ApparentPower(updatedSetPower, reactivePower)
+
+    val result: AccompaniedSimulationResult[ApparentPower] =
+      AccompaniedSimulationResult(apparentPower, Seq.empty[ResultEntity])
+
+    (updatedState, result, flexChangeIndicator)
+
   }
 
   /** Update the last known model state with the given external, relevant data

src/main/scala/edu/ie3/simona/agent/participant/wec/WecAgentFundamentals.scala

@@ -7,6 +7,7 @@
 package edu.ie3.simona.agent.participant.wec
 
 import edu.ie3.datamodel.models.input.system.WecInput
+import edu.ie3.datamodel.models.result.ResultEntity
 import edu.ie3.datamodel.models.result.system.{
   SystemParticipantResult,
   WecResult,
@@ -246,15 +247,22 @@ protected trait WecAgentFundamentals
       data: WecRelevantData,
       lastState: ConstantState.type,
       setPower: squants.Power,
-  ): (ConstantState.type, ApparentPower, FlexChangeIndicator) = {
+  ): (
+      ConstantState.type,
+      AccompaniedSimulationResult[ApparentPower],
+      FlexChangeIndicator,
+  ) = {
     /* Calculate result */
     val voltage = getAndCheckNodalVoltage(baseStateData, tick)
 
     val reactivePower = baseStateData.model.calculateReactivePower(
       setPower,
       voltage,
     )
-    val result = ApparentPower(setPower, reactivePower)
+    val result = AccompaniedSimulationResult(
+      ApparentPower(setPower, reactivePower),
+      Seq.empty[ResultEntity],
+    )
 
     /* Handle the request within the model */
     val (updatedState, flexChangeIndicator) =