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.重试任务添加重试id

Browse Source
This commit is contained in:
opensnail 2025-02-22 00:02:44 +08:00
parent 3a6566c532
commit 9a144c28a7
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/controller/RetryTaskLogController.java → snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/controller/RetryTaskController.java
View File

@ -22,7 +22,7 @@ import java.util.Set;
*/ */
@RestController @RestController
@RequestMapping("/retry-task") @RequestMapping("/retry-task")
public class RetryTaskLogController { public class RetryTaskController {
@Autowired @Autowired
private RetryTaskLogService retryTaskLogService; private RetryTaskLogService retryTaskLogService;

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

@ -19,6 +19,7 @@ import com.aizuda.snailjob.server.web.service.convert.RetryTaskLogResponseVOConv
import com.aizuda.snailjob.server.web.util.UserSessionUtils; import com.aizuda.snailjob.server.web.util.UserSessionUtils;
import com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskMapper; import com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskMapper;
import com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMessageMapper; import com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMessageMapper;
import com.aizuda.snailjob.template.datasource.persistence.po.Retry;
import com.aizuda.snailjob.template.datasource.persistence.po.RetryTask; import com.aizuda.snailjob.template.datasource.persistence.po.RetryTask;
import com.aizuda.snailjob.template.datasource.persistence.po.RetryTaskLogMessage; import com.aizuda.snailjob.template.datasource.persistence.po.RetryTaskLogMessage;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@ -60,7 +61,7 @@ public class RetryTaskLogServiceImpl implements RetryTaskLogService {
.between(ObjUtil.isNotNull(queryVO.getDatetimeRange()), .between(ObjUtil.isNotNull(queryVO.getDatetimeRange()),
RetryTask::getCreateDt, queryVO.getStartDt(), queryVO.getEndDt()) RetryTask::getCreateDt, queryVO.getStartDt(), queryVO.getEndDt())
.select(RetryTask::getGroupName, RetryTask::getId, RetryTask::getSceneName, RetryTask::getTaskStatus, .select(RetryTask::getGroupName, RetryTask::getId, RetryTask::getSceneName, RetryTask::getTaskStatus,
RetryTask::getCreateDt, RetryTask::getTaskType, RetryTask::getOperationReason) RetryTask::getCreateDt, RetryTask::getTaskType, RetryTask::getOperationReason, RetryTask::getRetryId)
.orderByDesc(RetryTask::getCreateDt); .orderByDesc(RetryTask::getCreateDt);
PageDTO<RetryTask> retryTaskPageDTO = retryTaskMapper.selectPage(pageDTO, wrapper); PageDTO<RetryTask> retryTaskPageDTO = retryTaskMapper.selectPage(pageDTO, wrapper);

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

@ -99,7 +99,7 @@ public class RetryTaskServiceImpl implements RetryTaskService {
.eq(Retry::getTaskType, SyetemTaskTypeEnum.RETRY.getType()) .eq(Retry::getTaskType, SyetemTaskTypeEnum.RETRY.getType())
.select(Retry::getId, Retry::getBizNo, Retry::getIdempotentId, .select(Retry::getId, Retry::getBizNo, Retry::getIdempotentId,
Retry::getGroupName, Retry::getNextTriggerAt, Retry::getRetryCount, Retry::getGroupName, Retry::getNextTriggerAt, Retry::getRetryCount,
Retry::getRetryStatus, Retry::getUpdateDt, Retry::getSceneName, Retry::getRetryStatus, Retry::getUpdateDt, Retry::getCreateDt, Retry::getSceneName,
Retry::getTaskType, Retry::getParentId) Retry::getTaskType, Retry::getParentId)
.orderByDesc(Retry::getCreateDt); .orderByDesc(Retry::getCreateDt);
pageDTO = accessTemplate.getRetryAccess().listPage(pageDTO, queryWrapper); pageDTO = accessTemplate.getRetryAccess().listPage(pageDTO, queryWrapper);