Feature/nyh365 Step3: 사용자 전체 정보 조회

src/main/java/org/c4marathon/assignment/controller/MarathonController.java

@@ -0,0 +1,27 @@
+package org.c4marathon.assignment.controller;
+
+import org.c4marathon.assignment.dto.response.FinancialInfoRes;
+import org.c4marathon.assignment.service.MarathonService;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import lombok.RequiredArgsConstructor;
+
+@RestController
+@RequestMapping("/marathon")
+@RequiredArgsConstructor
+public class MarathonController {
+	private final MarathonService marathonService;
+
+	@GetMapping("/all-info")
+	public FinancialInfoRes getAllInfoWithLimit(@RequestParam Integer id) {
+		return marathonService.getAllInfoWithLimit(id);
+	}
+
+	@GetMapping("/all-info-not-parallel")
+	public FinancialInfoRes getAllInfoNotParallel(@RequestParam Integer id) {
+		return marathonService.getAllInfoNotParallel(id);
+	}
+}

src/main/java/org/c4marathon/assignment/core/C4ThreadPoolExecutor.java

@@ -0,0 +1,78 @@
+package org.c4marathon.assignment.core;
+
+import java.util.concurrent.Executor;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@RequiredArgsConstructor
+@Slf4j
+public class C4ThreadPoolExecutor implements Executor {
+	private final int threadCount;
+	private final int queueSize;
+	private ThreadPoolExecutor threadPoolExecutor;
+	private RuntimeException exception = null;
+
+	public void init() {
+		if (threadPoolExecutor != null) {
+			return;
+		}
+
+		threadPoolExecutor = new ThreadPoolExecutor(threadCount, threadCount, 0L, TimeUnit.MILLISECONDS,
+			new LinkedBlockingQueue<>(queueSize),
+			(r, executor) -> {
+				try {
+					executor.getQueue().put(r);
+				} catch (InterruptedException e) {
+					log.error(e.toString(), e);
+					Thread.currentThread().interrupt();
+				}
+			});
+	}
+
+	@Override
+	public void execute(Runnable command) {
+		if (isInvalidState()) {
+			return;
+		}
+
+		threadPoolExecutor.execute(() -> {
+			try {
+				command.run();
+			} catch (RuntimeException e) {
+				log.error(e.toString(), e);
+				exception = e;
+			}
+		});
+	}
+
+	public void waitToEnd() {
+		if (isInvalidState()) {
+			return;
+		}
+
+		threadPoolExecutor.shutdown();
+		while (true) {
+			try {
+				if (threadPoolExecutor.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS)) {
+					break;
+				}
+			} catch (InterruptedException e) {
+				log.error(e.toString(), e);
+				Thread.currentThread().interrupt();
+			}
+		}
+
+		threadPoolExecutor = null;
+		if (exception != null) {
+			throw exception;
+		}
+	}
+
+	private boolean isInvalidState() {
+		return threadPoolExecutor == null || threadPoolExecutor.isTerminating() || threadPoolExecutor.isTerminated();
+	}
+}

src/main/java/org/c4marathon/assignment/dto/response/AccountRes.java

@@ -0,0 +1,15 @@
+package org.c4marathon.assignment.dto.response;
+
+import org.c4marathon.assignment.entity.Account;
+
+public record AccountRes(
+	String accountNumber,
+	Long balance
+) {
+	public AccountRes(Account account) {
+		this(
+			account.getAccountNumber(),
+			account.getBalance()
+		);
+	}
+}

src/main/java/org/c4marathon/assignment/dto/response/FinancialInfoRes.java

@@ -0,0 +1,19 @@
+package org.c4marathon.assignment.dto.response;
+
+import java.util.List;
+
+public record FinancialInfoRes(
+	List<AccountRes> accountRes,
+	List<TransactionRes> transactionRes,
+	int accountTotal,
+	int transactionTotal
+) {
+	public FinancialInfoRes(List<AccountRes> accountRes, List<TransactionRes> transactionRes) {
+		this(
+			accountRes,
+			transactionRes,
+			accountRes.size(),
+			transactionRes.size()
+		);
+	}
+}

src/main/java/org/c4marathon/assignment/dto/response/TransactionRes.java

@@ -0,0 +1,31 @@
+package org.c4marathon.assignment.dto.response;
+
+import java.time.Instant;
+
+import org.c4marathon.assignment.entity.Transaction;
+
+public record TransactionRes(
+	String senderAccount,
+	String receiverAccount,
+	String senderSwiftCode,
+	String receiverSwiftCode,
+	String senderName,
+	String receiverName,
+	Long amount,
+	String memo,
+	Instant transactionDate
+) {
+	public TransactionRes(Transaction transaction) {
+		this(
+			transaction.getSenderAccount(),
+			transaction.getReceiverAccount(),
+			transaction.getSenderSwiftCode(),
+			transaction.getReceiverSwiftCode(),
+			transaction.getSenderName(),
+			transaction.getReceiverName(),
+			transaction.getAmount(),
+			transaction.getMemo(),
+			transaction.getTransactionDate()
+		);
+	}
+}

