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

Revision 19805, 34.1 KB checked in by Seasoft, 13 years ago (diff)

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