From 4b845908e26e4b999d8121c0b31e383f98471913 Mon Sep 17 00:00:00 2001 From: Nicolas N Date: Mon, 18 Nov 2024 10:33:20 +0100 Subject: [PATCH] Kun sende sakIder siden resten ikke blir brukt --- .../main/kotlin/behandling/BehandlingDao.kt | 9 ++-- .../kotlin/behandling/BehandlingService.kt | 8 +--- .../behandling/BehandlingStatusService.kt | 11 +++-- .../behandling/BehandlingsstatusRoutes.kt | 6 +-- .../AarligInntektsjusteringJobbService.kt | 4 +- .../src/main/kotlin/sak/SakRoutes.kt | 21 ++++---- .../src/main/kotlin/sak/SakService.kt | 9 ++-- .../behandling/BehandlingDaoReguleringTest.kt | 7 ++- .../src/main/kotlin/BehandlingService.kt | 12 ++--- .../InntektsjusteringJobbRiver.kt | 2 +- .../main/kotlin/regulering/Batchkjoerer.kt | 14 +++--- .../regulering/FinnSakerTilReguleringRiver.kt | 4 +- .../ReguleringsforespoerselRiver.kt | 28 +++++------ .../kotlin/InntektsjusteringJobbRiverTest.kt | 28 ++--------- .../ReguleringsforespoerselRiverTest.kt | 48 +++++-------------- .../src/main/kotlin/sak/Sak.kt | 4 +- 16 files changed, 83 insertions(+), 132 deletions(-) diff --git a/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingDao.kt b/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingDao.kt index 42d7535cfa5..f74a908e28d 100644 --- a/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingDao.kt +++ b/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingDao.kt @@ -31,7 +31,6 @@ import no.nav.etterlatte.libs.common.gyldigSoeknad.GyldighetsResultat import no.nav.etterlatte.libs.common.sak.BehandlingOgSak import no.nav.etterlatte.libs.common.sak.Sak import no.nav.etterlatte.libs.common.sak.SakId -import no.nav.etterlatte.libs.common.sak.Saker import no.nav.etterlatte.libs.common.tidspunkt.Tidspunkt import no.nav.etterlatte.libs.common.tidspunkt.getTidspunkt import no.nav.etterlatte.libs.common.tidspunkt.getTidspunktOrNull @@ -141,7 +140,7 @@ class BehandlingDao( } } - fun migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(saker: Saker): List = + fun migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(sakIder: List): List = connectionAutoclosing.hentConnection { connection -> with(connection) { val stmt = @@ -158,13 +157,13 @@ class BehandlingDao( 1, createArrayOf("text", BehandlingStatus.skalIkkeOmregnesVedGRegulering().toTypedArray()), ) - stmt.setArray(2, createArrayOf("bigint", saker.saker.map { it.id }.toTypedArray())) + stmt.setArray(2, createArrayOf("bigint", sakIder.toTypedArray())) stmt.executeQuery().toList { BehandlingOgSak(getUUID("id"), SakId(getLong("sak_id"))) } } } - fun hentAapneBehandlinger(saker: Saker): List = + fun hentAapneBehandlinger(sakIder: List): List = connectionAutoclosing.hentConnection { connection -> with(connection) { val stmt = @@ -176,7 +175,7 @@ class BehandlingDao( """.trimIndent(), ) stmt.setArray(1, createArrayOf("text", BehandlingStatus.underBehandling().toTypedArray())) - stmt.setArray(2, createArrayOf("bigint", saker.saker.map { it.id }.toTypedArray())) + stmt.setArray(2, createArrayOf("bigint", sakIder.toTypedArray())) stmt.executeQuery().toList { BehandlingOgSak(getUUID("id"), SakId(getLong("sak_id"))) } } diff --git a/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingService.kt b/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingService.kt index b123510b46c..30c46f42c44 100644 --- a/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingService.kt +++ b/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingService.kt @@ -56,7 +56,6 @@ import no.nav.etterlatte.libs.common.sak.BehandlingOgSak import no.nav.etterlatte.libs.common.sak.Sak import no.nav.etterlatte.libs.common.sak.SakId import no.nav.etterlatte.libs.common.sak.SakMedUtlandstilknytning -import no.nav.etterlatte.libs.common.sak.Saker import no.nav.etterlatte.libs.common.toJsonNode import no.nav.etterlatte.libs.ktor.route.lagGrunnlagsopplysning import no.nav.etterlatte.libs.ktor.token.BrukerTokenInfo @@ -271,7 +270,7 @@ interface BehandlingService { fun hentTidligereFamiliepleier(behandlingId: UUID): TidligereFamiliepleier? - fun hentAapneBehandlingerForSak(sak: Sak): List + fun hentAapneBehandlingerForSak(sakId: SakId): List } internal class BehandlingServiceImpl( @@ -909,10 +908,7 @@ internal class BehandlingServiceImpl( override fun hentTidligereFamiliepleier(behandlingId: UUID): TidligereFamiliepleier? = behandlingDao.hentTidligereFamiliepleier(behandlingId) - override fun hentAapneBehandlingerForSak(sak: Sak): List = - behandlingDao.hentAapneBehandlinger( - Saker(listOf(sak)), - ) + override fun hentAapneBehandlingerForSak(sakId: SakId): List = behandlingDao.hentAapneBehandlinger(listOf(sakId)) private fun hentBehandlingOrThrow(behandlingId: UUID) = behandlingDao.hentBehandling(behandlingId) diff --git a/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingStatusService.kt b/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingStatusService.kt index a0877c6e41a..ba01a828ccf 100644 --- a/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingStatusService.kt +++ b/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingStatusService.kt @@ -17,7 +17,7 @@ import no.nav.etterlatte.libs.common.oppgave.OppgaveKilde import no.nav.etterlatte.libs.common.oppgave.OppgaveType import no.nav.etterlatte.libs.common.oppgave.VedtakEndringDTO import no.nav.etterlatte.libs.common.sak.SakIDListe -import no.nav.etterlatte.libs.common.sak.Saker +import no.nav.etterlatte.libs.common.sak.SakslisteDTO import no.nav.etterlatte.libs.common.tidspunkt.Tidspunkt import no.nav.etterlatte.libs.common.tidspunkt.toLocalDatetimeUTC import no.nav.etterlatte.libs.common.vedtak.VedtakType @@ -99,7 +99,7 @@ interface BehandlingStatusService { vedtakHendelse: VedtakHendelse, ) - fun migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(saker: Saker): SakIDListe + fun migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(sakslisteDTO: SakslisteDTO): SakIDListe } class BehandlingStatusServiceImpl( @@ -337,10 +337,11 @@ class BehandlingStatusServiceImpl( } } - override fun migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(saker: Saker) = + override fun migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(sakslisteDTO: SakslisteDTO) = inTransaction { - val tilbakestilte = behandlingDao.migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(saker) - val aapne = behandlingDao.hentAapneBehandlinger(saker) + val tilbakestilte = + behandlingDao.migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(sakslisteDTO.sakIdListe) + val aapne = behandlingDao.hentAapneBehandlinger(sakslisteDTO.sakIdListe) SakIDListe( tilbakestilte, aapne, diff --git a/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingsstatusRoutes.kt b/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingsstatusRoutes.kt index 6f7127284e5..f2016b32103 100644 --- a/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingsstatusRoutes.kt +++ b/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingsstatusRoutes.kt @@ -11,7 +11,7 @@ import io.ktor.server.routing.post import io.ktor.server.routing.route import no.nav.etterlatte.inTransaction import no.nav.etterlatte.libs.common.feilhaandtering.ForespoerselException -import no.nav.etterlatte.libs.common.sak.Saker +import no.nav.etterlatte.libs.common.sak.SakslisteDTO import no.nav.etterlatte.libs.ktor.route.BEHANDLINGID_CALL_PARAMETER import no.nav.etterlatte.libs.ktor.route.behandlingId import no.nav.etterlatte.libs.ktor.route.kunSystembruker @@ -175,9 +175,9 @@ internal fun Route.behandlingsstatusRoutes(behandlingsstatusService: BehandlingS route("/behandlinger") { post("/settTilbakeTilTrygdetidOppdatert") { kunSystembruker { - val saker = call.receive() + val sakslisteDTO = call.receive() val tilbakestilteBehandlinger = - behandlingsstatusService.migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(saker) + behandlingsstatusService.migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(sakslisteDTO) call.respond(tilbakestilteBehandlinger) } } diff --git a/apps/etterlatte-behandling/src/main/kotlin/inntektsjustering/AarligInntektsjusteringJobbService.kt b/apps/etterlatte-behandling/src/main/kotlin/inntektsjustering/AarligInntektsjusteringJobbService.kt index 994c4d52f11..9072fb20401 100644 --- a/apps/etterlatte-behandling/src/main/kotlin/inntektsjustering/AarligInntektsjusteringJobbService.kt +++ b/apps/etterlatte-behandling/src/main/kotlin/inntektsjustering/AarligInntektsjusteringJobbService.kt @@ -89,7 +89,7 @@ class AarligInntektsjusteringJobbService( saksbehandler: Saksbehandler, ): Revurdering { val sak = sakService.finnSak(sakId) ?: throw InternfeilException("Fant ikke sak med id $sakId") - val aapneBehandlinger = behandlingService.hentAapneBehandlingerForSak(sak) + val aapneBehandlinger = behandlingService.hentAapneBehandlingerForSak(sak.id) if (aapneBehandlinger.isNotEmpty()) { logger.info("Sak har åpne behandlinger, kan ikke opprette revurdering") throw UgyldigForespoerselException( @@ -159,7 +159,7 @@ class AarligInntektsjusteringJobbService( val sak = sakService.finnSak(sakId) ?: throw InternfeilException("Fant ikke sak med id $sakId") - val aapneBehandlinger = behandlingService.hentAapneBehandlingerForSak(sak) + val aapneBehandlinger = behandlingService.hentAapneBehandlingerForSak(sak.id) if (aapneBehandlinger.isNotEmpty()) { nyOppgaveOgOppdaterKjoering(sakId, forrigeBehandling.id, kjoering, AAPEN_BEHANDLING) return@inTransaction diff --git a/apps/etterlatte-behandling/src/main/kotlin/sak/SakRoutes.kt b/apps/etterlatte-behandling/src/main/kotlin/sak/SakRoutes.kt index f9a00992154..dfaba8b615b 100644 --- a/apps/etterlatte-behandling/src/main/kotlin/sak/SakRoutes.kt +++ b/apps/etterlatte-behandling/src/main/kotlin/sak/SakRoutes.kt @@ -28,7 +28,7 @@ import no.nav.etterlatte.libs.common.feilhaandtering.UgyldigForespoerselExceptio import no.nav.etterlatte.libs.common.sak.HentSakerRequest import no.nav.etterlatte.libs.common.sak.Sak import no.nav.etterlatte.libs.common.sak.SakId -import no.nav.etterlatte.libs.common.sak.Saker +import no.nav.etterlatte.libs.common.sak.SakslisteDTO import no.nav.etterlatte.libs.ktor.route.SAKID_CALL_PARAMETER import no.nav.etterlatte.libs.ktor.route.kunSaksbehandler import no.nav.etterlatte.libs.ktor.route.kunSystembruker @@ -63,16 +63,17 @@ internal fun Route.sakSystemRoutes( val loependeFom = request.loependeFom call.respond( - Saker( + SakslisteDTO( inTransaction { - sakService.hentSaker( - kjoering, - antall, - spesifikkeSaker, - ekskluderteSaker, - sakstype, - loependeFom, - ) + sakService + .hentSakIdListeForKjoering( + kjoering, + antall, + spesifikkeSaker, + ekskluderteSaker, + sakstype, + loependeFom, + ) }, ), ) diff --git a/apps/etterlatte-behandling/src/main/kotlin/sak/SakService.kt b/apps/etterlatte-behandling/src/main/kotlin/sak/SakService.kt index 6b117d70fe2..81149a7a822 100644 --- a/apps/etterlatte-behandling/src/main/kotlin/sak/SakService.kt +++ b/apps/etterlatte-behandling/src/main/kotlin/sak/SakService.kt @@ -40,14 +40,14 @@ import org.slf4j.LoggerFactory import java.time.YearMonth interface SakService { - fun hentSaker( + fun hentSakIdListeForKjoering( kjoering: String, antall: Int, spesifikkeSaker: List, ekskluderteSaker: List, sakType: SakType? = null, loependeFom: YearMonth? = null, - ): List + ): List fun finnSaker(ident: String): List @@ -139,19 +139,20 @@ class SakServiceImpl( return saker.associateBy { it.id } } - override fun hentSaker( + override fun hentSakIdListeForKjoering( kjoering: String, antall: Int, spesifikkeSaker: List, ekskluderteSaker: List, sakType: SakType?, loependeFom: YearMonth?, - ): List = + ): List = lesDao .hentSaker(kjoering, antall, spesifikkeSaker, ekskluderteSaker, sakType, loependeFom) .also { logger.info("Henta ${it.size} saker før filtrering") } .filterForEnheter() .also { logger.info("Henta ${it.size} saker etter filtrering") } + .map(Sak::id) private fun finnSakForPerson( ident: String, diff --git a/apps/etterlatte-behandling/src/test/kotlin/behandling/BehandlingDaoReguleringTest.kt b/apps/etterlatte-behandling/src/test/kotlin/behandling/BehandlingDaoReguleringTest.kt index a9d74e6e981..2570f20b65a 100644 --- a/apps/etterlatte-behandling/src/test/kotlin/behandling/BehandlingDaoReguleringTest.kt +++ b/apps/etterlatte-behandling/src/test/kotlin/behandling/BehandlingDaoReguleringTest.kt @@ -12,7 +12,6 @@ import no.nav.etterlatte.common.Enheter import no.nav.etterlatte.libs.common.behandling.BehandlingStatus import no.nav.etterlatte.libs.common.behandling.BehandlingType import no.nav.etterlatte.libs.common.behandling.SakType -import no.nav.etterlatte.libs.common.sak.Saker import no.nav.etterlatte.opprettBehandling import no.nav.etterlatte.sak.SakSkrivDao import no.nav.etterlatte.sak.SakendringerDao @@ -67,7 +66,7 @@ internal class BehandlingDaoReguleringTest( behandlingRepo.opprettBehandling(opprettBehandling) val trengerNyBeregning = - behandlingRepo.migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(Saker(listOf(sak))) + behandlingRepo.migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(listOf(sak.id)) with(behandlingRepo.hentBehandling(opprettBehandling.id)) { val expected = BehandlingStatus.TRYGDETID_OPPDATERT @@ -95,7 +94,7 @@ internal class BehandlingDaoReguleringTest( } val trengerNyBeregning = - behandlingRepo.migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(Saker(listOf(relevantSak))) + behandlingRepo.migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(listOf(relevantSak.id)) trengerNyBeregning.map { it.sakId } shouldContainExactly listOf(relevantSak.id) with(behandlingRepo.hentBehandling(sakOgBehandling.find { it.sakId == relevantSak.id }!!.id)) { @@ -122,7 +121,7 @@ internal class BehandlingDaoReguleringTest( opprettBehandling(type = BehandlingType.FØRSTEGANGSBEHANDLING, sakId = sak.id, status = status) behandlingRepo.opprettBehandling(opprettBehandling) - behandlingRepo.migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(Saker(listOf(sak))) + behandlingRepo.migrerStatusPaaAlleBehandlingerSomTrengerNyBeregning(listOf(sak.id)) with(behandlingRepo.hentBehandling(opprettBehandling.id)) { val expected = status diff --git a/apps/etterlatte-oppdater-behandling/src/main/kotlin/BehandlingService.kt b/apps/etterlatte-oppdater-behandling/src/main/kotlin/BehandlingService.kt index dd135cfe022..0acef4fea0e 100644 --- a/apps/etterlatte-oppdater-behandling/src/main/kotlin/BehandlingService.kt +++ b/apps/etterlatte-oppdater-behandling/src/main/kotlin/BehandlingService.kt @@ -41,7 +41,7 @@ import no.nav.etterlatte.libs.common.sak.LagreKjoeringRequest import no.nav.etterlatte.libs.common.sak.Sak import no.nav.etterlatte.libs.common.sak.SakIDListe import no.nav.etterlatte.libs.common.sak.SakId -import no.nav.etterlatte.libs.common.sak.Saker +import no.nav.etterlatte.libs.common.sak.SakslisteDTO import no.nav.etterlatte.libs.common.tidspunkt.Tidspunkt import no.nav.etterlatte.libs.ktor.route.FoedselsnummerDTO import no.nav.etterlatte.libs.tidshendelser.JobbType @@ -75,7 +75,7 @@ interface BehandlingService { ekskluderteSaker: List = listOf(), sakType: SakType? = null, loependeFom: YearMonth? = null, - ): Saker + ): SakslisteDTO fun opprettAutomatiskRevurdering(request: AutomatiskRevurderingRequest): AutomatiskRevurderingResponse @@ -100,7 +100,7 @@ interface BehandlingService { jobbType: JobbType, ): OpprettOppgaveForAktivitetspliktResponse - fun migrerAlleTempBehandlingerTilbakeTilTrygdetidOppdatert(saker: Saker): SakIDListe + fun migrerAlleTempBehandlingerTilbakeTilTrygdetidOppdatert(sakslisteDTO: SakslisteDTO): SakIDListe fun avbryt(behandlingId: UUID): HttpResponse @@ -232,12 +232,12 @@ class BehandlingServiceImpl( }.body() } - override fun migrerAlleTempBehandlingerTilbakeTilTrygdetidOppdatert(saker: Saker): SakIDListe = + override fun migrerAlleTempBehandlingerTilbakeTilTrygdetidOppdatert(sakslisteDTO: SakslisteDTO): SakIDListe = runBlocking { behandlingKlient .post("$url/behandlinger/settTilbakeTilTrygdetidOppdatert") { contentType(ContentType.Application.Json) - setBody(saker) + setBody(sakslisteDTO) }.body() } @@ -248,7 +248,7 @@ class BehandlingServiceImpl( ekskluderteSaker: List, sakType: SakType?, loependeFom: YearMonth?, - ): Saker = + ): SakslisteDTO = runBlocking { behandlingKlient .post("$url/saker/$kjoering/$antall") { 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 82c27d04a55..ae2107e59cc 100644 --- a/apps/etterlatte-oppdater-behandling/src/main/kotlin/inntektsjustering/InntektsjusteringJobbRiver.kt +++ b/apps/etterlatte-oppdater-behandling/src/main/kotlin/inntektsjustering/InntektsjusteringJobbRiver.kt @@ -72,7 +72,7 @@ internal class InntektsjusteringJobbRiver( val request = AarligInntektsjusteringRequest( kjoering = kjoering, - saker = sakerSomSkalInformeres.saker.map { it.id }, + saker = sakerSomSkalInformeres.sakIdListe, ) behandlingService.startAarligInntektsjustering(request) }, diff --git a/apps/etterlatte-oppdater-behandling/src/main/kotlin/regulering/Batchkjoerer.kt b/apps/etterlatte-oppdater-behandling/src/main/kotlin/regulering/Batchkjoerer.kt index 1d98c25640a..4166bf38a8a 100644 --- a/apps/etterlatte-oppdater-behandling/src/main/kotlin/regulering/Batchkjoerer.kt +++ b/apps/etterlatte-oppdater-behandling/src/main/kotlin/regulering/Batchkjoerer.kt @@ -1,6 +1,6 @@ package no.nav.etterlatte.regulering -import no.nav.etterlatte.libs.common.sak.Saker +import no.nav.etterlatte.libs.common.sak.SakslisteDTO import org.slf4j.Logger import java.time.Duration import kotlin.math.max @@ -10,9 +10,9 @@ const val MAKS_BATCHSTOERRELSE = 100 fun kjoerIBatch( logger: Logger, - finnSaker: (Int) -> Saker, + finnSaker: (Int) -> SakslisteDTO, antall: Int, - haandterSaker: (Saker) -> Unit, + haandterSaker: (SakslisteDTO) -> Unit, venteperiode: Duration = Duration.ofSeconds(5), ) { val maksBatchstoerrelse = MAKS_BATCHSTOERRELSE @@ -24,18 +24,18 @@ fun kjoerIBatch( val sakerTilOmregning = finnSaker(antallIDenneRunden) - logger.info("Henta ${sakerTilOmregning.saker.size} saker") + logger.info("Henta ${sakerTilOmregning.sakIdListe.size} saker") - if (sakerTilOmregning.saker.isEmpty()) { + if (sakerTilOmregning.sakIdListe.isEmpty()) { logger.debug("Ingen saker i denne runden. Returnerer") return } haandterSaker(sakerTilOmregning) - tatt += sakerTilOmregning.saker.size + tatt += sakerTilOmregning.sakIdListe.size logger.info("Ferdig med $tatt av totalt $antall saker") - if (sakerTilOmregning.saker.size < maksBatchstoerrelse) { + if (sakerTilOmregning.sakIdListe.size < maksBatchstoerrelse) { return } logger.info("Venter $venteperiode før neste runde.") diff --git a/apps/etterlatte-oppdater-behandling/src/main/kotlin/regulering/FinnSakerTilReguleringRiver.kt b/apps/etterlatte-oppdater-behandling/src/main/kotlin/regulering/FinnSakerTilReguleringRiver.kt index 35d1a2625d0..1c971046713 100644 --- a/apps/etterlatte-oppdater-behandling/src/main/kotlin/regulering/FinnSakerTilReguleringRiver.kt +++ b/apps/etterlatte-oppdater-behandling/src/main/kotlin/regulering/FinnSakerTilReguleringRiver.kt @@ -42,8 +42,8 @@ class FinnSakerTilReguleringRiver( behandlingService.hentAlleSaker(kjoering = kjoering, antall = antall) }, haandterSaker = { saker -> - saker.saker.forEach { sak -> - behandlingService.lagreKjoering(sak.id, KjoeringStatus.KLAR_TIL_REGULERING, kjoering) + saker.sakIdListe.forEach { sakId -> + behandlingService.lagreKjoering(sakId, KjoeringStatus.KLAR_TIL_REGULERING, kjoering) } }, venteperiode = Duration.ofSeconds(1), diff --git a/apps/etterlatte-oppdater-behandling/src/main/kotlin/regulering/ReguleringsforespoerselRiver.kt b/apps/etterlatte-oppdater-behandling/src/main/kotlin/regulering/ReguleringsforespoerselRiver.kt index 190d9023581..13582e8ebe8 100644 --- a/apps/etterlatte-oppdater-behandling/src/main/kotlin/regulering/ReguleringsforespoerselRiver.kt +++ b/apps/etterlatte-oppdater-behandling/src/main/kotlin/regulering/ReguleringsforespoerselRiver.kt @@ -8,9 +8,9 @@ import no.nav.etterlatte.libs.common.behandling.Revurderingaarsak import no.nav.etterlatte.libs.common.behandling.SakType import no.nav.etterlatte.libs.common.rapidsandrivers.setEventNameForHendelseType import no.nav.etterlatte.libs.common.sak.KjoeringStatus -import no.nav.etterlatte.libs.common.sak.Sak import no.nav.etterlatte.libs.common.sak.SakIDListe -import no.nav.etterlatte.libs.common.sak.Saker +import no.nav.etterlatte.libs.common.sak.SakId +import no.nav.etterlatte.libs.common.sak.SakslisteDTO import no.nav.etterlatte.rapidsandrivers.DATO_KEY import no.nav.etterlatte.rapidsandrivers.HENDELSE_DATA_KEY import no.nav.etterlatte.rapidsandrivers.Kontekst @@ -85,8 +85,8 @@ internal class ReguleringsforespoerselRiver( }, haandterSaker = { sakerTilOmregning -> val sakListe = flyttBehandlingerUnderArbeidTilbakeTilTrygdetidOppdatert(sakerTilOmregning) - sakerTilOmregning.saker.forEach { - publiserSak(it, kjoering, packet, sakListe, context) + sakerTilOmregning.sakIdListe.forEach { sakId -> + publiserSak(sakId, kjoering, packet, sakListe, context) } }, ) @@ -98,9 +98,9 @@ internal class ReguleringsforespoerselRiver( else -> SakType.valueOf(node.asText()) } - private fun flyttBehandlingerUnderArbeidTilbakeTilTrygdetidOppdatert(sakerTilOmregning: Saker): SakIDListe = + private fun flyttBehandlingerUnderArbeidTilbakeTilTrygdetidOppdatert(sakslisteDTOTilOmregning: SakslisteDTO): SakIDListe = behandlingService - .migrerAlleTempBehandlingerTilbakeTilTrygdetidOppdatert(sakerTilOmregning) + .migrerAlleTempBehandlingerTilbakeTilTrygdetidOppdatert(sakslisteDTOTilOmregning) .also { sakIdListe -> logger.info( "Tilbakeført ${sakIdListe.tilbakestileBehandlinger.size} behandlinger til trygdetid oppdatert:\n" + @@ -109,25 +109,25 @@ internal class ReguleringsforespoerselRiver( } private fun publiserSak( - sak: Sak, + sakId: SakId, kjoering: String, packet: JsonMessage, sakListe: SakIDListe, context: MessageContext, ) { - logger.debug("Lagrer kjøring starta for sak ${sak.id}") - behandlingService.lagreKjoering(sak.id, KjoeringStatus.STARTA, kjoering) - logger.debug("Ferdig lagra kjøring starta for sak ${sak.id}") + logger.debug("Lagrer kjøring starta for sak $sakId") + behandlingService.lagreKjoering(sakId, KjoeringStatus.STARTA, kjoering) + logger.debug("Ferdig lagra kjøring starta for sak $sakId") packet.setEventNameForHendelseType(ReguleringHendelseType.SAK_FUNNET) - packet.tilbakestilteBehandlinger = sakListe.tilbakestilteForSak(sak.id) - packet.aapneBehandlinger = sakListe.aapneBehandlingerForSak(sak.id) + packet.tilbakestilteBehandlinger = sakListe.tilbakestilteForSak(sakId) + packet.aapneBehandlinger = sakListe.aapneBehandlingerForSak(sakId) packet[HENDELSE_DATA_KEY] = OmregningData( kjoering = kjoering, - sakId = sak.id, + sakId = sakId, revurderingaarsak = Revurderingaarsak.REGULERING, ) - logger.debug("Sender til omregning for sak ${sak.id}") + logger.debug("Sender til omregning for sak $sakId") context.publish(packet.toJson()) } } diff --git a/apps/etterlatte-oppdater-behandling/src/test/kotlin/InntektsjusteringJobbRiverTest.kt b/apps/etterlatte-oppdater-behandling/src/test/kotlin/InntektsjusteringJobbRiverTest.kt index 62fbf1e5d2c..edb43309921 100644 --- a/apps/etterlatte-oppdater-behandling/src/test/kotlin/InntektsjusteringJobbRiverTest.kt +++ b/apps/etterlatte-oppdater-behandling/src/test/kotlin/InntektsjusteringJobbRiverTest.kt @@ -3,7 +3,6 @@ import io.mockk.mockk import io.mockk.verify import no.nav.etterlatte.BehandlingService import no.nav.etterlatte.behandling.randomSakId -import no.nav.etterlatte.common.Enheter import no.nav.etterlatte.funksjonsbrytere.FeatureToggleService import no.nav.etterlatte.inntektsjustering.InntektsjusteringJobbRiver import no.nav.etterlatte.libs.common.behandling.BehandlingSammendrag @@ -13,9 +12,8 @@ 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 -import no.nav.etterlatte.libs.common.sak.Saker +import no.nav.etterlatte.libs.common.sak.SakslisteDTO import no.nav.etterlatte.rapidsandrivers.InntektsjusteringHendelseType import no.nav.etterlatte.rapidsandrivers.RapidEvents.ANTALL import no.nav.etterlatte.rapidsandrivers.RapidEvents.EKSKLUDERTE_SAKER @@ -37,17 +35,7 @@ class InntektsjusteringJobbRiverTest { val behandlingServiceMock = mockk(relaxed = true).also { - every { it.hentAlleSaker(any(), any(), any(), any()) } returns - Saker( - listOf( - Sak( - "saksbehandler1", - SakType.OMSTILLINGSSTOENAD, - randomSakId(), - Enheter.PORSGRUNN.enhetNr, - ), - ), - ) + every { it.hentAlleSaker(any(), any(), any(), any()) } returns SakslisteDTO(listOf(randomSakId())) } val inspector = @@ -74,17 +62,7 @@ class InntektsjusteringJobbRiverTest { val behandlingServiceMock = mockk(relaxed = true).also { - every { it.hentAlleSaker(any(), any(), any(), any()) } returns - Saker( - listOf( - Sak( - "saksbehandler1", - SakType.OMSTILLINGSSTOENAD, - randomSakId(), - Enheter.PORSGRUNN.enhetNr, - ), - ), - ) + every { it.hentAlleSaker(any(), any(), any(), any()) } returns SakslisteDTO(listOf(randomSakId())) } val inspector = diff --git a/apps/etterlatte-oppdater-behandling/src/test/kotlin/regulering/ReguleringsforespoerselRiverTest.kt b/apps/etterlatte-oppdater-behandling/src/test/kotlin/regulering/ReguleringsforespoerselRiverTest.kt index 67a5ee7c7f2..ff86e10d16c 100644 --- a/apps/etterlatte-oppdater-behandling/src/test/kotlin/regulering/ReguleringsforespoerselRiverTest.kt +++ b/apps/etterlatte-oppdater-behandling/src/test/kotlin/regulering/ReguleringsforespoerselRiverTest.kt @@ -18,10 +18,9 @@ import no.nav.etterlatte.libs.common.rapidsandrivers.EVENT_NAME_KEY import no.nav.etterlatte.libs.common.rapidsandrivers.FEILENDE_STEG import no.nav.etterlatte.libs.common.rapidsandrivers.lagParMedEventNameKey import no.nav.etterlatte.libs.common.sak.BehandlingOgSak -import no.nav.etterlatte.libs.common.sak.Sak import no.nav.etterlatte.libs.common.sak.SakIDListe import no.nav.etterlatte.libs.common.sak.SakId -import no.nav.etterlatte.libs.common.sak.Saker +import no.nav.etterlatte.libs.common.sak.SakslisteDTO import no.nav.etterlatte.rapidsandrivers.AAPNE_BEHANDLINGER_KEY import no.nav.etterlatte.rapidsandrivers.DATO_KEY import no.nav.etterlatte.rapidsandrivers.EventNames.FEILA @@ -64,10 +63,7 @@ internal class ReguleringsforespoerselRiverTest { val melding = genererReguleringMelding(foersteMai2023) val vedtakServiceMock = mockk(relaxed = true).also { - every { it.hentAlleSaker(any(), any(), any(), any()) } returns - Saker( - listOf(Sak("saksbehandler1", SakType.BARNEPENSJON, randomSakId(), porsgrunn)), - ) + every { it.hentAlleSaker(any(), any(), any(), any()) } returns SakslisteDTO(listOf(randomSakId())) } val inspector = TestRapid().apply { ReguleringsforespoerselRiver(this, vedtakServiceMock, featureToggleService) } @@ -84,13 +80,8 @@ internal class ReguleringsforespoerselRiverTest { val melding = genererReguleringMelding(foersteMai2023) val vedtakServiceMock = mockk(relaxed = true) every { vedtakServiceMock.hentAlleSaker("Regulering2023", any(), any(), any()) } returns - Saker( - listOf( - Sak("saksbehandler1", SakType.BARNEPENSJON, sakId1, porsgrunn), - Sak("saksbehandler2", SakType.BARNEPENSJON, sakId2, porsgrunn), - Sak("saksbehandler1", SakType.BARNEPENSJON, sakId3, porsgrunn), - ), - ) andThen Saker(listOf()) + SakslisteDTO(listOf(sakId1, sakId2, sakId3)) andThen SakslisteDTO(listOf()) + val inspector = TestRapid().apply { ReguleringsforespoerselRiver(this, vedtakServiceMock, featureToggleService) } @@ -124,13 +115,8 @@ internal class ReguleringsforespoerselRiverTest { val sak2 = randomSakId() val sak3 = randomSakId() every { behandlingServiceMock.hentAlleSaker("Regulering2023", any(), any(), any()) } returns - Saker( - listOf( - Sak("saksbehandler1", SakType.BARNEPENSJON, sak1, porsgrunn), - Sak("saksbehandler2", SakType.BARNEPENSJON, sak2, porsgrunn), - Sak("saksbehandler1", SakType.BARNEPENSJON, sak3, porsgrunn), - ), - ) + SakslisteDTO(listOf(sak1, sak2, sak3)) + val inspector = TestRapid().apply { ReguleringsforespoerselRiver(this, behandlingServiceMock, featureToggleService) } inspector.sendTestMessage(melding.toJson()) @@ -150,11 +136,8 @@ internal class ReguleringsforespoerselRiverTest { val behandlingServiceMock = mockk(relaxed = true) val sakId = randomSakId() every { behandlingServiceMock.hentAlleSaker("Regulering2023", any(), any(), any()) } returns - Saker( - listOf( - Sak("saksbehandler1", SakType.BARNEPENSJON, sakId, porsgrunn), - ), - ) + SakslisteDTO(listOf(sakId)) + val behandlingId1 = UUID.randomUUID() val behandlingId2 = UUID.randomUUID() every { behandlingServiceMock.migrerAlleTempBehandlingerTilbakeTilTrygdetidOppdatert(any()) } returns @@ -183,9 +166,7 @@ internal class ReguleringsforespoerselRiverTest { val behandlingServiceMock = mockk(relaxed = true).also { every { it.hentAlleSaker(any(), any(), any(), any()) } returns - Saker( - listOf(Sak("saksbehandler1", SakType.BARNEPENSJON, randomSakId(), porsgrunn)), - ) + SakslisteDTO(listOf(randomSakId())) } coEvery { behandlingServiceMock.migrerAlleTempBehandlingerTilbakeTilTrygdetidOppdatert(any()) @@ -207,16 +188,11 @@ internal class ReguleringsforespoerselRiverTest { val vedtakServiceMock = mockk(relaxed = true) val kjoering = "Regulering2023" every { vedtakServiceMock.hentAlleSaker(kjoering, any(), any(), any()) } returns - Saker( + SakslisteDTO( (0..MAKS_BATCHSTOERRELSE).map { - Sak("saksbehandler1", SakType.BARNEPENSJON, SakId(it.toLong()), porsgrunn) + SakId(it.toLong()) }, - ) andThen - Saker( - listOf( - Sak("saksbehandler1", SakType.BARNEPENSJON, randomSakId(), porsgrunn), - ), - ) andThen Saker(listOf()) + ) andThen SakslisteDTO(listOf(randomSakId())) andThen SakslisteDTO(listOf()) val inspector = TestRapid().apply { ReguleringsforespoerselRiver(this, vedtakServiceMock, featureToggleService) } diff --git a/libs/saksbehandling-common/src/main/kotlin/sak/Sak.kt b/libs/saksbehandling-common/src/main/kotlin/sak/Sak.kt index d8c987e103d..26a0a1eee32 100644 --- a/libs/saksbehandling-common/src/main/kotlin/sak/Sak.kt +++ b/libs/saksbehandling-common/src/main/kotlin/sak/Sak.kt @@ -16,6 +16,6 @@ data class VedtakSak( val id: SakId, ) -data class Saker( - val saker: List, +data class SakslisteDTO( + val sakIdListe: List, )