diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/inntektsmelding/InntektsmeldingClient.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/inntektsmelding/InntektsmeldingClient.java index bb9c8b46496..5a1f525a6eb 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/inntektsmelding/InntektsmeldingClient.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/inntektsmelding/InntektsmeldingClient.java @@ -25,6 +25,7 @@ import java.util.List; import java.util.stream.Collectors; +import static java.util.Collections.singletonList; import static java.util.Objects.nonNull; import static no.nav.dolly.domain.resultset.SystemTyper.INNTKMELD; import static org.apache.commons.lang3.StringUtils.isBlank; @@ -70,6 +71,12 @@ public Flux gjenopprett(RsDollyUtvidetBestilling bestilling, Dolly return Flux.empty(); } + @Override + public void release(List identer) { + + // Inntektsmelding mangler pt. sletting + } + private ClientFuture futurePersist(BestillingProgress progress, String status) { return () -> { @@ -78,12 +85,6 @@ private ClientFuture futurePersist(BestillingProgress progress, String status) { }; } - @Override - public void release(List identer) { - - // Inntektsmelding mangler pt. sletting - } - private Flux postInntektsmelding(boolean isSendMelding, InntektsmeldingRequest inntektsmeldingRequest, Long bestillingid) { @@ -94,17 +95,27 @@ private Flux postInntektsmelding(boolean isSendMelding, transaksjonMappingService.saveAll( response.getDokumenter().stream() - .map(dokument -> TransaksjonMapping.builder() - .ident(inntektsmeldingRequest.getArbeidstakerFnr()) - .bestillingId(bestillingid) - .transaksjonId(toJson(TransaksjonMappingDTO.builder() - .request(inntektsmeldingRequest) - .dokument(dokument) - .build())) - .datoEndret(LocalDateTime.now()) - .miljoe(inntektsmeldingRequest.getMiljoe()) - .system(INNTKMELD.name()) - .build()) + .map(dokument -> { + var gjeldendeInntektRequest = InntektsmeldingRequest.builder() + .arbeidstakerFnr(inntektsmeldingRequest.getArbeidstakerFnr()) + .inntekter(singletonList( + inntektsmeldingRequest.getInntekter().get(response.getDokumenter().indexOf(dokument)))) + .joarkMetadata(inntektsmeldingRequest.getJoarkMetadata()) + .miljoe(inntektsmeldingRequest.getMiljoe()) + .build(); + + return TransaksjonMapping.builder() + .ident(inntektsmeldingRequest.getArbeidstakerFnr()) + .bestillingId(bestillingid) + .transaksjonId(toJson(TransaksjonMappingDTO.builder() + .request(gjeldendeInntektRequest) + .dokument(dokument) + .build())) + .datoEndret(LocalDateTime.now()) + .miljoe(inntektsmeldingRequest.getMiljoe()) + .system(INNTKMELD.name()) + .build(); + }) .toList()); return inntektsmeldingRequest.getMiljoe() + ":OK"; diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/inntektsmelding/domain/InntektsmeldingRequest.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/inntektsmelding/domain/InntektsmeldingRequest.java index 46589137d18..1c86c049473 100644 --- a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/inntektsmelding/domain/InntektsmeldingRequest.java +++ b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/inntektsmelding/domain/InntektsmeldingRequest.java @@ -16,6 +16,7 @@ import java.time.LocalDateTime; import java.util.List; +@Builder @Getter @Setter @NoArgsConstructor