Sender hendelse om at mottak av inntektsjustering er fullført etter o…

…pprettelse av behandling eller oppgave (#6497) * Sender hendelse om at mottak av inntektsjustering er fullført etter opprettelse av behandling eller oppgave * Unittest * Rename metode * Legger til inntektsjusteringsid på melding
navikt · Nov 29, 2024 · 3e01191 · 3e01191
1 parent 0a51445
commit 3e01191
Show file tree

Hide file tree

Showing 5 changed files with 46 additions and 17 deletions.
diff --git a/.../src/main/kotlin/inntektsjustering/selvbetjening/InntektsjusteringSelvbetjeningService.kt b/.../src/main/kotlin/inntektsjustering/selvbetjening/InntektsjusteringSelvbetjeningService.kt
@@ -16,12 +16,14 @@ import no.nav.etterlatte.libs.common.rapidsandrivers.TEKNISK_TID_KEY
 import no.nav.etterlatte.libs.common.sak.SakId
 import no.nav.etterlatte.libs.common.tidspunkt.Tidspunkt
 import no.nav.etterlatte.libs.inntektsjustering.MottattInntektsjustering
+import no.nav.etterlatte.libs.inntektsjustering.MottattInntektsjusteringHendelseType
 import no.nav.etterlatte.libs.ktor.token.HardkodaSystembruker
 import no.nav.etterlatte.omregning.OmregningData
 import no.nav.etterlatte.omregning.OmregningDataPacket
 import no.nav.etterlatte.omregning.OmregningHendelseType
 import no.nav.etterlatte.oppgave.OppgaveService
 import org.slf4j.LoggerFactory
+import java.util.UUID
 
 class InntektsjusteringSelvbetjeningService(
     private val oppgaveService: OppgaveService,
@@ -40,6 +42,7 @@ class InntektsjusteringSelvbetjeningService(
         } else {
             startManuellBehandling(mottattInntektsjustering)
         }
+        mottattInntektsjsuteringFullfoert(mottattInntektsjustering.sak, mottattInntektsjustering.inntektsjusteringId)
     }
 
     private fun startAutomatiskBehandling(mottattInntektsjustering: MottattInntektsjustering) {
@@ -110,6 +113,33 @@ class InntektsjusteringSelvbetjeningService(
         return true
     }
 
+    private fun mottattInntektsjsuteringFullfoert(
+        sakId: SakId,
+        inntektsjusteirngId: UUID,
+    ) {
+        logger.info("Mottak av inntektsjustering fullført sender melding til selvbetjening sak=$sakId")
+        val correlationId = getCorrelationId()
+        val hendelsetype = MottattInntektsjusteringHendelseType.MOTTAK_FULLFOERT.lagEventnameForType()
+        rapid
+            .publiser(
+                "mottak-inntektsjustering-fullfoert-$sakId",
+                JsonMessage
+                    .newMessage(
+                        hendelsetype,
+                        mapOf(
+                            CORRELATION_ID_KEY to correlationId,
+                            TEKNISK_TID_KEY to Tidspunkt.now(),
+                            "inntektsjustering_id" to inntektsjusteirngId,
+                        ),
+                    ).toJson(),
+            ).also { (partition, offset) ->
+                logger.info(
+                    "Publiserte $hendelsetype for $sakId på partition " +
+                        "$partition, offset $offset, correlationid: $correlationId",
+                )
+            }
+    }
+
     enum class InntektsjusterinFeatureToggle(
         private val key: String,
     ) : FeatureToggle {

diff --git a/.../test/kotlin/inntektsjustering/selvbetjening/InntektsjusteringSelvbetjeningServiceTest.kt b/.../test/kotlin/inntektsjustering/selvbetjening/InntektsjusteringSelvbetjeningServiceTest.kt
@@ -226,9 +226,8 @@ class InntektsjusteringSelvbetjeningServiceTest {
                 saksbehandler = null,
             )
         }
-
-        verify(exactly = 0) {
-            rapid wasNot Called
+        coVerify(exactly = 1) {
+            rapid.publiser("mottak-inntektsjustering-fullfoert-123", any())
         }
     }
 
@@ -242,9 +241,7 @@ class InntektsjusteringSelvbetjeningServiceTest {
             )
             behandlingService.hentAapneBehandlingerForSak(any())
             vedtakKlient.sakHarLopendeVedtakPaaDato(any(), any(), any())
-        }
-        verify(exactly = 0) {
-            oppgaveService wasNot Called
+            rapid.publiser("mottak-inntektsjustering-fullfoert-123", any())
         }
     }
 }
