package com.shlanbao.tzsc.pms.file.docfile.service.impl;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ConnectException;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.ResourceBundle;
import java.util.Set;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import com.shlanbao.tzsc.utils.tools.*;
import org.apache.poi.common.usermodel.Fill;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.artofsolving.jodconverter.DocumentConverter;
import com.artofsolving.jodconverter.openoffice.connection.OpenOfficeConnection;
import com.artofsolving.jodconverter.openoffice.connection.OpenOfficeException;
import com.artofsolving.jodconverter.openoffice.connection.SocketOpenOfficeConnection;
import com.artofsolving.jodconverter.openoffice.converter.OpenOfficeDocumentConverter;
import com.shlanbao.tzsc.base.dao.DocFileDaoI;
import com.shlanbao.tzsc.base.mapping.DocFile;
import com.shlanbao.tzsc.base.mapping.SysUser;
import com.shlanbao.tzsc.base.model.SessionInfo;
import com.shlanbao.tzsc.base.service.BaseService;
import com.shlanbao.tzsc.pms.file.docfile.beans.DocFileBean;
import com.shlanbao.tzsc.pms.file.docfile.service.DocFileServiceI;

@Service
public class DocFileServiceImpl extends BaseService implements DocFileServiceI {
	@Autowired
	private DocFileDaoI fileDaoI;
	@Autowired
	private HttpServletRequest request;

	private File sourceFile;  //目标源文件
	private File pdfFile;     //PDF目标文件
	private File swfFile;     //swf目标文件
    private Runtime runtime;
	private static final ResourceBundle bundle = ResourceBundle.getBundle("config");
	/**
	 *查询所有文件
	 */
	@Override
	public List<DocFileBean> getDocFileAll(DocFileBean fileBean)
			throws Exception {
		List<DocFileBean> df = new ArrayList<DocFileBean>();

		StringBuilder hql = new StringBuilder();
		hql.append("from DocFile d  where 1=1 and d.attr=0 order by d.createTime");
		List<DocFile> docFiles = fileDaoI.query(hql.toString());
		if(docFiles!=null){
			for (DocFile docfile : docFiles) {

				DocFileBean dffile = new DocFileBean();
				dffile = BeanConvertor.copyProperties(docfile, DocFileBean.class);
				if (docfile.getDocFile() != null) {
					dffile.setPid(docfile.getDocFile().getId());
				}
				dffile.setSysUserName(docfile.getSysUser().getName());
				if (dffile.getType().equals("1")) {
					dffile.setIconCls("icon-standard-folder");
				} else {
					switch (dffile.getFileType()){
						case "doc" :
							dffile.setIconCls("icon-standard-page-white-word");
							break;
						case "docx" :
							dffile.setIconCls("icon-standard-page-white-word");
							break;
						case "xls" :
							dffile.setIconCls("icon-standard-page-white-excel");
							break;
						case "xlsx" :
							dffile.setIconCls("icon-standard-page-white-excel");
							break;
						case "pdf" :
							dffile.setIconCls("icon-standard-page-white-acrobat");
							break;
						case "png" :
							dffile.setIconCls("icon-standard-picture");
							break;
						case "jpg" :
							dffile.setIconCls("icon-strandard-picture");
							break;
						case "gif" :
							dffile.setIconCls("icon-standard-picture");
							break;
						case "zip" :
							dffile.setIconCls("icon-standard-page-white-zip");
							break;
						case "rar" :
							dffile.setIconCls("icon-standard-page-white-zip");
							break;
						case "ppt" :
							dffile.setIconCls("icon-standard-page-white-powerpoint");
							break;

						case "pptx" :
							dffile.setIconCls("icon-standard-page-white-powerpoint");
							break;
						default:
							dffile.setIconCls("icon-standard-page-white-text");
							break;
					}
				}
				dffile.setUrl(bundle.getString("service_url") + dffile.getUrl());
				FillUserInfoUtil.fillCreateAndUpdateUserInfo(docfile,dffile);
				df.add(dffile);
			}
		}
		return df;
	}

