2 include_once( INSTALL_PATH . "/reclib.php" );
4 function garbageClean() {
8 $arr = DBRecord::createRecords( PROGRAM_TBL, "WHERE endtime < subdate( now(), 8 )" );
9 foreach( $arr as $val ) $val->delete();
13 $arr = DBRecord::createRecords( PROGRAM_TBL, "WHERE starttime > adddate( now(), 8 ) ");
14 foreach( $arr as $val ) $val->delete();
18 $arr = DBRecord::createRecords( LOG_TBL, "WHERE logtime < subdate( now(), 10 )" );
19 foreach( $arr as $val ) $val->delete();
22 function doKeywordReservation() {
25 $arr = Keyword::createKeywords();
26 foreach( $arr as $val ) {
30 catch( Exception $e ) {
36 function storeProgram( $type, $xmlfile ) {
37 global $BS_CHANNEL_MAP, $GR_CHANNEL_MAP, $CS_CHANNEL_MAP;
42 if( $type == "BS" ) $map = $BS_CHANNEL_MAP;
43 else if( $type == "GR") $map = $GR_CHANNEL_MAP;
44 else if( $type == "CS") $map = $CS_CHANNEL_MAP;
47 $xml = @simplexml_load_file( $xmlfile );
48 if( $xml === false ) {
49 reclog( "getepg:: 正常な".$xmlfile."が作成されなかった模様(放送間帯でないなら問題ありません)", EPGREC_WARN );
50 return; // XMLが読み取れないなら何もしない
53 foreach( $xml->channel as $ch ) {
57 $num = DBRecord::countRecords( CHANNEL_TBL , "WHERE channel_disc = '" . $disc ."'" );
59 if( array_key_exists( "$disc", $map ) ) {
61 $rec = new DBRecord( CHANNEL_TBL );
63 $rec->channel = $map["$disc"];
64 $rec->channel_disc = $disc;
65 $rec->name = $ch->{'display-name'};
69 // 存在した場合も、とりあえずチャンネル名は更新する
70 $rec = new DBRecord(CHANNEL_TBL, "channel_disc", $disc );
71 $rec->name = $ch->{'display-name'};
74 catch( Exception $e ) {
75 reclog( "getepg::DBの接続またはチャンネルテーブルの書き込みに失敗", EPGREC_ERROR );
82 foreach( $xml->programme as $program ) {
85 $channel_disc = $program['channel'];
86 if( ! array_key_exists( "$channel_disc", $map ) ) continue;
87 $channel = $map["$channel_disc"];
90 $channel_rec = new DBRecord(CHANNEL_TBL, "channel_disc", "$channel_disc" );
92 catch( Exception $e ) {
93 reclog( "getepg::チャンネルレコード $channel_disc が発見できない", EPGREC_ERROR );
95 if( $channel_rec == null ) continue; // あり得ないことが起きた
96 if( $channel_rec->skip == 1 ) continue; // 受信しないチャンネル
98 $starttime = str_replace(" +0900", '', $program['start'] );
99 $endtime = str_replace( " +0900", '', $program['stop'] );
100 $title = $program->title;
101 $desc = $program->desc;
104 foreach( $program->category as $cat ) {
105 if( $cat['lang'] == "ja_JP" ) $cat_ja = $cat;
106 if( $cat['lang'] == "en" ) $cat_en = $cat;
108 $program_disc = md5( $channel_disc . $starttime . $endtime );
109 // printf( "%s %s %s %s %s %s %s \n", $program_disc, $channel, $starttime, $endtime, $title, $desc, $cat_ja );
116 $category_disc = md5( $cat_ja . $cat_en );
117 $num = DBRecord::countRecords(CATEGORY_TBL, "WHERE category_disc = '".$category_disc."'" );
120 $cat_rec = new DBRecord( CATEGORY_TBL );
121 $cat_rec->name_jp = $cat_ja;
122 $cat_rec->name_en = $cat_en;
123 $cat_rec->category_disc = $category_disc;
124 reclog("getepg:: 新規カテゴリ".$cat_ja."を追加" );
127 $cat_rec = new DBRecord(CATEGORY_TBL, "category_disc" , $category_disc );
129 catch( Exception $e ) {
130 reclog("getepg:: カテゴリテーブルのアクセスに失敗した模様", EPGREC_ERROR );
131 reclog("getepg:: ".$e->getMessage()."" ,EPGREC_ERROR );
132 exit( $e->getMessage() );
139 $num = DBRecord::countRecords(PROGRAM_TBL, "WHERE program_disc = '".$program_disc."'" );
143 $options = "WHERE channel_disc = '".$channel_disc."' ".
144 "AND starttime < '". $endtime ."' AND endtime > '".$starttime."'";
145 $battings = DBRecord::countRecords(PROGRAM_TBL, $options );
146 if( $battings > 0 ) {
148 $records = DBRecord::createRecords(PROGRAM_TBL, $options);
149 foreach( $records as $rec ) {
150 // 自動録画予約された番組は放映時間変更と同時にいったん削除する
152 $reserve = new DBRecord(RESERVE_TBL, "program_id", $rec->id );
154 if( time() > (toTimestamp($reserve->starttime) - PADDING_TIME - $settings->former_time) ) {
155 reclog( "getepg::録画ID".$reserve->id.":".$reserve->type.$reserve->channel.$reserve->title."は録画開始後に時間変更が発生した可能性がある", EPGREC_WARN );
158 if( $reserve->autorec ) {
159 reclog( "getepg::録画ID".$reserve->id.":".$reserve->type.$reserve->channel.$reserve->title."は時間変更の可能性があり予約取り消し" );
160 Reservation::cancel( $reserve->id );
164 catch( Exception $e ) {
168 reclog( "getepg::放送時間重複が発生した番組ID".$rec->id." ".$rec->type.$rec->channel.$rec->title."を削除" );
173 $rec = new DBRecord( PROGRAM_TBL );
174 $rec->channel_disc = $channel_disc;
175 $rec->channel_id = $channel_rec->id;
177 $rec->channel = $channel_rec->channel;
178 $rec->title = $title;
179 $rec->description = $desc;
180 $rec->category_id = $cat_rec->id;
181 $rec->starttime = $starttime;
182 $rec->endtime = $endtime;
183 $rec->program_disc = $program_disc;
188 $rec = new DBRecord( PROGRAM_TBL, "program_disc", $program_disc );
189 $rec->title = $title;
190 $rec->description = $desc;
191 $rec->category_id = $cat_rec->id;
194 $reserve = new DBRecord( RESERVE_TBL, "program_id", $rec->id );
195 // dirtyが立っておらず現在より後の録画予約であるなら
196 if( ($reserve->dirty == 0) && (toTimestamp($reserve->starttime) > time()) ) {
197 $reserve->title = $title;
198 $reserve->description = $desc;
199 reclog( "getepg:: 予約ID".$reserve->id."のEPG情報が更新された" );
203 catch( Exception $e ) {
209 catch(Exception $e) {
210 reclog( "getepg:: プログラムテーブルに問題が生じた模様", EPGREC_ERROR );
211 reclog( "getepg:: ".$e->getMessage()."" , EPGREC_ERROR);
212 exit( $e->getMessage() );