Legg til endepunkt for å kunne hente uncached inntekt

Author: ArselanSultani

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

@@ -32,6 +32,7 @@ import no.nav.dagpenger.inntekt.db.StoreInntektCommand
 import no.nav.dagpenger.inntekt.db.StoredInntektMedMetadata
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.AktoerType
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektkomponentRequest
+import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektkomponentResponse
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektskomponentClient
 import no.nav.dagpenger.inntekt.mapping.GUIInntekt
 import no.nav.dagpenger.inntekt.mapping.Inntektsmottaker
@@ -294,55 +295,59 @@ fun Route.uklassifisertInntekt(
                     val inntektId = InntektId(call.parameters["inntektId"]!!)
                     logger.info { "Henter nye inntekt for $inntektId" }
 
-                    call.withInntektRequest("GET /uklassifisert/uncached/") {
-                        inntektStore
-                            .getStoredInntektMedMetadata(inntektId)
-                            .let { storedInntektMedMetadata ->
-                                logger.info { "Henter stored inntekt: ${storedInntektMedMetadata.inntektId}" }
-                                val person = personOppslag.hentPerson(storedInntektMedMetadata.fødselsnummer)
-                                val opptjeningsperiode = Opptjeningsperiode(storedInntektMedMetadata.beregningsdato)
+                    inntektStore
+                        .getStoredInntektMedMetadata(inntektId)
+                        .let { storedInntektMedMetadata ->
+                            logger.info { "Henter stored inntekt: ${storedInntektMedMetadata.inntektId}" }
+                            val person = personOppslag.hentPerson(storedInntektMedMetadata.fødselsnummer)
+                            val opptjeningsperiode = Opptjeningsperiode(storedInntektMedMetadata.beregningsdato)
 
-                                toInntektskomponentRequest(person, opptjeningsperiode)
-                                    .let {
-                                        logger.info { "Henter nye inntekter fra inntektskomponenten" }
-                                        inntektskomponentClient.getInntekt(it, callId = callId)
-                                    }.let {
-                                        logger.info { "Fikk nye inntekter fra inntektskomponenten" }
-                                        val inntektsmottaker =
-                                            Inntektsmottaker(person.fødselsnummer, person.sammensattNavn())
-                                        val organisasjoner =
-                                            hentOrganisasjoner(
-                                                enhetsregisterClient,
-                                                it.arbeidsInntektMaaned
-                                                    ?.flatMap { it.arbeidsInntektInformasjon?.inntektListe.orEmpty() }
-                                                    ?.filter { inntekt ->
-                                                        inntekt.virksomhet?.aktoerType == AktoerType.ORGANISASJON &&
-                                                            (inntekt.opptjeningsland == "NO" || inntekt.opptjeningsland == null)
-                                                    }?.mapNotNull { it.virksomhet?.identifikator }
-                                                    ?.toTypedArray()
-                                                    ?.toList() ?: emptyList(),
-                                            )
+                            toInntektskomponentRequest(person, opptjeningsperiode)
+                                .let {
+                                    logger.info { "Henter nye inntekter fra inntektskomponenten" }
+                                    inntektskomponentClient.getInntekt(it, callId = callId)
+                                }.let {
+                                    logger.info { "Fikk nye inntekter fra inntektskomponenten" }
+                                    val inntektsmottaker =
+                                        Inntektsmottaker(person.fødselsnummer, person.sammensattNavn())
+                                    val organisasjoner =
+                                        hentOrganisasjoner(
+                                            enhetsregisterClient,
+                                            it.arbeidsInntektMaaned
+                                                ?.flatMap { it.arbeidsInntektInformasjon?.inntektListe.orEmpty() }
+                                                ?.filter { inntekt ->
+                                                    inntekt.virksomhet?.aktoerType == AktoerType.ORGANISASJON &&
+                                                        (inntekt.opptjeningsland == "NO" || inntekt.opptjeningsland == null)
+                                                }?.mapNotNull { it.virksomhet?.identifikator }
+                                                ?.toTypedArray()
+                                                ?.toList() ?: emptyList(),
+                                        )
 
-                                        it.mapToFrontend(
-                                            person = inntektsmottaker,
-                                            organisasjoner = organisasjoner,
-                                            storedInntektMedMetadata =
-                                                StoredInntektMedMetadata(
-                                                    inntektId = inntektId,
-                                                    fødselsnummer = storedInntektMedMetadata.fødselsnummer,
-                                                    inntekt = it,
-                                                    manueltRedigert = false,
-                                                    timestamp = storedInntektMedMetadata.timestamp,
-                                                    beregningsdato = storedInntektMedMetadata.beregningsdato,
-                                                    storedInntektPeriode = storedInntektMedMetadata.storedInntektPeriode,
-                                                    begrunnelse = "",
-                                                ),
+                                    val kombinerFraInntektskomponentenOgStoredInntekt =
+                                        kombinerInntektFraInntektskomponentenOgStoredInntekt(
+                                            it,
+                                            storedInntektMedMetadata.inntekt,
                                         )
-                                    }.let {
-                                        call.respond(HttpStatusCode.OK, it)
-                                    }.also { inntektOppfriskingCounter.inc() }
-                            } ?: throw InntektNotFoundException("Inntekt with id $inntektId not found.")
-                    }
+
+                                    it.mapToFrontend(
+                                        person = inntektsmottaker,
+                                        organisasjoner = organisasjoner,
+                                        storedInntektMedMetadata =
+                                            StoredInntektMedMetadata(
+                                                inntektId = inntektId,
+                                                fødselsnummer = storedInntektMedMetadata.fødselsnummer,
+                                                inntekt = kombinerFraInntektskomponentenOgStoredInntekt,
+                                                manueltRedigert = false,
+                                                timestamp = storedInntektMedMetadata.timestamp,
+                                                beregningsdato = storedInntektMedMetadata.beregningsdato,
+                                                storedInntektPeriode = storedInntektMedMetadata.storedInntektPeriode,
+                                                begrunnelse = "",
+                                            ),
+                                    )
+                                }.let {
+                                    call.respond(HttpStatusCode.OK, it)
+                                }.also { inntektOppfriskingCounter.inc() }
+                        } ?: throw InntektNotFoundException("Inntekt with id $inntektId not found.")
                 }
             }
         }
