Endret transaksjonsId til å kun returnere inntekten som gjelder for d…

…et innsendte dokumentet #deploy-test-dolly-backend
navikt · Oct 11, 2023 · 90b6e49 · 90b6e49
1 parent accdc51
commit 90b6e49
Show file tree

Hide file tree

Showing 2 changed files with 29 additions and 17 deletions.
diff --git a/...-backend/src/main/java/no/nav/dolly/bestilling/inntektsmelding/InntektsmeldingClient.java b/...-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<ClientFuture> gjenopprett(RsDollyUtvidetBestilling bestilling, Dolly
         return Flux.empty();
     }
 
+    @Override
+    public void release(List<String> 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<String> identer) {
-
-        // Inntektsmelding mangler pt. sletting
-    }
-
     private Flux<String> postInntektsmelding(boolean isSendMelding,
                                              InntektsmeldingRequest inntektsmeldingRequest, Long bestillingid) {
 
@@ -94,17 +95,27 @@ private Flux<String> 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/.../src/main/java/no/nav/dolly/bestilling/inntektsmelding/domain/InntektsmeldingRequest.java b/.../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
-Original file line number
+Diff line change
@@ Expand Up / @@ -16,6 +16,7 @@ @@
     import java.time.LocalDateTime;
     import java.util.List;
+    @Builder
     @Getter
     @Setter
     @NoArgsConstructor
@@ Expand Down @@