Merge pull request #1855 from navikt/dev

Prodsette #1853
navikt · Feb 14, 2025 · cdcd1ed · cdcd1ed
2 parents 1755f5e + 7922f60
commit cdcd1ed
Show file tree

Hide file tree

Showing 29 changed files with 569 additions and 132 deletions.
diff --git a/src/main/java/no/nav/pto/veilarbportefolje/domene/Bruker.java b/src/main/java/no/nav/pto/veilarbportefolje/domene/Bruker.java
@@ -11,8 +11,8 @@
 import no.nav.pto.veilarbportefolje.opensearch.domene.OppfolgingsBruker;
 import no.nav.pto.veilarbportefolje.persononinfo.barnUnder18Aar.BarnUnder18AarData;
 import no.nav.pto.veilarbportefolje.persononinfo.domene.Adressebeskyttelse;
-import no.nav.pto.veilarbportefolje.siste14aVedtak.Avvik14aVedtak;
-import no.nav.pto.veilarbportefolje.siste14aVedtak.GjeldendeVedtak14a;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.avvik14aVedtak.Avvik14aVedtak;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.gjeldende14aVedtak.GjeldendeVedtak14a;
 import no.nav.pto.veilarbportefolje.util.OppfolgingUtils;
 
 import java.sql.Timestamp;

diff --git a/src/main/java/no/nav/pto/veilarbportefolje/domene/Filtervalg.java b/src/main/java/no/nav/pto/veilarbportefolje/domene/Filtervalg.java
@@ -6,7 +6,7 @@
 import no.nav.pto.veilarbportefolje.domene.filtervalg.UtdanningBestattSvar;
 import no.nav.pto.veilarbportefolje.domene.filtervalg.UtdanningGodkjentSvar;
 import no.nav.pto.veilarbportefolje.domene.filtervalg.UtdanningSvar;
-import no.nav.pto.veilarbportefolje.siste14aVedtak.Avvik14aVedtak;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.avvik14aVedtak.Avvik14aVedtak;
 import no.nav.pto.veilarbportefolje.sisteendring.SisteEndringsKategori;
 import no.nav.pto.veilarbportefolje.vedtakstotte.Hovedmal;
 import no.nav.pto.veilarbportefolje.vedtakstotte.Innsatsgruppe;

diff --git a/src/main/java/no/nav/pto/veilarbportefolje/kafka/KafkaConfigCommon.java b/src/main/java/no/nav/pto/veilarbportefolje/kafka/KafkaConfigCommon.java
@@ -48,8 +48,8 @@
 import no.nav.pto.veilarbportefolje.oppfolgingsbruker.OppfolgingsbrukerServiceV2;
 import no.nav.pto.veilarbportefolje.persononinfo.PdlBrukerdataKafkaService;
 import no.nav.pto.veilarbportefolje.persononinfo.PdlResponses.PdlDokument;
-import no.nav.pto.veilarbportefolje.siste14aVedtak.Siste14aVedtakKafkaDto;
-import no.nav.pto.veilarbportefolje.siste14aVedtak.Siste14aVedtakService;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak.Siste14aVedtakKafkaDto;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak.Siste14aVedtakService;
 import no.nav.pto.veilarbportefolje.sistelest.SistLestKafkaMelding;
 import no.nav.pto.veilarbportefolje.sistelest.SistLestService;
 import no.nav.pto.veilarbportefolje.tiltakshendelse.TiltakshendelseService;
@@ -64,7 +64,6 @@
 import java.util.List;
 import java.util.Properties;
 import java.util.stream.Collectors;
