Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Tilpasning til at ekstern behandling forutsettes - men opprettes førs… #2834

Merged
merged 1 commit into from
Jun 17, 2024
Merged

Tilpasning til at ekstern behandling forutsettes - men opprettes førs… #2834

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
4 changes: 4 additions & 0 deletions ...v/foreldrepenger/tilbakekreving/behandlingskontroll/impl/BehandlingskontrollTjeneste.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -396,6 +396,10 @@ public void avsluttBehandling(BehandlingskontrollKontekst kontekst) {

}

public void publiserBehandlingStatusEtterOpprettet(BehandlingskontrollKontekst kontekst, Behandling behandling) {
eventPubliserer.fireEvent(kontekst, null, behandling.getStatus());
}

/**
* Setter behandlingen på vent.
*
Expand Down
2 changes: 1 addition & 1 deletion ...er/tilbakekreving/behandlingslager/behandling/repository/EksternBehandlingRepository.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -140,7 +140,7 @@ public void deaktivateTilkobling(long internId) {
public EksternBehandling hentForSisteAktivertInternId(long internBehandlingId) {
TypedQuery<EksternBehandling> query = entityManager.createQuery("from EksternBehandling where internId=:internId order by opprettetTidspunkt desc", EksternBehandling.class);
query.setParameter(INTERN_ID, internBehandlingId);
return query.getResultList().get(0);
return query.getResultList().stream().findFirst().orElse(null);
}

public Optional<EksternBehandling> hentOptionalFraInternId(long internBehandlingId) {
Expand Down
3 changes: 3 additions & 0 deletions ...a/no/nav/foreldrepenger/tilbakekreving/behandling/impl/BehandlingRevurderingTjeneste.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@

import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject;

import no.nav.foreldrepenger.tilbakekreving.behandlingskontroll.impl.BehandlingskontrollTjeneste;
import no.nav.foreldrepenger.tilbakekreving.behandlingslager.aktør.OrganisasjonsEnhet;
import no.nav.foreldrepenger.tilbakekreving.behandlingslager.behandling.Behandling;
Expand Down Expand Up @@ -106,6 +107,8 @@ private Behandling opprettManuellRevurdering(Fagsak fagsak, BehandlingÅrsakType

opprettRelasjonMedEksternBehandling(henvisning, revurdering, eksternUuid);

behandlingskontrollTjeneste.publiserBehandlingStatusEtterOpprettet(kontekst, revurdering);

// revurdering skal starte med Fakta om feilutbetaling
behandlingskontrollTjeneste.lagreAksjonspunkterFunnet(kontekst, BehandlingStegType.FAKTA_FEILUTBETALING, List.of(AksjonspunktDefinisjon.AVKLART_FAKTA_FEILUTBETALING));

Expand Down
9 changes: 6 additions & 3 deletions ...rc/main/java/no/nav/foreldrepenger/tilbakekreving/behandling/impl/BehandlingTjeneste.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,12 +6,13 @@
import java.util.Optional;
import java.util.UUID;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject;
import jakarta.transaction.Transactional;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import no.nav.foreldrepenger.tilbakekreving.behandling.BehandlingFeil;
import no.nav.foreldrepenger.tilbakekreving.behandlingskontroll.BehandlingskontrollProvider;
import no.nav.foreldrepenger.tilbakekreving.behandlingskontroll.impl.BehandlingskontrollAsynkTjeneste;
Expand Down Expand Up @@ -225,6 +226,8 @@ public Optional<BehandlingVedtak> hentBehandlingvedtakForBehandlingId(long behan
EksternBehandling eksternBehandling = new EksternBehandling(behandling, henvisning, eksternUuid);
eksternBehandlingRepository.lagre(eksternBehandling);

behandlingskontrollTjeneste.publiserBehandlingStatusEtterOpprettet(kontekst, behandling);

historikkinnslagTjeneste.opprettHistorikkinnslagForOpprettetBehandling(behandling); // FIXME: sjekk om journalpostId skal hentes ///

hentVergeInformasjonFraFpsak(fagsakYtelseType, behandling.getId());
Expand Down
11 changes: 6 additions & 5 deletions .../foreldrepenger/tilbakekreving/datavarehus/saksstatistikk/BehandlingTilstandTjeneste.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,10 @@ public BehandlingTilstand hentBehandlingensTilstand(Behandling behandling) {
}

public BehandlingTilstand hentBehandlingensTilstand(Behandling behandling, Fagsystem fagsystem) {
EksternBehandling eksternBehandling = getEksternBehandling(behandling.getId());
var eksternBehandling = getEksternBehandling(behandling.getId());
if (eksternBehandling == null) {
return null;
}
BehandlingResultatType behandlingResultatType = behandlingresultatRepository.hent(behandling)
.map(Behandlingsresultat::getBehandlingResultatType)
.orElse(BehandlingResultatType.IKKE_FASTSATT);
Expand Down Expand Up @@ -116,13 +119,11 @@ public BehandlingTilstand hentBehandlingensTilstand(Behandling behandling, Fagsy
}

private EksternBehandling getEksternBehandling(long behandlingId) {
EksternBehandling eksternBehandling;
if (eksternBehandlingRepository.finnesAktivtEksternBehandling(behandlingId)) {
eksternBehandling = eksternBehandlingRepository.hentFraInternId(behandlingId);
return eksternBehandlingRepository.hentFraInternId(behandlingId);
} else {
eksternBehandling = eksternBehandlingRepository.hentForSisteAktivertInternId(behandlingId);
return eksternBehandlingRepository.hentForSisteAktivertInternId(behandlingId);
}
return eksternBehandling;
}

private static OffsetDateTime tilOffsetDateTime(LocalDateTime tidspunkt) {
Expand Down
6 changes: 4 additions & 2 deletions .../foreldrepenger/tilbakekreving/datavarehus/saksstatistikk/SakshendelserEventObserver.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -53,8 +53,10 @@ public void observerEndretAnsvarligSaksbehandlerEvent(@Observes BehandlingSaksbe
}

private void klargjørSendingAvBehandlingensTilstand(long behandlingId) {
BehandlingTilstand tilstand = behandlingTilstandTjeneste.hentBehandlingensTilstand(behandlingId);
opprettProsessTask(behandlingId, tilstand);
var tilstand = behandlingTilstandTjeneste.hentBehandlingensTilstand(behandlingId);
if (tilstand != null) {
opprettProsessTask(behandlingId, tilstand);
}
}

private void opprettProsessTask(long behandlingId, BehandlingTilstand behandlingTilstand) {
Expand Down