✨ Legger til vedtaksperiode_forkastet på totrinnsvurdering

Author: trinelinderud

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

@@ -31,6 +31,12 @@ internal class AvbrytCommand(
                 featureToggles = featureToggles,
             ),
             AvbrytOppgaveCommand(vedtaksperiodeId = vedtaksperiodeId, oppgaveService = oppgaveService),
+            AvbrytTotrinnsvurderingCommand(
+                vedtaksperiodeId = vedtaksperiodeId,
+                fødselsnummer = fødselsnummer,
+                totrinnsvurderingRepository = totrinnsvurderingRepository,
+                featureToggles = featureToggles,
+            ),
             AvbrytContextCommand(vedtaksperiodeId = vedtaksperiodeId, commandContextDao = commandContextDao),
         )
 }

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

@@ -0,0 +1,33 @@
+package no.nav.helse.modell.kommando
+
+import no.nav.helse.FeatureToggles
+import no.nav.helse.spesialist.application.TotrinnsvurderingRepository
+import org.slf4j.LoggerFactory
+import java.util.UUID
+
+internal class AvbrytTotrinnsvurderingCommand(
+    private val vedtaksperiodeId: UUID,
+    private val fødselsnummer: String,
+    private val totrinnsvurderingRepository: TotrinnsvurderingRepository,
+    private val featureToggles: FeatureToggles,
+) : Command {
+    private companion object {
+        private val sikkerlogg = LoggerFactory.getLogger("tjenestekall")
+    }
+
+    override fun execute(context: CommandContext): Boolean {
+        sikkerlogg.info("setter vedtaksperiode_forkastet i totrinnsvurdering for fødselsnummer=$fødselsnummer")
+
+        val totrinnsvurdering =
+            if (featureToggles.skalBenytteNyTotrinnsvurderingsløsning()) {
+                totrinnsvurderingRepository.finn(fødselsnummer)
+            } else {
+                totrinnsvurderingRepository.finn(vedtaksperiodeId)
+            }
+        if (totrinnsvurdering == null) return true
+
+        totrinnsvurdering.vedtaksperiodeForkastet(vedtaksperiodeId)
+        totrinnsvurderingRepository.lagre(totrinnsvurdering)
+        return true
+    }
+}

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

@@ -191,6 +191,7 @@ internal class VurderBehovForTotrinnskontrollTest {
             oppdatert = LocalDateTime.now(),
             overstyringer = emptyList(),
             tilstand = tilstand,
+            vedtaksperiodeForkastet = false,
         )
 
     private fun command(nyTotrinnsløype: Boolean = true) =

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

@@ -0,0 +1,7 @@
+alter table totrinnsvurdering add column vedtaksperiode_forkastet boolean default false;
+
+update totrinnsvurdering tv
+set vedtaksperiode_forkastet = true
+from vedtak v
+where tv.vedtaksperiode_id = v.vedtaksperiode_id
+  and v.forkastet = true

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

@@ -43,13 +43,15 @@ class PgTotrinnsvurderingRepository(session: Session) : QueryRunner by MedSessio
                    tv.beslutter as beslutter_oid,
                    ui.id as utbetaling_id,
                    tv.tilstand,
+                   tv.vedtaksperiode_forkastet,
                    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 tv.tilstand != 'GODKJENT'
+              AND tv.vedtaksperiode_forkastet = false
             """.trimIndent(),
             "fodselsnummer" to fødselsnummer,
         ).singleOrNull { it.toTotrinnsvurdering() }
@@ -65,6 +67,7 @@ class PgTotrinnsvurderingRepository(session: Session) : QueryRunner by MedSessio
                    tv.beslutter as beslutter_oid,
                    ui.id as utbetaling_id,
                    tv.tilstand,
+                   tv.vedtaksperiode_forkastet,
                    tv.opprettet,
                    tv.oppdatert,
                    p.fødselsnummer
@@ -75,6 +78,7 @@ class PgTotrinnsvurderingRepository(session: Session) : QueryRunner by MedSessio
                      LEFT JOIN utbetaling_id ui on ui.id = tv.utbetaling_id_ref
             WHERE v.vedtaksperiode_id = :vedtaksperiodeId
               AND tv.tilstand != 'GODKJENT'
+              AND tv.vedtaksperiode_forkastet = false
             """.trimIndent(),
             "vedtaksperiodeId" to vedtaksperiodeId,
         ).singleOrNull { it.toTotrinnsvurderingDeprecated() }
