Action Repository

Entity/Action.php

@@ -7,7 +7,7 @@ use Symfony\Component\Validator\Constraints as Assert;
 
 /**
  * @ORM\Table
- * @ORM\Entity
+ * @ORM\Entity(repositoryClass="WorkflowBundle\Repository\ActionRepository")
  */
 class Action
 {

Repository/ActionRepository.php

@@ -0,0 +1,26 @@
+<?php
+
+namespace WorkflowBundle\Repository;
+
+use \Doctrine\ORM\EntityRepository;
+
+class ActionRepository extends EntityRepository
+{
+
+    /**
+     * @param string $eventName
+     * @param string $objectClass
+     * 
+     * @return array
+     */
+    public function findAllByEventAndObjectClass($eventName, $objectClass)
+    {
+        $qb = $this->createQueryBuilder('Action')
+                   ->andWhere('Action.event LIKE :eventName')->setParameter('eventName', "%{$eventName}%")
+                   ->andWhere('Action.objectClass = :objectClass')->setParameter('objectClass', $objectClass)
+                ;
+        
+        return $qb->getQuery()->getResult();
+    }
+
+}

Services/ProducerService.php

@@ -51,11 +51,7 @@ class ProducerService
         // la $entity esta dentro de las entidades con workflow
         if (in_array($entityClass, WorkFlowEntityClasses::getConstants())) {
             $actionRepository = $this->getEntityManager()->getRepository('WorkflowBundle:Action');
-            
-            /* @todo Refactorizar */
-            $actions = $actionRepository->findBy(array(
-                'objectClass' => $entityClass,
-            ));
+            $actions = $actionRepository->findAllByEventAndObjectClass($eventName, $entityClass);
             foreach ($actions as $action) {
                 $this->publishMessage($action, $entity);
             }