package com.yeshi.buwan.util;

import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;
import java.net.URL;
import java.util.Date;
import java.util.List;

import org.apache.log4j.Logger;

import com.aliyun.oss.OSSClient;
import com.aliyun.oss.model.DeleteObjectsRequest;
import com.aliyun.oss.model.PutObjectResult;

/**
 * 阿里云OSS存储
 */
public class OSSManager {

	Logger logger = Logger.getLogger(OSSManager.class);

	final String GETURL = "buwanimg.oss-cn-qingdao.aliyuncs.com";// 内网-zbsq.oss-cn-qingdao-internal.aliyuncs.com
	// 外网-http://zbsq.img-cn-qingdao.aliyuncs.com
	final String UPLOAD_URL = "http://oss-cn-qingdao.aliyuncs.com";// 内网-http://oss-cn-qingdao-internal.aliyuncs.com
	final String UPLOAD_URL_INTERNAL = "http://oss-cn-qingdao.aliyuncs.com";// "http://oss-cn-qingdao-internal.aliyuncs.com";
	// 外网-http://oss-cn-qingdao.aliyuncs.com
	// 外网-zbsq.oss-cn-qingdao.aliyuncs.com
	final String AK = "YQGAzGNuEnCGbpWQ";
	final String AKS = "EZkz2uhfCn3yOQp5AfUpDiPaLiMKEa";

	final String BUCKET = "buwanimg";

	static OSSManager instance;
	OSSClient client = null;

	public static OSSManager getInstance() {
		if (instance == null)
			instance = new OSSManager();
		return instance;
	}

	private void openOss(String url) {
		// if (client == null)
		client = new OSSClient(url, AK, AKS);
	}

	private void closeOss() {
		if (client != null)
			client.shutdown();
	}

	/**
	 * 上传文件
	 * 
	 * @param f
	 * @param key
	 * @return
	 */

	public String uploadFile(File f, String key) {
		if (f == null || !f.exists())
			return "";
		// 上传文件流
		openOss(UPLOAD_URL_INTERNAL);
		try {
			InputStream inputStream = new FileInputStream(f);
			PutObjectResult result = client.putObject(BUCKET, key, inputStream);

		} catch (FileNotFoundException e) {
			e.printStackTrace();
			key = "";
		} catch (Exception e) {
			e.printStackTrace();
			logger.error(e.getMessage());
			key = "";
		}
		closeOss();
		return key;// Constant.ALIYUN_IMAGE + key;
	}

	public void deleteObject(String key) {
		// 上传文件流
		openOss(UPLOAD_URL_INTERNAL);
		client.deleteObject(BUCKET, key);
		closeOss();
	}

	/**
	 * 删除文件列表
	 * 
	 * @param keys
	 */
	public void deleteObjects(List<String> keys) {
		// 上传文件流
		openOss(UPLOAD_URL_INTERNAL);
		client.deleteObjects(new DeleteObjectsRequest(BUCKET).withKeys(keys));
		closeOss();
	}

	public boolean createDir(String dirname) {
		openOss(UPLOAD_URL_INTERNAL);
		PutObjectResult result = client.putObject(BUCKET, dirname + "/", new ByteArrayInputStream(new byte[0]));
		closeOss();
		return true;
	}

	public String getUrl(String key) {
		openOss(UPLOAD_URL);
		// 设置URL过期时间为2小时
		Date expiration = new Date(new Date().getTime() + 1000 * 60 * 60 * 2L);
		// 生成URL
		URL url = client.generatePresignedUrl(BUCKET, key, expiration);
		closeOss();
		if (url != null) {
			return url.toString();
		}
		return null;
	}
}