顶管ids删除

ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/impl/ZEngineeringPipeJackingServiceImpl.java

@@ -11,6 +11,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.ruoyi.zdsz.domain.ZEngineeringNode;
 import com.ruoyi.zdsz.domain.bo.ZEngineeringNodeBo;
+import com.ruoyi.zdsz.domain.vo.ZEngineeringCivilVo;
 import com.ruoyi.zdsz.domain.vo.ZEngineeringNodeVo;
 import com.ruoyi.zdsz.service.IZEngineeringNodeService;
 import lombok.RequiredArgsConstructor;
@@ -137,6 +138,7 @@ public class ZEngineeringPipeJackingServiceImpl implements IZEngineeringPipeJack
      * 修改顶管工程
      */
     @Override
+    @Transactional(rollbackFor=Exception.class)
     public Boolean updateByBo(ZEngineeringPipeJackingBo bo) {
         ZEngineeringPipeJacking update = BeanUtil.toBean(bo, ZEngineeringPipeJacking.class);
         validEntityBeforeSave(update);
@@ -183,11 +185,21 @@ public class ZEngineeringPipeJackingServiceImpl implements IZEngineeringPipeJack
      * 批量删除顶管工程
      */
     @Override
+    @Transactional(rollbackFor=Exception.class)
     public Boolean deleteWithValidByIds(Collection<String> ids, Boolean isValid) {
         if(isValid){
             //TODO 做一些业务上的校验,判断是否需要校验
         }
-        nodeService.queryIdByCivliId(ids);
+        ids.forEach(item -> {
+            ZEngineeringPipeJackingVo vo = baseMapper.selectVoById(item);
+            ZEngineeringNodeBo zEngineeringNodeBo = new ZEngineeringNodeBo();
+            zEngineeringNodeBo.setCreateTime(vo.getCreateTime());
+            zEngineeringNodeBo.setCivliId(vo.getId());
+            List<ZEngineeringNodeBo> zEngineeringNodeBos = nodeService.queryListDetails(zEngineeringNodeBo);
+            zEngineeringNodeBos.stream().forEach(ite ->
+                nodeService.delete(ite)
+            );
+        });
         return baseMapper.deleteBatchIds(ids) > 0;
     }
 }