From ff8ea10dbd9f21e50eaf34eb4eb52561b0769350 Mon Sep 17 00:00:00 2001 From: xuye Date: Wed, 12 Apr 2023 18:55:43 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=B6=88=E6=81=AF=E9=80=9A?= =?UTF-8?q?=E7=9F=A5=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/work/xuye/sink/handler/DisappearHandler.java | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/sink/src/main/java/work/xuye/sink/handler/DisappearHandler.java b/sink/src/main/java/work/xuye/sink/handler/DisappearHandler.java index 5557f0d..724d47c 100644 --- a/sink/src/main/java/work/xuye/sink/handler/DisappearHandler.java +++ b/sink/src/main/java/work/xuye/sink/handler/DisappearHandler.java @@ -78,14 +78,12 @@ public class DisappearHandler { SinkParams.DisappearConfig disappearConfig = task.getSinkParams().getCheckDelete().getDisappearConfig(); // 处理自动/手动删除，生成通知标题 - if (disappearConfig.isAutoDeleteEnabled()) { - if (disappearConfig.getAutoDeleteThreshold() >= removed.size()) { - sqlExecutor.executeSql(sqlEntity.getId(), sqlEntity.getCaptcha()); - autoDeleted = true; - messageTitle = "已经自动删除 " + taskName + " 已删除的资讯"; - } else { - messageTitle = "检测到 " + taskName + " 已删除的资讯，条数超过自动删除阈值，未执行删除，请手动处理"; - } + if (disappearConfig.isAutoDeleteEnabled() && disappearConfig.getAutoDeleteThreshold() >= removed.size()) { + sqlExecutor.executeSql(sqlEntity.getId(), sqlEntity.getCaptcha()); + autoDeleted = true; + messageTitle = "已经自动删除 " + taskName + " 已删除的资讯"; + } else { + messageTitle = "检测到 " + taskName + " 已删除的资讯，条数超过自动删除阈值，未执行删除，请手动处理"; } // 根据模板，生成通知内容