package com.email.service.internal;

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.URLEncoder;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Optional;
import java.util.Random;

import javax.servlet.http.HttpServletResponse;

import com.email.EmailUtils;
import com.email.EmailUtils_2;
import com.email.dao.SysEmailInfoDao;
import com.email.entity.SysEmailInfo;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import com.app.base.data.ApiResponseResult;
import com.app.base.service.FtpClientService;
import com.email.service.EmailService;
import com.system.file.dao.FsFileDao;
import com.system.file.entity.FsFile;

@Configuration
public class EmailImpl  implements EmailService {
	protected Logger logger = LoggerFactory.getLogger(this.getClass());
    @Autowired
    private FsFileDao fsFileDao;
    @Autowired
    private FtpClientService ftpClientService;
    @Autowired
    private Environment env;
    @Autowired
    private SysEmailInfoDao sysEmailInfoDao;
    @Autowired
    private EmailUtils_2 emailUtils_2;

    /**
     * 上传文件
     * @param fsFile
     * @param file
     * @return
     * @throws Exception
     */
    public ApiResponseResult upload(FsFile fsFile, MultipartFile file) throws Exception {
        if(null==file || file.isEmpty()) {
            return ApiResponseResult.failure("上传文件不能为空");
        }
        String qmsPath = env.getProperty("fs.qms.path");

        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
        String ymd = sdf.format(new Date());

        String path = qmsPath + "/" + ymd;

        SimpleDateFormat df = new SimpleDateFormat("yyyyMMddHHmmss");
        String dateFileName = df.format(new Date()) + "_" + new Random().nextInt(1000);

        try {
            fsFile.setBsFileSize(file.getSize());
            if(null==fsFile.getBsContentType()) {
                fsFile.setBsContentType(file.getContentType());
            }
            if(null==file.getOriginalFilename()) {
                fsFile.setBsFileType("Unknown");
                return ApiResponseResult.failure("无法识别该文件类型！");
            }

            String originalFiletype = file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."), file.getOriginalFilename().length());
            fsFile.setBsFileType(originalFiletype);

//            String originalFilename = file.getOriginalFilename().substring(0, file.getOriginalFilename().lastIndexOf("."));
            fsFile.setBsName(file.getOriginalFilename());
            fsFile.setBsFileName(dateFileName + originalFiletype);
            fsFile.setBsFilePath("/"+ymd);
            ApiResponseResult result = ftpClientService.uploadFile(path, dateFileName+fsFile.getBsFileType(), new ByteArrayInputStream(file.getBytes()));
            if(result.isResult()) {
                fsFile.setCreatedTime(new Date());
                fsFileDao.save(fsFile);
                return ApiResponseResult.success("文件上传成功！").data(fsFile);
            }
        } catch (IOException e) {
            logger.error("upload file exception", e);
        }
        return ApiResponseResult.failure("上传文件发生异常");
    }

    /**
     * 下载文件
     * @param fsFileId
     * @param response
     * @return
     * @throws Exception
     */
    public ApiResponseResult get(Long fsFileId, HttpServletResponse response) throws Exception {
        Optional<FsFile> fsFiles = fsFileDao.findById(fsFileId);
        if(null==fsFiles) {
            return ApiResponseResult.failure("文件不存在或已被删除");
        }
        FsFile fsFile = fsFiles.get();
        String path = env.getProperty("fs.qms.path")+fsFile.getBsFilePath();
        ApiResponseResult result = ftpClientService.download(path, fsFile.getBsFileName());
        try {
//            String fileName = new String(fsFile.getBsName().getBytes("UTF-8"), "ISO-8859-1")+ fsFile.getBsFileType();
            String fileName = URLEncoder.encode(fsFile.getBsName(), "UTF-8");
//            response.setContentType("application/octet-stream");
            response.setContentType(fsFile.getBsContentType());
            // 设置response的Header
//            response.setHeader("Content-Disposition", "attachment;filename=" + new String((fsFile.getBsName()+fsFile.getBsFileType()).getBytes("UTF-8"), "ISO-8859-1"));
            response.addHeader("Content-Disposition", "attachment;filename=" + fileName );
            response.addHeader("Content-Length", "" + fsFile.getBsFileSize());
            OutputStream os = response.getOutputStream();
            byte[] bytes = (byte[]) result.getData();
            os.write(bytes);
            os.flush();
            os.close();
        } catch (IOException e) {
            logger.error("download file exception", e);
        }
        return null;
    }

