La til dato sjekk for å sortere ut gjeldende vedtak

navikt · Feb 5, 2025 · dde2832 · dde2832
1 parent 7d15e7d
commit dde2832
Show file tree

Hide file tree

Showing 3 changed files with 23 additions and 31 deletions.
diff --git a/src/main/java/no/nav/pto/veilarbportefolje/opensearch/OpensearchIndexer.java b/src/main/java/no/nav/pto/veilarbportefolje/opensearch/OpensearchIndexer.java
@@ -123,17 +123,9 @@ private void flettInnNodvendigData(List<OppfolgingsBruker> brukere) {
         postgresOpensearchMapper.flettInnEnsligeForsorgereData(brukere);
         postgresOpensearchMapper.flettInnBarnUnder18Aar(brukere);
         postgresOpensearchMapper.flettInnTiltakshendelser(brukere);
-<<<<<<< Updated upstream
-        postgresOpensearchMapper.flettInnSiste14aVedtak(brukere);
         postgresOpensearchMapper.flettInnEldsteUtgattVarsel(brukere);
-
         postgresOpensearchMapper.flettInnOpplysningerOmArbeidssoekerData(brukere);
-=======
         postgresOpensearchMapper.flettInnGjeldende14aVedtak(brukere);
-        if (FeatureToggle.brukNyttArbeidssoekerregister(defaultUnleash)) {
-            postgresOpensearchMapper.flettInnOpplysningerOmArbeidssoekerData(brukere);
-        }
->>>>>>> Stashed changes
 
         if (brukere.isEmpty()) {
             log.warn("Skriver ikke til index da alle brukere i batchen er ugyldige");

diff --git a/src/main/java/no/nav/pto/veilarbportefolje/oppfolging/OppfolgingRepositoryV2.java b/src/main/java/no/nav/pto/veilarbportefolje/oppfolging/OppfolgingRepositoryV2.java
@@ -6,9 +6,7 @@
 import no.nav.common.types.identer.AktorId;
 import no.nav.pto.veilarbportefolje.domene.BrukerOppdatertInformasjon;
 import no.nav.pto.veilarbportefolje.domene.value.VeilederId;
-import no.nav.pto.veilarbportefolje.siste14aVedtak.Siste14aVedtakForBruker;
 import no.nav.pto.veilarbportefolje.util.DateUtils;
-import org.springframework.boot.autoconfigure.data.jdbc.JdbcRepositoriesAutoConfiguration;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Repository;
 
@@ -133,16 +131,7 @@ public Map<AktorId, Optional<ZonedDateTime>> hentStartDatoForOppfolging(Set<Akto
                 });
     }
 
-
-                Optional.ofNullable(
-                queryForObjectOrNull(
-                        () -> db.queryForObject("select startdato from oppfolging_data where aktoerid = any (?::varchar[])",
-                                (rs, i) -> DateUtils.toZonedDateTime(rs.getTimestamp("startdato")), aktoerId.get())
-                ));
-    }
-
     private static String listParam(List<String> identer) {
         return identer.stream().collect(Collectors.joining(",", "{", "}"));
     }
-
 }
diff --git a/src/main/java/no/nav/pto/veilarbportefolje/postgres/PostgresOpensearchMapper.java b/src/main/java/no/nav/pto/veilarbportefolje/postgres/PostgresOpensearchMapper.java
@@ -17,6 +17,7 @@
 import no.nav.pto.veilarbportefolje.kodeverk.KodeverkService;
 import no.nav.pto.veilarbportefolje.opensearch.domene.Endring;
 import no.nav.pto.veilarbportefolje.opensearch.domene.OppfolgingsBruker;
+import no.nav.pto.veilarbportefolje.oppfolging.OppfolgingRepositoryV2;
 import no.nav.pto.veilarbportefolje.persononinfo.PdlService;
 import no.nav.pto.veilarbportefolje.persononinfo.barnUnder18Aar.BarnUnder18AarData;
 import no.nav.pto.veilarbportefolje.persononinfo.barnUnder18Aar.BarnUnder18AarService;
