Skip to content

Commit

Permalink
foramt-and-sort
Browse files Browse the repository at this point in the history
  • Loading branch information
wetret committed Dec 15, 2023
1 parent ef3c66a commit d4299dc
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 12 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,6 @@
import de.medizininformatik_initiative.process.data_transfer.ConstantsDataTransfer;
import de.medizininformatik_initiative.processes.common.util.ConstantsBase;
import de.medizininformatik_initiative.processes.common.util.DataSetStatusGenerator;

import dev.dsf.bpe.v1.ProcessPluginApi;
import dev.dsf.bpe.v1.activity.AbstractTaskMessageSend;
import dev.dsf.bpe.v1.variables.Variables;
Expand Down Expand Up @@ -55,15 +54,14 @@ protected Stream<ParameterComponent> getAdditionalInputParameters(DelegateExecut
.setCode(ConstantsDataTransfer.CODESYSTEM_DATA_TRANSFER_VALUE_DATA_SET_REFERENCE);
binaryComponent.setValue(new Reference().setType(ResourceType.Binary.name()).setReference(binaryId));

String projectIdentifier = variables.getString(
ConstantsDataTransfer.BPMN_EXECUTION_VARIABLE_PROJECT_IDENTIFIER);
String projectIdentifier = variables
.getString(ConstantsDataTransfer.BPMN_EXECUTION_VARIABLE_PROJECT_IDENTIFIER);

Task.ParameterComponent projectIdentifierComponent = new Task.ParameterComponent();
projectIdentifierComponent.getType().addCoding().setSystem(ConstantsDataTransfer.CODESYSTEM_DATA_TRANSFER)
.setCode(ConstantsDataTransfer.CODESYSTEM_DATA_TRANSFER_VALUE_PROJECT_IDENTIFIER);
projectIdentifierComponent.setValue(
new Identifier().setSystem(ConstantsBase.NAMINGSYSTEM_MII_PROJECT_IDENTIFIER)
.setValue(projectIdentifier));
projectIdentifierComponent.setValue(new Identifier()
.setSystem(ConstantsBase.NAMINGSYSTEM_MII_PROJECT_IDENTIFIER).setValue(projectIdentifier));

return Stream.of(binaryComponent, projectIdentifierComponent);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,6 @@
import de.medizininformatik_initiative.process.data_transfer.ConstantsDataTransfer;
import de.medizininformatik_initiative.processes.common.util.ConstantsBase;
import de.medizininformatik_initiative.processes.common.util.DataSetStatusGenerator;

import dev.dsf.bpe.v1.ProcessPluginApi;
import dev.dsf.bpe.v1.activity.AbstractTaskMessageSend;
import dev.dsf.bpe.v1.variables.Variables;
Expand Down Expand Up @@ -56,16 +55,18 @@ protected IdType doSend(FhirWebserviceClient client, Task task)

private Stream<Task.ParameterComponent> createReceiptError(Variables variables)
{
return statusGenerator.transformOutputToInputComponent(variables.getStartTask(),
ConstantsDataTransfer.CODESYSTEM_DATA_TRANSFER,
ConstantsDataTransfer.CODESYSTEM_DATA_TRANSFER_VALUE_DATA_SET_STATUS).map(this::receiveToReceiptStatus);
return statusGenerator
.transformOutputToInputComponent(variables.getStartTask(),
ConstantsDataTransfer.CODESYSTEM_DATA_TRANSFER,
ConstantsDataTransfer.CODESYSTEM_DATA_TRANSFER_VALUE_DATA_SET_STATUS)
.map(this::receiveToReceiptStatus);
}

private Task.ParameterComponent receiveToReceiptStatus(Task.ParameterComponent parameterComponent)
{
Type value = parameterComponent.getValue();
if (value instanceof Coding coding && ConstantsBase.CODESYSTEM_DATA_SET_STATUS_VALUE_RECEIVE_ERROR.equals(
coding.getCode()))
if (value instanceof Coding coding
&& ConstantsBase.CODESYSTEM_DATA_SET_STATUS_VALUE_RECEIVE_ERROR.equals(coding.getCode()))
{
coding.setCode(ConstantsBase.CODESYSTEM_DATA_SET_STATUS_VALUE_RECEIPT_ERROR);
}
Expand Down

0 comments on commit d4299dc

Please sign in to comment.