importonecpackagesale.php

<?php
 
namespace Bitrix\Sale\Exchange;
 
 
use Bitrix\Main\Error;
use Bitrix\Sale\Cashbox\Cashbox1C;
use Bitrix\Sale\Cashbox\Internals\CashboxCheckTable;
use Bitrix\Sale\Exchange\Entity\OrderImport;
use Bitrix\Sale\Exchange\Entity\PaymentImport;
use Bitrix\Sale\Exchange\OneC\DocumentType;
use Bitrix\Sale\Exchange\OneC\OrderDocument;
use Bitrix\Sale\Exchange\OneC\ShipmentDocument;
use Bitrix\Sale\Result;
 
final class ImportOneCPackageSale extends ImportOneCPackage
{
    protected function convert(array $documents)
    {
        $documentOrder = $this->getDocumentByTypeId(DocumentType::ORDER, $documents);
 
        if($documentOrder instanceof OrderDocument)
        {
            //region Presset - create Shipment if Service in the Order by information from 1C
            $documentShipment = $this->getDocumentByTypeId(DocumentType::SHIPMENT, $documents);
            if($documentShipment == null)
            {
                $fieldsOrder = $documentOrder->getFieldValues();
                $items = $this->getProductsItems($fieldsOrder);
 
                if($this->deliveryServiceExists($items))
                {
                    $shipment['ID_1C'] = $documentOrder->getField('ID_1C');
                    $shipment['VERSION_1C'] = $documentOrder->getField('VERSION_1C');
                    $shipment['ITEMS'] = $items;
                    $shipment['REK_VALUES']['1C_TRACKING_NUMBER'] = $this->getDefaultTrackingNumber($documentOrder);
 
                    $documentShipment = new ShipmentDocument();
                    $documentShipment->setFields($shipment);
                    $documents[] = $documentShipment;
                }
            }
            //endregion
 
            foreach($documents as $document)
            {
                if($document instanceof OneC\PaymentDocument)
                {
                    $paymentFields = $document->getFieldValues();
                    $paymentFields['REK_VALUES']['PAY_SYSTEM_ID_DEFAULT'] = $this->getDefaultPaySystem($documentOrder);
                    $document->setFields($paymentFields);
                }
 
                if($document instanceof OneC\ShipmentDocument)
                {
                    $shimpentFields = $document->getFieldValues();
                    $shimpentFields['REK_VALUES']['DELIVERY_SYSTEM_ID_DEFAULT'] = $this->getDefaultDeliverySystem($documentOrder);
                    $document->setFields($shimpentFields);
                }
            }
        }
        else
        {
            $settingsShipment = ManagerImport::getSettingsByType(static::getShipmentEntityTypeId());
 
            if($settingsShipment->canCreateOrder(static::getShipmentEntityTypeId())=='Y')
            {
                $documentShipment = $this->getDocumentByTypeId(DocumentType::SHIPMENT, $documents);
                if($documentShipment !== null)
                {
                    $order['ID_1C'] = $documentShipment->getField('ID_1C');
                    $order['VERSION_1C'] = $documentShipment->getField('VERSION_1C');
                    $order['AMOUNT'] = $documentShipment->getField('AMOUNT');
                    $order['ITEMS'] = $documentShipment->getField('ITEMS');
                    $order['TAXES'] = $documentShipment->getField('TAXES');
                    $order['AGENT'] = $documentShipment->getField('AGENT');
 
                    $documentOrder = new OrderDocument();
                    $documentOrder->setFields($order);
                    $documents[] = $documentOrder;
                }
            }
        }
 
        return parent::convert($documents);
    }
 
    protected function getDefaultTrackingNumber(OneC\OrderDocument $document)
    {
        $fields = $document->getFieldValues();
        return isset($fields['REK_VALUES']['1C_TRACKING_NUMBER'])?$fields['REK_VALUES']['1C_TRACKING_NUMBER']:null;
    }
 
    protected function getDefaultPaySystem(OneC\OrderDocument $document)
    {
        $fields = $document->getFieldValues();
        return isset($fields['REK_VALUES']['PAY_SYSTEM_ID'])?$fields['REK_VALUES']['PAY_SYSTEM_ID']:null;
    }
 
    protected function getDefaultDeliverySystem(OneC\OrderDocument $document)
    {
        $fields = $document->getFieldValues();
        return isset($fields['REK_VALUES']['DELIVERY_SYSTEM_ID'])?$fields['REK_VALUES']['DELIVERY_SYSTEM_ID']:null;
    }
 
    protected function UpdateCashBoxChecks(OrderImport $orderImport, array $items)
    {
        $result = new Result();
        $bCheckUpdated = false;
 
        $order = $orderImport->getEntity();
 
        foreach ($items as $item)
        {
            if($item->getOwnerTypeId() == static::getPaymentCashEntityTypeId() ||
                $item->getOwnerTypeId() == static::getPaymentCashLessEntityTypeId() ||
                $item->getOwnerTypeId() == static::getPaymentCardEntityTypeId()
            )
            {
                $params = $item->getFieldValues();
                static::load($item, $params['TRAITS'], $order);
 
                if($item->getEntityId()>0)
                {
                    $entity = $item->getEntity();
 
                    if(isset($params['CASH_BOX_CHECKS']))
                    {
                        $fields = $params['CASH_BOX_CHECKS'];
 
                        if($fields['ID']>0)
                        {
                            $res = CashboxCheckTable::getById($fields['ID']);
                            if ($data = $res->fetch())
                            {
                                if($data['STATUS']<>'Y')
                                {
                                    $applyResult = Cashbox1C::applyCheckResult($params['CASH_BOX_CHECKS']);
                                    $bCheckUpdated = $applyResult->isSuccess();
                                }
                            }
                            else
                            {
                                $item->setCollisions(EntityCollisionType::PaymentCashBoxCheckNotFound, $entity);
                            }
                        }
                    }
                }
            }
        }
 
        $collision = $orderImport->getCurrentCollision(EntityType::ORDER);
        $collisionTypes = $collision->getCollision($orderImport);
 
        if(count($collisionTypes)>0 && $bCheckUpdated)
        {
            return $result;
        }
        else
        {
            $result->addError(new Error('', 'CASH_BOX_CHECK_IGNORE'));
        }
 
        return $result;
    }
 
}