Merge branch 'master' into q2-migrering

README.md

@@ -5,7 +5,7 @@ Oppgavestyrere definerer kriterier som ligger til grunn for køer som fordeler o
 
 # Bygge og kjøre lokalt
 
-1. Start k9-verdikjede. Er avhengig av vtp, postgresql og nav-auth-mock.
+1. Start k9-verdikjede. Er avhengig av vtp, postgresql og azure-mock.
 
 
 

build.gradle.kts

@@ -2,7 +2,7 @@ import com.github.jengelman.gradle.plugins.shadow.tasks.ShadowJar
 
 val mainClass = "no.nav.k9.los.K9LosKt"
 val hikariVersion = "6.1.0"
-val flywayVersion = "10.20.1"
+val flywayVersion = "10.21.0"
 val vaultJdbcVersion = "1.3.10"
 val koinVersion = "4.0.0"
 val kotliqueryVersion = "1.9.0"
@@ -73,9 +73,9 @@ dependencies {
     implementation("no.nav.k9.statistikk:kontrakter:2.0_20220411110858_dc06dd1")
 
     // opentelemetry
-    implementation("io.opentelemetry:opentelemetry-api:1.43.0")
-    implementation("io.opentelemetry:opentelemetry-extension-kotlin:1.43.0")
-    implementation("io.opentelemetry.instrumentation:opentelemetry-instrumentation-annotations:2.9.0")
+    implementation("io.opentelemetry:opentelemetry-api:1.44.1")
+    implementation("io.opentelemetry:opentelemetry-extension-kotlin:1.44.1")
+    implementation("io.opentelemetry.instrumentation:opentelemetry-instrumentation-annotations:2.10.0")
 
     // Div
     implementation(enforcedPlatform( "com.fasterxml.jackson:jackson-bom:$jacksonVersion"))

nais/kafka/produksjonsstyring-k9sak.yml

@@ -19,6 +19,9 @@ spec:
     - team: k9saksbehandling
       application: k9-sak
       access: write
+    - team: k9saksbehandling
+      application: ung-sak
+      access: write
     - team: k9saksbehandling
       application: k9-los-api
       access: read

nais/prod-fss.yml

@@ -37,6 +37,8 @@ spec:
       runtime: java
       destinations:
         - id: "elastic-apm"
+        - id: "grafana-lgtm"
+
   vault:
     enabled: true
     paths:

src/main/kotlin/no/nav/k9/los/K9Los.kt

@@ -113,7 +113,7 @@ fun Application.k9Los() {
     val k9TilbakeTilLosAdapterTjeneste = koin.get<K9TilbakeTilLosAdapterTjeneste>()
     k9TilbakeTilLosAdapterTjeneste.setup()
 
-    if (LocalDateTime.now().isBefore(LocalDateTime.of(2024, 11, 6, 10, 0))) {
+    if (LocalDateTime.now().isBefore(LocalDateTime.of(2024, 11, 19, 22, 30))) {
         if (1 == 0) { //HAXX for å ikke kjøre jobb, men indikere at koden er i bruk og dermed ikke slettes
             //koin.get<ReservasjonKonverteringJobb>().kjørReservasjonskonvertering() //TODO slette
             //koin.get<K9SakTilLosLukkeFeiloppgaverTjeneste>().kjørFeiloppgaverVask() //TODO slette
@@ -122,9 +122,7 @@ fun Application.k9Los() {
             koin.get<K9KlageTilLosHistorikkvaskTjeneste>().kjørHistorikkvask()
             koin.get<K9TilbakeTilLosHistorikkvaskTjeneste>().kjørHistorikkvask()
         }
-        if (configuration.koinProfile == KoinProfile.PREPROD) {
-            koin.get<K9TilbakeTilLosHistorikkvaskTjeneste>().kjørHistorikkvask()
-        }
+        koin.get<K9TilbakeTilLosHistorikkvaskTjeneste>().kjørHistorikkvask()
     }
 
     install(Authentication) {

src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9v3Tjeneste.kt

@@ -88,7 +88,8 @@ class RefreshK9v3Tjeneste(
     @WithSpan
     fun behandlingerTilOppfriskning(tx: TransactionalSession, antallPrKø: Int) : Set<UUID> {
         return DetaljerMetrikker.time("RefreshK9V3", "refreshForKøer", "alle") {
-            val alleKøer = oppgaveKoRepository.hentListe(false) + oppgaveKoRepository.hentListe(true)
+            val alleKøer = oppgaveKoRepository.hentListe(medSkjermet = false, medSaksbehandlere = false) +
+                    oppgaveKoRepository.hentListe(medSkjermet = true, medSaksbehandlere = false)
             val behandlinger = behandlingerTilOppfriskning(tx, alleKøer, antallPrKø)
             log.info("Hentet ${behandlinger.size} oppgaver fra ${alleKøer.size} køer")
             behandlinger

src/main/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/tilbaketillos/K9TilbakeTilLosHistorikkvaskTjeneste.kt

@@ -38,9 +38,9 @@ class K9TilbakeTilLosHistorikkvaskTjeneste(
                 name = TRÅDNAVN
             ) {
 
-                Thread.sleep(2.toDuration(DurationUnit.MINUTES).inWholeMilliseconds)
+                Thread.sleep(1.toDuration(DurationUnit.MINUTES).inWholeMilliseconds)
 
-                val dispatcher = newFixedThreadPoolContext(5, "Historikkvask k9tilbake")
+                val dispatcher = newFixedThreadPoolContext(1, "Historikkvask k9tilbake")
 
                 log.info("Starter avspilling av historiske BehandlingProsessEventer")
 
@@ -141,16 +141,16 @@ class K9TilbakeTilLosHistorikkvaskTjeneste(
 
         val behandlingProsessEventer = DetaljerMetrikker.time("k9tilbakeHistorikkvask", "hentEventer") { behandlingProsessEventTilbakeRepository.hentMedLås(tx, uuid).eventer }
         val høyesteInternVersjon = DetaljerMetrikker.time("k9tilbakeHistorikkvask", "hentHøyesteInternVersjon") {
-            oppgaveV3Tjeneste.hentHøyesteInternVersjon(uuid.toString(), "k9tilbake", "K9", tx)!!
+            oppgaveV3Tjeneste.hentHøyesteInternVersjon(uuid.toString(), "k9tilbake", "K9", tx)
         }
         var eventNrForBehandling = 0L
         var oppgaveV3 : OppgaveV3? = null
         for (event in behandlingProsessEventer) {
-            if (eventNrForBehandling > høyesteInternVersjon) {
+            if (høyesteInternVersjon != null && eventNrForBehandling > høyesteInternVersjon) {
                 log.info("Avbryter historikkvask for ${event.eksternId} ved eventTid ${event.eventTid}. Forventer at håndteres av vanlig adaptertjeneste.")
                 break //Historikkvasken har funnet eventer som ennå ikke er lastet inn med normalflyt. Dirty eventer skal håndteres av vanlig adaptertjeneste
             }
-            var oppgaveDto = TilbakeEventTilDtoMapper.lagOppgaveDto(event, forrigeOppgave)
+            val oppgaveDto = TilbakeEventTilDtoMapper.lagOppgaveDto(event, forrigeOppgave)
 
             oppgaveV3 = DetaljerMetrikker.time("k9tilbakeHistorikkvask", "utledEksisterendeOppgaveversjon") { oppgaveV3Tjeneste.utledEksisterendeOppgaveversjon(oppgaveDto, eventNrForBehandling, tx) }
             DetaljerMetrikker.time("k9tilbakeHistorikkvask", "oppdaterEksisterendeOppgaveversjon") { oppgaveV3Tjeneste.oppdaterEksisterendeOppgaveversjon(oppgaveV3, eventNrForBehandling, tx) }

src/main/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/tilbaketillos/TilbakeEventTilDtoMapper.kt

@@ -121,10 +121,14 @@ class TilbakeEventTilDtoMapper {
             ),
             OppgaveFeltverdiDto(
                 nøkkel = "registrertDato",
-                //TODO feltet heter *dato, avrunde til dato?
                 verdi = forrigeOppgave?.hentVerdi("registrertDato")
                     ?: event.opprettetBehandling.truncatedTo(ChronoUnit.SECONDS).toString()
             ),
+            OppgaveFeltverdiDto(
+                nøkkel = "mottattDato",
+                verdi = forrigeOppgave?.hentVerdi("mottattDato")
+                    ?: event.opprettetBehandling.truncatedTo(ChronoUnit.SECONDS).toString()
+            ),
             OppgaveFeltverdiDto(
                 nøkkel = "feilutbetaltBeløp",
                 verdi = event.feilutbetaltBeløp?.toString() ?: forrigeOppgave?.hentVerdi("feilutbetaltBeløp")

src/main/kotlin/no/nav/k9/los/nyoppgavestyring/ko/AntallOppgaver.kt

@@ -0,0 +1,3 @@
+package no.nav.k9.los.nyoppgavestyring.ko
+
+data class AntallOppgaver(val antallUtenReserverte: Long)

src/main/kotlin/no/nav/k9/los/nyoppgavestyring/ko/OppgaveKoApis.kt

@@ -105,6 +105,26 @@ fun Route.OppgaveKoApis() {
         }
     }
 
+    get("/andre-saksbehandleres-koer") {
+        requestContextService.withRequestContext(call) {
+            if (pepClient.erOppgaveStyrer()) {
+                call.respond(
+                    oppgaveKoTjeneste.hentKøerForSaksbehandler(
+                        call.parameters["id"]?.toLong()!!,
+                        pepClient.harTilgangTilKode6()
+                    ).map {
+                        OppgaveKoIdOgTittel(
+                            id = it.id,
+                            tittel = it.tittel
+                        )
+                    }
+                )
+            } else {
+                call.respond(HttpStatusCode.Forbidden)
+            }
+        }
+    }
+
     get("/{id}/oppgaver") {
         requestContextService.withRequestContext(call) {
             if (pepClient.harTilgangTilReserveringAvOppgaver()) {
@@ -160,6 +180,24 @@ fun Route.OppgaveKoApis() {
         }
     }
 
+    get("/{id}/antall-uten-reserverte") {
+        requestContextService.withRequestContext(call) {
+            if (pepClient.harBasisTilgang()) {
+                val oppgavekøId = call.parameters["id"]!!
+
+                val antallUtenReserverte = OpentelemetrySpanUtil.span("OppgaveKoTjeneste.hentAntallOppgaverForKø") {
+                    oppgaveKoTjeneste.hentAntallOppgaverForKø(
+                        oppgavekøId.toLong(),
+                        true
+                    )
+                }
+                call.respond(AntallOppgaver(antallUtenReserverte))
+            } else {
+                call.respond(HttpStatusCode.Forbidden)
+            }
+        }
+    }
+
     post("/{id}/fa-oppgave") {
         requestContextService.withRequestContext(call) {
             if (pepClient.harTilgangTilReserveringAvOppgaver()) {

src/main/kotlin/no/nav/k9/los/nyoppgavestyring/ko/OppgaveKoTjeneste.kt

@@ -20,7 +20,10 @@ import no.nav.k9.los.nyoppgavestyring.mottak.oppgave.AktivOppgaveRepository
 import no.nav.k9.los.nyoppgavestyring.query.Avgrensning
 import no.nav.k9.los.nyoppgavestyring.query.OppgaveQueryService
 import no.nav.k9.los.nyoppgavestyring.query.QueryRequest
-import no.nav.k9.los.nyoppgavestyring.reservasjon.*
+import no.nav.k9.los.nyoppgavestyring.reservasjon.AlleredeReservertException
+import no.nav.k9.los.nyoppgavestyring.reservasjon.ManglerTilgangException
+import no.nav.k9.los.nyoppgavestyring.reservasjon.ReservasjonV3
+import no.nav.k9.los.nyoppgavestyring.reservasjon.ReservasjonV3Tjeneste
 import no.nav.k9.los.nyoppgavestyring.visningoguttrekk.GenerellOppgaveV3Dto
 import no.nav.k9.los.nyoppgavestyring.visningoguttrekk.Oppgave
 import no.nav.k9.los.nyoppgavestyring.visningoguttrekk.OppgaveRepository
@@ -87,7 +90,27 @@ class OppgaveKoTjeneste(
         saksbehandlerEpost: String
     ): List<OppgaveKo> {
         return transactionalManager.transaction { tx ->
-            oppgaveKoRepository.hentKoerMedOppgittSaksbehandler(tx, saksbehandlerEpost)
+            oppgaveKoRepository.hentKoerMedOppgittSaksbehandler(
+                tx = tx,
+                saksbehandlerEpost = saksbehandlerEpost,
+                medSaksbehandlere = false,
+                skjermet = false
+            )
+        }
+    }
+
+    @WithSpan
+    fun hentKøerForSaksbehandler(
+        saksbehandlerId: Long,
+        skjermet: Boolean
+    ): List<OppgaveKo> {
+        return transactionalManager.transaction { tx ->
+            oppgaveKoRepository.hentKoerMedOppgittSaksbehandler(
+                tx = tx,
+                saksbehandlerId = saksbehandlerId,
+                medSaksbehandlere = false,
+                skjermet = skjermet
+            )
         }
     }
 

src/main/kotlin/no/nav/k9/los/nyoppgavestyring/ko/db/OppgaveKoRepository.kt

@@ -31,21 +31,20 @@ class OppgaveKoRepository(
         objectMapper.writeValueAsString(kode6OppgaveQuery)
     }
 
-    fun hentListe(medSkjermet: Boolean = false): List<OppgaveKo> {
+    fun hentListe(medSkjermet: Boolean = false, medSaksbehandlere: Boolean = true): List<OppgaveKo> {
         return using(sessionOf(datasource)) {
-            it.transaction { tx -> hentListe(tx, medSkjermet) }
+            it.transaction { tx -> hentListe(tx, medSaksbehandlere, medSkjermet) }
         }
     }
 
-    fun hentListe(tx: TransactionalSession, skjermet: Boolean = false): List<OppgaveKo> {
+    fun hentListe(tx: TransactionalSession, medSaksbehandlere: Boolean, skjermet: Boolean = false): List<OppgaveKo> {
         return tx.run(
             queryOf(
                 """SELECT id, versjon, tittel, beskrivelse, query, fritt_valg_av_oppgave, endret_tidspunkt, skjermet 
                     FROM OPPGAVEKO_V3 WHERE skjermet = :medSkjermet""",
                 mapOf("medSkjermet" to skjermet)
-            ).map { row -> row.tilOppgaveKo(objectMapper, tx) }.asList
+            ).map { row -> row.tilOppgaveKo(objectMapper, medSaksbehandlere, tx) }.asList
         )
-
     }
 
     fun hent(oppgaveKoId: Long): OppgaveKo {
@@ -64,19 +63,19 @@ class OppgaveKoRepository(
                     "id" to oppgaveKoId,
                     "skjermet" to skjermet
                 )
-            ).map { it.tilOppgaveKo(objectMapper, tx) to it.boolean("skjermet") }.asSingle
+            ).map { it.tilOppgaveKo(objectMapper, true, tx) to it.boolean("skjermet") }.asSingle
         ) ?: throw IllegalStateException("Feil ved henting av oppgavekø: $oppgaveKoId")
     }
 
-    fun Row.tilOppgaveKo(objectMapper: ObjectMapper, tx: TransactionalSession): OppgaveKo {
+    private fun Row.tilOppgaveKo(objectMapper: ObjectMapper, medSaksbehandlere: Boolean = true, tx: TransactionalSession): OppgaveKo {
         return OppgaveKo(
             id = long("id"),
             versjon = long("versjon"),
             tittel = string("tittel"),
             beskrivelse = string("beskrivelse"),
             oppgaveQuery = objectMapper.readValue(string("query"), OppgaveQuery::class.java),
             frittValgAvOppgave = boolean("fritt_valg_av_oppgave"),
-            saksbehandlere = hentKoSaksbehandlere(tx, long("id")),
+            saksbehandlere = if (medSaksbehandlere) hentKoSaksbehandlere(tx, long("id")) else emptyList(),
             endretTidspunkt = localDateTimeOrNull("endret_tidspunkt"),
             skjermet = boolean("skjermet")
         )
@@ -154,7 +153,8 @@ class OppgaveKoRepository(
     fun hentKoerMedOppgittSaksbehandler(
         tx: TransactionalSession,
         saksbehandlerEpost: String,
-        skjermet: Boolean = false
+        skjermet: Boolean = false,
+        medSaksbehandlere: Boolean = true
     ): List<OppgaveKo> {
         return tx.run(
             queryOf(
@@ -173,17 +173,36 @@ class OppgaveKoRepository(
                     "skjermet" to skjermet
                 )
             ).map { row ->
-                OppgaveKo(
-                    id = row.long("id"),
-                    versjon = row.long("versjon"),
-                    tittel = row.string("tittel"),
-                    beskrivelse = row.string("beskrivelse"),
-                    oppgaveQuery = objectMapper.readValue(row.string("query"), OppgaveQuery::class.java),
-                    frittValgAvOppgave = row.boolean("fritt_valg_av_oppgave"),
-                    saksbehandlere = hentKoSaksbehandlere(tx, row.long("id")),
-                    endretTidspunkt = row.localDateTimeOrNull("endret_tidspunkt"),
-                    skjermet = row.boolean("skjermet")
+                row.tilOppgaveKo(objectMapper, medSaksbehandlere, tx)
+            }.asList
+        )
+    }
+
+    fun hentKoerMedOppgittSaksbehandler(
+        tx: TransactionalSession,
+        saksbehandlerId: Long,
+        skjermet: Boolean,
+        medSaksbehandlere: Boolean
+    ): List<OppgaveKo> {
+        return tx.run(
+            queryOf(
+                """
+                    select id, versjon, tittel, beskrivelse, query, fritt_valg_av_oppgave, endret_tidspunkt, skjermet
+                    from OPPGAVEKO_V3 ko
+                    where skjermet = :skjermet AND      
+                    exists (
+                        select 1
+                        from oppgaveko_saksbehandler os
+                        inner join saksbehandler s on s.epost = os.saksbehandler_epost
+                        where os.oppgaveko_v3_id = ko.id
+                        and s.id = :saksbehandler_id
+                        )""",
+                mapOf(
+                    "saksbehandler_id" to saksbehandlerId,
+                    "skjermet" to skjermet
                 )
+            ).map { row ->
+                row.tilOppgaveKo(objectMapper, medSaksbehandlere, tx)
             }.asList
         )
     }

src/main/kotlin/no/nav/k9/los/nyoppgavestyring/ko/dto/OppgaveKoIdOgTittel.kt

@@ -0,0 +1,6 @@
+package no.nav.k9.los.nyoppgavestyring.ko.dto
+
+data class OppgaveKoIdOgTittel(
+    val id: Long,
+    val tittel: String,
+)

src/main/kotlin/no/nav/k9/los/tjenester/avdelingsleder/AvdelingslederTjeneste.kt

@@ -112,7 +112,7 @@ class AvdelingslederTjeneste(
 
         transactionalManager.transaction { tx ->
             // V3-modellen: Sletter køer saksbehandler er med i
-            oppgaveKøV3Repository.hentKoerMedOppgittSaksbehandler(tx, epost, skjermet).forEach { kø ->
+            oppgaveKøV3Repository.hentKoerMedOppgittSaksbehandler(tx, epost, skjermet, true).forEach { kø ->
                 oppgaveKøV3Repository.endre(tx, kø.copy(saksbehandlere = kø.saksbehandlere - epost))
             }
 
@@ -139,6 +139,7 @@ class AvdelingslederTjeneste(
         val saksbehandlersKoer = hentSaksbehandlersOppgavekoer()
         return saksbehandlersKoer.entries.map {
             SaksbehandlerDto(
+                id = it.key.id,
                 brukerIdent = it.key.brukerIdent,
                 navn = it.key.navn,
                 epost = it.key.epost,

src/main/kotlin/no/nav/k9/los/tjenester/saksbehandler/saksliste/SaksbehandlerDto.kt

@@ -1,6 +1,7 @@
 package no.nav.k9.los.tjenester.saksbehandler.saksliste
 
 data class SaksbehandlerDto(
+    val id: Long?,
     val brukerIdent: String?,
     val navn: String?,
     val epost: String,

src/main/resources/adapterdefinisjoner/k9-oppgavetyper-k9tilbake.json

@@ -36,6 +36,11 @@
           "visPåOppgave": true,
           "påkrevd": false
         },
+        {
+          "id": "mottattDato",
+          "visPåOppgave": true,
+          "påkrevd": false
+        },
         {
           "id": "registrertDato",
           "visPåOppgave": true,