convertrunnable.java

简单的视频上传系统

package cn.com.csuinfosoft.util;

import java.io.File;

import org.apache.log4j.Logger;

import cn.com.csuinfosoft.dao.DAO;
import cn.com.csuinfosoft.video.ConvertVideo;
import cn.com.csuinfosoft.video.Video;
import cn.com.csuinfosoft.vo.FLVVO;

public class ConvertRunnable implements Runnable {

	/**
	 * 视频转换处理对象
	 */
	private Video video = null;
	
	private boolean inUse = false;
	
	/**
	 *  待转换流媒体文件
	 */
	private File videoFile = null;
	
	private DAO flvDAO = null;
	
	private Logger logger = null;
	
	public ConvertRunnable(DAO argDAO) {
		this.video = new ConvertVideo();
		flvDAO = argDAO;
		logger = Logger.getLogger(this.getClass());
	}
	
	public void run() {
		logger.debug("ConvertRunnable exec...");
		if(videoFile == null || !videoFile.exists()) {
			videoFile = null;
			inUse = false;
			return;
		}
		if(videoFile.getName().indexOf("Thumbs") > -1) {
			videoFile.delete();
			videoFile = null;
			inUse = false;
			logger.debug("videoFile is delete...");
			return;
		}
		String videoPath = videoFile.getAbsolutePath();
		String flvPath = videoPath.substring(0, videoPath.indexOf("\\videoDir"));
		String videoName = videoPath.substring(videoPath.lastIndexOf("\\") + 1,videoPath.lastIndexOf("."));
		flvPath = flvPath+"\\flvDir"+"\\" + videoName +".flv";
		video.process(videoPath, flvPath);
		//修改记录
		FLVVO flvVO = (FLVVO) flvDAO.loadByFlvInfo(videoName);
		flvVO.setFlvPath(flvPath.substring(flvPath.indexOf("\\flvDir") + 1));
		flvVO.setFlvState(2);	//处理完状态
		flvDAO.updateInfo(flvVO);
		//删除文件
		videoFile.delete();
		videoFile = null;
		inUse = false;
	}

	public void setVideoFile(File videoFile) {
		this.videoFile = videoFile;
	}

	public boolean isInUse() {
		return inUse;
	}

	public void setInUse(boolean inUse) {
		this.inUse = inUse;
	}

}