Gh 6

src/Actions/Schedule/CollectOrders.php

@@ -0,0 +1,54 @@
+<?php
+
+namespace Cdek\Actions\Schedule;
+
+use Cdek\Contracts\TaskContract;
+use Cdek\Model\TaskOutputData;
+use Cdek\Model\Validate;
+
+class CollectOrders extends TaskContract
+{
+    const ORDERS_LIMIT = 10000;
+
+    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 TaskOutputData(
+                    'success',
+                    [
+                        'orders' => array_map(
+                            static fn($order) => (string)$order,
+                            $result->orders
+                        )
+                    ],
+                    $page,
+                    $maxPages
+                )
+            );
+
+            $this->initData($response);
+        }
+    }
+}

src/Actions/Schedule/ReindexOrders.php

@@ -0,0 +1,63 @@
+<?php
+
+
+namespace {
+
+    defined('ABSPATH') or exit;
+}
+
+namespace Cdek\Actions\Schedule {
+
+    use Cdek\Contracts\TaskContract;
+    use Cdek\Exceptions\CdekApiException;
+    use Cdek\Exceptions\CdekScheduledTaskException;
+    use Cdek\Model\TaskOutputData;
+    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';
+        }
+
+        /**
+         * @return void
+         * @throws CdekApiException
+         * @throws CdekScheduledTaskException
+         * @throws \JsonException
+         */
+        public function start()
+        {
+            if (empty($this->getTaskMeta())) {
+                throw new CdekScheduledTaskException(
+                    '[CDEKDelivery] Failed to get orders meta info',
+                    'cdek_error.core.data',
+                );
+            }
+
+            foreach ($this->getTaskMeta() as $arOrder) {
+                OrderMetaData::updateMetaByOrderId(
+                    $arOrder['external_id'],
+                    [
+                        'order_uuid' => $arOrder['id'],
+                    ],
+                );
+            }
+
+            $this->initData($this->cdekCoreApi->sendTaskData(
+                $this->taskId,
+                new TaskOutputData('success'),
+            ));
+        }
+    }
+}

src/Cache/FileCache.php

@@ -0,0 +1,64 @@
+<?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(): ?array
+    {
+        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);
+    }
+
+    /**
+     * @param $vars
+     *
+     * @return void
+     * @throws CdekApiException
+     */
+    public static function putVars($vars): void
+    {
+        if(empty($vars)){
+            return;
+        }
+
+        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);
+            }
+        }else{
+            if(!is_writable(Loader::getPluginPath())){
+                throw new CdekApiException('[CDEKDelivery] Failed check directory rights',
+                                           'cdek_error.cache.rights',
+                                           ['path' => Loader::getPluginPath()],
+                                           true);
+            }
+        }
+
+
+        $logFile = fopen( Loader::getPluginPath() . DIRECTORY_SEPARATOR . self::CACHE_FILE_NAME, 'w+');
+
+        fwrite($logFile, '<?php return ' . var_export($vars, true) . ';' . PHP_EOL);
+        fclose($logFile);
+    }
+
+    /**
+     * @return void
+     */
+    public static function clear(): void
+    {
+        unlink(Loader::getPluginPath() . DIRECTORY_SEPARATOR . self::CACHE_FILE_NAME);
+    }
+}