Skip to content

Commit

Permalink
♻️ Bruker ikke lenger lambda for oppretting av ny oppgave
Browse files Browse the repository at this point in the history 
* Instruerer i stedet OppgaveService om å lage oppgave og lagre denne
  • Loading branch information
@chsko
chsko committed Nov 5, 2024
1 parent b460ae5 commit 4cfc259
Show file tree
Hide file tree
Showing 10 changed files with 178 additions and 325 deletions.
2 changes: 2 additions & 0 deletions spesialist-felles/src/testFixtures/kotlin/no/nav/helse/spesialist/test/Test.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,8 @@ private val organisasjonsnavnDel2 = listOf("AVDELINGEN", "SENTERET", "FORUM", "K
fun lagOrganisasjonsnavn() = organisasjonsnavnDel1.random() + organisasjonsnavnDel2.random()

fun lagSaksbehandlerident() = ('A'..'Z').random() + "${nextInt(from = 100_000, until = 999_999)}"
fun lagSaksbehandlernavn() = "${lagFornavn()} ${lagEtternavn()}"
fun lagEpostadresseFraFulltNavn(navn: String) = navn.split(" ").joinToString(".").lowercase() + "@nav.no"

fun fødselsdato(): LocalDate {
val end = LocalDate.now().minusYears(18)
Expand Down
15 changes: 11 additions & 4 deletions spesialist-modell/src/main/kotlin/no/nav/helse/modell/oppgave/Oppgave.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -333,12 +333,19 @@ class Oppgave private constructor(
utbetalingId: UUID,
hendelseId: UUID,
kanAvvises: Boolean,
egenskaper: List<Egenskap>,
egenskaper: Set<Egenskap>,
totrinnsvurdering: Totrinnsvurdering? = null,
): Oppgave {
return Oppgave(id, AvventerSaksbehandler, vedtaksperiodeId, utbetalingId, hendelseId, kanAvvises, totrinnsvurdering).also {
it.egenskaper.addAll(egenskaper)
}
return Oppgave(
id = id,
tilstand = AvventerSaksbehandler,
vedtaksperiodeId = vedtaksperiodeId,
utbetalingId = utbetalingId,
hendelseId = hendelseId,
kanAvvises = kanAvvises,
totrinnsvurdering = totrinnsvurdering,
egenskaper = egenskaper.toMutableSet(),
)
}

fun Oppgave.toDto() =
Expand Down
12 changes: 6 additions & 6 deletions spesialist-modell/src/test/kotlin/no/nav/helse/modell/oppgave/OppgaveTest.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -604,16 +604,16 @@ internal class OppgaveTest {
UTBETALING_ID,
UUID.randomUUID(),
true,
listOf(OPPGAVETYPE),
setOf(OPPGAVETYPE),
)
val oppgave1 =
Oppgave.nyOppgave(OPPGAVE_ID, VEDTAKSPERIODE_ID, UTBETALING_ID, UUID.randomUUID(), true, listOf(SØKNAD))
Oppgave.nyOppgave(OPPGAVE_ID, VEDTAKSPERIODE_ID, UTBETALING_ID, UUID.randomUUID(), true, setOf(SØKNAD))
val oppgave2 =
Oppgave.nyOppgave(OPPGAVE_ID, VEDTAKSPERIODE_ID, UTBETALING_ID, UUID.randomUUID(), true, listOf(SØKNAD))
Oppgave.nyOppgave(OPPGAVE_ID, VEDTAKSPERIODE_ID, UTBETALING_ID, UUID.randomUUID(), true, setOf(SØKNAD))
val oppgave3 =
Oppgave.nyOppgave(OPPGAVE_ID, UUID.randomUUID(), UTBETALING_ID, UUID.randomUUID(), true, listOf(SØKNAD))
Oppgave.nyOppgave(OPPGAVE_ID, UUID.randomUUID(), UTBETALING_ID, UUID.randomUUID(), true, setOf(SØKNAD))
val oppgave4 =
Oppgave.nyOppgave(OPPGAVE_ID, VEDTAKSPERIODE_ID, UTBETALING_ID, UUID.randomUUID(), true, listOf(STIKKPRØVE))
Oppgave.nyOppgave(OPPGAVE_ID, VEDTAKSPERIODE_ID, UTBETALING_ID, UUID.randomUUID(), true, setOf(STIKKPRØVE))
assertEquals(oppgave1, oppgave2)
assertEquals(oppgave1.hashCode(), oppgave2.hashCode())
assertNotEquals(oppgave1, oppgave3)
Expand Down Expand Up @@ -643,7 +643,7 @@ internal class OppgaveTest {
UTBETALING_ID,
UUID.randomUUID(),
true,
egenskaper.toList(),
egenskaper.toSet(),
totrinnsvurdering,
)
}
Expand Down
13 changes: 10 additions & 3 deletions spesialist-selve/src/main/kotlin/no/nav/helse/mediator/oppgave/OppgaveService.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ import no.nav.helse.mediator.oppgave.OppgaveMapper.tilOppgaverTilBehandling
import no.nav.helse.modell.Modellfeil
import no.nav.helse.modell.oppgave.Egenskap
import no.nav.helse.modell.oppgave.Oppgave
import no.nav.helse.modell.oppgave.Oppgave.Companion.nyOppgave
import no.nav.helse.modell.oppgave.Oppgave.Companion.toDto
import no.nav.helse.modell.saksbehandler.Saksbehandler
import no.nav.helse.modell.saksbehandler.Tilgangskontroll
Expand Down Expand Up @@ -89,15 +90,21 @@ internal class OppgaveService(
internal fun nyOppgave(
fødselsnummer: String,
contextId: UUID,
opprettOppgaveBlock: (reservertId: Long) -> Oppgave,
vedtaksperiodeId: UUID,
utbetalingId: UUID,
hendelseId: UUID,
kanAvvises: Boolean,
egenskaper: Set<Egenskap>,
) {
logg.info("Oppretter saksbehandleroppgave")
sikkerlogg.info("Oppretter saksbehandleroppgave for {}", kv("fødselsnummer", fødselsnummer))
val nesteId = oppgaveDao.reserverNesteId()
val oppgave = opprettOppgaveBlock(nesteId)
val oppgavemelder = Oppgavemelder(fødselsnummer, rapidsConnection)
val oppgave = nyOppgave(nesteId, vedtaksperiodeId, utbetalingId, hendelseId, kanAvvises, egenskaper)
oppgave.register(oppgavemelder)
oppgavemelder.oppgaveOpprettet(oppgave)
tildelVedReservasjon(fødselsnummer, oppgave)
Oppgavelagrer(tildelingRepository).lagre(this, oppgave.toDto(), contextId)
oppgavemelder.oppgaveOpprettet(oppgave)
}

fun <T> oppgave(
Expand Down
56 changes: 21 additions & 35 deletions spesialist-selve/src/main/kotlin/no/nav/helse/modell/kommando/OpprettSaksbehandleroppgave.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,6 @@ import no.nav.helse.modell.oppgave.Egenskap.UTBETALING_TIL_ARBEIDSGIVER
import no.nav.helse.modell.oppgave.Egenskap.UTBETALING_TIL_SYKMELDT
import no.nav.helse.modell.oppgave.Egenskap.UTLAND
import no.nav.helse.modell.oppgave.Egenskap.VERGEMÅL
import no.nav.helse.modell.oppgave.Oppgave
import no.nav.helse.modell.person.HentEnhetløsning
import no.nav.helse.modell.sykefraværstilfelle.Sykefraværstilfelle
import no.nav.helse.modell.utbetaling.Utbetaling
Expand All @@ -44,7 +43,6 @@ import no.nav.helse.modell.vedtaksperiode.GodkjenningsbehovData
import no.nav.helse.modell.vedtaksperiode.Inntektskilde
import no.nav.helse.modell.vedtaksperiode.Periodetype
import no.nav.helse.spesialist.api.person.Adressebeskyttelse
import org.slf4j.LoggerFactory
import java.util.UUID

internal class OpprettSaksbehandleroppgave(
Expand All @@ -61,22 +59,17 @@ internal class OpprettSaksbehandleroppgave(
private val vedtakDao: VedtakDao,
private val påVentRepository: PåVentRepository,
) : Command {
private companion object {
private val logg = LoggerFactory.getLogger(OpprettSaksbehandleroppgave::class.java)
private val sikkerLogg = LoggerFactory.getLogger("tjenestekall")
}

override fun execute(context: CommandContext): Boolean {
val fødselsnummer = behovData.fødselsnummer
val vedtaksperiodeId = behovData.vedtaksperiodeId
val hendelseId = behovData.id
val utbetalingId = utbetaling.utbetalingId
val utbetalingId = behovData.utbetalingId
val periodetype = behovData.periodetype
val inntektskilde = behovData.inntektskilde
val kanAvvises = behovData.kanAvvises

val egenskaper =
emptyList<Egenskap>()
emptySet<Egenskap>()
.vurderEgenAnsatt(fødselsnummer)
.vurderAdressebeskyttelse(fødselsnummer)
.vurderOppgavetype(utbetalingtype)
Expand All @@ -95,23 +88,16 @@ internal class OpprettSaksbehandleroppgave(
.vurderMedlemskap(vedtaksperiodeId)
.vurderHaster(vedtaksperiodeId)

oppgaveService.nyOppgave(fødselsnummer, context.id()) { reservertId ->
val oppgave = Oppgave.nyOppgave(reservertId, vedtaksperiodeId, utbetalingId, hendelseId, kanAvvises, egenskaper)

logg.info("Saksbehandleroppgave opprettet, avventer lagring: $oppgave")
sikkerLogg.info("Saksbehandleroppgave opprettet, avventer lagring: $oppgave")
oppgave
}

oppgaveService.nyOppgave(fødselsnummer, context.id(), vedtaksperiodeId, utbetalingId, hendelseId, kanAvvises, egenskaper)
return true
}

private fun List<Egenskap>.vurderEgenAnsatt(fødselsnummer: String): List<Egenskap> {
private fun Set<Egenskap>.vurderEgenAnsatt(fødselsnummer: String): Set<Egenskap> {
if (egenAnsattRepository.erEgenAnsatt(fødselsnummer) == true) return this + EGEN_ANSATT
return this
}

private fun List<Egenskap>.vurderAdressebeskyttelse(fødselsnummer: String): List<Egenskap> {
private fun Set<Egenskap>.vurderAdressebeskyttelse(fødselsnummer: String): Set<Egenskap> {
val adressebeskyttelse = personRepository.finnAdressebeskyttelse(fødselsnummer) ?: return this
return when (adressebeskyttelse) {
Adressebeskyttelse.StrengtFortrolig,
Expand All @@ -122,37 +108,37 @@ internal class OpprettSaksbehandleroppgave(
}
}

private fun List<Egenskap>.vurderOppgavetype(utbetalingtype: Utbetalingtype): List<Egenskap> {
private fun Set<Egenskap>.vurderOppgavetype(utbetalingtype: Utbetalingtype): Set<Egenskap> {
if (utbetalingtype == Utbetalingtype.REVURDERING) return this + REVURDERING
return this + SØKNAD
}

private fun List<Egenskap>.vurderStikkprøve(
private fun Set<Egenskap>.vurderStikkprøve(
vedtaksperiodeId: UUID,
hendelseId: UUID,
): List<Egenskap> {
): Set<Egenskap> {
if (automatisering.erStikkprøve(vedtaksperiodeId, hendelseId)) return this + STIKKPRØVE
return this
}

private fun List<Egenskap>.vurderVurderingsmomenter(vedtaksperiodeId: UUID): List<Egenskap> {
private fun Set<Egenskap>.vurderVurderingsmomenter(vedtaksperiodeId: UUID): Set<Egenskap> {
if (!this.contains(REVURDERING) && risikovurderingRepository.kreverSupersaksbehandler(vedtaksperiodeId)) {
return this + RISK_QA
}
return this
}

private fun List<Egenskap>.vurderVergemål(fødselsnummer: String): List<Egenskap> {
private fun Set<Egenskap>.vurderVergemål(fødselsnummer: String): Set<Egenskap> {
if (vergemålRepository.harVergemål(fødselsnummer) == true) return this + VERGEMÅL
return this
}

private fun List<Egenskap>.vurderEnhetUtland(fødselsnummer: String): List<Egenskap> {
private fun Set<Egenskap>.vurderEnhetUtland(fødselsnummer: String): Set<Egenskap> {
if (HentEnhetløsning.erEnhetUtland(personRepository.finnEnhetId(fødselsnummer))) return this + UTLAND
return this
}

private fun List<Egenskap>.vurderMottaker(): List<Egenskap> {
private fun Set<Egenskap>.vurderMottaker(): Set<Egenskap> {
return when {
utbetaling.delvisRefusjon() -> this + DELVIS_REFUSJON
utbetaling.kunUtbetalingTilSykmeldt() -> this + UTBETALING_TIL_SYKMELDT
Expand All @@ -162,14 +148,14 @@ internal class OpprettSaksbehandleroppgave(
}
}

private fun List<Egenskap>.vurderInntektskilde(inntektskilde: Inntektskilde): List<Egenskap> {
private fun Set<Egenskap>.vurderInntektskilde(inntektskilde: Inntektskilde): Set<Egenskap> {
return when (inntektskilde) {
Inntektskilde.EN_ARBEIDSGIVER -> this + EN_ARBEIDSGIVER
Inntektskilde.FLERE_ARBEIDSGIVERE -> this + FLERE_ARBEIDSGIVERE
}
}

private fun List<Egenskap>.vurderPeriodetype(periodetype: Periodetype): List<Egenskap> {
private fun Set<Egenskap>.vurderPeriodetype(periodetype: Periodetype): Set<Egenskap> {
return when (periodetype) {
Periodetype.FØRSTEGANGSBEHANDLING -> this + FORSTEGANGSBEHANDLING
Periodetype.FORLENGELSE -> this + FORLENGELSE
Expand All @@ -178,37 +164,37 @@ internal class OpprettSaksbehandleroppgave(
}
}

private fun List<Egenskap>.vurderSpesialsak(vedtaksperiodeId: UUID): List<Egenskap> {
private fun Set<Egenskap>.vurderSpesialsak(vedtaksperiodeId: UUID): Set<Egenskap> {
if (vedtakDao.erSpesialsak(vedtaksperiodeId)) return this + SPESIALSAK
return this
}

private fun List<Egenskap>.vurderPåVent(vedtaksperiodeId: UUID): List<Egenskap> {
private fun Set<Egenskap>.vurderPåVent(vedtaksperiodeId: UUID): Set<Egenskap> {
if (påVentRepository.erPåVent(vedtaksperiodeId)) return this + PÅ_VENT
return this
}

private fun List<Egenskap>.vurderSkjønnsfastsettelse(vedtaksperiodeId: UUID): List<Egenskap> {
private fun Set<Egenskap>.vurderSkjønnsfastsettelse(vedtaksperiodeId: UUID): Set<Egenskap> {
if (sykefraværstilfelle.kreverSkjønnsfastsettelse(vedtaksperiodeId)) return this + SKJØNNSFASTSETTELSE
return this
}

private fun List<Egenskap>.vurderTilbakedatert(vedtaksperiodeId: UUID): List<Egenskap> {
private fun Set<Egenskap>.vurderTilbakedatert(vedtaksperiodeId: UUID): Set<Egenskap> {
if (sykefraværstilfelle.erTilbakedatert(vedtaksperiodeId)) return this + TILBAKEDATERT
return this
}

private fun List<Egenskap>.vurderKunÅpenGosysOppgave(vedtaksperiodeId: UUID): List<Egenskap> {
private fun Set<Egenskap>.vurderKunÅpenGosysOppgave(vedtaksperiodeId: UUID): Set<Egenskap> {
if (sykefraværstilfelle.harKunÅpenGosysOppgave(vedtaksperiodeId)) return this + GOSYS
return this
}

private fun List<Egenskap>.vurderMedlemskap(vedtaksperiodeId: UUID): List<Egenskap> {
private fun Set<Egenskap>.vurderMedlemskap(vedtaksperiodeId: UUID): Set<Egenskap> {
if (sykefraværstilfelle.harMedlemskapsvarsel(vedtaksperiodeId)) return this + MEDLEMSKAP
return this
}

private fun List<Egenskap>.vurderHaster(vedtaksperiodeId: UUID): List<Egenskap> {
private fun Set<Egenskap>.vurderHaster(vedtaksperiodeId: UUID): Set<Egenskap> {
if (sykefraværstilfelle.haster(vedtaksperiodeId) && utbetaling.harEndringIUtbetalingTilSykmeldt()) return this + HASTER
return this
}
Expand Down
Loading

0 comments on commit 4cfc259

Please sign in to comment.