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

Revision 20959, 47.0 KB checked in by Seasoft, 13 years ago (diff)

#1294 (ソースを読みやすくする)

  • 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 * 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     * ダウンロード可能と判断されるのは, 以下の通り.
936     *
937     * 1. ダウンロード可能期限が期限内かつ, 入金日が入力されている
938     * 2. 販売価格が 0 円である
939     *
940     * 受注詳細行には, is_downloadable という真偽値が設定される.
941     * @param array 受注詳細の配列
942     * @return void
943     */
944    function setDownloadableFlgTo(&$arrOrderDetail) {
945        foreach (array_keys($arrOrderDetail) as $key) {
946            // 販売価格が 0 円
947            if ($arrOrderDetail[$key]['price'] == '0') {
948                $arrOrderDetail[$key]['is_downloadable'] = true;
949            }
950            // ダウンロード期限内かつ, 入金日あり
951            elseif ($arrOrderDetail[$key]['effective'] == '1'
952                    && !SC_Utils_Ex::isBlank($arrOrderDetail[$key]['payment_date'])) {
953                $arrOrderDetail[$key]['is_downloadable'] = true;
954            } else {
955                $arrOrderDetail[$key]['is_downloadable'] = false;
956            }
957        }
958    }
959
960    /**
961     * 配送情報を取得する.
962     *
963     * @param integer $order_id 受注ID
964     * @param boolean $has_items 結果に配送商品も含める場合 true
965     * @return array 配送情報の配列
966     */
967    function getShippings($order_id, $has_items = true) {
968        $objQuery =& SC_Query_Ex::getSingletonInstance();
969        $arrResults = array();
970        $objQuery->setOrder('shipping_id');
971        $arrShippings = $objQuery->select("*", "dtb_shipping", "order_id = ?",
972                                          array($order_id));
973        // shipping_id ごとの配列を生成する
974        foreach ($arrShippings as $shipping) {
975            foreach ($shipping as $key => $val) {
976                $arrResults[$shipping['shipping_id']][$key] = $val;
977            }
978        }
979
980        if ($has_items) {
981            $objProduct = new SC_Product_Ex();
982            foreach (array_keys($arrResults) as $shipping_id) {
983                $arrResults[$shipping_id]['shipment_item']
984                        =& $this->getShipmentItems($order_id, $shipping_id);
985            }
986        }
987        return $arrResults;
988    }
989
990    /**
991     * 配送商品を取得する.
992     *
993     * @param integer $order_id 受注ID
994     * @param integer $shipping_id 配送先ID
995     * @param boolean $has_detail 商品詳細も取得する場合 true
996     * @return array 商品規格IDをキーにした配送商品の配列
997     */
998    function getShipmentItems($order_id, $shipping_id, $has_detail = true) {
999        $objQuery =& SC_Query_Ex::getSingletonInstance();
1000        $objProduct = new SC_Product_Ex();
1001        $arrResults = array();
1002        $arrItems = $objQuery->select("*", "dtb_shipment_item",
1003                                      "order_id = ? AND shipping_id = ?",
1004                                      array($order_id, $shipping_id));
1005
1006        foreach ($arrItems as $key => $arrItem) {
1007            $product_class_id = $arrItem['product_class_id'];
1008
1009            foreach ($arrItem as $detailKey => $detailVal) {
1010                $arrResults[$key][$detailKey] = $detailVal;
1011            }
1012            // 商品詳細を関連づける
1013            if ($has_detail) {
1014                $arrResults[$key]['productsClass']
1015                    =& $objProduct->getDetailAndProductsClass($product_class_id);
1016            }
1017        }
1018        return $arrResults;
1019    }
1020
1021    /**
1022     * 受注完了メールを送信する.
1023     *
1024     * HTTP_USER_AGENT の種別により, 携帯電話の場合は携帯用の文面,
1025     * PC の場合は PC 用の文面でメールを送信する.
1026     *
1027     * @param integer $orderId 受注ID
1028     * @return void
1029     */
1030    function sendOrderMail($orderId) {
1031        $mailHelper = new SC_Helper_Mail_Ex();
1032        $mailHelper->sfSendOrderMail($orderId,
1033                                     SC_MobileUserAgent_Ex::isMobile() ? 2 : 1);
1034    }
1035
1036    /**
1037     * 受注.対応状況の更新
1038     *
1039     * 必ず呼び出し元でトランザクションブロックを開いておくこと。
1040     *
1041     * @param integer $orderId 注文番号
1042     * @param integer|null $newStatus 対応状況 (null=変更無し)
1043     * @param integer|null $newAddPoint 加算ポイント (null=変更無し)
1044     * @param integer|null $newUsePoint 使用ポイント (null=変更無し)
1045     * @param array $sqlval 更新後の値をリファレンスさせるためのパラメータ
1046     * @return void
1047     */
1048    function sfUpdateOrderStatus($orderId, $newStatus = null, $newAddPoint = null, $newUsePoint = null, &$sqlval) {
1049        $objQuery =& SC_Query_Ex::getSingletonInstance();
1050
1051        $arrOrderOld = $objQuery->getRow('status, add_point, use_point, customer_id', 'dtb_order', 'order_id = ?', array($orderId));
1052
1053        // 対応状況が変更無しの場合、DB値を引き継ぐ
1054        if (is_null($newStatus)) {
1055            $newStatus = $arrOrderOld['status'];
1056        }
1057
1058        // 使用ポイント、DB値を引き継ぐ
1059        if (is_null($newUsePoint)) {
1060            $newUsePoint = $arrOrderOld['use_point'];
1061        }
1062
1063        // 加算ポイント、DB値を引き継ぐ
1064        if (is_null($newAddPoint)) {
1065            $newAddPoint = $arrOrderOld['add_point'];
1066        }
1067
1068        if (USE_POINT !== false) {
1069            // 会員.ポイントの加減値
1070            $addCustomerPoint = 0;
1071
1072            // ▼使用ポイント
1073            // 変更前の対応状況が利用対象の場合、変更前の使用ポイント分を戻す
1074            if ($this->isUsePoint($arrOrderOld['status'])) {
1075                $addCustomerPoint += $arrOrderOld['use_point'];
1076            }
1077
1078            // 変更後の対応状況が利用対象の場合、変更後の使用ポイント分を引く
1079            if ($this->isUsePoint($newStatus)) {
1080                $addCustomerPoint -= $newUsePoint;
1081            }
1082
1083            // ▲使用ポイント
1084
1085            // ▼加算ポイント
1086            // 変更前の対応状況が加算対象の場合、変更前の加算ポイント分を戻す
1087            if ($this->isAddPoint($arrOrderOld['status'])) {
1088                $addCustomerPoint -= $arrOrderOld['add_point'];
1089            }
1090
1091            // 変更後の対応状況が加算対象の場合、変更後の加算ポイント分を足す
1092            if ($this->isAddPoint($newStatus)) {
1093                $addCustomerPoint += $newAddPoint;
1094            }
1095            // ▲加算ポイント
1096
1097            if ($addCustomerPoint != 0) {
1098                // ▼会員テーブルの更新
1099                $sqlval = array();
1100                $where = '';
1101                $arrVal = array();
1102                $arrRawSql = array();
1103                $arrRawSqlVal = array();
1104
1105                $sqlval['update_date'] = 'Now()';
1106                $arrRawSql['point'] = 'point + ?';
1107                $arrRawSqlVal[] = $addCustomerPoint;
1108                $where .= 'customer_id = ?';
1109                $arrVal[] = $arrOrderOld['customer_id'];
1110
1111                $objQuery->update('dtb_customer', $sqlval, $where, $arrVal, $arrRawSql, $arrRawSqlVal);
1112                // ▲会員テーブルの更新
1113
1114                // 会員.ポイントをマイナスした場合、
1115                if ($addCustomerPoint < 0) {
1116                    $sql = 'SELECT point FROM dtb_customer WHERE customer_id = ?';
1117                    $point = $objQuery->getOne($sql, array($arrOrderOld['customer_id']));
1118                    // 変更後の会員.ポイントがマイナスの場合、
1119                    if ($point < 0) {
1120                        // ロールバック
1121                        $objQuery->rollback();
1122                        // エラー
1123                        SC_Utils_Ex::sfDispSiteError(LACK_POINT);
1124                    }
1125                }
1126            }
1127        }
1128
1129        // ▼受注テーブルの更新
1130        if (empty($sqlval)) {
1131            $sqlval = array();
1132        }
1133
1134        if (USE_POINT !== false) {
1135            $sqlval['add_point'] = $newAddPoint;
1136            $sqlval['use_point'] = $newUsePoint;
1137        }
1138        // ステータスが発送済みに変更の場合、発送日を更新
1139        if ($arrOrderOld['status'] != ORDER_DELIV && $newStatus == ORDER_DELIV) {
1140            $sqlval['commit_date'] = 'Now()';
1141        }
1142        // ステータスが入金済みに変更の場合、入金日を更新
1143        elseif ($arrOrderOld['status'] != ORDER_PRE_END && $newStatus == ORDER_PRE_END) {
1144            $sqlval['payment_date'] = 'Now()';
1145        }
1146
1147        $sqlval['status'] = $newStatus;
1148        $sqlval['update_date'] = 'Now()';
1149
1150        $dest = $objQuery->extractOnlyColsOf('dtb_order', $sqlval);
1151        $objQuery->update('dtb_order', $dest, 'order_id = ?', array($orderId));
1152        // ▲受注テーブルの更新
1153    }
1154
1155    /**
1156     * 受注の名称列を更新する
1157     *
1158     * @param integer $order_id 更新対象の注文番号
1159     * @param boolean $temp_table 更新対象は「受注_Temp」か
1160     * @static
1161     */
1162    function sfUpdateOrderNameCol($order_id, $temp_table = false) {
1163        $objQuery =& SC_Query_Ex::getSingletonInstance();
1164
1165        if ($temp_table) {
1166            $tgt_table = 'dtb_order_temp';
1167            $sql_where = 'order_temp_id = ?';
1168        } else {
1169            $tgt_table = 'dtb_order';
1170            $sql_where = 'order_id = ?';
1171
1172            $objQuery->update('dtb_shipping', array(),
1173                              $sql_where,
1174                              array($order_id),
1175                              array('shipping_time' =>
1176                                    "(SELECT deliv_time FROM dtb_delivtime WHERE time_id = dtb_shipping.time_id AND deliv_id = dtb_shipping.deliv_id)"));
1177
1178        }
1179
1180        $objQuery->update($tgt_table, array(),
1181                          $sql_where,
1182                          array($order_id),
1183                          array('payment_method' =>
1184                                "(SELECT payment_method FROM dtb_payment WHERE payment_id = " . $tgt_table . ".payment_id)"));
1185    }
1186
1187    /**
1188     * ポイント使用するかの判定
1189     *
1190     * $status が null の場合は false を返す.
1191     *
1192     * @param integer $status 対応状況
1193     * @return boolean 使用するか(会員テーブルから減算するか)
1194     */
1195    function isUsePoint($status) {
1196        if ($status == null) {
1197            return false;
1198        }
1199        switch ($status) {
1200            case ORDER_CANCEL:      // キャンセル
1201                return false;
1202            default:
1203                break;
1204        }
1205
1206        return true;
1207    }
1208
1209    /**
1210     * ポイント加算するかの判定
1211     *
1212     * @param integer $status 対応状況
1213     * @return boolean 加算するか
1214     */
1215    function isAddPoint($status) {
1216        switch ($status) {
1217            case ORDER_NEW:         // 新規注文
1218            case ORDER_PAY_WAIT:    // 入金待ち
1219            case ORDER_PRE_END:     // 入金済み
1220            case ORDER_CANCEL:      // キャンセル
1221            case ORDER_BACK_ORDER:  // 取り寄せ中
1222                return false;
1223
1224            case ORDER_DELIV:       // 発送済み
1225                return true;
1226
1227            default:
1228                break;
1229        }
1230
1231        return false;
1232    }
1233
1234    /**
1235     * セッションに保持している情報を破棄する.
1236     *
1237     * 通常、受注処理(completeOrder)完了後に呼び出され、
1238     * セッション情報を破棄する.
1239     *
1240     * 決済モジュール画面から確認画面に「戻る」場合を考慮し、
1241     * セッション情報を破棄しないカスタマイズを、モジュール側で
1242     * 加える機会を与える.
1243     *
1244     * @param integer $orderId 注文番号
1245     * @param SC_CartSession $objCartSession カート情報のインスタンス
1246     * @param SC_Customer $objCustomer SC_Customer インスタンス
1247     * @param integer $cartKey 登録を行うカート情報のキー
1248     */
1249    function cleanupSession($orderId, &$objCartSession, &$objCustomer, $cartKey) {
1250        // カートの内容を削除する.
1251        $objCartSession->delAllProducts($cartKey);
1252        SC_SiteSession_Ex::unsetUniqId();
1253
1254        // セッションの配送情報を破棄する.
1255        $this->unsetShippingTemp();
1256        $objCustomer->updateSession();
1257    }
1258}
Note: See TracBrowser for help on using the repository browser.