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

Revision 20368, 32.9 KB checked in by adachi, 11 years ago (diff)

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

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