| | |
| | | } |
| | | Collection<FileObject> fileObjects = listByIds(oids); |
| | | if(!CollectionUtils.isEmpty(fileObjects)){ |
| | | VciBaseUtil.switchCollectionForOracleIn(fileObjects).stream().forEach(fileDOs->{ |
| | | VciBaseUtil.switchCollectionForOracleIn(fileObjects).parallelStream().forEach(fileDOs->{ |
| | | fileObjectMapper.deleteBatchIds(fileDOs.stream().map(FileObject::getOid).collect(Collectors.toList())); |
| | | }); |
| | | //删除minio里的文件,这儿多条记录删除使用parallelStream多线程时可能会出现tennantId无法拼接上的问题,所以还是用Stream |
| | |
| | | fileObject.setObjectName(bladeFile.getName()); |
| | | fileObject.setFileLink(bladeFile.getLink()); |
| | | // 添加之前赋默认值 |
| | | DefaultAttrAssimtUtil.addDefaultAttrAssimt(fileObject, MdmBtmTypeConstant.FILE_OBJECT); |
| | | DefaultAttrAssimtUtil.addDefaultAttrAssimt(fileObject, MdmBtmTypeConstant.FILE_OBJECT,null); |
| | | fileObjectMapper.insert(fileObject); |
| | | if(log.isDebugEnabled()){ |
| | | log.debug("新增文件",fileObject.toString()); |