commit 8bf7d2bd765682f7e05479e3ea24414ab44cee37
author mgeiss <mgeiss@mifos.org> Mon Jun 26 16:28:51 2017 +0200
committer mgeiss <mgeiss@mifos.org> Mon Jun 26 16:28:51 2017 +0200
tree 1476b5851f458eb49662e716830812390e33a2e9
parent 619cbc7ccd188f5ce4ecdb23e5f8eea7e13754ab

delete commands when deleting product definition

service/src/main/java/io/mifos/deposit/service/internal/command/handler/ProductDefinitionAggregate.java

diff --git a/service/src/main/java/io/mifos/deposit/service/internal/command/handler/ProductDefinitionAggregate.java b/service/src/main/java/io/mifos/deposit/service/internal/command/handler/ProductDefinitionAggregate.java
index 4afe8c9..690641e 100644
--- a/service/src/main/java/io/mifos/deposit/service/internal/command/handler/ProductDefinitionAggregate.java
+++ b/service/src/main/java/io/mifos/deposit/service/internal/command/handler/ProductDefinitionAggregate.java
@@ -207,6 +207,10 @@
     if (optionalProductDefinition.isPresent()) {
       final ProductDefinitionEntity productDefinitionEntity = optionalProductDefinition.get();
 
+      this.productDefinitionCommandRepository.delete(
+          this.productDefinitionCommandRepository.findByProductDefinition(productDefinitionEntity)
+      );
+
       this.currencyRepository.delete(productDefinitionEntity.getCurrency());
       this.termRepository.delete(productDefinitionEntity.getTerm());
       this.chargeRepository.delete(productDefinitionEntity.getCharges());