ny oppdateringstype utsettSpeilRelatert

src/main/kotlin/no/nav/syfo/utsattoppgave/UtsattOppgaveDTO.kt

@@ -11,16 +11,23 @@ data class UtsattOppgaveDTO(
 )
 
 enum class OppdateringstypeDTO {
-    Utsett, Opprett, OpprettSpeilRelatert, Ferdigbehandlet
+    Utsett, UtsettSpeilRelatert, Opprett, OpprettSpeilRelatert, Ferdigbehandlet
 }
 
 enum class DokumentTypeDTO {
     Inntektsmelding, Søknad
 }
 
 fun OppdateringstypeDTO.tilHandling() = when (this) {
-    OppdateringstypeDTO.Utsett -> Handling.Utsett
-    OppdateringstypeDTO.Opprett -> Handling.Opprett
-    OppdateringstypeDTO.Ferdigbehandlet -> Handling.Forkast
+    OppdateringstypeDTO.Utsett,
+    OppdateringstypeDTO.UtsettSpeilRelatert -> Handling.Utsett
+    OppdateringstypeDTO.Opprett,
     OppdateringstypeDTO.OpprettSpeilRelatert -> Handling.Opprett
+    OppdateringstypeDTO.Ferdigbehandlet -> Handling.Forkast
+}
+
+fun OppdateringstypeDTO.erSpeilRelatert() = when (this) {
+    OppdateringstypeDTO.UtsettSpeilRelatert,
+    OppdateringstypeDTO.OpprettSpeilRelatert -> true
+    else -> false
 }

src/main/kotlin/no/nav/syfo/utsattoppgave/UtsattOppgaveService.kt

@@ -36,45 +36,43 @@ class UtsattOppgaveService(
             logger.info("Mottok oppdatering på en ukjent oppgave for id: ${oppdatering.id}")
             return
         }
+
         logger.info("Fant oppgave for inntektsmelding: ${oppgave.arkivreferanse} med tilstand: ${oppgave.tilstand.name}")
-        val gjelderSpeil = oppdatering.oppdateringstype == OppdateringstypeDTO.OpprettSpeilRelatert
+        val gjelderSpeil = oppdatering.oppdateringstype.erSpeilRelatert()
 
