✨ Legger til tilstand på totrinnsvurdering

Co-authored-by: Martin Solheim <[email protected]>
Co-authored-by: Øydis Kind Refsum <[email protected]>
Co-authored-by: Trine Linderud <[email protected]>
Co-authored-by: Christian Skovborg Gule <[email protected]>
Co-authored-by: Svein Elgstøen <[email protected]>

Author: 6 people

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

@@ -12,6 +12,7 @@ import no.nav.helse.modell.melding.Saksbehandlerløsning
 import no.nav.helse.modell.periodehistorikk.Historikkinnslag
 import no.nav.helse.modell.saksbehandler.SaksbehandlerDto
 import no.nav.helse.modell.totrinnsvurdering.Totrinnsvurdering
+import no.nav.helse.modell.totrinnsvurdering.TotrinnsvurderingTilstand.GODKJENT
 import no.nav.helse.spesialist.api.Godkjenninghåndterer
 import no.nav.helse.spesialist.api.vedtak.GodkjenningDto
 import no.nav.helse.spesialist.domain.Saksbehandler
@@ -88,7 +89,7 @@ class GodkjenningService(
                     featureToggles.skalBenytteNyTotrinnsvurderingsløsning(),
                 )
 
-                if (totrinnsvurdering?.erBeslutteroppgave == true && godkjenningDTO.godkjent) {
+                if (totrinnsvurdering?.tilstand == GODKJENT && godkjenningDTO.godkjent) {
                     val beslutter =
                         totrinnsvurdering.beslutter?.let { saksbehandlerId ->
                             session.saksbehandlerRepository.finn(saksbehandlerId)?.let { saksbehandler ->

spesialist-api/src/main/kotlin/no/nav/helse/mediator/SaksbehandlerMediator.kt

@@ -59,6 +59,7 @@ import no.nav.helse.modell.saksbehandler.handlinger.SkjønnsfastsattArbeidsgiver
 import no.nav.helse.modell.saksbehandler.handlinger.SkjønnsfastsattSykepengegrunnlag
 import no.nav.helse.modell.stoppautomatiskbehandling.StansAutomatiskBehandlinghåndtererImpl
 import no.nav.helse.modell.totrinnsvurdering.Totrinnsvurdering
+import no.nav.helse.modell.totrinnsvurdering.TotrinnsvurderingTilstand.AVVENTER_BESLUTTER
 import no.nav.helse.modell.vedtak.Utfall
 import no.nav.helse.modell.vilkårsprøving.Lovhjemmel
 import no.nav.helse.spesialist.api.SendIReturResult
@@ -291,7 +292,7 @@ class SaksbehandlerMediator(
         val totrinnsvurdering =
             eksisterendeTotrinnsvurdering(vedtaksperiodeId, fødselsnummer, totrinnsvurderingRepository)
         val feil =
-            if (totrinnsvurdering?.erBeslutteroppgave == true) {
+            if (totrinnsvurdering?.tilstand == AVVENTER_BESLUTTER) {
                 if (!legacySaksbehandler.harTilgangTil(listOf(Egenskap.BESLUTTER)) && !env.kanGodkjenneUtenBesluttertilgang) {
                     VedtakResultat.Feil.BeslutterFeil.TrengerBeslutterRolle()
                 } else if (totrinnsvurdering.saksbehandler?.value == legacySaksbehandler.oid && !env.kanBeslutteEgneSaker) {

spesialist-api/src/main/kotlin/no/nav/helse/spesialist/api/graphql/resolvers/ApiBeregnetPeriodeResolver.kt

@@ -18,6 +18,8 @@ import no.nav.helse.db.api.TotrinnsvurderingApiDao
 import no.nav.helse.db.api.VarselApiRepository
 import no.nav.helse.mediator.SaksbehandlerMediator
 import no.nav.helse.mediator.oppgave.ApiOppgaveService
+import no.nav.helse.modell.totrinnsvurdering.TotrinnsvurderingTilstand.AVVENTER_BESLUTTER
+import no.nav.helse.modell.totrinnsvurdering.TotrinnsvurderingTilstand.AVVENTER_SAKSBEHANDLER
 import no.nav.helse.spesialist.api.graphql.mapping.tilApiDag
 import no.nav.helse.spesialist.api.graphql.mapping.tilApiHendelse
 import no.nav.helse.spesialist.api.graphql.mapping.tilApiInntektstype
@@ -369,10 +371,10 @@ data class ApiBeregnetPeriodeResolver(
             return sessionFactory.transactionalSessionScope { sessionContext ->
                 sessionContext.totrinnsvurderingRepository.finn(fødselsnummer)?.let {
                     ApiTotrinnsvurdering(
-                        erRetur = it.erRetur,
+                        erRetur = it.tilstand == AVVENTER_SAKSBEHANDLER && it.saksbehandler != null,
                         saksbehandler = it.saksbehandler?.value,
                         beslutter = it.beslutter?.value,
-                        erBeslutteroppgave = !it.erRetur && it.saksbehandler != null,
+                        erBeslutteroppgave = it.tilstand == AVVENTER_BESLUTTER,
                     )
                 }
             }

spesialist-application/src/main/kotlin/no/nav/helse/modell/automatisering/Automatisering.kt

@@ -20,6 +20,7 @@ import no.nav.helse.modell.person.Adressebeskyttelse
 import no.nav.helse.modell.person.HentEnhetløsning.Companion.erEnhetUtland
 import no.nav.helse.modell.person.Sykefraværstilfelle
 import no.nav.helse.modell.stoppautomatiskbehandling.StansAutomatiskBehandlingMediator
+import no.nav.helse.modell.totrinnsvurdering.TotrinnsvurderingTilstand.GODKJENT
 import no.nav.helse.modell.utbetaling.Refusjonstype
 import no.nav.helse.modell.utbetaling.Utbetaling
 import no.nav.helse.modell.vedtaksperiode.Inntektskilde
@@ -258,7 +259,7 @@ internal class Automatisering(
         val antallÅpneGosysoppgaver = åpneGosysOppgaverDao.antallÅpneOppgaver(fødselsnummer)
         val harPågåendeOverstyring =
             if (featureToggles.skalBenytteNyTotrinnsvurderingsløsning()) {
-                totrinnsvurderingRepository.finn(fødselsnummer)?.ferdigstilt == false
+                totrinnsvurderingRepository.finn(fødselsnummer)?.tilstand != GODKJENT
             } else {
                 overstyringDao.harVedtaksperiodePågåendeOverstyring(vedtaksperiodeId)
             }

spesialist-application/src/main/kotlin/no/nav/helse/modell/kommando/ReserverPersonHvisTildeltCommand.kt

@@ -4,6 +4,7 @@ import no.nav.helse.FeatureToggles
 import no.nav.helse.db.OppgaveDao
 import no.nav.helse.db.ReservasjonDao
 import no.nav.helse.db.TildelingDao
+import no.nav.helse.modell.totrinnsvurdering.TotrinnsvurderingTilstand.AVVENTER_BESLUTTER
 import no.nav.helse.spesialist.application.TotrinnsvurderingRepository
 import org.slf4j.Logger
 import org.slf4j.LoggerFactory
@@ -31,7 +32,7 @@ internal class ReserverPersonHvisTildeltCommand(
                 totrinnsvurderingRepository.finn(vedtaksperiodeId)
             }
         val saksbehandlerOid: UUID =
-            if (totrinnsvurdering?.erBeslutteroppgave == true) {
+            if (totrinnsvurdering?.tilstand == AVVENTER_BESLUTTER) {
                 totrinnsvurdering.saksbehandler?.value ?: tildeltSaksbehandler.oid
             } else {
                 tildeltSaksbehandler.oid

spesialist-application/src/main/kotlin/no/nav/helse/modell/kommando/VurderBehovForTotrinnskontroll.kt

@@ -8,6 +8,7 @@ import no.nav.helse.modell.periodehistorikk.Historikkinnslag
 import no.nav.helse.modell.person.Sykefraværstilfelle
 import no.nav.helse.modell.person.vedtaksperiode.Vedtaksperiode
 import no.nav.helse.modell.totrinnsvurdering.Totrinnsvurdering
+import no.nav.helse.modell.totrinnsvurdering.TotrinnsvurderingTilstand.AVVENTER_BESLUTTER
 import no.nav.helse.spesialist.application.TotrinnsvurderingRepository
 import org.slf4j.LoggerFactory
 import java.util.UUID
@@ -49,10 +50,14 @@ internal class VurderBehovForTotrinnskontroll(
         if ((kreverTotrinnsvurdering && !vedtaksperiodeHarFerdigstiltOppgave) || eksisterendeTotrinnsvurdering != null) {
             logg.info("Vedtaksperioden: $vedtaksperiodeId trenger totrinnsvurdering")
 
-            val totrinnsvurdering = (eksisterendeTotrinnsvurdering ?: Totrinnsvurdering.ny(vedtaksperiodeId, fødselsnummer))
-            if (totrinnsvurdering.erBeslutteroppgave) {
-                totrinnsvurdering.settRetur()
-                periodehistorikkDao.lagre(Historikkinnslag.totrinnsvurderingAutomatiskRetur(), vedtaksperiode.gjeldendeUnikId)
+            val totrinnsvurdering =
+                (eksisterendeTotrinnsvurdering ?: Totrinnsvurdering.ny(vedtaksperiodeId, fødselsnummer))
+            if (totrinnsvurdering.tilstand == AVVENTER_BESLUTTER) {
+                totrinnsvurdering.settAvventerSaksbehandler()
+                periodehistorikkDao.lagre(
+                    Historikkinnslag.totrinnsvurderingAutomatiskRetur(),
+                    vedtaksperiode.gjeldendeUnikId,
+                )
             }
             totrinnsvurderingRepository.lagre(totrinnsvurdering)
 
@@ -69,13 +74,24 @@ internal class VurderBehovForTotrinnskontroll(
         kreverTotrinnsvurdering: Boolean,
         vedtaksperiodeHarFerdigstiltOppgave: Boolean,
     ) {
-        if ((kreverTotrinnsvurdering && !vedtaksperiodeHarFerdigstiltOppgave) || overstyringDao.harVedtaksperiodePågåendeOverstyring(vedtaksperiodeId)) {
+        if ((kreverTotrinnsvurdering && !vedtaksperiodeHarFerdigstiltOppgave) ||
+            overstyringDao.harVedtaksperiodePågåendeOverstyring(
+                vedtaksperiodeId,
+            )
+        ) {
             logg.info("Vedtaksperioden: $vedtaksperiodeId trenger totrinnsvurdering")
 
-            val totrinnsvurdering = totrinnsvurderingRepository.finn(vedtaksperiodeId) ?: Totrinnsvurdering.ny(vedtaksperiodeId, fødselsnummer)
-            if (totrinnsvurdering.erBeslutteroppgave) {
-                totrinnsvurdering.settRetur()
-                periodehistorikkDao.lagre(Historikkinnslag.totrinnsvurderingAutomatiskRetur(), vedtaksperiode.gjeldendeUnikId)
+            val totrinnsvurdering =
+                totrinnsvurderingRepository.finn(vedtaksperiodeId) ?: Totrinnsvurdering.ny(
+                    vedtaksperiodeId,
+                    fødselsnummer,
+                )
+            if (totrinnsvurdering.tilstand == AVVENTER_BESLUTTER) {
+                totrinnsvurdering.settAvventerSaksbehandler()
+                periodehistorikkDao.lagre(
+                    Historikkinnslag.totrinnsvurderingAutomatiskRetur(),
+                    vedtaksperiode.gjeldendeUnikId,
+                )
             }
 
             totrinnsvurderingRepository.lagre(totrinnsvurdering)

spesialist-application/src/test/kotlin/no/nav/helse/spesialist/application/kommando/VurderBehovForTotrinnskontrollTest.kt

@@ -16,6 +16,9 @@ import no.nav.helse.modell.person.vedtaksperiode.Varsel
 import no.nav.helse.modell.person.vedtaksperiode.Vedtaksperiode
 import no.nav.helse.modell.totrinnsvurdering.Totrinnsvurdering
 import no.nav.helse.modell.totrinnsvurdering.TotrinnsvurderingId
+import no.nav.helse.modell.totrinnsvurdering.TotrinnsvurderingTilstand
+import no.nav.helse.modell.totrinnsvurdering.TotrinnsvurderingTilstand.AVVENTER_BESLUTTER
+import no.nav.helse.modell.totrinnsvurdering.TotrinnsvurderingTilstand.AVVENTER_SAKSBEHANDLER
 import no.nav.helse.spesialist.application.TotrinnsvurderingRepository
 import no.nav.helse.spesialist.domain.SaksbehandlerOid
 import no.nav.helse.spesialist.domain.legacy.LegacyBehandling
@@ -125,19 +128,22 @@ internal class VurderBehovForTotrinnskontrollTest {
     }
 
     @Test
-    fun `Hvis totrinnsvurdering har beslutter skal totrinnsvurderingen markeres som retur`() {
+    fun `Hvis totrinnsvurdering har beslutter skal tilstanden til totrinnsvurderingen settes tilbake til AVVENTER_SAKSBEHANDLER`() {
         val saksbehandler = lagSaksbehandlerOid()
         val beslutter = lagSaksbehandlerOid()
 
         every { overstyringDao.harVedtaksperiodePågåendeOverstyring(any()) } returns true
-        totrinnsvurderingRepository.totrinnsvurderingSomSkalReturneres = lagTotrinnsvurdering(false, saksbehandler, beslutter)
+        totrinnsvurderingRepository.totrinnsvurderingSomSkalReturneres = lagTotrinnsvurdering(
+            saksbehandler = saksbehandler,
+            beslutter = beslutter
+        )
 
         assertTrue(command.execute(context))
 
         assertEquals(1, totrinnsvurderingRepository.lagredeTotrinnsvurderinger.size)
         verify(exactly = 1) { oppgaveService.reserverOppgave(saksbehandler.value, FØDSELSNUMMER) }
 
-        assertEquals(true, totrinnsvurderingRepository.lagredeTotrinnsvurderinger.single().erRetur)
+        assertEquals(AVVENTER_SAKSBEHANDLER, totrinnsvurderingRepository.lagredeTotrinnsvurderinger.single().tilstand)
 
         verify(exactly = 1) {
             periodehistorikkDao.lagre(historikkinnslag = any<TotrinnsvurderingAutomatiskRetur>(), any())
@@ -170,22 +176,21 @@ internal class VurderBehovForTotrinnskontrollTest {
     private fun lagSaksbehandlerOid(oid: UUID = UUID.randomUUID()) = SaksbehandlerOid(oid)
 
     private fun lagTotrinnsvurdering(
-        erRetur: Boolean = false,
+        tilstand: TotrinnsvurderingTilstand = AVVENTER_BESLUTTER,
         saksbehandler: SaksbehandlerOid = lagSaksbehandlerOid(),
         beslutter: SaksbehandlerOid = lagSaksbehandlerOid()
     ) =
         Totrinnsvurdering.fraLagring(
             id = TotrinnsvurderingId(nextLong()),
             vedtaksperiodeId = VEDTAKSPERIODE_ID_2,
             fødselsnummer = FØDSELSNUMMER,
-            erRetur = erRetur,
             saksbehandler = saksbehandler,
             beslutter = beslutter,
             utbetalingId = null,
             opprettet = LocalDateTime.now(),
             oppdatert = LocalDateTime.now(),
             overstyringer = emptyList(),
-            ferdigstilt = false,
+            tilstand = tilstand,
         )
 
     private fun command(nyTotrinnsløype: Boolean = true) =

spesialist-db-migrations/src/main/resources/db/migration/V578__tilstand_i_totrinnsvurdering.sql

@@ -0,0 +1,14 @@
+create type totrinnsvurdering_tilstand as enum ('AVVENTER_SAKSBEHANDLER', 'AVVENTER_BESLUTTER', 'GODKJENT');
+
+alter table totrinnsvurdering
+    add column tilstand totrinnsvurdering_tilstand;
+
+update totrinnsvurdering set tilstand = 'GODKJENT' where tilstand is null and utbetaling_id_ref is not null;
+update totrinnsvurdering set tilstand = 'AVVENTER_SAKSBEHANDLER' where tilstand is null and er_retur = true;
+update totrinnsvurdering set tilstand = 'AVVENTER_BESLUTTER' where tilstand is null and saksbehandler is not null;
+update totrinnsvurdering set tilstand = 'AVVENTER_SAKSBEHANDLER' where tilstand is null;
+
+alter table totrinnsvurdering
+    alter column tilstand set not null;
+
+alter table totrinnsvurdering drop column er_retur;

spesialist-db/src/main/kotlin/no/nav/helse/spesialist/db/repository/PgTotrinnsvurderingRepository.kt

@@ -39,17 +39,17 @@ class PgTotrinnsvurderingRepository(session: Session) : QueryRunner by MedSessio
             SELECT tv.id,
                    tv.vedtaksperiode_id,
                    p.fødselsnummer,
-                   er_retur,
                    tv.saksbehandler as saksbehandler_oid,
                    tv.beslutter as beslutter_oid,
                    ui.id as utbetaling_id,
+                   tv.tilstand,
                    tv.opprettet,
                    tv.oppdatert
             FROM totrinnsvurdering tv
                      INNER JOIN person p on tv.person_ref = p.id
                      LEFT JOIN utbetaling_id ui on ui.id = tv.utbetaling_id_ref
             WHERE p.fødselsnummer = :fodselsnummer
-              AND utbetaling_id_ref IS NULL
+              AND tv.tilstand != 'GODKJENT'
             """.trimIndent(),
             "fodselsnummer" to fødselsnummer,
         ).singleOrNull { it.toTotrinnsvurdering() }
@@ -61,10 +61,10 @@ class PgTotrinnsvurderingRepository(session: Session) : QueryRunner by MedSessio
             SELECT DISTINCT ON (tv.id)
                    v.vedtaksperiode_id,
                    tv.id,
-                   er_retur,
                    tv.saksbehandler as saksbehandler_oid,
                    tv.beslutter as beslutter_oid,
                    ui.id as utbetaling_id,
+                   tv.tilstand,
                    tv.opprettet,
                    tv.oppdatert,
                    p.fødselsnummer
@@ -74,43 +74,43 @@ class PgTotrinnsvurderingRepository(session: Session) : QueryRunner by MedSessio
                      INNER JOIN oppgave o on v.id = o.vedtak_ref
                      LEFT JOIN utbetaling_id ui on ui.id = tv.utbetaling_id_ref
             WHERE v.vedtaksperiode_id = :vedtaksperiodeId
-              AND utbetaling_id_ref IS NULL
+              AND tv.tilstand != 'GODKJENT'
             """.trimIndent(),
             "vedtaksperiodeId" to vedtaksperiodeId,
         ).singleOrNull { it.toTotrinnsvurderingDeprecated() }
 
     private fun insert(totrinnsvurdering: Totrinnsvurdering): Long =
         asSQL(
             """
-            INSERT INTO totrinnsvurdering (vedtaksperiode_id, er_retur, saksbehandler, beslutter, person_ref, opprettet, oppdatert)
-            SELECT :vedtaksperiodeId, :erRetur, :saksbehandler, :beslutter, p.id, :opprettet, null
+            INSERT INTO totrinnsvurdering (vedtaksperiode_id, saksbehandler, beslutter, person_ref, tilstand, opprettet, oppdatert)
+            SELECT :vedtaksperiodeId, :saksbehandler, :beslutter, p.id, CAST(:tilstand AS totrinnsvurdering_tilstand), :opprettet, null
             FROM person p 
             WHERE p.fødselsnummer = :fodselsnummer
             """.trimIndent(),
             "vedtaksperiodeId" to totrinnsvurdering.vedtaksperiodeId,
-            "erRetur" to totrinnsvurdering.erRetur,
             "saksbehandler" to totrinnsvurdering.saksbehandler?.value,
             "beslutter" to totrinnsvurdering.beslutter?.value,
             "fodselsnummer" to totrinnsvurdering.fødselsnummer,
+            "tilstand" to totrinnsvurdering.tilstand.name,
             "opprettet" to totrinnsvurdering.opprettet,
         ).updateAndReturnGeneratedKey()
 
     private fun update(totrinnsvurdering: Totrinnsvurdering) {
         asSQL(
             """
             UPDATE totrinnsvurdering 
-            SET er_retur            = :erRetur,
-                saksbehandler       = :saksbehandler,
+            SET saksbehandler       = :saksbehandler,
                 beslutter           = :beslutter,
                 utbetaling_id_ref   = (SELECT id from utbetaling_id ui WHERE ui.utbetaling_id = :utbetalingId),
+                tilstand            = CAST(:tilstand AS totrinnsvurdering_tilstand),
                 oppdatert           = :oppdatert
             WHERE id = :id
             """.trimIndent(),
             "id" to totrinnsvurdering.id().value,
-            "erRetur" to totrinnsvurdering.erRetur,
             "saksbehandler" to totrinnsvurdering.saksbehandler?.value,
             "beslutter" to totrinnsvurdering.beslutter?.value,
             "utbetalingId" to totrinnsvurdering.utbetalingId,
+            "tilstand" to totrinnsvurdering.tilstand.name,
             "oppdatert" to totrinnsvurdering.oppdatert,
         ).update()
     }
@@ -120,13 +120,12 @@ class PgTotrinnsvurderingRepository(session: Session) : QueryRunner by MedSessio
             id = TotrinnsvurderingId(long("id")),
             vedtaksperiodeId = uuid("vedtaksperiode_id"),
             fødselsnummer = string("fødselsnummer"),
-            erRetur = boolean("er_retur"),
             saksbehandler = uuidOrNull("saksbehandler_oid")?.let(::SaksbehandlerOid),
             beslutter = uuidOrNull("beslutter_oid")?.let(::SaksbehandlerOid),
             utbetalingId = uuidOrNull("utbetaling_id"),
             opprettet = localDateTime("opprettet"),
             oppdatert = localDateTimeOrNull("oppdatert"),
-            ferdigstilt = uuidOrNull("utbetaling_id") != null,
+            tilstand = enumValueOf(string("tilstand")),
             overstyringer = overstyringRepository.finnAktive(string("fødselsnummer"), TotrinnsvurderingId(long("id"))),
         )
 
@@ -136,13 +135,12 @@ class PgTotrinnsvurderingRepository(session: Session) : QueryRunner by MedSessio
             id = TotrinnsvurderingId(long("id")),
             vedtaksperiodeId = uuid("vedtaksperiode_id"),
             fødselsnummer = string("fødselsnummer"),
-            erRetur = boolean("er_retur"),
             saksbehandler = uuidOrNull("saksbehandler_oid")?.let(::SaksbehandlerOid),
             beslutter = uuidOrNull("beslutter_oid")?.let(::SaksbehandlerOid),
             utbetalingId = uuidOrNull("utbetaling_id"),
             opprettet = localDateTime("opprettet"),
             oppdatert = localDateTimeOrNull("oppdatert"),
-            ferdigstilt = uuidOrNull("utbetaling_id") != null,
+            tilstand = enumValueOf(string("tilstand")),
             overstyringer = overstyringRepository.finnAktive(string("fødselsnummer")),
         )
 }