Skip to content

Commit

Permalink
⚰️ Fjern kode for resume av kommandoer som aldri ble brukt
Browse files Browse the repository at this point in the history
  • Loading branch information
@havstein
havstein committed Feb 20, 2024
1 parent e4b9ffe commit 3fd948e
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 207 deletions.
174 changes: 0 additions & 174 deletions spesialist-selve/src/main/kotlin/no/nav/helse/mediator/Hendelsefabrikk.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,6 @@ import no.nav.helse.modell.kommando.TilbakedateringGodkjentCommand
import no.nav.helse.modell.overstyring.OverstyringDao
import no.nav.helse.modell.overstyring.OverstyringIgangsatt
import no.nav.helse.modell.overstyring.OverstyrtArbeidsgiver
import no.nav.helse.modell.overstyring.OverstyrtArbeidsgiver.Companion.arbeidsgiverelementer
import no.nav.helse.modell.overstyring.SkjønnsfastsattArbeidsgiver
import no.nav.helse.modell.person.EndretEgenAnsattStatus
import no.nav.helse.modell.person.EndretEgenAnsattStatusCommand
Expand All @@ -55,7 +54,6 @@ import no.nav.helse.modell.utbetaling.Utbetalingsstatus
import no.nav.helse.modell.utbetaling.Utbetalingtype
import no.nav.helse.modell.varsel.ActualVarselRepository
import no.nav.helse.modell.varsel.Varsel
import no.nav.helse.modell.varsel.Varsel.Companion.varsler
import no.nav.helse.modell.vedtaksperiode.ActualGenerasjonRepository
import no.nav.helse.modell.vedtaksperiode.Generasjon
import no.nav.helse.modell.vedtaksperiode.Godkjenningsbehov
Expand Down Expand Up @@ -86,7 +84,6 @@ import no.nav.helse.spesialist.api.saksbehandler.handlinger.OverstyrArbeidsforho
import no.nav.helse.spesialist.api.snapshot.SnapshotClient
import no.nav.helse.spesialist.api.tildeling.TildelingDao
import org.slf4j.LoggerFactory
import no.nav.helse.modell.overstyring.SkjønnsfastsattArbeidsgiver.Companion.arbeidsgiverelementer as skjønnsfastsattArbeidsgiverelementer

internal class Hendelsefabrikk(
dataSource: DataSource,
Expand Down Expand Up @@ -243,21 +240,6 @@ internal class Hendelsefabrikk(
)
}

fun søknadSendt(
json: String,
): SøknadSendt {
val jsonNode = mapper.readTree(json)
return SøknadSendt(
id = UUID.fromString(jsonNode.path("@id").asText()),
fødselsnummer = jsonNode.path("fødselsnummer").asText(),
aktørId = jsonNode.path("aktorId").asText(),
organisasjonsnummer = jsonNode.path("organisasjonsnummer").asText(),
json = json,
personDao = personDao,
arbeidsgiverDao = arbeidsgiverDao
)
}

fun søknadSendt(
id: UUID,
fødselsnummer: String,
Expand Down Expand Up @@ -377,29 +359,6 @@ internal class Hendelsefabrikk(
)
}

fun saksbehandlerløsning(json: String): Saksbehandlerløsning {
val jsonNode = mapper.readTree(json)
return saksbehandlerløsning(
id = UUID.fromString(jsonNode["@id"].asText()),
behandlingId = UUID.fromString(jsonNode["behandlingId"].asText()),
godkjenningsbehovhendelseId = UUID.fromString(jsonNode["hendelseId"].asText()),
fødselsnummer = jsonNode["fødselsnummer"].asText(),
godkjent = jsonNode["godkjent"].asBoolean(),
saksbehandlerident = jsonNode["saksbehandlerident"].asText(),
epostadresse = jsonNode["saksbehandlerepost"].asText(),
godkjenttidspunkt = jsonNode["godkjenttidspunkt"].asLocalDateTime(),
årsak = jsonNode["årsak"].takeUnless(JsonNode::isMissingOrNull)?.asText(),
begrunnelser = jsonNode["begrunnelser"].takeUnless(JsonNode::isMissingOrNull)?.map(JsonNode::asText),
kommentar = jsonNode["kommentar"].takeUnless(JsonNode::isMissingOrNull)?.asText(),
saksbehandleroverstyringer = jsonNode["saksbehandleroverstyringer"].takeUnless(JsonNode::isMissingOrNull)
?.map {
UUID.fromString(it.asText())
} ?: emptyList(),
oppgaveId = jsonNode["oppgaveId"].asLong(),
json = json
)
}

