Source/UBCS/ubcs-ops/ubcs-resource/src/main/java/com/vci/ubcs/resource/service/impl/FileServiceImpl.java

@@ -17,6 +17,8 @@
import com.vci.ubcs.resource.utils.ZipUtil;
import com.vci.ubcs.resource.vo.FileObjectVO;
import com.vci.ubcs.starter.exception.VciBaseException;
import com.vci.ubcs.starter.util.DefaultAttrAssimtUtil;
import com.vci.ubcs.starter.util.MdmBtmTypeConstant;
import com.vci.ubcs.starter.web.enumpck.BaseEnum;
import com.vci.ubcs.starter.web.enumpck.UserSecretEnum;
import com.vci.ubcs.starter.web.util.BeanUtil;
@@ -173,7 +175,7 @@
     * @return 执行结果
     */
    @Override
    @Transactional()
    @Transactional(rollbackFor = Exception.class)
    public void deleteFiles(Collection<String> oids) {
        VciBaseUtil.alertNotNull(oids,"文件的主键集合");
        if(log.isDebugEnabled()){
@@ -182,16 +184,15 @@
        Collection<FileObject> fileObjects = listByIds(oids);
        if(!CollectionUtils.isEmpty(fileObjects)){
            VciBaseUtil.switchCollectionForOracleIn(fileObjects).stream().forEach(fileDOs->{
                fileObjectMapper.deleteBatchIds(fileDOs.stream().map(FileObject::getId).collect(Collectors.toList()));
                fileObjectMapper.deleteBatchIds(fileDOs.stream().map(FileObject::getOid).collect(Collectors.toList()));
            });
            //删除minio里的文件
         fileObjects.parallelStream().forEach(fileObject -> {
            //删除minio里的文件,这儿多条记录删除使用parallelStream多线程时可能会出现tennantId无法拼接上的问题，所以还是用Stream
         fileObjects.stream().forEach(fileObject -> {
            ossTemplate.removeFile(fileObject.getBucketName(),fileObject.getObjectName());
         });

        }
    }



    /**
     * 上传文件
@@ -277,6 +278,8 @@
      fileObject.setBucketName(bucketName);
      fileObject.setObjectName(bladeFile.getName());
      fileObject.setFileLink(bladeFile.getLink());
      // 添加之前赋默认值
      DefaultAttrAssimtUtil.addDefaultAttrAssimt(fileObject, MdmBtmTypeConstant.FILE_OBJECT);
      fileObjectMapper.insert(fileObject);
      if(log.isDebugEnabled()){
         log.debug("新增文件",fileObject.toString());
@@ -284,8 +287,6 @@
      FileObjectVO fileObjectVO = do2Vo(fileObject);
      return fileObjectVO;
   }



   /**
     * 数据对象转显示对象
@@ -403,7 +404,6 @@
        });
        return R.data(do2Vos(fileObjectMap.values()));
    }


    /**
     * 文件列表查询