package com.mandi.servlet.file.impl;

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.URLEncoder;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.UUID;

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

import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import org.apache.log4j.Logger;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.MultipartHttpServletRequest;

import com.mandi.servlet.file.FileLoad;
@Service
public class FileLoadImpl implements FileLoad{
	private Logger log=Logger.getLogger(FileLoadImpl.class);
	@SuppressWarnings("unchecked")
	@Override
	public String uploadFile(String dest/*相对位置*/, HttpServletRequest request,boolean randname) {
		String directory="";
		String filenames="";//
		if(dest==null)
			directory=request.getSession().getServletContext().getRealPath("");
		else
			directory=request.getSession().getServletContext().getRealPath(dest);
		
		File file=new File(directory);
		if(!file.exists())
		{
			file.mkdirs();
		}
		DiskFileItemFactory dfif=new DiskFileItemFactory(); 
		ServletFileUpload  sf=new ServletFileUpload(dfif);
		sf.setHeaderEncoding("utf-8");
		List<FileItem> list=null;
		try{
			list=sf.parseRequest(request);
			Iterator<FileItem> it=list.iterator();
			while(it.hasNext())
			{
				FileItem fi=it.next();
				if(fi.isFormField())
					continue;
				String name1=fi.getName();
				if(randname==true)
				{
					int point=name1.lastIndexOf(".");
					if(point>0 && name1.length()>(point+1))
					{
						name1=name1.substring(point);
					}
					name1=UUID.randomUUID()+name1;
				}
				String filename="";//file.getPath();
				if(directory.endsWith(File.separator))
					filename=directory+name1;
				else
					filename=directory+File.separator+name1;
				File file1=new File(filename);
				fi.write(file1);
				filenames=dest.endsWith(File.separator)?(dest+name1):(dest+"/"+name1);//file relative path
				filenames=request.getServletContext().getContextPath()+filenames;
			}
		}catch (Exception e) {
			log.error("uploadFile error");
		}
		
		return filenames;
	}
	/**
	 * 
	 * @return 
	 * @author mengly 
	 * @version 创建时间：2016年8月6日 下午5:42:49
	 */
	public Map<String, Object> uploadFileRP(String dir,MultipartHttpServletRequest request,boolean randname){
		if(dir==null)
			dir=request.getSession().getServletContext().getRealPath("");
		Path p=Paths.get(dir);
		if(!Files.exists(p))
			try {
				Files.createDirectories(p);
			} catch (IOException e) {
				e.printStackTrace();
				return null;
			}
		if(!dir.endsWith(File.separator))
			dir+=File.separator;
	    Map<String,MultipartFile> mpfs=request.getFileMap();
	    for (Entry<String,MultipartFile> en : mpfs.entrySet()) {
	    	MultipartFile mf=en.getValue();
	    	if(mf.isEmpty())
	    		continue;
	    	Map<String, Object> mp=new HashMap<String, Object>();
	    	String uuid=UUID.randomUUID().toString();
			mp.put("name", mf.getOriginalFilename());
			mp.put("size", mf.getSize());
			mp.put("uuid", uuid);
			
			String fullp=dir+uuid+mf.getOriginalFilename();
			Path pf=Paths.get(fullp);
			try {
				Files.copy(mf.getInputStream(), pf);
				mp.put("url", fullp);
				return mp;
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		return null;
	}
	
	@SuppressWarnings("unchecked")
	@Override
	public List<Object> uploadFile_map(String dest,HttpServletRequest request,boolean randname){
		List<Object> list1=new ArrayList<Object>();
		String directory="";
		String filenames="";//
		
		if(dest==null)
			directory=request.getSession().getServletContext().getRealPath("");
		else
			directory=request.getSession().getServletContext().getRealPath(dest);
		
		File file=new File(directory);
		if(!file.exists())
		{
			file.mkdirs();
		}
		DiskFileItemFactory dfif=new DiskFileItemFactory(); 
		ServletFileUpload  sf=new ServletFileUpload(dfif);
		sf.setHeaderEncoding("utf-8");
		List<FileItem> list=null;
		try{
			list=sf.parseRequest(request);
			Iterator<FileItem> it=list.iterator();
			while(it.hasNext())
			{
				Map<String, Object> mp=new HashMap<String, Object>();
				FileItem fi=it.next();
				mp.put("name", fi.getName());
				mp.put("size", fi.getSize());
				if(fi.isFormField())
					continue;
				String name1=fi.getName();
				if(randname==true)
				{
					int point=name1.lastIndexOf(".");
					if(point>0 && name1.length()>(point+1))
					{
						name1=name1.substring(point);
					}
					name1=UUID.randomUUID()+name1;
				}
				String filename="";//file.getPath();
				if(directory.endsWith(File.separator))
					filename=directory+name1;
				else
					filename=directory+File.separator+name1;
				File file1=new File(filename);
				fi.write(file1);
				filenames=dest.endsWith(File.separator)?(dest+name1):(dest+"/"+name1);//file relative path
				mp.put("url", filenames);
				list1.add(mp);
			}
		}catch (Exception e) {
			log.error("uploadFile error");
		}
		return list1;
	}
	
	@SuppressWarnings("unchecked")
	@Override
	public List<Object> uploadFile_map(String dest,HttpServletRequest request,boolean randname,long size){
		List<Object> list1=new ArrayList<Object>();
		String directory="";
		String filenames="";//
		if(dest==null)
			directory=request.getSession().getServletContext().getRealPath("");
		else
			directory=request.getSession().getServletContext().getRealPath(dest);
		
		File file=new File(directory);
		if(!file.exists())
		{
			file.mkdirs();
		}
		DiskFileItemFactory dfif=new DiskFileItemFactory(); 
		ServletFileUpload  sf=new ServletFileUpload(dfif);
		sf.setHeaderEncoding("utf-8");
		List<FileItem> list=null;
		try{
			list=sf.parseRequest(request);
			Iterator<FileItem> it=list.iterator();
			while(it.hasNext())
			{
				Map<String, Object> mp=new HashMap<String, Object>();
				FileItem fi=it.next();
				mp.put("name", fi.getName());
				mp.put("size", fi.getSize());
				if(fi.isFormField())
				{
					continue;
				}
				if(size!=0)
				{
					if(fi.getSize()>size)
					{
						log.info("file size 超过限制值!!");
						continue;
					}
				}
				String name1=fi.getName();
				if(randname==true)
				{
					int point=name1.lastIndexOf(".");
					if(point>0 && name1.length()>(point+1))
					{
						name1=name1.substring(point);
					}
					name1=UUID.randomUUID()+name1;
				}
				String filename="";//file.getPath();
				if(directory.endsWith(File.separator))
					filename=directory+name1;
				else
					filename=directory+File.separator+name1;
				File file1=new File(filename);
				fi.write(file1);
				filenames=dest.endsWith(File.separator)?(dest+name1):(dest+"/"+name1);//file relative path
				mp.put("url", filenames);
				list1.add(mp);
			}
		}catch (Exception e) {
			log.error("uploadFile error");
		}
		return list1;
	}
	
	@Override
	public Map<String, Object> uploadFile_map(String dest,HttpServletRequest request,FileItem fi,boolean randname,long size){
		if(fi==null)
			return null;
		String directory="";
		String filenames="";//
		if(dest==null)
			directory=request.getSession().getServletContext().getRealPath("");
		else
			directory=request.getSession().getServletContext().getRealPath(dest);
		
		File file=new File(directory);
		if(!file.exists())
		{
			file.mkdirs();
		}
		Map<String, Object> mp=new HashMap<String, Object>();
		try{
				mp.put("name", fi.getName());
				mp.put("size", fi.getSize());
				if(fi.isFormField())
				{
					return null;
				}
				if(size!=0)
				{
					if(fi.getSize()>size)
					{
						log.info("file size 超过限制值!!");
						return null;
					}
				}
				String name1=fi.getName();
				if(randname==true)
				{
					int point=name1.lastIndexOf(".");
					if(point>0 && name1.length()>(point+1))
					{
						name1=name1.substring(point);
					}
					name1=UUID.randomUUID()+name1;
				}
				String filename="";//file.getPath();
				if(directory.endsWith(File.separator))
					filename=directory+name1;
				else
					filename=directory+File.separator+name1;
				File file1=new File(filename);
				fi.write(file1);
				filenames=dest.endsWith(File.separator)?(dest+name1):(dest+"/"+name1);//file relative path
				mp.put("url", filenames);
		}catch (Exception e) {
			log.error("uploadFile error");
		}
		return mp;
	}
	
	@Override
	public void downloadFile(String displayname, String source,
			HttpServletResponse response) {
		if(source==null)
			return;
		File file=new File(source);
		if(!file.exists())
			return;
		response.setContentType("application/x-download");
		if(displayname==null)
			displayname=file.getName();
		try{
			displayname=URLEncoder.encode(displayname,"utf-8");
			response.setHeader("Content-Disposition", "attachment; filename=\""+displayname+"\""); 
			FileInputStream fis=new FileInputStream(file);
			BufferedInputStream bis=new BufferedInputStream(fis);
			OutputStream out1=response.getOutputStream();
			byte[] bytes=new byte[1024*4];
			int length=-1;
			while((length=bis.read(bytes))!=-1)
			{
				out1.write(bytes, 0, length);
			}
			out1.flush();
			bis.close();
			fis.close();
			out1.close();
		}catch (Exception e) {
			log.error("downloadFile error");
		}
		file.delete();
	}

	@Override
	public void downloadFile(String desplayname, String source,
			HttpServletResponse response, HttpServletRequest request) {
		File file=new File(source);
		if(!file.exists())
			return;
		long range=0;
		if(request.getHeader("Range")!=null)
		{
			 response . setStatus ( javax . servlet . http . HttpServletResponse . SC_PARTIAL_CONTENT ) ;
			 range=Long . parseLong ( request . getHeader ( "Range" ) . replaceAll ( "bytes=" , "" ) . replaceAll ( "-" , "" ) ) ;
		}
		response . setHeader ( "Content-Length" ,   new   Long ( file.length()  -  range ) . toString ( ) ) ; 
		if(range!=0)
		{
			 response.setHeader( "Content-Range", "bytes "   +   new  Long(range).toString()+ "-"+new Long(file.length()-1).toString()+"/"+new Long(file.length()).toString());   
		}
		response.setContentType("application/x-download");
		response.setContentType ( "application/octet-stream"); 
		try {
			String fn=URLEncoder.encode(desplayname,"utf-8");
			response . setHeader ( "Content-Disposition","attachment;filename=\""+fn+"\""); 
			
			FileInputStream fis=new FileInputStream(file);
			BufferedInputStream bis=new BufferedInputStream(fis);
			bis.skip(range);
			OutputStream out1=response.getOutputStream();
			byte[] bytes=new byte[1024*4];
			int length=-1;
			while((length=bis.read(bytes))!=-1)
			{
				out1.write(bytes, 0, length);
			}
			out1.flush();
			bis.close();
			fis.close();
		} catch (Exception e) {
			log.error("downloadFile error"+e.getMessage());
		}finally{
			
		}
	}

	@Override
	public String realpath2path(String localpath, HttpServletRequest request) {
		String realpath=request.getServletContext().getRealPath("");
		if(localpath==null)
			return "/";
		if(localpath.lastIndexOf(realpath)!=0)
			return "/";
		realpath=localpath.substring(realpath.length());
		if(realpath.length()>0 && !realpath.startsWith(File.separator)&&!realpath.startsWith("/"))
		{
			realpath="/"+realpath;
		}
		realpath=realpath.replaceAll("\\\\", "/");
		return realpath;
	}
	
}