IS-3142: Add consumer for updating oppfolgingsenhet changes

vetlesolgaard · vetlesolgaard · commit b8404859b4da · 2025-03-19T16:23:06.000+01:00
diff --git a/src/main/kotlin/no/nav/syfo/personstatus/application/IPersonOversiktStatusRepository.kt b/src/main/kotlin/no/nav/syfo/personstatus/application/IPersonOversiktStatusRepository.kt
@@ -30,7 +30,7 @@ interface IPersonOversiktStatusRepository {
 
     fun getVeilederTilknytningHistorikk(personident: PersonIdent): List<VeilederTildelingHistorikkDTO>
 
-    fun getPersonerWithOppgaveAndOldEnhet(): List<Pair<PersonIdent, String?>>
+    fun getPersonerWithOppgaveAndOldEnhet(): List<PersonIdent>
 
     fun getPersonerWithVeilederTildelingAndOldOppfolgingstilfelle(): List<PersonOversiktStatus>
 
diff --git a/src/main/kotlin/no/nav/syfo/personstatus/application/PersonBehandlendeEnhetService.kt b/src/main/kotlin/no/nav/syfo/personstatus/application/PersonBehandlendeEnhetService.kt
@@ -8,21 +8,21 @@ class PersonBehandlendeEnhetService(
     private val personoversiktStatusRepository: IPersonOversiktStatusRepository,
     private val behandlendeEnhetClient: BehandlendeEnhetClient,
 ) {
-    fun getPersonerToCheckForUpdatedEnhet(): List<Pair<PersonIdent, String?>> =
+    fun getPersonerToCheckForUpdatedEnhet(): List<PersonIdent> =
         personoversiktStatusRepository.getPersonerWithOppgaveAndOldEnhet()
 
-    suspend fun updateBehandlendeEnhet(
-        personIdent: PersonIdent,
-        tildeltEnhet: String? = null,
-    ) {
-        val maybeNewBehandlendeEnhet = behandlendeEnhetClient.getEnhet(
+    suspend fun updateBehandlendeEnhet(personIdent: PersonIdent) {
+        val behandlendeEnhet = behandlendeEnhetClient.getEnhet(
             callId = UUID.randomUUID().toString(),
             personIdent = personIdent,
         )
-        if (maybeNewBehandlendeEnhet != null && maybeNewBehandlendeEnhet.enhetId != tildeltEnhet) {
+        val tildeltEnhet = personoversiktStatusRepository.getPersonOversiktStatus(personIdent)?.enhet
+        val isEnhetUpdate = behandlendeEnhet != null && behandlendeEnhet.enhetId != tildeltEnhet
+
+        if (isEnhetUpdate) {
             personoversiktStatusRepository.updatePersonTildeltEnhetAndRemoveTildeltVeileder(
                 personIdent = personIdent,
-                enhetId = maybeNewBehandlendeEnhet.enhetId,
+                enhetId = behandlendeEnhet.enhetId,
             )
         } else {
             personoversiktStatusRepository.updatePersonTildeltEnhetUpdatedAt(
diff --git a/src/main/kotlin/no/nav/syfo/personstatus/application/oppfolgingsoppgave/OppfolgingsoppgaveService.kt b/src/main/kotlin/no/nav/syfo/personstatus/application/oppfolgingsoppgave/OppfolgingsoppgaveService.kt
@@ -14,7 +14,6 @@ import no.nav.syfo.personstatus.infrastructure.database.queries.updateOppfolging
 import org.slf4j.Logger
 import org.slf4j.LoggerFactory
 import kotlin.collections.filter
-import kotlin.collections.first
 import kotlin.collections.firstOrNull
 import kotlin.collections.forEach
 import kotlin.jvm.java
@@ -27,10 +26,7 @@ class OppfolgingsoppgaveService(
     fun processOppfolgingsoppgave(records: List<OppfolgingsoppgaveRecord>) {
         createOrUpdatePersonOversiktStatus(records)
         records.filter { it.isActive }.forEach {
-            val personOversiktStatus = database.getPersonOversiktStatusList(
-                fnr = it.personIdent,
-            ).first()
-            updateBehandlendeEnhet(PersonIdent(it.personIdent), personOversiktStatus.enhet)
+            updateBehandlendeEnhet(PersonIdent(it.personIdent))
         }
     }
 
@@ -61,17 +57,11 @@ class OppfolgingsoppgaveService(
         }
     }
 
-    private fun updateBehandlendeEnhet(
-        personIdent: PersonIdent,
-        existingEnhet: String?,
-    ) {
+    private fun updateBehandlendeEnhet(personIdent: PersonIdent) {
         try {
             runBlocking {
                 launch(Dispatchers.IO) {
-                    personBehandlendeEnhetService.updateBehandlendeEnhet(
-                        personIdent = personIdent,
-                        tildeltEnhet = existingEnhet
-                    )
+                    personBehandlendeEnhetService.updateBehandlendeEnhet(personIdent = personIdent)
                     log.info("Updated Behandlende Enhet of person after received active oppfolgingsoppgave")
                 }
             }
diff --git a/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/cronjob/behandlendeenhet/PersonBehandlendeEnhetCronjob.kt b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/cronjob/behandlendeenhet/PersonBehandlendeEnhetCronjob.kt
@@ -22,13 +22,9 @@ class PersonBehandlendeEnhetCronjob(
         val result = CronjobResult()
 
         personBehandlendeEnhetService.getPersonerToCheckForUpdatedEnhet()
-            .forEach { personIdentTildeltEnhetPair ->
+            .forEach { personident ->
                 try {
-                    val (personIdent, tildeltEnhet) = personIdentTildeltEnhetPair
-                    personBehandlendeEnhetService.updateBehandlendeEnhet(
-                        personIdent = personIdent,
-                        tildeltEnhet = tildeltEnhet,
-                    )
+                    personBehandlendeEnhetService.updateBehandlendeEnhet(personIdent = personident)
                     result.updated++
                     COUNT_CRONJOB_PERSON_BEHANDLENDE_ENHET_UPDATE.increment()
                 } catch (ex: Exception) {
diff --git a/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/database/repository/PersonOversiktStatusRepository.kt b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/database/repository/PersonOversiktStatusRepository.kt
@@ -237,15 +237,10 @@ class PersonOversiktStatusRepository(private val database: DatabaseInterface) :
             }
         }
 
-    override fun getPersonerWithOppgaveAndOldEnhet(): List<Pair<PersonIdent, String?>> =
+    override fun getPersonerWithOppgaveAndOldEnhet(): List<PersonIdent> =
         database.connection.use { connection ->
             connection.prepareStatement(GET_PERSONER_WITH_OPPGAVE_AND_OLD_ENHET).use {
-                it.executeQuery().toList {
-                    Pair(
-                        PersonIdent(getString("fnr")),
-                        getString("tildelt_enhet"),
-                    )
-                }
+                it.executeQuery().toList { PersonIdent(getString("fnr")) }
             }
         }
 
@@ -334,7 +329,8 @@ class PersonOversiktStatusRepository(private val database: DatabaseInterface) :
         }
 
         return results.map {
-            val personOppfolgingstilfelleVirksomhetList = personOppfolgingstilfelleVirksomhetMap[it.id]?.toPersonOppfolgingstilfelleVirksomhet() ?: emptyList()
+            val personOppfolgingstilfelleVirksomhetList =
+                personOppfolgingstilfelleVirksomhetMap[it.id]?.toPersonOppfolgingstilfelleVirksomhet() ?: emptyList()
             it.toPersonOversiktStatus(personOppfolgingstilfelleVirksomhetList = personOppfolgingstilfelleVirksomhetList)
         }
     }
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
@@ -14,6 +14,7 @@ import no.nav.syfo.pdlpersonhendelse.kafka.launchKafkaTaskPersonhendelse
 import no.nav.syfo.personoppgavehendelse.kafka.launchKafkaTaskPersonoppgavehendelse
 import no.nav.syfo.personstatus.application.PersonoversiktStatusService
 import no.nav.syfo.personstatus.application.OppfolgingstilfelleService
+import no.nav.syfo.personstatus.infrastructure.kafka.behandlendeenhet.BehandlendeEnhetConsumer
 import no.nav.syfo.personstatus.infrastructure.kafka.manglendemedvirkning.ManglendeMedvirkningVurderingConsumer
 import no.nav.syfo.personstatus.infrastructure.kafka.meroppfolging.SenOppfolgingKandidatStatusConsumer
 import no.nav.syfo.personstatus.infrastructure.kafka.oppfolgingsoppgave.launchOppfolgingsoppgaveConsumer
@@ -85,4 +86,10 @@ fun launchKafkaModule(
             applicationState = applicationState,
             kafkaEnvironment = environment.kafka,
         )
+
+    BehandlendeEnhetConsumer(personBehandlendeEnhetService = personBehandlendeEnhetService)
+        .start(
+            applicationState = applicationState,
+            kafkaEnvironment = environment.kafka,
+        )
 }
diff --git a/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/behandlendeenhet/BehandlendeEnhetConsumer.kt b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/behandlendeenhet/BehandlendeEnhetConsumer.kt
@@ -0,0 +1,70 @@
+package no.nav.syfo.personstatus.infrastructure.kafka.behandlendeenhet
+
+import no.nav.syfo.ApplicationState
+import no.nav.syfo.personstatus.application.PersonBehandlendeEnhetService
+import no.nav.syfo.personstatus.domain.PersonIdent
+import no.nav.syfo.personstatus.infrastructure.kafka.KafkaConsumerService
+import no.nav.syfo.personstatus.infrastructure.kafka.KafkaEnvironment
+import no.nav.syfo.personstatus.infrastructure.kafka.kafkaAivenConsumerConfig
+import no.nav.syfo.personstatus.infrastructure.kafka.launchKafkaTask
+import no.nav.syfo.util.configuredJacksonMapper
+import org.apache.kafka.clients.consumer.ConsumerConfig
+import org.apache.kafka.clients.consumer.ConsumerRecords
+import org.apache.kafka.clients.consumer.KafkaConsumer
+import org.apache.kafka.common.serialization.Deserializer
+import org.slf4j.LoggerFactory
+import java.time.Duration
+import java.time.OffsetDateTime
+import java.util.Properties
+
+class BehandlendeEnhetConsumer(
+    private val personBehandlendeEnhetService: PersonBehandlendeEnhetService,
+) : KafkaConsumerService<BehandlendeEnhetUpdateRecord> {
+
+    override val pollDurationInMillis: Long = 1000
+
+    override suspend fun pollAndProcessRecords(consumer: KafkaConsumer<String, BehandlendeEnhetUpdateRecord>) {
+        val records = consumer.poll(Duration.ofMillis(pollDurationInMillis))
+        if (records.count() > 0) {
+            log.info("BehandlendeEnhetConsumer trace: Received ${records.count()} records")
+            processRecords(records = records)
+            consumer.commitSync()
+        }
+    }
+
+    private suspend fun processRecords(records: ConsumerRecords<String, BehandlendeEnhetUpdateRecord>) =
+        records.requireNoNulls().map { record ->
+            personBehandlendeEnhetService.updateBehandlendeEnhet(
+                PersonIdent(record.value().personident)
+            )
+        }
+
+    fun start(applicationState: ApplicationState, kafkaEnvironment: KafkaEnvironment) {
+        val consumerProperties = Properties().apply {
+            putAll(kafkaAivenConsumerConfig(kafkaEnvironment = kafkaEnvironment))
+            this[ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG] = BehandlendeEnhetUpdateRecordDeserializer::class.java.canonicalName
+        }
+        launchKafkaTask(
+            applicationState = applicationState,
+            kafkaConsumerService = this,
+            consumerProperties = consumerProperties,
+            topic = TOPIC,
+        )
+    }
+
+    companion object {
+        private val log = LoggerFactory.getLogger(this::class.java)
+        private const val TOPIC = "teamsykefravr.behandlendeenhet"
+    }
+}
+
+data class BehandlendeEnhetUpdateRecord(
+    val personident: String,
+    val updatedAt: OffsetDateTime,
+)
+
+class BehandlendeEnhetUpdateRecordDeserializer : Deserializer<BehandlendeEnhetUpdateRecord> {
+    private val mapper = configuredJacksonMapper()
+    override fun deserialize(topic: String, data: ByteArray): BehandlendeEnhetUpdateRecord =
+        mapper.readValue(data, BehandlendeEnhetUpdateRecord::class.java)
+}
diff --git a/src/test/kotlin/no/nav/syfo/cronjob/behandlendeenhet/PersonBehandlendeEnhetCronjobSpek.kt b/src/test/kotlin/no/nav/syfo/cronjob/behandlendeenhet/PersonBehandlendeEnhetCronjobSpek.kt
@@ -93,7 +93,7 @@ object PersonBehandlendeEnhetCronjobSpek : Spek({
                     val pPersonOversiktStatus = pPersonOversiktStatusList.first()
 
                     pPersonOversiktStatus.enhet shouldNotBeEqualTo firstEnhet
-                    pPersonOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
+                    pPersonOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO.enhetId
                     pPersonOversiktStatus.tildeltEnhetUpdatedAt.shouldNotBeNull()
                     pPersonOversiktStatus.tildeltEnhetUpdatedAt!!.toInstant()
                         .toEpochMilli() shouldBeGreaterThan tildeltEnhetUpdatedAtBeforeUpdate.toInstant()
@@ -171,7 +171,7 @@ object PersonBehandlendeEnhetCronjobSpek : Spek({
 
                     val pPersonOversiktStatus = pPersonOversiktStatusList.first()
 
-                    pPersonOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
+                    pPersonOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO.enhetId
                     pPersonOversiktStatus.tildeltEnhetUpdatedAt.shouldNotBeNull()
                     pPersonOversiktStatus.tildeltEnhetUpdatedAt shouldNotBeEqualTo tildeltEnhetUpdatedAtBeforeUpdate
                     pPersonOversiktStatus.veilederIdent.shouldBeNull()
diff --git a/src/test/kotlin/no/nav/syfo/personstatus/api/v2/BehandlerdialogPersonoversiktStatusApiV2Spek.kt b/src/test/kotlin/no/nav/syfo/personstatus/api/v2/BehandlerdialogPersonoversiktStatusApiV2Spek.kt
@@ -58,7 +58,7 @@ object BehandlerdialogPersonoversiktStatusApiV2Spek : Spek({
                 response.status shouldBeEqualTo HttpStatusCode.OK
                 val personOversiktStatus = response.body<List<PersonOversiktStatusDTO>>().first()
                 personOversiktStatus.fnr shouldBeEqualTo oversikthendelseBehandlerdialogSvarMottatt.personident
-                personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
+                personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO.enhetId
                 personOversiktStatus.behandlerdialogUbehandlet shouldBeEqualTo true
             }
         }
@@ -87,7 +87,7 @@ object BehandlerdialogPersonoversiktStatusApiV2Spek : Spek({
 
                 val personOversiktStatus = response.body<List<PersonOversiktStatusDTO>>().first()
                 personOversiktStatus.fnr shouldBeEqualTo oversikthendelseBehandlerdialogUbesvartMottatt.personident
-                personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
+                personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO.enhetId
                 personOversiktStatus.behandlerdialogUbehandlet shouldBeEqualTo true
             }
         }
@@ -122,7 +122,7 @@ object BehandlerdialogPersonoversiktStatusApiV2Spek : Spek({
 
                 val personOversiktStatus = response.body<List<PersonOversiktStatusDTO>>().first()
                 personOversiktStatus.fnr shouldBeEqualTo oversikthendelseBehandlerdialogSvarMottatt.personident
-                personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
+                personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO.enhetId
                 personOversiktStatus.behandlerdialogUbehandlet shouldBeEqualTo true
             }
         }
@@ -151,7 +151,7 @@ object BehandlerdialogPersonoversiktStatusApiV2Spek : Spek({
 
                 val personOversiktStatus = response.body<List<PersonOversiktStatusDTO>>().first()
                 personOversiktStatus.fnr shouldBeEqualTo oversikthendelseBehandlerdialogAvvistMottatt.personident
-                personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
+                personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO.enhetId
                 personOversiktStatus.behandlerdialogUbehandlet shouldBeEqualTo true
             }
         }
diff --git a/src/test/kotlin/no/nav/syfo/personstatus/api/v2/DialogmotekandidatPersonoversiktStatusApiV2Spek.kt b/src/test/kotlin/no/nav/syfo/personstatus/api/v2/DialogmotekandidatPersonoversiktStatusApiV2Spek.kt
@@ -88,7 +88,7 @@ object DialogmotekandidatPersonoversiktStatusApiV2Spek : Spek({
                     personOversiktStatus.shouldNotBeNull()
                     personOversiktStatus.veilederIdent shouldBeEqualTo null
                     personOversiktStatus.fnr shouldBeEqualTo ARBEIDSTAKER_FNR
-                    personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
+                    personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO.enhetId
                     personOversiktStatus.motebehovUbehandlet.shouldBeNull()
                     personOversiktStatus.oppfolgingsplanLPSBistandUbehandlet.shouldBeNull()
                     personOversiktStatus.dialogmotesvarUbehandlet shouldBeEqualTo false
@@ -112,7 +112,7 @@ object DialogmotekandidatPersonoversiktStatusApiV2Spek : Spek({
                     personOversiktStatus.shouldNotBeNull()
                     personOversiktStatus.veilederIdent shouldBeEqualTo null
                     personOversiktStatus.fnr shouldBeEqualTo ARBEIDSTAKER_FNR
-                    personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
+                    personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO.enhetId
                     personOversiktStatus.motebehovUbehandlet.shouldBeNull()
                     personOversiktStatus.oppfolgingsplanLPSBistandUbehandlet.shouldBeNull()
                     personOversiktStatus.dialogmotesvarUbehandlet shouldBeEqualTo false
diff --git a/src/test/kotlin/no/nav/syfo/personstatus/api/v2/PersonoversiktStatusApiV2Spek.kt b/src/test/kotlin/no/nav/syfo/personstatus/api/v2/PersonoversiktStatusApiV2Spek.kt
diff --git a/src/test/kotlin/no/nav/syfo/personstatus/application/PersonBehandlendeEnhetServiceSpek.kt b/src/test/kotlin/no/nav/syfo/personstatus/application/PersonBehandlendeEnhetServiceSpek.kt
diff --git a/src/test/kotlin/no/nav/syfo/testutil/ExternalMockEnvironment.kt b/src/test/kotlin/no/nav/syfo/testutil/ExternalMockEnvironment.kt
diff --git a/src/test/kotlin/no/nav/syfo/testutil/mock/SyfobehandlendeenhetMock.kt b/src/test/kotlin/no/nav/syfo/testutil/mock/SyfobehandlendeenhetMock.kt

Original file line number	Diff line number	Diff line change
`@@ -237,15 +237,10 @@ class PersonOversiktStatusRepository(private val database: DatabaseInterface) :`
`237`	`237`	`}`
`238`	`238`	`}`
`239`	`239`
`240`		`- override fun getPersonerWithOppgaveAndOldEnhet(): List<Pair<PersonIdent, String?>> =`
	`240`	`+ override fun getPersonerWithOppgaveAndOldEnhet(): List<PersonIdent> =`
`241`	`241`	`database.connection.use { connection ->`
`242`	`242`	`connection.prepareStatement(GET_PERSONER_WITH_OPPGAVE_AND_OLD_ENHET).use {`
`243`		`- it.executeQuery().toList {`
`244`		`- Pair(`
`245`		`- PersonIdent(getString("fnr")),`
`246`		`- getString("tildelt_enhet"),`
`247`		`- )`
`248`		`- }`
	`243`	`+ it.executeQuery().toList { PersonIdent(getString("fnr")) }`
`249`	`244`	`}`
`250`	`245`	`}`
`251`	`246`
`@@ -334,7 +329,8 @@ class PersonOversiktStatusRepository(private val database: DatabaseInterface) :`
`334`	`329`	`}`
`335`	`330`
`336`	`331`	`return results.map {`
`337`		`- val personOppfolgingstilfelleVirksomhetList = personOppfolgingstilfelleVirksomhetMap[it.id]?.toPersonOppfolgingstilfelleVirksomhet() ?: emptyList()`
	`332`	`+ val personOppfolgingstilfelleVirksomhetList =`
	`333`	`+ personOppfolgingstilfelleVirksomhetMap[it.id]?.toPersonOppfolgingstilfelleVirksomhet() ?: emptyList()`
`338`	`334`	`it.toPersonOversiktStatus(personOppfolgingstilfelleVirksomhetList = personOppfolgingstilfelleVirksomhetList)`
`339`	`335`	`}`
`340`	`336`	`}`
Original file line number	Diff line number	Diff line change
`@@ -58,7 +58,7 @@ object BehandlerdialogPersonoversiktStatusApiV2Spek : Spek({`
`58`	`58`	`response.status shouldBeEqualTo HttpStatusCode.OK`
`59`	`59`	`val personOversiktStatus = response.body<List<PersonOversiktStatusDTO>>().first()`
`60`	`60`	`personOversiktStatus.fnr shouldBeEqualTo oversikthendelseBehandlerdialogSvarMottatt.personident`
`61`		`- personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId`
	`61`	`+ personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO.enhetId`
`62`	`62`	`personOversiktStatus.behandlerdialogUbehandlet shouldBeEqualTo true`
`63`	`63`	`}`
`64`	`64`	`}`
`@@ -87,7 +87,7 @@ object BehandlerdialogPersonoversiktStatusApiV2Spek : Spek({`
`87`	`87`
`88`	`88`	`val personOversiktStatus = response.body<List<PersonOversiktStatusDTO>>().first()`
`89`	`89`	`personOversiktStatus.fnr shouldBeEqualTo oversikthendelseBehandlerdialogUbesvartMottatt.personident`
`90`		`- personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId`
	`90`	`+ personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO.enhetId`
`91`	`91`	`personOversiktStatus.behandlerdialogUbehandlet shouldBeEqualTo true`
`92`	`92`	`}`
`93`	`93`	`}`
`@@ -122,7 +122,7 @@ object BehandlerdialogPersonoversiktStatusApiV2Spek : Spek({`
`122`	`122`
`123`	`123`	`val personOversiktStatus = response.body<List<PersonOversiktStatusDTO>>().first()`
`124`	`124`	`personOversiktStatus.fnr shouldBeEqualTo oversikthendelseBehandlerdialogSvarMottatt.personident`
`125`		`- personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId`
	`125`	`+ personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO.enhetId`
`126`	`126`	`personOversiktStatus.behandlerdialogUbehandlet shouldBeEqualTo true`
`127`	`127`	`}`
`128`	`128`	`}`
`@@ -151,7 +151,7 @@ object BehandlerdialogPersonoversiktStatusApiV2Spek : Spek({`
`151`	`151`
`152`	`152`	`val personOversiktStatus = response.body<List<PersonOversiktStatusDTO>>().first()`
`153`	`153`	`personOversiktStatus.fnr shouldBeEqualTo oversikthendelseBehandlerdialogAvvistMottatt.personident`
`154`		`- personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId`
	`154`	`+ personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO.enhetId`
`155`	`155`	`personOversiktStatus.behandlerdialogUbehandlet shouldBeEqualTo true`
`156`	`156`	`}`
`157`	`157`	`}`