Merge pull request #19 from C4-ComeTrue/feature/hellozo0_step1

Feature/hellozo0 step1

Author: hellozo0

.gitignore

@@ -38,3 +38,6 @@ out/
 
 ### MAC ###
 .DS_Store
+
+### Redis ###
+dump.rdb

build.gradle

@@ -29,6 +29,7 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-web'
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
     implementation 'org.springframework.boot:spring-boot-starter-validation'
+    implementation 'org.springframework.boot:spring-boot-starter-cache'
 
     //apache
     implementation 'org.apache.commons:commons-lang3:3.13.0'
@@ -41,6 +42,10 @@ dependencies {
     //mysql
     runtimeOnly 'com.mysql:mysql-connector-j'
 
+    //redis
+    implementation 'org.springframework.boot:spring-boot-starter-data-redis'
+    implementation 'org.springframework.session:spring-session-data-redis'
+
     //test
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
 }

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

@@ -2,8 +2,14 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
+@EnableScheduling
+@EnableJpaAuditing
+@EnableCaching
 public class AssignmentApplication {
 
 	public static void main(String[] args) {

src/main/java/org/c4marathon/assignment/common/cache/CacheConfig.java

@@ -0,0 +1,22 @@
+package org.c4marathon.assignment.common.cache;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.GenericToStringSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+@Configuration
+public class CacheConfig {
+
+	@Bean
+	public RedisTemplate<String, Long> redisStringLongTemplate(RedisConnectionFactory connectionFactory) {
+		RedisTemplate<String, Long> template = new RedisTemplate<>();
+		template.setConnectionFactory(connectionFactory);
+		template.setKeySerializer(new StringRedisSerializer());
+		template.setValueSerializer(new GenericToStringSerializer<>(Long.class));
+
+		return template;
+	}
+}

src/main/java/org/c4marathon/assignment/common/cache/CacheScheduler.java

@@ -0,0 +1,30 @@
+package org.c4marathon.assignment.common.cache;
+
+import java.time.Duration;
+
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+public class CacheScheduler {
+	private final RedisTemplate<String, Long> redisTemplate;
+
+	public CacheScheduler(RedisTemplate<String, Long> redisTemplate) {
+		this.redisTemplate = redisTemplate;
+	}
+
+	@Scheduled(cron = "0 0 0 * * *")
+	public void resetDailyLimit() {
+		/* 24시에 10분동안 은행 계좌 점검 => 10분동안 일일 한도 초기화 */
+		String lockKey = "reset";
+		redisTemplate.opsForValue().set(lockKey, 1L, Duration.ofMinutes(10));
+
+		/* 모든 dailyLimit 삭제 */
+		try {
+			redisTemplate.keys("dailyLimit:*").forEach(redisTemplate::delete);
+		} finally {
+			redisTemplate.delete(lockKey);
+		}
+	}
+}

src/main/java/org/c4marathon/assignment/common/dto/ErrorResponse.java

@@ -0,0 +1,25 @@
+package org.c4marathon.assignment.common.dto;
+
+import org.c4marathon.assignment.common.exception.enums.ErrorCode;
+import org.springframework.http.HttpStatus;
+
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+import lombok.ToString;
+
+@Getter
+@ToString
+@RequiredArgsConstructor(access = AccessLevel.PRIVATE)
+public class ErrorResponse {
+	private final int code;
+	private final String message;
+
+	public static ErrorResponse error(ErrorCode errorCode) {
+		return new ErrorResponse(errorCode.getHttpStatus().value(), errorCode.getMessage());
+	}
+
+	public static ErrorResponse badRequestError(final String errorMessage) {
+		return new ErrorResponse(HttpStatus.BAD_REQUEST.value(), errorMessage);
+	}
+}

src/main/java/org/c4marathon/assignment/common/dto/SuccessNonDataResponse.java

@@ -0,0 +1,20 @@
+package org.c4marathon.assignment.common.dto;
+
+import org.c4marathon.assignment.common.exception.enums.SuccessCode;
+
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.ToString;
+
+@Getter
+@ToString
+@AllArgsConstructor(access = AccessLevel.PRIVATE)
+public class SuccessNonDataResponse {
+	private final int code;
+	private final String message;
+
+	public static SuccessNonDataResponse success(SuccessCode successCode) {
+		return new SuccessNonDataResponse(successCode.getHttpStatus().value(), successCode.getMessage());
+	}
+}

src/main/java/org/c4marathon/assignment/common/dto/SuccessResponse.java

@@ -0,0 +1,21 @@
+package org.c4marathon.assignment.common.dto;
+
+import org.c4marathon.assignment.common.exception.enums.SuccessCode;
+
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.ToString;
+
+@Getter
+@ToString
+@AllArgsConstructor(access = AccessLevel.PRIVATE)
+public class SuccessResponse<T> {
+	private final int code;
+	private final String message;
+	private final T data;
+
+	public static <T> SuccessResponse<T> success(SuccessCode successCode, T data) {
+		return new SuccessResponse<>(successCode.getHttpStatus().value(), successCode.getMessage(), data);
+	}
+}

src/main/java/org/c4marathon/assignment/common/exception/BalanceUpdateException.java

@@ -0,0 +1,9 @@
+package org.c4marathon.assignment.common.exception;
+
+import org.c4marathon.assignment.common.exception.enums.ErrorCode;
+
+public class BalanceUpdateException extends BaseException {
+	public BalanceUpdateException(ErrorCode errorCode) {
+      super(errorCode);
+    }
+}

src/main/java/org/c4marathon/assignment/common/exception/BaseException.java

@@ -0,0 +1,14 @@
+package org.c4marathon.assignment.common.exception;
+
+import org.c4marathon.assignment.common.exception.enums.ErrorCode;
+import lombok.Getter;
+
+@Getter
+public class BaseException extends RuntimeException {
+	private final ErrorCode errorCode;
+
+	public BaseException(final ErrorCode errorCode) {
+		super(errorCode.getMessage());
+		this.errorCode = errorCode;
+	}
+}