From e33f393586132e8e9681ae339e09d6c0d825ef87 Mon Sep 17 00:00:00 2001
From: Holger Brunn <mail@hunki-enterprises.com>
Date: Thu, 6 May 2021 08:35:24 +0200
Subject: [PATCH] [ADD] connector-magento: migrate v9 import_record jobs

---
 .../migrations/10.0.1.0.0/post-migration.py   | 78 +++++++++++++++++++
 1 file changed, 78 insertions(+)
 create mode 100644 connector_magento/migrations/10.0.1.0.0/post-migration.py

diff --git a/connector_magento/migrations/10.0.1.0.0/post-migration.py b/connector_magento/migrations/10.0.1.0.0/post-migration.py
new file mode 100644
index 000000000..430592f4b
--- /dev/null
+++ b/connector_magento/migrations/10.0.1.0.0/post-migration.py
@@ -0,0 +1,78 @@
+# -*- coding: utf-8 -*-
+# (c) 2021 Hunki Enterprises BV
+# License AGPL-3.0 or later (http://www.gnu.org/licenses/agpl).
+
+
+def migrate(cr, version=None):
+    """Migrate jobs to new format"""
+    if not version:
+        return
+    # import_record
+    cr.execute(
+        """update queue_job
+        set
+        args=json_build_array(
+            json_build_object(
+                '_type', 'odoo_recordset',
+                'model', 'magento.backend',
+                'ids', array[args::json->1],
+                'uid', user_id
+            ),
+            args::json->2
+        )
+        where
+        method_name=%s and model_name in %s""",
+        ('import_record', tuple([
+            'magento.account.invoice',
+            'magento.sale.order',
+            'magento.sale.order.line',
+            'magento.stock.picking',
+        ])),
+    )
+    # sale_order_import_batch
+    cr.execute(
+        """update queue_job
+        set
+        method_name='import_batch',
+        args=json_build_array(
+            json_build_object(
+                '_type', 'odoo_recordset',
+                'model', 'magento.backend',
+                'ids', array[args::json->1],
+                'uid', user_id
+            )
+        )
+        where
+        method_name=%s and model_name in %s""",
+        ('sale_order_import_batch', tuple([
+            'magento.sale.order',
+        ])),
+    )
+    # export_picking_done
+    cr.execute(
+        """update queue_job
+        set
+        record_ids=json_build_array(
+            args::json->1
+        ),
+        args=json_build_array()
+        where
+        method_name=%s and model_name in %s""",
+        ('export_picking_done', tuple([
+            'magento.stock.picking',
+        ])),
+    )
+    # export_tracking_number
+    cr.execute(
+        """update queue_job
+        set
+        record_ids=json_build_array(
+            args::json->1
+        ),
+        args=json_build_array()
+        where
+        method_name=%s and model_name in %s""",
+        ('export_tracking_number', tuple([
+            'magento.stock.picking',
+        ])),
+    )