table_name = $wpdb->prefix . AWS_INDEX_TABLE_NAME;
add_action( 'wp_insert_post', array( $this, 'update_table' ), 10, 3 );
add_action( 'aws_settings_saved', array( $this, 'clear_cache' ) );
add_action( 'aws_cache_clear', array( $this, 'clear_cache' ) );
add_action( 'create_term', array( &$this, 'term_changed' ), 10, 3 );
add_action( 'delete_term', array( &$this, 'term_changed' ), 10, 3 );
add_action( 'edit_term', array( &$this, 'term_changed' ), 10, 3 );
add_action( 'woocommerce_variable_product_sync', array( &$this, 'variable_product_changed' ), 10, 2 );
add_action( 'wp_ajax_aws-reindex', array( $this, 'reindex_table' ) );
add_action( 'wp_ajax_aws-cancel-index', array( $this, 'cancel_reindex' ) );
add_action( 'wp_ajax_aws-clear-cache', array( &$this, 'clear_cache' ) );
}
/*
* Reindex plugin table
*/
public function reindex_table() {
global $wpdb;
$index_meta = get_option( 'aws_index_meta', false );
$status = false;
// No current index going on. Let's start over
if ( false === $index_meta ) {
$status = 'start';
$index_meta = array(
'offset' => 0,
'start' => true,
);
$wpdb->query("DROP TABLE IF EXISTS {$this->table_name}");
$this->create_table();
} else if ( ! empty( $index_meta['site_stack'] ) && $index_meta['offset'] >= $index_meta['found_posts'] ) {
$status = 'start';
$index_meta['start'] = true;
$index_meta['offset'] = 0;
$index_meta['current_site'] = array_shift( $index_meta['site_stack'] );
} else {
$index_meta['start'] = false;
}
$index_meta = apply_filters( 'aws_index_meta', $index_meta );
$posts_per_page = apply_filters( 'aws_index_posts_per_page', 100 );
$args = array(
'posts_per_page' => $posts_per_page,
'fields' => 'ids',
'post_type' => 'product',
'post_status' => 'publish',
'offset' => $index_meta['offset'],
'ignore_sticky_posts' => true,
'suppress_filters' => true,
'no_found_rows' => 1,
'orderby' => 'ID',
'order' => 'DESC',
);
$posts = get_posts( $args );
$index_meta['found_posts'] = count( $posts );
if ( $status !== 'start' ) {
if ( $posts && count( $posts ) > 0 ) {
$queued_posts = array();
foreach( $posts as $post_id ) {
$queued_posts[] = absint( $post_id );
}
$this->fill_table( $queued_posts );
$index_meta['offset'] = absint( $index_meta['offset'] + $posts_per_page );
if ( $index_meta['offset'] >= $index_meta['found_posts'] ) {
$index_meta['offset'] = $index_meta['found_posts'];
}
update_option( 'aws_index_meta', $index_meta );
} else {
// We are done (with this site)
$index_meta['offset'] = (int) count( $posts );
delete_option( 'aws_index_meta' );
$this->clear_cache();
update_option( 'aws_reindex_version', AWS_VERSION );
}
} else {
update_option( 'aws_index_meta', $index_meta );
}
wp_send_json_success( $index_meta );
}
/*
* Check if index table exist
*/
private function is_table_not_exist() {
global $wpdb;
return ( $wpdb->get_var( "SHOW TABLES LIKE '{$this->table_name}'" ) != $this->table_name );
}
/*
* Create index table
*/
private function create_table() {
global $wpdb;
$charset_collate = $wpdb->get_charset_collate();
$sql = "CREATE TABLE {$this->table_name} (
id BIGINT(20) UNSIGNED NOT NULL DEFAULT 0,
term VARCHAR(50) NOT NULL DEFAULT 0,
term_source VARCHAR(20) NOT NULL DEFAULT 0,
type VARCHAR(50) NOT NULL DEFAULT 0,
count BIGINT(20) UNSIGNED NOT NULL DEFAULT 0,
in_stock INT(11) NOT NULL DEFAULT 0,
visibility VARCHAR(20) NOT NULL DEFAULT 0,
lang VARCHAR(20) NOT NULL DEFAULT 0
) $charset_collate;";
require_once( ABSPATH . 'wp-admin/includes/upgrade.php' );
dbDelta( $sql );
}
/*
* Insert data into the index table
*/
private function fill_table( $posts ) {
foreach ( $posts as $found_post_id ) {
$data = array();
$data['terms'] = array();
$data['id'] = $found_post_id;
$product = wc_get_product( $data['id'] );
$lang = has_filter( 'wpml_post_language_details' ) ? apply_filters( 'wpml_post_language_details', NULL, $data['id'] ) : '';
$data['in_stock'] = ( $product->get_stock_status() === 'outofstock' ) ? 0 : 1;
$data['visibility'] = $product->get_catalog_visibility() ? $product->get_catalog_visibility() : ( $product->get_visibility() ? $product->get_visibility() : 'visible' );
$data['lang'] = $lang ? $lang['language_code'] : '';
$sku = $product->get_sku();
$title = apply_filters( 'the_title', get_the_title( $data['id'] ) );
$content = apply_filters( 'the_content', get_post_field( 'post_content', $data['id'] ) );
$excerpt = get_post_field( 'post_excerpt', $data['id'] );
$cat_names = $this->get_terms_names_list( $data['id'], 'product_cat' );
$tag_names = $this->get_terms_names_list( $data['id'], 'product_tag' );
// Get all child products if exists
if ( $product->is_type( 'variable' ) && class_exists( 'WC_Product_Variation' ) ) {
if ( sizeof( $product->get_children() ) > 0 ) {
foreach ( $product->get_children() as $child_id ) {
$variation_product = new WC_Product_Variation( $child_id );
$variation_sku = $variation_product->get_sku();
$variation_desc = '';
if ( method_exists( $variation_product, 'get_description' ) ) {
$variation_desc = $variation_product->get_description();
}
if ( $variation_sku ) {
$sku = $sku . ' ' . $variation_sku;
}
if ( $variation_desc ) {
$content = $content . ' ' . $variation_desc;
}
}
}
}
// WP 4.2 emoji strip
if ( function_exists( 'wp_encode_emoji' ) ) {
$content = wp_encode_emoji( $content );
}
$content = strip_shortcodes( $content );
$data['terms']['title'] = $this->extract_terms( $title );
$data['terms']['content'] = $this->extract_terms( $content );
$data['terms']['excerpt'] = $this->extract_terms( $excerpt );
$data['terms']['sku'] = $this->extract_terms( $sku );
$data['terms']['category'] = $this->extract_terms( $cat_names );
$data['terms']['tag'] = $this->extract_terms( $tag_names );
// Get translations if exists
if ( has_filter('wpml_element_has_translations') && has_filter('wpml_get_element_translations') ) {
$is_translated = apply_filters( 'wpml_element_has_translations', NULL, $data['id'], 'post_product' );
if ( $is_translated ) {
$translations = apply_filters( 'wpml_get_element_translations', NULL, $data['id'], 'post_product');
foreach( $translations as $language => $lang_obj ) {
if ( ! $lang_obj->original && $lang_obj->post_status === 'publish' ) {
$translated_post = get_post( $lang_obj->element_id );
if ( $translated_post && !empty( $translated_post ) ) {
$translated_post_data = array();
$translated_post_data['id'] = $translated_post->ID;
$translated_post_data['in_stock'] = $data['in_stock'];
$translated_post_data['visibility'] = $data['visibility'];
$translated_post_data['lang'] = $lang_obj->language_code;
$translated_post_data['terms'] = array();
$translated_title = apply_filters( 'the_title', get_the_title( $translated_post->ID ) );
$translated_content = apply_filters( 'the_content', get_post_field( 'post_content', $translated_post->ID ) );
$translated_excerpt = get_post_field( 'post_excerpt', $translated_post->ID );
$translated_post_data['terms']['title'] = $this->extract_terms( $translated_title );
$translated_post_data['terms']['content'] = $this->extract_terms( $translated_content );
$translated_post_data['terms']['excerpt'] = $this->extract_terms( $translated_excerpt );
$translated_post_data['terms']['sku'] = $this->extract_terms( $sku );
//Insert translated product data into table
$this->insert_into_table( $translated_post_data );
}
}
}
}
}
//Insert data into table
$this->insert_into_table( $data );
}
}
/*
* Scrap all product data and insert to table
*/
private function insert_into_table( $data ) {
global $wpdb;
$values = array();
foreach( $data['terms'] as $source => $all_terms ) {
foreach ( $all_terms as $term => $count ) {
if ( ! $term ) {
continue;
}
$value = $wpdb->prepare(
"(%d, %s, %s, %s, %d, %d, %s, %s)",
$data['id'], $term, $source, 'product', $count, $data['in_stock'], $data['visibility'], $data['lang']
);
$values[] = $value;
}
}
if ( count( $values ) > 0 ) {
$values = implode( ', ', $values );
$query = "INSERT IGNORE INTO {$this->table_name}
(`id`, `term`, `term_source`, `type`, `count`, `in_stock`, `visibility`, `lang`)
VALUES $values
";
$wpdb->query( $query );
}
}
/*
* Update index table
*/
public function update_table( $post_id, $post, $update ) {
global $wpdb;
if ( $this->is_table_not_exist() ) {
$this->create_table();
}
$slug = 'product';
if ( $slug != $post->post_type ) {
return;
}
$wpdb->delete( $this->table_name, array( 'id' => $post_id ) );
$posts = get_posts( array(
'posts_per_page' => -1,
'fields' => 'ids',
'post_type' => 'product',
'post_status' => 'publish',
'suppress_filters' => false,
'no_found_rows' => 1,
'include' => $post_id
) );
$this->fill_table( $posts );
$this->clear_cache();
}
/*
* Fires when products terms are changed
*/
public function term_changed( $term_id, $tt_id, $taxonomy ) {
if ( $taxonomy === 'product_cat' || $taxonomy === 'product_tag' ) {
do_action( 'aws_cache_clear' );
}
}
/*
* Fires when products variations are changed
*/
public function variable_product_changed( $product_id, $children ) {
global $wpdb;
if ( $this->is_table_not_exist() ) {
$this->create_table();
}
$wpdb->delete( $this->table_name, array( 'id' => $product_id ) );
$posts = get_posts( array(
'posts_per_page' => -1,
'fields' => 'ids',
'post_type' => 'product',
'post_status' => 'publish',
'suppress_filters' => false,
'no_found_rows' => 1,
'include' => $product_id
) );
$this->fill_table( $posts );
$this->clear_cache();
}
/*
* Cancel index
*/
public function cancel_reindex() {
delete_option( 'aws_index_meta' );
wp_send_json_success( 'Deleted!' );
}
/*
* Clear search cache
*/
public function clear_cache() {
global $wpdb;
$table_name = "aws_search_term_%";
$sql = "DELETE FROM $wpdb->options
WHERE option_name LIKE '{$table_name}'
";
$wpdb->query( $sql );
}
/*
* Extract terms from content
*/
private function extract_terms( $str ) {
$str = AWS_Helpers::html2txt( $str );
// Avoid single A-Z.
//$str = preg_replace( '/\b\w{1}\b/i', " ", $str );
$str = str_replace( array(
'_',
'|',
'+',
'`',
'~',
'!',
'@',
'#',
'$',
'%',
'^',
'&',
'*',
'(',
')',
'\\',
'?',
';',
':',
"'",
'"',
".",
",",
"<",
">",
"{",
"}",
"/",
"[",
"]",
), "", $str );
$str = str_replace( array(
"ˇ",
"°",
"Ë›",
"Ëť",
"¸",
"§",
"=",
"¨",
"’",
"â€",
"”",
"“",
"„",
"´",
"—",
"–",
"Ă—",
'’',
" ",
chr( 194 ) . chr( 160 )
), " ", $str );
$str = str_replace( 'Ăź', 'ss', $str );
//$str = preg_replace( '/[[:punct:]]+/u', ' ', $str );
$str = preg_replace( '/[[:space:]]+/', ' ', $str );
// Most objects except unicode characters
$str = preg_replace( '/[\x00-\x08\x0B\x0C\x0E-\x1F\x80-\x9F]/u', '', $str );
// Line feeds, carriage returns, tabs
$str = preg_replace( '/[\x00-\x1F\x80-\x9F]/u', '', $str );
$str = strtolower( $str );
$str = preg_replace( '/^[a-z]$/i', "", $str );
$str = trim( preg_replace( '/\s+/', ' ', $str ) );
$str_array = array_count_values( explode( ' ', $str ) );
return $str_array;
}
/*
* Removes scripts, styles, html tags
*/
private function html2txt( $str ) {
$search = array(
'@@si',
'@<[\/\!]*?[^<>]*?>@si',
'@@siU',
'@@'
);
$text = preg_replace( $search, '', $str );
return $text;
}
/*
* Get string with current product terms ids
*
* @return string List of terms ids
*/
private function get_terms_list( $id, $taxonomy ) {
$terms = get_the_terms( $id, $taxonomy );
if ( is_wp_error( $terms ) ) {
return '';
}
if ( empty( $terms ) ) {
return '';
}
$cats_array_temp = array();
foreach ( $terms as $term ) {
$cats_array_temp[] = $term->term_id;
}
return implode( ', ', $cats_array_temp );
}
/*
* Get string with current product terms names
*
* @return string List of terms names
*/
private function get_terms_names_list( $id, $taxonomy ) {
$terms = get_the_terms( $id, $taxonomy );
if ( is_wp_error( $terms ) ) {
return '';
}
if ( empty( $terms ) ) {
return '';
}
$cats_array_temp = array();
foreach ( $terms as $term ) {
$cats_array_temp[] = $term->name;
}
return implode( ', ', $cats_array_temp );
}
}
endif;
new AWS_Table();