Mulighet for å resende utbetaling

navikt · Jan 4, 2024 · e5fa5d7 · e5fa5d7
1 parent 175da81
commit e5fa5d7
Show file tree

Hide file tree

Showing 21 changed files with 470 additions and 42 deletions.
diff --git a/database/src/main/kotlin/no/nav/su/se/bakover/database/sak/SakPostgresRepo.kt b/database/src/main/kotlin/no/nav/su/se/bakover/database/sak/SakPostgresRepo.kt
@@ -2,6 +2,7 @@ package no.nav.su.se.bakover.database.sak
 
 import arrow.core.NonEmptyList
 import kotliquery.Row
+import no.nav.su.se.bakover.common.UUID30
 import no.nav.su.se.bakover.common.domain.Saksnummer
 import no.nav.su.se.bakover.common.domain.sak.Behandlingssammendrag
 import no.nav.su.se.bakover.common.domain.sak.Sakstype
@@ -145,6 +146,17 @@ internal class SakPostgresRepo(
         }!!
     }
 
+    override fun hentSakForUtbetalingId(utbetalingId: UUID30, sessionContext: SessionContext?): Sak? {
+        return dbMetrics.timeQuery("hentSakForUtbetalingId") {
+            sessionFactory.withSessionContext(sessionContext) { sessionContext ->
+                sessionContext.withSession { session ->
+                    "select s.* from sak s join utbetaling u on u.sakid = s.id where u.id = :utbetalingId"
+                        .hent(mapOf("utbetalingId" to utbetalingId), session) { it.toSak(sessionContext) }
+                }
+            }
+        }
+    }
+
     override fun hentSakforSøknadsbehandling(søknadsbehandlingId: UUID): Sak {
         return dbMetrics.timeQuery("hentSakForSøknadsbehandling") {
             sessionFactory.withSessionContext { sessionContext ->

diff --git a/database/src/main/kotlin/no/nav/su/se/bakover/database/vedtak/VedtakPostgresRepo.kt b/database/src/main/kotlin/no/nav/su/se/bakover/database/vedtak/VedtakPostgresRepo.kt
@@ -9,16 +9,19 @@ import no.nav.su.se.bakover.common.deserializeListNullable
 import no.nav.su.se.bakover.common.domain.Saksnummer
 import no.nav.su.se.bakover.common.ident.NavIdentBruker
 import no.nav.su.se.bakover.common.infrastructure.persistence.DbMetrics
+import no.nav.su.se.bakover.common.infrastructure.persistence.PostgresSessionContext.Companion.withOptionalSession
 import no.nav.su.se.bakover.common.infrastructure.persistence.PostgresSessionFactory
 import no.nav.su.se.bakover.common.infrastructure.persistence.PostgresTransactionContext.Companion.withTransaction
 import no.nav.su.se.bakover.common.infrastructure.persistence.Session
 import no.nav.su.se.bakover.common.infrastructure.persistence.TransactionalSession
 import no.nav.su.se.bakover.common.infrastructure.persistence.hent
 import no.nav.su.se.bakover.common.infrastructure.persistence.hentListe
 import no.nav.su.se.bakover.common.infrastructure.persistence.insert
+import no.nav.su.se.bakover.common.infrastructure.persistence.oppdatering
 import no.nav.su.se.bakover.common.infrastructure.persistence.tidspunkt
 import no.nav.su.se.bakover.common.infrastructure.persistence.uuid30OrNull
 import no.nav.su.se.bakover.common.journal.JournalpostId
+import no.nav.su.se.bakover.common.persistence.SessionContext
 import no.nav.su.se.bakover.common.persistence.TransactionContext
 import no.nav.su.se.bakover.common.person.Fnr
 import no.nav.su.se.bakover.common.serialize
@@ -196,6 +199,19 @@ internal class VedtakPostgresRepo(
         }
     }
 
+    override fun oppdaterUtbetalingId(
+        vedtakId: UUID,
+        utbetalingId: UUID30,
+        sessionContext: SessionContext?,
+    ) {
+        sessionContext.withOptionalSession(sessionFactory) { session ->
+            """
+                update vedtak set utbetalingId = :utbetalingId where id = :vedtakId
+            """.trimIndent()
+                .oppdatering(mapOf("utbetalingId" to utbetalingId, "vedtakId" to vedtakId), session)
+        }
+    }
+
     /**
      * Det er kun [VedtakEndringIYtelse] som inneholder en utbetalingId
      */

diff --git a/domain/src/main/kotlin/no/nav/su/se/bakover/domain/oppdrag/utbetaling/Utbetalinger.kt b/domain/src/main/kotlin/no/nav/su/se/bakover/domain/oppdrag/utbetaling/Utbetalinger.kt
@@ -75,7 +75,11 @@ data class Utbetalinger(
     data object FantIkkeGjeldendeUtbetaling
 
     fun sisteUtbetalingslinje(): Utbetalingslinje? {
-        return utbetalinger.lastOrNull()?.sisteUtbetalingslinje()
+        return sisteUtbetaling()?.sisteUtbetalingslinje()
+    }
+
+    fun sisteUtbetaling(): Utbetaling? {
+        return utbetalinger.lastOrNull()
     }
 
     fun sisteUtbetalingslinjeId(): UUID30? {

diff --git a/domain/src/main/kotlin/no/nav/su/se/bakover/domain/revurdering/IverksattRevurdering.kt b/domain/src/main/kotlin/no/nav/su/se/bakover/domain/revurdering/IverksattRevurdering.kt
@@ -1,9 +1,13 @@
 package no.nav.su.se.bakover.domain.revurdering
 
+import arrow.core.NonEmptyList
+import arrow.core.getOrElse
 import beregning.domain.Beregning
 import no.nav.su.se.bakover.common.domain.attestering.Attestering
 import no.nav.su.se.bakover.common.domain.attestering.Attesteringshistorikk
 import no.nav.su.se.bakover.common.domain.oppgave.OppgaveId
+import no.nav.su.se.bakover.common.domain.sak.Sakstype
+import no.nav.su.se.bakover.common.extensions.toNonEmptyList
 import no.nav.su.se.bakover.common.ident.NavIdentBruker
 import no.nav.su.se.bakover.common.tid.Tidspunkt
 import no.nav.su.se.bakover.common.tid.periode.Periode
@@ -17,6 +21,7 @@ import no.nav.su.se.bakover.domain.revurdering.revurderes.VedtakSomRevurderesMå
 import no.nav.su.se.bakover.domain.revurdering.steg.InformasjonSomRevurderes
 import no.nav.su.se.bakover.domain.revurdering.årsak.Revurderingsårsak
 import no.nav.su.se.bakover.domain.sak.SakInfo
+import vilkår.uføre.domain.Uføregrunnlag
 import økonomi.domain.simulering.Simulering
 import java.time.Clock
 import java.time.LocalDate
@@ -69,6 +74,25 @@ sealed class IverksattRevurdering : Revurdering() {
         override val erOpphørt = false
 
         override fun utledOpphørsgrunner(clock: Clock): List<Opphørsgrunn> = emptyList()
+
+        /**
+         * @return null dersom man kaller denne for en alderssak.
+         * @throws IllegalStateException Dersom søknadsbehandlingen mangler uføregrunnlag. Dette skal ikke skje. Initen skal også verifisere dette.
+         *
+         * Se også tilsvarende implementasjon for søknadsbehandling: [no.nav.su.se.bakover.domain.søknadsbehandling.IverksattSøknadsbehandling.Innvilget.hentUføregrunnlag]
+         */
+        fun hentUføregrunnlag(): NonEmptyList<Uføregrunnlag>? {
+            return when (this.sakstype) {
+                Sakstype.ALDER -> null
+
+                Sakstype.UFØRE -> {
+                    this.vilkårsvurderinger.uføreVilkår()
+                        .getOrElse { throw IllegalStateException("Revurdering uføre: ${this.id} mangler uføregrunnlag") }
+                        .grunnlag
+                        .toNonEmptyList()
+                }
+            }
+        }
     }
 
     data class Opphørt(

diff --git a/...o/nav/su/se/bakover/domain/revurdering/iverksett/innvilg/IverksettInnvilgetRevurdering.kt b/...o/nav/su/se/bakover/domain/revurdering/iverksett/innvilg/IverksettInnvilgetRevurdering.kt
@@ -2,10 +2,7 @@ package no.nav.su.se.bakover.domain.revurdering.iverksett.innvilg
 
 import arrow.core.Either
 import arrow.core.flatMap
-import arrow.core.getOrElse
 import arrow.core.left
-import no.nav.su.se.bakover.common.domain.sak.Sakstype
-import no.nav.su.se.bakover.common.extensions.toNonEmptyList
 import no.nav.su.se.bakover.common.ident.NavIdentBruker
 import no.nav.su.se.bakover.domain.Sak
 import no.nav.su.se.bakover.domain.oppdrag.simulering.kontrollsimuler
@@ -47,18 +44,7 @@ internal fun Sak.iverksettInnvilgetRevurdering(
             beregning = iverksattRevurdering.beregning,
             clock = clock,
             utbetalingsinstruksjonForEtterbetaling = UtbetalingsinstruksjonForEtterbetalinger.SåFortSomMulig,
-            uføregrunnlag = when (iverksattRevurdering.sakstype) {
-                Sakstype.ALDER -> {
-                    null
-                }
-
-                Sakstype.UFØRE -> {
-                    iverksattRevurdering.vilkårsvurderinger.uføreVilkår()
-                        .getOrElse { throw IllegalStateException("Revurdering uføre: ${iverksattRevurdering.id} mangler uføregrunnlag") }
-                        .grunnlag
-                        .toNonEmptyList()
-                }
-            },
+            uføregrunnlag = iverksattRevurdering.hentUføregrunnlag(),
         ).let {
             kontrollsimuler(
                 utbetalingForSimulering = it,

diff --git a/domain/src/main/kotlin/no/nav/su/se/bakover/domain/sak/SakRepo.kt b/domain/src/main/kotlin/no/nav/su/se/bakover/domain/sak/SakRepo.kt
@@ -1,6 +1,7 @@
 package no.nav.su.se.bakover.domain.sak
 
 import arrow.core.NonEmptyList
+import no.nav.su.se.bakover.common.UUID30
 import no.nav.su.se.bakover.common.domain.Saksnummer
 import no.nav.su.se.bakover.common.domain.sak.Behandlingssammendrag
 import no.nav.su.se.bakover.common.domain.sak.Sakstype
@@ -29,7 +30,7 @@ interface SakRepo {
     fun hentSakForRevurdering(revurderingId: UUID): Sak
 
     fun hentSakForRevurdering(revurderingId: UUID, sessionContext: SessionContext): Sak
-
+    fun hentSakForUtbetalingId(utbetalingId: UUID30, sessionContext: SessionContext? = null): Sak?
     fun hentSakforSøknadsbehandling(søknadsbehandlingId: UUID): Sak
     fun hentSakForSøknad(søknadId: UUID): Sak?
     fun hentSakForVedtak(vedtakId: UUID): Sak?

diff --git a/domain/src/main/kotlin/no/nav/su/se/bakover/domain/sak/SakService.kt b/domain/src/main/kotlin/no/nav/su/se/bakover/domain/sak/SakService.kt
@@ -2,6 +2,7 @@ package no.nav.su.se.bakover.domain.sak
 
 import arrow.core.Either
 import dokument.domain.Dokument
+import no.nav.su.se.bakover.common.UUID30
 import no.nav.su.se.bakover.common.domain.Saksnummer
 import no.nav.su.se.bakover.common.domain.sak.Behandlingssammendrag
 import no.nav.su.se.bakover.common.domain.sak.Sakstype
@@ -25,6 +26,7 @@ interface SakService {
     fun hentSak(sakId: UUID, sessionContext: SessionContext): Either<FantIkkeSak, Sak>
     fun hentSak(fnr: Fnr, type: Sakstype): Either<FantIkkeSak, Sak>
     fun hentSak(saksnummer: Saksnummer): Either<FantIkkeSak, Sak>
+    fun hentSakForUtbetalingId(utbetalingId: UUID30): Either<FantIkkeSak, Sak>
     fun hentSaker(fnr: Fnr): Either<FantIkkeSak, List<Sak>>
 
     fun hentSak(hendelseId: HendelseId): Either<FantIkkeSak, Sak>

diff --git a/...c/main/kotlin/no/nav/su/se/bakover/domain/søknadsbehandling/IverksattSøknadsbehandling.kt b/...c/main/kotlin/no/nav/su/se/bakover/domain/søknadsbehandling/IverksattSøknadsbehandling.kt
@@ -1,11 +1,14 @@
 package no.nav.su.se.bakover.domain.søknadsbehandling
 
+import arrow.core.NonEmptyList
+import arrow.core.getOrElse
 import arrow.core.left
 import beregning.domain.Beregning
 import no.nav.su.se.bakover.common.domain.Saksnummer
 import no.nav.su.se.bakover.common.domain.attestering.Attesteringshistorikk
 import no.nav.su.se.bakover.common.domain.oppgave.OppgaveId
 import no.nav.su.se.bakover.common.domain.sak.Sakstype
+import no.nav.su.se.bakover.common.extensions.toNonEmptyList
 import no.nav.su.se.bakover.common.ident.NavIdentBruker
 import no.nav.su.se.bakover.common.person.Fnr
 import no.nav.su.se.bakover.common.tid.Tidspunkt
@@ -23,6 +26,7 @@ import no.nav.su.se.bakover.domain.søknadsbehandling.avslag.ErAvslag
 import no.nav.su.se.bakover.domain.søknadsbehandling.stønadsperiode.Aldersvurdering
 import no.nav.su.se.bakover.domain.søknadsbehandling.stønadsperiode.Stønadsperiode
 import no.nav.su.se.bakover.domain.vilkår.Vilkårsvurderingsresultat
+import vilkår.uføre.domain.Uføregrunnlag
 import økonomi.domain.simulering.Simulering
 import java.util.UUID
 
@@ -70,6 +74,25 @@ sealed interface IverksattSøknadsbehandling : Søknadsbehandling, KanGenerereBr
         override fun skalSendeVedtaksbrev(): Boolean {
             return true
         }
+
+        /**
+         * @return null dersom man kaller denne for en alderssak.
+         * @throws IllegalStateException Dersom søknadsbehandlingen mangler uføregrunnlag. Dette skal ikke skje. Initen skal også verifisere dette.
+         *
+         * Se også tilsvarende implementasjon for revurdering: [no.nav.su.se.bakover.domain.revurdering.IverksattRevurdering.Innvilget.hentUføregrunnlag]
+         */
+        fun hentUføregrunnlag(): NonEmptyList<Uføregrunnlag>? {
+            return when (this.sakstype) {
+                Sakstype.ALDER -> null
+
+                Sakstype.UFØRE -> {
+                    this.vilkårsvurderinger.uføreVilkår()
+                        .getOrElse { throw IllegalStateException("Søknadsbehandling uføre: ${this.id} mangler uføregrunnlag") }
+                        .grunnlag
+                        .toNonEmptyList()
+                }
+            }
+        }
     }
 
     sealed interface Avslag : IverksattSøknadsbehandling, ErAvslag, KanGenerereAvslagsbrev {

diff --git a/...bakover/domain/søknadsbehandling/iverksett/innvilg/IverksettInnvilgetSøknadsbehandling.kt b/...bakover/domain/søknadsbehandling/iverksett/innvilg/IverksettInnvilgetSøknadsbehandling.kt
@@ -1,28 +1,23 @@
 package no.nav.su.se.bakover.domain.søknadsbehandling.iverksett.innvilg
 
 import arrow.core.Either
-import arrow.core.NonEmptyList
 import arrow.core.getOrElse
 import arrow.core.left
 import arrow.core.nonEmptyListOf
 import arrow.core.raise.either
 import arrow.core.right
 import no.nav.su.se.bakover.common.domain.attestering.Attestering
-import no.nav.su.se.bakover.common.domain.sak.Sakstype
-import no.nav.su.se.bakover.common.extensions.toNonEmptyList
 import no.nav.su.se.bakover.common.sikkerLogg
 import no.nav.su.se.bakover.domain.Sak
 import no.nav.su.se.bakover.domain.oppdrag.simulering.kontrollsimuler
 import no.nav.su.se.bakover.domain.sak.lagNyUtbetaling
 import no.nav.su.se.bakover.domain.sak.oppdaterSøknadsbehandling
 import no.nav.su.se.bakover.domain.statistikk.StatistikkEvent
-import no.nav.su.se.bakover.domain.søknadsbehandling.IverksattSøknadsbehandling
 import no.nav.su.se.bakover.domain.søknadsbehandling.SøknadsbehandlingTilAttestering
 import no.nav.su.se.bakover.domain.søknadsbehandling.iverksett.KunneIkkeIverksetteSøknadsbehandling
 import no.nav.su.se.bakover.domain.søknadsbehandling.validerOverlappendeStønadsperioder
 import no.nav.su.se.bakover.domain.vedtak.VedtakSomKanRevurderes
 import org.slf4j.LoggerFactory
-import vilkår.uføre.domain.Uføregrunnlag
 import økonomi.domain.simulering.SimuleringFeilet
 import økonomi.domain.utbetaling.Utbetaling
 import økonomi.domain.utbetaling.UtbetalingsinstruksjonForEtterbetalinger
@@ -63,7 +58,7 @@ internal fun Sak.iverksettInnvilgetSøknadsbehandling(
         beregning = iverksattBehandling.beregning,
         clock = clock,
         utbetalingsinstruksjonForEtterbetaling = UtbetalingsinstruksjonForEtterbetalinger.SåFortSomMulig,
-        uføregrunnlag = hentUføregrunnlag(iverksattBehandling),
+        uføregrunnlag = iverksattBehandling.hentUføregrunnlag(),
     ).let {
         kontrollsimuler(
             utbetalingForSimulering = it,
@@ -103,22 +98,6 @@ private fun Sak.validerGjeldendeVedtak(
     }
 }
 
-private fun hentUføregrunnlag(
-    iverksattBehandling: IverksattSøknadsbehandling.Innvilget,
-): NonEmptyList<Uføregrunnlag>? {
-    return when (iverksattBehandling.sakstype) {
-        Sakstype.ALDER -> {
-            null
-        }
-
-        Sakstype.UFØRE -> {
-            iverksattBehandling.vilkårsvurderinger.uføreVilkår().getOrElse {
-                throw IllegalStateException("Søknadsbehandling uføre: ${iverksattBehandling.id} mangler uføregrunnlag")
-            }.grunnlag.toNonEmptyList()
-        }
-    }
-}
-
 /**
  * Sjekker kun saksbehandlers simulering.
  */

diff --git a/domain/src/main/kotlin/no/nav/su/se/bakover/domain/vedtak/VedtakRepo.kt b/domain/src/main/kotlin/no/nav/su/se/bakover/domain/vedtak/VedtakRepo.kt
@@ -2,6 +2,7 @@ package no.nav.su.se.bakover.domain.vedtak
 
 import no.nav.su.se.bakover.common.UUID30
 import no.nav.su.se.bakover.common.journal.JournalpostId
+import no.nav.su.se.bakover.common.persistence.SessionContext
 import no.nav.su.se.bakover.common.persistence.TransactionContext
 import no.nav.su.se.bakover.common.person.Fnr
 import no.nav.su.se.bakover.common.tid.periode.Måned
@@ -14,8 +15,15 @@ interface VedtakRepo {
     fun hentForRevurderingId(revurderingId: UUID): Vedtak?
     fun hentForMåned(måned: Måned): List<Vedtaksammendrag>
     fun hentForFødselsnumreOgFraOgMedMåned(fødselsnumre: List<Fnr>, fraOgMed: Måned): List<Vedtaksammendrag>
+
+    /** Denne vil feile dersom vedtaket er lagret før. */
     fun lagre(vedtak: Vedtak)
+
+    /** Denne vil feile dersom vedtaket er lagret før. */
     fun lagreITransaksjon(vedtak: Vedtak, tx: TransactionContext)
+
+    /** En spesialoperasjon som kun skal brukes ved resending av utbetalinger */
+    fun oppdaterUtbetalingId(vedtakId: UUID, utbetalingId: UUID30, sessionContext: SessionContext? = null)
     fun hentForUtbetaling(utbetalingId: UUID30): VedtakSomKanRevurderes?
     fun hentJournalpostId(vedtakId: UUID): JournalpostId?
     fun hentSøknadsbehandlingsvedtakFraOgMed(fraOgMed: LocalDate): List<UUID>

diff --git a/service/src/main/kotlin/no/nav/su/se/bakover/service/sak/SakServiceImpl.kt b/service/src/main/kotlin/no/nav/su/se/bakover/service/sak/SakServiceImpl.kt
@@ -9,6 +9,7 @@ import arrow.core.right
 import dokument.domain.Dokument
 import dokument.domain.DokumentRepo
 import dokument.domain.brev.BrevService
+import no.nav.su.se.bakover.common.UUID30
 import no.nav.su.se.bakover.common.domain.Saksnummer
 import no.nav.su.se.bakover.common.domain.sak.Behandlingssammendrag
 import no.nav.su.se.bakover.common.domain.sak.Sakstype
@@ -85,6 +86,10 @@ class SakServiceImpl(
         return sakRepo.hentSak(saksnummer)?.right() ?: FantIkkeSak.left()
     }
 
+    override fun hentSakForUtbetalingId(utbetalingId: UUID30): Either<FantIkkeSak, Sak> {
+        return sakRepo.hentSakForUtbetalingId(utbetalingId)?.right() ?: FantIkkeSak.left()
+    }
+
     override fun hentSak(hendelseId: HendelseId): Either<FantIkkeSak, Sak> {
         return sakRepo.hentSak(hendelseId)?.right() ?: FantIkkeSak.left()
     }

diff --git a/service/src/main/kotlin/no/nav/su/se/bakover/service/utbetaling/UtbetalingServiceImpl.kt b/service/src/main/kotlin/no/nav/su/se/bakover/service/utbetaling/UtbetalingServiceImpl.kt
@@ -89,14 +89,18 @@ class UtbetalingServiceImpl(
             .map { utbetalingForSimulering.toSimulertUtbetaling(it) }
     }
 
-    private fun sendUtbetalingTilOS(utbetalingsRequest: Utbetalingsrequest): Either<UtbetalingFeilet.Protokollfeil, Utbetalingsrequest> {
+    private fun sendUtbetalingTilOS(
+        utbetalingsRequest: Utbetalingsrequest,
+    ): Either<UtbetalingFeilet.Protokollfeil, Utbetalingsrequest> {
         return utbetalingPublisher.publishRequest(utbetalingsRequest)
             .mapLeft {
                 UtbetalingFeilet.Protokollfeil
             }
     }
 
-    private fun Utbetaling.SimulertUtbetaling.forberedOversendelse(transactionContext: TransactionContext): Utbetaling.OversendtUtbetaling.UtenKvittering {
+    private fun Utbetaling.SimulertUtbetaling.forberedOversendelse(
+        transactionContext: TransactionContext,
+    ): Utbetaling.OversendtUtbetaling.UtenKvittering {
         return toOversendtUtbetaling(utbetalingPublisher.generateRequest(this)).also {
             utbetalingRepo.opprettUtbetaling(
                 utbetaling = it,

diff --git a/settings.gradle.kts b/settings.gradle.kts
@@ -50,6 +50,7 @@ include("oppgave:infrastructure")
 include("økonomi:domain")
 include("økonomi:infrastructure")
 include("økonomi:application")
+include("økonomi:presentation")
 
 include("tilbakekreving:presentation")
 include("tilbakekreving:application")

diff --git a/web/build.gradle.kts b/web/build.gradle.kts
@@ -32,7 +32,9 @@ dependencies {
     implementation(project(":oppgave:infrastructure"))
     implementation(project(":oppgave:domain"))
     implementation(project(":økonomi:domain"))
+    implementation(project(":økonomi:application"))
     implementation(project(":økonomi:infrastructure"))
+    implementation(project(":økonomi:presentation"))
 
     implementation(project(":dokument:domain"))
     implementation(project(":dokument:infrastructure"))