Kjør jobb for å migrere digitale behovsmeldinger til V2

olesls · olesls · commit 20e121e23f27 · 2025-07-24T11:54:35.000+02:00
diff --git a/.github/workflows/deploy-dev.yaml b/.github/workflows/deploy-dev.yaml
@@ -9,7 +9,7 @@ on:
       - "CODEOWNERS"
     branches:
       - main
-      - sunset-v1
+      - endepunkt-migrering-v2
 
 jobs:
   build:
diff --git a/app/src/main/kotlin/no/nav/hjelpemidler/soknad/db/Application.kt b/app/src/main/kotlin/no/nav/hjelpemidler/soknad/db/Application.kt
@@ -1,5 +1,6 @@
 package no.nav.hjelpemidler.soknad.db
 
+import io.github.oshai.kotlinlogging.KotlinLogging
 import io.ktor.http.ContentType
 import io.ktor.serialization.jackson.JacksonConverter
 import io.ktor.server.application.Application
@@ -16,6 +17,10 @@ import io.ktor.server.request.path
 import io.ktor.server.resources.Resources
 import io.ktor.server.routing.route
 import io.ktor.server.routing.routing
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.runBlocking
 import no.nav.hjelpemidler.configuration.Environment
 import no.nav.hjelpemidler.database.PostgreSQL
 import no.nav.hjelpemidler.database.createDataSource
@@ -30,6 +35,11 @@ import no.nav.tms.token.support.azure.validation.azure
 import no.nav.tms.token.support.tokenx.validation.TokenXAuthenticator
 import no.nav.tms.token.support.tokenx.validation.tokenX
 import org.slf4j.event.Level
+import java.util.Timer
+import kotlin.concurrent.schedule
+import kotlin.system.measureTimeMillis
+
+private val logg = KotlinLogging.logger { }
 
 fun main() {
     embeddedServer(Netty, Configuration.PORT, module = Application::module).start(wait = true)
@@ -80,6 +90,8 @@ fun Application.module() {
             }
         }
     }
+
+    startDataMigrering(database, serviceContext)
 }
 
 fun Application.felles() {
@@ -93,3 +105,24 @@ fun Application.felles() {
     }
     feilmelding()
 }
