Gh 6

src/Actions/Schedule/CollectOrders.php

@@ -0,0 +1,55 @@
+<?php
+
+namespace Cdek\Actions\Schedule;
+
+use Cdek\Contracts\TaskContract;
+use Cdek\Model\CoreRequestData;
+use Cdek\Model\Validate;
+
+class CollectOrders extends TaskContract
+{
+    const ORDERS_LIMIT = 10000;
+    private Validate $error;
+
+    public static function getName(): string
+    {
+        return 'collect-orphaned-orders';
+    }
+
+    public function start()
+    {
+        $query = new \WC_Order_Query(
+            [
+                'orderby'  => 'id',
+                'order'    => 'ASC',
+                'paginate' => true,
+                'limit'    => self::ORDERS_LIMIT,
+                'return'   => 'ids',
+            ],
+        );
+
+        for ($page = 1, $maxPages = 1; $page <= $maxPages; $page++) {
+            $query->set('page', $page);
+            $result = $query->get_orders();
+
+            $maxPages = $result->max_num_pages;
+
+            $response = $this->cdekCoreApi->sendTaskData(
+                $this->taskId,
+                new CoreRequestData(
+                    'success',
+                    [
+                        'orders' => array_map(
+                            static fn($order) => (string)$order,
+                            $result->orders,
+                        )
+                    ],
+                    $page,
+                    $maxPages
+                )
+            );
+
+            $this->initData($response);
+        }
+    }
+}

src/Actions/Schedule/ReindexOrders.php

@@ -0,0 +1,56 @@
+<?php
+
+
+namespace {
+
+    defined('ABSPATH') or exit;
+}
+
+namespace Cdek\Actions\Schedule {
+
+    use Cdek\Contracts\TaskContract;
+    use Cdek\Exceptions\CdekScheduledTaskException;
+    use Cdek\Model\CoreRequestData;
+    use Cdek\Model\OrderMetaData;
+    use Cdek\Model\Validate;
+
+    class ReindexOrders extends TaskContract
+    {
+        private Validate $error;
+
+        public function __construct(string $taskId)
+        {
+            parent::__construct($taskId);
+            $this->initTaskData();
+        }
+
+        public static function getName(): string
+        {
+            return 'restore-order-uuids';
+        }
+
+        public function start()
+        {
+            if (empty($this->getTaskMeta())) {
+                throw new CdekScheduledTaskException('[CDEKDelivery] Failed to get orders meta info',
+                                               'cdek_error.core.data',
+                                               $this->getTaskData()
+                );
+            }
+
+            foreach ($this->getTaskMeta() as $arOrder) {
+                OrderMetaData::updateMetaByOrderId(
+                    $arOrder['external_id'],
+                    [
+                        'order_uuid'   => $arOrder['id']
+                    ]
+                );
+            }
+
+            $this->initData($this->cdekCoreApi->sendTaskData(
+                $this->taskId,
+                new CoreRequestData('success')
+            ));
+        }
+    }
+}

src/Cache/FileCache.php

