buy.model.php 59 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278
  1. <?php
  2. /**
  3. * 下单业务模型
  4. *
  5. * by 33hao.com 好商城欢迎您使用
  6. */
  7. defined('InShopNC') or exit('Access Invalid!');
  8. class buyModel {
  9. /**
  10. * 输出有货到付款时,在线支付和货到付款及每种支付下商品数量和详细列表
  11. * @param $buy_list 商品列表
  12. * @return 返回 以支付方式为下标分组的商品列表
  13. */
  14. public function getOfflineGoodsPay($buy_list) {
  15. //以支付方式为下标,存放购买商品
  16. $buy_goods_list = array();
  17. $offline_pay = Model('payment')->getPaymentOpenInfo(array('payment_code'=>'offline'));
  18. if ($offline_pay) {
  19. //下单里包括平台自营商品并且平台已开户货到付款,则显示货到付款项及对应商品数量,取出支持货到付款的店铺ID组成的数组,目前就一个,DEFAULT_PLATFORM_STORE_ID
  20. $offline_store_id_array = array(DEFAULT_PLATFORM_STORE_ID);
  21. foreach ($buy_list as $value) {
  22. if (in_array($value['store_id'],$offline_store_id_array)) {
  23. $buy_goods_list['offline'][] = $value;
  24. } else {
  25. $buy_goods_list['online'][] = $value;
  26. }
  27. }
  28. }
  29. return $buy_goods_list;
  30. }
  31. /**
  32. * 计算每个店铺(所有店铺级优惠活动)总共优惠多少金额
  33. * @param array $store_goods_total 最初店铺商品总金额
  34. * @param array $store_final_goods_total 去除各种店铺级促销后,最终店铺商品总金额(不含运费)
  35. * @return array
  36. */
  37. public function getStorePromotionTotal($store_goods_total, $store_final_goods_total) {
  38. if (!is_array($store_goods_total) || !is_array($store_final_goods_total)) return array();
  39. $store_promotion_total = array();
  40. foreach ($store_goods_total as $store_id => $goods_total) {
  41. $store_promotion_total[$store_id] = abs($goods_total - $store_final_goods_total[$store_id]);
  42. }
  43. return $store_promotion_total;
  44. }
  45. /**
  46. * 返回需要计算运费的店铺ID组成的数组 和 免运费店铺ID及免运费下限金额描述
  47. * @param array $store_goods_total 每个店铺的商品金额小计,以店铺ID为下标
  48. * @return array
  49. */
  50. public function getStoreFreightDescList($store_goods_total) {
  51. if (empty($store_goods_total) || !is_array($store_goods_total)) return array(array(),array());
  52. //定义返回数组
  53. $need_calc_sid_array = array();
  54. $cancel_calc_sid_array = array();
  55. //如果商品金额未达到免运费设置下线,则需要计算运费
  56. $condition = array('store_id' => array('in',array_keys($store_goods_total)));
  57. $store_list = Model('store')->getStoreOnlineList($condition,null,'','store_id,store_free_price');
  58. foreach ($store_list as $store_info) {
  59. $limit_price = floatval($store_info['store_free_price']);
  60. if ($limit_price == 0 || $limit_price > $store_goods_total[$store_info['store_id']]) {
  61. //需要计算运费
  62. $need_calc_sid_array[] = $store_info['store_id'];
  63. } else {
  64. //返回免运费金额下限
  65. $cancel_calc_sid_array[$store_info['store_id']]['free_price'] = $limit_price;
  66. $cancel_calc_sid_array[$store_info['store_id']]['desc'] = sprintf('满%s免运费',$limit_price);
  67. }
  68. }
  69. return array($need_calc_sid_array,$cancel_calc_sid_array);
  70. }
  71. /**
  72. * 取得店铺运费(使用运费模板的商品运费不会计算,但会返回模板信息)
  73. * 先将免运费的店铺运费置0,然后算出店铺里没使用运费模板的商品运费之和 ,存到iscalced下标中
  74. * 然后再计算使用运费模板的信息(array(店铺ID=>array(运费模板ID=>购买数量)),放到nocalced下标里
  75. * @param array $buy_list 购买商品列表
  76. * @param array $free_freight_sid_list 免运费的店铺ID数组
  77. */
  78. public function getStoreFreightList($buy_list = array(), $free_freight_sid_list) {
  79. //定义返回数组
  80. $return = array();
  81. //先将免运费的店铺运费置0(格式:店铺ID=>0)
  82. $freight_list = array();
  83. if (!empty($free_freight_sid_list) && is_array($free_freight_sid_list)) {
  84. foreach ($free_freight_sid_list as $store_id) {
  85. $freight_list[$store_id] = 0;
  86. }
  87. }
  88. //然后算出店铺里没使用运费模板(优惠套装商品除外)的商品运费之和(格式:店铺ID=>运费)
  89. //定义数组,存放店铺优惠套装商品运费总额 store_id=>运费
  90. $store_bl_goods_freight = array();
  91. foreach ($buy_list as $key => $goods_info) {
  92. //免运费店铺的商品不需要计算
  93. if (array_key_exists($goods_info['store_id'], $freight_list)) {
  94. unset($buy_list[$key]);
  95. continue;
  96. }
  97. //优惠套装商品运费另算
  98. if (intval($goods_info['bl_id'])) {
  99. unset($buy_list[$key]);
  100. $store_bl_goods_freight[$goods_info['store_id']] = $goods_info['bl_id'];
  101. continue;
  102. }
  103. if (!intval($goods_info['transport_id']) && !in_array($goods_info['store_id'],$free_freight_sid_list)) {
  104. $freight_list[$goods_info['store_id']] += $goods_info['goods_freight'];
  105. unset($buy_list[$key]);
  106. }
  107. }
  108. //计算优惠套装商品运费
  109. if (!empty($store_bl_goods_freight)) {
  110. $model_bl = Model('p_bundling');
  111. foreach (array_unique($store_bl_goods_freight) as $store_id => $bl_id) {
  112. $bl_info = $model_bl->getBundlingInfo(array('bl_id'=>$bl_id));
  113. if (!empty($bl_info)) {
  114. $freight_list[$store_id] += $bl_info['bl_freight'];
  115. }
  116. }
  117. }
  118. $return['iscalced'] = $freight_list;
  119. //最后再计算使用运费模板的信息(店铺ID,运费模板ID,购买数量),使用使用相同运费模板的商品数量累加
  120. $freight_list = array();
  121. foreach ($buy_list as $goods_info) {
  122. $freight_list[$goods_info['store_id']][$goods_info['transport_id']] += $goods_info['goods_num'];
  123. }
  124. $return['nocalced'] = $freight_list;
  125. return $return;
  126. }
  127. /**
  128. * 根据地区选择计算出所有店铺最终运费
  129. * @param array $freight_list 运费信息(店铺ID,运费,运费模板ID,购买数量)
  130. * @param int $city_id 市级ID
  131. * @return array 返回店铺ID=>运费
  132. */
  133. public function calcStoreFreight($freight_list, $city_id) {
  134. if (!is_array($freight_list) || empty($freight_list) || empty($city_id)) return;
  135. //免费和固定运费计算结果
  136. $return_list = $freight_list['iscalced'];
  137. //使用运费模板的信息(array(店铺ID=>array(运费模板ID=>购买数量))
  138. $nocalced_list = $freight_list['nocalced'];
  139. //然后计算使用运费运费模板的在该$city_id时的运费值
  140. if (!empty($nocalced_list) && is_array($nocalced_list)) {
  141. //如果有商品使用的运费模板,先计算这些商品的运费总金额
  142. $model_transport = Model('transport');
  143. foreach ($nocalced_list as $store_id => $value) {
  144. if (is_array($value)) {
  145. foreach ($value as $transport_id => $buy_num) {
  146. $freight_total = $model_transport->calc_transport($transport_id,$buy_num, $city_id);
  147. if (empty($return_list[$store_id])) {
  148. $return_list[$store_id] = $freight_total;
  149. } else {
  150. $return_list[$store_id] += $freight_total;
  151. }
  152. }
  153. }
  154. }
  155. }
  156. return $return_list;
  157. }
  158. /**
  159. * 取得店铺下商品分类佣金比例
  160. * @param array $goods_list
  161. * @return array 店铺ID=>array(分类ID=>佣金比例)
  162. */
  163. public function getStoreGcidCommisRateList($goods_list) {
  164. if (empty($goods_list) || !is_array($goods_list)) return array();
  165. //定义返回数组
  166. $store_gc_id_commis_rate = array();
  167. //取得每个店铺下有哪些商品分类
  168. $store_gc_id_list = array();
  169. foreach ($goods_list as $goods) {
  170. if (!intval($goods['gc_id'])) continue;
  171. if (!in_array($goods['gc_id'],(array)$store_gc_id_list[$goods['store_id']])) {
  172. if (in_array($goods['store_id'],array(DEFAULT_PLATFORM_STORE_ID))) {
  173. //平台店铺佣金为0 33hao
  174. //$store_gc_id_commis_rate[$goods['store_id']][$goods['gc_id']] = 0;
  175. } else {
  176. //$store_gc_id_list[$goods['store_id']][] = $goods['gc_id'];
  177. }
  178. //33hao
  179. $store_gc_id_list[$goods['store_id']][] = $goods['gc_id'];
  180. }
  181. }
  182. if (empty($store_gc_id_list)) return array();
  183. $model_bind_class = Model('store_bind_class');
  184. //商品分类
  185. $goods_class = Model('goods_class')->getGoodsClassForCacheModel();
  186. foreach ($store_gc_id_list as $store_id => $gc_id_list) {
  187. $condition = array();
  188. $condition['store_id'] = $store_id;
  189. foreach($gc_id_list as $gc_id)
  190. {
  191. $class_2 = $goods_class[$gc_id]['gc_parent_id'];
  192. $class_1 = $goods_class[$class_2]['gc_parent_id'];
  193. $condition['class_1'] = $class_1;
  194. $condition['class_2'] = $class_2;
  195. $condition['class_3'] = $gc_id;
  196. $bind_info = $model_bind_class->getStoreBindClassInfo($condition);
  197. if (!empty($bind_info))
  198. {
  199. $store_gc_id_commis_rate[$store_id][$gc_id] = $bind_info['commis_rate'];
  200. }
  201. else
  202. {
  203. $condition['class_3'] = 0;
  204. $bind_info = $model_bind_class->getStoreBindClassInfo($condition);
  205. if (!empty($bind_info))
  206. {
  207. $store_gc_id_commis_rate[$store_id][$gc_id] = $bind_info['commis_rate'];
  208. }
  209. else
  210. {
  211. $condition['class_2'] = 0;
  212. $condition['class_3'] = 0;
  213. $bind_info = $model_bind_class->getStoreBindClassInfo($condition);
  214. if (!empty($bind_info))
  215. {
  216. $store_gc_id_commis_rate[$store_id][$gc_id] = $bind_info['commis_rate'];
  217. }
  218. else
  219. {
  220. $condition['class_1'] = 0;
  221. $condition['class_2'] = 0;
  222. $condition['class_3'] = 0;
  223. $bind_info = $model_bind_class->getStoreBindClassInfo($condition);
  224. if (!empty($bind_info))
  225. {
  226. $store_gc_id_commis_rate[$store_id][$gc_id] = $bind_info['commis_rate'];
  227. }
  228. }
  229. }
  230. }
  231. }
  232. }
  233. return $store_gc_id_commis_rate;
  234. }
  235. /**
  236. * 追加赠品到下单列表,并更新购买数量
  237. * @param array $store_cart_list 购买列表
  238. * @param array $store_premiums_list 赠品列表
  239. * @param array $store_mansong_rule_list 满即送规则
  240. */
  241. public function appendPremiumsToCartList($store_cart_list, $store_premiums_list = array(), $store_mansong_rule_list = array(), $member_id) {
  242. if (empty($store_cart_list)) return array();
  243. //取得每种商品的库存
  244. $goods_storage_quantity = $this->_getEachGoodsStorageQuantity($store_cart_list,$store_premiums_list);
  245. //取得每种商品的购买量
  246. $goods_buy_quantity = $this->_getEachGoodsBuyQuantity($store_cart_list);
  247. //本次购买后,余库存为0的,则后面不再送赠品
  248. $last_storage = array();
  249. foreach ($goods_buy_quantity as $goods_id => $quantity) {
  250. $goods_storage_quantity[$goods_id] -= $quantity;
  251. if ($goods_storage_quantity[$goods_id] < 0) {
  252. return array('error' => '抱歉,您购买的商品库存不足,请重购买');
  253. }
  254. }
  255. //将赠品追加到购买列表
  256. if(is_array($store_premiums_list)) {
  257. foreach ($store_premiums_list as $store_id => $goods_list) {
  258. foreach ($goods_list as $goods_info) {
  259. //如果没有库存了,则不再送赠品
  260. if (!intval($goods_storage_quantity[$goods_id])) {
  261. $store_mansong_rule_list[$store_id]['desc'] .= ' ( 抱歉,库存不足,系统未送赠品 )';
  262. continue;
  263. }
  264. $new_data = array();
  265. $new_data['buyer_id'] = $member_id;
  266. $new_data['store_id'] = $store_id;
  267. $new_data['store_name'] = $store_cart_list[$store_id][0]['store_name'];
  268. $new_data['goods_id'] = $goods_info['goods_id'];
  269. $new_data['goods_name'] = $goods_info['goods_name'];
  270. $new_data['goods_num'] = 1;
  271. $new_data['goods_price'] = 0;
  272. $new_data['goods_image'] = $goods_info['goods_image'];
  273. $new_data['bl_id'] = 0;
  274. $new_data['state'] = true;
  275. $new_data['storage_state'] = true;
  276. $new_data['gc_id'] = 0;
  277. $new_data['transport_id'] = 0;
  278. $new_data['goods_freight'] = 0;
  279. $new_data['goods_vat'] = 0;
  280. $new_data['goods_total'] = 0;
  281. $new_data['ifzengpin'] = true;
  282. $store_cart_list[$store_id][] = $new_data;
  283. $goods_buy_quantity[$goods_info['goods_id']] += 1;
  284. }
  285. }
  286. }
  287. return array($store_cart_list,$goods_buy_quantity,$store_mansong_rule_list);
  288. }
  289. /**
  290. * 取得每种商品的库存
  291. * @param array $store_cart_list 购买列表
  292. * @param array $store_premiums_list 赠品列表
  293. * @return array 商品ID=>库存
  294. */
  295. private function _getEachGoodsStorageQuantity($store_cart_list, $store_premiums_list = array()) {
  296. if(empty($store_cart_list) || !is_array($store_cart_list)) return array();
  297. $goods_storage_quangity = array();
  298. foreach ($store_cart_list as $store_cart) {
  299. foreach ($store_cart as $cart_info) {
  300. if (!intval($cart_info['bl_id'])) {
  301. //正常商品
  302. $goods_storage_quangity[$cart_info['goods_id']] = $cart_info['goods_storage'];
  303. } elseif (!empty($cart_info['bl_goods_list']) && is_array($cart_info['bl_goods_list'])) {
  304. //优惠套装
  305. foreach ($cart_info['bl_goods_list'] as $goods_info) {
  306. $goods_storage_quangity[$goods_info['goods_id']] = $goods_info['goods_storage'];
  307. }
  308. }
  309. }
  310. }
  311. //取得赠品商品的库存
  312. if (is_array($store_premiums_list)) {
  313. foreach ($store_premiums_list as $store_id => $goods_list) {
  314. foreach($goods_list as $goods_info) {
  315. if (!isset($goods_storage_quangity[$goods_info['goods_id']])) {
  316. $goods_storage_quangity[$goods_info['goods_id']] = $goods_info['goods_storage'];
  317. }
  318. }
  319. }
  320. }
  321. return $goods_storage_quangity;
  322. }
  323. /**
  324. * 取得每种商品的购买量
  325. * @param array $store_cart_list 购买列表
  326. * @return array 商品ID=>购买数量
  327. */
  328. private function _getEachGoodsBuyQuantity($store_cart_list) {
  329. if(empty($store_cart_list) || !is_array($store_cart_list)) return array();
  330. $goods_buy_quangity = array();
  331. foreach ($store_cart_list as $store_cart) {
  332. foreach ($store_cart as $cart_info) {
  333. if (!intval($cart_info['bl_id'])) {
  334. //正常商品
  335. $goods_buy_quangity[$cart_info['goods_id']] += $cart_info['goods_num'];
  336. } elseif (!empty($cart_info['bl_goods_list']) && is_array($cart_info['bl_goods_list'])) {
  337. //优惠套装
  338. foreach ($cart_info['bl_goods_list'] as $goods_info) {
  339. $goods_buy_quangity[$goods_info['goods_id']] += $cart_info['goods_num'];
  340. }
  341. }
  342. }
  343. }
  344. return $goods_buy_quangity;
  345. }
  346. /**
  347. * 生成订单
  348. * @param array $input
  349. * @throws Exception
  350. * @return array array(支付单sn,订单列表)
  351. */
  352. public function createOrder($input, $member_id, $member_name, $member_email) {
  353. extract($input);
  354. $model_order = Model('order');
  355. //存储生成的订单,函数会返回该数组
  356. $order_list = array();
  357. //每个店铺订单是货到付款还是线上支付,店铺ID=>付款方式[在线支付/货到付款]
  358. $store_pay_type_list = $this->_getStorePayTypeList(array_keys($store_cart_list), $if_offpay, $pay_name);
  359. $pay_sn = $this->makePaySn($member_id);
  360. $order_pay = array();
  361. $order_pay['pay_sn'] = $pay_sn;
  362. $order_pay['buyer_id'] = $member_id;
  363. $order_pay_id = $model_order->addOrderPay($order_pay);
  364. if (!$order_pay_id) {
  365. throw new Exception('订单保存失败');
  366. }
  367. //收货人信息
  368. $reciver_info = array();
  369. $reciver_info['address'] = $address_info['area_info'].'&nbsp;'.$address_info['address'];
  370. $reciver_info['phone'] = $address_info['mob_phone'].($address_info['tel_phone'] ? ','.$address_info['tel_phone'] : null);
  371. $reciver_info = serialize($reciver_info);
  372. $reciver_name = $address_info['true_name'];
  373. foreach ($store_cart_list as $store_id => $goods_list) {
  374. //取得本店优惠额度(后面用来计算每件商品实际支付金额,结算需要)
  375. $promotion_total = !empty($store_promotion_total[$store_id]) ? $store_promotion_total[$store_id] : 0;
  376. //本店总的优惠比例,保留3位小数
  377. $should_goods_total = $store_final_order_total[$store_id]-$store_freight_total[$store_id]+$promotion_total;
  378. $promotion_rate = abs(number_format($promotion_total/$should_goods_total,5));
  379. if ($promotion_rate <= 1) {
  380. $promotion_rate = floatval(substr($promotion_rate,0,5));
  381. } else {
  382. $promotion_rate = 0;
  383. }
  384. //每种商品的优惠金额累加保存入 $promotion_sum
  385. $promotion_sum = 0;
  386. $order = array();
  387. $order_common = array();
  388. $order_goods = array();
  389. $order['order_sn'] = $this->makeOrderSn($order_pay_id);
  390. $order['pay_sn'] = $pay_sn;
  391. $order['store_id'] = $store_id;
  392. $order['store_name'] = $goods_list[0]['store_name'];
  393. $order['buyer_id'] = $member_id;
  394. $order['buyer_name'] = $member_name;
  395. $order['buyer_email'] = $member_email;
  396. $order['add_time'] = time();
  397. $order['payment_code'] = $store_pay_type_list[$store_id];
  398. $order['order_state'] = $store_pay_type_list[$store_id] == 'online' ? ORDER_STATE_NEW : ORDER_STATE_PAY;
  399. $order['order_amount'] = $store_final_order_total[$store_id];
  400. $order['shipping_fee'] = $store_freight_total[$store_id];
  401. $order['goods_amount'] = $order['order_amount'] - $order['shipping_fee'];
  402. $order['order_from'] = 1;
  403. $order_id = $model_order->addOrder($order);
  404. if (!$order_id) {
  405. throw new Exception('订单保存失败');
  406. }
  407. $order['order_id'] = $order_id;
  408. $order_list[$order_id] = $order;
  409. $order_common['order_id'] = $order_id;
  410. $order_common['store_id'] = $store_id;
  411. $order_common['order_message'] = $pay_message[$store_id];
  412. //代金券
  413. if (isset($voucher_list[$store_id])){
  414. $order_common['voucher_price'] = $voucher_list[$store_id]['voucher_price'];
  415. $order_common['voucher_code'] = $voucher_list[$store_id]['voucher_code'];
  416. }
  417. $order_common['reciver_info']= $reciver_info;
  418. $order_common['reciver_name'] = $reciver_name;
  419. //发票信息
  420. $order_common['invoice_info'] = $this->_createInvoiceData($invoice_info);
  421. //保存促销信息
  422. if(is_array($store_mansong_rule_list[$store_id])) {
  423. $order_common['promotion_info'] = addslashes($store_mansong_rule_list[$store_id]['desc']);
  424. }
  425. //取得省ID b y 3 3 h a o .com 货到付款
  426. require_once(BASE_DATA_PATH.'/area/area.php');
  427. $order_common['reciver_province_id'] = intval($area_array[$input_city_id]['area_parent_id']);
  428. $order_id = $model_order->addOrderCommon($order_common);
  429. if (!$order_id) {
  430. throw new Exception('订单保存失败');
  431. }
  432. //生成order_goods订单商品数据
  433. $i = 0;
  434. foreach ($goods_list as $goods_info) {
  435. if (!$goods_info['state'] || !$goods_info['storage_state']) {
  436. throw new Exception('部分商品已经下架或库存不足,请重新选择');
  437. }
  438. if (!intval($goods_info['bl_id'])) {
  439. //如果不是优惠套装
  440. $order_goods[$i]['order_id'] = $order_id;
  441. $order_goods[$i]['goods_id'] = $goods_info['goods_id'];
  442. $order_goods[$i]['store_id'] = $store_id;
  443. $order_goods[$i]['goods_name'] = $goods_info['goods_name'];
  444. $order_goods[$i]['goods_price'] = $goods_info['goods_price'];
  445. $order_goods[$i]['goods_num'] = $goods_info['goods_num'];
  446. $order_goods[$i]['goods_image'] = $goods_info['goods_image'];
  447. $order_goods[$i]['buyer_id'] = $member_id;
  448. if ($goods_info['ifgroupbuy']) {
  449. $order_goods[$i]['goods_type'] = 2;
  450. }elseif ($goods_info['ifxianshi']) {
  451. $order_goods[$i]['goods_type'] = 3;
  452. }elseif ($goods_info['ifzengpin']) {
  453. $order_goods[$i]['goods_type'] = 5;
  454. }else {
  455. $order_goods[$i]['goods_type'] = 1;
  456. }
  457. $order_goods[$i]['promotions_id'] = $goods_info['promotions_id'] ? $goods_info['promotions_id'] : 0;
  458. $order_goods[$i]['commis_rate'] = floatval($store_gc_id_commis_rate_list[$store_id][$goods_info['gc_id']]);
  459. $order_goods[$i]['gc_id'] = $goods_info['gc_id'];
  460. //计算商品金额
  461. $goods_total = $goods_info['goods_price'] * $goods_info['goods_num'];
  462. //计算本件商品优惠金额
  463. $promotion_value = floor($goods_total*($promotion_rate));
  464. $order_goods[$i]['goods_pay_price'] = $goods_total - $promotion_value;
  465. $promotion_sum += $promotion_value;
  466. $i++;
  467. // 验证库存发送库存报警
  468. if ($goods_info['goods_storage_alarm'] >= ($goods_info['goods_storage'] - $goods_info['goods_num'])) {
  469. $param = array();
  470. $param['common_id'] = $goods_info['goods_commonid'];
  471. $param['sku_id'] = $goods_info['goods_id'];
  472. $this->sendStoreMsg('goods_storage_alarm', $goods_info['store_id'], $param);
  473. }
  474. } elseif (!empty($goods_info['bl_goods_list']) && is_array($goods_info['bl_goods_list'])) {
  475. //优惠套装
  476. foreach ($goods_info['bl_goods_list'] as $bl_goods_info) {
  477. $order_goods[$i]['order_id'] = $order_id;
  478. $order_goods[$i]['goods_id'] = $bl_goods_info['goods_id'];
  479. $order_goods[$i]['store_id'] = $store_id;
  480. $order_goods[$i]['goods_name'] = $bl_goods_info['goods_name'];
  481. $order_goods[$i]['goods_price'] = $bl_goods_info['bl_goods_price'];
  482. $order_goods[$i]['goods_num'] = $goods_info['goods_num'];
  483. $order_goods[$i]['goods_image'] = $bl_goods_info['goods_image'];
  484. $order_goods[$i]['buyer_id'] = $member_id;
  485. $order_goods[$i]['goods_type'] = 4;
  486. $order_goods[$i]['promotions_id'] = $bl_goods_info['bl_id'];
  487. $order_goods[$i]['commis_rate'] = floatval($store_gc_id_commis_rate_list[$store_id][$goods_info['gc_id']]);
  488. $order_goods[$i]['gc_id'] = $bl_goods_info['gc_id'];
  489. //计算商品实际支付金额(goods_price减去分摊优惠金额后的值)
  490. $goods_total = $bl_goods_info['bl_goods_price'] * $goods_info['goods_num'];
  491. //计算本件商品优惠金额
  492. $promotion_value = floor($goods_total*($promotion_rate));
  493. $order_goods[$i]['goods_pay_price'] = $goods_total - $promotion_value;
  494. $promotion_sum += $promotion_value;
  495. $i++;
  496. // 验证库存发送库存报警
  497. if ($bl_goods_info['goods_storage_alarm'] >= ($bl_goods_info['goods_storage'] - $goods_info['goods_num'])) {
  498. $param = array();
  499. $param['common_id'] = $bl_goods_info['goods_commonid'];
  500. $param['sku_id'] = $bl_goods_info['goods_id'];
  501. $this->sendStoreMsg('goods_storage_alarm', $bl_goods_info['store_id'], $param);
  502. }
  503. }
  504. }
  505. }
  506. //将因舍出小数部分出现的差值补到最后一个商品的实际成交价中(商品goods_price=0时不给补,可能是赠品)
  507. if ($promotion_total > $promotion_sum) {
  508. $i--;
  509. for($i;$i>=0;$i--) {
  510. if (floatval($order_goods[$i]['goods_price']) > 0) {
  511. $order_goods[$i]['goods_pay_price'] -= $promotion_total - $promotion_sum;
  512. break;
  513. }
  514. }
  515. }
  516. $insert = $model_order->addOrderGoods($order_goods);
  517. if (!$insert) {
  518. throw new Exception('订单保存失败');
  519. }
  520. // 货到付款订单发送商家提醒
  521. if ($store_pay_type_list[$store_id] == 'offline') {
  522. $param = array();
  523. $param['order_sn'] = $order['order_sn'];
  524. $this->sendStoreMsg('new_order', $order['store_id'], $param);
  525. }
  526. }
  527. return array($pay_sn,$order_list);
  528. }
  529. /**
  530. * 发送店铺消息
  531. * @param string $code
  532. * @param int $store_id
  533. * @param array $param
  534. */
  535. private function sendStoreMsg($code, $store_id, $param) {
  536. QueueClient::push('sendStoreMsg', array('code' => $code, 'store_id' => $store_id, 'param' => $param));
  537. }
  538. /**
  539. * 记录订单日志
  540. * @param array $order_list
  541. */
  542. public function addOrderLog($order_list = array()) {
  543. if (empty($order_list) || !is_array($order_list)) return;
  544. $model_order = Model('order');
  545. foreach ($order_list as $order_id => $order) {
  546. $data = array();
  547. $data['order_id'] = $order_id;
  548. $data['log_role'] = 'buyer';
  549. $data['log_msg'] = L('order_log_new');
  550. $data['log_orderstate'] = $order['payment_code'] == 'offline' ? ORDER_STATE_PAY : ORDER_STATE_NEW;
  551. $model_order->addOrderLog($data);
  552. }
  553. }
  554. /**
  555. * 店铺购买列表
  556. * @param array $goods_buy_quantity 商品ID与购买数量数组
  557. * @throws Exception
  558. */
  559. public function updateGoodsStorageNum($goods_buy_quantity) {
  560. if (empty($goods_buy_quantity) || !is_array($goods_buy_quantity)) return;
  561. $model_goods = Model('goods');
  562. foreach ($goods_buy_quantity as $goods_id => $quantity) {
  563. //$goods_info = $cart_info;
  564. $data = array();
  565. $data['goods_storage'] = array('exp','goods_storage-'.$quantity);
  566. $data['goods_salenum'] = array('exp','goods_salenum+'.$quantity);
  567. $result = $model_goods->editGoods($data,array('goods_id'=>$goods_id));
  568. if (!$result) throw new Exception('更新库存失败');
  569. }
  570. }
  571. /**
  572. * 预存款支付,依次循环每个订单
  573. * 如果预存款足够就单独支付了该订单,如果不足就暂时冻结,等API支付成功了再彻底扣除
  574. */
  575. public function pdPay($order_list, $input, $member_id, $member_name) {
  576. if (empty($input['pd_pay']) || empty($input['password'])) return;
  577. $model_payment = Model('payment');
  578. $pd_payment_info = $model_payment->getPaymentOpenInfo(array('payment_code'=>'predeposit'));
  579. if (empty($pd_payment_info)) return;
  580. $buyer_info = Model('member')->getMemberInfo(array('member_id' => $member_id),'available_predeposit,member_paypwd');
  581. if ($buyer_info['member_paypwd'] == '' || $buyer_info['member_paypwd'] != md5($input['password'])) return ;
  582. $available_pd_amount = floatval($buyer_info['available_predeposit']);
  583. if ($available_pd_amount <= 0) return;
  584. $model_order = Model('order');
  585. $model_pd = Model('predeposit');
  586. foreach ($order_list as $order_info)
  587. {
  588. //货到付款的订单跳过
  589. if ($order_info['payment_code'] == 'offline') continue;
  590. $order_amount = floatval($order_info['order_amount']);
  591. $data_pd = array();
  592. $data_pd['member_id'] = $member_id;
  593. $data_pd['member_name'] = $member_name;
  594. $data_pd['amount'] = $order_info['order_amount'];
  595. $data_pd['order_sn'] = $order_info['order_sn'];
  596. if ($available_pd_amount >= $order_amount)
  597. {
  598. //预存款立即支付,订单支付完成
  599. $model_pd->changePd('order_pay',$data_pd);
  600. $available_pd_amount -= $order_amount;
  601. //记录订单日志(已付款)
  602. $data = array();
  603. $data['order_id'] = $order_info['order_id'];
  604. $data['log_role'] = 'buyer';
  605. $data['log_msg'] = L('order_log_pay');
  606. $data['log_orderstate'] = ORDER_STATE_PAY;
  607. $insert = $model_order->addOrderLog($data);
  608. if (!$insert) {
  609. throw new Exception('记录订单日志出现错误');
  610. }
  611. //订单状态 置为已支付
  612. $data_order = array();
  613. $data_order['order_state'] = ORDER_STATE_PAY;
  614. $data_order['payment_time'] = time();
  615. $data_order['payment_code'] = 'predeposit';
  616. $data_order['pd_amount'] = $order_amount;
  617. $result = $model_order->editOrder($data_order,array('order_id'=>$order_info['order_id']));
  618. if (!$result) {
  619. throw new Exception('订单更新失败');
  620. }
  621. // 发送商家提醒
  622. $param = array();
  623. $param['code'] = 'new_order';
  624. $param['store_id'] = $order_info['store_id'];
  625. $param['param'] = array(
  626. 'order_sn' => $order_info['order_sn']
  627. );
  628. QueueClient::push('sendStoreMsg', $param);
  629. }
  630. elseif ($available_pd_amount > 0) {
  631. //暂冻结预存款,后面还需要 API彻底完成支付
  632. $data_pd['amount'] = $available_pd_amount;
  633. $model_pd->changePd('order_freeze',$data_pd);
  634. //预存款支付金额保存到订单
  635. $data_order = array();
  636. $data_order['pd_amount'] = $available_pd_amount;
  637. $result = $model_order->editOrder($data_order,array('order_id'=>$order_info['order_id']));
  638. $available_pd_amount = 0;
  639. if (!$result) {
  640. throw new Exception('订单更新失败');
  641. }
  642. }
  643. }
  644. }
  645. /**
  646. * 整理发票信息
  647. * @param array $invoice_info 发票信息数组
  648. * @return string
  649. */
  650. private function _createInvoiceData($invoice_info){
  651. //发票信息
  652. $inv = array();
  653. if ($invoice_info['inv_state'] == 1) {
  654. $inv['类型'] = '普通发票 ';
  655. $inv['抬头'] = $invoice_info['inv_title_select'] == 'person' ? '个人' : $invoice_info['inv_title'];
  656. $inv['内容'] = $invoice_info['inv_content'];
  657. } elseif (!empty($invoice_info)) {
  658. $inv['单位名称'] = $invoice_info['inv_company'];
  659. $inv['纳税人识别号'] = $invoice_info['inv_code'];
  660. $inv['注册地址'] = $invoice_info['inv_reg_addr'];
  661. $inv['注册电话'] = $invoice_info['inv_reg_phone'];
  662. $inv['开户银行'] = $invoice_info['inv_reg_bname'];
  663. $inv['银行帐户'] = $invoice_info['inv_reg_baccount'];
  664. $inv['收票人姓名'] = $invoice_info['inv_rec_name'];
  665. $inv['收票人手机号'] = $invoice_info['inv_rec_mobphone'];
  666. $inv['收票人省份'] = $invoice_info['inv_rec_province'];
  667. $inv['送票地址'] = $invoice_info['inv_goto_addr'];
  668. }
  669. return !empty($inv) ? serialize($inv) : serialize(array());
  670. }
  671. /**
  672. * 计算本次下单中每个店铺订单是货到付款还是线上支付,店铺ID=>付款方式[online在线支付offline货到付款]
  673. * @param array $store_id_array 店铺ID数组
  674. * @param boolean $if_offpay 是否支持货到付款 true/false
  675. * @param string $pay_name 付款方式 online/offline
  676. * @return array
  677. */
  678. private function _getStorePayTypeList($store_id_array, $if_offpay, $pay_name) {
  679. $store_pay_type_list = array();
  680. if ($_POST['pay_name'] == 'online') {
  681. foreach ($store_id_array as $store_id) {
  682. $store_pay_type_list[$store_id] = 'online';
  683. }
  684. } else {
  685. $offline_pay = Model('payment')->getPaymentOpenInfo(array('payment_code'=>'offline'));
  686. if ($offline_pay) {
  687. //下单里包括平台自营商品并且平台已开启货到付款
  688. $offline_store_id_array = array(DEFAULT_PLATFORM_STORE_ID);
  689. foreach ($store_id_array as $store_id) {
  690. if (in_array($store_id,$offline_store_id_array)) {
  691. $store_pay_type_list[$store_id] = 'offline';
  692. } else {
  693. $store_pay_type_list[$store_id] = 'online';
  694. }
  695. }
  696. }
  697. }
  698. return $store_pay_type_list;
  699. }
  700. /**
  701. * 生成支付单编号(两位随机 + 从2000-01-01 00:00:00 到现在的秒数+微秒+会员ID%1000),该值会传给第三方支付接口
  702. * 长度 =2位 + 10位 + 3位 + 3位 = 18位
  703. * 1000个会员同一微秒提订单,重复机率为1/100
  704. * @return string
  705. */
  706. public function makePaySn($member_id) {
  707. return mt_rand(10,99)
  708. . sprintf('%010d',time() - 946656000)
  709. . sprintf('%03d', (float) microtime() * 1000)
  710. . sprintf('%03d', (int) $member_id % 1000);
  711. }
  712. /**
  713. * 订单编号生成规则,n(n>=1)个订单表对应一个支付表,
  714. * 生成订单编号(年取1位 + $pay_id取13位 + 第N个子订单取2位)
  715. * 1000个会员同一微秒提订单,重复机率为1/100
  716. * @param $pay_id 支付表自增ID
  717. * @return string
  718. */
  719. public function makeOrderSn($pay_id) {
  720. //记录生成子订单的个数,如果生成多个子订单,该值会累加
  721. static $num;
  722. if (empty($num)) {
  723. $num = 1;
  724. } else {
  725. $num ++;
  726. }
  727. return (date('y',time()) % 9+1) . sprintf('%013d', $pay_id) . sprintf('%02d', $num);
  728. }
  729. /**
  730. * 更新库存与销量
  731. *
  732. * @param array $buy_items 商品ID => 购买数量
  733. */
  734. public function editGoodsNum($buy_items) {
  735. //$model = Model()->table('goods');
  736. $model = Model('goods');
  737. foreach ($buy_items as $goods_id => $buy_num) {
  738. $data = array('goods_storage'=>array('exp','goods_storage-'.$buy_num),'goods_salenum'=>array('exp','goods_salenum+'.$buy_num));
  739. //$result = $model->where(array('goods_id'=>$goods_id))->update($data);
  740. $result = $model->editGoodsById($data, $goods_id);
  741. if (!$result) throw new Exception(L('cart_step2_submit_fail'));
  742. }
  743. }
  744. /**
  745. * 购买第一步
  746. *
  747. * @param array $cart_id 购物车
  748. * @param int $ifcart 是否为购物车
  749. * @param int $invalid_cart
  750. * @param int $member_id 会员编号
  751. * @param int $store_id 店铺编号
  752. */
  753. public function buyStep1($cart_id, $ifcart, $invalid_cart, $member_id, $store_id) {
  754. $model_cart = Model('cart');
  755. $result = array();
  756. //取得POST ID和购买数量
  757. $buy_items = $this->_parseItems($cart_id);
  758. if (count($buy_items) > 50) {
  759. return array('error' => '一次最多只可购买50种商品');
  760. }
  761. if ($ifcart) {
  762. //来源于购物车
  763. //取购物车列表
  764. $condition = array('cart_id'=>array('in',array_keys($buy_items)), 'buyer_id'=>$member_id);
  765. $cart_list = $model_cart->listCart('db', $condition);
  766. //取商品最新的在售信息
  767. $cart_list = $model_cart->getOnlineCartList($cart_list);
  768. //得到限时折扣信息
  769. $cart_list = $model_cart->getXianshiCartList($cart_list);
  770. //得到优惠套装状态,并取得组合套装商品列表
  771. $cart_list = $model_cart->getBundlingCartList($cart_list);
  772. //到得商品列表
  773. $goods_list = $model_cart->getGoodsList($cart_list);
  774. //购物车列表以店铺ID分组显示
  775. $store_cart_list = $model_cart->getStoreCartList($cart_list);
  776. //标识来源于购物车
  777. $result['ifcart'] = 1;
  778. } else {
  779. //来源于直接购买
  780. $goods_id = key($buy_items);
  781. $quantity = current($buy_items);
  782. //取得商品最新在售信息
  783. $goods_info = $model_cart->getGoodsOnlineInfo($goods_id,intval($quantity));
  784. if(empty($goods_info)) {
  785. return array('error' => '商品不存在');
  786. }
  787. //不能购买自己店铺的商品
  788. if ($goods_info['store_id'] == $store_id) {
  789. return array('error' => '不能购买自己店铺的商品' );
  790. }
  791. //判断是不是正在抢购中,如果是则按抢购价格计算,购买数量若超过抢购规定的上限,则按抢购上限计算
  792. $goods_info = $model_cart->getGroupbuyInfo($goods_info);
  793. //如果未进行抢购,则再判断是否限时折扣中
  794. if (!$goods_info['ifgroupbuy']) {
  795. $goods_info = $model_cart->getXianshiInfo($goods_info,$quantity);
  796. }
  797. //转成多维数组,方便纺一使用购物车方法与模板
  798. $store_cart_list = array();
  799. $goods_list = array();
  800. $goods_list[0] = $store_cart_list[$goods_info['store_id']][0] = $goods_info;
  801. }
  802. //商品金额计算(分别对每个商品/优惠套装小计、每个店铺小计)
  803. list($store_cart_list,$store_goods_total) = $model_cart->calcCartList($store_cart_list);
  804. $result['store_cart_list'] = $store_cart_list;
  805. $result['store_goods_total'] = $store_goods_total;
  806. //取得店铺优惠 - 满即送(赠品列表,店铺满送规则列表)
  807. list($store_premiums_list,$store_mansong_rule_list) = $model_cart->getMansongRuleCartListByTotal($store_goods_total);
  808. $result['store_premiums_list'] = $store_premiums_list;
  809. $result['store_mansong_rule_list'] = $store_mansong_rule_list;
  810. //重新计算优惠后(满即送)的店铺实际商品总金额
  811. $store_goods_total = $model_cart->reCalcGoodsTotal($store_goods_total,$store_mansong_rule_list,'mansong');
  812. $optional_goods = $this->_logic_buy_1->getOptionalGoods($store_cart_list);
  813. $store_goods_total = $this->_logic_buy_1->reCalcGoodsTotal($store_goods_total,$optional_goods,'optional_goods');
  814. //返回店铺可用的代金券
  815. $store_voucher_list = $model_cart->getStoreAvailableVoucherList($store_goods_total, $member_id);
  816. $result['store_voucher_list'] = $store_voucher_list;
  817. //返回需要计算运费的店铺ID数组 和 不需要计算运费(满免运费活动的)店铺ID及描述
  818. list($need_calc_sid_list,$cancel_calc_sid_list) = $this->getStoreFreightDescList($store_goods_total);
  819. $result['need_calc_sid_list'] = $need_calc_sid_list;
  820. $result['cancel_calc_sid_list'] = $cancel_calc_sid_list;
  821. //将商品ID、数量、运费模板、运费序列化,加密,输出到模板,选择地区AJAX计算运费时作为参数使用
  822. $freight_list = $this->getStoreFreightList($goods_list,array_keys($cancel_calc_sid_list));
  823. $result['freight_list'] = $this->buyEncrypt($freight_list, $member_id);
  824. //输出用户默认收货地址
  825. $result['address_info'] = Model('address')->getDefaultAddressInfo(array('member_id'=>$member_id));
  826. //输出有货到付款时,在线支付和货到付款及每种支付下商品数量和详细列表
  827. $pay_goods_list = $this->getOfflineGoodsPay($goods_list);
  828. if (!empty($pay_goods_list['offline'])) {
  829. $result['pay_goods_list'] = $pay_goods_list;
  830. $result['ifshow_offpay'] = true;
  831. } else {
  832. //如果所购商品只支持线上支付,支付方式不允许修改
  833. $result['deny_edit_payment'] = true;
  834. }
  835. //发票 :只有所有商品都支持增值税发票才提供增值税发票
  836. foreach ($goods_list as $goods) {
  837. if (!intval($goods['goods_vat'])) {
  838. $vat_deny = true;break;
  839. }
  840. }
  841. //不提供增值税发票时抛出true(模板使用)
  842. $result['vat_deny'] = $vat_deny;
  843. $result['vat_hash'] = $this->buyEncrypt($result['vat_deny'] ? 'deny_vat' : 'allow_vat', $member_id);
  844. //输出默认使用的发票信息
  845. $inv_info = Model('invoice')->getDefaultInvInfo(array('member_id'=>$member_id));
  846. if ($inv_info['inv_state'] == '2' && !$vat_deny) {
  847. $inv_info['content'] = '增值税发票 '.$inv_info['inv_company'].' '.$inv_info['inv_code'].' '.$inv_info['inv_reg_addr'];
  848. } elseif ($inv_info['inv_state'] == '2' && $vat_deny) {
  849. $inv_info = array();
  850. $inv_info['content'] = '不需要发票';
  851. } elseif (!empty($inv_info)) {
  852. $inv_info['content'] = '普通发票 '.$inv_info['inv_title'].' '.$inv_info['inv_content'];
  853. } else {
  854. $inv_info = array();
  855. $inv_info['content'] = '不需要发票';
  856. }
  857. $result['inv_info'] = $inv_info;
  858. //删除购物车中无效商品
  859. if ($ifcart) {
  860. if (is_array($invalid_cart)) {
  861. $cart_id_str = implode(',',$invalid_cart);
  862. if (preg_match_all('/^[\d,]+$/',$cart_id_str,$matches)) {
  863. $model_cart->delCart('db',array('buyer_id'=>$member_id,'cart_id'=>array('in',$cart_id_str)));
  864. }
  865. }
  866. }
  867. //显示使用预存款支付及会员预存款
  868. $model_payment = Model('payment');
  869. $pd_payment_info = $model_payment->getPaymentOpenInfo(array('payment_code'=>'predeposit'));
  870. if (!empty($pd_payment_info)) {
  871. $buyer_info = Model('member')->getMemberInfo(array('member_id' => $member_id),'available_predeposit,member_paypwd');
  872. if (floatval($buyer_info['available_predeposit']) > 0) {
  873. $result['available_predeposit'] = $buyer_info['available_predeposit'];
  874. $result['member_paypwd'] = $buyer_info['member_paypwd'] ? true : false;
  875. }
  876. }
  877. return $result;
  878. }
  879. /**
  880. * 购物车、直接购买第二步:保存订单入库,产生订单号,开始选择支付方式
  881. *
  882. */
  883. public function buyStep2($post, $member_id, $member_name, $member_email) {
  884. $model_cart = Model('cart');
  885. //取得商品ID和购买数量
  886. $input_buy_items = $this->_parseItems($post['cart_id']);
  887. //验证收货地址
  888. $input_address_id = intval($post['address_id']);
  889. if ($input_address_id <= 0) {
  890. return array('error' => '请选择收货地址');
  891. } else {
  892. $input_address_info = Model('address')->getAddressInfo(array('address_id'=>$input_address_id));
  893. if ($input_address_info['member_id'] != $member_id) {
  894. return array('error' => '请选择收货地址');
  895. }
  896. }
  897. //收货地址城市编号
  898. $input_city_id = intval($input_address_info['city_id']);
  899. //是否开增值税发票
  900. $input_if_vat = $this->buyDecrypt($post['vat_hash'], $member_id);
  901. if (!in_array($input_if_vat,array('allow_vat','deny_vat'))) {
  902. return array('error' => '订单保存出现异常,请重试');
  903. }
  904. $input_if_vat = ($input_if_vat == 'allow_vat') ? true : false;
  905. //是否支持货到付款
  906. $input_if_offpay = $this->buyDecrypt($post['offpay_hash'], $member_id);
  907. if (!in_array($input_if_offpay,array('allow_offpay','deny_offpay'))) {
  908. return array('error' => '订单保存出现异常,请重试');
  909. }
  910. $input_if_offpay = ($input_if_offpay == 'allow_offpay') ? true : false;
  911. //付款方式:在线支付/货到付款(online/offline)
  912. if (!in_array($post['pay_name'],array('online','offline'))) {
  913. return array('error' => '付款方式错误,请重新选择');
  914. }
  915. $input_pay_name = $post['pay_name'];
  916. //验证发票信息
  917. if (!empty($post['invoice_id'])) {
  918. $input_invoice_id = intval($post['invoice_id']);
  919. if ($input_invoice_id > 0) {
  920. $input_invoice_info = Model('invoice')->getinvInfo(array('inv_id'=>$input_invoice_id));
  921. if ($input_invoice_info['member_id'] != $member_id) {
  922. return array('error' => '请正确填写发票信息');
  923. }
  924. }
  925. }
  926. //验证代金券
  927. $input_voucher_list = array();
  928. if (is_array($post['voucher'])) {
  929. foreach ($post['voucher'] as $store_id => $voucher) {
  930. if (preg_match_all('/^(\d+)\|(\d+)\|([\d.]+)$/',$voucher,$matchs)) {
  931. if (floatval($matchs[3][0]) > 0) {
  932. $input_voucher_list[$store_id]['voucher_t_id'] = $matchs[1][0];
  933. $input_voucher_list[$store_id]['voucher_price'] = $matchs[3][0];
  934. }
  935. }
  936. }
  937. }
  938. if ($post['ifcart']) {
  939. //取购物车列表
  940. $condition = array('cart_id'=>array('in',array_keys($input_buy_items)),'buyer_id'=>$member_id);
  941. $cart_list = $model_cart->listCart('db',$condition);
  942. //取商品最新的在售信息
  943. $cart_list = $model_cart->getOnlineCartList($cart_list);
  944. //得到限时折扣信息
  945. $cart_list = $model_cart->getXianshiCartList($cart_list);
  946. //得到优惠套装状态,并取得组合套装商品列表
  947. $cart_list = $model_cart->getBundlingCartList($cart_list);
  948. //到得商品列表
  949. $goods_list = $model_cart->getGoodsList($cart_list);
  950. //购物车列表以店铺ID分组显示
  951. $store_cart_list = $model_cart->getStoreCartList($cart_list);
  952. } else {
  953. //来源于直接购买
  954. //取得购买的商品ID和购买数量,只有有一个下标 ,只会循环一次
  955. foreach ($input_buy_items as $goods_id => $quantity) {break;}
  956. //取得商品最新在售信息
  957. $goods_info = $model_cart->getGoodsOnlineInfo($goods_id,$quantity);
  958. if(empty($goods_info)) {
  959. return array('error' => '商品不存在');
  960. }
  961. //判断是不是正在抢购中,如果是则按抢购价格计算,购买数量若超过抢购规定的上限,则按抢购上限计算
  962. $goods_info = $model_cart->getGroupbuyInfo($goods_info);
  963. //如果未进行抢购,则再判断是否限时折扣中
  964. if (!$goods_info['ifgroupbuy']) {
  965. $goods_info = $model_cart->getXianshiInfo($goods_info,$quantity);
  966. } else {
  967. //这里记录一下抢购数量,订单完成后需要更新一下抢购表信息
  968. $groupbuy_info = array();
  969. $groupbuy_info['groupbuy_id'] = $goods_info['groupbuy_id'];
  970. $groupbuy_info['quantity'] = $quantity;
  971. }
  972. //转成多维数组,方便统一使用购物车方法与模板
  973. $store_cart_list = array();
  974. $goods_list = array();
  975. $goods_list[0] = $store_cart_list[$goods_info['store_id']][0] = $goods_info;
  976. }
  977. //商品金额计算(分别对每个商品/优惠套装小计、每个店铺小计)
  978. list($store_cart_list,$store_goods_total) = $model_cart->calcCartList($store_cart_list);
  979. //取得店铺优惠 - 满即送(赠品列表,店铺满送规则列表)
  980. list($store_premiums_list,$store_mansong_rule_list) = $model_cart->getMansongRuleCartListByTotal($store_goods_total);
  981. //重新计算店铺扣除满即送后商品实际支付金额
  982. $store_goods_total = $model_cart->reCalcGoodsTotal($store_goods_total,$store_mansong_rule_list,'mansong');
  983. $optional_goods = $this->_logic_buy_1->getOptionalGoods($store_cart_list);
  984. $store_final_goods_total = $this->_logic_buy_1->reCalcGoodsTotal($store_goods_total,$optional_goods,'optional_goods');
  985. //得到有效的代金券
  986. $input_voucher_list = $model_cart->reParseVoucherList($input_voucher_list,$store_goods_total,$member_id);
  987. //重新计算店铺扣除优惠券送商品实际支付金额
  988. $store_final_goods_total = $model_cart->reCalcGoodsTotal($store_final_goods_total,$input_voucher_list,'voucher');
  989. //计算每个店铺(所有店铺级优惠活动)总共优惠多少
  990. $store_promotion_total = $this->getStorePromotionTotal($store_goods_total, $store_final_goods_total);
  991. //计算每个店铺运费
  992. list($need_calc_sid_list,$cancel_calc_sid_list) = $this->getStoreFreightDescList($store_final_goods_total);
  993. $freight_list = $this->getStoreFreightList($goods_list,array_keys($cancel_calc_sid_list));
  994. $store_freight_total = $this->calcStoreFreight($freight_list,$input_city_id);
  995. //计算店铺最终订单实际支付金额(加上运费)
  996. $store_final_order_total = $model_cart->reCalcGoodsTotal($store_final_goods_total,$store_freight_total,'freight');
  997. //计算店铺分类佣金
  998. $store_gc_id_commis_rate_list = $this->getStoreGcidCommisRateList($goods_list);
  999. //将赠品追加到购买列表(如果库存不足,则不送赠品)
  1000. $append_premiums_to_cart_list = $this->appendPremiumsToCartList($store_cart_list,$store_premiums_list,$store_mansong_rule_list,$member_id);
  1001. if(!empty($append_premiums_to_cart_list['error'])) {
  1002. return array('error' => $append_premiums_to_cart_list['error']);
  1003. } else {
  1004. list($store_cart_list,$goods_buy_quantity,$store_mansong_rule_list) = $append_premiums_to_cart_list;
  1005. }
  1006. //整理已经得出的固定数据,准备下单
  1007. $input = array();
  1008. $input['pay_name'] = $input_pay_name;
  1009. $input['if_offpay'] = $input_if_offpay;
  1010. $input['if_vat'] = $input_if_vat;
  1011. $input['pay_message'] = $post['pay_message'];
  1012. $input['address_info'] = $input_address_info;
  1013. $input['invoice_info'] = $input_invoice_info;
  1014. $input['voucher_list'] = $input_voucher_list;
  1015. $input['store_goods_total'] = $store_goods_total;
  1016. $input['store_final_order_total'] = $store_final_order_total;
  1017. $input['store_freight_total'] = $store_freight_total;
  1018. $input['store_promotion_total'] = $store_promotion_total;
  1019. $input['store_gc_id_commis_rate_list'] = $store_gc_id_commis_rate_list;
  1020. $input['store_mansong_rule_list'] = $store_mansong_rule_list;
  1021. $input['store_cart_list'] = $store_cart_list;
  1022. $input['input_city_id'] = $input_city_id;//货到付款 by 3 3 hao.com
  1023. try {
  1024. //开始事务
  1025. $trans = new trans_wapper($model_cart,__METHOD__);
  1026. //生成订单
  1027. list($pay_sn,$order_list) = $this->createOrder($input, $member_id, $member_name, $member_email);
  1028. //记录订单日志
  1029. $this->addOrderLog($order_list);
  1030. //变更库存和销量
  1031. $this->updateGoodsStorageNum($goods_buy_quantity);
  1032. //使用预存款支付
  1033. $this->pdPay($order_list, $post, $member_id, $member_name);
  1034. //提交事务
  1035. $trans->commit();
  1036. }
  1037. catch (Exception $e){
  1038. $trans->rollback();
  1039. return array('error' => $e->getMessage());
  1040. }
  1041. //更新使用的代金券状态
  1042. if (!empty($input_voucher_list) && is_array($input_voucher_list)) {
  1043. QueueClient::push('editVoucherState', $input_voucher_list);
  1044. }
  1045. //更新抢购购买人数和数量
  1046. if (!empty($groupbuy_info) && is_array($groupbuy_info)) {
  1047. QueueClient::push('editGroupbuySaleCount', $groupbuy_info);
  1048. }
  1049. //更新收货人所在省份
  1050. QueueClient::push('editReciverProid', array('order_ids'=>array_keys($order_list),'area_id'=>$input_city_id));
  1051. //删除购物车中的商品
  1052. if ($post['ifcart']) {
  1053. $model_cart->delCart('db',array('buyer_id'=>$member_id,'cart_id'=>array('in',array_keys($input_buy_items))));
  1054. //QueueClient::push('delCart', array('buyer_id'=>$member_id,'cart_ids'=>array_keys($input_buy_items)));
  1055. }
  1056. return array('pay_sn' => $pay_sn);
  1057. }
  1058. /**
  1059. * 加密
  1060. * @param array/string $string
  1061. * @param int $member_id
  1062. * @return mixed arrray/string
  1063. */
  1064. public function buyEncrypt($string, $member_id) {
  1065. $buy_key = sha1(md5($member_id.'&'.MD5_KEY));
  1066. if (is_array($string)) {
  1067. $string = serialize($string);
  1068. } else {
  1069. $string = strval($string);
  1070. }
  1071. return encrypt(base64_encode($string), $buy_key);
  1072. }
  1073. /**
  1074. * 解密
  1075. * @param string $string
  1076. * @param int $member_id
  1077. * @param number $ttl
  1078. */
  1079. public function buyDecrypt($string, $member_id, $ttl = 0) {
  1080. $buy_key = sha1(md5($member_id.'&'.MD5_KEY));
  1081. if (empty($string)) return;
  1082. $string = base64_decode(decrypt(strval($string), $buy_key, $ttl));
  1083. return ($tmp = @unserialize($string)) ? $tmp : $string;
  1084. }
  1085. /**
  1086. * 得到所购买的id和数量
  1087. *
  1088. */
  1089. private function _parseItems($cart_id) {
  1090. //存放所购商品ID和数量组成的键值对
  1091. $buy_items = array();
  1092. if (is_array($cart_id)) {
  1093. foreach ($cart_id as $value) {
  1094. if (preg_match_all('/^(\d{1,10})\|(\d{1,6})$/', $value, $match)) {
  1095. $buy_items[$match[1][0]] = $match[2][0];
  1096. }
  1097. }
  1098. }
  1099. return $buy_items;
  1100. }
  1101. /**
  1102. * 选择不同地区时,异步处理并返回每个店铺总运费以及本地区是否能使用货到付款
  1103. * 如果店铺统一设置了满免运费规则,则运费模板无效
  1104. * 如果店铺未设置满免规则,且使用运费模板,按运费模板计算,如果其中有商品使用相同的运费模板,则两种商品数量相加后再应用该运费模板计算(即作为一种商品算运费)
  1105. * 如果未找到运费模板,按免运费处理
  1106. * 如果没有使用运费模板,商品运费按快递价格计算,运费不随购买数量增加
  1107. */
  1108. public function changeAddr($freight_hash, $city_id, $area_id, $member_id) {
  1109. //$city_id计算运费模板,$area_id计算货到付款
  1110. $city_id = intval($city_id);
  1111. $area_id = intval($area_id);
  1112. if ($city_id <= 0 || $area_id <= 0) return null;
  1113. //将hash解密,得到运费信息(店铺ID,运费,运费模板ID,购买数量),hash内容有效期为1小时
  1114. $freight_list = $this->buyDecrypt($freight_hash, $member_id);
  1115. //算运费
  1116. $store_freight_list = $this->calcStoreFreight($freight_list, $city_id);
  1117. $data = array();
  1118. $data['state'] = empty($store_freight_list) ? 'fail' : 'success';
  1119. $data['content'] = $store_freight_list;
  1120. //是否能使用货到付款(只有包含平台店铺的商品才会判断)
  1121. $if_include_platform_store = array_key_exists(DEFAULT_PLATFORM_STORE_ID,$freight_list['iscalced']) || array_key_exists(DEFAULT_PLATFORM_STORE_ID,$freight_list['nocalced']);
  1122. if ($if_include_platform_store) {
  1123. $allow_offpay = Model('offpay_area')->checkSupportOffpay($area_id,DEFAULT_PLATFORM_STORE_ID);
  1124. }
  1125. //JS验证使用
  1126. $data['allow_offpay'] = $allow_offpay ? '1' : '0';
  1127. //PHP验证使用
  1128. $data['offpay_hash'] = $this->buyEncrypt($allow_offpay ? 'allow_offpay' : 'deny_offpay', $member_id);
  1129. return $data;
  1130. }
  1131. }