wms commit

src/main/java/com/showcase/synapse/wms/aggregate/ProductAggregate.java → src/main/java/com/showcase/synapse/wms/aggregate/WMSAggregate.java

@@ -8,11 +8,11 @@ import org.axonframework.eventsourcing.EventSourcingHandler;
 import org.axonframework.modelling.command.AggregateIdentifier;
 import org.axonframework.spring.stereotype.Aggregate;
 
-import com.showcase.synapse.wms.command.ChangeQuantityCommand;
-import com.showcase.synapse.wms.command.CreateProductCommand;
-import com.showcase.synapse.wms.event.ProductCreatedEvent;
-import com.showcase.synapse.wms.event.ProductQuantityChangedEvent;
-import com.showcase.synapse.wms.saga.ProductSaga;
+import com.showcase.synapse.wms.command.ChangeInventoryQuantityCommand;
+import com.showcase.synapse.wms.command.CreateInventoryCommand;
+import com.showcase.synapse.wms.event.InventoryCreatedEvent;
+import com.showcase.synapse.wms.event.InventoryQuantityChangedEvent;
+import com.showcase.synapse.wms.saga.InventorySaga;
 
 import java.math.BigDecimal;
 
@@ -21,7 +21,7 @@ import static org.axonframework.modelling.command.AggregateLifecycle.apply;
 @Aggregate
 @NoArgsConstructor
 @Slf4j
