diff --git a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/receive/InsertDataIntoCodex.java b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/receive/InsertDataIntoCodex.java index 064396d..036ce69 100644 --- a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/receive/InsertDataIntoCodex.java +++ b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/receive/InsertDataIntoCodex.java @@ -4,6 +4,8 @@ import static de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.ConstantsDataTransfer.BPMN_EXECUTION_VARIABLE_CONTINUE_STATUS; import static de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.ConstantsDataTransfer.CODESYSTEM_NUM_CODEX_DATA_TRANSFER_ERROR_VALUE_INSERT_INTO_CRR_FHIR_REPOSITORY_FAILED; +import java.util.ArrayList; +import java.util.List; import java.util.Objects; import org.camunda.bpm.engine.delegate.BpmnError; @@ -57,6 +59,7 @@ protected void doExecute(DelegateExecution execution, Variables variables) throw dataLogger.logData("Received bundle", bundle); dataClientFactory.getDataStoreClient().getFhirClient().storeBundle(bundle); + logger.info("stored bundle with entries: {}", entryIdsToList(bundle)); execution.setVariable(BPMN_EXECUTION_VARIABLE_CONTINUE_STATUS, ContinueStatus.SUCCESS); } @@ -74,4 +77,20 @@ protected void doExecute(DelegateExecution execution, Variables variables) throw "Unable to insert data into CRR"); } } + + private List entryIdsToList(Bundle bundle) + { + List entryIds = new ArrayList<>(); + + for (Bundle.BundleEntryComponent entry : bundle.getEntry()) + { + String fullUrl = entry.getFullUrl(); + if (fullUrl != null && !fullUrl.isEmpty()) + { + entryIds.add(fullUrl); + } + } + + return entryIds; + } }