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

Revision 20369, 32.7 KB checked in by adachi, 11 years ago (diff)

#1031 商品CSVアップロードリファクタリング

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