Add missing patch for orders

2025-10-10 11:33:17 +00:00 · 2013-10-15 14:54:04 +02:00
parent 2dcbd2f985
commit 972ab94944
1 changed files with 124 additions and 0 deletions
--- a/lib/classes/patch/3901.php
+++ b/lib/classes/patch/3901.php
@@ -0,0 +1,124 @@
+<?php
+
+/*
+ * This file is part of Phraseanet
+ *
+ * (c) 2005-2012 Alchemy
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+use Alchemy\Phrasea\Application;
+use Entities\Order;
+use Entities\OrderElement;
+use Gedmo\Timestampable\TimestampableListener;
+
+class patch_3901 implements patchInterface
+{
+    /** @var string */
+    private $release = '3.9.0.a1';
+
+    /** @var array */
+    private $concern = array(base::APPLICATION_BOX);
+
+    /**
+     * {@inheritdoc}
+     */
+    public function get_release()
+    {
+        return $this->release;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function require_all_upgrades()
+    {
+        return false;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function concern()
+    {
+        return $this->concern;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function apply(base $appbox, Application $app)
+    {
+        $sql = 'DELETE FROM Orders';
+        $stmt = $app['phraseanet.appbox']->get_connection()->prepare($sql);
+        $stmt->execute();
+        $stmt->closeCursor();
+
+        $sql = 'DELETE FROM OrderElements';
+        $stmt = $app['phraseanet.appbox']->get_connection()->prepare($sql);
+        $stmt->execute();
+        $stmt->closeCursor();
+
+        $conn = $app['phraseanet.appbox']->get_connection();
+        $sql = 'SELECT id, usr_id, created_on, `usage`, deadline, ssel_id FROM `order`';
+        $stmt = $conn->prepare($sql);
+        $stmt->execute();
+        $rs = $stmt->fetchAll(\PDO::FETCH_ASSOC);
+        $stmt->closeCursor();
+
+        $n = 0;
+        $em = $app['EM'];
+        $em->getEventManager()->removeEventSubscriber(new TimestampableListener());
+
+        foreach ($rs as $row) {
+
+            $sql = 'SELECT count(id) as todo FROM order_elements WHERE deny = NULL AND order_id = :id';
+            $stmt = $conn->prepare($sql);
+            $stmt->execute(array(':id' => $row['id']));
+            $todo = $stmt->fetch(\PDO::FETCH_ASSOC);
+            $stmt->closeCursor();
+
+            $order = new Order();
+            $order->setUsrId($row['usr_id'])
+                ->setTodo($todo['todo'])
+                ->setOrderUsage($row['usage'])
+                ->setDeadline(new \DateTime($row['deadline']))
+                ->setCreatedOn(new \DateTime($row['created_on']))
+                ->setBasket($row['ssel_id']);
+
+            $em->persist($order);
+
+            $sql = 'SELECT base_id, record_id, order_master_id, deny
+                    FROM order_elements
+                    WHERE order_id = :id';
+            $stmt = $conn->prepare($sql);
+            $stmt->execute(array(':id' => $row['id']));
+            $elements = $stmt->fetchAll(\PDO::FETCH_ASSOC);
+            $stmt->closeCursor();
+
+            foreach ($elements as $element) {
+                $orderElement = new OrderElement();
+                $orderElement->setBaseId($element['base_id'])
+                    ->setDeny($element['deny'] === null ? null : (Boolean) $element['deny'])
+                    ->setOrder($order)
+                    ->setOrderMasterId($element['order_master_id'])
+                    ->setRecordId($element['record_id']);
+
+                $order->addElement($orderElement);
+                $em->persist($orderElement);
+            }
+
+            if ($n % 100 === 0) {
+                $em->flush();
+                $em->clear();
+            }
+        }
+
+        $em->flush();
+        $em->clear();
+
+        $em->getEventManager()->addEventSubscriber(new TimestampableListener());
+    }
+}