	@Override
	public void deleteDocFile(String Id) {

		fileDaoI.deleteById(Id, DocFile.class);
	}

	/**
	 * 文件上传
	 * 修改：shisihai
	 */
	@LogAnno(operateType = "文件上传")
	@Override
	public String uploadDocFile(String parentId, HttpServletRequest request,HttpSession session) throws Exception {
		request.setCharacterEncoding("utf-8");
		SessionInfo sessionInfo = (SessionInfo) session.getAttribute("sessionInfo");
		String[] UrlfileNames=(String[]) request.getParameterValues("urlfileName")[0].split(",");
		String err = null;
		// 获取文件名
		String[] fileUrls = (String[]) request.getParameterValues("fileUrl")[0].split(",");
		String[] fileNames = (String[]) request.getParameterValues("fileName")[0].split(",");
		// 取到 pid
		DocFile dbdocFile = fileDaoI.findById(DocFile.class, parentId);
		String pid;
		if (dbdocFile.getType().equals("2")) {
			// 表示是文件
			pid = dbdocFile.getDocFile().getId();
		} else {
			// 文件夹
			pid = dbdocFile.getId();
		}
		for (int i = 0; i < fileUrls.length; i++) {
			if (this.DocFileByFileName(fileNames[i].substring(0,fileNames[i].lastIndexOf(".")))) {
				DocFile docFile = new DocFile();
				docFile.setDocFile(new DocFile(pid));
				docFile.setCreateTime(new Date());
				docFile.setFilename(fileNames[i].substring(0,fileNames[i].lastIndexOf(".")));
				docFile.setFileType(fileNames[i].substring(fileNames[i].lastIndexOf(".") + 1));
				docFile.setType("2");
				docFile.setUrl(fileUrls[i].replace(docFile.getFilename(),UrlfileNames[i]));//修改后，
				//docFile.setUrl(bundle.getString("upload")+"/"+UrlfileNames[i]+"."+fileUrls[i].substring(fileUrls[i].lastIndexOf(".") + 1));
				docFile.setAttr("0");
				docFile.setSysUser(new SysUser(sessionInfo.getUser().getId()));
				FillUserInfoUtil.fillCreateUserInfo(docFile,request);
				fileDaoI.save(docFile);
			} else {
				err = "此文件已经存在！";
			}
		}
		return err;
	}
	/*public void init( HttpServletRequest request) {
		File uploadPath = new File(request.getServletContext().getRealPath(bundle.getString("upload")));
		File previewPDF = new File(request.getServletContext().getRealPath(bundle.getString("pdf")));
		if (!uploadPath.exists()) {
			uploadPath.mkdir();
		}
		if (!previewPDF.exists()) {
			previewPDF.mkdir();
		}
	}*/
	/**
	 * file初始化
	 * @param sourceFilePath  源文件
	 * @param pdfPath pdf file
	 * @param swfPath swf file
	 */
	protected void initFilePath(String sourceFilePath,String pdfPath,String swfPath){
		//判断源文件是否为PDF文件
		if("pdf".equals(sourceFilePath.substring((sourceFilePath.lastIndexOf(".")+1)))){
			sourceFile = new File(sourceFilePath);
			pdfFile = new File(pdfPath);
			swfFile = new File(swfPath);
		}else{
			sourceFile = new File(sourceFilePath);
			pdfFile = new File(pdfPath);
			swfFile = new File(swfPath);
		}
		System.out.println("文件对象已生成，准备转换..");
	}
	/**
	 * 文件转换为swf格式
	 * @throws IOException
	 */
	protected void fileConvert() throws IOException{
		System.out.println(pdfFile.getName());
		if(sourceFile.exists()){
			if(!pdfFile.exists()){
				OpenOfficeConnection connection = null;
				try {
					connection = new SocketOpenOfficeConnection("127.0.0.1",8100);
					connection.connect();
					DocumentConverter converter = new OpenOfficeDocumentConverter(connection);
					converter.convert(sourceFile, pdfFile);//源文件转换为PDF
					pdfFile.createNewFile();
					connection.disconnect();
					System.out.println("转换为PDF文件:"+pdfFile.getPath());
				} catch (ConnectException e) {
					System.out.println("openOffice 服务未启动: ");
					e.printStackTrace();
					throw e;
				} catch (OpenOfficeException e){
					System.out.println("文件读取失败: ");
					e.printStackTrace();
					throw e;
				} catch (Exception e){
					System.out.println("未知异常:");
					e.printStackTrace();
				}finally{//add by luther.zhang 20150129防止报错后不释放链接
					if(connection!=null){
						connection.disconnect();
					}
				}
		} else {
			System.out.println("Pdf文件已经转换，无需再次转。");
		}
		}else{
			System.out.println("要转换的源文件不存在， 可能是路径错误。");
		}

		runtime = Runtime.getRuntime();

		new Thread(){

			@Override
			public void run(){
				if(!swfFile.exists()){
					if(pdfFile.exists()){
						try {
							//System.out.println(ConfigParameter.psPath +
							//pdfFile.getPath() + " -o " + swfFile.getPath() + " -T 9");
							//Process p = runtime.exec(ConfigParameter.psPath + pdfFile.getPath() + " -o " + swfFile.getPath() + " -T 9");//单独的进程中执行指定的字符串命令
							//p.waitFor();//当前线程等待，如有必要，一直要等到由该 Process 对象表示的进程已经终止

							//runtime.exec(ConfigParameter.psPath + pdfFile.getPath() + " -o " + swfFile.getPath() + " -T 9");//单独的进程中执行指定的字符串命令
							String command=bundle.getString("exePath")+" -t \""+pdfFile.getPath()+"\" -o \""
									+swfFile.getPath()+"\" -T 9";
							System.out.println(command);
							runtime.exec(command);//单独的进程中执行指定的字符串命令

							swfFile.createNewFile();

							System.out.println("swfFile 格式路径："+swfFile.getPath());

							System.out.println("swfFile 格式名称："+swfFile.getName());

						} catch (IOException e) {
							System.out.println("IOException:");
							e.printStackTrace();
						} /*catch (InterruptedException e) {
							System.out.println("InterruptedException:");
							e.printStackTrace();
						}*/

					} else {
						System.out.println("Pdf文件格式不存在，无法转换");
					}
				} else {
					System.out.println("已转换为SWF格式,无需再次转换!");
				}
			}

		}.start();
	}
	@Override
	public DocFile DocFileById(String Id) throws Exception {

		return fileDaoI.findById(DocFile.class, Id);
	}

