FeatureContainer.php

<?php


namespace calderawp\CalderaFormsQuery\Features;

use calderawp\CalderaContainers\Container;
use calderawp\CalderaContainers\Interfaces\ServiceContainer;

use calderawp\CalderaFormsQuery\Delete\DeleteQueryBuilder;
use calderawp\CalderaFormsQuery\Delete\DoesDeleteQuery;
use calderawp\CalderaFormsQuery\DeleteQueries;
use calderawp\CalderaFormsQuery\MySqlBuilder;
use calderawp\CalderaFormsQuery\Delete\Entry as EntryDelete;
use \calderawp\CalderaFormsQuery\Delete\EntryValues as EntryValuesDelete;
use calderawp\CalderaFormsQuery\Select\DoesSelectQuery;
use \calderawp\CalderaFormsQuery\Select\Entry as EntrySelect;
use \calderawp\CalderaFormsQuery\Select\EntryValues as EntryValueSelect;
use calderawp\CalderaFormsQuery\Select\SelectQueryBuilder;
use calderawp\CalderaFormsQuery\SelectQueries;

class FeatureContainer extends Container
{
    /**
     * @var ServiceContainer
     */
    protected $serviceContainer;
    /**
     * @var \wpdb
     */
    protected $wpdb;

    /**
     * FeatureContainer constructor.
     * @param ServiceContainer $serviceContainer
     * @param \wpdb $wpdb
     */
    public function __construct(ServiceContainer $serviceContainer, \wpdb $wpdb)
    {
        $this->serviceContainer = $serviceContainer;
        $this->wpdb = $wpdb;
        $this->bindServices();
    }

    /**
     * Bind services to service container
     */
    protected function bindServices()
    {
        //@TODO move these to service provider classes
        $this->serviceContainer->singleton(MySqlBuilder::class, function () {
            return new MySqlBuilder();
        });

        $this->serviceContainer->bind(SelectQueries::class, function () {
            //@TODO Factory
            return new SelectQueries(
                new EntrySelect(
                    $this->getBuilder(),
                    $this->entryTableName()
                ),
                new EntryValueSelect(
                    $this->getBuilder(),
                    $this->entryValueTableName()
                ),
                $this->wpdb
            );
        });

        $this->serviceContainer->bind(DeleteQueries::class, function () {
            //@TODO Factory
            return new DeleteQueries(
                new EntryDelete(
                    $this->getBuilder(),
                    $this->entryTableName()
                ),
                new EntryValuesDelete(
                    $this->getBuilder(),
                    $this->entryValueTableName()
                ),
                $this->wpdb
            );
        });

        $this->serviceContainer->singleton(Queries::class, function () {
            return new Queries(
                $this
                    ->serviceContainer
                    ->make(SelectQueries::class),
                $this
                    ->serviceContainer
                    ->make(DeleteQueries::class)
            );
        });
    }

    /**
     * Get MySQL builder
     *
     * @return MySqlBuilder
     */
    public function getBuilder()
    {
        return $this
            ->serviceContainer
            ->make(MySqlBuilder::class);
    }

    /**
     * Get query runner
     *
     * @return Queries
     */
    public function getQueries()
    {
        return $this
            ->serviceContainer
            ->make(Queries::class);
    }

