Støtte for lagring og uthenting av begrunnelse

vskjefst · vskjefst · commit 83ababe76c1f · 2025-05-28T12:56:04.000+02:00
diff --git a/dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/api/v1/UklassifisertInntektRoute.kt b/dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/api/v1/UklassifisertInntektRoute.kt
@@ -165,8 +165,7 @@ fun Route.uklassifisertInntekt(
                             storedInntektMedMetadata.inntekt.mapToFrontend(
                                 person = inntektsmottaker,
                                 organisasjoner = organisasjoner,
-                                beregningsdato = storedInntektMedMetadata.beregningsdato,
-                                storedInntektPeriode = storedInntektMedMetadata.storedInntektPeriode,
+                                storedInntektMedMetadata,
                             )
                         }.let {
                             call.respond(HttpStatusCode.OK, it)
@@ -201,8 +200,9 @@ fun Route.uklassifisertInntekt(
                                     inntekt = it.inntekt,
                                     manueltRedigert =
                                         ManueltRedigert.from(
-                                            true,
-                                            call.getSubject(),
+                                            bool = true,
+                                            redigertAv = call.getSubject(),
+                                            begrunnelse = inntekterDto.begrunnelse,
                                         ),
                                 ),
                             )
diff --git a/dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/api/v1/models/InntekterDto.kt b/dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/api/v1/models/InntekterDto.kt
@@ -18,6 +18,7 @@ data class InntekterDto(
     val virksomheter: List<Virksomhet>,
     val mottaker: Inntektsmottaker,
     val periode: PeriodeDto,
+    val begrunnelse: String? = null,
 )
 
 data class PeriodeDto(
diff --git a/dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/db/InntektStore.kt b/dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/db/InntektStore.kt
@@ -67,13 +67,15 @@ data class InntektPersonMapping(
 
 data class ManueltRedigert(
     val redigertAv: String,
+    val begrunnelse: String? = null,
 ) {
     companion object {
         fun from(
             bool: Boolean,
             redigertAv: String,
+            begrunnelse: String? = null,
         ) = when (bool) {
-            true -> ManueltRedigert(redigertAv)
+            true -> ManueltRedigert(redigertAv, begrunnelse)
             false -> null
         }
     }
@@ -111,6 +113,7 @@ data class StoredInntektMedMetadata(
     val fødselsnummer: String,
     val beregningsdato: LocalDate,
     val storedInntektPeriode: StoredInntektPeriode?,
+    val begrunnelse: String? = null,
 )
 
 data class StoredInntektPeriode(
diff --git a/dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/db/PostgresInntektStore.kt b/dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/db/PostgresInntektStore.kt
@@ -42,7 +42,7 @@ internal class PostgresInntektStore(
         @Language("sql")
         val statement =
             """
-            SELECT redigert_av
+            SELECT redigert_av, begrunnelse
                 FROM inntekt_V1_manuelt_redigert
             WHERE inntekt_id = ?
             """.trimMargin()
@@ -51,7 +51,7 @@ internal class PostgresInntektStore(
                 session.run(
                     queryOf(statement, inntektId.id)
                         .map { row ->
-                            ManueltRedigert(row.string(1))
+                            ManueltRedigert(row.string("redigert_av"), row.string("begrunnelse"))
                         }.asSingle,
                 )
             }
@@ -192,9 +192,10 @@ internal class PostgresInntektStore(
         @Language("sql")
         val statement =
             """ 
-            SELECT inntekt.id, inntekt.inntekt, inntekt.manuelt_redigert, inntekt.timestamp, mapping.fnr, mapping.beregningsdato, mapping.periodeFraOgMed, mapping.periodeTilOgMed
+            SELECT inntekt.id, inntekt.inntekt, inntekt.manuelt_redigert, inntekt.timestamp, mapping.fnr, mapping.beregningsdato, mapping.periodeFraOgMed, mapping.periodeTilOgMed, manuelt_redigert.begrunnelse
             FROM inntekt_V1 inntekt
-            INNER JOIN inntekt_V1_person_mapping mapping ON inntekt.id = mapping.inntektid 
+            INNER JOIN inntekt_V1_person_mapping mapping ON inntekt.id = mapping.inntektid
+            LEFT JOIN inntekt_V1_manuelt_redigert manuelt_redigert ON inntekt.id = manuelt_redigert.inntektid
             WHERE inntekt.id = ?
             """.trimIndent()
 
@@ -214,6 +215,7 @@ internal class PostgresInntektStore(
                                     fraOgMed = it.localDateOrNull("periodeFraOgMed")?.let { localDate -> YearMonth.from(localDate) },
                                     tilOgMed = it.localDateOrNull("periodeTilOgMed")?.let { localDate -> YearMonth.from(localDate) },
                                 ),
+                            begrunnelse = it.stringOrNull("begrunnelse"),
                         )
                     }.asSingle,
             ) ?: throw InntektNotFoundException("Inntekt with id $inntektId not found.")
@@ -272,12 +274,17 @@ internal class PostgresInntektStore(
                     )
 
                     command.manueltRedigert?.let {
+                        it.begrunnelse?.length?.let { lengde ->
+                            require(lengde <= 1024) { "Begrunnelsen kan ikke være lengre enn 1024 tegn." }
+                        }
+
                         tx.run(
                             queryOf(
-                                "INSERT INTO inntekt_V1_manuelt_redigert VALUES(:id,:redigert)",
+                                "INSERT INTO inntekt_V1_manuelt_redigert (inntekt_id, redigert_av, begrunnelse) VALUES(:id, :redigert, :begrunnelse)",
                                 mapOf(
                                     "id" to inntektId.id,
                                     "redigert" to it.redigertAv,
+                                    "begrunnelse" to it.begrunnelse,
                                 ),
                             ).asUpdate,
                         )
diff --git a/dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/mapping/MapToInntektFrontend.kt b/dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/mapping/MapToInntektFrontend.kt
@@ -2,7 +2,7 @@ package no.nav.dagpenger.inntekt.mapping
 
 import no.nav.dagpenger.inntekt.api.v1.models.InntekterDto
 import no.nav.dagpenger.inntekt.api.v1.models.PeriodeDto
-import no.nav.dagpenger.inntekt.db.StoredInntektPeriode
+import no.nav.dagpenger.inntekt.db.StoredInntektMedMetadata
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.Aktoer
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.Avvik
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektBeskrivelse
@@ -12,14 +12,12 @@ import no.nav.dagpenger.inntekt.inntektskomponenten.v1.Periode
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.TilleggInformasjon
 import no.nav.dagpenger.inntekt.opptjeningsperiode.Opptjeningsperiode
 import java.math.BigDecimal
-import java.time.LocalDate
 import java.time.YearMonth
 
 fun InntektkomponentResponse.mapToFrontend(
     person: Inntektsmottaker,
     organisasjoner: List<Organisasjon>,
-    beregningsdato: LocalDate,
-    storedInntektPeriode: StoredInntektPeriode?,
+    storedInntektMedMetadata: StoredInntektMedMetadata,
 ): InntekterDto {
     val inntekt = arbeidsInntektMaaned
     val virksomheter: MutableList<Virksomhet> = mutableListOf()
@@ -105,18 +103,16 @@ fun InntektkomponentResponse.mapToFrontend(
     return InntekterDto(
         virksomheter = virksomheter,
         mottaker = person,
-        periode = getPeriode(storedInntektPeriode, beregningsdato),
+        periode = getPeriode(storedInntektMedMetadata),
+        begrunnelse = storedInntektMedMetadata.begrunnelse,
     )
 }
 
-private fun getPeriode(
-    storedInntektPeriode: StoredInntektPeriode?,
-    beregningsdato: LocalDate,
-): PeriodeDto {
-    val opptjeningsperiode = Opptjeningsperiode(beregningsdato)
+private fun getPeriode(storedInntektMedMetadata: StoredInntektMedMetadata): PeriodeDto {
+    val opptjeningsperiode = Opptjeningsperiode(beregningsdato = storedInntektMedMetadata.beregningsdato)
     return PeriodeDto(
-        storedInntektPeriode?.fraOgMed ?: opptjeningsperiode.førsteMåned,
-        storedInntektPeriode?.tilOgMed ?: opptjeningsperiode.sisteAvsluttendeKalenderMåned,
+        fraOgMed = storedInntektMedMetadata.storedInntektPeriode?.fraOgMed ?: opptjeningsperiode.førsteMåned,
+        tilOgMed = storedInntektMedMetadata.storedInntektPeriode?.tilOgMed ?: opptjeningsperiode.sisteAvsluttendeKalenderMåned,
     )
 }
 
diff --git a/dp-inntekt-api/src/main/resources/db/migration/V13_1__inntekt_manuelt_redigert_add_begrunnelse.sql b/dp-inntekt-api/src/main/resources/db/migration/V13_1__inntekt_manuelt_redigert_add_begrunnelse.sql
@@ -0,0 +1,2 @@
+ALTER TABLE inntekt_v1_manuelt_redigert
+    ADD COLUMN begrunnelse VARCHAR(1024);
diff --git a/dp-inntekt-api/src/test/kotlin/no/nav/dagpenger/inntekt/api/v1/UklassifisertInntektRouteTest.kt b/dp-inntekt-api/src/test/kotlin/no/nav/dagpenger/inntekt/api/v1/UklassifisertInntektRouteTest.kt
@@ -574,5 +574,6 @@ internal class UklassifisertInntektRouteTest {
                 YearMonth.of(2025, 4)
             storeInntektCommandSlot.captured.manueltRedigert.shouldNotBeNull()
             storeInntektCommandSlot.captured.manueltRedigert!!.redigertAv shouldBe TEST_OAUTH_USER
+            storeInntektCommandSlot.captured.manueltRedigert!!.begrunnelse shouldBe "Dette er en begrunnelse."
         }
 }
diff --git a/dp-inntekt-api/src/test/kotlin/no/nav/dagpenger/inntekt/db/PostgresTest.kt b/dp-inntekt-api/src/test/kotlin/no/nav/dagpenger/inntekt/db/PostgresTest.kt
@@ -1,9 +1,11 @@
 package no.nav.dagpenger.inntekt.db
 
 import io.kotest.assertions.assertSoftly
+import io.kotest.assertions.throwables.shouldThrow
 import io.kotest.core.spec.style.StringSpec
 import io.kotest.matchers.shouldBe
 import io.kotest.matchers.shouldNotBe
+import io.kotest.matchers.throwable.shouldHaveMessage
 import io.kotest.property.Arb
 import io.kotest.property.arbitrary.arbitrary
 import io.kotest.property.arbitrary.localDateTime
@@ -29,7 +31,7 @@ internal class PostgresTest {
     fun `Migration scripts are applied successfully`() {
         withCleanDb {
             val migrations = PostgresDataSourceBuilder.runMigration()
-            assertEquals(17, migrations, "Wrong number of migrations")
+            assertEquals(18, migrations, "Wrong number of migrations")
         }
     }
 
@@ -45,7 +47,7 @@ internal class PostgresTest {
     fun `Migration of testdata `() {
         withCleanDb {
             val migrations = PostgresDataSourceBuilder.runMigration(locations = listOf("db/migration", "db/testdata"))
-            assertEquals(22, migrations, "Wrong number of migrations")
+            assertEquals(23, migrations, "Wrong number of migrations")
         }
     }
 }
@@ -209,7 +211,7 @@ internal class PostgresInntektStoreTest {
                         emptyList(),
                         Aktoer(AktoerType.AKTOER_ID, "1234"),
                     )
-                val manueltRedigert = ManueltRedigert("user")
+                val manueltRedigert = ManueltRedigert("user", "Dette er en begrunnelse.")
 
                 val storedInntekt =
                     storeInntekt(
@@ -219,14 +221,82 @@ internal class PostgresInntektStoreTest {
                             manueltRedigert = manueltRedigert,
                         ),
                     )
-                assertTrue(storedInntekt.manueltRedigert)
-
                 val storedInntektByRequest = getInntekt(storedInntekt.inntektId)
-                assertTrue(storedInntektByRequest.manueltRedigert)
-
                 val storedManueltRedigert = getManueltRedigert(storedInntekt.inntektId)
-                assertNotNull(storedManueltRedigert)
-                assertEquals(manueltRedigert, storedManueltRedigert)
+                storedManueltRedigert shouldNotBe null
+                storedManueltRedigert shouldBe manueltRedigert
+                storedInntekt.manueltRedigert shouldBe true
+                storedInntektByRequest.manueltRedigert shouldBe true
+            }
+        }
+    }
+
+    @Test
+    fun `Lagring av inntekt skal kaste IllegalArgumentException når begrunnelse er lengre enn 1024 tegn`() {
+        withMigratedDb {
+            with(PostgresInntektStore(PostgresDataSourceBuilder.dataSource)) {
+                val parameters = Inntektparametre("1234", "1234", LocalDate.now(), RegelKontekst("1234", "vedtak"))
+                val hentInntektListeResponse =
+                    InntektkomponentResponse(
+                        emptyList(),
+                        Aktoer(AktoerType.AKTOER_ID, "1234"),
+                    )
+                val manueltRedigert = ManueltRedigert("user", "A".repeat(1025))
+
+                val exception =
+                    shouldThrow<IllegalArgumentException> {
+                        storeInntekt(
+                            StoreInntektCommand(
+                                inntektparametre = parameters,
+                                inntekt = hentInntektListeResponse,
+                                manueltRedigert = manueltRedigert,
+                            ),
+                        )
+                    }
+                exception shouldHaveMessage "Begrunnelsen kan ikke være lengre enn 1024 tegn."
+            }
+        }
+    }
+
+    @Test
+    fun `getStoredInntektMedMetadata returnerer forventet resultat når inntekten ikke er manuelt redigert`() {
+        withMigratedDb {
+            with(PostgresInntektStore(PostgresDataSourceBuilder.dataSource)) {
+                val parameters = Inntektparametre("1234", "1234", LocalDate.now(), RegelKontekst("1234", "vedtak"))
+                val hentInntektListeResponse =
+                    InntektkomponentResponse(
+                        emptyList(),
+                        Aktoer(AktoerType.AKTOER_ID, "1234"),
+                    )
+                storeInntekt(
+                    StoreInntektCommand(
+                        inntektparametre = parameters,
+                        inntekt = hentInntektListeResponse,
+                        manueltRedigert = null,
+                    ),
+                )
+            }
+        }
+    }
+
+    @Test
+    fun `getStoredInntektMedMetadata returnerer forventet resultat når inntekten er manuelt redigert`() {
+        withMigratedDb {
+            with(PostgresInntektStore(PostgresDataSourceBuilder.dataSource)) {
+                val parameters = Inntektparametre("1234", "1234", LocalDate.now(), RegelKontekst("1234", "vedtak"))
+                val hentInntektListeResponse =
+                    InntektkomponentResponse(
+                        emptyList(),
+                        Aktoer(AktoerType.AKTOER_ID, "1234"),
+                    )
+                val manueltRedigert = ManueltRedigert("user", "Dette er en begrunnelse.")
+                storeInntekt(
+                    StoreInntektCommand(
+                        inntektparametre = parameters,
+                        inntekt = hentInntektListeResponse,
+                        manueltRedigert = manueltRedigert,
+                    ),
+                )
             }
         }
     }
diff --git a/dp-inntekt-api/src/test/kotlin/no/nav/dagpenger/inntekt/mapping/MapToInntektFrontendTest.kt b/dp-inntekt-api/src/test/kotlin/no/nav/dagpenger/inntekt/mapping/MapToInntektFrontendTest.kt
@@ -1,5 +1,10 @@
 package no.nav.dagpenger.inntekt.mapping
 
+import de.huxhorn.sulky.ulid.ULID
+import io.kotest.matchers.shouldBe
+import no.nav.dagpenger.inntekt.db.InntektId
+import no.nav.dagpenger.inntekt.db.StoredInntektMedMetadata
+import no.nav.dagpenger.inntekt.db.StoredInntektPeriode
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.Aktoer
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.AktoerType
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.ArbeidsInntektInformasjon
@@ -13,6 +18,7 @@ import no.nav.dagpenger.inntekt.serder.jacksonObjectMapper
 import org.junit.jupiter.api.Test
 import java.math.BigDecimal
 import java.time.LocalDate.now
+import java.time.LocalDateTime
 import java.time.YearMonth
 import kotlin.test.assertEquals
 import kotlin.test.assertFalse
@@ -188,12 +194,21 @@ class MapToInntektFrontendTest {
     fun `Map inntekt til InntektForVirksomhetMedPersonInformasjon`() {
         val mappedToInntektFrontend =
             inntektkomponentResponse.mapToFrontend(
-                mottaker,
-                organisasjoner,
-                beregningsdato = now(),
-                storedInntektPeriode = null,
+                person = mottaker,
+                organisasjoner = organisasjoner,
+                StoredInntektMedMetadata(
+                    InntektId(ULID().nextULID().toString()),
+                    inntektkomponentResponse,
+                    true,
+                    LocalDateTime.now(),
+                    "01234567890",
+                    now(),
+                    StoredInntektPeriode(YearMonth.now(), YearMonth.now()),
+                    "Dette er en begrunnelse.",
+                ),
             )
 
+        mappedToInntektFrontend.begrunnelse shouldBe "Dette er en begrunnelse."
         assertEquals(2, mappedToInntektFrontend.virksomheter.size)
         assertEquals(mottaker, mappedToInntektFrontend.mottaker)
 
@@ -337,8 +352,16 @@ class MapToInntektFrontendTest {
             inntektkomponentResponseMedTomVirksomhet.mapToFrontend(
                 mottaker,
                 organisasjoner,
-                beregningsdato = now(),
-                storedInntektPeriode = null,
+                StoredInntektMedMetadata(
+                    InntektId(ULID().nextULID().toString()),
+                    inntektkomponentResponse,
+                    true,
+                    LocalDateTime.now(),
+                    "01234567890",
+                    now(),
+                    StoredInntektPeriode(YearMonth.now(), YearMonth.now()),
+                    "Dette er en begrunnelse.",
+                ),
             )
         assertEquals(3, mapTilFrontendMedNullVirksomhet.virksomheter.size)
         assertEquals(2, mapTilFrontendMedNullVirksomhet.virksomheter.filter { it.virksomhetsnummer == "" }.size)
diff --git a/dp-inntekt-api/src/test/resources/test-data/expected-uklassifisert-post-body.json b/dp-inntekt-api/src/test/resources/test-data/expected-uklassifisert-post-body.json
@@ -313,5 +313,6 @@
   "periode": {
     "fraOgMed": "2000-12",
     "tilOgMed": "2025-04"
-  }
+  },
+  "begrunnelse": "Dette er en begrunnelse."
 }

Original file line number	Diff line number	Diff line change
`@@ -18,6 +18,7 @@ data class InntekterDto(`
`18`	`18`	`val virksomheter: List<Virksomhet>,`
`19`	`19`	`val mottaker: Inntektsmottaker,`
`20`	`20`	`val periode: PeriodeDto,`
	`21`	`+ val begrunnelse: String? = null,`
`21`	`22`	`)`
`22`	`23`
`23`	`24`	`data class PeriodeDto(`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,2 @@`
	`1`	`+ALTER TABLE inntekt_v1_manuelt_redigert`
	`2`	`+ ADD COLUMN begrunnelse VARCHAR(1024);`
Original file line number	Diff line number	Diff line change
`@@ -574,5 +574,6 @@ internal class UklassifisertInntektRouteTest {`
`574`	`574`	`YearMonth.of(2025, 4)`
`575`	`575`	`storeInntektCommandSlot.captured.manueltRedigert.shouldNotBeNull()`
`576`	`576`	`storeInntektCommandSlot.captured.manueltRedigert!!.redigertAv shouldBe TEST_OAUTH_USER`
	`577`	`+ storeInntektCommandSlot.captured.manueltRedigert!!.begrunnelse shouldBe "Dette er en begrunnelse."`
`577`	`578`	`}`
`578`	`579`	`}`
Original file line number	Diff line number	Diff line change
`@@ -313,5 +313,6 @@`
`313`	`313`	`"periode": {`
`314`	`314`	`"fraOgMed": "2000-12",`
`315`	`315`	`"tilOgMed": "2025-04"`
`316`		`- }`
	`316`	`+ },`
	`317`	`+ "begrunnelse": "Dette er en begrunnelse."`
`317`	`318`	`}`