Lagrer opptjeningsperiode når inntekt lagres i database og henter den ut igjen når data skal sendes til nytt frontend

vskjefst · vskjefst · commit 4f975bf59eef · 2025-05-26T14:13:17.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
@@ -147,13 +147,13 @@ fun Route.uklassifisertInntekt(
                     val inntektId = InntektId(call.parameters["inntektId"]!!)
                     inntektStore
                         .getStoredInntektMedMetadata(inntektId)
-                        .let {
-                            val person = personOppslag.hentPerson(it.fødselsnummer)
-                            val inntektsmottaker = Inntektsmottaker(it.fødselsnummer, person.sammensattNavn())
+                        .let { storedInntektMedMetadata ->
+                            val person = personOppslag.hentPerson(storedInntektMedMetadata.fødselsnummer)
+                            val inntektsmottaker = Inntektsmottaker(storedInntektMedMetadata.fødselsnummer, person.sammensattNavn())
                             val organisasjoner =
                                 hentOrganisasjoner(
                                     enhetsregisterClient,
-                                    it.inntekt.arbeidsInntektMaaned
+                                    storedInntektMedMetadata.inntekt.arbeidsInntektMaaned
                                         ?.flatMap { it.arbeidsInntektInformasjon?.inntektListe.orEmpty() }
                                         ?.filter { inntekt ->
                                             inntekt.virksomhet?.aktoerType == AktoerType.ORGANISASJON &&
@@ -162,7 +162,12 @@ fun Route.uklassifisertInntekt(
                                         ?.toTypedArray()
                                         ?.toList() ?: emptyList(),
                                 )
-                            it.inntekt.mapToFrontend(inntektsmottaker, organisasjoner)
+                            storedInntektMedMetadata.inntekt.mapToFrontend(
+                                person = inntektsmottaker,
+                                organisasjoner = organisasjoner,
+                                beregningsdato = storedInntektMedMetadata.beregningsdato,
+                                storedInntektPeriode = storedInntektMedMetadata.storedInntektPeriode,
+                            )
                         }.let {
                             call.respond(HttpStatusCode.OK, it)
                         }
@@ -171,8 +176,9 @@ fun Route.uklassifisertInntekt(
             post {
                 withContext(coroutineContext) {
                     val inntektId = call.parameters["inntektId"]!!
-                    call
-                        .receive<InntekterDto>()
+                    val inntekterDto = call.receive<InntekterDto>()
+
+                    inntekterDto
                         .mapToStoredInntekt(
                             inntektId = inntektId,
                         ).let {
@@ -189,7 +195,10 @@ fun Route.uklassifisertInntekt(
                                                     inntektPersonMapping.kontekstType,
                                                 ),
                                             beregningsdato = inntektPersonMapping.beregningsdato,
-                                        ),
+                                        ).apply {
+                                            this.opptjeningsperiode.førsteMåned = inntekterDto.periode.fraOgMed
+                                            this.opptjeningsperiode.sisteAvsluttendeKalenderMåned = inntekterDto.periode.tilOgMed
+                                        },
                                     inntekt = it.inntekt,
                                     manueltRedigert =
                                         ManueltRedigert.from(
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
@@ -17,6 +17,12 @@ import java.time.YearMonth
 data class InntekterDto(
     val virksomheter: List<Virksomhet>,
     val mottaker: Inntektsmottaker,
+    val periode: PeriodeDto,
+)
+
+data class PeriodeDto(
+    val fraOgMed: YearMonth,
+    val tilOgMed: YearMonth,
 )
 
 fun InntekterDto.mapToStoredInntekt(inntektId: String): StoredInntekt =
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
@@ -6,6 +6,7 @@ import no.nav.dagpenger.inntekt.opptjeningsperiode.Opptjeningsperiode
 import no.nav.dagpenger.inntekt.v1.SpesifisertInntekt
 import java.time.LocalDate
 import java.time.LocalDateTime
+import java.time.YearMonth
 import java.time.ZoneOffset
 import java.time.ZonedDateTime
 
@@ -108,6 +109,13 @@ data class StoredInntektMedMetadata(
     val manueltRedigert: Boolean,
     val timestamp: LocalDateTime? = null,
     val fødselsnummer: String,
+    val beregningsdato: LocalDate,
+    val storedInntektPeriode: StoredInntektPeriode?,
+)
+
+data class StoredInntektPeriode(
+    val fraOgMed: YearMonth?,
+    val tilOgMed: YearMonth?,
 )
 
 class InntektNotFoundException(
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
@@ -18,6 +18,7 @@ import org.intellij.lang.annotations.Language
 import org.postgresql.util.PGobject
 import org.postgresql.util.PSQLException
 import java.time.LocalDate
+import java.time.YearMonth
 import java.time.ZonedDateTime
 import javax.sql.DataSource
 
@@ -191,7 +192,7 @@ internal class PostgresInntektStore(
         @Language("sql")
         val statement =
             """ 
-            SELECT inntekt.id, inntekt.inntekt, inntekt.manuelt_redigert, inntekt.timestamp, mapping.fnr 
+            SELECT inntekt.id, inntekt.inntekt, inntekt.manuelt_redigert, inntekt.timestamp, mapping.fnr, mapping.periodeFraOgMed, mapping.periodeTilOgMed
             from inntekt_V1 inntekt 
             inner join inntekt_V1_person_mapping mapping on inntekt.id = mapping.inntektid 
             where inntekt.id = ?
@@ -208,6 +209,12 @@ internal class PostgresInntektStore(
                             manueltRedigert = it.boolean("manuelt_redigert"),
                             timestamp = it.zonedDateTime("timestamp").toLocalDateTime(),
                             fødselsnummer = it.string("fnr"),
+                            beregningsdato = it.localDate("beregningsdato"),
+                            storedInntektPeriode =
+                                StoredInntektPeriode(
+                                    fraOgMed = it.localDateOrNull("periodeFraOgMed")?.let { localDate -> YearMonth.from(localDate) },
+                                    tilOgMed = it.localDateOrNull("periodeTilOgMed")?.let { localDate -> YearMonth.from(localDate) },
+                                ),
                         )
                     }.asSingle,
             ) ?: throw InntektNotFoundException("Inntekt with id $inntektId not found.")
@@ -242,14 +249,25 @@ internal class PostgresInntektStore(
                     )
                     tx.run(
                         queryOf(
-                            "INSERT INTO inntekt_V1_person_mapping(inntektId, aktørId, fnr, kontekstId, beregningsdato, kontekstType) VALUES (:inntektId, :aktorId, :fnr, :kontekstId, :beregningsdato, :kontekstType::kontekstTypeNavn)",
+                            """
+                            INSERT INTO inntekt_V1_person_mapping(inntektId, aktørId, fnr, kontekstId, beregningsdato, kontekstType, periodeFraOgMed, periodeTilOgMed) 
+                            VALUES (:inntektId, :aktorId, :fnr, :kontekstId, :beregningsdato, :kontekstType::kontekstTypeNavn, :periodeFraOgMed, :periodeTilOgMed)
+                            """.trimIndent(),
                             mapOf(
                                 "inntektId" to inntektId.id,
                                 "aktorId" to command.inntektparametre.aktørId,
                                 "fnr" to command.inntektparametre.fødselsnummer,
                                 "kontekstId" to command.inntektparametre.regelkontekst.id,
                                 "kontekstType" to command.inntektparametre.regelkontekst.type,
                                 "beregningsdato" to command.inntektparametre.beregningsdato,
+                                "periodeFraOgMed" to
+                                    command.inntektparametre.opptjeningsperiode.førsteMåned.let {
+                                        LocalDate.of(it.year, it.month, 1)
+                                    },
+                                "periodeTilOgMed" to
+                                    command.inntektparametre.opptjeningsperiode.sisteAvsluttendeKalenderMåned.let {
+                                        LocalDate.of(it.year, it.month, 1)
+                                    },
                             ),
                         ).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
@@ -1,19 +1,25 @@
 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.inntektskomponenten.v1.Aktoer
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.Avvik
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektBeskrivelse
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektType
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektkomponentResponse
 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?,
 ): InntekterDto {
     val inntekt = arbeidsInntektMaaned
     val virksomheter: MutableList<Virksomhet> = mutableListOf()
@@ -99,6 +105,18 @@ fun InntektkomponentResponse.mapToFrontend(
     return InntekterDto(
         virksomheter = virksomheter,
         mottaker = person,
+        periode = getPeriode(storedInntektPeriode, beregningsdato),
+    )
+}
+
+private fun getPeriode(
+    storedInntektPeriode: StoredInntektPeriode?,
+    beregningsdato: LocalDate,
+): PeriodeDto {
+    val opptjeningsperiode = Opptjeningsperiode(beregningsdato)
+    return PeriodeDto(
+        storedInntektPeriode?.fraOgMed ?: opptjeningsperiode.førsteMåned,
+        storedInntektPeriode?.tilOgMed ?: opptjeningsperiode.sisteAvsluttendeKalenderMåned,
     )
 }
 
diff --git a/dp-inntekt-api/src/main/resources/db/migration/V12_1__Inntekt_person_mapping_add_periodeFraOgMed_og_periodeTilOgMed.sql b/dp-inntekt-api/src/main/resources/db/migration/V12_1__Inntekt_person_mapping_add_periodeFraOgMed_og_periodeTilOgMed.sql
@@ -0,0 +1,3 @@
+ALTER TABLE inntekt_v1_person_mapping
+    ADD COLUMN periodeFraOgMed DATE,
+    ADD COLUMN periodeTilOgMed DATE;
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
@@ -504,6 +504,8 @@ internal class UklassifisertInntektRouteTest {
                     manueltRedigert = false,
                     timestamp = LocalDateTime.now(),
                     fødselsnummer = fødselsnummer,
+                    beregningsdato = LocalDate.now(),
+                    null,
                 )
 
             val response =
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
@@ -29,7 +29,7 @@ internal class PostgresTest {
     fun `Migration scripts are applied successfully`() {
         withCleanDb {
             val migrations = PostgresDataSourceBuilder.runMigration()
-            assertEquals(16, migrations, "Wrong number of migrations")
+            assertEquals(17, migrations, "Wrong number of migrations")
         }
     }
 
@@ -45,7 +45,7 @@ internal class PostgresTest {
     fun `Migration of testdata `() {
         withCleanDb {
             val migrations = PostgresDataSourceBuilder.runMigration(locations = listOf("db/migration", "db/testdata"))
-            assertEquals(21, migrations, "Wrong number of migrations")
+            assertEquals(22, migrations, "Wrong number of migrations")
         }
     }
 }
@@ -474,7 +474,9 @@ internal class InntektsStorePropertyTest : StringSpec() {
                         regelkontekst = RegelKontekst(kontekstId.next(it), "vedtak"),
                         fødselsnummer = aktørId.next(it),
                         beregningsdato =
-                            Arb.localDateTime(minYear = 2010, maxYear = LocalDate.now().year).next(it)
+                            Arb
+                                .localDateTime(minYear = 2010, maxYear = LocalDate.now().year)
+                                .next(it)
                                 .toLocalDate(),
                     ),
                 inntekt =
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
@@ -12,6 +12,7 @@ import no.nav.dagpenger.inntekt.inntektskomponenten.v1.TilleggInformasjon
 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.YearMonth
 import kotlin.test.assertEquals
 import kotlin.test.assertFalse
@@ -189,6 +190,8 @@ class MapToInntektFrontendTest {
             inntektkomponentResponse.mapToFrontend(
                 mottaker,
                 organisasjoner,
+                beregningsdato = now(),
+                storedInntektPeriode = null,
             )
 
         assertEquals(2, mappedToInntektFrontend.virksomheter.size)
@@ -331,7 +334,12 @@ class MapToInntektFrontendTest {
             )
 
         val mapTilFrontendMedNullVirksomhet =
-            inntektkomponentResponseMedTomVirksomhet.mapToFrontend(mottaker, organisasjoner)
+            inntektkomponentResponseMedTomVirksomhet.mapToFrontend(
+                mottaker,
+                organisasjoner,
+                beregningsdato = now(),
+                storedInntektPeriode = null,
+            )
         assertEquals(3, mapTilFrontendMedNullVirksomhet.virksomheter.size)
         assertEquals(2, mapTilFrontendMedNullVirksomhet.virksomheter.filter { it.virksomhetsnummer == "" }.size)
         assertEquals(1, mapTilFrontendMedNullVirksomhet.virksomheter.filter { it.virksomhetsnummer == "896929120" }.size)

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+ALTER TABLE inntekt_v1_person_mapping`
	`2`	`+ ADD COLUMN periodeFraOgMed DATE,`
	`3`	`+ ADD COLUMN periodeTilOgMed DATE;`
Original file line number	Diff line number	Diff line change
`@@ -504,6 +504,8 @@ internal class UklassifisertInntektRouteTest {`
`504`	`504`	`manueltRedigert = false,`
`505`	`505`	`timestamp = LocalDateTime.now(),`
`506`	`506`	`fødselsnummer = fødselsnummer,`
	`507`	`+ beregningsdato = LocalDate.now(),`
	`508`	`+ null,`
`507`	`509`	`)`
`508`	`510`
`509`	`511`	`val response =`
Original file line number	Diff line number	Diff line change
`@@ -29,7 +29,7 @@ internal class PostgresTest {`
`29`	`29`	fun `Migration scripts are applied successfully`() {
`30`	`30`	`withCleanDb {`
`31`	`31`	`val migrations = PostgresDataSourceBuilder.runMigration()`
`32`		`- assertEquals(16, migrations, "Wrong number of migrations")`
	`32`	`+ assertEquals(17, migrations, "Wrong number of migrations")`
`33`	`33`	`}`
`34`	`34`	`}`
`35`	`35`
`@@ -45,7 +45,7 @@ internal class PostgresTest {`
`45`	`45`	fun `Migration of testdata `() {
`46`	`46`	`withCleanDb {`
`47`	`47`	`val migrations = PostgresDataSourceBuilder.runMigration(locations = listOf("db/migration", "db/testdata"))`
`48`		`- assertEquals(21, migrations, "Wrong number of migrations")`
	`48`	`+ assertEquals(22, migrations, "Wrong number of migrations")`
`49`	`49`	`}`
`50`	`50`	`}`
`51`	`51`	`}`
`@@ -474,7 +474,9 @@ internal class InntektsStorePropertyTest : StringSpec() {`
`474`	`474`	`regelkontekst = RegelKontekst(kontekstId.next(it), "vedtak"),`
`475`	`475`	`fødselsnummer = aktørId.next(it),`
`476`	`476`	`beregningsdato =`
`477`		`- Arb.localDateTime(minYear = 2010, maxYear = LocalDate.now().year).next(it)`
	`477`	`+ Arb`
	`478`	`+ .localDateTime(minYear = 2010, maxYear = LocalDate.now().year)`
	`479`	`+ .next(it)`
`478`	`480`	`.toLocalDate(),`
`479`	`481`	`),`
`480`	`482`	`inntekt =`