diff --git a/behandlingskontroll/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandlingskontroll/impl/BehandlingskontrollTjeneste.java b/behandlingskontroll/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandlingskontroll/impl/BehandlingskontrollTjeneste.java index 52dff5203..72aa3a360 100644 --- a/behandlingskontroll/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandlingskontroll/impl/BehandlingskontrollTjeneste.java +++ b/behandlingskontroll/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandlingskontroll/impl/BehandlingskontrollTjeneste.java @@ -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. * diff --git a/behandlingslager/domene/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandlingslager/behandling/repository/EksternBehandlingRepository.java b/behandlingslager/domene/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandlingslager/behandling/repository/EksternBehandlingRepository.java index 963a6a90a..caef8f972 100644 --- a/behandlingslager/domene/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandlingslager/behandling/repository/EksternBehandlingRepository.java +++ b/behandlingslager/domene/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandlingslager/behandling/repository/EksternBehandlingRepository.java @@ -140,7 +140,7 @@ public void deaktivateTilkobling(long internId) { public EksternBehandling hentForSisteAktivertInternId(long internBehandlingId) { TypedQuery 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 hentOptionalFraInternId(long internBehandlingId) { diff --git a/domenetjenester/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandling/impl/BehandlingRevurderingTjeneste.java b/domenetjenester/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandling/impl/BehandlingRevurderingTjeneste.java index 54e1aba55..a834a555c 100644 --- a/domenetjenester/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandling/impl/BehandlingRevurderingTjeneste.java +++ b/domenetjenester/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandling/impl/BehandlingRevurderingTjeneste.java @@ -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; @@ -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)); diff --git a/domenetjenester/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandling/impl/BehandlingTjeneste.java b/domenetjenester/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandling/impl/BehandlingTjeneste.java index 6455a405f..300ae6ec7 100644 --- a/domenetjenester/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandling/impl/BehandlingTjeneste.java +++ b/domenetjenester/src/main/java/no/nav/foreldrepenger/tilbakekreving/behandling/impl/BehandlingTjeneste.java @@ -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; @@ -225,6 +226,8 @@ public Optional 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()); diff --git a/integrasjontjenester/datavarehus/src/main/java/no/nav/foreldrepenger/tilbakekreving/datavarehus/saksstatistikk/BehandlingTilstandTjeneste.java b/integrasjontjenester/datavarehus/src/main/java/no/nav/foreldrepenger/tilbakekreving/datavarehus/saksstatistikk/BehandlingTilstandTjeneste.java index 9bfb77bf4..044346388 100644 --- a/integrasjontjenester/datavarehus/src/main/java/no/nav/foreldrepenger/tilbakekreving/datavarehus/saksstatistikk/BehandlingTilstandTjeneste.java +++ b/integrasjontjenester/datavarehus/src/main/java/no/nav/foreldrepenger/tilbakekreving/datavarehus/saksstatistikk/BehandlingTilstandTjeneste.java @@ -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); @@ -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) { diff --git a/integrasjontjenester/datavarehus/src/main/java/no/nav/foreldrepenger/tilbakekreving/datavarehus/saksstatistikk/SakshendelserEventObserver.java b/integrasjontjenester/datavarehus/src/main/java/no/nav/foreldrepenger/tilbakekreving/datavarehus/saksstatistikk/SakshendelserEventObserver.java index 59481d6ed..0ea170e40 100644 --- a/integrasjontjenester/datavarehus/src/main/java/no/nav/foreldrepenger/tilbakekreving/datavarehus/saksstatistikk/SakshendelserEventObserver.java +++ b/integrasjontjenester/datavarehus/src/main/java/no/nav/foreldrepenger/tilbakekreving/datavarehus/saksstatistikk/SakshendelserEventObserver.java @@ -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) {