|
|
@@ -644,28 +644,32 @@ public class NodeAttachmentImpl implements NodeAttachmentService {
|
|
|
ProjectWorkflow projectWorkflow = landOneCodeService.getProjectWorkflowByNodeId(nodeId);
|
|
|
projectId = projectWorkflow.getProjectId();
|
|
|
}
|
|
|
- String rootPath = String.valueOf(nodeAttachment.getAttachment().get("path"));
|
|
|
- logger.info("全文检索根目录路径,rootPath: {}", rootPath);
|
|
|
- //先进行删除
|
|
|
- List<ProjectAttachmentInfo> projectAttachmentInfoList = projectAttachmentInfoMapper.selectByProjectIdNodeId(projectId,nodeId);
|
|
|
- if(CollectionUtils.isNotEmpty(projectAttachmentInfoList)){
|
|
|
- List<String> ids = projectAttachmentInfoList.stream().map(BaseId::getId).collect(Collectors.toList());
|
|
|
- projectAttachmentInfoMapper.deleteByIds(ids);
|
|
|
- }
|
|
|
- //再进行更新
|
|
|
- List<Path> fileList = ServiceFileUtil.getDirectoryFileList(rootPath);
|
|
|
- if(CollectionUtils.isNotEmpty(fileList)){
|
|
|
- for(Path path : fileList){
|
|
|
- ProjectAttachmentInfo projectAttachmentInfo = new ProjectAttachmentInfo();
|
|
|
- projectAttachmentInfo.generateId();
|
|
|
- projectAttachmentInfo.setProjectId(projectId);
|
|
|
- projectAttachmentInfo.setNodeId(nodeId);
|
|
|
- projectAttachmentInfo.setFilePath(path.toString());
|
|
|
- String baseName = FilenameUtils.getBaseName(path.getFileName().toString());
|
|
|
- projectAttachmentInfo.setFileName(baseName);
|
|
|
- projectAttachmentInfoMapper.insert(projectAttachmentInfo);
|
|
|
+ //项目id,在报批数据集成入参时候可能为空,这情况不入库(在确认上链时候入库)
|
|
|
+ if(StringUtils.isNotBlank(projectId)){
|
|
|
+ String rootPath = String.valueOf(nodeAttachment.getAttachment().get("path"));
|
|
|
+ logger.info("全文检索根目录路径,rootPath: {}", rootPath);
|
|
|
+ //先进行删除
|
|
|
+ List<ProjectAttachmentInfo> projectAttachmentInfoList = projectAttachmentInfoMapper.selectByProjectIdNodeId(projectId,nodeId);
|
|
|
+ if(CollectionUtils.isNotEmpty(projectAttachmentInfoList)){
|
|
|
+ List<String> ids = projectAttachmentInfoList.stream().map(BaseId::getId).collect(Collectors.toList());
|
|
|
+ projectAttachmentInfoMapper.deleteByIds(ids);
|
|
|
+ }
|
|
|
+ //再进行更新
|
|
|
+ List<Path> fileList = ServiceFileUtil.getDirectoryFileList(rootPath);
|
|
|
+ if(CollectionUtils.isNotEmpty(fileList)){
|
|
|
+ for(Path path : fileList){
|
|
|
+ ProjectAttachmentInfo projectAttachmentInfo = new ProjectAttachmentInfo();
|
|
|
+ projectAttachmentInfo.generateId();
|
|
|
+ projectAttachmentInfo.setProjectId(projectId);
|
|
|
+ projectAttachmentInfo.setNodeId(nodeId);
|
|
|
+ projectAttachmentInfo.setFilePath(path.toString());
|
|
|
+ String baseName = FilenameUtils.getBaseName(path.getFileName().toString());
|
|
|
+ projectAttachmentInfo.setFileName(baseName);
|
|
|
+ projectAttachmentInfoMapper.insert(projectAttachmentInfo);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
} catch (IOException e) {
|
|
|
throw new ServiceException("全文检索附件材料--保存失败");
|
|
|
}
|