@@ -27,7 +28,6 @@
 import no.nav.pto.veilarbportefolje.tiltakshendelse.TiltakshendelseRepository;
 import no.nav.pto.veilarbportefolje.tiltakshendelse.domain.Tiltakshendelse;
 import org.springframework.stereotype.Service;
-import no.nav.pto.veilarbportefolje.oppfolging.OppfolgingRepositoryV2;
 import java.time.ZonedDateTime;
 import java.util.*;
 import java.util.concurrent.atomic.AtomicInteger;
@@ -54,7 +54,7 @@ public class PostgresOpensearchMapper {
     private final TiltakshendelseRepository tiltakshendelseRepository;
     private final Siste14aVedtakRepository siste14aVedtakRepository;
     private final HendelseRepository hendelseRepository;
-    private final OppfolgingRepository oppfolgingRepositoryV2;
+    private final OppfolgingRepositoryV2 oppfolgingRepositoryV2;
 
     public void flettInnAktivitetsData(List<OppfolgingsBruker> brukere) {
         List<AktorId> aktoerIder = brukere.stream().map(OppfolgingsBruker::getAktoer_id).map(AktorId::of).toList();
@@ -239,20 +239,31 @@ public void flettInnGjeldende14aVedtak(List<OppfolgingsBruker> brukere) {
         Map<AktorId, Siste14aVedtakForBruker> aktorIdSiste14aVedtakMap = siste14aVedtakRepository.hentSiste14aVedtakForBrukere(brukere.stream().map(bruker ->
                 AktorId.of(bruker.getAktoer_id())).collect(Collectors.toSet())
         );
-
-        /*Map<AktorId, ZonedDateTime> aktorIdStartDatoForOppfolgingMap = oppfolgingRepositoryV2.hentStartDatoForOppfolging(brukere.stream().map(bruker ->
+        Map<AktorId, Optional<ZonedDateTime>> aktorIdStartDatoForOppfolgingMap = oppfolgingRepositoryV2.hentStartDatoForOppfolging(brukere.stream().map(bruker ->
                 AktorId.of(bruker.getAktoer_id())).collect(Collectors.toSet())
         );
-/*
+
         brukere.forEach(bruker -> {
-            if()
             Optional<Siste14aVedtakForBruker> maybeSiste14aVedtakForBruker = Optional.ofNullable(aktorIdSiste14aVedtakMap.get(AktorId.of(bruker.getAktoer_id())));
-            bruker.setGjeldendeVedtak14a(maybeSiste14aVedtakForBruker.map(siste14aVedtakForBruker -> new GjeldendeVedtak14a(
-                    siste14aVedtakForBruker.getInnsatsgruppe(),
-                    siste14aVedtakForBruker.getHovedmal(),
-                    siste14aVedtakForBruker.getFattetDato()
-            )).orElse(null));
-        });*/
+            Optional<ZonedDateTime> maybeStartDatoForOppfolging = aktorIdStartDatoForOppfolgingMap.getOrDefault(AktorId.of(bruker.getAktoer_id()), Optional.empty());
+
+            if(maybeStartDatoForOppfolging.isEmpty()) {
+                return;
+            }
+
+            boolean harBrukerGjeldende14aVedtak = maybeSiste14aVedtakForBruker.map(siste14aVedtakForBruker ->
+                    siste14aVedtakForBruker.getFattetDato().isAfter(maybeStartDatoForOppfolging.get()) ||
+                    siste14aVedtakForBruker.getFattetDato().isBefore(ZonedDateTime.parse("2017-12-02T19:37:25+02:00"))
+            ).orElse(false);
+
+            if(harBrukerGjeldende14aVedtak) {
+                bruker.setGjeldendeVedtak14a(maybeSiste14aVedtakForBruker.map(siste14aVedtakForBruker -> new GjeldendeVedtak14a(
+                        siste14aVedtakForBruker.getInnsatsgruppe(),
+                        siste14aVedtakForBruker.getHovedmal(),
+                        siste14aVedtakForBruker.getFattetDato()
+                )).orElse(null));
+            }
+        });
     }
 
     public void flettInnEldsteUtgattVarsel(List<OppfolgingsBruker> brukere) {