GOV-564: add new column sub batch id (#50)

openMF · Sep 11, 2023 · a544fdc · a544fdc
1 parent f658028
commit a544fdc
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/src/main/java/hu/dpc/phee/operator/entity/transfer/Transfer.java b/src/main/java/hu/dpc/phee/operator/entity/transfer/Transfer.java
@@ -71,6 +71,9 @@ public class Transfer extends AbstractPersistableCustom<Long> {
     @Column(name = "BATCH_ID")
     private String batchId;
 
+    @Column(name = "SUB_BATCH_ID")
+    private String subBatchId;
+
     @Column(name = "CLIENTCORRELATIONID")
     private String clientCorrelationId;
 
@@ -265,6 +268,14 @@ public void setBatchId(String batchId) {
         this.batchId = batchId;
     }
 
+    public String getSubBatchId() {
+        return subBatchId;
+    }
+
+    public void setSubBatchId(String subBatchId) {
+        this.subBatchId = subBatchId;
+    }
+
     public String getClientCorrelationId() {
         return clientCorrelationId;
     }

diff --git a/src/main/java/hu/dpc/phee/operator/importer/VariableParser.java b/src/main/java/hu/dpc/phee/operator/importer/VariableParser.java
@@ -55,6 +55,7 @@ public VariableParser() {
             parseTransferCreateFailed(pair.getFirst(), pair.getSecond());
         });
         transferParsers.put("batchId", pair -> pair.getFirst().setBatchId(strip(pair.getSecond())));
+        transferParsers.put("subBatchId", pair -> pair.getFirst().setSubBatchId(strip(pair.getSecond())));
         transferParsers.put("clientCorrelationId", pair -> parseClientCorrelationIdTransfers(pair.getFirst(), pair.getSecond()));
 
         transactionRequestParsers.put("authType", pair -> pair.getFirst().setAuthType(strip(pair.getSecond())));