Skip to content

Commit 1787615

Browse files
committed
Legg til logging for feilsøking av indeksering
1 parent 68ff49c commit 1787615

File tree

1 file changed

+16
-2
lines changed

1 file changed

+16
-2
lines changed

src/main/java/no/nav/pto/veilarbportefolje/postgres/PostgresOpensearchMapper.java

+16-2
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
import org.springframework.stereotype.Service;
2626

2727
import java.util.*;
28+
import java.util.concurrent.atomic.AtomicInteger;
2829
import java.util.stream.Collectors;
2930
import java.util.stream.Stream;
3031

@@ -176,9 +177,22 @@ public void flettInnEnsligeForsorgereData(List<OppfolgingsBruker> brukere) {
176177
}
177178

178179
public void flettInnTiltakshendelser(List<OppfolgingsBruker> brukere) {
180+
AtomicInteger brukereUtenTiltakshendelse = new AtomicInteger();
181+
AtomicInteger brukereMedTiltakshendelse = new AtomicInteger();
182+
179183
brukere.forEach(bruker -> {
180-
Tiltakshendelse eldsteTiltakshendelsePaBruker = tiltakshendelseRepository.hentEldsteTiltakshendelse(Fnr.of(bruker.getFnr()));
181-
bruker.setTiltakshendelse(eldsteTiltakshendelsePaBruker);
184+
try {
185+
Tiltakshendelse eldsteTiltakshendelsePaBruker = tiltakshendelseRepository.hentEldsteTiltakshendelse(Fnr.of(bruker.getFnr()));
186+
if (eldsteTiltakshendelsePaBruker == null) {
187+
brukereUtenTiltakshendelse.getAndIncrement();
188+
} else {
189+
brukereMedTiltakshendelse.getAndIncrement();
190+
}
191+
bruker.setTiltakshendelse(eldsteTiltakshendelsePaBruker);
192+
log.debug("Indeksering – Brukere med tiltakshendelse: " + brukereMedTiltakshendelse + ", brukere med tiltakshendelse: " + brukereUtenTiltakshendelse);
193+
} catch (Error e) {
194+
log.error("Indeksering – Feil utløst ved henting av eldste tiltakshendelse på bruker.");
195+
}
182196
});
183197
}
184198

0 commit comments

Comments
 (0)