Lagre inntekt (WiP, squash før merge)

Co-authored-by: John Martin Lindseth <[email protected]>

Author: vskjefst

buildSrc/src/main/kotlin/common.gradle.kts

@@ -1,6 +1,6 @@
 import org.gradle.api.tasks.testing.logging.TestExceptionFormat
-import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
 import org.gradle.api.tasks.testing.logging.TestLogEvent
+import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
 
 plugins {
     kotlin("jvm")

dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/Application.kt

@@ -47,15 +47,16 @@ fun main() {
         val cachedInntektsGetter = BehandlingsInntektsGetter(inntektskomponentHttpClient, postgresInntektStore)
         // Marks inntekt as used
         val subsumsjonBruktDataConsumer =
-            KafkaSubsumsjonBruktDataConsumer(config, postgresInntektStore).apply {
-                listen()
-            }.also {
-                Runtime.getRuntime().addShutdownHook(
-                    Thread {
-                        it.stop()
-                    },
-                )
-            }
+            KafkaSubsumsjonBruktDataConsumer(config, postgresInntektStore)
+                .apply {
+                    listen()
+                }.also {
+                    Runtime.getRuntime().addShutdownHook(
+                        Thread {
+                            it.stop()
+                        },
+                    )
+                }
 
         // Provides a HTTP API for getting inntekt
         embeddedServer(Netty, port = config.application.httpPort) {

dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/mapping/GUIInntektsKomponentResponse.kt

@@ -21,7 +21,7 @@ data class GUIInntekt(
 )
 
 data class Inntektsmottaker(
-    val pnr: String?,
+    val fnr: String?,
     val navn: String?,
 )
 

dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/mapping/MapFromGUIInntekt.kt

@@ -1,19 +1,18 @@
 package no.nav.dagpenger.inntekt.mapping
 
 import de.huxhorn.sulky.ulid.ULID
-import mu.KotlinLogging
 import no.nav.dagpenger.inntekt.db.DetachedInntekt
 import no.nav.dagpenger.inntekt.db.InntektId
 import no.nav.dagpenger.inntekt.db.StoredInntekt
+import no.nav.dagpenger.inntekt.inntektskomponenten.v1.Aktoer
+import no.nav.dagpenger.inntekt.inntektskomponenten.v1.AktoerType
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.ArbeidsInntektInformasjon
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.ArbeidsInntektMaaned
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.Inntekt
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektkomponentResponse
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.TilleggInformasjon
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.TilleggInformasjonsDetaljer
-
-private val logg = KotlinLogging.logger {}
-private val sikkerlogg = KotlinLogging.logger("tjenestekall.MapFromGUIInntekt")
+import java.time.LocalDateTime.now
 
 fun mapToStoredInntekt(guiInntekt: GUIInntekt): StoredInntekt =
     StoredInntekt(
@@ -26,6 +25,17 @@ fun mapToStoredInntekt(guiInntekt: GUIInntekt): StoredInntekt =
         guiInntekt.manueltRedigert,
     )
 
+fun mapToStoredInntekt(
+    inntekterDto: InntekterDto,
+    inntektId: String,
+): StoredInntekt =
+    StoredInntekt(
+        inntektId = InntektId(id = inntektId),
+        inntekt = mapToInntektkomponentResponse(inntekterDto),
+        manueltRedigert = true,
+        timestamp = now(),
+    )
+
 fun mapToDetachedInntekt(guiInntekt: GUIInntekt): DetachedInntekt =
     DetachedInntekt(
         InntektkomponentResponse(
@@ -36,13 +46,66 @@ fun mapToDetachedInntekt(guiInntekt: GUIInntekt): DetachedInntekt =
         guiInntekt.manueltRedigert,
     )
 
-private fun mapToArbeidsInntektMaaneder(arbeidsMaaneder: List<GUIArbeidsInntektMaaned>?): List<ArbeidsInntektMaaned>? {
-    return arbeidsMaaneder?.map { GUIarbeidsInntektMaaned ->
+private fun mapToInntektkomponentResponse(inntekterDto: InntekterDto): InntektkomponentResponse {
+    val arbeidsInntektMaaneder: MutableList<ArbeidsInntektMaaned> = mutableListOf()
+
+    inntekterDto.virksomheter.forEach { virksomhet ->
+        arbeidsInntektMaaneder.addAll(
+            virksomhet.inntekter?.map {
+                ArbeidsInntektMaaned(
+                    it.aarMaaned,
+                    virksomhet.avvikListe,
+                    ArbeidsInntektInformasjon(
+                        virksomhet.inntekter.map { inntektMaaned ->
+                            Inntekt(
+                                inntektMaaned.belop,
+                                inntektMaaned.inntektskilde,
+                                inntektMaaned.beskrivelse,
+                                inntektMaaned.inntektskilde,
+                                inntektMaaned.inntektsstatus,
+                                inntektMaaned.inntektsperiodetype ?: "Maaned",
+                                inntektMaaned.leveringstidspunkt,
+                                inntektMaaned.opptjeningsland,
+                                inntektMaaned.opptjeningsperiode,
+                                inntektMaaned.skattemessigBosattLand,
+                                inntektMaaned.utbetaltIMaaned,
+                                // TODO: Er det mottaker som skal brukes her?
+                                mapToAktoerNaturligIdent(inntekterDto.mottaker.fnr),
+                                // TODO: Er det virksomhet som skal brukes her?
+                                mapToAktoerOrganisasjon(virksomhet),
+                                mapToAktoerOrganisasjon(virksomhet),
+                                mapToAktoerNaturligIdent(inntekterDto.mottaker.fnr),
+                                inntektMaaned.inngaarIGrunnlagForTrekk,
+                                inntektMaaned.utloeserArbeidsgiveravgift,
+                                inntektMaaned.informasjonsstatus,
+                                inntektMaaned.inntektType,
+                                inntektMaaned.tilleggsinformasjon,
+                            )
+                        },
+                    ),
+                )
+            } ?: listOf(),
+        )
+    }
+
+    return InntektkomponentResponse(
+        arbeidsInntektMaaneder,
+        mapToAktoerNaturligIdent(inntekterDto.mottaker.fnr),
+    )
+}
+
+private fun mapToAktoerOrganisasjon(virksomhet: Virksomhet): Aktoer = Aktoer(AktoerType.ORGANISASJON, virksomhet.virksomhetsnummer)
+
+private fun mapToAktoerNaturligIdent(fnr: String?): Aktoer =
+    Aktoer(AktoerType.NATURLIG_IDENT, fnr ?: throw IllegalArgumentException("Fødselsenummer mangler"))
+
+private fun mapToArbeidsInntektMaaneder(arbeidsMaaneder: List<GUIArbeidsInntektMaaned>?): List<ArbeidsInntektMaaned>? =
+    arbeidsMaaneder?.map { guiArbeidsInntektMaaned ->
         ArbeidsInntektMaaned(
-            GUIarbeidsInntektMaaned.aarMaaned,
-            GUIarbeidsInntektMaaned.avvikListe,
+            guiArbeidsInntektMaaned.aarMaaned,
+            guiArbeidsInntektMaaned.avvikListe,
             ArbeidsInntektInformasjon(
-                GUIarbeidsInntektMaaned.arbeidsInntektInformasjon?.inntektListe?.map { inntekt ->
+                guiArbeidsInntektMaaned.arbeidsInntektInformasjon?.inntektListe?.map { inntekt ->
                     val datagrunnlagForVerdikode: DatagrunnlagKlassifisering = dataGrunnlag(inntekt.verdikode)
                     Inntekt(
                         inntekt.beloep,
@@ -78,4 +141,3 @@ private fun mapToArbeidsInntektMaaneder(arbeidsMaaneder: List<GUIArbeidsInntektM
             ),
         )
     }
-}

dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/mapping/MapToInntektFrontend.kt

@@ -5,16 +5,17 @@ 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 java.math.BigDecimal
 import java.time.YearMonth
 
 fun InntektkomponentResponse.mapToFrontend(
     person: Inntektsmottaker,
     organisasjonsInfoListe: MutableList<OrganisasjonNavnOgIdMapping>,
-): InntekterResponse {
+): InntekterDto {
     val inntekt = arbeidsInntektMaaned
-    val virksomhetListe: MutableList<Virksomhet> = mutableListOf()
+    val virksomheter: MutableList<Virksomhet> = mutableListOf()
 
     inntekt?.forEach { arbeidsInntektMaaned ->
         val inntektsInformasjon = arbeidsInntektMaaned.arbeidsInntektInformasjon
@@ -34,10 +35,12 @@ fun InntektkomponentResponse.mapToFrontend(
                     fordel = inntekt.fordel,
                     beskrivelse = inntekt.beskrivelse,
                     inntektsstatus = inntekt.inntektsstatus,
+                    inntektsperiodetype = inntekt.inntektsperiodetype,
                     utbetaltIMaaned = inntekt.utbetaltIMaaned,
                     inntektType = inntekt.inntektType,
                     leveringstidspunkt = inntekt.leveringstidspunkt,
                     opptjeningsland = inntekt.opptjeningsland,
+                    opptjeningsperiode = inntekt.opptjeningsperiode,
                     skattemessigBosattLand = inntekt.skattemessigBosattLand,
                     inntektsinnsender = inntekt.inntektsinnsender,
                     virksomhet = inntekt.virksomhet,
@@ -50,7 +53,7 @@ fun InntektkomponentResponse.mapToFrontend(
             )
 
             val eksisterendeVirksomhet =
-                virksomhetListe.find { it.virksomhetsnummer == virksomhet?.identifikator }
+                virksomheter.find { it.virksomhetsnummer == virksomhet?.identifikator }
             if (eksisterendeVirksomhet != null) {
                 eksisterendeVirksomhet.inntekter?.addAll(inntekter)
                 eksisterendeVirksomhet.periode =
@@ -60,7 +63,7 @@ fun InntektkomponentResponse.mapToFrontend(
                     )
                 eksisterendeVirksomhet.totalBeløp = eksisterendeVirksomhet.inntekter.sumOf { it.belop }
             } else {
-                virksomhetListe.add(
+                virksomheter.add(
                     Virksomhet(
                         virksomhetsnummer = virksomhet?.identifikator ?: "",
                         virksomhetsnavn = virksomhetNavn,
@@ -79,14 +82,14 @@ fun InntektkomponentResponse.mapToFrontend(
         }
     }
 
-    return InntekterResponse(
-        virksomhetsinntekt = virksomhetListe,
+    return InntekterDto(
+        virksomheter = virksomheter,
         mottaker = person,
     )
 }
 
-data class InntekterResponse(
-    val virksomhetsinntekt: List<Virksomhet>,
+data class InntekterDto(
+    val virksomheter: List<Virksomhet>,
     val mottaker: Inntektsmottaker,
 )
 
@@ -110,8 +113,10 @@ data class InntektMaaned(
     val beskrivelse: InntektBeskrivelse,
     val inntektskilde: String,
     val inntektsstatus: String,
+    val inntektsperiodetype: String?,
     val leveringstidspunkt: YearMonth? = null,
     val opptjeningsland: String? = null,
+    val opptjeningsperiode: Periode? = null,
     val skattemessigBosattLand: String? = null,
     val utbetaltIMaaned: YearMonth,
     val inntektsinnsender: Aktoer? = null,

dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/v1/UklassifisertInntektRoute.kt

@@ -28,6 +28,7 @@ import no.nav.dagpenger.inntekt.inntektskomponenten.v1.AktoerType
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektkomponentRequest
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektskomponentClient
 import no.nav.dagpenger.inntekt.mapping.GUIInntekt
+import no.nav.dagpenger.inntekt.mapping.InntekterDto
 import no.nav.dagpenger.inntekt.mapping.Inntektsmottaker
 import no.nav.dagpenger.inntekt.mapping.OrganisasjonNavnOgIdMapping
 import no.nav.dagpenger.inntekt.mapping.dataGrunnlagKlassifiseringToVerdikode
@@ -167,6 +168,40 @@ fun Route.uklassifisertInntekt(
                         }
                 }
             }
+            post {
+                withContext(Dispatchers.IO) {
+                    mapToStoredInntekt(
+                        inntekterDto = call.receive<InntekterDto>(),
+                        inntektId = call.parameters["inntektId"]!!,
+                    ).let {
+                        val person = personOppslag.hentPerson(it.inntekt.ident.identifikator)
+                        inntektStore.storeInntekt(
+                            StoreInntektCommand(
+                                inntektparametre =
+                                    Inntektparametre(
+                                        aktørId = person.aktørId,
+                                        fødselsnummer = person.fødselsnummer,
+                                        // TODO: Hent ut dette fra databasen: RegelKontekst(this.kontekstId, this.kontekstType),
+                                        regelkontekst = RegelKontekst("KONTEKSTID", "KONTEKSTTYPE"),
+                                        // TODO: Hent ut dette fra databasen også.
+                                        beregningsdato = LocalDate.now(),
+                                    ),
+                                inntekt = it.inntekt,
+                                manueltRedigert =
+                                    ManueltRedigert.from(
+                                        // TODO: Riktig verdi her, alltid true, kanskje?
+                                        true,
+                                        call.getSubject(),
+                                    ),
+                            ),
+                        )
+                    }.let {
+                        call.respond(HttpStatusCode.OK)
+                    }.also {
+                        inntektKorrigeringCounter.inc()
+                    }
+                }
+            }
         }
 
         route("/uklassifisert/uncached/{aktørId}/{kontekstType}/{kontekstId}/{beregningsDato}") {

dp-inntekt-api/src/test/kotlin/no/nav/dagpenger/inntekt/mapping/MapToInntektFrontendTest.kt

@@ -166,7 +166,7 @@ val inntektkomponentResponse =
 
 val mottaker =
     Inntektsmottaker(
-        pnr = "2044350291600",
+        fnr = "2044350291600",
         navn = "Ola Nordmann",
     )
 
@@ -191,39 +191,39 @@ class MapToInntektFrontendTest {
                 organisasjonNavnOgIdMappingForTesting,
             )
 
-        assertEquals(2, mappedToInntektFrontend.virksomhetsinntekt.size)
+        assertEquals(2, mappedToInntektFrontend.virksomheter.size)
         assertEquals(mottaker, mappedToInntektFrontend.mottaker)
 
-        assertTrue { mappedToInntektFrontend.virksomhetsinntekt.any { it.virksomhetsnummer == "896929119" } }
-        assertTrue { mappedToInntektFrontend.virksomhetsinntekt.any { it.virksomhetsnummer == "896929120" } }
-        assertFalse { mappedToInntektFrontend.virksomhetsinntekt.any { it.virksomhetsnummer == "8969291001" } }
+        assertTrue { mappedToInntektFrontend.virksomheter.any { it.virksomhetsnummer == "896929119" } }
+        assertTrue { mappedToInntektFrontend.virksomheter.any { it.virksomhetsnummer == "896929120" } }
+        assertFalse { mappedToInntektFrontend.virksomheter.any { it.virksomhetsnummer == "8969291001" } }
 
         assertEquals(
             2,
-            mappedToInntektFrontend.virksomhetsinntekt
+            mappedToInntektFrontend.virksomheter
                 .filter { it.virksomhetsnummer == "896929119" }[0]
                 .inntekter
                 ?.size,
         )
 
         assertEquals(
             BigDecimal(100000),
-            mappedToInntektFrontend.virksomhetsinntekt
+            mappedToInntektFrontend.virksomheter
                 .filter { it.virksomhetsnummer == "896929119" }[0]
                 .totalBeløp,
         )
 
         assertEquals(
             1,
-            mappedToInntektFrontend.virksomhetsinntekt
+            mappedToInntektFrontend.virksomheter
                 .filter { it.virksomhetsnummer == "896929120" }[0]
                 .inntekter
                 ?.size,
         )
 
         assertEquals(
             BigDecimal(50000),
-            mappedToInntektFrontend.virksomhetsinntekt
+            mappedToInntektFrontend.virksomheter
                 .filter { it.virksomhetsnummer == "896929120" }[0]
                 .totalBeløp,
         )
@@ -332,9 +332,9 @@ class MapToInntektFrontendTest {
 
         val mapTilFrontendMedNullVirksomhet =
             inntektkomponentResponseMedTomVirksomhet.mapToFrontend(mottaker, organisasjonNavnOgIdMappingForTesting)
-        assertEquals(3, mapTilFrontendMedNullVirksomhet.virksomhetsinntekt.size)
-        assertEquals(2, mapTilFrontendMedNullVirksomhet.virksomhetsinntekt.filter { it.virksomhetsnummer == "" }.size)
-        assertEquals(1, mapTilFrontendMedNullVirksomhet.virksomhetsinntekt.filter { it.virksomhetsnummer == "896929120" }.size)
+        assertEquals(3, mapTilFrontendMedNullVirksomhet.virksomheter.size)
+        assertEquals(2, mapTilFrontendMedNullVirksomhet.virksomheter.filter { it.virksomhetsnummer == "" }.size)
+        assertEquals(1, mapTilFrontendMedNullVirksomhet.virksomheter.filter { it.virksomhetsnummer == "896929120" }.size)
 
         jacksonObjectMapper.writeValueAsString(mapTilFrontendMedNullVirksomhet)
         println(

dp-inntekt-api/src/test/kotlin/no/nav/dagpenger/inntekt/v1/UklassifisertInntektRouteTest.kt

@@ -33,7 +33,7 @@ import no.nav.dagpenger.inntekt.mapping.GUIArbeidsInntektMaaned
 import no.nav.dagpenger.inntekt.mapping.GUIInntekt
 import no.nav.dagpenger.inntekt.mapping.GUIInntektsKomponentResponse
 import no.nav.dagpenger.inntekt.mapping.InntektMedVerdikode
-import no.nav.dagpenger.inntekt.mapping.InntekterResponse
+import no.nav.dagpenger.inntekt.mapping.InntekterDto
 import no.nav.dagpenger.inntekt.oppslag.Person
 import no.nav.dagpenger.inntekt.oppslag.PersonOppslag
 import no.nav.dagpenger.inntekt.oppslag.enhetsregister.EnhetsregisterClient
@@ -487,13 +487,13 @@ internal class UklassifisertInntektRouteTest {
 
             assertEquals(HttpStatusCode.OK, response.status)
             val storedInntekt =
-                jacksonObjectMapper.readValue<InntekterResponse>(response.bodyAsText())
-            assertEquals(2, storedInntekt.virksomhetsinntekt.size)
-            assertEquals(4, storedInntekt.virksomhetsinntekt[0].inntekter?.size)
-            assertEquals("1111111", storedInntekt.virksomhetsinntekt.first().virksomhetsnummer)
-            assertEquals("Test Org", storedInntekt.virksomhetsinntekt.first().virksomhetsnavn)
-            assertEquals("2222222", storedInntekt.virksomhetsinntekt[1].virksomhetsnummer)
-            assertEquals("", storedInntekt.virksomhetsinntekt[1].virksomhetsnavn)
+                jacksonObjectMapper.readValue<InntekterDto>(response.bodyAsText())
+            assertEquals(2, storedInntekt.virksomheter.size)
+            assertEquals(4, storedInntekt.virksomheter[0].inntekter?.size)
+            assertEquals("1111111", storedInntekt.virksomheter.first().virksomhetsnummer)
+            assertEquals("Test Org", storedInntekt.virksomheter.first().virksomhetsnavn)
+            assertEquals("2222222", storedInntekt.virksomheter[1].virksomhetsnummer)
+            assertEquals("", storedInntekt.virksomheter[1].virksomhetsnavn)
         }
     }
 }