[기능 구현] 가게 상태 변경 기능 구현(issue#72)

mealkitary-api/src/main/kotlin/com/mealkitary/shop/web/UpdateShopStatusController.kt

@@ -0,0 +1,22 @@
+package com.mealkitary.shop.web
+
+import com.mealkitary.shop.application.port.input.UpdateShopStatusUseCase
+import org.springframework.http.ResponseEntity
+import org.springframework.web.bind.annotation.PathVariable
+import org.springframework.web.bind.annotation.PostMapping
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RestController
+
+@RestController
+@RequestMapping("/shops")
+class UpdateShopStatusController(
+    private val updateShopStatusUseCase: UpdateShopStatusUseCase
+) {
+
+    @PostMapping("/{shopId}/status")
+    fun updateShopStatus(@PathVariable("shopId") shopId: Long): ResponseEntity<Unit> {
+        updateShopStatusUseCase.update(shopId)
+
+        return ResponseEntity.noContent().build()
+    }
+}

mealkitary-api/src/test/kotlin/com/mealkitary/WebIntegrationTestSupport.kt

@@ -14,9 +14,11 @@ import com.mealkitary.reservation.web.ReserveProductController
 import com.mealkitary.shop.application.port.input.GetProductQuery
 import com.mealkitary.shop.application.port.input.GetReservableTimeQuery
 import com.mealkitary.shop.application.port.input.GetShopQuery
+import com.mealkitary.shop.application.port.input.UpdateShopStatusUseCase
 import com.mealkitary.shop.web.GetProductController
 import com.mealkitary.shop.web.GetReservableTimeController
 import com.mealkitary.shop.web.GetShopController
+import com.mealkitary.shop.web.UpdateShopStatusController
 import com.ninjasquad.springmockk.MockkBean
 import io.kotest.core.spec.style.AnnotationSpec
 import io.kotest.extensions.spring.SpringExtension
@@ -33,7 +35,8 @@ import org.springframework.test.web.servlet.MockMvc
         GetReservationController::class,
         GetShopController::class,
         GetReservableTimeController::class,
-        GetProductController::class
+        GetProductController::class,
+        UpdateShopStatusController::class
     ]
 )
 abstract class WebIntegrationTestSupport : AnnotationSpec() {
@@ -69,4 +72,7 @@ abstract class WebIntegrationTestSupport : AnnotationSpec() {
 
     @MockkBean
     protected lateinit var getProductQuery: GetProductQuery
+
+    @MockkBean
+    protected lateinit var updateShopStatusUseCase: UpdateShopStatusUseCase
 }

mealkitary-api/src/test/kotlin/com/mealkitary/shop/web/UpdateShopStatusControllerTest.kt

@@ -0,0 +1,20 @@
+package com.mealkitary.shop.web
+
+import com.mealkitary.WebIntegrationTestSupport
+import io.mockk.every
+import org.springframework.test.web.servlet.request.MockMvcRequestBuilders
+import org.springframework.test.web.servlet.result.MockMvcResultMatchers
+
+class UpdateShopStatusControllerTest : WebIntegrationTestSupport() {
+
+    @Test
+    fun `api integration test - updateShopStatus`() {
+        val shopId = 1L
+        every { updateShopStatusUseCase.update(any()) } answers {}
+
+        mvc.perform(
+            MockMvcRequestBuilders.post("/shops/{shopId}/status", shopId)
+        )
+            .andExpect(MockMvcResultMatchers.status().isNoContent)
+    }
+}

mealkitary-application/src/main/kotlin/com/mealkitary/shop/application/port/input/UpdateShopStatusUseCase.kt

@@ -0,0 +1,6 @@
+package com.mealkitary.shop.application.port.input
+
+interface UpdateShopStatusUseCase {
+
+    fun update(shopId: Long)
+}

mealkitary-application/src/main/kotlin/com/mealkitary/shop/application/port/output/ShopPersistencePort.kt

@@ -0,0 +1,10 @@
+package com.mealkitary.shop.application.port.output
+
+import com.mealkitary.shop.domain.shop.Shop
+
+interface ShopPersistencePort {
+
+    fun loadOneShopById(shopId: Long): Shop
+
+    fun hasReservations(shopId: Long): Boolean
+}

mealkitary-application/src/main/kotlin/com/mealkitary/shop/application/service/UpdateShopStatusService.kt

@@ -0,0 +1,41 @@
+package com.mealkitary.shop.application.service
+
+import com.mealkitary.shop.application.port.input.UpdateShopStatusUseCase
+import com.mealkitary.shop.application.port.output.ShopPersistencePort
+import com.mealkitary.shop.domain.shop.Shop
+import org.springframework.stereotype.Service
+import org.springframework.transaction.annotation.Transactional
+
+@Service
+@Transactional
+class UpdateShopStatusService(
+    private val shopPersistencePort: ShopPersistencePort,
+) : UpdateShopStatusUseCase {
+
+    override fun update(shopId: Long) {
+        val shop = findShopById(shopId)
+
+        if (shop.status.isValidStatus()) {
+            checkReservationByShopId(shopId)
+        }
+        updateStatus(shop)
+    }
+
+    private fun findShopById(shopId: Long): Shop {
+        return shopPersistencePort.loadOneShopById(shopId)
+    }
+
+    private fun updateStatus(shop: Shop) {
+        if (shop.status.isValidStatus()) {
+            shop.changeStatusInvalid()
+        } else {
+            shop.changeStatusValid()
+        }
+    }
+
+    private fun checkReservationByShopId(shopId: Long) {
+        if (shopPersistencePort.hasReservations(shopId)) {
+            throw IllegalStateException("예약이 존재할 경우 가게 상태를 INVALID로 변경할 수 없습니다.")
+        }
+    }
+}

mealkitary-application/src/test/kotlin/com/mealkitary/shop/application/service/UpdateShopStatusServiceTest.kt

@@ -0,0 +1,70 @@
+package com.mealkitary.shop.application.service
+
+import com.mealkitary.shop.application.port.output.ShopPersistencePort
+import com.mealkitary.shop.domain.shop.Shop
+import com.mealkitary.shop.domain.shop.ShopStatus
+import io.kotest.assertions.throwables.shouldThrow
+import io.kotest.core.spec.style.AnnotationSpec
+import io.kotest.matchers.shouldBe
+import io.mockk.every
+import io.mockk.mockk
+
+class UpdateShopStatusServiceTest : AnnotationSpec() {
+
+    private val shopPersistencePort = mockk<ShopPersistencePort>()
+    private val updateShopStatusService = UpdateShopStatusService(shopPersistencePort)
+
+    @Test
+    fun `service unit test - 가게의 상태를 INVALID로 변경한다`() {
+        val shopId = 1L
+        val validShop = Shop(
+            "제목",
+            ShopStatus.VALID,
+            mutableListOf(),
+            mutableListOf()
+        )
+
+        every { shopPersistencePort.loadOneShopById(shopId) } returns validShop
+        every { shopPersistencePort.hasReservations(shopId) } returns false
+
+        updateShopStatusService.update(shopId)
+
+        validShop.status shouldBe ShopStatus.INVALID
+    }
+
+    @Test
+    fun `service unit test - 가게의 상태를 VALID로 변경한다`() {
+        val shopId = 1L
+        val validShop = Shop(
+            "제목",
+            ShopStatus.INVALID,
+            mutableListOf(),
+            mutableListOf()
+        )
+
+        every { shopPersistencePort.loadOneShopById(shopId) } returns validShop
+        every { shopPersistencePort.hasReservations(shopId) } returns false
+
+        updateShopStatusService.update(shopId)
+
+        validShop.status shouldBe ShopStatus.VALID
+    }
+
+    @Test
+    fun `service unit test - 가게의 상태를 INVALID로 변경할 때, 예약이 존재하면 예외가 발생한다`() {
+        val shopId = 1L
+        val validShop = Shop(
+            "제목",
+            ShopStatus.VALID,
+            mutableListOf(),
+            mutableListOf()
+        )
+
+        every { shopPersistencePort.loadOneShopById(shopId) } returns validShop
+        every { shopPersistencePort.hasReservations(shopId) } returns true
+
+        shouldThrow<IllegalStateException> {
+            updateShopStatusService.update(shopId)
+        }
+    }
+}

mealkitary-domain/src/main/kotlin/com/mealkitary/shop/domain/shop/Shop.kt

@@ -82,4 +82,12 @@ class Shop(
         val match = reservableTimes.filter { it == reserveAt.toLocalTime() }
         return match.isNotEmpty()
     }
+
+    fun changeStatusValid() {
+        status = ShopStatus.VALID
+    }
+
+    fun changeStatusInvalid() {
+        status = ShopStatus.INVALID
+    }
 }

