diff --git a/sykepenger-mediators/src/main/kotlin/no/nav/helse/spleis/PersonMediator.kt b/sykepenger-mediators/src/main/kotlin/no/nav/helse/spleis/PersonMediator.kt index 8a77304b49..08335f2681 100644 --- a/sykepenger-mediators/src/main/kotlin/no/nav/helse/spleis/PersonMediator.kt +++ b/sykepenger-mediators/src/main/kotlin/no/nav/helse/spleis/PersonMediator.kt @@ -280,25 +280,27 @@ internal class PersonMediator( ))) } - override fun vedtaksperiodeVenter(event: PersonObserver.VedtaksperiodeVenterEvent) { - queueMessage(JsonMessage.newMessage("vedtaksperiode_venter", mapOf( - "organisasjonsnummer" to event.organisasjonsnummer, - "vedtaksperiodeId" to event.vedtaksperiodeId, - "behandlingId" to event.behandlingId, - "skjæringstidspunkt" to event.skjæringstidspunkt, - "hendelser" to event.hendelser, - "ventetSiden" to event.ventetSiden, - "venterTil" to event.venterTil, - "venterPå" to mapOf( - "vedtaksperiodeId" to event.venterPå.vedtaksperiodeId, - "skjæringstidspunkt" to event.venterPå.skjæringstidspunkt, - "organisasjonsnummer" to event.venterPå.organisasjonsnummer, - "venteårsak" to mapOf( - "hva" to event.venterPå.venteårsak.hva, - "hvorfor" to event.venterPå.venteårsak.hvorfor + override fun vedtaksperioderVenter(eventer: List) { + eventer.forEach { event -> + queueMessage(JsonMessage.newMessage("vedtaksperiode_venter", mapOf( + "organisasjonsnummer" to event.organisasjonsnummer, + "vedtaksperiodeId" to event.vedtaksperiodeId, + "behandlingId" to event.behandlingId, + "skjæringstidspunkt" to event.skjæringstidspunkt, + "hendelser" to event.hendelser, + "ventetSiden" to event.ventetSiden, + "venterTil" to event.venterTil, + "venterPå" to mapOf( + "vedtaksperiodeId" to event.venterPå.vedtaksperiodeId, + "skjæringstidspunkt" to event.venterPå.skjæringstidspunkt, + "organisasjonsnummer" to event.venterPå.organisasjonsnummer, + "venteårsak" to mapOf( + "hva" to event.venterPå.venteårsak.hva, + "hvorfor" to event.venterPå.venteårsak.hvorfor + ) ) - ) - ))) + ))) + } } override fun vedtaksperiodeOpprettet(event: PersonObserver.VedtaksperiodeOpprettet) { diff --git a/sykepenger-model/src/main/kotlin/no/nav/helse/person/Person.kt b/sykepenger-model/src/main/kotlin/no/nav/helse/person/Person.kt index 7f4142f531..b01057779a 100644 --- a/sykepenger-model/src/main/kotlin/no/nav/helse/person/Person.kt +++ b/sykepenger-model/src/main/kotlin/no/nav/helse/person/Person.kt @@ -484,10 +484,6 @@ class Person private constructor( observers.forEach { it.vedtaksperiodeEndret(event) } } - internal fun vedtaksperiodeVenter(event: PersonObserver.VedtaksperiodeVenterEvent) { - observers.forEach { it.vedtaksperiodeVenter(event) } - } - internal fun inntektsmeldingReplay( vedtaksperiodeId: UUID, skjæringstidspunkt: LocalDate, @@ -801,11 +797,9 @@ class Person private constructor( is Sykmelding -> { /* Sykmelding fører ikke til endringer i tiltander, så sender ikke signal etter håndtering av den */ } else -> { val nestemann = arbeidsgivere.nestemann() ?: return - arbeidsgivere.venter(nestemann) + val eventer = arbeidsgivere.venter(nestemann) .map { it.event() } - .forEach { event -> - observers.forEach { it.vedtaksperiodeVenter(event) } - } + observers.forEach { it.vedtaksperioderVenter(eventer) } } } } diff --git a/sykepenger-model/src/main/kotlin/no/nav/helse/person/PersonObserver.kt b/sykepenger-model/src/main/kotlin/no/nav/helse/person/PersonObserver.kt index 452bbcf587..54f450c6ad 100644 --- a/sykepenger-model/src/main/kotlin/no/nav/helse/person/PersonObserver.kt +++ b/sykepenger-model/src/main/kotlin/no/nav/helse/person/PersonObserver.kt @@ -620,7 +620,7 @@ interface PersonObserver { fun vedtaksperiodePåminnet(vedtaksperiodeId: UUID, organisasjonsnummer: String, påminnelse: Påminnelse) {} fun vedtaksperiodeIkkePåminnet(vedtaksperiodeId: UUID, organisasjonsnummer: String, nåværendeTilstand: TilstandType) {} fun vedtaksperiodeEndret(event: VedtaksperiodeEndretEvent) {} - fun vedtaksperiodeVenter(event: VedtaksperiodeVenterEvent) {} + fun vedtaksperioderVenter(eventer: List) {} fun vedtaksperiodeForkastet(event: VedtaksperiodeForkastetEvent) {} fun vedtaksperiodeIkkeFunnet(event: VedtaksperiodeIkkeFunnetEvent) {} fun sykefraværstilfelleIkkeFunnet(event: SykefraværstilfelleIkkeFunnet) {} diff --git "a/sykepenger-model/src/test/kotlin/no/nav/helse/dsl/UgyldigeSituasjonerObservat\303\270r.kt" "b/sykepenger-model/src/test/kotlin/no/nav/helse/dsl/UgyldigeSituasjonerObservat\303\270r.kt" index 9f2f72d10f..b13f1f0074 100644 --- "a/sykepenger-model/src/test/kotlin/no/nav/helse/dsl/UgyldigeSituasjonerObservat\303\270r.kt" +++ "b/sykepenger-model/src/test/kotlin/no/nav/helse/dsl/UgyldigeSituasjonerObservat\303\270r.kt" @@ -137,9 +137,11 @@ internal class UgyldigeSituasjonerObservatør(private val person: Person): Perso søknader[søknadId] = null } - override fun vedtaksperiodeVenter(event: PersonObserver.VedtaksperiodeVenterEvent) = sjekk { - sjekkUgyldigeVentesituasjoner(event) - sjekkSøknadIdEierskap(event.vedtaksperiodeId, event.hendelser) + override fun vedtaksperioderVenter(eventer: List) = sjekk { + eventer.forEach { event -> + sjekkUgyldigeVentesituasjoner(event) + sjekkSøknadIdEierskap(event.vedtaksperiodeId, event.hendelser) + } } private fun sjekkUgyldigeVentesituasjoner(event: PersonObserver.VedtaksperiodeVenterEvent) { diff --git "a/sykepenger-model/src/test/kotlin/no/nav/helse/spleis/e2e/TestObservat\303\270r.kt" "b/sykepenger-model/src/test/kotlin/no/nav/helse/spleis/e2e/TestObservat\303\270r.kt" index 8b9265da9e..ac3aa905e9 100644 --- "a/sykepenger-model/src/test/kotlin/no/nav/helse/spleis/e2e/TestObservat\303\270r.kt" +++ "b/sykepenger-model/src/test/kotlin/no/nav/helse/spleis/e2e/TestObservat\303\270r.kt" @@ -78,8 +78,8 @@ internal class TestObservatør(person: Person? = null) : PersonObserver { inntektsmeldingReplayEventer.removeAll { it.vedtaksperiodeId == vedtaksperiodeId } } - override fun vedtaksperiodeVenter(event: PersonObserver.VedtaksperiodeVenterEvent) { - vedtaksperiodeVenter.add(event) + override fun vedtaksperioderVenter(eventer: List) { + vedtaksperiodeVenter.addAll(eventer) } fun forkastedePerioder() = forkastedeEventer.size