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 518fa494706..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 @@ -59,33 +59,31 @@ public PensjonforvalterConsumer( .build(); } - @Timed(name = "providers", tags = {"operation", "pen_getMiljoer"}) + @Timed(name = "providers", tags = { "operation", "pen_getMiljoer" }) public Mono> getMiljoer() { return tokenService.exchange(serverProperties) .flatMap(token -> new HentMiljoerCommand(webClient, token.getTokenValue()).call()); } - @Timed(name = "providers", tags = {"operation", "popp_lagreInntekt"}) + @Timed(name = "providers", tags = { "operation", "popp_lagreInntekt" }) public Flux lagreInntekter(PensjonPoppInntektRequest pensjonPoppInntektRequest) { - log.info("Popp lagre inntekt {}", pensjonPoppInntektRequest); return tokenService.exchange(serverProperties) .flatMapMany(token -> new LagrePoppInntektCommand(webClient, token.getTokenValue(), - pensjonPoppInntektRequest).call()); + pensjonPoppInntektRequest).call()); } - @Timed(name = "providers", tags = {"operation", "pen_opprettPerson"}) + @Timed(name = "providers", tags = { "operation", "pen_opprettPerson" }) public Flux opprettPerson(PensjonPersonRequest pensjonPersonRequest, Set miljoer) { pensjonPersonRequest.setMiljoer(miljoer); - log.info("Pensjon opprett person {}", pensjonPersonRequest); return tokenService.exchange(serverProperties) .flatMapMany(token -> new OpprettPersonCommand(webClient, pensjonPersonRequest, token.getTokenValue()).call()); } - @Timed(name = "providers", tags = {"operation", "pen_hentSamboer"}) + @Timed(name = "providers", tags = { "operation", "pen_hentSamboer" }) public Flux hentSamboer(String ident, String miljoe) { return tokenService.exchange(serverProperties) @@ -93,49 +91,44 @@ public Flux hentSamboer(String ident, String miljoe) { .doOnNext(response -> log.info("Pensjon samboer for {} i {} hentet {}", ident, miljoe, response)); } - @Timed(name = "providers", tags = {"operation", "pen_opprettSamboer"}) + @Timed(name = "providers", tags = { "operation", "pen_opprettSamboer" }) public Flux lagreSamboer(PensjonSamboerRequest pensjonSamboerRequest, String miljoe) { - log.info("Pensjon samboer opprett i {} {}", miljoe, pensjonSamboerRequest); return tokenService.exchange(serverProperties) .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) { + @Timed(name = "providers", tags = { "operation", "pen_opprettSamboer" }) + public Flux annullerSamboer(String periodeId, String miljoe) { - log.info("Pensjon samboer annuller {} periodeId {}", ident, periodeId); return tokenService.exchange(serverProperties) .flatMapMany(token -> new AnnullerSamboerCommand(webClient, periodeId, miljoe, token.getTokenValue()).call()); } - @Timed(name = "providers", tags = {"operation", "pen_lagreAlderspensjon"}) + @Timed(name = "providers", tags = { "operation", "pen_lagreAlderspensjon" }) public Flux lagreAlderspensjon(AlderspensjonRequest request) { - log.info("Pensjon lagre alderspensjon {}", request); return tokenService.exchange(serverProperties) .flatMapMany(token -> new LagreAlderspensjonCommand(webClient, token.getTokenValue(), request).call()); } - @Timed(name = "providers", tags = {"operation", "pen_lagreUforetrygd"}) + @Timed(name = "providers", tags = { "operation", "pen_lagreUforetrygd" }) public Flux lagreUforetrygd(PensjonUforetrygdRequest request) { - log.info("Pensjon lagre uforetrygd {}", request); return tokenService.exchange(serverProperties) .flatMapMany(token -> new LagreUforetrygdCommand(webClient, token.getTokenValue(), request).call()); } - @Timed(name = "providers", tags = {"operation", "pen_lagreTpForhold"}) + @Timed(name = "providers", tags = { "operation", "pen_lagreTpForhold" }) public Flux lagreTpForhold(PensjonTpForholdRequest pensjonTpForholdRequest) { - log.info("Pensjon lagre TP-forhold {}", pensjonTpForholdRequest); return tokenService.exchange(serverProperties) .flatMapMany(token -> new LagreTpForholdCommand(webClient, token.getTokenValue(), pensjonTpForholdRequest).call()); } - @Timed(name = "providers", tags = {"operation", "pen_sletteTpForhold"}) + @Timed(name = "providers", tags = { "operation", "pen_sletteTpForhold" }) public void sletteTpForhold(List identer) { tokenService.exchange(serverProperties) @@ -147,10 +140,9 @@ public void sletteTpForhold(List identer) { .subscribe(response -> log.info("Slettet mot PESYS (tp) i alle miljoer")); } - @Timed(name = "providers", tags = {"operation", "pen_lagreTpYtelse"}) + @Timed(name = "providers", tags = { "operation", "pen_lagreTpYtelse" }) public Flux lagreTpYtelse(PensjonTpYtelseRequest pensjonTpYtelseRequest) { - log.info("Pensjon lagre TP-ytelse {}", pensjonTpYtelseRequest); return tokenService.exchange(serverProperties) .flatMapMany(token -> new LagreTpYtelseCommand(webClient, token.getTokenValue(), pensjonTpYtelseRequest).call()); } 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 ab5b67beb8c..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 @@ -30,13 +30,17 @@ public class AnnullerSamboerCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon samboer annuller periodeId {}, callId: {}", periodeId, callId); + return webClient .put() .uri(uriBuilder -> uriBuilder .path(PEN_SAMBOER_URL) .build(miljoe, periodeId)) .header(AUTHORIZATION, "Bearer " + token) - .header(HEADER_NAV_CALL_ID, generateCallId()) + .header(HEADER_NAV_CALL_ID, callId) .header(HEADER_NAV_CONSUMER_ID, CONSUMER) .retrieve() .toBodilessEntity() @@ -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/HentPoppInntekterCommand.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/HentPoppInntekterCommand.java index 7b0f78b2921..3a2e47389e4 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/HentPoppInntekterCommand.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/HentPoppInntekterCommand.java @@ -14,7 +14,6 @@ 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 @@ -29,6 +28,7 @@ public class HentPoppInntekterCommand implements Callable> { private final String token; private final String ident; private final String miljoe; + private final String callId; public Mono call() { return webClient @@ -38,7 +38,7 @@ public Mono call() { .queryParam(FNR_PARAM, ident) .build()) .header(AUTHORIZATION, "Bearer " + token) - .header(HEADER_NAV_CALL_ID, generateCallId()) + .header(HEADER_NAV_CALL_ID, callId) .header(HEADER_NAV_CONSUMER_ID, CONSUMER) .header(MILJO_HEADER, miljoe) .retrieve() 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 1a7c18149f2..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 @@ -36,6 +36,10 @@ public class LagreAlderspensjonCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon lagre alderspensjon {}, callId: {}", alderspensjonRequest, callId); + return webClient .post() .uri(uriBuilder -> uriBuilder @@ -47,7 +51,7 @@ public Flux call() { reactorRequest.responseTimeout(Duration.ofSeconds(REQUEST_DURATION)); }) .header(AUTHORIZATION, "Bearer " + token) - .header(HEADER_NAV_CALL_ID, generateCallId()) + .header(HEADER_NAV_CALL_ID, callId) .header(HEADER_NAV_CONSUMER_ID, CONSUMER) .bodyValue(alderspensjonRequest) .retrieve() 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 48c050b98c8..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 @@ -32,6 +32,9 @@ public class LagrePoppInntektCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Popp lagre inntekt {}, callId: {}", pensjonPoppInntektRequest, callId); return webClient .post() .uri(uriBuilder -> uriBuilder @@ -42,7 +45,7 @@ public Flux call() { reactorRequest.responseTimeout(Duration.ofSeconds(REQUEST_DURATION)); }) .header(AUTHORIZATION, "Bearer " + token) - .header(HEADER_NAV_CALL_ID, generateCallId()) + .header(HEADER_NAV_CALL_ID, callId) .header(HEADER_NAV_CONSUMER_ID, CONSUMER) .bodyValue(pensjonPoppInntektRequest) .retrieve() 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 617a0ba26a7..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 @@ -29,13 +29,17 @@ 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 .path(PEN_SAMBOER_URL) .build(miljoe)) .header(AUTHORIZATION, "Bearer " + token) - .header(HEADER_NAV_CALL_ID, generateCallId()) + .header(HEADER_NAV_CALL_ID, callId) .header(HEADER_NAV_CONSUMER_ID, CONSUMER) .bodyValue(pensjonSamboerRequest) .retrieve() 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 4a4b5488661..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 @@ -36,6 +36,10 @@ public class LagreTpForholdCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon lagre TP-forhold {}, callId: {}", lagreTpForholdRequest, callId); + return webClient .post() .uri(uriBuilder -> uriBuilder @@ -47,7 +51,7 @@ public Flux call() { }) .header(AUTHORIZATION, "Bearer " + token) .header(UserConstant.USER_HEADER_JWT, getUserJwt()) - .header(HEADER_NAV_CALL_ID, generateCallId()) + .header(HEADER_NAV_CALL_ID, callId) .header(HEADER_NAV_CONSUMER_ID, CONSUMER) .bodyValue(lagreTpForholdRequest) .retrieve() 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 f6f41a82704..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 @@ -35,6 +35,10 @@ public class LagreTpYtelseCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon lagre TP-ytelse {}, callId: {}", pensjonTpYtelseRequest, callId); + return webClient .post() .uri(uriBuilder -> uriBuilder @@ -46,7 +50,7 @@ public Flux call() { }) .header(AUTHORIZATION, "Bearer " + token) .header(UserConstant.USER_HEADER_JWT, getUserJwt()) - .header(HEADER_NAV_CALL_ID, generateCallId()) + .header(HEADER_NAV_CALL_ID, callId) .header(HEADER_NAV_CONSUMER_ID, CONSUMER) .bodyValue(pensjonTpYtelseRequest) .retrieve() 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 dd1d77c0d1c..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 @@ -34,6 +34,10 @@ public class LagreUforetrygdCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon lagre uforetrygd {}, callId: {}", uforetrygdRequest, callId); + return webClient .post() .uri(uriBuilder -> uriBuilder @@ -44,7 +48,7 @@ public Flux call() { reactorRequest.responseTimeout(Duration.ofSeconds(REQUEST_DURATION)); }) .header(AUTHORIZATION, "Bearer " + token) - .header(HEADER_NAV_CALL_ID, generateCallId()) + .header(HEADER_NAV_CALL_ID, callId) .header(HEADER_NAV_CONSUMER_ID, CONSUMER) .bodyValue(uforetrygdRequest) .retrieve() 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 a37bd6a6705..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 @@ -32,6 +32,10 @@ public class OpprettPersonCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon opprett person {}, callId: {}", pensjonPersonRequest, callId); + return webClient .post() .uri(uriBuilder -> uriBuilder @@ -39,7 +43,7 @@ public Flux call() { .build()) .header(AUTHORIZATION, "Bearer " + token) .header(UserConstant.USER_HEADER_JWT, getUserJwt()) - .header(HEADER_NAV_CALL_ID, generateCallId()) + .header(HEADER_NAV_CALL_ID, callId) .header(HEADER_NAV_CONSUMER_ID, CONSUMER) .bodyValue(pensjonPersonRequest) .retrieve() 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 6b6a2fd11c6..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 @@ -1,5 +1,3 @@ - - package no.nav.dolly.bestilling.pensjonforvalter.command; import lombok.RequiredArgsConstructor; @@ -36,6 +34,10 @@ public class SletteTpForholdCommand implements Callable call() { + + var callId = generateCallId(); + log.info("Pensjon slette TP-forhold callId: {}", callId); + return webClient .delete() .uri(uriBuilder -> uriBuilder @@ -44,7 +46,7 @@ public Flux call() { .build()) .header(AUTHORIZATION, "Bearer " + token) .header(UserConstant.USER_HEADER_JWT, getUserJwt()) - .header(HEADER_NAV_CALL_ID, generateCallId()) + .header(HEADER_NAV_CALL_ID, callId) .header(HEADER_NAV_CONSUMER_ID, CONSUMER) .header("pid", ident) .retrieve()