@@ -103,6 +107,7 @@ class PgTotrinnsvurderingRepository(session: Session) : QueryRunner by MedSessio
                 beslutter           = :beslutter,
                 utbetaling_id_ref   = (SELECT id from utbetaling_id ui WHERE ui.utbetaling_id = :utbetalingId),
                 tilstand            = CAST(:tilstand AS totrinnsvurdering_tilstand),
+                vedtaksperiode_forkastet = :vedtaksperiodeForkastet,
                 oppdatert           = :oppdatert
             WHERE id = :id
             """.trimIndent(),
@@ -111,6 +116,7 @@ class PgTotrinnsvurderingRepository(session: Session) : QueryRunner by MedSessio
             "beslutter" to totrinnsvurdering.beslutter?.value,
             "utbetalingId" to totrinnsvurdering.utbetalingId,
             "tilstand" to totrinnsvurdering.tilstand.name,
+            "vedtaksperiodeForkastet" to totrinnsvurdering.vedtaksperiodeForkastet,
             "oppdatert" to totrinnsvurdering.oppdatert,
         ).update()
     }
@@ -126,6 +132,7 @@ class PgTotrinnsvurderingRepository(session: Session) : QueryRunner by MedSessio
             opprettet = localDateTime("opprettet"),
             oppdatert = localDateTimeOrNull("oppdatert"),
             tilstand = enumValueOf(string("tilstand")),
+            vedtaksperiodeForkastet = boolean("vedtaksperiode_forkastet"),
             overstyringer = overstyringRepository.finnAktive(string("fødselsnummer"), TotrinnsvurderingId(long("id"))),
         )
 
@@ -141,6 +148,7 @@ class PgTotrinnsvurderingRepository(session: Session) : QueryRunner by MedSessio
             opprettet = localDateTime("opprettet"),
             oppdatert = localDateTimeOrNull("oppdatert"),
             tilstand = enumValueOf(string("tilstand")),
+            vedtaksperiodeForkastet = boolean("vedtaksperiode_forkastet"),
             overstyringer = overstyringRepository.finnAktive(string("fødselsnummer")),
         )
 }

spesialist-db/src/test/kotlin/no/nav/helse/spesialist/db/repository/PgTotrinnsvurderingRepositoryTest.kt

@@ -61,6 +61,18 @@ class PgTotrinnsvurderingRepositoryTest : AbstractDBIntegrationTest() {
         assertNotNull(oppdatertTotrinnsvurdering.oppdatert)
     }
 
+    @Test
+    fun `finner ikke frem totrinnsvurdering hvor vdtaksperiode er forkastet`() {
+        totrinnsvurderingRepository.lagre(nyTotrinnsvurdering())
+        val hentetTotrinnsvurdering = totrinnsvurderingRepository.finn(FNR)
+        checkNotNull(hentetTotrinnsvurdering)
+        hentetTotrinnsvurdering.vedtaksperiodeForkastet(vedtaksperiodeId = VEDTAKSPERIODE)
+        totrinnsvurderingRepository.lagre(hentetTotrinnsvurdering)
+        val oppdatertTotrinnsvurdering = totrinnsvurderingRepository.finn(FNR)
+
+        assertNull(oppdatertTotrinnsvurdering)
+    }
+
     private fun nyTotrinnsvurdering(): Totrinnsvurdering =
         Totrinnsvurdering.ny(vedtaksperiodeId = VEDTAKSPERIODE, fødselsnummer = FNR)
 

spesialist-domain/src/main/kotlin/no/nav/helse/modell/totrinnsvurdering/Totrinnsvurdering.kt

@@ -32,6 +32,7 @@ class Totrinnsvurdering private constructor(
     oppdatert: LocalDateTime?,
     overstyringer: List<Overstyring> = emptyList(),
     tilstand: TotrinnsvurderingTilstand,
+    vedtaksperiodeForkastet: Boolean,
 ) : AggregateRoot<TotrinnsvurderingId>(id) {
     private val _overstyringer: MutableList<Overstyring> = overstyringer.toMutableList()
     val overstyringer: List<Overstyring>
@@ -52,6 +53,9 @@ class Totrinnsvurdering private constructor(
     var tilstand: TotrinnsvurderingTilstand = tilstand
         private set
 
+    var vedtaksperiodeForkastet: Boolean = vedtaksperiodeForkastet
+        private set
+
     fun settAvventerSaksbehandler() =
         oppdatering {
             tilstand = AVVENTER_SAKSBEHANDLER
@@ -109,6 +113,11 @@ class Totrinnsvurdering private constructor(
             .forEach { it.ferdigstill() }
     }
 
+    fun vedtaksperiodeForkastet(vedtaksperiodeId: UUID) =
+        oppdatering {
+            if (this.vedtaksperiodeId == vedtaksperiodeId) vedtaksperiodeForkastet = true
+        }
+
     private fun <T> oppdatering(block: () -> T): T {
         return block().also {
             oppdatert = LocalDateTime.now()
@@ -155,6 +164,7 @@ class Totrinnsvurdering private constructor(
                 oppdatert = null,
                 overstyringer = emptyList(),
                 tilstand = AVVENTER_SAKSBEHANDLER,
+                vedtaksperiodeForkastet = false,
             )
         }
 
@@ -169,6 +179,7 @@ class Totrinnsvurdering private constructor(
             oppdatert: LocalDateTime?,
             overstyringer: List<Overstyring>,
             tilstand: TotrinnsvurderingTilstand,
+            vedtaksperiodeForkastet: Boolean,
         ): Totrinnsvurdering {
             return Totrinnsvurdering(
                 id = id,
@@ -181,6 +192,7 @@ class Totrinnsvurdering private constructor(
                 oppdatert = oppdatert,
                 overstyringer = overstyringer,
                 tilstand = tilstand,
+                vedtaksperiodeForkastet = vedtaksperiodeForkastet,
             )
         }
     }

spesialist-domain/src/test/kotlin/no/nav/helse/modell/totrinnsvurdering/TotrinnsvurderingTest.kt

@@ -215,6 +215,14 @@ internal class TotrinnsvurderingTest {
         assertEquals(AVVENTER_SAKSBEHANDLER, totrinnsvurdering.tilstand)
     }
 
+    @Test
+    fun `kan sette vedtaksperiodeForkastet til true`() {
+        val vedtaksperiodeId = UUID.randomUUID()
+        val totrinnsvurdering = nyTotrinnsvurdering(vedtaksperiodeId = vedtaksperiodeId)
+        totrinnsvurdering.vedtaksperiodeForkastet(vedtaksperiodeId = vedtaksperiodeId)
+        assertTrue(totrinnsvurdering.vedtaksperiodeForkastet)
+    }
+
     private fun nySaksbehandler(
         oid: UUID = UUID.randomUUID()
     ) = SaksbehandlerOid(oid)
@@ -236,6 +244,7 @@ internal class TotrinnsvurderingTest {
         oppdatert = LocalDateTime.now(),
         overstyringer = overstyringer,
         tilstand = tilstand,
+        vedtaksperiodeForkastet = false,
     )
 
     private fun overstyrteDager(): List<OverstyrtTidslinjedag> = listOf(