From c721ca337999caa5daafc22034040e8cce2290b1 Mon Sep 17 00:00:00 2001 From: sigurdgroneng Date: Thu, 25 Apr 2024 07:57:37 +0200 Subject: [PATCH 1/2] =?UTF-8?q?Legg=20til=20startet-begrunnelse=20p=C3=A5?= =?UTF-8?q?=20pto.oppfolgingsperiode-v1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../domain/Oppfolgingsbruker.java | 6 ++-- .../OppfolgingsPeriodeRepository.java | 4 ++- .../entity/OppfolgingStartBegrunnelse.java | 13 ++++++++- .../entity/OppfolgingsperiodeEntity.java | 1 + .../service/KafkaProducerService.java | 15 ++++------ .../service/KafkaRepubliseringService.java | 6 ++-- .../service/OppfolgingEndringService.java | 2 +- .../service/OppfolgingService.java | 4 +-- .../veilarboppfolging/utils/DtoMappers.java | 11 ++++++++ .../kafka/dto/OppfolgingsperiodeDTO.kt | 28 +++++++++++++++++++ ...am.yml => oppfolgingsbruker.v1.schema.yml} | 0 .../schemas/oppfolgingsperiode.v1.schema.yml | 5 ++++ .../schemas/veilarboppfolging.asyncapi.yml | 4 +-- .../controller/AdminControllerTest.java | 1 - .../service/OppfolgingEndringServiceTest.java | 2 +- .../service/OppfolgingServiceTest.java | 5 ++-- 16 files changed, 81 insertions(+), 26 deletions(-) create mode 100644 src/main/kotlin/no/nav/veilarboppfolging/kafka/dto/OppfolgingsperiodeDTO.kt rename src/main/resources/schemas/{oppfolgingsbruker.v1.scheam.yml => oppfolgingsbruker.v1.schema.yml} (100%) diff --git a/src/main/java/no/nav/veilarboppfolging/domain/Oppfolgingsbruker.java b/src/main/java/no/nav/veilarboppfolging/domain/Oppfolgingsbruker.java index 237d7f246..ab686943c 100644 --- a/src/main/java/no/nav/veilarboppfolging/domain/Oppfolgingsbruker.java +++ b/src/main/java/no/nav/veilarboppfolging/domain/Oppfolgingsbruker.java @@ -3,6 +3,7 @@ import lombok.AllArgsConstructor; import lombok.EqualsAndHashCode; import no.nav.common.types.identer.AktorId; +import no.nav.pto_schema.enums.arena.Formidlingsgruppe; import no.nav.veilarboppfolging.controller.request.Innsatsgruppe; import no.nav.veilarboppfolging.controller.request.SykmeldtBrukerType; import no.nav.veilarboppfolging.repository.entity.OppfolgingStartBegrunnelse; @@ -33,8 +34,9 @@ public static Oppfolgingsbruker arbeidssokerOppfolgingsBruker(AktorId aktorId, I return new Arbeissoker(aktorId, OppfolgingStartBegrunnelse.ARBEIDSSOKER_REGISTRERING, innsatsgruppe); } - public static Oppfolgingsbruker arenaSyncOppfolgingBruker(AktorId aktorId) { - return new Oppfolgingsbruker(aktorId.get(), OppfolgingStartBegrunnelse.ARENA_SYNC); + public static Oppfolgingsbruker arenaSyncOppfolgingBruker(AktorId aktorId, Formidlingsgruppe formidlingsgruppe) { + if (formidlingsgruppe == Formidlingsgruppe.ISERV) throw new IllegalStateException("ISERV skal ikke starte oppfølging"); + return new Oppfolgingsbruker(aktorId.get(), formidlingsgruppe == Formidlingsgruppe.IARBS ? OppfolgingStartBegrunnelse.ARENA_SYNC_IARBS : OppfolgingStartBegrunnelse.ARENA_SYNC_ARBS); } } diff --git a/src/main/java/no/nav/veilarboppfolging/repository/OppfolgingsPeriodeRepository.java b/src/main/java/no/nav/veilarboppfolging/repository/OppfolgingsPeriodeRepository.java index 6b061079e..55c502255 100644 --- a/src/main/java/no/nav/veilarboppfolging/repository/OppfolgingsPeriodeRepository.java +++ b/src/main/java/no/nav/veilarboppfolging/repository/OppfolgingsPeriodeRepository.java @@ -3,6 +3,7 @@ import no.nav.common.types.identer.AktorId; import no.nav.veilarboppfolging.repository.entity.OppfolgingStartBegrunnelse; import no.nav.veilarboppfolging.repository.entity.OppfolgingsperiodeEntity; +import no.nav.veilarboppfolging.utils.EnumUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Repository; @@ -27,7 +28,7 @@ public class OppfolgingsPeriodeRepository { private final TransactionTemplate transactor; private final static String hentOppfolingsperioderSQL = - "SELECT uuid, aktor_id, avslutt_veileder, startdato, sluttdato, avslutt_begrunnelse " + + "SELECT uuid, aktor_id, avslutt_veileder, startdato, sluttdato, avslutt_begrunnelse, start_begrunnelse " + "FROM OPPFOLGINGSPERIODE "; @Autowired @@ -137,6 +138,7 @@ private static OppfolgingsperiodeEntity mapTilOppfolgingsperiode(ResultSet resul .startDato(hentZonedDateTime(result, "startdato")) .sluttDato(hentZonedDateTime(result, "sluttdato")) .begrunnelse(result.getString("avslutt_begrunnelse")) + .startetBegrunnelse(EnumUtils.valueOf(OppfolgingStartBegrunnelse.class, result.getString("start_begrunnelse"))) .build(); } diff --git a/src/main/java/no/nav/veilarboppfolging/repository/entity/OppfolgingStartBegrunnelse.java b/src/main/java/no/nav/veilarboppfolging/repository/entity/OppfolgingStartBegrunnelse.java index d3ea749bd..1fb113510 100644 --- a/src/main/java/no/nav/veilarboppfolging/repository/entity/OppfolgingStartBegrunnelse.java +++ b/src/main/java/no/nav/veilarboppfolging/repository/entity/OppfolgingStartBegrunnelse.java @@ -1,8 +1,19 @@ package no.nav.veilarboppfolging.repository.entity; +import no.nav.veilarboppfolging.kafka.dto.StartetBegrunnelseDTO; + public enum OppfolgingStartBegrunnelse { ARBEIDSSOKER_REGISTRERING, REAKTIVERT, SYKMELDT_MER_OPPFOLGING, - ARENA_SYNC, + ARENA_SYNC_ARBS, + ARENA_SYNC_IARBS; + + public StartetBegrunnelseDTO toStartetBegrunnelseDTO() { + if (this == ARBEIDSSOKER_REGISTRERING || this == ARENA_SYNC_ARBS) { + return StartetBegrunnelseDTO.ARBEIDSSOKER; + } else { // Reativer er sykmeldt fordi arbeidsøkere automatisk er under oppfølging + return StartetBegrunnelseDTO.SYKEMELDT_MER_OPPFOLGING; + } + } } diff --git a/src/main/java/no/nav/veilarboppfolging/repository/entity/OppfolgingsperiodeEntity.java b/src/main/java/no/nav/veilarboppfolging/repository/entity/OppfolgingsperiodeEntity.java index 5d34e1893..104b0935e 100644 --- a/src/main/java/no/nav/veilarboppfolging/repository/entity/OppfolgingsperiodeEntity.java +++ b/src/main/java/no/nav/veilarboppfolging/repository/entity/OppfolgingsperiodeEntity.java @@ -17,4 +17,5 @@ public class OppfolgingsperiodeEntity { ZonedDateTime sluttDato; String begrunnelse; List kvpPerioder; + OppfolgingStartBegrunnelse startetBegrunnelse; } diff --git a/src/main/java/no/nav/veilarboppfolging/service/KafkaProducerService.java b/src/main/java/no/nav/veilarboppfolging/service/KafkaProducerService.java index 17beccf3a..bdf6a02ac 100644 --- a/src/main/java/no/nav/veilarboppfolging/service/KafkaProducerService.java +++ b/src/main/java/no/nav/veilarboppfolging/service/KafkaProducerService.java @@ -2,22 +2,20 @@ import no.nav.common.auth.context.AuthContextHolder; import no.nav.common.kafka.producer.feilhandtering.KafkaProducerRecordStorage; -import no.nav.common.kafka.producer.serializer.JsonValidationSerializer; import no.nav.common.types.identer.AktorId; import no.nav.pto_schema.kafka.json.topic.SisteOppfolgingsperiodeV1; import no.nav.pto_schema.kafka.json.topic.SisteTilordnetVeilederV1; import no.nav.pto_schema.kafka.json.topic.onprem.*; import no.nav.veilarboppfolging.config.KafkaProperties; import no.nav.veilarboppfolging.kafka.KvpPeriode; +import no.nav.veilarboppfolging.kafka.dto.OppfolgingsperiodeDTO; import org.apache.kafka.clients.producer.ProducerRecord; -import org.apache.kafka.common.serialization.Serializer; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.time.ZonedDateTime; import static no.nav.common.kafka.producer.util.ProducerUtils.serializeJsonRecord; -import static no.nav.pto_schema.kafka.json.JsonSchemaLocator.getKafkaSchema; @Service public class KafkaProducerService { @@ -28,9 +26,6 @@ public class KafkaProducerService { private final KafkaProperties kafkaProperties; - private final Serializer sisteOppfolgingsperiodeV1Serializer - = new JsonValidationSerializer<>(getKafkaSchema(SisteOppfolgingsperiodeV1.class)); - @Autowired public KafkaProducerService( AuthContextHolder authContextHolder, @@ -42,9 +37,9 @@ public KafkaProducerService( this.kafkaProperties = kafkaProperties; } - public void publiserOppfolgingsperiode(SisteOppfolgingsperiodeV1 sisteOppfolgingsperiodeV1) { - sisteOppfolgingsPeriode(sisteOppfolgingsperiodeV1); - oppfolingsperiode(sisteOppfolgingsperiodeV1); + public void publiserOppfolgingsperiode(OppfolgingsperiodeDTO oppfolgingsperiode) { + sisteOppfolgingsPeriode(oppfolgingsperiode.toSisteOppfolgingsperiodeDTO()); + oppfolingsperiode(oppfolgingsperiode); } private void sisteOppfolgingsPeriode(SisteOppfolgingsperiodeV1 sisteOppfolgingsperiodeV1) { @@ -53,7 +48,7 @@ private void sisteOppfolgingsPeriode(SisteOppfolgingsperiodeV1 sisteOppfolgingsp sisteOppfolgingsperiodeV1); } - private void oppfolingsperiode(SisteOppfolgingsperiodeV1 sisteOppfolgingsperiodeV1) { + private void oppfolingsperiode(OppfolgingsperiodeDTO sisteOppfolgingsperiodeV1) { store(kafkaProperties.getOppfolgingsperiodeTopic(), sisteOppfolgingsperiodeV1.getAktorId(), sisteOppfolgingsperiodeV1); diff --git a/src/main/java/no/nav/veilarboppfolging/service/KafkaRepubliseringService.java b/src/main/java/no/nav/veilarboppfolging/service/KafkaRepubliseringService.java index f5fb9dd71..aed19411f 100644 --- a/src/main/java/no/nav/veilarboppfolging/service/KafkaRepubliseringService.java +++ b/src/main/java/no/nav/veilarboppfolging/service/KafkaRepubliseringService.java @@ -3,8 +3,8 @@ import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import no.nav.common.types.identer.AktorId; -import no.nav.pto_schema.kafka.json.topic.SisteOppfolgingsperiodeV1; import no.nav.veilarboppfolging.kafka.KvpPeriode; +import no.nav.veilarboppfolging.kafka.dto.OppfolgingsperiodeDTO; import no.nav.veilarboppfolging.repository.KvpRepository; import no.nav.veilarboppfolging.repository.OppfolgingsPeriodeRepository; import no.nav.veilarboppfolging.repository.OppfolgingsStatusRepository; @@ -122,9 +122,9 @@ public void republiserOppfolgingsperiodeForBruker(AktorId aktorId) { return; } - SisteOppfolgingsperiodeV1 sisteOppfolgingsperiodeV1 = DtoMappers.tilSisteOppfolgingsperiodeV1(sistePeriode); + OppfolgingsperiodeDTO periodeDTO = DtoMappers.tilOppfolgingsperiodeDTO(sistePeriode); - kafkaProducerService.publiserOppfolgingsperiode(sisteOppfolgingsperiodeV1); + kafkaProducerService.publiserOppfolgingsperiode(periodeDTO); } private void republiserSisteTilordnetVeilederForBruker(AktorId aktorId) { diff --git a/src/main/java/no/nav/veilarboppfolging/service/OppfolgingEndringService.java b/src/main/java/no/nav/veilarboppfolging/service/OppfolgingEndringService.java index 66165ab2e..96abb3421 100644 --- a/src/main/java/no/nav/veilarboppfolging/service/OppfolgingEndringService.java +++ b/src/main/java/no/nav/veilarboppfolging/service/OppfolgingEndringService.java @@ -63,7 +63,7 @@ public void oppdaterOppfolgingMedStatusFraArena(EndringPaaOppfoelgingsBrukerV2 b if (!erBrukerUnderOppfolging && erUnderOppfolgingIArena) { secureLog.info("Starter oppfølging på bruker som er under oppfølging i Arena, men ikke i veilarboppfolging. aktorId={}", aktorId); - oppfolgingService.startOppfolgingHvisIkkeAlleredeStartet(Oppfolgingsbruker.arenaSyncOppfolgingBruker(aktorId)); + oppfolgingService.startOppfolgingHvisIkkeAlleredeStartet(Oppfolgingsbruker.arenaSyncOppfolgingBruker(aktorId, formidlingsgruppe)); } else if (erBrukerUnderOppfolging && !erUnderOppfolgingIArena && erInaktivIArena) { Optional maybeArenaTilstand = arenaOppfolgingService.hentOppfolgingTilstandDirekteFraArena(fnr); diff --git a/src/main/java/no/nav/veilarboppfolging/service/OppfolgingService.java b/src/main/java/no/nav/veilarboppfolging/service/OppfolgingService.java index 0be8c4dad..ecf373289 100644 --- a/src/main/java/no/nav/veilarboppfolging/service/OppfolgingService.java +++ b/src/main/java/no/nav/veilarboppfolging/service/OppfolgingService.java @@ -293,7 +293,7 @@ public void startOppfolgingHvisIkkeAlleredeStartet(Oppfolgingsbruker oppfolgings OppfolgingsperiodeEntity sistePeriode = OppfolgingsperiodeUtils.hentSisteOppfolgingsperiode(perioder); log.info("Oppfølgingsperiode startet for bruker - publiserer endringer på oppfølgingsperiode-topics."); - kafkaProducerService.publiserOppfolgingsperiode(DtoMappers.tilSisteOppfolgingsperiodeV1(sistePeriode)); + kafkaProducerService.publiserOppfolgingsperiode(DtoMappers.tilOppfolgingsperiodeDTO(sistePeriode)); if (kontaktinfo.isReservert()) { manuellStatusService.settBrukerTilManuellGrunnetReservertIKRR(aktorId); @@ -321,7 +321,7 @@ public void avsluttOppfolgingForBruker(AktorId aktorId, String veilederId, Strin OppfolgingsperiodeEntity sistePeriode = OppfolgingsperiodeUtils.hentSisteOppfolgingsperiode(perioder); log.info("Oppfølgingsperiode avsluttet for bruker - publiserer endringer på oppfølgingsperiode-topics."); - kafkaProducerService.publiserOppfolgingsperiode(DtoMappers.tilSisteOppfolgingsperiodeV1(sistePeriode)); + kafkaProducerService.publiserOppfolgingsperiode(DtoMappers.tilOppfolgingsperiodeDTO(sistePeriode)); // Publiserer også endringer som resettes i oppfolgingsstatus-tabellen ved avslutting av oppfølging kafkaProducerService.publiserVeilederTilordnet(aktorId, null); diff --git a/src/main/java/no/nav/veilarboppfolging/utils/DtoMappers.java b/src/main/java/no/nav/veilarboppfolging/utils/DtoMappers.java index 714704077..f285d60c2 100644 --- a/src/main/java/no/nav/veilarboppfolging/utils/DtoMappers.java +++ b/src/main/java/no/nav/veilarboppfolging/utils/DtoMappers.java @@ -5,6 +5,7 @@ import no.nav.veilarboppfolging.controller.response.*; import no.nav.veilarboppfolging.domain.AvslutningStatusData; import no.nav.veilarboppfolging.domain.OppfolgingStatusData; +import no.nav.veilarboppfolging.kafka.dto.OppfolgingsperiodeDTO; import no.nav.veilarboppfolging.repository.entity.KvpPeriodeEntity; import no.nav.veilarboppfolging.repository.entity.MaalEntity; import no.nav.veilarboppfolging.repository.entity.OppfolgingsperiodeEntity; @@ -121,6 +122,16 @@ public static SisteOppfolgingsperiodeV1 tilSisteOppfolgingsperiodeV1(Oppfolgings ); } + public static OppfolgingsperiodeDTO tilOppfolgingsperiodeDTO(OppfolgingsperiodeEntity oppfolgingsperiode) { + return new OppfolgingsperiodeDTO( + oppfolgingsperiode.getUuid().toString(), + oppfolgingsperiode.getStartDato(), + oppfolgingsperiode.getSluttDato(), + oppfolgingsperiode.getAktorId(), + oppfolgingsperiode.getStartetBegrunnelse().toStartetBegrunnelseDTO() + ); + } + public static OppfolgingPeriodeMinimalDTO tilOppfolgingPeriodeMinimalDTO(OppfolgingsperiodeEntity oppfolgingsperiode) { return new OppfolgingPeriodeMinimalDTO() .setUuid(oppfolgingsperiode.getUuid()) diff --git a/src/main/kotlin/no/nav/veilarboppfolging/kafka/dto/OppfolgingsperiodeDTO.kt b/src/main/kotlin/no/nav/veilarboppfolging/kafka/dto/OppfolgingsperiodeDTO.kt new file mode 100644 index 000000000..82277ee5f --- /dev/null +++ b/src/main/kotlin/no/nav/veilarboppfolging/kafka/dto/OppfolgingsperiodeDTO.kt @@ -0,0 +1,28 @@ +package no.nav.veilarboppfolging.kafka.dto + +import no.nav.pto_schema.kafka.json.topic.SisteOppfolgingsperiodeV1 +import java.time.ZonedDateTime +import java.util.* + +data class OppfolgingsperiodeDTO( + val uuid: String, + val startDato: ZonedDateTime, + val sluttDato: ZonedDateTime?, + val aktorId: String, + val startetBegrunnelse: StartetBegrunnelseDTO +) { + fun toSisteOppfolgingsperiodeDTO(): SisteOppfolgingsperiodeV1 { + return SisteOppfolgingsperiodeV1( + UUID.fromString(uuid), + aktorId, + startDato, + sluttDato, + ) + } +} + +enum class StartetBegrunnelseDTO { + ARBEIDSSOKER, + SYKEMELDT_MER_OPPFOLGING +} + diff --git a/src/main/resources/schemas/oppfolgingsbruker.v1.scheam.yml b/src/main/resources/schemas/oppfolgingsbruker.v1.schema.yml similarity index 100% rename from src/main/resources/schemas/oppfolgingsbruker.v1.scheam.yml rename to src/main/resources/schemas/oppfolgingsbruker.v1.schema.yml diff --git a/src/main/resources/schemas/oppfolgingsperiode.v1.schema.yml b/src/main/resources/schemas/oppfolgingsperiode.v1.schema.yml index f2872533c..353f48d2d 100644 --- a/src/main/resources/schemas/oppfolgingsperiode.v1.schema.yml +++ b/src/main/resources/schemas/oppfolgingsperiode.v1.schema.yml @@ -19,3 +19,8 @@ properties: format: date-time aktorId: type: string + startet_begrunnelse: + type: string + enum: + - ARBEIDSSOKER + - SYKEMELDT_MER_OPPFOLGING diff --git a/src/main/resources/schemas/veilarboppfolging.asyncapi.yml b/src/main/resources/schemas/veilarboppfolging.asyncapi.yml index 570038089..c3ea5b34d 100644 --- a/src/main/resources/schemas/veilarboppfolging.asyncapi.yml +++ b/src/main/resources/schemas/veilarboppfolging.asyncapi.yml @@ -50,7 +50,7 @@ operations: $ref: "#/channels/kvp-perioder-v1" messages: - $ref: "#/channels/kvp-perioder-v1/messages/kvpperiode" - oppfolgingsperiodeCompacted: + siste-oppfolgingsperiode-v1: description: Oppfølgingsperiode compacted på aktørId (bare siste periode) action: send channel: @@ -84,4 +84,4 @@ components: title: Oppfølgingsbruker fra veilarbarena summary: Oppfølgings-status på en bruker fra Arena payload: - $ref: oppfolgingsbruker.v1.scheam.yml + $ref: oppfolgingsbruker.v1.schema.yml diff --git a/src/test/java/no/nav/veilarboppfolging/controller/AdminControllerTest.java b/src/test/java/no/nav/veilarboppfolging/controller/AdminControllerTest.java index b0c946d4c..2a0072957 100644 --- a/src/test/java/no/nav/veilarboppfolging/controller/AdminControllerTest.java +++ b/src/test/java/no/nav/veilarboppfolging/controller/AdminControllerTest.java @@ -9,7 +9,6 @@ import no.nav.veilarboppfolging.service.AuthService; import no.nav.veilarboppfolging.service.KafkaRepubliseringService; import no.nav.veilarboppfolging.service.ManuellStatusService; -import no.nav.veilarboppfolging.utils.auth.AuthorizationInterceptor; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.autoconfigure.web.servlet.WebMvcTest; diff --git a/src/test/java/no/nav/veilarboppfolging/service/OppfolgingEndringServiceTest.java b/src/test/java/no/nav/veilarboppfolging/service/OppfolgingEndringServiceTest.java index 4830edcb3..5d37ec0c9 100644 --- a/src/test/java/no/nav/veilarboppfolging/service/OppfolgingEndringServiceTest.java +++ b/src/test/java/no/nav/veilarboppfolging/service/OppfolgingEndringServiceTest.java @@ -65,7 +65,7 @@ public void oppdaterOppfolgingMedStatusFraArena__skal_starte_oppfolging_pa_bruke oppfolgingEndringService.oppdaterOppfolgingMedStatusFraArena(brukverV2); - verify(oppfolgingService, times(1)).startOppfolgingHvisIkkeAlleredeStartet(Oppfolgingsbruker.arenaSyncOppfolgingBruker(TEST_AKTOR_ID)); + verify(oppfolgingService, times(1)).startOppfolgingHvisIkkeAlleredeStartet(Oppfolgingsbruker.arenaSyncOppfolgingBruker(TEST_AKTOR_ID, Formidlingsgruppe.ARBS)); verify(oppfolgingService, never()).avsluttOppfolgingForBruker(any(), any(), any()); } diff --git a/src/test/java/no/nav/veilarboppfolging/service/OppfolgingServiceTest.java b/src/test/java/no/nav/veilarboppfolging/service/OppfolgingServiceTest.java index db85df525..b04f3c7af 100644 --- a/src/test/java/no/nav/veilarboppfolging/service/OppfolgingServiceTest.java +++ b/src/test/java/no/nav/veilarboppfolging/service/OppfolgingServiceTest.java @@ -20,6 +20,7 @@ import no.nav.veilarboppfolging.domain.AvslutningStatusData; import no.nav.veilarboppfolging.domain.OppfolgingStatusData; import no.nav.veilarboppfolging.domain.Oppfolgingsbruker; +import no.nav.veilarboppfolging.kafka.dto.OppfolgingsperiodeDTO; import no.nav.veilarboppfolging.repository.KvpRepository; import no.nav.veilarboppfolging.repository.OppfolgingsPeriodeRepository; import no.nav.veilarboppfolging.repository.OppfolgingsStatusRepository; @@ -115,7 +116,7 @@ public void skal_publisere_paa_kafka_ved_start_paa_oppfolging() { List oppfolgingsperioder = oppfolgingsPeriodeRepository.hentOppfolgingsperioder(AKTOR_ID); assertEquals(1, oppfolgingsperioder.size()); - verify(kafkaProducerService, times(1)).publiserOppfolgingsperiode(any(SisteOppfolgingsperiodeV1.class)); + verify(kafkaProducerService, times(1)).publiserOppfolgingsperiode(any(OppfolgingsperiodeDTO.class)); } @Test @@ -131,7 +132,7 @@ public void skal_publisere_paa_kafka_ved_avsluttet_oppfolging() { reset(kafkaProducerService); oppfolgingService.avsluttOppfolging(FNR, VEILEDER, ""); - verify(kafkaProducerService).publiserOppfolgingsperiode(any(SisteOppfolgingsperiodeV1.class)); + verify(kafkaProducerService).publiserOppfolgingsperiode(any(OppfolgingsperiodeDTO.class)); verify(kafkaProducerService).publiserVeilederTilordnet(AKTOR_ID, null); verify(kafkaProducerService).publiserEndringPaNyForVeileder(AKTOR_ID, false); verify(kafkaProducerService).publiserEndringPaManuellStatus(AKTOR_ID, false); From d376c3bd6d00904add081f02c22c6dd15a0aa948 Mon Sep 17 00:00:00 2001 From: sigurdgroneng Date: Thu, 25 Apr 2024 08:24:59 +0200 Subject: [PATCH 2/2] Legg til ARENA_SYNC for bakoverkompabilitet --- .../repository/entity/OppfolgingStartBegrunnelse.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/no/nav/veilarboppfolging/repository/entity/OppfolgingStartBegrunnelse.java b/src/main/java/no/nav/veilarboppfolging/repository/entity/OppfolgingStartBegrunnelse.java index 1fb113510..cb99f672e 100644 --- a/src/main/java/no/nav/veilarboppfolging/repository/entity/OppfolgingStartBegrunnelse.java +++ b/src/main/java/no/nav/veilarboppfolging/repository/entity/OppfolgingStartBegrunnelse.java @@ -6,6 +6,7 @@ public enum OppfolgingStartBegrunnelse { ARBEIDSSOKER_REGISTRERING, REAKTIVERT, SYKMELDT_MER_OPPFOLGING, + ARENA_SYNC, // TODO: Fjerne etter opprydding i databasen ARENA_SYNC_ARBS, ARENA_SYNC_IARBS;