source: branches/feature-module-update/html/admin/develop/csv.php @ 15078

Revision 15078, 7.9 KB checked in by nanasess, 17 years ago (diff)

r15064 から svn cp
とりあえず暫定コミット.

  • UTF-8 に変更
  • slib.php, glib.php のクラス化
  • LC_Page の抽象化(一部)
Line 
1<?php
2/*
3 * Copyright(c) 2000-2007 LOCKON CO.,LTD. All Rights Reserved.
4 *
5 * http://www.lockon.co.jp/
6 */
7require_once("../require.php");
8
9$conn = new SC_DBConn();
10$objView = new SC_AdminView();
11$objSess = new SC_Session();
12
13// パラメータ管理クラス
14$objFormParam = new SC_FormParam();
15// パラメータ情報の初期化
16lfInitParam();
17$colmax = $objFormParam->getCount();
18
19// 一時ファイル名の取得
20$filepath = $argv[1];
21
22if(!file_exists($filepath)) {
23    fwrite(STDOUT, "no file exists.\n");
24    exit;
25}
26
27// エンコード
28$enc_filepath = sfEncodeFile($filepath, CHAR_CODE, CSV_TEMP_DIR);
29
30$total = 0;
31
32for($i = 0; $i < 1500; $i++) {
33    $ret = lfRegistCSV($enc_filepath, $colmax, $total);
34    $total+= $ret;
35}
36
37fwrite(STDOUT, "■" . $total . "件のレコードを登録しました。\n");
38
39//--------------------------------------------------------------------------------------------------------------------------
40
41/* ファイル情報の初期化 */
42function lfInitFile() {
43    global $objUpFile;
44    $objUpFile->addFile("CSVファイル", 'csv_file', array('csv'), CSV_SIZE, true, 0, 0, false);
45}
46
47/* パラメータ情報の初期化 */
48function lfInitParam() {
49    global $objFormParam;
50   
51    $objFormParam->addParam("商品名", "name", MTEXT_LEN, "KVa", array("EXIST_CHECK","SPTAB_CHECK","MAX_LENGTH_CHECK"));
52    $objFormParam->addParam("カテゴリID", "category_id", INT_LEN, "n", array("EXIST_CHECK","MAX_LENGTH_CHECK","NUM_CHECK"));
53    $objFormParam->addParam("商品コード", "product_code", STEXT_LEN, "KVa", array("SPTAB_CHECK","MAX_LENGTH_CHECK"));
54    $objFormParam->addParam("商品価格", "price02", PRICE_LEN, "n", array("EXIST_CHECK","MAX_LENGTH_CHECK","NUM_CHECK"));
55    $objFormParam->addParam("商品価格", "price01", PRICE_LEN, "n", array("MAX_LENGTH_CHECK","NUM_CHECK"));
56    $objFormParam->addParam("在庫数", "stock", INT_LEN, "n", array("MAX_LENGTH_CHECK","NUM_CHECK"));
57    $objFormParam->addParam("購入制限", "sale_limit", INT_LEN, "n", array("MAX_LENGTH_CHECK","NUM_CHECK"));
58    $objFormParam->addParam("メーカーURL", "comment1", LTEXT_LEN, "KVa", array("URL_CHECK", "SPTAB_CHECK","MAX_LENGTH_CHECK"));
59    $objFormParam->addParam("商品ステータス", "product_flag", INT_LEN, "n", array("MAX_LENGTH_CHECK","NUM_CHECK"));
60    $objFormParam->addParam("ポイント付与率", "point_rate", PERCENTAGE_LEN, "n", array("EXIST_CHECK","MAX_LENGTH_CHECK","NUM_CHECK"));
61    $objFormParam->addParam("メイン一覧コメント", "main_list_comment", LTEXT_LEN, "KVa", array("EXIST_CHECK","SPTAB_CHECK","MAX_LENGTH_CHECK"));
62    $objFormParam->addParam("メインコメント", "main_comment", LTEXT_LEN, "KVa", array("EXIST_CHECK","SPTAB_CHECK","MAX_LENGTH_CHECK"));
63   
64    for($i = 1; $i <= PRODUCTSUB_MAX; $i++) {
65        $objFormParam->addParam("詳細-サブタイトル($i)", "sub_title$i", LTEXT_LEN, "KVa", array("SPTAB_CHECK","MAX_LENGTH_CHECK"));
66        $objFormParam->addParam("詳細-サブコメント($i)", "sub_comment$i", LTEXT_LEN, "KVa", array("SPTAB_CHECK","MAX_LENGTH_CHECK"));
67        $objFormParam->addParam("詳細-サブ画像($i)", "sub_image$i", LTEXT_LEN, "KVa", array("SPTAB_CHECK","MAX_LENGTH_CHECK","FIND_FILE"));
68        $objFormParam->addParam("詳細-サブ画像拡大($i)", "sub_large_image$i", LTEXT_LEN, "KVa", array("SPTAB_CHECK","MAX_LENGTH_CHECK","FIND_FILE"));
69    }
70       
71    $objFormParam->addParam("メイン一覧画像", "main_list_image", LTEXT_LEN, "KVa", array("EXIST_CHECK","SPTAB_CHECK","MAX_LENGTH_CHECK","FIND_FILE"));
72    $objFormParam->addParam("メイン詳細画像", "main_image", LTEXT_LEN, "KVa", array("EXIST_CHECK","SPTAB_CHECK","MAX_LENGTH_CHECK","FIND_FILE"));
73    $objFormParam->addParam("メイン詳細拡大画像", "main_large_image", LTEXT_LEN, "KVa", array("SPTAB_CHECK","MAX_LENGTH_CHECK","FIND_FILE"));
74    $objFormParam->addParam("比較画像", "file1", LTEXT_LEN, "KVa", array("SPTAB_CHECK","MAX_LENGTH_CHECK","FIND_FILE"));
75    $objFormParam->addParam("商品詳細ファイル", "file2", LTEXT_LEN, "KVa", array("SPTAB_CHECK","MAX_LENGTH_CHECK"));
76    $objFormParam->addParam("送料", "deliv_fee", PRICE_LEN, "n", array("MAX_LENGTH_CHECK","NUM_CHECK"));
77    $objFormParam->addParam("在庫無制限", "stock_unlimited", INT_LEN, "n", array("MAX_LENGTH_CHECK","NUM_CHECK"));
78    $objFormParam->addParam("販売無制限", "sale_unlimited", INT_LEN, "n", array("MAX_LENGTH_CHECK","NUM_CHECK"));
79}
80
81/* 特殊項目の変換 */
82function lfConvFormat($array) {
83    global $arrDISP;
84    foreach($array as $key => $val) {
85        switch($key) {
86        case 'status':
87            $arrRet[$key] = sfSearchKey($arrDISP, $val, 1);
88            break;
89        default:
90            $arrRet[$key] = $val;
91            break;
92        }
93    }
94    return $arrRet;
95}
96
97/* 商品の新規追加 */
98function lfInsertProduct($objQuery) {
99    global $objFormParam;
100    $arrRet = $objFormParam->getHashArray();
101   
102    // 規格に登録される値を除外する。
103    foreach($arrRet as $key => $val) {
104        switch($key) {
105        case 'product_code':
106        case 'price01':
107        case 'price02':
108        case 'stock':
109        case 'stock_unlimited':
110            break;
111        default:
112            $sqlval[$key] = $val;
113            break;
114        }
115    }
116   
117    if (DB_TYPE == "pgsql") {
118        $product_id = $objQuery->nextval("dtb_products", "product_id");
119        $sqlval['product_id'] = $product_id;
120    }
121    $sqlval['status'] = 1;  // 表示に設定する。
122    $sqlval['update_date'] = "Now()";
123    $sqlval['create_date'] = "Now()";
124    $sqlval['creator_id'] = $_SESSION['member_id'];
125   
126    if($_SESSION['member_id'] == "") {
127        $sqlval['creator_id'] = '0';
128    }
129       
130    $sqlval['rank'] = $objQuery->max("dtb_products", "rank", "del_flg = 0 AND category_id = ?", array($sqlval['category_id'])) + 1;
131   
132    // 規格登録
133    sfInsertProductClass($objQuery, $arrRet, $product_id);
134    // INSERTの実行
135    $objQuery->fast_insert("dtb_products", $sqlval);
136    if (DB_TYPE == "mysql") {
137        $product_id = $objQuery->nextval("dtb_products", "product_id");
138    }
139}
140
141/* 入力内容のチェック */
142function lfCheckError() {
143    global $objFormParam;
144    // 入力データを渡す。
145    $arrRet =  $objFormParam->getHashArray();
146    $objErr = new SC_CheckError($arrRet);
147    $objErr->arrErr = $objFormParam->checkError(false);
148   
149    if(!isset($objErr->arrErr['category_id'])) {
150        $objQuery = new SC_Query();
151        $col = "level";
152        $table = "dtb_category";
153        $where = "category_id = ?";
154        $level = $objQuery->get($table, $col, $where, array($arrRet['category_id']));
155        if($level != LEVEL_MAX) {
156            $objErr->arrErr['category_id'] = "※ このカテゴリIDには商品を登録できません。";
157        }
158    }
159    return $objErr->arrErr;
160}
161
162function lfRegistCSV($filepath, $colmax, $total) {
163    global $objFormParam;
164           
165    $fp = fopen($filepath, "r");
166    $line = 0;      // 行数
167    $regist = 0;    // 登録数
168   
169    $objQuery = new SC_Query();
170   
171    $err = false;
172   
173    while(!feof($fp)) {
174        $arrCSV = fgetcsv($fp, 10000);
175        // 行カウント
176        $line++;
177                       
178        // 項目数カウント
179        $max = count($arrCSV);
180       
181        // 項目数が1以下の場合は無視する
182        if($max <= 1) {
183            continue;           
184        }
185           
186        // 項目数チェック
187        if($max != $colmax) {
188            fwrite(STDOUT, "※ 項目数が" . $max . "個検出されました。項目数は" . $colmax . "個になります。\n");
189           
190            ob_start();
191            print_r($arrCSV);
192            $objPage->tpl_debug = ob_get_contents();
193            ob_end_clean();
194           
195            $err = true;
196        } else {
197            // シーケンス配列を格納する。
198            $objFormParam->setParam($arrCSV, true);
199            $arrRet = $objFormParam->getHashArray();
200            // 値をフォーマット変換して格納する。
201            $arrRet = lfConvFormat($arrRet);
202            $objFormParam->setParam($arrRet);
203            // 入力値の変換
204            $objFormParam->convParam();
205            // <br>なしでエラー取得する。
206            $objPage->arrCSVErr = lfCheckError();
207        }
208           
209        // 入力エラーチェック
210        if(count($objPage->arrCSVErr) > 0) {
211            fwrite(STDOUT, "■" . $line . "行目でエラーが発生しました。\n");
212            $objPage->arrParam = $objFormParam->getHashArray();
213            $err = true;
214        }
215           
216        if(!$err) {
217            $all = $total + $line;
218            fwrite(STDOUT, "writing $all\n");
219            $objQuery->begin();
220            lfInsertProduct($objQuery);
221            $objQuery->commit();
222            $regist++;
223        }
224    }
225    fclose($fp);
226   
227    return $regist;
228}
229?>
Note: See TracBrowser for help on using the repository browser.