Tar i bruk refusjonTom og graderer dagsats basert på utbetalingsgrad … (#1832)

espenjv · web-flow · commit 6e5005e3006f · 2022-03-22T08:47:49.000+01:00
* Tar i bruk refusjonTom og graderer dagsats basert på utbetalingsgrad i periode

* Mapper ikke inn selvstendig og frilans uten forsikring
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/domene/iay/YtelseAnvistAndel.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/domene/iay/YtelseAnvistAndel.java
@@ -47,6 +47,9 @@ public class YtelseAnvistAndel extends BaseEntitet implements IndexKey {
     @Embedded
     private InternArbeidsforholdRef arbeidsforholdRef;
 
+    /**
+     * Netto dagsats som tilsvarer grunnlagsdagsats * utbetalingsgrad
+     */
     @Embedded
     @AttributeOverrides(@AttributeOverride(name = "verdi", column = @Column(name = "dagsats", nullable = false)))
     @ChangeTracked
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/infotrygd/InfotrygdgrunnlagYtelseMapper.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/infotrygd/InfotrygdgrunnlagYtelseMapper.java
@@ -12,6 +12,9 @@
 import java.util.Set;
 import java.util.stream.Collectors;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import no.nav.abakus.iaygrunnlag.kodeverk.Arbeidskategori;
 import no.nav.abakus.iaygrunnlag.kodeverk.Fagsystem;
 import no.nav.abakus.iaygrunnlag.kodeverk.Inntektskategori;
@@ -33,6 +36,8 @@
 
 public class InfotrygdgrunnlagYtelseMapper {
 
+    private static final Logger LOGGER = LoggerFactory.getLogger(InfotrygdgrunnlagYtelseMapper.class);
+
     private InfotrygdgrunnlagYtelseMapper() {
     }
 
@@ -47,8 +52,12 @@ public static void oversettInfotrygdYtelseGrunnlagTilYtelse(InntektArbeidYtelseA
         grunnlag.getUtbetaltePerioder().forEach(vedtak -> {
             final IntervallEntitet intervall = utledPeriodeNårTomMuligFørFom(vedtak.getUtbetaltFom(), vedtak.getUtbetaltTom());
             var anvistBuilder = ytelseBuilder.getAnvistBuilder();
-            if (skalMappeInfotrygdandeler()) {
-                oversettYtelseArbeidTilAnvisteAndeler(grunnlag.getArbeidsforhold(), grunnlag.getKategori(), vedtak.getUtbetalingsgrad()).forEach(anvistBuilder::leggTilYtelseAnvistAndel);
+            if (skalMappeInfotrygdandeler(grunnlag)) {
+                oversettYtelseArbeidTilAnvisteAndeler(
+                    grunnlag.getArbeidsforhold(),
+                    grunnlag.getKategori(),
+                    intervall,
+                    vedtak.getUtbetalingsgrad()).forEach(anvistBuilder::leggTilYtelseAnvistAndel);
             }
             ytelseBuilder.leggtilYtelseAnvist(anvistBuilder
                 .medAnvistPeriode(intervall)
@@ -59,16 +68,36 @@ public static void oversettInfotrygdYtelseGrunnlagTilYtelse(InntektArbeidYtelseA
         aktørYtelseBuilder.leggTilYtelse(ytelseBuilder);
     }
 
-    private static boolean skalMappeInfotrygdandeler() {
-        return !Environment.current().isProd();
+
+    /**
+     * Næring og frilans uten forsikring har spesielle regler som gir reduksjon i netto dagsats som ikke reflekteres i utbetalingsgraden (se f.t.l. §§ 8-36 og 8-39)
+     * <p>
+     * Vi klarer ikke å representere dagsats nøyaktig for disse andelene
+     *
+     * @param grunnlag Beregningsgrunnlag fra infotrygd
+     * @return Verdi som sier som vi skal mappe inn andeler fra grunnlaget
+     */
+    private static boolean skalMappeInfotrygdandeler(InfotrygdYtelseGrunnlag grunnlag) {
+        var erToggletPå = !Environment.current().isProd();
+        return erToggletPå && !grunnlag.isNæringEllerFrilansUtenForsikring();
     }
 
-    private static List<YtelseAnvistAndel> oversettYtelseArbeidTilAnvisteAndeler(List<InfotrygdYtelseArbeid> arbeidsforhold, Arbeidskategori kategori, BigDecimal utbetalingsgrad) {
+    /** Mapper beregningsgrunnlagsandeler fra infotrygd til netto dagsats
+     *
+     * Netto dagsats = grunnlagsdasats * utbetalingsgrad
+     *
+     * @param arbeidsforhold Alle grunnlagsandeler fra infotrygd
+     * @param kategori Arbeidskategori fra infotrygd
+     * @param periode Periode for anvisning
+     * @param utbetalingsgrad Utbetalingsgrad for periode
+     * @return Liste med andeler
+     */
+    private static List<YtelseAnvistAndel> oversettYtelseArbeidTilAnvisteAndeler(List<InfotrygdYtelseArbeid> arbeidsforhold, Arbeidskategori kategori, IntervallEntitet periode, BigDecimal utbetalingsgrad) {
         var inntektskategorier = splittArbeidskategoriTilInntektskategorier(kategori);
         if (inntektskategorier.isEmpty()) {
             return Collections.emptyList();
         }
-        var andelBuildere = new ArrayList<>(finnArbeidstakerAndeler(arbeidsforhold, utbetalingsgrad));
+        var andelBuildere = new ArrayList<>(finnArbeidstakerAndeler(arbeidsforhold, utbetalingsgrad, periode));
         finnIkkeArbeidstakerAndel(arbeidsforhold, utbetalingsgrad, inntektskategorier).ifPresent(andelBuildere::add);
         finnYtelseRapportertPåNødnummer(arbeidsforhold, utbetalingsgrad, inntektskategorier).ifPresent(andelBuildere::add);
         return andelBuildere;
@@ -81,19 +110,31 @@ private static Optional<YtelseAnvistAndel> finnIkkeArbeidstakerAndel(List<Infotr
             .medUtbetalingsgrad(utbetalingsgrad)
             .medInntektskategori(i)
             .medRefusjonsgrad(BigDecimal.ZERO)
-            .medDagsats(finnDagsatsIkkeArbeidstaker(arbeidsforhold))
+            .medDagsats(finnDagsatsIkkeArbeidstaker(arbeidsforhold, utbetalingsgrad))
             .build()
         );
     }
 
+    /**
+     * Nødnummer brukes i infotrygd til å legge betalinger som skal gå direkte til bruker for et arbeidsforhold som det ikke er søkt refusjon for
+     *
+     *
+     * Dette brukes i situasjoner der det er kombinasjon med andre statuser.
+     *
+     * @param arbeidsforhold Infotrygdandeler
+     * @param utbetalingsgrad Utbetalingsgrad
+     * @param inntektskategorier Inntektskategorier på grunnlaget
+     * @return Ytelseandel fra nødnummer dersom den finnes
+     */
     private static Optional<YtelseAnvistAndel> finnYtelseRapportertPåNødnummer(List<InfotrygdYtelseArbeid> arbeidsforhold,
                                                                                BigDecimal utbetalingsgrad,
                                                                                Set<Inntektskategori> inntektskategorier) {
         var rapportertPåNødnummmer = arbeidsforhold.stream()
             .filter(arb -> arb.getOrgnr() != null && Arrays.stream(Nødnummer.values()).anyMatch(n -> n.getOrgnummer().equals(arb.getOrgnr())))
             .map(InfotrygdgrunnlagYtelseMapper::mapTilDagsats)
             .reduce(BigDecimal::add)
-            .orElse(BigDecimal.ZERO);
+            .orElse(BigDecimal.ZERO)
+            .multiply(utbetalingsgrad).divide(BigDecimal.valueOf(100), 10, RoundingMode.HALF_UP);
 
         if (rapportertPåNødnummmer.compareTo(BigDecimal.ZERO) > 0) {
             var nødnummerYtelse = YtelseAnvistAndelBuilder.ny()
@@ -111,35 +152,51 @@ private static Optional<YtelseAnvistAndel> finnIkkeArbeidstakerAndel(List<Infotr
         return Optional.empty();
     }
 
-    private static BigDecimal finnDagsatsIkkeArbeidstaker(List<InfotrygdYtelseArbeid> arbeidsforhold) {
+    private static BigDecimal finnDagsatsIkkeArbeidstaker(List<InfotrygdYtelseArbeid> arbeidsforhold, BigDecimal utbetalingsgrad) {
         return arbeidsforhold.stream().filter(arb -> arb.getOrgnr() == null)
             .map(InfotrygdgrunnlagYtelseMapper::mapTilDagsats)
             .reduce(BigDecimal::add)
-            .orElse(BigDecimal.ZERO);
+            .orElse(BigDecimal.ZERO)
+            .multiply(utbetalingsgrad).divide(BigDecimal.valueOf(100), 10, RoundingMode.HALF_UP);
     }
 
-    // TODO (Espen Velsvik) Ta inn refusjonTOM og periodiser ytelse anvist basert på tom-dato for refusjon
-    private static List<YtelseAnvistAndel> finnArbeidstakerAndeler(List<InfotrygdYtelseArbeid> arbeidsforhold, BigDecimal utbetalingsgrad) {
+    private static List<YtelseAnvistAndel> finnArbeidstakerAndeler(List<InfotrygdYtelseArbeid> arbeidsforhold, BigDecimal utbetalingsgrad, IntervallEntitet periode) {
         var gruppertPrOrg = arbeidsforhold.stream()
             .filter(a -> a.getOrgnr() != null)
             .filter(a -> OrganisasjonsNummerValidator.erGyldig(a.getOrgnr()))
             .collect(Collectors.groupingBy(InfotrygdYtelseArbeid::getOrgnr));
 
         return gruppertPrOrg.entrySet().stream()
             .filter(e -> e.getValue().stream().map(InfotrygdYtelseArbeid::getInntekt).reduce(BigDecimal::add).orElse(BigDecimal.ZERO).compareTo(BigDecimal.ZERO) > 0)
-            .map(e -> {
-                var refusjon = e.getValue().stream().filter(InfotrygdYtelseArbeid::getRefusjon).map(InfotrygdgrunnlagYtelseMapper::mapTilDagsats).reduce(BigDecimal::add).orElse(BigDecimal.ZERO);
-                var direkteUtbetaling = e.getValue().stream().filter(a -> !a.getRefusjon()).map(InfotrygdgrunnlagYtelseMapper::mapTilDagsats).reduce(BigDecimal::add).orElse(BigDecimal.ZERO);
-                var total = refusjon.add(direkteUtbetaling);
-                var refusjonsgrad = refusjon.divide(total, 10, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
-                return YtelseAnvistAndelBuilder.ny()
-                    .medDagsats(total)
-                    .medInntektskategori(Inntektskategori.ARBEIDSTAKER)
-                    .medArbeidsgiver(Arbeidsgiver.virksomhet(new OrgNummer(e.getKey())))
-                    .medRefusjonsgrad(refusjonsgrad)
-                    .medUtbetalingsgrad(utbetalingsgrad)
-                    .build();
-            }).toList();
+            .map(e -> mapGrunnlagsandelerTilAnvistandel(utbetalingsgrad, periode, new OrgNummer(e.getKey()), e.getValue())).toList();
+    }
+
+    private static YtelseAnvistAndel mapGrunnlagsandelerTilAnvistandel(BigDecimal utbetalingsgrad,
+                                                                       IntervallEntitet periode,
+                                                                       OrgNummer orgnummer,
+                                                                       List<InfotrygdYtelseArbeid> grunnlagsandeler) {
+        var refusjonTom = grunnlagsandeler.stream().map(InfotrygdYtelseArbeid::getRefusjonTom).findFirst();
+        refusjonTom.ifPresent(it -> validerRefusjonTom(periode, it));
+        var refusjon = grunnlagsandeler.stream().filter(InfotrygdYtelseArbeid::getRefusjon)
+            .map(InfotrygdgrunnlagYtelseMapper::mapTilDagsats).reduce(BigDecimal::add).orElse(BigDecimal.ZERO);
+        var direkteUtbetaling = grunnlagsandeler.stream().filter(a -> !a.getRefusjon()).map(InfotrygdgrunnlagYtelseMapper::mapTilDagsats).reduce(BigDecimal::add).orElse(BigDecimal.ZERO);
+        var total = refusjon.add(direkteUtbetaling);
+        var refusjonsgrad = refusjon.divide(total, 10, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+        // Mapper til netto dagsats for å være konskvent på tvers av kilder (fp-sak, k9-sak, infotrygd)
+        var nettoDagsats = total.multiply(utbetalingsgrad).divide(BigDecimal.valueOf(100), 10, RoundingMode.HALF_UP);
+        return YtelseAnvistAndelBuilder.ny()
+            .medDagsats(nettoDagsats)
+            .medInntektskategori(Inntektskategori.ARBEIDSTAKER)
+            .medArbeidsgiver(Arbeidsgiver.virksomhet(orgnummer))
+            .medRefusjonsgrad(refusjonsgrad)
+            .medUtbetalingsgrad(utbetalingsgrad)
+            .build();
+    }
+
+    private static void validerRefusjonTom(IntervallEntitet periode, LocalDate refusjonTom) {
+        if (periode.inkluderer(refusjonTom) && !periode.getTomDato().equals(refusjonTom)) {
+            LOGGER.warn(String.format("Fant periode i infotrygd der refusjonTom ikke ligger ved slutten av en utbetalingsperiode: periode: {%s}, refusjonTom: {%s}", periode, refusjonTom));
+        }
     }
 
     private static BigDecimal mapTilDagsats(InfotrygdYtelseArbeid arbeid) {
@@ -153,6 +210,12 @@ private static BigDecimal mapTilDagsats(InfotrygdYtelseArbeid arbeid) {
         };
     }
 
+    /**
+     * Splitter kombinasjonsstatuser fra infotrygd og mapper til inntektskategori
+     *
+     * @param kategori Arbeidskategori fra infotrygd
+     * @return Set av Inntektskategori
+     */
     private static Set<Inntektskategori> splittArbeidskategoriTilInntektskategorier(Arbeidskategori kategori) {
         return switch (kategori) {
             case FISKER -> Set.of(Inntektskategori.FISKER);
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/ytelse/infotrygd/InnhentingInfotrygdTjeneste.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/ytelse/infotrygd/InnhentingInfotrygdTjeneste.java
@@ -69,6 +69,10 @@ public class InnhentingInfotrygdTjeneste {
         Map.entry(no.nav.vedtak.felles.integrasjon.infotrygd.grunnlag.v1.respons.BehandlingstemaKode.PI, YtelseType.PLEIEPENGER_SYKT_BARN),
         Map.entry(no.nav.vedtak.felles.integrasjon.infotrygd.grunnlag.v1.respons.BehandlingstemaKode.PN, YtelseType.PLEIEPENGER_SYKT_BARN)
     );
+    public static final String SELVSTENDIG = "02";
+    public static final String ARBTAKER_SELVSTENDIG = "03";
+    public static final String FL_OPPDRAGSTAKER_U_FORS = "24";
+    public static final String ARB_FL_OPPDRAGSTAKER_U_FORS = "25";
 
     private InfotrygdGrunnlagAggregator infotrygdGrunnlag;
     private Spøkelse spøkelse;
@@ -147,6 +151,7 @@ private InfotrygdYtelseGrunnlag restTilInfotrygdYtelseGrunnlag(Grunnlag grunnlag
             .medVedtaksPeriodeFom(brukPeriode.fom())
             .medVedtaksPeriodeTom(brukPeriode.tom())
             .medArbeidskategori(arbeidskategori)
+            .medNæringEllerFrilansUtenForsikring(erNæringEllerFrilansUtenForsikring(grunnlag.getKategori()))
             .medDekningsgrad(dekningsgrad)
             .medGradering(grunnlag.getGradering())
             .medFødselsdatoBarn(grunnlag.getFødselsdatoBarn())
@@ -163,6 +168,13 @@ private InfotrygdYtelseGrunnlag restTilInfotrygdYtelseGrunnlag(Grunnlag grunnlag
         return grunnlagBuilder.build();
     }
 
+    private boolean erNæringEllerFrilansUtenForsikring(no.nav.vedtak.felles.integrasjon.infotrygd.grunnlag.v1.respons.Arbeidskategori kategori) {
+        return kategori.kode().getKode().equals(SELVSTENDIG) ||
+            kategori.kode().getKode().equals(ARBTAKER_SELVSTENDIG) ||
+            kategori.kode().getKode().equals(FL_OPPDRAGSTAKER_U_FORS) ||
+            kategori.kode().getKode().equals(ARB_FL_OPPDRAGSTAKER_U_FORS);
+    }
+
     private YtelseStatus mapYtelseStatus(Grunnlag grunnlag) {
         if (grunnlag.getStatus() == null) {
             if (grunnlag.getOpphørFom() != null)
@@ -179,7 +191,7 @@ private InfotrygdYtelseArbeid arbeidsforholdTilInfotrygdYtelseArbeid(Arbeidsforh
             InntektPeriodeReverse.reverseMap(arbeidsforhold.inntektsperiode().kode().name(), LOG);
         BigDecimal inntekt = arbeidsforhold.inntekt() != null ? new BigDecimal(arbeidsforhold.inntekt()) : null;
         return new InfotrygdYtelseArbeid(arbeidsforhold.orgnr().getOrgnr(),
-            inntekt, inntektPeriode, arbeidsforhold.refusjon());
+            inntekt, inntektPeriode, arbeidsforhold.refusjon(), arbeidsforhold.refusjonTom());
     }
 
     private Periode utledPeriode(LocalDate iverksatt, LocalDate opphoerFomDato, LocalDate registrert) {
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/ytelse/infotrygd/dto/InfotrygdYtelseArbeid.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/ytelse/infotrygd/dto/InfotrygdYtelseArbeid.java
@@ -1,6 +1,7 @@
 package no.nav.foreldrepenger.abakus.registerdata.ytelse.infotrygd.dto;
 
 import java.math.BigDecimal;
+import java.time.LocalDate;
 import java.util.Objects;
 
 import no.nav.abakus.iaygrunnlag.kodeverk.InntektPeriodeType;
@@ -11,12 +12,14 @@ public class InfotrygdYtelseArbeid {
     private BigDecimal inntekt;
     private InntektPeriodeType inntektperiode;
     private Boolean refusjon;
+    private LocalDate refusjonTom;
 
-    public InfotrygdYtelseArbeid(String orgnr, BigDecimal inntekt, InntektPeriodeType inntektperiode, Boolean refusjon) {
+    public InfotrygdYtelseArbeid(String orgnr, BigDecimal inntekt, InntektPeriodeType inntektperiode, Boolean refusjon, LocalDate refusjonTom) {
         this.orgnr = orgnr;
         this.inntekt = inntekt;
         this.inntektperiode = inntektperiode;
         this.refusjon = refusjon;
+        this.refusjonTom = refusjonTom;
     }
 
     public InfotrygdYtelseArbeid(String orgnr, int inntekt, InntektPeriodeType inntektperiode, Boolean refusjon) {
@@ -42,6 +45,10 @@ public Boolean getRefusjon() {
         return refusjon;
     }
 
+    public LocalDate getRefusjonTom() {
+        return refusjonTom;
+    }
+
     @Override
     public boolean equals(Object o) {
         if (this == o) return true;
@@ -50,12 +57,14 @@ public boolean equals(Object o) {
         return Objects.equals(orgnr, that.orgnr) &&
             Objects.equals(inntekt, that.inntekt) &&
             Objects.equals(inntektperiode, that.inntektperiode) &&
-            Objects.equals(refusjon, that.refusjon);
+            Objects.equals(refusjon, that.refusjon) &&
+            Objects.equals(refusjonTom, that.refusjonTom);
+
     }
 
     @Override
     public int hashCode() {
-        return Objects.hash(orgnr, inntekt, inntektperiode, refusjon);
+        return Objects.hash(orgnr, inntekt, inntektperiode, refusjon, refusjonTom);
     }
 
     @Override
@@ -65,6 +74,7 @@ public String toString() {
             ", inntekt=" + inntekt +
             ", inntektperiode=" + inntektperiode +
             ", refusjon=" + refusjon +
+            ", refusjon=" + refusjonTom +
             '}';
     }
 
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/ytelse/infotrygd/dto/InfotrygdYtelseGrunnlag.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/ytelse/infotrygd/dto/InfotrygdYtelseGrunnlag.java
@@ -23,6 +23,14 @@ public class InfotrygdYtelseGrunnlag {
     private LocalDate vedtaksPeriodeTom;
     private String vedtaksreferanse;
 
+    /**
+     * Makrerer om grunnlaget gjelder for næring eller frilans uten forsikring
+     *
+     * Informasjonen brukes til å finne ut om vi kan mappe fra grunnlagsdagsats til utbetalingsgrad
+     *
+     * Næring og frilans uten forsikring har spesielle regler som gir reduksjon i netto dagsats som ikke reflekteres i utbetalingsgraden (se f.t.l. §§ 8-36 og 8-39)
+     */
+    private boolean næringEllerFrilansUtenForsikring;
     private Arbeidskategori kategori;
     private List<InfotrygdYtelseArbeid> arbeidsforhold;
 
@@ -31,6 +39,9 @@ public class InfotrygdYtelseGrunnlag {
     private LocalDate fødselsdatoBarn;
     private LocalDate opprinneligIdentdato;
 
+    public InfotrygdYtelseGrunnlag() {
+    }
+
     public LocalDateTime getVedtattTidspunkt() {
         return vedtattTidspunkt;
     }
@@ -87,6 +98,10 @@ public String getVedtaksreferanse() {
         return vedtaksreferanse;
     }
 
+    public boolean isNæringEllerFrilansUtenForsikring() {
+        return næringEllerFrilansUtenForsikring;
+    }
+
     @Override
     public boolean equals(Object o) {
         if (this == o) return true;
@@ -204,11 +219,17 @@ public Builder medGradering(Integer gradering) {
             return this;
         }
 
+
         public Builder medGradering(BigDecimal gradering) {
             grunnlag.gradering = gradering;
             return this;
         }
 
+        public Builder medNæringEllerFrilansUtenForsikring(boolean næringEllerFrilansUtenForsikring) {
+            grunnlag.næringEllerFrilansUtenForsikring = næringEllerFrilansUtenForsikring;
+            return this;
+        }
+
         public Builder medFødselsdatoBarn(LocalDate fødselsdatoBarn) {
             grunnlag.fødselsdatoBarn = fødselsdatoBarn;
             return this;
diff --git a/pom.xml b/pom.xml
@@ -31,7 +31,7 @@
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 
-		<felles.version>4.1.18</felles.version>
+		<felles.version>4.1.19</felles.version>
 		<prosesstask.version>3.1.7</prosesstask.version>
 
 		<kontrakter.version>6.1.10</kontrakter.version>