    /**
     * 图片在线预览（非图片下载）
     * @param fsFileId
     * @param response
     * @return
     * @throws Exception
     */
    public ApiResponseResult onlineView(Long fsFileId, HttpServletResponse response) throws Exception {
    	Optional<FsFile> fsFiles = fsFileDao.findById(fsFileId);
        if(null==fsFiles) {
            return ApiResponseResult.failure("文件不存在或已被删除");
        }
        FsFile fsFile = fsFiles.get();
        String path = env.getProperty("fs.qms.path")+fsFile.getBsFilePath();
        ApiResponseResult result = ftpClientService.download(path, fsFile.getBsFileName());
        try {
            String fileName = URLEncoder.encode(fsFile.getBsName(), "UTF-8");  //文件名称
            String extName = fsFile.getBsFileType();  //文件后缀名
            response.setContentType(fsFile.getBsContentType());
            response.addHeader("Content-Disposition", "inline;filename=" + fileName );
            response.addHeader("Content-Length", "" + fsFile.getBsFileSize());
//            if(".png".equals(extName)){
//                response.setContentType("image/png");
//            }
            OutputStream os = response.getOutputStream();
            byte[] bytes = (byte[]) result.getData();
            os.write(bytes);
            os.flush();
            os.close();
        } catch (IOException e) {
            logger.error("download file exception", e);
        }
        return null;
    }

    /**
     * 删除文件
     * @param fsFileId
     * @return
     * @throws Exception
     */
    public ApiResponseResult delete(Long fsFileId) throws Exception{
        if(fsFileId == null){
            return ApiResponseResult.failure("记录ID不能为空！");
        }
        Optional<FsFile> fsFiles = fsFileDao.findById(fsFileId);
        if(null==fsFiles) {
            return ApiResponseResult.failure("文件不存在或已被删除");
        }
        FsFile fsFile = fsFiles.get();

        fsFile.setIsDel(1);
        fsFileDao.save(fsFile);
        return ApiResponseResult.success("文件删除成功！");
    }

    //发送邮件测试
    @Transactional
    public ApiResponseResult test() throws Exception{
        String enabled = env.getProperty("scm.mail.enabled");
        if(StringUtils.isNotEmpty(enabled) && enabled.equals("true")){
            String subject = "";
            String emailTo = "";
            String[] toUser = {emailTo};
            String content = "";

            EmailUtils.sendEmail(subject, toUser, null, content, null);
            Boolean flag = emailUtils_2.sendEmail(subject, toUser, null, "时间的沙漏总是忙碌和紧张_2", null);
            if(flag){
                SysEmailInfo sysEmailInfo = new SysEmailInfo();
                sysEmailInfo.setCreatedTime(new Date());
                String emailFrom = env.getProperty("mail.auth.name");
                sysEmailInfo.setBsEmailFrom(emailFrom);
                sysEmailInfo.setBsEmailTo(emailTo);
                sysEmailInfo.setBsEmailCc(null);
                sysEmailInfo.setBsSubject(subject);
                sysEmailInfo.setBsContent(content);
                //sysEmailInfoDao.save(sysEmailInfo);
                return ApiResponseResult.success("邮件发送成功！").data(sysEmailInfo);
            }else{
                return ApiResponseResult.success("邮件发送失败！");
            }
        }else{
            return ApiResponseResult.success("邮件发送失败！");
        }
    }
}