Fix algoritme som finner saker som mangler meldeperioder

hestad · hestad · commit b64fc4690e99 · 2025-03-21T16:17:56.000+01:00
diff --git a/app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/meldekort/service/GenererMeldeperioderService.kt b/app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/meldekort/service/GenererMeldeperioderService.kt
@@ -24,8 +24,9 @@ class GenererMeldeperioderService(
                 val sak = sakRepo.hentForSakId(sakId)!!
                 val (sakMedNyeMeldeperioder, meldeperioder) = sak.genererMeldeperioder(clock)
                 sessionFactory.withTransactionContext { tx ->
-                    sakRepo.oppdaterSisteDagSomGirRett(
+                    sakRepo.oppdaterFørsteOgSisteDagSomGirRett(
                         sakId = sakId,
+                        førsteDagSomGirRett = sakMedNyeMeldeperioder.førsteDagSomGirRett,
                         sisteDagSomGirRett = sakMedNyeMeldeperioder.sisteDagSomGirRett,
                         sessionContext = tx,
                     )
diff --git a/app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/repository/sak/SakPostgresRepo.kt b/app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/repository/sak/SakPostgresRepo.kt
@@ -185,8 +185,9 @@ internal class SakPostgresRepo(
             }
         }
 
-    override fun oppdaterSisteDagSomGirRett(
+    override fun oppdaterFørsteOgSisteDagSomGirRett(
         sakId: SakId,
+        førsteDagSomGirRett: LocalDate?,
         sisteDagSomGirRett: LocalDate?,
         sessionContext: SessionContext?,
     ) {
@@ -195,9 +196,10 @@ internal class SakPostgresRepo(
                 session.run(
                     queryOf(
                         """
-                        update sak set siste_dag_som_gir_rett = :siste_dag_som_gir_rett where id = :sak_id
+                        update sak set første_dag_som_gir_rett = :forste_dag_som_gir_rett, siste_dag_som_gir_rett = :siste_dag_som_gir_rett where id = :sak_id
                         """.trimIndent(),
                         mapOf(
+                            "forste_dag_som_gir_rett" to førsteDagSomGirRett,
                             "siste_dag_som_gir_rett" to sisteDagSomGirRett,
                             "sak_id" to sakId.toString(),
                         ),
@@ -214,10 +216,25 @@ internal class SakPostgresRepo(
                     queryOf(
                         // language=SQL
                         """
-                            with temp as (
-                                select s.id, s.siste_dag_som_gir_rett, max(m.til_og_med) as til_og_med from sak s join meldeperiode m on s.id = m.sak_id group by s.id
+                            select s.id, s.siste_dag_som_gir_rett, max(m.til_og_med) as til_og_med
+                            from sak s
+                            left join meldeperiode m on s.id = m.sak_id
+                            group by s.id
+                            having (
+                                -- Case 1: Has meldeperioder but needs more
+                                (
+                                    max(m.til_og_med) is not null 
+                                    and max(m.til_og_med) < s.siste_dag_som_gir_rett
+                                    and max(m.til_og_med) < :ikkeGenererEtter
+                                )
+                                or
+                                -- Case 2: Has no meldeperioder (max will be null)
+                                (
+                                    max(m.til_og_med) is null
+                                    and s.første_dag_som_gir_rett <= :ikkeGenererEtter
+                                )
                             )
-                            select * from temp where til_og_med < siste_dag_som_gir_rett and til_og_med < :ikkeGenererEtter limit $limit;
+                            limit $limit;
                         """.trimIndent(),
                         mapOf("ikkeGenererEtter" to ikkeGenererEtter),
                     ).map {
diff --git a/app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/saksbehandling/ports/SakRepo.kt b/app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/saksbehandling/ports/SakRepo.kt
@@ -41,8 +41,9 @@ interface SakRepo {
      *
      * Ment for å optimalisere db-spørringer (generering av meldeperioder)
      */
-    fun oppdaterSisteDagSomGirRett(
+    fun oppdaterFørsteOgSisteDagSomGirRett(
         sakId: SakId,
+        førsteDagSomGirRett: LocalDate?,
         sisteDagSomGirRett: LocalDate?,
         sessionContext: SessionContext? = null,
     )
diff --git a/app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/saksbehandling/service/behandling/IverksettBehandlingService.kt b/app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/saksbehandling/service/behandling/IverksettBehandlingService.kt
@@ -138,7 +138,12 @@ class IverksettBehandlingService(
         // Dersom denne endres til søknadsbehandling og vi kan ha mer enn 1 for en sak og den kan overlappe den eksistrende saksperioden, må den legge til nye versjoner av meldeperiodene her.
         sessionFactory.withTransactionContext { tx ->
             behandlingRepo.lagre(vedtak.behandling, tx)
-            sakService.oppdaterSisteDagSomGirRett(oppdatertSak.id, oppdatertSak.sisteDagSomGirRett, tx)
+            sakService.oppdaterSisteDagSomGirRett(
+                sakId = oppdatertSak.id,
+                førsteDagSomGirRett = oppdatertSak.førsteDagSomGirRett,
+                sisteDagSomGirRett = oppdatertSak.sisteDagSomGirRett,
+                sessionContext = tx,
+            )
             rammevedtakRepo.lagre(vedtak, tx)
             statistikkSakRepo.lagre(sakStatistikk, tx)
             statistikkStønadRepo.lagre(stønadStatistikk, tx)
@@ -159,7 +164,12 @@ class IverksettBehandlingService(
         // journalføring og dokumentdistribusjon skjer i egen jobb
         sessionFactory.withTransactionContext { tx ->
             behandlingRepo.lagre(vedtak.behandling, tx)
-            sakService.oppdaterSisteDagSomGirRett(oppdatertSak.id, oppdatertSak.sisteDagSomGirRett, tx)
+            sakService.oppdaterSisteDagSomGirRett(
+                sakId = oppdatertSak.id,
+                førsteDagSomGirRett = oppdatertSak.førsteDagSomGirRett,
+                sisteDagSomGirRett = oppdatertSak.sisteDagSomGirRett,
+                sessionContext = tx,
+            )
             rammevedtakRepo.lagre(vedtak, tx)
             statistikkSakRepo.lagre(sakStatistikk, tx)
             statistikkStønadRepo.lagre(stønadStatistikk, tx)
diff --git a/app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/saksbehandling/service/sak/SakService.kt b/app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/saksbehandling/service/sak/SakService.kt
@@ -67,6 +67,7 @@ interface SakService {
      */
     fun oppdaterSisteDagSomGirRett(
         sakId: SakId,
+        førsteDagSomGirRett: LocalDate?,
         sisteDagSomGirRett: LocalDate?,
         sessionContext: SessionContext,
     )
diff --git a/app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/saksbehandling/service/sak/SakServiceImpl.kt b/app/src/main/kotlin/no/nav/tiltakspenger/saksbehandling/saksbehandling/service/sak/SakServiceImpl.kt
@@ -204,11 +204,13 @@ class SakServiceImpl(
      */
     override fun oppdaterSisteDagSomGirRett(
         sakId: SakId,
+        førsteDagSomGirRett: LocalDate?,
         sisteDagSomGirRett: LocalDate?,
         sessionContext: SessionContext,
     ) {
-        sakRepo.oppdaterSisteDagSomGirRett(
+        sakRepo.oppdaterFørsteOgSisteDagSomGirRett(
             sakId = sakId,
+            førsteDagSomGirRett = førsteDagSomGirRett,
             sisteDagSomGirRett = sisteDagSomGirRett,
             sessionContext = sessionContext,
         )
diff --git a/app/src/main/resources/db/migration/V54__foerste_siste_dag_som_gir_rett.sql b/app/src/main/resources/db/migration/V54__foerste_siste_dag_som_gir_rett.sql
@@ -0,0 +1,8 @@
+ALTER TABLE sak
+    ADD COLUMN IF NOT EXISTS første_dag_som_gir_rett DATE;
+
+UPDATE sak s
+SET første_dag_som_gir_rett = (SELECT MAX(m.fra_og_med)
+                              FROM meldeperiode m
+                              WHERE m.sak_id = s.id)
+WHERE s.første_dag_som_gir_rett IS NULL;
diff --git a/app/src/test/kotlin/no/nav/tiltakspenger/saksbehandling/fakes/repos/SakFakeRepo.kt b/app/src/test/kotlin/no/nav/tiltakspenger/saksbehandling/fakes/repos/SakFakeRepo.kt
@@ -88,8 +88,9 @@ class SakFakeRepo(
         return hentSak(sakId)
     }
 
-    override fun oppdaterSisteDagSomGirRett(
+    override fun oppdaterFørsteOgSisteDagSomGirRett(
         sakId: SakId,
+        førsteDagSomGirRett: LocalDate?,
         sisteDagSomGirRett: LocalDate?,
         sessionContext: SessionContext?,
     ) {
diff --git a/app/src/test/kotlin/no/nav/tiltakspenger/saksbehandling/repository/sak/SakRepoTest.kt b/app/src/test/kotlin/no/nav/tiltakspenger/saksbehandling/repository/sak/SakRepoTest.kt
@@ -9,6 +9,7 @@ import no.nav.tiltakspenger.saksbehandling.db.persisterNySak
 import no.nav.tiltakspenger.saksbehandling.db.persisterOpprettetFørstegangsbehandling
 import no.nav.tiltakspenger.saksbehandling.db.persisterSak
 import no.nav.tiltakspenger.saksbehandling.db.withMigratedDb
+import no.nav.tiltakspenger.saksbehandling.felles.desember
 import no.nav.tiltakspenger.saksbehandling.felles.februar
 import no.nav.tiltakspenger.saksbehandling.felles.januar
 import no.nav.tiltakspenger.saksbehandling.objectmothers.ObjectMother
@@ -82,7 +83,7 @@ internal class SakRepoTest {
                     deltakelseFom = 1.februar(2025),
                     deltakelseTom = 28.februar(2025),
                 )
-                sakRepo.oppdaterSisteDagSomGirRett(sak.id, sak.sisteDagSomGirRett)
+                sakRepo.oppdaterFørsteOgSisteDagSomGirRett(sak.id, sak.førsteDagSomGirRett, sak.sisteDagSomGirRett)
                 sak.meldeperiodeKjeder.meldeperioder.size shouldBe 3
                 sakRepo.hentSakerSomMåGenerereMeldeperioderFra(1.februar(2025)) shouldBe emptyList()
             }
@@ -101,10 +102,11 @@ internal class SakRepoTest {
                 sakRepo.hentSakerSomMåGenerereMeldeperioderFra(1.januar(2000)) shouldBe emptyList()
                 sakRepo.hentSakerSomMåGenerereMeldeperioderFra(1.januar(2025)) shouldBe emptyList()
                 sakRepo.hentSakerSomMåGenerereMeldeperioderFra(1.januar(2050)) shouldBe emptyList()
-                // Later som det finnes et vedtak som siste dag gir rett 31.januar(2025)
-                sakRepo.oppdaterSisteDagSomGirRett(sak.id, 31.januar(2025))
-                // TODO jah: Virkelig bug som må fikses. Vi må også persistere førsteDagSomGirRett, for å kunne avgjøre om vi skal generere en meldeperiode dersom det ikke finnes meldeperioder fra før.
-                // meldeperiodeRepo.hentSakerSomMåGenerereMeldeperioderFra(ikkeGenererEtter = 1.januar(2050)) shouldBe listOf(sak)
+                // Later som det finnes et vedtak med innvilgelsesperiode hele januar 2025
+                sakRepo.oppdaterFørsteOgSisteDagSomGirRett(sak.id, 1.januar(2025), 31.januar(2025))
+                sakRepo.hentSakerSomMåGenerereMeldeperioderFra(ikkeGenererEtter = 31.desember(2024)) shouldBe emptyList()
+                sakRepo.hentSakerSomMåGenerereMeldeperioderFra(ikkeGenererEtter = 1.januar(2025)) shouldBe listOf(sak.id)
+                sakRepo.hentSakerSomMåGenerereMeldeperioderFra(ikkeGenererEtter = 1.januar(2050)) shouldBe listOf(sak.id)
 
                 testDataHelper.sessionFactory.withSessionContext {
                     meldeperiodeRepo.lagre(
@@ -119,6 +121,7 @@ internal class SakRepoTest {
 
                 sakRepo.hentSakerSomMåGenerereMeldeperioderFra(19.januar(2025)) shouldBe emptyList()
                 sakRepo.hentSakerSomMåGenerereMeldeperioderFra(20.januar(2025)) shouldBe listOf(sak.id)
+                sakRepo.hentSakerSomMåGenerereMeldeperioderFra(20.januar(2050)) shouldBe listOf(sak.id)
                 testDataHelper.sessionFactory.withSessionContext {
                     meldeperiodeRepo.lagre(
                         ObjectMother.meldeperiode(
@@ -129,14 +132,20 @@ internal class SakRepoTest {
                         it,
                     )
                 }
+                sakRepo.hentSakerSomMåGenerereMeldeperioderFra(19.januar(2000)) shouldBe emptyList()
                 sakRepo.hentSakerSomMåGenerereMeldeperioderFra(19.januar(2025)) shouldBe emptyList()
+                sakRepo.hentSakerSomMåGenerereMeldeperioderFra(19.januar(2050)) shouldBe emptyList()
 
-                sakRepo.oppdaterSisteDagSomGirRett(sak.id, 2.februar(2025))
+                sakRepo.oppdaterFørsteOgSisteDagSomGirRett(sak.id, 1.januar(2025), 2.februar(2025))
+                sakRepo.hentSakerSomMåGenerereMeldeperioderFra(2.februar(2000)) shouldBe emptyList()
                 sakRepo.hentSakerSomMåGenerereMeldeperioderFra(2.februar(2025)) shouldBe emptyList()
+                sakRepo.hentSakerSomMåGenerereMeldeperioderFra(2.februar(2050)) shouldBe emptyList()
 
-                sakRepo.oppdaterSisteDagSomGirRett(sak.id, 3.februar(2025))
+                sakRepo.oppdaterFørsteOgSisteDagSomGirRett(sak.id, 1.januar(2025), 3.februar(2025))
+                sakRepo.hentSakerSomMåGenerereMeldeperioderFra(2.februar(2000)) shouldBe emptyList()
                 sakRepo.hentSakerSomMåGenerereMeldeperioderFra(2.februar(2025)) shouldBe emptyList()
                 sakRepo.hentSakerSomMåGenerereMeldeperioderFra(3.februar(2025)) shouldBe listOf(sak.id)
+                sakRepo.hentSakerSomMåGenerereMeldeperioderFra(3.februar(2050)) shouldBe listOf(sak.id)
             }
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -41,8 +41,9 @@ interface SakRepo {`
`41`	`41`	`*`
`42`	`42`	`* Ment for å optimalisere db-spørringer (generering av meldeperioder)`
`43`	`43`	`*/`
`44`		`- fun oppdaterSisteDagSomGirRett(`
	`44`	`+ fun oppdaterFørsteOgSisteDagSomGirRett(`
`45`	`45`	`sakId: SakId,`
	`46`	`+ førsteDagSomGirRett: LocalDate?,`
`46`	`47`	`sisteDagSomGirRett: LocalDate?,`
`47`	`48`	`sessionContext: SessionContext? = null,`
`48`	`49`	`)`
Original file line number	Diff line number	Diff line change
`@@ -67,6 +67,7 @@ interface SakService {`
`67`	`67`	`*/`
`68`	`68`	`fun oppdaterSisteDagSomGirRett(`
`69`	`69`	`sakId: SakId,`
	`70`	`+ førsteDagSomGirRett: LocalDate?,`
`70`	`71`	`sisteDagSomGirRett: LocalDate?,`
`71`	`72`	`sessionContext: SessionContext,`
`72`	`73`	`)`