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

Revision 20497, 32.7 KB checked in by shutta, 11 years ago (diff)

SC_UploadFileクラスのclass_extends対応。

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