Index: branches/version-2/data/class/pages/admin/products/LC_Page_Admin_Products_UploadCSVCategory.php
===================================================================
--- branches/version-2/data/class/pages/admin/products/LC_Page_Admin_Products_UploadCSVCategory.php (revision 17047)
+++ branches/version-2/data/class/pages/admin/products/LC_Page_Admin_Products_UploadCSVCategory.php (revision 17047)
@@ -0,0 +1,387 @@
+tpl_mainpage = 'products/upload_csv_category.tpl';
+ $this->tpl_subnavi = 'products/subnavi.tpl';
+ $this->tpl_mainno = 'products';
+ $this->tpl_subno = 'upload_csv_category';
+ }
+
+ /**
+ * Page のプロセス.
+ *
+ * @return void
+ */
+ function process() {
+ $conn = new SC_DBConn();
+ $objView = new SC_AdminView();
+ $objSess = new SC_Session();
+ $objDb = new SC_Helper_DB_Ex();
+
+ // 認証可否の判定
+ SC_Utils_Ex::sfIsSuccess($objSess);
+
+ // ファイル管理クラス
+ $this->objUpFile = new SC_UploadFile(IMAGE_TEMP_DIR, IMAGE_SAVE_DIR);
+ // ファイル情報の初期化
+ $this->lfInitFile();
+ // パラメータ管理クラス
+ $this->objFormParam = new SC_FormParam();
+ // パラメータ情報の初期化
+ $this->lfInitParam();
+ $colmax = $this->objFormParam->getCount();
+ $this->objFormParam->setHtmlDispNameArray();
+ $this->arrTitle = $this->objFormParam->getHtmlDispNameArray();
+
+ if (!isset($_POST['mode'])) $_POST['mode'] = "";
+
+ switch($_POST['mode']) {
+ case 'csv_upload':
+ $err = false;
+ // エラーチェック
+ $arrErr['csv_file'] = $this->objUpFile->makeTempFile('csv_file');
+
+ if($arrErr['css_file'] == "") {
+ $arrErr = $this->objUpFile->checkEXISTS();
+ }
+
+ // 実行時間を制限しない
+ set_time_limit(0);
+
+ // 出力をバッファリングしない(==日本語自動変換もしない)
+ ob_end_clean();
+
+ // IEのために256バイト空文字出力
+ echo str_pad('',256);
+
+ if(empty($arrErr['csv_file'])) {
+ // 一時ファイル名の取得
+ $filepath = $this->objUpFile->getTempFilePath('csv_file');
+ // エンコード
+ $enc_filepath = SC_Utils_Ex::sfEncodeFile($filepath,
+ CHAR_CODE, CSV_TEMP_DIR);
+
+ // レコード数を得る
+ $rec_count = $this->lfCSVRecordCount($enc_filepath);
+
+ $fp = fopen($enc_filepath, "r");
+ $line = 0; // 行数
+ $regist = 0; // 登録数
+
+ $objQuery = new SC_Query();
+ $objQuery->begin();
+
+ echo "■ CSV登録進捗状況
\n";
+
+ while(!feof($fp) && !$err) {
+ $arrCSV = fgetcsv($fp, CSV_LINE_MAX);
+
+ // 行カウント
+ $line++;
+
+ if($line <= 1) {
+ continue;
+ }
+
+ // 項目数カウント
+ $max = count($arrCSV);
+
+ // 項目数が1以下の場合は無視する
+ if($max <= 1) {
+ continue;
+ }
+
+ // 項目数チェック
+ if($max != $colmax) {
+ echo "※ 項目数が" . $max . "個検出されました。項目数は" . $colmax . "個になります。\n";
+ $err = true;
+ } else {
+ // シーケンス配列を格納する。
+ $this->objFormParam->setParam($arrCSV, true);
+ $arrRet = $this->objFormParam->getHashArray();
+ $this->objFormParam->setParam($arrRet);
+ // 入力値の変換
+ $this->objFormParam->convParam();
+ //
なしでエラー取得する。
+ $arrCSVErr = $this->lfCheckError();
+ }
+
+ // 入力エラーチェック
+ if(count($arrCSVErr) > 0) {
+ echo "■" . $line . "行目でエラーが発生しました。\n";
+ foreach($arrCSVErr as $val) {
+ $this->printError($val);
+ }
+ $err = true;
+ }
+
+ if(!$err) {
+ $this->lfRegistProduct($objQuery, $line);
+ $regist++;
+ }
+ $arrParam = $this->objFormParam->getHashArray();
+
+ if(!$err) echo $line." / ".$rec_count. "行目 （カテゴリID：".$arrParam['category_id']." / カテゴリ名：".$arrParam['category_name'].")\n
";
+ flush();
+ }
+ fclose($fp);
+
+ if(!$err) {
+ $objQuery->commit();
+ echo "■" . $regist . "件のレコードを登録しました。";
+ // カテゴリ件数カウント関数の実行
+ $objDb->sfCategory_Count($objQuery);
+ } else {
+ $objQuery->rollback();
+ }
+ } else {
+ foreach($arrErr as $val) {
+ $this->printError($val);
+ }
+ }
+ echo "
→閉じる";
+ flush();
+ exit;
+ break;
+ default:
+ break;
+ }
+
+ $objView->assignobj($this);
+ $objView->display(MAIN_FRAME);
+ }
+
+ /**
+ * デストラクタ.
+ *
+ * @return void
+ */
+ function destroy() {
+ parent::destroy();
+ }
+
+
+ /**
+ * ファイル情報の初期化を行う.
+ *
+ * @return void
+ */
+ function lfInitFile() {
+ $this->objUpFile->addFile("CSVファイル", 'csv_file', array('csv'),
+ CSV_SIZE, true, 0, 0, false);
+ }
+
+ /**
+ * 入力情報の初期化を行う.
+ *
+ * @return void
+ */
+ function lfInitParam() {
+ $this->objFormParam->addParam("カテゴリID","category_id",INT_LEN,"n",array("MAX_LENGTH_CHECK","NUM_CHECK"));
+ $this->objFormParam->addParam("カテゴリ名","category_name",STEXT_LEN,"KVa",array("EXIST_CHECK","SPTAB_CHECK","MAX_LENGTH_CHECK"));
+ $this->objFormParam->addParam("親カテゴリID","parent_category_id",INT_LEN,"n",array("MAX_LENGTH_CHECK","NUM_CHECK"));
+ }
+
+ /**
+ * カテゴリ登録を行う.
+ *
+ * @param SC_Query $objQuery SC_Queryインスタンス
+ * @param string|integer $line 処理中の行数
+ * @return void
+ */
+ function lfRegistProduct($objQuery, $line = "") {
+ $objDb = new SC_Helper_DB_Ex();
+ $arrRet = $this->objFormParam->getHashArray();
+
+ //カテゴリID
+ $update = false;
+ if($arrRet['category_id'] != ""){
+ $sqlval['category_id'] = $arrRet['category_id'];
+ $update = true;
+ }else{
+ $category_id = $objQuery->max("dtb_category","category_id")+1;
+ $sqlval['category_id'] = $category_id;
+ $count = $objQuery->count("dtb_category", "category_id = ?", array($arrRet['category_id']));
+ if($count == 0){
+ $update = false;
+ }else{
+ $update = true;
+ }
+ }
+
+ // カテゴリ名
+ $sqlval['category_name'] = $arrRet['category_name'];
+
+ // 親カテゴリID、レベル
+ if ($arrRet['parent_category_id'] == 0) {
+ $sqlval['parent_category_id'] = "0";
+ $sqlval['level'] = 1;
+ } else {
+ $sqlval['parent_category_id'] = $arrRet['parent_category_id'];
+ $parent_level = $objQuery->get('dtb_category','level',"category_id = ?",array($sqlval['parent_category_id']));
+ $sqlval['level'] = $parent_level+1;
+ }
+
+ // その他
+ $time = date("Y-m-d H:i:s");
+ if($line != "") {
+ $microtime = sprintf("%06d", $line);
+ $time .= ".$microtime";
+ }
+ $sqlval['update_date'] = $time;
+ $sqlval['creator_id'] = $_SESSION['member_id'];
+
+ // UPDATE
+ if($update) {
+ echo "UPDATE ";
+ $where = "category_id = ?";
+ $objQuery->update("dtb_category", $sqlval, $where, array($sqlval['category_id']));
+
+ // 新規登録
+ } else {
+ $sqlval['create_date'] = $time;
+ // ランク
+ if ($sqlval['parent_category_id'] == 0) {
+ // ROOT階層で最大のランクを取得する。
+ $where = "parent_category_id = ?";
+ $sqlval['rank'] = $objQuery->max("dtb_category", "rank", $where, array($sqlval['parent_category_id'])) + 1;
+ } else {
+ // 親のランクを自分のランクとする。
+ $where = "category_id = ?";
+ $sqlval['rank'] = $objQuery->get("dtb_category", "rank", $where, array($sqlval['parent_category_id']));
+ // 追加レコードのランク以上のレコードを一つあげる。
+ $sqlup = "UPDATE dtb_category SET rank = (rank + 1) WHERE rank >= ?";
+ $objQuery->exec($sqlup, array($sqlval['rank']));
+ }
+ echo "INSERT ";
+ $objQuery->insert("dtb_category", $sqlval);
+ }
+ }
+
+ /**
+ * 入力チェックを行う.
+ *
+ * @return void
+ */
+ function lfCheckError() {
+ $arrRet = $this->objFormParam->getHashArray();
+ $objQuery = new SC_Query();
+ $objErr = new SC_CheckError($arrRet);
+ $objErr->arrErr = $this->objFormParam->checkError(false);
+
+ // 親カテゴリID設定
+ if ($arrRet['parent_category_id'] == 0) {
+ $parent_category_id = "0";
+ } else {
+ $parent_category_id = $arrRet['parent_category_id'];
+ }
+
+ // 存在する親カテゴリIDかチェック
+ if(count($objErr->arrErr) == 0) {
+ if($parent_category_id != 0){
+ $count = $objQuery->count("dtb_category", "category_id = ?", array($parent_category_id));
+ if($count == 0) {
+ $objErr->arrErr['parent_category_id'] = "※ 指定の親カテゴリID(".$parent_category_id.")は、存在しません。";
+ }
+ }
+ }
+
+ // 階層チェック
+ if(!isset($objErr->arrErr['category_name']) && !isset($objErr->arrErr['parent_category_id'])) {
+ $level = $objQuery->get("dtb_category", "level", "category_id = ?", array($parent_category_id));
+ if($level >= LEVEL_MAX) {
+ $objErr->arrErr['category_name'] = "※ ".LEVEL_MAX."階層以上の登録はできません。
";
+ }
+ }
+
+ // 重複チェック
+ if(!isset($objErr->arrErr['category_name']) && !isset($objErr->arrErr['parent_category_id'])) {
+ $where = "parent_category_id = ? AND category_name = ?";
+ $arrCat = $objQuery->select("category_id, category_name", "dtb_category", $where, array($parent_category_id, $arrRet['category_name']));
+ if (empty($arrCat)) {
+ $arrCat = array(array("category_id" => "", "category_name" => ""));
+ }
+ // 編集中のレコード以外に同じ名称が存在する場合
+ if ($arrCat[0]['category_id'] != $arrRet['category_id'] && $arrCat[0]['category_name'] == $_POST['category_name']) {
+ $objErr->arrErr['category_name'] = "※ 既に同じ内容の登録が存在します。
";
+ }
+ }
+ return $objErr->arrErr;
+ }
+
+ /**
+ * CSVのカウント数を得る.
+ *
+ * @param string $file_name ファイルパス
+ * @return integer CSV のカウント数
+ */
+ function lfCSVRecordCount($file_name) {
+ $count = 0;
+ $fp = fopen($file_name, "r");
+ while(!feof($fp)) {
+ $arrCSV = fgetcsv($fp, CSV_LINE_MAX);
+ $count++;
+ }
+
+ return $count-1;
+ }
+
+ /**
+ * 引数の文字列をエラー出力する.
+ *
+ * 引数 $val の内容は, htmlspecialchars() によってサニタイズされ
+ *
+ * @param string $val 出力する文字列
+ * @return void
+ */
+ function printError($val) {
+ echo ""
+ . htmlspecialchars($val, ENT_QUOTES)
+ . "\n";
+ }
+}
+?>