Endret håndtering av svar frister når ansvaret går tilbake til registeret

Author: nilsmsa

apps/bekreftelse-tjeneste/src/main/kotlin/no/nav/paw/bekreftelsetjeneste/paavegneav/HaandterBekreftelsePaaVegneAv.kt

@@ -2,15 +2,21 @@ package no.nav.paw.bekreftelsetjeneste.paavegneav
 
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseHendelse
 import no.nav.paw.bekreftelse.internehendelser.BekreftelsePaaVegneAvStartet
+import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeUtloeptEtterEksternInnsamling
 import no.nav.paw.bekreftelse.paavegneav.v1.PaaVegneAv
 import no.nav.paw.bekreftelse.paavegneav.v1.vo.Start
 import no.nav.paw.bekreftelse.paavegneav.v1.vo.Stopp
+import no.nav.paw.bekreftelsetjeneste.config.BekreftelseKonfigurasjon
+import no.nav.paw.bekreftelsetjeneste.logger
 import no.nav.paw.bekreftelsetjeneste.tilstand.BekreftelseTilstand
 import no.nav.paw.bekreftelsetjeneste.tilstand.GracePeriodeVarselet
 import no.nav.paw.bekreftelsetjeneste.tilstand.IkkeKlarForUtfylling
 import no.nav.paw.bekreftelsetjeneste.tilstand.InternBekreftelsePaaVegneAvStartet
 import no.nav.paw.bekreftelsetjeneste.tilstand.KlarForUtfylling
+import no.nav.paw.bekreftelsetjeneste.tilstand.Levert
 import no.nav.paw.bekreftelsetjeneste.tilstand.VenterSvar
+import no.nav.paw.bekreftelsetjeneste.tilstand.has
+import no.nav.paw.bekreftelsetjeneste.tilstand.opprettFoersteBekreftelse
 import no.nav.paw.bekreftelsetjeneste.tilstand.plus
 import no.nav.paw.bekreftelsetjeneste.tilstand.sisteTilstand
 import no.nav.paw.bekreftelsetjeneste.topology.Feil
@@ -19,13 +25,15 @@ import no.nav.paw.bekreftelsetjeneste.topology.logWarning
 import no.nav.paw.bekreftelsetjeneste.topology.paaVegneAvStartet
 import no.nav.paw.bekreftelsetjeneste.topology.paaVegneAvStoppet
 import java.time.Duration
