Gh 6

src/Actions/Schedule/CollectOrders.php

@@ -0,0 +1,65 @@
+<?php
+
+namespace Cdek\Actions\Schedule;
+
+use Cdek\Cache\FileCache;
+use Cdek\CdekCoreApi;
+use Cdek\Contracts\TaskContract;
+use Cdek\Model\Validate;
+
+class CollectOrders extends TaskContract
+{
+    const ORDERS_LIMIT = 10000;
+    private Validate $error;
+
+    public function __construct($taskId)
+    {
+        parent::__construct($taskId);
+    }
+
+    public static function getName(): string
+    {
+        return 'collect-orphaned-orders';
+    }
+
+    public function start()
+    {
+        $this->reportOrders();
+    }
+
+    protected function reportOrders()
+    {
+        $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;
+
+            $this->sendTaskData(
+                [
+                    'status' => 'success',
+                    'result' => [
+                        'orders' => array_map(
+                            static fn($order) => (string)$order,
+                            $result->orders,
+                        ),
+                    ],
+                ],
+                [
+                    'X-Total-Pages'  => $maxPages,
+                    'X-Current-Page' => $page,
+                ],
+            );
+        }
+    }
+}

src/Actions/Schedule/ReindexOrders.php

@@ -0,0 +1,76 @@
+<?php
+
+
+namespace {
+
+    defined('ABSPATH') or exit;
+}
+
+namespace Cdek\Actions\Schedule {
+
+    use Cdek\Contracts\TaskContract;
+    use Cdek\Model\OrderMetaData;
+    use Cdek\Model\Validate;
+
+    class ReindexOrders extends TaskContract
+    {
+        private array $orders = [];
+        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())) {
+                return;
+            }
+
+            $this->initOrders();
+
+            foreach ($this->orders as $orderId) {
+                $orderIndex = array_search($orderId, array_column($this->getTaskMeta(), 'external_id'));
+
+                $responseOrder = $this->getTaskMeta()[$orderIndex];
+
+                OrderMetaData::updateMetaByOrderId(
+                    $orderId,
+                    [
+                        'order_number' => $responseOrder['external_id'],
+                        'order_uuid'   => $responseOrder['id'],
+                    ],
+                );
+            }
+
+            $this->sendTaskData(
+                [
+                    'status' => 'success',
+                ],
+            );
+        }
+
+        protected function initOrders()
+        {
+            $query = new \WC_Order_Query(
+                [
+                    'orderby'  => 'id',
+                    'order'    => 'ASC',
+                    'return'   => 'ids',
+                    'post__in' => array_column($this->getTaskMeta(), 'external_id'),
+                ],
+            );
+
+            foreach ($query->get_orders() as $orderId) {
+                $this->orders[] = $orderId;
+            }
+        }
+    }
+}

src/Cache/FileCache.php

@@ -0,0 +1,63 @@
+<?php
+
+namespace Cdek\Cache;
+
+use Cdek\Exceptions\CdekApiException;
+use Cdek\Loader;
+
+class FileCache
+{
+    const CACHE_FILE_NAME = '.cache.php';
+    private static array $store;
+    private string $file;
+
+    public function __construct($fileName = self::CACHE_FILE_NAME)
+    {
+        $this->file = $fileName;
+    }
+
+    public function getVars()
+    {
+        if(!file_exists(Loader::getPluginPath() . DIRECTORY_SEPARATOR . $this->file)){
+            return null;
+        }
+
+        return self::$store[$this->file] ?? self::$store[$this->file] = require_once(Loader::getPluginPath() . DIRECTORY_SEPARATOR . $this->file);
+    }
+
+    public 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);
+        }
+
+        $arPath = explode(DIRECTORY_SEPARATOR, $this->file);
+        unset($arPath[count($arPath) - 1]);
+
+        if(!is_writable(Loader::getPluginPath() . implode(DIRECTORY_SEPARATOR, $arPath))){
+            throw new CdekApiException('[CDEKDelivery] Failed check directory rights',
+                                       'cdek_error.cache.rights',
+                                       ['path' => Loader::getPluginPath() . implode(DIRECTORY_SEPARATOR, $arPath)],
+                                       true);
+        }
+
+        $logFile = fopen( Loader::getPluginPath() . DIRECTORY_SEPARATOR . $this->file, 'w+');
+
+        $content = '<?php return ' . var_export($vars, true) . ';' . PHP_EOL;
+
+        fwrite($logFile, $content);
+        fclose($logFile);
+    }
+
+    public function clear()
+    {
+        unlink(Loader::getPluginPath() . DIRECTORY_SEPARATOR . $this->file);
+    }
+}

