[YS-130] feat: 기간이 지난 공고 state 변경 스케줄링 구현

build.gradle.kts

@@ -48,6 +48,7 @@ dependencies {
 	implementation("org.mariadb.jdbc:mariadb-java-client:2.7.3")
 	implementation("org.springdoc:springdoc-openapi-starter-webmvc-ui:2.7.0")
 	implementation("org.springframework.cloud:spring-cloud-starter-openfeign")
+	implementation("org.springframework.boot:spring-boot-starter-quartz")
 	implementation("io.awspring.cloud:spring-cloud-starter-aws:2.4.4")
 	compileOnly("org.projectlombok:lombok")
 	runtimeOnly("com.mysql:mysql-connector-j")

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

@@ -10,6 +10,7 @@ import com.dobby.backend.domain.exception.ExperimentAreaOverflowException
 import com.dobby.backend.infrastructure.database.entity.enums.areaInfo.Area
 import jakarta.transaction.Transactional
 import org.springframework.stereotype.Service
+import java.time.LocalDate
 
 @Service
 class ExperimentPostService(
@@ -19,7 +20,8 @@ class ExperimentPostService(
     private val getExperimentPostCountsByRegionUseCase: GetExperimentPostCountsByRegionUseCase,
     private val getExperimentPostCountsByAreaUseCase: GetExperimentPostCountsByAreaUseCase,
     private val getExperimentPostApplyMethodUseCase: GetExperimentPostApplyMethodUseCase,
-    private val generateExperimentPostPreSignedUrlUseCase: GenerateExperimentPostPreSignedUrlUseCase
+    private val generateExperimentPostPreSignedUrlUseCase: GenerateExperimentPostPreSignedUrlUseCase,
+    private val updateExpiredExperimentPostUseCase: UpdateExpiredExperimentPostUseCase
 ) {
     @Transactional
     fun createNewExperimentPost(input: CreateExperimentPostUseCase.Input): CreateExperimentPostUseCase.Output {
@@ -42,6 +44,11 @@ class ExperimentPostService(
         return getExperimentPostApplyMethodUseCase.execute(input)
     }
 
+    @Transactional
+    fun updateExpiredExperimentPosts(input: UpdateExpiredExperimentPostUseCase.Input): UpdateExpiredExperimentPostUseCase.Output  {
+        return updateExpiredExperimentPostUseCase.execute(input)
+    }
+
     fun getExperimentPostCounts(input: Any): Any {
         return when (input) {
             is GetExperimentPostCountsByRegionUseCase.Input -> getExperimentPostCountsByRegionUseCase.execute(input)
@@ -69,7 +76,6 @@ class ExperimentPostService(
             throw ExperimentAreaInCorrectException()
         }
     }
-
     fun generatePreSignedUrl(input: GenerateExperimentPostPreSignedUrlUseCase.Input): GenerateExperimentPostPreSignedUrlUseCase.Output {
         return generateExperimentPostPreSignedUrlUseCase.execute(input)
     }

src/main/kotlin/com/dobby/backend/application/usecase/experiment/UpdateExpiredExperimentPostUseCase.kt

@@ -0,0 +1,22 @@
+package com.dobby.backend.application.usecase.experiment
+
+import com.dobby.backend.application.usecase.UseCase
+import com.dobby.backend.domain.gateway.experiment.ExperimentPostGateway
+import java.time.LocalDate
+
+class UpdateExpiredExperimentPostUseCase(
+    private val experimentPostGateway: ExperimentPostGateway
+) : UseCase<UpdateExpiredExperimentPostUseCase.Input, UpdateExpiredExperimentPostUseCase.Output> {
+    data class Input(
+        val currentDate : LocalDate
+    )
+    data class Output(
+        val affectedRowsCount: Long
+    )
+
+    override fun execute(input: Input): Output {
+        return Output(
+            experimentPostGateway.updateExperimentPostStatus(input.currentDate)
+        )
+    }
+}

src/main/kotlin/com/dobby/backend/domain/gateway/experiment/ExperimentPostGateway.kt

@@ -5,6 +5,7 @@ import com.dobby.backend.domain.model.experiment.Pagination
 import com.dobby.backend.domain.model.experiment.ExperimentPost
 import com.dobby.backend.infrastructure.database.entity.enums.areaInfo.Region
 import jakarta.persistence.Tuple
+import java.time.LocalDate
 
 interface ExperimentPostGateway {
     fun save(experimentPost: ExperimentPost): ExperimentPost
@@ -14,6 +15,7 @@ interface ExperimentPostGateway {
     fun countExperimentPosts(): Int
     fun countExperimentPostByRegionGroupedByArea(region: Region): List<Tuple>
     fun countExperimentPostGroupedByRegion(): List<Tuple>
+    fun updateExperimentPostStatus(todayDate : LocalDate) : Long
     fun findExperimentPostsByMemberIdWithPagination(memberId: Long, pagination: Pagination, order: String): List<ExperimentPost>?
     fun countExperimentPostsByMemberId(memberId: Long): Int
 }

src/main/kotlin/com/dobby/backend/infrastructure/config/SchedulerConfig.kt

@@ -0,0 +1,30 @@
+package com.dobby.backend.infrastructure.config
+
+import com.dobby.backend.infrastructure.scheduler.ExpiredExperimentPostJob
+import org.quartz.*
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import java.util.*
+
+@Configuration
+class SchedulerConfig {
+    @Bean
+    fun expiredExperimentPostJobDetail(): JobDetail {
+        return JobBuilder.newJob(ExpiredExperimentPostJob::class.java)
+            .withIdentity("expired_experiment_post_job")
+            .storeDurably()
+            .build()
+    }
+
+    @Bean
+    fun expiredExperimentPostTrigger(): Trigger {
+        return TriggerBuilder.newTrigger()
+            .forJob(expiredExperimentPostJobDetail())
+            .withIdentity("expired_experiment_post_trigger")
+            .withSchedule(
+                CronScheduleBuilder.dailyAtHourAndMinute(0, 0)
+                    .inTimeZone(TimeZone.getTimeZone("Asia/Seoul"))
+            )
+            .build()
+    }
+}

src/main/kotlin/com/dobby/backend/infrastructure/database/repository/ExperimentPostCustomRepository.kt

@@ -4,6 +4,7 @@ import com.dobby.backend.domain.model.experiment.CustomFilter
 import com.dobby.backend.domain.model.experiment.Pagination
 import com.dobby.backend.infrastructure.database.entity.experiment.ExperimentPostEntity
 import org.springframework.stereotype.Repository
+import java.time.LocalDate
 
 @Repository
 interface ExperimentPostCustomRepository {
@@ -12,6 +13,7 @@ interface ExperimentPostCustomRepository {
         pagination: Pagination
     ): List<ExperimentPostEntity>?
 
+    fun updateExperimentPostStatus(currentDate : LocalDate): Long
     fun findExperimentPostsByMemberIdWithPagination(
         memberId: Long,
         pagination: Pagination,

src/main/kotlin/com/dobby/backend/infrastructure/database/repository/ExperimentPostCustomRepositoryImpl.kt

@@ -13,6 +13,7 @@ import com.querydsl.core.types.OrderSpecifier
 import com.querydsl.core.types.dsl.BooleanExpression
 import com.querydsl.jpa.impl.JPAQueryFactory
 import org.springframework.stereotype.Repository
+import java.time.LocalDate
 
 @Repository
 class ExperimentPostCustomRepositoryImpl (
@@ -87,6 +88,19 @@ class ExperimentPostCustomRepositoryImpl (
         return recruitDone?.let { post.recruitDone.eq(it) }
     }
 
+    @Override
+    override fun updateExperimentPostStatus(currentDate: LocalDate): Long {
+        val experimentPost = QExperimentPostEntity.experimentPostEntity
+
+        return jpaQueryFactory.update(experimentPost)
+            .set(experimentPost.recruitDone, true)
+            .where(
+                experimentPost.endDate.lt(currentDate)
+                    .and(experimentPost.recruitDone.eq(false))
+            )
+            .execute()
+    }
+
     private fun getOrderClause(order: String): OrderSpecifier<*> {
         val post = QExperimentPostEntity.experimentPostEntity
         return if (order == "ASC") {

src/main/kotlin/com/dobby/backend/infrastructure/gateway/experiment/ExperimentPostGatewayImpl.kt

@@ -11,6 +11,7 @@ import com.dobby.backend.infrastructure.database.repository.ExperimentPostCustom
 import com.dobby.backend.infrastructure.database.repository.ExperimentPostRepository
 import jakarta.persistence.Tuple
 import org.springframework.stereotype.Component
+import java.time.LocalDate
 
 @Component
 class ExperimentPostGatewayImpl(
@@ -56,6 +57,9 @@ class ExperimentPostGatewayImpl(
         return experimentPostRepository.countExperimentPostGroupedByRegion()
     }
 
+    override fun updateExperimentPostStatus(currentDate: LocalDate): Long {
+        return experimentPostCustomRepository.updateExperimentPostStatus(currentDate)
+    }
     override fun findExperimentPostsByMemberIdWithPagination(
         memberId: Long,
         pagination: Pagination,

src/main/kotlin/com/dobby/backend/infrastructure/scheduler/ExpiredExperimentPostJob.kt

@@ -0,0 +1,28 @@
+package com.dobby.backend.infrastructure.scheduler
+
+import com.dobby.backend.application.service.ExperimentPostService
+import com.dobby.backend.application.usecase.experiment.UpdateExpiredExperimentPostUseCase
+import org.quartz.Job
+import org.quartz.JobExecutionContext
+import org.slf4j.Logger
+import org.slf4j.LoggerFactory
+import org.springframework.stereotype.Component
+import java.time.LocalDate
+
+@Component
+class ExpiredExperimentPostJob(
+    private val experimentPostService: ExperimentPostService
+) : Job{
+    companion object {
+        private val logger : Logger = LoggerFactory.getLogger(ExpiredExperimentPostJob::class.java)
+    }
+
+    override fun execute(context: JobExecutionContext) {
+        val input = UpdateExpiredExperimentPostUseCase.Input(
+            LocalDate.now()
+        )
+        val output = experimentPostService.updateExpiredExperimentPosts(input)
+        logger.info("${output.affectedRowsCount} expired posts have been updated during scheduling jobs.")
+    }
+
+}

src/main/kotlin/com/dobby/backend/presentation/api/mapper/ExperimentPostMapper.kt

@@ -38,6 +38,7 @@ object ExperimentPostMapper {
         )
     }
 
+
     private fun toApplyMethodInfo(dto: ApplyMethodInfo): CreateExperimentPostUseCase.ApplyMethodInfo {
         return CreateExperimentPostUseCase.ApplyMethodInfo(
             content = dto.content,
@@ -55,6 +56,7 @@ object ExperimentPostMapper {
         )
     }
 
+
     private fun toImageListInfo(dto: ImageListInfo): CreateExperimentPostUseCase.ImageListInfo {
         return CreateExperimentPostUseCase.ImageListInfo(
             images = dto.images
@@ -204,8 +206,9 @@ object ExperimentPostMapper {
                 univName = output.postInfo.univName,
                 reward = output.postInfo.reward,
                 durationInfo = DurationInfo(
-                    startDate = output.postInfo.durationInfo.startDate,
-                    endDate = output.postInfo.durationInfo.endDate
+                    startDate = output.postInfo.durationInfo?.startDate,
+                    endDate = output.postInfo.durationInfo?.endDate
+
                 )
             ),
             recuritDone = output.postInfo.recruitDone

src/test/kotlin/com/dobby/backend/application/usecase/experiment/UpdateExperimentPostUseCaseTest.kt

@@ -0,0 +1,66 @@
+import com.dobby.backend.application.usecase.experiment.UpdateExpiredExperimentPostUseCase
+import com.dobby.backend.domain.gateway.experiment.ExperimentPostGateway
+import io.kotest.assertions.throwables.shouldThrow
+import io.kotest.core.spec.style.BehaviorSpec
+import io.kotest.matchers.shouldBe
+import io.mockk.clearMocks
+import io.mockk.every
+import io.mockk.mockk
+import io.mockk.verify
+import java.time.LocalDate
+
+class UpdateExperimentPostUseCaseTest : BehaviorSpec({
+
+    val experimentPostGateway = mockk<ExperimentPostGateway>()
+    val updateExpiredExperimentPostUseCase = UpdateExpiredExperimentPostUseCase(experimentPostGateway)
+
+    given("게시글이 만료되어 상태가 업데이트되는 경우") {
+        val currentDate = LocalDate.of(2025, 1, 16)
+        val input = UpdateExpiredExperimentPostUseCase.Input(currentDate)
+        every { experimentPostGateway.updateExperimentPostStatus(any()) } returns 5L
+
+        `when`("Execute를 호출하면") {
+            then("UseCase는 업데이트된 게시글 수를 반환해야 한다") {
+                val output = updateExpiredExperimentPostUseCase.execute(input)
+                output.affectedRowsCount shouldBe 5L
+                verify(exactly = 1) { experimentPostGateway.updateExperimentPostStatus(currentDate) }
+            }
+        }
+    }
+
+    given("업데이트할 게시글이 없는 경우") {
+        val currentDate = LocalDate.of(2025, 1, 17)
+        val input = UpdateExpiredExperimentPostUseCase.Input(currentDate)
+
+        // Mock 설정을 각 테스트에서 바로 적용하지 않고 초기화 시 설정
+        every { experimentPostGateway.updateExperimentPostStatus(currentDate) } returns 0L
+
+        `when`("Execute를 호출하면") {
+            then("UseCase는 0을 반환해야 한다") {
+                val output = updateExpiredExperimentPostUseCase.execute(input)
+                output.affectedRowsCount shouldBe 0L
+                verify(exactly = 1) { experimentPostGateway.updateExperimentPostStatus(currentDate) }
+            }
+        }
+    }
+
+    given("Gateway에서 예외를 던지면") {
+        val currentDate = LocalDate.of(2025, 1, 18)
+        val input = UpdateExpiredExperimentPostUseCase.Input(currentDate)
+        val exceptionMessage = "Database error"
+
+        // 예외를 던지는 Mock 설정
+        every { experimentPostGateway.updateExperimentPostStatus(currentDate) } throws RuntimeException(exceptionMessage)
+
+        `when`("Execute를 호출하면") {
+            then("UseCase는 예외를 상위로 전달해야 한다") {
+                val exception = shouldThrow<RuntimeException> {
+                    updateExpiredExperimentPostUseCase.execute(input)
+                }
+
+                exception.message shouldBe exceptionMessage
+                verify(exactly = 1) { experimentPostGateway.updateExperimentPostStatus(currentDate) }
+            }
+        }
+    }
+})