Mapper ytelse anvist andel fra infotrygdgrunnlag (#1825)

espenjv · web-flow · commit f442d8026861 · 2022-03-15T12:44:38.000+01:00
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/DefaultIAYRegisterInnhentingTjenesteImpl.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/DefaultIAYRegisterInnhentingTjenesteImpl.java
@@ -13,7 +13,6 @@
 import no.nav.foreldrepenger.abakus.kobling.kontroll.YtelseTypeRef;
 import no.nav.foreldrepenger.abakus.registerdata.arbeidsgiver.virksomhet.VirksomhetTjeneste;
 import no.nav.foreldrepenger.abakus.registerdata.inntekt.sigrun.SigrunTjeneste;
-import no.nav.foreldrepenger.abakus.vedtak.domene.VedtakYtelseRepository;
 
 /**
  * Standard IAY register innhenter.
@@ -31,7 +30,8 @@ public DefaultIAYRegisterInnhentingTjenesteImpl(InntektArbeidYtelseTjeneste innt
                                                     VirksomhetTjeneste virksomhetTjeneste,
                                                     InnhentingSamletTjeneste innhentingSamletTjeneste,
                                                     AktørTjeneste aktørConsumer,
-                                                    SigrunTjeneste sigrunTjeneste, VedtattYtelseInnhentingTjeneste vedtattYtelseInnhentingTjeneste) {
+                                                    SigrunTjeneste sigrunTjeneste,
+                                                    VedtattYtelseInnhentingTjeneste vedtattYtelseInnhentingTjeneste) {
         super(inntektArbeidYtelseTjeneste,
             virksomhetTjeneste,
             innhentingSamletTjeneste,
@@ -53,7 +53,7 @@ public DefaultIAYRegisterInnhentingTjenesteImpl(InntektArbeidYtelseTjeneste innt
         Optional<OppgittOpptjeningAggregat> aggregat = grunnlag.flatMap(InntektArbeidYtelseGrunnlag::getOppgittOpptjeningAggregat);
         boolean harOppgittOpptjeningSNMedAggregat = aggregat.isPresent() && aggregat.get().getOppgitteOpptjeninger().stream().anyMatch(oppgittOpptjening -> !oppgittOpptjening.getEgenNæring().isEmpty());
 
-        return harOppgittSNOpptjeningUtenAggregat || harOppgittOpptjeningSNMedAggregat ;
+        return harOppgittSNOpptjeningUtenAggregat || harOppgittOpptjeningSNMedAggregat;
 
 
     }
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/IAYRegisterInnhentingFellesTjenesteImpl.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/IAYRegisterInnhentingFellesTjenesteImpl.java
@@ -55,7 +55,6 @@
 import no.nav.foreldrepenger.abakus.typer.InternArbeidsforholdRef;
 import no.nav.foreldrepenger.abakus.typer.OrganisasjonsNummerValidator;
 import no.nav.foreldrepenger.abakus.typer.PersonIdent;
-import no.nav.foreldrepenger.abakus.vedtak.domene.VedtakYtelseRepository;
 import no.nav.vedtak.exception.TekniskException;
 
 public abstract class IAYRegisterInnhentingFellesTjenesteImpl implements IAYRegisterInnhentingTjeneste {
@@ -170,7 +169,7 @@ private void leggTilInntekter(AktørId aktørId, InntektArbeidYtelseAggregatBuil
         }
     }
 
-    private  Map<Arbeidsgiver, Map<YearMonth, List<MånedsbeløpOgSkatteOgAvgiftsregel>>> mapTilArbeidsgiver(InntektsInformasjon inntektsInformasjon, YtelseType ytelse) {
+    private Map<Arbeidsgiver, Map<YearMonth, List<MånedsbeløpOgSkatteOgAvgiftsregel>>> mapTilArbeidsgiver(InntektsInformasjon inntektsInformasjon, YtelseType ytelse) {
         Map<String, Set<YearMonth>> alleArbeidsgivereMedMåneder = inntektsInformasjon.getMånedsinntekterUtenomYtelser().stream()
             .collect(Collectors.groupingBy(Månedsinntekt::getArbeidsgiver, Collectors.mapping(Månedsinntekt::getMåned, Collectors.toSet())));
         Map<String, Arbeidsgiver> arbeidsgivereLookup = new HashMap<>();
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/YtelseRegisterInnhenting.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/YtelseRegisterInnhenting.java
@@ -1,28 +1,21 @@
 package no.nav.foreldrepenger.abakus.registerdata;
 
 import java.time.LocalDate;
-import java.util.Comparator;
 import java.util.List;
 import java.util.Optional;
 
 import no.nav.abakus.iaygrunnlag.kodeverk.Fagsystem;
 import no.nav.foreldrepenger.abakus.domene.iay.InntektArbeidYtelseAggregatBuilder;
 import no.nav.foreldrepenger.abakus.domene.iay.YtelseBuilder;
-import no.nav.foreldrepenger.abakus.domene.iay.YtelseGrunnlag;
-import no.nav.foreldrepenger.abakus.domene.iay.YtelseGrunnlagBuilder;
-import no.nav.foreldrepenger.abakus.domene.iay.YtelseStørrelseBuilder;
 import no.nav.foreldrepenger.abakus.felles.jpa.IntervallEntitet;
 import no.nav.foreldrepenger.abakus.kobling.Kobling;
+import no.nav.foreldrepenger.abakus.registerdata.infotrygd.InfotrygdgrunnlagYtelseMapper;
 import no.nav.foreldrepenger.abakus.registerdata.ytelse.arena.MeldekortUtbetalingsgrunnlagMeldekort;
 import no.nav.foreldrepenger.abakus.registerdata.ytelse.arena.MeldekortUtbetalingsgrunnlagSak;
-import no.nav.foreldrepenger.abakus.registerdata.ytelse.infotrygd.dto.InfotrygdYtelseAnvist;
 import no.nav.foreldrepenger.abakus.registerdata.ytelse.infotrygd.dto.InfotrygdYtelseGrunnlag;
 import no.nav.foreldrepenger.abakus.typer.AktørId;
-import no.nav.foreldrepenger.abakus.typer.OrgNummer;
-import no.nav.foreldrepenger.abakus.typer.OrganisasjonsNummerValidator;
 import no.nav.foreldrepenger.abakus.typer.PersonIdent;
 import no.nav.foreldrepenger.abakus.typer.Saksnummer;
-import no.nav.foreldrepenger.abakus.vedtak.domene.VedtakYtelseRepository;
 
 public class YtelseRegisterInnhenting {
     private final InnhentingSamletTjeneste innhentingSamletTjeneste;
@@ -49,7 +42,7 @@ void byggYtelser(Kobling behandling, AktørId aktørId, PersonIdent ident, Inter
         }
 
         List<InfotrygdYtelseGrunnlag> alleGrunnlag = innhentingSamletTjeneste.innhentInfotrygdGrunnlag(ident, opplysningsPeriode);
-        alleGrunnlag.forEach(grunnlag -> oversettInfotrygdYtelseGrunnlagTilYtelse(aktørYtelseBuilder, grunnlag));
+        alleGrunnlag.forEach(grunnlag -> InfotrygdgrunnlagYtelseMapper.oversettInfotrygdYtelseGrunnlagTilYtelse(aktørYtelseBuilder, grunnlag));
 
         List<InfotrygdYtelseGrunnlag> ghosts = innhentingSamletTjeneste.innhentSpokelseGrunnlag(ident, opplysningsPeriode);
         ghosts.forEach(grunnlag -> oversettSpokelseYtelseGrunnlagTilYtelse(aktørYtelseBuilder, grunnlag));
@@ -62,26 +55,6 @@ void byggYtelser(Kobling behandling, AktørId aktørId, PersonIdent ident, Inter
         inntektArbeidYtelseAggregatBuilder.leggTilAktørYtelse(aktørYtelseBuilder);
     }
 
-
-    private void oversettInfotrygdYtelseGrunnlagTilYtelse(InntektArbeidYtelseAggregatBuilder.AktørYtelseBuilder aktørYtelseBuilder, InfotrygdYtelseGrunnlag grunnlag) {
-        IntervallEntitet periode = utledPeriodeNårTomMuligFørFom(grunnlag.getVedtaksPeriodeFom(), grunnlag.getVedtaksPeriodeTom());
-        var tidligsteAnvist = grunnlag.getUtbetaltePerioder().stream().map(InfotrygdYtelseAnvist::getUtbetaltFom).min(Comparator.naturalOrder());
-        YtelseBuilder ytelseBuilder = aktørYtelseBuilder.getYtelselseBuilderForType(Fagsystem.INFOTRYGD, grunnlag.getYtelseType(),
-                grunnlag.getTemaUnderkategori(), periode, tidligsteAnvist)
-            .medBehandlingsTema(grunnlag.getTemaUnderkategori())
-            .medVedtattTidspunkt(grunnlag.getVedtattTidspunkt())
-            .medStatus(grunnlag.getYtelseStatus());
-        grunnlag.getUtbetaltePerioder().forEach(vedtak -> {
-            final IntervallEntitet intervall = utledPeriodeNårTomMuligFørFom(vedtak.getUtbetaltFom(), vedtak.getUtbetaltTom());
-            ytelseBuilder.leggtilYtelseAnvist(ytelseBuilder.getAnvistBuilder()
-                .medAnvistPeriode(intervall)
-                .medUtbetalingsgradProsent(vedtak.getUtbetalingsgrad())
-                .build());
-        });
-        ytelseBuilder.medYtelseGrunnlag(oversettYtelseArbeid(grunnlag, ytelseBuilder.getGrunnlagBuilder()));
-        aktørYtelseBuilder.leggTilYtelse(ytelseBuilder);
-    }
-
     private void oversettSpokelseYtelseGrunnlagTilYtelse(InntektArbeidYtelseAggregatBuilder.AktørYtelseBuilder aktørYtelseBuilder, InfotrygdYtelseGrunnlag grunnlag) {
         IntervallEntitet periode = utledPeriodeNårTomMuligFørFom(grunnlag.getVedtaksPeriodeFom(), grunnlag.getVedtaksPeriodeTom());
         var saksnummer = new Saksnummer(grunnlag.getVedtaksreferanse());
@@ -100,26 +73,6 @@ private void oversettSpokelseYtelseGrunnlagTilYtelse(InntektArbeidYtelseAggregat
         aktørYtelseBuilder.leggTilYtelse(ytelseBuilder);
     }
 
-    private YtelseGrunnlag oversettYtelseArbeid(InfotrygdYtelseGrunnlag grunnlag, YtelseGrunnlagBuilder grunnlagBuilder) {
-        grunnlagBuilder.medDekningsgradProsent(grunnlag.getDekningsgrad());
-        grunnlagBuilder.medGraderingProsent(grunnlag.getGradering());
-        grunnlagBuilder.medOpprinneligIdentdato(grunnlag.getOpprinneligIdentdato());
-        grunnlagBuilder.medArbeidskategori(grunnlag.getKategori());
-        grunnlagBuilder.tilbakestillStørrelse();
-        grunnlag.getArbeidsforhold().forEach(arbeid -> {
-            final YtelseStørrelseBuilder ysBuilder = grunnlagBuilder.getStørrelseBuilder();
-            ysBuilder.medBeløp(arbeid.getInntekt())
-                .medHyppighet(arbeid.getInntektperiode())
-                .medErRefusjon(arbeid.getRefusjon());
-            if (OrganisasjonsNummerValidator.erGyldig(arbeid.getOrgnr())) {
-                ysBuilder.medVirksomhet(new OrgNummer(arbeid.getOrgnr()));
-            }
-            // Her er plass til bool refusjon
-            grunnlagBuilder.medYtelseStørrelse(ysBuilder.build());
-        });
-        return grunnlagBuilder.build();
-    }
-
     private void oversettMeldekortUtbetalingsgrunnlagTilYtelse(InntektArbeidYtelseAggregatBuilder.AktørYtelseBuilder aktørYtelseBuilder,
                                                                MeldekortUtbetalingsgrunnlagSak ytelse) {
         Optional<LocalDate> førsteMeldekortFom = finnFørsteMeldekortFom(ytelse);
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/fagsakytelser/es/IAYRegisterInnhentingESTjenesteImpl.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/fagsakytelser/es/IAYRegisterInnhentingESTjenesteImpl.java
@@ -12,7 +12,6 @@
 import no.nav.foreldrepenger.abakus.registerdata.VedtattYtelseInnhentingTjeneste;
 import no.nav.foreldrepenger.abakus.registerdata.arbeidsgiver.virksomhet.VirksomhetTjeneste;
 import no.nav.foreldrepenger.abakus.registerdata.inntekt.sigrun.SigrunTjeneste;
-import no.nav.foreldrepenger.abakus.vedtak.domene.VedtakYtelseRepository;
 
 @ApplicationScoped
 @YtelseTypeRef("ES")
@@ -32,7 +31,8 @@ public IAYRegisterInnhentingESTjenesteImpl(InntektArbeidYtelseTjeneste inntektAr
             virksomhetTjeneste,
             innhentingSamletTjeneste,
             aktørConsumer,
-            sigrunTjeneste, vedtattYtelseInnhentingTjeneste);
+            sigrunTjeneste, vedtattYtelseInnhentingTjeneste
+        );
     }
 
     @Override
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/fagsakytelser/k9/IAYRegisterInnhentingK9TjenesteImpl.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/fagsakytelser/k9/IAYRegisterInnhentingK9TjenesteImpl.java
@@ -12,7 +12,6 @@
 import no.nav.foreldrepenger.abakus.registerdata.VedtattYtelseInnhentingTjeneste;
 import no.nav.foreldrepenger.abakus.registerdata.arbeidsgiver.virksomhet.VirksomhetTjeneste;
 import no.nav.foreldrepenger.abakus.registerdata.inntekt.sigrun.SigrunTjeneste;
-import no.nav.foreldrepenger.abakus.vedtak.domene.VedtakYtelseRepository;
 
 @ApplicationScoped
 @YtelseTypeRef("PSB")
@@ -28,12 +27,15 @@ public IAYRegisterInnhentingK9TjenesteImpl(InntektArbeidYtelseTjeneste inntektAr
                                                VirksomhetTjeneste virksomhetTjeneste,
                                                InnhentingSamletTjeneste innhentingSamletTjeneste,
                                                AktørTjeneste aktørConsumer,
-                                               SigrunTjeneste sigrunTjeneste, VedtattYtelseInnhentingTjeneste VedtattYtelseInnhentingTjeneste) {
+                                               SigrunTjeneste sigrunTjeneste,
+                                               VedtattYtelseInnhentingTjeneste vedtattYtelseInnhentingTjeneste) {
         super(inntektArbeidYtelseTjeneste,
             virksomhetTjeneste,
             innhentingSamletTjeneste,
             aktørConsumer,
-            sigrunTjeneste, VedtattYtelseInnhentingTjeneste);
+            sigrunTjeneste,
+            vedtattYtelseInnhentingTjeneste
+        );
     }
 
     // Skal alltid innhente næringsinntekter om det ligger i informasjonselementer, dette for å støtte 8-47.
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
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/infotrygd/Nødnummer.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/infotrygd/Nødnummer.java

Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,6 @@`
`55`	`55`	`import no.nav.foreldrepenger.abakus.typer.InternArbeidsforholdRef;`
`56`	`56`	`import no.nav.foreldrepenger.abakus.typer.OrganisasjonsNummerValidator;`
`57`	`57`	`import no.nav.foreldrepenger.abakus.typer.PersonIdent;`
`58`		`-import no.nav.foreldrepenger.abakus.vedtak.domene.VedtakYtelseRepository;`
`59`	`58`	`import no.nav.vedtak.exception.TekniskException;`
`60`	`59`
`61`	`60`	`public abstract class IAYRegisterInnhentingFellesTjenesteImpl implements IAYRegisterInnhentingTjeneste {`
`@@ -170,7 +169,7 @@ private void leggTilInntekter(AktørId aktørId, InntektArbeidYtelseAggregatBuil`
`170`	`169`	`}`
`171`	`170`	`}`
`172`	`171`
`173`		`- private Map<Arbeidsgiver, Map<YearMonth, List<MånedsbeløpOgSkatteOgAvgiftsregel>>> mapTilArbeidsgiver(InntektsInformasjon inntektsInformasjon, YtelseType ytelse) {`
	`172`	`+ private Map<Arbeidsgiver, Map<YearMonth, List<MånedsbeløpOgSkatteOgAvgiftsregel>>> mapTilArbeidsgiver(InntektsInformasjon inntektsInformasjon, YtelseType ytelse) {`
`174`	`173`	`Map<String, Set<YearMonth>> alleArbeidsgivereMedMåneder = inntektsInformasjon.getMånedsinntekterUtenomYtelser().stream()`
`175`	`174`	`.collect(Collectors.groupingBy(Månedsinntekt::getArbeidsgiver, Collectors.mapping(Månedsinntekt::getMåned, Collectors.toSet())));`
`176`	`175`	`Map<String, Arbeidsgiver> arbeidsgivereLookup = new HashMap<>();`