DrillCoder\AmoCRM_Wrap\AmoCRM::search()

Complexity

Conditions	25
Paths	10080

Size

Total Lines	105
Code Lines	59

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    private function search(
        $entityName,
        $query = null,
        $limit = 0,
        $offset = 0,
        $responsibleUsers = array(),
        DateTime $modifiedSince = null,
        $isRaw = false,
        $pipelineIdOrName = null,
        $statuses = array()
    )
    {
        $offset = (int)$offset;
        $limit = (int)$limit;

        if ($responsibleUsers === null) {

The condition $responsibleUsers === null is always false.

            $responsibleUsers = array();
        } elseif (!is_array($responsibleUsers)) {
            $responsibleUsers = array($responsibleUsers);
        }

        if ($statuses === null) {

The condition $statuses === null is always false.

            $statuses = array();
        } elseif (!is_array($statuses)) {

The condition is_array($statuses) is always true.

            $statuses = array($statuses);
        }

        $options = explode('-', $entityName);
        $className = $options[0];
        $type = isset($options[1]) ? mb_strtolower($options[1]) : null;

        $entityFulName = __NAMESPACE__ . "\\$className";
        $attribute     = mb_strtolower($className);
        $config        = Config::$$attribute;
        $url           = 'api/v2/' . $config['url'] . '?';
        if ($query !== null) {
            $url .= "&query=$query";
        }
        if ($type !== null) {
            $url .= "&type=$type";
        }

        if ($pipelineIdOrName !== null && count($statuses) > 0) {
            foreach ($statuses as $statusIdOrName) {
                $statusId = self::searchStatusId($pipelineIdOrName, $statusIdOrName);
                $url .= "&status[]=$statusId";
            }
        }

        if (count($responsibleUsers) > 0) {
            foreach ($responsibleUsers as $responsibleUserIdOrName) {
                $responsibleUserId = self::searchUserId($responsibleUserIdOrName);
                $url .= "&responsible_user_id[]=$responsibleUserId";
            }
        }

        $totalCount = $limit;
        $results = array();

        while (true) {
            if ($totalCount > 500 || $limit === 0) {
                $limitRows = 500;
            } else {
                $limitRows = $totalCount;
            }

            $res = Base::cUrl($url . "&limit_rows=$limitRows&limit_offset=$offset", array(), $modifiedSince);
            if ($res === null) {
                break;
            }

            $results[] = $res->_embedded->items;
            if ($limit !== 0) {
                $totalCount -= count($res->_embedded->items);
                if ($totalCount <= 0) {
                    break;
                }
            }
            $offset += 500;
        }

        $resultRaw = array();
        if ($isRaw) {
            foreach ($results as $result) {
                foreach ($result as $baseRaw) {
                    if ($isRaw) {
                        $resultRaw[] = $baseRaw;
                    }
                }
            }

            return $resultRaw;
        }

        $entities = array();
        foreach ($results as $result) {
            foreach ($result as $baseRaw) {
                /** @var BaseEntity $entity */
                $entity = new $entityFulName();
                $entity->loadInRaw($baseRaw);
                $entities[] = $entity;
            }
        }

        return $entities;
    }
}