Skip to content

Commit

Permalink
Merge pull request #1763 from navikt/dev
Browse files Browse the repository at this point in the history 
Synce master med dev
  • Loading branch information
@slovrid
slovrid authored Oct 30, 2024
2 parents 2e5813d + 6eefe8c commit dedbc11
Show file tree
Hide file tree
Showing 6 changed files with 33 additions and 33 deletions.
9 changes: 5 additions & 4 deletions src/main/java/no/nav/pto/veilarbportefolje/siste14aVedtak/Siste14aVedtak.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
import lombok.Builder;
import lombok.Data;
import lombok.experimental.Accessors;
import no.nav.common.types.identer.AktorId;
import no.nav.pto.veilarbportefolje.vedtakstotte.Hovedmal;
import no.nav.pto.veilarbportefolje.vedtakstotte.Innsatsgruppe;

Expand All @@ -14,17 +15,17 @@
@Accessors(chain = true)
@AllArgsConstructor
public class Siste14aVedtak {
String brukerId;
AktorId aktorId;
Innsatsgruppe innsatsgruppe;
Hovedmal hovedmal;
ZonedDateTime fattetDato;
boolean fraArena;

public static Siste14aVedtak fraKafkaDto(Siste14aVedtakKafkaDto dto) {
return new Siste14aVedtak(dto.aktorId.get(), dto.innsatsgruppe, dto.hovedmal, dto.fattetDato, dto.fraArena);
return new Siste14aVedtak(dto.aktorId, dto.innsatsgruppe, dto.hovedmal, dto.fattetDato, dto.fraArena);
}

public static Siste14aVedtak fraApiDto(Siste14aVedtakApiDto dto, String brukerId) {
return new Siste14aVedtak(brukerId, dto.innsatsgruppe, dto.hovedmal, dto.fattetDato, dto.fraArena);
public static Siste14aVedtak fraApiDto(Siste14aVedtakApiDto dto, AktorId aktorId) {
return new Siste14aVedtak(aktorId, dto.innsatsgruppe, dto.hovedmal, dto.fattetDato, dto.fraArena);
}
}
5 changes: 2 additions & 3 deletions src/main/java/no/nav/pto/veilarbportefolje/siste14aVedtak/Siste14aVedtakRepository.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import no.nav.common.types.identer.AktorId;
import no.nav.common.types.identer.EksternBrukerId;
import no.nav.pto.veilarbportefolje.persononinfo.domene.IdenterForBruker;
import no.nav.pto.veilarbportefolje.vedtakstotte.Hovedmal;
import no.nav.pto.veilarbportefolje.vedtakstotte.Innsatsgruppe;
Expand Down Expand Up @@ -38,7 +37,7 @@ insert into siste_14a_vedtak(bruker_id, hovedmal, innsatsgruppe, fattet_dato, fr

db.update(
sql,
siste14aVedtak.brukerId,
siste14aVedtak.aktorId.get(),
siste14aVedtak.hovedmal != null ? siste14aVedtak.hovedmal.name() : null,
siste14aVedtak.innsatsgruppe.name(),
Timestamp.from(siste14aVedtak.fattetDato.toInstant()),
Expand Down Expand Up @@ -73,7 +72,7 @@ private static String identerParam(IdenterForBruker identer) {
@SneakyThrows
private Siste14aVedtak siste14aVedtakMapper(ResultSet rs) {
return new Siste14aVedtak(
rs.getString("bruker_id"),
Optional.ofNullable(rs.getString("bruker_id")).map(AktorId::of).orElse(null),
Innsatsgruppe.valueOf(rs.getString("innsatsgruppe")),
Optional.ofNullable(rs.getString("hovedmal")).map(Hovedmal::valueOf).orElse(null),
toZonedDateTime(rs.getTimestamp("fattet_dato")),
Expand Down
6 changes: 3 additions & 3 deletions src/main/java/no/nav/pto/veilarbportefolje/siste14aVedtak/Siste14aVedtakService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -23,8 +23,8 @@ protected void behandleKafkaMeldingLogikk(Siste14aVedtakKafkaDto kafkaMelding) {
}

public void lagreSiste14aVedtak(Siste14aVedtak siste14aVedtak) {
if (pdlIdentRepository.erBrukerUnderOppfolging(siste14aVedtak.brukerId)) {
IdenterForBruker identer = pdlIdentRepository.hentIdenterForBruker(siste14aVedtak.brukerId);
if (pdlIdentRepository.erBrukerUnderOppfolging(siste14aVedtak.aktorId.get())) {
IdenterForBruker identer = pdlIdentRepository.hentIdenterForBruker(siste14aVedtak.aktorId.get());
siste14aVedtakRepository.upsert(siste14aVedtak, identer);
}
}
Expand All @@ -38,7 +38,7 @@ public void hentOgLagreSiste14aVedtak(AktorId aktorId) {
Fnr fnr = pdlIdentRepository.hentFnrForAktivBruker(aktorId);

vedtaksstotteClient.hentSiste14aVedtak(fnr)
.map(siste14aVedtak -> Siste14aVedtak.fraApiDto(siste14aVedtak, aktorId.get()))
.map(siste14aVedtak -> Siste14aVedtak.fraApiDto(siste14aVedtak, aktorId))
.ifPresent(this::lagreSiste14aVedtak);
}
}
4 changes: 2 additions & 2 deletions ...java/no/nav/pto/veilarbportefolje/oppfolging/OppfolgingStartetOgAvsluttetServiceTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -174,7 +174,7 @@ public void cleanup() {
IdenterForBruker identerForBruker = pdlIdentRepository.hentIdenterForBruker(aktorId.get());
Optional<Siste14aVedtak> siste14aVedtak = siste14aVedtakRepository.hentSiste14aVedtak(identerForBruker);
assertThat(siste14aVedtak).isNotEmpty();
assertThat(siste14aVedtak).isEqualTo(Optional.of(Siste14aVedtak.fraApiDto(siste14aVedtakApiDto, aktorId.get())));
assertThat(siste14aVedtak).isEqualTo(Optional.of(Siste14aVedtak.fraApiDto(siste14aVedtakApiDto, aktorId)));
}

@Test
Expand Down Expand Up @@ -299,7 +299,7 @@ public void cleanup() {
testDataClient.lagreBrukerUnderOppfolging(aktorId, tilfeldigDatoTilbakeITid());

siste14aVedtakService.lagreSiste14aVedtak(
new Siste14aVedtak(aktorId.get(), STANDARD_INNSATS, BEHOLDE_ARBEID, tilfeldigDatoTilbakeITid(), false)
new Siste14aVedtak(aktorId, STANDARD_INNSATS, BEHOLDE_ARBEID, tilfeldigDatoTilbakeITid(), false)
);

assertFalse(siste14aVedtakRepository.hentSiste14aVedtak(new IdenterForBruker(List.of(aktorId.get()))).isEmpty());
Expand Down
32 changes: 16 additions & 16 deletions src/test/java/no/nav/pto/veilarbportefolje/siste14aVedtak/Avvik14aVedtakServiceTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -41,13 +41,13 @@ public void skalIkkeFinneAvvikForBrukereMedTilsvarendeDataIArenaOgVedtaksstotte(
.hovedmaalkode(ArenaHovedmal.BEHOLDEA.name())
.build();
Siste14aVedtak siste14aVedtak = Siste14aVedtak.builder()
.brukerId(ident1.getAktorId().get())
.aktorId(ident1.getAktorId())
.innsatsgruppe(Innsatsgruppe.STANDARD_INNSATS)
.hovedmal(Hovedmal.BEHOLDE_ARBEID)
.build();

when(oppfolgingsbrukerRepositoryV3.hentOppfolgingsBrukere(anySet())).thenReturn(Map.of(Fnr.of(oppfolgingsbruker.fodselsnr()), oppfolgingsbruker));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(AktorId.of(siste14aVedtak.brukerId), siste14aVedtak));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(siste14aVedtak.aktorId, siste14aVedtak));

Map<GjeldendeIdenter, Avvik14aVedtak> avvik = avvik14aVedtakService.hentAvvik(identer);
assertThat(avvik.keySet()).containsAll(identer);
Expand All @@ -64,13 +64,13 @@ public void skalIkkeFinneAvvikNaarArenaInnsatsgruppeErNull() {
.hovedmaalkode(ArenaHovedmal.BEHOLDEA.name())
.build();
Siste14aVedtak siste14aVedtak = Siste14aVedtak.builder()
.brukerId(ident1.getAktorId().get())
.aktorId(ident1.getAktorId())
.innsatsgruppe(Innsatsgruppe.STANDARD_INNSATS)
.hovedmal(Hovedmal.BEHOLDE_ARBEID)
.build();

when(oppfolgingsbrukerRepositoryV3.hentOppfolgingsBrukere(anySet())).thenReturn(Map.of(Fnr.of(oppfolgingsbruker.fodselsnr()), oppfolgingsbruker));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(AktorId.of(siste14aVedtak.brukerId), siste14aVedtak));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(siste14aVedtak.aktorId, siste14aVedtak));

Map<GjeldendeIdenter, Avvik14aVedtak> avvik = avvik14aVedtakService.hentAvvik(identer);
assertThat(avvik.keySet()).containsAll(identer);
Expand All @@ -87,13 +87,13 @@ public void skalIkkeFinneAvvikNaarArenaKvalifiseringsgruppeErServiceGruppe() {
.hovedmaalkode(ArenaHovedmal.BEHOLDEA.name())
.build();
Siste14aVedtak siste14aVedtak = Siste14aVedtak.builder()
.brukerId(ident1.getAktorId().get())
.aktorId(ident1.getAktorId())
.innsatsgruppe(Innsatsgruppe.STANDARD_INNSATS)
.hovedmal(Hovedmal.BEHOLDE_ARBEID)
.build();

when(oppfolgingsbrukerRepositoryV3.hentOppfolgingsBrukere(anySet())).thenReturn(Map.of(Fnr.of(oppfolgingsbruker.fodselsnr()), oppfolgingsbruker));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(AktorId.of(siste14aVedtak.brukerId), siste14aVedtak));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(siste14aVedtak.aktorId, siste14aVedtak));

Map<GjeldendeIdenter, Avvik14aVedtak> avvik = avvik14aVedtakService.hentAvvik(identer);
assertThat(avvik.keySet()).containsAll(identer);
Expand All @@ -110,13 +110,13 @@ public void skalIkkeFinneAvvikNaarInnsatsgruppeErLikOgArenaHovedmaalErNull() {
.hovedmaalkode(null)
.build();
Siste14aVedtak siste14aVedtak = Siste14aVedtak.builder()
.brukerId(ident1.getAktorId().get())
.aktorId(ident1.getAktorId())
.innsatsgruppe(Innsatsgruppe.STANDARD_INNSATS)
.hovedmal(Hovedmal.BEHOLDE_ARBEID)
.build();

when(oppfolgingsbrukerRepositoryV3.hentOppfolgingsBrukere(anySet())).thenReturn(Map.of(Fnr.of(oppfolgingsbruker.fodselsnr()), oppfolgingsbruker));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(AktorId.of(siste14aVedtak.brukerId), siste14aVedtak));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(siste14aVedtak.aktorId, siste14aVedtak));

Map<GjeldendeIdenter, Avvik14aVedtak> avvik = avvik14aVedtakService.hentAvvik(identer);
assertThat(avvik.keySet()).containsAll(identer);
Expand All @@ -133,13 +133,13 @@ public void skalFinneAvvikDersomInnsatsgruppeErUlik() {
.hovedmaalkode(ArenaHovedmal.BEHOLDEA.name())
.build();
Siste14aVedtak siste14aVedtak = Siste14aVedtak.builder()
.brukerId(ident1.getAktorId().get())
.aktorId(ident1.getAktorId())
.innsatsgruppe(Innsatsgruppe.SITUASJONSBESTEMT_INNSATS)
.hovedmal(Hovedmal.BEHOLDE_ARBEID)
.build();

when(oppfolgingsbrukerRepositoryV3.hentOppfolgingsBrukere(anySet())).thenReturn(Map.of(Fnr.of(oppfolgingsbruker.fodselsnr()), oppfolgingsbruker));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(AktorId.of(siste14aVedtak.brukerId), siste14aVedtak));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(siste14aVedtak.aktorId, siste14aVedtak));

Map<GjeldendeIdenter, Avvik14aVedtak> avvik = avvik14aVedtakService.hentAvvik(identer);
assertThat(avvik.values()).containsOnly(Avvik14aVedtak.INNSATSGRUPPE_ULIK);
Expand All @@ -155,13 +155,13 @@ public void skalFinneAvvikDersomHovedmaalErUlik() {
.hovedmaalkode(ArenaHovedmal.OKEDELT.name())
.build();
Siste14aVedtak siste14aVedtak = Siste14aVedtak.builder()
.brukerId(ident1.getAktorId().get())
.aktorId(ident1.getAktorId())
.innsatsgruppe(Innsatsgruppe.STANDARD_INNSATS)
.hovedmal(Hovedmal.BEHOLDE_ARBEID)
.build();

when(oppfolgingsbrukerRepositoryV3.hentOppfolgingsBrukere(anySet())).thenReturn(Map.of(Fnr.of(oppfolgingsbruker.fodselsnr()), oppfolgingsbruker));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(AktorId.of(siste14aVedtak.brukerId), siste14aVedtak));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(siste14aVedtak.aktorId, siste14aVedtak));

Map<GjeldendeIdenter, Avvik14aVedtak> avvik = avvik14aVedtakService.hentAvvik(identer);
assertThat(avvik.values()).containsOnly(Avvik14aVedtak.HOVEDMAAL_ULIK);
Expand All @@ -177,13 +177,13 @@ public void skalFinneAvvikDersomInnsatsgruppeOgHovedmaalErUlik() {
.hovedmaalkode(ArenaHovedmal.OKEDELT.name())
.build();
Siste14aVedtak siste14aVedtak = Siste14aVedtak.builder()
.brukerId(ident1.getAktorId().get())
.aktorId(ident1.getAktorId())
.innsatsgruppe(Innsatsgruppe.SITUASJONSBESTEMT_INNSATS)
.hovedmal(Hovedmal.BEHOLDE_ARBEID)
.build();

when(oppfolgingsbrukerRepositoryV3.hentOppfolgingsBrukere(anySet())).thenReturn(Map.of(Fnr.of(oppfolgingsbruker.fodselsnr()), oppfolgingsbruker));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(AktorId.of(siste14aVedtak.brukerId), siste14aVedtak));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(siste14aVedtak.aktorId, siste14aVedtak));

