From 1d5345f92dbd4aac2b5f68265921bb2529a71b8e Mon Sep 17 00:00:00 2001
From: bingbing <zhaobingliang@aliyun.com>
Date: Tue, 27 Oct 2020 14:16:21 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into dev
---
kidgrow-business/kidgrow-filecenter/kidgrow-filecenter-biz/src/main/java/com/kidgrow/filecenter/service/impl/AbstractIFileService.java | 266 ++++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 261 insertions(+), 5 deletions(-)
diff --git a/kidgrow-business/kidgrow-filecenter/kidgrow-filecenter-biz/src/main/java/com/kidgrow/filecenter/service/impl/AbstractIFileService.java b/kidgrow-business/kidgrow-filecenter/kidgrow-filecenter-biz/src/main/java/com/kidgrow/filecenter/service/impl/AbstractIFileService.java
index 527487e..33591ab 100644
--- a/kidgrow-business/kidgrow-filecenter/kidgrow-filecenter-biz/src/main/java/com/kidgrow/filecenter/service/impl/AbstractIFileService.java
+++ b/kidgrow-business/kidgrow-filecenter/kidgrow-filecenter-biz/src/main/java/com/kidgrow/filecenter/service/impl/AbstractIFileService.java
@@ -1,21 +1,34 @@
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.util.List;
-import java.util.Map;
+import java.io.*;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.util.*;
/**
* 石家庄喜高科技有限责任公司 版权所有 © Copyright 2020<br>
@@ -28,7 +41,12 @@
@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);
@@ -82,6 +100,9 @@
* @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);
/**
* 删除文件
@@ -110,5 +131,240 @@
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) throws IOException {
+ 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,"pdf/"+newFileName,inputStream);
+ baseMapper.insert(newfileInfo);
+ inputStream.close();
+ 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;
+ }
}
--
Gitblit v1.8.0