diff --git a/...dig-soeknad/src/main/kotlin/no/nav/etterlatte/inntektsjustering/InntektsjusteringRiver.kt b/...dig-soeknad/src/main/kotlin/no/nav/etterlatte/inntektsjustering/InntektsjusteringRiver.kt
@@ -1,6 +1,5 @@
 package no.nav.etterlatte.inntektsjustering
 
-import com.fasterxml.jackson.databind.JsonMappingException
 import com.fasterxml.jackson.module.kotlin.treeToValue
 import kotlinx.coroutines.runBlocking
 import no.nav.etterlatte.gyldigsoeknad.client.BehandlingClient
@@ -13,7 +12,6 @@ import no.nav.etterlatte.libs.common.objectMapper
 import no.nav.etterlatte.libs.common.sak.Sak
 import no.nav.etterlatte.libs.inntektsjustering.MottattInntektsjustering
 import no.nav.etterlatte.rapidsandrivers.ListenerMedLogging
-import no.nav.etterlatte.sikkerLogg
 import no.nav.helse.rapids_rivers.JsonMessage
 import no.nav.helse.rapids_rivers.MessageContext
 import no.nav.helse.rapids_rivers.RapidsConnection
@@ -54,13 +52,12 @@ internal class InntektsjusteringRiver(
                     }
 
             startBehandlingAvInntektsjustering(sak, journalpostResponse, inntektsjustering)
-        } catch (e: JsonMappingException) {
-            sikkerLogg.error("Feil under deserialisering", e)
-            logger.error("Feil under deserialisering av inntektsjustering (id=${inntektsjustering.id}). Se sikkerlogg for detaljer.")
-            throw e
         } catch (e: Exception) {
-            logger.error("Uhåndtert feilsituasjon TODO : $", e)
-            // throw e TODO ta stilling til hvordan feil her skal håndteres...
+            // Selvbetjening-backend vil fortsette å sende nye meldinger til dette ikke feiler
+            logger.error(
+                "Journalføring eller opprettelse av behandling/oppgave for inntektsjustering inntektsjusteringsid=${inntektsjustering.id}",
+                e,
+            )
         }
     }
 

diff --git a/...ring-kafka/src/main/kotlin/no/nav/etterlatte/regulering/OpprettVedtakforespoerselRiver.kt b/...ring-kafka/src/main/kotlin/no/nav/etterlatte/regulering/OpprettVedtakforespoerselRiver.kt
@@ -126,9 +126,6 @@ internal class OpprettVedtakforespoerselRiver(
         }
     }
 
-    /*
-     *
-     */
     private fun vedtakOgBrev(
         sakId: SakId,
         behandlingId: UUID,

diff --git a/...odel/src/main/kotlin/no.nav.etterlatte.libs.inntektsjustering/MottattInntektsjustering.kt b/...odel/src/main/kotlin/no.nav.etterlatte.libs.inntektsjustering/MottattInntektsjustering.kt
@@ -1,5 +1,6 @@
 package no.nav.etterlatte.libs.inntektsjustering
 
+import no.nav.etterlatte.libs.common.event.EventnameHendelseType
 import no.nav.etterlatte.libs.common.sak.SakId
 import java.time.YearMonth
 import java.util.UUID
@@ -22,3 +23,10 @@ data class MottattInntektsjustering(
         fun utledLoependeFom() = AarligInntektsjusteringRequest.utledLoependeFom()
     }
 }
+
+enum class MottattInntektsjusteringHendelseType : EventnameHendelseType {
+    MOTTAK_FULLFOERT,
+    ;
+
+    override fun lagEventnameForType(): String = "INNTEKTSJUSTERING:${this.name}"
+}
-Original file line number
+Diff line change
@@ Expand Up / @@ -126,9 +126,6 @@ internal class OpprettVedtakforespoerselRiver( @@
             }
         }
-        /*
-         *
-         */
         private fun vedtakOgBrev(
             sakId: SakId,
             behandlingId: UUID,
@@ Expand Down @@