Skip to content

Commit

Permalink
Fjern oppgitt opptjening V2 siden FP har ikke behov for dette. (#2547)
Browse files Browse the repository at this point in the history
  • Loading branch information
mrsladek authored Mar 21, 2024
1 parent 023bd33 commit b974494
Show file tree
Hide file tree
Showing 13 changed files with 17 additions and 366 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@
import jakarta.persistence.Version;
import no.nav.foreldrepenger.abakus.domene.iay.arbeidsforhold.ArbeidsforholdInformasjon;
import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittOpptjening;
import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittOpptjeningAggregat;
import no.nav.foreldrepenger.abakus.felles.diff.ChangeTracked;
import no.nav.foreldrepenger.abakus.felles.diff.DiffIgnore;
import no.nav.foreldrepenger.abakus.felles.jpa.BaseEntitet;
Expand Down Expand Up @@ -64,14 +63,6 @@ public class InntektArbeidYtelseGrunnlag extends BaseEntitet {
@ChangeTracked
private OppgittOpptjening oppgittOpptjening;

/**
* versjon 2 - støtter å lagre flere oppgitt opptjening på en behandling
*/
@OneToOne
@JoinColumn(name = "oppgitte_opptjeninger_id", updatable = false, unique = true)
@ChangeTracked
private OppgittOpptjeningAggregat oppgittOpptjeningAggregat;

@OneToOne
@ChangeTracked
@JoinColumn(name = "inntektsmeldinger_id", updatable = false, unique = true)
Expand Down Expand Up @@ -105,7 +96,6 @@ private InntektArbeidYtelseGrunnlag() {

// NB! skal ikke lage ny versjon av oppgitt opptjening! Lenker bare inn
grunnlag.getOppgittOpptjening().ifPresent(kopiAvOppgittOpptjening -> this.setOppgittOpptjening(kopiAvOppgittOpptjening));
grunnlag.getOppgittOpptjeningAggregat().ifPresent(kopiAvAggregat -> this.setOppgittOpptjeningAggregat(kopiAvAggregat));

grunnlag.getOverstyrtOppgittOpptjening().ifPresent(this::setOverstyrtOppgittOpptjening);
grunnlag.getRegisterVersjon().ifPresent(nyRegisterVerson -> this.setRegister(nyRegisterVerson));
Expand Down Expand Up @@ -201,14 +191,6 @@ void setOverstyrtOppgittOpptjening(OppgittOpptjening overstyrtOppgittOpptjening)
this.overstyrtOppgittOpptjening = overstyrtOppgittOpptjening;
}

public Optional<OppgittOpptjeningAggregat> getOppgittOpptjeningAggregat() {
return Optional.ofNullable(oppgittOpptjeningAggregat);
}

void setOppgittOpptjeningAggregat(OppgittOpptjeningAggregat oppgittOpptjeningAggregat) {
this.oppgittOpptjeningAggregat = oppgittOpptjeningAggregat;
}

void setKobling(Long koblingId) {
if (this.koblingId != null && !Objects.equals(this.koblingId, koblingId)) {
throw new IllegalStateException(String.format("Kan ikke overskrive koblingId %s: %s", this.koblingId, koblingId));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,16 +6,14 @@
import java.util.Set;
import java.util.UUID;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import no.nav.abakus.iaygrunnlag.request.Dataset;
import no.nav.foreldrepenger.abakus.domene.iay.arbeidsforhold.ArbeidsforholdInformasjon;
import no.nav.foreldrepenger.abakus.domene.iay.arbeidsforhold.ArbeidsforholdInformasjonBuilder;
import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittOpptjening;
import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittOpptjeningAggregat;
import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittOpptjeningBuilder;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class InntektArbeidYtelseGrunnlagBuilder {
private static final Logger LOG = LoggerFactory.getLogger(InntektArbeidYtelseGrunnlagBuilder.class);

Expand Down Expand Up @@ -50,9 +48,6 @@ public static InntektArbeidYtelseGrunnlagBuilder kopierDeler(InntektArbeidYtelse
if (skalIkkeKopierMed(dataset, Dataset.OPPGITT_OPPTJENING)) {
kladd.setOppgittOpptjening(null);
}
if (skalIkkeKopierMed(dataset, Dataset.OPPGITT_OPPTJENING_V2)) {
kladd.setOppgittOpptjeningAggregat(null);
}
if (skalIkkeKopierMed(dataset, Dataset.OVERSTYRT_OPPGITT_OPPTJENING)) {
kladd.setOverstyrtOppgittOpptjening(null);
}
Expand Down Expand Up @@ -145,50 +140,19 @@ public InntektArbeidYtelseGrunnlagBuilder medOppgittOpptjening(OppgittOpptjening
if (kladd.getOppgittOpptjening().isPresent()) {
LOG.info("Erstatter eksisterende oppgitt opptjening");
}
if (kladd.getOppgittOpptjeningAggregat().isPresent()) {
throw new IllegalStateException(
"Utviklerfeil: Har allerede lagt inn oppgitt oppptjening på aggregat. Kan da ikke legge til oppgitt opptjening utenom aggregat.");
}
kladd.setOppgittOpptjening(builder.build());
}
return this;
}

public InntektArbeidYtelseGrunnlagBuilder leggTilOppgittOpptjening(OppgittOpptjeningBuilder builder) {
if (builder != null) {
if (kladd.getOppgittOpptjening().isPresent()) {
throw new IllegalStateException(
"Utviklerfeil: Har allerede lagt inn oppgitt opptjening utenom aggregat. Kan da ikke legge til oppgitt opptjening på aggregat i tillegg.");
}
OppgittOpptjening oppgittOpptjening = builder.build();
if (oppgittOpptjening.getJournalpostId() == null) {
throw new IllegalStateException("Utviklerfeil: Legg-til krever journalpostId.");
}
Optional<OppgittOpptjeningAggregat> gammel = kladd.getOppgittOpptjeningAggregat();
OppgittOpptjeningAggregat aggregat = gammel.isPresent() ? OppgittOpptjeningAggregat.oppdater(gammel.get(),
oppgittOpptjening) : OppgittOpptjeningAggregat.ny(oppgittOpptjening);

kladd.setOppgittOpptjeningAggregat(aggregat);
}
return this;
}

public InntektArbeidYtelseGrunnlagBuilder medOverstyrtOppgittOpptjening(OppgittOpptjeningBuilder builder) {
if (builder != null) {
kladd.setOverstyrtOppgittOpptjening(builder.build());
if (kladd.getOppgittOpptjeningAggregat().isPresent()) {
throw new IllegalStateException(
"Sanity check: Har allerede lagt inn oppgitt oppptjening på aggregat. Du vil da sannsynligvis ikke overstyre slik.");
}
}
return this;
}

public InntektArbeidYtelseGrunnlagBuilder fjernOverstyrtOppgittOpptjening() {
if (kladd.getOppgittOpptjeningAggregat().isPresent()) {
throw new IllegalStateException(
"Sanity check: Har allerede lagt inn oppgitt oppptjening på aggregat. Du vil da sannsynligvis ikke overstyre slik.");
}
kladd.setOverstyrtOppgittOpptjening(null);
return this;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@
import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittEgenNæring;
import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittFrilansoppdrag;
import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittOpptjening;
import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittOpptjeningAggregat;
import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittOpptjeningBuilder;
import no.nav.foreldrepenger.abakus.felles.diff.DiffResult;
import no.nav.foreldrepenger.abakus.kobling.Kobling;
Expand Down Expand Up @@ -303,20 +302,6 @@ public GrunnlagReferanse lagreOgNullstillOverstyring(KoblingReferanse koblingRef
return build.getGrunnlagReferanse();
}

public GrunnlagReferanse lagrePrJournalpostId(KoblingReferanse koblingReferanse, OppgittOpptjeningBuilder oppgittOpptjening) {
if (oppgittOpptjening == null) {
return null;
}
Optional<InntektArbeidYtelseGrunnlag> iayGrunnlag = hentInntektArbeidYtelseGrunnlagForBehandling(koblingReferanse);

InntektArbeidYtelseGrunnlagBuilder grunnlag = InntektArbeidYtelseGrunnlagBuilder.oppdatere(iayGrunnlag);
grunnlag.leggTilOppgittOpptjening(oppgittOpptjening);

InntektArbeidYtelseGrunnlag build = grunnlag.build();
lagreOgFlush(koblingReferanse, build);
return build.getGrunnlagReferanse();
}

public GrunnlagReferanse lagreOverstyring(KoblingReferanse koblingReferanse, OppgittOpptjeningBuilder overstyrOppgittOpptjening) {
if (overstyrOppgittOpptjening == null) {
return null;
Expand Down Expand Up @@ -421,13 +406,6 @@ public Set<JournalpostId> oppdaterBuilderMedNyeInntektsmeldinger(ArbeidsforholdI
return utdaterteInntektsmeldinger;
}

private InntektArbeidYtelseGrunnlagBuilder getGrunnlagBuilder(KoblingReferanse koblingReferanse, InntektArbeidYtelseAggregatBuilder builder) {
Objects.requireNonNull(builder, "inntektArbeidYtelserBuilder");
InntektArbeidYtelseGrunnlagBuilder opptjeningAggregatBuilder = opprettGrunnlagBuilderFor(koblingReferanse);
opptjeningAggregatBuilder.medData(builder);
return opptjeningAggregatBuilder;
}

private InntektArbeidYtelseGrunnlagBuilder opprettGrunnlagBuilderFor(KoblingReferanse koblingReferanse) {
Optional<InntektArbeidYtelseGrunnlag> inntektArbeidAggregat = hentInntektArbeidYtelseGrunnlagForBehandling(koblingReferanse);
return InntektArbeidYtelseGrunnlagBuilder.oppdatere(inntektArbeidAggregat);
Expand Down Expand Up @@ -520,7 +498,6 @@ private void lagreGrunnlag(InntektArbeidYtelseGrunnlag nyttGrunnlag, KoblingRefe

nyttGrunnlag.getOppgittOpptjening().ifPresent(this::lagreOppgittOpptjening);
nyttGrunnlag.getOverstyrtOppgittOpptjening().ifPresent(this::lagreOppgittOpptjening);
nyttGrunnlag.getOppgittOpptjeningAggregat().ifPresent(this::lagreOppgitteOpptjeninger);

var registerVersjon = entitet.getRegisterVersjon();
registerVersjon.ifPresent(this::lagreInntektArbeid);
Expand All @@ -534,11 +511,6 @@ private void lagreGrunnlag(InntektArbeidYtelseGrunnlag nyttGrunnlag, KoblingRefe
entityManager.persist(nyttGrunnlag);
}

private void lagreOppgitteOpptjeninger(OppgittOpptjeningAggregat oppgittOpptjeningAggregat) {
entityManager.persist(oppgittOpptjeningAggregat);
oppgittOpptjeningAggregat.getOppgitteOpptjeninger().forEach(this::lagreOppgittOpptjening);
}

private void lagreInformasjon(ArbeidsforholdInformasjon data) {

// va
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,21 +9,18 @@
import java.util.UUID;
import java.util.stream.Collectors;

import org.hibernate.annotations.Immutable;
import org.hibernate.annotations.NaturalId;

import jakarta.persistence.Column;
import jakarta.persistence.Embedded;
import jakarta.persistence.Entity;
import jakarta.persistence.GeneratedValue;
import jakarta.persistence.GenerationType;
import jakarta.persistence.Id;
import jakarta.persistence.JoinColumn;
import jakarta.persistence.ManyToOne;
import jakarta.persistence.OneToMany;
import jakarta.persistence.OneToOne;
import jakarta.persistence.Table;

import org.hibernate.annotations.Immutable;
import org.hibernate.annotations.NaturalId;

import no.nav.foreldrepenger.abakus.felles.diff.ChangeTracked;
import no.nav.foreldrepenger.abakus.felles.diff.DiffIgnore;
import no.nav.foreldrepenger.abakus.felles.jpa.BaseEntitet;
Expand All @@ -38,13 +35,6 @@ public class OppgittOpptjening extends BaseEntitet {
@GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "SEQ_SO_OPPGITT_OPPTJENING")
private Long id;

/**
* nullable - denne er kun i bruk når det lagres på aggregat ( se /v2/motta-endepunktet )
*/
@ManyToOne
@JoinColumn(name = "oppgitte_opptjeninger_id", updatable = false)
private OppgittOpptjeningAggregat oppgitteOpptjeninger;

@NaturalId
@DiffIgnore
@Column(name = "ekstern_referanse", updatable = false, unique = true)
Expand Down Expand Up @@ -113,10 +103,6 @@ public OppgittOpptjening(OppgittOpptjening orginal) {
}).orElse(null);
}

void setOppgitteOpptjeninger(OppgittOpptjeningAggregat oppgitteOpptjeninger) {
this.oppgitteOpptjeninger = oppgitteOpptjeninger;
}

public List<OppgittArbeidsforhold> getOppgittArbeidsforhold() {
if (this.oppgittArbeidsforhold == null) {
return Collections.emptyList();
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
@@ -1,13 +1,12 @@
package no.nav.foreldrepenger.abakus.iay;

import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject;
import no.nav.foreldrepenger.abakus.domene.iay.GrunnlagReferanse;
import no.nav.foreldrepenger.abakus.domene.iay.InntektArbeidYtelseRepository;
import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittOpptjeningBuilder;
import no.nav.foreldrepenger.abakus.kobling.KoblingReferanse;

import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject;

@ApplicationScoped
public class OppgittOpptjeningTjeneste {

Expand All @@ -32,8 +31,4 @@ public GrunnlagReferanse lagreOgNullstillOverstyring(KoblingReferanse koblingRef
public GrunnlagReferanse lagreOverstyring(KoblingReferanse koblingReferanse, OppgittOpptjeningBuilder builder) {
return repository.lagreOverstyring(koblingReferanse, builder);
}

public GrunnlagReferanse lagrePrJournalpostId(KoblingReferanse koblingReferanse, OppgittOpptjeningBuilder builder) {
return repository.lagrePrJournalpostId(koblingReferanse, builder);
}
}
Loading

0 comments on commit b974494

Please sign in to comment.