-public class ProductAggregate {
+public class WMSAggregate {
 
     @AggregateIdentifier
     private String id;
@@ -29,26 +29,26 @@ public class ProductAggregate {
 
 
     @CommandHandler
-    public ProductAggregate(CreateProductCommand command) {
-    	log.info("[ProductAggregate(CreateProductCommand) > apply new ProductCreatedEvent]");
-        apply(new ProductCreatedEvent(command.getId(), command.getName(), command.getComment(), command.getPrice()));
+    public WMSAggregate(CreateInventoryCommand command) {
+    	log.info("[WMSAggregate(CreateInventoryCommand) > apply new InventoryCreatedEvent]");
+        apply(new InventoryCreatedEvent(command.getId(), command.getName(), command.getComment(), command.getPrice()));
     }
 
     @EventSourcingHandler
-    public void createProduct(ProductCreatedEvent event) {
+    public void createProduct(InventoryCreatedEvent event) {
         this.id = event.getProductId();
 //        this.quantiy = event.getQuantity();
     }
 
     @CommandHandler
-    public void changeQuantity(ChangeQuantityCommand command) {
+    public void changeQuantity(ChangeInventoryQuantityCommand command) {
     	log.info("[@CommandHandler ProductchangeQuantity]");
 //        if(this.quantiy < command.getQuantity()) throw new IllegalArgumentException("tfy ");
-//        apply(new ProductQuantityChangedEvent(command.getProductId(), this.quantiy - command.getQuantity()));
+//        apply(new InventoryQuantityChangedEvent(command.getProductId(), this.quantiy - command.getQuantity()));
     }
 
     @EventSourcingHandler
-    public void changeQuantity(ProductQuantityChangedEvent event) {
+    public void changeQuantity(InventoryQuantityChangedEvent event) {
 //        this.quantiy = event.getQuantity();
     }
 

src/main/java/com/showcase/synapse/wms/command/ChangeQuantityCommand.java → src/main/java/com/showcase/synapse/wms/command/ChangeInventoryQuantityCommand.java

@@ -7,7 +7,7 @@ import lombok.Getter;
 
 @AllArgsConstructor
 @Getter
-public class ChangeQuantityCommand {
+public class ChangeInventoryQuantityCommand {
 
     @TargetAggregateIdentifier
     private String productId;

src/main/java/com/showcase/synapse/wms/command/CreateProductCommand.java → src/main/java/com/showcase/synapse/wms/command/CreateInventoryCommand.java

@@ -8,7 +8,7 @@ import java.math.BigDecimal;
 
 @AllArgsConstructor
 @Getter
-public class CreateProductCommand {
+public class CreateInventoryCommand {
 
     @TargetAggregateIdentifier
     private final String id;

src/main/java/com/showcase/synapse/wms/controller/ProductController.java → src/main/java/com/showcase/synapse/wms/controller/WMSController.java

@@ -3,9 +3,9 @@ package com.showcase.synapse.wms.controller;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 
-import com.showcase.synapse.wms.dto.ProductCreateDto;
-import com.showcase.synapse.wms.entity.ProductEntity;
-import com.showcase.synapse.wms.service.ProductService;
+import com.showcase.synapse.wms.dto.InventoryCreateDto;
+import com.showcase.synapse.wms.entity.InventoryEntity;
+import com.showcase.synapse.wms.service.InventoryService;
 
 import java.math.BigDecimal;
 import java.util.HashMap;
@@ -16,23 +16,23 @@ import java.util.concurrent.ExecutionException;
 @RestController
 @RequestMapping("/api/msa/product")
 @CrossOrigin(origins = "*")
-public class ProductController {
+public class WMSController {
 
-    final ProductService productService;
+    final InventoryService productService;
 
-    public ProductController(ProductService productService) {
+    public WMSController(InventoryService productService) {
         this.productService = productService;
     }
 
     @GetMapping("/")
-    public ResponseEntity<List<ProductEntity>> getProducts() throws ExecutionException, InterruptedException {
-        List<ProductEntity> productEntities = productService.getProducts();
+    public ResponseEntity<List<InventoryEntity>> getProducts() throws ExecutionException, InterruptedException {
+        List<InventoryEntity> productEntities = productService.getProducts();
         return ResponseEntity.ok(productEntities);
 
     }
 
     @PostMapping("/")
-    public ResponseEntity<Map<String, String>> productCreate(@RequestBody ProductCreateDto productCreateDto) {
+    public ResponseEntity<Map<String, String>> productCreate(@RequestBody InventoryCreateDto productCreateDto) {
         String productId = productService.createProduct(productCreateDto.getName(),
         		productCreateDto.getComment(), 
                 BigDecimal.valueOf(productCreateDto.getPrice()));

src/main/java/com/showcase/synapse/wms/dto/ProductCreateDto.java → src/main/java/com/showcase/synapse/wms/dto/InventoryCreateDto.java

@@ -5,7 +5,7 @@ import lombok.Setter;
 
 @Getter
 @Setter
-public class ProductCreateDto {
+public class InventoryCreateDto {
     private String name;
     private String comment;
     private int price;

src/main/java/com/showcase/synapse/wms/entity/ProductEntity.java → src/main/java/com/showcase/synapse/wms/entity/InventoryEntity.java

@@ -14,7 +14,7 @@ import java.math.BigDecimal;
 @Setter
 @AllArgsConstructor
 @NoArgsConstructor
-public class ProductEntity {
+public class InventoryEntity {
     @Id
     private String id;
     private String name;

src/main/java/com/showcase/synapse/wms/enums/OrderStatus.java → src/main/java/com/showcase/synapse/wms/enums/InventoryStatus.java

 package com.showcase.synapse.wms.enums;
 
-public enum OrderStatus {
+public enum InventoryStatus {
     CREATED, CANCELED
 }

src/main/java/com/showcase/synapse/wms/event/ProductCreatedEvent.java → src/main/java/com/showcase/synapse/wms/event/InventoryCreatedEvent.java

@@ -7,7 +7,7 @@ import java.math.BigDecimal;
 
 @AllArgsConstructor
 @Getter
-public class ProductCreatedEvent {
+public class InventoryCreatedEvent {
     private String productId;
     private String name;
     private String comment;

src/main/java/com/showcase/synapse/wms/event/ProductQuantityChangedEvent.java → src/main/java/com/showcase/synapse/wms/event/InventoryQuantityChangedEvent.java

@@ -5,7 +5,7 @@ import lombok.Getter;
 
 @AllArgsConstructor
 @Getter
-public class ProductQuantityChangedEvent {
+public class InventoryQuantityChangedEvent {
     private String productId;
     private int quantity;
 }

src/main/java/com/showcase/synapse/wms/event/handler/ProductEventHandler.java → src/main/java/com/showcase/synapse/wms/event/handler/InventoryEventHandler.java

@@ -5,24 +5,24 @@ import lombok.extern.slf4j.Slf4j;
 import org.axonframework.eventhandling.EventHandler;
 import org.springframework.stereotype.Component;
 
-import com.showcase.synapse.wms.entity.ProductEntity;
-import com.showcase.synapse.wms.event.ProductCreatedEvent;
-import com.showcase.synapse.wms.event.ProductQuantityChangedEvent;
-import com.showcase.synapse.wms.repository.ProductRepository;
+import com.showcase.synapse.wms.entity.InventoryEntity;
+import com.showcase.synapse.wms.event.InventoryCreatedEvent;
+import com.showcase.synapse.wms.event.InventoryQuantityChangedEvent;
+import com.showcase.synapse.wms.repository.InventoryRepository;
 
 @Component
 @AllArgsConstructor
 @Slf4j
-public class ProductEventHandler {
+public class InventoryEventHandler {
 
-    private final ProductRepository productRepository;
+    private final InventoryRepository productRepository;
 
     @EventHandler
-    protected void saveProduct(ProductCreatedEvent productCreatedEvent) {
+    protected void saveProduct(InventoryCreatedEvent productCreatedEvent) {
 
-    	log.info("ProductCreatedEvent 이벤트 받음?");
-        log.info("ProductEventHandler > [ProductCreatedEvent] productCreatedEvent");
-        ProductEntity productEntity = new ProductEntity();
+    	log.info("InventoryCreatedEvent 이벤트 받음?");
+        log.info("InventoryEventHandler > [InventoryCreatedEvent] productCreatedEvent");
+        InventoryEntity productEntity = new InventoryEntity();
         productEntity.setId(productCreatedEvent.getProductId());
         productEntity.setName(productCreatedEvent.getName());
         productEntity.setComment(productCreatedEvent.getComment());
@@ -33,10 +33,10 @@ public class ProductEventHandler {
     }
 
     @EventHandler
-    protected void changeQuantity(ProductQuantityChangedEvent productQuantityChangedEvent) {
-    	log.info("ProductQuantityChangedEvent 이벤트 받음?");
-    	log.info("[ProductQuantityChangedEvent]");
-        ProductEntity productEntity = productRepository.findById(productQuantityChangedEvent.getProductId()).get();
+    protected void changeQuantity(InventoryQuantityChangedEvent productQuantityChangedEvent) {
+    	log.info("InventoryQuantityChangedEvent 이벤트 받음?");
+    	log.info("[InventoryQuantityChangedEvent]");
+        InventoryEntity productEntity = productRepository.findById(productQuantityChangedEvent.getProductId()).get();
 //        log.info("[{}] quantity:{}", productEntity.getName(), productEntity.getQuentity());
 //        productEntity.setQuentity(productQuantityChangedEvent.getQuantity());
         productRepository.save(productEntity);

src/main/java/com/showcase/synapse/wms/query/GetProductsQuery.java → src/main/java/com/showcase/synapse/wms/query/GetInventoryQuery.java

 package com.showcase.synapse.wms.query;
 
-public class GetProductsQuery {
+public class GetInventoryQuery {
 }

src/main/java/com/showcase/synapse/wms/query/handler/ProductQueryHandler.java → src/main/java/com/showcase/synapse/wms/query/handler/InventoryQueryHandler.java

@@ -5,9 +5,9 @@ import java.util.List;
 import org.axonframework.queryhandling.QueryHandler;
 import org.springframework.stereotype.Component;
 
-import com.showcase.synapse.wms.entity.ProductEntity;
-import com.showcase.synapse.wms.query.GetProductsQuery;
-import com.showcase.synapse.wms.repository.ProductRepository;
+import com.showcase.synapse.wms.entity.InventoryEntity;
+import com.showcase.synapse.wms.query.GetInventoryQuery;
+import com.showcase.synapse.wms.repository.InventoryRepository;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -15,12 +15,12 @@ import lombok.extern.slf4j.Slf4j;
 @Component
 @RequiredArgsConstructor
 @Slf4j
-public class ProductQueryHandler {
+public class InventoryQueryHandler {
 
-    private final ProductRepository productRepository;
+    private final InventoryRepository productRepository;
 
     @QueryHandler
-    protected List<ProductEntity> on(GetProductsQuery query) {
+    protected List<InventoryEntity> on(GetInventoryQuery query) {
     	log.info("---product query---");
         return productRepository.findAll();
     }

src/main/java/com/showcase/synapse/wms/repository/ProductRepository.java → src/main/java/com/showcase/synapse/wms/repository/InventoryRepository.java

 package com.showcase.synapse.wms.repository;
 import org.springframework.data.jpa.repository.JpaRepository;
 
-import com.showcase.synapse.wms.entity.ProductEntity;
+import com.showcase.synapse.wms.entity.InventoryEntity;
 
-public interface ProductRepository extends JpaRepository<ProductEntity, String> {
+public interface InventoryRepository extends JpaRepository<InventoryEntity, String> {
 
 }

src/main/java/com/showcase/synapse/wms/saga/ProductSaga.java → src/main/java/com/showcase/synapse/wms/saga/InventorySaga.java

@@ -8,7 +8,7 @@ import lombok.extern.slf4j.Slf4j;
 
 //@Saga
 @Slf4j
-public class ProductSaga {
+public class InventorySaga {
 
     @Autowired
     private transient CommandGateway commandGateway;

src/main/java/com/showcase/synapse/wms/service/ProductService.java → src/main/java/com/showcase/synapse/wms/service/InventoryService.java

@@ -10,28 +10,28 @@ import org.axonframework.messaging.responsetypes.ResponseTypes;
 import org.axonframework.queryhandling.QueryGateway;
 import org.springframework.stereotype.Service;
 
-import com.showcase.synapse.wms.command.CreateProductCommand;
-import com.showcase.synapse.wms.entity.ProductEntity;
-import com.showcase.synapse.wms.query.GetProductsQuery;
+import com.showcase.synapse.wms.command.CreateInventoryCommand;
+import com.showcase.synapse.wms.entity.InventoryEntity;
+import com.showcase.synapse.wms.query.GetInventoryQuery;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
 @Service
-public class ProductService {
+public class InventoryService {
 
     private final CommandGateway commandGateway;
     private final QueryGateway queryGateway;
 
-    public ProductService(CommandGateway commandGateway, QueryGateway queryGateway) {
+    public InventoryService(CommandGateway commandGateway, QueryGateway queryGateway) {
         this.commandGateway = commandGateway;
         this.queryGateway = queryGateway;
     }
 
     public String createProduct(String name, String comment, BigDecimal price) {
-    	log.info("[@Service createProduct] new CreateProductCommand");
+    	log.info("[@Service createProduct] new CreateInventoryCommand");
         // command생성
-        CreateProductCommand createProductCommand = new CreateProductCommand(
+        CreateInventoryCommand createProductCommand = new CreateInventoryCommand(
                 UUID.randomUUID().toString(), name, comment, price
         );
         System.out.println("test");
@@ -42,9 +42,9 @@ public class ProductService {
         return returnValue;
     }
 
-    public List<ProductEntity> getProducts() throws ExecutionException, InterruptedException {
-        return queryGateway.query(new GetProductsQuery(),
-                ResponseTypes.multipleInstancesOf(ProductEntity.class)).get();
+    public List<InventoryEntity> getProducts() throws ExecutionException, InterruptedException {
+        return queryGateway.query(new GetInventoryQuery(),
+                ResponseTypes.multipleInstancesOf(InventoryEntity.class)).get();
     }
 
 }

src/main/resources/application.yml

@@ -5,7 +5,7 @@ axon:
     servers: localhost:8124
 
 server:             
-  port : 9090
+  port : 9094
 
 spring:
   datasource: