<?php
namespace Wbs24\Ozonapinew;

use Bitrix\Main\SystemException;

class OrdersStack {
    protected $Db;

    protected $accountIndex;

    public function __construct($accountIndex = 1, $objects = [])
    {
        $this->Db = $objects['Db'] ?? new Db();

        $this->accountIndex = $accountIndex;
    }

    public function addOrdersToStack($ordersFromTradingPlatform)
    {
        $data = [];
        foreach ($ordersFromTradingPlatform as $key => $resultOrder) {
            $externalId = $resultOrder['posting_number'];
            $order = $resultOrder;
            $serializedOrder = serialize(
                $this->clearDataFromInvalidCharacters($order)
            );
            $data['external_id'] = $externalId;
            $data['order'] = $serializedOrder;
            $data['account_index'] = $this->accountIndex;
            $this->Db->set('wbs24_ozonapinew_orders_stack', $data);
        }
    }

    protected function clearDataFromInvalidCharacters($order)
    {
        // Удаление Эмодзи из строки
        array_walk_recursive($order, function (&$value, $key) {
            if (gettype($value) == 'string') {
                $value = preg_replace('~[\x{10000}-\x{10FFFF}]~u', '', $value);
            }
        });

        return $order;
    }

    public function getOrders()
    {
        $serializedorders = $this->Db->get('wbs24_ozonapinew_orders_stack', [
            'account_index' => $this->accountIndex,
        ]);
        foreach ($serializedorders as $key => $resultOrder) {
            $unserializedOrder = $this->safeUnserialize($resultOrder['order']);
            $unserializedOrder['account_index'] = $this->accountIndex;
            $orders[] = $unserializedOrder;
        }

        return $orders;
    }

    public function safeUnserialize($s)
    {
        $u = unserialize($s);
        if (!$u) {
            $s = preg_replace_callback(
                '/s:(\d+):"(.*?)"([;}])/',
                function($m) {
                    return 's:'.strlen($m[2]).':"'.$m[2].'"'.$m[3];
                },
                $s
            );
            $u = unserialize($s);
        }

        if (!$u) {
            $s = preg_replace_callback(
                '/s:(\d+):"(.*?)"([;}])/',
                function($m) {
                    $f = iconv('windows-1251', 'UTF-8', $m[2]);
                    return 's:'.strlen($f).':"'.$m[2].'"'.$m[3];
                },
                $s
            );
            $u = unserialize($s);
        }

        return $u;
    }

    public function cleanStack($externalIds)
    {
        foreach ($externalIds as $externalId) {
            $this->Db->clear('wbs24_ozonapinew_orders_stack', $where = [
                'external_id' => $externalId,
                'account_index' => $this->accountIndex,
            ]);
        }
    }
}