Feat/register schedule with inventory

application/src/main/java/org/mandarin/booking/adapter/security/ApplicationAuthorizationRequestMatcherConfigurer.java

@@ -1,7 +1,10 @@
 package org.mandarin.booking.adapter.security;
 
 import org.mandarin.booking.adapter.AuthorizationRequestMatcherConfigurer;
+import org.springframework.context.annotation.Bean;
 import org.springframework.http.HttpMethod;
+import org.springframework.security.access.hierarchicalroles.RoleHierarchy;
+import org.springframework.security.access.hierarchicalroles.RoleHierarchyImpl;
 import org.springframework.security.config.annotation.web.builders.HttpSecurity;
 import org.springframework.security.config.annotation.web.configurers.AuthorizeHttpRequestsConfigurer;
 import org.springframework.stereotype.Component;
@@ -23,4 +26,12 @@ public void authorizeRequests(
                 .requestMatchers(HttpMethod.POST, "/api/hall").hasAuthority("ROLE_ADMIN")
                 .anyRequest().authenticated();
     }
+
+    @Bean
+    static RoleHierarchy roleHierarchy() {
+        return RoleHierarchyImpl.withDefaultRolePrefix()
+                .role("ADMIN").implies("DISTRIBUTOR")
+                .role("DISTRIBUTOR").implies("USER")
+                .build();
+    }
 }

application/src/main/java/org/mandarin/booking/app/JdbcBatchUtils.java

@@ -0,0 +1,51 @@
+package org.mandarin.booking.app;
+
+import static java.lang.Math.max;
+import static java.lang.Math.min;
+
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class JdbcBatchUtils {
+    private final JdbcTemplate jdbcTemplate;
+
+    public <T> void batchUpdate(String sql,
+                                List<T> items,
+                                SqlParameterBinder<T> binder,
+                                int batchSize) {
+        if (items.isEmpty()) {
+            return;
+        }
+        int size = items.size();
+        int chunk = max(1, batchSize);
+        for (int start = 0; start < size; start += chunk) {// chunk size만큼 slice
+            int end = min(size, start + chunk);
+            List<T> sub = items.subList(start, end);
+
+            jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {
+                @Override
+                public void setValues(PreparedStatement ps, int i) throws SQLException {
+                    binder.bind(ps, sub.get(i));
+                }
+
+                @Override
+                public int getBatchSize() {
+                    return sub.size();
+                }
+            });
+        }
+    }
+
+    @FunctionalInterface
+    public interface SqlParameterBinder<T> {
+        void bind(PreparedStatement ps, T item) throws SQLException;
+    }
+
+}

application/src/main/java/org/mandarin/booking/app/TableAwarePhysicalNamingStrategy.java

@@ -0,0 +1,28 @@
+package org.mandarin.booking.app;
+
+
+import static org.mandarin.booking.StringFormatterUtils.toSnakeCase;
+
+import org.hibernate.boot.model.naming.Identifier;
+import org.hibernate.boot.model.naming.PhysicalNamingStrategyStandardImpl;
+import org.hibernate.engine.jdbc.env.spi.JdbcEnvironment;
+import org.jspecify.annotations.Nullable;
+
+public class TableAwarePhysicalNamingStrategy extends PhysicalNamingStrategyStandardImpl {
+
+    private static final ThreadLocal<@Nullable String> CURRENT_TABLE = new ThreadLocal<>();
+
+    @Override
+    public Identifier toPhysicalTableName(Identifier name, JdbcEnvironment jdbcEnvironment) {
+        var table = toSnakeCase(name.getText());
+        CURRENT_TABLE.set(table);
+        return Identifier.toIdentifier(table, name.isQuoted());
+    }
+
+    @Override
+    public Identifier toPhysicalColumnName(Identifier name, JdbcEnvironment jdbcEnvironment) {
+        var logical = name.getText();
+        var physical = toSnakeCase(logical);
+        return Identifier.toIdentifier(physical, name.isQuoted());
+    }
+}

application/src/main/java/org/mandarin/booking/app/hall/HallCommandRepository.java

@@ -1,15 +1,42 @@
 package org.mandarin.booking.app.hall;
 
+import jakarta.validation.constraints.NotEmpty;
+import java.util.List;
 import lombok.RequiredArgsConstructor;
+import org.mandarin.booking.app.JdbcBatchUtils;
 import org.mandarin.booking.domain.hall.Hall;
+import org.mandarin.booking.domain.hall.Hall.SeatInsertRow;
 import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
 
 @Repository