    /**
     * Select all entries and entry values by user ID
     *
     * @param int $userId
     * @return array
     */
    public function selectByUserId($userId)
    {
        $query = $this
            ->getQueries()
            ->entrySelect()
            ->queryByUserId($userId);
        return $this->collectResults($this->select($query));
    }

<<<<<<< HEAD
	/**
	 * Find all entries that have or do not have field with a slug and value
	 *
	 * @param string $fieldSlug Field slug
	 * @param string $fieldValue Field value
	 * @param bool $have Optional. Default: true. If true query is for fields with this value
	 *
	 * @return array
	 */
	public function selectByFieldValue($fieldSlug, $fieldValue, $have = true, $page = 1, $limit = 25 )
	{
		$type = $have ? 'equals' : 'notEquals';
		$queryForEntryValues = $this
			->getQueries()
			->entryValuesSelect()
            ->addPagination($page,$limit)
			->queryByFieldValue($fieldSlug, $fieldValue, $type, 'AND', [
				'entry_id'
			]);
		$results = $this->select($queryForEntryValues);
		if (empty($results) || 0 >= count($results)) {
			return [];
		}
		$results = $this->reduceResultsToEntryId($results);

		$queryForValues = $this
			->getQueries()
			->entrySelect()
            ->addPagination($page,$limit)
            ->queryByEntryIds($results);
=======
    /**
     * Select entries by form ID
     *
     * @param string $formId ID of form to select
     *
     * @param bool $addValues Optional Add entry values? Default is true.
     * @return array
     */
    public function selectByFormId($formId, $addValues = true )
    {
        $query = $this
            ->getQueries()
            ->entrySelect()
            ->queryByFormsId($formId);
        return $this->collectResults($this->select($query), $addValues);

    }
>>>>>>> 527d79ed169861a0db38e730e1ed8f374b533d04

    /**
     * Find all entries that have or do not have field with a slug and value
     *
     * @param string $fieldSlug Field slug
     * @param string $fieldValue Field value
     * @param bool $have Optional. Default: true. If true query is for fields with this value
     *
     * @return array
     */
    public function selectByFieldValue($fieldSlug, $fieldValue, $have = true)
    {
        $type = $have ? 'equals' : 'notEquals';
        $queryForEntryValues = $this
            ->getQueries()
            ->entryValuesSelect()
            ->queryByFieldValue($fieldSlug, $fieldValue, $type, 'AND', [
                'entry_id'
            ]);
        $results = $this->select($queryForEntryValues);
        if (empty($results) || 0 >= count($results)) {
            return [];
        }
        $results = $this->reduceResultsToEntryId($results);

        $queryForValues = $this
            ->getQueries()
            ->entrySelect()
            ->queryByEntryIds($results);

        return $this->collectResults($this->select($queryForValues));
    }

    /**
     * Delete all entry data, including field values for a collection of entries
     *
     * @param array $entryIds Entry Ids to delete
     * @return $this
     */
    public function deleteByEntryIds(array $entryIds)
    {
        $this->delete(
            $this
                ->getQueries()
                ->entryDelete()
                ->deleteByEntryIds($entryIds)
        );
        $this->delete(
            $this->getQueries()
                ->entryValueDelete()
                ->deleteByEntryIds($entryIds)
        );

        return $this;
    }

    /**
     * Delete all entries and entry values by user ID
     *
     * @param int $userId
     */
    public function deleteByUserId($userId)
    {
        $entries = $this->select(
            $this
                ->getQueries()
                ->entrySelect()
                ->queryByUserId($userId)
        );
        if (!empty($entries)) {
            $ids = $this->reduceResultsToEntryId($entries, 'id');
            $this->delete(
                $this
                    ->getQueries()
                    ->entryDelete()
                    ->deleteByEntryIds($ids)
            );
            $this->delete(
                $this
                    ->getQueries()
                    ->entryValueDelete()
                    ->deleteByEntryIds($ids)
            );
        }
    }

    /**
     * @return string
     */
    protected function entryValueTableName()
    {
        return "{$this->wpdb->prefix}cf_form_entry_values";
    }

    /**
     * @return string
     */
    protected function entryTableName()
    {
        return "{$this->wpdb->prefix}cf_form_entries";
    }

    /**
     * Collect results using  Caldera_Forms_Entry_Entry and Caldera_Forms_Entry_Field to represent values
     *
     * @param \stdClass[] $entriesValues
     * @param bool $addValues Optional Add entry values? Default is true.
     * @return array
     */
    private function collectResults($entriesValues, $addValues = true)
    {
        $results = [];
        foreach ($entriesValues as $entry) {
            $entry = new \Caldera_Forms_Entry_Entry($entry);
            $query = $this
                ->getQueries()
                ->entryValuesSelect()
                ->queryByEntryId($entry->id);

            $entryValuesPrepared = [];
            if ($addValues) {
                $entriesValues = $this->select($query);
                $entryValuesPrepared = $this->collectEntryValues($entriesValues);
            }
            $results[] = [
                'entry' => $entry,
                'values' => $entryValuesPrepared
            ];
        }
        return $results;
    }

    /**
     * Collect entry values as Caldera_Forms_Entry_Field objects
     *
     * @param \stdClass[] $entriesValues
     * @return array
     */
    private function collectEntryValues($entriesValues): array
    {
        $entryValuesPrepared = [];
        if (!empty($entriesValues)) {
            foreach ($entriesValues as $entryValue) {
                $entryValuesPrepared[] = new \Caldera_Forms_Entry_Field($entryValue);
            }
        }
        return $entryValuesPrepared;
    }

    /**
     * Do a select query
     *
     * @param SelectQueryBuilder $query
     * @return \stdClass[]
     */
    private function select(SelectQueryBuilder $query)
    {
        return $this
            ->getQueries()
            ->select($query);
    }

    /**
     * Do a delete query
     *
     * @param DeleteQueryBuilder $query
     * @return \stdClass[]
     */
    private function delete(DeleteQueryBuilder $query)
    {
        return $this->
        getQueries()
            ->delete($query);
    }

    /**
     * @param $results
     * @return array
     */
    private function reduceResultsToEntryId($results, $colum = 'entry_id')
    {
        foreach ($results as &$result) {
            $result = $result->$colum;
        }
        return $results;
    }
}