[3주차] 송금 서비스 구현

README.md

@@ -11,3 +11,4 @@
 3. 송금 후에는 계좌잔액을 노출해야 한다.
 4. 송금 내역은 5개월동안 보장되고 그 이후의 내역은 삭제되어야 한다.
 
+

build/kotlin/compileKotlin/cacheable/caches-jvm/jvm/kotlin/proto.tab.values.s

@@ -0,0 +1 @@
+�z�m�f�h�g

build/kotlin/compileKotlin/cacheable/caches-jvm/lookups/counters.tab

@@ -0,0 +1,2 @@
+76
+0

build/kotlin/compileKotlin/cacheable/caches-jvm/lookups/lookups.tab.values.s

@@ -0,0 +1 @@
+�
�
��

build/resources/main/application.yml

@@ -0,0 +1,22 @@
+spring:
+  datasource:
+    driver-class-name: org.h2.Driver
+    url: jdbc:h2:mem:testdb;NON_KEYWORDS=USER
+    username: sa
+    password:
+
+  h2:
+    console:
+      enabled: true
+      path: /h2-console
+  jpa:
+    defer-datasource-initialization: true
+    database-platform: org.hibernate.dialect.H2Dialect
+    hibernate:
+      ddl-auto: create
+    properties:
+      hibernate:
+        dialect: org.hibernate.dialect.H2Dialect
+        format_sql: true
+        show_sql: true
+        physical-naming-strategy: com.example.estpayments.config.ImprovedNamingStrategy

http/http-client.env.json

@@ -0,0 +1,5 @@
+{
+  "default": {
+    "host": "http://localhost:8080"
+  }
+}

http/request/Account.http

@@ -0,0 +1,11 @@
+### 계좌 생성
+POST {{host}}/accounts
+Content-Type: application/json
+
+{
+  "userId": 1
+}
+
+### 계좌 조회
+GET {{host}}/accounts/1
+Content-Type: application/json

http/request/Transaction.http

@@ -0,0 +1,9 @@
+### 송금
+POST {{host}}/transactions
+Content-Type: application/json
+
+{
+  "senderAccountId": 1,
+  "receiverAccountId": 2,
+  "amount": 500
+}

src/main/kotlin/com/example/estdelivery/EstPaymentsApplication.kt → src/main/kotlin/com/example/estpayments/EstPaymentsApplication.kt

@@ -1,4 +1,4 @@
-package com.example.estdelivery
+package com.example.estpayments
 
 import org.springframework.boot.autoconfigure.SpringBootApplication
 import org.springframework.boot.runApplication

src/main/kotlin/com/example/estpayments/adapter/in/web/AccountController.kt

@@ -0,0 +1,42 @@
+package com.example.estpayments.adapter.`in`.web
+
+import com.example.estpayments.adapter.`in`.web.dto.AccountCreateRequest
+import com.example.estpayments.adapter.`in`.web.dto.AccountCreateResponse
+import com.example.estpayments.adapter.`in`.web.dto.AccountResponse
+import com.example.estpayments.application.domain.model.AccountId
+import com.example.estpayments.application.port.`in`.AccountCreateUseCase
+import com.example.estpayments.application.port.`in`.AccountFindUseCase
+import com.example.estpayments.application.port.`in`.command.AccountFindCommand
+import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.PathVariable
+import org.springframework.web.bind.annotation.PostMapping
+import org.springframework.web.bind.annotation.RequestBody
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RestController
+
+@RestController
+@RequestMapping("/accounts")
+class AccountController(
+    private val accountCreateUseCase: AccountCreateUseCase,
+    private val accountFindUseCase: AccountFindUseCase
+) {
+    @PostMapping
+    fun createAccount(
+        @RequestBody accountCreateRequest: AccountCreateRequest
+    ): Result<AccountCreateResponse> =
+        Result.success(
+            AccountCreateResponse.from(
+                accountCreateUseCase.create(accountCreateRequest.toCommand())
+            )
+        )
+
+    @GetMapping("/{id}")
+    fun getAccount(
+        @PathVariable id: Long
+    ): Result<AccountResponse> =
+        Result.success(
+            AccountResponse.from(
+                accountFindUseCase.get(AccountFindCommand(AccountId(id)))
+            )
+        )
+}

src/main/kotlin/com/example/estpayments/adapter/in/web/TransactionController.kt

