Added new files

Author: kuzmany

Config/config.php

@@ -57,7 +57,6 @@
                 'mautic.sqlConditions' => [
                     'route'    => 'mautic_sqlConditions_index',
                     'parent'   => 'mautic.campaign.menu.index',
-                    'iconClass' => 'fa fa-database',
                     'priority' => 70,
                     'checks'   => [
                         'integration' => [

EventListener/CampaignConditionSubscriber.php

@@ -0,0 +1,56 @@
+<?php
+
+/*
+ * @copyright   2016 Mautic Contributors. All rights reserved
+ * @author      Mautic, Inc.
+ *
+ * @link        https://mautic.org
+ *
+ * @license     GNU/GPLv3 http://www.gnu.org/licenses/gpl-3.0.html
+ */
+
+namespace MauticPlugin\MauticSqlConditionsBundle\EventListener;
+
+use Mautic\CampaignBundle\CampaignEvents;
+use Mautic\CampaignBundle\Event\CampaignBuilderEvent;
+use Mautic\CampaignBundle\Event\ConditionEvent;
+use MauticPlugin\MauticSqlConditionsBundle\SqlConditionsEvents;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+
+/**
+ * Class CampaignConditionSubscriber.
+ */
+class CampaignConditionSubscriber implements EventSubscriberInterface
+{
+    /**
+     * @return array
+     */
+    public static function getSubscribedEvents()
+    {
+        return [
+            CampaignEvents::CAMPAIGN_ON_BUILD          => ['onCampaignBuild', 0],
+            SqlConditionsEvents::ON_CAMPAIGN_CONDITION_TRIGGER => ['onCampaignTriggerCondition', 0],
+        ];
+    }
+
+    /**
+     * @param CampaignBuilderEvent $event
+     */
+    public function onCampaignBuild(CampaignBuilderEvent $event)
+    {
+        $event->addCondition(
+            'sql.condition',
+            [
+                'label'       => 'mautic.sqlConditions',
+                'eventName'   => SqlConditionsEvents::ON_CAMPAIGN_CONDITION_TRIGGER,
+            ]
+        );
+    }
+
+    /**
+     * @param ConditionEvent $event
+     */
+    public function onCampaignTriggerCondition(ConditionEvent $event)
+    {
+    }
+}

Executioner/Parser/Parser.php

@@ -0,0 +1,19 @@
+<?php
+
+/*
+ * @copyright   2019 Mautic Contributors. All rights reserved
+ * @author      Mautic
+ *
+ * @link        http://mautic.org
+ *
+ * @license     GNU/GPLv3 http://www.gnu.org/licenses/gpl-3.0.html
+ */
+
+namespace MauticPlugin\MauticSqlConditionsBundle\SqlExecutioner;
+
+class Parser
+{
+    public function parse()
+    {
+    }
+}

Executioner/QueryBuilder.php

@@ -0,0 +1,54 @@
+<?php
+
+/*
+ * @copyright   2019 Mautic Contributors. All rights reserved
+ * @author      Mautic
+ *
+ * @link        http://mautic.org
+ *
+ * @license     GNU/GPLv3 http://www.gnu.org/licenses/gpl-3.0.html
+ */
+
+namespace MauticPlugin\MauticSqlConditionsBundle\SqlExecutioner;
+
+use Doctrine\DBAL\Connections\MasterSlaveConnection;
+use Doctrine\ORM\EntityManager;
+
+class QueryBuilder
+{
+    /**
+     * @var EntityManager
+     */
+    private $entityManager;
+
+    /**
+     * @var \Doctrine\DBAL\Connection
+     */
+    private $connection;
+
+    /**
+     * SqlExecutioner constructor.
+     *
+     * @param SqlConditionDetails $sqlConditionDetails
+     */
+    public function __construct(EntityManager $entityManager)
+    {
+        $this->entityManager = $entityManager;
+
+        /** @var Connection $connection */
+        $this->connection = $this->entityManager->getConnection();
+        if ($this->connection instanceof MasterSlaveConnection) {
+            $this->connection->connect('slave');
+        }
+    }
+
+    public function getQuery()
+    {
+        //getdetail
+        // getParams
+        $this->connection->executeQuery($query, $params);
+        $queryBuilder = new QueryBuilder($this->connection);
+    }
+
+
+}

Executioner/SqlConditionDetails.php

@@ -0,0 +1,120 @@
+<?php
+
+/*
+ * @copyright   2019 Mautic Contributors. All rights reserved
+ * @author      Mautic
+ *
+ * @link        http://mautic.org
+ *
+ * @license     GNU/GPLv3 http://www.gnu.org/licenses/gpl-3.0.html
+ */
+
+namespace MauticPlugin\MauticSqlConditionsBundle\SqlExecutioner;
+
+use Mautic\CampaignBundle\Event\ConditionEvent;
+use MauticPlugin\MauticSqlConditionsBundle\Model\SqlConditionsModel;
+
+class SqlConditionDetails
+{
+    /**
+     * @var SqlConditionsModel
+     */
+    private $sqlConditionsModel;
+
+    /**
+     * @var ConditionEvent
+     */
+    private $conditionEvent;
+
+    /**
+     * SqlCondition constructor.
+     *
+     * @param SqlConditionsModel $sqlConditionsModel
+     */
+    public function __construct(SqlConditionsModel $sqlConditionsModel)
+    {
+        $this->sqlConditionsModel = $sqlConditionsModel;
+    }
+
+    /**
+     * @param ConditionEvent $conditionEvent
+     */
+    public function setConditionEvent(ConditionEvent $conditionEvent)
+    {
+        $this->conditionEvent = $conditionEvent;
+    }
+
+
+    /**
+     * @return ConditionEvent
+     * @throws \Exception
+     */
+    public function getConditionEvent()
+    {
+        if (!$this->conditionEvent) {
+            throw new \Exception('Condition event not exist');
+        }
+
+        return $this->conditionEvent;
+    }
+
+    /**
+     * @return mixed
+     * @throws \Exception
+     */
+    public function getSqlQuery()
+    {
+        $sqlConditionId = $this->getConditionEvent()->getEventConfig()['sql'];
+        $entity =  $this->sqlConditionsModel->getEntity($sqlConditionId);
+
+        if ($entity) {
+            return $entity->getSqlQuery();
+        }
+
+    }
+
+    /**
+     * @return int
+     * @throws \Exception
+     */
+    public function getContactId()
+    {
+        return $this->getConditionEvent()->getLead()->getId();
+    }
+
+    /**
+     * @return int
+     * @throws \Exception
+     */
+    public function getCampaignId()
+    {
+        return $this->getConditionEvent()->getLogEntry()->getCampaign()->getId();
+    }
+
+    /**
+     * @return int
+     * @throws \Exception
+     */
+    public function getEventId()
+    {
+        return $this->getConditionEvent()->getEvent()['id'];
+    }
+
+    /**
+     * @return int
+     * @throws \Exception
+     */
+    public function getRotation()
+    {
+        return $this->getConditionEvent()->getLogEntry()->getRotation();
+    }
+
+    /**
+     * @return string
+     */
+    public function getPrefix()
+    {
+        return MAUTIC_TABLE_PREFIX;
+    }
+
+}

Executioner/SqlExecutioner.php

@@ -0,0 +1,36 @@
+<?php
+
+/*
+ * @copyright   2019 Mautic Contributors. All rights reserved
+ * @author      Mautic
+ *
+ * @link        http://mautic.org
+ *
+ * @license     GNU/GPLv3 http://www.gnu.org/licenses/gpl-3.0.html
+ */
+
+namespace MauticPlugin\MauticSqlConditionsBundle\SqlExecutioner;
+
+class SqlExecutioner
+{
+    /**
+     * @var SqlConditionDetails
+     */
+    private $sqlConditionDetails;
+
+    /**
+     * SqlExecutioner constructor.
+     *
+     * @param SqlConditionDetails $sqlConditionDetails
+     */
+    public function __construct(SqlConditionDetails $sqlConditionDetails)
+    {
+        $this->sqlConditionDetails = $sqlConditionDetails;
+    }
+
+    public function runQuery()
+    {
+
+    }
+
+}

Executioner/Token/AbstractToken.php

@@ -0,0 +1,19 @@
+<?php
+
+/*
+ * @copyright   2019 Mautic Contributors. All rights reserved
+ * @author      Mautic
+ *
+ * @link        http://mautic.org
+ *
+ * @license     GNU/GPLv3 http://www.gnu.org/licenses/gpl-3.0.html
+ */
+
+namespace MauticPlugin\MauticSqlConditionsBundle\Token;
+
+abstract class AbstractToken
+{
+    protected $token;
+
+
+}

Executioner/Token/Prefix.php

@@ -0,0 +1,18 @@
+<?php
+
+/*
+ * @copyright   2019 Mautic Contributors. All rights reserved
+ * @author      Mautic
+ *
+ * @link        http://mautic.org
+ *
+ * @license     GNU/GPLv3 http://www.gnu.org/licenses/gpl-3.0.html
+ */
+
+namespace MauticPlugin\MauticSqlConditionsBundle\Token;
+
+class Prefix extends AbstractToken
+{
+    protected $token = 'PREFIX';
+    protected $value = 'PREFIX';
+}

SqlConditionsEvents.php

@@ -54,4 +54,13 @@ final class SqlConditionsEvents
      */
     const POST_DELETE = 'mautic.sqlConditions_post_delete';
 
+    /**
+     * The mautic.sqlConditions.on_campaign_condition_trigger event is dispatched when the campaign sql condition is executed.
+     *
+     * The event listener receives a      * Mautic\CampaignBundle\Event\CampaignExecutionEvent
+     *
+     * @var string
+     */
+    const ON_CAMPAIGN_CONDITION_TRIGGER = 'mautic.sqlConditions.on_campaign_condition_trigger';
+
 }