diff --git a/apps/etterlatte-gyldig-soeknad/src/main/kotlin/no/nav/etterlatte/inntektsjustering/InntektsjusteringRiver.kt b/apps/etterlatte-gyldig-soeknad/src/main/kotlin/no/nav/etterlatte/inntektsjustering/InntektsjusteringRiver.kt index 5ee0e9c77b4..05e08830870 100644 --- a/apps/etterlatte-gyldig-soeknad/src/main/kotlin/no/nav/etterlatte/inntektsjustering/InntektsjusteringRiver.kt +++ b/apps/etterlatte-gyldig-soeknad/src/main/kotlin/no/nav/etterlatte/inntektsjustering/InntektsjusteringRiver.kt @@ -41,10 +41,9 @@ internal class InntektsjusteringRiver( try { logger.info("Mottatt inntektsjustering (id=${inntektsjustering.id})") - val fnr = packet[InntektsjusteringInnsendt.fnrBruker].textValue() val sak = runBlocking { - behandlingKlient.finnEllerOpprettSak(fnr, SakType.OMSTILLINGSSTOENAD) + behandlingKlient.finnEllerOpprettSak(inntektsjustering.fnr, SakType.OMSTILLINGSSTOENAD) } val journalpostResponse = journalfoerInntektsjusteringService.opprettJournalpost(sak, inntektsjustering) diff --git a/apps/etterlatte-gyldig-soeknad/src/main/kotlin/no/nav/etterlatte/inntektsjustering/JournalfoerInntektsjusteringService.kt b/apps/etterlatte-gyldig-soeknad/src/main/kotlin/no/nav/etterlatte/inntektsjustering/JournalfoerInntektsjusteringService.kt index a7eb65547eb..484b18a1b2b 100644 --- a/apps/etterlatte-gyldig-soeknad/src/main/kotlin/no/nav/etterlatte/inntektsjustering/JournalfoerInntektsjusteringService.kt +++ b/apps/etterlatte-gyldig-soeknad/src/main/kotlin/no/nav/etterlatte/inntektsjustering/JournalfoerInntektsjusteringService.kt @@ -19,6 +19,7 @@ import no.nav.etterlatte.libs.common.retry import no.nav.etterlatte.libs.common.sak.Sak import no.nav.etterlatte.libs.common.sak.SakId import org.slf4j.LoggerFactory +import java.time.LocalDate import java.time.LocalDateTime import java.time.ZoneOffset import java.util.Base64 @@ -99,8 +100,13 @@ class JournalfoerInntektsjusteringService( aar = inntektsjustering.inntektsaar, arbeidsinntekt = inntektsjustering.arbeidsinntekt, naeringsinntekt = inntektsjustering.naeringsinntekt, - arbeidsinntektUtland = inntektsjustering.arbeidsinntektUtland, - naeringsinntektUtland = inntektsjustering.naeringsinntektUtland, + inntektFraUtland = inntektsjustering.inntektFraUtland, + afpInntekt = inntektsjustering.afpInntekt, + afpInntektAFPTjenesteordning = inntektsjustering.afpTjenesteordning ?: "", + skalGaaAvMedAlderspensjon = inntektsjustering.skalGaaAvMedAlderspensjon, + datoForAaGaaAvMedAlderspensjon = + inntektsjustering.datoForAaGaaAvMedAlderspensjon?.formatert() + ?: "", tidspunkt = inntektsjustering.formatertTidspunkt(), ), mal = "inntektsjustering_nytt_aar_v1", @@ -124,14 +130,19 @@ data class ArkiverInntektsjustering( val aar: Int, val arbeidsinntekt: Int, val naeringsinntekt: Int, - val arbeidsinntektUtland: Int, - val naeringsinntektUtland: Int, + val inntektFraUtland: Int, + val afpInntekt: Int, + val afpInntektAFPTjenesteordning: String, + val skalGaaAvMedAlderspensjon: String, + val datoForAaGaaAvMedAlderspensjon: String, val tidspunkt: String, ) : PDFMal -fun Inntektsjustering.formatertTidspunkt(): String { - fun t(tall: Int) = if (tall < 10) "0$tall" else "$tall" - return with(LocalDateTime.ofInstant(tidspunkt, ZoneOffset.ofHours(0))) { +private fun Inntektsjustering.formatertTidspunkt() = + with(LocalDateTime.ofInstant(tidspunkt, ZoneOffset.ofHours(0))) { "${t(dayOfMonth)}.${t(monthValue)}.$year ${t(hour)}:${t(minute)}:${t(second)}" } -} + +private fun LocalDate.formatert() = "${t(dayOfMonth)}.${t(monthValue)}.$year" + +private fun t(tall: Int) = if (tall < 10) "0$tall" else "$tall" diff --git a/apps/etterlatte-gyldig-soeknad/src/test/kotlin/no/nav/etterlatte/inntektsjustering/InntektsjusteringRiverTest.kt b/apps/etterlatte-gyldig-soeknad/src/test/kotlin/no/nav/etterlatte/inntektsjustering/InntektsjusteringRiverTest.kt index ebfb4c6c644..2d564c71096 100644 --- a/apps/etterlatte-gyldig-soeknad/src/test/kotlin/no/nav/etterlatte/inntektsjustering/InntektsjusteringRiverTest.kt +++ b/apps/etterlatte-gyldig-soeknad/src/test/kotlin/no/nav/etterlatte/inntektsjustering/InntektsjusteringRiverTest.kt @@ -32,6 +32,7 @@ import no.nav.helse.rapids_rivers.testsupport.TestRapid import org.junit.jupiter.api.Test import org.junit.jupiter.api.TestInstance import java.time.Instant +import java.time.LocalDate import java.util.UUID @TestInstance(TestInstance.Lifecycle.PER_CLASS) @@ -51,11 +52,15 @@ internal class InntektsjusteringRiverTest { val inntektsjustering = Inntektsjustering( id = UUID.randomUUID(), + fnr = "123", inntektsaar = 2025, arbeidsinntekt = 100, naeringsinntekt = 200, - arbeidsinntektUtland = 300, - naeringsinntektUtland = 400, + inntektFraUtland = 300, + afpInntekt = 400, + afpTjenesteordning = "tjenesteordning", + skalGaaAvMedAlderspensjon = "JA", + datoForAaGaaAvMedAlderspensjon = LocalDate.of(2025, 6, 10), tidspunkt = Instant.parse("2024-08-01T05:06:07Z"), ) @@ -119,8 +124,11 @@ internal class InntektsjusteringRiverTest { aar shouldBe 2025 arbeidsinntekt shouldBe 100 naeringsinntekt shouldBe 200 - arbeidsinntektUtland shouldBe 300 - naeringsinntektUtland shouldBe 400 + inntektFraUtland shouldBe 300 + afpInntekt shouldBe 400 + afpInntektAFPTjenesteordning shouldBe "tjenesteordning" + skalGaaAvMedAlderspensjon shouldBe "JA" + datoForAaGaaAvMedAlderspensjon shouldBe "10.06.2025" tidspunkt shouldBe "01.08.2024 05:06:07" } } diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml index 389ae0938dc..c7458f6fb98 100644 --- a/gradle/libs.versions.toml +++ b/gradle/libs.versions.toml @@ -57,7 +57,7 @@ ktor2-serverresources = { module = "io.ktor:ktor-server-resources", version.ref ktor2-servertests = { module = "io.ktor:ktor-server-tests", version.ref = "ktor2-version" } ktor2-webjars = { module = "io.ktor:ktor-server-webjars", version.ref = "ktor2-version" } -etterlatte-common = { module = "pensjon-etterlatte-felles:common", version = "2024.10.07-13.10.e0f33c581243" } +etterlatte-common = { module = "pensjon-etterlatte-felles:common", version = "2024.10.16-15.39.2e7626cfbcf3" } teamdokumenthandtering-avroschemas = { module = "no.nav.teamdokumenthandtering:teamdokumenthandtering-avro-schemas", version = "08c0b2d2" } logging-slf4japi = { module = "org.slf4j:slf4j-api", version = "2.0.16" }