remove the flag firstArrivingMeterValueIfMultiple and its usage (closes #1209)

Author: goekay

src/main/java/de/rwth/idsg/steve/repository/TransactionRepository.java

@@ -36,9 +36,5 @@ public interface TransactionRepository {
 
     List<Integer> getActiveTransactionIds(String chargeBoxId);
 
-    TransactionDetails getDetails(int transactionPk, boolean firstArrivingMeterValueIfMultiple);
-
-    default TransactionDetails getDetails(int transactionPk) {
-        return getDetails(transactionPk, true);
-    }
+    TransactionDetails getDetails(int transactionPk);
 }

src/main/java/de/rwth/idsg/steve/repository/impl/TransactionRepositoryImpl.java

@@ -89,7 +89,7 @@ public List<Integer> getActiveTransactionIds(String chargeBoxId) {
     }
 
     @Override
-    public TransactionDetails getDetails(int transactionPk, boolean firstArrivingMeterValueIfMultiple) {
+    public TransactionDetails getDetails(int transactionPk) {
 
         // -------------------------------------------------------------------------
         // Step 1: Collect general data about transaction
@@ -176,20 +176,7 @@ public TransactionDetails getDetails(int transactionPk, boolean firstArrivingMet
         //
         Table<ConnectorMeterValueRecord> t1 = transactionQuery.union(timestampQuery).asTable("t1");
 
-        // -------------------------------------------------------------------------
-        // Step 3: Charging station might send meter vales at fixed intervals (e.g.
-        // every 15 min) regardless of the fact that connector's meter value did not
-        // change (e.g. vehicle is fully charged, but cable is still connected). This
-        // yields multiple entries in db with the same value but different timestamp.
-        // We are only interested in the first (or last) arriving entry.
-        // -------------------------------------------------------------------------
-
-        Field<DateTime> dateTimeField;
-        if (firstArrivingMeterValueIfMultiple) {
-            dateTimeField = DSL.min(t1.field(2, DateTime.class)).as("min");
-        } else {
-            dateTimeField = DSL.max(t1.field(2, DateTime.class)).as("max");
-        }
+        Field<DateTime> dateTimeField = t1.field(2, DateTime.class);
 
         List<TransactionDetails.MeterValues> values =
                 ctx.select(
@@ -202,14 +189,6 @@ public TransactionDetails getDetails(int transactionPk, boolean firstArrivingMet
                         t1.field(8, String.class),
                         t1.field(9, String.class))
                    .from(t1)
-                   .groupBy(
-                           t1.field(3),
-                           t1.field(4),
-                           t1.field(5),
-                           t1.field(6),
-                           t1.field(7),
-                           t1.field(8),
-                           t1.field(9))
                    .orderBy(dateTimeField)
                    .fetch()
                    .map(r -> TransactionDetails.MeterValues.builder()

src/main/java/de/rwth/idsg/steve/service/TransactionStopService.java

@@ -57,7 +57,7 @@ public void stop(List<Integer> transactionPkList) {
     }
 
     public void stop(Integer transactionPk) {
-        TransactionDetails thisTxDetails = transactionRepository.getDetails(transactionPk, false);
+        TransactionDetails thisTxDetails = transactionRepository.getDetails(transactionPk);
         Transaction thisTx = thisTxDetails.getTransaction();
 
         // early exit, if transaction is already stopped