mealkitary-domain/src/main/kotlin/com/mealkitary/shop/domain/shop/ShopStatus.kt

@@ -8,4 +8,8 @@ enum class ShopStatus {
     fun isInvalidStatus(): Boolean {
         return this == INVALID
     }
+
+    fun isValidStatus(): Boolean {
+        return this == VALID
+    }
 }

mealkitary-domain/src/test/kotlin/com/mealkitary/shop/domain/shop/ShopStatusTest.kt

@@ -0,0 +1,22 @@
+package com.mealkitary.shop.domain.shop
+
+import data.ShopTestData.Companion.defaultShop
+import io.kotest.matchers.shouldBe
+import org.junit.jupiter.api.Test
+
+class ShopStatusTest {
+
+    @Test
+    fun isInvalidStatus() {
+        val shop = defaultShop().withStatus(ShopStatus.VALID).build()
+
+        shop.status.isValidStatus() shouldBe true
+    }
+
+    @Test
+    fun isValidStatus() {
+        val shop = defaultShop().withStatus(ShopStatus.INVALID).build()
+
+        shop.status.isInvalidStatus() shouldBe true
+    }
+}

mealkitary-domain/src/test/kotlin/com/mealkitary/shop/domain/shop/ShopTest.kt

@@ -5,10 +5,31 @@ import data.ShopTestData.Companion.defaultShop
 import io.kotest.assertions.throwables.shouldThrow
 import io.kotest.core.spec.style.AnnotationSpec
 import io.kotest.inspectors.forAll
