Lag ett nytt endepunkt for å sjekke om det finnes inntekt på en bestemt måned

Co-authored-by: Tonje Mjøvik Myran <[email protected]>
Co-authored-by: Richard Andre Martinsen <[email protected]>
Co-authored-by: Morten Tholander <[email protected]>

Author: 4 people

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

@@ -240,7 +240,7 @@ internal fun Application.inntektApi(
         }
         authenticate("azure") {
             route("/v3/inntekt") {
-                inntektV3(behandlingsInntektsGetter, personOppslag, inntektStore)
+                inntektV3(behandlingsInntektsGetter, personOppslag, inntektStore, inntektskomponentHttpClient)
             }
         }
         naischecks(healthChecks, meterRegistry)

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

@@ -9,22 +9,29 @@ import io.ktor.server.routing.post
 import io.ktor.server.routing.route
 import kotlinx.coroutines.Dispatchers.IO
 import kotlinx.coroutines.withContext
+import mu.KotlinLogging
+import mu.withLoggingContext
 import no.nav.dagpenger.inntekt.BehandlingsInntektsGetter
 import no.nav.dagpenger.inntekt.db.InntektId
 import no.nav.dagpenger.inntekt.db.InntektStore
 import no.nav.dagpenger.inntekt.db.Inntektparametre
 import no.nav.dagpenger.inntekt.db.ManueltRedigert
 import no.nav.dagpenger.inntekt.db.RegelKontekst
+import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektkomponentRequest
+import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektskomponentClient
 import no.nav.dagpenger.inntekt.oppslag.PersonOppslag
 import no.nav.dagpenger.inntekt.v1.Inntekt
 import no.nav.dagpenger.inntekt.v1.KlassifisertInntektMåned
 import java.time.LocalDate
 import java.time.YearMonth
 
+private val logger = KotlinLogging.logger {}
+
 fun Route.inntektV3(
     behandlingsInntektsGetter: BehandlingsInntektsGetter,
     personOppslag: PersonOppslag,
     inntektStore: InntektStore,
+    inntektskomponentClient: InntektskomponentClient,
 ) {
     route("/klassifisert") {
         post {
@@ -55,6 +62,33 @@ fun Route.inntektV3(
             }
         }
     }
+
+    route("/harInntekt") {
+        post {
+            withLoggingContext("callId" to call.callId) {
+                withContext(IO) {
+                    val dto = call.receive<HarInntektRequestDto>()
+                    val person = personOppslag.hentPerson(dto.ident)
+
+                    val inntekt =
+                        inntektskomponentClient.getInntekt(
+                            InntektkomponentRequest(
+                                aktørId = person.aktørId,
+                                fødselsnummer = person.fødselsnummer,
+                                månedFom = dto.måned,
+                                månedTom = dto.måned,
+                            ),
+                        )
+
+                    val harInntekt: Boolean = inntekt.arbeidsInntektMaaned?.isNotEmpty() == true
+
+                    logger.info { "harInntekt=$harInntekt for ${dto.måned}" }
+
+                    call.respond(HttpStatusCode.OK, harInntekt)
+                }
+            }
+        }
+    }
 }
 
 data class KlassifisertInntektRequestDto(
@@ -73,6 +107,11 @@ data class KlassifisertInntektResponseDto(
     val sisteAvsluttendeKalenderMåned: YearMonth,
 )
 
+data class HarInntektRequestDto(
+    val ident: String,
+    val måned: YearMonth,
+)
+
 private fun mapToKlassifisertInntektResponseDto(
     inntekt: Inntekt,
     manueltRedigert: ManueltRedigert?,

dp-inntekt-api/src/test/kotlin/no/nav/dagpenger/inntekt/api/v3/KlassifisertInntektRouteV3Test.kt

@@ -18,14 +18,18 @@ import no.nav.dagpenger.inntekt.db.InntektStore
 import no.nav.dagpenger.inntekt.db.Inntektparametre
 import no.nav.dagpenger.inntekt.db.ManueltRedigert
 import no.nav.dagpenger.inntekt.db.RegelKontekst
+import no.nav.dagpenger.inntekt.inntektskomponenten.v1.Aktoer
+import no.nav.dagpenger.inntekt.inntektskomponenten.v1.AktoerType
+import no.nav.dagpenger.inntekt.inntektskomponenten.v1.ArbeidsInntektMaaned
+import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektkomponentResponse
+import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektskomponentClient
 import no.nav.dagpenger.inntekt.oppslag.Person
 import no.nav.dagpenger.inntekt.oppslag.PersonOppslag
 import no.nav.dagpenger.inntekt.serder.jacksonObjectMapper
 import no.nav.dagpenger.inntekt.v1.Inntekt
 import no.nav.dagpenger.inntekt.v1.KlassifisertInntektMåned
 import java.time.LocalDate
 import java.time.YearMonth
-import java.time.YearMonth.now
 import kotlin.test.Test
 
 class KlassifisertInntektRouteV3Test {
@@ -40,7 +44,7 @@ class KlassifisertInntektRouteV3Test {
     private val periodeFraOgMed = YearMonth.of(2017, 1)!!
     private val periodeTilOgMed = YearMonth.of(2018, 12)!!
     private val inntektsId = ULID().nextULID()
-    private val sisteAvsluttendeKalenderMåned = now()
+    private val sisteAvsluttendeKalenderMåned = YearMonth.now()
 
     init {
         coEvery {
@@ -187,11 +191,46 @@ class KlassifisertInntektRouteV3Test {
         }
     }
 
+    @Test
+    fun `harInntekt-endepunktet returnerer true når det finnes inntekt`() {
+        val inntektskomponent = mockk<InntektskomponentClient>()
+
+        coEvery {
+            inntektskomponent.getInntekt(request = any())
+        } returns
+            InntektkomponentResponse(
+                listOf(ArbeidsInntektMaaned(YearMonth.now(), null, null)),
+                Aktoer(AktoerType.NATURLIG_IDENT, fødselsnummer),
+            )
+
+        withMockAuthServerAndTestApplication(
+            mockInntektApi(
+                personOppslag = personOppslagMock,
+                inntektskomponentClient = inntektskomponent,
+            ),
+        ) {
+            val response =
+                autentisert(
+                    httpMethod = HttpMethod.Post,
+                    endepunkt = "/v3/inntekt/harInntekt",
+                    body =
+                        jacksonObjectMapper.writeValueAsString(
+                            HarInntektRequestDto(fødselsnummer, sisteAvsluttendeKalenderMåned),
+                        ),
+                )
+
+            response.status shouldBe OK
+            val inntekt = jacksonObjectMapper.readValue<Boolean>(response.bodyAsText())
+
+            inntekt shouldBe true
+        }
+    }
+
     private fun createInntekt(manueltRedigert: Boolean): Inntekt =
         Inntekt(
             inntektsId,
-            listOf(KlassifisertInntektMåned(now(), listOf())),
+            listOf(KlassifisertInntektMåned(YearMonth.now(), listOf())),
             manueltRedigert,
-            now(),
+            YearMonth.now(),
         )
 }