<?php
/* Copyright (C) 2017 Open-DSI                     <support@open-dsi.fr>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 * or see http://www.gnu.org/
 */


include_once DOL_DOCUMENT_ROOT.'/core/lib/files.lib.php';
dol_include_once('/ecommerceng/class/data/eCommerceProduct.class.php');
dol_include_once('/ecommerceng/class/business/eCommerceSynchro.class.php');
dol_include_once('/ecommerceng/class/data/woocommerce/eCommerceRemoteAccessWoocommerce.class.php');

/**
 * Update the price for all product in the ecommerce product category for this site price level
 * @param eCommerceSite  $siteDb    Object eCommerceSite
 *
 * @return int                      <0 if KO, >0 if OK
 */
function updatePriceLevel($siteDb)
{
    global $db, $conf;

    if (!empty($conf->global->PRODUIT_MULTIPRICES) && $siteDb->price_level > 0 && $siteDb->price_level <= intval($conf->global->PRODUIT_MULTIPRICES_LIMIT)) {
        $sql = 'SELECT p.rowid';
        $sql.= ' FROM ' . MAIN_DB_PREFIX . 'product as p';
        $sql.= ' LEFT JOIN ' . MAIN_DB_PREFIX . "categorie_product as cp ON p.rowid = cp.fk_product";
        $sql.= ' WHERE p.entity IN (' . getEntity('product', 1) . ')';
        $sql.= ' AND cp.fk_categorie = ' . $siteDb->fk_cat_product;
        $sql.= ' GROUP BY p.rowid';

        $db->begin();

        dol_syslog("updatePriceLevel sql=" . $sql);
        $resql = $db->query($sql);
        if ($resql) {
            $product = new Product($db);
            $eCommerceProduct = new eCommerceProduct($db);

            while ($obj = $db->fetch_object($resql)) {
                $product->fetch($obj->rowid);
                $eCommerceProduct->fetchByProductId($obj->rowid, $siteDb->id);

                if ($eCommerceProduct->remote_id > 0) {
                    $eCommerceSynchro = new eCommerceSynchro($db, $siteDb);
                    $eCommerceSynchro->connect();
                    if (count($eCommerceSynchro->errors)) {
                        dol_syslog("updatePriceLevel eCommerceSynchro->connect() ".$eCommerceSynchro->error, LOG_ERR);
                        setEventMessages($eCommerceSynchro->error, $eCommerceSynchro->errors, 'errors');

                        $db->rollback();
                        return -1;
                    }

                    $product->price = $product->multiprices[$siteDb->price_level];

                    $result = $eCommerceSynchro->eCommerceRemoteAccess->updateRemoteProduct($eCommerceProduct->remote_id, $product);
                    if (!$result) {
                        dol_syslog("updatePriceLevel eCommerceSynchro->eCommerceRemoteAccess->updateRemoteProduct() ".$eCommerceSynchro->eCommerceRemoteAccess->error, LOG_ERR);
                        setEventMessages($eCommerceSynchro->eCommerceRemoteAccess->error, $eCommerceSynchro->eCommerceRemoteAccess->errors, 'errors');

                        $db->rollback();
                        return -2;
                    }
                } else {
                    dol_syslog("updatePriceLevel Product with id " . $product->id . " is not linked to an ecommerce record but has category flag to push on eCommerce. So we push it");
                    // TODO
                    //$result = $eCommerceSynchro->eCommerceRemoteAccess->updateRemoteProduct($eCommerceProduct->remote_id);
                }
            }
        }

        $db->commit();
    }

    return 1;
}