-        if (oppgave.tilstand == Tilstand.Utsatt && oppdatering.handling == no.nav.syfo.utsattoppgave.Handling.Utsett) {
-            if (oppgave.timeout == null) {
-                metrikk.tellUtsattOppgave_UtenDato()
+        when {
+            oppgave.tilstand == Tilstand.Utsatt && oppdatering.handling == Handling.Utsett -> {
+                if (oppgave.timeout == null) {
+                    metrikk.tellUtsattOppgave_UtenDato()
+                }
+                oppdatering.timeout ?: error("Timeout på utsettelse mangler for inntektsmelding: ${oppgave.arkivreferanse}")
+                oppgave.timeout = oppdatering.timeout
+                oppgave.oppdatert = LocalDateTime.now()
+                oppgave.speil = gjelderSpeil
+                lagre(oppgave)
+                metrikk.tellUtsattOppgave_Utsett()
+                logger.info("Oppdaterte timeout på inntektsmelding: ${oppgave.arkivreferanse} til ${oppdatering.timeout}")
+            }
+            oppgave.tilstand == Tilstand.Utsatt && oppdatering.handling == Handling.Forkast -> {
+                oppgave.oppdatert = LocalDateTime.now()
+                lagre(oppgave.copy(tilstand = Tilstand.Forkastet, speil = gjelderSpeil))
+                metrikk.tellUtsattOppgave_Forkast()
+                logger.info("Endret oppgave: ${oppgave.arkivreferanse} til tilstand: ${Tilstand.Forkastet.name}")
+            }
+            (oppgave.tilstand == Tilstand.Utsatt || oppgave.tilstand == Tilstand.Forkastet) && oppdatering.handling == Handling.Opprett -> {
+                val inntektsmeldingEntitet = inntektsmeldingRepository.findByArkivReferanse(oppgave.arkivreferanse)
+                val resultat = opprettOppgaveIGosys(oppgave, oppgaveClient, utsattOppgaveDAO, behandlendeEnhetConsumer, gjelderSpeil, inntektsmeldingEntitet, om)
+                oppgave.oppdatert = LocalDateTime.now()
+                lagre(oppgave.copy(tilstand = Tilstand.Opprettet, speil = gjelderSpeil))
+                metrikk.tellUtsattOppgave_Opprett()
+                logger.info("Endret oppgave: ${oppgave.inntektsmeldingId} til tilstand: ${Tilstand.Opprettet.name} gosys oppgaveID: ${resultat.oppgaveId} duplikat? ${resultat.duplikat}")
+            }
+            else -> {
+                metrikk.tellUtsattOppgave_Irrelevant()
+                logger.info("Oppdatering på dokumentId: ${oppdatering.id} ikke relevant")
             }
-            oppdatering.timeout ?: error("Timeout på utsettelse mangler for inntektsmelding: ${oppgave.arkivreferanse}")
-            oppgave.timeout = oppdatering.timeout
-            oppgave.oppdatert = LocalDateTime.now()
-            oppgave.speil = gjelderSpeil
-            lagre(oppgave)
-            metrikk.tellUtsattOppgave_Utsett()
-            logger.info("Oppdaterte timeout på inntektsmelding: ${oppgave.arkivreferanse} til ${oppdatering.timeout}")
-            return
-        }
-
-        if (oppgave.tilstand == Tilstand.Utsatt && oppdatering.handling == no.nav.syfo.utsattoppgave.Handling.Forkast) {
-            oppgave.oppdatert = LocalDateTime.now()
-            lagre(oppgave.copy(tilstand = Tilstand.Forkastet, speil = gjelderSpeil))
-            metrikk.tellUtsattOppgave_Forkast()
-            logger.info("Endret oppgave: ${oppgave.arkivreferanse} til tilstand: ${Tilstand.Forkastet.name}")
-            return
-        }
-
-        if ((oppgave.tilstand == Tilstand.Utsatt || oppgave.tilstand == Tilstand.Forkastet) && oppdatering.handling == Handling.Opprett) {
-            val inntektsmeldingEntitet = inntektsmeldingRepository.findByArkivReferanse(oppgave.arkivreferanse)
-            val resultat = opprettOppgaveIGosys(oppgave, oppgaveClient, utsattOppgaveDAO, behandlendeEnhetConsumer, gjelderSpeil, inntektsmeldingEntitet, om)
-            oppgave.oppdatert = LocalDateTime.now()
-            lagre(oppgave.copy(tilstand = Tilstand.Opprettet, speil = gjelderSpeil))
-            metrikk.tellUtsattOppgave_Opprett()
-            logger.info("Endret oppgave: ${oppgave.inntektsmeldingId} til tilstand: ${Tilstand.Opprettet.name} gosys oppgaveID: ${resultat.oppgaveId} duplikat? ${resultat.duplikat}")
-            return
         }
-
-        metrikk.tellUtsattOppgave_Irrelevant()
-        logger.info("Oppdatering på dokumentId: ${oppdatering.id} ikke relevant")
     }
-
     fun lagre(oppgave: UtsattOppgaveEntitet) {
         utsattOppgaveDAO.lagre(oppgave)
     }

src/test/kotlin/no/nav/syfo/utsattoppgave/UtsattOppgaveServiceTest.kt

@@ -1,6 +1,7 @@
 package no.nav.syfo.utsattoppgave
 
 import com.fasterxml.jackson.databind.ObjectMapper
+import io.mockk.every
 import io.mockk.mockk
 import io.mockk.verify
 import no.nav.syfo.client.OppgaveClient
@@ -20,8 +21,8 @@ open class UtsattOppgaveServiceTest {
     private var oppgaveClient: OppgaveClient = mockk()
     private var behandlendeEnhetConsumer: BehandlendeEnhetConsumer = mockk()
     private lateinit var oppgaveService: UtsattOppgaveService
-    private var metrikk: Metrikk = mockk()
-    private var inntektsmeldingRepository: InntektsmeldingRepository = mockk()
+    private var metrikk: Metrikk = mockk(relaxed = true)
+    private var inntektsmeldingRepository: InntektsmeldingRepository = mockk(relaxed = true)
     private var om: ObjectMapper = mockk()
 
     @BeforeEach
@@ -43,6 +44,22 @@ open class UtsattOppgaveServiceTest {
         verify { utsattOppgaveDAO.opprett(oppgave) }
     }
 
+    @Test
+    fun `lagrerer utsatt oppgave med gjelder speil flagg for UtsettSpeilRelatert`() {
+        val timeout = LocalDateTime.of(2023, 4, 6, 9, 0)
+        val nyTimout = timeout.plusDays(7)
+        val oppgave = enOppgave(timeout)
+        every { utsattOppgaveDAO.finn(any()) } returns oppgave
+        val oppgaveOppdatering = OppgaveOppdatering(
+            UUID.randomUUID(),
+            OppdateringstypeDTO.UtsettSpeilRelatert.tilHandling(),
+            nyTimout,
+            OppdateringstypeDTO.UtsettSpeilRelatert
+        )
+        oppgaveService.prosesser(oppgaveOppdatering)
+        verify { utsattOppgaveDAO.lagre(eq(oppgave.copy(timeout = nyTimout, speil = true))) }
+    }
+
     private fun enOppgave(timeout: LocalDateTime, tilstand: Tilstand = Tilstand.Utsatt) = UtsattOppgaveEntitet(
         fnr = fnr,
         aktørId = aktørId,