♻️ OppgaveDao blir QueryRunner - TransactionalOppgaveDao forsvinner

spesialist-selve/src/main/kotlin/no/nav/helse/bootstrap/SpesialistApp.kt

@@ -8,6 +8,7 @@ import no.nav.helse.Tilgangsgrupper
 import no.nav.helse.db.AvviksvurderingDao
 import no.nav.helse.db.BehandlingsstatistikkDao
 import no.nav.helse.db.NotatDao
+import no.nav.helse.db.OppgaveDao
 import no.nav.helse.db.OpptegnelseDao
 import no.nav.helse.db.PgHistorikkinnslagRepository
 import no.nav.helse.db.PgTotrinnsvurderingDao
@@ -25,7 +26,6 @@ import no.nav.helse.mediator.SaksbehandlerMediator
 import no.nav.helse.mediator.Subsumsjonsmelder
 import no.nav.helse.mediator.TilgangskontrollørForReservasjon
 import no.nav.helse.mediator.dokument.DokumentMediator
-import no.nav.helse.mediator.oppgave.OppgaveDao
 import no.nav.helse.mediator.oppgave.OppgaveService
 import no.nav.helse.modell.automatisering.PlukkTilManuell
 import no.nav.helse.modell.automatisering.Stikkprøver

spesialist-selve/src/main/kotlin/no/nav/helse/db/TransactionalOppgaveDao.kt → spesialist-selve/src/main/kotlin/no/nav/helse/db/OppgaveDao.kt

@@ -11,7 +11,7 @@ import java.time.LocalDate
 import java.util.UUID
 import javax.sql.DataSource
 
-class TransactionalOppgaveDao(queryRunner: QueryRunner) : OppgaveRepository, QueryRunner by queryRunner {
+class OppgaveDao(queryRunner: QueryRunner) : OppgaveRepository, QueryRunner by queryRunner {
     constructor(dataSource: DataSource) : this(MedDataSource(dataSource))
     constructor(session: Session) : this(MedSession(session))
 
@@ -128,6 +128,17 @@ class TransactionalOppgaveDao(queryRunner: QueryRunner) : OppgaveRepository, Que
         }
     }
 
