diff --git a/pom.xml b/pom.xml index 77550849..fb424b83 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ no.nav.foreldrepenger.felles fp-bom - 3.5.2 + 3.6.1 no.nav.familie.inntektsmelding @@ -18,9 +18,9 @@ ft-inntektsmelding navikt_ft-inntektsmelding - 7.3.4 - 5.0.20 - 9.1.22 + 7.4.2 + 5.0.21 + 9.2.0 @@ -28,7 +28,7 @@ no.nav.foreldrepenger.felles fp-bom - 3.5.2 + 3.6.1 import pom diff --git "a/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/Foresp\303\270rselBehandlingTjenesteImpl.java" "b/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/Foresp\303\270rselBehandlingTjenesteImpl.java" index 024d8b7f..575b2013 100644 --- "a/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/Foresp\303\270rselBehandlingTjenesteImpl.java" +++ "b/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/Foresp\303\270rselBehandlingTjenesteImpl.java" @@ -155,7 +155,6 @@ class ForespørselBehandlingTjenesteImpl implements ForespørselBehandlingTjenes } if (!taskGruppe.getTasks().isEmpty()) { - taskGruppe.setCallIdFraEksisterende(); prosessTaskTjeneste.lagre(taskGruppe); } else { LOG.info("Ingen oppdatering er nødvendig for saksnr: {}", fagsakSaksnummer); diff --git "a/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/task/H\303\245ndterRekkef\303\270lgeAvForesp\303\270rselTasks.java" "b/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/task/H\303\245ndterRekkef\303\270lgeAvForesp\303\270rselTasks.java" index 0abc3031..93cb2d73 100644 --- "a/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/task/H\303\245ndterRekkef\303\270lgeAvForesp\303\270rselTasks.java" +++ "b/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/task/H\303\245ndterRekkef\303\270lgeAvForesp\303\270rselTasks.java" @@ -4,25 +4,30 @@ import java.util.List; import java.util.Objects; import java.util.Optional; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; +import java.util.Set; import jakarta.enterprise.context.ApplicationScoped; - import jakarta.inject.Inject; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + import no.nav.vedtak.felles.prosesstask.api.ProsessTaskData; import no.nav.vedtak.felles.prosesstask.api.ProsessTaskGruppe; import no.nav.vedtak.felles.prosesstask.api.ProsessTaskLifecycleObserver; import no.nav.vedtak.felles.prosesstask.api.ProsessTaskStatus; import no.nav.vedtak.felles.prosesstask.api.ProsessTaskVeto; +import no.nav.vedtak.felles.prosesstask.api.TaskType; import no.nav.vedtak.felles.prosesstask.impl.ProsessTaskRepository; @ApplicationScoped public class HåndterRekkefølgeAvForespørselTasks implements ProsessTaskLifecycleObserver { - private static final Logger log = LoggerFactory.getLogger(HåndterRekkefølgeAvForespørselTasks.class); + private static final Logger LOG = LoggerFactory.getLogger(HåndterRekkefølgeAvForespørselTasks.class); + + private static final TaskType OPPRETT = TaskType.forProsessTask(OpprettForespørselTask.class); + + private static final Set BLOKKERENDE = Set.of(OPPRETT, TaskType.forProsessTask(SettForespørselTilUtgåttTask.class)); private ProsessTaskRepository prosessTaskRepository; @@ -38,25 +43,25 @@ public class HåndterRekkefølgeAvForespørselTasks implements ProsessTaskLifecy @Override public ProsessTaskVeto vetoKjøring(ProsessTaskData prosessTaskData) { - if (prosessTaskData.getTaskType().equals(OpprettForespørselTask.TASKTYPE)) { - String fagsakSaksnummer = prosessTaskData.getSaksnummer(); + if (prosessTaskData.taskType().equals(OPPRETT)) { + var fagsakSaksnummer = prosessTaskData.getSaksnummer(); if (fagsakSaksnummer == null || fagsakSaksnummer.isBlank()) { - throw new IllegalArgumentException("Task av type " + OpprettForespørselTask.TASKTYPE + " mangler saksnummer"); + throw new IllegalArgumentException("Task av type " + OPPRETT.value() + " mangler saksnummer"); } //TODO bytt til en mer spesifikk query når vi er over på k9-prosesstask Optional blokkerendeTask = prosessTaskRepository.finnAlle(List.of(ProsessTaskStatus.KLAR)) .stream() - .filter(task -> List.of(OpprettForespørselTask.TASKTYPE, SettForespørselTilUtgåttTask.TASKTYPE).contains(task.getTaskType())) + .filter(task -> BLOKKERENDE.contains(task.taskType())) .filter(task -> Objects.equals(task.getSaksnummer(), fagsakSaksnummer)) .filter(task -> !Objects.equals(task.getGruppe(), prosessTaskData.getGruppe())) .filter(task -> task.getOpprettetTid().isBefore(prosessTaskData.getOpprettetTid())) .max(Comparator.comparing(ProsessTaskData::getOpprettetTid)); if (blokkerendeTask.isPresent()) { - log.info("Vetoer kjøring av prosesstask[{}] av type[{}] for fagsak [{}], er blokkert av prosesstask[{}] for samme fagsak.", - prosessTaskData.getId(), prosessTaskData.getTaskType(), fagsakSaksnummer, blokkerendeTask.get().getId()); + LOG.info("Vetoer kjøring av prosesstask[{}] av {} for fagsak [{}], er blokkert av prosesstask[{}] for samme fagsak.", + prosessTaskData.getId(), prosessTaskData.taskType(), fagsakSaksnummer, blokkerendeTask.get().getId()); return new ProsessTaskVeto(true, prosessTaskData.getId(), blokkerendeTask.get().getId(), "Må vente på annen task for samme fagsak som ble opprettet før denne."); diff --git "a/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/task/OpprettForesp\303\270rselTask.java" "b/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/task/OpprettForesp\303\270rselTask.java" index c1816d71..065ce096 100644 --- "a/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/task/OpprettForesp\303\270rselTask.java" +++ "b/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/task/OpprettForesp\303\270rselTask.java" @@ -23,13 +23,11 @@ import no.nav.vedtak.felles.prosesstask.api.ProsessTaskHandler; @ApplicationScoped -@ProsessTask(value = OpprettForespørselTask.TASKTYPE) +@ProsessTask("forespørsel.opprett") public class OpprettForespørselTask implements ProsessTaskHandler { - public static final String TASKTYPE = "forespørsel.opprett"; - private static final Logger log = LoggerFactory.getLogger(OpprettForespørselTask.class); + private static final Logger LOG = LoggerFactory.getLogger(OpprettForespørselTask.class); public static final String YTELSETYPE = "ytelsetype"; - public static final String AKTØR_ID = "aktoerId"; public static final String ORGNR = "orgnr"; public static final String STP = "skjaeringstidspunkt"; @@ -47,7 +45,7 @@ public class OpprettForespørselTask implements ProsessTaskHandler { @Override public void doTask(ProsessTaskData prosessTaskData) { Ytelsetype ytelsetype = Ytelsetype.valueOf(prosessTaskData.getPropertyValue(YTELSETYPE)); - AktørIdEntitet aktørId = new AktørIdEntitet(prosessTaskData.getPropertyValue(AKTØR_ID)); + AktørIdEntitet aktørId = new AktørIdEntitet(prosessTaskData.getAktørId()); SaksnummerDto fagsakSaksnummer = new SaksnummerDto(prosessTaskData.getSaksnummer()); OrganisasjonsnummerDto organisasjonsnummer = new OrganisasjonsnummerDto(prosessTaskData.getPropertyValue(ORGNR)); LocalDate skjæringstidspunkt = LocalDate.parse(prosessTaskData.getPropertyValue(STP)); @@ -55,7 +53,7 @@ public void doTask(ProsessTaskData prosessTaskData) { List eksisterendeForespørsler = forespørselBehandlingTjeneste.hentForespørslerForFagsak(fagsakSaksnummer, organisasjonsnummer, skjæringstidspunkt); if (eksisterendeForespørsler.stream().anyMatch(eksisterende -> !eksisterende.getStatus().equals(ForespørselStatus.UTGÅTT))) { - log.info("Forespørsel finnes allerede, orgnr: {}, stp: {}, saksnr: {}, ytelse: {}", + LOG.info("Forespørsel finnes allerede, orgnr: {}, stp: {}, saksnr: {}, ytelse: {}", organisasjonsnummer.orgnr(), skjæringstidspunkt, fagsakSaksnummer.saksnr(), ytelsetype); return; } @@ -74,7 +72,7 @@ public static ProsessTaskData lagTaskData(Ytelsetype ytelsetype, LocalDate skjæringstidspunkt) { var taskdata = ProsessTaskData.forProsessTask(OpprettForespørselTask.class); taskdata.setProperty(YTELSETYPE, ytelsetype.name()); - taskdata.setProperty(AKTØR_ID, aktørId.getAktørId()); + taskdata.setAktørId(aktørId.getAktørId()); taskdata.setSaksnummer(fagsakSaksnummer.saksnr()); taskdata.setProperty(ORGNR, organisasjon.orgnr()); taskdata.setProperty(STP, skjæringstidspunkt.toString()); diff --git "a/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/task/SettForesp\303\270rselTilUtg\303\245ttTask.java" "b/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/task/SettForesp\303\270rselTilUtg\303\245ttTask.java" index 2cce42e1..fb472711 100644 --- "a/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/task/SettForesp\303\270rselTilUtg\303\245ttTask.java" +++ "b/src/main/java/no/nav/familie/inntektsmelding/foresp\303\270rsel/tjenester/task/SettForesp\303\270rselTilUtg\303\245ttTask.java" @@ -18,10 +18,9 @@ import no.nav.vedtak.felles.prosesstask.api.ProsessTaskHandler; @ApplicationScoped -@ProsessTask(value = SettForespørselTilUtgåttTask.TASKTYPE) +@ProsessTask("forespørsel.utgått") public class SettForespørselTilUtgåttTask implements ProsessTaskHandler { - public static final String TASKTYPE = "forespørsel.utgått"; - private static final Logger log = LoggerFactory.getLogger(SettForespørselTilUtgåttTask.class); + private static final Logger LOG = LoggerFactory.getLogger(SettForespørselTilUtgåttTask.class); public static final String FORESPØRSEL_UUID = "forespoerselUuid"; @@ -42,13 +41,13 @@ public void doTask(ProsessTaskData prosessTaskData) { Optional opt = forespørselBehandlingTjeneste.hentForespørsel(UUID.fromString(forespørselUuid)); if (opt.isEmpty()) { - log.warn("Fant ikke forespørsel med uuid {}", forespørselUuid); + LOG.warn("Fant ikke forespørsel med uuid {}", forespørselUuid); return; } ForespørselEntitet forespørsel = opt.get(); if (forespørsel.getStatus() == ForespørselStatus.UTGÅTT) { - log.info("Forespørsel med uuid {} har allerede status utgått", forespørselUuid); + LOG.info("Forespørsel med uuid {} har allerede status utgått", forespørselUuid); return; } diff --git a/src/main/java/no/nav/familie/inntektsmelding/imdialog/tjenester/InntektsmeldingTjeneste.java b/src/main/java/no/nav/familie/inntektsmelding/imdialog/tjenester/InntektsmeldingTjeneste.java index 8304a843..9f87bbba 100644 --- a/src/main/java/no/nav/familie/inntektsmelding/imdialog/tjenester/InntektsmeldingTjeneste.java +++ b/src/main/java/no/nav/familie/inntektsmelding/imdialog/tjenester/InntektsmeldingTjeneste.java @@ -101,7 +101,6 @@ private void opprettTaskForSendTilJoark(Long imId, String fagsystemSaksnummer) { var task = ProsessTaskData.forProsessTask(SendTilJoarkTask.class); task.setSaksnummer(fagsystemSaksnummer); task.setProperty(SendTilJoarkTask.KEY_INNTEKTSMELDING_ID, imId.toString()); - task.setCallIdFraEksisterende(); prosessTaskTjeneste.lagre(task); LOG.info("Opprettet task for oversending til joark"); } diff --git a/src/main/java/no/nav/familie/inntektsmelding/overstyring/InntektsmeldingOverstyringTjeneste.java b/src/main/java/no/nav/familie/inntektsmelding/overstyring/InntektsmeldingOverstyringTjeneste.java index 0eb2a560..03be2c68 100644 --- a/src/main/java/no/nav/familie/inntektsmelding/overstyring/InntektsmeldingOverstyringTjeneste.java +++ b/src/main/java/no/nav/familie/inntektsmelding/overstyring/InntektsmeldingOverstyringTjeneste.java @@ -43,7 +43,6 @@ private void opprettTaskForSendTilJoark(Long imId, SaksnummerDto fagsystemSaksnu var task = ProsessTaskData.forProsessTask(SendTilJoarkTask.class); task.setSaksnummer(fagsystemSaksnummer.saksnr()); task.setProperty(SendTilJoarkTask.KEY_INNTEKTSMELDING_ID, imId.toString()); - task.setCallIdFraEksisterende(); prosessTaskTjeneste.lagre(task); LOG.info("Opprettet task for oversending til joark"); } diff --git a/src/main/java/no/nav/familie/inntektsmelding/server/exceptions/JsonMappingExceptionMapper.java b/src/main/java/no/nav/familie/inntektsmelding/server/exceptions/JsonMappingExceptionMapper.java index 8ee99883..8124f4b3 100644 --- a/src/main/java/no/nav/familie/inntektsmelding/server/exceptions/JsonMappingExceptionMapper.java +++ b/src/main/java/no/nav/familie/inntektsmelding/server/exceptions/JsonMappingExceptionMapper.java @@ -11,12 +11,12 @@ public class JsonMappingExceptionMapper implements ExceptionMapper { - private static final Logger log = LoggerFactory.getLogger(JsonMappingExceptionMapper.class); + private static final Logger LOG = LoggerFactory.getLogger(JsonMappingExceptionMapper.class); @Override public Response toResponse(JsonMappingException exception) { var feil = "FIM-252294: JSON-mapping feil"; - log.warn(feil); + LOG.warn(feil); return Response.status(Response.Status.BAD_REQUEST).entity(new FeilDto(feil)).type(MediaType.APPLICATION_JSON).build(); } } diff --git a/src/main/java/no/nav/familie/inntektsmelding/server/exceptions/JsonParseExceptionMapper.java b/src/main/java/no/nav/familie/inntektsmelding/server/exceptions/JsonParseExceptionMapper.java index 02a42877..b4d31819 100644 --- a/src/main/java/no/nav/familie/inntektsmelding/server/exceptions/JsonParseExceptionMapper.java +++ b/src/main/java/no/nav/familie/inntektsmelding/server/exceptions/JsonParseExceptionMapper.java @@ -11,12 +11,12 @@ public class JsonParseExceptionMapper implements ExceptionMapper { - private static final Logger log = LoggerFactory.getLogger(JsonParseExceptionMapper.class); + private static final Logger LOG = LoggerFactory.getLogger(JsonParseExceptionMapper.class); @Override public Response toResponse(JsonParseException exception) { var feil = String.format("FIM-299955: JSON-parsing feil: %s", exception.getMessage()); - log.warn(feil); + LOG.warn(feil); return Response.status(Response.Status.BAD_REQUEST).entity(new FeilDto(feil)).type(MediaType.APPLICATION_JSON).build(); } } diff --git a/src/main/java/no/nav/familie/inntektsmelding/server/jackson/IndexClasses.java b/src/main/java/no/nav/familie/inntektsmelding/server/jackson/IndexClasses.java index 771b1881..92db3c81 100644 --- a/src/main/java/no/nav/familie/inntektsmelding/server/jackson/IndexClasses.java +++ b/src/main/java/no/nav/familie/inntektsmelding/server/jackson/IndexClasses.java @@ -27,7 +27,7 @@ * Henter persistert index (hvis generert) eller genererer index for angitt location (typisk matcher en jar/war fil). */ public class IndexClasses { - private static final Logger log = org.slf4j.LoggerFactory.getLogger(IndexClasses.class); + private static final Logger LOG = org.slf4j.LoggerFactory.getLogger(IndexClasses.class); private static final ConcurrentMap INDEXES = new ConcurrentHashMap<>(); @@ -125,7 +125,7 @@ public List> getClassesWithAnnotation(Class annotationClass) { try { jsonTypes.add(Class.forName(className)); } catch (ClassNotFoundException e) { - log.error("Kan ikke finne klasse i Classpath, som funnet i Jandex index", e);// NOSONAR + LOG.error("Kan ikke finne klasse i Classpath, som funnet i Jandex index", e);// NOSONAR } } } @@ -147,7 +147,7 @@ public List> getClasses(Predicate predicate, Predicate tilgangTjeneste.sjekkAtAnsattHarRollenDrift()); assertThat(ex.getMessage()).contains("Ansatt mangler en rolle."); @@ -205,12 +205,12 @@ void test_sjekk_om_ansatt_har_rollen_drift_feil_rolle_nok() { @Test void test_sjekk_om_ansatt_har_rollen_drift_ok() { try (var mockedKontekts = Mockito.mockStatic(KontekstHolder.class)) { - var forventetRolle = Groups.DRIFT; + var forventetRolle = AnsattGruppe.DRIFT; mockedKontekts.when(KontekstHolder::getKontekst).thenReturn(fakeRequestKontekts(IdentType.InternBruker, Set.of(forventetRolle))); assertDoesNotThrow(() -> tilgangTjeneste.sjekkAtAnsattHarRollenDrift()); } } - + @Test void test_sjekk_om_systembruker_kall_nok_pga_internbruker() { try (var mockedKontekts = Mockito.mockStatic(KontekstHolder.class)) { @@ -243,7 +243,7 @@ private Kontekst fakeRequestKontekts(IdentType identType) { return fakeRequestKontekts(identType, Set.of()); } - private Kontekst fakeRequestKontekts(IdentType identType, Set groups) { + private Kontekst fakeRequestKontekts(IdentType identType, Set groups) { return RequestKontekst.forRequest("brukerUid", "brukerUid", identType, fakeOidcToken(OpenIDProvider.TOKENX), UUID.randomUUID(), groups); }