feat: problem 도메인 1차 구현

.gitignore

@@ -88,4 +88,10 @@ Footer
 *.ear
 *.zip
 *.tar.gz
-*.rar
+*.rar
+
+# Jooq
+**/generated/
+*.log
+*.tmp
+

api-repo/.gitignore

@@ -0,0 +1,2 @@
+# DB schema migration path
+**/*.sql

api-repo/build.gradle.kts

@@ -23,7 +23,7 @@ sourceSets {
 
 dependencies {
     /** spring starter */
-    implementation("org.springframework.boot:spring-boot-starter-data-jdbc")
+    api("org.springframework.boot:spring-boot-starter-data-jdbc")
     implementation("com.mysql:mysql-connector-j")
 
     /** flyway */

api-repo/src/main/kotlin/com/few/api/repo/dao/problem/ProblemDao.kt

@@ -0,0 +1,40 @@
+package com.few.api.repo.dao.problem
+
+import com.few.api.repo.dao.problem.query.SelectProblemAnswerQuery
+import com.few.api.repo.dao.problem.query.SelectProblemQuery
+import com.few.api.repo.dao.problem.record.SelectProblemAnswerRecord
+import com.few.api.repo.dao.problem.record.SelectProblemRecord
+import jooq.jooq_dsl.tables.Problem
+import org.jooq.DSLContext
+import org.jooq.impl.DSL
+import org.springframework.stereotype.Component
+
+@Component
+class ProblemDao(
+    private val dslContext: DSLContext
+) {
+    fun selectProblemContentsByProblemId(query: SelectProblemQuery): SelectProblemRecord {
+        return dslContext.select(
+            Problem.PROBLEM.ID.`as`(SelectProblemRecord::id.name),
+            Problem.PROBLEM.TITLE.`as`(SelectProblemRecord::title.name),
+            DSL.field("JSON_UNQUOTE({0})", String::class.java, Problem.PROBLEM.CONTENTS)
+                .`as`(SelectProblemRecord::contents.name)
+        )
+            .from(Problem.PROBLEM)
+            .where(Problem.PROBLEM.ID.eq(query.problemId))
+            .fetchOneInto(SelectProblemRecord::class.java)
+            ?: throw RuntimeException("Problem with ID ${query.problemId} not found") // TODO: 에러 표준화
+    }
+
+    fun selectProblemAnswerByProblemId(query: SelectProblemAnswerQuery): SelectProblemAnswerRecord {
+        return dslContext.select(
+            Problem.PROBLEM.ID.`as`(SelectProblemAnswerRecord::id.name),
+            Problem.PROBLEM.ANSWER.`as`(SelectProblemAnswerRecord::answer.name),
+            Problem.PROBLEM.EXPLANATION.`as`(SelectProblemAnswerRecord::explanation.name)
+        )
+            .from(Problem.PROBLEM)
+            .where(Problem.PROBLEM.ID.eq(query.problemId))
+            .fetchOneInto(SelectProblemAnswerRecord::class.java)
+            ?: throw RuntimeException("Problem Answer with ID ${query.problemId} not found") // TODO: 에러 표준화
+    }
+}

api-repo/src/main/kotlin/com/few/api/repo/dao/problem/SubmitHistoryDao.kt

@@ -0,0 +1,25 @@
+package com.few.api.repo.dao.problem
+
+import com.few.api.repo.dao.problem.command.InsertSubmitHistoryCommand
+import jooq.jooq_dsl.Tables.SUBMIT_HISTORY
+import org.jooq.DSLContext
+import org.springframework.stereotype.Component
+
+@Component
+class SubmitHistoryDao(
+    private val dslContext: DSLContext
+) {
+
+    fun insertSubmitHistory(command: InsertSubmitHistoryCommand): Long {
+        val result = dslContext.insertInto(SUBMIT_HISTORY)
+            .set(SUBMIT_HISTORY.PROBLEM_ID, command.problemId)
+            .set(SUBMIT_HISTORY.MEMBER_ID, command.memberId)
+            .set(SUBMIT_HISTORY.SUBMIT_ANS, command.submitAns)
+            .set(SUBMIT_HISTORY.IS_SOLVED, command.isSolved)
+            .returning(SUBMIT_HISTORY.ID)
+            .fetchOne()
+
+        return result?.getValue(SUBMIT_HISTORY.ID)
+            ?: throw RuntimeException("Submit History with ID ${command.problemId} insertion fail") // TODO: 에러 표준화
+    }
+}

