From f5275424036004aa0c84d35b5fb4c9a96715bca6 Mon Sep 17 00:00:00 2001 From: Tia Firing Date: Thu, 6 Feb 2025 07:26:06 +0100 Subject: [PATCH] flytter ferdigstilling av oppgave til behandlingen blir iverksatt --- .../vedtak/context/ApplicationContext.kt | 1 - .../context/F\303\270rstegangsbehandlingContext.kt" | 3 --- .../s\303\270knad/PostgresS\303\270knadRepo.kt" | 7 ------- .../repository/s\303\270knad/S\303\270knadDAO.kt" | 12 ------------ .../no/nav/tiltakspenger/LocalApplicationContext.kt | 1 - .../saksbehandling/ports/S\303\270knadRepo.kt" | 4 ---- .../service/behandling/BehandlingServiceImpl.kt | 12 +++++------- .../tiltakspenger/common/TestApplicationContext.kt | 1 - .../fakes/repos/S\303\270knadFakeRepo.kt" | 7 ------- 9 files changed, 5 insertions(+), 43 deletions(-) diff --git a/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/context/ApplicationContext.kt b/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/context/ApplicationContext.kt index af6ece968..910943604 100644 --- a/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/context/ApplicationContext.kt +++ b/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/context/ApplicationContext.kt @@ -128,7 +128,6 @@ open class ApplicationContext( sakService = sakContext.sakService, tiltakGateway = tiltakContext.tiltakGateway, oppgaveGateway = oppgaveGateway, - søknadRepo = søknadContext.søknadRepo, ) } diff --git "a/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/context/F\303\270rstegangsbehandlingContext.kt" "b/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/context/F\303\270rstegangsbehandlingContext.kt" index d216af2f8..2198184d8 100644 --- "a/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/context/F\303\270rstegangsbehandlingContext.kt" +++ "b/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/context/F\303\270rstegangsbehandlingContext.kt" @@ -15,7 +15,6 @@ import no.nav.tiltakspenger.saksbehandling.ports.OppgaveGateway import no.nav.tiltakspenger.saksbehandling.ports.RammevedtakRepo import no.nav.tiltakspenger.saksbehandling.ports.StatistikkSakRepo import no.nav.tiltakspenger.saksbehandling.ports.StatistikkStønadRepo -import no.nav.tiltakspenger.saksbehandling.ports.SøknadRepo import no.nav.tiltakspenger.saksbehandling.ports.TiltakGateway import no.nav.tiltakspenger.saksbehandling.service.behandling.BehandlingService import no.nav.tiltakspenger.saksbehandling.service.behandling.BehandlingServiceImpl @@ -49,7 +48,6 @@ open class FørstegangsbehandlingContext( sakService: SakService, tiltakGateway: TiltakGateway, oppgaveGateway: OppgaveGateway, - søknadRepo: SøknadRepo, ) { open val rammevedtakRepo: RammevedtakRepo by lazy { RammevedtakPostgresRepo(sessionFactory as PostgresSessionFactory) } open val behandlingRepo: BehandlingRepo by lazy { BehandlingPostgresRepo(sessionFactory as PostgresSessionFactory) } @@ -68,7 +66,6 @@ open class FørstegangsbehandlingContext( sakService = sakService, tiltakGateway = tiltakGateway, oppgaveGateway = oppgaveGateway, - søknadRepo = søknadRepo, ) } val tiltaksdeltagelseVilkårService: TiltaksdeltagelseVilkårService by lazy { diff --git "a/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/repository/s\303\270knad/PostgresS\303\270knadRepo.kt" "b/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/repository/s\303\270knad/PostgresS\303\270knadRepo.kt" index 5a8659e9f..b85d8d335 100644 --- "a/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/repository/s\303\270knad/PostgresS\303\270knadRepo.kt" +++ "b/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/repository/s\303\270knad/PostgresS\303\270knadRepo.kt" @@ -1,7 +1,5 @@ package no.nav.tiltakspenger.vedtak.repository.søknad -import no.nav.tiltakspenger.felles.OppgaveId -import no.nav.tiltakspenger.libs.common.BehandlingId import no.nav.tiltakspenger.libs.common.SakId import no.nav.tiltakspenger.libs.common.SøknadId import no.nav.tiltakspenger.libs.persistering.domene.TransactionContext @@ -30,9 +28,4 @@ internal class PostgresSøknadRepo( sessionFactory.withSession { SøknadDAO.finnSakId(søknadId, it) } - - override fun hentOppgaveIdForBehandling(behandlingId: BehandlingId): OppgaveId? = - sessionFactory.withSession { - SøknadDAO.finnOppgaveIdForBehandlingId(behandlingId, it) - } } diff --git "a/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/repository/s\303\270knad/S\303\270knadDAO.kt" "b/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/repository/s\303\270knad/S\303\270knadDAO.kt" index 3a654eec7..219998776 100644 --- "a/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/repository/s\303\270knad/S\303\270knadDAO.kt" +++ "b/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/repository/s\303\270knad/S\303\270knadDAO.kt" @@ -46,16 +46,6 @@ internal object SøknadDAO { .asSingle, ) - fun finnOppgaveIdForBehandlingId( - behandlingId: BehandlingId, - session: Session, - ): OppgaveId? = - session.run( - queryOf(sqlHent, behandlingId.toString()) - .map { row -> row.toOppgaveId() } - .asSingle, - ) - fun finnSakId( søknadId: SøknadId, session: Session, @@ -202,8 +192,6 @@ internal object SøknadDAO { private fun Row.toJournalpostId() = string("journalpost_id") - private fun Row.toOppgaveId() = stringOrNull("oppgave_id")?.let { OppgaveId(it) } - private fun Row.toSakId() = stringOrNull("sak_id")?.let { SakId.fromString(it) } private fun Row.toSøknad(session: Session): Søknad { diff --git a/app/src/test/kotlin/no/nav/tiltakspenger/LocalApplicationContext.kt b/app/src/test/kotlin/no/nav/tiltakspenger/LocalApplicationContext.kt index 196be7055..c447e005f 100644 --- a/app/src/test/kotlin/no/nav/tiltakspenger/LocalApplicationContext.kt +++ b/app/src/test/kotlin/no/nav/tiltakspenger/LocalApplicationContext.kt @@ -210,7 +210,6 @@ class LocalApplicationContext : ApplicationContext(gitHash = "fake-git-hash") { sakService = sakContext.sakService, tiltakGateway = tiltakGatewayFake, oppgaveGateway = oppgaveGateway, - søknadRepo = søknadContext.søknadRepo, ) {} } override val utbetalingContext by lazy { diff --git "a/domene/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/ports/S\303\270knadRepo.kt" "b/domene/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/ports/S\303\270knadRepo.kt" index a3fe05bee..19e0b7fda 100644 --- "a/domene/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/ports/S\303\270knadRepo.kt" +++ "b/domene/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/ports/S\303\270knadRepo.kt" @@ -1,7 +1,5 @@ package no.nav.tiltakspenger.saksbehandling.ports -import no.nav.tiltakspenger.felles.OppgaveId -import no.nav.tiltakspenger.libs.common.BehandlingId import no.nav.tiltakspenger.libs.common.SakId import no.nav.tiltakspenger.libs.common.SøknadId import no.nav.tiltakspenger.libs.persistering.domene.TransactionContext @@ -16,6 +14,4 @@ interface SøknadRepo { fun hentForSøknadId(søknadId: SøknadId): Søknad? fun hentSakIdForSoknad(søknadId: SøknadId): SakId? - - fun hentOppgaveIdForBehandling(behandlingId: BehandlingId): OppgaveId? } diff --git a/domene/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/service/behandling/BehandlingServiceImpl.kt b/domene/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/service/behandling/BehandlingServiceImpl.kt index 9b91d87fe..b7d8432a3 100644 --- a/domene/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/service/behandling/BehandlingServiceImpl.kt +++ b/domene/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/service/behandling/BehandlingServiceImpl.kt @@ -41,7 +41,6 @@ import no.nav.tiltakspenger.saksbehandling.ports.OppgaveGateway import no.nav.tiltakspenger.saksbehandling.ports.RammevedtakRepo import no.nav.tiltakspenger.saksbehandling.ports.StatistikkSakRepo import no.nav.tiltakspenger.saksbehandling.ports.StatistikkStønadRepo -import no.nav.tiltakspenger.saksbehandling.ports.SøknadRepo import no.nav.tiltakspenger.saksbehandling.ports.TiltakGateway import no.nav.tiltakspenger.saksbehandling.service.person.PersonService import no.nav.tiltakspenger.saksbehandling.service.sak.KanIkkeStarteFørstegangsbehandling @@ -67,7 +66,6 @@ class BehandlingServiceImpl( private val gitHash: String, private val tiltakGateway: TiltakGateway, private val oppgaveGateway: OppgaveGateway, - private val søknadRepo: SøknadRepo, ) : BehandlingService { val logger = KotlinLogging.logger { } @@ -184,12 +182,7 @@ class BehandlingServiceImpl( logger.warn { "Navident ${saksbehandler.navIdent} med rollene ${saksbehandler.roller} har ikke tilgang til å sende behandling til beslutter" } return KanIkkeSendeTilBeslutter.MåVæreSaksbehandler.left() } - val oppgaveId = søknadRepo.hentOppgaveIdForBehandling(behandlingId) return hentBehandling(behandlingId, saksbehandler, correlationId).tilBeslutning(saksbehandler).also { - oppgaveId?.let { id -> - logger.info { "Ferdigstiller oppgave med id $id for søknad med behandlingsId $behandlingId" } - oppgaveGateway.ferdigstillOppgave(id) - } behandlingRepo.lagre(it) }.right() } @@ -277,6 +270,11 @@ class BehandlingServiceImpl( ) } + behandling.oppgaveId?.let { id -> + logger.info { "Ferdigstiller oppgave med id $id for behandling med behandlingsId $behandlingId" } + oppgaveGateway.ferdigstillOppgave(id) + } + return iverksattBehandling.right() } diff --git a/test-common/src/main/kotlin/no/nav/tiltakspenger/common/TestApplicationContext.kt b/test-common/src/main/kotlin/no/nav/tiltakspenger/common/TestApplicationContext.kt index e66a22ee3..032901bc6 100644 --- a/test-common/src/main/kotlin/no/nav/tiltakspenger/common/TestApplicationContext.kt +++ b/test-common/src/main/kotlin/no/nav/tiltakspenger/common/TestApplicationContext.kt @@ -216,7 +216,6 @@ class TestApplicationContext( sakService = sakContext.sakService, tiltakGateway = tiltakGatewayFake, oppgaveGateway = oppgaveGateway, - søknadRepo = søknadFakeRepo, ) { override val rammevedtakRepo = rammevedtakFakeRepo override val behandlingRepo = behandlingFakeRepo diff --git "a/test-common/src/main/kotlin/no/nav/tiltakspenger/fakes/repos/S\303\270knadFakeRepo.kt" "b/test-common/src/main/kotlin/no/nav/tiltakspenger/fakes/repos/S\303\270knadFakeRepo.kt" index c48c9fdc3..7e58e1307 100644 --- "a/test-common/src/main/kotlin/no/nav/tiltakspenger/fakes/repos/S\303\270knadFakeRepo.kt" +++ "b/test-common/src/main/kotlin/no/nav/tiltakspenger/fakes/repos/S\303\270knadFakeRepo.kt" @@ -1,12 +1,9 @@ package no.nav.tiltakspenger.fakes.repos import arrow.atomic.Atomic -import no.nav.tiltakspenger.felles.OppgaveId -import no.nav.tiltakspenger.libs.common.BehandlingId import no.nav.tiltakspenger.libs.common.SakId import no.nav.tiltakspenger.libs.common.SøknadId import no.nav.tiltakspenger.libs.persistering.domene.TransactionContext -import no.nav.tiltakspenger.objectmothers.ObjectMother import no.nav.tiltakspenger.saksbehandling.domene.behandling.Søknad import no.nav.tiltakspenger.saksbehandling.ports.SøknadRepo @@ -26,10 +23,6 @@ class SøknadFakeRepo : SøknadRepo { override fun hentSakIdForSoknad(søknadId: SøknadId): SakId = data.get()[søknadId]!!.sakId - override fun hentOppgaveIdForBehandling(behandlingId: BehandlingId): OppgaveId { - return ObjectMother.oppgaveId() - } - fun hentForSakId(sakId: SakId): List { return data.get().filter { it.value.sakId == sakId }.values.toList() }