package org.jeecg.modules.system.service.impl;

import org.jeecg.common.util.DateUtils;
import org.jeecg.common.util.oss.OssBootUtil;
import org.jeecg.modules.system.service.IAliUploadService;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.net.URLEncoder;

/**
 * 
 * @ClassName: AliUploadServiceImpl</br>
 * @Description: TODO</br>
 * @author yk</br>
 * @date 2021年4月6日</br>
 *       </br>
 */
@Service
public class AliUploadServiceImpl implements IAliUploadService {

	@Value(value = "${jeecg.oss.endpoint}")
	private String endPoint;

	@Value(value = "${jeecg.oss.accessKey}")
	private String accessKeyId;

	@Value(value = "${jeecg.oss.secretKey}")
	private String accessKeySecret;

	@Value(value = "${jeecg.oss.bucketName}")
	private String bucketName;

	@Override
	@Transactional(rollbackFor = { Exception.class })
	public String uploadFile(MultipartFile file) throws Exception {
		String path = "mes/" + DateUtils.date2Str(DateUtils.yyyyMMdd.get());
		OssBootUtil.setEndPoint(endPoint);
		OssBootUtil.setAccessKeyId(accessKeyId);
		OssBootUtil.setAccessKeySecret(accessKeySecret);
		OssBootUtil.setBucketName(bucketName);
		return OssBootUtil.upload(file, path);
	}

	@Override
	public void downloadFile(HttpServletResponse response, String url, String fileName) {
		OssBootUtil.setEndPoint(endPoint);
		OssBootUtil.setAccessKeyId(accessKeyId);
		OssBootUtil.setAccessKeySecret(accessKeySecret);
		OssBootUtil.setBucketName(bucketName);
		InputStream inputStream = OssBootUtil.download(url);

		byte[] buffer = new byte[1024];
		FileInputStream fis = null;
		BufferedInputStream bis = null;
		try {
			response.setHeader("Content-Type", "application/octet-stream;charset=utf-8"); // 告诉浏览器输出内容为流
			// response.setHeader("Content-Disposition", "attachment;fileName="+ new
			// String(toFileName.getBytes("UTF-8"),"ISO-8859-1"));
			response.setHeader("Content-Disposition", "attachment;fileName=" + URLEncoder.encode(fileName, "UTF-8"));
			// fis = new FileInputStream(file);
			bis = new BufferedInputStream(inputStream);
			OutputStream os = response.getOutputStream();
			int i = bis.read(buffer);
			while (i != -1) {
				os.write(buffer, 0, i);
				i = bis.read(buffer);
			}
			os.flush();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if (bis != null) {
				try {
					bis.close();
				} catch (IOException e) {
				}
			}
			if (fis != null) {
				try {
					fis.close();
				} catch (IOException e) {
				}
			}
		}
	}

}