Skip to content

Commit

Permalink
Fjerner splitt-dato for ny inntekt (#553)
Browse files Browse the repository at this point in the history
  • Loading branch information
@espenjv
espenjv authored Oct 1, 2024
1 parent 1c62770 commit f1b13f4
Show file tree
Hide file tree
Showing 2 changed files with 101 additions and 109 deletions.
3 changes: 1 addition & 2 deletions ...olketrygdloven/kalkulator/felles/inntektgradering/SimulerGraderingMotInntektTjeneste.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -77,9 +77,8 @@ public List<Intervall> finnTilkommetAktivitetPerioder(BeregningsgrunnlagInput be
beregningsgrunnlagInput.getIayGrunnlag()
);
var tidlinjeMedTilkommetAktivitet = tilkommetTidslinje.filterValue(v -> !v.isEmpty()).compress();
var redusertTidslinje = tidlinjeMedTilkommetAktivitet.intersection(new LocalDateInterval(TilkommetInntektPeriodeTjeneste.FOM_DATO_GRADERING_MOT_INNTEKT, LocalDateInterval.TIDENES_ENDE));

return redusertTidslinje.toSegments().stream()
return tidlinjeMedTilkommetAktivitet.toSegments().stream()
.map(s -> Intervall.fraOgMedTilOgMed(s.getFom(), s.getTom()))
.toList();
}
Expand Down
207 changes: 100 additions & 107 deletions ...nav/folketrygdloven/kalkulator/steg/tilkommetInntekt/TilkommetInntektPeriodeTjeneste.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@

import static no.nav.folketrygdloven.kalkulator.felles.periodesplitting.TidslinjeUtils.opprettTidslinje;