api-repo/src/main/kotlin/com/few/api/repo/dao/problem/command/InsertSubmitHistoryCommand.kt

@@ -0,0 +1,8 @@
+package com.few.api.repo.dao.problem.command
+
+data class InsertSubmitHistoryCommand(
+    val problemId: Long,
+    val memberId: Long,
+    val submitAns: String,
+    val isSolved: Boolean
+)

api-repo/src/main/kotlin/com/few/api/repo/dao/problem/query/SelectProblemAnswerQuery.kt

@@ -0,0 +1,5 @@
+package com.few.api.repo.dao.problem.query
+
+data class SelectProblemAnswerQuery(
+    val problemId: Long
+)

api-repo/src/main/kotlin/com/few/api/repo/dao/problem/query/SelectProblemQuery.kt

@@ -0,0 +1,5 @@
+package com.few.api.repo.dao.problem.query
+
+data class SelectProblemQuery(
+    val problemId: Long
+)

api-repo/src/main/kotlin/com/few/api/repo/dao/problem/record/SelectProblemAnswerRecord.kt

@@ -0,0 +1,7 @@
+package com.few.api.repo.dao.problem.record
+
+data class SelectProblemAnswerRecord(
+    val id: Long,
+    val answer: String,
+    val explanation: String
+)

api-repo/src/main/kotlin/com/few/api/repo/dao/problem/record/SelectProblemRecord.kt

@@ -0,0 +1,7 @@
+package com.few.api.repo.dao.problem.record
+
+data class SelectProblemRecord(
+    val id: Long,
+    val title: String,
+    val contents: String
+)

api/build.gradle.kts

