Phraseanet/lib/classes/patch/390alpha6a.php

<?php

/*
 * This file is part of Phraseanet
 *
 * (c) 2005-2014 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 Alchemy\Phrasea\Model\Entities\FtpExport;
use Alchemy\Phrasea\Model\Entities\FtpExportElement;
use Gedmo\Timestampable\TimestampableListener;

class patch_390alpha6a extends patchAbstract
{
    /** @var string */
    private $release = '3.9.0-alpha.6';

    /** @var array */
    private $concern = [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 getDoctrineMigrations()
    {
        return ['20131118000013'];
    }

    /**
     * {@inheritdoc}
     */
    public function apply(base $appbox, Application $app)
    {
        $sql = 'DELETE FROM FtpExports';
        $stmt = $app->getApplicationBox()->get_connection()->prepare($sql);
        $stmt->execute();
        $stmt->closeCursor();

        $sql = 'DELETE FROM FtpExportElements';
        $stmt = $app->getApplicationBox()->get_connection()->prepare($sql);
        $stmt->execute();
        $stmt->closeCursor();

        $conn = $app->getApplicationBox()->get_connection();

        $em = $app['orm.em'];
        $em->getEventManager()->removeEventSubscriber(new TimestampableListener());

        $sql = 'SELECT `id`, `crash`, `nbretry`, `mail`, `addr`, `ssl`,
                    `login`, `pwd`, `passif`,
                    `destfolder`, `sendermail`, `text_mail_sender`,
                    `text_mail_receiver`, `usr_id`, `date`, `foldertocreate`,
                    `logfile`
                FROM ftp_export';
        $stmt = $conn->prepare($sql);
        $stmt->execute();
        $rs = $stmt->fetchAll(\PDO::FETCH_ASSOC);
        $stmt->closeCursor();

        $sql = 'SELECT base_id, record_id, subdef, filename, folder, error, done, businessfields
                FROM ftp_export_elements
                WHERE ftp_export_id = :export_id';
        $stmt = $conn->prepare($sql);

        $n = 0;

        foreach ($rs as $row) {
            if (null === $user = $this->loadUser($app['orm.em'], $row['usr_id'])) {
                continue;
            }

            $export = new FtpExport();
            $export
                ->setAddr($row['addr'])
                ->setCrash($row['crash'])
                ->setNbretry($row['nbretry'])
                ->setMail($row['mail'])
                ->setSsl($row['ssl'])
                ->setLogin($row['login'])
                ->setPwd($row['pwd'])
                ->setPassif($row['passif'])
                ->setDestfolder($row['destfolder'])
                ->setSendermail($row['sendermail'])
                ->setTextMailReceiver($row['text_mail_sender'])
                ->setTextMailSender($row['text_mail_receiver'])
                ->setUser($user)
                ->setCreated(new \DateTime($row['date']))
                ->setUpdated(new \DateTime($row['date']))
                ->setFoldertocreate($row['foldertocreate'])
                ->setLogfile($row['logfile']);

            $em->persist($export);

            $stmt->execute(['export_id' => $row['id']]);
            $rs = $stmt->fetchAll(\PDO::FETCH_ASSOC);

            foreach ($rs as $element_row) {
                $element = new FtpExportElement();
                $element->setBaseId($element_row['base_id'])
                    ->setRecordId($element_row['record_id'])
                    ->setBusinessfields($element_row['businessfields'])
                    ->setCreated(new \DateTime($row['date']))
                    ->setUpdated(new \DateTime($row['date']))
                    ->setDone(!!$element_row['done'])
                    ->setError(!!$element_row['error'])
                    ->setFilename($element_row['filename'])
                    ->setFolder($element_row['folder'])
                    ->setSubdef($element_row['subdef'])
                    ->setExport($export);

                $export->addElement($element);

                $em->persist($element);
            }

            $n++;

            if ($n % 200 === 0) {
                $em->flush();
                $em->clear();
            }
        }
        $stmt->closeCursor();

        $em->flush();
        $em->clear();

        $em->getEventManager()->addEventSubscriber(new TimestampableListener());

        return true;
    }
}