From d89862f8244b3fb8cc298ef8b46e6a52c6960abd Mon Sep 17 00:00:00 2001 From: opensnail <598092184@qq.com> Date: Fri, 25 Apr 2025 21:36:04 +0800 Subject: [PATCH] =?UTF-8?q?fix(1.5.0-beta1):=20=E4=BC=98=E5=8C=96sql?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/job/task/support/schedule/JobClearLogSchedule.java | 2 +- .../task/support/schedule/AbstractRetryTaskAlarmSchedule.java | 2 +- .../server/web/service/impl/GroupConfigServiceImpl.java | 2 +- .../aizuda/snailjob/server/web/service/impl/JobServiceImpl.java | 2 +- .../server/web/service/impl/NotifyRecipientServiceImpl.java | 2 +- .../server/web/service/impl/SceneConfigServiceImpl.java | 2 +- .../snailjob/server/web/service/impl/WorkflowServiceImpl.java | 2 +- 7 files changed, 7 insertions(+), 7 deletions(-) diff --git a/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/schedule/JobClearLogSchedule.java b/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/schedule/JobClearLogSchedule.java index 8e1761643..89020989c 100644 --- a/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/schedule/JobClearLogSchedule.java +++ b/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/schedule/JobClearLogSchedule.java @@ -97,7 +97,7 @@ public class JobClearLogSchedule extends AbstractSchedule implements Lifecycle { private List jobTaskBatchList(Long startId, LocalDateTime endTime) { List jobTaskBatchList = jobTaskBatchMapper.selectPage( - new Page<>(0, 1000), + new Page<>(0, 1000, Boolean.FALSE), new LambdaUpdateWrapper() .ge(JobTaskBatch::getId, startId) .le(JobTaskBatch::getCreateDt, endTime) diff --git a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/AbstractRetryTaskAlarmSchedule.java b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/AbstractRetryTaskAlarmSchedule.java index ec9405ae8..3fa6e2134 100644 --- a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/AbstractRetryTaskAlarmSchedule.java +++ b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/AbstractRetryTaskAlarmSchedule.java @@ -72,7 +72,7 @@ public abstract class AbstractRetryTaskAlarmSchedule extends AbstractSchedule im */ protected List queryPartitionList(Long startId) { List retrySceneConfigList = accessTemplate.getSceneConfigAccess() - .listPage(new PageDTO<>(0, 500), + .listPage(new PageDTO<>(0, 500, Boolean.FALSE), new LambdaQueryWrapper() .gt(RetrySceneConfig::getId, startId) .eq(RetrySceneConfig::getSceneStatus, StatusEnum.YES.getStatus()) diff --git a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/GroupConfigServiceImpl.java b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/GroupConfigServiceImpl.java index 9558d9378..0eaac4124 100644 --- a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/GroupConfigServiceImpl.java +++ b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/GroupConfigServiceImpl.java @@ -347,7 +347,7 @@ public class GroupConfigServiceImpl implements GroupConfigService { List allRequestList = Lists.newArrayList(); PartitionTaskUtils.process((startId -> { - List groupConfigs = accessTemplate.getGroupConfigAccess().listPage(new PageDTO<>(0, 100), + List groupConfigs = accessTemplate.getGroupConfigAccess().listPage(new PageDTO<>(0, 100, Boolean.FALSE), new LambdaQueryWrapper() .ge(GroupConfig::getId, startId) .eq(GroupConfig::getNamespaceId, namespaceId) diff --git a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/JobServiceImpl.java b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/JobServiceImpl.java index fbad88149..91b673aa8 100644 --- a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/JobServiceImpl.java +++ b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/JobServiceImpl.java @@ -279,7 +279,7 @@ public class JobServiceImpl implements JobService { List requestList = new ArrayList<>(); PartitionTaskUtils.process(startId -> { - List jobList = jobMapper.selectPage(new PageDTO<>(0, 100), + List jobList = jobMapper.selectPage(new PageDTO<>(0, 100, Boolean.FALSE), new LambdaQueryWrapper() .eq(Job::getNamespaceId, namespaceId) .eq(StrUtil.isNotBlank(exportJobVO.getGroupName()), Job::getGroupName, exportJobVO.getGroupName()) diff --git a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/NotifyRecipientServiceImpl.java b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/NotifyRecipientServiceImpl.java index abaf4462c..6dddb18a4 100644 --- a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/NotifyRecipientServiceImpl.java +++ b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/NotifyRecipientServiceImpl.java @@ -109,7 +109,7 @@ public class NotifyRecipientServiceImpl implements NotifyRecipientService { List requestList = new ArrayList<>(); String namespaceId = UserSessionUtils.currentUserSession().getNamespaceId(); PartitionTaskUtils.process(startId -> { - List recipients = notifyRecipientMapper.selectPage(new PageDTO<>(0, 100), + List recipients = notifyRecipientMapper.selectPage(new PageDTO<>(0, 100, Boolean.FALSE), new LambdaQueryWrapper() .eq(NotifyRecipient::getNamespaceId, namespaceId) .eq(Objects.nonNull(exportVO.getNotifyType()), NotifyRecipient::getNotifyType, diff --git a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/SceneConfigServiceImpl.java b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/SceneConfigServiceImpl.java index 11d5a100f..2ee42e6f6 100644 --- a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/SceneConfigServiceImpl.java +++ b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/SceneConfigServiceImpl.java @@ -205,7 +205,7 @@ public class SceneConfigServiceImpl implements SceneConfigService { PartitionTaskUtils.process(startId -> { List sceneConfigs = accessTemplate.getSceneConfigAccess() - .listPage(new PageDTO<>(0, 500), new LambdaQueryWrapper() + .listPage(new PageDTO<>(0, 500, Boolean.FALSE), new LambdaQueryWrapper() .eq(RetrySceneConfig::getNamespaceId, UserSessionUtils.currentUserSession().getNamespaceId()) .eq(Objects.nonNull(exportSceneVO.getSceneStatus()), RetrySceneConfig::getSceneStatus, exportSceneVO.getSceneStatus()) .eq(StrUtil.isNotBlank(exportSceneVO.getGroupName()), diff --git a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/WorkflowServiceImpl.java b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/WorkflowServiceImpl.java index 8777c6e89..026a7780c 100644 --- a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/WorkflowServiceImpl.java +++ b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/WorkflowServiceImpl.java @@ -325,7 +325,7 @@ public class WorkflowServiceImpl implements WorkflowService { List resultList = new ArrayList<>(); PartitionTaskUtils.process(startId -> { - List workflowList = workflowMapper.selectPage(new PageDTO<>(0, 100), + List workflowList = workflowMapper.selectPage(new PageDTO<>(0, 100, Boolean.FALSE), new LambdaQueryWrapper() .eq(Workflow::getNamespaceId, UserSessionUtils.currentUserSession().getNamespaceId()) .eq(Workflow::getDeleted, StatusEnum.NO.getStatus())