@@ -1,6 +1,9 @@
 import org.hidetake.gradle.swagger.generator.GenerateSwaggerUI
 
 dependencies {
+    /** module */
+    implementation(project(":api-repo"))
+
     /** spring starter */
     implementation("org.springframework.boot:spring-boot-starter-webflux")
     implementation("org.springframework.boot:spring-boot-starter-actuator")

api/src/main/kotlin/com/few/api/config/ApiConfig.kt

@@ -0,0 +1,19 @@
+package com.few.api.config
+
+import com.few.api.repo.config.ApiRepoConfig
+import org.springframework.context.annotation.ComponentScan
+import org.springframework.context.annotation.Configuration
+import org.springframework.context.annotation.Import
+
+@Configuration
+@ComponentScan(basePackages = [ApiConfig.BASE_PACKAGE])
+@Import(ApiRepoConfig::class)
+class ApiConfig {
+    companion object {
+        const val BASE_PACKAGE = "com.few.api"
+        const val SERVICE_NAME = "few"
+        const val MODULE_NAME = "few-api"
+        const val BEAN_NAME_PREFIX = "fewApi"
+        const val PROPERTY_PREFIX = SERVICE_NAME + "." + MODULE_NAME
+    }
+}

api/src/main/kotlin/com/few/api/web/controller/problem/ProblemController.kt

@@ -6,42 +6,53 @@ import com.few.api.web.controller.problem.response.ProblemContents
 import com.few.api.web.controller.problem.response.ReadProblemResponse
 import com.few.api.web.support.ApiResponse
 import com.few.api.web.support.ApiResponseGenerator
+import com.few.api.web.usecase.problem.CheckProblemUseCase
+import com.few.api.web.usecase.problem.ReadProblemUseCase
+import com.few.api.web.usecase.problem.`in`.CheckProblemUseCaseIn
+import com.few.api.web.usecase.problem.`in`.ReadProblemUseCaseIn
 import org.springframework.http.HttpStatus
 import org.springframework.validation.annotation.Validated
 import org.springframework.web.bind.annotation.*
+import java.util.*
 
 @Validated
 @RestController
 @RequestMapping("/api/v1/problems")
-class ProblemController {
+class ProblemController(
+    private val readProblemUseCase: ReadProblemUseCase,
+    private val checkProblemUseCase: CheckProblemUseCase
+) {
 
     @GetMapping("/{problemId}")
     fun readProblem(
         @PathVariable(value = "problemId") problemId: Long
     ): ApiResponse<ApiResponse.SuccessBody<ReadProblemResponse>> {
-        val data = ReadProblemResponse(
-            id = 1L,
-            title = "ETF(상장지수펀드)의 특징이 아닌것은?",
-            contents = listOf(
-                ProblemContents(1L, "분산투자"),
-                ProblemContents(2L, "높은 운용 비용"),
-                ProblemContents(3L, "유동성"),
-                ProblemContents(4L, "투명성")
-            )
+        val useCaseOut = readProblemUseCase.execute(ReadProblemUseCaseIn(problemId))
+
+        val response = ReadProblemResponse(
+            id = useCaseOut.id,
+            title = useCaseOut.title,
+            contents = useCaseOut.contents
+                .map { c -> ProblemContents(c.number, c.content) }
+                .toCollection(LinkedList())
         )
-        return ApiResponseGenerator.success(data, HttpStatus.OK)
+
+        return ApiResponseGenerator.success(response, HttpStatus.OK)
     }
 
     @PostMapping("/{problemId}")
     fun checkProblem(
         @PathVariable(value = "problemId") problemId: Long,
         @RequestBody body: CheckProblemBody
     ): ApiResponse<ApiResponse.SuccessBody<CheckProblemResponse>> {
-        val data = CheckProblemResponse(
-            explanation = "ETF는 일반적으로 낮은 운용 비용을 특징으로 합니다.이는 ETF가 보통 지수 추종(passive management) 방식으로 운용되기 때문입니다. 지수를 추종하는 전략은 액티브 매니지먼트(active management)에 비해 관리가 덜 복잡하고, 따라서 비용이 낮습니다.",
-            answer = "2",
-            isSolved = true
+        val useCaseOut = checkProblemUseCase.execute(CheckProblemUseCaseIn(problemId, body.sub))
+
+        val response = CheckProblemResponse(
+            explanation = useCaseOut.explanation,
+            answer = useCaseOut.answer,
+            isSolved = useCaseOut.isSolved
         )
-        return ApiResponseGenerator.success(data, HttpStatus.OK)
+
+        return ApiResponseGenerator.success(response, HttpStatus.OK)
     }
 }

api/src/main/kotlin/com/few/api/web/usecase/problem/CheckProblemUseCase.kt

@@ -0,0 +1,36 @@
+package com.few.api.web.usecase.problem
+
+import com.few.api.repo.dao.problem.ProblemDao
+import com.few.api.repo.dao.problem.SubmitHistoryDao
+import com.few.api.repo.dao.problem.command.InsertSubmitHistoryCommand
+import com.few.api.repo.dao.problem.query.SelectProblemAnswerQuery
+import com.few.api.web.usecase.problem.`in`.CheckProblemUseCaseIn
+import com.few.api.web.usecase.problem.out.CheckProblemUseCaseOut
+import org.springframework.stereotype.Component
+import org.springframework.transaction.annotation.Transactional
+
+@Component
+class CheckProblemUseCase(
+    private val problemDao: ProblemDao,
+    private val submitHistoryDao: SubmitHistoryDao
+) {
+
+    @Transactional
+    fun execute(useCaseIn: CheckProblemUseCaseIn): CheckProblemUseCaseOut {
+        val problemId = useCaseIn.problemId
+        val submitAns = useCaseIn.sub
+
+        val record = problemDao.selectProblemAnswerByProblemId(SelectProblemAnswerQuery(problemId))
+        val isSolved = submitAns.equals(record.answer)
+
+        val submitHistoryId = submitHistoryDao.insertSubmitHistory(
+            InsertSubmitHistoryCommand(problemId, 1L, submitAns, isSolved)
+        ) // not used 'submitHistoryId'
+
+        return CheckProblemUseCaseOut(
+            explanation = record.explanation,
+            isSolved = isSolved,
+            answer = record.answer
+        )
+    }
+}

api/src/main/kotlin/com/few/api/web/usecase/problem/ReadProblemUseCase.kt

@@ -0,0 +1,33 @@
+package com.few.api.web.usecase.problem
+
+import com.fasterxml.jackson.databind.ObjectMapper
+import com.fasterxml.jackson.module.kotlin.readValue
+import com.few.api.repo.dao.problem.ProblemDao
+import com.few.api.repo.dao.problem.query.SelectProblemQuery
+import com.few.api.web.usecase.problem.`in`.ReadProblemUseCaseIn
+import com.few.api.web.usecase.problem.out.ReadProblemContentsUseCaseOutDetail
+import com.few.api.web.usecase.problem.out.ReadProblemUseCaseOut
+import org.springframework.stereotype.Component
+import org.springframework.transaction.annotation.Transactional
+
+@Component
+class ReadProblemUseCase(
+    private val problemDao: ProblemDao,
+    private val objectMapper: ObjectMapper
+) {
+
+    @Transactional(readOnly = true)
+    fun execute(useCaseIn: ReadProblemUseCaseIn): ReadProblemUseCaseOut {
+        val problemId = useCaseIn.problemId
+
+        val record = problemDao.selectProblemContentsByProblemId(SelectProblemQuery(problemId))
+
+        val contents: List<ReadProblemContentsUseCaseOutDetail> = objectMapper.readValue(record.contents)
+
+        return ReadProblemUseCaseOut(
+            id = record.id,
+            title = record.title,
+            contents = contents
+        )
+    }
+}

api/src/main/kotlin/com/few/api/web/usecase/problem/in/CheckProblemUseCaseIn.kt

@@ -0,0 +1,6 @@
+package com.few.api.web.usecase.problem.`in`
+
+data class CheckProblemUseCaseIn(
+    val problemId: Long,
+    val sub: String
+)

api/src/main/kotlin/com/few/api/web/usecase/problem/in/ReadProblemUseCaseIn.kt

@@ -0,0 +1,5 @@
+package com.few.api.web.usecase.problem.`in`
+
+data class ReadProblemUseCaseIn(
+    val problemId: Long
+)

api/src/main/kotlin/com/few/api/web/usecase/problem/out/CheckProblemUseCaseOut.kt

@@ -0,0 +1,7 @@
+package com.few.api.web.usecase.problem.out
+
+data class CheckProblemUseCaseOut(
+    val explanation: String,
+    val answer: String,
+    val isSolved: Boolean
+)

api/src/main/kotlin/com/few/api/web/usecase/problem/out/ReadProblemUseCaseOut.kt

@@ -0,0 +1,12 @@
+package com.few.api.web.usecase.problem.out
+
+class ReadProblemUseCaseOut(
+    val id: Long,
+    val title: String,
+    val contents: List<ReadProblemContentsUseCaseOutDetail>
+)
+
+data class ReadProblemContentsUseCaseOutDetail(
+    val number: Long,
+    val content: String
+)

api/src/main/resources/application.yml

@@ -0,0 +1,10 @@
+spring:
+    profiles:
+        group:
+            local:
+                - api-repo-local
+            prd:
+                - api-repo-prd
+            test:
+                - new
+                - api-repo-local