Endepunkt som returnerer klassifisert inntekt

Ny versjon av det som ligger i InntektRoute. Slår sammen aktørId og fnr til personidentifikator, og tar i tillegg inn periodeFraOgMed og periodeTilOgMed, som erstatter periodene utledet av Opptjeningsperiode gitt beregningsDato.

Author: vskjefst

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

@@ -36,6 +36,7 @@ import no.nav.dagpenger.inntekt.api.v1.enhetsregisteret
 import no.nav.dagpenger.inntekt.api.v1.inntekt
 import no.nav.dagpenger.inntekt.api.v1.opptjeningsperiodeApi
 import no.nav.dagpenger.inntekt.api.v1.uklassifisertInntekt
+import no.nav.dagpenger.inntekt.api.v3.inntektV3
 import no.nav.dagpenger.inntekt.db.IllegalInntektIdException
 import no.nav.dagpenger.inntekt.db.InntektNotFoundException
 import no.nav.dagpenger.inntekt.db.InntektStore
@@ -60,7 +61,12 @@ internal fun Application.inntektApi(
     enhetsregisterClient: EnhetsregisterClient,
     healthChecks: List<HealthCheck>,
     collectorRegistry: PrometheusRegistry = PrometheusRegistry.defaultRegistry,
-    meterRegistry: PrometheusMeterRegistry = PrometheusMeterRegistry(PrometheusConfig.DEFAULT, collectorRegistry, Clock.SYSTEM),
+    meterRegistry: PrometheusMeterRegistry =
+        PrometheusMeterRegistry(
+            PrometheusConfig.DEFAULT,
+            collectorRegistry,
+            Clock.SYSTEM,
+        ),
 ) {
     install(DefaultHeaders)
     install(MicrometerMetrics) {
@@ -231,6 +237,11 @@ internal fun Application.inntektApi(
                 }
             }
         }
+        authenticate("azure") {
+            route("/v3/inntekt") {
+                inntektV3(behandlingsInntektsGetter, personOppslag)
+            }
+        }
         naischecks(healthChecks, meterRegistry)
     }
 }

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