fun overstyringInntektOgRefusjon(
id: UUID,
fødselsnummer: String,
Expand Down Expand Up @@ -461,52 +420,6 @@ internal class Hendelsefabrikk(
overstyringMediator = overstyringMediator,
)

fun overstyringArbeidsforhold(json: String): OverstyringArbeidsforhold {
val jsonNode = mapper.readTree(json)
return overstyringArbeidsforhold(
id = UUID.fromString(jsonNode.path("@id").asText()),
fødselsnummer = jsonNode.path("fødselsnummer").asText(),
oid = UUID.fromString(jsonNode.path("saksbehandlerOid").asText()),
overstyrteArbeidsforhold = jsonNode.path("overstyrteArbeidsforhold").map {
OverstyrArbeidsforholdHandlingFraApi.ArbeidsforholdFraApi(
it["orgnummer"].asText(),
it["deaktivert"].asBoolean(),
it["begrunnelse"].asText(),
it["forklaring"].asText()
)
},
skjæringstidspunkt = jsonNode.path("skjæringstidspunkt").asLocalDate(),
opprettet = jsonNode.path("@opprettet").asLocalDateTime(),
json = json
)
}

fun overstyringInntektOgRefusjon(json: String): OverstyringInntektOgRefusjon {
val jsonNode = mapper.readTree(json)
return overstyringInntektOgRefusjon(
id = UUID.fromString(jsonNode.path("@id").asText()),
fødselsnummer = jsonNode.path("fødselsnummer").asText(),
oid = UUID.fromString(jsonNode.path("saksbehandlerOid").asText()),
arbeidsgivere = jsonNode.path("arbeidsgivere").arbeidsgiverelementer(),
skjæringstidspunkt = jsonNode.path("skjæringstidspunkt").asLocalDate(),
opprettet = jsonNode.path("@opprettet").asLocalDateTime(),
json = json
)
}

fun skjønnsfastsettingSykepengegrunnlag(json: String): SkjønnsfastsettingSykepengegrunnlag {
val jsonNode = mapper.readTree(json)
return skjønnsfastsettingSykepengegrunnlag(
id = UUID.fromString(jsonNode.path("@id").asText()),
fødselsnummer = jsonNode.path("fødselsnummer").asText(),
oid = UUID.fromString(jsonNode.path("saksbehandlerOid").asText()),
arbeidsgivere = jsonNode.path("arbeidsgivere").skjønnsfastsattArbeidsgiverelementer(),
skjæringstidspunkt = jsonNode.path("skjæringstidspunkt").asLocalDate(),
opprettet = jsonNode.path("@opprettet").asLocalDateTime(),
json = json
)
}

fun adressebeskyttelseEndret(id: UUID, fødselsnummer: String, json: String) =
AdressebeskyttelseEndret(
id = id,
Expand Down Expand Up @@ -541,27 +454,6 @@ internal class Hendelsefabrikk(
)
}

fun sykefraværstilfeller(json: String): Sykefraværstilfeller {
val jsonNode = mapper.readTree(json)
return sykefraværstilfeller(
id = UUID.fromString(jsonNode["@id"].asText()),
vedtaksperiodeOppdateringer = jsonNode["tilfeller"].flatMap { tilfelleNode ->
val skjæringstidspunkt = tilfelleNode["dato"].asLocalDate()
tilfelleNode["perioder"].map {
VedtaksperiodeOppdatering(
skjæringstidspunkt = skjæringstidspunkt,
fom = LocalDate.parse(it["fom"].asText()),
tom = LocalDate.parse(it["tom"].asText()),
vedtaksperiodeId = UUID.fromString(it["vedtaksperiodeId"].asText()),
)
}
},
fødselsnummer = jsonNode.path("fødselsnummer").asText(),
aktørId = jsonNode.path("aktørId").asText(),
json = json
)
}

fun vedtaksperiodeEndret(
id: UUID,
vedtaksperiodeId: UUID,
Expand All @@ -586,19 +478,6 @@ internal class Hendelsefabrikk(
)
}

fun vedtaksperiodeEndret(json: String): VedtaksperiodeEndret {
val jsonNode = mapper.readTree(json)
return vedtaksperiodeEndret(
id = UUID.fromString(jsonNode.path("@id").asText()),
vedtaksperiodeId = UUID.fromString(jsonNode.path("vedtaksperiodeId").asText()),
fødselsnummer = jsonNode.path("fødselsnummer").asText(),
forårsaketAvId = UUID.fromString(jsonNode.path("@forårsaket_av.id").asText()),
forrigeTilstand = jsonNode.path("forrigeTilstand").asText(),
gjeldendeTilstand = jsonNode.path("gjeldendeTilstand").asText(),
json = json
)
}

fun vedtaksperiodeForkastet(
id: UUID,
vedtaksperiodeId: UUID,
Expand Down Expand Up @@ -689,17 +568,6 @@ internal class Hendelsefabrikk(
)
}

fun vedtaksperiodeNyUtbetaling(json: String): VedtaksperiodeNyUtbetaling {
val jsonNode = mapper.readTree(json)
return vedtaksperiodeNyUtbetaling(
hendelseId = UUID.fromString(jsonNode.path("@id").asText()),
fødselsnummer = jsonNode.path("fødselsnummer").asText(),
vedtaksperiodeId = UUID.fromString(jsonNode.path("vedtaksperiodeId").asText()),
utbetalingId = UUID.fromString(jsonNode.path("utbetalingId").asText()),
json = json,
)
}

private fun tilOppdrag(jsonNode: JsonNode, mottaker: String) = LagreOppdragCommand.Oppdrag(
fagsystemId = jsonNode.path("fagsystemId").asText(),
mottaker = jsonNode.path("mottaker").takeIf(JsonNode::isTextual)?.asText() ?: mottaker,
Expand Down Expand Up @@ -870,29 +738,6 @@ internal class Hendelsefabrikk(
)
}

fun vedtaksperiodeOpprettet(json: String): VedtaksperiodeOpprettet {
val jsonNode = mapper.readTree(json)
return vedtaksperiodeOpprettet(
id = UUID.fromString(jsonNode["@id"].asText()),
fødselsnummer = jsonNode["fødselsnummer"].asText(),
organisasjonsnummer = jsonNode.path("organisasjonsnummer").asText(),
vedtaksperiodeId = UUID.fromString(jsonNode.path("vedtaksperiodeId").asText()),
fom = LocalDate.parse(jsonNode.path("fom").asText()),
tom = LocalDate.parse(jsonNode.path("tom").asText()),
skjæringstidspunkt = LocalDate.parse(jsonNode.path("skjæringstidspunkt").asText()),
json = json,
)
}

fun godkjentTilbakedatertSykmelding(json: String): TilbakedateringGodkjent {
val jsonNode = mapper.readTree(json)
return godkjentTilbakedatertSykmelding(
id = UUID.fromString(jsonNode.path("@id").asText()),
fødselsnummer = jsonNode.path("fødselsnummer").asText(),
json = json
)
}

fun godkjentTilbakedatertSykmelding(
id: UUID,
fødselsnummer: String,
Expand Down Expand Up @@ -937,27 +782,8 @@ internal class Hendelsefabrikk(
return VedtakFattet(id, fødselsnummer, vedtaksperiodeId, json, gjeldendeGenerasjon(vedtaksperiodeId), vedtakDao)
}

fun vedtakFattet(json: String): VedtakFattet {
val jsonNode = mapper.readTree(json)
return vedtakFattet(
id = UUID.fromString(jsonNode.path("@id").asText()),
fødselsnummer = jsonNode.path("fødselsnummer").asText(),
vedtaksperiodeId = UUID.fromString(jsonNode.path("vedtaksperiodeId").asText()),
json
)
}

fun nyeVarsler(id: UUID, fødselsnummer: String, varsler: List<Varsel>, json: String): NyeVarsler {
return NyeVarsler(id, fødselsnummer, varsler, json)
}

fun nyeVarsler(json: String): NyeVarsler {
val jsonNode = mapper.readTree(json)
return nyeVarsler(
id = UUID.fromString(jsonNode.path("@id").asText()),
fødselsnummer = jsonNode.path("fødselsnummer").asText(),
varsler = jsonNode.path("aktiviteter").varsler(),
json,
)
}
}
22 changes: 5 additions & 17 deletions spesialist-selve/src/main/kotlin/no/nav/helse/modell/HendelseDao.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -213,34 +213,22 @@ internal class HendelseDao(private val dataSource: DataSource) {
}.asSingle)
}

