Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Flett inn gjeldende § 14 a-vedtak #1853

Merged
merged 20 commits into from
Feb 14, 2025
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
7d15e7d
WIP
sneha-d-desai Feb 5, 2025
dde2832
La til dato sjekk for å sortere ut gjeldende vedtak
sneha-d-desai Feb 5, 2025
ba13db6
Refaktorte og fikset feil test
sneha-d-desai Feb 5, 2025
7903dec
Begynne på logikk for å bruke riktig § 14 a-vedtak som gjeldende
sneha-d-desai Feb 5, 2025
be281e3
La til dato sjekk for å sortere ut gjeldende vedtak
sneha-d-desai Feb 5, 2025
dc7bf89
Refaktorte og fikset feil test
sneha-d-desai Feb 5, 2025
1d04c7a
Merge branch 'filtrer-gjeldende-vedtak14a' of github.com:navikt/veila…
sneha-d-desai Feb 6, 2025
c981047
Legg til tester for fletting av gjeldende § 14 a-vedtak
sneha-d-desai Feb 6, 2025
7366eef
Merge branch 'dev' into filtrer-gjeldende-vedtak14a
slovrid Feb 7, 2025
28fbee9
Handtere tilfelle der siste § 14 a-vedtak er fatta før lansering av v…
slovrid Feb 7, 2025
31cad62
Trekk ut lanseringstidspunkt som konstant og legg til eit ekstra test…
slovrid Feb 7, 2025
775103a
Legg til eit test-scenario med fleire brukarar
slovrid Feb 10, 2025
fe5e1f0
Trekk ut funksjon for å sjekke om § 14 a-vedtak er gjeldande
slovrid Feb 10, 2025
de6f9fd
Legg til funksjon som hentar gjeldande vedtak, slik at vi slepp å gje…
slovrid Feb 12, 2025
4489d41
Endrar litt på pakkestrukturen slik at den representerer ansvarsområd…
slovrid Feb 12, 2025
5ac1f56
Bruk meir idiomatisk måte å mappe "null"-value frå eit Map til defaul…
slovrid Feb 12, 2025
92848b1
Avvik/differanse sjekk mellom § 14 a-vedtak og Arena-oppfølgingsdata …
slovrid Feb 12, 2025
1daa512
Fjern test-scenario som ikkje er mogleg
slovrid Feb 12, 2025
fc6feec
Gjer klassefelt "final"
slovrid Feb 12, 2025
b3f3bb8
Hovedmål må vere nullable sidan det kan vere null i databasen
slovrid Feb 14, 2025
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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(",", "{", "}"));
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
@@ -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;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package no.nav.pto.veilarbportefolje.siste14aVedtak;
package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.avvik14aVedtak;
public enum Avvik14aVedtak {
INNSATSGRUPPE_ULIK,
HOVEDMAAL_ULIK,
Expand Down
Original file line number Diff line number Diff line change
@@ -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;
Expand All @@ -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;
Expand All @@ -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()) {
Expand All @@ -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) {
Expand Down
Original file line number Diff line number Diff line change
@@ -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
)
Original file line number Diff line number Diff line change
@@ -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;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package no.nav.pto.veilarbportefolje.siste14aVedtak;
package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak;

import lombok.AllArgsConstructor;
import lombok.Data;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package no.nav.pto.veilarbportefolje.siste14aVedtak;
package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak;

import lombok.AllArgsConstructor;
import lombok.Builder;
Expand All @@ -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);
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package no.nav.pto.veilarbportefolje.siste14aVedtak;
package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak;

import lombok.AllArgsConstructor;
import lombok.Data;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package no.nav.pto.veilarbportefolje.siste14aVedtak;
package no.nav.pto.veilarbportefolje.oppfolgingsvedtak14a.siste14aVedtak;

import lombok.RequiredArgsConstructor;
import lombok.SneakyThrows;
Expand Down
Original file line number Diff line number Diff line change
@@ -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;
Expand Down
Loading
Loading