Start consumer manglende medvirkning

navikt · Sep 23, 2024 · 53323a4 · 53323a4
1 parent 5947e7f
commit 53323a4
Show file tree

Hide file tree

Showing 5 changed files with 18 additions and 12 deletions.
diff --git a/...tlin/no/nav/syfo/personstatus/application/manglendemedvirkning/ManglendeMedvirkningDTO.kt b/...tlin/no/nav/syfo/personstatus/application/manglendemedvirkning/ManglendeMedvirkningDTO.kt
@@ -28,5 +28,5 @@ data class ManglendeMedvirkningVarselDTO(
 )
 
 enum class ManglendeMedvirkningVurderingType {
-    FORHANDSVARSEL, OPPFYLT, STANS, IKKE_AKTUELL,
+    FORHANDSVARSEL, OPPFYLT, STANS, IKKE_AKTUELL, UNNTAK
 }
diff --git a/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/KafkaModule.kt b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/KafkaModule.kt
@@ -13,6 +13,7 @@ import no.nav.syfo.oppfolgingstilfelle.kafka.launchKafkaTaskOppfolgingstilfelleP
 import no.nav.syfo.pdlpersonhendelse.kafka.launchKafkaTaskPersonhendelse
 import no.nav.syfo.personoppgavehendelse.kafka.launchKafkaTaskPersonoppgavehendelse
 import no.nav.syfo.personstatus.PersonoversiktStatusService
+import no.nav.syfo.personstatus.infrastructure.kafka.manglendemedvirkning.ManglendeMedvirkningVurderingConsumer
 import no.nav.syfo.personstatus.infrastructure.kafka.meroppfolging.SenOppfolgingKandidatStatusConsumer
 import no.nav.syfo.trengeroppfolging.kafka.launchTrengerOppfolgingConsumer
 
@@ -75,4 +76,10 @@ fun launchKafkaModule(
             applicationState = applicationState,
             kafkaEnvironment = environment.kafka,
         )
+
+    ManglendeMedvirkningVurderingConsumer(personoversiktStatusService = personoversiktStatusService)
+        .start(
+            applicationState = applicationState,
+            kafkaEnvironment = environment.kafka,
+        )
 }
diff --git a/...status/infrastructure/kafka/manglendemedvirkning/ManglendeMedvirkningVurderingConsumer.kt b/...status/infrastructure/kafka/manglendemedvirkning/ManglendeMedvirkningVurderingConsumer.kt
@@ -2,8 +2,8 @@ package no.nav.syfo.personstatus.infrastructure.kafka.manglendemedvirkning
 
 import no.nav.syfo.ApplicationState
 import no.nav.syfo.personstatus.PersonoversiktStatusService
+import no.nav.syfo.personstatus.domain.PersonIdent
 import no.nav.syfo.personstatus.infrastructure.kafka.*
-import no.nav.syfo.personstatus.infrastructure.kafka.meroppfolging.KandidatStatusRecord
 import no.nav.syfo.util.configuredJacksonMapper
 import org.apache.kafka.clients.consumer.ConsumerConfig
 import org.apache.kafka.clients.consumer.ConsumerRecords
@@ -47,7 +47,7 @@ class ManglendeMedvirkningVurderingConsumer(
         return validRecords.map { record ->
             val recordValue = record.value()
             personoversiktStatusService.upsertManglendeMedvirkningStatus(
-                personident = recordValue.personident,
+                personident = PersonIdent(recordValue.personident),
                 isAktivVurdering = recordValue.vurderingType.isActive,
             )
         }
@@ -59,8 +59,8 @@ class ManglendeMedvirkningVurderingConsumer(
     }
 }
 
-class ManglendeMedvirkningVurderingRecordDeserializer : Deserializer<KandidatStatusRecord> {
+class ManglendeMedvirkningVurderingRecordDeserializer : Deserializer<VurderingRecord> {
     private val mapper = configuredJacksonMapper()
-    override fun deserialize(topic: String, data: ByteArray): KandidatStatusRecord =
-        mapper.readValue(data, KandidatStatusRecord::class.java)
+    override fun deserialize(topic: String, data: ByteArray): VurderingRecord =
+        mapper.readValue(data, VurderingRecord::class.java)
 }
diff --git a/...lin/no/nav/syfo/personstatus/infrastructure/kafka/manglendemedvirkning/VurderingRecord.kt b/...lin/no/nav/syfo/personstatus/infrastructure/kafka/manglendemedvirkning/VurderingRecord.kt
@@ -1,13 +1,12 @@
 package no.nav.syfo.personstatus.infrastructure.kafka.manglendemedvirkning
 
-import no.nav.syfo.personstatus.domain.PersonIdent
 import java.time.LocalDate
 import java.time.OffsetDateTime
 import java.util.*
 
 data class VurderingRecord(
     val uuid: UUID,
-    val personident: PersonIdent,
+    val personident: String,
     val veilederident: String,
     val createdAt: OffsetDateTime,
     val begrunnelse: String,
@@ -21,11 +20,11 @@ data class VurderingTypeDTO(
 )
 
 enum class VurderingType {
-    FORHANDSVARSEL, OPPFYLT, STANS, IKKE_AKTUELL
+    FORHANDSVARSEL, OPPFYLT, STANS, IKKE_AKTUELL, UNNTAK
 }
 
 data class Varsel(
     val uuid: UUID,
     val createdAt: OffsetDateTime,
-    val svarFrist: LocalDate,
+    val svarfrist: LocalDate,
 )
diff --git a/...us/infrastructure/kafka/manglendemedvirkning/ManglendeMedvirkningVurderingConsumerSpek.kt b/...us/infrastructure/kafka/manglendemedvirkning/ManglendeMedvirkningVurderingConsumerSpek.kt
@@ -60,14 +60,14 @@ class ManglendeMedvirkningVurderingConsumerSpek : Spek({
         val personident = PersonIdent(UserConstants.ARBEIDSTAKER_FNR)
         val forhandsvarselVurderingRecord = VurderingRecord(
             uuid = UUID.randomUUID(),
-            personident = personident,
+            personident = personident.value,
             veilederident = UserConstants.VEILEDER_ID,
             createdAt = OffsetDateTime.now(),
             begrunnelse = "begrunnelse",
             varsel = Varsel(
                 uuid = UUID.randomUUID(),
                 createdAt = OffsetDateTime.now(),
-                svarFrist = LocalDate.now().plusWeeks(3),
+                svarfrist = LocalDate.now().plusWeeks(3),
             ),
             vurderingType = VurderingTypeDTO(
                 value = VurderingType.FORHANDSVARSEL,