# acymailing/10.0.1/back/Classes/ScenarioProcessClass.php

AcyMailing – An Ultimate Newsletter Plugin and Marketing Automation Solution for WordPress, version 10.0.1. 94 lines.

- Page: https://pluginprobe.com/plugins/acymailing/10.0.1/code/back/Classes/ScenarioProcessClass.php
- Raw: https://pluginprobe.com/plugins/acymailing/10.0.1/raw/back/Classes/ScenarioProcessClass.php
- Modified: 2025-01-27T11:09:38+00:00

Line numbers below start at 1. Link to a line or a range by appending a fragment to the
page URL, for example `https://pluginprobe.com/plugins/acymailing/10.0.1/code/back/Classes/ScenarioProcessClass.php#L10-L20`.

```php
<?php

namespace AcyMailing\Classes;

use AcyMailing\Helpers\PaginationHelper;
use AcyMailing\Core\AcymClass;

class ScenarioProcessClass extends AcymClass
{
    public function __construct()
    {
        parent::__construct();

        $this->table = 'scenario_process';
        $this->pkey = 'id';
    }

    public function getOneByScenarioIdUserId(int $scenarioId, int $userId)
    {
        $query = 'SELECT * FROM #__acym_scenario_process WHERE scenario_id = '.$scenarioId.' AND user_id = '.$userId;

        return acym_loadResult($query);
    }

    public function endProcess(int $scenarioProcessId)
    {
        $scenarioProcess = new \stdClass();
        $scenarioProcess->id = $scenarioProcessId;
        $scenarioProcess->end_at = acym_date('now', 'Y-m-d H:i:s', false);

        $this->save($scenarioProcess);
    }

    public function getNumberOfTriggerByScenarioId(int $scenarioId)
    {
        $numberOfTrigger = acym_loadResult('SELECT COUNT(*) FROM #__acym_scenario_process WHERE scenario_id = '.$scenarioId);

        if (empty($numberOfTrigger)) {
            return 0;
        }

        return $numberOfTrigger;
    }


    public function getMatchingElements(array $settings = []): array
    {
        $results = [];

        $query = 'SELECT DISTINCT scenario_process.*, user.email  FROM #__acym_scenario_process AS `scenario_process`';
        $queryCount = 'SELECT COUNT(DISTINCT scenario_process.id) FROM #__acym_scenario_process AS scenario_process';
        $filters = [];

        $joins = [
            'JOIN #__acym_user AS user ON user.id = scenario_process.user_id',
        ];

        if (!empty($joins)) {
            $query .= ' '.implode(' ', $joins);
            $queryCount .= ' '.implode(' ', $joins);
        }

        if (!empty($settings['scenarioId'])) {
            $filters[] = 'scenario_process.scenario_id = '.intval($settings['scenarioId']);

            $results['totalOverall'] = acym_loadResult('SELECT COUNT(*) FROM #__acym_scenario_process WHERE scenario_id = '.intval($settings['scenarioId']));
        }

        if (!empty($settings['search'])) {
            $searchValue = acym_escapeDB('%'.$settings['search'].'%');
            $filters[] = 'user.name LIKE '.$searchValue.' OR user.email LIKE '.$searchValue;
        }

        if (!empty($filters)) {
            $query .= ' WHERE ('.implode(') AND (', $filters).')';
            $queryCount .= ' WHERE ('.implode(') AND (', $filters).')';
        }

        if (empty($settings['offset']) || $settings['offset'] < 0) {
            $settings['offset'] = 0;
        }

        if (empty($settings['elementsPerPage']) || $settings['elementsPerPage'] < 1) {
            $pagination = new PaginationHelper();
            $settings['elementsPerPage'] = $pagination->getListLimit();
        }

        $results['elements'] = acym_loadObjectList($query, 'id', $settings['offset'], $settings['elementsPerPage']);
        $results['total'] = acym_loadResult($queryCount);

        return $results;
    }
}

```