+    override fun finnVedtaksperiodeId(oppgaveId: Long) =
+        asSQL(
+            """
+            SELECT v.vedtaksperiode_id
+            FROM vedtak v
+            INNER JOIN oppgave o on v.id = o.vedtak_ref
+            WHERE o.id = :oppgaveId
+            """.trimIndent(),
+            "oppgaveId" to oppgaveId,
+        ).single { row -> row.uuid("vedtaksperiode_id") }
+
     override fun harGyldigOppgave(utbetalingId: UUID) =
         asSQL(
             """

spesialist-selve/src/main/kotlin/no/nav/helse/db/OppgaveRepository.kt

@@ -19,6 +19,8 @@ interface OppgaveRepository {
 
     fun finnVedtaksperiodeId(fødselsnummer: String): UUID
 
+    fun finnVedtaksperiodeId(oppgaveId: Long): UUID
+
     fun harGyldigOppgave(utbetalingId: UUID): Boolean
 
     fun finnHendelseId(id: Long): UUID

spesialist-selve/src/main/kotlin/no/nav/helse/db/TransactionalPeriodehistorikkDao.kt

@@ -18,7 +18,7 @@ import java.util.UUID
 class TransactionalPeriodehistorikkDao(
     private val session: Session,
 ) : HistorikkinnslagRepository {
-    val oppgaveDao = TransactionalOppgaveDao(session)
+    val oppgaveDao = OppgaveDao(session)
 
     override fun lagre(
         historikkinnslag: HistorikkinnslagDto,

spesialist-selve/src/main/kotlin/no/nav/helse/mediator/GodkjenningService.kt

@@ -1,12 +1,13 @@
 package no.nav.helse.mediator
 
 import net.logstash.logback.argument.StructuredArguments
+import no.nav.helse.db.OppgaveDao
+import no.nav.helse.db.OppgaveRepository
 import no.nav.helse.db.PgHistorikkinnslagRepository
 import no.nav.helse.db.PgTotrinnsvurderingDao
 import no.nav.helse.db.ReservasjonDao
 import no.nav.helse.db.SaksbehandlerRepository
 import no.nav.helse.db.toDto
-import no.nav.helse.mediator.oppgave.OppgaveDao
 import no.nav.helse.mediator.oppgave.OppgaveService
 import no.nav.helse.modell.overstyring.OverstyringDao
 import no.nav.helse.modell.periodehistorikk.HistorikkinnslagDto
@@ -24,7 +25,7 @@ import javax.sql.DataSource
 
 internal class GodkjenningService(
     private val dataSource: DataSource,
-    private val oppgaveDao: OppgaveDao = OppgaveDao(dataSource),
+    private val oppgaveDao: OppgaveRepository = OppgaveDao(dataSource),
     private val overstyringDao: OverstyringDao = OverstyringDao(dataSource),
     private val rapidsConnection: RapidsConnection,
     private val oppgaveService: OppgaveService,

spesialist-selve/src/main/kotlin/no/nav/helse/mediator/Kommandofabrikk.kt

@@ -6,14 +6,14 @@ import kotliquery.sessionOf
 import no.nav.helse.db.AvviksvurderingDao
 import no.nav.helse.db.CommandContextRepository
 import no.nav.helse.db.InntektskilderDao
+import no.nav.helse.db.OppgaveDao
 import no.nav.helse.db.OppgaveRepository
 import no.nav.helse.db.OpptegnelseDao
 import no.nav.helse.db.PgTotrinnsvurderingDao
 import no.nav.helse.db.ReservasjonDao
 import no.nav.helse.db.TildelingDao
 import no.nav.helse.db.TransactionalEgenAnsattDao
 import no.nav.helse.db.TransactionalMeldingDao
-import no.nav.helse.db.TransactionalOppgaveDao
 import no.nav.helse.db.TransactionalPeriodehistorikkDao
 import no.nav.helse.db.TransactionalUtbetalingDao
 import no.nav.helse.db.TransactionalVedtakDao
@@ -22,7 +22,6 @@ import no.nav.helse.db.TransactionalÅpneGosysOppgaverDao
 import no.nav.helse.mediator.meldinger.AdressebeskyttelseEndret
 import no.nav.helse.mediator.meldinger.AdressebeskyttelseEndretCommand
 import no.nav.helse.mediator.meldinger.Personmelding
-import no.nav.helse.mediator.oppgave.OppgaveDao
 import no.nav.helse.mediator.oppgave.OppgaveService
 import no.nav.helse.modell.MeldingDao
 import no.nav.helse.modell.arbeidsforhold.ArbeidsforholdDao
@@ -77,7 +76,7 @@ internal typealias Kommandostarter = Personmelding.(Kommandofabrikk.() -> Comman
 internal class Kommandofabrikk(
     private val dataSource: DataSource,
     private val meldingDao: MeldingDao = MeldingDao(dataSource),
-    private val oppgaveDao: OppgaveDao = OppgaveDao(dataSource),
+    private val oppgaveDao: OppgaveRepository = OppgaveDao(dataSource),
     private val egenAnsattDao: EgenAnsattDao = EgenAnsattDao(dataSource),
     oppgaveService: () -> OppgaveService,
     private val godkjenningMediator: GodkjenningMediator,
@@ -126,7 +125,7 @@ internal class Kommandofabrikk(
             oppgavedataForAutomatisering = oppgaveDataForAutomatisering,
             automatisering = transaksjonellAutomatisering(transactionalSession),
             åpneGosysOppgaverRepository = TransactionalÅpneGosysOppgaverDao(transactionalSession),
-            oppgaveRepository = TransactionalOppgaveDao(transactionalSession),
+            oppgaveRepository = OppgaveDao(transactionalSession),
             oppgaveService = transaksjonellOppgaveService(transactionalSession),
             godkjenningMediator = GodkjenningMediator(OpptegnelseDao(transactionalSession)),
             godkjenningsbehov = godkjenningsbehovData,
@@ -192,7 +191,7 @@ internal class Kommandofabrikk(
             oppgaveService = transaksjonellOppgaveService(session),
             reservasjonRepository = ReservasjonDao(session),
             tildelingRepository = TildelingDao(session),
-            oppgaveRepository = TransactionalOppgaveDao(session),
+            oppgaveRepository = OppgaveDao(session),
             totrinnsvurderingService = lagTotrinnsvurderingService(session),
         )
 
@@ -232,7 +231,7 @@ internal class Kommandofabrikk(
         return AdressebeskyttelseEndretCommand(
             fødselsnummer = melding.fødselsnummer(),
             personRepository = PersonDao(transactionalSession),
-            oppgaveRepository = TransactionalOppgaveDao(transactionalSession),
+            oppgaveRepository = OppgaveDao(transactionalSession),
             godkjenningMediator = GodkjenningMediator(OpptegnelseDao(transactionalSession)),
             godkjenningsbehov = godkjenningsbehovData,
             utbetaling = utbetaling,
@@ -289,7 +288,7 @@ internal class Kommandofabrikk(
             utbetalingRepository = TransactionalUtbetalingDao(session),
             opptegnelseRepository = OpptegnelseDao(session),
             reservasjonRepository = ReservasjonDao(session),
-            oppgaveRepository = TransactionalOppgaveDao(session),
+            oppgaveRepository = OppgaveDao(session),
             tildelingRepository = TildelingDao(session),
             oppgaveService = transaksjonellOppgaveService(session),
             totrinnsvurderingService = lagTotrinnsvurderingService(session),
@@ -308,7 +307,7 @@ internal class Kommandofabrikk(
             oppgaveService = transaksjonellOppgaveService(session),
             reservasjonRepository = ReservasjonDao(session),
             tildelingRepository = TildelingDao(session),
-            oppgaveRepository = TransactionalOppgaveDao(session),
+            oppgaveRepository = OppgaveDao(session),
             totrinnsvurderingService = lagTotrinnsvurderingService(session),
         )
 
@@ -365,7 +364,7 @@ internal class Kommandofabrikk(
             påVentRepository = PåVentDao(session),
             overstyringRepository = OverstyringDao(session),
             periodehistorikkDao = TransactionalPeriodehistorikkDao(session),
-            oppgaveRepository = TransactionalOppgaveDao(session),
+            oppgaveRepository = OppgaveDao(session),
             avviksvurderingRepository = AvviksvurderingDao(session),
             oppgaveService = transaksjonellOppgaveService(session),
             godkjenningMediator = GodkjenningMediator(OpptegnelseDao(session)),
@@ -476,7 +475,7 @@ internal class Kommandofabrikk(
     private fun lagTotrinnsvurderingService(session: Session) =
         TotrinnsvurderingService(
             PgTotrinnsvurderingDao(session),
-            TransactionalOppgaveDao(session),
+            OppgaveDao(session),
             TransactionalPeriodehistorikkDao(session),
         )
 }