wip

Author: slovrid

Diff for: src/main/java/no/nav/pto/veilarbportefolje/opensearch/OpensearchIndexer.java

@@ -125,6 +125,7 @@ private void flettInnNodvendigData(List<OppfolgingsBruker> brukere) {
         postgresOpensearchMapper.flettInnEnsligeForsorgereData(brukere);
         postgresOpensearchMapper.flettInnBarnUnder18Aar(brukere);
         postgresOpensearchMapper.flettInnTiltakshendelser(brukere);
+        postgresOpensearchMapper.flettInnSiste14aVedtak(brukere);
         if (FeatureToggle.brukNyttArbeidssoekerregister(defaultUnleash)) {
             postgresOpensearchMapper.flettInnOpplysningerOmArbeidssoekerData(brukere);
         }

Diff for: src/main/java/no/nav/pto/veilarbportefolje/opensearch/domene/OppfolgingsBruker.java

@@ -7,6 +7,7 @@
 import no.nav.pto.veilarbportefolje.domene.Statsborgerskap;
 import no.nav.pto.veilarbportefolje.persononinfo.barnUnder18Aar.BarnUnder18AarData;
 import no.nav.pto.veilarbportefolje.siste14aVedtak.Avvik14aVedtak;
+import no.nav.pto.veilarbportefolje.siste14aVedtak.Siste14aVedtak;
 import no.nav.pto.veilarbportefolje.tiltakshendelse.domain.Tiltakshendelse;
 
 import java.time.LocalDate;
@@ -131,4 +132,6 @@ public class OppfolgingsBruker {
     String fargekategori;
     String fargekategori_enhetId;
     Tiltakshendelse tiltakshendelse;
+
+    Siste14aVedtak siste14aVedtak;
 }

Diff for: src/main/java/no/nav/pto/veilarbportefolje/postgres/PostgresOpensearchMapper.java

@@ -19,6 +19,8 @@
 import no.nav.pto.veilarbportefolje.postgres.utils.AvtaltAktivitetEntity;
 import no.nav.pto.veilarbportefolje.siste14aVedtak.Avvik14aVedtak;
 import no.nav.pto.veilarbportefolje.siste14aVedtak.Avvik14aVedtakService;
+import no.nav.pto.veilarbportefolje.siste14aVedtak.Siste14aVedtak;
+import no.nav.pto.veilarbportefolje.siste14aVedtak.Siste14aVedtakRepository;
 import no.nav.pto.veilarbportefolje.sisteendring.SisteEndringService;
 import no.nav.pto.veilarbportefolje.tiltakshendelse.TiltakshendelseRepository;
 import no.nav.pto.veilarbportefolje.tiltakshendelse.domain.Tiltakshendelse;
@@ -48,6 +50,7 @@ public class PostgresOpensearchMapper {
     private final EnsligeForsorgereService ensligeForsorgereService;
     private final ArbeidssoekerService arbeidssoekerService;
     private final TiltakshendelseRepository tiltakshendelseRepository;
+    private final Siste14aVedtakRepository siste14aVedtakRepository;
 
     public void flettInnAktivitetsData(List<OppfolgingsBruker> brukere) {
         List<AktorId> aktoerIder = brukere.stream().map(OppfolgingsBruker::getAktoer_id).map(AktorId::of).toList();
@@ -227,4 +230,11 @@ public void flettInnOpplysningerOmArbeidssoekerData(List<OppfolgingsBruker> bruk
             });
         });
     }
+
+    public void flettInnSiste14aVedtak(List<OppfolgingsBruker> brukere) {
+        Map<AktorId, Siste14aVedtak> aktorIdSiste14aVedtakMap = siste14aVedtakRepository.hentSiste14aVedtakForBrukere(brukere.stream().map(bruker ->
+                AktorId.of(bruker.getAktoer_id())).collect(Collectors.toSet())
+        );
+        brukere.forEach(bruker -> bruker.setSiste14aVedtak(aktorIdSiste14aVedtakMap.get(AktorId.of(bruker.getAktoer_id()))));
+    }
 }