<?php
	//本文件需要到定时调用，一般可10秒左右调用一次，用于预约录像的处理。	

	set_time_limit(300);
	require_once("include/common.php");

	//管理员后台通过AJAX调用刷新
	$admin = 0;
	if(!empty ($_GET['admin'])){
		$admin = $_GET['admin'];
	}

	//每分钟通过计划任务调用时
	$task = 0;
	if(!empty ($_GET['task'])){
		$task = $_GET['task'];
	}

	session_start();
	if(isset($_SESSION['admin_time'])){
		$t1 = time() - $_SESSION['admin_time'];
		if($t1<=60 && $admin==0){
			//前台显示网页时，后台已经调用在调用，就不再处理，直接返回。
			$dt = date("H:i:s");
			$t1 = 60 - (time() % 60);
			echo "<div style='text-align:center;padding:20px;'>本页面用于处理自动预约录像，请不要关闭，$t1 秒后会自动刷新。<br>当前后台正在自动处理预约录像中。<p><h3>当前服务器时间:$dt</h3></p></div>";
			fresh_page($t1*1000);
			die;
		}
	}

	$msg = "";

	if($admin){
		$_SESSION['admin_time']= time();
	}else{
		echo "<div style='text-align:center;padding:20px;'>";
	}
	session_commit();

	//处理因网络不稳定或推流暂停等原因造成录像暂停后的继续录制
	runContinueRecord();

	//处理预约录课的自动结束
	$st = getNextStopTime();
	if($mt<=0){
		runStopRecord();
	}

	//检测最近的一次录课开始时间。
	$et = getNextStartTime();
	if($admin==0 && $et<60 && $et>0 && $task)
	{
		sleep($et);
		$et = 0;
	}

	//处理预约预约录课的自动开始
	runStartRecord();

	//将录制下来的flv文件转为MP4文件
	runFlv2Mp4();

	//将录制的结果发布到网站
	runPublish();


	if($admin){
		$nt = 10 - (time() % 10);
		if($st>0 && $st<$nt) $nt = $st;
		if($et>0 && $et<$nt) $nt = $et;
		echo $nt;
	}else{		
		$dt = date("H:i:s");
		$t1 = 60 - (time() % 60);
		if($et<$t1 && $et>0) $t1 = $et;
		if($st<$t1 && $st>0) $t1 = $st;
		echo "<p>页面用于处理自动预约录像，请不要关闭，$t1 秒后会自动刷新。</p><h3>当前服务器时间:$dt</h3></div>";		
		fresh_page($t1*1000);
	}



	function fresh_page($time){	
		//<!--JS 页面自动刷新 -->
		echo ("<script type=\"text/javascript\">");
		echo ("function fresh_page()");
		echo ("{");
		echo ("window.location.reload();");
		echo ("}"); 
		echo ("setTimeout('fresh_page()',$time);");      
		echo ("</script>");

	}


	//获取最近预约的开始时间
	function getNextStartTime(){
		global $dsql;
		$csqlStr = "SELECT title,start FROM sea_subscribe WHERE stat=0 AND start > now() ORDER BY start ASC  LIMIT 1";		
		$dsql->SetQuery($csqlStr);
		$dsql->Execute('vod_list');
		while($row=$dsql->GetObject('vod_list'))
		{
			if($admin==0) echo "<p>下一预约时间：$row->start    名称：$row->title</p>";
			$t1 = strtotime($row->start) - time();
			return $t1;
		}
		return false;
	}

		//获取最近预约的结束时间
		function getNextStopTime(){
			global $dsql;
			$csqlStr = "SELECT end FROM sea_subscribe WHERE stat=1 AND unix_timestamp(NOW()) >= unix_timestamp(end) ORDER BY end ASC  LIMIT 1";
			$dsql->SetQuery($csqlStr);
			$dsql->Execute('vod_list');
			while($row=$dsql->GetObject('vod_list'))
			{
				$t1 = strtotime($row->end) - time();
				return $t1;
			}
			return false;
		}

			
	//处理预约录像的开始任务
	function runStartRecord(){
		global $dsql;
		$csqlStr = "SELECT sea_subscribe.id,sea_subscribe.title,sea_subscribe.vid,sea_vod.app_name,sea_vod.stream_name  FROM sea_subscribe LEFT JOIN sea_vod ON sea_subscribe.vid = sea_vod .id WHERE sea_subscribe.stat=0 AND now() BETWEEN sea_subscribe.start AND sea_subscribe.end ORDER BY sea_subscribe.start ASC";
		$dsql->SetQuery($csqlStr);
		$dsql->Execute('vod_list');
		while($row=$dsql->GetObject('vod_list'))
		{
			$id = $row->id;
			$vid =  $row->vid;
			$app_name = $row->app_name;
			$stream_name = $row->stream_name;
			$url = makeStartUrl($app_name, $stream_name);
			$filename = curl_get($url);

			if($admin==0) echo "<p>开始自动录制：$row->title</p>";

			if(strlen($filename) <= 0){
				$stat = 6;
			} else {
				$stat = 1;
				$updateSql = "UPDATE sea_vod SET file_name = '$filename', stat = '2' WHERE id = $vid";
				$dsql->ExecuteNoneQuery($updateSql);	
			}
			$updateSql = "UPDATE sea_subscribe SET file_name = '$filename', stat = '$stat' WHERE stat =0 and id = $id";
			$dsql->ExecuteNoneQuery($updateSql);
		}
	}


	//检测录像因推流暂停或网络不稳定被暂停的继续录制问题
	function runContinueRecord(){
		global $dsql;
		$csqlStr = "SELECT sea_subscribe.id,sea_subscribe.title,sea_subscribe.vid,sea_subscribe.file_name,sea_vod.app_name,sea_vod.stream_name  FROM sea_subscribe LEFT JOIN sea_vod ON sea_subscribe.vid = sea_vod .id WHERE (sea_subscribe.stat=1 OR sea_subscribe.stat=6)  AND NOW() BETWEEN sea_subscribe.start AND sea_subscribe.end";
		$dsql->SetQuery($csqlStr);
		$dsql->Execute('vod_list');
		while($row=$dsql->GetObject('vod_list'))
		{
			$id = $row->id;
			$vid =  $row->vid;
			$app_name = $row->app_name;
			$stream_name = $row->stream_name;
			$url = makeStartUrl($app_name, $stream_name);
			$filename = curl_get($url);
			if(strlen($filename) > 0){

				if($admin==0) echo "<p>继续录制因网络原因造成中断的项目：$row->title</p>";

				$updateSql = "UPDATE sea_vod SET file_name = '$filename', stat = '2' WHERE id = $vid";
				$dsql->ExecuteNoneQuery($updateSql);
				if(strlen($row->file_name) > 0)
					$new_file_name = $row->file_name."*".$filename;
				else
				$new_file_name = $filename;
				$updateSql = "UPDATE sea_subscribe SET file_name = '$new_file_name', stat = '1' WHERE id = $id";
				$dsql->ExecuteNoneQuery($updateSql);
			}
		}
	}

			
	//处理预约录像的结束任务
	function runStopRecord(){
		global $dsql;
		$csqlStr = "SELECT sea_subscribe.id,sea_subscribe.title,sea_subscribe.vid,sea_subscribe.title,sea_subscribe.tid,sea_subscribe.file_name,sea_subscribe.start,sea_subscribe.v_pic,sea_subscribe.end,sea_subscribe.v_publisharea,sea_subscribe.v_director,sea_subscribe.user,sea_vod.app_name,sea_vod.stream_name  FROM sea_subscribe LEFT JOIN sea_vod ON sea_subscribe.vid = sea_vod .id WHERE  sea_subscribe.stat=1 AND unix_timestamp(NOW()) >= unix_timestamp(sea_subscribe.end) ORDER BY sea_subscribe.end ASC";
		$dsql->SetQuery($csqlStr);
		$dsql->Execute('vod_list');
		while($row=$dsql->GetObject('vod_list'))
		{
			$id = $row->id;
			$app_name = $row->app_name;
			$stream_name = $row->stream_name;
			$url = makeStopUrl($app_name, $stream_name);
			$filename = curl_get($url);
			if(strlen($row->file_name) > 0){
				$filename = $row->file_name;
			}

			if($admin==0) echo "<p>自动结束预约录像：$row->title</p>";

			$updateSql = "UPDATE sea_vod SET file_name = '$filename', stat = '1' WHERE id = $row->vid";
			$dsql->ExecuteNoneQuery($updateSql);	

			$updateSql = "UPDATE sea_subscribe SET file_name = '$filename', stat = '2' WHERE stat = 1 and id = $id";
			$dsql->ExecuteNoneQuery($updateSql);
		}
	}


	//因续录造成多个文件的合并处理。
	function mergeFlv($files,$mp4file,$ffmpeg){

		$size = count($files);
		if($size>1){
			$basename = getFullPath($files[0]);
			$basename = substr($basename,0,strrpos($basename, '.'));
			$txtname = $basename.".txt";
			$handle = fopen($txtname, "w");

			for($i=0;$i<$size;$i++){
				if(strlen($files[$i])>4){
					$flvname = getFullPath($files[$i]);
					if(file_exists($flvname)){
						$flvsize = filesize($flvname);
						if($flvsize>1024){
							$flvname =  basename($files[$i]);
							fwrite($handle,"file '");
							fwrite($handle,$flvname);
							fwrite($handle,"'\n");							
						}
					}
				}
			}
			fclose($handle);
			$command = "$ffmpeg -f concat -safe 0 -loglevel quiet -i $txtname -c copy $mp4file";
			echo $command;
			exec($command) ;
			unlink($txtname);
	
			if(file_exists($mp4file)){
				for($i=0;$i<$size;$i++){
					unlink(getFullPath($files[$i]));
				}
				return $mp4file;
			}
			return getFullPath($files[0]);
		} else {
			$flvname = getFullPath($files[0]);
			$command = "$ffmpeg -loglevel quiet -i $flvname -c copy $mp4file";
			echo $command;
			exec($command) ;
			
			if(file_exists($mp4file)){
				
				$flvsize = filesize($flvname);
				$mp4size = filesize($mp4file);
				if($mp4size*2>$flvsize){
					unlink($flvname);
					return $mp4file;
				}
			}
			return $flvname;
		}
	}


	//处理FLV录像转为MP4格式
	function runFlv2Mp4(){

		global $dsql,$cfg_movevodfile,$cfg_screenshot;
		$csqlStr = "SELECT id,tid,title,user,v_pic,start,file_name FROM sea_subscribe WHERE stat=2 and tid>0  ORDER BY id ASC LIMIT 1";
		$dsql->SetQuery($csqlStr);
		$dsql->Execute('vod_list');
		if(strtoupper(substr(PHP_OS,0,3))==='WIN'){
			$ffmpeg = str_replace('\\','/',realpath(dirname(__FILE__)))."/setup/ffmpeg";
		}else{
			$ffmpeg = "ffmpeg";
		}
		while($row=$dsql->GetObject('vod_list'))
		{
			$id = $row->id;

			$files = explode('*',$row->file_name);
			$flvfile = getFullPath($files[0]);

			if($cfg_movevodfile){
				$path = dirname($flvfile)."/".getTidName($row->tid);
				mkdirs($path);
				$str_user = str_replace([' ',':','?','"','<','>','|','\\','/','*','$','&',';'],'_',$row->user);
				$str_title = str_replace([' ',':','?','"','<','>','|','\\','/','*','$','&',';'],'_',$row->title);
				$mp4file = $path."/".date("YmdHi",strtotime($row->start))."_".$str_user."_".$str_title.".mp4";
				if($cfg_screenshot && $row->v_pic=="") $jpgfile = $path."/".date("YmdHi",strtotime($row->start))."_".$str_user."_".$str_title.".jpg";
			}else{
				$mp4file = substr($flvfile,0,strrpos($flvfile, '.')).".mp4";		
				if($cfg_screenshot && $row->v_pic=="") $jpgfile = substr($flvfile,0,strrpos($flvfile, '.')).".jpg";		
			}

			$updateSql = "UPDATE sea_subscribe SET stat = '3' WHERE stat = 2 AND id = $id";
			if(!$dsql->ExecuteNoneQuery($updateSql))
			{
				return "更新预约数据库错误！";
			}

			$outfile = mergeFlv($files,$mp4file,$ffmpeg);
			
			if($cfg_screenshot && $row->v_pic=="") {
				if($row->v_pic==""){
					$command = "$ffmpeg -ss 1.0 -t 0.001 -loglevel quiet -i $outfile -f image2 -y $jpgfile";
					exec($command);
					if(file_exists($jpgfile)){
						$jpgfile = getRelativePath($jpgfile);
					}else{
						$jpgfile = "";
					}
				}else{
					$jpgfile = $row->v_pic;
				}				
			}


			$outfile = getRelativePath($outfile);

			if($cfg_screenshot  && $row->v_pic=="") 
				$updateSql = "UPDATE sea_subscribe SET file_name = '$outfile',v_pic = '$jpgfile', stat = '4' WHERE stat = 3 AND id = $id";
			else
				$updateSql = "UPDATE sea_subscribe SET file_name = '$outfile', stat = '4' WHERE stat = 3 AND id = $id";
			if(!$dsql->ExecuteNoneQuery($updateSql))
			{
				//echo "更新预约数据库错误！";
			}else{
				//echo "转码成功。   ";
			}
		}
	}

	#根据目录号，获取目录名
	function getTidName($tid){
		global $dsql;
		
		$csqlStr = "SELECT `tname` FROM `sea_type` WHERE `tid`=$tid LIMIT 1";
		$dsql->SetQuery($csqlStr);
		$dsql->Execute('type_name');
		$row = $dsql->GetOne($csqlStr);
		while($row=$dsql->GetObject('type_name')){
			return $row->tname;
			
		}
		return "默认";
	}

	function mkdirs($dir, $mode = 0777)
	{
		if (is_dir($dir) || @mkdir($dir, $mode)) return TRUE;
		if (!mkdirs(dirname($dir), $mode)) return FALSE;
		return @mkdir($dir, $mode);
	}

	//处理等待发布的信息
	function runPublish(){
		global $dsql;
		$csqlStr = "SELECT id,title,tid,file_name,v_pic,v_publisharea,v_director,user  FROM sea_subscribe WHERE  stat='4' and publish='1' LIMIT 1";
		$dsql->SetQuery($csqlStr);
		$dsql->Execute('vod_list');
		while($row=$dsql->GetObject('vod_list'))
		{

			//先将状态设置为已发布状态，防止重复发布。
			$updateSql = "UPDATE sea_subscribe SET stat = '5' WHERE id = $row->id";
			$dsql->ExecuteNoneQuery($updateSql);

			$year =date('Y');
			$v_lang = "上学期";
			$month = date('m');
			if ($month>1 && $month<=8)
				$v_lang = "下学期";
			$t = time();
			$v_enname = Pinyin($row->title);
			$v_letter = strtoupper(substr($v_enname,0,1));

			#加入课程到数据库
			$insertSql = "insert into sea_data(tid,v_name,v_letter,v_state,v_topic,v_hit,v_money,v_vip,v_rank,v_actor,v_color,v_publishyear,v_publisharea,v_pic,v_spic,v_gpic,v_addtime,v_note,v_tags,v_lang,v_score,v_scorenum,v_director,v_enname,v_commend,v_extratype,v_jq,v_nickname,v_reweek,v_douban,v_mtime,v_imdb,v_tvs,v_company,v_dayhit,v_weekhit,v_monthhit,v_len,v_total,v_daytime,v_weektime,v_monthtime,v_ver,v_psd,v_try,v_longtxt,v_digg,v_tread) values ('$row->tid','$row->title','$v_letter','0','0','0','0','','0','$row->user','#FF0000','$year','$row->v_publisharea','$row->v_pic','','','$t','','','$v_lang','0','0','$row->v_director','$v_enname','0','','','','','0','0','0','','','0','0','0','','','$t','$t','$t','','','0','','0','0')";
			if($dsql->ExecuteNoneQuery($insertSql))
			{
				if($admin==0) echo "<p>自动前台发布：$row->title</p>";
				$v_id = $dsql->GetLastID();
				$v_playdata = 'Xgplayer$$第1集$'.$row->file_name.'$xg';
				$dsql->ExecuteNoneQuery("INSERT INTO `sea_playdata`(`v_id`,`tid`,`body`,`body1`) VALUES ('$v_id','$row->tid','$v_playdata','')");
				cache_clear(sea_ROOT.'/data/cache');
				$updateSql = "UPDATE sea_subscribe SET pid = '$v_id',file_name = '$row->file_name' WHERE id = $row->id";
				$dsql->ExecuteNoneQuery($updateSql);
			}
			break;
		}
	}

	function cache_clear($dir) {
		$dirname=$dir;
		$handle = opendir($dirname);
		if($handle){
			while (($file = readdir($handle)) !== false) {
				if ($file != '.' && $file != '..') {
					$dir = $dirname .'/' . $file;
					is_dir($dir) ? cache_clear($dir) : unlink($dir);
				}
			}
			closedir($handle);			
		}

 }


	//根据相对路径，获取完整路径。
	function getFullPath($filename){
		global $cfg_cmspath;
		if($filename[0]=='/') return $filename;
		if(strlen($cfg_cmspath)>0){
			$wwwroot = str_replace('\\','/',realpath(dirname(__FILE__).'/../../'));		
		}else{
			$wwwroot = str_replace('\\','/',realpath(dirname(__FILE__).'/../'));		
		}

		return $wwwroot."/".$filename;
	}

	//根据完整路径，获取相对路径。
	function getRelativePath($filename){
		global $cfg_cmspath;
		if(strlen($cfg_cmspath)>0){
			$wwwroot = str_replace('\\','/',realpath(dirname(__FILE__).'/../'));
		}else{
			$wwwroot = str_replace('\\','/',realpath(dirname(__FILE__)));	
		}
		$wwwlen = strlen($wwwroot);
		if(strncmp($wwwroot,$filename,$wwwlen)==0){
			return substr($filename,$wwwlen);
		}
		return $filename;
	}


	//通过curl调用网页，并获取网页内容。
	function curl_get($url){
		$testurl = $url;
		$ch = curl_init();  
		curl_setopt($ch, CURLOPT_URL, $testurl);  
		//参数为1表示传输数据，为0表示直接输出显示。
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
		//参数为0表示不带头文件，为1表示带头文件
		curl_setopt($ch, CURLOPT_HEADER,0);
		$output = curl_exec($ch); 
		curl_close($ch); 
		return $output;
	}


	function makeStartUrl($app_name, $stream_name){
		global $cfg_basehost;
    	return $cfg_basehost."/control/record/start?app=$app_name&name=$stream_name&rec=all";
	}

	function makeStopUrl($app_name, $stream_name){
		global $cfg_basehost;
    	return $cfg_basehost."/control/record/stop?app=$app_name&name=$stream_name&rec=all";
	}	

?>