-import java.util.stream.Stream;
 
 import static no.nav.common.kafka.consumer.util.ConsumerUtils.findConsumerConfigsWithStoreOnFailure;
 import static no.nav.common.kafka.util.KafkaPropertiesPreset.aivenDefaultConsumerProperties;

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,10 +123,9 @@ private void flettInnNodvendigData(List<OppfolgingsBruker> brukere) {
         postgresOpensearchMapper.flettInnEnsligeForsorgereData(brukere);
         postgresOpensearchMapper.flettInnBarnUnder18Aar(brukere);
         postgresOpensearchMapper.flettInnTiltakshendelser(brukere);
-        postgresOpensearchMapper.flettInnSiste14aVedtak(brukere);
         postgresOpensearchMapper.flettInnEldsteUtgattVarsel(brukere);
-
         postgresOpensearchMapper.flettInnOpplysningerOmArbeidssoekerData(brukere);
+        postgresOpensearchMapper.flettInnGjeldende14aVedtak(brukere);
 
         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/opensearch/OpensearchIndexerV2.java b/src/main/java/no/nav/pto/veilarbportefolje/opensearch/OpensearchIndexerV2.java
@@ -14,7 +14,7 @@
 import no.nav.pto.veilarbportefolje.hendelsesfilter.Hendelse;
 import no.nav.pto.veilarbportefolje.oppfolging.OppfolgingRepositoryV2;
 import no.nav.pto.veilarbportefolje.oppfolgingsbruker.OppfolgingsbrukerEntity;
-import no.nav.pto.veilarbportefolje.siste14aVedtak.GjeldendeVedtak14a;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.gjeldende14aVedtak.GjeldendeVedtak14a;
 import no.nav.pto.veilarbportefolje.sisteendring.SisteEndringDTO;
 import no.nav.pto.veilarbportefolje.sisteendring.SisteEndringsKategori;
 import no.nav.pto.veilarbportefolje.tiltakshendelse.domain.Tiltakshendelse;

diff --git a/src/main/java/no/nav/pto/veilarbportefolje/opensearch/OpensearchService.java b/src/main/java/no/nav/pto/veilarbportefolje/opensearch/OpensearchService.java
@@ -13,7 +13,7 @@
 import no.nav.pto.veilarbportefolje.opensearch.domene.*;
 import no.nav.pto.veilarbportefolje.opensearch.domene.Avvik14aStatistikkResponse.Avvik14aStatistikkAggregation.Avvik14aStatistikkFilter.Avvik14aStatistikkBuckets;
 import no.nav.pto.veilarbportefolje.opensearch.domene.StatustallResponse.StatustallAggregation.StatustallFilter.StatustallBuckets;
-import no.nav.pto.veilarbportefolje.siste14aVedtak.Avvik14aVedtak;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.avvik14aVedtak.Avvik14aVedtak;
 import no.nav.pto.veilarbportefolje.vedtakstotte.VedtaksstotteClient;
 import org.apache.commons.lang3.StringUtils;
 import org.opensearch.action.search.SearchRequest;

diff --git a/src/main/java/no/nav/pto/veilarbportefolje/opensearch/domene/OppfolgingsBruker.java b/src/main/java/no/nav/pto/veilarbportefolje/opensearch/domene/OppfolgingsBruker.java
@@ -7,8 +7,8 @@
 import no.nav.pto.veilarbportefolje.domene.Statsborgerskap;
 import no.nav.pto.veilarbportefolje.hendelsesfilter.Hendelse;
 import no.nav.pto.veilarbportefolje.persononinfo.barnUnder18Aar.BarnUnder18AarData;
-import no.nav.pto.veilarbportefolje.siste14aVedtak.Avvik14aVedtak;
-import no.nav.pto.veilarbportefolje.siste14aVedtak.GjeldendeVedtak14a;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.avvik14aVedtak.Avvik14aVedtak;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.gjeldende14aVedtak.GjeldendeVedtak14a;
 import no.nav.pto.veilarbportefolje.tiltakshendelse.domain.Tiltakshendelse;
 
 import java.time.LocalDate;

diff --git a/src/main/java/no/nav/pto/veilarbportefolje/oppfolging/OppfolgingAvsluttetService.java b/src/main/java/no/nav/pto/veilarbportefolje/oppfolging/OppfolgingAvsluttetService.java
@@ -15,7 +15,7 @@
 import no.nav.pto.veilarbportefolje.oppfolgingsbruker.OppfolgingsbrukerServiceV2;
 import no.nav.pto.veilarbportefolje.persononinfo.PdlIdentRepository;
 import no.nav.pto.veilarbportefolje.persononinfo.PdlService;
-import no.nav.pto.veilarbportefolje.siste14aVedtak.Siste14aVedtakService;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak.Siste14aVedtakService;
 import no.nav.pto.veilarbportefolje.sisteendring.SisteEndringService;
 import org.springframework.stereotype.Service;
 

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,13 +6,14 @@
 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.util.DateUtils;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Repository;
 
 import java.sql.ResultSet;
 import java.time.ZonedDateTime;
-import java.util.List;
-import java.util.Optional;
+import java.util.*;
+import java.util.stream.Collectors;
 
 import static no.nav.pto.veilarbportefolje.database.PostgresTable.OPPFOLGING_DATA.AKTOERID;
 import static no.nav.pto.veilarbportefolje.database.PostgresTable.OPPFOLGING_DATA.MANUELL;
@@ -115,4 +116,22 @@ public Optional<VeilederId> hentVeilederForBruker(AktorId aktoerId) {
                                 (rs, i) -> VeilederId.veilederIdOrNull(rs.getString("veilederid")), aktoerId.get())
                 ));
     }