@@ -0,0 +1,25 @@
+package com.example.estpayments.adapter.`in`.web
+
+import com.example.estpayments.adapter.`in`.web.dto.TransactionExecuteRequest
+import com.example.estpayments.adapter.`in`.web.dto.TransactionExecuteResponse
+import com.example.estpayments.application.port.`in`.TransactionExecuteUseCase
+import org.springframework.web.bind.annotation.PostMapping
+import org.springframework.web.bind.annotation.RequestBody
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RestController
+
+@RestController
+@RequestMapping("/transactions")
+class TransactionController(
+    private val transactionExecuteUseCase: TransactionExecuteUseCase
+) {
+    @PostMapping
+    fun executeTransaction(
+        @RequestBody transactionExecuteRequest: TransactionExecuteRequest
+    ): Result<TransactionExecuteResponse> =
+        Result.success(
+            TransactionExecuteResponse.from(
+                transactionExecuteUseCase.execute(transactionExecuteRequest.toCommand())
+            )
+        )
+}

src/main/kotlin/com/example/estpayments/adapter/in/web/dto/AccountDto.kt

@@ -0,0 +1,33 @@
+package com.example.estpayments.adapter.`in`.web.dto
+
+import com.example.estpayments.application.domain.model.Account
+import com.example.estpayments.application.domain.model.UserId
+import com.example.estpayments.application.port.`in`.command.AccountCreateCommand
+
+data class AccountResponse(
+    val id: Long,
+    val userId: Long,
+    val balance: Long
+) {
+    companion object {
+        fun from(account: Account): AccountResponse =
+            AccountResponse(id = account.id.value, userId = account.userId.value, balance = account.balance.value)
+    }
+}
+
+data class AccountCreateRequest(
+    val userId: Long
+) {
+    fun toCommand(): AccountCreateCommand = AccountCreateCommand(userId = UserId(userId))
+}
+
+data class AccountCreateResponse(
+    val id: Long,
+    val userId: Long,
+    val balance: Long
+) {
+    companion object {
+        fun from(account: Account): AccountCreateResponse =
+            AccountCreateResponse(id = account.id.value, userId = account.userId.value, balance = account.balance.value)
+    }
+}

src/main/kotlin/com/example/estpayments/adapter/in/web/dto/TransactionExecuteRequest.kt

@@ -0,0 +1,27 @@
+package com.example.estpayments.adapter.`in`.web.dto
+
+import com.example.estpayments.application.domain.model.Account
+import com.example.estpayments.application.domain.model.AccountId
+import com.example.estpayments.application.domain.model.Money
+import com.example.estpayments.application.port.`in`.command.TransactionExecuteCommand
+
+data class TransactionExecuteRequest(
+    val senderAccountId: Long,
+    val receiverAccountId: Long,
+    val amount: Long
+) {
+    fun toCommand(): TransactionExecuteCommand = TransactionExecuteCommand(
+        senderAccountId = AccountId(senderAccountId),
+        receiverAccountId = AccountId(receiverAccountId),
+        amount = Money(amount)
+    )
+}
+
+data class TransactionExecuteResponse(
+    val balance: Long
+) {
+    companion object {
+        fun from(account: Account): TransactionExecuteResponse =
+            TransactionExecuteResponse(balance = account.balance.value)
+    }
+}

src/main/kotlin/com/example/estpayments/adapter/out/persistence/AccountEntity.kt

@@ -0,0 +1,21 @@
+package com.example.estpayments.adapter.out.persistence
+
+import jakarta.persistence.Entity
+import jakarta.persistence.GeneratedValue
+import jakarta.persistence.GenerationType
+import jakarta.persistence.Id
+import jakarta.persistence.Table
+
+@Entity
+@Table(name = "account")
+class AccountEntity(
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    val id: Long? = null,
+    val userId: Long,
+    var balance: Long,
+) : BaseTimeEntity() {
+    fun updateBalance(money: Long) {
+        balance = money
+    }
+}

src/main/kotlin/com/example/estpayments/adapter/out/persistence/AccountMapper.kt

@@ -0,0 +1,17 @@
+package com.example.estpayments.adapter.out.persistence
+
+import com.example.estpayments.application.domain.model.Account
+import com.example.estpayments.application.domain.model.AccountId
+import com.example.estpayments.application.domain.model.Money
+import com.example.estpayments.application.domain.model.UserId
+import com.example.estpayments.common.Constant.INITIAL_BALANCE
+
+
+object AccountMapper {
+    fun toAccount(accountEntity: AccountEntity): Account =
+        Account(
+            id = AccountId(accountEntity.id!!),
+            userId = UserId(accountEntity.userId),
+            balance = Money(INITIAL_BALANCE)
+        )
+}

src/main/kotlin/com/example/estpayments/adapter/out/persistence/AccountPersistenceAdapter.kt

