Query med ferdigstiltDato. Tuner litt på indekser.

Author: mbolstad

src/main/kotlin/no/nav/k9/los/nyoppgavestyring/query/db/AktivOppgaveQuerySqlBuilder.kt

@@ -128,11 +128,6 @@ class AktivOppgaveQuerySqlBuilder(
 
         val index = queryParams.size + orderByParams.size
         when (feltkode) {
-            "sistEndret" -> {
-                query += "${combineOperator.sql} o.endret_tidspunkt ${operator.sql} (timestamp :sistEndret$index)) "
-                queryParams["sistEndret$index"] = feltverdi
-            }
-
             "kildeområde" -> {
                 query += "${combineOperator.sql} o.kildeomrade ${operator.sql} (:kildeomrade$index) "
                 queryParams["kildeomrade$index"] = feltverdi
@@ -179,7 +174,11 @@ class AktivOppgaveQuerySqlBuilder(
                 }
             }
 
-            else -> log.warn("Håndterer ikke filter for $feltkode")
+            "oppgavestatus" -> {
+                // Ignorerer felt, siden det er håndtert spesielt
+            }
+
+            else -> log.warn("Håndterer ikke filter for $feltkode. Legg til i ignorering hvis feltet håndteres spesielt.")
         }
     }
 

src/main/kotlin/no/nav/k9/los/nyoppgavestyring/query/db/PartisjonertOppgaveQuerySqlBuilder.kt

@@ -17,18 +17,20 @@ import no.nav.k9.los.spi.felter.SqlMedParams
 import no.nav.k9.los.spi.felter.TransientFeltutleder
 import no.nav.k9.los.spi.felter.WhereInput
 import org.slf4j.LoggerFactory
+import java.time.LocalDate
 import java.time.LocalDateTime
 
 class PartisjonertOppgaveQuerySqlBuilder(
     val felter: Map<OmrådeOgKode, OppgavefeltMedMer>,
     oppgavestatusFilter: List<Oppgavestatus>,
     val now: LocalDateTime,
-    private val ferdigstiltDato: LocalDateTime? = null,
+    private val ferdigstiltDato: LocalDate? = null,
 ) : OppgaveQuerySqlBuilder {
     private val log = LoggerFactory.getLogger(PartisjonertOppgaveQuerySqlBuilder::class.java)
 
     private val oppgavestatusPlaceholder: String = InClauseHjelper.tilParameternavn(oppgavestatusFilter, "status")
-    private val ferdigstiltDatoBetingelse = if (ferdigstiltDato != null) " AND ov.ferdigstilt_dato = :ferdigstilt_dato " else ""
+    private val ferdigstiltDatoBetingelseOppgavefeltverdi = if (ferdigstiltDato != null) " AND ov.ferdigstilt_dato = :ferdigstilt_dato " else ""
+    private val ferdigstiltDatoBetingelseOppgave = if (ferdigstiltDato != null) " AND o.ferdigstilt_dato = :ferdigstilt_dato " else ""
 
     private var selectPrefix = """
                 SELECT o.oppgave_ekstern_id, o.oppgave_ekstern_versjon
@@ -39,7 +41,7 @@ class PartisjonertOppgaveQuerySqlBuilder(
     private var query = ("""
         FROM oppgave_v3_part o
         LEFT JOIN oppgave_pep_cache opc ON (opc.kildeomrade = 'K9' AND o.oppgave_ekstern_id = opc.ekstern_id)
-        WHERE o.oppgavestatus in ($oppgavestatusPlaceholder) $ferdigstiltDatoBetingelse
+        WHERE o.oppgavestatus in ($oppgavestatusPlaceholder) $ferdigstiltDatoBetingelseOppgave
     """).trimIndent()
 
     private val filtrerReserverteOppgaver = """
@@ -82,6 +84,9 @@ class PartisjonertOppgaveQuerySqlBuilder(
             putAll(queryParams)
             putAll(orderByParams)
             putAll(oppgavestatusParams)
+            if (ferdigstiltDato != null) {
+                put("ferdigstilt_dato", ferdigstiltDato)
+            }
         }
     }
 
