Phraseanet/lib/Alchemy/Phrasea/Controller/Prod/WorkZone.php

<?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.
 */

namespace Alchemy\Phrasea\Controller\Prod;

use Silex\Application,
    Silex\ControllerProviderInterface,
    Silex\ControllerCollection;
use Symfony\Component\HttpFoundation\Request,
    Symfony\Component\HttpFoundation\Response,
    Symfony\Component\HttpFoundation\RedirectResponse,
    Symfony\Component\HttpKernel\Exception\HttpException,
    Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
use Alchemy\Phrasea\RouteProcessor\WorkZone as RouteWorkZone,
    Alchemy\Phrasea\Helper;

/**
 *
 * @license     http://opensource.org/licenses/gpl-3.0 GPLv3
 * @link        www.phraseanet.com
 */
class WorkZone implements ControllerProviderInterface
{

    public function connect(Application $app)
    {
        $controllers = $app['controllers_factory'];

        $controllers->get('/', function(Application $app) {
                $params = array(
                    'WorkZone'      => new Helper\WorkZone($app['phraseanet.core'], $app['request'])
                    , 'selected_type' => $app['request']->get('type')
                    , 'selected_id'   => $app['request']->get('id')
                    , 'srt'           => $app['request']->get('sort')
                );

                return new Response($app['twig']->render('prod/WorkZone/WorkZone.html.twig', $params));
            });

        $controllers->get('/Browse/', function(Application $app) {
                $date_obj = new \DateTime();

                $params = array(
                    'CurrentYear' => $date_obj->format('Y')
                );

                return new Response(
                        $app['twig']->render('prod/WorkZone/Browser/Browser.html.twig'
                            , $params
                        )
                );
            });

        $controllers->get('/Browse/Search/', function(Application $app) {

                $user = $app['phraseanet.core']->getAuthenticatedUser();

                $request = $app['request'];

                $em = $app['phraseanet.core']->getEntityManager();
                /* @var $em \Doctrine\ORM\EntityManager */

                $BasketRepo = $em->getRepository('\Entities\Basket');

                $Page = (int) $request->get('Page', 0);

                $PerPage = 10;
                $offsetStart = max(($Page - 1) * $PerPage, 0);

                $Baskets = $BasketRepo->findWorkzoneBasket(
                    $user
                    , $request->get('Query')
                    , $request->get('Year')
                    , $request->get('Type')
                    , $offsetStart
                    , $PerPage
                );

                $page = floor($offsetStart / $PerPage) + 1;
                $maxPage = floor(count($Baskets) / $PerPage) + 1;

                $params = array(
                    'Baskets' => $Baskets
                    , 'Page'    => $page
                    , 'MaxPage' => $maxPage
                    , 'Total'   => count($Baskets)
                    , 'Query'   => $request->get('Query')
                    , 'Year'    => $request->get('Year')
                    , 'Type'    => $request->get('Type')
                );

                return new Response($app['twig']->render('prod/WorkZone/Browser/Results.html.twig', $params));
            });

        $controllers->get('/Browse/Basket/{basket_id}/', function(Application $app, Request $request, $basket_id) {

                $em = $app['phraseanet.core']->getEntityManager();

                $basket = $em->getRepository('\Entities\Basket')
                    ->findUserBasket($basket_id, $app['phraseanet.core']->getAuthenticatedUser(), false);

                $params = array(
                    'Basket' => $basket
                );

                return new Response($app['twig']->render('prod/WorkZone/Browser/Basket.html.twig', $params));
            })->assert('basket_id', '\d+');

        $controllers->post('/attachStories/', function(Application $app, Request $request) {
                if ( ! $request->get('stories'))
                    throw new \Exception_BadRequest();

                $user = $app['phraseanet.core']->getAuthenticatedUser();

                $em = $app['phraseanet.core']->getEntityManager();
                /* @var $em \Doctrine\ORM\EntityManager */

                $StoryWZRepo = $em->getRepository('\Entities\StoryWZ');

                $alreadyFixed = $done = 0;

                $stories = $request->get('stories', array());

                foreach ($stories as $element) {
                    $element = explode('_', $element);
                    $Story = new \record_adapter($element[0], $element[1]);

                    if ( ! $Story->is_grouping())
                        throw new \Exception('You can only attach stories');

                    if ( ! $user->ACL()->has_access_to_base($Story->get_base_id()))
                        throw new \Exception_Forbidden('You do not have access to this Story');

                    if ($StoryWZRepo->findUserStory($user, $Story)) {
                        $alreadyFixed ++;
                        continue;
                    }

                    $StoryWZ = new \Entities\StoryWZ();
                    $StoryWZ->setUser($user);
                    $StoryWZ->setRecord($Story);

                    $em->persist($StoryWZ);
                    $done ++;
                }

                $em->flush();

                if ($alreadyFixed === 0) {
                    if ($done <= 1) {
                        $message = sprintf(
                            _('%d Story attached to the WorkZone')
                            , $done
                        );
                    } else {
                        $message = sprintf(
                            _('%d Stories attached to the WorkZone')
                            , $done
                        );
                    }
                } else {
                    if ($done <= 1) {
                        $message = sprintf(
                            _('%1$d Story attached to the WorkZone, %2$d already attached')
                            , $done
                            , $alreadyFixed
                        );
                    } else {
                        $message = sprintf(
                            _('%1$d Stories attached to the WorkZone, %2$d already attached')
                            , $done
                            , $alreadyFixed
                        );
                    }
                }

                $data = array(
                    'success' => true
                    , 'message' => $message
                );

                if ($request->getRequestFormat() == 'json') {
                    return $app->json($data);
                } else {
                    return $app->redirect('/{sbas_id}/{record_id}/');
                }
            });

        $controllers->post('/detachStory/{sbas_id}/{record_id}/', function(Application $app, Request $request, $sbas_id, $record_id) {
                $Story = new \record_adapter($sbas_id, $record_id);

                $user = $app['phraseanet.core']->getAuthenticatedUser();

                $em = $app['phraseanet.core']->getEntityManager();

                $repository = $em->getRepository('\Entities\StoryWZ');

                /* @var $repository \Repositories\StoryWZRepository */
                $StoryWZ = $repository->findUserStory($user, $Story);

                if ( ! $StoryWZ) {
                    throw new \Exception_NotFound('Story not found');
                }
                $em->remove($StoryWZ);
                $em->flush();

                $data = array(
                    'success' => true
                    , 'message' => _('Story detached from the WorkZone')
                );

                if ($request->getRequestFormat() == 'json') {
                    return $app->json($data);
                } else {
                    return $app->redirect('/');
                }
            })->assert('sbas_id', '\d+')->assert('record_id', '\d+');

        return $controllers;
    }
}