Fix arbeidsplassen CV innsending (#4112)

Author: krharum

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/arbeidsplassencv/ArbeidsplassenCVClient.java

@@ -5,6 +5,9 @@
 import ma.glasnost.orika.MapperFacade;
 import no.nav.dolly.bestilling.ClientRegister;
 import no.nav.dolly.bestilling.arbeidsplassencv.dto.PAMCVDTO;
+import no.nav.dolly.bestilling.personservice.PersonServiceConsumer;
+import no.nav.dolly.domain.PdlPerson;
+import no.nav.dolly.domain.PdlPersonBolk;
 import no.nav.dolly.domain.jpa.BestillingProgress;
 import no.nav.dolly.domain.resultset.RsDollyUtvidetBestilling;
 import no.nav.dolly.domain.resultset.dolly.DollyPerson;
@@ -14,14 +17,18 @@
 import no.nav.testnav.libs.dto.arbeidsplassencv.v1.ArbeidsplassenCVDTO;
 import org.springframework.http.HttpStatus;
 import org.springframework.stereotype.Service;
+import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import reactor.util.retry.Retry;
 
 import java.util.List;
 import java.util.function.Consumer;
 
 import static java.util.Objects.isNull;
+import static java.util.Objects.nonNull;
 import static no.nav.dolly.errorhandling.ErrorStatusDecoder.getInfoVenter;
+import static no.nav.testnav.libs.dto.pdlforvalter.v1.AdressebeskyttelseDTO.AdresseBeskyttelse.STRENGT_FORTROLIG;
+import static org.apache.commons.lang3.BooleanUtils.isTrue;
 
 @Slf4j
 @Service
@@ -32,6 +39,7 @@ public class ArbeidsplassenCVClient implements ClientRegister {
     private final MapperFacade mapperFacade;
     private final TransactionHelperService transactionHelperService;
     private final ErrorStatusDecoder errorStatusDecoder;
+    private final PersonServiceConsumer personServiceConsumer;
 
     @Override
     public Mono<BestillingProgress> gjenopprett(RsDollyUtvidetBestilling bestilling, DollyPerson dollyPerson, BestillingProgress progress, boolean isOpprettEndre) {
@@ -40,27 +48,56 @@ public Mono<BestillingProgress> gjenopprett(RsDollyUtvidetBestilling bestilling,
             return Mono.empty();
         }
 
-        return oppdaterStatus(progress, getInfoVenter("Arbeidsplassen"))
-                .then(Mono.just(bestilling.getArbeidsplassenCV()))
-                .flatMap(arbeidsplassenCV -> {
-                    var oppdatertOrdre = mapperFacade.map(arbeidsplassenCV, ArbeidsplassenCVDTO.class);
-                    bestilling.setArbeidsplassenCV(oppdatertOrdre);
-                    return transactionHelperService.persister(progress.getBestillingId(), bestilling)
-                            .then(Mono.just(arbeidsplassenCV));
-                })
-                .flatMap(oppdatertOrdre -> Mono.just(CallIdUtil.generateCallId())
-                        .flatMap(uuid -> arbeidsplassenCVConsumer.opprettPerson(dollyPerson.getIdent(), uuid)
-                                .flatMap(response ->
-                                        arbeidsplassenCVConsumer.godtaHjemmel(dollyPerson.getIdent(), uuid)
-                                                .then(Mono.just(mapperFacade.map(oppdatertOrdre, PAMCVDTO.class))
-                                                        .flatMap(request -> arbeidsplassenCVConsumer.oppdaterCV(dollyPerson.getIdent(),
-                                                                request, uuid, logRetries(progress)))))
-
-                                .map(status -> status.getStatus().is2xxSuccessful() ? "OK" :
-                                        errorStatusDecoder.getErrorText(HttpStatus.valueOf(status.getStatus().value()),
-                                                status.getFeilmelding()))
-
-                                .flatMap(resultat -> oppdaterStatus(progress, resultat))));
+        return getPerson(dollyPerson)
+                .flatMap(person -> Mono.zip(
+                        Mono.just(person.getAdressebeskyttelse().stream()
+                                .anyMatch(ab ->
+                                        STRENGT_FORTROLIG.equals(ab.getGradering()))),
+                        Mono.just(person.getDoedsfall().stream()
+                                .anyMatch(doed -> nonNull(doed.getDoedsdato())))))
+                .flatMap(harAdressebeskyttelseEllerDoed -> {
+                    if (isTrue(harAdressebeskyttelseEllerDoed.getT1())) {
+                        return oppdaterStatus(progress, "Avvik: CV kan ikke opprettes - person har adressebeskyttelse STRENGT FORTROLIG");
+                    } else if (isTrue(harAdressebeskyttelseEllerDoed.getT2())) {
+                        return oppdaterStatus(progress, "Avvik: CV kan ikke opprettes - person er død");
+                    } else {
+
+                        return oppdaterStatus(progress, getInfoVenter("Arbeidsplassen"))
+                                .then(Mono.just(bestilling.getArbeidsplassenCV()))
+                                .flatMap(arbeidsplassenCV -> {
+                                    var oppdatertOrdre = mapperFacade.map(arbeidsplassenCV, ArbeidsplassenCVDTO.class);
+                                    bestilling.setArbeidsplassenCV(oppdatertOrdre);
+                                    return transactionHelperService.persister(progress.getBestillingId(), bestilling)
+                                            .then(Mono.just(arbeidsplassenCV));
+                                })
+                                .flatMap(oppdatertOrdre -> Mono.just(CallIdUtil.generateCallId())
+                                        .flatMap(uuid -> arbeidsplassenCVConsumer.opprettPerson(dollyPerson.getIdent(), uuid)
+                                                .flatMap(response ->
+                                                        arbeidsplassenCVConsumer.godtaHjemmel(dollyPerson.getIdent(), uuid)
+                                                                .then(Mono.just(mapperFacade.map(oppdatertOrdre, PAMCVDTO.class))
+                                                                        .flatMap(request -> arbeidsplassenCVConsumer.oppdaterCV(dollyPerson.getIdent(),
+                                                                                request, uuid, logRetries(progress)))))
+
+                                                .map(status -> status.getStatus().is2xxSuccessful() ? "OK" :
+                                                        errorStatusDecoder.getErrorText(HttpStatus.valueOf(status.getStatus().value()),
+                                                                status.getFeilmelding()))
+
+                                                .flatMap(resultat -> oppdaterStatus(progress, resultat))));
+                    }
+                });
+    }
+
+    private Mono<PdlPerson.Person> getPerson(DollyPerson dollyPerson) {
+
+        return personServiceConsumer.getPdlPersoner(List.of(dollyPerson.getIdent()))
+                .filter(pdlPersonBolk -> nonNull(pdlPersonBolk.getData()))
+                .map(PdlPersonBolk::getData)
+                .map(PdlPersonBolk.Data::getHentPersonBolk)
+                .flatMap(Flux::fromIterable)
+                .filter(personBolk -> nonNull(personBolk.getPerson()))
+                .map(PdlPersonBolk.PersonBolk::getPerson)
+                .next()
+                .switchIfEmpty(Mono.just(new PdlPerson.Person()));
     }
 
     private Consumer<Retry.RetrySignal> logRetries(BestillingProgress progress) {

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/arbeidsplassencv/command/ArbeidsplassenPutCVCommand.java

@@ -54,7 +54,7 @@ public Mono<ArbeidsplassenCVStatusDTO> call() {
                         .uuid(uuid)
                         .build())
                 .doOnError(WebClientError.logTo(log))
-                .retryWhen(Retry.fixedDelay(10, ofSeconds(5))
+                .retryWhen(Retry.fixedDelay(15, ofSeconds(5))
                         .filter(throwable ->
                                 throwable instanceof WebClientResponseException.Forbidden forbidden &&
                                         (forbidden.getResponseBodyAsString().contains(FORBIDDEN_TEXT) ||