Ikke send utbetaling for sak der forrige status ikke er ok.

Prøver heller ikke hente status for en utbetaling som ikke er sendt til helved

Author: hestad

app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/repository/utbetaling/UtbetalingsvedtakPostgresRepo.kt

@@ -160,7 +160,7 @@ internal class UtbetalingsvedtakPostgresRepo(
                             left join utbetalingsvedtak parent on parent.id = u.forrige_vedtak_id
                               and parent.sak_id = u.sak_id
                             where u.sendt_til_utbetaling_tidspunkt is null
-                              and (u.forrige_vedtak_id is null or parent.sendt_til_utbetaling_tidspunkt is not null)
+                              and (u.forrige_vedtak_id is null or (parent.sendt_til_utbetaling_tidspunkt is not null and parent.status IN ('OK','OK_UTEN_UTBETALING')))
                             order by u.opprettet
                             limit :limit
                     """.trimIndent(),
@@ -224,7 +224,8 @@ internal class UtbetalingsvedtakPostgresRepo(
                             select u.id, u.sak_id, s.saksnummer 
                             from utbetalingsvedtak u 
                             join sak s on s.id = u.sak_id 
-                            where u.status is null or u.status IN ('IKKE_PÅBEGYNT', 'SENDT_TIL_OPPDRAG')
+                            where (u.status is null or u.status IN ('IKKE_PÅBEGYNT', 'SENDT_TIL_OPPDRAG')) and u.sendt_til_utbetaling_tidspunkt is not null
+                            order by u.opprettet
                             limit :limit
                     """.trimIndent(),
                     mapOf("limit" to limit),

app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/utbetaling/service/OppdaterUtbetalingsstatusService.kt

@@ -6,7 +6,6 @@ import no.nav.tiltakspenger.saksbehandling.felles.sikkerlogg
 import no.nav.tiltakspenger.saksbehandling.saksbehandling.ports.UtbetalingGateway
 import no.nav.tiltakspenger.saksbehandling.utbetaling.domene.UtbetalingDetSkalHentesStatusFor
 import no.nav.tiltakspenger.saksbehandling.utbetaling.ports.UtbetalingsvedtakRepo
-import java.util.concurrent.atomic.AtomicBoolean
 
 /**
  * Ment å kalles fra en jobb.
@@ -18,18 +17,12 @@ class OppdaterUtbetalingsstatusService(
 ) {
     private val logger = KotlinLogging.logger { }
 
-    // TODO jah: Sletter når vi har sjekket at klienten fungerer.
-    private val harFeilet = AtomicBoolean(false)
-
     suspend fun oppdaterUtbetalingsstatus() {
         Either.catch {
-            if (harFeilet.get()) return
             utbetalingsvedtakRepo.hentDeSomSkalHentesUtbetalingsstatusFor().forEach {
-                if (harFeilet.get()) return
                 oppdaterEnkel(it)
             }
         }.onLeft {
-            harFeilet.set(true)
             with("Uventet feil ved oppdatering av utbetalingsstatus.") {
                 logger.error(RuntimeException("Trigger stacktrace for enklere debug")) { "$this Se sikkerlogg for mer kontekst." }
                 sikkerlogg.error(it) { this }
@@ -43,11 +36,9 @@ class OppdaterUtbetalingsstatusService(
                 utbetalingsvedtakRepo.oppdaterUtbetalingsstatus(utbetaling.vedtakId, it)
                 logger.info { "Oppdatert utbetalingsstatus til $it. Kontekst: $utbetaling" }
             }.onLeft {
-                harFeilet.set(true)
                 // Dette logges fra klienten.
             }
         }.onLeft {
-            harFeilet.set(true)
             with("Uventet feil ved oppdatering av utbetalingsstatus for $utbetaling.") {
                 logger.error(RuntimeException("Trigger stacktrace for enklere debug")) { "$this Se sikkerlogg for mer kontekst." }
                 sikkerlogg.error(it) { this }

app/src/test/kotlin/no/nav/tiltakspenger/saksbehandling/MaskedLogTest.kt

@@ -8,9 +8,9 @@ class MaskedLogTest {
     fun manuellTest() {
         System.setProperty("logback.configurationFile", "logback.xml")
         val log = KotlinLogging.logger {}
-        log.info("12345678901")
-        log.info("1234567890123")
-        log.info("12345678901er")
-        log.info("e12345678901e")
+        log.info { "12345678901" }
+        log.info { "1234567890123" }
+        log.info { "12345678901er" }
+        log.info { "e12345678901e" }
     }
 }

app/src/test/kotlin/no/nav/tiltakspenger/saksbehandling/repository/utbetaling/UtbetalingsvedtakRepoImplTest.kt

@@ -84,8 +84,13 @@ class UtbetalingsvedtakRepoImplTest {
             // Utbetaling
             val utbetalingsvedtak = meldekort.opprettUtbetalingsvedtak(sak.saksnummer, sak.fnr, null)
             utbetalingsvedtakRepo.lagre(utbetalingsvedtak)
+            utbetalingsvedtakRepo.markerSendtTilUtbetaling(
+                vedtakId = utbetalingsvedtak.id,
+                tidspunkt = nå(),
+                utbetalingsrespons = SendtUtbetaling("myReq", "myRes", 202),
+            )
 
-            val exptected = listOf(
+            val expected = listOf(
                 UtbetalingDetSkalHentesStatusFor(
                     sakId = utbetalingsvedtak.sakId,
                     vedtakId = utbetalingsvedtak.id,
@@ -95,21 +100,21 @@ class UtbetalingsvedtakRepoImplTest {
             testDataHelper.sessionFactory.withSession {
                 UtbetalingsvedtakPostgresRepo.hentForSakId(sak.id, it).single().status shouldBe null
             }
-            utbetalingsvedtakRepo.hentDeSomSkalHentesUtbetalingsstatusFor() shouldBe exptected
+            utbetalingsvedtakRepo.hentDeSomSkalHentesUtbetalingsstatusFor() shouldBe expected
             utbetalingsvedtakRepo.oppdaterUtbetalingsstatus(
                 vedtakId = utbetalingsvedtak.id,
                 status = Utbetalingsstatus.IkkePåbegynt,
             )
             testDataHelper.sessionFactory.withSession {
                 UtbetalingsvedtakPostgresRepo.hentForSakId(sak.id, it).single().status shouldBe Utbetalingsstatus.IkkePåbegynt
             }
-            utbetalingsvedtakRepo.hentDeSomSkalHentesUtbetalingsstatusFor() shouldBe exptected
+            utbetalingsvedtakRepo.hentDeSomSkalHentesUtbetalingsstatusFor() shouldBe expected
 
             utbetalingsvedtakRepo.oppdaterUtbetalingsstatus(
                 vedtakId = utbetalingsvedtak.id,
                 status = Utbetalingsstatus.SendtTilOppdrag,
             )
-            utbetalingsvedtakRepo.hentDeSomSkalHentesUtbetalingsstatusFor() shouldBe exptected
+            utbetalingsvedtakRepo.hentDeSomSkalHentesUtbetalingsstatusFor() shouldBe expected
 
             utbetalingsvedtakRepo.oppdaterUtbetalingsstatus(
                 vedtakId = utbetalingsvedtak.id,