Skip to content

Commit

Permalink
Merge branch 'master' into feature/TFP-5859-relatert-til-fagsystem
Browse files Browse the repository at this point in the history
  • Loading branch information
jolarsen authored Oct 30, 2024
2 parents 838f175 + 806ee6a commit ca084e8
Show file tree
Hide file tree
Showing 28 changed files with 24 additions and 2,749 deletions.
Original file line number Diff line number Diff line change
@@ -1,8 +1,6 @@
package no.nav.foreldrepenger.datavarehus.domene;

import java.util.List;
import java.util.Objects;
import java.util.Optional;

import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject;
Expand All @@ -23,44 +21,11 @@ public DatavarehusRepository( EntityManager entityManager) {
this.entityManager = entityManager;
}

private static Optional<VedtakUtbetalingDvh> optionalFirst(List<VedtakUtbetalingDvh> liste) {
return liste.isEmpty() ? Optional.empty() : Optional.of(liste.get(0));
}

public long lagre(BehandlingDvh behandlingDvh) {
entityManager.persist(behandlingDvh);
return behandlingDvh.getId();
}

public long lagre(VedtakUtbetalingDvh vedtakUtbetalingDvh) {
entityManager.persist(vedtakUtbetalingDvh);
return vedtakUtbetalingDvh.getId();
}

public long oppdater(Long eksisterendeBehandlingId, Long eksisterendeVedtakId, String nyVedtakXml) {
var eksisterende = finn(eksisterendeBehandlingId, eksisterendeVedtakId);
if (eksisterende.isPresent()) {
return
oppdater(eksisterende.get(), nyVedtakXml);
}
throw new IllegalStateException(String.format("Finner ikke eksiterende dvh vedtak utbetaling for behandling %s og vedtak %s", eksisterendeBehandlingId, eksisterendeVedtakId));
}

public long oppdater(VedtakUtbetalingDvh vedtakUtbetalingDvh, String nyVedtakXml) {
vedtakUtbetalingDvh.setXmlClob(nyVedtakXml);
vedtakUtbetalingDvh.setTransTid();
var merge = entityManager.merge(vedtakUtbetalingDvh);
return merge.getId();
}

public Optional<VedtakUtbetalingDvh> finn(Long behandlingId, Long vedtakId) {
var query = entityManager.createQuery("from VedtakUtbetalingDvh where behandlingId = :behandlingId " +
"AND vedtakId = :vedtakId order by id", VedtakUtbetalingDvh.class);
query.setParameter("behandlingId", behandlingId);
query.setParameter("vedtakId", vedtakId);
return optionalFirst(query.getResultList());
}

