Skip to content

Commit

Permalink
Oppdatert pensjoninnsending, venter på svar #deploy-test-dolly-backend
Browse files Browse the repository at this point in the history
  • Loading branch information
@krharum
krharum committed Jan 15, 2024
1 parent 5ed4db9 commit e6267f2
Showing 1 changed file with 73 additions and 57 deletions.
130 changes: 73 additions & 57 deletions ...ackend/src/main/java/no/nav/dolly/bestilling/pensjonforvalter/PensjonforvalterClient.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,7 @@
import reactor.util.function.Tuple2;

import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Objects;
Expand Down Expand Up @@ -99,13 +100,13 @@ public static PensjonforvalterResponse mergePensjonforvalterResponses(List<Pensj

var status = new HashMap<String, PensjonforvalterResponse.Response>();
responser.forEach(respons -> respons.getStatus()
.forEach(detalj -> {
if (detalj.getResponse().isResponse2xx()) {
status.putIfAbsent(detalj.getMiljo(), detalj.getResponse());
} else {
status.put(detalj.getMiljo(), detalj.getResponse());
}
}));
.forEach(detalj -> {
if (detalj.getResponse().isResponse2xx()) {
status.putIfAbsent(detalj.getMiljo(), detalj.getResponse());
} else {
status.put(detalj.getMiljo(), detalj.getResponse());
}
}));

return PensjonforvalterResponse.builder()
.status(status.entrySet().stream()
Expand All @@ -129,8 +130,9 @@ public Flux<ClientFuture> gjenopprett(RsDollyUtvidetBestilling bestilling, Dolly
.collect(Collectors.toSet()));

var bestillingId = bestilling.getId();
var statusResultat = new ArrayList<String>();

return Flux.from(pensjonforvalterConsumer.getMiljoer())
return Flux.from(Flux.from(pensjonforvalterConsumer.getMiljoer())
.flatMap(tilgjengeligeMiljoer -> {
bestilteMiljoer.set(bestilteMiljoer.get().stream()
.filter(tilgjengeligeMiljoer::contains)
Expand All @@ -156,50 +158,66 @@ public Flux<ClientFuture> gjenopprett(RsDollyUtvidetBestilling bestilling, Dolly
log.warn("Persondata for {} gir tom response fra PDL", dollyPerson.getIdent());
}
})
.map(utvidetPersondata -> Flux.concat(
opprettPersoner(dollyPerson.getIdent(), tilgjengeligeMiljoer, utvidetPersondata.getT1())
.map(response -> PENSJON_FORVALTER + decodeStatus(response, dollyPerson.getIdent())),

lagreSamboer(dollyPerson.getIdent(), tilgjengeligeMiljoer)
.map(response -> SAMBOER_REGISTER + decodeStatus(response, dollyPerson.getIdent())),

lagreInntekt(bestilling1.getPensjonforvalter(), dollyPerson.getIdent(), bestilteMiljoer.get(),
progress.getIsTpsSyncEnv())
.map(response -> POPP_INNTEKTSREGISTER + decodeStatus(response, dollyPerson.getIdent())),

Flux.just(bestilling1)
.filter(bestilling2 -> nonNull(bestilling2.getPensjonforvalter()))
.map(RsDollyUtvidetBestilling::getPensjonforvalter)
.flatMap(pensjon -> Flux.merge(

lagreTpForhold(pensjon, dollyPerson.getIdent(), bestilteMiljoer.get())
.map(response -> TP_FORHOLD + decodeStatus(response, dollyPerson.getIdent())),

lagreAlderspensjon(
pensjon,
utvidetPersondata,
dollyPerson.getIdent(),
bestilteMiljoer.get(),
isOpprettEndre,
bestillingId,
progress.getIsTpsSyncEnv())
.map(response -> PEN_ALDERSPENSJON + decodeStatus(response, dollyPerson.getIdent())),

lagreUforetrygd(
pensjon,
utvidetPersondata.getT2(),
dollyPerson.getIdent(),
bestilteMiljoer.get(),
isOpprettEndre,
bestillingId,
progress.getIsTpsSyncEnv())
.map(response -> PEN_UFORETRYGD + decodeStatus(response, dollyPerson.getIdent())))))))

.flatMap(Flux::from)
.filter(StringUtils::isNotBlank)
.collect(Collectors.joining(SEP));
.flatMap(utvidetPersondata -> Flux.concat(
opprettPersoner(dollyPerson.getIdent(), tilgjengeligeMiljoer, utvidetPersondata.getT1())
.map(response -> PENSJON_FORVALTER + decodeStatus(response, dollyPerson.getIdent())),

lagreSamboer(dollyPerson.getIdent(), tilgjengeligeMiljoer)
.map(response -> SAMBOER_REGISTER + decodeStatus(response, dollyPerson.getIdent()))
)
.collectList()
.doOnNext(statusResultat::addAll)
.map(status -> Flux.just(bestilling1)
.filter(bestilling2 -> nonNull(bestilling2.getPensjonforvalter()))
.map(RsDollyUtvidetBestilling::getPensjonforvalter)
.flatMap(pensjon -> Flux.merge(

lagreInntekt(pensjon,
dollyPerson.getIdent(), bestilteMiljoer.get(),
progress.getIsTpsSyncEnv())
.map(response -> POPP_INNTEKTSREGISTER + decodeStatus(response, dollyPerson.getIdent())),

lagreTpForhold(pensjon, dollyPerson.getIdent(), bestilteMiljoer.get())
.map(response -> TP_FORHOLD + decodeStatus(response, dollyPerson.getIdent()))
)
.collectList()
.doOnNext(statusResultat::addAll)

.map(status2 -> Flux.just(pensjon)
.flatMap(pensjon2 -> Flux.merge(

lagreAlderspensjon(
pensjon2,
utvidetPersondata,
dollyPerson.getIdent(),
bestilteMiljoer.get(),
isOpprettEndre,
bestillingId,
progress.getIsTpsSyncEnv())
.map(response -> PEN_ALDERSPENSJON + decodeStatus(response, dollyPerson.getIdent())),

lagreUforetrygd(
pensjon2,
utvidetPersondata.getT2(),
dollyPerson.getIdent(),
bestilteMiljoer.get(),
isOpprettEndre,
bestillingId,
progress.getIsTpsSyncEnv())
.map(response -> PEN_UFORETRYGD + decodeStatus(response, dollyPerson.getIdent()))
)
.collectList()
.doOnNext(statusResultat::addAll)
))))));
})
.map(status -> futurePersist(dollyPerson, progress, status));
.flatMap(Flux::from)
.flatMap(Flux::from)
.flatMap(Flux::fromIterable)
.collectList()
.map(status -> statusResultat.stream()
.filter(StringUtils::isNotBlank)
.collect(Collectors.joining("$")))
.map(status2 -> futurePersist(dollyPerson, progress, status2)));
}

