gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat(1.4.0-beta1): 1. 修复手动执行失败问题

Browse Source
This commit is contained in:
opensnail 2025-02-23 21:51:11 +08:00
parent 3f95f49e16
commit c731bcbada
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/executor/RemoteCallbackExecutor.java
View File

@ -9,6 +9,8 @@ import com.aizuda.snailjob.client.core.log.RetryLogMeta;
import com.aizuda.snailjob.client.core.retryer.RetryerInfo;
import com.aizuda.snailjob.common.core.context.SnailSpringContext;
import com.aizuda.snailjob.common.core.enums.RetryStatusEnum;
import com.aizuda.snailjob.common.core.util.JsonUtil;
import com.aizuda.snailjob.common.log.SnailJobLog;
import com.aizuda.snailjob.common.log.enums.LogTypeEnum;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.NoSuchBeanDefinitionException;
@ -47,6 +49,8 @@ public class RemoteCallbackExecutor {
// 以Spring Bean模式回调
doCallbackForSpringBean(context);
// 上报执行成功
SnailJobLog.REMOTE.info("任务执行成功 taskId:[{}]", context.getRetryTaskId());
} catch (NoSuchBeanDefinitionException e) {
// 若不是SpringBean 则直接反射以普通类调用
doCallbackForOrdinaryClass(context);
@ -120,7 +124,7 @@ public class RemoteCallbackExecutor {
ReflectionUtils.invokeMethod(method, retryCompleteCallback, retryerInfo.getScene(),
retryerInfo.getExecutorClassName(), deSerialize);
SnailJobLog.REMOTE.info("任务执行成功 taskId:[{}] [{}]", context.getRetryTaskId());
}

4
snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/dispatch/RetryExecutor.java
View File

@ -79,9 +79,9 @@ public class RetryExecutor extends AbstractActor {
private void doExecute(RetryTaskExecuteDTO execute) {
LambdaQueryWrapper<Retry> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(Retry::getId, execute.getRetryId());
if (RetryTaskExecutorSceneEnum.MANUAL_RETRY.getScene() != execute.getRetryTaskExecutorScene()) {
wrapper.eq(Retry::getId, execute.getRetryId()).eq(Retry::getRetryStatus, RetryStatusEnum.RUNNING.getStatus());
wrapper.eq(Retry::getRetryStatus, RetryStatusEnum.RUNNING.getStatus());
}
Retry retry = retryMapper.selectOne(wrapper);