Context Navigation

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

Visit:

Revision 20971, 46.5 KB checked in by Seasoft, 13 years ago (diff)

#1333 (謎な処理 SC_Helper_Purchase#shippingItemTempToCart)

一旦削除してみましたので、不具合が確認されましたら、報告をお願いいたします。

Property svn:eol-style set to LF
Property svn:keywords set to Id
Property svn:mime-type set to text/x-httpd-php; charset=UTF-8

Line
1	<?php
2	/*
3	* This file is part of EC-CUBE
4	*
5	* Copyright(c) 2000-2011 LOCKON CO.,LTD. All Rights Reserved.
6	*
7	* http://www.lockon.co.jp/
8	*
9	* This program is free software; you can redistribute it and/or
10	* modify it under the terms of the GNU General Public License
11	* as published by the Free Software Foundation; either version 2
12	* of the License, or (at your option) any later version.
13	*
14	* This program is distributed in the hope that it will be useful,
15	* but WITHOUT ANY WARRANTY; without even the implied warranty of
16	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17	* GNU General Public License for more details.
18	*
19	* You should have received a copy of the GNU General Public License
20	* along with this program; if not, write to the Free Software
21	* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
22	*/
23
24	/**
25	* 商品購入関連のヘルパークラス.
26	*
27	* TODO 購入時強制会員登録機能(#521)の実装を検討
28	* TODO dtb_customer.buy_times, dtb_customer.buy_total の更新
29	*
30	* @package Helper
31	* @author Kentaro Ohkouchi
32	* @version $Id$
33	*/
34	class SC_Helper_Purchase {
35
36	/**
37	* 受注を完了する.
38	*
39	* 下記のフローで受注を完了する.
40	*
41	* 1. トランザクションを開始する
42	* 2. カートの内容を検証する.
43	* 3. 受注一時テーブルから受注データを読み込む
44	* 4. ユーザーがログインしている場合はその他の発送先へ登録する
45	* 5. 受注データを受注テーブルへ登録する
46	* 6. トランザクションをコミットする
47	*
48	* 実行中に, 何らかのエラーが発生した場合, 処理を中止しエラーページへ遷移する
49	*
50	* 決済モジュールを使用する場合は受注ステータスを「決済処理中」に設定し,
51	* 決済完了後「新規受付」に変更すること
52	*
53	* @param integer $orderStatus 受注処理を完了する際に設定する受注ステータス
54	* @return void
55	*/
56	function completeOrder($orderStatus = ORDER_NEW) {
57	$objQuery =& SC_Query_Ex::getSingletonInstance();
58	$objSiteSession = new SC_SiteSession_Ex();
59	$objCartSession = new SC_CartSession_Ex();
60	$objCustomer = new SC_Customer_Ex();
61	$customerId = $objCustomer->getValue('customer_id');
62
63	$objQuery->begin();
64	if (!$objSiteSession->isPrePage()) {
65	SC_Utils_Ex::sfDispSiteError(PAGE_ERROR, $objSiteSession);
66	}
67
68	$uniqId = $objSiteSession->getUniqId();
69	$this->verifyChangeCart($uniqId, $objCartSession);
70
71	$orderTemp = $this->getOrderTemp($uniqId);
72
73	$orderTemp['status'] = $orderStatus;
74	$cartkey = $objCartSession->getKey();
75	$orderId = $this->registerOrderComplete($orderTemp, $objCartSession,
76	$cartkey);
77	$shippingTemp =& $this->getShippingTemp();
78	if (count($shippingTemp) > 1) {
79	foreach ($shippingTemp as $shippingId => $val) {
80	$this->registerShipmentItem($orderId, $shippingId,
81	$val['shipment_item']);
82	}
83	}
84
85	$this->registerShipping($orderId, $shippingTemp);
86	$objQuery->commit();
87	$this->cleanupSession($orderId, $objCartSession, $objCustomer, $cartkey);
88	}
89
90	/**
91	* 受注をキャンセルする.
92	*
93	* 受注完了後の受注をキャンセルする.
94	* この関数は, 主に決済モジュールにて, 受注をキャンセルする場合に使用する.
95	*
96	* 受注ステータスを引数 $orderStatus で指定したステータスに変更する.
97	* (デフォルト ORDER_CANCEL)
98	* 引数 $is_delete が true の場合は, 受注データを論理削除する.
99	* 商品の在庫数は, 受注前の在庫数に戻される.
100	*
101	* @param integer $order_id 受注ID
102	* @param integer $orderStatus 受注ステータス
103	* @param boolean $is_delete 受注データを論理削除する場合 true
104	* @return void
105	*/
106	function cancelOrder($order_id, $orderStatus = ORDER_CANCEL, $is_delete = false) {
107	$objQuery =& SC_Query_Ex::getSingletonInstance();
108	$in_transaction = $objQuery->inTransaction();
109	if (!$in_transaction) {
110	$objQuery->begin();
111	}
112
113	$arrParams['status'] = $orderStatus;
114	if ($is_delete) {
115	$arrParams['del_flg'] = 1;
116	}
117
118	$this->registerOrder($order_id, $arrParams);
119
120	$arrOrderDetail = $this->getOrderDetail($order_id);
121	foreach ($arrOrderDetail as $arrDetail) {
122	$objQuery->update('dtb_products_class', array(),
123	"product_class_id = ?", array($arrDetail['product_class_id']),
124	array('stock' => 'stock + ?'), array($arrDetail['quantity']));
125	}
126	if (!$in_transaction) {
127	$objQuery->commit();
128	}
129	}
130
131	/**
132	* 受注をキャンセルし, カートをロールバックして, 受注一時IDを返す.
133	*
134	* 受注完了後の受注をキャンセルし, カートの状態を受注前の状態へ戻す.
135	* この関数は, 主に, 決済モジュールに遷移した後, 購入確認画面へ戻る場合に使用する.
136	*
137	* 受注ステータスを引数 $orderStatus で指定したステータスに変更する.
138	* (デフォルト ORDER_CANCEL)
139	* 引数 $is_delete が true の場合は, 受注データを論理削除する.
140	* 商品の在庫数, カートの内容は受注前の状態に戻される.
141	*
142	* @param integer $order_id 受注ID
143	* @param integer $orderStatus 受注ステータス
144	* @param boolean $is_delete 受注データを論理削除する場合 true
145	* @return string 受注一時ID
146	*/
147	function rollbackOrder($order_id, $orderStatus = ORDER_CANCEL, $is_delete = false) {
148	$objQuery =& SC_Query_Ex::getSingletonInstance();
149	$in_transaction = $objQuery->inTransaction();
150	if (!$in_transaction) {
151	$objQuery->begin();
152	}
153
154	$this->cancelOrder($order_id, $orderStatus, $is_delete);
155	$arrOrderTemp = $this->getOrderTempByOrderId($order_id);
156	$_SESSION = array_merge($_SESSION, unserialize($arrOrderTemp['session']));
157
158	$objSiteSession = new SC_SiteSession_Ex();
159	$objCartSession = new SC_CartSession_Ex();
160	$objCustomer = new SC_Customer_Ex();
161
162	// 新たに受注一時情報を保存する
163	$objSiteSession->unsetUniqId();
164	$uniqid = $objSiteSession->getUniqId();
165	$arrOrderTemp['del_flg'] = 0;
166	$this->saveOrderTemp($uniqid, $arrOrderTemp, $objCustomer);
167	$this->verifyChangeCart($uniqid, $objCartSession);
168	$objSiteSession->setRegistFlag();
169
170	if (!$in_transaction) {
171	$objQuery->commit();
172	}
173	return $uniqid;
174	}
175
176	/**
177	* カートに変化が無いか検証する.
178	*
179	* ユニークIDとセッションのユニークIDを比較し, 異なる場合は
180	* エラー画面を表示する.
181	*
182	* カートが空の場合, 購入ボタン押下後にカートが変更された場合は
183	* カート画面へ遷移する.
184	*
185	* @param string $uniqId ユニークID
186	* @param SC_CartSession $objCartSession
187	* @return void
188	*/
189	function verifyChangeCart($uniqId, &$objCartSession) {
190	$cartKeys = $objCartSession->getKeys();
191
192	// カート内が空でないか
193	if (SC_Utils_Ex::isBlank($cartKeys)) {
194	SC_Response_Ex::sendRedirect(CART_URLPATH);
195	exit;
196	}
197
198	foreach ($cartKeys as $cartKey) {
199	// 初回のみカートの内容を保存
200	$objCartSession->saveCurrentCart($uniqId, $cartKey);
201
202	/*
203	* POSTのユニークIDとセッションのユニークIDを比較
204	*(ユニークIDがPOSTされていない場合はスルー)
205	*/
206	if(!SC_SiteSession_Ex::checkUniqId()) {
207	SC_Utils_Ex::sfDispSiteError(CANCEL_PURCHASE);
208	exit;
209	}
210
211	// 購入ボタンを押してから変化がないか
212	$quantity = $objCartSession->getTotalQuantity($cartKey);
213	if($objCartSession->checkChangeCart($cartKey) \|\| !($quantity > 0)) {
214	SC_Response_Ex::sendRedirect(CART_URLPATH);
215	exit;
216	}
217	}
218	}
219
220	/**
221	* 受注一時情報を取得する.
222	*
223	* @param integer $uniqId 受注一時情報ID
224	* @return array 受注一時情報の配列
225	*/
226	function getOrderTemp($uniqId) {
227	$objQuery =& SC_Query_Ex::getSingletonInstance();
228	return $objQuery->getRow("*", "dtb_order_temp", "order_temp_id = ?",
229	array($uniqId));
230	}
231
232	/**
233	* 受注IDをキーにして受注一時情報を取得する.
234	*
235	* @param integer $order_id 受注ID
236	* @return array 受注一時情報の配列
237	*/
238	function getOrderTempByOrderId($order_id) {
239	$objQuery =& SC_Query_Ex::getSingletonInstance();
240	return $objQuery->getRow("*", "dtb_order_temp", "order_id = ?",
241	array($order_id));
242	}
243
244	/**
245	* 受注一時情報を保存する.
246	*
247	* 既存のデータが存在しない場合は新規保存. 存在する場合は更新する.
248	* 既存のデータが存在せず, ユーザーがログインしている場合は,
249	* 会員情報をコピーする.
250	*
251	* @param integer $uniqId 受注一時情報ID
252	* @param array $params 登録する受注情報の配列
253	* @param SC_Customer $objCustomer SC_Customer インスタンス
254	* @return array void
255	*/
256	function saveOrderTemp($uniqId, $params, &$objCustomer) {
257	if (SC_Utils_Ex::isBlank($uniqId)) {
258	return;
259	}
260	$params['device_type_id'] = SC_Display::detectDevice();
261	$objQuery =& SC_Query_Ex::getSingletonInstance();
262	// 存在するカラムのみを対象とする
263	$cols = $objQuery->listTableFields('dtb_order_temp');
264	foreach ($params as $key => $val) {
265	if (in_array($key, $cols)) {
266	$sqlval[$key] = $val;
267	}
268	}
269
270	$sqlval['session'] = serialize($_SESSION);
271	$exists = $this->getOrderTemp($uniqId);
272	if (SC_Utils_Ex::isBlank($exists)) {
273	$this->copyFromCustomer($sqlval, $objCustomer);
274	$sqlval['order_temp_id'] = $uniqId;
275	$sqlval['create_date'] = "now()";
276	$objQuery->insert("dtb_order_temp", $sqlval);
277	} else {
278	$objQuery->update("dtb_order_temp", $sqlval, 'order_temp_id = ?',
279	array($uniqId));
280	}
281	}
282
283	/**
284	* セッションの配送情報を取得する.
285	*/
286	function getShippingTemp() {
287	return $_SESSION['shipping'];
288	}
289
290	/**
291	* 配送商品をクリア(消去)する
292	*
293	* @param integer $shipping_id 配送先ID
294	* @return void
295	*/
296	function clearShipmentItemTemp($shipping_id = null) {
297	if (is_null($shipping_id)) {
298	unset($_SESSION['shipping']);
299	} else {
300	unset($_SESSION['shipping'][$shipping_id]);
301	}
302	}
303
304	/**
305	* 配送商品を設定する.
306	*
307	* @param integer $shipping_id 配送先ID
308	* @param integer $product_class_id 商品規格ID
309	* @param integer $quantity 数量
310	* @return void
311	*/
312	function setShipmentItemTemp($shipping_id, $product_class_id, $quantity) {
313	// 配列が長くなるので, リファレンスを使用する
314	$arrItems =& $_SESSION['shipping'][$shipping_id]['shipment_item'];
315
316	$arrItems[$product_class_id]['shipping_id'] = $shipping_id;
317	$arrItems[$product_class_id]['product_class_id'] = $product_class_id;
318	$arrItems[$product_class_id]['quantity'] = $quantity;
319
320	$objProduct = new SC_Product_Ex();
321	if (empty($arrItems[$product_class_id]['productsClass'])) {
322	$product =& $objProduct->getDetailAndProductsClass($product_class_id);
323	$arrItems[$product_class_id]['productsClass'] = $product;
324	}
325	$incTax = SC_Helper_DB_Ex::sfCalcIncTax($arrItems[$product_class_id]['productsClass']['price02']);
326	$arrItems[$product_class_id]['total_inctax'] = $incTax * $arrItems[$product_class_id]['quantity'];
327	}
328
329	/**
330	* 配送先都道府県の配列を返す.
331	*/
332	function getShippingPref() {
333	$results = array();
334	foreach ($_SESSION['shipping'] as $val) {
335	$results[] = $val['shipping_pref'];
336	}
337	return $results;
338	}
339
340	/**
341	* 複数配送指定の購入かどうか.
342	*
343	* @return boolean 複数配送指定の購入の場合 true
344	*/
345	function isMultiple() {
346	return count($this->getShippingTemp()) > 1;
347	}
348
349	/**
350	* 配送情報をセッションに保存する.
351	*
352	* @param array $arrSrc 配送情報の連想配列
353	* @param integer $shipping_id 配送先ID
354	* @return void
355	*/
356	function saveShippingTemp(&$arrSrc, $shipping_id = 0) {
357	if (empty($_SESSION['shipping'][$shipping_id])) {
358	$_SESSION['shipping'][$shipping_id] = $arrSrc;
359	$_SESSION['shipping'][$shipping_id]['shipping_id'] = $shipping_id;
360	} else {
361	$_SESSION['shipping'][$shipping_id] = array_merge($_SESSION['shipping'][$shipping_id], $arrSrc);
362	$_SESSION['shipping'][$shipping_id]['shipping_id'] = $shipping_id;
363	}
364	}
365
366	/**
367	* セッションの配送情報を破棄する.
368	*/
369	function unsetShippingTemp() {
370	unset($_SESSION['shipping']);
371	unset($_SESSION['multiple_temp']);
372	}
373
374	/**
375	* 会員情報を受注情報にコピーする.
376	*
377	* ユーザーがログインしていない場合は何もしない.
378	* 会員情報を $dest の order_* へコピーする.
379	* customer_id は強制的にコピーされる.
380	*
381	* @param array $dest コピー先の配列
382	* @param SC_Customer $objCustomer SC_Customer インスタンス
383	* @param string $prefix コピー先の接頭辞. デフォルト order
384	* @param array $keys コピー対象のキー
385	* @return void
386	*/
387	function copyFromCustomer(&$dest, &$objCustomer, $prefix = 'order',
388	$keys = array('name01', 'name02', 'kana01', 'kana02',
389	'sex', 'zip01', 'zip02', 'pref',
390	'addr01', 'addr02',
391	'tel01', 'tel02', 'tel03', 'job',
392	'birth', 'email')) {
393	if ($objCustomer->isLoginSuccess(true)) {
394
395	foreach ($keys as $key) {
396	if (in_array($key, $keys)) {
397	$dest[$prefix . '_' . $key] = $objCustomer->getValue($key);
398	}
399	}
400
401	if (Net_UserAgent_Mobile::isMobile()
402	&& in_array('email', $keys)) {
403	$email_mobile = $objCustomer->getValue('email_mobile');
404	if (empty($email_mobile)) {
405	$dest[$prefix . '_email'] = $objCustomer->getValue('email');
406	} else {
407	$dest[$prefix . '_email'] = $email_mobile;
408	}
409	}
410
411	$dest['customer_id'] = $objCustomer->getValue('customer_id');
412	$dest['update_date'] = 'Now()';
413	}
414	}
415
416	/**
417	* 受注情報を配送情報にコピーする.
418	*
419	* 受注情報($src)を $dest の order_* へコピーする.
420	*
421	* TODO 汎用的にして SC_Utils へ移動
422	*
423	* @param array $dest コピー先の配列
424	* @param array $src コピー元の配列
425	* @param array $keys コピー対象のキー
426	* @param string $prefix コピー先の接頭辞. デフォルト shipping
427	* @param string $src_prefix コピー元の接頭辞. デフォルト order
428	* @return void
429	*/
430	function copyFromOrder(&$dest, $src,
431	$prefix = 'shipping', $src_prefix = 'order',
432	$keys = array('name01', 'name02', 'kana01', 'kana02',
433	'sex', 'zip01', 'zip02', 'pref',
434	'addr01', 'addr02',
435	'tel01', 'tel02', 'tel03')) {
436	if (!SC_Utils_Ex::isBlank($prefix)) {
437	$prefix = $prefix . '_';
438	}
439	if (!SC_Utils_Ex::isBlank($src_prefix)) {
440	$src_prefix = $src_prefix . '_';
441	}
442	foreach ($keys as $key) {
443	if (in_array($key, $keys)) {
444	$dest[$prefix . $key] = $src[$src_prefix . $key];
445	}
446	}
447	}
448
449	/**
450	* 購入金額に応じた支払方法を取得する.
451	*
452	* @param integer $total 購入金額
453	* @param integer $deliv_id 配送業者ID
454	* @return array 購入金額に応じた支払方法の配列
455	*/
456	function getPaymentsByPrice($total, $deliv_id) {
457
458	$arrPaymentIds = $this->getPayments($deliv_id);
459	if (SC_Utils_Ex::isBlank($arrPaymentIds)) {
460	return array();
461	}
462
463	$objQuery =& SC_Query_Ex::getSingletonInstance();
464
465	// 削除されていない支払方法を取得
466	$where = 'del_flg = 0 AND payment_id IN (' . implode(', ', array_pad(array(), count($arrPaymentIds), '?')) . ')';
467	$objQuery->setOrder("rank DESC");
468	$payments = $objQuery->select("payment_id, payment_method, rule, upper_rule, note, payment_image, charge", "dtb_payment", $where, $arrPaymentIds);
469	foreach ($payments as $data) {
470	// 下限と上限が設定されている
471	if (strlen($data['rule']) != 0 && strlen($data['upper_rule']) != 0) {
472	if ($data['rule'] <= $total && $data['upper_rule'] >= $total) {
473	$arrPayment[] = $data;
474	}
475	}
476	// 下限のみ設定されている
477	elseif (strlen($data['rule']) != 0) {
478	if($data['rule'] <= $total) {
479	$arrPayment[] = $data;
480	}
481	}
482	// 上限のみ設定されている
483	elseif (strlen($data['upper_rule']) != 0) {
484	if($data['upper_rule'] >= $total) {
485	$arrPayment[] = $data;
486	}
487	}
488	// いずれも設定なし
489	else {
490	$arrPayment[] = $data;
491	}
492	}
493	return $arrPayment;
494	}
495
496	/**
497	* お届け日一覧を取得する.
498	*/
499	function getDelivDate(&$objCartSess, $productTypeId) {
500	$cartList = $objCartSess->getCartList($productTypeId);
501	$delivDateIds = array();
502	foreach ($cartList as $item) {
503	$delivDateIds[] = $item['productsClass']['deliv_date_id'];
504	}
505	$max_date = max($delivDateIds);
506	//発送目安
507	switch($max_date) {
508	//即日発送
509	case '1':
510	$start_day = 1;
511	break;
512	//1-2日後
513	case '2':
514	$start_day = 3;
515	break;
516	//3-4日後
517	case '3':
518	$start_day = 5;
519	break;
520	//1週間以内
521	case '4':
522	$start_day = 8;
523	break;
524	//2週間以内
525	case '5':
526	$start_day = 15;
527	break;
528	//3週間以内
529	case '6':
530	$start_day = 22;
531	break;
532	//1ヶ月以内
533	case '7':
534	$start_day = 32;
535	break;
536	//2ヶ月以降
537	case '8':
538	$start_day = 62;
539	break;
540	//お取り寄せ(商品入荷後)
541	case '9':
542	$start_day = "";
543	break;
544	default:
545	//お届け日が設定されていない場合
546	$start_day = "";
547	}
548	//お届け可能日のスタート値から、お届け日の配列を取得する
549	$arrDelivDate = $this->getDateArray($start_day, DELIV_DATE_END_MAX);
550	return $arrDelivDate;
551	}
552
553	/**
554	* お届け可能日のスタート値から, お届け日の配列を取得する.
555	*/
556	function getDateArray($start_day, $end_day) {
557	$masterData = new SC_DB_MasterData();
558	$arrWDAY = $masterData->getMasterData("mtb_wday");
559	//お届け可能日のスタート値がセットされていれば
560	if($start_day >= 1) {
561	$now_time = time();
562	$max_day = $start_day + $end_day;
563	// 集計
564	for ($i = $start_day; $i < $max_day; $i++) {
565	// 基本時間から日数を追加していく
566	$tmp_time = $now_time + ($i * 24 * 3600);
567	list($y, $m, $d, $w) = explode(" ", date("Y m d w", $tmp_time));
568	$val = sprintf("%04d/%02d/%02d(%s)", $y, $m, $d, $arrWDAY[$w]);
569	$arrDate[$val] = $val;
570	}
571	} else {
572	$arrDate = false;
573	}
574	return $arrDate;
575	}
576
577	/**
578	* 配送業者IDからお届け時間の配列を取得する.
579	*
580	* @param integer $deliv_id 配送業者ID
581	* @return array お届け時間の配列
582	*/
583	function getDelivTime($deliv_id) {
584	$objQuery =& SC_Query_Ex::getSingletonInstance();
585	$objQuery->setOrder('time_id');
586	$results = $objQuery->select('time_id, deliv_time',
587	'dtb_delivtime',
588	'deliv_id = ?', array($deliv_id));
589	$arrDelivTime = array();
590	foreach ($results as $val) {
591	$arrDelivTime[$val['time_id']] = $val['deliv_time'];
592	}
593	return $arrDelivTime;
594	}
595
596	/**
597	* 商品種別ID から配送業者を取得する.
598	*
599	* @param integer $product_type_id 商品種別ID
600	* @return array 配送業者の配列
601	*/
602	function getDeliv($product_type_id) {
603	$objQuery =& SC_Query_Ex::getSingletonInstance();
604	$objQuery->setOrder('rank DESC');
605	return $objQuery->select('*', 'dtb_deliv', 'product_type_id = ? AND del_flg = 0',
606	array($product_type_id));
607	}
608
609	/**
610	* 配送業者ID から, 有効な支払方法IDを取得する.
611	*
612	* @param integer $deliv_id 配送業者ID
613	* @return array 有効な支払方法IDの配列
614	*/
615	function getPayments($deliv_id) {
616	$objQuery =& SC_Query_Ex::getSingletonInstance();
617	$objQuery->setOrder('rank');
618	return $objQuery->getCol('payment_id', 'dtb_payment_options',
619	'deliv_id = ?',
620	array($deliv_id), MDB2_FETCHMODE_ORDERED);
621	}
622
623	/**
624	* 配送情報の登録を行う.
625	*
626	* $arrParam のうち, dtb_shipping テーブルに存在するカラムのみを登録する.
627	*
628	* TODO UPDATE/INSERT にする
629	*
630	* @param integer $order_id 受注ID
631	* @param array $arrParams 配送情報の連想配列
632	* @param boolean $convert_shipping_date yyyy/mm/dd(EEE) 形式の配送日付を変換する場合 true
633	* @return void
634	*/
635	function registerShipping($order_id, $arrParams, $convert_shipping_date = true) {
636	$objQuery =& SC_Query_Ex::getSingletonInstance();
637	$table = 'dtb_shipping';
638	$where = 'order_id = ?';
639	$objQuery->delete($table, $where, array($order_id));
640
641	foreach ($arrParams as $key => $arrShipping) {
642
643	$arrValues = $objQuery->extractOnlyColsOf($table, $arrShipping);
644
645	// 配送日付を timestamp に変換
646	if (!SC_Utils_Ex::isBlank($arrValues['shipping_date'])
647	&& $convert_shipping_date) {
648	$d = mb_strcut($arrValues["shipping_date"], 0, 10);
649	$arrDate = explode("/", $d);
650	$ts = mktime(0, 0, 0, $arrDate[1], $arrDate[2], $arrDate[0]);
651	$arrValues['shipping_date'] = date("Y-m-d", $ts);
652	}
653
654	// 非会員購入の場合は shipping_id が存在しない
655	if (!isset($arrValues['shipping_id'])) {
656	$arrValues['shipping_id'] = $key;
657	}
658	$arrValues['order_id'] = $order_id;
659	$arrValues['create_date'] = 'Now()';
660	$arrValues['update_date'] = 'Now()';
661	$objQuery->insert($table, $arrValues);
662	}
663	}
664
665	/**
666	* 配送商品を登録する.
667	*
668	* @param integer $order_id 受注ID
669	* @param integer $shipping_id 配送先ID
670	* @param array $arrParams 配送商品の配列
671	* @return void
672	*/
673	function registerShipmentItem($order_id, $shipping_id, $arrParams) {
674	$objQuery =& SC_Query_Ex::getSingletonInstance();
675	$table = 'dtb_shipment_item';
676	$where = 'order_id = ? AND shipping_id = ?';
677	$objQuery->delete($table, $where, array($order_id, $shipping_id));
678
679	$objProduct = new SC_Product_Ex();
680	foreach ($arrParams as $arrValues) {
681	if (SC_Utils_Ex::isBlank($arrValues['product_class_id'])) {
682	continue;
683	}
684	$d = $objProduct->getDetailAndProductsClass($arrValues['product_class_id']);
685	$name = SC_Utils_Ex::isBlank($arrValues['product_name'])
686	? $d['name']
687	: $arrValues['product_name'];
688
689	$code = SC_Utils_Ex::isBlank($arrValues['product_code'])
690	? $d['product_code']
691	: $arrValues['product_code'];
692
693	$cname1 = SC_Utils_Ex::isBlank($arrValues['classcategory_name1'])
694	? $d['classcategory_name1']
695	: $arrValues['classcategory_name1'];
696
697	$cname2 = SC_Utils_Ex::isBlank($arrValues['classcategory_name2'])
698	? $d['classcategory_name2']
699	: $arrValues['classcategory_name2'];
700
701	$price = SC_Utils_Ex::isBlank($arrValues['price'])
702	? $d['price02']
703	: $arrValues['price'];
704
705	$arrValues['order_id'] = $order_id;
706	$arrValues['shipping_id'] = $shipping_id;
707	$arrValues['product_name'] = $name;
708	$arrValues['product_code'] = $code;
709	$arrValues['classcategory_name1'] = $cname1;
710	$arrValues['classcategory_name2'] = $cname2;
711	$arrValues['price'] = $price;
712
713	$arrExtractValues = $objQuery->extractOnlyColsOf($table, $arrValues);
714	$objQuery->insert($table, $arrExtractValues);
715	}
716	}
717
718	/**
719	* 受注登録を完了する.
720	*
721	* 引数の受注情報を受注テーブル及び受注詳細テーブルに登録する.
722	* 登録後, 受注一時テーブルに削除フラグを立てる.
723	*
724	* @param array $orderParams 登録する受注情報の配列
725	* @param SC_CartSession $objCartSession カート情報のインスタンス
726	* @param integer $cartKey 登録を行うカート情報のキー
727	* @param integer 受注ID
728	*/
729	function registerOrderComplete($orderParams, &$objCartSession, $cartKey) {
730	$objQuery =& SC_Query_Ex::getSingletonInstance();
731
732	// 不要な変数を unset
733	$unsets = array('mailmaga_flg', 'deliv_check', 'point_check', 'password',
734	'reminder', 'reminder_answer', 'mail_flag', 'session');
735	foreach ($unsets as $unset) {
736	unset($orderParams[$unset]);
737	}
738
739	// 注文ステータスの指定が無い場合は新規受付
740	if(SC_Utils_Ex::isBlank($orderParams['status'])) {
741	$orderParams['status'] = ORDER_NEW;
742	}
743
744	$orderParams['create_date'] = 'Now()';
745	$orderParams['update_date'] = 'Now()';
746
747	$this->registerOrder($orderParams['order_id'], $orderParams);
748
749	// 詳細情報を取得
750	$cartItems = $objCartSession->getCartList($cartKey);
751
752	// 詳細情報を生成
753	$objProduct = new SC_Product_Ex();
754	$i = 0;
755	foreach ($cartItems as $item) {
756	$p =& $item['productsClass'];
757	$arrDetail[$i]['order_id'] = $orderParams['order_id'];
758	$arrDetail[$i]['product_id'] = $p['product_id'];
759	$arrDetail[$i]['product_class_id'] = $p['product_class_id'];
760	$arrDetail[$i]['product_name'] = $p['name'];
761	$arrDetail[$i]['product_code'] = $p['product_code'];
762	$arrDetail[$i]['classcategory_name1'] = $p['classcategory_name1'];
763	$arrDetail[$i]['classcategory_name2'] = $p['classcategory_name2'];
764	$arrDetail[$i]['point_rate'] = $item['point_rate'];
765	$arrDetail[$i]['price'] = $item['price'];
766	$arrDetail[$i]['quantity'] = $item['quantity'];
767
768	// 在庫の減少処理
769	if (!$objProduct->reduceStock($p['product_class_id'], $item['quantity'])) {
770	$objQuery->rollback();
771	SC_Utils_Ex::sfDispSiteError(SOLD_OUT, "", true);
772	}
773	$i++;
774	}
775	$this->registerOrderDetail($orderParams['order_id'], $arrDetail);
776
777	$objQuery->update("dtb_order_temp", array('del_flg' => 1),
778	"order_temp_id = ?",
779	array(SC_SiteSession_Ex::getUniqId()));
780
781	return $orderParams['order_id'];
782	}
783
784	/**
785	* 受注情報を登録する.
786	*
787	* 既に受注IDが存在する場合は, 受注情報を更新する.
788	* 引数の受注IDが, 空白又は null の場合は, 新しく受注IDを発行して登録する.
789	*
790	* @param integer $order_id 受注ID
791	* @param array $arrParams 受注情報の連想配列
792	* @return integer 受注ID
793	*/
794	function registerOrder($order_id, $arrParams) {
795	$table = 'dtb_order';
796	$where = 'order_id = ?';
797	$objQuery = SC_Query_Ex::getSingletonInstance();
798	$arrValues = $objQuery->extractOnlyColsOf($table, $arrParams);
799
800	$exists = $objQuery->count($table, $where, array($order_id));
801	if ($exists > 0) {
802
803	$this->sfUpdateOrderStatus($order_id, $arrValues['status'],
804	$arrValues['add_point'],
805	$arrValues['use_point'],
806	$arrValues);
807	$this->sfUpdateOrderNameCol($order_id);
808
809	$arrValues['update_date'] = 'now()';
810	$objQuery->update($table, $arrValues, $where, array($order_id));
811	} else {
812	if (SC_Utils_Ex::isBlank($order_id)) {
813	$order_id = $objQuery->nextVal('dtb_order_order_id');
814	}
815	/*
816	* 新規受付の場合は受注ステータス null で insert し,
817	* sfUpdateOrderStatus で ORDER_NEW に変更する.
818	*/
819	$status = $arrValues['status'];
820	$arrValues['status'] = null;
821	$arrValues['order_id'] = $order_id;
822	$arrValues['customer_id'] =
823	SC_Utils_Ex::isBlank($arrValues['customer_id'])
824	? 0 : $arrValues['customer_id'];
825	$arrValues['create_date'] = 'now()';
826	$arrValues['update_date'] = 'now()';
827	$objQuery->insert($table, $arrValues);
828
829	$this->sfUpdateOrderStatus($order_id, $status,
830	$arrValues['add_point'],
831	$arrValues['use_point'],
832	$arrValues);
833	$this->sfUpdateOrderNameCol($order_id);
834
835	}
836	return $order_id;
837	}
838
839	/**
840	* 受注詳細情報を登録する.
841	*
842	* 既に, 該当の受注が存在する場合は, 受注情報を削除し, 登録する.
843	*
844	* @param integer $order_id 受注ID
845	* @param array $arrParams 受注情報の連想配列
846	* @return void
847	*/
848	function registerOrderDetail($order_id, $arrParams) {
849	$table = 'dtb_order_detail';
850	$where = 'order_id = ?';
851	$objQuery = SC_Query_Ex::getSingletonInstance();
852
853	$objQuery->delete($table, $where, array($order_id));
854	foreach ($arrParams as $arrDetail) {
855	$arrValues = $objQuery->extractOnlyColsOf($table, $arrDetail);
856	$arrValues['order_detail_id'] = $objQuery->nextVal('dtb_order_detail_order_detail_id');
857	$arrValues['order_id'] = $order_id;
858	$objQuery->insert($table, $arrValues);
859	}
860	}
861
862	/**
863	* 受注情報を取得する.
864	*
865	* @param integer $order_id 受注ID
866	* @param integer $customer_id 会員ID
867	* @return array 受注情報の配列
868	*/
869	function getOrder($order_id, $customer_id = null) {
870	$objQuery =& SC_Query_Ex::getSingletonInstance();
871	$where = 'order_id = ?';
872	$arrValues = array($order_id);
873	if (!SC_Utils_Ex::isBlank($customer_id)) {
874	$where .= ' AND customer_id = ?';
875	$arrValues[] = $customer_id;
876	}
877	return $objQuery->getRow('*', 'dtb_order', $where, $arrValues);
878	}
879
880	/**
881	* 受注詳細を取得する.
882	*
883	* @param integer $order_id 受注ID
884	* @param boolean $has_order_status 受注ステータス, 入金日も含める場合 true
885	* @return array 受注詳細の配列
886	*/
887	function getOrderDetail($order_id, $has_order_status = true) {
888	$objQuery =& SC_Query_Ex::getSingletonInstance();
889	$dbFactory = SC_DB_DBFactory_Ex::getInstance();
890	$col = <<< __EOS__
891	T3.product_id,
892	T3.product_class_id as product_class_id,
893	T3.product_type_id AS product_type_id,
894	T2.product_code,
895	T2.product_name,
896	T2.classcategory_name1 AS classcategory_name1,
897	T2.classcategory_name2 AS classcategory_name2,
898	T2.price,
899	T2.quantity,
900	T2.point_rate,
901	__EOS__;
902	if ($has_order_status) {
903	$col .= 'T1.status AS status, T1.payment_date AS payment_date,';
904
905	}
906	$col .= <<< __EOS__
907
908	CASE WHEN EXISTS(
909	SELECT * FROM dtb_products
910	WHERE product_id = T3.product_id
911	AND del_flg = 0
912	AND status = 1)
913	THEN '1' ELSE '0'
914	END AS enable,
915	__EOS__;
916	$col .= $dbFactory->getDownloadableDaysWhereSql('T1') . ' AS effective';
917	$from = <<< __EOS__
918	dtb_order T1
919	JOIN dtb_order_detail T2
920	ON T1.order_id = T2.order_id
921	JOIN dtb_products_class T3
922	ON T2.product_class_id = T3.product_class_id
923	__EOS__;
924	$objQuery->setOrder('T2.order_detail_id');
925	return $objQuery->select($col, $from, 'T1.order_id = ?', array($order_id));
926	}
927
928	/**
929	* ダウンロード可能フラグを, 受注詳細に設定する.
930	*
931	* ダウンロード可能と判断されるのは, 以下の通り.
932	*
933	* 1. ダウンロード可能期限が期限内かつ, 入金日が入力されている
934	* 2. 販売価格が 0 円である
935	*
936	* 受注詳細行には, is_downloadable という真偽値が設定される.
937	* @param array 受注詳細の配列
938	* @return void
939	*/
940	function setDownloadableFlgTo(&$arrOrderDetail) {
941	foreach (array_keys($arrOrderDetail) as $key) {
942	// 販売価格が 0 円
943	if ($arrOrderDetail[$key]['price'] == '0') {
944	$arrOrderDetail[$key]['is_downloadable'] = true;
945	}
946	// ダウンロード期限内かつ, 入金日あり
947	elseif ($arrOrderDetail[$key]['effective'] == '1'
948	&& !SC_Utils_Ex::isBlank($arrOrderDetail[$key]['payment_date'])) {
949	$arrOrderDetail[$key]['is_downloadable'] = true;
950	} else {
951	$arrOrderDetail[$key]['is_downloadable'] = false;
952	}
953	}
954	}
955
956	/**
957	* 配送情報を取得する.
958	*
959	* @param integer $order_id 受注ID
960	* @param boolean $has_items 結果に配送商品も含める場合 true
961	* @return array 配送情報の配列
962	*/
963	function getShippings($order_id, $has_items = true) {
964	$objQuery =& SC_Query_Ex::getSingletonInstance();
965	$arrResults = array();
966	$objQuery->setOrder('shipping_id');
967	$arrShippings = $objQuery->select("*", "dtb_shipping", "order_id = ?",
968	array($order_id));
969	// shipping_id ごとの配列を生成する
970	foreach ($arrShippings as $shipping) {
971	foreach ($shipping as $key => $val) {
972	$arrResults[$shipping['shipping_id']][$key] = $val;
973	}
974	}
975
976	if ($has_items) {
977	$objProduct = new SC_Product_Ex();
978	foreach (array_keys($arrResults) as $shipping_id) {
979	$arrResults[$shipping_id]['shipment_item']
980	=& $this->getShipmentItems($order_id, $shipping_id);
981	}
982	}
983	return $arrResults;
984	}
985
986	/**
987	* 配送商品を取得する.
988	*
989	* @param integer $order_id 受注ID
990	* @param integer $shipping_id 配送先ID
991	* @param boolean $has_detail 商品詳細も取得する場合 true
992	* @return array 商品規格IDをキーにした配送商品の配列
993	*/
994	function getShipmentItems($order_id, $shipping_id, $has_detail = true) {
995	$objQuery =& SC_Query_Ex::getSingletonInstance();
996	$objProduct = new SC_Product_Ex();
997	$arrResults = array();
998	$arrItems = $objQuery->select("*", "dtb_shipment_item",
999	"order_id = ? AND shipping_id = ?",
1000	array($order_id, $shipping_id));
1001
1002	foreach ($arrItems as $key => $arrItem) {
1003	$product_class_id = $arrItem['product_class_id'];
1004
1005	foreach ($arrItem as $detailKey => $detailVal) {
1006	$arrResults[$key][$detailKey] = $detailVal;
1007	}
1008	// 商品詳細を関連づける
1009	if ($has_detail) {
1010	$arrResults[$key]['productsClass']
1011	=& $objProduct->getDetailAndProductsClass($product_class_id);
1012	}
1013	}
1014	return $arrResults;
1015	}
1016
1017	/**
1018	* 受注完了メールを送信する.
1019	*
1020	* HTTP_USER_AGENT の種別により, 携帯電話の場合は携帯用の文面,
1021	* PC の場合は PC 用の文面でメールを送信する.
1022	*
1023	* @param integer $orderId 受注ID
1024	* @return void
1025	*/
1026	function sendOrderMail($orderId) {
1027	$mailHelper = new SC_Helper_Mail_Ex();
1028	$mailHelper->sfSendOrderMail($orderId,
1029	SC_MobileUserAgent_Ex::isMobile() ? 2 : 1);
1030	}
1031
1032	/**
1033	* 受注.対応状況の更新
1034	*
1035	* 必ず呼び出し元でトランザクションブロックを開いておくこと。
1036	*
1037	* @param integer $orderId 注文番号
1038	* @param integer\|null $newStatus 対応状況 (null=変更無し)
1039	* @param integer\|null $newAddPoint 加算ポイント (null=変更無し)
1040	* @param integer\|null $newUsePoint 使用ポイント (null=変更無し)
1041	* @param array $sqlval 更新後の値をリファレンスさせるためのパラメーター
1042	* @return void
1043	*/
1044	function sfUpdateOrderStatus($orderId, $newStatus = null, $newAddPoint = null, $newUsePoint = null, &$sqlval) {
1045	$objQuery =& SC_Query_Ex::getSingletonInstance();
1046
1047	$arrOrderOld = $objQuery->getRow('status, add_point, use_point, customer_id', 'dtb_order', 'order_id = ?', array($orderId));
1048
1049	// 対応状況が変更無しの場合、DB値を引き継ぐ
1050	if (is_null($newStatus)) {
1051	$newStatus = $arrOrderOld['status'];
1052	}
1053
1054	// 使用ポイント、DB値を引き継ぐ
1055	if (is_null($newUsePoint)) {
1056	$newUsePoint = $arrOrderOld['use_point'];
1057	}
1058
1059	// 加算ポイント、DB値を引き継ぐ
1060	if (is_null($newAddPoint)) {
1061	$newAddPoint = $arrOrderOld['add_point'];
1062	}
1063
1064	if (USE_POINT !== false) {
1065	// 会員.ポイントの加減値
1066	$addCustomerPoint = 0;
1067
1068	// ▼使用ポイント
1069	// 変更前の対応状況が利用対象の場合、変更前の使用ポイント分を戻す
1070	if ($this->isUsePoint($arrOrderOld['status'])) {
1071	$addCustomerPoint += $arrOrderOld['use_point'];
1072	}
1073
1074	// 変更後の対応状況が利用対象の場合、変更後の使用ポイント分を引く
1075	if ($this->isUsePoint($newStatus)) {
1076	$addCustomerPoint -= $newUsePoint;
1077	}
1078
1079	// ▲使用ポイント
1080
1081	// ▼加算ポイント
1082	// 変更前の対応状況が加算対象の場合、変更前の加算ポイント分を戻す
1083	if ($this->isAddPoint($arrOrderOld['status'])) {
1084	$addCustomerPoint -= $arrOrderOld['add_point'];
1085	}
1086
1087	// 変更後の対応状況が加算対象の場合、変更後の加算ポイント分を足す
1088	if ($this->isAddPoint($newStatus)) {
1089	$addCustomerPoint += $newAddPoint;
1090	}
1091	// ▲加算ポイント
1092
1093	if ($addCustomerPoint != 0) {
1094	// ▼会員テーブルの更新
1095	$sqlval = array();
1096	$where = '';
1097	$arrVal = array();
1098	$arrRawSql = array();
1099	$arrRawSqlVal = array();
1100
1101	$sqlval['update_date'] = 'Now()';
1102	$arrRawSql['point'] = 'point + ?';
1103	$arrRawSqlVal[] = $addCustomerPoint;
1104	$where .= 'customer_id = ?';
1105	$arrVal[] = $arrOrderOld['customer_id'];
1106
1107	$objQuery->update('dtb_customer', $sqlval, $where, $arrVal, $arrRawSql, $arrRawSqlVal);
1108	// ▲会員テーブルの更新
1109
1110	// 会員.ポイントをマイナスした場合、
1111	if ($addCustomerPoint < 0) {
1112	$sql = 'SELECT point FROM dtb_customer WHERE customer_id = ?';
1113	$point = $objQuery->getOne($sql, array($arrOrderOld['customer_id']));
1114	// 変更後の会員.ポイントがマイナスの場合、
1115	if ($point < 0) {
1116	// ロールバック
1117	$objQuery->rollback();
1118	// エラー
1119	SC_Utils_Ex::sfDispSiteError(LACK_POINT);
1120	}
1121	}
1122	}
1123	}
1124
1125	// ▼受注テーブルの更新
1126	if (empty($sqlval)) {
1127	$sqlval = array();
1128	}
1129
1130	if (USE_POINT !== false) {
1131	$sqlval['add_point'] = $newAddPoint;
1132	$sqlval['use_point'] = $newUsePoint;
1133	}
1134	// ステータスが発送済みに変更の場合、発送日を更新
1135	if ($arrOrderOld['status'] != ORDER_DELIV && $newStatus == ORDER_DELIV) {
1136	$sqlval['commit_date'] = 'Now()';
1137	}
1138	// ステータスが入金済みに変更の場合、入金日を更新
1139	elseif ($arrOrderOld['status'] != ORDER_PRE_END && $newStatus == ORDER_PRE_END) {
1140	$sqlval['payment_date'] = 'Now()';
1141	}
1142
1143	$sqlval['status'] = $newStatus;
1144	$sqlval['update_date'] = 'Now()';
1145
1146	$dest = $objQuery->extractOnlyColsOf('dtb_order', $sqlval);
1147	$objQuery->update('dtb_order', $dest, 'order_id = ?', array($orderId));
1148	// ▲受注テーブルの更新
1149	}
1150
1151	/**
1152	* 受注の名称列を更新する
1153	*
1154	* @param integer $order_id 更新対象の注文番号
1155	* @param boolean $temp_table 更新対象は「受注_Temp」か
1156	* @static
1157	*/
1158	function sfUpdateOrderNameCol($order_id, $temp_table = false) {
1159	$objQuery =& SC_Query_Ex::getSingletonInstance();
1160
1161	if ($temp_table) {
1162	$tgt_table = 'dtb_order_temp';
1163	$sql_where = 'order_temp_id = ?';
1164	} else {
1165	$tgt_table = 'dtb_order';
1166	$sql_where = 'order_id = ?';
1167
1168	$objQuery->update('dtb_shipping', array(),
1169	$sql_where,
1170	array($order_id),
1171	array('shipping_time' =>
1172	"(SELECT deliv_time FROM dtb_delivtime WHERE time_id = dtb_shipping.time_id AND deliv_id = dtb_shipping.deliv_id)"));
1173
1174	}
1175
1176	$objQuery->update($tgt_table, array(),
1177	$sql_where,
1178	array($order_id),
1179	array('payment_method' =>
1180	"(SELECT payment_method FROM dtb_payment WHERE payment_id = " . $tgt_table . ".payment_id)"));
1181	}
1182
1183	/**
1184	* ポイント使用するかの判定
1185	*
1186	* $status が null の場合は false を返す.
1187	*
1188	* @param integer $status 対応状況
1189	* @return boolean 使用するか(会員テーブルから減算するか)
1190	*/
1191	function isUsePoint($status) {
1192	if ($status == null) {
1193	return false;
1194	}
1195	switch ($status) {
1196	case ORDER_CANCEL: // キャンセル
1197	return false;
1198	default:
1199	break;
1200	}
1201
1202	return true;
1203	}
1204
1205	/**
1206	* ポイント加算するかの判定
1207	*
1208	* @param integer $status 対応状況
1209	* @return boolean 加算するか
1210	*/
1211	function isAddPoint($status) {
1212	switch ($status) {
1213	case ORDER_NEW: // 新規注文
1214	case ORDER_PAY_WAIT: // 入金待ち
1215	case ORDER_PRE_END: // 入金済み
1216	case ORDER_CANCEL: // キャンセル
1217	case ORDER_BACK_ORDER: // 取り寄せ中
1218	return false;
1219
1220	case ORDER_DELIV: // 発送済み
1221	return true;
1222
1223	default:
1224	break;
1225	}
1226
1227	return false;
1228	}
1229
1230	/**
1231	* セッションに保持している情報を破棄する.
1232	*
1233	* 通常、受注処理(completeOrder)完了後に呼び出され、
1234	* セッション情報を破棄する.
1235	*
1236	* 決済モジュール画面から確認画面に「戻る」場合を考慮し、
1237	* セッション情報を破棄しないカスタマイズを、モジュール側で
1238	* 加える機会を与える.
1239	*
1240	* @param integer $orderId 注文番号
1241	* @param SC_CartSession $objCartSession カート情報のインスタンス
1242	* @param SC_Customer $objCustomer SC_Customer インスタンス
1243	* @param integer $cartKey 登録を行うカート情報のキー
1244	*/
1245	function cleanupSession($orderId, &$objCartSession, &$objCustomer, $cartKey) {
1246	// カートの内容を削除する.
1247	$objCartSession->delAllProducts($cartKey);
1248	SC_SiteSession_Ex::unsetUniqId();
1249
1250	// セッションの配送情報を破棄する.
1251	$this->unsetShippingTemp();
1252	$objCustomer->updateSession();
1253	}
1254	}

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

Download in other formats: