| | |
| | | package com.iplatform.file; |
| | | |
| | | import com.iplatform.base.PlatformRuntimeException; |
| | | import com.iplatform.file.util.FileStoreUtils; |
| | | import com.walker.file.FileInfo; |
| | | import com.walker.file.FileOperateEngine; |
| | |
| | | public class FileEngineFactory implements ApplicationBeanInitialized { |
| | | |
| | | protected final transient Logger logger = LoggerFactory.getLogger(this.getClass()); |
| | | |
| | | /** |
| | | * 下载oss文件 |
| | | * @param fileStoreType |
| | | * @param id 文件唯一编号 |
| | | * @return |
| | | * @date 2023-12-13 |
| | | */ |
| | | public byte[] downloadOssFile(FileStoreType fileStoreType, String id){ |
| | | try { |
| | | return this.fileOperateEngineMap.get(fileStoreType).downloadFile(id); |
| | | } catch (FileOperateException e) { |
| | | throw new PlatformRuntimeException("下载oss文件错误:" + e.getMessage() + ", id=" + id, e); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 根据文件ID,返回文件对象。 |
| | |
| | | public FileInfo uploadFileToOss(InputStream inputStream, String fileName, String groupId |
| | | , long fileSize, Integer businessType, String owner, FileStoreType fileStoreType) throws FileOperateException{ |
| | | if(fileStoreType != FileStoreType.OssQiNiu |
| | | && fileStoreType != FileStoreType.OssTx && fileStoreType != FileStoreType.OssAli){ |
| | | && fileStoreType != FileStoreType.OssTx && fileStoreType != FileStoreType.OssAli |
| | | && fileStoreType != FileStoreType.OssAws){ |
| | | throw new UnsupportedOperationException("不支持的OSS类型:" + fileStoreType); |
| | | } |
| | | if(this.remoteAsLocal){ |
| | |
| | | public FileInfo[] uploadFileToOss(InputStream[] inputStream, String[] fileName, String groupId |
| | | , long[] fileSize, Integer businessType, String owner, FileStoreType fileStoreType) throws FileOperateException{ |
| | | if(fileStoreType != FileStoreType.OssQiNiu |
| | | && fileStoreType != FileStoreType.OssTx && fileStoreType != FileStoreType.OssAli){ |
| | | && fileStoreType != FileStoreType.OssTx && fileStoreType != FileStoreType.OssAli |
| | | && fileStoreType != FileStoreType.OssAws){ |
| | | throw new UnsupportedOperationException("不支持的OSS类型:" + fileStoreType); |
| | | } |
| | | if(this.remoteAsLocal){ |