@@ -354,6 +359,37 @@ fun Route.uklassifisertInntekt(
     }
 }
 
+fun kombinerInntektFraInntektskomponentenOgStoredInntekt(
+    inntektkomponentenInntekt: InntektkomponentResponse,
+    storedInntektMedMetadata: InntektkomponentResponse,
+): InntektkomponentResponse {
+    val arbeidsInntektMåned = inntektkomponentenInntekt.arbeidsInntektMaaned ?: emptyList()
+    val storedArbeidsInntektMåned = storedInntektMedMetadata.arbeidsInntektMaaned ?: emptyList()
+
+    storedArbeidsInntektMåned.map { storedInntektMåned ->
+        val inntektKomponentMåned = arbeidsInntektMåned.find { it.aarMaaned == storedInntektMåned.aarMaaned }
+        if (inntektKomponentMåned != null) {
+            inntektKomponentMåned.arbeidsInntektInformasjon?.inntektListe.orEmpty().forEach { inntekt ->
+                val matchIndex =
+                    storedInntektMåned.arbeidsInntektInformasjon
+                        ?.inntektListe
+                        ?.indexOfFirst {
+                            it.virksomhet?.identifikator == inntekt.virksomhet?.identifikator &&
+                                it.utbetaltIMaaned == inntekt.utbetaltIMaaned &&
+                                it.beskrivelse == inntekt.beskrivelse
+                        }
+                if (matchIndex != null && matchIndex >= 0) {
+                    storedInntektMåned.arbeidsInntektInformasjon.inntektListe.let {
+                        it.toMutableList()[matchIndex] = inntekt
+                    }
+                }
+            }
+        }
+    }
+
+    return storedInntektMedMetadata
+}
+
 private suspend fun hentOrganisasjoner(
     enhetsregisterClient: EnhetsregisterClient,
     organisasjonsNummerListe: List<String>?,