Mercurial > epgrec.yaz
comparison Reservation.class.php @ 174:3474a501f802
relaxing check for overlapped programs. patch from http://www.sky.sannet.ne.jp/kn_ishi/epgrec/epgrec_Reservation.class.html
author | Yoshiki Yazawa <yaz@honeyplanet.jp> |
---|---|
date | Tue, 16 Apr 2013 15:23:28 +0900 |
parents | 1c4558d1a449 |
children |
comparison
equal
deleted
inserted
replaced
173:78ea97c5ad24 | 174:3474a501f802 |
---|---|
85 | 85 |
86 // 既存予約数 = TUNER番号 | 86 // 既存予約数 = TUNER番号 |
87 $tuners = ($crec->type == "GR") ? (int)($settings->gr_tuners) : (int)($settings->bs_tuners); | 87 $tuners = ($crec->type == "GR") ? (int)($settings->gr_tuners) : (int)($settings->bs_tuners); |
88 $type_str = ($crec->type == "GR") ? "type = 'GR' " : "(type = 'BS' OR type = 'CS') "; | 88 $type_str = ($crec->type == "GR") ? "type = 'GR' " : "(type = 'BS' OR type = 'CS') "; |
89 | 89 |
90 $battings = DBRecord::countRecords( RESERVE_TBL, "WHERE complete = '0' ". | 90 // 影響する予約情報を集める |
91 "AND ".$type_str. | 91 $trecs = DBRecord::createRecords(RESERVE_TBL, "WHERE complete = '0' ". |
92 "AND starttime < '".toDatetime($end_time) ."' ". | 92 "AND ".$type_str. |
93 "AND endtime > '".toDatetime($rec_start)."'" | 93 "AND starttime < '".toDatetime($end_time)."' ". |
94 ); | 94 "AND endtime > '".toDatetime($rec_start)."'" ); |
95 | 95 // 情報を配列に入れる |
96 if( $battings >= $tuners ) { | 96 for( $i = 0; $i < count($trecs) ; $i++ ) { |
97 // 重複を発見した | 97 $dim_start_time[$i] = toTimestamp($trecs[$i]->starttime); |
98 if( $settings->force_cont_rec == 1 ) { | 98 $dim_end_time[$i] = toTimestamp($trecs[$i]->endtime); |
99 // 解消可能な重複かどうかを調べる | 99 } |
100 // 前後の予約数 | 100 // 新規予約の値も配列に追加 |
101 $nexts = DBRecord::countRecords( RESERVE_TBL, "WHERE complete = '0' ". | 101 $dim_start_time[count($trecs)] = $rec_start; |
102 "AND ".$type_str. | 102 $dim_end_time[count($trecs)] = $end_time; |
103 "AND starttime = '".toDatetime($end_time - $settings->former_time)."'"); | 103 |
104 | 104 // 配列を使って重複を調べ、重複解消を検証する |
105 $prevs = DBRecord::countRecords( RESERVE_TBL, "WHERE complete = '0' ". | 105 $battings = 0; |
106 "AND ".$type_str. | 106 $mi = 0; |
107 "AND endtime = '".$starttime."'" ); | 107 for( $i = 0; $i <= count($trecs) ; $i++ ) { |
108 | 108 $mem_battings = 0; |
109 // 前後を引いてもチューナー数と同数以上なら重複の解消は無理 | 109 for( $j = 0; $j <= count($trecs) ; $j++ ) { |
110 if( ($battings - $nexts - $prevs) >= $tuners ) | 110 if( ( $i <> $j ) && ( $dim_start_time[$j] < $dim_end_time[$i] ) && ( $dim_end_time[$j] >= $dim_end_time[$i] ) ) { |
111 throw new Exception( "重複予約を解消できません" ); | 111 $mem_battings++; // 重複をカウント |
112 | 112 } |
113 // 直後の番組はあるか? | 113 } |
114 if( $nexts ) { | 114 if( $mem_battings > $tuners ) { // 重複が多すぎるので予約不可 |
115 // この番組の終わりをちょっとだけ早める | 115 throw new Exception( " 重複予約があります" ); |
116 $end_time = $end_time - $settings->former_time - $settings->rec_switch_time; | 116 } |
117 $duration = $end_time - $rec_start; // durationを計算しなおす | 117 // チューナー数が足りないとき、連続予約="する"なら重複解消を試みる |
118 } | 118 if( ( $mem_battings >= $tuners ) && ( $settings->force_cont_rec == 1 ) ) { |
119 $battings -= $nexts; | 119 for( $j = 0; $j <= count($trecs) ; $j++ ) { |
120 | 120 // 連続予約があるか? |
121 // 直前の録画予約を見付ける | 121 if( ( $i <> $j ) && ( $dim_end_time[$i] > $dim_start_time[$j] - $settings->rec_switch_time ) |
122 $trecs = DBRecord::createRecords(RESERVE_TBL, "WHERE complete = '0' ". | 122 && ( $dim_end_time[$i] <= $dim_start_time[$j] + $settings->extra_time + $settings->former_time ) ) { |
123 "AND ".$type_str. | 123 // 録画が始まっていないか? |
124 "AND endtime = '".$starttime."'" ); | 124 if( $dim_start_time[$i] > ( time() + PADDING_TIME + $settings->former_time + $settings->rec_switch_time ) + 1 ) { |
125 // 直前の番組をずらす | 125 $mem[$mi] = $i; // 変更すべき予約IDをメモ |
126 for( $i = 0; $i < count($trecs) ; $i++ ) { | 126 $dim_end_time[$i] = $dim_start_time[$j] - $settings->rec_switch_time; // 先行予約の終了時刻を早める |
127 if( $battings < $tuners ) break; // 解消終了のハズ? | |
128 // 予約修正に必要な情報を取り出す | |
129 $prev_id = $trecs[$i]->id; | |
130 $prev_program_id = $trecs[$i]->program_id; | |
131 $prev_channel_id = $trecs[$i]->channel_id; | |
132 $prev_title = $trecs[$i]->title; | |
133 $prev_description = $trecs[$i]->description; | |
134 $prev_category_id = $trecs[$i]->category_id; | |
135 $prev_starttime = $trecs[$i]->starttime; | |
136 $prev_endtime = $trecs[$i]->endtime; | |
137 $prev_autorec = $trecs[$i]->autorec; | |
138 $prev_mode = $trecs[$i]->mode; | |
139 $prev_dirty = $trecs[$i]->dirty; | |
140 | |
141 $prev_start_time = toTimestamp($prev_starttime); | |
142 // 始まっていない予約? | |
143 if( $prev_start_time > (time() + PADDING_TIME + $settings->former_time) ) { | |
144 // 開始時刻を元に戻す | |
145 $prev_starttime = toDatetime( $prev_start_time + $settings->former_time ); | |
146 // 終わりをちょっとだけずらす | |
147 $prev_endtime = toDatetime( toTimestamp($prev_endtime) - $settings->former_time - $settings->rec_switch_time ); | |
148 | |
149 // tryのネスト | |
150 try { | |
151 // いったん予約取り消し | |
152 self::cancel( $prev_id ); | |
153 // 再予約 | |
154 self::custom( | |
155 $prev_starttime, // 開始時間Datetime型 | |
156 $prev_endtime, // 終了時間Datetime型 | |
157 $prev_channel_id, // チャンネルID | |
158 $prev_title, // タイトル | |
159 $prev_description, // 概要 | |
160 $prev_category_id, // カテゴリID | |
161 $prev_program_id, // 番組ID | |
162 $prev_autorec, // 自動録画 | |
163 $prev_mode, | |
164 $prev_dirty ); | |
165 } | 127 } |
166 catch( Exception $e ) { | 128 else { |
167 throw new Exception( "重複予約を解消できません" ); | 129 $mem[$mi] = $j; // 変更すべき予約IDをメモ |
130 $dim_start_time[$j] = $dim_end_time[$i] + $settings->rec_switch_time; // 後続予約の開始時刻を遅くする | |
168 } | 131 } |
132 $mi++; | |
133 $mem_battings--; | |
134 break; | |
169 } | 135 } |
170 else { | 136 } |
171 throw new Exception( "重複予約を解消できません" ); | 137 } |
138 if( $mem_battings >= $tuners ) { // 重複解消できない | |
139 for( $j = 0; $j < count($trecs) ; $j++ ) { | |
140 if( ( $dim_start_time[$j] < $dim_end_time[$i] ) && ( $dim_end_time[$j] >= $dim_end_time[$i] ) ) { | |
141 $msg = $msg."\n 「".$trecs[$j]->title."」"; | |
172 } | 142 } |
173 $battings--; | 143 } |
174 } | 144 throw new Exception( " 予約が重複しています".$msg ); |
175 if( $battings < 0 ) $battings = 0; | 145 } |
176 // これで重複解消したはず | 146 if( $battings < $mem_battings ) { |
177 } | 147 $battings = $mem_battings; |
178 else { | 148 } |
179 throw new Exception( "重複予約があります" ); | 149 } |
180 } | 150 |
181 } | 151 // ここまでくれば予約可能 |
152 for( $i = 0; $i < $mi ; $i++ ) { // 重複解消が必要なら実行する | |
153 if( $mem[$i] == count($trecs) ) { // 変更すべきは新規予約 | |
154 $rec_start = $dim_start_time[$mem[$i]]; | |
155 $end_time = $dim_end_time[$mem[$i]]; | |
156 $duration = $end_time - $rec_start; // durationを計算しなおす | |
157 } | |
158 else { // 変更すべきは既存予約 | |
159 // 予約修正に必要な情報を取り出す | |
160 $prev_id = $trecs[$mem[$i]]->id; | |
161 $prev_program_id = $trecs[$mem[$i]]->program_id; | |
162 $prev_channel_id = $trecs[$mem[$i]]->channel_id; | |
163 $prev_title = $trecs[$mem[$i]]->title; | |
164 $prev_description = $trecs[$mem[$i]]->description; | |
165 $prev_category_id = $trecs[$mem[$i]]->category_id; | |
166 $prev_starttime = $trecs[$mem[$i]]->starttime; | |
167 $prev_endtime = $trecs[$mem[$i]]->endtime; | |
168 $prev_autorec = $trecs[$mem[$i]]->autorec; | |
169 $prev_mode = $trecs[$mem[$i]]->mode; | |
170 $prev_dirty = $trecs[$mem[$i]]->dirty; | |
171 $prev_start_time = toTimestamp($prev_starttime); | |
172 // 開始時刻を再設定 | |
173 $prev_starttime = toDatetime( $dim_start_time[$mem[$i]] + $settings->former_time ); | |
174 // 終了時刻を再設定 | |
175 $prev_endtime = toDatetime( $dim_end_time[$mem[$i]] ); | |
176 // tryのネスト | |
177 try { | |
178 self::cancel( $prev_id ); // いったん予約取り消し | |
179 self::custom( // 再予約 | |
180 $prev_starttime, // 開始時間Datetime型 | |
181 $prev_endtime, // 終了時間Datetime型 | |
182 $prev_channel_id, // チャンネルID | |
183 $prev_title, // タイトル | |
184 $prev_description, // 概要 | |
185 $prev_category_id, // カテゴリID | |
186 $prev_program_id, // 番組ID | |
187 $prev_autorec, // 自動録画 | |
188 $prev_mode, | |
189 $prev_dirty ); | |
190 } | |
191 catch( Exception $e ) { | |
192 throw new Exception( " 予約時刻変更(再予約)に失敗しました\n 「".$prev_title."」" ); | |
193 } | |
194 } | |
195 } | |
196 | |
182 // チューナー番号 | 197 // チューナー番号 |
183 $tuner = $battings; | 198 $tuner = $battings; |
184 | 199 |
185 // 改めてdurationをチェックしなおす | 200 // 改めてdurationをチェックしなおす |
186 if( $duration < ($settings->former_time + 60) ) { // 60秒以下の番組は弾く | 201 if( $duration < ($settings->former_time + 60) ) { // 60秒以下の番組は弾く |