/**
 * @author mazhq
 * @Title: X509TrustUtiil
 * @ProjectName: zeus
 * @Description: 证书信任管理器类
 * @date 2019/2/18 15:14
 */
public class X509TrustUtil implements X509TrustManager {
    @Override
    public void checkClientTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {

    }

    @Override
    public void checkServerTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {

    }

    @Override
    public X509Certificate[] getAcceptedIssuers() {
        return new X509Certificate[0];
    }
}

/**
 * @author mazhq
 * @Title: OSSUtil
 * @ProjectName: zeus
 * @Description: TODO
 * @date 2019/2/18 14:07
 */
public class OSSUtil {
    /**
    * @Description: 上传文件到阿里云
    * @param recordingLink
    * @param fileName
    * @return void
    * @exception
    * @author mazhq
    * @date 2019/2/18 14:30
    */
    public static String uploadRecording(JSONObject ossJson, String recordingLink, String fileName){
        try {
            // Endpoint以杭州为例，其它Region请按实际情况填写。
            String endpoint = "";

            String bucketServer;
            String bucketName;
            bucketName = "dev-uploadtoimages";
            endpoint = "http://oss-devimage.xxxx.com/";
            bucketServer = "http://dev-uploadtoimages.oss-cn-beijing.aliyuncs.com/";

            // 阿里云主账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维，请登录 https://ram.console.aliyun.com 创建RAM账号。
            String accessKeyId = ossJson.getString("accessKeyId");
            String accessKeySecret =  ossJson.getString("accessKeySecret");
            String security = ossJson.getString("security");

            // 创建OSSClient实例。
            OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret, security);

            // 上传网络流。
            SSLContext sslcontext = SSLContext.getInstance("SSL", "SunJSSE");
            sslcontext.init(null, new TrustManager[] { new X509TrustUtil() }, new java.security.SecureRandom());
            URL url = new URL(recordingLink);
            HostnameVerifier ignoreHostnameVerifier = new HostnameVerifier() {
                public boolean verify(String s, SSLSession sslsession) {
                    System.out.println("WARNING: Hostname is not matched for cert.");
                    return true;
                }
            };
            HttpsURLConnection.setDefaultHostnameVerifier(ignoreHostnameVerifier);
            HttpsURLConnection.setDefaultSSLSocketFactory(sslcontext.getSocketFactory());
            HttpsURLConnection urlCon = (HttpsURLConnection) url.openConnection();
            urlCon.setConnectTimeout(6000);
            urlCon.setReadTimeout(6000);
            int code = urlCon.getResponseCode();
            if (code != HttpURLConnection.HTTP_OK) {
                throw new Exception("文件读取失败");
            }
            // 读文件流
            InputStream inputStream = urlCon.getInputStream();

            // 上传文件 (上传文件流的形式)
            ossClient.putObject(bucketName, "recording/"+fileName, inputStream);

            // 关闭OSSClient。
            ossClient.shutdown();

            return bucketServer+"recording/"+fileName;
        } catch (IOException e) {
            e.printStackTrace();
        }catch (Exception e){
            e.printStackTrace();
        }

        return null;
    }

}