From 8c52a4b224a069d6066cb2c1e9a6af21f5353adb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C3=98yvind=20Stette=20Haarberg?= Date: Fri, 24 Jan 2025 13:47:16 +0100 Subject: [PATCH] EY-4849 send melding endring enhet (#6812) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * Oppsett for å sende melding til statistikk ved endring av enhet * Jobb for å sende meldinger på det som er under behandling Siden vi har en del oppgaver som er under behandling som potensielt har endret enheter må vi sende ut en melding for disse også * Setter opp kjøring av send meldinger jobb * Bump migreringsscript * Passer på at teknisk tid for oppdatert enhet er strengt stigende * Og en bump til * Korrigerer migreringsscript * Bump migreringsscript --- .../src/main/kotlin/Application.kt | 1 + .../behandling/BehandlingsHendelserService.kt | 37 ++++ ...SendMeldingOmOppgaverUnderBehandlingJob.kt | 159 ++++++++++++++++++ .../main/kotlin/config/ApplicationContext.kt | 18 ++ .../src/main/kotlin/oppgave/OppgaveService.kt | 13 ++ ...et_oppdatert_oppgaver_under_behandling.sql | 16 ++ .../statistikk/config/ApplicationContext.kt | 2 + .../river/BehandlingEndretEnhetRiver.kt | 59 +++++++ .../statistikk/service/StatistikkService.kt | 36 ++++ .../common/behandling/StatistikkBehandling.kt | 3 + 10 files changed, 344 insertions(+) create mode 100644 apps/etterlatte-behandling/src/main/kotlin/behandling/jobs/SendMeldingOmOppgaverUnderBehandlingJob.kt create mode 100644 apps/etterlatte-behandling/src/main/resources/db/migration/V216__send_enhet_oppdatert_oppgaver_under_behandling.sql create mode 100644 apps/etterlatte-statistikk/src/main/kotlin/statistikk/river/BehandlingEndretEnhetRiver.kt diff --git a/apps/etterlatte-behandling/src/main/kotlin/Application.kt b/apps/etterlatte-behandling/src/main/kotlin/Application.kt index 032a6d08e3e..63039935603 100644 --- a/apps/etterlatte-behandling/src/main/kotlin/Application.kt +++ b/apps/etterlatte-behandling/src/main/kotlin/Application.kt @@ -94,6 +94,7 @@ private fun timerJobs(context: ApplicationContext): List = context.doedsmeldingerJob, context.doedsmeldingerReminderJob, context.saksbehandlerJob, + context.sendMeldingOmOppgaverUnderBehandlingJob, ) @Deprecated("Denne blir brukt i veldig mange testar. Bør rydde opp, men tar det etter denne endringa er inne") diff --git a/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingsHendelserService.kt b/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingsHendelserService.kt index 9d8a0d43fd8..1bc8cb6671c 100644 --- a/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingsHendelserService.kt +++ b/apps/etterlatte-behandling/src/main/kotlin/behandling/BehandlingsHendelserService.kt @@ -2,13 +2,16 @@ package no.nav.etterlatte.behandling import no.nav.etterlatte.kafka.JsonMessage import no.nav.etterlatte.kafka.KafkaProdusent +import no.nav.etterlatte.libs.common.Enhetsnummer import no.nav.etterlatte.libs.common.aktivitetsplikt.AKTIVITETSPLIKT_DTO_RIVER_KEY import no.nav.etterlatte.libs.common.aktivitetsplikt.AktivitetspliktDto import no.nav.etterlatte.libs.common.aktivitetsplikt.AktivitetspliktHendelse import no.nav.etterlatte.libs.common.behandling.BEHANDLING_ID_PAA_VENT_RIVER_KEY import no.nav.etterlatte.libs.common.behandling.BehandlingHendelseType +import no.nav.etterlatte.libs.common.behandling.NY_ENHET_KEY import no.nav.etterlatte.libs.common.behandling.PAA_VENT_AARSAK_KEY import no.nav.etterlatte.libs.common.behandling.PaaVentAarsak +import no.nav.etterlatte.libs.common.behandling.REFERANSE_ENDRET_ENHET_KEY import no.nav.etterlatte.libs.common.behandling.STATISTIKKBEHANDLING_RIVER_KEY import no.nav.etterlatte.libs.common.behandling.StatistikkBehandling import no.nav.etterlatte.libs.common.logging.getCorrelationId @@ -26,6 +29,12 @@ interface BehandlingHendelserKafkaProducer { overstyrtTekniskTid: Tidspunkt? = null, ) + fun sendMeldingForEndretEnhet( + oppgaveReferanse: String, + enhet: Enhetsnummer, + overstyrtTekniskTid: Tidspunkt? = null, + ) + fun sendMeldingForHendelsePaaVent( behandlingId: UUID, hendelseType: BehandlingHendelseType, @@ -72,6 +81,34 @@ class BehandlingsHendelserKafkaProducerImpl( } } + override fun sendMeldingForEndretEnhet( + oppgaveReferanse: String, + enhet: Enhetsnummer, + overstyrtTekniskTid: Tidspunkt?, + ) { + val correlationId = getCorrelationId() + val hendelse = BehandlingHendelseType.ENDRET_ENHET + rapid + .publiser( + oppgaveReferanse, + JsonMessage + .newMessage( + hendelse.lagEventnameForType(), + mapOf( + CORRELATION_ID_KEY to correlationId, + TEKNISK_TID_KEY to (overstyrtTekniskTid ?: Tidspunkt.now()), + REFERANSE_ENDRET_ENHET_KEY to oppgaveReferanse, + NY_ENHET_KEY to enhet.enhetNr, + ), + ).toJson(), + ).also { (partition, offset) -> + logger.info( + "Postet hendelse ${hendelse.lagEventnameForType()} for oppgave med referanse " + + "$oppgaveReferanse til partisjon $partition, offset $offset correlationid: $correlationId", + ) + } + } + override fun sendMeldingForHendelsePaaVent( behandlingId: UUID, hendelseType: BehandlingHendelseType, diff --git a/apps/etterlatte-behandling/src/main/kotlin/behandling/jobs/SendMeldingOmOppgaverUnderBehandlingJob.kt b/apps/etterlatte-behandling/src/main/kotlin/behandling/jobs/SendMeldingOmOppgaverUnderBehandlingJob.kt new file mode 100644 index 00000000000..ae969fc7026 --- /dev/null +++ b/apps/etterlatte-behandling/src/main/kotlin/behandling/jobs/SendMeldingOmOppgaverUnderBehandlingJob.kt @@ -0,0 +1,159 @@ +package no.nav.etterlatte.behandling.jobs + +import no.nav.etterlatte.Context +import no.nav.etterlatte.Kontekst +import no.nav.etterlatte.Self +import no.nav.etterlatte.behandling.BehandlingHendelserKafkaProducer +import no.nav.etterlatte.behandling.hendelse.getUUID +import no.nav.etterlatte.common.ConnectionAutoclosing +import no.nav.etterlatte.common.DatabaseContext +import no.nav.etterlatte.inTransaction +import no.nav.etterlatte.jobs.LoggerInfo +import no.nav.etterlatte.jobs.fixedRateCancellableTimer +import no.nav.etterlatte.libs.common.Enhetsnummer +import no.nav.etterlatte.libs.common.TimerJob +import no.nav.etterlatte.libs.database.toList +import no.nav.etterlatte.libs.ktor.token.HardkodaSystembruker +import no.nav.etterlatte.oppgave.OppgaveDaoMedEndringssporing +import no.nav.etterlatte.sak.SakTilgangDao +import org.slf4j.Logger +import org.slf4j.LoggerFactory +import java.time.Duration +import java.util.Timer +import java.util.UUID +import javax.sql.DataSource + +class SendMeldingOmOppgaverUnderBehandlingJob( + private val erLeader: () -> Boolean, + private val sendEndretEnhet: SendEndretEnhet, + sakTilgangDao: SakTilgangDao, + dataSource: DataSource, +) : TimerJob { + private val jobbNavn = this::class.java.simpleName + private val logger: Logger = LoggerFactory.getLogger(SendMeldingOmOppgaverUnderBehandlingJob::class.java) + private val initialDelay = Duration.ofMinutes(3) + private val period = Duration.ofMinutes(1) + + private var jobContext: Context = + Context( + Self(SendMeldingOmOppgaverUnderBehandlingJob::class.java.simpleName), + DatabaseContext(dataSource), + sakTilgangDao, + HardkodaSystembruker.doedshendelse, + ) + + override fun schedule(): Timer { + logger.info("$jobbNavn er satt til å kjøre med oppstart=$initialDelay og periode $period") + + return fixedRateCancellableTimer( + name = jobbNavn, + initialDelay = initialDelay.toMillis(), + loggerInfo = LoggerInfo(logger = logger, loggTilSikkerLogg = false), + period = period.toMillis(), + ) { + if (erLeader()) { + sendEndretEnhet + .setupKontekstAndRun(jobContext) + } + } + } +} + +class SendEndretEnhet( + private val behandlingHendelserKafkaProducer: BehandlingHendelserKafkaProducer, + private val oppgaveEnhetEndretDao: OppgaveEnhetEndretDao, + private val oppgaveEndringerDao: OppgaveDaoMedEndringssporing, +) { + private val logger: Logger = LoggerFactory.getLogger(SendMeldingOmOppgaverUnderBehandlingJob::class.java) + + fun setupKontekstAndRun(jobContext: Context) { + Kontekst.set(jobContext) + sendMeldingForEnheter() + } + + private fun sendMeldingForEnheter() { + val oppgaverAaSendeMeldingFor = + try { + inTransaction { + oppgaveEnhetEndretDao.hentOppgaverUnderBehandlingManglerMelding() + } + } catch (e: Exception) { + logger.warn("Kunne ikke hente ut oppgaver under behandling med enhet", e) + return + } + oppgaverAaSendeMeldingFor.forEach { oppgaveOgEnhet -> + try { + inTransaction { + val endringerForOppgaveSistFoerst = + oppgaveEndringerDao.hentEndringerForOppgave(oppgaveOgEnhet.oppgaveId).sortedByDescending { + it.tidspunkt + } + val tidspunktForEndring = + endringerForOppgaveSistFoerst + .firstOrNull { it.oppgaveFoer.enhet != oppgaveOgEnhet.enhet } + ?.tidspunkt + behandlingHendelserKafkaProducer.sendMeldingForEndretEnhet( + oppgaveReferanse = oppgaveOgEnhet.referanse, + enhet = oppgaveOgEnhet.enhet, + overstyrtTekniskTid = tidspunktForEndring, + ) + oppgaveEnhetEndretDao.oppdaterSendtMelding(oppgaveOgEnhet.oppgaveId) + } + } catch (e: Exception) { + logger.warn( + "Kunne ikke sende endret enhet for oppgave med id=${oppgaveOgEnhet.oppgaveId}, " + + "referanse=${oppgaveOgEnhet.referanse}", + e, + ) + } + } + } +} + +data class OppgaveEndretEnhet( + val oppgaveId: UUID, + val referanse: String, + val enhet: Enhetsnummer, +) + +class OppgaveEnhetEndretDao( + private val connectionAutoclosing: ConnectionAutoclosing, +) { + private val logger: Logger = LoggerFactory.getLogger(OppgaveEnhetEndretDao::class.java) + + fun hentOppgaverUnderBehandlingManglerMelding(): List = + connectionAutoclosing.hentConnection { + val statement = + it.prepareStatement( + """ + SELECT oppgave_id, referanse, enhet from send_melding_om_enhet where not sendt limit 10 + """.trimIndent(), + ) + statement.executeQuery().toList { + val oppgaveId = getUUID("oppgave_id") + val referanse = getString("referanse") + val enhet = Enhetsnummer(getString("enhet")) + OppgaveEndretEnhet( + oppgaveId = oppgaveId, + referanse = referanse, + enhet = enhet, + ) + } + } + + fun oppdaterSendtMelding(oppgaveId: UUID) { + connectionAutoclosing.hentConnection { + val statement = + it.prepareStatement( + """ + UPDATE send_melding_om_enhet SET sendt = true where oppgave_id = ? + """.trimIndent(), + ) + statement.setObject(1, oppgaveId) + val updated = statement.executeUpdate() + if (updated != 1) { + logger.warn("Kunne ikke oppdatere sendt enhet for oppgave med id=$oppgaveId") + } + } + } +} diff --git a/apps/etterlatte-behandling/src/main/kotlin/config/ApplicationContext.kt b/apps/etterlatte-behandling/src/main/kotlin/config/ApplicationContext.kt index 6b2fdece0fe..4cc67eeb696 100644 --- a/apps/etterlatte-behandling/src/main/kotlin/config/ApplicationContext.kt +++ b/apps/etterlatte-behandling/src/main/kotlin/config/ApplicationContext.kt @@ -39,7 +39,10 @@ import no.nav.etterlatte.behandling.hendelse.HendelseDao import no.nav.etterlatte.behandling.job.SaksbehandlerJobService import no.nav.etterlatte.behandling.jobs.DoedsmeldingJob import no.nav.etterlatte.behandling.jobs.DoedsmeldingReminderJob +import no.nav.etterlatte.behandling.jobs.OppgaveEnhetEndretDao import no.nav.etterlatte.behandling.jobs.SaksbehandlerJob +import no.nav.etterlatte.behandling.jobs.SendEndretEnhet +import no.nav.etterlatte.behandling.jobs.SendMeldingOmOppgaverUnderBehandlingJob import no.nav.etterlatte.behandling.klage.KlageBrevService import no.nav.etterlatte.behandling.klage.KlageDaoImpl import no.nav.etterlatte.behandling.klage.KlageHendelserServiceImpl @@ -612,6 +615,21 @@ internal class ApplicationContext( behandlingService = behandlingService, ) + // Utsending av meldinger for enheter oppgaver under behandling + private val sendEndretEnhet = + SendEndretEnhet( + behandlingHendelserKafkaProducer = behandlingsHendelser, + oppgaveEnhetEndretDao = OppgaveEnhetEndretDao(connectionAutoclosing = autoClosingDatabase), + oppgaveEndringerDao = oppgaveDaoEndringer, + ) + val sendMeldingOmOppgaverUnderBehandlingJob: SendMeldingOmOppgaverUnderBehandlingJob = + SendMeldingOmOppgaverUnderBehandlingJob( + erLeader = { leaderElectionKlient.isLeader() }, + sendEndretEnhet = sendEndretEnhet, + sakTilgangDao = sakTilgangDao, + dataSource = dataSource, + ) + // Jobs val metrikkerJob: MetrikkerJob by lazy { MetrikkerJob( diff --git a/apps/etterlatte-behandling/src/main/kotlin/oppgave/OppgaveService.kt b/apps/etterlatte-behandling/src/main/kotlin/oppgave/OppgaveService.kt index af63362a711..051c5297273 100644 --- a/apps/etterlatte-behandling/src/main/kotlin/oppgave/OppgaveService.kt +++ b/apps/etterlatte-behandling/src/main/kotlin/oppgave/OppgaveService.kt @@ -485,6 +485,19 @@ class OppgaveService( oppgaverForSak.forEach { if (it.erUnderBehandling()) { oppgaveDao.endreStatusPaaOppgave(it.id, Status.NY) + + // For oppgaver som ikke er ferdige er det relevant for saksbehandlingsstatistikken + // å få en oppdatert rad med ny enhet + when (it.type) { + OppgaveType.FOERSTEGANGSBEHANDLING, + OppgaveType.REVURDERING, + OppgaveType.TILBAKEKREVING, + OppgaveType.KLAGE, + -> { + hendelser.sendMeldingForEndretEnhet(it.referanse, enhetsID) + } + else -> Unit + } } oppgaveDao.endreEnhetPaaOppgave(it.id, enhetsID) } diff --git a/apps/etterlatte-behandling/src/main/resources/db/migration/V216__send_enhet_oppdatert_oppgaver_under_behandling.sql b/apps/etterlatte-behandling/src/main/resources/db/migration/V216__send_enhet_oppdatert_oppgaver_under_behandling.sql new file mode 100644 index 00000000000..71c0f25aeea --- /dev/null +++ b/apps/etterlatte-behandling/src/main/resources/db/migration/V216__send_enhet_oppdatert_oppgaver_under_behandling.sql @@ -0,0 +1,16 @@ +create table send_melding_om_enhet +( + oppgave_id uuid, + referanse text, + enhet text, + sendt boolean default false +); + +-- Legger inn alle oppgaver knyttet til saksbehandlingsstatistikk-oppgaver som er under behandling +-- i listen over oppgaver som skal bli sendt på nytt +insert into send_melding_om_enhet (oppgave_id, referanse, enhet) +select o.id, o.referanse, s.enhet +from oppgave o + inner join public.sak s on o.sak_id = s.id +where o.type in ('KLAGE', 'TILBAKEKREVING', 'FOERSTEGANGSBEHANDLING', 'REVURDERING') + and o.status not in ('AVBRUTT', 'FERDIGSTILT'); diff --git a/apps/etterlatte-statistikk/src/main/kotlin/statistikk/config/ApplicationContext.kt b/apps/etterlatte-statistikk/src/main/kotlin/statistikk/config/ApplicationContext.kt index 85f6ed3ae79..310a62af3c4 100644 --- a/apps/etterlatte-statistikk/src/main/kotlin/statistikk/config/ApplicationContext.kt +++ b/apps/etterlatte-statistikk/src/main/kotlin/statistikk/config/ApplicationContext.kt @@ -23,6 +23,7 @@ import no.nav.etterlatte.statistikk.database.StoenadRepository import no.nav.etterlatte.statistikk.jobs.MaanedligStatistikkJob import no.nav.etterlatte.statistikk.river.AktivitetspliktHendelseRiver import no.nav.etterlatte.statistikk.river.AvbruttOpprettetBehandlinghendelseRiver +import no.nav.etterlatte.statistikk.river.BehandlingEndretEnhetRiver import no.nav.etterlatte.statistikk.river.BehandlingPaaVentHendelseRiver import no.nav.etterlatte.statistikk.river.KlagehendelseRiver import no.nav.etterlatte.statistikk.river.SoeknadStatistikkRiver @@ -52,6 +53,7 @@ class ApplicationContext { SoeknadStatistikkRiver(rapidsConnection, soeknadStatistikkService) KlagehendelseRiver(rapidsConnection, statistikkService) AktivitetspliktHendelseRiver(rapidsConnection, aktivitetspliktService) + BehandlingEndretEnhetRiver(rapidsConnection, statistikkService) } private val behandlingKlient: BehandlingKlient by lazy { diff --git a/apps/etterlatte-statistikk/src/main/kotlin/statistikk/river/BehandlingEndretEnhetRiver.kt b/apps/etterlatte-statistikk/src/main/kotlin/statistikk/river/BehandlingEndretEnhetRiver.kt new file mode 100644 index 00000000000..f7c616f3adf --- /dev/null +++ b/apps/etterlatte-statistikk/src/main/kotlin/statistikk/river/BehandlingEndretEnhetRiver.kt @@ -0,0 +1,59 @@ +package no.nav.etterlatte.statistikk.river + +import no.nav.etterlatte.libs.common.Enhetsnummer +import no.nav.etterlatte.libs.common.behandling.BehandlingHendelseType +import no.nav.etterlatte.libs.common.behandling.NY_ENHET_KEY +import no.nav.etterlatte.libs.common.behandling.REFERANSE_ENDRET_ENHET_KEY +import no.nav.etterlatte.libs.common.objectMapper +import no.nav.etterlatte.libs.common.rapidsandrivers.TEKNISK_TID_KEY +import no.nav.etterlatte.libs.common.rapidsandrivers.correlationId +import no.nav.etterlatte.libs.common.rapidsandrivers.lagParMedEventNameKey +import no.nav.etterlatte.libs.common.toJson +import no.nav.etterlatte.rapidsandrivers.ListenerMedLogging +import no.nav.etterlatte.statistikk.service.StatistikkService +import no.nav.helse.rapids_rivers.JsonMessage +import no.nav.helse.rapids_rivers.MessageContext +import no.nav.helse.rapids_rivers.RapidsConnection +import org.slf4j.LoggerFactory +import java.util.UUID + +class BehandlingEndretEnhetRiver( + rapidsConnection: RapidsConnection, + private val service: StatistikkService, +) : ListenerMedLogging() { + private val logger = LoggerFactory.getLogger(this::class.java) + + init { + initialiserRiver(rapidsConnection, BehandlingHendelseType.ENDRET_ENHET) { + validate { it.requireKey(TEKNISK_TID_KEY) } + validate { it.requireKey(REFERANSE_ENDRET_ENHET_KEY) } + validate { it.requireKey(NY_ENHET_KEY) } + } + } + + override fun haandterPakke( + packet: JsonMessage, + context: MessageContext, + ) = try { + val tekniskTid = parseTekniskTid(packet, logger) + val referanse = UUID.fromString(packet[REFERANSE_ENDRET_ENHET_KEY].textValue()) + val nyEnhet = Enhetsnummer(packet[NY_ENHET_KEY].textValue()) + + service + .registrerEndretEnhetForReferanse(referanse, nyEnhet, tekniskTid) + ?.also { + context.publish( + mapOf( + StatistikkhendelseType.REGISTRERT.lagParMedEventNameKey(), + "sak_rad" to objectMapper.writeValueAsString(it), + ).toJson(), + ) + } ?: logger.info("Ikke registrert statistikk på pakken ${packet.correlationId}") + } catch (e: Exception) { + logger.error( + """ + Kunne ikke mappe ut statistikk for endret enhet-hendelse i pakken med korrelasjonsId ${packet.correlationId} + """.trimIndent(), + ) + } +} diff --git a/apps/etterlatte-statistikk/src/main/kotlin/statistikk/service/StatistikkService.kt b/apps/etterlatte-statistikk/src/main/kotlin/statistikk/service/StatistikkService.kt index 4ac30b02285..2af15749ba7 100644 --- a/apps/etterlatte-statistikk/src/main/kotlin/statistikk/service/StatistikkService.kt +++ b/apps/etterlatte-statistikk/src/main/kotlin/statistikk/service/StatistikkService.kt @@ -2,6 +2,7 @@ package no.nav.etterlatte.statistikk.service import kotlinx.coroutines.runBlocking import no.nav.etterlatte.common.Enheter +import no.nav.etterlatte.libs.common.Enhetsnummer import no.nav.etterlatte.libs.common.Vedtaksloesning import no.nav.etterlatte.libs.common.behandling.BehandlingHendelseType import no.nav.etterlatte.libs.common.behandling.BehandlingStatus @@ -51,6 +52,7 @@ import org.slf4j.LoggerFactory import java.time.LocalDateTime import java.time.LocalTime import java.time.YearMonth +import java.time.temporal.ChronoUnit import java.util.UUID class StatistikkService( @@ -527,6 +529,40 @@ class StatistikkService( return sakRepository.lagreRad(behandlingTilSakRad(statistikkBehandling, hendelse, tekniskTid)) } + fun registrerEndretEnhetForReferanse( + referanse: UUID, + nyEnhet: Enhetsnummer, + tekniskTid: LocalDateTime, + ): SakRad? { + val sisteRadForReferanse = sakRepository.hentSisteRad(referanse) + if (sisteRadForReferanse == null) { + logger.warn("Fikk melding om behandling statistikk ikke kjenner til, med referanse $referanse") + return null + } + + return if (sisteRadForReferanse.ansvarligEnhet == nyEnhet) { + logger.info( + "Behandlingen med referanse $referanse har allerede enhet $nyEnhet på siste registrering. " + + "Oppdaterer ikke statistikken.", + ) + null + } else { + val tekniskTidForOppdatertEnhet = + if (sisteRadForReferanse.tekniskTid >= tekniskTid.toTidspunkt()) { + sisteRadForReferanse.tekniskTid.plus(1, ChronoUnit.SECONDS) + } else { + tekniskTid.toTidspunkt() + } + val nyRad = + sisteRadForReferanse.copy( + ansvarligEnhet = nyEnhet, + status = BehandlingHendelseType.ENDRET_ENHET.name, + tekniskTid = tekniskTidForOppdatertEnhet, + ) + return sakRepository.lagreRad(nyRad) + } + } + fun registrerStatistikkBehandlingPaaVentHendelse( behandlingId: UUID, hendelse: BehandlingHendelseType, diff --git a/libs/etterlatte-behandling-model/src/main/kotlin/no/nav/etterlatte/libs/common/behandling/StatistikkBehandling.kt b/libs/etterlatte-behandling-model/src/main/kotlin/no/nav/etterlatte/libs/common/behandling/StatistikkBehandling.kt index b99284c2213..1c5f65390a6 100644 --- a/libs/etterlatte-behandling-model/src/main/kotlin/no/nav/etterlatte/libs/common/behandling/StatistikkBehandling.kt +++ b/libs/etterlatte-behandling-model/src/main/kotlin/no/nav/etterlatte/libs/common/behandling/StatistikkBehandling.kt @@ -37,6 +37,7 @@ enum class BehandlingHendelseType : EventnameHendelseType { PAA_VENT, AV_VENT, AVBRUTT, + ENDRET_ENHET, ; override fun lagEventnameForType(): String = "BEHANDLING:${this.name}" @@ -44,6 +45,8 @@ enum class BehandlingHendelseType : EventnameHendelseType { const val STATISTIKKBEHANDLING_RIVER_KEY = "behandling" const val BEHANDLING_ID_PAA_VENT_RIVER_KEY = "behandling_vent" +const val REFERANSE_ENDRET_ENHET_KEY = "referanse_endret_enhet" +const val NY_ENHET_KEY = "ny_enhet" const val PAA_VENT_AARSAK_KEY = "paaVentAarsak" enum class PaaVentAarsak {