ff

Author: Anover000

src/main/java/hu/dpc/phee/operator/streams/InflightBatchManager.java

@@ -120,6 +120,10 @@ private void    updateTransferTableForBatch(Batch batch, Long workflowInstanceKe
             transfer.setPayeeFee(BigDecimal.ZERO);
             transfer.setPayerFeeCurrency(transaction.getCurrency());
             transfer.setPayerFee(BigDecimal.ZERO);
+            transfer.setPayeePartyIdType(transaction.getPayeeIdentifierType());
+            transfer.setPayeePartyId(transaction.getPayeeIdentifier());
+            transfer.setPayerPartyIdType(transaction.getPayerIdentifierType());
+            transfer.setPayerPartyId(transaction.getPayerIdentifier());
 
             BatchFormatToTransferMapper.updateTransferUsingBatchDetails(transfer, batch);
             transfer = updatedExistingRecord(transfer, batchId);

src/main/java/hu/dpc/phee/operator/streams/RecordParser.java

@@ -368,10 +368,10 @@ public void parseSubBatchDetails(String jsonString, String bpmn, Long timestamp)
             existingBatchOpt.orElseGet(() -> {
                 batchRepository.save(bt);
                 Optional<TransferTransformerConfig.Flow> config = transferTransformerConfig.findFlow(bpmn);
-//                if(!config.get().getName().contains("bulk_processor")) {
-//                    inflightBatchManager.storeBatchFileName(bt.getWorkflowKey(), bt.getRequestFile());
-//                    inflightBatchManager.checkWorkerIdAndUpdateTransferData(bt, bt.getWorkflowInstanceKey(), timestamp);
-//                }
+                if(config.get().getName().equalsIgnoreCase("bulk_connector_closedloop")) {
+                    inflightBatchManager.storeBatchFileName(bt.getWorkflowKey(), bt.getRequestFile());
+                    inflightBatchManager.checkWorkerIdAndUpdateTransferData(bt, bt.getWorkflowInstanceKey(), timestamp);
+                }
                 return bt; // Return bt as it's saved now.
             });
         }