+import io.kotest.matchers.shouldBe
 import io.kotest.matchers.throwable.shouldHaveMessage
 
 class ShopTest : AnnotationSpec() {
 
+    @Test
+    fun `가게 상태를 VALID로 변경한다`() {
+        val sut = defaultShop().withStatus(ShopStatus.INVALID)
+            .build()
+
+        sut.changeStatusValid()
+
+        sut.status shouldBe ShopStatus.VALID
+    }
+
+    @Test
+    fun `가게 상태를 INVALID로 변경한다`() {
+        val sut = defaultShop().withStatus(ShopStatus.VALID)
+            .build()
+
+        sut.changeStatusInvalid()
+
+        sut.status shouldBe ShopStatus.INVALID
+    }
+
     @Test
     fun `유효하지 않은 가게라면 예외를 발생한다`() {
         val sut = defaultShop().withStatus(ShopStatus.INVALID)

mealkitary-infrastructure/adapter-persistence-spring-data-jpa/src/main/kotlin/com/mealkitary/reservation/persistence/ReservationRepository.kt

@@ -12,4 +12,6 @@ interface ReservationRepository : JpaRepository<Reservation, UUID> {
     fun findOneWithShopById(reservationId: UUID): Optional<Reservation>
 
     fun findAllByShopId(shopId: Long): List<Reservation>
+
+    fun existsReservationByShopId(shopId: Long): Boolean
 }

mealkitary-infrastructure/adapter-persistence-spring-data-jpa/src/main/kotlin/com/mealkitary/shop/persistence/SpringDataJpaShopPersistenceAdapter.kt

@@ -1,9 +1,11 @@
 package com.mealkitary.shop.persistence
 
 import com.mealkitary.common.exception.EntityNotFoundException
+import com.mealkitary.reservation.persistence.ReservationRepository
 import com.mealkitary.shop.application.port.output.LoadProductPort
 import com.mealkitary.shop.application.port.output.LoadReservableTimePort
 import com.mealkitary.shop.application.port.output.LoadShopPort
+import com.mealkitary.shop.application.port.output.ShopPersistencePort
 import com.mealkitary.shop.domain.shop.Shop
 import org.springframework.stereotype.Repository
 import java.util.Optional
@@ -14,7 +16,8 @@ private const val NOT_FOUND_SHOP_MESSAGE = "존재하지 않는 가게입니다.
 @Repository
 class SpringDataJpaShopPersistenceAdapter(
     private val shopRepository: ShopRepository,
-) : LoadShopPort, LoadProductPort, LoadReservableTimePort {
+    private val reservationRepository: ReservationRepository
+) : LoadShopPort, LoadProductPort, LoadReservableTimePort, ShopPersistencePort {
 
     override fun loadAllShop(): List<Shop> = shopRepository.findAll()
 
@@ -26,6 +29,10 @@ class SpringDataJpaShopPersistenceAdapter(
     override fun loadAllReservableTimeByShopId(shopId: Long) =
         getShopOrThrow(shopRepository::findOneWithReservableTimesById, shopId).reservableTimes
 
+    override fun hasReservations(shopId: Long): Boolean {
+        return reservationRepository.existsReservationByShopId(shopId)
+    }
+
     private fun getShopOrThrow(queryMethod: Function<Long, Optional<Shop>>, shopId: Long): Shop {
         return (queryMethod.apply(shopId).orElseThrow { throw EntityNotFoundException(NOT_FOUND_SHOP_MESSAGE) })
     }

mealkitary-infrastructure/adapter-persistence-spring-data-jpa/src/main/resources/data.sql

@@ -45,3 +45,13 @@ insert into reservable_time
 values (3, '20:00');
 insert into reservable_time
 values (3, '23:30');
+
+
+insert into shop
+values (4, 'VALID', '집밥뚝딱 다산점');
+insert into product
+values (10, '김치찌개', 15800, 4);
+insert into reservable_time
+values (4, '16:30');
+insert into reservation (id, shop_id, reserve_at, reservation_status)
+values ('c1e170e4-57e4-4d7d-8c10-6f4a8c658020', 4, '2023-09-22T16:30:00', 'NOTPAID');

mealkitary-infrastructure/adapter-persistence-spring-data-jpa/src/test/kotlin/com/mealkitary/PersistenceIntegrationTestSupport.kt

@@ -3,6 +3,7 @@ package com.mealkitary
 import com.mealkitary.reservation.application.service.AcceptReservationService
 import com.mealkitary.reservation.application.service.PayReservationService
 import com.mealkitary.reservation.application.service.RejectReservationService
+import com.mealkitary.shop.application.service.UpdateShopStatusService
 import com.ninjasquad.springmockk.MockkBean
 import io.kotest.core.spec.style.AnnotationSpec
 import io.kotest.extensions.spring.SpringExtension
@@ -32,4 +33,7 @@ abstract class PersistenceIntegrationTestSupport : AnnotationSpec() {
 
     @MockkBean
     private lateinit var rejectReservationService: RejectReservationService
+
+    @MockkBean
+    private lateinit var updateShopStatusService: UpdateShopStatusService
 }

mealkitary-infrastructure/adapter-persistence-spring-data-jpa/src/test/kotlin/com/mealkitary/shop/persistence/SpringDataJpaShopPersistenceAdapterTest.kt

@@ -14,11 +14,18 @@ class SpringDataJpaShopPersistenceAdapterTest(
     private val adapterUnderTest: SpringDataJpaShopPersistenceAdapter,
 ) : PersistenceIntegrationTestSupport() {
 
+    @Test
+    fun `db integration test - 가게에 예약이 존재하는지 확인한다`() {
+        val existsReservation = adapterUnderTest.hasReservations(4L)
+
+        existsReservation.shouldBeTrue()
+    }
+
     @Test
     fun `db integration test - 모든 가게를 조회한다`() {
         val shops = adapterUnderTest.loadAllShop()
 
-        shops.size shouldBe 3
+        shops.size shouldBe 4
         shops.get(0).title shouldBe "집밥뚝딱 철산점"
     }
 
@@ -94,6 +101,8 @@ class SpringDataJpaShopPersistenceAdapterTest(
 
     @Test
     fun `db integration test - 가게가 하나도 존재하지 않는 경우 빈 배열을 반환한다 `() {
+        em.createQuery("delete from Reservation r")
+            .executeUpdate()
         em.createQuery("delete from Product p")
             .executeUpdate()
         em.createNativeQuery("delete from reservable_time")