@@ -150,7 +155,11 @@ class PartisjonertOppgaveQuerySqlBuilder(
                 }
             }
 
-            else -> log.warn("Håndterer ikke filter for $feltkode")
+            "ferdigstiltDato", "oppgavestatus" -> {
+                // Ignorerer felter, siden de er håndtert spesielt
+            }
+
+            else -> log.warn("Håndterer ikke filter for $feltkode. Legg til i ignorering hvis feltet håndteres spesielt.")
         }
     }
 
@@ -190,7 +199,7 @@ class PartisjonertOppgaveQuerySqlBuilder(
             ${combineOperator.sql} ${if (operator.negasjonAv != null) "NOT" else ""} EXISTS (
                 SELECT 1
                 FROM oppgavefelt_verdi_part ov
-                WHERE ov.oppgavestatus in ($oppgavestatusPlaceholder) $ferdigstiltDatoBetingelse
+                WHERE ov.oppgavestatus in ($oppgavestatusPlaceholder) $ferdigstiltDatoBetingelseOppgavefeltverdi
                   AND ov.oppgave_ekstern_id = o.oppgave_ekstern_id
                   AND ov.oppgave_ekstern_versjon = o.oppgave_ekstern_versjon
                   AND ov.omrade_ekstern_id = :feltOmrade$index
@@ -247,7 +256,7 @@ class PartisjonertOppgaveQuerySqlBuilder(
             ${combineOperator.sql}$invertertOperator EXISTS (
                 SELECT 1
                 FROM oppgavefelt_verdi_part ov 
-                WHERE ov.oppgavestatus in ($oppgavestatusPlaceholder) $ferdigstiltDatoBetingelse
+                WHERE ov.oppgavestatus in ($oppgavestatusPlaceholder) $ferdigstiltDatoBetingelseOppgavefeltverdi
                     AND ov.oppgave_ekstern_id = o.oppgave_ekstern_id
                     AND ov.oppgave_ekstern_versjon = o.oppgave_ekstern_versjon
                     AND ov.omrade_ekstern_id = :feltOmrade$index
@@ -291,7 +300,6 @@ class PartisjonertOppgaveQuerySqlBuilder(
 
         orderByParams.putAll(
             mapOf(
-                "ferdigstilt_dato" to ferdigstiltDato,
                 "orderByfeltOmrade$index" to feltområde,
                 "orderByfeltkode$index" to feltkode
             )
@@ -303,7 +311,7 @@ class PartisjonertOppgaveQuerySqlBuilder(
                 , (
                   SELECT $verdifelt                    
                   FROM oppgavefelt_verdi_part ov 
-                  WHERE ov.oppgavestatus in ($oppgavestatusPlaceholder) $ferdigstiltDatoBetingelse
+                  WHERE ov.oppgavestatus in ($oppgavestatusPlaceholder) $ferdigstiltDatoBetingelseOppgavefeltverdi
                     AND ov.oppgave_ekstern_id = o.oppgave_ekstern_id
                     AND ov.oppgave_ekstern_versjon = o.oppgave_ekstern_versjon
                     AND ov.omrade_ekstern_id = :orderByfeltOmrade$index

src/main/kotlin/no/nav/k9/los/nyoppgavestyring/query/mapping/OppgaveQueryToSqlMapper.kt

@@ -4,6 +4,7 @@ import no.nav.k9.los.nyoppgavestyring.mottak.oppgave.Oppgavestatus
 import no.nav.k9.los.nyoppgavestyring.query.QueryRequest
 import no.nav.k9.los.nyoppgavestyring.query.db.*
 import no.nav.k9.los.nyoppgavestyring.query.dto.query.*
+import java.time.LocalDate
 import java.time.LocalDateTime
 
 object OppgaveQueryToSqlMapper {
@@ -14,7 +15,10 @@ object OppgaveQueryToSqlMapper {
     ): OppgaveQuerySqlBuilder {
         val oppgavestatusFilter = traverserFiltereOgFinnOppgavestatusfilter(request)
         return when {
-            oppgavestatusFilter.isEmpty() || oppgavestatusFilter.contains(Oppgavestatus.LUKKET) -> PartisjonertOppgaveQuerySqlBuilder(felter, oppgavestatusFilter, now)
+            oppgavestatusFilter.isEmpty() || oppgavestatusFilter.contains(Oppgavestatus.LUKKET) -> {
+                PartisjonertOppgaveQuerySqlBuilder(felter, oppgavestatusFilter, now,
+                    traverserFiltereOgFinnFerdigstiltDatofilter(request))
+            }
             else -> AktivOppgaveQuerySqlBuilder(felter, oppgavestatusFilter, now)
         }
     }
@@ -49,7 +53,12 @@ object OppgaveQueryToSqlMapper {
 
     fun traverserFiltereOgFinnOppgavestatusfilter(queryRequest: QueryRequest): List<Oppgavestatus> {
         val statuser = mutableSetOf<Oppgavestatus>()
-        rekursivtSøk(queryRequest.oppgaveQuery.filtere, statuser)
+        rekursivtSøk(
+            queryRequest.oppgaveQuery.filtere,
+            statuser,
+            { verdi -> Oppgavestatus.fraKode(verdi.toString()) },
+            { filter -> filter.kode == "oppgavestatus" }
+        )
 
         //dette parameteret brukes av index på oppgavefeltverdi. Spørringer som ser på lukkede oppgaver er ikke indekserte, og vil være trege
         //Dersom spørringen filterer på oppgavestatus, så matcher vi det.
@@ -61,7 +70,35 @@ object OppgaveQueryToSqlMapper {
         }
     }
 
-    private fun rekursivtSøk(
+    fun traverserFiltereOgFinnFerdigstiltDatofilter(queryRequest: QueryRequest): LocalDate? {
+        val datoer = mutableSetOf<LocalDate>()
+        rekursivtSøk(
+            queryRequest.oppgaveQuery.filtere,
+            datoer,
+            { verdi -> LocalDate.parse(verdi.toString()) },
+            { filter -> filter.kode == "ferdigstiltDato" }
+        )
+
+        //dette parameteret brukes av index på oppgavefeltverdi. Spørringer som ser på lukkede oppgaver er ikke indekserte, og vil være trege
+        return datoer.firstOrNull()
+    }
+
+    private fun <T> rekursivtSøk(
+        filtere: List<Oppgavefilter>,
+        verdierFunnet: MutableSet<T>,
+        mapper: (Any?) -> T,
+        betingelse: (FeltverdiOppgavefilter) -> Boolean
+    ) {
+        for (filter in filtere) {
+            if (filter is FeltverdiOppgavefilter && betingelse(filter)) {
+                verdierFunnet.addAll(filter.verdi.map { verdi -> mapper(verdi) })
+            } else if (filter is CombineOppgavefilter) {
+                rekursivtSøk(filter.filtere, verdierFunnet, mapper, betingelse)
+            }
+        }
+    }
+
+    /*private fun rekursivtSøk(
         filtere: List<Oppgavefilter>,
         statuser: MutableSet<Oppgavestatus>
     ) {
@@ -72,7 +109,7 @@ object OppgaveQueryToSqlMapper {
                 rekursivtSøk(filter.filtere, statuser)
             }
         }
-    }
+    }*/
 
     private fun håndterFiltere(
         queryBuilder: OppgaveQuerySqlBuilder,

src/main/kotlin/no/nav/k9/los/nyoppgavestyring/visningoguttrekk/nøkkeltall/ferdigstilteperenhet/FerdigstiltePerEnhetService.kt

@@ -4,6 +4,7 @@ import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.launch
 import no.nav.k9.los.domene.modell.FagsakYtelseType
+import no.nav.k9.los.nyoppgavestyring.mottak.oppgave.Oppgavestatus
 import no.nav.k9.los.nyoppgavestyring.query.OppgaveQueryService
 import no.nav.k9.los.nyoppgavestyring.query.QueryRequest
 import no.nav.k9.los.nyoppgavestyring.query.dto.query.FeltverdiOppgavefilter
@@ -163,7 +164,12 @@ class FerdigstiltePerEnhetService(
                     }
                     add(
                         FeltverdiOppgavefilter(
-                            "K9", "ferdigstiltTidspunkt", FeltverdiOperator.EQUALS.name, listOf(dato.toString())
+                            null, "oppgavestatus", FeltverdiOperator.EQUALS.name, listOf(Oppgavestatus.LUKKET.kode)
+                        )
+                    )
+                    add(
+                        FeltverdiOppgavefilter(
+                            null, "ferdigstiltDato", FeltverdiOperator.EQUALS.name, listOf(dato.toString())
                         )
                     )
                 }

src/main/resources/migreringer/V1.0_0078__partisjoner_ofv.sql

@@ -59,25 +59,21 @@ CREATE TABLE oppgavefelt_verdi_lukket_2025_part
 
 -- Indekser
 create index ofv_oppgave_id_idx on oppgavefelt_verdi_part(oppgave_ekstern_id);
-create index ofv_aapen_venter_verdi_idx on oppgavefelt_verdi_aapen_venter_part(omrade_ekstern_id, feltdefinisjon_ekstern_id, verdi, oppgave_ekstern_id);
-create index ofv_aapen_venter_verdi_bigint_idx on oppgavefelt_verdi_aapen_venter_part(omrade_ekstern_id, feltdefinisjon_ekstern_id, verdi_bigint, oppgave_ekstern_id);
-create index ofv_aapen_venter_idx on oppgavefelt_verdi_aapen_venter_part(omrade_ekstern_id, feltdefinisjon_ekstern_id, oppgave_ekstern_id);
+create index ofv_aapen_venter_verdi_idx on oppgavefelt_verdi_aapen_venter_part(oppgave_ekstern_id, feltdefinisjon_ekstern_id, verdi);
+create index ofv_aapen_venter_verdi_bigint_idx on oppgavefelt_verdi_aapen_venter_part(oppgave_ekstern_id, feltdefinisjon_ekstern_id, verdi_bigint) where verdi_bigint is not null;
 create index ofv_lukket_ferdigstilt_dato_idx on oppgavefelt_verdi_lukket_part(
-    ferdigstilt_dato,
-    omrade_ekstern_id,
+    ferdigstilt_dato desc,
+    oppgave_ekstern_id,
     feltdefinisjon_ekstern_id,
-    verdi,
-    oppgave_ekstern_id
-    );
+    verdi
+);
 create index ofv_lukket_verdi_idx on oppgavefelt_verdi_lukket_part(
-    omrade_ekstern_id,
+    oppgave_ekstern_id,
     feltdefinisjon_ekstern_id,
-    verdi,
-    oppgave_ekstern_id
-    );
+    verdi
+);
 create index ofv_lukket_verdi_bigint_idx on oppgavefelt_verdi_lukket_part(
-    omrade_ekstern_id,
+    oppgave_ekstern_id,
     feltdefinisjon_ekstern_id,
-    verdi,
-    oppgave_ekstern_id
-    );
+    verdi_bigint
+) where verdi_bigint is not null;

src/test/kotlin/no/nav/k9/los/nyoppgavestyring/OppgaveTestDataBuilder.kt

@@ -67,21 +67,21 @@ class OppgaveTestDataBuilder(
     }
 
 
-    fun lagOgLagre(status: Oppgavestatus = Oppgavestatus.AAPEN): OppgaveV3 {
+    fun lagOgLagre(status: Oppgavestatus = Oppgavestatus.AAPEN, endretTidspunkt: LocalDateTime = LocalDateTime.now()): OppgaveV3 {
         return transactionManager.transaction { tx ->
-            val oppgave = lag(status)
+            val oppgave = lag(status, endretTidspunkt = endretTidspunkt)
             oppgaverepo.nyOppgaveversjon(oppgave, tx)
             oppgave
         }
     }
 
-    fun lag(status: Oppgavestatus = Oppgavestatus.AAPEN, reservasjonsnøkkel: String = "", eksternVersjon: String? = null): OppgaveV3 {
+    fun lag(status: Oppgavestatus = Oppgavestatus.AAPEN, reservasjonsnøkkel: String = "", eksternVersjon: String? = null, endretTidspunkt: LocalDateTime = LocalDateTime.now()): OppgaveV3 {
         return OppgaveV3(
             eksternId = oppgaveFeltverdier[FeltType.BEHANDLINGUUID]?.verdi ?: UUID.randomUUID().toString(),
             eksternVersjon = eksternVersjon ?: eksternVersjonTeller++.toString(),
             oppgavetype = oppgavetype,
             status = status,
-            endretTidspunkt = LocalDateTime.now(),
+            endretTidspunkt = endretTidspunkt,
             kildeområde = område.eksternId,
             felter = oppgaveFeltverdier.values.toList(),
             reservasjonsnøkkel = reservasjonsnøkkel,
@@ -119,6 +119,7 @@ enum class FeltType(
     LØSBART_AKSJONSPUNKT("løsbartAksjonspunkt"),
     LIGGER_HOS_BESLUTTER("liggerHosBeslutter", tolkesSom = "boolean"),
     TID_FORSTE_GANG_HOS_BESLUTTER("tidFørsteGangHosBeslutter"),
+    FERDIGSTILT_DATO("ferdigstiltDato", tolkesSom = "Timestamp", område = null),
 }
 
 val felter: Map<OmrådeOgKode, OppgavefeltMedMer> = mapOf(

src/test/kotlin/no/nav/k9/los/nyoppgavestyring/query/OppgaveQueryTest.kt

@@ -18,6 +18,7 @@ import no.nav.k9.los.nyoppgavestyring.kodeverk.PersonBeskyttelseType
 import no.nav.k9.los.nyoppgavestyring.mottak.feltdefinisjon.FeltdefinisjonRepository
 import no.nav.k9.los.nyoppgavestyring.mottak.omraade.OmrådeRepository
 import no.nav.k9.los.nyoppgavestyring.mottak.oppgave.Oppgavestatus
+import no.nav.k9.los.nyoppgavestyring.mottak.oppgave.PartisjonertOppgaveId
 import no.nav.k9.los.nyoppgavestyring.pep.PepCache
 import no.nav.k9.los.nyoppgavestyring.pep.PepCacheRepository
 import no.nav.k9.los.nyoppgavestyring.pep.TestRepository
@@ -930,6 +931,34 @@ class OppgaveQueryTest : AbstractK9LosIntegrationTest() {
         assertThat(oppgaveQueryRepository.query(QueryRequest(query))).isEmpty()
     }
 
+    @Test
+    fun `sjekk at ferdigstiltDato kan brukes som felt`() {
+        val oppgaveTestDataBuilder = OppgaveTestDataBuilder()
+        val oppgaveQueryRepository = OppgaveQueryRepository(dataSource, mockk<FeltdefinisjonRepository>())
+
+        // lager to oppgaver, en ferdigstilt i dag og en ferdigstilt 1. januar 2025
+       oppgaveTestDataBuilder
+            .lagOgLagre(
+                status = Oppgavestatus.LUKKET,
+            )
+        val oppgaveLukketFørsteJanuar = oppgaveTestDataBuilder
+            .lagOgLagre(
+                status = Oppgavestatus.LUKKET,
+                endretTidspunkt = LocalDateTime.of(2025, 1, 1, 0, 0, 0)
+            )
+
+        val resultat = oppgaveQueryRepository.query(
+            QueryRequest(
+                OppgaveQuery(
+                    listOf(
+                        byggFilter(FeltType.FERDIGSTILT_DATO, FeltverdiOperator.EQUALS, "2025-01-01"),
+                        byggFilter(FeltType.OPPGAVE_STATUS, FeltverdiOperator.EQUALS, "LUKKET"),
+                    )
+                )
+            ))
+        assertThat(resultat).containsOnly(PartisjonertOppgaveId(oppgaveLukketFørsteJanuar.eksternId, oppgaveLukketFørsteJanuar.eksternVersjon))
+    }
+
     private fun lagOppgaveMedPepCache(
         kode6: Boolean = false,
         kode7: Boolean = false,