+@Transactional
 @RequiredArgsConstructor
 class HallCommandRepository {
     private final HallRepository jpaRepository;
+    private final JdbcBatchUtils jdbcBatchUtils;
 
     Hall insert(Hall hall) {
-        return jpaRepository.save(hall);
+        var seatRows = hall.extractSeatRows();
+        hall.clearSeats();// jpa가 아닌 jdbc로 일괄 삽입을 위해 clear
+
+        var saved = jpaRepository.save(hall);
+
+        batchInsertSeats(seatRows);
+
+        return saved;
+    }
+
+    private void batchInsertSeats(@NotEmpty List<SeatInsertRow> rows) {
+        jdbcBatchUtils.batchUpdate(
+                "INSERT INTO seat (section_id, seat_row, seat_number) VALUES (?, ?, ?)",
+                rows,
+                (ps, row) -> {
+                    ps.setLong(1, row.section().getId());
+                    ps.setString(2, row.rowNumber());
+                    ps.setString(3, row.seatNumber());
+                },
+                1000
+        );
     }
 }

application/src/main/java/org/mandarin/booking/app/hall/HallQueryRepository.java

@@ -1,5 +1,11 @@
 package org.mandarin.booking.app.hall;
 
+import static org.mandarin.booking.domain.hall.QSeat.seat;
+import static org.mandarin.booking.domain.hall.QSection.section;
+
+import com.querydsl.jpa.impl.JPAQueryFactory;
+import java.util.HashSet;
+import java.util.List;
 import lombok.RequiredArgsConstructor;
 import org.mandarin.booking.domain.hall.Hall;
 import org.mandarin.booking.domain.hall.HallException;
@@ -11,6 +17,7 @@
 @RequiredArgsConstructor
 class HallQueryRepository {
     private final HallRepository repository;
+    private final JPAQueryFactory jpaQueryFactory;
 
     boolean existsById(Long hallId) {
         return repository.existsById(hallId);
@@ -24,4 +31,28 @@ Hall findById(Long hallId) {
         return repository.findById(hallId)
                 .orElseThrow(() -> new HallException("NOT_FOUND", "해당 공연장을 찾을 수 없습니다."));
     }
+
+    boolean existsByHallIdAndSectionId(Long hallId, Long sectionId) {
+        return findById(hallId).hasSectionOf(sectionId);
+    }
+
+    boolean containsSeatIdsBySectionId(Long sectionId, List<Long> seatIds) {
+        var fetched = jpaQueryFactory
+                .select(seat.id)
+                .from(section)
+                .join(section.seats, seat)
+                .where(section.id.eq(sectionId))
+                .fetch();
+        return new HashSet<>(fetched).containsAll(seatIds);
+    }
+
+    boolean equalsSeatIdsBySectionId(Long sectionId, List<Long> seatIds) {
+        var fetched = jpaQueryFactory
+                .select(seat.id)
+                .from(section)
+                .join(section.seats, seat)
+                .where(section.id.eq(sectionId))
+                .fetch();
+        return new HashSet<>(seatIds).equals(new HashSet<>(fetched));
+    }
 }

application/src/main/java/org/mandarin/booking/app/hall/HallService.java

@@ -1,5 +1,6 @@
 package org.mandarin.booking.app.hall;
 
+import java.util.List;
 import lombok.RequiredArgsConstructor;
 import org.mandarin.booking.domain.hall.Hall;
 import org.mandarin.booking.domain.hall.HallException;
@@ -32,11 +33,32 @@ public void checkHallExistByHallName(String hallName) {
         }
     }
 
