AmoCRM\Models\Pipelines

Complexity

Total Complexity

15

Size/Duplication

Total Lines	149
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

88%

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setIsMain()	0	10	2
A	apiList()	0	16	4
A	apiUpdate()	0	19	2
A	addStatusField()	0	12	2
B	apiAdd()	0	28	5

<?php

namespace AmoCRM\Models;

/**
 * Class Pipelines
 *
 * Класс модель для работы с списком воронок и этапов продаж
 *
 * @package AmoCRM\Models
 * @version 0.3.6
 * @author dotzero <mail@dotzero.ru>
 * @link http://www.dotzero.ru/
 * @link https://github.com/dotzero/amocrm-php
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
class Pipelines extends Base
{
    /**
     * @var array Список доступный полей для модели (исключая кастомные поля)
     */
    protected $fields = [
        'name',
        'sort',
        'is_main',
        'statuses',
    ];

    /**
     * Сеттер для поля - является ли воронка "главной"
     *
     * @param string $flag Флаг состояния
     * @return $this
     */
    public function setIsMain($flag)
    {
        if ($flag) {
            $this->values['is_main'] = 'on';
        } else {
            unset($this->values['is_main']);
        }

        return $this;
    }

    /**
     * Список воронок и этапов продаж
     *
     * Метод для получения списка воронок и этапов продаж.
     *
     * @link https://developers.amocrm.ru/rest_api/pipelines/list.php
     * @param null|int $id Уникальный идентификатор воронки
     * @return array Ответ amoCRM API
     * @throws \AmoCRM\Exception
     */
    public function apiList($id = null)
    {
        if ($id !== null) {
            $this->checkId($id);

            $response = $this->getRequest('/private/api/v2/json/pipelines/list', [
                'id' => $id
            ]);

            return isset($response['pipelines'][$id]) ? $response['pipelines'][$id] : [];
        }

        $response = $this->getRequest('/private/api/v2/json/pipelines/list');

        return isset($response['pipelines']) ? $response['pipelines'] : [];
    }

    /**
     * Добавление воронок и этапов продаж
     *
     * Метод позволяет добавлять воронки и этапов продаж по одной или пакетно
     *
     * @link https://developers.amocrm.ru/rest_api/pipelines/set.php
     * @param array $pipelines Массив воронок для пакетного добавления
     * @return int|array Уникальный идентификатор воронки или массив при пакетном добавлении
     */
    public function apiAdd($pipelines = [])
    {
        if (empty($pipelines)) {
            $pipelines = [$this];
        }

        $parameters = [
            'pipelines' => [
                'add' => [],
            ],
        ];

        foreach ($pipelines AS $pipeline) {
            $parameters['pipelines']['add'][] = $pipeline->getValues();
        }

        $response = $this->postRequest('/private/api/v2/json/pipelines/set', $parameters);

        if (isset($response['pipelines']['add']['pipelines'])) {
            $result = array_map(function ($item) {
                return $item['id'];
            }, $response['pipelines']['add']['pipelines']);
        } else {
            return [];
        }

        return count($pipelines) == 1 ? array_shift($result) : $result;
    }

    /**
     * Обновление воронок и этапов продаж
     *
     * Метод позволяет обновлять данные по уже существующим воронкам и этапам продаж
     *
     * @link https://developers.amocrm.ru/rest_api/pipelines/set.php
     * @param int $id Уникальный идентификатор воронки
     * @return bool Флаг успешности выполнения запроса
     * @throws \AmoCRM\Exception
     */
    public function apiUpdate($id)
    {
        $this->checkId($id);

        $parameters = [
            'pipelines' => [
                'update' => [],
            ],
        ];

        $pipeline = $this->getValues();
        $pipeline['id'] = $id;

        $parameters['pipelines']['update'][] = $pipeline;

        $response = $this->postRequest('/private/api/v2/json/pipelines/set', $parameters);

        return isset($response['pipelines']) ? true : false;
    }

    /**
     * Добавление этапов воронки, необходимо передать хотя бы один этап,
     * кроме успешно/неуспешно завершенного.
     *
     * В качестве ключа необходимо передать идентификатор этапа, если он существует.
     * Для этапов успешно/неуспешно завершенно (id 142/143 соответственно)
     * возможно передать только поле name
     *
     * @param mixed $parameters Значения заполняемого дополнительного поля типа мультиселект
     * @param int $id Уникальный идентификатор заполняемого дополнительного поля
     * @return $this
     */
    public function addStatusField($parameters, $id = null)
    {
        if ($id === null) {
            $this->values['statuses'][] = $parameters;
        } else {
            $this->checkId($id);
            $parameters['id'] = $id;
            $this->values['statuses'][$id] = $parameters;
        }

        return $this;
    }
}