Context Navigation

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

Visit:

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

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

Download in other formats: