From fd5cce01423a4755c2df8e99fce7e613a70259f7 Mon Sep 17 00:00:00 2001 From: opensnail <598092184@qq.com> Date: Wed, 23 Oct 2024 17:29:28 +0800 Subject: [PATCH] =?UTF-8?q?feat:(1.1.2.0-beta2):=20=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E6=97=A5=E5=BF=97=E6=B8=85=E9=99=A4BUG?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../job/task/support/schedule/JobClearLogSchedule.java | 6 +++--- 1 file changed, 3 insertions(+), 3 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 0655649cb..0bfe28e76 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 @@ -123,7 +123,7 @@ public class JobClearLogSchedule extends AbstractSchedule implements Lifecycle { if (CollectionUtils.isEmpty(ids)) { return; } - Lists.partition(ids, 500).forEach(partIds -> jobTaskBatchMapper.deleteByIds(ids)); + Lists.partition(ids, 500).forEach(jobTaskBatchMapper::deleteByIds); // Waiting for deletion JobTaskList List jobTaskList = jobTaskMapper.selectList(new LambdaQueryWrapper().in(JobTask::getTaskBatchId, ids)); @@ -131,7 +131,7 @@ public class JobClearLogSchedule extends AbstractSchedule implements Lifecycle { return; } List jobTaskListIds = StreamUtils.toList(jobTaskList, JobTask::getId); - Lists.partition(jobTaskListIds, 500).forEach(partIds -> jobTaskMapper.deleteByIds(partIds)); + Lists.partition(jobTaskListIds, 500).forEach(jobTaskMapper::deleteByIds); // Waiting for deletion JobLogMessageList List jobLogMessageList = jobLogMessageMapper.selectList(new LambdaQueryWrapper().in(JobLogMessage::getTaskBatchId, ids)); @@ -139,7 +139,7 @@ public class JobClearLogSchedule extends AbstractSchedule implements Lifecycle { return; } List jobLogMessageListIds = StreamUtils.toList(jobLogMessageList, JobLogMessage::getId); - Lists.partition(jobLogMessageListIds, 500).forEach(partIds -> jobTaskMapper.deleteByIds(jobLogMessageListIds)); + Lists.partition(jobLogMessageListIds, 500).forEach(jobLogMessageMapper::deleteByIds); } }); }