// Denne funksjonen trenger bare å støtte de hendelsetypene som starter en kommandokjede som sender ut behov.
// Kommandokjeder som ikke har noen suspenderende subcommands vil aldri kunne komme inn her.
private fun fraHendelsetype(
hendelsetype: Hendelsetype,
json: String,
hendelsefabrikk: Hendelsefabrikk,
): Personhendelse =
when (hendelsetype) {
ADRESSEBESKYTTELSE_ENDRET -> hendelsefabrikk.adressebeskyttelseEndret(json)
VEDTAKSPERIODE_ENDRET -> hendelsefabrikk.vedtaksperiodeEndret(json)
// VEDTAKSPERIODE_FORKASTET trengs pt. pga. KommandohendelseDaoTest.`lagrer og finner hendelser`
VEDTAKSPERIODE_FORKASTET -> hendelsefabrikk.vedtaksperiodeForkastet(json)
GODKJENNING -> hendelsefabrikk.godkjenning(json)
OVERSTYRING_INNTEKT_OG_REFUSJON -> hendelsefabrikk.overstyringInntektOgRefusjon(json)
OVERSTYRING_ARBEIDSFORHOLD -> hendelsefabrikk.overstyringArbeidsforhold(json)
SKJØNNSFASTSETTING_SYKEPENGEGRUNNLAG -> hendelsefabrikk.skjønnsfastsettingSykepengegrunnlag(json)
OVERSTYRING_IGANGSATT -> hendelsefabrikk.overstyringIgangsatt(json)
SAKSBEHANDLERLØSNING -> hendelsefabrikk.saksbehandlerløsning(json)
UTBETALING_ANNULLERT -> hendelsefabrikk.utbetalingAnnullert(json)
UTBETALING_ENDRET -> hendelsefabrikk.utbetalingEndret(json)
OPPDATER_PERSONSNAPSHOT -> hendelsefabrikk.oppdaterPersonsnapshot(json)
VEDTAKSPERIODE_REBEREGNET -> hendelsefabrikk.vedtaksperiodeReberegnet(json)
GOSYS_OPPGAVE_ENDRET -> hendelsefabrikk.gosysOppgaveEndret(json)
GODKJENT_TILBAKEDATERT_SYKMELDING -> hendelsefabrikk.godkjentTilbakedatertSykmelding(json)
ENDRET_EGEN_ANSATT_STATUS -> hendelsefabrikk.endretEgenAnsattStatus(json)
VEDTAK_FATTET -> hendelsefabrikk.vedtakFattet(json)
NYE_VARSLER -> hendelsefabrikk.nyeVarsler(json)
VEDTAKSPERIODE_OPPRETTET -> hendelsefabrikk.vedtaksperiodeOpprettet(json)
SØKNAD_SENDT -> hendelsefabrikk.søknadSendt(json)
VEDTAKSPERIODE_NY_UTBETALING -> hendelsefabrikk.vedtaksperiodeNyUtbetaling(json)
SYKEFRAVÆRSTILFELLER -> hendelsefabrikk.sykefraværstilfeller(json)
else -> throw IllegalArgumentException("Prøver å gjenoppta en kommando(kjede) etter mottak av hendelsetype " +
"$hendelsetype, men koden som trengs mangler!")
}