public long lagre(KlageFormkravDvh formkrav) {
entityManager.persist(formkrav);
return formkrav.getId();
Expand Down

This file was deleted.

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,5 @@ public interface DatavarehusTjeneste {

void lagreNedBehandling(Behandling behandling, BehandlingVedtak vedtak);

void opprettOgLagreVedtakXml(Long behandlingId);

void oppdaterHvisKlageEllerAnke(Long behandlingId, Collection<Aksjonspunkt> aksjonspunkter);
}
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@

import no.nav.foreldrepenger.behandling.Skjæringstidspunkt;
import no.nav.foreldrepenger.behandlingslager.behandling.Behandling;
import no.nav.foreldrepenger.behandlingslager.behandling.BehandlingStatus;
import no.nav.foreldrepenger.behandlingslager.behandling.BehandlingType;
import no.nav.foreldrepenger.behandlingslager.behandling.Behandlingsresultat;
import no.nav.foreldrepenger.behandlingslager.behandling.BehandlingsresultatRepository;
Expand All @@ -32,7 +31,6 @@
import no.nav.foreldrepenger.behandlingslager.behandling.beregning.BeregningsresultatEntitet;
import no.nav.foreldrepenger.behandlingslager.behandling.beregning.BeregningsresultatPeriode;
import no.nav.foreldrepenger.behandlingslager.behandling.beregning.BeregningsresultatRepository;
import no.nav.foreldrepenger.behandlingslager.behandling.familiehendelse.FamilieHendelseEntitet;
import no.nav.foreldrepenger.behandlingslager.behandling.familiehendelse.FamilieHendelseGrunnlagEntitet;
import no.nav.foreldrepenger.behandlingslager.behandling.familiehendelse.FamilieHendelseRepository;
import no.nav.foreldrepenger.behandlingslager.behandling.familiehendelse.FamilieHendelseType;
Expand Down Expand Up @@ -62,7 +60,6 @@
import no.nav.foreldrepenger.behandlingslager.fagsak.FagsakEgenskapRepository;
import no.nav.foreldrepenger.behandlingslager.fagsak.FagsakYtelseType;
import no.nav.foreldrepenger.datavarehus.domene.DatavarehusRepository;
import no.nav.foreldrepenger.datavarehus.xml.DvhVedtakXmlTjeneste;
import no.nav.foreldrepenger.skjæringstidspunkt.SkjæringstidspunktTjeneste;

@ApplicationScoped
Expand All @@ -84,7 +81,6 @@ public class DatavarehusTjenesteImpl implements DatavarehusTjeneste {
private KlageRepository klageRepository;
private MottatteDokumentRepository mottatteDokumentRepository;
private AnkeRepository ankeRepository;
private DvhVedtakXmlTjeneste dvhVedtakXmlTjeneste;
private SkjæringstidspunktTjeneste skjæringstidspunktTjeneste;
private BeregningsresultatRepository beregningsresultatRepository;
private YtelsesFordelingRepository ytelsesFordelingRepository;
Expand All @@ -98,7 +94,6 @@ public DatavarehusTjenesteImpl(BehandlingRepositoryProvider repositoryProvider,
AnkeRepository ankeRepository,
KlageRepository klageRepository,
MottatteDokumentRepository mottatteDokumentRepository,
DvhVedtakXmlTjeneste dvhVedtakXmlTjeneste,
SkjæringstidspunktTjeneste skjæringstidspunktTjeneste,
SvangerskapspengerRepository svangerskapspengerRepository) {
this.datavarehusRepository = datavarehusRepository;
Expand All @@ -110,7 +105,6 @@ public DatavarehusTjenesteImpl(BehandlingRepositoryProvider repositoryProvider,
this.klageRepository = klageRepository;
this.mottatteDokumentRepository = mottatteDokumentRepository;
this.ankeRepository = ankeRepository;
this.dvhVedtakXmlTjeneste = dvhVedtakXmlTjeneste;
this.skjæringstidspunktTjeneste = skjæringstidspunktTjeneste;
this.fagsakEgenskapRepository = fagsakEgenskapRepository;
this.svangerskapspengerRepository = svangerskapspengerRepository;
Expand Down Expand Up @@ -251,22 +245,6 @@ private LocalDate finnUtbetaltDato(Behandling behandling, BehandlingVedtak vedta
}
}

@Override
public void opprettOgLagreVedtakXml(Long behandlingId) {
var behandlingVedtakOpt = behandlingVedtakRepository.hentForBehandlingHvisEksisterer(behandlingId);
var behandling = behandlingRepository.hentBehandling(behandlingId);
if (behandlingVedtakOpt.isPresent()) {
var vedtakXml = dvhVedtakXmlTjeneste.opprettDvhVedtakXml(behandlingId);
var hendelseType = familieGrunnlagRepository.hentAggregatHvisEksisterer(behandling.getId())
.map(FamilieHendelseGrunnlagEntitet::getGjeldendeVersjon)
.map(FamilieHendelseEntitet::getType)
.orElse(FamilieHendelseType.UDEFINERT);
var vedtakUtbetalingDvh = VedtakUtbetalingDvhMapper.map(vedtakXml, behandling, behandlingVedtakOpt.get(), hendelseType);
datavarehusRepository.lagre(vedtakUtbetalingDvh);
}
}


private void lagreKlageFormkrav(KlageFormkravEntitet klageFormkrav) {
var klageFormkravDvh = KlageFormkravDvhMapper.map(klageFormkrav);
datavarehusRepository.lagre(klageFormkravDvh);
Expand Down
Loading

0 comments on commit ca084e8

Please sign in to comment.