function ecommerceng_wordpress_sanitize_file_name( $filename ) {
    //$filename_raw = $filename;
    $special_chars = array("?", "[", "]", "/", "\\", "=", "<", ">", ":", ";", ",", "'", "\"", "&", "$", "#", "*", "(", ")", "|", "~", "`", "!", "{", "}", "%", "+", chr(0));
    /**
     * Filters the list of characters to remove from a filename.
     *
     * @since 2.8.0
     *
     * @param array  $special_chars Characters to remove.
     * @param string $filename_raw  Filename as it was passed into sanitize_file_name().
     */
    $filename = preg_replace( "#\x{00a0}#siu", ' ', $filename );
    $filename = str_replace( $special_chars, '', $filename );
    $filename = str_replace( array( '%20', '+' ), '-', $filename );
    $filename = preg_replace( '/[\r\n\t -]+/', '-', $filename );
    $filename = trim( $filename, '.-_' );

    /*if ( false === strpos( $filename, '.' ) ) {
        $mime_types = wp_get_mime_types();
        $filetype = wp_check_filetype( 'test.' . $filename, $mime_types );
        if ( $filetype['ext'] === $filename ) {
            $filename = 'unnamed-file.' . $filetype['ext'];
        }
    }*/

    // Split the filename into a base and extension[s]
    //$parts = explode('.', $filename);

    // Return if only one extension
    /*if ( count( $parts ) <= 2 ) {
        /**
         * Filters a sanitized filename string.
         *
         * @since 2.8.0
         *
         * @param string $filename     Sanitized filename.
         * @param string $filename_raw The filename prior to sanitization.
         */
    /*    return apply_filters( 'sanitize_file_name', $filename, $filename_raw );
    }*/

    // Process multiple extensions
    /*$filename = array_shift($parts);
    $extension = array_pop($parts);
    $mimes = get_allowed_mime_types();

    /*
     * Loop over any intermediate extensions. Postfix them with a trailing underscore
     * if they are a 2 - 5 character long alpha string not in the extension whitelist.
     */
    /*foreach ( (array) $parts as $part) {
        $filename .= '.' . $part;

        if ( preg_match("/^[a-zA-Z]{2,5}\d?$/", $part) ) {
            $allowed = false;
            foreach ( $mimes as $ext_preg => $mime_match ) {
                $ext_preg = '!^(' . $ext_preg . ')$!i';
                if ( preg_match( $ext_preg, $part ) ) {
                    $allowed = true;
                    break;
                }
            }
            if ( !$allowed )
                $filename .= '_';
        }
    }
    $filename .= '.' . $extension;
    /** This filter is documented in wp-includes/formatting.php */
    //return apply_filters('sanitize_file_name', $filename, $filename_raw);
    return $filename;
}

