ludc
2023-12-05 b40cd8c94978d43f9d13ba9ee93a4164b68a8165
Source/UBCS/ubcs-ops/ubcs-resource/src/main/java/com/vci/ubcs/resource/service/impl/FileServiceImpl.java
@@ -183,7 +183,7 @@
        }
        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
@@ -279,7 +279,7 @@
      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());