- */
-@Configuration
-@MapperScan(basePackages = "go.kr.project.api.internal.mapper")
-public class ApiMapperConfig {
-}
diff --git a/src/main/java/go/kr/project/api/config/RestTemplateConfig.java b/src/main/java/go/kr/project/api/config/RestTemplateConfig.java
index 771c537..ab73c83 100644
--- a/src/main/java/go/kr/project/api/config/RestTemplateConfig.java
+++ b/src/main/java/go/kr/project/api/config/RestTemplateConfig.java
@@ -22,9 +22,7 @@ import java.io.IOException;
/**
* RestTemplate 설정 클래스
- * VMIS Integration Mode에 따라 다른 설정 적용
- * - Internal Mode: 정부 API 호출용 (빠른 타임아웃)
- * - External Mode: 외부 VMIS-interface API 호출용 (여유 있는 타임아웃)
+ * 외부 VMIS-interface API 호출용 설정
* Apache HttpClient 4 기반 연결 풀 관리 및 타임아웃 설정
*/
@Slf4j
@@ -36,17 +34,9 @@ public class RestTemplateConfig {
@Bean
public RestTemplate restTemplate(RestTemplateBuilder builder) {
- // VMIS Integration Mode에 따라 적절한 설정 선택
- String mode = vmisProperties.getIntegration().getMode();
- VmisProperties.RestTemplateProps.ModeConfig config;
+ VmisProperties.RestTemplateProps config = vmisProperties.getRestTemplate();
- if ("internal".equalsIgnoreCase(mode)) {
- config = vmisProperties.getRestTemplate().getInternal();
- log.info("RestTemplate 설정 - Internal Mode (정부 API 호출용)");
- } else {
- config = vmisProperties.getRestTemplate().getExternal();
- log.info("RestTemplate 설정 - External Mode (외부 VMIS-interface API 호출용)");
- }
+ log.info("RestTemplate 설정 - 외부 VMIS-interface API 호출용");
// 타임아웃 설정
int connectTimeout = config.getTimeout().getConnectTimeoutMillis();
diff --git a/src/main/java/go/kr/project/api/config/VmisIntegrationConfig.java b/src/main/java/go/kr/project/api/config/VmisIntegrationConfig.java
deleted file mode 100644
index bc880ab..0000000
--- a/src/main/java/go/kr/project/api/config/VmisIntegrationConfig.java
+++ /dev/null
@@ -1,117 +0,0 @@
-package go.kr.project.api.config;
-
-import go.kr.project.api.config.properties.VmisProperties;
-import go.kr.project.api.service.VehicleInfoService;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.boot.CommandLineRunner;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-
-/**
- * VMIS 통합 설정 및 모니터링
- *
- *
이 설정 클래스는 VMIS 통합 모드에 대한 정보를 제공하고,
- * 애플리케이션 시작 시 현재 활성화된 모드를 로그로 출력합니다.
- *
- *
주요 기능:
- *
- *
애플리케이션 시작 시 VMIS 통합 모드 출력
- *
활성화된 VehicleInfoService 구현체 표시
- *
설정 검증 및 경고 메시지 출력
- *
- *
- *
지원하는 모드:
- *
- *
internal: 내부 VMIS 모듈 직접 호출 (InternalVehicleInfoServiceImpl)
- *
external: 외부 REST API 호출 (ExternalVehicleInfoServiceImpl)
- *
- */
-@Slf4j
-@Configuration
-@RequiredArgsConstructor
-public class VmisIntegrationConfig {
-
- private final VmisProperties vmisProperties;
-
- /**
- * VMIS 통합 모드 정보 출력
- *
- *
애플리케이션 시작 시 현재 설정된 VMIS 통합 모드와
- * 관련 설정 정보를 로그로 출력합니다.
- *
- * @param vehicleInfoService 활성화된 VehicleInfoService 구현체
- * @return CommandLineRunner
- */
- @Bean
- public CommandLineRunner vmisIntegrationModeLogger(VehicleInfoService vehicleInfoService) {
- return args -> {
- String mode = vmisProperties.getIntegration().getMode();
- String implClass = vehicleInfoService.getClass().getSimpleName();
-
- log.info("========================================");
- log.info("VMIS Integration Mode: {}", mode);
- log.info("Active Implementation: {}", implClass);
- log.info("========================================");
-
- if ("internal".equalsIgnoreCase(mode)) {
- logInternalModeInfo();
- } else if ("external".equalsIgnoreCase(mode)) {
- logExternalModeInfo();
- } else {
- log.warn("알 수 없는 VMIS 통합 모드: {}. 'internal' 또는 'external'을 사용하세요.", mode);
- }
- };
- }
-
- /**
- * Internal 모드 설정 정보 출력
- */
- private void logInternalModeInfo() {
- log.info("[Internal Mode] 내부 VMIS 모듈을 직접 사용합니다");
- log.info(" - 정부 API 호스트: {}://{}",
- vmisProperties.getGov().getScheme(),
- vmisProperties.getGov().getHost());
- log.info(" - 기본사항 조회 경로: {}",
- vmisProperties.getGov().getServices().getBasic().getPath());
- log.info(" - 등록원부 조회 경로: {}",
- vmisProperties.getGov().getServices().getLedger().getPath());
- log.info(" - GPKI 암호화: {}",
- vmisProperties.getGpki().getEnabled());
- log.info(" - 연결 타임아웃: {}ms",
- vmisProperties.getRestTemplate().getInternal().getTimeout().getConnectTimeoutMillis());
- log.info(" - 읽기 타임아웃: {}ms",
- vmisProperties.getRestTemplate().getInternal().getTimeout().getReadTimeoutMillis());
- log.info(" - Rate Limit: 초당 {} 건",
- vmisProperties.getRestTemplate().getInternal().getRateLimit().getPermitsPerSecond());
-
- if ("Y".equalsIgnoreCase(vmisProperties.getGpki().getEnabled())) {
- log.info(" - GPKI 인증서 서버 ID: {}",
- vmisProperties.getGpki().getCertServerId());
- log.info(" - GPKI 대상 서버 ID: {}",
- vmisProperties.getGpki().getTargetServerId());
- } else {
- log.warn(" - GPKI 암호화가 비활성화되어 있습니다. 개발 환경에서만 사용하세요.");
- }
- }
-
- /**
- * External 모드 설정 정보 출력
- */
- private void logExternalModeInfo() {
- log.info("[External Mode] 외부 REST API를 사용합니다");
- log.info(" - 외부 API Base URL: {}",
- vmisProperties.getExternal().getApi().getUrl().getBase());
- log.info(" - 연결 타임아웃: {}ms",
- vmisProperties.getRestTemplate().getExternal().getTimeout().getConnectTimeoutMillis());
- log.info(" - 읽기 타임아웃: {}ms",
- vmisProperties.getRestTemplate().getExternal().getTimeout().getReadTimeoutMillis());
- log.info(" - Rate Limit: 초당 {} 건",
- vmisProperties.getRestTemplate().getExternal().getRateLimit().getPermitsPerSecond());
- log.warn(" - 외부 VMIS-interface 서버가 실행 중이어야 합니다.");
- log.info(" - 기본사항 조회: POST {}",
- vmisProperties.getExternal().getApi().getUrl().buildBasicUrl());
- log.info(" - 등록원부 조회: POST {}",
- vmisProperties.getExternal().getApi().getUrl().buildLedgerUrl());
- }
-}
diff --git a/src/main/java/go/kr/project/api/config/properties/VmisProperties.java b/src/main/java/go/kr/project/api/config/properties/VmisProperties.java
index 499bad6..138e65a 100644
--- a/src/main/java/go/kr/project/api/config/properties/VmisProperties.java
+++ b/src/main/java/go/kr/project/api/config/properties/VmisProperties.java
@@ -2,35 +2,23 @@ package go.kr.project.api.config.properties;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
import org.springframework.validation.annotation.Validated;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
@Data
+@Component
@ConfigurationProperties(prefix = "vmis")
@Validated
public class VmisProperties {
- @NotNull
- private IntegrationProps integration = new IntegrationProps();
@NotNull
private RestTemplateProps restTemplate = new RestTemplateProps();
@NotNull
- private SystemProps system = new SystemProps();
- @NotNull
- private GpkiProps gpki = new GpkiProps();
- @NotNull
- private GovProps gov = new GovProps();
- @NotNull
private ExternalProps external = new ExternalProps();
- @Data
- public static class IntegrationProps {
- @NotBlank
- private String mode = "external";
- }
-
@Data
public static class ExternalProps {
@NotNull
@@ -50,7 +38,7 @@ public class VmisProperties {
@NotBlank
private String ledger = "/ledger"; // 자동차등록원부 엔드포인트 경로
- // 중요: 외부 VMIS-interface 호출용 전체 URL 조합 헬퍼 (공통 RestTemplate 타임아웃 설정 사용)
+ // 외부 VMIS-interface 호출용 전체 URL 조합 헬퍼
public String buildBasicUrl() { return join(base, basic); }
public String buildLedgerUrl() { return join(base, ledger); }
@@ -69,125 +57,30 @@ public class VmisProperties {
}
}
- @Data
- public static class SystemProps {
- @NotBlank
- private String infoSysId;
- /** INFO_SYS_IP */
- private String infoSysIp;
- /** 시군구코드 (SIGUNGU_CODE) */
- private String sigunguCode;
- private String departmentCode;
- // 담당자 정보
- private String chargerId;
- private String chargerIp;
- private String chargerNm;
- }
-
- @Data
- public static class GpkiProps {
- /** "Y" 또는 "N" */
- @NotBlank
- private String enabled = "N";
- private boolean useSign = true;
- @NotBlank
- private String charset = "UTF-8";
- @NotBlank
- private String certServerId;
- @NotBlank
- private String targetServerId;
- // Optional advanced config for native GPKI util
- private Boolean ldap; // null -> util default
- private String gpkiLicPath; // e.g., C:/gpki2/gpkisecureweb/conf
- private String certFilePath; // directory for target cert files when LDAP=false
- private String envCertFilePathName; // ..._env.cer
- private String envPrivateKeyFilePathName; // ..._env.key
- private String envPrivateKeyPasswd;
- private String sigCertFilePathName; // ..._sig.cer
- private String sigPrivateKeyFilePathName; // ..._sig.key
- private String sigPrivateKeyPasswd;
-
- public boolean isEnabledFlag() { return "Y".equalsIgnoreCase(enabled); }
- }
-
@Data
public static class RestTemplateProps {
@NotNull
- private ModeConfig internal = new ModeConfig();
+ private TimeoutConfig timeout = new TimeoutConfig();
@NotNull
- private ModeConfig external = new ModeConfig();
-
- @Data
- public static class ModeConfig {
- @NotNull
- private TimeoutConfig timeout = new TimeoutConfig();
- @NotNull
- private ConnectionPoolConfig connectionPool = new ConnectionPoolConfig();
- @NotNull
- private RateLimitConfig rateLimit = new RateLimitConfig();
-
- @Data
- public static class TimeoutConfig {
- private int connectTimeoutMillis = 10000;
- private int readTimeoutMillis = 12000;
- }
-
- @Data
- public static class ConnectionPoolConfig {
- private int maxTotal = 100;
- private int maxPerRoute = 20;
- }
-
- @Data
- public static class RateLimitConfig {
- private double permitsPerSecond = 5.0;
- }
- }
- }
-
- @Data
- public static class GovProps {
- @NotBlank
- private String scheme = "http";
- @NotBlank
- private String host;
- @NotBlank
- private String basePath;
+ private ConnectionPoolConfig connectionPool = new ConnectionPoolConfig();
@NotNull
- private Services services = new Services();
+ private RateLimitConfig rateLimit = new RateLimitConfig();
- public String buildServiceUrl(String path) {
- StringBuilder sb = new StringBuilder();
- sb.append(scheme).append("://").append(host);
- if (basePath != null && !basePath.isEmpty()) {
- if (!basePath.startsWith("/")) sb.append('/');
- sb.append(basePath);
- }
- if (path != null && !path.isEmpty()) {
- if (!path.startsWith("/")) sb.append('/');
- sb.append(path);
- }
- return sb.toString();
+ @Data
+ public static class TimeoutConfig {
+ private int connectTimeoutMillis = 10000;
+ private int readTimeoutMillis = 12000;
}
@Data
- public static class Services {
- @NotNull
- private Service basic = new Service();
- @NotNull
- private Service ledger = new Service();
+ public static class ConnectionPoolConfig {
+ private int maxTotal = 100;
+ private int maxPerRoute = 20;
}
@Data
- public static class Service {
- @NotBlank
- private String path;
- @NotBlank
- private String cntcInfoCode;
- @NotBlank
- private String apiKey;
- @NotBlank
- private String cvmisApikey;
+ public static class RateLimitConfig {
+ private double permitsPerSecond = 5.0;
}
}
}
diff --git a/src/main/java/go/kr/project/api/controller/VehicleInterfaceController.java b/src/main/java/go/kr/project/api/controller/VehicleInterfaceController.java
index 011d5e2..00ec930 100644
--- a/src/main/java/go/kr/project/api/controller/VehicleInterfaceController.java
+++ b/src/main/java/go/kr/project/api/controller/VehicleInterfaceController.java
@@ -1,12 +1,11 @@
package go.kr.project.api.controller;
import go.kr.project.api.model.Envelope;
-import go.kr.project.api.model.VehicleApiResponseVO;
import go.kr.project.api.model.request.BasicRequest;
import go.kr.project.api.model.request.LedgerRequest;
import go.kr.project.api.model.response.BasicResponse;
import go.kr.project.api.model.response.LedgerResponse;
-import go.kr.project.api.service.VehicleInfoService;
+import go.kr.project.api.service.ExternalVehicleApiService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.media.Content;
import io.swagger.v3.oas.annotations.media.ExampleObject;
@@ -47,45 +46,10 @@ import java.util.Collections;
@RequestMapping("/api/v1/vehicles")
@RequiredArgsConstructor
@Slf4j
-@Tag(name = "VMIS 차량정보 (Swagger)", description = "vmis.integration.mode에 따라 내부/외부 분기 호출")
+@Tag(name = "VMIS 차량정보 (Swagger)", description = "외부 호출")
public class VehicleInterfaceController {
- private final VehicleInfoService vehicleInfoService; // 모드별 구현체 자동 주입
-
- /**
- * 자동차 기본정보 + 등록원부(갑) 통합 조회
- * - Internal/External 공통 진입점 (VehicleInfoService 사용)
- * - 요청은 Envelope 형식으로 VHRNO(차량번호) 및 추가 파라미터 포함
- */
- @PostMapping(value = "/info.ajax", consumes = MediaType.APPLICATION_JSON_VALUE, produces = MediaType.APPLICATION_JSON_VALUE)
- @Operation(
- summary = "자동차 통합 조회 (기본+등록원부)",
- description = "vmis.integration.mode 값에 따라 내부 모듈 또는 외부 REST API를 통해 통합 조회 수행",
- requestBody = @RequestBody(
- content = @Content(
- mediaType = MediaType.APPLICATION_JSON_VALUE,
- examples = @ExampleObject(
- name = "통합 조회 예제",
- value = "{\"data\": [{\"VHRNO\": \"12가3456\",\"LEVY_STDDE\": \"20250101\"}]}"
- )
- )
- )
- )
- public ResponseEntity> info(
- @org.springframework.web.bind.annotation.RequestBody Envelope envelope
- ) {
- // 중요 로직: Swagger 요청 Envelope에서 BasicRequest 추출 (차량번호 및 필수 파라미터 포함)
- BasicRequest request = (envelope != null && !envelope.getData().isEmpty()) ? envelope.getData().get(0) : null;
- if (request == null || request.getVhrno() == null || request.getVhrno().trim().isEmpty()) {
- // 간단한 검증 실패 시 빈 데이터로 반환
- return ResponseEntity.ok(new Envelope<>(Collections.emptyList()));
- }
-
- // VehicleInfoService는 모드에 따라 구현체가 자동 주입됨
- VehicleApiResponseVO resp = vehicleInfoService.getVehicleInfo(request);
- Envelope out = new Envelope<>(resp);
- return ResponseEntity.ok(out);
- }
+ private final ExternalVehicleApiService service;
/**
* 자동차 기본사항만 조회
@@ -115,7 +79,7 @@ public class VehicleInterfaceController {
}
// VehicleInfoService는 모드에 따라 구현체가 자동 주입되어 분기 처리
- BasicResponse basic = vehicleInfoService.getBasicInfo(request);
+ BasicResponse basic = service.getBasicInfo(request);
Envelope out = (basic != null) ? new Envelope<>(basic) : new Envelope<>(Collections.emptyList());
return ResponseEntity.ok(out);
}
@@ -147,8 +111,7 @@ public class VehicleInterfaceController {
return ResponseEntity.ok(new Envelope<>(Collections.emptyList()));
}
- // VehicleInfoService는 모드에 따라 구현체가 자동 주입되어 분기 처리
- LedgerResponse ledger = vehicleInfoService.getLedgerInfo(request);
+ LedgerResponse ledger = service.getLedgerInfo(request);
Envelope out = (ledger != null) ? new Envelope<>(ledger) : new Envelope<>(Collections.emptyList());
return ResponseEntity.ok(out);
}
diff --git a/src/main/java/go/kr/project/api/external/service/impl/ExternalVehicleInfoServiceImpl.java b/src/main/java/go/kr/project/api/external/service/impl/ExternalVehicleInfoServiceImpl.java
deleted file mode 100644
index 0b87a98..0000000
--- a/src/main/java/go/kr/project/api/external/service/impl/ExternalVehicleInfoServiceImpl.java
+++ /dev/null
@@ -1,91 +0,0 @@
-package go.kr.project.api.external.service.impl;
-
-import go.kr.project.api.external.service.ExternalVehicleApiService;
-import go.kr.project.api.model.VehicleApiResponseVO;
-import go.kr.project.api.model.request.BasicRequest;
-import go.kr.project.api.model.request.LedgerRequest;
-import go.kr.project.api.model.response.BasicResponse;
-import go.kr.project.api.model.response.LedgerResponse;
-import go.kr.project.api.service.VehicleInfoService;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.egovframe.rte.fdl.cmmn.EgovAbstractServiceImpl;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
-import org.springframework.stereotype.Service;
-
-/**
- * 외부 REST API를 호출하는 차량 정보 조회 서비스 구현체
- *
- *
이 구현체는 외부 VMIS-interface 서버의 REST API를 호출하여
- * 차량 정보를 조회합니다. 기존 ExternalVehicleApiService를 그대로 활용합니다.
- *
- * @param envelope 자동차 기본사항 조회 요청을 담은 Envelope
- * @return ResponseEntity<Envelope<BasicResponse>> 조회 결과를 담은 응답
- */
- public ResponseEntity> callBasic(Envelope envelope) {
- // 순수한 전송 책임만 수행: DB 로깅은 서비스 레이어에서 처리
- return callModel(ServiceType.BASIC, envelope, new TypeReference>(){});
- }
-
- /**
- * 자동차 등록원부(갑) 조회 API 호출
- *
- *
타입 안전성이 보장되는 자동차 등록원부 조회 메서드입니다.
- * 내부적으로 {@link #callModel}을 호출하여 실제 통신을 수행합니다.
- *
- * @param envelope 자동차 등록원부 조회 요청을 담은 Envelope
- * @return ResponseEntity<Envelope<LedgerResponse>> 조회 결과를 담은 응답
- */
- public ResponseEntity> callLedger(Envelope envelope) {
- // TypeReference를 사용하여 제네릭 타입 정보 전달
- // 익명 클래스를 생성하여 타입 소거(Type Erasure) 문제 해결
- return callModel(ServiceType.LEDGER, envelope, new TypeReference>(){});
- }
-
- /**
- * 정부 API 호출 (타입 안전 모델 기반)
- *
- *
이 메서드는 정부 API 호출의 핵심 로직을 담고 있는 제네릭 메서드입니다.
- * Java 객체를 받아 JSON으로 변환하고, 암호화하여 전송한 후, 응답을 복호화하여
- * 다시 Java 객체로 변환하는 전체 파이프라인을 처리합니다.
- *
- *
Template Method 패턴:
- *
- *
이 메서드는 Template Method 패턴의 템플릿 역할
- *
공통 처리 흐름을 정의하고 서비스별 차이는 파라미터로 처리
- *
코드 중복을 제거하고 일관성을 보장
- *
- *
- *
제네릭 타입 파라미터:
- *
- *
<TReq>: 요청 데이터 타입 (BasicRequest 또는 LedgerRequest)
- *
<TResp>: 응답 데이터 타입 (BasicResponse 또는 LedgerResponse)
- *
타입 안전성을 보장하여 런타임 에러 방지
- *
- *
- *
처리 흐름 (상세):
- *
- *
설정 로드:
- *
서비스 타입에 따라 BASIC 또는 LEDGER 설정 선택
- *
- *
URL 및 트랜잭션 ID 구성:
- *
완전한 API URL 생성
- *
고유 트랜잭션 ID 생성
- *
- *
직렬화 (Serialization):
- *
Java 객체(Envelope<TReq>)를 JSON 문자열로 변환
- *
ObjectMapper.writeValueAsString() 사용
- *
- *
헤더 구성:
- *
buildHeaders() 메서드 호출
- *
모든 필수 헤더 추가
- *
- *
GPKI 암호화 (선택적):
- *
GPKI가 활성화된 경우 JSON을 암호화
- *
gpkiEncrypt() 메서드 호출
- *
- *
HTTP 요청 전송:
- *
RestTemplate.exchange()로 POST 요청
- *
요청 로그 기록
- *
- *
GPKI 복호화 (선택적):
- *
성공 응답(2xx)이고 GPKI가 활성화된 경우
- *
gpkiDecrypt() 메서드 호출
- *
- *
역직렬화 (Deserialization):
- *
JSON 문자열을 Java 객체(Envelope<TResp>)로 변환
- *
TypeReference를 사용하여 제네릭 타입 정보 보존
- *
- *
응답 반환:
- *
ResponseEntity로 감싸서 HTTP 정보 포함
- *
- *
- *
- *
에러 처리 전략 (3단계):
- *
- *
HttpStatusCodeException (HTTP 에러):
- *
- *
정부 API가 4xx 또는 5xx 상태 코드를 반환한 경우
- *
에러 응답 바디를 파싱하여 Envelope 객체로 변환 시도
- *
파싱 실패 시 빈 Envelope 객체 반환
- *
에러 로그 기록 (WARN 레벨)
- *
- *
- *
JSON 파싱 에러:
- *
- *
응답 JSON이 예상한 형식과 다른 경우
- *
RuntimeException으로 래핑하여 상위로 전파
- *
- *
- *
기타 예외:
- *
- *
네트워크 타임아웃, 연결 실패 등
- *
RuntimeException으로 래핑하여 상위로 전파
- *
- *
- *
- *
- *
TypeReference의 필요성:
- *
Java의 제네릭은 런타임에 타입 소거(Type Erasure)가 발생하여
- * {@code objectMapper.readValue(json, Envelope.class)}와 같은 코드는
- * 컴파일되지 않습니다. TypeReference는 익명 클래스를 사용하여 컴파일 타임의
- * 제네릭 타입 정보를 런타임에 전달하는 Jackson의 메커니즘입니다.
- *
- *
로깅 정보:
- *
- *
요청 로그: [GOV-REQ] url, tx_id, gpki, length
- *
에러 로그: [GOV-ERR] status, body
- *
- *
- * @param 요청 데이터의 제네릭 타입
- * @param 응답 데이터의 제네릭 타입
- * @param type 서비스 타입 (BASIC 또는 LEDGER)
- * @param envelope 요청 데이터를 담은 Envelope 객체
- * @param respType 응답 타입에 대한 TypeReference (제네릭 타입 정보 보존용)
- * @return ResponseEntity<Envelope<TResp>> 응답 데이터를 담은 ResponseEntity
- * @throws RuntimeException JSON 직렬화/역직렬화 실패, 네트워크 오류, GPKI 암복호화 실패 등
- */
- private ResponseEntity> callModel(ServiceType type,
- Envelope envelope,
- TypeReference> respType) {
- // 1. 서비스 타입에 따른 설정 로드
- VmisProperties.GovProps gov = props.getGov();
- VmisProperties.GovProps.Service svc = (type == ServiceType.BASIC)
- ? gov.getServices().getBasic()
- : gov.getServices().getLedger();
-
- // 2. URL 및 트랜잭션 ID 생성
- String url = gov.buildServiceUrl(svc.getPath());
- String txId = TxIdUtil.generate();
-
- try {
- // 3. 직렬화: Java 객체 → JSON 문자열
- // ObjectMapper가 Envelope 객체를 JSON으로 변환
- // 날짜, null 값 등의 처리는 ObjectMapper 설정에 따름
- String jsonBody = objectMapper.writeValueAsString(envelope);
-
- // 4. HTTP 헤더 구성
- HttpHeaders headers = buildHeaders(svc, txId);
-
- // 5. GPKI 암호화 처리
- String bodyToSend = jsonBody;
- if (gpkiService.isEnabled()) {
- // JSON 평문을 암호화된 문자열로 변환
- bodyToSend = gpkiEncrypt(jsonBody);
- }
-
- // 6. HTTP 엔티티 생성 (헤더 + 바디)
- HttpEntity request = new HttpEntity<>(bodyToSend, headers);
-
- // 7. 요청 로그 기록
- log.info("[GOV-REQ] url={}, tx_id={}, gpki={}, length={}", url, txId, gpkiService.isEnabled(), bodyToSend != null ? bodyToSend.length() : 0);
-
- // 8. 실제 HTTP POST 요청 전송
- ResponseEntity response = restTemplate.exchange(url, HttpMethod.POST, request, String.class);
- String respBody = response.getBody();
-
- // 9. GPKI 복호화 처리 (성공 응답인 경우만)
- if (gpkiService.isEnabled() && response.getStatusCode().is2xxSuccessful()) {
- // 암호화된 응답을 평문 JSON으로 복호화
- respBody = gpkiDecrypt(respBody);
- }
-
- // 10. 역직렬화: JSON 문자열 → Java 객체
- // TypeReference를 사용하여 제네릭 타입 정보 전달
- Envelope mapped = objectMapper.readValue(respBody, respType);
-
- // 11. 응답 반환 (상태 코드, 헤더, 바디 모두 포함)
- return ResponseEntity.status(response.getStatusCode()).headers(response.getHeaders()).body(mapped);
-
- } catch (HttpStatusCodeException ex) {
- // HTTP 에러 처리 (4xx, 5xx)
- log.warn("[GOV-ERR] status={}, body={}", ex.getStatusCode(), ex.getResponseBodyAsString());
-
- // 에러 응답 바디 파싱 시도
- // 정부 API는 에러 응답도 Envelope 형식으로 반환할 수 있음
- Envelope empty = new Envelope<>();
- try {
- // 에러 응답을 Envelope 객체로 파싱
- Envelope parsed = objectMapper.readValue(ex.getResponseBodyAsString(), respType);
- return ResponseEntity.status(ex.getStatusCode()).headers(ex.getResponseHeaders() != null ? ex.getResponseHeaders() : new HttpHeaders()).body(parsed);
- } catch (Exception parseEx) {
- // 파싱 실패 시 빈 Envelope 반환
- // 호출자는 HTTP 상태 코드로 에러 판단 가능
- return ResponseEntity.status(ex.getStatusCode()).headers(ex.getResponseHeaders() != null ? ex.getResponseHeaders() : new HttpHeaders()).body(empty);
- }
- } catch (Exception e) {
- // 기타 모든 예외 (네트워크 오류, JSON 파싱 오류, GPKI 오류 등)
- // RuntimeException으로 래핑하여 상위로 전파
- // Spring의 @ExceptionHandler에서 처리 가능
- throw new RuntimeException("정부 API 호출 중 오류", e);
- }
- }
-
- /**
- * GPKI 암호화 처리
- *
- *
평문 JSON 문자열을 GPKI(행정전자서명) 알고리즘으로 암호화하는 헬퍼 메서드입니다.
- * 암호화 실패 시 명확한 에러 메시지와 함께 RuntimeException을 발생시킵니다.