학급 open api batch로 가져오기

build.gradle.kts

@@ -41,18 +41,15 @@ dependencies {
     implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
     implementation("org.jetbrains.kotlin:kotlin-reflect")
 
-    implementation("org.springframework.boot:spring-boot-starter-web")
-
     // spring test
     testImplementation("org.springframework.boot:spring-boot-starter-test")
     testFixturesImplementation("org.springframework.boot:spring-boot-starter-test")
 
     // jpa
     implementation("org.springframework.boot:spring-boot-starter-data-jpa")
-    runtimeOnly("com.mysql:mysql-connector-j")
 
-    // mongodb
-    implementation("org.springframework.boot:spring-boot-starter-data-mongodb")
+    //mysql
+    runtimeOnly("com.mysql:mysql-connector-j")
 
     // security
     implementation("org.springframework.boot:spring-boot-starter-security")
@@ -77,20 +74,17 @@ dependencies {
     // caffeine
     implementation("com.github.ben-manes.caffeine:caffeine:3.1.8")
 
-
     // RestDocs
     testImplementation("org.springframework.restdocs:spring-restdocs-mockmvc")
     asciidoctorExt("org.springframework.restdocs:spring-restdocs-asciidoctor")
     testFixturesImplementation("org.springframework.restdocs:spring-restdocs-mockmvc")
 
     // webclient
     implementation("org.springframework.boot:spring-boot-starter-webflux")
+
     //JSON
     implementation("org.json:json:20231013")
 
-    //Gson
-    implementation("com.google.code.gson:gson:2.8.9")
-
     // logger
     implementation("io.github.oshai:kotlin-logging-jvm:5.1.0")
 

src/main/kotlin/com/asap/asapbackend/batch/classroom/ClassroomInfoProvider.kt

@@ -0,0 +1,31 @@
+package com.asap.asapbackend.batch.classroom
+
+import com.asap.asapbackend.domain.classroom.domain.model.Classroom
+import com.asap.asapbackend.domain.school.domain.model.School
+
+interface ClassroomInfoProvider {
+    fun retrieveClassroomInfo(batchSize: Int, pageNumber: Int): ClassroomDataContainer
+
+    data class ClassroomDataContainer(
+        val classroomInfo: List<ClassroomInfo>,
+        val hasNext: Boolean
+    )
+
+    data class ClassroomInfo(
+        val school: School,
+        val grade: Int,
+        val classNumber: String
+    ) {
+        fun toClassroom(): Classroom {
+            return Classroom(
+                school = school,
+                grade = grade,
+                className = classNumber
+            )
+        }
+    }
+}
+
+fun List<ClassroomInfoProvider.ClassroomInfo>.toClassrooms(): List<Classroom> {
+    return this.map { it.toClassroom() }
+}

src/main/kotlin/com/asap/asapbackend/batch/classroom/ClassroomScheduler.kt

@@ -1,16 +1,27 @@
 package com.asap.asapbackend.batch.classroom
 
+import com.asap.asapbackend.domain.classroom.domain.service.ClassroomAppender
+import com.asap.asapbackend.global.util.TransactionUtils
 import org.springframework.scheduling.annotation.Scheduled
-import org.springframework.web.bind.annotation.GetMapping
-import org.springframework.web.bind.annotation.RestController
+import org.springframework.stereotype.Component
 
-@RestController
+@Component
 class ClassroomScheduler(
-        private val classroomService: ClassroomService
+    private val classroomInfoProvider: ClassroomInfoProvider,
+    private val classroomAppender: ClassroomAppender
 ) {
-    @Scheduled(cron = "0 0 4 1 3 ?") // 매년 3월 1일 04:00:00에 실행
-    @GetMapping("/addClassroom")
-    fun addClassroom(){
-        classroomService.addClassroom()
+    @Scheduled(cron = "0 5 4 1 3 ?") // 매년 3월 1일 04:05:00에 실행
+    fun addClassroom() {
+        val batchSize = 100
+        var pageNumber = 0
+        do {
+            val classroomDataContainer = classroomInfoProvider.retrieveClassroomInfo(batchSize, pageNumber)
+
+            pageNumber++
+
+            TransactionUtils.writable {
+                classroomAppender.addClassroom(classroomDataContainer.classroomInfo.toClassrooms())
+            }
+        } while (classroomDataContainer.hasNext)
     }
 }

src/main/kotlin/com/asap/asapbackend/batch/school/SchoolInfoProvider.kt

@@ -1,6 +1,5 @@
 package com.asap.asapbackend.batch.school
 
-import com.asap.asapbackend.client.openapi.school.dto.SchoolInfo
 import com.asap.asapbackend.domain.school.domain.model.School
 
 interface SchoolInfoProvider {
@@ -16,8 +15,8 @@ interface SchoolInfoProvider {
         val eduOfficeCode: String, //ATPT_OFCDC_SC_CODE
         val schoolCode: String, //SD_SCHUL_CODE
         val school: String, //SCHUL_NM
-        val address:String //ORG_RDNMA
-    ){
+        val address: String //ORG_RDNMA
+    ) {
         fun toSchool(): School {
             return School(
                 eduOfficeCode = eduOfficeCode,

src/main/kotlin/com/asap/asapbackend/batch/school/SchoolScheduler.kt

@@ -2,23 +2,18 @@ package com.asap.asapbackend.batch.school
 
 import com.asap.asapbackend.domain.school.domain.service.SchoolAppender
 import com.asap.asapbackend.global.util.TransactionUtils
-import io.github.oshai.kotlinlogging.KotlinLogging
 import org.springframework.scheduling.annotation.Scheduled
 import org.springframework.stereotype.Component
 
-private val logger = KotlinLogging.logger {}
-
 @Component
 class SchoolScheduler(
     private val schoolInfoProvider: SchoolInfoProvider,
     private val schoolAppender: SchoolAppender
 ) {
     @Scheduled(cron = "0 0 4 1 3 ?") // 매년 3월 1일 04:00:00에 실행
-//    @Scheduled(fixedRate = 500000) // 500초마다 실행
     fun addSchool() {
         val batchSize = 100
         var startIndex = 1
-        logger.info { "start scheduler" }
         do {
             val schoolDataContainer = schoolInfoProvider.retrieveSchoolInfo(batchSize, startIndex)
 
@@ -27,6 +22,6 @@ class SchoolScheduler(
             TransactionUtils.writable {
                 schoolAppender.appendUniqueSchool(schoolDataContainer.schoolInfo.toSchools())
             }
-        }while (schoolDataContainer.hasNext)
+        } while (schoolDataContainer.hasNext)
     }
 }