From 2b289864bd6807d83a0704f58571ffab3d1bbd5e Mon Sep 17 00:00:00 2001 From: kimscott Date: Tue, 3 Sep 2019 17:51:28 +0900 Subject: [PATCH] =?UTF-8?q?=EC=9D=B4=EB=B2=A4=ED=8A=B8=20=ED=94=84?= =?UTF-8?q?=EB=A1=9C=EC=84=B8=EC=8A=A4=20=EC=88=98=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/example/template/ProductRequired.java | 23 -------------- .../com/example/template/ProductService.java | 31 ++----------------- 2 files changed, 3 insertions(+), 51 deletions(-) delete mode 100644 src/main/java/com/example/template/ProductRequired.java diff --git a/src/main/java/com/example/template/ProductRequired.java b/src/main/java/com/example/template/ProductRequired.java deleted file mode 100644 index 317e233..0000000 --- a/src/main/java/com/example/template/ProductRequired.java +++ /dev/null @@ -1,23 +0,0 @@ -package com.example.template; - -public class ProductRequired extends AbstractEvent{ - - private String stateMessage; - private String productName ; - - public String getStateMessage() { - return stateMessage; - } - - public void setStateMessage(String stateMessage) { - this.stateMessage = stateMessage; - } - - public String getProductName() { - return productName; - } - - public void setProductName(String productName) { - this.productName = productName; - } -} diff --git a/src/main/java/com/example/template/ProductService.java b/src/main/java/com/example/template/ProductService.java index c9dc90a..d6181e7 100644 --- a/src/main/java/com/example/template/ProductService.java +++ b/src/main/java/com/example/template/ProductService.java @@ -26,39 +26,14 @@ public class ProductService { ObjectMapper objectMapper = new ObjectMapper(); objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false); - ProductRequired productRequired = null; + OrderPlaced orderPlaced = null; try { - productRequired = objectMapper.readValue(message, ProductRequired.class); + orderPlaced = objectMapper.readValue(message, OrderPlaced.class); - /** - * 상품 추가 요청이 왔을때 해당 상품을 찾아서 재고를 늘린다. - */ - if( productRequired.getEventType().equals(ProductRequired.class.getSimpleName())){ - - List productList = productRepository.findByName(productRequired.getProductName()); - Product product = null; - if( productList != null && productList.size() > 0 ){ - product = productList.get(0); - } - - if( product == null ) { - product = new Product(); - product.setName(productRequired.getProductName()); - product.setPrice(10000); - product.setStock(1); - } - - // product 의 수량을 10개씩 늘린다 - product.setStock(product.getStock() + 10); - - productRepository.save(product); - - } /** * 주문이 발생시, 수량을 줄인다. */ - else if( productRequired.getEventType().equals(OrderPlaced.class.getSimpleName())){ - OrderPlaced orderPlaced = objectMapper.readValue(message, OrderPlaced.class); + if( orderPlaced.getEventType().equals(OrderPlaced.class.getSimpleName())){ Optional productOptional = productRepository.findById(orderPlaced.getProductId()); Product product = productOptional.get();