flytter ferdigstilling av oppgave til behandlingen blir iverksatt

navikt · Feb 6, 2025 · f527542 · f527542
1 parent ec6b2e4
commit f527542
Show file tree

Hide file tree

Showing 9 changed files with 5 additions and 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
@@ -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ørstegangsbehandlingContext.kt b/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/context/FørstegangsbehandlingContext.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øknad/PostgresSøknadRepo.kt b/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/repository/søknad/PostgresSøknadRepo.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øknad/SøknadDAO.kt b/app/src/main/kotlin/no/nav/tiltakspenger/vedtak/repository/søknad/SøknadDAO.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
@@ -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øknadRepo.kt b/domene/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/ports/SøknadRepo.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/...in/kotlin/no/nav/tiltakspenger/saksbehandling/service/behandling/BehandlingServiceImpl.kt b/...in/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
@@ -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øknadFakeRepo.kt b/test-common/src/main/kotlin/no/nav/tiltakspenger/fakes/repos/SøknadFakeRepo.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<Søknad> {
         return data.get().filter { it.value.sakId == sakId }.values.toList()
     }