Changeset 19037

Timestamp:

2010/11/06 21:30:13 (13 years ago)

Author:

AMUAMU

Message:

sfCategory_Countの高速化の試作

File:

• branches/camp/camp-2_5-D/data/class/helper/SC_Helper_DB.php (modified) (2 diffs)

branches/camp/camp-2_5-D/data/class/helper/SC_Helper_DB.php

@@ -897 +897 @@
     /**
      * カテゴリ数の登録を行う.
+     * 
      *
      * @param SC_Query $objQuery SC_Query インスタンス
      * @return void
      */
-    function sfCategory_Count($objQuery){
+    function sfCategory_Count($objQuery = NULL){
+        $objProduct = new SC_Product();
+        
+        if($objQuery == NULL) {
+                $objQuery =& SC_Query::getSingletonInstance();
+        }
+        $is_out_tarns = false;
+        //トランザクションの開始確認。開始していない場合は
+        if(!$objQuery->inTransaction()){
+            //TODO: トランザクション制御を足す？ (重い！）
+            //$objQuery->begin();
+            $is_out_trans = false;
+        }
+
+        //共通のfrom/where文の構築
+        $sql_where = 'alldtl.del_flg = 0 AND alldtl.status = 1';
+        // 在庫無し商品の非表示
+        if (NOSTOCK_HIDDEN === true) {
+            $sql_where_dtl = 'stock_max >= 1 OR stock_unlimited_max = 1';
+            $from = $objProduct->alldtlSQL($sql_where_dtl);
+        }else{
+            $from = " dtb_products as alldtl ";
+        }
+        
+        //dtb_category_countの構成
+        // 各カテゴリに所属する商品の数を集計。集計対象には子カテゴリを含まない。
+        // 2.5で消える予定だったが復活させます。
+        
+        //まずテーブル内容の元を取得
+        $arrCategoryCountOld = $objQuery->select('category_id,product_count','dtb_category_count');
 
         //テーブル内容の削除
         $objQuery->query("DELETE FROM dtb_category_count");
-        $objQuery->query("DELETE FROM dtb_category_total_count");
-
-        $sql_where .= 'alldtl.del_flg = 0 AND alldtl.status = 1';
-        // 在庫無し商品の非表示
-        if (NOSTOCK_HIDDEN === true) {
-            $sql_where .= ' AND (alldtl.stock_max >= 1 OR alldtl.stock_unlimited_max = 1)';
-        }
-
-        //子カテゴリ内の商品数を集計する
-
-        // カテゴリ情報を取得
-        $arrCat = $objQuery->select('category_id', 'dtb_category');
-
-        $objProduct = new SC_Product();
-
-        foreach ($arrCat as $row) {
-            $category_id = $row['category_id'];
+
+        //各カテゴリ内の商品数を数えて格納
+        // これは単純集計なので比較的軽い
+        $sql = <<< __EOS__
+            INSERT INTO dtb_category_count(category_id, product_count, create_date)
+            SELECT T1.category_id, count(T2.category_id), now()
+            FROM dtb_category AS T1
+                LEFT JOIN dtb_product_categories AS T2
+                    ON T1.category_id = T2.category_id
+                LEFT JOIN $from
+                    ON T2.product_id = alldtl.product_id
+            WHERE $sql_where
+            GROUP BY T1.category_id, T2.category_id
+__EOS__;
+        $objQuery->query($sql);
+                
+        //dtb_category_total_countの構成
+        // 各カテゴリに所属する商品の数を集計。集計対象には子カテゴリを「含む」。        
+        //差分を取得して、更新対象カテゴリだけを確認する。
+        
+        //各カテゴリ毎のデータ値において以前との差を見る
+        $arrCategoryCountNew = $objQuery->select('category_id, product_count','dtb_category_count');
+        
+        //古いデータの構造入れ替え
+        $arrOld = array();
+        foreach($arrCategoryCountOld as $item){
+            $arrOld[$item['category_id']] = $item;
+        }
+        //新しいデータの構造入れ替え
+        $arrNew = array();
+        foreach($arrCategoryCountNew as $item){
+            $arrNew[$item['category_id']] = $item;
+        }
+        $arrDiffCategory_id = array();
+        //新しいカテゴリ一覧から見て商品数が異なるデータが無いか確認
+        foreach($arrCategoryCountNew as $item){
+            $category_id = $item['category_id'];
+            if($arrOld[$category_id]['product_count'] != $item['product_count']){
+                $arrDiffCategory_id[] = $category_id;
+            }
+        }
+        //削除カテゴリを想定して、古いカテゴリ一覧から見て商品数が異なるデータが無いか確認。
+        foreach($arrCategoryCountOld as $item){
+            $category_id = $item['category_id'];
+            if($arrNew[$category_id]['product_count'] != $item['product_count']){
+                $arrDiffCategory_id[] = $category_id;
+            }
+        }
+        
+        //対象IDが無ければ終了
+        if(count($arrDiffCategory_id) == 0){
+            if($is_out_tarns){
+                $objQuery->commit();
+            }
+            return;
+        }
+
+        //差分対象カテゴリIDの重複を除去
+        $arrDiffCategory_id = array_unique($arrDiffCategory_id);
+        //差分があったIDとその親カテゴリIDのリストを取得する
+        $arrTgtCategory_id = array();
+        foreach ($arrDiffCategory_id as $parent_category_id) {
+            $arrTgtCategory_id[] = $parent_category_id;
+            $arrParentID = $this->sfGetParents($objQuery, 'dtb_category', 'parent_category_id', 'category_id', $parent_category_id);
+            foreach($arrParentID as $pid) {
+                $arrTgtCategory_id[] = $pid;
+            }
+        }
+        
+        //重複を取り除く
+        $arrTgtCategory_id = array_unique($arrTgtCategory_id);
+
+        //dtb_cateogry_total_count 集計処理開始
+        //旧データの削除
+        $objQuery->query("DELETE FROM dtb_category_total_count WHERE category_id in (" . implode(',',$arrTgtCategory_id) . ")");
+
+        //カテゴリ毎に処理
+        foreach ($arrTgtCategory_id as $category_id) {
             $arrval = array();
-
             $arrval[] = $category_id;
-
             list($tmp_where, $tmp_arrval) = $this->sfGetCatWhere($category_id);
             if ($tmp_where != "") {
@@ -945 +1034 @@
                WHERE $where
 __EOS__;
-
             $objQuery->query($sql, $arrval);
+        }
+        //トランザクションの終了処理。
+        if($is_out_tarns){
+            $objQuery->commit();
         }
     }