Fjerner logging av fullt orgnr (#1137)

espenjv · web-flow · commit 54a715fb1474 · 2021-01-14T08:02:50.000+01:00
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/domene/iay/InntektArbeidYtelseRepository.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/domene/iay/InntektArbeidYtelseRepository.java
@@ -21,8 +21,6 @@
 import javax.persistence.TypedQuery;
 
 import org.hibernate.jpa.QueryHints;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import no.nav.foreldrepenger.abakus.domene.iay.arbeidsforhold.ArbeidsforholdInformasjon;
 import no.nav.foreldrepenger.abakus.domene.iay.arbeidsforhold.ArbeidsforholdInformasjonBuilder;
@@ -45,7 +43,6 @@
 
 @ApplicationScoped
 public class InntektArbeidYtelseRepository {
-    private static final Logger log = LoggerFactory.getLogger(InntektArbeidYtelseRepository.class);
     private EntityManager entityManager;
     private KoblingRepository koblingRepository;
 
@@ -222,7 +219,7 @@ public Optional<OppgittOpptjening> hentOppgittOpptjeningFor(UUID oppgittOpptjeni
             " WHERE oo.eksternReferanse = :eksternReferanse", OppgittOpptjening.class);
         query.setParameter("eksternReferanse", oppgittOpptjeningEksternReferanse);
         var res = HibernateVerktøy.hentUniktResultat(query);
-        
+
         if(res.isEmpty()) {
             return Optional.empty();
         } else {
@@ -405,10 +402,8 @@ private void lagreOgFlush(KoblingReferanse koblingReferanse, InntektArbeidYtelse
         if (tidligereAggregat.isPresent()) {
             InntektArbeidYtelseGrunnlag aggregat = tidligereAggregat.get();
             if (diffResultat(aggregat, nyttGrunnlag, false).isEmpty()) {
-                log.info("Ingen diff mellom nytt og gammelt grunnlag. Nytt grunnlag: {}, Gammelt grunnlag: {}", nyttGrunnlag, aggregat);
                 return;
             }
-            log.info("Lagrer nytt grunnlag: {}", nyttGrunnlag);
 
             if (nyttGrunnlag.isAktiv()) {
                 aggregat.setAktivt(false);
@@ -595,7 +590,6 @@ private void lagreInntekt(AktørInntekt aktørInntekt) {
 
     private void lagreAktørYtelse(AktørYtelse aktørYtelse) {
         for (Ytelse ytelse : aktørYtelse.getAlleYtelser()) {
-            log.info("Lagrer ytelse {}", ytelse);
             entityManager.persist(ytelse);
             for (YtelseAnvist ytelseAnvist : ytelse.getYtelseAnvist()) {
                 entityManager.persist(ytelseAnvist);
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/iay/tjeneste/InntektsmeldingerRestTjeneste.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/iay/tjeneste/InntektsmeldingerRestTjeneste.java
@@ -22,9 +22,6 @@
 import javax.ws.rs.core.MediaType;
 import javax.ws.rs.core.Response;
 
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
 import com.fasterxml.jackson.annotation.JsonAutoDetect;
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
@@ -73,7 +70,6 @@ public class InntektsmeldingerRestTjeneste {
     private InntektsmeldingerTjeneste imTjeneste;
     private KoblingTjeneste koblingTjeneste;
     private InntektArbeidYtelseTjeneste iayTjeneste;
-    private static final Logger LOGGER = LoggerFactory.getLogger(InntektsmeldingerRestTjeneste.class);
 
     public InntektsmeldingerRestTjeneste() {
     } // RESTEASY ctor
@@ -124,7 +120,6 @@ public Response hentRefusjonskravDatoForSak(@NotNull @Valid InntektsmeldingerReq
         } else {
             InntektArbeidYtelseGrunnlag nyesteGrunnlag = iayTjeneste.hentAggregat(kobling.get().getKoblingReferanse());
             RefusjonskravDatoerDto refusjonskravDatoerDto = MapInntektsmeldinger.mapRefusjonskravdatoer(inntektsmeldinger, nyesteGrunnlag);
-            LOGGER.info("RefusjonskravDtoer for saksnummer ({}) er ({})", spesifikasjon.getSaksnummer(), refusjonskravDatoerDto);
             response = Response.ok(refusjonskravDatoerDto).build();
         }
         return response;
@@ -145,7 +140,7 @@ public UuidDto lagreInntektsmeldinger(@NotNull @TilpassetAbacAttributt(supplierC
         var koblingReferanse = new KoblingReferanse(mottattRequest.getKoblingReferanse());
         var koblingLås = Optional.ofNullable(koblingTjeneste.taSkrivesLås(koblingReferanse));
         var kobling = koblingTjeneste.finnEllerOpprett(mottattRequest.getYtelseType(), koblingReferanse, aktørId, new Saksnummer(mottattRequest.getSaksnummer()));
-        
+
         var informasjonBuilder = ArbeidsforholdInformasjonBuilder.oppdatere(imTjeneste.hentArbeidsforholdInformasjonForKobling(koblingReferanse));
 
         var inntektsmeldingerAggregat = new MapInntektsmeldinger.MapFraDto().map(informasjonBuilder, mottattRequest.getInntektsmeldinger());
@@ -155,7 +150,7 @@ public UuidDto lagreInntektsmeldinger(@NotNull @TilpassetAbacAttributt(supplierC
         var grunnlagReferanse = imTjeneste.lagre(koblingReferanse, informasjonBuilder, inntektsmeldinger);
 
         koblingTjeneste.lagre(kobling);
-        
+
         koblingLås.ifPresent(lås -> koblingTjeneste.oppdaterLåsVersjon(lås));
 
         if (grunnlagReferanse != null) {
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
@@ -221,22 +221,33 @@ private void oversettFrilanseArbeidsforhold(Kobling kobling,
                 aktørInntektBuilder.leggTilInntekt(byggInntekt(månedsinntekterGruppertPåArbeidsgiver, arbeidsgiver, aktørInntektBuilder, inntektOpptjening));
                 builder.leggTilAktørInntekt(aktørInntektBuilder);
             } else {
-                LOGGER.info("Inntekter rapportert på orgledd({}), blir IKKE lagret", arbeidsgiverIdentifikator);
+                LOGGER.info("Inntekter rapportert på orgledd({}), blir IKKE lagret", getIdentifikatorString(arbeidsgiverIdentifikator));
             }
         } else {
             if (PersonIdent.erGyldigFnr(arbeidsgiverIdentifikator)) {
                 var arbeidsgiverAktørId = aktørConsumer.hentAktørForIdent(new PersonIdent(arbeidsgiverIdentifikator), ytelse)
                     .orElseThrow(() -> InnhentingFeil.FACTORY.finnerIkkeAktørIdForArbeidsgiverSomErPrivatperson().toException());
                 arbeidsgiver = Arbeidsgiver.person(arbeidsgiverAktørId);
             } else {
-                LOGGER.info("Arbeidsgiveridentifikator: {}", arbeidsgiverIdentifikator);
+                LOGGER.info("Arbeidsgiveridentifikator: {}", getIdentifikatorString(arbeidsgiverIdentifikator));
                 arbeidsgiver = Arbeidsgiver.person(new AktørId(arbeidsgiverIdentifikator));
             }
             aktørInntektBuilder.leggTilInntekt(byggInntekt(månedsinntekterGruppertPåArbeidsgiver, arbeidsgiver, aktørInntektBuilder, inntektOpptjening));
             builder.leggTilAktørInntekt(aktørInntektBuilder);
         }
     }
 
+    private String getIdentifikatorString(String arbeidsgiverIdentifikator) {
+        if (arbeidsgiverIdentifikator == null) {
+            return null;
+        }
+        int length = arbeidsgiverIdentifikator.length();
+        if (length <= 4) {
+            return "*".repeat(length);
+        }
+        return "*".repeat(length - 4) + arbeidsgiverIdentifikator.substring(length - 4);
+    }
+
     private LocalDate finnHentedatoForJuridisk(Set<YearMonth> inntekterForMåneder) {
         return inntekterForMåneder.stream()
             .map(m -> LocalDate.of(m.getYear(), m.getMonth(), 1))
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
@@ -33,7 +33,6 @@
 import no.nav.foreldrepenger.abakus.vedtak.domene.VedtakYtelseRepository;
 
 public class YtelseRegisterInnhenting {
-    private static final Logger LOGGER = LoggerFactory.getLogger(YtelseRegisterInnhenting.class);
     private final InnhentingSamletTjeneste innhentingSamletTjeneste;
     private final VedtakYtelseRepository vedtakYtelseRepository;
 
@@ -47,13 +46,11 @@ void byggYtelser(Kobling behandling, AktørId aktørId, PersonIdent ident, Inter
 
         InntektArbeidYtelseAggregatBuilder.AktørYtelseBuilder aktørYtelseBuilder = inntektArbeidYtelseAggregatBuilder.getAktørYtelseBuilder(aktørId);
         aktørYtelseBuilder.tilbakestillYtelser();
-        LOGGER.info("Ytelseaggregat før ytelser er lagt til : {}", aktørYtelseBuilder);
 
         innhentFraYtelsesRegister(aktørId, behandling, aktørYtelseBuilder);
 
         if (!medGrunnlag) {
             // Ikke lenger relevant å hente eksternt for 2part eller engangsstønad
-            LOGGER.info("Ytelseaggregat etter at ytelser er lagt til : {}", aktørYtelseBuilder);
             inntektArbeidYtelseAggregatBuilder.leggTilAktørYtelse(aktørYtelseBuilder);
             return;
         }
@@ -69,7 +66,6 @@ void byggYtelser(Kobling behandling, AktørId aktørId, PersonIdent ident, Inter
             oversettMeldekortUtbetalingsgrunnlagTilYtelse(aktørYtelseBuilder, sak);
         }
 
-        LOGGER.info("Ytelseaggregat etter at ytelser er lagt til : {}", aktørYtelseBuilder);
         inntektArbeidYtelseAggregatBuilder.leggTilAktørYtelse(aktørYtelseBuilder);
     }
 
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/arbeidsforhold/ArbeidsforholdTjeneste.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/arbeidsforhold/ArbeidsforholdTjeneste.java
@@ -126,12 +126,23 @@ private Arbeidsavtale byggArbeidsavtaleRS(ArbeidsavtaleRS arbeidsavtale,
 
         if (arbeidsavtaleTom != null && arbeidsavtaleTom.isBefore(arbeidsavtaleFom)) {
             LOGGER.warn("Arbeidsavtale tom={} er før fom={} for orgnr={}, navArbeidsforholdId={}",
-                arbeidsavtaleTom, arbeidsavtaleFom, arbeidsforhold.getArbeidsgiver().getOrganisasjonsnummer(), arbeidsforhold.getNavArbeidsforholdId());
+                arbeidsavtaleTom, arbeidsavtaleFom, getIdentifikatorString(arbeidsforhold.getArbeidsgiver().getOrganisasjonsnummer()), arbeidsforhold.getNavArbeidsforholdId());
         }
 
         return builder.build();
     }
 
+    private String getIdentifikatorString(String arbeidsgiverIdentifikator) {
+        if (arbeidsgiverIdentifikator == null) {
+            return null;
+        }
+        int length = arbeidsgiverIdentifikator.length();
+        if (length <= 4) {
+            return "*".repeat(length);
+        }
+        return "*".repeat(length - 4) + arbeidsgiverIdentifikator.substring(length - 4);
+    }
+
     private Permisjon byggPermisjonRS(PermisjonPermitteringRS permisjonPermitteringRS) {
         return new Permisjon.Builder()
             .medPermisjonFom(permisjonPermitteringRS.getPeriode().getFom())
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/arbeidsgiver/virksomhet/VirksomhetTjeneste.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/arbeidsgiver/virksomhet/VirksomhetTjeneste.java
@@ -89,14 +89,25 @@ public Virksomhet hentOrganisasjonMedHensynTilJuridisk(String orgNummer, LocalDa
 
         if (OrganisasjonType.JURIDISK_ENHET.equals(virksomhet.getOrganisasjonstype())) {
             Optional<Virksomhet> unikVirksomhetForJuridiskEnhet = hentUnikVirksomhetForJuridiskEnhet(orgNummer, hentedato);
-            LOGGER.info("ABAKUS EREG fant {} unik virksomhet for juridisk {}", unikVirksomhetForJuridiskEnhet.isPresent() ? "en" : "ikke",  orgNummer);
+            LOGGER.info("ABAKUS EREG fant {} unik virksomhet for juridisk {}", unikVirksomhetForJuridiskEnhet.isPresent() ? "en" : "ikke",  getIdentifikatorString(orgNummer));
             return unikVirksomhetForJuridiskEnhet.orElse(virksomhet);
         }
         if (OrganisasjonType.ORGLEDD.equals(virksomhet.getOrganisasjonstype()))
             throw OrganisasjonTjenesteFeil.FACTORY.organisasjonErOrgledd(TJENESTE).toException();
         return virksomhet;
     }
 
+    private String getIdentifikatorString(String arbeidsgiverIdentifikator) {
+        if (arbeidsgiverIdentifikator == null) {
+            return null;
+        }
+        int length = arbeidsgiverIdentifikator.length();
+        if (length <= 4) {
+            return "*".repeat(length);
+        }
+        return "*".repeat(length - 4) + arbeidsgiverIdentifikator.substring(length - 4);
+    }
+
     private Optional<Virksomhet> hentUnikVirksomhetForJuridiskEnhet(String orgNummer, LocalDate hentedato) {
         var jenhet = hentResponseJuridisk(orgNummer);
 
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
@@ -61,12 +61,23 @@ public int hashCode() {
     @Override
     public String toString() {
         return "InfotrygdYtelseArbeid{" +
-            "orgnr='" + orgnr + '\'' +
+            "orgnr='" + getOrgnrString() + '\'' +
             ", inntekt=" + inntekt +
             ", inntektperiode=" + inntektperiode +
             ", refusjon=" + refusjon +
             '}';
     }
+
+    private String getOrgnrString() {
+        if (orgnr == null) {
+            return null;
+        }
+        int length = orgnr.length();
+        if (length <= 4) {
+            return "*".repeat(length);
+        }
+        return "*".repeat(length - 4) + orgnr.substring(length - 4);
+    }
 }
 
 
