fix: unblokkerer tasks (#42)

navikt · Apr 23, 2020 · 5dcdce6 · 5dcdce6
1 parent c25db0f
commit 5dcdce6
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 8 deletions.
diff --git a/task/src/main/java/no/nav/vedtak/felles/prosesstask/impl/RunTask.java b/task/src/main/java/no/nav/vedtak/felles/prosesstask/impl/RunTask.java
@@ -194,11 +194,12 @@ private ProsessTaskEntitet refreshProsessTask(Long id) {
         }
 
         ProsessTaskStatus markerTaskFerdig(ProsessTaskEntitet pte) {
+            // frigir veto etter at event handlere er fyrt
+            taskManagerRepository.frigiVeto(pte);
+
             ProsessTaskStatus nyStatus = ProsessTaskStatus.KJOERT;
             taskManagerRepository.oppdaterStatus(pte.getId(), nyStatus);
 
-            // frigir veto etter at event handlere er fyrt
-            taskManagerRepository.frigiVeto(pte);
 
             pte = refreshProsessTask(pte.getId());
             feilOgStatushåndterer.publiserNyStatusEvent(pte.tilProsessTask(), ProsessTaskStatus.KLAR, nyStatus);

diff --git a/task/src/main/java/no/nav/vedtak/felles/prosesstask/impl/TaskManagerRepositoryImpl.java b/task/src/main/java/no/nav/vedtak/felles/prosesstask/impl/TaskManagerRepositoryImpl.java
@@ -122,16 +122,14 @@ void frigiVeto(ProsessTaskEntitet blokkerendeTask) {
             + ", blokkert_av=NULL"
             + ", siste_kjoering_feil_kode=NULL"
             + ", siste_kjoering_feil_tekst=NULL"
-            + ", neste_kjoering_etter=:neste"
-            + " WHERE status='VETO' and blokkert_av=:id";
-
-        LocalDateTime nesteKjøringEtter = LocalDateTime.now();
+            + ", neste_kjoering_etter=NULL"
+            + ", versjon = versjon +1"
+            + " WHERE blokkert_av=:id";
 
         @SuppressWarnings("resource")
         int tasks = getEntityManagerAsSession()
             .createNativeQuery(updateSql)
             .setParameter("id", blokkerendeTask.getId())
-            .setParameter("neste", nesteKjøringEtter, TemporalType.TIMESTAMP) // NOSONAR
             .executeUpdate();
         if (tasks > 0) {
             log.info("ProsessTask [{}] FERDIG. Frigitt {} tidligere blokkerte tasks", blokkerendeTask.getId(), tasks);
@@ -149,7 +147,7 @@ void frigiVeto(ProsessTaskEntitet blokkerendeTask) {
             " ,siste_kjoering_feil_tekst = :feiltekst" +
             ", siste_kjoering_slutt_ts = :status_ts" +
             " ,versjon=versjon+1 " +
-            " WHERE id = :id";
+            " WHERE id = :id AND status NOT IN ('VETO', 'SUSPENDERT', 'KJOERT', 'FERDIG')";
 
         LocalDateTime now = LocalDateTime.now();
         String status = taskStatus.getDbKode();