publish narmeste leder dialogmote svar to esyfo varselbus

luantr · luantr · commit c4d186a020a3 · 2025-01-20T21:09:20.000+01:00
diff --git a/src/main/kotlin/no/nav/syfo/brev/esyfovarsel/EsyfovarselProducer.kt b/src/main/kotlin/no/nav/syfo/brev/esyfovarsel/EsyfovarselProducer.kt
@@ -1,6 +1,7 @@
 package no.nav.syfo.brev.esyfovarsel
 
 import com.fasterxml.jackson.annotation.JsonTypeInfo
+import no.nav.syfo.dialogmote.domain.DialogmoteSvarType
 import java.io.Serializable
 import java.util.*
 import org.apache.kafka.clients.producer.KafkaProducer
@@ -55,7 +56,8 @@ data class ArbeidstakerHendelse(
 data class VarselData(
     val journalpost: VarselDataJournalpost? = null,
     val narmesteLeder: VarselDataNarmesteLeder? = null,
-    val motetidspunkt: VarselDataMotetidspunkt? = null
+    val motetidspunkt: VarselDataMotetidspunkt? = null,
+    val dialogmoteSvar: VarselDataDialogmoteSvar? = null
 )
 
 data class VarselDataJournalpost(
@@ -71,6 +73,10 @@ data class VarselDataMotetidspunkt(
     val tidspunkt: LocalDateTime
 )
 
+data class VarselDataDialogmoteSvar(
+    val svar: DialogmoteSvarType
+)
+
 enum class HendelseType {
     NL_DIALOGMOTE_INNKALT,
     SM_DIALOGMOTE_INNKALT,
@@ -81,4 +87,5 @@ enum class HendelseType {
     NL_DIALOGMOTE_NYTT_TID_STED,
     SM_DIALOGMOTE_NYTT_TID_STED,
     SM_DIALOGMOTE_LEST,
+    NL_DIALOGMOTE_SVAR,
 }
diff --git a/src/main/kotlin/no/nav/syfo/brev/narmesteleder/NarmesteLederBrevApi.kt b/src/main/kotlin/no/nav/syfo/brev/narmesteleder/NarmesteLederBrevApi.kt
@@ -1,7 +1,6 @@
 package no.nav.syfo.brev.narmesteleder
 
 import io.ktor.http.*
-import io.ktor.server.application.*
 import io.ktor.server.request.*
 import io.ktor.server.response.*
 import io.ktor.server.routing.*
@@ -177,6 +176,11 @@ fun Route.registerNarmestelederBrevApi(
                         svarTekst = responsDTO.svarTekst,
                     )
                     if (updated) {
+                        dialogmoteService.publishNarmesteLederSvarVarselHendelse(
+                            brev = brev,
+                            responsDTO = responsDTO,
+                            narmesteLederPersonIdent = narmesteLederPersonIdent,
+                        )
                         call.respond(HttpStatusCode.OK)
                     } else {
                         throw IllegalArgumentException("Response already stored")
diff --git a/src/main/kotlin/no/nav/syfo/brev/narmesteleder/NarmesteLederVarselService.kt b/src/main/kotlin/no/nav/syfo/brev/narmesteleder/NarmesteLederVarselService.kt
@@ -26,6 +26,10 @@ class NarmesteLederVarselService(
         esyfovarselProducer.sendVarselToEsyfovarsel(hendelse)
     }
 
+    fun sendMelding(hendelse: EsyfovarselHendelse) {
+        esyfovarselProducer.sendVarselToEsyfovarsel(hendelse)
+    }
+
     private fun getNaermesteLederVarselType(motedeltakerVarselType: MotedeltakerVarselType): HendelseType {
         return when (motedeltakerVarselType) {
             MotedeltakerVarselType.INNKALT -> HendelseType.NL_DIALOGMOTE_INNKALT
diff --git a/src/main/kotlin/no/nav/syfo/dialogmote/DialogmoteService.kt b/src/main/kotlin/no/nav/syfo/dialogmote/DialogmoteService.kt
@@ -3,6 +3,7 @@ package no.nav.syfo.dialogmote
 import no.nav.syfo.application.api.authentication.getNAVIdentFromToken
 import no.nav.syfo.application.database.DatabaseInterface
 import no.nav.syfo.application.exception.ConflictException
+import no.nav.syfo.brev.narmesteleder.domain.NarmesteLederResponsDTO
 import no.nav.syfo.client.behandlendeenhet.BehandlendeEnhetClient
 import no.nav.syfo.client.narmesteleder.NarmesteLederClient
 import no.nav.syfo.client.narmesteleder.NarmesteLederRelasjonDTO
@@ -78,10 +79,9 @@ class DialogmoteService(
         val personIdent = PersonIdent(newDialogmoteDTO.arbeidstaker.personIdent)
         val virksomhetsnummer = Virksomhetsnummer(newDialogmoteDTO.arbeidsgiver.virksomhetsnummer)
 
-        val anyUnfinishedDialogmote =
-            getDialogmoteList(personIdent).filter {
-                it.arbeidsgiver.virksomhetsnummer == virksomhetsnummer
-            }.anyUnfinished()
+        val anyUnfinishedDialogmote = getDialogmoteList(personIdent).filter {
+            it.arbeidsgiver.virksomhetsnummer == virksomhetsnummer
+        }.anyUnfinished()
 
         if (anyUnfinishedDialogmote) {
             throw ConflictException("Denied access to create Dialogmote: unfinished Dialogmote exists for PersonIdent")
@@ -220,14 +220,13 @@ class DialogmoteService(
             pdfContent = avlysDialogmote.arbeidsgiver.avlysning,
         ) ?: throw RuntimeException("Failed to request PDF - Avlysning Arbeidsgiver")
 
-        val pdfAvlysningBehandler =
-            avlysDialogmote.behandler?.let {
-                pdfGenClient.pdfAvlysning(
-                    callId = callId,
-                    mottakerNavn = dialogmote.behandler?.behandlerNavn,
-                    pdfContent = it.avlysning,
-                ) ?: throw RuntimeException("Failed to request PDF - Avlysning Behandler")
-            }
+        val pdfAvlysningBehandler = avlysDialogmote.behandler?.let {
+            pdfGenClient.pdfAvlysning(
+                callId = callId,
+                mottakerNavn = dialogmote.behandler?.behandlerNavn,
+                pdfContent = it.avlysning,
+            ) ?: throw RuntimeException("Failed to request PDF - Avlysning Behandler")
+        }
 
         val digitalVarsling = isDigitalVarselEnabled(
             personIdent = dialogmote.arbeidstaker.personIdent,
@@ -315,14 +314,13 @@ class DialogmoteService(
             pdfContent = endreDialogmoteTidSted.arbeidsgiver.endringsdokument,
         ) ?: throw RuntimeException("Failed to request PDF - EndringTidSted Arbeidsgiver")
 
-        val pdfEndringBehandler =
-            endreDialogmoteTidSted.behandler?.let {
-                pdfGenClient.pdfEndringTidSted(
-                    callId = callId,
-                    mottakerNavn = dialogmote.behandler?.behandlerNavn,
-                    pdfContent = it.endringsdokument,
-                ) ?: throw RuntimeException("Failed to request PDF - EndringTidSted Behandler")
-            }
+        val pdfEndringBehandler = endreDialogmoteTidSted.behandler?.let {
+            pdfGenClient.pdfEndringTidSted(
+                callId = callId,
+                mottakerNavn = dialogmote.behandler?.behandlerNavn,
+                pdfContent = it.endringsdokument,
+            ) ?: throw RuntimeException("Failed to request PDF - EndringTidSted Behandler")
+        }
 
         val digitalVarsling = isDigitalVarselEnabled(
             personIdent = dialogmote.arbeidstaker.personIdent,
@@ -481,9 +479,7 @@ class DialogmoteService(
         database.connection.use { connection ->
             dialogmoter.forEach { dialogmote ->
                 connection.updateMoteTildeltVeileder(
-                    commit = false,
-                    moteId = dialogmote.id,
-                    veilederId = veilederIdent
+                    commit = false, moteId = dialogmote.id, veilederId = veilederIdent
                 )
             }
             connection.commit()
@@ -843,4 +839,24 @@ class DialogmoteService(
             callId = callId,
         )
     }
+
+    fun publishNarmesteLederSvarVarselHendelse(
+        brev: NarmesteLederBrev,
+        responsDTO: NarmesteLederResponsDTO,
+        narmesteLederPersonIdent: PersonIdent,
+    ) {
+        val dialogmoteDeltagerArbeidsgiver = dialogmotedeltakerService.getDialogmoteDeltakerArbeidsgiverById(
+            motedeltakerArbeidsgiverId = brev.motedeltakerArbeidsgiverId,
+        )
+        val arbeidstakerPersonIdent = dialogmotedeltakerService.getDialogmoteDeltakerArbeidstaker(
+            moteId = dialogmoteDeltagerArbeidsgiver.moteId,
+        ).personIdent
+
+        varselService.sendNarmesteLederSvarVarselHendelse(
+            responsDTO = responsDTO,
+            narmesteLederPersonIdent = narmesteLederPersonIdent,
+            arbeidstakerPersonIdent = arbeidstakerPersonIdent,
+            virksomhetsnummer = dialogmoteDeltagerArbeidsgiver.virksomhetsnummer,
+        )
+    }
 }
diff --git a/src/main/kotlin/no/nav/syfo/dialogmote/VarselService.kt b/src/main/kotlin/no/nav/syfo/dialogmote/VarselService.kt
@@ -3,14 +3,22 @@ package no.nav.syfo.dialogmote
 import java.util.*
 import no.nav.syfo.brev.arbeidstaker.ArbeidstakerVarselService
 import no.nav.syfo.brev.behandler.BehandlerVarselService
+import no.nav.syfo.brev.esyfovarsel.HendelseType
+import no.nav.syfo.brev.esyfovarsel.NarmesteLederHendelse
+import no.nav.syfo.brev.esyfovarsel.VarselData
+import no.nav.syfo.brev.esyfovarsel.VarselDataDialogmoteSvar
 import no.nav.syfo.brev.narmesteleder.NarmesteLederVarselService
+import no.nav.syfo.brev.narmesteleder.domain.NarmesteLederResponsDTO
 import no.nav.syfo.client.altinn.AltinnClient
 import no.nav.syfo.client.altinn.createAltinnMelding
+import no.nav.syfo.client.ereg.EregOrganisasjonResponse
 import no.nav.syfo.client.narmesteleder.NarmesteLederRelasjonDTO
 import no.nav.syfo.client.oppfolgingstilfelle.OppfolgingstilfelleClient
 import no.nav.syfo.client.oppfolgingstilfelle.isInactive
+import no.nav.syfo.dialogmote.domain.DialogmoteSvarType
 import no.nav.syfo.dialogmote.domain.DocumentComponentDTO
 import no.nav.syfo.dialogmote.domain.MotedeltakerVarselType
+import no.nav.syfo.dialogmote.domain.NarmesteLederBrev
 import no.nav.syfo.domain.PersonIdent
 import no.nav.syfo.domain.Virksomhetsnummer
 import org.slf4j.Logger
@@ -106,4 +114,23 @@ class VarselService(
             }
         }
     }
+    fun sendNarmesteLederSvarVarselHendelse(
+        responsDTO: NarmesteLederResponsDTO,
+        narmesteLederPersonIdent: PersonIdent,
+        arbeidstakerPersonIdent: PersonIdent,
+        virksomhetsnummer: Virksomhetsnummer
+    ) {
+
+        narmesteLederVarselService.sendMelding(NarmesteLederHendelse(
+            type = HendelseType.NL_DIALOGMOTE_SVAR,
+            data = VarselData(
+                dialogmoteSvar = VarselDataDialogmoteSvar(
+                    svar = DialogmoteSvarType.valueOf(responsDTO.svarType),
+                )
+            ),
+            narmesteLederFnr = narmesteLederPersonIdent.value,
+            arbeidstakerFnr = arbeidstakerPersonIdent.value,
+            orgnummer = virksomhetsnummer.value,
+        ))
+    }
 }
diff --git a/src/test/kotlin/no/nav/syfo/brev/narmesteleder/NarmesteLederBrevSpek.kt b/src/test/kotlin/no/nav/syfo/brev/narmesteleder/NarmesteLederBrevSpek.kt
@@ -36,10 +36,7 @@ import no.nav.syfo.testhelper.UserConstants.NARMESTELEDER_FNR
 import no.nav.syfo.testhelper.UserConstants.NARMESTELEDER_FNR_2
 import no.nav.syfo.testhelper.UserConstants.OTHER_VIRKSOMHETSNUMMER_HAS_NARMESTELEDER
 import no.nav.syfo.testhelper.UserConstants.VEILEDER_IDENT
-import no.nav.syfo.testhelper.generator.generateInkallingHendelse
-import no.nav.syfo.testhelper.generator.generateInkallingHendelseOtherVirksomhet
-import no.nav.syfo.testhelper.generator.generateNewDialogmoteDTO
-import no.nav.syfo.testhelper.generator.generateNewReferatDTO
+import no.nav.syfo.testhelper.generator.*
 import no.nav.syfo.testhelper.mock.pdfInnkalling
 import no.nav.syfo.testhelper.mock.pdfReferat
 import no.nav.syfo.util.NAV_PERSONIDENT_HEADER
@@ -199,6 +196,12 @@ object NarmesteLederBrevSpek : Spek({
                             )
                         )
                     }.apply {
+                        verify(exactly = 1) {
+                            esyfovarselProducerMock.sendVarselToEsyfovarsel(
+                                generateKommerSvarHendelse()
+                            )
+                        }
+                        clearMocks(esyfovarselProducerMock)
                         status shouldBeEqualTo HttpStatusCode.OK
                     }
 
diff --git a/src/test/kotlin/no/nav/syfo/testhelper/ExternalMockEnvironment.kt b/src/test/kotlin/no/nav/syfo/testhelper/ExternalMockEnvironment.kt
@@ -79,7 +79,7 @@ class ExternalMockEnvironment private constructor() {
 }
 
 fun ExternalMockEnvironment.startExternalMocks() {
-    this.redisServer.start()
+    //this.redisServer.start()
 }
 
 fun HashMap<String, NettyApplicationEngine>.start() {
diff --git a/src/test/kotlin/no/nav/syfo/testhelper/generator/EsyfovarselHendelseGenerator.kt b/src/test/kotlin/no/nav/syfo/testhelper/generator/EsyfovarselHendelseGenerator.kt
@@ -1,6 +1,7 @@
 package no.nav.syfo.testhelper.generator
 
 import no.nav.syfo.brev.esyfovarsel.*
+import no.nav.syfo.dialogmote.domain.DialogmoteSvarType
 import no.nav.syfo.testhelper.UserConstants.ARBEIDSTAKER_FNR
 import no.nav.syfo.testhelper.UserConstants.NARMESTELEDER_FNR
 import no.nav.syfo.testhelper.UserConstants.OTHER_VIRKSOMHETSNUMMER_HAS_NARMESTELEDER
@@ -64,3 +65,14 @@ fun generateReferatHendelse() =
         arbeidstakerFnr = ARBEIDSTAKER_FNR.value,
         orgnummer = VIRKSOMHETSNUMMER_HAS_NARMESTELEDER.value
     )
+
+fun generateKommerSvarHendelse() =
+    NarmesteLederHendelse(
+        type = HendelseType.NL_DIALOGMOTE_SVAR,
+        narmesteLederFnr = NARMESTELEDER_FNR.value,
+        data = VarselData(
+            dialogmoteSvar = VarselDataDialogmoteSvar(DialogmoteSvarType.KOMMER)
+        ),
+        arbeidstakerFnr = ARBEIDSTAKER_FNR.value,
+        orgnummer = VIRKSOMHETSNUMMER_HAS_NARMESTELEDER.value
+    )

Original file line number	Diff line number	Diff line change
`@@ -79,7 +79,7 @@ class ExternalMockEnvironment private constructor() {`
`79`	`79`	`}`
`80`	`80`
`81`	`81`	`fun ExternalMockEnvironment.startExternalMocks() {`
`82`		`- this.redisServer.start()`
	`82`	`+ //this.redisServer.start()`
`83`	`83`	`}`
`84`	`84`
`85`	`85`	`fun HashMap<String, NettyApplicationEngine>.start() {`