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

Revision 20975, 46.8 KB checked in by Seasoft, 13 years ago (diff)

#1322 (単価の表示が永続化される変数と異なる)
#1294 (ソースを読みやすくする)

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