function ecommerceng_download_image($image, $product, &$error_message)
{
    dol_syslog(__METHOD__.': image=' . implode(',',$image) . ' product_id=' . $product->id, LOG_DEBUG);
    global $db, $conf, $maxwidthsmall, $maxheightsmall, $maxwidthmini, $maxheightmini;

    if ($product->type != Product::TYPE_PRODUCT && $product->type != Product::TYPE_SERVICE) {
        $error_message = "Error the product is not a product or service type";
        dol_syslog(__METHOD__.': '.$error_message, LOG_ERR);
        return false;
    }

    $entity = isset($product->entity) ? $product->entity : $conf->entity;

    // Set upload directory
    if (!empty($conf->global->PRODUCT_USE_OLD_PATH_FOR_PHOTO)) {    // For backward compatiblity, we scan also old dirs
        if ($product->type == Product::TYPE_PRODUCT) {
            $upload_dir = $conf->product->multidir_output[$entity] . '/' . substr(substr("000" . $product->id, -2), 1, 1) . '/' . substr(substr("000" . $product->id, -2), 0, 1) . '/' . $product->id . "/photos";
        } else {
            $upload_dir = $conf->service->multidir_output[$entity] . '/' . substr(substr("000" . $product->id, -2), 1, 1) . '/' . substr(substr("000" . $product->id, -2), 0, 1) . '/' . $product->id . "/photos";
        }
    } else {
		if (version_compare(DOL_VERSION, "13.0.0") >= 0) {
			if ($product->type == Product::TYPE_PRODUCT) {
				$upload_dir = $conf->product->multidir_output[$entity] . '/' . get_exdir(0, 0, 0, 1, $product, 'product');
			} else {
				$upload_dir = $conf->service->multidir_output[$entity] . '/' . get_exdir(0, 0, 0, 1, $product, 'product');
			}
		} else {
			if ($product->type == Product::TYPE_PRODUCT) {
				$upload_dir = $conf->product->multidir_output[$entity] . '/' . get_exdir(0, 0, 0, 0, $product, 'product') . dol_sanitizeFileName($product->ref);
			} else {
				$upload_dir = $conf->service->multidir_output[$entity] . '/' . get_exdir(0, 0, 0, 0, $product, 'product') . dol_sanitizeFileName($product->ref);
			}
		}
    }

    // Define $destpath (path to file including filename) and $destfile (only filename)
    $file_name = dol_sanitizeFileName($image['filename']); //basename(parse_url($image['url'], PHP_URL_PATH));
    $destpath = $upload_dir . "/" . $file_name;
    $destfile = $file_name;

    // lowercase extension
    $info = pathinfo($destpath);
    $destpath = $info['dirname'] . '/' . $info['filename'] . '.' . strtolower($info['extension']);
    $info = pathinfo($destfile);
    $destfile = $info['filename'] . '.' . strtolower($info['extension']);

    // Security:
    // Disallow file with some extensions. We rename them.
    // Because if we put the documents directory into a directory inside web root (very bad), this allows to execute on demand arbitrary code.
    if (preg_match('/\.htm|\.html|\.php|\.pl|\.cgi|\.exe$/i', $destfile) && empty($conf->global->MAIN_DOCUMENT_IS_OUTSIDE_WEBROOT_SO_NOEXE_NOT_REQUIRED)) {
        $destfile .= '.noexe';
        $destpath .= '.noexe';
    }

	$destpath = dol_sanitizePathName($destpath);

    // Check if image is modified
    if (file_exists($destpath)) {
        $local_image_date = new DateTime();
        $local_image_date->setTimestamp(filectime($destpath));
        $remote_image_date = new DateTime($image['date_modified']);

        if ($local_image_date >= $remote_image_date) {
            return true;
        }
    }

    dol_syslog(__METHOD__.': upload_dir=' . $upload_dir . ' image=' . implode(',',$image) . ' product_id=' . $product->id . ' dest_path=' . $destpath, LOG_DEBUG);

    if (dol_mkdir($upload_dir) < 0) {
        $error_message = "Error create product images directory ($upload_dir)";
        dol_syslog(__METHOD__.': '.$error_message, LOG_ERR);
        return false;
    }

    $error = 0;

    // Get file
    $timeout = !empty($conf->global->ECOMMERCE_DOWNLOAD_TIMEOUT) ? $conf->global->ECOMMERCE_DOWNLOAD_TIMEOUT : 30;
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $image['url']);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
    curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
	$userAgent = 'Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; .NET CLR 1.0.3705; .NET CLR 1.1.4322)';
	if (!empty($conf->global->ECOMMERCE_USER_AGENT)) $userAgent = $conf->global->ECOMMERCE_USER_AGENT;
	curl_setopt($ch, CURLOPT_USERAGENT, $userAgent);
	curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
	curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
	curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);

	if (!empty($conf->global->ECOMMERCE_CURL_VERBOSE)) {
		curl_setopt($ch, CURLOPT_VERBOSE, true);
		$verbose = fopen(DOL_DATA_ROOT . '/curl_verbose.txt', 'w+');
		curl_setopt($ch, CURLOPT_STDERR, $verbose);
	}

	$data = curl_exec($ch);
	if (curl_errno($ch) || $data === false) {
        $error_message = "CURL - " . curl_error($ch);
        dol_syslog(__METHOD__.': '.$error_message, LOG_ERR);
		$error++;
	} else {
		$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
		if ($code != 200) {
			$error_message = "CURL - HTTP code: $code";
			dol_syslog(__METHOD__.': '.$error_message, LOG_ERR);
			$error++;
		}
	}
	curl_close($ch);
	if (!empty($conf->global->ECOMMERCE_CURL_VERBOSE) && isset($verbose)) {
		@fclose($verbose);
	}

	if ($error) {
		return false;
	}

    // Get in temporary file name
    if (version_compare(phpversion(), '5.2.1', '<')) {
        if ($conf->global->ECOMMERCE_DOWNLOAD_TMP_DIRECTORY_PATH) {
            $tmp_path = $conf->global->ECOMMERCE_DOWNLOAD_TMP_DIRECTORY_PATH;
        } else {
            $error_message = "Error ECOMMERCE_DOWNLOAD_TMP_DIRECTORY_PATH not defined";
            dol_syslog(__METHOD__.': '.$error_message, LOG_ERR);
            return false;
        }
    } else {
        $tmp_path = sys_get_temp_dir();
    }

    if (dol_mkdir($tmp_path) < 0) {
        $error_message = "Error create download temporary directory ($tmp_path)";
        dol_syslog(__METHOD__.': '.$error_message, LOG_ERR);
        return false;
    }

    // Save temporary file
    $temp_file = tempnam($tmp_path, $destfile);
    $fh = @fopen($temp_file, "w");
    if ($fh === false) {
        $error_message = "Error open temporary file ($temp_file)";
        dol_syslog(__METHOD__.': '.$error_message, LOG_ERR);
        return false;
    }
    $ret = fwrite($fh, $data);
    if ($ret === false) {
        $error_message = "Error write data in temporary file ($temp_file)";
        dol_syslog(__METHOD__.': '.$error_message, LOG_ERR);
        return false;
    }
    $ret = fclose($fh);
    if ($ret === false) {
        $error_message = "Error close temporary file ($temp_file)";
        dol_syslog(__METHOD__.': '.$error_message, LOG_ERR);
        return false;
    }

    // If we need to make a virus scan
    if (empty($disablevirusscan) && file_exists($temp_file) && !empty($conf->global->MAIN_ANTIVIRUS_COMMAND)) {
        if (!class_exists('AntiVir')) {
            require_once DOL_DOCUMENT_ROOT . '/core/class/antivir.class.php';
        }
        $antivir = new AntiVir($db);
        $result = $antivir->dol_avscan_file($temp_file);
        if ($result < 0)    // If virus or error, we stop here
        {
            $error_message = 'Error file is infected with a virus: ' . join(',', $antivir->errors);
            dol_syslog('Files.lib::dol_move_uploaded_file File "' . $temp_file . '" (target name "' . $temp_file . '") KO with antivirus: result=' . $result . ' errors=' . join(',', $antivir->errors), LOG_ERR);
            return false;
        }
    }

    if (!dol_move($temp_file, $destpath)) {
        unlink($temp_file);
        $error_message = "Error move temporary file ($temp_file) in product image directory ($destpath)";
        dol_syslog(__METHOD__.': '.$error_message, LOG_ERR);
        return false;
    }

    include_once DOL_DOCUMENT_ROOT . '/core/lib/images.lib.php';
    if (image_format_supported($destpath) == 1) {
        // Create thumbs
        // We can't use $object->addThumbs here because there is no $object known

        // Used on logon for example
        $imgThumbSmall = vignette($destpath, $maxwidthsmall, $maxheightsmall, '_small', 50, "thumbs");
        // Create mini thumbs for image (Ratio is near 16/9)
        // Used on menu or for setup page for example
        $imgThumbMini = vignette($destpath, $maxwidthmini, $maxheightmini, '_mini', 50, "thumbs");
    }

    return true;
}

