[HCR-425] Hotfix/hsc 425

build.gradle

@@ -64,7 +64,9 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-security'
     implementation 'org.springframework.boot:spring-boot-starter-oauth2-client'
     implementation 'org.springframework.boot:spring-boot-starter-web'
+    implementation 'org.springframework.boot:spring-boot-starter-cache'
     implementation 'org.springframework.kafka:spring-kafka'
+    implementation 'com.github.ben-manes.caffeine:caffeine'
     runtimeOnly 'software.amazon.msk:aws-msk-iam-auth:2.3.5'
     runtimeOnly 'org.postgresql:postgresql'
     compileOnly 'org.projectlombok:lombok'

src/main/java/site/holliverse/HolliverseApplication.java

@@ -2,7 +2,9 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cache.annotation.EnableCaching;
 
+@EnableCaching
 @SpringBootApplication(
         scanBasePackages = "site.holliverse"
 )

src/main/java/site/holliverse/admin/application/usecase/RetrieveRegionalMetricUseCase.java

@@ -1,12 +1,14 @@
 package site.holliverse.admin.application.usecase;
 
 import lombok.RequiredArgsConstructor;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.context.annotation.Profile;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import site.holliverse.admin.query.dao.AdminRegionalMetricDao;
 import site.holliverse.admin.query.dao.RegionalMetricRawData;
 import site.holliverse.admin.web.dto.analytics.AdminRegionalMetricRequestDto;
+import site.holliverse.shared.config.cache.CacheConfig;
 import site.holliverse.shared.alert.AlertOwner;
 import site.holliverse.shared.logging.SystemLogEvent;
 
