Feature/nyh365 step2

build.gradle

@@ -28,9 +28,14 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-web'
     implementation 'org.apache.commons:commons-lang3:3.13.0'
     implementation 'org.apache.commons:commons-collections4:4.4'
+    implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
+    implementation 'org.springframework.boot:spring-boot-starter-validation'
+    runtimeOnly 'com.mysql:mysql-connector-j'
     compileOnly 'org.projectlombok:lombok'
     annotationProcessor 'org.projectlombok:lombok'
+    implementation 'org.springframework.boot:spring-boot-starter-amqp'
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
+    testImplementation 'org.springframework.amqp:spring-rabbit-test'
 }
 
 checkstyle {

src/main/java/org/c4marathon/assignment/AssignmentApplication.java

@@ -2,7 +2,12 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
+@EnableJpaAuditing
+@EnableScheduling
 @SpringBootApplication
 public class AssignmentApplication {
 

src/main/java/org/c4marathon/assignment/config/AsyncConfig.java

@@ -0,0 +1,36 @@
+package org.c4marathon.assignment.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+@Configuration
+@EnableAsync
+public class AsyncConfig {
+	public static final String ASYNC_LISTENER_TASK_EXECUTOR_NAME = "AsyncListenerTaskExecutor";
+	public static final String ASYNC_SCHEDULER_TASK_EXECUTOR_NAME = "AsyncSchedulerTaskExecutor";
+	private static final int CORE_POOL_SIZE = 2;
+	private static final int MAX_POOL_SIZE = 4;
+
+	@Bean(name = ASYNC_LISTENER_TASK_EXECUTOR_NAME)
+	public ThreadPoolTaskExecutor asyncListenerTaskExecutor() {
+		return getThreadPoolTaskExecutor(ASYNC_LISTENER_TASK_EXECUTOR_NAME);
+	}
+
+	@Bean(name = ASYNC_SCHEDULER_TASK_EXECUTOR_NAME)
+	public ThreadPoolTaskExecutor asyncSchedulerTaskExecutor() {
+		return getThreadPoolTaskExecutor(ASYNC_SCHEDULER_TASK_EXECUTOR_NAME);
+	}
+
+	private ThreadPoolTaskExecutor getThreadPoolTaskExecutor(String asyncSchedulerTaskExecutorName) {
+		ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+		executor.setCorePoolSize(CORE_POOL_SIZE);
+		executor.setMaxPoolSize(MAX_POOL_SIZE);
+		executor.setThreadNamePrefix(asyncSchedulerTaskExecutorName);
+		executor.setWaitForTasksToCompleteOnShutdown(true);
+		executor.setAwaitTerminationSeconds(10);
+		executor.initialize();
+		return executor;
+	}
+}

src/main/java/org/c4marathon/assignment/config/RabbitmqConfig.java

@@ -0,0 +1,76 @@
+package org.c4marathon.assignment.config;
+
+import org.springframework.amqp.core.Binding;
+import org.springframework.amqp.core.BindingBuilder;
+import org.springframework.amqp.core.DirectExchange;
+import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
+import org.springframework.amqp.support.converter.MessageConverter;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class RabbitmqConfig {
+
+	@Value("${spring.rabbitmq.host}")
+	private String host;
+
+	@Value("${spring.rabbitmq.username}")
+	private String username;
+
+	@Value("${spring.rabbitmq.password}")
+	private String password;
+
+	@Value("${spring.rabbitmq.port}")
+	private int port;
+
+	@Value("${rabbitmq.queue.name}")
+	private String queueName;
+
+	@Value("${rabbitmq.exchange.name}")
+	private String exchangeName;
+
+	@Value("${rabbitmq.routing.key}")
+	private String routingKey;
+
+	@Bean
+	DirectExchange directExchange() {
+		return new DirectExchange(exchangeName);
+	}
+
+	@Bean
+	Queue queue() {
+		return new Queue(queueName);
+	}
+
+	@Bean
+	Binding binding(DirectExchange directExchange, Queue queue) {
+		return BindingBuilder.bind(queue).to(directExchange).with(routingKey);
+	}
+
+	@Bean
+	ConnectionFactory connectionFactory() {
+		CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
+		connectionFactory.setHost(host);
+		connectionFactory.setPort(port);
+		connectionFactory.setUsername(username);
+		connectionFactory.setPassword(password);
+		return connectionFactory;
+	}
+
+	@Bean
+	MessageConverter messageConverter() {
+		return new Jackson2JsonMessageConverter();
+	}
+
+	@Bean
+	RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory, MessageConverter messageConverter) {
+		RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
+		rabbitTemplate.setMessageConverter(messageConverter);
+		return rabbitTemplate;
+	}
+}

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

@@ -0,0 +1,42 @@
+package org.c4marathon.assignment.controller;
+
+import org.c4marathon.assignment.dto.request.PostMainAccountReq;
+import org.c4marathon.assignment.dto.request.PostSavingsAccountReq;
+import org.c4marathon.assignment.dto.request.TransferReq;
+import org.c4marathon.assignment.dto.request.WithdrawMainAccountReq;
+import org.c4marathon.assignment.dto.response.MainAccountInfoRes;
+import org.c4marathon.assignment.dto.response.TransferRes;
+import org.c4marathon.assignment.dto.response.WithdrawInfoRes;
+import org.c4marathon.assignment.service.AccountService;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+
+@RestController
+@RequestMapping("/v1/accounts")
+@RequiredArgsConstructor
+public class AccountController {
+	private final AccountService accountService;
+
+	@PostMapping("/savings")
+	public void createSavingsAccount(@RequestBody @Valid PostSavingsAccountReq postSavingsAccountReq) {
+		accountService.createSavingsAccount(postSavingsAccountReq);
+	}
+	@PostMapping("/main/deposit")
+	public MainAccountInfoRes depositMainAccount(@RequestBody @Valid PostMainAccountReq postMainAccountReq) {
+		return accountService.depositMainAccount(postMainAccountReq);
+	}
+	@PostMapping("/savings/withdraw")
+	public WithdrawInfoRes withdrawForSavings(@RequestBody @Valid WithdrawMainAccountReq withdrawMainAccountReq) {
+		return accountService.withdrawForSavings(withdrawMainAccountReq);
+	}
+
+	@PostMapping("/main/transfer")
+	public TransferRes transfer(@RequestBody @Valid TransferReq transferReq) {
+		return accountService.transfer(transferReq);
+	}
+}

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

@@ -0,0 +1,25 @@
+package org.c4marathon.assignment.controller;
+
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import org.c4marathon.assignment.dto.request.PostUserReq;
+import org.c4marathon.assignment.service.UserService;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/v1/users")
+@RequiredArgsConstructor
+public class UserController {
+    private final UserService userService;
+
+    @PostMapping()
+    public ResponseEntity<Void> registerUser(@RequestBody @Valid PostUserReq postUserReq) {
+        userService.registerUser(postUserReq);
+        return ResponseEntity.status(HttpStatus.CREATED).build();
+    }
+}

src/main/java/org/c4marathon/assignment/dto/MessageDto.java

@@ -0,0 +1,27 @@
+package org.c4marathon.assignment.dto;
+
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+
+@Getter
+@ToString
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class MessageDto {
+	long transferTransactionId;
+
+	long senderMainAccount;
+
+	long receiverMainAccount;
+	long amount;
+
+	@Builder
+	public MessageDto(long transferTransactionId, long senderMainAccount, long receiverMainAccount, long amount) {
+		this.transferTransactionId = transferTransactionId;
+		this.senderMainAccount = senderMainAccount;
+		this.receiverMainAccount = receiverMainAccount;
+		this.amount = amount;
+	}
+}

src/main/java/org/c4marathon/assignment/dto/TransferTransactionEvent.java

@@ -0,0 +1,27 @@
+package org.c4marathon.assignment.dto;
+
+import lombok.Builder;
+import lombok.Getter;
+
+@Getter
+public class TransferTransactionEvent {
+	private static final int INIT_TRANSFER_TRANSACTION_ID = -1;
+	String userName;
+	long transferTransactionId;
+	long senderMainAccount;
+	long receiverMainAccount;
+	long amount;
+
+	@Builder
+	public TransferTransactionEvent(String userName, long senderMainAccount, long receiverMainAccount, long amount) {
+		this.userName = userName;
+		this.transferTransactionId = INIT_TRANSFER_TRANSACTION_ID;
+		this.senderMainAccount = senderMainAccount;
+		this.receiverMainAccount = receiverMainAccount;
+		this.amount = amount;
+	}
+
+	public void updateTransferTransactionId(long transferTransactionId) {
+		this.transferTransactionId = transferTransactionId;
+	}
+}

src/main/java/org/c4marathon/assignment/dto/request/PostMainAccountReq.java

@@ -0,0 +1,12 @@
+package org.c4marathon.assignment.dto.request;
+
+import jakarta.validation.constraints.Positive;
+
+public record PostMainAccountReq(
+	@Positive(message = "회원 번호는 양수가 되어야 합니다.")
+	long userId,
+
+	@Positive(message = "이체 금액은 양수가 되어야 합니다.")
+	long amount
+) {
+}

src/main/java/org/c4marathon/assignment/dto/request/PostSavingsAccountReq.java

@@ -0,0 +1,11 @@
+package org.c4marathon.assignment.dto.request;
+
+import jakarta.validation.constraints.Email;
+import jakarta.validation.constraints.NotBlank;
+
+public record PostSavingsAccountReq(
+	@Email
+	@NotBlank
+	String email
+) {
+}

src/main/java/org/c4marathon/assignment/dto/request/PostUserReq.java

@@ -0,0 +1,20 @@
+package org.c4marathon.assignment.dto.request;
+
+import jakarta.validation.constraints.Email;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.Size;
+
+public record PostUserReq(
+        @Size(max = 100)
+        @NotBlank
+        String username,
+
+        @Email
+        @NotBlank
+        String email,
+
+        @Size(max = 100)
+        @NotBlank
+        String nickname
+) {
+}

src/main/java/org/c4marathon/assignment/dto/request/TransferReq.java

@@ -0,0 +1,15 @@
+package org.c4marathon.assignment.dto.request;
+
+import jakarta.validation.constraints.Positive;
+
+public record TransferReq(
+	@Positive(message = "사용자 번호는 양수가 되어야 합니다.")
+	long senderId,
+
+	@Positive(message = "메인 계좌번호는 양수가 되어야 합니다.")
+	long receiverMainAccount,
+
+	@Positive(message = "송금 금액은 양수가 되어야 합니다.")
+	long amount
+) {
+}

src/main/java/org/c4marathon/assignment/dto/request/WithdrawMainAccountReq.java

@@ -0,0 +1,13 @@
+package org.c4marathon.assignment.dto.request;
+
+import jakarta.validation.constraints.Positive;
+
+public record WithdrawMainAccountReq(
+	@Positive(message = "회원 번호는 양수가 되어야 합니다.")
+	long userId,
+	@Positive(message = "적금 계좌번호는 양수가 되어야 합니다.")
+	long savingsAccount,
+	@Positive(message = " 금액은 양수가 되어야 합니다.")
+	long amount
+) {
+}

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

@@ -0,0 +1,17 @@
+package org.c4marathon.assignment.dto.response;
+
+import java.time.Instant;
+
+import org.c4marathon.assignment.entity.Account;
+
+public record MainAccountInfoRes(
+	Instant depositDate,
+	Long balance
+) {
+	public MainAccountInfoRes(Account account) {
+		this(
+			account.getUpdatedDate(),
+			account.getBalance()
+		);
+	}
+}

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

@@ -0,0 +1,15 @@
+package org.c4marathon.assignment.dto.response;
+
+import java.time.Instant;
+
+public record TransferRes(
+	Instant transferDate,
+	Long mainAccountBalance
+) {
+	public TransferRes(long mainAccountBalance) {
+		this(
+			Instant.now(),
+			mainAccountBalance
+		);
+	}
+}

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

@@ -0,0 +1,17 @@
+package org.c4marathon.assignment.dto.response;
+
+import java.time.Instant;
+
+public record WithdrawInfoRes(
+	Instant withdrawDate,
+	Long mainAccountBalance,
+	Long savingsAccountBalance
+) {
+	public WithdrawInfoRes(long mainAccountBalance, long savingsAccountBalance) {
+		this(
+			Instant.now(),
+			mainAccountBalance,
+			savingsAccountBalance
+		);
+	}
+}