source: branches/version-2_11-dev/data/class/helper/SC_Helper_Purchase.php @ 20971

Revision 20971, 46.5 KB checked in by Seasoft, 10 years ago (diff)

#1333 (謎な処理 SC_Helper_Purchase#shippingItemTempToCart)

  • 一旦削除してみましたので、不具合が確認されましたら、報告をお願いいたします。
  • 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-2011 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/**
25 * 商品購入関連のヘルパークラス.
26 *
27 * TODO 購入時強制会員登録機能(#521)の実装を検討
28 * TODO dtb_customer.buy_times, dtb_customer.buy_total の更新
29 *
30 * @package Helper
31 * @author Kentaro Ohkouchi
32 * @version $Id$
33 */
34class SC_Helper_Purchase {
35
36    /**
37     * 受注を完了する.
38     *
39     * 下記のフローで受注を完了する.
40     *
41     * 1. トランザクションを開始する
42     * 2. カートの内容を検証する.
43     * 3. 受注一時テーブルから受注データを読み込む
44     * 4. ユーザーがログインしている場合はその他の発送先へ登録する
45     * 5. 受注データを受注テーブルへ登録する
46     * 6. トランザクションをコミットする
47     *
48     * 実行中に, 何らかのエラーが発生した場合, 処理を中止しエラーページへ遷移する
49     *
50     * 決済モジュールを使用する場合は受注ステータスを「決済処理中」に設定し,
51     * 決済完了後「新規受付」に変更すること
52     *
53     * @param integer $orderStatus 受注処理を完了する際に設定する受注ステータス
54     * @return void
55     */
56    function completeOrder($orderStatus = ORDER_NEW) {
57        $objQuery =& SC_Query_Ex::getSingletonInstance();
58        $objSiteSession = new SC_SiteSession_Ex();
59        $objCartSession = new SC_CartSession_Ex();
60        $objCustomer = new SC_Customer_Ex();
61        $customerId = $objCustomer->getValue('customer_id');
62
63        $objQuery->begin();
64        if (!$objSiteSession->isPrePage()) {
65            SC_Utils_Ex::sfDispSiteError(PAGE_ERROR, $objSiteSession);
66        }
67
68        $uniqId = $objSiteSession->getUniqId();
69        $this->verifyChangeCart($uniqId, $objCartSession);
70
71        $orderTemp = $this->getOrderTemp($uniqId);
72
73        $orderTemp['status'] = $orderStatus;
74        $cartkey = $objCartSession->getKey();
75        $orderId = $this->registerOrderComplete($orderTemp, $objCartSession,
76                                                $cartkey);
77        $shippingTemp =& $this->getShippingTemp();
78        if (count($shippingTemp) > 1) {
79            foreach ($shippingTemp as $shippingId => $val) {
80                $this->registerShipmentItem($orderId, $shippingId,
81                                            $val['shipment_item']);
82            }
83        }
84
85        $this->registerShipping($orderId, $shippingTemp);
86        $objQuery->commit();
87        $this->cleanupSession($orderId, $objCartSession, $objCustomer, $cartkey);
88    }
89
90    /**
91     * 受注をキャンセルする.
92     *
93     * 受注完了後の受注をキャンセルする.
94     * この関数は, 主に決済モジュールにて, 受注をキャンセルする場合に使用する.
95     *
96     * 受注ステータスを引数 $orderStatus で指定したステータスに変更する.
97     * (デフォルト ORDER_CANCEL)
98     * 引数 $is_delete が true の場合は, 受注データを論理削除する.
99     * 商品の在庫数は, 受注前の在庫数に戻される.
100     *
101     * @param integer $order_id 受注ID
102     * @param integer $orderStatus 受注ステータス
103     * @param boolean $is_delete 受注データを論理削除する場合 true
104     * @return void
105     */
106    function cancelOrder($order_id, $orderStatus = ORDER_CANCEL, $is_delete = false) {
107        $objQuery =& SC_Query_Ex::getSingletonInstance();
108        $in_transaction = $objQuery->inTransaction();
109        if (!$in_transaction) {
110            $objQuery->begin();
111        }
112
113        $arrParams['status'] = $orderStatus;
114        if ($is_delete) {
115            $arrParams['del_flg'] = 1;
116        }
117
118        $this->registerOrder($order_id, $arrParams);
119
120        $arrOrderDetail = $this->getOrderDetail($order_id);
121        foreach ($arrOrderDetail as $arrDetail) {
122            $objQuery->update('dtb_products_class', array(),
123                              "product_class_id = ?", array($arrDetail['product_class_id']),
124                              array('stock' => 'stock + ?'), array($arrDetail['quantity']));
125        }
126        if (!$in_transaction) {
127            $objQuery->commit();
128        }
129    }
130
131    /**
132     * 受注をキャンセルし, カートをロールバックして, 受注一時IDを返す.
133     *
134     * 受注完了後の受注をキャンセルし, カートの状態を受注前の状態へ戻す.
135     * この関数は, 主に, 決済モジュールに遷移した後, 購入確認画面へ戻る場合に使用する.
136     *
137     * 受注ステータスを引数 $orderStatus で指定したステータスに変更する.
138     * (デフォルト ORDER_CANCEL)
139     * 引数 $is_delete が true の場合は, 受注データを論理削除する.
140     * 商品の在庫数, カートの内容は受注前の状態に戻される.
141     *
142     * @param integer $order_id 受注ID
143     * @param integer $orderStatus 受注ステータス
144     * @param boolean $is_delete 受注データを論理削除する場合 true
145     * @return string 受注一時ID
146     */
147    function rollbackOrder($order_id, $orderStatus = ORDER_CANCEL, $is_delete = false) {
148        $objQuery =& SC_Query_Ex::getSingletonInstance();
149        $in_transaction = $objQuery->inTransaction();
150        if (!$in_transaction) {
151            $objQuery->begin();
152        }
153
154        $this->cancelOrder($order_id, $orderStatus, $is_delete);
155        $arrOrderTemp = $this->getOrderTempByOrderId($order_id);
156        $_SESSION = array_merge($_SESSION, unserialize($arrOrderTemp['session']));
157
158        $objSiteSession = new SC_SiteSession_Ex();
159        $objCartSession = new SC_CartSession_Ex();
160        $objCustomer = new SC_Customer_Ex();
161
162        // 新たに受注一時情報を保存する
163        $objSiteSession->unsetUniqId();
164        $uniqid = $objSiteSession->getUniqId();
165        $arrOrderTemp['del_flg'] = 0;
166        $this->saveOrderTemp($uniqid, $arrOrderTemp, $objCustomer);
167        $this->verifyChangeCart($uniqid, $objCartSession);
168        $objSiteSession->setRegistFlag();
169
170        if (!$in_transaction) {
171            $objQuery->commit();
172        }
173        return $uniqid;
174    }
175
176    /**
177     * カートに変化が無いか検証する.
178     *
179     * ユニークIDとセッションのユニークIDを比較し, 異なる場合は
180     * エラー画面を表示する.
181     *
182     * カートが空の場合, 購入ボタン押下後にカートが変更された場合は
183     * カート画面へ遷移する.
184     *
185     * @param string $uniqId ユニークID
186     * @param SC_CartSession $objCartSession
187     * @return void
188     */
189    function verifyChangeCart($uniqId, &$objCartSession) {
190        $cartKeys = $objCartSession->getKeys();
191
192        // カート内が空でないか
193        if (SC_Utils_Ex::isBlank($cartKeys)) {
194            SC_Response_Ex::sendRedirect(CART_URLPATH);
195            exit;
196        }
197
198        foreach ($cartKeys as $cartKey) {
199            // 初回のみカートの内容を保存
200            $objCartSession->saveCurrentCart($uniqId, $cartKey);
201
202            /*
203             * POSTのユニークIDとセッションのユニークIDを比較
204             *(ユニークIDがPOSTされていない場合はスルー)
205             */
206            if(!SC_SiteSession_Ex::checkUniqId()) {
207                SC_Utils_Ex::sfDispSiteError(CANCEL_PURCHASE);
208                exit;
209            }
210
211            // 購入ボタンを押してから変化がないか
212            $quantity = $objCartSession->getTotalQuantity($cartKey);
213            if($objCartSession->checkChangeCart($cartKey) || !($quantity > 0)) {
214                SC_Response_Ex::sendRedirect(CART_URLPATH);
215                exit;
216            }
217        }
218    }
219
220    /**
221     * 受注一時情報を取得する.
222     *
223     * @param integer $uniqId 受注一時情報ID
224     * @return array 受注一時情報の配列
225     */
226    function getOrderTemp($uniqId) {
227        $objQuery =& SC_Query_Ex::getSingletonInstance();
228        return $objQuery->getRow("*", "dtb_order_temp", "order_temp_id = ?",
229                                 array($uniqId));
230    }
231
232    /**
233     * 受注IDをキーにして受注一時情報を取得する.
234     *
235     * @param integer $order_id 受注ID
236     * @return array 受注一時情報の配列
237     */
238    function getOrderTempByOrderId($order_id) {
239        $objQuery =& SC_Query_Ex::getSingletonInstance();
240        return $objQuery->getRow("*", "dtb_order_temp", "order_id = ?",
241                                 array($order_id));
242    }
243
244    /**
245     * 受注一時情報を保存する.
246     *
247     * 既存のデータが存在しない場合は新規保存. 存在する場合は更新する.
248     * 既存のデータが存在せず, ユーザーがログインしている場合は,
249     * 会員情報をコピーする.
250     *
251     * @param integer $uniqId 受注一時情報ID
252     * @param array $params 登録する受注情報の配列
253     * @param SC_Customer $objCustomer SC_Customer インスタンス
254     * @return array void
255     */
256    function saveOrderTemp($uniqId, $params, &$objCustomer) {
257        if (SC_Utils_Ex::isBlank($uniqId)) {
258            return;
259        }
260        $params['device_type_id'] = SC_Display::detectDevice();
261        $objQuery =& SC_Query_Ex::getSingletonInstance();
262        // 存在するカラムのみを対象とする
263        $cols = $objQuery->listTableFields('dtb_order_temp');
264        foreach ($params as $key => $val) {
265            if (in_array($key, $cols)) {
266                $sqlval[$key] = $val;
267            }
268        }
269
270        $sqlval['session'] = serialize($_SESSION);
271        $exists = $this->getOrderTemp($uniqId);
272        if (SC_Utils_Ex::isBlank($exists)) {
273            $this->copyFromCustomer($sqlval, $objCustomer);
274            $sqlval['order_temp_id'] = $uniqId;
275            $sqlval['create_date'] = "now()";
276            $objQuery->insert("dtb_order_temp", $sqlval);
277        } else {
278            $objQuery->update("dtb_order_temp", $sqlval, 'order_temp_id = ?',
279                              array($uniqId));
280        }
281    }
282
283    /**
284     * セッションの配送情報を取得する.
285     */
286    function getShippingTemp() {
287        return $_SESSION['shipping'];
288    }
289
290    /**
291     * 配送商品をクリア(消去)する
292     *
293     * @param integer $shipping_id 配送先ID
294     * @return void
295     */
296    function clearShipmentItemTemp($shipping_id = null) {
297        if (is_null($shipping_id)) {
298            unset($_SESSION['shipping']);
299        } else {
300            unset($_SESSION['shipping'][$shipping_id]);
301        }
302    }
303
304    /**
305     * 配送商品を設定する.
306     *
307     * @param integer $shipping_id 配送先ID
308     * @param integer $product_class_id 商品規格ID
309     * @param integer $quantity 数量
310     * @return void
311     */
312    function setShipmentItemTemp($shipping_id, $product_class_id, $quantity) {
313        // 配列が長くなるので, リファレンスを使用する
314        $arrItems =& $_SESSION['shipping'][$shipping_id]['shipment_item'];
315
316        $arrItems[$product_class_id]['shipping_id'] = $shipping_id;
317        $arrItems[$product_class_id]['product_class_id'] = $product_class_id;
318        $arrItems[$product_class_id]['quantity'] = $quantity;
319
320        $objProduct = new SC_Product_Ex();
321        if (empty($arrItems[$product_class_id]['productsClass'])) {
322            $product =& $objProduct->getDetailAndProductsClass($product_class_id);
323            $arrItems[$product_class_id]['productsClass'] = $product;
324        }
325        $incTax = SC_Helper_DB_Ex::sfCalcIncTax($arrItems[$product_class_id]['productsClass']['price02']);
326        $arrItems[$product_class_id]['total_inctax'] = $incTax * $arrItems[$product_class_id]['quantity'];
327    }
328
329    /**
330     * 配送先都道府県の配列を返す.
331     */
332    function getShippingPref() {
333        $results = array();
334        foreach ($_SESSION['shipping'] as $val) {
335            $results[] = $val['shipping_pref'];
336        }
337        return $results;
338    }
339
340    /**
341     * 複数配送指定の購入かどうか.
342     *
343     * @return boolean 複数配送指定の購入の場合 true
344     */
345    function isMultiple() {
346        return count($this->getShippingTemp()) > 1;
347    }
348
349    /**
350     * 配送情報をセッションに保存する.
351     *
352     * @param array $arrSrc 配送情報の連想配列
353     * @param integer $shipping_id 配送先ID
354     * @return void
355     */
356    function saveShippingTemp(&$arrSrc, $shipping_id = 0) {
357        if (empty($_SESSION['shipping'][$shipping_id])) {
358            $_SESSION['shipping'][$shipping_id] = $arrSrc;
359            $_SESSION['shipping'][$shipping_id]['shipping_id'] = $shipping_id;
360        } else {
361            $_SESSION['shipping'][$shipping_id] = array_merge($_SESSION['shipping'][$shipping_id], $arrSrc);
362            $_SESSION['shipping'][$shipping_id]['shipping_id'] = $shipping_id;
363        }
364    }
365
366    /**
367     * セッションの配送情報を破棄する.
368     */
369    function unsetShippingTemp() {
370        unset($_SESSION['shipping']);
371        unset($_SESSION['multiple_temp']);
372    }
373
374    /**
375     * 会員情報を受注情報にコピーする.
376     *
377     * ユーザーがログインしていない場合は何もしない.
378     * 会員情報を $dest の order_* へコピーする.
379     * customer_id は強制的にコピーされる.
380     *
381     * @param array $dest コピー先の配列
382     * @param SC_Customer $objCustomer SC_Customer インスタンス
383     * @param string $prefix コピー先の接頭辞. デフォルト order
384     * @param array $keys コピー対象のキー
385     * @return void
386     */
387    function copyFromCustomer(&$dest, &$objCustomer, $prefix = 'order',
388                              $keys = array('name01', 'name02', 'kana01', 'kana02',
389                                            'sex', 'zip01', 'zip02', 'pref',
390                                            'addr01', 'addr02',
391                                            'tel01', 'tel02', 'tel03', 'job',
392                                            'birth', 'email')) {
393        if ($objCustomer->isLoginSuccess(true)) {
394
395            foreach ($keys as $key) {
396                if (in_array($key, $keys)) {
397                    $dest[$prefix . '_' . $key] = $objCustomer->getValue($key);
398                }
399            }
400
401            if (Net_UserAgent_Mobile::isMobile()
402                && in_array('email', $keys)) {
403                $email_mobile = $objCustomer->getValue('email_mobile');
404                if (empty($email_mobile)) {
405                    $dest[$prefix . '_email'] = $objCustomer->getValue('email');
406                } else {
407                    $dest[$prefix . '_email'] = $email_mobile;
408                }
409            }
410
411            $dest['customer_id'] = $objCustomer->getValue('customer_id');
412            $dest['update_date'] = 'Now()';
413        }
414    }
415
416    /**
417     * 受注情報を配送情報にコピーする.
418     *
419     * 受注情報($src)を $dest の order_* へコピーする.
420     *
421     * TODO 汎用的にして SC_Utils へ移動
422     *
423     * @param array $dest コピー先の配列
424     * @param array $src コピー元の配列
425     * @param array $keys コピー対象のキー
426     * @param string $prefix コピー先の接頭辞. デフォルト shipping
427     * @param string $src_prefix コピー元の接頭辞. デフォルト order
428     * @return void
429     */
430    function copyFromOrder(&$dest, $src,
431                           $prefix = 'shipping', $src_prefix = 'order',
432                           $keys = array('name01', 'name02', 'kana01', 'kana02',
433                                         'sex', 'zip01', 'zip02', 'pref',
434                                         'addr01', 'addr02',
435                                         'tel01', 'tel02', 'tel03')) {
436        if (!SC_Utils_Ex::isBlank($prefix)) {
437            $prefix = $prefix . '_';
438        }
439        if (!SC_Utils_Ex::isBlank($src_prefix)) {
440            $src_prefix = $src_prefix . '_';
441        }
442        foreach ($keys as $key) {
443            if (in_array($key, $keys)) {
444                $dest[$prefix . $key] = $src[$src_prefix . $key];
445            }
446        }
447    }
448
449    /**
450     * 購入金額に応じた支払方法を取得する.
451     *
452     * @param integer $total 購入金額
453     * @param integer $deliv_id 配送業者ID
454     * @return array 購入金額に応じた支払方法の配列
455     */
456    function getPaymentsByPrice($total, $deliv_id) {
457
458        $arrPaymentIds = $this->getPayments($deliv_id);
459        if (SC_Utils_Ex::isBlank($arrPaymentIds)) {
460            return array();
461        }
462
463        $objQuery =& SC_Query_Ex::getSingletonInstance();
464
465        // 削除されていない支払方法を取得
466        $where = 'del_flg = 0 AND payment_id IN (' . implode(', ', array_pad(array(), count($arrPaymentIds), '?')) . ')';
467        $objQuery->setOrder("rank DESC");
468        $payments = $objQuery->select("payment_id, payment_method, rule, upper_rule, note, payment_image, charge", "dtb_payment", $where, $arrPaymentIds);
469        foreach ($payments as $data) {
470            // 下限と上限が設定されている
471            if (strlen($data['rule']) != 0 && strlen($data['upper_rule']) != 0) {
472                if ($data['rule'] <= $total && $data['upper_rule'] >= $total) {
473                    $arrPayment[] = $data;
474                }
475            }
476            // 下限のみ設定されている
477            elseif (strlen($data['rule']) != 0) {
478                if($data['rule'] <= $total) {
479                    $arrPayment[] = $data;
480                }
481            }
482            // 上限のみ設定されている
483            elseif (strlen($data['upper_rule']) != 0) {
484                if($data['upper_rule'] >= $total) {
485                    $arrPayment[] = $data;
486                }
487            }
488            // いずれも設定なし
489            else {
490                $arrPayment[] = $data;
491            }
492          }
493        return $arrPayment;
494    }
495
496    /**
497     * お届け日一覧を取得する.
498     */
499    function getDelivDate(&$objCartSess, $productTypeId) {
500        $cartList = $objCartSess->getCartList($productTypeId);
501        $delivDateIds = array();
502        foreach ($cartList as $item) {
503            $delivDateIds[] = $item['productsClass']['deliv_date_id'];
504        }
505        $max_date = max($delivDateIds);
506        //発送目安
507        switch($max_date) {
508        //即日発送
509        case '1':
510            $start_day = 1;
511            break;
512            //1-2日後
513        case '2':
514            $start_day = 3;
515            break;
516            //3-4日後
517        case '3':
518            $start_day = 5;
519            break;
520            //1週間以内
521        case '4':
522            $start_day = 8;
523            break;
524            //2週間以内
525        case '5':
526            $start_day = 15;
527            break;
528            //3週間以内
529        case '6':
530            $start_day = 22;
531            break;
532            //1ヶ月以内
533        case '7':
534            $start_day = 32;
535            break;
536            //2ヶ月以降
537        case '8':
538            $start_day = 62;
539            break;
540            //お取り寄せ(商品入荷後)
541        case '9':
542            $start_day = "";
543            break;
544        default:
545            //お届け日が設定されていない場合
546            $start_day = "";
547        }
548        //お届け可能日のスタート値から、お届け日の配列を取得する
549        $arrDelivDate = $this->getDateArray($start_day, DELIV_DATE_END_MAX);
550        return $arrDelivDate;
551    }
552
553    /**
554     * お届け可能日のスタート値から, お届け日の配列を取得する.
555     */
556    function getDateArray($start_day, $end_day) {
557        $masterData = new SC_DB_MasterData();
558        $arrWDAY = $masterData->getMasterData("mtb_wday");
559        //お届け可能日のスタート値がセットされていれば
560        if($start_day >= 1) {
561            $now_time = time();
562            $max_day = $start_day + $end_day;
563            // 集計
564            for ($i = $start_day; $i < $max_day; $i++) {
565                // 基本時間から日数を追加していく
566                $tmp_time = $now_time + ($i * 24 * 3600);
567                list($y, $m, $d, $w) = explode(" ", date("Y m d w", $tmp_time));
568                $val = sprintf("%04d/%02d/%02d(%s)", $y, $m, $d, $arrWDAY[$w]);
569                $arrDate[$val] = $val;
570            }
571        } else {
572            $arrDate = false;
573        }
574        return $arrDate;
575    }
576
577    /**
578     * 配送業者IDからお届け時間の配列を取得する.
579     *
580     * @param integer $deliv_id 配送業者ID
581     * @return array お届け時間の配列
582     */
583    function getDelivTime($deliv_id) {
584        $objQuery =& SC_Query_Ex::getSingletonInstance();
585        $objQuery->setOrder('time_id');
586        $results = $objQuery->select('time_id, deliv_time',
587                                     'dtb_delivtime',
588                                     'deliv_id = ?', array($deliv_id));
589        $arrDelivTime = array();
590        foreach ($results as $val) {
591            $arrDelivTime[$val['time_id']] = $val['deliv_time'];
592        }
593        return $arrDelivTime;
594    }
595
596    /**
597     * 商品種別ID から配送業者を取得する.
598     *
599     * @param integer $product_type_id 商品種別ID
600     * @return array 配送業者の配列
601     */
602    function getDeliv($product_type_id) {
603        $objQuery =& SC_Query_Ex::getSingletonInstance();
604        $objQuery->setOrder('rank DESC');
605        return $objQuery->select('*', 'dtb_deliv', 'product_type_id = ? AND del_flg = 0',
606                                 array($product_type_id));
607    }
608
609    /**
610     * 配送業者ID から, 有効な支払方法IDを取得する.
611     *
612     * @param integer $deliv_id 配送業者ID
613     * @return array 有効な支払方法IDの配列
614     */
615    function getPayments($deliv_id) {
616        $objQuery =& SC_Query_Ex::getSingletonInstance();
617        $objQuery->setOrder('rank');
618        return $objQuery->getCol('payment_id', 'dtb_payment_options',
619                                 'deliv_id = ?',
620                                 array($deliv_id), MDB2_FETCHMODE_ORDERED);
621    }
622
623    /**
624     * 配送情報の登録を行う.
625     *
626     * $arrParam のうち, dtb_shipping テーブルに存在するカラムのみを登録する.
627     *
628     * TODO UPDATE/INSERT にする
629     *
630     * @param integer $order_id 受注ID
631     * @param array $arrParams 配送情報の連想配列
632     * @param boolean $convert_shipping_date yyyy/mm/dd(EEE) 形式の配送日付を変換する場合 true
633     * @return void
634     */
635    function registerShipping($order_id, $arrParams, $convert_shipping_date = true) {
636        $objQuery =& SC_Query_Ex::getSingletonInstance();
637        $table = 'dtb_shipping';
638        $where = 'order_id = ?';
639        $objQuery->delete($table, $where, array($order_id));
640
641         foreach ($arrParams as $key => $arrShipping) {
642
643            $arrValues = $objQuery->extractOnlyColsOf($table, $arrShipping);
644
645            // 配送日付を timestamp に変換
646            if (!SC_Utils_Ex::isBlank($arrValues['shipping_date'])
647                && $convert_shipping_date) {
648                $d = mb_strcut($arrValues["shipping_date"], 0, 10);
649                $arrDate = explode("/", $d);
650                $ts = mktime(0, 0, 0, $arrDate[1], $arrDate[2], $arrDate[0]);
651                $arrValues['shipping_date'] = date("Y-m-d", $ts);
652            }
653
654            // 非会員購入の場合は shipping_id が存在しない
655            if (!isset($arrValues['shipping_id'])) {
656                $arrValues['shipping_id'] = $key;
657            }
658            $arrValues['order_id'] = $order_id;
659            $arrValues['create_date'] = 'Now()';
660            $arrValues['update_date'] = 'Now()';
661            $objQuery->insert($table, $arrValues);
662        }
663    }
664
665    /**
666     * 配送商品を登録する.
667     *
668     * @param integer $order_id 受注ID
669     * @param integer $shipping_id 配送先ID
670     * @param array $arrParams 配送商品の配列
671     * @return void
672     */
673    function registerShipmentItem($order_id, $shipping_id, $arrParams) {
674        $objQuery =& SC_Query_Ex::getSingletonInstance();
675        $table = 'dtb_shipment_item';
676        $where = 'order_id = ? AND shipping_id = ?';
677        $objQuery->delete($table, $where, array($order_id, $shipping_id));
678
679        $objProduct = new SC_Product_Ex();
680        foreach ($arrParams as $arrValues) {
681            if (SC_Utils_Ex::isBlank($arrValues['product_class_id'])) {
682                continue;
683            }
684            $d = $objProduct->getDetailAndProductsClass($arrValues['product_class_id']);
685            $name = SC_Utils_Ex::isBlank($arrValues['product_name'])
686                ? $d['name']
687                : $arrValues['product_name'];
688
689            $code = SC_Utils_Ex::isBlank($arrValues['product_code'])
690                ? $d['product_code']
691                : $arrValues['product_code'];
692
693            $cname1 = SC_Utils_Ex::isBlank($arrValues['classcategory_name1'])
694                ? $d['classcategory_name1']
695                : $arrValues['classcategory_name1'];
696
697            $cname2 = SC_Utils_Ex::isBlank($arrValues['classcategory_name2'])
698                ? $d['classcategory_name2']
699                : $arrValues['classcategory_name2'];
700
701            $price = SC_Utils_Ex::isBlank($arrValues['price'])
702                ? $d['price02']
703                : $arrValues['price'];
704
705            $arrValues['order_id'] = $order_id;
706            $arrValues['shipping_id'] = $shipping_id;
707            $arrValues['product_name'] = $name;
708            $arrValues['product_code'] = $code;
709            $arrValues['classcategory_name1'] = $cname1;
710            $arrValues['classcategory_name2'] = $cname2;
711            $arrValues['price'] = $price;
712
713            $arrExtractValues = $objQuery->extractOnlyColsOf($table, $arrValues);
714            $objQuery->insert($table, $arrExtractValues);
715        }
716    }
717
718    /**
719     * 受注登録を完了する.
720     *
721     * 引数の受注情報を受注テーブル及び受注詳細テーブルに登録する.
722     * 登録後, 受注一時テーブルに削除フラグを立てる.
723     *
724     * @param array $orderParams 登録する受注情報の配列
725     * @param SC_CartSession $objCartSession カート情報のインスタンス
726     * @param integer $cartKey 登録を行うカート情報のキー
727     * @param integer 受注ID
728     */
729    function registerOrderComplete($orderParams, &$objCartSession, $cartKey) {
730        $objQuery =& SC_Query_Ex::getSingletonInstance();
731
732        // 不要な変数を unset
733        $unsets = array('mailmaga_flg', 'deliv_check', 'point_check', 'password',
734                        'reminder', 'reminder_answer', 'mail_flag', 'session');
735        foreach ($unsets as $unset) {
736            unset($orderParams[$unset]);
737        }
738
739        // 注文ステータスの指定が無い場合は新規受付
740        if(SC_Utils_Ex::isBlank($orderParams['status'])) {
741            $orderParams['status'] = ORDER_NEW;
742        }
743
744        $orderParams['create_date'] = 'Now()';
745        $orderParams['update_date'] = 'Now()';
746
747        $this->registerOrder($orderParams['order_id'], $orderParams);
748
749        // 詳細情報を取得
750        $cartItems = $objCartSession->getCartList($cartKey);
751
752        // 詳細情報を生成
753        $objProduct = new SC_Product_Ex();
754        $i = 0;
755        foreach ($cartItems as $item) {
756            $p =& $item['productsClass'];
757            $arrDetail[$i]['order_id'] = $orderParams['order_id'];
758            $arrDetail[$i]['product_id'] = $p['product_id'];
759            $arrDetail[$i]['product_class_id'] = $p['product_class_id'];
760            $arrDetail[$i]['product_name'] = $p['name'];
761            $arrDetail[$i]['product_code'] = $p['product_code'];
762            $arrDetail[$i]['classcategory_name1'] = $p['classcategory_name1'];
763            $arrDetail[$i]['classcategory_name2'] = $p['classcategory_name2'];
764            $arrDetail[$i]['point_rate'] = $item['point_rate'];
765            $arrDetail[$i]['price'] = $item['price'];
766            $arrDetail[$i]['quantity'] = $item['quantity'];
767
768            // 在庫の減少処理
769            if (!$objProduct->reduceStock($p['product_class_id'], $item['quantity'])) {
770                $objQuery->rollback();
771                SC_Utils_Ex::sfDispSiteError(SOLD_OUT, "", true);
772            }
773            $i++;
774        }
775        $this->registerOrderDetail($orderParams['order_id'], $arrDetail);
776
777        $objQuery->update("dtb_order_temp", array('del_flg' => 1),
778                          "order_temp_id = ?",
779                          array(SC_SiteSession_Ex::getUniqId()));
780
781        return $orderParams['order_id'];
782    }
783
784    /**
785     * 受注情報を登録する.
786     *
787     * 既に受注IDが存在する場合は, 受注情報を更新する.
788     * 引数の受注IDが, 空白又は null の場合は, 新しく受注IDを発行して登録する.
789     *
790     * @param integer $order_id 受注ID
791     * @param array $arrParams 受注情報の連想配列
792     * @return integer 受注ID
793     */
794    function registerOrder($order_id, $arrParams) {
795        $table = 'dtb_order';
796        $where = 'order_id = ?';
797        $objQuery = SC_Query_Ex::getSingletonInstance();
798        $arrValues = $objQuery->extractOnlyColsOf($table, $arrParams);
799
800        $exists = $objQuery->count($table, $where, array($order_id));
801        if ($exists > 0) {
802
803            $this->sfUpdateOrderStatus($order_id, $arrValues['status'],
804                                       $arrValues['add_point'],
805                                       $arrValues['use_point'],
806                                       $arrValues);
807            $this->sfUpdateOrderNameCol($order_id);
808
809            $arrValues['update_date'] = 'now()';
810            $objQuery->update($table, $arrValues, $where, array($order_id));
811        } else {
812            if (SC_Utils_Ex::isBlank($order_id)) {
813                $order_id = $objQuery->nextVal('dtb_order_order_id');
814            }
815            /*
816             * 新規受付の場合は受注ステータス null で insert し,
817             * sfUpdateOrderStatus で ORDER_NEW に変更する.
818             */
819            $status = $arrValues['status'];
820            $arrValues['status'] = null;
821            $arrValues['order_id'] = $order_id;
822            $arrValues['customer_id'] =
823                    SC_Utils_Ex::isBlank($arrValues['customer_id'])
824                    ? 0 : $arrValues['customer_id'];
825            $arrValues['create_date'] = 'now()';
826            $arrValues['update_date'] = 'now()';
827            $objQuery->insert($table, $arrValues);
828
829            $this->sfUpdateOrderStatus($order_id, $status,
830                                       $arrValues['add_point'],
831                                       $arrValues['use_point'],
832                                       $arrValues);
833            $this->sfUpdateOrderNameCol($order_id);
834
835        }
836        return $order_id;
837    }
838
839    /**
840     * 受注詳細情報を登録する.
841     *
842     * 既に, 該当の受注が存在する場合は, 受注情報を削除し, 登録する.
843     *
844     * @param integer $order_id 受注ID
845     * @param array $arrParams 受注情報の連想配列
846     * @return void
847     */
848    function registerOrderDetail($order_id, $arrParams) {
849        $table = 'dtb_order_detail';
850        $where = 'order_id = ?';
851        $objQuery = SC_Query_Ex::getSingletonInstance();
852
853        $objQuery->delete($table, $where, array($order_id));
854        foreach ($arrParams as $arrDetail) {
855            $arrValues = $objQuery->extractOnlyColsOf($table, $arrDetail);
856            $arrValues['order_detail_id'] = $objQuery->nextVal('dtb_order_detail_order_detail_id');
857            $arrValues['order_id'] = $order_id;
858            $objQuery->insert($table, $arrValues);
859        }
860    }
861
862    /**
863     * 受注情報を取得する.
864     *
865     * @param integer $order_id 受注ID
866     * @param integer $customer_id 会員ID
867     * @return array 受注情報の配列
868     */
869    function getOrder($order_id, $customer_id = null) {
870        $objQuery =& SC_Query_Ex::getSingletonInstance();
871        $where = 'order_id = ?';
872        $arrValues = array($order_id);
873        if (!SC_Utils_Ex::isBlank($customer_id)) {
874            $where .= ' AND customer_id = ?';
875            $arrValues[] = $customer_id;
876        }
877        return $objQuery->getRow('*', 'dtb_order', $where, $arrValues);
878    }
879
880    /**
881     * 受注詳細を取得する.
882     *
883     * @param integer $order_id 受注ID
884     * @param boolean $has_order_status 受注ステータス, 入金日も含める場合 true
885     * @return array 受注詳細の配列
886     */
887    function getOrderDetail($order_id, $has_order_status = true) {
888        $objQuery =& SC_Query_Ex::getSingletonInstance();
889        $dbFactory  = SC_DB_DBFactory_Ex::getInstance();
890        $col = <<< __EOS__
891            T3.product_id,
892            T3.product_class_id as product_class_id,
893            T3.product_type_id AS product_type_id,
894            T2.product_code,
895            T2.product_name,
896            T2.classcategory_name1 AS classcategory_name1,
897            T2.classcategory_name2 AS classcategory_name2,
898            T2.price,
899            T2.quantity,
900            T2.point_rate,
901__EOS__;
902        if ($has_order_status) {
903            $col .= 'T1.status AS status, T1.payment_date AS payment_date,';
904
905        }
906        $col .= <<< __EOS__
907
908            CASE WHEN EXISTS(
909                    SELECT * FROM dtb_products
910                     WHERE product_id = T3.product_id
911                       AND del_flg = 0
912                       AND status = 1)
913                 THEN '1' ELSE '0'
914                  END AS enable,
915__EOS__;
916        $col .= $dbFactory->getDownloadableDaysWhereSql('T1') . ' AS effective';
917        $from = <<< __EOS__
918                 dtb_order T1
919            JOIN dtb_order_detail T2
920              ON T1.order_id = T2.order_id
921            JOIN dtb_products_class T3
922              ON T2.product_class_id = T3.product_class_id
923__EOS__;
924        $objQuery->setOrder('T2.order_detail_id');
925        return $objQuery->select($col, $from, 'T1.order_id = ?', array($order_id));
926    }
927
928    /**
929     * ダウンロード可能フラグを, 受注詳細に設定する.
930     *
931     * ダウンロード可能と判断されるのは, 以下の通り.
932     *
933     * 1. ダウンロード可能期限が期限内かつ, 入金日が入力されている
934     * 2. 販売価格が 0 円である
935     *
936     * 受注詳細行には, is_downloadable という真偽値が設定される.
937     * @param array 受注詳細の配列
938     * @return void
939     */
940    function setDownloadableFlgTo(&$arrOrderDetail) {
941        foreach (array_keys($arrOrderDetail) as $key) {
942            // 販売価格が 0 円
943            if ($arrOrderDetail[$key]['price'] == '0') {
944                $arrOrderDetail[$key]['is_downloadable'] = true;
945            }
946            // ダウンロード期限内かつ, 入金日あり
947            elseif ($arrOrderDetail[$key]['effective'] == '1'
948                    && !SC_Utils_Ex::isBlank($arrOrderDetail[$key]['payment_date'])) {
949                $arrOrderDetail[$key]['is_downloadable'] = true;
950            } else {
951                $arrOrderDetail[$key]['is_downloadable'] = false;
952            }
953        }
954    }
955
956    /**
957     * 配送情報を取得する.
958     *
959     * @param integer $order_id 受注ID
960     * @param boolean $has_items 結果に配送商品も含める場合 true
961     * @return array 配送情報の配列
962     */
963    function getShippings($order_id, $has_items = true) {
964        $objQuery =& SC_Query_Ex::getSingletonInstance();
965        $arrResults = array();
966        $objQuery->setOrder('shipping_id');
967        $arrShippings = $objQuery->select("*", "dtb_shipping", "order_id = ?",
968                                          array($order_id));
969        // shipping_id ごとの配列を生成する
970        foreach ($arrShippings as $shipping) {
971            foreach ($shipping as $key => $val) {
972                $arrResults[$shipping['shipping_id']][$key] = $val;
973            }
974        }
975
976        if ($has_items) {
977            $objProduct = new SC_Product_Ex();
978            foreach (array_keys($arrResults) as $shipping_id) {
979                $arrResults[$shipping_id]['shipment_item']
980                        =& $this->getShipmentItems($order_id, $shipping_id);
981            }
982        }
983        return $arrResults;
984    }
985
986    /**
987     * 配送商品を取得する.
988     *
989     * @param integer $order_id 受注ID
990     * @param integer $shipping_id 配送先ID
991     * @param boolean $has_detail 商品詳細も取得する場合 true
992     * @return array 商品規格IDをキーにした配送商品の配列
993     */
994    function getShipmentItems($order_id, $shipping_id, $has_detail = true) {
995        $objQuery =& SC_Query_Ex::getSingletonInstance();
996        $objProduct = new SC_Product_Ex();
997        $arrResults = array();
998        $arrItems = $objQuery->select("*", "dtb_shipment_item",
999                                      "order_id = ? AND shipping_id = ?",
1000                                      array($order_id, $shipping_id));
1001
1002        foreach ($arrItems as $key => $arrItem) {
1003            $product_class_id = $arrItem['product_class_id'];
1004
1005            foreach ($arrItem as $detailKey => $detailVal) {
1006                $arrResults[$key][$detailKey] = $detailVal;
1007            }
1008            // 商品詳細を関連づける
1009            if ($has_detail) {
1010                $arrResults[$key]['productsClass']
1011                    =& $objProduct->getDetailAndProductsClass($product_class_id);
1012            }
1013        }
1014        return $arrResults;
1015    }
1016
1017    /**
1018     * 受注完了メールを送信する.
1019     *
1020     * HTTP_USER_AGENT の種別により, 携帯電話の場合は携帯用の文面,
1021     * PC の場合は PC 用の文面でメールを送信する.
1022     *
1023     * @param integer $orderId 受注ID
1024     * @return void
1025     */
1026    function sendOrderMail($orderId) {
1027        $mailHelper = new SC_Helper_Mail_Ex();
1028        $mailHelper->sfSendOrderMail($orderId,
1029                                     SC_MobileUserAgent_Ex::isMobile() ? 2 : 1);
1030    }
1031
1032    /**
1033     * 受注.対応状況の更新
1034     *
1035     * 必ず呼び出し元でトランザクションブロックを開いておくこと。
1036     *
1037     * @param integer $orderId 注文番号
1038     * @param integer|null $newStatus 対応状況 (null=変更無し)
1039     * @param integer|null $newAddPoint 加算ポイント (null=変更無し)
1040     * @param integer|null $newUsePoint 使用ポイント (null=変更無し)
1041     * @param array $sqlval 更新後の値をリファレンスさせるためのパラメーター
1042     * @return void
1043     */
1044    function sfUpdateOrderStatus($orderId, $newStatus = null, $newAddPoint = null, $newUsePoint = null, &$sqlval) {
1045        $objQuery =& SC_Query_Ex::getSingletonInstance();
1046
1047        $arrOrderOld = $objQuery->getRow('status, add_point, use_point, customer_id', 'dtb_order', 'order_id = ?', array($orderId));
1048
1049        // 対応状況が変更無しの場合、DB値を引き継ぐ
1050        if (is_null($newStatus)) {
1051            $newStatus = $arrOrderOld['status'];
1052        }
1053
1054        // 使用ポイント、DB値を引き継ぐ
1055        if (is_null($newUsePoint)) {
1056            $newUsePoint = $arrOrderOld['use_point'];
1057        }
1058
1059        // 加算ポイント、DB値を引き継ぐ
1060        if (is_null($newAddPoint)) {
1061            $newAddPoint = $arrOrderOld['add_point'];
1062        }
1063
1064        if (USE_POINT !== false) {
1065            // 会員.ポイントの加減値
1066            $addCustomerPoint = 0;
1067
1068            // ▼使用ポイント
1069            // 変更前の対応状況が利用対象の場合、変更前の使用ポイント分を戻す
1070            if ($this->isUsePoint($arrOrderOld['status'])) {
1071                $addCustomerPoint += $arrOrderOld['use_point'];
1072            }
1073
1074            // 変更後の対応状況が利用対象の場合、変更後の使用ポイント分を引く
1075            if ($this->isUsePoint($newStatus)) {
1076                $addCustomerPoint -= $newUsePoint;
1077            }
1078
1079            // ▲使用ポイント
1080
1081            // ▼加算ポイント
1082            // 変更前の対応状況が加算対象の場合、変更前の加算ポイント分を戻す
1083            if ($this->isAddPoint($arrOrderOld['status'])) {
1084                $addCustomerPoint -= $arrOrderOld['add_point'];
1085            }
1086
1087            // 変更後の対応状況が加算対象の場合、変更後の加算ポイント分を足す
1088            if ($this->isAddPoint($newStatus)) {
1089                $addCustomerPoint += $newAddPoint;
1090            }
1091            // ▲加算ポイント
1092
1093            if ($addCustomerPoint != 0) {
1094                // ▼会員テーブルの更新
1095                $sqlval = array();
1096                $where = '';
1097                $arrVal = array();
1098                $arrRawSql = array();
1099                $arrRawSqlVal = array();
1100
1101                $sqlval['update_date'] = 'Now()';
1102                $arrRawSql['point'] = 'point + ?';
1103                $arrRawSqlVal[] = $addCustomerPoint;
1104                $where .= 'customer_id = ?';
1105                $arrVal[] = $arrOrderOld['customer_id'];
1106
1107                $objQuery->update('dtb_customer', $sqlval, $where, $arrVal, $arrRawSql, $arrRawSqlVal);
1108                // ▲会員テーブルの更新
1109
1110                // 会員.ポイントをマイナスした場合、
1111                if ($addCustomerPoint < 0) {
1112                    $sql = 'SELECT point FROM dtb_customer WHERE customer_id = ?';
1113                    $point = $objQuery->getOne($sql, array($arrOrderOld['customer_id']));
1114                    // 変更後の会員.ポイントがマイナスの場合、
1115                    if ($point < 0) {
1116                        // ロールバック
1117                        $objQuery->rollback();
1118                        // エラー
1119                        SC_Utils_Ex::sfDispSiteError(LACK_POINT);
1120                    }
1121                }
1122            }
1123        }
1124
1125        // ▼受注テーブルの更新
1126        if (empty($sqlval)) {
1127            $sqlval = array();
1128        }
1129
1130        if (USE_POINT !== false) {
1131            $sqlval['add_point'] = $newAddPoint;
1132            $sqlval['use_point'] = $newUsePoint;
1133        }
1134        // ステータスが発送済みに変更の場合、発送日を更新
1135        if ($arrOrderOld['status'] != ORDER_DELIV && $newStatus == ORDER_DELIV) {
1136            $sqlval['commit_date'] = 'Now()';
1137        }
1138        // ステータスが入金済みに変更の場合、入金日を更新
1139        elseif ($arrOrderOld['status'] != ORDER_PRE_END && $newStatus == ORDER_PRE_END) {
1140            $sqlval['payment_date'] = 'Now()';
1141        }
1142
1143        $sqlval['status'] = $newStatus;
1144        $sqlval['update_date'] = 'Now()';
1145
1146        $dest = $objQuery->extractOnlyColsOf('dtb_order', $sqlval);
1147        $objQuery->update('dtb_order', $dest, 'order_id = ?', array($orderId));
1148        // ▲受注テーブルの更新
1149    }
1150
1151    /**
1152     * 受注の名称列を更新する
1153     *
1154     * @param integer $order_id 更新対象の注文番号
1155     * @param boolean $temp_table 更新対象は「受注_Temp」か
1156     * @static
1157     */
1158    function sfUpdateOrderNameCol($order_id, $temp_table = false) {
1159        $objQuery =& SC_Query_Ex::getSingletonInstance();
1160
1161        if ($temp_table) {
1162            $tgt_table = 'dtb_order_temp';
1163            $sql_where = 'order_temp_id = ?';
1164        } else {
1165            $tgt_table = 'dtb_order';
1166            $sql_where = 'order_id = ?';
1167
1168            $objQuery->update('dtb_shipping', array(),
1169                              $sql_where,
1170                              array($order_id),
1171                              array('shipping_time' =>
1172                                    "(SELECT deliv_time FROM dtb_delivtime WHERE time_id = dtb_shipping.time_id AND deliv_id = dtb_shipping.deliv_id)"));
1173
1174        }
1175
1176        $objQuery->update($tgt_table, array(),
1177                          $sql_where,
1178                          array($order_id),
1179                          array('payment_method' =>
1180                                "(SELECT payment_method FROM dtb_payment WHERE payment_id = " . $tgt_table . ".payment_id)"));
1181    }
1182
1183    /**
1184     * ポイント使用するかの判定
1185     *
1186     * $status が null の場合は false を返す.
1187     *
1188     * @param integer $status 対応状況
1189     * @return boolean 使用するか(会員テーブルから減算するか)
1190     */
1191    function isUsePoint($status) {
1192        if ($status == null) {
1193            return false;
1194        }
1195        switch ($status) {
1196            case ORDER_CANCEL:      // キャンセル
1197                return false;
1198            default:
1199                break;
1200        }
1201
1202        return true;
1203    }
1204
1205    /**
1206     * ポイント加算するかの判定
1207     *
1208     * @param integer $status 対応状況
1209     * @return boolean 加算するか
1210     */
1211    function isAddPoint($status) {
1212        switch ($status) {
1213            case ORDER_NEW:         // 新規注文
1214            case ORDER_PAY_WAIT:    // 入金待ち
1215            case ORDER_PRE_END:     // 入金済み
1216            case ORDER_CANCEL:      // キャンセル
1217            case ORDER_BACK_ORDER:  // 取り寄せ中
1218                return false;
1219
1220            case ORDER_DELIV:       // 発送済み
1221                return true;
1222
1223            default:
1224                break;
1225        }
1226
1227        return false;
1228    }
1229
1230    /**
1231     * セッションに保持している情報を破棄する.
1232     *
1233     * 通常、受注処理(completeOrder)完了後に呼び出され、
1234     * セッション情報を破棄する.
1235     *
1236     * 決済モジュール画面から確認画面に「戻る」場合を考慮し、
1237     * セッション情報を破棄しないカスタマイズを、モジュール側で
1238     * 加える機会を与える.
1239     *
1240     * @param integer $orderId 注文番号
1241     * @param SC_CartSession $objCartSession カート情報のインスタンス
1242     * @param SC_Customer $objCustomer SC_Customer インスタンス
1243     * @param integer $cartKey 登録を行うカート情報のキー
1244     */
1245    function cleanupSession($orderId, &$objCartSession, &$objCustomer, $cartKey) {
1246        // カートの内容を削除する.
1247        $objCartSession->delAllProducts($cartKey);
1248        SC_SiteSession_Ex::unsetUniqId();
1249
1250        // セッションの配送情報を破棄する.
1251        $this->unsetShippingTemp();
1252        $objCustomer->updateSession();
1253    }
1254}
Note: See TracBrowser for help on using the repository browser.