[YS-509] feat: 공고 키워드 자동완성 기능 구현 (재배포)

application/src/main/kotlin/com/dobby/service/ExperimentPostService.kt

@@ -8,6 +8,7 @@ import com.dobby.exception.InvalidRequestValueException
 import com.dobby.gateway.CacheGateway
 import com.dobby.usecase.experiment.CreateExperimentPostUseCase
 import com.dobby.usecase.experiment.DeleteExperimentPostUseCase
+import com.dobby.usecase.experiment.ExtractExperimentPostKeywordsUseCase
 import com.dobby.usecase.experiment.GenerateExperimentPostPreSignedUrlUseCase
 import com.dobby.usecase.experiment.GetExperimentPostApplyMethodUseCase
 import com.dobby.usecase.experiment.GetExperimentPostCountsByAreaUseCase
@@ -41,6 +42,7 @@ class ExperimentPostService(
     private val getExperimentPostTotalCountByCustomFilterUseCase: GetExperimentPostTotalCountByCustomFilterUseCase,
     private val getMyExperimentPostsUseCase: GetMyExperimentPostsUseCase,
     private val getMyExperimentPostTotalCountUseCase: GetMyExperimentPostTotalCountUseCase,
+    private val extractExperimentPostKeywordsUseCase: ExtractExperimentPostKeywordsUseCase,
     private val cacheGateway: CacheGateway
 ) {
     @Transactional
@@ -165,6 +167,10 @@ class ExperimentPostService(
         evictExperimentPostCountsCaches()
     }
 
+    fun extractExperimentPostKeywords(input: ExtractExperimentPostKeywordsUseCase.Input): ExtractExperimentPostKeywordsUseCase.Output {
+        return extractExperimentPostKeywordsUseCase.execute(input)
+    }
+
     private fun evictExperimentPostCountsCaches() {
         listOf("ALL", "OPEN").forEach { cacheGateway.evict("experimentPostCounts:$it") }
     }

application/src/main/kotlin/com/dobby/usecase/experiment/ExtractExperimentPostKeywordsUseCase.kt

@@ -0,0 +1,17 @@
+package com.dobby.usecase.experiment
+
+import com.dobby.gateway.experiment.ExperimentKeywordExtractionGateway
+import com.dobby.model.experiment.keyword.ExperimentPostKeyword
+import com.dobby.usecase.UseCase
+
+class ExtractExperimentPostKeywordsUseCase(
+    private val experimentKeywordExtractionGateway: ExperimentKeywordExtractionGateway
+) : UseCase<ExtractExperimentPostKeywordsUseCase.Input, ExtractExperimentPostKeywordsUseCase.Output> {
+    data class Input(val text: String)
+    data class Output(val experimentPostKeyword: ExperimentPostKeyword)
+
+    override fun execute(input: Input): Output {
+        val experimentPostKeyword = experimentKeywordExtractionGateway.extractKeywords(input.text)
+        return Output(experimentPostKeyword)
+    }
+}

application/src/test/kotlin/com/dobby/usecase/experiment/ExtractExperimentPostKeywordsUseCaseTest.kt

@@ -0,0 +1,34 @@
+package com.dobby.usecase.experiment
+
+import com.dobby.gateway.experiment.ExperimentKeywordExtractionGateway
+import com.dobby.model.experiment.keyword.ExperimentPostKeyword
+import io.kotest.core.spec.style.BehaviorSpec
+import io.kotest.matchers.shouldBe
+import io.mockk.every
+import io.mockk.mockk
+import io.mockk.verify
+
+class ExtractExperimentPostKeywordsUseCaseTest : BehaviorSpec({
+    val experimentKeywordExtractionGateway = mockk<ExperimentKeywordExtractionGateway>()
+    val extractExperimentPostKeywordsUseCase = ExtractExperimentPostKeywordsUseCase(experimentKeywordExtractionGateway)
+
+    given("실험 게시글 텍스트에서 키워드를 추출할 때") {
+        val inputText = "남성 20-30대 대상 설문조사 참여자 모집합니다. 시간은 1시간 소요되며 참가비 10,000원 지급합니다."
+        val input = ExtractExperimentPostKeywordsUseCase.Input(inputText)
+        val mockExperimentPostKeyword = mockk<ExperimentPostKeyword>()
+
+        every { experimentKeywordExtractionGateway.extractKeywords(inputText) } returns mockExperimentPostKeyword
+
+        `when`("키워드 추출을 요청하면") {
+            val result = extractExperimentPostKeywordsUseCase.execute(input)
+
+            then("추출된 키워드 정보를 반환해야 한다") {
+                result.experimentPostKeyword shouldBe mockExperimentPostKeyword
+
+                verify(exactly = 1) {
+                    experimentKeywordExtractionGateway.extractKeywords(inputText)
+                }
+            }
+        }
+    }
+})

domain/src/main/kotlin/com/dobby/exception/DobbyException.kt

@@ -77,3 +77,8 @@ data object ExperimentPostLeadResearcherException : ClientException("EP0013", "L
 sealed class ServerException(code: String, message: String, cause: Throwable? = null) : DobbyException(code, message, cause)
 
 data object UnknownServerErrorException : ServerException("DB0001", "An unknown error has occurred")
+
+/**
+ * OpenAI API call specific exceptions
+ */
+data class CustomOpenAiCallException(override val message: String, override val cause: Throwable? = null) : ServerException("AI0001", message, cause)

domain/src/main/kotlin/com/dobby/gateway/experiment/ExperimentKeywordExtractionGateway.kt

@@ -0,0 +1,7 @@
+package com.dobby.gateway.experiment
+
+import com.dobby.model.experiment.keyword.ExperimentPostKeyword
+
+interface ExperimentKeywordExtractionGateway {
+    fun extractKeywords(text: String): ExperimentPostKeyword
+}

domain/src/main/kotlin/com/dobby/model/experiment/keyword/ApplyMethodKeyword.kt

@@ -0,0 +1,9 @@
+package com.dobby.model.experiment.keyword
+
+data class ApplyMethodKeyword(
+    val content: String?,
+    val isFormUrl: Boolean,
+    val formUrl: String?,
+    val isPhoneNum: Boolean,
+    val phoneNum: String?
+)

domain/src/main/kotlin/com/dobby/model/experiment/keyword/ExperimentPostKeyword.kt

@@ -0,0 +1,13 @@
+package com.dobby.model.experiment.keyword
+
+import com.dobby.enums.MatchType
+import com.dobby.enums.experiment.TimeSlot
+
+data class ExperimentPostKeyword(
+    val targetGroup: TargetGroupKeyword?,
+    val applyMethod: ApplyMethodKeyword?,
+    val matchType: MatchType?,
+    val reward: String?,
+    val count: Int?,
+    val timeRequired: TimeSlot?
+)

domain/src/main/kotlin/com/dobby/model/experiment/keyword/TargetGroupKeyword.kt

@@ -0,0 +1,10 @@
+package com.dobby.model.experiment.keyword
+
+import com.dobby.enums.member.GenderType
+
+data class TargetGroupKeyword(
+    var startAge: Int?,
+    var endAge: Int?,
+    var genderType: GenderType?,
+    var otherCondition: String?
+)

infrastructure/src/main/kotlin/com/dobby/config/OpenAiFeignConfig.kt

@@ -0,0 +1,17 @@
+package com.dobby.config
+
+import com.dobby.config.properties.OpenAiProperties
+import feign.RequestInterceptor
+import org.springframework.context.annotation.Bean
+
+class OpenAiFeignConfig(
+    private val openAiProperties: OpenAiProperties
+) {
+    @Bean
+    fun openAiRequestInterceptor(): RequestInterceptor {
+        return RequestInterceptor { template ->
+            template.header("Authorization", "Bearer ${openAiProperties.api.key}")
+            template.header("Content-Type", "application/json")
+        }
+    }
+}

infrastructure/src/main/kotlin/com/dobby/config/properties/OpenAiProperties.kt

@@ -0,0 +1,14 @@
+package com.dobby.config.properties
+
+import org.springframework.boot.context.properties.ConfigurationProperties
+import org.springframework.stereotype.Component
+
+@Component
+@ConfigurationProperties(prefix = "openai")
+data class OpenAiProperties(
+    var api: Api = Api()
+) {
+    data class Api(
+        var key: String = ""
+    )
+}

infrastructure/src/main/kotlin/com/dobby/external/feign/openAi/OpenAiFeignClient.kt

@@ -0,0 +1,18 @@
+package com.dobby.external.feign.openAi
+
+import com.dobby.api.dto.request.OpenAiRequest
+import com.dobby.api.dto.response.OpenAiResponse
+import com.dobby.config.OpenAiFeignConfig
+import org.springframework.cloud.openfeign.FeignClient
+import org.springframework.web.bind.annotation.PostMapping
+import org.springframework.web.bind.annotation.RequestBody
+
+@FeignClient(
+    name = "openAiClient",
+    url = "https://api.openai.com/v1",
+    configuration = [OpenAiFeignConfig::class]
+)
+interface OpenAiFeignClient {
+    @PostMapping("/chat/completions")
+    fun chatCompletion(@RequestBody request: OpenAiRequest): OpenAiResponse
+}

infrastructure/src/main/kotlin/com/dobby/external/gateway/experiment/ExperimentKeywordExtractionGatewayImpl.kt

@@ -0,0 +1,78 @@
+package com.dobby.external.gateway.experiment
+
+import com.dobby.api.dto.request.OpenAiRequest
+import com.dobby.exception.CustomOpenAiCallException
+import com.dobby.external.feign.openAi.OpenAiFeignClient
+import com.dobby.external.prompt.ExperimentPostKeywordMapper
+import com.dobby.external.prompt.PromptTemplate
+import com.dobby.external.prompt.PromptTemplateLoader
+import com.dobby.external.prompt.dto.ExperimentPostKeywordDto
+import com.dobby.gateway.experiment.ExperimentKeywordExtractionGateway
+import com.dobby.model.experiment.keyword.ExperimentPostKeyword
+import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
+import com.fasterxml.jackson.module.kotlin.readValue
+import feign.FeignException
+import org.springframework.stereotype.Component
+
+@Component
+class ExperimentKeywordExtractionGatewayImpl(
+    private val openAiFeignClient: OpenAiFeignClient,
+    private val promptTemplateLoader: PromptTemplateLoader,
+    private val mapper: ExperimentPostKeywordMapper
+) : ExperimentKeywordExtractionGateway {
+
+    private val objectMapper = jacksonObjectMapper()
+
+    private val promptTemplate: PromptTemplate by lazy {
+        promptTemplateLoader.loadPrompt("prompts/keyword_extraction_prompt.json")
+    }
+
+    override fun extractKeywords(text: String): ExperimentPostKeyword {
+        val promptJson = objectMapper.writeValueAsString(promptTemplate)
+        val prompt = promptJson.replace("{{text}}", escapeJsonString(text))
+        val messages = listOf(
+            OpenAiRequest.Message(role = "user", content = prompt)
+        )
+
+        val request = OpenAiRequest(
+            model = "gpt-4o",
+            temperature = 0.2,
+            messages = messages
+        )
+
+        val content = try {
+            val response = openAiFeignClient.chatCompletion(request)
+            response.choices.firstOrNull()?.message?.content
+                ?: throw IllegalStateException("No response received from OpenAI")
+        } catch (e: FeignException) {
+            throw CustomOpenAiCallException("OpenAI API call failed (status=${e.status()})", e)
+        } catch (e: Exception) {
+            throw IllegalStateException("Unexpected error occurred during OpenAI API call", e)
+        }
+
+        return try {
+            val cleanedContent = cleanJsonResponse(content)
+            val dto = objectMapper.readValue<ExperimentPostKeywordDto>(cleanedContent)
+            mapper.toDomain(dto)
+        } catch (e: Exception) {
+            throw IllegalStateException("Failed to parse response: $content", e)
+        }
+    }
+
+    private fun escapeJsonString(text: String): String {
+        return text.replace("\\", "\\\\")
+            .replace("\"", "\\\"")
+            .replace("\n", "\\n")
+            .replace("\r", "\\r")
+            .replace("\t", "\\t")
+    }
+
+    private fun cleanJsonResponse(content: String): String {
+        return content.trim()
+            .replace(Regex("^```json\\s*"), "")
+            .replace(Regex("```\\s*$"), "")
+            .replace(Regex("^`+"), "")
+            .replace(Regex("`+$"), "")
+            .trim()
+    }
+}

infrastructure/src/main/kotlin/com/dobby/external/prompt/ExperimentPostKeywordMapper.kt

@@ -0,0 +1,87 @@
+package com.dobby.external.prompt
+
+import com.dobby.enums.MatchType
+import com.dobby.enums.experiment.TimeSlot
+import com.dobby.enums.member.GenderType
+import com.dobby.external.prompt.dto.ApplyMethodDto
+import com.dobby.external.prompt.dto.ExperimentPostKeywordDto
+import com.dobby.external.prompt.dto.TargetGroupDto
+import com.dobby.model.experiment.keyword.ApplyMethodKeyword
+import com.dobby.model.experiment.keyword.ExperimentPostKeyword
+import com.dobby.model.experiment.keyword.TargetGroupKeyword
+import org.springframework.stereotype.Component
+
+@Component
+class ExperimentPostKeywordMapper {
+
+    fun toDomain(dto: ExperimentPostKeywordDto): ExperimentPostKeyword {
+        return ExperimentPostKeyword(
+            targetGroup = dto.targetGroup?.let { targetGroupDto ->
+                TargetGroupKeyword(
+                    startAge = targetGroupDto.startAge ?: 0,
+                    endAge = targetGroupDto.endAge ?: 0,
+                    genderType = targetGroupDto.genderType?.let { genderStr ->
+                        when (genderStr) {
+                            "MALE" -> GenderType.MALE
+                            "FEMALE" -> GenderType.FEMALE
+                            "ALL" -> GenderType.ALL
+                            else -> GenderType.ALL
+                        }
+                    } ?: GenderType.ALL,
+                    otherCondition = targetGroupDto.otherCondition
+                )
+            },
+            applyMethod = dto.applyMethod?.let { applyMethodDto ->
+                ApplyMethodKeyword(
+                    content = applyMethodDto.content ?: "",
+                    isFormUrl = applyMethodDto.isFormUrl,
+                    formUrl = applyMethodDto.formUrl ?: "",
+                    isPhoneNum = applyMethodDto.isPhoneNum,
+                    phoneNum = applyMethodDto.phoneNum ?: ""
+                )
+            },
+            matchType = dto.matchType?.let { matchTypeStr ->
+                try {
+                    MatchType.valueOf(matchTypeStr)
+                } catch (e: IllegalArgumentException) {
+                    MatchType.ALL
+                }
+            } ?: MatchType.ALL,
+            reward = dto.reward ?: "",
+            count = dto.count ?: 0,
+            timeRequired = dto.timeRequired?.takeIf { it.isNotBlank() }?.let { timeSlotStr ->
+                try {
+                    TimeSlot.valueOf(timeSlotStr)
+                } catch (e: IllegalArgumentException) {
+                    null
+                }
+            }
+        )
+    }
+
+    fun toDto(domain: ExperimentPostKeyword): ExperimentPostKeywordDto {
+        return ExperimentPostKeywordDto(
+            targetGroup = domain.targetGroup?.let { targetGroupDomain ->
+                TargetGroupDto(
+                    startAge = targetGroupDomain.startAge,
+                    endAge = targetGroupDomain.endAge,
+                    genderType = targetGroupDomain.genderType?.name,
+                    otherCondition = targetGroupDomain.otherCondition
+                )
+            },
+            applyMethod = domain.applyMethod?.let { applyMethodDomain ->
+                ApplyMethodDto(
+                    content = applyMethodDomain.content,
+                    isFormUrl = applyMethodDomain.isFormUrl,
+                    formUrl = applyMethodDomain.formUrl,
+                    isPhoneNum = applyMethodDomain.isPhoneNum,
+                    phoneNum = applyMethodDomain.phoneNum
+                )
+            },
+            matchType = domain.matchType?.name,
+            reward = domain.reward,
+            count = domain.count,
+            timeRequired = domain.timeRequired?.name
+        )
+    }
+}

infrastructure/src/main/kotlin/com/dobby/external/prompt/PromptTemplate.kt

@@ -0,0 +1,9 @@
+package com.dobby.external.prompt
+
+data class PromptTemplate(
+    val description: String,
+    val input: Map<String, String>,
+    val extract_items: List<String>,
+    val output_format: Map<String, Any>,
+    val conditions: List<String>
+)

infrastructure/src/main/kotlin/com/dobby/external/prompt/PromptTemplateLoader.kt

@@ -0,0 +1,19 @@
+package com.dobby.external.prompt
+
+import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
+import org.springframework.stereotype.Component
+
+@Component
+class PromptTemplateLoader {
+
+    private val mapper = jacksonObjectMapper()
+
+    fun loadPrompt(resourcePath: String): PromptTemplate {
+        val resource = this::class.java.classLoader.getResource(resourcePath)
+            ?: throw IllegalArgumentException("프롬프트 파일을 찾을 수 없습니다: $resourcePath")
+
+        return resource.openStream().use { inputStream ->
+            mapper.readValue(inputStream, PromptTemplate::class.java)
+        }
+    }
+}

infrastructure/src/main/kotlin/com/dobby/external/prompt/dto/ApplyMethodDto.kt

@@ -0,0 +1,9 @@
+package com.dobby.external.prompt.dto
+
+data class ApplyMethodDto(
+    val content: String? = null,
+    val isFormUrl: Boolean = false,
+    val formUrl: String? = null,
+    val isPhoneNum: Boolean = false,
+    val phoneNum: String? = null
+)