Current path: home/webdevt/www/schtroumpf.fr/modules/mbeshipping/src/Helper/
?? Go up: /home/webdevt/www/schtroumpf.fr/modules/mbeshipping/src
<?php
/**
* 2017-2022 PrestaShop
*
* NOTICE OF LICENSE
*
* This source file is subject to the Academic Free License (AFL 3.0)
* that is bundled with this package in the file LICENSE.txt.
* It is also available through the world-wide-web at this URL:
* http://opensource.org/licenses/afl-3.0.php
* If you did not receive a copy of the license and are unable to
* obtain it through the world-wide-web, please send an email
* to license@prestashop.com so we can send you a copy immediately.
*
* DISCLAIMER
*
* Do not edit or add to this file if you wish to upgrade PrestaShop to newer
* versions in the future. If you wish to customize PrestaShop for your
* needs please refer to http://www.prestashop.com for more information.
*
* @author MBE Worldwide
* @copyright 2017-2023 MBE Worldwide
* @license http://opensource.org/licenses/afl-3.0.php Academic Free License (AFL 3.0)
* International Registered Trademark & Property of MBE Worldwide
*/
namespace PrestaShop\Module\Mbeshipping\Helper;
use PrestaShop\Module\Mbeshipping\Ws;
require_once(dirname(__FILE__) . '/../../classes/custom/models/MbeRatesCacheHelper.php');
if (!defined('MBE_UAP_WEIGHT_LIMIT_20_KG')) {
define('MBE_UAP_WEIGHT_LIMIT_20_KG', 20);
}
if (!defined('MBE_UAP_LONGEST_LIMIT_97_CM')) {
define('MBE_UAP_LONGEST_LIMIT_97_CM', 97);
}
if (!defined('MBE_UAP_TOTAL_SIZE_LIMIT_300_CM')) {
define('MBE_UAP_TOTAL_SIZE_LIMIT_300_CM', 300);
}
if (!defined('MBE_UAP_SERVICE')) {
define('MBE_UAP_SERVICE', 'MDP');
}
if (!defined('MBE_UAP_ALLOWED_COUNTRIES_LIST')) {
define('MBE_UAP_ALLOWED_COUNTRIES_LIST', array('IT','FR','GB','ES','DE','PL'));
}
if (!defined('_PS_VERSION_')) {
exit;
}
class RatesHelper
{
protected $rate_table_name = 'mbeshippingrate';
const SHIPMENT_CONFIGURATION_MODE_ONE_SHIPMENT_PER_ITEM = 1;
const SHIPMENT_CONFIGURATION_MODE_ONE_SHIPMENT_PER_SHOPPING_CART_SINGLE_PARCEL = 2;
const SHIPMENT_CONFIGURATION_MODE_ONE_SHIPMENT_PER_SHOPPING_CART_MULTI_PARCEL = 3;
const HANDLING_TYPE_PER_SHIPMENT = "S";
const HANDLING_TYPE_PER_PARCEL = "P";
const HANDLING_TYPE_FIXED = "F";
const ITALIAN_URL = "https://www.mbe.it/it/tracking?c=@";
const SPAIN_URL = "https://www.mbe.es/es/tracking?c=@";
const GERMANY_URL = "https://www.mbe.de/de/tracking?c=@";
const AUSTRIA_URL = "https://www.mbe.at/at/tracking?c=@";
const FRANCE_URL = "https://www.mbefrance.fr/fr/suivi?c=@";
const POLAND_URL = "https://www.mbe.pl/pl/tracking?c=@";
const CROATIA_URL = "https://www.mbe.hr/hr/tracking?c=@";
public function installRatesTable()
{
$sql = "
CREATE TABLE IF NOT EXISTS `" . _DB_PREFIX_ . bqSQL($this->rate_table_name) . "`(
`id_mbeshippingrate` int(10) unsigned NOT NULL AUTO_INCREMENT,
`country` varchar(4) NOT NULL DEFAULT '',
`region` varchar(10) NOT NULL DEFAULT '',
`city` varchar(30) NOT NULL DEFAULT '',
`zip` varchar(10) NOT NULL DEFAULT '',
`zip_to` varchar(10) NOT NULL DEFAULT '',
`weight_from` decimal(12,4) NOT NULL DEFAULT '0.0000',
`weight_to` decimal(12,4) NOT NULL DEFAULT '0.0000',
`price` decimal(12,4) DEFAULT '0.0000',
`delivery_type` varchar(255) DEFAULT '',
PRIMARY KEY (`id_mbeshippingrate`))
";
$result = \Db::getInstance()->execute($sql);
return $result;
}
public function uninstallRatesTable()
{
$sql = "DROP TABLE IF EXISTS `" . _DB_PREFIX_ . bqSQL($this->rate_table_name) . "`";
$result = \Db::getInstance()->execute($sql);
return $result;
}
public function truncate()
{
$truncateSql = " TRUNCATE `" . _DB_PREFIX_ . bqSQL($this->rate_table_name) . "` ";
$truncateResult = \Db::getInstance()->execute($truncateSql);
return $truncateResult;
}
public function insertRate($country, $region, $city, $zip, $zipTo, $weightFrom, $weightTo, $price, $deliveryType)
{
$sql = "
INSERT INTO `" . _DB_PREFIX_ . bqSQL($this->rate_table_name) . "` (
`country`,`region`,`city`,`zip`,`zip_to`,`weight_from`,`weight_to`,`price`,`delivery_type`
)
VALUES (
'" . pSQL($country) . "',
'" . pSQL($region) . "',
'" . pSQL($city) . "',
'" . pSQL($zip) . "',
'" . pSQL($zipTo) . "',
" . (float)$weightFrom . ",
" . (float)$weightTo . ",
" . (float)$price . ",
'" . pSQL($deliveryType) . "'
);
";
$insertResult = \Db::getInstance()->execute($sql);
return $insertResult;
}
public function useCustomRates($country)
{
$result = false;
if (\Configuration::get('shipments_csv_mode') == DataHelper::MBE_CSV_MODE_DISABLED) {
} elseif (\Configuration::get('shipments_csv_mode') == DataHelper::MBE_CSV_MODE_TOTAL) {
$result = true;
} elseif (\Configuration::get('shipments_csv_mode') == DataHelper::MBE_CSV_MODE_PARTIAL) {
$sql = "SELECT * FROM `" . _DB_PREFIX_ . bqSQL($this->rate_table_name) . "` WHERE `country` = '" . pSQL($country) . "'";
$rates = \Db::getInstance()->executeS($sql);
if (is_array($rates) && count($rates) > 0) {
$result = true;
}
}
return $result;
}
public function getCountryRates($country)
{
$sql = "SELECT * FROM `" . _DB_PREFIX_ . bqSQL($this->rate_table_name) . "` WHERE `country` = '" . pSQL($country) . "'";
$result = \Db::getInstance()->executeS($sql);
return $result;
}
public function applyInsuranceToRate($rate, $insuranceValue)
{
$result = $rate;
$percentageValue = \Configuration::get("mbe_shipments_csv_insurance_per") / 100 * $insuranceValue;
$fixedValue = \Configuration::get("mbe_shipments_csv_insurance_min");
if ($percentageValue < $fixedValue) {
$result += $fixedValue;
} else {
$result += $percentageValue;
}
return $result;
}
public function getCustomRates($country, $region, $city, $postCode, $weight, $insuranceValue)
{
$result = array();
$newdata = array();
$zipSql = " '" . pSQL($postCode) . "' BETWEEN zip AND zip_to";
$country = str_replace("'","''", $country);
$region = str_replace("'","''", $region);
$city = str_replace("'","''", $city);
$helper = new DataHelper();
$services = $helper->getAllowedShipmentServicesArray();
foreach ($services as $service) {
for ($j = 0; $j <= 7; $j++) {
$sql = "SELECT * FROM `" . _DB_PREFIX_ . bqSQL($this->rate_table_name) . "` ";
switch ($j) {
case 0:
$sql .= "WHERE ";
$sql .= "`country` = '" . pSQL($country) . "'";
$sql .= " AND ";
$sql .= "`region` = '" . pSQL($region) . "'";
$sql .= " AND ";
$sql .= " STRCMP(LOWER(city),LOWER('" . pSQL($city) . "')) = 0";
$sql .= " AND ";
$sql .= $zipSql;
break;
case 1:
$sql .= "WHERE ";
$sql .= "`country` = '" . pSQL($country) . "'";
$sql .= " AND ";
$sql .= "`region` = '" . pSQL($region) . "'";
$sql .= " AND ";
$sql .= "`city` = ''";
$sql .= " AND ";
$sql .= $zipSql;
break;
case 2:
$sql .= "WHERE ";
$sql .= "`country` = '" . pSQL($country) . "'";
$sql .= " AND ";
$sql .= "`region` = '" . pSQL($region) . "'";
$sql .= " AND ";
$sql .= "STRCMP(LOWER(city),LOWER('" . pSQL($city) . "')) = 0";
$sql .= " AND ";
$sql .= " zip = '' ";
break;
case 3:
$sql .= "WHERE ";
$sql .= "`country` = '" . pSQL($country) . "'";
$sql .= " AND ";
//$sql .= "`region` = '" . $region . "'";
$sql .= "`region` = ''";
$sql .= " AND ";
$sql .= "STRCMP(LOWER(city),LOWER('" . pSQL($city) . "')) = 0";
$sql .= " AND ";
$sql .= $zipSql;
break;
case 4:
$sql .= "WHERE ";
$sql .= "`country` = '" . pSQL($country) . "'";
$sql .= " AND ";
//$sql .= "`region` = '" . $region . "'";
$sql .= "`region` = ''";
$sql .= " AND ";
$sql .= "STRCMP(LOWER(city),LOWER('" . pSQL($city) . "')) = 0";
$sql .= " AND ";
$sql .= "zip = ''";
break;
case 5:
$sql .= "WHERE ";
$sql .= "`country` = '" . pSQL($country) . "'";
$sql .= " AND ";
//$sql .= "`region` = '" . $region . "'";
$sql .= "`region` = ''";
$sql .= " AND ";
$sql .= "city = ''";
$sql .= " AND ";
$sql .= $zipSql;
break;
case 6:
$sql .= "WHERE ";
$sql .= "`country` = '" . pSQL($country) . "'";
$sql .= " AND ";
$sql .= "`region` = '" . pSQL($region) . "'";
$sql .= " AND ";
$sql .= "city = ''";
$sql .= " AND ";
$sql .= "zip = ''";
break;
case 7:
$sql .= "WHERE ";
$sql .= "`country` = '" . pSQL($country) . "'";
$sql .= " AND ";
$sql .= "`region` = ''";
$sql .= " AND ";
$sql .= "city = ''";
$sql .= " AND ";
$sql .= "zip = ''";
break;
}
$sql .= " AND weight_from <= " . (float)$weight . " AND weight_to >=" . (float)$weight;
$sql .= " AND delivery_type = '" . pSQL($service) . "'";
$sql .= " ORDER BY country DESC, region DESC, zip DESC";
$rows = \Db::getInstance()->executeS($sql);
//$row = $read->fetchAll($select);
if (!empty($rows)) {
// have found a result or found nothing and at end of list!
foreach ($rows as $data) {
$newdata[$data["delivery_type"]] = $data;
}
break;
}
}
}
$ws = new Ws();
foreach ($newdata as $data) {
$rate = new \stdClass;
$rate->Service = $data["delivery_type"];
$rate->ServiceDesc = $ws->getLabelFromShipmentType($data["delivery_type"]);
$rate->SubzoneDesc = '';
$rate->IdSubzone = '';
$rate->NetShipmentTotalPrice = $data["price"];
$result[] = $rate;
//rate with insurance
$rateWithInsurance = new \stdClass;
$rateWithInsurance->Service = $helper->convertShippingCodeWithInsurance($data["delivery_type"]);
$label = $ws->getLabelFromShipmentType($data["delivery_type"]);
$rateWithInsurance->ServiceDesc = $helper->convertShippingLabelWithInsurance($label);
$rateWithInsurance->SubzoneDesc = '';
$rateWithInsurance->IdSubzone = '';
$rateWithInsurance->NetShipmentTotalPrice = $this->applyInsuranceToRate($data["price"], $insuranceValue);
$result[] = $rateWithInsurance;
}
return $result;
}
public function getRates($destCountry, $destRegion, $city, $destPostCode, $baseSubtotalInclTax, $weight, $boxes, $insuranceValue, $oldResults = array(), $iteration = 1)
{
$logger = new LoggerHelper();
$helper = new DataHelper();
if ($helper->isEnabledCustomMapping()) {
// If custom mapping is used no MBE methods will be available
return [];
} else {
$ws = new Ws();
$result = array();
$newResults = array();
$allowedShipmentServicesArray = $helper->getAllowedShipmentServicesArray();
if ($this->useCustomRates($destCountry)) {
$totalWeight = $weight;
$totalWeight = 0;
if ( is_array( $weight ) ) {
foreach ( $weight as $boxType ) {
$totalWeight += array_sum($boxType['weight']);
}
}
$shipments = $this->getCustomRates($destCountry, $destRegion, $city, $destPostCode, $totalWeight, $insuranceValue);
} else {
if (is_array($weight)) {
$weightString = json_encode($weight);
} else {
$weightString = $weight;
}
$values = json_encode([$destCountry, $destRegion, $destPostCode, $weightString, $boxes, $insuranceValue]);
$id_cache = md5($values);
$id_cart = \Context::getContext()->cart->id;
if ($cached_response = \MbeRatesCacheHelper::get($id_cache, $id_cart)) {
$logger->logDebug('Rates cache found for ' . $id_cache . ' and cart ' . $id_cart);
$logger->logDebug('Rates cache: ' . print_r($cached_response, true));
$shipments = $cached_response;
} else {
$logger->logDebug('No rates cache found for ' . $id_cache . ' and cart ' . $id_cart);
}
if (!isset($shipments) || $shipments === false) {
$shipments = $ws->estimateShipping($destCountry, $destRegion, $destPostCode, $weight, $boxes, $insuranceValue, $allowedShipmentServicesArray);
$logger->logDebug('Storing rates cache for ' . $id_cache . ' and cart ' . $id_cart);
$logger->logDebug('Rates cache: ' . print_r($shipments, true));
\MbeRatesCacheHelper::store($id_cache, $id_cart, $shipments);
}
}
if ($shipments) {
$allowedShipmentServicesArray = $helper->getAllowedShipmentServicesArray();
$shipments = $this->selectShipments($shipments);
foreach ($shipments as $shipment) {
$shipmentMethod = $shipment->Service;
$shipmentMethodKey = $shipment->Service;
if (in_array($shipmentMethod, $allowedShipmentServicesArray)) {
$shipmentTitle = $shipment->ServiceDesc;
$shipmentTitle .= " - " . $shipment->SubzoneDesc;
$shipmentPrice = $shipment->NetShipmentTotalPrice;
$shipmentPrice = $this->applyFee($shipmentPrice, $boxes);
$shippingThreshold = $helper->getThresholdByShippingServrice($shipmentMethod . (\Configuration::get('mbecountry') === $destCountry ? '' : '_ww'));
if ($shippingThreshold != null && $baseSubtotalInclTax >= $shippingThreshold) {
$shipmentPrice = 0;
}
$customLabel = $helper->getShippingMethodCustomLabel($shipment->Service);
$current = new \stdClass();
$current->title = $customLabel ? $customLabel : $shipment->ServiceDesc;
$current->mbetitle = $shipment->ServiceDesc;
$current->title_full = $shipmentTitle;
$current->method = $shipmentMethod;
$current->price = $shipmentPrice;
$current->subzone = $shipment->SubzoneDesc;
$current->subzone_id = $shipment->IdSubzone;
$current->shipment_code = $shipmentMethodKey;
$newResults[$shipmentMethodKey] = $current;
}
}
if ($iteration == 1) {
$result = $newResults;
} else {
foreach ($newResults as $newResultKey => $newResult) {
if (array_key_exists($newResultKey, $oldResults)) {
$newResult->price += $oldResults[$newResultKey]->price;
$result[$newResultKey] = $newResult;
}
}
}
}
return $result;
}
}
/**
* @param $cart CartCore
* @param $weight
* @return array
*/
public function collectRates($cart)
{
//INSERT HERE CHECK FOR CSV
$helper = new DataHelper();
$logger = new LoggerHelper();
$id_address = $cart->id_address_delivery;
$address = new \Address($id_address);
$country = new \Country((int)($address->id_country));
$city = $address->city;
$region = new \State($address->id_state);
$destRegion = $region->iso_code;
$shipmentConfigurationMode = $helper->getShipmentConfigurationMode();
$shipments = array();
$baseSubtotalInclTax = $cart->getOrderTotal(true, \Cart::BOTH_WITHOUT_SHIPPING);
$boxesDimensionWeight = [];
$boxesSingleParcelDimensionWeight = [];
if ($shipmentConfigurationMode == self::SHIPMENT_CONFIGURATION_MODE_ONE_SHIPMENT_PER_ITEM) {
$iteration = 1;
foreach ($cart->getProducts() as $item) {
$weight = $item['weight'];
$weight = $helper->convertWeight($weight);
$boxesDimensionWeight = [];
$boxesSingleParcelDimensionWeight = [];
// Retrieve the product info using the new box structure
$helper->getBoxesArray(
$boxesDimensionWeight,
$boxesSingleParcelDimensionWeight,
$weight,
$helper->getPackageInfo($item['reference'])
);
if (\Configuration::get('mbe_shipments_ins_mode') == DataHelper::MBE_INSURANCE_WITH_TAXES) {
$insuranceValue = $item["price_wt"];
}
else {
$insuranceValue = $item["price"];
}
for ($i = 1; $i <= $item['cart_quantity']; $i++) {
$logger->logDebug("Product Iteration: " . $iteration);
$shipments = $this->getRates($country->iso_code, $destRegion, $city, $address->postcode, $baseSubtotalInclTax, $boxesDimensionWeight, 1, $insuranceValue, $shipments, $iteration);
$iteration++;
}
}
} elseif ($shipmentConfigurationMode == self::SHIPMENT_CONFIGURATION_MODE_ONE_SHIPMENT_PER_SHOPPING_CART_SINGLE_PARCEL) {
$insuranceValue = 0;
foreach ($cart->getProducts() as $item) {
$itemQty = $item['cart_quantity'];
for ($i = 1; $i <= $itemQty; $i++) {
$packageInfo = $helper->getPackageInfo($item['reference']);
$boxesDimensionWeight = $helper->getBoxesArray(
$boxesDimensionWeight,
$boxesSingleParcelDimensionWeight,
$helper->convertWeight($item['weight']),
$packageInfo
);
}
$insuranceValue += $this->getSubtotalForInsurance($item);
}
$boxesDimensionWeight = $helper->mergeBoxesArray(
$boxesDimensionWeight,
$boxesSingleParcelDimensionWeight
);
$numBoxes = $helper->countBoxesArray($boxesDimensionWeight);
$logger->logDebug("Num Boxes: " . $numBoxes);
$shipments = $this->getRates($country->iso_code, $destRegion, $city, $address->postcode, $baseSubtotalInclTax, $boxesDimensionWeight, $numBoxes, $insuranceValue, array(), 1);
} elseif ($shipmentConfigurationMode == self::SHIPMENT_CONFIGURATION_MODE_ONE_SHIPMENT_PER_SHOPPING_CART_MULTI_PARCEL) {
$numBoxes = 0;
$insuranceValue = 0;
foreach ($cart->getProducts() as $item) {
$insuranceValue += $this->getSubtotalForInsurance($item);
$numBoxes += $item['cart_quantity'];
for ($i = 1; $i <= $item['cart_quantity']; $i++) {
$helper->getBoxesArray(
$boxesDimensionWeight,
$boxesSingleParcelDimensionWeight,
$helper->convertWeight($item['weight']),
$helper->getPackageInfo($item['reference'], true)
);
}
}
$logger->logDebug("Num Boxes: " . $numBoxes);
$shipments = $this->getRates($country->iso_code, $destRegion, $city, $address->postcode, $baseSubtotalInclTax, $boxesSingleParcelDimensionWeight, $numBoxes, $insuranceValue, array(), 1);
}
$result = array();
if (!empty($shipments)) {
foreach ($shipments as $key => $shipment) {
if ($shipment instanceof \stdClass) {
$c = $this->createOrFindCarrier($shipment->title, $shipment->mbetitle, $shipment->shipment_code);
\Configuration::updateValue('carrier_' . $c->id, $shipment->shipment_code);
$showUapService = false;
if ( \Tools::strtolower($shipment->method) === 'mdp' ) {
$showUapService = $this->isUapEnabled( $helper->mergeBoxesArray(
$boxesDimensionWeight,
$boxesSingleParcelDimensionWeight
), $cart->getProducts() );
}
if ( \Tools::strtolower($shipment->method) !== 'mdp' || $showUapService ) {
$result[$key] = array('carrier' => $c, 'price' => $shipment->price);
}
}
else {
foreach ($shipment as $k => $obj) {
if ($obj instanceof \stdClass) {
if (!isset($result[$k])) {
$showUapService = false;
if ( \Tools::strtolower($shipment->method) === 'mdp' ) {
$showUapService = $this->isUapEnabled( $helper->mergeBoxesArray(
$boxesDimensionWeight,
$boxesSingleParcelDimensionWeight
), $cart->getProducts() );
}
if ( \Tools::strtolower($shipment->method) !== 'mdp' || $showUapService ) {
$c = $this->createOrFindCarrier($obj->title, $obj->mbetitle, $obj->shipment_code);
\Configuration::updateValue('carrier_' . $c->id, $obj->shipment_code);
$price = $obj->price;
$shippingThreshold = $helper->getThresholdByShippingServrice($obj->shipment_code . (\Configuration::get('mbecountry') === $country ? '' : '_ww'));
if ($shippingThreshold != null && $baseSubtotalInclTax >= $shippingThreshold) {
$price = 0;
}
$result[$k] = array('carrier' => $c, 'price' => $price);
}
}
}
}
}
}
}
return $result;
}
public function selectShipments($shipments)
{
$result = array();
foreach ($shipments as $s) {
$values = array();
foreach ($result as $r) {
$values[] = $r->Service;
}
if (!in_array($s->Service, $values)) {
$result[] = $s;
}
else {
$r = null;
$k = null;
foreach ($result as $t => $struct) {
if ($s->Service == $struct->Service) {
$r = $struct;
$k = $t;
break;
}
}
if ($s->NetShipmentTotalPrice > $r->NetShipmentTotalPrice) {
$result[$k] = $s;
}
}
}
return $result;
}
public function applyFee($value, $packages = 1)
{
$handlingType = \Configuration::get("handling_type");
$handlingAction = \Configuration::get("handling_action");
$handlingFee = \Configuration::get("handling_fee");
if ($handlingAction == self::HANDLING_TYPE_PER_SHIPMENT) {
$packages = 1;
}
if (self::HANDLING_TYPE_FIXED == $handlingType) {
$result = $value + $handlingFee * $packages;
} else {
$result = $value * (100 + $handlingFee) / 100;
}
return $result;
}
public function createOrFindCarrier($key, $mbekey, $key2)
{
$logger = new LoggerHelper();
$carrier = new \Carrier();
if (!isset($mbekey) || $mbekey=='' || $key==$mbekey ) {
// add service code to service title and check if there is insurance present
$key2_firstchars = \Tools::substr($key2, 0, 3);
if (\strpos($key, $key2_firstchars) == false) {
if (\strpos($key2, 'INSURANCE') == true) {
$keys = explode("+", $key);
$keys2 = explode("_", $key2);
$key = $keys[0] . '(' . $keys2[0] . ') +' . $keys[1];
} else {
$key .= ' (' . $key2 . ')';
}
}
}
$carrier->name = $key;
$carrier->active = true;
$carrier->deleted = 0;
$carrier->shipping_handling = false;
$carrier->range_behavior = 0;
$carrier->url = $this->getTrackingUrlBySystem(\Configuration::get('mbecountry'));
if(isset($mbekey) && $mbekey!='' && $key!=$mbekey ) {
$key = $mbekey;
$key2_firstchars = \Tools::substr($key2, 0, 3);
if (\strpos($key, $key2_firstchars) == false) {
if (\strpos($key2, 'INSURANCE') == true) {
$keys = explode("+", $key);
$keys2 = explode("_", $key2);
$key = $keys[0] . '(' . $keys2[0] . ') +' . $keys[1];
} else {
$key .= ' (' . $key2 . ')';
}
}
}
foreach (\Language::getLanguages() as $lang) {
$carrier->delay[$lang['id_lang']] = \Tools::substr(\Configuration::get('mbeshippingdelay_' . \Tools::substr(md5($key . '_' . $lang['iso_code']), 0, 15)), 0, 128);
if(isset($carrier->delay[$lang['id_lang']]))
$carrier->delay[$lang['id_lang']] = " ";
}
$id_tax_rules_group = (int)\Configuration::get('mbe_tax_rule_' . \Tools::strtolower($key2));
$carrier->setTaxRulesGroup($id_tax_rules_group);
$carrier->shipping_external = true;
$carrier->is_module = true;
$carrier->external_module_name = 'mbeshipping';
$carrier->need_range = true;
$id_carrier = \Db::getInstance()->getValue('SELECT `id_carrier` FROM `' . _DB_PREFIX_ . 'carrier` where name = "' . pSQL($carrier->name) . '" AND deleted="0"');
$logger->logDebug("createOrFindCarrier $id_carrier: " . $id_carrier);
try {
if (!$id_carrier) {
if ($carrier->add()) {
$logger->logDebug("carrier added" . $carrier->id);
$groups = \Group::getGroups(true);
$logger->logDebug("groups");
foreach ($groups as $group) {
\Db::getInstance()->insert('carrier_group', array(
'id_carrier' => (int)$carrier->id,
'id_group' => (int)$group['id_group'],
));
$logger->logDebug("added group " . $group['id_group']);
}
\Db::getInstance()->insert('carrier_tax_rules_group_shop', array(
'id_carrier' => (int)$carrier->id,
'id_tax_rules_group' => (int)$id_tax_rules_group,
'id_shop' => (int)\Context::getContext()->shop->id,
));
$rangePrice = new \RangePrice();
$rangePrice->id_carrier = $carrier->id;
$rangePrice->delimiter1 = '0';
$rangePrice->delimiter2 = '1000000';
$rangePrice->add();
$rangeWeight = new \RangeWeight();
$rangeWeight->id_carrier = $carrier->id;
$rangeWeight->delimiter1 = '0';
$rangeWeight->delimiter2 = '1000000';
$rangeWeight->add();
$zones = \Zone::getZones(true);
foreach ($zones as $z) {
\Db::getInstance()->insert(
'carrier_zone',
array('id_carrier' => (int)$carrier->id, 'id_zone' => (int)$z['id_zone']));
\Db::getInstance()->insert(
'delivery',
array('id_carrier' => (int)$carrier->id, 'id_range_price' => (int)$rangePrice->id, 'id_range_weight' => null, 'id_zone' => (int)$z['id_zone'], 'price' => '0'),
true,
0,
\Db::INSERT_IGNORE);
\Db::getInstance()->insert(
'delivery',
array('id_carrier' => (int)$carrier->id, 'id_range_price' => null, 'id_range_weight' => (int)$rangeWeight->id, 'id_zone' => (int)$z['id_zone'], 'price' => '0'),
true,
0,
\Db::INSERT_IGNORE);
}
if (_PS_VERSION_ >= 1.7) {
$logoPath = realpath(_PS_MODULE_DIR_ . 'mbeshipping' . DIRECTORY_SEPARATOR . 'views' . DIRECTORY_SEPARATOR . 'img' . DIRECTORY_SEPARATOR . 'logo1-7.jpg');
}
else {
$logoPath = realpath(_PS_MODULE_DIR_ . 'mbeshipping' . DIRECTORY_SEPARATOR . 'views' . DIRECTORY_SEPARATOR . 'img' . DIRECTORY_SEPARATOR . 'logo.jpg');
}
$logoPathDestination = _PS_ROOT_DIR_ . DIRECTORY_SEPARATOR . 'img' . DIRECTORY_SEPARATOR . 's' . DIRECTORY_SEPARATOR . $carrier->id . '.jpg';
copy($logoPath, $logoPathDestination);
return $carrier;
}
}
else {
foreach (\Language::getLanguages() as $lang) {
$v = \Tools::substr(\Configuration::get('mbeshippingdelay_' . \Tools::substr(md5($key . '_' . $lang['iso_code']), 0, 15)), 0, 128);
\Db::getInstance()->update('carrier_lang', array('delay' => pSQL($v)), 'id_carrier = ' . (int)$id_carrier . ' and id_lang = ' . (int)$lang['id_lang'], \Db::INSERT_IGNORE);
}
return new \Carrier($id_carrier);
}
}
catch (Exception $e) {
$logger->logDebug("createOrFindCarrier Exception : " . $e->getMessage());
$logger->logDebug(print_r($e->getTrace(), true));
}
}
public function getTrackingUrlBySystem($system)
{
$result = "";
if ($system == "IT") {
$result = self::ITALIAN_URL;
} elseif ($system == "ES") {
$result = self::SPAIN_URL;
} elseif ($system == "DE") {
$result = self::GERMANY_URL;
} elseif ($system == "AT") {
$result = self::AUSTRIA_URL;
} elseif ($system == "FR") {
$result = self::FRANCE_URL;
} elseif ($system == "PL") {
$result = self::POLAND_URL;
} elseif ($system == "HR") {
$result = self::CROATIA_URL;
}
return $result;
}
public function enabledCountry($id_address)
{
$a = new \Address($id_address);
$c = new \Country($a->id_country);
//TODO: CHECK sallowspecific
if (\Configuration::get('sallowspecific') == 1) {
return in_array($c->iso_code, explode('-', \Configuration::get('specificcountry')));
} else {
return true;
}
}
public function getTotalNumOfBoxes($weight)
{
$helper = new DataHelper();
$numBoxes = 1;
$maxPackageWeight = $helper->getMaxPackageWeight();
if ($weight > $maxPackageWeight && $maxPackageWeight != 0) {
$numBoxes = ceil($weight / $maxPackageWeight);
$weight = $weight / $numBoxes;
}
return $numBoxes;
}
protected function getSubtotalForInsurance($item) {
$insuranceValue = 0;
if (\Configuration::get('mbe_shipments_ins_mode') == DataHelper::MBE_INSURANCE_WITH_TAXES) {
$insuranceValue += $item["price_wt"] * $item['cart_quantity'];
} else {
$insuranceValue += $item["price"] * $item['cart_quantity'];
}
return $insuranceValue;
}
/**
* @param $boxes
* If shipping mode is SHIPMENT_CONFIGURATION_MODE_ONE_SHIPMENT_PER_ITEM $boxes is the last one used for getRates, it's always a "settings" box as CSV it's not used for this mode,
* so it must be used for dimensions check only since it contains only 1 item
* In the other cases it's the proper list of boxes for the shipment
* @param $items
*
* @return bool
*/
private function isUapEnabled( $boxes, $items )
{
$helper = new DataHelper();
$oneParcel = (
( $helper->getShipmentConfigurationMode() == self::SHIPMENT_CONFIGURATION_MODE_ONE_SHIPMENT_PER_ITEM ) ||
( $helper->countBoxesArray( $boxes ) === 1 &&
in_array( $helper->getShipmentConfigurationMode(), [
self::SHIPMENT_CONFIGURATION_MODE_ONE_SHIPMENT_PER_SHOPPING_CART_SINGLE_PARCEL,
self::SHIPMENT_CONFIGURATION_MODE_ONE_SHIPMENT_PER_SHOPPING_CART_MULTI_PARCEL
] )
)
);
// Check longest size of the last box used for getRates. This must be modified if CSV will be enabled for SHIPMENT_CONFIGURATION_MODE_ONE_SHIPMENT_PER_ITEM shipping mode
// Nested if to avoid useless check
if ( $oneParcel ) {
$longestSize = $helper->longestSizeBoxesArray( $boxes );
$box = $boxes[ $helper->arrayKeyFirst( $boxes ) ]; // since it's one parcel we can check only the first element of the array
if ( $longestSize <= MBE_UAP_LONGEST_LIMIT_97_CM ) {
// Longest Size Ok
if ( ( $longestSize + ( 2 * $box['dimensions']['width'] ) + ( 2 * $box['dimensions']['height'] ) ) <= MBE_UAP_TOTAL_SIZE_LIMIT_300_CM ) {
// Total Size Ok
$weightOk = true;
if ( $helper->getShipmentConfigurationMode() == self::SHIPMENT_CONFIGURATION_MODE_ONE_SHIPMENT_PER_ITEM ) {
foreach ( $items as $item ) {
if ( $helper->convertWeight( $item['weight'] ) > MBE_UAP_WEIGHT_LIMIT_20_KG ) {
$weightOk = false;
break;
}
}
} else {
$weightOk = $helper->convertWeight( $helper->totalWeightBoxesArray( $boxes ) ) <= MBE_UAP_WEIGHT_LIMIT_20_KG;
}
if ( $weightOk ) {
// All the checks are OK
return true;
}
}
}
}
return false;
}
}