Start konsumering av FriskTilArbeidVedtak

Author: nilsjorgen

src/main/kotlin/no/nav/helse/flex/frisktilarbeid/FriskTilArbeidConsumer.kt

@@ -5,12 +5,10 @@ import no.nav.helse.flex.config.EnvironmentToggles
 import no.nav.helse.flex.kafka.FRISKTILARBEID_TOPIC
 import no.nav.helse.flex.logger
 import org.apache.kafka.clients.consumer.ConsumerRecord
-import org.springframework.context.annotation.Profile
 import org.springframework.kafka.annotation.KafkaListener
 import org.springframework.kafka.support.Acknowledgment
 import org.springframework.stereotype.Component
 
-@Profile("frisktilarbeid")
 @Component
 class FriskTilArbeidConsumer(
     private val friskTilArbeidService: FriskTilArbeidService,
@@ -21,16 +19,14 @@ class FriskTilArbeidConsumer(
     @WithSpan
     @KafkaListener(
         topics = [FRISKTILARBEID_TOPIC],
-        id = "flex-frisktilarbeid-dev-2",
+        id = "flex-frisktilarbeid-v1",
         containerFactory = "aivenKafkaListenerContainerFactory",
-        properties = ["auto.offset.reset = latest"],
+        properties = ["auto.offset.reset = earliest"],
     )
     fun listen(
         cr: ConsumerRecord<String, String>,
         acknowledgment: Acknowledgment,
     ) {
-        log.info("Mottok FriskTilArbeidVedtakStatus med key: ${cr.key()}.")
-
         try {
             friskTilArbeidService.lagreFriskTilArbeidVedtakStatus(
                 FriskTilArbeidVedtakStatusKafkaMelding(

src/main/kotlin/no/nav/helse/flex/frisktilarbeid/FriskTilArbeidService.kt

@@ -7,9 +7,11 @@ import no.nav.helse.flex.logger
 import no.nav.helse.flex.medlemskap.tilPostgresJson
 import no.nav.helse.flex.service.IdentService
 import no.nav.helse.flex.util.objectMapper
+import no.nav.helse.flex.util.osloZone
 import org.springframework.stereotype.Service
 import java.time.Instant
 import java.time.LocalDate
+import java.time.LocalDateTime
 import java.time.OffsetDateTime
 import java.util.*
 
@@ -21,9 +23,16 @@ class FriskTilArbeidService(
 ) {
     private val log = logger()
 
+    private val tidspunktForOvertakelse = LocalDateTime.of(2025, 3, 10, 0, 0, 0).atZone(osloZone).toOffsetDateTime()
+
     fun lagreFriskTilArbeidVedtakStatus(kafkaMelding: FriskTilArbeidVedtakStatusKafkaMelding) {
         val friskTilArbeidVedtakStatus = kafkaMelding.friskTilArbeidVedtakStatus
 
+        // Vi skal bare prosessere vedtak som er fattet etter 10. mars 2025 00:00 norsk tid.
+        if (friskTilArbeidVedtakStatus.statusAt.isBefore(tidspunktForOvertakelse)) {
+            return
+        }
+
         if (friskTilArbeidVedtakStatus.status == Status.FATTET) {
             val identer = identService.hentFolkeregisterIdenterMedHistorikkForFnr(friskTilArbeidVedtakStatus.personident)
             val eksisterendeVedtak = friskTilArbeidRepository.findByFnrIn(identer.alle())

src/test/kotlin/no/nav/helse/flex/frisktilarbeid/FriskTilArbeidServiceTest.kt

@@ -9,7 +9,9 @@ import org.junit.jupiter.api.Test
 import org.junit.jupiter.api.assertThrows
 import org.springframework.beans.factory.annotation.Autowired
 import java.time.LocalDate
-import java.util.*
+import java.time.LocalDateTime
+import java.time.OffsetDateTime
+import java.time.ZoneOffset
 
 class FriskTilArbeidServiceTest : FakesTestOppsett() {
     @Autowired
@@ -50,6 +52,42 @@ class FriskTilArbeidServiceTest : FakesTestOppsett() {
         fakeFriskTilArbeidRepository.findAll().toList() shouldHaveSize 0
     }
 
+    @Test
+    fun `Lagrer ikke vedtak med statusAt før tidspunktForOvertakelse norsk tid`() {
+        val statusAt = OffsetDateTime.of(LocalDateTime.of(2025, 3, 9, 22, 59, 0), ZoneOffset.UTC)
+
+        friskTilArbeidService.lagreFriskTilArbeidVedtakStatus(
+            FriskTilArbeidVedtakStatusKafkaMelding(
+                key = key,
+                friskTilArbeidVedtakStatus =
+                    lagFriskTilArbeidVedtakStatus(
+                        fnr,
+                        Status.FATTET,
+                    ).copy(statusAt = statusAt),
+            ),
+        )
+
+        fakeFriskTilArbeidRepository.findAll().toList() shouldHaveSize 0
+    }
+
+    @Test
+    fun `Lagrer ikke vedtak med statusAt etter tidspunktForOvertakelse norsk tid`() {
+        val statusAt = OffsetDateTime.of(LocalDateTime.of(2025, 3, 9, 23, 1, 0), ZoneOffset.UTC)
+
+        friskTilArbeidService.lagreFriskTilArbeidVedtakStatus(
+            FriskTilArbeidVedtakStatusKafkaMelding(
+                key = key,
+                friskTilArbeidVedtakStatus =
+                    lagFriskTilArbeidVedtakStatus(
+                        fnr,
+                        Status.FATTET,
+                    ).copy(statusAt = statusAt),
+            ),
+        )
+
+        fakeFriskTilArbeidRepository.findAll().toList() shouldHaveSize 1
+    }
+
     @Test
     fun `Lagrer to perioder som ikke overlapper`() {
         lagFriskTilArbeidVedtakStatus(