Feat: 주점 매출 순위 등락 기능 추가

nowait-app-admin-api/build.gradle

@@ -21,6 +21,7 @@ dependencies {
     implementation project(':nowait-infra')
     implementation project(':nowait-domain:domain-admin-rdb')
     implementation project(':nowait-domain:domain-core-rdb')
+    implementation project(':nowait-domain:domain-redis')
 
     // Spring Boot Starter
     implementation 'org.springframework.boot:spring-boot-starter-web'
@@ -36,6 +37,9 @@ dependencies {
     implementation 'io.jsonwebtoken:jjwt-impl:0.12.3'
     implementation 'io.jsonwebtoken:jjwt-jackson:0.12.3'
 
+    // redis
+    implementation 'org.springframework.boot:spring-boot-starter-data-redis'
+
     // SWAGGER
     implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.6.0'
 

nowait-app-admin-api/src/main/java/com/nowait/ApiAdminApplication.java

@@ -2,8 +2,10 @@
 
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @EnableJpaAuditing
+@EnableScheduling
 @SpringBootApplication
 public class ApiAdminApplication {
 	public static void main(String[] args) {

nowait-app-admin-api/src/main/java/com/nowait/applicationadmin/order/controller/OrderController.java

@@ -17,8 +17,6 @@
 import com.nowait.applicationadmin.order.dto.OrderStatusUpdateResponseDto;
 import com.nowait.applicationadmin.order.service.OrderService;
 import com.nowait.common.api.ApiUtils;
-import com.nowait.domaincorerdb.order.dto.OrderSalesSumDetail;
-import com.nowait.domaincorerdb.order.dto.TopSalesStoresDetail;
 import com.nowait.domaincorerdb.user.entity.MemberDetails;
 
 import io.swagger.v3.oas.annotations.Operation;
@@ -65,34 +63,4 @@ public ResponseEntity<?> updateOrderStatus(
 			.status(HttpStatus.OK)
 			.body(ApiUtils.success(response));
 	}
-
-	@GetMapping("/sales")
-	@Operation(summary = "오늘의 매출 조회", description = "오늘의 매출을 조회합니다.")
-	@ApiResponse(responseCode = "200", description = "오늘의 매출 조회 성공")
-	public ResponseEntity<?> getTodaySales(@AuthenticationPrincipal MemberDetails memberDetails) {
-		OrderSalesSumDetail sales = orderService.getSaleSumByStoreId(memberDetails);
-
-		return ResponseEntity
-			.status(HttpStatus.OK)
-			.body(
-				ApiUtils.success(
-					sales
-				)
-			);
-	}
-
-	@GetMapping("/top-sales")
-	@Operation(summary = "오늘의 매출 상위 5개 주점 조회", description = "오늘의 매출이 가장 높은 상위 5개 주점을 조회합니다.")
-	@ApiResponse(responseCode = "200", description = "오늘의 매출 상위 5개 주점 조회 성공")
-	public ResponseEntity<?> getTopSalesStores(@AuthenticationPrincipal MemberDetails memberDetails) {
-		List<TopSalesStoresDetail> topSalesStoresDetail =  orderService.getTop5StoresBySalesToday(memberDetails);
-
-		return ResponseEntity
-			.status(HttpStatus.OK)
-			.body(
-				ApiUtils.success(
-					topSalesStoresDetail
-				)
-			);
-	}
 }

nowait-app-admin-api/src/main/java/com/nowait/applicationadmin/order/service/OrderService.java

@@ -9,8 +9,9 @@
 import com.nowait.applicationadmin.order.dto.OrderResponseDto;
 import com.nowait.applicationadmin.order.dto.OrderStatusUpdateResponseDto;
 import com.nowait.common.enums.Role;
-import com.nowait.domaincorerdb.order.dto.OrderSalesSumDetail;
-import com.nowait.domaincorerdb.order.dto.TopSalesStoresDetail;
+import com.nowait.domainadminrdb.statistic.dto.OrderSalesSumDetail;
+import com.nowait.domainadminrdb.statistic.dto.TopSalesStoresDetail;
+import com.nowait.domainadminrdb.statistic.repository.StatisticCustomRepository;
 import com.nowait.domaincorerdb.order.entity.OrderStatus;
 import com.nowait.domaincorerdb.order.entity.UserOrder;
 import com.nowait.domaincorerdb.order.exception.OrderNotFoundException;
@@ -30,6 +31,7 @@
 @RequiredArgsConstructor
 public class OrderService {
 	private final OrderRepository orderRepository;
+	private final StatisticCustomRepository statisticCustomRepository;
 	private final UserRepository userRepository;
 	private final StoreRepository storeRepository;
 
@@ -67,7 +69,7 @@ public OrderSalesSumDetail getSaleSumByStoreId(MemberDetails memberDetails) {
 			throw new OrderViewUnauthorizedException();
 		}
 
-		return orderRepository.findSalesSumByStoreId(storeId);
+		return statisticCustomRepository.findSalesSumByStoreId(storeId);
 	}
 
 	@Transactional(readOnly = true)
@@ -79,6 +81,6 @@ public List<TopSalesStoresDetail> getTop5StoresBySalesToday(MemberDetails member
 			throw new OrderViewUnauthorizedException();
 		}
 
-		return orderRepository.getTop4PlusMine(storeId);
+		return statisticCustomRepository.getTop4PlusMine(storeId);
 	}
 }

nowait-app-admin-api/src/main/java/com/nowait/applicationadmin/statistic/controller/StatisticsController.java

@@ -0,0 +1,61 @@
+package com.nowait.applicationadmin.statistic.controller;
+
+import java.util.List;
+
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.nowait.applicationadmin.order.service.OrderService;
+import com.nowait.applicationadmin.statistic.dto.StoreRankingDto;
+import com.nowait.applicationadmin.statistic.service.RankingService;
+import com.nowait.common.api.ApiUtils;
+import com.nowait.domainadminrdb.statistic.dto.OrderSalesSumDetail;
+import com.nowait.domaincorerdb.user.entity.MemberDetails;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+
+@Tag(name = "Statistics API", description = "통계 API")
+@RestController
+@RequestMapping("/admin/statistics")
+@RequiredArgsConstructor
+public class StatisticsController {
+
+	private final OrderService orderService;
+	private final RankingService rankingService;
+
+	@GetMapping("/sales")
+	@Operation(summary = "오늘의 매출 조회", description = "오늘의 매출을 조회합니다.")
+	@ApiResponse(responseCode = "200", description = "오늘의 매출 조회 성공")
+	public ResponseEntity<?> getTodaySales(@AuthenticationPrincipal MemberDetails memberDetails) {
+		OrderSalesSumDetail sales = orderService.getSaleSumByStoreId(memberDetails);
+
+		return ResponseEntity
+			.status(HttpStatus.OK)
+			.body(
+				ApiUtils.success(
+					sales
+				)
+			);
+	}
+
+	@GetMapping("/top-sales")
+	@Operation(summary = "주점별 매출 통계 조회", description = "주점별 매출 통계를 조회합니다.")
+	@ApiResponse(responseCode = "200", description = "주점별 매출 통계 조회 성공")
+	public ResponseEntity<?> getTopSalesStores(@AuthenticationPrincipal MemberDetails memberDetails) {
+		List<StoreRankingDto> response = rankingService.getStatisticsRankings(memberDetails);
+		return ResponseEntity
+			.status(HttpStatus.OK)
+			.body(
+				ApiUtils.success(
+					response
+				)
+			);
+	}
+}

nowait-app-admin-api/src/main/java/com/nowait/applicationadmin/statistic/dto/StoreRankingDto.java

@@ -0,0 +1,25 @@
+package com.nowait.applicationadmin.statistic.dto;
+
+import lombok.Getter;
+
+@Getter
+public class StoreRankingDto {
+	private final Long   storeId;
+	private final String storeName;
+	private final Long   departmentId;
+	private final String departmentName;
+	private final Integer totalSales;
+	private final Long    currentRank;
+	private final Integer delta;
+
+	public StoreRankingDto(Long storeId, String storeName, Long departmentId, String departmentName, Integer totalSales,
+		Long currentRank, Integer delta) {
+		this.storeId = storeId;
+		this.storeName = storeName;
+		this.departmentId = departmentId;
+		this.departmentName = departmentName;
+		this.totalSales = totalSales;
+		this.currentRank = currentRank;
+		this.delta = delta;
+	}
+}

nowait-app-admin-api/src/main/java/com/nowait/applicationadmin/statistic/scheduler/RankingRefreshScheduler.java

@@ -0,0 +1,97 @@
+package com.nowait.applicationadmin.statistic.scheduler;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.core.RedisCallback;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import com.nowait.domainadminrdb.statistic.dto.StoreSales;
+import com.nowait.domainadminrdb.statistic.repository.StatisticCustomRepository;
+import com.nowait.domaincoreredis.common.util.RedisKeyUtils;
+import com.nowait.domaincoreredis.rank.repository.RankingQueryRepository;
+
+import jakarta.annotation.PostConstruct;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+
+@Component
+@RequiredArgsConstructor
+@Slf4j
+public class RankingRefreshScheduler {
+
+	private final StatisticCustomRepository statisticCustomRepository;
+	private final RankingQueryRepository rankingQueryRepository;
+	private final RedisTemplate<String, String> redis;
+
+	@PostConstruct
+	public void init() {
+		// 초기화 작업
+		refresh();
+	}
+
+	@Scheduled(cron = "0 */5 * * * *") // 매 5분마다 실행
+	public void refresh() {
+		log.info("RankingRefreshScheduler.refresh() called at {}", LocalDateTime.now());
+
+		try {
+			doRefresh();
+		} catch (Exception e) {
+			log.error("랭킹 데이터 갱신 중 오류 발생", e);
+			// 예외 발생 시 알림 또는 로깅 처리
+		}
+	}
+
+	private void doRefresh() {
+		String nextKey = RedisKeyUtils.buildNextKey();
+		String currentKey = RedisKeyUtils.buildCurrentKey();
+		String previousKey = RedisKeyUtils.buildPreviousKey();
+
+		// 1) 다음 스냅샷 키 초기화
+		redis.delete(nextKey);
+
+		// 2) DB에서 매출 합계 가져와 ZADD
+		List<StoreSales> salesList = statisticCustomRepository.findTotalSales();
+
+		if (salesList.isEmpty()) {
+			log.warn("매출 데이터가 없습니다. 다음 스냅샷 키를 초기화합니다.");
+			return;
+		}
+
+		salesList.forEach(s ->
+			rankingQueryRepository.addToRanking(nextKey, s.getStoreId(), s.getTotalSales())
+		);
+
+		// 3) 현재 스냅샷 키를 이전 스냅샷 키로 이동
+		rotateKeys(currentKey, previousKey, nextKey);
+	}
+
+	private void rotateKeys(String currentKey, String previousKey, String nextKey) {
+		try {
+			redis.execute((RedisCallback<Object>)connection -> {
+				// 현재 스냅샷 키를 이전 스냅샷 키로 이동하고, 다음 스냅샷 키를 현재 스냅샷 키로 이동
+				if (redis.hasKey(previousKey)) {
+					redis.delete(previousKey);
+				}
+				// 현재 스냅샷 키를 다음 스냅샷 키로 이동
+				if (redis.hasKey(currentKey)) {
+					redis.rename(currentKey, previousKey);
+				}
+				// 다음 스냅샷 키가 존재하면 현재 스냅샷 키로 이동
+				if (redis.hasKey(nextKey)) {
+					redis.rename(nextKey, currentKey);
+				}
+				return null;
+			});
+			log.info("Keys rotated: current -> {}, previous -> {}, next -> {}", currentKey, previousKey, nextKey);
+		} catch (Exception e) {
+			log.error("Redis 키 교체 중 오류 발생", e);
+			throw new RuntimeException("랭킹 데이터 갱신 실패", e);
+		}
+	}
+}

nowait-app-admin-api/src/main/java/com/nowait/applicationadmin/statistic/service/RankingService.java

@@ -0,0 +1,10 @@
+package com.nowait.applicationadmin.statistic.service;
+
+import java.util.List;
+
+import com.nowait.applicationadmin.statistic.dto.StoreRankingDto;
+import com.nowait.domaincorerdb.user.entity.MemberDetails;
+
+public interface RankingService {
+	List<StoreRankingDto> getStatisticsRankings(MemberDetails memberDetails);
+}

nowait-app-admin-api/src/main/java/com/nowait/applicationadmin/statistic/service/impl/RankingServiceImpl.java

@@ -0,0 +1,75 @@
+package com.nowait.applicationadmin.statistic.service.impl;
+
+import java.util.List;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.nowait.applicationadmin.statistic.dto.StoreRankingDto;
+import com.nowait.applicationadmin.statistic.service.RankingService;
+import com.nowait.common.enums.Role;
+import com.nowait.domainadminrdb.statistic.dto.StoreInfo;
+import com.nowait.domainadminrdb.statistic.exception.StatisticViewUnauthorizedException;
+import com.nowait.domainadminrdb.statistic.repository.StatisticCustomRepository;
+import com.nowait.domaincorerdb.user.entity.MemberDetails;
+import com.nowait.domaincorerdb.user.entity.User;
+import com.nowait.domaincorerdb.user.exception.UserNotFoundException;
+import com.nowait.domaincorerdb.user.repository.UserRepository;
+import com.nowait.domaincoreredis.rank.dto.RankingEntry;
+import com.nowait.domaincoreredis.rank.service.RankingQueryService;
+
+import lombok.RequiredArgsConstructor;
+
+@Service
+@RequiredArgsConstructor
+public class RankingServiceImpl implements RankingService {
+
+	private final StatisticCustomRepository statisticCustomRepository;
+	private final UserRepository userRepository;
+	private final RankingQueryService rankingQuery;
+
+
+	@Override
+	@Transactional(readOnly = true)
+	public List<StoreRankingDto> getStatisticsRankings(MemberDetails memberDetails) {
+		User user = userRepository.findById(memberDetails.getId()).orElseThrow(UserNotFoundException::new);
+		Long userStoreId = user.getStoreId();
+
+		if (!Role.SUPER_ADMIN.equals(user.getRole()) && !user.getStoreId().equals(userStoreId)) {
+			throw new StatisticViewUnauthorizedException();
+		}
+
+		// 1) Redis에서 Top4+내주점: storeId, totalSales, currentRank, delta
+		List<RankingEntry> entries = rankingQuery.getRankings(userStoreId, 5);
+
+		// 2) DB에서 store 정보 가져오기
+		List<Long> storeIds = entries.stream()
+			.map(RankingEntry::getStoreId)
+			.toList();
+
+		List<StoreInfo> infos = statisticCustomRepository.findStoreInfoByIds(storeIds);
+
+		// StoreInfo를 storeId로 매핑
+		Map<Long, StoreInfo> infoMap = infos.stream()
+			.collect(Collectors.toMap(StoreInfo::getStoreId, Function.identity()));
+
+		// 3) 매핑 → 최종 DTO
+		return entries.stream()
+			.map(e -> {
+				StoreInfo info = infoMap.get(e.getStoreId());
+				return new StoreRankingDto(
+					e.getStoreId(),
+					info.getStoreName(),
+					info.getDepartmentId(),
+					info.getDepartmentName(),
+					e.getTotalSales(),
+					e.getCurrentRank(),
+					e.getDelta()
+				);
+			})
+			.collect(Collectors.toList());
+	}
+}

nowait-common/src/main/java/com/nowait/common/exception/ErrorMessage.java

@@ -50,7 +50,6 @@ public enum ErrorMessage {
 	STORE_WAITING_DISABLED("해당 주점은 대기 비활성화된 주점입니다.", "store006"),
 
 	// storePayment
-
 	STORE_PAYMENT_PARAMETER_EMPTY("주점 결제 생성 시 파라미터 정보가 없습니다.", "storePayment001"),
 	STORE_PAYMENT_NOT_FOUND("해당 주점 결제 정보를 찾을 수 없습니다.", "storePayment002"),
 	STORE_PAYMENT_VIEW_UNAUTHORIZED("주점 결제 정보 보기 권한이 없습니다.(슈퍼계정 or 주점 관리자만 가능)", "storePayment003"),
@@ -59,6 +58,8 @@ public enum ErrorMessage {
 	STORE_PAYMENT_DELETE_UNAUTHORIZED("주점 결제 정보 삭제 권한이 없습니다.(슈퍼계정 or 주점 관리자만 가능)", "storePayment005"),
 	STORE_PAYMENT_ALREADY_EXISTS("이미 존재하는 주점 결제 정보입니다.", "storePayment006"),
 
+	// Statistics
+	STATISTIC_VIEW_UNAUTHORIZED("통계 보기 권한이 없습니다.(슈퍼계정 or 주점 관리자만 가능)", "statistics001"),
 
 	// image
 	IMAGE_FILE_EMPTY("이미지 파일을 업로드 해주세요", "image001"),