feat: 투표 리워드 시스템 구현 (#175)

src/main/java/hanium/modic/backend/common/property/property/VoteProperties.java

@@ -15,4 +15,19 @@ public class VoteProperties {
 	private int humanVoteWeight;
 	private Boolean enableAiAssessment;
 	private int maxVotesPerUserPerDay;
+
+	/**
+	 * 연속 정답 리워드 지급 기준 횟수 (기본값 3)
+	 */
+	private int streakRewardCount = 3;
+
+	/**
+	 * 연속 정답 카운트 TTL (일, 기본값 30)
+	 */
+	private int streakTtlDays = 30;
+
+	/**
+	 * 리워드 지급 시 증가하는 티켓 수 (기본값 1)
+	 */
+	private int rewardTicketCount = 1;
 }

src/main/java/hanium/modic/backend/common/redis/distributedLock/LockManager.java

@@ -29,6 +29,7 @@ public class LockManager {
 	private final String POST_LIKE_PREFIX = "lock:postlike:";
 	private final String AI_PERMISSION_PREFIX = "lock:ai:perm:";
 	private final String VOTE_SUMMARY_PREFIX = "lock:vote:summary:";
+	private final String VOTE_STREAK_PREFIX = "lock:vote:streak:";
 
 	public void userLock(long userId, Runnable block) throws LockException {
 		exec.withLock(USER_PREFIX + userId, block);
@@ -58,4 +59,8 @@ public void aiImagePermissionLock(long userId, long postId, Runnable block) thro
 	public void voteSummaryLock(long voteId, Runnable block) throws LockException {
 		exec.withLock(VOTE_SUMMARY_PREFIX + voteId, block);
 	}
+
+	public void voteStreakLock(long userId, Runnable block) throws LockException {
+		exec.withLock(VOTE_STREAK_PREFIX + userId, block);
+	}
 }

src/main/java/hanium/modic/backend/domain/ticket/entity/TicketEntity.java

@@ -58,6 +58,15 @@ public void resetTickets() {
 		this.lastIssuedAt = LocalDateTime.now();
 	}
 
+	// 리워드 티켓 지급 (발급 시간은 변경하지 않음)
+	public void increaseTicket(final long amount) {
+		if (amount <= 0) {
+			return;
+		}
+
+		this.ticketCount += amount;
+	}
+
 	public boolean isTicketExpired() {
 		return LocalDateTime.now().isAfter(this.lastIssuedAt.plusDays(1));
 	}

src/main/java/hanium/modic/backend/domain/ticket/service/TicketService.java

@@ -8,6 +8,7 @@
 import hanium.modic.backend.common.error.exception.AppException;
 import hanium.modic.backend.common.error.exception.LockException;
 import hanium.modic.backend.common.redis.distributedLock.LockManager;
+import hanium.modic.backend.common.property.property.VoteProperties;
 import hanium.modic.backend.domain.ticket.entity.TicketEntity;
 import hanium.modic.backend.domain.ticket.repository.TicketRepository;
 import hanium.modic.backend.web.ticket.dto.response.GetTicketInformationResponse;
@@ -19,6 +20,7 @@ public class TicketService {
 
 	private final TicketRepository ticketRepository;
 	private final LockManager lockManager;
+    private final VoteProperties voteProperties;
 
 	// 티켓 관련 정보 조회
 	public GetTicketInformationResponse getTicketInformation(Long userId) {
@@ -77,4 +79,18 @@ public TicketEntity createInitialTicket(Long userId) {
 
 		return ticketRepository.save(newUserTicket);
 	}
+
+	// 리워드 티켓 지급
+	@Transactional
+	public void giveRewardTicket(final long userId) {
+		try {
+			lockManager.aiRequestTicketLock(userId, () -> {
+				TicketEntity userTicket = getTicketEntity(userId);
+                userTicket.increaseTicket(voteProperties.getRewardTicketCount());
+				ticketRepository.save(userTicket);
+			});
+		} catch (LockException e) {
+			throw new AppException(AI_REQUEST_TICKET_PROCESSING_FAIL_EXCEPTION);
+		}
+	}
 }

src/main/java/hanium/modic/backend/domain/user/entity/UserVoteStreak.java

@@ -0,0 +1,35 @@
+package hanium.modic.backend.domain.user.entity;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.redis.core.RedisHash;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Builder
+@RedisHash(value = "userVoteStreak", timeToLive = 60 * 60 * 24 * 7) // 7 days TTL
+@NoArgsConstructor
+@AllArgsConstructor
+public class UserVoteStreak {
+
+	@Id
+	private Long userId;
+
+	@Builder.Default
+	private Integer streakCount = 0;
+
+	public void updateStreak(boolean isCorrect) {
+		this.streakCount = isCorrect ? this.streakCount + 1 : 0;
+	}
+
+	public void resetStreak() {
+		this.streakCount = 0;
+	}
+
+	public boolean shouldReceiveReward(int rewardThreshold) {
+		return this.streakCount >= rewardThreshold;
+	}
+}

src/main/java/hanium/modic/backend/domain/user/repository/UserVoteStreakRepository.java

@@ -0,0 +1,10 @@
+package hanium.modic.backend.domain.user.repository;
+
+import org.springframework.data.repository.CrudRepository;
+import org.springframework.stereotype.Repository;
+
+import hanium.modic.backend.domain.user.entity.UserVoteStreak;
+
+@Repository
+public interface UserVoteStreakRepository extends CrudRepository<UserVoteStreak, Long> {
+}

src/main/java/hanium/modic/backend/domain/user/service/UserVoteStreakService.java

@@ -0,0 +1,56 @@
+package hanium.modic.backend.domain.user.service;
+
+import org.springframework.stereotype.Service;
+
+import hanium.modic.backend.common.error.exception.LockException;
+import hanium.modic.backend.common.property.property.VoteProperties;
+import hanium.modic.backend.common.redis.distributedLock.LockManager;
+import hanium.modic.backend.domain.user.entity.UserVoteStreak;
+import hanium.modic.backend.domain.user.repository.UserVoteStreakRepository;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class UserVoteStreakService {
+
+	private final UserVoteStreakRepository streakRepository;
+	private final LockManager lockManager;
+	private final VoteProperties voteProperties;
+
+	public int getStreakCount(Long userId) {
+		return streakRepository.findById(userId)
+			.map(UserVoteStreak::getStreakCount)
+			.orElse(0);
+	}
+
+	public void updateStreakWithReset(Long userId, boolean isCorrect) {
+		try {
+			lockManager.voteStreakLock(userId, () -> {
+				UserVoteStreak streak = getOrCreateStreak(userId);
+				int currentStreak = streak.getStreakCount();
+				streak.updateStreak(isCorrect);
+
+				// 3연속 정답 달성 시 초기화
+				if (isCorrect && streak.getStreakCount() >= voteProperties.getStreakRewardCount()) {
+					streak.resetStreak();
+				}
+
+				streakRepository.save(streak);
+				log.debug("연속 정답 업데이트 (리셋 포함): userId={}, current={}, next={}, isCorrect={}",
+					userId, currentStreak, streak.getStreakCount(), isCorrect);
+			});
+		} catch (LockException e) {
+			log.error("투표 연속 정답 업데이트 (리셋 포함) 락 실패: userId={}", userId, e);
+			throw new RuntimeException("투표 연속 정답 업데이트에 실패했습니다.", e);
+		}
+	}
+
+	private UserVoteStreak getOrCreateStreak(Long userId) {
+		return streakRepository.findById(userId)
+			.orElse(UserVoteStreak.builder().userId(userId).build());
+	}
+}
+
+

src/main/java/hanium/modic/backend/domain/vote/service/VoteRewardResult.java

@@ -0,0 +1,4 @@
+package hanium.modic.backend.domain.vote.service;
+
+public record VoteRewardResult(boolean isCorrectAnswer, int currentStreak, boolean receivedTicket) {
+}

src/main/java/hanium/modic/backend/domain/vote/service/VoteRewardService.java

@@ -0,0 +1,73 @@
+package hanium.modic.backend.domain.vote.service;
+
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import hanium.modic.backend.common.error.exception.AppException;
+import hanium.modic.backend.common.property.property.VoteProperties;
+import hanium.modic.backend.domain.user.service.UserVoteStreakService;
+import hanium.modic.backend.domain.ticket.service.TicketService;
+import hanium.modic.backend.domain.vote.entity.SimilarityVoteSummaryEntity;
+import hanium.modic.backend.domain.vote.enums.VoteDecision;
+import hanium.modic.backend.domain.vote.repository.SimilarityVoteSummaryRepository;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+import static hanium.modic.backend.common.error.ErrorCode.*;
+
+@Service
+@RequiredArgsConstructor
+@Transactional(readOnly = true)
+@Slf4j
+public class VoteRewardService {
+
+	private final SimilarityVoteSummaryRepository voteSummaryRepository;
+	private final UserVoteStreakService userVoteStreakService;
+	private final VoteProperties voteProperties;
+	private final TicketService ticketService;
+
+	public VoteDecision analyzeTrend(Long voteId) {
+		SimilarityVoteSummaryEntity summary = voteSummaryRepository.findByVoteId(voteId)
+			.orElseThrow(() -> new AppException(VOTE_SUMMARY_NOT_FOUND_EXCEPTION));
+
+		Long approveWeight = summary.getApproveWeight();
+		Long denyWeight = summary.getDenyWeight();
+
+		return approveWeight >= denyWeight ? VoteDecision.APPROVE : VoteDecision.DENY;
+	}
+
+	public boolean isCorrectAnswer(VoteDecision userDecision, VoteDecision trend) {
+		return userDecision == trend;
+	}
+
+	@Transactional
+	public VoteRewardResult processVoteReward(Long voteId, Long userId, VoteDecision userDecision) {
+		try {
+			VoteDecision trend = analyzeTrend(voteId);
+			boolean isCorrect = isCorrectAnswer(userDecision, trend);
+			// streak 업데이트 전 현재 값 확인
+			int currentStreak = userVoteStreakService.getStreakCount(userId);
+			boolean willReceiveReward = isCorrect && (currentStreak + 1) >= voteProperties.getStreakRewardCount();
+
+			// streak 업데이트 (3연속 정답 시 자동 초기화 포함)
+			userVoteStreakService.updateStreakWithReset(userId, isCorrect);
+
+			boolean receivedTicket = false;
+			if (willReceiveReward) {
+				ticketService.giveRewardTicket(userId);
+				receivedTicket = true;
+			}
+
+			// 업데이트 후 streak 값 (리워드 받았으면 0, 아니면 업데이트된 값)
+			int finalStreak = willReceiveReward ? 0 : userVoteStreakService.getStreakCount(userId);
+			log.info("투표 리워드 처리 완료: voteId={}, userId={}, userDecision={}, trend={}, isCorrect={}",
+				voteId, userId, userDecision, trend, isCorrect);
+			return new VoteRewardResult(isCorrect, finalStreak, receivedTicket);
+		} catch (Exception e) {
+			log.error("투표 리워드 처리 중 오류 발생: voteId={}, userId={}", voteId, userId, e);
+			return new VoteRewardResult(false, userVoteStreakService.getStreakCount(userId), false);
+		}
+	}
+}
+
+

src/main/java/hanium/modic/backend/domain/vote/service/VotingService.java

@@ -43,6 +43,7 @@ public class VotingService {
 	private final PostEntityRepository postEntityRepository;
 	private final LockManager lockManager;
 	private final VoteProperties voteProperties;
+	private final VoteRewardService voteRewardService;
 
 	/**
 	 * 투표 참여 메서드
@@ -92,8 +93,16 @@ public VoteParticipationResponse participateVote(Long voteId, Long userId, VoteD
 				checkAndCompleteVote(voteId);
 			});
 
-			// 9. 단순한 응답 생성
-			return VoteParticipationResponse.of(voteId);
+			// 9. 리워드 처리 (투표 참여 직후)
+			VoteRewardResult reward = voteRewardService.processVoteReward(voteId, userId, decision);
+
+			// 10. 응답 생성
+			return VoteParticipationResponse.of(
+				voteId,
+				reward.isCorrectAnswer(),
+				reward.currentStreak(),
+				reward.receivedTicket()
+			);
 		} catch (LockException e) {
 			log.error("투표 참여 락 획득 실패: voteId={}, userId={}", voteId, userId, e);
 			throw new AppException(VOTE_UPDATE_FAIL_EXCEPTION);

src/main/java/hanium/modic/backend/web/vote/dto/response/VoteParticipationResponse.java

@@ -1,8 +1,10 @@
 package hanium.modic.backend.web.vote.dto.response;
 
-public record VoteParticipationResponse(Long voteId) {
-
-	public static VoteParticipationResponse of(Long voteId) {
-		return new VoteParticipationResponse(voteId);
+public record VoteParticipationResponse(Long voteId, boolean isCorrectAnswer, int currentStreak,
+										boolean receivedTicket) {
+
+	public static VoteParticipationResponse of(Long voteId, boolean isCorrectAnswer, int currentStreak,
+		boolean receivedTicket) {
+		return new VoteParticipationResponse(voteId, isCorrectAnswer, currentStreak, receivedTicket);
 	}
 }