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 + " 已删除的资讯,条数超过自动删除阈值,未执行删除,请手动处理"; } // 根据模板,生成通知内容