diff --git a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/ClearLogSchedule.java b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/ClearLogSchedule.java index ec95eb904..f1b769929 100644 --- a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/ClearLogSchedule.java +++ b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/ClearLogSchedule.java @@ -115,21 +115,21 @@ public class ClearLogSchedule extends AbstractSchedule implements Lifecycle { protected void doInTransactionWithoutResult(final TransactionStatus status) { List uniqueIdIds = StreamUtils.toList(partitionTasks, PartitionTask::getUniqueId); - if (uniqueIdIds == null || uniqueIdIds.size() == 0) { + if (uniqueIdIds == null || uniqueIdIds.isEmpty()) { return; } // Waiting for deletion RetryLog List retryTaskLogList = retryTaskLogMapper.selectList(new LambdaQueryWrapper().in(RetryTaskLog::getUniqueId, uniqueIdIds)); - if (retryTaskLogList != null && retryTaskLogList.size() > 0) { + if (retryTaskLogList != null && !retryTaskLogList.isEmpty()) { List retryTaskListIds = StreamUtils.toList(retryTaskLogList, RetryTaskLog::getId); - retryTaskLogMapper.deleteBatchIds(retryTaskListIds); + retryTaskLogMapper.deleteByIds(retryTaskListIds); } // Waiting for deletion RetryTaskLogMessage List retryTaskLogMessageList = retryTaskLogMessageMapper.selectList(new LambdaQueryWrapper().in(RetryTaskLogMessage::getUniqueId, uniqueIdIds)); - if (retryTaskLogMessageList != null && retryTaskLogMessageList.size() > 0) { + if (retryTaskLogMessageList != null && !retryTaskLogMessageList.isEmpty()) { List retryTaskListIds = StreamUtils.toList(retryTaskLogMessageList, RetryTaskLogMessage::getId); - retryTaskLogMessageMapper.deleteBatchIds(retryTaskListIds); + retryTaskLogMessageMapper.deleteByIds(retryTaskListIds); } } });