쿠폰을 잘못 발급해서 일부 쿠폰은 바로 소멸시키고 새로운 쿠폰으로 교체한다.

batch-coupon-exchang/README.md

@@ -0,0 +1,17 @@
+
+### 배치 실행 명령어
+
+```shell
+export PROD_DATASOURCE_URL=jdbc:mysql://{DB_HOST}:{DP_PORT}/batch?serverTimezone=Asia/Seoul
+export PROD_DATASOURCE_USERNAME={USERNAME}
+export PROD_DATASOURCE_PASSWORD={PASSWORD}
+
+java -jar batch-coupon-exchang/build/libs/batch-coupon-exchang-1.0-SNAPSHOT.jar  \
+--spring.profiles.active=prod \
+name='100% 할인 보상 쿠폰' \
+description='배송 오류로 인한 쿠폰 교환' \
+amountType='RATE' \
+amount=100 \
+expiredCouponId=13
+```
+

batch-coupon-exchang/build.gradle.kts

@@ -0,0 +1,29 @@
+group = "com.example.estdelivery"
+version = "1.0-SNAPSHOT"
+
+tasks.withType<Jar> {
+    enabled = true
+}
+
+repositories {
+    mavenCentral()
+}
+
+dependencies {
+    runtimeOnly("com.mysql:mysql-connector-j")
+    implementation("org.springframework.boot:spring-boot-starter-batch")
+    testImplementation("org.springframework.batch:spring-batch-test")
+    testImplementation("org.springframework.boot:spring-boot-testcontainers")
+    implementation("org.springframework.cloud:spring-cloud-starter-openfeign")
+    testImplementation("org.testcontainers:mysql")
+    testImplementation("org.testcontainers:junit-jupiter")
+    testImplementation("com.navercorp.fixturemonkey:fixture-monkey-starter-kotlin:1.0.16")
+}
+
+tasks.test {
+    useJUnitPlatform()
+}
+
+kotlin {
+    jvmToolchain(17)
+}

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/BatchConfiguration.kt

@@ -0,0 +1,25 @@
+package com.example.estdelivery
+
+import javax.sql.DataSource
+import org.springframework.batch.core.configuration.support.DefaultBatchConfiguration
+import org.springframework.context.annotation.Configuration
+import org.springframework.transaction.PlatformTransactionManager
+
+
+/**
+ * datasource 를 빈으로 등록하고 EnableBatchProcessing 애너테이션을 사용하면 순환 의존성으로 인해 datasource 를 외부에서 주입받기 어렵다.
+ * DefaultBatchConfiguration 로 의존성을 주입하자.
+ */
+@Configuration
+class BatchConfiguration(
+    private val dataSource: DataSource,
+    private val transactionManager: PlatformTransactionManager,
+) : DefaultBatchConfiguration() {
+    override fun getDataSource(): DataSource {
+        return dataSource
+    }
+
+    override fun getTransactionManager(): PlatformTransactionManager {
+        return transactionManager
+    }
+}

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/ChunkSizeProperty.kt

@@ -0,0 +1,10 @@
+package com.example.estdelivery
+
+import org.springframework.boot.context.properties.ConfigurationProperties
+
+@ConfigurationProperties(prefix = "batch.chunk")
+data class ChunkSizeProperty(
+    val commitSize: Int,
+    val processSize: Int,
+    val writeSize: Int,
+)

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/CouponExchangeApplication.kt

@@ -0,0 +1,15 @@
+package com.example.estdelivery
+
+import org.springframework.boot.autoconfigure.SpringBootApplication
+import org.springframework.boot.context.properties.EnableConfigurationProperties
+import org.springframework.boot.runApplication
+
+@SpringBootApplication
+@EnableConfigurationProperties(
+    ChunkSizeProperty::class
+)
+class CouponExchangeApplication
+
+fun main(args: Array<String>) {
+    runApplication<CouponExchangeApplication>(*args)
+}

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/FeignClientConfig.kt

@@ -0,0 +1,10 @@
+package com.example.estdelivery
+
+import org.springframework.cloud.openfeign.EnableFeignClients
+import org.springframework.context.annotation.Configuration
+import org.springframework.context.annotation.Profile
+
+@Configuration
+@Profile("!test")
+@EnableFeignClients
+class FeignClientConfig

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/JpaConfiguration.kt

@@ -0,0 +1,10 @@
+package com.example.estdelivery
+
+import org.springframework.context.annotation.Configuration
+import org.springframework.data.jpa.repository.config.EnableJpaRepositories
+
+@Configuration
+@EnableJpaRepositories(
+    basePackages = ["com.example.estdelivery.job.step.service.repository"]
+)
+class JpaConfiguration

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/RunnerConfiguration.kt

