From b085738dd45bbbf41b01df5ebd3440dca64cde92 Mon Sep 17 00:00:00 2001 From: opensnail <598092184@qq.com> Date: Tue, 21 May 2024 09:14:02 +0800 Subject: [PATCH] =?UTF-8?q?feat(sj=5F1.0.0):=20=E4=BC=98=E5=8C=96=E4=BB=A3?= =?UTF-8?q?=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/starter/schedule/OfflineNodeSchedule.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/snail-job-server/snail-job-server-starter/src/main/java/com/aizuda/snailjob/server/starter/schedule/OfflineNodeSchedule.java b/snail-job-server/snail-job-server-starter/src/main/java/com/aizuda/snailjob/server/starter/schedule/OfflineNodeSchedule.java index c6d780ff..33860f14 100644 --- a/snail-job-server/snail-job-server-starter/src/main/java/com/aizuda/snailjob/server/starter/schedule/OfflineNodeSchedule.java +++ b/snail-job-server/snail-job-server-starter/src/main/java/com/aizuda/snailjob/server/starter/schedule/OfflineNodeSchedule.java @@ -1,5 +1,7 @@ package com.aizuda.snailjob.server.starter.schedule; +import cn.hutool.core.collection.CollStreamUtil; +import cn.hutool.core.collection.CollUtil; import com.aizuda.snailjob.common.core.util.StreamUtils; import com.aizuda.snailjob.common.log.SnailJobLog; import com.aizuda.snailjob.server.common.Lifecycle; @@ -46,9 +48,9 @@ public class OfflineNodeSchedule extends AbstractSchedule implements Lifecycle { List serverNodes = serverNodeMapper.selectList( new LambdaQueryWrapper().select(ServerNode::getId) .le(ServerNode::getExpireAt, endTime)); - if (!CollectionUtils.isEmpty(serverNodes)) { + if (CollUtil.isNotEmpty(serverNodes)) { // 先删除DB中需要下线的机器 - serverNodeMapper.deleteBatchIds(serverNodes.stream().map(ServerNode::getId).collect(Collectors.toSet())); + serverNodeMapper.deleteBatchIds(StreamUtils.toSet(serverNodes, ServerNode::getId)); } Set allPods = CacheRegisterTable.getAllPods();