Fikset merge conflicts

apps/app-tilgang-analyse-service/src/main/java/no/nav/testnav/apps/apptilganganalyseservice/AppTilgangAnalyseServiceApplicationStarter.java

@@ -18,4 +18,4 @@ public class AppTilgangAnalyseServiceApplicationStarter {
  public static void main(String[] args) {
  SpringApplication.run(AppTilgangAnalyseServiceApplicationStarter.class, args);
  }
-}
+}

apps/dolly-backend/config.yml

@@ -36,6 +36,8 @@ spec:
  namespace: aap
  - application: testnav-helsepersonell-service
  cluster: dev-gcp
+ - application: statuspoll
+ namespace: navdig
  outbound:
  rules:
  - application: generer-navn-service

apps/dolly-backend/src/main/java/no/nav/dolly/DollyBackendApplicationStarter.java

@@ -9,4 +9,4 @@ public static void main(String[] args) {
 
  SpringApplication.run(DollyBackendApplicationStarter.class, args);
  }
-}
+}

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

@@ -1,6 +1,7 @@
 package no.nav.dolly.bestilling;
 
 import no.nav.dolly.util.CheckAliveUtil;
+import no.nav.testnav.libs.dto.status.v1.TestnavStatusResponse;
 import org.springframework.web.reactive.function.client.WebClient;
 
 import java.util.Map;
