Changeset 19523 for branches/camp

Timestamp:

2010/11/07 04:16:05 (13 years ago)

Author:

AMUAMU

Message:

商品一覧高速化と、IN句が長くなり正常に動かない問題を修正

Location:

branches/camp/camp-2_5-D/data/class

Files:

• SC_Product.php (modified) (3 diffs)
• pages/products/LC_Page_Products_List.php (modified) (7 diffs)

branches/camp/camp-2_5-D/data/class/SC_Product.php

@@ -46 +46 @@
     var $classCat2_find;
     var $classCats1;
+    /** 検索用並び替え条件配列 */
+    var $arrOrderData;
 
     /**
@@ -72 +74 @@
         return array_unique($resultValues);
     }
+    
+    /**
+     * 商品検索結果の並び順を指定する。
+     *
+     * ただし指定できるテーブルはproduct_idを持っているテーブルであることが必要.
+     *
+     * @param string $col 並び替えの基準とするフィールド
+     * @param string $table 並び替えの基準とするフィールドがあるテーブル
+     * @param string $order 並び替えの順序 ASC / DESC
+     * @return void
+     */
+    function setProductsOrder($col, $table = 'dtb_products', $order = 'ASC') {
+        $this->arrOrderData = array('col' => $col, 'table' => $table, 'order' => $order);
+    }
+
+    /**
+     * SC_Queryインスタンスに設定された検索条件を元に並び替え済みの検索結果商品IDの配列を取得する。
+     *
+     * 検索条件は, SC_Query::getWhere() 関数で設定しておく必要があります.
+     *
+     * @param SC_Query $objQuery SC_Query インスタンス
+     * @param array $arrVal 検索パラメータの配列
+     * @return array 商品IDの配列
+     */
+    function findProductIdsOrder(&$objQuery, $arrVal = array(), $where) {
+        $table = <<< __EOS__
+                 dtb_products AS alldtl
+            JOIN dtb_products_class AS T1
+              ON alldtl.product_id = T1.product_id
+            JOIN dtb_product_categories AS T2
+              ON alldtl.product_id = T2.product_id
+            JOIN dtb_category
+              ON T2.category_id = dtb_category.category_id
+__EOS__;
+        $objQuery->setGroupBy('alldtl.product_id');
+        if(is_array($this->arrOrderData) and $objQuery->order == ""){
+            $o_col = $this->arrOrderData['col'];
+            $o_table = $this->arrOrderData['table'];
+            $o_order = $this->arrOrderData['order'];
+            $order = <<< __EOS__
+                    (
+                        SELECT $o_col
+                        FROM
+                            $o_table as T2
+                        WHERE T2.product_id = alldtl.product_id
+                        ORDER BY T2.$o_col $o_order
+                        LIMIT 1
+                    ) $o_order, product_id
+__EOS__;
+            $objQuery->setOrder($order);
+        }
+        $results = $objQuery->select('alldtl.product_id', $table, "", $arrVal,
+                                     MDB2_FETCHMODE_ORDERED);
+        foreach ($results as $val) {
+            $resultValues[] = $val[0];
+        }
+        return $resultValues;
+    }
+
+    /**
+     * SC_Queryインスタンスに設定された検索条件をもとに対象商品数を取得する.
+     *
+     * 検索条件は, SC_Query::getWhere() 関数で設定しておく必要があります.
+     *
+     * @param SC_Query $objQuery SC_Query インスタンス
+     * @param array $arrVal 検索パラメータの配列
+     * @return array 対象商品ID数
+     */
+    function findProductCount(&$objQuery, $arrVal = array()) {
+        $table = <<< __EOS__
+                 dtb_products AS alldtl
+            JOIN dtb_product_categories AS T2
+              ON alldtl.product_id = T2.product_id
+            JOIN dtb_category
+              ON T2.category_id = dtb_category.category_id
+__EOS__;
+        $objQuery->setGroupBy('alldtl.product_id');
+        $sql_base = $objQuery->getSql('alldtl.product_id',$table);
+        return $objQuery->getOne( "SELECT count(*) FROM ( $sql_base ) as t" , $arrVal);
+    }
+    
 
     /**
@@ -109 +192 @@
             ,update_date
 __EOS__;
-        return $objQuery->select($col, $this->alldtlSQL($objQuery->where),
+        $res = $objQuery->select($col, $this->alldtlSQL($objQuery->where),
                                  "", $arrVal);
+        return $res;
     }
 

branches/camp/camp-2_5-D/data/class/pages/products/LC_Page_Products_List.php

@@ -314 +314 @@
     /* 商品一覧の表示 */
     function lfDispProductsList() {
-
         $objDb = new SC_Helper_DB_Ex();
         $arrval = array();
@@ -324 +323 @@
             list($where_category, $arrval_category) = $objDb->sfGetCatWhere($this->arrSearchData['category_id']);
         }
-
         // ▼対象商品IDの抽出
         // 商品検索条件の作成（未削除、表示）
