From 10757a957b5bdb4fa3b68c17b2e1766fe00a99a5 Mon Sep 17 00:00:00 2001
From: Ole Christian Kvernberg <42737566+olekvernberg@users.noreply.github.com>
Date: Tue, 9 Apr 2024 10:59:10 +0200
Subject: [PATCH] =?UTF-8?q?Sender=20melding=20til=20behandlingsstatistikk?=
=?UTF-8?q?=20for=20g-omregning.=20Rettet=20slik=20at=20det=20ikke=20allti?=
=?UTF-8?q?d=20sendes=20true=20som=20verdi=20p=C3=A5=20totrinn-feltet.=20(?=
=?UTF-8?q?#916)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
* Sender melding til behandlingsstatistikk for g-omregning. Rettet slik at det ikke alltid sendes true som verdi på totrinn-feltet.
* Ta i bruk ny versjon av kontrakter som inneholder ekstern id for relatert behandlingid.
---
pom.xml | 2 +-
.../BehandlingsstatistikkProducer.kt | 8 +-
.../BehandlingsstatistikkService.kt | 144 +++++++++++++-----
.../BehandlingsstatistikkTask.kt | 35 +++++
...SendBrukernotifikasjonVedGOmregningTask.kt | 11 ++
.../iverksett/infrastruktur/task/TaskFlyt.kt | 2 +
.../iverksetting/domene/IverksettData.kt | 1 +
...BrukernotifikasjonVedGOmregningTaskTest.kt | 4 +-
.../infrastruktur/task/TaskTypeTest.kt | 5 +
.../json/IverksettBarnetilsynDtoEksempel.json | 1 +
.../resources/json/IverksettDtoEksempel.json | 1 +
.../json/IverksettSkolepengerDtoEksempel.json | 1 +
12 files changed, 170 insertions(+), 45 deletions(-)
create mode 100644 src/main/kotlin/no/nav/familie/ef/iverksett/behandlingsstatistikk/BehandlingsstatistikkTask.kt
diff --git a/pom.xml b/pom.xml
index 3a1770134..d03b8c847 100644
--- a/pom.xml
+++ b/pom.xml
@@ -18,7 +18,7 @@
1.9.23
2.4.0
3.20240322152837_a01cd9d
- 3.0_20240326084609_597be6d
+ 3.0_20240405130633_ed41285
2.0_20230926133506_4e05190
2.0_20230214104704_706e9c0
2.0_20230214104704_706e9c0
diff --git a/src/main/kotlin/no/nav/familie/ef/iverksett/behandlingsstatistikk/BehandlingsstatistikkProducer.kt b/src/main/kotlin/no/nav/familie/ef/iverksett/behandlingsstatistikk/BehandlingsstatistikkProducer.kt
index ac1d67bd8..1b8cf09e3 100644
--- a/src/main/kotlin/no/nav/familie/ef/iverksett/behandlingsstatistikk/BehandlingsstatistikkProducer.kt
+++ b/src/main/kotlin/no/nav/familie/ef/iverksett/behandlingsstatistikk/BehandlingsstatistikkProducer.kt
@@ -16,18 +16,16 @@ class BehandlingsstatistikkProducer(private val kafkaProducerService: KafkaProdu
private val secureLogger = LoggerFactory.getLogger("secureLogger")
fun sendBehandling(behandlingDvh: BehandlingDVH) {
- logger.info("Sending to Kafka topic: {}", topic)
- secureLogger.debug("Sending to Kafka topic: {}\nBehandlingstatistikk: {}", topic, behandlingDvh)
runCatching {
kafkaProducerService.send(topic, behandlingDvh.behandlingId.toString(), behandlingDvh.toJson())
logger.info(
"Behandlingstatistikk for behandling=${behandlingDvh.behandlingId} " +
- "behandlingStatus=${behandlingDvh.behandlingStatus} sent til Kafka",
+ "behandlingStatus=${behandlingDvh.behandlingStatus} sendt til Kafka",
)
}.onFailure {
- val errorMessage = "Could not send behandling to Kafka. Check secure logs for more information."
+ val errorMessage = "Kunne ikke sende behandlingsstatistikk til topic: $topic. Se securelogs for mer info."
logger.error(errorMessage)
- secureLogger.error("Could not send behandling to Kafka", it)
+ secureLogger.error("Kunne ikke sende behandlingsstatistikk til topic: $topic", it)
throw RuntimeException(errorMessage)
}
}
diff --git a/src/main/kotlin/no/nav/familie/ef/iverksett/behandlingsstatistikk/BehandlingsstatistikkService.kt b/src/main/kotlin/no/nav/familie/ef/iverksett/behandlingsstatistikk/BehandlingsstatistikkService.kt
index a1f38e81e..bd9aff665 100644
--- a/src/main/kotlin/no/nav/familie/ef/iverksett/behandlingsstatistikk/BehandlingsstatistikkService.kt
+++ b/src/main/kotlin/no/nav/familie/ef/iverksett/behandlingsstatistikk/BehandlingsstatistikkService.kt
@@ -1,7 +1,11 @@
package no.nav.familie.ef.iverksett.behandlingsstatistikk
+import no.nav.familie.ef.iverksett.iverksetting.domene.IverksettOvergangsstønad
+import no.nav.familie.eksterne.kontrakter.ef.BehandlingÅrsak
import no.nav.familie.eksterne.kontrakter.saksstatistikk.ef.BehandlingDVH
+import no.nav.familie.kontrakter.ef.iverksett.AdressebeskyttelseGradering
import no.nav.familie.kontrakter.ef.iverksett.BehandlingKategori
+import no.nav.familie.kontrakter.ef.iverksett.BehandlingMetode
import no.nav.familie.kontrakter.ef.iverksett.BehandlingsstatistikkDto
import no.nav.familie.kontrakter.ef.iverksett.Hendelse
import org.springframework.stereotype.Service
@@ -17,75 +21,133 @@ class BehandlingsstatistikkService(private val behandlingsstatistikkProducer: Be
behandlingsstatistikkProducer.sendBehandling(behandlingDVH)
}
- private fun mapTilBehandlingDVH(behandlingstatistikk: BehandlingsstatistikkDto): BehandlingDVH {
+ fun mapGOmregningIverksettingTilBehandlingDVH(iverksett: IverksettOvergangsstønad): BehandlingDVH {
+ val zoneId = ZoneId.of("Europe/Oslo")
+ val tekniskTid = ZonedDateTime.now(zoneId)
+ return BehandlingDVH(
+ behandlingId = iverksett.behandling.eksternId,
+ sakId = iverksett.fagsak.eksternId,
+ personIdent = iverksett.søker.personIdent,
+ registrertTid = iverksett.vedtak.vedtakstidspunkt.atZone(zoneId),
+ endretTid = iverksett.vedtak.vedtakstidspunkt.atZone(zoneId),
+ tekniskTid = tekniskTid,
+ behandlingStatus = Hendelse.FERDIG.name,
+ opprettetAv =
+ maskerVerdiHvisStrengtFortrolig(
+ iverksett.søker.adressebeskyttelse.erStrengtFortrolig(),
+ iverksett.vedtak.saksbehandlerId,
+ ),
+ saksnummer = iverksett.fagsak.eksternId,
+ mottattTid = iverksett.vedtak.vedtakstidspunkt.atZone(zoneId),
+ saksbehandler =
+ maskerVerdiHvisStrengtFortrolig(
+ iverksett.søker.adressebeskyttelse.erStrengtFortrolig(),
+ iverksett.vedtak.saksbehandlerId,
+ ),
+ opprettetEnhet =
+ maskerVerdiHvisStrengtFortrolig(
+ iverksett.søker.adressebeskyttelse.erStrengtFortrolig(),
+ MASKINELL_JOURNALFOERENDE_ENHET,
+ ),
+ ansvarligEnhet =
+ maskerVerdiHvisStrengtFortrolig(
+ iverksett.søker.adressebeskyttelse.erStrengtFortrolig(),
+ MASKINELL_JOURNALFOERENDE_ENHET,
+ ),
+ behandlingMetode = BehandlingMetode.BATCH.name,
+ behandlingÅrsak = iverksett.behandling.behandlingÅrsak.name,
+ avsender = "NAV enslig forelder",
+ behandlingType = iverksett.behandling.behandlingType.name,
+ sakYtelse = iverksett.fagsak.stønadstype.name,
+ behandlingResultat = iverksett.vedtak.vedtaksresultat.name,
+ resultatBegrunnelse = "G-omregning",
+ ansvarligBeslutter = null,
+ vedtakTid = iverksett.vedtak.vedtakstidspunkt.atZone(zoneId),
+ ferdigBehandletTid = iverksett.vedtak.vedtakstidspunkt.atZone(zoneId),
+ totrinnsbehandling = false,
+ sakUtland = mapTilStreng(iverksett.behandling.kategori),
+ relatertBehandlingId = iverksett.behandling.forrigeBehandlingEksternId,
+ kravMottatt = null,
+ revurderingÅrsak = BehandlingÅrsak.G_OMREGNING.name,
+ revurderingOpplysningskilde = null,
+ avslagAarsak = null,
+ )
+ }
+
+ private fun mapTilBehandlingDVH(behandlingsstatistikkDto: BehandlingsstatistikkDto): BehandlingDVH {
val tekniskTid = ZonedDateTime.now(ZoneId.of("Europe/Oslo"))
return BehandlingDVH(
- behandlingId = behandlingstatistikk.eksternBehandlingId,
- sakId = behandlingstatistikk.eksternFagsakId,
- personIdent = behandlingstatistikk.personIdent,
+ behandlingId = behandlingsstatistikkDto.eksternBehandlingId,
+ sakId = behandlingsstatistikkDto.eksternFagsakId,
+ personIdent = behandlingsstatistikkDto.personIdent,
registrertTid =
- behandlingstatistikk.behandlingOpprettetTidspunkt
- ?: behandlingstatistikk.hendelseTidspunkt,
- endretTid = behandlingstatistikk.hendelseTidspunkt,
+ behandlingsstatistikkDto.behandlingOpprettetTidspunkt
+ ?: behandlingsstatistikkDto.hendelseTidspunkt,
+ endretTid = behandlingsstatistikkDto.hendelseTidspunkt,
tekniskTid = tekniskTid,
- behandlingStatus = behandlingstatistikk.hendelse.name,
+ behandlingStatus = behandlingsstatistikkDto.hendelse.name,
opprettetAv =
maskerVerdiHvisStrengtFortrolig(
- behandlingstatistikk.strengtFortroligAdresse,
- behandlingstatistikk.gjeldendeSaksbehandlerId,
+ behandlingsstatistikkDto.strengtFortroligAdresse,
+ behandlingsstatistikkDto.gjeldendeSaksbehandlerId,
),
- saksnummer = behandlingstatistikk.eksternFagsakId,
- mottattTid = behandlingstatistikk.henvendelseTidspunkt,
+ saksnummer = behandlingsstatistikkDto.eksternFagsakId,
+ mottattTid = behandlingsstatistikkDto.henvendelseTidspunkt,
saksbehandler =
maskerVerdiHvisStrengtFortrolig(
- behandlingstatistikk.strengtFortroligAdresse,
- behandlingstatistikk.gjeldendeSaksbehandlerId,
+ behandlingsstatistikkDto.strengtFortroligAdresse,
+ behandlingsstatistikkDto.gjeldendeSaksbehandlerId,
),
opprettetEnhet =
maskerVerdiHvisStrengtFortrolig(
- behandlingstatistikk.strengtFortroligAdresse,
- behandlingstatistikk.opprettetEnhet,
+ behandlingsstatistikkDto.strengtFortroligAdresse,
+ behandlingsstatistikkDto.opprettetEnhet,
),
ansvarligEnhet =
maskerVerdiHvisStrengtFortrolig(
- behandlingstatistikk.strengtFortroligAdresse,
- behandlingstatistikk.ansvarligEnhet,
+ behandlingsstatistikkDto.strengtFortroligAdresse,
+ behandlingsstatistikkDto.ansvarligEnhet,
),
- behandlingMetode = behandlingstatistikk.behandlingMetode?.name ?: "MANUELL",
- behandlingÅrsak = behandlingstatistikk.behandlingÅrsak?.name,
+ behandlingMetode = behandlingsstatistikkDto.behandlingMetode?.name ?: "MANUELL",
+ behandlingÅrsak = behandlingsstatistikkDto.behandlingÅrsak.name,
avsender = "NAV enslig forelder",
- behandlingType = behandlingstatistikk.behandlingstype.name,
- sakYtelse = behandlingstatistikk.stønadstype.name,
- behandlingResultat = behandlingstatistikk.behandlingResultat,
- resultatBegrunnelse = behandlingstatistikk.resultatBegrunnelse,
+ behandlingType = behandlingsstatistikkDto.behandlingstype.name,
+ sakYtelse = behandlingsstatistikkDto.stønadstype.name,
+ behandlingResultat = behandlingsstatistikkDto.behandlingResultat,
+ resultatBegrunnelse = behandlingsstatistikkDto.resultatBegrunnelse,
ansvarligBeslutter =
- if (Hendelse.BESLUTTET == behandlingstatistikk.hendelse && behandlingstatistikk.beslutterId.isNotNullOrEmpty()) {
+ if (Hendelse.BESLUTTET == behandlingsstatistikkDto.hendelse && behandlingsstatistikkDto.beslutterId.isNotNullOrEmpty()) {
maskerVerdiHvisStrengtFortrolig(
- behandlingstatistikk.strengtFortroligAdresse,
- behandlingstatistikk.beslutterId.toString(),
+ behandlingsstatistikkDto.strengtFortroligAdresse,
+ behandlingsstatistikkDto.beslutterId.toString(),
)
} else {
null
},
vedtakTid =
- if (Hendelse.VEDTATT == behandlingstatistikk.hendelse) {
- behandlingstatistikk.hendelseTidspunkt
+ if (Hendelse.VEDTATT == behandlingsstatistikkDto.hendelse) {
+ behandlingsstatistikkDto.hendelseTidspunkt
} else {
null
},
ferdigBehandletTid =
- if (Hendelse.FERDIG == behandlingstatistikk.hendelse) {
- behandlingstatistikk.hendelseTidspunkt
+ if (Hendelse.FERDIG == behandlingsstatistikkDto.hendelse) {
+ behandlingsstatistikkDto.hendelseTidspunkt
} else {
null
},
- totrinnsbehandling = true,
- sakUtland = mapTilStreng(behandlingstatistikk.kategori),
- relatertBehandlingId = behandlingstatistikk.relatertEksternBehandlingId,
- kravMottatt = behandlingstatistikk.kravMottatt,
- revurderingÅrsak = behandlingstatistikk.årsakRevurdering?.årsak?.name,
- revurderingOpplysningskilde = behandlingstatistikk.årsakRevurdering?.opplysningskilde?.name,
- avslagAarsak = behandlingstatistikk.avslagÅrsak?.name,
+ totrinnsbehandling =
+ if (Hendelse.BESLUTTET == behandlingsstatistikkDto.hendelse) {
+ true
+ } else {
+ false
+ },
+ sakUtland = mapTilStreng(behandlingsstatistikkDto.kategori),
+ relatertBehandlingId = behandlingsstatistikkDto.relatertEksternBehandlingId,
+ kravMottatt = behandlingsstatistikkDto.kravMottatt,
+ revurderingÅrsak = behandlingsstatistikkDto.årsakRevurdering?.årsak?.name,
+ revurderingOpplysningskilde = behandlingsstatistikkDto.årsakRevurdering?.opplysningskilde?.name,
+ avslagAarsak = behandlingsstatistikkDto.avslagÅrsak?.name,
)
}
@@ -107,4 +169,10 @@ class BehandlingsstatistikkService(private val behandlingsstatistikkProducer: Be
BehandlingKategori.NASJONAL -> "Nasjonal"
null -> "Nasjonal"
}
+
+ companion object {
+ const val MASKINELL_JOURNALFOERENDE_ENHET = "9999"
+ }
}
+
+fun AdressebeskyttelseGradering?.erStrengtFortrolig() = this == AdressebeskyttelseGradering.STRENGT_FORTROLIG || this == AdressebeskyttelseGradering.STRENGT_FORTROLIG_UTLAND
diff --git a/src/main/kotlin/no/nav/familie/ef/iverksett/behandlingsstatistikk/BehandlingsstatistikkTask.kt b/src/main/kotlin/no/nav/familie/ef/iverksett/behandlingsstatistikk/BehandlingsstatistikkTask.kt
new file mode 100644
index 000000000..adee02c03
--- /dev/null
+++ b/src/main/kotlin/no/nav/familie/ef/iverksett/behandlingsstatistikk/BehandlingsstatistikkTask.kt
@@ -0,0 +1,35 @@
+package no.nav.familie.ef.iverksett.behandlingsstatistikk
+
+import no.nav.familie.ef.iverksett.featuretoggle.FeatureToggleService
+import no.nav.familie.ef.iverksett.iverksetting.IverksettingRepository
+import no.nav.familie.ef.iverksett.iverksetting.domene.IverksettOvergangsstønad
+import no.nav.familie.ef.iverksett.repository.findByIdOrThrow
+import no.nav.familie.prosessering.AsyncTaskStep
+import no.nav.familie.prosessering.TaskStepBeskrivelse
+import no.nav.familie.prosessering.domene.Task
+import org.springframework.stereotype.Service
+import java.util.UUID
+
+@Service
+@TaskStepBeskrivelse(
+ taskStepType = BehandlingsstatistikkTask.TYPE,
+ beskrivelse = "Sender melding til behandlingsstatistikk om at behandling er G-omregnet",
+ settTilManuellOppfølgning = true,
+)
+class BehandlingsstatistikkTask(
+ val behandlingsstatistikkService: BehandlingsstatistikkService,
+ val behandlingsstatistikkProducer: BehandlingsstatistikkProducer,
+ val iverksettingRepository: IverksettingRepository,
+ val featureToggleService: FeatureToggleService,
+) : AsyncTaskStep {
+ override fun doTask(task: Task) {
+ val behandlingId = UUID.fromString(task.payload)
+ val iverksett = iverksettingRepository.findByIdOrThrow(behandlingId).data as IverksettOvergangsstønad
+ val behandlingDVH = behandlingsstatistikkService.mapGOmregningIverksettingTilBehandlingDVH(iverksett)
+ behandlingsstatistikkProducer.sendBehandling(behandlingDVH)
+ }
+
+ companion object {
+ const val TYPE = "BehandlingsstatistikkTask"
+ }
+}
diff --git a/src/main/kotlin/no/nav/familie/ef/iverksett/brukernotifikasjon/SendBrukernotifikasjonVedGOmregningTask.kt b/src/main/kotlin/no/nav/familie/ef/iverksett/brukernotifikasjon/SendBrukernotifikasjonVedGOmregningTask.kt
index e5dd7496c..f1acba827 100644
--- a/src/main/kotlin/no/nav/familie/ef/iverksett/brukernotifikasjon/SendBrukernotifikasjonVedGOmregningTask.kt
+++ b/src/main/kotlin/no/nav/familie/ef/iverksett/brukernotifikasjon/SendBrukernotifikasjonVedGOmregningTask.kt
@@ -1,12 +1,14 @@
package no.nav.familie.ef.iverksett.brukernotifikasjon
import no.nav.familie.ef.iverksett.featuretoggle.FeatureToggleService
+import no.nav.familie.ef.iverksett.infrastruktur.task.opprettNestePubliseringTask
import no.nav.familie.ef.iverksett.iverksetting.IverksettingRepository
import no.nav.familie.ef.iverksett.iverksetting.domene.IverksettOvergangsstønad
import no.nav.familie.ef.iverksett.repository.findByIdOrThrow
import no.nav.familie.prosessering.AsyncTaskStep
import no.nav.familie.prosessering.TaskStepBeskrivelse
import no.nav.familie.prosessering.domene.Task
+import no.nav.familie.prosessering.internal.TaskService
import org.springframework.stereotype.Service
import java.util.UUID
@@ -20,6 +22,7 @@ class SendBrukernotifikasjonVedGOmregningTask(
val brukernotifikasjonKafkaProducer: BrukernotifikasjonKafkaProducer,
val iverksettingRepository: IverksettingRepository,
val featureToggleService: FeatureToggleService,
+ val taskService: TaskService,
) : AsyncTaskStep {
override fun doTask(task: Task) {
val behandlingId = UUID.fromString(task.payload)
@@ -32,6 +35,14 @@ class SendBrukernotifikasjonVedGOmregningTask(
}
}
+ override fun onCompletion(task: Task) {
+ val behandlingId = UUID.fromString(task.payload)
+ val iverksett = iverksettingRepository.findByIdOrThrow(behandlingId).data
+ if (iverksett.erGOmregning() && featureToggleService.isEnabled("familie.ef.sak.g-beregning-scheduler")) {
+ taskService.save(task.opprettNestePubliseringTask())
+ }
+ }
+
companion object {
const val TYPE = "sendBrukernotifikasjonVedGOmregningTask"
}
diff --git a/src/main/kotlin/no/nav/familie/ef/iverksett/infrastruktur/task/TaskFlyt.kt b/src/main/kotlin/no/nav/familie/ef/iverksett/infrastruktur/task/TaskFlyt.kt
index 813325e30..38068d898 100644
--- a/src/main/kotlin/no/nav/familie/ef/iverksett/infrastruktur/task/TaskFlyt.kt
+++ b/src/main/kotlin/no/nav/familie/ef/iverksett/infrastruktur/task/TaskFlyt.kt
@@ -2,6 +2,7 @@ package no.nav.familie.ef.iverksett.infrastruktur.task
import no.nav.familie.ef.iverksett.arbeidsoppfolging.SendVedtakTilArbeidsoppfølgingTask
import no.nav.familie.ef.iverksett.arena.SendFattetVedtakTilArenaTask
+import no.nav.familie.ef.iverksett.behandlingsstatistikk.BehandlingsstatistikkTask
import no.nav.familie.ef.iverksett.brev.DistribuerVedtaksbrevTask
import no.nav.familie.ef.iverksett.brev.JournalførVedtaksbrevTask
import no.nav.familie.ef.iverksett.brukernotifikasjon.SendBrukernotifikasjonVedGOmregningTask
@@ -42,6 +43,7 @@ fun publiseringsflyt() =
TaskType(OpprettFremleggsoppgaveForOvergangsstønadTask.TYPE),
TaskType(VedtakstatistikkTask.TYPE),
TaskType(SendBrukernotifikasjonVedGOmregningTask.TYPE),
+ TaskType(BehandlingsstatistikkTask.TYPE),
)
fun TaskType.nesteHovedflytTask() = hovedflyt().zipWithNext().first { this.type == it.first.type }.second
diff --git a/src/main/kotlin/no/nav/familie/ef/iverksett/iverksetting/domene/IverksettData.kt b/src/main/kotlin/no/nav/familie/ef/iverksett/iverksetting/domene/IverksettData.kt
index 74c36e400..a123fb87b 100644
--- a/src/main/kotlin/no/nav/familie/ef/iverksett/iverksetting/domene/IverksettData.kt
+++ b/src/main/kotlin/no/nav/familie/ef/iverksett/iverksetting/domene/IverksettData.kt
@@ -230,6 +230,7 @@ data class Behandlingsdetaljer(
val behandlingType: BehandlingType,
val behandlingÅrsak: BehandlingÅrsak,
val relatertBehandlingId: UUID? = null,
+ val forrigeBehandlingEksternId: Long? = null,
val vilkårsvurderinger: List = emptyList(),
val aktivitetspliktInntrefferDato: LocalDate? = null,
val kravMottatt: LocalDate? = null,
diff --git a/src/test/kotlin/no/nav/familie/ef/iverksett/brukernotifikasjon/SendBrukernotifikasjonVedGOmregningTaskTest.kt b/src/test/kotlin/no/nav/familie/ef/iverksett/brukernotifikasjon/SendBrukernotifikasjonVedGOmregningTaskTest.kt
index 544ce7ea7..117043fe3 100644
--- a/src/test/kotlin/no/nav/familie/ef/iverksett/brukernotifikasjon/SendBrukernotifikasjonVedGOmregningTaskTest.kt
+++ b/src/test/kotlin/no/nav/familie/ef/iverksett/brukernotifikasjon/SendBrukernotifikasjonVedGOmregningTaskTest.kt
@@ -13,6 +13,7 @@ import no.nav.familie.ef.iverksett.util.mockFeatureToggleService
import no.nav.familie.ef.iverksett.util.opprettIverksettDto
import no.nav.familie.kontrakter.ef.felles.BehandlingÅrsak
import no.nav.familie.prosessering.domene.Task
+import no.nav.familie.prosessering.internal.TaskService
import org.junit.jupiter.api.BeforeEach
import org.junit.jupiter.api.Test
import java.util.UUID
@@ -20,8 +21,9 @@ import java.util.UUID
class SendBrukernotifikasjonVedGOmregningTaskTest {
private val iverksettingRepository = mockk()
private val brukernotifikasjonKafkaProducer = mockk()
+ private val taskService = mockk()
private val task =
- SendBrukernotifikasjonVedGOmregningTask(brukernotifikasjonKafkaProducer, iverksettingRepository, mockFeatureToggleService())
+ SendBrukernotifikasjonVedGOmregningTask(brukernotifikasjonKafkaProducer, iverksettingRepository, mockFeatureToggleService(), taskService)
@BeforeEach
internal fun setUp() {
diff --git a/src/test/kotlin/no/nav/familie/ef/iverksett/infrastruktur/task/TaskTypeTest.kt b/src/test/kotlin/no/nav/familie/ef/iverksett/infrastruktur/task/TaskTypeTest.kt
index 41c4381ec..1bb967dfd 100644
--- a/src/test/kotlin/no/nav/familie/ef/iverksett/infrastruktur/task/TaskTypeTest.kt
+++ b/src/test/kotlin/no/nav/familie/ef/iverksett/infrastruktur/task/TaskTypeTest.kt
@@ -2,6 +2,7 @@ package no.nav.familie.ef.iverksett.infrastruktur.task
import no.nav.familie.ef.iverksett.arbeidsoppfolging.SendVedtakTilArbeidsoppfølgingTask
import no.nav.familie.ef.iverksett.arena.SendFattetVedtakTilArenaTask
+import no.nav.familie.ef.iverksett.behandlingsstatistikk.BehandlingsstatistikkTask
import no.nav.familie.ef.iverksett.brev.DistribuerVedtaksbrevTask
import no.nav.familie.ef.iverksett.brev.JournalførVedtaksbrevTask
import no.nav.familie.ef.iverksett.brukernotifikasjon.SendBrukernotifikasjonVedGOmregningTask
@@ -80,6 +81,10 @@ class TaskTypeTest {
val sendBrukernotifikasjonVedGOmregningTask = vedtaksstatistikkTask.opprettNestePubliseringTask()
assertThat(sendBrukernotifikasjonVedGOmregningTask.type).isEqualTo(SendBrukernotifikasjonVedGOmregningTask.TYPE)
assertThat(sendBrukernotifikasjonVedGOmregningTask.triggerTid).isBefore(LocalDateTime.now().plusMinutes(1))
+
+ val behandlingsstatistikkTask = sendBrukernotifikasjonVedGOmregningTask.opprettNestePubliseringTask()
+ assertThat(behandlingsstatistikkTask.type).isEqualTo(BehandlingsstatistikkTask.TYPE)
+ assertThat(behandlingsstatistikkTask.triggerTid).isBefore(LocalDateTime.now().plusMinutes(1))
}
@Test
diff --git a/src/test/resources/json/IverksettBarnetilsynDtoEksempel.json b/src/test/resources/json/IverksettBarnetilsynDtoEksempel.json
index 8c9945f0d..18644dbe8 100644
--- a/src/test/resources/json/IverksettBarnetilsynDtoEksempel.json
+++ b/src/test/resources/json/IverksettBarnetilsynDtoEksempel.json
@@ -7,6 +7,7 @@
"behandling": {
"behandlingId": "234bed7c-b1d3-11eb-8529-0242ac130003",
"forrigeBehandlingId": "999abcde-fabc-11eb-8529-0242ac130003",
+ "forrigeBehandlingEksternId": 11,
"eksternId": 14,
"behandlingType": "FØRSTEGANGSBEHANDLING",
"behandlingÅrsak": "NYE_OPPLYSNINGER",
diff --git a/src/test/resources/json/IverksettDtoEksempel.json b/src/test/resources/json/IverksettDtoEksempel.json
index d94769d52..adbdaf477 100644
--- a/src/test/resources/json/IverksettDtoEksempel.json
+++ b/src/test/resources/json/IverksettDtoEksempel.json
@@ -7,6 +7,7 @@
"behandling": {
"behandlingId": "234bed7c-b1d3-11eb-8529-0242ac130003",
"forrigeBehandlingId": "999abcde-fabc-11eb-8529-0242ac130003",
+ "forrigeBehandlingEksternId": 11,
"eksternId": 14,
"behandlingType": "FØRSTEGANGSBEHANDLING",
"behandlingÅrsak": "NYE_OPPLYSNINGER",
diff --git a/src/test/resources/json/IverksettSkolepengerDtoEksempel.json b/src/test/resources/json/IverksettSkolepengerDtoEksempel.json
index 6a501165d..cc6ccaa50 100644
--- a/src/test/resources/json/IverksettSkolepengerDtoEksempel.json
+++ b/src/test/resources/json/IverksettSkolepengerDtoEksempel.json
@@ -7,6 +7,7 @@
"behandling": {
"behandlingId": "234bed7c-b1d3-11eb-8529-0242ac130003",
"forrigeBehandlingId": "999abcde-fabc-11eb-8529-0242ac130003",
+ "forrigeBehandlingEksternId": 11,
"eksternId": 14,
"behandlingType": "FØRSTEGANGSBEHANDLING",
"behandlingÅrsak": "NYE_OPPLYSNINGER",