diff --git a/CLAUDE.md b/CLAUDE.md
index 13c956d..2667297 100644
--- a/CLAUDE.md
+++ b/CLAUDE.md
@@ -501,13 +501,31 @@ QA Engineer
- **컴파일**: 최상위 루트에서 `./gradlew {service-name}:compileJava` 명령 사용
- **서버 시작**: AI가 직접 서버를 시작하지 말고 반드시 사람에게 요청할것
+## JSON 데이터 바인딩 문제
+- **문제**: DTO에서 JSON 요청 데이터가 바인딩되지 않아 모든 필드가 "필수입니다" 검증 오류 발생
+- **원인**: Jackson JSON 직렬화/역직렬화 시 명시적 프로퍼티 매핑 누락
+- **해결책**: DTO 필드에 `@JsonProperty("fieldName")` 어노테이션 추가 필수
+- **적용**: UserRegistrationRequest, LoginRequest 등 모든 Request DTO에 적용
+
## 실행 프로파일 작성 경험
- **Gradle 실행 프로파일**: Spring Boot가 아닌 Gradle 실행 프로파일 사용 필수
- **환경변수 매핑**: `` 형태로 환경변수 설정
- **컴포넌트 스캔 이슈**: common 모듈의 @Component가 인식되지 않는 경우 발생
- **의존성 주입 오류**: JwtTokenProvider 빈을 찾을 수 없는 오류 확인됨
+## Authorization Header 문제
+- **문제**: Swagger UI에서 생성된 curl 명령에 Authorization 헤더 누락
+- **원인**: SwaggerConfig의 SecurityRequirement 이름과 Controller의 @SecurityRequirement 이름 불일치
+- **해결책**: SwaggerConfig의 "Bearer Authentication"을 "bearerAuth"로 통일
+- **적용**: bill-service, product-service 모두 수정 완료
+
## 백킹서비스 연결 정보
- **LoadBalancer External IP**: kubectl 명령으로 실제 IP 확인 후 환경변수 설정
- **DB 연결정보**: 각 서비스별 별도 DB 사용 (auth, bill_inquiry, product_change)
- **Redis 공유**: 모든 서비스가 동일한 Redis 인스턴스 사용
+
+## 쿠버네티스 DB 접근 방법
+- **패스워드 확인**: `kubectl get secret -n {namespace} {secret-name} -o jsonpath='{.data.postgres-password}' | base64 -d`
+- **환경변수 확인**: `kubectl exec -n {namespace} {pod-name} -c postgresql -- env | grep POSTGRES`
+- **SQL 실행**: `kubectl exec -n {namespace} {pod-name} -c postgresql -- bash -c 'PGPASSWORD="$POSTGRES_POSTGRES_PASSWORD" psql -U postgres -d {database} -c "{SQL}"'`
+- **예시**: `kubectl exec -n phonebill-dev product-change-postgres-dev-postgresql-0 -c postgresql -- bash -c 'PGPASSWORD="$POSTGRES_POSTGRES_PASSWORD" psql -U postgres -d product_change_db -c "ALTER TABLE product_change.pc_product_change_history ALTER COLUMN customer_id TYPE VARCHAR(100);"'`
diff --git a/api-gateway/.run/api-gateway.run.xml b/api-gateway/.run/api-gateway.run.xml
index ba289bc..a2bad0b 100644
--- a/api-gateway/.run/api-gateway.run.xml
+++ b/api-gateway/.run/api-gateway.run.xml
@@ -3,18 +3,15 @@
@@ -37,4 +34,4 @@
false
-
+
\ No newline at end of file
diff --git a/api-gateway/src/main/java/com/unicorn/phonebill/gateway/config/GatewayConfig.java b/api-gateway/src/main/java/com/unicorn/phonebill/gateway/config/GatewayConfig.java
index 5924d8d..a4ad379 100644
--- a/api-gateway/src/main/java/com/unicorn/phonebill/gateway/config/GatewayConfig.java
+++ b/api-gateway/src/main/java/com/unicorn/phonebill/gateway/config/GatewayConfig.java
@@ -1,6 +1,7 @@
package com.unicorn.phonebill.gateway.config;
import com.unicorn.phonebill.gateway.filter.JwtAuthenticationGatewayFilterFactory;
+import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.context.annotation.Bean;
@@ -31,6 +32,9 @@ public class GatewayConfig {
private final JwtAuthenticationGatewayFilterFactory jwtAuthFilter;
+ @Value("${cors.allowed-origins")
+ private String allowedOrigins;
+
public GatewayConfig(JwtAuthenticationGatewayFilterFactory jwtAuthFilter) {
this.jwtAuthFilter = jwtAuthFilter;
}
@@ -48,28 +52,30 @@ public class GatewayConfig {
public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
return builder.routes()
// Auth Service 라우팅 (인증 불필요)
- .route("auth-service", r -> r
- .path("/auth/login", "/auth/refresh")
+ .route("user-service-login", r -> r
+ .path("/api/auth/login", "/api/auth/refresh")
.and()
.method("POST")
- .uri("lb://auth-service"))
+ .filters(f -> f.rewritePath("/api/auth/(?.*)", "/auth/${segment}"))
+ .uri("lb://user-service"))
// Auth Service 라우팅 (인증 필요)
- .route("auth-service-authenticated", r -> r
- .path("/auth/**")
+ .route("user-service-authenticated", r -> r
+ .path("/api/auth/**")
.filters(f -> f
+ .rewritePath("/api/auth/(?.*)", "/auth/${segment}")
.filter(jwtAuthFilter.apply(new JwtAuthenticationGatewayFilterFactory.Config()))
.circuitBreaker(cb -> cb
- .setName("auth-service-cb")
+ .setName("user-service-cb")
.setFallbackUri("forward:/fallback/auth"))
.retry(retry -> retry
.setRetries(3)
.setBackoff(java.time.Duration.ofSeconds(2), java.time.Duration.ofSeconds(10), 2, true)))
- .uri("lb://auth-service"))
+ .uri("lb://user-service"))
// Bill-Inquiry Service 라우팅 (인증 필요)
.route("bill-service", r -> r
- .path("/bills/**")
+ .path("/api/v1/bills/**")
.filters(f -> f
.filter(jwtAuthFilter.apply(new JwtAuthenticationGatewayFilterFactory.Config()))
.circuitBreaker(cb -> cb
@@ -131,15 +137,11 @@ public class GatewayConfig {
@Bean
public CorsWebFilter corsWebFilter() {
CorsConfiguration corsConfig = new CorsConfiguration();
-
- // 허용할 Origin 설정
- corsConfig.setAllowedOriginPatterns(Arrays.asList(
- "http://localhost:3000", // React 개발 서버
- "http://localhost:3001", // Next.js 개발 서버
- "https://*.unicorn.com", // 운영 도메인
- "https://*.phonebill.com" // 운영 도메인
- ));
-
+
+ // 환경변수에서 허용할 Origin 패턴 설정
+ String[] origins = allowedOrigins.split(",");
+ corsConfig.setAllowedOriginPatterns(Arrays.asList(origins));
+
// 허용할 HTTP 메서드
corsConfig.setAllowedMethods(Arrays.asList(
"GET", "POST", "PUT", "DELETE", "OPTIONS", "HEAD"
diff --git a/api-gateway/src/main/java/com/unicorn/phonebill/gateway/service/JwtTokenService.java b/api-gateway/src/main/java/com/unicorn/phonebill/gateway/service/JwtTokenService.java
index 48b43e6..e53ea09 100644
--- a/api-gateway/src/main/java/com/unicorn/phonebill/gateway/service/JwtTokenService.java
+++ b/api-gateway/src/main/java/com/unicorn/phonebill/gateway/service/JwtTokenService.java
@@ -44,9 +44,9 @@ public class JwtTokenService {
private final long refreshTokenValidityInSeconds;
public JwtTokenService(
- @Value("${app.jwt.secret}") String jwtSecret,
- @Value("${app.jwt.access-token-validity-in-seconds:1800}") long accessTokenValidityInSeconds,
- @Value("${app.jwt.refresh-token-validity-in-seconds:86400}") long refreshTokenValidityInSeconds) {
+ @Value("${jwt.secret}") String jwtSecret,
+ @Value("${jwt.access-token-validity:1800}") long accessTokenValidityInSeconds,
+ @Value("${jwt.refresh-token-validity:86400}") long refreshTokenValidityInSeconds) {
this.secretKey = Keys.hmacShaKeyFor(jwtSecret.getBytes(StandardCharsets.UTF_8));
this.accessTokenValidityInSeconds = accessTokenValidityInSeconds;
diff --git a/api-gateway/src/main/resources/application-dev.yml b/api-gateway/src/main/resources/application-dev.yml
index 43d7a12..50d0500 100644
--- a/api-gateway/src/main/resources/application-dev.yml
+++ b/api-gateway/src/main/resources/application-dev.yml
@@ -1,128 +1,10 @@
-# API Gateway 개발 환경 설정
-
-server:
- port: 8080
-
-spring:
-
- # Cloud Gateway 개발환경 설정
- cloud:
- gateway:
- default-filters: []
- globalcors:
- cors-configurations:
- '[/**]':
- allowed-origin-patterns:
- - "http://localhost:*"
- - "http://127.0.0.1:*"
- - "https://localhost:*"
- allowed-methods: "*"
- allowed-headers: "*"
- allow-credentials: true
- max-age: 86400 # 24시간
-
- # 개발도구 설정
- devtools:
- restart:
- enabled: true
- additional-paths: src/main/java,src/main/resources
- livereload:
- enabled: true
-
-# JWT 설정 (개발용 - 더 긴 유효시간)
-app:
- jwt:
- secret: ${JWT_SECRET:dev-phonebill-api-gateway-jwt-secret-key-256-bit-minimum-length-for-development}
- access-token-validity-in-seconds: 3600 # 1시간 (개발편의성)
- refresh-token-validity-in-seconds: 172800 # 48시간 (개발편의성)
-
-# Circuit Breaker 설정 (개발환경 - 더 관대한 설정)
-resilience4j:
- circuitbreaker:
- instances:
- auth-service-cb:
- failure-rate-threshold: 80 # 개발환경은 더 관대한 임계값
- wait-duration-in-open-state: 10s
- sliding-window-size: 5
- minimum-number-of-calls: 3
- bill-service-cb:
- failure-rate-threshold: 80
- wait-duration-in-open-state: 10s
- sliding-window-size: 5
- minimum-number-of-calls: 3
- product-service-cb:
- failure-rate-threshold: 80
- wait-duration-in-open-state: 10s
- sliding-window-size: 5
- minimum-number-of-calls: 3
- kos-mock-cb:
- failure-rate-threshold: 90
- wait-duration-in-open-state: 5s
- sliding-window-size: 5
- minimum-number-of-calls: 2
-
-# Actuator 설정 (개발환경 - 모든 엔드포인트 노출)
-management:
- endpoints:
- web:
- exposure:
- include: "*" # 개발환경에서는 모든 엔드포인트 노출
- base-path: /actuator
- endpoint:
- health:
- show-details: always # 개발환경에서는 상세 정보 항상 표시
- shutdown:
- enabled: true # 개발환경에서만 활성화
- beans:
- enabled: true
- env:
- enabled: true
- configprops:
- enabled: true
-
# 로깅 설정 (개발환경 - 더 상세한 로그)
logging:
level:
- com.unicorn.phonebill.gateway: ${LOG_LEVEL_GATEWAY:DEBUG}
- org.springframework.cloud.gateway: ${LOG_LEVEL_SPRING_CLOUD_GATEWAY:DEBUG}
- org.springframework.data.redis: ${LOG_LEVEL_SPRING_DATA_REDIS:DEBUG}
- org.springframework.web.reactive: ${LOG_LEVEL_SPRING_WEB_REACTIVE:DEBUG}
- reactor.netty.http.client: ${LOG_LEVEL_REACTOR_NETTY_HTTP_CLIENT:DEBUG}
- io.netty.handler.ssl: ${LOG_LEVEL_IO_NETTY_HANDLER_SSL:WARN}
- root: ${LOG_LEVEL_ROOT:INFO}
- file:
- name: ${LOG_FILE:logs/api-gateway.log}
- max-size: ${LOG_FILE_MAX_SIZE:100MB}
- max-history: ${LOG_FILE_MAX_HISTORY:7}
-
-# OpenAPI 설정 (개발환경)
-springdoc:
- api-docs:
- enabled: true
- path: /v3/api-docs
- swagger-ui:
- enabled: true
- path: /swagger-ui.html
- try-it-out-enabled: true # 개발환경에서 Try it out 활성화
- urls:
- - name: Auth Service (Dev)
- url: http://localhost:8081/v3/api-docs
- - name: Bill Service (Dev)
- url: http://localhost:8082/v3/api-docs
- - name: Product Service (Dev)
- url: http://localhost:8083/v3/api-docs
- - name: KOS Mock Service (Dev)
- url: http://localhost:8084/v3/api-docs
-
-# CORS 설정 (개발환경 - 더 관대한 설정) - 이미 위에서 설정됨
-
-# 개발환경 특성 설정
-debug: false
-trace: false
-
-# 애플리케이션 정보 (개발환경)
-info:
- app:
- environment: development
- debug-mode: enabled
- hot-reload: enabled
\ No newline at end of file
+ com.unicorn.phonebill.gateway: DEBUG
+ org.springframework.cloud.gateway: DEBUG
+ org.springframework.data.redis: DEBUG
+ org.springframework.web.reactive: DEBUG
+ reactor.netty.http.client: DEBUG
+ io.netty.handler.ssl: DEBUG
+ root: DEBUG
diff --git a/api-gateway/src/main/resources/application-prod.yml b/api-gateway/src/main/resources/application-prod.yml
index 6e84076..3a4cb0d 100644
--- a/api-gateway/src/main/resources/application-prod.yml
+++ b/api-gateway/src/main/resources/application-prod.yml
@@ -1,219 +1,9 @@
-# API Gateway 운영 환경 설정
-
-server:
- port: 8080
- netty:
- connection-timeout: 20s
- idle-timeout: 30s
- compression:
- enabled: true
- mime-types: application/json,application/xml,text/html,text/xml,text/plain
- http2:
- enabled: true
-
-spring:
- profiles:
- active: prod
-
- # Redis 설정 (운영용) - 현재 사용하지 않음
- # data:
- # redis:
- # host: ${REDIS_HOST:redis-cluster.unicorn.com}
- # port: ${REDIS_PORT:6379}
- # database: ${REDIS_DATABASE:0}
- # password: ${REDIS_PASSWORD}
- # timeout: 2000ms
- # ssl: true # 운영환경에서는 SSL 사용
- # lettuce:
- # pool:
- # max-active: 20
- # max-wait: 2000ms
- # max-idle: 10
- # min-idle: 5
- # cluster:
- # refresh:
- # adaptive: true
- # period: 30s
-
- # Cloud Gateway 운영환경 설정
- cloud:
- gateway:
- default-filters:
- # - name: RequestRateLimiter # Redis 사용하지 않으므로 주석처리
- # args:
- # redis-rate-limiter.replenishRate: 500 # 운영환경 적정 한도
- # redis-rate-limiter.burstCapacity: 1000
- # key-resolver: "#{@userKeyResolver}"
- - name: RequestSize
- args:
- maxSize: 5MB # 요청 크기 제한
- globalcors:
- cors-configurations:
- '[/**]':
- allowed-origins:
- - "https://app.phonebill.com"
- - "https://admin.phonebill.com"
- - "https://*.unicorn.com"
- allowed-methods:
- - GET
- - POST
- - PUT
- - DELETE
- allowed-headers:
- - Authorization
- - Content-Type
- - X-Requested-With
- allow-credentials: true
- max-age: 3600
-
-# JWT 설정 (운영용 - 보안 강화)
-app:
- jwt:
- secret: ${JWT_SECRET} # 환경변수에서 주입 (필수)
- access-token-validity-in-seconds: 1800 # 30분 (보안 강화)
- refresh-token-validity-in-seconds: 86400 # 24시간
-
-# Circuit Breaker 설정 (운영환경 - 엄격한 설정)
-resilience4j:
- circuitbreaker:
- instances:
- auth-service-cb:
- failure-rate-threshold: 50
- slow-call-rate-threshold: 60
- slow-call-duration-threshold: 3s
- wait-duration-in-open-state: 30s
- sliding-window-size: 100
- minimum-number-of-calls: 20
- permitted-number-of-calls-in-half-open-state: 10
- bill-service-cb:
- failure-rate-threshold: 50
- slow-call-rate-threshold: 60
- slow-call-duration-threshold: 5s
- wait-duration-in-open-state: 30s
- sliding-window-size: 100
- minimum-number-of-calls: 20
- product-service-cb:
- failure-rate-threshold: 50
- slow-call-rate-threshold: 60
- slow-call-duration-threshold: 5s
- wait-duration-in-open-state: 30s
- sliding-window-size: 100
- minimum-number-of-calls: 20
- kos-mock-cb:
- failure-rate-threshold: 60
- slow-call-rate-threshold: 70
- slow-call-duration-threshold: 10s
- wait-duration-in-open-state: 60s
- sliding-window-size: 50
- minimum-number-of-calls: 10
-
- retry:
- instances:
- default:
- max-attempts: 3
- wait-duration: 1s
- exponential-backoff-multiplier: 2
- retry-exceptions:
- - java.net.ConnectException
- - java.net.SocketTimeoutException
- - org.springframework.web.client.ResourceAccessException
-
-# Actuator 설정 (운영환경 - 보안 강화)
-management:
- endpoints:
- web:
- exposure:
- include: health,info,metrics,prometheus,gateway # 필요한 것만 노출
- base-path: /actuator
- endpoint:
- health:
- show-details: never # 운영환경에서는 상세 정보 숨김
- show-components: never
- gateway:
- enabled: true
- shutdown:
- enabled: false # 운영환경에서는 비활성화
- health:
- redis:
- enabled: true
- circuitbreakers:
- enabled: true
- info:
- env:
- enabled: false # 환경 정보 숨김
- java:
- enabled: true
- build:
- enabled: true
- metrics:
- export:
- prometheus:
- enabled: true
-
-# 로깅 설정 (운영환경 - 성능 고려)
logging:
level:
com.unicorn.phonebill.gateway: INFO
- org.springframework.cloud.gateway: WARN
- reactor.netty: WARN
- io.netty: WARN
+ org.springframework.cloud.gateway: INFO
+ org.springframework.data.redis: INFO
+ org.springframework.web.reactive: WARN
+ reactor.netty.http.client: WARN
+ io.netty.handler.ssl: WARN
root: WARN
- file:
- name: /var/log/api-gateway/api-gateway.log
- max-size: 500MB
- max-history: 30
- pattern:
- file: "%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level [%X{traceId:-},%X{spanId:-}] %logger{36} - %msg%n"
- loggers:
- org.springframework.security: WARN
- org.springframework.web: WARN
-
-# OpenAPI 설정 (운영환경 - 비활성화)
-springdoc:
- api-docs:
- enabled: false # 운영환경에서는 비활성화
- swagger-ui:
- enabled: false # 운영환경에서는 비활성화
-
-# CORS 설정은 위의 spring.cloud.gateway 섹션에서 설정됨
-
-# 보안 설정
-security:
- headers:
- frame:
- deny: true
- content-type:
- nosniff: true
- xss:
- protection: true
-
-# JVM 튜닝 (운영환경)
-jvm:
- heap:
- initial: 512m
- maximum: 1024m
- gc:
- algorithm: G1GC
- options:
- - "-server"
- - "-XX:+UseG1GC"
- - "-XX:G1HeapRegionSize=16m"
- - "-XX:+UseStringDeduplication"
- - "-XX:+OptimizeStringConcat"
- - "-XX:+UnlockExperimentalVMOptions"
- - "-XX:+UseJVMCICompiler"
-
-# 모니터링 및 트레이싱
-tracing:
- enabled: true
- sampling:
- probability: 0.1 # 10% 샘플링
- zipkin:
- base-url: ${ZIPKIN_BASE_URL:http://zipkin.monitoring.unicorn.com:9411}
-
-# 애플리케이션 정보 (운영환경)
-info:
- app:
- environment: production
- security-level: high
- monitoring: enabled
\ No newline at end of file
diff --git a/api-gateway/src/main/resources/application.yml b/api-gateway/src/main/resources/application.yml
index a11e11d..1cf9eea 100644
--- a/api-gateway/src/main/resources/application.yml
+++ b/api-gateway/src/main/resources/application.yml
@@ -7,15 +7,15 @@ server:
connection-timeout: ${SERVER_NETTY_CONNECTION_TIMEOUT:30s}
idle-timeout: ${SERVER_NETTY_IDLE_TIMEOUT:60s}
http2:
- enabled: ${SERVER_HTTP2_ENABLED:true}
+ enabled: true
spring:
application:
name: api-gateway
profiles:
- active: dev
-
+ active: ${SPRING_PROFILES_ACTIVE:dev}
+
# Spring Cloud Gateway 설정
cloud:
gateway:
@@ -59,12 +59,15 @@ spring:
deserialization:
fail-on-unknown-properties: false
-# JWT 설정
-app:
- jwt:
- secret: ${JWT_SECRET:phonebill-api-gateway-jwt-secret-key-256-bit-minimum-length-required}
- access-token-validity-in-seconds: 1800 # 30분
- refresh-token-validity-in-seconds: 86400 # 24시간
+# CORS
+cors:
+ allowed-origins: ${CORS_ALLOWED_ORIGINS:http://localhost:3000}
+
+# JWT 토큰 설정
+jwt:
+ secret: ${JWT_SECRET:}
+ access-token-validity: ${JWT_ACCESS_TOKEN_VALIDITY:1800}
+ refresh-token-validity: ${JWT_ACCESS_TOKEN_VALIDITY:86400}
# 서비스 URL 설정
services:
@@ -142,14 +145,8 @@ management:
# 로깅 설정
logging:
- level:
- com.unicorn.phonebill.gateway: ${LOG_LEVEL_GATEWAY:INFO}
- org.springframework.cloud.gateway: ${LOG_LEVEL_SPRING_CLOUD_GATEWAY:DEBUG}
- reactor.netty: ${LOG_LEVEL_REACTOR_NETTY:INFO}
- io.netty: ${LOG_LEVEL_IO_NETTY:WARN}
- root: ${LOG_LEVEL_ROOT:INFO}
file:
- name: ${LOG_FILE:logs/api-gateway.log}
+ name: logs/api-gateway.log
logback:
rollingpolicy:
max-file-size: 10MB
diff --git a/bill-service/.run/bill-service.run.xml b/bill-service/.run/bill-service.run.xml
index e45fa58..3c026df 100644
--- a/bill-service/.run/bill-service.run.xml
+++ b/bill-service/.run/bill-service.run.xml
@@ -3,64 +3,35 @@
@@ -80,7 +51,7 @@
false
true
false
- false
+ false
\ No newline at end of file
diff --git a/bill-service/build.gradle b/bill-service/build.gradle
index 1b580bc..6613315 100644
--- a/bill-service/build.gradle
+++ b/bill-service/build.gradle
@@ -28,6 +28,7 @@ dependencies {
// Common modules (로컬 의존성)
implementation project(':common')
+ implementation project(':kos-mock')
// Test Dependencies (bill service specific)
testImplementation 'org.testcontainers:postgresql'
diff --git a/bill-service/src/main/java/com/phonebill/bill/config/JpaAuditingConfig.java b/bill-service/src/main/java/com/phonebill/bill/config/JpaAuditingConfig.java
new file mode 100644
index 0000000..765e493
--- /dev/null
+++ b/bill-service/src/main/java/com/phonebill/bill/config/JpaAuditingConfig.java
@@ -0,0 +1,22 @@
+package com.phonebill.bill.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+
+/**
+ * JPA Auditing 설정
+ *
+ * BaseTimeEntity의 @CreatedDate, @LastModifiedDate 자동 설정을 위한 구성
+ * - 엔티티 저장/수정 시 자동으로 시간 정보 설정
+ * - 모든 엔티티의 생성/수정 시간 추적 가능
+ *
+ * @author 이개발(백엔더)
+ * @version 1.0.0
+ * @since 2025-09-09
+ */
+@Configuration
+@EnableJpaAuditing
+public class JpaAuditingConfig {
+ // JPA Auditing 활성화를 위한 설정 클래스
+ // 별도의 Bean 정의 없이 @EnableJpaAuditing만으로 충분
+}
\ No newline at end of file
diff --git a/bill-service/src/main/java/com/phonebill/bill/config/JwtConfig.java b/bill-service/src/main/java/com/phonebill/bill/config/JwtConfig.java
new file mode 100644
index 0000000..101c81d
--- /dev/null
+++ b/bill-service/src/main/java/com/phonebill/bill/config/JwtConfig.java
@@ -0,0 +1,38 @@
+package com.phonebill.bill.config;
+
+import com.phonebill.common.security.JwtTokenProvider;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * JWT 설정
+ *
+ * Bill Service의 JWT 토큰 검증을 위한 설정
+ * User Service와 동일한 시크릿 키를 사용하여 토큰 검증
+ *
+ * @author 이개발(백엔더)
+ * @version 1.0.0
+ * @since 2025-09-09
+ */
+@Configuration
+public class JwtConfig {
+
+ /**
+ * JwtTokenProvider 빈 생성
+ *
+ * @param secret JWT 시크릿 키
+ * @param expirationInSeconds JWT 만료 시간 (초)
+ * @return JwtTokenProvider 인스턴스
+ */
+ @Bean
+ public JwtTokenProvider jwtTokenProvider(
+ @Value("${jwt.secret:dev-jwt-secret-key-for-development-only}") String secret,
+ @Value("${jwt.access-token-validity:86400000}") long expirationInMillis) {
+
+ // 만료 시간을 초 단위로 변환
+ long expirationInSeconds = expirationInMillis / 1000;
+
+ return new JwtTokenProvider(secret, expirationInSeconds);
+ }
+}
\ No newline at end of file
diff --git a/bill-service/src/main/java/com/phonebill/bill/config/RedisConfig.java b/bill-service/src/main/java/com/phonebill/bill/config/RedisConfig.java
index 6813e90..4296be0 100644
--- a/bill-service/src/main/java/com/phonebill/bill/config/RedisConfig.java
+++ b/bill-service/src/main/java/com/phonebill/bill/config/RedisConfig.java
@@ -98,8 +98,8 @@ public class RedisConfig {
template.setKeySerializer(new StringRedisSerializer());
template.setHashKeySerializer(new StringRedisSerializer());
- // Value 직렬화: JSON 사용
- GenericJackson2JsonRedisSerializer jsonSerializer = new GenericJackson2JsonRedisSerializer(objectMapper());
+ // Value 직렬화: Redis 전용 ObjectMapper 사용
+ GenericJackson2JsonRedisSerializer jsonSerializer = new GenericJackson2JsonRedisSerializer(redisObjectMapper());
template.setValueSerializer(jsonSerializer);
template.setHashValueSerializer(jsonSerializer);
@@ -128,8 +128,8 @@ public class RedisConfig {
.serializeKeysWith(org.springframework.data.redis.serializer.RedisSerializationContext.SerializationPair
.fromSerializer(new StringRedisSerializer()))
.serializeValuesWith(org.springframework.data.redis.serializer.RedisSerializationContext.SerializationPair
- .fromSerializer(new GenericJackson2JsonRedisSerializer(objectMapper())))
- .disableCachingNullValues(); // null 값 캐싱 비활성화
+ .fromSerializer(new GenericJackson2JsonRedisSerializer(redisObjectMapper())));
+ // null 값 캐싱은 @Cacheable unless 조건으로 처리
// 캐시별 개별 설정
Map cacheConfigurations = new HashMap<>();
@@ -163,25 +163,24 @@ public class RedisConfig {
}
/**
- * ObjectMapper 구성
+ * Redis 전용 ObjectMapper 구성
*
- * @return JSON 직렬화용 ObjectMapper
+ * @return Redis 직렬화용 ObjectMapper (다형성 타입 정보 포함)
*/
- @Bean
- public ObjectMapper objectMapper() {
+ private ObjectMapper redisObjectMapper() {
ObjectMapper mapper = new ObjectMapper();
// Java Time 모듈 등록 (LocalDateTime 등 지원)
mapper.registerModule(new JavaTimeModule());
- // 타입 정보 포함 (다형성 지원)
+ // 타입 정보 포함 (다형성 지원) - Redis 캐싱에만 필요
mapper.activateDefaultTyping(
LaissezFaireSubTypeValidator.instance,
ObjectMapper.DefaultTyping.NON_FINAL,
JsonTypeInfo.As.PROPERTY
);
- log.debug("ObjectMapper 구성 완료");
+ log.debug("Redis 전용 ObjectMapper 구성 완료");
return mapper;
}
diff --git a/bill-service/src/main/java/com/phonebill/bill/config/SecurityConfig.java b/bill-service/src/main/java/com/phonebill/bill/config/SecurityConfig.java
index 49661bd..a736fc6 100644
--- a/bill-service/src/main/java/com/phonebill/bill/config/SecurityConfig.java
+++ b/bill-service/src/main/java/com/phonebill/bill/config/SecurityConfig.java
@@ -1,7 +1,10 @@
package com.phonebill.bill.config;
+import com.phonebill.common.security.JwtAuthenticationFilter;
+import com.phonebill.common.security.JwtTokenProvider;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.HttpMethod;
@@ -21,6 +24,7 @@ import org.springframework.web.cors.CorsConfigurationSource;
import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
import java.util.Arrays;
+import java.util.List;
/**
* Spring Security 설정
@@ -42,6 +46,11 @@ import java.util.Arrays;
@RequiredArgsConstructor
public class SecurityConfig {
+ private final JwtTokenProvider jwtTokenProvider;
+
+ @Value("${cors.allowed-origins")
+ private String allowedOrigins;
+
/**
* 보안 필터 체인 구성
*
@@ -53,76 +62,55 @@ public class SecurityConfig {
log.info("Security Filter Chain 구성 시작");
http
- // CSRF 비활성화 (REST API는 CSRF 불필요)
- .csrf(AbstractHttpConfigurer::disable)
+ // CSRF 비활성화 (JWT 사용으로 불필요)
+ .csrf(csrf -> csrf.disable())
- // CORS 설정 활성화
+ // CORS 설정
.cors(cors -> cors.configurationSource(corsConfigurationSource()))
- // 세션 관리 - Stateless (JWT 사용)
+ // 세션 비활성화 (JWT 기반 Stateless)
.sessionManagement(session ->
session.sessionCreationPolicy(SessionCreationPolicy.STATELESS))
- // 요청별 인증/인가 설정
- .authorizeHttpRequests(auth -> auth
- // 공개 엔드포인트 - 인증 불필요
+ // 권한 설정
+ .authorizeHttpRequests(authz -> authz
+ // Public endpoints (인증 불필요)
.requestMatchers(
- // Health Check
- "/actuator/**",
- // Swagger UI
- "/swagger-ui/**",
+ "/actuator/health",
+ "/actuator/info",
+ "/actuator/prometheus",
"/v3/api-docs/**",
+ "/api-docs/**",
+ "/swagger-ui/**",
+ "/swagger-ui.html",
"/swagger-resources/**",
- "/webjars/**",
- // 정적 리소스
- "/favicon.ico",
- "/error"
+ "/webjars/**"
).permitAll()
// OPTIONS 요청은 모두 허용 (CORS Preflight)
.requestMatchers(HttpMethod.OPTIONS, "/**").permitAll()
+
+ // Actuator endpoints (관리용)
+ .requestMatchers("/actuator/**").hasRole("ADMIN")
- // 요금 조회 API - 인증 필요
- .requestMatchers("/api/bills/**").authenticated()
-
- // 나머지 모든 요청 - 인증 필요
+ // 나머지 모든 요청 인증 필요
.anyRequest().authenticated()
)
- // JWT 인증 필터 추가
- // TODO: JWT 필터 구현 후 활성화
- // .addFilterBefore(jwtAuthenticationFilter(), UsernamePasswordAuthenticationFilter.class)
+ // JWT 필터 추가
+ .addFilterBefore(jwtAuthenticationFilter(), UsernamePasswordAuthenticationFilter.class)
- // 예외 처리
- .exceptionHandling(exception -> exception
- // 인증 실패 시 처리
+ // Exception 처리
+ .exceptionHandling(exceptions -> exceptions
.authenticationEntryPoint((request, response, authException) -> {
- log.warn("인증 실패 - URI: {}, 오류: {}",
- request.getRequestURI(), authException.getMessage());
response.setStatus(401);
response.setContentType("application/json;charset=UTF-8");
- response.getWriter().write("""
- {
- "success": false,
- "message": "인증이 필요합니다",
- "timestamp": "%s"
- }
- """.formatted(java.time.LocalDateTime.now()));
+ response.getWriter().write("{\"success\":false,\"error\":{\"code\":\"UNAUTHORIZED\",\"message\":\"인증이 필요합니다.\",\"details\":\"유효한 토큰이 필요합니다.\"}}");
})
-
- // 권한 부족 시 처리
.accessDeniedHandler((request, response, accessDeniedException) -> {
- log.warn("접근 거부 - URI: {}, 오류: {}",
- request.getRequestURI(), accessDeniedException.getMessage());
response.setStatus(403);
response.setContentType("application/json;charset=UTF-8");
- response.getWriter().write("""
- {
- "success": false,
- "message": "접근 권한이 없습니다",
- "timestamp": "%s"
- }
- """.formatted(java.time.LocalDateTime.now()));
+ response.getWriter().write("{\"success\":false,\"error\":{\"code\":\"ACCESS_DENIED\",\"message\":\"접근이 거부되었습니다.\",\"details\":\"권한이 부족합니다.\"}}");
})
);
@@ -130,99 +118,37 @@ public class SecurityConfig {
return http.build();
}
- /**
- * CORS 설정
- *
- * @return CORS 설정 소스
- */
+ @Bean
+ public JwtAuthenticationFilter jwtAuthenticationFilter() {
+ return new JwtAuthenticationFilter(jwtTokenProvider);
+ }
+
@Bean
public CorsConfigurationSource corsConfigurationSource() {
- log.debug("CORS 설정 구성 시작");
-
CorsConfiguration configuration = new CorsConfiguration();
-
- // 허용할 Origin 설정 (개발환경)
- configuration.setAllowedOriginPatterns(Arrays.asList(
- "http://localhost:*",
- "https://localhost:*",
- "http://127.0.0.1:*",
- "https://127.0.0.1:*"
- // TODO: 운영환경 도메인 추가
- ));
-
- // 허용할 HTTP 메소드
- configuration.setAllowedMethods(Arrays.asList(
- "GET", "POST", "PUT", "DELETE", "PATCH", "OPTIONS"
- ));
-
- // 허용할 헤더
- configuration.setAllowedHeaders(Arrays.asList(
- "Authorization",
- "Content-Type",
- "X-Requested-With",
- "Accept",
- "Origin",
- "Access-Control-Request-Method",
- "Access-Control-Request-Headers"
- ));
-
- // 자격 증명 허용 (쿠키, Authorization 헤더 등)
- configuration.setAllowCredentials(true);
-
- // Preflight 요청 캐시 시간 (초)
- configuration.setMaxAge(3600L);
+ // 환경변수에서 허용할 Origin 패턴 설정
+ String[] origins = allowedOrigins.split(",");
+ configuration.setAllowedOriginPatterns(Arrays.asList(origins));
+
+ configuration.setAllowedMethods(Arrays.asList("GET", "POST", "PUT", "DELETE", "OPTIONS"));
+ configuration.setAllowedHeaders(Arrays.asList("*"));
+ configuration.setAllowCredentials(true);
+ configuration.setMaxAge(3600L);
+
UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
source.registerCorsConfiguration("/**", configuration);
-
- log.debug("CORS 설정 구성 완료");
return source;
}
- /**
- * 비밀번호 인코더 구성
- *
- * @return BCrypt 패스워드 인코더
- */
@Bean
public PasswordEncoder passwordEncoder() {
- log.debug("Password Encoder 구성 - BCrypt 사용");
- return new BCryptPasswordEncoder();
+ return new BCryptPasswordEncoder(12); // 기본 설정에서 강도 12 사용
}
- /**
- * 인증 매니저 구성
- *
- * @param config 인증 설정
- * @return 인증 매니저
- */
@Bean
public AuthenticationManager authenticationManager(AuthenticationConfiguration config) throws Exception {
- log.debug("Authentication Manager 구성");
return config.getAuthenticationManager();
}
- /**
- * JWT 인증 필터 구성
- *
- * TODO: JWT 토큰 검증 필터 구현
- *
- * @return JWT 인증 필터
- */
- // @Bean
- // public JwtAuthenticationFilter jwtAuthenticationFilter() {
- // return new JwtAuthenticationFilter();
- // }
-
- /**
- * JWT 토큰 제공자 구성
- *
- * TODO: JWT 토큰 생성/검증 서비스 구현
- *
- * @return JWT 토큰 제공자
- */
- // @Bean
- // public JwtTokenProvider jwtTokenProvider() {
- // return new JwtTokenProvider();
- // }
}
\ No newline at end of file
diff --git a/bill-service/src/main/java/com/phonebill/bill/config/SwaggerConfig.java b/bill-service/src/main/java/com/phonebill/bill/config/SwaggerConfig.java
index 2249705..9bf1062 100644
--- a/bill-service/src/main/java/com/phonebill/bill/config/SwaggerConfig.java
+++ b/bill-service/src/main/java/com/phonebill/bill/config/SwaggerConfig.java
@@ -39,9 +39,9 @@ public class SwaggerConfig {
.addServerVariable("port", new io.swagger.v3.oas.models.servers.ServerVariable()
._default("8082")
.description("Server port"))))
- .addSecurityItem(new SecurityRequirement().addList("Bearer Authentication"))
+ .addSecurityItem(new SecurityRequirement().addList("bearerAuth"))
.components(new Components()
- .addSecuritySchemes("Bearer Authentication", createAPIKeyScheme()));
+ .addSecuritySchemes("bearerAuth", createAPIKeyScheme()));
}
private Info apiInfo() {
diff --git a/bill-service/src/main/java/com/phonebill/bill/controller/BillController.java b/bill-service/src/main/java/com/phonebill/bill/controller/BillController.java
index a178341..e3e4759 100644
--- a/bill-service/src/main/java/com/phonebill/bill/controller/BillController.java
+++ b/bill-service/src/main/java/com/phonebill/bill/controller/BillController.java
@@ -1,6 +1,8 @@
package com.phonebill.bill.controller;
import com.phonebill.bill.dto.*;
+import com.phonebill.kosmock.dto.KosCommonResponse;
+import com.phonebill.kosmock.dto.KosBillInquiryResponse;
import com.phonebill.bill.service.BillInquiryService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
@@ -32,7 +34,7 @@ import org.springframework.web.bind.annotation.*;
*/
@Slf4j
@RestController
-@RequestMapping("/bills")
+@RequestMapping("/api/v1/bills")
@RequiredArgsConstructor
@Validated
@Tag(name = "Bill Inquiry", description = "요금조회 관련 API")
@@ -115,63 +117,22 @@ public class BillController {
description = "KOS 시스템 장애 (Circuit Breaker Open)"
)
})
- public ResponseEntity> inquireBill(
+ public ResponseEntity> inquireBill(
@Valid @RequestBody BillInquiryRequest request) {
log.info("요금조회 요청 - 회선번호: {}, 조회월: {}",
request.getLineNumber(), request.getInquiryMonth());
- BillInquiryResponse response = billInquiryService.inquireBill(request);
+ KosBillInquiryResponse response = billInquiryService.inquireBill(request);
- if (response.getStatus() == BillInquiryResponse.ProcessStatus.COMPLETED) {
- log.info("요금조회 완료 - 요청ID: {}, 회선: {}",
- response.getRequestId(), request.getLineNumber());
- return ResponseEntity.ok(
- ApiResponse.success(response, "요금조회가 완료되었습니다")
- );
- } else {
- log.info("요금조회 비동기 처리 - 요청ID: {}, 상태: {}",
- response.getRequestId(), response.getStatus());
- return ResponseEntity.accepted().body(
- ApiResponse.success(response, "요금조회 요청이 접수되었습니다")
- );
- }
- }
-
- /**
- * 요금조회 결과 확인
- *
- * 비동기로 처리된 요금조회 결과를 확인합니다.
- * requestId를 통해 조회 상태와 결과를 반환합니다.
- */
- @GetMapping("/inquiry/{requestId}")
- @Operation(
- summary = "요금조회 결과 확인",
- description = "비동기로 처리된 요금조회의 상태와 결과를 확인합니다.",
- security = @SecurityRequirement(name = "bearerAuth")
- )
- @ApiResponses(value = {
- @io.swagger.v3.oas.annotations.responses.ApiResponse(
- responseCode = "200",
- description = "요금조회 결과 조회 성공"
- ),
- @io.swagger.v3.oas.annotations.responses.ApiResponse(
- responseCode = "404",
- description = "요청 ID를 찾을 수 없음"
- )
- })
- public ResponseEntity> getBillInquiryResult(
- @Parameter(description = "요금조회 요청 ID", example = "REQ_20240308_001")
- @PathVariable String requestId) {
- log.info("요금조회 결과 확인 - 요청ID: {}", requestId);
+ log.info("요금조회 완료 - 요청ID: {}, 회선: {}",
+ response.getRequestId(), request.getLineNumber());
- BillInquiryResponse response = billInquiryService.getBillInquiryResult(requestId);
-
- log.info("요금조회 결과 반환 - 요청ID: {}, 상태: {}", requestId, response.getStatus());
return ResponseEntity.ok(
- ApiResponse.success(response, "요금조회 결과를 조회했습니다")
+ KosCommonResponse.success(response, "요금 조회가 완료되었습니다")
);
}
+
/**
* 요금조회 이력 조회
*
diff --git a/bill-service/src/main/java/com/phonebill/bill/dto/ApiResponse.java b/bill-service/src/main/java/com/phonebill/bill/dto/ApiResponse.java
index 676c3a1..17836c4 100644
--- a/bill-service/src/main/java/com/phonebill/bill/dto/ApiResponse.java
+++ b/bill-service/src/main/java/com/phonebill/bill/dto/ApiResponse.java
@@ -13,10 +13,12 @@ import java.time.LocalDateTime;
*
* 모든 API 응답에 대한 공통 구조를 제공
* - success: 성공/실패 여부
+ * - resultCode: 결과 코드
+ * - resultMessage: 결과 메시지
* - data: 실제 응답 데이터 (성공시)
* - error: 오류 정보 (실패시)
- * - message: 응답 메시지
* - timestamp: 응답 시간
+ * - traceId: 추적 ID
*
* @param 응답 데이터 타입
* @author 이개발(백엔더)
@@ -35,6 +37,16 @@ public class ApiResponse {
*/
private boolean success;
+ /**
+ * 결과 코드
+ */
+ private String resultCode;
+
+ /**
+ * 결과 메시지
+ */
+ private String resultMessage;
+
/**
* 응답 데이터 (성공시에만 포함)
*/
@@ -45,17 +57,17 @@ public class ApiResponse {
*/
private ErrorDetail error;
- /**
- * 응답 메시지
- */
- private String message;
-
/**
* 응답 시간
*/
@Builder.Default
private LocalDateTime timestamp = LocalDateTime.now();
+ /**
+ * 추적 ID
+ */
+ private String traceId;
+
/**
* 성공 응답 생성
*
@@ -67,8 +79,9 @@ public class ApiResponse {
public static ApiResponse success(T data, String message) {
return ApiResponse.builder()
.success(true)
+ .resultCode("0000")
+ .resultMessage(message)
.data(data)
- .message(message)
.build();
}
@@ -93,8 +106,9 @@ public class ApiResponse {
public static ApiResponse failure(ErrorDetail error, String message) {
return ApiResponse.builder()
.success(false)
+ .resultCode(error.getCode())
+ .resultMessage(message)
.error(error)
- .message(message)
.build();
}
@@ -110,7 +124,12 @@ public class ApiResponse {
.code(code)
.message(message)
.build();
- return failure(error, message);
+ return ApiResponse.builder()
+ .success(false)
+ .resultCode(code)
+ .resultMessage(message)
+ .error(error)
+ .build();
}
}
diff --git a/bill-service/src/main/java/com/phonebill/bill/dto/BillInquiryRequest.java b/bill-service/src/main/java/com/phonebill/bill/dto/BillInquiryRequest.java
index 733a9ef..d2c3bb9 100644
--- a/bill-service/src/main/java/com/phonebill/bill/dto/BillInquiryRequest.java
+++ b/bill-service/src/main/java/com/phonebill/bill/dto/BillInquiryRequest.java
@@ -1,5 +1,6 @@
package com.phonebill.bill.dto;
+import com.fasterxml.jackson.annotation.JsonProperty;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.Pattern;
import lombok.AllArgsConstructor;
@@ -28,6 +29,7 @@ public class BillInquiryRequest {
* 조회할 회선번호 (필수)
* 010-XXXX-XXXX 형식만 허용
*/
+ @JsonProperty("lineNumber")
@NotBlank(message = "회선번호는 필수입니다")
@Pattern(
regexp = "^010-\\d{4}-\\d{4}$",
@@ -37,11 +39,12 @@ public class BillInquiryRequest {
/**
* 조회월 (선택)
- * YYYY-MM 형식, 미입력시 당월 조회
+ * YYYYMM 형식, 미입력시 당월 조회
*/
+ @JsonProperty("inquiryMonth")
@Pattern(
- regexp = "^\\d{4}-\\d{2}$",
- message = "조회월은 YYYY-MM 형식이어야 합니다"
+ regexp = "^\\d{6}$",
+ message = "조회월은 YYYYMM 형식이어야 합니다"
)
private String inquiryMonth;
}
\ No newline at end of file
diff --git a/bill-service/src/main/java/com/phonebill/bill/exception/GlobalExceptionHandler.java b/bill-service/src/main/java/com/phonebill/bill/exception/GlobalExceptionHandler.java
index a3f370c..dc7ba95 100644
--- a/bill-service/src/main/java/com/phonebill/bill/exception/GlobalExceptionHandler.java
+++ b/bill-service/src/main/java/com/phonebill/bill/exception/GlobalExceptionHandler.java
@@ -108,7 +108,7 @@ public class GlobalExceptionHandler {
.body(ApiResponse.>builder()
.success(false)
.data(errors)
- .message("입력값이 올바르지 않습니다")
+ .resultMessage("입력값이 올바르지 않습니다")
.timestamp(LocalDateTime.now())
.build());
}
@@ -129,7 +129,7 @@ public class GlobalExceptionHandler {
.body(ApiResponse.>builder()
.success(false)
.data(errors)
- .message("입력값이 올바르지 않습니다")
+ .resultMessage("입력값이 올바르지 않습니다")
.timestamp(LocalDateTime.now())
.build());
}
@@ -152,7 +152,7 @@ public class GlobalExceptionHandler {
.body(ApiResponse.>builder()
.success(false)
.data(errors)
- .message("입력값이 올바르지 않습니다")
+ .resultMessage("입력값이 올바르지 않습니다")
.timestamp(LocalDateTime.now())
.build());
}
diff --git a/bill-service/src/main/java/com/phonebill/bill/external/KosRequest.java b/bill-service/src/main/java/com/phonebill/bill/external/KosRequest.java
index c5e316d..1e5b05a 100644
--- a/bill-service/src/main/java/com/phonebill/bill/external/KosRequest.java
+++ b/bill-service/src/main/java/com/phonebill/bill/external/KosRequest.java
@@ -27,17 +27,23 @@ import java.time.LocalDateTime;
public class KosRequest {
/**
- * 회선번호 (KOS 필드명: lineNum)
+ * 회선번호 (KOS 필드명: lineNumber)
*/
- @JsonProperty("lineNum")
+ @JsonProperty("lineNumber")
private String lineNumber;
/**
- * 조회월 (KOS 필드명: searchMonth, YYYY-MM 형식)
+ * 조회월 (KOS 필드명: billingMonth, YYYYMM 형식)
*/
- @JsonProperty("searchMonth")
+ @JsonProperty("billingMonth")
private String inquiryMonth;
+ /**
+ * 요청 ID (KOS 필드명: requestId)
+ */
+ @JsonProperty("requestId")
+ private String requestId;
+
/**
* 서비스 구분 코드 (KOS 필드명: svcDiv)
* - BILL_INQ: 요금조회
@@ -122,9 +128,14 @@ public class KosRequest {
* @return KOS 요청 객체
*/
public static KosRequest createBillInquiryRequest(String lineNumber, String inquiryMonth, String requestUserId) {
+ // YYYY-MM 형식을 YYYYMM 형식으로 변환
+ String billingMonth = inquiryMonth.replace("-", "");
+ String requestId = "REQ_" + java.time.LocalDateTime.now().format(java.time.format.DateTimeFormatter.ofPattern("yyyyMMdd_HHmmss"));
+
return KosRequest.builder()
- .lineNumber(lineNumber)
- .inquiryMonth(inquiryMonth)
+ .lineNumber(lineNumber.replace("-", "")) // 하이픈 제거
+ .inquiryMonth(billingMonth)
+ .requestId(requestId)
.requestUserId(requestUserId)
.requestTime(LocalDateTime.now())
.requestSequenceNumber(generateSequenceNumber())
diff --git a/bill-service/src/main/java/com/phonebill/bill/repository/BillInquiryHistoryRepository.java b/bill-service/src/main/java/com/phonebill/bill/repository/BillInquiryHistoryRepository.java
index ab0413e..c851bc7 100644
--- a/bill-service/src/main/java/com/phonebill/bill/repository/BillInquiryHistoryRepository.java
+++ b/bill-service/src/main/java/com/phonebill/bill/repository/BillInquiryHistoryRepository.java
@@ -95,12 +95,92 @@ public interface BillInquiryHistoryRepository extends JpaRepository= :startTime) " +
- "AND (:endTime IS NULL OR h.requestTime <= :endTime) " +
- "AND (:status IS NULL OR h.status = :status) " +
"ORDER BY h.requestTime DESC")
- Page findBillHistoryWithFilters(
+ Page findBillHistoryByLineNumbers(
+ @Param("lineNumbers") List lineNumbers,
+ Pageable pageable
+ );
+
+ @Query("SELECT h FROM BillInquiryHistoryEntity h WHERE " +
+ "h.lineNumber IN :lineNumbers " +
+ "AND h.lineNumber = :lineNumber " +
+ "ORDER BY h.requestTime DESC")
+ Page findBillHistoryByLineNumbersAndLineNumber(
+ @Param("lineNumbers") List lineNumbers,
+ @Param("lineNumber") String lineNumber,
+ Pageable pageable
+ );
+
+ @Query("SELECT h FROM BillInquiryHistoryEntity h WHERE " +
+ "h.lineNumber IN :lineNumbers " +
+ "AND h.requestTime >= :startTime " +
+ "AND h.requestTime <= :endTime " +
+ "ORDER BY h.requestTime DESC")
+ Page findBillHistoryByLineNumbersAndDateRange(
+ @Param("lineNumbers") List lineNumbers,
+ @Param("startTime") LocalDateTime startTime,
+ @Param("endTime") LocalDateTime endTime,
+ Pageable pageable
+ );
+
+ @Query("SELECT h FROM BillInquiryHistoryEntity h WHERE " +
+ "h.lineNumber IN :lineNumbers " +
+ "AND h.status = :status " +
+ "ORDER BY h.requestTime DESC")
+ Page findBillHistoryByLineNumbersAndStatus(
+ @Param("lineNumbers") List lineNumbers,
+ @Param("status") String status,
+ Pageable pageable
+ );
+
+ @Query("SELECT h FROM BillInquiryHistoryEntity h WHERE " +
+ "h.lineNumber IN :lineNumbers " +
+ "AND h.lineNumber = :lineNumber " +
+ "AND h.requestTime >= :startTime " +
+ "AND h.requestTime <= :endTime " +
+ "ORDER BY h.requestTime DESC")
+ Page findBillHistoryByLineNumbersAndLineNumberAndDateRange(
+ @Param("lineNumbers") List lineNumbers,
+ @Param("lineNumber") String lineNumber,
+ @Param("startTime") LocalDateTime startTime,
+ @Param("endTime") LocalDateTime endTime,
+ Pageable pageable
+ );
+
+ @Query("SELECT h FROM BillInquiryHistoryEntity h WHERE " +
+ "h.lineNumber IN :lineNumbers " +
+ "AND h.lineNumber = :lineNumber " +
+ "AND h.status = :status " +
+ "ORDER BY h.requestTime DESC")
+ Page findBillHistoryByLineNumbersAndLineNumberAndStatus(
+ @Param("lineNumbers") List lineNumbers,
+ @Param("lineNumber") String lineNumber,
+ @Param("status") String status,
+ Pageable pageable
+ );
+
+ @Query("SELECT h FROM BillInquiryHistoryEntity h WHERE " +
+ "h.lineNumber IN :lineNumbers " +
+ "AND h.requestTime >= :startTime " +
+ "AND h.requestTime <= :endTime " +
+ "AND h.status = :status " +
+ "ORDER BY h.requestTime DESC")
+ Page findBillHistoryByLineNumbersAndDateRangeAndStatus(
+ @Param("lineNumbers") List lineNumbers,
+ @Param("startTime") LocalDateTime startTime,
+ @Param("endTime") LocalDateTime endTime,
+ @Param("status") String status,
+ Pageable pageable
+ );
+
+ @Query("SELECT h FROM BillInquiryHistoryEntity h WHERE " +
+ "h.lineNumber IN :lineNumbers " +
+ "AND h.lineNumber = :lineNumber " +
+ "AND h.requestTime >= :startTime " +
+ "AND h.requestTime <= :endTime " +
+ "AND h.status = :status " +
+ "ORDER BY h.requestTime DESC")
+ Page findBillHistoryWithAllFilters(
@Param("lineNumbers") List lineNumbers,
@Param("lineNumber") String lineNumber,
@Param("startTime") LocalDateTime startTime,
diff --git a/bill-service/src/main/java/com/phonebill/bill/service/BillCacheService.java b/bill-service/src/main/java/com/phonebill/bill/service/BillCacheService.java
index 7c0975b..0e2cfd6 100644
--- a/bill-service/src/main/java/com/phonebill/bill/service/BillCacheService.java
+++ b/bill-service/src/main/java/com/phonebill/bill/service/BillCacheService.java
@@ -55,7 +55,7 @@ public class BillCacheService {
* @param inquiryMonth 조회월
* @return 캐시된 요금 데이터 (없으면 null)
*/
- @Cacheable(value = "billData", key = "#lineNumber + ':' + #inquiryMonth")
+ @Cacheable(value = "billData", key = "#lineNumber + ':' + #inquiryMonth", unless = "#result == null")
public BillInquiryResponse getCachedBillData(String lineNumber, String inquiryMonth) {
log.debug("요금 데이터 캐시 조회 - 회선: {}, 조회월: {}", lineNumber, inquiryMonth);
@@ -90,6 +90,12 @@ public class BillCacheService {
public void cacheBillData(String lineNumber, String inquiryMonth, BillInquiryResponse billData) {
log.debug("요금 데이터 캐시 저장 - 회선: {}, 조회월: {}", lineNumber, inquiryMonth);
+ // null 값은 캐시하지 않음
+ if (billData == null) {
+ log.debug("요금 데이터가 null이므로 캐시 저장을 건너뜀 - 회선: {}, 조회월: {}", lineNumber, inquiryMonth);
+ return;
+ }
+
String cacheKey = BILL_DATA_PREFIX + lineNumber + ":" + inquiryMonth;
try {
diff --git a/bill-service/src/main/java/com/phonebill/bill/service/BillHistoryService.java b/bill-service/src/main/java/com/phonebill/bill/service/BillHistoryService.java
index 46c8832..deb909e 100644
--- a/bill-service/src/main/java/com/phonebill/bill/service/BillHistoryService.java
+++ b/bill-service/src/main/java/com/phonebill/bill/service/BillHistoryService.java
@@ -194,11 +194,9 @@ public class BillHistoryService {
endDateTime = LocalDate.parse(endDate).atTime(23, 59, 59);
}
- String statusFilter = status != null ? status.name() : null;
-
- // 이력 조회
- Page historyPage = historyRepository.findBillHistoryWithFilters(
- userLineNumbers, lineNumber, startDateTime, endDateTime, statusFilter, pageable
+ // 조건에 따라 적절한 쿼리 선택
+ Page historyPage = getBillHistoryByConditions(
+ userLineNumbers, lineNumber, startDateTime, endDateTime, status, pageable
);
// 응답 데이터 변환
@@ -233,6 +231,64 @@ public class BillHistoryService {
}
}
+ /**
+ * 조건에 따라 적절한 쿼리를 선택하여 이력 조회
+ */
+ private Page getBillHistoryByConditions(
+ List userLineNumbers, String lineNumber,
+ LocalDateTime startDateTime, LocalDateTime endDateTime,
+ BillInquiryResponse.ProcessStatus status, Pageable pageable) {
+
+ boolean hasLineNumber = lineNumber != null && !lineNumber.trim().isEmpty();
+ boolean hasDateRange = startDateTime != null && endDateTime != null;
+ boolean hasStatus = status != null;
+
+ String statusFilter = hasStatus ? status.name() : null;
+
+ // 8가지 경우의 수에 따라 적절한 쿼리 선택
+ if (hasLineNumber && hasDateRange && hasStatus) {
+ // 모든 필터 적용
+ return historyRepository.findBillHistoryWithAllFilters(
+ userLineNumbers, lineNumber, startDateTime, endDateTime, statusFilter, pageable
+ );
+ } else if (hasLineNumber && hasDateRange) {
+ // 회선번호 + 날짜 범위
+ return historyRepository.findBillHistoryByLineNumbersAndLineNumberAndDateRange(
+ userLineNumbers, lineNumber, startDateTime, endDateTime, pageable
+ );
+ } else if (hasLineNumber && hasStatus) {
+ // 회선번호 + 상태
+ return historyRepository.findBillHistoryByLineNumbersAndLineNumberAndStatus(
+ userLineNumbers, lineNumber, statusFilter, pageable
+ );
+ } else if (hasDateRange && hasStatus) {
+ // 날짜 범위 + 상태
+ return historyRepository.findBillHistoryByLineNumbersAndDateRangeAndStatus(
+ userLineNumbers, startDateTime, endDateTime, statusFilter, pageable
+ );
+ } else if (hasLineNumber) {
+ // 회선번호만
+ return historyRepository.findBillHistoryByLineNumbersAndLineNumber(
+ userLineNumbers, lineNumber, pageable
+ );
+ } else if (hasDateRange) {
+ // 날짜 범위만
+ return historyRepository.findBillHistoryByLineNumbersAndDateRange(
+ userLineNumbers, startDateTime, endDateTime, pageable
+ );
+ } else if (hasStatus) {
+ // 상태만
+ return historyRepository.findBillHistoryByLineNumbersAndStatus(
+ userLineNumbers, statusFilter, pageable
+ );
+ } else {
+ // 필터 없음 (기본)
+ return historyRepository.findBillHistoryByLineNumbers(
+ userLineNumbers, pageable
+ );
+ }
+ }
+
/**
* 엔티티를 이력 아이템으로 변환
*/
diff --git a/bill-service/src/main/java/com/phonebill/bill/service/BillInquiryService.java b/bill-service/src/main/java/com/phonebill/bill/service/BillInquiryService.java
index ffa920c..2955725 100644
--- a/bill-service/src/main/java/com/phonebill/bill/service/BillInquiryService.java
+++ b/bill-service/src/main/java/com/phonebill/bill/service/BillInquiryService.java
@@ -1,6 +1,7 @@
package com.phonebill.bill.service;
import com.phonebill.bill.dto.*;
+import com.phonebill.kosmock.dto.KosBillInquiryResponse;
/**
* 요금조회 서비스 인터페이스
@@ -41,20 +42,8 @@ public interface BillInquiryService {
* @param request 요금조회 요청 데이터
* @return 요금조회 응답 데이터
*/
- BillInquiryResponse inquireBill(BillInquiryRequest request);
+ KosBillInquiryResponse inquireBill(BillInquiryRequest request);
- /**
- * 요금조회 결과 확인
- *
- * 비동기로 처리된 요금조회의 상태와 결과를 반환
- * - PROCESSING: 처리 중 상태
- * - COMPLETED: 처리 완료 (요금 정보 포함)
- * - FAILED: 처리 실패 (오류 메시지 포함)
- *
- * @param requestId 요금조회 요청 ID
- * @return 요금조회 응답 데이터
- */
- BillInquiryResponse getBillInquiryResult(String requestId);
/**
* 요금조회 이력 조회
diff --git a/bill-service/src/main/java/com/phonebill/bill/service/BillInquiryServiceImpl.java b/bill-service/src/main/java/com/phonebill/bill/service/BillInquiryServiceImpl.java
index 9c9e2a1..48ad737 100644
--- a/bill-service/src/main/java/com/phonebill/bill/service/BillInquiryServiceImpl.java
+++ b/bill-service/src/main/java/com/phonebill/bill/service/BillInquiryServiceImpl.java
@@ -2,8 +2,12 @@ package com.phonebill.bill.service;
import com.phonebill.bill.dto.*;
import com.phonebill.bill.exception.BillInquiryException;
+import com.phonebill.common.security.UserPrincipal;
+import com.phonebill.kosmock.dto.KosBillInquiryResponse;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
+import org.springframework.security.core.Authentication;
+import org.springframework.security.core.context.SecurityContextHolder;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -47,12 +51,11 @@ public class BillInquiryServiceImpl implements BillInquiryService {
log.info("요금조회 메뉴 조회 시작");
// 현재 인증된 사용자의 고객 정보 조회 (JWT에서 추출)
- // TODO: SecurityContext에서 사용자 정보 추출 로직 구현
String customerId = getCurrentCustomerId();
String lineNumber = getCurrentLineNumber();
- // 조회 가능한 월 목록 생성 (최근 12개월)
- List availableMonths = generateAvailableMonths();
+ // 실제 요금 데이터가 있는 월 목록 조회
+ List availableMonths = getAvailableMonthsWithData(lineNumber);
// 현재 월
String currentMonth = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM"));
@@ -77,7 +80,7 @@ public class BillInquiryServiceImpl implements BillInquiryService {
*/
@Override
@Transactional
- public BillInquiryResponse inquireBill(BillInquiryRequest request) {
+ public KosBillInquiryResponse inquireBill(BillInquiryRequest request) {
log.info("요금조회 요청 처리 시작 - 회선: {}, 조회월: {}",
request.getLineNumber(), request.getInquiryMonth());
@@ -87,125 +90,33 @@ public class BillInquiryServiceImpl implements BillInquiryService {
// 조회월 기본값 설정 (미입력시 당월)
String inquiryMonth = request.getInquiryMonth();
if (inquiryMonth == null || inquiryMonth.trim().isEmpty()) {
- inquiryMonth = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM"));
+ inquiryMonth = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMM"));
}
try {
- // 1단계: 캐시에서 데이터 확인 (Cache-Aside 패턴)
- BillInquiryResponse cachedResponse = billCacheService.getCachedBillData(
+ // KOS Mock 서비스 직접 호출
+ KosBillInquiryResponse response = kosClientService.inquireBillFromKosDirect(
request.getLineNumber(), inquiryMonth
);
- if (cachedResponse != null) {
- log.info("캐시에서 요금 데이터 조회 완료 - 요청ID: {}", requestId);
- cachedResponse = BillInquiryResponse.builder()
- .requestId(requestId)
- .status(BillInquiryResponse.ProcessStatus.COMPLETED)
- .billInfo(cachedResponse.getBillInfo())
- .build();
-
- // 이력 저장 (비동기)
- billHistoryService.saveInquiryHistoryAsync(requestId, request, cachedResponse);
- return cachedResponse;
- }
-
- // 2단계: KOS 시스템 연동 (Circuit Breaker 적용)
- CompletableFuture kosResponseFuture = kosClientService.inquireBillFromKos(
- request.getLineNumber(), inquiryMonth
- );
- BillInquiryResponse kosResponse;
- try {
- kosResponse = kosResponseFuture.get();
- } catch (InterruptedException e) {
- Thread.currentThread().interrupt();
- throw new BillInquiryException("요금조회 처리가 중단되었습니다", e);
- } catch (Exception e) {
- throw new BillInquiryException("요금조회 처리 중 오류가 발생했습니다", e);
- }
-
- if (kosResponse != null && kosResponse.getStatus() == BillInquiryResponse.ProcessStatus.COMPLETED) {
- // 3단계: 캐시에 저장 (1시간 TTL)
- billCacheService.cacheBillData(request.getLineNumber(), inquiryMonth, kosResponse);
-
- // 응답 데이터 구성
- BillInquiryResponse response = BillInquiryResponse.builder()
- .requestId(requestId)
- .status(BillInquiryResponse.ProcessStatus.COMPLETED)
- .billInfo(kosResponse.getBillInfo())
- .build();
-
- // 이력 저장 (비동기)
- billHistoryService.saveInquiryHistoryAsync(requestId, request, response);
-
- log.info("KOS 연동을 통한 요금조회 완료 - 요청ID: {}", requestId);
- return response;
- } else {
- // KOS에서 비동기 처리 중인 경우
- BillInquiryResponse response = BillInquiryResponse.builder()
- .requestId(requestId)
- .status(BillInquiryResponse.ProcessStatus.PROCESSING)
- .build();
-
- // 이력 저장 (처리 중 상태)
- billHistoryService.saveInquiryHistoryAsync(requestId, request, response);
-
- log.info("KOS 연동 비동기 처리 - 요청ID: {}", requestId);
- return response;
- }
+ log.info("KOS Mock 요금조회 완료 - 요청ID: {}, 상태: {}",
+ response.getRequestId(), response.getProcStatus());
+ return response;
} catch (Exception e) {
- log.error("요금조회 처리 중 오류 발생 - 요청ID: {}, 오류: {}", requestId, e.getMessage(), e);
+ log.error("KOS Mock 요금조회 실패 - 회선: {}, 오류: {}",
+ request.getLineNumber(), e.getMessage(), e);
- // 실패 응답 생성
- BillInquiryResponse errorResponse = BillInquiryResponse.builder()
+ // 실패 시 기본 응답 반환
+ return KosBillInquiryResponse.builder()
.requestId(requestId)
- .status(BillInquiryResponse.ProcessStatus.FAILED)
+ .procStatus("FAILED")
+ .resultCode("9999")
+ .resultMessage("요금 조회 중 오류가 발생했습니다")
.build();
-
- // 이력 저장 (실패 상태)
- billHistoryService.saveInquiryHistoryAsync(requestId, request, errorResponse);
-
- // 비즈니스 예외는 그대로 던지고, 시스템 예외는 래핑
- if (e instanceof BillInquiryException) {
- throw e;
- } else {
- throw new BillInquiryException("요금조회 처리 중 시스템 오류가 발생했습니다", e);
- }
}
}
- /**
- * 요금조회 결과 확인
- */
- @Override
- public BillInquiryResponse getBillInquiryResult(String requestId) {
- log.info("요금조회 결과 확인 - 요청ID: {}", requestId);
-
- // 이력에서 요청 정보 조회
- BillInquiryResponse response = billHistoryService.getBillInquiryResult(requestId);
-
- if (response == null) {
- throw BillInquiryException.billDataNotFound(requestId, "요청 ID");
- }
-
- // 처리 중인 경우 KOS에서 최신 상태 확인
- if (response.getStatus() == BillInquiryResponse.ProcessStatus.PROCESSING) {
- try {
- BillInquiryResponse latestResponse = kosClientService.checkInquiryStatus(requestId);
- if (latestResponse != null) {
- // 상태 업데이트
- billHistoryService.updateInquiryStatus(requestId, latestResponse);
- response = latestResponse;
- }
- } catch (Exception e) {
- log.warn("KOS 상태 확인 중 오류 발생 - 요청ID: {}, 오류: {}", requestId, e.getMessage());
- // 상태 확인 실패해도 기존 상태 그대로 반환
- }
- }
-
- log.info("요금조회 결과 반환 - 요청ID: {}, 상태: {}", requestId, response.getStatus());
- return response;
- }
/**
* 요금조회 이력 조회
@@ -244,8 +155,21 @@ public class BillInquiryServiceImpl implements BillInquiryService {
* 현재 인증된 사용자의 고객 ID 조회
*/
private String getCurrentCustomerId() {
- // TODO: SecurityContext에서 JWT 토큰을 파싱하여 고객 ID 추출
- // 현재는 더미 데이터 반환
+ // JWT에서 인증된 사용자의 고객 ID 추출
+ Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
+
+ if (authentication != null && authentication.getPrincipal() instanceof UserPrincipal) {
+ UserPrincipal userPrincipal = (UserPrincipal) authentication.getPrincipal();
+ String customerId = userPrincipal.getCustomerId();
+
+ if (customerId != null && !customerId.trim().isEmpty()) {
+ log.debug("사용자 {}의 고객 ID: {}", userPrincipal.getUserId(), customerId);
+ return customerId;
+ }
+ }
+
+ // 인증 정보가 없거나 고객 ID가 없는 경우 기본값 반환
+ log.warn("사용자의 고객 ID 정보를 찾을 수 없습니다. 기본값 사용");
return "CUST001";
}
@@ -253,8 +177,21 @@ public class BillInquiryServiceImpl implements BillInquiryService {
* 현재 인증된 사용자의 회선번호 조회
*/
private String getCurrentLineNumber() {
- // TODO: SecurityContext에서 JWT 토큰을 파싱하여 회선번호 추출
- // 현재는 더미 데이터 반환
+ // JWT에서 인증된 사용자의 회선번호 추출
+ Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
+
+ if (authentication != null && authentication.getPrincipal() instanceof UserPrincipal) {
+ UserPrincipal userPrincipal = (UserPrincipal) authentication.getPrincipal();
+ String lineNumber = userPrincipal.getLineNumber();
+
+ if (lineNumber != null && !lineNumber.trim().isEmpty()) {
+ log.debug("사용자 {}의 회선번호: {}", userPrincipal.getUserId(), lineNumber);
+ return lineNumber;
+ }
+ }
+
+ // 인증 정보가 없거나 회선번호가 없는 경우 기본값 반환
+ log.warn("사용자의 회선번호 정보를 찾을 수 없습니다. 기본값 사용");
return "010-1234-5678";
}
@@ -262,22 +199,60 @@ public class BillInquiryServiceImpl implements BillInquiryService {
* 현재 사용자의 모든 회선번호 목록 조회
*/
private List getCurrentUserLineNumbers() {
- // TODO: 사용자 권한에 따른 회선번호 목록 조회
- // 현재는 더미 데이터 반환
- List lineNumbers = new ArrayList<>();
- lineNumbers.add("010-1234-5678");
- return lineNumbers;
+ // JWT에서 인증된 사용자의 회선번호 추출
+ Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
+
+ if (authentication != null && authentication.getPrincipal() instanceof UserPrincipal) {
+ UserPrincipal userPrincipal = (UserPrincipal) authentication.getPrincipal();
+ String lineNumber = userPrincipal.getLineNumber();
+
+ if (lineNumber != null) {
+ List lineNumbers = new ArrayList<>();
+ lineNumbers.add(lineNumber);
+ log.debug("사용자 {}의 회선번호: {}", userPrincipal.getUserId(), lineNumber);
+ return lineNumbers;
+ }
+ }
+
+ // 인증 정보가 없거나 회선번호가 없는 경우 빈 목록 반환
+ log.warn("사용자의 회선번호 정보를 찾을 수 없습니다");
+ return new ArrayList<>();
}
/**
- * 조회 가능한 월 목록 생성 (최근 12개월)
+ * 실제 요금 데이터가 있는 월 목록 조회
*/
- private List generateAvailableMonths() {
+ private List getAvailableMonthsWithData(String lineNumber) {
+ try {
+ log.info("회선 {}의 실제 요금 데이터가 있는 월 목록 조회", lineNumber);
+
+ // KOS Mock 서비스를 통해 실제 데이터가 있는 월 목록 조회
+ List availableMonths = kosClientService.getAvailableMonths(lineNumber);
+
+ if (availableMonths == null || availableMonths.isEmpty()) {
+ log.warn("KOS에서 조회 가능한 월 정보가 없음. 기본 최근 3개월 반환");
+ return generateDefaultMonths(3);
+ }
+
+ log.info("KOS에서 조회된 데이터 보유 월: {}", availableMonths);
+ return availableMonths;
+
+ } catch (Exception e) {
+ log.error("KOS 시스템에서 조회 가능한 월 정보 조회 실패: {}", e.getMessage(), e);
+ // 실패 시 기본 최근 3개월 반환
+ return generateDefaultMonths(3);
+ }
+ }
+
+ /**
+ * 기본 월 목록 생성 (fallback용)
+ */
+ private List generateDefaultMonths(int monthCount) {
List months = new ArrayList<>();
LocalDate currentDate = LocalDate.now();
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM");
- for (int i = 0; i < 12; i++) {
+ for (int i = 0; i < monthCount; i++) {
LocalDate monthDate = currentDate.minusMonths(i);
months.add(monthDate.format(formatter));
}
diff --git a/bill-service/src/main/java/com/phonebill/bill/service/KosClientService.java b/bill-service/src/main/java/com/phonebill/bill/service/KosClientService.java
index f123d54..3ee2df1 100644
--- a/bill-service/src/main/java/com/phonebill/bill/service/KosClientService.java
+++ b/bill-service/src/main/java/com/phonebill/bill/service/KosClientService.java
@@ -6,6 +6,10 @@ import com.phonebill.bill.exception.CircuitBreakerException;
import com.phonebill.bill.exception.KosConnectionException;
import com.phonebill.bill.external.KosRequest;
import com.phonebill.bill.external.KosResponse;
+import com.phonebill.kosmock.dto.KosCommonResponse;
+import com.phonebill.kosmock.dto.KosBillInquiryResponse;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import java.util.Map;
import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker;
import io.github.resilience4j.retry.annotation.Retry;
import io.github.resilience4j.timelimiter.annotation.TimeLimiter;
@@ -48,7 +52,146 @@ public class KosClientService {
private final KosProperties kosProperties;
/**
- * KOS 시스템에서 요금 정보 조회
+ * KOS Mock 시스템에서 요금 정보 조회 (KosBillInquiryResponse 직접 반환)
+ *
+ * @param lineNumber 회선번호
+ * @param inquiryMonth 조회월
+ * @return KOS 원본 응답 데이터
+ */
+ @CircuitBreaker(name = "kos-bill-inquiry-direct", fallbackMethod = "inquireBillDirectFallback")
+ @Retry(name = "kos-bill-inquiry-direct")
+ public KosBillInquiryResponse inquireBillFromKosDirect(String lineNumber, String inquiryMonth) {
+ log.info("KOS Mock 직접 호출 - 회선: {}, 조회월: {}", lineNumber, inquiryMonth);
+
+ try {
+ // 회선번호 형식 변환 (010-1234-5678 → 01012345678)
+ String formattedLineNumber = lineNumber.replaceAll("-", "");
+
+ // KOS Mock 요청 데이터 구성 (KosBillInquiryRequest 형식)
+ Map kosRequest = Map.of(
+ "lineNumber", formattedLineNumber,
+ "billingMonth", inquiryMonth,
+ "requestId", generateRequestId()
+ );
+
+ // HTTP 헤더 설정
+ HttpHeaders headers = new HttpHeaders();
+ headers.set("Content-Type", "application/json");
+ headers.set("X-Service-Name", "MVNO-BILL-INQUIRY");
+ headers.set("X-Request-ID", java.util.UUID.randomUUID().toString());
+
+ HttpEntity> requestEntity = new HttpEntity<>(kosRequest, headers);
+
+ // KOS Mock API 호출
+ String kosUrl = kosProperties.getBaseUrl() + "/api/v1/kos/bill/inquiry";
+ ResponseEntity