Changeset 16420

Timestamp:

2007/10/14 22:55:13 (17 years ago)

Author:

adachi

Message:

ｵｰﾅｰｽﾞｽﾄｱ連携暫定コミット

Location:

branches/feature-module-update/data/class

Files:

• batch/SC_Batch_Update.php (modified) (6 diffs)
• pages/upgrade/LC_Page_Upgrade_Base.php (modified) (1 diff)
• pages/upgrade/LC_Page_Upgrade_ProductsList.php (modified) (3 diffs)

branches/feature-module-update/data/class/batch/SC_Batch_Update.php

@@ -37 +37 @@
      */
     function execute($target = ".") {
+        $arrLog = array();
         $includeArray = explode(',', $this->includes);
         $excludeArray = explode(',', $this->excludes);
@@ -55 +56 @@
                 // distinfo.php を読み込む
                 if ($fileName == "distinfo.php") {
-                    include_once($fileName);
+                    include_once($path);
                 }
 
                 // 除外ファイルをスキップ
                 if (in_array($fileName, $excludeArray)) {
-                    echo "excludes by " . $path . "\n";
+                    $arrLog[] = "excludes by " . $path . "\n";
                     continue;
                 }
@@ -67 +68 @@
                 $sha1 = sha1_file($path);
 
-                echo $sha1 . " => " . $path . "\n";
+                $arrLog[] = $sha1 . " => " . $path . "\n";
 
 
@@ -81 +82 @@
                             $out = $distinfo[$sha1];
                         } else {
-                            die("ハッシュ値が一致しないため, コピー先が取得できません.");
+                            $arrLog[] = "ハッシュ値が一致しないため, コピー先が取得できません.";
+                            die();
                         }
 
                         // ファイルを書き出しモードで開く
-                        $handle = fopen($out, "w");
+                        $handle = @fopen($out, "w");
                         if (!$handle) {
-                            echo "Cannot open file (". $out . ")";
-                            continue;
+                            // ディレクトリ作成を行ってリトライ
+                            $this->mkdir_p($out);
+                            $handle = @fopen($out, "w");
+                            if (!$handle) {
+                                $arrLog[] = "Cannot open file (". $out . ")\n";
+                                continue;
+                            }
                         }
 
                         // 取得した内容を書き込む
                         if (fwrite($handle, $contents) === false) {
-                            echo "Cannot write to file (" . $out . ")";
+                            $arrLog[] = "Cannot write to file (" . $out . ")\n";
                             continue;
                         }
 
-                        echo "copyed " . $out . "\n";
+                        $arrLog[] =  "copyed " . $out . "\n";
                         // ファイルを閉じる
                         fclose($handle);
@@ -104 +111 @@
             }
         }
-        echo "Finished Successful!\n";
+        $arrLog[] = "Finished Successful!\n";
+        return $arrLog;
     }
 
@@ -123 +131 @@
         return $alldirs;
     }
+
+    /**
+     * mkdir -p
+     *
+     * @param string $path 絶対パス
+     */
+    function mkdir_p($path){
+        $path = dirname($path);
+        $path = str_replace ('\\', '/', $path);
+
+        $arrDirs = explode("/", $path);
+        $dir = '';
+
+        foreach($arrDirs as $n){
+            $dir .= $n . '/';
+            if(!file_exists($dir)) {
+                if (!@mkdir($dir)) return;
+            }
+        }
+}
 }
 ?>

branches/feature-module-update/data/class/pages/upgrade/LC_Page_Upgrade_Base.php

@@ -1 +1 @@
 <?php
+/*
+ * Copyright(c) 2000-2007 LOCKON CO.,LTD. All Rights Reserved.
+ *
+ * http://www.lockon.co.jp/
+ */
 
+// {{{ requires
+require_once CLASS_PATH . 'pages/LC_Page.php';
+
+/**
+ * オーナーズストア連携の基底クラス
+ *
+ * @package Page
+ * @author LOCKON CO.,LTD.
+ * @version $Id$
+ */
+class LC_Page_Upgrade_Base extends LC_Page {
+
+    // }}}
+    // {{{ functions
+
+    function LC_Page_Upgrade_Base() {
+        $this->objJson = new Services_Json();
+    }
+    /**
+     * 配信サーバへリクエストを送信する.
+     *
+     * @param string $mode
+     * @param array $arrParams 追加パラメータ.連想配列で渡す.
+     * @return string|object レスポンスボディ|エラー時にはPEAR::Errorオブジェクトを返す.
+     */
+    function request($mode, $arrParams = array()) {
+        $objReq = new HTTP_Request();
+        $objReq->setUrl('http://cube-shopaccount/upgrade/index.php');
+        $objReq->setMethod('POST');
+        $objReq->addPostData('mode', $mode);
+        $objReq->addPostData('site_url', SITE_URL);
+        $objReq->addPostData('ssl_url', SSL_URL);
+        $objReq->addPostDataArray($arrParams);
+
+        $e = $objReq->sendRequest();
+        if (PEAR::isError($e)) {
+            return $e;
+        }
+
+        if (($code = $objReq->getResponseCode()) !== 200) {
+            return PEAR::raiseError('HTTP RESPONSE CODE:' . $code);
+        }
+
+        return $objReq->getResponseBody();
+    }
+
+    /**
+     * ユーザへ結果を通知する.
+     *
+     * @param integer $status ステータスコード
+     * @param string $message ステータスメッセージ
+     * @param array arrParam 追加パラメータ
+     * @return void
+     */
+    function displayJson($status, $message, $arrParam = array()) {
+        $arrData = array(
+            'status'  => $status,
+            'body'    => $message
+        );
+        echo $this->objJson->encode(array_merge($arrData, $arrParam));
+    }
+
+    /**
+     * ログ出力を行う
+     *
+     * @param integer $message logメッセージ
+     * @param string $val debug用パラメータ
+     */
+    function log($message, $val = null) {
+        $msg = sprintf("%s / debug: %s", $message, serialize($val));
+        GC_Utils::gfPrintLog($msg, DATA_PATH . 'logs/ownersstore.log');
+    }
+}
 ?>

branches/feature-module-update/data/class/pages/upgrade/LC_Page_Upgrade_ProductsList.php

@@ -8 +8 @@
 // {{{ requires
 require_once CLASS_PATH . 'pages/LC_Page.php';
-require_once DATA_PATH  . 'module/Services/JSON.php';
-require_once DATA_PATH  . 'module/Request.php';
 
 /**
@@ -39 +37 @@
     function process() {
         $objSess = new SC_Session();
-        if ( $objSess->isSuccess() !== true) {
+        if ($objSess->isSuccess() !== true) {
             // TODO エラー処理
         }
@@ -71 +69 @@
         parent::destroy();
     }
-
-
-    function createResponceHTML() {}
 }
 ?>