package com.iplatform.file;
|
|
import com.iplatform.base.ArgumentsConstants;
|
import com.iplatform.base.Constants;
|
import com.iplatform.base.FileOperateSpi;
|
import com.iplatform.base.config.FileProperties;
|
import com.iplatform.core.BeanContextAware;
|
import com.iplatform.file.util.FileStoreUtils;
|
import com.walker.file.FileInfo;
|
import com.walker.file.FileStoreType;
|
import com.walker.infrastructure.arguments.ArgumentsManager;
|
import com.walker.infrastructure.arguments.ElementNotFoundException;
|
import com.walker.infrastructure.arguments.Variable;
|
import com.walker.infrastructure.utils.StringUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import java.io.InputStream;
|
import java.util.List;
|
|
/**
|
* 默认的文件操作服务提供者实现。
|
* @author 时克英
|
* @date 2023-02-15
|
*/
|
public class DefaultFileOperateSpi implements FileOperateSpi {
|
|
protected final transient Logger logger = LoggerFactory.getLogger(getClass());
|
|
private static final int FILE_CONTEXT_LENGTH = Constants.FILE_CONTEXT_PATH.length();
|
|
/**
|
* 清除给定文件地址的CDN前缀。如：https://qnyun.com/oss/12345678
|
* <pre>
|
* 去掉前缀后，只剩下"12345678"
|
* </pre>
|
* @param path 给定的文件资源地址
|
* @return
|
* @date 2023-05-17
|
*/
|
@Override
|
public String clearCdnPrefix(String path){
|
if(StringUtils.isEmpty(path)){
|
return path;
|
}
|
|
// 如果URL路径中包含本地识别部分（/file/）则直接替换，2023-06-10
|
int fileIndex = path.indexOf(Constants.FILE_CONTEXT_PATH);
|
if(fileIndex > 0){
|
return path.substring(fileIndex + FILE_CONTEXT_LENGTH, path.length());
|
}
|
|
// 如果是其他远程存储方式，则根据存储类型分别获取配置前缀
|
String prefix = this.getCdnUrl() + StringUtils.FOLDER_SEPARATOR;
|
if(!prefix.endsWith(StringUtils.FOLDER_SEPARATOR)){
|
prefix += StringUtils.FOLDER_SEPARATOR;
|
}
|
if(path.contains(prefix)){
|
if (path.contains("callback/alipay")) {
|
return path;
|
}
|
return path.replace(prefix, StringUtils.EMPTY_STRING);
|
}
|
return path;
|
}
|
|
/**
|
* 获取上传文件的CDN地址，根据使用的不同第三方服务从配置中查找。
|
* @return
|
* @date 2023-05-17
|
*/
|
@Override
|
public String getCdnUrl(){
|
Variable uploadTypeVar = this.acquireArgumentsManager().getVariable(ArgumentsConstants.CONFIG_UPLOAD_TYPE);
|
if(uploadTypeVar == null){
|
throw new ElementNotFoundException("参数未找到：" + ArgumentsConstants.CONFIG_UPLOAD_TYPE);
|
}
|
|
String uploadUrl = null;
|
String uploadType = uploadTypeVar.getStringValue();
|
// if(uploadType.equals("1") || uploadType.equals(FileStoreType.INDEX_FS)){
|
// uploadUrl = ArgumentsConstants.CONFIG_LOCAL_UPLOAD_URL;
|
// } else if(uploadType.equals("2") || uploadType.equals(FileStoreType.INDEX_OSS_QI_NIU)){
|
// uploadUrl = ArgumentsConstants.CONFIG_QN_UPLOAD_URL;
|
// } else if(uploadType.equals("3") || uploadType.equals(FileStoreType.INDEX_OSS_ALI)){
|
// uploadUrl = ArgumentsConstants.CONFIG_AL_UPLOAD_URL;
|
// } else if(uploadType.equals("4") || uploadType.equals(FileStoreType.INDEX_OSS_TX)){
|
// uploadUrl = ArgumentsConstants.CONFIG_TX_UPLOAD_URL;
|
// } else {
|
// throw new UnsupportedOperationException("不支持的上传类型：" + uploadType);
|
// }
|
uploadUrl = FileStoreUtils.getFileUrlPrefixKey(uploadType);
|
return this.acquireArgumentsManager().getVariable(uploadUrl).getStringValue();
|
}
|
|
/**
|
* 上传文件你到本地磁盘。
|
* @param inputStream
|
* @param fileName
|
* @param groupId
|
* @param fileSize
|
* @param businessType
|
* @param owner
|
* @return
|
* @throws Exception
|
* @date 2023-06-09
|
*/
|
@Override
|
public FileInfo uploadFileToLocal(InputStream inputStream
|
, String fileName, String groupId, long fileSize, Integer businessType, String owner) throws Exception{
|
return this.acquireFileEngineFactory().uploadFileToLocal(inputStream, fileName, groupId, fileSize, businessType, owner);
|
}
|
|
@Override
|
public FileInfo[] uploadFileToLocal(InputStream[] inputStream, String[] fileName, String groupId, long[] fileSize, Integer businessType, String owner) throws Exception {
|
return this.acquireFileEngineFactory().uploadFileToLocal(inputStream, fileName, groupId, fileSize, businessType, owner);
|
}
|
|
@Override
|
public FileInfo uploadFileToFtp(InputStream inputStream
|
, String fileName, String groupId, long fileSize, Integer businessType, String owner) throws Exception{
|
return this.acquireFileEngineFactory().uploadFileToFtp(inputStream, fileName, groupId, fileSize, businessType, owner);
|
}
|
|
@Override
|
public FileInfo[] uploadFileToFtp(InputStream[] inputStream, String[] fileName, String groupId, long[] fileSize, Integer businessType, String owner) throws Exception {
|
return this.acquireFileEngineFactory().uploadFileToFtp(inputStream, fileName, groupId, fileSize, businessType, owner);
|
}
|
|
@Override
|
public FileInfo uploadFileToOss(InputStream inputStream
|
, String fileName, String groupId, long fileSize, Integer businessType, String owner, FileStoreType ossType) throws Exception{
|
return this.acquireFileEngineFactory().uploadFileToOss(inputStream, fileName, groupId, fileSize, businessType, owner, ossType);
|
}
|
|
@Override
|
public FileInfo[] uploadFileToOss(InputStream[] inputStream, String[] fileName, String groupId, long[] fileSize, Integer businessType, String owner, FileStoreType ossType) throws Exception {
|
return this.acquireFileEngineFactory().uploadFileToOss(inputStream, fileName, groupId, fileSize, businessType, owner, ossType);
|
}
|
|
@Deprecated
|
@Override
|
public FileInfo uploadFileToSystem(InputStream inputStream, String fileName, String groupId, long fileSize) throws Exception {
|
return this.acquireFileEngineFactory().uploadFileToSystem(inputStream, fileName, groupId, fileSize);
|
}
|
|
@Deprecated
|
@Override
|
public FileInfo uploadFileToFtp(InputStream inputStream, String fileName, String groupId, long fileSize) throws Exception {
|
return this.acquireFileEngineFactory().uploadFileToFtp(inputStream, fileName, groupId, fileSize);
|
}
|
|
@Override
|
public FileInfo getFileInfo(long id) {
|
return this.acquireFileEngineFactory().getFileInfo(String.valueOf(id));
|
}
|
|
@Override
|
public List<FileInfo> getFileInfoList(List<String> ids) {
|
return this.acquireFileEngineFactory().getFileInfoList(ids);
|
}
|
|
@Override
|
public String getFileRootConfig() {
|
if(this.localFileRoot == null){
|
this.localFileRoot = this.getFileProperties().getFileRoot();
|
}
|
return this.localFileRoot;
|
}
|
|
@Override
|
public boolean isRemoteAsLocal() {
|
if(this.remoteAsLocal == null){
|
this.remoteAsLocal = this.getFileProperties().isRemoteAsLocal();
|
}
|
return this.remoteAsLocal;
|
}
|
|
private FileProperties getFileProperties(){
|
return BeanContextAware.getBeanByType(FileProperties.class);
|
}
|
|
private FileEngineFactory acquireFileEngineFactory(){
|
return BeanContextAware.getBeanByType(FileEngineFactory.class);
|
}
|
|
/**
|
* 引入参数配置管理器。
|
* @date 2023-05-17
|
*/
|
private ArgumentsManager acquireArgumentsManager(){
|
return BeanContextAware.getBeanByType(ArgumentsManager.class);
|
}
|
|
private Boolean remoteAsLocal = null;
|
private String localFileRoot = null;
|
|
// /**
|
// * 引入参数配置管理器。
|
// * @param argumentsManager
|
// * @date 2023-05-17
|
// */
|
// public void setArgumentsManager(ArgumentsManager argumentsManager) {
|
// this.argumentsManager = argumentsManager;
|
// }
|
//
|
// private ArgumentsManager argumentsManager;
|
}
|