function ecommerceng_remove_obsolete_image($product, $images, &$error_message)
{
	$images = is_array($images) ? $images : array();

    dol_syslog(__METHOD__.': product_id=' . $product->id . ' images=' . implode(',', $images), LOG_DEBUG);
    global $db, $conf;

    if ($product->type != Product::TYPE_PRODUCT && $product->type != Product::TYPE_SERVICE) {
        $error_message = "Error the product is not a product or service type";
        dol_syslog(__METHOD__.': '.$error_message, LOG_ERR);
        return false;
    }

    $entity = isset($product->entity) ? $product->entity : $conf->entity;

    // Set upload directory
    if (!empty($conf->global->PRODUCT_USE_OLD_PATH_FOR_PHOTO)) {    // For backward compatiblity, we scan also old dirs
        if ($product->type == Product::TYPE_PRODUCT) {
            $upload_dir = $conf->product->multidir_output[$entity] . '/' . substr(substr("000" . $product->id, -2), 1, 1) . '/' . substr(substr("000" . $product->id, -2), 0, 1) . '/' . $product->id . "/photos/";
        } else {
            $upload_dir = $conf->service->multidir_output[$entity] . '/' . substr(substr("000" . $product->id, -2), 1, 1) . '/' . substr(substr("000" . $product->id, -2), 0, 1) . '/' . $product->id . "/photos/";
        }
    } else {
		if (version_compare(DOL_VERSION, "13.0.0") >= 0) {
			if ($product->type == Product::TYPE_PRODUCT) {
				$upload_dir = $conf->product->multidir_output[$entity] . '/' . get_exdir(0, 0, 0, 1, $product, 'product') . '/';
			} else {
				$upload_dir = $conf->service->multidir_output[$entity] . '/' . get_exdir(0, 0, 0, 1, $product, 'product') . '/';
			}
		} else {
			if ($product->type == Product::TYPE_PRODUCT) {
				$upload_dir = $conf->product->multidir_output[$entity] . '/' . get_exdir(0, 0, 0, 0, $product, 'product') . dol_sanitizeFileName($product->ref) . '/';
			} else {
				$upload_dir = $conf->service->multidir_output[$entity] . '/' . get_exdir(0, 0, 0, 0, $product, 'product') . dol_sanitizeFileName($product->ref) . '/';
			}
		}
    }

    $images_name = [];
    foreach ($images as $image) {
        // Define $destpath (path to file including filename) and $destfile (only filename)
        $file_name = dol_sanitizeFileName($image['filename']); //basename(parse_url($image['url'], PHP_URL_PATH));
        $destfile = $file_name;

        // lowercase extension
        $info = pathinfo($destfile);
        $destfile = $info['filename'] . '.' . strtolower($info['extension']);

        // Security:
        // Disallow file with some extensions. We rename them.
        // Because if we put the documents directory into a directory inside web root (very bad), this allows to execute on demand arbitrary code.
        if (preg_match('/\.htm|\.html|\.php|\.pl|\.cgi|\.exe$/i', $destfile) && empty($conf->global->MAIN_DOCUMENT_IS_OUTSIDE_WEBROOT_SO_NOEXE_NOT_REQUIRED)) {
            $destfile .= '.noexe';
        }

        $images_name[] = $destfile;
    }

    dol_syslog(__METHOD__.': upload_dir=' . $upload_dir . ' images=' . implode(',',$images_name) . ' product_id=' . $product->id, LOG_DEBUG);

    $photos = $product->liste_photos($upload_dir);
    foreach ($photos as $index => $photo) {
        if (! in_array($photo['photo'], $images_name, true)) {
            unlink($upload_dir . $photo['photo']);
        }
    }

    return true;
}

