Legg til oppdatering av oppfolgingsbruker i VeilarbarenaClient

navikt · Feb 14, 2025 · 75f4c42 · 75f4c42
1 parent 0518103
commit 75f4c42
Show file tree

Hide file tree

Showing 5 changed files with 30 additions and 8 deletions.
diff --git a/src/main/java/no/nav/veilarbvedtaksstotte/client/arena/VeilarbarenaClient.java b/src/main/java/no/nav/veilarbvedtaksstotte/client/arena/VeilarbarenaClient.java
@@ -10,7 +10,7 @@ public interface VeilarbarenaClient extends HealthCheck {
 
     Optional<VeilarbArenaOppfolging> hentOppfolgingsbruker(Fnr fnr);
 
-    Optional<VeilarbArenaOppfolging> hentOppfolgingsbrukerUtenCache(Fnr fnr);
+    Optional<VeilarbArenaOppfolging> oppdaterOppfolgingsbruker(Fnr fnr, String enhetNr);
 
     Optional<String> oppfolgingssak(Fnr fnr);
 }
diff --git a/src/main/java/no/nav/veilarbvedtaksstotte/client/arena/VeilarbarenaClientImpl.java b/src/main/java/no/nav/veilarbvedtaksstotte/client/arena/VeilarbarenaClientImpl.java
@@ -12,6 +12,8 @@
 import okhttp3.OkHttpClient;
 import okhttp3.Request;
 import okhttp3.Response;
+import org.springframework.cache.Cache;
+import org.springframework.cache.annotation.CachePut;
 import org.springframework.cache.annotation.Cacheable;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.HttpStatus;
@@ -45,10 +47,19 @@ public Optional<VeilarbArenaOppfolging> hentOppfolgingsbruker(Fnr fnr) {
         return hentOppfolgingsbrukerIntern(fnr);
     }
 
