package com.ruoyi.common.qiniu;

import com.qiniu.storage.UploadManager;
import com.qiniu.util.Auth;
import com.ruoyi.common.utils.StringUtils;
import net.coobird.thumbnailator.Thumbnails;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;
import java.io.*;
import java.math.BigInteger;
import java.security.MessageDigest;

/**
 * 七牛云文件存储服务
 * @author Wzp
 */
@Component
public class QiNiuUploadUtils {

    private final Logger logger = LoggerFactory.getLogger(this.getClass());

    /** 磁盘图片配置 */
    @Resource
    private QiNiuConfig qiNiuConfig;

    /** 上传对象 */
    private UploadManager uploadManager;

    /** 上传凭证 */
    private Auth auth;

//    /**
//     * 初始化上传对象
//     */
//    protected void init(){
//        //构造一个带指定 Region 对象的配置类
//        Configuration cfg = new Configuration(Region.huanan());
//        // 指定分片上传版本
//        cfg.resumableUploadAPIVersion = Configuration.ResumableUploadAPIVersion.V2;
//        this.uploadManager = new UploadManager(cfg);
//        // 获取token凭证对象
//        this.auth = Auth.create(qiNiuConfig.getAccessKey(), qiNiuConfig.getSecretKey());
//    }

    // /**
    //  * 上传字节数组
    //  * @param uploadBytes 字节数组数据
    //  * @return 结果
    //  */
    // public String  uploadByte(byte[] uploadBytes, String key){
    //     String fileUrl = "";
    //     File outputFile = new File(qiNiuConfig.getImgFolderUrl()+"/"+key);
    //     try (FileOutputStream fos = new FileOutputStream(outputFile)) {
    //         fos.write(uploadBytes);
    //     } catch (IOException e) {
    //         e.printStackTrace();
    //         logger.error(e.getMessage());
    //     }finally {
    //         fileUrl = qiNiuConfig.getLocalBaseUrl()+key;
    //         return fileUrl;
    //     }
    // }
    //
    // /**
    //  * 数据流上传
    //  * @param inputStream 数据流
    //  * @return 结果
    //  */
    // public String uploadInputStream(InputStream inputStream,String key) {
    //     String url = "";
    //
    //     File outputFile = new File(qiNiuConfig.getImgFolderUrl()+"/"+key);
    //
    //     try (FileOutputStream outputStream = new FileOutputStream(outputFile)) {
    //         byte[] buffer = new byte[4096];
    //         int bytesRead;
    //         while ((bytesRead = inputStream.read(buffer)) != -1) {
    //             outputStream.write(buffer, 0, bytesRead);
    //         }
    //     } catch (FileNotFoundException e) {
    //         logger.error(e.getMessage());
    //         throw new RuntimeException(e);
    //     } catch (IOException e) {
    //         logger.error(e.getMessage());
    //         throw new RuntimeException(e);
    //     }finally {
    //         url = qiNiuConfig.getLocalBaseUrl()+key;
    //         return url;
    //     }
    //
    // }
    //
    //
    //
    // /**
    //  * 获取文件上传名称
    //  * @param file 文件
    //  * @return 结果
    //  */
    // public String getFileUploadName(MultipartFile file){
    //     // 上传文件名
    //     String fileName = "";
    //     try {
    //         // 文件真实名称
    //         String originalFilename = file.getOriginalFilename();
    //         if (StringUtils.isNotBlank(originalFilename)){
    //             // 获取后缀名
    //             String substring = originalFilename.substring(originalFilename.lastIndexOf(".") + 1);
    //             // 获取文件hash值
    //             String s = md5HashCode(file.getInputStream());
    //             fileName = s+"."+substring;
    //         }
    //     } catch (IOException e) {
    //         e.printStackTrace();
    //     }
    //     return fileName;
    // }
    //
    // /**
    //  * java获取文件的md5值
    //  * @param fis 输入流
    //  * @return 结果
    //  */
    // public static String md5HashCode(InputStream fis) {
    //     try {
    //         //拿到一个MD5转换器,如果想使用SHA-1或SHA-256，则传入SHA-1,SHA-256
    //         MessageDigest md = MessageDigest.getInstance("MD5");
    //
    //         //分多次将一个文件读入，对于大型文件而言，比较推荐这种方式，占用内存比较少。
    //         byte[] buffer = new byte[1024];
    //         int length = -1;
    //         while ((length = fis.read(buffer, 0, 1024)) != -1) {
    //             md.update(buffer, 0, length);
    //         }
    //         fis.close();
    //         //转换并返回包含16个元素字节数组,返回数值范围为-128到127
    //         byte[] md5Bytes  = md.digest();
    //         BigInteger bigInt = new BigInteger(1, md5Bytes);//1代表绝对值
    //         return bigInt.toString(16);//转换为16进制
    //     } catch (Exception e) {
    //         e.printStackTrace();
    //         return "";
    //     }
    // }

    /**
     * 图片压缩
     * @param file 文件
     * @return 字节数组
     */
    public static byte[] getZipImage(MultipartFile file) {
        byte[] zipBytes = null;
        ByteArrayOutputStream outputStream = null;
        InputStream inputStream = null;
        try {
            byte[] bytes = file.getBytes();
            outputStream = new ByteArrayOutputStream(bytes.length);
            inputStream = file.getInputStream();
            Thumbnails.of(inputStream)
                    .scale(0.8f)
                    .outputQuality(1f)
                    .toOutputStream(outputStream);
            zipBytes = outputStream.toByteArray();
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try {
                if (inputStream != null) {
                    inputStream.close();
                }
                if (outputStream != null) {
                    outputStream.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return zipBytes;
    }

}