+import java.time.Duration.between
 import java.time.Instant
 import java.util.*
 
 @JvmInline
 value class WallClock(val value: Instant)
 
 fun haandterBekreftelsePaaVegneAvEndret(
+    bekreftelseKonfigurasjon: BekreftelseKonfigurasjon,
     wallclock: WallClock,
     bekreftelseTilstand: BekreftelseTilstand?,
     paaVegneAvTilstand: PaaVegneAvTilstand?,
@@ -40,11 +48,13 @@ fun haandterBekreftelsePaaVegneAvEndret(
             handling = handling
         )
 
-        is Stopp -> stoppPaaVegneAv(
+        is Stopp -> haandterStoppPaaVegneAv(
+            bekreftelseKonfigurasjon = bekreftelseKonfigurasjon,
+            wallclock = wallclock,
+            bekreftelseTilstand = bekreftelseTilstand,
             paaVegneAvTilstand = paaVegneAvTilstand,
             paaVegneAvHendelse = paaVegneAvHendelse
         )
-
         else -> emptyList()
     }.also { _ ->
         val action = when (paaVegneAvHendelse.handling) {
@@ -74,6 +84,67 @@ fun haandterBekreftelsePaaVegneAvEndret(
     }
 }
 
+fun haandterStoppPaaVegneAv(
+    bekreftelseKonfigurasjon: BekreftelseKonfigurasjon,
+    wallclock: WallClock,
+    bekreftelseTilstand: BekreftelseTilstand?,
+    paaVegneAvTilstand: PaaVegneAvTilstand?,
+    paaVegneAvHendelse: PaaVegneAv
+): List<Handling> {
+    val handlingerKnyttetTilFrister = if (bekreftelseTilstand != null) {
+        verifiserBekreftelseFrist(bekreftelseTilstand, bekreftelseKonfigurasjon, wallclock, paaVegneAvHendelse)
+    } else {
+        null
+    }
+    return stoppPaaVegneAv(
+        paaVegneAvTilstand = paaVegneAvTilstand,
+        paaVegneAvHendelse = paaVegneAvHendelse
+    ) + listOfNotNull(handlingerKnyttetTilFrister)
+}
+
+fun verifiserBekreftelseFrist(
+    bekreftelseTilstand: BekreftelseTilstand,
+    bekreftelseKonfigurasjon: BekreftelseKonfigurasjon,
+    wallclock: WallClock,
+    paaVegneAvHendelse: PaaVegneAv
+): SendHendelse? {
+    val sisteLevering = bekreftelseTilstand?.bekreftelser
+        ?.filter { it.has<Levert>() }
+        ?.maxByOrNull { it.gjelderTil }
+    val frist = bekreftelseKonfigurasjon.interval + bekreftelseKonfigurasjon.graceperiode
+    val tidSidenFrist = sisteLevering?.let { between(it.gjelderTil, wallclock.value).toString() } ?: "null"
+    logger.info("[${wallclock.value}]Siste levering: ${sisteLevering?.gjelderTil}, frist: $frist, tid siden frist: $tidSidenFrist")
+    return when {
+        sisteLevering != null &&  between(sisteLevering.gjelderTil, wallclock.value) > frist -> {
+            SendHendelse(
+                RegisterGracePeriodeUtloeptEtterEksternInnsamling(
+                    hendelseId = UUID.randomUUID(),
+                    periodeId = paaVegneAvHendelse.periodeId,
+                    arbeidssoekerId = bekreftelseTilstand.periode.arbeidsoekerId,
+                    hendelseTidspunkt = wallclock.value
+                )
+            )
+        }
+
+        sisteLevering == null -> opprettFoersteBekreftelse(
+            tidligsteStartTidspunktForBekreftelse = bekreftelseKonfigurasjon.migreringstidspunkt,
+            periode = bekreftelseTilstand.periode,
+            interval = bekreftelseKonfigurasjon.interval
+        ).takeIf { between(it.gjelderTil, wallclock.value) > bekreftelseKonfigurasjon.graceperiode }
+            ?.let {
+                SendHendelse(
+                    RegisterGracePeriodeUtloeptEtterEksternInnsamling(
+                        hendelseId = UUID.randomUUID(),
+                        periodeId = paaVegneAvHendelse.periodeId,
+                        arbeidssoekerId = bekreftelseTilstand.periode.arbeidsoekerId,
+                        hendelseTidspunkt = wallclock.value
+                    )
+                )
+            }
+        else -> null
+    }
+}
+
 fun stoppPaaVegneAv(
     paaVegneAvTilstand: PaaVegneAvTilstand?,
     paaVegneAvHendelse: PaaVegneAv

apps/bekreftelse-tjeneste/src/main/kotlin/no/nav/paw/bekreftelsetjeneste/topology/BekreftelsePaaVegneAvStroem.kt

@@ -9,6 +9,7 @@ import no.nav.paw.bekreftelse.internehendelser.BekreftelseHendelseSerde
 import no.nav.paw.bekreftelse.paavegneav.v1.PaaVegneAv
 import no.nav.paw.bekreftelse.paavegneav.v1.vo.Start
 import no.nav.paw.bekreftelse.paavegneav.v1.vo.Stopp
+import no.nav.paw.bekreftelsetjeneste.config.BekreftelseKonfigurasjon
 import no.nav.paw.bekreftelsetjeneste.paavegneav.*
 import no.nav.paw.bekreftelsetjeneste.config.KafkaTopologyConfig
 import no.nav.paw.bekreftelsetjeneste.metrics.tellPaVegneAv
@@ -22,6 +23,7 @@ import java.time.Instant
 import java.util.*
 
 fun StreamsBuilder.byggBekreftelsePaaVegneAvStroem(
+    bekreftelseKonfigurasjon: BekreftelseKonfigurasjon,
     registry: PrometheusMeterRegistry,
     kafkaTopologyConfig: KafkaTopologyConfig,
     bekreftelseHendelseSerde: BekreftelseHendelseSerde
@@ -43,7 +45,8 @@ fun StreamsBuilder.byggBekreftelsePaaVegneAvStroem(
                 ansvarlige = paaVegneAvTilstand?.paaVegneAvList?.map { it.loesning } ?: emptyList()
             )
             haandterBekreftelsePaaVegneAvEndret(
-                wallclock = WallClock(Instant.now()),
+                wallclock = WallClock(Instant.ofEpochMilli(this.currentSystemTimeMs())),
+                bekreftelseKonfigurasjon = bekreftelseKonfigurasjon,
                 bekreftelseTilstand = bekreftelseTilstand,
                 paaVegneAvTilstand = paaVegneAvTilstand,
                 paaVegneAvHendelse = message

apps/bekreftelse-tjeneste/src/main/kotlin/no/nav/paw/bekreftelsetjeneste/topology/BekreftelsePunctuator.kt

@@ -12,6 +12,7 @@ import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeUtloept
 import no.nav.paw.bekreftelsetjeneste.paavegneav.PaaVegneAvTilstand
 import no.nav.paw.bekreftelsetjeneste.paavegneav.WallClock
 import no.nav.paw.bekreftelsetjeneste.config.BekreftelseKonfigurasjon
+import no.nav.paw.bekreftelsetjeneste.logger
 import no.nav.paw.bekreftelsetjeneste.tilstand.*
 import no.nav.paw.collections.toPawNonEmptyListOrNull
 import org.apache.kafka.streams.KeyValue

apps/bekreftelse-tjeneste/src/main/kotlin/no/nav/paw/bekreftelsetjeneste/topology/Topology.kt

@@ -22,7 +22,8 @@ fun StreamsBuilder.buildTopology(
     byggBekreftelsePaaVegneAvStroem(
         registry = applicationContext.prometheusMeterRegistry,
         kafkaTopologyConfig = applicationContext.applicationConfig.kafkaTopology,
-        bekreftelseHendelseSerde = applicationContext.bekreftelseHendelseSerde
+        bekreftelseHendelseSerde = applicationContext.bekreftelseHendelseSerde,
+        bekreftelseKonfigurasjon = applicationContext.bekreftelseKonfigurasjon
     )
     return build()
 }

apps/bekreftelse-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/BekreftelseHappyPathSimulator.kt

@@ -12,10 +12,12 @@ import no.nav.paw.bekreftelse.internehendelser.BekreftelseHendelse
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseMeldingMottatt
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseTilgjengelig
 import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeUtloept
+import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeUtloeptEtterEksternInnsamling
 import no.nav.paw.bekreftelse.melding.v1.Bekreftelse
 import no.nav.paw.bekreftelse.melding.v1.vo.Bekreftelsesloesning
 import no.nav.paw.bekreftelse.melding.v1.vo.Svar
 import no.nav.paw.bekreftelse.paavegneav.v1.PaaVegneAv
+import no.nav.paw.bekreftelse.paavegneav.v1.vo.Stopp
 import java.time.Duration
 import java.time.Instant
 import java.util.*
@@ -35,7 +37,7 @@ fun main() {
         )
     ) {
         val opploesning = Duration.ofSeconds(60)
-        val stoppTid = "01.06.2025 00:00".timestamp
+        val stoppTid = "02.05.2025 00:00".timestamp
         with(KafkaKeyContext(this.kafkaKeysClient)) {
             val periode = periode(
                 identitetsnummer = identietsnummer,
@@ -123,7 +125,8 @@ fun ApplicationTestContext.run(
         if (!bekreftelseHendelseloggTopicOut.isEmpty) {
             val kv = bekreftelseHendelseloggTopicOut.readKeyValue()
             when (val hendelse = kv.value) {
-                is RegisterGracePeriodeUtloept -> {
+                is RegisterGracePeriodeUtloept,
+                is RegisterGracePeriodeUtloeptEtterEksternInnsamling -> {
                     perioder
                         .first { it.id == kv.value.periodeId }
                         .let { periode ->
@@ -144,7 +147,7 @@ fun ApplicationTestContext.run(
         }
         still_klokken_frem(opploesning)
         counter++
-        if (counter % 100000 == 0) {
+        if (counter % 1000 == 0) {
             println("Tidspunkt: ${wallclock.get().prettyPrint}")
         }
     }

apps/bekreftelse-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/TestUtils.kt

@@ -13,6 +13,7 @@ import no.nav.paw.bekreftelse.internehendelser.LeveringsfristUtloept
 import no.nav.paw.bekreftelse.internehendelser.PeriodeAvsluttet
 import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeGjenstaaendeTid
 import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeUtloept
+import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeUtloeptEtterEksternInnsamling
 import no.nav.paw.bekreftelsetjeneste.config.BekreftelseKonfigurasjon
 import no.nav.paw.bekreftelsetjeneste.tilstand.*
 import no.nav.paw.test.days
@@ -214,6 +215,7 @@ fun BekreftelseHendelse.prettyPrint(): String {
         is PeriodeAvsluttet -> null
         is RegisterGracePeriodeGjenstaaendeTid -> "\tgjenstående tid: ${this.gjenstaandeTid}"
         is RegisterGracePeriodeUtloept -> "\tperiode avsluttes"
+        is RegisterGracePeriodeUtloeptEtterEksternInnsamling -> null
     }
     return if (detaljer == null) {
         header

apps/bekreftelse-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/paavegneav/DagpengerStarterBekreftelsePaaVegneAv1DagFoerGraceperiodenUtloeper.kt

@@ -34,7 +34,8 @@ class DagpengerStarterBekreftelsePaaVegneAv1DagFoerGraceperiodenUtloeper : FreeS
             wallclock = WallClock(intervaller.gracePeriodeUtloeper(periodeStart) - 1.days),
             bekreftelseTilstand = tilstand,
             paaVegneAvTilstand = null,
-            paaVegneAvHendelse = dagpengerStarterBekreftelsePaaVegneAv
+            paaVegneAvHendelse = dagpengerStarterBekreftelsePaaVegneAv,
+            bekreftelseKonfigurasjon = intervaller
         )
         "BekreftelsePaaVegneAv skal skrives til key-value store" {
             handlinger.assertExactlyOne<Handling, SkrivPaaVegneAvTilstand> {

apps/bekreftelse-tjeneste/src/test/resources/logback-test.xml

@@ -19,5 +19,6 @@
 
     <logger name="punctuator.bekreftelse" level="trace"/>
     <logger name="org.apache.kafka" level="WARN"/>
-    <logger name="bekreftelse" level="INFO"/>
+    <logger name="bekreftelse" level="trace"/>
+    <logger name="bekreftelse.tjeneste.punctuator" level="warn"/>
 </configuration>

apps/bekreftelse-utgang/src/main/kotlin/no/nav/paw/bekreftelseutgang/topology/BekreftelseUtgangStream.kt

@@ -9,6 +9,7 @@ import no.nav.paw.arbeidssokerregisteret.intern.v1.vo.Metadata
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseHendelse
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseHendelseSerde
 import no.nav.paw.bekreftelse.internehendelser.baOmAaAvsluttePeriodeHendelsesType
+import no.nav.paw.bekreftelse.internehendelser.registerGracePeriodeUtloeptEtterEksternInnsamlingHendelseType
 import no.nav.paw.bekreftelse.internehendelser.registerGracePeriodeUtloeptHendelseType
 import no.nav.paw.bekreftelseutgang.config.ApplicationConfig
 import no.nav.paw.bekreftelseutgang.tilstand.InternTilstand
@@ -58,6 +59,16 @@ fun processBekreftelseHendelse(
             ),
             aarsak = "Graceperiode utløpt"
         )
+        registerGracePeriodeUtloeptEtterEksternInnsamlingHendelseType -> avsluttetHendelse(
+            identitetsnummer = identitetsnummer,
+            periodeId = bekreftelseHendelse.periodeId,
+            arbeidssoekerId = bekreftelseHendelse.arbeidssoekerId,
+            utfoertAv = Bruker(
+                type = BrukerType.SYSTEM,
+                id = applicationConfig.getAppImage()
+            ),
+            aarsak = "Graceperiode utløpt etter ekstern innsamling"
+        )
         baOmAaAvsluttePeriodeHendelsesType -> avsluttetHendelse(
             identitetsnummer = identitetsnummer,
             periodeId = bekreftelseHendelse.periodeId,

domain/bekreftelse-interne-hendelser/src/main/kotlin/no/nav/paw/bekreftelse/internehendelser/BekreftelseHendelseSerde.kt

@@ -46,6 +46,7 @@ class BekreftelseHendelseDeserializer: Deserializer<BekreftelseHendelse> {
             registerGracePeriodeGjenstaaendeTid -> objectMapper.readValue<RegisterGracePeriodeGjenstaaendeTid>(node.traverse())
             baOmAaAvsluttePeriodeHendelsesType -> objectMapper.readValue<BaOmAaAvsluttePeriode>(node.traverse())
             bekreftelsePaaVegneAvStartetHendelsesType -> objectMapper.readValue<BekreftelsePaaVegneAvStartet>(node.traverse())
+            registerGracePeriodeUtloeptEtterEksternInnsamlingHendelseType -> objectMapper.readValue<RegisterGracePeriodeUtloeptEtterEksternInnsamling>(node.traverse())
             else -> throw IllegalArgumentException("Ukjent hendelseType: $hendelseType")
         }
 }

domain/bekreftelse-interne-hendelser/src/main/kotlin/no/nav/paw/bekreftelse/internehendelser/RegisterGracePeriodeUtloeptEtterEksternInnsamling.kt

@@ -0,0 +1,15 @@
+package no.nav.paw.bekreftelse.internehendelser
+
+import java.time.Instant
+import java.util.*
+
+const val registerGracePeriodeUtloeptEtterEksternInnsamlingHendelseType = "bekreftelse.register_grace_periode_utloept_etter_ekstern_innsamling"
+
+data class RegisterGracePeriodeUtloeptEtterEksternInnsamling(
+    override val hendelseId: UUID,
+    override val periodeId: UUID,
+    override val arbeidssoekerId: Long,
+    override val hendelseTidspunkt: Instant
+) : BekreftelseHendelse {
+    override val hendelseType: String = registerGracePeriodeUtloeptEtterEksternInnsamlingHendelseType
+}