-    public Optional<VeilarbArenaOppfolging> hentOppfolgingsbrukerUtenCache(Fnr fnr) {
-        return hentOppfolgingsbrukerIntern(fnr);
+    @CachePut(value = CacheConfig.ARENA_BRUKER_CACHE_NAME, key = "#fnr")
+    public Optional<VeilarbArenaOppfolging> oppdaterOppfolgingsbruker(Fnr fnr, String navKontor) {
+        var oppfolgingsbruker = hentOppfolgingsbrukerIntern(fnr);
+
+        if (oppfolgingsbruker.isEmpty()) {
+            return Optional.empty();
+        }
+
+        var oppdatertOppfolgingsBruker = new VeilarbArenaOppfolging(navKontor, oppfolgingsbruker.get().getFormidlingsgruppekode(), oppfolgingsbruker.get().getKvalifiseringsgruppekode());
+        return Optional.of(oppdatertOppfolgingsBruker);
     }
 
+
     private Optional<VeilarbArenaOppfolging> hentOppfolgingsbrukerIntern(Fnr fnr) {
         Request request = new Request.Builder()
                 .url(joinPaths(veilarbarenaUrl, "/api/v3/hent-oppfolgingsbruker"))

diff --git a/src/main/java/no/nav/veilarbvedtaksstotte/service/KafkaConsumerService.java b/src/main/java/no/nav/veilarbvedtaksstotte/service/KafkaConsumerService.java
@@ -7,6 +7,7 @@
 import no.nav.common.client.utils.graphql.GraphqlErrorException;
 import no.nav.common.types.identer.AktorId;
 import no.nav.common.types.identer.Fnr;
+import no.nav.veilarbvedtaksstotte.client.arena.VeilarbarenaClient;
 import no.nav.veilarbvedtaksstotte.client.norg2.Norg2Client;
 import no.nav.veilarbvedtaksstotte.domain.kafka.ArenaVedtakRecord;
 import no.nav.veilarbvedtaksstotte.domain.kafka.KafkaOppfolgingsbrukerEndringV2;
@@ -40,19 +41,22 @@ public class KafkaConsumerService {
 
     private final AktorOppslagClient aktorOppslagClient;
 
+    private final VeilarbarenaClient veilarbarenaClient;
+
     @Autowired
     public KafkaConsumerService(
             Siste14aVedtakService siste14aVedtakService,
             VedtaksstotteRepository vedtaksstotteRepository,
             BeslutteroversiktRepository beslutteroversiktRepository,
             Norg2Client norg2Client,
-            AktorOppslagClient aktorOppslagClient
-    ) {
+            AktorOppslagClient aktorOppslagClient,
+            VeilarbarenaClient veilarbarenaClient) {
         this.siste14aVedtakService = siste14aVedtakService;
         this.vedtaksstotteRepository = vedtaksstotteRepository;
         this.beslutteroversiktRepository = beslutteroversiktRepository;
         this.norg2Client = norg2Client;
         this.aktorOppslagClient = aktorOppslagClient;
+        this.veilarbarenaClient = veilarbarenaClient;
     }
 
     public void flyttingAvOppfolgingsbrukerTilNyEnhet(ConsumerRecord<String, KafkaOppfolgingsbrukerEndringV2> kafkaOppfolgingsbrukerEndring) {
@@ -85,6 +89,8 @@ public void flyttingAvOppfolgingsbrukerTilNyEnhet(ConsumerRecord<String, KafkaOp
         Enhet enhet = norg2Client.hentEnhet(oppfolgingsenhetId);
         vedtaksstotteRepository.oppdaterUtkastEnhet(utkast.getId(), oppfolgingsenhetId);
         beslutteroversiktRepository.oppdaterBrukerEnhet(utkast.getId(), oppfolgingsenhetId, enhet.getNavn());
+
+        veilarbarenaClient.oppdaterOppfolgingsbruker(fnr, enhet.getEnhetNr());
     }
 
     public void behandleArenaVedtak(ConsumerRecord<String, ArenaVedtakRecord> arenaVedtakRecord) {

diff --git a/src/test/java/no/nav/veilarbvedtaksstotte/config/ClientTestConfig.java b/src/test/java/no/nav/veilarbvedtaksstotte/config/ClientTestConfig.java
@@ -151,11 +151,10 @@ public Optional<VeilarbArenaOppfolging> hentOppfolgingsbruker(Fnr fnr) {
             }
 
             @Override
-            public Optional<VeilarbArenaOppfolging> hentOppfolgingsbrukerUtenCache(Fnr fnr) {
+            public Optional<VeilarbArenaOppfolging> oppdaterOppfolgingsbruker(Fnr fnr, String enhetNr) {
                 return Optional.of(new VeilarbArenaOppfolging(TEST_OPPFOLGINGSENHET_ID, "ARBS", "IKVAL"));
             }
 
-
             @Override
             public Optional<String> oppfolgingssak(Fnr fnr) {
                 return Optional.of(TEST_OPPFOLGINGSSAK);

diff --git a/src/test/java/no/nav/veilarbvedtaksstotte/service/KafkaConsumerServiceTest.java b/src/test/java/no/nav/veilarbvedtaksstotte/service/KafkaConsumerServiceTest.java
@@ -3,6 +3,8 @@
 import no.nav.common.client.aktoroppslag.AktorOppslagClient;
 import no.nav.common.client.norg2.Enhet;
 import no.nav.common.types.identer.AktorId;
+import no.nav.veilarbvedtaksstotte.client.arena.VeilarbarenaClient;
+import no.nav.veilarbvedtaksstotte.client.arena.VeilarbarenaClientImpl;
 import no.nav.veilarbvedtaksstotte.client.norg2.Norg2Client;
 import no.nav.veilarbvedtaksstotte.domain.kafka.KafkaOppfolgingsbrukerEndringV2;
 import no.nav.veilarbvedtaksstotte.domain.kafka.KafkaSisteOppfolgingsperiode;
@@ -17,6 +19,7 @@
 import java.time.ZonedDateTime;
 import java.util.UUID;
 
+import static no.nav.veilarbvedtaksstotte.client.arena.VeilarbarenaClientImplTest.veilarbarenaClient;
 import static no.nav.veilarbvedtaksstotte.utils.TestData.TEST_AKTOR_ID;
 import static no.nav.veilarbvedtaksstotte.utils.TestData.TEST_FNR;
 import static no.nav.veilarbvedtaksstotte.utils.TestData.TEST_OPPFOLGINGSENHET_ID;
@@ -40,14 +43,17 @@ public class KafkaConsumerServiceTest {
 
     private final Siste14aVedtakService siste14aVedtakService = mock(Siste14aVedtakService.class);
 
+    private final VeilarbarenaClient veilarbarenaClient = mock(VeilarbarenaClientImpl.class);
+
     private final AktorOppslagClient aktorOppslagClient = mock(AktorOppslagClient.class);
 
     private final KafkaConsumerService kafkaConsumerService = new KafkaConsumerService(
             siste14aVedtakService,
             vedtaksstotteRepository,
             beslutteroversiktRepository,
             norg2Client,
-            aktorOppslagClient);
+            aktorOppslagClient,
+            veilarbarenaClient);
 
     @Test
     public void skal_sette_gjeldende_til_historisk_hvis_fattet_foer_oppfolging_avsluttet() {