✨ feat: AI 파생 이미지 유사성 판단 투표 시스템 구현

build.gradle

@@ -21,6 +21,22 @@ configurations {
 
 repositories {
     mavenCentral()
+    maven { url "https://repo.spring.io/milestone" }
+    maven { url "https://repo.spring.io/snapshot" }
+}
+
+// 의존성 버전 강제 고정
+configurations.all {
+    resolutionStrategy {
+        // AWS SDK v2 및 다른 라이브러리 버전을 강제 고정하여 잠재적 충돌 방지
+        force 'software.amazon.awssdk:cloudfront:2.26.14',
+                'software.amazon.awssdk:s3:2.26.14',
+                'software.amazon.awssdk:url-signer:2.26.14'
+        force 'io.jsonwebtoken:jjwt-api:0.12.5'
+        force "io.swagger.core.v3:swagger-annotations-jakarta:2.2.36"
+        force "io.swagger.core.v3:swagger-core-jakarta:2.2.36"
+        force "io.swagger.core.v3:swagger-models-jakarta:2.2.36"
+    }
 }
 
 dependencies {
@@ -33,40 +49,46 @@ dependencies {
     runtimeOnly 'com.h2database:h2'
     runtimeOnly 'com.mysql:mysql-connector-j'
     annotationProcessor 'org.projectlombok:lombok'
-    implementation 'com.google.guava:guava:30.1.1-jre'
+    implementation 'com.google.guava:guava:33.2.1-jre'
 
     // test
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
     testImplementation 'org.springframework.security:spring-security-test'
     testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
 
-    //s3
-    implementation 'org.springframework.cloud:spring-cloud-starter-aws:2.2.6.RELEASE'
-    implementation 'com.amazonaws:aws-java-sdk-cloudfront:1.12.772'
+    // AWS SDK v2 (버전은 resolutionStrategy로 관리)
+    implementation 'software.amazon.awssdk:s3'
+    implementation 'software.amazon.awssdk:cloudfront'
+
     //swagger
-    implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.8.6'
+    implementation("org.springdoc:springdoc-openapi-starter-webmvc-ui:2.8.12") {
+        exclude group: "io.swagger.core.v3", module: "swagger-annotations"
+    }
 
     implementation 'io.jsonwebtoken:jjwt-api:0.11.5'
     runtimeOnly 'io.jsonwebtoken:jjwt-impl:0.11.5'
     runtimeOnly 'io.jsonwebtoken:jjwt-jackson:0.11.5'
 
-    implementation 'jakarta.xml.bind:jakarta.xml.bind-api:4.0.0'
-    runtimeOnly 'org.glassfish.jaxb:jaxb-runtime:4.0.3'
+    implementation 'jakarta.xml.bind:jakarta.xml.bind-api:4.0.2'
+    runtimeOnly 'org.glassfish.jaxb:jaxb-runtime:4.0.5'
 
     implementation 'org.springframework.boot:spring-boot-starter-mail'
 
     implementation 'org.springframework.boot:spring-boot-starter-data-redis'
-    // Amqp
-    implementation 'org.springframework.boot:spring-boot-starter-amqp:3.4.2'
+    // Amqp (버전은 Spring Boot가 관리)
+    implementation 'org.springframework.boot:spring-boot-starter-amqp'
     // Redisson(Redis Client)
-    implementation 'org.redisson:redisson-spring-boot-starter:3.27.2'
-    // OAuth
-    implementation 'org.springframework.boot:spring-boot-starter-oauth2-client:3.5.0'
+    implementation 'org.redisson:redisson-spring-boot-starter:3.32.0'
+    // OAuth (버전은 Spring Boot가 관리)
+    implementation 'org.springframework.boot:spring-boot-starter-oauth2-client'
     // metric
     implementation("org.springframework.boot:spring-boot-starter-actuator")
-    implementation("io.micrometer:micrometer-registry-cloudwatch2")
+    implementation("io.micrometer:micrometer-registry-cloudwatch2:1.13.4")
+
+    // webClient용 라이브러리, WebFlux 사용x
+    implementation 'org.springframework.boot:spring-boot-starter-webflux'
 }
 
 tasks.named('test') {
     useJUnitPlatform()
-}
+}

gradle/wrapper/gradle-wrapper.properties

@@ -1,6 +1,6 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-8.13-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.8-bin.zip
 networkTimeout=10000
 validateDistributionUrl=true
 zipStoreBase=GRADLE_USER_HOME

src/main/java/hanium/modic/backend/domain/ai/service/MessageQueueService.java → src/main/java/hanium/modic/backend/common/amqp/service/MessageQueueService.java

@@ -1,4 +1,4 @@
-package hanium.modic.backend.domain.ai.service;
+package hanium.modic.backend.common.amqp.service;
 
 import static hanium.modic.backend.common.amqp.config.RabbitMqConfig.*;
 
@@ -7,7 +7,7 @@
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.stereotype.Service;
 
-import hanium.modic.backend.domain.ai.dto.AiImageRequestMessageDto;
+import hanium.modic.backend.domain.ai.aiServer.dto.AiImageRequestMessageDto;
 import lombok.AccessLevel;
 import lombok.RequiredArgsConstructor;
 
@@ -17,8 +17,7 @@ public class MessageQueueService {
 
 	private final RabbitTemplate rabbitTemplate;
 
-	public void sendImageGenerationRequest(String requestId, String requestImageUrl, List<String> styleImageUrls) {
-		AiImageRequestMessageDto message = new AiImageRequestMessageDto(requestId, requestImageUrl, styleImageUrls);
+	public void sendImageGenerationRequest(Object message) {
 		rabbitTemplate.convertAndSend(
 			AI_IMAGE_REQUEST_EXCHANGE,
 			AI_IMAGE_REQUEST_ROUTING_KEY,

src/main/java/hanium/modic/backend/common/error/ErrorCode.java

@@ -42,6 +42,8 @@ public enum ErrorCode {
 	// Post
 	POST_NOT_FOUND_EXCEPTION(HttpStatus.NOT_FOUND, "P-001", "해당 포스트를 찾을 수 없습니다."),
 	POST_ROLE_EXCEPTION(HttpStatus.FORBIDDEN, "P-002", "포스트에 대한 권한이 없습니다."),
+	POST_ACCESS_DENIED_EXCEPTION(HttpStatus.FORBIDDEN, "P-003", "포스트에 대한 접근 권한이 없습니다."),
+	NOT_AI_DERIVED_POST_EXCEPTION(HttpStatus.BAD_REQUEST, "P-004", "AI 파생 포스트가 아닙니다."),
 
 	// Post Like
 	CANNOT_LIKE_OWN_POST_EXCEPTION(HttpStatus.BAD_REQUEST, "PL-001", "자신의 게시글에는 하트를 할 수 없습니다."),
@@ -83,11 +85,25 @@ public enum ErrorCode {
 	AI_IMAGE_PERMISSION_ALREADY_EXISTS_EXCEPTION(HttpStatus.CONFLICT, "AI-009", "이미 AI 이미지 생성권을 구매했습니다."),
 	AI_IMAGE_NOT_FOUND_EXCEPTION(HttpStatus.NOT_FOUND, "AI-010", "생성된 AI 이미지를 찾을 수 없습니다."),
 	AI_IMAGE_ACCESS_DENIED_EXCEPTION(HttpStatus.FORBIDDEN, "AI-011", "AI 이미지에 대한 권한이 없습니다."),
-	POST_ACCESS_DENIED_EXCEPTION(HttpStatus.FORBIDDEN, "P-003", "포스트에 대한 접근 권한이 없습니다."),
-	NOT_AI_DERIVED_POST_EXCEPTION(HttpStatus.BAD_REQUEST, "P-004", "AI 파생 포스트가 아닙니다."),
+	AI_SERVER_ERROR(HttpStatus.INTERNAL_SERVER_ERROR, "AI-012", "AI 서버와의 통신 중 에러가 발생하였습니다."),
+
+	// AI Chat
+	AI_CHAT_ROOM_NOT_FOUND(HttpStatus.NOT_FOUND, "AC-001", "AI 채팅방을 찾을 수 없습니다."),
+
+	// Vote
+	VOTE_NOT_FOUND_EXCEPTION(HttpStatus.NOT_FOUND, "V-001", "해당 투표를 찾을 수 없습니다."),
+	DUPLICATE_VOTE_EXCEPTION(HttpStatus.BAD_REQUEST, "V-002", "이미 투표에 참여했습니다."),
+	VOTE_ALREADY_COMPLETED_EXCEPTION(HttpStatus.BAD_REQUEST, "V-003", "이미 완료된 투표입니다."),
+	VOTE_PERMISSION_DENIED_EXCEPTION(HttpStatus.FORBIDDEN, "V-004", "투표 권한이 없습니다."),
+	VOTE_NOT_IN_PROGRESS_EXCEPTION(HttpStatus.BAD_REQUEST, "V-005", "진행 중인 투표가 아닙니다."),
+	VOTE_DAILY_LIMIT_EXCEEDED_EXCEPTION(HttpStatus.BAD_REQUEST, "V-006", "일일 투표 한도를 초과했습니다."),
+	VOTE_SUMMARY_NOT_FOUND_EXCEPTION(HttpStatus.NOT_FOUND, "V-007", "투표 집계 정보를 찾을 수 없습니다."),
+	VOTE_UPDATE_FAIL_EXCEPTION(HttpStatus.INTERNAL_SERVER_ERROR, "V-008", "투표 집계 업데이트에 실패했습니다."),
+	NO_AVAILABLE_VOTES_EXCEPTION(HttpStatus.NOT_FOUND, "V-009", "참여 가능한 투표가 없습니다."),
 	;
 
 	private final HttpStatus status;
 	private final String code;
 	private final String message;
+
 }

src/main/java/hanium/modic/backend/common/property/config/PropertyConfig.java

@@ -3,6 +3,7 @@
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Configuration;
 
+import hanium.modic.backend.common.property.property.AiProperties;
 import hanium.modic.backend.common.property.property.CloudFrontProperties;
 import hanium.modic.backend.common.property.property.CorsProperties;
 import hanium.modic.backend.common.property.property.EmailProperty;
@@ -12,6 +13,7 @@
 import hanium.modic.backend.common.property.property.SecurityProperties;
 import hanium.modic.backend.common.property.property.SwaggerProperties;
 import hanium.modic.backend.common.property.property.TokenProperty;
+import hanium.modic.backend.common.property.property.VoteProperties;
 
 // 전역적으로 사용되는 상수
 @Configuration
@@ -24,7 +26,9 @@
 	SecurityProperties.class,
 	CorsProperties.class,
 	RabbitMqProperties.class,
-	CloudFrontProperties.class
+	CloudFrontProperties.class,
+	AiProperties.class,
+	VoteProperties.class
 })
 public class PropertyConfig {
 }

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

@@ -0,0 +1,21 @@
+package hanium.modic.backend.common.property.property;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+@ConfigurationProperties(prefix = "ai")
+public class AiProperties {
+
+	private OpenAi openai = new OpenAi();
+
+	@Getter
+	@Setter
+	public static class OpenAi {
+		private String apiKey;
+		private String model;
+	}
+}

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

@@ -0,0 +1,18 @@
+package hanium.modic.backend.common.property.property;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+@ConfigurationProperties(prefix = "vote.similarity")
+public class VoteProperties {
+
+	private int minTotalWeight;
+	private int aiVoteWeight;
+	private int humanVoteWeight;
+	private Boolean enableAiAssessment;
+	private int maxVotesPerUserPerDay;
+}

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

@@ -28,6 +28,7 @@ public class LockManager {
 	private final String USER_TICKET_PREFIX = "lock:user:ticket:";
 	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:";
 
 	public void userLock(long userId, Runnable block) throws LockException {
 		exec.withLock(USER_PREFIX + userId, block);
@@ -53,4 +54,8 @@ public void aiRequestTicketLock(long userId, Runnable block) throws LockExceptio
 	public void aiImagePermissionLock(long userId, long postId, Runnable block) throws LockException {
 		exec.withLock(AI_PERMISSION_PREFIX + userId + ":" + postId, block);
 	}
+
+	public void voteSummaryLock(long voteId, Runnable block) throws LockException {
+		exec.withLock(VOTE_SUMMARY_PREFIX + voteId, block);
+	}
 }

src/main/java/hanium/modic/backend/domain/ai/service/AiRequestEmitterService.java → src/main/java/hanium/modic/backend/common/sse/service/EmitterService.java

@@ -1,42 +1,28 @@
-package hanium.modic.backend.domain.ai.service;
-
-import static hanium.modic.backend.common.error.ErrorCode.*;
+package hanium.modic.backend.common.sse.service;
 
 import java.io.IOException;
 import java.util.Map;
-import java.util.Objects;
 import java.util.concurrent.ConcurrentHashMap;
 
 import org.springframework.stereotype.Service;
 import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
-import hanium.modic.backend.common.error.ErrorCode;
-import hanium.modic.backend.common.error.exception.AppException;
-import hanium.modic.backend.domain.ai.domain.AiRequestEntity;
-import hanium.modic.backend.domain.ai.repository.AiRequestRepository;
 import lombok.RequiredArgsConstructor;
 
+// SSE(서버-발행 이벤트) 연결 및 메시지 전송을 관리하는 서비스
 @Service
 @RequiredArgsConstructor
-public class AiRequestEmitterService {
-
-	private final AiRequestRepository aiRequestRepository;
+public class EmitterService {
 
 	/**
 	 * SseEmitter 관리 맵
 	 * 해당 맵은 단일 서버를 가정한 map이며, 멀티 서버 환경에서는 Redis등을 활용한 별도의 관리가 필요
 	 */
 	private final Map<String, SseEmitter> emitters = new ConcurrentHashMap<>();
 
-	// requestId와 SseEmitter를 ,emitter관리 맵에 저장
-	public void addEmitter(Long userId, String requestId, SseEmitter emitter) {
-		AiRequestEntity aiRequest = aiRequestRepository.findByRequestId(requestId)
-			.orElseThrow(() -> new AppException(ErrorCode.AI_REQUEST_NOT_FOUND));
-
-		if (!Objects.equals(aiRequest.getUserId(), userId)) {
-			throw new AppException(USER_ROLE_EXCEPTION);
-		}
 
+	// requestId와 SseEmitter를 ,emitter관리 맵에 저장
+	public void addEmitter(String requestId, SseEmitter emitter) {
 		emitters.put(requestId, emitter);
 	}
 
@@ -52,7 +38,6 @@ public void sendToClient(String requestId, Object data) {
 			try {
 				emitter.send(SseEmitter.event()
 					.id(requestId)
-					.name("image")
 					.data(data));
 				emitter.complete();
 				emitters.remove(requestId);

src/main/java/hanium/modic/backend/domain/ai/aiChat/dto/ChatContextResetResponse.java

@@ -0,0 +1,12 @@
+package hanium.modic.backend.domain.ai.aiChat.dto;
+
+import java.time.LocalDateTime;
+
+/**
+ * 컨텍스트 초기화 응답 DTO
+ */
+public record ChatContextResetResponse(
+	Long roomId,
+	LocalDateTime contextResetAt
+) {
+}

src/main/java/hanium/modic/backend/domain/ai/aiChat/dto/ChatMessageRequest.java

@@ -0,0 +1,19 @@
+package hanium.modic.backend.domain.ai.aiChat.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.Size;
+
+/**
+ * 채팅 메시지 전송 요청 DTO
+ */
+@Schema(description = "채팅 메시지 전송 요청")
+public record ChatMessageRequest(
+	@Schema(description = "채팅 메시지 내용", example = "안녕하세요! 이 그림을 더 밝게 만들어주세요.", required = true)
+	@NotBlank(message = "메시지 내용은 필수입니다.")
+	String textContent,
+
+	@Schema(description = "첨부할 이미지 ID (선택사항)", example = "123")
+	Long aiChatImageId // 이미지 첨부 시에만 (optional)
+) {
+}