TSFF-1095: Reduksjon inntekt (#152)

* FIX: Refaktorering av uttak, deler opp i meir tydelige steg

* Lager egne vurderere per regel

* Legger til regel for reduksjon ved innrapportert inntekt

* Legger på javadoc

* Bytter rekkefølge på avslag ved død og innvilgelse

* Test for reduksjon

* Mapper rapporterte inntekter

* Bruker statiske datoer i test

* Legger til behandlingsårsak i perioder til vurdering utleder

* Endringer etter QA:
Gjer regelvurderere uavhengig av kvarandre

* Legger nokDagerTidslinje inn i Avslagsvurderer

* Legger til kommentarer

Author: espenjv

behandlingslager/domene/src/main/java/no/nav/ung/sak/behandlingslager/ytelse/uttak/UngdomsytelseUttakPeriode.java

@@ -3,6 +3,7 @@
 import java.math.BigDecimal;
 import java.time.LocalDate;
 
+import no.nav.fpsak.tidsserie.LocalDateInterval;
 import org.hibernate.annotations.Type;
 
 import jakarta.persistence.Column;
@@ -53,6 +54,12 @@ public UngdomsytelseUttakPeriode(BigDecimal utbetalingsgrad,
         this.periode = periode.toRange();
     }
 
+    public UngdomsytelseUttakPeriode(LocalDate fom, LocalDate tom, BigDecimal utbetalingsgrad, UngdomsytelseUttakAvslagsårsak avslagsårsak) {
+        this.periode = Range.closed(fom, tom);
+        this.utbetalingsgrad = utbetalingsgrad;
+        this.avslagsårsak = avslagsårsak;
+    }
+
     public UngdomsytelseUttakPeriode(UngdomsytelseUttakAvslagsårsak avslagsårsak,
                                      DatoIntervallEntitet periode) {
         this.utbetalingsgrad = BigDecimal.ZERO;

behandlingsprosess/src/main/java/no/nav/ung/sak/domene/behandling/steg/uttak/RapportertInntektMapper.java

@@ -0,0 +1,94 @@
+package no.nav.ung.sak.domene.behandling.steg.uttak;
+
+import jakarta.enterprise.context.Dependent;
+import jakarta.inject.Inject;
+import no.nav.fpsak.tidsserie.LocalDateSegment;
+import no.nav.fpsak.tidsserie.LocalDateTimeline;
+import no.nav.fpsak.tidsserie.StandardCombinators;
+import no.nav.ung.sak.domene.arbeidsforhold.InntektArbeidYtelseTjeneste;
+import no.nav.ung.sak.domene.behandling.steg.uttak.regler.InntektType;
+import no.nav.ung.sak.domene.behandling.steg.uttak.regler.RapportertInntekt;
+import no.nav.ung.sak.domene.iay.modell.InntektArbeidYtelseGrunnlag;
+import no.nav.ung.sak.domene.iay.modell.OppgittOpptjening;
+import org.jetbrains.annotations.NotNull;
+
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.Comparator;
+import java.util.List;
+import java.util.Set;
+
+@Dependent
+public class RapportertInntektMapper {
+
+    private InntektArbeidYtelseTjeneste inntektArbeidYtelseTjeneste;
+
+    @Inject
+    public RapportertInntektMapper(InntektArbeidYtelseTjeneste inntektArbeidYtelseTjeneste) {
+        this.inntektArbeidYtelseTjeneste = inntektArbeidYtelseTjeneste;
+    }
+
+    public LocalDateTimeline<Set<RapportertInntekt>> map(Long behandlingId) {
+        // Henter iay-grunnlag (kall til abakus)
+        final var iayGrunnlag = inntektArbeidYtelseTjeneste.hentGrunnlag(behandlingId);
+        // Finner rapporterte inntekter pr journalpost sortert på mottattdato med siste mottatt journalpost først
+        final var sorterteInntekttidslinjerPåMottattdato = finnSorterteInntektstidslinjer(iayGrunnlag);
+
+        var resultatTidslinje = new LocalDateTimeline<Set<RapportertInntekt>>(List.of());
+        for (InntektForMottattidspunkt journalpostMedInntekttidslinje : sorterteInntekttidslinjerPåMottattdato) {
+            // Dersom vi ikke allerede har lagt til en rapportert inntekt for perioden legger vi den til i resultattidslinjen
+            if (!resultatTidslinje.intersects(journalpostMedInntekttidslinje.tidslinje())) {
+                // Trenger ikkje å håndtere overlapp sidan vi aldri går inn her med overlapp
+                resultatTidslinje = resultatTidslinje.crossJoin(journalpostMedInntekttidslinje.tidslinje());
+            }
+        }
+
+        return resultatTidslinje;
+    }
+
+    private List<InntektForMottattidspunkt> finnSorterteInntektstidslinjer(InntektArbeidYtelseGrunnlag iayGrunnlag) {
+        return iayGrunnlag.getOppgittOpptjeningAggregat()
+            .stream()
+            .flatMap(o -> o.getOppgitteOpptjeninger().stream().map(RapportertInntektMapper::finnInntekterPrMottattidspunkt))
+            .sorted(Comparator.reverseOrder())
+            .toList();
+    }
+
+    private static InntektForMottattidspunkt finnInntekterPrMottattidspunkt(OppgittOpptjening o) {
+        final var res = new ArrayList<LocalDateSegment<Set<RapportertInntekt>>>();
+        res.addAll(finnArbeidOgFrilansSegmenter(o));
+        res.addAll(finnNæringssegmenter(o));
+        return new InntektForMottattidspunkt(o.getInnsendingstidspunkt(), new LocalDateTimeline<>(res, StandardCombinators::union));
+    }
+
+    private static List<LocalDateSegment<Set<RapportertInntekt>>> finnNæringssegmenter(OppgittOpptjening o) {
+        return o.getEgenNæring().stream()
+            .map(it -> new LocalDateSegment<>(
+                it.getPeriode().toLocalDateInterval(),
+                Set.of(new RapportertInntekt(
+                    InntektType.SELVSTENDIG_NÆRINGSDRIVENDE,
+                    it.getBruttoInntekt())
+                ))).toList();
+    }
+
+    private static List<LocalDateSegment<Set<RapportertInntekt>>> finnArbeidOgFrilansSegmenter(OppgittOpptjening o) {
+        return o.getOppgittArbeidsforhold().stream()
+            .map(it -> new LocalDateSegment<>(
+                it.getPeriode().toLocalDateInterval(),
+                Set.of(new RapportertInntekt(
+                    InntektType.ARBEIDSTAKER_ELLER_FRILANSER,
+                    it.getInntekt())
+                ))).toList();
+    }
+
+    private record InntektForMottattidspunkt(LocalDateTime mottattTidspunkt,
+                                             LocalDateTimeline<Set<RapportertInntekt>> tidslinje
+    ) implements Comparable<InntektForMottattidspunkt> {
+
+        @Override
+        public int compareTo(@NotNull InntektForMottattidspunkt o) {
+            return this.mottattTidspunkt.compareTo(o.mottattTidspunkt);
+        }
+    }
+
+}

behandlingsprosess/src/main/java/no/nav/ung/sak/domene/behandling/steg/uttak/UttaksperiodeMapper.java

@@ -0,0 +1,62 @@
+package no.nav.ung.sak.domene.behandling.steg.uttak;
+
+import no.nav.fpsak.tidsserie.LocalDateInterval;
+import no.nav.fpsak.tidsserie.LocalDateSegment;
+import no.nav.fpsak.tidsserie.LocalDateSegmentCombinator;
+import no.nav.fpsak.tidsserie.LocalDateTimeline;
+import no.nav.ung.kodeverk.ungdomsytelse.uttak.UngdomsytelseUttakAvslagsårsak;
+import no.nav.ung.sak.behandlingslager.ytelse.uttak.UngdomsytelseUttakPeriode;
+import no.nav.ung.sak.domene.behandling.steg.uttak.regler.UttakResultat;
+
+import java.util.List;
+
+public class UttaksperiodeMapper {
+
+    static List<UngdomsytelseUttakPeriode> mapTilUttaksperioder(List<LocalDateTimeline<UttakResultat>> uttakstidslinjer) {
+        return uttakstidslinjer.stream()
+            .reduce(UttaksperiodeMapper::kombinerTidslinjer)
+            .orElse(LocalDateTimeline.empty())
+            .compress()
+            .stream()
+            .map(s -> new UngdomsytelseUttakPeriode(s.getFom(), s.getTom(), s.getValue().utbetalingsgrad(), s.getValue().avslagsårsak()))
+            .toList();
+    }
+
+    private static LocalDateTimeline<UttakResultat> kombinerTidslinjer(LocalDateTimeline<UttakResultat> t1, LocalDateTimeline<UttakResultat> t2) {
+        return t1.combine(t2, kombinerUttaksresultater(), LocalDateTimeline.JoinStyle.CROSS_JOIN);
+    }
+
+    private static LocalDateSegmentCombinator<UttakResultat, UttakResultat, UttakResultat> kombinerUttaksresultater() {
+        return (di, lhs, rhs) -> {
+            // Hvis en av segmentene er null, bruk det andre
+            if (lhs == null) {
+                return new LocalDateSegment<>(di, rhs.getValue());
+            } else if (rhs == null) {
+                return new LocalDateSegment<>(di, lhs.getValue());
+            }
+
+            // Hvis begge segmentene er avslått, velg den høyest prioriterte avslagsårsaken
+            if (lhs.getValue().avslagsårsak() != null && rhs.getValue().avslagsårsak() != null) {
+                return velgPrioritertAvslagsårsak(di, lhs, rhs);
+            }
+
+            // Hvis ett av segmentene er avslått, bruk dette
+            if (lhs.getValue().avslagsårsak() != null) {
+                return new LocalDateSegment<>(di, lhs.getValue());
+            } else if (rhs.getValue().avslagsårsak() != null) {
+                return new LocalDateSegment<>(di, rhs.getValue());
+            }
+
+            // Forventer ikke å ha to regler som begge gir innvilget i samme periode
+            throw new IllegalStateException("Fant to overlappende segmenter for innvilgelse");
+        };
+    }
+
+    private static LocalDateSegment<UttakResultat> velgPrioritertAvslagsårsak(LocalDateInterval di, LocalDateSegment<UttakResultat> lhs, LocalDateSegment<UttakResultat> rhs) {
+        if (lhs.getValue().avslagsårsak().equals(UngdomsytelseUttakAvslagsårsak.SØKERS_DØDSFALL) || rhs.getValue().avslagsårsak().equals(UngdomsytelseUttakAvslagsårsak.SØKERS_DØDSFALL)) {
+            return new LocalDateSegment<>(di, UttakResultat.forAvslag(UngdomsytelseUttakAvslagsårsak.SØKERS_DØDSFALL));
+        } else {
+            return new LocalDateSegment<>(di, UttakResultat.forAvslag(lhs.getValue().avslagsårsak()));
+        }
+    }
+}