remove queue after mass email remove

2015-09-21 11:41:14 +03:00
parent 9ce65c9a2b
commit 1145406531
1 changed files with 12 additions and 0 deletions
@@ -62,6 +62,18 @@ class MassEmail extends \Espo\Services\Record
        }
    }

+    protected function afterRemove(Entity $entity, array $data = array())
+    {
+        parent::afterRemove($entity, $data);
+        $existingQueueItemList = $this->getEntityManager()->getRepository('EmailQueueItem')->where(array(
+            'status' => ['Pending', 'Failed'],
+            'massEmailId' => $massEmail->id
+        ))->find();
+        foreach ($existingQueueItemList as $existingQueueItem) {
+            $this->getEntityManager()->getMapper('RDB')->deleteFromDb('EmailQueueItem', $existingQueueItem->id);
+        }
+    }
+
    public function createQueue(Entity $massEmail, $isTest = false, $additionalTargetList = [])
    {
        if (!$isTest && $massEmail->get('status') !== 'Pending') {