Ki hwan

build.gradle.kts

@@ -43,11 +43,17 @@ dependencies {
     implementation("com.mysql:mysql-connector-j")
     implementation("org.flywaydb:flyway-mysql")
     implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
+    implementation("org.apache.poi:poi:5.2.5")
+    implementation("org.apache.poi:poi-ooxml:5.2.5")
+    implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
+    implementation("org.springframework.boot:spring-boot-starter-webflux")
+    implementation("io.projectreactor.netty:reactor-netty")
     testImplementation("org.springframework.boot:spring-boot-starter-test")
     testImplementation("org.springframework.boot:spring-boot-testcontainers")
     testImplementation("org.testcontainers:junit-jupiter")
     testImplementation("org.testcontainers:mysql")
     testImplementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.8.1")
+    implementation("org.springdoc:springdoc-openapi-starter-webmvc-ui:2.7.0")
 }
 
 kotlin {

src/main/kotlin/com/wafflestudio/spring2025/config/WebClientConfig.kt

@@ -0,0 +1,37 @@
+package com.wafflestudio.spring2025.config
+
+import io.netty.channel.ChannelOption
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.http.client.reactive.ReactorClientHttpConnector
+import org.springframework.web.reactive.function.client.WebClient
+import reactor.netty.http.client.HttpClient
+import java.time.Duration
+
+@Configuration
+class WebClientConfig(
+    @Value("\${sugang.base-url}") private val baseUrl: String,
+    @Value("\${sugang.connect-timeout-ms:5000}") private val connectTimeoutMS: Int,
+    @Value("\${sugang.read-timeout-ms:15000}") private val readTimeoutMS: Int,
+) {
+    @Bean
+    fun sugangWebClient(): WebClient {
+        val httpClient =
+            HttpClient
+                .create()
+                .option(
+                    ChannelOption.CONNECT_TIMEOUT_MILLIS,
+                    connectTimeoutMS,
+                ).responseTimeout(Duration.ofMillis(readTimeoutMS.toLong()))
+        return WebClient
+            .builder()
+            .baseUrl(
+                baseUrl,
+            ).defaultHeader("User-Agent", "Mozilla/5.0")
+            .clientConnector(ReactorClientHttpConnector(httpClient))
+            .codecs { cfg ->
+                cfg.defaultCodecs().maxInMemorySize(16 * 1024 * 1024)
+            }.build()
+    }
+}

src/main/kotlin/com/wafflestudio/spring2025/course/CourseException.kt

@@ -0,0 +1,25 @@
+package com.wafflestudio.spring2025.course
+
+import com.wafflestudio.spring2025.DomainException
+import org.springframework.http.HttpStatus
+import org.springframework.http.HttpStatusCode
+
+open class CourseException(
+    errorCode: Int,
+    httpStatusCode: HttpStatusCode,
+    msg: String,
+) : DomainException(errorCode, httpStatusCode, msg) {
+    class InvalidSemesterException :
+        CourseException(
+            errorCode = 0,
+            httpStatusCode = HttpStatus.BAD_REQUEST,
+            msg = "Invalid semester",
+        )
+
+    class CourseNotFoundException :
+        CourseException(
+            errorCode = 0,
+            httpStatusCode = HttpStatus.NOT_FOUND,
+            msg = "Course not found",
+        )
+}

src/main/kotlin/com/wafflestudio/spring2025/course/controller/CourseController.kt

@@ -0,0 +1,35 @@
+package com.wafflestudio.spring2025.course.controller
+
+import com.wafflestudio.spring2025.course.dto.course.SearchCourseRequest
+import com.wafflestudio.spring2025.course.dto.course.SearchCourseResponse
+import com.wafflestudio.spring2025.course.service.CourseService
+import org.springframework.http.ResponseEntity
+import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RequestParam
+import org.springframework.web.bind.annotation.RestController
+
+@RestController
+@RequestMapping("/api/v1/courses")
+class CourseController(
+    private val courseService: CourseService,
+) {
+    @GetMapping
+    fun search(
+        @RequestParam year: Int,
+        @RequestParam semester: String,
+        @RequestParam(name = "query", required = false) keyword: String?,
+        @RequestParam(name = "size", defaultValue = "20") limit: Int,
+        @RequestParam(name = "cursor", required = false) nextId: Long?,
+    ): ResponseEntity<SearchCourseResponse> {
+        val request =
+            SearchCourseRequest(
+                year = year,
+                semester = semester,
+                keyword = keyword,
+                limit = limit,
+                nextId = nextId,
+            )
+        return ResponseEntity.ok(courseService.search(request))
+    }
+}

src/main/kotlin/com/wafflestudio/spring2025/course/dto/course/CourseDto.kt

@@ -0,0 +1,42 @@
+package com.wafflestudio.spring2025.course.dto.course
+
+import com.wafflestudio.spring2025.course.dto.coursetime.CourseTimeDto
+import com.wafflestudio.spring2025.course.model.Course
+
+data class CourseDto(
+    val id: Long,
+    val year: Int,
+    val semester: String,
+    val courseNumber: String,
+    val classNumber: String,
+    val title: String,
+    val subtitle: String?,
+    val credit: Int?,
+    val professor: String?,
+    val room: String?,
+    val category: String?,
+    val college: String?,
+    val department: String?,
+    val grade: Int?,
+    val procedure: String?,
+    val times: List<CourseTimeDto> = emptyList(),
+) {
+    constructor(c: Course, times: List<CourseTimeDto>) : this(
+        id = c.id!!,
+        year = c.year,
+        semester = c.semester,
+        courseNumber = c.courseNumber,
+        classNumber = c.classNumber,
+        title = c.title,
+        subtitle = c.subtitle,
+        credit = c.credit,
+        professor = c.professor,
+        room = c.room,
+        category = c.category,
+        college = c.college,
+        department = c.department,
+        grade = c.grade,
+        procedure = c.procedure,
+        times = times,
+    )
+}

src/main/kotlin/com/wafflestudio/spring2025/course/dto/course/SearchCourseRequest.kt

@@ -0,0 +1,9 @@
+package com.wafflestudio.spring2025.course.dto.course
+
+data class SearchCourseRequest(
+    val year: Int,
+    val semester: String,
+    val keyword: String? = null,
+    val limit: Int = 20,
+    val nextId: Long? = null,
+)

src/main/kotlin/com/wafflestudio/spring2025/course/dto/course/SearchCourseResponse.kt

@@ -0,0 +1,11 @@
+package com.wafflestudio.spring2025.course.dto.course
+
+data class SearchCourseResponse(
+    val data: List<CourseDto>,
+    val paging: Paging,
+)
+
+data class Paging(
+    val hasNext: Boolean,
+    val nextCursor: Long?,
+)

src/main/kotlin/com/wafflestudio/spring2025/course/dto/coursetime/CourseTimeDto.kt

@@ -0,0 +1,8 @@
+package com.wafflestudio.spring2025.course.dto.coursetime
+
+data class CourseTimeDto(
+    val weekday: Int,
+    val startMin: Int,
+    val endMin: Int,
+    val location: String?,
+)

src/main/kotlin/com/wafflestudio/spring2025/course/extract/controller/CourseExtractController.kt

@@ -0,0 +1,38 @@
+package com.wafflestudio.spring2025.course.extract.controller
+
+import com.wafflestudio.spring2025.course.extract.dto.CourseExtractDto
+import com.wafflestudio.spring2025.course.extract.dto.CourseSyncRequestDto
+import com.wafflestudio.spring2025.course.extract.dto.CourseSyncResultDto
+import com.wafflestudio.spring2025.course.extract.service.CourseExtractService
+import org.springframework.http.ResponseEntity
+import org.springframework.web.bind.annotation.PostMapping
+import org.springframework.web.bind.annotation.RequestBody
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RequestParam
+import org.springframework.web.bind.annotation.RequestPart
+import org.springframework.web.bind.annotation.RestController
+import org.springframework.web.multipart.MultipartFile
+
+@RestController
+@RequestMapping("/course/extract")
+class CourseExtractController(
+    private val courseExtractService: CourseExtractService,
+) {
+    @PostMapping("/put")
+    fun putXlsInDB(
+        @RequestParam year: Int,
+        @RequestParam semester: String,
+        @RequestPart file: MultipartFile,
+    ): ResponseEntity<CourseExtractDto> {
+        val inserted = courseExtractService.readInputXlsAndPutInDB(year, semester, file.inputStream)
+        return ResponseEntity.ok(CourseExtractDto(inserted))
+    }
+
+    @PostMapping("/sync")
+    fun sync(
+        @RequestBody req: CourseSyncRequestDto,
+    ): ResponseEntity<CourseSyncResultDto> {
+        val result = courseExtractService.syncFromSugang(req.year, req.semCode)
+        return ResponseEntity.ok(result)
+    }
+}

src/main/kotlin/com/wafflestudio/spring2025/course/extract/controller/CourseTimeExtractController.kt

@@ -0,0 +1,32 @@
+package com.wafflestudio.spring2025.course.extract.controller
+
+import com.wafflestudio.spring2025.course.extract.dto.CourseTimeExtractDto
+import com.wafflestudio.spring2025.course.extract.service.CourseTimeExtractService
+import org.springframework.http.ResponseEntity
+import org.springframework.web.bind.annotation.PostMapping
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RequestParam
+import org.springframework.web.bind.annotation.RequestPart
+import org.springframework.web.bind.annotation.RestController
+import org.springframework.web.multipart.MultipartFile
+
+@RestController
+@RequestMapping("/course/extract")
+class CourseTimeExtractController(
+    private val courseTimeExtractService: CourseTimeExtractService,
+) {
+    @PostMapping("/times")
+    fun putXlsTimeInDB(
+        @RequestParam year: Int,
+        @RequestParam semester: String,
+        @RequestPart file: MultipartFile,
+    ): ResponseEntity<CourseTimeExtractDto> {
+        val inserted =
+            courseTimeExtractService.importTimesFromXls(
+                year = year,
+                semester = semester,
+                inputStream = file.inputStream,
+            )
+        return ResponseEntity.ok(CourseTimeExtractDto(inserted))
+    }
+}

src/main/kotlin/com/wafflestudio/spring2025/course/extract/dto/CourseExtractDto.kt

@@ -0,0 +1,5 @@
+package com.wafflestudio.spring2025.course.extract.dto
+
+data class CourseExtractDto(
+    val inserted: Int, // number of inserted on DB
+)

src/main/kotlin/com/wafflestudio/spring2025/course/extract/dto/CourseSyncRequestDto.kt

@@ -0,0 +1,6 @@
+package com.wafflestudio.spring2025.course.extract.dto
+
+data class CourseSyncRequestDto(
+    val year: Int,
+    val semCode: String,
+)

src/main/kotlin/com/wafflestudio/spring2025/course/extract/dto/CourseSyncResultDto.kt

@@ -0,0 +1,9 @@
+package com.wafflestudio.spring2025.course.extract.dto
+
+data class CourseSyncResultDto(
+    val year: Int,
+    val semester: String,
+    val fetchedBytes: Int,
+    val insertedCourses: Int,
+    val insertedCourseTimes: Int,
+)

src/main/kotlin/com/wafflestudio/spring2025/course/extract/dto/CourseTimeExtractDto.kt

@@ -0,0 +1,5 @@
+package com.wafflestudio.spring2025.course.extract.dto
+
+class CourseTimeExtractDto(
+    val inserted: Int,
+)

src/main/kotlin/com/wafflestudio/spring2025/course/extract/repository/CourseExtractRepository.kt

@@ -0,0 +1,13 @@
+package com.wafflestudio.spring2025.course.extract.repository
+
+import com.wafflestudio.spring2025.course.model.Course
+import org.springframework.data.repository.CrudRepository
+
+interface CourseExtractRepository : CrudRepository<Course, Long> {
+    fun findByYearAndSemesterAndCourseNumberAndClassNumber(
+        year: Int,
+        semester: String,
+        courseNumber: String,
+        classNumber: String,
+    ): Course?
+}

src/main/kotlin/com/wafflestudio/spring2025/course/extract/repository/CourseTimeExtractRepository.kt

@@ -0,0 +1,8 @@
+package com.wafflestudio.spring2025.course.extract.repository
+
+import com.wafflestudio.spring2025.course.model.CourseTime
+import org.springframework.data.repository.CrudRepository
+
+interface CourseTimeExtractRepository : CrudRepository<CourseTime, Long> {
+    fun deleteByCourseId(courseId: Long): Long
+}