diff --git a/src/main/java/no/nav/pto/veilarbportefolje/opensearch/OpensearchIndexer.java b/src/main/java/no/nav/pto/veilarbportefolje/opensearch/OpensearchIndexer.java index 5ddcb6779..5139509cc 100644 --- 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 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 index d36cf2960..43704c38d 100644 --- 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> hentStartDatoForOppfolging(Set 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 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 index 2ac6844fe..4ecf5dbfe 100644 --- 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 brukere) { List aktoerIder = brukere.stream().map(OppfolgingsBruker::getAktoer_id).map(AktorId::of).toList(); @@ -239,20 +239,31 @@ public void flettInnGjeldende14aVedtak(List brukere) { Map aktorIdSiste14aVedtakMap = siste14aVedtakRepository.hentSiste14aVedtakForBrukere(brukere.stream().map(bruker -> AktorId.of(bruker.getAktoer_id())).collect(Collectors.toSet()) ); - - /*Map aktorIdStartDatoForOppfolgingMap = oppfolgingRepositoryV2.hentStartDatoForOppfolging(brukere.stream().map(bruker -> + Map> aktorIdStartDatoForOppfolgingMap = oppfolgingRepositoryV2.hentStartDatoForOppfolging(brukere.stream().map(bruker -> AktorId.of(bruker.getAktoer_id())).collect(Collectors.toSet()) ); -/* + brukere.forEach(bruker -> { - if() Optional 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 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 brukere) {