feat: catalog-events, order-events 이벤트추가

Author: adminhelper

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/CatalogMetricsConsumer.java

@@ -3,14 +3,16 @@
 import com.loopers.confg.kafka.KafkaConfig;
 import com.loopers.domain.event.EventHandledService;
 import com.loopers.domain.metrics.ProductMetricsService;
+import com.loopers.ranking.RankingService;
 import com.loopers.interfaces.consumer.message.CatalogEventMessage;
-import java.util.List;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.kafka.support.Acknowledgment;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
+
 @Slf4j
 @Component
 @RequiredArgsConstructor
@@ -21,6 +23,7 @@ public class CatalogMetricsConsumer {
 
     private final ProductMetricsService productMetricsService;
     private final EventHandledService eventHandledService;
+    private final RankingService rankingService;
 
     @KafkaListener(
             topics = TOPIC,
@@ -48,6 +51,7 @@ public void consume(
                         ? System.currentTimeMillis()
                         : message.occurredAt().toInstant().toEpochMilli();
                 productMetricsService.applyLikeDelta(message.productId(), message.delta(), version);
+                rankingService.recordLikeEvent(message.productId(), message.delta(), message.occurredAt());
                 eventHandledService.markHandled(
                         message.eventId(),
                         HANDLER,

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderMetricsConsumer.java

@@ -4,15 +4,17 @@
 import com.loopers.domain.event.EventHandledService;
 import com.loopers.domain.metrics.ProductMetricsService;
 import com.loopers.domain.product.ProductCacheRefreshService;
+import com.loopers.ranking.RankingService;
 import com.loopers.interfaces.consumer.message.OrderEventMessage;
-import java.util.List;
-import java.util.Objects;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.kafka.support.Acknowledgment;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
+import java.util.Objects;
+
 @Slf4j
 @Component
 @RequiredArgsConstructor
@@ -24,6 +26,7 @@ public class OrderMetricsConsumer {
     private final ProductMetricsService productMetricsService;
     private final ProductCacheRefreshService productCacheRefreshService;
     private final EventHandledService eventHandledService;
+    private final RankingService rankingService;
 
     @KafkaListener(
             topics = TOPIC,
@@ -83,6 +86,7 @@ private void handleSalesMetrics(OrderEventMessage message, long version) {
             }
             productMetricsService.increaseSales(item.productId(), item.quantity(), version);
             productCacheRefreshService.refreshIfSoldOut(item.productId());
+            rankingService.recordOrderEvent(item.productId(), item.price(), item.quantity(), message.occurredAt());
         }
     }