1
|
|
|
<?php |
2
|
|
|
class WP_SYND_Action { |
3
|
|
|
private $args = array( |
4
|
|
|
'post_type' => 'wp-syndicate', |
5
|
|
|
'posts_per_page' => -1, |
6
|
|
|
'post_status' => 'publish' |
7
|
|
|
); |
8
|
|
|
private $post; |
9
|
|
|
private $host; |
10
|
|
|
private $match_count = 0; |
11
|
|
|
private $media_id; |
12
|
|
|
private $is_enclosure = false; |
13
|
|
|
private $enclosure_url; |
14
|
|
|
|
15
|
|
|
|
16
|
|
|
public function __construct() { |
17
|
|
|
add_filter( 'cron_schedules', array( $this, 'cron_schedules' ) ); |
18
|
|
|
add_action( 'publish_to_trash', array( $this, 'publish_to_trash' )); |
19
|
|
|
add_action( 'save_post', array( $this, 'set_event' ) ); |
20
|
|
|
add_action( 'admin_head', array( $this, 'ping' ) ); |
21
|
|
|
add_action( 'template_redirect', array( $this, 'ping' ) ); |
22
|
|
|
add_action( 'init', array( $this, 'init' ) ); |
23
|
|
|
} |
24
|
|
|
|
25
|
|
|
public function init() { |
26
|
|
|
$posts = get_posts($this->args); |
27
|
|
|
|
28
|
|
|
if ( empty($posts) ) |
29
|
|
|
return; |
30
|
|
|
|
31
|
|
|
foreach ( $posts as $post ) { |
32
|
|
|
add_action( 'wp_syndicate_' . $post->post_name . '_import', array( $this, 'import' ) ); |
33
|
|
|
} |
34
|
|
|
} |
35
|
|
|
|
36
|
|
|
public function publish_to_trash($post) { |
37
|
|
|
if ( 'wp-syndicate' !== $post->post_type ) |
38
|
|
|
return; |
39
|
|
|
|
40
|
|
|
$hook = 'wp_syndicate_' . str_replace( '__trashed', '', $post->post_name ) . '_import'; |
41
|
|
|
if ( wp_next_scheduled( $hook, array( $post->ID )) ) |
42
|
|
|
var_dump(wp_clear_scheduled_hook( $hook, array( $post->ID ) )); |
|
|
|
|
43
|
|
|
} |
44
|
|
|
|
45
|
|
|
public function ping() { |
46
|
|
|
$posts = get_posts($this->args); |
47
|
|
|
if ( empty($posts) ) |
48
|
|
|
return; |
49
|
|
|
|
50
|
|
|
foreach ( $posts as $post ) { |
51
|
|
|
$key = $post->post_name; |
52
|
|
|
$hook = 'wp_syndicate_' . $key . '_import'; |
53
|
|
|
|
54
|
|
|
if ( !wp_next_scheduled( $hook, array( $post->ID ) ) ) { |
55
|
|
|
$this->set_event($post->ID); |
56
|
|
|
$subject = '[' . get_bloginfo( 'name' ) . ']' . __( 'WP Cron Error', WPSYND_DOMAIN ); |
57
|
|
|
$msg = sprintf( __( '%s of WP Cron restart, because it stopped.', WPSYND_DOMAIN ), $hook ) . "\n". __( 'action time', WPSYND_DOMAIN ). ':' . date_i18n('Y/m/d:H:i:s') . "\n\n\n"; |
58
|
|
|
$msg .= admin_url(); |
59
|
|
|
WP_SYND_logger::get_instance()->error( $subject, $msg ); |
60
|
|
|
$options = get_option( 'wp_syndicate_options' ); |
61
|
|
|
wp_mail( $options['error_mail'], $subject, $msg ); |
62
|
|
|
} |
63
|
|
|
} |
64
|
|
|
} |
65
|
|
|
|
66
|
|
|
public function cron_schedules($schedules) { |
67
|
|
|
$posts = get_posts($this->args); |
68
|
|
|
|
69
|
|
|
if ( empty($posts) ) { |
70
|
|
|
return $schedules; |
71
|
|
|
} |
72
|
|
|
|
73
|
|
|
foreach ( $posts as $post ) { |
74
|
|
|
$key = 'wp_syndicate_' . $post->post_name; |
75
|
|
|
$interval_min = get_post_meta( $post->ID, 'wp_syndicate-feed-retrieve-term', true ); |
76
|
|
|
$interval = intval($interval_min)*60; |
77
|
|
|
$display = get_the_title( $post->ID ); |
78
|
|
|
$schedules[$key] = array( 'interval' => $interval, 'display' => $display ); |
79
|
|
|
} |
80
|
|
|
|
81
|
|
|
return $schedules; |
82
|
|
|
} |
83
|
|
|
|
84
|
|
|
public function set_event($post_id) { |
85
|
|
|
|
86
|
|
|
if ( wp_is_post_revision($post_id) ) |
87
|
|
|
return; |
88
|
|
|
|
89
|
|
|
if ( 'wp-syndicate' != get_post_type($post_id) ) |
90
|
|
|
return; |
91
|
|
|
|
92
|
|
|
$post = get_post( $post_id ); |
93
|
|
|
if ( !is_object($post) ) |
94
|
|
|
return; |
95
|
|
|
|
96
|
|
|
$key = $post->post_name; |
97
|
|
|
$interval_min = get_post_meta( $post_id, 'wp_syndicate-feed-retrieve-term', true ); |
98
|
|
|
$interval = intval($interval_min)*60; |
99
|
|
|
$action_time = time() + $interval; |
100
|
|
|
|
101
|
|
|
$hook = 'wp_syndicate_' . $key . '_import'; |
102
|
|
|
$event = 'wp_syndicate_' . $key; |
103
|
|
|
|
104
|
|
|
if ( wp_next_scheduled( $hook, array( $post_id )) ) |
105
|
|
|
wp_clear_scheduled_hook( $hook, array( $post_id ) ); |
106
|
|
|
|
107
|
|
|
wp_schedule_event( $action_time, $event, $hook, array( $post_id ) ); |
108
|
|
|
spawn_cron( $action_time ); |
109
|
|
|
} |
110
|
|
|
|
111
|
|
|
public function import($post_id) { |
112
|
|
|
global $allowedposttags; |
113
|
|
|
|
114
|
|
|
$allowedposttags = apply_filters( 'wp_syndicate_allowedposttags', $allowedposttags ); |
115
|
|
|
|
116
|
|
|
$options = get_option( 'wp_syndicate_options' ); |
117
|
|
|
$post = get_post($post_id); |
118
|
|
|
|
119
|
|
|
if ( !is_object($post) ) |
120
|
|
|
return; |
121
|
|
|
|
122
|
|
|
$this->media_id = $post_id; |
123
|
|
|
$feed_url = html_entity_decode(get_post_meta( $post_id, 'wp_syndicate-feed-url', true ), ENT_QUOTES, 'UTF-8'); |
124
|
|
|
|
125
|
|
|
add_action('wp_feed_options', function(&$feed){ |
126
|
|
|
$feed->set_timeout(30); |
127
|
|
|
$feed->force_feed(true); |
128
|
|
|
$feed->enable_cache(false); |
129
|
|
|
}, 10); |
130
|
|
|
|
131
|
|
|
add_filter( 'wp_feed_cache_transient_lifetime' , array( $this, 'return_0' ) ); |
132
|
|
|
$rss = fetch_feed( $feed_url ); |
133
|
|
|
remove_filter( 'wp_feed_cache_transient_lifetime' , array( $this, 'return_0' ) ); |
134
|
|
View Code Duplication |
if ( is_wp_error( $rss ) ) { |
135
|
|
|
$subject = '[' . get_bloginfo( 'name' ) . ']' . __( 'feed import failed', WPSYND_DOMAIN ); |
136
|
|
|
$msg = sprintf( __( 'An error occurred at a feed retrieval of %s', WPSYND_DOMAIN ), $post->post_name ) . "\n". __( 'action time', WPSYND_DOMAIN ). ':' . date_i18n('Y/m/d:H:i:s') . "\n\n\n"; |
137
|
|
|
$msg .= __( 'below error message', WPSYND_DOMAIN ) . "\n"; |
138
|
|
|
$msg .= $rss->get_error_message()."\n\n"; |
139
|
|
|
$msg .= __( 'feed URL', WPSYND_DOMAIN ) . ':' . $feed_url; |
140
|
|
|
$error_post_id = WP_SYND_logger::get_instance()->error( $subject, $msg ); |
141
|
|
|
$msg .= admin_url('/post.php?post=' . $error_post_id . '&action=edit'); |
142
|
|
|
wp_mail( $options['error_mail'], $subject, $msg ); |
143
|
|
|
return; |
144
|
|
|
} |
145
|
|
|
|
146
|
|
|
$url = parse_url($rss->get_base()); |
147
|
|
|
$this->host = $url['host']; |
148
|
|
|
|
149
|
|
|
$rss_items = $rss->get_items(0, 50); |
150
|
|
|
$post_ids = array(); |
151
|
|
|
$flg = true; |
152
|
|
|
$registration_method = get_post_meta( $post_id, 'wp_syndicate-registration-method', true ); |
153
|
|
|
$post_type = get_post_meta( $post_id, 'wp_syndicate-default-post-type', true ); |
154
|
|
|
foreach ( $rss_items as $item ) { |
155
|
|
|
$this->is_enclosure = false; |
156
|
|
|
|
157
|
|
|
//投稿ID取得 |
158
|
|
|
$slug = $post->post_name . '_' . $item->get_id(); |
159
|
|
|
$set_post = get_page_by_path( sanitize_title($slug), OBJECT, $post_type ); |
160
|
|
|
$set_post_id = $set_post == null ? '' : $set_post->ID; |
161
|
|
|
|
162
|
|
|
if ( empty($set_post_id) ) { |
163
|
|
|
global $wpdb; |
164
|
|
|
$db_ret = $wpdb->get_row( $wpdb->prepare( "SELECT count(1) as cnt FROM $wpdb->postmeta WHERE meta_key='%s'", $slug) ); |
165
|
|
|
if ( $db_ret === null || $db_ret->cnt !== '0' ) |
166
|
|
|
continue; |
167
|
|
|
} |
168
|
|
|
|
169
|
|
|
if ( $registration_method == 'insert' && is_object($set_post) ) { |
170
|
|
|
continue; |
171
|
|
|
} |
172
|
|
|
|
173
|
|
|
$updated = empty($set_post_id) ? false : true; |
174
|
|
|
$is_skip = apply_filters( 'wp_syndicate_is_skip', false, $item, $updated, $set_post_id, $post_id ); |
175
|
|
|
if ( $is_skip ) { |
176
|
|
|
continue; |
177
|
|
|
} |
178
|
|
|
|
179
|
|
|
$post_args = array( |
180
|
|
|
'ID' => $set_post_id, |
181
|
|
|
'post_name' => $slug, |
182
|
|
|
'post_date' => apply_filters( 'wp_syndicate_get_date', $item->get_date('Y/m/d H:i:s'), $post_id ), |
183
|
|
|
'post_title' => apply_filters( 'wp_syndicate_get_title', $item->get_title(), $post_id ), |
184
|
|
|
'post_content' => '', |
185
|
|
|
); |
186
|
|
|
if ( !$updated ) { |
187
|
|
|
$post_args['post_author'] = get_post_meta( $post_id, 'wp_syndicate-author-id', true ); |
188
|
|
|
$post_args['post_status'] = get_post_meta( $post_id, 'wp_syndicate-default-post-status', true ); |
189
|
|
|
$post_args['post_type'] = get_post_meta( $post_id, 'wp_syndicate-default-post-type', true ); |
190
|
|
|
} |
191
|
|
|
$this->post = new wp_post_helper($post_args); |
192
|
|
|
|
193
|
|
|
//画像の登録 |
194
|
|
|
if ( $updated ) { |
195
|
|
|
$images = get_attached_media( 'image', $set_post_id ); |
196
|
|
|
if ( is_array( $images ) ) { |
197
|
|
|
foreach ( $images as $image ) { |
198
|
|
|
wp_delete_attachment( $image->ID ); |
199
|
|
|
} |
200
|
|
|
} |
201
|
|
|
} |
202
|
|
|
|
203
|
|
|
$content = apply_filters( 'the_content', $item->get_content() ); |
204
|
|
|
if ( $item->get_enclosure() && !empty($item->get_enclosure()->link) ) { |
205
|
|
|
$this->is_enclosure = true; |
206
|
|
|
$this->set_enclosure( $item->get_enclosure()->link ); |
207
|
|
|
} |
208
|
|
|
|
209
|
|
|
$this->match_count = 0; |
210
|
|
|
$content = preg_replace_callback( '#<img([^>]*)src=["\']([^"\']+)["\']([^>]*)>#i', array($this, 'update_link'), $content, -1 ); |
211
|
|
|
$this->match_count = 0; |
212
|
|
|
$this->post->set(array( |
213
|
|
|
'post_content' => apply_filters( 'wp_syndicate_get_content', $content, $post_id ) |
214
|
|
|
)); |
215
|
|
|
$this->post->add_meta( 'wp_syndicate-origin-of-syndication-slug', $post->post_name, true ); |
216
|
|
|
$this->post->add_meta( 'wp_syndicate-origin-of-syndication-siteurl', $this->host, true ); |
217
|
|
|
|
218
|
|
|
$update_post_id = $this->post->update(); |
219
|
|
|
if ( !$update_post_id ) { |
220
|
|
|
$flg = false; |
221
|
|
|
} else { |
222
|
|
|
update_post_meta( $update_post_id, $slug, 1 ); |
223
|
|
|
do_action( 'wp_syndicate_save_post', $update_post_id, $item, $updated, $post_id ); |
224
|
|
|
$post_ids[] = $update_post_id; |
225
|
|
|
} |
226
|
|
|
} |
227
|
|
|
|
228
|
|
|
if ( $flg ) { |
229
|
|
|
$subject = '[' . get_bloginfo( 'name' ) . ']' . __( 'feed import success', WPSYND_DOMAIN ); |
230
|
|
|
$msg = __( 'feed URL:', WPSYND_DOMAIN ) . $feed_url . "\n"; |
231
|
|
|
$msg .= sprintf( __( 'Feed acquisition completion of %s', WPSYND_DOMAIN ), $post->post_name ) . "\n" . __( 'action time', WPSYND_DOMAIN ). ':' . date_i18n('Y/m/d:H:i:s') . "\n\n\n"; |
232
|
|
|
$msg .= __( 'below ID data updates', WPSYND_DOMAIN ) . "\n"; |
233
|
|
|
$msg .= implode( "\n", $post_ids ); |
234
|
|
|
WP_SYND_logger::get_instance()->success( $subject, $msg ); |
235
|
|
View Code Duplication |
} else { |
236
|
|
|
$subject = '[' . get_bloginfo( 'name' ) . ']' . __( 'feed import failed', WPSYND_DOMAIN ); |
237
|
|
|
$msg = __( 'feed URL:', WPSYND_DOMAIN ) . $feed_url . "\n"; |
238
|
|
|
$msg .= sprintf( __( 'Failed to some data registration of %s', WPSYND_DOMAIN ), $post->post_name ) . "\n". __( 'action time', WPSYND_DOMAIN ). ':' . date_i18n('Y/m/d:H:i:s') . "\n\n\n"; |
239
|
|
|
$msg .= __( 'below ID data updates', WPSYND_DOMAIN ) . "\n"; |
240
|
|
|
$msg .= implode( "\n", $post_ids ); |
241
|
|
|
$error_post_id = WP_SYND_logger::get_instance()->error( $subject, $msg ); |
242
|
|
|
$msg .= admin_url('/post.php?post=' . $error_post_id . '&action=edit'); |
243
|
|
|
wp_mail( $options['error_mail'], $subject, $msg ); |
244
|
|
|
} |
245
|
|
|
|
246
|
|
|
} |
247
|
|
|
|
248
|
|
|
public function return_0( $seconds ) { |
|
|
|
|
249
|
|
|
return 0; |
250
|
|
|
} |
251
|
|
|
|
252
|
|
|
public function update_link( $matches ) { |
253
|
|
|
|
254
|
|
|
if ( is_array($matches) && array_key_exists(2, $matches) && isset($this->post) && is_object($this->post) && is_a($this->post, 'wp_post_helper') ) { |
255
|
|
|
$args = array(); |
256
|
|
|
$user = get_post_meta( $this->media_id, 'wp_syndicate-basic-auth-user', true ); |
257
|
|
|
$pass = get_post_meta( $this->media_id, 'wp_syndicate-basic-auth-pass', true ); |
258
|
|
View Code Duplication |
if ( !empty($user) && !empty($pass) ) { |
259
|
|
|
$args = array( |
260
|
|
|
'headers' => array( 'Authorization' => 'Basic ' . base64_encode( $user . ':' . $pass ) ) |
261
|
|
|
); |
262
|
|
|
} |
263
|
|
|
|
264
|
|
|
$args['timeout'] = 30; |
265
|
|
|
if ( $media = remote_get_file($matches[2], '', $args) ) { |
266
|
|
|
|
267
|
|
|
if ( $this->is_enclosure === true ) { |
268
|
|
|
$thumnail_flg = false; |
269
|
|
|
} else { |
270
|
|
|
$thumnail_flg = $this->match_count > 0 ? false : true; |
271
|
|
|
} |
272
|
|
|
|
273
|
|
|
$url = preg_split( '/wp-content/', $media ); |
274
|
|
|
$url = home_url( 'wp-content' . $url[1] ); |
275
|
|
|
|
276
|
|
|
if ( $url == $this->enclosure_url ) { |
277
|
|
|
$thumnail_flg = true; |
278
|
|
|
} |
279
|
|
|
|
280
|
|
|
$this->post->add_media($media, '', '', '', $thumnail_flg); |
281
|
|
|
$this->match_count++; |
282
|
|
|
|
283
|
|
|
return apply_filters( 'wp_syndicate_return_img', '<img' . $matches[1] . 'src="' . $url . '"' . $matches[3] . '>', $thumnail_flg, $url, $this->enclosure_url, $this->match_count ); |
284
|
|
|
} else { |
285
|
|
|
return $matches[0]; |
286
|
|
|
} |
287
|
|
|
} |
288
|
|
|
return $matches[0]; |
289
|
|
|
} |
290
|
|
|
|
291
|
|
|
public function set_enclosure($link) { |
292
|
|
|
if ( !empty($link) && is_object($this->post) && is_a($this->post, 'wp_post_helper') ) { |
293
|
|
|
$args = array(); |
294
|
|
|
$user = get_post_meta( $this->media_id, 'wp_syndicate-basic-auth-user', true ); |
295
|
|
|
$pass = get_post_meta( $this->media_id, 'wp_syndicate-basic-auth-pass', true ); |
296
|
|
View Code Duplication |
if ( !empty($user) && !empty($pass) ) { |
297
|
|
|
$args = array( |
298
|
|
|
'headers' => array( 'Authorization' => 'Basic ' . base64_encode( $user . ':' . $pass ) ) |
299
|
|
|
); |
300
|
|
|
} |
301
|
|
|
|
302
|
|
|
$args['timeout'] = 30; |
303
|
|
|
if ( $media = remote_get_file($link, '', $args) ) { |
304
|
|
|
$this->post->add_media($media, '', '', '', true); |
305
|
|
|
$url = preg_split( '/wp-content/', $media ); |
306
|
|
|
$url = home_url( 'wp-content' . $url[1] ); |
307
|
|
|
$this->enclosure_url = $url; |
308
|
|
|
} |
309
|
|
|
} |
310
|
|
|
} |
311
|
|
|
} |
312
|
|
|
new WP_SYND_Action(); |
313
|
|
|
|