如果要考虑监理项目

huzhou/src/main/java/com/easy/admin/modules/huzhou/dao/HuzhouSubProjectinfoMapper.java

@@ -4,6 +4,14 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.easy.admin.modules.huzhou.entity.HuzhouProjectinfo;
 import com.easy.admin.modules.huzhou.entity.HuzhouSubProjectinfo;
+import org.apache.ibatis.annotations.Select;
 
 public interface HuzhouSubProjectinfoMapper extends BaseMapper<HuzhouSubProjectinfo> {
+    /**
+     * 获取子项目名称
+     * @param subProjectId 子项目id
+     * @return 子项目名称
+     */
+    @Select("select project_name from huzhou_sub_projectinfo where id = #{subProjectId}")
+    String getSubProjectName (String subProjectId);
 }

huzhou/src/main/java/com/easy/admin/modules/huzhou/service/impl/HuzhouPlaninfoServiceImpl.java

@@ -725,7 +725,6 @@ public class HuzhouPlaninfoServiceImpl extends ServiceImpl<HuzhouPlaninfoMapper,
                 }
             }
         }
-        // 删除掉已完成或者审批中的信息
         newPlanInfos.removeAll(toRemove);
         newPlanInfos.forEach(item -> log.info("待新上传的计划阶段名称:{}-->任务所处状态{}:",item.getTaskName(), item.getIsfinish()));
 

huzhou/src/main/java/com/easy/admin/modules/huzhou/service/impl/HuzhouProjectinfoServiceImpl.java

@@ -2918,6 +2918,7 @@ public class HuzhouProjectinfoServiceImpl extends ServiceImpl<HuzhouProjectinfoM
                 String projectId = projectInfo.getId();
                 // 1.获取当且任务所处的节点名称
                 String currentPointName = planinfoMapper.getCurrentPointName(projectId);
+
                 if (StringUtils.isNotBlank(currentPointName)) {
                     projectInfo.setCurrentPointName(currentPointName);
                     // 当且阶段有实际提交过文件

huzhou/src/main/java/com/easy/admin/modules/huzhou/service/impl/HuzhouSubProjectinfoServiceImpl.java

@@ -84,15 +84,27 @@ public class HuzhouSubProjectinfoServiceImpl extends ServiceImpl<HuzhouSubProjec
                         item.setProjectId(subProjectId);
                         item.setId(null);
                         // 子项目默认1阶段全部完成
-                        if (item.getTaskLevel() != null && PATTERN_PREFIX_1.matcher(item.getTaskLevel()).find()){
+                        if (item.getTaskLevel() != null && PATTERN_PREFIX_1.matcher(item.getTaskLevel()).find()) {
                             item.setIsfinish(CommonConstant.PRO_PLAN_FINISHED);
-                            log.info("阶段：{},完成情况：{}",item.getTaskLevel(),item.getIsfinish());
+                            log.info("阶段：{},完成情况：{}", item.getTaskLevel(), item.getIsfinish());
-                        }else {
+                        } else {
                             item.setIsfinish(CommonConstant.PRO_PLAN_UNFINISHED);
                         }
                     })
                     .collect(Collectors.toList());
-            log.info("saveBatch数量 {} ,updatedHuzhouPlaninfoList:{} " ,updatedHuzhouPlaninfoList.size(),updatedHuzhouPlaninfoList);
+            log.info("saveBatch数量 {} " ,updatedHuzhouPlaninfoList.size());
+            //如果要考虑监理项目
+            // 1.根据subProjectId获取对应的子项目名称是否包含了 监理项目
+            // 2.如果包含了监理项目 则只需要保留监理项目所需要的节点就行,不需要全部复制
+            // 3. List<String> finalList = Arrays.asList("a", "b","c");
+            // Set<String> allowedNames = new HashSet<>(finalList);
+            //  当 projectName 包含 "监理项目" 时，才对 taskName 做过滤
+            //    .filter(item -> {
+            //        if (item.getProjectName() != null && item.getProjectName().contains("监理项目")) {
+            //            return allowedNames.contains(item.getTaskName());
+            //        }
+            //        return true; // 否则保留所有
+            //    })
             planinfoService.saveBatch(updatedHuzhouPlaninfoList);
 
         }else {