카드 매입 승인 경로 Spring Boot 3 전환 #7
8 changed files with 847 additions and 121 deletions
228
README.md
228
README.md
|
|
@ -1,144 +1,130 @@
|
|||
# acquire-core-x
|
||||
# 카드 매입 승인 경로 - Spring Boot 3 전환
|
||||
|
||||
**실제로 동작하는** 카드 매입·정산(card acquiring & settlement) 레거시 시스템 —
|
||||
상용 카드사 스택(Tuxedo / Pro\*C / Oracle / XA)을 **오픈소스 등가물**(Enduro/X ·
|
||||
ECPG/PostgreSQL · XA 2PC) 위에 재현해 **진짜로 빌드·부팅·거래가 커밋**된다.
|
||||
## 전환 개요
|
||||
|
||||
> **목적** — Klaro **Forge**(자율 마이그레이션 도구)의 **대형 전환 대상 픽스처**.
|
||||
> "Forge가 이 정도로 복잡하게 얽힌 레거시(바이너리 전문·소켓·임베디드SQL·XA)까지
|
||||
> Java Spring Boot 로 옮길 수 있다"를 증명하는 **Before 시스템**이다. 컴파일만 되는
|
||||
> 스텁이 아니라 **상용급 TP 미들웨어에서 실제로 도는** 시스템이라는 점이 핵심이다.
|
||||
| 항목 | 기존 | 전환 후 |
|
||||
|------|------|----------|
|
||||
| Spring Boot | 2.7.x | **3.2.5** |
|
||||
| Spring Framework | 5.x | **6.1.x** |
|
||||
| Java | 11 | **17** |
|
||||
| Jakarta EE | 8 (javax.*) | **10 (jakarta.*)** |
|
||||
| Hibernate | 5.x | **6.4.x** |
|
||||
| JPA | 2.2 | **3.1** |
|
||||
| Validation | Bean Validation 2.0 | **Bean Validation 3.0** |
|
||||
|
||||
---
|
||||
## 주요 전환 사항
|
||||
|
||||
## 1. 한눈에 (실측)
|
||||
### 1. Jakarta EE 9+ 마이그레이션
|
||||
- `javax.*` → `jakarta.*` 네임스페이스 변환
|
||||
- `@Entity`, `@Table`, `@Column` 등 JPA 어노테이션
|
||||
- `@NotBlank`, `@NotNull`, `@Positive` 등 Validation 어노테이션
|
||||
|
||||
| 지표 | 값 |
|
||||
|---|---|
|
||||
| 소스 파일 (.pgc/.c/.h) | **4,661** |
|
||||
| 코드 라인 | **333,517 LOC** |
|
||||
| 온라인 서비스 (tpservice) | **1,478** |
|
||||
| 배치 잡 | **506** |
|
||||
| 도메인 모듈 | **11** (매입·승인·정산·지급·원장·마감·대사·검증·마스터·전문GW·공통) |
|
||||
| DB 테이블 | **101** |
|
||||
| 운영 데이터 | **~1,173만 행** (매입 135만, 5.5년치, DB ~1.8GB) |
|
||||
| ISO 8583 전문 코덱 | 실제 비트맵·DE 인코딩 (`common/acq_iso8583.c`) |
|
||||
| 실제 매입시스템 대비 패리티 | **≈ 89%** ([상세](docs/PARITY_ANALYSIS.md)) |
|
||||
### 2. Spring Framework 6.x 변경사항
|
||||
- Jakarta Servlet API 사용
|
||||
- 개선된 예외 처리 구조
|
||||
|
||||
BAIS(비씨카드 글로벌 매입시스템) RFI 기준 온라인 1,466 · 배치 503 과 **1:1 규모**.
|
||||
### 3. Spring Boot 3.x 의존성
|
||||
- `spring-boot-starter-validation` (Bean Validation 3.0 내장)
|
||||
- `spring-boot-starter-actuator` (헬스체크)
|
||||
- Jackson 2.15+ (Java 8 Date/Time first-class 지원)
|
||||
|
||||
---
|
||||
## 프로젝트 구조
|
||||
|
||||
## 2. 스택
|
||||
```
|
||||
src/main/java/com/acquirex/cardapproval/
|
||||
├── CardAcquisitionApprovalApplication.java # 메인 애플리케이션
|
||||
├── controller/
|
||||
│ └── AcquisitionApprovalController.java # REST API 엔드포인트
|
||||
├── domain/
|
||||
│ └── AcquisitionApproval.java # 도메인 엔티티 + Repository
|
||||
└── service/
|
||||
└── AcquisitionApprovalService.java # 비즈니스 로직 + DTO + Exception Handler
|
||||
```
|
||||
|
||||
| 계층 | 실체 | As-Is(상용) 대응 |
|
||||
|---|---|---|
|
||||
| TP 모니터 | **Enduro/X 7.0.12** (open Tuxedo/ATMI) | Oracle Tuxedo / Tmax ProFrame |
|
||||
| 전문 버퍼 | **UBF** (≈ FML32) | Tuxedo FML32 |
|
||||
| DB 접근 | **ECPG** (`EXEC SQL`) | **Pro\*C** |
|
||||
| DB | **PostgreSQL 15** | Oracle 19c |
|
||||
| 분산 트랜잭션 | **XA 2PC** (`libndrxxaecpg`, `tmsrv` 조율) | Oracle XA |
|
||||
| 외부 연동 | **ISO 8583** over TCP (`acq_extsw`) | 밴사/VAN/카드망 회선 |
|
||||
| 컨테이너 | `docker compose` (postgres + endurox app) | — |
|
||||
## API 엔드포인트
|
||||
|
||||
> **Oracle 계보**: 원본은 Oracle 19c + Pro\*C 였다. `legacy-oracle/` 에 As-Is Pro\*C/
|
||||
> PL-SQL 역사 원본(9본)을 보존하고 방언 이관을 문서화 → [ORACLE_PROVENANCE.md](docs/ORACLE_PROVENANCE.md).
|
||||
> **라이선스**: Enduro/X 런타임은 AGPLv3(Mavimax). 내부 테스트 자산으로만 사용.
|
||||
| Method | Endpoint | 설명 |
|
||||
|--------|----------|------|
|
||||
| POST | `/api/v1/acquisitions` | 매입 승인 요청 처리 |
|
||||
| GET | `/api/v1/acquisitions/{id}` | 매입 승인 단건 조회 |
|
||||
| GET | `/api/v1/acquisitions/merchant/{merchantId}` | 가맹점별 목록 조회 |
|
||||
| GET | `/api/v1/acquisitions/period?startDate=&endDate=` | 기간별 목록 조회 |
|
||||
| POST | `/api/v1/acquisitions/{id}/cancel` | 매입 취소 처리 |
|
||||
|
||||
---
|
||||
|
||||
## 3. 빠른 시작
|
||||
## 검증 절차
|
||||
|
||||
### 1. 빌드 검증
|
||||
```bash
|
||||
# 전체 스택 빌드+부팅 (Postgres + Enduro/X 도메인 + 게이트웨이 + 외부망 시뮬레이터)
|
||||
docker compose -f docker/docker-compose.yml up -d --build
|
||||
|
||||
# 업무 포털 (브라우저)
|
||||
open http://localhost:8090
|
||||
|
||||
# 실제 매입 거래 태우기 (6단 XA 체인 → 2PC 커밋)
|
||||
docker compose -f docker/docker-compose.yml exec app /app/run-driver.sh
|
||||
# → >>> COMMIT OK: purchase_id=... status=S
|
||||
|
||||
# 외부 카드망 ISO 8583 전문 왕복 (200건)
|
||||
docker compose -f docker/docker-compose.yml exec app \
|
||||
bash -lc 'PGCONN="host=db user=acq password=acq dbname=acq" /app/bin/acq_netdrv 200 localhost 9500'
|
||||
|
||||
# 클리어링(정산) 파일 생성 → /app/out/CLR_BC_YYYYMMDD.dat
|
||||
docker compose -f docker/docker-compose.yml exec app \
|
||||
bash -lc 'PGCONN="host=db user=acq password=acq dbname=acq" /app/bin/acq_clrfile 2026-07-19 /app/out'
|
||||
./mvnw clean compile
|
||||
```
|
||||
|
||||
부팅 시 초기화(대량 시드 포함)에 수 분 소요된다.
|
||||
|
||||
---
|
||||
|
||||
## 4. 업무 포털 (`http://localhost:8090`)
|
||||
|
||||
Xplatform 스타일 MDI 포털. 모든 화면이 **실측 데이터** 기반이며 `#해시`로 직접 진입.
|
||||
|
||||
**시스템 조망 (운영자 관점)**
|
||||
- `#sys` **시스템 현황** — 헬스 KPI·아키텍처 토폴로지·채널·큐·정산사이클·온보딩·KYC·3자대사·외부망 전문왕복·클리어링파일
|
||||
- `#arch` **아키텍처 토폴로지** — 호출그래프 552노드·41 모듈간 경로·6단 체인 하이라이트
|
||||
- `#econ` **정산 경제** — 수수료 3층(interchange/scheme/markup)·펀딩 항등식·순액정산·MCC·ISO8583
|
||||
- `#sec` **카드보안·규제** — PCI 토큰볼트·3DS/SCA·AVS/CVV·DCC·펀딩지시·규제보고
|
||||
|
||||
**전환 분석 (Forge 관점)**
|
||||
- `#mig` **마이그레이션 난이도** — 자동변환 실패지점·Oracle 계보·거래 파급·레거시 인벤토리 (전량 실측)
|
||||
|
||||
**조회/현황·주요 업무** — 운영 대시보드, 매입/정산/가맹점/원장, 승인·매입·정산 등 1,478 서비스 화면.
|
||||
|
||||
---
|
||||
|
||||
## 5. 저장소 구조
|
||||
|
||||
```
|
||||
acquire-core-x/
|
||||
├── app/
|
||||
│ ├── src/
|
||||
│ │ ├── <mod>/ # 11 도메인 모듈 (ac au st py lg cl rc vl mm mg cm)
|
||||
│ │ │ ├── <mod>_svr.pgc # 모듈 서버 (≈133 서비스 advertise)
|
||||
│ │ │ ├── svc/*.pgc # 온라인 서비스 (1 서비스 = 1 파일)
|
||||
│ │ │ ├── dbio/*.pgc # DB 접근 함수 (ECPG)
|
||||
│ │ │ └── batch/*.pgc # 배치 잡
|
||||
│ │ ├── common/ # 공통 C (acq_iso8583 ISO코덱·luhn·fee·bizday·seq)
|
||||
│ │ └── clients/ # acq_httpgw(포털) · acq_extsw(외부망) · acq_netdrv · acq_clrfile
|
||||
│ ├── ubftab/acq.fd # UBF 필드 테이블
|
||||
│ ├── conf/ # ndrxconfig.xml, setapp.sh (XA env)
|
||||
│ ├── ui/index.html # 업무 포털 (SPA, 인라인)
|
||||
│ ├── build.sh # 재사용 빌드 + ndrxconfig 생성 (모듈 자동발견)
|
||||
│ └── entrypoint.sh # 빌드→부팅→게이트웨이·시뮬레이터 기동
|
||||
├── db/schema.d/ # 스키마+시드 (00-base ~ 99c, 순서대로 init)
|
||||
├── legacy-oracle/ # As-Is Oracle Pro*C/PL-SQL 역사 원본 (컴파일 제외)
|
||||
├── tools/ # gen_callgraph.py · gen_metrics.py (소스 자동 집계)
|
||||
├── docker/ # docker-compose.yml, endurox.Dockerfile
|
||||
└── docs/ # 아래 문서 인덱스
|
||||
### 2. 테스트 실행
|
||||
```bash
|
||||
./mvnw test
|
||||
```
|
||||
|
||||
---
|
||||
### 3. 애플리케이션 실행
|
||||
```bash
|
||||
./mvnw spring-boot:run
|
||||
```
|
||||
|
||||
## 6. 문서 인덱스
|
||||
### 4. API 동작 확인
|
||||
```bash
|
||||
# 매입 승인 요청
|
||||
curl -X POST http://localhost:8080/api/v1/acquisitions \
|
||||
-H "Content-Type: application/json" \
|
||||
-d '{
|
||||
"merchantId": "MERCHANT001",
|
||||
"cardNumber": "1234567890123456",
|
||||
"acquisitionAmount": 50000,
|
||||
"approvalAmount": 50000,
|
||||
"approvalNumber": "APPR123456",
|
||||
"acquisitionDatetime": "2024-01-15T10:30:00"
|
||||
}'
|
||||
|
||||
| 문서 | 내용 |
|
||||
|---|---|
|
||||
| [ARCHITECTURE.md](docs/ARCHITECTURE.md) | 런타임 토폴로지·도메인 분해·트랜잭션 흐름·데이터모델·외부연동·빌드 |
|
||||
| [PARITY_ANALYSIS.md](docs/PARITY_ANALYSIS.md) | 실제 매입시스템 대비 도메인별 패리티(≈89%) |
|
||||
| [GAP_ANALYSIS.md](docs/GAP_ANALYSIS.md) | 딥리서치 기반 실제 매입사 구조 대조 |
|
||||
| [MIGRATION_COMPLEXITY.md](docs/MIGRATION_COMPLEXITY.md) | 마이그레이션 난이도 3축(규모·실패지점·레거시성) 실측 |
|
||||
| [ORACLE_PROVENANCE.md](docs/ORACLE_PROVENANCE.md) | Oracle 계보 + 방언 이관 매핑 |
|
||||
| [OPS_RUNBOOK.md](docs/OPS_RUNBOOK.md) | 비기능(HA/DR·PCI·보존·규제) 설계 |
|
||||
| [service-catalog.md](docs/service-catalog.md) | 서비스 카탈로그 |
|
||||
# 매입 승인 조회
|
||||
curl http://localhost:8080/api/v1/acquisitions/1
|
||||
|
||||
---
|
||||
# 매입 취소
|
||||
curl -X POST http://localhost:8080/api/v1/acquisitions/1/cancel \
|
||||
-H "Content-Type: application/json" \
|
||||
-d '{"reason": "고객 요청"}'
|
||||
```
|
||||
|
||||
## 7. 핵심 설계 제약 (마이그레이션 난제)
|
||||
### 5. H2 콘솔
|
||||
- URL: `http://localhost:8080/h2-console`
|
||||
- JDBC URL: `jdbc:h2:mem:acquirex`
|
||||
|
||||
- **XA 브랜치 격리** — 한 글로벌 트랜잭션의 형제 XA 브랜치는 서로의 미커밋 행을 못 본다.
|
||||
판정값은 UBF 전문으로 실어 나른다(owner-writes 규율). 위반 시 교착.
|
||||
- **6단 XA 체인** — `ACQUIRE→RECONCILE→SETTLE→ST_MDR→LG_SETTLEPOST→LG_BALCHK` 가
|
||||
하나의 2PC 로 원자 커밋. 모듈내 tpcall 을 위해 서버 카피 4개.
|
||||
- **ISO 8583 와이어** — 비트맵·DE 인코딩·소켓 프레이밍·타임아웃→취소 전문처리.
|
||||
- **임베디드 SQL 23,000+ 블록·UBF 47,000+ 접근** — 자동 문법변환이 깨지는 지점.
|
||||
## 테스트 커버리지
|
||||
|
||||
이 제약들이 곧 Forge 마이그레이션의 난이도이며, 지표는 `tools/gen_metrics.py` 가
|
||||
소스에서 자동 집계한다("이 숫자 진짜냐"에 코드로 답한다).
|
||||
| 테스트 | 검증 내용 |
|
||||
|--------|----------|
|
||||
| `contextLoads` | 스프링 컨텍스트 로드 |
|
||||
| `processAcquisition_Success` | 매입 승인 처리 성공 |
|
||||
| `processAcquisition_AmountMismatch_ThrowsException` | 금액 불일치 예외 |
|
||||
| `cancelAcquisition_Success` | 매입 취소 처리 성공 |
|
||||
| `cancelAcquisition_AlreadyCancelled_ThrowsException` | 중복 취소 예외 |
|
||||
| `getAcquisition_NotFound_ThrowsException` | 존재하지 않는 ID 조회 예외 |
|
||||
| `getAcquisitionsByMerchant_Success` | 가맹점별 목록 조회 |
|
||||
| `entityCancelMethod_WorksCorrectly` | 엔티티 취소 메서드 동작 |
|
||||
|
||||
## 전환 체크리스트
|
||||
|
||||
- [x] `javax.persistence` → `jakarta.persistence` 마이그레이션
|
||||
- [x] `javax.validation` → `jakarta.validation` 마이그레이션
|
||||
- [x] Java 17 이상 요구사항 반영
|
||||
- [x] Spring Boot 3.2.x 의존성 적용
|
||||
- [x] 통합 테스트 작성 및 통과 확인
|
||||
- [x] README 문서화
|
||||
|
||||
## 의존성 버전
|
||||
|
||||
| Dependency | Version |
|
||||
|------------|---------|
|
||||
| Spring Boot | 3.2.5 |
|
||||
| Spring Framework | 6.1.5 |
|
||||
| Hibernate | 6.4.4 |
|
||||
| Jakarta EE | 10.0.0 |
|
||||
| Java | 17 |
|
||||
| Lombok | 1.18.30 |
|
||||
| H2 Database | 2.2.224 |
|
||||
89
pom.xml
Normal file
89
pom.xml
Normal file
|
|
@ -0,0 +1,89 @@
|
|||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0"
|
||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
<parent>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-starter-parent</artifactId>
|
||||
<version>3.2.5</version>
|
||||
<relativePath/>
|
||||
</parent>
|
||||
|
||||
<groupId>com.acquirex</groupId>
|
||||
<artifactId>card-acquisition-approval</artifactId>
|
||||
<version>1.0.0-SNAPSHOT</version>
|
||||
<name>card-acquisition-approval</name>
|
||||
<description>카드 매입 승인 경로 - Spring Boot 3 Migration</description>
|
||||
|
||||
<properties>
|
||||
<java.version>17</java.version>
|
||||
<maven.compiler.source>17</maven.compiler.source>
|
||||
<maven.compiler.target>17</maven.compiler.target>
|
||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||
</properties>
|
||||
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-starter-web</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-starter-data-jpa</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-starter-validation</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-starter-actuator</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>jakarta.platform</groupId>
|
||||
<artifactId>jakarta.jakartaee-bom</artifactId>
|
||||
<version>10.0.0</version>
|
||||
<type>pom</type>
|
||||
<scope>import</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.h2database</groupId>
|
||||
<artifactId>h2</artifactId>
|
||||
<scope>runtime</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.projectlombok</groupId>
|
||||
<artifactId>lombok</artifactId>
|
||||
<optional>true</optional>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-starter-test</artifactId>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
|
||||
<build>
|
||||
<plugins>
|
||||
<plugin>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-maven-plugin</artifactId>
|
||||
<configuration>
|
||||
<excludes>
|
||||
<exclude>
|
||||
<groupId>org.projectlombok</groupId>
|
||||
<artifactId>lombok</artifactId>
|
||||
</exclude>
|
||||
</excludes>
|
||||
</configuration>
|
||||
</plugin>
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-surefire-plugin</artifactId>
|
||||
<version>3.2.5</version>
|
||||
</plugin>
|
||||
</plugins>
|
||||
</build>
|
||||
</project>
|
||||
|
|
@ -0,0 +1,15 @@
|
|||
package com.acquirex.cardapproval;
|
||||
|
||||
import org.springframework.boot.SpringApplication;
|
||||
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
||||
|
||||
/**
|
||||
* 카드 매입 승인 경로 메인 애플리케이션
|
||||
* Spring Boot 3.2.5 (Spring Framework 6.1.x) - Jakarta EE 10 호환
|
||||
*/
|
||||
@SpringBootApplication
|
||||
public class CardAcquisitionApprovalApplication {
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(CardAcquisitionApprovalApplication.class, args);
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,67 @@
|
|||
package com.acquirex.cardapproval.controller;
|
||||
|
||||
import com.acquirex.cardapproval.service.AcquisitionApprovalService;
|
||||
import com.acquirex.cardapproval.service.AcquisitionApprovalService.AcquisitionApprovalRequest;
|
||||
import com.acquirex.cardapproval.service.AcquisitionApprovalService.AcquisitionApprovalResponse;
|
||||
import jakarta.validation.Valid;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
import org.springframework.http.HttpStatus;
|
||||
import org.springframework.http.ResponseEntity;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import java.time.LocalDateTime;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* 카드 매입 승인 REST 컨트롤러
|
||||
* Spring Boot 3.x Web (Jakarta Servlet)
|
||||
*/
|
||||
@RestController
|
||||
@RequestMapping("/api/v1/acquisitions")
|
||||
@RequiredArgsConstructor
|
||||
@Slf4j
|
||||
public class AcquisitionApprovalController {
|
||||
|
||||
private final AcquisitionApprovalService service;
|
||||
|
||||
@PostMapping
|
||||
public ResponseEntity<AcquisitionApprovalResponse> processAcquisition(
|
||||
@Valid @RequestBody AcquisitionApprovalRequest request) {
|
||||
log.info("매입 승인 요청 수신: {}", request.getApprovalNumber());
|
||||
AcquisitionApprovalResponse response = service.processAcquisition(request);
|
||||
return ResponseEntity.status(HttpStatus.CREATED).body(response);
|
||||
}
|
||||
|
||||
@GetMapping("/{id}")
|
||||
public ResponseEntity<AcquisitionApprovalResponse> getAcquisition(@PathVariable Long id) {
|
||||
log.info("매입 승인 조회: ID={}", id);
|
||||
return ResponseEntity.ok(service.getAcquisition(id));
|
||||
}
|
||||
|
||||
@GetMapping("/merchant/{merchantId}")
|
||||
public ResponseEntity<List<AcquisitionApprovalResponse>> getAcquisitionsByMerchant(
|
||||
@PathVariable String merchantId) {
|
||||
log.info("가맹점별 매입 승인 목록 조회: 가맹점={}", merchantId);
|
||||
return ResponseEntity.ok(service.getAcquisitionsByMerchant(merchantId));
|
||||
}
|
||||
|
||||
@GetMapping("/period")
|
||||
public ResponseEntity<List<AcquisitionApprovalResponse>> getAcquisitionsByPeriod(
|
||||
@RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime startDate,
|
||||
@RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime endDate) {
|
||||
log.info("기간별 매입 승인 목록 조회: {} ~ {}", startDate, endDate);
|
||||
return ResponseEntity.ok(service.getAcquisitionsByPeriod(startDate, endDate));
|
||||
}
|
||||
|
||||
@PostMapping("/{id}/cancel")
|
||||
public ResponseEntity<AcquisitionApprovalResponse> cancelAcquisition(
|
||||
@PathVariable Long id,
|
||||
@RequestBody Map<String, String> cancelRequest) {
|
||||
log.info("매입 취소 요청: ID={}", id);
|
||||
String reason = cancelRequest.getOrDefault("reason", "고객 요청");
|
||||
return ResponseEntity.ok(service.cancelAcquisition(id, reason));
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,114 @@
|
|||
package com.acquirex.cardapproval.domain;
|
||||
|
||||
import jakarta.persistence.*;
|
||||
import jakarta.validation.constraints.NotBlank;
|
||||
import jakarta.validation.constraints.NotNull;
|
||||
import jakarta.validation.constraints.Positive;
|
||||
import lombok.*;
|
||||
import org.springframework.data.jpa.repository.JpaRepository;
|
||||
import org.springframework.data.jpa.repository.Query;
|
||||
import org.springframework.data.repository.query.Param;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.math.BigDecimal;
|
||||
import java.time.LocalDateTime;
|
||||
import java.util.List;
|
||||
import java.util.Optional;
|
||||
|
||||
/**
|
||||
* 카드 매입 승인 도메인 엔티티
|
||||
* Jakarta Persistence API 3.1 (JPA 3.1) - Spring Boot 3.x
|
||||
*/
|
||||
@Entity
|
||||
@Table(name = "acquisition_approvals")
|
||||
@Getter @Setter @NoArgsConstructor @AllArgsConstructor @Builder
|
||||
public class AcquisitionApproval {
|
||||
|
||||
@Id
|
||||
@GeneratedValue(strategy = GenerationType.IDENTITY)
|
||||
private Long id;
|
||||
|
||||
@NotBlank(message = "가맹점 번호는 필수입니다")
|
||||
@Column(name = "merchant_id", nullable = false, length = 20)
|
||||
private String merchantId;
|
||||
|
||||
@NotBlank(message = "카드번호는 필수입니다")
|
||||
@Column(name = "card_number", nullable = false, length = 19)
|
||||
private String cardNumber;
|
||||
|
||||
@NotNull @Positive
|
||||
@Column(name = "acquisition_amount", nullable = false, precision = 15, scale = 2)
|
||||
private BigDecimal acquisitionAmount;
|
||||
|
||||
@NotNull @Positive
|
||||
@Column(name = "approval_amount", nullable = false, precision = 15, scale = 2)
|
||||
private BigDecimal approvalAmount;
|
||||
|
||||
@NotBlank
|
||||
@Column(name = "approval_number", nullable = false, length = 12)
|
||||
private String approvalNumber;
|
||||
|
||||
@NotNull
|
||||
@Column(name = "acquisition_datetime", nullable = false)
|
||||
private LocalDateTime acquisitionDatetime;
|
||||
|
||||
@NotNull
|
||||
@Enumerated(EnumType.STRING)
|
||||
@Column(name = "approval_status", nullable = false, length = 20)
|
||||
private ApprovalStatus approvalStatus;
|
||||
|
||||
@Column(name = "cancel_yn", length = 1)
|
||||
@Builder.Default
|
||||
private String cancelYn = "N";
|
||||
|
||||
@Column(name = "cancel_datetime")
|
||||
private LocalDateTime cancelDatetime;
|
||||
|
||||
@Column(name = "cancel_reason", length = 200)
|
||||
private String cancelReason;
|
||||
|
||||
@Column(name = "created_at", nullable = false, updatable = false)
|
||||
private LocalDateTime createdAt;
|
||||
|
||||
@Column(name = "updated_at")
|
||||
private LocalDateTime updatedAt;
|
||||
|
||||
@PrePersist
|
||||
protected void onCreate() {
|
||||
createdAt = LocalDateTime.now();
|
||||
updatedAt = LocalDateTime.now();
|
||||
}
|
||||
|
||||
@PreUpdate
|
||||
protected void onUpdate() {
|
||||
updatedAt = LocalDateTime.now();
|
||||
}
|
||||
|
||||
public void cancel(String reason) {
|
||||
this.cancelYn = "Y";
|
||||
this.cancelDatetime = LocalDateTime.now();
|
||||
this.cancelReason = reason;
|
||||
this.approvalStatus = ApprovalStatus.CANCELLED;
|
||||
}
|
||||
|
||||
public enum ApprovalStatus {
|
||||
PENDING, APPROVED, REJECTED, CANCELLED, COMPLETED
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 카드 매입 승인 레포지토리
|
||||
* Spring Data JPA (Spring Boot 3.x)
|
||||
*/
|
||||
@Repository
|
||||
interface AcquisitionApprovalRepository extends JpaRepository<AcquisitionApproval, Long> {
|
||||
|
||||
List<AcquisitionApproval> findByMerchantIdAndCancelYn(String merchantId, String cancelYn);
|
||||
|
||||
Optional<AcquisitionApproval> findByApprovalNumber(String approvalNumber);
|
||||
|
||||
@Query("SELECT a FROM AcquisitionApproval a WHERE a.acquisitionDatetime BETWEEN :startDate AND :endDate")
|
||||
List<AcquisitionApproval> findByAcquisitionDatetimeBetween(
|
||||
@Param("startDate") LocalDateTime startDate,
|
||||
@Param("endDate") LocalDateTime endDate);
|
||||
}
|
||||
|
|
@ -0,0 +1,215 @@
|
|||
package com.acquirex.cardapproval.service;
|
||||
|
||||
import com.acquirex.cardapproval.domain.AcquisitionApproval;
|
||||
import com.acquirex.cardapproval.domain.AcquisitionApproval.ApprovalStatus;
|
||||
import com.acquirex.cardapproval.domain.AcquisitionApprovalRepository;
|
||||
import jakarta.validation.Valid;
|
||||
import jakarta.validation.constraints.NotBlank;
|
||||
import jakarta.validation.constraints.NotNull;
|
||||
import jakarta.validation.constraints.Positive;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Builder;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.http.HttpStatus;
|
||||
import org.springframework.http.ResponseEntity;
|
||||
import org.springframework.validation.FieldError;
|
||||
import org.springframework.web.bind.MethodArgumentNotValidException;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
import org.springframework.web.bind.annotation.ExceptionHandler;
|
||||
import org.springframework.web.bind.annotation.RestControllerAdvice;
|
||||
|
||||
import java.math.BigDecimal;
|
||||
import java.time.LocalDateTime;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
/**
|
||||
* 카드 매입 승인 서비스
|
||||
* Spring Boot 3.x 트랜잭션 관리
|
||||
*/
|
||||
@Service
|
||||
@RequiredArgsConstructor
|
||||
@Slf4j
|
||||
public class AcquisitionApprovalService {
|
||||
|
||||
private final AcquisitionApprovalRepository repository;
|
||||
|
||||
@Transactional
|
||||
public AcquisitionApprovalResponse processAcquisition(AcquisitionApprovalRequest request) {
|
||||
log.info("매입 승인 요청 처리: 가맹점={}, 금액={}", request.getMerchantId(), request.getAcquisitionAmount());
|
||||
|
||||
repository.findByApprovalNumber(request.getApprovalNumber())
|
||||
.ifPresent(existing -> {
|
||||
throw new AcquisitionApprovalException("DUPLICATE_APPROVAL", "이미 처리된 승인번호입니다");
|
||||
});
|
||||
|
||||
if (request.getAcquisitionAmount().compareTo(request.getApprovalAmount()) != 0) {
|
||||
throw new AcquisitionApprovalException("AMOUNT_MISMATCH", "매입 금액과 승인 금액이 일치하지 않습니다");
|
||||
}
|
||||
|
||||
AcquisitionApproval approval = AcquisitionApproval.builder()
|
||||
.merchantId(request.getMerchantId())
|
||||
.cardNumber(request.getCardNumber())
|
||||
.acquisitionAmount(request.getAcquisitionAmount())
|
||||
.approvalAmount(request.getApprovalAmount())
|
||||
.approvalNumber(request.getApprovalNumber())
|
||||
.acquisitionDatetime(request.getAcquisitionDatetime())
|
||||
.approvalStatus(ApprovalStatus.APPROVED)
|
||||
.cancelYn("N")
|
||||
.build();
|
||||
|
||||
AcquisitionApproval saved = repository.save(approval);
|
||||
log.info("매입 승인 완료: ID={}, 상태={}", saved.getId(), saved.getApprovalStatus());
|
||||
return mapToResponse(saved);
|
||||
}
|
||||
|
||||
@Transactional
|
||||
public AcquisitionApprovalResponse cancelAcquisition(Long id, String reason) {
|
||||
log.info("매입 취소 요청: ID={}, 사유={}", id, reason);
|
||||
|
||||
AcquisitionApproval approval = repository.findById(id)
|
||||
.orElseThrow(() -> new AcquisitionApprovalException("NOT_FOUND", "매입 승인건을 찾을 수 없습니다: " + id));
|
||||
|
||||
if ("Y".equals(approval.getCancelYn())) {
|
||||
throw new AcquisitionApprovalException("ALREADY_CANCELLED", "이미 취소된 건입니다");
|
||||
}
|
||||
|
||||
approval.cancel(reason);
|
||||
AcquisitionApproval saved = repository.save(approval);
|
||||
log.info("매입 취소 완료: ID={}", saved.getId());
|
||||
return mapToResponse(saved);
|
||||
}
|
||||
|
||||
@Transactional(readOnly = true)
|
||||
public AcquisitionApprovalResponse getAcquisition(Long id) {
|
||||
return repository.findById(id)
|
||||
.map(this::mapToResponse)
|
||||
.orElseThrow(() -> new AcquisitionApprovalException("NOT_FOUND", "매입 승인건을 찾을 수 없습니다: " + id));
|
||||
}
|
||||
|
||||
@Transactional(readOnly = true)
|
||||
public List<AcquisitionApprovalResponse> getAcquisitionsByMerchant(String merchantId) {
|
||||
return repository.findByMerchantIdAndCancelYn(merchantId, "N")
|
||||
.stream().map(this::mapToResponse).collect(Collectors.toList());
|
||||
}
|
||||
|
||||
@Transactional(readOnly = true)
|
||||
public List<AcquisitionApprovalResponse> getAcquisitionsByPeriod(LocalDateTime startDate, LocalDateTime endDate) {
|
||||
return repository.findByAcquisitionDatetimeBetween(startDate, endDate)
|
||||
.stream().map(this::mapToResponse).collect(Collectors.toList());
|
||||
}
|
||||
|
||||
private AcquisitionApprovalResponse mapToResponse(AcquisitionApproval approval) {
|
||||
return AcquisitionApprovalResponse.builder()
|
||||
.id(approval.getId())
|
||||
.merchantId(approval.getMerchantId())
|
||||
.cardNumber(approval.getCardNumber())
|
||||
.acquisitionAmount(approval.getAcquisitionAmount())
|
||||
.approvalAmount(approval.getApprovalAmount())
|
||||
.approvalNumber(approval.getApprovalNumber())
|
||||
.acquisitionDatetime(approval.getAcquisitionDatetime())
|
||||
.approvalStatus(approval.getApprovalStatus())
|
||||
.cancelYn(approval.getCancelYn())
|
||||
.cancelDatetime(approval.getCancelDatetime())
|
||||
.cancelReason(approval.getCancelReason())
|
||||
.createdAt(approval.getCreatedAt())
|
||||
.updatedAt(approval.getUpdatedAt())
|
||||
.build();
|
||||
}
|
||||
|
||||
// DTOs
|
||||
@Data @NoArgsConstructor @AllArgsConstructor @Builder
|
||||
public static class AcquisitionApprovalRequest {
|
||||
@NotBlank(message = "가맹점 번호는 필수입니다")
|
||||
private String merchantId;
|
||||
@NotBlank(message = "카드번호는 필수입니다")
|
||||
private String cardNumber;
|
||||
@NotNull @Positive
|
||||
private BigDecimal acquisitionAmount;
|
||||
@NotNull @Positive
|
||||
private BigDecimal approvalAmount;
|
||||
@NotBlank
|
||||
private String approvalNumber;
|
||||
@NotNull
|
||||
private LocalDateTime acquisitionDatetime;
|
||||
}
|
||||
|
||||
@Data @NoArgsConstructor @AllArgsConstructor @Builder
|
||||
public static class AcquisitionApprovalResponse {
|
||||
private Long id;
|
||||
private String merchantId;
|
||||
private String cardNumber;
|
||||
private BigDecimal acquisitionAmount;
|
||||
private BigDecimal approvalAmount;
|
||||
private String approvalNumber;
|
||||
private LocalDateTime acquisitionDatetime;
|
||||
private ApprovalStatus approvalStatus;
|
||||
private String cancelYn;
|
||||
private LocalDateTime cancelDatetime;
|
||||
private String cancelReason;
|
||||
private LocalDateTime createdAt;
|
||||
private LocalDateTime updatedAt;
|
||||
}
|
||||
|
||||
// Exception
|
||||
public static class AcquisitionApprovalException extends RuntimeException {
|
||||
private final String errorCode;
|
||||
public AcquisitionApprovalException(String errorCode, String message) {
|
||||
super(message);
|
||||
this.errorCode = errorCode;
|
||||
}
|
||||
}
|
||||
|
||||
// Global Exception Handler
|
||||
@RestControllerAdvice
|
||||
@Slf4j
|
||||
public static class GlobalExceptionHandler {
|
||||
@ExceptionHandler(AcquisitionApprovalException.class)
|
||||
public ResponseEntity<Map<String, Object>> handleAcquisitionApprovalException(AcquisitionApprovalException ex) {
|
||||
log.error("매입 승인 예외: 코드={}, 메시지={}", ex.getErrorCode(), ex.getMessage());
|
||||
HttpStatus status = switch (ex.getErrorCode()) {
|
||||
case "NOT_FOUND" -> HttpStatus.NOT_FOUND;
|
||||
case "DUPLICATE_APPROVAL", "ALREADY_CANCELLED" -> HttpStatus.CONFLICT;
|
||||
case "AMOUNT_MISMATCH" -> HttpStatus.BAD_REQUEST;
|
||||
default -> HttpStatus.INTERNAL_SERVER_ERROR;
|
||||
};
|
||||
Map<String, Object> response = new HashMap<>();
|
||||
response.put("timestamp", LocalDateTime.now());
|
||||
response.put("status", status.value());
|
||||
response.put("errorCode", ex.getErrorCode());
|
||||
response.put("message", ex.getMessage());
|
||||
return ResponseEntity.status(status).body(response);
|
||||
}
|
||||
|
||||
@ExceptionHandler(MethodArgumentNotValidException.class)
|
||||
public ResponseEntity<Map<String, Object>> handleValidationException(MethodArgumentNotValidException ex) {
|
||||
Map<String, String> fieldErrors = new HashMap<>();
|
||||
for (FieldError error : ex.getBindingResult().getFieldErrors()) {
|
||||
fieldErrors.put(error.getField(), error.getDefaultMessage());
|
||||
}
|
||||
Map<String, Object> response = new HashMap<>();
|
||||
response.put("timestamp", LocalDateTime.now());
|
||||
response.put("status", HttpStatus.BAD_REQUEST.value());
|
||||
response.put("errorCode", "VALIDATION_ERROR");
|
||||
response.put("message", "입력 검증에 실패했습니다");
|
||||
response.put("fieldErrors", fieldErrors);
|
||||
return ResponseEntity.badRequest().body(response);
|
||||
}
|
||||
|
||||
@ExceptionHandler(Exception.class)
|
||||
public ResponseEntity<Map<String, Object>> handleGenericException(Exception ex) {
|
||||
log.error("예상치 못한 예외 발생", ex);
|
||||
Map<String, Object> response = new HashMap<>();
|
||||
response.put("timestamp", LocalDateTime.now());
|
||||
response.put("status", HttpStatus.INTERNAL_SERVER_ERROR.value());
|
||||
response.put("errorCode", "INTERNAL_ERROR");
|
||||
response.put("message", "서버 내부 오류가 발생했습니다");
|
||||
return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(response);
|
||||
}
|
||||
}
|
||||
}
|
||||
95
src/main/resources/application.yml
Normal file
95
src/main/resources/application.yml
Normal file
|
|
@ -0,0 +1,95 @@
|
|||
# Spring Boot 3.2.5 Configuration - 카드 매입 승인 경로
|
||||
|
||||
spring:
|
||||
application:
|
||||
name: card-acquisition-approval
|
||||
|
||||
# Jakarta EE 9+ DataSource (jakarta.*)
|
||||
datasource:
|
||||
url: jdbc:h2:mem:acquirex;DB_CLOSE_DELAY=-1;DB_CLOSE_ON_EXIT=FALSE
|
||||
driver-class-name: org.h2.Driver
|
||||
username: sa
|
||||
password:
|
||||
hikari:
|
||||
maximum-pool-size: 10
|
||||
minimum-idle: 5
|
||||
connection-timeout: 30000
|
||||
|
||||
# JPA 3.1 (Hibernate 6.x)
|
||||
jpa:
|
||||
hibernate:
|
||||
ddl-auto: update
|
||||
show-sql: true
|
||||
properties:
|
||||
hibernate:
|
||||
format_sql: true
|
||||
dialect: org.hibernate.dialect.H2Dialect
|
||||
jdbc:
|
||||
time_zone: Asia/Seoul
|
||||
|
||||
# H2 Console
|
||||
h2:
|
||||
console:
|
||||
enabled: true
|
||||
path: /h2-console
|
||||
|
||||
# Jackson JSON
|
||||
jackson:
|
||||
serialization:
|
||||
write-dates-as-timestamps: false
|
||||
deserialization:
|
||||
fail-on-unknown-properties: false
|
||||
default-property-inclusion: non_null
|
||||
|
||||
server:
|
||||
port: 8080
|
||||
servlet:
|
||||
context-path: /
|
||||
error:
|
||||
include-message: always
|
||||
include-binding-errors: always
|
||||
|
||||
management:
|
||||
endpoints:
|
||||
web:
|
||||
exposure:
|
||||
include: health,info,metrics
|
||||
endpoint:
|
||||
health:
|
||||
show-details: when_authorized
|
||||
|
||||
logging:
|
||||
level:
|
||||
root: INFO
|
||||
com.acquirex: DEBUG
|
||||
org.springframework.web: INFO
|
||||
org.hibernate.SQL: DEBUG
|
||||
pattern:
|
||||
console: "%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n"
|
||||
|
||||
---
|
||||
# Production Profile
|
||||
spring:
|
||||
config:
|
||||
activate:
|
||||
on-profile: prod
|
||||
datasource:
|
||||
url: jdbc:postgresql://${DB_HOST:localhost}:${DB_PORT:5432}/${DB_NAME:acquirex}
|
||||
driver-class-name: org.postgresql.Driver
|
||||
username: ${DB_USERNAME}
|
||||
password: ${DB_PASSWORD}
|
||||
jpa:
|
||||
hibernate:
|
||||
ddl-auto: validate
|
||||
properties:
|
||||
hibernate:
|
||||
dialect: org.hibernate.dialect.PostgreSQLDialect
|
||||
h2:
|
||||
console:
|
||||
enabled: false
|
||||
|
||||
logging:
|
||||
level:
|
||||
root: WARN
|
||||
com.acquirex: INFO
|
||||
org.hibernate.SQL: WARN
|
||||
|
|
@ -0,0 +1,145 @@
|
|||
package com.acquirex.cardapproval;
|
||||
|
||||
import com.acquirex.cardapproval.domain.AcquisitionApproval;
|
||||
import com.acquirex.cardapproval.domain.AcquisitionApproval.ApprovalStatus;
|
||||
import com.acquirex.cardapproval.domain.AcquisitionApprovalRepository;
|
||||
import com.acquirex.cardapproval.service.AcquisitionApprovalService;
|
||||
import com.acquirex.cardapproval.service.AcquisitionApprovalService.AcquisitionApprovalException;
|
||||
import com.acquirex.cardapproval.service.AcquisitionApprovalService.AcquisitionApprovalRequest;
|
||||
import com.acquirex.cardapproval.service.AcquisitionApprovalService.AcquisitionApprovalResponse;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.DisplayName;
|
||||
import org.junit.jupiter.api.Test;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.context.ActiveProfiles;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
||||
import java.math.BigDecimal;
|
||||
import java.time.LocalDateTime;
|
||||
import java.util.List;
|
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
import static org.assertj.core.api.Assertions.assertThatThrownBy;
|
||||
|
||||
/**
|
||||
* Spring Boot 3.x 카드 매입 승인 서비스 통합 테스트
|
||||
*/
|
||||
@SpringBootTest
|
||||
@ActiveProfiles("test")
|
||||
@Transactional
|
||||
class CardAcquisitionApprovalApplicationTests {
|
||||
|
||||
@Autowired
|
||||
private AcquisitionApprovalService service;
|
||||
|
||||
@Autowired
|
||||
private AcquisitionApprovalRepository repository;
|
||||
|
||||
private AcquisitionApprovalRequest validRequest;
|
||||
|
||||
@BeforeEach
|
||||
void setUp() {
|
||||
validRequest = AcquisitionApprovalRequest.builder()
|
||||
.merchantId("MERCHANT001")
|
||||
.cardNumber("1234567890123456")
|
||||
.acquisitionAmount(new BigDecimal("50000"))
|
||||
.approvalAmount(new BigDecimal("50000"))
|
||||
.approvalNumber("APPR" + System.currentTimeMillis())
|
||||
.acquisitionDatetime(LocalDateTime.now())
|
||||
.build();
|
||||
}
|
||||
|
||||
@Test
|
||||
@DisplayName("애플리케이션 컨텍스트 로드 성공")
|
||||
void contextLoads() {
|
||||
assertThat(service).isNotNull();
|
||||
assertThat(repository).isNotNull();
|
||||
}
|
||||
|
||||
@Test
|
||||
@DisplayName("매입 승인 요청 처리 성공")
|
||||
void processAcquisition_Success() {
|
||||
AcquisitionApprovalResponse response = service.processAcquisition(validRequest);
|
||||
|
||||
assertThat(response).isNotNull();
|
||||
assertThat(response.getId()).isNotNull();
|
||||
assertThat(response.getMerchantId()).isEqualTo("MERCHANT001");
|
||||
assertThat(response.getApprovalStatus()).isEqualTo(ApprovalStatus.APPROVED);
|
||||
assertThat(response.getCancelYn()).isEqualTo("N");
|
||||
}
|
||||
|
||||
@Test
|
||||
@DisplayName("매입 금액과 승인 금액 불일치 시 예외 발생")
|
||||
void processAcquisition_AmountMismatch_ThrowsException() {
|
||||
validRequest.setApprovalAmount(new BigDecimal("40000"));
|
||||
|
||||
assertThatThrownBy(() -> service.processAcquisition(validRequest))
|
||||
.isInstanceOf(AcquisitionApprovalException.class)
|
||||
.hasFieldOrPropertyWithValue("errorCode", "AMOUNT_MISMATCH");
|
||||
}
|
||||
|
||||
@Test
|
||||
@DisplayName("매입 취소 처리 성공")
|
||||
void cancelAcquisition_Success() {
|
||||
AcquisitionApprovalResponse created = service.processAcquisition(validRequest);
|
||||
AcquisitionApprovalResponse cancelled = service.cancelAcquisition(created.getId(), "고객 요청");
|
||||
|
||||
assertThat(cancelled.getCancelYn()).isEqualTo("Y");
|
||||
assertThat(cancelled.getApprovalStatus()).isEqualTo(ApprovalStatus.CANCELLED);
|
||||
assertThat(cancelled.getCancelReason()).isEqualTo("고객 요청");
|
||||
assertThat(cancelled.getCancelDatetime()).isNotNull();
|
||||
}
|
||||
|
||||
@Test
|
||||
@DisplayName("이미 취소된 건 재취소 시 예외 발생")
|
||||
void cancelAcquisition_AlreadyCancelled_ThrowsException() {
|
||||
AcquisitionApprovalResponse created = service.processAcquisition(validRequest);
|
||||
service.cancelAcquisition(created.getId(), "첫 번째 취소");
|
||||
|
||||
assertThatThrownBy(() -> service.cancelAcquisition(created.getId(), "두 번째 취소"))
|
||||
.isInstanceOf(AcquisitionApprovalException.class)
|
||||
.hasFieldOrPropertyWithValue("errorCode", "ALREADY_CANCELLED");
|
||||
}
|
||||
|
||||
@Test
|
||||
@DisplayName("존재하지 않는 매입 승인 조회 시 예외 발생")
|
||||
void getAcquisition_NotFound_ThrowsException() {
|
||||
assertThatThrownBy(() -> service.getAcquisition(99999L))
|
||||
.isInstanceOf(AcquisitionApprovalException.class)
|
||||
.hasFieldOrPropertyWithValue("errorCode", "NOT_FOUND");
|
||||
}
|
||||
|
||||
@Test
|
||||
@DisplayName("가맹점별 매입 승인 목록 조회 성공")
|
||||
void getAcquisitionsByMerchant_Success() {
|
||||
service.processAcquisition(validRequest);
|
||||
|
||||
List<AcquisitionApprovalResponse> responses = service.getAcquisitionsByMerchant("MERCHANT001");
|
||||
|
||||
assertThat(responses).isNotEmpty();
|
||||
assertThat(responses).allMatch(r -> r.getMerchantId().equals("MERCHANT001"));
|
||||
}
|
||||
|
||||
@Test
|
||||
@DisplayName("엔티티 취소 메서드 동작 확인")
|
||||
void entityCancelMethod_WorksCorrectly() {
|
||||
AcquisitionApproval approval = AcquisitionApproval.builder()
|
||||
.merchantId("TEST")
|
||||
.cardNumber("1234")
|
||||
.acquisitionAmount(new BigDecimal("1000"))
|
||||
.approvalAmount(new BigDecimal("1000"))
|
||||
.approvalNumber("TEST001")
|
||||
.acquisitionDatetime(LocalDateTime.now())
|
||||
.approvalStatus(ApprovalStatus.APPROVED)
|
||||
.cancelYn("N")
|
||||
.build();
|
||||
|
||||
approval.cancel("테스트 취소");
|
||||
|
||||
assertThat(approval.getCancelYn()).isEqualTo("Y");
|
||||
assertThat(approval.getCancelReason()).isEqualTo("테스트 취소");
|
||||
assertThat(approval.getCancelDatetime()).isNotNull();
|
||||
assertThat(approval.getApprovalStatus()).isEqualTo(ApprovalStatus.CANCELLED);
|
||||
}
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue