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-25 23:32:35 +08:00
parent 4db55f6fa0
commit 0e76e5fe1c
3 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/generator/retry/AbstractGenerator.java
View File

@ -125,6 +125,8 @@ public abstract class AbstractGenerator implements TaskGenerator {
retry.setGroupName(taskContext.getGroupName()); retry.setGroupName(taskContext.getGroupName());
retry.setSceneName(taskContext.getSceneName()); retry.setSceneName(taskContext.getSceneName());
retry.setRetryStatus(initStatus(taskContext)); retry.setRetryStatus(initStatus(taskContext));
retry.setParentId(0L);
retry.setDeleted(0L);
if (StrUtil.isBlank(retry.getBizNo())) { if (StrUtil.isBlank(retry.getBizNo())) {
// 默认生成一个业务单据号方便用户查询 // 默认生成一个业务单据号方便用户查询
retry.setBizNo(IdUtil.fastSimpleUUID()); retry.setBizNo(IdUtil.fastSimpleUUID());

2
snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/model/response/RetryTaskResponseVO.java
View File

@ -32,4 +32,6 @@ public class RetryTaskResponseVO {
*/ */
private String clientInfo; private String clientInfo;
private RetryResponseVO responseVO;
} }

12
snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/RetryTaskServiceImpl.java
View File

@ -15,11 +15,13 @@ import com.aizuda.snailjob.server.web.model.base.PageResult;
import com.aizuda.snailjob.server.web.model.request.RetryTaskLogMessageQueryVO; import com.aizuda.snailjob.server.web.model.request.RetryTaskLogMessageQueryVO;
import com.aizuda.snailjob.server.web.model.request.RetryTaskQueryVO; import com.aizuda.snailjob.server.web.model.request.RetryTaskQueryVO;
import com.aizuda.snailjob.server.web.model.request.UserSessionVO; import com.aizuda.snailjob.server.web.model.request.UserSessionVO;
import com.aizuda.snailjob.server.web.model.response.RetryResponseVO;
import com.aizuda.snailjob.server.web.model.response.RetryTaskLogMessageResponseVO; import com.aizuda.snailjob.server.web.model.response.RetryTaskLogMessageResponseVO;
import com.aizuda.snailjob.server.web.model.response.RetryTaskResponseVO; import com.aizuda.snailjob.server.web.model.response.RetryTaskResponseVO;
import com.aizuda.snailjob.server.web.service.RetryTaskService; import com.aizuda.snailjob.server.web.service.RetryTaskService;
import com.aizuda.snailjob.server.web.service.convert.RetryConverter; import com.aizuda.snailjob.server.web.service.convert.RetryConverter;
import com.aizuda.snailjob.server.web.service.convert.RetryTaskLogResponseVOConverter; import com.aizuda.snailjob.server.web.service.convert.RetryTaskLogResponseVOConverter;
import com.aizuda.snailjob.server.web.service.convert.RetryTaskResponseVOConverter;
import com.aizuda.snailjob.server.web.util.UserSessionUtils; import com.aizuda.snailjob.server.web.util.UserSessionUtils;
import com.aizuda.snailjob.template.datasource.persistence.mapper.RetryMapper; import com.aizuda.snailjob.template.datasource.persistence.mapper.RetryMapper;
import com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskMapper; import com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskMapper;
@ -165,7 +167,15 @@ public class RetryTaskServiceImpl implements RetryTaskService {
@Override @Override
public RetryTaskResponseVO getRetryTaskById(Long id) { public RetryTaskResponseVO getRetryTaskById(Long id) {
RetryTask retryTask = retryTaskMapper.selectById(id); RetryTask retryTask = retryTaskMapper.selectById(id);
return RetryTaskLogResponseVOConverter.INSTANCE.convert(retryTask);
if (retryTask == null) {
return null;
}
Retry retry = retryMapper.selectById(retryTask.getRetryId());
RetryTaskResponseVO responseVO = RetryTaskLogResponseVOConverter.INSTANCE.convert(retryTask);
responseVO.setResponseVO(RetryTaskResponseVOConverter.INSTANCE.convert(retry));
return responseVO;
} }
@Override @Override