wip

Author: luantr

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,
 }

src/main/kotlin/no/nav/syfo/brev/narmesteleder/NarmesteLederBrevApi.kt

@@ -177,6 +177,11 @@ fun Route.registerNarmestelederBrevApi(
                         svarTekst = responsDTO.svarTekst,
                     )
                     if (updated) {
+                        dialogmoteService.publishNarmesteLederSvarMelding(
+                            brev = brev,
+                            responsDTO = responsDTO,
+                            narmesteLederPersonIdent = narmesteLederPersonIdent,
+                        )
                         call.respond(HttpStatusCode.OK)
                     } else {
                         throw IllegalArgumentException("Response already stored")

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

src/main/kotlin/no/nav/syfo/dialogmote/DialogmoteService.kt

@@ -3,6 +3,11 @@ 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.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.domain.NarmesteLederResponsDTO
 import no.nav.syfo.client.behandlendeenhet.BehandlendeEnhetClient
 import no.nav.syfo.client.narmesteleder.NarmesteLederClient
 import no.nav.syfo.client.narmesteleder.NarmesteLederRelasjonDTO
@@ -17,6 +22,8 @@ import no.nav.syfo.dialogmote.domain.*
 import no.nav.syfo.domain.EnhetNr
 import no.nav.syfo.domain.PersonIdent
 import no.nav.syfo.domain.Virksomhetsnummer
+import org.slf4j.Logger
+import org.slf4j.LoggerFactory
 import java.sql.Connection
 import java.time.LocalDateTime
 import java.util.*
@@ -843,4 +850,31 @@ class DialogmoteService(
             callId = callId,
         )
     }
+
+    fun publishNarmesteLederSvarMelding(
+        brev: NarmesteLederBrev,
+        responsDTO: NarmesteLederResponsDTO,
+        narmesteLederPersonIdent: PersonIdent,
+    ) {
+        val dialogmoteDeltagerArbeidsgiver = dialogmotedeltakerService.getDialogmoteDeltakerArbeidsgiverById(
+            motedeltakerArbeidsgiverId = brev.motedeltakerArbeidsgiverId,
+        )
+        val arbeidstakerPersonIdent = dialogmotedeltakerService.getDialogmoteDeltakerArbeidstaker(
+            moteId = dialogmoteDeltagerArbeidsgiver.moteId,
+        ).personIdent.value
+
+        varselService.sendNarmesteLederEsyfovarselMelding(
+            NarmesteLederHendelse(
+                type = HendelseType.NL_DIALOGMOTE_SVAR,
+                data = VarselData(
+                    dialogmoteSvar = VarselDataDialogmoteSvar(
+                        svar = DialogmoteSvarType.valueOf(responsDTO.svarType),
+                    )
+                ),
+                narmesteLederFnr = narmesteLederPersonIdent.value,
+                arbeidstakerFnr = arbeidstakerPersonIdent,
+                orgnummer = dialogmoteDeltagerArbeidsgiver.virksomhetsnummer.value,
+            )
+        )
+    }
 }

src/main/kotlin/no/nav/syfo/dialogmote/VarselService.kt

@@ -3,6 +3,7 @@ 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.NarmesteLederHendelse
 import no.nav.syfo.brev.narmesteleder.NarmesteLederVarselService
 import no.nav.syfo.client.altinn.AltinnClient
 import no.nav.syfo.client.altinn.createAltinnMelding
@@ -106,4 +107,9 @@ class VarselService(
             }
         }
     }
+    fun sendNarmesteLederEsyfovarselMelding(
+        hendelse: NarmesteLederHendelse
+    ) {
+        narmesteLederVarselService.sendMelding(hendelse)
+    }
 }