Forenkler tidslinjer

navikt · Oct 29, 2024 · 42e72f2 · 42e72f2
1 parent 32a621e
commit 42e72f2
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 4 deletions.
diff --git a/...nav/folketrygdloven/kalkulator/steg/tilkommetInntekt/TilkommetInntektPeriodeTjeneste.java b/...nav/folketrygdloven/kalkulator/steg/tilkommetInntekt/TilkommetInntektPeriodeTjeneste.java
@@ -55,7 +55,7 @@ public BeregningsgrunnlagDto splittPerioderVedTilkommetInntekt(Beregningsgrunnla
 				.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);
+			tidlinjeMedTilkommetAktivitet = tidlinjeMedTilkommetAktivitet.intersection(new LocalDateInterval(ytelseGrunnlag.getTilkommetInntektHensyntasFom().get(), LocalDateInterval.TIDENES_ENDE));
 		} else if (!tidlinjeMedTilkommetAktivitet.isEmpty()) {
 			throw new IllegalStateException("Hadde ikke startdato for nye regler, men fikk tilkommet inntekt");
 		}

diff --git a/...av/folketrygdloven/kalkulator/steg/tilkommetInntekt/TilkommetInntektsforholdTjeneste.java b/...av/folketrygdloven/kalkulator/steg/tilkommetInntekt/TilkommetInntektsforholdTjeneste.java
@@ -110,8 +110,9 @@ private static LocalDateTimeline<Set<Inntektsforhold>> finnDagpengetidslinje(Inn
 	private static LocalDateTimeline<Boolean> finnTidslinjeForUtbetalingsperiode(UtbetalingsgradGrunnlag utbetalingsgradGrunnlag) {
 		return utbetalingsgradGrunnlag.getUtbetalingsgradPrAktivitet().stream()
 				.flatMap(a -> a.getPeriodeMedUtbetalingsgrad().stream())
-				.map(p -> new LocalDateSegment<>(p.getPeriode().getFomDato(), p.getPeriode().getTomDato(), Boolean.TRUE))
-				.collect(Collectors.collectingAndThen(Collectors.toList(), s -> new LocalDateTimeline<>(s, StandardCombinators::alwaysTrueForMatch)));
+				.map(p -> new LocalDateTimeline<>(p.getPeriode().getFomDato(), p.getPeriode().getTomDato(), true))
+				.reduce(LocalDateTimeline::crossJoin)
+				.orElse(LocalDateTimeline.empty());
 	}
 
 	private static List<LocalDateSegment<Set<StatusOgArbeidsgiver>>> mapTilkommetTidslinje(Collection<BeregningsgrunnlagPrStatusOgAndelDto> andeler,

diff --git a/...kalkulator/steg/fordeling/avklaringsbehov/AvklaringsbehovUtlederTilkommetInntektTest.java b/...kalkulator/steg/fordeling/avklaringsbehov/AvklaringsbehovUtlederTilkommetInntektTest.java
@@ -103,7 +103,7 @@ void skal_finne_tilkommet_andel_dersom_en_andel_fra_start_og_direkte_overgang_ut
 		assertThat(tilkomneAndeler.size()).isEqualTo(1);
 		assertThat(tilkomneAndeler.iterator().next().arbeidsgiver()).isEqualTo(arbeidsgiver2);
 	}
-	
+
 	@Test
 	void skal_finne_tilkommet_andel_dersom_en_andel_fra_start_med_overlapp_til_nytt_arbeid() {