fix JobLifeCycle

Zzm0809 · Dec 26, 2023 · df76f79 · df76f79
1 parent a20b680
commit df76f79
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/dinky-admin/src/main/java/org/dinky/service/impl/TaskServiceImpl.java b/dinky-admin/src/main/java/org/dinky/service/impl/TaskServiceImpl.java
@@ -487,6 +487,7 @@ public void initTenantByTaskId(Integer id) {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public boolean changeTaskLifeRecyle(Integer taskId, JobLifeCycle lifeCycle) throws SqlExplainExcepition {
         TaskDTO task = getTaskInfoById(taskId);
         task.setStep(lifeCycle.getValue());
@@ -504,7 +505,14 @@ public boolean changeTaskLifeRecyle(Integer taskId, JobLifeCycle lifeCycle) thro
             Integer taskVersionId = taskVersionService.createTaskVersionSnapshot(task);
             task.setVersionId(taskVersionId);
         }
-        return saveOrUpdate(task.buildTask());
+        boolean saved = saveOrUpdate(task.buildTask());
+        if (saved && Asserts.isNotNull(task.getJobInstanceId())) {
+            JobInstance jobInstance = jobInstanceService.getById(task.getJobInstanceId());
+            jobInstance.setStep(lifeCycle.getValue());
+            jobInstanceService.updateById(jobInstance);
+            log.info("jobInstance [{}] step change to {}", jobInstance.getJid(), lifeCycle.getValue());
+        }
+        return saved;
     }
 
     @Override