feat: 대기열 도메인 나를 포함한 상위인원 모두 입장처리하는 테스트 API 추가

Author: kimeunkyoungg

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

@@ -75,4 +75,18 @@ ApiResponse<ProcessEntriesResponse> processUntilMe(
 		@Parameter(description = "이벤트 ID", example = "1")
 		@PathVariable Long eventId
 	);
+
+	@Operation(
+		summary = "[테스트용] 나를 포함한 앞 사용자 모두 입장 처리",
+		description = "나를 포함하여 내 앞에 있는 모든 사용자들을 입장 처리합니다."
+	)
+	@ApiErrorCode({
+		"NOT_FOUND_QUEUE_ENTRY",
+		"NOT_WAITING_STATUS",
+		"NOT_INVALID_COUNT"
+	})
+	ApiResponse<ProcessEntriesResponse> processIncludingMe(
+		@Parameter(description = "이벤트 ID", example = "1")
+		@PathVariable Long eventId
+	);
 }

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

@@ -81,4 +81,19 @@ public ApiResponse<ProcessEntriesResponse> processUntilMe(
 		return ApiResponse.ok("내 앞 사용들이 모두 입장 처리가 완료되었습니다.", response);
 	}
 
+	@Override
+	@PostMapping("/{eventId}/process-include-me")
+	public ApiResponse<ProcessEntriesResponse> processIncludingMe(
+		@PathVariable Long eventId
+	) {
+		Long userId = httpRequestContext.getUserId();
+
+		ProcessEntriesResponse response = queueEntryProcessService.processTopEntriesIncludingMeForTest(
+			eventId,
+			userId
+		);
+
+		return ApiResponse.ok("나를 포함한 내 앞 사용들이 모두 입장 처리가 완료되었습니다.", response);
+	}
+
 }

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

@@ -236,6 +236,48 @@ public ProcessEntriesResponse processTopEntriesUntilMeForTest(Long eventId, Long
 		return ProcessEntriesResponse.from(eventId, userIds.size(), remainingCount);
 	}
 
+	/* ==================== 테스트용 내 앞에 사람 + 나까지 모두 입장 처리 ==================== */
+	@Transactional
+	public ProcessEntriesResponse processTopEntriesIncludingMeForTest(Long eventId, Long userId) {
+
+		QueueEntry myEntry = queueEntryRepository.findByEvent_IdAndUser_Id(eventId, userId)
+			.orElseThrow(() -> new ErrorException(QueueEntryErrorCode.NOT_FOUND_QUEUE_ENTRY));
+
+		if (myEntry.getQueueEntryStatus() != QueueEntryStatus.WAITING) {
+			throw new ErrorException(QueueEntryErrorCode.NOT_WAITING_STATUS);
+		}
+
+		Long myRank = queueEntryRedisRepository.getMyRankInWaitingQueue(eventId, userId);
+
+		if (myRank == null) {
+			throw new ErrorException(QueueEntryErrorCode.NOT_FOUND_QUEUE_ENTRY);
+		}
+
+		// 나를 포함한 입장 처리 (나의 순위만큼 처리)
+		int countToProcess = myRank.intValue();
+
+		Set<Object> topWaitingUsers = queueEntryRedisRepository.getTopWaitingUsers(eventId, countToProcess);
+
+		if (topWaitingUsers.isEmpty()) {
+			throw new ErrorException(QueueEntryErrorCode.NOT_INVALID_COUNT);
+		}
+
+		List<Long> userIds = new ArrayList<>();
+		for (Object userIdObj : topWaitingUsers) {
+			userIds.add(Long.parseLong(userIdObj.toString()));
+		}
+
+		if (userIds.isEmpty()) {
+			return ProcessEntriesResponse.from(eventId, 0,
+				queueEntryRedisRepository.getTotalWaitingCount(eventId));
+		}
+
+		processBatchEntry(eventId, userIds);
+		publishWaitingUpdateEvents(eventId);
+
+		Long remainingCount = queueEntryRedisRepository.getTotalWaitingCount(eventId);
+		return ProcessEntriesResponse.from(eventId, userIds.size(), remainingCount);
+	}
 
 	/* ==================== 만료 처리 ==================== */