[FEAT] 지하철 시간표 관련 코드 구현

server/src/main/java/com/talkka/server/subway/controller/SubwayTimetableController.java

@@ -0,0 +1,68 @@
+package com.talkka.server.subway.controller;
+
+import java.time.format.DateTimeParseException;
+
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.talkka.server.common.exception.InvalidTypeException;
+import com.talkka.server.subway.exception.StationNotFoundException;
+import com.talkka.server.subway.exception.TimetableNotFoundException;
+import com.talkka.server.subway.service.SubwayTimetableService;
+
+import lombok.RequiredArgsConstructor;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/api/subway/timetable")
+public class SubwayTimetableController {
+
+	private final SubwayTimetableService timetableService;
+
+	@GetMapping("/{stationId}")
+	public ResponseEntity<?> getTimetable(
+		@PathVariable Long stationId,
+		@RequestParam String dayTypeCode,
+		@RequestParam String updownCode,
+		@RequestParam String time
+	) {
+		ResponseEntity<?> response;
+		try {
+			response = ResponseEntity.ok(
+				timetableService.getTimetable(stationId, dayTypeCode, updownCode, time));
+		} catch (DateTimeParseException exception) {
+			response = ResponseEntity.badRequest().body("해당 시간 형식은 올바르지 않습니다.");
+		} catch (StationNotFoundException | InvalidTypeException exception) {
+			response = ResponseEntity.badRequest().body(exception.getMessage());
+		} catch (TimetableNotFoundException exception) {
+			response = ResponseEntity.status(HttpStatus.NOT_FOUND).body(exception.getMessage());
+		}
+		return response;
+	}
+
+	// 첫차 = 5:00:00, 막차 = 0:30:30 기준으로 널널하게 잡음
+	@GetMapping("/{stationId}/list")
+	public ResponseEntity<?> getTimetableList(
+		@PathVariable Long stationId,
+		@RequestParam String dayTypeCode,
+		@RequestParam String updownCode,
+		@RequestParam(required = false, defaultValue = "4:00:00") String startTime,
+		@RequestParam(required = false, defaultValue = "1:00:00") String endTime
+	) {
+		ResponseEntity<?> response;
+		try {
+			response = ResponseEntity.ok(
+				timetableService.getTimetableList(stationId, dayTypeCode, updownCode, startTime, endTime));
+		} catch (DateTimeParseException exception) {
+			response = ResponseEntity.badRequest().body("해당 시간 형식은 올바르지 않습니다.");
+		} catch (StationNotFoundException | InvalidTypeException exception) {
+			response = ResponseEntity.badRequest().body(exception.getMessage());
+		}
+		return response;
+	}
+}

server/src/main/java/com/talkka/server/subway/dao/SubwayTimetableRepository.java

@@ -1,8 +1,23 @@
 package com.talkka.server.subway.dao;
 
-import org.hibernate.type.descriptor.converter.spi.JpaAttributeConverter;
+import java.time.LocalTime;
+import java.util.List;
+import java.util.Optional;
+
+import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 
+import com.talkka.server.subway.enums.DayType;
+import com.talkka.server.subway.enums.Updown;
+
 @Repository