+    @Override
+    public void checkHallExistBySectionId(Long hallId, Long sectionId) {
+        if (!queryRepository.existsByHallIdAndSectionId(hallId, sectionId)) {
+            throw new HallException("NOT_FOUND", "해당 공연장에 섹션이 존재하지 않습니다.");
+        }
+    }
+
+    @Override
+    public void checkHallInvalidSeatIds(Long sectionId, List<Long> seatIds) {
+        if (!queryRepository.containsSeatIdsBySectionId(sectionId, seatIds)) {
+            throw new HallException("BAD_REQUEST", "해당 섹션에 해당하지 않는 좌석이 있습니다.");
+        }
+    }
+
+    @Override
+    public void checkSectionContainsAllOf(Long sectionId, List<Long> seatIds) {
+        if (!queryRepository.equalsSeatIdsBySectionId(sectionId, seatIds)) {
+            throw new HallException("BAD_REQUEST", "해당 섹션 좌석과 총 좌석이 상이합니다.");
+        }
+    }
+
     @Override
     public HallRegisterResponse register(String userId, HallRegisterRequest request) {
         checkHallExistByHallName(request.hallName());
 
-        var hall = Hall.create(request.hallName(), userId);
+        var hall = Hall.create(request.hallName(), request.sections(), userId);
 
         var saved = commandRepository.insert(hall);
 

application/src/main/java/org/mandarin/booking/app/hall/HallValidator.java

@@ -1,7 +1,15 @@
 package org.mandarin.booking.app.hall;
 
+import java.util.List;
+
 public interface HallValidator {
     void checkHallExistByHallId(Long hallId);
 
     void checkHallExistByHallName(String hallName);
+
+    void checkHallExistBySectionId(Long hallId, Long sectionId);
+
+    void checkHallInvalidSeatIds(Long sectionId, List<Long> seatIds);
+
+    void checkSectionContainsAllOf(Long sectionId, List<Long> seatIds);
 }

application/src/main/java/org/mandarin/booking/app/show/InventoryCommandRepository.java

@@ -0,0 +1,40 @@
+package org.mandarin.booking.app.show;
+
+import jakarta.validation.constraints.NotEmpty;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.mandarin.booking.app.JdbcBatchUtils;
+import org.mandarin.booking.domain.show.Inventory;
+import org.mandarin.booking.domain.show.SeatState.SeatStateRow;
+import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
+
+@Repository
+@Transactional
+@RequiredArgsConstructor
+class InventoryCommandRepository {
+    private final InventoryRepository repository;
+    private final JdbcBatchUtils jdbcBatchUtils;
+
+    void insert(Inventory inventory) {
+        List<SeatStateRow> rows = inventory.extractSeatStateRows();
+        inventory.clearSeatStates();// jpa가 아닌 jdbc로 일괄 삽입하기 위해 clear
+
+        repository.save(inventory);
+
+        batchInsert(inventory.getId(), rows);
+    }
+
+    void batchInsert(Long inventoryId, @NotEmpty List<SeatStateRow> rows) {
+        jdbcBatchUtils.batchUpdate(
+                "INSERT INTO seat_state (inventory_id, seat_id, grade_id) VALUES (?, ?, ?)",
+                rows,
+                (ps, row) -> {
+                    ps.setLong(1, inventoryId);
+                    ps.setLong(2, row.seatId());
+                    ps.setLong(3, row.gradeId());
+                },
+                1000
+        );
+    }
+}

application/src/main/java/org/mandarin/booking/app/show/InventoryRepository.java

@@ -0,0 +1,8 @@
+package org.mandarin.booking.app.show;
+
+import org.mandarin.booking.domain.show.Inventory;
+import org.springframework.data.repository.Repository;
+
+interface InventoryRepository extends Repository<Inventory, Long> {
+    void save(Inventory inventory);
+}

application/src/main/java/org/mandarin/booking/app/show/InventoryService.java

@@ -0,0 +1,19 @@
+package org.mandarin.booking.app.show;
+
+import java.util.List;
+import java.util.Map;
+import lombok.RequiredArgsConstructor;
+import org.mandarin.booking.domain.show.Inventory;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+class InventoryService implements InventoryWriter {
+    private final InventoryCommandRepository commandRepository;
+
+    @Override
+    public void createInventory(Long scheduleId, Map<Long, List<Long>> seatAssociations) {
+        Inventory inventory = Inventory.create(scheduleId, seatAssociations);
+        commandRepository.insert(inventory);
+    }
+}

application/src/main/java/org/mandarin/booking/app/show/InventoryWriter.java

@@ -0,0 +1,8 @@
+package org.mandarin.booking.app.show;
+
+import java.util.List;
+import java.util.Map;
+
+public interface InventoryWriter {
+    void createInventory(Long scheduleId, Map<Long, List<Long>> seatAssociations);
+}

application/src/main/java/org/mandarin/booking/app/show/ShowCommandRepository.java

@@ -1,5 +1,6 @@
 package org.mandarin.booking.app.show;
 
+import jakarta.persistence.EntityManager;
 import lombok.RequiredArgsConstructor;
 import org.mandarin.booking.domain.show.Show;
 import org.springframework.stereotype.Repository;
@@ -9,10 +10,13 @@
 @Transactional
 @RequiredArgsConstructor
 class ShowCommandRepository {
-    private final ShowRepository jpaRepository;
+    private final EntityManager entityManager;
 
     Show insert(Show show) {
-        return jpaRepository.save(show);
+        entityManager.persist(show);
+        entityManager.flush();
+        entityManager.refresh(show);
+        return show;
     }
 }