<?php
if ( ! defined( 'ABSPATH' ) ) {
		exit;
} // Exit if accessed directly

class atkp_asa1_helper {

		const DB_COLL = 'asa_collection';
		const DB_COLL_ITEM = 'asa_collection_item';

		protected $bb_regex_collection = '#\[asa_collection(.[^\]]*|)\]([\w-\s]+)\[/asa_collection\]#Usi';
		protected $bb_regex = '#\[asa(.[^\]]*|)\]([\w-]+)\[/asa\]#Usi';
		protected $_regex_param_separator = '/(,)(?=(?:[^"]|"[^"]*")*$)/m';

		public function getCollectionId( $collection_label ) {
				global $wpdb;

				$sql = '
                SELECT collection_id
                FROM `' . $wpdb->prefix . atkp_asa1_helper::DB_COLL . '`
                WHERE collection_label = "' . esc_sql( $collection_label ) . '"
            ';

				return $wpdb->get_var( $sql );
		}

		public function getCollectionLabels() {
				global $wpdb;

				$sql = '
                SELECT collection_label
                FROM `' . $wpdb->prefix . atkp_asa1_helper::DB_COLL . '`
            ';

				return $wpdb->get_results( $sql );
		}

		public function getCollectionItems( $collection_id ) {
				global $wpdb;

				$sql = '
                SELECT collection_item_asin
                FROM `' . $wpdb->prefix . atkp_asa1_helper::DB_COLL_ITEM . '`
                WHERE collection_id = "' . esc_sql( $collection_id ) . '"
                ORDER by collection_item_timestamp DESC
            ';

				$result = $wpdb->get_results( $sql );

				return $result;
		}

		public function createProductsFromPost( $id, $content, &$messages ) {
				$shopid     = get_option( ATKP_PLUGIN_PREFIX . '_asa_shopid' );
				$poststatus = get_option( ATKP_PLUGIN_PREFIX . '_asa_poststatus', 'publish' );

				$matches = array();

				// single items
				preg_match_all( $this->bb_regex, $content, $matches );

				if ( $matches && count( $matches[0] ) > 0 ) {

						for ( $i = 0; $i < count( $matches[0] ); $i ++ ) {

								try {

										$asin = $matches[2][ $i ];

										$created = $this->createProduct( $asin, $shopid, $poststatus );

										array_push( $messages, 'ID: ' . $id . ' Product ' . $asin . ' productid: ' . $created );
								} catch ( Exception $e ) {
										array_push( $messages, 'ID: ' . $id . ' Exception: ' . $e->getMessage() );
								}

						}
				} else {
						array_push( $messages, 'ID: ' . $id . ' [asa] skipped' );
				}

		}

		private function createList( $name, $asins ) {

				$args  = array(
						'title'          => 'ASA:' . $name,
						'post_type'      => ATKP_LIST_POSTTYPE,
						'post_status'    => 'publish',
						'posts_per_page' => - 1
				);
				$posts = get_posts( $args );

				if ( count( $posts ) == 0 ) {
						$shopid     = get_option( ATKP_PLUGIN_PREFIX . '_asa_shopid' );
						$poststatus = get_option( ATKP_PLUGIN_PREFIX . '_asa_poststatus', 'publish' );

						if ( $shopid == '' || $shopid == null ) {
								throw new exception( 'ASA default shop is empty' );
						}

						global $user_ID;
						$new_post = array(
								'post_title'  => 'ASA:' . $name,
								'post_status' => 'publish',
								'post_author' => $user_ID,
								'post_type'   => ATKP_LIST_POSTTYPE,
						);
						$post_id  = wp_insert_post( $new_post );

						ATKPTools::set_post_setting( $post_id, ATKP_LIST_POSTTYPE . '_shopid', '' );

						$products = '';

						foreach ( $asins as $asin ) {
								$productid = $this->createProduct( $asin, $shopid, $poststatus );

								if ( $products == '' ) {
										$products = $productid;
								} else {
										$products .= "\n" . $productid;
								}

						}

						ATKPTools::set_post_setting( $post_id, ATKP_LIST_POSTTYPE . '_products', $products );

						$cronjob = new atkp_cronjob( array() );
						$cronjob->update_list( $post_id );

						return $post_id;
				} else {
						return $posts[0]->ID;
				}

		}

		private function createProduct( $asin, $shopid, $post_status = 'publish' ) {

				$args  = array(
						'meta_key'       => ATKP_PRODUCT_POSTTYPE . '_asin',
						'meta_value'     => $asin,
						'post_type'      => ATKP_PRODUCT_POSTTYPE,
						'post_status'    => 'publish',
						'posts_per_page' => - 1
				);
				$posts = get_posts( $args );

				if ( count( $posts ) == 0 ) {

						if ( $shopid == '' || $shopid == null ) {
								throw new exception( 'ASA default shop is empty' );
						}

						$globaltools = new atkp_global_tools();

						$gif_data = $globaltools->atkp_import_product( $shopid, $asin, 'ASIN', null, $post_status, '' );

						return $gif_data['postid'];
				} else {
						return $posts[0]->ID;
				}
		}

		public function createAllLists( &$messages ) {


				$collectionlabels = $this->getCollectionLabels();

				foreach ( $collectionlabels as $collection_entry ) {
						$asins            = array();
						$collection_label = $collection_entry->collection_label;

						$collection_id = $this->getCollectionId( $collection_label );

						$collection = $this->getCollectionItems( $collection_id );

						foreach ( $collection as $entry ) {

								array_push( $asins, $entry->collection_item_asin );
						}

						if ( count( $asins ) == 0 ) {
								array_push( $messages, 'List ASA:' . $collection_label . ' not created. Empty!' );
						} else {
								$created = $this->createList( $collection_label, $asins );

								array_push( $messages, 'List ASA:' . $collection_label . ' listid: ' . $created );
						}
				}
		}

		public function createListsFromPost( $id, $content, &$messages ) {
				$lists = array();

				$matches_coll = array();

				// collections
				preg_match_all( $this->bb_regex_collection, $content, $matches_coll );

				if ( $matches_coll && count( $matches_coll[0] ) > 0 ) {

						for ( $i = 0; $i < count( $matches_coll[0] ); $i ++ ) {
								try {

										$coll_label = $matches_coll[2][ $i ];

										$asins = array();

										if ( ! empty( $coll_label ) ) {

												$collection_id = $this->getCollectionId( $coll_label );

												$collection = $this->getCollectionItems( $collection_id );

												foreach ( $collection as $entry ) {

														array_push( $asins, $entry->collection_item_asin );
												}

												$created = $this->createList( $coll_label, $asins );

												array_push( $messages, 'ID: ' . $id . ' List ASA:' . $coll_label . ' listid: ' . $created );
										}

										//TODO: generate list

								} catch ( Exception $e ) {
										array_push( $messages, 'ID: ' . $id . ' Exception: ' . $e->getMessage() );
								}

						}
				} else {
						array_push( $messages, 'ID: ' . $id . ' [asa_collection] skipped' );
				}

				return $lists;
		}
}