@@ -0,0 +1,39 @@
+package com.example.estdelivery
+
+import org.springframework.batch.core.explore.JobExplorer
+import org.springframework.batch.core.launch.JobLauncher
+import org.springframework.batch.core.repository.JobRepository
+import org.springframework.boot.autoconfigure.batch.BatchProperties
+import org.springframework.boot.autoconfigure.batch.JobLauncherApplicationRunner
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty
+import org.springframework.boot.context.properties.EnableConfigurationProperties
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.util.StringUtils
+
+/**
+ * CommandLineRunner 를 이용하면 spring boot 가 제공하는 기본 기능을 이용할 수 없다.
+ * 예를 들어 JPA 관련 설정 DB 관련 설정이다. 이런 auto configure 가 필요없다면 해당 클래스를 직접 생성하지 않아도 된다.
+ */
+@Configuration
+@EnableConfigurationProperties(BatchProperties::class)
+class RunnerConfiguration {
+
+    @Bean
+    @ConditionalOnMissingBean
+    @ConditionalOnProperty(prefix = "spring.batch.job", name = ["enabled"])
+    fun jobLauncherApplicationRunner(
+        jobLauncher: JobLauncher,
+        jobExplorer: JobExplorer,
+        jobRepository: JobRepository,
+        properties: BatchProperties
+    ): JobLauncherApplicationRunner {
+        val runner = JobLauncherApplicationRunner(jobLauncher, jobExplorer, jobRepository)
+        val jobNames = properties.job.name
+        if (StringUtils.hasText(jobNames)) {
+            runner.setJobName(jobNames)
+        }
+        return runner
+    }
+}

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/client/AlimTalkClient.kt

@@ -0,0 +1,5 @@
+package com.example.estdelivery.client
+
+interface AlimTalkClient {
+    fun sendAlimTalk(alimTalkRequest: AlimTalkRequest)
+}

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/client/AlimTalkFeignClient.kt

@@ -0,0 +1,15 @@
+package com.example.estdelivery.client
+
+import org.springframework.cloud.openfeign.FeignClient
+import org.springframework.web.bind.annotation.PostMapping
+import org.springframework.web.bind.annotation.RequestBody
+
+
+@FeignClient(
+    name = "alim",
+    url = "http://localhost:8090"
+)
+interface AlimTalkFeignClient : AlimTalkClient {
+    @PostMapping("/alim")
+    override fun sendAlimTalk(@RequestBody alimTalkRequest: AlimTalkRequest)
+}

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/client/AlimTalkRequest.kt

@@ -0,0 +1,6 @@
+package com.example.estdelivery.client
+
+data class AlimTalkRequest(
+    val sender: String,
+    val message: String,
+)

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/client/MemberClient.kt

@@ -0,0 +1,5 @@
+package com.example.estdelivery.client
+
+interface MemberClient{
+    fun findMemberById(memberId: Long): MemberResponse
+}

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/client/MemberFeignClient.kt

@@ -0,0 +1,14 @@
+package com.example.estdelivery.client
+
+import org.springframework.cloud.openfeign.FeignClient
+import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.PathVariable
+
+@FeignClient(
+    name = "member",
+    url = "http://localhost:8081"
+)
+interface MemberFeignClient : MemberClient {
+    @GetMapping("/members/{memberId}")
+    override fun findMemberById(@PathVariable memberId: Long): MemberResponse
+}

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/client/MemberResponse.kt

@@ -0,0 +1,9 @@
+package com.example.estdelivery.client
+
+import com.example.estdelivery.domain.PhoneNumber
+import com.example.estdelivery.domain.UserName
+
+data class MemberResponse(
+    val phone: PhoneNumber,
+    val name: UserName,
+)

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/domain/Coupon.kt

@@ -0,0 +1,42 @@
+package com.example.estdelivery.domain
+
+import jakarta.persistence.Entity
+import jakarta.persistence.EnumType
+import jakarta.persistence.Enumerated
+import jakarta.persistence.GeneratedValue
+import jakarta.persistence.GenerationType
+import jakarta.persistence.Id
+import jakarta.persistence.NamedQuery
+import jakarta.persistence.Table
+
+@Entity
+@NamedQuery(
+    name = "couponFinaAll",
+    query = "SELECT c FROM Coupon c"
+)
+@Table(name = "coupon", catalog = "coupon")
+class Coupon(
+    val name: String,
+    val description: String,
+    @Enumerated(EnumType.STRING)
+    val amountType: CouponStateAmountType,
+    @Enumerated(EnumType.STRING)
+    val type: CouponStateType,
+    val amount: Int,
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    val id: Long = 0,
+) {
+    override fun equals(other: Any?): Boolean {
+        if (this === other) return true
+        if (other !is Coupon) return false
+
+        if (id != other.id) return false
+
+        return true
+    }
+
+    override fun hashCode(): Int {
+        return id.hashCode()
+    }
+}

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/domain/CouponExchangeNotificationTemplate.kt

