basket.php

<?php
namespace Bitrix\Sale;
 
use Bitrix\Main\Localization\Loc;
use Bitrix\Sale\Internals;
use Bitrix\Main;
 
Loc::loadMessages(__FILE__);
 
class Basket extends BasketBase
{
    const BASKET_DELETE_LIMIT = 2000;
 
    public static function getRegistryType()
    {
        return Registry::REGISTRY_TYPE_ORDER;
    }
 
    public static function getList(array $parameters = array())
    {
        return Internals\BasketTable::getList($parameters);
    }
 
    public static function deleteNoDemand($idOrder)
    {
        $result = new Result();
 
        $itemsDataList = static::getList(
            array(
                "filter" => array("=ORDER_ID" => $idOrder),
                "select" => array("ID", "TYPE")
            )
        );
 
        $itemClassName = static::getItemCollectionClassName();
        while ($item = $itemsDataList->fetch())
        {
            if ($item['TYPE'] === $itemClassName::TYPE_SET)
            {
                $r = Internals\BasketTable::deleteBundle($item['ID']);
            }
            else
            {
                $r = Internals\BasketTable::deleteWithItems($item['ID']);
            }
 
            if (!$r->isSuccess())
            {
                $result->addErrors($r->getErrors());
            }
        }
 
        return $result;
    }
 
    public static function deleteOld($days)
    {
        $expired = new Main\Type\DateTime();
        $expired->add('-'.$days.' days');
        $expiredValue = $expired->format('Y-m-d H:i:s');
 
        $connection = Main\Application::getConnection();
        $sqlHelper = $connection->getSqlHelper();
 
        $sqlExpiredDate = $sqlHelper->getDateToCharFunction("'" . $expiredValue . "'");
 
        $query = "DELETE FROM b_sale_basket WHERE
            FUSER_ID IN (
                SELECT b_sale_fuser.id FROM b_sale_fuser WHERE
                        b_sale_fuser.DATE_UPDATE < ".$sqlExpiredDate."
                        AND b_sale_fuser.USER_ID IS NULL
                ) AND ORDER_ID IS NULL LIMIT ". static::BASKET_DELETE_LIMIT;
 
        $connection->queryExecute($query);
        $affectRows = $connection->getAffectedRowsCount();
 
        $query = "DELETE FROM b_sale_basket 
            WHERE
                FUSER_ID NOT IN (SELECT b_sale_fuser.id FROM b_sale_fuser)
                AND 
                ORDER_ID IS NULL
            LIMIT ". static::BASKET_DELETE_LIMIT;
 
        $connection->queryExecute($query);
        $affectRows = max($affectRows, $connection->getAffectedRowsCount());
 
        $query = "
            DELETE
            FROM b_sale_basket_props 
            WHERE b_sale_basket_props.BASKET_ID NOT IN (
                SELECT b_sale_basket.ID FROM b_sale_basket
            )
            LIMIT ".static::BASKET_DELETE_LIMIT;
 
        $connection->queryExecute($query);
 
        return max($affectRows, $connection->getAffectedRowsCount());
    }
 
    public static function deleteOldAgent($days, $speed = 0)
    {
        if (!isset($GLOBALS["USER"]) || !is_object($GLOBALS["USER"]))
        {
            $tmpUser = True;
            $GLOBALS["USER"] = new \CUser();
        }
 
        $affectRows = static::deleteOld($days);
        Fuser::deleteOld($days);
 
        $days = intval(Main\Config\Option::get("sale", "delete_after", "30"));
        $result = "\Bitrix\Sale\Basket::deleteOldAgent(".$days.");";
 
        if ($affectRows === static::BASKET_DELETE_LIMIT)
        {
            global $pPERIOD;
            $pPERIOD = 300;
        }
 
        if (isset($tmpUser))
        {
            unset($GLOBALS["USER"]);
        }
 
        return $result;
    }
 