@@ -24,6 +26,7 @@ public class RetrieveRegionalMetricUseCase {
     @Transactional(readOnly = true)
     @SystemLogEvent("admin.regional.metrics")
     @AlertOwner("bm")
+    @Cacheable(cacheNames = CacheConfig.REGIONAL_METRICS_CACHE, key = "#requestDto.yyyymm()",sync = true)
     public List<RegionalMetricRawData> execute(AdminRegionalMetricRequestDto requestDto) {
         return adminRegionalMetricDao.findRegionalAverages(requestDto.yyyymm());
     }

src/main/java/site/holliverse/admin/application/usecase/RetrieveRegionalTopPlanUseCase.java

@@ -1,12 +1,14 @@
 package site.holliverse.admin.application.usecase;
 
 import lombok.RequiredArgsConstructor;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.context.annotation.Profile;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import site.holliverse.admin.query.dao.AdminRegionalTopPlanDao;
 import site.holliverse.admin.query.dao.RegionalSubscriberCountRawData;
 import site.holliverse.admin.query.dao.RegionalTopPlanRawData;
+import site.holliverse.shared.config.cache.CacheConfig;
 import site.holliverse.shared.alert.AlertOwner;
 import site.holliverse.shared.logging.SystemLogEvent;
 
@@ -43,6 +45,7 @@ public class RetrieveRegionalTopPlanUseCase {
     @Transactional(readOnly = true)
     @SystemLogEvent("admin.regional.topN")
     @AlertOwner("bm")
+    @Cacheable(cacheNames = CacheConfig.REGIONAL_TOP_PLANS_CACHE, sync = true)
     public List<RegionalTopPlanSummary> execute() {
 
         // 지역별

src/main/java/site/holliverse/admin/query/dao/AdminRegionalTopPlanDao.java

@@ -20,6 +20,7 @@
  * 지역별 Top 요금제/가입자 수 집계를 담당하는 DAO.
  * - 전지역 단위로 한 번에 집계한다.
  * - 기준 데이터는 활성 구독만 사용한다.
+ *
  * @author nonstop
  * @version 1.0.0
  * @since 2026-02-23
@@ -34,60 +35,82 @@ public class AdminRegionalTopPlanDao {
 
     /**
      * 전지역의 Top N 요금제명을 조회한다.
-     *
      * 정렬 기준(지역 내부):
      * 1) 요금제 가입자 수 내림차순
      * 2) 요금제명 오름차순 (이유 : 요금제명 오름차순을 안하면 같은 구독자일시 매번 요금제명이 달라질 수 있음)
-     *
      * 반환:
      * 지역과 top3 요금제
      */
     public List<RegionalTopPlanRawData> findTopPlansByAllProvinces(int limit) {
         Field<String> province = ADDRESS.PROVINCE.as("province");
+        Field<Long> memberId = MEMBER.MEMBER_ID.as("memberId");
         Field<String> planName = PRODUCT.NAME.as("planName");
-        // 지역별 순위를 만들기 위한 윈도우 함수(row_number)
-        Field<Integer> rankNo = DSL.rowNumber().over(
-                DSL.partitionBy(ADDRESS.PROVINCE)
-                        .orderBy(DSL.countDistinct(MEMBER.MEMBER_ID).desc(), PRODUCT.NAME.asc())
-        ).as("rankNo");
 
-        // 1단계: (지역, 요금제)별 가입자 수를 집계하고 지역 내부 순위를 계산
-        Table<?> ranked = dsl
-                .select(province, planName, rankNo)
+        //1. 먼저 지역 + 회원 + 요금제 기준으로 중복을 제거
+        // 원래 countDistinct(member_id)로 하던 일을 앞단의 distinct로 옮긴 단계였음.
+        Table<?> base = dsl
+                .selectDistinct(province, memberId, planName)
                 .from(SUBSCRIPTION)
                 .join(MEMBER).on(MEMBER.MEMBER_ID.eq(SUBSCRIPTION.MEMBER_ID))
                 .join(ADDRESS).on(ADDRESS.ADDRESS_ID.eq(MEMBER.ADDRESS_ID))
                 .join(PRODUCT).on(PRODUCT.PRODUCT_ID.eq(SUBSCRIPTION.PRODUCT_ID))
                 .where(SUBSCRIPTION.STATUS.isTrue())
                 .and(PRODUCT.PRODUCT_TYPE.eq(ProductTypeEnum.MOBILE_PLAN))
-                .groupBy(ADDRESS.PROVINCE, PRODUCT.NAME)
-                .asTable("ranked");
+                .asTable("base");
+        Field<String> baseProvince = base.field("province", String.class);
+        Field<String> basePlanName = base.field("planName", String.class);
 
-        Field<String> rankedProvince = ranked.field(province);
-        Field<String> rankedPlanName = ranked.field(planName);
-        Field<Integer> rankedRankNo = ranked.field(rankNo);
+        //2. 중복 제거된 결과에서 지역 + 요금제별 가입자 수를 카운트
+        // 개선안 : 여기서는 이미 회원 중복이 제거 됐으므로 countDistinct가 아니라 count(*)면 됨
+        Field<Integer> subscriberCount = DSL.count().as("subscriberCount");
+        Table<?> planCounts = dsl
+                .select(
+                        baseProvince,
+                        basePlanName,
+                        subscriberCount
+                )
+                .from(base)
+                .groupBy(baseProvince, basePlanName)
+                .asTable("planCounts");
 
-        // 2단계: 지역별 순위가 limit 이하인 데이터만 추출
-        return dsl
+        Field<String> countedProvince = planCounts.field("province", String.class);
+        Field<String> countedPlanName = planCounts.field("planName", String.class);
+        Field<Integer> countedSubscriberCount = planCounts.field("subscriberCount", Integer.class);
+
+        // 3. 지역별로 가입자 수 내림차순, 요금제명 오름차순 기준 rank를 만듬
+        Field<Integer> rankNo = DSL.rowNumber().over(
+                DSL.partitionBy(countedProvince)
+                        .orderBy(countedSubscriberCount.desc(), countedPlanName.asc())
+        ).as("rankNo");
+
+        Table<?> ranked = dsl
                 .select(
-                        rankedProvince,
-                        rankedPlanName
+                        countedProvince,
+                        countedPlanName,
+                        rankNo
                 )
+                .from(planCounts)
+                .asTable("ranked");
+
+        Field<String> rankedProvince = ranked.field("province", String.class);
+        Field<String> rankedPlanName = ranked.field("planName", String.class);
+        Field<Integer> rankedRankNo = ranked.field("rankNo", Integer.class);
+
+        // 4. 지역별 상위 N개만 추출하고 기존 DTO 형태로 반환
+        return dsl
+                .select(rankedProvince, rankedPlanName)
                 .from(ranked)
                 .where(rankedRankNo.le(limit))
-                .orderBy(
-                        rankedProvince.asc(),
-                        rankedRankNo.asc()
-                )
+                .orderBy(rankedProvince.asc(), rankedRankNo.asc())
                 .fetch(r -> new RegionalTopPlanRawData(
                         r.get(rankedProvince),
                         r.get(rankedPlanName)
                 ));
+
     }
 
     /**
      * 전지역 총 가입자 수를 조회한다.
-     *
      * 규칙:
      * - distinct(member_id) 기준
      * - 활성 구독(status=true)만 포함

src/main/java/site/holliverse/shared/config/cache/CacheConfig.java

@@ -0,0 +1,65 @@
+package site.holliverse.shared.config.cache;
+
+import com.github.benmanes.caffeine.cache.Caffeine;
+import org.springframework.beans.factory.annotation.Value;
+
+import org.springframework.cache.CacheManager;
+import org.springframework.cache.caffeine.CaffeineCacheManager;
+import org.springframework.cache.support.CompositeCacheManager;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+
+
+/**
+ * ==========================
+ * 캐쉬 컨피그 파일
+ *
+ * @author nonstop
+ * @version 1.0.0
+ * @since 2026-04-04
+ * ==========================
+ */
+
+@Configuration
+public class CacheConfig {
+
+    public static final String REGIONAL_METRICS_CACHE = "regionalMetrics";
+    public static final String REGIONAL_TOP_PLANS_CACHE = "regionalTopPlans";
+
+    /**
+     * 스프링이 사용할 캐시매니저 빈 등록
+     * 각 캐시의 만료시간, 최대 크기를 application.yaml에서 주입받는다.
+     * 값이 없으면 기본 값으로 설정
+     */
+    @Bean
+    public CacheManager cacheManager(
+            @Value("${app.cache.regional-metrics.spec:maximumSize=50,expireAfterWrite=5m}") String regionalMetricsSpec,
+            @Value("${app.cache.regional-top-plans.spec:maximumSize=10,expireAfterWrite=5m}") String regionalTopPlansSpec
+    ) {
+
+        /**
+         * 관리자 통계 쪽 전용 캐시 매니저 생성
+         * caffeine 정책으로 적용
+         * 별도 TTL/사이즈 정책으로 가질 수 잇음.
+         */
+
+        var regionalMetricsCache = new CaffeineCacheManager(REGIONAL_METRICS_CACHE);
+        regionalMetricsCache.setCaffeine(Caffeine.from(regionalMetricsSpec));
+
+        var regionalTopPlansCache = new CaffeineCacheManager(REGIONAL_TOP_PLANS_CACHE);
+        regionalTopPlansCache.setCaffeine(Caffeine.from(regionalTopPlansSpec));
+
+        /**
+         * 스프링에서는 하나의 캐시매니저만 등록해야되기때문에 여러 캐시매니저를 묶어서 반환.
+         * 캐시 이름에 따라 적절한 매니저를 찾아주는 역할
+         */
+        return new CompositeCacheManager(
+                regionalMetricsCache,
+                regionalTopPlansCache
+        );
+    }
+
+
+
+}

src/main/resources/application.yaml

@@ -120,6 +120,11 @@ app:
   version: ${APP_VERSION:latest} #현재 release version 명시
   logging:
     member-hash-salt: ${APP_LOGGING_MEMBER_HASH_SALT:change-me-local}
+  cache:
+    regional-metrics:
+      spec: ${APP_CACHE_REGIONAL_METRICS_SPEC:maximumSize=50,expireAfterWrite=5m}
+    regional-top-plans:
+      spec: ${APP_CACHE_REGIONAL_TOP_PLANS_SPEC:maximumSize=10,expireAfterWrite=5m}
 
   #Discord
   alerts: