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

Commit

Permalink
Annoterer BrukerRegistreringService med @service
Browse files Browse the repository at this point in the history
  • Loading branch information
maccyber committed Dec 11, 2023
1 parent 3f6b15f commit 016b94b
Show file tree
Hide file tree
Showing 5 changed files with 10 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,6 @@ import no.nav.fo.veilarbregistrering.metrics.MetricsConfig
import no.nav.fo.veilarbregistrering.oppfolging.adapter.OppfolgingGatewayConfig
import no.nav.fo.veilarbregistrering.oppgave.adapter.OppgaveGatewayConfig
import no.nav.fo.veilarbregistrering.orgenhet.adapter.Norg2GatewayConfig
import no.nav.fo.veilarbregistrering.registrering.ordinaer.scheduler.OpplysningMottattScheduler
import no.nav.fo.veilarbregistrering.registrering.ordinaer.scheduler.OpplysningerMottattSchedulerConfig
import no.nav.fo.veilarbregistrering.registrering.publisering.scheduler.PubliseringSchedulerConfig
import org.springframework.context.annotation.Configuration
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,10 +31,12 @@ import no.nav.fo.veilarbregistrering.registrering.veileder.NavVeileder
import no.nav.paw.arbeidssokerregisteret.intern.v1.OpplysningerOmArbeidssoekerMottatt
import no.nav.paw.arbeidssokerregisteret.intern.v1.vo.BrukerType
import org.slf4j.LoggerFactory
import org.springframework.stereotype.Service
import org.springframework.transaction.annotation.Transactional
import java.time.LocalDate

open class BrukerRegistreringService(
@Service
class BrukerRegistreringService(
private val brukerRegistreringRepository: BrukerRegistreringRepository,
private val profileringRepository: ProfileringRepository,
private val oppfolgingGateway: OppfolgingGateway,
Expand All @@ -46,13 +48,8 @@ open class BrukerRegistreringService(
private val aktorIdCacheService: AktorIdCacheService,
private val arbeidssokerperiodeService: ArbeidssokerperiodeService
) {
init {
requireNotNull(brukerRegistreringRepository) {
"brukerRegistreringRepository kan ikke være null"
}
}
@Transactional
open fun registrerBrukerUtenOverforing(
fun registrerBrukerUtenOverforing(
ordinaerBrukerRegistrering: OrdinaerBrukerRegistrering,
bruker: Bruker,
veileder: NavVeileder?
Expand Down Expand Up @@ -187,9 +184,7 @@ open class BrukerRegistreringService(
}

fun hentNesteOpplysningerOmArbeidssoker(antall: Int): List<Pair<Long, OpplysningerOmArbeidssoekerMottatt>> =
// Hente opplysninger om arbeidssøker fra databasen
brukerRegistreringRepository.hentNesteOpplysningerOmArbeidssoeker(antall).map { (id, opplysninger) ->
// Løpe gjennom listen og slå opp manuell registrering for å finne veileder
Triple(id, opplysninger, manuellRegistreringRepository.hentManuellRegistrering(id, BrukerRegistreringType.ORDINAER))
}.map { (id, opplysninger, manuellRegistrering) ->
id to (manuellRegistrering?.let {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import org.springframework.scheduling.annotation.Scheduled

class OpplysningMottattScheduler(
private val leaderElectionClient: LeaderElectionClient,
private val registreringService: BrukerRegistreringService,
private val brukerRegistreringService: BrukerRegistreringService,
private val opplysningerMottattProducer: OpplysningerMottattProducer,
private val unleashClient: Unleash,
) {
Expand All @@ -27,7 +27,7 @@ class OpplysningMottattScheduler(
return
}

val opplysningerOmArbeidssoekere = registreringService.hentNesteOpplysningerOmArbeidssoker(100)
val opplysningerOmArbeidssoekere = brukerRegistreringService.hentNesteOpplysningerOmArbeidssoker(100)

if (opplysningerOmArbeidssoekere.isEmpty()) {
logger.info("Opplysninger om arbeidssøker: Fant ingen arbeidssøkeropplysninger som skal overføres")
Expand All @@ -38,7 +38,7 @@ class OpplysningMottattScheduler(

opplysningerOmArbeidssoekere.forEach { (_, opplysninger) -> opplysningerMottattProducer.publiserOpplysningerMottatt(opplysninger) }

registreringService.settOpplysningerOmArbeidssoekerSomOverfort(opplysningerOmArbeidssoekere.map { it.first.toInt() })
brukerRegistreringService.settOpplysningerOmArbeidssoekerSomOverfort(opplysningerOmArbeidssoekere.map { it.first.toInt() })

logger.info("Opplysninger om arbeidssøker: Hendelser overført ${opplysningerOmArbeidssoekere.size}")
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,13 +13,13 @@ class OpplysningerMottattSchedulerConfig {
@Bean
fun opplysningMottattScheduler(
leaderElectionClient: LeaderElectionClient,
registreringService: BrukerRegistreringService,
brukerRegistreringService: BrukerRegistreringService,
opplysningerMottattProducer: OpplysningerMottattProducer,
unleashClient: Unleash
): OpplysningMottattScheduler {
return OpplysningMottattScheduler(
leaderElectionClient,
registreringService,
brukerRegistreringService,
opplysningerMottattProducer,
unleashClient
)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,5 +24,5 @@ class KafkaConfig {
fun arbeidssokerperiodeKafkaProducerAiven(): ArbeidssokerperiodeProducer = mockk()

@Bean
fun opplysningerOmArbeidssokerProducerAvien(): OpplysningerMottattProducer = mockk()
fun opplysningerOmArbeidssokerProducerAiven(): OpplysningerMottattProducer = mockk()
}

0 comments on commit 016b94b

Please sign in to comment.