private static Mono<List<PdlPersonBolk.PersonBolk>> getPdlPerson(Flux<PdlPersonBolk.Data> persondata) {
Expand Down Expand Up @@ -455,7 +473,8 @@ private static Flux<PensjonforvalterResponse> getStatus(String miljoe, Integer s
}

@SuppressWarnings("java:S3740")
private void saveAPTransaksjonId(String ident, String miljoe, Long bestillingId, SystemTyper type, AtomicReference vedtak) {
private void saveAPTransaksjonId(String ident, String miljoe, Long bestillingId, SystemTyper
type, AtomicReference vedtak) {

log.info("Lagrer transaksjon for {} i {} ", ident, miljoe);

Expand All @@ -473,10 +492,6 @@ private void saveAPTransaksjonId(String ident, String miljoe, Long bestillingId,
private Flux<PensjonforvalterResponse> lagreInntekt(PensjonData pensjonData, String ident,
Set<String> miljoer, List<String> isTpsSyncEnv) {

if (isNull(pensjonData)) {
return Flux.empty();
}

return Flux.just(pensjonData)
.filter(PensjonData::hasInntekt)
.map(PensjonData::getInntekt)
Expand All @@ -496,7 +511,8 @@ private Flux<PensjonforvalterResponse> lagreInntekt(PensjonData pensjonData, Str
}));
}

private Mono<PensjonforvalterResponse> lagreTpForhold(PensjonData pensjonData, String ident, Set<String> miljoer) {
private Mono<PensjonforvalterResponse> lagreTpForhold(PensjonData pensjonData, String
ident, Set<String> miljoer) {

return Flux.just(pensjonData)
.filter(PensjonData::hasTp)
Expand Down

0 comments on commit e6267f2

Please sign in to comment.