[박재현/완료] 0050

.env.default

@@ -0,0 +1 @@
+TOSS_PAYMENTS_SECRET_KEY=NEED_TO_INPUT

.gitignore

@@ -35,3 +35,5 @@ out/
 
 ### VS Code ###
 .vscode/
+application.yml
+application-dev.yml

build.gradle

@@ -28,6 +28,10 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-h2console'
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
     implementation 'org.springframework.boot:spring-boot-starter-webmvc'
+    implementation("org.springframework.boot:spring-boot-starter-validation")
+    implementation 'org.springframework.boot:spring-boot-starter-batch'
+    testImplementation 'org.springframework.batch:spring-batch-test'
+
     compileOnly 'org.projectlombok:lombok'
     developmentOnly 'org.springframework.boot:spring-boot-devtools'
     runtimeOnly 'com.h2database:h2'

readme.md

@@ -0,0 +1,18 @@
+- # 토스 페이먼츠
+- [토스 페이먼츠, 내 개발정보](https://developers.tosspayments.com/my/api-logs)
+    - API 개별 연동 키
+        - 테스트 클라이언트 키
+        - 시크릿 키
+    - API 로그
+    - 테스트 결제내역
+
+# 토스 페이먼츠 테스트
+
+- [결제시도](https://codepen.io/jangka44/debug/yyJBXaM)
+    - [소스코드](https://codepen.io/jangka44/pen/yyJBXaM?editors=1000)
+- [최종승인](https://codepen.io/jangka44/debug/GgqKEWV)
+    - 직접 접근 금지
+    - [소스코드](https://codepen.io/jangka44/pen/GgqKEWV?editors=1000)
+- [결제실패](https://codepen.io/jangka44/debug/xbOKrdJ)
+    - 직접 접근 금지
+    - [소스코드](https://codepen.io/jangka44/pen/xbOKrdJ?editors=1000)

src/main/java/com/back/BackApplication.java

@@ -2,12 +2,15 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
 
 @SpringBootApplication
+@EnableJpaAuditing
 public class BackApplication {
 
     public static void main(String[] args) {
         SpringApplication.run(BackApplication.class, args);
     }
 
+
 }

src/main/java/com/back/boundedContext/cash/app/facade/CashFacade.java

@@ -0,0 +1,71 @@
+package com.back.boundedContext.cash.app.facade;
+
+import com.back.boundedContext.cash.app.query.CashMemberQuery;
+import com.back.boundedContext.cash.app.query.WalletQuery;
+import com.back.boundedContext.cash.app.usecase.CashCompleteOrderPaymentUseCase;
+import com.back.boundedContext.cash.app.usecase.CashCompletePayoutUseCase;
+import com.back.boundedContext.cash.app.usecase.CashCreateWalletUseCase;
+import com.back.boundedContext.cash.app.usecase.CashSyncMemberUseCase;
+import com.back.boundedContext.cash.domain.CashMember;
+import com.back.boundedContext.cash.domain.Wallet;
+import com.back.shared.market.dto.OrderDto;
+import com.back.shared.member.dto.MemberDto;
+import com.back.shared.payout.dto.PayoutDto;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Optional;
+
+@Service
+@RequiredArgsConstructor
+public class CashFacade {
+    private final CashMemberQuery cashMemberQuery;
+    private final WalletQuery walletQuery;
+
+    private final CashCreateWalletUseCase cashCreateWalletUseCase;
+    private final CashSyncMemberUseCase cashSyncMemberUseCase;
+    private final CashCompleteOrderPaymentUseCase cashCompleteOrderPaymentUseCase;
+    private final CashCompletePayoutUseCase cashCompletePayoutUseCase;
+
+    @Transactional
+    public Wallet createWallet(CashMember holder) {
+        return cashCreateWalletUseCase.createWallet(holder);
+    }
+
+    @Transactional
+    public long count() {return cashMemberQuery.count();}
+
+    @Transactional
+    public Optional<CashMember> findCashMemberById(Long id) {
+        return cashMemberQuery.findCashMemberById(id);
+    }
+
+    @Transactional(readOnly = true)
+    public Optional<CashMember> findCashMemberByUsername(String username) {
+        return cashMemberQuery.findCashMemberByUsername(username);
+    }
+
+    @Transactional(readOnly = true)
+    public Optional<Wallet> findWalletByHolder(CashMember holder) {
+        return walletQuery.findWalletByHolder(holder);
+    }
+
+    @Transactional
+    public CashMember syncMember(MemberDto member) {
+        return cashSyncMemberUseCase.syncMember(member);
+    }
+
+    @Transactional
+    public void completeOrderPayment(OrderDto order, long pgPaymentAmount) {
+        cashCompleteOrderPaymentUseCase.completeOrderPayment(order, pgPaymentAmount);
+    }    @Transactional(readOnly = true)
+    public Optional<Wallet> findWalletByHolderId(Long holderId) {
+        return walletQuery.findWalletByHolderId(holderId);
+    }
+
+    @Transactional
+    public void completePayout(PayoutDto payout) {
+        cashCompletePayoutUseCase.completePayout(payout);
+    }
+}

src/main/java/com/back/boundedContext/cash/app/query/CashMemberQuery.java

@@ -0,0 +1,36 @@
+package com.back.boundedContext.cash.app.query;
+
+import com.back.boundedContext.cash.domain.CashMember;
+import com.back.boundedContext.cash.out.repository.CashMemberRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Optional;
+
+
+
+@Component
+@RequiredArgsConstructor
+public class CashMemberQuery {
+
+    private final CashMemberRepository cashMemberRepository;
+
+    @Transactional
+    public long count() {
+        return cashMemberRepository.count();
+    }
+
+
+    public Optional<CashMember> findCashMemberById(Long id) {
+        return cashMemberRepository.findById(id);
+    }
+
+
+    @Transactional(readOnly = true)
+    public Optional<CashMember> findCashMemberByUsername(String username) {
+        return cashMemberRepository.findByUsername(username);
+    }
+
+
+}

src/main/java/com/back/boundedContext/cash/app/query/WalletQuery.java

@@ -0,0 +1,32 @@
+package com.back.boundedContext.cash.app.query;
+
+import com.back.boundedContext.cash.domain.CashMember;
+import com.back.boundedContext.cash.domain.CashPolicy;
+import com.back.boundedContext.cash.domain.Wallet;
+import com.back.boundedContext.cash.out.repository.WalletRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Optional;
+
+
+@Component
+@RequiredArgsConstructor
+public class WalletQuery {
+
+    private final WalletRepository walletRepository;
+
+    @Transactional(readOnly = true)
+    public Optional<Wallet> findWalletByHolder(CashMember holder) {
+        return walletRepository.findByHolder(holder);
+    }
+
+    public Optional<Wallet> findWalletByHolderId(Long holderId) {
+        return walletRepository.findByHolderId(holderId);
+    }
+
+    public Optional<Wallet> findHoldingWallet() {
+        return walletRepository.findByHolderId(CashPolicy.HOLDING_MEMBER_ID);
+    }
+}

src/main/java/com/back/boundedContext/cash/app/usecase/CashCompleteOrderPaymentUseCase.java

@@ -0,0 +1,69 @@
+package com.back.boundedContext.cash.app.usecase;
+
+import com.back.boundedContext.cash.app.query.CashMemberQuery;
+import com.back.boundedContext.cash.app.query.WalletQuery;
+import com.back.boundedContext.cash.domain.CashEventType;
+import com.back.boundedContext.cash.domain.Wallet;
+import com.back.global.eventPublisher.EventPublisher;
+import com.back.shared.cash.event.CashOrderPaymentFailedEvent;
+import com.back.shared.cash.event.CashOrderPaymentSucceededEvent;
+import com.back.shared.market.dto.OrderDto;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+public class CashCompleteOrderPaymentUseCase {
+    private final CashMemberQuery cashMemberQuery;
+    private final WalletQuery walletQuery;
+    private final EventPublisher eventPublisher;
+
+
+    public void completeOrderPayment(OrderDto order, long pgPaymentAmount) {
+        Wallet customerWallet = walletQuery.findWalletByHolderId(order.getCustomerId()).get();
+        Wallet holdingWallet = walletQuery.findHoldingWallet().get();
+
+        if (pgPaymentAmount > 0) {
+            customerWallet.credit(
+                    pgPaymentAmount,
+                    CashEventType.충전__PG결제_토스페이먼츠,
+                    order.getModelTypeCode(),
+                    order.getId()            );
+        }
+
+        boolean canPay = customerWallet.getBalance() >= order.getSalePrice();
+
+        if (canPay) {
+            customerWallet.debit(
+                    order.getSalePrice(),
+                    CashEventType.사용__주문결제,
+                    order.getModelTypeCode(),
+                    order.getId()
+            );
+
+            holdingWallet.credit(
+                    order.getSalePrice(),
+                    CashEventType.임시보관__주문결제,
+                    order.getModelTypeCode(),
+                    order.getId()
+            );
+
+            eventPublisher.publish(
+                    new CashOrderPaymentSucceededEvent(
+                            order,
+                            pgPaymentAmount
+                    )
+            );
+        } else {
+            eventPublisher.publish(
+                    new CashOrderPaymentFailedEvent(
+                            "400-1",
+                            "충전은 완료했지만 %번 주문을 결제완료처리를 하기에는 예치금이 부족합니다.".formatted(order.getId()),
+                            order,
+                            pgPaymentAmount,
+                            pgPaymentAmount - customerWallet.getBalance()
+                    )
+            );
+        }
+    }
+}

src/main/java/com/back/boundedContext/cash/app/usecase/CashCompletePayoutUseCase.java

@@ -0,0 +1,33 @@
+package com.back.boundedContext.cash.app.usecase;
+
+import com.back.boundedContext.cash.app.query.WalletQuery;
+import com.back.boundedContext.cash.domain.CashEventType;
+import com.back.boundedContext.cash.domain.Wallet;
+import com.back.shared.payout.dto.PayoutDto;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+public class CashCompletePayoutUseCase {
+    private final WalletQuery walletQuery;
+
+    public void completePayout(PayoutDto payout) {
+        Wallet holdingWallet = walletQuery.findHoldingWallet().get();
+        Wallet payeeWallet = walletQuery.findWalletByHolderId(payout.getPayeeId()).get();
+
+        holdingWallet.debit(
+                payout.getAmount(),
+                payout.isPayeeSystem() ? CashEventType.정산지급__상품판매_수수료 : CashEventType.정산지급__상품판매_대금,
+                payout.getModelTypeCode(),
+                payout.getId()
+        );
+
+        payeeWallet.credit(
+                payout.getAmount(),
+                payout.isPayeeSystem() ? CashEventType.정산수령__상품판매_수수료 : CashEventType.정산수령__상품판매_대금,
+                payout.getModelTypeCode(),
+                payout.getId()
+        );
+    }
+}

src/main/java/com/back/boundedContext/cash/app/usecase/CashCreateWalletUseCase.java

@@ -0,0 +1,23 @@
+package com.back.boundedContext.cash.app.usecase;
+
+import com.back.boundedContext.cash.domain.CashMember;
+import com.back.boundedContext.cash.domain.Wallet;
+import com.back.boundedContext.cash.out.repository.WalletRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+public class CashCreateWalletUseCase {
+
+    private final WalletRepository walletRepository;
+
+    @Transactional
+    public Wallet createWallet(CashMember holder) {
+        Wallet wallet = new Wallet(holder);
+
+        return walletRepository.save(wallet);
+    }
+
+}

src/main/java/com/back/boundedContext/cash/app/usecase/CashSyncMemberUseCase.java

@@ -0,0 +1,68 @@
+package com.back.boundedContext.cash.app.usecase;
+
+import com.back.boundedContext.cash.domain.CashMember;
+import com.back.boundedContext.cash.out.repository.CashMemberRepository;
+import com.back.global.eventPublisher.EventPublisher;
+import com.back.shared.cash.event.CashMemberCreatedEvent;
+import com.back.shared.member.dto.MemberDto;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * Member를 Cash 컨텍스트의 CashMember로 동기화하는 UseCase
+ *
+ * [설계 원칙]
+ * - MemberJoinedEvent, MemberUpdatedEvent 모두 동일한 MemberDto를 사용
+ * - 도메인 일관성 > 이벤트 책임분리: Member는 항상 동일한 구조(MemberDto)로 표현
+ * - 신규/갱신 판단은 수신 컨텍스트(Cash)의 책임
+ */
+@Service
+@RequiredArgsConstructor
+public class CashSyncMemberUseCase {
+
+    private final CashMemberRepository cashMemberRepository;
+    private final EventPublisher eventPublisher;
+
+    /**
+     * Member를 CashMember로 동기화한다.
+     *
+     * [동작 방식]
+     * - 신규 멤버: CashMember 생성 후 CashMemberCreatedEvent 발행 (Wallet 생성 트리거)
+     * - 기존 멤버: CashMember 정보 갱신 (이벤트 발행 없음)
+     *
+     * @param member MemberDto - 도메인 기반 공유 DTO
+     * @return 동기화된 CashMember
+     */
+    @Transactional
+    public CashMember syncMember(MemberDto member) {
+        boolean isNew = !cashMemberRepository.existsById(member.getId());
+
+        // 민감정보인 Password는 미러링에 넘기지 않는다
+        CashMember cashMember = cashMemberRepository.save(
+                new CashMember(
+                        member.getId(),
+                        member.getCreatedAt(),
+                        member.getUpdatedAt(),
+                        member.getUsername(),
+                        "",
+                        member.getNickname(),
+                        member.getActivityScore()
+                )
+        );
+
+        // 신규 생성시에만 CashMemberCreatedEvent 발행
+        // → CashEventListener가 수신하여 Wallet 생성
+        if (isNew) {
+            eventPublisher.publish(
+                    new CashMemberCreatedEvent(
+                            cashMember.toDto()
+                    )
+            );
+        }
+
+
+        return cashMember;
+    }
+
+}