Dolibarr\Code\Product\Api\Products::index()

Complexity

Conditions	27
Paths	15169

Size

Total Lines	120
Code Lines	72

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function index($sortfield = "t.ref", $sortorder = 'ASC', $limit = 100, $page = 0, $mode = 0, $category = 0, $sqlfilters = '', $ids_only = false, $variant_filter = 0, $pagination_data = false, $includestockdata = 0, $properties = '')
    {
        global $db, $conf;

        if (!DolibarrApiAccess::$user->hasRight('produit', 'lire')) {
            throw new RestException(403);
        }

        $obj_ret = array();

        $socid = DolibarrApiAccess::$user->socid ? DolibarrApiAccess::$user->socid : '';

        $sql = "SELECT t.rowid, t.ref, t.ref_ext";
        $sql .= " FROM " . $this->db->prefix() . "product as t";
        $sql .= " LEFT JOIN " . MAIN_DB_PREFIX . "product_extrafields AS ef ON ef.fk_object = t.rowid"; // So we will be able to filter on extrafields
        if ($category > 0) {
            $sql .= ", " . $this->db->prefix() . "categorie_product as c";
        }
        $sql .= ' WHERE t.entity IN (' . getEntity('product') . ')';

        if ($variant_filter == 1) {
            $sql .= ' AND t.rowid not in (select distinct fk_product_parent from ' . $this->db->prefix() . 'product_attribute_combination)';
            $sql .= ' AND t.rowid not in (select distinct fk_product_child from ' . $this->db->prefix() . 'product_attribute_combination)';
        }
        if ($variant_filter == 2) {
            $sql .= ' AND t.rowid in (select distinct fk_product_parent from ' . $this->db->prefix() . 'product_attribute_combination)';
        }
        if ($variant_filter == 3) {
            $sql .= ' AND t.rowid in (select distinct fk_product_child from ' . $this->db->prefix() . 'product_attribute_combination)';
        }

        // Select products of given category
        if ($category > 0) {
            $sql .= " AND c.fk_categorie = " . ((int) $category);
            $sql .= " AND c.fk_product = t.rowid";
        }
        if ($mode == 1) {
            // Show only products
            $sql .= " AND t.fk_product_type = 0";
        } elseif ($mode == 2) {
            // Show only services
            $sql .= " AND t.fk_product_type = 1";
        }

        // Add sql filters
        if ($sqlfilters) {
            $errormessage = '';
            $sql .= forgeSQLFromUniversalSearchCriteria($sqlfilters, $errormessage);
            if ($errormessage) {
                throw new RestException(400, 'Error when validating parameter sqlfilters -> ' . $errormessage);
            }
        }

        //this query will return total products with the filters given
        $sqlTotals =  str_replace('SELECT t.rowid, t.ref, t.ref_ext', 'SELECT count(t.rowid) as total', $sql);

        $sql .= $this->db->order($sortfield, $sortorder);
        if ($limit) {
            if ($page < 0) {
                $page = 0;
            }
            $offset = $limit * $page;

            $sql .= $this->db->plimit($limit + 1, $offset);
        }

        $result = $this->db->query($sql);
        if ($result) {
            $num = $this->db->num_rows($result);
            $min = min($num, ($limit <= 0 ? $num : $limit));
            $i = 0;
            while ($i < $min) {
                $obj = $this->db->fetch_object($result);
                if (!$ids_only) {
                    $product_static = new Product($this->db);
                    if ($product_static->fetch($obj->rowid)) {
                        if (!empty($includestockdata) && DolibarrApiAccess::$user->hasRight('stock', 'lire')) {
                            $product_static->load_stock();

                            if (is_array($product_static->stock_warehouse)) {
                                foreach ($product_static->stock_warehouse as $keytmp => $valtmp) {
                                    if (isset($product_static->stock_warehouse[$keytmp]->detail_batch) && is_array($product_static->stock_warehouse[$keytmp]->detail_batch)) {
                                        foreach ($product_static->stock_warehouse[$keytmp]->detail_batch as $keytmp2 => $valtmp2) {
                                            unset($product_static->stock_warehouse[$keytmp]->detail_batch[$keytmp2]->db);
                                        }
                                    }
                                }
                            }
                        }


                        $obj_ret[] = $this->_filterObjectProperties($this->_cleanObjectDatas($product_static), $properties);
                    }
                } else {
                    $obj_ret[] = $obj->rowid;
                }
                $i++;
            }
        } else {
            throw new RestException(503, 'Error when retrieve product list : ' . $this->db->lasterror());
        }

        //if $pagination_data is true the response will contain element data with all values and element pagination with pagination data(total,page,limit)
        if ($pagination_data) {
            $totalsResult = $this->db->query($sqlTotals);
            $total = $this->db->fetch_object($totalsResult)->total;

            $tmp = $obj_ret;
            $obj_ret = array();

            $obj_ret['data'] = $tmp;
            $obj_ret['pagination'] = array(
                'total' => (int) $total,
                'page' => $page, //count starts from 0
                'page_count' => ceil((int) $total / $limit),
                'limit' => $limit
            );
        }

        return $obj_ret;
    }