function ecommerceng_add_extrafields($db, $langs, $extrafields, &$error) {
    $result = 1;

    $efields = new ExtraFields($db);
    foreach ($extrafields as $extrafield) {
        $result = $efields->addExtraField(
            $extrafield['attrname'],
            $langs->trans($extrafield['label']),
            $extrafield['type'],
            $extrafield['pos'],
            $extrafield['size'],
            $extrafield['elementtype'],
            $extrafield['unique'],
            $extrafield['required'],
            $extrafield['default_value'],
            $extrafield['param'],
            $extrafield['alwayseditable'],
            $extrafield['perms'],
            $extrafield['list']
        );
        if ($result <= 0) {
            $error = $efields->error;
            return -1;
        }
    }

    return $result;
}

function ecommerceng_update_woocommerce_attribute($db, $site)
{
	global $conf, $langs;
	$langs->load('woocommerce@ecommerceng');

	$db->begin();

	$eCommerceRemoteAccessWoocommerce = new eCommerceRemoteAccessWoocommerce($db, $site);

	if (!$eCommerceRemoteAccessWoocommerce->connect()) {
		setEventMessages('', $eCommerceRemoteAccessWoocommerce->errors, 'errors');
		$db->rollback();
		return false;
	}

	$attributes = $eCommerceRemoteAccessWoocommerce->getAllWoocommerceAttributes();
	if ($attributes === false) {
		setEventMessages('', $eCommerceRemoteAccessWoocommerce->errors, 'errors');
		$db->rollback();
		return false;
	}

	$eCommerceDict = new eCommerceDict($db, MAIN_DB_PREFIX.'c_ecommerceng_attribute');

	// Get all attributes in dictionary for this entity and site
	$dict_attributes = $eCommerceDict->search(['entity'=>['value'=>$conf->entity],'site_id'=>['value'=>$site->id]]);

	// Disable attribute not found in woocommerce
	foreach ($dict_attributes as $line) {
		if (!isset($attributes[$line['attribute_id']])) {
			// Disable attribute
			$result = $eCommerceDict->update(['active' => ['value' => 0]], ['rowid' => ['value' => $line['rowid']]]);
			if ($result == false) {
				setEventMessage($langs->trans('ECommerceWoocommerceErrorDisableDictAttribute', $line['attribute_slug'], $db->error()), 'errors');
				$db->rollback();
				return false;
			}
		} else {
			$attribute = $attributes[$line['attribute_id']];
			$result = $eCommerceDict->update([
				'attribute_name' => ['value'=>$attribute->name,'type'=>'string'],
				'attribute_slug' => ['value'=>$attribute->slug,'type'=>'string'],
				'attribute_type' => ['value'=>$attribute->type,'type'=>'string'],
				'attribute_order_by' => ['value'=>$attribute->order_by,'type'=>'string'],
				'attribute_has_archives' => ['value'=>$attribute->has_archives?1:0],
			], ['rowid' => ['value' => $line['rowid']]]);
			if ($result == false) {
				setEventMessage($langs->trans('ECommerceWoocommerceErrorUpdateDictAttribute', $line['attribute_slug'], $db->error()), 'errors');
				$db->rollback();
				return false;
			}
			$attributes[$line['attribute_id']]->founded = true;
		}
	}

	// Add new attribute from woocommerce
	foreach ($attributes as $attribute) {
		if (!isset($attribute->founded)) {
			// Add new attribute
			$result = $eCommerceDict->insert(['site_id','attribute_id','attribute_name','attribute_slug','attribute_type','attribute_order_by','attribute_has_archives','entity','active'], ['site_id'=>['value'=>$site->id],
				'attribute_id'=>['value'=>$attribute->id],
				'attribute_name'=>['value'=>$attribute->name,'type'=>'string'],
				'attribute_slug'=>['value'=>$attribute->slug,'type'=>'string'],
				'attribute_type'=>['value'=>$attribute->type,'type'=>'string'],
				'attribute_order_by'=>['value'=>$attribute->order_by,'type'=>'string'],
				'attribute_has_archives'=>['value'=>$attribute->has_archives?1:0],
				'entity'=>['value'=>$conf->entity],'active'=>['value'=>1]]);
			if ($result == false) {
				setEventMessage($langs->trans('ECommerceWoocommerceErrorAddDictAttribute', $attribute->slug, $attribute->name, $db->error()), 'errors');
				$db->rollback();
				return false;
			}
		}
	}

	$db->commit();
	return true;
}

