Skip to content

Commit

Permalink
Legger til inntektsjusteringsid på melding
Browse files Browse the repository at this point in the history
  • Loading branch information
Bjodn committed Nov 29, 2024
1 parent d8bceae commit 261bdc5
Showing 1 changed file with 7 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ 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,
Expand All @@ -41,7 +42,7 @@ class InntektsjusteringSelvbetjeningService(
} else {
startManuellBehandling(mottattInntektsjustering)
}
mottattInntektsjsuteringFullfoert(mottattInntektsjustering.sak)
mottattInntektsjsuteringFullfoert(mottattInntektsjustering.sak, mottattInntektsjustering.inntektsjusteringId)
}

private fun startAutomatiskBehandling(mottattInntektsjustering: MottattInntektsjustering) {
Expand Down Expand Up @@ -112,7 +113,10 @@ class InntektsjusteringSelvbetjeningService(
return true
}

private fun mottattInntektsjsuteringFullfoert(sakId: SakId) {
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()
Expand All @@ -125,6 +129,7 @@ class InntektsjusteringSelvbetjeningService(
mapOf(
CORRELATION_ID_KEY to correlationId,
TEKNISK_TID_KEY to Tidspunkt.now(),
"inntektsjustering_id" to inntektsjusteirngId,
),
).toJson(),
).also { (partition, offset) ->
Expand Down

0 comments on commit 261bdc5

Please sign in to comment.