+
+    public Map<AktorId, Optional<ZonedDateTime>> hentStartDatoForOppfolging(Set<AktorId> aktoerIder) {
+        Map<AktorId, Optional<ZonedDateTime>> result = new HashMap<>();
+        return db.query("select startdato, aktoerid from oppfolging_data where aktoerid = any (?::varchar[])",
+                ps -> ps.setString(1, listParam(aktoerIder.stream().map(AktorId::get).toList())),
+                (ResultSet rs) -> {
+                    while (rs.next()) {
+                        ZonedDateTime startDatoForOppfolging = DateUtils.toZonedDateTime(rs.getTimestamp("startdato"));
+                        AktorId aktoerid = AktorId.of(rs.getString("aktoerid"));
+                        result.put(aktoerid, Optional.ofNullable(startDatoForOppfolging));
+                    }
+                    return result;
+                });
+    }
+
+    private static String listParam(List<String> identer) {
+        return identer.stream().collect(Collectors.joining(",", "{", "}"));
+    }
 }
diff --git a/src/main/java/no/nav/pto/veilarbportefolje/oppfolging/OppfolgingStartetService.java b/src/main/java/no/nav/pto/veilarbportefolje/oppfolging/OppfolgingStartetService.java
@@ -7,7 +7,7 @@
 import no.nav.pto.veilarbportefolje.opensearch.OpensearchIndexer;
 import no.nav.pto.veilarbportefolje.oppfolgingsbruker.OppfolgingsbrukerServiceV2;
 import no.nav.pto.veilarbportefolje.persononinfo.PdlService;
-import no.nav.pto.veilarbportefolje.siste14aVedtak.Siste14aVedtakService;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak.Siste14aVedtakService;
 import org.springframework.stereotype.Service;
 
 import java.time.ZonedDateTime;

diff --git a/...e14aVedtak/Avvik14aStatistikkMetrikk.java → ...k14aVedtak/Avvik14aStatistikkMetrikk.java b/...e14aVedtak/Avvik14aStatistikkMetrikk.java → ...k14aVedtak/Avvik14aStatistikkMetrikk.java
@@ -1,4 +1,4 @@
-package no.nav.pto.veilarbportefolje.siste14aVedtak;
+package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.avvik14aVedtak;
 
 import io.micrometer.core.instrument.MeterRegistry;
 import io.micrometer.core.instrument.binder.MeterBinder;