function ecommerceng_update_woocommerce_dict_tax($db, $site)
{
	global $conf, $langs;
	$langs->load('woocommerce@ecommerceng');

	$db->begin();

	$eCommerceRemoteAccessWoocommerce = new eCommerceRemoteAccessWoocommerce($db, $site);

	if (!$eCommerceRemoteAccessWoocommerce->connect()) {
		setEventMessages('', $eCommerceRemoteAccessWoocommerce->errors, 'errors');
		$db->rollback();
		return false;
	}

	$taxClasses = $eCommerceRemoteAccessWoocommerce->getAllWoocommerceTaxClass();
	if ($taxClasses === false) {
		setEventMessages('', $eCommerceRemoteAccessWoocommerce->errors, 'errors');
		$db->rollback();
		return false;
	}

	$eCommerceDict = new eCommerceDict($db, MAIN_DB_PREFIX.'c_ecommerceng_tax_class');

	// Get all tax class in dictionary for this entity and site
	$dict_tax_classes = $eCommerceDict->search(['entity'=>['value'=>$conf->entity],'site_id'=>['value'=>$site->id]]);

	// Desactive code not found in woocommerce
	foreach ($dict_tax_classes as $line) {
		if (!isset($taxClasses[$line['code']])) {
			// Desactive code
			$result = $eCommerceDict->update(['active' => ['value' => 0]], ['rowid' => ['value' => $line['rowid']]]);
			if ($result == false) {
				setEventMessage($langs->trans('ECommerceWoocommerceErrorDisableDictTaxClass', $line['code'], $db->error()), 'errors');
				$db->rollback();
				return false;
			}
		} else {
			$result = $eCommerceDict->update(['label' => ['value'=>$taxClasses[$line['code']]->name,'type'=>'string']], ['rowid' => ['value' => $line['rowid']]]);
			if ($result == false) {
				setEventMessage($langs->trans('ECommerceWoocommerceErrorUpdateDictTaxClass', $line['code'], $db->error()), 'errors');
				$db->rollback();
				return false;
			}
			$taxClasses[$line['code']]->founded = true;
		}
	}

	// Add new code from woocommerce
	foreach ($taxClasses as $taxClass) {
		if (!isset($taxClass->founded)) {
			// Add new tax class code
			$result = $eCommerceDict->insert(['site_id','code','label','entity','active'], ['site_id'=>['value'=>$site->id],'code'=>['value'=>$taxClass->slug,'type'=>'string'],'label'=>['value'=>$taxClass->name,'type'=>'string'],'entity'=>['value'=>$conf->entity],'active'=>['value'=>1]]);
			if ($result == false) {
				setEventMessage($langs->trans('ECommerceWoocommerceErrorAddDictTaxClass', $taxClass->slug, $taxClass->name, $db->error()), 'errors');
				$db->rollback();
				return false;
			}
		}
	}

	$taxRates = $eCommerceRemoteAccessWoocommerce->getAllWoocommerceTaxRate();
	if ($taxRates === false) {
		setEventMessages('', $eCommerceRemoteAccessWoocommerce->errors, 'errors');
		$db->rollback();
		return false;
	}

	$eCommerceDict = new eCommerceDict($db, MAIN_DB_PREFIX.'c_ecommerceng_tax_rate');

	// Get all tax class in dictionary for this entity and site
	$dict_tax_rates = $eCommerceDict->search(['entity'=>['value'=>$conf->entity],'site_id'=>['value'=>$site->id]]);

	// Desactive code not found in woocommerce
	foreach ($dict_tax_rates as $line) {
		if (!isset($taxRates[$line['tax_id']])) {
			// Desactive code
			$result = $eCommerceDict->update(['active' => ['value' => 0]], ['rowid' => ['value' => $line['rowid']]]);
			if ($result == false) {
				setEventMessage($langs->trans('ECommerceWoocommerceErrorDisableDictTaxRate', $line['tax_id'], $db->error()), 'errors');
				$db->rollback();
				return false;
			}
		} else {
			$taxRate = $taxRates[$line['tax_id']];
			$rate = price2num($taxRate->rate);
			if (strpos((string)$rate, '.') === false) $rate = $rate . '.0';
			$result = $eCommerceDict->update(['tax_country'=>['value'=>$taxRate->country,'type'=>'string'],'tax_state'=>['value'=>$taxRate->state,'type'=>'string'],
				'tax_postcode'=>['value'=>$taxRate->postcode,'type'=>'string'],'tax_city'=>['value'=>$taxRate->city,'type'=>'string'],'tax_rate'=>['value'=>$rate,'type'=>'string'],
				'tax_name'=>['value'=>$taxRate->name,'type'=>'string'],'tax_priority'=>['value'=>$taxRate->priority],'tax_compound'=>['value'=>$taxRate->compound?1:0],
				'tax_shipping'=>['value'=>$taxRate->shipping?1:0],'tax_order'=>['value'=>$taxRate->order],'tax_class'=>['value'=>$taxRate->class,'type'=>'string']], ['rowid' => ['value' => $line['rowid']]]);
			if ($result == false) {
				setEventMessage($langs->trans('ECommerceWoocommerceErrorUpdateDictTaxRate', $line['tax_id'], $db->error()), 'errors');
				$db->rollback();
				return false;
			}
			$taxRates[$line['tax_id']]->founded = true;
		}
	}

	// Add new tax rate from woocommerce
	foreach ($taxRates as $taxRate) {
		if (!isset($taxRate->founded)) {
			$rate = price2num($taxRate->rate);
			if (strpos((string)$rate, '.') === false) $rate = $rate . '.0';
			// Add new tax rate
			$result = $eCommerceDict->insert(['site_id','tax_id','tax_country','tax_state','tax_postcode','tax_city','tax_rate','tax_name','tax_priority','tax_compound','tax_shipping','tax_order','tax_class','entity','active'],
				['site_id'=>['value'=>$site->id],'tax_id'=>['value'=>$taxRate->id],'tax_country'=>['value'=>$taxRate->country,'type'=>'string'],'tax_state'=>['value'=>$taxRate->state,'type'=>'string'],
					'tax_postcode'=>['value'=>$taxRate->postcode,'type'=>'string'],'tax_city'=>['value'=>$taxRate->city,'type'=>'string'],'tax_rate'=>['value'=>$rate,'type'=>'string'],
					'tax_name'=>['value'=>$taxRate->name,'type'=>'string'],'tax_priority'=>['value'=>$taxRate->priority],'tax_compound'=>['value'=>$taxRate->compound?1:0],
					'tax_shipping'=>['value'=>$taxRate->shipping?1:0],'tax_order'=>['value'=>$taxRate->order],'tax_class'=>['value'=>$taxRate->class,'type'=>'string']
					,'entity'=>['value'=>$conf->entity],'active'=>['value'=>1]]);
			if ($result == false) {
				setEventMessage($langs->trans('ECommerceWoocommerceErrorAddDictTaxRate', $taxRate->slug, $db->error()), 'errors');
				$db->rollback();
				return false;
			}
		}
	}

	$db->commit();
	return true;
}

