Flytkontroll vaskejobb for reservasjoner, oppstart av ny kjøring i Q

navikt · Jan 17, 2024 · 676fdac · 676fdac
1 parent a4060a9
commit 676fdac
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 9 deletions.
diff --git a/src/main/kotlin/no/nav/k9/los/K9Los.kt b/src/main/kotlin/no/nav/k9/los/K9Los.kt
@@ -98,7 +98,7 @@ fun Application.k9Los() {
     val k9KlageTilLosAdapterTjeneste = koin.get<K9KlageTilLosAdapterTjeneste>()
     k9KlageTilLosAdapterTjeneste.setup()
 
-    if (LocalDateTime.now().isBefore(LocalDateTime.of(2024, 1, 16, 17, 0))) {
+    if (LocalDateTime.now().isBefore(LocalDateTime.of(2024, 1, 17, 17, 0))) {
         //koin.get<K9SakTilLosLukkeFeiloppgaverTjeneste>().kjørFeiloppgaverVask()
         //koin.get<K9SakTilLosHistorikkvaskTjeneste>().kjørHistorikkvask()
         //koin.get<K9KlageTilLosHistorikkvaskTjeneste>().kjørHistorikkvask()

diff --git a/...nyoppgavestyring/domeneadaptere/k9/reservasjonkonvertering/ReservasjonKonverteringJobb.kt b/...nyoppgavestyring/domeneadaptere/k9/reservasjonkonvertering/ReservasjonKonverteringJobb.kt
@@ -35,43 +35,37 @@ class ReservasjonKonverteringJobb(
 
     fun spillAvReservasjoner() {
         log.info("Starter avspilling av reservasjoner")
-        val tidKjøringStartet = System.currentTimeMillis()
 
         val reservasjonIder = reservasjonRepository.hentAlleReservasjonUUID()
         log.info("Fant ${reservasjonIder.size} behandlinger")
         var reservasjonTeller = 0L
         var slettetReservasjon = 0L
 
-        reservasjonIder.forEach { gammelReservasjonUuid ->
+        for (gammelReservasjonUuid in reservasjonIder) {
             val reservasjonV1 = reservasjonRepository.hent(gammelReservasjonUuid)
             val saksbehandlerIdSomHolderReservasjonV1 = runBlocking {
                 saksbehandlerRepository.finnSaksbehandlerIdForIdent(reservasjonV1.reservertAv)
             }!!
-            log.info("Hentet saksbehandler som holder reservasjonV1")
             //TODO filtrer bort gamle og/eller ugyldige reservasjoner?
             if (reservasjonV1.reservertTil == null) {
                 slettetReservasjon++
-                return //Logisk slettet reservasjon. Migreres ikke
+                continue //Logisk slettet reservasjon. Migreres ikke
             }
             val oppgaveV1 = oppgaveRepository.hent(reservasjonV1.oppgave)
-            log.info("Hentet oppgaven hvis reservasjon skal konverteres")
 
             val flyttetAvSaksbehandlerId = reservasjonV1.flyttetAv?.let {
                 runBlocking {
                     saksbehandlerRepository.finnSaksbehandlerIdForIdent(it)!!
                 }
             }
-            log.info("Hentet saksbehandler som flyttet reservasjon")
 
-            log.info("Konverterer reservasjon for oppgaveUuid: ${reservasjonV1.oppgave}")
             reservasjonOversetter.taNyReservasjonFraGammelKontekst(
                 oppgaveV1 = oppgaveV1,
                 reserverForSaksbehandlerId = saksbehandlerIdSomHolderReservasjonV1,
                 reservertTil = reservasjonV1.reservertTil!!,
                 utførtAvSaksbehandlerId = flyttetAvSaksbehandlerId ?: saksbehandlerIdSomHolderReservasjonV1,
                 kommentar = reservasjonV1.begrunnelse,
             )
-            log.info("Konvertert reservasjon for oppgaveUuid: ${reservasjonV1.oppgave}")
             reservasjonTeller++
             loggFremgangForHver100(reservasjonTeller, "Konvertert $reservasjonTeller reservasjoner")
         }