feat ( #9 ) : persistence 레이어 추가

Author: qkrwndnjs1075

casper-user/src/main/kotlin/hs/kr/entrydsm/user/domain/user/adapter/out/persistence/UserPersistenceAdapter.kt

@@ -0,0 +1,95 @@
+package hs.kr.entrydsm.user.domain.user.adapter.out.persistence
+
+import hs.kr.entrydsm.user.domain.user.adapter.out.mapper.UserMapper
+import hs.kr.entrydsm.user.domain.user.adapter.out.persistence.repository.UserRepository
+import hs.kr.entrydsm.user.domain.user.application.port.out.UserPort
+import hs.kr.entrydsm.user.domain.user.model.User
+import hs.kr.entrydsm.user.global.utils.encryption.EncryptionUtil
+import hs.kr.entrydsm.user.global.utils.encryption.HashUtil
+import org.springframework.data.repository.findByIdOrNull
+import org.springframework.stereotype.Component
+import java.time.LocalDateTime
+import java.util.UUID
+
+/**
+ * 사용자 데이터의 영속성 처리를 담당하는 어댑터 클래스입니다.
+ * 헥사고날 아키텍처의 Driven Adapter 역할을 하며, 도메인 계층의 UserPort를 구현합니다.
+ *
+ * @property userRepository JPA 기반 사용자 데이터 저장소
+ * @property userMapper 도메인 모델과 JPA 엔티티 간 변환 매퍼
+ * @property encryptionUtil 민감한 데이터 암호화 유틸리티
+ */
+@Component
+class UserPersistenceAdapter(
+    private val userRepository: UserRepository,
+    private val userMapper: UserMapper,
+    private val encryptionUtil: EncryptionUtil,
+) : UserPort {
+    /**
+     * ID로 사용자를 조회합니다.
+     *
+     * @param id 조회할 사용자 ID
+     * @return 조회된 사용자 도메인 모델 (없으면 null)
+     */
+    override fun findById(id: UUID): User? {
+        return userRepository.findByIdOrNull(id)
+            ?.let { userMapper.toModel(it) }
+    }
+
+    /**
+     * 전화번호로 사용자를 조회합니다.
+     * 전화번호를 암호화하여 데이터베이스에서 조회합니다.
+     *
+     * @param phoneNumber 조회할 전화번호
+     * @return 조회된 사용자 도메인 모델 (없으면 null)
+     */
+    override fun findByPhoneNumber(phoneNumber: String): User? {
+        val phoneNumberHash = HashUtil.sha256(phoneNumber)
+        return userRepository.findByPhoneNumberHash(phoneNumberHash)
+            ?.let { userMapper.toModel(it) }
+    }
+
+    /**
+     * 전화번호로 사용자 존재 여부를 확인합니다.
+     *
+     * @param phoneNumber 확인할 전화번호
+     * @return 사용자 존재 여부
+     */
+    override fun existsByPhoneNumber(phoneNumber: String): Boolean {
+        val phoneNumberHash = HashUtil.sha256(phoneNumber)
+        return userRepository.existsByPhoneNumberHash(phoneNumberHash)
+    }
+
+    /**
+     * 사용자 정보를 저장합니다.
+     *
+     * @param user 저장할 사용자 도메인 모델
+     * @return 저장된 사용자 도메인 모델
+     */
+    override fun save(user: User): User {
+        val entity = userMapper.toEntity(user)
+        val savedEntity = userRepository.save(entity)
+        return userMapper.toModelNotNull(savedEntity)
+    }
+
+    /**
+     * ID로 사용자를 삭제합니다.
+     *
+     * @param userId 삭제할 사용자 ID
+     */
+    override fun deleteById(userId: UUID) {
+        userRepository.deleteById(userId)
+    }
+
+    /**
+     * 지정된 일수보다 오래된 탈퇴 사용자를 조회합니다.
+     *
+     * @param days 기준 일수
+     * @return 삭제 대상 사용자 목록
+     */
+    override fun findWithdrawnUsersOlderThan(days: Long): List<User> {
+        val cutoffDate = LocalDateTime.now().minusDays(days)
+        return userRepository.findAllByIsActiveFalseAndWithdrawalAtBefore(cutoffDate)
+            .map { userMapper.toModelNotNull(it) }
+    }
+}

casper-user/src/main/kotlin/hs/kr/entrydsm/user/domain/user/adapter/out/persistence/repository/UserCacheRepository.kt

@@ -0,0 +1,11 @@
+package hs.kr.entrydsm.user.domain.user.adapter.out.persistence.repository
+
+import hs.kr.entrydsm.user.domain.user.adapter.out.domain.UserCache
+import org.springframework.data.repository.CrudRepository
+import java.util.UUID
+
+/**
+ * 사용자 캐시를 위한 Redis 저장소 인터페이스입니다.
+ * Spring Data Redis를 통해 사용자 캐시 데이터의 관리를 담당합니다.
+ */
+interface UserCacheRepository : CrudRepository<UserCache, UUID>

casper-user/src/main/kotlin/hs/kr/entrydsm/user/domain/user/adapter/out/persistence/repository/UserInfoRepository.kt

@@ -0,0 +1,10 @@
+package hs.kr.entrydsm.user.domain.user.adapter.out.persistence.repository
+
+import hs.kr.entrydsm.user.domain.user.adapter.out.domain.UserInfo
+import org.springframework.data.repository.CrudRepository
+
+/**
+ * 사용자 인증 정보를 위한 Redis 저장소 인터페이스입니다.
+ * Spring Data Redis를 통해 사용자 인증 캐시 데이터를 관리합니다.
+ */
+interface UserInfoRepository : CrudRepository<UserInfo, String>

casper-user/src/main/kotlin/hs/kr/entrydsm/user/domain/user/adapter/out/persistence/repository/UserRepository.kt

@@ -0,0 +1,47 @@
+package hs.kr.entrydsm.user.domain.user.adapter.out.persistence.repository
+
+import hs.kr.entrydsm.user.domain.user.adapter.out.UserJpaEntity
+import org.springframework.data.jpa.repository.JpaRepository
+import java.time.LocalDateTime
+import java.util.UUID
+
+/**
+ * 사용자 JPA 엔티티를 위한 저장소 인터페이스입니다.
+ * Spring Data JPA를 통해 기본 CRUD 작업과 커스텀 쿼리를 제공합니다.
+ */
+interface UserRepository : JpaRepository<UserJpaEntity, UUID> {
+
+
+
+
+    /**
+     * 전화번호로 사용자를 조회합니다.
+     *
+     * @param phoneNumberHash 조회할 전화번호
+     * @return 조회된 사용자 엔티티 (없으면 null)
+     */
+    fun findByPhoneNumberHash(phoneNumberHash: String): UserJpaEntity?
+
+    /**
+     * 전화번호로 사용자 존재 여부를 확인합니다.
+     *
+     * @param phoneNumberHash 확인할 전화번호
+     * @return 사용자 존재 여부
+     */
+    fun existsByPhoneNumberHash(phoneNumberHash: String): Boolean
+
+    /**
+     * ID로 사용자를 삭제합니다.
+     *
+     * @param id 삭제할 사용자 ID
+     */
+    fun deleteById(id: UUID?)
+
+    /**
+     * 지정된 일시 이전에 탈퇴한 비활성 사용자들을 조회합니다.
+     *
+     * @param cutoffDate 기준 일시
+     * @return 삭제 대상 사용자 엔티티 목록
+     */
+    fun findAllByIsActiveFalseAndWithdrawalAtBefore(cutoffDate: LocalDateTime): List<UserJpaEntity>
+}