From 789e361634773276d0ad3c6c9d0db9996d5bf0ab Mon Sep 17 00:00:00 2001 From: Simen Ullern Date: Mon, 20 Nov 2023 08:40:45 +0100 Subject: [PATCH] =?UTF-8?q?Logger=20potensielle=20speilrelaterte=20oppgave?= =?UTF-8?q?r=20n=C3=A5r=20IM=20ikke=20h=C3=A5ndteres=20p=C3=A5=20direkten?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../spre/oppgaver/InntektsmeldingIkkeH\303\245ndtert.kt" | 9 +++++++-- .../kotlin/no/nav/helse/spre/oppgaver/EndToEndTest.kt | 4 +++- 2 files changed, 10 insertions(+), 3 deletions(-) diff --git "a/oppgaver/src/main/kotlin/no/nav/helse/spre/oppgaver/InntektsmeldingIkkeH\303\245ndtert.kt" "b/oppgaver/src/main/kotlin/no/nav/helse/spre/oppgaver/InntektsmeldingIkkeH\303\245ndtert.kt" index 2dc90df3..ac4cde42 100644 --- "a/oppgaver/src/main/kotlin/no/nav/helse/spre/oppgaver/InntektsmeldingIkkeH\303\245ndtert.kt" +++ "b/oppgaver/src/main/kotlin/no/nav/helse/spre/oppgaver/InntektsmeldingIkkeH\303\245ndtert.kt" @@ -14,17 +14,22 @@ class InntektsmeldingIkkeHåndtert( init { River(rapidsConnection).apply { validate { it.requireValue("@event_name", "inntektsmelding_ikke_håndtert") } - validate { it.requireKey("inntektsmeldingId") } + validate { it.requireKey("inntektsmeldingId", "harPeriodeInnenfor16Dager") } }.register(this) } override fun onPacket(packet: JsonMessage, context: MessageContext) { val inntektsmeldingId = packet["inntektsmeldingId"].asText().let { UUID.fromString(it) } + val harPeriodeInnenfor16Dager = packet["harPeriodeInnenfor16Dager"].asBoolean() + val oppgave = oppgaveDAO.finnOppgave(inntektsmeldingId, observer) ?: return - withMDC(mapOf("event" to "inntektsmelding_ikke_håndtert")) { + withMDC(mapOf("event" to "inntektsmelding_ikke_håndtert", "harPeriodeInnenfor16Dager" to harPeriodeInnenfor16Dager.utfall())) { oppgave.håndterInntektsmeldingIkkeHåndtert() log.info("Mottok inntektsmelding_ikke_håndtert-event: {}", oppgave.hendelseId) } } + + private fun Boolean.utfall() = if (this) "JA" else "NEI" + } diff --git a/oppgaver/src/test/kotlin/no/nav/helse/spre/oppgaver/EndToEndTest.kt b/oppgaver/src/test/kotlin/no/nav/helse/spre/oppgaver/EndToEndTest.kt index d46e151f..c3d5b16c 100644 --- a/oppgaver/src/test/kotlin/no/nav/helse/spre/oppgaver/EndToEndTest.kt +++ b/oppgaver/src/test/kotlin/no/nav/helse/spre/oppgaver/EndToEndTest.kt @@ -1077,12 +1077,14 @@ fun inntektsmeldingFørSøknad( fun inntektsmeldingIkkeHåndtert( inntektsmeldingId: UUID, organisasjonsnummer: String, - fødselsnummer: String + fødselsnummer: String, + harPeriodeInnenfor16Dager: Boolean = false ) = """{ "@event_name": "inntektsmelding_ikke_håndtert", "inntektsmeldingId": "$inntektsmeldingId", "organisasjonsnummer": "$organisasjonsnummer", + "harPeriodeInnenfor16Dager" : "$harPeriodeInnenfor16Dager", "fødselsnummer": "$fødselsnummer" }"""