Changeset 19742 for branches/version-2_5-dev/data/class/helper/SC_Helper_CSV.php

Timestamp:

2010/12/18 20:04:49 (12 years ago)

Author:

AMUAMU

Message:

#657 (CSVダウンロードの改善） のうち商品CSVダウンロードの修正。
#781 (規格のデータベースを木構造に) の影響により機能していなかった商品ＣＳＶダウンロード機能の修正。
#823 (商品種別によってカートを分ける) や #792 (ダウンロード販売機能) による影響部分も修正。

File:

• branches/version-2_5-dev/data/class/helper/SC_Helper_CSV.php (modified) (3 diffs)

branches/version-2_5-dev/data/class/helper/SC_Helper_CSV.php

@@ -120 +120 @@
         $data = $objCSV->lfGetCSV("dtb_order", $where, $option, $arrval, $arrCsvOutputCols, $arrCsvOutputConvs);
     }
+    
+    //  CSV作成 コールバック関数
+    function cbOutputProductCSV($data) {
+        $line = $this->sfArrayToCSV($data);
+        $line = mb_convert_encoding($line, 'SJIS-Win');
+        $line .= "\r\n";
+        fwrite($this->fpOutput, $line);
+        return true;
+    }
 
     // CSVを送信する。(商品)
-    function sfDownloadProductsCsv($where, $arrval, $order) {
+    function sfDownloadProductsCsv($where, $arrval, $order, $is_download = false) {
 
         // CSV出力タイトル行の作成
@@ -131 +140 @@
         $objQuery = new SC_Query();
         $objQuery->setOrder($order);
-
-        /*
-         * FIXME
-         * パフォーマンスが出ないため,
-         * SC_Product::getProductsClassByProductIds() を使用した実装に変更
-         */
-        $dataRows = $objQuery->select(
-             SC_Utils_Ex::sfGetCommaList($arrOutputCols, true, array('category_id'))
-            ,'vw_product_class AS prdcls'
-            ,$where
-            ,$arrval
-        );
-        
-        // 規格分類名一覧
-        if (in_array('classcategory_id1', $arrOutputCols) || in_array('classcategory_id2', $arrOutputCols)) {
-            $objDb = new SC_Helper_DB_Ex();
-            $arrClassCatName = $objDb->sfGetIDValueList("dtb_classcategory", "classcategory_id", "name");
-        }
-
-        $outputArray = array();
-        
-        // ヘッダ行
-        $outputArray[] = $arrOutput['disp_name'];
-        
-        $objQuery = new SC_Query();
-        // データ行
-        foreach ($dataRows as $row) {
-            // 規格名1
-            if (in_array('classcategory_id1', $arrOutputCols)) {
-                $row['classcategory_id1'] = $arrClassCatName[$row['classcategory_id1']];
-            }
-
-            // 規格名2
-            if (in_array('classcategory_id2', $arrOutputCols)) {
-                $row['classcategory_id2'] = $arrClassCatName[$row['classcategory_id2']];
-            }
-
-            // カテゴリID
-            if (in_array('category_id', $arrOutputCols)) {
-                $row['category_id'] = $objQuery->getCol(
-                    "category_id",
-                    "dtb_product_categories",
-                    "product_id = ?",
-                    array($row['product_id'])
-                );
-            }
-
-            $outputArray[] = $row;
-        }
-        
-        // CSVを送信する。
-        #$this->lfDownloadCsv($outputArray);
-        return $this->lfGetCsv2($outputArray);
-        
-        // 成功終了
-        #return true;
+        
+        $objProduct = new SC_Product();
+        $cols = SC_Utils_Ex::sfGetCommaList($arrOutputCols, true);
+        $sql = $objQuery->getSql($cols, $objProduct->prdclsSQL(),$where);
+        $header = $this->sfArrayToCSV($arrOutput['disp_name']);
+        $header = mb_convert_encoding($header, 'SJIS-Win');
+        $header .= "\r\n";
+        
+        //テンポラリファイル作成
+        // TODO: パフォーマンス向上には、ストリームを使うようにすると良い
+        //  環境要件がバージョン5.1以上になったら使うように変えても良いかと
+        //  fopen('php://temp/maxmemory:'. (5*1024*1024), 'r+');
+        $tmp_filename = tempnam(CSV_TEMP_DIR, 'product_csv');
+        $this->fpOutput = fopen($tmp_filename, "w+");
+
+        fwrite($this->fpOutput, $header);
+
+        $objQuery->doCallbackAll(array(&$this, 'cbOutputProductCSV'), $sql, $arrval);
+
+        fclose($this->fpOutput);
+
+        if($is_download) {
+            // CSVを送信する。
+            $this->lfDownloadCSVFile($tmp_filename,"product_");
+            $res = true;
+        }else{
+            $res = SC_Utils_Ex::sfReadFile($tmp_filename);
+        }
+        
+        //テンポラリファイル削除
+        unlink($tmp_filename);
+        return $res;
     }
 
@@ -498 +483 @@
         }
     }
+    
+    /**
+     * CSVファイルを送信する。
+     */
+    function lfDownloadCSVFile($filepath, $prefix = "") {
+        $file_name = $prefix . date("YmdHis") . ".csv";
+        
+        /* HTTPヘッダの出力 */
+        Header("Content-disposition: attachment; filename=${file_name}");
+        Header("Content-type: application/octet-stream; name=${file_name}");
+        Header("Cache-Control: ");
+        Header("Pragma: ");
+        
+        /* データを出力 */
+        // file_get_contentsはメモリマッピングも自動的に使ってくれるので高速＆省メモリ
+        echo file_get_contents($filepath);
+    }
 
     /**