Legg til endepunkt for lagring av inntekt

Dette endepunktet skal brukes av den nye frontenden.
Inkludert mapping fra dto til intern klasse.

Co-authored-by: Vegard Skjefstad <[email protected]>
Co-authored-by: Arselan.Sultani <[email protected]>
Co-authored-by: John Martin Lindseth <[email protected]>

Author: 3 people

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/db/InntektStore.kt

@@ -18,6 +18,8 @@ interface InntektStore {
 
     fun getBeregningsdato(inntektId: InntektId): LocalDate
 
+    fun getInntektPersonMapping(inntektId: String): InntektPersonMapping
+
     fun storeInntekt(
         command: StoreInntektCommand,
         created: ZonedDateTime = ZonedDateTime.now(ZoneOffset.UTC),
@@ -52,6 +54,16 @@ data class StoreInntektCommand(
     val manueltRedigert: ManueltRedigert? = null,
 )
 
+data class InntektPersonMapping(
+    val inntektId: InntektId,
+    val aktørId: String,
+    val fnr: String? = null,
+    val kontekstId: String,
+    val beregningsdato: LocalDate,
+    val timestamp: LocalDateTime,
+    val kontekstType: String,
+)
+
 data class ManueltRedigert(
     val redigertAv: String,
 ) {

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

@@ -93,6 +93,30 @@ internal class PostgresInntektStore(
         }
     }
 
+    override fun getInntektPersonMapping(inntektId: String): InntektPersonMapping {
+        @Language("sql")
+        val statement = "SELECT * FROM inntekt_V1_person_mapping WHERE inntektId = :inntektId)".trimMargin()
+
+        return using(sessionOf(dataSource)) { session ->
+            session.run(
+                queryOf(
+                    statement,
+                    mapOf("inntektId" to inntektId),
+                ).map { row ->
+                    InntektPersonMapping(
+                        inntektId = InntektId(row.string("inntektid")),
+                        aktørId = row.string("aktorid"),
+                        fnr = row.string("fnr"),
+                        kontekstId = row.string("kontekstid"),
+                        beregningsdato = row.zonedDateTime("beregningsdato").toLocalDate(),
+                        timestamp = row.zonedDateTime("timestamp").toLocalDateTime(),
+                        kontekstType = row.string("konteksttype"),
+                    )
+                }.asSingle,
+            ) ?: throw InntektNotFoundException("Inntekt with id $inntektId not found.")
+        }
+    }
+
     override fun getBeregningsdato(inntektId: InntektId): LocalDate {
         @Language("sql")
         val statement =

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

@@ -1,7 +1,6 @@
 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
@@ -12,9 +11,6 @@ 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")
-
 fun mapToStoredInntekt(guiInntekt: GUIInntekt): StoredInntekt =
     StoredInntekt(
         guiInntekt.inntektId ?: InntektId(ULID().nextULID()),
@@ -36,13 +32,13 @@ fun mapToDetachedInntekt(guiInntekt: GUIInntekt): DetachedInntekt =
         guiInntekt.manueltRedigert,
     )
 
-private fun mapToArbeidsInntektMaaneder(arbeidsMaaneder: List<GUIArbeidsInntektMaaned>?): List<ArbeidsInntektMaaned>? {
-    return arbeidsMaaneder?.map { GUIarbeidsInntektMaaned ->
+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 +74,3 @@ private fun mapToArbeidsInntektMaaneder(arbeidsMaaneder: List<GUIArbeidsInntektM
             ),
         )
     }
-}

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

@@ -5,16 +5,18 @@ 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.v1.models.InntekterDto
 import java.math.BigDecimal
 import java.time.YearMonth
 
 fun InntektkomponentResponse.mapToFrontend(
     person: Inntektsmottaker,
-    organisasjonsInfoListe: MutableList<OrganisasjonNavnOgIdMapping>,
-): InntekterResponse {
+    organisasjonsInfoListe: List<OrganisasjonNavnOgIdMapping>,
+): InntekterDto {
     val inntekt = arbeidsInntektMaaned
-    val virksomhetListe: MutableList<Virksomhet> = mutableListOf()
+    val virksomheter: MutableList<Virksomhet> = mutableListOf()
 
     inntekt?.forEach { arbeidsInntektMaaned ->
         val inntektsInformasjon = arbeidsInntektMaaned.arbeidsInntektInformasjon
@@ -34,10 +36,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 +54,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 +64,7 @@ fun InntektkomponentResponse.mapToFrontend(
                     )
                 eksisterendeVirksomhet.totalBeløp = eksisterendeVirksomhet.inntekter.sumOf { it.belop }
             } else {
-                virksomhetListe.add(
+                virksomheter.add(
                     Virksomhet(
                         virksomhetsnummer = virksomhet?.identifikator ?: "",
                         virksomhetsnavn = virksomhetNavn,
@@ -79,17 +83,12 @@ fun InntektkomponentResponse.mapToFrontend(
         }
     }
 
-    return InntekterResponse(
-        virksomhetsinntekt = virksomhetListe,
+    return InntekterDto(
+        virksomheter = virksomheter,
         mottaker = person,
     )
 }
 
-data class InntekterResponse(
-    val virksomhetsinntekt: List<Virksomhet>,
-    val mottaker: Inntektsmottaker,
-)
-
 data class Virksomhet(
     val virksomhetsnummer: String,
     val virksomhetsnavn: String,
@@ -110,10 +109,13 @@ 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 opplysningspliktig: Aktoer? = null,
     val inntektsinnsender: Aktoer? = null,
     val virksomhet: Aktoer? = null,
     val inntektsmottaker: Aktoer? = null,

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

@@ -18,6 +18,7 @@ import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.withContext
 import mu.KotlinLogging
 import mu.withLoggingContext
+import no.nav.dagpenger.inntekt.db.InntektId
 import no.nav.dagpenger.inntekt.db.InntektNotFoundException
 import no.nav.dagpenger.inntekt.db.InntektStore
 import no.nav.dagpenger.inntekt.db.Inntektparametre
@@ -39,7 +40,10 @@ import no.nav.dagpenger.inntekt.oppslag.Person
 import no.nav.dagpenger.inntekt.oppslag.PersonOppslag
 import no.nav.dagpenger.inntekt.oppslag.enhetsregister.EnhetsregisterClient
 import no.nav.dagpenger.inntekt.opptjeningsperiode.Opptjeningsperiode
+import no.nav.dagpenger.inntekt.v1.models.InntekterDto
+import no.nav.dagpenger.inntekt.v1.models.mapToStoredInntekt
 import java.time.LocalDate
+import kotlin.coroutines.CoroutineContext
 
 private val logger = KotlinLogging.logger {}
 const val INNTEKT_KORRIGERING = "inntekt_korrigering"
@@ -69,11 +73,12 @@ fun Route.uklassifisertInntekt(
     inntektStore: InntektStore,
     personOppslag: PersonOppslag,
     enhetsregisterClient: EnhetsregisterClient,
+    coroutineContext: CoroutineContext = Dispatchers.IO,
 ) {
     authenticate("azure") {
         route("/uklassifisert/{aktørId}/{kontekstType}/{kontekstId}/{beregningsDato}") {
             get {
-                withContext(Dispatchers.IO) {
+                withContext(coroutineContext) {
                     call.withInntektRequest("GET /uklassifisert/") {
                         val person = personOppslag.hentPerson(this.aktørId)
                         inntektStore
@@ -96,7 +101,7 @@ fun Route.uklassifisertInntekt(
                 }
             }
             post {
-                withContext(Dispatchers.IO) {
+                withContext(coroutineContext) {
                     call.withInntektRequest("POST /uklassifisert/") {
                         val person = personOppslag.hentPerson(this.aktørId)
                         val guiInntekt = call.receive<GUIInntekt>()
@@ -138,12 +143,8 @@ fun Route.uklassifisertInntekt(
 
         route("/uklassifisert/{inntektId}") {
             get {
-                withContext(Dispatchers.IO) {
-                    val inntektId =
-                        call.parameters["inntektId"]?.let {
-                            no.nav.dagpenger.inntekt.db
-                                .InntektId(it)
-                        } ?: throw IllegalArgumentException("Missing inntektId")
+                withContext(coroutineContext) {
+                    val inntektId = InntektId(call.parameters["inntektId"]!!)
                     inntektStore
                         .getInntektMedPersonFnr(inntektId)
                         .let {
@@ -167,12 +168,49 @@ fun Route.uklassifisertInntekt(
                         }
                 }
             }
+            post {
+                withContext(coroutineContext) {
+                    val inntektId = call.parameters["inntektId"]!!
+                    call
+                        .receive<InntekterDto>()
+                        .mapToStoredInntekt(
+                            inntektId = inntektId,
+                        ).let {
+                            val inntektPersonMapping = inntektStore.getInntektPersonMapping(inntektId)
+                            inntektStore.storeInntekt(
+                                StoreInntektCommand(
+                                    inntektparametre =
+                                        Inntektparametre(
+                                            aktørId = inntektPersonMapping.aktørId,
+                                            fødselsnummer = it.inntekt.ident.identifikator,
+                                            regelkontekst =
+                                                RegelKontekst(
+                                                    inntektPersonMapping.kontekstId,
+                                                    inntektPersonMapping.kontekstType,
+                                                ),
+                                            beregningsdato = inntektPersonMapping.beregningsdato,
+                                        ),
+                                    inntekt = it.inntekt,
+                                    manueltRedigert =
+                                        ManueltRedigert.from(
+                                            true,
+                                            call.getSubject(),
+                                        ),
+                                ),
+                            )
+                        }.let {
+                            call.respond(HttpStatusCode.OK, it.inntektId.id)
+                        }.also {
+                            inntektKorrigeringCounter.inc()
+                        }
+                }
+            }
         }
 
         route("/uklassifisert/uncached/{aktørId}/{kontekstType}/{kontekstId}/{beregningsDato}") {
             get {
                 val callId = call.callId
-                withContext(Dispatchers.IO) {
+                withContext(coroutineContext) {
                     call.withInntektRequest("GET /uklassifisert/uncached/") {
                         val person = personOppslag.hentPerson(this.aktørId)
                         val opptjeningsperiode = Opptjeningsperiode(this.beregningsDato)
@@ -195,7 +233,7 @@ fun Route.uklassifisertInntekt(
             }
 
             post {
-                withContext(Dispatchers.IO) {
+                withContext(coroutineContext) {
                     call.withInntektRequest("POST /uklassifisert/uncached/") {
                         val guiInntekt = call.receive<GUIInntekt>()
                         val person = personOppslag.hentPerson(this.aktørId)
@@ -237,9 +275,7 @@ fun Route.uklassifisertInntekt(
     }
     route("/verdikoder") {
         get {
-            withContext(Dispatchers.IO) {
-                call.respond(HttpStatusCode.OK, dataGrunnlagKlassifiseringToVerdikode.values)
-            }
+            call.respond(HttpStatusCode.OK, dataGrunnlagKlassifiseringToVerdikode.values)
         }
     }
 }