2주차 : 줌터파크 과제 제출합니다.

build.gradle

@@ -38,6 +38,9 @@ dependencies {
     // 쿼리 파라미터 로그
     implementation 'com.github.gavlyukovskiy:p6spy-spring-boot-starter:1.5.8'
 
+    //redisson
+    implementation 'org.redisson:redisson-spring-boot-starter:3.17.4'
+
     compileOnly 'org.projectlombok:lombok'
     runtimeOnly 'com.h2database:h2'
     runtimeOnly 'com.mysql:mysql-connector-j'

docker-compose.yml

@@ -0,0 +1,12 @@
+version: '3.9'
+services:
+  redis:
+    image: 'redis:alpine'
+    hostname: redis
+    container_name: redis-dailyProject
+    ports:
+      - '6379:6379'
+
+volumes:
+  redis:
+    driver: local

src/main/java/com/week/zumgnmarket/config/QueryDslConfig.java

@@ -0,0 +1,21 @@
+package com.week.zumgnmarket.config;
+
+import com.querydsl.jpa.impl.JPAQueryFactory;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import javax.persistence.EntityManager;
+import javax.persistence.PersistenceContext;
+
+@Configuration
+public class QueryDslConfig {
+
+    @PersistenceContext
+    private EntityManager entityManager;
+
+    @Bean
+    public JPAQueryFactory jpaQueryFactory() {
+        return new JPAQueryFactory(entityManager);
+    }
+}
+

src/main/java/com/week/zumgnmarket/config/RedissonConfig.java

@@ -0,0 +1,28 @@
+package com.week.zumgnmarket.config;
+
+import org.redisson.Redisson;
+import org.redisson.api.RedissonClient;
+import org.redisson.config.Config;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class RedissonConfig {
+    @Value("${spring.redis.host}")
+    private String redisHost;
+
+    @Value("${spring.redis.port}")
+    private int redisPort;
+
+    private static final String REDISSON_HOST_PREFIX = "redis://";
+
+    @Bean
+    public RedissonClient redissonClient() {
+        RedissonClient redisson = null;
+        Config config = new Config();
+        config.useSingleServer().setAddress(REDISSON_HOST_PREFIX + redisHost + ":" + redisPort);
+        redisson = Redisson.create(config);
+        return redisson;
+    }
+}

src/main/java/com/week/zumgnmarket/controller/TicketController.java

@@ -0,0 +1,24 @@
+package com.week.zumgnmarket.controller;
+
+import com.week.zumgnmarket.fecade.TicketFacade;
+import com.week.zumgnmarket.fecade.dto.TicketRequest;
+import com.week.zumgnmarket.fecade.dto.TicketResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/tickets")
+@RequiredArgsConstructor
+public class TicketController {
+
+    private final TicketFacade ticketFacade;
+
+    @GetMapping("/buy")
+    public ResponseEntity<TicketResponse> buy(@RequestBody TicketRequest ticketRequest) {
+        return ResponseEntity.ok(ticketFacade.buy(ticketRequest));
+    }
+}

src/main/java/com/week/zumgnmarket/entity/Buyer.java

@@ -0,0 +1,28 @@
+package com.week.zumgnmarket.entity;
+
+import lombok.*;
+
+import javax.persistence.*;
+
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@Getter
+@Builder
+@Table(name = "buyer")
+public class Buyer {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "buyer_idx")
+    private Integer id;
+
+    @Column(name = "nick_name")
+    private String nickName;
+
+    public static Buyer of(String nickName) {
+        return Buyer.builder()
+                .nickName(nickName).build();
+    }
+
+}

src/main/java/com/week/zumgnmarket/entity/Musical.java

@@ -0,0 +1,32 @@
+package com.week.zumgnmarket.entity;
+
+import lombok.*;
+
+import javax.persistence.*;
+
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@Getter
+@Builder
+@Table(name = "musical")
+public class Musical {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "musical_idx")
+    private Integer id;
+
+    @Column(name = "title")
+    private String title;
+
+    @Column(name = "description")
+    private String description;
+
+    public static Musical of(String title, String description) {
+        return Musical.builder()
+                .title(title)
+                .description(description)
+                .build();
+    }
+}