@@ -0,0 +1,54 @@
+<?php
+
+namespace Cdek\Cache;
+
+use Cdek\Exceptions\CdekApiException;
+use Cdek\Loader;
+
+class FileCache
+{
+    const CACHE_FILE_NAME = '.cache.php';
+    private static array $store;
+    public static function getVars()
+    {
+        if(!file_exists(Loader::getPluginPath() . DIRECTORY_SEPARATOR . self::CACHE_FILE_NAME)){
+            return null;
+        }
+
+        return self::$store[self::CACHE_FILE_NAME] ?? self::$store[self::CACHE_FILE_NAME] = require_once(Loader::getPluginPath() . DIRECTORY_SEPARATOR . self::CACHE_FILE_NAME);
+    }
+
+    public static function putVars($vars)
+    {
+        if(empty($vars)){
+            return;
+        }
+
+        if(!is_writable(Loader::getPluginPath())){
+            throw new CdekApiException('[CDEKDelivery] Failed check directory rights',
+                                       'cdek_error.cache.rights',
+                                       ['path' => Loader::getPluginPath()],
+                                       true);
+        }
+
+        if(file_exists(Loader::getPluginPath() . DIRECTORY_SEPARATOR . self::CACHE_FILE_NAME)){
+            if(!is_writable(Loader::getPluginPath() . DIRECTORY_SEPARATOR . self::CACHE_FILE_NAME)){
+                throw new CdekApiException('[CDEKDelivery] Failed check directory rights',
+                                           'cdek_error.cache.rights',
+                                           ['path' => Loader::getPluginPath() . DIRECTORY_SEPARATOR . self::CACHE_FILE_NAME],
+                                           true);
+            }
+        }
+
+
+        $logFile = fopen( Loader::getPluginPath() . DIRECTORY_SEPARATOR . self::CACHE_FILE_NAME, 'w+');
+
+        fwrite($logFile, '<?php return ' . var_export($vars, true) . ';' . PHP_EOL);
+        fclose($logFile);
+    }
+
+    public static function clear()
+    {
+        unlink(Loader::getPluginPath() . DIRECTORY_SEPARATOR . self::CACHE_FILE_NAME);
+    }
+}

src/CdekCoreApi.php

