[3주차] 예약 API 구현 및 Redisson Lock 구현

app/build.gradle

@@ -29,6 +29,7 @@ dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-validation'
 	implementation 'org.springframework.boot:spring-boot-starter-web'
 	implementation 'org.springframework.boot:spring-boot-starter-data-redis'
+	implementation 'org.redisson:redisson-spring-boot-starter:3.43.0'
 	compileOnly 'org.projectlombok:lombok'
 	developmentOnly 'org.springframework.boot:spring-boot-docker-compose'
 	runtimeOnly 'com.mysql:mysql-connector-j'

app/src/main/java/com/movie/app/controller/MovieRestController.java

@@ -4,8 +4,9 @@
 import org.springframework.web.bind.annotation.*;
 
 import com.movie.app.domain.Movie;
-import com.movie.app.domain.MovieRepository;
 import com.movie.app.domain.MovieRequestDto;
+import com.movie.app.domain.TicketingRequestDto;
+import com.movie.app.service.MovieService;
 
 import jakarta.validation.constraints.Size;
 import lombok.RequiredArgsConstructor;
@@ -15,7 +16,7 @@
 @RestController
 public class MovieRestController {
 
-    private final MovieRepository movieRepository;
+    private final MovieService movieService;
 
     @GetMapping("/api/movies")
     public List<Movie> getMovies(
@@ -24,18 +25,21 @@ public List<Movie> getMovies(
         @RequestParam(required=false) String genre) {
 
             if(genre != null) {
-                return movieRepository.findByGenre(genre);
+                return movieService.getMoviesByGenre(genre);
             } else if (title != null) {
-                return movieRepository.findByTitle(title);
+                return movieService.getMoviesByTitle(title);
             } else {
-                return movieRepository.findAll();
+                return movieService.getMoviesAll();
             }     
     }
 
     @PostMapping("/api/movies")
     public Movie postMovies(@RequestBody MovieRequestDto requestDto) {
-        Movie movie = new Movie(requestDto);
-        movieRepository.save(movie);
-        return movie;
+        return movieService.postMovie(requestDto);
+    }
+
+    @PutMapping("/api/ticketing/{id}")
+    public Movie ticketingMovie(@PathVariable Long id, @RequestBody TicketingRequestDto requestDto) {
+        return movieService.ticketing(id ,requestDto);
     }
 }

app/src/main/java/com/movie/app/domain/Movie.java

@@ -1,5 +1,6 @@
 package com.movie.app.domain;
 
+import java.time.LocalTime;
 import java.util.List;
 
 import jakarta.persistence.Column;
@@ -14,6 +15,9 @@
 @NoArgsConstructor
 @Entity(name="Movie")
 public class Movie extends Timestamped{
+
+    private static final int MAX_SEATS = 25;
+
     @GeneratedValue(strategy = GenerationType.AUTO)
     @Id
     private Long id;
@@ -40,7 +44,14 @@ public class Movie extends Timestamped{
     private String theater;
 
     @Column
-    private List<String> screeningSchedule;
+    private LocalTime screenStartTime;
+
+    @Column
+    private LocalTime screenEndTime;
+
+    @Column
+    private Boolean[] seats = new Boolean[MAX_SEATS];
+
 
     public Movie(MovieRequestDto requestDto) {
         this.title = requestDto.getTitle();
@@ -50,6 +61,16 @@ public Movie(MovieRequestDto requestDto) {
         this.runningTime = requestDto.getRunningTime();
         this.genre = requestDto.getGenre();
         this.theater = requestDto.getTheater();
-        this.screeningSchedule = requestDto.getScreeningSchedule();
+    }
+
+    public void updateSeats(List<Integer> wantedSeats) {
+        if(this.seats == null) {
+            this.seats = new Boolean[MAX_SEATS];
+        }
+
+        for (int i=0; i<wantedSeats.size(); i++) {
+            int val= wantedSeats.get(i);
+            this.seats[val]=true;
+        }
     }
 }

app/src/main/java/com/movie/app/domain/TicketingRequestDto.java

@@ -0,0 +1,10 @@
+package com.movie.app.domain;
+
+import java.util.List;
+
+import lombok.Getter;
+
+@Getter
+public class TicketingRequestDto {
+    private List<Integer> seats;
+}

app/src/main/java/com/movie/app/service/MovieService.java

@@ -1,12 +1,18 @@
 package com.movie.app.service;
 
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
 import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import com.movie.app.domain.Movie;
 import com.movie.app.domain.MovieRepository;
+import com.movie.app.domain.MovieRequestDto;
+import com.movie.app.domain.TicketingRequestDto;
 
 import lombok.RequiredArgsConstructor;
 
@@ -15,6 +21,7 @@
 public class MovieService {
 
     private final MovieRepository movieRepository;
+    private final RedissonClient redissonClient;
 
     @Cacheable(value = "Movies", key = "#title", cacheManager = "contentCacheManager")
     public List<Movie> getMoviesByTitle(String title) {
@@ -27,8 +34,40 @@ public List<Movie> getMoviesByGenre(String genre) {
     }
 
     @Cacheable(value = "Movies", key = "all", cacheManager = "contentCacheManager")
-    public List<Movie> getMoviesByGenre() {
+    public List<Movie> getMoviesAll() {
         return movieRepository.findAll();
     }
 
+    public Movie postMovie(MovieRequestDto requestDto) {
+        Movie movie = new Movie(requestDto);
+        movieRepository.save(movie);
+        return movie;
+    }
+
+    @Transactional
+    public Movie ticketing(Long id, TicketingRequestDto requestDto) {
+        Movie movie = movieRepository.findById(id).orElseThrow(
+                () -> new NullPointerException("There is no id at DB.")
+        );
+
+        if(movie==null) {
+            return movie;
+        }
+
+        RLock lock = redissonClient.getLock(id.toString());
+        try {
+            boolean acquireLock = lock.tryLock(10, 1, TimeUnit.SECONDS);
+            if (!acquireLock) {
+                System.out.println("Lock get fail");
+                return movie;
+            }
+            movie.updateSeats(requestDto.getSeats());
+        } catch (InterruptedException e) {
+        } finally {
+            lock.unlock();
+        }
+
+        return movie;
+    }
+
 }