+
+private fun startDataMigrering(database: Database, serviceContext: ServiceContext) {
+    val timer = Timer("data-migrering-task", true)
+
+    timer.schedule(delay = 10_000) {
+        runBlocking(Dispatchers.IO) {
+            launch {
+                var antallMigrert = 1
+                while (antallMigrert > 0) {
+                    logg.info { "Kjører datamigreringsbatch." }
+                    val tidsbrukMs = measureTimeMillis {
+                        antallMigrert = serviceContext.søknadService.migrerTilDataV2()
+                    }
+                    logg.info { "Antall migrert: $antallMigrert (${tidsbrukMs}ms)" }
+                    delay(1_000)
+                }
+                logg.info { "Datamigrering ferdig." }
+            }
+        }
+    }
+}
diff --git a/app/src/main/kotlin/no/nav/hjelpemidler/soknad/db/soknad/SøknadApi.kt b/app/src/main/kotlin/no/nav/hjelpemidler/soknad/db/soknad/SøknadApi.kt
@@ -34,6 +34,7 @@ fun Route.søknadApi(
 
     get<Søknader.SøknadId> {
         val søknadId = it.søknadId
+        logg.info { "Kall til Søknader.SøknadId oppdaget." }
         val søknad = transaction { søknadStore.finnSøknad(søknadId, it.inkluderData) }
         if (søknad == null) {
             logg.info { "Fant ikke søknad med søknadId: $søknadId" }
diff --git a/app/src/main/kotlin/no/nav/hjelpemidler/soknad/db/soknad/SøknadService.kt b/app/src/main/kotlin/no/nav/hjelpemidler/soknad/db/soknad/SøknadService.kt
@@ -47,6 +47,17 @@ class SøknadService(private val transaction: Transaction) {
         }
     }
 
+    suspend fun migrerTilDataV2(): Int {
+        return transaction {
+            try {
+                søknadStore.migrerDataTilV2()
+            } catch (e: Exception) {
+                logg.error(e) { "Migrering til data_v2 feilet." }
+                0
+            }
+        }
+    }
+
     suspend fun finnSak(søknadId: BehovsmeldingId): Fagsak? {
         return transaction {
             hotsakStore.finnSak(søknadId) ?: infotrygdStore.finnSak(søknadId)
diff --git a/app/src/main/kotlin/no/nav/hjelpemidler/soknad/db/store/SøknadStore.kt b/app/src/main/kotlin/no/nav/hjelpemidler/soknad/db/store/SøknadStore.kt
@@ -1,15 +1,19 @@
 package no.nav.hjelpemidler.soknad.db.store
 
 import com.fasterxml.jackson.databind.JsonNode
+import com.fasterxml.jackson.module.kotlin.convertValue
 import io.github.oshai.kotlinlogging.KotlinLogging
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.runBlocking
 import no.nav.hjelpemidler.behovsmeldingsmodell.BehovsmeldingStatus
+import no.nav.hjelpemidler.behovsmeldingsmodell.BehovsmeldingType
 import no.nav.hjelpemidler.behovsmeldingsmodell.Behovsmeldingsgrunnlag
 import no.nav.hjelpemidler.behovsmeldingsmodell.InnsenderbehovsmeldingMetadataDto
 import no.nav.hjelpemidler.behovsmeldingsmodell.SøknadDto
 import no.nav.hjelpemidler.behovsmeldingsmodell.v1.Behovsmelding
+import no.nav.hjelpemidler.behovsmeldingsmodell.v1.Brukerpassbytte
 import no.nav.hjelpemidler.behovsmeldingsmodell.v2.Innsenderbehovsmelding
+import no.nav.hjelpemidler.behovsmeldingsmodell.v2.mapping.tilBrukerpassbytteV2
 import no.nav.hjelpemidler.behovsmeldingsmodell.v2.mapping.tilInnsenderbehovsmeldingV2
 import no.nav.hjelpemidler.collections.enumSetOf
 import no.nav.hjelpemidler.collections.toStringArray
@@ -19,6 +23,7 @@ import no.nav.hjelpemidler.database.Row
 import no.nav.hjelpemidler.database.Store
 import no.nav.hjelpemidler.database.pgJsonbOf
 import no.nav.hjelpemidler.database.sql.Sql
+import no.nav.hjelpemidler.domain.person.Fødselsnummer
 import no.nav.hjelpemidler.http.slack.SlackClient
 import no.nav.hjelpemidler.http.slack.slackIconEmoji
 import no.nav.hjelpemidler.serialization.jackson.jsonMapper
@@ -33,6 +38,7 @@ import no.nav.hjelpemidler.soknad.db.metrics.StatusTemporal
 import java.math.BigInteger
 import java.time.DayOfWeek
 import java.time.Instant
+import java.time.LocalDate
 import java.time.LocalDateTime
 import java.time.ZoneId
 import java.util.UUID
@@ -413,6 +419,80 @@ class SøknadStore(private val tx: JdbcOperations, private val slackClient: Slac
         ).actualRowCount
     }
 
+    fun migrerDataTilV2(): Int {
+
+        data class Data(
+            val id: UUID,
+            val data: JsonNode,
+            val fnrInnsender: Fødselsnummer,
+            val datoOpprettet: LocalDate,
+        )
+
+        val behovsmeldingerV1 = tx.list(
+            """
+             SELECT soknads_id, data, fnr_innsender, created
+             FROM v1_soknad
+             WHERE er_digital = true AND data_v2 IS NULL AND data IS NOT NULL
+             FOR UPDATE SKIP LOCKED
+             LIMIT 100
+            """.trimIndent(),
+            mapOf(),
+            { row ->
+                val id = row.uuid("soknads_id")
+                logg.info { "Klargjør $id for migrering." }
+                Data(
+                    id = id,
+                    data = row.json<JsonNode>("data"),
+                    fnrInnsender = Fødselsnummer(row.string("fnr_innsender")),
+                    datoOpprettet = row.localDate("created")
+                )
+            },
+        )
+
+        var count = 0
+        behovsmeldingerV1.forEach { (id, data, fnrInnsender, datoOpprettet) ->
+            logg.info { "Migrerer til data_v2 for behovsmelding '$id'" }
+            val typeNode = data["behovsmeldingType"]
+            val type = if (typeNode == null || typeNode.isNull()) {
+                BehovsmeldingType.SØKNAD
+            } else {
+                BehovsmeldingType.valueOf(
+                    typeNode.asText("SØKNAD")
+                )
+            }
+
+            logg.info { "$id har type ${type.name}" }
+
+            val dataV2 = try {
+                when (type) {
+                    BehovsmeldingType.BRUKERPASSBYTTE -> tilBrukerpassbytteV2(
+                        v1 = jsonMapper.convertValue<Brukerpassbytte>(data["brukerpassbytte"]),
+                        fnr = fnrInnsender,
+                    )
+
+                    else -> tilInnsenderbehovsmeldingV2(jsonMapper.convertValue<Behovsmelding>(data), datoOpprettet)
+                }
+            } catch (e: Exception) {
+                logg.error(e) { "Migrering til V2 feilet for $id. Skipper." }
+                return@forEach
+            }
+
+            logg.info { "Mappet $id til v2" }
+
+            tx.update(
+                """
+                    UPDATE v1_soknad SET data_v2 = :dataV2 WHERE soknads_id = :id
+                """.trimIndent(),
+                mapOf("id" to id, "dataV2" to pgJsonbOf(dataV2)),
+            )
+
+            logg.info { "Lagret data_v2 for $id" }
+            count++
+        }
+
+        return count
+    }
+
     fun lagrePapirsøknad(grunnlag: Behovsmeldingsgrunnlag.Papir): Int {
         lagreStatus(grunnlag.søknadId, grunnlag.status)
         return tx.update(
diff --git a/behovsmeldingsmodell/src/main/kotlin/no/nav/hjelpemidler/behovsmeldingsmodell/v2/mapping/BrukerpassbytteMapper.kt b/behovsmeldingsmodell/src/main/kotlin/no/nav/hjelpemidler/behovsmeldingsmodell/v2/mapping/BrukerpassbytteMapper.kt
@@ -31,7 +31,7 @@ fun tilBrukerpassbytteV2(v1: no.nav.hjelpemidler.behovsmeldingsmodell.v1.Brukerp
         hmsArtNr = v1.hjelpemiddel.artnr,
         artikkelnavn = v1.hjelpemiddel.navn,
         iso6Tittel = v1.hjelpemiddel.kategori,
-        iso6 = v1.hjelpemiddel.kategorinummer?.let { Iso6(it) },
+        iso6 = v1.hjelpemiddel.kategorinummer?.let { Iso6(it.take(6)) },
     )
 
     return Brukerpassbytte(
diff --git a/behovsmeldingsmodell/src/main/kotlin/no/nav/hjelpemidler/behovsmeldingsmodell/v2/mapping/InnsenderbehovsmeldingMapper.kt b/behovsmeldingsmodell/src/main/kotlin/no/nav/hjelpemidler/behovsmeldingsmodell/v2/mapping/InnsenderbehovsmeldingMapper.kt
@@ -51,14 +51,15 @@ import no.nav.hjelpemidler.behovsmeldingsmodell.v2.Utlevertinfo
 import no.nav.hjelpemidler.behovsmeldingsmodell.v2.Varsel
 import no.nav.hjelpemidler.behovsmeldingsmodell.v2.Varseltype
 import no.nav.hjelpemidler.behovsmeldingsmodell.ÅrsakForAntall
+import java.time.LocalDate
 
-fun tilInnsenderbehovsmeldingV2(v1: Behovsmelding): Innsenderbehovsmelding {
+fun tilInnsenderbehovsmeldingV2(v1: Behovsmelding, defaultDato: LocalDate? = null): Innsenderbehovsmelding {
     val id = v1.id ?: error("Behovsmelding v1 mangler id")
     val v1Bruker = v1.søknad?.bruker ?: error("Behovsmelding $id mangler søknad")
     return Innsenderbehovsmelding(
         id = id,
         type = v1.behovsmeldingType,
-        innsendingsdato = v1.søknad.dato ?: error("Behovsmelding $id mangler dato"),
+        innsendingsdato = v1.søknad.dato ?: defaultDato ?:error("Behovsmelding $id mangler dato"),
         bruker = Bruker(
             fnr = v1Bruker.fnr,
             navn = v1Bruker.navn,

Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ fun tilBrukerpassbytteV2(v1: no.nav.hjelpemidler.behovsmeldingsmodell.v1.Brukerp`
`31`	`31`	`hmsArtNr = v1.hjelpemiddel.artnr,`
`32`	`32`	`artikkelnavn = v1.hjelpemiddel.navn,`
`33`	`33`	`iso6Tittel = v1.hjelpemiddel.kategori,`
`34`		`- iso6 = v1.hjelpemiddel.kategorinummer?.let { Iso6(it) },`
	`34`	`+ iso6 = v1.hjelpemiddel.kategorinummer?.let { Iso6(it.take(6)) },`
`35`	`35`	`)`
`36`	`36`
`37`	`37`	`return Brukerpassbytte(`