diff --git a/...efolje/siste14aVedtak/Avvik14aVedtak.java → ...tak14a/avvik14aVedtak/Avvik14aVedtak.java b/...efolje/siste14aVedtak/Avvik14aVedtak.java → ...tak14a/avvik14aVedtak/Avvik14aVedtak.java
@@ -1,4 +1,4 @@
-package no.nav.pto.veilarbportefolje.siste14aVedtak;
+package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.avvik14aVedtak;
 public enum Avvik14aVedtak {
     INNSATSGRUPPE_ULIK,
     HOVEDMAAL_ULIK,

diff --git a/...siste14aVedtak/Avvik14aVedtakService.java → ...avvik14aVedtak/Avvik14aVedtakService.java b/...siste14aVedtak/Avvik14aVedtakService.java → ...avvik14aVedtak/Avvik14aVedtakService.java
@@ -1,4 +1,4 @@
-package no.nav.pto.veilarbportefolje.siste14aVedtak;
+package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.avvik14aVedtak;
 
 import lombok.RequiredArgsConstructor;
 import no.nav.common.types.identer.AktorId;
@@ -10,6 +10,8 @@
 import no.nav.pto.veilarbportefolje.domene.Vedtak14aInfo;
 import no.nav.pto.veilarbportefolje.oppfolgingsbruker.OppfolgingsbrukerEntity;
 import no.nav.pto.veilarbportefolje.oppfolgingsbruker.OppfolgingsbrukerRepositoryV3;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.gjeldende14aVedtak.Gjeldende14aVedtak;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.gjeldende14aVedtak.Gjeldende14aVedtakService;
 import org.springframework.stereotype.Service;
 
 import java.util.Collections;
@@ -27,7 +29,7 @@
 public class Avvik14aVedtakService {
 
     final OppfolgingsbrukerRepositoryV3 oppfolgingsbrukerRepositoryV3;
-    final Siste14aVedtakRepository siste14aVedtakRepository;
+    final Gjeldende14aVedtakService gjeldende14aVedtakService;
 
     public Map<GjeldendeIdenter, Avvik14aVedtak> hentAvvik(Set<GjeldendeIdenter> brukere) {
         if (brukere.isEmpty()) {
@@ -39,29 +41,29 @@ public Map<GjeldendeIdenter, Avvik14aVedtak> hentAvvik(Set<GjeldendeIdenter> bru
                         brukere.stream().map(GjeldendeIdenter::getFnr).collect(Collectors.toSet())
                 );
 
-        Map<AktorId, Siste14aVedtakForBruker> aktorIdSiste14aVedtakMap =
-                siste14aVedtakRepository.hentSiste14aVedtakForBrukere(
+        Map<AktorId, Optional<Gjeldende14aVedtak>> aktorIdGjeldende14aVedtakMap =
+                gjeldende14aVedtakService.hentGjeldende14aVedtak(
                         brukere.stream().map(GjeldendeIdenter::getAktorId).collect(Collectors.toSet())
                 );
 
 
         return brukere.stream().map((GjeldendeIdenter identer) -> {
-            Vedtak14aInfo vedtak14aInfo = mapTilVedtak14aInfo(fnrOppfolgingsbrukerEntityMap, aktorIdSiste14aVedtakMap, identer);
+            Vedtak14aInfo vedtak14aInfo = mapTilVedtak14aInfo(fnrOppfolgingsbrukerEntityMap, aktorIdGjeldende14aVedtakMap, identer);
             Avvik14aVedtak avvik14aVedtak = finnAvvik(vedtak14aInfo);
 
             return Map.entry(identer, avvik14aVedtak);
         }).collect(toMap(Entry::getKey, Entry::getValue));
     }
 
-    private Vedtak14aInfo mapTilVedtak14aInfo(Map<Fnr, OppfolgingsbrukerEntity> fnrOppfolgingsbrukerEntityMap, Map<AktorId, Siste14aVedtakForBruker> aktorIdSiste14aVedtakMap, GjeldendeIdenter identer) {
-        Optional<OppfolgingsbrukerEntity> oppfolgingsbruker = Optional.ofNullable(fnrOppfolgingsbrukerEntityMap.getOrDefault(identer.getFnr(), null));
-        Optional<Siste14aVedtakForBruker> siste14aVedtak = Optional.ofNullable(aktorIdSiste14aVedtakMap.getOrDefault(identer.getAktorId(), null));
+    private Vedtak14aInfo mapTilVedtak14aInfo(Map<Fnr, OppfolgingsbrukerEntity> fnrOppfolgingsbrukerEntityMap, Map<AktorId, Optional<Gjeldende14aVedtak>> aktorIdGjeldende14aVedtakMap, GjeldendeIdenter identer) {
+        Optional<OppfolgingsbrukerEntity> maybeOppfolgingsbruker = Optional.ofNullable(fnrOppfolgingsbrukerEntityMap.getOrDefault(identer.getFnr(), null));
+        Optional<Gjeldende14aVedtak> maybeGjeldende14aVedtak = aktorIdGjeldende14aVedtakMap.getOrDefault(identer.getAktorId(), Optional.empty());
 
         return Vedtak14aInfo.builder()
-                .arenaInnsatsgruppe(oppfolgingsbruker.map(OppfolgingsbrukerEntity::kvalifiseringsgruppekode).map(kvalifiseringsgruppeKode -> valueOfOrNull(ArenaInnsatsgruppe.class, kvalifiseringsgruppeKode)).orElse(null))
-                .arenaHovedmal(oppfolgingsbruker.map(OppfolgingsbrukerEntity::hovedmaalkode).map(hovedmaal -> valueOfOrNull(ArenaHovedmal.class, hovedmaal)).orElse(null))
-                .innsatsgruppe(siste14aVedtak.map(Siste14aVedtakForBruker::getInnsatsgruppe).orElse(null))
-                .hovedmal(siste14aVedtak.map(Siste14aVedtakForBruker::getHovedmal).orElse(null)).build();
+                .arenaInnsatsgruppe(maybeOppfolgingsbruker.map(OppfolgingsbrukerEntity::kvalifiseringsgruppekode).map(kvalifiseringsgruppeKode -> valueOfOrNull(ArenaInnsatsgruppe.class, kvalifiseringsgruppeKode)).orElse(null))
+                .arenaHovedmal(maybeOppfolgingsbruker.map(OppfolgingsbrukerEntity::hovedmaalkode).map(hovedmaal -> valueOfOrNull(ArenaHovedmal.class, hovedmaal)).orElse(null))
+                .innsatsgruppe(maybeGjeldende14aVedtak.map(Gjeldende14aVedtak::getInnsatsgruppe).orElse(null))
+                .hovedmal(maybeGjeldende14aVedtak.map(Gjeldende14aVedtak::getHovedmal).orElse(null)).build();
     }
 
     private Avvik14aVedtak finnAvvik(Vedtak14aInfo vedtak14aInfo) {

diff --git a/...to/veilarbportefolje/oppfolgingsvedtak14a/gjeldende14aVedtak/Gjeldende14aVedtakService.kt b/...to/veilarbportefolje/oppfolgingsvedtak14a/gjeldende14aVedtak/Gjeldende14aVedtakService.kt
@@ -0,0 +1,84 @@
+package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.gjeldende14aVedtak
+
+import no.nav.common.types.identer.AktorId
+import no.nav.pto.veilarbportefolje.oppfolging.OppfolgingRepositoryV2
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak.Siste14aVedtakForBruker
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak.Siste14aVedtakRepository
+import no.nav.pto.veilarbportefolje.vedtakstotte.Hovedmal
+import no.nav.pto.veilarbportefolje.vedtakstotte.Innsatsgruppe
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.stereotype.Service
+import java.time.ZoneId
+import java.time.ZonedDateTime
+import java.util.*
+
+@Service
+class Gjeldende14aVedtakService(
+    @Autowired val siste14aVedtakRepository: Siste14aVedtakRepository,
+    @Autowired val oppfolgingRepositoryV2: OppfolgingRepositoryV2
+) {
+    fun hentGjeldende14aVedtak(brukerIdenter: Set<AktorId>): Map<AktorId, Optional<Gjeldende14aVedtak>> {
+        val aktorIdSiste14aVedtakMap: Map<AktorId, Optional<Siste14aVedtakForBruker>> =
+            siste14aVedtakRepository.hentSiste14aVedtakForBrukere(brukerIdenter)
+                .mapValues { Optional.ofNullable(it.value) }
+        val aktorIdStartDatoOppfolgingMap: Map<AktorId, Optional<ZonedDateTime>> =
+            oppfolgingRepositoryV2.hentStartDatoForOppfolging(brukerIdenter)
+
+        return brukerIdenter.associate { brukerIdent ->
+            val maybeSiste14aVedtak: Optional<Siste14aVedtakForBruker> =
+                aktorIdSiste14aVedtakMap[brukerIdent] ?: Optional.empty()
+            val maybeStartDatoOppfolging: Optional<ZonedDateTime> =
+                aktorIdStartDatoOppfolgingMap[brukerIdent] ?: Optional.empty()
+
+            if (maybeSiste14aVedtak.isEmpty || maybeStartDatoOppfolging.isEmpty) {
+                return@associate brukerIdent to Optional.empty<Gjeldende14aVedtak>()
+            }
+
+            if (!sjekkOmVedtakErGjeldende(maybeSiste14aVedtak.get(), maybeStartDatoOppfolging.get())) {
+                return@associate brukerIdent to Optional.empty<Gjeldende14aVedtak>()
+            }
+
+            return@associate brukerIdent to maybeSiste14aVedtak.get().let {
+                Optional.of(
+                    Gjeldende14aVedtak(
+                        aktorId = it.aktorId,
+                        innsatsgruppe = it.innsatsgruppe,
+                        hovedmal = it.hovedmal,
+                        fattetDato = it.fattetDato
+                    )
+                )
+            }
+        }
+    }
+
+    companion object {
+        @JvmField
+        val LANSERINGSDATO_VEILARBOPPFOLGING_OPPFOLGINGSPERIODE: ZonedDateTime =
+            ZonedDateTime.of(2017, 12, 4, 0, 0, 0, 0, ZoneId.systemDefault())
+
+        @JvmStatic
+        fun sjekkOmVedtakErGjeldende(
+            siste14aVedtakForBruker: Siste14aVedtakForBruker,
+            startDatoInnevarendeOppfolgingsperiode: ZonedDateTime
+        ): Boolean {
+            val erVedtaketFattetIInnevarendeOppfolgingsperiode =
+                siste14aVedtakForBruker.fattetDato.isAfter(startDatoInnevarendeOppfolgingsperiode)
+            val erVedtaketFattetForLanseringsdatoForVeilarboppfolging = siste14aVedtakForBruker.fattetDato
+                .isBefore(LANSERINGSDATO_VEILARBOPPFOLGING_OPPFOLGINGSPERIODE)
+            val erStartdatoForOppfolgingsperiodeLikLanseringsdatoForVeilarboppfolging =
+                !startDatoInnevarendeOppfolgingsperiode
+                    .isAfter(LANSERINGSDATO_VEILARBOPPFOLGING_OPPFOLGINGSPERIODE)
+
+            return erVedtaketFattetIInnevarendeOppfolgingsperiode ||
+                    (erVedtaketFattetForLanseringsdatoForVeilarboppfolging
+                            && erStartdatoForOppfolgingsperiodeLikLanseringsdatoForVeilarboppfolging)
+        }
+    }
+}
+
+data class Gjeldende14aVedtak(
+    val aktorId: AktorId,
+    val innsatsgruppe: Innsatsgruppe,
+    val hovedmal: Hovedmal?,
+    val fattetDato: ZonedDateTime
+)
diff --git a/...je/siste14aVedtak/GjeldendeVedtak14a.java → ...jeldende14aVedtak/GjeldendeVedtak14a.java b/...je/siste14aVedtak/GjeldendeVedtak14a.java → ...jeldende14aVedtak/GjeldendeVedtak14a.java
@@ -1,4 +1,4 @@
-package no.nav.pto.veilarbportefolje.siste14aVedtak;
+package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.gjeldende14aVedtak;
 
 import no.nav.pto.veilarbportefolje.vedtakstotte.Hovedmal;
 import no.nav.pto.veilarbportefolje.vedtakstotte.Innsatsgruppe;

diff --git a/.../siste14aVedtak/Siste14aVedtakApiDto.java → .../siste14aVedtak/Siste14aVedtakApiDto.java b/.../siste14aVedtak/Siste14aVedtakApiDto.java → .../siste14aVedtak/Siste14aVedtakApiDto.java
@@ -1,4 +1,4 @@
-package no.nav.pto.veilarbportefolje.siste14aVedtak;
+package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

diff --git a/...ste14aVedtak/Siste14aVedtakForBruker.java → ...ste14aVedtak/Siste14aVedtakForBruker.java b/...ste14aVedtak/Siste14aVedtakForBruker.java → ...ste14aVedtak/Siste14aVedtakForBruker.java
@@ -1,4 +1,4 @@
-package no.nav.pto.veilarbportefolje.siste14aVedtak;
+package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak;
 
 import lombok.AllArgsConstructor;
 import lombok.Builder;
@@ -21,6 +21,26 @@ public class Siste14aVedtakForBruker {
     ZonedDateTime fattetDato;
     boolean fraArena;
 
+    public AktorId getAktorId() {
+        return aktorId;
+    }
+
+    public Innsatsgruppe getInnsatsgruppe() {
+        return innsatsgruppe;
+    }
+
+    public Hovedmal getHovedmal() {
+        return hovedmal;
+    }
+
+    public ZonedDateTime getFattetDato() {
+        return fattetDato;
+    }
+
+    public boolean isFraArena() {
+        return fraArena;
+    }
+
     public static Siste14aVedtakForBruker fraKafkaDto(Siste14aVedtakKafkaDto dto) {
         return new Siste14aVedtakForBruker(dto.aktorId, dto.innsatsgruppe, dto.hovedmal, dto.fattetDato, dto.fraArena);
     }

diff --git a/...iste14aVedtak/Siste14aVedtakKafkaDto.java → ...iste14aVedtak/Siste14aVedtakKafkaDto.java b/...iste14aVedtak/Siste14aVedtakKafkaDto.java → ...iste14aVedtak/Siste14aVedtakKafkaDto.java
@@ -1,4 +1,4 @@
-package no.nav.pto.veilarbportefolje.siste14aVedtak;
+package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

diff --git a/...te14aVedtak/Siste14aVedtakRepository.java → ...te14aVedtak/Siste14aVedtakRepository.java b/...te14aVedtak/Siste14aVedtakRepository.java → ...te14aVedtak/Siste14aVedtakRepository.java
@@ -1,4 +1,4 @@
-package no.nav.pto.veilarbportefolje.siste14aVedtak;
+package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak;
 
 import lombok.RequiredArgsConstructor;
 import lombok.SneakyThrows;

diff --git a/...siste14aVedtak/Siste14aVedtakService.java → ...siste14aVedtak/Siste14aVedtakService.java b/...siste14aVedtak/Siste14aVedtakService.java → ...siste14aVedtak/Siste14aVedtakService.java
@@ -1,10 +1,11 @@
-package no.nav.pto.veilarbportefolje.siste14aVedtak;
+package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak;
 
 import lombok.RequiredArgsConstructor;
 import no.nav.common.types.identer.AktorId;
 import no.nav.common.types.identer.Fnr;
 import no.nav.pto.veilarbportefolje.kafka.KafkaCommonNonKeyedConsumerService;
 import no.nav.pto.veilarbportefolje.opensearch.OpensearchIndexerV2;
+import no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.gjeldende14aVedtak.GjeldendeVedtak14a;
 import no.nav.pto.veilarbportefolje.persononinfo.PdlIdentRepository;
 import no.nav.pto.veilarbportefolje.persononinfo.domene.IdenterForBruker;
 import no.nav.pto.veilarbportefolje.vedtakstotte.VedtaksstotteClient;