Juster format på CSV til å matche uttrekk

Author: naviktthomas

jobs/arbeidssoekere-synk-jobb/src/main/kotlin/no/nav/paw/arbeidssoeker/synk/model/Arbeidssoeker.kt

@@ -4,7 +4,7 @@ import java.time.Instant
 
 data class ArbeidssoekerFileRow(
     val identitetsnummer: String,
-    val tidspunktFraKilde: Instant? = null
+    val tidspunktFraKilde: String? = null
 )
 
 data class ArbeidssoekerDatabaseRow(

jobs/arbeidssoekere-synk-jobb/src/main/kotlin/no/nav/paw/arbeidssoeker/synk/model/Converters.kt

@@ -5,6 +5,13 @@ import io.ktor.http.isSuccess
 import org.jetbrains.exposed.sql.ResultRow
 import java.time.Duration
 import java.time.Instant
+import java.time.LocalDateTime
+import java.time.ZoneId
+import java.time.format.DateTimeFormatter
+
+private const val DATETIME_FORMAT = "dd.MM.yyyy HH:mm:ss"
+private val OSLO_ZONE_ID: ZoneId = ZoneId.of("Europe/Oslo")
+private val dateTimeFormatter = DateTimeFormatter.ofPattern(DATETIME_FORMAT)
 
 fun ArbeidssoekerFileRow.asArbeidssoeker(
     version: String,
@@ -14,7 +21,9 @@ fun ArbeidssoekerFileRow.asArbeidssoeker(
     version = version,
     identitetsnummer = identitetsnummer,
     periodeTilstand = periodeTilstand,
-    tidspunktFraKilde = tidspunktFraKilde,
+    tidspunktFraKilde = tidspunktFraKilde?.ifBlank { null }?.let {
+        LocalDateTime.parse(it, dateTimeFormatter).atZone(OSLO_ZONE_ID).toInstant()
+    },
     forhaandsgodkjentAvAnsatt = forhaandsgodkjentAvAnsatt
 )
 

jobs/arbeidssoekere-synk-jobb/src/main/kotlin/no/nav/paw/arbeidssoeker/synk/service/ArbeidssoekerSynkService.kt

@@ -35,12 +35,12 @@ class ArbeidssoekerSynkService(
                 if (totalCount % 100 == 0) {
                     logger.info("Prosessert {} linjer CSV-data på {} ms", totalCount, timestamp.millisSince())
                 }
-                val arbeidssoeker = fileRows.nextValue()
-                    .asArbeidssoeker(
-                        version = version,
-                        periodeTilstand = defaultVerdier.periodeTilstand,
-                        forhaandsgodkjentAvAnsatt = defaultVerdier.forhaandsgodkjentAvAnsatt
-                    )
+                val fileRow = fileRows.nextValue()
+                val arbeidssoeker = fileRow.asArbeidssoeker(
+                    version = version,
+                    periodeTilstand = defaultVerdier.periodeTilstand,
+                    forhaandsgodkjentAvAnsatt = defaultVerdier.forhaandsgodkjentAvAnsatt
+                )
                 prosesserArbeidssoeker(arbeidssoeker)
             }
             logger.info(

jobs/arbeidssoekere-synk-jobb/src/main/kotlin/no/nav/paw/arbeidssoeker/synk/utils/CsvReader.kt

@@ -16,8 +16,10 @@ private val csvMapper: ObjectMapper = CsvMapper()
     .registerModule(JavaTimeModule())
 private val csvSchema: CsvSchema = CsvSchema.builder()
     .setAllowComments(true)
-    .setColumnSeparator(',')
-    .setUseHeader(true)
+    .setColumnSeparator(';')
+    .setUseHeader(false)
+    .addColumn("identitetsnummer", CsvSchema.ColumnType.STRING)
+    .addColumn("tidspunktFraKilde", CsvSchema.ColumnType.STRING)
     .build()
 
 sealed class CsvReader<T>(val objectReader: ObjectReader) {

jobs/arbeidssoekere-synk-jobb/src/test/resources/v1.csv

@@ -1,11 +1,10 @@
-identitetsnummer,tidspunktFraKilde
-01017012345,
-02017012345,1970-01-02T12:00:00.000Z
-03017012345,1970-01-03T12:00:00.000Z
-04017012345,
-05017012345,
-06017012345,1970-01-06T12:00:00.000Z
-07017012345,1970-01-07T12:00:00.000Z
-08017012345,
-09017012345,1970-01-09T12:00:00.000Z
-10017012345,
+01017012345;
+02017012345;02.01.1970 12:00:00
+03017012345;03.01.1970 12:00:00
+04017012345;
+05017012345;
+06017012345;06.01.1970 12:00:00
+07017012345;07.01.1970 12:00:00
+08017012345;
+09017012345;09.01.1970 12:00:00
+10017012345;