Map<GjeldendeIdenter, Avvik14aVedtak> avvik = avvik14aVedtakService.hentAvvik(identer);
assertThat(avvik.values()).containsOnly(Avvik14aVedtak.INNSATSGRUPPE_OG_HOVEDMAAL_ULIK);
Expand All @@ -199,12 +199,12 @@ public void skalFinneAvvikDersomInnsatsgruppeManglerISiste14aVedtak() {
.hovedmaalkode(ArenaHovedmal.BEHOLDEA.name())
.build();
Siste14aVedtak siste14aVedtak = Siste14aVedtak.builder()
.brukerId(ident1.getAktorId().get())
.aktorId(ident1.getAktorId())
.hovedmal(Hovedmal.BEHOLDE_ARBEID)
.build();

when(oppfolgingsbrukerRepositoryV3.hentOppfolgingsBrukere(anySet())).thenReturn(Map.of(Fnr.of(oppfolgingsbruker.fodselsnr()), oppfolgingsbruker));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(AktorId.of(siste14aVedtak.brukerId), siste14aVedtak));
when(siste14aVedtakRepository.hentSiste14aVedtakForBrukere(anySet())).thenReturn(Map.of(siste14aVedtak.aktorId, siste14aVedtak));

Map<GjeldendeIdenter, Avvik14aVedtak> avvik = avvik14aVedtakService.hentAvvik(identer);
assertThat(avvik.values()).containsOnly(Avvik14aVedtak.INNSATSGRUPPE_MANGLER_I_NY_KILDE);
Expand Down
10 changes: 5 additions & 5 deletions src/test/java/no/nav/pto/veilarbportefolje/siste14aVedtak/Siste14aVedtakRepositoryTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ public void upsert_hent_og_slett_siste_14a_vedtak() {
IdenterForBruker identerForAnnenBruker = new IdenterForBruker(List.of(aktorIdForAnnenBruker.get(), randomAktorId().get()));

Siste14aVedtak siste14aVedtakForAnnenBruker = new Siste14aVedtak(
aktorIdForAnnenBruker.get(),
aktorIdForAnnenBruker,
Innsatsgruppe.SPESIELT_TILPASSET_INNSATS,
Hovedmal.OKE_DELTAKELSE,
ZonedDateTime.parse("2022-01-01T11:33:22.133000+02:00"),
Expand All @@ -60,7 +60,7 @@ public void upsert_hent_og_slett_siste_14a_vedtak() {
assertLagretVedtak(siste14aVedtakForAnnenBruker, identerForAnnenBruker);

Siste14aVedtak siste14aVedtak = new Siste14aVedtak(
aktorId1.get(),
aktorId1,
STANDARD_INNSATS,
SKAFFE_ARBEID,
ZonedDateTime.parse("2021-05-04T09:48:58.762000+02:00"),
Expand All @@ -72,7 +72,7 @@ public void upsert_hent_og_slett_siste_14a_vedtak() {
assertLagretVedtak(siste14aVedtak, identerForBruker);

Siste14aVedtak oppdatert14aVedtak = new Siste14aVedtak(
aktorId2.get(),
aktorId2,
SITUASJONSBESTEMT_INNSATS,
BEHOLDE_ARBEID,
ZonedDateTime.parse("2022-01-04T10:01:32.689000+02:00"),
Expand Down Expand Up @@ -118,7 +118,7 @@ private void assertLagretVedtak(Siste14aVedtak expected, IdenterForBruker idente
Siste14aVedtak resultat = kanskjeResultat.get();

assertEquals(expected.getFattetDato().toInstant(), resultat.getFattetDato().toInstant());
assertEquals(expected.getBrukerId(), resultat.getBrukerId());
assertEquals(expected.getAktorId(), resultat.getAktorId());
assertEquals(expected.getHovedmal(), resultat.getHovedmal());
assertEquals(expected.getInnsatsgruppe(), resultat.getInnsatsgruppe());
assertEquals(expected.isFraArena(), resultat.isFraArena());
Expand Down Expand Up @@ -148,7 +148,7 @@ private List<PDLIdent> lagreIdenterForTilfeldigBruker() {
private Siste14aVedtak upsertSiste14aForBrukersIdenterOgReturnerSiste(List<PDLIdent> identer) {
List<Siste14aVedtak> vedtakListe = identer.stream().map(ident ->
new Siste14aVedtak(
ident.getIdent(),
AktorId.of(ident.getIdent()),
randomInnsatsgruppe(),
randomHovedmal(),
randomZonedDate(),
Expand Down

0 comments on commit dedbc11

Please sign in to comment.