🔀 :: (entry-238) application fullback method추가

application-domain/src/main/kotlin/hs/kr/equus/application/domain/application/spi/ApplicationQueryUserPort.kt

@@ -1,8 +1,11 @@
 package hs.kr.equus.application.domain.application.spi
 
 import hs.kr.equus.application.domain.user.model.User
+import hs.kr.equus.application.domain.user.model.UserCache
 import java.util.UUID
 
 interface ApplicationQueryUserPort {
-    fun queryUserByUserId(userId: UUID): User
+    fun queryUserByUserId(userId: UUID): User?
+
+    fun queryUserByUserIdInCache(userId: UUID): UserCache?
 }

application-domain/src/main/kotlin/hs/kr/equus/application/domain/user/model/UserCache.kt

@@ -0,0 +1,13 @@
+package hs.kr.equus.application.domain.user.model
+
+import java.util.*
+
+data class UserCache (
+    val id: UUID,
+    val phoneNumber: String,
+    val name: String,
+    val isParent: Boolean,
+    val receiptCode: Long?,
+    val role: String,
+    val ttl: Long
+)

application-infrastructure/src/main/kotlin/hs/kr/equus/application/domain/user/domain/UserPersistenceAdapter.kt

@@ -1,6 +1,8 @@
 package hs.kr.equus.application.domain.user.domain
 
+import hs.kr.equus.application.domain.user.domain.repository.UserCacheRepository
 import hs.kr.equus.application.domain.user.model.User
+import hs.kr.equus.application.domain.user.model.UserCache
 import hs.kr.equus.application.domain.user.spi.UserPort
 import hs.kr.equus.application.global.feign.client.UserClient
 import org.springframework.stereotype.Component
@@ -9,15 +11,31 @@ import java.util.UUID
 @Component
 class UserPersistenceAdapter(
     private val userClient: UserClient,
+    private val userCacheRepository: UserCacheRepository
 ) : UserPort {
-    override fun queryUserByUserId(userId: UUID): User {
-        return userClient.getUserInfoByUserId(userId).run {
+    override fun queryUserByUserId(userId: UUID): User? {
+        return userClient.getUserInfoByUserId(userId)?.let {
             User(
-                id = id,
-                phoneNumber = phoneNumber,
-                name = name,
-                isParent = isParent,
+                id = it.id,
+                phoneNumber = it.phoneNumber,
+                name = it.name,
+                isParent = it.isParent,
             )
         }
     }
+
+    override fun queryUserByUserIdInCache(userId: UUID): UserCache? {
+        return userCacheRepository.findById(userId)
+            .map {
+                UserCache(
+                    id = it.id,
+                    phoneNumber = it.phoneNumber,
+                    name = it.name,
+                    isParent = it.isParent,
+                    receiptCode = it.receiptCode,
+                    role = it.role.name,
+                    ttl = it.ttl
+                )
+            }.orElse(null)
+    }
 }

application-infrastructure/src/main/kotlin/hs/kr/equus/application/domain/user/domain/entity/UserCacheRedisEntity.kt

@@ -0,0 +1,20 @@
+package hs.kr.equus.application.domain.user.domain.entity
+
+import hs.kr.equus.application.global.security.jwt.UserRole
+import org.springframework.data.annotation.Id
+import org.springframework.data.redis.core.RedisHash
+import org.springframework.data.redis.core.TimeToLive
+import java.util.*
+
+@RedisHash(value = "status_cache")
+class UserCacheRedisEntity (
+    @Id
+    val id: UUID,
+    val phoneNumber: String,
+    val name: String,
+    val isParent: Boolean,
+    val receiptCode: Long?,
+    val role: UserRole,
+    @TimeToLive
+    val ttl: Long
+)

application-infrastructure/src/main/kotlin/hs/kr/equus/application/domain/user/domain/repository/UserCacheRepository.kt

@@ -0,0 +1,8 @@
+package hs.kr.equus.application.domain.user.domain.repository
+
+import hs.kr.equus.application.domain.user.domain.entity.UserCacheRedisEntity
+import org.springframework.data.repository.CrudRepository
+import java.util.UUID
+
+interface UserCacheRepository : CrudRepository<UserCacheRedisEntity, UUID> {
+}

application-infrastructure/src/main/kotlin/hs/kr/equus/application/global/feign/client/UserClient.kt

@@ -1,15 +1,48 @@
 package hs.kr.equus.application.global.feign.client
 
+import hs.kr.equus.application.domain.status.spi.StatusPort
+import hs.kr.equus.application.domain.user.model.UserCache
+import hs.kr.equus.application.domain.user.spi.UserPort
+import hs.kr.equus.application.global.feign.client.dto.response.StatusInfoElement
 import hs.kr.equus.application.global.feign.client.dto.response.UserInfoElement
+import hs.kr.equus.application.global.security.jwt.UserRole
 import org.springframework.cloud.openfeign.FeignClient
+import org.springframework.context.annotation.Lazy
+import org.springframework.stereotype.Component
 import org.springframework.web.bind.annotation.GetMapping
 import org.springframework.web.bind.annotation.PathVariable
 import java.util.UUID
 
-@FeignClient(name = "UserClient", url = "\${url.user}")
+@FeignClient(name = "UserClient", url = "\${url.user}", fallback = UserFallBack::class)
 interface UserClient {
     @GetMapping("/user/{userId}")
     fun getUserInfoByUserId(
         @PathVariable("userId") userId: UUID,
-    ): UserInfoElement
+    ): UserInfoElement?
+
+}
+
+@Component
+class UserFallBack(
+    @Lazy private val userPort: UserPort
+) : UserClient {
+
+    override fun getUserInfoByUserId(userId: UUID): UserInfoElement? {
+        val user = userPort.queryUserByUserIdInCache(userId)
+        return user?.let {
+            UserInfoElement(
+                id = it.id,
+                isParent = it.isParent,
+                phoneNumber = it.phoneNumber,
+                name = it.name,
+                role = UserRole.valueOf(it.role)
+            )
+        } ?: UserInfoElement(
+            id = userId,
+            phoneNumber = "",
+            name = "",
+            isParent = false,
+            role = UserRole.USER
+        )
+    }
 }