From a8d3c484857c49ccf325078eba8ba25895b5c490 Mon Sep 17 00:00:00 2001 From: stigus Date: Wed, 3 Apr 2024 10:13:36 +0200 Subject: [PATCH] Refaktorert PensjonforvalterClient og PensjonforvalterConsumer --- .../PensjonforvalterClient.java | 180 +++++++++--------- .../PensjonforvalterConsumer.java | 40 +--- .../command/AnnullerSamboerCommand.java | 8 +- .../command/LagreAlderspensjonCommand.java | 5 +- .../command/LagrePoppInntektCommand.java | 4 +- .../command/LagreSamboerCommand.java | 6 +- .../command/LagreTpForholdCommand.java | 5 +- .../command/LagreTpYtelseCommand.java | 5 +- .../command/LagreUforetrygdCommand.java | 5 +- .../command/OpprettPersonCommand.java | 6 +- .../command/SletteTpForholdCommand.java | 6 +- 11 files changed, 140 insertions(+), 130 deletions(-) diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/PensjonforvalterClient.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/PensjonforvalterClient.java index 844d4495105..3f34286411f 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/PensjonforvalterClient.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/PensjonforvalterClient.java @@ -95,28 +95,6 @@ public class PensjonforvalterClient implements ClientRegister { private final ObjectMapper objectMapper; private final Norg2Consumer norg2Consumer; - public static PensjonforvalterResponse mergePensjonforvalterResponses(List responser) { - - var status = new HashMap(); - responser.forEach(respons -> respons.getStatus() - .forEach(detalj -> { - if (detalj.getResponse().isResponse2xx()) { - status.putIfAbsent(detalj.getMiljo(), detalj.getResponse()); - } else { - status.put(detalj.getMiljo(), detalj.getResponse()); - } - })); - - return PensjonforvalterResponse.builder() - .status(status.entrySet().stream() - .map(detalj -> PensjonforvalterResponse.ResponseEnvironment.builder() - .miljo(detalj.getKey()) - .response(detalj.getValue()) - .build()) - .toList()) - .build(); - } - @Override public Flux gjenopprett(RsDollyUtvidetBestilling bestilling, DollyPerson dollyPerson, BestillingProgress progress, boolean isOpprettEndre) { @@ -216,13 +194,34 @@ public Flux gjenopprett(RsDollyUtvidetBestilling bestilling, Dolly .map(status2 -> futurePersist(dollyPerson, progress, status2))); } - private static Mono> getPdlPerson(Flux persondata) { + @Override + public void release(List identer) { - return persondata - .map(PdlPersonBolk.Data::getHentPersonBolk) - .flatMap(Flux::fromIterable) - .filter(personBolk -> nonNull(personBolk.getPerson())) - .collectList(); + // Pensjonforvalter / POPP støtter pt ikke sletting + + pensjonforvalterConsumer.sletteTpForhold(identer); + } + + public static PensjonforvalterResponse mergePensjonforvalterResponses(List responser) { + + var status = new HashMap(); + responser.forEach(respons -> respons.getStatus() + .forEach(detalj -> { + if (detalj.getResponse().isResponse2xx()) { + status.putIfAbsent(detalj.getMiljo(), detalj.getResponse()); + } else { + status.put(detalj.getMiljo(), detalj.getResponse()); + } + })); + + return PensjonforvalterResponse.builder() + .status(status.entrySet().stream() + .map(detalj -> PensjonforvalterResponse.ResponseEnvironment.builder() + .miljo(detalj.getKey()) + .response(detalj.getValue()) + .build()) + .toList()) + .build(); } private Mono getNavEnhetNr(Flux persondata, String ident) { @@ -275,18 +274,13 @@ private Flux annulerAlleSamboere(String ident, Set pensjonforvalterConsumer.hentSamboer(identSamboer, miljoe))) .flatMap(samboerResponse -> Flux.fromIterable(samboerResponse.getSamboerforhold()) - .flatMap(samboer -> pensjonforvalterConsumer.annullerSamboer(samboer.getPidBruker(), + .flatMap(samboer -> pensjonforvalterConsumer.annullerSamboer( getPeriodeId(samboer.get_links().getAnnuller().getHref()), miljoe) .filter(response1 -> samboer.getPidBruker().equals(ident) && response1.getStatus().stream() .noneMatch(status -> status.getResponse().getHttpStatus().getStatus() == 200)))))); } - private static String getPeriodeId(String lenke) { - return lenke.substring(lenke.indexOf(PERIODE) + PERIODE.length()) - .replace("/annuller", ""); - } - private String prepInitStatus(Set miljoer) { return PENSJON_FORVALTER + @@ -344,14 +338,6 @@ private Flux getPersonData(List identer) { .map(PdlPersonBolk::getData); } - @Override - public void release(List identer) { - - // Pensjonforvalter / POPP støtter pt ikke sletting - - pensjonforvalterConsumer.sletteTpForhold(identer); - } - private Flux opprettPersoner(String hovedperson, Set miljoer, List personer) { @@ -418,20 +404,20 @@ private Flux lagreUforetrygd(PensjonData pensjondata, if (isOpprettEndre || !transaksjonMappingService.existAlready(PEN_UT, ident, miljoe, null)) { - var context = MappingContextUtils.getMappingContext(); - context.setProperty(IDENT, ident); - context.setProperty(MILJOER, List.of(miljoe)); - context.setProperty(NAV_ENHET, navEnhetNr); - return Flux.just(mapperFacade.map(uforetrygd, PensjonUforetrygdRequest.class, context)) - .flatMap(request -> pensjonforvalterConsumer.lagreUforetrygd(request) - .map(response -> { - response.getStatus().stream() - .filter(status -> status.getResponse().isResponse2xx()) - .forEach(status -> - saveAPTransaksjonId(ident, status.getMiljo(), bestillingId, - PEN_UT, new AtomicReference<>(request))); - return response; - })); + var context = MappingContextUtils.getMappingContext(); + context.setProperty(IDENT, ident); + context.setProperty(MILJOER, List.of(miljoe)); + context.setProperty(NAV_ENHET, navEnhetNr); + return Flux.just(mapperFacade.map(uforetrygd, PensjonUforetrygdRequest.class, context)) + .flatMap(request -> pensjonforvalterConsumer.lagreUforetrygd(request) + .map(response -> { + response.getStatus().stream() + .filter(status -> status.getResponse().isResponse2xx()) + .forEach(status -> + saveAPTransaksjonId(ident, status.getMiljo(), bestillingId, + PEN_UT, new AtomicReference<>(request))); + return response; + })); } else { return getStatus(miljoe, 200, "OK"); @@ -439,22 +425,6 @@ private Flux lagreUforetrygd(PensjonData pensjondata, })); } - private static Flux getStatus(String miljoe, Integer status, String reasonPhrase) { - - return Flux.just(PensjonforvalterResponse.builder() - .status(List.of(PensjonforvalterResponse.ResponseEnvironment.builder() - .miljo(miljoe) - .response(PensjonforvalterResponse.Response.builder() - .httpStatus(PensjonforvalterResponse.HttpStatus.builder() - .status(status) - .reasonPhrase(reasonPhrase) - .build()) - .message(reasonPhrase) - .build()) - .build())) - .build()); - } - @SuppressWarnings("java:S3740") private void saveAPTransaksjonId(String ident, String miljoe, Long bestillingId, SystemTyper type, AtomicReference vedtak) { @@ -531,24 +501,6 @@ private String decodeStatus(PensjonforvalterResponse response, String ident) { .collect(Collectors.joining(",")); } - String getError(PensjonforvalterResponse.ResponseEnvironment entry) { - - var response = entry.getResponse(); - var httpStatus = response.getHttpStatus(); - - if (isNotBlank(response.getMessage())) { - if (response.getMessage().contains("{")) { - return ErrorStatusDecoder.encodeStatus( - "Feil: " + response.getMessage().split("\\{")[1].split("}")[0].replace("message\":", "")); - } else { - return ErrorStatusDecoder.encodeStatus("Feil: " + response.getMessage()); - } - - } else { - return errorStatusDecoder.getErrorText(HttpStatus.valueOf(httpStatus.getStatus()), httpStatus.getReasonPhrase()); - } - } - private String toJson(Object object) { try { @@ -559,6 +511,36 @@ private String toJson(Object object) { return null; } + private static Mono> getPdlPerson(Flux persondata) { + + return persondata + .map(PdlPersonBolk.Data::getHentPersonBolk) + .flatMap(Flux::fromIterable) + .filter(personBolk -> nonNull(personBolk.getPerson())) + .collectList(); + } + + private static String getPeriodeId(String lenke) { + return lenke.substring(lenke.indexOf(PERIODE) + PERIODE.length()) + .replace("/annuller", ""); + } + + private static Flux getStatus(String miljoe, Integer status, String reasonPhrase) { + + return Flux.just(PensjonforvalterResponse.builder() + .status(List.of(PensjonforvalterResponse.ResponseEnvironment.builder() + .miljo(miljoe) + .response(PensjonforvalterResponse.Response.builder() + .httpStatus(PensjonforvalterResponse.HttpStatus.builder() + .status(status) + .reasonPhrase(reasonPhrase) + .build()) + .message(reasonPhrase) + .build()) + .build())) + .build()); + } + private static String getGeografiskTilknytning(PdlPersonBolk.GeografiskTilknytning tilknytning) { if (isNotBlank(tilknytning.getGtKommune())) { @@ -571,4 +553,22 @@ private static String getGeografiskTilknytning(PdlPersonBolk.GeografiskTilknytni return "030102"; } } + + String getError(PensjonforvalterResponse.ResponseEnvironment entry) { + + var response = entry.getResponse(); + var httpStatus = response.getHttpStatus(); + + if (isNotBlank(response.getMessage())) { + if (response.getMessage().contains("{")) { + return ErrorStatusDecoder.encodeStatus( + "Feil: " + response.getMessage().split("\\{")[1].split("}")[0].replace("message\":", "")); + } else { + return ErrorStatusDecoder.encodeStatus("Feil: " + response.getMessage()); + } + + } else { + return errorStatusDecoder.getErrorText(HttpStatus.valueOf(httpStatus.getStatus()), httpStatus.getReasonPhrase()); + } + } } \ No newline at end of file diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/PensjonforvalterConsumer.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/PensjonforvalterConsumer.java index 4aaf0f775e2..818ef214e17 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/PensjonforvalterConsumer.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/PensjonforvalterConsumer.java @@ -35,7 +35,6 @@ import java.util.List; import java.util.Set; -import static no.nav.dolly.util.CallIdUtil.generateCallId; import static no.nav.dolly.util.JacksonExchangeStrategyUtil.getJacksonStrategy; @Slf4j @@ -70,11 +69,9 @@ public Mono> getMiljoer() { @Timed(name = "providers", tags = { "operation", "popp_lagreInntekt" }) public Flux lagreInntekter(PensjonPoppInntektRequest pensjonPoppInntektRequest) { - String callId = generateCallId(); - log.info("Popp lagre inntekt {}, callId: {}", pensjonPoppInntektRequest, callId); return tokenService.exchange(serverProperties) .flatMapMany(token -> new LagrePoppInntektCommand(webClient, token.getTokenValue(), - pensjonPoppInntektRequest, callId).call()); + pensjonPoppInntektRequest).call()); } @Timed(name = "providers", tags = { "operation", "pen_opprettPerson" }) @@ -82,10 +79,8 @@ public Flux opprettPerson(PensjonPersonRequest pensjon Set miljoer) { pensjonPersonRequest.setMiljoer(miljoer); - String callId = generateCallId(); - log.info("Pensjon opprett person {}, callId: {}", pensjonPersonRequest, callId); return tokenService.exchange(serverProperties) - .flatMapMany(token -> new OpprettPersonCommand(webClient, pensjonPersonRequest, token.getTokenValue(), callId).call()); + .flatMapMany(token -> new OpprettPersonCommand(webClient, pensjonPersonRequest, token.getTokenValue()).call()); } @Timed(name = "providers", tags = { "operation", "pen_hentSamboer" }) @@ -100,59 +95,46 @@ public Flux hentSamboer(String ident, String miljoe) { public Flux lagreSamboer(PensjonSamboerRequest pensjonSamboerRequest, String miljoe) { - String callId = generateCallId(); - log.info("Pensjon samboer opprett i {} {}, callId: {}", miljoe, pensjonSamboerRequest, callId); return tokenService.exchange(serverProperties) - .flatMapMany(token -> new LagreSamboerCommand(webClient, pensjonSamboerRequest, miljoe, token.getTokenValue(), callId).call()); + .flatMapMany(token -> new LagreSamboerCommand(webClient, pensjonSamboerRequest, miljoe, token.getTokenValue()).call()); } @Timed(name = "providers", tags = { "operation", "pen_opprettSamboer" }) - public Flux annullerSamboer(String ident, String periodeId, String miljoe) { + public Flux annullerSamboer(String periodeId, String miljoe) { - String callId = generateCallId(); - log.info("Pensjon samboer annuller {} periodeId {}, callId: {}", ident, periodeId, callId); return tokenService.exchange(serverProperties) - .flatMapMany(token -> new AnnullerSamboerCommand(webClient, periodeId, miljoe, token.getTokenValue(), callId).call()); + .flatMapMany(token -> new AnnullerSamboerCommand(webClient, periodeId, miljoe, token.getTokenValue()).call()); } @Timed(name = "providers", tags = { "operation", "pen_lagreAlderspensjon" }) public Flux lagreAlderspensjon(AlderspensjonRequest request) { - String callId = generateCallId(); - log.info("Pensjon lagre alderspensjon {}, callId: {}", request, callId); return tokenService.exchange(serverProperties) .flatMapMany(token -> - new LagreAlderspensjonCommand(webClient, token.getTokenValue(), request, callId).call()); + new LagreAlderspensjonCommand(webClient, token.getTokenValue(), request).call()); } @Timed(name = "providers", tags = { "operation", "pen_lagreUforetrygd" }) public Flux lagreUforetrygd(PensjonUforetrygdRequest request) { - String callId = generateCallId(); - log.info("Pensjon lagre uforetrygd {}, callId: {}", request, callId); return tokenService.exchange(serverProperties) - .flatMapMany(token -> new LagreUforetrygdCommand(webClient, token.getTokenValue(), request, callId).call()); + .flatMapMany(token -> new LagreUforetrygdCommand(webClient, token.getTokenValue(), request).call()); } @Timed(name = "providers", tags = { "operation", "pen_lagreTpForhold" }) public Flux lagreTpForhold(PensjonTpForholdRequest pensjonTpForholdRequest) { - String callId = generateCallId(); - log.info("Pensjon lagre TP-forhold {}, callId: {}", pensjonTpForholdRequest, callId); return tokenService.exchange(serverProperties) - .flatMapMany(token -> new LagreTpForholdCommand(webClient, token.getTokenValue(), pensjonTpForholdRequest, callId).call()); + .flatMapMany(token -> new LagreTpForholdCommand(webClient, token.getTokenValue(), pensjonTpForholdRequest).call()); } @Timed(name = "providers", tags = { "operation", "pen_sletteTpForhold" }) public void sletteTpForhold(List identer) { - String callId = generateCallId(); - log.info("Pensjon slette TP-forhold callId: {}", callId); - tokenService.exchange(serverProperties) .flatMapMany(token -> new HentMiljoerCommand(webClient, token.getTokenValue()).call() .flatMapMany(miljoer -> Flux.range(0, identer.size()) - .map(index -> new SletteTpForholdCommand(webClient, identer.get(index), miljoer, token.getTokenValue(), callId).call()))) + .map(index -> new SletteTpForholdCommand(webClient, identer.get(index), miljoer, token.getTokenValue()).call()))) .flatMap((Flux::from)) .collectList() .subscribe(response -> log.info("Slettet mot PESYS (tp) i alle miljoer")); @@ -161,10 +143,8 @@ public void sletteTpForhold(List identer) { @Timed(name = "providers", tags = { "operation", "pen_lagreTpYtelse" }) public Flux lagreTpYtelse(PensjonTpYtelseRequest pensjonTpYtelseRequest) { - String callId = generateCallId(); - log.info("Pensjon lagre TP-ytelse {}, callId: {}", pensjonTpYtelseRequest, callId); return tokenService.exchange(serverProperties) - .flatMapMany(token -> new LagreTpYtelseCommand(webClient, token.getTokenValue(), pensjonTpYtelseRequest, callId).call()); + .flatMapMany(token -> new LagreTpYtelseCommand(webClient, token.getTokenValue(), pensjonTpYtelseRequest).call()); } @Override diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/AnnullerSamboerCommand.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/AnnullerSamboerCommand.java index 3c884e00386..12f694b1bb7 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/AnnullerSamboerCommand.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/AnnullerSamboerCommand.java @@ -16,6 +16,7 @@ import static no.nav.dolly.domain.CommonKeysAndUtils.CONSUMER; import static no.nav.dolly.domain.CommonKeysAndUtils.HEADER_NAV_CALL_ID; import static no.nav.dolly.domain.CommonKeysAndUtils.HEADER_NAV_CONSUMER_ID; +import static no.nav.dolly.util.CallIdUtil.generateCallId; import static org.springframework.http.HttpHeaders.AUTHORIZATION; @Slf4j @@ -27,9 +28,12 @@ public class AnnullerSamboerCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon samboer annuller periodeId {}, callId: {}", periodeId, callId); + return webClient .put() .uri(uriBuilder -> uriBuilder @@ -75,7 +79,7 @@ private static PensjonforvalterResponse pensjonforvalterResponseFromError(String .reasonPhrase(WebClientFilter.getStatus(error).getReasonPhrase()) .build()) .message(WebClientFilter.getMessage(error)) - .path(PEN_SAMBOER_URL.replace("{miljoe}", miljoe).replace("{periodeId}", periodeId)) + .path(PEN_SAMBOER_URL.replace("{miljoe}", miljoe).replace("{periodeId}", periodeId)) .build()) .build(); diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreAlderspensjonCommand.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreAlderspensjonCommand.java index af37ff5627f..f5d86013fd8 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreAlderspensjonCommand.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreAlderspensjonCommand.java @@ -34,9 +34,12 @@ public class LagreAlderspensjonCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon lagre alderspensjon {}, callId: {}", alderspensjonRequest, callId); + return webClient .post() .uri(uriBuilder -> uriBuilder diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagrePoppInntektCommand.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagrePoppInntektCommand.java index 0c23bd3f1f4..adba7bf9e85 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagrePoppInntektCommand.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagrePoppInntektCommand.java @@ -30,9 +30,11 @@ public class LagrePoppInntektCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Popp lagre inntekt {}, callId: {}", pensjonPoppInntektRequest, callId); return webClient .post() .uri(uriBuilder -> uriBuilder diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreSamboerCommand.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreSamboerCommand.java index df9ca97bc41..28e9395a267 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreSamboerCommand.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreSamboerCommand.java @@ -15,6 +15,7 @@ import static no.nav.dolly.domain.CommonKeysAndUtils.CONSUMER; import static no.nav.dolly.domain.CommonKeysAndUtils.HEADER_NAV_CALL_ID; import static no.nav.dolly.domain.CommonKeysAndUtils.HEADER_NAV_CONSUMER_ID; +import static no.nav.dolly.util.CallIdUtil.generateCallId; import static org.springframework.http.HttpHeaders.AUTHORIZATION; @Slf4j @@ -26,9 +27,12 @@ public class LagreSamboerCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon samboer opprett i {} {}, callId: {}", miljoe, pensjonSamboerRequest, callId); + return webClient .post() .uri(uriBuilder -> uriBuilder diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreTpForholdCommand.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreTpForholdCommand.java index a0bbcad5abc..208d797e4e3 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreTpForholdCommand.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreTpForholdCommand.java @@ -34,9 +34,12 @@ public class LagreTpForholdCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon lagre TP-forhold {}, callId: {}", lagreTpForholdRequest, callId); + return webClient .post() .uri(uriBuilder -> uriBuilder diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreTpYtelseCommand.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreTpYtelseCommand.java index 51222793c1c..9756f8b2667 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreTpYtelseCommand.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreTpYtelseCommand.java @@ -33,9 +33,12 @@ public class LagreTpYtelseCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon lagre TP-ytelse {}, callId: {}", pensjonTpYtelseRequest, callId); + return webClient .post() .uri(uriBuilder -> uriBuilder diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreUforetrygdCommand.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreUforetrygdCommand.java index 0fc1d461032..11287c76bd0 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreUforetrygdCommand.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreUforetrygdCommand.java @@ -32,9 +32,12 @@ public class LagreUforetrygdCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon lagre uforetrygd {}, callId: {}", uforetrygdRequest, callId); + return webClient .post() .uri(uriBuilder -> uriBuilder diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/OpprettPersonCommand.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/OpprettPersonCommand.java index 50ef944cfd2..a72dfc6a746 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/OpprettPersonCommand.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/OpprettPersonCommand.java @@ -17,6 +17,7 @@ import static no.nav.dolly.domain.CommonKeysAndUtils.CONSUMER; import static no.nav.dolly.domain.CommonKeysAndUtils.HEADER_NAV_CALL_ID; import static no.nav.dolly.domain.CommonKeysAndUtils.HEADER_NAV_CONSUMER_ID; +import static no.nav.dolly.util.CallIdUtil.generateCallId; import static no.nav.dolly.util.TokenXUtil.getUserJwt; import static org.springframework.http.HttpHeaders.AUTHORIZATION; @@ -29,9 +30,12 @@ public class OpprettPersonCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon opprett person {}, callId: {}", pensjonPersonRequest, callId); + return webClient .post() .uri(uriBuilder -> uriBuilder diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/SletteTpForholdCommand.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/SletteTpForholdCommand.java index 86099d58896..db60ec8ce9c 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/SletteTpForholdCommand.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/SletteTpForholdCommand.java @@ -17,6 +17,7 @@ import static no.nav.dolly.domain.CommonKeysAndUtils.CONSUMER; import static no.nav.dolly.domain.CommonKeysAndUtils.HEADER_NAV_CALL_ID; import static no.nav.dolly.domain.CommonKeysAndUtils.HEADER_NAV_CONSUMER_ID; +import static no.nav.dolly.util.CallIdUtil.generateCallId; import static no.nav.dolly.util.TokenXUtil.getUserJwt; import static org.springframework.http.HttpHeaders.AUTHORIZATION; @@ -30,10 +31,13 @@ public class SletteTpForholdCommand implements Callable miljoer; private final String token; - private final String callId; public Flux call() { + + var callId = generateCallId(); + log.info("Pensjon slette TP-forhold callId: {}", callId); + return webClient .delete() .uri(uriBuilder -> uriBuilder