diff --git a/java-spring/accounts-query-side-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/queryside/accounts/AccountInfo.java b/java-spring/accounts-query-side-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/queryside/accounts/AccountInfo.java index 0fc343f..cd134f1 100644 --- a/java-spring/accounts-query-side-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/queryside/accounts/AccountInfo.java +++ b/java-spring/accounts-query-side-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/queryside/accounts/AccountInfo.java @@ -18,7 +18,6 @@ public class AccountInfo { private long balance; private List changes; private Map transactions; - private Map transferStates; private String version; private Date date; @@ -77,12 +76,4 @@ public class AccountInfo { public Date getDate() { return date; } - - public Map getTransferStates() { - return transferStates; - } - - public void setTransferStates(Map transferStates) { - this.transferStates = transferStates; - } } diff --git a/java-spring/accounts-query-side-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/queryside/accounts/AccountInfoUpdateService.java b/java-spring/accounts-query-side-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/queryside/accounts/AccountInfoUpdateService.java index d727b1c..9fe105d 100644 --- a/java-spring/accounts-query-side-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/queryside/accounts/AccountInfoUpdateService.java +++ b/java-spring/accounts-query-side-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/queryside/accounts/AccountInfoUpdateService.java @@ -55,10 +55,12 @@ public class AccountInfoUpdateService { public void addTransaction(String accountId, AccountTransactionInfo ti) { + System.out.println("Start addTransaction for: "+ti.toString()); mongoTemplate.upsert(new Query(where("id").is(accountId)), new Update(). set("transactions." + ti.getTransactionId(), ti), AccountInfo.class); + System.out.println("End addTransaction for: "+ti.toString()); } @@ -72,9 +74,11 @@ public class AccountInfoUpdateService { } public void updateTransactionStatus(String accountId, String transactionId, TransferState status) { + System.out.println("Start updateTransactionStatus "+accountId +" "+transactionId+" "+status); mongoTemplate.upsert(new Query(where("id").is(accountId)), new Update(). - set("transferStates." + transactionId, status), + set("transactions." + transactionId + ".status", status), AccountInfo.class); + System.out.println("End updateTransactionStatus "+accountId +" "+transactionId+" "+status); } } diff --git a/java-spring/accounts-query-side-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/queryside/accounts/AccountQueryService.java b/java-spring/accounts-query-side-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/queryside/accounts/AccountQueryService.java index f8b736f..3dfa68b 100644 --- a/java-spring/accounts-query-side-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/queryside/accounts/AccountQueryService.java +++ b/java-spring/accounts-query-side-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/queryside/accounts/AccountQueryService.java @@ -15,8 +15,6 @@ public class AccountQueryService { if (account == null) throw new AccountNotFoundException(accountId); else - if(account.getTransferStates()!=null) - account.getTransactions().stream().forEach(ati -> ati.setStatus(account.getTransferStates().get(ati.getTransactionId()))); return account; }