Mercurial > epgrec.yaz

comparison getepg.php @ 87:36ac7c416bd7

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
merged with upstream
author Yoshiki Yazawa <yaz@honeyplanet.jp>
date Mon, 01 Mar 2010 20:51:36 +0900
parents 605d327bddcc c29d41d0c945
children 663521c2bf06
comparison
equal deleted inserted replaced
75:11f63ae04a96 87:36ac7c416bd7
3 include_once('config.php'); 3 include_once('config.php');
4 include_once( INSTALL_PATH . '/DBRecord.class.php' ); 4 include_once( INSTALL_PATH . '/DBRecord.class.php' );
5 include_once( INSTALL_PATH . '/Reservation.class.php' ); 5 include_once( INSTALL_PATH . '/Reservation.class.php' );
6 include_once( INSTALL_PATH . '/Keyword.class.php' ); 6 include_once( INSTALL_PATH . '/Keyword.class.php' );
7 include_once( INSTALL_PATH . '/Settings.class.php' ); 7 include_once( INSTALL_PATH . '/Settings.class.php' );
8 8
9 // 後方互換性
10 if( ! defined( "BS_EPG_CHANNEL" ) ) define( "BS_EPG_CHANNEL", "211" );
11 if( ! defined( "CS1_EPG_CHANNEL" ) ) define( "CS1_EPG_CHANNEL", "CS8" );
12 if( ! defined( "CS2_EPG_CHANNEL" ) ) define( "CS2_EPG_CHANNEL", "CS24" );
13
14
15 function check_file( $file ) {
16 // ファイルがないなら無問題
17 if( ! file_exists( $file ) ) return true;
18
19 // 1時間以上前のファイルなら削除してやり直す
20 if( (time() - filemtime( $file )) > 3600 ) {
21 @unlink( $file );
22 return true;
23 }
24
25 return false;
26 }
27
9 $settings = Settings::factory(); 28 $settings = Settings::factory();
10 29
30 $temp_xml_bs = $settings->temp_xml."_bs";
31 $temp_xml_cs1 = $settings->temp_xml."_cs1";
32 $temp_xml_cs2 = $settings->temp_xml."_cs2";
33 $temp_xml_gr = $settings->temp_xml."_gr";
34
11 if( file_exists( $settings->temp_data ) ) @unlink( $settings->temp_data ); 35 if( file_exists( $settings->temp_data ) ) @unlink( $settings->temp_data );
12 if( file_exists( $settings->temp_xml ) ) @unlink( $settings->temp_xml ); 36
13
14 // BSを処理する 37 // BSを処理する
15 if( $settings->bs_tuners != 0 ) { 38 if( $settings->bs_tuners != 0 ) {
16 // 録画重複チェック 39 // 録画重複チェック
17 $num = DBRecord::countRecords( RESERVE_TBL, "WHERE complete = '0' AND (type = 'BS' OR type = 'CS') AND endtime > now() AND starttime < addtime( now(), '00:03:05')" ); 40 $num = DBRecord::countRecords( RESERVE_TBL, "WHERE complete = '0' AND (type = 'BS' OR type = 'CS') AND endtime > now() AND starttime < addtime( now(), '00:03:05')" );
18 if( $num < $settings->bs_tuners ) { 41 if( $num < $settings->bs_tuners ) { //xxx
19 $cmdline = "CHANNEL=211 DURATION=180 TYPE=BS TUNER=0 MODE=0 OUTPUT=".$settings->temp_data." ".DO_RECORD . " >/dev/null 2>&1"; 42 // if( ($num == 0) && check_file($temp_xml_bs) ) { //orig
43 $cmdline = "CHANNEL=".BS_EPG_CHANNEL." DURATION=180 TYPE=BS TUNER=0 MODE=0 OUTPUT=".$settings->temp_data." ".DO_RECORD . " >/dev/null 2>&1";
20 exec( $cmdline ); 44 exec( $cmdline );
21 $cmdline = $settings->epgdump." /BS ".$settings->temp_data." ".$settings->temp_xml; 45 $cmdline = $settings->epgdump." /BS ".$settings->temp_data." ".$temp_xml_bs;
22 exec( $cmdline ); 46 exec( $cmdline );
23 storeProgram( "BS", $settings->temp_xml ); 47 $cmdline = INSTALL_PATH."/storeProgram.php BS ".$temp_xml_bs." >/dev/null 2>&1 &";
48 exec( $cmdline );
24 if( file_exists( $settings->temp_data ) ) @unlink( $settings->temp_data ); 49 if( file_exists( $settings->temp_data ) ) @unlink( $settings->temp_data );
25 if( file_exists( $settings->temp_xml ) ) @unlink( $settings->temp_xml ); 50 }
26 51
27 // CS 52 // CS
28 if ($settings->cs_rec_flg != 0) { 53 if ($settings->cs_rec_flg != 0) {
29 $cmdline = "CHANNEL=CS8 DURATION=120 TYPE=CS TUNER=0 MODE=0 OUTPUT=".$settings->temp_data." ".DO_RECORD . " >/dev/null 2>&1"; 54 $num = DBRecord::countRecords( RESERVE_TBL, "WHERE complete = '0' AND (type = 'BS' OR type = 'CS') AND endtime > now() AND starttime < addtime( now(), '00:03:05')" );
55 if( ($num == 0) && check_file($temp_xml_cs1) ) {
56 $cmdline = "CHANNEL=".CS1_EPG_CHANNEL." DURATION=120 TYPE=CS TUNER=0 MODE=0 OUTPUT=".$settings->temp_data." ".DO_RECORD . " >/dev/null 2>&1";
30 exec( $cmdline ); 57 exec( $cmdline );
31 $cmdline = $settings->epgdump." /CS ".$settings->temp_data." ".$settings->temp_xml; 58 $cmdline = $settings->epgdump." /CS ".$settings->temp_data." ".$temp_xml_cs1;
32 exec( $cmdline ); 59 exec( $cmdline );
33 storeProgram( "CS", $settings->temp_xml ); 60 $cmdline = INSTALL_PATH."/storeProgram.php CS ".$temp_xml_cs1." >/dev/null 2>&1 &";
61 exec( $cmdline );
34 if( file_exists( $settings->temp_data ) ) @unlink( $settings->temp_data ); 62 if( file_exists( $settings->temp_data ) ) @unlink( $settings->temp_data );
35 if( file_exists( $settings->temp_xml ) ) @unlink( $settings->temp_xml ); 63 }
36 64 $num = DBRecord::countRecords( RESERVE_TBL, "WHERE complete = '0' AND (type = 'BS' OR type = 'CS') AND endtime > now() AND starttime < addtime( now(), '00:03:05')" );
37 $cmdline = "CHANNEL=CS24 DURATION=120 TYPE=CS TUNER=0 MODE=0 OUTPUT=".$settings->temp_data." ".DO_RECORD . " >/dev/null 2>&1"; 65 if( ($num == 0) && check_file($temp_xml_cs2) ) {
66 $cmdline = "CHANNEL=".CS2_EPG_CHANNEL." DURATION=120 TYPE=CS TUNER=0 MODE=0 OUTPUT=".$settings->temp_data." ".DO_RECORD . " >/dev/null 2>&1";
38 exec( $cmdline ); 67 exec( $cmdline );
39 $cmdline = $settings->epgdump." /CS ".$settings->temp_data." ".$settings->temp_xml; 68 $cmdline = $settings->epgdump." /CS ".$settings->temp_data." ".$temp_xml_cs2;
40 exec( $cmdline ); 69 exec( $cmdline );
41 storeProgram( "CS", $settings->temp_xml ); 70 $cmdline = INSTALL_PATH."/storeProgram.php CS ".$temp_xml_cs2." >/dev/null 2>&1 &";
71 exec( $cmdline );
42 if( file_exists( $settings->temp_data ) ) @unlink( $settings->temp_data ); 72 if( file_exists( $settings->temp_data ) ) @unlink( $settings->temp_data );
43 if( file_exists( $settings->temp_xml ) ) @unlink( $settings->temp_xml );
44 } 73 }
45 } 74 }
46 } 75 }
47 76
48 // 地上波を処理する 77 // 地上波を処理する
49 if( $settings->gr_tuners != 0 ) { 78 if( $settings->gr_tuners != 0 ) {
50 foreach( $GR_CHANNEL_MAP as $key=>$value ){ 79 foreach( $GR_CHANNEL_MAP as $key=>$value ){
51 // 録画重複チェック 80 // 録画重複チェック
52 $num = DBRecord::countRecords( RESERVE_TBL, "WHERE complete = '0' AND type = 'GR' AND endtime > now() AND starttime < addtime( now(), '00:01:10')" ); 81 $num = DBRecord::countRecords( RESERVE_TBL, "WHERE complete = '0' AND type = 'GR' AND endtime > now() AND starttime < addtime( now(), '00:01:10')" );
53 if( $num < $settings->gr_tuners ) { 82 if( $num < $settings->gr_tuners ) { //xxx
83 // if( ($num == 0) && check_file($temp_xml_gr.$value."") ) {
54 $cmdline = "CHANNEL=".$value." DURATION=60 TYPE=GR TUNER=0 MODE=0 OUTPUT=".$settings->temp_data." ".DO_RECORD . " >/dev/null 2>&1"; 84 $cmdline = "CHANNEL=".$value." DURATION=60 TYPE=GR TUNER=0 MODE=0 OUTPUT=".$settings->temp_data." ".DO_RECORD . " >/dev/null 2>&1";
55 exec( $cmdline ); 85 exec( $cmdline );
56 $cmdline = $settings->epgdump." ".$key." ".$settings->temp_data." ".$settings->temp_xml; 86 $cmdline = $settings->epgdump." ".$key." ".$settings->temp_data." ".$temp_xml_gr.$value."";
57 exec( $cmdline ); 87 exec( $cmdline );
58 storeProgram( "GR", $settings->temp_xml ); 88 $cmdline = INSTALL_PATH."/storeProgram.php GR ".$temp_xml_gr.$value." >/dev/null 2>&1 &";
59 if( file_exists( $settings->temp_data ) ) @unlink( $settings->temp_data ); 89 exec( $cmdline );
60 if( file_exists( $settings->temp_xml ) ) @unlink( $settings->temp_xml ); 90 if( file_exists( $settings->temp_data ) ) @unlink( $settings->temp_data );
61 } 91 }
62 } 92 }
63 } 93 }
64 94
65 // 不要なプログラムの削除
66 // 8日以上前のプログラムを消す
67 $arr = array();
68 $arr = DBRecord::createRecords( PROGRAM_TBL, "WHERE endtime < subdate( now(), 8 )" );
69 foreach( $arr as $val ) $val->delete();
70
71 // 8日以上先のデータがあれば消す
72 $arr = array();
73 $arr = DBRecord::createRecords( PROGRAM_TBL, "WHERE starttime > adddate( now(), 8 )" );
74 foreach( $arr as $val ) $val->delete();
75
76 // キーワード自動録画予約
77 $arr = array();
78 $arr = Keyword::createKeywords();
79 foreach( $arr as $val ) {
80 try {
81 $val->reservation();
82 }
83 catch( Exception $e ) {
84 // 無視
85 }
86 }
87
88 exit();
89
90 function storeProgram( $type, $xmlfile ) {
91 global $BS_CHANNEL_MAP, $GR_CHANNEL_MAP, $CS_CHANNEL_MAP;
92 // チャンネルマップファイルの準備
93 $map = array();
94 if( $type == "BS" ) $map = $BS_CHANNEL_MAP;
95 else if( $type == "GR") $map = $GR_CHANNEL_MAP;
96 else if( $type == "CS") $map = $CS_CHANNEL_MAP;
97
98 // XML parse
99 $xml = @simplexml_load_file( $xmlfile );
100 if( $xml === false ) {
101 return; // XMLが読み取れないなら何もしない
102 }
103 // channel抽出
104 foreach( $xml->channel as $ch ) {
105 $disc = $ch['id'];
106 try {
107 // チャンネルデータを探す
108 $num = DBRecord::countRecords( CHANNEL_TBL , "WHERE channel_disc = '" . $disc ."'" );
109 if( $num == 0 ) {
110 // チャンネルデータがないなら新規作成
111 $rec = new DBRecord( CHANNEL_TBL );
112 $rec->type = $type;
113 $rec->channel = $map["$disc"];
114 $rec->channel_disc = $disc;
115 $rec->name = $ch->{'display-name'};
116 }
117 else {
118 // 存在した場合も、とりあえずチャンネル名は更新する
119 $rec = new DBRecord(CHANNEL_TBL, "channel_disc", $disc );
120 $rec->name = $ch->{'display-name'};
121 }
122 }
123 catch( Exception $e ) {
124 // 無視
125 }
126 }
127 // channel 終了
128
129 // programme 取得
130
131 foreach( $xml->programme as $program ) {
132 $channel_disc = $program['channel'];
133 $channel = $map["$channel_disc"];
134 $starttime = str_replace(" +0900", '', $program['start'] );
135 $endtime = str_replace( " +0900", '', $program['stop'] );
136 $title = $program->title;
137 $desc = $program->desc;
138 $cat_ja = "";
139 $cat_en = "";
140 foreach( $program->category as $cat ) {
141 if( $cat['lang'] == "ja_JP" ) $cat_ja = $cat;
142 if( $cat['lang'] == "en" ) $cat_en = $cat;
143 }
144 $program_disc = md5( $channel_disc . $starttime . $endtime );
145 // printf( "%s %s %s %s %s %s %s \n", $program_disc, $channel, $starttime, $endtime, $title, $desc, $cat_ja );
146 try {
147 // カテゴリを処理する
148 $category_disc = md5( $cat_ja . $cat_en );
149 $num = DBRecord::countRecords(CATEGORY_TBL, "WHERE category_disc = '".$category_disc."'" );
150 $cat_rec = null;
151 if( $num == 0 ) {
152 // 新規カテゴリの追加
153 $cat_rec = new DBRecord( CATEGORY_TBL );
154 $cat_rec->name_jp = $cat_ja;
155 $cat_rec->name_en = $cat_en;
156 $cat_rec->category_disc = $category_disc;
157 }
158 else
159 $cat_rec = new DBRecord(CATEGORY_TBL, "category_disc" , $category_disc );
160 //
161 $channel_rec = new DBRecord(CHANNEL_TBL, "channel_disc", $channel_disc );
162 $num = DBRecord::countRecords(PROGRAM_TBL, "WHERE program_disc = '".$program_disc."'" );
163 if( $num == 0 ) {
164 // 新規番組
165 // 重複チェック 同時間帯にある番組
166 $options = "WHERE channel_disc = '".$channel_disc."' ".
167 "AND starttime < '". $endtime ."' AND endtime > '".$starttime."'";
168 $battings = DBRecord::countRecords(PROGRAM_TBL, $options );
169 if( $battings > 0 ) {
170 // 重複発生＝おそらく放映時間の変更
171 $records = DBRecord::createRecords(PROGRAM_TBL, $options );
172 foreach( $records as $rec ) {
173 // 自動録画予約された番組は放映時間変更と同時にいったん削除する
174 try {
175 $reserve = new DBRecord(RESERVE_TBL, "program_id", $rec->id );
176 if( $reserve->autorec ) {
177 Reservation::cancel( $reserve->id );
178 }
179 }
180 catch( Exception $e ) {
181 //無視
182 }
183 // 番組削除
184 $rec->delete();
185 }
186 }
187 // //
188 $rec = new DBRecord( PROGRAM_TBL );
189 $rec->channel_disc = $channel_disc;
190 $rec->channel_id = $channel_rec->id;
191 $rec->type = $type;
192 $rec->channel = $channel_rec->channel;
193 $rec->title = $title;
194 $rec->description = $desc;
195 $rec->category_id = $cat_rec->id;
196 $rec->starttime = $starttime;
197 $rec->endtime = $endtime;
198 $rec->program_disc = $program_disc;
199 }
200 else {
201 // 番組内容更新
202 $rec = new DBRecord( PROGRAM_TBL, "program_disc", $program_disc );
203 $rec->title = $title;
204 $rec->description = $desc;
205 $rec->category_id = $cat_rec->id;
206 }
207 }
208 catch(Exception $e) {
209 exit( $e->getMessage() );
210 }
211 }
212 }
213 ?> 95 ?>