Bugfix/misc rydding (#2552)

jolarsen · web-flow · commit 34ee065799ac · 2024-03-25T21:08:04.000+01:00
* Forenklinger

* Sjekk bruk av environment

* Fikse oppsett av klasser
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
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
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/IAYRegisterInnhentingTjeneste.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/IAYRegisterInnhentingTjeneste.java
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/InnhentingSamletTjeneste.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/InnhentingSamletTjeneste.java
@@ -42,7 +42,7 @@ public class InnhentingSamletTjeneste {
 
     private static final Logger LOG = LoggerFactory.getLogger(InnhentingSamletTjeneste.class);
     private static final Set<YtelseType> LØNNSKOMP_FOR_YTELSER = Set.of(YtelseType.FORELDREPENGER, YtelseType.SVANGERSKAPSPENGER);
-    private final boolean isDev = Environment.current().isDev();
+    private static final boolean FAILSOFT_DEV = Environment.current().isDev();
     private ArbeidsforholdTjeneste arbeidsforholdTjeneste;
     private InntektTjeneste inntektTjeneste;
     private FpwsproxyKlient fpwsproxyKlient;
@@ -114,7 +114,7 @@ public Map<ArbeidsforholdIdentifikator, List<Arbeidsforhold>> getArbeidsforholdF
     }
 
     public List<InfotrygdYtelseGrunnlag> innhentInfotrygdGrunnlag(PersonIdent ident, IntervallEntitet periode) {
-        if (isDev) {
+        if (FAILSOFT_DEV) {
             return innhentingInfotrygdTjeneste.getInfotrygdYtelserFailSoft(ident, periode);
         }
         return innhentingInfotrygdTjeneste.getInfotrygdYtelser(ident, periode);
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/RegisterdataInnhentingTask.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/RegisterdataInnhentingTask.java
@@ -2,26 +2,21 @@
 
 import java.util.Set;
 
-import jakarta.enterprise.context.ApplicationScoped;
-import jakarta.enterprise.inject.Any;
-import jakarta.enterprise.inject.Instance;
-import jakarta.inject.Inject;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
 import no.nav.abakus.iaygrunnlag.JsonObjectMapper;
-import no.nav.abakus.iaygrunnlag.kodeverk.YtelseType;
 import no.nav.abakus.iaygrunnlag.request.InnhentRegisterdataRequest;
 import no.nav.foreldrepenger.abakus.domene.iay.InntektArbeidYtelseGrunnlagBuilder;
 import no.nav.foreldrepenger.abakus.iay.InntektArbeidYtelseTjeneste;
 import no.nav.foreldrepenger.abakus.kobling.Kobling;
 import no.nav.foreldrepenger.abakus.kobling.KoblingTask;
 import no.nav.foreldrepenger.abakus.kobling.KoblingTjeneste;
 import no.nav.foreldrepenger.abakus.kobling.TaskConstants;
-import no.nav.foreldrepenger.abakus.kobling.kontroll.YtelseTypeRef;
 import no.nav.foreldrepenger.abakus.kobling.repository.LåsRepository;
 import no.nav.foreldrepenger.abakus.registerdata.tjeneste.InnhentRegisterdataTjeneste;
 import no.nav.foreldrepenger.abakus.registerdata.tjeneste.RegisterdataElement;
@@ -35,7 +30,7 @@ public class RegisterdataInnhentingTask extends KoblingTask {
     private static final Logger LOG = LoggerFactory.getLogger(RegisterdataInnhentingTask.class);
     private KoblingTjeneste koblingTjeneste;
     private InntektArbeidYtelseTjeneste iayTjeneste;
-    private Instance<IAYRegisterInnhentingTjeneste> innhentTjenester;
+    private IAYRegisterInnhentingTjeneste innhentTjeneste;
 
     RegisterdataInnhentingTask() {
     }
@@ -44,15 +39,11 @@ public class RegisterdataInnhentingTask extends KoblingTask {
     public RegisterdataInnhentingTask(LåsRepository låsRepository,
                                       KoblingTjeneste koblingTjeneste,
                                       InntektArbeidYtelseTjeneste iayTjeneste,
-                                      @Any Instance<IAYRegisterInnhentingTjeneste> innhentingTjeneste) {
+                                      IAYRegisterInnhentingTjeneste innhentingTjeneste) {
         super(låsRepository);
         this.koblingTjeneste = koblingTjeneste;
         this.iayTjeneste = iayTjeneste;
-        this.innhentTjenester = innhentingTjeneste;
-    }
-
-    private IAYRegisterInnhentingTjeneste finnInnhenter(YtelseType ytelseType) {
-        return YtelseTypeRef.Lookup.find(innhentTjenester, ytelseType).orElseThrow();
+        this.innhentTjeneste = innhentingTjeneste;
     }
 
     @Override
@@ -77,7 +68,7 @@ protected void prosesser(ProsessTaskData prosessTaskData) {
         }
         LOG.info("Registerdataelementer for sak=[{}, {}] med behandling='{}' er: {} ", kobling.getSaksnummer(), kobling.getYtelseType(),
             kobling.getKoblingReferanse(), informasjonsElementer);
-        InntektArbeidYtelseGrunnlagBuilder builder = finnInnhenter(kobling.getYtelseType()).innhentRegisterdata(kobling, informasjonsElementer);
+        InntektArbeidYtelseGrunnlagBuilder builder = innhentTjeneste.innhentRegisterdata(kobling, informasjonsElementer);
         iayTjeneste.lagre(kobling.getKoblingReferanse(), builder);
     }
 }
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
@@ -30,20 +30,13 @@ void byggYtelser(Kobling behandling,
                      AktørId aktørId,
                      PersonIdent ident,
                      IntervallEntitet opplysningsPeriode,
-                     InntektArbeidYtelseAggregatBuilder inntektArbeidYtelseAggregatBuilder,
-                     boolean medGrunnlag) {
+                     InntektArbeidYtelseAggregatBuilder inntektArbeidYtelseAggregatBuilder) {
 
         InntektArbeidYtelseAggregatBuilder.AktørYtelseBuilder aktørYtelseBuilder = inntektArbeidYtelseAggregatBuilder.getAktørYtelseBuilder(aktørId);
         aktørYtelseBuilder.tilbakestillYtelser();
 
         vedtattYtelseInnhentingTjeneste.innhentFraYtelsesRegister(aktørId, behandling, aktørYtelseBuilder);
 
-        if (!medGrunnlag) {
-            // Ikke lenger relevant å hente eksternt for 2part eller engangsstønad
-            inntektArbeidYtelseAggregatBuilder.leggTilAktørYtelse(aktørYtelseBuilder);
-            return;
-        }
-
         List<InfotrygdYtelseGrunnlag> alleGrunnlag = innhentingSamletTjeneste.innhentInfotrygdGrunnlag(ident, opplysningsPeriode);
         alleGrunnlag.forEach(grunnlag -> InfotrygdgrunnlagYtelseMapper.oversettInfotrygdYtelseGrunnlagTilYtelse(aktørYtelseBuilder, grunnlag));
 
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/inntekt/komponenten/InntektTjeneste.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/inntekt/komponenten/InntektTjeneste.java
@@ -11,9 +11,7 @@
 import org.slf4j.LoggerFactory;
 
 import jakarta.enterprise.context.ApplicationScoped;
-import jakarta.inject.Inject;
 import no.nav.abakus.iaygrunnlag.kodeverk.InntektskildeType;
-import no.nav.foreldrepenger.abakus.aktor.AktørTjeneste;
 import no.nav.tjenester.aordningen.inntektsinformasjon.Aktoer;
 import no.nav.tjenester.aordningen.inntektsinformasjon.ArbeidsInntektIdent;
 import no.nav.tjenester.aordningen.inntektsinformasjon.ArbeidsInntektMaaned;
@@ -44,24 +42,17 @@ public class InntektTjeneste {
 
     private static final Logger LOG = LoggerFactory.getLogger(InntektTjeneste.class);
 
-    private RestClient restClient;
-    private RestConfig restConfig;
-    private AktørTjeneste aktørConsumer;
-    private Map<InntektskildeType, InntektsFilter> kildeTilFilter;
+    private final RestClient restClient;
+    private final RestConfig restConfig;
+    private final Map<InntektskildeType, InntektsFilter> kildeTilFilter;
 
-    InntektTjeneste() {
-        // For CDI proxy
+    public InntektTjeneste() {
+        this(RestClient.client());
     }
 
-    @Inject
-    public InntektTjeneste(AktørTjeneste aktørConsumer) {
-        this(RestClient.client(), aktørConsumer);
-    }
-
-    public InntektTjeneste(RestClient restClient, AktørTjeneste aktørConsumer) {
+    public InntektTjeneste(RestClient restClient) {
         this.restClient = restClient;
         this.restConfig = RestConfig.forClient(InntektTjeneste.class);
-        this.aktørConsumer = aktørConsumer;
         this.kildeTilFilter = Map.of(InntektskildeType.INNTEKT_OPPTJENING, InntektsFilter.OPPTJENINGSGRUNNLAG, InntektskildeType.INNTEKT_BEREGNING,
             InntektsFilter.BEREGNINGSGRUNNLAG, InntektskildeType.INNTEKT_SAMMENLIGNING, InntektsFilter.SAMMENLIGNINGSGRUNNLAG);
     }
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/inntekt/sigrun/SigrunTjeneste.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/inntekt/sigrun/SigrunTjeneste.java
@@ -20,7 +20,6 @@
 import no.nav.foreldrepenger.abakus.registerdata.inntekt.sigrun.klient.summertskattegrunnlag.SigrunSummertSkattegrunnlagResponse;
 import no.nav.foreldrepenger.abakus.typer.AktørId;
 import no.nav.foreldrepenger.abakus.typer.PersonIdent;
-import no.nav.foreldrepenger.konfig.Environment;
 
 
 @ApplicationScoped
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/inntekt/sigrun/klient/SigrunRestClient.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/inntekt/sigrun/klient/SigrunRestClient.java
@@ -20,7 +20,6 @@
 import jakarta.ws.rs.core.UriBuilder;
 import no.nav.foreldrepenger.abakus.registerdata.inntekt.sigrun.klient.pgifolketrygden.PgiFolketrygdenResponse;
 import no.nav.foreldrepenger.abakus.registerdata.inntekt.sigrun.klient.summertskattegrunnlag.SSGResponse;
-import no.nav.foreldrepenger.konfig.Environment;
 import no.nav.vedtak.exception.IntegrasjonException;
 import no.nav.vedtak.exception.ManglerTilgangException;
 import no.nav.vedtak.felles.integrasjon.rest.NavHeaders;
@@ -36,8 +35,6 @@
     scopesProperty = "sigrunrestberegnetskatt.scopes", scopesDefault = "api://prod-fss.team-inntekt.sigrun/.default")
 public class SigrunRestClient {
 
-    private static final boolean IS_DEV = Environment.current().isDev();
-
     private static final Year FØRSTE_PGI = Year.of(2017);
 
     private static final Logger LOG = LoggerFactory.getLogger(SigrunRestClient.class);
diff --git a/domenetjenester/iay/src/test/java/no/nav/foreldrepenger/abakus/registerdata/inntekt/komponenten/impl/InntektTjenesteImplTest.java b/domenetjenester/iay/src/test/java/no/nav/foreldrepenger/abakus/registerdata/inntekt/komponenten/impl/InntektTjenesteImplTest.java
@@ -24,7 +24,6 @@
 import org.mockito.junit.jupiter.MockitoExtension;
 
 import no.nav.abakus.iaygrunnlag.kodeverk.InntektskildeType;
-import no.nav.abakus.iaygrunnlag.kodeverk.YtelseType;
 import no.nav.foreldrepenger.abakus.registerdata.inntekt.komponenten.FinnInntektRequest;
 import no.nav.foreldrepenger.abakus.registerdata.inntekt.komponenten.InntektTjeneste;
 import no.nav.foreldrepenger.abakus.registerdata.inntekt.komponenten.InntektsInformasjon;
@@ -56,7 +55,7 @@ class InntektTjenesteImplTest {
 
     @BeforeEach
     public void before() {
-        inntektTjeneste = new InntektTjeneste(restKlient, null);
+        inntektTjeneste = new InntektTjeneste(restKlient);
     }
 
     @SuppressWarnings("resource")
diff --git a/domenetjenester/vedtak/src/main/java/no/nav/foreldrepenger/abakus/vedtak/kafka/VedtakConsumer.java b/domenetjenester/vedtak/src/main/java/no/nav/foreldrepenger/abakus/vedtak/kafka/VedtakConsumer.java
@@ -1,7 +1,5 @@
 package no.nav.foreldrepenger.abakus.vedtak.kafka;
 
-import java.util.List;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -24,7 +22,7 @@ public class VedtakConsumer implements LiveAndReadinessAware, Controllable {
 
     @Inject
     public VedtakConsumer(VedtaksHendelseHåndterer vedtaksHendelseHåndterer) {
-        this.kcm = new KafkaConsumerManager<>(List.of(vedtaksHendelseHåndterer));
+        this.kcm = new KafkaConsumerManager<>(vedtaksHendelseHåndterer);
     }
 
     @Override
diff --git a/pom.xml b/pom.xml
@@ -35,7 +35,7 @@
 
         <kontrakt.java.version>21</kontrakt.java.version>
 
-		<felles.version>7.0.8</felles.version>
+		<felles.version>7.0.9</felles.version>
 		<prosesstask.version>5.0.5</prosesstask.version>
 		<kontrakter.version>9.1.8</kontrakter.version>
         <tidsserie.version>2.7.1</tidsserie.version>
diff --git a/web/src/main/java/no/nav/foreldrepenger/abakus/app/diagnostikk/dumps/RegisterInnhentingDump.java b/web/src/main/java/no/nav/foreldrepenger/abakus/app/diagnostikk/dumps/RegisterInnhentingDump.java
@@ -12,11 +12,10 @@
 import java.util.concurrent.TimeUnit;
 import java.util.function.Function;
 
-import jakarta.enterprise.context.ApplicationScoped;
-import jakarta.inject.Inject;
-
 import com.fasterxml.jackson.databind.ObjectWriter;
 
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
 import no.nav.abakus.iaygrunnlag.kodeverk.InntektskildeType;
 import no.nav.foreldrepenger.abakus.app.diagnostikk.ContainerContextRunner;
 import no.nav.foreldrepenger.abakus.app.diagnostikk.DebugDump;
@@ -25,7 +24,7 @@
 import no.nav.foreldrepenger.abakus.app.jackson.JacksonJsonConfig;
 import no.nav.foreldrepenger.abakus.felles.jpa.IntervallEntitet;
 import no.nav.foreldrepenger.abakus.kobling.kontroll.YtelseTypeRef;
-import no.nav.foreldrepenger.abakus.registerdata.IAYRegisterInnhentingFellesTjenesteImpl;
+import no.nav.foreldrepenger.abakus.registerdata.IAYRegisterInnhentingTjeneste;
 import no.nav.foreldrepenger.abakus.registerdata.arbeidsforhold.rest.AaregRestKlient;
 import no.nav.foreldrepenger.abakus.registerdata.inntekt.komponenten.FinnInntektRequest;
 import no.nav.foreldrepenger.abakus.registerdata.inntekt.komponenten.InntektTjeneste;
@@ -39,7 +38,7 @@
 @YtelseTypeRef
 public class RegisterInnhentingDump implements DebugDump {
 
-    private static final Collection<InntektskildeType> INNTEKTSKILDER = IAYRegisterInnhentingFellesTjenesteImpl.ELEMENT_TIL_INNTEKTS_KILDE_MAP.values();
+    private static final Collection<InntektskildeType> INNTEKTSKILDER = IAYRegisterInnhentingTjeneste.ELEMENT_TIL_INNTEKTS_KILDE_MAP.values();
     private static final String PREFIKS = "register-innhenting";
     private InntektTjeneste inntektTjeneste;
     private AaregRestKlient aaregKlient;
