[1단계 - DB 복제와 캐시] 알파카(최휘용) 미션 제출합니다.

src/main/java/coupon/DataSourceConfig.java

@@ -0,0 +1,68 @@
+package coupon;
+
+import com.zaxxer.hikari.HikariDataSource;
+import jakarta.persistence.EntityManagerFactory;
+import java.util.HashMap;
+import java.util.Map;
+import javax.sql.DataSource;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.boot.jdbc.DataSourceBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.DependsOn;
+import org.springframework.context.annotation.Primary;
+import org.springframework.jdbc.datasource.LazyConnectionDataSourceProxy;
+import org.springframework.orm.jpa.JpaTransactionManager;
+import org.springframework.transaction.PlatformTransactionManager;
+
+@Configuration
+public class DataSourceConfig {
+
+ public static final String READER = "reader";
+ public static final String WRITER = "writer";
+
+ @ConfigurationProperties(prefix = "coupon.datasource.writer")
+ @Bean
+ public DataSource writerDataSource() {
+ return DataSourceBuilder.create().type(HikariDataSource.class).build();
+ }
+
+ @ConfigurationProperties(prefix = "coupon.datasource.reader")
+ @Bean
+ public DataSource readerDataSource() {
+ return DataSourceBuilder.create().type(HikariDataSource.class).build();
+ }
+
+ @DependsOn({"writerDataSource", "readerDataSource"})
+ @Bean
+ public DataSource routingDataSource(
+ @Qualifier("writerDataSource") DataSource writer,
+ @Qualifier("readerDataSource") DataSource reader) {
+ ReadOnlyDataSourceRouter routingDataSource = new ReadOnlyDataSourceRouter();
+
+ Map<Object, Object> dataSourceMap = new HashMap<>();
+
+ dataSourceMap.put(WRITER, writer);
+ dataSourceMap.put(READER, reader);
+
+ routingDataSource.setTargetDataSources(dataSourceMap);
+ routingDataSource.setDefaultTargetDataSource(writer);
+
+ return routingDataSource;
+ }
+
+ @DependsOn({"routingDataSource"})
+ @Primary
+ @Bean
+ public DataSource dataSource(DataSource routingDataSource) {
+ return new LazyConnectionDataSourceProxy(routingDataSource);
+ }
+
+ @Bean
+ public PlatformTransactionManager transactionManager(EntityManagerFactory entityManagerFactory) {
+ JpaTransactionManager jpaTransactionManager = new JpaTransactionManager();
+ jpaTransactionManager.setEntityManagerFactory(entityManagerFactory);
+ return jpaTransactionManager;
+ }
+}

src/main/java/coupon/ReadOnlyDataSourceRouter.java

@@ -0,0 +1,15 @@
+package coupon;
+
+import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
+import org.springframework.transaction.support.TransactionSynchronizationManager;
+
+public class ReadOnlyDataSourceRouter extends AbstractRoutingDataSource {
+
+ @Override
+ protected Object determineCurrentLookupKey() {
+ if (TransactionSynchronizationManager.isCurrentTransactionReadOnly()) {
+ return DataSourceConfig.READER;
+ }
+ return DataSourceConfig.WRITER;
+ }
+}

src/main/java/coupon/domain/Category.java

@@ -0,0 +1,6 @@
+package coupon.domain;
+
+public enum Category {
+
+ FASHION, HOME_APPLIANCE, FURNITURE, FOOD
+}

src/main/java/coupon/domain/MemberCoupon.java

@@ -0,0 +1,43 @@
+package coupon.domain;
+
+import coupon.domain.coupon.Coupon;
+import coupon.domain.member.Member;
+import jakarta.persistence.Entity;
+import jakarta.persistence.FetchType;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.JoinColumn;
+import jakarta.persistence.ManyToOne;
+import java.time.LocalDate;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class MemberCoupon {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ private Long id;
+ @ManyToOne(fetch = FetchType.LAZY)
+ @JoinColumn(name = "coupon_id")
+ private Coupon coupon;
+ @ManyToOne(fetch = FetchType.LAZY)
+ @JoinColumn(name = "member_id")
+ private Member member;
+ private boolean used;
+ private LocalDate issueDate;
+ private LocalDate expirationDate;
+
+ public MemberCoupon(Long id, Coupon coupon, Member member, boolean used, LocalDate issueDate) {
+ this.id = id;
+ this.coupon = coupon;
+ this.member = member;
+ this.used = used;
+ this.issueDate = issueDate;
+ this.expirationDate = issueDate.plusDays(6);
+ }
+}

src/main/java/coupon/domain/coupon/Coupon.java

@@ -0,0 +1,51 @@
+package coupon.domain.coupon;
+
+import coupon.domain.Category;
+import jakarta.persistence.Embedded;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class Coupon {
+
+ private static final int MINIMUM_DISCOUNT_RATE = 3;
+ private static final int MAXIMUM_DISCOUNT_RATE = 20;
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ private Long id;
+ @Embedded
+ private CouponName couponName;
+ @Embedded
+ private DiscountMount discountMount;
+ @Embedded
+ private MinimumMount minimumMount;
+ private Category category;
+ @Embedded
+ private Period period;
+
+ public Coupon(CouponName couponName, DiscountMount discountMount, MinimumMount minimumMount, Category category,
+ Period period) {
+ validateDiscountRate(discountMount, minimumMount);
+ this.couponName = couponName;
+ this.discountMount = discountMount;
+ this.minimumMount = minimumMount;
+ this.category = category;
+ this.period = period;
+ }
+
+ private void validateDiscountRate(DiscountMount discountMount, MinimumMount minimumMount) {
+ float discountRate = (float) discountMount.getDiscountMount() / minimumMount.getMinimumMount() * 100;
+ int truncatedDiscountRate = (int) discountRate;
+ if (truncatedDiscountRate < MINIMUM_DISCOUNT_RATE || truncatedDiscountRate > MAXIMUM_DISCOUNT_RATE) {
+ throw new IllegalArgumentException("쿠폰 할인율은 3% 이상, 20% 이하여야 합니다.");
+ }
+ }
+}