src/main/java/com/week/zumgnmarket/entity/MusicalTicket.java

@@ -0,0 +1,59 @@
+package com.week.zumgnmarket.entity;
+
+import lombok.*;
+import lombok.extern.slf4j.Slf4j;
+
+import javax.persistence.*;
+import java.time.LocalDate;
+
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@Getter
+@Slf4j
+@Builder
+@Table(name = "musical_ticket")
+public class MusicalTicket {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "ticket_idx")
+    private Integer id;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "musicla_idx")
+    private Musical musical;
+
+    @Column(name = "ticket_count")
+    private Long ticketCount;
+
+    @Column(name = "ticketing_date")
+    private LocalDate ticketingDate;
+
+    public static MusicalTicket of(Musical musical, Long ticketCount, LocalDate ticketingDate) {
+        return MusicalTicket.builder()
+                .musical(musical)
+                .ticketCount(ticketCount)
+                .ticketingDate(ticketingDate)
+                .build();
+    }
+
+    public void decrease() {
+        final String thread = Thread.currentThread().getName();
+        if((this.ticketCount - 1) < 0 ){
+            //throw new RuntimeException("오늘자 티켓팅이 마감되었습니다 (재고 부족)"); - 테스트 위해 주석
+            log.error("진행중인 사람 : {}, 메세지 : 티켓팅이 마감되었습니다(재고 부족 - {} 개) ", thread, this.ticketCount);
+            return;
+        }
+        this.ticketCount = this.ticketCount - 1;
+        log.error("진행중인 사람 : {}, 메세지 : 티켓팅을 성공하셨습니다(남은 티켓 갯수 - {} 개) ", thread, this.ticketCount);
+    }
+
+    public boolean checkTicketingDate(LocalDate localDate) {
+        return this.ticketingDate.equals(localDate);
+    }
+
+    public Integer getMusicalId() {
+        return this.musical.getId();
+    }
+}

src/main/java/com/week/zumgnmarket/entity/Purchase.java

@@ -0,0 +1,41 @@
+package com.week.zumgnmarket.entity;
+
+import lombok.*;
+
+import javax.persistence.*;
+
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@Getter
+@Builder
+@Table(name = "purchase")
+public class Purchase {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "purchase_idx")
+    private Integer id;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "buyer_idx")
+    private Buyer buyer;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "musical_idx")
+    private Musical musical;
+
+    public static Purchase of(Buyer buyer, Musical musical) {
+        return Purchase.builder()
+                .buyer(buyer)
+                .musical(musical)
+                .build();
+    }
+
+    public Integer getBuyerId() {
+        return this.buyer.getId();
+    }
+
+    public String getTitle() {
+        return this.musical.getTitle();
+    }
+}

src/main/java/com/week/zumgnmarket/fecade/TicketFacade.java

