GTsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(sj_1.0.0): 优化代码

Browse Source
This commit is contained in:
opensnail 2024-05-21 09:14:02 +08:00
parent dceb6f2714
commit b085738dd4
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
snail-job-server/snail-job-server-starter/src/main/java/com/aizuda/snailjob/server/starter/schedule/OfflineNodeSchedule.java
View File

@ -1,5 +1,7 @@
package com.aizuda.snailjob.server.starter.schedule; 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.core.util.StreamUtils;
import com.aizuda.snailjob.common.log.SnailJobLog; import com.aizuda.snailjob.common.log.SnailJobLog;
import com.aizuda.snailjob.server.common.Lifecycle; import com.aizuda.snailjob.server.common.Lifecycle;
@ -46,9 +48,9 @@ public class OfflineNodeSchedule extends AbstractSchedule implements Lifecycle {
List<ServerNode> serverNodes = serverNodeMapper.selectList( List<ServerNode> serverNodes = serverNodeMapper.selectList(
new LambdaQueryWrapper<ServerNode>().select(ServerNode::getId) new LambdaQueryWrapper<ServerNode>().select(ServerNode::getId)
.le(ServerNode::getExpireAt, endTime)); .le(ServerNode::getExpireAt, endTime));
if (!CollectionUtils.isEmpty(serverNodes)) { if (CollUtil.isNotEmpty(serverNodes)) {
// 先删除DB中需要下线的机器 // 先删除DB中需要下线的机器
serverNodeMapper.deleteBatchIds(serverNodes.stream().map(ServerNode::getId).collect(Collectors.toSet())); serverNodeMapper.deleteBatchIds(StreamUtils.toSet(serverNodes, ServerNode::getId));
} }
Set<RegisterNodeInfo> allPods = CacheRegisterTable.getAllPods(); Set<RegisterNodeInfo> allPods = CacheRegisterTable.getAllPods();