private fun tilHendelsetype(hendelse: Personhendelse) = when (hendelse) {
Expand Down
22 changes: 6 additions & 16 deletions ...t-selve/src/main/kotlin/no/nav/helse/modell/kommando/OpprettMinimalArbeidsgiverCommand.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,22 +13,12 @@ internal class OpprettMinimalArbeidsgiverCommand(
}

override fun execute(context: CommandContext): Boolean {
if (arbeidsgiverFinnes()) return ignorer()
return behandle()
}

override fun resume(context: CommandContext): Boolean {
return behandle()
}

private fun ignorer(): Boolean {
log.info("arbeidsgiver finnes fra før, lager ikke ny")
return true
}

private fun behandle(): Boolean {
sikkerLog.info("Oppretter minimal arbeidsgiver for organisasjonsnummer: $organisasjonsnummer")
arbeidsgiverDao.insertArbeidsgiver(organisasjonsnummer)
if (arbeidsgiverFinnes()) {
log.info("arbeidsgiver finnes fra før, lager ikke ny")
} else {
sikkerLog.info("Oppretter minimal arbeidsgiver for organisasjonsnummer: $organisasjonsnummer")
arbeidsgiverDao.insertArbeidsgiver(organisasjonsnummer)
}
return true
}

Expand Down

0 comments on commit 3fd948e

Please sign in to comment.