Skip to content
This repository has been archived by the owner on Nov 5, 2024. It is now read-only.

Commit

Permalink
r All funksjonalitet for publisering av periode avsluttet-hendelse sk…
Browse files Browse the repository at this point in the history
…al skje i observer-klassen.

Fjerner også metrikker for sammenligning av meldekort-data med avslutning da ingen bruker disse metrikkene lenger
  • Loading branch information
marenger committed Feb 22, 2023
1 parent 1c3bd07 commit 2bf07ab
Show file tree
Hide file tree
Showing 7 changed files with 3 additions and 390 deletions.
Original file line number Diff line number Diff line change
@@ -1,11 +1,8 @@
package no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe

import no.nav.common.featuretoggle.UnleashClient
import no.nav.fo.veilarbregistrering.aktorIdCache.AktorIdCacheService
import no.nav.fo.veilarbregistrering.arbeidssoker.Arbeidssoker
import no.nav.fo.veilarbregistrering.arbeidssoker.perioder.ArbeidssokerperiodeAvsluttetProducer
import no.nav.fo.veilarbregistrering.arbeidssoker.perioder.ArbeidssokerperiodeAvsluttetService
import no.nav.fo.veilarbregistrering.arbeidssoker.perioder.Arbeidssokerperioder
import no.nav.fo.veilarbregistrering.arbeidssoker.perioder.PopulerArbeidssokerperioderService
import no.nav.fo.veilarbregistrering.bruker.Foedselsnummer
import no.nav.fo.veilarbregistrering.log.logger
Expand All @@ -16,7 +13,6 @@ import java.time.LocalDateTime
@Service
class FormidlingsgruppeMottakService(
private val formidlingsgruppeRepository: FormidlingsgruppeRepository,
private val arbeidssokerperiodeAvsluttetService: ArbeidssokerperiodeAvsluttetService,
private val aktorIdCacheService: AktorIdCacheService,
private val populerArbeidssokerperioderService: PopulerArbeidssokerperioderService,
private val arbeidssokerperiodeAvsluttetProducer: ArbeidssokerperiodeAvsluttetProducer
Expand All @@ -42,9 +38,7 @@ class FormidlingsgruppeMottakService(
return
}

val eksisterendeArbeidssokerperioderLokalt = hentArbeidssøkerperioder(formidlingsgruppeEndretEvent)
val arbeidssøker = hentArbeidssøker(formidlingsgruppeEndretEvent.foedselsnummer)

formidlingsgruppeRepository.lagre(formidlingsgruppeEndretEvent)

try {
Expand All @@ -53,23 +47,9 @@ class FormidlingsgruppeMottakService(
logger.warn("Klarte ikke populere aktørid-cache for innkommende formidlingsgruppe", e)
}

arbeidssokerperiodeAvsluttetService.behandleAvslutningAvArbeidssokerperiode(
formidlingsgruppeEndretEvent,
eksisterendeArbeidssokerperioderLokalt
)

behandle(arbeidssøker, formidlingsgruppeEndretEvent)
}

private fun hentArbeidssøkerperioder(formidlingsgruppeEndretEvent: FormidlingsgruppeEndretEvent): Arbeidssokerperioder {
val eksisterendeFormidlingsgruppeEndretEvents =
formidlingsgruppeRepository.finnFormidlingsgruppeEndretEventFor(
listOf(formidlingsgruppeEndretEvent.foedselsnummer)
)

return ArbeidssokerperioderMapper.map(eksisterendeFormidlingsgruppeEndretEvents)
}

private fun hentArbeidssøker(foedselsnummer: Foedselsnummer): Arbeidssoker? {
return try {
val arbeidssøker = populerArbeidssokerperioderService.hentArbeidssøker(foedselsnummer)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@ import no.nav.fo.veilarbregistrering.arbeidssoker.ArbeidssøkerDomainEvent
import no.nav.fo.veilarbregistrering.arbeidssoker.ArbeidssøkerperiodeAvsluttetEvent
import no.nav.fo.veilarbregistrering.arbeidssoker.ArbeidssøkerperiodeStartetEvent
import no.nav.fo.veilarbregistrering.arbeidssoker.Observer
import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.FormidlingsgruppeEndretEvent
import no.nav.fo.veilarbregistrering.log.logger

class ArbeidssokerperiodeAvsluttetProducer: Observer {
Expand All @@ -24,14 +23,4 @@ class ArbeidssokerperiodeAvsluttetProducer: Observer {
logger.info("Avslutter en eksisterende arbeidssøkerperiode ${arbeidssøkerperiodeAvsluttetEvent.tilOgMedDato}")
}

fun publiserArbeidssokerperiodeAvsluttet(
formidlingsgruppeEndretEvent: FormidlingsgruppeEndretEvent,
sisteArbeidssokerperiode: Arbeidssokerperiode
) {

logger.info("Ny formidlingsgruppe for person: ${formidlingsgruppeEndretEvent.formidlingsgruppe} - " +
"arbeidssøkerperiode avsluttet ${formidlingsgruppeEndretEvent.formidlingsgruppeEndret}. " +
"Nyeste arbeidssøkerperiode før denne endringen er: $sisteArbeidssokerperiode.")
}

}

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@ import no.nav.fo.veilarbregistrering.arbeidssoker.meldekort.MeldekortService
import no.nav.fo.veilarbregistrering.arbeidssoker.meldekort.resources.MeldekortResource
import no.nav.fo.veilarbregistrering.arbeidssoker.perioder.ArbeidssokerService
import no.nav.fo.veilarbregistrering.arbeidssoker.perioder.ArbeidssokerperiodeAvsluttetProducer
import no.nav.fo.veilarbregistrering.arbeidssoker.perioder.ArbeidssokerperiodeAvsluttetService
import no.nav.fo.veilarbregistrering.arbeidssoker.perioder.PopulerArbeidssokerperioderService
import no.nav.fo.veilarbregistrering.arbeidssoker.perioder.resources.ArbeidssokerResource
import no.nav.fo.veilarbregistrering.autorisasjon.TilgangskontrollService
Expand Down Expand Up @@ -325,28 +324,18 @@ class ServiceBeansConfig {
@Bean
fun formidlingsgruppeMottakService(
formidlingsgruppeRepository: FormidlingsgruppeRepository,
arbeidssokerperiodeAvsluttetService: ArbeidssokerperiodeAvsluttetService,
aktorIdCacheService: AktorIdCacheService,
populerArbeidssokerperioderService: PopulerArbeidssokerperioderService,
arbeidssokerperiodeAvsluttetProducer: ArbeidssokerperiodeAvsluttetProducer
): FormidlingsgruppeMottakService {
return FormidlingsgruppeMottakService(
formidlingsgruppeRepository,
arbeidssokerperiodeAvsluttetService,
aktorIdCacheService,
populerArbeidssokerperioderService,
arbeidssokerperiodeAvsluttetProducer
)
}

@Bean
fun arbeidssokerperiodeAvsluttetService(
arbeidssokerperiodeAvsluttetProducer: ArbeidssokerperiodeAvsluttetProducer,
meldekortService: MeldekortService,
metricsService: MetricsService
): ArbeidssokerperiodeAvsluttetService =
ArbeidssokerperiodeAvsluttetService(arbeidssokerperiodeAvsluttetProducer, meldekortService, metricsService)

@Bean
fun arbeidssokerperiodeAvsluttetProducer(): ArbeidssokerperiodeAvsluttetProducer =
ArbeidssokerperiodeAvsluttetProducer()
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,9 @@
package no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe

import io.mockk.*
import io.mockk.every
import io.mockk.mockk
import io.mockk.verify
import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.FormidlingsgruppeEndretEventTestdataBuilder.testEvent
import no.nav.fo.veilarbregistrering.arbeidssoker.perioder.ArbeidssokerperiodeAvsluttetService
import org.junit.jupiter.api.BeforeEach
import org.junit.jupiter.api.Test
import java.time.LocalDateTime
Expand All @@ -11,16 +12,12 @@ import java.time.Month
class FormidlingsgruppeMottakServiceTest {
private lateinit var formidlingsgruppeMottakService: FormidlingsgruppeMottakService
private lateinit var formidlingsgruppeRepository: FormidlingsgruppeRepository
private lateinit var arbeidssokerperiodeAvsluttetService: ArbeidssokerperiodeAvsluttetService

@BeforeEach
fun setup() {
formidlingsgruppeRepository = mockk()
arbeidssokerperiodeAvsluttetService = mockk()
every { arbeidssokerperiodeAvsluttetService.behandleAvslutningAvArbeidssokerperiode(any(), any()) } just Runs
formidlingsgruppeMottakService = FormidlingsgruppeMottakService(
formidlingsgruppeRepository,
arbeidssokerperiodeAvsluttetService,
mockk(relaxed = true),
mockk(relaxed = true),
mockk(relaxed = true)
Expand Down

This file was deleted.

Loading

0 comments on commit 2bf07ab

Please sign in to comment.