FIN-350 add the possibility to import transactions using a profile export json.

Author: gjong

bpmn-process/src/.camunda/element-templates/transaction.json

@@ -313,5 +313,48 @@
         }
       }
     ]
+  },
+  {
+    "$schema": "https://unpkg.com/@camunda/element-templates-json-schema/resources/schema.json",
+    "name": "Transaction: Create from TransactionJSON",
+    "id": "com.jongsoft.finance.bpmn.delegate.scheduler.ImportTransactionJsonDelegate",
+    "description": "Create a transaction in the application using a JSON representation stored on disk.",
+    "version": 1,
+    "appliesTo": [
+      "bpmn:ServiceTask"
+    ],
+    "properties": [
+      {
+        "label": "Implementation",
+        "type": "String",
+        "value": "${importTransactionJsonDelegate}",
+        "editable": false,
+        "binding": {
+          "type": "property",
+          "name": "camunda:delegateExpression"
+        }
+      },
+      {
+        "label": "Transaction",
+        "description": "The JSON transaction.",
+        "type": "String",
+        "binding": {
+          "type": "camunda:inputParameter",
+          "name": "transaction"
+        },
+        "constraint": {
+          "notEmpty": true
+        }
+      },
+      {
+        "label": "Transaction id",
+        "description": "The id of the created transaction",
+        "type": "String",
+        "binding": {
+          "type": "camunda:outputParameter",
+          "source": "${transactionId}"
+        }
+      }
+    ]
   }
 ]

bpmn-process/src/main/java/com/jongsoft/finance/bpmn/delegate/transaction/ImportTransactionJsonDelegate.java

@@ -0,0 +1,56 @@
+package com.jongsoft.finance.bpmn.delegate.transaction;
+
+import com.jongsoft.finance.domain.transaction.Transaction;
+import com.jongsoft.finance.messaging.commands.transaction.CreateTransactionCommand;
+import com.jongsoft.finance.messaging.handlers.TransactionCreationHandler;
+import com.jongsoft.finance.providers.AccountProvider;
+import com.jongsoft.finance.serialized.TransactionJson;
+import jakarta.inject.Singleton;
+import lombok.extern.slf4j.Slf4j;
+import org.camunda.bpm.engine.delegate.DelegateExecution;
+import org.camunda.bpm.engine.delegate.JavaDelegate;
+
+@Slf4j
+@Singleton
+public class ImportTransactionJsonDelegate implements JavaDelegate {
+
+    private final AccountProvider accountProvider;
+    private final TransactionCreationHandler creationHandler;
+
+    public ImportTransactionJsonDelegate(AccountProvider accountProvider, TransactionCreationHandler creationHandler) {
+        this.accountProvider = accountProvider;
+        this.creationHandler = creationHandler;
+    }
+
+    @Override
+    public void execute(DelegateExecution execution) throws Exception {
+        var transaction = (TransactionJson) execution.getVariableLocal("transaction");
+
+        log.debug("{}: Importing a transaction from '{}' to '{}'.",
+                execution.getCurrentActivityName(),
+                transaction.getFromAccount(),
+                transaction.getToAccount());
+
+        var fromAccount = accountProvider.lookup(transaction.getFromAccount())
+                .getOrThrow(() ->
+                        new IllegalStateException(
+                                "Unable to find account with name " + transaction.getFromAccount()));
+        var toAccount = accountProvider.lookup(transaction.getToAccount())
+                .getOrThrow(() ->
+                        new IllegalStateException(
+                                "Unable to find account with name " + transaction.getToAccount()));
+
+        var created = fromAccount.createTransaction(
+                toAccount,
+                transaction.getAmount(),
+                Transaction.Type.CREDIT,
+                t -> t.currency(transaction.getCurrency())
+                        .date(transaction.getDate())
+                        .bookDate(transaction.getBookDate())
+                        .interestDate(transaction.getInterestDate())
+                        .description(transaction.getDescription()));
+
+        long transactionId = creationHandler.handleCreatedEvent(new CreateTransactionCommand(created));
+        execution.setVariable("transactionId", transactionId);
+    }
+}

bpmn-process/src/main/java/com/jongsoft/finance/bpmn/delegate/user/ParseUserConfigurationDelegate.java

@@ -62,12 +62,16 @@ public void execute(DelegateExecution execution) throws Exception {
             execution.setVariableLocal("budgetPeriods", List.of());
         }
 
+        execution.setVariableLocal("transactions", Control.Option(profileJson.getTransactions())
+                    .getOrSupply(List::of));
+
         execution.setVariableLocal("accounts", serialize(profileJson.getAccounts()));
         execution.setVariableLocal("contracts", serialize(profileJson.getContracts()));
         execution.setVariableLocal("categories", serialize(profileJson.getCategories()));
         execution.setVariableLocal("tags", Control.Option(profileJson.getTags()).getOrSupply(List::of));
     }
 
+
     List<String> serialize(List<?> input) {
         if (input == null) {
             return List.of();