Edited At 이후 일자만 색인

src/main/kotlin/com/retrip/map/application/out/repository/LocationElasticRepository.kt

@@ -7,5 +7,5 @@ import java.util.UUID
 
 @Repository
 interface LocationElasticRepository: ElasticsearchRepository<LocationDocument, UUID> {
-
+    fun findFirstByOrderByEditedAtDesc(): LocationDocument?
 }

src/main/kotlin/com/retrip/map/application/out/repository/LocationQueryRepository.kt

@@ -5,9 +5,10 @@ import com.retrip.map.domain.entity.Location
 import org.springframework.data.domain.Page
 import org.springframework.data.domain.Pageable
 import java.time.LocalDate
+import java.time.LocalDateTime
 import java.util.UUID
 
 interface LocationQueryRepository {
     fun findLocations(id: UUID?, page: Pageable): Page<LocationResponse>
-    fun findLocationsByEditedAt( editedAt: LocalDate): List<Location>
+    fun findLocationsByEditedAt( editedAt: LocalDateTime): List<Location>
 }

src/main/kotlin/com/retrip/map/infra/adapter/in/batch/MapReader.kt

@@ -1,18 +1,21 @@
 package com.retrip.map.infra.adapter.`in`.batch
 
+import co.elastic.clients.elasticsearch.ElasticsearchClient
+import com.retrip.map.application.out.repository.LocationElasticRepository
 import com.retrip.map.application.out.repository.LocationQueryRepository
 import com.retrip.map.domain.entity.Location
 import org.springframework.batch.item.ItemReader
 import org.springframework.stereotype.Component
 import java.time.LocalDate
+import java.time.LocalDateTime
 
 @Component
 class MapReader(
-    val locationQueryRepository: LocationQueryRepository
-
+    private val locationQueryRepository: LocationQueryRepository,
+    private val locationElasticRepository: LocationElasticRepository
 ): ItemReader<List<Location>> {
     override fun read(): List<Location>? {
-        println("TEST")
-        return locationQueryRepository.findLocationsByEditedAt(LocalDate.now())
+        val lastUpdateDocument = locationElasticRepository.findFirstByOrderByEditedAtDesc()
+        return locationQueryRepository.findLocationsByEditedAt(lastUpdateDocument?.editedAt ?: LocalDateTime.now())
     }
 }

src/main/kotlin/com/retrip/map/infra/adapter/out/persistence/mysql/query/LocationQuerydslRepository.kt

@@ -12,6 +12,7 @@ import org.springframework.data.domain.PageImpl
 import org.springframework.data.domain.Pageable
 import org.springframework.stereotype.Repository
 import java.time.LocalDate
+import java.time.LocalDateTime
 import java.util.*
 
 
@@ -51,13 +52,10 @@ class LocationQuerydslRepository(
         return PageImpl(locations, page, count ?: 0)
     }
 
-    override fun findLocationsByEditedAt(editedAt: LocalDate): List<Location> {
-        val startOfDay = editedAt.atStartOfDay()
-        val endOfDay = editedAt.plusDays(1).atStartOfDay()
+    override fun findLocationsByEditedAt(editedAt: LocalDateTime): List<Location> {
         return query.selectFrom(location)
             .where(
-                location.editedAt.goe(startOfDay),
-                location.createdAt.lt(endOfDay)
+                location.editedAt.gt(editedAt)
             ).fetch()
     }
 

src/main/kotlin/com/retrip/map/infra/adapter/out/search/elasticsearch/entity/LocationDocument.kt

@@ -7,6 +7,7 @@ import jakarta.persistence.Id
 import org.springframework.data.elasticsearch.annotations.Document
 import org.springframework.data.elasticsearch.annotations.Field
 import org.springframework.data.elasticsearch.annotations.FieldType
+import java.time.LocalDateTime
 import java.util.*
 
 @Document(indexName = "locations")
@@ -28,7 +29,11 @@ data class LocationDocument(
     @Field(type = FieldType.Double)
     val latitude: Double?,
     @Field(type = FieldType.Double)
-    val longitude: Double?
+    val longitude: Double?,
+    @Field(type = FieldType.Date)
+    val createdAt: LocalDateTime?,
+    @Field(type = FieldType.Date)
+    val editedAt: LocalDateTime?,
 ) {
     companion object {
         fun of(location: Location): LocationDocument {
@@ -42,6 +47,8 @@ data class LocationDocument(
                 location.address?.roadAddress,
                 location.geoPoint?.latitude,
                 location.geoPoint?.longitude,
+                location.createdAt,
+                location.editedAt
             )
         }
     }