src/main/java/coupon/domain/coupon/CouponName.java

@@ -0,0 +1,27 @@
+package coupon.domain.coupon;
+
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@NoArgsConstructor
+public class CouponName {
+
+ private static final int MAX_LENGTH = 30;
+
+ private String couponName;
+
+ public CouponName(String couponName) {
+ validate(couponName);
+ this.couponName = couponName;
+ }
+
+ private void validate(String name) {
+ if (name == null || name.isEmpty()) {
+ throw new IllegalArgumentException("이름은 비어있을 수 없습니다.");
+ }
+ if (name.length() > MAX_LENGTH) {
+ throw new IllegalArgumentException("이름은 최대 " + MAX_LENGTH + "자 입니다.");
+ }
+ }
+}

src/main/java/coupon/domain/coupon/DiscountMount.java

@@ -0,0 +1,32 @@
+package coupon.domain.coupon;
+
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@NoArgsConstructor
+public class DiscountMount {
+
+ private static final int MINIMUM_MOUNT = 1_000;
+ private static final int MAXIMUM_MOUNT = 10_000;
+ private static final int UNIT = 500;
+
+ private int discountMount;
+
+ public DiscountMount(int discountMount) {
+ validate(discountMount);
+ this.discountMount = discountMount;
+ }
+
+ private void validate(int mount) {
+ if (mount < MINIMUM_MOUNT) {
+ throw new IllegalArgumentException("할인 금액은 " + MINIMUM_MOUNT + "원 이상이어야 합니다.");
+ }
+ if (mount > MAXIMUM_MOUNT) {
+ throw new IllegalArgumentException("할인 금액은 " + MAXIMUM_MOUNT + "원 이하여야 합니다.");
+ }
+ if (mount % UNIT != 0) {
+ throw new IllegalArgumentException("할인 금액은 " + UNIT + "원 단위여야 합니다.");
+ }
+ }
+}

src/main/java/coupon/domain/coupon/MinimumMount.java

@@ -0,0 +1,28 @@
+package coupon.domain.coupon;
+
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@NoArgsConstructor
+public class MinimumMount {
+
+ private static final int MINIMUM_MOUNT = 5_000;
+ private static final int MAXIMUM_MOUNT = 100_000;
+
+ private int minimumMount;
+
+ public MinimumMount(int minimumMount) {
+ validate(minimumMount);
+ this.minimumMount = minimumMount;
+ }
+
+ private void validate(int mount) {
+ if (mount < MINIMUM_MOUNT) {
+ throw new IllegalArgumentException("최소 주문 금액은 " + MINIMUM_MOUNT + "원 이상이어야 합니다.");
+ }
+ if (mount > MAXIMUM_MOUNT) {
+ throw new IllegalArgumentException("최소 주문 금액은 " + MAXIMUM_MOUNT + "원 이하여야 합니다.");
+ }
+ }
+}

src/main/java/coupon/domain/coupon/Period.java

@@ -0,0 +1,25 @@
+package coupon.domain.coupon;
+
+import java.time.LocalDate;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@NoArgsConstructor
+public class Period {
+
+ private LocalDate startDate;
+ private LocalDate endDate;
+
+ public Period(LocalDate startDate, LocalDate endDate) {
+ validate(startDate, endDate);
+ this.startDate = startDate;
+ this.endDate = endDate;
+ }
+
+ private void validate(LocalDate startDate, LocalDate endDate) {
+ if (startDate.isAfter(endDate)) {
+ throw new IllegalArgumentException("시작일은 종료일보다 이전이어야 합니다.");
+ }
+ }
+}

src/main/java/coupon/domain/member/Member.java

@@ -0,0 +1,27 @@
+package coupon.domain.member;
+
+import jakarta.persistence.Embedded;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class Member {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ private Long id;
+ @Embedded
+ private MemberName memberName;
+
+ public Member(Long id, MemberName memberName) {
+ this.id = id;
+ this.memberName = memberName;
+ }
+}

src/main/java/coupon/domain/member/MemberName.java

@@ -0,0 +1,25 @@
+package coupon.domain.member;
+
+import lombok.Getter;
+
+@Getter
+public class MemberName {
+
+ private static final int MAX_LENGTH = 30;
+
+ private final String name;
+
+ public MemberName(String name) {
+ validate(name);
+ this.name = name;
+ }
+
+ private void validate(String name) {
+ if (name == null || name.isEmpty()) {
+ throw new IllegalArgumentException("이름은 비어있을 수 없습니다.");
+ }
+ if (name.length() > MAX_LENGTH) {
+ throw new IllegalArgumentException("이름은 최대 " + MAX_LENGTH + "자 입니다.");
+ }
+ }
+}

src/main/java/coupon/repository/CouponRepository.java

@@ -0,0 +1,9 @@
+package coupon.repository;
+
+import coupon.domain.coupon.Coupon;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface CouponRepository extends JpaRepository<Coupon, Long> {
+}