From c802009c78f86fa2806917b35bbaa8b49a0b97a9 Mon Sep 17 00:00:00 2001
From: opensnail <598092184@qq.com>
Date: Thu, 24 Oct 2024 18:27:28 +0800
Subject: [PATCH] =?UTF-8?q?feat:(1.2.0-beta2):=20=E4=BC=98=E5=8C=96?=
 =?UTF-8?q?=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../retry/task/support/schedule/ClearLogSchedule.java  | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

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 ec95eb90..f1b76992 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<String> uniqueIdIds = StreamUtils.toList(partitionTasks, PartitionTask::getUniqueId);
-                if (uniqueIdIds == null || uniqueIdIds.size() == 0) {
+                if (uniqueIdIds == null || uniqueIdIds.isEmpty()) {
                     return;
                 }
                 // Waiting for deletion RetryLog
                 List<RetryTaskLog> retryTaskLogList = retryTaskLogMapper.selectList(new LambdaQueryWrapper<RetryTaskLog>().in(RetryTaskLog::getUniqueId, uniqueIdIds));
-                if (retryTaskLogList != null && retryTaskLogList.size() > 0) {
+                if (retryTaskLogList != null && !retryTaskLogList.isEmpty()) {
                     List<Long> retryTaskListIds = StreamUtils.toList(retryTaskLogList, RetryTaskLog::getId);
-                    retryTaskLogMapper.deleteBatchIds(retryTaskListIds);
+                    retryTaskLogMapper.deleteByIds(retryTaskListIds);
                 }
 
                 // Waiting for deletion RetryTaskLogMessage
                 List<RetryTaskLogMessage> retryTaskLogMessageList = retryTaskLogMessageMapper.selectList(new LambdaQueryWrapper<RetryTaskLogMessage>().in(RetryTaskLogMessage::getUniqueId, uniqueIdIds));
-                if (retryTaskLogMessageList != null && retryTaskLogMessageList.size() > 0) {
+                if (retryTaskLogMessageList != null && !retryTaskLogMessageList.isEmpty()) {
                     List<Long> retryTaskListIds = StreamUtils.toList(retryTaskLogMessageList, RetryTaskLogMessage::getId);
-                    retryTaskLogMessageMapper.deleteBatchIds(retryTaskListIds);
+                    retryTaskLogMessageMapper.deleteByIds(retryTaskListIds);
                 }
             }
         });