source: branches/version-2_5-dev/data/class/pages/admin/products/LC_Page_Admin_Products_UploadCSV.php @ 20041

Revision 20041, 34.5 KB checked in by eccuore, 13 years ago (diff)

#642(共通ロジックの機能向上) mode 取得用の関数を利用するように修正（switchリファクタリングは未対応）
  • Property svn:eol-style set to LF
  • Property svn:keywords set to Id Revision Date
  • Property svn:mime-type set to text/x-httpd-php; charset=UTF-8
Line 
1<?php
2/*
3 * This file is part of EC-CUBE
4 *
5 * Copyright(c) 2000-2010 LOCKON CO.,LTD. All Rights Reserved.
6 *
7 * http://www.lockon.co.jp/
8 *
9 * This program is free software; you can redistribute it and/or
10 * modify it under the terms of the GNU General Public License
11 * as published by the Free Software Foundation; either version 2
12 * of the License, or (at your option) any later version.
13 *
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
17 * GNU General Public License for more details.
18 *
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
22 */
23
24// {{{ requires
25require_once(CLASS_REALDIR . "pages/admin/LC_Page_Admin.php");
26require_once(CLASS_EX_REALDIR . "helper_extends/SC_Helper_CSV_Ex.php");
27
28/**
29 * 商品登録CSVのページクラス.
30 *
31 * @package Page
32 * @author LOCKON CO.,LTD.
33 * @version $Id:LC_Page_Admin_Products_UploadCSV.php 15532 2007-08-31 14:39:46Z nanasess $
34 *
35 * FIXME 同一商品IDで商品規格違いを登録できない。(更新は可能)
36 */
37class LC_Page_Admin_Products_UploadCSV extends LC_Page_Admin {
38
39    // }}}
40    // {{{ functions
41
42    /** フォームパラメータ */
43    var $objFormParam;
44
45    /** SC_UploadFile インスタンス */
46    var $objUpfile;
47
48    /** TAGエラーチェックフィールド情報 */
49    var $arrTagCheckItem;
50
51    /** 商品テーブルカラム情報 (登録処理用) **/
52    var $arrProductColumn;
53
54    /** 商品規格テーブルカラム情報 (登録処理用) **/
55    var $arrProductClassColumn;
56
57    /** 登録フォームカラム情報 **/
58    var $arrFormKeyList;
59
60    /**
61     * Page を初期化する.
62     *
63     * @return void
64     */
65    function init() {
66        parent::init();
67        $this->tpl_mainpage = 'products/upload_csv.tpl';
68        $this->tpl_subnavi = 'products/subnavi.tpl';
69        $this->tpl_mainno = 'products';
70        $this->tpl_subno = 'upload_csv';
71        $this->tpl_subtitle = '商品登録CSV';
72        $this->csv_id = '1';
73
74        $masterData = new SC_DB_MasterData_Ex();
75        $this->arrDISP = $masterData->getMasterData("mtb_disp");
76        $this->arrSTATUS = $masterData->getMasterData("mtb_status");
77        $this->arrDELIVERYDATE = $masterData->getMasterData("mtb_delivery_date");
78        $this->arrProductType = $masterData->getMasterData("mtb_product_type");
79        $this->arrMaker = SC_Helper_DB_Ex::sfGetIDValueList("dtb_maker", "maker_id", "name");
80        $this->arrPayments = SC_Helper_DB_Ex::sfGetIDValueList("dtb_payment", "payment_id", "payment_method");
81        $this->arrAllowedTag = $masterData->getMasterData("mtb_allowed_tag");
82        $this->arrTagCheckItem = array();
83    }
84
85    /**
86     * Page のプロセス.
87     *
88     * @return void
89     */
90    function process() {
91        $this->action();
92        $this->sendResponse();
93    }
94
95    /**
96     * Page のアクション.
97     *
98     * @return void
99     */
100    function action() {
101        $objSess = new SC_Session();
102        $this->objDb = new SC_Helper_DB_Ex();
103        $objView = new SC_SiteView();
104
105        // 認証可否の判定
106        SC_Utils_Ex::sfIsSuccess($objSess);
107
108        // ファイル管理クラス
109        $this->objUpFile = new SC_UploadFile(IMAGE_TEMP_REALDIR, IMAGE_SAVE_REALDIR);
110        // サイト基本情報 (ポイントレート初期値用)
111        $this->arrInfo = $this->objDb->sfGetBasisData();
112        // CSV管理ヘルパー
113        $this->objCSV = new SC_Helper_CSV();
114        // CSV構造読み込み
115        $arrCSVFrame = $this->objCSV->sfGetCsvOutput($this->csv_id);
116
117        // CSV構造がインポート可能かのチェック
118        if( !$this->objCSV->sfIsImportCSVFrame($arrCSVFrame) ) {
119            // 無効なフォーマットなので初期状態に強制変更
120            $arrCSVFram = $this->objCSV->sfGetCsvOutput($this->csv_id, '', array(), $order ='no');
121            $this->tpl_is_format_default = true;
122        }
123        // CSV構造は更新可能なフォーマットかのフラグ取得
124        $this->tpl_is_update = $this->objCSV->sfIsUpdateCSVFrame($arrCSVFrame);
125
126        // CSVファイルアップロード情報の初期化
127        $this->lfInitFile();
128        // パラメータ管理クラス
129        $this->objFormParam = new SC_FormParam();
130        // パラメータ情報の初期化
131        $this->lfInitParam($arrCSVFrame);
132        // 現在のフォーマットにおける列数を取得
133        $col_count = $this->objFormParam->getCount();
134        $this->objFormParam->setHtmlDispNameArray();
135        $this->arrTitle = $this->objFormParam->getHtmlDispNameArray();
136
137        switch($this->getMode()) {
138        case 'csv_upload':
139            // 登録先テーブル カラム情報の初期化
140            $this->lfInitTableInfo();
141            // 登録フォーム カラム情報
142            $this->arrFormKeyList = $this->objFormParam->getKeyList();
143
144            $err = false;
145            // CSVファイルアップロード エラーチェック
146            $arrErr['csv_file'] = $this->objUpFile->makeTempFile('csv_file');
147
148            if($arrErr['csv_file'] == "") {
149                $arrErr = $this->objUpFile->checkEXISTS();
150            }
151
152            $objView->assignobj($this);
153            $objView->display('admin_popup_header.tpl');
154
155            // 実行時間を制限しない
156            set_time_limit(0);
157
158            // 出力をバッファリングしない(==日本語自動変換もしない)
159            ob_end_flush();
160
161            // IEのために256バイト空文字出力
162            echo str_pad('',256);
163
164            if(empty($arrErr['csv_file'])) {
165                // 一時ファイル名の取得
166                $filepath = $this->objUpFile->getTempFilePath('csv_file');
167                // エンコード
168                $enc_filepath = SC_Utils_Ex::sfEncodeFile($filepath,
169                                                          CHAR_CODE, CSV_TEMP_REALDIR);
170                $fp = fopen($enc_filepath, "r");
171
172                // 無効なファイルポインタが渡された場合はエラー表示
173                if ($fp === false) {
174                    SC_Utils_Ex::sfDispError("");
175                }
176
177                // レコード行数を得る
178                $record_count = $this->objCSV->sfGetCSVRecordCount($fp);
179                // ファイルが無効な場合はエラー
180                if($record_count === FALSE) {
181                    SC_Utils_Ex::sfDispError("");
182                }
183
184                $line = 0;      // 現在行数
185                $regist = 0;    // 登録数
186
187                $objQuery =& SC_Query::getSingletonInstance();
188                $objQuery->begin();
189
190                echo "■　CSV登録進捗状況 <br/><br/>\n";
191
192                while(!feof($fp) && !$err) {
193                    $arrCSV = fgetcsv($fp, CSV_LINE_MAX);
194                    // 行カウント
195                    $line++;
196                    if($line <= 1) {
197                        continue;
198                    }
199                    // 現在行の項目数カウント
200                    $line_col_count = count($arrCSV);
201                    // 項目数が1以下の場合は無視する
202                    if($line_col_count <= 1) {
203                        continue;
204                    }
205
206                    // 項目数チェック
207                    if($line_col_count != $col_count) {
208                        echo "※ 項目数が" . $line_col_count . "個検出されました。項目数は" . $col_count . "個になります。</br>\n";
209                        $err = true;
210                    } else {
211                        // シーケンス配列を格納する。
212                        $this->objFormParam->setParam($arrCSV, true);
213                        $arrRet = $this->objFormParam->getHashArray();
214                        $this->objFormParam->setParam($arrRet);
215                        // 入力値の変換
216                        $this->objFormParam->convParam();
217                        // <br>なしでエラー取得する。
218                        $arrCSVErr = $this->lfCheckError();
219                    }
220
221                    // 入力エラーチェック
222                    if(count($arrCSVErr) > 0) {
223                        echo "<font color=\"red\">■ $line / $record_count 行目でエラーが発生しました。</font></br>\n";
224                        foreach($arrCSVErr as $val) {
225                            $this->printError($val);
226                        }
227                        $err = true;
228                    }
229
230                    if(!$err) {
231                        $this->lfRegistProduct($objQuery, $line);
232                        $regist++;
233                    }
234                    $arrParam = $this->objFormParam->getHashArray();
235
236                    if(!$err) echo $line. "行目　（商品ID：".$arrParam['product_id']." / 商品名：".$arrParam['name'].")\n<br />";
237                    flush();
238                }
239                fclose($fp);
240
241                if(!$err) {
242                    $objQuery->commit();
243                    echo "■" . $regist . "件のレコードを登録しました。";
244                    // 商品件数カウント関数の実行
245                    $this->objDb->sfCountCategory($objQuery);
246                    $this->objDb->sfCountMaker($objQuery);
247                } else {
248                    $objQuery->rollback();
249                }
250            } else {
251                foreach($arrErr as $val) {
252                    $this->printError($val);
253                }
254            }
255            echo "<br/><a href=\"javascript:window.close()\">→閉じる</a>";
256            flush();
257
258            $this->setTemplate('admin_popup_footer.tpl');
259
260            return;
261            break;
262        default:
263            break;
264        }
265    }
266
267    /**
268     * デストラクタ.
269     *
270     * @return void
271     */
272    function destroy() {
273        parent::destroy();
274    }
275
276    /**
277     * ファイル情報の初期化を行う.
278     *
279     * @return void
280     */
281    function lfInitFile() {
282        $this->objUpFile->addFile("CSVファイル", 'csv_file', array('csv'),
283                                  CSV_SIZE, true, 0, 0, false);
284    }
285
286    /**
287     * 入力情報の初期化を行う.
288     *
289     * @param array CSV構造設定配列
290     * @return void
291     */
292    function lfInitParam(&$arrCSVFrame) {
293        // 固有の初期値調整
294        $arrCSVFrame = $this->lfSetParamDefaultValue($arrCSVFrame);
295        // CSV項目毎の処理
296        foreach($arrCSVFrame as $item) {
297            if($item['status'] == CSV_COLUMN_STATUS_FLG_DISABLE) continue;
298            //サブクエリ構造の場合は AS名 を使用
299            if(preg_match_all('/\(.+\) as (.+)$/i', $item['col'], $match, PREG_SET_ORDER)) {
300                $col = $match[0][1];
301            }else{
302                $col = $item['col'];
303            }
304            // HTML_TAG_CHECKは別途実行なので除去し、別保存しておく
305            if(stripos($item['error_check_types'], 'HTML_TAG_CHECK') !== FALSE) {
306                $this->arrTagCheckItem[] = $item;
307                $error_check_types = str_replace('HTML_TAG_CHECK', '', $item['error_check_types']);
308            }else{
309                $error_check_types = $item['error_check_types'];
310            }
311            $arrErrorCheckTypes = explode(',', $error_check_types);
312            foreach($arrErrorCheckTypes as $key => $val) {
313                if(trim($val) == "") {
314                    unset($arrErrorCheckTypes[$key]);
315                }else{
316                    $arrErrorCheckTypes[$key] = trim($val);
317                }
318            }
319            // パラメーター登録
320            $this->objFormParam->addParam(
321                    $item['disp_name']
322                    , $col
323                    , constant($item['size_const_type'])
324                    , $item['mb_convert_kana_option']
325                    , $arrErrorCheckTypes
326                    , $item['default']
327                    , ($item['rw_flg'] != CSV_COLUMN_RW_FLG_READ_ONLY) ? true : false
328                    );
329        }
330    }
331
332    /**
333     * 入力チェックを行う.
334     *
335     * @return void
336     */
337    function lfCheckError() {
338        // 入力データを渡す。
339        $arrRet =  $this->objFormParam->getHashArray();
340        $objErr = new SC_CheckError($arrRet);
341        $objErr->arrErr = $this->objFormParam->checkError(false);
342        // HTMLタグチェックの実行
343        foreach($this->arrTagCheckItem as $item) {
344            $objErr->doFunc(array( $item['disp_name'], $item['col'], $this->arrAllowedTag), array("HTML_TAG_CHECK"));
345        }
346        // このフォーム特有の複雑系のエラーチェックを行う
347        if(count($objErr->arrErr) == 0) {
348            $objErr->arrErr = $this->lfCheckErrorDetail($arrRet, $objErr->arrErr);
349        }
350        return $objErr->arrErr;
351    }
352
353    /**
354     * 保存先テーブル情報の初期化を行う.
355     *
356     * @return void
357     */
358    function lfInitTableInfo() {
359        $objQuery =& SC_Query::getSingletonInstance();
360        $this->arrProductColumn = $objQuery->listTableFields('dtb_products');
361        $this->arrProductClassColumn = $objQuery->listTableFields('dtb_products_class');
362    }
363
364    /**
365     * 商品登録を行う.
366     *
367     * FIXME: 商品登録の実処理自体は、LC_Page_Admin_Products_Productと共通化して欲しい。
368     *
369     * @param SC_Query $objQuery SC_Queryインスタンス
370     * @param string|integer $line 処理中の行数
371     * @return void
372     */
373    function lfRegistProduct($objQuery, $line = "") {
374        $objProduct = new SC_Product();
375        // 登録データ対象取得
376        $arrList = $this->objFormParam->getHashArray();
377        // 登録時間を生成(DBのnow()だとcommitした際、すべて同一の時間になってしまう)
378        $arrList['update_date'] = $this->lfGetDbFormatTimeWithLine($line);
379
380        // 商品登録情報を生成する。
381        // 商品テーブルのカラムに存在しているもののうち、Form投入設定されていないデータは上書きしない。
382        $sqlval = SC_Utils_Ex::sfArrayIntersectKeys($arrList, $this->arrProductColumn);
383
384        // 必須入力では無い項目だが、空文字では問題のある特殊なカラム値の初期値設定
385        $sqlval = $this->lfSetProductDefaultData($sqlval);
386
387        if($sqlval['product_id'] != "") {
388            // UPDATEの実行
389            $where = "product_id = ?";
390            $objQuery->update("dtb_products", $sqlval, $where, array($sqlval['product_id']));
391            $product_id = $sqlval['product_id'];
392        } else {
393            // 新規登録
394            $sqlval['product_id'] = $objQuery->nextVal('dtb_products_product_id');
395            $product_id = $sqlval['product_id'];
396            $sqlval['create_date'] = $arrList['update_date'];
397            // INSERTの実行
398            $objQuery->insert("dtb_products", $sqlval);
399        }
400
401        // カテゴリ登録
402        if($arrList['category_ids'] != "") {
403            $arrCategory_id = explode(',', $arrList['category_ids']);
404            $this->objDb->updateProductCategories($arrCategory_id, $product_id);
405        }
406        // ステータス登録
407        if($arrList['product_statuses'] != "") {
408            $arrStatus_id = explode(',', $arrList['product_statuses']);
409            $objProduct->setProductStatus($product_id, $arrStatus_id);
410        }
411
412        // 商品規格情報を登録する
413        $this->lfRegistProductClass($objQuery, $arrList, $product_id, $arrList['product_class_id']);
414
415        // 関連商品登録
416        $this->lfRegistReccomendProducts($objQuery, $arrList, $product_id);
417    }
418
419    /**
420     * 商品規格登録を行う.
421     *
422     * FIXME: 商品規格登録の実処理自体は、LC_Page_Admin_Products_Productと共通化して欲しい。
423     *
424     * @param SC_Query $objQuery SC_Queryインスタンス
425     * @param array $arrList 商品規格情報配列
426     * @param integer $product_id 商品ID
427     * @param integer $product_class_id 商品規格ID
428     * @return void
429     */
430    function lfRegistProductClass($objQuery, $arrList, $product_id, $product_class_id) {
431        $objProduct = new SC_Product();
432        // 商品規格登録情報を生成する。
433        // 商品規格テーブルのカラムに存在しているもののうち、Form投入設定されていないデータは上書きしない。
434        $sqlval = SC_Utils_Ex::sfArrayIntersectKeys($arrList, $this->arrProductClassColumn);
435        // 必須入力では無い項目だが、空文字では問題のある特殊なカラム値の初期値設定
436        $sqlval = $this->lfSetProductClassDefaultData($sqlval);
437
438        if($product_class_id == "") {
439            // 新規登録
440            $sqlval['product_id'] = $product_id;
441            $sqlval['product_class_id'] = $objQuery->nextVal('dtb_products_class_product_class_id');
442            $sqlval['create_date'] = $arrList['update_date'];
443            // INSERTの実行
444            $objQuery->insert("dtb_products_class", $sqlval);
445            $product_class_id = $sqlval['product_class_id'];
446        } else {
447            // UPDATEの実行
448            $where = "product_class_id = ?";
449            $objQuery->update("dtb_products_class", $sqlval, $where, array($product_class_id));
450        }
451        // 支払い方法登録
452        if($arrList['product_payment_ids'] != "") {
453            $arrPayment_id = explode(',', $arrList['product_payment_ids']);
454            $objProduct->setPaymentOptions($product_class_id, $arrPayment_id);
455        }
456    }
457
458    /**
459     * 関連商品登録を行う.
460     *
461     * FIXME: 商品規格登録の実処理自体は、LC_Page_Admin_Products_Productと共通化して欲しい。
462     *        DELETE/INSERT ではなく UPDATEへの変更も・・・
463     *
464     * @param SC_Query $objQuery SC_Queryインスタンス
465     * @param array $arrList 商品規格情報配列
466     * @param integer $product_id 商品ID
467     * @return void
468     */
469    function lfRegistReccomendProducts($objQuery, $arrList, $product_id) {
470        $objQuery->delete("dtb_recommend_products", "product_id = ?", array($product_id));
471        for($i = 1; $i <= RECOMMEND_PRODUCT_MAX; $i++) {
472            $keyname = "recommend_product_id" . $i;
473            $comment_key = "recommend_comment" . $i;
474            if($arrList[$keyname] != "") {
475                $arrProduct = $objQuery->select("product_id", "dtb_products", "product_id = ?", array($arrList[$keyname]));
476                if($arrProduct[0]['product_id'] != "") {
477                    $arrval['product_id'] = $product_id;
478                    $arrval['recommend_product_id'] = $arrProduct[0]['product_id'];
479                    $arrval['comment'] = $arrList[$comment_key];
480                    $arrval['update_date'] = $arrList['update_date'];
481                    $arrval['create_date'] = $arrList['update_date'];
482                    $arrval['creator_id'] = $_SESSION['member_id'];
483                    $arrval['rank'] = RECOMMEND_PRODUCT_MAX - $i + 1;
484                    $objQuery->insert("dtb_recommend_products", $arrval);
485                }
486            }
487        }
488    }
489
490    /**
491     * 初期値の設定
492     *
493     * @param array $arrCSVFrame CSV構造配列
494     * @return array $arrCSVFrame CSV構造配列
495     */
496    function lfSetParamDefaultValue(&$arrCSVFrame) {
497        foreach($arrCSVFrame as $key => $val) {
498            switch($val['col']) {
499                case 'status':
500                    $arrCSVFrame[$key]['default'] = DEFAULT_PRODUCT_DISP;
501                    break;
502                case 'del_flg':
503                    $arrCSVFrame[$key]['default'] = '0';
504                    break;
505                case 'point_rate':
506                    $arrCSVFrame[$key]['default'] = $this->arrInfo['point_rate'];
507                    break;
508                case 'product_type_id':
509                    $arrCSVFrame[$key]['default'] = DEFAULT_PRODUCT_DOWN;
510                    break;
511                case 'product_payment_ids':
512                    $arrCSVFrame[$key]['default'] = implode(',',array_keys($this->arrPayments));
513                    break;
514                case 'stock_unlimited':
515                    $arrCSVFrame[$key]['default'] = UNLIMITED_FLG_LIMITED;
516                default:
517                    break;
518            }
519        }
520        return $arrCSVFrame;
521    }
522
523    /**
524     * 商品データ登録前に特殊な値の持ち方をする部分のデータ部分の初期値補正を行う
525     *
526     * @param array $sqlval 商品登録情報配列
527     * @return $sqlval 登録情報配列
528     */
529    function lfSetProductDefaultData(&$sqlval) {
530        //新規登録時のみ設定する項目
531        if( $sqlval['product_id'] == "") {
532            if($sqlval['status'] == "") {
533                $sqlval['status'] = DEFAULT_PRODUCT_DISP;
534            }
535        }
536        //共通で空欄時に上書きする項目
537        if($sqlval['del_flg'] == ""){
538            $sqlval['del_flg'] = '0'; //有効
539        }
540        if($sqlval['creator_id'] == "") {
541            $sqlval['creator_id'] = $_SESSION['member_id'];
542        }
543        return $sqlval;
544    }
545
546    /**
547     * 商品規格データ登録前に特殊な値の持ち方をする部分のデータ部分の初期値補正を行う
548     *
549     * @param array $sqlval 商品登録情報配列
550     * @return $sqlval 登録情報配列
551     */
552    function lfSetProductClassDefaultData(&$sqlval) {
553        //新規登録時のみ設定する項目
554        if($sqlval['product_class_id'] == "") {
555            if($sqlval['point_rate'] == "") {
556                $sqlval['point_rate'] = $this->arrInfo['point_rate'];
557            }
558            if($sqlval['product_type_id'] == "") {
559                $sqlval['product_type_id'] = DEFAULT_PRODUCT_DOWN;
560            }
561            // TODO: 在庫数、無制限フラグの扱いについて仕様がぶれているので要調整
562            if($sqlval['stock'] == "" and $sqlval['stock_unlimited'] != UNLIMITED_FLG_UNLIMITED) {
563                //在庫数設定がされておらず、かつ無制限フラグが設定されていない場合、強制無制限
564                $sqlval['stock_unlimited'] = UNLIMITED_FLG_UNLIMITED;
565            }elseif($sqlval['stock'] != "" and $sqlval['stock_unlimited'] != UNLIMITED_FLG_UNLIMITED) {
566                //在庫数設定時は在庫無制限フラグをクリア
567                $sqlval['stock_unlimited'] = UNLIMITED_FLG_LIMITED;
568            }elseif($sqlval['stock'] != "" and $sqlval['stock_unlimited'] == UNLIMITED_FLG_UNLIMITED) {
569                //在庫無制限フラグ設定時は在庫数をクリア
570                $sqlval['stock'] = '';
571            }
572        }else{
573            //更新時のみ設定する項目
574            if(array_key_exists('stock_unlimited', $sqlval) and $sqlval['stock_unlimited'] == UNLIMITED_FLG_UNLIMITED) {
575                $sqlval['stock'] = '';
576            }
577        }
578        //共通で設定する項目
579        if($sqlval['del_flg'] == ""){
580            $sqlval['del_flg'] = '0'; //有効
581        }
582        if($sqlval['creator_id'] == "") {
583            $sqlval['creator_id'] = $_SESSION['member_id'];
584        }
585        return $sqlval;
586    }
587
588    /**
589     * このフォーム特有の複雑な入力チェックを行う.
590     *
591     * @param array 確認対象データ
592     * @param array エラー配列
593     * @return array エラー配列
594     */
595    function lfCheckErrorDetail($item, $arrErr) {
596        // 商品IDの存在チェック
597        if(!$this->lfIsDbRecord('dtb_products', 'product_id', $item)) {
598            $arrErr['product_id'] = "※ 指定の商品IDは、登録されていません。";
599        }
600        // 規格IDの存在チェック
601        if(!$this->lfIsDbRecord('dtb_products_class', 'product_class_id', $item)) {
602            $arrErr['product_class_id'] = "※ 指定の商品規格IDは、登録されていません。";
603        }
604        // 商品ID、規格IDの組合せチェック
605        if(array_search('product_class_id', $this->arrFormKeyList) !== FALSE
606                and $item['product_class_id'] != "") {
607            if($item['product_id'] == "") {
608                $arrErr['product_class_id'] = "※ 商品規格ID指定時には商品IDの指定が必須です。";
609            }else{
610                if(!$this->objDb->sfIsRecord('dtb_products_class', 'product_id, product_class_id'
611                        , array($item['product_id'], $item['product_class_id']))) {
612                    $arrErr['product_class_id'] = "※ 指定の商品IDと商品規格IDの組合せは正しくありません。";
613                }
614            }
615        }
616        // 規格組合せIDの存在チェック
617//        if(!$this->lfIsDbRecord('dtb_class_combination', 'class_combination_id', $item)) {
618//      SC_Utils::sfIsRecord が del_flg が無いと使えない為、個別処理
619        if(array_search('class_combination_id', $this->arrFormKeyList) !== FALSE
620                and $item['class_combination_id'] != "" ) {
621            $objQuery =& SC_Query::getSingletonInstance();
622            $ret = $objQuery->get('class_combination_id', 'dtb_class_combination', 'class_combination_id = ?', array($item['class_combination_id']));
623            if($ret == "") {
624                $arrErr['class_combination_id'] = "※ 指定の規格組合せIDは、登録されていません。";
625            }
626        }
627        // 表示ステータスの存在チェック
628        if(!$this->lfIsArrayRecord($this->arrDISP, 'status', $item)) {
629            $arrErr['status'] = "※ 指定の表示ステータスは、登録されていません。";
630        }
631        // メーカーIDの存在チェック
632        if(!$this->lfIsArrayRecord($this->arrMaker, 'maker_id', $item)) {
633            $arrErr['maker_id'] = "※ 指定のメーカーIDは、登録されていません。";
634        }
635        // 発送日目安IDの存在チェック
636        if(!$this->lfIsArrayRecord($this->arrDELIVERYDATE, 'deliv_date_id', $item)) {
637            $arrErr['deliv_date_id'] = "※ 指定の発送日目安IDは、登録されていません。";
638        }
639        // 発送日目安IDの存在チェック
640        if(!$this->lfIsArrayRecord($this->arrProductType, 'product_type_id', $item)) {
641            $arrErr['product_type_id'] = "※ 指定の商品種別IDは、登録されていません。";
642        }
643        // 関連商品IDの存在チェック
644        for($i = 1; $i <= RECOMMEND_PRODUCT_MAX; $i++) {
645            if(array_search('recommend_product_id' . $i, $this->arrFormKeyList) !== FALSE
646                    and $item['recommend_product_id' . $i] != ""
647                    and !$this->objDb->sfIsRecord('dtb_products', 'product_id', (array)$item['recommend_product_id' . $i]) ) {
648                $arrErr['recommend_product_id' . $i] = "※ 指定の関連商品ID($i)は、登録されていません。";
649            }
650        }
651        // カテゴリIDの存在チェック
652        if(!$this->lfIsDbRecordMulti('dtb_category', 'category_id', 'category_ids', $item, ',')) {
653            $arrErr['category_ids'] = "※ 指定のカテゴリIDは、登録されていません。";
654        }
655        // ステータスIDの存在チェック
656        if(!$this->lfIsArrayRecordMulti($this->arrSTATUS, 'product_statuses', $item, ',')) {
657            $arrErr['product_statuses'] = "※ 指定のステータスIDは、登録されていません。";
658        }
659        // 支払い方法IDの存在チェック
660        if(!$this->lfIsArrayRecordMulti($this->arrPayments, 'product_payment_ids', $item, ',')) {
661            $arrErr['product_payment_ids'] = "※ 指定の支払い方法IDは、登録されていません。";
662        }
663        // 削除フラグのチェック
664        if(array_search('del_flg', $this->arrFormKeyList) !== FALSE
665                and $item['del_flg'] != "") {
666            if(!($item['del_flg'] == "0" or $item['del_flg'] == "1")) {
667                $arrErr['del_flg'] = "※ 削除フラグは「0」(有効)、「1」(削除)のみが有効な値です。";
668            }
669        }
670/*
671    TODO: 在庫数の扱いが2.4仕様ではぶれているのでどうするか・・
672        // 在庫数/在庫無制限フラグの有効性に関するチェック
673        if($item['stock'] == "") {
674            if(array_search('stock_unlimited', $this->arrFormKeyList) === FALSE) {
675                $arrErr['stock'] = "※ 在庫数は必須です（無制限フラグ項目がある場合のみ空欄許可）。";
676            }else if($item['stock_unlimited'] != UNLIMITED_FLG_UNLIMITED) {
677                $arrErr['stock'] = "※ 在庫数または在庫無制限フラグのいずれかの入力が必須です。";
678            }
679        }
680*/
681        // ダウンロード商品チェック
682        if(array_search('product_type_id', $this->arrFormKeyList) !== FALSE
683                 and $item['product_type_id'] == PRODUCT_TYPE_NORMAL) {
684            //実商品の場合
685            if( $item['down_filename'] != "") {
686                $arrErr['down_filename'] = "※ 実商品の場合はダウンロードファイル名は入力できません。";
687            }
688            if( $item['down_realfilename'] != "") {
689                $arrErr['down_realfilename'] = "※ 実商品の場合はダウンロード商品用ファイルアップロードは入力できません。";
690            }
691        }elseif(array_search('product_type_id', $this->arrFormKeyList) !== FALSE
692                and $item['product_type_id'] == PRODUCT_TYPE_DOWNLOAD) {
693            //ダウンロード商品の場合
694            if( $item['down_filename'] == "") {
695                $arrErr['down_filename'] = "※ ダウンロード商品の場合はダウンロードファイル名は必須です。";
696            }
697            if( $item['down_realfilename'] == "") {
698                $arrErr['down_realfilename'] = "※ ダウンロード商品の場合はダウンロード商品用ファイルアップロードは必須です。";
699            }
700        }
701        return $arrErr;
702    }
703
704    // TODO: ここから下のルーチンは汎用ルーチンとして移動が望ましい
705
706    /**
707     * 指定された行番号をmicrotimeに付与してDB保存用の時間を生成する。
708     * トランザクション内のnow()は全てcommit()時の時間に統一されてしまう為。
709     *
710     * @param string $line_no 行番号
711     * @return string $time DB保存用の時間文字列
712     */
713    function lfGetDbFormatTimeWithLine($line_no = '') {
714        $time = date("Y-m-d H:i:s");
715        // 秒以下を生成
716        if($line != '') {
717            $microtime = sprintf("%06d", $line_no);
718            $time .= ".$microtime";
719        }
720        return $time;
721    }
722
723    /**
724     * 指定されたキーと複数値の有効性の配列内確認
725     *
726     * @param string $arr チェック対象配列
727     * @param string $keyname フォームキー名
728     * @param array  $item 入力データ配列
729     * @param string $delimiter 分割文字
730     * @return boolean true:有効なデータがある false:有効ではない
731     */
732    function lfIsArrayRecordMulti($arr, $keyname, $item, $delimiter = ',') {
733        if(array_search($keyname, $this->arrFormKeyList) === FALSE) {
734            return true;
735        }
736        if($item[$keyname] == "") {
737            return true;
738        }
739        $arrItems = explode($delimiter, $item[$keyname]);
740        //空項目のチェック 1つでも空指定があったら不正とする。
741        if(array_search("", $arrItems) !== FALSE) {
742            return false;
743        }
744        //キー項目への存在チェック
745        foreach($arrItems as $item) {
746            if(!array_key_exists($item, $arr)) {
747                return false;
748            }
749        }
750        return true;
751    }
752
753    /**
754     * 指定されたキーと複数値の有効性のDB確認
755     *
756     * @param string $table テーブル名
757     * @param string $tblkey テーブルキー名
758     * @param string $keyname フォームキー名
759     * @param array  $item 入力データ配列
760     * @param string $delimiter 分割文字
761     * @return boolean true:有効なデータがある false:有効ではない
762     */
763    function lfIsDbRecordMulti($table, $tblkey, $keyname, $item, $delimiter = ',') {
764        if(array_search($keyname, $this->arrFormKeyList) === FALSE) {
765            return true;
766        }
767        if($item[$keyname] == "") {
768            return true;
769        }
770        $arrItems = explode($delimiter, $item[$keyname]);
771        //空項目のチェック 1つでも空指定があったら不正とする。
772        if(array_search("", $arrItems) !== FALSE) {
773            return false;
774        }
775        $count = count($arrItems);
776        $where = $tblkey ." IN (" . implode(",", array_fill(0, $count, "?")) . ")";
777
778        $objQuery =& SC_Query::getSingletonInstance();
779        $db_count = $objQuery->count($table, $where, $arrItems);
780        if($count != $db_count) {
781            return false;
782        }
783        return true;
784    }
785
786    /**
787     * 指定されたキーと値の有効性のDB確認
788     *
789     * @param string $table テーブル名
790     * @param string $keyname キー名
791     * @param array  $item 入力データ配列
792     * @return boolean true:有効なデータがある false:有効ではない
793     */
794    function lfIsDbRecord($table, $keyname, $item) {
795        if(array_search($keyname, $this->arrFormKeyList) !== FALSE  //入力対象である
796                and $item[$keyname] != ""   // 空ではない
797                and !$this->objDb->sfIsRecord($table, $keyname, (array)$item[$keyname]) //DBに存在するか
798                ) {
799            return false;
800        }
801        return true;
802    }
803
804    /**
805     * 指定されたキーと値の有効性の配列内確認
806     *
807     * @param string $arr チェック対象配列
808     * @param string $keyname キー名
809     * @param array  $item 入力データ配列
810     * @return boolean true:有効なデータがある false:有効ではない
811     */
812    function lfIsArrayRecord($arr, $keyname, $item) {
813        if(array_search($keyname, $this->arrFormKeyList) !== FALSE //入力対象である
814                and $item[$keyname] != "" // 空ではない
815                and !array_key_exists($item[$keyname], $arr) //配列に存在するか
816                ) {
817            return false;
818        }
819        return true;
820    }
821
822    /**
823     * 引数の文字列をエラー出力する.
824     *
825     * 引数 $val の内容は, htmlspecialchars() によってサニタイズされる
826     *
827     * @param string $val 出力する文字列
828     * @return void
829     */
830    function printError($val) {
831         echo "<font color=\"red\">"
832             . htmlspecialchars($val, ENT_QUOTES)
833             . "</font><br />\n";
834    }
835}
836?>
Note: See TracBrowser for help on using the repository browser.