From 0873df325cb09b04f996ec5336ae445c37213855 Mon Sep 17 00:00:00 2001
From: ellynoize <a.kolesnikov@retailcrm.ru>
Date: Thu, 19 Dec 2024 14:25:10 +0300
Subject: [PATCH] add upload function

---
 src/include/class-wc-retailcrm-base.php     |  5 +++
 src/include/class-wc-retailcrm-uploader.php | 45 ++++++++++++++++++++-
 2 files changed, 49 insertions(+), 1 deletion(-)

diff --git a/src/include/class-wc-retailcrm-base.php b/src/include/class-wc-retailcrm-base.php
index 758763f..4bfe9a6 100644
--- a/src/include/class-wc-retailcrm-base.php
+++ b/src/include/class-wc-retailcrm-base.php
@@ -111,6 +111,7 @@ if (!class_exists('WC_Retailcrm_Base')) {
             add_action('admin_enqueue_scripts', [$this, 'include_files_for_admin'], 101);
             add_action('woocommerce_new_order', [$this, 'fill_array_create_orders'], 11, 1);
             add_action('shutdown', [$this, 'create_order'], -2);
+            add_action('wp_console_upload', [$this, 'console_upload'], 99, 2);
 
             if (
                 !$this->get_option('deactivate_update_order')
@@ -174,6 +175,10 @@ if (!class_exists('WC_Retailcrm_Base')) {
             $this->activateModule();
         }
 
+        public function console_upload($entity, $page = 0)
+        {
+            $this->uploader->uploadConsole($entity, $page);
+        }
         /**
          * Init settings fields
          */
diff --git a/src/include/class-wc-retailcrm-uploader.php b/src/include/class-wc-retailcrm-uploader.php
index f3119e1..1c06850 100644
--- a/src/include/class-wc-retailcrm-uploader.php
+++ b/src/include/class-wc-retailcrm-uploader.php
@@ -234,5 +234,48 @@ if (class_exists('WC_Retailcrm_Uploader') === false) {
                 );
             }
         }
+
+        public function uploadConsole($entity, $page = 0)
+        {
+            $ordersCount = $this->getCountOrders();
+            $customerCount = $this->getCountUsers();
+
+            $ordersPages = (int)($ordersCount / 50) + (($ordersCount % 50 === 0) ? -1 : 0);
+            $customerPages = (int)($customerCount / 50) + (($customerCount % 50 === 0) ? -1 : 0);
+
+            echo $customerPages;
+
+            try {
+                switch ($entity) {
+                    case 'orders':
+                        $this->ArchiveUpload('orders', $page, $ordersPages);
+                        break;
+                    case 'customers':
+                        $this->ArchiveUpload('customers', $page, $customerPages);;
+                        break;
+                    case 'full_upload':
+                        $this->ArchiveUpload('orders', 0, $ordersPages);
+                        $this->ArchiveUpload('customers', 0, $customerPages);
+                        break;
+                    default:
+                        echo 'Unknown entity: ' . $entity;
+                }
+            } catch (Exception $exception) {
+                echo $exception->getMessage();
+            }
+        }
+
+        public function archiveUpload($entity, $page, $countPages)
+        {
+            for ($i = $page; $i <= $countPages; $i++) {
+                if ($entity === 'orders') {
+                    $this->uploadArchiveOrders($i);
+                    echo $page . ' page uploaded' . PHP_EOL;
+                } elseif ($entity === 'customers') {
+                    $this->uploadArchiveCustomers($i);
+                    echo $page . ' page uploaded' . PHP_EOL;
+                }
+            }
+        }
     }
-}//end if
+}