Feat/refactor/40

pom.xml

@@ -311,6 +311,22 @@
                     <tag>${project.version}</tag>
                 </configuration>
             </plugin>
+
+            <!-- Maven Surefire Plugin for Testing -->
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-surefire-plugin</artifactId>
+                <version>3.2.5</version>
+                <configuration>
+                    <argLine>
+                        --add-opens java.base/java.lang=ALL-UNNAMED
+                        --add-opens java.base/java.util=ALL-UNNAMED
+                        --add-opens java.base/java.lang.reflect=ALL-UNNAMED
+                        --add-opens java.base/java.text=ALL-UNNAMED
+                        --add-opens java.desktop/java.awt.font=ALL-UNNAMED
+                    </argLine>
+                </configuration>
+            </plugin>
         </plugins>
     </build>
 </project>

src/main/java/com/agenticcp/core/AgenticCpCoreApplication.java

@@ -2,12 +2,10 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
 import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
-@EnableJpaRepositories
 @EnableAsync
 @EnableScheduling
 public class AgenticCpCoreApplication {

src/main/java/com/agenticcp/core/common/config/JpaConfig.java

@@ -1,9 +1,52 @@
 package com.agenticcp.core.common.config;
 
+import com.agenticcp.core.common.interceptor.TenantAwareInterceptor;
+import com.agenticcp.core.common.repository.TenantAwareRepositoryImpl;
+import org.hibernate.cfg.AvailableSettings;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.orm.jpa.HibernatePropertiesCustomizer;
+import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
 
+/**
+ * JPA 설정 클래스
+ * Hibernate Interceptor를 통한 테넌트 데이터 격리 설정
+ * 
+ * @author AgenticCP Team
+ * @version 1.0.0
+ * @since 2025-01-01
+ */
 @Configuration
 @EnableJpaAuditing
+@EnableJpaRepositories(
+    basePackages = {"com.agenticcp.core.domain", "com.agenticcp.core.common.repository"},
+    repositoryBaseClass = TenantAwareRepositoryImpl.class
+)
 public class JpaConfig {
+
+    @Autowired
+    private TenantAwareInterceptor tenantAwareInterceptor;
+
+    /**
+     * Hibernate 속성 커스터마이저
+     * StatementInspector를 통해 SQL 쿼리 인터셉션 설정
+     * 
+     * @return HibernatePropertiesCustomizer
+     */
+    @Bean
+    public HibernatePropertiesCustomizer hibernatePropertiesCustomizer() {
+        return hibernateProperties -> {
+            // StatementInspector 설정 (Hibernate 5.4+)
+            hibernateProperties.put(AvailableSettings.STATEMENT_INSPECTOR, tenantAwareInterceptor);
+
+            // Interceptor 설정 (추가적인 엔티티 레벨 처리용)
+            hibernateProperties.put(AvailableSettings.INTERCEPTOR, tenantAwareInterceptor);
+
+            // SQL 로깅 활성화 (개발 환경에서 테넌트 필터링 확인용)
+            hibernateProperties.put("hibernate.show_sql", false);
+            hibernateProperties.put("hibernate.format_sql", true);
+        };
+    }
 }

src/main/java/com/agenticcp/core/common/entity/BaseEntity.java

@@ -1,86 +1,71 @@
 package com.agenticcp.core.common.entity;
 
 import jakarta.persistence.*;
+import lombok.Getter;
+import lombok.Setter;
 import org.springframework.data.annotation.CreatedDate;
 import org.springframework.data.annotation.LastModifiedDate;
 import org.springframework.data.jpa.domain.support.AuditingEntityListener;
 
 import java.time.LocalDateTime;
 
+/**
+ * 기본 엔티티 - 테넌트 정보 없음
+ * 
+ * <p>
+ * 전역 기능(플랫폼 설정, 클라우드 제공자 등)에서 사용하는 베이스 엔티티입니다.
+ * 모든 엔티티의 공통 필드(ID, 생성/수정 정보, 삭제 플래그)를 제공합니다.
+ * </p>
+ * 
+ * @author AgenticCP Team
+ * @version 1.0.0
+ * @since 2025-10-24
+ */
+@Getter
+@Setter
 @MappedSuperclass
-@EntityListeners({
-    AuditingEntityListener.class,
-    com.agenticcp.core.common.audit.AuditEntityListener.class
-})
+@EntityListeners(AuditingEntityListener.class)
 public abstract class BaseEntity {
 
+    /**
+     * 엔티티 고유 식별자
+     */
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     private Long id;
 
+    /**
+     * 엔티티 생성 시각
+     * Spring Data JPA Auditing에 의해 자동으로 설정됩니다.
+     */
     @CreatedDate
     @Column(name = "created_at", nullable = false, updatable = false)
     private LocalDateTime createdAt;
 
+    /**
+     * 엔티티 최종 수정 시각
+     * Spring Data JPA Auditing에 의해 자동으로 설정됩니다.
+     */
     @LastModifiedDate
     @Column(name = "updated_at")
     private LocalDateTime updatedAt;
 
+    /**
+     * 엔티티 생성자 식별자 (사용자명 또는 시스템 ID)
+     */
     @Column(name = "created_by")
     private String createdBy;
 
+    /**
+     * 엔티티 최종 수정자 식별자 (사용자명 또는 시스템 ID)
+     */
     @Column(name = "updated_by")
     private String updatedBy;
 
+    /**
+     * 논리 삭제 플래그
+     * true인 경우 삭제된 것으로 간주합니다.
+     */
     @Column(name = "is_deleted", nullable = false)
     private Boolean isDeleted = false;
-
-    // Getters and Setters
-    public Long getId() {
-        return id;
-    }
-
-    public void setId(Long id) {
-        this.id = id;
-    }
-
-    public LocalDateTime getCreatedAt() {
-        return createdAt;
-    }
-
-    public void setCreatedAt(LocalDateTime createdAt) {
-        this.createdAt = createdAt;
-    }
-
-    public LocalDateTime getUpdatedAt() {
-        return updatedAt;
-    }
-
-    public void setUpdatedAt(LocalDateTime updatedAt) {
-        this.updatedAt = updatedAt;
-    }
-
-    public String getCreatedBy() {
-        return createdBy;
-    }
-
-    public void setCreatedBy(String createdBy) {
-        this.createdBy = createdBy;
-    }
-
-    public String getUpdatedBy() {
-        return updatedBy;
-    }
-
-    public void setUpdatedBy(String updatedBy) {
-        this.updatedBy = updatedBy;
-    }
-
-    public Boolean getIsDeleted() {
-        return isDeleted;
-    }
-
-    public void setIsDeleted(Boolean isDeleted) {
-        this.isDeleted = isDeleted;
-    }
 }

src/main/java/com/agenticcp/core/common/entity/TenantAwareEntity.java

@@ -0,0 +1,59 @@
+package com.agenticcp.core.common.entity;
+
+import com.agenticcp.core.domain.tenant.entity.Tenant;
+import jakarta.persistence.*;
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.data.jpa.domain.support.AuditingEntityListener;
+
+/**
+ * 테넌트 인식 엔티티 - 테넌트 정보 포함
+ * 
+ * <p>
+ * 테넌트별 격리가 필요한 기능(사용자, 조직, 리소스 등)에서 사용하는 베이스 엔티티입니다.
+ * BaseEntity를 상속받아 공통 필드를 포함하며, 추가로 테넌트 정보를 관리합니다.
+ * </p>
+ * 
+ * <p>
+ * TenantAwareEntityListener를 통해 테넌트 컨텍스트 기반의 자동 설정 및 
+ * 멀티 테넌시 데이터 격리를 지원합니다.
+ * </p>
+ * 
+ * @author AgenticCP Team
+ * @version 1.0.0
+ * @since 2025-10-24
+ */
+@Getter
+@Setter
+@MappedSuperclass
+@EntityListeners({AuditingEntityListener.class, TenantAwareEntityListener.class})
+public abstract class TenantAwareEntity extends BaseEntity {
+
+    /**
+     * 엔티티가 속한 테넌트
+     * 멀티 테넌시 환경에서 데이터 격리를 위해 사용됩니다.
+     */
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "tenant_id", nullable = false)
+    private Tenant tenant;
+
+    /**
+     * 엔티티가 특정 테넌트에 속하는지 확인합니다.
+     * 
+     * @param tenant 확인할 테넌트 객체
+     * @return 엔티티가 해당 테넌트에 속하면 true, 아니면 false
+     */
+    public boolean belongsToTenant(Tenant tenant) {
+        return this.tenant != null && this.tenant.equals(tenant);
+    }
+
+    /**
+     * 엔티티가 특정 테넌트 ID에 속하는지 확인합니다.
+     * 
+     * @param tenantId 확인할 테넌트 ID
+     * @return 엔티티가 해당 테넌트 ID에 속하면 true, 아니면 false
+     */
+    public boolean belongsToTenant(Long tenantId) {
+        return this.tenant != null && this.tenant.getId().equals(tenantId);
+    }
+}

