diff --git a/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/dispatch/JobTaskPrepareActor.java b/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/dispatch/JobTaskPrepareActor.java index a003c131c..7e4baabd8 100644 --- a/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/dispatch/JobTaskPrepareActor.java +++ b/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/dispatch/JobTaskPrepareActor.java @@ -77,8 +77,6 @@ public class JobTaskPrepareActor extends AbstractActor { // 模拟完成情况 jobTaskBatch.setTaskBatchStatus(JobTaskBatchStatusEnum.SUCCESS.getStatus()); notCompleteJobTaskBatchList = Lists.newArrayList(jobTaskBatch); -// TerminalJobPrepareHandler terminalJobPrepareHandler = SnailSpringContext.getBeanByType(TerminalJobPrepareHandler.class); -// terminalJobPrepareHandler.handle(prepare); } boolean onlyTimeoutCheck = false; diff --git a/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/prepare/job/TerminalJobPrepareHandler.java b/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/prepare/job/TerminalJobPrepareHandler.java index 38e3f652a..fa1760e8e 100644 --- a/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/prepare/job/TerminalJobPrepareHandler.java +++ b/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/prepare/job/TerminalJobPrepareHandler.java @@ -12,6 +12,8 @@ import org.springframework.stereotype.Component; import java.util.Objects; +import static com.aizuda.snailjob.common.core.enums.JobTaskBatchStatusEnum.COMPLETED; + /** * 处理处于已完成 {@link JobTaskBatchStatusEnum::COMPLETED} 状态的任务 * @@ -29,7 +31,7 @@ public class TerminalJobPrepareHandler extends AbstractJobPrepareHandler { @Override public boolean matches(Integer status) { - return Objects.isNull(status); + return COMPLETED.contains(status); } @Override