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

Revision 20835, 45.8 KB checked in by nanasess, 13 years ago (diff)

#854 (PHP4 対応)

  • 参照渡しを修正
  • 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     * @param integer $product_class_id 商品規格ID
295     * @param integer $quantity 数量
296     * @return void
297     */
298    function setShipmentItemTemp($shipping_id, $product_class_id, $quantity) {
299        // 配列が長くなるので, リファレンスを使用する
300        $arrItems =& $_SESSION['shipping'][$shipping_id]['shipment_item'];
301
302        $arrItems[$product_class_id]['shipping_id'] = $shipping_id;
303        $arrItems[$product_class_id]['product_class_id'] = $product_class_id;
304        $arrItems[$product_class_id]['quantity'] = $quantity;
305
306        $objProduct = new SC_Product_Ex();
307        if (empty($arrItems[$product_class_id]['productsClass'])) {
308            $product =& $objProduct->getDetailAndProductsClass($product_class_id);
309            $arrItems[$product_class_id]['productsClass'] = $product;
310        }
311        $incTax = SC_Helper_DB_Ex::sfCalcIncTax($arrItems[$product_class_id]['productsClass']['price02']);
312        $arrItems[$product_class_id]['total_inctax'] = $incTax * $arrItems[$product_class_id]['quantity'];
313    }
314
315    /**
316     * 配送商品の情報でカートを更新する.
317     *
318     * @param SC_CartSession $objCartSession SC_CartSession インスタンス
319     */
320    function shippingItemTempToCart(&$objCartSession) {
321        $arrShipmentItems = array();
322        foreach (array_keys($_SESSION['shipping']) as $shipping_id) {
323            foreach (array_keys($_SESSION['shipping'][$shipping_id]['shipment_item']) as $product_class_id) {
324                $arrShipmentItems[$product_class_id] += $_SESSION['shipping'][$shipping_id]['shipment_item'][$product_class_id]['quantity'];
325           }
326        }
327        foreach ($arrShipmentItems as $product_class_id => $quantity) {
328            $objCartSession->setProductValue($product_class_id, 'quantity',
329                                             $quantity,$objCartSession->getKey());
330        }
331    }
332
333    /**
334     * 配送先都道府県の配列を返す.
335     */
336    function getShippingPref() {
337        $results = array();
338        foreach ($_SESSION['shipping'] as $val) {
339            $results[] = $val['shipping_pref'];
340        }
341        return $results;
342    }
343
344    /**
345     * 複数配送指定の購入かどうか.
346     *
347     * @return boolean 複数配送指定の購入の場合 true
348     */
349    function isMultiple() {
350        return count($this->getShippingTemp()) > 1;
351    }
352
353    /**
354     * 配送情報をセッションに保存する.
355     *
356     * @param array $arrSrc 配送情報の連想配列
357     * @param integer $shipping_id 配送先ID
358     * @return void
359     */
360    function saveShippingTemp(&$arrSrc, $shipping_id = 0) {
361        if (empty($_SESSION['shipping'][$shipping_id])) {
362            $_SESSION['shipping'][$shipping_id] = $arrSrc;
363            $_SESSION['shipping'][$shipping_id]['shipping_id'] = $shipping_id;
364        } else {
365            $_SESSION['shipping'][$shipping_id] = array_merge($_SESSION['shipping'][$shipping_id], $arrSrc);
366            $_SESSION['shipping'][$shipping_id]['shipping_id'] = $shipping_id;
367        }
368    }
369
370    /**
371     * セッションの配送情報を破棄する.
372     */
373    function unsetShippingTemp() {
374        unset($_SESSION['shipping']);
375        unset($_SESSION['multiple_temp']);
376    }
377
378    /**
379     * 会員情報を受注情報にコピーする.
380     *
381     * ユーザーがログインしていない場合は何もしない.
382     * 会員情報を $dest の order_* へコピーする.
383     * customer_id は強制的にコピーされる.
384     *
385     * @param array $dest コピー先の配列
386     * @param SC_Customer $objCustomer SC_Customer インスタンス
387     * @param string $prefix コピー先の接頭辞. デフォルト order
388     * @param array $keys コピー対象のキー
389     * @return void
390     */
391    function copyFromCustomer(&$dest, &$objCustomer, $prefix = 'order',
392                              $keys = array('name01', 'name02', 'kana01', 'kana02',
393                                            'sex', 'zip01', 'zip02', 'pref',
394                                            'addr01', 'addr02',
395                                            'tel01', 'tel02', 'tel03', 'job',
396                                            'birth', 'email')) {
397        if ($objCustomer->isLoginSuccess(true)) {
398
399            foreach ($keys as $key) {
400                if (in_array($key, $keys)) {
401                    $dest[$prefix . '_' . $key] = $objCustomer->getValue($key);
402                }
403            }
404
405            if (Net_UserAgent_Mobile::isMobile()
406                && in_array('email', $keys)) {
407                $email_mobile = $objCustomer->getValue('email_mobile');
408                if (empty($email_mobile)) {
409                    $dest[$prefix . '_email'] = $objCustomer->getValue('email');
410                } else {
411                    $dest[$prefix . '_email'] = $email_mobile;
412                }
413            }
414
415            $dest['customer_id'] = $objCustomer->getValue('customer_id');
416            $dest['update_date'] = 'Now()';
417        }
418    }
419
420    /**
421     * 受注情報を配送情報にコピーする.
422     *
423     * 受注情報($src)を $dest の order_* へコピーする.
424     *
425     * TODO 汎用的にして SC_Utils へ移動
426     *
427     * @param array $dest コピー先の配列
428     * @param array $src コピー元の配列
429     * @param array $keys コピー対象のキー
430     * @param string $prefix コピー先の接頭辞. デフォルト shipping
431     * @param string $src_prefix コピー元の接頭辞. デフォルト order
432     * @return void
433     */
434    function copyFromOrder(&$dest, $src,
435                           $prefix = 'shipping', $src_prefix = 'order',
436                           $keys = array('name01', 'name02', 'kana01', 'kana02',
437                                         'sex', 'zip01', 'zip02', 'pref',
438                                         'addr01', 'addr02',
439                                         'tel01', 'tel02', 'tel03')) {
440        if (!SC_Utils_Ex::isBlank($prefix)) {
441            $prefix = $prefix . '_';
442        }
443        if (!SC_Utils_Ex::isBlank($src_prefix)) {
444            $src_prefix = $src_prefix . '_';
445        }
446        foreach ($keys as $key) {
447            if (in_array($key, $keys)) {
448                $dest[$prefix . $key] = $src[$src_prefix . $key];
449            }
450        }
451    }
452
453    /**
454     * 購入金額に応じた支払方法を取得する.
455     *
456     * @param integer $total 購入金額
457     * @param integer $deliv_id 配送業者ID
458     * @return array 購入金額に応じた支払方法の配列
459     */
460    function getPaymentsByPrice($total, $deliv_id) {
461
462        $arrPaymentIds = $this->getPayments($deliv_id);
463        if (SC_Utils_Ex::isBlank($arrPaymentIds)) {
464            return array();
465        }
466
467        $objQuery =& SC_Query_Ex::getSingletonInstance();
468
469        // 削除されていない支払方法を取得
470        $where = 'del_flg = 0 AND payment_id IN (' . implode(', ', array_pad(array(), count($arrPaymentIds), '?')) . ')';
471        $objQuery->setOrder("rank DESC");
472        $payments = $objQuery->select("payment_id, payment_method, rule, upper_rule, note, payment_image, charge", "dtb_payment", $where, $arrPaymentIds);
473        foreach ($payments as $data) {
474            // 下限と上限が設定されている
475            if (strlen($data['rule']) != 0 && strlen($data['upper_rule']) != 0) {
476                if ($data['rule'] <= $total && $data['upper_rule'] >= $total) {
477                    $arrPayment[] = $data;
478                }
479            }
480            // 下限のみ設定されている
481            elseif (strlen($data['rule']) != 0) {
482                if($data['rule'] <= $total) {
483                    $arrPayment[] = $data;
484                }
485            }
486            // 上限のみ設定されている
487            elseif (strlen($data['upper_rule']) != 0) {
488                if($data['upper_rule'] >= $total) {
489                    $arrPayment[] = $data;
490                }
491            }
492            // いずれも設定なし
493            else {
494                $arrPayment[] = $data;
495            }
496          }
497        return $arrPayment;
498    }
499
500    /**
501     * お届け日一覧を取得する.
502     */
503    function getDelivDate(&$objCartSess, $productTypeId) {
504        $cartList = $objCartSess->getCartList($productTypeId);
505        $delivDateIds = array();
506        foreach ($cartList as $item) {
507            $delivDateIds[] = $item['productsClass']['deliv_date_id'];
508        }
509        $max_date = max($delivDateIds);
510        //発送目安
511        switch($max_date) {
512        //即日発送
513        case '1':
514            $start_day = 1;
515            break;
516            //1-2日後
517        case '2':
518            $start_day = 3;
519            break;
520            //3-4日後
521        case '3':
522            $start_day = 5;
523            break;
524            //1週間以内
525        case '4':
526            $start_day = 8;
527            break;
528            //2週間以内
529        case '5':
530            $start_day = 15;
531            break;
532            //3週間以内
533        case '6':
534            $start_day = 22;
535            break;
536            //1ヶ月以内
537        case '7':
538            $start_day = 32;
539            break;
540            //2ヶ月以降
541        case '8':
542            $start_day = 62;
543            break;
544            //お取り寄せ(商品入荷後)
545        case '9':
546            $start_day = "";
547            break;
548        default:
549            //お届け日が設定されていない場合
550            $start_day = "";
551        }
552        //お届け可能日のスタート値から、お届け日の配列を取得する
553        $arrDelivDate = $this->getDateArray($start_day, DELIV_DATE_END_MAX);
554        return $arrDelivDate;
555    }
556
557    /**
558     * お届け可能日のスタート値から, お届け日の配列を取得する.
559     */
560    function getDateArray($start_day, $end_day) {
561        $masterData = new SC_DB_MasterData();
562        $arrWDAY = $masterData->getMasterData("mtb_wday");
563        //お届け可能日のスタート値がセットされていれば
564        if($start_day >= 1) {
565            $now_time = time();
566            $max_day = $start_day + $end_day;
567            // 集計
568            for ($i = $start_day; $i < $max_day; $i++) {
569                // 基本時間から日数を追加していく
570                $tmp_time = $now_time + ($i * 24 * 3600);
571                list($y, $m, $d, $w) = explode(" ", date("Y m d w", $tmp_time));
572                $val = sprintf("%04d/%02d/%02d(%s)", $y, $m, $d, $arrWDAY[$w]);
573                $arrDate[$val] = $val;
574            }
575        } else {
576            $arrDate = false;
577        }
578        return $arrDate;
579    }
580
581    /**
582     * 配送業者IDからお届け時間の配列を取得する.
583     *
584     * @param integer $deliv_id 配送業者ID
585     * @return array お届け時間の配列
586     */
587    function getDelivTime($deliv_id) {
588        $objQuery =& SC_Query_Ex::getSingletonInstance();
589        $objQuery->setOrder('time_id');
590        $results = $objQuery->select('time_id, deliv_time',
591                                     'dtb_delivtime',
592                                     'deliv_id = ?', array($deliv_id));
593        $arrDelivTime = array();
594        foreach ($results as $val) {
595            $arrDelivTime[$val['time_id']] = $val['deliv_time'];
596        }
597        return $arrDelivTime;
598    }
599
600    /**
601     * 商品種別ID から配送業者を取得する.
602     *
603     * @param integer $product_type_id 商品種別ID
604     * @return array 配送業者の配列
605     */
606    function getDeliv($product_type_id) {
607        $objQuery =& SC_Query_Ex::getSingletonInstance();
608        $objQuery->setOrder('rank DESC');
609        return $objQuery->select('*', 'dtb_deliv', 'product_type_id = ? AND del_flg = 0',
610                                 array($product_type_id));
611    }
612
613    /**
614     * 配送業者ID から, 有効な支払方法IDを取得する.
615     *
616     * @param integer $deliv_id 配送業者ID
617     * @return array 有効な支払方法IDの配列
618     */
619    function getPayments($deliv_id) {
620        $objQuery =& SC_Query_Ex::getSingletonInstance();
621        $objQuery->setOrder('rank');
622        return $objQuery->getCol('payment_id', 'dtb_payment_options',
623                                 'deliv_id = ?',
624                                 array($deliv_id), MDB2_FETCHMODE_ORDERED);
625    }
626
627    /**
628     * 配送情報の登録を行う.
629     *
630     * $arrParam のうち, dtb_shipping テーブルに存在するカラムのみを登録する.
631     *
632     * TODO UPDATE/INSERT にする
633     *
634     * @param integer $order_id 受注ID
635     * @param array $arrParams 配送情報の連想配列
636     * @param boolean $convert_shipping_date yyyy/mm/dd(EEE) 形式の配送日付を変換する場合 true
637     * @return void
638     */
639    function registerShipping($order_id, $arrParams, $convert_shipping_date = true) {
640        $objQuery =& SC_Query_Ex::getSingletonInstance();
641        $table = 'dtb_shipping';
642        $where = 'order_id = ?';
643        $objQuery->delete($table, $where, array($order_id));
644
645         foreach ($arrParams as $key => $arrShipping) {
646
647            $arrValues = $objQuery->extractOnlyColsOf($table, $arrShipping);
648
649            // 配送日付を timestamp に変換
650            if (!SC_Utils_Ex::isBlank($arrValues['shipping_date'])
651                && $convert_shipping_date) {
652                $d = mb_strcut($arrValues["shipping_date"], 0, 10);
653                $arrDate = explode("/", $d);
654                $ts = mktime(0, 0, 0, $arrDate[1], $arrDate[2], $arrDate[0]);
655                $arrValues['shipping_date'] = date("Y-m-d", $ts);
656            }
657
658            // 非会員購入の場合は shipping_id が存在しない
659            if (!isset($arrValues['shipping_id'])) {
660                $arrValues['shipping_id'] = $key;
661            }
662            $arrValues['order_id'] = $order_id;
663            $arrValues['create_date'] = 'Now()';
664            $arrValues['update_date'] = 'Now()';
665            $objQuery->insert($table, $arrValues);
666        }
667    }
668
669    /**
670     * 配送商品を登録する.
671     *
672     * @param integer $order_id 受注ID
673     * @param integer $shipping_id 配送先ID
674     * @param array $arrParams 配送商品の配列
675     * @return void
676     */
677    function registerShipmentItem($order_id, $shipping_id, $arrParams) {
678        $objQuery =& SC_Query_Ex::getSingletonInstance();
679        $table = 'dtb_shipment_item';
680        $where = 'order_id = ? AND shipping_id = ?';
681        $objQuery->delete($table, $where, array($order_id, $shipping_id));
682
683        $objProduct = new SC_Product_Ex();
684        foreach ($arrParams as $arrValues) {
685            if (SC_Utils_Ex::isBlank($arrValues['product_class_id'])) {
686                continue;
687            }
688            $d = $objProduct->getDetailAndProductsClass($arrValues['product_class_id']);
689            $name = SC_Utils_Ex::isBlank($arrValues['product_name'])
690                ? $d['name']
691                : $arrValues['product_name'];
692
693            $code = SC_Utils_Ex::isBlank($arrValues['product_code'])
694                ? $d['product_code']
695                : $arrValues['product_code'];
696
697            $cname1 = SC_Utils_Ex::isBlank($arrValues['classcategory_name1'])
698                ? $d['classcategory_name1']
699                : $arrValues['classcategory_name1'];
700
701            $cname2 = SC_Utils_Ex::isBlank($arrValues['classcategory_name2'])
702                ? $d['classcategory_name2']
703                : $arrValues['classcategory_name2'];
704
705            $price = SC_Utils_Ex::isBlank($arrValues['price'])
706                ? $d['price02']
707                : $arrValues['price'];
708
709            $arrValues['order_id'] = $order_id;
710            $arrValues['shipping_id'] = $shipping_id;
711            $arrValues['product_name'] = $name;
712            $arrValues['product_code'] = $code;
713            $arrValues['classcategory_name1'] = $cname1;
714            $arrValues['classcategory_name2'] = $cname2;
715            $arrValues['price'] = $price;
716
717            $arrExtractValues = $objQuery->extractOnlyColsOf($table, $arrValues);
718            $objQuery->insert($table, $arrExtractValues);
719        }
720    }
721
722    /**
723     * 受注登録を完了する.
724     *
725     * 引数の受注情報を受注テーブル及び受注詳細テーブルに登録する.
726     * 登録後, 受注一時テーブルに削除フラグを立てる.
727     *
728     * @param array $orderParams 登録する受注情報の配列
729     * @param SC_CartSession $objCartSession カート情報のインスタンス
730     * @param integer $cartKey 登録を行うカート情報のキー
731     * @param integer 受注ID
732     */
733    function registerOrderComplete($orderParams, &$objCartSession, $cartKey) {
734        $objQuery =& SC_Query_Ex::getSingletonInstance();
735
736        // 不要な変数を unset
737        $unsets = array('mailmaga_flg', 'deliv_check', 'point_check', 'password',
738                        'reminder', 'reminder_answer', 'mail_flag', 'session');
739        foreach ($unsets as $unset) {
740            unset($orderParams[$unset]);
741        }
742
743        // 注文ステータスの指定が無い場合は新規受付
744        if(SC_Utils_Ex::isBlank($orderParams['status'])) {
745            $orderParams['status'] = ORDER_NEW;
746        }
747
748        $orderParams['create_date'] = 'Now()';
749        $orderParams['update_date'] = 'Now()';
750
751        $this->registerOrder($orderParams['order_id'], $orderParams);
752
753        // 詳細情報を取得
754        $cartItems = $objCartSession->getCartList($cartKey);
755
756        // 詳細情報を生成
757        $objProduct = new SC_Product_Ex();
758        $i = 0;
759        foreach ($cartItems as $item) {
760            $p =& $item['productsClass'];
761            $arrDetail[$i]['order_id'] = $orderParams['order_id'];
762            $arrDetail[$i]['product_id'] = $p['product_id'];
763            $arrDetail[$i]['product_class_id'] = $p['product_class_id'];
764            $arrDetail[$i]['product_name'] = $p['name'];
765            $arrDetail[$i]['product_code'] = $p['product_code'];
766            $arrDetail[$i]['classcategory_name1'] = $p['classcategory_name1'];
767            $arrDetail[$i]['classcategory_name2'] = $p['classcategory_name2'];
768            $arrDetail[$i]['point_rate'] = $item['point_rate'];
769            $arrDetail[$i]['price'] = $item['price'];
770            $arrDetail[$i]['quantity'] = $item['quantity'];
771
772            // 在庫の減少処理
773            if (!$objProduct->reduceStock($p['product_class_id'], $item['quantity'])) {
774                $objQuery->rollback();
775                SC_Utils_Ex::sfDispSiteError(SOLD_OUT, "", true);
776            }
777            $i++;
778        }
779        $this->registerOrderDetail($orderParams['order_id'], $arrDetail);
780
781        $objQuery->update("dtb_order_temp", array('del_flg' => 1),
782                          "order_temp_id = ?",
783                          array(SC_SiteSession_Ex::getUniqId()));
784
785        return $orderParams['order_id'];
786    }
787
788    /**
789     * 受注情報を登録する.
790     *
791     * 既に受注IDが存在する場合は, 受注情報を更新する.
792     * 引数の受注IDが, 空白又は null の場合は, 新しく受注IDを発行して登録する.
793     *
794     * @param integer $order_id 受注ID
795     * @param array $arrParams 受注情報の連想配列
796     * @return integer 受注ID
797     */
798    function registerOrder($order_id, $arrParams) {
799        $table = 'dtb_order';
800        $where = 'order_id = ?';
801        $objQuery = SC_Query_Ex::getSingletonInstance();
802        $arrValues = $objQuery->extractOnlyColsOf($table, $arrParams);
803
804        $exists = $objQuery->count($table, $where, array($order_id));
805        if ($exists > 0) {
806
807            $this->sfUpdateOrderStatus($order_id, $arrValues['status'],
808                                       $arrValues['add_point'],
809                                       $arrValues['use_point'],
810                                       $arrValues);
811            $this->sfUpdateOrderNameCol($order_id);
812
813            $arrValues['update_date'] = 'now()';
814            $objQuery->update($table, $arrValues, $where, array($order_id));
815        } else {
816            if (SC_Utils_Ex::isBlank($order_id)) {
817                $order_id = $objQuery->nextVal('dtb_order_order_id');
818            }
819            /*
820             * 新規受付の場合は受注ステータス null で insert し,
821             * sfUpdateOrderStatus で ORDER_NEW に変更する.
822             */
823            $status = $arrValues['status'];
824            $arrValues['status'] = null;
825            $arrValues['order_id'] = $order_id;
826            $arrValues['customer_id'] =
827                    SC_Utils_Ex::isBlank($arrValues['customer_id'])
828                    ? 0 : $arrValues['customer_id'];
829            $arrValues['create_date'] = 'now()';
830            $arrValues['update_date'] = 'now()';
831            $objQuery->insert($table, $arrValues);
832
833            $this->sfUpdateOrderStatus($order_id, $status,
834                                       $arrValues['add_point'],
835                                       $arrValues['use_point'],
836                                       $arrValues);
837            $this->sfUpdateOrderNameCol($order_id);
838
839        }
840        return $order_id;
841    }
842
843    /**
844     * 受注詳細情報を登録する.
845     *
846     * 既に, 該当の受注が存在する場合は, 受注情報を削除し, 登録する.
847     *
848     * @param integer $order_id 受注ID
849     * @param array $arrParams 受注情報の連想配列
850     * @return void
851     */
852    function registerOrderDetail($order_id, $arrParams) {
853        $table = 'dtb_order_detail';
854        $where = 'order_id = ?';
855        $objQuery = SC_Query_Ex::getSingletonInstance();
856
857        $objQuery->delete($table, $where, array($order_id));
858        foreach ($arrParams as $arrDetail) {
859            $arrValues = $objQuery->extractOnlyColsOf($table, $arrDetail);
860            $arrValues['order_detail_id'] = $objQuery->nextVal('dtb_order_detail_order_detail_id');
861            $arrValues['order_id'] = $order_id;
862            $objQuery->insert($table, $arrValues);
863        }
864    }
865
866    /**
867     * 受注情報を取得する.
868     *
869     * @param integer $order_id 受注ID
870     * @param integer $customer_id 顧客ID
871     * @return array 受注情報の配列
872     */
873    function getOrder($order_id, $customer_id = null) {
874        $objQuery =& SC_Query_Ex::getSingletonInstance();
875        $where = 'order_id = ?';
876        $arrValues = array($order_id);
877        if (!SC_Utils_Ex::isBlank($customer_id)) {
878            $where .= ' AND customer_id = ?';
879            $arrValues[] = $customer_id;
880        }
881        return $objQuery->getRow('*', 'dtb_order', $where, $arrValues);
882    }
883
884    /**
885     * 受注詳細を取得する.
886     *
887     * @param integer $order_id 受注ID
888     * @param boolean $has_order_status 受注ステータス, 入金日も含める場合 true
889     * @return array 受注詳細の配列
890     */
891    function getOrderDetail($order_id, $has_order_status = true) {
892        $objQuery =& SC_Query_Ex::getSingletonInstance();
893        $dbFactory  = SC_DB_DBFactory_Ex::getInstance();
894        $col = <<< __EOS__
895            T3.product_id,
896            T3.product_class_id as product_class_id,
897            T3.product_type_id AS product_type_id,
898            T2.product_code,
899            T2.product_name,
900            T2.classcategory_name1 AS classcategory_name1,
901            T2.classcategory_name2 AS classcategory_name2,
902            T2.price,
903            T2.quantity,
904            T2.point_rate,
905__EOS__;
906        if ($has_order_status) {
907            $col .= 'T1.status AS status, T1.payment_date AS payment_date,';
908
909        }
910        $col .= <<< __EOS__
911
912            CASE WHEN EXISTS(
913                    SELECT 1 FROM dtb_products
914                     WHERE product_id = T3.product_id
915                       AND del_flg = 0
916                       AND status = 1)
917                 THEN '1' ELSE '0'
918                  END AS enable,
919__EOS__;
920        $col .= $dbFactory->getDownloadableDaysWhereSql('T1') . ' AS effective';
921        $from = <<< __EOS__
922                 dtb_order T1
923            JOIN dtb_order_detail T2
924              ON T1.order_id = T2.order_id
925            JOIN dtb_products_class T3
926              ON T2.product_class_id = T3.product_class_id
927__EOS__;
928        $objQuery->setOrder('T2.order_detail_id');
929        return $objQuery->select($col, $from, 'T1.order_id = ?', array($order_id));
930    }
931
932    /**
933     * 配送情報を取得する.
934     *
935     * @param integer $order_id 受注ID
936     * @param boolean $has_items 結果に配送商品も含める場合 true
937     * @return array 配送情報の配列
938     */
939    function getShippings($order_id, $has_items = true) {
940        $objQuery =& SC_Query_Ex::getSingletonInstance();
941        $arrResults = array();
942        $objQuery->setOrder('shipping_id');
943        $arrShippings = $objQuery->select("*", "dtb_shipping", "order_id = ?",
944                                          array($order_id));
945        // shipping_id ごとの配列を生成する
946        foreach ($arrShippings as $shipping) {
947            foreach ($shipping as $key => $val) {
948                $arrResults[$shipping['shipping_id']][$key] = $val;
949            }
950        }
951
952        if ($has_items) {
953            $objProduct = new SC_Product_Ex();
954            foreach (array_keys($arrResults) as $shipping_id) {
955                $arrResults[$shipping_id]['shipment_item']
956                        =& $this->getShipmentItems($order_id, $shipping_id);
957            }
958        }
959        return $arrResults;
960    }
961
962    /**
963     * 配送商品を取得する.
964     *
965     * @param integer $order_id 受注ID
966     * @param integer $shipping_id 配送先ID
967     * @param boolean $has_detail 商品詳細も取得する場合 true
968     * @return array 商品規格IDをキーにした配送商品の配列
969     */
970    function getShipmentItems($order_id, $shipping_id, $has_detail = true) {
971        $objQuery =& SC_Query_Ex::getSingletonInstance();
972        $objProduct = new SC_Product_Ex();
973        $arrResults = array();
974        $arrItems = $objQuery->select("*", "dtb_shipment_item",
975                                      "order_id = ? AND shipping_id = ?",
976                                      array($order_id, $shipping_id));
977
978        foreach ($arrItems as $key => $arrItem) {
979            $product_class_id = $arrItem['product_class_id'];
980
981            foreach ($arrItem as $detailKey => $detailVal) {
982                $arrResults[$key][$detailKey] = $detailVal;
983            }
984            // 商品詳細を関連づける
985            if ($has_detail) {
986                $arrResults[$key]['productsClass']
987                    =& $objProduct->getDetailAndProductsClass($product_class_id);
988            }
989        }
990        return $arrResults;
991    }
992
993    /**
994     * 受注完了メールを送信する.
995     *
996     * HTTP_USER_AGENT の種別により, 携帯電話の場合は携帯用の文面,
997     * PC の場合は PC 用の文面でメールを送信する.
998     *
999     * @param integer $orderId 受注ID
1000     * @return void
1001     */
1002    function sendOrderMail($orderId) {
1003        $mailHelper = new SC_Helper_Mail_Ex();
1004        $mailHelper->sfSendOrderMail($orderId,
1005                                     SC_MobileUserAgent_Ex::isMobile() ? 2 : 1);
1006    }
1007
1008    /**
1009     * 受注.対応状況の更新
1010     *
1011     * 必ず呼び出し元でトランザクションブロックを開いておくこと。
1012     *
1013     * @param integer $orderId 注文番号
1014     * @param integer|null $newStatus 対応状況 (null=変更無し)
1015     * @param integer|null $newAddPoint 加算ポイント (null=変更無し)
1016     * @param integer|null $newUsePoint 使用ポイント (null=変更無し)
1017     * @param array $sqlval 更新後の値をリファレンスさせるためのパラメータ
1018     * @return void
1019     */
1020    function sfUpdateOrderStatus($orderId, $newStatus = null, $newAddPoint = null, $newUsePoint = null, &$sqlval) {
1021        $objQuery =& SC_Query_Ex::getSingletonInstance();
1022
1023        $arrOrderOld = $objQuery->getRow('status, add_point, use_point, customer_id', 'dtb_order', 'order_id = ?', array($orderId));
1024
1025        // 対応状況が変更無しの場合、DB値を引き継ぐ
1026        if (is_null($newStatus)) {
1027            $newStatus = $arrOrderOld['status'];
1028        }
1029
1030        // 使用ポイント、DB値を引き継ぐ
1031        if (is_null($newUsePoint)) {
1032            $newUsePoint = $arrOrderOld['use_point'];
1033        }
1034
1035        // 加算ポイント、DB値を引き継ぐ
1036        if (is_null($newAddPoint)) {
1037            $newAddPoint = $arrOrderOld['add_point'];
1038        }
1039
1040        if (USE_POINT !== false) {
1041            // 顧客.ポイントの加減値
1042            $addCustomerPoint = 0;
1043
1044            // ▼使用ポイント
1045            // 変更前の対応状況が利用対象の場合、変更前の使用ポイント分を戻す
1046            if ($this->isUsePoint($arrOrderOld['status'])) {
1047                $addCustomerPoint += $arrOrderOld['use_point'];
1048            }
1049
1050            // 変更後の対応状況が利用対象の場合、変更後の使用ポイント分を引く
1051            if ($this->isUsePoint($newStatus)) {
1052                $addCustomerPoint -= $newUsePoint;
1053            }
1054
1055            // ▲使用ポイント
1056
1057            // ▼加算ポイント
1058            // 変更前の対応状況が加算対象の場合、変更前の加算ポイント分を戻す
1059            if ($this->isAddPoint($arrOrderOld['status'])) {
1060                $addCustomerPoint -= $arrOrderOld['add_point'];
1061            }
1062
1063            // 変更後の対応状況が加算対象の場合、変更後の加算ポイント分を足す
1064            if ($this->isAddPoint($newStatus)) {
1065                $addCustomerPoint += $newAddPoint;
1066            }
1067            // ▲加算ポイント
1068
1069            if ($addCustomerPoint != 0) {
1070                // ▼顧客テーブルの更新
1071                $sqlval = array();
1072                $where = '';
1073                $arrVal = array();
1074                $arrRawSql = array();
1075                $arrRawSqlVal = array();
1076
1077                $sqlval['update_date'] = 'Now()';
1078                $arrRawSql['point'] = 'point + ?';
1079                $arrRawSqlVal[] = $addCustomerPoint;
1080                $where .= 'customer_id = ?';
1081                $arrVal[] = $arrOrderOld['customer_id'];
1082
1083                $objQuery->update('dtb_customer', $sqlval, $where, $arrVal, $arrRawSql, $arrRawSqlVal);
1084                // ▲顧客テーブルの更新
1085
1086                // 顧客.ポイントをマイナスした場合、
1087                if ($addCustomerPoint < 0) {
1088                    $sql = 'SELECT point FROM dtb_customer WHERE customer_id = ?';
1089                    $point = $objQuery->getOne($sql, array($arrOrderOld['customer_id']));
1090                    // 変更後の顧客.ポイントがマイナスの場合、
1091                    if ($point < 0) {
1092                        // ロールバック
1093                        $objQuery->rollback();
1094                        // エラー
1095                        SC_Utils_Ex::sfDispSiteError(LACK_POINT);
1096                    }
1097                }
1098            }
1099        }
1100
1101        // ▼受注テーブルの更新
1102        if (empty($sqlval)) {
1103            $sqlval = array();
1104        }
1105
1106        if (USE_POINT !== false) {
1107            $sqlval['add_point'] = $newAddPoint;
1108            $sqlval['use_point'] = $newUsePoint;
1109        }
1110        // ステータスが発送済みに変更の場合、発送日を更新
1111        if ($arrOrderOld['status'] != ORDER_DELIV && $newStatus == ORDER_DELIV) {
1112            $sqlval['commit_date'] = 'Now()';
1113        }
1114        // ステータスが入金済みに変更の場合、入金日を更新
1115        elseif ($arrOrderOld['status'] != ORDER_PRE_END && $newStatus == ORDER_PRE_END) {
1116            $sqlval['payment_date'] = 'Now()';
1117        }
1118
1119        $sqlval['status'] = $newStatus;
1120        $sqlval['update_date'] = 'Now()';
1121
1122        $dest = $objQuery->extractOnlyColsOf('dtb_order', $sqlval);
1123        $objQuery->update('dtb_order', $dest, 'order_id = ?', array($orderId));
1124        // ▲受注テーブルの更新
1125    }
1126
1127    /**
1128     * 受注の名称列を更新する
1129     *
1130     * @param integer $order_id 更新対象の注文番号
1131     * @param boolean $temp_table 更新対象は「受注_Temp」か
1132     * @static
1133     */
1134    function sfUpdateOrderNameCol($order_id, $temp_table = false) {
1135        $objQuery =& SC_Query_Ex::getSingletonInstance();
1136
1137        if ($temp_table) {
1138            $tgt_table = 'dtb_order_temp';
1139            $sql_where = 'order_temp_id = ?';
1140        } else {
1141            $tgt_table = 'dtb_order';
1142            $sql_where = 'order_id = ?';
1143
1144            $objQuery->update('dtb_shipping', array(),
1145                              $sql_where,
1146                              array($order_id),
1147                              array('shipping_time' =>
1148                                    "(SELECT deliv_time FROM dtb_delivtime WHERE time_id = dtb_shipping.time_id AND deliv_id = dtb_shipping.deliv_id)"));
1149
1150        }
1151
1152        $objQuery->update($tgt_table, array(),
1153                          $sql_where,
1154                          array($order_id),
1155                          array('payment_method' =>
1156                                "(SELECT payment_method FROM dtb_payment WHERE payment_id = " . $tgt_table . ".payment_id)"));
1157    }
1158
1159    /**
1160     * ポイント使用するかの判定
1161     *
1162     * $status が null の場合は false を返す.
1163     *
1164     * @param integer $status 対応状況
1165     * @return boolean 使用するか(顧客テーブルから減算するか)
1166     */
1167    function isUsePoint($status) {
1168        if ($status == null) {
1169            return false;
1170        }
1171        switch ($status) {
1172            case ORDER_CANCEL:      // キャンセル
1173                return false;
1174            default:
1175                break;
1176        }
1177
1178        return true;
1179    }
1180
1181    /**
1182     * ポイント加算するかの判定
1183     *
1184     * @param integer $status 対応状況
1185     * @return boolean 加算するか
1186     */
1187    function isAddPoint($status) {
1188        switch ($status) {
1189            case ORDER_NEW:         // 新規注文
1190            case ORDER_PAY_WAIT:    // 入金待ち
1191            case ORDER_PRE_END:     // 入金済み
1192            case ORDER_CANCEL:      // キャンセル
1193            case ORDER_BACK_ORDER:  // 取り寄せ中
1194                return false;
1195
1196            case ORDER_DELIV:       // 発送済み
1197                return true;
1198
1199            default:
1200                break;
1201        }
1202
1203        return false;
1204    }
1205
1206    /**
1207     * セッションに保持している情報を破棄する.
1208     *
1209     * 通常、受注処理(completeOrder)完了後に呼び出され、
1210     * セッション情報を破棄する.
1211     *
1212     * 決済モジュール画面から確認画面に「戻る」場合を考慮し、
1213     * セッション情報を破棄しないカスタマイズを、モジュール側で
1214     * 加える機会を与える.
1215     *
1216     * @param integer $orderId 注文番号
1217     * @param SC_CartSession $objCartSession カート情報のインスタンス
1218     * @param SC_Customer $objCustomer SC_Customer インスタンス
1219     * @param integer $cartKey 登録を行うカート情報のキー
1220     */
1221    function cleanupSession($orderId, &$objCartSession, &$objCustomer, $cartKey) {
1222        // カートの内容を削除する.
1223        $objCartSession->delAllProducts($cartKey);
1224        SC_SiteSession_Ex::unsetUniqId();
1225
1226        // セッションの配送情報を破棄する.
1227        $this->unsetShippingTemp();
1228        $objCustomer->updateSession();
1229    }
1230}
Note: See TracBrowser for help on using the repository browser.