src/main/java/com/agenticcp/core/common/entity/TenantAwareEntityListener.java

@@ -0,0 +1,112 @@
+package com.agenticcp.core.common.entity;
+
+import com.agenticcp.core.common.context.TenantContextHolder;
+import com.agenticcp.core.common.enums.CommonErrorCode;
+import com.agenticcp.core.common.exception.BusinessException;
+import com.agenticcp.core.domain.tenant.entity.Tenant;
+import jakarta.persistence.PrePersist;
+import jakarta.persistence.PreUpdate;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * 테넌트 인식 엔티티 리스너
+ * 
+ * <p>
+ * JPA 엔티티 생명주기 콜백을 통해 TenantAwareEntity를 상속받은 엔티티에 대해 
+ * 자동으로 현재 테넌트 정보를 주입합니다.
+ * </p>
+ * 
+ * <p>
+ * 멀티 테넌시 환경에서 데이터 격리를 보장하기 위해 엔티티 저장/수정 시 
+ * 반드시 테넌트 컨텍스트가 설정되어 있어야 합니다.
+ * </p>
+ * 
+ * @author AgenticCP Team
+ * @version 1.0.0
+ * @since 2025-10-24
+ */
+@Slf4j
+public class TenantAwareEntityListener {
+
+    /**
+     * 엔티티 저장 전에 테넌트 정보를 자동으로 설정합니다.
+     * 
+     * <p>
+     * 엔티티에 테넌트 정보가 설정되지 않은 경우, 
+     * TenantContextHolder에서 현재 테넌트 정보를 가져와 자동으로 설정합니다.
+     * </p>
+     * 
+     * @param entity 저장할 엔티티 (TenantAwareEntity를 상속받은 객체)
+     * @throws BusinessException 테넌트 컨텍스트가 설정되지 않은 경우
+     */
+    @PrePersist
+    public void prePersist(Object entity) {
+        if (entity instanceof TenantAwareEntity tenantAwareEntity) {
+            setTenantIfNotSet(tenantAwareEntity, "prePersist");
+        }
+    }
+
+    /**
+     * 엔티티 수정 전에 테넌트 정보를 검증합니다.
+     * 
+     * <p>
+     * 엔티티에 테넌트 정보가 설정되지 않은 경우, 
+     * TenantContextHolder에서 현재 테넌트 정보를 가져와 자동으로 설정합니다.
+     * (일반적으로 수정 시에는 이미 테넌트가 설정되어 있어야 합니다)
+     * </p>
+     * 
+     * @param entity 수정할 엔티티 (TenantAwareEntity를 상속받은 객체)
+     * @throws BusinessException 테넌트 컨텍스트가 설정되지 않은 경우
+     */
+    @PreUpdate
+    public void preUpdate(Object entity) {
+        if (entity instanceof TenantAwareEntity tenantAwareEntity) {
+            setTenantIfNotSet(tenantAwareEntity, "preUpdate");
+        }
+    }
+
+    /**
+     * 엔티티에 테넌트 정보가 설정되지 않은 경우 현재 컨텍스트의 테넌트 정보를 설정합니다.
+     * 
+     * <p>
+     * 이미 테넌트가 설정된 경우 건너뛰며, 테넌트 컨텍스트가 설정되지 않은 경우 
+     * BusinessException을 발생시킵니다.
+     * </p>
+     * 
+     * @param tenantAwareEntity 테넌트 정보를 설정할 엔티티
+     * @param operation 수행 중인 작업 (prePersist 또는 preUpdate, 로깅용)
+     * @throws BusinessException 테넌트 컨텍스트가 설정되지 않은 경우 (TENANT_CONTEXT_NOT_SET)
+     */
+    private void setTenantIfNotSet(TenantAwareEntity tenantAwareEntity, String operation) {
+        // 이미 테넌트가 설정되어 있으면 건너뛰기
+        if (tenantAwareEntity.getTenant() != null) {
+            log.debug("테넌트가 이미 설정됨: entity={}, operation={}", 
+                tenantAwareEntity.getClass().getSimpleName(), operation);
+            return;
+        }
+
+        try {
+            // 현재 테넌트 컨텍스트에서 테넌트 정보 조회
+            Tenant currentTenant = TenantContextHolder.getCurrentTenantOrThrow();
+
+            // 테넌트 정보 설정
+            tenantAwareEntity.setTenant(currentTenant);
+
+            log.debug("테넌트 자동 설정 완료: tenantKey={}, entity={}, operation={}", 
+                currentTenant.getTenantKey(), 
+                tenantAwareEntity.getClass().getSimpleName(), 
+                operation);
+
+        } catch (BusinessException e) {
+            // 테넌트 컨텍스트가 설정되지 않은 경우
+            log.error("테넌트 설정 실패: entity={}, operation={}, error={}", 
+                tenantAwareEntity.getClass().getSimpleName(), 
+                operation, 
+                e.getMessage());
+
+            // 테넌트 컨텍스트가 필수인 경우 예외 발생
+            throw new BusinessException(CommonErrorCode.TENANT_CONTEXT_NOT_SET, 
+                "Tenant context is required for entity operations");
+        }
+    }
+}