Gh 6

src/Actions/Schedule/CollectOrders.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace Cdek\Actions\Schedule;
+
+use Cdek\Cache\FileCache;
+use Cdek\CdekCoreApi;
+use Cdek\Contracts\TaskContract;
+use Cdek\Model\CoreApiHeadersData;
+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,
+                [
+                    'status' => 'success',
+                    'result' => [
+                        'orders' => array_map(
+                            static fn($order) => (string)$order,
+                            $result->orders,
+                        ),
+                    ],
+                ],
+                (new CoreApiHeadersData())
+                    ->setCurrentPage($page)
+                    ->setTotalPages($maxPages)
+            );
+
+            $this->initData($response);
+        }
+    }
+}

src/Actions/Schedule/ReindexOrders.php

@@ -0,0 +1,57 @@
+<?php
+
+
+namespace {
+
+    defined('ABSPATH') or exit;
+}
+
+namespace Cdek\Actions\Schedule {
+
+    use Cdek\Contracts\TaskContract;
+    use Cdek\Exceptions\CdekCoreApiException;
+    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 CdekCoreApiException('[CDEKDelivery] Failed to get orders meta info',
+                                               'cdek_error.core.data',
+                                               $this->getTaskData(),
+                                               true);
+            }
+
+            foreach ($this->getTaskMeta() as $arOrder) {
+                OrderMetaData::updateMetaByOrderId(
+                    $arOrder['external_id'],
+                    [
+                        'order_uuid'   => $arOrder['id']
+                    ]
+                );
+            }
+
+            $this->initData($this->cdekCoreApi->sendTaskData(
+                $this->taskId,
+                [
+                    'status' => 'success'
+                ]
+            ));
+        }
+    }
+}

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,178 @@
+<?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\Model\CoreApiHeadersData;
+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 = [500, 502, 503, 504];
+    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 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)
+    {
+        $response = $this->coreClient->sendCdekRequest($this->getShopApiUrl() . '/' .  self::TASKS, 'GET',
+                                                  $this->tokenCoreStorage->getToken(), $data);
+
+        return $this->initData($response);
+    }
+
+    /**
+     * @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, ?CoreApiHeadersData $headers = null)
+    {
+        $response = $this->coreClient->sendCdekRequest($this->getShopApiUrl() . '/' .  self::TASKS . '/' . $taskId, 'GET',
+                                                  $this->tokenCoreStorage->getToken(), $data, $headers);
+
+        return $this->initData($response);
+    }
+
+    /**
+     * @param       $taskId
+     * @param       $data
+     * @param ?CoreApiHeadersData $headers
+     *
+     * @return array|false|string|\WP_Error
+     * @throws CdekApiException
+     * @throws CdekCoreApiException
+     * @throws \JsonException
+     */
+    public function sendTaskData($taskId, $data, ?CoreApiHeadersData $headers = null)
+    {
+        $response = $this->coreClient->sendCdekRequest(
+            $this->getShopApiUrl() . '/' .  self::TASKS . '/' . $taskId,
+            'PUT',
+            $this->tokenCoreStorage->getToken(),
+            $data,
+            $headers ? $headers->getHeaders() : []
+        );
+
+        return $this->initData($response);
+    }
+
+    private function getShopApiUrl()
+    {
+        return $this->tokenCoreStorage->getPath();
+    }
+
+    private function initData($response)
+    {
+        $decodeResponse = json_decode($response['body'], true);
+
+        $this->status = $decodeResponse['status'];
+
+        if(
+            !in_array(
+                $this->status,
+                [self::FINISH_STATUS, self::HAS_NEXT_INFO_STATUS, self::SUCCESS_STATUS],
+            )
+            &&
+            !in_array($this->status, self::FATAL_ERRORS)
+        ){
+            throw new CdekCoreApiException('[CDEKDelivery] Failed to get core api response',
+                                           'cdek_error.core.response',
+                                           $response,
+                                           true);
+        }
+
+        return $decodeResponse;
+    }
+}