package test.com.redis;

import java.io.ByteArrayOutputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.MalformedURLException;
import java.net.URL;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.cloopen.rest.sdk.utils.encoder.BASE64Decoder;
import com.cloopen.rest.sdk.utils.encoder.BASE64Encoder;
import com.ovopark.shopweb.common.oss.OssHelper;

public class Atest {
    
    private static final Logger LOGGER = LoggerFactory.getLogger(Atest.class);
    private static final int PROTECTED_LENGTH = 1024 * 1024;// 輸入流保護 1M

    public static String downLoad(String strUrl, Boolean isProxy, String host, String port) {
        if (isProxy) {
            setProxy(host, port);
        }
        URL url = null;
        try {
            url = new URL(strUrl);
        } catch (MalformedURLException e2) {
            LOGGER.error("下載圖片異常，新建URL失敗");
            return "";
        }
        InputStream is = null;
        try {
            is = url.openStream();
            return readInfoStreamToBytes(is);
        } catch (IOException e1) {
            LOGGER.error("下載圖片異常");
            return "";
        }
    }

    public static void setProxy(String host, String port) {
        System.setProperty("proxySet", "true");
        System.setProperty("proxyHost", host);
        System.setProperty("proxyPort", port);
    }

    public static void main(String[] args) {
        String str = "http://ovopark.oss-cn-hangzhou.aliyuncs.com/2018/12/18/1545109997006425.jpeg?x-oss-process=image/resize,w_100,h_100/quality,q_80";
        String picStr = Atest.downLoad(str, true, "", "");
        GenerateImage(picStr);
        System.out.print(picStr);

    }

    public static boolean GenerateImage(String imgStr) { // 對位元組陣列字串進行Base64解碼並生成圖片
        if (imgStr == null) // 影象資料為空
            return false;
        BASE64Decoder decoder = new BASE64Decoder();
        try {
            // Base64解碼
            byte[] b = decoder.decodeBuffer(imgStr);
            for (int i = 0; i < b.length; ++i) {
                if (b[i] < 0) {// 調整異常資料
                    b[i] += 256;
                }
            }
            //上傳oss返回圖片url
            OssHelper o = new OssHelper();
            String aString = "http://ovopark.oss-cn-hangzhou.aliyuncs.com/"+o.uploadFile(b);
            
            // 生成本地jpeg圖片
            String imgFilePath = "C:\\Users\\WDZ88\\Desktop.jpeg";// 新生成的圖片
            OutputStream out = new FileOutputStream(imgFilePath);
            out.write(b);
            out.flush();
            out.close();
            return true;
        } catch (Exception e) {
            return false;
        }
    }

    public static String readInfoStreamToBytes(InputStream is) {
        if (is == null) {
            LOGGER.error("輸入流為null");
            return null;
        }

        // 位元組陣列
        byte[] bCache = new byte[2048];
        int readSize = 0;// 每次讀取的位元組長度
        int totalSize = 0;// 總位元組長度
        ByteArrayOutputStream infoStream = new ByteArrayOutputStream();
        try {
            // 一次性讀取2048位元組
            while ((readSize = is.read(bCache)) > 0) {
                totalSize += readSize;
                if (totalSize > PROTECTED_LENGTH) {
                    LOGGER.error("輸入流超出1M大小限制");
                    return null;
                }
                // 將bcache中讀取的input資料寫入infoStream
                infoStream.write(bCache, 0, readSize);
            }
        } catch (IOException e1) {
            LOGGER.error("輸入流讀取異常");
            return null;
        } finally {
            try {
                is.close();
            } catch (IOException e) {
                LOGGER.error("輸入流關閉異常");
            }
        }
        BASE64Encoder encoder = new BASE64Encoder();
        return encoder.encode(infoStream.toByteArray());
    }
    
}