@@ -0,0 +1,60 @@
+package com.week.zumgnmarket.fecade;
+
+import com.week.zumgnmarket.entity.Buyer;
+import com.week.zumgnmarket.entity.Musical;
+import com.week.zumgnmarket.entity.MusicalTicket;
+import com.week.zumgnmarket.entity.Purchase;
+import com.week.zumgnmarket.fecade.dto.TicketRequest;
+import com.week.zumgnmarket.fecade.dto.TicketResponse;
+import com.week.zumgnmarket.service.BuyerService;
+import com.week.zumgnmarket.service.MusicalTicketService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.TimeUnit;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class TicketFacade {
+    private final MusicalTicketService musicalTicketService;
+    private final BuyerService buyerService;
+    private final RedissonClient redissonClient;
+
+    public TicketResponse buy(TicketRequest ticketRequest) {
+        Buyer buyer = buyerService.findBuyerById(ticketRequest.getBuyerId());
+        Musical musical = musicalTicketService.findMusicalById(ticketRequest.getMusicalId());
+        MusicalTicket musicalTicket = musicalTicketService.findTicketByMusical(musical);
+        if (!musicalTicket.checkTicketingDate(ticketRequest.getTicketingDate())) {
+            throw new RuntimeException("지금은 티켓팅 기간이 아닙니다.");
+        }
+        RLock lock = redissonClient.getLock(musical.getTitle() + ":" + ticketRequest.getTicketingDate());
+        try {
+            if (!lock.tryLock(3, 5, TimeUnit.SECONDS)) {
+                return new TicketResponse();
+            }
+            Purchase purchase = musicalTicketService.buyTicket(buyer, musicalTicket.getId());
+            return TicketResponse.of(purchase);
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        } finally {
+            //lock.isLocked() && lock.isHeldByCurrentThread()
+            if (lock != null && lock.isLocked() && lock.isHeldByCurrentThread()) {
+                lock.unlock();
+            }
+        }
+    }
+
+    public void buyNoLock(TicketRequest ticketRequest) {
+        Buyer buyer = buyerService.findBuyerById(ticketRequest.getBuyerId());
+        Musical musical = musicalTicketService.findMusicalById(ticketRequest.getMusicalId());
+        MusicalTicket musicalTicket = musicalTicketService.findTicketByMusical(musical);
+        if (!musicalTicket.checkTicketingDate(ticketRequest.getTicketingDate())) {
+            throw new RuntimeException("지금은 티켓팅 기간이 아닙니다.");
+        }
+        musicalTicketService.buyTicket(buyer, musicalTicket.getId());
+    }
+}

src/main/java/com/week/zumgnmarket/fecade/dto/TicketRequest.java

@@ -0,0 +1,23 @@
+package com.week.zumgnmarket.fecade.dto;
+
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+
+import java.time.LocalDate;
+
+@Getter
+@Setter
+@Builder
+public class TicketRequest {
+    private Integer buyerId;
+    private Integer musicalId;
+    private LocalDate TicketingDate;
+
+    public static TicketRequest of(Integer buyerId, Integer musicalId, LocalDate TicketingDate) {
+        return TicketRequest.builder()
+                .buyerId(buyerId)
+                .musicalId(musicalId)
+                .TicketingDate(TicketingDate).build();
+    }
+}

src/main/java/com/week/zumgnmarket/fecade/dto/TicketResponse.java

@@ -0,0 +1,22 @@
+package com.week.zumgnmarket.fecade.dto;
+
+import com.week.zumgnmarket.entity.Purchase;
+import lombok.*;
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+@Getter
+@Setter
+public class TicketResponse {
+
+    private Integer buyerId;
+    private String title;
+    private boolean isPurchase;
+
+    public static TicketResponse of(Purchase purchase) {
+        return TicketResponse.builder()
+                .buyerId(purchase.getBuyerId())
+                .title(purchase.getTitle())
+                .isPurchase(true).build();
+    }
+}

src/main/java/com/week/zumgnmarket/repository/BuyerJpaRepository.java

@@ -0,0 +1,8 @@
+package com.week.zumgnmarket.repository;
+
+import com.week.zumgnmarket.entity.Buyer;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface BuyerJpaRepository extends JpaRepository<Buyer, Integer> {
+
+}

src/main/java/com/week/zumgnmarket/repository/MusicalJpaRepository.java

@@ -0,0 +1,7 @@
+package com.week.zumgnmarket.repository;
+
+import com.week.zumgnmarket.entity.Musical;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface MusicalJpaRepository extends JpaRepository<Musical, Integer> {
+}

src/main/java/com/week/zumgnmarket/repository/PurchaseJpaRepository.java

@@ -0,0 +1,10 @@
+package com.week.zumgnmarket.repository;
+
+import com.week.zumgnmarket.entity.Buyer;
+import com.week.zumgnmarket.entity.Musical;
+import com.week.zumgnmarket.entity.Purchase;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface PurchaseJpaRepository extends JpaRepository<Purchase, Integer> {
+    boolean existsByBuyerAndMusical(Buyer buyer, Musical musical);
+}