refactor: 대기열 redis->db 롤백 로직, 사용자 대기열 상태 확인 로직 리팩토링

* refactor: /{eventId}/exists entered만 확인하도록 변경

* refactor: redis->db 로직 수정

* feat: 로그인/회원가입 기본 데이터 세팅

* refactor: isUserEntered 로직 수정

* refactor: 스케줄러 롤백

Author: kimeunkyoungg

backend/src/main/java/com/back/api/auth/dto/request/LoginRequest.java

@@ -10,10 +10,18 @@ public record LoginRequest(
 	@NotBlank(message = "이메일을 입력해주세요.")
 	@Email(message = "이메일 형식이 올바르지 않습니다.")
 	@Size(max = 100)
+	@Schema(
+		description = "이메일",
+		example = "test@test.com"
+	)
 	String email,
 
 	@NotBlank(message = "비밀번호를 입력해주세요.")
 	@Size(min = 8, max = 30, message = "비밀번호는 8~30 글자여야 합니다.")
+	@Schema(
+		description = "비밀번호",
+		example = "abc12345"
+	)
 	String password
 ) {
 }

backend/src/main/java/com/back/api/auth/dto/request/SignupRequest.java

@@ -13,10 +13,18 @@ public record SignupRequest(
 	@NotBlank(message = "이메일은 필수입니다.")
 	@Email(message = "이메일 형식이 올바르지 않습니다.")
 	@Size(max = 100)
+	@Schema(
+		description = "이메일",
+		example = "test@test.com"
+	)
 	String email,
 
 	@NotBlank(message = "비밀번호는 필수입니다.")
 	@Size(min = 8, max = 30, message = "비밀번호는 8~30 글자여야 합니다.")
+	@Schema(
+		description = "비밀번호",
+		example = "abc12345"
+	)
 	String password,
 
 	@NotBlank(message = "이름은 필수입니다.")

backend/src/main/java/com/back/api/auth/dto/response/UserResponse.java

@@ -14,7 +14,7 @@ public record UserResponse(
 
 	@Schema(
 		description = "사용자 이메일",
-		example = "user@example.com",
+		example = "test@test.com",
 		maxLength = 100
 	)
 	String email,

backend/src/main/java/com/back/api/queue/controller/QueueEntryApi.java

@@ -32,8 +32,8 @@ ApiResponse<QueueEntryStatusResponse> getMyQueueEntryStatus(
 
 
 	@Operation(
-		summary = "대기열 진입 여부 조회",
-		description = "사용자가 특정 이벤트의 대기열에 진입했는지 조회합니다."
+		summary = "대기열 입장 완료 여부 조회",
+		description = "사용자가 특정 이벤트의 대기열에 입장했는지 조회합니다.(ENTERED)"
 	)
 	ApiResponse<Boolean> existsInQueue(
 		@Parameter(description = "이벤트 ID", example = "1")

backend/src/main/java/com/back/api/queue/controller/QueueEntryController.java

@@ -45,8 +45,8 @@ public ApiResponse<Boolean> existsInQueue(
 		@PathVariable Long eventId
 	) {
 		Long userId = httpRequestContext.getUserId();
-		boolean exists = queueEntryReadService.existsInWaitingQueue(eventId, userId);
-		return ApiResponse.ok("대기열 진입 여부를 확인했습니다.", exists);
+		boolean exists = queueEntryReadService.isUserEntered(eventId, userId);
+		return ApiResponse.ok("대기열 입장 완료 여부를 확인했습니다.(ENTERED)", exists);
 	}
 
 	@Override

backend/src/main/java/com/back/api/queue/scheduler/QueueShuffleScheduler.java

@@ -36,7 +36,7 @@ public class QueueShuffleScheduler {
 	private final QueueEntryRepository queueEntryRepository;
 	private final QueueShuffleService queueShuffleService;
 	private final EventService eventService;
-	private final PreRegisterRepository preRegisterRepository; //TODO service로 변경 필요
+	private final PreRegisterRepository preRegisterRepository;
 	private final QueueSchedulerProperties properties;
 
 	@Scheduled(cron = "${queue.scheduler.shuffle.cron}", zone = "Asia/Seoul")
@@ -149,7 +149,6 @@ private boolean shuffleQueueForEvent(Event event) {
 			return false;
 		}
 
-		//TODO PreRegisterService로 변경 필요
 		List<Long> preRegisteredUserIds = preRegisterRepository.findRegisteredUserIdsByEventId(eventId);
 
 		if (preRegisteredUserIds.isEmpty()) {

backend/src/main/java/com/back/api/queue/service/QueueEntryProcessService.java

@@ -35,7 +35,7 @@
 /*
  * 대기열 처리 로직
  * QueueEntry 입장 처리
- * 스케줄러, 배치 활용
+ * 스케줄러 활용
  * 대기중 -> 입장 완료
  */
 
@@ -91,22 +91,98 @@ public void processBatchEntry(Long eventId, List<Long> userIds) {
 		}
 	}
 
-	/* ==================== 이벤트 단위 자동 입장 처리 (스케줄러) ==================== */
+	/*
+	Redis에만 의존. Redis + DB 로직으로 수정했으나 주석처리 보관
+	 */
+	// @Transactional
+	// public void processEventQueueEntries(Event event) {
+	//
+	// 	Long eventId = event.getId();
+	//
+	// 	//대기 중인 인원 확인
+	// 	Long totalWaitingCount = queueEntryRedisRepository.getTotalWaitingCount(eventId);
+	//
+	// 	if (totalWaitingCount == 0) {
+	// 		return;
+	// 	}
+	//
+	// 	//입장 완료된 인원 확인
+	// 	Long currentEnteredCount = queueEntryRedisRepository.getTotalEnteredCount(eventId);
+	// 	int maxEnteredLimit = properties.getEntry().getMaxEnteredLimit();
+	//
+	// 	//입장 가능한 인원 확인
+	// 	int availableEnteredCount = maxEnteredLimit - currentEnteredCount.intValue();
+	//
+	// 	if (availableEnteredCount <= 0) {
+	// 		log.info("[EventId: {}] 최대 수용 인원 도달 - 현재: {}명, 최대: {}명",
+	// 			eventId, currentEnteredCount, maxEnteredLimit);
+	// 		return;
+	// 	}
+	//
+	// 	//한번에 입장시킬 인원
+	// 	int batchSize = properties.getEntry().getBatchSize();
+	//
+	// 	// 입장 인원 선정
+	// 	// 빈 자리 순차적으로 들어갈 수 있도록 함
+	// 	int entryCount = Math.min(
+	// 		batchSize,
+	// 		Math.min(availableEnteredCount, totalWaitingCount.intValue())  // 빈 자리와 대기 인원 중 작은 값
+	// 	);
+	//
+	// 	log.info("입장 처리 - eventId: {}, 대기: {}명, 입장완료: {}명, 빈자리: {}명, 배치사이즈: {}명, 입장시킬인원: {}명",
+	// 		eventId, totalWaitingCount, currentEnteredCount, availableEnteredCount, batchSize, entryCount);
+	//
+	//
+	// 	//상위 N명 추출
+	// 	Set<Object> topWaitingUsers = queueEntryRedisRepository.getTopWaitingUsers(eventId, entryCount);
+	//
+	// 	if (topWaitingUsers.isEmpty()) {
+	// 		return;
+	// 	}
+	//
+	// 	List<Long> userIds = new ArrayList<>();
+	// 	for (Object userId : topWaitingUsers) {
+	// 		userIds.add(Long.parseLong(userId.toString()));
+	// 	}
+	//
+	// 	processBatchEntry(eventId, userIds); // 입장 순서인 사용자 입장처리
+	//
+	// 	publishWaitingUpdateEvents(eventId); // 대기중인 사용자 실시간 순위 업데이트
+	//
+	// }
 
+	/* ==================== 이벤트 단위 자동 입장 처리 (스케줄러) ==================== */
+	// Redis + DB
 	@Transactional
 	public void processEventQueueEntries(Event event) {
 
 		Long eventId = event.getId();
 
 		//대기 중인 인원 확인
-		Long totalWaitingCount = queueEntryRedisRepository.getTotalWaitingCount(eventId);
+		Long totalWaitingCount;
+
+		try {
+			totalWaitingCount =  queueEntryRedisRepository.getTotalWaitingCount(eventId);
+		} catch (Exception e) {
+			log.warn("Redis 조회 실패, DB로부터 대기 중 인원 수 조회 시도 - eventId: {}", eventId,  e);
+			totalWaitingCount = queueEntryRepository.countByEvent_IdAndQueueEntryStatus(eventId, QueueEntryStatus.WAITING);
+		}
 
 		if (totalWaitingCount == 0) {
 			return;
 		}
 
 		//입장 완료된 인원 확인
-		Long currentEnteredCount = queueEntryRedisRepository.getTotalEnteredCount(eventId);
+		Long currentEnteredCount;
+
+		try {
+			currentEnteredCount = queueEntryRedisRepository.getTotalEnteredCount(eventId);
+		} catch (Exception e) {
+			log.warn("Redis 조회 실패, DB로부터 입장 완료된 인원 수 조회 시도 - eventId: {}", eventId,  e);
+			currentEnteredCount = queueEntryRepository.countByEvent_IdAndQueueEntryStatus(eventId, QueueEntryStatus.ENTERED);
+		}
+
+
 		int maxEnteredLimit = properties.getEntry().getMaxEnteredLimit();
 
 		//입장 가능한 인원 확인
@@ -132,16 +208,20 @@ public void processEventQueueEntries(Event event) {
 			eventId, totalWaitingCount, currentEnteredCount, availableEnteredCount, batchSize, entryCount);
 
 
-		//상위 N명 추출
-		Set<Object> topWaitingUsers = queueEntryRedisRepository.getTopWaitingUsers(eventId, entryCount);
 
-		if (topWaitingUsers.isEmpty()) {
-			return;
+		List<Long> userIds;
+		try {
+			Set<Object> topWaitingUsers = queueEntryRedisRepository.getTopWaitingUsers(eventId, entryCount);
+			userIds = topWaitingUsers.stream()
+				.map(obj -> Long.parseLong(obj.toString()))
+				.toList();
+		} catch (Exception e) {
+			log.warn("Redis 조회 실패, DB로부터 상위 대기 인원 조회 시도 - eventId: {}", eventId,  e);
+			userIds = queueEntryRepository.findTopNWaitingUsers(eventId, entryCount);
 		}
 
-		List<Long> userIds = new ArrayList<>();
-		for (Object userId : topWaitingUsers) {
-			userIds.add(Long.parseLong(userId.toString()));
+		if (userIds.isEmpty()) {
+			return;
 		}
 
 		processBatchEntry(eventId, userIds); // 입장 순서인 사용자 입장처리
@@ -332,7 +412,7 @@ public void expireBatchEntries(List<QueueEntry> entries) {
 
 	/* ==================== 결제 완료 처리 ==================== */
 
-	//TODO 결제 도메인에서 사용 필요
+
 	@Transactional
 	public void completePayment(Long eventId, Long userId) {
 

backend/src/main/java/com/back/api/queue/service/QueueEntryReadService.java

@@ -22,7 +22,6 @@
 /*
  * 대기열 조회 로직
  * Redis 우선 조회 -> DB 조회
- * 트랜잭션 읽기 / 쓰기 분리 고려
  * TODO 시간 계산 로직 수정
  */
 @Service
@@ -115,8 +114,20 @@ public boolean existsInWaitingQueue(Long eventId, Long userId) {
 	//Redis & DB
 	public boolean isUserEntered(Long eventId, Long userId) {
 		try {
-			return queueEntryRedisRepository.isInEnteredQueue(eventId, userId);
+			boolean isInRedis = queueEntryRedisRepository.isInEnteredQueue(eventId, userId);
+
+			if (isInRedis) {
+				return true;
+			}
+
+			//Redis false면 DB 한번 더 확인
+			return queueEntryRepository
+				.findByEvent_IdAndUser_Id(eventId, userId)
+				.map(entry -> entry.getQueueEntryStatus() == QueueEntryStatus.ENTERED)
+				.orElse(false);
+
 		} catch (Exception e) {
+			// Redis 예외 시 DB 조회
 			log.warn("Redis ENTERED 조회 실패, DB Fallback");
 
 			return queueEntryRepository

backend/src/main/java/com/back/api/queue/service/QueueShuffleService.java

@@ -59,8 +59,6 @@ public void shuffleQueue(Long eventId, List<Long> preRegisteredUserIds) {
 
 		event.changeStatus(EventStatus.QUEUE_READY);
 
-		//TODO 알림 로직 추가 필요
-
 	}
 
 	private void validateShuffleRequest(Long eventId, List<Long> preRegisteredUserIds) {

backend/src/main/java/com/back/api/user/dto/response/UserProfileResponse.java

@@ -13,7 +13,7 @@ public record UserProfileResponse(
 	Long userId,
 	@Schema(
 		description = "사용자 이메일",
-		example = "user@example.com",
+		example = "test@test.com",
 		maxLength = 100
 	)
 	String email,