WorkflowBundle/Command/WorkflowApplyCommand.php

<?php

namespace WorkflowBundle\Command;

use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use WorkflowBundle\Utils\WorkFlowEntityClasses;

class WorkflowApplyCommand extends ContainerAwareCommand
{
    protected function configure()
    {
        $this
            ->setName('workflow:apply')
            ->setDescription('Ejecuta una transiciÃn (de un workflow) en una entidad')
            ->setHelp('Ejecuta un Action (WorflowBundle\Entity\Action) de workflow para una Entidad (WorkflowBundle\Utils\WorkFlowEntityClasses)')
            ->addOption(
                'transition',
                null,
                InputOption::VALUE_REQUIRED,
                'Transition name'
            )
	    ->addOption(
                'workflow',
                null,
                InputOption::VALUE_REQUIRED,
                'Workflow name'
            )
            ->addOption(
                'entity',
                null,
                InputOption::VALUE_REQUIRED,
                'Entity Class. Possible values: ' . implode(', ', WorkFlowEntityClasses::getConstants()) 
            )
            ->addOption(
                'id',
                null,
                InputOption::VALUE_REQUIRED,
                'Entity id'
            )
        ;
    }

    /**
     * @param InputInterface $input
     * @param OutputInterface $output
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $entity_manager = $this->getContainer()->get("doctrine.orm.entity_manager");

	$transition = $input->getOption('transition');
	$workflow = $input->getOption('workflow');
        $entityClass = $input->getOption('entity');
        $entityId = $input->getOption('id');

	$entity = $entity_manager->getRepository($entityClass)->find($entityId);
	if(!$entity){
		throw \Exception("Entity $entityClass with id $entityId not found");
	}
        
	$wreg = $this->getContainer()->get("workflow.registry");
	$wf = $wreg->get($entity, $workflow);

	$newState = $wf->apply($entity, $transition);
	$entity_manager->persist($entity);
	$entity_manager->flush($entity);

    }
}