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
openMF · Jun 21, 2023 · f5c4c06 · f5c4c06
1 parent eefe52c
commit f5c4c06
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 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
@@ -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
@@ -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