diff --git a/muyu-quest-server/src/main/java/com/muyu/quest/job/TaskJob.java b/muyu-quest-server/src/main/java/com/muyu/quest/job/TaskJob.java index 43e3617..def6c61 100644 --- a/muyu-quest-server/src/main/java/com/muyu/quest/job/TaskJob.java +++ b/muyu-quest-server/src/main/java/com/muyu/quest/job/TaskJob.java @@ -22,6 +22,8 @@ import org.springframework.stereotype.Component; import javax.annotation.Resource; import java.util.List; +import java.util.Set; +import java.util.stream.Collectors; /** * @Author: 胡杨 @@ -49,27 +51,27 @@ public class TaskJob { List dispositions = nodeDispositionService.selectNodeDispositionList(new NodeDisposition()); // 查询节点表存在但任务表不存在的任务编码 - List notContainsTaskCodeList = nodes. + Set notContainsTaskCodeList = nodes. stream(). map(Node::getTaskCode). filter(nodeTaskCode -> !tasks. stream(). map(TaskResp::getTaskCode). toList().contains(nodeTaskCode)). - toList(); + collect(Collectors.toSet()); // 删除相关节点表数据 if (!notContainsTaskCodeList.isEmpty()) { nodeService.batchDelect(notContainsTaskCodeList.toArray(new String[0])); } // 查询配置表存在但节点表不存在的节点编码 - List notContainsNodeCodeList = dispositions. + Set notContainsNodeCodeList = dispositions. stream(). map(NodeDisposition::getNodeCode). filter(nodeDispositionNodeCode -> !nodes. stream(). map(Node::getNodeCode). toList().contains(nodeDispositionNodeCode)). - toList(); + collect(Collectors.toSet()); // 删除相关配置表数据 if (!notContainsNodeCodeList.isEmpty()) { nodeDispositionService.batchDelect(notContainsNodeCodeList.toArray(new String[0]));