-public interface SubwayTimetableRepository extends JpaAttributeConverter<SubwayTimetableEntity, Long> {
+public interface SubwayTimetableRepository extends JpaRepository<SubwayTimetableEntity, Long> {
+
+	Optional<SubwayTimetableEntity> findBySubwayStationIdAndDayTypeAndUpdownAndArrivalTime(
+		Long stationId, DayType dayType, Updown updown, LocalTime time
+	);
+
+	List<SubwayTimetableEntity> findBySubwayStationIdAndDayTypeAndUpdownAndArrivalTimeBetween(
+		Long stationId, DayType dayType, Updown updown, LocalTime startTime, LocalTime endTime
+	);
 }

server/src/main/java/com/talkka/server/subway/dto/SubwayTimetableRespDto.java

@@ -0,0 +1,37 @@
+package com.talkka.server.subway.dto;
+
+import java.time.LocalTime;
+
+import com.talkka.server.subway.dao.SubwayTimetableEntity;
+import com.talkka.server.subway.enums.DayType;
+import com.talkka.server.subway.enums.Express;
+import com.talkka.server.subway.enums.Line;
+import com.talkka.server.subway.enums.Updown;
+
+import lombok.Builder;
+
+@Builder
+public record SubwayTimetableRespDto(
+	Long stationId,
+	String stationName,
+	Line line,
+	DayType dayType,
+	Updown updown,
+	Express express,
+	LocalTime arrivalTime,
+	String startStationName,
+	String endStationName
+) {
+	public static SubwayTimetableRespDto of(SubwayTimetableEntity subwayTimetableEntity) {
+		return new SubwayTimetableRespDto(
+			subwayTimetableEntity.getSubwayStation().getId(),
+			subwayTimetableEntity.getStationName(),
+			subwayTimetableEntity.getLine(),
+			subwayTimetableEntity.getDayType(),
+			subwayTimetableEntity.getUpdown(),
+			subwayTimetableEntity.getExpress(),
+			subwayTimetableEntity.getArrivalTime(),
+			subwayTimetableEntity.getStartStationName(),
+			subwayTimetableEntity.getEndStationName());
+	}
+}

server/src/main/java/com/talkka/server/subway/exception/TimetableNotFoundException.java

@@ -0,0 +1,9 @@
+package com.talkka.server.subway.exception;
+
+public class TimetableNotFoundException extends RuntimeException {
+	private static final String MESSAGE = "조회 가능한 시간표 정보가 없습니다.";
+
+	public TimetableNotFoundException() {
+		super(MESSAGE);
+	}
+}

server/src/main/java/com/talkka/server/subway/service/SubwayTimetableService.java

@@ -0,0 +1,67 @@
+package com.talkka.server.subway.service;
+
+import java.time.LocalTime;
+import java.time.format.DateTimeFormatter;
+import java.time.format.DateTimeParseException;
+import java.util.List;
+
+import org.springframework.stereotype.Service;
+
+import com.talkka.server.common.exception.InvalidTypeException;
+import com.talkka.server.subway.dao.SubwayStationRepository;
+import com.talkka.server.subway.dao.SubwayTimetableEntity;
+import com.talkka.server.subway.dao.SubwayTimetableRepository;
+import com.talkka.server.subway.dto.SubwayTimetableRespDto;
+import com.talkka.server.subway.enums.DayType;
+import com.talkka.server.subway.enums.Updown;
+import com.talkka.server.subway.exception.StationNotFoundException;
+import com.talkka.server.subway.exception.TimetableNotFoundException;
+
+import lombok.RequiredArgsConstructor;
+
+@Service
+@RequiredArgsConstructor
+public class SubwayTimetableService {
+
+	private final SubwayTimetableRepository timetableRepository;
+	private final SubwayStationRepository stationRepository;
+
+	public SubwayTimetableRespDto getTimetable(
+		Long stationId, String dayTypeCode, String updownCode, String time
+	) throws DateTimeParseException, StationNotFoundException, TimetableNotFoundException, InvalidTypeException {
+		DateTimeFormatter formatter = DateTimeFormatter.ofPattern("H:mm:ss");
+		LocalTime parseTime = LocalTime.parse(time, formatter);
+
+		isExisted(stationId);
+
+		SubwayTimetableEntity entity = timetableRepository.findBySubwayStationIdAndDayTypeAndUpdownAndArrivalTime(
+			stationId, DayType.valueOfEnumString(dayTypeCode), Updown.valueOfEnumString(updownCode), parseTime
+		).orElseThrow(TimetableNotFoundException::new);
+
+		return SubwayTimetableRespDto.of(entity);
+	}
+
+	public List<SubwayTimetableRespDto> getTimetableList(
+		Long stationId, String dayTypeCode, String updownCode, String startTime, String endTime
+	) throws DateTimeParseException, StationNotFoundException, InvalidTypeException {
+		DateTimeFormatter formatter = DateTimeFormatter.ofPattern("H:mm:ss");
+		LocalTime start = LocalTime.parse(startTime, formatter);
+		LocalTime end = LocalTime.parse(endTime, formatter);
+
+		isExisted(stationId);
+
+		List<SubwayTimetableEntity> entityList = timetableRepository.findBySubwayStationIdAndDayTypeAndUpdownAndArrivalTimeBetween(
+			stationId, DayType.valueOfEnumString(dayTypeCode), Updown.valueOfEnumString(updownCode), start, end
+		);
+
+		return entityList.stream()
+			.map(SubwayTimetableRespDto::of)
+			.toList();
+	}
+
+	private void isExisted(Long stationId) {
+		if (!stationRepository.existsById(stationId)) {
+			throw new StationNotFoundException(stationId);
+		}
+	}
+}