From f5c4c064ababced2e19d573078ace9c90e866628 Mon Sep 17 00:00:00 2001
From: Arka Das <127482132+arkadasfynarfin@users.noreply.github.com>
Date: Wed, 21 Jun 2023 18:47:15 +0530
Subject: [PATCH] GOV-508: Importer rdbms bulk parser configuration (#42)

* GOV-75: added bpmn, no variables added

* GOV-508: add config for closedloop bulk connector

* GOV-508: address review comments 1
---
 .../java/hu/dpc/phee/operator/importer/RecordParser.java     | 5 +++--
 src/main/resources/application.yml                           | 4 +++-
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/src/main/java/hu/dpc/phee/operator/importer/RecordParser.java b/src/main/java/hu/dpc/phee/operator/importer/RecordParser.java
index d072570c..feba7f3d 100644
--- a/src/main/java/hu/dpc/phee/operator/importer/RecordParser.java
+++ b/src/main/java/hu/dpc/phee/operator/importer/RecordParser.java
@@ -314,7 +314,9 @@ private void updateTransferTableForBatch(Long workflowInstanceKey, Long complete
         for (Transaction transaction: transactionList) {
             Transfer transfer = BatchFormatToTransferMapper.mapToTransferEntity(transaction);
             transfer.setWorkflowInstanceKey(workflowInstanceKey);
-            transfer.setBatchId(strip(tempDocumentStore.getBatchId(workflowInstanceKey)));
+
+            String batchId = tempDocumentStore.getBatchId(workflowInstanceKey);
+            transfer.setBatchId(strip(batchId));
             transfer.setCompletedAt(new Date(completeTimestamp));
             transfer.setTransactionId(transaction.getRequestId());
 
@@ -327,7 +329,6 @@ private void updateTransferTableForBatch(Long workflowInstanceKey, Long complete
             transfer.setPayerFee(BigDecimal.ZERO);
 
             BatchFormatToTransferMapper.updateTransferUsingBatchDetails(transfer, batch);
-
             transferRepository.save(transfer);
         }
 
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 15837f91..f35ccd92 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -118,11 +118,13 @@ bpmn:
     - id: "mock_payment_transfer_debit"
       direction: "${bpmn.outgoing-direction}"
       type: "${bpmn.transfer-type}"
+    - id: "bulk_connector_closedloop"
+      direction: "UNKNOWN"
+      type: "${bpmn.batch-type}"
     - id: "minimal_mock_fund_transfer"
       direction: "${bpmn.outgoing-direction}"
       type: "${bpmn.transfer-type}"
 
-
 logging:
   level:
     ROOT: ERROR