	/**
	 * 文件下载
	 *
	 * @param filePath
	 *            文件路径
	 * @param fileName
	 *            文件名称
	 * @param response
	 *            响应对象
	 * @return
	 */
	public boolean download(String filePath, String fileName,
			HttpServletResponse response) {

		// 将服务器上的文件写入本地文件
		OutputStream outputStream = null;
		// 读取服务器上的文件信息
		InputStream inputStream = null;
		// 文件名,输出到用户的下载对话框
		// String fileName = null;
		try {

			inputStream = new FileInputStream(filePath);
			response.setContentType("text/plain");
			response.setHeader("Location", fileName);
			response.setHeader("Content-Disposition", "attachment;filename="
					+ fileName);
			outputStream = response.getOutputStream();
			byte[] buffer = new byte[1024];
			int i = -1;
			while ((i = inputStream.read(buffer)) != -1) {
				outputStream.write(buffer, 0, i);
			}

		} catch (Exception e) {
			log.error("下载失败", e);
			return false;
		} finally {
			try {
				if (outputStream != null) {
					outputStream.flush();
					outputStream.close();
				}
				if (inputStream != null) {
					inputStream.close();
				}
			} catch (IOException e) {
				e.printStackTrace();
				log.error("关闭流失败", e);
			}
		}
		return true;
	}
	@LogAnno(operateType = "删除文档")
	@Override
	public String deleteFile(String id) throws Exception {
		// 判断有没有子节点
		DocFile docFile = fileDaoI.findById(DocFile.class, id);
		Set<DocFile> docFiles = docFile.getDocFiles();
		String err = null;
		int str=0;
		for (DocFile docFile2 : docFiles) {
			if(docFile2.getAttr().equals("0")){
				str++;
			}
		}
		if (str > 0) {
			err = "请先删除文件夹里的文件";
		} else {
			docFile.setAttr("1");
		}
		return err;
	}
	/**
	 * 添加文件夹
	 *
	 */
	@LogAnno(operateType = "添加文件夹")
	@Override
	public String saveFile(String parentId, String filename,
			HttpServletRequest request, HttpSession session) throws Exception {
		request.setCharacterEncoding("utf-8");
		SessionInfo sessionInfo = (SessionInfo) session
				.getAttribute("sessionInfo");
		String err = null;
		if (this.fileByFileName(filename,parentId)&& StringUtil.notNull(filename)) {
			String pid;
			String url;
			// 取到 pid
			if(StringUtil.notNull(parentId)){
				DocFile dbdocFile = fileDaoI.findById(DocFile.class, parentId);

				if (dbdocFile.getType().equals("2")) {
					// 表示是文件
					pid = dbdocFile.getDocFile().getId();
					url = dbdocFile.getDocFile().getUrl();
				} else {
					// 文件夹
					pid = dbdocFile.getId();
					url = dbdocFile.getUrl();
				}
			}else{
				pid=null;
				url ="upload";

			}
			System.out.println(request.getServletContext()
					.getRealPath("upload"));

			DocFile docFile = new DocFile();
			if(StringUtil.notNull(pid)){
			docFile.setDocFile(new DocFile(pid));
			}else{
				docFile.setDocFile(null);
			}
			// docFile.setCreateTime(new Date());
			docFile.setFilename(filename);
			docFile.setFileType(null);
			docFile.setType("1");
			docFile.setUrl(url);
			docFile.setAttr("0");
			docFile.setCreateTime(new Date());
			docFile.setSysUser(new SysUser(sessionInfo.getUser().getId()));
			FillUserInfoUtil.fillCreateUserInfo(docFile,request);
			fileDaoI.save(docFile);

		} else {
			err = "此文件已经存在、或者不能为空";

		}
		return err;
	}