@@ -0,0 +1,36 @@
+package com.example.estpayments.adapter.out.persistence
+
+import com.example.estpayments.application.domain.model.Account
+import com.example.estpayments.application.port.out.AccountCreatePort
+import com.example.estpayments.application.port.out.AccountFindPort
+import com.example.estpayments.application.port.out.AccountUpdatePort
+import com.example.estpayments.common.Constant
+import com.example.estpayments.common.annotation.PersistenceAdapter
+import org.springframework.data.repository.findByIdOrNull
+
+@PersistenceAdapter
+class AccountPersistenceAdapter(
+    private val accountRepository: AccountRepository
+) : AccountCreatePort, AccountFindPort, AccountUpdatePort {
+    override fun create(userId: Long): Account =
+        AccountMapper.toAccount(
+            accountRepository.save(
+                AccountEntity(
+                    userId = userId,
+                    balance = Constant.INITIAL_BALANCE
+                )
+            )
+        )
+
+    override fun get(id: Long): Account =
+        AccountMapper.toAccount(
+            accountRepository.findByIdOrNull(id)
+                ?: throw IllegalArgumentException("not exists account.")
+        )
+
+    override fun updateBalance(account: Account) {
+        val accountEntity = accountRepository.findByIdOrNull(account.id.value)
+            ?: throw IllegalArgumentException("not exists account.")
+        accountEntity.updateBalance(account.balance.value)
+    }
+}

src/main/kotlin/com/example/estpayments/adapter/out/persistence/AccountRepository.kt

@@ -0,0 +1,6 @@
+package com.example.estpayments.adapter.out.persistence
+
+import org.springframework.data.jpa.repository.JpaRepository
+
+interface AccountRepository : JpaRepository<AccountEntity, Long> {
+}

src/main/kotlin/com/example/estpayments/adapter/out/persistence/BaseTimeEntity.kt

@@ -0,0 +1,18 @@
+package com.example.estpayments.adapter.out.persistence
+
+import jakarta.persistence.EntityListeners
+import jakarta.persistence.MappedSuperclass
+import org.springframework.data.annotation.CreatedDate
+import org.springframework.data.annotation.LastModifiedDate
+import org.springframework.data.jpa.domain.support.AuditingEntityListener
+import java.time.LocalDateTime
+
+@MappedSuperclass
+@EntityListeners(AuditingEntityListener::class)
+abstract class BaseTimeEntity {
+    @CreatedDate
+    var createdAt: LocalDateTime? = null
+
+    @LastModifiedDate
+    var updatedAt: LocalDateTime? = null
+}

src/main/kotlin/com/example/estpayments/adapter/out/persistence/TransactionEntity.kt

@@ -0,0 +1,33 @@
+package com.example.estpayments.adapter.out.persistence
+
+import com.example.estpayments.application.domain.model.TransactionStatus
+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.Table
+import java.time.LocalDateTime
+
+@Entity
+@Table(name = "transaction")
+class TransactionEntity(
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    val id: Long? = null,
+    val senderAccountId: Long,
+    val receiverAccountId: Long,
+    val amount: Long,
+    val transactionDate: LocalDateTime,
+    @Enumerated(EnumType.STRING)
+    var status: TransactionStatus
+) : BaseTimeEntity() {
+    fun completed() {
+        status = TransactionStatus.COMPLETED
+    }
+
+    fun failed() {
+        status = TransactionStatus.FAILED
+    }
+}

src/main/kotlin/com/example/estpayments/adapter/out/persistence/TransactionMapper.kt

@@ -0,0 +1,28 @@
+package com.example.estpayments.adapter.out.persistence
+
+import com.example.estpayments.application.domain.model.AccountId
+import com.example.estpayments.application.domain.model.Money
+import com.example.estpayments.application.domain.model.Transaction
+import com.example.estpayments.application.domain.model.TransactionId
+import java.time.LocalDateTime
+
+
+object TransactionMapper {
+    fun toTransaction(transactionEntity: TransactionEntity): Transaction =
+        Transaction(
+            id = TransactionId(transactionEntity.id!!),
+            senderAccountId = AccountId(transactionEntity.senderAccountId),
+            receiverAccountId = AccountId(transactionEntity.receiverAccountId),
+            amount = Money(transactionEntity.amount),
+            transactionDate = transactionEntity.transactionDate,
+            status = transactionEntity.status
+        )
+
+    fun toTransactionEntity(transaction: Transaction) = TransactionEntity(
+        senderAccountId = transaction.senderAccountId.value,
+        receiverAccountId = transaction.receiverAccountId.value,
+        amount = transaction.amount.value,
+        status = transaction.status!!,
+        transactionDate = LocalDateTime.now()
+    )
+}