source: branches/version-2_13-dev/data/class/helper/SC_Helper_Purchase.php @ 23681

Revision 23681, 54.3 KB checked in by shutta, 6 years ago (diff)

#2649 (購入確認ページにて、ページ遷移の正当性チェックをすり抜けることができる)
r23680 と同様な箇所を修正。

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