import java.time.LocalDate;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Comparator;
Expand Down Expand Up @@ -40,112 +39,106 @@
*/
public class TilkommetInntektPeriodeTjeneste {

/**
* Det er bestemt at gradering mot inntekt ved tilkommet aktivitet skal gjelde perioder fom 4.11.2024.
*/
public static final LocalDate FOM_DATO_GRADERING_MOT_INNTEKT = LocalDate.of(2024, 11, 4);

public BeregningsgrunnlagDto splittPerioderVedTilkommetInntekt(BeregningsgrunnlagInput input, BeregningsgrunnlagDto beregningsgrunnlag) {
if (!(input.getYtelsespesifiktGrunnlag() instanceof UtbetalingsgradGrunnlag ytelseGrunnlag)) {
return beregningsgrunnlag;
}

var tilkommetAktivitetTidslinje = TilkommetInntektsforholdTjeneste.finnTilkommetInntektsforholdTidslinje(
beregningsgrunnlag.getSkjæringstidspunkt(),
beregningsgrunnlag.getBeregningsgrunnlagPerioder().get(0).getBeregningsgrunnlagPrStatusOgAndelList(),
input.getYtelsespesifiktGrunnlag(),
input.getIayGrunnlag()
);
var tidlinjeMedTilkommetAktivitet = tilkommetAktivitetTidslinje.filterValue(v -> !v.isEmpty())
.combine(opprettTidslinje(input.getForlengelseperioder()), StandardCombinators::leftOnly, input.getForlengelseperioder().isEmpty() ? LocalDateTimeline.JoinStyle.LEFT_JOIN : LocalDateTimeline.JoinStyle.INNER_JOIN)
.combine(new LocalDateSegment<>(new LocalDateInterval(FOM_DATO_GRADERING_MOT_INNTEKT, LocalDateInterval.TIDENES_ENDE), Boolean.TRUE), StandardCombinators::leftOnly, LocalDateTimeline.JoinStyle.LEFT_JOIN);

if (ytelseGrunnlag.getTilkommetInntektHensyntasFom().isPresent()) {
tidlinjeMedTilkommetAktivitet = tidlinjeMedTilkommetAktivitet.combine(new LocalDateSegment<>(new LocalDateInterval(ytelseGrunnlag.getTilkommetInntektHensyntasFom().get(), LocalDateInterval.TIDENES_ENDE), Boolean.TRUE), StandardCombinators::leftOnly, LocalDateTimeline.JoinStyle.INNER_JOIN);
} else if (!tidlinjeMedTilkommetAktivitet.isEmpty()) {
throw new IllegalStateException("Hadde ikke startdato for nye regler, men fikk tilkommet inntekt");
}

PeriodeSplitter<Set<StatusOgArbeidsgiver>> periodeSplitter = getPeriodeSplitter(input);
return periodeSplitter.splittPerioder(beregningsgrunnlag, tidlinjeMedTilkommetAktivitet);
}

private PeriodeSplitter<Set<StatusOgArbeidsgiver>> getPeriodeSplitter(BeregningsgrunnlagInput input) {
var splittPerioderConfig = new SplittPeriodeConfig<>(
TilkommetInntektPeriodeTjeneste::opprettTilkommetInntekt,
StandardPeriodeSplittMappers.settAvsluttetPeriodeårsak(input.getForlengelseperioder(), PeriodeÅrsak.TILKOMMET_INNTEKT_AVSLUTTET));
splittPerioderConfig.setAbutsPredikatForCompress((di1, di2) -> di1.abuts(di2) && !di2.getFomDato().equals(FOM_DATO_GRADERING_MOT_INNTEKT));
return new PeriodeSplitter<>(splittPerioderConfig);
}


public static LocalDateSegment<BeregningsgrunnlagPeriodeDto> opprettTilkommetInntekt(LocalDateInterval di,
LocalDateSegment<BeregningsgrunnlagPeriodeDto> lhs,
LocalDateSegment<Set<StatusOgArbeidsgiver>> rhs) {
if (lhs != null && rhs != null) {
var nyPeriode = BeregningsgrunnlagPeriodeDto.kopier(lhs.getValue())
.leggTilPeriodeÅrsak(PeriodeÅrsak.TILKOMMET_INNTEKT)
.medBeregningsgrunnlagPeriode(di.getFomDato(), di.getTomDato());
mapTilkomneInntekter(lhs.getValue(), rhs.getValue().stream().sorted(Comparator.naturalOrder()).collect(Collectors.toCollection(LinkedHashSet::new))).forEach(nyPeriode::leggTilTilkommetInntekt);
return new LocalDateSegment<>(di, nyPeriode.build());
} else if (lhs != null) {
var nyPeriode = BeregningsgrunnlagPeriodeDto.kopier(lhs.getValue())
.medBeregningsgrunnlagPeriode(di.getFomDato(), di.getTomDato())
.build();
return new LocalDateSegment<>(di, nyPeriode);
}
return null;
}


private static List<TilkommetInntektDto> mapTilkomneInntekter(BeregningsgrunnlagPeriodeDto periode, Set<StatusOgArbeidsgiver> nyeInntektsforhold) {
var innteksforholdListe = new ArrayList<TilkommetInntektDto>();
innteksforholdListe.addAll(mapAndelerTilInntektsforholdDto(periode, nyeInntektsforhold));
innteksforholdListe.addAll(mapResterendeUtenAndel(nyeInntektsforhold, innteksforholdListe));
return innteksforholdListe;
}


private static Set<TilkommetInntektDto> mapResterendeUtenAndel(Set<StatusOgArbeidsgiver> nyeInntektsforholdListe,
Collection<TilkommetInntektDto> tilkomneInntektsforhold) {
var tilkomneInntekterUtenAndel = finnTilkomneUtenAndel(nyeInntektsforholdListe, tilkomneInntektsforhold);
return tilkomneInntekterUtenAndel.stream()
.map(it -> new TilkommetInntektDto(it.aktivitetStatus(), it.arbeidsgiver(), InternArbeidsforholdRefDto.nullRef()))
.collect(Collectors.toSet());
}

private static List<StatusOgArbeidsgiver> finnTilkomneUtenAndel(Set<StatusOgArbeidsgiver> nyeInntektsforholdListe,
Collection<TilkommetInntektDto> tilkomneInntektsforhold) {
return nyeInntektsforholdListe.stream()
.filter(it -> tilkomneInntektsforhold.stream().noneMatch(ti -> ti.getAktivitetStatus().equals(it.aktivitetStatus()) &&
Objects.equals(ti.getArbeidsgiver().orElse(null), it.arbeidsgiver())))
.toList();
}

private static Set<TilkommetInntektDto> mapAndelerTilInntektsforholdDto(BeregningsgrunnlagPeriodeDto periode,
Set<StatusOgArbeidsgiver> nyeInntektsforholdListe) {
return periode.getBeregningsgrunnlagPrStatusOgAndelList()
.stream()
.filter(a -> erNyttArbeidsforhold(nyeInntektsforholdListe, a))
.map(TilkommetInntektPeriodeTjeneste::mapTilInntektsforhold)
.collect(Collectors.toCollection(HashSet::new));
}

private static boolean erNyttArbeidsforhold(Set<StatusOgArbeidsgiver> nyeInntektsforholdListe, BeregningsgrunnlagPrStatusOgAndelDto a) {
return finnMatchendeNyttInntektsforhold(nyeInntektsforholdListe, a).isPresent();
}

private static Optional<StatusOgArbeidsgiver> finnMatchendeNyttInntektsforhold(Set<StatusOgArbeidsgiver> nyeInntektsforholdListe, BeregningsgrunnlagPrStatusOgAndelDto a) {
return nyeInntektsforholdListe.stream().filter(sa -> sa.aktivitetStatus().equals(a.getAktivitetStatus()) &&
Objects.equals(sa.arbeidsgiver(), a.getArbeidsgiver().orElse(null))).findFirst();
}

private static TilkommetInntektDto mapTilInntektsforhold(BeregningsgrunnlagPrStatusOgAndelDto a) {
return new TilkommetInntektDto(
a.getAktivitetStatus(),
a.getArbeidsgiver().orElse(null),
a.getArbeidsforholdRef().orElse(InternArbeidsforholdRefDto.nullRef()));
}

public BeregningsgrunnlagDto splittPerioderVedTilkommetInntekt(BeregningsgrunnlagInput input, BeregningsgrunnlagDto beregningsgrunnlag) {
if (!(input.getYtelsespesifiktGrunnlag() instanceof UtbetalingsgradGrunnlag ytelseGrunnlag)) {
return beregningsgrunnlag;
}

var tilkommetAktivitetTidslinje = TilkommetInntektsforholdTjeneste.finnTilkommetInntektsforholdTidslinje(
beregningsgrunnlag.getSkjæringstidspunkt(),
beregningsgrunnlag.getBeregningsgrunnlagPerioder().get(0).getBeregningsgrunnlagPrStatusOgAndelList(),
input.getYtelsespesifiktGrunnlag(),
input.getIayGrunnlag()
);
var tidlinjeMedTilkommetAktivitet = tilkommetAktivitetTidslinje.filterValue(v -> !v.isEmpty())
.combine(opprettTidslinje(input.getForlengelseperioder()), StandardCombinators::leftOnly, input.getForlengelseperioder().isEmpty() ? LocalDateTimeline.JoinStyle.LEFT_JOIN : LocalDateTimeline.JoinStyle.INNER_JOIN);

if (ytelseGrunnlag.getTilkommetInntektHensyntasFom().isPresent()) {
tidlinjeMedTilkommetAktivitet = tidlinjeMedTilkommetAktivitet.combine(new LocalDateSegment<>(new LocalDateInterval(ytelseGrunnlag.getTilkommetInntektHensyntasFom().get(), LocalDateInterval.TIDENES_ENDE), Boolean.TRUE), StandardCombinators::leftOnly, LocalDateTimeline.JoinStyle.INNER_JOIN);
} else if (!tidlinjeMedTilkommetAktivitet.isEmpty()) {
throw new IllegalStateException("Hadde ikke startdato for nye regler, men fikk tilkommet inntekt");
}

PeriodeSplitter<Set<StatusOgArbeidsgiver>> periodeSplitter = getPeriodeSplitter(input);
return periodeSplitter.splittPerioder(beregningsgrunnlag, tidlinjeMedTilkommetAktivitet);
}

private PeriodeSplitter<Set<StatusOgArbeidsgiver>> getPeriodeSplitter(BeregningsgrunnlagInput input) {
var splittPerioderConfig = new SplittPeriodeConfig<>(
TilkommetInntektPeriodeTjeneste::opprettTilkommetInntekt,
StandardPeriodeSplittMappers.settAvsluttetPeriodeårsak(input.getForlengelseperioder(), PeriodeÅrsak.TILKOMMET_INNTEKT_AVSLUTTET));
return new PeriodeSplitter<>(splittPerioderConfig);
}


public static LocalDateSegment<BeregningsgrunnlagPeriodeDto> opprettTilkommetInntekt(LocalDateInterval di,
LocalDateSegment<BeregningsgrunnlagPeriodeDto> lhs,
LocalDateSegment<Set<StatusOgArbeidsgiver>> rhs) {
if (lhs != null && rhs != null) {
var nyPeriode = BeregningsgrunnlagPeriodeDto.kopier(lhs.getValue())
.leggTilPeriodeÅrsak(PeriodeÅrsak.TILKOMMET_INNTEKT)
.medBeregningsgrunnlagPeriode(di.getFomDato(), di.getTomDato());
mapTilkomneInntekter(lhs.getValue(), rhs.getValue().stream().sorted(Comparator.naturalOrder()).collect(Collectors.toCollection(LinkedHashSet::new))).forEach(nyPeriode::leggTilTilkommetInntekt);
return new LocalDateSegment<>(di, nyPeriode.build());
} else if (lhs != null) {
var nyPeriode = BeregningsgrunnlagPeriodeDto.kopier(lhs.getValue())
.medBeregningsgrunnlagPeriode(di.getFomDato(), di.getTomDato())
.build();
return new LocalDateSegment<>(di, nyPeriode);
}
return null;
}


private static List<TilkommetInntektDto> mapTilkomneInntekter(BeregningsgrunnlagPeriodeDto periode, Set<StatusOgArbeidsgiver> nyeInntektsforhold) {
var innteksforholdListe = new ArrayList<TilkommetInntektDto>();
innteksforholdListe.addAll(mapAndelerTilInntektsforholdDto(periode, nyeInntektsforhold));
innteksforholdListe.addAll(mapResterendeUtenAndel(nyeInntektsforhold, innteksforholdListe));
return innteksforholdListe;
}


private static Set<TilkommetInntektDto> mapResterendeUtenAndel(Set<StatusOgArbeidsgiver> nyeInntektsforholdListe,
Collection<TilkommetInntektDto> tilkomneInntektsforhold) {
var tilkomneInntekterUtenAndel = finnTilkomneUtenAndel(nyeInntektsforholdListe, tilkomneInntektsforhold);
return tilkomneInntekterUtenAndel.stream()
.map(it -> new TilkommetInntektDto(it.aktivitetStatus(), it.arbeidsgiver(), InternArbeidsforholdRefDto.nullRef()))
.collect(Collectors.toSet());
}

private static List<StatusOgArbeidsgiver> finnTilkomneUtenAndel(Set<StatusOgArbeidsgiver> nyeInntektsforholdListe,
Collection<TilkommetInntektDto> tilkomneInntektsforhold) {
return nyeInntektsforholdListe.stream()
.filter(it -> tilkomneInntektsforhold.stream().noneMatch(ti -> ti.getAktivitetStatus().equals(it.aktivitetStatus()) &&
Objects.equals(ti.getArbeidsgiver().orElse(null), it.arbeidsgiver())))
.toList();
}

private static Set<TilkommetInntektDto> mapAndelerTilInntektsforholdDto(BeregningsgrunnlagPeriodeDto periode,
Set<StatusOgArbeidsgiver> nyeInntektsforholdListe) {
return periode.getBeregningsgrunnlagPrStatusOgAndelList()
.stream()
.filter(a -> erNyttArbeidsforhold(nyeInntektsforholdListe, a))
.map(TilkommetInntektPeriodeTjeneste::mapTilInntektsforhold)
.collect(Collectors.toCollection(HashSet::new));
}

private static boolean erNyttArbeidsforhold(Set<StatusOgArbeidsgiver> nyeInntektsforholdListe, BeregningsgrunnlagPrStatusOgAndelDto a) {
return finnMatchendeNyttInntektsforhold(nyeInntektsforholdListe, a).isPresent();
}

private static Optional<StatusOgArbeidsgiver> finnMatchendeNyttInntektsforhold(Set<StatusOgArbeidsgiver> nyeInntektsforholdListe, BeregningsgrunnlagPrStatusOgAndelDto a) {
return nyeInntektsforholdListe.stream().filter(sa -> sa.aktivitetStatus().equals(a.getAktivitetStatus()) &&
Objects.equals(sa.arbeidsgiver(), a.getArbeidsgiver().orElse(null))).findFirst();
}

private static TilkommetInntektDto mapTilInntektsforhold(BeregningsgrunnlagPrStatusOgAndelDto a) {
return new TilkommetInntektDto(
a.getAktivitetStatus(),
a.getArbeidsgiver().orElse(null),
a.getArbeidsforholdRef().orElse(InternArbeidsforholdRefDto.nullRef()));
}


}

0 comments on commit f1b13f4

Please sign in to comment.