-        $where = "del_flg = 0 AND status = 1 ";
-        $where1 = "alldtl.del_flg = 0 AND alldtl.status = 1 ";
+        $where = "alldtl.del_flg = 0 AND alldtl.status = 1 ";
 
         // 在庫無し商品の非表示
         if (NOSTOCK_HIDDEN === true) {
-            $where .= ' AND (stock_max >= 1 OR stock_unlimited_max = 1)';
+            $where .= ' AND (stock >= 1 OR stock_unlimited = 1)';
         }
 
         if (strlen($where_category) >= 1) {
-            $where.= " AND $where_category";
-            $where1 .= " AND T2.$where_category";
+            $where .= " AND T2.$where_category";
             $arrval = array_merge($arrval, $arrval_category);
         }
@@ -351 +347 @@
         foreach ($names as $val) {
             if ( strlen($val) > 0 ) {
-                $where .= " AND ( name ILIKE ? OR comment3 ILIKE ?) ";
-                $where1 .= " AND ( alldtl.name ILIKE ? OR alldtl.comment3 ILIKE ?) ";
+                $where .= " AND ( alldtl.name ILIKE ? OR alldtl.comment3 ILIKE ?) ";
                 $arrval[] = "%$val%";
                 $arrval[] = "%$val%";
@@ -360 +355 @@
         // メーカーらのWHERE文字列取得
         if ($this->arrSearchData['maker_id']) {
-            $where .= " AND maker_id = ? ";
-            $where1 .= " AND alldtl.maker_id = ? ";
+            $where .= " AND alldtl.maker_id = ? ";
             $arrval[] = $this->arrSearchData['maker_id'];
         }
-
-        // 一覧表示する商品IDを取得
+ 
+        // 検索結果対象となる商品の数を取得
         $objQuery =& SC_Query::getSingletonInstance();
-        $objQuery->setWhere($where1);
+        $objQuery->setWhere($where);
         $objProduct = new SC_Product();
-        $arrProduct_id = $objProduct->findProductIds($objQuery, $arrval);
-
-        // 行数の取得
-        $linemax = count($arrProduct_id);
-
+        $linemax = $objProduct->findProductCount($objQuery, $arrval);
         $this->tpl_linemax = $linemax;   // 何件が該当しました。表示用
 
@@ -385 +375 @@
         $startno = $this->objNavi->start_row;                 // 開始行
 
-        // WHERE 句
-        $where = '0=0';
-        if (is_array($arrProduct_id) && !empty($arrProduct_id)) {
-            $where .= ' AND product_id IN (' . implode(',', $arrProduct_id) . ')';
-        } else {
-            // 一致させない
-            $where .= ' AND 0<>0';
-        }
-
+        $objProduct = new SC_Product();
+        $objQuery =& SC_Query::getSingletonInstance();
         // 表示順序
         switch ($this->orderby) {
-
-            // 販売価格順
+            // 販売価格が安い順
             case 'price':
-                $order = "price02_min, product_id";
+                $objProduct->setProductsOrder('price02', 'dtb_products_class', 'ASC');
                 break;
 
             // 新着順
             case 'date':
-                $order = "create_date DESC, product_id";
+                $objProduct->setProductsOrder('create_date', 'dtb_products', 'DESC');
                 break;
 
@@ -439 +421 @@
                     ,product_id
 __EOS__;
+                    $objQuery->setOrder($order);
                 break;
         }
-
         // 取得範囲の指定(開始行番号、行数のセット)
+        $objQuery->setLimitOffset($this->disp_number, $startno)
+                 ->setWhere($where);
+
+         // 表示すべきIDとそのIDの並び順を一気に取得
+        $arrProduct_id = $objProduct->findProductIdsOrder($objQuery, array_merge($arrval, $arrval_order));
+
+        // 取得した表示すべきIDだけを指定して情報を取得。
+        $where = "";
+        if (is_array($arrProduct_id) && !empty($arrProduct_id)) {
+            $where = 'product_id IN (' . implode(',', $arrProduct_id) . ')';
+        } else {
+            // 一致させない
+            $where = '0<>0';
+        }
         $objQuery =& SC_Query::getSingletonInstance();
-        $objQuery->setLimitOffset($this->disp_number, $startno)
-                 ->setOrder($order)
-                 ->setWhere($where);
-
-        // 検索結果の取得
-        $objProduct = new SC_Product();
-        $this->arrProducts = $objProduct->lists($objQuery, $arrval_order);
-
-        $arrProductId = array();
-        // 規格セレクトボックス設定
-        foreach ($this->arrProducts as $product) {
-            $arrProductId[] = $product['product_id'];
+        $objQuery->setWhere($where);
+        $arrProducts = $objProduct->lists($objQuery, $arrProduct_id);
+
+        //取得している並び順で並び替え
+        $arrProducts2 = array();
+        foreach($arrProducts as $item) {
+            $arrProducts2[ $item['product_id'] ] = $item;
+        }
+        $this->arrProducts = array();
+        foreach($arrProduct_id as $product_id) {
+            $this->arrProducts[] = $arrProducts2[$product_id];
         }
 
         // 規格を設定
-        $objProduct->setProductsClassByProductIds($arrProductId);
+        $objProduct->setProductsClassByProductIds($arrProduct_id);
 
         // 規格1クラス名
@@ -480 +475 @@
 
         // 商品ステータスを取得
-        $this->productStatus = $objProduct->getProductStatus($arrProductId);
+        $this->productStatus = $objProduct->getProductStatus($arrProduct_id);
 
         $productsClassCategories = $objProduct->classCategories;