@@ -146,7 +146,7 @@ fun Route.uklassifisertInntekt(
                 withContext(coroutineContext) {
                     val inntektId = InntektId(call.parameters["inntektId"]!!)
                     inntektStore
-                        .getInntektMedPersonFnr(inntektId)
+                        .getStoredInntektMedMetadata(inntektId)
                         .let {
                             val person = personOppslag.hentPerson(it.fødselsnummer)
                             val inntektsmottaker = Inntektsmottaker(it.fødselsnummer, person.sammensattNavn())

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

@@ -0,0 +1,55 @@
+package no.nav.dagpenger.inntekt.api.v3
+
+import io.ktor.http.HttpStatusCode
+import io.ktor.server.plugins.callid.callId
+import io.ktor.server.request.receive
+import io.ktor.server.response.respond
+import io.ktor.server.routing.Route
+import io.ktor.server.routing.post
+import io.ktor.server.routing.route
+import kotlinx.coroutines.Dispatchers.IO
+import kotlinx.coroutines.withContext
+import no.nav.dagpenger.inntekt.BehandlingsInntektsGetter
+import no.nav.dagpenger.inntekt.db.Inntektparametre
+import no.nav.dagpenger.inntekt.db.RegelKontekst
+import no.nav.dagpenger.inntekt.oppslag.PersonOppslag
+import java.time.LocalDate
+import java.time.YearMonth
+
+fun Route.inntektV3(
+    behandlingsInntektsGetter: BehandlingsInntektsGetter,
+    personOppslag: PersonOppslag,
+) {
+    route("/klassifisert") {
+        post {
+            withContext(IO) {
+                val inntektRequestDto = call.receive<InntektRequestDto>()
+                val person = personOppslag.hentPerson(inntektRequestDto.personIdentifikator)
+                val inntektparametre =
+                    Inntektparametre(
+                        aktørId = person.aktørId,
+                        fødselsnummer = person.fødselsnummer,
+                        regelkontekst = inntektRequestDto.regelkontekst,
+                        beregningsdato = inntektRequestDto.beregningsDato,
+                    ).apply {
+                        opptjeningsperiode.førsteMåned = inntektRequestDto.periodeFraOgMed
+                        opptjeningsperiode.sisteAvsluttendeKalenderMåned = inntektRequestDto.periodeTilOgMed
+                    }
+                val klassifisertInntekt =
+                    behandlingsInntektsGetter.getKlassifisertInntekt(
+                        inntektparametre,
+                        call.callId,
+                    )
+                call.respond(HttpStatusCode.OK, klassifisertInntekt)
+            }
+        }
+    }
+}
+
+data class InntektRequestDto(
+    val personIdentifikator: String,
+    val regelkontekst: RegelKontekst,
+    val beregningsDato: LocalDate,
+    val periodeFraOgMed: YearMonth,
+    val periodeTilOgMed: YearMonth,
+)

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

@@ -29,7 +29,7 @@ interface InntektStore {
 
     fun markerInntektBrukt(inntektId: InntektId): Int
 
-    fun getInntektMedPersonFnr(inntektId: InntektId): StoredInntektMedFnr
+    fun getStoredInntektMedMetadata(inntektId: InntektId): StoredInntektMedMetadata
 }
 
 data class Inntektparametre(
@@ -102,7 +102,7 @@ data class InntektId(
     }
 }
 
-data class StoredInntektMedFnr(
+data class StoredInntektMedMetadata(
     val inntektId: InntektId,
     val inntekt: InntektkomponentResponse,
     val manueltRedigert: Boolean,

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

@@ -187,7 +187,7 @@ internal class PostgresInntektStore(
         return mapToSpesifisertInntekt(stored.first, Opptjeningsperiode(stored.second).sisteAvsluttendeKalenderMåned)
     }
 
-    override fun getInntektMedPersonFnr(inntektId: InntektId): StoredInntektMedFnr {
+    override fun getStoredInntektMedMetadata(inntektId: InntektId): StoredInntektMedMetadata {
         @Language("sql")
         val statement =
             """ 
@@ -202,7 +202,7 @@ internal class PostgresInntektStore(
             session.run(
                 queryOf(statement, inntektId.id)
                     .map {
-                        StoredInntektMedFnr(
+                        StoredInntektMedMetadata(
                             inntektId = InntektId(it.string("id")),
                             inntekt = it.binaryStream("inntekt").use { jacksonObjectMapper.readValue<InntektkomponentResponse>(it) },
                             manueltRedigert = it.boolean("manuelt_redigert"),

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

@@ -6,7 +6,9 @@ import java.time.YearMonth
 import java.time.ZoneId
 import java.util.Date
 
-data class Opptjeningsperiode(val beregningsdato: LocalDate) {
+data class Opptjeningsperiode(
+    val beregningsdato: LocalDate,
+) {
     private val antattRapporteringsFrist = LocalDate.of(beregningsdato.year, beregningsdato.month, 5)
     private val reellRapporteringsFrist: LocalDate =
         finnFørsteArbeidsdagEtterRapporterteringsFrist(antattRapporteringsFrist)
@@ -16,21 +18,20 @@ data class Opptjeningsperiode(val beregningsdato: LocalDate) {
             else -> 1
         }
 
-    val sisteAvsluttendeKalenderMåned: YearMonth = beregningsdato.minusMonths(månedSubtraksjon).toYearMonth()
-    val førsteMåned: YearMonth = sisteAvsluttendeKalenderMåned.minusMonths(35)
+    var sisteAvsluttendeKalenderMåned: YearMonth = beregningsdato.minusMonths(månedSubtraksjon).toYearMonth()
+    var førsteMåned: YearMonth = sisteAvsluttendeKalenderMåned.minusMonths(35)
 
     fun sammeOpptjeningsPeriode(other: Opptjeningsperiode): Boolean =
         this.sisteAvsluttendeKalenderMåned == other.sisteAvsluttendeKalenderMåned
 
-    private tailrec fun finnFørsteArbeidsdagEtterRapporterteringsFrist(rapporteringsFrist: LocalDate): LocalDate {
-        return if (rapporteringsFrist.erArbeidsdag()) {
+    private tailrec fun finnFørsteArbeidsdagEtterRapporterteringsFrist(rapporteringsFrist: LocalDate): LocalDate =
+        if (rapporteringsFrist.erArbeidsdag()) {
             rapporteringsFrist
         } else {
             finnFørsteArbeidsdagEtterRapporterteringsFrist(
                 rapporteringsFrist.plusDays(1),
             )
         }
-    }
 
     private fun LocalDate.erArbeidsdag(): Boolean =
         NorwegianDateUtil.isWorkingDay(Date.from(this.atStartOfDay(ZoneId.systemDefault()).toInstant()))