diff --git a/project/src/main/java/com/sdm/project/service/impl/NodeServiceImpl.java b/project/src/main/java/com/sdm/project/service/impl/NodeServiceImpl.java index f38db419..d5d891a5 100644 --- a/project/src/main/java/com/sdm/project/service/impl/NodeServiceImpl.java +++ b/project/src/main/java/com/sdm/project/service/impl/NodeServiceImpl.java @@ -3093,6 +3093,21 @@ public class NodeServiceImpl extends ServiceImpl NodeTypeEnum.PHASE.getValue().equals(node.getNodeType())).findFirst().orElse(null); + if (ObjectUtils.isNotEmpty(phaseNode)) { + String phaseNodeName = phaseNode.getNodeName(); + log.info("节点中的阶段为:{}",phaseNodeName); + if (StringUtils.isNotBlank(phaseNodeName)) { + todoInfoList = todoInfoList.stream().filter(todoInfo -> phaseNodeName.equals(todoInfo.getProjectStage())).toList(); + log.info("过滤阶段后待同步的待办数量:{}", todoInfoList.size()); + if (CollectionUtils.isEmpty(todoInfoList)) { + log.info("过滤阶段后没有需要同步的待办"); + return SdmResponse.success(); + } + } + } + // 4. 准备基础数据 Long tenantId = ThreadLocalContext.getTenantId(); Long currentUserId = ThreadLocalContext.getUserId();