envelope
) {
- // YAML 설정값으로 공통 필드 자동 채움
- enricher.enrichLedger(envelope);
- // 실제 처리는 GovernmentApiClient에 위임
- return govClient.callLedger(envelope);
+ // 서비스에서 요청 보강/호출을 오케스트레이션
+ return vehicleService.ledger(envelope);
}
}
diff --git a/src/main/java/com/vmis/interfaceapp/mapper/SampleMapper.java b/src/main/java/com/vmis/interfaceapp/mapper/SampleMapper.java
deleted file mode 100644
index 528aa2c..0000000
--- a/src/main/java/com/vmis/interfaceapp/mapper/SampleMapper.java
+++ /dev/null
@@ -1,26 +0,0 @@
-package com.vmis.interfaceapp.mapper;
-
-import org.apache.ibatis.annotations.Mapper;
-
-/**
- * 샘플 MyBatis Mapper 인터페이스
- *
- * 이 인터페이스는 MyBatis 설정 테스트 및 예제 용도입니다.
- * 실제 프로젝트에서는 비즈니스 요구사항에 맞는 Mapper를 작성하세요.
- *
- * @Mapper 어노테이션을 사용하면 Spring이 자동으로 구현체를 생성합니다.
- * XML 파일의 namespace와 이 인터페이스의 경로가 일치해야 합니다.
- */
-@Mapper
-public interface SampleMapper {
-
- /**
- * 데이터베이스 연결 테스트용 쿼리
- *
- * 현재 시간을 조회하여 데이터베이스 연결이 정상적으로
- * 작동하는지 확인할 수 있습니다.
- *
- * @return 현재 시간 문자열
- */
- String selectCurrentTime();
-}
diff --git a/src/main/java/com/vmis/interfaceapp/service/VehicleInterfaceService.java b/src/main/java/com/vmis/interfaceapp/service/VehicleInterfaceService.java
new file mode 100644
index 0000000..1987d75
--- /dev/null
+++ b/src/main/java/com/vmis/interfaceapp/service/VehicleInterfaceService.java
@@ -0,0 +1,228 @@
+package com.vmis.interfaceapp.service;
+
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.vmis.interfaceapp.client.GovernmentApi;
+import com.vmis.interfaceapp.model.basic.BasicRequest;
+import com.vmis.interfaceapp.model.basic.BasicResponse;
+import com.vmis.interfaceapp.model.basic.CarBassMatterInqireVO;
+import com.vmis.interfaceapp.model.common.Envelope;
+import com.vmis.interfaceapp.model.ledger.LedgerRequest;
+import com.vmis.interfaceapp.model.ledger.LedgerResponse;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * 차량 연계 서비스: 컨트롤러-클라이언트 사이의 오케스트레이션 계층.
+ * - 요청 보강(RequestEnricher)
+ * - 요청/응답 DB 로깅(CarBassMatterInqire)
+ * - 정부 API 클라이언트 위임(GovernmentApi)
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class VehicleInterfaceService {
+
+ private final GovernmentApi governmentApi;
+ private final RequestEnricher enricher;
+ private final CarBassMatterInqireService carBassMatterInqireService;
+
+ /**
+ * 자동차 기본사항 조회: 보강 -> 최초요청로그 -> 외부호출 -> 응답로그.
+ */
+ @Transactional
+ public ResponseEntity> basic(Envelope envelope) {
+ // 1) 요청 보강
+ enricher.enrichBasic(envelope);
+
+ String generatedId = null;
+ try {
+ // 2) 최초 요청 로그 저장 (첫 번째 데이터 기준)
+ if (envelope.getData() != null && !envelope.getData().isEmpty()) {
+ BasicRequest req = envelope.getData().get(0);
+ CarBassMatterInqireVO logEntity = mapInitialLog(req);
+ generatedId = carBassMatterInqireService.createInitialRequest(logEntity);
+ log.info("[BASIC-REQ-LOG] 요청 정보 저장 완료 - ID: {}, 차량번호: {}", generatedId, req.getVhrno());
+ }
+
+ // 3) 외부 API 호출
+ ResponseEntity> response = governmentApi.callBasic(envelope);
+
+ // 4) 응답 로그 업데이트
+ // 원본 소스, 정상적인 호출, 리턴(에러 리턴포함) 일 경우에만 에러 로그 남김
+ if (generatedId != null && response.getBody() != null) {
+ CarBassMatterInqireVO update = mapResponseLog(generatedId, response.getBody());
+ if (update != null) {
+ carBassMatterInqireService.updateResponse(update);
+ log.info("[BASIC-RES-LOG] 응답 정보 저장 완료 - ID: {}", generatedId);
+ }
+ }
+
+ return response;
+ } catch (Exception e) {
+ // 5) 오류 로그 업데이트
+ if (generatedId != null) {
+ try {
+ String detail = buildExceptionDetail(e);
+ CarBassMatterInqireVO errorLog = CarBassMatterInqireVO.builder()
+ .carBassMatterInqire(generatedId)
+ .cntcResultCode("99")
+ .cntcResultDtls(detail)
+ .build();
+ carBassMatterInqireService.updateResponse(errorLog);
+ log.error("[BASIC-ERR-LOG] API 호출 에러 정보 저장 완료 - ID: {}, detail: {}", generatedId, detail, e);
+ } catch (Exception ignore) {
+ log.error("[BASIC-ERR-LOG] 에러 로그 저장 실패 - ID: {}", generatedId, ignore);
+ }
+ }
+ throw e;
+ }
+ }
+
+ /**
+ * 자동차 등록원부(갑) 조회: 보강 -> 외부호출. (별도 로그 테이블 미정)
+ */
+ public ResponseEntity> ledger(Envelope envelope) {
+ enricher.enrichLedger(envelope);
+ return governmentApi.callLedger(envelope);
+ }
+
+ private CarBassMatterInqireVO mapInitialLog(BasicRequest request) {
+ return CarBassMatterInqireVO.builder()
+ .infoSysId(request.getInfoSysId())
+ .infoSysIp(request.getInfoSysIp())
+ .sigunguCode(request.getSigunguCode())
+ .cntcInfoCode(request.getCntcInfoCode())
+ .chargerId(request.getChargerId())
+ .chargerIp(request.getChargerIp())
+ .chargerNm(request.getChargerNm())
+ .dmndLevyStdde(request.getLevyStdde())
+ .dmndInqireSeCode(request.getInqireSeCode())
+ .dmndVhrno(request.getVhrno())
+ .dmndVin(request.getVin())
+ .rgtr("SYSTEM")
+ .build();
+ }
+
+ private CarBassMatterInqireVO mapResponseLog(String id, Envelope envelope) {
+ if (envelope.getData() == null || envelope.getData().isEmpty()) return null;
+ BasicResponse response = envelope.getData().get(0);
+ CarBassMatterInqireVO.CarBassMatterInqireVOBuilder builder = CarBassMatterInqireVO.builder()
+ .carBassMatterInqire(id)
+ .cntcResultCode(response.getCntcResultCode())
+ .cntcResultDtls(response.getCntcResultDtls());
+
+ if (response.getRecord() != null && !response.getRecord().isEmpty()) {
+ BasicResponse.Record record = response.getRecord().get(0);
+ mapRecordToEntity(builder, record);
+ }
+ return builder.build();
+ }
+
+ private void mapRecordToEntity(CarBassMatterInqireVO.CarBassMatterInqireVOBuilder builder, BasicResponse.Record record) {
+ builder
+ .prye(record.getPrye())
+ .registDe(record.getRegistDe())
+ .ersrRegistSeCode(record.getErsrRegistSeCode())
+ .ersrRegistSeNm(record.getErsrRegistSeNm())
+ .ersrRegistDe(record.getErsrRegistDe())
+ .registDetailCode(record.getRegistDetailCode())
+ .dsplvl(record.getDsplvl())
+ .useStrnghldLegaldongCode(record.getUseStrnghldLegaldongCode())
+ .useStrnghldAdstrdCode(record.getUseStrnghldAdstrdCode())
+ .useStrnghldMntn(record.getUseStrnghldMntn())
+ .useStrnghldLnbr(record.getUseStrnghldLnbr())
+ .useStrnghldHo(record.getUseStrnghldHo())
+ .useStrnghldAdresNm(record.getUseStrnghldAdresNm())
+ .useStrnghldRoadNmCode(record.getUseStrnghldRoadNmCode())
+ .usgsrhldUndgrndBuldSeCode(record.getUsgsrhldUndgrndBuldSeCode())
+ .useStrnghldBuldMainNo(record.getUseStrnghldBuldMainNo())
+ .useStrnghldBuldSubNo(record.getUseStrnghldBuldSubNo())
+ .usgsrhldAdresFull(record.getUsgsrhldAdresFull())
+ .mberSeCode(record.getMberSeCode())
+ .mberSeNo(record.getMberSeNo())
+ .mberNm(record.getMberNm())
+ .telno(record.getTelno())
+ .ownerLegaldongCode(record.getOwnerLegaldongCode())
+ .ownerAdstrdCode(record.getOwnerAdstrdCode())
+ .ownerMntn(record.getOwnerMntn())
+ .ownerLnbr(record.getOwnerLnbr())
+ .ownerHo(record.getOwnerHo())
+ .ownerAdresNm(record.getOwnerAdresNm())
+ .ownerRoadNmCode(record.getOwnerRoadNmCode())
+ .ownerUndgrndBuldSeCode(record.getOwnerUndgrndBuldSeCode())
+ .ownerBuldMainNo(record.getOwnerBuldMainNo())
+ .ownerBuldSubNo(record.getOwnerBuldSubNo())
+ .ownrWholaddr(record.getOwnerAdresFull())
+ .aftrVhrno(record.getAftrVhrno())
+ .useFuelCode(record.getUseFuelCode())
+ .prposSeCode(record.getPrposSeCode())
+ .mtrsFomNm(record.getMtrsFomNm())
+ .frntVhrno(record.getFrntVhrno())
+ .vhclno(record.getVhrno())
+ .vin(record.getVin())
+ .cnm(record.getCnm())
+ .vhcleTotWt(record.getVhcleTotWt())
+ .caagEndde(record.getCaagEndde())
+ .changeDe(record.getChangeDe())
+ .vhctyAsortCode(record.getVhctyAsortCode())
+ .vhctyTyCode(record.getVhctyTyCode())
+ .vhctySeCode(record.getVhctySeCode())
+ .mxmmLdg(record.getMxmmLdg())
+ .vhctyAsortNm(record.getVhctyAsortNm())
+ .vhctyTyNm(record.getVhctyTyNm())
+ .vhctySeNm(record.getVhctySeNm())
+ .frstRegistDe(record.getFrstRegistDe())
+ .fomNm(record.getFomNm())
+ .acqsDe(record.getAcqsDe())
+ .acqsEndDe(record.getAcqsEndDe())
+ .yblMd(record.getYblMd())
+ .transrRegistDe(record.getTransrRegistDe())
+ .spcfRegistSttusCode(record.getSpcfRegistSttusCode())
+ .colorNm(record.getColorNm())
+ .mrtgCo(record.getMrtgCo())
+ .seizrCo(record.getSeizrCo())
+ .stmdCo(record.getStmdCo())
+ .nmplCsdyAt(record.getNmplCsdyAt())
+ .nmplCsdyRemnrDe(record.getNmplCsdyRemnrDe())
+ .originSeCode(record.getOriginSeCode())
+ .nmplStndrdCode(record.getNmplStndrdCode())
+ .acqsAmount(record.getAcqsAmount())
+ .insptValidPdBgnde(record.getInsptValidPdBgnde())
+ .insptValidPdEndde(record.getInsptValidPdEndde())
+ .useStrnghldGrcCode(record.getUseStrnghldGrcCode())
+ .tkcarPscapCo(record.getTkcarPscapCo())
+ .spmnno(record.getSpmnno())
+ .trvlDstnc(record.getTrvlDstnc())
+ .frstRegistRqrcno(record.getFrstRegistRqrcno())
+ .vlntErsrPrvntcNticeDe(record.getVlntErsrPrvntcNticeDe())
+ .registInsttNm(record.getRegistInsttNm())
+ .processImprtyResnCode(record.getProcessImprtyResnCode())
+ .processImprtyResnDtls(record.getProcessImprtyResnDtls())
+ .cbdLt(record.getCbdLt())
+ .cbdBt(record.getCbdBt())
+ .cbdHg(record.getCbdHg())
+ .frstMxmmLdg(record.getFrstMxmmLdg())
+ .fuelCnsmpRt(record.getFuelCnsmpRt())
+ .elctyCmpndFuelCnsmpRt(record.getElctyCmpndFuelCnsmpRt());
+ }
+
+ private String buildExceptionDetail(Throwable t) {
+ if (t == null) return "오류: unknown";
+ Throwable root = t;
+ int guard = 0;
+ while (root.getCause() != null && root.getCause() != root && guard++ < 20) {
+ root = root.getCause();
+ }
+ String className = root.getClass().getName();
+ String message = root.getMessage();
+ String detail = (message != null && !message.isEmpty()) ? (className + ": " + message) : root.toString();
+ // DB 컬럼(CNTC_RESULT_DTLS) 길이: 200
+ if (detail.length() > 200) {
+ detail = detail.substring(0, 200);
+ }
+ return detail;
+ }
+}
diff --git a/src/main/resources/mybatis/mapper/sample_maria.xml b/src/main/resources/mybatis/mapper/sample_maria.xml
deleted file mode 100644
index b1a4c7f..0000000
--- a/src/main/resources/mybatis/mapper/sample_maria.xml
+++ /dev/null
@@ -1,44 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-