epgrec.yaz: Reservation.class.php comparison

comparison Reservation.class.php @ 159:66eabfc1b118

revoke all whitespace modifications

author	Yoshiki Yazawa <yaz@honeyplanet.jp>
date	Wed, 31 Mar 2010 06:42:51 +0900
parents	3a6ec345ab0c
children	3d4df1fe4166

comparison

equal deleted inserted replaced

-:be39a7efcc87
+:66eabfc1b118
 // 予約クラス
 class Reservation {
 	public static function simple( $program_id , $autorec = 0, $mode = 0) {
 		$settings = Settings::factory();
 		$rval = 0;
 		try {
 			$prec = new DBRecord( PROGRAM_TBL, "id", $program_id );
 			$rval = self::custom(
 				$prec->starttime,
 				$prec->endtime,
 				$prec->channel_id,
 				$prec->title,
 				$prec->description,
 				$prec->category_id,
 				$program_id,
 				$autorec,
 				$mode );
 		}
 		catch( Exception $e ) {
 			throw $e;
 		}
 		return $rval;
 	}
 	public static function custom(
 		$starttime,				// 開始時間Datetime型
 		$endtime,				// 終了時間Datetime型
 		$channel_id,			// チャンネルID
 		$title = "none",		// タイトル
 		$settings = Settings::factory();
 		// 時間を計算
 		$start_time = toTimestamp( $starttime );
 		$end_time = toTimestamp( $endtime ) + $settings->extra_time;
 		if( $start_time < (time() + PADDING_TIME + 10) ) {	// 現在時刻より3分先より小さい＝すでに開始されている番組
 			$start_time = time() + PADDING_TIME + 10;		// 録画開始時間を3分10秒先に設定する
 		}
 		$at_start = $start_time - PADDING_TIME;
 		$sleep_time = PADDING_TIME - $settings->former_time;
 		$rec_start = $start_time - $settings->former_time;
 		// durationを計算しておく
 		$duration = $end_time - $rec_start;
 		if( $duration < ($settings->former_time + 60) ) {	// 60秒以下の番組は弾く
 			throw new Exception( "終わりつつある/終わっている番組です" );
 		}
 		$rrec = null;
 		try {
 			// 同一番組予約チェック
 			if( $program_id ) {
 				$num = DBRecord::countRecords( RESERVE_TBL, "WHERE program_id = '".$program_id."'" );
 				if( $num ) {
 					throw new Exception("同一の番組が録画予約されています");
 				}
 			}
 			$crec = new DBRecord( CHANNEL_TBL, "id", $channel_id );
 			// 既存予約数 = TUNER番号
 			$tuners = ($crec->type == "GR") ? (int)($settings->gr_tuners) : (int)($settings->bs_tuners);
 			$type_str = ($crec->type == "GR") ? "type = 'GR' " : "(type = 'BS' OR type = 'CS') ";
 			$battings = DBRecord::countRecords( RESERVE_TBL, "WHERE complete = '0' ".
 															  "AND ".$type_str.
 															  "AND starttime < '".toDatetime($end_time) ."' ".
 															  "AND endtime > '".toDatetime($rec_start)."'"
 			);
 			if( $battings >= $tuners ) {
 				// 重複を発見した
 				if( $settings->force_cont_rec == 1 ) {
 					// 解消可能な重複かどうかを調べる
 					// 前後の予約数
 					$nexts = DBRecord::countRecords( RESERVE_TBL, "WHERE complete = '0' ".
 																	"AND ".$type_str.
 																	"AND starttime = '".toDatetime($end_time - $settings->former_time)."'");
 					$prevs = DBRecord::countRecords( RESERVE_TBL, "WHERE complete = '0' ".
 																"AND ".$type_str.
 																"AND endtime = '".$starttime."'"  );
 					// 前後を引いてもチューナー数と同数以上なら重複の解消は無理
 					if( ($battings - $nexts - $prevs) >= $tuners )
 						throw new Exception( "重複予約を解消できません" );
 					// 直後の番組はあるか?
 					if( $nexts ) {
 						// この番組の終わりをちょっとだけ早める
 						$end_time = $end_time - $settings->former_time - $settings->rec_switch_time;
 						$duration = $end_time - $rec_start;		// durationを計算しなおす
 					}
 					$battings -= $nexts;
 					// 直前の録画予約を見付ける
 					$trecs = DBRecord::createRecords(RESERVE_TBL, "WHERE complete = '0' ".
 																		 "AND ".$type_str.
 																		 "AND endtime = '".$starttime."'" );
 					// 直前の番組をずらす
 						if( $prev_start_time > (time() + PADDING_TIME + $settings->former_time) ) {
 							// 開始時刻を元に戻す
 							$prev_starttime = toDatetime( $prev_start_time + $settings->former_time );
 							// 終わりをちょっとだけずらす
 							$prev_endtime   = toDatetime( toTimestamp($prev_endtime) - $settings->former_time - $settings->rec_switch_time );
 							// tryのネスト
 							try {
 								// いったん予約取り消し
 								self::cancel( $prev_id );
 								// 再予約
 								self::custom(
 									$prev_starttime,			// 開始時間Datetime型
 									$prev_endtime,				// 終了時間Datetime型
 									$prev_channel_id,			// チャンネルID
 									$prev_title,				// タイトル
 									$prev_description,			// 概要
 					throw new Exception( "重複予約があります" );
 				}
 			}
 			// チューナー番号
 			$tuner = $battings;
 			// 改めてdurationをチェックしなおす
 			if( $duration < ($settings->former_time + 60) ) {	// 60秒以下の番組は弾く
 				throw new Exception( "終わりつつある/終わっている番組です" );
 			}
 				$filename = mb_convert_encoding( $filename, FILESYSTEM_ENCODING, "UTF-8" );
 			}
 			$filename .= $RECORD_MODE["$mode"]['suffix'];
 			$thumbname = $filename.".jpg";
 			// サムネール
 			$gen_thumbnail = INSTALL_PATH."/gen-thumbnail.sh";
 			if( defined("GEN_THUMBNAIL") )
 				$gen_thumbnail = GEN_THUMBNAIL;
 			// ファイル名生成終了
 			// 予約レコードを埋める
 			$rrec = new DBRecord( RESERVE_TBL );
 			$rrec->channel_disc = $crec->channel_disc;
 			$rrec->channel_id = $crec->id;
 			$rrec->program_id = $program_id;
 			$rrec->endtime = toDatetime( $end_time );
 			$rrec->path = $filename;
 			$rrec->autorec = $autorec;
 			$rrec->mode = $mode;
 			$rrec->reserve_disc = md5( $crec->channel_disc . toDatetime( $start_time ). toDatetime( $end_time ) );
 			// 予約実行
 			$cmdline = $settings->at." ".date("H:i m/d/Y", $at_start);
 			$descriptor = array( 0 => array( "pipe", "r" ),
 			                     1 => array( "pipe", "w" ),
 			                     2 => array( "pipe", "w" ),
 			              "THUMB"    => INSTALL_PATH.$settings->thumbs."/".$thumbname,
 			              "FORMER"   => "".$settings->former_time,
 			              "FFMPEG"   => "".$settings->ffmpeg,
 			              "SID"      => $crec->sid,
 			);
 			// ATで予約する
 			$process = proc_open( $cmdline , $descriptor, $pipes, INSTALL_PATH.$settings->spool, $env );
 			if( is_resource( $process ) ) {
 				fwrite($pipes[0], $settings->sleep." ".$sleep_time."\n" );
 				fwrite($pipes[0], DO_RECORD . "\n" );
 					fwrite($pipes[0], $gen_thumbnail."\n" );
 				}
 				fclose($pipes[0]);
 				// 標準エラーを取る
 				$rstring = stream_get_contents( $pipes[2]);
 			    fclose( $pipes[2] );
 			    proc_close( $process );
 			}
 			else {
 				$rrec->delete();
 			}
 			throw $e;
 		}
 	}
 	// custom 終了
 	// 取り消し
 	public static function cancel( $reserve_id = 0, $program_id = 0 ) {
 		$settings = Settings::factory();
 		$rec = null;
 		try {
 			if( $reserve_id ) {
 				$rec = new DBRecord( RESERVE_TBL, "id" , $reserve_id );
 			}
 			else if( $program_id ) {

Mercurial > epgrec.yaz

comparison Reservation.class.php @ 159:66eabfc1b118