From 516a1839781407d16a4235342025c3d8e63b77fb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bj=C3=B8rn=20Golberg?= Date: Fri, 15 Nov 2024 12:00:51 +0100 Subject: [PATCH] Bruke samme datokey som regulering (#6343) * Bruke samme datokey som regulering * Fjerner dato fra melding da den alltid er det samme --- .../kotlin/inntektsjustering/InntektsjusteringJobbRiver.kt | 6 +----- .../src/test/kotlin/InntektsjusteringJobbRiverTest.kt | 5 ++--- .../main/resources/templates/egendefinert/ny-melding.hbs | 2 +- .../AarligInntektsjusteringService.kt | 2 -- .../inntektsjustering/AarligInntektsjusteringRequest.kt | 4 ++-- 5 files changed, 6 insertions(+), 13 deletions(-) diff --git a/apps/etterlatte-oppdater-behandling/src/main/kotlin/inntektsjustering/InntektsjusteringJobbRiver.kt b/apps/etterlatte-oppdater-behandling/src/main/kotlin/inntektsjustering/InntektsjusteringJobbRiver.kt index 4991d74532a..82c27d04a55 100644 --- a/apps/etterlatte-oppdater-behandling/src/main/kotlin/inntektsjustering/InntektsjusteringJobbRiver.kt +++ b/apps/etterlatte-oppdater-behandling/src/main/kotlin/inntektsjustering/InntektsjusteringJobbRiver.kt @@ -10,12 +10,10 @@ import no.nav.etterlatte.rapidsandrivers.ListenerMedLogging import no.nav.etterlatte.rapidsandrivers.RapidEvents.ANTALL import no.nav.etterlatte.rapidsandrivers.RapidEvents.EKSKLUDERTE_SAKER import no.nav.etterlatte.rapidsandrivers.RapidEvents.KJOERING -import no.nav.etterlatte.rapidsandrivers.RapidEvents.LOEPENDE_FOM import no.nav.etterlatte.rapidsandrivers.RapidEvents.SPESIFIKKE_SAKER import no.nav.etterlatte.rapidsandrivers.antall import no.nav.etterlatte.rapidsandrivers.ekskluderteSaker import no.nav.etterlatte.rapidsandrivers.kjoering -import no.nav.etterlatte.rapidsandrivers.loependeFom import no.nav.etterlatte.rapidsandrivers.saker import no.nav.etterlatte.regulering.kjoerIBatch import no.nav.helse.rapids_rivers.JsonMessage @@ -34,7 +32,6 @@ internal class InntektsjusteringJobbRiver( initialiserRiver(rapidsConnection, InntektsjusteringHendelseType.START_INNTEKTSJUSTERING_JOBB) { validate { it.requireKey(KJOERING) } validate { it.requireKey(ANTALL) } - validate { it.requireKey(LOEPENDE_FOM) } validate { it.interestedIn(SPESIFIKKE_SAKER) } validate { it.interestedIn(EKSKLUDERTE_SAKER) } } @@ -54,7 +51,7 @@ internal class InntektsjusteringJobbRiver( val antall = packet.antall val sakType = SakType.OMSTILLINGSSTOENAD - val loependeFom = packet.loependeFom + val loependeFom = AarligInntektsjusteringRequest.utledLoependeFom() kjoerIBatch( logger = logger, @@ -75,7 +72,6 @@ internal class InntektsjusteringJobbRiver( val request = AarligInntektsjusteringRequest( kjoering = kjoering, - loependeFom = loependeFom, saker = sakerSomSkalInformeres.saker.map { it.id }, ) behandlingService.startAarligInntektsjustering(request) diff --git a/apps/etterlatte-oppdater-behandling/src/test/kotlin/InntektsjusteringJobbRiverTest.kt b/apps/etterlatte-oppdater-behandling/src/test/kotlin/InntektsjusteringJobbRiverTest.kt index aef59dccbad..62fbf1e5d2c 100644 --- a/apps/etterlatte-oppdater-behandling/src/test/kotlin/InntektsjusteringJobbRiverTest.kt +++ b/apps/etterlatte-oppdater-behandling/src/test/kotlin/InntektsjusteringJobbRiverTest.kt @@ -11,6 +11,7 @@ import no.nav.etterlatte.libs.common.behandling.BehandlingStatus import no.nav.etterlatte.libs.common.behandling.Revurderingaarsak import no.nav.etterlatte.libs.common.behandling.SakType import no.nav.etterlatte.libs.common.behandling.Virkningstidspunkt +import no.nav.etterlatte.libs.common.inntektsjustering.AarligInntektsjusteringRequest import no.nav.etterlatte.libs.common.rapidsandrivers.lagParMedEventNameKey import no.nav.etterlatte.libs.common.sak.Sak import no.nav.etterlatte.libs.common.sak.SakId @@ -19,7 +20,6 @@ import no.nav.etterlatte.rapidsandrivers.InntektsjusteringHendelseType import no.nav.etterlatte.rapidsandrivers.RapidEvents.ANTALL import no.nav.etterlatte.rapidsandrivers.RapidEvents.EKSKLUDERTE_SAKER import no.nav.etterlatte.rapidsandrivers.RapidEvents.KJOERING -import no.nav.etterlatte.rapidsandrivers.RapidEvents.LOEPENDE_FOM import no.nav.etterlatte.rapidsandrivers.RapidEvents.SPESIFIKKE_SAKER import no.nav.helse.rapids_rivers.JsonMessage import no.nav.helse.rapids_rivers.testsupport.TestRapid @@ -28,7 +28,7 @@ import java.time.YearMonth class InntektsjusteringJobbRiverTest { private val kjoering = "inntektsjustering-jobb-2024" - private val loependeFom = YearMonth.of(2024, 1) + private val loependeFom = AarligInntektsjusteringRequest.utledLoependeFom() @Test fun `teste start inntektsjustering jobb aktivert`() { @@ -112,7 +112,6 @@ class InntektsjusteringJobbRiverTest { ANTALL to 12000, SPESIFIKKE_SAKER to listOf(), EKSKLUDERTE_SAKER to listOf(), - LOEPENDE_FOM to loependeFom.atDay(1), ), ).toJson() diff --git a/apps/etterlatte-testdata/src/main/resources/templates/egendefinert/ny-melding.hbs b/apps/etterlatte-testdata/src/main/resources/templates/egendefinert/ny-melding.hbs index 5484cff1cb0..22f5993b9ea 100644 --- a/apps/etterlatte-testdata/src/main/resources/templates/egendefinert/ny-melding.hbs +++ b/apps/etterlatte-testdata/src/main/resources/templates/egendefinert/ny-melding.hbs @@ -54,7 +54,7 @@ document.getElementById('json').value = '{"@event_name":"OMREGNING:KLAR_FOR_OMREGNING","hendelse_data":{"sakId":"","fradato":"2024-01-01","revurderingaarsak":""}}' prettify() } else if( hendelseType == 'inntektsjusteringjobb') { - document.getElementById('json').value = '{"@event_name": "INNTEKTSJUSTERING:START_INNTEKTSJUSTERING_JOBB","kjoering": "asdf","antall": 1,"loepende_fom": "2024-01-01","spesifikke_saker": "","ekskluderte_saker": ""}' + document.getElementById('json').value = '{"@event_name": "INNTEKTSJUSTERING:START_INNTEKTSJUSTERING_JOBB","kjoering": "asdf","antall": 1, "spesifikke_saker": "","ekskluderte_saker": ""}' prettify() } else { document.getElementById('json').value = '' diff --git a/apps/etterlatte-tidshendelser/src/main/kotlin/no/nav/etterlatte/tidshendelser/aarliginntektsjustering/AarligInntektsjusteringService.kt b/apps/etterlatte-tidshendelser/src/main/kotlin/no/nav/etterlatte/tidshendelser/aarliginntektsjustering/AarligInntektsjusteringService.kt index 405b0295588..8058b44ff5d 100644 --- a/apps/etterlatte-tidshendelser/src/main/kotlin/no/nav/etterlatte/tidshendelser/aarliginntektsjustering/AarligInntektsjusteringService.kt +++ b/apps/etterlatte-tidshendelser/src/main/kotlin/no/nav/etterlatte/tidshendelser/aarliginntektsjustering/AarligInntektsjusteringService.kt @@ -4,7 +4,6 @@ import no.nav.etterlatte.libs.common.inntektsjustering.AarligInntektsjusteringRe import no.nav.etterlatte.libs.common.rapidsandrivers.lagParMedEventNameKey import no.nav.etterlatte.rapidsandrivers.InntektsjusteringHendelseType import no.nav.etterlatte.rapidsandrivers.RapidEvents -import no.nav.etterlatte.rapidsandrivers.ReguleringEvents import no.nav.etterlatte.rapidsandrivers.tilSeparertString import no.nav.etterlatte.tidshendelser.HendelserJobb import no.nav.etterlatte.tidshendelser.regulering.ReguleringDao @@ -42,7 +41,6 @@ fun createRecord(konfigurasjon: Reguleringskonfigurasjon) = .newMessage( mapOf( InntektsjusteringHendelseType.START_INNTEKTSJUSTERING_JOBB.lagParMedEventNameKey(), - ReguleringEvents.DATO to AarligInntektsjusteringRequest.utledLoependeFom(), RapidEvents.KJOERING to AarligInntektsjusteringRequest.utledKjoering(), RapidEvents.ANTALL to konfigurasjon.antall, RapidEvents.SPESIFIKKE_SAKER to konfigurasjon.spesifikkeSaker.tilSeparertString(), diff --git a/libs/etterlatte-behandling-model/src/main/kotlin/no/nav/etterlatte/libs/common/inntektsjustering/AarligInntektsjusteringRequest.kt b/libs/etterlatte-behandling-model/src/main/kotlin/no/nav/etterlatte/libs/common/inntektsjustering/AarligInntektsjusteringRequest.kt index 94a537daa34..316a043e5ee 100644 --- a/libs/etterlatte-behandling-model/src/main/kotlin/no/nav/etterlatte/libs/common/inntektsjustering/AarligInntektsjusteringRequest.kt +++ b/libs/etterlatte-behandling-model/src/main/kotlin/no/nav/etterlatte/libs/common/inntektsjustering/AarligInntektsjusteringRequest.kt @@ -6,12 +6,12 @@ import java.time.YearMonth data class AarligInntektsjusteringRequest( val kjoering: String, - val loependeFom: YearMonth, + val loependeFom: YearMonth = utledLoependeFom(), val saker: List, ) { companion object { fun utledKjoering() = "INNTEKTSJUSTERING_JOBB_${Year.now().value}" - fun utledLoependeFom() = YearMonth.of(Year.now().value, 1) + fun utledLoependeFom() = YearMonth.of(Year.now().value, 1).plusYears(1) } }