[박태영/완료]0050

.gitignore

@@ -35,3 +35,9 @@ out/
 
 ### VS Code ###
 .vscode/
+
+
+### Custom ###
+db_dev.mv.db
+db_dev.trace.db
+.env

build.gradle

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

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,8 +2,10 @@
 
 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) {

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

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

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

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

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

@@ -0,0 +1,25 @@
+package com.back.boundedContext.cash.app;
+
+import org.springframework.stereotype.Service;
+
+import com.back.boundedContext.cash.domain.CashMember;
+import com.back.boundedContext.cash.domain.Wallet;
+import com.back.boundedContext.cash.out.CashMemberRepository;
+import com.back.boundedContext.cash.out.WalletRepository;
+import com.back.shared.cash.dto.CashMemberDto;
+
+import lombok.RequiredArgsConstructor;
+
+@Service
+@RequiredArgsConstructor
+public class CashCreateWalletUseCase {
+	private final CashMemberRepository cashMemberRepository;
+	private final WalletRepository walletRepository;
+
+	public Wallet createWallet(CashMemberDto member) {
+		CashMember _member = cashMemberRepository.getReferenceById(member.getId());
+		Wallet wallet = new Wallet(_member);
+
+		return walletRepository.save(wallet);
+	}
+}

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

@@ -0,0 +1,65 @@
+package com.back.boundedContext.cash.app;
+
+import java.util.Optional;
+
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.back.boundedContext.cash.domain.CashMember;
+import com.back.boundedContext.cash.domain.Wallet;
+import com.back.shared.cash.dto.CashMemberDto;
+import com.back.shared.market.dto.OrderDto;
+import com.back.shared.member.dto.MemberDto;
+import com.back.shared.payout.dto.PayoutDto;
+
+import lombok.RequiredArgsConstructor;
+
+@Service
+@RequiredArgsConstructor
+public class CashFacade {
+	private final CashSupport cashSupport;
+	private final CashSyncMemberUseCase cashSyncMemberUseCase;
+	private final CashCreateWalletUseCase cashCreateWalletUseCase;
+	private final CashCompleteOrderPaymentUseCase cashCompleteOrderPaymentUseCase;
+	private final CashCompletePayoutUseCase cashCompletePayoutUseCase;
+
+	@Transactional
+	public CashMember syncMember(MemberDto memberDto) {
+
+		return cashSyncMemberUseCase.syncMember(memberDto);
+	}
+
+	@Transactional
+	public Wallet createWallet(CashMemberDto holder) {
+
+		return cashCreateWalletUseCase.createWallet(holder);
+	}
+
+	@Transactional(readOnly = true)
+	public Optional<CashMember> findMemberByUserName(String userName) {
+
+		return cashSupport.findMemberByUserName(userName);
+	}
+
+	@Transactional(readOnly = true)
+	public Optional<Wallet> findWalletByHolder(CashMember holder) {
+
+		return cashSupport.findWalletByHolder(holder);
+	}
+
+	@Transactional
+	public void completeOrderPayment(OrderDto orderDto, long pgPaymentAmount) {
+		cashCompleteOrderPaymentUseCase.completeOrderPayment(orderDto, pgPaymentAmount);
+	}
+
+	@Transactional(readOnly = true)
+	public Optional<Wallet> findWalletByHolderId(int id) {
+		return cashSupport.findWalletByHolderId(id);
+	}
+
+	//정산 집행 후 시스템,회원 지갑에 정산 내역 반영
+	@Transactional
+	public void completePayout(PayoutDto payout) {
+		cashCompletePayoutUseCase.completePayout(payout);
+	}
+}

src/main/java/com/back/boundedContext/cash/app/CashSupport.java

@@ -0,0 +1,36 @@
+package com.back.boundedContext.cash.app;
+
+import java.util.Optional;
+
+import org.springframework.stereotype.Component;
+
+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.CashMemberRepository;
+import com.back.boundedContext.cash.out.WalletRepository;
+
+import lombok.RequiredArgsConstructor;
+
+@Component
+@RequiredArgsConstructor
+public class CashSupport {
+	private final CashMemberRepository cashMemberRepository;
+	private final WalletRepository walletRepository;
+
+	public Optional<CashMember> findMemberByUserName(String userName) {
+		return cashMemberRepository.findByUserName(userName);
+	}
+
+	public Optional<Wallet> findWalletByHolder(CashMember holder) {
+		return walletRepository.findByHolder(holder);
+	}
+
+	public Optional <Wallet> findWalletByHolderId(int holderId) {
+		return walletRepository.findByHolderId(holderId);
+	}
+
+	public Optional <Wallet> findHoldingWallet() {
+		return walletRepository.findByHolderId(CashPolicy.HOLDING_MEMBER_ID);
+	}
+}

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

@@ -0,0 +1,45 @@
+package com.back.boundedContext.cash.app;
+
+import org.springframework.stereotype.Service;
+
+import com.back.boundedContext.cash.domain.CashMember;
+import com.back.boundedContext.cash.out.CashMemberRepository;
+import com.back.global.eventPublisher.EventPublisher;
+import com.back.shared.cash.event.CashMemberCreateEvent;
+import com.back.shared.member.dto.MemberDto;
+
+import lombok.RequiredArgsConstructor;
+
+@Service
+@RequiredArgsConstructor
+public class CashSyncMemberUseCase {
+	private final CashMemberRepository cashMemberRepository;
+	private final EventPublisher eventPublisher;
+
+	public CashMember syncMember(MemberDto memberDto) {
+
+		boolean isNew = !cashMemberRepository.existsById(memberDto.getId());
+
+		CashMember _member = cashMemberRepository.save(
+			new CashMember(
+				memberDto.getId(),
+				memberDto.getCreateTime(),
+				memberDto.getModifyTime(),
+				memberDto.getUserName(),
+				"",
+				memberDto.getNickName(),
+				memberDto.getActivityScore()
+			)
+		);
+
+		if (isNew) {
+			eventPublisher.publish(
+				new CashMemberCreateEvent(
+					_member.toDto()
+				)
+			);
+		}
+
+		return _member;
+	}
+}

src/main/java/com/back/boundedContext/cash/domain/CashLog.java

@@ -0,0 +1,49 @@
+package com.back.boundedContext.cash.domain;
+
+import com.back.global.jpa.entity.BaseIdAndTime;
+
+import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.FetchType;
+import jakarta.persistence.ManyToOne;
+import jakarta.persistence.Table;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Table(name = "CASH_CASH_LOG")
+@NoArgsConstructor
+public class CashLog extends BaseIdAndTime {
+	public enum EventType {
+		충전__무통장입금,
+		충전__PG결제_토스페이먼츠,
+		출금__통장입금,
+		사용__주문결제,
+		임시보관__주문결제,
+		정산지급__상품판매_수수료,
+		정산수령__상품판매_수수료,
+		정산지급__상품판매_대금,
+		정산수령__상품판매_대금,
+	}
+
+	@Enumerated(EnumType.STRING)
+	private EventType eventType;
+	private String relTypeCode;
+	private int relId;
+	@ManyToOne(fetch = FetchType.LAZY)
+	private CashMember member;
+	@ManyToOne(fetch = FetchType.LAZY)
+	private Wallet wallet;
+	private long amount;
+	private long balance;
+
+	public CashLog(EventType eventType, String relTypeCode, int relId, CashMember member, Wallet wallet, long amount, long balance) {
+		this.eventType = eventType;
+		this.relTypeCode = relTypeCode;
+		this.relId = relId;
+		this.member = member;
+		this.wallet = wallet;
+		this.amount = amount;
+		this.balance = balance;
+	}
+}