Merge pull request #57 from nowgnas/LF1-859-order-payment-request

✨ LF1-859 주문 결제 요청 추가

.gitignore

@@ -37,4 +37,5 @@ out/
 .vscode/
 docker.sh
 *.DS_Store
-data.sql
+data.sql
+ProductKafkaTest.java

src/main/java/kr/bb/product/domain/product/application/handler/ProductQueryHandler.java

@@ -12,17 +12,21 @@
 @RequiredArgsConstructor
 public class ProductQueryHandler {
   private static final String STORE_AVERAGE_RATING_UPDATE_TOPIC = "store-average-rating-update";
+  private static final String ORDER_CREATE = "order-create";
   private final ProductQueryUseCase productQueryUseCase;
   private final StoreServiceClient storeServiceClient;
-  private final ProductKafkaProcessor<Map<Long, Double>> productKafkaProcessor;
+  private final ProductKafkaProcessor<Map<Long, Double>> mapProductKafkaProcessor;
+  private final ProductKafkaProcessor<ProcessOrderDto> processOrderDtoProductKafkaProcessor;
 
   public void getStoreAverageRating() {
-    Map<Long, Double> storeAverageRating = productQueryUseCase.getStoreAverageRating();
-    productKafkaProcessor.send(STORE_AVERAGE_RATING_UPDATE_TOPIC, storeAverageRating);
+    mapProductKafkaProcessor.send(
+        STORE_AVERAGE_RATING_UPDATE_TOPIC, productQueryUseCase.getStoreAverageRating());
   }
 
   public void getFlowerAmountForOrder(ProcessOrderDto processOrderDto) {
     storeServiceClient.flowerStockDecreaseRequest(
         productQueryUseCase.getFlowerAmountGroupByStoreId(processOrderDto));
+    // order create request kafka
+    processOrderDtoProductKafkaProcessor.send(ORDER_CREATE, processOrderDto);
   }
 }