@@ -9,19 +10,17 @@
 public interface ConsumerStatus {
 
  String serviceUrl();
+
  String consumerName();
 
- default Map<String, Object> checkStatus(WebClient webClient) {
- final String TEAM_DOLLY = "Team Dolly";
+ default Map<String, TestnavStatusResponse> checkStatus(WebClient webClient) {
 
- var consumerStatus =  CheckAliveUtil.checkConsumerStatus(
+ var consumerStatus = CheckAliveUtil.checkConsumerStatus(
  serviceUrl() + "/internal/isAlive",
  serviceUrl() + "/internal/isReady",
  webClient);
 
- consumerStatus.put("team", TEAM_DOLLY);
-
- var statusMap = new ConcurrentHashMap<String, Object>();
+ var statusMap = new ConcurrentHashMap<String, TestnavStatusResponse>();
  statusMap.put(consumerName(), consumerStatus);
 
  try {

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/arenaforvalter/mapper/ArenaMappingStrategy.java

@@ -38,6 +38,13 @@ public void register(MapperFactory factory) {
  @Override
  public void mapAtoB(Arenadata arenadata, ArenaNyBruker arenaNyBruker, MappingContext context) {
 
+ if (isNull(arenaNyBruker.getKvalifiseringsgruppe())) {
+ arenaNyBruker.setKvalifiseringsgruppe(IKVAL);
+ }
+ if (isNull(arenaNyBruker.getAutomatiskInnsendingAvMeldekort())) {
+ arenaNyBruker.setAutomatiskInnsendingAvMeldekort(true);
+ }
+
  if (UTEN_SERVICEBEHOV.equals(arenadata.getArenaBrukertype())) {
  mapUtenServicebehov(arenadata, arenaNyBruker);
  } else if (!arenadata.getAap().isEmpty() || !arenadata.getAap115().isEmpty() || !arenadata.getDagpenger().isEmpty()) {
@@ -131,15 +138,11 @@ private void mapMedServicebehov(Arenadata arenadata, ArenaNyBruker arenaNyBruker
  }
 
  private void mapUtenServicebehov(Arenadata arenadata, ArenaNyBruker arenaNyBruker) {
- arenaNyBruker.setUtenServicebehov(new ArenaBrukerUtenServicebehov());
-
- arenaNyBruker.setKvalifiseringsgruppe(IKVAL);
- if (isNull(arenadata.getAutomatiskInnsendingAvMeldekort())) {
- arenaNyBruker.setAutomatiskInnsendingAvMeldekort(true);
- }
 
- if (nonNull(arenadata.getInaktiveringDato())) {
- arenaNyBruker.getUtenServicebehov().setStansDato(arenadata.getInaktiveringDato().toLocalDate());
- }
+ arenaNyBruker.setUtenServicebehov(ArenaBrukerUtenServicebehov.builder()
+ .stansDato(nonNull(arenadata.getInaktiveringDato()) ?
+ arenadata.getInaktiveringDato().toLocalDate() :
+ LocalDate.now())
+ .build());
  }
 }

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/arenaforvalter/service/ArenaBrukerService.java

@@ -6,6 +6,7 @@
 import no.nav.dolly.bestilling.arenaforvalter.ArenaUtils;
 import no.nav.dolly.bestilling.arenaforvalter.dto.ArenaVedtakOperasjoner;
 import no.nav.dolly.domain.resultset.arenaforvalter.ArenaBruker;
+import no.nav.dolly.domain.resultset.arenaforvalter.ArenaBrukerUtenServicebehov;
 import no.nav.dolly.domain.resultset.arenaforvalter.ArenaNyBruker;
 import no.nav.dolly.domain.resultset.arenaforvalter.ArenaNyeBrukere;
 import no.nav.dolly.domain.resultset.arenaforvalter.ArenaNyeBrukereResponse;
@@ -16,11 +17,14 @@
 import reactor.core.publisher.Mono;
 
 import java.time.LocalDate;
+import java.time.LocalDateTime;
 import java.util.List;
 import java.util.Objects;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
+import static java.util.Objects.isNull;
+import static java.util.Objects.nonNull;
 import static no.nav.dolly.bestilling.arenaforvalter.utils.ArenaStatusUtil.getMessage;
 import static no.nav.dolly.errorhandling.ErrorStatusDecoder.encodeStatus;
 
@@ -50,14 +54,20 @@ public Flux<String> sendBruker(Arenadata arenadata, ArenaVedtakOperasjoner arbei
  })
  .flatMap(arenaNyeBrukere -> {
 
- if (arenaNyeBrukere.getNyeBrukere().stream().anyMatch(ArenaNyBruker::hasServicebehov)) {
+ if (arenaNyeBrukere.getNyeBrukere().stream().anyMatch(ArenaNyBruker::hasServicebehov) ||
+ isNull(arbeidssoker.getRegistrertDato())) {
 
  arenaNyeBrukere.getNyeBrukere().stream()
  .findFirst()
  .ifPresent(nyBruker -> {
  if (!nyBruker.hasKvalifiseringsgruppe()) {
  nyBruker.setKvalifiseringsgruppe(arbeidssoker.getKvalifiseringsgruppe());
  }
+ if (nonNull(arenadata.getInaktiveringDato())) {
+ nyBruker.setUtenServicebehov(ArenaBrukerUtenServicebehov.builder()
+ .stansDato(toLocalDate(arenadata.getInaktiveringDato()))
+ .build());
+ }
  });
 
  return arenaForvalterConsumer.postArenaBruker(arenaNyeBrukere)
@@ -110,4 +120,9 @@ private Mono<String> getBrukerStatus(ArenaNyeBrukereResponse response) {
 
  .collect(Collectors.joining());
  }
+
+ private static LocalDate toLocalDate(LocalDateTime localDateTime) {
+
+ return nonNull(localDateTime) ? localDateTime.toLocalDate() : null;
+ }
 }

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/histark/HistarkConsumer.java

@@ -2,7 +2,6 @@
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.extern.slf4j.Slf4j;
-import no.nav.dolly.bestilling.ConsumerStatus;
 import no.nav.dolly.bestilling.histark.command.HistarkPostCommand;
 import no.nav.dolly.bestilling.histark.domain.HistarkRequest;
 import no.nav.dolly.bestilling.histark.domain.HistarkResponse;
@@ -22,7 +21,7 @@
 
 @Slf4j
 @Service
-public class HistarkConsumer implements ConsumerStatus {
+public class HistarkConsumer {
 
  private final WebClient webClient;
  private final TokenExchange tokenService;
@@ -52,16 +51,6 @@ public Flux<HistarkResponse> postHistark(HistarkRequest histarkRequest) {
  token.getTokenValue()).call());
  }
 
- @Override
- public String serviceUrl() {
- return serviceProperties.getUrl();
- }
-
- @Override
- public String consumerName() {
- return "testnav-histark-proxy";
- }
-
  private static String getNavCallId() {
  return format("%s %s", CONSUMER, UUID.randomUUID());
  }

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/inntektsmelding/InntektsmeldingConsumer.java

@@ -38,11 +38,7 @@ public InntektsmeldingConsumer(
  .build();
  }
 
- private static String getNavCallId() {
- return format("%s %s", CONSUMER, UUID.randomUUID());
- }
-
- @Timed(name = "providers", tags = {"operation", "inntektsmelding_opprett"})
+ @Timed(name = "providers", tags = { "operation", "inntektsmelding_opprett" })
  public Flux<InntektsmeldingResponse> postInntektsmelding(InntektsmeldingRequest inntekstsmelding) {
 
  var callId = getNavCallId();
@@ -63,4 +59,8 @@ public String consumerName() {
  return "testnav-inntektsmelding-service";
  }
 
+ private static String getNavCallId() {
+ return format("%s %s", CONSUMER, UUID.randomUUID());
+ }
+
 }

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/PensjonforvalterClient.java

@@ -126,16 +126,21 @@ public Flux<ClientFuture> gjenopprett(RsDollyUtvidetBestilling bestilling, Dolly
  .collectList()
  .map(this::getPersonData)
  .flatMapMany(Flux::collectList)
- .map(relasjoner -> Flux.concat(
- opprettPersoner(dollyPerson.getIdent(), tilgjengeligeMiljoer, relasjoner)
+ .doOnNext(persondata -> {
+ if (persondata.isEmpty()) {
+ log.warn("Persondata for {} gir tom response fra PDL", dollyPerson.getIdent());
+ }
+ })
+ .map(persondata -> Flux.concat(
+ opprettPersoner(dollyPerson.getIdent(), tilgjengeligeMiljoer, persondata)
  .map(response -> PENSJON_FORVALTER + decodeStatus(response, dollyPerson.getIdent())),
 
  lagreTpForhold(bestilling.getPensjonforvalter(), dollyPerson, bestilteMiljoer.get())
  .map(response -> TP_FORHOLD + decodeStatus(response, dollyPerson.getIdent())),
 
  lagreAlderspensjon(
  bestilling1.getPensjonforvalter(),
- relasjoner,
+ persondata,
  dollyPerson.getIdent(),
  bestilteMiljoer.get(),
  isOpprettEndre,
@@ -210,9 +215,9 @@ public void release(List<String> identer) {
  }
 
  private Flux<PensjonforvalterResponse> opprettPersoner(String hovedperson, Set<String> miljoer,
- List<PdlPersonBolk.PersonBolk> relasjoner) {
+ List<PdlPersonBolk.PersonBolk> personer) {
 
- return Flux.fromIterable(relasjoner)
+ return Flux.fromIterable(personer)
  .map(person -> mapperFacade.map(person, PensjonPersonRequest.class))
  .flatMap(request -> pensjonforvalterConsumer.opprettPerson(request, miljoer)
  .filter(response -> hovedperson.equals(request.getFnr())));

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/GetMiljoerCommand.java

@@ -46,6 +46,7 @@ public Mono<Set<String>> call() {
  .doOnError(WebClientFilter::logErrorMessage)
  .retryWhen(Retry.backoff(3, Duration.ofSeconds(5))
  .filter(WebClientFilter::is5xxException))
- .onErrorResume(throwable -> Mono.just(emptySet()));
+ .onErrorResume(throwable -> Mono.just(emptySet()))
+ .cache(Duration.ofHours(1));
  }
 }

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/mapper/PensjonAlderspensjonMappingStrategy.java

@@ -11,7 +11,9 @@
 import org.springframework.stereotype.Component;
 
 import java.time.LocalDate;
+import java.util.Collection;
 import java.util.List;
+import java.util.Objects;
 import java.util.concurrent.atomic.AtomicReference;
 
 import static java.util.Objects.isNull;
@@ -68,10 +70,30 @@ public void mapAtoB(PensjonData.Alderspensjon alderspensjon, AlderspensjonReques
  request.setMiljoer((List<String>) context.getProperty("miljoer"));
  request.setStatsborgerskap("NOR");
 
- var relasjoner = (List<PdlPersonBolk.PersonBolk>) context.getProperty("relasjoner");
+ var personer = (List<PdlPersonBolk.PersonBolk>) context.getProperty("relasjoner");
+ request.setSivilstand(personer.stream()
+ .filter(person -> hovedperson.equals(person.getIdent()))
+ .map(PdlPersonBolk.PersonBolk::getPerson)
+ .map(PdlPerson.Person::getSivilstand)
+ .flatMap(Collection::stream)
+ .map(PdlPerson.Sivilstand::getType)
+ .map(PensjonAlderspensjonMappingStrategy::mapSivilstand)
+ .filter(Objects::nonNull)
+ .findFirst()
+ .orElse(null));
+
+ request.setSivilstandDatoFom(personer.stream()
+ .filter(person -> hovedperson.equals(person.getIdent()))
+ .map(PdlPersonBolk.PersonBolk::getPerson)
+ .map(PdlPerson.Person::getSivilstand)
+ .flatMap(Collection::stream)
+ .map(PdlPerson.Sivilstand::getGyldigFraOgMed)
+ .filter(Objects::nonNull)
+ .findFirst()
+ .orElse(null));
 
  var partner = new AtomicReference<String>();
- relasjoner.stream()
+ personer.stream()
  .filter(person -> person.getIdent().equals(hovedperson))
  .forEach(personBolk -> personBolk.getPerson().getSivilstand().stream()
  .filter(PdlPerson.Sivilstand::isGift)
@@ -82,11 +104,11 @@ public void mapAtoB(PensjonData.Alderspensjon alderspensjon, AlderspensjonReques
  partner.set(sivilstand.getRelatertVedSivilstand());
  }));
 
- if (relasjoner.stream().anyMatch(person -> person.getIdent().equals(partner.get())) &&
+ if (personer.stream().anyMatch(person -> person.getIdent().equals(partner.get())) &&
  !alderspensjon.getRelasjoner().isEmpty()) {
 
  request.setRelasjonListe(mapperFacade.mapAsList(alderspensjon.getRelasjoner(), AlderspensjonRequest.SkjemaRelasjon.class));
- relasjoner.stream()
+ personer.stream()
  .filter(personBolk -> personBolk.getIdent().equals(partner.get()))
  .forEach(partnerPerson -> {
  request.getRelasjonListe().get(0).setFnr(partnerPerson.getIdent());
@@ -111,7 +133,7 @@ public void mapAtoB(PensjonData.Alderspensjon alderspensjon, AlderspensjonReques
  partnerPerson.getPerson().getForelderBarnRelasjon().stream()
  .filter(PdlPerson.ForelderBarnRelasjon::isBarn)
  .map(PdlPerson.ForelderBarnRelasjon::getRelatertPersonsIdent)
- .anyMatch(barnAvPartner -> relasjoner.stream()
+ .anyMatch(barnAvPartner -> personer.stream()
  .filter(person -> hovedperson.equals(person.getIdent()))
  .map(PdlPersonBolk.PersonBolk::getPerson)
  .anyMatch(person -> person.getForelderBarnRelasjon().stream()