package cn.cetc54.platform.base.manager.impl;
|
|
|
import cn.cetc54.platform.base.manager.FileManage;
|
import cn.cetc54.platform.core.common.exception.PlatformException;
|
import cn.cetc54.platform.core.config.properties.OSSProperties;
|
import cn.hutool.core.date.DateUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.*;
|
|
/**
|
* @author x
|
*/
|
@Slf4j
|
@Component
|
public class LocalFileManage implements FileManage {
|
|
@Autowired
|
private OSSProperties ossProperties;
|
|
|
|
@Override
|
@Deprecated
|
public String pathUpload(String filePath, String key) {
|
|
throw new PlatformException("暂不支持");
|
}
|
|
/**
|
* 实则为路径上传
|
* @param inputStream
|
* @param key
|
* @param file
|
* @return
|
*/
|
@Override
|
public String inputStreamUpload(InputStream inputStream, String key, MultipartFile file) {
|
|
String day = DateUtil.format(DateUtil.date(), "yyyyMMdd");
|
String path = ossProperties.getFilePath() + "/" + day;
|
File dir = new File(path);
|
if(!dir.exists()){
|
dir.mkdirs();
|
}
|
File f = new File(path + "/" + key);
|
if(f.exists()){
|
throw new PlatformException("文件名已存在");
|
}
|
try {
|
file.transferTo(f);
|
return path + "/" + key;
|
} catch (IOException e) {
|
log.error(e.toString());
|
throw new PlatformException("上传文件出错");
|
}
|
}
|
|
/**
|
* 注意此处需传入url
|
* @param url
|
* @param toKey
|
* @return
|
*/
|
@Override
|
public String renameFile(String url, String toKey) {
|
|
String result = copyFile(url, toKey);
|
deleteFile(url);
|
return result;
|
}
|
|
/**
|
* 注意此处需传入url
|
* @param url
|
* @param toKey
|
* @return
|
*/
|
@Override
|
public String copyFile(String url, String toKey) {
|
|
File file = new File(url);
|
FileInputStream i = null;
|
FileOutputStream o = null;
|
|
try {
|
i = new FileInputStream(file);
|
o = new FileOutputStream(new File(file.getParentFile() + "/" + toKey));
|
|
byte[] buf = new byte[1024];
|
int bytesRead;
|
|
while ((bytesRead = i.read(buf))>0){
|
o.write(buf, 0, bytesRead);
|
}
|
|
i.close();
|
o.close();
|
return file.getParentFile() + "/" + toKey;
|
} catch (IOException e) {
|
log.error(e.toString());
|
throw new PlatformException("复制文件出错");
|
}
|
}
|
|
/**
|
* 注意此处需传入url
|
* @param url
|
*/
|
@Override
|
public void deleteFile(String url) {
|
|
File file = new File(url);
|
if (file.exists()) {
|
file.delete();
|
}
|
}
|
|
/**
|
* 读取文件
|
* @param url
|
* @param response
|
*/
|
public static void view(String url, HttpServletResponse response){
|
|
File file = new File(url);
|
FileInputStream in = null;
|
OutputStream out = null;
|
|
try {
|
if (file.exists()) {
|
in = new FileInputStream(file);
|
out = response.getOutputStream();
|
|
byte[] buf = new byte[1024];
|
int bytesRead;
|
|
while ((bytesRead = in.read(buf)) > 0) {
|
out.write(buf, 0, bytesRead);
|
out.flush();
|
}
|
}
|
} catch (IOException e) {
|
|
} finally {
|
if(out!=null){
|
try {
|
in.close();
|
out.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
}
|
}
|
