Innhent og sammenlign fra SP subbase

Author: jolarsen

domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/ytelse/infotrygd/rest/felles/InfotrygdGrunnlagAggregator.java

@@ -5,35 +5,58 @@
 import java.time.LocalDate;
 import java.util.List;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import jakarta.enterprise.context.ApplicationScoped;
-import jakarta.enterprise.inject.Any;
-import jakarta.enterprise.inject.Instance;
 import jakarta.inject.Inject;
-
+import no.nav.foreldrepenger.abakus.registerdata.ytelse.infotrygd.rest.ps.InfotrygdPSGrunnlag;
+import no.nav.foreldrepenger.abakus.registerdata.ytelse.infotrygd.rest.sp.InfotrygdSPGrunnlag;
+import no.nav.foreldrepenger.abakus.registerdata.ytelse.infotrygd.rest.sp.TestInfotrygdSPGrunnlag;
 import no.nav.vedtak.felles.integrasjon.infotrygd.grunnlag.InfotrygdGrunnlag;
 import no.nav.vedtak.felles.integrasjon.infotrygd.grunnlag.v1.respons.Grunnlag;
 
 @ApplicationScoped
 public class InfotrygdGrunnlagAggregator {
-
+    private static final Logger LOG = LoggerFactory.getLogger(InfotrygdGrunnlagAggregator.class);
     private List<InfotrygdGrunnlag> tjenester;
+    private InfotrygdGrunnlag sykepenger;
+    private InfotrygdGrunnlag testSykepenger;
 
     InfotrygdGrunnlagAggregator() {
     }
 
     @Inject
-    public InfotrygdGrunnlagAggregator(@Any Instance<InfotrygdGrunnlag> tjenester) {
-        this.tjenester = tjenester.stream().collect(toList());
+    public InfotrygdGrunnlagAggregator(InfotrygdPSGrunnlag ps, InfotrygdSPGrunnlag sp, TestInfotrygdSPGrunnlag tsp) {
+        this.tjenester = List.of(ps, sp);
+        this.sykepenger = sp;
+        this.testSykepenger = tsp;
     }
 
     public List<Grunnlag> hentAggregertGrunnlag(String fnr, LocalDate fom, LocalDate tom) {
+        sammenlignSykepenger(fnr, fom, tom);
         return tjenester.stream().map(t -> t.hentGrunnlag(fnr, fom, tom)).flatMap(List::stream).collect(toList());
     }
 
     public List<Grunnlag> hentAggregertGrunnlagFailSoft(String fnr, LocalDate fom, LocalDate tom) {
+        sammenlignSykepenger(fnr, fom, tom);
         return tjenester.stream().map(t -> t.hentGrunnlagFailSoft(fnr, fom, tom)).flatMap(List::stream).collect(toList());
     }
 
+    private void sammenlignSykepenger(String fnr, LocalDate fom, LocalDate tom) {
+        try {
+            var gs = sykepenger.hentGrunnlagFailSoft(fnr, fom, tom);
+            var gt = testSykepenger.hentGrunnlagFailSoft(fnr, fom, tom);
+            if (gs.size() == gt.size() && gs.containsAll(gt)) {
+                LOG.info("ABAKUS-SYKEPENGER like svar");
+            } else {
+                LOG.info("ABAKUS-SYKEPENGER ulike svar gamle {} nye {}", gs, gt);
+            }
+        } catch (Exception e) {
+            LOG.info("ABAKUS-SYKEPENGER fikk feil", e);
+        }
+    }
+
     @Override
     public String toString() {
         return getClass().getSimpleName() + "[tjenester=" + tjenester + "]";

domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/ytelse/infotrygd/rest/sp/TSP.java

@@ -0,0 +1,15 @@
+package no.nav.foreldrepenger.abakus.registerdata.ytelse.infotrygd.rest.sp;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+import jakarta.inject.Qualifier;
+
+@Qualifier
+@Retention(RetentionPolicy.RUNTIME)
+@Target({ElementType.PARAMETER, ElementType.TYPE})
+public @interface TSP {
+
+}

domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/ytelse/infotrygd/rest/sp/TestInfotrygdSPGrunnlag.java

@@ -0,0 +1,18 @@
+package no.nav.foreldrepenger.abakus.registerdata.ytelse.infotrygd.rest.sp;
+
+import jakarta.enterprise.context.Dependent;
+import no.nav.vedtak.felles.integrasjon.infotrygd.grunnlag.AbstractInfotrygdGrunnlag;
+import no.nav.vedtak.felles.integrasjon.rest.RestClientConfig;
+import no.nav.vedtak.felles.integrasjon.rest.TokenFlow;
+
+@TSP
+@Dependent
+@RestClientConfig(tokenConfig = TokenFlow.AZUREAD_CC, endpointProperty = "fpabakus.it.tsp.grunnlag.url",
+    endpointDefault = "http://fp-infotrygd-sykepenger.teamforeldrepenger/grunnlag",
+    scopesProperty = "fpabakus.it.tsp.scopes", scopesDefault = "api://prod-fss.teamforeldrepenger.fp-infotrygd-sykepenger/.default")
+public class TestInfotrygdSPGrunnlag extends AbstractInfotrygdGrunnlag {
+
+    public TestInfotrygdSPGrunnlag() {
+        super();
+    }
+}

web/src/main/resources/application-dev-fss.properties

@@ -11,6 +11,7 @@ sigrunrestberegnetskatt.scopes=api://dev-fss.team-inntekt.sigrun-q2/.default
 
 fpabakus.it.ps.scopes=api://dev-fss.k9saksbehandling.k9-infotrygd-grunnlag-paaroerende-sykdom/.default
 fpabakus.it.sp.scopes=api://dev-fss.infotrygd.infotrygd-sykepenger-fp/.default
+fpabakus.it.tsp.scopes=api://dev-fss.teamforeldrepenger.fp-infotrygd-sykepenger/.default
 
 # Spokelse
 spokelse.grunnlag.url=https://spokelse.intern.dev.nav.no/grunnlag

web/src/main/resources/application-prod-fss.properties

@@ -11,6 +11,7 @@ sigrunrestberegnetskatt.scopes=api://prod-fss.team-inntekt.sigrun/.default
 
 fpabakus.it.ps.scopes=api://prod-fss.k9saksbehandling.k9-infotrygd-grunnlag-paaroerende-sykdom/.default
 fpabakus.it.sp.scopes=api://prod-fss.infotrygd.infotrygd-sykepenger-fp/.default
+fpabakus.it.tsp.scopes=api://prod-fss.teamforeldrepenger.fp-infotrygd-sykepenger/.default
 
 # Spokelse
 spokelse.grunnlag.url=https://spokelse.intern.nav.no/grunnlag

web/src/main/resources/application.properties

@@ -24,6 +24,7 @@ kafka.fattevedtak.topic=teamforeldrepenger.familie-vedtakfattet-v1
 # Klienter
 fpabakus.it.ps.grunnlag.url=http://k9-infotrygd-grunnlag-paaroerende-sykdom.k9saksbehandling/paaroerendeSykdom/grunnlag
 fpabakus.it.sp.grunnlag.url=http://infotrygd-sykepenger-fp.infotrygd/grunnlag
+fpabakus.it.tsp.grunnlag.url=http://fp-infotrygd-sykepenger.teamforeldrepenger/grunnlag
 
 # PDL
 pdl.base.url=http://pdl-api.pdl/graphql

web/src/test/resources/application-local.properties

@@ -42,6 +42,9 @@ hentinntektlistebolk.url=https://localhost:8063/rest/inntektskomponenten-ws/rs/a
 hentinntektlistebolk.scopes=testscope
 fpabakus.it.sp.grunnlag.url=https://localhost:8063/rest/infotrygd/grunnlag/sykepenger
 fpabakus.it.sp.scopes=testscope
+fpabakus.it.tsp.grunnlag.url=https://localhost:8063/rest/infotrygd/grunnlag/sykepenger
+fpabakus.it.tsp.scopes=testscope
+
 fpabakus.it.ps.grunnlag.url=https://localhost:8063/rest/infotrygd/grunnlag/paaroerende-sykdom
 fpabakus.it.ps.scopes=testscope
 

web/src/test/resources/application-vtp.properties

@@ -44,6 +44,8 @@ hentinntektlistebolk.url=http://localhost:8060/rest/inntektskomponenten-ws/rs/ap
 hentinntektlistebolk.scopes=testscope
 fpabakus.it.sp.grunnlag.url=http://localhost:8060/rest/infotrygd/grunnlag/sykepenger
 fpabakus.it.sp.scopes=testscope
+fpabakus.it.tsp.grunnlag.url=http://localhost:8060/rest/infotrygd/grunnlag/sykepenger
+fpabakus.it.tsp.scopes=testscope
 fpabakus.it.ps.grunnlag.url=http://localhost:8060/rest/infotrygd/grunnlag/paaroerende-sykdom
 fpabakus.it.ps.scopes=testscope