package com.kidgrow.filecenter.service.impl;
|
|
import cn.hutool.core.util.IdUtil;
|
import com.aliyun.oss.model.OSSObject;
|
import com.aliyun.oss.model.ObjectMetadata;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.kidgrow.common.constant.CommonConstant;
|
import com.kidgrow.common.model.PageResult;
|
import com.kidgrow.common.model.ResultBody;
|
import com.kidgrow.common.utils.DateUtil;
|
import com.kidgrow.common.utils.RandomValueUtils;
|
import com.kidgrow.common.utils.StringUtils;
|
import com.kidgrow.filecenter.mapper.FileMapper;
|
import com.kidgrow.filecenter.model.FileInfo;
|
import com.kidgrow.filecenter.service.IFileService;
|
import com.kidgrow.filecenter.util.FileUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import net.coobird.thumbnailator.Thumbnails;
|
import org.apache.commons.collections4.MapUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.web.multipart.MultipartFile;
|
import sun.misc.BASE64Decoder;
|
import sun.misc.BASE64Encoder;
|
|
import java.io.*;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
import java.util.*;
|
|
/**
|
* 石家庄喜高科技有限责任公司 版权所有 © Copyright 2020<br>
|
*
|
* @Description: <br>
|
* @Project: <br>
|
* @CreateDate: Created in 2020/2/18 11:24 <br>
|
* @Author: <a href="4345453@kidgrow.com">liuke</a>
|
*/
|
@Slf4j
|
public abstract class AbstractIFileService extends ServiceImpl<FileMapper, FileInfo> implements IFileService {
|
private static final String FILE_SPLIT = ".";
|
private static Logger logger = LoggerFactory.getLogger(AbstractIFileService.class);
|
|
@Value("${kidgrow.file-server.oss.domain}")
|
private String DOMAIN;
|
@Value("${spring.profiles.active}")
|
private String OssPathEn;
|
@Override
|
public FileInfo upload(MultipartFile file) throws Exception {
|
FileInfo fileInfo = FileUtil.getFileInfo(file);
|
FileInfo oldFileInfo = baseMapper.selectById(fileInfo.getId());
|
if (oldFileInfo != null) {
|
return oldFileInfo;
|
}
|
if (!fileInfo.getName().contains(FILE_SPLIT)) {
|
throw new IllegalArgumentException("缺少后缀名");
|
}
|
uploadFile(file, fileInfo);
|
// 设置文件来源
|
fileInfo.setSource(fileType());
|
// 将文件信息保存到数据库
|
baseMapper.insert(fileInfo);
|
|
return fileInfo;
|
}
|
|
@Override
|
public FileInfo upload(MultipartFile file,String imgType) throws Exception {
|
FileInfo fileInfo = FileUtil.getFileInfo(file);
|
FileInfo oldFileInfo = baseMapper.selectById(fileInfo.getId());
|
if (oldFileInfo != null) {
|
return oldFileInfo;
|
}
|
if (!fileInfo.getName().contains(FILE_SPLIT)) {
|
throw new IllegalArgumentException("缺少后缀名");
|
}
|
fileInfo.setImgType(imgType); // X光片或者Logo
|
uploadFile(file, fileInfo);
|
// 设置文件来源
|
fileInfo.setSource(fileType());
|
// 将文件信息保存到数据库
|
baseMapper.insert(fileInfo);
|
|
return fileInfo;
|
}
|
|
/**
|
* 文件来源
|
*
|
* @return
|
*/
|
protected abstract String fileType();
|
|
/**
|
* 上传文件
|
*
|
* @param file
|
* @param fileInfo
|
*/
|
protected abstract void uploadFile(MultipartFile file, FileInfo fileInfo) throws Exception;
|
protected abstract void fileUpLoadOss(FileInfo fileInfo,String newFilePath, InputStream fileStream);
|
protected abstract String FilePath(String imgType,String folderByDate,String hospitalId,String departmentId);
|
protected abstract OSSObject down(String url);
|
|
/**
|
* 删除文件
|
* @param id 文件id
|
*/
|
@Override
|
public void delete(String id) {
|
FileInfo fileInfo = baseMapper.selectById(id);
|
if (fileInfo != null) {
|
baseMapper.deleteById(fileInfo.getId());
|
this.deleteFile(fileInfo);
|
}
|
}
|
|
/**
|
* 删除文件资源
|
*
|
* @param fileInfo
|
* @return
|
*/
|
protected abstract boolean deleteFile(FileInfo fileInfo);
|
|
@Override
|
public PageResult<FileInfo> findList(Map<String, Object> params) {
|
Page<FileInfo> page = new Page<>(MapUtils.getInteger(params, "page"), MapUtils.getInteger(params, "limit"));
|
List<FileInfo> list = baseMapper.findList(page, params);
|
return PageResult.<FileInfo>builder().data(list).code(0).count(page.getTotal()).build();
|
}
|
/**
|
* 上传图片-并缩略，其实是给文件服务器存储了两个文件 一个原文件 一个缩略图文件
|
* @param file form内的文件数据
|
* @param imgType 业务类型 例如logo
|
* @return 返回的实体中 path字段保存的是缩略图地址
|
* @throws Exception
|
*/
|
@Override
|
public FileInfo uploadForThumbnails(MultipartFile file, String imgType) throws Exception {
|
FileInfo fileInfo=this.upload(file,imgType);
|
List<String> lassStr= Arrays.asList("png","bmp","dib","gif","jfif","jpe","jpeg","jpg","tif","tiff","ico");
|
String suffix=file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf(".")+1);
|
if(!lassStr.contains(suffix)){
|
return null;
|
}
|
if (StringUtils.isNotBlank(fileInfo.getUrl())) {
|
//生成缩略图上传
|
// File nowFile= MultipartFileUtils.multipartFileToFile(file);
|
// File nowFile= new File(file.getOriginalFilename());
|
//暂存目录 发布后真实存在的磁盘目录
|
String result = CommonConstant.TEMP_IMAGE_PATH;
|
//文件扩展名
|
String newFileName= RandomValueUtils.uuid()+"."+suffix;
|
//生成缩略图
|
Thumbnails.of(file.getInputStream()).size(CommonConstant.TH_IMG_WIDTH, CommonConstant.TH_IMG_HEIGHT).toFile(result+newFileName);
|
File thuFile= new File(result+newFileName);
|
if (thuFile.exists()) {
|
//将生成的文件转换为流
|
InputStream inputStream=new FileInputStream(thuFile);
|
String folderByDate = DateUtil.formatDate(new Date());
|
String filefloder=this.FilePath(imgType,folderByDate,null,null);
|
FileInfo newfileInfo=new FileInfo();
|
newfileInfo.setName(newFileName);
|
newfileInfo.setId(IdUtil.fastSimpleUUID());
|
newfileInfo.setSize(thuFile.length());
|
newfileInfo.setIsImg(true);
|
newfileInfo.setContentType(file.getContentType());
|
newfileInfo.setSource(fileInfo.getSource());
|
newfileInfo.setImgType(imgType);
|
newfileInfo.setCreateTime(new Date());
|
//文件上传到oss
|
this.fileUpLoadOss(newfileInfo,filefloder+newFileName,inputStream);
|
inputStream.close();
|
// //删除暂存文件
|
// MultipartFileUtils.delteTempFile(thuFile);
|
boolean delete = thuFile.delete();
|
|
// 将文件信息保存到数据库
|
baseMapper.insert(newfileInfo);
|
fileInfo.setPath(newfileInfo.getUrl());
|
}
|
return fileInfo;
|
}
|
else
|
{
|
return fileInfo;
|
}
|
}
|
|
@Override
|
public FileInfo baseUplaod(String file, String imgType, String hospitalId, String departmentId) {
|
if(file==null||"".equals(file.trim())){
|
return null;
|
}
|
String name=file.split(",")[0];
|
file = file.split(",")[1];
|
BASE64Decoder decoder = new BASE64Decoder();
|
try {
|
byte[] bytes = decoder.decodeBuffer(file);
|
ObjectMetadata objectMeta = new ObjectMetadata();
|
objectMeta.setContentLength(file.length());
|
//将字节码转换成流
|
InputStream input = new ByteArrayInputStream(bytes);
|
String fileName= UUID.randomUUID().toString().replaceAll("-","");
|
//image/jpeg;base64
|
String newFileName=fileName+"."+name.substring(name.lastIndexOf("/")+1,name.lastIndexOf(";"));
|
FileInfo newfileInfo=new FileInfo();
|
newfileInfo.setName(newFileName);
|
newfileInfo.setId(IdUtil.fastSimpleUUID());
|
newfileInfo.setSize(file.length());
|
newfileInfo.setIsImg(true);
|
newfileInfo.setContentType("image/jpeg");
|
newfileInfo.setSource("aliyun");
|
newfileInfo.setImgType(imgType);
|
newfileInfo.setCreateTime(new Date());
|
String folderByDate =DateUtil.formatDate(new Date());
|
String filePath = FilePath(imgType, folderByDate, hospitalId, departmentId);
|
this.fileUpLoadOss(newfileInfo,filePath+newFileName,input);
|
input.close();
|
baseMapper.insert(newfileInfo);
|
return newfileInfo;
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
@Override
|
public ResultBody baseDownLoad(Map<String, Object> map) throws Exception {
|
String urlDiZhi=MapUtils.getString(map,"url");
|
if(!urlDiZhi.contains(DOMAIN)){
|
ByteArrayOutputStream outPut = new ByteArrayOutputStream();
|
byte[] data = new byte[1024];
|
try {
|
// 创建URL
|
URL url = new URL(urlDiZhi);
|
// 创建链接
|
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
|
conn.setRequestMethod("GET");
|
conn.setConnectTimeout(10 * 1000);
|
InputStream inStream = conn.getInputStream();
|
int len = -1;
|
while ((len = inStream.read(data)) != -1) {
|
outPut.write(data, 0, len);
|
}
|
inStream.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
String substring = urlDiZhi.substring(urlDiZhi.lastIndexOf(".") + 1, urlDiZhi.length());
|
String str="data:image/" + substring + ";base64,";
|
// 对字节数组Base64编码
|
BASE64Encoder encoder = new BASE64Encoder();
|
System.out.println(encoder.encode(outPut.toByteArray()));
|
return ResultBody.ok().data(str+encoder.encode(outPut.toByteArray()).replaceAll("\n", "").replaceAll("\r", ""));
|
}else {
|
List<FileInfo> fileInfos = baseMapper.selectByMap(map);
|
if (fileInfos.size() > 0) {
|
FileInfo fileInfo = fileInfos.get(0);
|
OSSObject down = this.down(fileInfo.getUrl().replace(DOMAIN, ""));
|
InputStream objectContent = down.getObjectContent();
|
//返回Base64编码过的字节数组字符串
|
byte[] data = null;
|
// 读取图片字节数组
|
try {
|
ByteArrayOutputStream swapStream = new ByteArrayOutputStream();
|
byte[] buff = new byte[100];
|
int rc = 0;
|
while ((rc = objectContent.read(buff, 0, 100)) > 0) {
|
swapStream.write(buff, 0, rc);
|
}
|
data = swapStream.toByteArray();
|
} catch (IOException e) {
|
e.printStackTrace();
|
} finally {
|
if (objectContent != null) {
|
try {
|
objectContent.close();
|
down.close();
|
} catch (IOException e) {
|
throw new Exception("输入流关闭异常");
|
}
|
}
|
}
|
String encode = "data:" + fileInfo.getContentType() + ";base64," + Base64.getEncoder().encodeToString(data);
|
return ResultBody.ok().data(encode);
|
} else {
|
return ResultBody.failed("获取数据失败");
|
}
|
}
|
}
|
|
public static void main(String[] args) {
|
|
ByteArrayOutputStream outPut = new ByteArrayOutputStream();
|
byte[] data = new byte[1024];
|
try {
|
// 创建URL
|
URL url = new URL("http://192.168.2.25:8008/123/J-1.jpg");
|
// 创建链接
|
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
|
conn.setRequestMethod("GET");
|
conn.setConnectTimeout(10 * 1000);
|
InputStream inStream = conn.getInputStream();
|
int len = -1;
|
while ((len = inStream.read(data)) != -1) {
|
outPut.write(data, 0, len);
|
}
|
inStream.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
// 对字节数组Base64编码
|
BASE64Encoder encoder = new BASE64Encoder();
|
System.out.println(encoder.encode(outPut.toByteArray()));
|
|
}
|
|
@Override
|
public FileInfo byteUplaod(String fileName, InputStream inputStream,int size) {
|
String houzhui=fileName.substring(fileName.lastIndexOf(".")+1);
|
String newFileName= RandomValueUtils.uuid()+"."+houzhui;
|
FileInfo newfileInfo=new FileInfo();
|
newfileInfo.setName(newFileName);
|
newfileInfo.setId(IdUtil.fastSimpleUUID());
|
newfileInfo.setSize(size);
|
newfileInfo.setIsImg(false);
|
newfileInfo.setContentType("byte[]");
|
newfileInfo.setSource("aliyun");
|
newfileInfo.setImgType(houzhui);
|
newfileInfo.setCreateTime(new Date());
|
this.fileUpLoadOss(newfileInfo,OssPathEn.trim()+"pdf/"+newFileName,inputStream);
|
baseMapper.insert(newfileInfo);
|
return newfileInfo;
|
}
|
|
@Override
|
public FileInfo feignUploadHosIdAndDepId(MultipartFile file, String imgType, String hospitalId, String departmentId) throws Exception {
|
List<String> lassStr= Arrays.asList("png","bmp","dib","gif","jfif","jpe","jpeg","jpg","tif","tiff","ico");
|
String suffix=file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf(".")+1);
|
if(!lassStr.contains(suffix)){
|
return null;
|
}
|
String name = file.getOriginalFilename();
|
String fileName= UUID.randomUUID().toString().replaceAll("-","");
|
//image/jpeg;base64
|
String newFileName=fileName+name.substring(name.lastIndexOf("."));
|
FileInfo newfileInfo=new FileInfo();
|
newfileInfo.setName(newFileName);
|
newfileInfo.setId(IdUtil.fastSimpleUUID());
|
newfileInfo.setSize(file.getSize());
|
newfileInfo.setIsImg(true);
|
newfileInfo.setContentType("image/jpeg");
|
newfileInfo.setSource("aliyun");
|
newfileInfo.setImgType(imgType);
|
newfileInfo.setCreateTime(new Date());
|
String folderByDate =DateUtil.formatDate(new Date());
|
String filePath = FilePath(imgType, folderByDate, hospitalId, departmentId);
|
InputStream inputStream = file.getInputStream();
|
this.fileUpLoadOss(newfileInfo,filePath+newFileName,inputStream);
|
inputStream.close();
|
baseMapper.insert(newfileInfo);
|
return newfileInfo;
|
}
|
}
|