src/CdekCoreApi.php

@@ -0,0 +1,142 @@
+<?php
+
+namespace Cdek;
+
+use Cdek\Contracts\TokenStorageContract;
+use Cdek\Exceptions\CdekApiException;
+use Cdek\Exceptions\CdekCoreApiException;
+use Cdek\Helpers\DBCoreTokenStorage;
+use Cdek\Helpers\DBTokenStorage;
+use Cdek\Transport\HttpCoreClient;
+
+class CdekCoreApi
+{
+    private const TOKEN_PATH = 'cms/wordpress/shops/%s/token';
+    private const SHOP = 'cms/wordpress/shops';
+    private const TASKS = 'wordpress/tasks';
+    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 CdekCoreApiException
+     * @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 CdekCoreApiException('[CDEKDelivery] Failed to get shop uuid',
+                                           'cdek_error.uuid.auth',
+                                           $response,
+                                           true);
+        }
+
+        $body = json_decode($response['body'], true);
+
+        if(empty($body) || empty($body['data']['id'])){
+            throw new CdekCoreApiException('[CDEKDelivery] Failed to get shop uuid',
+                                           'cdek_error.uuid.auth',
+                                           $response,
+                                           true);
+        }
+
+        $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 CdekCoreApiException('[CDEKDelivery] Failed to get shop token',
+                                           'cdek_error.shop_token.auth',
+                                           $body,
+                                           true);
+        }
+
+        return ['tokens' => $body['data']];
+    }
+
+    /**
+     * @param $data
+     *
+     * @return array|false|string|\WP_Error
+     * @throws CdekApiException
+     * @throws CdekCoreApiException
+     * @throws \JsonException
+     */
+    public function taskManager($data = null)
+    {
+        return $this->coreClient->sendCdekRequest($this->getShopApiUrl() . '/' .  self::TASKS, 'GET',
+                                                  $this->tokenCoreStorage->getToken(), $data);
+    }
+
+    /**
+     * @param       $taskId
+     * @param null  $data
+     * @param array $headers
+     *
+     * @return array|false|string|\WP_Error
+     * @throws CdekApiException
+     * @throws CdekCoreApiException
+     * @throws \JsonException
+     */
+    public function taskInfo($taskId, $data = null, array $headers = [])
+    {
+        return $this->coreClient->sendCdekRequest($this->getShopApiUrl() . '/' .  self::TASKS . '/' . $taskId, 'GET',
+                                                  $this->tokenCoreStorage->getToken(), $data, $headers);
+    }
+
+    /**
+     * @param       $taskId
+     * @param       $data
+     * @param array $headers
+     *
+     * @return array|false|string|\WP_Error
+     * @throws CdekApiException
+     * @throws CdekCoreApiException
+     * @throws \JsonException
+     */
+    public function sendTaskData($taskId, $data, array $headers = [])
+    {
+        return $this->coreClient->sendCdekRequest(
+            $this->getShopApiUrl() . '/' .  self::TASKS . '/' . $taskId,
+            'PUT',
+            $this->tokenCoreStorage->getToken(),
+            $data,
+            $headers
+        );
+    }
+
+    private function getShopApiUrl()
+    {
+        return $this->tokenCoreStorage->getPath();
+    }
+}