function ecommerceng_update_payment_gateways($db, $site)
{
    global $conf, $langs;
    $langs->load('woocommerce@ecommerceng');

    dol_include_once('/ecommerceng/class/business/eCommerceSynchro.class.php');
    $synchro = new eCommerceSynchro($db, $site, 0, 0);

    dol_syslog("site.php Try to connect to eCommerce site ".$site->name);
    $synchro->connect();
    if (count($synchro->errors))
    {
        setEventMessages($synchro->error, $synchro->errors, 'errors');
        return false;
    }

    $paymentGateways = $synchro->getAllPaymentGateways();
    if ($paymentGateways === false) {
        setEventMessages($synchro->error, $synchro->errors, 'errors');
        return false;
    }

    // Get all payment gateways
    dol_include_once('/ecommerceng/class/data/eCommercePaymentGateways.class.php');
    $pay_gateways = new eCommercePaymentGateways($db);
    $currentPaymentGateways = $pay_gateways->get_all($site->id);
    if (!is_array($currentPaymentGateways) && $currentPaymentGateways < 0) {
        setEventMessages('', $pay_gateways->errors, 'errors');
        return false;
    }

    $payment_gateways = array();
    foreach ($paymentGateways as $id => $label) {
        $payment_gateways[$id] = array(
            'payment_gateway_label' => $label,
            'payment_mode_id' => $currentPaymentGateways[$id]['payment_mode_id'] > 0 ? $currentPaymentGateways[$id]['payment_mode_id'] : 0,
            'bank_account_id' => $currentPaymentGateways[$id]['bank_account_id'] > 0 ? $currentPaymentGateways[$id]['bank_account_id'] : 0,
            'supplier_id' => $currentPaymentGateways[$id]['supplier_id'] > 0 ? $currentPaymentGateways[$id]['supplier_id'] : 0,
        );
    }

    $result = $pay_gateways->set($site->id, $payment_gateways);
    if ($result < 0) {
        setEventMessages($pay_gateways->error, $pay_gateways->errors, 'errors');
        return false;
    }

    return true;
}

function get_company_by_email($db, $email, $site=0)
{
	$email = $db->escape($email);

	$sql = "SELECT DISTINCT s.rowid FROM " . MAIN_DB_PREFIX . "societe AS s";
	$sql .= " LEFT JOIN " . MAIN_DB_PREFIX . "socpeople AS sp ON sp.fk_soc = s.rowid";
	if ($site > 0) $sql .= " LEFT JOIN " . MAIN_DB_PREFIX . "ecommerce_societe AS es ON es.fk_societe = s.rowid";
	$sql .= " WHERE (s.email = '$email' OR sp.email = '$email')";
	if ($site > 0) $sql .= " AND es.fk_site = $site";
	$sql .= " AND s.status = 1";
	$sql .= " AND s.entity IN (" . getEntity('societe') . ")";

	$resql = $db->query($sql);
	if ($resql) {
		$num = $db->num_rows($resql);
		if ($num > 1) {
			$result = -2;
		} elseif ($num) {
			$obj = $db->fetch_object($resql);
			$result = $obj->rowid;
		} else {
			$result = 0;
		}

		$db->free($resql);
	} else {
		$result = -1;
	}

	return $result;
}