@@ -0,0 +1,21 @@
+package com.example.estdelivery.domain
+
+data class CouponExchangeNotificationTemplate(
+    private val receivingPhoneNumber: PhoneNumber,
+    private val receivingName: UserName,
+    private val couponNameBeforeExchange: String,
+    private val couponNameAfterExchange: String,
+) {
+    val sendMessage: String
+        get(): String = """
+            [이스트딜리버리]
+            ${receivingName}님, 보관중인 쿠폰에 문제가 생겨 다음과 같이 변경됩니다.
+
+            사유 : ${receivingName}님의 쿠폰이 만료되었습니다.
+            변경 전 쿠폰 : $couponNameBeforeExchange
+            변경 후 쿠폰 : $couponNameAfterExchange
+            """.trimIndent()
+
+    val sender: String
+        get(): String = receivingPhoneNumber.number
+}

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/domain/CouponStateAmountType.kt

@@ -0,0 +1,6 @@
+package com.example.estdelivery.domain
+
+enum class CouponStateAmountType {
+    RATE,
+    FIX,
+}

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/domain/CouponStateType.kt

@@ -0,0 +1,10 @@
+package com.example.estdelivery.domain
+
+enum class CouponStateType {
+    PUBLISHED,
+    HANDOUT,
+    EVENT,
+    EXPIRED,
+    REWARD,
+    ;
+}

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/domain/ExchangeCoupon.kt

@@ -0,0 +1,7 @@
+package com.example.estdelivery.domain
+
+class ExchangeCoupon(
+    val owner: UserName,
+    val ownerPhone: PhoneNumber,
+    val memberCoupon: MemberCoupon,
+)

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/domain/ExchangeCouponHistory.kt

@@ -0,0 +1,18 @@
+package com.example.estdelivery.domain
+
+import jakarta.persistence.Entity
+import jakarta.persistence.GeneratedValue
+import jakarta.persistence.GenerationType
+import jakarta.persistence.Id
+import jakarta.persistence.Table
+
+@Entity
+@Table(name = "exchange_coupon_history", catalog = "coupon")
+class ExchangeCouponHistory(
+    val expiredCouponId: Long,
+    val rewardCouponId: Long,
+    val jobExecutionId: Long,
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    val id: Long = 0,
+)

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/domain/MemberCoupon.kt

@@ -0,0 +1,55 @@
+package com.example.estdelivery.domain
+
+import com.example.estdelivery.domain.MemberCouponUseState.UNUSED
+import jakarta.persistence.Entity
+import jakarta.persistence.EnumType
+import jakarta.persistence.Enumerated
+import jakarta.persistence.GeneratedValue
+import jakarta.persistence.GenerationType
+import jakarta.persistence.Id
+import jakarta.persistence.NamedQuery
+import jakarta.persistence.Table
+
+const val UNUSED_MEMBER_COUPON_FIND_ALL = "unusedMemberCouponFinaAll"
+
+@Entity
+@NamedQuery(
+    name = UNUSED_MEMBER_COUPON_FIND_ALL,
+    query = """
+        SELECT c 
+        FROM MemberCoupon c 
+        WHERE c.couponId = :couponId
+        """
+)
+@Table(name = "member_coupon", catalog = "coupon")
+class MemberCoupon(
+    val couponId: Long,
+    val memberId: Long,
+    @Enumerated(EnumType.STRING)
+    var status: MemberCouponUseState = UNUSED,
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    val id: Long = 0,
+) {
+    override fun equals(other: Any?): Boolean {
+        if (this === other) return true
+        if (other !is MemberCoupon) return false
+
+        if (other.id == 0L) return false
+        if (id != other.id) return false
+
+        return true
+    }
+
+    override fun hashCode(): Int {
+        return id.hashCode()
+    }
+
+    fun exchange(exchangedCouponId: Long): MemberCoupon {
+        return MemberCoupon(
+            couponId = exchangedCouponId,
+            memberId = memberId,
+            id = id,
+        )
+    }
+}

batch-coupon-exchang/src/main/kotlin/com/example/estdelivery/domain/MemberCouponUseState.kt

@@ -0,0 +1,7 @@
+package com.example.estdelivery.domain
+
+enum class MemberCouponUseState {
+    USED,
+    UNUSED,
+    ;
+}