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);}}}

//ffmpeg -f s16le -ar 8000 -ac 2 -i out.pcm -ar 44100 -ac 2 out.wav   ---- 可用
//ffmpeg -i file.wav -f s16le -acodec pcm_s16le file.pcm  ----- 没测
//ffmpeg -f s16le -ar 44.1k -ac 2 -i file.pcm file.wav   ----- 没测
// ffmpeg -y -ac 2 -ar 44100 -f s16le -i output.pcm -acodec libmp3lame -ab 128k a.mp3   ----- 不能用
List<String> commend = new ArrayList<String>();
/*commend.add("c:\\ffmpeg\\ffmpeg");
commend.add("-f");
commend.add("s16le");
commend.add("-ar");
commend.add("8000");
commend.add("-ac");
commend.add("2");
commend.add("-i");
commend.add("c:\\ffmpeg\\input\\863925029959719-courseA.pcm");
commend.add("-ar");
commend.add("44100");
commend.add("-ac");
commend.add("2");
commend.add("c:\\ffmpeg\\output\\vvvvvvvvv.wav");*///ffmpeg -i testwav.wav -ar 8000 -ab 12.2k audio.amr  -----不能用
//ffmpeg -i test.wav -acodec libamr_nb -ab 12.2k -ar 8000 -ac 1 wav2amr.amr  -----不能用
//ffmpeg.exe -i PA003.wav -ar 8000 -ab 12.2k -ac 1 target.amr  此方法验证通过
commend.add("c:\\ffmpeg\\ffmpeg");
commend.add("-i");
commend.add("c:\\ffmpeg\\output\\vvvvvvvvv.wav");
//commend.add("-acodec");
//commend.add("libamr_nb");
commend.add("-ab");
commend.add("12.2k");
commend.add("-ar");
commend.add("8000");
commend.add("-ac");
commend.add("1");
commend.add("c:\\ffmpeg\\output\\audio.amr");