From 5f69a549add739b190f46ba7d035e2fe31390e01 Mon Sep 17 00:00:00 2001
From: zhaoxiaohao <913652501@qq.com>
Date: Fri, 17 Jul 2020 09:39:04 +0800
Subject: [PATCH] 添加修改密码的加密的功能

---
 kidgrow-business/kidgrow-filecenter/kidgrow-filecenter-biz/src/main/java/com/kidgrow/filecenter/service/impl/AbstractIFileService.java |   71 +++++++++++++++++++++++++++++------
 1 files changed, 59 insertions(+), 12 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 638d6a0..eb8531c 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,11 +1,13 @@
 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.MultipartFileUtils;
 import com.kidgrow.common.utils.RandomValueUtils;
@@ -17,15 +19,13 @@
 import lombok.extern.slf4j.Slf4j;
 import net.coobird.thumbnailator.Thumbnails;
 import org.apache.commons.collections4.MapUtils;
-import org.springframework.http.MediaType;
 import org.springframework.web.multipart.MultipartFile;
 import sun.misc.BASE64Decoder;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.io.*;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
-import java.util.UUID;
+import java.util.*;
 
 /**
  * 石家庄喜高科技有限责任公司 版权所有 © Copyright 2020<br>
@@ -38,6 +38,7 @@
 @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);
 
     @Override
     public FileInfo upload(MultipartFile file) throws Exception {
@@ -94,6 +95,7 @@
     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);
+    protected abstract OSSObject down(String url);
 
     /**
      * 删除文件
@@ -132,20 +134,25 @@
     @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= MultipartFileUtils.multipartFileToFile(file);
+//            File nowFile= new File(file.getOriginalFilename());
             //暂存目录  发布后真实存在的磁盘目录
             String result = CommonConstant.TEMP_IMAGE_PATH;
             //文件扩展名
-            String suffix=file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
-            String newFileName= RandomValueUtils.uuid()+suffix;
+            String newFileName= RandomValueUtils.uuid()+"."+suffix;
             //生成缩略图
-            Thumbnails.of(nowFile).size(CommonConstant.TH_IMG_WIDTH, CommonConstant.TH_IMG_HEIGHT).toFile(result+newFileName);
+            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(new File(result+newFileName));
+                InputStream inputStream=new FileInputStream(thuFile);
                 String folderByDate = DateUtil.formatDate(new Date());
                 String filefloder=this.FilePath(imgType,folderByDate);
                 FileInfo newfileInfo=new FileInfo();
@@ -160,8 +167,10 @@
                 //文件上传到oss
                 this.fileUpLoadOss(newfileInfo,filefloder+newFileName,inputStream);
                 inputStream.close();
-                //删除暂存文件
-                MultipartFileUtils.delteTempFile(thuFile);
+//                //删除暂存文件
+//                MultipartFileUtils.delteTempFile(thuFile);
+                boolean delete = thuFile.delete();
+
                 // 将文件信息保存到数据库
                 baseMapper.insert(newfileInfo);
                 fileInfo.setPath(newfileInfo.getUrl());
@@ -209,5 +218,43 @@
         }
         return null;
     }
+
+    @Override
+    public ResultBody baseDownLoad(Map<String, Object> map) throws Exception {
+        List<FileInfo> fileInfos = baseMapper.selectByMap(map);
+        if(fileInfos.size()>0){
+            FileInfo fileInfo = fileInfos.get(0);
+            OSSObject down1 = this.down(fileInfo.getUrl().replace("https://kidgrow.oss-accelerate.aliyuncs.com/",""));
+            InputStream objectContent = down1.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();
+                        down1.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("获取数据失败");
+        }
+    }
+
 }
 

--
Gitblit v1.8.0