TransactionRepository: add method getOcppTagOfActiveTransaction(integ…

…er connectorPK)

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

@@ -38,6 +38,8 @@ public interface TransactionRepository {
 
     List<Integer> getActiveTransactionIds(String chargeBoxId);
 
+    String getOcppTagOfActiveTransaction(Integer connectorPk);
+
     TransactionDetails getDetails(int transactionPk, boolean firstArrivingMeterValueIfMultiple);
 
     default TransactionDetails getDetails(int transactionPk) {

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

@@ -98,6 +98,15 @@ public List<Integer> getActiveTransactionIds(String chargeBoxId) {
                   .fetch(TRANSACTION.TRANSACTION_PK);
     }
 
+    @Override
+    public String getOcppTagOfActiveTransaction(Integer connectorPk) {
+        return ctx.select(TRANSACTION.ID_TAG)
+                .from(TRANSACTION)
+                .where(TRANSACTION.CONNECTOR_PK.eq(connectorPk))
+                .and(TRANSACTION.STOP_VALUE.isNull())
+                .fetchAny(TRANSACTION.ID_TAG);
+    }
+
     @Override
     public TransactionDetails getDetails(int transactionPk, boolean firstArrivingMeterValueIfMultiple) {