@@ -33,10 +33,10 @@ discard block |
||
33 | 33 | * @access private |
34 | 34 | */ |
35 | 35 | public function __construct() { |
36 | - add_filter( 'cron_schedules', array( $this, 'register_schedule' ), 10, 1 ); |
|
37 | - add_action( 'lsx_wetu_importer_settings_before', array( $this, 'watch_for_trigger' ), 200 ); |
|
38 | - add_action( 'lsx_wetu_accommodation_images_cron', array( $this, 'process' ), 10, 1 ); |
|
39 | - add_action( 'lsx_wetu_accommodation_images_sync', array( $this, 'cron_callback' ), 10, 1 ); |
|
36 | + add_filter('cron_schedules', array($this, 'register_schedule'), 10, 1); |
|
37 | + add_action('lsx_wetu_importer_settings_before', array($this, 'watch_for_trigger'), 200); |
|
38 | + add_action('lsx_wetu_accommodation_images_cron', array($this, 'process'), 10, 1); |
|
39 | + add_action('lsx_wetu_accommodation_images_sync', array($this, 'cron_callback'), 10, 1); |
|
40 | 40 | } |
41 | 41 | |
42 | 42 | /** |
@@ -48,7 +48,7 @@ discard block |
||
48 | 48 | */ |
49 | 49 | public static function get_instance() { |
50 | 50 | // If the single instance hasn't been set, set it now. |
51 | - if ( null === self::$instance ) { |
|
51 | + if (null === self::$instance) { |
|
52 | 52 | self::$instance = new self(); |
53 | 53 | } |
54 | 54 | return self::$instance; |
@@ -60,10 +60,10 @@ discard block |
||
60 | 60 | * @param array $schedules |
61 | 61 | * @return array |
62 | 62 | */ |
63 | - public function register_schedule( $schedules ) { |
|
63 | + public function register_schedule($schedules) { |
|
64 | 64 | $schedules['wetu-5-minutes'] = array( |
65 | 65 | 'interval' => 5 * MINUTE_IN_SECONDS, |
66 | - 'display' => __( 'Every 5 minutes', 'lsx-wetu-importer' ), |
|
66 | + 'display' => __('Every 5 minutes', 'lsx-wetu-importer'), |
|
67 | 67 | ); |
68 | 68 | return $schedules; |
69 | 69 | } |
@@ -75,26 +75,26 @@ discard block |
||
75 | 75 | */ |
76 | 76 | public function watch_for_trigger() { |
77 | 77 | |
78 | - if ( isset( $_GET['page'] ) && 'lsx-wetu-importer' === $_GET['page'] && isset( $_GET['tab'] ) && 'settings' === $_GET['tab'] ) { |
|
78 | + if (isset($_GET['page']) && 'lsx-wetu-importer' === $_GET['page'] && isset($_GET['tab']) && 'settings' === $_GET['tab']) { |
|
79 | 79 | $options = lsx_wetu_get_options(); |
80 | 80 | |
81 | 81 | // Check what state the option is in. |
82 | 82 | $accommodation_cron = 'deactivate'; |
83 | - if ( isset( $options['accommodation_images_cron'] ) && '' !== $options['accommodation_images_cron'] ) { |
|
83 | + if (isset($options['accommodation_images_cron']) && '' !== $options['accommodation_images_cron']) { |
|
84 | 84 | $accommodation_cron = 'activate'; |
85 | 85 | } |
86 | 86 | |
87 | 87 | // Check what state the cron is in. |
88 | 88 | $schedule = false; |
89 | - if ( wp_next_scheduled( 'lsx_wetu_accommodation_images_cron' ) ) { |
|
89 | + if (wp_next_scheduled('lsx_wetu_accommodation_images_cron')) { |
|
90 | 90 | $schedule = true; |
91 | 91 | } |
92 | 92 | |
93 | 93 | // If activate and its not running. |
94 | - if ( false === $schedule && 'activate' === $accommodation_cron ) { |
|
94 | + if (false === $schedule && 'activate' === $accommodation_cron) { |
|
95 | 95 | $schedule = 'daily'; |
96 | - $this->schedule( 'lsx_wetu_accommodation_images_cron', $schedule ); |
|
97 | - } elseif ( true === $schedule && 'deactivate' === $accommodation_cron ) { |
|
96 | + $this->schedule('lsx_wetu_accommodation_images_cron', $schedule); |
|
97 | + } elseif (true === $schedule && 'deactivate' === $accommodation_cron) { |
|
98 | 98 | $this->deactivate(); |
99 | 99 | } |
100 | 100 | } |
@@ -105,8 +105,8 @@ discard block |
||
105 | 105 | * |
106 | 106 | * @return void |
107 | 107 | */ |
108 | - public function deactivate( $task = 'lsx_wetu_accommodation_images_cron' ) { |
|
109 | - wp_clear_scheduled_hook( $task ); |
|
108 | + public function deactivate($task = 'lsx_wetu_accommodation_images_cron') { |
|
109 | + wp_clear_scheduled_hook($task); |
|
110 | 110 | } |
111 | 111 | |
112 | 112 | /** |
@@ -117,11 +117,11 @@ discard block |
||
117 | 117 | * @param string $time |
118 | 118 | * @return void |
119 | 119 | */ |
120 | - public function schedule( $task = 'lsx_wetu_accommodation_images_cron', $schedule = 'daily', $time = '' ) { |
|
121 | - if ( '' === $time ) { |
|
120 | + public function schedule($task = 'lsx_wetu_accommodation_images_cron', $schedule = 'daily', $time = '') { |
|
121 | + if ('' === $time) { |
|
122 | 122 | $time = time(); |
123 | 123 | } |
124 | - wp_schedule_event( $time, $schedule, $task, array( $task ) ); |
|
124 | + wp_schedule_event($time, $schedule, $task, array($task)); |
|
125 | 125 | } |
126 | 126 | |
127 | 127 | /** |
@@ -129,8 +129,8 @@ discard block |
||
129 | 129 | * |
130 | 130 | * @return void |
131 | 131 | */ |
132 | - public function process( $task = '' ) { |
|
133 | - switch ( $task ) { |
|
132 | + public function process($task = '') { |
|
133 | + switch ($task) { |
|
134 | 134 | case 'lsx_wetu_accommodation_images_cron': |
135 | 135 | $this->register_accommodation_images_sync(); |
136 | 136 | break; |
@@ -146,10 +146,10 @@ discard block |
||
146 | 146 | * @return void |
147 | 147 | */ |
148 | 148 | public function register_accommodation_images_sync() { |
149 | - $time = strtotime( '+1 min' ); |
|
150 | - if ( ! wp_next_scheduled( 'lsx_wetu_accommodation_images_sync' ) ) { |
|
151 | - $this->load_items_to_sync( 'accommodation_images' ); |
|
152 | - $this->schedule( 'lsx_wetu_accommodation_images_sync', 'wetu-5-minutes', $time ); |
|
149 | + $time = strtotime('+1 min'); |
|
150 | + if (!wp_next_scheduled('lsx_wetu_accommodation_images_sync')) { |
|
151 | + $this->load_items_to_sync('accommodation_images'); |
|
152 | + $this->schedule('lsx_wetu_accommodation_images_sync', 'wetu-5-minutes', $time); |
|
153 | 153 | } |
154 | 154 | } |
155 | 155 | |
@@ -158,22 +158,22 @@ discard block |
||
158 | 158 | * |
159 | 159 | * @return void |
160 | 160 | */ |
161 | - public function cron_callback( $task = '' ) { |
|
162 | - $has_accommodation = get_option( $task ); |
|
163 | - if ( false !== $has_accommodation && ! empty( $has_accommodation ) ) { |
|
164 | - $next_time = array_slice( $has_accommodation, 5 ); // returns "c", "d", and "e" |
|
165 | - $output = array_slice( $has_accommodation, 0, 4 ); // returns "a", "b", and "c" |
|
161 | + public function cron_callback($task = '') { |
|
162 | + $has_accommodation = get_option($task); |
|
163 | + if (false !== $has_accommodation && !empty($has_accommodation)) { |
|
164 | + $next_time = array_slice($has_accommodation, 5); // returns "c", "d", and "e" |
|
165 | + $output = array_slice($has_accommodation, 0, 4); // returns "a", "b", and "c" |
|
166 | 166 | |
167 | 167 | // Run through the current items. |
168 | 168 | |
169 | 169 | // Save the values for next time. |
170 | - if ( ! empty( $next_time ) ) { |
|
171 | - update_option( $task, $next_time ); |
|
172 | - } else { |
|
173 | - $this->deactivate( $task ); |
|
170 | + if (!empty($next_time)) { |
|
171 | + update_option($task, $next_time); |
|
172 | + }else { |
|
173 | + $this->deactivate($task); |
|
174 | 174 | } |
175 | - } else { |
|
176 | - $this->deactivate( $task ); |
|
175 | + }else { |
|
176 | + $this->deactivate($task); |
|
177 | 177 | } |
178 | 178 | } |
179 | 179 | |
@@ -183,14 +183,14 @@ discard block |
||
183 | 183 | * @param string $task |
184 | 184 | * @return void |
185 | 185 | */ |
186 | - public function load_items_to_sync( $task = 'accommodation_images' ) { |
|
186 | + public function load_items_to_sync($task = 'accommodation_images') { |
|
187 | 187 | $args = array( |
188 | 188 | 'post_status' => 'publish', |
189 | 189 | 'posts_per_page' => -1, |
190 | 190 | 'nopagin' => true, |
191 | 191 | 'fields' => 'ids', |
192 | 192 | ); |
193 | - switch ( $task ) { |
|
193 | + switch ($task) { |
|
194 | 194 | case 'accommodation_images': |
195 | 195 | $args['post_type'] = 'accommodation'; |
196 | 196 | break; |
@@ -198,9 +198,9 @@ discard block |
||
198 | 198 | default: |
199 | 199 | break; |
200 | 200 | } |
201 | - $items = new \WP_Query( $args ); |
|
202 | - if ( $items->have_posts() ) { |
|
203 | - update_option( 'lsx_wetu_' . $task . '_sync', $items->posts ); |
|
201 | + $items = new \WP_Query($args); |
|
202 | + if ($items->have_posts()) { |
|
203 | + update_option('lsx_wetu_'.$task.'_sync', $items->posts); |
|
204 | 204 | } |
205 | 205 | } |
206 | 206 | } |