package com.victoria.controller;
import java.io.File;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.URLDecoder;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import com.victoria.dao.DaoFactory;
import com.victoria.dao.MediaDao;
import com.victoria.entity.Media;
import com.victoria.manager.MediaManager;
import com.victoria.utils.DateTimeUtil;
/**
 *
 *  MediaService.java   
 *
 *  @version ： 1.1
 * 
 *  @author  ： 苏若年    <a href="mailto:DennisIT@163.com">发送邮件</a>
 *   
 *  @since     ： 1.0        创建时间:    2013-2-08        下午02:24:47
 *     
 *  TODO     :    class MediaService.java is used for ...
 *
 */
public class MediaServlet extends HttpServlet {
    public void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        doPost(request, response);
    }
    public void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        PrintWriter out = response.getWriter();
        MediaDao mediaDao = DaoFactory.getMediaDao();
        ServletContext sctx = this.getServletContext();
        //获得保存文件的路径
        String audiosPath = sctx.getRealPath("audios");
        String videosPath = sctx.getRealPath("videos");
        String dataPath = DateTimeUtil.getYMDFormat();
        String savePath = ""; //mp4保存路径
        String fileName = ""; //上传的文件名
        audiosPath = audiosPath + File.separator + dataPath;
        Map<String, String> map = new HashMap<String, String>();
        //创建音频保存路径
        File audiosFile = new File(audiosPath);
        if (!audiosFile.exists()) {
            audiosFile.mkdir();
        }
        //创建视频保存路径
        videosPath = videosPath + File.separator + dataPath;
        File videosFile = new File(videosPath);
        if (!videosFile.exists()) {
            videosFile.mkdir();
        }
        String uri = request.getRequestURI();
        String path = uri.substring(uri.lastIndexOf("/"));
        if (uri.indexOf(".") != -1) {
            path = uri.substring(uri.lastIndexOf("/"), uri.lastIndexOf("."));
        }
        //System.out.println("path: "+ System.getProperties().getProperty("os.name"));
        if("/uploadFile".equals(path)){
            //提供解析时的一些缺省配置
            DiskFileItemFactory factory = new DiskFileItemFactory();
            //创建一个解析器,分析InputStream,该解析器会将分析的结果封装成一个FileItem对象的集合
            //一个FileItem对象对应一个表单域
            ServletFileUpload sfu = new ServletFileUpload(factory);
            try {
                Media media = new Media();
                List<FileItem> items = sfu.parseRequest(request);
                boolean flag = false;    //转码成功与否的标记
                for(int i=0; i<items.size(); i++){
                    FileItem item = items.get(i);
                    //要区分是上传文件还是普通的表单域
                    if(!item.isFormField()){//isFormField()为true,表示这不是文件上传表单域
                        //上传文件
                        //获得文件名
                        fileName = item.getName();
                        System.out.println("---------------上传文件名："+fileName+"-----------------");
                        long size = item.getSize();
                        if((fileName == null || "".equals(fileName)) && size == 0){
                            continue;
                        }
                        fileName = URLDecoder.decode(fileName, "UTF-8"); 
                        //System.out.println("上传文件" + item.getName());
                        //在某些操作系统上,item.getName()方法会返回文件的完整名称,即包括路径
                        String mp3 = audiosPath + File.separator + DateTimeUtil.getYMDHMS();
                        String fileType = "";
                        if (fileName.indexOf(".")!=-1) {
                            fileType = fileName.substring(fileName.lastIndexOf(".")); //截取文件格式
                            mp3 += fileType;
                        }
                        //待转码的文件
                        File uploadFile = new File(mp3);
                        item.write(uploadFile);
                        System.out.println("--------------mp3:"+mp3+"--------------");
                        if(item.getSize()>500*1024*1024){
                            map.put("state", "0");
                        }
                        //String mediaPicPath = basePath + "/images" +File.separator+ serialName + ".jpg";    //设置上传视频截图的保存路径
                        // 获取配置的转换工具（ffmpeg.exe）的存放路径
                        String ffmpegPath = getServletContext().getRealPath("/tools/ffmpeg.exe");
                        System.out.println("--------------ffmpegPath:"+ffmpegPath+"--------------");
                        String[] arr = null;
                        if (fileName.indexOf(File.separator)!=-1) {
                            //如果文件名带完整路径 包括 斜杠的。进行截取
                            String wei = fileName.substring(fileName.lastIndexOf(File.separator)+1, fileName.lastIndexOf("."));
                            arr = wei.split("-");
                            media.setImei(wei.substring(0, wei.lastIndexOf("-")));
                            media.setCid(arr[arr.length-1]);
                            if ("course1".equals(arr[arr.length-1])){
                            } else {
                            }
                        } else {
                            //如果文件名是不带路径的
                            String wei = fileName.substring(0, fileName.lastIndexOf("."));
                            arr = wei.split("-");
                            media.setImei(wei.substring(0, wei.lastIndexOf("-")));
                            media.setCid(arr[arr.length-1]);
                            System.out.println("imei:"+media.getImei()+"Cid:"+arr[arr.length-1]);
                            if ("course1".equals(arr[1])){
                            } else {
                            }
                        }
                        String codcFilePath = videosPath +File.separator+ media.getCid() +"-" + DateTimeUtil.getYMDHMS() + ".mp4";//设置转换为flv格式后文件的保存路径
                        //用于保存mp4最终路径
                        savePath = "/videos/" + dataPath + "/" + media.getCid() +"-" +DateTimeUtil.getYMDHMS() + ".mp4";
                        media.setSrc("/audios/" + dataPath + "/" + DateTimeUtil.getYMDHMS() + fileType);
                        media.setDest(savePath);
                        media.setUptime(DateTimeUtil.getYMDHMSFormat());
                        //转码
                        ffmpegPath = ffmpegPath.replaceAll("\\\\","/");
                        codcFilePath = codcFilePath.replaceAll("\\\\","/");
                        String uploadFilePath = uploadFile.getAbsolutePath().replaceAll("\\\\","/");
                        flag = mediaDao.executeCodecs(ffmpegPath, uploadFilePath, codcFilePath, media.getCid());
                    }
                }
                if(flag){
                    //转码成功,向数据表中添加该视频信息
                    //mediaDao.saveMedia(media);
                    //MediaManager.getInstance().addMedia(media);
                    map.put("state", "1");
                    map.put(media.getCid(), savePath);
                } else {
                    map.put("state", "0");
                }
                //request.setAttribute("message", message);
                //request.getRequestDispatcher("media_upload.jsp").forward(request,response);
                //response.sendRedirect(request.getContextPath()+ "/index.jsp?success=modify");
            } catch (Exception e) {
                e.printStackTrace();
                map.put("state", "0");
                throw new ServletException(e);
            } finally {
                //response.getOutputStream().write();
                response.setCharacterEncoding("UTF-8");
                response.getWriter().print(JSONObject.fromObject(map));
            }
        }
        if("/queryAll".equals(path)){
            List<Media> mediaList;
            try {
                mediaList = mediaDao.queryALlMedia(0,5);
                request.setAttribute("mediaList", mediaList);
                request.getRequestDispatcher("media_list.jsp").forward(request, response);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        if("/play".equals(path)){
            String idstr = request.getParameter("id");
            int mediaId = -1;
            Media media = null;
            if(null!=idstr){
                mediaId = Integer.parseInt(idstr);
            }
            try {
                media = mediaDao.queryMediaById(mediaId);
            } catch (Exception e) {
                e.printStackTrace();
            }
            request.setAttribute("media", media);
            request.getRequestDispatcher("media_player.jsp").forward(request, response);
        }
    }
}