Merge branch 'yeonjiyeon' into feature/week10

Author: yeonjiyeon

apps/commerce-api/build.gradle.kts

@@ -13,6 +13,19 @@ dependencies {
     implementation("org.springframework.boot:spring-boot-starter-actuator")
     implementation("org.springdoc:springdoc-openapi-starter-webmvc-ui:${project.properties["springDocOpenApiVersion"]}")
 
+    // Resilience4j (Spring Boot 3.x 기준)
+    implementation("io.github.resilience4j:resilience4j-spring-boot3")
+
+    // AOP
+    implementation("org.springframework.boot:spring-boot-starter-aop")
+
+    //Micrometer Prometheus
+    implementation("io.micrometer:micrometer-registry-prometheus")
+
+    //Spring Cloud OpenFeign
+    implementation("org.springframework.cloud:spring-cloud-starter-openfeign")
+
+
     // querydsl
     annotationProcessor("com.querydsl:querydsl-apt::jakarta")
     annotationProcessor("jakarta.persistence:jakarta.persistence-api")

apps/commerce-api/src/main/java/com/loopers/application/rank/RankingScheduler.java

@@ -0,0 +1,35 @@
+package com.loopers.application.rank;
+
+import com.loopers.infrastructure.rank.RankingService;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class RankingScheduler {
+
+  private final RankingService rankingService;
+
+  @Scheduled(cron = "0 50 23 * * *")
+  public void scheduleRankingCarryOver() {
+    LocalDateTime now = LocalDateTime.now();
+    DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMdd");
+
+    String today = now.format(formatter);
+    String tomorrow = now.plusDays(1).format(formatter);
+
+    log.info("Starting Ranking Carry-Over: {} -> {}", today, tomorrow);
+
+    try {
+      rankingService.carryOverRanking(today, tomorrow, 0.1);
+      log.info("Ranking Carry-Over completed successfully.");
+    } catch (Exception e) {
+      log.error("Ranking Carry-Over failed", e);
+    }
+  }
+}

apps/commerce-streamer/src/main/java/com/loopers/domain/metrics/ProductMetrics.java

@@ -0,0 +1,47 @@
+package com.loopers.domain.metrics;
+
+import jakarta.persistence.Entity;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import java.time.LocalDateTime;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@Table(name = "product_metrics")
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class ProductMetrics {
+
+  @Id
+  private Long productId;
+
+  private int likeCount = 0;
+  private int viewCount = 0;
+  private int salesCount = 0;
+
+  private LocalDateTime updatedAt;
+
+  public ProductMetrics(Long productId) {
+    this.productId = productId;
+  }
+
+  public void updateLikeCount(int newCount, LocalDateTime eventTime) {
+    if (this.updatedAt != null && eventTime.isBefore(this.updatedAt)) {
+      return;
+    }
+    this.likeCount = newCount;
+    this.updatedAt = eventTime;
+  }
+
+  public void incrementViewCount() {
+    this.viewCount += 1;
+    this.updatedAt = LocalDateTime.now();
+  }
+
+  public void addSalesCount(int quantity) {
+    this.salesCount += quantity;
+    this.updatedAt = LocalDateTime.now();
+  }
+}

settings.gradle.kts

@@ -8,6 +8,7 @@ include(
     ":modules:jpa",
     ":modules:redis",
     ":modules:kafka",
+
     ":supports:jackson",
     ":supports:logging",
     ":supports:monitoring",