src/main/java/org/c4marathon/assignment/entity/Account.java

@@ -0,0 +1,67 @@
+package org.c4marathon.assignment.entity;
+
+import java.time.Instant;
+import java.util.stream.IntStream;
+
+import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.hibernate.annotations.ColumnDefault;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Size;
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+@Entity
+@Table(name = "account")
+public class Account {
+	public static final String ACCOUNT_PREFIX = "3333";
+
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "account_id", nullable = false)
+	private Integer id;
+
+	@Size(max = 13)
+	@NotNull
+	@Column(name = "account_number", nullable = false, length = 13)
+	private String accountNumber;
+
+	@NotNull
+	@Column(name = "user_id", nullable = false)
+	private Integer userId;
+
+	@NotNull
+	@Column(name = "account_type", nullable = false)
+	private Character accountType;
+
+	@Size(max = 200)
+	@Column(name = "memo", length = 200)
+	private String memo;
+
+	@NotNull
+	@ColumnDefault("0")
+	@Column(name = "balance", nullable = false)
+	private Long balance;
+
+	@NotNull
+	@ColumnDefault("CURRENT_TIMESTAMP")
+	@Column(name = "create_date", nullable = false)
+	private Instant createDate;
+
+	@Column(name = "recent_transaction_date")
+	private Instant recentTransactionDate;
+
+	@Override
+	public String toString() {
+		return ToStringBuilder.reflectionToString(this);
+	}
+}

src/main/java/org/c4marathon/assignment/entity/User.java

@@ -0,0 +1,54 @@
+package org.c4marathon.assignment.entity;
+
+import java.time.Instant;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Size;
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+@Entity
+@Table(name = "user")
+public class User {
+	@Id
+	@Column(name = "user_id", nullable = false)
+	private Integer id;
+
+	@Size(max = 30)
+	@NotNull
+	@Column(name = "username", nullable = false, length = 30)
+	private String username;
+
+	@Size(max = 30)
+	@NotNull
+	@Column(name = "email", nullable = false, length = 30)
+	private String email;
+
+	@Size(max = 10)
+	@NotNull
+	@Column(name = "nickname", nullable = false, length = 10)
+	private String nickname;
+
+	@NotNull
+	@Column(name = "group_id", nullable = false)
+	private Integer groupId;
+
+	@NotNull
+	@Column(name = "user_status", nullable = false)
+	private Character userStatus;
+
+	@NotNull
+	@Column(name = "create_date", nullable = false)
+	private Instant createDate;
+
+	@NotNull
+	@Column(name = "update_date", nullable = false)
+	private Instant updateDate;
+
+}

src/main/java/org/c4marathon/assignment/exception/BadRequestException.java

@@ -0,0 +1,7 @@
+package org.c4marathon.assignment.exception;
+
+public class BadRequestException extends RuntimeException {
+	public BadRequestException(String message) {
+		super(message);
+	}
+}

src/main/java/org/c4marathon/assignment/handler/GlobalExceptionHandler.java

@@ -0,0 +1,24 @@
+package org.c4marathon.assignment.handler;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.c4marathon.assignment.exception.BadRequestException;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.ControllerAdvice;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+
+@ControllerAdvice
+public class GlobalExceptionHandler {
+	private static final String MESSAGE = "message";
+
+	@ExceptionHandler(BadRequestException.class)
+	public ResponseEntity<Map<String, Object>> handleBadRequestException(BadRequestException ex) {
+		Map<String, Object> resultMap = new HashMap<>();
+
+		resultMap.put(MESSAGE, ex.getMessage());
+
+		return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(resultMap);
+	}
+}

src/main/java/org/c4marathon/assignment/repository/AccountJpaRepository.java

@@ -0,0 +1,12 @@
+package org.c4marathon.assignment.repository;
+
+import java.util.List;
+
+import org.c4marathon.assignment.entity.Account;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface AccountJpaRepository extends JpaRepository<Account, Long> {
+	List<Account> findAllByUserId(Integer userId);
+}

src/main/java/org/c4marathon/assignment/repository/AccountRepository.java

@@ -0,0 +1,18 @@
+package org.c4marathon.assignment.repository;
+
+import java.util.List;
+
+import org.c4marathon.assignment.entity.Account;
+import org.springframework.stereotype.Repository;
+
+import lombok.RequiredArgsConstructor;
+
+@Repository
+@RequiredArgsConstructor
+public class AccountRepository {
+	private final AccountJpaRepository accountJpaRepository;
+
+	public List<Account> findAllAccountByUserId(Integer userId) {
+		return accountJpaRepository.findAllByUserId(userId);
+	}
+}