CQRS Pattern

// Command: Rõ ràng, mang đậm ngôn ngữ nghiệp vụ (Ubiquitous Language)
public record ReserveSeatsCommand(
    UUID showtimeId,
    UUID userId,
    List<String> seatCodes
) {}
 
// Command Handler: Chỉ chứa logic xử lý thay đổi trạng thái
@Component
@RequiredArgsConstructor
public class ReserveSeatsCommandHandler {
    private final ShowtimeRepository writeRepository;
    private final ApplicationEventPublisher eventPublisher;
 
    @Transactional
    public ReservationResult handle(ReserveSeatsCommand cmd) {
        Showtime showtime = writeRepository.findByIdWithLock(cmd.showtimeId())
            .orElseThrow(() -> new ShowtimeNotFoundException(cmd.showtimeId()));
 
        // Domain logic: Giữ ghế và ném lỗi nếu ghế đã bị người khác đặt
        Reservation reservation = showtime.reserveSeats(cmd.userId(), cmd.seatCodes());
        writeRepository.save(showtime);
 
        // Publish Event để Read-side cập nhật lại sơ đồ ghế
        eventPublisher.publishEvent(new SeatsReservedEvent(
            cmd.showtimeId(), cmd.seatCodes()
        ));
 
        return new ReservationResult(reservation.getId(), reservation.getExpiresAt());
    }
}

public record GetAvailableSeatsQuery(UUID showtimeId) {}
 
@Component
@RequiredArgsConstructor
public class GetAvailableSeatsQueryHandler {
    private final SeatMapProjectionRepository readRepository;
 
    @Cacheable(value = "seat-maps", key = "#query.showtimeId()")
    public SeatMapDTO handle(GetAvailableSeatsQuery query) {
        // Truy vấn thẳng vào MongoDB - Dữ liệu đã được denormalize, không cần JOIN
        return readRepository.findByShowtimeId(query.showtimeId())
            .orElseThrow(() -> new SeatMapNotFoundException(query.showtimeId()));
    }
}

@Saga
@Slf4j
public class TicketBookingSaga {
 
    @Autowired
    private transient CommandGateway commandGateway;
 
    // Bắt đầu quy trình khi ghế được giữ thành công
    @StartSaga
    @SagaEventHandler(associationProperty = "reservationId")
    public void on(SeatsReservedEvent event) {
        log.info("Ghế đã giữ, yêu cầu thanh toán cho Reservation: {}", event.reservationId());
        commandGateway.send(new CreatePaymentCommand(
            event.reservationId(), event.totalAmount()
        ));
    }
 
    // Xử lý khi thanh toán thành công
    @SagaEventHandler(associationProperty = "reservationId")
    public void on(PaymentCompletedEvent event) {
        log.info("Thanh toán thành công, tiến hành xuất vé");
        commandGateway.send(new IssueTicketCommand(event.reservationId()));
    }
 
    // Xử lý thất bại (Compensating Transaction)
    @SagaEventHandler(associationProperty = "reservationId")
    public void on(PaymentFailedEvent event) {
        log.warn("Thanh toán thất bại, nhả ghế đang giữ");
        commandGateway.send(new ReleaseSeatsCommand(event.reservationId()));
    }
 
    // Kết thúc Saga khi vé đã xuất
    @EndSaga
    @SagaEventHandler(associationProperty = "reservationId")
    public void on(TicketIssuedEvent event) {
        log.info("Quy trình đặt vé hoàn tất: {}", event.ticketId());
    }
}

public interface PricingStrategy {
    boolean isApplicable(BookingContext context);
    BigDecimal calculate(BigDecimal basePrice, BookingContext context);
}
 
@Component
public class WeekendPricingStrategy implements PricingStrategy { /*...+20%...*/ }
 
@Component
public class StudentPricingStrategy implements PricingStrategy { /*...-15%...*/ }
 
// Trong BookingService
private final List<PricingStrategy> pricingStrategies; // Spring tự inject tất cả các bean implement interface này
 
public BigDecimal calculateFinalPrice(BigDecimal basePrice, BookingContext context) {
    return pricingStrategies.stream()
        .filter(strategy -> strategy.isApplicable(context))
        .findFirst()
        .map(strategy -> strategy.calculate(basePrice, context))
        .orElse(basePrice);
}

@Transactional
public void reserveAndPublish(ReserveSeatsCommand cmd) {
    // 1. Cập nhật state vào nghiệp vụ
    showtimeRepository.save(showtime);
 
    // 2. Lưu event vào bảng Outbox cùng Transaction
    OutboxEvent event = OutboxEvent.builder()
        .aggregateId(showtime.getId())
        .eventType("SEAT_RESERVED")
        .payload(objectMapper.writeValueAsString(cmd))
        .build();
    outboxRepository.save(event);
}
// Poller background sẽ đọc outboxRepository và push vào Kafka cluster, đảm bảo At-Least-Once Delivery.

@Document(collection = "showtime_seat_maps")
public class ShowtimeSeatMapProjection {
    @Id
    private UUID showtimeId;
    private String movieName;
    private List<SeatInfo> availableSeats;
    private List<SeatInfo> reservedSeats;
    // Dữ liệu đã được "nấu" sẵn, query API chỉ cần bốc ra trả về JSON dưới 10ms.
}