@@ -0,0 +1,197 @@
+<?php
+
+namespace Cdek;
+
+use Cdek\Contracts\TokenStorageContract;
+use Cdek\Exceptions\CdekApiException;
+use Cdek\Exceptions\CdekScheduledTaskException;
+use Cdek\Helpers\DBCoreTokenStorage;
+use Cdek\Helpers\DBTokenStorage;
+use Cdek\Model\CoreRequestData;
+use Cdek\Transport\HttpCoreClient;
+
+class CdekCoreApi
+{
+    const SUCCESS_STATUS = 200;
+    const FINISH_STATUS = 201;
+    const HAS_NEXT_INFO_STATUS = 202;
+    const UNKNOWN_METHOD = 404;
+    const FATAL_ERRORS_FIRST_NUMBER = 5;
+    private const TOKEN_PATH = 'cms/wordpress/shops/%s/token';
+    private const SHOP = 'cms/wordpress/shops';
+    private const TASKS = 'wordpress/tasks';
+    public ?int $status;
+    private TokenStorageContract $generalTokenStorage;
+    private TokenStorageContract $tokenCoreStorage;
+    private HttpCoreClient $coreClient;
+
+    public function __construct(
+        ?TokenStorageContract $tokenStorage = null,
+        ?TokenStorageContract $tokenCoreStorage = null
+    )
+    {
+        $this->coreClient = new HttpCoreClient();
+        $this->generalTokenStorage = $tokenStorage ?? new DBTokenStorage();
+        $this->tokenCoreStorage = $tokenCoreStorage ?? new DBCoreTokenStorage();
+    }
+
+    /**
+     * @return array
+     * @throws CdekApiException
+     * @throws CdekScheduledTaskException
+     * @throws \JsonException
+     */
+    public function fetchShopToken(): array
+    {
+        $response = $this->coreClient->sendCdekRequest(
+            Config::API_CORE_URL . self::SHOP,
+            'POST',
+            $this->generalTokenStorage->getToken(),
+            [
+                'name' => get_bloginfo('name'),
+                'url'  => [
+                    'rest'  => rest_url(),
+                    'home'  => home_url(),
+                    'admin' => admin_url(),
+                ],
+            ],
+        );
+
+        if (empty($response['body'])) {
+            throw new CdekScheduledTaskException('[CDEKDelivery] Failed to get shop uuid',
+                                                 'cdek_error.uuid.auth',
+                                                 $response,
+            );
+        }
+
+        $body = json_decode($response['body'], true);
+
+        if (empty($body) || empty($body['data']['id'])) {
+            throw new CdekScheduledTaskException('[CDEKDelivery] Failed to get shop uuid',
+                                                 'cdek_error.uuid.auth',
+                                                 $response,
+            );
+        }
+
+        $response = $this->coreClient->sendCdekRequest(
+            sprintf(Config::API_CORE_URL . self::TOKEN_PATH, $body['data']['id']),
+            'POST',
+            $this->generalTokenStorage->getToken(),
+        );
+
+        $body = json_decode($response['body'], true);
+
+        if ($body === null || !$body['success'] || empty($body['data'])) {
+            throw new CdekScheduledTaskException('[CDEKDelivery] Failed to get shop token',
+                                                 'cdek_error.shop_token.auth',
+                                                 $body,
+            );
+        }
+
+        return ['tokens' => $body['data']];
+    }
+
+    /**
+     * @param $data
+     *
+     * @return array|false|string|\WP_Error
+     * @throws CdekApiException
+     * @throws CdekScheduledTaskException
+     * @throws \JsonException
+     */
+    public function taskManager($data = null)
+    {
+        $response = $this->coreClient->sendCdekRequest($this->getShopApiUrl() . '/' . self::TASKS,
+                                                       'GET',
+                                                       $this->tokenCoreStorage->getToken(),
+                                                       $data);
+
+        return $this->initData($response);
+    }
+
+    /**
+     * @param                             $taskId
+     * @param CoreRequestData             $data
+     *
+     * @return array|false|string|\WP_Error
+     * @throws \Cdek\Exceptions\CdekApiException
+     * @throws \Cdek\Exceptions\CdekScheduledTaskException
+     * @throws \JsonException
+     */
+    public function taskInfo($taskId, CoreRequestData $data)
+    {
+        $response = $this->coreClient->sendCdekRequest(
+            $this->getShopApiUrl() . '/' . self::TASKS . '/' . $taskId,
+            'GET',
+            $this->tokenCoreStorage->getToken(),
+            [
+                'status' => $data->getStatus(),
+                'result' => $data->getData(),
+            ],
+        );
+
+        return $this->initData($response);
+    }
+
+    /**
+     * @param                 $taskId
+     * @param CoreRequestData $data
+     *
+     * @return array|false|string|\WP_Error
+     * @throws CdekApiException
+     * @throws CdekScheduledTaskException
+     * @throws \JsonException
+     */
+    public function sendTaskData($taskId, CoreRequestData $data)
+    {
+        $response = $this->coreClient->sendCdekRequest(
+            $this->getShopApiUrl() . '/' . self::TASKS . '/' . $taskId,
+            'PUT',
+            $this->tokenCoreStorage->getToken(),
+            [
+                'status' => $data->getStatus(),
+                'result' => $data->getData(),
+            ],
+            [
+                'X-Current-Page' => $data->getCurrentPage(),
+                'X-Total-Pages'  => $data->getTotalPages(),
+            ],
+        );
+
+        return $this->initData($response);
+    }
+
+    public function isServerError(): bool
+    {
+        return empty($this->status) || substr($this->status, 0, 1) == self::FATAL_ERRORS_FIRST_NUMBER;
+    }
+
+    private function getShopApiUrl()
+    {
+        return $this->tokenCoreStorage->getPath();
+    }
+
+    private function initData($response)
+    {
+        $decodeResponse = json_decode($response['body'], true);
+
+        $this->status = $decodeResponse['status'] ?? null;
+
+        if (
+            !in_array(
+                $this->status,
+                [self::FINISH_STATUS, self::HAS_NEXT_INFO_STATUS, self::SUCCESS_STATUS],
+            )
+            &&
+            !$this->isServerError()
+        ) {
+            throw new CdekScheduledTaskException(
+                '[CDEKDelivery] Failed to get core api response',
+                'cdek_error.core.response',
+                $response,
+            );
+        }
+
+        return $decodeResponse;
+    }
+}