Context Navigation

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

Visit:

Revision 23457, 53.8 KB checked in by pineray, 10 years ago (diff)

#2448 typo修正・ソース整形・ソースコメントの改善 for 2.13.3

LC_Page_Products_Detail および関連するファイルのソース改善.
お気に入り登録のエラーチェックが動作していない不具合を修正.

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

Note: See TracBrowser for help on using the repository browser.

Download in other formats: