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

Revision 22301, 34.9 KB checked in by undertree, 8 years ago (diff)

#2027 (商品登録CSVの商品更新時、未入力だとシステムエラーになる項目がある)

・CSVからの更新時に、product_class_idの取得を試みるコードを追加

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