Skip to content

Commit

Permalink
Enhance PdlApiConsumer with additional metadata fields (#3628)
Browse files Browse the repository at this point in the history 
Synkronisering på samtlige opplysningstyper
  • Loading branch information
@krharum
krharum authored Sep 20, 2024
1 parent 6b05b36 commit cb4dfc5
Show file tree
Hide file tree
Showing 4 changed files with 384 additions and 48 deletions.
103 changes: 58 additions & 45 deletions ...n-service/src/main/java/no/nav/testnav/apps/personservice/consumer/v1/PdlApiConsumer.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@
import no.nav.testnav.apps.personservice.config.Consumers;
import no.nav.testnav.apps.personservice.consumer.v1.command.GetPdlAktoerCommand;
import no.nav.testnav.apps.personservice.consumer.v1.command.GetPdlPersonCommand;
import no.nav.testnav.apps.personservice.consumer.v1.pdl.graphql.HentPerson;
import no.nav.testnav.apps.personservice.consumer.v1.pdl.graphql.MetadataDTO;
import no.nav.testnav.apps.personservice.consumer.v1.pdl.graphql.PdlAktoer;
import no.nav.testnav.apps.personservice.domain.Person;
Expand All @@ -19,14 +20,17 @@
import reactor.core.publisher.Mono;
import reactor.util.function.Tuple2;

import java.lang.reflect.InvocationTargetException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.List;
import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
import java.util.stream.Stream;

import static java.util.Collections.emptyList;
import static java.util.Collections.emptySet;
import static java.util.Objects.nonNull;
import static org.apache.commons.lang3.StringUtils.isNotBlank;

Expand Down Expand Up @@ -80,17 +84,41 @@ public Mono<Optional<Person>> getPerson(String ident) {
});
}