    // must be moved to notify
    public function getListOfFormatText()
    {
        $list = array();
 
        $basketItemClassName = static::getItemCollectionClassName();
 
        foreach ($this->collection as $basketItem)
        {
            $basketItemData = $basketItem->getField("NAME");
 
            if ($basketPropertyCollection = $basketItem->getPropertyCollection())
            {
                $basketItemDataProperty = "";
                foreach ($basketPropertyCollection as $basketPropertyItem)
                {
                    if ($basketPropertyItem->getField('CODE') == "PRODUCT.XML_ID"
                        || $basketPropertyItem->getField('CODE') == "CATALOG.XML_ID"
                        || $basketPropertyItem->getField('CODE') == "SUM_OF_CHARGE"
                    )
                    {
                        continue;
                    }
 
                    if (strval(trim($basketPropertyItem->getField('VALUE'))) == "")
                        continue;
 
 
                    $basketItemDataProperty .= (!empty($basketItemDataProperty) ? "; " : "").trim($basketPropertyItem->getField('NAME')).": ".trim($basketPropertyItem->getField('VALUE'));
                }
 
                if (!empty($basketItemDataProperty))
                    $basketItemData .= " [".$basketItemDataProperty."]";
            }
 
            $measure = (strval($basketItem->getField("MEASURE_NAME")) != '') ? $basketItem->getField("MEASURE_NAME") : Loc::getMessage("SOA_SHT");
            $list[$basketItem->getBasketCode()] = $basketItemData." - ".$basketItemClassName::formatQuantity($basketItem->getQuantity())." ".$measure." x ".SaleFormatCurrency($basketItem->getPrice(), $basketItem->getCurrency());
 
        }
 
        return !empty($list) ? $list : false;
    }
 
    public function save()
    {
        $result = parent::save();
 
        $orderId = $this->getOrderId();
        if ($orderId > 0)
        {
            $registry = Registry::getInstance(static::getRegistryType());
 
            $orderHistory = $registry->getOrderHistoryClassName();
            $orderHistory::collectEntityFields('BASKET', $orderId);
        }
 
        return $result;
    }
 
    protected function deleteInternal(array $itemValues)
    {
        $result = new Result();
 
        $itemClassName = static::getItemCollectionClassName();
        if ($itemValues['TYPE'] == $itemClassName::TYPE_SET)
        {
            $r = Internals\BasketTable::deleteBundle($itemValues['ID']);
        }
        else
        {
            $r = Internals\BasketTable::deleteWithItems($itemValues['ID']);
        }
 
        if (!$r->isSuccess())
        {
            $result->addErrors($r->getErrors());
        }
 
        $orderId = $this->getOrderId();
        if ($orderId > 0)
        {
            $registry = Registry::getInstance(static::getRegistryType());
 
            $orderHistory = $registry->getOrderHistoryClassName();
            $orderHistory::addLog(
                'BASKET',
                $orderId,
                'BASKET_ITEM_DELETED',
                $itemValues['ID'],
                null,
                array(
                    "PRODUCT_ID" => $itemValues["PRODUCT_ID"],
                    "NAME" => $itemValues["NAME"],
                    "QUANTITY" => $itemValues["QUANTITY"],
                ),
                $orderHistory::SALE_ORDER_HISTORY_LOG_LEVEL_1
            );
        }
 
        return $result;
    }
 
    protected function callEventOnSaleBasketItemDeleted($itemValues)
    {
        parent::callEventOnSaleBasketItemDeleted($itemValues);
 
        $orderId = $this->getOrderId();
        if ($orderId > 0)
        {
            $registry = Registry::getInstance(static::getRegistryType());
 
            $orderHistory = $registry->getOrderHistoryClassName();
            $orderHistory::addAction(
                'BASKET',
                $orderId,
                'BASKET_REMOVED',
                $itemValues['ID'],
                null,
                array(
                    'NAME' => $itemValues['NAME'],
                    'QUANTITY' => $itemValues['QUANTITY'],
                    'PRODUCT_ID' => $itemValues['PRODUCT_ID'],
                )
            );
 
            $entityMarker = $registry->getEntityMarkerClassName();
            $entityMarker::deleteByFilter(array(
                '=ORDER_ID' => $orderId,
                '=ENTITY_TYPE' => $entityMarker::ENTITY_TYPE_BASKET_ITEM,
                '=ENTITY_ID' => $itemValues['ID'],
            ));
        }
    }
 
    public function deleteItem($index)
    {
        if ($order = $this->getOrder())
        {
            $item = $this->getItemByIndex($index);
 
            $order->onBeforeBasketItemDelete($item);
        }
 
        return parent::deleteItem($index);
    }
 
}