	@Override
	public boolean DocFileByFileName(String fileName) {
		List<DocFile> docFiles = fileDaoI.query(
				"from DocFile d where d.filename=?  and d.attr='0'", fileName);
		if (docFiles.size() > 0) {
			return false;
		} else {
			return true;
		}
	}

	public boolean fileByFileName(String fileName,String pid) {
		List<DocFile> docFiles = fileDaoI.query(
				"from DocFile d where d.filename=? and type = 1 and pid = ?  and d.attr='0'", fileName,pid);
		if (docFiles.size() > 0) {
			return false;
		} else {
			return true;
		}
	}
	@LogAnno(operateType = "修改文件夹或文件名字")
	@Override
	public String updatefile(DocFileBean docFileBean, HttpSession session) {
		String err = null;
		SessionInfo sessionInfo = (SessionInfo) session
				.getAttribute("sessionInfo");
		if (sessionInfo.getUser() == null) {
			err = "请登录后修改";
		} else {
		DocFile file=	fileDaoI.findById(DocFile.class, docFileBean.getId());
			file.setFilename(docFileBean.getFilename());
			file.setSysUser( new SysUser(sessionInfo.getUser().getId()));
			FillUserInfoUtil.fillUpdateUserInfo(file,request);
		}
		return err;
	}



}