private boolean isNotPresent(PdlAktoer pdlAktoer) {
public Mono<Optional<PdlAktoer.AktoerIdent>> getAktoer(String ident) {

log.info("Henter ident {} fra PDL", ident);
return tokenExchange
.exchange(serverProperties)
.flatMap(token -> Mono.zip(new GetPdlAktoerCommand(webClient, PDL_URL, ident, token.getTokenValue()).call(),
new GetPdlAktoerCommand(webClient, PDL_Q1_URL, ident, token.getTokenValue()).call())
.map(tuple -> {
if (isNotPresent(tuple.getT1()) || isNotPresent(tuple.getT2())) {
return Optional.empty();
}
return Optional.of(tuple.getT1().getData().getHentIdenter().getIdenter().getFirst());
}));
}

public Mono<Boolean> isPerson(String ident, Set<String> opplysningId) {

return tokenExchange
.exchange(serverProperties)
.flatMap(token -> Mono.zip(new GetPdlAktoerCommand(webClient, PDL_Q1_URL, ident, token.getTokenValue()).call(),
new GetPdlAktoerCommand(webClient, PDL_URL, ident, token.getTokenValue()).call())
.map(tuple -> isPresent(ident, tuple, opplysningId)));
}

private static boolean isNotPresent(PdlAktoer pdlAktoer) {

return pdlAktoer.getErrors().stream().anyMatch(value -> value.getMessage().equals("Fant ikke person"));
}

private boolean isGruppe(PdlAktoer.AktoerIdent ident, String gruppe) {
private static boolean isGruppe(PdlAktoer.AktoerIdent ident, String gruppe) {

return isNotBlank(ident.getIdent()) && !ident.getHistorisk() && gruppe.equals(ident.getGruppe());
}

private boolean isPresent(String ident, Tuple2<PdlAktoer, PdlAktoer> pdlAktoer, Set<String> opplysningId) {
private static boolean isPresent(String ident, Tuple2<PdlAktoer, PdlAktoer> pdlAktoer, Set<String> opplysningId) {

var statusQ1 = isPresent(ident, pdlAktoer.getT1(), "q1", opplysningId);
var statusQ2 = isPresent(ident, pdlAktoer.getT2(), "q2", opplysningId);
Expand All @@ -99,67 +127,52 @@ private boolean isPresent(String ident, Tuple2<PdlAktoer, PdlAktoer> pdlAktoer,
return statusQ1 && statusQ2;
}

private boolean isPresent(String ident, PdlAktoer pdlAktoer, String miljoe, Set<String> opplysningId) {
private static boolean isPresent(String ident, PdlAktoer pdlAktoer, String miljoe, Set<String> opplysningId) {

var opplysningIdsFraPdl = getOpplysningIds(pdlAktoer.getData().getHentPerson());

var person = pdlAktoer.getData().getHentPerson();
log.info("Sjekker ident {} i miljø {}, med PDL opplysningId {}, sjekkes for mottatt opplysningId {}", ident, miljoe,
nonNull(person) ?
Stream.of(person.getNavn(), person.getFoedselsdato(), person.getKjoenn(), person.getFolkeregisterpersonstatus())
.flatMap(Collection::stream)
.map(MetadataDTO::getMetadata)
.map(MetadataDTO.Metadata::getOpplysningsId)
.collect(Collectors.joining(", ")) : null,
String.join(",",opplysningIdsFraPdl),
nonNull(opplysningId) ?
String.join(", ", opplysningId) :
null);

boolean resultat;

if (nonNull(opplysningId)) {

resultat = nonNull(person) &&
Stream.of(person.getNavn(), person.getFoedselsdato(), person.getKjoenn(), person.getFolkeregisterpersonstatus())
.flatMap(Collection::stream)
.map(MetadataDTO::getMetadata)
.map(MetadataDTO.Metadata::getOpplysningsId)
.anyMatch(opplysningId::contains);
return opplysningId.stream()
.anyMatch(opplysningIdsFraPdl::contains);

} else {

List<PdlAktoer.AktoerIdent> identer = nonNull(pdlAktoer) && nonNull(pdlAktoer.getData()) && nonNull(pdlAktoer.getData().getHentIdenter()) ?
List<PdlAktoer.AktoerIdent> identer = nonNull(pdlAktoer.getData().getHentIdenter()) ?
pdlAktoer.getData().getHentIdenter().getIdenter() : emptyList();

resultat = nonNull(pdlAktoer) &&
return
pdlAktoer.getErrors().stream().noneMatch(value -> value.getMessage().equals("Fant ikke person")) &&
identer.stream()
.filter(ident1 -> identer.stream().anyMatch(ident2 -> isGruppe(ident2, "AKTORID")))
.anyMatch(ident1 -> identer.stream().anyMatch(ident2 -> isGruppe(ident2, "FOLKEREGISTERIDENT")) ||
identer.stream().anyMatch(ident2 -> isGruppe(ident2, "NPID")));
}

return resultat;
}

public Mono<Optional<PdlAktoer.AktoerIdent>> getAktoer(String ident) {

log.info("Henter ident {} fra PDL", ident);
return tokenExchange
.exchange(serverProperties)
.flatMap(token -> Mono.zip(new GetPdlAktoerCommand(webClient, PDL_URL, ident, token.getTokenValue()).call(),
new GetPdlAktoerCommand(webClient, PDL_Q1_URL, ident, token.getTokenValue()).call())
.map(tuple -> {
if (isNotPresent(tuple.getT1()) || isNotPresent(tuple.getT2())) {
return Optional.empty();
}
return Optional.of(tuple.getT1().getData().getHentIdenter().getIdenter().get(0));
}));
}

public Mono<Boolean> isPerson(String ident, Set<String> opplysningId) {

return tokenExchange
.exchange(serverProperties)
.flatMap(token -> Mono.zip(new GetPdlAktoerCommand(webClient, PDL_Q1_URL, ident, token.getTokenValue()).call(),
new GetPdlAktoerCommand(webClient, PDL_URL, ident, token.getTokenValue()).call())
.map(tuple -> isPresent(ident, tuple, opplysningId)));
private static Set<String> getOpplysningIds(HentPerson hentPerson) {

return nonNull(hentPerson) ? Arrays.stream(hentPerson.getClass().getMethods())
.filter(method -> method.getName().contains("get"))
.filter(method -> method.getReturnType().equals(List.class))
.map(method -> {
try {
return (List<? extends MetadataDTO>) method.invoke(hentPerson);
} catch (IllegalAccessException | InvocationTargetException e) {
log.error("Feilet å lese verdi fra getter {} ", e.getMessage(), e);
return new ArrayList<MetadataDTO>();
}
})
.flatMap(Collection::stream)
.map(MetadataDTO::getMetadata)
.map(MetadataDTO.Metadata::getOpplysningsId)
.collect(Collectors.toSet()) : emptySet();
}
}
200 changes: 199 additions & 1 deletion ...e/src/main/java/no/nav/testnav/apps/personservice/consumer/v1/pdl/graphql/HentPerson.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,28 @@ public class HentPerson {
List<Bostedsadresse> bostedsadresse;
List<Folkeregisteridentifikator> folkeregisteridentifikator;
List<Folkeregisterpersonstatus> folkeregisterpersonstatus;
List<MetadataDTO> foedested;
List<MetadataDTO> doedsfall;
List<MetadataDTO> sivilstand;
List<MetadataDTO> oppholdsadresse;
List<MetadataDTO> kontaktadresse;
List<MetadataDTO> innflyttingTilNorge;
List<MetadataDTO> utflyttingFraNorge;
List<MetadataDTO> vergemaalEllerFremtidsfullmakt;
List<MetadataDTO> doedfoedtBarn;
List<MetadataDTO> adressebeskyttelse;
List<MetadataDTO> falskIdentitet;
List<MetadataDTO> utenlandskIdentifikasjonsnummer;
List<MetadataDTO> tilrettelagtKommunikasjon;
List<MetadataDTO> sikkerhetstiltak;
List<MetadataDTO> deltBosted;
List<MetadataDTO> forelderBarnRelasjon;
List<MetadataDTO> foreldreansvar;
List<MetadataDTO> kontaktinformasjonForDoedsbo;
List<MetadataDTO> navspersonidentifikator;
List<MetadataDTO> statsborgerskap;
List<MetadataDTO> opphold;
List<MetadataDTO> fullmakt;

public List<Navn> getNavn() {

Expand Down Expand Up @@ -54,7 +76,7 @@ public List<Folkeregisteridentifikator> getFolkeregisteridentifikator() {

public List<Bostedsadresse> getBostedsadresse() {

if(isNull(bostedsadresse)) {
if (isNull(bostedsadresse)) {
bostedsadresse = new ArrayList<>();
}
return bostedsadresse;
Expand All @@ -67,4 +89,180 @@ public List<Folkeregisterpersonstatus> getFolkeregisterpersonstatus() {
}
return folkeregisterpersonstatus;
}

public List<MetadataDTO> getFoedested() {

if (isNull(foedested)) {
foedested = new ArrayList<>();
}
return foedested;
}

public List<MetadataDTO> getDoedsfall() {

if (isNull(doedsfall)) {
doedsfall = new ArrayList<>();
}
return doedsfall;
}

public List<MetadataDTO> getVergemaalEllerFremtidsfullmakt() {

if (isNull(vergemaalEllerFremtidsfullmakt)) {
vergemaalEllerFremtidsfullmakt = new ArrayList<>();
}
return vergemaalEllerFremtidsfullmakt;
}

public List<MetadataDTO> getDoedfoedtBarn() {

if (isNull(doedfoedtBarn)) {
doedfoedtBarn = new ArrayList<>();
}
return doedfoedtBarn;
}

public List<MetadataDTO> getAdressebeskyttelse() {

if (isNull(adressebeskyttelse)) {
adressebeskyttelse = new ArrayList<>();
}
return adressebeskyttelse;
}

public List<MetadataDTO> getFalskIdentitet() {

if (isNull(falskIdentitet)) {
falskIdentitet = new ArrayList<>();
}
return falskIdentitet;
}

public List<MetadataDTO> getUtenlandskIdentifikasjonsnummer() {

if (isNull(utenlandskIdentifikasjonsnummer)) {
utenlandskIdentifikasjonsnummer = new ArrayList<>();
}
return utenlandskIdentifikasjonsnummer;
}

public List<MetadataDTO> getTilrettelagtKommunikasjon() {

if (isNull(tilrettelagtKommunikasjon)) {
tilrettelagtKommunikasjon = new ArrayList<>();
}
return tilrettelagtKommunikasjon;
}

public List<MetadataDTO> getSikkerhetstiltak() {

if (isNull(sikkerhetstiltak)) {
sikkerhetstiltak = new ArrayList<>();
}
return sikkerhetstiltak;
}

public List<MetadataDTO> getDeltBosted() {

if (isNull(deltBosted)) {
deltBosted = new ArrayList<>();
}
return deltBosted;
}

public List<MetadataDTO> getForelderBarnRelasjon() {

if (isNull(forelderBarnRelasjon)) {
forelderBarnRelasjon = new ArrayList<>();
}
return forelderBarnRelasjon;
}

public List<MetadataDTO> getForeldreansvar() {

if (isNull(foreldreansvar)) {
foreldreansvar = new ArrayList<>();
}
return foreldreansvar;
}

public List<MetadataDTO> getKontaktinformasjonForDoedsbo() {

if (isNull(kontaktinformasjonForDoedsbo)) {
kontaktinformasjonForDoedsbo = new ArrayList<>();
}
return kontaktinformasjonForDoedsbo;
}

public List<MetadataDTO> getNavspersonidentifikator() {

if (isNull(navspersonidentifikator)) {
navspersonidentifikator = new ArrayList<>();
}
return navspersonidentifikator;
}

public List<MetadataDTO> getSivilstand() {

if (isNull(sivilstand)) {
sivilstand = new ArrayList<>();
}
return sivilstand;
}

public List<MetadataDTO> getStatsborgerskap() {

if (isNull(statsborgerskap)) {
statsborgerskap = new ArrayList<>();
}
return statsborgerskap;
}

public List<MetadataDTO> getOppholdsadresse() {

if (isNull(oppholdsadresse)) {
oppholdsadresse = new ArrayList<>();
}
return oppholdsadresse;
}

public List<MetadataDTO> getKontaktadresse() {

if (isNull(kontaktadresse)) {
kontaktadresse = new ArrayList<>();
}
return kontaktadresse;
}

public List<MetadataDTO> getInnflyttingTilNorge() {

if (isNull(innflyttingTilNorge)) {
innflyttingTilNorge = new ArrayList<>();
}
return innflyttingTilNorge;
}

public List<MetadataDTO> getUtflyttingFraNorge() {

if (isNull(utflyttingFraNorge)) {
utflyttingFraNorge = new ArrayList<>();
}
return utflyttingFraNorge;
}

public List<MetadataDTO> getOpphold() {

if (isNull(opphold)) {
opphold = new ArrayList<>();
}
return opphold;
}

public List<MetadataDTO> getFullmakt() {

if (isNull(fullmakt)) {
fullmakt = new ArrayList<>();
}
return fullmakt;
}
}
Loading

0 comments on commit cb4dfc5

Please sign in to comment.